TmstrainLoadingResultServiceImpl.java 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556
  1. package com.steerinfo.dil.service.impl;
  2. import com.steerinfo.dil.feign.WmshBoundFeign;
  3. import com.steerinfo.dil.mapper.*;
  4. import com.steerinfo.dil.model.*;
  5. import com.steerinfo.dil.service.ITmstrainLoadingResultService;
  6. import com.steerinfo.dil.util.DataChange;
  7. import com.steerinfo.framework.service.pagehelper.PageHelper;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Transactional;
  11. import java.math.BigDecimal;
  12. import java.util.*;
  13. /**
  14. * TmstrainLoadingResult服务实现:
  15. * @author generator
  16. * @version 1.0-SNAPSHORT 2021-08-30 02:23
  17. * 类描述
  18. * 修订历史:
  19. * 日期:2021-08-30
  20. * 作者:generator
  21. * 参考:
  22. * 描述:TmstrainLoadingResult服务实现
  23. * @see null
  24. * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
  25. */
  26. @Service(value = "tmstrainLoadingResultService")
  27. public class TmstrainLoadingResultServiceImpl implements ITmstrainLoadingResultService {
  28. @Autowired
  29. private TmstrainLoadingResultMapper tmstrainLoadingResultMapper;
  30. @Autowired
  31. private TmstrainLoadingTempMapper tmstrainLoadingTempMapper;
  32. @Autowired
  33. private WmshBoundFeign wmshBoundFeign;
  34. @Autowired
  35. private TmstrainTruckTotalResultMapper tmstrainTruckTotalResultMapper;
  36. @Autowired
  37. private TmstrainTotalResultMapper tmstrainTotalResultMapper;
  38. @Autowired
  39. private TmstrainMeasureCommissionServiceImpl tmstrainMeasureCommissionService;
  40. @Autowired
  41. private TmstrainWeightResultMapper tmstrainWeightResultMapper;
  42. /**
  43. * 查看所有装车实绩
  44. * @param map
  45. * @return
  46. */
  47. @Override
  48. public List<Map<String, Object>> getTmstrainWagonLoad(Map<String, Object> map) {
  49. BigDecimal resultType = DataChange.dataToBigDecimal(map.get("resultType"));
  50. switch (resultType.intValue()){
  51. case 1:
  52. case 2:
  53. case 3:
  54. List<Map<String, Object>> tmsWagonLoadInfo = tmstrainLoadingResultMapper.getTmsWagonLoadInfo(map);// apiId = 58 - 209
  55. for (Map<String, Object> obj : tmsWagonLoadInfo) {
  56. Integer deleted = DataChange.dataToBigDecimal(obj.get("deleted")).intValue();
  57. if(deleted == 0){
  58. obj.put("isUnload", "已装车");
  59. }else {
  60. obj.put("isUnload", "已卸车");
  61. }
  62. }
  63. return tmsWagonLoadInfo;
  64. case 4:
  65. return tmstrainLoadingResultMapper.selectLoadedForConverted(map); //apiId = 203
  66. case 10:
  67. //查询国产矿需要补录的装车实绩
  68. return tmstrainLoadingResultMapper.getNoPurOrderIdLoadResult(map); //apiId = 209
  69. }
  70. return null;
  71. }
  72. /**
  73. * 添加火运总实绩
  74. * @param loadingId
  75. * @return
  76. */
  77. public int addTotalResult(BigDecimal loadingId){
  78. TmstrainTotalResult tmstrainTotalResult = new TmstrainTotalResult();
  79. BigDecimal maxId = tmstrainTotalResultMapper.selectMaxId();
  80. tmstrainTotalResult.setId(maxId); //获取添加火运总实绩主键ID
  81. //生成火运单号
  82. tmstrainTotalResult.setTransportNum(DataChange.generateEightDigitsNumber("WTRAN", maxId.intValue()));
  83. //添加火运装车实绩ID
  84. tmstrainTotalResult.setLoadingId(loadingId);
  85. //新增计量实绩
  86. TmstrainWeightResult tmstrainWeightResult=new TmstrainWeightResult();
  87. tmstrainWeightResult.setResultId(tmstrainWeightResultMapper.selectMaxId());
  88. tmstrainWeightResult.setResultTotalId(maxId);
  89. tmstrainWeightResultMapper.insertSelective(tmstrainWeightResult);
  90. return tmstrainTotalResultMapper.insertSelective(tmstrainTotalResult);
  91. }
  92. /**
  93. * 进口矿新增装车实绩
  94. * @param tmstrainLoadingResult
  95. * @return
  96. */
  97. @Override
  98. @Transactional
  99. public int addTmstrainLoadingResult(TmstrainLoadingResult tmstrainLoadingResult) throws Exception{
  100. List<String> wagonNoList = tmstrainLoadingResult.getWagonNoList();
  101. if(wagonNoList.size()<=0){
  102. throw new Exception("车皮号异常");
  103. }
  104. //通过采购订单号获得批次ID
  105. BigDecimal purchaseOrderId = tmstrainLoadingResult.getPurchaseOrderRailPlanId();
  106. BigDecimal arrivalStationId = tmstrainLoadingResult.getArrivalStationId();
  107. if(arrivalStationId.intValue() == 1){
  108. tmstrainLoadingResult.setSendRequest(new BigDecimal(1));
  109. }
  110. BigDecimal batchId = tmstrainLoadingResultMapper.getBatchIdByPurOrderId(purchaseOrderId);
  111. tmstrainLoadingResult.setBatchId(batchId);
  112. //添加常规字段
  113. addRegularField(tmstrainLoadingResult);
  114. //准备插入
  115. int count = 0;
  116. List<Map<String,Object>> resultIdList=new ArrayList<>();
  117. for (String wagonNo : wagonNoList) {
  118. tmstrainLoadingResult.setResultWagonNo(wagonNo);
  119. BigDecimal maxId = tmstrainLoadingResultMapper.selectMaxId();
  120. //生成主键id
  121. tmstrainLoadingResult.setResultId(maxId);
  122. //通过车皮号计算车皮标重
  123. int wagonWeight = calculateWagonWeight(tmstrainLoadingResult.getResultWagonNo());
  124. tmstrainLoadingResult.setResultBillableTonnage(new BigDecimal(wagonWeight));
  125. count += tmstrainLoadingResultMapper.insertSelective(tmstrainLoadingResult);
  126. //添加火运总实绩
  127. count += addTotalResult(maxId);
  128. //计量委托实绩list
  129. Map<String, Object> temp = new HashMap<>();
  130. temp.put("resultId",maxId);
  131. resultIdList.add(temp);
  132. }
  133. //新增完成,发送计量委托
  134. if(resultIdList.size()==wagonNoList.size()){
  135. Map<String, Object> map = new HashMap<>();
  136. map.put("resultIdList",resultIdList);
  137. int i = tmstrainMeasureCommissionService.batchSendMeasureCommission(map);
  138. if(i==-1){
  139. return i;
  140. }
  141. }else{
  142. return -1;
  143. }
  144. return count;
  145. }
  146. /**
  147. * 添加国产矿装车实绩
  148. * @param list
  149. * @return
  150. */
  151. public int addDomesticLoadResult(List<Map<String, Object>> list) throws Exception {
  152. //装车临时list
  153. List<TmstrainLoadingTemp> loadingTemps=new ArrayList<>();
  154. //装车实绩list
  155. List<TmstrainLoadingResult> loadingResults=new ArrayList<>();
  156. int i = 0;
  157. for(Map<String,Object> map:list){
  158. TmstrainLoadingTemp temp=new TmstrainLoadingTemp();
  159. TmstrainLoadingResult result=new TmstrainLoadingResult();
  160. //设置序列号主键
  161. BigDecimal maxId = tmstrainLoadingResultMapper.selectMaxId();
  162. temp.setResultId(maxId);
  163. result.setResultId(maxId);
  164. //处理临时表
  165. temp.setSendStation((String)map.get("sendStation"));//发站
  166. temp.setArrivalStation((String)map.get("arrivalStation"));//到站
  167. temp.setMaterialName((String)map.get("materialName"));//物资
  168. temp.setSupplierName((String)map.get("supplierName"));//发货单位
  169. //temp.setSendDate((String)map.get("sendDate"));//发货日期
  170. temp.setResultWagonNo(map.get("wagonNo").toString());//车皮号
  171. //temp.setResultBillableTonnage(new BigDecimal((String)map.get("weight")));
  172. //处理实绩表
  173. result.setArrivalStationId(new BigDecimal(map.get("arrivalStationId").toString()));
  174. result.setResultLoadingDate(new Date((Long)map.get("resultLoadingDate")));//装车日期
  175. result.setResultType(new BigDecimal(map.get("resultType").toString()));//装车类型,国产矿应该为3
  176. result.setResultRemarks((String) map.get("resultRemarks"));
  177. result.setResultWagonNo(map.get("wagonNo").toString());//车皮号
  178. //取得发站名,查询是否存在该站台,如果存在则绑定,否则新增该站台再绑定
  179. String sendStationName=(String) map.get("sendStation");//发站名
  180. if(sendStationName!=null){
  181. BigDecimal sendStationId=tmstrainLoadingResultMapper.getSendStationId(sendStationName);
  182. if(sendStationId==null){
  183. //如果没有该站,新增
  184. sendStationId=tmstrainLoadingResultMapper.getMaxSendStationId().add(new BigDecimal(1));
  185. Map<String,Object> station=new HashMap<>();
  186. station.put("arrivalId",sendStationId);
  187. station.put("arrivalName",sendStationName);
  188. station.put("insertTime",new Date());
  189. station.put("updateTime",new Date());
  190. if(tmstrainLoadingResultMapper.addSendStation(station)<=0){
  191. throw new Exception("添加发站失败");
  192. }
  193. }
  194. result.setSendStationId(sendStationId);
  195. }
  196. //添加常规字段
  197. addRegularField(result);
  198. //通过车皮号计算车皮标重
  199. result.setResultBillableTonnage(new BigDecimal(calculateWagonWeight(result.getResultWagonNo())));
  200. //通过到站ID匹配计量衡 如果是老区轨道衡或者是新区轨道衡 则匹配轨道衡
  201. //如果到站ID是老区轨道衡
  202. BigDecimal arrivalStationId = result.getArrivalStationId();
  203. if(arrivalStationId!=null && arrivalStationId.intValue() == 1){
  204. result.setTrainCalculateId(new BigDecimal(13)); //设置计量衡为 铁专线(老区)
  205. result.setSendRequest(new BigDecimal(1));
  206. }
  207. loadingTemps.add(temp);
  208. loadingResults.add(result);
  209. i += addTotalResult(maxId);
  210. }
  211. //批量插入
  212. tmstrainLoadingTempMapper.batchInsert(loadingTemps);
  213. int count = tmstrainLoadingResultMapper.batchInsert(loadingResults);
  214. return count;
  215. }
  216. /**
  217. * 补录采购订单信息
  218. * @param map
  219. * @return
  220. */
  221. public int updateDomesticLoadResult(Map<String, Object> map){
  222. //获取要补录的实绩ID 列表
  223. List<Integer> resultIdList = (List<Integer>) map.get("resultIdList");
  224. TmstrainLoadingResult tmstrainLoadingResult = new TmstrainLoadingResult();
  225. BigDecimal purchaseOrderId = DataChange.dataToBigDecimal(map.get("purchaseOrderId"));
  226. if(purchaseOrderId.intValue() != 0){
  227. //查询补录信息
  228. Map<String,Object> record=tmstrainLoadingResultMapper.getRecordByPurOrderId(purchaseOrderId);
  229. BigDecimal materialId=DataChange.dataToBigDecimal(record.get("materialId"));
  230. BigDecimal supplierId=DataChange.dataToBigDecimal(record.get("supplierId"));
  231. BigDecimal batchId =DataChange.dataToBigDecimal(record.get("batchId"));
  232. //设置补录字段
  233. tmstrainLoadingResult.setBatchId(batchId);
  234. tmstrainLoadingResult.setMaterialId(materialId);
  235. tmstrainLoadingResult.setSendUnitId(supplierId);
  236. }
  237. tmstrainLoadingResult.setPurchaseOrderRailPlanId(purchaseOrderId); //采购订单Id
  238. int count = 0;
  239. //对每一个实绩id对应的记录修改字段
  240. for (Integer resultId : resultIdList) {
  241. tmstrainLoadingResult.setResultId(new BigDecimal(resultId)); //设置要补录的实绩主键
  242. count += tmstrainLoadingResultMapper.updateByPrimaryKeySelective(tmstrainLoadingResult);
  243. }
  244. //全部补录成功,发送计量委托
  245. if(resultIdList.size()-count==0){
  246. // System.out.println("发送计量委托");
  247. Map<String, Object> map1 = new HashMap<>();
  248. List<Map<String,Object>> resultIdList1=new ArrayList<>();
  249. for(Integer resultId:resultIdList){
  250. Map<String, Object> temp = new HashMap<>();
  251. temp.put("resultId",resultId);
  252. resultIdList1.add(temp);
  253. }
  254. map1.put("resultIdList",resultIdList1);
  255. int i = tmstrainMeasureCommissionService.batchSendMeasureCommission(map1);
  256. if(i==-1){
  257. return i;
  258. }
  259. }
  260. return count;
  261. }
  262. /**
  263. * 通过车皮标重计算车皮标重
  264. * @return
  265. */
  266. public int calculateWagonWeight(String wagonNo){
  267. String number = wagonNo.substring(0,2);
  268. if (number.equals("14"))
  269. {
  270. String No = wagonNo.substring(0,3);
  271. if (No.equals("143")||No.equals("140")||No.equals("141")||No.equals("142")){
  272. return 60;
  273. }
  274. else if (No.equals("145")){
  275. return 61;
  276. }
  277. }
  278. else if(number.equals("45")||number.equals("46")){
  279. return 60;
  280. }
  281. else if(number.equals("42")||number.equals("47")||number.equals("48")||number.equals("49")){
  282. return 61;
  283. }
  284. else if(number.equals("15")||number.equals("16")||number.equals("17")||number.equals("18")){
  285. return 70;
  286. }
  287. return 0;
  288. }
  289. /**
  290. * 添加港存库出库实绩
  291. * @param tmstrainLoadingResult
  292. * @param batchId
  293. */
  294. public void addOutWarehouse(TmstrainLoadingResult tmstrainLoadingResult, BigDecimal batchId){
  295. Map<String, Object> map = new HashMap<>();
  296. map.put("isClean",tmstrainLoadingResult.getResultIsclear());
  297. map.put("resultTonnage", tmstrainLoadingResult.getResultBillableTonnage());
  298. map.put("batchId", batchId);
  299. //通过发站查询发站的所属港口
  300. BigDecimal portId = tmstrainLoadingResultMapper.getPortIdBySendStationId(tmstrainLoadingResult.getSendStationId());
  301. map.put("downSwimPortId", portId);
  302. map.put("port", portId);
  303. wmshBoundFeign.addResult(map);
  304. }
  305. /**
  306. * 添加常规字段
  307. * @param tmstrainLoadingResult
  308. */
  309. public void addRegularField(TmstrainLoadingResult tmstrainLoadingResult){
  310. //常规字段插入
  311. tmstrainLoadingResult.setInsertUsername("admin");
  312. tmstrainLoadingResult.setInsertTime(new Date());
  313. tmstrainLoadingResult.setInsertUpdateRemark("无");
  314. tmstrainLoadingResult.setDeleted(new BigDecimal(0));
  315. }
  316. /**
  317. * 通过ID获取装车实绩数据
  318. * @param resultId
  319. * @return
  320. */
  321. @Override
  322. public List<Map<String, Object>> getTmstrainLoadingResultByResultId(BigDecimal resultId) {
  323. return tmstrainLoadingResultMapper.selectByResultId(resultId);
  324. }
  325. /**
  326. * 修改火运装车实绩
  327. * @param map
  328. * @return
  329. */
  330. @Override
  331. public int updateTmstrainLoadingResult(Map<String,Object> map) throws Exception{
  332. TmstrainLoadingResult tmstrainLoadingResult=new TmstrainLoadingResult();
  333. String wagonNo=map.get("resultWagonNo").toString();
  334. BigDecimal resultId=DataChange.dataToBigDecimal(map.get("resultId"));
  335. Integer resultType=(Integer) map.get("resultType");
  336. if(wagonNo==null || wagonNo.length()!=7 || calculateWagonWeight(wagonNo)<=0){
  337. return -1;
  338. }else if(resultId==null){
  339. return -2;
  340. }else if(resultType==0){
  341. return -3;
  342. }
  343. //国产矿未配单仅支持修改部分字段,并且不重新发委托
  344. List<Map<String,Object>> results=tmstrainLoadingResultMapper.selectByResultId(resultId);
  345. if(resultType==3 && results!=null && results.get(0)!=null && results.get(0).get("purchaseOrderRainPlanId")==null){
  346. tmstrainLoadingResult.setResultId(resultId);
  347. tmstrainLoadingResult.setResultWagonNo(wagonNo);
  348. tmstrainLoadingResult.setSendStationId(DataChange.dataToBigDecimal(map.get("sendStationId")));
  349. tmstrainLoadingResult.setArrivalStationId(DataChange.dataToBigDecimal(map.get("arrivalStationId")));
  350. tmstrainLoadingResult.setResultLoadingDate(new Date((Long)map.get("resultLoadingDate")));
  351. if(map.get("resultRemarks")!=null)
  352. tmstrainLoadingResult.setResultRemarks(map.get("resultRemarks").toString());
  353. tmstrainLoadingResultMapper.updateByPrimaryKeySelective(tmstrainLoadingResult);
  354. return -5;
  355. }
  356. //进口矿字段
  357. if(resultType!=3){
  358. if(map.get("resultClass")!=null)
  359. tmstrainLoadingResult.setResultClass(map.get("resultClass").toString());
  360. if(map.get("resultIsclear")!=null)
  361. tmstrainLoadingResult.setResultIsclear(map.get("resultIsclear").toString());
  362. if(map.get("capacityId")!=null)
  363. tmstrainLoadingResult.setCapacityId(DataChange.dataToBigDecimal(map.get("capacityId")));
  364. if(map.get("resultBillableTonnage")!=null)
  365. tmstrainLoadingResult.setCapacityId(DataChange.dataToBigDecimal(map.get("resultBillableTonnage")));
  366. }
  367. //通过采购订单号查询获得采购订单ID、批次ID
  368. if(map.get("purchaseOrderNo")!=null){
  369. String purchaseOrderNo = map.get("purchaseOrderNo").toString() ;
  370. BigDecimal purchaseOrderId = tmstrainLoadingResultMapper.getPurchaseOrderIdByPurOrderNo(purchaseOrderNo);
  371. BigDecimal batchId = tmstrainLoadingResultMapper.getBatchIdByPurOrderNo(purchaseOrderNo);
  372. if(purchaseOrderId==null || batchId==null){
  373. return -4;
  374. }
  375. tmstrainLoadingResult.setBatchId(batchId);
  376. tmstrainLoadingResult.setPurchaseOrderRailPlanId(purchaseOrderId);
  377. }
  378. //设置其他字段
  379. tmstrainLoadingResult.setResultId(resultId);
  380. tmstrainLoadingResult.setResultWagonNo(wagonNo);
  381. tmstrainLoadingResult.setSendStationId(DataChange.dataToBigDecimal(map.get("sendStationId")));
  382. tmstrainLoadingResult.setArrivalStationId(DataChange.dataToBigDecimal(map.get("arrivalStationId")));
  383. tmstrainLoadingResult.setResultLoadingDate(new Date((Long)map.get("resultLoadingDate")));
  384. if(map.get("resultRemarks")!=null)
  385. tmstrainLoadingResult.setResultRemarks(map.get("resultRemarks").toString());
  386. tmstrainLoadingResult.setUpdateTime(new Date());
  387. //更新
  388. int count=tmstrainLoadingResultMapper.updateByPrimaryKeySelective(tmstrainLoadingResult);
  389. //更新完成,发送计量委托
  390. if(count > 0){
  391. List<Map<String, Object>> resultIdList = new ArrayList<>();
  392. Map<String, Object> map1 = new HashMap<>();
  393. Map<String, Object> map2 = new HashMap<>();
  394. map1.put("resultId",resultId);
  395. resultIdList.add(map1);
  396. map2.put("resultIdList",resultIdList);
  397. tmstrainMeasureCommissionService.batchSendMeasureCommission(map2);
  398. }
  399. return count;
  400. }
  401. /**
  402. * 删除装车作业
  403. * @param resultId
  404. * @return
  405. */
  406. @Override
  407. public int deleteTmstrainLoadingResultByResultId(BigDecimal resultId) {
  408. TmstrainLoadingResult tmstrainLoadingResult = new TmstrainLoadingResult();
  409. tmstrainLoadingResult.setResultId(resultId);
  410. tmstrainLoadingResult.setDeleted(new BigDecimal(1));
  411. return tmstrainLoadingResultMapper.updateByPrimaryKeySelective(tmstrainLoadingResult);
  412. }
  413. /**
  414. * 内转添加装车实绩
  415. * "railPlanId": 1,
  416. * "resultClass":"白班",
  417. * "resultWagonNo":"1609999",
  418. * "insertUpdateRemark": "这是第二条",
  419. * "scanCodeText": "HRB400E-12-21706023-9-3077-385-20210909120037-a0691de83a1a1fef-08010103010100014-20"
  420. * @param map
  421. * @return
  422. */
  423. @Override
  424. @Transactional
  425. public int addTrainLoadResultForConverted(Map<String, Object> map) {
  426. int count = 0;
  427. TmstrainLoadingResult tmstrainLoadingResult = new TmstrainLoadingResult();
  428. String resultWagonNo = (String) map.get("resultWagonNo"); //车皮号
  429. BigDecimal railPlanId = DataChange.dataToBigDecimal(map.get("railPlanId")); //发运计划ID
  430. Integer loadingId = tmstrainLoadingResultMapper.getLoadingIdByWnoAndRailPlanId(resultWagonNo, railPlanId.intValue());
  431. //通过火运装车实绩ID查询火运总实绩ID 如果火运装车实绩不为空
  432. BigDecimal trainTotalId = null;
  433. if(loadingId != null){
  434. trainTotalId = tmstrainTotalResultMapper.getTotalIdByLoadingId(loadingId);
  435. }
  436. //如果没有这个车皮号和发运计划的装车实绩,则新增一条装车实绩
  437. if(loadingId == null){
  438. //获取装车实绩主键ID
  439. BigDecimal maxId = tmstrainLoadingResultMapper.selectMaxId();
  440. tmstrainLoadingResult.setId(maxId);
  441. //获取发运计划ID
  442. tmstrainLoadingResult.setPurchaseOrderRailPlanId(railPlanId);
  443. tmstrainLoadingResult.setResultWagonNo(resultWagonNo);
  444. //通过车皮号计算车皮标重
  445. tmstrainLoadingResult.setResultBillableTonnage(new BigDecimal(calculateWagonWeight(resultWagonNo)));
  446. tmstrainLoadingResult.setResultLoadingDate(new Date());
  447. tmstrainLoadingResult.setResultClass((String) map.get("resultClass")); //班别
  448. tmstrainLoadingResult.setInsertUpdateRemark((String) map.get("insertUpdateRemark"));
  449. tmstrainLoadingResult.setInsertTime(new Date());
  450. tmstrainLoadingResult.setInsertUsername("admin");
  451. tmstrainLoadingResult.setResultType(new BigDecimal(4)); //内转类型
  452. tmstrainLoadingResult.setDeleted(new BigDecimal(0)); //逻辑删除0
  453. //添加车皮装车实绩
  454. count += tmstrainLoadingResultMapper.insertSelective(tmstrainLoadingResult);
  455. //添加火运总实绩
  456. TmstrainTotalResult tmstrainTotalResult = new TmstrainTotalResult();
  457. trainTotalId = tmstrainTotalResultMapper.selectMaxId();
  458. tmstrainTotalResult.setId(trainTotalId); //获取添加火运总实绩主键ID
  459. //添加火运装车实绩ID
  460. tmstrainTotalResult.setLoadingId(maxId);
  461. count += tmstrainTotalResultMapper.insertSelective(tmstrainTotalResult);
  462. }
  463. //通过物资扫描结果匹配出库主键ID
  464. Integer outBoundResultId = tmstrainLoadingResultMapper.getOutBoundResultIdByScan((String) map.get("scanCodeText"));
  465. //通过出库主键查询汽运总实绩ID和物资ID
  466. Map<String, Object> mesMap = tmstrainLoadingResultMapper.getResultTotalIdByOutBoundResultId(outBoundResultId);
  467. //通过汽运总实绩ID查询该订单是否已装车(扫一件即可全部扫描上)
  468. Integer resultId = tmstrainLoadingResultMapper.getTrainTruckIdByTruckTotalId(DataChange.dataToBigDecimal(mesMap.get("resultTotalId")));
  469. if(resultId != null){
  470. return 1; //如果已经扫描上了则默认已装车
  471. }
  472. //添加火运物资中间表
  473. TmstrainTruckTotalResult tmstrainTruckTotalResult = new TmstrainTruckTotalResult();
  474. tmstrainTruckTotalResult.setResultId(tmstrainTruckTotalResultMapper.selectMaxId());//添加火运物资中间表主键ID
  475. tmstrainTruckTotalResult.setTmstruckTotalResultId(DataChange.dataToBigDecimal(mesMap.get("resultTotalId")));//添加汽运总实绩ID
  476. tmstrainTruckTotalResult.setMaterialId(DataChange.dataToBigDecimal(mesMap.get("materialId")));//添加物资ID
  477. tmstrainTruckTotalResult.setTmstrainTotalResultId(trainTotalId);//添加火运总实绩ID
  478. tmstrainTruckTotalResult.setLoadStatus(new BigDecimal(0)); //已装车
  479. tmstrainTruckTotalResult.setInsertTime(new Date());
  480. tmstrainTruckTotalResult.setInsertUsername("admin");
  481. count += tmstrainTruckTotalResultMapper.insertSelective(tmstrainTruckTotalResult);
  482. return count;
  483. }
  484. @Override
  485. public List<Map<String, Object>> selectLoadByResultId(BigDecimal resultId) {
  486. return tmstrainLoadingResultMapper.selectLoadByResultId(resultId);
  487. }
  488. @Override
  489. public List<Map<String, Object>> getSendStationName() {
  490. return tmstrainLoadingResultMapper.getSendStationName();
  491. }
  492. @Override
  493. public List<Map<String, Object>> getArrivalStationName() {
  494. return tmstrainLoadingResultMapper.getArrivalStationName();
  495. }
  496. @Override
  497. public List<Map<String, Object>> getBatchId() {
  498. return tmstrainLoadingResultMapper.getBatchId();
  499. }
  500. @Override
  501. public List<Map<String, Object>> getWagonNo(Map<String, Object> map) {
  502. return tmstrainLoadingResultMapper.getWagonNo(map);
  503. }
  504. /**
  505. * 内转查询车皮物资信息
  506. * @param map
  507. * @return
  508. */
  509. @Override
  510. public List<Map<String, Object>> getMaterialAndCarByLoadingId(Map<String, Object> map) {
  511. return tmstrainLoadingResultMapper.getMaterialAndCarByLoadingId(map);
  512. }
  513. /**
  514. * 根据物资名和外轮船名查询采购订单号
  515. * @param map
  516. * @return
  517. */
  518. @Override
  519. public List<Map<String, Object>> getPurchaseOrderList(Map<String, Object> map) {
  520. return tmstrainLoadingResultMapper.getPurchaseOrderList(map);
  521. }
  522. }