|
|
@@ -1,5 +1,6 @@
|
|
|
package com.steerinfo.meterwork.meterworkcaractual.service.impl;
|
|
|
|
|
|
+import com.github.pagehelper.util.StringUtil;
|
|
|
import com.steerinfo.baseinfo.meterbasematterinfomatch.mapper.MeterBaseMatterInfoMatchMapper;
|
|
|
import com.steerinfo.baseinfo.meterbasematterinfomatch.model.MeterBaseMatterInfoMatch;
|
|
|
import com.steerinfo.baseinfo.meterbaseoperationlog.mapper.MeterBaseOperationLogMapper;
|
|
|
@@ -14,6 +15,8 @@ import com.steerinfo.framework.service.impl.BaseServiceImpl;
|
|
|
import com.steerinfo.framework.service.pagehelper.PageHelper;
|
|
|
import com.steerinfo.framework.service.pagehelper.PageList;
|
|
|
import com.steerinfo.framework.user.UserPayload;
|
|
|
+import com.steerinfo.metermonitor.metermonitornote.mapper.MeterMonitorNoteMapper;
|
|
|
+import com.steerinfo.metermonitor.metermonitornote.model.MeterMonitorNote;
|
|
|
import com.steerinfo.meterwork.constants.DbConstants;
|
|
|
import com.steerinfo.meterwork.except.MarkerMetException;
|
|
|
import com.steerinfo.meterwork.metertolimsold.mapper.MeterToLimsOldMapper;
|
|
|
@@ -32,7 +35,6 @@ import com.steerinfo.meterwork.meterworkrailwayactual.mapper.MeterWorkRailwayAct
|
|
|
import com.steerinfo.meterwork.meterworkrailwayactual.model.MeterWorkRailwayActual;
|
|
|
import com.steerinfo.meterwork.meterworkscheduledhelp.mapper.MeterWorkScheduledHelpMapper;
|
|
|
import com.steerinfo.meterwork.meterworkscheduledhelp.model.MeterWorkScheduledHelp;
|
|
|
-import com.steerinfo.pretrack.prerailwayscale.model.PreRailwayScale;
|
|
|
import com.steerinfo.pretrack.pretracknotice.mapper.PreTrackNoticeMapper;
|
|
|
import com.steerinfo.pretrack.pretracknotice.model.PreTrackNotice;
|
|
|
import com.steerinfo.pretrack.pretrackscale.mapper.PreTrackScaleMapper;
|
|
|
@@ -41,18 +43,17 @@ import com.steerinfo.util.CommonPage;
|
|
|
import com.steerinfo.util.FieldsCollector;
|
|
|
import com.steerinfo.util.PublicMethod;
|
|
|
import com.steerinfo.util.StringUtils;
|
|
|
-import org.apache.catalina.User;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
|
|
import org.springframework.util.Assert;
|
|
|
-import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import javax.sql.DataSource;
|
|
|
import java.math.BigDecimal;
|
|
|
+import java.text.ParseException;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
@@ -100,6 +101,9 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
@Resource
|
|
|
private MeterBaseOperationLogMapper meterBaseOperationLogMapper;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private MeterMonitorNoteMapper meterMonitorNoteMapper;
|
|
|
+
|
|
|
@Autowired
|
|
|
IMeterWorkPreLinkService meterWorkPreLinkService;
|
|
|
|
|
|
@@ -226,7 +230,7 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
}
|
|
|
PreTrackScale scale = preTrackScaleMapper.selectByPrimaryKey(model.getPredictionNo());
|
|
|
if(scale != null && scale.getValueFlag().equals("9")) {
|
|
|
- throw new MarkerMetException(500, "只有未结算的洁净数据才能进行撤销发布操作");
|
|
|
+ throw new MarkerMetException(500, "只有未结算的结净数据才能进行撤销发布操作");
|
|
|
}
|
|
|
check(model);
|
|
|
model.setValueFlag("1"); // 状态改为未发布
|
|
|
@@ -424,6 +428,19 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
actualRow.setUpdateTime(new Date());
|
|
|
meterWorkCarActualMapper.insertSelective(actualRow);
|
|
|
|
|
|
+ MeterBaseOperationLog logModel = new MeterBaseOperationLog();
|
|
|
+ logModel.setId(PublicMethod.IdCreate(2));
|
|
|
+ logModel.setCreateManNo(userId);
|
|
|
+ logModel.setCreateManName(userName);
|
|
|
+ logModel.setCreateTime(new Date());
|
|
|
+ logModel.setOperationPage("web端-汽车衡一次数据维护");
|
|
|
+ logModel.setOperationFunction("毛皮结净");
|
|
|
+ logModel.setOperationId(actualRow.getActualNo());
|
|
|
+ logModel.setOperationPredictionNo(actualRow.getPredictionNo());
|
|
|
+ logModel.setOperationCarnNo(actualRow.getCarNo());
|
|
|
+ logModel.setOperationBeforeFix(actualRow.getActualFirst1No()+ "," + actualRow.getActualFirst2No());
|
|
|
+ meterBaseOperationLogMapper.insertSelective(logModel);
|
|
|
+
|
|
|
PreTrackScale scale = preTrackScaleMapper.selectByPrimaryKey(predictionNo);
|
|
|
scale.setValueFlag(DbConstants.NET);
|
|
|
scale.setUpdateTime(new Date());
|
|
|
@@ -512,6 +529,19 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
actualRow.setUpdateTime(new Date());
|
|
|
meterWorkCarActualMapper.insertSelective(actualRow);
|
|
|
|
|
|
+ MeterBaseOperationLog logModel = new MeterBaseOperationLog();
|
|
|
+ logModel.setId(PublicMethod.IdCreate(2));
|
|
|
+ logModel.setCreateManNo(userId);
|
|
|
+ logModel.setCreateManName(userName);
|
|
|
+ logModel.setCreateTime(new Date());
|
|
|
+ logModel.setOperationPage("web端-汽车衡一次数据维护");
|
|
|
+ logModel.setOperationFunction("毛皮结净");
|
|
|
+ logModel.setOperationId(actualRow.getActualNo());
|
|
|
+ logModel.setOperationPredictionNo(actualRow.getPredictionNo());
|
|
|
+ logModel.setOperationCarnNo(actualRow.getCarNo());
|
|
|
+ logModel.setOperationBeforeFix(actualRow.getActualFirst1No()+ "," + actualRow.getActualFirst2No());
|
|
|
+ meterBaseOperationLogMapper.insertSelective(logModel);
|
|
|
+
|
|
|
scale.setValueFlag(DbConstants.NET);
|
|
|
scale.setUpdateTime(new Date());
|
|
|
scale.setUpdateManNo("system");
|
|
|
@@ -584,6 +614,19 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
actualRow.setUpdateManName(userName);
|
|
|
actualRow.setUpdateTime(new Date());
|
|
|
meterWorkCarActualMapper.insertSelective(actualRow);
|
|
|
+
|
|
|
+ MeterBaseOperationLog logModel = new MeterBaseOperationLog();
|
|
|
+ logModel.setId(PublicMethod.IdCreate(2));
|
|
|
+ logModel.setCreateManNo(userId);
|
|
|
+ logModel.setCreateManName(userName);
|
|
|
+ logModel.setCreateTime(new Date());
|
|
|
+ logModel.setOperationPage("web端-汽车衡一次数据维护");
|
|
|
+ logModel.setOperationFunction("毛皮结净");
|
|
|
+ logModel.setOperationId(actualRow.getActualNo());
|
|
|
+ logModel.setOperationPredictionNo(actualRow.getPredictionNo());
|
|
|
+ logModel.setOperationCarnNo(actualRow.getCarNo());
|
|
|
+ logModel.setOperationBeforeFix(actualRow.getActualFirst1No()+ "," + actualRow.getActualFirst2No());
|
|
|
+ meterBaseOperationLogMapper.insertSelective(logModel);
|
|
|
}
|
|
|
return actualRow;
|
|
|
} catch (MarkerMetException e) {
|
|
|
@@ -694,26 +737,27 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
}
|
|
|
// }
|
|
|
//meterWorkCarActualMapper.deleteByPrimaryKey(model.getActualNo());
|
|
|
- model.setUploadFlag("1");
|
|
|
- model.setValueFlag("0");
|
|
|
- model.setIsPreScale("0");
|
|
|
- model.setUpdateManNo(userId);
|
|
|
- model.setUpdateManName(userName);
|
|
|
- model.setUpdateTime(new Date());
|
|
|
- meterWorkCarActualMapper.updateByPrimaryKey(model);
|
|
|
+ MeterWorkCarActual modelTemp = meterWorkCarActualMapper.cleanPredcition(model.getActualNo());
|
|
|
+ modelTemp.setUploadFlag("1");
|
|
|
+ modelTemp.setValueFlag("0");
|
|
|
+ modelTemp.setIsPreScale("0");
|
|
|
+ modelTemp.setUpdateManNo(userId);
|
|
|
+ modelTemp.setUpdateManName(userName);
|
|
|
+ modelTemp.setUpdateTime(new Date());
|
|
|
+ meterWorkCarActualMapper.updateByPrimaryKey(modelTemp);
|
|
|
|
|
|
MeterBaseOperationLog logModel = new MeterBaseOperationLog();
|
|
|
logModel.setId(PublicMethod.IdCreate(2));
|
|
|
logModel.setCreateManNo(userId);
|
|
|
logModel.setCreateManName(userName);
|
|
|
logModel.setCreateTime(new Date());
|
|
|
- logModel.setOperationPage("汽车衡净重数据维护");
|
|
|
- logModel.setOperationFunction("汽车衡结净毛皮分解");
|
|
|
+ logModel.setOperationPage("web端-汽车衡净重数据维护");
|
|
|
+ logModel.setOperationFunction("毛皮分解");
|
|
|
logModel.setOperationId(model.getActualNo());
|
|
|
logModel.setOperationPredictionNo(model.getPredictionNo());
|
|
|
logModel.setOperationCarnNo(model.getCarNo());
|
|
|
logModel.setOperationBeforeFix(model.toString());
|
|
|
- logModel.setOperationAfterFix("");
|
|
|
+ logModel.setOperationAfterFix(modelTemp.toString());
|
|
|
meterBaseOperationLogMapper.insertSelective(logModel);
|
|
|
num++;
|
|
|
}
|
|
|
@@ -806,6 +850,16 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
return rm;
|
|
|
}
|
|
|
}
|
|
|
+ String userId = "";
|
|
|
+ String userName = "";
|
|
|
+ try{
|
|
|
+ UserPayload userPayload = UserPayload.getCurrUser();
|
|
|
+ userId = userPayload.getUserCode();
|
|
|
+ userName = userPayload.getUserName();
|
|
|
+ }catch (Exception e) {
|
|
|
+ userId = "system";
|
|
|
+ userName = "system";
|
|
|
+ }
|
|
|
switch(type){
|
|
|
case "5":
|
|
|
case "6":
|
|
|
@@ -855,16 +909,16 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
|
|
|
MeterBaseOperationLog logModel = new MeterBaseOperationLog();
|
|
|
logModel.setId(PublicMethod.IdCreate(2));
|
|
|
- logModel.setCreateManNo(modelTemp.getUpdateManNo());
|
|
|
- logModel.setCreateManName(modelTemp.getUpdateManName());
|
|
|
+ logModel.setCreateManNo(userId);
|
|
|
+ logModel.setCreateManName(userName);
|
|
|
logModel.setCreateTime(new Date());
|
|
|
logModel.setOperationPage("web端-汽车衡净重数据维护");
|
|
|
if(type.equals("5")){
|
|
|
- logModel.setOperationFunction("取消双委托洁净");
|
|
|
+ logModel.setOperationFunction("取消双委托结净");
|
|
|
}else if(type.equals("6")) {
|
|
|
- logModel.setOperationFunction("取消混卸洁净");
|
|
|
+ logModel.setOperationFunction("取消混卸结净");
|
|
|
}else if(type.equals("7")) {
|
|
|
- logModel.setOperationFunction("取消混装洁净");
|
|
|
+ logModel.setOperationFunction("取消混装结净");
|
|
|
}
|
|
|
logModel.setOperationId(model.getActualNo());
|
|
|
logModel.setOperationPredictionNo(model.getPredictionNo());
|
|
|
@@ -1045,7 +1099,7 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
logModel.setCreateManName(userName);
|
|
|
logModel.setCreateTime(new Date());
|
|
|
logModel.setOperationPage("web端-汽车衡净重数据维护");
|
|
|
- logModel.setOperationFunction("洁净废除");
|
|
|
+ logModel.setOperationFunction("结净废除");
|
|
|
logModel.setOperationId(model.getActualNo());
|
|
|
logModel.setOperationPredictionNo(model.getPredictionNo());
|
|
|
logModel.setOperationCarnNo(model.getRailwayNo());
|
|
|
@@ -1147,6 +1201,10 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
@Override
|
|
|
public PageList<MeterWorkCarActual> likeByDesc(HashMap<String, Object> params, Integer pageNum, Integer pageSize) {
|
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
|
+ if(params.get("netSpot3NoStr") != null) {
|
|
|
+ String[] spotNoStr = params.get("netSpot3NoStr").toString().split(",");
|
|
|
+ params.put("spotNoStr", spotNoStr);
|
|
|
+ }
|
|
|
List<MeterWorkCarActual> rows = meterWorkCarActualMapper.likeByDesc(params);
|
|
|
PageList pageInfo = new PageList(rows);
|
|
|
return pageInfo;
|
|
|
@@ -1218,6 +1276,16 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
return rm;
|
|
|
}
|
|
|
|
|
|
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ if(model.getUpdateTime() != null && StringUtils.isNotEmpty(model.getUpdateTime().toString())) {
|
|
|
+ long eTime = df.parse(model.getUpdateTime().toString()).getTime();
|
|
|
+ long sTime = df.parse((new Date()).toString()).getTime();
|
|
|
+ long diff = (eTime - sTime) / 1000;
|
|
|
+ if(diff <= 15) {
|
|
|
+ throw new MarkerMetException(500, "匹配委托需在解除委托15秒后进行,请稍等");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
if(scale == null) {
|
|
|
rm.setMessage("不存在对应的预报数据,请确认!!");
|
|
|
return rm;
|
|
|
@@ -1320,6 +1388,21 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
MeterWorkCarActual mwcaquery = meterWorkCarActualMapper.selectByPrimaryKey(model.getActualNo());
|
|
|
if (mwcaquery == null) {
|
|
|
throw new MarkerMetException(500, "不存在对应的结净数据");
|
|
|
+ }else {
|
|
|
+ try{
|
|
|
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ if(mwcaquery.getUpdateTime() != null && StringUtils.isNotEmpty(mwcaquery.getUpdateTime().toString())) {
|
|
|
+ long eTime = df.parse(mwcaquery.getUpdateTime().toString()).getTime();
|
|
|
+ long sTime = df.parse((new Date()).toString()).getTime();
|
|
|
+ long diff = (eTime - sTime) / 1000;
|
|
|
+ if(diff <= 15) {
|
|
|
+ throw new MarkerMetException(500, "解除委托需在匹配委托15秒后进行,请稍等");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (ParseException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ throw new MarkerMetException(500, "操作异常");
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
PreTrackScale scaleTemp = preTrackScaleMapper.selectByPrimaryKey(model.getPredictionNo());
|
|
|
@@ -2525,11 +2608,14 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
public List<HashMap> countAllSpotSate(HashMap params) {
|
|
|
List<HashMap> map = new ArrayList<>();
|
|
|
|
|
|
- //根据时间查询所有秤点的洁净已匹配、洁净未匹配、洁净已上传、洁净未上传、已作废数据
|
|
|
+ //根据时间查询所有秤点的结净已匹配、结净未匹配、结净已上传、结净未上传、已作废数据
|
|
|
List<MeterWorkCarActual> carActual = meterWorkCarActualMapper.countAllState(params);
|
|
|
List<MeterWorkCarActualFirst> carFirst = meterWorkCarActualFirstMapper.countAllState(params);
|
|
|
List<MeterWorkScheduledHelp> carHelp = meterWorkScheduledHelpMapper.countAllState(params);
|
|
|
- List<HashMap> carLog = meterBaseOperationLogMapper.countAllState(params);
|
|
|
+ List<HashMap> carFirstLog = meterBaseOperationLogMapper.countAllFirstState(params);
|
|
|
+ List<HashMap> carActualLog = meterBaseOperationLogMapper.countAllActualState(params);
|
|
|
+ List<MeterMonitorNote> carMonitorLog = meterMonitorNoteMapper.countAllState(params);
|
|
|
+ List<MeterMonitorNote> countResetCarLog = meterMonitorNoteMapper.countResetCar(params);
|
|
|
//.map(MeterWorkCarActual::getCarNo).distinct().collect(Collectors.toList());
|
|
|
// List<String> spotList = carActual.stream().map(MeterWorkCarActual::getNetSpot3Name).distinct().collect(Collectors.toList());
|
|
|
|
|
|
@@ -2544,29 +2630,29 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
long countUpload = 0L;
|
|
|
long countUnUpload = 0L;
|
|
|
long countActualValid = 0L;
|
|
|
- if(carActual != null) {
|
|
|
- //洁净已匹配
|
|
|
+ if(carActual != null && carActual.size() >= 1) {
|
|
|
+ //结净已匹配
|
|
|
countIsPrescale = carActual.stream().filter(model -> model.getNetSpot3No().equals(spot.getBaseSpotNo())
|
|
|
&& model.getNetSpot3Name().equals(spot.getBaseSpotName())
|
|
|
&& model.getValueFlag().equals("1")
|
|
|
&& model.getIsPreScale().equals("1")).count();
|
|
|
- //洁净未匹配
|
|
|
+ //结净未匹配
|
|
|
countIsNotPrescale = carActual.stream().filter(model -> model.getNetSpot3No().equals(spot.getBaseSpotNo())
|
|
|
&& model.getNetSpot3Name().equals(spot.getBaseSpotName())
|
|
|
&& model.getValueFlag().equals("1")
|
|
|
&& model.getIsPreScale().equals("0")).count();
|
|
|
- //洁净已上传
|
|
|
+ //结净已上传
|
|
|
countUpload = carActual.stream().filter(model -> model.getNetSpot3No().equals(spot.getBaseSpotNo())
|
|
|
&& model.getNetSpot3Name().equals(spot.getBaseSpotName())
|
|
|
&& model.getValueFlag().equals("1")
|
|
|
&& model.getIsPreScale().equals("1")
|
|
|
&& model.getUploadFlag().equals("2")).count();
|
|
|
- //洁净未上传
|
|
|
+ //结净未上传
|
|
|
countUnUpload = carActual.stream().filter(model -> model.getNetSpot3No().equals(spot.getBaseSpotNo())
|
|
|
&& model.getNetSpot3Name().equals(spot.getBaseSpotName())
|
|
|
&& !model.getUploadFlag().equals("2")
|
|
|
&& !model.getIsPreScale().equals("0")).count();
|
|
|
- //洁净数据已作废
|
|
|
+ //结净数据已作废
|
|
|
countActualValid = carActual.stream().filter(model -> model.getNetSpot3No().equals(spot.getBaseSpotNo())
|
|
|
&& model.getNetSpot3Name().equals(spot.getBaseSpotName())
|
|
|
&& model.getValueFlag().equals("0")).count();
|
|
|
@@ -2575,24 +2661,30 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
long countGross = 0L;
|
|
|
long countTare = 0L;
|
|
|
long countTermTare = 0L;
|
|
|
+ long countNullWeightType = 0L;
|
|
|
long countFirst = 0L;
|
|
|
long countFirstValid = 0L;
|
|
|
- if(carFirst != null) {
|
|
|
+ if(carFirst != null && carFirst.size() >= 1) {
|
|
|
//一次毛重
|
|
|
- countGross = carFirst.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ countGross = carFirst.stream().filter(model -> StringUtils.isNotEmpty(model.getWeightType()) && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
&& model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
&& !model.getValueFlag().equals("0")
|
|
|
&& model.getWeightType().equals("0")).count();
|
|
|
//一次皮重
|
|
|
- countTare = carFirst.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ countTare = carFirst.stream().filter(model -> StringUtils.isNotEmpty(model.getWeightType()) && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
&& model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
&& !model.getValueFlag().equals("0")
|
|
|
- && model.getValueFlag().equals("1")).count();
|
|
|
+ && model.getWeightType().equals("1")).count();
|
|
|
//一次期限皮重
|
|
|
- countTermTare = carFirst.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ countTermTare = carFirst.stream().filter(model -> StringUtils.isNotEmpty(model.getWeightType()) && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
&& model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
&& !model.getValueFlag().equals("0")
|
|
|
&& model.getWeightType().equals("2")).count();
|
|
|
+ //一次无重量类型
|
|
|
+ countNullWeightType = carFirst.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && !model.getValueFlag().equals("0")
|
|
|
+ && StringUtil.isEmpty(model.getWeightType())).count();
|
|
|
//仅一次有效
|
|
|
countFirst = carFirst.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
&& model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
@@ -2606,7 +2698,11 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
long countCarHelp = 0L;
|
|
|
long countCarHelpIsNotValue = 0L;
|
|
|
long countCarHelpIsValue = 0L;
|
|
|
- if(carHelp != null) {
|
|
|
+ long countCarHelpRfid = 0L;
|
|
|
+ long countCarHelpScanningCode = 0L;
|
|
|
+ long countCarHelpNormal = 0L;
|
|
|
+ long countCarHelpVehicleReset = 0L;
|
|
|
+ if(carHelp != null && carHelp.size() >= 1) {
|
|
|
//报警总数
|
|
|
countCarHelp = carHelp.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
&& model.getBaseSpotName().equals(spot.getBaseSpotName())).count();
|
|
|
@@ -2618,34 +2714,171 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
countCarHelpIsValue = carHelp.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
&& model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
&& model.getValueFlag().equals("1")).count();
|
|
|
+ //报警Rfid
|
|
|
+ countCarHelpRfid = carHelp.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getHelpContent().equals("rfid")).count();
|
|
|
+ //报警扫码
|
|
|
+ countCarHelpScanningCode = carHelp.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getHelpContent().equals("扫码")).count();
|
|
|
+ //报警正常
|
|
|
+ countCarHelpNormal = carHelp.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getHelpContent().equals("正常")).count();
|
|
|
+ //报警车号重置
|
|
|
+ countCarHelpVehicleReset = carHelp.stream().filter(model -> model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getHelpContent().equals("车号重置")).count();
|
|
|
}
|
|
|
|
|
|
- long countLogIsPreScale = 0L;
|
|
|
- long countLogIsNotPreScale = 0L;
|
|
|
- long countLogUpdateCar = 0L;
|
|
|
- long countLogValid = 0L;
|
|
|
- long countLogRecover = 0L;
|
|
|
- if(carLog != null) {
|
|
|
+ long countLogFirstIsPreScale = 0L;
|
|
|
+ long countLogFirstIsNotPreScale = 0L;
|
|
|
+ long countLogFirstUpdateCar = 0L;
|
|
|
+ long countLogFirstValid = 0L;
|
|
|
+ long countLogFirstRecover = 0L;
|
|
|
+ if(carFirstLog != null && carFirstLog.size() >= 1) {
|
|
|
//日志一次处理匹配委托
|
|
|
- countLogIsPreScale = carLog.stream().filter(model -> model.get("baseSpotNo").equals(spot.getBaseSpotNo())
|
|
|
- && model.get("baseSpotName").equals(spot.getBaseSpotName())
|
|
|
- && model.get("operationFunction").equals("汽车衡匹配委托")).count();
|
|
|
- countLogIsNotPreScale = carLog.stream().filter(model -> model.get("baseSpotNo").equals(spot.getBaseSpotNo())
|
|
|
- && model.get("baseSpotName").equals(spot.getBaseSpotName())
|
|
|
- && model.get("operationFunction").equals("汽车衡撤销委托")).count();
|
|
|
- countLogUpdateCar = carLog.stream().filter(model -> model.get("baseSpotNo").equals(spot.getBaseSpotNo())
|
|
|
- && model.get("baseSpotName").equals(spot.getBaseSpotName())
|
|
|
- && model.get("operationFunction").equals("车号修改")).count();
|
|
|
- countLogValid = carLog.stream().filter(model -> model.get("baseSpotNo").equals(spot.getBaseSpotNo())
|
|
|
- && model.get("baseSpotName").equals(spot.getBaseSpotName())
|
|
|
- && model.get("operationFunction").equals("作废")).count();
|
|
|
- countLogRecover = carLog.stream().filter(model -> model.get("baseSpotNo").equals(spot.getBaseSpotNo())
|
|
|
- && model.get("baseSpotName").equals(spot.getBaseSpotName())
|
|
|
- && model.get("operationFunction").equals("启用")).count();
|
|
|
+ countLogFirstIsPreScale = carFirstLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("BASE_SPOT_NO") != null
|
|
|
+ && model.get("BASE_SPOT_NAME") != null
|
|
|
+ && model.get("BASE_SPOT_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("BASE_SPOT_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("匹配委托")).count();
|
|
|
+ countLogFirstIsNotPreScale = carFirstLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("BASE_SPOT_NO") != null
|
|
|
+ && model.get("BASE_SPOT_NAME") != null
|
|
|
+ && model.get("BASE_SPOT_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("BASE_SPOT_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("撤销委托")).count();
|
|
|
+ countLogFirstUpdateCar = carFirstLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("BASE_SPOT_NO") != null
|
|
|
+ && model.get("BASE_SPOT_NAME") != null
|
|
|
+ && model.get("BASE_SPOT_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("BASE_SPOT_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("车号修改")).count();
|
|
|
+ countLogFirstValid = carFirstLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("BASE_SPOT_NO") != null
|
|
|
+ && model.get("BASE_SPOT_NAME") != null
|
|
|
+ && model.get("BASE_SPOT_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("BASE_SPOT_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("作废")).count();
|
|
|
+ countLogFirstRecover = carFirstLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("BASE_SPOT_NO") != null
|
|
|
+ && model.get("BASE_SPOT_NAME") != null
|
|
|
+ && model.get("BASE_SPOT_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("BASE_SPOT_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("启用")).count();
|
|
|
+ }
|
|
|
+
|
|
|
+ long countLogActualIsPreScale = 0L;
|
|
|
+ long countLogActualIsNotPreScale = 0L;
|
|
|
+ long countLogActualDecompose = 0L;
|
|
|
+ long countLogActualValid = 0L;
|
|
|
+// long countLogFirstClean = 0L;
|
|
|
+// long countLogFirstDoubleEntrust = 0L;
|
|
|
+// long countLogFirstMixedLoading = 0L;
|
|
|
+// long countLogFirstMixedDischarge = 0L;
|
|
|
+ if(carActualLog != null && carActualLog.size() >= 1) {
|
|
|
+// countLogFirstClean = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+// && model.get("NET_SPOT3_NO") != null
|
|
|
+// && model.get("NET_SPOT3_NAME") != null
|
|
|
+// && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+// && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+// && model.get("OPERATION_FUNCTION").equals("毛皮结净")).count();
|
|
|
+// countLogFirstDoubleEntrust = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+// && model.get("NET_SPOT3_NO") != null
|
|
|
+// && model.get("NET_SPOT3_NAME") != null
|
|
|
+// && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+// && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+// && model.get("OPERATION_FUNCTION").equals("毛皮结净")).count();
|
|
|
+// countLogFirstMixedLoading = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+// && model.get("NET_SPOT3_NO") != null
|
|
|
+// && model.get("NET_SPOT3_NAME") != null
|
|
|
+// && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+// && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+// && model.get("OPERATION_FUNCTION").equals("毛皮结净")).count();
|
|
|
+// countLogFirstMixedDischarge = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+// && model.get("NET_SPOT3_NO") != null
|
|
|
+// && model.get("NET_SPOT3_NAME") != null
|
|
|
+// && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+// && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+// && model.get("OPERATION_FUNCTION").equals("毛皮结净")).count();
|
|
|
+ countLogActualIsPreScale = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("NET_SPOT3_NO") != null
|
|
|
+ && model.get("NET_SPOT3_NAME") != null
|
|
|
+ && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("匹配委托")).count();
|
|
|
+ countLogActualIsNotPreScale = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("NET_SPOT3_NO") != null
|
|
|
+ && model.get("NET_SPOT3_NAME") != null
|
|
|
+ && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("撤销委托")).count();
|
|
|
+ countLogActualDecompose = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("NET_SPOT3_NO") != null
|
|
|
+ && model.get("NET_SPOT3_NAME") != null
|
|
|
+ && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("毛皮分解")).count();
|
|
|
+ countLogActualValid = carActualLog.stream().filter(model -> model.get("OPERATION_FUNCTION") != null
|
|
|
+ && model.get("NET_SPOT3_NO") != null
|
|
|
+ && model.get("NET_SPOT3_NAME") != null
|
|
|
+ && model.get("NET_SPOT3_NO").equals(spot.getBaseSpotNo())
|
|
|
+ && model.get("NET_SPOT3_NAME").equals(spot.getBaseSpotName())
|
|
|
+ && model.get("OPERATION_FUNCTION").equals("结净废除")).count();
|
|
|
+ }
|
|
|
+
|
|
|
+ long countMonitorLogHisTare = 0L;
|
|
|
+ long countMonitorLogGrossTare = 0L;
|
|
|
+ long countMonitorLogActual = 0L;
|
|
|
+ long countMonitorLogInfraredContrast = 0L;
|
|
|
+ long countMonitorLogZero = 0L;
|
|
|
+ long countMonitorLogTime = 0L;
|
|
|
+ if(carMonitorLog != null && carMonitorLog.size() >= 1) {
|
|
|
+ countMonitorLogHisTare = carMonitorLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getOperationContent().endsWith("历史皮重")).count();
|
|
|
+ countMonitorLogGrossTare = carMonitorLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getOperationContent().endsWith("毛皮超差")).count();
|
|
|
+ countMonitorLogActual = carMonitorLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getOperationContent().endsWith("异地计量")).count();
|
|
|
+ countMonitorLogInfraredContrast = carMonitorLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getOperationContent().endsWith("对射")).count();
|
|
|
+ countMonitorLogZero = carMonitorLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getOperationContent().endsWith("零点告警")).count();
|
|
|
+ countMonitorLogTime = carMonitorLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())
|
|
|
+ && model.getOperationContent().endsWith("时间间隔")).count();
|
|
|
+ }
|
|
|
+
|
|
|
+ long countResetCar = 0L;
|
|
|
+ if(countResetCarLog != null && countResetCarLog.size() >= 1) {
|
|
|
+ countResetCar = countResetCarLog.stream().filter(model -> model.getBaseSpotNo() != null
|
|
|
+ && model.getBaseSpotName() != null
|
|
|
+ && model.getBaseSpotNo().equals(spot.getBaseSpotNo())
|
|
|
+ && model.getBaseSpotName().equals(spot.getBaseSpotName())).count();
|
|
|
}
|
|
|
|
|
|
HashMap<String, Object> obj = new HashMap<>();
|
|
|
- //根据时间查询所有秤点的洁净已匹配、洁净未匹配、洁净已上传、洁净未上传、洁净已作废
|
|
|
+ //根据时间查询所有秤点的结净已匹配、结净未匹配、结净已上传、结净未上传、结净已作废
|
|
|
obj.put("spotNo", spot.getBaseSpotNo());
|
|
|
obj.put("spotName", spot.getBaseSpotName());
|
|
|
obj.put("countIsPrescale", countIsPrescale);
|
|
|
@@ -2657,18 +2890,37 @@ public class MeterWorkCarActualServiceImpl extends BaseServiceImpl<MeterWorkCarA
|
|
|
obj.put("countGross", countGross);
|
|
|
obj.put("countTare", countTare);
|
|
|
obj.put("countTermTare", countTermTare);
|
|
|
+ obj.put("countNullWeightType", countNullWeightType);
|
|
|
obj.put("countFirst", countFirst);
|
|
|
obj.put("countFirstValid", countFirstValid);
|
|
|
//根据时间查询所有秤点的报警总数、报警未处理、报警已处理
|
|
|
obj.put("countCarHelp", countCarHelp);
|
|
|
obj.put("countCarHelpIsNotValue", countCarHelpIsNotValue);
|
|
|
obj.put("countCarHelpIsValue", countCarHelpIsValue);
|
|
|
- //根据时间查询所有秤点的匹配委托、
|
|
|
- obj.put("countLogIsPreScale", countLogIsPreScale);
|
|
|
- obj.put("countLogIsNotPreScale", countLogIsNotPreScale);
|
|
|
- obj.put("countLogUpdateCar", countLogUpdateCar);
|
|
|
- obj.put("countLogValid", countLogValid);
|
|
|
- obj.put("countLogRecover", countLogRecover);
|
|
|
+ obj.put("countCarHelpRfid", countCarHelpRfid);
|
|
|
+ obj.put("countCarHelpScanningCode", countCarHelpScanningCode);
|
|
|
+ obj.put("countCarHelpNormal", countCarHelpNormal);
|
|
|
+ obj.put("countCarHelpVehicleReset", countCarHelpVehicleReset);
|
|
|
+ //根据时间查询所有秤点的一次匹配委托、撤销委托、车号修改、作废、启用
|
|
|
+ obj.put("countLogFirstIsPreScale", countLogFirstIsPreScale);
|
|
|
+ obj.put("countLogFirstIsNotPreScale", countLogFirstIsNotPreScale);
|
|
|
+ obj.put("countLogFirstUpdateCar", countLogFirstUpdateCar);
|
|
|
+ obj.put("countLogFirstValid", countLogFirstValid);
|
|
|
+ obj.put("countLogFirstRecover", countLogFirstRecover);
|
|
|
+ //根据时间查询所有秤点的结净匹配委托、撤销委托、毛皮分解、结净废除
|
|
|
+ obj.put("countLogActualIsPreScale", countLogActualIsPreScale);
|
|
|
+ obj.put("countLogActualIsNotPreScale", countLogActualIsNotPreScale);
|
|
|
+ obj.put("countLogActualDecompose", countLogActualDecompose);
|
|
|
+ obj.put("countLogActualValid", countLogActualValid);
|
|
|
+ //根据时间查询所有秤点的不验证历史皮重、不验证异地计量、不验证零点告警、不验证时间间隔、不验证对射、不验证毛皮超差
|
|
|
+ obj.put("countMonitorLogHisTare", countMonitorLogHisTare);
|
|
|
+ obj.put("countMonitorLogGrossTare", countMonitorLogGrossTare);
|
|
|
+ obj.put("countMonitorLogActual", countMonitorLogActual);
|
|
|
+ obj.put("countMonitorLogInfraredContrast", countMonitorLogInfraredContrast);
|
|
|
+ obj.put("countMonitorLogZero", countMonitorLogZero);
|
|
|
+ obj.put("countMonitorLogTime", countMonitorLogTime);
|
|
|
+ //监控程序重置车号
|
|
|
+ obj.put("countResetCar", countResetCar);
|
|
|
map.add(obj);
|
|
|
}
|
|
|
return map;
|