From 28b01f6a80a38883d61b456b13936baa0291664e Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 14 四月 2021 13:45:21 +0800
Subject: [PATCH] #

---
 src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java |   50 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 50 insertions(+), 0 deletions(-)

diff --git a/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java b/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java
index 5506500..0c0cb46 100644
--- a/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java
+++ b/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java
@@ -9,9 +9,11 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import zy.cloud.wms.common.model.BillDto;
 import zy.cloud.wms.common.model.MatnrDto;
 import zy.cloud.wms.common.model.OrderStoDto;
 import zy.cloud.wms.common.service.MainService;
+import zy.cloud.wms.common.service.erp.ErpService;
 import zy.cloud.wms.common.utils.VersionUtils;
 import zy.cloud.wms.manager.entity.*;
 import zy.cloud.wms.manager.entity.param.*;
@@ -51,6 +53,8 @@
     private ItemService itemService;
     @Autowired
     private CstmrService cstmrService;
+    @Autowired
+    private ErpService erpService;
 
     @Override
     @Transactional
@@ -96,6 +100,30 @@
                     throw new CoolException("鏂板搴撳瓨鏄庣粏妗eけ璐�");
                 }
             }
+        }
+
+        // 涓婃姤缁檈rp
+        List<BillDto> dtos = new ArrayList<>();
+        for (MatnrDto dto : param.getMats()) {
+            BillDto billDto = new BillDto();
+            billDto.setMatnr(dto.getMatnr());
+            billDto.setQty(dto.getCount());
+            dtos.add(billDto);
+        }
+        Integer docId = Optional.ofNullable(param.getDocType()).orElse(34);
+        String docNum = String.valueOf(snowflakeIdWorker.nextId());
+        switch (docId) {
+            case 34:    // 閲囪喘鍗�
+                docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);
+                break;
+            case 45:    // 閿�鍞��璐у崟
+                docNum = "SR-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);
+                break;
+            default:
+                break;
+        }
+        if (!erpService.uploadBill(dtos, docId, docNum)) {
+            throw new CoolException("鏃犳硶涓婃姤鑷砮rp");
         }
 
         return R.ok("鍏ュ簱鎴愬姛");
@@ -160,6 +188,18 @@
 
             }
 
+        }
+
+        // 涓婃姤缁檈rp
+        List<BillDto> dtos = new ArrayList<>();
+        for (Comb comb : combs) {
+            BillDto billDto = new BillDto();
+            billDto.setMatnr(comb.getMatnr());
+            billDto.setQty(comb.getAnfme());
+            dtos.add(billDto);
+        }
+        if (!erpService.uploadBill(dtos, param.getDocType(), docNum)) {
+            throw new CoolException("鏃犳硶涓婃姤鑷砮rp");
         }
         return R.ok();
     }
@@ -666,6 +706,16 @@
         if (!checkService.updateById(check)) {
             throw new CoolException("淇敼鐩樼偣璁板綍鐘舵�佸け璐�");
         }
+
+        // 涓婃姤缁檈rp
+        List<BillDto> dtos = new ArrayList<>();
+        BillDto billDto = new BillDto();
+        billDto.setMatnr(check.getMatnr());
+        billDto.setQty(Math.abs(check.getDiffQty()));
+        dtos.add(billDto);
+        if (!erpService.uploadBill(dtos, docId.intValue(), docNum)) {
+            throw new CoolException("鏃犳硶涓婃姤鑷砮rp");
+        }
         return R.ok();
     }
 

--
Gitblit v1.9.1