From e26a08269c24077cdac7ca3992fc068edd5971aa Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 12 五月 2025 15:10:30 +0800
Subject: [PATCH] #AGV站点绑定

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |   49 ++++++++++++++++++-------------------------------
 1 files changed, 18 insertions(+), 31 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
index 4538f27..70094d9 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java
@@ -2,7 +2,6 @@
 
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.vincent.rsf.framework.common.Cools;
 import com.vincent.rsf.framework.common.R;
 import com.vincent.rsf.framework.exception.CoolException;
@@ -612,15 +611,15 @@
                     .setId(isptItem.getId())
                     .setMatnrCode(isptItem.getMatnrCode())
                     .setMaktx(isptItem.getMaktx())
-                    .setDisQty(isptItem.getDisQty())
+//                    .setDisQty(isptItem.getDisQty())
                     .setDlyQty(isptItem.getDlyQty())
                     .setRcptQty(isptItem.getRcptQty())
                     .setIsptResult(isptItem.getIsptResult())
                     .setSplrBatch(isptItem.getSplrBatch())
                     .setSplrName(isptItem.getSplrName())
                     .setPicPath(isptItem.getPicPath())
-                    .setMemo(isptItem.getMemo())
-                    .setSafeQty(isptItem.getSafeQty());
+                    .setMemo(isptItem.getMemo());
+//                    .setSafeQty(isptItem.getSafeQty());
             dtos.add(objDto);
         });
         return R.ok(dtos);
@@ -630,16 +629,17 @@
      * 蹇�熻川妫�
      *
      * @param params
+     * @param loginUserId
      * @return
      */
     @Override
-    public R checkUpdate(List<QlyIsptItem> params) {
+    public R checkUpdate(List<QlyIsptItem> params, Long loginUserId) {
         if (Objects.isNull(params) || params.isEmpty()) {
             throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
         }
         IsptItemsParams itemsParams = new IsptItemsParams();
         itemsParams.setIsptItem(params).setType("0");
-        if (qlyIsptItemService.batchUpdate(itemsParams)) {
+        if (qlyIsptItemService.batchUpdate(itemsParams, loginUserId)) {
             return R.ok();
         } else {
             return R.error("淇濆瓨澶辫触锛侊紒");
@@ -656,35 +656,22 @@
     @Override
     public R operateToStock(OpStockParams params) {
         if (org.apache.commons.lang3.StringUtils.isBlank(params.getBarcode())) {
-            throw new CoolException("鎷栫洏鐮佷笉鑳戒负绌猴紒锛�");
+            throw new CoolException("鎵樼洏鐮佷笉鑳戒负绌猴紒锛�");
         }
-        if (StringUtils.isBlank(params.getAsnCode())) {
-            throw new CoolException("鍗曟嵁涓嶈兘涓虹┖锛侊紒");
+        WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
+                .eq(WaitPakin::getBarcode, params.getBarcode())
+                .eq(WaitPakin::getIoStatus,PakinIOStatus.PAKIN_IO_STATUS_DONE.val)
+        );
+        if (Cools.isEmpty(waitPakin)){
+            throw new CoolException("鏈壘鍒扮粍鎵樻暟鎹�,璇锋鏌ョ姸鎬�");
         }
-        if (StringUtils.isBlank(params.getMatnrCode())) {
-            throw new CoolException("鐗╂枡缂栫爜涓嶈兘涓虹┖锛侊紒");
+        List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId()));
+        if (Cools.isEmpty(waitPakinItems)){
+            throw new CoolException("鏁版嵁閿欒锛屾湭鎵惧埌缁勬墭鏄庣粏");
         }
-        AsnOrder asnOrders = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getCode, params.getAsnCode()));
-        if (Objects.isNull(asnOrders)) {
-            throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
-        }
-        List<Loc> locs = locService.list(new LambdaQueryWrapper<Loc>().eq(Loc::getBarcode, params.getBarcode()));
-        if (!locs.isEmpty()) {
-            throw new CoolException("鎷栫洏宸蹭娇鐢�");
-        }
-        List<WaitPakin> waitPakins = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>().eq(WaitPakin::getBarcode, params.getBarcode()));
-        if (!waitPakins.isEmpty()) {
-            throw new CoolException("鎷栫洏宸蹭娇鐢�!!");
-        }
-        AsnOrderItem orderItems = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>()
-                .eq(AsnOrderItem::getAsnId, asnOrders.getId())
-                .eq(AsnOrderItem::getMatnrCode, params.getMatnrCode()));
-        if (Objects.isNull(orderItems)) {
-            return R.ok(null);
-        }
-        orderItems.setBarcode(params.getBarcode());
 
-        return R.ok(orderItems);
+
+        return R.ok(waitPakinItems);
     }
 
     /**

--
Gitblit v1.9.1