From 4f45f8f3ec334a73ba24fc5d16017b5c044168aa Mon Sep 17 00:00:00 2001
From: Administrator <1051256694@qq.com>
Date: 星期五, 13 三月 2026 11:24:01 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/web/WcsController.java |  172 +++++++++++++++++++++++++++++----------------------------
 1 files changed, 88 insertions(+), 84 deletions(-)

diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index 4afa422..8f099ca 100644
--- a/src/main/java/com/zy/common/web/WcsController.java
+++ b/src/main/java/com/zy/common/web/WcsController.java
@@ -47,7 +47,7 @@
     @Autowired
     private WaitPakinService waitPakinService;
     @Autowired
-    private  LocDetlService locDetlService;
+    private LocDetlService locDetlService;
     @Autowired
     private RowLastnoService rowLastnoService;
     @Autowired
@@ -62,59 +62,60 @@
         }
         List<WaitPakin> waitPakins = null;
 
-            if (Cools.isEmpty(param.getBarcode())) {
-                return R.error("鏉$爜涓嶈兘涓虹┖");
-            }
+        if (Cools.isEmpty(param.getBarcode())) {
+            return R.error("鏉$爜涓嶈兘涓虹┖");
+        }
         WrkMast wrkMast1 = wrkMastService.selectByBarcode(param.getBarcode());
-        if (!Cools.isEmpty(wrkMast1)&&wrkMast1.getWrkSts()==2) {
-            StartupDto dto1 =new StartupDto();
+        if (!Cools.isEmpty(wrkMast1) && wrkMast1.getWrkSts() == 2) {
+            StartupDto dto1 = new StartupDto();
             dto1.setBarcode(param.getBarcode());
             dto1.setStaNo(Integer.valueOf(wrkMast1.getStaNo()));
             String wcsLoc = Utils.WMSLocToWCSLoc(wrkMast1.getLocNo());
             dto1.setLocNo(wcsLoc);
             dto1.setCrnNo(wrkMast1.getCrnNo());
             dto1.setWorkNo(wrkMast1.getWrkNo());
-            dto1.setTaskNo(wrkMast1.getWrkNo()+"");
+            dto1.setTaskNo(wrkMast1.getWrkNo() + "");
 //            dto1.setTaskPri((int) Math.round(wrkMast1.getIoPri()));
             return R.ok(dto1);
         }
         List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("io_type", 1));
