From bcdcebacdd2b58397c5f00f28983ad36e67ce9fe Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期一, 25 三月 2024 13:18:27 +0800
Subject: [PATCH] #for循环异常处理

---
 src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java |  254 ++++++++++++++++++++++++++------------------------
 1 files changed, 131 insertions(+), 123 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
index c6b22d5..51b1728 100644
--- a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
@@ -134,154 +134,162 @@
     private void execute2(){
         try{
             for(Integer staNo : STA_WORK_CU){
-                BasDevp basDevp = basDevpService.selectById(staNo);
-                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)){
-                        continue;
-                    }
-                    if (wrkMast.getIoType()!=101 && wrkMast.getIoType()!=103){
-                        continue;
-                    }
-                    if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
-                        continue;
-                    }
-                    if (wrkMast.getStaNo()<118 || wrkMast.getStaNo()>121){
-                        continue;
-                    }
-                    int count = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", wrkMast.getStaNo()).or().eq("sta_end", wrkMast.getStaNo()));
-                    if (count!=0){
-                        continue;
-                    }
-                    int countStart = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", staNo).or().eq("sta_end", staNo).or().eq("wrk_no", wrkMast.getWrkNo()));
-                    if (countStart!=0){
-                        continue;
-                    }
-                    BasDevp basDevpEnd = basDevpService.selectById(wrkMast.getStaNo());
-                    if (!basDevpEnd.getAutoing().equals("Y") || basDevpEnd.getWrkNo()!=0 || basDevpEnd.getLoading().equals("Y") || basDevpEnd.getReportSign()!=0){
-                        continue;
-                    }
-                    if (wrkMast.getStaNo()==118 || wrkMast.getStaNo()==119){
-                        RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign"));
-                        if (rgvOneSign.getRgvOneSign()==1){
+                try{
+                    BasDevp basDevp = basDevpService.selectById(staNo);
+                    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)){
                             continue;
                         }
-                    }
-                    if (wrkMast.getIoType()!=101){
-                        List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
-                        if (wrkDetls.size()!=0){
-                            String origin = wrkDetls.get(0).getOrigin();
-                            if (origin.equals("1")){
-                                if (!STA_WORK_CU_CAR_FOUR.contains(wrkMast.getStaNo())){
-                                    continue;
-                                }
-                            }else {
-                                if (!STA_WORK_CU_CAR_THREE.contains(wrkMast.getStaNo())){
-                                    continue;
-                                }
-                            }
-                        }else {
-                            log.error("鏈煡璇㈠埌宸ヤ綔鏄庣粏");
+                        if (wrkMast.getIoType()!=101 && wrkMast.getIoType()!=103){
                             continue;
                         }
-                    }
-//
-                    boolean wrkTypeSign = fullKM(wrkMast);
-                    if (!Cools.isEmpty(wrkMast)){
-                        if (wrkTypeSign) {
-                            ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);//3锛氬彇鏀�
-                            if (result.getCode()==200){
+                        if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
+                            continue;
+                        }
+                        if (wrkMast.getStaNo()<118 || wrkMast.getStaNo()>121){
+                            continue;
+                        }
+                        int count = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", wrkMast.getStaNo()).or().eq("sta_end", wrkMast.getStaNo()));
+                        if (count!=0){
+                            continue;
+                        }
+                        int countStart = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", staNo).or().eq("sta_end", staNo).or().eq("wrk_no", wrkMast.getWrkNo()));
+                        if (countStart!=0){
+                            continue;
+                        }
+                        BasDevp basDevpEnd = basDevpService.selectById(wrkMast.getStaNo());
+                        if (!basDevpEnd.getAutoing().equals("Y") || basDevpEnd.getWrkNo()!=0 || basDevpEnd.getLoading().equals("Y") || basDevpEnd.getReportSign()!=0){
+                            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;
+                            }
+                        }
+                        if (wrkMast.getIoType()!=101){
+                            List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
+                            if (wrkDetls.size()!=0){
+                                String origin = wrkDetls.get(0).getOrigin();
+                                if (origin.equals("1")){
+                                    if (!STA_WORK_CU_CAR_FOUR.contains(wrkMast.getStaNo())){
+                                        continue;
+                                    }
+                                }else {
+                                    if (!STA_WORK_CU_CAR_THREE.contains(wrkMast.getStaNo())){
+                                        continue;
+                                    }
+                                }
                             }else {
-                                System.out.println(staNo+"澶辫触锛�");
+                                log.error("鏈煡璇㈠埌宸ヤ綔鏄庣粏");
+                                continue;
+                            }
+                        }
+//
+                        boolean wrkTypeSign = fullKM(wrkMast);
+                        if (!Cools.isEmpty(wrkMast)){
+                            if (wrkTypeSign) {
+                                ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);//3锛氬彇鏀�
+                                if (result.getCode()==200){
+                                    continue;
+                                }else {
+                                    System.out.println(staNo+"澶辫触锛�");
+                                }
                             }
                         }
                     }
