BmstruckDetailsOrderServiceImpl.java 61 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351
  1. package com.steerinfo.dil.service.impl;
  2. import com.steerinfo.dil.feign.AmsFeign;
  3. import com.steerinfo.dil.feign.JoinApiFeign;
  4. import com.steerinfo.dil.feign.OmsFeign;
  5. import com.steerinfo.dil.mapper.AmsContractTransportPriceMapper;
  6. import com.steerinfo.dil.mapper.BmstruckDetailsOrderMapper;
  7. import com.steerinfo.dil.mapper.OmstruckOrderMapper;
  8. import com.steerinfo.dil.model.AmsContractTransportPrice;
  9. import com.steerinfo.dil.model.BmstruckDetailsOrder;
  10. import com.steerinfo.dil.model.OmstruckOrder;
  11. import com.steerinfo.dil.service.IBmstruckDetailsOrderService;
  12. import com.steerinfo.dil.util.DataChange;
  13. import com.steerinfo.dil.util.EASUtil;
  14. import com.steerinfo.dil.util.NoUtil;
  15. import com.steerinfo.dil.util.SaleLogUtil;
  16. import io.swagger.models.auth.In;
  17. import org.apache.shiro.crypto.hash.Hash;
  18. import org.junit.Test;
  19. import org.springframework.beans.factory.annotation.Autowired;
  20. import org.springframework.stereotype.Service;
  21. import org.springframework.transaction.annotation.Transactional;
  22. import javax.annotation.Resource;
  23. import java.lang.reflect.Array;
  24. import java.math.BigDecimal;
  25. import java.math.RoundingMode;
  26. import java.text.DecimalFormat;
  27. import java.util.*;
  28. import java.util.regex.Matcher;
  29. import java.util.regex.Pattern;
  30. /**
  31. * @Description:
  32. * @Author:HuJianGuo
  33. * @GreateTime:2021/9/24 17:34
  34. * @Version:V2.0
  35. */
  36. @Service
  37. public class BmstruckDetailsOrderServiceImpl implements IBmstruckDetailsOrderService {
  38. @Autowired
  39. BmstruckDetailsOrderMapper bmstruckDetailsOrderMapper;
  40. @Autowired
  41. BmstruckFormulaServiceImpl bmstruckFormulaService;
  42. @Autowired
  43. NoUtil noUtil;
  44. @Autowired
  45. JoinApiFeign joinApiFeign;
  46. @Autowired
  47. EASUtil easUtil;
  48. @Autowired
  49. OmstruckOrderMapper omstruckOrderMapper;
  50. @Autowired
  51. OmsFeign omsFeign;
  52. @Autowired
  53. AmsFeign amsFeign;
  54. @Autowired
  55. SaleLogUtil saleLogUtil;
  56. @Autowired
  57. AmsContractTransportPriceMapper amsContractTransportPriceMapper;
  58. //以下订单类型是需要算计量实绩的
  59. final private List<Integer> inwardTypeList = Arrays.asList(10,11,15,16,23,24,20,25);
  60. //以下订单类型是需要根据线路去匹配承运起止范围以及物资
  61. final private List<Integer> toLineAndMaterial = Arrays.asList(10,20,23,24);
  62. //以下订单类型是需要去根据固定承运起止范围以及物资
  63. final private List<Integer> fixLineList = Arrays.asList(15,16);
  64. //以下订单类型是钢材
  65. final private List<Integer> steelTypeList = Arrays.asList(25);
  66. /**
  67. * 展示汽运详单列表
  68. * @param mapVal
  69. * @return
  70. */
  71. @Override
  72. public List<Map<String, Object>> getTruckDetailsOrderList(Map<String, Object> mapVal) {
  73. Integer orderType = (Integer) mapVal.get("orderType");
  74. List<Map<String, Object>> truckDetailsOrderList;
  75. if (orderType <= 3 && orderType >= 1) {
  76. truckDetailsOrderList = bmstruckDetailsOrderMapper.getSaleTruckDetailsOrderList(mapVal);
  77. }
  78. else {
  79. truckDetailsOrderList = bmstruckDetailsOrderMapper.getTruckDetailsOrderList(mapVal);
  80. }
  81. return truckDetailsOrderList;
  82. }
  83. /**
  84. * 新增详单
  85. * @param orderId
  86. * @return
  87. */
  88. @Override
  89. public synchronized int insertSelective(BigDecimal orderId) throws Exception {
  90. System.out.println(orderId + "生成计费详单");
  91. List<Map<String,Object>> weightTaskResultIdList = bmstruckDetailsOrderMapper.getSteelWeightTaskResultId(orderId);
  92. //根据该id寻找相同的订单号
  93. List<BigDecimal> orderIds = bmstruckDetailsOrderMapper.getOrderIds(orderId);
  94. for (BigDecimal orderId1 : orderIds) {
  95. weightTaskResultIdList.addAll(bmstruckDetailsOrderMapper.getSteelWeightTaskResultId(orderId1));
  96. }
  97. Map<String,Object> priceMap = getPriceId(orderId);
  98. if (priceMap == null || priceMap.size() == 0) {
  99. return 0;
  100. }
  101. BigDecimal priceId = (BigDecimal) priceMap.get("priceId");
  102. if (priceId.intValue() == 0) {
  103. return 0;
  104. }
  105. int result = 0;
  106. for (Map<String, Object> map : weightTaskResultIdList) {
  107. if(map == null) {
  108. System.out.println("空Map,释放");
  109. continue;
  110. }
  111. BigDecimal weightTaskResultId = DataChange.dataToBigDecimal(map.get("weightTaskResultId"));
  112. if(weightTaskResultId == null) {
  113. System.out.println("计量实绩Id为空,释放");
  114. continue;
  115. }
  116. //判断该计量实绩有没有结算数据
  117. if(bmstruckDetailsOrderMapper.getIsHaveDetailsOrder(weightTaskResultId) > 0 ){
  118. continue;
  119. }
  120. BigDecimal netWeightIsNull = bmstruckDetailsOrderMapper.getNetWeight(weightTaskResultId);
  121. if (netWeightIsNull == null) {
  122. System.out.println("没有计量实绩,不生成结算数据:" + orderId);
  123. continue;
  124. }
  125. //BigDecimal detailsAmountOld=new BigDecimal(0);
  126. try {
  127. BigDecimal detailsAmountOld = generateTruckFees(orderId, weightTaskResultId);
  128. Double amount = detailsAmountOld.doubleValue();
  129. BigDecimal detailsAmount = new BigDecimal(amount).setScale(2,RoundingMode.HALF_UP);
  130. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  131. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  132. if (orderType.intValue() == 3) {
  133. BigDecimal purchaseOrderId = getFormulaMembers(orderId);
  134. bmstruckDetailsOrder.setPurchaseOrderId(purchaseOrderId);
  135. }
  136. if (orderType.intValue() == 2 || orderType.intValue() == 1) {
  137. bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(0));
  138. }
  139. // 得到最大id
  140. BigDecimal detailsId = selectMaxId();
  141. String detailsNo = noUtil.setResultNo("QYXD", detailsId);
  142. bmstruckDetailsOrder.setDetailsId(detailsId);
  143. bmstruckDetailsOrder.setWeightTaskResultId(weightTaskResultId);
  144. bmstruckDetailsOrder.setOrderId(orderId);
  145. bmstruckDetailsOrder.setDetailsNo(detailsNo);
  146. bmstruckDetailsOrder.setPriceId(priceId);
  147. bmstruckDetailsOrder.setDetailsAmount(detailsAmount);
  148. bmstruckDetailsOrder.setDetailsTime(new Date());
  149. // 设置常规字段
  150. bmstruckDetailsOrder.setInsertTime(new Date());
  151. bmstruckDetailsOrder.setUpdateTime(new Date());
  152. bmstruckDetailsOrder.setInsertUsername("admin");
  153. bmstruckDetailsOrder.setUpdateUsername("admin");
  154. bmstruckDetailsOrder.setInsertUpdateRemark("无");
  155. result += bmstruckDetailsOrderMapper.insertSelective(bmstruckDetailsOrder);
  156. }catch (Exception e){
  157. //不打印给控制台(有可能是正常情况)
  158. e.printStackTrace();
  159. }
  160. }
  161. return result;
  162. }
  163. /**
  164. * 新增详单(只为计费详单修改数据时才使用)
  165. * @param orderId
  166. * @return
  167. */
  168. @Override
  169. public synchronized int insertSelectiveNew(BigDecimal orderId) throws Exception {
  170. List<Map<String,Object>> weightTaskResultIdList = bmstruckDetailsOrderMapper.getSteelWeightTaskResultId(orderId);
  171. System.out.println("根据运单查询到的计量实绩数据为," + weightTaskResultIdList);
  172. Map<String,Object> priceMap = getPriceId(orderId);
  173. System.out.println("根据运单查询到单价数据为," + priceMap);
  174. if (priceMap == null || priceMap.size() == 0 || priceMap.get("priceId") == null) {
  175. return 0;
  176. }
  177. BigDecimal priceId = (BigDecimal) priceMap.get("priceId");
  178. //if (priceId.intValue() == 0) {
  179. // return 0;
  180. //}
  181. int result = 0;
  182. for (Map<String, Object> map : weightTaskResultIdList) {
  183. if(map == null) {
  184. System.out.println("map为空");
  185. continue;
  186. }
  187. BigDecimal weightTaskResultId = DataChange.dataToBigDecimal(map.get("weightTaskResultId"));
  188. if (weightTaskResultId == null) {
  189. System.out.println("计量实绩Id为空");
  190. continue;
  191. }
  192. //判断该计量实绩有没有结算数据
  193. if(bmstruckDetailsOrderMapper.getIsHaveDetailsOrder(weightTaskResultId) > 0 ){
  194. continue;
  195. }
  196. BigDecimal netWeightIsNull = bmstruckDetailsOrderMapper.getNetWeight(weightTaskResultId);
  197. if (netWeightIsNull == null) {
  198. System.out.println("没有计量实绩,不生成结算数据:" + orderId);
  199. continue;
  200. }
  201. //BigDecimal detailsAmountOld=new BigDecimal(0);
  202. try {
  203. BigDecimal detailsAmountOld = generateTruckFeesNew(orderId, weightTaskResultId);
  204. Double amount = detailsAmountOld.doubleValue();
  205. BigDecimal detailsAmount = new BigDecimal(amount).setScale(2,RoundingMode.HALF_UP);
  206. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  207. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  208. if (orderType.intValue() == 3) {
  209. BigDecimal purchaseOrderId = getFormulaMembers(orderId);
  210. bmstruckDetailsOrder.setPurchaseOrderId(purchaseOrderId);
  211. }
  212. if (orderType.intValue() == 2 || orderType.intValue() == 1) {
  213. bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(0));
  214. }
  215. // 得到最大id
  216. BigDecimal detailsId = selectMaxId();
  217. String detailsNo = noUtil.setResultNo("QYXD", detailsId);
  218. bmstruckDetailsOrder.setDetailsId(detailsId);
  219. bmstruckDetailsOrder.setWeightTaskResultId(weightTaskResultId);
  220. bmstruckDetailsOrder.setOrderId(orderId);
  221. bmstruckDetailsOrder.setDetailsNo(detailsNo);
  222. bmstruckDetailsOrder.setPriceId(priceId);
  223. bmstruckDetailsOrder.setDetailsAmount(detailsAmount);
  224. bmstruckDetailsOrder.setDetailsTime(new Date());
  225. // 设置常规字段
  226. bmstruckDetailsOrder.setInsertTime(new Date());
  227. bmstruckDetailsOrder.setUpdateTime(new Date());
  228. bmstruckDetailsOrder.setInsertUsername("admin");
  229. bmstruckDetailsOrder.setUpdateUsername("admin");
  230. bmstruckDetailsOrder.setInsertUpdateRemark("无");
  231. result += bmstruckDetailsOrderMapper.insertSelective(bmstruckDetailsOrder);
  232. System.out.println("订单生成了结算单据" + orderId);
  233. }catch (Exception e){
  234. //不打印给控制台(有可能是正常情况)
  235. e.printStackTrace();
  236. }
  237. }
  238. return result;
  239. }
  240. /**
  241. * 查询最大id
  242. * @return
  243. */
  244. @Override
  245. public BigDecimal selectMaxId() {
  246. return bmstruckDetailsOrderMapper.selectDetailsId();
  247. }
  248. /**
  249. * 展示汽运实绩列表
  250. * @param mapVal
  251. * @return
  252. */
  253. @Override
  254. public List<Map<String, Object>> getTruckResultList(Map<String, Object> mapVal) {
  255. BigDecimal orderId = (BigDecimal) mapVal.get("orderId") ;
  256. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  257. List<Map<String,Object>> mapList;
  258. if (orderType.intValue() <= 3 && orderType.intValue() >= 1) {
  259. mapList = bmstruckDetailsOrderMapper.getSaleTruckResultList(mapVal);
  260. }
  261. else {
  262. mapList = bmstruckDetailsOrderMapper.getTruckResultList(mapVal);
  263. }
  264. return mapList;
  265. }
  266. /**
  267. * 得到计算因子
  268. * @param orderId
  269. * @return
  270. */
  271. @Override
  272. public BigDecimal getFormulaMembers(BigDecimal orderId) {
  273. return bmstruckDetailsOrderMapper.getFormulaMembers(orderId);
  274. }
  275. /**
  276. * 得到价格id
  277. * @return
  278. */
  279. @Override
  280. public Map<String, Object> getPriceId(BigDecimal orderId) {
  281. return bmstruckDetailsOrderMapper.getPriceId(orderId);
  282. }
  283. /**
  284. * 得到单价
  285. * @param priceId
  286. * @return
  287. */
  288. @Override
  289. public BigDecimal getPriceValue(BigDecimal priceId) {
  290. return bmstruckDetailsOrderMapper.getPriceValue(priceId);
  291. }
  292. /**
  293. * 得到到厂湿重
  294. * @param weightTaskResultId
  295. * @return
  296. */
  297. @Override
  298. public BigDecimal getNetWeight(BigDecimal weightTaskResultId) {
  299. return bmstruckDetailsOrderMapper.getNetWeight(weightTaskResultId);
  300. }
  301. /**
  302. * 展示未转成销售账单的销售详单
  303. * @param mapVal
  304. * @param orderType
  305. * @return
  306. */
  307. @Override
  308. public List<Map<String, Object>> getUnFinishedTruckDetailsOrderList(Map<String, Object> mapVal, Integer orderType) {
  309. if (mapVal == null) {
  310. mapVal = new HashMap<>();
  311. }
  312. mapVal.put("orderType",new BigDecimal(orderType));
  313. return bmstruckDetailsOrderMapper.getUnFinishedTruckDetailsOrderList(mapVal);
  314. }
  315. //通过不同的值,查询未生成账单的计费详单
  316. @Override
  317. public List<Map<String, Object>> getUnFinishedConvertedTruckDetailsOrderList(Map<String, Object> mapVal, Integer orderType) {
  318. //orderType:1:计时,2:计数,3:计重,4:包月
  319. if(orderType==1){
  320. return bmstruckDetailsOrderMapper.getUnFinishedTimeTruckDetailsOrderList(mapVal);
  321. }
  322. else if(orderType==2){
  323. return bmstruckDetailsOrderMapper.getUnFinishedNumTruckDetailsOrderList(mapVal);
  324. }
  325. else if(orderType==3){
  326. return bmstruckDetailsOrderMapper.getUnFinishedWeightTruckDetailsOrderList(mapVal);
  327. }
  328. else if(orderType==4){
  329. return bmstruckDetailsOrderMapper.getUnFinishedMonthTruckDetailsOrderList(mapVal);
  330. }
  331. return null;
  332. }
  333. /**
  334. * 替换汽运费公式并进行计算
  335. * @param orderId
  336. * @return
  337. * @throws Exception
  338. */
  339. public BigDecimal generateTruckFees(BigDecimal orderId,BigDecimal weightTaskResultId) throws Exception {
  340. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  341. Map<String, Object> priceMap = getPriceId(orderId);
  342. BigDecimal priceId = (BigDecimal) priceMap.get("priceId");
  343. BigDecimal priceValue = getPriceValue(priceId);
  344. BigDecimal netWeight = getNetWeight(weightTaskResultId);
  345. //用于给单价id为2400的生成详单
  346. // if (priceValue==null||priceValue.compareTo(BigDecimal.ZERO)==0){
  347. // //该值为任意给的值
  348. // priceValue=BigDecimal.TEN;
  349. // }
  350. // 得到计费公式
  351. String formula_string = null;
  352. if (orderType.intValue() == 3) {
  353. // 得到采购汽运计费公式
  354. formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(8));
  355. // 替换采购汽运运计算公式
  356. formula_string = formula_string.replace("到厂计量湿吨",netWeight.toString())
  357. .replace("单价",priceValue.toString());
  358. }
  359. if (orderType.intValue() >= 1 && orderType.intValue() <= 3) {
  360. // BigDecimal distance = new BigDecimal(101);
  361. // 得到销售汽运计费公式
  362. // if (distance.intValue() >= 91 || distance.intValue() <= 109) {
  363. // 得到销售10km差距内的汽运计费公式
  364. formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(10));
  365. // 替换采购汽运运计算公式
  366. formula_string = formula_string.replace("运输单价",priceValue.toString())
  367. .replace("物资净重",netWeight.toString());
  368. // }
  369. // else {
  370. // // 得到销售10km差距外的汽运计费公式
  371. // formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(11));
  372. // // 替换采购汽运运计算公式
  373. // formula_string = formula_string.replace("运输单价",priceValue.toString())
  374. // .replace("运输距离",distance.toString())
  375. // .replace("物资净重",netWeight.toString());
  376. // }
  377. }
  378. String s = toSufExpr(formula_string);
  379. return calSufExpr(s);
  380. }
  381. /**
  382. * 钢材直接修改计算运费
  383. * @param priceValue
  384. * @param weightTaskResultId
  385. * @return
  386. * @throws Exception
  387. */
  388. public BigDecimal generateTruckFeesForDirect(BigDecimal priceValue,BigDecimal weightTaskResultId) throws Exception {
  389. BigDecimal netWeight = getNetWeight(weightTaskResultId);
  390. // 得到计费公式
  391. String formula_string = null;
  392. formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(10));
  393. // 替换采购汽运运计算公式
  394. formula_string = formula_string.replace("运输单价",priceValue.toString())
  395. .replace("物资净重",netWeight.toString());
  396. String s = toSufExpr(formula_string);
  397. return calSufExpr(s);
  398. }
  399. /**
  400. * 替换汽运费公式并进行计算(专为计费详单服务)
  401. * @param orderId
  402. * @return
  403. * @throws Exception
  404. */
  405. public BigDecimal generateTruckFeesNew (BigDecimal orderId,BigDecimal weightTaskResultId) throws Exception {
  406. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  407. Map<String, Object> priceMap = getPriceId(orderId);
  408. BigDecimal priceId = (BigDecimal) priceMap.get("priceId");
  409. BigDecimal priceValue = getPriceValue(priceId);
  410. BigDecimal netWeight = getNetWeight(weightTaskResultId);
  411. //用于给单价id为2400的生成详单
  412. if (priceValue==null||priceValue.compareTo(BigDecimal.ZERO)==0){
  413. //该值为任意给的值
  414. priceValue=BigDecimal.TEN;
  415. }
  416. // 得到计费公式
  417. String formula_string = null;
  418. if (orderType.intValue() == 3) {
  419. // 得到采购汽运计费公式
  420. formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(8));
  421. // 替换采购汽运运计算公式
  422. formula_string = formula_string.replace("到厂计量湿吨",netWeight.toString())
  423. .replace("单价",priceValue.toString());
  424. }
  425. if (orderType.intValue() >= 1 && orderType.intValue() <= 3) {
  426. // BigDecimal distance = new BigDecimal(101);
  427. // 得到销售汽运计费公式
  428. // if (distance.intValue() >= 91 || distance.intValue() <= 109) {
  429. // 得到销售10km差距内的汽运计费公式
  430. formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(10));
  431. // 替换采购汽运运计算公式
  432. formula_string = formula_string.replace("运输单价",priceValue.toString())
  433. .replace("物资净重",netWeight.toString());
  434. // }
  435. // else {
  436. // // 得到销售10km差距外的汽运计费公式
  437. // formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(11));
  438. // // 替换采购汽运运计算公式
  439. // formula_string = formula_string.replace("运输单价",priceValue.toString())
  440. // .replace("运输距离",distance.toString())
  441. // .replace("物资净重",netWeight.toString());
  442. // }
  443. }
  444. String s = toSufExpr(formula_string);
  445. return calSufExpr(s);
  446. }
  447. public BigDecimal updateSteelAmounts(Map<String,Object> map) throws Exception {
  448. BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  449. BigDecimal weightTaskResultId = DataChange.dataToBigDecimal(map.get("weightTaskResultId"));
  450. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  451. BigDecimal priceId = DataChange.dataToBigDecimal(map.get("priceId"));
  452. BigDecimal priceValue = getPriceValue(priceId);
  453. if(priceValue==null){
  454. //单价为Null,则返回0
  455. return new BigDecimal(0);
  456. }
  457. BigDecimal netWeight = getNetWeight(weightTaskResultId);
  458. // 得到计费公式
  459. String formula_string = null;
  460. if (orderType.intValue() >= 1 && orderType.intValue() <= 3) {
  461. // BigDecimal distance = new BigDecimal(101);
  462. // 得到销售汽运计费公式
  463. // if (distance.intValue() >= 91 || distance.intValue() <= 109) {
  464. // 得到销售10km差距内的汽运计费公式
  465. formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(10));
  466. // 替换采购汽运运计算公式
  467. formula_string = formula_string.replace("运输单价",priceValue.toString())
  468. .replace("物资净重",netWeight.toString());
  469. // }
  470. // else {
  471. // // 得到销售10km差距外的汽运计费公式
  472. // formula_string = bmstruckFormulaService.getTruckFormula(new BigDecimal(11));
  473. // // 替换采购汽运运计算公式
  474. // formula_string = formula_string.replace("运输单价",priceValue.toString())
  475. // .replace("运输距离",distance.toString())
  476. // .replace("物资净重",netWeight.toString());
  477. // }
  478. }
  479. String s = toSufExpr(formula_string);
  480. return calSufExpr(s);
  481. }
  482. /**
  483. * 中缀转换后缀表达式
  484. */
  485. public String toSufExpr(String s) {
  486. StringBuffer sufExpr = new StringBuffer();
  487. Stack<String> stack = new Stack<>();
  488. //压入空方便判断
  489. stack.push(null);
  490. Pattern pattern = Pattern.compile("\\(int\\)|(?<!\\d|[)])-?\\d+(\\.\\d+)?|!=|>=|<=|==|[+\\-*/%()><=|]");
  491. Matcher matcher = pattern.matcher(s);
  492. while (matcher.find()) {
  493. String group = matcher.group();
  494. if (group.matches("!=|>=|<=|==|[+\\-*/%()><=|]|\\(int\\)")) {//是运算符
  495. if (group.equals("(")) {//之间压栈
  496. stack.push(group);
  497. } else if (group.equals(")")) {//等于右括号,一直弹栈,直到遇到左括号
  498. String pop = null;
  499. while (!(pop = stack.pop()).equals("(")) {//遍历循环至左括号
  500. sufExpr.append(pop + " ");
  501. }
  502. } else {//是运算符:加减乘除强转,根据优先级压栈
  503. while (getPriority(group) <= getPriority(stack.peek())) {
  504. String pop = stack.pop();
  505. System.out.println(pop);
  506. System.out.println(sufExpr);
  507. if(pop!=null&&!pop.equals("|")){
  508. sufExpr.append(pop + " ");
  509. }
  510. }
  511. stack.push(group);
  512. }
  513. } else {//是数字
  514. sufExpr.append(group + " ");
  515. }
  516. }
  517. String pop = null;
  518. while (null != (pop = stack.pop())) {
  519. sufExpr.append(pop + " ");
  520. }
  521. return sufExpr.toString();
  522. }
  523. /**
  524. * 设置出栈优先级,(:优先级最低,表示只有遇到)才能出栈
  525. * 当栈顶遇到优先级比自己小或等于的弹栈
  526. */
  527. public Integer getPriority(String c) {
  528. if (c == null) {
  529. return 0;
  530. }
  531. switch (c) {
  532. case "(":
  533. return 1;
  534. case "+":
  535. case "-":
  536. return 2;
  537. case "*":
  538. case "/":
  539. case "%":
  540. return 3;
  541. case ">":
  542. case "<":
  543. case ">=":
  544. case "<=":
  545. case "!=":
  546. case "==":
  547. return 4;
  548. case "|":
  549. return 5;
  550. case "=":
  551. return 6;
  552. case "(int)":
  553. return 7;
  554. }
  555. return 0;
  556. }
  557. /**
  558. * 计算值
  559. */
  560. public BigDecimal cal(BigDecimal a1, BigDecimal a2, String operator) throws Exception {
  561. switch (operator){
  562. case "+":return a1.add(a2);
  563. case "-":return a1.subtract(a2);
  564. case "*":return a1.multiply(a2);
  565. case "/":return a1.divide(a2,3,BigDecimal.ROUND_CEILING);
  566. case "%":return a1.divideAndRemainder(a2)[1];
  567. default:
  568. break;
  569. }
  570. throw new Exception("非法运算符");
  571. }
  572. public Boolean calBoolean(BigDecimal a1, BigDecimal a2, String operator) throws Exception {
  573. switch (operator){
  574. case ">":return a1.compareTo(a2) == 1;
  575. case "<":return a1.compareTo(a2) == -1;
  576. case ">=":return a1.compareTo(a2) > -1;
  577. case "<=":return a1.compareTo(a2) < 1;
  578. case "!=":return a1.compareTo(a2) != 0;
  579. case "==":return a1.compareTo(a2) == 0;
  580. default:
  581. break;
  582. }
  583. throw new Exception("非法运算符");
  584. }
  585. /**
  586. * 计算后缀表达式
  587. */
  588. public BigDecimal calSufExpr(String sufExpr) throws Exception {
  589. Stack<BigDecimal> stack = new Stack<>();
  590. Pattern pattern=Pattern.compile("\\(int\\)|-?\\d+(\\.\\d+)?|!=|>=|<=|==|[+\\-*/%><=]");//提取运算符和数字
  591. Matcher matcher = pattern.matcher(sufExpr);
  592. BigDecimal result=new BigDecimal("0.0");
  593. while (matcher.find()){
  594. String group = matcher.group();
  595. if(group.matches("[+\\-*/%]")){
  596. BigDecimal a1 =stack.pop();
  597. BigDecimal a2 =stack.pop();
  598. result = cal(a2, a1, group);
  599. stack.push(result);
  600. }
  601. else if(group.equals("(int)")){
  602. BigDecimal pop = stack.pop();
  603. BigDecimal bigDecimal = pop.setScale(0, BigDecimal.ROUND_DOWN);
  604. stack.push(bigDecimal);
  605. }
  606. else if(group.matches("!=|>=|<=|==|[><]")){
  607. BigDecimal a1 =stack.pop();
  608. BigDecimal a2 =stack.pop();
  609. stack.push(calBoolean(a2,a1,group)?new BigDecimal(1):new BigDecimal(0));
  610. }
  611. else if(group.equals("=")){
  612. BigDecimal a1 =stack.pop();
  613. BigDecimal a2 =stack.pop();
  614. if (a2.compareTo(new BigDecimal(1))==0) {
  615. stack.push(a1);
  616. }
  617. }
  618. else {//为数字直接压栈
  619. stack.push(new BigDecimal(group));
  620. }
  621. }
  622. return result;
  623. }
  624. /**
  625. * 新增内转汽运详单
  626. * @param orderId
  627. * @return
  628. * @throws Exception
  629. */
  630. @Override
  631. public int addConvertedDetailsOrder(BigDecimal orderId) throws Exception {
  632. // 得到最大id
  633. BigDecimal detailsId = selectMaxId();
  634. String detailsNo = noUtil.setResultNo("QYXD", detailsId);
  635. // 新增详单实体
  636. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  637. // 设置常规字段
  638. bmstruckDetailsOrder.setInsertTime(new Date());
  639. bmstruckDetailsOrder.setInsertUsername("admin");
  640. bmstruckDetailsOrder.setInsertUpdateRemark("无");
  641. // 通过订单号获取物资信息以及结算方式
  642. Map<String, Object> mapVal=getSettlement(orderId);
  643. //需求类型(0:计重;1:计时;2:计次;3:包月)
  644. String requirementType=mapVal.get("requirementType").toString();
  645. Integer materialId =Integer.parseInt(mapVal.get("materialId").toString());
  646. //通过物资id以及结算方式获取单价;
  647. BigDecimal priceId=getPriceByWz(requirementType,materialId);
  648. // 将单价存入实体
  649. bmstruckDetailsOrder.setPriceId(priceId);
  650. // 获取物资数量/计时获取时长/计数为一次/包月为包月价
  651. if("0".equals(requirementType)){
  652. //通过单价ID获取单价
  653. BigDecimal price=getPriceValue(priceId);
  654. //获取物资重量
  655. BigDecimal weight=getNetWeight(priceId);
  656. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(price.doubleValue()*weight.doubleValue()));
  657. }
  658. else{
  659. //通过单价ID获取单价
  660. BigDecimal price=getPriceValue(priceId);
  661. bmstruckDetailsOrder.setDetailsAmount(price);
  662. }
  663. return bmstruckDetailsOrderMapper.insertSelective(bmstruckDetailsOrder);
  664. }
  665. //通过物资id以及结算方式获取单价;
  666. @Override
  667. public BigDecimal getPriceByWz(String requirementType, Integer materialId) {
  668. return bmstruckDetailsOrderMapper.getPriceByWz(requirementType,materialId);
  669. }
  670. @Override
  671. // 通过订单号获取物资信息以及结算方式
  672. public Map<String, Object> getSettlement(BigDecimal orderId) {
  673. return bmstruckDetailsOrderMapper.getSettlement(orderId);
  674. }
  675. /**
  676. * 修改详单
  677. * @param mapValue
  678. * @return
  679. */
  680. @Transactional
  681. @Override
  682. public synchronized int updateDetailsOrder(Map<String, Object> mapValue) {
  683. System.out.println("修改单价,时间:" + new Date() + "-----------" + mapValue);
  684. BigDecimal orderId = DataChange.dataToBigDecimal(mapValue.get("orderId"));
  685. BigDecimal priceId = DataChange.dataToBigDecimal(mapValue.get("priceId"));
  686. System.out.println("运单Id,为" + orderId);
  687. System.out.println("随接口传输过来的单价Id,为" + priceId);
  688. try {
  689. int i = insertSelectiveNew(orderId);
  690. } catch (Exception e) {
  691. //不打印给控制台(可能是正常情况)
  692. }
  693. //根据运输订单id查询计费详单id
  694. OmstruckOrder omstruckOrder = new OmstruckOrder();
  695. omstruckOrder.setOrderId(orderId);
  696. omstruckOrder.setPriceId(priceId);
  697. try{
  698. //通过userId查询出用户名
  699. String carrierName = bmstruckDetailsOrderMapper.getCarrierNameForPriceValue((String) mapValue.get("userId"));
  700. System.out.println("正在执行该操作的人员为:" + carrierName + "时间为:" + new Date()) ;
  701. //根据运输ID查询出记录下来的用户名
  702. String recordUserName = bmstruckDetailsOrderMapper.getUserName(orderId);
  703. if (recordUserName==null){
  704. omstruckOrder.setRecordUsername(carrierName+",");
  705. }else {
  706. String[] s = recordUserName.split(",");
  707. if (s.length < 2){
  708. omstruckOrder.setRecordUsername(recordUserName+carrierName+",");
  709. }else if (s.length ==2){
  710. omstruckOrder.setRecordUsername(recordUserName+carrierName);
  711. }else if (s.length==3){
  712. s[0]=s[1];
  713. s[1]=s[2];
  714. s[2]=carrierName;
  715. omstruckOrder.setRecordUsername(s[0]+","+s[1]+","+s[2]);
  716. }
  717. }
  718. }catch (Exception e){
  719. System.out.println("e"+e.getMessage());
  720. }
  721. omstruckOrderMapper.updateByPrimaryKeySelective(omstruckOrder);
  722. List<BigDecimal> detailIds = bmstruckDetailsOrderMapper.getDetailIds(orderId);
  723. int result = 0;
  724. for (BigDecimal detailsId : detailIds) {
  725. BmstruckDetailsOrder bmstruckDetailsOrder = bmstruckDetailsOrderMapper.selectByPrimaryKey(detailsId);
  726. bmstruckDetailsOrder.setHistoryDetailsAmount(bmstruckDetailsOrder.getDetailsAmount());
  727. // 重新设置单价
  728. BigDecimal priceId1 = bmstruckDetailsOrder.getPriceId();
  729. bmstruckDetailsOrder.setPriceids(priceId1+","+priceId);
  730. bmstruckDetailsOrder.setPriceId(priceId);
  731. BigDecimal weightTaskResultId = bmstruckDetailsOrder.getWeightTaskResultId();
  732. Map<String,Object> map = new HashMap<>();
  733. map.put("orderId",orderId);
  734. map.put("weightTaskResultId",weightTaskResultId);
  735. map.put("priceId",priceId);
  736. try {
  737. // 计算出新的详单金额
  738. BigDecimal newAmount = updateSteelAmounts(map);
  739. bmstruckDetailsOrder.setDetailsAmount(newAmount.divide(new BigDecimal(1),2, RoundingMode.HALF_UP));
  740. //修改单价的历史时间
  741. //omstruckOrderMapper.modifyOldTime(priceId,new Date());
  742. }catch (Exception e) {
  743. System.out.println("更新历史时间失败");
  744. }
  745. System.out.println("更新详单数据成功");
  746. result = bmstruckDetailsOrderMapper.updateByPrimaryKeySelective(bmstruckDetailsOrder);
  747. }
  748. /*try {
  749. amsFeign.copySteelPrice(mapValue);
  750. } catch (Exception e) {
  751. e.printStackTrace();
  752. }*/
  753. if(DataChange.dataToBigDecimal(mapValue.get("updatePlace")).intValue() == 1) {
  754. System.out.println("更新asom里面的实际地址数据");
  755. Map<String, Object> stringObjectMap = bmstruckDetailsOrderMapper.getsaleShippingAddressId(mapValue);
  756. BigDecimal saleShippingAddressId = (BigDecimal) stringObjectMap.get("saleShippingAddressId");
  757. BigDecimal historyShippingAddressId = (BigDecimal) stringObjectMap.get("historyShippingAddressId");
  758. bmstruckDetailsOrderMapper.updateActuallyPlace(mapValue);
  759. //if (historyShippingAddressId!=null){
  760. // //修改地址(不修改历史地址)
  761. // bmstruckDetailsOrderMapper.updatePlaceNew(mapValue);
  762. //}else if (historyShippingAddressId==null ) {
  763. // mapValue.put("historyPlaceId", saleShippingAddressId);
  764. // //修改地址(不修改历史地址)
  765. // bmstruckDetailsOrderMapper.updatePlace(mapValue);
  766. //}
  767. }
  768. System.out.println("修改单价,时间:" + new Date() + "-----------" + mapValue);
  769. return result;
  770. }
  771. @Override
  772. public int updateAsomPriceId(Map<String, Object> mapValue) {
  773. System.out.println("更新ASOM表里面的数据实际地址数据" + mapValue + "----------" + new Date());
  774. //前面更新运单时更新过地址了,这里就不更新了,如果订单ID为空,才更新
  775. if(DataChange.dataToBigDecimal(mapValue.get("updatePlace")).intValue() == 1 && mapValue.get("orderId")==null) {
  776. Map<String, Object> stringObjectMap = bmstruckDetailsOrderMapper.getsaleShippingAddressId(mapValue);
  777. BigDecimal saleShippingAddressId = (BigDecimal) stringObjectMap.get("saleShippingAddressId");
  778. BigDecimal historyShippingAddressId = (BigDecimal) stringObjectMap.get("historyShippingAddressId");
  779. bmstruckDetailsOrderMapper.updateActuallyPlace(mapValue);
  780. //if (historyShippingAddressId!=null){
  781. // //修改地址(不修改历史地址)
  782. // bmstruckDetailsOrderMapper.updatePlaceNew(mapValue);
  783. //}else if (historyShippingAddressId==null ) {
  784. // mapValue.put("historyPlaceId", saleShippingAddressId);
  785. // //修改地址(不修改历史地址)
  786. // bmstruckDetailsOrderMapper.updatePlace(mapValue);
  787. //}
  788. }
  789. return bmstruckDetailsOrderMapper.updateAsomPriceId(mapValue);
  790. }
  791. @Override
  792. public BigDecimal getCarrierIdBySSO(String carrierSsoId) {
  793. return bmstruckDetailsOrderMapper.getCarrierIdBySSO(carrierSsoId);
  794. }
  795. // 根据单价id查询价格和地址
  796. @Override
  797. public Map<String,Object> findAddressAndPrice(Integer priceId) {
  798. return bmstruckDetailsOrderMapper.findAddressAndPrice(new BigDecimal(priceId));
  799. }
  800. /**
  801. * 增加焦炭途损费
  802. * @param map
  803. * @return
  804. */
  805. @Override
  806. public int addLossFeeOfCoke(Map<String,Object> map) {
  807. BigDecimal lossFees = DataChange.dataToBigDecimal(map.get("lossFees"));
  808. BigDecimal detailsId = DataChange.dataToBigDecimal(map.get("detailsId"));
  809. BmstruckDetailsOrder bmstruckDetailsOrder = bmstruckDetailsOrderMapper.selectByPrimaryKey(detailsId);
  810. BigDecimal detailsAmount = bmstruckDetailsOrder.getDetailsAmount();
  811. DecimalFormat df = new DecimalFormat("0.00");
  812. Double newAmount = detailsAmount.doubleValue() - lossFees.doubleValue();
  813. String newAmountStr = df.format(newAmount);
  814. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(newAmountStr));
  815. int result = bmstruckDetailsOrderMapper.updateByPrimaryKeySelective(bmstruckDetailsOrder);
  816. return result;
  817. }
  818. /*
  819. 内转计重计费详单
  820. */
  821. @Override
  822. public List<Map<String, Object>> getInwardWeightDetailsOrder(Map<String, Object> mapValue, Integer orderType) {
  823. List<Map<String,Object>>mapList = new ArrayList<>();
  824. switch (orderType){
  825. case 10:
  826. List<Map<String, Object>> inwardReportResult = bmstruckDetailsOrderMapper.getPurInwarWeightDetailsOrder(mapValue);
  827. return inwardReportResult;
  828. case 21:
  829. return bmstruckDetailsOrderMapper.getInwardTimeDetailsOrder(mapValue);
  830. case 11:
  831. return bmstruckDetailsOrderMapper.getAllInwardWeight(mapValue);
  832. case 26:
  833. return bmstruckDetailsOrderMapper.getInwardCountDetailsOrder(mapValue);
  834. default:
  835. break;
  836. }
  837. return mapList;
  838. }
  839. @Override
  840. public synchronized int inserInwardOrder(Map<String, Object> mapVal) {
  841. //获取运输订单ID
  842. BigDecimal orderId= DataChange.dataToBigDecimal(mapVal.get("orderId"));
  843. //根据运输订单去查找订单类型
  844. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  845. //根据运输订单id去查询计费详单id
  846. if(bmstruckDetailsOrderMapper.selectDetailsByOrder(orderId) > 0){
  847. return -1;
  848. }
  849. List<Map<String,Object>> priceAmountList = new ArrayList<>();
  850. if(inwardTypeList.contains(orderType.intValue())){
  851. //获取该订单的计量实绩ID以及净重,只会返回一条数据
  852. priceAmountList = bmstruckDetailsOrderMapper.getWeightTaskResultId(orderId);
  853. }
  854. if(toLineAndMaterial.contains(orderType.intValue())){
  855. //如果在以上订单类型里面则需要根据运输订单ID去找线路和物资
  856. Map<String,Object> priceInfoPur = bmstruckDetailsOrderMapper.getPriceInfoPur(orderId);
  857. //根据物资品类ID和承运起止范围去匹配单价
  858. Map<String,Object> map = bmstruckDetailsOrderMapper.getPurInwardPrice(priceInfoPur);
  859. if(map != null){
  860. mapVal.putAll(map);
  861. }else{
  862. return -1;
  863. }
  864. }
  865. if(fixLineList.contains(orderType.intValue())){
  866. //拼装车皮进厂以及一焦化采购焦炭进厂
  867. Map<String,Object> priceInfoPur = bmstruckDetailsOrderMapper.getPriceInfoPur(orderId);
  868. priceInfoPur.put("transRangeId",1);
  869. //根据物资品类ID和承运起止范围去匹配单价
  870. Map<String,Object> map = bmstruckDetailsOrderMapper.getPurInwardPrice(priceInfoPur);
  871. if(map != null){
  872. mapVal.putAll(map);
  873. }else{
  874. return -1;
  875. }
  876. }
  877. if(steelTypeList.contains(orderType.intValue())){
  878. //钢材倒库
  879. //首先获取净重
  880. //BigDecimal netWeight = bmstruckDetailsOrderMapper.selectNetWeight(orderId);
  881. //mapVal.put("netWeight",netWeight);
  882. //获取单价
  883. Map<String, Object> priceInfoPur = new HashMap<>();
  884. priceInfoPur.put("transRangeId",1);
  885. priceInfoPur.put("materialTypeId",5102);
  886. Map<String,Object> map = bmstruckDetailsOrderMapper.getPurInwardPrice(priceInfoPur);
  887. if(map != null){
  888. mapVal.putAll(map);
  889. }else{
  890. return -1;
  891. }
  892. }
  893. if(orderType.intValue() == 21 || orderType.intValue()==26){
  894. //计时/计次
  895. priceAmountList.add(mapVal);
  896. }
  897. //获取单价ID
  898. BigDecimal priceId = DataChange.dataToBigDecimal(mapVal.get("priceId")) ;
  899. //获取单价值
  900. BigDecimal priceValue = DataChange.dataToBigDecimal(mapVal.get("priceValue"));
  901. if(priceId == null){
  902. System.out.println(orderId + "没有单价");
  903. return 1;
  904. }
  905. int result = 0;
  906. for (Map<String, Object> map : priceAmountList) {
  907. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  908. //查询计重且计时
  909. String s = bmstruckDetailsOrderMapper.selectWeightAndTimeByOrderId(orderId);
  910. int num=0;
  911. if (s!=null && s.contains("计时且过计量")){
  912. num=21;
  913. }
  914. if(inwardTypeList.contains(orderType.intValue()) && num==0){
  915. BigDecimal weightTaskResultId = DataChange.dataToBigDecimal(map.get("weightTaskResultId"));
  916. BigDecimal netWeight = null;
  917. if(mapVal.get("netWeight") != null) {
  918. //因为事务的关系,部分订单结束时可能没有净重,故需要添加净重
  919. netWeight = DataChange.dataToBigDecimal(mapVal.get("netWeight"));
  920. }
  921. else{
  922. netWeight = DataChange.dataToBigDecimal(map.get("netWeight"));
  923. }
  924. //计算详单金额
  925. BigDecimal detailsAmount = new BigDecimal(priceValue.doubleValue()*netWeight.doubleValue());
  926. //保留两位小数
  927. DecimalFormat df = new DecimalFormat("0.00");
  928. String format = df.format(detailsAmount);
  929. //关联计量实绩
  930. bmstruckDetailsOrder.setWeightTaskResultId(weightTaskResultId);
  931. if(priceId != null && priceValue !=null && detailsAmount.intValue() > 0){
  932. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(format));
  933. }
  934. }
  935. //内转计时结算
  936. if(orderType.intValue() == 21 || num==21){
  937. BigDecimal resultTime = DataChange.dataToBigDecimal(mapVal.get("Time1"));
  938. //保留两位小数
  939. DecimalFormat df = new DecimalFormat("0.00");
  940. BigDecimal settleTime = new BigDecimal(String.valueOf(resultTime.divide(new BigDecimal(60), 14, BigDecimal.ROUND_HALF_UP)));
  941. if(settleTime.doubleValue()<2.00){
  942. BigDecimal detailsAmount = new BigDecimal(priceValue.doubleValue()*2);
  943. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(df.format(detailsAmount)));
  944. }else{
  945. BigDecimal detailsAmount = new BigDecimal(priceValue.doubleValue()*settleTime.doubleValue());
  946. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(df.format(detailsAmount)));
  947. }
  948. }
  949. //内转计次结算
  950. if(orderType.intValue() == 26){
  951. //保留两位小数
  952. DecimalFormat df = new DecimalFormat("0.00");
  953. BigDecimal detailsAmount = new BigDecimal(priceValue.doubleValue());
  954. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(df.format(detailsAmount)));
  955. }
  956. bmstruckDetailsOrder.setPriceId(priceId);
  957. bmstruckDetailsOrder.setInsertUpdateRemark("单价存在");
  958. // 得到最大id
  959. BigDecimal detailsId = selectMaxId();
  960. bmstruckDetailsOrder.setOrderId(orderId);
  961. String detailsNo = noUtil.setResultNo("QYXD", detailsId);
  962. bmstruckDetailsOrder.setDetailsId(detailsId);
  963. bmstruckDetailsOrder.setDetailsNo(detailsNo);
  964. bmstruckDetailsOrder.setDetailsTime(new Date());
  965. // 设置常规字段
  966. bmstruckDetailsOrder.setInsertTime(new Date());
  967. bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(0));
  968. bmstruckDetailsOrder.setInsertUsername("admin");
  969. bmstruckDetailsOrder.setUpdateUsername("admin");
  970. result += bmstruckDetailsOrderMapper.insertSelective(bmstruckDetailsOrder);
  971. }
  972. return result;
  973. }
  974. @Override
  975. public int updateDetails() {
  976. List<Map<String,Object>>mapList = bmstruckDetailsOrderMapper.selectDetailsNoAmount();
  977. int i=0;
  978. for (Map<String,Object>map:mapList
  979. ) {
  980. //获取详单ID、价格值,净重
  981. BigDecimal detailsId = DataChange.dataToBigDecimal(map.get("detailsId"));
  982. BigDecimal netWeight = DataChange.dataToBigDecimal(map.get("netWeight"));
  983. BigDecimal priceValue = DataChange.dataToBigDecimal(map.get("priceValue"));
  984. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  985. bmstruckDetailsOrder.setDetailsId(detailsId);
  986. BigDecimal detailsAmount = new BigDecimal(priceValue.doubleValue()*netWeight.doubleValue());
  987. DecimalFormat df = new DecimalFormat("0.00");
  988. String format = df.format(detailsAmount);
  989. bmstruckDetailsOrder.setDetailsAmount(new BigDecimal(format));
  990. i += bmstruckDetailsOrderMapper.updateByPrimaryKeySelective(bmstruckDetailsOrder);
  991. }
  992. return i;
  993. }
  994. /*
  995. 内转计重+计时计费详单
  996. */
  997. @Override
  998. public List<Map<String, Object>> getInwardWeightTimeDetailsOrder(Map<String, Object> mapValue, Integer orderType) {
  999. List<Map<String,Object>>mapListWeight = new ArrayList<>();
  1000. List<Map<String,Object>>mapListTime = new ArrayList<>();
  1001. //计重计费详单查询结果
  1002. mapListWeight = bmstruckDetailsOrderMapper.getInwardWeightDetailsOrder(mapValue);
  1003. //for(Map<String, Object> mapListWeightOne : mapListWeight)
  1004. //{
  1005. // mapListWeightOne.put("resultTime","null");
  1006. //}
  1007. //计时计费详单查询结果
  1008. mapListTime = bmstruckDetailsOrderMapper.getInwardTimeDetailsOrder(mapValue);
  1009. //将计时查询结果加入到计重查询结果中
  1010. for(Map<String, Object> mapListTimeOne:mapListTime)
  1011. { mapListTimeOne.put("capacityNumber",mapListTimeOne.remove("capacityNum"));
  1012. mapListWeight.add(mapListTimeOne);
  1013. }
  1014. //返回计重+计时计费详单查询结果
  1015. return mapListWeight;
  1016. }
  1017. @Override
  1018. public List<Map<String, Object>> getNoInwardDetails(Map<String, Object> mapValue) {
  1019. return bmstruckDetailsOrderMapper.getNoInwardDetails(mapValue);
  1020. }
  1021. @Override
  1022. public List<Map<String, Object>> getSteelTruckDetailsOrder(Map<String, Object> mapValue) {
  1023. return bmstruckDetailsOrderMapper.getSteelTruckDetailsOrder(mapValue);
  1024. }
  1025. @Override
  1026. public int newInwardSettle(List<Map<String,Object>> orderIds) {
  1027. int count = 0;
  1028. //遍历数组
  1029. for(Map<String,Object> orderIdMap:orderIds){
  1030. Integer orderId = DataChange.dataToBigDecimal(orderIdMap.get("orderId")).intValue();
  1031. //根据运输ID获取订单类型
  1032. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(new BigDecimal(orderId));
  1033. //根据订单类型调用不同的方法
  1034. //如果订单类型是11,
  1035. if(orderType.intValue() == 11){
  1036. List<BigDecimal> detailsIds = bmstruckDetailsOrderMapper.getDetailsIdByOrderId(orderId);
  1037. if(detailsIds.size() == 0){
  1038. omsFeign.closeInwardOrder(orderId);
  1039. count++;
  1040. }else{
  1041. for(int i=0;i<detailsIds.size();i++){
  1042. bmstruckDetailsOrderMapper.deleteByPrimaryKey(detailsIds.get(i));
  1043. omsFeign.closeInwardOrder(orderId);
  1044. count++;
  1045. }
  1046. }
  1047. }
  1048. if(orderType.intValue() == 10 || orderType.intValue() == 20){
  1049. //根据运输订单ID找寻计费详单ID
  1050. List<BigDecimal> detailsIds = bmstruckDetailsOrderMapper.getDetailsIdByOrderId(orderId);
  1051. for(BigDecimal detailsId:detailsIds){
  1052. //根据详单ID物理删除详单
  1053. bmstruckDetailsOrderMapper.deleteByPrimaryKey(detailsId);
  1054. count++;
  1055. }
  1056. inserInwardOrder(orderIdMap);
  1057. }
  1058. if(orderType.intValue() == 23 || orderType.intValue() == 24){
  1059. List<BigDecimal> detailsIds = bmstruckDetailsOrderMapper.getDetailsIdByOrderId(orderId);
  1060. for(BigDecimal detailsId:detailsIds){
  1061. //根据详单ID物理删除详单
  1062. bmstruckDetailsOrderMapper.deleteByPrimaryKey(detailsId);
  1063. count++;
  1064. }
  1065. inserInwardOrder(orderIdMap);
  1066. }
  1067. if(orderType.intValue() == 16 || orderType.intValue() == 15){
  1068. List<BigDecimal> detailsIds = bmstruckDetailsOrderMapper.getDetailsIdByOrderId(orderId);
  1069. for(BigDecimal detailsId:detailsIds){
  1070. //根据详单ID物理删除详单
  1071. bmstruckDetailsOrderMapper.deleteByPrimaryKey(detailsId);
  1072. count++;
  1073. }
  1074. inserInwardOrder(orderIdMap);
  1075. }
  1076. }
  1077. return count;
  1078. }
  1079. @Override
  1080. public int updateDetailsStatus(List<Integer> detailsOrderList) {
  1081. int i = 0;
  1082. for(Integer detailsId :detailsOrderList) {
  1083. if(detailsId == null) {
  1084. continue;
  1085. }
  1086. //BigDecimal detailId = DataChange.dataToBigDecimal(map.get("detailId"));
  1087. //BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  1088. //bmstruckDetailsOrder.setDetailsId(detailId);
  1089. //bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(1));
  1090. //i += bmstruckDetailsOrderMapper.updateByPrimaryKeySelective(bmstruckDetailsOrder);
  1091. try {
  1092. i += bmstruckDetailsOrderMapper.updateDetailsStatus(detailsId);
  1093. } catch (Exception e) {
  1094. e.printStackTrace();
  1095. }
  1096. /*BigDecimal priceId = omstruckOrderMapper.getPriceId(orderId);
  1097. omstruckOrderMapper.modifyOldTime(priceId,new Date());*/
  1098. }
  1099. return i;
  1100. }
  1101. @Override
  1102. public int getSaleOrderStatus(BigDecimal orderId) {
  1103. return bmstruckDetailsOrderMapper.getSaleOrderStatus(orderId);
  1104. }
  1105. @Override
  1106. public synchronized int insertPriceValue(List<Map<String, Object>> mapList) {
  1107. for (Map<String, Object> map : mapList) {
  1108. Integer placeId =(Integer) map.get("placeId");
  1109. //根据位置ID去查询是否有单价存在,如果有就跳过
  1110. BigDecimal priceIdInt = bmstruckDetailsOrderMapper.getPriceIdInt(placeId);
  1111. if (priceIdInt!=null&&priceIdInt.compareTo(BigDecimal.ZERO)!=0){
  1112. break;
  1113. }else {
  1114. ////新增单价
  1115. //BigDecimal orderId = DataChange.dataToBigDecimal(map.get("orderId"));
  1116. //BigDecimal omsTruckOrderPriceId = bmstruckDetailsOrderMapper.getOmsTruckOrderPriceId(orderId);
  1117. //Map<String,Object> map1=new HashMap<>();
  1118. //map1.put("orderId",orderId);
  1119. //map1.put("priceId",omsTruckOrderPriceId);
  1120. //try {
  1121. // amsFeign.copySteelPrice(map1);
  1122. //} catch (Exception e) {
  1123. // e.printStackTrace();
  1124. //}
  1125. //单价的主键
  1126. //map1.put("priceId",bmstruckDetailsOrderMapper.selectMaxIdNew());
  1127. //map1.put("priceValue",map.get("priceValue"));
  1128. //map1.put("placeId",placeId);
  1129. //bmstruckDetailsOrderMapper.insertPriceValue(map1);
  1130. }
  1131. }
  1132. return 0;
  1133. }
  1134. public int cancelMakeSure(List<Integer> detailsOrderList) {
  1135. int i = 0;
  1136. for(Integer detailsId :detailsOrderList) {
  1137. if(detailsId == null) {
  1138. continue;
  1139. }
  1140. //BigDecimal detailId = DataChange.dataToBigDecimal(map.get("detailId"));
  1141. //BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  1142. //bmstruckDetailsOrder.setDetailsId(detailId);
  1143. //bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(1));
  1144. //i += bmstruckDetailsOrderMapper.updateByPrimaryKeySelective(bmstruckDetailsOrder);
  1145. i += bmstruckDetailsOrderMapper.cancelMakeSure(detailsId);
  1146. /*BigDecimal priceId = omstruckOrderMapper.getPriceId(orderId);
  1147. omstruckOrderMapper.modifyOldTime(priceId,new Date());*/
  1148. }
  1149. return i;
  1150. }
  1151. @Override
  1152. public int updateDetailsDirect(Map<String, Object> mapValue) throws Exception {
  1153. List<BigDecimal> orderIds = (List<BigDecimal>) mapValue.get("orderList");
  1154. BigDecimal priceValue = DataChange.dataToBigDecimal(mapValue.get("detailAmount"));//以java变量名为准,这里是所填写的单价值
  1155. if(priceValue.intValue() < 0){
  1156. throw new Exception("单价不能小于等于0");
  1157. }
  1158. String detailRemark = mapValue.get("detailRemark").toString();
  1159. String userId = mapValue.get("userId").toString();
  1160. String userName = bmstruckDetailsOrderMapper.getUserNameByUserId(userId);
  1161. String url = mapValue.get("url").toString();
  1162. AmsContractTransportPrice amsContractTransportPrice = new AmsContractTransportPrice();
  1163. BigDecimal priceId = amsContractTransportPriceMapper.selectMaxId();
  1164. amsContractTransportPrice.setPriceId(priceId);
  1165. amsContractTransportPrice.setPriceValue(priceValue);
  1166. amsContractTransportPrice.setPriceDate(new Date());
  1167. int result = 0;
  1168. for(int i=0;i<orderIds.size();i++){
  1169. BigDecimal orderId = DataChange.dataToBigDecimal(orderIds.get(i));
  1170. //校验
  1171. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  1172. if(orderType.intValue() != 1){
  1173. throw new Exception("订单类型错误,不允许生成汽运计费详单");
  1174. }
  1175. //更新订单表单价
  1176. bmstruckDetailsOrderMapper.updateOrderPrice(orderId,priceId);
  1177. //更新车序号表单价
  1178. bmstruckDetailsOrderMapper.updateAsomPriceIdByOrderId(orderId,priceId);
  1179. saleLogUtil.logOrder(orderId,"直接修改单价",userName,SaleLogUtil.UPDATE);
  1180. //查询订单计量详情
  1181. List<Map<String,Object>> weightTaskResultIdList = bmstruckDetailsOrderMapper.getSteelWeightTaskResultId(orderId);
  1182. for (Map<String, Object> map : weightTaskResultIdList) {
  1183. BigDecimal weightTaskResultId = DataChange.dataToBigDecimal(map.get("weightTaskResultId"));
  1184. BigDecimal netWeightIsNull = bmstruckDetailsOrderMapper.getNetWeight(weightTaskResultId);
  1185. if (netWeightIsNull == null) {
  1186. System.out.println("没有计量实绩,不生成结算数据:" + orderId);
  1187. continue;
  1188. }
  1189. //计算总费用
  1190. BigDecimal detailsAmountOld = generateTruckFeesForDirect(priceValue, weightTaskResultId);
  1191. Double amount = detailsAmountOld.doubleValue();
  1192. BigDecimal detailsAmount = new BigDecimal(amount).setScale(2,RoundingMode.HALF_UP);
  1193. //判断该计量实绩有没有结算数据
  1194. if(bmstruckDetailsOrderMapper.getIsHaveDetailsOrder(weightTaskResultId) > 0 ){
  1195. //如果有,更新
  1196. Map<String,Object> temp =new HashMap<>();
  1197. temp.put("orderId",orderId);
  1198. temp.put("weightTaskResultId",weightTaskResultId);
  1199. temp.put("priceValue",priceValue);
  1200. temp.put("detailAmount",detailsAmount);
  1201. temp.put("detailRemark",detailRemark);
  1202. temp.put("url",url);
  1203. temp.put("userId",userId);
  1204. result +=bmstruckDetailsOrderMapper.updateTruckDetails(temp);
  1205. continue;
  1206. }
  1207. //否则,新增详单
  1208. try {
  1209. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  1210. bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(0));
  1211. // 得到最大id
  1212. BigDecimal detailsId = selectMaxId();
  1213. String detailsNo = noUtil.setResultNo("QYXD", detailsId);
  1214. bmstruckDetailsOrder.setDetailsId(detailsId);
  1215. bmstruckDetailsOrder.setWeightTaskResultId(weightTaskResultId);
  1216. bmstruckDetailsOrder.setOrderId(orderId);
  1217. bmstruckDetailsOrder.setDetailsNo(detailsNo);
  1218. bmstruckDetailsOrder.setDetailsAmount(detailsAmount);
  1219. bmstruckDetailsOrder.setDetailsTime(new Date());
  1220. bmstruckDetailsOrder.setPriceValue(priceValue);//填写的单价
  1221. bmstruckDetailsOrder.setPhoto(url);//上传的凭证图片路径
  1222. bmstruckDetailsOrder.setRemark(detailRemark);//凭证备注
  1223. // 设置常规字段
  1224. bmstruckDetailsOrder.setInsertTime(new Date());
  1225. bmstruckDetailsOrder.setUpdateTime(new Date());
  1226. bmstruckDetailsOrder.setInsertUsername(userId);
  1227. bmstruckDetailsOrder.setUpdateUsername("admin");
  1228. bmstruckDetailsOrder.setInsertUpdateRemark("无");
  1229. result += bmstruckDetailsOrderMapper.insertSelective(bmstruckDetailsOrder);
  1230. }catch (Exception e){
  1231. //不打印给控制台(有可能是正常情况)
  1232. e.printStackTrace();
  1233. }
  1234. }
  1235. }
  1236. amsContractTransportPriceMapper.insertSelective(amsContractTransportPrice);
  1237. return result;
  1238. }
  1239. @Override
  1240. public int addTruckDetail(Map<String, Object> mapValue) throws Exception {
  1241. List<BigDecimal> orderIds = (List<BigDecimal>) mapValue.get("orderList");
  1242. BigDecimal detailsAmount = DataChange.dataToBigDecimal(mapValue.get("detailAmount"));
  1243. String detailRemark = mapValue.get("detailRemark").toString();
  1244. String userId = mapValue.get("userId").toString();
  1245. String urls = "" + mapValue.get("urls");
  1246. int result = 0;
  1247. for(int i=0;i<orderIds.size();i++){
  1248. BigDecimal orderId = DataChange.dataToBigDecimal(orderIds.get(i));
  1249. //校验
  1250. BigDecimal orderType = bmstruckDetailsOrderMapper.getOrderType(orderId);
  1251. if(orderType.intValue() != 1){
  1252. throw new Exception("订单类型错误,不允许生成汽运计费详单");
  1253. }
  1254. List<Map<String,Object>> weightTaskResultIdList = bmstruckDetailsOrderMapper.getSteelWeightTaskResultId(orderId);
  1255. if(weightTaskResultIdList.size()<=0){
  1256. throw new Exception("没有计量实绩,无法冲红");
  1257. }
  1258. //新增详单
  1259. try {
  1260. // 得到最大id
  1261. BigDecimal detailsId = selectMaxId();
  1262. BmstruckDetailsOrder bmstruckDetailsOrder = new BmstruckDetailsOrder();
  1263. bmstruckDetailsOrder.setWetherToStatement(new BigDecimal(0));
  1264. String detailsNo = noUtil.setResultNo("QYXD", detailsId);
  1265. bmstruckDetailsOrder.setWeightTaskResultId(DataChange.dataToBigDecimal(weightTaskResultIdList.get(0).get("weightTaskResultId")));
  1266. bmstruckDetailsOrder.setDetailsId(detailsId);
  1267. bmstruckDetailsOrder.setOrderId(orderId);
  1268. bmstruckDetailsOrder.setDetailsNo(detailsNo);
  1269. bmstruckDetailsOrder.setDetailsAmount(detailsAmount);
  1270. bmstruckDetailsOrder.setDetailsTime(new Date());
  1271. bmstruckDetailsOrder.setRemark(detailRemark);//凭证备注
  1272. bmstruckDetailsOrder.setPhoto(urls);//图片
  1273. // 设置常规字段
  1274. bmstruckDetailsOrder.setInsertTime(new Date());
  1275. bmstruckDetailsOrder.setUpdateTime(new Date());
  1276. bmstruckDetailsOrder.setInsertUsername(userId);
  1277. bmstruckDetailsOrder.setUpdateUsername("admin");
  1278. bmstruckDetailsOrder.setInsertUpdateRemark("无");
  1279. result += bmstruckDetailsOrderMapper.insertSelective(bmstruckDetailsOrder);
  1280. }catch (Exception e){
  1281. e.printStackTrace();
  1282. }
  1283. }
  1284. return result;
  1285. }
  1286. @Override
  1287. public int updateConsignee(Map<String, Object> map) throws Exception {
  1288. bmstruckDetailsOrderMapper.updateConsignee(map);
  1289. //记录日志
  1290. saleLogUtil.logOrder(map,"修改计费详单的收货客户",SaleLogUtil.UPDATE);
  1291. return 0;
  1292. }
  1293. }