#for循环异常处理

LSH

2024-03-25 915e2fbc3dd51674bcc1ad7eacbd91258243fb75

#for循环异常处理

 src/main/java/com/zy/asrs/task/BarcodeUploadScheduler.java

@@ -2,14 +2,15 @@

import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.BarcodeUploadHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * Created by Monkey D. Luffy on 2023.07.25
 * 徐工汉云..............以下.............上饶江铜.............条码上传中控
 */
@Slf4j
@Component
public class BarcodeUploadScheduler {

@@ -20,10 +21,15 @@
    private void execute(){//条码上传中控
        int[] staNos =new int[]{215,219};
        for (int staNo : staNos){
            try{
            ReturnT<String> result = barcodeUploadHandler.start(staNo);
            if (result.getCode()==200){
                break;
            }
            }catch (Exception e){
                log.error("工作档[workNo={}]条码上传中控失败", staNo);
                log.error("处理失败，异常信息："+e);
            }
        }
    }


 src/main/java/com/zy/asrs/task/LocMoveAllScheduler.java

@@ -50,6 +50,7 @@
            return;
        }
        for (BasCrnp basCrnp:basCrnps){
           try{
            if (basCrnp.getCrnSts()!=3) continue;
            if (!basCrnp.getInEnable().equals("N") || !basCrnp.getOutEnable().equals("Y")) continue;
            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("crn_no",basCrnp.getCrnNo()));
@@ -87,6 +88,9 @@
                    log.error("处理失败");
                }
            }
           }catch (Exception e){
               log.error("处理失败，异常信息："+e);
           }
        }
    }


 src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java

@@ -7,6 +7,7 @@
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.OneLouHangJiaHandler;
import com.zy.asrs.task.handler.RailwayPlatformHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -15,6 +16,7 @@
 * Created by Monkey D. Luffy on 2023.09.17
 * 徐工汉云..............以下.............上饶江铜.............退库拆码垛
 */
@Slf4j
@Component
public class OneLouHangJiaScheduler {

@@ -28,6 +30,7 @@
//        int[] staNos =new int[]{118,119};
        int[] staNos =new int[]{118};
        for (int staNo : staNos){
            try{
            WrkMastSta wrkMastSta = wrkMastStaService.selectOne(new EntityWrapper<WrkMastSta>().eq("sta_end",staNo)
                    .eq("type", 2).eq("wrk_sts", 0).eq("wrk_type", 2));
            if (!Cools.isEmpty(wrkMastSta)){
@@ -37,6 +40,9 @@
            if (result.getCode()==200){
                break;
            }
            }catch (Exception e){
                log.error("退库拆码垛"+staNo+"站点处理失败，异常信息："+e);
            }
        }
    }


 src/main/java/com/zy/asrs/task/OrderSyncScheduler.java

@@ -45,10 +45,15 @@
        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
            List<Order> orders = orderService.selectComplete();
            for (Order order : orders) {
                try{
                ReturnT<String> result = orderSyncHandler.start(order);
                if (!result.isSuccess()) {
                    log.error("单据[orderNo={}]上报erp失败", order.getOrderNo());
                }
                }catch (Exception e){
                    log.error("单据[orderNo={}]上报erp失败", order.getOrderNo());
                    log.error("订单"+order+"处理失败，异常信息："+e);
                }
            }
        }
    }

 src/main/java/com/zy/asrs/task/RailwayPlatformScheduler.java

@@ -2,6 +2,7 @@

import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.RailwayPlatformHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -10,6 +11,7 @@
 * Created by Monkey D. Luffy on 2023.09.17
 * 徐工汉云..............以下.............上饶江铜.............上报月台
 */
@Slf4j
@Component
public class RailwayPlatformScheduler {

@@ -20,10 +22,14 @@
    private void execute(){//上报月台
        int[] staNos =new int[]{144};
        for (int staNo : staNos){
            try{
            ReturnT<String> result = railwayPlatformHandler.start(staNo);
            if (result.getCode()==200){
                break;
            }
            }catch (Exception e){
                log.error("站点"+staNo+"上报月台处理失败，异常信息："+e);
            }
        }
    }


 src/main/java/com/zy/asrs/task/ReportToDismantleTheStackScheduler.java

@@ -2,6 +2,7 @@

import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.ReportToDismantleTheStackHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -10,6 +11,7 @@
 * Created by Monkey D. Luffy on 2023.07.25
 * 徐工汉云..............以下.............上饶江铜.............拆垛信息上传
 */
@Slf4j
@Component
public class ReportToDismantleTheStackScheduler {

@@ -20,10 +22,14 @@
    private void execute(){//拆垛信息上传
        int[] staNos =new int[]{118,119,120,121};
        for (int staNo : staNos){
            try{
            ReturnT<String> result = reportToDismantleTheStackHandler.start(staNo);
            if (result.getCode()==200){
                break;
            }
            }catch (Exception e){
                log.error("站点"+staNo+"拆垛信息上传处理失败，异常信息："+e);
            }
        }
    }


 src/main/java/com/zy/asrs/task/WorkLogScheduler.java

@@ -43,6 +43,7 @@
                }
            }catch (Exception e){
                log.error("工作档[workNo={}]历史档处理失败", wrkMast.getWrkNo());
                log.error("处理失败，异常信息："+e);
            }
        }
    }
@@ -59,6 +60,7 @@
                wrkMastService.updateById(wrkMast);
            }catch (Exception e){
                log.error("工作档[workNo={}]标记处理失败", wrkMast.getWrkNo());
                log.error("处理失败，异常信息："+e);
            }
        }
    }
@@ -77,6 +79,7 @@
                }
            }catch (Exception e){
                log.error("工作档[workNo={}]历史档处理失败", wrkMastSta.getWrkNo());
                log.error("处理失败，异常信息："+e);
            }
        }
    }

 src/main/java/com/zy/asrs/task/WorkMastScheduler.java

@@ -56,6 +56,7 @@
                }
            }catch (Exception e){
                log.error("工作档[workNo={}]更新库存处理失败", wrkMast.getWrkNo());
                log.error("处理失败，异常信息："+e);
            }
        }
    }
@@ -83,7 +84,7 @@
                }
            }catch (Exception e){
                log.error("工作档[workNo={}]转完成处理失败", wrkMast.getWrkNo());

                log.error("处理失败，异常信息："+e);
            }
        }
    }

 src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java

@@ -66,6 +66,7 @@
    @Scheduled(cron = "0/3 * * * * ? ")
    private void execute(){
        for(Integer staNo : STA_WORK_CU){
            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()));
@@ -102,9 +103,13 @@
                    }
                }
            }
            }catch (Exception e){
                log.error("自动补空板STA_WORK_CU处理失败，当前站点号："+staNo+"异常信息"+e);
            }
        }

        for(Integer staNo : STA_WORK_RU){
            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()));
@@ -127,6 +132,9 @@
                        }
                }
            }
            }catch (Exception e){
                log.error("自动补空板STA_WORK_RU处理失败，当前站点号："+staNo+"异常信息"+e);
            }
        }
    }