AmsSaleOrderServiceImpl.java 102 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126
  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. if (placeIdList == null || placeIdList.size() == 0) {
  1426. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  1427. BigDecimal placeId = rmsReceivePlaceMapper.selectMaxId();
  1428. rmsReceivePlace.setPlaceId(placeId);
  1429. rmsReceivePlace.setAddressId(shippingAddressId);
  1430. rmsReceivePlace.setAddressDeliveryAddress(place);
  1431. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  1432. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  1433. addressid2 = placeId;
  1434. } else {
  1435. addressid2 =(BigDecimal) placeIdList.get(0).get("placeId");
  1436. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  1437. }
  1438. }
  1439. String addressids="";
  1440. addressids =addressid1+","+addressid2;
  1441. amsSaleOrderMaterial.setShippingAddressIds(addressids);
  1442. result += amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial);
  1443. // 需要换车
  1444. if (isNewCar != null && (Integer) isNewCar == 0) {
  1445. // 根据车序号得到定向派单表主键
  1446. BigDecimal dispatchId = amsSaleOrderMapper.getDispatchId(saleOrderMaterialId);
  1447. if (dispatchId != null) {
  1448. amsDispatchSaleOrderMapper.deleteByPrimaryKey(dispatchId);
  1449. }
  1450. if (orderId != null) {
  1451. omstruckOrderMapper.deleteByPrimaryKey(orderId);
  1452. }
  1453. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null) {
  1454. // 自动匹配承运商
  1455. List<Map<String, Object>> carrierList = getCarrierByPlace(amsSaleOrderMaterial.getSaleShippingAddressId());
  1456. // 单一承运商才进行匹配
  1457. if (carrierList != null && carrierList.size() == 1) {
  1458. List<Map<String, Object>> list = new ArrayList<>();
  1459. Map<String, Object> map1 = carrierList.get(0);
  1460. // 传入车序号主键和承运商id
  1461. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1462. map1.put("carrierId", map1.get("value"));
  1463. list.add(map1);
  1464. dispatchToCarrier(list);
  1465. }
  1466. }
  1467. }
  1468. return result;
  1469. }
  1470. /**
  1471. * 展示未匹配承运商的车序号
  1472. * @param mapValue
  1473. * @return
  1474. */
  1475. @Override
  1476. public List<Map<String, Object>> getSteelTruckNoList(Map<String, Object> mapValue) {
  1477. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSteelTruckNoList(mapValue);
  1478. return resultList;
  1479. }
  1480. /**
  1481. * 展示车序号的详情
  1482. * @param saleOrderMaterialId
  1483. * @return
  1484. */
  1485. @Override
  1486. public List<Map<String, Object>> getTruckNoMaterial(BigDecimal saleOrderMaterialId) {
  1487. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoMaterialAndCarrier(saleOrderMaterialId);
  1488. for (Map<String,Object> map : mapList) {
  1489. BigDecimal placeId = (BigDecimal) map.get("placeId");
  1490. if (placeId != null) {
  1491. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  1492. map.put("carrierAndPriceList", carrierAndPriceList);
  1493. }
  1494. }
  1495. return mapList;
  1496. }
  1497. /**
  1498. * 展示已分配承运商但未派车的车序号
  1499. * @param mapValue
  1500. * @return
  1501. */
  1502. @Override
  1503. public List<Map<String, Object>> getNoCarTruckNoList(Map<String, Object> mapValue) {
  1504. List<Map<String, Object>> resultList = amsSaleOrderMapper.getCarrierTruckNoList(mapValue);
  1505. return resultList;
  1506. }
  1507. /**
  1508. * 展示已派车的车序号
  1509. * @param mapValue
  1510. * @return
  1511. */
  1512. @Override
  1513. public List<Map<String, Object>> getHaveCarTruckNoList(Map<String, Object> mapValue) {
  1514. List<Map<String, Object>> resultList = amsSaleOrderMapper.getHaveCarTruckNoList(mapValue);
  1515. return resultList;
  1516. }
  1517. /**
  1518. * 修改销售订单中的物资
  1519. * @param mapValue
  1520. * @return
  1521. */
  1522. @Transactional(rollbackFor = Exception.class)
  1523. @Override
  1524. public int updateAllMaterialInSale(Map<String, Object> mapValue) {
  1525. int result = 0;
  1526. // 得到销售订单主键
  1527. BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
  1528. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1529. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  1530. // 将车辆改为不可作业状态
  1531. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1532. omstruckOrder.setOrderId(orderId);
  1533. omstruckOrder.setCanWork(new BigDecimal(1));
  1534. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1535. // 得到运单中的物资
  1536. List<Map<String, Object>> oldList = omstruckOrderMaterialMapper.getMaterialList(orderId);
  1537. Map<String, Object> toTmsMap = new HashMap<>();
  1538. Map<String, Object> truckNoMap = new HashMap<>();
  1539. truckNoMap.put("saleOrderMaterialId",saleOrderMaterialId);
  1540. toTmsMap.put("orderId", orderId);
  1541. toTmsMap.put("oldMaterialMapList", oldList);
  1542. // 得到所有的物资
  1543. List<Map<String, Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1544. /*
  1545. 删除三个物资表数据
  1546. */
  1547. List<AmsSaleTrucknoMaterial> amsSaleTrucknoMaterials = amsSaleTrucknoMaterialMapper.selectByParameters(truckNoMap);
  1548. for (AmsSaleTrucknoMaterial amsSaleTrucknoMaterial : amsSaleTrucknoMaterials) {
  1549. // 销售订单物资子表
  1550. amsSaleMaterialMapper.deleteByPrimaryKey(amsSaleTrucknoMaterial.getMaterialId());
  1551. // 车序号子表
  1552. amsSaleTrucknoMaterialMapper.deleteByPrimaryKey(amsSaleTrucknoMaterial.getTrucknoMaterialId());
  1553. }
  1554. // 运输订单物资子表
  1555. List<OmstruckOrderMaterial> omstruckOrderMaterials = omstruckOrderMaterialMapper.selectByParameters(toTmsMap);
  1556. for (OmstruckOrderMaterial omstruckOrderMaterial : omstruckOrderMaterials) {
  1557. omstruckOrderMaterialMapper.deleteByPrimaryKey(omstruckOrderMaterial.getOrderMaterialId());
  1558. }
  1559. /*
  1560. 重新新增三个表
  1561. */
  1562. for (Map<String, Object> map : mapList) {
  1563. Object saleMaterialId = map.get("saleMaterialId");
  1564. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  1565. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("orderPlanWeight"));
  1566. Object trucknoMaterialId = map.get("trucknoMaterialId");
  1567. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPound"));
  1568. Object materialWeight = map.get("materialWeight");
  1569. Object steelMeter = map.get("meterNumber");
  1570. Object easId = map.get("easId");
  1571. Object warehouse = map.get("warehouse");
  1572. // 销售订单分录表
  1573. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1574. // 车序号子表
  1575. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  1576. // 运输订单子表
  1577. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1578. // if (saleMaterialId != null) {
  1579. // amsSaleMaterial.setSaleMaterialId(DataChange.dataToBigDecimal(saleMaterialId));
  1580. // amsSaleTrucknoMaterial.setTrucknoMaterialId(DataChange.dataToBigDecimal(trucknoMaterialId));
  1581. // }
  1582. // if (saleMaterialId == null){
  1583. amsSaleMaterial.setSaleMaterialId(amsSaleMaterialMapper.selectMaxId());
  1584. amsSaleTrucknoMaterial.setTrucknoMaterialId(amsSaleTrucknoMaterialMapper.selectMaxId());
  1585. // }
  1586. if (easId != null) {
  1587. amsSaleMaterial.setEasPrimaryId(easId.toString());
  1588. }
  1589. if (warehouse != null) {
  1590. amsSaleMaterial.setSaleWarehouse(warehouse.toString());
  1591. }
  1592. if (steelMeter != null) {
  1593. amsSaleMaterial.setSteelMeter(DataChange.dataToBigDecimal(steelMeter));
  1594. }
  1595. if (materialWeight != null) {
  1596. amsSaleMaterial.setMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  1597. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  1598. }
  1599. amsSaleMaterial.setSaleOrderId(saleOrderId);
  1600. amsSaleMaterial.setIsPoundSale(isPoundSale);
  1601. amsSaleMaterial.setMaterialId(materialId);
  1602. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1603. amsSaleMaterial.setMaterialNumber(materialNumber);
  1604. amsSaleMaterial.setUpdateTime(new Date());
  1605. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  1606. // 车序号子表
  1607. amsSaleTrucknoMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  1608. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  1609. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  1610. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  1611. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  1612. // 运输订单子表
  1613. omstruckOrderMaterial.setOrderMaterialId(omstruckOrderMaterialMapper.selectMaxId());
  1614. omstruckOrderMaterial.setOrderId(orderId);
  1615. omstruckOrderMaterial.setMaterialId(materialId);
  1616. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  1617. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1618. }
  1619. // 得到运单中的物资
  1620. List<Map<String, Object>> newList = omstruckOrderMaterialMapper.getMaterialList(orderId);
  1621. toTmsMap.put("newMaterialMapList", newList);
  1622. // 修改实绩结果
  1623. Map<String, Object> updateResult = tmsTruckFeign.update(toTmsMap);
  1624. System.out.println(updateResult);
  1625. return result;
  1626. }
  1627. /**
  1628. * 副产品订单
  1629. * @param map
  1630. * @return
  1631. */
  1632. @Override
  1633. public List<Map<String, Object>> getFuSaleOrderList(Map<String, Object> map) {
  1634. List<Map<String, Object>> resultList = amsSaleOrderMapper.getFuSaleOrderList(map);
  1635. return resultList;
  1636. }
  1637. /**
  1638. * 同步关闭金蝶销售订单
  1639. * @param mapValue
  1640. * @return
  1641. */
  1642. @Override
  1643. public int deleteSaleOrderSame(Map<String, Object> mapValue) {
  1644. int result = 0;
  1645. BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
  1646. String reason = (String) mapValue.get("reason");
  1647. String number = (String) mapValue.get("number");
  1648. Map<String,Object> head = new HashMap<>();
  1649. Map<String,Object> input = new HashMap<>();
  1650. // 销售订单号
  1651. input.put("number",number);
  1652. Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1653. totalMap.put("input",input);
  1654. // 调用金蝶关闭接口
  1655. String json = JSONUtils.toJSONString(totalMap);
  1656. System.out.println(json);
  1657. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1658. System.out.println(resultMap);
  1659. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1660. amsSaleOrder.setSaleOrderId(saleOrderId);
  1661. amsSaleOrder.setDeleted(new BigDecimal(2));
  1662. amsSaleOrder.setInsertUpdateRemark(reason);
  1663. result += amsSaleOrderMapper.closeOrderNotIn(saleOrderId);
  1664. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1665. return result;
  1666. }
  1667. /**
  1668. * 展示反审批的钢材订单
  1669. * @param mapValue
  1670. * @return
  1671. */
  1672. @Override
  1673. public List<Map<String, Object>> getSteelOrderDeletedList(Map<String, Object> mapValue) {
  1674. List<Map<String, Object>> mapList = amsSaleOrderMapper.getSteelOrderDeletedList(mapValue);
  1675. return mapList;
  1676. }
  1677. /**
  1678. * 展示所有状态销售订单列表
  1679. * @param mapValue
  1680. * @return
  1681. */
  1682. @Override
  1683. public List<Map<String, Object>> getAllSteelSaleOrderList(Map<String, Object> mapValue) {
  1684. return amsSaleOrderMapper.getAllSteelSaleOrderList(mapValue);
  1685. }
  1686. /**
  1687. * 修改厂内未装货车辆的运单车牌号
  1688. * @param mapValue
  1689. * @return
  1690. */
  1691. @Override
  1692. public int updateCapacityNumberInFactory(Map<String, Object> mapValue) {
  1693. Object lineSequence = mapValue.get("lineSequence");
  1694. int result = 0;
  1695. //查询输入进来的车牌号是否与原有车牌号一致,如果一致则退出
  1696. BigDecimal oldCapacityId = omstruckOrderMapper.getOldCapacityId(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1697. if(oldCapacityId.compareTo(DataChange.dataToBigDecimal(mapValue.get("capacityId"))) == 0){
  1698. return 1;
  1699. }
  1700. if (lineSequence == null || "0".equals(lineSequence.toString()) || "1".equals(lineSequence.toString()) || "2".equals(lineSequence.toString())) {
  1701. String capacityids="";
  1702. Integer capacityid1= (Integer) mapValue.get("capacityIds");
  1703. Integer capacityid2= (Integer) mapValue.get("capacityId");
  1704. if (capacityid1!=null && !("".equals(capacityid1))){
  1705. capacityids=capacityid1+","+capacityid2;
  1706. }
  1707. mapValue.put("capacityids",capacityids);
  1708. //这是修改车牌号
  1709. //将排队信息删掉
  1710. Map<String, Object> isSpellingMap = omstruckOrderMapper.getSteelIsSpelling(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1711. if(isSpellingMap != null){
  1712. int isSpelling = DataChange.dataToBigDecimal(isSpellingMap.get("isSpelling")).intValue();
  1713. if(isSpelling == 1){
  1714. result += omstruckOrderMapper.deleteSpellingList(isSpellingMap.get("listId"));
  1715. }else{
  1716. result += omstruckOrderMapper.deleteQueueList(isSpellingMap.get("listId"));
  1717. }
  1718. }
  1719. result += amsSaleOrderMapper.updateCapacityNumberInFactory(mapValue);
  1720. //若是接单之后还需要删除实绩且将状态变为4
  1721. //查询运输订单的状态和总实绩ID
  1722. Map<String, Object> orderMesMap = amsSaleOrderMapper.getOrderMes(mapValue);
  1723. BigDecimal resultTotalId = DataChange.dataToBigDecimal(orderMesMap.get("resultTotalId"));
  1724. if(DataChange.dataToBigDecimal(orderMesMap.get("orderStatus")).intValue() == 5){
  1725. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1726. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1727. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1728. omstruckOrder.setOrderLineSequence(new BigDecimal(0));
  1729. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1730. result += omstruckOrderMapper.deleteEnResult(resultTotalId);
  1731. result += omstruckOrderMapper.deleteWeightResult(resultTotalId);
  1732. result += omstruckOrderMapper.deleteLoadResult(resultTotalId);
  1733. result += omstruckOrderMapper.deleteLeaveResult(resultTotalId);
  1734. }
  1735. }
  1736. return result;
  1737. }
  1738. @Override
  1739. public int updateConsigneeTel(Map<String, Object> mapValue) {
  1740. String saleOrderNo= (String) mapValue.get("saleOrderNo");
  1741. Integer saleOrderMaterialId= (Integer) mapValue.get("saleOrderMaterialId");
  1742. String consigneeTel= (String) mapValue.get("consigneeTel");
  1743. int result = 0;
  1744. if (saleOrderNo!=null&&!("".equals(saleOrderNo)) && saleOrderMaterialId!=null && !("".equals(saleOrderMaterialId))){
  1745. BigDecimal id = DataChange.dataToBigDecimal(saleOrderMaterialId);
  1746. if (id!=null&&!("".equals(id))){
  1747. result += amsSaleOrderMapper.updateForTel(id,consigneeTel);
  1748. }
  1749. }
  1750. return result;
  1751. }
  1752. @Override
  1753. public List<Map<String, Object>> getSaleMaterialId(BigDecimal saleOrderMaterialId) {
  1754. return amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1755. }
  1756. /**
  1757. * 展示下发给承运商的车序号和物资
  1758. * @param map
  1759. * @return
  1760. */
  1761. @Override
  1762. public List<Map<String, Object>> getCarrierTruckNoAndMaterialList(Map<String,Object> map) {
  1763. Object carrierSsoId = map.get("carrierSsoId");
  1764. if (carrierSsoId != null && ("".equals(carrierSsoId)) || "null".equals(carrierSsoId) || "undefined".equals(carrierSsoId)) {
  1765. map.replace("carrierSsoId",null);
  1766. }
  1767. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoAndMaterial(map);
  1768. for (Map<String,Object> mapValue : mapList) {
  1769. BigDecimal placeId = (BigDecimal) mapValue.get("placeId");
  1770. if (placeId != null) {
  1771. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  1772. mapValue.put("carrierAndPriceList", carrierAndPriceList);
  1773. }
  1774. }
  1775. return mapList;
  1776. }
  1777. /**
  1778. * 同步关闭金蝶物资分录
  1779. * @param mapValue
  1780. * @return
  1781. */
  1782. @Override
  1783. @Transactional
  1784. public int closeSteelMaterialId(Map<String, Object> mapValue) {
  1785. int result = 0;
  1786. Object orderId = mapValue.get("orderId");
  1787. Integer orderStatus = (Integer) mapValue.get("orderStatus");
  1788. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1789. List<Map<String, Object>> loadIdList = amsSaleMaterialMapper.findLoadIdList(saleOrderMaterialId);
  1790. List<Map<String, Object>> weightIdList = amsSaleMaterialMapper.findWeightIdList(saleOrderMaterialId);
  1791. String reason = (String) mapValue.get("reason");
  1792. BigDecimal saleMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleMaterialId"));
  1793. // 如果还未派车
  1794. if (orderId == null) {
  1795. // 订单子表设为关闭状态
  1796. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1797. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1798. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1799. amsSaleMaterial.setInsertUpdateRemark(reason);
  1800. result += amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1801. return result;
  1802. }
  1803. // 订单子表设为关闭状态
  1804. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1805. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1806. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1807. amsSaleMaterial.setInsertUpdateRemark(reason);
  1808. result += amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1809. // 已派车
  1810. if (loadIdList == null || loadIdList.size() == 0) {
  1811. return result;
  1812. }
  1813. // 删除实绩表
  1814. Map<String, Object> loadMap = loadIdList.get(0);
  1815. Map<String, Object> weightMap = weightIdList.get(0);
  1816. BigDecimal loadId = (BigDecimal) loadMap.get("loadId");
  1817. BigDecimal weightId = (BigDecimal) weightMap.get("weightId");
  1818. result += amsSaleMaterialMapper.updateOrderMaterialToClose(mapValue);
  1819. result += amsSaleMaterialMapper.deleteLoadResult(loadId);
  1820. result += amsSaleMaterialMapper.deleteWeightResult(weightId);
  1821. result += amsSaleMaterialMapper.deleteWmspOutResult(mapValue);
  1822. return result;
  1823. }
  1824. /**
  1825. * 展示已审核化产焦炭销售订单列表
  1826. * @param mapValue
  1827. * @return
  1828. */
  1829. @Override
  1830. public List<Map<String, Object>> getSaleCokeOrder(Map<String, Object> mapValue) {
  1831. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleCokeOrder(mapValue);
  1832. return resultList;
  1833. }
  1834. /**
  1835. * 反关闭金蝶单个分录
  1836. * @param saleMaterialId
  1837. * @return
  1838. */
  1839. @Override
  1840. public int adverseCloseSaleMaterial(BigDecimal saleMaterialId) {
  1841. Map<String,Object> head = new HashMap<>();
  1842. Map<String,Object> input = new HashMap<>();
  1843. // 0:代表不关闭整单
  1844. String wholeOrder = "0";
  1845. // unClose : 代表反关闭
  1846. String status = "unClose";
  1847. AmsSaleMaterial amsSaleMaterial = amsSaleMaterialMapper.selectByPrimaryKey(saleMaterialId);
  1848. int result = amsSaleMaterialMapper.adverseCloseSaleMaterial(saleMaterialId);
  1849. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(amsSaleMaterial.getSaleOrderId());
  1850. // 根据分录id查询运单id,物资id,总实绩id
  1851. Map<String,Object> saleMaterialMap = amsSaleOrderMapper.getSaleMaterialMessage(saleMaterialId);
  1852. BigDecimal orderId = (BigDecimal) saleMaterialMap.get("orderId");
  1853. BigDecimal orderStatus = (BigDecimal) saleMaterialMap.get("orderStatus");
  1854. if (orderId != null && orderStatus.intValue() == 5) {
  1855. BigDecimal resultTotalId = (BigDecimal) saleMaterialMap.get("resultTotalId");
  1856. BigDecimal materialId = (BigDecimal) saleMaterialMap.get("materialId");
  1857. // 根据总实绩id查询订单中的最大路段顺序号
  1858. int maxNum = amsSaleOrderMapper.findOrderMaxNum(resultTotalId);
  1859. // 得到皮重顺序号
  1860. int tareNum = maxNum - 3;
  1861. // 得到装货顺序号
  1862. int loadNum = maxNum - 2;
  1863. // 得到毛重顺序号
  1864. int grossNum = maxNum - 1;
  1865. // 装货实绩
  1866. TmstruckLoadResult tmstruckLoadResult = new TmstruckLoadResult();
  1867. TmstruckWeightResult tmstruckWeightResult = new TmstruckWeightResult();
  1868. tmstruckLoadResult.setResultId(tmstruckLoadResultMapper.selectMaxId());
  1869. tmstruckLoadResult.setResultTotalId(resultTotalId);
  1870. tmstruckLoadResult.setMaterialId(materialId);
  1871. tmstruckLoadResult.setSegmentSqe(new BigDecimal(loadNum));
  1872. result += tmstruckLoadResultMapper.insertSelective(tmstruckLoadResult);
  1873. // 计量实绩
  1874. tmstruckWeightResult.setWeightTaskResultId(tmstruckWeightResultMapper.selectMaxId());
  1875. tmstruckWeightResult.setResultTotalId(resultTotalId);
  1876. tmstruckWeightResult.setMaterialId(materialId);
  1877. tmstruckWeightResult.setResultTarePlaceId(new BigDecimal(10));
  1878. tmstruckWeightResult.setResultGrossPlaceId(new BigDecimal(2));
  1879. tmstruckWeightResult.setGrossSegmentSqe(new BigDecimal(grossNum));
  1880. tmstruckWeightResult.setTareSegmentSqe(new BigDecimal(tareNum));
  1881. result += tmstruckWeightResultMapper.insertSelective(tmstruckWeightResult);
  1882. // 出库子表
  1883. BigDecimal outBoundId = (BigDecimal) saleMaterialMap.get("outBoundId");
  1884. BigDecimal materialNumber = (BigDecimal) saleMaterialMap.get("materialNumber");
  1885. if (outBoundId != null) {
  1886. BigDecimal resultMaterialId = wmspOutboundResultMaterialMapper.getSeqNumber("seq__WMSP_OUTBOUND_RESUL_TMATRIAL");
  1887. WmspOutboundResultMaterial wmspOutboundResultMaterial = new WmspOutboundResultMaterial();
  1888. wmspOutboundResultMaterial.setResultMaterialId(resultMaterialId);
  1889. wmspOutboundResultMaterial.setOutboundResultId(outBoundId);
  1890. wmspOutboundResultMaterial.setMaterialId(materialId);
  1891. wmspOutboundResultMaterial.setMaterialNumber(materialNumber);
  1892. wmspOutboundResultMaterial.setInsertTime(new Date());
  1893. wmspOutboundResultMaterial.setInsertUsername("admin");
  1894. wmspOutboundResultMaterial.setStatus(new BigDecimal(1));
  1895. result += wmspOutboundResultMaterialMapper.insertSelective(wmspOutboundResultMaterial);
  1896. }
  1897. }
  1898. // 设置反关闭分录id
  1899. head.put("unCloseEntryId",amsSaleMaterial.getEasPrimaryId());
  1900. // 设置是否整单
  1901. head.put("wholeOrder",wholeOrder);
  1902. // 设置销售订单号
  1903. head.put("number",amsSaleOrder.getSaleNumber());
  1904. // 设置状态:unClose,反关闭;close,关闭
  1905. head.put("status",status);
  1906. input.put("head",head);
  1907. // 测试
  1908. Map<String, Object> totalMap = easUtil.getTotalMap();
  1909. // 正式
  1910. // Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1911. input.put("head",head);
  1912. totalMap.put("input",input);
  1913. // 调用金蝶关闭接口
  1914. String json = JSONUtils.toJSONString(totalMap);
  1915. System.out.println(json);
  1916. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1917. System.out.println(resultMap);
  1918. return result;
  1919. }
  1920. /**
  1921. * 反关闭金蝶整个销售订单
  1922. * @param saleOrderId
  1923. * @return
  1924. */
  1925. @Override
  1926. public int adverseCloseSaleOrder(BigDecimal saleOrderId) {
  1927. Map<String,Object> head = new HashMap<>();
  1928. Map<String,Object> input = new HashMap<>();
  1929. // 0:代表不关闭整单
  1930. String wholeOrder = "1";
  1931. // unClose : 代表反关闭
  1932. String status = "unClose";
  1933. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  1934. amsSaleOrder.setDeleted(new BigDecimal(0));
  1935. // 开启所有的分录
  1936. int result = amsSaleMaterialMapper.openAllSaleMaterial(amsSaleOrder.getSaleOrderId());
  1937. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1938. // 设置是否整单
  1939. head.put("wholeOrder",wholeOrder);
  1940. // 设置销售订单号
  1941. head.put("number",amsSaleOrder.getSaleNumber());
  1942. // 设置状态:unClose,反关闭;close,关闭
  1943. head.put("status",status);
  1944. input.put("head",head);
  1945. // 测试
  1946. Map<String, Object> totalMap = easUtil.getTotalMap();
  1947. // 正式
  1948. // Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1949. input.put("head",head);
  1950. totalMap.put("input",input);
  1951. // 调用金蝶关闭接口
  1952. String json = JSONUtils.toJSONString(totalMap);
  1953. System.out.println(json);
  1954. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1955. System.out.println(resultMap);
  1956. return result;
  1957. }
  1958. @Override
  1959. public List<Map<String, Object>> getKucunList(Map<String, Object> map) {
  1960. return amsSaleOrderMapper.getKucunList(map);
  1961. }
  1962. //反关闭
  1963. @Override
  1964. public int reverseCloseOrder(Map<String, Object> map) {
  1965. Integer isOpenEas = (Integer) map.get("isOpenEas");
  1966. String operateName = (String) map.get("operateName");
  1967. int result = 0;
  1968. // 运输订单id
  1969. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  1970. // 车序号id
  1971. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  1972. Map<String,Object> head = new HashMap<>();
  1973. Map<String,Object> input = new HashMap<>();
  1974. // 0:代表不关闭整单
  1975. String wholeOrder = "0";
  1976. // unClose : 代表反关闭
  1977. String status = "unClose";
  1978. if( orderId != null && orderId.intValue() != 0){
  1979. //根据订单id查询下面的实绩个数
  1980. int resultCount = amsSaleMaterialMapper.getOrderResults(orderId);
  1981. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1982. omstruckOrder.setOrderId(orderId);
  1983. if(resultCount == 0){
  1984. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1985. }else{
  1986. omstruckOrder.setOrderStatus(new BigDecimal(5));
  1987. }
  1988. if(operateName != null){
  1989. omstruckOrder.setOptionerCode(operateName);
  1990. }
  1991. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1992. // 根据车序号主键修改子表
  1993. amsSaleMaterialMapper.updateSaleMaterial(saleOrderMaterialId);
  1994. //查询分录ID,修改金蝶
  1995. List<Map<String,Object>> saleMaterialIdList = amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1996. for(Map<String,Object> easMap:saleMaterialIdList){
  1997. // 设置反关闭分录id
  1998. head.put("unCloseEntryId",easMap.get("closeEntryId"));
  1999. // 设置是否整单
  2000. head.put("wholeOrder",wholeOrder);
  2001. // 设置销售订单号
  2002. head.put("number",map.get("saleNumber"));
  2003. // 设置状态:unClose,反关闭;close,关闭
  2004. head.put("status",status);
  2005. input.put("head",head);
  2006. Map<String, Object> totalMap = easUtil.getTotalMap();
  2007. input.put("head",head);
  2008. totalMap.put("input",input);
  2009. // 调用金蝶关闭接口
  2010. String json = JSONUtils.toJSONString(totalMap);
  2011. System.out.println(json);
  2012. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2013. System.out.println(resultMap);
  2014. }
  2015. return 0;
  2016. }
  2017. return 1;
  2018. }
  2019. @Override
  2020. public int getSaleOrderStatus(String saleNumber) {
  2021. int result = 0;
  2022. Map<String,Object> input = new HashMap<>();
  2023. // 销售订单号
  2024. input.put("number",saleNumber);
  2025. Map<String, Object> totalMap = easSaleOrderStatusUtil.getTotalMap();
  2026. totalMap.put("input",input);
  2027. // 调用金蝶关闭接口
  2028. String json = JSONUtils.toJSONString(totalMap);
  2029. System.out.println(json);
  2030. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2031. System.out.println(resultMap);
  2032. String outPutMap = (String) resultMap.get("output");
  2033. JSONObject jsonObject = JSON.parseObject(outPutMap);
  2034. if(jsonObject != null){
  2035. result = DataChange.dataToBigDecimal(jsonObject.get("NumberStatus")).intValue();
  2036. }
  2037. if(result == 7){
  2038. //如果为7则更新
  2039. amsSaleOrderMapper.updateSaleOrderStatus(saleNumber);
  2040. }
  2041. return result;
  2042. }
  2043. }