+                }catch (Exception e){
+                    log.error("STA_WORK_CU澶勭悊澶辫触锛屽綋鍓嶇珯鐐瑰彿锛�"+staNo+"寮傚父淇℃伅"+e);
                 }
             }
 
             for(Integer staNo : STA_WORK_CU){
-                BasDevp basDevp = basDevpService.selectById(staNo);
-                if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){
-                    List<Integer> STA_WORK_CU_CAR_NOW = STA_WORK_CU_CAR;
-                    WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo()));
-                    if(Cools.isEmpty(wrkMast)){
-                        continue;
-                    }
-                    if (wrkMast.getIoType()!=101 && wrkMast.getIoType()!=103){
-                        continue;
-                    }
-                    if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
-                        continue;
-                    }
-                    Integer wrkMastStaNo = wrkMast.getStaNo();
-                    if (wrkMastStaNo<118 || wrkMastStaNo>121){
-                        continue;
-                    }
-                    String origin = null;
-                    boolean sign = false;
-                    if (wrkMast.getIoType()!=101){
-                        List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
-                        if (wrkDetls.size()!=0){
-                            origin = wrkDetls.get(0).getOrigin();
-                            if (origin.equals("1")){
-                                if (!STA_WORK_CU_CAR_FOUR.contains(wrkMastStaNo)){
-                                    sign = true;
-                                }
-                            }else {
-                                if (!STA_WORK_CU_CAR_THREE.contains(wrkMastStaNo)){
-                                    sign = true;
-                                }
-                            }
-                        }else {
-                            log.error("鏈煡璇㈠埌宸ヤ綔鏄庣粏");
+                try{
+                    BasDevp basDevp = basDevpService.selectById(staNo);
+                    if (basDevp.getWrkNo()!=0 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")){
+                        List<Integer> STA_WORK_CU_CAR_NOW = STA_WORK_CU_CAR;
+                        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo()));
+                        if(Cools.isEmpty(wrkMast)){
                             continue;
                         }
-                    }
-                    int count = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", wrkMastStaNo).or().eq("sta_end", wrkMastStaNo));
-                    if (count!=0){
-                        continue;
-                    }
-                    int countStart = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", staNo).or().eq("sta_end", staNo).or().eq("wrk_no", wrkMast.getWrkNo()));
-                    if (countStart!=0){
-                        continue;
-                    }
-                    RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign"));
-                    if (rgvOneSign.getRgvOneSign()==1){
-                        STA_WORK_CU_CAR_NOW = STA_WORK_CU_CAR_TWO;
-                    }
-
-                    BasDevp basDevpEnd = basDevpService.selectById(wrkMastStaNo);
-                    if (sign || !basDevpEnd.getAutoing().equals("Y") || basDevpEnd.getWrkNo()!=0 || basDevpEnd.getLoading().equals("Y") || basDevpEnd.getReportSign()!=0) {
-                        for (Integer staNoOther : STA_WORK_CU_CAR_NOW) {
-                            if (staNoOther.equals(wrkMastStaNo)) continue;
-
-                            if (sign){
+                        if (wrkMast.getIoType()!=101 && wrkMast.getIoType()!=103){
+                            continue;
+                        }
+                        if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
+                            continue;
+                        }
+                        Integer wrkMastStaNo = wrkMast.getStaNo();
+                        if (wrkMastStaNo<118 || wrkMastStaNo>121){
+                            continue;
+                        }
+                        String origin = null;
+                        boolean sign = false;
+                        if (wrkMast.getIoType()!=101){
+                            List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
+                            if (wrkDetls.size()!=0){
+                                origin = wrkDetls.get(0).getOrigin();
                                 if (origin.equals("1")){
-                                    if (!STA_WORK_CU_CAR_FOUR.contains(staNoOther)){
-                                        continue;
+                                    if (!STA_WORK_CU_CAR_FOUR.contains(wrkMastStaNo)){
+                                        sign = true;
                                     }
                                 }else {
-                                    if (!STA_WORK_CU_CAR_THREE.contains(staNoOther)){
-                                        continue;
+                                    if (!STA_WORK_CU_CAR_THREE.contains(wrkMastStaNo)){
+                                        sign = true;
                                     }
                                 }
+                            }else {
+                                log.error("鏈煡璇㈠埌宸ヤ綔鏄庣粏");
+                                continue;
                             }
+                        }
+                        int count = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", wrkMastStaNo).or().eq("sta_end", wrkMastStaNo));
+                        if (count!=0){
+                            continue;
+                        }
+                        int countStart = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", staNo).or().eq("sta_end", staNo).or().eq("wrk_no", wrkMast.getWrkNo()));
+                        if (countStart!=0){
+                            continue;
+                        }
+                        RgvOneSign rgvOneSign = rgvOneSignService.selectOne(new EntityWrapper<RgvOneSign>().eq("rgv_one_type","oneSign"));
+                        if (rgvOneSign.getRgvOneSign()==1){
+                            STA_WORK_CU_CAR_NOW = STA_WORK_CU_CAR_TWO;
+                        }
 
-                            int countOther = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", staNoOther).or().eq("sta_end", staNoOther));
-                            if (countOther!=0){
-                                continue;
+                        BasDevp basDevpEnd = basDevpService.selectById(wrkMastStaNo);
+                        if (sign || !basDevpEnd.getAutoing().equals("Y") || basDevpEnd.getWrkNo()!=0 || basDevpEnd.getLoading().equals("Y") || basDevpEnd.getReportSign()!=0) {
+                            for (Integer staNoOther : STA_WORK_CU_CAR_NOW) {
+                                if (staNoOther.equals(wrkMastStaNo)) continue;
+
+                                if (sign){
+                                    if (origin.equals("1")){
+                                        if (!STA_WORK_CU_CAR_FOUR.contains(staNoOther)){
+                                            continue;
+                                        }
+                                    }else {
+                                        if (!STA_WORK_CU_CAR_THREE.contains(staNoOther)){
+                                            continue;
+                                        }
+                                    }
+                                }
+
+                                int countOther = wrkMastStaService.selectCount(new EntityWrapper<WrkMastSta>().eq("sta_start", staNoOther).or().eq("sta_end", staNoOther));
+                                if (countOther!=0){
+                                    continue;
+                                }
+                                BasDevp basDevpOther = basDevpService.selectById(staNoOther);
+                                if (!basDevpOther.getAutoing().equals("Y") || basDevpOther.getWrkNo()!=0 || basDevpOther.getLoading().equals("Y") || basDevpOther.getReportSign()!=0) {
+                                    continue;
+                                }
+                                wrkMast.setStaNo(staNoOther);
+                                wrkMastService.updateById(wrkMast);
+                                log.info("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"淇敼鐩爣绔欎负:"+staNoOther+";鍘熺洰鏍囩珯涓�:"+wrkMastStaNo);
+                                return;
                             }
-                            BasDevp basDevpOther = basDevpService.selectById(staNoOther);
-                            if (!basDevpOther.getAutoing().equals("Y") || basDevpOther.getWrkNo()!=0 || basDevpOther.getLoading().equals("Y") || basDevpOther.getReportSign()!=0) {
-                                continue;
-                            }
-                            wrkMast.setStaNo(staNoOther);
-                            wrkMastService.updateById(wrkMast);
-                            log.info("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"淇敼鐩爣绔欎负:"+staNoOther+";鍘熺洰鏍囩珯涓�:"+wrkMastStaNo);
-                            return;
                         }
                     }
+                }catch (Exception e){
+                    log.error("STA_WORK_CU澶勭悊澶辫触锛屽綋鍓嶇珯鐐瑰彿锛�"+staNo+"寮傚父淇℃伅"+e);
                 }
             }
         }catch (Exception e){

--
Gitblit v1.9.1