From e768d9f666e139cea2c40e542f6e6b50ea7fc453 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 29 五月 2024 16:21:17 +0800
Subject: [PATCH] #pda平库上架

---
 zy-asrs-common/src/main/java/com/zy/asrs/common/wms/service/impl/MobileServiceImpl.java |   60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 60 insertions(+), 0 deletions(-)

diff --git a/zy-asrs-common/src/main/java/com/zy/asrs/common/wms/service/impl/MobileServiceImpl.java b/zy-asrs-common/src/main/java/com/zy/asrs/common/wms/service/impl/MobileServiceImpl.java
index 9aaacf0..ee572f3 100644
--- a/zy-asrs-common/src/main/java/com/zy/asrs/common/wms/service/impl/MobileServiceImpl.java
+++ b/zy-asrs-common/src/main/java/com/zy/asrs/common/wms/service/impl/MobileServiceImpl.java
@@ -5,11 +5,16 @@
 import com.zy.asrs.common.domain.param.MobileAdjustParam;
 import com.zy.asrs.common.openapi.entity.param.CombParam;
 import com.zy.asrs.common.wms.entity.*;
+import com.zy.asrs.common.wms.mapper.LocDetlMapper;
 import com.zy.asrs.common.wms.service.*;
 import com.zy.asrs.framework.common.BaseRes;
 import com.zy.asrs.framework.common.Cools;
+import com.zy.asrs.framework.common.R;
 import com.zy.asrs.framework.exception.CoolException;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.ibatis.session.ExecutorType;
+import org.apache.ibatis.session.SqlSession;
+import org.apache.ibatis.session.SqlSessionFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -40,6 +45,12 @@
     private WrkMastService wrkMastService;
     @Autowired
     private WrkDetlService wrkDetlService;
+    @Autowired
+    private LocMastService locMastService;
+    @Autowired
+    private LocDetlService locDetlService;
+    @Autowired
+    private WaitPakinLogService waitPakinLogService;
 
     @Override
     @Transactional
@@ -222,4 +233,53 @@
         }
 
     }
+
+    @Override
+    @Transactional
+    public R WarehouseIn(String locNo, String barcode,Long hostId) {
+       //鍒ゆ柇搴撲綅鐘舵��
+        LocMast locMast = locMastService.getOne(new LambdaQueryWrapper<LocMast>().eq(LocMast::getLocNo, locNo).eq(LocMast::getHostId,hostId));
+        if (Cools.isEmpty(locMast)){
+            return R.error("璇ュ簱浣嶄笉瀛樺湪");
+        }
+        if (!locMast.getLocSts().equals("O")){
+            return R.error("璇ュ簱浣嶇姸鎬佷负锛�"+locMast.getLocSts()+",绂佹鍏ュ簱");
+        }
+        //鏌ヨ缁勬墭鏁版嵁
+        List<WaitPakin> list = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getZpallet, barcode).eq(WaitPakin::getHostId, hostId));
+        if (Cools.isEmpty(list)){
+            return R.error("鏈壘鍒扮粍鎵樹俊鎭�");
+        }
+        Date now = new Date();
+        //鎻掑叆搴撳瓨鏁版嵁
+        for (WaitPakin waitPakin: list){
+            Mat mat = matService.getOne(new LambdaQueryWrapper<Mat>().eq(Mat::getMatnr, waitPakin.getMatnr()).eq(Mat::getHostId, hostId));
+            LocDetl locDetl = new LocDetl();
+            locDetl.sync(mat);
+            locDetl.setLocNo(locNo);
+//            locDetl.setBarcode(waitPakin.getBarcode());
+            locDetl.setZpallet(waitPakin.getZpallet());
+            locDetl.setAnfme(waitPakin.getAnfme());
+            locDetl.setBatch(waitPakin.getBatch());
+//            locDetl.setWeight(waitPakin.getWeight());
+            locDetl.setHostId(hostId);
+            locDetl.setModiTime(now);
+            locDetl.setAppeTime(now);
+            locDetlService.save(locDetl);
+        }
+        //淇敼搴撲綅鐘舵��
+        locMast.setLocSts("F");
+        locMast.setModiTime(now);
+        locMastService.updateById(locMast);
+
+        // 淇濆瓨鍏ュ簱閫氱煡妗e巻鍙叉。
+        if (!waitPakinLogService.saveToHistory(barcode, hostId)) {
+            throw new CoolException("淇濆瓨缁勬墭鏁版嵁澶辫触");
+        }
+        // 鍒犻櫎鍏ュ簱閫氱煡妗�
+        if (!waitPakinService.remove(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getZpallet, barcode).eq(WaitPakin::getHostId, hostId))) {
+            throw new CoolException("鍒犻櫎缁勬墭鏁版嵁澶辫触");
+        }
+        return R.ok("涓婃灦鎴愬姛");
+    }
 }

--
Gitblit v1.9.1