From 5bc7091e58978baea6537ca68a6afef5c22f31e7 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期五, 12 一月 2024 08:19:23 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |   80 ++++++++++++++++-----------------------
 1 files changed, 33 insertions(+), 47 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index a8cb3bb..20e0152 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -79,9 +79,10 @@
     private ManLocDetlService manLocDetlService;
     @Autowired
     private ManLocDetlMapper manLocDetlMapper;
-
     @Autowired
     private  DocTypeService docTypeService;
+    @Autowired
+    private MatV2Service matV2Service;
     @Override
     @Transactional
     public void comb(CombParam param, Long userId) {
@@ -136,11 +137,16 @@
 
             for (DetlDto detlDto : detlDtos) {
                 Mat mat = matService.selectByMatnr(detlDto.getMatnr());
-                if (Cools.isEmpty(mat)) {
-                    throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�");
-                }
                 WaitPakin waitPakin = new WaitPakin();
-                waitPakin.sync(mat);
+                if (Cools.isEmpty(mat)) {
+                    MatV2 matV2 = matV2Service.selectOne(new EntityWrapper<MatV2>().eq("matnr", detlDto.getMatnr()));
+                    if(Cools.isEmpty(matV2)){
+                        throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�");
+                    }
+                    waitPakin.sync(matV2);
+                } else {
+                    waitPakin.sync(mat);
+                }
                 waitPakin.setBatch(detlDto.getBatch());
                 waitPakin.setZpallet(param.getBarcode());   // 鎵樼洏鐮�
                 waitPakin.setIoStatus("N");     // 鍏ュ嚭鐘舵��
@@ -669,20 +675,15 @@
                 return R.error("璇ヨ鍗曟槸鍑哄簱璁㈠崟锛屾棤娉曞叆搴�");
             }
 
-            OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>()
-                    .eq("order_no", jsonOrderDetl.getOrderNo())
-                    .and()
-                    .eq("maktx",jsonOrderDetl.getMaktx()));
+            OrderDetl orderDetl = orderDetlService.selectItem(jsonOrderDetl.getOrderNo(),jsonOrderDetl.getMatnr(),jsonOrderDetl.getBatch());
             if (Cools.isEmpty(orderDetl)) {
                 return R.error("鍗曟嵁鏄庣粏鏈夎,璇锋鏌�");
             }
             if (orderDetl.getAnfme() - (jsonOrderDetl.getAnfme() + orderDetl.getWorkQty()) < 0) {
                 return R.error("鍏ュ簱鏁伴噺澶т簬鍙叆鏁伴噺");
             }
-            ManLocDetl checkManLocDetl = manLocDetlService.selectOne(new EntityWrapper<ManLocDetl>()
-                    .eq("loc_no", jsonLocNo)
-                    .eq("matnr", orderDetl.getMatnr())
-                    .eq("batch",orderDetl.getBatch()));
+            //鏌ヨ骞冲簱涓槸鍚︽湁涓�鏍风殑鐗╂枡鍙凤紝鏈夌殑璇濈洿鎺ュ鍔犳暟閲�
+            ManLocDetl checkManLocDetl = manLocDetlService.selectInventory(jsonLocNo,orderDetl.getMatnr(),jsonOrderDetl.getBatch());
             if (checkManLocDetl == null) {
                 ManLocDetl manLocDetl = new ManLocDetl();
                 Synchro.Copy(orderDetl, manLocDetl);
@@ -694,13 +695,13 @@
                 manLocDetl.setModiTime(date);
                 manLocDetl.setCreateTime(date);
                 manLocDetl.setBatch(jsonOrderDetl.getBatch());
-                manLocDetlService.insert(manLocDetl);
+                if(!manLocDetlService.insert(manLocDetl)){
+                    return R.error("淇敼骞冲簱鐗╂枡澶辫触锛�");
+                }
             } else {
-                checkManLocDetl.setAnfme(checkManLocDetl.getAnfme() + jsonOrderDetl.getAnfme());
-                checkManLocDetl.setModiTime(date);
-                manLocDetlService.update(checkManLocDetl, new EntityWrapper<ManLocDetl>()
-                        .eq("loc_no", jsonLocNo)
-                        .eq("matnr", orderDetl.getMatnr()));
+                if(manLocDetlService.increase(checkManLocDetl.getAnfme() + jsonOrderDetl.getAnfme(), jsonOrderDetl.getOrderNo(), jsonOrderDetl.getMaktx(), jsonOrderDetl.getBatch())<=0){
+                    return R.error("淇敼骞冲簱鐗╂枡澶辫触锛�");
+                }
             }
             orderDetl.setQty(orderDetl.getQty() + jsonOrderDetl.getAnfme());
             orderDetl.setWorkQty(orderDetl.getWorkQty() + jsonOrderDetl.getAnfme());
