From 15c8f00ab3a1e3d2d96b56bae0ec11efedd60231 Mon Sep 17 00:00:00 2001
From: 18516761980 <4761516tqsxp>
Date: 星期三, 29 九月 2021 11:14:15 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java |   50 ++++++++++++++++++++++++++++++++------------------
 1 files changed, 32 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
index 0282b28..3f73da9 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java
@@ -10,7 +10,10 @@
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.common.service.erp.ErpService;
+import com.zy.common.service.erp.entity.OutStockBillEntry;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
@@ -22,9 +25,10 @@
 /**
  * Created by vincent on 2020/7/6
  */
+@Slf4j
 @Service
 @RestController
-public class WorkLogHandler extends AbstractHandler<String> {
+public class WorkLogHandler extends AbstractHandler<Exception> {
 
     @Autowired
     private WrkMastService wrkMastService;
@@ -40,23 +44,13 @@
     private WaitPakinLogService waitPakinLogService;
     @Autowired
     private ErpService erpService;
-
-    @GetMapping("/test1")
-    public String test1(String barcode){
-        Wrapper<WaitPakin> wrapper = new EntityWrapper<WaitPakin>().eq("zpallet", barcode);
-        // erp鍏宠仈璁㈠崟澶勭悊
-        List<WaitPakin> waitPakins = waitPakinService.selectList(wrapper);
-        for (WaitPakin waitPakin : waitPakins) {
-            boolean erpRes = erpService.incrementPakIn(waitPakin.getSupplier(), waitPakin.getMatnr(), waitPakin.getAnfme());
-            if (!erpRes) {
-                exceptionHandle("鏇存柊ERP鍏ュ簱鏁版嵁[matnr={0}]澶辫触", waitPakin.getMatnr());
-            }
-        }
-        return "ok";
-    }
+    @Autowired
+    private OutStockService outStockService;
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
 
     @Transactional
-    public ReturnT<String> start(WrkMast wrkMast) {
+    public ReturnT<Exception> start(WrkMast wrkMast) {
         try {
 
             if (!Cools.isEmpty(wrkMast.getBarcode())) {
@@ -84,6 +78,26 @@
                 waitPakinService.delete(wrapper);
             }
 
+            // erp鍏宠仈鍑哄簱璁㈠崟澶勭悊
+            if (wrkMast.getIoType() == 101 || wrkMast.getIoType() == 53) {
+                EntityWrapper<WrkDetl> wrapper = new EntityWrapper<>();
+                // 鑾峰彇宸ヤ綔妗e唴鐗╂枡娓呭崟
+                List<WrkDetl> wrkDetls = wrkDetlService.selectList(wrapper.eq("wrk_no", wrkMast.getWrkNo()).and().isNotNull("supplier"));
+                for (WrkDetl wrkDetl: wrkDetls) {
+                    if (!Cools.isEmpty(wrkDetl)) {
+                        Integer FInterI = outStockService.queryOutStockFInterID(wrkDetl.getSupplier()); // 鑾峰彇鍑哄簱鍗曚富琛ㄤ富閿�
+                        if (!Cools.isEmpty(FInterI)) {
+                            if (!erpService.incrementCPakOut(FInterI, wrkDetl.getMatnr(),  wrkDetl.getAnfme(), wrkDetl.getSupplier())) {
+                                exceptionHandle("[xtyasrs_dual]鏇存柊ERP鎴愬搧鍑哄簱鏁版嵁[matnr={0}]澶辫触", wrkDetl.getMatnr());
+                            }
+                            if (!outStockService.incrementCPakOut(FInterI, wrkDetl.getMatnr(),  wrkDetl.getAnfme(), wrkDetl.getSupplier())) {
+                                exceptionHandle("[xtyasrs]鏇存柊ERP鎴愬搧鍑哄簱鏁版嵁[matnr={0}]澶辫触", wrkDetl.getMatnr());
+                            }
+                        }
+                    }
+                }
+            }
+
             // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
             if (!wrkMastLogService.save(wrkMast.getWrkNo())) {
                 exceptionHandle("淇濆瓨宸ヤ綔鍘嗗彶妗workNo={0}]澶辫触", wrkMast.getWrkNo());
@@ -101,9 +115,9 @@
 //                exceptionHandle("鍒犻櫎宸ヤ綔鏄庣粏妗workNo={0}]澶辫触", wrkMast.getWrkNo());
             }
         } catch (Exception e) {
-            e.printStackTrace();
+            log.error("fail", e);
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-            return FAIL.setMsg(e.getMessage());
+            return FAIL.setContent(e);
         }
         return SUCCESS;
     }

--
Gitblit v1.9.1