|
@@ -4,8 +4,10 @@ import com.steerinfo.dil.feign.OmsFeign;
|
|
import com.steerinfo.dil.mapper.TmstruckEnfactoryResultMapper;
|
|
import com.steerinfo.dil.mapper.TmstruckEnfactoryResultMapper;
|
|
import com.steerinfo.dil.mapper.UtilsMapper;
|
|
import com.steerinfo.dil.mapper.UtilsMapper;
|
|
import com.steerinfo.dil.model.TmstruckEnfactoryResult;
|
|
import com.steerinfo.dil.model.TmstruckEnfactoryResult;
|
|
|
|
+import com.steerinfo.dil.model.TmstruckLeaveFactoryResult;
|
|
import com.steerinfo.dil.service.ITmstruckEnfactoryResultService;
|
|
import com.steerinfo.dil.service.ITmstruckEnfactoryResultService;
|
|
import com.steerinfo.dil.util.DataChange;
|
|
import com.steerinfo.dil.util.DataChange;
|
|
|
|
+import io.swagger.models.auth.In;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
@@ -149,6 +151,22 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
|
|
int i = 0;
|
|
int i = 0;
|
|
//通过运输订单号查询订单类型
|
|
//通过运输订单号查询订单类型
|
|
String orderNumber = (String) map.get("orderNumber");
|
|
String orderNumber = (String) map.get("orderNumber");
|
|
|
|
+ //通过订单号查询订单类型 及总实绩Id
|
|
|
|
+ Map<String, Object> mesMap = utilsMapper.getOrderTypeByOrderNumber(orderNumber);
|
|
|
|
+ Integer orderType = DataChange.dataToBigDecimal(mesMap.get("orderType")).intValue();
|
|
|
|
+
|
|
|
|
+ if(orderType == 11){
|
|
|
|
+ //内转订单类型 没有生成实绩 直接新增
|
|
|
|
+ Integer sqe = utilsMapper.getLineSequenceByOrderNumber(orderNumber);
|
|
|
|
+ sqe = sqe == null ? 1 : sqe + 1;
|
|
|
|
+ map.put("resultId", tmstruckEnfactoryResultMapper.selectMaxId()); //插入进厂实绩Id
|
|
|
|
+ map.put("Sqe", sqe); //查询路段顺序号 + 1
|
|
|
|
+ i += tmstruckEnfactoryResultMapper.insertSelective(generateEnFactoryResult(map));
|
|
|
|
+ mesMap.put("orderLineSequence", sqe);
|
|
|
|
+ i += utilsService.updateOrderLineSqeByOrderNumber(mesMap); //更新路段顺序号
|
|
|
|
+ return i;
|
|
|
|
+ }
|
|
|
|
+
|
|
Map<String, Object> selectMap = tmstruckEnfactoryResultMapper.selectEnFactoryResultId(orderNumber);
|
|
Map<String, Object> selectMap = tmstruckEnfactoryResultMapper.selectEnFactoryResultId(orderNumber);
|
|
if(selectMap == null){
|
|
if(selectMap == null){
|
|
throw new Exception("该车已进厂!!");
|
|
throw new Exception("该车已进厂!!");
|
|
@@ -161,12 +179,11 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
|
|
}
|
|
}
|
|
}
|
|
}
|
|
map.putAll(selectMap);
|
|
map.putAll(selectMap);
|
|
- BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderTypee"));
|
|
|
|
BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
|
|
BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
|
|
BigDecimal resultTotalId = DataChange.dataToBigDecimal(map.get("resultTotalId"));
|
|
BigDecimal resultTotalId = DataChange.dataToBigDecimal(map.get("resultTotalId"));
|
|
//判断委托是否发送成功
|
|
//判断委托是否发送成功
|
|
int checkMeasureCommission = 0;
|
|
int checkMeasureCommission = 0;
|
|
- switch (orderType.intValue()){
|
|
|
|
|
|
+ switch (orderType){
|
|
case 1:
|
|
case 1:
|
|
//查询未装车实绩
|
|
//查询未装车实绩
|
|
List<Map<String, Object>> mapList = rulesService.judgeLastMaterial(DataChange.dataToBigDecimal(map.get("orderId")));
|
|
List<Map<String, Object>> mapList = rulesService.judgeLastMaterial(DataChange.dataToBigDecimal(map.get("orderId")));
|
|
@@ -199,7 +216,7 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
|
|
// case 8:
|
|
// case 8:
|
|
// case 9:
|
|
// case 9:
|
|
case 10:
|
|
case 10:
|
|
- case 11:
|
|
|
|
|
|
+// case 11:
|
|
// case 17:
|
|
// case 17:
|
|
case 18:
|
|
case 18:
|
|
checkMeasureCommission = tmstruckMeasureCommissionService.addMaoMeasureCommission(map); //添加计毛委托 并发送计毛委托
|
|
checkMeasureCommission = tmstruckMeasureCommissionService.addMaoMeasureCommission(map); //添加计毛委托 并发送计毛委托
|
|
@@ -220,7 +237,7 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
|
|
if(checkMeasureCommission == 0){
|
|
if(checkMeasureCommission == 0){
|
|
throw new Exception("委托发送失败");
|
|
throw new Exception("委托发送失败");
|
|
}
|
|
}
|
|
- i += updateEnFactoryResultByPDA(map); //添加进厂实绩
|
|
|
|
|
|
+ i += tmstruckEnfactoryResultMapper.updateByPrimaryKeySelective(generateEnFactoryResult(map)); //添加进厂实绩
|
|
//修改路段顺序号
|
|
//修改路段顺序号
|
|
i += utilsService.updateOrderLineSequence(map);
|
|
i += utilsService.updateOrderLineSequence(map);
|
|
utilsService.pushMesToWebsocket((String) map.get("capacityNumber"), "车辆进厂");
|
|
utilsService.pushMesToWebsocket((String) map.get("capacityNumber"), "车辆进厂");
|
|
@@ -291,11 +308,11 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 通过PDA添加进厂实绩方法
|
|
|
|
|
|
+ * 生成进厂实绩
|
|
* @param map
|
|
* @param map
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
- public int updateEnFactoryResultByPDA(Map<String, Object> map){
|
|
|
|
|
|
+ public TmstruckEnfactoryResult generateEnFactoryResult(Map<String, Object> map){
|
|
TmstruckEnfactoryResult tmstruckEnfactoryResult = new TmstruckEnfactoryResult();
|
|
TmstruckEnfactoryResult tmstruckEnfactoryResult = new TmstruckEnfactoryResult();
|
|
//获取进厂实绩id
|
|
//获取进厂实绩id
|
|
tmstruckEnfactoryResult.setResultId(DataChange.dataToBigDecimal(map.get("resultId")));
|
|
tmstruckEnfactoryResult.setResultId(DataChange.dataToBigDecimal(map.get("resultId")));
|
|
@@ -306,7 +323,13 @@ public class TmstruckEnfactoryResultServiceImpl implements ITmstruckEnfactoryRes
|
|
tmstruckEnfactoryResult.setInsertTime(new Date());
|
|
tmstruckEnfactoryResult.setInsertTime(new Date());
|
|
tmstruckEnfactoryResult.setResultEntryMode("手动抬杠");
|
|
tmstruckEnfactoryResult.setResultEntryMode("手动抬杠");
|
|
tmstruckEnfactoryResult.setInsertUsername("admin");
|
|
tmstruckEnfactoryResult.setInsertUsername("admin");
|
|
- return tmstruckEnfactoryResultMapper.updateByPrimaryKeySelective(tmstruckEnfactoryResult);
|
|
|
|
|
|
+ if(map.get("Sqe") != null){
|
|
|
|
+ tmstruckEnfactoryResult.setSegmenSqe(DataChange.dataToBigDecimal(map.get("Sqe")));
|
|
|
|
+ }
|
|
|
|
+ if(map.get("totalId") != null){
|
|
|
|
+ tmstruckEnfactoryResult.setResultTotalId(DataChange.dataToBigDecimal(map.get("totalId")));
|
|
|
|
+ }
|
|
|
|
+ return tmstruckEnfactoryResult;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|