@@ -748,46 +749,30 @@
             if (Cools.isEmpty(node, order)) {
                 return R.error("鍙傛暟涓虹┖");
             }
-            OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>()
-                    .eq("order_no", jsonOrderDetl.getOrderNo())
-                    .and()
-                    .eq("maktx",jsonOrderDetl.getMaktx())
-                    .and()
-                    .eq("batch",jsonOrderDetl.getBatch()));
+            OrderDetl orderDetl = orderDetlService.selectItem(jsonOrderDetl.getOrderNo(),jsonOrderDetl.getMatnr(),jsonOrderDetl.getBatch());
             if (Cools.isEmpty(orderDetl)) {
                 return R.error("鍗曟嵁鏄庣粏鏈夎,璇锋鏌�");
             }
             if (jsonOrderDetl.getAnfme() > (orderDetl.getAnfme() - orderDetl.getWorkQty())) {
                 return R.error("鍑哄簱鏁伴噺澶т簬鍗曟嵁鍙嚭鏁伴噺");
             }
-            ManLocDetl manLocDetl = manLocDetlService.selectOne(new EntityWrapper<ManLocDetl>()
-                    .eq("loc_no", jsonLocNo)
-                    .and()
-                    .eq("maktx", jsonOrderDetl.getMaktx())
-                    .and()
-                    .eq("batch",jsonOrderDetl.getBatch()));
-            if (manLocDetl == null) {
+            //鏌ヨ骞冲簱涓槸鍚︽湁涓�鏍风殑鐗╂枡鍙�
+            ManLocDetl checkManLocDetl = manLocDetlService.selectInventory(jsonLocNo,orderDetl.getMatnr(),orderDetl.getBatch());
+            if (checkManLocDetl == null) {
                 return R.error("璇ュ簱浣嶆病鏈夊嚭搴撶殑鐗╂枡淇℃伅");
             }
-            if (jsonOrderDetl.getAnfme() > manLocDetl.getAnfme()) {
+            if (jsonOrderDetl.getAnfme() > checkManLocDetl.getAnfme()) {
                 return R.error("鍑哄簱鏁伴噺澶т簬鍙嚭鏁伴噺");
             }
-            Double finalQty = manLocDetl.getAnfme() - jsonOrderDetl.getAnfme();
+            Double finalQty = checkManLocDetl.getAnfme() - jsonOrderDetl.getAnfme();
             if (finalQty <= 0){
-                manLocDetlService.delete(new EntityWrapper<ManLocDetl>()
-                        .eq("loc_no", jsonLocNo)
-                        .and()
-                        .eq("matnr", orderDetl.getMatnr())
-                        .and()
-                        .eq("batch",jsonOrderDetl.getBatch()));
+                if(manLocDetlService.deleteDatailed(jsonLocNo, jsonOrderDetl.getMatnr(), jsonOrderDetl.getBatch())<=0){
+                    return R.error("淇敼骞冲簱鐗╂枡澶辫触锛�");
+                }
             }else {
-                manLocDetl.setAnfme(finalQty);
-                manLocDetl.setModiTime(date);
-                manLocDetlService.update(manLocDetl,new EntityWrapper<ManLocDetl>()
-                        .eq("loc_no", jsonLocNo)
-                        .eq("matnr", orderDetl.getMatnr())
-                        .and()
-                        .eq("batch",jsonOrderDetl.getBatch()));
+                if(manLocDetlService.increase(finalQty, jsonLocNo, jsonOrderDetl.getMatnr(), jsonOrderDetl.getBatch())<=0){
+                    return R.error("淇敼骞冲簱鐗╂枡澶辫触锛�");
+                }
             }
             orderDetl.setQty(orderDetl.getQty() + jsonOrderDetl.getAnfme());
             orderDetl.setWorkQty(orderDetl.getWorkQty() + jsonOrderDetl.getAnfme());
@@ -814,4 +799,5 @@
         return R.ok("涓嬫灦瀹屾垚");
     }
 
+
 }

--
Gitblit v1.9.1