OmstruckOrderServiceImpl.java 89 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033
  1. package com.steerinfo.dil.service.impl;
  2. import com.baomidou.mybatisplus.extension.api.R;
  3. import com.steerinfo.dil.feign.AmsFeign;
  4. import com.steerinfo.dil.feign.IMFeign;
  5. import com.steerinfo.dil.feign.TmsTruckFeign;
  6. import com.steerinfo.dil.mapper.*;
  7. import com.steerinfo.dil.model.*;
  8. import com.steerinfo.dil.service.IOmstruckOrderService;
  9. import com.steerinfo.dil.util.DataChange;
  10. import io.swagger.models.auth.In;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.stereotype.Service;
  13. import org.springframework.transaction.annotation.Transactional;
  14. import java.math.BigDecimal;
  15. import java.text.SimpleDateFormat;
  16. import java.util.*;
  17. /**
  18. * OmstruckOrder服务实现:
  19. *
  20. * @author generator
  21. * @version 1.0-SNAPSHORT 2021-10-15 09:37
  22. * 类描述
  23. * 修订历史:
  24. * 日期:2021-10-15
  25. * 作者:generator
  26. * 参考:
  27. * 描述:OmstruckOrder服务实现
  28. * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
  29. * @see null
  30. */
  31. @Service(value = "omstruckOrderService")
  32. public class OmstruckOrderServiceImpl implements IOmstruckOrderService {
  33. @Autowired
  34. private OmstruckOrderMapper omstruckOrderMapper;
  35. @Autowired
  36. private OmstruckOrderMaterialMapper omstruckOrderMaterialMapper;
  37. @Autowired
  38. private AmsFeign amsFeign;
  39. @Autowired
  40. private TmsTruckFeign tmsTruckFeign;
  41. @Autowired
  42. private IMFeign imFeign;
  43. @Autowired
  44. RmsCapacityMapper rmsCapacityMapper;
  45. @Autowired
  46. RmsDriverCapacityMapper rmsDriverCapacityMapper;
  47. @Autowired
  48. AmstruckInwardPlanMapper amstruckInwardPlanMapper;
  49. @Autowired
  50. OmstruckOrderSeparateServiceImpl omstruckOrderSeparateService;
  51. @Autowired
  52. OmstruckOrderSeparateMapper omstruckOrderSeparateMapper;
  53. /**
  54. * 用于远程调用运输订单新增
  55. *
  56. * @param omstruckOrder
  57. * @return
  58. */
  59. @Override
  60. public int insertSelective(OmstruckOrder omstruckOrder) {
  61. return omstruckOrderMapper.insertSelective(omstruckOrder);
  62. }
  63. /**
  64. * 查询所有运输订单
  65. * 获取已下发的运输订单 用于websocket
  66. *
  67. * @param map
  68. * @return
  69. */
  70. @Override
  71. public List<Map<String, Object>> getAllTruckOrder(Map<String, Object> map) {
  72. return omstruckOrderMapper.getAllTruckOrder(map);
  73. }
  74. /**
  75. * 新增运输订单
  76. *
  77. * @param map
  78. * @return
  79. */
  80. @Override
  81. @Transactional
  82. public int addPurOrder(Map<String, Object> map) {
  83. BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderType"));
  84. int i = 0;
  85. switch (orderType.intValue()) {
  86. case 1:
  87. case 2:
  88. case 3:
  89. i = dispatchSteelOrder(map);//新增焦炭发运计划订单
  90. break;
  91. case 4:
  92. break;
  93. case 5:
  94. case 6:
  95. case 7:
  96. case 8:
  97. case 17:
  98. case 18:
  99. i = addCGPurOrders(map);
  100. break;
  101. // case 8:
  102. // i = addCGPurOrder(map); //新增采购运输订单
  103. // break;
  104. case 9:
  105. break;
  106. case 10:
  107. break;
  108. case 11:
  109. }
  110. return i;
  111. }
  112. /**
  113. * 新增采购其他订单
  114. * @return
  115. */
  116. public int addCGPurOrders(Map<String, Object> map){
  117. //从map中获取司机运力列表
  118. List<Map<String, Object>> driverCapacityIdList = (List<Map<String, Object>>) map.get("driverCapacityIdList");
  119. BigDecimal purchaseOrderId = DataChange.dataToBigDecimal(map.get("purchaseOrderId"));
  120. //是否一车多趟 有则更新采购订单
  121. Object isMoreTrips = map.get("isMoreTrips");
  122. if(isMoreTrips != null){
  123. boolean trips = (boolean) isMoreTrips;
  124. if(trips){
  125. //更新采购订单为一车多趟类型
  126. omstruckOrderSeparateMapper.updateAPOisMoreTrips(DataChange.dataToBigDecimal(map.get("purchaseOrderId")));
  127. }
  128. }
  129. //物资ID
  130. Object materialId = map.get("materialId");
  131. BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderType"));
  132. //预计进厂时间
  133. Date orderEntryTime = null;
  134. if(map.get("orderEntryTime") != null){
  135. try {
  136. orderEntryTime = new Date((long) map.get("orderEntryTime"));
  137. } catch (Exception e) {
  138. System.out.println("预估进厂日期转换失败");
  139. }
  140. }
  141. int count = 0;
  142. for (Map<String, Object> capacityMap : driverCapacityIdList) {
  143. map.put("carrierId",capacityMap.get("carrierId"));
  144. map.put("priceId",capacityMap.get("priceId"));
  145. //添加运输订单
  146. OmstruckOrder omstruckOrder = generateOmsTruckOrder(map);
  147. omstruckOrder.setOrderPlanId(purchaseOrderId);
  148. omstruckOrder.setCapacityId(DataChange.dataToBigDecimal(capacityMap.get("capacityId"))); //添加运力ID
  149. omstruckOrder.setOrderEntryTime(orderEntryTime);
  150. count += omstruckOrderMapper.insertSelective(omstruckOrder);
  151. BigDecimal orderId = omstruckOrder.getOrderId();
  152. //添加运输订单子表
  153. capacityMap.put("materialId", materialId);
  154. capacityMap.put("orderType", orderType);
  155. addOrderMaterial(capacityMap,orderId);
  156. //添加总实绩
  157. capacityMap.put("orderId", orderId);
  158. tmsTruckFeign.addTotalResult(capacityMap);
  159. }
  160. return count;
  161. }
  162. /**
  163. * 新增采购进口矿运输订单订单
  164. *
  165. * @param map
  166. * @return
  167. */
  168. @Transactional
  169. public int addCGPurOrder(Map<String, Object> map) {
  170. //生成运输订单号和主键
  171. OmstruckOrder omstruckOrder = generateOmsTruckOrder(map);
  172. Object orderEntryTime = map.get("orderEntryTime");
  173. if (orderEntryTime != null) {
  174. omstruckOrder.setOrderEntryTime(new Date((long) orderEntryTime)); //新增预计进厂时间
  175. }
  176. if (map.get("orderMaterialWeight") != null) {
  177. amsFeign.updateMaterial(map); //更改运输计划子表 增加已分配重量 减少未分配重量 feign调用ams
  178. }
  179. //添加运力Id
  180. BigDecimal capacityId = DataChange.dataToBigDecimal(map.get("capacityId"));
  181. omstruckOrder.setCapacityId(capacityId);
  182. //新增运输订单
  183. omstruckOrderMapper.insertSelective(omstruckOrder);
  184. //更新运力状态为待运输:2
  185. // map.put("capacityStatus", 2);
  186. // omstruckOrderMapper.updateCapacityByCarIdOrNum(map);
  187. //新增运输订单子表
  188. addOrderMaterial(map, omstruckOrder.getOrderId());
  189. //新增实绩总表关联订单 feign 调用truckTms
  190. map.put("orderId", omstruckOrder.getOrderId());
  191. tmsTruckFeign.addTotalResult(map);
  192. return 1;
  193. }
  194. /**
  195. * 生成运输订单实体类
  196. */
  197. public OmstruckOrder generateOmsTruckOrder(Map<String, Object> map) {
  198. BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderType"));
  199. OmstruckOrder omstruckOrder = new OmstruckOrder();
  200. //生成订单主键Id
  201. BigDecimal maxId = omstruckOrderMapper.selectMaxId();
  202. omstruckOrder.setOrderId(maxId);
  203. //生成运输订单号
  204. int id = maxId.intValue();
  205. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", id);
  206. omstruckOrder.setOrderNumber(orderNumber);
  207. //设置线路
  208. omstruckOrder.setLineId(DataChange.dataToBigDecimal(map.get("lineId")));
  209. //添加当前订单所属承运商Id与运价ID
  210. Object carrierId = map.get("carrierId");
  211. Object priceId = map.get("priceId");
  212. if(carrierId != null) omstruckOrder.setCarrierId(DataChange.dataToBigDecimal(carrierId));
  213. if (priceId != null) omstruckOrder.setPriceId(DataChange.dataToBigDecimal(priceId));
  214. //运单状态 刚分配默认为未下发
  215. omstruckOrder.setOrderStatus(new BigDecimal(3));
  216. switch (orderType.intValue()) {
  217. case 1:
  218. omstruckOrder.setOrderPlanId(DataChange.dataToBigDecimal(map.get("saleOrderMaterialId")));
  219. break;
  220. case 2:
  221. case 3:
  222. omstruckOrder.setOrderPlanId(DataChange.dataToBigDecimal(map.get("dayPlanId")));
  223. break;
  224. case 4:
  225. break;
  226. case 5:
  227. case 6:
  228. case 7:
  229. case 8:
  230. case 17:
  231. case 18:
  232. if (map.get("purchaseOrderId") != null) omstruckOrder.setOrderPlanId(DataChange.dataToBigDecimal(map.get("purchaseOrderId"))); //订单ID
  233. if (map.get("unloadPointId") != null) omstruckOrder.setUnloadPointId(DataChange.dataToBigDecimal(map.get("unloadPointId")));// 添加卸货点
  234. break;
  235. case 9:
  236. break;
  237. case 10:
  238. break;
  239. case 11:
  240. }
  241. //添加订单类型
  242. omstruckOrder.setOrderType(orderType);
  243. omstruckOrder.setInsertUsername("admin");
  244. omstruckOrder.setInsertTime(new Date());
  245. return omstruckOrder;
  246. }
  247. /**
  248. * 新增订单子表
  249. *
  250. * @param map
  251. * @param
  252. */
  253. public void addOrderMaterial(Map<String, Object> map, BigDecimal orderId) {
  254. BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderType"));
  255. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  256. switch (orderType.intValue()) {
  257. case 1:
  258. //获得销售物资id
  259. //生成子表主键
  260. omstruckOrderMaterial.setOrderMaterialId(omstruckOrderMaterialMapper.selectMaxId());
  261. Integer saleOrderMaterialId = (Integer) map.get("saleOrderMaterialId");
  262. //通过车序号id查找物资件数和物资重量
  263. Map<String, Object> map1 = omstruckOrderMapper.selectTheoreticalWeightAndMaterialNumber(saleOrderMaterialId);
  264. BigDecimal materialNumber = (BigDecimal) map1.get("materialNumber");
  265. BigDecimal weight = (BigDecimal) map1.get("weight");
  266. //设置物资理重和物资件数
  267. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(weight));
  268. omstruckOrderMaterial.setOrderMaterialNumber(DataChange.dataToBigDecimal(materialNumber));
  269. //通过销售订单车序号id查找物资id
  270. List<Map<String, Object>> materialList = omstruckOrderMapper.selectMaterialIdBysaleOrderMaterialId(saleOrderMaterialId);
  271. for (int i = 0; i < materialList.size(); i++) {
  272. Map<String, Object> map2 = materialList.get(i);
  273. BigDecimal materialId = (BigDecimal) map2.get("materialId");
  274. omstruckOrderMaterial.setMaterialId(materialId);
  275. }
  276. //执行新增
  277. omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  278. break;
  279. case 2:
  280. case 3:
  281. //获取发运计划id
  282. //生成子表主键
  283. omstruckOrderMaterial.setOrderMaterialId(omstruckOrderMaterialMapper.selectMaxId());
  284. Integer dayPlanId = (Integer) map.get("dayPlanId");
  285. //设置订单id
  286. omstruckOrderMaterial.setOrderId(orderId);
  287. //根据发运计划id查找物资id和物资重量
  288. map = omstruckOrderMapper.selectMaterialIdAndWeightByDayPlanId(dayPlanId);
  289. BigDecimal materialId = (BigDecimal) map.get("materialId");
  290. BigDecimal materialWeight = (BigDecimal) map.get("materialWeight");
  291. //设置物资id
  292. omstruckOrderMaterial.setMaterialId(DataChange.dataToBigDecimal(materialId));
  293. //设置物资重量
  294. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  295. omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  296. break;
  297. case 4:
  298. break;
  299. case 5:
  300. case 6:
  301. case 7:
  302. case 8:
  303. case 17:
  304. case 18:
  305. //生成子表主键
  306. omstruckOrderMaterial.setOrderMaterialId(omstruckOrderMaterialMapper.selectMaxId());
  307. omstruckOrderMaterial.setMaterialId(DataChange.dataToBigDecimal(map.get("materialId")));
  308. omstruckOrderMaterial.setOrderId(orderId);
  309. Object orderMaterialWeight = map.get("orderMaterialWeight");
  310. if (orderMaterialWeight != null) {
  311. if (orderMaterialWeight.toString().length() != 0) {
  312. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(map.get("orderMaterialWeight")));
  313. }
  314. }
  315. Object orderMaterialNumber = map.get("orderMaterialNumber");
  316. if(orderMaterialNumber != null ) {
  317. if (orderMaterialNumber.toString().length() != 0) {
  318. omstruckOrderMaterial.setOrderMaterialNumber(DataChange.dataToBigDecimal(map.get("orderMaterialNumber")));
  319. }
  320. }
  321. omstruckOrderMaterial.setInsertUsername("admin");
  322. omstruckOrderMaterial.setInsertTime(new Date());
  323. omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  324. break;
  325. case 9:
  326. break;
  327. case 10:
  328. break;
  329. case 11:
  330. }
  331. }
  332. /**
  333. * 修改运输订单 和订单子表
  334. *
  335. * @param map
  336. * @return
  337. */
  338. @Override
  339. @Transactional
  340. public int updateOrder(Map<String, Object> map) {
  341. //修改运输订单运力ID
  342. OmstruckOrder omstruckOrder = new OmstruckOrder();
  343. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  344. BigDecimal orderType;
  345. if(map.get("orderType") == null){
  346. //查询订单类型
  347. orderType = new BigDecimal(omstruckOrderMapper.getOrderTypeByOrderNumber(orderId));
  348. }else{
  349. orderType = DataChange.dataToBigDecimal(map.get("orderType"));
  350. }
  351. omstruckOrder.setOrderId(orderId);
  352. if (map.get("unloadPointId") != null) {
  353. omstruckOrder.setUnloadPointId(DataChange.dataToBigDecimal(map.get("unloadPointId")));
  354. }
  355. if (map.get("capacityId") != null) {
  356. omstruckOrder.setCapacityId(DataChange.dataToBigDecimal(map.get("capacityId")));
  357. }
  358. if(map.get("orderEntryTime") != null){
  359. omstruckOrder.setOrderEntryTime(new Date((long) map.get("orderEntryTime")));
  360. }
  361. if(map.get("unloadPointId")!=null || map.get("capacityId") != null || map.get("orderEntryTime") != null){
  362. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  363. }
  364. switch (orderType.intValue()) {
  365. case 1:
  366. break;
  367. case 2:
  368. break;
  369. case 3:
  370. break;
  371. case 4:
  372. break;
  373. case 5:
  374. case 6:
  375. case 7:
  376. case 8:
  377. case 17:
  378. case 18:
  379. //修改运输订单子表物资重量
  380. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  381. //添加子表主键 通过订单ID查询出子表主键
  382. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.getOrderMaterialIdByOrderId(DataChange.dataToBigDecimal(map.get("orderId")));
  383. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  384. if (map.get("orderMaterialWeight") != null) {
  385. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(map.get("orderMaterialWeight")));
  386. if(orderType.intValue() == 8)
  387. amsFeign.updateMaterial(map);//修改运输计划子表 已分配未分配重量
  388. }
  389. if(map.get("orderMaterialNumber") != null) {
  390. omstruckOrderMaterial.setOrderMaterialNumber(DataChange.dataToBigDecimal(map.get("orderMaterialNumber")));
  391. }
  392. if (map.get("materialId") != null) {
  393. omstruckOrderMaterial.setMaterialId(DataChange.dataToBigDecimal(map.get("materialId")));
  394. }
  395. if(map.get("orderMaterialWeight") != null || map.get("orderMaterialNumber") != null || map.get("materialId") != null){
  396. omstruckOrderMaterialMapper.updateByPrimaryKeySelective(omstruckOrderMaterial);
  397. }
  398. break;
  399. case 9:
  400. break;
  401. case 10:
  402. break;
  403. case 11:
  404. }
  405. return 1;
  406. }
  407. /**
  408. * 逻辑删除未下发订单
  409. *
  410. * @param map
  411. * @return
  412. */
  413. @Override
  414. @Transactional
  415. public int deleteOrder(Map<String, Object> map) {
  416. OmstruckOrder omstruckOrder = new OmstruckOrder();
  417. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(map.get("orderId")));
  418. //设置状态为逻辑删除:7
  419. omstruckOrder.setOrderStatus(new BigDecimal(7));
  420. int i = omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  421. //若是传来物资重量则修改已分配未分配重量
  422. if (map.get("orderMaterialWeight") != null) {
  423. amsFeign.updateMaterial(map); //feign调用
  424. }
  425. // //通过车牌号修改运输状态为空闲中 0
  426. // String capacityNumber = (String) map.get("capacityNumber");
  427. // HashMap<String, Object> changeStatusMap = new HashMap<>();
  428. // changeStatusMap.put("capacityNumber", capacityNumber);
  429. // changeStatusMap.put("capacityStatus", 0);
  430. // int i1 = omstruckOrderMapper.updateCapacityByCarIdOrNum(changeStatusMap);
  431. return i;
  432. }
  433. /**
  434. * 运单派发、下发
  435. * 运单ID
  436. *
  437. * @param mapValue
  438. * @return
  439. */
  440. @Override
  441. @Transactional
  442. public int dispatchOrder(Map<String, Object> mapValue) {
  443. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  444. int result = 0;
  445. for (Map<String, Object> map : mapList) {
  446. Integer orderId = (Integer) map.get("orderId");
  447. OmstruckOrder omstruckOrder = new OmstruckOrder();
  448. omstruckOrder.setOrderId(new BigDecimal(orderId));
  449. //生成订单下发时间 修改订单表
  450. omstruckOrder.setOrderIssueTime(new Date());
  451. //设置状态为已下发:4
  452. omstruckOrder.setOrderStatus(new BigDecimal(4));
  453. //下发 推送数据给 websocket
  454. pushMesToWebsocket(map);
  455. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  456. }
  457. return result;
  458. }
  459. /**
  460. * 发送消息到 websocket 推送消息
  461. * orderId 订单Id
  462. * @return
  463. */
  464. public void pushMesToWebsocket(Map<String, Object> map) {
  465. Map<String, Object> mesMap = omstruckOrderMapper.pushMesToWebsocket(map);
  466. //添加消息实体
  467. HashMap<Object, Object> mapp = new HashMap<>();
  468. mapp.put("messageType", 3);
  469. mapp.put("sendPerson", "system");
  470. mapp.put("receivePerson", mesMap.get("capacityNumber"));
  471. mapp.put("messageContent", mesMap);
  472. mapp.put("createTime", new Date());
  473. ArrayList<Object> list = new ArrayList<>();
  474. list.add(mapp);
  475. //调用websocket接口推送
  476. HashMap<Object, Object> sendMap = new HashMap<>();
  477. //将消息实体放入list中存到map中
  478. sendMap.put("messages", list);
  479. String s = imFeign.sendToUser(sendMap);
  480. System.out.println(s);
  481. }
  482. @Override//判断一车多单是否还有订单,如果又就再推送消息给他
  483. public void pushMessageToDriver(Map<String, Object> mapValue) {
  484. Map<String,Object> mapAddOrder =omstruckOrderMapper.getSporadicOrdermapAddOrder(new BigDecimal(mapValue.get("orderId").toString()));
  485. BigDecimal sporadicOrderTimes = DataChange.dataToBigDecimal(mapAddOrder.get("sporadicOrderTimes"));
  486. BigDecimal sporadicOrderId = DataChange.dataToBigDecimal(mapAddOrder.get("sporadicOrderId"));
  487. BigDecimal transStatus = DataChange.dataToBigDecimal(mapAddOrder.get("transStatus"));
  488. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  489. //获取运输订单类型
  490. Integer orderType = omstruckOrderMapper.getOrderTypeByOrderId(orderId);
  491. BigDecimal capacityId = DataChange.dataToBigDecimal(mapAddOrder.get("capacityId"));
  492. Map<String, Object> addMapSporadicOrder = new HashMap<>();
  493. addMapSporadicOrder.put("sporadicOrderId",sporadicOrderId);
  494. addMapSporadicOrder.put("orderId",orderId);
  495. List<Map<String,Object>> mapList = new ArrayList<>();
  496. Map<String,Object> map=new HashMap<>();
  497. map.put("capacityId",capacityId);
  498. mapList.add(map);
  499. addMapSporadicOrder.put("mapList",mapList);
  500. switch (orderType) {
  501. case 13:
  502. case 19:
  503. case 12:
  504. if (transStatus.intValue()==1){
  505. amsFeign.addSporadicOrderTimes(addMapSporadicOrder);
  506. }
  507. break;
  508. //普通零星
  509. case 15:
  510. case 16:
  511. if (sporadicOrderTimes.intValue() > 0) {
  512. //mapvalue需要orderId,零星订单id,maplist放一个运力id
  513. amsFeign.addSporadicOrderTimes(addMapSporadicOrder);
  514. }
  515. }
  516. }
  517. //撤销订单
  518. @Transactional
  519. @Override
  520. public int undoOrder(Map<String, Object> map) {
  521. int result=0;
  522. BigDecimal orderId =DataChange.dataToBigDecimal(map.get("orderId"));
  523. Map<String, Object> mesMap = omstruckOrderSeparateMapper.getOrderMesByOrderId(orderId);
  524. BigDecimal orderPlanId = DataChange.dataToBigDecimal(mesMap.get("orderPlanId"));
  525. int orderType = DataChange.dataToBigDecimal(mesMap.get("orderType")).intValue();
  526. BigDecimal resultTotalId = DataChange.dataToBigDecimal(mesMap.get("resultTotalId"));
  527. OmstruckOrder omstruckOrder = new OmstruckOrder();
  528. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(orderId));
  529. omstruckOrder.setOrderStatus(new BigDecimal(4));
  530. //讲路段顺序号设为空,适应进厂以后扫码
  531. omstruckOrder.setOrderLineSequence(new BigDecimal(0));
  532. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  533. if(orderType == 11 ){
  534. result += omstruckOrderMapper.deleteLoadResult(resultTotalId);
  535. return result ;
  536. }
  537. //通过总实绩ID删除所有已经生成的实绩
  538. result += omstruckOrderMapper.deleteEnResult(resultTotalId);
  539. result += omstruckOrderMapper.deleteWeightResult(resultTotalId);
  540. result += omstruckOrderMapper.deleteUnloadResult(resultTotalId);
  541. result += omstruckOrderMapper.deleteLoadResult(resultTotalId);
  542. result += omstruckOrderMapper.deleteLeaveResult(resultTotalId);
  543. if(orderType == 15 || orderType == 16 || orderType == 19){
  544. Map<String, Object> sporadicOrderTimes = omstruckOrderMapper.getSporadicOrderTimes(orderId);
  545. BigDecimal orderTimes =(BigDecimal)sporadicOrderTimes.get("orderTimes");
  546. BigDecimal transTimes = (BigDecimal)sporadicOrderTimes.get("transTimes");
  547. //更新趟次
  548. omstruckOrderSeparateService.updateTimes(orderPlanId,orderTimes.intValue()+1);
  549. //更新已运输趟次
  550. if (transTimes.intValue()>0) {
  551. omstruckOrderSeparateMapper.updateTranTimes(orderPlanId, transTimes.intValue() - 1);
  552. }
  553. }
  554. return result;
  555. }
  556. //修改运力
  557. @Override
  558. public int updateCapacityId(Map<String,Object> map) {
  559. int result=0;
  560. OmstruckOrder omstruckOrder=new OmstruckOrder();
  561. BigDecimal orderId =DataChange.dataToBigDecimal(map.get("orderId"));
  562. BigDecimal capacityId =DataChange.dataToBigDecimal(map.get("capacityId"));
  563. omstruckOrder.setOrderId(orderId);
  564. omstruckOrder.setCapacityId(capacityId);
  565. result+=omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  566. return result;
  567. }
  568. //采购内转派单
  569. @Override
  570. public int addPurInwardOrder(Map<String, Object> mapValue) {
  571. int result = 0;
  572. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  573. BigDecimal planId = DataChange.dataToBigDecimal(mapValue.get("planId"));
  574. BigDecimal lineId = DataChange.dataToBigDecimal(mapValue.get("lineId"));
  575. BigDecimal orderType = DataChange.dataToBigDecimal(mapValue.get("orderType"));
  576. AmstruckInwardPlan amstruckInwardPlan = amstruckInwardPlanMapper.selectByPrimaryKey(planId);
  577. amstruckInwardPlan.setPlanStatus(new BigDecimal(3));
  578. result += amstruckInwardPlanMapper.updateByPrimaryKeySelective(amstruckInwardPlan);
  579. BigDecimal materialId = omstruckOrderMapper.getInwardMaterial(planId);
  580. for (Map<String,Object> orderMap : mapList) {
  581. OmstruckOrder omstruckOrder = new OmstruckOrder();
  582. String capacityNumber = (String)orderMap.get("capacityNumber");
  583. Map<String,Object> capacityMap = new HashMap<>();
  584. capacityMap.put("capacityNumber",capacityNumber);
  585. List<RmsCapacity> rmsCapacities = rmsCapacityMapper.selectByParameters(capacityMap);
  586. RmsCapacity rmsCapacity = rmsCapacities.get(0);
  587. // rmsCapacity.setCapacityStatus(new BigDecimal(2));
  588. result +=rmsCapacityMapper.updateByPrimaryKeySelective(rmsCapacity);
  589. BigDecimal capacityId = rmsCapacity.getCapacityId();
  590. capacityMap.clear();
  591. capacityMap.put("capacityId",capacityId);
  592. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  593. // 添加总实绩
  594. Map<String,Object> orderIdMap = new HashMap<>();
  595. orderIdMap.put("orderId",orderId);
  596. tmsTruckFeign.addTotalResult(orderIdMap);
  597. omstruckOrder.setOrderId(orderId);
  598. omstruckOrder.setOrderPlanId(planId);
  599. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue());
  600. omstruckOrder.setOrderNumber(orderNumber);
  601. omstruckOrder.setOrderIssueTime(new Date());
  602. omstruckOrder.setOrderStatus(new BigDecimal(4));
  603. omstruckOrder.setCapacityId(capacityId);
  604. omstruckOrder.setInsertTime(new Date());
  605. omstruckOrder.setUpdateTime(new Date());
  606. omstruckOrder.setInsertUsername("admin");
  607. omstruckOrder.setUpdateUsername("admin");
  608. omstruckOrder.setInsertUpdateRemark("无");
  609. omstruckOrder.setDeleted(new BigDecimal(0));
  610. omstruckOrder.setOrderType(orderType);
  611. omstruckOrder.setLineId(lineId);
  612. result +=omstruckOrderMapper.insertSelective(omstruckOrder);
  613. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  614. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  615. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  616. omstruckOrderMaterial.setOrderId(orderId);
  617. omstruckOrderMaterial.setMaterialId(materialId);
  618. omstruckOrderMaterial.setInsertTime(new Date());
  619. omstruckOrderMaterial.setUpdateTime(new Date());
  620. omstruckOrderMaterial.setInsertUsername("admin");
  621. omstruckOrderMaterial.setUpdateUsername("admin");
  622. omstruckOrderMaterial.setInsertUpdateRemark("无");
  623. result +=omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  624. }
  625. return result;
  626. }
  627. @Override
  628. public List<Map<String, Object>> getPurInwardOrderList(Map<String, Object> mapValue) {
  629. List<Map<String,Object>> mapList = omstruckOrderMapper.getPurInwardOrderList(mapValue);
  630. for (Map<String,Object>map:mapList
  631. ) {
  632. map.put("loadName","化工园区铁专线");
  633. }
  634. return mapList;
  635. }
  636. @Override
  637. public int addPurInwardOrder1(BigDecimal orderId) {
  638. //根据运输订单id查询信息
  639. Map<String,Object>map = omstruckOrderMapper.selectOrderMap(orderId);
  640. BigDecimal planId = DataChange.dataToBigDecimal(map.get("planId"));
  641. BigDecimal lineId = DataChange.dataToBigDecimal(map.get("lineId"));
  642. BigDecimal orderType = DataChange.dataToBigDecimal(map.get("orderType"));
  643. BigDecimal capacityId = DataChange.dataToBigDecimal(map.get("capacityId"));
  644. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  645. int result = 0;
  646. OmstruckOrder omstruckOrder = new OmstruckOrder();
  647. BigDecimal orderIds = omstruckOrderMapper.selectMaxId();
  648. // 添加总实绩
  649. Map<String,Object> orderIdMap = new HashMap<>();
  650. orderIdMap.put("orderId",orderIds);
  651. tmsTruckFeign.addTotalResult(orderIdMap);
  652. omstruckOrder.setOrderId(orderIds);
  653. omstruckOrder.setOrderPlanId(planId);
  654. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", orderIds.intValue());
  655. omstruckOrder.setOrderNumber(orderNumber);
  656. omstruckOrder.setOrderIssueTime(new Date());
  657. omstruckOrder.setOrderStatus(new BigDecimal(4));
  658. omstruckOrder.setCapacityId(capacityId);
  659. omstruckOrder.setInsertTime(new Date());
  660. omstruckOrder.setUpdateTime(new Date());
  661. omstruckOrder.setInsertUsername("admin");
  662. omstruckOrder.setUpdateUsername("admin");
  663. omstruckOrder.setInsertUpdateRemark("无");
  664. omstruckOrder.setDeleted(new BigDecimal(0));
  665. omstruckOrder.setOrderType(orderType);
  666. omstruckOrder.setLineId(lineId);
  667. result +=omstruckOrderMapper.insertSelective(omstruckOrder);
  668. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  669. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  670. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  671. omstruckOrderMaterial.setOrderId(orderIds);
  672. omstruckOrderMaterial.setMaterialId(materialId);
  673. omstruckOrderMaterial.setInsertTime(new Date());
  674. omstruckOrderMaterial.setUpdateTime(new Date());
  675. omstruckOrderMaterial.setInsertUsername("admin");
  676. omstruckOrderMaterial.setUpdateUsername("admin");
  677. omstruckOrderMaterial.setInsertUpdateRemark("无");
  678. result +=omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  679. return result;
  680. }
  681. @Override
  682. public int refuseCtrlZ(Map<String, Object> map) {
  683. return omstruckOrderMapper.refuseCtrlZ(map);
  684. }
  685. /**
  686. * 销售物流,下发订单
  687. *
  688. * @param map
  689. * @return
  690. */
  691. @Override
  692. public int dispatchOrderForSale(Map<String, Object> map) {
  693. OmstruckOrder omstruckOrder = new OmstruckOrder();
  694. Integer orderId = (Integer) map.get("orderId");
  695. Integer orderType = (Integer) map.get("orderType");
  696. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(orderId));
  697. if (orderType == 2 || orderType == 3) {
  698. Integer loadId = (Integer) map.get("LoadId");
  699. if (loadId != null) {
  700. //根据运输订单id查找装车实绩id
  701. omstruckOrder.setUnloadPointId(DataChange.dataToBigDecimal(loadId));
  702. }
  703. }
  704. //设置下发状态
  705. omstruckOrder.setOrderIssueTime(new Date());
  706. omstruckOrder.setOrderStatus(new BigDecimal(4));
  707. // pushMesToWebsocket(map); //下发 推送数据给 websocket
  708. return omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  709. }
  710. @Override
  711. public List<Map<String, Object>> selectWaterSlagForOrder(Map<String, Object> map) {
  712. return omstruckOrderMapper.selectWaterSlagForOrder(map);
  713. }
  714. @Override
  715. public List<Map<String, Object>> selectCokeRailPlanForOrder(Map<String, Object> map) {
  716. return omstruckOrderMapper.selectCokeRailPlanForOrder(map);
  717. }
  718. /**
  719. * 司机接单、拒绝 0:拒绝 1:接收
  720. * 需要接收参数 主键Id 与 接收拒绝操作码
  721. *
  722. * @param map
  723. * @return
  724. */
  725. @Override
  726. @Transactional
  727. public synchronized int driverReceiveOrRefuse(Map<String, Object> map) throws RuntimeException {
  728. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  729. OmstruckOrder omstruckOrder = new OmstruckOrder();
  730. if((Integer) map.get("orderReceiveStatus") == 1) {
  731. List<Integer> orderIdList = omstruckOrderMapper.getReceiveOrderIdListByCapacityNum((String) map.get("capacityNumber"));
  732. if (orderIdList.size() > 0) {
  733. throw new RuntimeException("已有接收的订单!");
  734. }
  735. omstruckOrder.setOrderStatus(new BigDecimal(5)); //5 :已接收
  736. //通过订单ID查询信息
  737. Map<String, Object> orderMessage = omstruckOrderSeparateMapper.getOrderMessagge(orderId);
  738. int orderStatus = DataChange.dataToBigDecimal(orderMessage.get("orderStatus")).intValue();
  739. if(orderStatus == 5 || orderStatus == 6) {
  740. throw new RuntimeException("订单已被接收或已被拒绝!");
  741. }
  742. int orderType = DataChange.dataToBigDecimal(orderMessage.get("orderType")).intValue();
  743. if(orderType == 11){
  744. //发送计量委托
  745. orderMessage.put("asd", 1);
  746. orderMessage.put("orderId", orderId);
  747. tmsTruckFeign.sendMeasureCommission(orderMessage);
  748. }else {
  749. //添加各个实绩
  750. omstruckOrderSeparateService.addAllSonResult(orderMessage);
  751. }
  752. //判断订单是否是一车多单
  753. if (orderType ==15 || orderType ==16 || orderType ==19) {
  754. //通过订单查询趟次
  755. Map<String, Object> sporadicOrderTimes = omstruckOrderMapper.getSporadicOrderTimes(orderId);
  756. BigDecimal orderTimes = DataChange.dataToBigDecimal(sporadicOrderTimes.get("orderTimes"));
  757. //通过订单id查询已运输趟次
  758. BigDecimal transTimes=DataChange.dataToBigDecimal(sporadicOrderTimes.get("transTimes"));
  759. //生成作业实绩之后、更改订单数量
  760. if (orderMessage.containsKey("orderPlanId") && orderTimes.intValue() > 0) {
  761. int state =0;
  762. state+=omstruckOrderSeparateService.updateTimes(new BigDecimal(orderMessage.get("orderPlanId").toString()), orderTimes.intValue() - 1);
  763. //接收订单以后已运输订单趟次+1
  764. state+=omstruckOrderSeparateMapper.updateTranTimes(DataChange.dataToBigDecimal(orderMessage.get("orderPlanId").toString()),transTimes.intValue()+1);
  765. System.out.println(state);
  766. }
  767. }
  768. } else { //其他状态都视为 拒绝接单
  769. omstruckOrder.setOrderStatus(new BigDecimal(6));
  770. //添加拒绝原因
  771. omstruckOrder.setInsertUpdateRemark((String) map.get("insertUpdateRemark"));
  772. }
  773. omstruckOrder.setOrderId(orderId);
  774. //生成接收/拒绝时间
  775. Date receiveTime = new Date();
  776. omstruckOrder.setOrderReceiveRefuseTime(receiveTime);
  777. //计算司机从派单到操作时长
  778. Date issueTime = omstruckOrderMapper.getInsertTimeById(orderId.intValue());
  779. long time = receiveTime.getTime() - issueTime.getTime();
  780. long min = time / (1000 * 60);
  781. omstruckOrder.setOrderCommunicationDuration(new BigDecimal(min));
  782. return omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  783. }
  784. //根据承运商获取销售订单
  785. @Override
  786. public List<Map<String, Object>> selectSaleOrderForCarrier(Map<String, Object> map) {
  787. Integer carrierId = (Integer) map.get("carrierId");
  788. List<Map<String, Object>> maps = omstruckOrderMapper.selectSaleMaterialIdByCarrierId(carrierId);
  789. List<Map<String, Object>> list = null;
  790. for (Map<String, Object> map1 : maps) {
  791. BigDecimal saleOrderMaterialId = (BigDecimal) map1.get("saleOrderMaterialId");
  792. list = omstruckOrderMapper.selectSaleBySaleOrderMaterialId(saleOrderMaterialId.intValue());
  793. }
  794. return list;
  795. }
  796. /**
  797. * 查询已接收的焦炭发运计划
  798. *
  799. * @param
  800. * @return
  801. */
  802. @Override
  803. public List<Map<String, Object>> selectCokeDayPlanAndRecived(Map<String, Object> map) {
  804. return omstruckOrderMapper.selectCokeDayPlanAndRecived(map);
  805. }
  806. /**
  807. * 查询已接收的水渣发运计划
  808. *
  809. * @param
  810. * @return
  811. */
  812. @Override
  813. public List<Map<String, Object>> selectWaterSlagDayPlanAndRecived(Integer carrierId) {
  814. return omstruckOrderMapper.selectWaterSlagDayPlanAndRecived(carrierId);
  815. }
  816. /**
  817. * 司机接单推送数据
  818. * 车牌号
  819. * @param
  820. * @return
  821. */
  822. @Override
  823. public List<Map<String, Object>> sendMesToDriver(Map<String, Object> map) {
  824. //通过车牌号匹配运力ID
  825. BigDecimal capacityId = omstruckOrderMapper.getCapacityIdByCapacityNum((String) map.get("capacityNumber"));
  826. if (capacityId == null) {
  827. return null;
  828. }
  829. map.put("capacityId", capacityId);
  830. //通过运力Id匹配 已下发的运输订单
  831. List<Map<String, Object>> truckOrderByCapacityNum;
  832. if ((Integer) map.get("orderType") == 1 || (Integer) map.get("orderType") == 2) {
  833. truckOrderByCapacityNum = omstruckOrderMapper.getSaleTruckOrderByCapacityNum(map);
  834. } else {
  835. truckOrderByCapacityNum = omstruckOrderMapper.getTruckOrderByCapacityNum(map);
  836. }
  837. return truckOrderByCapacityNum;
  838. }
  839. /**
  840. * 得到作业时间和地点
  841. *
  842. * @param orderId
  843. * @return
  844. */
  845. @Override
  846. public List<Map<String, Object>> selectPlaceAndTime(BigDecimal orderId) {
  847. List<Map<String, Object>> mapList = omstruckOrderMapper.selectPlaceAndTime(orderId);
  848. Map<String, Object> map = mapList.get(0);
  849. String entryGatepost = (String) map.get("entryGatepost");
  850. Date entryTime = (Date) map.get("entryTime");
  851. String entryResult = entryGatepost + "/" + entryTime;
  852. String grossCalculate = (String) map.get("grossCalculate");
  853. Date grossTime = (Date) map.get("grossTime");
  854. String grossResult = grossCalculate + "/" + grossTime;
  855. String unloadWarhouse = (String) map.get("unloadWarhouse");
  856. Date unloadTime = (Date) map.get("unloadTime");
  857. String unloadResult = unloadWarhouse + "/" + unloadTime;
  858. String tareCalculate = (String) map.get("tareCalculate");
  859. Date tareTime = (Date) map.get("tareTime");
  860. String tareResult = tareCalculate + "/" + tareTime;
  861. String leaveGatepost = (String) map.get("leaveGatepost");
  862. Date outTime = (Date) map.get("outTime");
  863. String leaveResult = leaveGatepost + "/" + outTime;
  864. String receiptWarhouse = (String) map.get("receiptWarhouse");
  865. Date receiptTime = (Date) map.get("receiptTime");
  866. String receiptResult = receiptWarhouse + "/" + receiptTime;
  867. List<Map<String, Object>> resultList = new ArrayList<>();
  868. Map<String, Object> map1 = new HashMap<>();
  869. map1.put("title", "进厂门岗/时间");
  870. map1.put("desc", entryResult);
  871. resultList.add(map1);
  872. Map<String, Object> map2 = new HashMap<>();
  873. map2.put("title", "毛重衡器/时间");
  874. map2.put("desc", grossResult);
  875. resultList.add(map2);
  876. Map<String, Object> map3 = new HashMap<>();
  877. map3.put("title", "卸货地点/时间");
  878. map3.put("desc", unloadResult);
  879. resultList.add(map3);
  880. Map<String, Object> map4 = new HashMap<>();
  881. map4.put("title", "皮重衡器/时间");
  882. map4.put("desc", tareResult);
  883. resultList.add(map4);
  884. Map<String, Object> map5 = new HashMap<>();
  885. map5.put("title", "出厂门岗/时间");
  886. map5.put("desc", leaveResult);
  887. resultList.add(map5);
  888. if ((Integer) map.get("orderType") == 1) {
  889. Map<String, Object> map6 = new HashMap<>();
  890. map5.put("title", "异地库/时间");
  891. map5.put("desc", receiptResult);
  892. resultList.add(map6);
  893. }
  894. Map<String, Object> map7 = new HashMap<>();
  895. BigDecimal orderLineSequence = (BigDecimal) map.get("orderLineSequence");
  896. map7.put("orderLineSequence", orderLineSequence);
  897. resultList.add(map7);
  898. return resultList;
  899. }
  900. /**
  901. * 查询已下发未接受的销售订单信息
  902. *
  903. * @param orderType
  904. * @return
  905. */
  906. @Override
  907. public List<Map<String, Object>> getOrderUnReceive(BigDecimal orderType) {
  908. return omstruckOrderMapper.getOrderUnReceive(orderType);
  909. }
  910. /**
  911. * 查询已下发已接受的销售订单信息
  912. *
  913. * @param orderType
  914. * @return
  915. */
  916. @Override
  917. public List<Map<String, Object>> getOrderReceived(BigDecimal orderType) {
  918. return omstruckOrderMapper.getOrderReceived(orderType);
  919. }
  920. /**
  921. * 分派钢材销售订单
  922. *
  923. * @param map
  924. * @return
  925. */
  926. @Override
  927. public int dispatchSteelOrder(Map<String, Object> map) {
  928. //新增运单(销售钢材订单)
  929. //生成运输订单号和主键以及绑定运力
  930. OmstruckOrder omstruckOrder = generateOmsTruckOrder(map);
  931. //设置线路 遗留问题,设置为进门门岗
  932. omstruckOrder.setLineId(new BigDecimal(1));
  933. //新增运输订单
  934. omstruckOrderMapper.insertSelective(omstruckOrder);
  935. //更新运力状态为待运输:2
  936. // map.put("capacityStatus", 2);
  937. // omstruckOrderMapper.updateCapacityById(map);
  938. //新增运输订单子表
  939. addOrderMaterial(map, omstruckOrder.getOrderId());
  940. //新增实绩总表关联订单 feign调用
  941. map.put("orderId", omstruckOrder.getOrderId());
  942. tmsTruckFeign.addTotalResult(map);
  943. return 6;
  944. }
  945. //设置销售订单下发状态
  946. @Override
  947. public int IssueSteelOrder(Map<String, Object> map) {
  948. //设置下发状态
  949. OmstruckOrder omstruckOrder = new OmstruckOrder();
  950. Integer orderId = (Integer) map.get("orderId");
  951. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(orderId));
  952. omstruckOrder.setOrderIssueTime(new Date());
  953. //设置下发状态值:4
  954. omstruckOrder.setOrderStatus(new BigDecimal(4));
  955. return 2;
  956. }
  957. //销售模块查看所有订单
  958. @Override
  959. public List<Map<String, Object>> selectAllOrderForSale(Map<String, Object> map) {
  960. //map获取承运商
  961. Integer carrierId = (Integer) map.get("carrierId");
  962. Integer saleOrderMaterialId = (Integer) map.get("saleOrderMaterialId");
  963. List<Map<String, Object>> maps = omstruckOrderMapper.selectSaleMaterialIdByCarrierId(carrierId);
  964. //根据车序号查找运输订单
  965. List<Map<String, Object>> mapList = null;
  966. List<Map<String, Object>> maps1 = new ArrayList<>();
  967. //判断获取的车序号是否属于承运商
  968. for (Map<String, Object> map1 : maps) {
  969. BigDecimal compareNum = DataChange.dataToBigDecimal(map1.get("saleOrderMaterialId"));
  970. if (compareNum.intValue() == saleOrderMaterialId) {
  971. mapList = omstruckOrderMapper.selectAllOrderForSale(map);
  972. for (int i = 0; i < mapList.size(); i++) {
  973. Map<String, Object> map2 = mapList.get(i);
  974. if (map2.get("orderId") == null) {
  975. return maps1;
  976. }
  977. }
  978. return mapList;
  979. }
  980. }
  981. return maps1;
  982. }
  983. @Override
  984. public List<Map<String, Object>> selectTransportOrderForSale(Map<String, Object> map) {
  985. String carrierSsoId = (String) map.get("carrierSsoId");
  986. BigDecimal carrierId = omstruckOrderMapper.getCarrierIdBySSO(carrierSsoId);
  987. map.put("carrierId",carrierId);
  988. List<Map<String, Object>> mapList = omstruckOrderMapper.selectTransportOrderForSale(map);
  989. int count = 1;
  990. for (Map<String, Object> stringObjectMap : mapList) {
  991. stringObjectMap.put("ROW_ID",count);
  992. count ++;
  993. }
  994. return mapList;
  995. }
  996. @Override
  997. public List<Map<String, Object>> selectSteelSaleForCarrier(Map<String, Object> map) {
  998. return omstruckOrderMapper.selectSteelSaleForCarrier(map);
  999. }
  1000. //根据销售订单id查找信息
  1001. @Override
  1002. public List<Map<String, Object>> selectInfoBySaleOrderId(Integer saleOrderId) {
  1003. return omstruckOrderMapper.selectInfoBySaleOrderId(saleOrderId);
  1004. }
  1005. @Override
  1006. public List<Map<String, Object>> selectCokeRailPlan(Map<String, Object> map) {
  1007. return omstruckOrderMapper.selectCokeRailPlan(map);
  1008. }
  1009. @Override
  1010. public List<Map<String, Object>> selectInfoByDayPlanId(Map<String, Object> map) {
  1011. return omstruckOrderMapper.selectInfoByDayPlanId(map);
  1012. }
  1013. /**
  1014. * 查找司机排班表信息
  1015. *
  1016. * @param map
  1017. * @return
  1018. */
  1019. @Override
  1020. public List<Map<String, Object>> selectCapacityAndDriver(Map<String, Object> map) {
  1021. return omstruckOrderMapper.selectCapacityAndDriver(map);
  1022. }
  1023. /**
  1024. * 查询所有运力信息
  1025. *
  1026. * @return
  1027. */
  1028. @Override
  1029. public List<Map<String, Object>> getAllCapacity(Map<String, Object> map) {
  1030. return omstruckOrderMapper.getAllCapacity(map);
  1031. }
  1032. /**
  1033. * 用于后台展示司机接单未接单数据
  1034. *
  1035. * @param map
  1036. * @return
  1037. */
  1038. @Override
  1039. public List<Map<String, Object>> getReceiveRefuseOrder(Map<String, Object> map) {
  1040. return omstruckOrderMapper.getTruckOrderByCapacityNum(map);
  1041. }
  1042. /**
  1043. * 通过运输订单号查询运单所有信息 包含作业路径名称
  1044. *
  1045. * @param map 传运输订单号
  1046. * @return
  1047. */
  1048. @Override
  1049. public List<Map<String, Object>> getOrderMesByOrderNum(Map<String, Object> map) {
  1050. return omstruckOrderMapper.getTruckOrderByCapacityNum(map);
  1051. }
  1052. /**
  1053. * 查询所有司机已拒绝的订单
  1054. * 车牌号
  1055. *
  1056. * @param map
  1057. * @return
  1058. */
  1059. @Override
  1060. public List<Map<String, Object>> getReceiveRefuseOrderByCapacityId(Map<String, Object> map) {
  1061. //通过车牌号查询运力Id
  1062. BigDecimal capacityId = omstruckOrderMapper.getCapacityIdByCapacityNum((String) map.get("capacityNumber"));
  1063. map.put("capacityId", capacityId);
  1064. return omstruckOrderMapper.getReceiveRefuseOrderByCapacityId(map);
  1065. }
  1066. /**
  1067. * 通过运单号查询订单详情
  1068. * 运输订单号
  1069. *
  1070. * @param
  1071. * @return
  1072. */
  1073. @Override
  1074. public List<Map<String, Object>> getOrderByOrderId(BigDecimal orderId) {
  1075. return omstruckOrderMapper.getOrderByOrderId(orderId);
  1076. }
  1077. /**
  1078. * 查看运输派单
  1079. *
  1080. * @param map
  1081. * @return
  1082. */
  1083. @Override
  1084. public List<Map<String, Object>> getTransportDispatch(Map<String, Object> map) {
  1085. return omstruckOrderMapper.getTransportDispatch(map);
  1086. }
  1087. /**
  1088. * 用于更新路段顺序号
  1089. *
  1090. * @param map orderId
  1091. * @return
  1092. */
  1093. public int updateOrderLineSequence(Map<String, Object> map, Integer lineSequence) {
  1094. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1095. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(map.get("orderId")));
  1096. omstruckOrder.setOrderLineSequence(new BigDecimal(lineSequence));
  1097. return omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1098. }
  1099. //新增内转运输订单
  1100. @Override
  1101. public int insert(OmstruckOrder omstruckOrder) {
  1102. //生成订单主键Id
  1103. BigDecimal maxId = omstruckOrderMapper.selectMaxId();
  1104. omstruckOrder.setOrderId(maxId);
  1105. //生成运输订单号
  1106. int id = maxId.intValue();
  1107. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", id);
  1108. omstruckOrder.setOrderNumber(orderNumber);
  1109. //设置状态为未下发
  1110. omstruckOrder.setOrderStatus(new BigDecimal(3));
  1111. //设置运输订单的类型
  1112. omstruckOrder.setOrderType(new BigDecimal(11));
  1113. omstruckOrder.setInsertTime(new Date());
  1114. omstruckOrder.setInsertUsername("admin");
  1115. return omstruckOrderMapper.insertSelective(omstruckOrder);
  1116. }
  1117. //通过物资id查询批次表匹配最新的批次,关联最新的采购订单号
  1118. @Override
  1119. public Map<String, Object> selectNewOrderId(Map<String, Object> map) {
  1120. return omstruckOrderMapper.selectNewOrderId(map);
  1121. }
  1122. //app司机接单查询数据
  1123. @Override
  1124. public Map<String, Object> sendMesToDriverApp(Map<String, Object> map) {
  1125. //通过车牌号匹配运力ID
  1126. BigDecimal capacityId = omstruckOrderMapper.getCapacityIdByCapacityNum((String) map.get("capacityNumber"));
  1127. map.put("capacityId", capacityId);
  1128. if (capacityId == null) {
  1129. return null;
  1130. }
  1131. //通过运力Id匹配 已下发的运输订单
  1132. Map<String, Object> truckOrderByCapacityNum = new HashMap<>();
  1133. if ((Integer) map.get("orderType") == 1 || (Integer) map.get("orderType") == 2) {
  1134. //查询主干信息
  1135. Map<String, Object> map1 = omstruckOrderMapper.getSaleTruckOrderByCapacityId(map);
  1136. //查询物资信息
  1137. List<Map<String, Object>> mapList = omstruckOrderMapper.getSaleTruckOrderByCapacityNumMaterial(map);
  1138. truckOrderByCapacityNum.put("orderf", map1);
  1139. truckOrderByCapacityNum.put("materialList", mapList);
  1140. }
  1141. return truckOrderByCapacityNum;
  1142. }
  1143. @Override
  1144. public BigDecimal selectCapacityId(BigDecimal carrierId, String capacityNumber) {
  1145. return omstruckOrderMapper.selectCapacityId(carrierId, capacityNumber);
  1146. }
  1147. /**
  1148. * 车牌号下拉
  1149. *
  1150. * @return
  1151. */
  1152. @Override
  1153. public List<Map<String, Object>> getDriverCapacity() {
  1154. return omstruckOrderMapper.getDriverCapacity();
  1155. }
  1156. /**
  1157. * 派单信息
  1158. *
  1159. * @param dispatchId
  1160. * @return
  1161. */
  1162. @Override
  1163. public Map<String, Object> getTruckNoDispatchMap(Integer dispatchId) {
  1164. Map<String, Object> map = omstruckOrderMapper.getTruckNoDispatchMap(new BigDecimal(dispatchId));
  1165. List<BigDecimal> orderIdList = omstruckOrderMapper.getNullOrNotNull(new BigDecimal(dispatchId));
  1166. if (orderIdList != null || orderIdList.size() != 0) {
  1167. return null;
  1168. }
  1169. List<Map<String, Object>> materialMessages = omstruckOrderMapper.getMaterialMessages(new BigDecimal(dispatchId));
  1170. String allMaterialName = "";
  1171. String allMaterialNumber = "";
  1172. String allMaterialTheoreticalWeight = "";
  1173. String allMaterialSpecificationModel = "";
  1174. if (materialMessages == null || materialMessages.size() == 0) {
  1175. } else {
  1176. for (Map<String, Object> materialMap : materialMessages) {
  1177. if (materialMap != null) {
  1178. String materialName = (String) materialMap.get("materialName");
  1179. allMaterialName += materialName + "/";
  1180. String materialTheoreticalWeight = materialMap.get("materialTheoreticalWeight").toString();
  1181. if (materialTheoreticalWeight != null) {
  1182. allMaterialTheoreticalWeight += materialTheoreticalWeight + "/";
  1183. }
  1184. String saleOrderMaterialNumber = materialMap.get("saleOrderMaterialNumber").toString();
  1185. allMaterialNumber += saleOrderMaterialNumber + "/";
  1186. String specificationModel = materialMap.get("specificationModel").toString();
  1187. if (specificationModel != null) {
  1188. allMaterialSpecificationModel += specificationModel + "/";
  1189. }
  1190. }
  1191. }
  1192. String subMaterialName = null;
  1193. String subMaterialNumber = null;
  1194. String subMaterialTheoreticalWeight = null;
  1195. String subMaterialSpecificationModel = null;
  1196. if (allMaterialName.length() >= 2) {
  1197. subMaterialName = allMaterialName.substring(0, allMaterialName.length() - 2);
  1198. }
  1199. if (allMaterialName.length() < 2) {
  1200. subMaterialName = allMaterialName;
  1201. }
  1202. if (allMaterialNumber.length() >= 2) {
  1203. subMaterialNumber = allMaterialNumber.substring(0, allMaterialNumber.length() - 2);
  1204. }
  1205. if (allMaterialNumber.length() < 2) {
  1206. subMaterialNumber = allMaterialNumber;
  1207. }
  1208. if (allMaterialTheoreticalWeight.length() >= 2) {
  1209. subMaterialTheoreticalWeight = allMaterialTheoreticalWeight.substring(0, allMaterialTheoreticalWeight.length() - 2);
  1210. }
  1211. if (allMaterialTheoreticalWeight.length() < 2) {
  1212. subMaterialTheoreticalWeight = allMaterialTheoreticalWeight;
  1213. }
  1214. if (allMaterialSpecificationModel.length() >= 2) {
  1215. subMaterialSpecificationModel = allMaterialSpecificationModel.substring(0, allMaterialSpecificationModel.length() - 2);
  1216. }
  1217. if (allMaterialSpecificationModel.length() < 2) {
  1218. subMaterialSpecificationModel = allMaterialSpecificationModel;
  1219. }
  1220. map.put("allMaterialName", subMaterialName);
  1221. map.put("allMaterialNumber", subMaterialNumber);
  1222. map.put("allMaterialTheoreticalWeight", subMaterialTheoreticalWeight);
  1223. map.put("allMaterialSpecificationModel", subMaterialSpecificationModel);
  1224. }
  1225. return map;
  1226. }
  1227. /**
  1228. * 承运商分派运输订单给司机
  1229. * @param dispatchId
  1230. * @param orderType
  1231. * @param capacityNumber
  1232. * @param carrierId
  1233. * @return
  1234. */
  1235. @Override
  1236. public int addAppTruckOrder(Integer dispatchId, Integer orderType, String capacityNumber, Integer carrierId) {
  1237. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1238. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  1239. Map<String,Object> orderIdMap = new HashMap<>();
  1240. orderIdMap.put("orderId",orderId);
  1241. tmsTruckFeign.addTotalResult(orderIdMap);
  1242. omstruckOrder.setOrderId(orderId);
  1243. BigDecimal saleOrderMaterialId = omstruckOrderMapper.getSaleMaterialId(new BigDecimal(dispatchId));
  1244. omstruckOrder.setOrderPlanId(saleOrderMaterialId);
  1245. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue());
  1246. omstruckOrder.setOrderNumber(orderNumber);
  1247. omstruckOrder.setOrderIssueTime(new Date());
  1248. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1249. omstruckOrder.setInsertTime(new Date());
  1250. omstruckOrder.setUpdateTime(new Date());
  1251. omstruckOrder.setInsertUsername("admin");
  1252. omstruckOrder.setUpdateUsername("admin");
  1253. omstruckOrder.setInsertUpdateRemark("无");
  1254. omstruckOrder.setDeleted(new BigDecimal(0));
  1255. omstruckOrder.setOrderType(new BigDecimal(orderType));
  1256. BigDecimal capacityId = omstruckOrderMapper.getCapacityId(capacityNumber);
  1257. omstruckOrder.setCapacityId(capacityId);
  1258. // omstruckOrder.setCarrierId();
  1259. // BigDecimal driverCapacityId = omstruckOrderMapper.getDriverCapacityId(capacityId);
  1260. // omstruckOrder.setDriverCapacityId(driverCapacityId);
  1261. // RmsDriverCapacity rmsDriverCapacity = rmsDriverCapacityMapper.selectByPrimaryKey(driverCapacityId);
  1262. // rmsDriverCapacity.setCarrierId(new BigDecimal(carrierId));
  1263. // rmsDriverCapacityMapper.updateByPrimaryKeySelective(rmsDriverCapacity);
  1264. List<Map<String, Object>> mapList = omstruckOrderMapper.getMaterialMessages(new BigDecimal(dispatchId));
  1265. if (mapList != null && mapList.size() != 0) {
  1266. for (Map<String, Object> map : mapList) {
  1267. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1268. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  1269. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  1270. omstruckOrderMaterial.setOrderId(orderId);
  1271. omstruckOrderMaterial.setInsertTime(new Date());
  1272. omstruckOrderMaterial.setUpdateTime(new Date());
  1273. omstruckOrderMaterial.setInsertUsername("admin");
  1274. omstruckOrderMaterial.setUpdateUsername("admin");
  1275. omstruckOrderMaterial.setInsertUpdateRemark("无");
  1276. if (map != null) {
  1277. BigDecimal materialTheoreticalWeight = (BigDecimal) map.get("materialTheoreticalWeight");
  1278. BigDecimal saleOrderMaterialNumber = (BigDecimal) map.get("saleOrderMaterialNumber");
  1279. BigDecimal materialId = (BigDecimal) map.get("materialId");
  1280. omstruckOrderMaterial.setOrderMaterialWeight(materialTheoreticalWeight);
  1281. omstruckOrderMaterial.setMaterialId(materialId);
  1282. omstruckOrderMaterial.setOrderMaterialNumber(saleOrderMaterialNumber);
  1283. }
  1284. omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1285. }
  1286. }
  1287. // RmsCapacity rmsCapacity = new RmsCapacity();
  1288. // rmsCapacity.setCapacityId(capacityId);
  1289. // rmsCapacity.setCapacityStatus(new BigDecimal(2));
  1290. // rmsCapacityMapper.updateByPrimaryKeySelective(rmsCapacity);
  1291. int result = omstruckOrderMapper.insertSelective(omstruckOrder);
  1292. // 调用websocket推送数据给司机
  1293. pushMesToWebsocket(orderIdMap);
  1294. return result;
  1295. }
  1296. /**
  1297. * 根据运单id关闭订单
  1298. * @param orderId
  1299. * @return
  1300. */
  1301. @Override
  1302. public int closeOmstruckOrder(BigDecimal orderId) {
  1303. OmstruckOrder omstruckOrder = omstruckOrderMapper.selectByPrimaryKey(orderId);
  1304. omstruckOrder.setOrderStatus(new BigDecimal(7));
  1305. int result = omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1306. return result;
  1307. }
  1308. /**
  1309. * 查询所有车牌号和司机
  1310. * @param mapValue
  1311. * @return
  1312. */
  1313. @Override
  1314. public List<Map<String, Object>> getCapacityAndDriverList(Map<String, Object> mapValue) {
  1315. return omstruckOrderMapper.getCapacityAndDriver(mapValue);
  1316. }
  1317. @Override
  1318. public int closeOrder(Map<String, Object> map) {
  1319. Integer orderId =(Integer) map.get("orderId");
  1320. OmstruckOrder omstruckOrder=new OmstruckOrder();
  1321. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(orderId));
  1322. omstruckOrder.setOrderStatus(new BigDecimal(8));
  1323. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1324. return 1;
  1325. }
  1326. /**
  1327. * 分解内转计划(新增运输订单)
  1328. * @param mapValue
  1329. * @return
  1330. */
  1331. @Transactional
  1332. @Override
  1333. public int addInwardOrder(Map<String, Object> mapValue) {
  1334. int result = 0;
  1335. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1336. BigDecimal planId = DataChange.dataToBigDecimal(mapValue.get("planId")) ;
  1337. BigDecimal lineId = DataChange.dataToBigDecimal(mapValue.get("lineId")) ;
  1338. BigDecimal orderType = DataChange.dataToBigDecimal(mapValue.get("orderType")) ;
  1339. Integer carrierId = (Integer) mapValue.get("carrierId");
  1340. AmstruckInwardPlan amstruckInwardPlan = amstruckInwardPlanMapper.selectByPrimaryKey(planId);
  1341. amstruckInwardPlan.setPlanStatus(new BigDecimal(3));
  1342. result += amstruckInwardPlanMapper.updateByPrimaryKeySelective(amstruckInwardPlan);
  1343. for (Map<String,Object> orderMap : mapList) {
  1344. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1345. String capacityNumber = (String)orderMap.get("capacityNumber");
  1346. List<Map<String,Object>>orderMaterialList = (List<Map<String,Object>>)orderMap.get("orderMaterialList");
  1347. Map<String,Object> capacityMap = new HashMap<>();
  1348. capacityMap.put("capacityNumber",capacityNumber);
  1349. List<RmsCapacity> rmsCapacities = rmsCapacityMapper.selectByParameters(capacityMap);
  1350. RmsCapacity rmsCapacity = rmsCapacities.get(0);
  1351. // rmsCapacity.setCapacityStatus(new BigDecimal(2));
  1352. result +=rmsCapacityMapper.updateByPrimaryKeySelective(rmsCapacity);
  1353. BigDecimal capacityId = rmsCapacity.getCapacityId();
  1354. capacityMap.clear();
  1355. capacityMap.put("capacityId",capacityId);
  1356. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  1357. // 添加总实绩
  1358. Map<String,Object> orderIdMap = new HashMap<>();
  1359. orderIdMap.put("orderId",orderId);
  1360. tmsTruckFeign.addTotalResult(orderIdMap);
  1361. omstruckOrder.setOrderId(orderId);
  1362. omstruckOrder.setOrderPlanId(planId);
  1363. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue());
  1364. omstruckOrder.setOrderNumber(orderNumber);
  1365. omstruckOrder.setOrderIssueTime(new Date());
  1366. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1367. omstruckOrder.setCapacityId(capacityId);
  1368. omstruckOrder.setInsertTime(new Date());
  1369. omstruckOrder.setUpdateTime(new Date());
  1370. omstruckOrder.setInsertUsername("admin");
  1371. omstruckOrder.setUpdateUsername("admin");
  1372. omstruckOrder.setInsertUpdateRemark("无");
  1373. omstruckOrder.setDeleted(new BigDecimal(0));
  1374. omstruckOrder.setOrderType(orderType);
  1375. if(lineId != null){
  1376. omstruckOrder.setLineId(lineId);
  1377. }
  1378. omstruckOrder.setCarrierId(new BigDecimal(carrierId));
  1379. result +=omstruckOrderMapper.insertSelective(omstruckOrder);
  1380. for (Map<String,Object>orderMaterial:orderMaterialList
  1381. ) {
  1382. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1383. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  1384. BigDecimal materialId = DataChange.dataToBigDecimal(orderMaterial.get("materialId"));
  1385. BigDecimal materialWeight = DataChange.dataToBigDecimal(orderMaterial.get("materialWeight"));
  1386. BigDecimal materialCount = DataChange.dataToBigDecimal(orderMaterial.get("materialCount"));
  1387. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  1388. omstruckOrderMaterial.setOrderId(orderId);
  1389. omstruckOrderMaterial.setMaterialId(materialId);
  1390. omstruckOrderMaterial.setOrderMaterialNumber(materialCount);
  1391. omstruckOrderMaterial.setInsertTime(new Date());
  1392. omstruckOrderMaterial.setUpdateTime(new Date());
  1393. omstruckOrderMaterial.setInsertUsername("admin");
  1394. omstruckOrderMaterial.setUpdateUsername("admin");
  1395. omstruckOrderMaterial.setInsertUpdateRemark("无");
  1396. omstruckOrderMaterial.setOrderMaterialWeight(materialWeight);
  1397. result +=omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1398. }
  1399. }
  1400. return result;
  1401. }
  1402. /**
  1403. * 查询分解计划
  1404. * @param mapValue
  1405. * @return
  1406. */
  1407. @Override
  1408. public List<Map<String, Object>> getInwardOrderList(Map<String, Object> mapValue) {
  1409. List<Map<String,Object>> mapList = omstruckOrderMapper.getInwardOrderList(mapValue);
  1410. return mapList;
  1411. }
  1412. /**
  1413. * 下发计划
  1414. * @param mapList
  1415. * @return
  1416. */
  1417. @Override
  1418. public int issuePlanOrder(List<Map<String, Object>> mapList) {
  1419. int result = 0;
  1420. for (Map<String,Object> map : mapList) {
  1421. Integer orderId = (Integer) map.get("orderId");
  1422. OmstruckOrder omstruckOrder = omstruckOrderMapper.selectByPrimaryKey(new BigDecimal(orderId));
  1423. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1424. omstruckOrder.setOrderIssueTime(new Date());
  1425. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1426. }
  1427. return result;
  1428. }
  1429. /**
  1430. * 分派计划
  1431. * @param mapList
  1432. * @return
  1433. */
  1434. @Override
  1435. public int apportionInwardOrder(List<Map<String, Object>> mapList) {
  1436. int result = 0;
  1437. for (Map<String,Object> map : mapList) {
  1438. BigDecimal orderId = new BigDecimal((Integer) map.get("orderId"));
  1439. OmstruckOrder omstruckOrder = omstruckOrderMapper.selectByPrimaryKey(orderId);
  1440. omstruckOrder.setOrderIssueTime(new Date());
  1441. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1442. // Map<Object, Object> map9 = new HashMap<>();
  1443. // long data = new Date().getTime();
  1444. // //根据运输订单id查询车牌号
  1445. // String capacityNumber = omstruckOrderMapper.selectCapacityNumber(orderId);
  1446. // BigDecimal orderType = omstruckOrderMapper.selectOrderType(orderId);
  1447. //
  1448. // map9.put("receivePerson",capacityNumber);
  1449. // map9.put("messageType",2);
  1450. // map9.put("snedPerson","system");
  1451. // map9.put("creatTime",data);
  1452. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1453. }
  1454. return result;
  1455. }
  1456. /**
  1457. * 司机APP端查询下发给自己运输订单
  1458. * @param capacityNumber
  1459. * @return
  1460. */
  1461. @Override
  1462. public List<Map<String, Object>> sendOrderToApp(String capacityNumber) {
  1463. //通过车牌号匹配运力ID
  1464. BigDecimal capacityId = omstruckOrderMapper.getCapacityIdByCapacityNum(capacityNumber);
  1465. List<Map<String,Object>> resultList = omstruckOrderMapper.getResultList(capacityId);
  1466. for (Map<String,Object> map : resultList) {
  1467. BigDecimal orderId = (BigDecimal) map.get("orderId");
  1468. BigDecimal orderType = (BigDecimal) map.get("orderType");
  1469. // 查询物资信息
  1470. List<Map<String,Object>> materialMapList = omstruckOrderMapper.getMaterialMes(orderId);
  1471. String allMaterialName = "";
  1472. String allMaterialNumber = "";
  1473. String allMaterialWeight = "";
  1474. String allMaterialSpecificationModel = "";
  1475. // 对物资信息进行处理
  1476. if (materialMapList == null && materialMapList.size() == 0) {
  1477. } else {
  1478. for (Map<String,Object> materialMap : materialMapList) {
  1479. String materialName = (String) materialMap.get("materialName");
  1480. BigDecimal materialNumber = (BigDecimal) materialMap.get("materialNumber");
  1481. BigDecimal materialWeight = (BigDecimal) materialMap.get("materialWeight");
  1482. String materialModel = (String) materialMap.get("materialModel");
  1483. String materialSpecification = (String) materialMap.get("materialSpecification");
  1484. if (materialName != null) {
  1485. allMaterialName += materialName + "/";
  1486. }
  1487. if (materialNumber != null) {
  1488. allMaterialNumber += materialNumber.toString() + "/";
  1489. }
  1490. if (materialWeight != null) {
  1491. allMaterialWeight += materialWeight.toString() + "/";
  1492. }
  1493. if (materialSpecification != null || materialModel != null) {
  1494. allMaterialSpecificationModel += materialSpecification + materialModel + "/";
  1495. }
  1496. }
  1497. String subMaterialName = "";
  1498. String subMaterialNumber = "";
  1499. String subMaterialWeight = "";
  1500. String subMaterialSpecificationModel = "";
  1501. if (allMaterialName.length() >= 2) {
  1502. subMaterialName = allMaterialName.substring(0, allMaterialName.length() - 2);
  1503. }
  1504. if (allMaterialName.length() < 2) {
  1505. subMaterialName = allMaterialName;
  1506. }
  1507. if (allMaterialNumber.length() >= 2) {
  1508. subMaterialNumber = allMaterialNumber.substring(0, allMaterialNumber.length() - 1);
  1509. }
  1510. if (allMaterialNumber.length() < 2) {
  1511. subMaterialNumber = allMaterialNumber;
  1512. }
  1513. if (allMaterialWeight.length() >= 2) {
  1514. subMaterialWeight = allMaterialWeight.substring(0, allMaterialWeight.length() - 1);
  1515. }
  1516. if (allMaterialWeight.length() < 2) {
  1517. subMaterialWeight = allMaterialWeight;
  1518. }
  1519. if (allMaterialSpecificationModel.length() >= 2) {
  1520. subMaterialSpecificationModel = allMaterialSpecificationModel.substring(0, allMaterialSpecificationModel.length() - 2);
  1521. }
  1522. if (allMaterialSpecificationModel.length() < 2) {
  1523. subMaterialSpecificationModel = allMaterialSpecificationModel;
  1524. }
  1525. map.put("allMaterialName", subMaterialName);
  1526. map.put("allMaterialNumber", subMaterialNumber);
  1527. map.put("allMaterialWeight", subMaterialWeight);
  1528. map.put("allMaterialSpecificationModel", subMaterialSpecificationModel);
  1529. }
  1530. Map<String,Object> orderMap = null;
  1531. int intValue = orderType.intValue();
  1532. if (intValue == 1 || intValue == 2 || intValue == 3) {
  1533. orderMap = omstruckOrderMapper.getSaleOrderMap(orderId);
  1534. }
  1535. if (intValue == 4) {
  1536. orderMap = omstruckOrderMapper.getSteelInwardOrderMap(orderId);
  1537. }
  1538. if (intValue == 5 || intValue == 6 || intValue == 7 || intValue == 8) {
  1539. orderMap = omstruckOrderMapper.getPurchaseOrderMap(orderId);
  1540. }
  1541. if (intValue == 9 || intValue == 10 || intValue == 11) {
  1542. orderMap = omstruckOrderMapper.getInwardOrderMap(orderId);
  1543. }
  1544. map.putAll(orderMap);
  1545. }
  1546. return resultList;
  1547. }
  1548. //新增内转异地库计划订单(新增运输订单)
  1549. @Override
  1550. public int apportionInwardOffsetOrder(Map<String, Object> mapValue) {
  1551. int result = 0;
  1552. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1553. String dayPlanId = (String) mapValue.get("dayPlanId");
  1554. Integer lineId = (Integer) mapValue.get("lineId");
  1555. String orderType = (String) mapValue.get("orderType");
  1556. // Integer carrierId = (Integer) mapValue.get("carrierId");
  1557. // AmstruckInwardPlan amstruckInwardPlan = amstruckInwardPlanMapper.selectByPrimaryKey(new BigDecimal(planId));
  1558. // amstruckInwardPlan.setPlanStatus(new BigDecimal(3));
  1559. // result += amstruckInwardPlanMapper.updateByPrimaryKeySelective(amstruckInwardPlan);
  1560. BigDecimal materialId = omstruckOrderMapper.getInwardMaterial(new BigDecimal(dayPlanId));
  1561. for (Map<String,Object> orderMap : mapList) {
  1562. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1563. String capacityNumber = (String)orderMap.get("capacityNumber");
  1564. BigDecimal materialNumber = DataChange.dataToBigDecimal(orderMap.get("materialNumber")) ;
  1565. // BigDecimal materialWeight = DataChange.dataToBigDecimal(orderMap.get("materialWeight"));
  1566. Map<String,Object> capacityMap = new HashMap<>();
  1567. capacityMap.put("capacityNumber",capacityNumber);
  1568. List<RmsCapacity> rmsCapacities = rmsCapacityMapper.selectByParameters(capacityMap);
  1569. RmsCapacity rmsCapacity = rmsCapacities.get(0);
  1570. rmsCapacity.setCapacityStatus(new BigDecimal(2));
  1571. result +=rmsCapacityMapper.updateByPrimaryKeySelective(rmsCapacity);
  1572. BigDecimal capacityId = rmsCapacity.getCapacityId();
  1573. capacityMap.clear();
  1574. capacityMap.put("capacityId",capacityId);
  1575. List<RmsDriverCapacity> rmsDriverCapacities = rmsDriverCapacityMapper.selectByParameters(capacityMap);
  1576. RmsDriverCapacity rmsDriverCapacity = rmsDriverCapacities.get(0);
  1577. BigDecimal dcId = rmsDriverCapacity.getDriverCapacityId();
  1578. if(dcId!=null){
  1579. BigDecimal orderId = omstruckOrderMapper.selectOrderId(dcId);
  1580. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1581. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  1582. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  1583. omstruckOrderMaterial.setOrderId(orderId);
  1584. omstruckOrderMaterial.setMaterialId(materialId);
  1585. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  1586. omstruckOrderMaterial.setInsertTime(new Date());
  1587. omstruckOrderMaterial.setUpdateTime(new Date());
  1588. omstruckOrderMaterial.setInsertUsername("admin");
  1589. omstruckOrderMaterial.setUpdateUsername("admin");
  1590. omstruckOrderMaterial.setInsertUpdateRemark("无");
  1591. }
  1592. // rmsDriverCapacity.setCarrierId(new BigDecimal(carrierId));
  1593. result +=rmsDriverCapacityMapper.updateByPrimaryKeySelective(rmsDriverCapacity);
  1594. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  1595. omstruckOrder.setOrderId(orderId);
  1596. omstruckOrder.setOrderPlanId(new BigDecimal(dayPlanId));
  1597. String orderNumber = DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue());
  1598. omstruckOrder.setOrderNumber(orderNumber);
  1599. omstruckOrder.setOrderIssueTime(new Date());
  1600. omstruckOrder.setOrderStatus(new BigDecimal(3));
  1601. omstruckOrder.setInsertTime(new Date());
  1602. omstruckOrder.setUpdateTime(new Date());
  1603. omstruckOrder.setInsertUsername("admin");
  1604. omstruckOrder.setUpdateUsername("admin");
  1605. omstruckOrder.setInsertUpdateRemark("无");
  1606. omstruckOrder.setDeleted(new BigDecimal(0));
  1607. omstruckOrder.setOrderType(new BigDecimal(orderType));
  1608. omstruckOrder.setLineId(new BigDecimal(lineId));
  1609. result +=omstruckOrderMapper.insertSelective(omstruckOrder);
  1610. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1611. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  1612. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  1613. omstruckOrderMaterial.setOrderId(orderId);
  1614. omstruckOrderMaterial.setMaterialId(materialId);
  1615. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  1616. omstruckOrderMaterial.setInsertTime(new Date());
  1617. omstruckOrderMaterial.setUpdateTime(new Date());
  1618. omstruckOrderMaterial.setInsertUsername("admin");
  1619. omstruckOrderMaterial.setUpdateUsername("admin");
  1620. omstruckOrderMaterial.setInsertUpdateRemark("无");
  1621. // omstruckOrderMaterial.setOrderMaterialWeight(materialWeight);
  1622. result +=omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1623. }
  1624. return result;
  1625. }
  1626. /**
  1627. * 查询运单下的所有信息
  1628. * @param capacityNumber
  1629. * @return
  1630. */
  1631. @Override
  1632. public List<Map<String, Object>> getAllOrderMessage(String capacityNumber) {
  1633. List<Map<String, Object>> resultList;
  1634. // 判断是走采购,销售还是内转
  1635. resultList = omstruckOrderMapper.getResultListByCapacity(capacityNumber);
  1636. // 如果不是内转则取下面的orderId和orderType
  1637. if (resultList == null || resultList.size() == 0) {
  1638. //通过车牌号匹配运力ID
  1639. BigDecimal capacityId = omstruckOrderMapper.getCapacityIdByCapacityNum(capacityNumber);
  1640. BigDecimal driverCapacityId = omstruckOrderMapper.getDriverCapacityId(capacityId);
  1641. resultList = omstruckOrderMapper.getResultList(driverCapacityId);
  1642. }
  1643. // 循环遍历出每一条运输订单的信息
  1644. for (Map<String, Object> map : resultList) {
  1645. BigDecimal orderId = (BigDecimal) map.get("orderId");
  1646. BigDecimal orderType = (BigDecimal) map.get("orderType");
  1647. // 查询物资信息
  1648. List<Map<String, Object>> materialMapList = omstruckOrderMapper.getMaterialMes(orderId);
  1649. String allMaterialName = "";
  1650. String allMaterialNumber = "";
  1651. String allMaterialWeight = "";
  1652. String allMaterialSpecificationModel = "";
  1653. // 对物资信息进行处理
  1654. if (materialMapList == null && materialMapList.size() == 0) {
  1655. } else {
  1656. for (Map<String, Object> materialMap : materialMapList) {
  1657. String materialName = (String) materialMap.get("materialName");
  1658. BigDecimal materialNumber = (BigDecimal) materialMap.get("materialNumber");
  1659. BigDecimal materialWeight = (BigDecimal) materialMap.get("materialWeight");
  1660. String materialModel = (String) materialMap.get("materialModel");
  1661. String materialSpecification = (String) materialMap.get("materialSpecification");
  1662. if (materialName != null) {
  1663. allMaterialName += materialName + "/";
  1664. }
  1665. if (materialNumber != null) {
  1666. allMaterialNumber += materialNumber.toString() + "/";
  1667. }
  1668. if (materialWeight != null) {
  1669. allMaterialWeight += materialWeight.toString() + "/";
  1670. }
  1671. if (materialSpecification != null || materialModel != null) {
  1672. allMaterialSpecificationModel += materialSpecification + materialModel + "/";
  1673. }
  1674. }
  1675. String subMaterialName = "";
  1676. String subMaterialNumber = "";
  1677. String subMaterialWeight = "";
  1678. String subMaterialSpecificationModel = "";
  1679. if (allMaterialName.length() >= 2) {
  1680. subMaterialName = allMaterialName.substring(0, allMaterialName.length() - 2);
  1681. }
  1682. if (allMaterialName.length() < 2) {
  1683. subMaterialName = allMaterialName;
  1684. }
  1685. if (allMaterialNumber.length() >= 2) {
  1686. subMaterialNumber = allMaterialNumber.substring(0, allMaterialNumber.length() - 1);
  1687. }
  1688. if (allMaterialNumber.length() < 2) {
  1689. subMaterialNumber = allMaterialNumber;
  1690. }
  1691. if (allMaterialWeight.length() >= 2) {
  1692. subMaterialWeight = allMaterialWeight.substring(0, allMaterialWeight.length() - 1);
  1693. }
  1694. if (allMaterialWeight.length() < 2) {
  1695. subMaterialWeight = allMaterialWeight;
  1696. }
  1697. if (allMaterialSpecificationModel.length() >= 2) {
  1698. subMaterialSpecificationModel = allMaterialSpecificationModel.substring(0, allMaterialSpecificationModel.length() - 2);
  1699. }
  1700. if (allMaterialSpecificationModel.length() < 2) {
  1701. subMaterialSpecificationModel = allMaterialSpecificationModel;
  1702. }
  1703. map.put("allMaterialName", subMaterialName);
  1704. map.put("allMaterialNumber", subMaterialNumber);
  1705. map.put("allMaterialWeight", subMaterialWeight);
  1706. map.put("allMaterialSpecificationModel", subMaterialSpecificationModel);
  1707. }
  1708. Map<String, Object> orderMap = null;
  1709. int intValue = orderType.intValue();
  1710. if (intValue == 1 || intValue == 2 || intValue == 3) {
  1711. orderMap = omstruckOrderMapper.getSaleMap(orderId);
  1712. }
  1713. if (intValue == 4) {
  1714. orderMap = omstruckOrderMapper.getSteelInwardMap(orderId);
  1715. }
  1716. if (intValue == 5 || intValue == 6 || intValue == 7 || intValue == 8) {
  1717. orderMap = omstruckOrderMapper.getPurchaseMap(orderId);
  1718. }
  1719. if (intValue == 9 || intValue == 10 || intValue == 11) {
  1720. orderMap = omstruckOrderMapper.getInwardMap(orderId);
  1721. }
  1722. map.putAll(orderMap);
  1723. }
  1724. return resultList;
  1725. }
  1726. /**
  1727. * 司机确认订单
  1728. * orderNumber 运输订单号
  1729. * @param map
  1730. * @return
  1731. */
  1732. @Override
  1733. public int driverConfirmation(Map<String, Object> map) {
  1734. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1735. BigDecimal orderId;
  1736. //通过运输订单号查询运输订单Id
  1737. if(map.get("orderId") == null){
  1738. orderId = new BigDecimal(omstruckOrderMapper.getOrderIdByOrderNumber((String) map.get("orderNumber")));
  1739. }else {
  1740. orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  1741. }
  1742. Map<String, Object> seqMap = omstruckOrderMapper.getMaxLineSeqByOrderId(orderId);
  1743. if(seqMap != null){
  1744. //如果没有到最后一步之前 不允许确认
  1745. BigDecimal orderLineSequence = DataChange.dataToBigDecimal(seqMap.get("orderLineSequence"));
  1746. BigDecimal maxSegmentSqe = DataChange.dataToBigDecimal(seqMap.get("segmentSqe"));
  1747. int i = maxSegmentSqe.intValue() - orderLineSequence.intValue();
  1748. if( i != 1){
  1749. return 0;
  1750. }
  1751. }
  1752. omstruckOrder.setOrderId(orderId);
  1753. //设置司机确认订单
  1754. omstruckOrder.setDriverConfirmation(new BigDecimal(1));
  1755. omstruckOrder.setUpdateTime(new Date());
  1756. return omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1757. }
  1758. /**
  1759. * 查询订单是否确认
  1760. * @Author TXF
  1761. * @Date 2022/1/4 23:36
  1762. * @param map {orderId}
  1763. * @return
  1764. **/
  1765. public boolean getDriverConfirmation(Map<String, Object> map){
  1766. Integer driverConfirmation = omstruckOrderMapper.getDriverConfirmation(DataChange.dataToBigDecimal(map.get("orderId")));
  1767. if(driverConfirmation == null){
  1768. return true;
  1769. }else {
  1770. return false;
  1771. }
  1772. }
  1773. /**
  1774. * 通过运输订单号查询订单信息给司机
  1775. * @param map
  1776. * @return
  1777. */
  1778. public Map<String, Object> getMessageToApp(Map<String, Object> map){
  1779. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  1780. Integer orderType;
  1781. //获取订单类型
  1782. if(map.get("orderType") == null){
  1783. orderType = omstruckOrderMapper.getOrderTypeByOrderNumber(orderId);
  1784. }else {
  1785. orderType = DataChange.dataToBigDecimal(map.get("orderType")).intValue();
  1786. }
  1787. Map<String, Object> mesMap = new HashMap<>();
  1788. switch (orderType){
  1789. case 1:
  1790. case 2:
  1791. mesMap = omstruckOrderMapper.getXSOrderMessageToApp(map);
  1792. break;
  1793. case 3:
  1794. case 4:
  1795. mesMap = omstruckOrderMapper.getFYJHOrderMessageToApp(map);
  1796. break;
  1797. case 5:
  1798. case 6:
  1799. case 7:
  1800. case 8:
  1801. case 17:
  1802. case 18:
  1803. mesMap = omstruckOrderMapper.getCGOrderMessageToApp(map);
  1804. break;
  1805. case 9:
  1806. case 10:
  1807. case 20:
  1808. mesMap = omstruckOrderMapper.getNZOrderMessageToApp(map);
  1809. mesMap.put("loadName","化工园区铁专线");
  1810. BigDecimal organizationId =(BigDecimal) mesMap.get("organizationId");
  1811. if (organizationId.intValue()==1){
  1812. mesMap.put("organizationCode","一厂");
  1813. }else if (organizationId.intValue()==2){
  1814. mesMap.put("organizationCode","二厂");
  1815. }
  1816. break;
  1817. case 11:
  1818. mesMap = omstruckOrderMapper.getInwardOrderMessageToApp(map);
  1819. break;
  1820. case 12:
  1821. case 13:
  1822. case 15:
  1823. case 16:
  1824. mesMap = omstruckOrderMapper.getSporadicOrder(map);
  1825. break;
  1826. case 19:
  1827. mesMap=omstruckOrderMapper.getSporadicOrder(map);
  1828. mesMap.put("type", "零星退货");
  1829. }
  1830. mesMap.put("materialMesList", omstruckOrderMapper.getMaterialMes(orderId));
  1831. return mesMap;
  1832. }
  1833. /**
  1834. * 通过车牌号查询所有已下发未接收的订单信息
  1835. * @param map
  1836. * @return
  1837. */
  1838. public List<Map<String, Object>> getAllOrderMessagesByCapacityNum(Map<String, Object> map){
  1839. String capacityNumber = (String) map.get("capacityNumber");
  1840. //通过车牌号查询所有未下发的订单ID
  1841. List<Map<String, Object>> orderMesList = omstruckOrderMapper.getOrderIdListByCapacityNumber(capacityNumber);
  1842. List<Map<String, Object>> mesMapList = new ArrayList<>();
  1843. for (Map<String, Object> orderMesMap: orderMesList) {
  1844. int orderType = DataChange.dataToBigDecimal(orderMesMap.get("orderType")).intValue();
  1845. //如果订单类型为2 则判断订单发货日期是否为当日 如果不是当日则不给显示
  1846. if(orderType == 2){
  1847. Integer judgeDate = omstruckOrderSeparateMapper.getDeliveryDate(orderMesMap.get("orderId"));
  1848. if(judgeDate == null){ // 数据为空则不是当天的订单
  1849. continue;
  1850. }
  1851. }
  1852. if(orderType == 10|| orderType == 20){
  1853. Integer planEnable = omstruckOrderSeparateMapper.getOrderPlanEnable(orderMesMap.get("orderId"));
  1854. if(planEnable == 0){ // 数据为0则失效
  1855. continue;
  1856. }
  1857. }
  1858. //如果订单类型为11 当订单大于截止日期时,不显示订单
  1859. if(orderType == 11){
  1860. int result = omstruckOrderSeparateMapper.getInward(orderMesMap.get("orderId"));
  1861. if(result == 0){
  1862. continue;
  1863. }
  1864. }
  1865. Map<String, Object> mesMap = getMessageToApp(orderMesMap);
  1866. mesMapList.add(mesMap);
  1867. }
  1868. return mesMapList;
  1869. }
  1870. /**
  1871. * 新增进口矿
  1872. * @param mapValue
  1873. * @return
  1874. */
  1875. @Transactional
  1876. @Override
  1877. public int addInputOrder(Map<String, Object> mapValue) {
  1878. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1879. BigDecimal purchaseOrderId = new BigDecimal((Integer) mapValue.get("purchaseOrderId"));
  1880. BigDecimal materialId = new BigDecimal((Integer) mapValue.get("materialId"));
  1881. BigDecimal orderType = new BigDecimal((Integer) mapValue.get("orderType"));
  1882. BigDecimal lineId = new BigDecimal((Integer) mapValue.get("lineId"));
  1883. Integer planId = (Integer) mapValue.get("planId");
  1884. int result = 0;
  1885. for (Map<String, Object> map : mapList) {
  1886. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1887. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1888. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  1889. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  1890. String capacityNumber = (String)map.get("capacityNumber");
  1891. BigDecimal capacityId = omstruckOrderMapper.getCapacityId(capacityNumber);
  1892. BigDecimal materialWeight = DataChange.dataToBigDecimal(map.get("orderMaterialWeight"));
  1893. String unloadPoint = (String) map.get("unloadPoint");
  1894. BigDecimal unloadPointId = omstruckOrderMapper.getUnloadPointId(unloadPoint);
  1895. // Date orderEntryTime = new Date((Long) map.get("orderEntryTime"));
  1896. // 运输订单
  1897. omstruckOrder.setOrderId(orderId);
  1898. omstruckOrder.setOrderNumber(DataChange.generateEightDigitsNumber("WYSDD",orderId.intValue()));
  1899. omstruckOrder.setCapacityId(capacityId);
  1900. omstruckOrder.setOrderPlanId(purchaseOrderId);
  1901. omstruckOrder.setOrderType(orderType);
  1902. omstruckOrder.setOrderStatus(new BigDecimal(3));
  1903. omstruckOrder.setLineId(lineId);
  1904. omstruckOrder.setUnloadPointId(unloadPointId);
  1905. // omstruckOrder.setOrderEntryTime(orderEntryTime);
  1906. omstruckOrder.setInsertTime(new Date());
  1907. omstruckOrder.setInsertUsername("admin");
  1908. // 运输订单子表
  1909. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  1910. omstruckOrderMaterial.setOrderId(orderId);
  1911. omstruckOrderMaterial.setOrderMaterialWeight(materialWeight);
  1912. omstruckOrderMaterial.setMaterialId(materialId);
  1913. omstruckOrderMaterial.setInsertTime(new Date());
  1914. omstruckOrderMaterial.setInsertUsername("admin");
  1915. result += omstruckOrderMapper.insertSelective(omstruckOrder);
  1916. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1917. //新增实绩总表关联订单 feign 调用truckTms
  1918. map.put("orderId", omstruckOrder.getOrderId());
  1919. tmsTruckFeign.addTotalResult(map);
  1920. //更改运输计划子表 增加已分配重量 减少未分配重量 feign调用ams
  1921. map.put("planId",planId);
  1922. amsFeign.updateMaterial(map);
  1923. }
  1924. return result;
  1925. }
  1926. }