From b5fa899c46b54a7f7c447d7d8d7ba0c440415204 Mon Sep 17 00:00:00 2001
From: lsh <1>
Date: 星期三, 24 一月 2024 17:21:18 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java |   84 +++++++++++++++++++++++++++++++++++------
 1 files changed, 71 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
index dd36e7f..75f8e67 100644
--- a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
@@ -3,9 +3,11 @@
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
 import com.zy.asrs.entity.BasDevp;
+import com.zy.asrs.entity.RgvOneSign;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.entity.WrkMastSta;
 import com.zy.asrs.service.BasDevpService;
+import com.zy.asrs.service.RgvOneSignService;
 import com.zy.asrs.service.WrkMastService;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.asrs.task.handler.WrkMastStaInItHandler;
@@ -29,6 +31,8 @@
     private BasDevpService basDevpService;
     @Autowired
     private WrkMastService wrkMastService;
+    @Autowired
+    private RgvOneSignService rgvOneSignService;
 
 
     public static final List<Integer> STA_WORK_CU = new ArrayList<Integer>() {{
@@ -44,14 +48,47 @@
     private void execute(){
         for(Integer staNo : STA_WORK_CU){
             BasDevp basDevp = basDevpService.selectById(staNo);
-            if (basDevp.getWrkNo()!=0){
+            if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){
                 WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo()));
-                if (!Cools.isEmpty(wrkMast)){
-                    ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp);
-                    if (result.getCode()==200){
+                if(Cools.isEmpty(wrkMast)){
+                    continue;
+                }
+                if (wrkMast.getIoType()<100 || wrkMast.getIoType()==110){
+                    if (!wrkMast.getStaNo().equals(122)){
                         continue;
-                    }else {
-                        System.out.println(staNo+"澶辫触锛�");
+                    }
+                }
+                if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
+                    continue;
+                }
+//                if (wrkMast.getStaNo()==118 || wrkMast.getStaNo()==119){
+//                    RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign"));
+//                    if (rgvOneSign.getRgvOneSign()==1){
+//                        continue;
+//                    }
+//                }
+                boolean wrkTypeSign = fullKM(wrkMast);
+                if (!Cools.isEmpty(wrkMast)){
+                    if (wrkTypeSign) {
+//                        ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,11);//1:鍙栵紙鍙犵洏锛�
+//                        if (result.getCode()==200){
+//                            continue;
+//                        }else {
+//                            System.out.println(staNo+"澶辫触锛�");
+//                        }
+                        ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);//3锛氬彇鏀�
+                        if (result.getCode()==200){
+                            continue;
+                        }else {
+                            System.out.println(staNo+"澶辫触锛�");
+                        }
+                    } else {
+                        ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);//3锛氬彇鏀�
+                        if (result.getCode()==200){
+                            continue;
+                        }else {
+                            System.out.println(staNo+"澶辫触锛�");
+                        }
                     }
                 }
             }
@@ -59,18 +96,39 @@
 
         for(Integer staNo : STA_WORK_RU){
             BasDevp basDevp = basDevpService.selectById(staNo);
-            if (basDevp.getWrkNo()!=0){
+            if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){
                 WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo()));
+                if (wrkMast.getWrkSts()!=2 || wrkMast.getIoType()==10){
+                    continue;
+                }
+//                boolean wrkTypeSign = fullKM(wrkMast);
+
                 if (!Cools.isEmpty(wrkMast)){
-                    ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp);
-                    if (result.getCode()==200){
-                        continue;
-                    }else {
-                        System.out.println(staNo+"澶辫触锛�");
-                    }
+//                    if (wrkTypeSign){
+                        ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);
+                        if (result.getCode()==200) {
+                            continue;
+                        } else {
+                            System.out.println(staNo+"澶辫触锛�");
+                        }
+//                    }else {
+//                        ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,23);
+//                        if (result.getCode()==200) {
+//                            continue;
+//                        } else {
+//                            System.out.println(staNo+"澶辫触锛�");
+//                        }
+//                    }
                 }
             }
         }
     }
 
+    public boolean fullKM(WrkMast wrkMast){
+        if (wrkMast.getIoType()!=10 && wrkMast.getIoType()!=110){
+            return true;
+        }
+        return false;
+    }
+
 }

--
Gitblit v1.9.1