AmsSaleOrderServiceImpl.java 102 KB

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