|
|
@@ -29,6 +29,9 @@ import com.steerinfo.meterwork.meterworkrailwayactfirst.model.MeterWorkRailwayAc
|
|
|
import com.steerinfo.meterwork.meterworkrailwayactfirst.service.IMeterWorkRailwayActFirstService;
|
|
|
import com.steerinfo.meterwork.meterworkrailwayactual.mapper.MeterWorkRailwayActualMapper;
|
|
|
import com.steerinfo.meterwork.meterworkrailwayactual.model.MeterWorkRailwayActual;
|
|
|
+import com.steerinfo.meterwork.meterworkrailwaymotorialreceived.model.MeterWorkRailwayMotorialReceived;
|
|
|
+import com.steerinfo.meterwork.meterworkrailwayreceived.mapper.MeterWorkRailwayReceivedMapper;
|
|
|
+import com.steerinfo.meterwork.meterworkrailwayreceived.model.MeterWorkRailwayReceived;
|
|
|
import com.steerinfo.pretrack.prerailwayscale.mapper.PreRailwayScaleMapper;
|
|
|
import com.steerinfo.pretrack.prerailwayscale.model.PreRailwayScale;
|
|
|
import com.steerinfo.pretrack.pretrackscale.model.PreTrackScale;
|
|
|
@@ -70,6 +73,9 @@ public class MeterWorkRailwayActFirstServiceImpl extends BaseServiceImpl<MeterWo
|
|
|
@Resource
|
|
|
private PreRailwayScaleMapper preRailwayScaleMapper;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private MeterWorkRailwayReceivedMapper meterWorkRailwayReceivedMapper;
|
|
|
+
|
|
|
@Resource
|
|
|
private MeterWorkRailwayActualMapper meterWorkRailwayActualMapper;
|
|
|
|
|
|
@@ -2931,6 +2937,167 @@ public class MeterWorkRailwayActFirstServiceImpl extends BaseServiceImpl<MeterWo
|
|
|
return pageInfo;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public RESTfulResult doAddRailWf(List<MeterWorkRailwayActFirst> models) {
|
|
|
+ RESTfulResult rm = new RESTfulResult();
|
|
|
+ rm.setFailed();
|
|
|
+ try{
|
|
|
+ int count = 0;
|
|
|
+ for (MeterWorkRailwayActFirst model : models) {
|
|
|
+ //若存在相同车号的数据,则将之前的数据状态还原,然后再删除一次计量表的数据,之后再新增一次计量表数据,以及修改数据状态
|
|
|
+ Map<String,Object> mp=new HashMap<>();
|
|
|
+ mp.put("railwayNo",model.getRailwayNo());
|
|
|
+ mp.put("valueFlag","1");
|
|
|
+ mp.put("railwayTypeNo","001019002");
|
|
|
+ List<MeterWorkRailwayActFirst> ll=meterWorkRailwayActFirstMapper.selectByParameters(mp);
|
|
|
+ if(ll!=null&&ll.size()>0){
|
|
|
+ for(MeterWorkRailwayActFirst fs:ll){
|
|
|
+ meterWorkRailwayActFirstMapper.deleteByPrimaryKey(fs.getActualFirstNo());
|
|
|
+ preRailwayScaleMapper.updateMeterWorkRailwayReceiveds(fs.getActualFirstNo());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ meterWorkRailwayActFirstMapper.insertSelective(model);
|
|
|
+ meterWorkRailwayReceivedMapper.updateMeterWorkRailwayReceived(model.getActualFirstNo());
|
|
|
+ count++;
|
|
|
+ }
|
|
|
+ /*int count = 0;
|
|
|
+ for(MeterWorkRailwayActFirst model: models) {
|
|
|
+ model.setWeightType("1");
|
|
|
+ model.setCreateTime(new Date());
|
|
|
+ int i = meterWorkRailwayActFirstMapper.insertSelective(model);
|
|
|
+ int j = meterWorkRailwayMotorialReceive.update
|
|
|
+ if(i >= 1) {
|
|
|
+ count++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ rm.setSucceed();
|
|
|
+ rm.setCode("200");
|
|
|
+ rm.setMessage("操作成功,总共" + count + "条及记录转换成功!!");*/
|
|
|
+ rm.setSucceed();
|
|
|
+ rm.setCode("200");
|
|
|
+ rm.setMessage("操作成功,总共" + count + "条及记录转换成功!!");
|
|
|
+ }catch(Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ rm.setMessage("操作异常,请确认!!!>>>" + e.getMessage());
|
|
|
+ }
|
|
|
+ return rm;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public RESTfulResult doAddRailNetWf(List<MeterWorkRailwayMotorialReceived> grossModels, List<MeterWorkRailwayActFirst> tareModels) {
|
|
|
+ RESTfulResult rm = new RESTfulResult();
|
|
|
+ rm.setFailed();
|
|
|
+ try{
|
|
|
+ int count = 0;
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
|
|
|
+ String afl = sdf.format(new Date());
|
|
|
+ String userId ="",userName="";
|
|
|
+ try {
|
|
|
+ UserPayload payload = UserPayload.getCurrUser();
|
|
|
+ userId = payload.getId();
|
|
|
+ userName = payload.getUserName();
|
|
|
+ }catch (Exception ex){}
|
|
|
+
|
|
|
+ for(MeterWorkRailwayMotorialReceived received: grossModels){
|
|
|
+ for(MeterWorkRailwayActFirst first:tareModels){
|
|
|
+ //两个车号一样则匹配,否则则不匹配
|
|
|
+ if(first.getRailwayNo().equals(received.getRailwayNo())){
|
|
|
+ //已使用 METER_WORK_RAILWAY_RECEIVED表状态设置为已使用
|
|
|
+ preRailwayScaleMapper.updateMeterWorkRailwayReceived(received.getActualFirstNo());
|
|
|
+
|
|
|
+ //将一次表中的皮重设置为已洁净
|
|
|
+ first.setValueFlag("2");
|
|
|
+ meterWorkRailwayActFirstMapper.updateByPrimaryKeySelective(first);
|
|
|
+
|
|
|
+ //新增一条毛重信息
|
|
|
+ MeterWorkRailwayActFirst second=new MeterWorkRailwayActFirst();
|
|
|
+ second.setActualFirstNo(received.getActualFirstNo());
|
|
|
+ second.setValueFlag("2");
|
|
|
+ second.setRailwayNo(received.getRailwayNo());
|
|
|
+ second.setRailwayCarriageNo(received.getRailwayCarriageNo());
|
|
|
+ second.setRailwaySpeed(received.getRailwaySpeed());
|
|
|
+ second.setMeterWeight(received.getMeterWeight());
|
|
|
+ second.setCreateTime(received.getCreateTime());
|
|
|
+ second.setCreateManNo(userId);
|
|
|
+ second.setCreateManName(userName);
|
|
|
+ second.setWeightType("0");
|
|
|
+ second.setRailwayTypeNo(received.getRailwayTypeNo());
|
|
|
+ second.setRailwayTypeName(received.getRailwayTypeName());
|
|
|
+ second.setBaseSpotNo(received.getBaseSpotNo());
|
|
|
+ second.setBaseSpotName(received.getBaseSpotName());
|
|
|
+ second.setShipmentGrossWeight(received.getShipmentGrossWeight());
|
|
|
+ second.setShipmentNetWeight(received.getShipmentNetWeight());
|
|
|
+ second.setRailwayModelName(received.getRailwayModel());
|
|
|
+ meterWorkRailwayActFirstMapper.insertSelective(second);
|
|
|
+
|
|
|
+
|
|
|
+ //新增一条洁净数据
|
|
|
+ MeterWorkRailwayActual netRail=new MeterWorkRailwayActual();
|
|
|
+ String netNo = meterWorkRailwayActualMapper.getNewID(afl);
|
|
|
+ netRail.setActualNo(afl + netNo);
|
|
|
+ netRail.setRailwayNo(received.getRailwayNo());
|
|
|
+ netRail.setRailwayCarriageNo(received.getRailwayCarriageNo());
|
|
|
+ netRail.setGrossWeight(received.getMeterWeight());
|
|
|
+ netRail.setGrossMode("1");
|
|
|
+ netRail.setGrossManNo(userId);
|
|
|
+ netRail.setGrossManName(userName);
|
|
|
+ netRail.setGrossTime(received.getCreateTime());
|
|
|
+ netRail.setGrossClass(received.getShipmentGrossWeight().doubleValue()+""); //左右偏载
|
|
|
+ netRail.setGrossGroup(received.getShipmentNetWeight().doubleValue()+"");//前后偏载
|
|
|
+ netRail.setBaseSpot1No(received.getBaseSpotNo());
|
|
|
+ netRail.setBaseSpot1Name(received.getBaseSpotName());
|
|
|
+ netRail.setActualFirst1No(second.getActualFirstNo());
|
|
|
+
|
|
|
+ netRail.setRailwayTypeNo(received.getRailwayTypeNo());
|
|
|
+ netRail.setRailwayTypeName(received.getRailwayTypeName());
|
|
|
+ netRail.setConveyanceType(received.getRailwayModel());
|
|
|
+ //netRail.setRailwayModelName(received.getRailwayModel());
|
|
|
+
|
|
|
+ netRail.setTareWeight(first.getMeterWeight());
|
|
|
+ netRail.setTareManNo(userId);
|
|
|
+ netRail.setTareManName(userName);
|
|
|
+ netRail.setTareTime(first.getCreateTime());
|
|
|
+ netRail.setTareMode("1");
|
|
|
+ netRail.setTareClass(first.getShipmentGrossWeight().doubleValue()+""); //左右偏载
|
|
|
+ netRail.setTareGroup(first.getShipmentNetWeight().doubleValue()+"");//前后偏载
|
|
|
+ netRail.setBaseSpot2No(first.getBaseSpotNo());
|
|
|
+ netRail.setBaseSpot2Name(first.getBaseSpotName());
|
|
|
+ netRail.setActualFirst2No(first.getActualFirstNo());
|
|
|
+
|
|
|
+ netRail.setNetMode("1");
|
|
|
+ netRail.setNetWeight(second.getMeterWeight().subtract(first.getMeterWeight()));
|
|
|
+ netRail.setNetTime(new Date());
|
|
|
+ netRail.setNetManNo(userId);
|
|
|
+ netRail.setNetManName(userName);
|
|
|
+ netRail.setNetSpot3No(received.getBaseSpotNo());
|
|
|
+ netRail.setNetSpot3Name(received.getBaseSpotName());
|
|
|
+
|
|
|
+ netRail.setValueFlag("0");
|
|
|
+ netRail.setUploadFlag("0");
|
|
|
+
|
|
|
+ netRail.setMeterTypeNo(received.getMeterTypeNo());
|
|
|
+ netRail.setMeterTypeName(received.getMeterTypeName());
|
|
|
+
|
|
|
+ int i = meterWorkRailwayActualMapper.insertSelective(netRail);
|
|
|
+
|
|
|
+ if(i >= 1) {
|
|
|
+ count++;
|
|
|
+ }
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ rm.setSucceed();
|
|
|
+ rm.setCode("200");
|
|
|
+ rm.setMessage("操作成功,总共" + count + "条及记录匹配洁净成功!!");
|
|
|
+ }catch(Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ rm.setMessage("操作异常,请确认!!!>>>" + e.getMessage());
|
|
|
+ }
|
|
|
+ return rm;
|
|
|
+ }
|
|
|
+
|
|
|
public static void main(String[] args) {
|
|
|
BigDecimal a = new BigDecimal(95120);
|
|
|
BigDecimal b = a.divide(new BigDecimal(1000));
|