SalesOrderServiceImpl.java 63 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390
  1. package com.iamberry.rst.service.cm;
  2. import com.github.pagehelper.PageHelper;
  3. import com.iamberry.redis.RedisUtils;
  4. import com.iamberry.rst.core.address.Province;
  5. import com.iamberry.rst.core.cm.FittingsInfo;
  6. import com.iamberry.rst.core.cm.SalesOrder;
  7. import com.iamberry.rst.core.cm.SalesOrderItem;
  8. import com.iamberry.rst.core.cm.StoreInfo;
  9. import com.iamberry.rst.core.fm.InventoryInfo;
  10. import com.iamberry.rst.core.fm.InventoryLog;
  11. import com.iamberry.rst.core.order.*;
  12. import com.iamberry.rst.core.page.PagedResult;
  13. import com.iamberry.rst.core.sys.Admin;
  14. import com.iamberry.rst.core.sys.SysConfig;
  15. import com.iamberry.rst.core.tools.LogisticsInfo;
  16. import com.iamberry.rst.faces.address.AddressService;
  17. import com.iamberry.rst.faces.cm.SalesOrderService;
  18. import com.iamberry.rst.faces.cm.StoreInfoService;
  19. import com.iamberry.rst.faces.order.EfastOrderService;
  20. import com.iamberry.rst.faces.product.ProductService;
  21. import com.iamberry.rst.service.cm.mapper.FittingsInfoMapper;
  22. import com.iamberry.rst.service.cm.mapper.SalesOrderMapper;
  23. import com.iamberry.rst.service.fm.mapper.InventoryLogMapper;
  24. import com.iamberry.rst.service.fm.mapper.InventoryMapper;
  25. import com.iamberry.rst.service.order.mapper.LogisticsInfoMapper;
  26. import com.iamberry.rst.service.order.mapper.ProvincesLogisticsMapper;
  27. import com.iamberry.rst.service.product.mapper.ProductMapper;
  28. import com.iamberry.rst.service.sys.mapper.SysConfigMapper;
  29. import com.iamberry.rst.util.PageUtil;
  30. import com.iamberry.wechat.tools.DateTimeUtil;
  31. import com.iamberry.wechat.tools.payUtil.DatetimeUtil;
  32. import net.sf.json.JSONArray;
  33. import net.sf.json.JSONObject;
  34. import org.slf4j.Logger;
  35. import org.slf4j.LoggerFactory;
  36. import org.springframework.beans.BeanUtils;
  37. import org.springframework.beans.factory.annotation.Autowired;
  38. import org.springframework.stereotype.Service;
  39. import org.springframework.transaction.annotation.Transactional;
  40. import java.beans.Transient;
  41. import java.text.SimpleDateFormat;
  42. import java.util.*;
  43. /**
  44. * Created by liuzhiwei on 2017/10/31.
  45. */
  46. @Service
  47. public class SalesOrderServiceImpl implements SalesOrderService {
  48. private static Logger logger = LoggerFactory.getLogger(CustomerServiceImpl.class);
  49. @Autowired
  50. private SalesOrderMapper salesOrderMapper;
  51. @Autowired
  52. private ProductService productService;
  53. @Autowired
  54. private StoreInfoService storeInfoService;
  55. @Autowired
  56. private EfastOrderService efastOrderService;
  57. @Autowired
  58. private SalesOrderService salesOrderService;
  59. @Autowired
  60. private FittingsInfoMapper fittingsInfoMapper;
  61. @Autowired
  62. private SysConfigMapper sysConfigMapper;
  63. @Autowired
  64. private AddressService addressService;
  65. @Autowired
  66. private ProvincesLogisticsMapper provincesLogisticsMapper;
  67. @Autowired
  68. private ProductMapper productMapper;
  69. @Autowired
  70. private InventoryMapper inventoryMapper;
  71. @Autowired
  72. private InventoryLogMapper inventoryLogMapper;
  73. @Override
  74. public Integer addSalesOrder(SalesOrder salesOrder) {
  75. return salesOrderMapper.addSalesOrder(salesOrder);
  76. }
  77. @Override
  78. @Transactional
  79. public Integer addSalesOrderManual(SalesOrder salesOrder) {
  80. salesOrderMapper.addSalesOrder(salesOrder);
  81. return null;
  82. }
  83. @Override
  84. public SalesOrder getSalesOrderById(Integer salesId) {
  85. return salesOrderMapper.getSalesOrderById(salesId);
  86. }
  87. @Override
  88. public Integer updateSalesOrder(SalesOrder salesOrder) {
  89. //作废订单时需要返还库存
  90. if(salesOrder.getSalesStatus() != null && salesOrder.getSalesStatus() == 3){
  91. //如果已出库则返还库存
  92. if(salesOrderMapper.getSalesOrderById(salesOrder.getSalesId()).getSalesDeliver() == 2){
  93. returnInventory(salesOrder.getSalesId());
  94. }
  95. }
  96. return salesOrderMapper.updateSalesOrder(salesOrder);
  97. }
  98. @Transactional
  99. @Override
  100. public Integer updateOrderInfo(SalesOrder salesOrder) {
  101. int flag = 0;
  102. //删除订单项
  103. flag = salesOrderMapper.delOrderItem(salesOrder.getSalesId());
  104. if (flag <= 0) {
  105. throw new RuntimeException("删除订单项失败!");
  106. }
  107. //修改订单
  108. salesOrderMapper.updateSalesOrder(salesOrder);
  109. if (flag <= 0) {
  110. throw new RuntimeException("修改订单失败!");
  111. }
  112. //批量添加订单项数据
  113. flag = salesOrderMapper.addOrderItemList(salesOrder.getSalesOrderItemList());
  114. if (flag <= 0) {
  115. throw new RuntimeException("增加订单项失败!");
  116. }
  117. return flag;
  118. }
  119. @Override
  120. public Integer addSalesOrderList(List<SalesOrder> list) {
  121. return salesOrderMapper.addSalesOrderList(list);
  122. }
  123. @Override
  124. public List<SalesOrder> listSalesOrder(SalesOrder salesOrder) {
  125. return salesOrderMapper.listSalesOrder(salesOrder);
  126. }
  127. @Override
  128. public Integer listSalesOrderNum(SalesOrder salesOrder) {
  129. return salesOrderMapper.listSalesOrderNum(salesOrder);
  130. }
  131. @Override
  132. public PagedResult<SalesOrder> listSalesOrderPage(int pageNO, int pageSize, SalesOrder salesOrder, boolean isTotalNum) {
  133. salesOrder.setStartOrderNO((pageNO-1) * pageSize);
  134. salesOrder.setEndOrderNO(pageSize);
  135. //查询订单列表信息
  136. List<SalesOrder> orderList = salesOrderMapper.listSalesOrderNew(salesOrder);
  137. for(SalesOrder so : orderList){
  138. SalesOrderItem salesOrderItem = new SalesOrderItem();
  139. salesOrderItem.setItemOrderId(so.getSalesId());
  140. List<SalesOrderItem> salesOrderItemList = salesOrderMapper.listSalesOrderItem(salesOrderItem);
  141. //去除已退货的订单项
  142. int num = salesOrderItemList.size();
  143. for(int i = 0;i< num;){
  144. SalesOrderItem item = salesOrderItemList.get(i);
  145. if(item.getItemNum().intValue() == item.getItemReturnNum().intValue()){
  146. salesOrderItemList.remove(i);
  147. num = salesOrderItemList.size();
  148. i = 0;
  149. }else{
  150. i++;
  151. }
  152. }
  153. for(SalesOrderItem item : salesOrderItemList){//判断是否包含净水机 1是 2否
  154. if(item.getColorIsMachine() != null){
  155. if(item.getColorIsMachine() == 1){
  156. so.setIsDevelop(1);
  157. }else{
  158. so.setIsDevelop(2);
  159. }
  160. }else{
  161. so.setIsDevelop(1);
  162. }
  163. }
  164. so.setSalesOrderItemList(salesOrderItemList);
  165. }
  166. PagedResult<SalesOrder> result = PageUtil.getPage(orderList);
  167. // 查询分页的数据
  168. int count = salesOrderMapper.listSalesOrderNum(salesOrder);
  169. result.setTotal(count);
  170. if(count%pageSize==0){
  171. count=count/pageSize;
  172. } else{
  173. count=count/pageSize+1;
  174. }
  175. result.setPages(count);
  176. result.setPageNo(pageNO);
  177. result.setPageSize(pageSize);
  178. return result;
  179. }
  180. @Override
  181. public List<PostInfo> listWaitPrintOrderNum(Integer salesWarehouseId) {
  182. return salesOrderMapper.listWaitPrintOrderNum(salesWarehouseId);
  183. }
  184. @Override
  185. public PagedResult<SalesOrder> listAwaitSendSalesOrderPage(int pageNO, int pageSize, SalesOrder salesOrder, boolean isTotalNum) {
  186. PageHelper.startPage(pageNO, pageSize, isTotalNum);
  187. //查询订单列表信息
  188. List<SalesOrder> orderList = salesOrderMapper.listAwaitSendSalesOrderPage(salesOrder);
  189. return PageUtil.getPage(orderList);
  190. }
  191. @Override
  192. @Transactional
  193. public boolean addOrderAndItem(SalesOrder salesOrder, List<SalesOrderItem> list) throws Exception {
  194. if (list == null || list.size() == 0) {
  195. throw new RuntimeException("获取订单信息出错!");
  196. }
  197. SalesOrder verifyOrder = new SalesOrder();
  198. verifyOrder.setSalesOrderId(salesOrder.getSalesOrderId());
  199. //查询该订单是否存在,如果存在,不需要再次添加到订单中
  200. int count = salesOrderMapper.getOrderInfoCount(verifyOrder);
  201. if (count > 0) {
  202. return true;
  203. }
  204. //添加订单数据
  205. try {
  206. int orderNum = salesOrderMapper.addSalesOrder(salesOrder);
  207. if (orderNum <= 0) {
  208. throw new RuntimeException("获取订单信息出错!");
  209. }
  210. } catch (Exception e) {
  211. return true;
  212. }
  213. for (SalesOrderItem item : list) {
  214. item.setItemOrderId(salesOrder.getSalesId());
  215. }
  216. //批量添加订单项数据
  217. int itemNum = salesOrderMapper.addOrderItemList(list);
  218. if (itemNum <= 0) {
  219. throw new RuntimeException("获取订单信息出错!");
  220. }
  221. return true;
  222. }
  223. @Override
  224. @Transactional
  225. public SalesOrder addOrderAndIteminfo(SalesOrder salesOrder, List<SalesOrderItem> list) {
  226. //添加订单数据
  227. int orderNum = salesOrderMapper.addSalesOrder(salesOrder);
  228. if (orderNum <= 0) {
  229. return salesOrder;
  230. }
  231. for (SalesOrderItem item : list) {
  232. item.setItemOrderId(salesOrder.getSalesId());
  233. }
  234. //批量添加订单项数据
  235. int itemNum = salesOrderMapper.addOrderItemList(list);
  236. if (itemNum <= 0) {
  237. return salesOrder;
  238. }
  239. return salesOrder;
  240. }
  241. public void parseOrder(SalesOrder oginerOrder, List<SalesOrder> listOrder) {
  242. // 订单项拆分完成,直接返回
  243. if (oginerOrder.getSalesOrderItemList().size() <= 0) {
  244. return;
  245. }
  246. List<DownsingleRuleInfo> listDownsingleRuleInfo = salesOrderService.listDownsingleRule();
  247. if(listDownsingleRuleInfo.size() < 1){
  248. listOrder.add(oginerOrder);
  249. return;
  250. }
  251. // 拆单,比较的是数量和产品
  252. Map<String, SalesOrderItem> itemMap = new HashMap<>(oginerOrder.getSalesOrderItemList().size());
  253. for (SalesOrderItem item : oginerOrder.getSalesOrderItemList()) {
  254. SalesOrderItem itemTwo = new SalesOrderItem();
  255. BeanUtils.copyProperties(item,itemTwo);
  256. itemMap.put(item.getItemColorBar(), itemTwo);
  257. }
  258. // 遍历拆单规则
  259. int ruleCount = 0;
  260. for (DownsingleRuleInfo rule : listDownsingleRuleInfo) {
  261. // 一个拆单规则
  262. int count = 0;
  263. for (DownsingleRuleItemInfo item : rule.getDownsingleRuleItemList()) {
  264. if (itemMap.get(item.getDownsingleItemBar()) != null) {
  265. if (item.getDownsingleItemNum() <= itemMap.get(item.getDownsingleItemBar()).getItemNum()) {
  266. count ++;
  267. }
  268. }
  269. }
  270. if (count == rule.getDownsingleRuleItemList().size()) {
  271. // 满足拆单条件
  272. SalesOrder newOrder = new SalesOrder();
  273. BeanUtils.copyProperties(oginerOrder,newOrder);
  274. newOrder.setSalesOrderItemList(new ArrayList<SalesOrderItem>(count));
  275. for (DownsingleRuleItemInfo item : rule.getDownsingleRuleItemList()) {
  276. SalesOrderItem temp = new SalesOrderItem();
  277. BeanUtils.copyProperties(itemMap.get(item.getDownsingleItemBar()),temp);
  278. temp.setItemNum(item.getDownsingleItemNum());
  279. newOrder.getSalesOrderItemList().add(temp);
  280. }
  281. listOrder.add(newOrder);
  282. // 继续递归
  283. for (DownsingleRuleItemInfo item : rule.getDownsingleRuleItemList()) {
  284. if (item.getDownsingleItemNum().equals(itemMap.get(item.getDownsingleItemBar()).getItemNum())) {
  285. // 数量和拆单规则相同,则删除原订单的订单项
  286. /*oginerOrder.getSalesOrderItemList().remove(itemMap.get(item.getDownsingleItemBar()));*/
  287. for(int i = 0;i<oginerOrder.getSalesOrderItemList().size();i++){
  288. if(oginerOrder.getSalesOrderItemList().get(i).getItemColorBar() .equals(item.getDownsingleItemBar())){
  289. oginerOrder.getSalesOrderItemList().remove(i);
  290. }
  291. }
  292. } else {
  293. // SalesOrderItem orderItem = itemMap.get(item.getDownsingleItemBar());
  294. SalesOrderItem orderItem = new SalesOrderItem();
  295. BeanUtils.copyProperties(itemMap.get(item.getDownsingleItemBar()),orderItem);
  296. int oldCount = orderItem.getItemNum();
  297. /*orderItem.setItemNum(oldCount - item.getDownsingleItemNum());*/
  298. for(int i = 0;i<oginerOrder.getSalesOrderItemList().size();i++){
  299. if(oginerOrder.getSalesOrderItemList().get(i).getItemColorBar() .equals(item.getDownsingleItemBar())){
  300. oginerOrder.getSalesOrderItemList().get(i).setItemNum(oldCount - item.getDownsingleItemNum());
  301. }
  302. }
  303. }
  304. }
  305. salesOrderService.parseOrder(oginerOrder, listOrder);
  306. break;
  307. } else {
  308. // 不满足, 继续下一个规则
  309. // 如果是最后一个拆单规则,则不拆单
  310. if ((ruleCount + 1) == listDownsingleRuleInfo.size()) {
  311. if (oginerOrder.getSalesOrderItemList().size() > 0) {
  312. listOrder.add(oginerOrder);
  313. }
  314. }
  315. }
  316. ruleCount++;
  317. }
  318. }
  319. @Override
  320. @Transactional
  321. public boolean addRstOrderAndIteminfo(SalesOrder salesOrder){
  322. //合并订单项-------------statr
  323. List<SalesOrderItem> listItem = salesOrder.getSalesOrderItemList();
  324. salesOrder.setSalesOrderItemList(null);
  325. List<SalesOrderItem> list = new ArrayList<>();
  326. for (int i = 0;i<listItem.size();i++){
  327. if(i < listItem.size() - 1 ){
  328. for(int j = 0;j<listItem.size();j++){
  329. if (i != j){
  330. if(listItem.get(i).getItemColorBar().equals(listItem.get(j).getItemColorBar())){
  331. listItem.get(i).setItemNum(listItem.get(i).getItemNum()+listItem.get(j).getItemNum());
  332. }
  333. }
  334. }
  335. }
  336. boolean bl = true;
  337. for (SalesOrderItem salesOrderItem : list){
  338. if(salesOrderItem.getItemColorBar().equals(listItem.get(i).getItemColorBar())){
  339. bl = false;
  340. }
  341. }
  342. if(bl){
  343. list.add(listItem.get(i));
  344. }
  345. }
  346. //合并订单项----------------------end
  347. //匹配拆单规则 分割订单-------------state
  348. List<SalesOrder> listSalesOrder = new ArrayList<>();
  349. salesOrder.setSalesOrderItemList(list);
  350. salesOrderService.parseOrder(salesOrder, listSalesOrder);
  351. //匹配拆单规则 分割订单-------------end
  352. boolean msg = false;
  353. /*根据省份来分配物流公司*/
  354. salesOrderService.setProvincesLogistics(listSalesOrder);
  355. //判断主从订单--------------------state
  356. if (listSalesOrder.size() > 0){
  357. SalesOrder mainOrder = null;
  358. for (int s = 0;s < listSalesOrder.size();s++){
  359. if(mainOrder == null){
  360. for(int i = 0;i<listSalesOrder.get(s).getSalesOrderItemList().size();i++){
  361. int isMachine = salesOrderService.getIsMachine(listSalesOrder.get(s).getSalesOrderItemList().get(i).getItemColorBar());
  362. if( isMachine == 1){//1:水机 2:其它产品 0:未查到
  363. mainOrder = listSalesOrder.get(s);
  364. listSalesOrder.remove(s);
  365. break;
  366. }
  367. }
  368. }
  369. }
  370. if(mainOrder == null){//如果不存有水机的订单则默认第一个订单为主订单
  371. mainOrder = listSalesOrder.get(0);
  372. listSalesOrder.remove(0);
  373. }
  374. //判断主从订单--------------------end
  375. msg = salesOrderService.addRstOrderinfo(mainOrder,listSalesOrder);
  376. }
  377. return msg;
  378. }
  379. @Override
  380. @Transactional
  381. public boolean addRstOrderinfo(SalesOrder mainOrder,List<SalesOrder> listSalesOrder) {
  382. Integer flag = salesOrderMapper.getOrderBySalesDealCodeNum(mainOrder.getSalesDealCode());
  383. if(flag > 0){
  384. throw new RuntimeException("交易号("+ mainOrder.getSalesDealCode() +")重复,请重新生成交易号!");
  385. }
  386. if(mainOrder.getSalesCreateTime() == null){
  387. /*保证时间与以前一样*/
  388. mainOrder.setSalesCreateTime(new Date());
  389. }
  390. int orderNum = salesOrderMapper.addSalesOrder(mainOrder);
  391. if (orderNum <= 0) {
  392. throw new RuntimeException("添加订单出错--------!");
  393. }
  394. for (SalesOrderItem item : mainOrder.getSalesOrderItemList()) {
  395. item.setItemOrderId(mainOrder.getSalesId());
  396. }
  397. //批量添加订单项数据
  398. int itemNum = salesOrderMapper.addOrderItemList(mainOrder.getSalesOrderItemList());
  399. if (itemNum <= 0) {
  400. throw new RuntimeException("添加订单出错--------!");
  401. }else{
  402. if(listSalesOrder.size() > 0){
  403. for (int i = 0;i<listSalesOrder.size();i++){
  404. listSalesOrder.get(i).setSalesDealCode(listSalesOrder.get(i).getSalesDealCode()+"-"+(i+1));
  405. listSalesOrder.get(i).setSalesMainOrderId(mainOrder.getSalesId());
  406. listSalesOrder.get(i).setSalesId(null);
  407. orderNum = salesOrderMapper.addSalesOrder(listSalesOrder.get(i));
  408. if (orderNum <= 0) {
  409. throw new RuntimeException("添加订单出错--------!");
  410. }
  411. for (SalesOrderItem item : listSalesOrder.get(i).getSalesOrderItemList()) {
  412. item.setItemOrderId(listSalesOrder.get(i).getSalesId());
  413. }
  414. //批量添加订单项数据
  415. itemNum = salesOrderMapper.addOrderItemList(listSalesOrder.get(i).getSalesOrderItemList());
  416. if (itemNum <= 0) {
  417. throw new RuntimeException("添加订单出错--------!");
  418. }
  419. }
  420. }
  421. }
  422. return true;
  423. }
  424. /**
  425. * 根据省份来分配物流公司
  426. * @param listSalesOrder
  427. * @return
  428. */
  429. @Override
  430. public void setProvincesLogistics(List<SalesOrder> listSalesOrder){
  431. for (SalesOrder salesOrder:listSalesOrder) {
  432. boolean flag = false;
  433. for (SalesOrderItem salesOrderItem:salesOrder.getSalesOrderItemList()) {
  434. ProductColor productColor = productService.getColorByBar(salesOrderItem.getItemColorBar());
  435. if(productColor.getColorIsMachine() == 1){
  436. flag = true;
  437. }
  438. }
  439. if(flag){
  440. String addresses[] = salesOrder.getSalesAddressInfo().split("-");
  441. if(addresses == null || addresses.length < 3){
  442. addresses = salesOrder.getSalesAddressInfo().split(" ");
  443. }
  444. if(addresses == null || addresses.length < 3){
  445. addresses = salesOrder.getSalesAddressInfo().split("_");
  446. }
  447. if(addresses == null || addresses.length < 3){
  448. break;
  449. }
  450. String provincesStr = addresses[0];
  451. provincesStr = provincesStr.substring(0,2);
  452. ProvincesLogistics provincesLogistics = new ProvincesLogistics();
  453. provincesLogistics.setProvince(provincesStr);
  454. List<ProvincesLogistics> provincesLogisticsList = provincesLogisticsMapper.getProvincesLogisticsList(provincesLogistics);
  455. if(provincesLogisticsList == null || provincesLogisticsList.size() < 1){
  456. /*未查到地址*/
  457. break;
  458. }
  459. //设置快递公司
  460. provincesLogistics = provincesLogisticsList.get(0);
  461. if(provincesLogistics.getLogisticsRstCode() != null){
  462. salesOrder.setSalesPostFirm(provincesLogistics.getLogisticsRstCode());
  463. }
  464. }
  465. }
  466. }
  467. @Override
  468. public List<SalesOrderItem> listSalesOrderItem(SalesOrderItem salesOrderItem) {
  469. // 通过计算机名称来判断服务器环境
  470. Map<String,String> map = System.getenv();
  471. String name = map.get("COMPUTERNAME");
  472. if ("iZ94klno8qrZ".equalsIgnoreCase(name)) {
  473. name = "RST_";
  474. } else {
  475. name = "adv_";
  476. }
  477. // 获取数据
  478. String key = name + "ORDER_ITEM_" + salesOrderItem.getItemOrderId();
  479. List<SalesOrderItem> list = RedisUtils.list(key, SalesOrderItem.class);
  480. if (list == null ) {
  481. list = salesOrderMapper.listSalesOrderItem(salesOrderItem);
  482. RedisUtils.put(key, list);
  483. RedisUtils.expire(key, new Date(259200000 + System.currentTimeMillis()));
  484. }
  485. return list;
  486. }
  487. @Override
  488. public Integer updateOrderList(JSONArray orderList, List<SalesOrder> list) {
  489. List<SalesOrder> salesOrders = new ArrayList<SalesOrder>();
  490. //订单号相同时,判断状态,发货状态,物流公司,物流单号等是否相同,如果有一个不同,则需添加到salesOrders中进行同步
  491. for (int i = 0;i < orderList.size();i++) {
  492. JSONObject orderInfo = orderList.getJSONObject(i);
  493. for (SalesOrder salesOrder : list) {
  494. if (orderInfo.get("order_sn").equals(salesOrder.getSalesOrderId())
  495. && !(orderInfo.getInt("order_status") == salesOrder.getSalesStatus()
  496. && orderInfo.getInt("shipping_status") == salesOrder.getSalesShippingStatus()
  497. && orderInfo.getInt("pay_status") == salesOrder.getSalesPayStatus()
  498. && orderInfo.getInt("process_status") == salesOrder.getSalesProcessStatus()
  499. && orderInfo.getInt("is_send") == salesOrder.getSalesIsSend()
  500. && orderInfo.getInt("is_locked") == salesOrder.getSalesIsLocked()
  501. && orderInfo.getInt("is_separate") == salesOrder.getSalesIsSeparate()
  502. && orderInfo.getString("shipping_name").equals(salesOrder.getSalesPostFirm())
  503. && orderInfo.getString("invoice_no").equals(salesOrder.getSalesPostNum())
  504. )) {
  505. SalesOrder order = new SalesOrder();
  506. order.setSalesId(salesOrder.getSalesId());
  507. order.setSalesStatus(orderInfo.getInt("order_status"));
  508. order.setSalesShippingStatus(orderInfo.getInt("shipping_status"));
  509. order.setSalesPayStatus(orderInfo.getInt("pay_status"));
  510. order.setSalesProcessStatus(orderInfo.getInt("process_status"));
  511. order.setSalesIsSend(orderInfo.getInt("is_send"));
  512. order.setSalesIsLocked(orderInfo.getInt("is_locked"));
  513. order.setSalesIsSeparate(orderInfo.getInt("is_separate"));
  514. order.setSalesPostFirm(orderInfo.getString("shipping_name"));
  515. order.setSalesPostNum(orderInfo.getString("invoice_no"));
  516. salesOrders.add(order);
  517. }
  518. }
  519. }
  520. if (salesOrders != null && salesOrders.size() > 0) {
  521. //批量修改订单状态等信息
  522. return salesOrderMapper.updateOrderList(salesOrders);
  523. } else {
  524. return 1;
  525. }
  526. }
  527. @Override
  528. public Integer updateReturnOrderList(JSONArray orderList, List<SalesOrder> list) {
  529. List<SalesOrder> salesOrders = new ArrayList<SalesOrder>();
  530. //订单号相同时,判断状态,发货状态,物流公司,物流单号等是否相同,如果有一个不同,则需添加到salesOrders中进行同步
  531. for (int i = 0;i < orderList.size();i++) {
  532. JSONObject orderInfo = orderList.getJSONObject(i);
  533. for (SalesOrder salesOrder : list) {
  534. if (orderInfo.get("relating_order_sn").equals(salesOrder.getSalesOrderId())) {
  535. SalesOrder order = new SalesOrder();
  536. switch (orderInfo.getInt("process_type")) {
  537. case 1://退货
  538. order.setSalesOrderStatus(3);
  539. break;
  540. case 4://换货
  541. order.setSalesOrderStatus(2);
  542. break;
  543. default:
  544. order.setSalesOrderStatus(3);
  545. break;
  546. }
  547. order.setSalesId(salesOrder.getSalesId());
  548. salesOrders.add(order);
  549. }
  550. }
  551. }
  552. //批量修改订单状态等信息
  553. return salesOrderMapper.updateOrderList(list);
  554. }
  555. @Override
  556. public void addSalesOrderList(JSONObject obj) throws Exception{
  557. if (obj == null) {
  558. return;
  559. }
  560. JSONArray orderList = obj.getJSONArray("list");
  561. if (orderList == null || orderList.size() == 0) {
  562. return;
  563. }
  564. String endTime = sysConfigMapper.getSysConfig(1);
  565. for (int i = 0;i < orderList.size();i++) {
  566. JSONObject order = orderList.getJSONObject(i);
  567. //获取订单详情
  568. JSONObject orderInfo = null;
  569. try{
  570. orderInfo = efastOrderService.getOrderFormEfast(order.getString("deal_code"));
  571. }catch (Exception e){
  572. logger.info("获取订单失败;异常编号:505;失败原因:"+ e.getMessage() +"--获取失败订单号:" + orderList.getJSONObject(i).getString("deal_code"));
  573. }
  574. if (orderInfo == null) {
  575. continue;
  576. }
  577. if (!orderInfo.has("orders")) {
  578. continue;
  579. }
  580. //获取订单项集合
  581. JSONArray itemArray = orderInfo.getJSONArray("orders");
  582. if (itemArray == null || itemArray.size() == 0) {
  583. continue;
  584. }
  585. SalesOrder salesOrder = new SalesOrder();
  586. salesOrder.setSalesOrderId(order.getString("order_sn"));//订单编号
  587. salesOrder.setSalesDealCode(order.getString("deal_code"));//交易号
  588. salesOrder.setSalesOrderStatus(1);//订单状态
  589. salesOrder.setSalesShippingStatus(order.getInt("shipping_status"));//发货状态 0:未发货,1:已发货,3:备货中
  590. salesOrder.setSalesPayStatus(order.getInt("pay_status"));//是否付款 0:未付款,2:已付款
  591. salesOrder.setSalesProcessStatus(order.getInt("process_status"));//单据状态
  592. salesOrder.setSalesIsSend(order.getInt("is_send"));//是否通知配货
  593. salesOrder.setSalesIsLocked(order.getInt("is_locked"));//是否锁定
  594. salesOrder.setSalesIsSeparate(order.getInt("is_separate"));//是否缺货
  595. salesOrder.setSalesStatus(order.getInt("order_status"));//订单状态 0:未确认,1:已确认,2:挂起,3:作废
  596. salesOrder.setSalesPostFirm(order.getString("shipping_name").trim());//快递方式代码
  597. salesOrder.setSalesPostNum(order.getString("invoice_no").trim());//快递单号
  598. salesOrder.setSalesOpenId(order.getString("mobile").trim());//唯一标识
  599. salesOrder.setSalesPayType(efastOrderService.getPayType(order.getString("pay_name").trim()));//支付方式
  600. salesOrder.setSalesPayTime(new Date(order.getLong("pay_time")*1000));//支付时间
  601. salesOrder.setSalesUserRemark(order.getString("postscript"));//买家留言
  602. salesOrder.setSalesAdminRemark(order.getString("to_buyer"));//商家留言
  603. salesOrder.setSalesAmount((int)(order.getDouble("order_amount")*100));//应付款
  604. salesOrder.setSalesPayMoney((int)(order.getDouble("money_paid")*100));//已付款
  605. salesOrder.setSalesAddressName(order.getString("consignee").trim());//收货人
  606. String mobile = order.getString("mobile").replaceAll("[\\u00A0]+", "").trim();
  607. salesOrder.setSalesAddressTel(mobile);//收货人电话
  608. salesOrder.setSalesAddressInfo(order.getString("address").replaceAll(" ","-"));//收货地址
  609. salesOrder.setSalesShippingFee((int)(order.getDouble("shipping_fee")*100));//邮费
  610. salesOrder.setSalesCreateTime(DateTimeUtil.parse(order.getString("create_time"),"yyyy-MM-dd HH:mm:ss"));//创建时间
  611. if (order.getInt("shipping_status") == 1) {
  612. if(order.has("delivery_time")){
  613. salesOrder.setSalesSendTime(DateTimeUtil.parse(order.getString("delivery_time"),"yyyy-MM-dd HH:mm:ss"));//发货时间
  614. }else{
  615. salesOrder.setSalesSendTime(new Date());//发货时间
  616. }
  617. }
  618. salesOrder.setSalesDiscountMoney(salesOrder.getSalesAmount() - salesOrder.getSalesPayMoney());//优惠金额
  619. salesOrder.setSalesPledgeMoney(0);//押金金额
  620. salesOrder.setSalesRemainDeposit(0);//待提取金额
  621. salesOrder.setSalesSendType(2);//发货方式,默认为物流发货
  622. salesOrder.setSalesSalesTime(salesOrder.getSalesCreateTime());//订购时间
  623. salesOrder.setSalesWaitMoney(0);//待付金额
  624. salesOrder.setSalesLastMoney(salesOrder.getSalesPayMoney());//本次支付金额
  625. salesOrder.setSalesPayNumber("0000");//支付尾号
  626. salesOrder.setSalesType(1);//订单类型
  627. endTime = order.getString("create_time"); //获取
  628. //查询店铺信息
  629. StoreInfo storeInfo = new StoreInfo();
  630. storeInfo.setStoreEfast(order.getString("sd_id"));
  631. List<StoreInfo> storeList = storeInfoService.listStore(storeInfo);
  632. int storeId = 0;
  633. int companyId = 0;
  634. if (storeList != null && storeList.size() > 0) {
  635. storeInfo = storeList.get(0);
  636. storeId = storeInfo.getStoreId();
  637. companyId = storeInfo.getCompanyId();
  638. }
  639. salesOrder.setSalesStoreId(storeId);//店铺id
  640. salesOrder.setSalesCompanyId(companyId);//销售公司id
  641. List<SalesOrderItem> itemList = new ArrayList<SalesOrderItem>();
  642. for (int j = 0;j < itemArray.size();j++) {
  643. ProductColor color = new ProductColor();
  644. JSONObject itemJson = itemArray.getJSONObject(j);
  645. SalesOrderItem item = new SalesOrderItem();
  646. color.setColorBar(itemJson.getString("goods_sn"));
  647. List<ProductColor> colorList = productService.listproductAndColor(color);
  648. if (colorList != null && colorList.size() > 0) {
  649. color = colorList.get(0);
  650. item.setItemColorBar(itemJson.getString("goods_sn"));//商品69码
  651. item.setItemNum(itemJson.getInt("goods_number"));//商品数量
  652. item.setItemCreateTime(salesOrder.getSalesCreateTime());
  653. item.setItemColorId(color.getColorId());
  654. item.setItemProductColor(color.getColorName());
  655. item.setItemProductDiscount(color.getColorDiscount());
  656. item.setItemProductId(color.getColorProductId());
  657. item.setItemProductName(color.getProductName());
  658. item.setItemProductPic(color.getColorPicture());
  659. item.setItemProductType(color.getProductType());
  660. item.setItemProductPrice(color.getColorPrice());
  661. item.setItemIsSource(1);
  662. itemList.add(item);
  663. }
  664. // else {
  665. // //获取配件信息
  666. // FittingsInfo fittingsInfo = new FittingsInfo();
  667. // fittingsInfo.setFittingsBar(itemJson.getString("goods_sn"));
  668. // List<FittingsInfo> Fittings = fittingsInfoMapper.listFittings(fittingsInfo);
  669. // if (Fittings == null || Fittings.size() == 0) {
  670. // continue;
  671. // }
  672. // fittingsInfo = Fittings.get(0);
  673. // item.setItemColorBar(itemJson.getString("goods_sn"));//商品69码
  674. // item.setItemNum(itemJson.getInt("goods_number"));//商品数量
  675. // item.setItemCreateTime(salesOrder.getSalesCreateTime());
  676. // item.setItemColorId(fittingsInfo.getFittingsId());
  677. // item.setItemProductColor(fittingsInfo.getFittingsName());
  678. // item.setItemProductDiscount(fittingsInfo.getFittingsDiscount());
  679. // item.setItemProductId(fittingsInfo.getProductId());
  680. // item.setItemProductName(fittingsInfo.getFittingsName());
  681. // item.setItemProductPic("");
  682. // item.setItemProductType(0);
  683. // item.setItemProductPrice(fittingsInfo.getFittingsPrice());
  684. // item.setItemIsSource(2);
  685. // itemList.add(item);
  686. // }
  687. }
  688. //添加订单和订单项
  689. try{
  690. salesOrderService.addOrderAndItem(salesOrder,itemList);
  691. }catch (Exception e){
  692. logger.info("添加订单失败,异常编号:505;失败原因:+"+ e.getMessage() +"Efast编号:"+ salesOrder.getSalesOrderId());
  693. }
  694. }
  695. SysConfig sysConfig = new SysConfig(1,endTime);
  696. sysConfigMapper.updateSysConfig(sysConfig);
  697. }
  698. @Override
  699. @Transactional
  700. public boolean syncEfastOrder(JSONObject orderInfo) throws Exception {
  701. if (orderInfo == null) {
  702. throw new RuntimeException("获取Efast订单信息出错!");
  703. }
  704. if (!orderInfo.has("orders")) {
  705. throw new RuntimeException("获取Efast订单信息出错!");
  706. }
  707. //获取订单项集合
  708. JSONArray itemArray = orderInfo.getJSONArray("orders");
  709. if (itemArray == null || itemArray.size() == 0) {
  710. throw new RuntimeException("获取Efast订单信息出错!");
  711. }
  712. SalesOrder salesOrder = new SalesOrder();
  713. salesOrder.setSalesOrderId(orderInfo.getString("order_sn"));//订单编号
  714. salesOrder.setSalesDealCode(orderInfo.getString("deal_code"));//交易号
  715. salesOrder.setSalesOrderStatus(1);//订单状态
  716. salesOrder.setSalesShippingStatus(orderInfo.getInt("shipping_status"));//发货状态 0:未发货,1:已发货,3:备货中
  717. salesOrder.setSalesPayStatus(orderInfo.getInt("pay_status"));//是否付款 0:未付款,2:已付款
  718. salesOrder.setSalesProcessStatus(orderInfo.getInt("process_status"));//单据状态
  719. salesOrder.setSalesIsSend(orderInfo.getInt("is_send"));//是否通知配货
  720. salesOrder.setSalesIsLocked(orderInfo.getInt("is_locked"));//是否锁定
  721. salesOrder.setSalesIsSeparate(orderInfo.getInt("is_separate"));//是否缺货
  722. salesOrder.setSalesStatus(orderInfo.getInt("order_status"));//订单状态 0:未确认,1:已确认,2:挂起,3:作废
  723. salesOrder.setSalesPostFirm(new String(orderInfo.getString("shipping_name")).trim());//快递方式代码
  724. salesOrder.setSalesPostNum(new String(orderInfo.getString("invoice_no")).trim());//快递单号
  725. salesOrder.setSalesOpenId(orderInfo.getString("mobile").trim());//唯一标识
  726. salesOrder.setSalesPayType(efastOrderService.getPayType(orderInfo.getString("pay_name").trim()));//支付方式
  727. salesOrder.setSalesPayTime(new Date(orderInfo.getLong("pay_time")*1000));//支付时间
  728. salesOrder.setSalesUserRemark(orderInfo.getString("postscript"));//买家留言
  729. salesOrder.setSalesAdminRemark(orderInfo.getString("to_buyer"));//商家留言
  730. salesOrder.setSalesAmount((int)(orderInfo.getDouble("order_amount")*100));//应付款
  731. salesOrder.setSalesPayMoney((int)(orderInfo.getDouble("money_paid")*100));//已付款
  732. salesOrder.setSalesAddressName(orderInfo.getString("consignee"));//收货人
  733. String mobile = orderInfo.getString("mobile").replaceAll("[\\u00A0]+", "");
  734. salesOrder.setSalesAddressTel(mobile.trim());//收货人电话
  735. salesOrder.setSalesAddressInfo(orderInfo.getString("address").replaceAll(" ","-"));//收货地址
  736. salesOrder.setSalesShippingFee((int)(orderInfo.getDouble("shipping_fee")*100));//邮费
  737. salesOrder.setSalesCreateTime(new Date(orderInfo.getLong("pay_time")*1000));//创建时间
  738. if (orderInfo.getInt("shipping_status") == 1) {
  739. if(orderInfo.has("delivery_time")){
  740. salesOrder.setSalesSendTime(DateTimeUtil.parse(orderInfo.getString("delivery_time"),"yyyy-MM-dd HH:mm:ss"));//发货时间
  741. }else{
  742. salesOrder.setSalesSendTime(new Date());//发货时间
  743. }
  744. }
  745. salesOrder.setSalesDiscountMoney(salesOrder.getSalesAmount() - salesOrder.getSalesPayMoney());//优惠金额
  746. salesOrder.setSalesPledgeMoney(0);//押金金额
  747. salesOrder.setSalesRemainDeposit(0);//待提取金额
  748. salesOrder.setSalesSendType(2);//发货方式,默认为物流发货
  749. salesOrder.setSalesSalesTime(salesOrder.getSalesCreateTime());//订购时间
  750. salesOrder.setSalesWaitMoney(0);//待付金额
  751. salesOrder.setSalesLastMoney(salesOrder.getSalesPayMoney());//本次支付金额
  752. salesOrder.setSalesPayNumber("0000");//支付尾号
  753. salesOrder.setSalesType(1);//订单类型
  754. //查询店铺信息
  755. StoreInfo storeInfo = new StoreInfo();
  756. if (orderInfo.has("sd_id")) {
  757. storeInfo.setStoreEfast(orderInfo.getString("sd_id"));
  758. } else {
  759. storeInfo.setStoreEfast("1");
  760. }
  761. List<StoreInfo> storeList = storeInfoService.listStore(storeInfo);
  762. int storeId = 0;
  763. int companyId = 0;
  764. if (storeList != null && storeList.size() > 0) {
  765. storeInfo = storeList.get(0);
  766. storeId = storeInfo.getStoreId();
  767. companyId = storeInfo.getCompanyId();
  768. }
  769. salesOrder.setSalesStoreId(storeId);//店铺id
  770. salesOrder.setSalesCompanyId(companyId);//销售公司id
  771. List<SalesOrderItem> itemList = new ArrayList<SalesOrderItem>();
  772. for (int j = 0;j < itemArray.size();j++) {
  773. ProductColor color = new ProductColor();
  774. JSONObject itemJson = itemArray.getJSONObject(j);
  775. SalesOrderItem item = new SalesOrderItem();
  776. color.setColorBar(itemJson.getString("goods_barcode"));
  777. List<ProductColor> colorList = productService.listproductAndColor(color);
  778. if (colorList != null && colorList.size() > 0) {
  779. color = colorList.get(0);
  780. item.setItemColorBar(itemJson.getString("goods_barcode"));//商品69码
  781. item.setItemNum(itemJson.getInt("goods_number"));//商品数量
  782. item.setItemCreateTime(salesOrder.getSalesCreateTime());
  783. item.setItemColorId(color.getColorId());
  784. item.setItemProductColor(color.getColorName());
  785. item.setItemProductDiscount(color.getColorDiscount());
  786. item.setItemProductId(color.getColorProductId());
  787. item.setItemProductName(color.getProductName());
  788. item.setItemProductPic(color.getColorPicture());
  789. item.setItemProductType(color.getProductType());
  790. item.setItemProductPrice(color.getColorPrice());
  791. item.setItemIsSource(1);
  792. itemList.add(item);
  793. }
  794. // else {
  795. // //获取配件信息
  796. // FittingsInfo fittingsInfo = new FittingsInfo();
  797. // fittingsInfo.setFittingsBar(itemJson.getString("goods_barcode"));
  798. // List<FittingsInfo> Fittings = fittingsInfoMapper.listFittings(fittingsInfo);
  799. // if (Fittings == null || Fittings.size() == 0) {
  800. // continue;
  801. // }
  802. // fittingsInfo = Fittings.get(0);
  803. // item.setItemColorBar(itemJson.getString("goods_barcode"));//商品69码
  804. // item.setItemNum(itemJson.getInt("goods_number"));//商品数量
  805. // item.setItemCreateTime(salesOrder.getSalesCreateTime());
  806. // item.setItemColorId(fittingsInfo.getFittingsId());
  807. // item.setItemProductColor(fittingsInfo.getFittingsName());
  808. // item.setItemProductDiscount(fittingsInfo.getFittingsDiscount());
  809. // item.setItemProductId(fittingsInfo.getProductId());
  810. // item.setItemProductName(fittingsInfo.getFittingsName());
  811. // item.setItemProductPic("");
  812. // item.setItemProductType(0);
  813. // item.setItemProductPrice(fittingsInfo.getFittingsPrice());
  814. // item.setItemIsSource(2);
  815. // itemList.add(item);
  816. // }
  817. }
  818. boolean flag = salesOrderService.addOrderAndItem(salesOrder,itemList);
  819. if (flag) {
  820. return true;
  821. } else {
  822. throw new RuntimeException("添加订单项出错!");
  823. }
  824. }
  825. @Override
  826. public Integer getOrderInfoCount(SalesOrder salesOrder) {
  827. return salesOrderMapper.getOrderInfoCount(salesOrder);
  828. }
  829. @Override
  830. public List<SalesOrder> listOrderExcel(SalesOrder salesOrder) {
  831. return salesOrderMapper.listOrderExcel(salesOrder);
  832. }
  833. @Override
  834. public Integer listOrderExcelNum(SalesOrder salesOrder) {
  835. return salesOrderMapper.listOrderExcelNum(salesOrder);
  836. }
  837. @Override
  838. public Integer delOrder(String orderId) {
  839. return salesOrderMapper.delOrder(orderId);
  840. }
  841. @Override
  842. @Transactional
  843. public Integer delSalesOrder(Integer id) {
  844. //查询出库状态判断是否需要返还库存
  845. if(salesOrderMapper.getSalesOrderById(id).getSalesDeliver() == 2){
  846. returnInventory(id);
  847. }
  848. // 检查客诉是否使用订单,如果有使用订单,无法删除
  849. salesOrderMapper.delOrderItem(id);
  850. salesOrderMapper.delSalesOrder(id);
  851. return 1;
  852. }
  853. //执行删除和作废订单时返还库存
  854. public boolean returnInventory(Integer salesId){
  855. SalesOrderItem salesOrderItem = new SalesOrderItem();
  856. salesOrderItem.setItemOrderId(salesId);
  857. List<SalesOrderItem> listOrderitem = salesOrderService.listSalesOrderItem(salesOrderItem);
  858. SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  859. for(SalesOrderItem item : listOrderitem){
  860. InventoryInfo info = inventoryMapper.getByInventoryByBar(item.getItemColorBar());
  861. if(info != null){
  862. info.setInventoryGoodProductNum(info.getInventoryGoodProductNum() + item.getItemNum());
  863. info.setInventoryRecentRecord(sdf.format(new Date())+"删除/作废订单返还库存:"+item.getItemNum()+"件");
  864. inventoryMapper.updateById(info);
  865. //添加日志
  866. InventoryLog inventoryLog = new InventoryLog();
  867. inventoryLog.setLogProductName(info.getInventoryProductName());
  868. inventoryLog.setLogProductBar(info.getInventoryProductBar());
  869. inventoryLog.setLogRemainingNum(item.getItemNum());
  870. inventoryLog.setLogType(1);
  871. inventoryLog.setLogOperationType(1);
  872. inventoryLog.setLogDesc(sdf.format(new Date())+"删除/作废订单返还库存:"+item.getItemNum()+"件");
  873. inventoryLog.setLogQualityType(1);
  874. inventoryLog.setLogWarehouseId(1);
  875. inventoryLogMapper.insert(inventoryLog);
  876. }
  877. }
  878. return true;
  879. }
  880. @Override
  881. public Integer updateOrderItem(SalesOrderItem salesOrderItem) {
  882. return salesOrderMapper.updateOrderItem(salesOrderItem);
  883. }
  884. @Override
  885. public SalesOrder getSalesOrderByLogistics(SalesOrder salesOrder) {
  886. return salesOrderMapper.getSalesOrderByLogistics(salesOrder);
  887. }
  888. @Override
  889. public Integer updateOrderListIsDownload(List<SalesOrder> list) {
  890. return salesOrderMapper.updateOrderListIsDownload(list);
  891. }
  892. @Override
  893. public Integer updateSalesOrderByDealCode(SalesOrder salesOrder) {
  894. return salesOrderMapper.updateSalesOrderByDealCode(salesOrder);
  895. }
  896. @Override
  897. public List<LogisticsInfo> getLogisticsInfo(LogisticsInfo logisticsInfo) {
  898. return salesOrderMapper.getLogisticsInfo(logisticsInfo);
  899. }
  900. @Override
  901. public List<DownsingleRuleInfo> listDownsingleRule() {
  902. return salesOrderMapper.listDownsingleRule();
  903. }
  904. @Override
  905. public Integer getIsMachine(String colorBar) {
  906. return salesOrderMapper.getIsMachine(colorBar);
  907. }
  908. @Override
  909. public Integer getOrderBySalesDealCodeNum(String code) {
  910. return salesOrderMapper.getOrderBySalesDealCodeNum(code);
  911. }
  912. @Override
  913. public Integer listSalesOrderAndItemNum(SalesOrder salesOrder) {
  914. return salesOrderMapper.listSalesOrderAndItemNum(salesOrder);
  915. }
  916. @Override
  917. public List<SalesOrder> listSalesOrderAndItem(SalesOrder salesOrder) {
  918. return salesOrderMapper.listSalesOrderAndItem(salesOrder);
  919. }
  920. @Override
  921. public Integer getSalesOrderNum(SalesOrder salesOrder) {
  922. return salesOrderMapper.getSalesOrderNum(salesOrder);
  923. }
  924. @Transactional
  925. @Override
  926. public Integer listConfirmSalesOrderByBatch(String salesBatchId) {
  927. Integer flag = 0;
  928. SalesOrder salesOrder = new SalesOrder();
  929. salesOrder.setSalesBatchId(salesBatchId);
  930. List<SalesOrder> salesOrderList = salesOrderMapper.listSalesOrder(salesOrder);
  931. if(salesOrderList == null || salesOrderList.size() < 1){
  932. throw new RuntimeException("查询订单失败!");
  933. }
  934. for (SalesOrder so:salesOrderList){
  935. flag = salesOrderService.confirmSalesOrder(so.getSalesId());
  936. }
  937. return flag;
  938. }
  939. @Override
  940. public Integer noticeDistribution(SalesOrder salesOrder) {
  941. // 检查订单是否已经有了配送方式,如果没有不允许通知配货 -- 移到controller中自己添加
  942. // SalesOrder temp = salesOrderMapper.getSalesOrderById(salesOrder.getSalesId());
  943. // if (temp == null || temp.getSalesPostFirm() == null || temp.getSalesPostFirm().isEmpty()) {
  944. // return 0;
  945. // }
  946. return salesOrderMapper.noticeDistribution(salesOrder);
  947. }
  948. @Transactional
  949. @Override
  950. public Integer confirmSalesOrder(Integer saleId) {
  951. /*
  952. * 查询订单
  953. * 查询订单项
  954. * 删除订单
  955. * 修改查询的订单状态
  956. * 添加订单
  957. */
  958. if(saleId == null ){
  959. throw new RuntimeException("确认订单-订单id异常!");
  960. }
  961. SalesOrder salesOrder = salesOrderMapper.getSalesOrderById(saleId);
  962. if(salesOrder == null){
  963. throw new RuntimeException("确认订单-订单异常!");
  964. }
  965. Integer flag = 0;
  966. SalesOrderItem salesOrderItem = new SalesOrderItem();
  967. salesOrderItem.setItemOrderId(salesOrder.getSalesId());
  968. List<SalesOrderItem> salesOrderItemList = salesOrderMapper.listSalesOrderItem(salesOrderItem);
  969. if(salesOrderItemList == null || salesOrderItemList.size()<1){
  970. throw new RuntimeException("确认订单-查询订单项失败!");
  971. }
  972. salesOrder.setSalesOrderItemList(salesOrderItemList);
  973. flag = salesOrderMapper.delOrderById(salesOrder.getSalesId());
  974. if(flag < 1){
  975. throw new RuntimeException("确认订单-删除订单失败!");
  976. }
  977. flag = salesOrderMapper.delOrderItem(salesOrder.getSalesId());
  978. if(flag < 1){
  979. throw new RuntimeException("确认订单-删除订单项失败!");
  980. }
  981. //1:确认 状态
  982. salesOrder.setSalesStatus(1);
  983. boolean fl = salesOrderService.addRstOrderAndIteminfo(salesOrder);
  984. if(!fl){
  985. throw new RuntimeException("确认订单-添加订单失败!");
  986. }
  987. return flag;
  988. }
  989. @Override
  990. public Integer distributionExpress(SalesOrder salesOrder) {
  991. return salesOrderMapper.distributionExpress(salesOrder);
  992. }
  993. @Override
  994. public Integer listSalesPostFirm(SalesOrder salesOrder) {
  995. return salesOrderMapper.listSalesPostFirm(salesOrder);
  996. }
  997. @Override
  998. public Integer listSalesPostFirmByIds(SalesOrder salesOrder) {
  999. return salesOrderMapper.listSalesPostFirmByIds(salesOrder);
  1000. }
  1001. @Override
  1002. public SalesOrder getSalesOrderByPostNum(String postNum) {
  1003. return salesOrderMapper.getSalesOrderByPostNum(postNum);
  1004. }
  1005. @Transactional
  1006. @Override
  1007. public Integer updateDeliver(SalesOrder salesOrder) {
  1008. if(salesOrder.getSalesDeliver() == 2){//修改库存
  1009. if(!updateInventory(salesOrder.getSalesId())){
  1010. return 0;
  1011. }
  1012. }
  1013. return salesOrderMapper.updateDeliver(salesOrder);
  1014. }
  1015. public boolean updateInventory(Integer salesId){
  1016. SalesOrderItem salesOrderItem = new SalesOrderItem();
  1017. salesOrderItem.setItemOrderId(salesId);
  1018. List<SalesOrderItem> listOrderitem = salesOrderService.listSalesOrderItem(salesOrderItem);
  1019. SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  1020. for(SalesOrderItem item : listOrderitem){
  1021. InventoryInfo info = inventoryMapper.getByInventoryByBar(item.getItemColorBar());
  1022. if(info != null){
  1023. if(info.getInventoryGoodProductNum() >= item.getItemNum()){
  1024. info.setInventoryGoodProductNum(info.getInventoryGoodProductNum() - item.getItemNum());
  1025. info.setInventoryRecentRecord(sdf.format(new Date())+"出库:"+item.getItemNum()+"件");
  1026. inventoryMapper.updateById(info);
  1027. //添加日志
  1028. InventoryLog inventoryLog = new InventoryLog();
  1029. inventoryLog.setLogProductName(info.getInventoryProductName());
  1030. inventoryLog.setLogProductBar(info.getInventoryProductBar());
  1031. inventoryLog.setLogRemainingNum(item.getItemNum());
  1032. inventoryLog.setLogType(2);
  1033. inventoryLog.setLogOperationType(2);
  1034. inventoryLog.setLogDesc(sdf.format(new Date())+"待发货标记出库:"+item.getItemNum()+"件");
  1035. inventoryLog.setLogQualityType(1);
  1036. inventoryLog.setLogWarehouseId(1);
  1037. inventoryLogMapper.insert(inventoryLog);
  1038. }else{
  1039. return false;
  1040. }
  1041. }
  1042. }
  1043. return true;
  1044. }
  1045. @Override
  1046. public List<SalesOrderItem> getDeliverNum(SalesOrder salesOrder) {
  1047. return salesOrderMapper.getDeliverNum(salesOrder);
  1048. }
  1049. @Override
  1050. public List<Date> getNotSendDate() {
  1051. return salesOrderMapper.getNotSendDate();
  1052. }
  1053. @Override
  1054. public List<SalesOrder> salesOrderListAndItem(SalesOrder salesOrder) {
  1055. return salesOrderMapper.salesOrderListAndItem(salesOrder);
  1056. }
  1057. @Override
  1058. public PagedResult<SalesOrder> salesOrderListAndItemPage(int pageNO, int pageSize, SalesOrder salesOrder, boolean isTotalNum) {
  1059. PageHelper.startPage(pageNO, pageSize, isTotalNum);
  1060. List<SalesOrder> list = salesOrderMapper.salesOrderListAndItem(salesOrder);
  1061. return PageUtil.getPage(list);
  1062. }
  1063. @Override
  1064. public List<SalesOrderItem> selectSalesOrderItemList(Integer salesId) {
  1065. return salesOrderMapper.selectSalesOrderItemList(salesId);
  1066. }
  1067. @Transactional
  1068. @Override
  1069. public Boolean addCorrectInfo(OrderCorrectInfo orderCorrectInfo, String arrayItem, Admin admin) {
  1070. //添加更新信息
  1071. orderCorrectInfo.setAdminId(admin.getAdminId());
  1072. if(salesOrderMapper.addCorrectInfo(orderCorrectInfo) < 1){
  1073. throw new RuntimeException("更正订单-订单异常!");
  1074. }
  1075. //封装订单项数据
  1076. JSONArray jsonArray = JSONArray.fromObject(arrayItem);
  1077. List salesOrderItemList = ((List)JSONArray.toCollection(jsonArray, SalesOrderItem.class));
  1078. for(Object temp : salesOrderItemList){
  1079. SalesOrderItem salesOrderItem = (SalesOrderItem) temp;
  1080. //查询订单项原数量
  1081. SalesOrderItem orderItem = salesOrderMapper.getSalesOrderItem(salesOrderItem.getItemId());
  1082. OrderCorrectItem orderCorrectItem = new OrderCorrectItem();
  1083. orderCorrectItem.setCorrectId(orderCorrectInfo.getCorrectId());
  1084. orderCorrectItem.setOrderItemId(salesOrderItem.getItemId());
  1085. orderCorrectItem.setItemProductColor(salesOrderItem.getItemProductColor());
  1086. orderCorrectItem.setItemProductName(salesOrderItem.getItemProductName());
  1087. orderCorrectItem.setCorrectNum(salesOrderItem.getItemNum());
  1088. orderCorrectItem.setOldNum(orderItem.getItemNum());
  1089. if(orderItem.getItemNum().intValue() != salesOrderItem.getItemNum().intValue()){
  1090. //查询订单判断是否已出库
  1091. if(salesOrderMapper.getSalesOrderById(orderCorrectInfo.getItemOrderId()).getSalesDeliver() == 2){
  1092. //返还库存
  1093. SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  1094. InventoryInfo info = inventoryMapper.getByInventoryByBar(orderItem.getItemColorBar());
  1095. //添加日志
  1096. InventoryLog inventoryLog = new InventoryLog();
  1097. inventoryLog.setLogProductName(info.getInventoryProductName());
  1098. inventoryLog.setLogProductBar(info.getInventoryProductBar());
  1099. inventoryLog.setLogOperationType(1);
  1100. inventoryLog.setLogQualityType(1);
  1101. inventoryLog.setLogWarehouseId(1);
  1102. if(orderItem.getItemNum() > salesOrderItem.getItemNum()){//原数量大于更正后数量
  1103. info.setInventoryGoodProductNum(info.getInventoryGoodProductNum() + (orderItem.getItemNum() - salesOrderItem.getItemNum()));
  1104. info.setInventoryRecentRecord(sdf.format(new Date())+"更正订单返还库存:"+(orderItem.getItemNum() - salesOrderItem.getItemNum())+"件");
  1105. inventoryLog.setLogRemainingNum(orderItem.getItemNum() - salesOrderItem.getItemNum());
  1106. inventoryLog.setLogType(2);
  1107. inventoryLog.setLogDesc(sdf.format(new Date())+"更正订单返还库存:"+(orderItem.getItemNum() - salesOrderItem.getItemNum())+"件");
  1108. }else if(orderItem.getItemNum() < salesOrderItem.getItemNum()){
  1109. if(info.getInventoryGoodProductNum() > (salesOrderItem.getItemNum() - orderItem.getItemNum())){
  1110. info.setInventoryGoodProductNum(info.getInventoryGoodProductNum() - (salesOrderItem.getItemNum() - orderItem.getItemNum()));
  1111. info.setInventoryRecentRecord(sdf.format(new Date())+"更正订单减少库存:"+(orderItem.getItemNum() - salesOrderItem.getItemNum())+"件");
  1112. inventoryLog.setLogRemainingNum(salesOrderItem.getItemNum() - orderItem.getItemNum());
  1113. inventoryLog.setLogType(1);
  1114. inventoryLog.setLogDesc(sdf.format(new Date())+"更正订单减少库存:"+(salesOrderItem.getItemNum() - orderItem.getItemNum())+"件");
  1115. }else{
  1116. return false;
  1117. }
  1118. }
  1119. inventoryMapper.updateById(info);
  1120. inventoryLogMapper.insert(inventoryLog);
  1121. }
  1122. //修改订单项数量
  1123. orderItem.setItemNum(salesOrderItem.getItemNum());
  1124. if(salesOrderMapper.updateOrderItemById(orderItem) < 1){
  1125. throw new RuntimeException("更正订单-修改订单项数量失败!");
  1126. }
  1127. if(salesOrderMapper.addCorrectItem(orderCorrectItem) < 1){
  1128. throw new RuntimeException("更正订单-添加记录失败!");
  1129. }
  1130. }
  1131. }
  1132. return true;
  1133. }
  1134. //更正订单时返还库存
  1135. public boolean returnInventoryByItemId(Integer itemId){
  1136. SalesOrderItem salesOrderItem = new SalesOrderItem();
  1137. salesOrderItem.setItemId(itemId);
  1138. List<SalesOrderItem> listOrderitem = salesOrderService.listSalesOrderItem(salesOrderItem);
  1139. SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  1140. for(SalesOrderItem item : listOrderitem){
  1141. InventoryInfo info = inventoryMapper.getByInventoryByBar(item.getItemColorBar());
  1142. if(info != null){
  1143. info.setInventoryGoodProductNum(info.getInventoryGoodProductNum() + item.getItemNum());
  1144. info.setInventoryRecentRecord(sdf.format(new Date())+"删除/作废订单返还库存:"+item.getItemNum()+"件");
  1145. inventoryMapper.updateById(info);
  1146. //添加日志
  1147. InventoryLog inventoryLog = new InventoryLog();
  1148. inventoryLog.setLogProductName(info.getInventoryProductName());
  1149. inventoryLog.setLogProductBar(info.getInventoryProductBar());
  1150. inventoryLog.setLogRemainingNum(item.getItemNum());
  1151. inventoryLog.setLogType(1);
  1152. inventoryLog.setLogOperationType(1);
  1153. inventoryLog.setLogDesc(sdf.format(new Date())+"删除/作废订单返还库存:"+item.getItemNum()+"件");
  1154. inventoryLog.setLogQualityType(1);
  1155. inventoryLog.setLogWarehouseId(1);
  1156. inventoryLogMapper.insert(inventoryLog);
  1157. }
  1158. }
  1159. return true;
  1160. }
  1161. @Override
  1162. public Integer addCorrectItem(OrderCorrectItem orderCorrectItem) {
  1163. return salesOrderMapper.addCorrectItem(orderCorrectItem);
  1164. }
  1165. @Override
  1166. public OrderCorrectInfo getOrderCorrectInfo(Integer correctId) {
  1167. return salesOrderMapper.getOrderCorrectInfo(correctId);
  1168. }
  1169. @Override
  1170. public List<OrderCorrectItem> listOrderCorrectItem(Integer correctId) {
  1171. return salesOrderMapper.listOrderCorrectItem(correctId);
  1172. }
  1173. @Override
  1174. public SalesOrderItem getSalesOrderItem(Integer itemId) {
  1175. return salesOrderMapper.getSalesOrderItem(itemId);
  1176. }
  1177. @Override
  1178. public Integer updateOrderItemById(SalesOrderItem salesOrderItem) {
  1179. return salesOrderMapper.updateOrderItemById(salesOrderItem);
  1180. }
  1181. @Override
  1182. public List<OrderCorrectInfo> listOrderCorrectInfo(Integer orderId) {
  1183. return salesOrderMapper.listOrderCorrectInfo(orderId);
  1184. }
  1185. @Override
  1186. public OrderWarehouse selectAdminWarehouse(Integer adminId) {
  1187. return salesOrderMapper.selectAdminWarehouse(adminId);
  1188. }
  1189. @Override
  1190. public List<OrderWarehouse> listOrderWarehouse() {
  1191. return salesOrderMapper.listOrderWarehouse();
  1192. }
  1193. @Transactional
  1194. @Override
  1195. public List<SalesOrder> salesOrderAndItemStat(SalesOrder salesOrder) {
  1196. return salesOrderMapper.salesOrderAndItemStat(salesOrder);
  1197. }
  1198. @Transactional
  1199. @Override
  1200. public Integer splitOrder(String mainOrderId, List<SalesOrder> salesOrderList) {
  1201. Integer flag = 0;
  1202. SalesOrder mainOrder = new SalesOrder();
  1203. mainOrder.setSalesDealCode(mainOrderId);
  1204. List<SalesOrder> orderList = salesOrderService.salesOrderListAndItem(mainOrder);
  1205. SalesOrder or = new SalesOrder();
  1206. or.setSalesMainOrderId(orderList.get(0).getSalesId());
  1207. //该订单为主订单
  1208. List<SalesOrder> sonSalesOrderList = salesOrderService.salesOrderListAndItem(or);
  1209. orderList.addAll(sonSalesOrderList);
  1210. for (SalesOrder salesOrder:salesOrderList) {
  1211. for (int j=0;j<orderList.size();j++){
  1212. if(salesOrder.getSalesDealCode().equals(orderList.get(j).getSalesDealCode())){
  1213. orderList.remove(j);
  1214. }
  1215. }
  1216. if(salesOrder.getSalesId() != null && salesOrder.getSalesShippingStatus() > 0){
  1217. continue;
  1218. }
  1219. //create order item
  1220. for (SalesOrderItem itemSaleItem:salesOrder.getSalesOrderItemList()) {
  1221. ProductColor productColor = productMapper.getProductBySku(itemSaleItem.getItemColorBar());
  1222. itemSaleItem.setItemProductId(productColor.getColorProductId());
  1223. itemSaleItem.setItemProductColor(productColor.getColorName());
  1224. itemSaleItem.setColorAbbreviation(productColor.getColorAbbreviation());
  1225. itemSaleItem.setProductAbbreviation(productColor.getColorAbbreviation());
  1226. itemSaleItem.setItemIsSource(1);
  1227. itemSaleItem.setItemProductDiscount(productColor.getColorDiscount());
  1228. itemSaleItem.setItemProductPrice(productColor.getColorPrice());
  1229. itemSaleItem.setItemProductPic(productColor.getColorPicture());
  1230. itemSaleItem.setItemProductName(productColor.getProductName());
  1231. itemSaleItem.setItemProductType(productColor.getProductType());
  1232. itemSaleItem.setItemColorId(productColor.getColorId());
  1233. if(salesOrder.getSalesId() != null){
  1234. itemSaleItem.setItemOrderId(salesOrder.getSalesId());
  1235. }
  1236. }
  1237. Integer salesId = salesOrder.getSalesId();
  1238. if(salesId == null){
  1239. //添加订单和订单项
  1240. salesOrderService.addOrderAndIteminfo(salesOrder,salesOrder.getSalesOrderItemList());
  1241. }else{
  1242. //其余全部做修改,删除订单项,添加新的订单项
  1243. flag = salesOrderMapper.delOrderItem(salesOrder.getSalesId());
  1244. if(flag < 1){
  1245. throw new RuntimeException("删除订单项失败,订单交易号:"+salesOrder.getSalesDealCode());
  1246. }
  1247. flag = salesOrderMapper.addOrderItemList(salesOrder.getSalesOrderItemList());
  1248. if(flag < 1){
  1249. throw new RuntimeException("添加订单项失败,订单交易号:"+salesOrder.getSalesDealCode());
  1250. }
  1251. }
  1252. }
  1253. for (SalesOrder soDelete:orderList) {
  1254. flag = salesOrderService.delSalesOrder(soDelete.getSalesId());
  1255. if(flag < 1){
  1256. throw new RuntimeException("删除订单失败,删除订单交易号:"+soDelete.getSalesDealCode());
  1257. }
  1258. }
  1259. return flag;
  1260. }
  1261. @Override
  1262. public AfterrulesInfo getAfterrulesInfo(Integer storeId) {
  1263. return salesOrderMapper.getAfterrulesInfo(storeId);
  1264. }
  1265. @Override
  1266. public Integer updateOrderItemReturnNum(SalesOrderItem salesOrderItem) {
  1267. return salesOrderMapper.updateOrderItemReturnNum(salesOrderItem);
  1268. }
  1269. @Override
  1270. public List<SmsSignatureInfo> listSmsSignatureInfo(SmsSignatureInfo smsSignatureInfo) {
  1271. return salesOrderMapper.listSmsSignatureInfo(smsSignatureInfo);
  1272. }
  1273. @Override
  1274. public List<SmsTemplateInfo> listSmsTemplateInfo(SmsTemplateInfo smsTemplateInfo) {
  1275. return salesOrderMapper.listSmsTemplateInfo(smsTemplateInfo);
  1276. }
  1277. }