AmsSaleOrderServiceImpl.java 112 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327
  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. //如果前端传输过来的销售订单id不是空,则改变为已上传
  502. if (mapValue.get("saleOrderId") != null) {
  503. //先判断该销售订单有没有被上传,如果传了则不允许重复上传
  504. int count = amsSaleOrderMaterialMapper.selectSaleOrderIdIsUpload(DataChange.dataToBigDecimal(mapValue.get("saleOrderId")));
  505. if(count != 0) {
  506. return 0;
  507. }
  508. amsSaleOrderMapper.updateOldSaleOrderUpload(DataChange.dataToBigDecimal(mapValue.get("saleOrderId")));
  509. }
  510. // 得到发货单位
  511. BigDecimal shipperId = DataChange.dataToBigDecimal(mapValue.get("shipperId"));
  512. // 收货单位
  513. BigDecimal receiveId = DataChange.dataToBigDecimal(mapValue.get("receiveId"));
  514. if (receiveId == null || receiveId.intValue() == 0) {
  515. receiveId = amsSaleOrderMapper.findReceiveId(mapValue.get("receiveName"));
  516. if (receiveId == null) {
  517. throw new RuntimeException("您输入的下单客户:" + mapValue.get("receiveName") + "不存在!!");
  518. }else {
  519. //判断该收货客户有没有绑定片区
  520. BigDecimal saleAreaId = amsSaleOrderMapper.selectSaleAreaId(receiveId);
  521. if(saleAreaId == null){
  522. //如果片区为null,则绑定片区
  523. //根据片区名称去查找片区ID
  524. if(mapValue.get("saleArea") != null){
  525. String saleAreaName = (String) mapValue.get("saleArea");
  526. saleAreaId = amsSaleOrderMapper.selectSaleAreaIdByName(saleAreaName);
  527. if(saleAreaId == null){
  528. throw new Exception("您输入的销售片区:" + mapValue.get("saleArea") +"不存在!!");
  529. }else{
  530. //更新收货客户下的销售片区
  531. amsSaleOrderMapper.bindSaleArea(receiveId,saleAreaId);
  532. }
  533. }
  534. }
  535. }
  536. }
  537. // 是否自提
  538. String isSelfMention = (String) mapValue.get("isSelfMention");
  539. // 备注
  540. String saleRemark = (String) mapValue.get("saleRemark");
  541. // 收款客户
  542. String saleOrderReceiveCustomer = (String) mapValue.get("saleOrderReceiveCustomer");
  543. // 业务员
  544. BigDecimal salerId = DataChange.dataToBigDecimal(mapValue.get("salerId"));
  545. if (salerId == null || salerId.intValue() == 0) {
  546. salerId = amsSaleOrderMapper.findSalerId(mapValue.get("salerName"));
  547. if (salerId == null) {
  548. throw new Exception("您输入的业务员:" + mapValue.get("salerName") +"不存在!!");
  549. }
  550. }
  551. BigDecimal saleOrderId = amsSaleOrderMapper.selectMaxId();
  552. int result = 0;
  553. // 销售订单
  554. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  555. amsSaleOrder.setReceiveId(receiveId);
  556. amsSaleOrder.setSaleRemark(saleRemark == null ? "":saleRemark);
  557. amsSaleOrder.setShipperId(shipperId);
  558. amsSaleOrder.setSaleOrderIsselfMention(isSelfMention);
  559. amsSaleOrder.setSaleOrderId(saleOrderId);
  560. amsSaleOrder.setSalerId(salerId);
  561. // 设置钢材订单
  562. amsSaleOrder.setSaleType(new BigDecimal(1));
  563. amsSaleOrder.setSaleNumber(DataChange.generateEightDigitsNumber("WXSDD",saleOrderId.intValue(),"-"));
  564. amsSaleOrder.setInsertTime(new Date());
  565. amsSaleOrder.setInsertUpdateRemark("物流新增销售订单");
  566. amsSaleOrder.setInsertUsername("物流");
  567. amsSaleOrder.setUpdateTime(new Date());
  568. amsSaleOrder.setDeleted(new BigDecimal(0));
  569. amsSaleOrder.setSaleOrderStatus(new BigDecimal(0));
  570. // 税率默认13%
  571. amsSaleOrder.setSaleOrderTax("13%");
  572. // 含税单价某人4000
  573. amsSaleOrder.setSaleUnitPrice(new BigDecimal(4000));
  574. // 收款客户
  575. amsSaleOrder.setSaleOrderReceiveCustomer(saleOrderReceiveCustomer);
  576. // 销售订单物资表
  577. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  578. // 车序号物资表
  579. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  580. // 遍历每一行
  581. for (Map<String, Object> map : mapList) {
  582. /*
  583. 车序号表
  584. */
  585. // 得到车序号
  586. BigDecimal truckNo = DataChange.dataToBigDecimal(map.get("truckNo"));
  587. Map<String,Object> saleMap = new HashMap<>();
  588. saleMap.put("saleOrderId",saleOrderId);
  589. saleMap.put("saleOrderMaterialTruckNo",truckNo);
  590. // 检测销售订单下的车序号是否已存在
  591. List<AmsSaleOrderMaterial> amsSaleOrderMaterials = amsSaleOrderMaterialMapper.selectByParameters(saleMap);
  592. // 车序号表
  593. AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  594. if (amsSaleOrderMaterials == null || amsSaleOrderMaterials.size() == 0) {
  595. // 车序号主键
  596. BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
  597. BigDecimal shippingAddressId = DataChange.dataToBigDecimal(map.get("shipperAddressId"));
  598. if (shippingAddressId == null || shippingAddressId.intValue() == 0) {
  599. String province = (String) map.get("province");
  600. String district = (String) map.get("district");
  601. String town = (String) map.get("town");
  602. Map<String,Object> addressMap = new HashMap<>();
  603. addressMap.put("province",province);
  604. addressMap.put("district",district);
  605. addressMap.put("town",town);
  606. shippingAddressId = amsSaleOrderMapper.findAddressId(addressMap);
  607. if (shippingAddressId == null) {
  608. throw new Exception("您输入的:" + province + district + town + "地址不存在!!");
  609. }
  610. }
  611. // 车号备注
  612. String truckRemark = (String) (map.get("truckRemark"));
  613. String place = (String) (map.get("place"));
  614. if (place != null && !"null".equals(place)) {
  615. List<Map<String, Object>> placeIdList = amsSaleOrderMaterialMapper.getPlaceId(place,shippingAddressId);
  616. if (placeIdList == null || placeIdList.size() == 0) {
  617. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  618. rmsReceivePlace.setPlaceId(rmsReceivePlaceMapper.selectMaxId());
  619. rmsReceivePlace.setAddressId(shippingAddressId);
  620. rmsReceivePlace.setAddressDeliveryAddress(place);
  621. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  622. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  623. } else {
  624. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  625. }
  626. }
  627. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null && isSelfMention.equals("否")) {
  628. // 自动匹配承运商
  629. List<Map<String, Object>> carrierList = getCarrierByAddress(amsSaleOrderMaterial.getSaleShippingAddressId());
  630. BigDecimal carrierCount = null;
  631. if(place != null && !"null".equals(place)){
  632. carrierCount = amsSaleOrderMapper.getMoreCarrier(place);
  633. }
  634. // 单一承运商才进行匹配
  635. if (carrierList != null && carrierList.size() == 1 && carrierList.get(0) != null && carrierCount.intValue() == 0) {
  636. List<Map<String, Object>> list = new ArrayList<>();
  637. Map<String, Object> map1 = carrierList.get(0);
  638. // 传入车序号主键和承运商id
  639. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  640. list.add(map1);
  641. dispatchToCarrier(list);
  642. }
  643. }
  644. if (isSelfMention.equals("是")) {
  645. // 根据收货单位id查询出收货单位名称
  646. String consigneeName = amsSaleOrderMapper.selectConsigneeName(receiveId);
  647. // 根据收货单位名称查询承运商id
  648. BigDecimal carrierId = amsSaleOrderMapper.selectCarrierId(consigneeName);
  649. List<Map<String, Object>> list = new ArrayList<>();
  650. Map<String,Object> map1 = new HashMap<>();
  651. // 传入车序号主键和承运商id
  652. if (carrierId != null) {
  653. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  654. map1.put("carrierId", carrierId);
  655. list.add(map1);
  656. dispatchToCarrier(list);
  657. }
  658. }
  659. // 收货方姓名
  660. String consigneeName = String.valueOf(map.get("saleOrderConsignee"));
  661. // 收货方电话
  662. String consigneeTel = String.valueOf(map.get("saleOrderConsigneeTel"));
  663. // 截止日期
  664. String dateOfReceiptStr = String.valueOf(map.get("saleDateOfReceipt"));
  665. Date dateOfReceipt = null;
  666. if (!"null".equals(dateOfReceiptStr) && !"undefined".equals(dateOfReceiptStr)) {
  667. dateOfReceipt = new Date(Long.valueOf(dateOfReceiptStr));
  668. }
  669. amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  670. amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
  671. amsSaleOrderMaterial.setTruckRemark(truckRemark);
  672. amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(truckNo);
  673. if(map.get("orderNo") != null) {
  674. amsSaleOrderMaterial.setPreviousOrderNumber((String) map.get("orderNo"));
  675. }
  676. if (consigneeName != null && !consigneeName.equals("null")) {
  677. amsSaleOrderMaterial.setSaleOrderConsignee(consigneeName);
  678. }
  679. if (consigneeTel != null && !consigneeTel.equals("null")) {
  680. amsSaleOrderMaterial.setSaleOrderConsigneeTel(consigneeTel);
  681. }
  682. amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
  683. amsSaleOrderMaterial.setInsertTime(new Date());
  684. amsSaleOrderMaterial.setUpdateTime(new Date());
  685. amsSaleOrderMaterial.setInsertUpdateRemark("物流新增");
  686. result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
  687. }
  688. else {
  689. amsSaleOrderMaterial = amsSaleOrderMaterials.get(0);
  690. }
  691. /*
  692. 销售订单物资表
  693. */
  694. // 物资
  695. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  696. if (materialId == null || materialId.intValue() == 0) {
  697. String name = (String) map.get("materialName");
  698. String specification = (String) map.get("materialSpecification");
  699. String model = (String) map.get("materialModel");
  700. Map<String,Object> materialMap = new HashMap<>();
  701. materialMap.put("name",name);
  702. materialMap.put("specification",specification);
  703. if (model == null || model.equals("") || model.equals("null")) {
  704. model = null;
  705. }
  706. materialMap.put("model",model);
  707. materialId = amsSaleOrderMapper.findMaterialId(materialMap);
  708. if (materialId == null) {
  709. throw new Exception("您输入的物资:" + name + specification + model + "不存在!!");
  710. }
  711. }
  712. Integer materialCount = amsSaleMaterialMapper.getMaterialCount(materialId);
  713. RmsMaterial rmsMaterial = new RmsMaterial();
  714. rmsMaterial.setMaterialId(materialId);
  715. if (materialCount == null) {
  716. materialCount = new Integer(0);
  717. }
  718. rmsMaterial.setMaterialCount(new BigDecimal(materialCount + 1));
  719. rmsMaterialMapper.updateByPrimaryKeySelective(rmsMaterial);
  720. // 物资件数
  721. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("materialNumber"));
  722. // 物资名称
  723. Object materialName = map.get("materialName");
  724. // 钢材米数
  725. BigDecimal steelMeters = DataChange.dataToBigDecimal(map.get("steelMeters"));
  726. // 判断物资是否是盘螺或盘元/盘圆
  727. if (materialName != null && (materialName.toString().contains("盘螺") || materialName.toString().contains("盘元") || materialName.toString().contains("盘圆"))) {
  728. amsSaleMaterial.setSteelMeter(null);
  729. }
  730. else {
  731. amsSaleMaterial.setSteelMeter(steelMeters);
  732. }
  733. // 是否磅重销售(0:磅重;1:理重)
  734. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPoundSale"));
  735. // 销售订单物资表主键
  736. BigDecimal saleMaterialId = amsSaleMaterialMapper.selectMaxId();
  737. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  738. amsSaleMaterial.setSaleOrderId(saleOrderId);
  739. amsSaleMaterial.setMaterialId(materialId);
  740. amsSaleMaterial.setMaterialNumber(materialNumber);
  741. amsSaleMaterial.setInsertTime(new Date());
  742. amsSaleMaterial.setUpdateTime(new Date());
  743. amsSaleMaterial.setIsPoundSale(isPoundSale);
  744. amsSaleMaterial.setInsertUpdateRemark("物流新增");
  745. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  746. /*
  747. 车序号物资表
  748. */
  749. // 车序号物资表主键
  750. BigDecimal truckNoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
  751. amsSaleTrucknoMaterial.setTrucknoMaterialId(truckNoMaterialId);
  752. amsSaleTrucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  753. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  754. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  755. amsSaleTrucknoMaterial.setInsertTime(new Date());
  756. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  757. amsSaleTrucknoMaterial.setInsertUpdateRemark("物流新增");
  758. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  759. }
  760. result += amsSaleOrderMapper.insertSelective(amsSaleOrder);
  761. return saleOrderId.intValue();
  762. }
  763. /**
  764. * 展示销售订单下的车序号和物资
  765. * @param saleOrderId
  766. * @return
  767. */
  768. @Override
  769. public List<Map<String, Object>> getTruckNoAndMaterialList(BigDecimal saleOrderId) {
  770. HashMap<String,Object> mapValue = new HashMap<>();
  771. mapValue.put("saleOrderId",saleOrderId);
  772. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoAndMaterial(mapValue);
  773. for (Map<String,Object> map : mapList) {
  774. BigDecimal placeId = (BigDecimal) map.get("placeId");
  775. if (placeId != null) {
  776. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  777. map.put("carrierAndPriceList", carrierAndPriceList);
  778. }
  779. }
  780. return mapList;
  781. }
  782. /**
  783. * 销售钢材派车
  784. * @param mapList
  785. * @return
  786. */
  787. @Transactional(rollbackFor = Exception.class)
  788. @Override
  789. public int dispatchSteelOrder(List<Map<String, Object>> mapList) throws Exception {
  790. Map<String, Object> stringObjectMap = mapList.get(0);
  791. Integer isCheckGps = amsSaleOrderMapper.getDispachSwitch();
  792. Integer saleStatus = amsSaleOrderMapper.findStatus(DataChange.dataToBigDecimal(stringObjectMap.get("saleOrderMaterialId")));
  793. String selfMention = amsSaleOrderMapper.findSelfMention(DataChange.dataToBigDecimal(stringObjectMap.get("saleOrderMaterialId")));
  794. //如果这个车序号下面有运单,则证明已经派了
  795. Map<String,Object> orderMap = amsSaleOrderMapper.getSteelOrderMap(DataChange.dataToBigDecimal(stringObjectMap.get("saleOrderMaterialId")));
  796. if (orderMap != null) {
  797. throw new Exception("该订单已派发,无法重复派车");
  798. }
  799. if (saleStatus == 1) {
  800. throw new Exception("订单未审核,无法派车!");
  801. }
  802. int result = 0;
  803. // 遍历每一行
  804. for (Map<String,Object> map : mapList) {
  805. // 得到车牌号
  806. String capacityNumber = (String) map.get("capacityNumber");
  807. Map<String,Object> details = amsSaleOrderMapper.getOrderIdByCapacity(map);
  808. if(details!=null && details.get("orderId")!=null){
  809. if(details.get("isEn")==null){
  810. throw new Exception(capacityNumber+"有未进厂的运输订单任务,无法派单");
  811. }else if(details.get("isLeave")==null){
  812. throw new Exception(capacityNumber+"有未出厂的运输订单任务,无法派单");
  813. }else if(details.get("isArrival")==null){
  814. throw new Exception(capacityNumber+"有未抵达的运输订单任务,无法派单");
  815. }else if(details.get("isReceipt")==null){
  816. throw new Exception(capacityNumber+"有未签收的运输订单任务,无法派单");
  817. }
  818. throw new Exception(capacityNumber+"有未完成的运输订单任务,无法派单");
  819. }
  820. if(isCheckGps!=null && isCheckGps==0){
  821. Map<String,Object> locationResult = null;
  822. try{
  823. Map<String,Object> data = (Map<String,Object>)otmsFeign.getCurrentLocation(capacityNumber).getData();
  824. locationResult = (Map<String,Object>)data.get("result");
  825. }catch (Exception e){
  826. //出现任何异常不抛出,不终止程序
  827. }
  828. if(locationResult==null || locationResult.get("lon")==null || locationResult.get("lat")==null){
  829. throw new Exception("该车没有GPS定位信息,请联系销售公司物流部,申请是否可以派车。");
  830. }
  831. }
  832. // 得到车序号表主键
  833. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  834. // 得到承运商
  835. BigDecimal carrierId = DataChange.dataToBigDecimal(map.get("carrierId"));
  836. // 查询到车序号的单价
  837. BigDecimal priceId = amsSaleOrderMapper.getOrderPrice(map);
  838. // 得到详细地址id
  839. BigDecimal placeId = amsSaleOrderMapper.getPlaceId(saleOrderMaterialId);
  840. // 如果详细地址匹配不到单价,则匹配省市县内最高的一条单价(只给非自提的进行匹配)
  841. if (priceId == null && selfMention.equals("否")) {
  842. // 找到详细地址下的省市县id
  843. BigDecimal addressId = amsSaleOrderMapper.getAddressByPlace(placeId);
  844. // 根据省市县匹配出省市县下的所有单价
  845. Map<String, Object> hashMap = new HashMap<>();
  846. hashMap.put("addressId", addressId);
  847. hashMap.put("carrierId", carrierId);
  848. List<Map<String, Object>> priceList = amsSaleOrderMapper.getAddressPriceList(hashMap);
  849. // 如果长度为0,说明此地址所在省市县内也无单价
  850. if (priceList != null && priceList.size() != 0) {
  851. Map<String, Object> priceMap = priceList.get(0);
  852. priceId = (BigDecimal) priceMap.get("priceId");
  853. } else {
  854. priceId = new BigDecimal(2400);
  855. }
  856. }
  857. // 运输线路id
  858. BigDecimal lineId = DataChange.dataToBigDecimal(map.get("lineId"));
  859. // 司机电话号码
  860. String driverTel = (String) map.get("driverTel");
  861. BigDecimal isSteel = new BigDecimal(1);
  862. // 得到运力id
  863. BigDecimal capacityId = amsSaleOrderMaterialMapper.getCapacityId(capacityNumber);
  864. if (capacityId == null) {
  865. return 0;
  866. }
  867. List<Map<String, Object>> materialList = amsSaleOrderMaterialMapper.getMaterial(saleOrderMaterialId);
  868. /*
  869. 定向派单表
  870. */
  871. // 通过车序号主键确认定向派单是否已存在
  872. BigDecimal dispatchId0 = amsDispatchSaleOrderMapper.isDispatchExist(saleOrderMaterialId);
  873. if (dispatchId0 == null || dispatchId0.toString().length() == 0) {
  874. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  875. // 主键
  876. BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
  877. amsDispatchSaleOrder.setDispatchId(dispatchId);
  878. // 车序号表id
  879. amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
  880. // 承运商id
  881. amsDispatchSaleOrder.setCarrierId(carrierId);
  882. // 派单时间和成交时间
  883. amsDispatchSaleOrder.setDispatchTime(new Date());
  884. amsDispatchSaleOrder.setDispatchDealTime(new Date());
  885. // 成交类型
  886. amsDispatchSaleOrder.setDispatchType(new BigDecimal(2));
  887. // 车序号状态
  888. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
  889. result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
  890. }
  891. // 如果已经匹配过承运商或者给某个承运商授权过,则派车时做修改承运商操作
  892. else {
  893. AmsDispatchSaleOrder amsDispatchSaleOrder = amsDispatchSaleOrderMapper.selectByPrimaryKey(dispatchId0);
  894. amsDispatchSaleOrder.setCarrierId(carrierId);
  895. result += amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(amsDispatchSaleOrder);
  896. }
  897. /*
  898. 运输订单
  899. */
  900. OmstruckOrder omstruckOrder = new OmstruckOrder();
  901. Map<String, Object> map1 = new HashMap<>();
  902. map1.put("orderType", new BigDecimal(2));
  903. map1.put("orderPlanId", saleOrderMaterialId);
  904. List<OmstruckOrder> omstruckOrders = omstruckOrderMapper.selectByParameters(map1);
  905. if (omstruckOrders == null || omstruckOrders.size() == 0) {
  906. // 运输订单主键
  907. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  908. omstruckOrder.setOrderId(orderId);
  909. // 车序号主键
  910. omstruckOrder.setOrderPlanId(saleOrderMaterialId);
  911. //添加承运商ID 和 运价ID
  912. // Object priceId = map.get("priceId");
  913. if (priceId != null) {
  914. omstruckOrder.setPriceId(priceId);
  915. } else {
  916. omstruckOrder.setPriceId(new BigDecimal(0));
  917. }
  918. omstruckOrder.setCarrierId(carrierId);
  919. // 运输订单号
  920. omstruckOrder.setOrderNumber(DataChange.generateEightDigitsNumber("WYSDD", orderId.intValue()));
  921. // 运力id
  922. omstruckOrder.setCapacityId(capacityId);
  923. // 承运商
  924. omstruckOrder.setCarrierId(carrierId);
  925. // 是否可作业
  926. omstruckOrder.setCanWork(new BigDecimal(0));
  927. // 下发时间
  928. omstruckOrder.setOrderIssueTime(new Date());
  929. // 运单状态
  930. omstruckOrder.setOrderStatus(new BigDecimal(4));
  931. // 司机电话
  932. if (driverTel != null && !"null".equals(driverTel)) {
  933. omstruckOrder.setDriverTel(driverTel);
  934. }
  935. BigDecimal status;
  936. // 钢材
  937. if (isSteel != null && isSteel.intValue() == 1) {
  938. status = new BigDecimal(1);
  939. }
  940. // 非钢材(危化品,焦炭,副产品)
  941. else {
  942. status = new BigDecimal(2);
  943. }
  944. // 订单类型
  945. omstruckOrder.setOrderType(status);
  946. // 运输线路id
  947. omstruckOrder.setLineId(lineId);
  948. omstruckOrder.setInsertTime(new Date());
  949. omstruckOrder.setInsertUsername("");
  950. result += omstruckOrderMapper.insertSelective(omstruckOrder);
  951. } else {
  952. omstruckOrder = omstruckOrders.get(0);
  953. }
  954. for (Map<String, Object> materialMap : materialList) {
  955. BigDecimal materialId = (BigDecimal) materialMap.get("materialId");
  956. BigDecimal materialWeight = (BigDecimal) materialMap.get("materialWeight");
  957. BigDecimal materialNumber = (BigDecimal) materialMap.get("materialNumber");
  958. /*
  959. 运输订单物资子表
  960. */
  961. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  962. // 主键
  963. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  964. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  965. // 运输订单id
  966. omstruckOrderMaterial.setOrderId(omstruckOrder.getOrderId());
  967. // 物资id
  968. omstruckOrderMaterial.setMaterialId(materialId);
  969. // 物资重量
  970. omstruckOrderMaterial.setOrderMaterialWeight(materialWeight);
  971. // 物资件数
  972. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  973. // 新增运输订单子表
  974. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  975. }
  976. // 调用websocket
  977. Map<String, Object> orderIdMap = new HashMap<>();
  978. orderIdMap.put("orderId", omstruckOrder.getOrderId());
  979. try {
  980. amsSaleOrderMaterialService.pushMesToWebsocket(orderIdMap);
  981. } catch (Exception e) {
  982. e.printStackTrace();
  983. }
  984. // 生成运输执行总实绩
  985. result += tmsTruckFeign.addTotalResult(orderIdMap);
  986. }
  987. return result;
  988. }
  989. @Override
  990. public int continueSteelOrder(List<Map<String, Object>> mapList) throws Exception {
  991. int result = 0;
  992. // 遍历每一行
  993. for (Map<String,Object> map : mapList) {
  994. List<OmstruckOrder> orders=omstruckOrderMapper.selectByParameters(map);
  995. if(orders==null || orders.size()<=0){
  996. throw new Exception("没有对应的运输订单");
  997. }
  998. OmstruckOrder omstruckOrder=orders.get(0);
  999. // 得到车序号表主键
  1000. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  1001. // 得到承运商
  1002. BigDecimal carrierId = omstruckOrder.getCarrierId();
  1003. //查询车序号表物资
  1004. List<Map<String, Object>> materialList = amsSaleOrderMaterialMapper.getMaterial(saleOrderMaterialId);
  1005. if(materialList==null||materialList.size()<=0){
  1006. throw new Exception("车序号没有剩余物资");
  1007. }
  1008. // 程序根据剩余多少拼生成运输线路id 110001 到 110010(单拼到十拼)
  1009. BigDecimal lineId = DataChange.dataToBigDecimal(110000+materialList.size());
  1010. /*
  1011. 定向派单表
  1012. */
  1013. // 通过车序号主键确认定向派单是否已存在
  1014. BigDecimal dispatchId0 = amsDispatchSaleOrderMapper.isDispatchExist(saleOrderMaterialId);
  1015. if (dispatchId0 == null || dispatchId0.toString().length() == 0) {
  1016. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  1017. // 主键
  1018. BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
  1019. amsDispatchSaleOrder.setDispatchId(dispatchId);
  1020. // 车序号表id
  1021. amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
  1022. // 承运商id
  1023. amsDispatchSaleOrder.setCarrierId(carrierId);
  1024. // 派单时间和成交时间
  1025. amsDispatchSaleOrder.setDispatchTime(new Date());
  1026. amsDispatchSaleOrder.setDispatchDealTime(new Date());
  1027. // 成交类型
  1028. amsDispatchSaleOrder.setDispatchType(new BigDecimal(2));
  1029. // 车序号状态
  1030. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
  1031. result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
  1032. }
  1033. // 如果已经匹配过承运商或者给某个承运商授权过,则派车时做修改承运商操作
  1034. else {
  1035. AmsDispatchSaleOrder amsDispatchSaleOrder = amsDispatchSaleOrderMapper.selectByPrimaryKey(dispatchId0);
  1036. amsDispatchSaleOrder.setCarrierId(carrierId);
  1037. result += amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(amsDispatchSaleOrder);
  1038. }
  1039. /*
  1040. 运输订单
  1041. */
  1042. // 运输订单主键
  1043. BigDecimal orderId = omstruckOrderMapper.selectMaxId();
  1044. omstruckOrder.setOrderId(orderId);
  1045. // 车序号主键
  1046. omstruckOrder.setOrderPlanId(saleOrderMaterialId);
  1047. // 是否可作业
  1048. omstruckOrder.setCanWork(new BigDecimal(0));
  1049. // 下发时间
  1050. omstruckOrder.setOrderIssueTime(new Date());
  1051. // 运单状态
  1052. if(omstruckOrder.getOrderReceiveRefuseTime()!=null){
  1053. omstruckOrder.setOrderStatus(new BigDecimal(7));
  1054. }else{
  1055. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1056. }
  1057. //路段顺序号
  1058. //omstruckOrder.setOrderLineSequence(new BigDecimal(2));
  1059. // 运输线路id
  1060. omstruckOrder.setLineId(lineId);
  1061. omstruckOrder.setInsertTime(new Date());
  1062. omstruckOrder.setInsertUsername("continue");
  1063. result += omstruckOrderMapper.insertSelective(omstruckOrder);
  1064. for (Map<String, Object> materialMap : materialList) {
  1065. BigDecimal materialId = (BigDecimal) materialMap.get("materialId");
  1066. BigDecimal materialWeight = (BigDecimal) materialMap.get("materialWeight");
  1067. BigDecimal materialNumber = (BigDecimal) materialMap.get("materialNumber");
  1068. /*
  1069. 运输订单物资子表
  1070. */
  1071. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1072. // 主键
  1073. BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
  1074. omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
  1075. // 运输订单id
  1076. omstruckOrderMaterial.setOrderId(omstruckOrder.getOrderId());
  1077. // 物资id
  1078. omstruckOrderMaterial.setMaterialId(materialId);
  1079. // 物资重量
  1080. omstruckOrderMaterial.setOrderMaterialWeight(materialWeight);
  1081. // 物资件数
  1082. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  1083. // 新增运输订单子表
  1084. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1085. }
  1086. // 调用websocket
  1087. Map<String, Object> orderIdMap = new HashMap<>();
  1088. orderIdMap.put("orderId", omstruckOrder.getOrderId());
  1089. amsSaleOrderMaterialService.pushMesToWebsocket(orderIdMap);
  1090. orderIdMap.put("orderIdOld", map.get("orderId"));
  1091. orderIdMap.put("resultTotalIdOld",map.get("resultTotalId"));
  1092. // 生成所有实绩
  1093. result += tmsTruckFeign.copyAllResult(orderIdMap);
  1094. }
  1095. return result;
  1096. }
  1097. /**
  1098. * 根据详细地址匹配承运商
  1099. * @param placeId
  1100. * @return
  1101. */
  1102. @Override
  1103. public synchronized List<Map<String,Object>> getCarrierByPlace(BigDecimal placeId) {
  1104. BigDecimal addressId = amsSaleOrderMapper.getAddressByPlace(placeId);
  1105. List<Map<String,Object>> mapList = amsSaleOrderMapper.getCarrierByPlace(placeId);
  1106. return mapList;
  1107. }
  1108. /**
  1109. * 根据省市县匹配承运商
  1110. * @param placeId
  1111. * @return
  1112. */
  1113. public synchronized List<Map<String,Object>> getCarrierByAddress(BigDecimal placeId) {
  1114. BigDecimal addressId = amsSaleOrderMapper.getAddressByPlace(placeId);
  1115. List<Map<String,Object>> mapList = amsSaleOrderMapper.getCarrierByAddress(addressId);
  1116. return mapList;
  1117. }
  1118. /**
  1119. * 根据详细地址和承运商匹配单价
  1120. * @param mapValue
  1121. * @return
  1122. */
  1123. @Override
  1124. public Map<String, Object> getPriceByCarrierAndPlace(Map<String, Object> mapValue) {
  1125. Map<String,Object> map = amsSaleOrderMapper.getPriceByCarrierAndPlace(mapValue);
  1126. return map;
  1127. }
  1128. /**
  1129. * 将车序号下发给承运商
  1130. * @param mapList
  1131. * @return
  1132. */
  1133. @Override
  1134. public int dispatchToCarrier(List<Map<String,Object>> mapList) {
  1135. int result = 0;
  1136. // 遍历每一行
  1137. for (Map<String, Object> map : mapList) {
  1138. // 得到承运商
  1139. BigDecimal carrierId =DataChange.dataToBigDecimal(map.get("carrierId"));
  1140. // 得到车序号表主键
  1141. BigDecimal saleOrderMaterialId =DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  1142. AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
  1143. BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
  1144. amsDispatchSaleOrder.setDispatchId(dispatchId);
  1145. amsDispatchSaleOrder.setCarrierId(carrierId);
  1146. amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
  1147. amsDispatchSaleOrder.setInsertTime(new Date());
  1148. amsDispatchSaleOrder.setInsertUpdateRemark("授权承运商");
  1149. // 派单时间和成交时间
  1150. amsDispatchSaleOrder.setDispatchTime(new Date());
  1151. amsDispatchSaleOrder.setDispatchDealTime(new Date());
  1152. // 成交类型
  1153. amsDispatchSaleOrder.setDispatchType(new BigDecimal(2));
  1154. // 车序号状态
  1155. amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
  1156. result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
  1157. }
  1158. return result;
  1159. }
  1160. @Override
  1161. public List<Map<String, Object>> getSaleOrderListToCarrier(Map<String, Object> map) {
  1162. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleOrderListToCarrier(map);
  1163. if (resultList.isEmpty()){
  1164. }else {
  1165. for (Map<String, Object> stringObjectMap : resultList) {
  1166. try {
  1167. BigDecimal saleShippingAddressId = (BigDecimal) stringObjectMap.get("saleShippingAddressId");
  1168. if (saleShippingAddressId!=null&&!("".equals(saleShippingAddressId))){
  1169. String address = amsSaleOrderMapper.getshippingAddress(saleShippingAddressId);
  1170. stringObjectMap.put("saleShippingAddress",address);
  1171. }
  1172. }catch (Exception e){
  1173. System.out.println("e"+e.getMessage());
  1174. stringObjectMap.put("saleShippingAddress","");
  1175. }
  1176. }
  1177. }
  1178. return resultList;
  1179. }
  1180. @Override
  1181. public List<Map<String, Object>> getSaleOrderListByCarrierSsoId(Map<String, Object> map) {
  1182. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleOrderListByCarrierSsoId(map);
  1183. return resultList;
  1184. }
  1185. /**
  1186. * 同步金蝶删除
  1187. * @param saleOrderId
  1188. * @return
  1189. */
  1190. @Override
  1191. public int deleteSaleOrderById(BigDecimal saleOrderId) {
  1192. int result = 0;
  1193. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1194. amsSaleOrder.setSaleOrderId(saleOrderId);
  1195. amsSaleOrder.setDeleted(new BigDecimal(2));
  1196. // 如果是已经上传金蝶的销售订单,则同步删除
  1197. AmsSaleOrder amsSaleOrder1 = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  1198. if (amsSaleOrder1.getSaleOrderStatus().intValue() == 4) {
  1199. String reason = "修改物资关闭上一条销售订单";
  1200. String number = amsSaleOrder1.getSaleNumber();
  1201. String wholeOrder = "1";
  1202. String status = "close";
  1203. Map<String,Object> head = new HashMap<>();
  1204. head.put("number",number);
  1205. head.put("reason",reason);
  1206. head.put("wholeOrder",wholeOrder);
  1207. head.put("status",status);
  1208. Map<String,Object> input = new HashMap<>();
  1209. Map<String, Object> totalMap = easDeleteApproveUtil.getTotalMap();
  1210. input.put("head",head);
  1211. totalMap.put("input",input);
  1212. // 调用金蝶关闭接口
  1213. String json = JSONUtils.toJSONString(totalMap);
  1214. System.out.println(json);
  1215. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1216. System.out.println(resultMap);
  1217. }else if(amsSaleOrder1.getSaleOrderStatus().intValue() == 1 || amsSaleOrder1.getSaleOrderStatus().intValue() == 2){
  1218. String reason = "修改物资关闭上一条销售订单";
  1219. String number = amsSaleOrder1.getSaleNumber();
  1220. Map<String, Object> deleteMap = new HashMap<>();
  1221. deleteMap.put("saleOrderId",saleOrderId);
  1222. deleteMap.put("reason",reason);
  1223. deleteMap.put("number",number);
  1224. deleteSaleOrderSame(deleteMap);
  1225. }
  1226. // 如果是副产品订单则关闭时同步关闭未进厂的运单
  1227. Map<String,Object> map = new HashMap<>();
  1228. map.put("saleOrderId",saleOrderId);
  1229. List<AmsSaleMaterial> amsSaleMaterials = amsSaleMaterialMapper.selectByParameters(map);
  1230. if (amsSaleMaterials != null && amsSaleMaterials.get(0).getSaleWarehouse() != null && amsSaleMaterials.get(0).getSaleWarehouse().equals("副产品库")) {
  1231. result += amsSaleOrderMapper.closeOrderNotIn(saleOrderId);
  1232. }
  1233. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1234. return result;
  1235. }
  1236. /**
  1237. * 查询出销售订单下的所有数据
  1238. * @param saleOrderId
  1239. * @return
  1240. */
  1241. @Override
  1242. public Map<String, Object> getAllSaleMessages(BigDecimal saleOrderId) {
  1243. Map<String,Object> saleMap = amsSaleOrderMapper.getSaleMapMessages(saleOrderId);
  1244. List<Map<String,Object>> mapList = amsSaleOrderMapper.getSaleListMessages(saleOrderId);
  1245. saleMap.put("mapList",mapList);
  1246. return saleMap;
  1247. }
  1248. /**
  1249. * 修改承运商授权
  1250. * @param mapValue
  1251. * @return
  1252. */
  1253. @Override
  1254. public int updateTruckNoCarrier(Map<String, Object> mapValue) {
  1255. BigDecimal carrierId = DataChange.dataToBigDecimal(mapValue.get("carrierId"));
  1256. mapValue.remove("carrierId");
  1257. List<AmsDispatchSaleOrder> amsDispatchSaleOrders = amsDispatchSaleOrderMapper.selectByParameters(mapValue);
  1258. AmsDispatchSaleOrder amsDispatchSaleOrder = amsDispatchSaleOrders.get(0);
  1259. amsDispatchSaleOrder.setCarrierId(carrierId);
  1260. int result = amsDispatchSaleOrderMapper.updateByPrimaryKeySelective(amsDispatchSaleOrder);
  1261. return result;
  1262. }
  1263. /**
  1264. * 批量上传销售订单至金蝶
  1265. * @param saleOrderIdList
  1266. * @return
  1267. */
  1268. @Transactional(rollbackFor = Exception.class)
  1269. @Override
  1270. public int uploadSaleOrderList(List<Map<String, Object>> saleOrderIdList) {
  1271. int result = 0;
  1272. for (Map<String, Object> map : saleOrderIdList) {
  1273. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1274. BigDecimal saleOrderId = DataChange.dataToBigDecimal(map.get("saleOrderId"));
  1275. // 调用金蝶接口,将销售订单推送到金蝶系统
  1276. Map<String, Object> input = joinFeign.getSaleOrder(saleOrderId);
  1277. Map<String, Object> head = (Map<String, Object>) input.get("head");
  1278. head.put("status","");
  1279. // 获得金蝶接口配置:正式
  1280. // Map<String, Object> totalMap = easUtil.getTotalMap();
  1281. // 获得金蝶接口配置:测试
  1282. Map<String, Object> totalMap = easUtil.getTotalMap();
  1283. // 组装报文
  1284. totalMap.put("input",input);
  1285. System.out.println(totalMap);
  1286. String json = JSONUtils.toJSONString(totalMap);
  1287. System.out.println(json);
  1288. Map<String,Object> s = joinFeign.pushSaleOrderToEas(totalMap);
  1289. String status = (String) s.get("status");
  1290. if ("-1".equals(status)) {
  1291. continue;
  1292. }
  1293. System.out.println(s);
  1294. amsSaleOrder.setSaleOrderId(saleOrderId);
  1295. amsSaleOrder.setSaleOrderStatus(new BigDecimal(1));
  1296. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1297. }
  1298. return result;
  1299. }
  1300. /**
  1301. * 新增钒渣销售订单
  1302. * @param mapValue
  1303. * @return
  1304. */
  1305. @Override
  1306. public int addVanadiumSaleOrder(Map<String, Object> mapValue) {
  1307. List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1308. // 得到发货单位
  1309. BigDecimal shipperId = DataChange.dataToBigDecimal(mapValue.get("shipperId"));
  1310. // 收货单位
  1311. BigDecimal receiveId = DataChange.dataToBigDecimal(mapValue.get("receiveId"));
  1312. // 是否自提
  1313. String isSelfMention = (String) mapValue.get("isSelfMention");
  1314. // 备注
  1315. String saleRemark = (String) mapValue.get("saleRemark");
  1316. // 收款客户
  1317. String saleOrderReceiveCustomer = (String) mapValue.get("saleOrderReceiveCustomer");
  1318. // 业务员
  1319. BigDecimal salerId = DataChange.dataToBigDecimal(mapValue.get("salerId"));
  1320. BigDecimal saleOrderId = amsSaleOrderMapper.selectMaxId();
  1321. int result = 0;
  1322. // 销售订单
  1323. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1324. amsSaleOrder.setReceiveId(receiveId);
  1325. amsSaleOrder.setSaleRemark(saleRemark == null ? "":saleRemark);
  1326. amsSaleOrder.setShipperId(shipperId);
  1327. amsSaleOrder.setSaleOrderIsselfMention(isSelfMention);
  1328. amsSaleOrder.setSaleOrderId(saleOrderId);
  1329. amsSaleOrder.setSalerId(salerId);
  1330. // 设置钒渣订单
  1331. amsSaleOrder.setSaleType(new BigDecimal(2));
  1332. amsSaleOrder.setSaleNumber(DataChange.generateEightDigitsNumber("WXSDD",saleOrderId.intValue(),"-"));
  1333. amsSaleOrder.setInsertTime(new Date());
  1334. amsSaleOrder.setInsertUpdateRemark("物流新增销售订单");
  1335. amsSaleOrder.setInsertUsername("物流");
  1336. amsSaleOrder.setUpdateTime(new Date());
  1337. amsSaleOrder.setDeleted(new BigDecimal(0));
  1338. amsSaleOrder.setSaleOrderStatus(new BigDecimal(0));
  1339. // 税率默认13%
  1340. amsSaleOrder.setSaleOrderTax("13%");
  1341. // 含税单价某人4000
  1342. amsSaleOrder.setSaleUnitPrice(new BigDecimal(4000));
  1343. // 收款客户
  1344. amsSaleOrder.setSaleOrderReceiveCustomer(saleOrderReceiveCustomer);
  1345. // 销售订单物资表
  1346. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1347. // 车序号物资表
  1348. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  1349. // 遍历每一行
  1350. for (Map<String, Object> map : mapList) {
  1351. /*
  1352. 车序号表
  1353. */
  1354. // 得到车序号
  1355. BigDecimal truckNo = DataChange.dataToBigDecimal(map.get("truckNo"));
  1356. Map<String,Object> saleMap = new HashMap<>();
  1357. saleMap.put("saleOrderId",saleOrderId);
  1358. saleMap.put("saleOrderMaterialTruckNo",truckNo);
  1359. // 检测销售订单下的车序号是否已存在
  1360. List<AmsSaleOrderMaterial> amsSaleOrderMaterials = amsSaleOrderMaterialMapper.selectByParameters(saleMap);
  1361. // 车序号表
  1362. AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
  1363. if (amsSaleOrderMaterials == null || amsSaleOrderMaterials.size() == 0) {
  1364. // 车序号主键
  1365. BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
  1366. BigDecimal shippingAddressId = DataChange.dataToBigDecimal(map.get("shipperAddressId"));
  1367. // 车号备注
  1368. String truckRemark = (String) (map.get("truckRemark"));
  1369. String place = (String) (map.get("place"));
  1370. if (place != null && !"null".equals(place)) {
  1371. List<Map<String, Object>> placeIdList = amsSaleOrderMaterialMapper.getPlaceId(place,shippingAddressId);
  1372. if (placeIdList == null || placeIdList.size() == 0) {
  1373. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  1374. rmsReceivePlace.setPlaceId(rmsReceivePlaceMapper.selectMaxId());
  1375. rmsReceivePlace.setAddressId(shippingAddressId);
  1376. rmsReceivePlace.setAddressDeliveryAddress(place);
  1377. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  1378. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  1379. } else {
  1380. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  1381. }
  1382. }
  1383. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null && isSelfMention.equals("否")) {
  1384. // 自动匹配承运商
  1385. List<Map<String, Object>> carrierList = getCarrierByPlace(amsSaleOrderMaterial.getSaleShippingAddressId());
  1386. // 单一承运商才进行匹配
  1387. if (carrierList != null && carrierList.size() == 1) {
  1388. List<Map<String, Object>> list = new ArrayList<>();
  1389. Map<String, Object> map1 = carrierList.get(0);
  1390. // 传入车序号主键和承运商id
  1391. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1392. map1.put("carrierId", map1.get("value"));
  1393. list.add(map1);
  1394. dispatchToCarrier(list);
  1395. }
  1396. }
  1397. if (isSelfMention.equals("是")) {
  1398. // 根据收货单位id查询出收货单位名称
  1399. String consigneeName = amsSaleOrderMapper.selectConsigneeName(receiveId);
  1400. // 根据收货单位名称查询承运商id
  1401. BigDecimal carrierId = amsSaleOrderMapper.selectCarrierId(consigneeName);
  1402. List<Map<String, Object>> list = new ArrayList<>();
  1403. Map<String,Object> map1 = new HashMap<>();
  1404. // 传入车序号主键和承运商id
  1405. if (carrierId != null) {
  1406. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1407. map1.put("carrierId", carrierId);
  1408. list.add(map1);
  1409. dispatchToCarrier(list);
  1410. }
  1411. }
  1412. // 收货方姓名
  1413. String consigneeName = String.valueOf(map.get("saleOrderConsignee"));
  1414. // 收货方电话
  1415. String consigneeTel = String.valueOf(map.get("saleOrderConsigneeTel"));
  1416. // 截止日期
  1417. String dateOfReceiptStr = String.valueOf(map.get("saleDateOfReceipt"));
  1418. Date dateOfReceipt = null;
  1419. if (!"null".equals(dateOfReceiptStr) && !"undefined".equals(dateOfReceiptStr)) {
  1420. dateOfReceipt = new Date(Long.valueOf(dateOfReceiptStr));
  1421. }
  1422. amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  1423. amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
  1424. amsSaleOrderMaterial.setTruckRemark(truckRemark);
  1425. amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(truckNo);
  1426. if (consigneeName != null && !consigneeName.equals("null")) {
  1427. amsSaleOrderMaterial.setSaleOrderConsignee(consigneeName);
  1428. }
  1429. if (consigneeTel != null && !consigneeTel.equals("null")) {
  1430. amsSaleOrderMaterial.setSaleOrderConsigneeTel(consigneeTel);
  1431. }
  1432. amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
  1433. amsSaleOrderMaterial.setInsertTime(new Date());
  1434. amsSaleOrderMaterial.setUpdateTime(new Date());
  1435. amsSaleOrderMaterial.setInsertUpdateRemark("物流新增");
  1436. result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
  1437. }
  1438. else {
  1439. amsSaleOrderMaterial = amsSaleOrderMaterials.get(0);
  1440. }
  1441. /*
  1442. 销售订单物资表
  1443. */
  1444. // 物资
  1445. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  1446. // 物资件数
  1447. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("materialNumber"));
  1448. // 钢材米数
  1449. BigDecimal steelMeters = DataChange.dataToBigDecimal(map.get("steelMeters"));
  1450. // 是否磅重销售(0:磅重;1:理重)
  1451. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPoundSale"));
  1452. // 销售订单物资表主键
  1453. BigDecimal saleMaterialId = amsSaleMaterialMapper.selectMaxId();
  1454. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1455. amsSaleMaterial.setSaleOrderId(saleOrderId);
  1456. amsSaleMaterial.setMaterialId(materialId);
  1457. amsSaleMaterial.setMaterialNumber(materialNumber);
  1458. amsSaleMaterial.setInsertTime(new Date());
  1459. amsSaleMaterial.setUpdateTime(new Date());
  1460. if (steelMeters != null && !steelMeters.toString().equals("0")) {
  1461. amsSaleMaterial.setSteelMeter(steelMeters);
  1462. }
  1463. amsSaleMaterial.setIsPoundSale(isPoundSale);
  1464. amsSaleMaterial.setInsertUpdateRemark("物流新增");
  1465. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  1466. /*
  1467. 车序号物资表
  1468. */
  1469. // 车序号物资表主键
  1470. BigDecimal truckNoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
  1471. amsSaleTrucknoMaterial.setTrucknoMaterialId(truckNoMaterialId);
  1472. amsSaleTrucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
  1473. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  1474. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  1475. amsSaleTrucknoMaterial.setInsertTime(new Date());
  1476. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  1477. amsSaleTrucknoMaterial.setInsertUpdateRemark("物流新增");
  1478. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  1479. }
  1480. result += amsSaleOrderMapper.insertSelective(amsSaleOrder);
  1481. return result;
  1482. }
  1483. /**
  1484. * 自动匹配出最近的一个地址
  1485. * @param receiveId
  1486. * @return
  1487. */
  1488. @Override
  1489. public List<Map<String, Object>> matchingAddressRecently(BigDecimal receiveId) {
  1490. List<Map<String,Object>> mapList = amsSaleOrderMapper.matchingAddressRecently(receiveId);
  1491. List<Map<String,Object>> salerList = amsSaleOrderMapper.getSalerByReceiveId(receiveId);
  1492. if (mapList != null && mapList.size() != 0) {
  1493. if (salerList != null && salerList.size() !=0) {
  1494. Map<String, Object> salerMap = salerList.get(0);
  1495. for (Map<String, Object> map : mapList) {
  1496. map.putAll(salerMap);
  1497. }
  1498. }
  1499. }
  1500. return mapList;
  1501. }
  1502. /**
  1503. * 自动匹配上一条运单的司机电话
  1504. * @param capacityNumber
  1505. * @return
  1506. */
  1507. @Override
  1508. public String matchingDriverTelRecently(String capacityNumber) {
  1509. String driverTel = amsSaleOrderMapper.matchingDriverTelRecently(capacityNumber);
  1510. return driverTel;
  1511. }
  1512. /**
  1513. * 查询内转焦炭订单
  1514. * @param mapValue
  1515. * @return
  1516. */
  1517. @Override
  1518. public List<Map<String, Object>> getCokeInwardOrderList(Map<String, Object> mapValue) {
  1519. return amsSaleOrderMapper.getCokeInwardOrderList(mapValue);
  1520. }
  1521. /**
  1522. * 修改收货地址
  1523. * @param mapValue
  1524. * @return
  1525. */
  1526. @Transactional(rollbackFor = Exception.class)
  1527. @Override
  1528. public int updateCarAddress(Map<String, Object> mapValue) {
  1529. // 判断是否需要删除金蝶分录
  1530. Integer isCloseEas = (Integer) mapValue.get("isCloseEas");
  1531. String operateName = (String) mapValue.get("operateName");
  1532. int result = 0;
  1533. // 运输订单id
  1534. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  1535. // 车序号id
  1536. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1537. // 是
  1538. if (isCloseEas == 0 && orderId != null && orderId.intValue() != 0) {
  1539. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1540. omstruckOrder.setOrderId(orderId);
  1541. omstruckOrder.setOrderStatus(new BigDecimal(7));
  1542. if(operateName != null){
  1543. omstruckOrder.setOptionerCode(operateName);
  1544. }
  1545. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1546. // 得到销售订单物资表主键
  1547. List<Map<String,Object>> saleMaterialIdList = amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1548. for (Map<String, Object> map : saleMaterialIdList) {
  1549. // 关闭销售订单物资子表
  1550. BigDecimal saleMaterialId = (BigDecimal) map.get("saleMaterialId");
  1551. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1552. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1553. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1554. amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1555. }
  1556. return 0;
  1557. }
  1558. // 判断是否需要修改派车
  1559. Object isNewCar = mapValue.get("isNewCar");
  1560. // 省市县ID
  1561. BigDecimal shippingAddressId = DataChange.dataToBigDecimal(mapValue.get("shipperAddressId"));
  1562. // 具体地址
  1563. String place = (String) mapValue.get("place");
  1564. Integer addressid1= (Integer) mapValue.get("placeId");
  1565. BigDecimal addressid2 =BigDecimal.ZERO;
  1566. AmsSaleOrderMaterial amsSaleOrderMaterial = amsSaleOrderMaterialMapper.selectByPrimaryKey(saleOrderMaterialId);
  1567. if (place != null && !("".equals(place))) {
  1568. List<Map<String, Object>> placeIdList = amsSaleOrderMaterialMapper.getPlaceId(place,shippingAddressId);
  1569. if (placeIdList == null || placeIdList.size() == 0) {
  1570. RmsReceivePlace rmsReceivePlace = new RmsReceivePlace();
  1571. BigDecimal placeId = rmsReceivePlaceMapper.selectMaxId();
  1572. rmsReceivePlace.setPlaceId(placeId);
  1573. rmsReceivePlace.setAddressId(shippingAddressId);
  1574. rmsReceivePlace.setAddressDeliveryAddress(place);
  1575. amsSaleOrderMaterial.setSaleShippingAddressId(rmsReceivePlace.getPlaceId());
  1576. rmsReceivePlaceMapper.insertSelective(rmsReceivePlace);
  1577. addressid2 = placeId;
  1578. } else {
  1579. addressid2 =(BigDecimal) placeIdList.get(0).get("placeId");
  1580. amsSaleOrderMaterial.setSaleShippingAddressId((BigDecimal) placeIdList.get(0).get("placeId"));
  1581. }
  1582. }
  1583. String addressids="";
  1584. addressids =addressid1+","+addressid2;
  1585. amsSaleOrderMaterial.setShippingAddressIds(addressids);
  1586. result += amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial);
  1587. // 需要换车
  1588. if (isNewCar != null && (Integer) isNewCar == 0) {
  1589. // 根据车序号得到定向派单表主键
  1590. BigDecimal dispatchId = amsSaleOrderMapper.getDispatchId(saleOrderMaterialId);
  1591. if (dispatchId != null) {
  1592. amsDispatchSaleOrderMapper.deleteByPrimaryKey(dispatchId);
  1593. }
  1594. if (orderId != null) {
  1595. omstruckOrderMapper.deleteByPrimaryKey(orderId);
  1596. }
  1597. if (amsSaleOrderMaterial.getSaleShippingAddressId() != null) {
  1598. // 自动匹配承运商
  1599. List<Map<String, Object>> carrierList = getCarrierByPlace(amsSaleOrderMaterial.getSaleShippingAddressId());
  1600. // 单一承运商才进行匹配
  1601. if (carrierList != null && carrierList.size() == 1) {
  1602. List<Map<String, Object>> list = new ArrayList<>();
  1603. Map<String, Object> map1 = carrierList.get(0);
  1604. // 传入车序号主键和承运商id
  1605. map1.put("saleOrderMaterialId", saleOrderMaterialId);
  1606. map1.put("carrierId", map1.get("value"));
  1607. list.add(map1);
  1608. dispatchToCarrier(list);
  1609. }
  1610. }
  1611. }
  1612. return result;
  1613. }
  1614. /**
  1615. * 展示未匹配承运商的车序号
  1616. * @param mapValue
  1617. * @return
  1618. */
  1619. @Override
  1620. public List<Map<String, Object>> getSteelTruckNoList(Map<String, Object> mapValue) {
  1621. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSteelTruckNoList(mapValue);
  1622. return resultList;
  1623. }
  1624. /**
  1625. * 展示车序号的详情
  1626. * @param saleOrderMaterialId
  1627. * @return
  1628. */
  1629. @Override
  1630. public List<Map<String, Object>> getTruckNoMaterial(BigDecimal saleOrderMaterialId) {
  1631. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoMaterialAndCarrier(saleOrderMaterialId);
  1632. for (Map<String,Object> map : mapList) {
  1633. BigDecimal placeId = (BigDecimal) map.get("placeId");
  1634. if (placeId != null) {
  1635. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  1636. map.put("carrierAndPriceList", carrierAndPriceList);
  1637. }
  1638. }
  1639. return mapList;
  1640. }
  1641. /**
  1642. * 展示已分配承运商但未派车的车序号
  1643. * @param mapValue
  1644. * @return
  1645. */
  1646. @Override
  1647. public List<Map<String, Object>> getNoCarTruckNoList(Map<String, Object> mapValue) {
  1648. List<Map<String, Object>> resultList = amsSaleOrderMapper.getCarrierTruckNoList(mapValue);
  1649. return resultList;
  1650. }
  1651. /**
  1652. * 展示已派车的车序号
  1653. * @param mapValue
  1654. * @return
  1655. */
  1656. @Override
  1657. public List<Map<String, Object>> getHaveCarTruckNoList(Map<String, Object> mapValue) {
  1658. List<Map<String, Object>> resultList = amsSaleOrderMapper.getHaveCarTruckNoList(mapValue);
  1659. return resultList;
  1660. }
  1661. /**
  1662. * 修改销售订单中的物资
  1663. * @param mapValue
  1664. * @return
  1665. */
  1666. @Transactional(rollbackFor = Exception.class)
  1667. @Override
  1668. public int updateAllMaterialInSale(Map<String, Object> mapValue) {
  1669. int result = 0;
  1670. // 得到销售订单主键
  1671. BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
  1672. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1673. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  1674. // 将车辆改为不可作业状态
  1675. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1676. omstruckOrder.setOrderId(orderId);
  1677. omstruckOrder.setCanWork(new BigDecimal(1));
  1678. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1679. // 得到运单中的物资
  1680. List<Map<String, Object>> oldList = omstruckOrderMaterialMapper.getMaterialList(orderId);
  1681. Map<String, Object> toTmsMap = new HashMap<>();
  1682. Map<String, Object> truckNoMap = new HashMap<>();
  1683. truckNoMap.put("saleOrderMaterialId",saleOrderMaterialId);
  1684. toTmsMap.put("orderId", orderId);
  1685. toTmsMap.put("oldMaterialMapList", oldList);
  1686. // 得到所有的物资
  1687. List<Map<String, Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
  1688. /*
  1689. 删除三个物资表数据
  1690. */
  1691. List<AmsSaleTrucknoMaterial> amsSaleTrucknoMaterials = amsSaleTrucknoMaterialMapper.selectByParameters(truckNoMap);
  1692. for (AmsSaleTrucknoMaterial amsSaleTrucknoMaterial : amsSaleTrucknoMaterials) {
  1693. // 销售订单物资子表
  1694. amsSaleMaterialMapper.deleteByPrimaryKey(amsSaleTrucknoMaterial.getMaterialId());
  1695. // 车序号子表
  1696. amsSaleTrucknoMaterialMapper.deleteByPrimaryKey(amsSaleTrucknoMaterial.getTrucknoMaterialId());
  1697. }
  1698. // 运输订单物资子表
  1699. List<OmstruckOrderMaterial> omstruckOrderMaterials = omstruckOrderMaterialMapper.selectByParameters(toTmsMap);
  1700. for (OmstruckOrderMaterial omstruckOrderMaterial : omstruckOrderMaterials) {
  1701. omstruckOrderMaterialMapper.deleteByPrimaryKey(omstruckOrderMaterial.getOrderMaterialId());
  1702. }
  1703. /*
  1704. 重新新增三个表
  1705. */
  1706. for (Map<String, Object> map : mapList) {
  1707. Object saleMaterialId = map.get("saleMaterialId");
  1708. BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
  1709. BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("orderPlanWeight"));
  1710. Object trucknoMaterialId = map.get("trucknoMaterialId");
  1711. BigDecimal isPoundSale = DataChange.dataToBigDecimal(map.get("isPound"));
  1712. Object materialWeight = map.get("materialWeight");
  1713. Object steelMeter = map.get("meterNumber");
  1714. Object easId = map.get("easId");
  1715. Object warehouse = map.get("warehouse");
  1716. // 销售订单分录表
  1717. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1718. // 车序号子表
  1719. AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
  1720. // 运输订单子表
  1721. OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
  1722. // if (saleMaterialId != null) {
  1723. // amsSaleMaterial.setSaleMaterialId(DataChange.dataToBigDecimal(saleMaterialId));
  1724. // amsSaleTrucknoMaterial.setTrucknoMaterialId(DataChange.dataToBigDecimal(trucknoMaterialId));
  1725. // }
  1726. // if (saleMaterialId == null){
  1727. amsSaleMaterial.setSaleMaterialId(amsSaleMaterialMapper.selectMaxId());
  1728. amsSaleTrucknoMaterial.setTrucknoMaterialId(amsSaleTrucknoMaterialMapper.selectMaxId());
  1729. // }
  1730. if (easId != null) {
  1731. amsSaleMaterial.setEasPrimaryId(easId.toString());
  1732. }
  1733. if (warehouse != null) {
  1734. amsSaleMaterial.setSaleWarehouse(warehouse.toString());
  1735. }
  1736. if (steelMeter != null) {
  1737. amsSaleMaterial.setSteelMeter(DataChange.dataToBigDecimal(steelMeter));
  1738. }
  1739. if (materialWeight != null) {
  1740. amsSaleMaterial.setMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  1741. omstruckOrderMaterial.setOrderMaterialWeight(DataChange.dataToBigDecimal(materialWeight));
  1742. }
  1743. amsSaleMaterial.setSaleOrderId(saleOrderId);
  1744. amsSaleMaterial.setIsPoundSale(isPoundSale);
  1745. amsSaleMaterial.setMaterialId(materialId);
  1746. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1747. amsSaleMaterial.setMaterialNumber(materialNumber);
  1748. amsSaleMaterial.setUpdateTime(new Date());
  1749. result += amsSaleMaterialMapper.insertSelective(amsSaleMaterial);
  1750. // 车序号子表
  1751. amsSaleTrucknoMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
  1752. amsSaleTrucknoMaterial.setMaterialId(amsSaleMaterial.getSaleMaterialId());
  1753. amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
  1754. amsSaleTrucknoMaterial.setUpdateTime(new Date());
  1755. result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
  1756. // 运输订单子表
  1757. omstruckOrderMaterial.setOrderMaterialId(omstruckOrderMaterialMapper.selectMaxId());
  1758. omstruckOrderMaterial.setOrderId(orderId);
  1759. omstruckOrderMaterial.setMaterialId(materialId);
  1760. omstruckOrderMaterial.setOrderMaterialNumber(materialNumber);
  1761. result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
  1762. }
  1763. // 得到运单中的物资
  1764. List<Map<String, Object>> newList = omstruckOrderMaterialMapper.getMaterialList(orderId);
  1765. toTmsMap.put("newMaterialMapList", newList);
  1766. // 修改实绩结果
  1767. Map<String, Object> updateResult = tmsTruckFeign.update(toTmsMap);
  1768. System.out.println(updateResult);
  1769. return result;
  1770. }
  1771. /**
  1772. * 副产品订单
  1773. * @param map
  1774. * @return
  1775. */
  1776. @Override
  1777. public List<Map<String, Object>> getFuSaleOrderList(Map<String, Object> map) {
  1778. List<Map<String, Object>> resultList = amsSaleOrderMapper.getFuSaleOrderList(map);
  1779. return resultList;
  1780. }
  1781. /**
  1782. * 同步关闭金蝶销售订单
  1783. * @param mapValue
  1784. * @return
  1785. */
  1786. @Override
  1787. public int deleteSaleOrderSame(Map<String, Object> mapValue) {
  1788. int result = 0;
  1789. BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
  1790. String reason = (String) mapValue.get("reason");
  1791. String number = (String) mapValue.get("number");
  1792. Map<String,Object> head = new HashMap<>();
  1793. Map<String,Object> input = new HashMap<>();
  1794. // 销售订单号
  1795. input.put("number",number);
  1796. Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  1797. totalMap.put("input",input);
  1798. // 调用金蝶关闭接口
  1799. String json = JSONUtils.toJSONString(totalMap);
  1800. System.out.println(json);
  1801. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  1802. System.out.println(resultMap);
  1803. AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
  1804. amsSaleOrder.setSaleOrderId(saleOrderId);
  1805. amsSaleOrder.setDeleted(new BigDecimal(2));
  1806. amsSaleOrder.setInsertUpdateRemark(reason);
  1807. result += amsSaleOrderMapper.closeOrderNotIn(saleOrderId);
  1808. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  1809. return result;
  1810. }
  1811. /**
  1812. * 展示反审批的钢材订单
  1813. * @param mapValue
  1814. * @return
  1815. */
  1816. @Override
  1817. public List<Map<String, Object>> getSteelOrderDeletedList(Map<String, Object> mapValue) {
  1818. List<Map<String, Object>> mapList = amsSaleOrderMapper.getSteelOrderDeletedList(mapValue);
  1819. return mapList;
  1820. }
  1821. /**
  1822. * 展示所有状态销售订单列表
  1823. * @param mapValue
  1824. * @return
  1825. */
  1826. @Override
  1827. public List<Map<String, Object>> getAllSteelSaleOrderList(Map<String, Object> mapValue) {
  1828. return amsSaleOrderMapper.getAllSteelSaleOrderList(mapValue);
  1829. }
  1830. /**
  1831. * 修改厂内未装货车辆的运单车牌号
  1832. * @param mapValue
  1833. * @return
  1834. */
  1835. @Override
  1836. public int updateCapacityNumberInFactory(Map<String, Object> mapValue) {
  1837. Object lineSequence = mapValue.get("lineSequence");
  1838. int result = 0;
  1839. try{
  1840. //查询输入进来的车牌号是否与原有车牌号一致,如果一致则退出
  1841. BigDecimal oldCapacityId = omstruckOrderMapper.getOldCapacityId(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1842. if(oldCapacityId.compareTo(DataChange.dataToBigDecimal(mapValue.get("capacityId"))) == 0){
  1843. return 1;
  1844. }
  1845. if (lineSequence == null || "0".equals(lineSequence.toString()) || "1".equals(lineSequence.toString()) || "2".equals(lineSequence.toString())) {
  1846. String capacityids="";
  1847. Integer capacityid1= (Integer) mapValue.get("capacityIds");
  1848. Integer capacityid2= (Integer) mapValue.get("capacityId");
  1849. if (capacityid1!=null && !("".equals(capacityid1))){
  1850. capacityids=capacityid1+","+capacityid2;
  1851. }
  1852. mapValue.put("capacityids",capacityids);
  1853. //这是修改车牌号
  1854. //将排队信息删掉
  1855. Map<String, Object> isSpellingMap = omstruckOrderMapper.getSteelIsSpelling(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1856. if(isSpellingMap != null){
  1857. int isSpelling = DataChange.dataToBigDecimal(isSpellingMap.get("isSpelling")).intValue();
  1858. if(isSpelling == 1){
  1859. result += omstruckOrderMapper.deleteSpellingList(isSpellingMap.get("listId"));
  1860. }else{
  1861. result += omstruckOrderMapper.deleteQueueList(isSpellingMap.get("listId"));
  1862. }
  1863. }
  1864. result += amsSaleOrderMapper.updateCapacityNumberInFactory(mapValue);
  1865. //若是接单之后还需要删除实绩且将状态变为4
  1866. //查询运输订单的状态和总实绩ID
  1867. Map<String, Object> orderMesMap = amsSaleOrderMapper.getOrderMes(mapValue);
  1868. BigDecimal resultTotalId = DataChange.dataToBigDecimal(orderMesMap.get("resultTotalId"));
  1869. //删除排队实绩
  1870. if (resultTotalId !=null && !("".equals(resultTotalId))){
  1871. omstruckOrderMapper.deleteQueuingPerformance(resultTotalId);
  1872. }
  1873. if(DataChange.dataToBigDecimal(orderMesMap.get("orderStatus")).intValue() == 5){
  1874. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1875. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(mapValue.get("orderId")));
  1876. omstruckOrder.setOrderStatus(new BigDecimal(4));
  1877. omstruckOrder.setOrderLineSequence(new BigDecimal(0));
  1878. /*omstruckOrder.set*/
  1879. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1880. result += omstruckOrderMapper.deleteEnResult(resultTotalId);
  1881. result += omstruckOrderMapper.deleteWeightResult(resultTotalId);
  1882. result += omstruckOrderMapper.deleteLoadResult(resultTotalId);
  1883. result += omstruckOrderMapper.deleteLeaveResult(resultTotalId);
  1884. }
  1885. }
  1886. }catch (Exception e){
  1887. System.out.println("e"+e.getMessage());
  1888. }
  1889. return result;
  1890. }
  1891. @Override
  1892. public int updateConsigneeTel(Map<String, Object> mapValue) {
  1893. String saleOrderNo= (String) mapValue.get("saleOrderNo");
  1894. Integer saleOrderMaterialId= (Integer) mapValue.get("saleOrderMaterialId");
  1895. String consigneeTel= (String) mapValue.get("consigneeTel");
  1896. int result = 0;
  1897. if (saleOrderNo!=null&&!("".equals(saleOrderNo)) && saleOrderMaterialId!=null && !("".equals(saleOrderMaterialId))){
  1898. BigDecimal id = DataChange.dataToBigDecimal(saleOrderMaterialId);
  1899. if (id!=null&&!("".equals(id))){
  1900. result += amsSaleOrderMapper.updateForTel(id,consigneeTel);
  1901. }
  1902. }
  1903. return result;
  1904. }
  1905. @Override
  1906. public List<Map<String, Object>> getSaleMaterialId(BigDecimal saleOrderMaterialId) {
  1907. return amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  1908. }
  1909. /**
  1910. * 展示下发给承运商的车序号和物资
  1911. * @param map
  1912. * @return
  1913. */
  1914. @Override
  1915. public List<Map<String, Object>> getCarrierTruckNoAndMaterialList(Map<String,Object> map) {
  1916. Object carrierSsoId = map.get("carrierSsoId");
  1917. if (carrierSsoId != null && ("".equals(carrierSsoId)) || "null".equals(carrierSsoId) || "undefined".equals(carrierSsoId)) {
  1918. map.replace("carrierSsoId",null);
  1919. }
  1920. List<Map<String,Object>> mapList = amsSaleOrderMapper.getTruckNoAndMaterial(map);
  1921. for (Map<String,Object> mapValue : mapList) {
  1922. BigDecimal placeId = (BigDecimal) mapValue.get("placeId");
  1923. if (placeId != null) {
  1924. List<Map<String, Object>> carrierAndPriceList = getCarrierByPlace(placeId);
  1925. mapValue.put("carrierAndPriceList", carrierAndPriceList);
  1926. }
  1927. }
  1928. return mapList;
  1929. }
  1930. @Override
  1931. public int updateAMSDeleted(BigDecimal closeWlEntryId) {
  1932. return amsSaleOrderMapper.updateAMSDeleted(closeWlEntryId);
  1933. }
  1934. /**
  1935. * 同步关闭金蝶物资分录
  1936. * @param mapValue
  1937. * @return
  1938. */
  1939. @Override
  1940. @Transactional
  1941. public int closeSteelMaterialId(Map<String, Object> mapValue) {
  1942. int result = 0;
  1943. Object orderId = mapValue.get("orderId");
  1944. Integer orderStatus = (Integer) mapValue.get("orderStatus");
  1945. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleOrderMaterialId"));
  1946. List<Map<String, Object>> loadIdList = amsSaleMaterialMapper.findLoadIdList(saleOrderMaterialId);
  1947. List<Map<String, Object>> weightIdList = amsSaleMaterialMapper.findWeightIdList(saleOrderMaterialId);
  1948. String reason = (String) mapValue.get("reason");
  1949. BigDecimal saleMaterialId = DataChange.dataToBigDecimal(mapValue.get("saleMaterialId"));
  1950. // 如果还未派车
  1951. if (orderId == null) {
  1952. // 订单子表设为关闭状态
  1953. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1954. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1955. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1956. amsSaleMaterial.setInsertUpdateRemark(reason);
  1957. result += amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1958. return result;
  1959. }
  1960. orderStatus = omstruckOrderMapper.getOrderStatus(DataChange.dataToBigDecimal(orderId));
  1961. // 订单子表设为关闭状态
  1962. AmsSaleMaterial amsSaleMaterial = new AmsSaleMaterial();
  1963. amsSaleMaterial.setSaleMaterialId(saleMaterialId);
  1964. amsSaleMaterial.setDeleted(new BigDecimal(0));
  1965. amsSaleMaterial.setInsertUpdateRemark(reason);
  1966. // 已派车
  1967. if ((loadIdList == null || loadIdList.size() == 0) && orderStatus == 5) {
  1968. return result;
  1969. }
  1970. //判断关闭分录是否为最后一拼
  1971. int asmMaterialCount = amsSaleMaterialMapper.getSaleMaterialDelete(saleOrderMaterialId);
  1972. if (asmMaterialCount > 1 && orderStatus == 5) {
  1973. // 删除实绩表
  1974. Map<String, Object> loadMap = loadIdList.get(0);
  1975. Map<String, Object> weightMap = weightIdList.get(0);
  1976. BigDecimal loadId = (BigDecimal) loadMap.get("loadId");
  1977. BigDecimal weightId = (BigDecimal) weightMap.get("weightId");
  1978. result += amsSaleMaterialMapper.deleteLoadResult(loadId);
  1979. result += amsSaleMaterialMapper.deleteWeightResult(weightId);
  1980. result += amsSaleMaterialMapper.deleteWmspOutResult(mapValue);
  1981. }else if(asmMaterialCount <= 1){
  1982. //关闭运输订单
  1983. OmstruckOrder omstruckOrder = new OmstruckOrder();
  1984. omstruckOrder.setOrderId(DataChange.dataToBigDecimal(orderId));
  1985. //如果是单拼或者只剩一条分录没有关闭了则将状态设为7
  1986. omstruckOrder.setOrderStatus(new BigDecimal(7));
  1987. omstruckOrder.setUpdateTime(new Date());
  1988. omstruckOrder.setInsertUpdateRemark("关闭分录,同步关闭运输订单");
  1989. result += omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  1990. }
  1991. result += amsSaleMaterialMapper.updateByPrimaryKeySelective(amsSaleMaterial);
  1992. result += amsSaleMaterialMapper.updateOrderMaterialToClose(mapValue);
  1993. return result;
  1994. }
  1995. /**
  1996. * 展示已审核化产焦炭销售订单列表
  1997. * @param mapValue
  1998. * @return
  1999. */
  2000. @Override
  2001. public List<Map<String, Object>> getSaleCokeOrder(Map<String, Object> mapValue) {
  2002. List<Map<String, Object>> resultList = amsSaleOrderMapper.getSaleCokeOrder(mapValue);
  2003. return resultList;
  2004. }
  2005. /**
  2006. * 反关闭金蝶单个分录
  2007. * @param saleMaterialId
  2008. * @return
  2009. */
  2010. @Override
  2011. public int adverseCloseSaleMaterial(BigDecimal saleMaterialId) {
  2012. Map<String,Object> head = new HashMap<>();
  2013. Map<String,Object> input = new HashMap<>();
  2014. // 0:代表不关闭整单
  2015. String wholeOrder = "0";
  2016. // unClose : 代表反关闭
  2017. String status = "unClose";
  2018. AmsSaleMaterial amsSaleMaterial = amsSaleMaterialMapper.selectByPrimaryKey(saleMaterialId);
  2019. int result = amsSaleMaterialMapper.adverseCloseSaleMaterial(saleMaterialId);
  2020. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(amsSaleMaterial.getSaleOrderId());
  2021. // 根据分录id查询运单id,物资id,总实绩id
  2022. Map<String,Object> saleMaterialMap = amsSaleOrderMapper.getSaleMaterialMessage(saleMaterialId);
  2023. BigDecimal orderId = (BigDecimal) saleMaterialMap.get("orderId");
  2024. BigDecimal orderStatus = (BigDecimal) saleMaterialMap.get("orderStatus");
  2025. //查询订单字表条数
  2026. int orderMaterialNum = omstruckOrderMapper.getOrderMaterialNum(orderId);
  2027. //查询计量实绩条数
  2028. int weightResultNum = omstruckOrderMapper.getWeightResultNum(orderId);
  2029. if (orderId != null && orderStatus.intValue() == 5 && orderMaterialNum != weightResultNum) {
  2030. BigDecimal resultTotalId = (BigDecimal) saleMaterialMap.get("resultTotalId");
  2031. BigDecimal materialId = (BigDecimal) saleMaterialMap.get("materialId");
  2032. // 根据总实绩id查询订单中的最大路段顺序号
  2033. // 得到皮重顺序号
  2034. int tareNum = (weightResultNum + 1) * 3 - 1;
  2035. // 得到装货顺序号
  2036. int loadNum = (weightResultNum + 1) * 3;
  2037. // 得到毛重顺序号
  2038. int grossNum = (weightResultNum + 1) * 3 + 1;
  2039. // 装货实绩
  2040. TmstruckLoadResult tmstruckLoadResult = new TmstruckLoadResult();
  2041. TmstruckWeightResult tmstruckWeightResult = new TmstruckWeightResult();
  2042. tmstruckLoadResult.setResultId(tmstruckLoadResultMapper.selectMaxId());
  2043. tmstruckLoadResult.setResultTotalId(resultTotalId);
  2044. tmstruckLoadResult.setSegmentSqe(new BigDecimal(loadNum));
  2045. result += tmstruckLoadResultMapper.insertSelective(tmstruckLoadResult);
  2046. // 计量实绩
  2047. tmstruckWeightResult.setWeightTaskResultId(tmstruckWeightResultMapper.selectMaxId());
  2048. tmstruckWeightResult.setResultTotalId(resultTotalId);
  2049. tmstruckWeightResult.setResultTarePlaceId(new BigDecimal(10));
  2050. tmstruckWeightResult.setResultGrossPlaceId(new BigDecimal(2));
  2051. tmstruckWeightResult.setGrossSegmentSqe(new BigDecimal(grossNum));
  2052. tmstruckWeightResult.setTareSegmentSqe(new BigDecimal(tareNum));
  2053. result += tmstruckWeightResultMapper.insertSelective(tmstruckWeightResult);
  2054. // 出库子表
  2055. BigDecimal outBoundId = (BigDecimal) saleMaterialMap.get("outBoundId");
  2056. BigDecimal materialNumber = (BigDecimal) saleMaterialMap.get("materialNumber");
  2057. if (outBoundId != null) {
  2058. BigDecimal resultMaterialId = wmspOutboundResultMaterialMapper.getSeqNumber("seq__WMSP_OUTBOUND_RESUL_TMATRIAL");
  2059. WmspOutboundResultMaterial wmspOutboundResultMaterial = new WmspOutboundResultMaterial();
  2060. wmspOutboundResultMaterial.setResultMaterialId(resultMaterialId);
  2061. wmspOutboundResultMaterial.setOutboundResultId(outBoundId);
  2062. wmspOutboundResultMaterial.setMaterialId(materialId);
  2063. wmspOutboundResultMaterial.setMaterialNumber(materialNumber);
  2064. wmspOutboundResultMaterial.setInsertTime(new Date());
  2065. wmspOutboundResultMaterial.setInsertUsername("admin");
  2066. wmspOutboundResultMaterial.setStatus(new BigDecimal(1));
  2067. result += wmspOutboundResultMaterialMapper.insertSelective(wmspOutboundResultMaterial);
  2068. }
  2069. }
  2070. //去掉取消装货
  2071. result += omstruckOrderMaterialMapper.updateOmsMaterial(saleMaterialMap);
  2072. if (orderId != null && orderStatus.intValue() == 7) {
  2073. //如果订单被关闭,那么还原
  2074. //判断下面有没有实绩
  2075. int resultCount = omstruckOrderMapper.getResultCount(orderId);
  2076. OmstruckOrder omstruckOrder = new OmstruckOrder();
  2077. if (resultCount == 0) {
  2078. omstruckOrder.setOrderId(orderId);
  2079. omstruckOrder.setOrderStatus(new BigDecimal(4));
  2080. omstruckOrder.setInsertUpdateRemark("反关闭分录,运单同步开启");
  2081. omstruckOrder.setUpdateTime(new Date());
  2082. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  2083. }else{
  2084. omstruckOrder.setOrderId(orderId);
  2085. omstruckOrder.setOrderStatus(new BigDecimal(5));
  2086. omstruckOrder.setInsertUpdateRemark("反关闭分录,运单同步开启");
  2087. omstruckOrder.setUpdateTime(new Date());
  2088. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  2089. }
  2090. }
  2091. // 设置反关闭分录id
  2092. head.put("unCloseEntryId",amsSaleMaterial.getEasPrimaryId());
  2093. // 设置是否整单
  2094. head.put("wholeOrder",wholeOrder);
  2095. // 设置销售订单号
  2096. head.put("number",amsSaleOrder.getSaleNumber());
  2097. // 设置状态:unClose,反关闭;close,关闭
  2098. head.put("status",status);
  2099. input.put("head",head);
  2100. // 测试
  2101. Map<String, Object> totalMap = easUtil.getTotalMap();
  2102. // 正式
  2103. // Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  2104. input.put("head",head);
  2105. totalMap.put("input",input);
  2106. // 调用金蝶关闭接口
  2107. String json = JSONUtils.toJSONString(totalMap);
  2108. System.out.println(json);
  2109. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2110. System.out.println(resultMap);
  2111. return result;
  2112. }
  2113. /**
  2114. * 反关闭金蝶整个销售订单
  2115. * @param saleOrderId
  2116. * @return
  2117. */
  2118. @Override
  2119. public int adverseCloseSaleOrder(BigDecimal saleOrderId) {
  2120. Map<String,Object> head = new HashMap<>();
  2121. Map<String,Object> input = new HashMap<>();
  2122. // 0:代表不关闭整单
  2123. String wholeOrder = "1";
  2124. // unClose : 代表反关闭
  2125. String status = "unClose";
  2126. AmsSaleOrder amsSaleOrder = amsSaleOrderMapper.selectByPrimaryKey(saleOrderId);
  2127. amsSaleOrder.setDeleted(new BigDecimal(0));
  2128. // 开启所有的分录
  2129. int result = amsSaleMaterialMapper.openAllSaleMaterial(amsSaleOrder.getSaleOrderId());
  2130. result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
  2131. // 设置是否整单
  2132. head.put("wholeOrder",wholeOrder);
  2133. // 设置销售订单号
  2134. head.put("number",amsSaleOrder.getSaleNumber());
  2135. // 设置状态:unClose,反关闭;close,关闭
  2136. head.put("status",status);
  2137. input.put("head",head);
  2138. // 测试
  2139. Map<String, Object> totalMap = easUtil.getTotalMap();
  2140. // 正式
  2141. // Map<String, Object> totalMap = easDeleteUtil.getTotalMap();
  2142. input.put("head",head);
  2143. totalMap.put("input",input);
  2144. // 调用金蝶关闭接口
  2145. String json = JSONUtils.toJSONString(totalMap);
  2146. System.out.println(json);
  2147. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2148. System.out.println(resultMap);
  2149. return result;
  2150. }
  2151. @Override
  2152. public List<Map<String, Object>> getKucunList(Map<String, Object> map) {
  2153. return amsSaleOrderMapper.getKucunList(map);
  2154. }
  2155. //反关闭
  2156. @Override
  2157. public int reverseCloseOrder(Map<String, Object> map) {
  2158. Integer isOpenEas = (Integer) map.get("isOpenEas");
  2159. String operateName = (String) map.get("operateName");
  2160. int result = 0;
  2161. // 运输订单id
  2162. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  2163. // 车序号id
  2164. BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
  2165. Map<String,Object> head = new HashMap<>();
  2166. Map<String,Object> input = new HashMap<>();
  2167. // 0:代表不关闭整单
  2168. String wholeOrder = "0";
  2169. // unClose : 代表反关闭
  2170. String status = "unClose";
  2171. if( orderId != null && orderId.intValue() != 0){
  2172. //根据订单id查询下面的实绩个数
  2173. int resultCount = amsSaleMaterialMapper.getOrderResults(orderId);
  2174. OmstruckOrder omstruckOrder = new OmstruckOrder();
  2175. omstruckOrder.setOrderId(orderId);
  2176. if(resultCount == 0){
  2177. omstruckOrder.setOrderStatus(new BigDecimal(4));
  2178. }else{
  2179. omstruckOrder.setOrderStatus(new BigDecimal(5));
  2180. }
  2181. if(operateName != null){
  2182. omstruckOrder.setOptionerCode(operateName);
  2183. }
  2184. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  2185. // 根据车序号主键修改子表
  2186. amsSaleMaterialMapper.updateSaleMaterial(saleOrderMaterialId);
  2187. //查询分录ID,修改金蝶
  2188. List<Map<String,Object>> saleMaterialIdList = amsSaleOrderMapper.getSaleMaterialId(saleOrderMaterialId);
  2189. for(Map<String,Object> easMap:saleMaterialIdList){
  2190. // 设置反关闭分录id
  2191. head.put("unCloseEntryId",easMap.get("closeEntryId"));
  2192. // 设置是否整单
  2193. head.put("wholeOrder",wholeOrder);
  2194. // 设置销售订单号
  2195. head.put("number",map.get("saleNumber"));
  2196. // 设置状态:unClose,反关闭;close,关闭
  2197. head.put("status",status);
  2198. input.put("head",head);
  2199. Map<String, Object> totalMap = easUtil.getTotalMap();
  2200. input.put("head",head);
  2201. totalMap.put("input",input);
  2202. // 调用金蝶关闭接口
  2203. String json = JSONUtils.toJSONString(totalMap);
  2204. System.out.println(json);
  2205. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2206. System.out.println(resultMap);
  2207. }
  2208. return 0;
  2209. }
  2210. return 1;
  2211. }
  2212. @Override
  2213. public int getSaleOrderStatus(String saleNumber) {
  2214. int result = 0;
  2215. Map<String,Object> input = new HashMap<>();
  2216. // 销售订单号
  2217. input.put("number",saleNumber);
  2218. Map<String, Object> totalMap = easSaleOrderStatusUtil.getTotalMap();
  2219. totalMap.put("input",input);
  2220. // 调用金蝶关闭接口
  2221. String json = JSONUtils.toJSONString(totalMap);
  2222. System.out.println(json);
  2223. Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
  2224. System.out.println(resultMap);
  2225. String outPutMap = (String) resultMap.get("output");
  2226. JSONObject jsonObject = JSON.parseObject(outPutMap);
  2227. if(jsonObject != null){
  2228. result = DataChange.dataToBigDecimal(jsonObject.get("NumberStatus")).intValue();
  2229. }
  2230. if(result == 7){
  2231. //如果为7则更新
  2232. amsSaleOrderMapper.updateSaleOrderStatus(saleNumber);
  2233. }
  2234. return result;
  2235. }
  2236. }