-        if (!Cools.isEmpty(wrkMasts)&&wrkMasts.size()>30) {
+        if (!Cools.isEmpty(wrkMasts) && wrkMasts.size() > 10) {
             return R.error("闄愯");
         }
-            waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
-            if (Cools.isEmpty(waitPakins)) {
-                WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode());
-                if (wrkMast != null && wrkMast.getIoType() == 103) {
-                    return R.parse(CodeRes.PICK_600);
-                }
-                Date now = new Date();
-                WaitPakin waitPakin = new WaitPakin();
-                waitPakin.setMatnr("emptyPallet");
-                waitPakin.setBatch("");
-                waitPakin.setAnfme(1D);
-                waitPakin.setZpallet(param.getBarcode());
-                waitPakin.setIoStatus("N");
-                waitPakin.setStatus("Y");
-                waitPakin.setAppeUser(9999L);
-                waitPakin.setAppeTime(now);
-                waitPakin.setModiUser(9999L);
-                waitPakin.setModiTime(now);
-                if (!waitPakinService.insert(waitPakin)) {
-                    return R.error("鑷姩鐢熸垚鍏ュ簱閫氱煡妗eけ璐�");
-                }
-                waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
-                if (Cools.isEmpty(waitPakins)) {
-                    return R.error("鑷姩鐢熸垚鍏ュ簱閫氱煡妗e悗鏈煡璇㈠埌鏁版嵁");
-                }
-                log.info("WCS鍏ュ簱鎺ュ彛鑷姩鐢熸垚鍏ュ簱閫氱煡妗�, zpallet:{}, matnr:{}, anfme:{}", param.getBarcode(), "32149", 1D);
-            }
-             int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode()));
-            int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet",param.getBarcode()));
-            if (countLoc > 0 || countWrk > 0) {
-                return R.error(CodeRes.EXIST_500);
-            }
-        if (Cools.isEmpty(param.getLocType1())){
+        waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
+        if (Cools.isEmpty(waitPakins)) {
+            return R.error("璇峰厛娣诲姞鍏ュ簱閫氱煡妗�");
+//            WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode());
+//            if (wrkMast != null && wrkMast.getIoType() == 103) {
+//                return R.parse(CodeRes.PICK_600);
+//            }
+//            Date now = new Date();
+//            WaitPakin waitPakin = new WaitPakin();
+//            waitPakin.setMatnr("emptyPallet");
+//            waitPakin.setBatch("");
+//            waitPakin.setAnfme(1D);
+//            waitPakin.setZpallet(param.getBarcode());
+//            waitPakin.setIoStatus("N");
+//            waitPakin.setStatus("Y");
+//            waitPakin.setAppeUser(9999L);
+//            waitPakin.setAppeTime(now);
+//            waitPakin.setModiUser(9999L);
+//            waitPakin.setModiTime(now);
+//            if (!waitPakinService.insert(waitPakin)) {
+//                return R.error("鑷姩鐢熸垚鍏ュ簱閫氱煡妗eけ璐�");
+//            }
+//            waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
+//            if (Cools.isEmpty(waitPakins)) {
+//                return R.error("鑷姩鐢熸垚鍏ュ簱閫氱煡妗e悗鏈煡璇㈠埌鏁版嵁");
+//            }
+//            log.info("WCS鍏ュ簱鎺ュ彛鑷姩鐢熸垚鍏ュ簱閫氱煡妗�, zpallet:{}, matnr:{}, anfme:{}", param.getBarcode(), "32149", 1D);
+        }
+        int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBarcode()));
+        int countWrk = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("zpallet", param.getBarcode()));
+        if (countLoc > 0 || countWrk > 0) {
+            return R.error(CodeRes.EXIST_500);
+        }
+        if (Cools.isEmpty(param.getLocType1())) {
             return R.error("楂樹綆妫�娴嬩俊鍙蜂笉鑳戒负绌�");
         }
 
@@ -143,12 +144,12 @@
                 return R.error("鏉$爜涓嶈兘涓虹┖");
             }
         }
