AmsSaleOrderServiceImpl.java 102 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123
  1. package com.steerinfo.dil.service.impl;
  2. import com.alibaba.druid.support.json.JSONUtils;
  3. import com.alibaba.fastjson.JSON;
  4. import com.alibaba.fastjson.JSONObject;
  5. import com.steerinfo.dil.feign.JoinFeign;
  6. import com.steerinfo.dil.feign.OtmsFeign;
  7. import com.steerinfo.dil.feign.TmsTruckFeign;
  8. import com.steerinfo.dil.mapper.*;
  9. import com.steerinfo.dil.model.*;
  10. import com.steerinfo.dil.service.IAmsSaleOrderService;
  11. import com.steerinfo.dil.util.*;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import org.springframework.transaction.annotation.Transactional;
  15. import javax.annotation.Resource;
  16. import java.math.BigDecimal;
  17. import java.text.ParseException;
  18. import java.text.SimpleDateFormat;
  19. import java.util.*;
  20. /**
  21. * AmsSaleOrder服务实现:
  22. *
  23. * @author generator
  24. * @version 1.0-SNAPSHORT 2021-09-06 07:10
  25. * 类描述
  26. * 修订历史:
  27. * 日期:2021-09-06
  28. * 作者:generator
  29. * 参考:
  30. * 描述:AmsSaleOrder服务实现
  31. * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
  32. * @see null
  33. */
  34. @Service(value = "amsSaleOrderService")
  35. public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
  36. @Autowired
  37. private AmsSaleOrderMapper amsSaleOrderMapper;
  38. @Autowired
  39. private AmsSaleOrderMaterialMapper amsSaleOrderMaterialMapper;
  40. @Autowired
  41. private AmsSaleTrucknoMaterialMapper trucknoMaterialMapper;
  42. @Autowired
  43. TmstruckLoadResult tmstruckLoadResult;
  44. @Autowired
  45. TmstruckWeightResult tmstruckWeightResult;
  46. @Autowired
  47. TmstruckWeightResultMapper tmstruckWeightResultMapper;
  48. @Autowired
  49. TmstruckLoadResultMapper tmstruckLoadResultMapper;
  50. @Autowired
  51. AmsDispatchSaleOrderMapper amsDispatchSaleOrderMapper;
  52. @Autowired
  53. AmsSaleMaterialMapper amsSaleMaterialMapper;
  54. @Autowired
  55. AmsSaleTrucknoMaterialMapper amsSaleTrucknoMaterialMapper;
  56. @Autowired
  57. RmsReceivePlaceMapper rmsReceivePlaceMapper;
  58. @Autowired
  59. JoinFeign joinFeign;
  60. @Autowired
  61. OmstruckOrderMapper omstruckOrderMapper;
  62. @Autowired
  63. OmstruckOrderMaterialMapper omstruckOrderMaterialMapper;
  64. @Autowired
  65. AmsSaleOrderMaterialServiceImpl amsSaleOrderMaterialService;
  66. @Autowired
  67. TmsTruckFeign tmsTruckFeign;
  68. @Autowired
  69. EASUtil easUtil;
  70. @Autowired
  71. EASDeleteUtil easDeleteUtil;
  72. @Autowired
  73. EASSaleOrderUtil easSaleOrderUtil;
  74. @Autowired
  75. EASTestUtil easTestUtil;
  76. @Autowired
  77. EASDeleteTestUtil easDeleteTestUtil;
  78. @Autowired
  79. EASDeleteApproveUtil easDeleteApproveUtil;
  80. @Autowired
  81. RmsMaterialMapper rmsMaterialMapper;
  82. @Autowired
  83. TmstrainPleaseApproveResultMapper tmstrainPleaseApproveResultMapper;
  84. @Autowired
  85. WmspOutboundResultMaterialMapper wmspOutboundResultMaterialMapper;
  86. @Resource
  87. EasSaleOrderStatusUtil easSaleOrderStatusUtil;
  88. @Autowired
  89. OtmsFeign otmsFeign;
  90. @Override
  91. public List<Map<String, Object>> getSaleOrderInfo(Map<String, Object> map) {
  92. return amsSaleOrderMapper.getSaleOrderInfo(map);
  93. }
  94. @Override
  95. public List<Map<String, Object>> getSaleOrderReported(Map<String, Object> map) {
  96. return amsSaleOrderMapper.getSaleOrderReported(map);
  97. }
  98. @Override
  99. public List<Map<String, Object>> getSaleOrderDetail(Map<String, Object> map) {
  100. return amsSaleOrderMapper.getSaleOrderDetail(map);
  101. }
  102. @Override
  103. public List<Map<String, Object>> getSalePlanName() {
  104. return amsSaleOrderMapper.getSalePlanName();
  105. }
  106. @Override
  107. public List<Map<String, Object>> getShipperName() {
  108. return amsSaleOrderMapper.getShipperName();
  109. }
  110. @Override
  111. public List<Map<String, Object>> getConsigneeCompanyName() {
  112. return amsSaleOrderMapper.getConsigneeCompanyName();
  113. }
  114. @Override
  115. /**
  116. * map存放为前端获取的amsSaleOrder基础数据以及selectionList物资信息
  117. * map1为基础数据包括,收货地址,收货人等
  118. * map2存放的从selectionList取出的数据,包括物资id,物资名称等。
  119. */
  120. public int addAmsSaleOrder(Map<String, Object> map) throws ParseException {
  121. //获取前端传过来的map,
  122. int i = 0;
  123. Map<String, Object> map1 = (Map<String, Object>) map.get("amsSaleOrder");
  124. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  125. Integer id = (amsSaleOrderMapper.selectMaxId()).intValue();
  126. //生成主键id
  127. amsSaleOrder.setSaleOrderId(new BigDecimal(id));
  128. //WXSDD-年月日-8位数的顺序号
  129. String wxsdd = DataChange.generateEightDigitsNumber("WXSDD", id);
  130. amsSaleOrder.setSaleNumber(wxsdd);
  131. //获得是否自提
  132. amsSaleOrder.setSaleOrderIsselfMention((String) map1.get("saleOrderIsselfMention"));
  133. //获取收货地址id
  134. amsSaleOrder.setReceiveId(DataChange.dataToBigDecimal(map1.get("receiveId")));
  135. //获取发货单位id
  136. amsSaleOrder.setShipperId(DataChange.dataToBigDecimal(map1.get("shipperId")));
  137. //获取备注
  138. amsSaleOrder.setSaleRemark((String) map1.get("saleRemark"));
  139. //设置销售订单状态
  140. amsSaleOrder.setSaleOrderStatus(new BigDecimal(0));
  141. amsSaleOrder.setSaleUnitPrice(new BigDecimal(4000));
  142. amsSaleOrder.setSaleOrderTax("13%");
  143. amsSaleOrder.setInsertUsername("admin");
  144. amsSaleOrder.setInsertTime(new Date());
  145. amsSaleOrder.setUpdateUsername("admin");
  146. amsSaleOrder.setUpdateTime(new Date());
  147. amsSaleOrder.setInsertUpdateRemark("无");
  148. amsSaleOrder.setDeleted(new BigDecimal(0));
  149. amsSaleOrder.setSaleOrderStatus(new BigDecimal(0));
  150. //设置收款客户
  151. amsSaleOrder.setSaleOrderReceiveCustomer((String) map1.get("saleOrderReceiveCustomer"));
  152. i += amsSaleOrderMapper.insertSelective(amsSaleOrder);
  153. //获取车序号和物资信息进行新增车序号与物资中间表
  154. //一个销售订单对应多个车序号
  155. List<Map<String, Object>> selectionList = (List<Map<String, Object>>) map.get("selectionList");
  156. for (Map<String, Object> map2 : selectionList) {
  157. BigDecimal materialId = DataChange.dataToBigDecimal(map2.get("materialId"));
  158. Integer cxh = (Integer) map2.get("cxh");
  159. //生成车序号与物资实体
  160. AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  161. //生成主键
  162. amsSaleOrderMaterial.setSaleOrderMaterialId(amsSaleOrderMaterialMapper.selectMaxId());
  163. amsSaleOrderMaterial.setSaleOrderId(amsSaleOrder.getSaleOrderId());
  164. // 生成定向派单
  165. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  166. amsDispatchSaleOrder.setDispatchId(amsDispatchSaleOrderMapper.selectOtherId());
  167. amsDispatchSaleOrder.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  168. //获取收货地址
  169. Integer saleShipperAddressId =(Integer) map2.get("saleShipperAddressId");
  170. amsSaleOrderMaterial.setSaleShippingAddressId(new BigDecimal(saleShipperAddressId));
  171. //根据收货地址查询承运商
  172. Map<String,Object> map4 = amsSaleOrderMapper.selectProvince(saleShipperAddressId);
  173. BigDecimal carrierId = amsSaleOrderMapper.selectCarrierIdByprovince(map4);
  174. //获取收货方电话号码
  175. amsDispatchSaleOrder.setCarrierId(carrierId);
  176. amsDispatchSaleOrder.setDispatchTime(new Date());
  177. //设置成交类型
  178. amsDispatchSaleOrder.setDispatchType(new BigDecimal(0));
  179. //设置下发状态为未下发
  180. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(1));
  181. amsDispatchSaleOrder.setInsertTime(new Date());
  182. amsDispatchSaleOrder.setInsertUsername("admin");
  183. amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
  184. amsSaleOrderMaterial.setSaleOrderConsigneeTel(map2.get("saleOrderConsigneeTel").toString());
  185. //获取收货日期
  186. String saleDateOfReceipt =(String) map2.get("saleDateOfReceipt");
  187. SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd");
  188. Date date = simpleDateFormat.parse(saleDateOfReceipt);
  189. amsSaleOrderMaterial.setSaleDateOfReceipt(date);
  190. //获取收货方姓名
  191. amsSaleOrderMaterial.setSaleOrderConsignee((String) map2.get("saleOrderConsignee"));
  192. //设置车序号
  193. amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(new BigDecimal(cxh));
  194. //设置删除状态
  195. amsSaleOrderMaterial.setDeleted(new BigDecimal(0));
  196. i += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
  197. //新增车序号与物资中间表
  198. AmsSaleTrucknoMaterial trucknoMaterial = new AmsSaleTrucknoMaterial();
  199. trucknoMaterial.setTrucknoMaterialId(trucknoMaterialMapper.selectMaxId());
  200. //设置物资id
  201. trucknoMaterial.setMaterialId(materialId);
  202. //获取车序号物资id
  203. trucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  204. Integer orderPlanWeight = (Integer) map2.get("orderPlanWeight");
  205. trucknoMaterial.setSaleOrderMaterialNumber(DataChange.dataToBigDecimal(orderPlanWeight));
  206. //获取物资理重
  207. BigDecimal materialTheoreticalWeight = DataChange.dataToBigDecimal(map2.get("materialTheoreticalWeight"));
  208. //判断是否有物资理重
  209. if (materialTheoreticalWeight.intValue() != 0) {
  210. trucknoMaterial.setMaterialTheoreticalWeight(materialTheoreticalWeight);
  211. }
  212. //新增车序号与物资中间表
  213. i += trucknoMaterialMapper.insertSelective(trucknoMaterial);
  214. }
  215. return i;
  216. }
  217. @Transactional(rollbackFor = Exception.class)
  218. @Override
  219. public int uploadSaleOrder(BigDecimal saleOrderId) throws Exception {
  220. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  221. // 调用金蝶接口,将销售订单推送到金蝶系统
  222. Map<String, Object> input = joinFeign.getSaleOrder(saleOrderId);
  223. Map<String, Object> head = (Map<String, Object>) input.get("head");
  224. head.put("status","");
  225. // 获得金蝶接口配置:正式
  226. Map<String, Object> totalMap = easUtil.getTotalMap();
  227. // 获得金蝶接口配置:测试
  228. //Map<String, Object> totalMap = easSaleOrderUtil.getTotalMap();
  229. // 组装报文
  230. totalMap.put("input",input);
  231. System.out.println(totalMap);
  232. String json = JSONUtils.toJSONString(totalMap);
  233. System.out.println(json);
  234. // 得到金蝶返回结果
  235. Map<String,Object> s = joinFeign.pushSaleOrderToEas(totalMap);
  236. String status = (String) s.get("status");
  237. if ("-1".equals(status)) {
  238. throw new Exception(amsSaleOrder.getSaleNumber() + "上传金蝶失败!");
  239. }
  240. System.out.println(s);
  241. amsSaleOrder.setSaleOrderStatus(new BigDecimal(1));
  242. return amsSaleOrderMapper.updateByPrimaryKey(amsSaleOrder);
  243. }
  244. @Override
  245. public List<Map<String, Object>> selectBySaleOrderId(BigDecimal saleOrderId) {
  246. return amsSaleOrderMapper.selectBySaleOrderId(saleOrderId);
  247. }
  248. /**
  249. * 修改订单信息、车序号表、车序号物资中间表
  250. *
  251. * @param map
  252. * @return
  253. */
  254. @Override
  255. @Transactional
  256. public int updateAmsSaleOrder(Map<String, Object> map) throws ParseException {
  257. int i = 0;
  258. int j = 0;
  259. Map<String, Object> map1 = (Map<String, Object>) map.get("amsSaleOrder");
  260. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  261. //修改销售订单表 更新销售订单基础信息
  262. amsSaleOrder.setSaleOrderId(DataChange.dataToBigDecimal(map1.get("saleOrderId")));
  263. amsSaleOrder.setShipperId(DataChange.dataToBigDecimal(map1.get("shipperId")));
  264. amsSaleOrder.setReceiveId(DataChange.dataToBigDecimal(map1.get("reciveId")));
  265. amsSaleOrder.setSaleOrderIsselfMention((String) map1.get("saleOrderIsselfMention"));
  266. amsSaleOrder.setSaleOrderReceiveCustomer((String) map1.get("saleOrderReciveCustomer"));
  267. amsSaleOrder.setSaleRemark((String) map1.get("saleRemark"));
  268. amsSaleOrder.setUpdateTime(new Date());
  269. i += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  270. //根据销售订单id查找销售车序号和车序号与物资中间表主键
  271. List<Map<String, Object>> map2 = amsSaleOrderMapper.selectSaleOrderMaterialIdBySaleOrderId(DataChange.dataToBigDecimal(map1.get("saleOrderId")));
  272. for (Map<String,Object> Id:map2){
  273. BigDecimal truckNoMaterialId =(BigDecimal) Id.get("TruckNoMaterialId");
  274. BigDecimal saleOrderMaterialId=(BigDecimal) Id.get("saleOrderMaterialId");
  275. //删除对应的车序号表与车序号与物资中间表
  276. j+=amsSaleOrderMaterialMapper.deleteByPrimaryKey(saleOrderMaterialId);
  277. j+=trucknoMaterialMapper.deleteByPrimaryKey(truckNoMaterialId);
  278. }
  279. //新增车序号和物资中间表
  280. //获取车序号和物资信息进行新增车序号与物资中间表
  281. //一个销售订单对应多个车序号
  282. List<Map<String, Object>> selectionList = (List<Map<String, Object>>) map.get("selectionList");
  283. for (Map<String, Object> map3 : selectionList) {
  284. BigDecimal materialId = DataChange.dataToBigDecimal(map3.get("materialId"));
  285. Integer cxh = (Integer) map3.get("cxh");
  286. //生成车序号与物资实体
  287. AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  288. //生成主键
  289. amsSaleOrderMaterial.setSaleOrderMaterialId(amsSaleOrderMaterialMapper.selectMaxId());
  290. amsSaleOrderMaterial.setSaleOrderId(DataChange.dataToBigDecimal(map1.get("saleOrderId")));
  291. //获取收货地址
  292. amsSaleOrderMaterial.setSaleShippingAddressId(DataChange.dataToBigDecimal(map3.get("saleShipperAddressId")));
  293. //获取收货方电话号码
  294. amsSaleOrderMaterial.setSaleOrderConsigneeTel(map3.get("saleOrderConsigneeTel").toString());
  295. //获取收货日期
  296. String saleDateOfReceipt =(String) map3.get("saleDateOfReceipt");
  297. SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd");
  298. Date date = simpleDateFormat.parse(saleDateOfReceipt);
  299. amsSaleOrderMaterial.setSaleDateOfReceipt(date);
  300. //获取收货方姓名
  301. amsSaleOrderMaterial.setSaleOrderConsignee((String) map3.get("saleOrderConsignee"));
  302. //设置车序号
  303. amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(new BigDecimal(cxh));
  304. //设置删除状态
  305. amsSaleOrderMaterial.setDeleted(new BigDecimal(0));
  306. i += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
  307. // 生成定向派单
  308. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  309. amsDispatchSaleOrder.setDispatchId(amsDispatchSaleOrderMapper.selectOtherId());
  310. amsDispatchSaleOrder.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  311. //获取收货地址
  312. Integer saleShipperAddressId =(Integer) map3.get("saleShipperAddressId");
  313. amsSaleOrderMaterial.setSaleShippingAddressId(new BigDecimal(saleShipperAddressId));
  314. //根据收货地址查询承运商
  315. Map<String,Object> map4 = amsSaleOrderMapper.selectProvince(saleShipperAddressId);
  316. BigDecimal carrierId = amsSaleOrderMapper.selectCarrierIdByprovince(map4);
  317. //获取收货方电话号码
  318. amsDispatchSaleOrder.setCarrierId(carrierId);
  319. amsDispatchSaleOrder.setDispatchTime(new Date());
  320. //设置成交类型
  321. amsDispatchSaleOrder.setDispatchType(new BigDecimal(0));
  322. //设置下发状态为已下发
  323. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(0));
  324. amsDispatchSaleOrder.setInsertTime(new Date());
  325. amsDispatchSaleOrder.setInsertUsername("admin");
  326. //新增车序号与物资中间表
  327. AmsSaleTrucknoMaterial trucknoMaterial = new AmsSaleTrucknoMaterial();
  328. trucknoMaterial.setTrucknoMaterialId(trucknoMaterialMapper.selectMaxId());
  329. //设置物资id
  330. trucknoMaterial.setMaterialId(materialId);
  331. //获取车序号物资id
  332. trucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  333. Integer orderPlanWeight = (Integer) map3.get("orderPlanWeight");
  334. trucknoMaterial.setSaleOrderMaterialNumber(DataChange.dataToBigDecimal(orderPlanWeight));
  335. //获取物资理重
  336. BigDecimal materialTheoreticalWeight = DataChange.dataToBigDecimal(map3.get("materialTheoreticalWeight"));
  337. //判断是否有物资理重
  338. if (materialTheoreticalWeight.intValue() != 0) {
  339. trucknoMaterial.setMaterialTheoreticalWeight(materialTheoreticalWeight);
  340. }
  341. //新增车序号与物资中间表
  342. i += trucknoMaterialMapper.insertSelective(trucknoMaterial);
  343. }
  344. // List<Map<String, Object>> mapList = (List<Map<String, Object>>) map.get("mapList");
  345. // ArrayList<Integer> list = new ArrayList<>();
  346. // for (Map<String, Object> truckMesMap : mapList) {
  347. // //修改车序号表
  348. // BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(truckMesMap.get("saleOrderMaterialId"));
  349. // if (!list.contains(saleOrderMaterialId.intValue())) {
  350. // //车序号表专用字段
  351. // BigDecimal saleShipperAddressId = DataChange.dataToBigDecimal(truckMesMap.get("saleShipperAddressId"));
  352. // String saleDateOfReceipt =(String) truckMesMap.get("saleDateOfReceipt");
  353. // SimpleDateFormat simpleDateFormat=new SimpleDateFormat("yyyy-MM-dd");
  354. // Date date = simpleDateFormat.parse(saleDateOfReceipt);
  355. // String saleOrderConsignee = (String) truckMesMap.get("saleOrderConsignee");
  356. // String saleOrderConsigneeTel = (String) truckMesMap.get("saleOrderConsigneeTel");
  357. // AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  358. // amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  359. // amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(DataChange.dataToBigDecimal(truckMesMap.get("cxh")));
  360. // amsSaleOrderMaterial.setSaleShippingAddressId(saleShipperAddressId);
  361. // amsSaleOrderMaterial.setSaleDateOfReceipt(date);
  362. // amsSaleOrderMaterial.setSaleOrderConsignee(saleOrderConsignee);
  363. // amsSaleOrderMaterial.setSaleOrderConsigneeTel(saleOrderConsigneeTel);
  364. // i += amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial);
  365. // list.add(saleOrderMaterialId.intValue());
  366. // }
  367. // //修改车车序号物资表
  368. // AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  369. // amsSaleTrucknoMaterial.setTrucknoMaterialId(DataChange.dataToBigDecimal(truckMesMap.get("trucknoMaterialId")));
  370. // amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(DataChange.dataToBigDecimal(truckMesMap.get("orderPlanWeight")));
  371. // amsSaleTrucknoMaterial.setMaterialId(DataChange.dataToBigDecimal(truckMesMap.get("materialId")));
  372. // i += trucknoMaterialMapper.updateByPrimaryKeySelective(amsSaleTrucknoMaterial);
  373. // }
  374. return i;
  375. }
  376. @Override
  377. public int deleteAmsSaleOrderBySaleOrderId(BigDecimal saleOrderId) {
  378. //删除所有从表信息
  379. //amsSaleOrderMapper.deleteBySaleOrderId(saleOrderId);
  380. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  381. amsSaleOrder.setDeleted(new BigDecimal(2));
  382. return amsSaleOrderMapper.updateByPrimaryKey(amsSaleOrder);
  383. }
  384. @Override
  385. public List<Map<String, Object>> getSaleOrderUpdateLog(Map<String, Object> map) {
  386. return amsSaleOrderMapper.getSaleOrderUpdateLog(map);
  387. }
  388. /**
  389. * 销售公司查询已审核的订单
  390. * @param map
  391. * @return
  392. */
  393. @Override
  394. public List<Map<String, Object>> getSaleOrderListBySaleCompany(Map<String, Object> map) {
  395. return amsSaleOrderMapper.getSaleOrderListBySaleCompany(map);
  396. }
  397. @Override
  398. public List<Map<String, Object>> getAmsSaleOrderApproved(Map<String, Object> map) {
  399. return amsSaleOrderMapper.getAmsSaleOrderApproved(map);
  400. }
  401. @Override
  402. public List<Map<String, Object>> getSaleOrderList(Map<String, Object> mapValue) {
  403. return amsSaleOrderMapper.getSaleOrderList(mapValue);
  404. }
  405. public Map<String, Object> getCarrier(Integer addressId) {
  406. return amsSaleOrderMapper.selectProvince(addressId);
  407. }
  408. /**
  409. * 根据销售订单id查找信息
  410. */
  411. @Override
  412. public Map<String, Object> selectInfoBySaleOrderId(BigDecimal saleOrderId) {
  413. return amsSaleOrderMapper.selectInfoBySaleOrderId(saleOrderId);
  414. }
  415. /**
  416. * 根据销售订单id查找物资信息
  417. *
  418. * @param saleOrderId
  419. * @return
  420. */
  421. @Override
  422. public List<Map<String, Object>> selectMaterialInfoBySaleOrderId(BigDecimal saleOrderId) {
  423. return amsSaleOrderMapper.selectMaterialInfoBySaleOrderId(saleOrderId);
  424. }
  425. @Override
  426. public int addAmsDispatchSaleOrder(List<Map<String, Object>> mapValue) {
  427. int result = 0;
  428. for (Map<String,Object> map : mapValue) {
  429. Integer dispatchId = (Integer)map.get("dispatchId");
  430. AmsDispatchSaleOrder amsDispatchSaleOrder = amsDispatchSaleOrderMapper.selectByPrimaryKey(new BigDecimal(dispatchId));
  431. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(0));
  432. result = amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(amsDispatchSaleOrder);
  433. }
  434. return result;
  435. }
  436. @Override
  437. public List<Map<String, Object>> getSaleOrderInfoes(Map<String, Object> map) {
  438. return amsSaleOrderMapper.getSaleOrderInfoes(map);
  439. }
  440. @Override
  441. public List<Map<String, Object>> getSaleOrderReportedes(Map<String, Object> map) {
  442. return amsSaleOrderMapper.getSaleOrderReportedes(map);
  443. }
  444. @Override
  445. public List<Map<String, Object>> getSaleOrderListBySaleCompanyes(Map<String, Object> map) {
  446. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleOrderListBySaleCompanyes(map);
  447. return resultList;
  448. }
  449. @Override
  450. public List<Map<String, Object>> getAmsSaleOrderApprovedes(Map<String, Object> map) {
  451. List<Map<String,Object>> resultList = amsSaleOrderMapper.getAmsSaleOrderApprovedes(map);
  452. return resultList;
  453. }
  454. /*
  455. * 根据销售订单主键展示销售基本信息、物资信息
  456. * */
  457. @Override
  458. public List<Map<String, Object>> getSaleOrderAndMaterialById(Map<String,Object> mapValue) {
  459. List<Map<String, Object>> mapList=amsSaleOrderMapper.getSaleOrderAndMaterialById(mapValue);
  460. for (Map<String, Object> map : mapList) {
  461. BigDecimal number;
  462. BigDecimal materialNumber = (BigDecimal) map.get("materialNumber");
  463. BigDecimal materialWeight = (BigDecimal) map.get("materialWeight");
  464. String materialName =(String) map.get("materialName");
  465. if (materialNumber != null && materialNumber.toString().length() != 0 && !materialName.equals("钒渣")) {
  466. number = materialNumber;
  467. }
  468. else {
  469. number = materialWeight;
  470. }
  471. map.put("number",number);
  472. }
  473. return mapList;
  474. }
  475. /**
  476. * 销售焦炭订单
  477. * @param mapValue
  478. * @return
  479. */
  480. @Override
  481. public List<Map<String, Object>> getCokeSaleOrderList(Map<String, Object> mapValue) {
  482. List<Map<String,Object>> mapList = amsSaleOrderMapper.getCokeSaleOrderList(mapValue);
  483. for (Map<String, Object> resultMap : mapList) {
  484. BigDecimal saleOrderId = (BigDecimal) resultMap.get("saleOrderId");
  485. BigDecimal netWeight = amsSaleOrderMapper.getNetWeight(saleOrderId);
  486. BigDecimal carNum = amsSaleOrderMapper.getCarNum(saleOrderId);
  487. resultMap.put("netWeight",netWeight);
  488. resultMap.put("carNum",carNum);
  489. }
  490. return mapList;
  491. }
  492. /**
  493. * 新增钢材销售订单
  494. * @param mapValue
  495. * @return
  496. */
  497. @Override
  498. @Transactional(rollbackFor = Exception.class)
  499. public int addSteelSaleOrder(Map<String, Object> mapValue) throws Exception {
  500. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  501. // 得到发货单位
  502. BigDecimal shipperId = DataChange.dataToBigDecimal(mapValue.get("shipperId"));
  503. // 收货单位
  504. BigDecimal receiveId = DataChange.dataToBigDecimal(mapValue.get("receiveId"));
  505. if (receiveId == null || receiveId.intValue() == 0) {
  506. receiveId = amsSaleOrderMapper.findReceiveId(mapValue.get("receiveName"));
  507. if (receiveId == null) {
  508. throw new Exception("您输入的下单客户:" + mapValue.get("receiveName") + "不存在!!");
  509. }else {
  510. //判断该收货客户有没有绑定片区
  511. BigDecimal saleAreaId = amsSaleOrderMapper.selectSaleAreaId(receiveId);
  512. if(saleAreaId == null){
  513. //如果片区为null,则绑定片区
  514. //根据片区名称去查找片区ID
  515. if(mapValue.get("saleArea") != null){
  516. String saleAreaName = (String) mapValue.get("saleArea");
  517. saleAreaId = amsSaleOrderMapper.selectSaleAreaIdByName(saleAreaName);
  518. if(saleAreaId == null){
  519. throw new Exception("您输入的销售片区:" + mapValue.get("saleArea") +"不存在!!");
  520. }else{
  521. //更新收货客户下的销售片区
  522. amsSaleOrderMapper.bindSaleArea(receiveId,saleAreaId);
  523. }
  524. }
  525. }
  526. }
  527. }
  528. // 是否自提
  529. String isSelfMention = (String) mapValue.get("isSelfMention");
  530. // 备注
  531. String saleRemark = (String) mapValue.get("saleRemark");
  532. // 收款客户
  533. String saleOrderReceiveCustomer = (String) mapValue.get("saleOrderReceiveCustomer");
  534. // 业务员
  535. BigDecimal salerId = DataChange.dataToBigDecimal(mapValue.get("salerId"));
  536. if (salerId == null || salerId.intValue() == 0) {
  537. salerId = amsSaleOrderMapper.findSalerId(mapValue.get("salerName"));
  538. if (salerId == null) {
  539. throw new Exception("您输入的业务员:" + mapValue.get("salerName") +"不存在!!");
  540. }
  541. }
  542. BigDecimal saleOrderId = amsSaleOrderMapper.selectMaxId();
  543. int result = 0;
  544. // 销售订单
  545. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  546. amsSaleOrder.setReceiveId(receiveId);
  547. amsSaleOrder.setSaleRemark(saleRemark == null ? "":saleRemark);
  548. amsSaleOrder.setShipperId(shipperId);
  549. amsSaleOrder.setSaleOrderIsselfMention(isSelfMention);
  550. amsSaleOrder.setSaleOrderId(saleOrderId);
  551. amsSaleOrder.setSalerId(salerId);
  552. // 设置钢材订单
  553. amsSaleOrder.setSaleType(new BigDecimal(1));
  554. amsSaleOrder.setSaleNumber(DataChange.generateEightDigitsNumber("WXSDD",saleOrderId.intValue(),"-"));
  555. amsSaleOrder.setInsertTime(new Date());
  556. amsSaleOrder.setInsertUpdateRemark("物流新增销售订单");
  557. amsSaleOrder.setInsertUsername("物流");
  558. amsSaleOrder.setUpdateTime(new Date());
  559. amsSaleOrder.setDeleted(new BigDecimal(0));
  560. amsSaleOrder.setSaleOrderStatus(new BigDecimal(0));
  561. // 税率默认13%
  562. amsSaleOrder.setSaleOrderTax("13%");
  563. // 含税单价某人4000
  564. amsSaleOrder.setSaleUnitPrice(new BigDecimal(4000));
  565. // 收款客户
  566. amsSaleOrder.setSaleOrderReceiveCustomer(saleOrderReceiveCustomer);
  567. // 销售订单物资表
  568. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  569. // 车序号物资表
  570. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  571. // 遍历每一行
  572. for (Map<String, Object> map : mapList) {
  573. /*
  574. 车序号表
  575. */
  576. // 得到车序号
  577. BigDecimal truckNo = DataChange.dataToBigDecimal(map.get("truckNo"));
  578. Map<String,Object> saleMap = new HashMap<>();
  579. saleMap.put("saleOrderId",saleOrderId);
  580. saleMap.put("saleOrderMaterialTruckNo",truckNo);
  581. // 检测销售订单下的车序号是否已存在
  582. List<AmsSaleOrderMaterial> amsSaleOrderMaterials = amsSaleOrderMaterialMapper.selectByParameters(saleMap);
  583. // 车序号表
  584. AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  585. if (amsSaleOrderMaterials == null || amsSaleOrderMaterials.size() == 0) {
  586. // 车序号主键
  587. BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
  588. BigDecimal shippingAddressId = DataChange.dataToBigDecimal(map.get("shipperAddressId"));
  589. if (shippingAddressId == null || shippingAddressId.intValue() == 0) {
  590. String province = (String) map.get("province");
  591. String district = (String) map.get("district");
  592. String town = (String) map.get("town");
  593. Map<String,Object> addressMap = new HashMap<>();
  594. addressMap.put("province",province);
  595. addressMap.put("district",district);
  596. addressMap.put("town",town);
  597. shippingAddressId = amsSaleOrderMapper.findAddressId(addressMap);
  598. if (shippingAddressId == null) {
  599. throw new Exception("您输入的:" + province + district + town + "地址不存在!!");
  600. }
  601. }
  602. // 车号备注
  603. String truckRemark = (String) (map.get("truckRemark"));
  604. String place = (String) (map.get("place"));
  605. if (place != null && !"null".equals(place)) {
  606. List<Map<String, Object>> placeIdList = amsSaleOrderMaterialMapper.getPlaceId(place,shippingAddressId);
  607. if (placeIdList == null || placeIdList.size() == 0) {
  608. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  609. rmsReceivePlace.setPlaceId(rmsReceivePlaceMapper.selectMaxId());
  610. rmsReceivePlace.setAddressId(shippingAddressId);
  611. rmsReceivePlace.setAddressDeliveryAddress(place);
  612. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  613. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  614. } else {
  615. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  616. }
  617. }
  618. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null && isSelfMention.equals("否")) {
  619. // 自动匹配承运商
  620. List<Map<String, Object>> carrierList = getCarrierByAddress(amsSaleOrderMaterial.getSaleShippingAddressId());
  621. BigDecimal carrierCount = null;
  622. if(place != null && !"null".equals(place)){
  623. carrierCount = amsSaleOrderMapper.getMoreCarrier(place);
  624. }
  625. // 单一承运商才进行匹配
  626. if (carrierList != null && carrierList.size() == 1 && carrierList.get(0) != null && carrierCount.intValue() == 0) {
  627. List<Map<String, Object>> list = new ArrayList<>();
  628. Map<String, Object> map1 = carrierList.get(0);
  629. // 传入车序号主键和承运商id
  630. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  631. list.add(map1);
  632. dispatchToCarrier(list);
  633. }
  634. }
  635. if (isSelfMention.equals("是")) {
  636. // 根据收货单位id查询出收货单位名称
  637. String consigneeName = amsSaleOrderMapper.selectConsigneeName(receiveId);
  638. // 根据收货单位名称查询承运商id
  639. BigDecimal carrierId = amsSaleOrderMapper.selectCarrierId(consigneeName);
  640. List<Map<String, Object>> list = new ArrayList<>();
  641. Map<String,Object> map1 = new HashMap<>();
  642. // 传入车序号主键和承运商id
  643. if (carrierId != null) {
  644. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  645. map1.put("carrierId", carrierId);
  646. list.add(map1);
  647. dispatchToCarrier(list);
  648. }
  649. }
  650. // 收货方姓名
  651. String consigneeName = String.valueOf(map.get("saleOrderConsignee"));
  652. // 收货方电话
  653. String consigneeTel = String.valueOf(map.get("saleOrderConsigneeTel"));
  654. // 截止日期
  655. String dateOfReceiptStr = String.valueOf(map.get("saleDateOfReceipt"));
  656. Date dateOfReceipt = null;
  657. if (!"null".equals(dateOfReceiptStr) && !"undefined".equals(dateOfReceiptStr)) {
  658. dateOfReceipt = new Date(Long.valueOf(dateOfReceiptStr));
  659. }
  660. amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  661. amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
  662. amsSaleOrderMaterial.setTruckRemark(truckRemark);
  663. amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(truckNo);
  664. if (consigneeName != null && !consigneeName.equals("null")) {
  665. amsSaleOrderMaterial.setSaleOrderConsignee(consigneeName);
  666. }
  667. if (consigneeTel != null && !consigneeTel.equals("null")) {
  668. amsSaleOrderMaterial.setSaleOrderConsigneeTel(consigneeTel);
  669. }
  670. amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
  671. amsSaleOrderMaterial.setInsertTime(new Date());
  672. amsSaleOrderMaterial.setUpdateTime(new Date());
  673. amsSaleOrderMaterial.setInsertUpdateRemark("物流新增");
  674. result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
  675. }
  676. else {
  677. amsSaleOrderMaterial = amsSaleOrderMaterials.get(0);
  678. }
  679. /*
  680. 销售订单物资表
  681. */
  682. // 物资
  683. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  684. if (materialId == null || materialId.intValue() == 0) {
  685. String name = (String) map.get("materialName");
  686. String specification = (String) map.get("materialSpecification");
  687. String model = (String) map.get("materialModel");
  688. Map<String,Object> materialMap = new HashMap<>();
  689. materialMap.put("name",name);
  690. materialMap.put("specification",specification);
  691. if (model == null || model.equals("") || model.equals("null")) {
  692. model = null;
  693. }
  694. materialMap.put("model",model);
  695. materialId = amsSaleOrderMapper.findMaterialId(materialMap);
  696. if (materialId == null) {
  697. throw new Exception("您输入的物资:" + name + specification + model + "不存在!!");
  698. }
  699. }
  700. Integer materialCount = amsSaleMaterialMapper.getMaterialCount(materialId);
  701. RmsMaterial rmsMaterial = new RmsMaterial();
  702. rmsMaterial.setMaterialId(materialId);
  703. if (materialCount == null) {
  704. materialCount = new Integer(0);
  705. }
  706. rmsMaterial.setMaterialCount(new BigDecimal(materialCount + 1));
  707. rmsMaterialMapper.updateByPrimaryKeySelective(rmsMaterial);
  708. // 物资件数
  709. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("materialNumber"));
  710. // 物资名称
  711. Object materialName = map.get("materialName");
  712. // 钢材米数
  713. BigDecimal steelMeters = DataChange.dataToBigDecimal(map.get("steelMeters"));
  714. // 判断物资是否是盘螺或盘元/盘圆
  715. if (materialName != null && (materialName.toString().contains("盘螺") || materialName.toString().contains("盘元") || materialName.toString().contains("盘圆"))) {
  716. amsSaleMaterial.setSteelMeter(null);
  717. }
  718. else {
  719. amsSaleMaterial.setSteelMeter(steelMeters);
  720. }
  721. // 是否磅重销售(0:磅重;1:理重)
  722. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPoundSale"));
  723. // 销售订单物资表主键
  724. BigDecimal saleMaterialId = amsSaleMaterialMapper.selectMaxId();
  725. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  726. amsSaleMaterial.setSaleOrderId(saleOrderId);
  727. amsSaleMaterial.setMaterialId(materialId);
  728. amsSaleMaterial.setMaterialNumber(materialNumber);
  729. amsSaleMaterial.setInsertTime(new Date());
  730. amsSaleMaterial.setUpdateTime(new Date());
  731. amsSaleMaterial.setIsPoundSale(isPoundSale);
  732. amsSaleMaterial.setInsertUpdateRemark("物流新增");
  733. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  734. /*
  735. 车序号物资表
  736. */
  737. // 车序号物资表主键
  738. BigDecimal truckNoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
  739. amsSaleTrucknoMaterial.setTrucknoMaterialId(truckNoMaterialId);
  740. amsSaleTrucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  741. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  742. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  743. amsSaleTrucknoMaterial.setInsertTime(new Date());
  744. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  745. amsSaleTrucknoMaterial.setInsertUpdateRemark("物流新增");
  746. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  747. }
  748. result += amsSaleOrderMapper.insertSelective(amsSaleOrder);
  749. return result;
  750. }
  751. /**
  752. * 展示销售订单下的车序号和物资
  753. * @param saleOrderId
  754. * @return
  755. */
  756. @Override
  757. public List<Map<String, Object>> getTruckNoAndMaterialList(BigDecimal saleOrderId) {
  758. HashMap<String,Object> mapValue = new HashMap<>();
  759. mapValue.put("saleOrderId",saleOrderId);
  760. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoAndMaterial(mapValue);
  761. for (Map<String,Object> map : mapList) {
  762. BigDecimal placeId = (BigDecimal) map.get("placeId");
  763. if (placeId != null) {
  764. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  765. map.put("carrierAndPriceList", carrierAndPriceList);
  766. }
  767. }
  768. return mapList;
  769. }
  770. /**
  771. * 销售钢材派车
  772. * @param mapList
  773. * @return
  774. */
  775. @Transactional(rollbackFor = Exception.class)
  776. @Override
  777. public int dispatchSteelOrder(List<Map<String, Object>> mapList) throws Exception {
  778. Map<String, Object> stringObjectMap = mapList.get(0);
  779. Integer isCheckGps = amsSaleOrderMapper.getDispachSwitch();
  780. Integer saleStatus = amsSaleOrderMapper.findStatus(DataChange.dataToBigDecimal(stringObjectMap.get("saleOrderMaterialId")));
  781. String selfMention = amsSaleOrderMapper.findSelfMention(DataChange.dataToBigDecimal(stringObjectMap.get("saleOrderMaterialId")));
  782. if (saleStatus == 1) {
  783. throw new Exception("订单未审核,无法派车!");
  784. }
  785. int result = 0;
  786. // 遍历每一行
  787. for (Map<String,Object> map : mapList) {
  788. // 得到车牌号
  789. String capacityNumber = (String) map.get("capacityNumber");
  790. Map<String,Object> details = amsSaleOrderMapper.getOrderIdByCapacity(map);
  791. if(details!=null && details.get("orderId")!=null){
  792. if(details.get("isEn")==null){
  793. throw new Exception(capacityNumber+"有未进厂的运输订单任务,无法派单");
  794. }else if(details.get("isLeave")==null){
  795. throw new Exception(capacityNumber+"有未出厂的运输订单任务,无法派单");
  796. }else if(details.get("isArrival")==null){
  797. throw new Exception(capacityNumber+"有未抵达的运输订单任务,无法派单");
  798. }else if(details.get("isReceipt")==null){
  799. throw new Exception(capacityNumber+"有未签收的运输订单任务,无法派单");
  800. }
  801. throw new Exception(capacityNumber+"有未完成的运输订单任务,无法派单");
  802. }
  803. if(isCheckGps!=null && isCheckGps==0){
  804. Map<String,Object> locationResult = null;
  805. try{
  806. Map<String,Object> data = (Map<String,Object>)otmsFeign.getCurrentLocation(capacityNumber).getData();
  807. locationResult = (Map<String,Object>)data.get("result");
  808. }catch (Exception e){
  809. //出现任何异常不抛出,不终止程序
  810. }
  811. if(locationResult==null || locationResult.get("lon")==null || locationResult.get("lat")==null){
  812. throw new Exception("该车没有GPS定位信息,请联系销售公司物流部,申请是否可以派车。");
  813. }
  814. }
  815. // 得到车序号表主键
  816. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  817. // 得到承运商
  818. BigDecimal carrierId = DataChange.dataToBigDecimal(map.get("carrierId"));
  819. // 查询到车序号的单价
  820. BigDecimal priceId = amsSaleOrderMapper.getOrderPrice(map);
  821. // 得到详细地址id
  822. BigDecimal placeId = amsSaleOrderMapper.getPlaceId(saleOrderMaterialId);
  823. // 如果详细地址匹配不到单价,则匹配省市县内最高的一条单价(只给非自提的进行匹配)
  824. if (priceId == null && selfMention.equals("否")) {
  825. // 找到详细地址下的省市县id
  826. BigDecimal addressId = amsSaleOrderMapper.getAddressByPlace(placeId);
  827. // 根据省市县匹配出省市县下的所有单价
  828. Map<String, Object> hashMap = new HashMap<>();
  829. hashMap.put("addressId", addressId);
  830. hashMap.put("carrierId", carrierId);
  831. List<Map<String, Object>> priceList = amsSaleOrderMapper.getAddressPriceList(hashMap);
  832. // 如果长度为0,说明此地址所在省市县内也无单价
  833. if (priceList != null && priceList.size() != 0) {
  834. Map<String, Object> priceMap = priceList.get(0);
  835. priceId = (BigDecimal) priceMap.get("priceId");
  836. } else {
  837. priceId = new BigDecimal(2400);
  838. }
  839. }
  840. // 运输线路id
  841. BigDecimal lineId = DataChange.dataToBigDecimal(map.get("lineId"));
  842. // 司机电话号码
  843. String driverTel = (String) map.get("driverTel");
  844. BigDecimal isSteel = new BigDecimal(1);
  845. // 得到运力id
  846. BigDecimal capacityId = amsSaleOrderMaterialMapper.getCapacityId(capacityNumber);
  847. if (capacityId == null) {
  848. return 0;
  849. }
  850. List<Map<String, Object>> materialList = amsSaleOrderMaterialMapper.getMaterial(saleOrderMaterialId);
  851. /*
  852. 定向派单表
  853. */
  854. // 通过车序号主键确认定向派单是否已存在
  855. BigDecimal dispatchId0 = amsDispatchSaleOrderMapper.isDispatchExist(saleOrderMaterialId);
  856. if (dispatchId0 == null || dispatchId0.toString().length() == 0) {
  857. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  858. // 主键
  859. BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
  860. amsDispatchSaleOrder.setDispatchId(dispatchId);
  861. // 车序号表id
  862. amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
  863. // 承运商id
  864. amsDispatchSaleOrder.setCarrierId(carrierId);
  865. // 派单时间和成交时间
  866. amsDispatchSaleOrder.setDispatchTime(new Date());
  867. amsDispatchSaleOrder.setDispatchDealTime(new Date());
  868. // 成交类型
  869. amsDispatchSaleOrder.setDispatchType(new BigDecimal(2));
  870. // 车序号状态
  871. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
  872. result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
  873. }
  874. // 如果已经匹配过承运商或者给某个承运商授权过,则派车时做修改承运商操作
  875. else {
  876. AmsDispatchSaleOrder amsDispatchSaleOrder = amsDispatchSaleOrderMapper.selectByPrimaryKey(dispatchId0);
  877. amsDispatchSaleOrder.setCarrierId(carrierId);
  878. result += amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(amsDispatchSaleOrder);
  879. }
  880. /*
  881. 运输订单
  882. */
  883. OmstruckOrder omstruckOrder = new OmstruckOrder();
  884. Map<String, Object> map1 = new HashMap<>();
  885. map1.put("orderType", new BigDecimal(2));
  886. map1.put("orderPlanId", saleOrderMaterialId);
  887. List<OmstruckOrder> omstruckOrders = omstruckOrderMapper.selectByParameters(map1);
  888. if (omstruckOrders == null || omstruckOrders.size() == 0) {
  889. // 运输订单主键
  890. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  891. omstruckOrder.setOrderId(orderId);
  892. // 车序号主键
  893. omstruckOrder.setOrderPlanId(saleOrderMaterialId);
  894. //添加承运商ID 和 运价ID
  895. // Object priceId = map.get("priceId");
  896. if (priceId != null) {
  897. omstruckOrder.setPriceId(priceId);
  898. } else {
  899. omstruckOrder.setPriceId(new BigDecimal(0));
  900. }
  901. omstruckOrder.setCarrierId(carrierId);
  902. // 运输订单号
  903. omstruckOrder.setOrderNumber(DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue()));
  904. // 运力id
  905. omstruckOrder.setCapacityId(capacityId);
  906. // 承运商
  907. omstruckOrder.setCarrierId(carrierId);
  908. // 是否可作业
  909. omstruckOrder.setCanWork(new BigDecimal(0));
  910. // 下发时间
  911. omstruckOrder.setOrderIssueTime(new Date());
  912. // 运单状态
  913. omstruckOrder.setOrderStatus(new BigDecimal(4));
  914. // 司机电话
  915. if (driverTel != null && !"null".equals(driverTel)) {
  916. omstruckOrder.setDriverTel(driverTel);
  917. }
  918. BigDecimal status;
  919. // 钢材
  920. if (isSteel != null && isSteel.intValue() == 1) {
  921. status = new BigDecimal(1);
  922. }
  923. // 非钢材(危化品,焦炭,副产品)
  924. else {
  925. status = new BigDecimal(2);
  926. }
  927. // 订单类型
  928. omstruckOrder.setOrderType(status);
  929. // 运输线路id
  930. omstruckOrder.setLineId(lineId);
  931. omstruckOrder.setInsertTime(new Date());
  932. omstruckOrder.setInsertUsername("");
  933. result += omstruckOrderMapper.insertSelective(omstruckOrder);
  934. } else {
  935. omstruckOrder = omstruckOrders.get(0);
  936. }
  937. for (Map<String, Object> materialMap : materialList) {
  938. BigDecimal materialId = (BigDecimal) materialMap.get("materialId");
  939. BigDecimal materialWeight = (BigDecimal) materialMap.get("materialWeight");
  940. BigDecimal materialNumber = (BigDecimal) materialMap.get("materialNumber");
  941. /*
  942. 运输订单物资子表
  943. */
  944. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  945. // 主键
  946. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  947. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  948. // 运输订单id
  949. omstruckOrderMaterial.setOrderId(omstruckOrder.getOrderId());
  950. // 物资id
  951. omstruckOrderMaterial.setMaterialId(materialId);
  952. // 物资重量
  953. omstruckOrderMaterial.setOrderMaterialWeight(materialWeight);
  954. // 物资件数
  955. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  956. // 新增运输订单子表
  957. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  958. }
  959. // 调用websocket
  960. Map<String, Object> orderIdMap = new HashMap<>();
  961. orderIdMap.put("orderId", omstruckOrder.getOrderId());
  962. amsSaleOrderMaterialService.pushMesToWebsocket(orderIdMap);
  963. // 生成运输执行总实绩
  964. result += tmsTruckFeign.addTotalResult(orderIdMap);
  965. }
  966. return result;
  967. }
  968. /**
  969. * 根据详细地址匹配承运商
  970. * @param placeId
  971. * @return
  972. */
  973. @Override
  974. public synchronized List<Map<String,Object>> getCarrierByPlace(BigDecimal placeId) {
  975. BigDecimal addressId = amsSaleOrderMapper.getAddressByPlace(placeId);
  976. List<Map<String,Object>> mapList = amsSaleOrderMapper.getCarrierByPlace(placeId);
  977. return mapList;
  978. }
  979. /**
  980. * 根据省市县匹配承运商
  981. * @param placeId
  982. * @return
  983. */
  984. public synchronized List<Map<String,Object>> getCarrierByAddress(BigDecimal placeId) {
  985. BigDecimal addressId = amsSaleOrderMapper.getAddressByPlace(placeId);
  986. List<Map<String,Object>> mapList = amsSaleOrderMapper.getCarrierByAddress(addressId);
  987. return mapList;
  988. }
  989. /**
  990. * 根据详细地址和承运商匹配单价
  991. * @param mapValue
  992. * @return
  993. */
  994. @Override
  995. public Map<String, Object> getPriceByCarrierAndPlace(Map<String, Object> mapValue) {
  996. Map<String,Object> map = amsSaleOrderMapper.getPriceByCarrierAndPlace(mapValue);
  997. return map;
  998. }
  999. /**
  1000. * 将车序号下发给承运商
  1001. * @param mapList
  1002. * @return
  1003. */
  1004. @Override
  1005. public int dispatchToCarrier(List<Map<String,Object>> mapList) {
  1006. int result = 0;
  1007. // 遍历每一行
  1008. for (Map<String, Object> map : mapList) {
  1009. // 得到承运商
  1010. BigDecimal carrierId =DataChange.dataToBigDecimal(map.get("carrierId"));
  1011. // 得到车序号表主键
  1012. BigDecimal saleOrderMaterialId =DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  1013. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  1014. BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
  1015. amsDispatchSaleOrder.setDispatchId(dispatchId);
  1016. amsDispatchSaleOrder.setCarrierId(carrierId);
  1017. amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
  1018. amsDispatchSaleOrder.setInsertTime(new Date());
  1019. amsDispatchSaleOrder.setInsertUpdateRemark("授权承运商");
  1020. // 派单时间和成交时间
  1021. amsDispatchSaleOrder.setDispatchTime(new Date());
  1022. amsDispatchSaleOrder.setDispatchDealTime(new Date());
  1023. // 成交类型
  1024. amsDispatchSaleOrder.setDispatchType(new BigDecimal(2));
  1025. // 车序号状态
  1026. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
  1027. result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
  1028. }
  1029. return result;
  1030. }
  1031. @Override
  1032. public List<Map<String, Object>> getSaleOrderListToCarrier(Map<String, Object> map) {
  1033. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleOrderListToCarrier(map);
  1034. return resultList;
  1035. }
  1036. @Override
  1037. public List<Map<String, Object>> getSaleOrderListByCarrierSsoId(Map<String, Object> map) {
  1038. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleOrderListByCarrierSsoId(map);
  1039. return resultList;
  1040. }
  1041. /**
  1042. * 同步金蝶删除
  1043. * @param saleOrderId
  1044. * @return
  1045. */
  1046. @Override
  1047. public int deleteSaleOrderById(BigDecimal saleOrderId) {
  1048. int result = 0;
  1049. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1050. amsSaleOrder.setSaleOrderId(saleOrderId);
  1051. amsSaleOrder.setDeleted(new BigDecimal(2));
  1052. // 如果是已经上传金蝶的销售订单,则同步删除
  1053. AmsSaleOrder amsSaleOrder1 = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  1054. if (amsSaleOrder1.getSaleOrderStatus().intValue() == 4) {
  1055. String reason = "修改物资关闭上一条销售订单";
  1056. String number = amsSaleOrder1.getSaleNumber();
  1057. String wholeOrder = "1";
  1058. String status = "close";
  1059. Map<String,Object> head = new HashMap<>();
  1060. head.put("number",number);
  1061. head.put("reason",reason);
  1062. head.put("wholeOrder",wholeOrder);
  1063. head.put("status",status);
  1064. Map<String,Object> input = new HashMap<>();
  1065. Map<String, Object> totalMap = easDeleteApproveUtil.getTotalMap();
  1066. input.put("head",head);
  1067. totalMap.put("input",input);
  1068. // 调用金蝶关闭接口
  1069. String json = JSONUtils.toJSONString(totalMap);
  1070. System.out.println(json);
  1071. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1072. System.out.println(resultMap);
  1073. }else if(amsSaleOrder1.getSaleOrderStatus().intValue() == 1 || amsSaleOrder1.getSaleOrderStatus().intValue() == 2){
  1074. String reason = "修改物资关闭上一条销售订单";
  1075. String number = amsSaleOrder1.getSaleNumber();
  1076. Map<String, Object> deleteMap = new HashMap<>();
  1077. deleteMap.put("saleOrderId",saleOrderId);
  1078. deleteMap.put("reason",reason);
  1079. deleteMap.put("number",number);
  1080. deleteSaleOrderSame(deleteMap);
  1081. }
  1082. // 如果是副产品订单则关闭时同步关闭未进厂的运单
  1083. Map<String,Object> map = new HashMap<>();
  1084. map.put("saleOrderId",saleOrderId);
  1085. List<AmsSaleMaterial> amsSaleMaterials = amsSaleMaterialMapper.selectByParameters(map);
  1086. if (amsSaleMaterials != null && amsSaleMaterials.get(0).getSaleWarehouse() != null && amsSaleMaterials.get(0).getSaleWarehouse().equals("副产品库")) {
  1087. result += amsSaleOrderMapper.closeOrderNotIn(saleOrderId);
  1088. }
  1089. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1090. return result;
  1091. }
  1092. /**
  1093. * 查询出销售订单下的所有数据
  1094. * @param saleOrderId
  1095. * @return
  1096. */
  1097. @Override
  1098. public Map<String, Object> getAllSaleMessages(BigDecimal saleOrderId) {
  1099. Map<String,Object> saleMap = amsSaleOrderMapper.getSaleMapMessages(saleOrderId);
  1100. List<Map<String,Object>> mapList = amsSaleOrderMapper.getSaleListMessages(saleOrderId);
  1101. saleMap.put("mapList",mapList);
  1102. return saleMap;
  1103. }
  1104. /**
  1105. * 修改承运商授权
  1106. * @param mapValue
  1107. * @return
  1108. */
  1109. @Override
  1110. public int updateTruckNoCarrier(Map<String, Object> mapValue) {
  1111. BigDecimal carrierId = DataChange.dataToBigDecimal(mapValue.get("carrierId"));
  1112. mapValue.remove("carrierId");
  1113. List<AmsDispatchSaleOrder> amsDispatchSaleOrders = amsDispatchSaleOrderMapper.selectByParameters(mapValue);
  1114. AmsDispatchSaleOrder amsDispatchSaleOrder = amsDispatchSaleOrders.get(0);
  1115. amsDispatchSaleOrder.setCarrierId(carrierId);
  1116. int result = amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(amsDispatchSaleOrder);
  1117. return result;
  1118. }
  1119. /**
  1120. * 批量上传销售订单至金蝶
  1121. * @param saleOrderIdList
  1122. * @return
  1123. */
  1124. @Transactional(rollbackFor = Exception.class)
  1125. @Override
  1126. public int uploadSaleOrderList(List<Map<String, Object>> saleOrderIdList) {
  1127. int result = 0;
  1128. for (Map<String, Object> map : saleOrderIdList) {
  1129. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1130. BigDecimal saleOrderId = DataChange.dataToBigDecimal(map.get("saleOrderId"));
  1131. // 调用金蝶接口,将销售订单推送到金蝶系统
  1132. Map<String, Object> input = joinFeign.getSaleOrder(saleOrderId);
  1133. Map<String, Object> head = (Map<String, Object>) input.get("head");
  1134. head.put("status","");
  1135. // 获得金蝶接口配置:正式
  1136. // Map<String, Object> totalMap = easUtil.getTotalMap();
  1137. // 获得金蝶接口配置:测试
  1138. Map<String, Object> totalMap = easUtil.getTotalMap();
  1139. // 组装报文
  1140. totalMap.put("input",input);
  1141. System.out.println(totalMap);
  1142. String json = JSONUtils.toJSONString(totalMap);
  1143. System.out.println(json);
  1144. Map<String,Object> s = joinFeign.pushSaleOrderToEas(totalMap);
  1145. String status = (String) s.get("status");
  1146. if ("-1".equals(status)) {
  1147. continue;
  1148. }
  1149. System.out.println(s);
  1150. amsSaleOrder.setSaleOrderId(saleOrderId);
  1151. amsSaleOrder.setSaleOrderStatus(new BigDecimal(1));
  1152. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1153. }
  1154. return result;
  1155. }
  1156. /**
  1157. * 新增钒渣销售订单
  1158. * @param mapValue
  1159. * @return
  1160. */
  1161. @Override
  1162. public int addVanadiumSaleOrder(Map<String, Object> mapValue) {
  1163. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1164. // 得到发货单位
  1165. BigDecimal shipperId = DataChange.dataToBigDecimal(mapValue.get("shipperId"));
  1166. // 收货单位
  1167. BigDecimal receiveId = DataChange.dataToBigDecimal(mapValue.get("receiveId"));
  1168. // 是否自提
  1169. String isSelfMention = (String) mapValue.get("isSelfMention");
  1170. // 备注
  1171. String saleRemark = (String) mapValue.get("saleRemark");
  1172. // 收款客户
  1173. String saleOrderReceiveCustomer = (String) mapValue.get("saleOrderReceiveCustomer");
  1174. // 业务员
  1175. BigDecimal salerId = DataChange.dataToBigDecimal(mapValue.get("salerId"));
  1176. BigDecimal saleOrderId = amsSaleOrderMapper.selectMaxId();
  1177. int result = 0;
  1178. // 销售订单
  1179. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1180. amsSaleOrder.setReceiveId(receiveId);
  1181. amsSaleOrder.setSaleRemark(saleRemark == null ? "":saleRemark);
  1182. amsSaleOrder.setShipperId(shipperId);
  1183. amsSaleOrder.setSaleOrderIsselfMention(isSelfMention);
  1184. amsSaleOrder.setSaleOrderId(saleOrderId);
  1185. amsSaleOrder.setSalerId(salerId);
  1186. // 设置钒渣订单
  1187. amsSaleOrder.setSaleType(new BigDecimal(2));
  1188. amsSaleOrder.setSaleNumber(DataChange.generateEightDigitsNumber("WXSDD",saleOrderId.intValue(),"-"));
  1189. amsSaleOrder.setInsertTime(new Date());
  1190. amsSaleOrder.setInsertUpdateRemark("物流新增销售订单");
  1191. amsSaleOrder.setInsertUsername("物流");
  1192. amsSaleOrder.setUpdateTime(new Date());
  1193. amsSaleOrder.setDeleted(new BigDecimal(0));
  1194. amsSaleOrder.setSaleOrderStatus(new BigDecimal(0));
  1195. // 税率默认13%
  1196. amsSaleOrder.setSaleOrderTax("13%");
  1197. // 含税单价某人4000
  1198. amsSaleOrder.setSaleUnitPrice(new BigDecimal(4000));
  1199. // 收款客户
  1200. amsSaleOrder.setSaleOrderReceiveCustomer(saleOrderReceiveCustomer);
  1201. // 销售订单物资表
  1202. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1203. // 车序号物资表
  1204. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  1205. // 遍历每一行
  1206. for (Map<String, Object> map : mapList) {
  1207. /*
  1208. 车序号表
  1209. */
  1210. // 得到车序号
  1211. BigDecimal truckNo = DataChange.dataToBigDecimal(map.get("truckNo"));
  1212. Map<String,Object> saleMap = new HashMap<>();
  1213. saleMap.put("saleOrderId",saleOrderId);
  1214. saleMap.put("saleOrderMaterialTruckNo",truckNo);
  1215. // 检测销售订单下的车序号是否已存在
  1216. List<AmsSaleOrderMaterial> amsSaleOrderMaterials = amsSaleOrderMaterialMapper.selectByParameters(saleMap);
  1217. // 车序号表
  1218. AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  1219. if (amsSaleOrderMaterials == null || amsSaleOrderMaterials.size() == 0) {
  1220. // 车序号主键
  1221. BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
  1222. BigDecimal shippingAddressId = DataChange.dataToBigDecimal(map.get("shipperAddressId"));
  1223. // 车号备注
  1224. String truckRemark = (String) (map.get("truckRemark"));
  1225. String place = (String) (map.get("place"));
  1226. if (place != null && !"null".equals(place)) {
  1227. List<Map<String, Object>> placeIdList = amsSaleOrderMaterialMapper.getPlaceId(place,shippingAddressId);
  1228. if (placeIdList == null || placeIdList.size() == 0) {
  1229. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  1230. rmsReceivePlace.setPlaceId(rmsReceivePlaceMapper.selectMaxId());
  1231. rmsReceivePlace.setAddressId(shippingAddressId);
  1232. rmsReceivePlace.setAddressDeliveryAddress(place);
  1233. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  1234. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  1235. } else {
  1236. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  1237. }
  1238. }
  1239. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null && isSelfMention.equals("否")) {
  1240. // 自动匹配承运商
  1241. List<Map<String, Object>> carrierList = getCarrierByPlace(amsSaleOrderMaterial.getSaleShippingAddressId());
  1242. // 单一承运商才进行匹配
  1243. if (carrierList != null && carrierList.size() == 1) {
  1244. List<Map<String, Object>> list = new ArrayList<>();
  1245. Map<String, Object> map1 = carrierList.get(0);
  1246. // 传入车序号主键和承运商id
  1247. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1248. map1.put("carrierId", map1.get("value"));
  1249. list.add(map1);
  1250. dispatchToCarrier(list);
  1251. }
  1252. }
  1253. if (isSelfMention.equals("是")) {
  1254. // 根据收货单位id查询出收货单位名称
  1255. String consigneeName = amsSaleOrderMapper.selectConsigneeName(receiveId);
  1256. // 根据收货单位名称查询承运商id
  1257. BigDecimal carrierId = amsSaleOrderMapper.selectCarrierId(consigneeName);
  1258. List<Map<String, Object>> list = new ArrayList<>();
  1259. Map<String,Object> map1 = new HashMap<>();
  1260. // 传入车序号主键和承运商id
  1261. if (carrierId != null) {
  1262. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1263. map1.put("carrierId", carrierId);
  1264. list.add(map1);
  1265. dispatchToCarrier(list);
  1266. }
  1267. }
  1268. // 收货方姓名
  1269. String consigneeName = String.valueOf(map.get("saleOrderConsignee"));
  1270. // 收货方电话
  1271. String consigneeTel = String.valueOf(map.get("saleOrderConsigneeTel"));
  1272. // 截止日期
  1273. String dateOfReceiptStr = String.valueOf(map.get("saleDateOfReceipt"));
  1274. Date dateOfReceipt = null;
  1275. if (!"null".equals(dateOfReceiptStr) && !"undefined".equals(dateOfReceiptStr)) {
  1276. dateOfReceipt = new Date(Long.valueOf(dateOfReceiptStr));
  1277. }
  1278. amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  1279. amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
  1280. amsSaleOrderMaterial.setTruckRemark(truckRemark);
  1281. amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(truckNo);
  1282. if (consigneeName != null && !consigneeName.equals("null")) {
  1283. amsSaleOrderMaterial.setSaleOrderConsignee(consigneeName);
  1284. }
  1285. if (consigneeTel != null && !consigneeTel.equals("null")) {
  1286. amsSaleOrderMaterial.setSaleOrderConsigneeTel(consigneeTel);
  1287. }
  1288. amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
  1289. amsSaleOrderMaterial.setInsertTime(new Date());
  1290. amsSaleOrderMaterial.setUpdateTime(new Date());
  1291. amsSaleOrderMaterial.setInsertUpdateRemark("物流新增");
  1292. result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
  1293. }
  1294. else {
  1295. amsSaleOrderMaterial = amsSaleOrderMaterials.get(0);
  1296. }
  1297. /*
  1298. 销售订单物资表
  1299. */
  1300. // 物资
  1301. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  1302. // 物资件数
  1303. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("materialNumber"));
  1304. // 钢材米数
  1305. BigDecimal steelMeters = DataChange.dataToBigDecimal(map.get("steelMeters"));
  1306. // 是否磅重销售(0:磅重;1:理重)
  1307. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPoundSale"));
  1308. // 销售订单物资表主键
  1309. BigDecimal saleMaterialId = amsSaleMaterialMapper.selectMaxId();
  1310. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1311. amsSaleMaterial.setSaleOrderId(saleOrderId);
  1312. amsSaleMaterial.setMaterialId(materialId);
  1313. amsSaleMaterial.setMaterialNumber(materialNumber);
  1314. amsSaleMaterial.setInsertTime(new Date());
  1315. amsSaleMaterial.setUpdateTime(new Date());
  1316. if (steelMeters != null && !steelMeters.toString().equals("0")) {
  1317. amsSaleMaterial.setSteelMeter(steelMeters);
  1318. }
  1319. amsSaleMaterial.setIsPoundSale(isPoundSale);
  1320. amsSaleMaterial.setInsertUpdateRemark("物流新增");
  1321. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  1322. /*
  1323. 车序号物资表
  1324. */
  1325. // 车序号物资表主键
  1326. BigDecimal truckNoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
  1327. amsSaleTrucknoMaterial.setTrucknoMaterialId(truckNoMaterialId);
  1328. amsSaleTrucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  1329. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  1330. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  1331. amsSaleTrucknoMaterial.setInsertTime(new Date());
  1332. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  1333. amsSaleTrucknoMaterial.setInsertUpdateRemark("物流新增");
  1334. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  1335. }
  1336. result += amsSaleOrderMapper.insertSelective(amsSaleOrder);
  1337. return result;
  1338. }
  1339. /**
  1340. * 自动匹配出最近的一个地址
  1341. * @param receiveId
  1342. * @return
  1343. */
  1344. @Override
  1345. public List<Map<String, Object>> matchingAddressRecently(BigDecimal receiveId) {
  1346. List<Map<String,Object>> mapList = amsSaleOrderMapper.matchingAddressRecently(receiveId);
  1347. List<Map<String,Object>> salerList = amsSaleOrderMapper.getSalerByReceiveId(receiveId);
  1348. if (mapList != null && mapList.size() != 0) {
  1349. if (salerList != null && salerList.size() !=0) {
  1350. Map<String, Object> salerMap = salerList.get(0);
  1351. for (Map<String, Object> map : mapList) {
  1352. map.putAll(salerMap);
  1353. }
  1354. }
  1355. }
  1356. return mapList;
  1357. }
  1358. /**
  1359. * 自动匹配上一条运单的司机电话
  1360. * @param capacityNumber
  1361. * @return
  1362. */
  1363. @Override
  1364. public String matchingDriverTelRecently(String capacityNumber) {
  1365. String driverTel = amsSaleOrderMapper.matchingDriverTelRecently(capacityNumber);
  1366. return driverTel;
  1367. }
  1368. /**
  1369. * 查询内转焦炭订单
  1370. * @param mapValue
  1371. * @return
  1372. */
  1373. @Override
  1374. public List<Map<String, Object>> getCokeInwardOrderList(Map<String, Object> mapValue) {
  1375. return amsSaleOrderMapper.getCokeInwardOrderList(mapValue);
  1376. }
  1377. /**
  1378. * 修改收货地址
  1379. * @param mapValue
  1380. * @return
  1381. */
  1382. @Transactional(rollbackFor = Exception.class)
  1383. @Override
  1384. public int updateCarAddress(Map<String, Object> mapValue) {
  1385. // 判断是否需要删除金蝶分录
  1386. Integer isCloseEas = (Integer) mapValue.get("isCloseEas");
  1387. String operateName = (String) mapValue.get("operateName");
  1388. int result = 0;
  1389. // 运输订单id
  1390. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  1391. // 车序号id
  1392. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1393. // 是
  1394. if (isCloseEas == 0 && orderId != null && orderId.intValue() != 0) {
  1395. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1396. omstruckOrder.setOrderId(orderId);
  1397. omstruckOrder.setOrderStatus(new BigDecimal(7));
  1398. if(operateName != null){
  1399. omstruckOrder.setOptionerCode(operateName);
  1400. }
  1401. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1402. // 得到销售订单物资表主键
  1403. List<Map<String,Object>> saleMaterialIdList = amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1404. for (Map<String, Object> map : saleMaterialIdList) {
  1405. // 关闭销售订单物资子表
  1406. BigDecimal saleMaterialId = (BigDecimal) map.get("saleMaterialId");
  1407. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1408. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1409. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1410. amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1411. }
  1412. return 0;
  1413. }
  1414. // 判断是否需要修改派车
  1415. Object isNewCar = mapValue.get("isNewCar");
  1416. // 省市县ID
  1417. BigDecimal shippingAddressId = DataChange.dataToBigDecimal(mapValue.get("shipperAddressId"));
  1418. // 具体地址
  1419. String place = (String) mapValue.get("place");
  1420. Integer addressid1= (Integer) mapValue.get("placeId");
  1421. BigDecimal addressid2 =BigDecimal.ZERO;
  1422. AmsSaleOrderMaterial amsSaleOrderMaterial = amsSaleOrderMaterialMapper.selectByPrimaryKey(saleOrderMaterialId);
  1423. if (place != null && !("".equals(place))) {
  1424. List<Map<String, Object>> placeIdList = amsSaleOrderMaterialMapper.getPlaceId(place,shippingAddressId);
  1425. addressid2 =(BigDecimal) placeIdList.get(0).get("placeId");
  1426. if (placeIdList == null || placeIdList.size() == 0) {
  1427. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  1428. rmsReceivePlace.setPlaceId(rmsReceivePlaceMapper.selectMaxId());
  1429. rmsReceivePlace.setAddressId(shippingAddressId);
  1430. rmsReceivePlace.setAddressDeliveryAddress(place);
  1431. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  1432. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  1433. } else {
  1434. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  1435. }
  1436. }
  1437. String addressids="";
  1438. addressids =addressid1+","+addressid2;
  1439. amsSaleOrderMaterial.setShippingAddressIds(addressids);
  1440. result += amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial);
  1441. // 需要换车
  1442. if (isNewCar != null && (Integer) isNewCar == 0) {
  1443. // 根据车序号得到定向派单表主键
  1444. BigDecimal dispatchId = amsSaleOrderMapper.getDispatchId(saleOrderMaterialId);
  1445. if (dispatchId != null) {
  1446. amsDispatchSaleOrderMapper.deleteByPrimaryKey(dispatchId);
  1447. }
  1448. if (orderId != null) {
  1449. omstruckOrderMapper.deleteByPrimaryKey(orderId);
  1450. }
  1451. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null) {
  1452. // 自动匹配承运商
  1453. List<Map<String, Object>> carrierList = getCarrierByPlace(amsSaleOrderMaterial.getSaleShippingAddressId());
  1454. // 单一承运商才进行匹配
  1455. if (carrierList != null && carrierList.size() == 1) {
  1456. List<Map<String, Object>> list = new ArrayList<>();
  1457. Map<String, Object> map1 = carrierList.get(0);
  1458. // 传入车序号主键和承运商id
  1459. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1460. map1.put("carrierId", map1.get("value"));
  1461. list.add(map1);
  1462. dispatchToCarrier(list);
  1463. }
  1464. }
  1465. }
  1466. return result;
  1467. }
  1468. /**
  1469. * 展示未匹配承运商的车序号
  1470. * @param mapValue
  1471. * @return
  1472. */
  1473. @Override
  1474. public List<Map<String, Object>> getSteelTruckNoList(Map<String, Object> mapValue) {
  1475. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSteelTruckNoList(mapValue);
  1476. return resultList;
  1477. }
  1478. /**
  1479. * 展示车序号的详情
  1480. * @param saleOrderMaterialId
  1481. * @return
  1482. */
  1483. @Override
  1484. public List<Map<String, Object>> getTruckNoMaterial(BigDecimal saleOrderMaterialId) {
  1485. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoMaterialAndCarrier(saleOrderMaterialId);
  1486. for (Map<String,Object> map : mapList) {
  1487. BigDecimal placeId = (BigDecimal) map.get("placeId");
  1488. if (placeId != null) {
  1489. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  1490. map.put("carrierAndPriceList", carrierAndPriceList);
  1491. }
  1492. }
  1493. return mapList;
  1494. }
  1495. /**
  1496. * 展示已分配承运商但未派车的车序号
  1497. * @param mapValue
  1498. * @return
  1499. */
  1500. @Override
  1501. public List<Map<String, Object>> getNoCarTruckNoList(Map<String, Object> mapValue) {
  1502. List<Map<String, Object>> resultList = amsSaleOrderMapper.getCarrierTruckNoList(mapValue);
  1503. return resultList;
  1504. }
  1505. /**
  1506. * 展示已派车的车序号
  1507. * @param mapValue
  1508. * @return
  1509. */
  1510. @Override
  1511. public List<Map<String, Object>> getHaveCarTruckNoList(Map<String, Object> mapValue) {
  1512. List<Map<String, Object>> resultList = amsSaleOrderMapper.getHaveCarTruckNoList(mapValue);
  1513. return resultList;
  1514. }
  1515. /**
  1516. * 修改销售订单中的物资
  1517. * @param mapValue
  1518. * @return
  1519. */
  1520. @Transactional(rollbackFor = Exception.class)
  1521. @Override
  1522. public int updateAllMaterialInSale(Map<String, Object> mapValue) {
  1523. int result = 0;
  1524. // 得到销售订单主键
  1525. BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
  1526. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1527. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  1528. // 将车辆改为不可作业状态
  1529. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1530. omstruckOrder.setOrderId(orderId);
  1531. omstruckOrder.setCanWork(new BigDecimal(1));
  1532. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1533. // 得到运单中的物资
  1534. List<Map<String, Object>> oldList = omstruckOrderMaterialMapper.getMaterialList(orderId);
  1535. Map<String, Object> toTmsMap = new HashMap<>();
  1536. Map<String, Object> truckNoMap = new HashMap<>();
  1537. truckNoMap.put("saleOrderMaterialId",saleOrderMaterialId);
  1538. toTmsMap.put("orderId", orderId);
  1539. toTmsMap.put("oldMaterialMapList", oldList);
  1540. // 得到所有的物资
  1541. List<Map<String, Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1542. /*
  1543. 删除三个物资表数据
  1544. */
  1545. List<AmsSaleTrucknoMaterial> amsSaleTrucknoMaterials = amsSaleTrucknoMaterialMapper.selectByParameters(truckNoMap);
  1546. for (AmsSaleTrucknoMaterial amsSaleTrucknoMaterial : amsSaleTrucknoMaterials) {
  1547. // 销售订单物资子表
  1548. amsSaleMaterialMapper.deleteByPrimaryKey(amsSaleTrucknoMaterial.getMaterialId());
  1549. // 车序号子表
  1550. amsSaleTrucknoMaterialMapper.deleteByPrimaryKey(amsSaleTrucknoMaterial.getTrucknoMaterialId());
  1551. }
  1552. // 运输订单物资子表
  1553. List<OmstruckOrderMaterial> omstruckOrderMaterials = omstruckOrderMaterialMapper.selectByParameters(toTmsMap);
  1554. for (OmstruckOrderMaterial omstruckOrderMaterial : omstruckOrderMaterials) {
  1555. omstruckOrderMaterialMapper.deleteByPrimaryKey(omstruckOrderMaterial.getOrderMaterialId());
  1556. }
  1557. /*
  1558. 重新新增三个表
  1559. */
  1560. for (Map<String, Object> map : mapList) {
  1561. Object saleMaterialId = map.get("saleMaterialId");
  1562. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  1563. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("orderPlanWeight"));
  1564. Object trucknoMaterialId = map.get("trucknoMaterialId");
  1565. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPound"));
  1566. Object materialWeight = map.get("materialWeight");
  1567. Object steelMeter = map.get("meterNumber");
  1568. Object easId = map.get("easId");
  1569. Object warehouse = map.get("warehouse");
  1570. // 销售订单分录表
  1571. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1572. // 车序号子表
  1573. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  1574. // 运输订单子表
  1575. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1576. // if (saleMaterialId != null) {
  1577. // amsSaleMaterial.setSaleMaterialId(DataChange.dataToBigDecimal(saleMaterialId));
  1578. // amsSaleTrucknoMaterial.setTrucknoMaterialId(DataChange.dataToBigDecimal(trucknoMaterialId));
  1579. // }
  1580. // if (saleMaterialId == null){
  1581. amsSaleMaterial.setSaleMaterialId(amsSaleMaterialMapper.selectMaxId());
  1582. amsSaleTrucknoMaterial.setTrucknoMaterialId(amsSaleTrucknoMaterialMapper.selectMaxId());
  1583. // }
  1584. if (easId != null) {
  1585. amsSaleMaterial.setEasPrimaryId(easId.toString());
  1586. }
  1587. if (warehouse != null) {
  1588. amsSaleMaterial.setSaleWarehouse(warehouse.toString());
  1589. }
  1590. if (steelMeter != null) {
  1591. amsSaleMaterial.setSteelMeter(DataChange.dataToBigDecimal(steelMeter));
  1592. }
  1593. if (materialWeight != null) {
  1594. amsSaleMaterial.setMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  1595. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  1596. }
  1597. amsSaleMaterial.setSaleOrderId(saleOrderId);
  1598. amsSaleMaterial.setIsPoundSale(isPoundSale);
  1599. amsSaleMaterial.setMaterialId(materialId);
  1600. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1601. amsSaleMaterial.setMaterialNumber(materialNumber);
  1602. amsSaleMaterial.setUpdateTime(new Date());
  1603. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  1604. // 车序号子表
  1605. amsSaleTrucknoMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  1606. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  1607. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  1608. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  1609. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  1610. // 运输订单子表
  1611. omstruckOrderMaterial.setOrderMaterialId(omstruckOrderMaterialMapper.selectMaxId());
  1612. omstruckOrderMaterial.setOrderId(orderId);
  1613. omstruckOrderMaterial.setMaterialId(materialId);
  1614. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  1615. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1616. }
  1617. // 得到运单中的物资
  1618. List<Map<String, Object>> newList = omstruckOrderMaterialMapper.getMaterialList(orderId);
  1619. toTmsMap.put("newMaterialMapList", newList);
  1620. // 修改实绩结果
  1621. Map<String, Object> updateResult = tmsTruckFeign.update(toTmsMap);
  1622. System.out.println(updateResult);
  1623. return result;
  1624. }
  1625. /**
  1626. * 副产品订单
  1627. * @param map
  1628. * @return
  1629. */
  1630. @Override
  1631. public List<Map<String, Object>> getFuSaleOrderList(Map<String, Object> map) {
  1632. List<Map<String, Object>> resultList = amsSaleOrderMapper.getFuSaleOrderList(map);
  1633. return resultList;
  1634. }
  1635. /**
  1636. * 同步关闭金蝶销售订单
  1637. * @param mapValue
  1638. * @return
  1639. */
  1640. @Override
  1641. public int deleteSaleOrderSame(Map<String, Object> mapValue) {
  1642. int result = 0;
  1643. BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
  1644. String reason = (String) mapValue.get("reason");
  1645. String number = (String) mapValue.get("number");
  1646. Map<String,Object> head = new HashMap<>();
  1647. Map<String,Object> input = new HashMap<>();
  1648. // 销售订单号
  1649. input.put("number",number);
  1650. Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1651. totalMap.put("input",input);
  1652. // 调用金蝶关闭接口
  1653. String json = JSONUtils.toJSONString(totalMap);
  1654. System.out.println(json);
  1655. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1656. System.out.println(resultMap);
  1657. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1658. amsSaleOrder.setSaleOrderId(saleOrderId);
  1659. amsSaleOrder.setDeleted(new BigDecimal(2));
  1660. amsSaleOrder.setInsertUpdateRemark(reason);
  1661. result += amsSaleOrderMapper.closeOrderNotIn(saleOrderId);
  1662. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1663. return result;
  1664. }
  1665. /**
  1666. * 展示反审批的钢材订单
  1667. * @param mapValue
  1668. * @return
  1669. */
  1670. @Override
  1671. public List<Map<String, Object>> getSteelOrderDeletedList(Map<String, Object> mapValue) {
  1672. List<Map<String, Object>> mapList = amsSaleOrderMapper.getSteelOrderDeletedList(mapValue);
  1673. return mapList;
  1674. }
  1675. /**
  1676. * 展示所有状态销售订单列表
  1677. * @param mapValue
  1678. * @return
  1679. */
  1680. @Override
  1681. public List<Map<String, Object>> getAllSteelSaleOrderList(Map<String, Object> mapValue) {
  1682. return amsSaleOrderMapper.getAllSteelSaleOrderList(mapValue);
  1683. }
  1684. /**
  1685. * 修改厂内未装货车辆的运单车牌号
  1686. * @param mapValue
  1687. * @return
  1688. */
  1689. @Override
  1690. public int updateCapacityNumberInFactory(Map<String, Object> mapValue) {
  1691. Object lineSequence = mapValue.get("lineSequence");
  1692. int result = 0;
  1693. //查询输入进来的车牌号是否与原有车牌号一致,如果一致则退出
  1694. BigDecimal oldCapacityId = omstruckOrderMapper.getOldCapacityId(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1695. if(oldCapacityId.compareTo(DataChange.dataToBigDecimal(mapValue.get("capacityId"))) == 0){
  1696. return 1;
  1697. }
  1698. if (lineSequence == null || "0".equals(lineSequence.toString()) || "1".equals(lineSequence.toString()) || "2".equals(lineSequence.toString())) {
  1699. String capacityids="";
  1700. Integer capacityid1= (Integer) mapValue.get("capacityIds");
  1701. Integer capacityid2= (Integer) mapValue.get("capacityId");
  1702. if (capacityid1!=null && !("".equals(capacityid1))){
  1703. capacityids=capacityid1+","+capacityid2;
  1704. }
  1705. mapValue.put("capacityids",capacityids);
  1706. //这是修改车牌号
  1707. //将排队信息删掉
  1708. Map<String, Object> isSpellingMap = omstruckOrderMapper.getSteelIsSpelling(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1709. if(isSpellingMap != null){
  1710. int isSpelling = DataChange.dataToBigDecimal(isSpellingMap.get("isSpelling")).intValue();
  1711. if(isSpelling == 1){
  1712. result += omstruckOrderMapper.deleteSpellingList(isSpellingMap.get("listId"));
  1713. }else{
  1714. result += omstruckOrderMapper.deleteQueueList(isSpellingMap.get("listId"));
  1715. }
  1716. }
  1717. result += amsSaleOrderMapper.updateCapacityNumberInFactory(mapValue);
  1718. //若是接单之后还需要删除实绩且将状态变为4
  1719. //查询运输订单的状态和总实绩ID
  1720. Map<String, Object> orderMesMap = amsSaleOrderMapper.getOrderMes(mapValue);
  1721. BigDecimal resultTotalId = DataChange.dataToBigDecimal(orderMesMap.get("resultTotalId"));
  1722. if(DataChange.dataToBigDecimal(orderMesMap.get("orderStatus")).intValue() == 5){
  1723. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1724. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1725. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1726. omstruckOrder.setOrderLineSequence(new BigDecimal(0));
  1727. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1728. result += omstruckOrderMapper.deleteEnResult(resultTotalId);
  1729. result += omstruckOrderMapper.deleteWeightResult(resultTotalId);
  1730. result += omstruckOrderMapper.deleteLoadResult(resultTotalId);
  1731. result += omstruckOrderMapper.deleteLeaveResult(resultTotalId);
  1732. }
  1733. }
  1734. return result;
  1735. }
  1736. @Override
  1737. public int updateConsigneeTel(Map<String, Object> mapValue) {
  1738. String saleOrderNo= (String) mapValue.get("saleOrderNo");
  1739. Integer saleOrderMaterialId= (Integer) mapValue.get("saleOrderMaterialId");
  1740. String consigneeTel= (String) mapValue.get("consigneeTel");
  1741. int result = 0;
  1742. if (saleOrderNo!=null&&!("".equals(saleOrderNo)) && saleOrderMaterialId!=null && !("".equals(saleOrderMaterialId))){
  1743. BigDecimal id = DataChange.dataToBigDecimal(saleOrderMaterialId);
  1744. if (id!=null&&!("".equals(id))){
  1745. result += amsSaleOrderMapper.updateForTel(id,consigneeTel);
  1746. }
  1747. }
  1748. return result;
  1749. }
  1750. @Override
  1751. public List<Map<String, Object>> getSaleMaterialId(BigDecimal saleOrderMaterialId) {
  1752. return amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1753. }
  1754. /**
  1755. * 展示下发给承运商的车序号和物资
  1756. * @param map
  1757. * @return
  1758. */
  1759. @Override
  1760. public List<Map<String, Object>> getCarrierTruckNoAndMaterialList(Map<String,Object> map) {
  1761. Object carrierSsoId = map.get("carrierSsoId");
  1762. if (carrierSsoId != null && ("".equals(carrierSsoId)) || "null".equals(carrierSsoId) || "undefined".equals(carrierSsoId)) {
  1763. map.replace("carrierSsoId",null);
  1764. }
  1765. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoAndMaterial(map);
  1766. for (Map<String,Object> mapValue : mapList) {
  1767. BigDecimal placeId = (BigDecimal) mapValue.get("placeId");
  1768. if (placeId != null) {
  1769. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  1770. mapValue.put("carrierAndPriceList", carrierAndPriceList);
  1771. }
  1772. }
  1773. return mapList;
  1774. }
  1775. /**
  1776. * 同步关闭金蝶物资分录
  1777. * @param mapValue
  1778. * @return
  1779. */
  1780. @Override
  1781. @Transactional
  1782. public int closeSteelMaterialId(Map<String, Object> mapValue) {
  1783. int result = 0;
  1784. Object orderId = mapValue.get("orderId");
  1785. Integer orderStatus = (Integer) mapValue.get("orderStatus");
  1786. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1787. List<Map<String, Object>> loadIdList = amsSaleMaterialMapper.findLoadIdList(saleOrderMaterialId);
  1788. List<Map<String, Object>> weightIdList = amsSaleMaterialMapper.findWeightIdList(saleOrderMaterialId);
  1789. String reason = (String) mapValue.get("reason");
  1790. BigDecimal saleMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleMaterialId"));
  1791. // 如果还未派车
  1792. if (orderId == null) {
  1793. // 订单子表设为关闭状态
  1794. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1795. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1796. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1797. amsSaleMaterial.setInsertUpdateRemark(reason);
  1798. result += amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1799. return result;
  1800. }
  1801. // 订单子表设为关闭状态
  1802. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1803. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1804. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1805. amsSaleMaterial.setInsertUpdateRemark(reason);
  1806. result += amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1807. // 已派车
  1808. if (loadIdList == null || loadIdList.size() == 0) {
  1809. return result;
  1810. }
  1811. // 删除实绩表
  1812. Map<String, Object> loadMap = loadIdList.get(0);
  1813. Map<String, Object> weightMap = weightIdList.get(0);
  1814. BigDecimal loadId = (BigDecimal) loadMap.get("loadId");
  1815. BigDecimal weightId = (BigDecimal) weightMap.get("weightId");
  1816. result += amsSaleMaterialMapper.updateOrderMaterialToClose(mapValue);
  1817. result += amsSaleMaterialMapper.deleteLoadResult(loadId);
  1818. result += amsSaleMaterialMapper.deleteWeightResult(weightId);
  1819. result += amsSaleMaterialMapper.deleteWmspOutResult(mapValue);
  1820. return result;
  1821. }
  1822. /**
  1823. * 展示已审核化产焦炭销售订单列表
  1824. * @param mapValue
  1825. * @return
  1826. */
  1827. @Override
  1828. public List<Map<String, Object>> getSaleCokeOrder(Map<String, Object> mapValue) {
  1829. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleCokeOrder(mapValue);
  1830. return resultList;
  1831. }
  1832. /**
  1833. * 反关闭金蝶单个分录
  1834. * @param saleMaterialId
  1835. * @return
  1836. */
  1837. @Override
  1838. public int adverseCloseSaleMaterial(BigDecimal saleMaterialId) {
  1839. Map<String,Object> head = new HashMap<>();
  1840. Map<String,Object> input = new HashMap<>();
  1841. // 0:代表不关闭整单
  1842. String wholeOrder = "0";
  1843. // unClose : 代表反关闭
  1844. String status = "unClose";
  1845. AmsSaleMaterial amsSaleMaterial = amsSaleMaterialMapper.selectByPrimaryKey(saleMaterialId);
  1846. int result = amsSaleMaterialMapper.adverseCloseSaleMaterial(saleMaterialId);
  1847. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(amsSaleMaterial.getSaleOrderId());
  1848. // 根据分录id查询运单id,物资id,总实绩id
  1849. Map<String,Object> saleMaterialMap = amsSaleOrderMapper.getSaleMaterialMessage(saleMaterialId);
  1850. BigDecimal orderId = (BigDecimal) saleMaterialMap.get("orderId");
  1851. BigDecimal orderStatus = (BigDecimal) saleMaterialMap.get("orderStatus");
  1852. if (orderId != null && orderStatus.intValue() == 5) {
  1853. BigDecimal resultTotalId = (BigDecimal) saleMaterialMap.get("resultTotalId");
  1854. BigDecimal materialId = (BigDecimal) saleMaterialMap.get("materialId");
  1855. // 根据总实绩id查询订单中的最大路段顺序号
  1856. int maxNum = amsSaleOrderMapper.findOrderMaxNum(resultTotalId);
  1857. // 得到皮重顺序号
  1858. int tareNum = maxNum - 3;
  1859. // 得到装货顺序号
  1860. int loadNum = maxNum - 2;
  1861. // 得到毛重顺序号
  1862. int grossNum = maxNum - 1;
  1863. // 装货实绩
  1864. TmstruckLoadResult tmstruckLoadResult = new TmstruckLoadResult();
  1865. TmstruckWeightResult tmstruckWeightResult = new TmstruckWeightResult();
  1866. tmstruckLoadResult.setResultId(tmstruckLoadResultMapper.selectMaxId());
  1867. tmstruckLoadResult.setResultTotalId(resultTotalId);
  1868. tmstruckLoadResult.setMaterialId(materialId);
  1869. tmstruckLoadResult.setSegmentSqe(new BigDecimal(loadNum));
  1870. result += tmstruckLoadResultMapper.insertSelective(tmstruckLoadResult);
  1871. // 计量实绩
  1872. tmstruckWeightResult.setWeightTaskResultId(tmstruckWeightResultMapper.selectMaxId());
  1873. tmstruckWeightResult.setResultTotalId(resultTotalId);
  1874. tmstruckWeightResult.setMaterialId(materialId);
  1875. tmstruckWeightResult.setResultTarePlaceId(new BigDecimal(10));
  1876. tmstruckWeightResult.setResultGrossPlaceId(new BigDecimal(2));
  1877. tmstruckWeightResult.setGrossSegmentSqe(new BigDecimal(grossNum));
  1878. tmstruckWeightResult.setTareSegmentSqe(new BigDecimal(tareNum));
  1879. result += tmstruckWeightResultMapper.insertSelective(tmstruckWeightResult);
  1880. // 出库子表
  1881. BigDecimal outBoundId = (BigDecimal) saleMaterialMap.get("outBoundId");
  1882. BigDecimal materialNumber = (BigDecimal) saleMaterialMap.get("materialNumber");
  1883. if (outBoundId != null) {
  1884. BigDecimal resultMaterialId = wmspOutboundResultMaterialMapper.getSeqNumber("seq__WMSP_OUTBOUND_RESUL_TMATRIAL");
  1885. WmspOutboundResultMaterial wmspOutboundResultMaterial = new WmspOutboundResultMaterial();
  1886. wmspOutboundResultMaterial.setResultMaterialId(resultMaterialId);
  1887. wmspOutboundResultMaterial.setOutboundResultId(outBoundId);
  1888. wmspOutboundResultMaterial.setMaterialId(materialId);
  1889. wmspOutboundResultMaterial.setMaterialNumber(materialNumber);
  1890. wmspOutboundResultMaterial.setInsertTime(new Date());
  1891. wmspOutboundResultMaterial.setInsertUsername("admin");
  1892. wmspOutboundResultMaterial.setStatus(new BigDecimal(1));
  1893. result += wmspOutboundResultMaterialMapper.insertSelective(wmspOutboundResultMaterial);
  1894. }
  1895. }
  1896. // 设置反关闭分录id
  1897. head.put("unCloseEntryId",amsSaleMaterial.getEasPrimaryId());
  1898. // 设置是否整单
  1899. head.put("wholeOrder",wholeOrder);
  1900. // 设置销售订单号
  1901. head.put("number",amsSaleOrder.getSaleNumber());
  1902. // 设置状态:unClose,反关闭;close,关闭
  1903. head.put("status",status);
  1904. input.put("head",head);
  1905. // 测试
  1906. Map<String, Object> totalMap = easUtil.getTotalMap();
  1907. // 正式
  1908. // Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1909. input.put("head",head);
  1910. totalMap.put("input",input);
  1911. // 调用金蝶关闭接口
  1912. String json = JSONUtils.toJSONString(totalMap);
  1913. System.out.println(json);
  1914. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1915. System.out.println(resultMap);
  1916. return result;
  1917. }
  1918. /**
  1919. * 反关闭金蝶整个销售订单
  1920. * @param saleOrderId
  1921. * @return
  1922. */
  1923. @Override
  1924. public int adverseCloseSaleOrder(BigDecimal saleOrderId) {
  1925. Map<String,Object> head = new HashMap<>();
  1926. Map<String,Object> input = new HashMap<>();
  1927. // 0:代表不关闭整单
  1928. String wholeOrder = "1";
  1929. // unClose : 代表反关闭
  1930. String status = "unClose";
  1931. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  1932. amsSaleOrder.setDeleted(new BigDecimal(0));
  1933. // 开启所有的分录
  1934. int result = amsSaleMaterialMapper.openAllSaleMaterial(amsSaleOrder.getSaleOrderId());
  1935. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1936. // 设置是否整单
  1937. head.put("wholeOrder",wholeOrder);
  1938. // 设置销售订单号
  1939. head.put("number",amsSaleOrder.getSaleNumber());
  1940. // 设置状态:unClose,反关闭;close,关闭
  1941. head.put("status",status);
  1942. input.put("head",head);
  1943. // 测试
  1944. Map<String, Object> totalMap = easUtil.getTotalMap();
  1945. // 正式
  1946. // Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1947. input.put("head",head);
  1948. totalMap.put("input",input);
  1949. // 调用金蝶关闭接口
  1950. String json = JSONUtils.toJSONString(totalMap);
  1951. System.out.println(json);
  1952. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1953. System.out.println(resultMap);
  1954. return result;
  1955. }
  1956. @Override
  1957. public List<Map<String, Object>> getKucunList(Map<String, Object> map) {
  1958. return amsSaleOrderMapper.getKucunList(map);
  1959. }
  1960. //反关闭
  1961. @Override
  1962. public int reverseCloseOrder(Map<String, Object> map) {
  1963. Integer isOpenEas = (Integer) map.get("isOpenEas");
  1964. String operateName = (String) map.get("operateName");
  1965. int result = 0;
  1966. // 运输订单id
  1967. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  1968. // 车序号id
  1969. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  1970. Map<String,Object> head = new HashMap<>();
  1971. Map<String,Object> input = new HashMap<>();
  1972. // 0:代表不关闭整单
  1973. String wholeOrder = "0";
  1974. // unClose : 代表反关闭
  1975. String status = "unClose";
  1976. if( orderId != null && orderId.intValue() != 0){
  1977. //根据订单id查询下面的实绩个数
  1978. int resultCount = amsSaleMaterialMapper.getOrderResults(orderId);
  1979. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1980. omstruckOrder.setOrderId(orderId);
  1981. if(resultCount == 0){
  1982. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1983. }else{
  1984. omstruckOrder.setOrderStatus(new BigDecimal(5));
  1985. }
  1986. if(operateName != null){
  1987. omstruckOrder.setOptionerCode(operateName);
  1988. }
  1989. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1990. // 根据车序号主键修改子表
  1991. amsSaleMaterialMapper.updateSaleMaterial(saleOrderMaterialId);
  1992. //查询分录ID,修改金蝶
  1993. List<Map<String,Object>> saleMaterialIdList = amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1994. for(Map<String,Object> easMap:saleMaterialIdList){
  1995. // 设置反关闭分录id
  1996. head.put("unCloseEntryId",easMap.get("closeEntryId"));
  1997. // 设置是否整单
  1998. head.put("wholeOrder",wholeOrder);
  1999. // 设置销售订单号
  2000. head.put("number",map.get("saleNumber"));
  2001. // 设置状态:unClose,反关闭;close,关闭
  2002. head.put("status",status);
  2003. input.put("head",head);
  2004. Map<String, Object> totalMap = easUtil.getTotalMap();
  2005. input.put("head",head);
  2006. totalMap.put("input",input);
  2007. // 调用金蝶关闭接口
  2008. String json = JSONUtils.toJSONString(totalMap);
  2009. System.out.println(json);
  2010. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2011. System.out.println(resultMap);
  2012. }
  2013. return 0;
  2014. }
  2015. return 1;
  2016. }
  2017. @Override
  2018. public int getSaleOrderStatus(String saleNumber) {
  2019. int result = 0;
  2020. Map<String,Object> input = new HashMap<>();
  2021. // 销售订单号
  2022. input.put("number",saleNumber);
  2023. Map<String, Object> totalMap = easSaleOrderStatusUtil.getTotalMap();
  2024. totalMap.put("input",input);
  2025. // 调用金蝶关闭接口
  2026. String json = JSONUtils.toJSONString(totalMap);
  2027. System.out.println(json);
  2028. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2029. System.out.println(resultMap);
  2030. String outPutMap = (String) resultMap.get("output");
  2031. JSONObject jsonObject = JSON.parseObject(outPutMap);
  2032. if(jsonObject != null){
  2033. result = DataChange.dataToBigDecimal(jsonObject.get("NumberStatus")).intValue();
  2034. }
  2035. if(result == 7){
  2036. //如果为7则更新
  2037. amsSaleOrderMapper.updateSaleOrderStatus(saleNumber);
  2038. }
  2039. return result;
  2040. }
  2041. }