From 46168fbb7c925b0ec04def176095e967720e684a Mon Sep 17 00:00:00 2001
From: chen.llin <1442464845@qq.comm>
Date: 星期五, 16 一月 2026 15:22:07 +0800
Subject: [PATCH] agv查询修复

---
 src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java |   91 +++++++++++++++++++++++++--------------------
 1 files changed, 51 insertions(+), 40 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
index f8883ff..bdba3e6 100644
--- a/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WorkMastHandler.java
@@ -865,55 +865,66 @@
 
     @Transactional(rollbackFor = Exception.class)
     public ReturnT<String> agvDoIn(Task wrkMast) {
-        if (wrkMast.getIoType().equals(1)) {
-            LocCache locCache = locCacheService.selectOne(new EntityWrapper<LocCache>().eq("loc_no", wrkMast.getLocNo()));
-            if (Objects.isNull(locCache)) {
-                throw new CoolException("鏁版嵁閿欒锛屽簱浣嶄笉瀛樺湪锛侊紒");
-            }
-            if (!locCache.getLocSts().equals(LocStsType.LOC_STS_TYPE_S.type)) {
-                throw new CoolException("褰撳墠搴撲綅鐘舵�佷负锛�" + LocStsType.LOC_STS_TYPE_S.type + "." + LocStsType.LOC_STS_TYPE_S.desc + "锛屼笉鏄嚭搴撻绾︾姸鎬�");
-            }
-            List<TaskDetl> taskDetls = taskDetlService.selectList(new EntityWrapper<TaskDetl>().eq("task_id", wrkMast.getId()));
-            if (Objects.isNull(taskDetls)) {
-                throw new CoolException("鏁版嵁閿欒锛氱粍鎵樻暟鎹笉瀛樺湪锛侊紒");
-            }
-            taskDetls.forEach(pakin -> {
-                LocCacheDetl detl = new LocCacheDetl();
-                BeanUtils.copyProperties(pakin, detl);
-                detl.setBarcode(pakin.getBarcode())
-                        .setLocId(locCache.getId())
-                        .setAnfme(pakin.getAnfme())
-                        .setBrand(pakin.getBrand())
-                        .setAppeTime(new Date())
-                        .setSpecs(pakin.getSpecs())
-                        .setColor(pakin.getColor())
-                        .setLocNo(locCache.getLocNo())
-                        .setAreaId(locCache.getAreaId())
-                        .setAreaName(locCache.getAreaName())
-                        .setUnit(pakin.getUnit())
-                        .setBatch(pakin.getBatch());
-                if (!locCacheDetlService.insert(detl)) {
-                    throw new CoolException("搴撲綅鏄庣粏淇濆瓨澶辫触锛侊紒");
+        Integer ioType = wrkMast.getIoType();
+        if (ioType == null) {
+            throw new CoolException("鏁版嵁閿欒锛歩oType涓虹┖锛侊紒");
+        }
+        
+        // 澶勭悊鍏ュ簱浠诲姟绫诲瀷锛�1锛堝疄鎵樺叆搴擄級銆�10锛堢┖鎵樺叆搴擄級銆�53銆�57
+        if (ioType == 1 || ioType == 10 || ioType == 53 || ioType == 57) {
+            // ioType == 1 闇�瑕佸鐞嗙粍鎵樻暟鎹�
+            if (ioType == 1) {
+                LocCache locCache = locCacheService.selectOne(new EntityWrapper<LocCache>().eq("loc_no", wrkMast.getLocNo()));
+                if (Objects.isNull(locCache)) {
+                    throw new CoolException("鏁版嵁閿欒锛屽簱浣嶄笉瀛樺湪锛侊紒");
                 }
-            });
+                if (!locCache.getLocSts().equals(LocStsType.LOC_STS_TYPE_S.type)) {
+                    throw new CoolException("褰撳墠搴撲綅鐘舵�佷负锛�" + LocStsType.LOC_STS_TYPE_S.type + "." + LocStsType.LOC_STS_TYPE_S.desc + "锛屼笉鏄嚭搴撻绾︾姸鎬�");
+                }
+                List<TaskDetl> taskDetls = taskDetlService.selectList(new EntityWrapper<TaskDetl>().eq("task_id", wrkMast.getId()));
+                if (Objects.isNull(taskDetls)) {
+                    throw new CoolException("鏁版嵁閿欒锛氱粍鎵樻暟鎹笉瀛樺湪锛侊紒");
+                }
+                taskDetls.forEach(pakin -> {
+                    LocCacheDetl detl = new LocCacheDetl();
+                    BeanUtils.copyProperties(pakin, detl);
+                    detl.setBarcode(pakin.getBarcode())
+                            .setLocId(locCache.getId())
+                            .setAnfme(pakin.getAnfme())
+                            .setBrand(pakin.getBrand())
+                            .setAppeTime(new Date())
+                            .setSpecs(pakin.getSpecs())
+                            .setColor(pakin.getColor())
+                            .setLocNo(locCache.getLocNo())
+                            .setAreaId(locCache.getAreaId())
+                            .setAreaName(locCache.getAreaName())
+                            .setUnit(pakin.getUnit())
+                            .setBatch(pakin.getBatch());
+                    if (!locCacheDetlService.insert(detl)) {
+                        throw new CoolException("搴撲綅鏄庣粏淇濆瓨澶辫触锛侊紒");
+                    }
+                });
 
-            locCache.setLocSts(LocStsType.LOC_STS_TYPE_F.type);
-            locCache.setModiTime(new Date());
-            locCache.setBarcode(wrkMast.getBarcode());
-            locCache.setModiTime(new Date());
-            locCache.setIoTime(new Date());
-            if (!locCacheService.updateById(locCache)) {
-                throw new CoolException("搴撲綅鐘舵�佷慨鏀瑰け璐ワ紒");
+                locCache.setLocSts(LocStsType.LOC_STS_TYPE_F.type);
+                locCache.setModiTime(new Date());
+                locCache.setBarcode(wrkMast.getBarcode());
+                locCache.setModiTime(new Date());
+                locCache.setIoTime(new Date());
+                if (!locCacheService.updateById(locCache)) {
+                    throw new CoolException("搴撲綅鐘舵�佷慨鏀瑰け璐ワ紒");
+                }
             }
+            
+            // 鏇存柊浠诲姟鐘舵�佷负5锛堝簱瀛樻洿鏂板畬鎴愶級
             wrkMast.setWrkSts(5L);
             wrkMast.setModiTime(new Date());
             if (!taskService.updateById(wrkMast)) {
                 throw new CoolException("浠诲姟鐘舵�佷慨鏀瑰け璐ワ紒锛�");
             }
-        }else {
-            throw new CoolException("鏁版嵁閿欒锛歩oType涓嶅瓨鍦紒锛�");
+        } else {
+            // 闈炲叆搴撲换鍔$被鍨嬶紝璁板綍鏃ュ織浣嗕笉鎶涘嚭寮傚父锛屽厑璁稿叾浠栫被鍨嬬殑浠诲姟閫氳繃
+            log.warn("agvDoIn鏂规硶鏀跺埌闈炲叆搴撲换鍔$被鍨嬶紝ioType锛歿}锛宼askId锛歿}锛岃烦杩囧鐞�", ioType, wrkMast.getId());
         }
-
 
         return SUCCESS;
     }

--
Gitblit v1.9.1