-        if (Cools.isEmpty(param.getLocType1())){
+        if (Cools.isEmpty(param.getLocType1())) {
             return R.error("楂樹綆妫�娴嬩俊鍙蜂笉鑳戒负绌�");
         }
         // 婧愮珯鐐圭姸鎬佹娴�
         BasDevp sourceStaNo = basDevpService.selectById(param.getSourceStaNo());
-        if(sourceStaNo.getWrkNo() == 0 && sourceStaNo.getDevNo() != 2033){
+        if (sourceStaNo.getWrkNo() == 0 && sourceStaNo.getDevNo() != 2033) {
             return R.error("绔欑偣宸ヤ綔鍙蜂笉瀛樺湪");
         }
         sourceStaNo.setLocType1(param.getLocType1());
@@ -158,7 +159,7 @@
         switch (param.getIoType()) {
             case 1://婊℃墭鐩樺叆搴�
             case 10://绌烘墭鐩樺叆搴�
-                dto = startupFullPutStoreAgv(param.getSourceStaNo(), param.getBarcode(), locTypeDto,param.getOutArea());
+                dto = startupFullPutStoreAgv(param.getSourceStaNo(), param.getBarcode(), locTypeDto, param.getOutArea());
                 break;
 //                dto = emptyPlateIn(param.getSourceStaNo(), locTypeDto, param.getBarcode());
 //                break;
@@ -171,15 +172,15 @@
 
     @PostMapping("/auto/emptyIn/v1")
     @ResponseBody
-    public R autoEmptyIn(@RequestBody LocTypeDto locTypeDto){
+    public R autoEmptyIn(@RequestBody LocTypeDto locTypeDto) {
         // 婧愮珯鐐圭姸鎬佹娴�
         BasDevp sourceStaNo = basDevpService.checkSiteStatus(1038, true);
 
         // 妫�绱㈠簱浣�
         FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo();
 
-        StartupDto dto = commonService.getLocNo( 10, 1038, findLocNoAttributeVo, locTypeDto);
-        if (dto == null){
+        StartupDto dto = commonService.getLocNo(10, 1038, findLocNoAttributeVo, locTypeDto);
+        if (dto == null) {
             throw new CoolException("鏌ヨ搴撲綅澶辫触");
         }
         Date now = new Date();
@@ -208,27 +209,27 @@
         sourceStaNo.setWrkNo(dto.getWorkNo());
         sourceStaNo.setModiUser(9999L);
         sourceStaNo.setModiTime(now);
-        if (!basDevpService.updateById(sourceStaNo)){
+        if (!basDevpService.updateById(sourceStaNo)) {
             throw new CoolException("鏇存柊婧愮珯澶辫触");
         }
         // 鏇存柊鐩爣搴撲綅鐘舵��
         LocMast locMast = locMastService.selectById(dto.getLocNo());
-        if (locMast.getLocSts().equals("O")){
+        if (locMast.getLocSts().equals("O")) {
             locMast.setLocSts("S"); // S.鍏ュ簱棰勭害
             locMast.setModiUser(9999L);
             locMast.setModiTime(now);
-            if (!locMastService.updateById(locMast)){
+            if (!locMastService.updateById(locMast)) {
                 throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�");
             }
         } else {
-            throw new CoolException(dto.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤");
+            throw new CoolException(dto.getLocNo() + "鐩爣搴撲綅宸茶鍗犵敤");
         }
-        return wrkMastService.insert(wrkMast) ? R.ok("鑷姩绌烘墭鍏ュ簱鎴愬姛,宸ヤ綔鍙�:"+wrkMast.getWrkNo()).add(wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩绌烘墭鍏ュ簱澶辫触");
+        return wrkMastService.insert(wrkMast) ? R.ok("鑷姩绌烘墭鍏ュ簱鎴愬姛,宸ヤ綔鍙�:" + wrkMast.getWrkNo()).add(wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩绌烘墭鍏ュ簱澶辫触");
     }
 
     @PostMapping("auto/emptyOut/v1")
     @ResponseBody
-    public R autoEmptyOut(@RequestBody LocTypeDto locTypeDto){
+    public R autoEmptyOut(@RequestBody LocTypeDto locTypeDto) {
         LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
                 .eq("loc_sts", "D"));
         if (Cools.isEmpty(locMast)) {
@@ -236,9 +237,11 @@
         }
         EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
         emptyPlateOutParam.setOutSite(locTypeDto.getSiteId());
-        emptyPlateOutParam.setLocNos(new ArrayList<String>(){{add(locMast.getLocNo()+"");}});
+        emptyPlateOutParam.setLocNos(new ArrayList<String>() {{
+            add(locMast.getLocNo() + "");
+        }});
         WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam);
-        return R.ok(!Cools.isEmpty(wrkMast)? R.ok("鑷姩绌烘墭鍑哄簱鎴愬姛,宸ヤ綔鍙�:" + wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩绌烘墭鍑哄簱澶辫触"));
+        return R.ok(!Cools.isEmpty(wrkMast) ? R.ok("鑷姩绌烘墭鍑哄簱鎴愬姛,宸ヤ綔鍙�:" + wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩绌烘墭鍑哄簱澶辫触"));
     }
 
 
@@ -281,20 +284,21 @@
         }
         return workNo;
     }
+
     @PostMapping("/auto/TransplantingOut/v1")
     @ResponseBody
-    public R autoTransplantingOut(@RequestBody TransplantWork transplantWork){
+    public R autoTransplantingOut(@RequestBody TransplantWork transplantWork) {
         // 婧愮珯鐐圭姸鎬佹娴�
 //        BasDevp sourceStaNo = basDevpService.checkSiteStatus(transplantWork.getStaNo(), true);
-        WrkMast wrkMast1 = wrkMastService.selectWrkMast(transplantWork.getWorkNo(),transplantWork.getBarcode());
+        WrkMast wrkMast1 = wrkMastService.selectWrkMast(transplantWork.getWorkNo(), transplantWork.getBarcode());
 //        if(sourceStaNo ==null )hnagbao1{
 //            return R.error("璇ョ珯鐐圭洏鐐圭Щ鏍借鍙紝璇锋煡鐪嬫簮绔欑偣鐘舵�佹娴�");
 //        }
-        if(wrkMast1== null){
-            return  R.error("鏃犺鐩樼偣绉绘牻浠诲姟");
+        if (wrkMast1 == null) {
+            return R.error("鏃犺鐩樼偣绉绘牻浠诲姟");
         }
-        WrkMast wrkMast2 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no",9997));
-        if(wrkMast2 != null){
+        WrkMast wrkMast2 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", 9997));
+        if (wrkMast2 != null) {
             throw new CoolException("瀛樺湪9997鐩樼偣绉绘牻浠诲姟");
         }
         List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(transplantWork.getWorkNo());
@@ -331,23 +335,23 @@
                 throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
             }
         }
-        return wrkMastService.insert(wrkMast) ? R.ok("鑷姩3鍙峰爢鍨涙満绉绘牻鎴愬姛,宸ヤ綔鍙�:"+wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩3鍙峰爢鍨涙満绉绘牻澶辫触");
+        return wrkMastService.insert(wrkMast) ? R.ok("鑷姩3鍙峰爢鍨涙満绉绘牻鎴愬姛,宸ヤ綔鍙�:" + wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩3鍙峰爢鍨涙満绉绘牻澶辫触");
     }
 
     @PostMapping("/auto/TransplantingIn/v1")
     @ResponseBody
-    public R autoTransplantingIn(@RequestBody TransplantWork transplantWork){
+    public R autoTransplantingIn(@RequestBody TransplantWork transplantWork) {
         // 婧愮珯鐐圭姸鎬佹娴�
 //        BasDevp sourceStaNo = basDevpService.checkSiteStatus(transplantWork.getStaNo(), true);
-        WrkMast wrkMast1 = wrkMastService.selectWrkMast(transplantWork.getWorkNo(),transplantWork.getBarcode());
+        WrkMast wrkMast1 = wrkMastService.selectWrkMast(transplantWork.getWorkNo(), transplantWork.getBarcode());
 //        if(sourceStaNo == null){
 //
 //        }
-        if(wrkMast1== null){
-            return  R.error("鏃犺鐩樼偣绉绘牻浠诲姟");
+        if (wrkMast1 == null) {
+            return R.error("鏃犺鐩樼偣绉绘牻浠诲姟");
         }
-        WrkMast wrkMast2 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no",9996));
-        if(wrkMast2 != null){
+        WrkMast wrkMast2 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", 9996));
+        if (wrkMast2 != null) {
             throw new CoolException("瀛樺湪9996鐩樼偣绉绘牻浠诲姟");
         }
         List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(transplantWork.getWorkNo());
@@ -384,7 +388,7 @@
                 throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
             }
         }
-        return wrkMastService.insert(wrkMast) ? R.ok("鑷姩3鍙峰爢鍨涙満绉绘牻鎴愬姛,宸ヤ綔鍙�:"+wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩3鍙峰爢鍨涙満绉绘牻澶辫触");
+        return wrkMastService.insert(wrkMast) ? R.ok("鑷姩3鍙峰爢鍨涙満绉绘牻鎴愬姛,宸ヤ綔鍙�:" + wrkMast.getWrkNo()) : R.error("鐢熸垚鑷姩3鍙峰爢鍨涙満绉绘牻澶辫触");
     }
 
 
@@ -392,29 +396,29 @@
      * 鍏ㄦ澘鍏ュ簱AGV
      */
     @Transactional
-    public StartupDto startupFullPutStoreAgv(Integer devpNo, String barcode, LocTypeDto locTypeDto,Integer outArea) {
+    public StartupDto startupFullPutStoreAgv(Integer devpNo, String barcode, LocTypeDto locTypeDto, Integer outArea) {
         // 婧愮珯鐐圭姸鎬佹娴�
 //        BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);
         // 妫�绱㈠簱浣�
         FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo();
         findLocNoAttributeVo.setOutArea(outArea);
 //        FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(waitPakins.get(0));
-        StartupDto dto = commonService.getLocNo( 1, devpNo,findLocNoAttributeVo, locTypeDto);
+        StartupDto dto = commonService.getLocNo(1, devpNo, findLocNoAttributeVo, locTypeDto);
         // 鏇存柊鐩爣搴撲綅鐘舵��
         Date now = new Date();
-        if(dto == null){
+        if (dto == null) {
             throw new CoolException("鏈壘鍒板簱浣�");
         }
         LocMast locMast = locMastService.selectById(dto.getLocNo());
-        if (locMast.getLocSts().equals("O")){
+        if (locMast.getLocSts().equals("O")) {
             locMast.setLocSts("S"); // S.鍏ュ簱棰勭害
             locMast.setBarcode(barcode);
             locMast.setModiTime(now);
-            if (!locMastService.updateById(locMast)){
+            if (!locMastService.updateById(locMast)) {
                 throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�");
             }
         } else {
-            throw new CoolException(dto.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤");
+            throw new CoolException(dto.getLocNo() + "鐩爣搴撲綅宸茶鍗犵敤");
         }
         return dto;
     }
@@ -490,18 +494,18 @@
 //        }
         // 鏇存柊鐩爣搴撲綅鐘舵��
         LocMast locMast = locMastService.selectById(dto.getLocNo());
-        if (locMast.getLocSts().equals("O")){
+        if (locMast.getLocSts().equals("O")) {
             locMast.setLocSts("S"); // S.鍏ュ簱棰勭害
             locMast.setModiTime(now);
-            if (!locMastService.updateById(locMast)){
+            if (!locMastService.updateById(locMast)) {
                 throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�");
             }
         } else {
-            throw new CoolException(dto.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤");
+            throw new CoolException(dto.getLocNo() + "鐩爣搴撲綅宸茶鍗犵敤");
         }
         String wcsLoc = Utils.WMSLocToWCSLoc(dto.getLocNo());
         dto.setLocNo(wcsLoc);
-        dto.setTaskNo(workNo+"");
+        dto.setTaskNo(workNo + "");
         return dto;
     }
 
@@ -512,7 +516,7 @@
         // 妫�绱㈠簱浣�
         FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo();
 
-        StartupDto dto = commonService.getLocNo( 10, devpNo, findLocNoAttributeVo, locTypeDto);
+        StartupDto dto = commonService.getLocNo(10, devpNo, findLocNoAttributeVo, locTypeDto);
         int workNo = dto.getWorkNo();
         // 鐢熸垚宸ヤ綔妗�
         WrkMast wrkMast = new WrkMast();
@@ -542,19 +546,19 @@
         // 鏇存柊婧愮珯鐐逛俊鎭�
         sourceStaNo.setWrkNo(workNo);
         sourceStaNo.setModiTime(new Date());
-        if (!basDevpService.updateById(sourceStaNo)){
+        if (!basDevpService.updateById(sourceStaNo)) {
             throw new CoolException("鏇存柊婧愮珯澶辫触");
         }
         // 鏇存柊鐩爣搴撲綅鐘舵��
         LocMast locMast = locMastService.selectById(dto.getLocNo());
-        if (locMast.getLocSts().equals("O")){
+        if (locMast.getLocSts().equals("O")) {
             locMast.setLocSts("S"); // S.鍏ュ簱棰勭害
             locMast.setModiTime(new Date());
-            if (!locMastService.updateById(locMast)){
+            if (!locMastService.updateById(locMast)) {
                 throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�");
             }
         } else {
-            throw new CoolException(dto.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤");
+            throw new CoolException(dto.getLocNo() + "鐩爣搴撲綅宸茶鍗犵敤");
         }
         return dto;
     }

--
Gitblit v1.9.1