From 915e2fbc3dd51674bcc1ad7eacbd91258243fb75 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期一, 25 三月 2024 13:25:47 +0800
Subject: [PATCH] #for循环异常处理
---
src/main/java/com/zy/asrs/task/RailwayPlatformScheduler.java | 12 ++
src/main/java/com/zy/asrs/task/ReportToDismantleTheStackScheduler.java | 12 ++
src/main/java/com/zy/asrs/task/LocMoveAllScheduler.java | 72 +++++++++--------
src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java | 84 +++++++++++---------
src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java | 22 +++--
src/main/java/com/zy/asrs/task/WorkMastScheduler.java | 3
src/main/java/com/zy/asrs/task/OrderSyncScheduler.java | 9 +
src/main/java/com/zy/asrs/task/WorkLogScheduler.java | 3
src/main/java/com/zy/asrs/task/BarcodeUploadScheduler.java | 14 ++-
9 files changed, 138 insertions(+), 93 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/BarcodeUploadScheduler.java b/src/main/java/com/zy/asrs/task/BarcodeUploadScheduler.java
index 7186e7b..ea5eafa 100644
--- a/src/main/java/com/zy/asrs/task/BarcodeUploadScheduler.java
+++ b/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,9 +21,14 @@
private void execute(){//鏉＄爜涓婁紶涓帶
int[] staNos =new int[]{215,219};
for (int staNo : staNos){
- ReturnT<String> result = barcodeUploadHandler.start(staNo);
- if (result.getCode()==200){
- break;
+ try{
+ ReturnT<String> result = barcodeUploadHandler.start(staNo);
+ if (result.getCode()==200){
+ break;
+ }
+ }catch (Exception e){
+ log.error("宸ヤ綔妗workNo={}]鏉＄爜涓婁紶涓帶澶辫触", staNo);
+ log.error("澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/LocMoveAllScheduler.java b/src/main/java/com/zy/asrs/task/LocMoveAllScheduler.java
index 7fa8019..c62aa2b 100644
--- a/src/main/java/com/zy/asrs/task/LocMoveAllScheduler.java
+++ b/src/main/java/com/zy/asrs/task/LocMoveAllScheduler.java
@@ -50,43 +50,47 @@
return;
}
for (BasCrnp basCrnp:basCrnps){
- 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()));
- if (Cools.isEmpty(wrkMasts) || wrkMasts.size()==0) {
- LocMast locMastStart = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts","D").eq("crn_no",basCrnp.getCrnNo()).orderBy("appe_time",true));//绌烘澘鎵�鍦�
- if (Cools.isEmpty(locMastStart)){
- continue;
- }
- if (!Utils.isShallowLoc(slaveProperties, locMastStart.getLocNo())){
- String shallowLocNo = Utils.getShallowLoc(slaveProperties, locMastStart.getLocNo());
- LocMast locNo = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLocNo));
- if (!locNo.getLocSts().equals("O")){
- locMastStart = locNo;
- }
- }
- LocMast locMastEnd = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts","O").eq("crn_no",basCrnp.getCrnNo()).ne("modi_user",66).orderBy("row1",true));//鐩爣
- if (Cools.isEmpty(locMastEnd)){
- continue;
- }
- if (!Utils.isShallowLoc(slaveProperties, locMastEnd.getLocNo())){
- String shallowLocNo = Utils.getShallowLoc(slaveProperties, locMastEnd.getLocNo());
- LocMast locNo = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLocNo));
- if (locNo.getLocSts().equals("O")){
+ 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()));
+ if (Cools.isEmpty(wrkMasts) || wrkMasts.size()==0) {
+ LocMast locMastStart = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts","D").eq("crn_no",basCrnp.getCrnNo()).orderBy("appe_time",true));//绌烘澘鎵�鍦�
+ if (Cools.isEmpty(locMastStart)){
+ continue;
+ }
+ if (!Utils.isShallowLoc(slaveProperties, locMastStart.getLocNo())){
+ String shallowLocNo = Utils.getShallowLoc(slaveProperties, locMastStart.getLocNo());
+ LocMast locNo = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLocNo));
+ if (!locNo.getLocSts().equals("O")){
+ locMastStart = locNo;
+ }
+ }
+ LocMast locMastEnd = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts","O").eq("crn_no",basCrnp.getCrnNo()).ne("modi_user",66).orderBy("row1",true));//鐩爣
+ if (Cools.isEmpty(locMastEnd)){
+ continue;
+ }
+ if (!Utils.isShallowLoc(slaveProperties, locMastEnd.getLocNo())){
+ String shallowLocNo = Utils.getShallowLoc(slaveProperties, locMastEnd.getLocNo());
+ LocMast locNo = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLocNo));
+ if (locNo.getLocSts().equals("O")){
- }else {
- locMastEnd.setModiUser(66L);
- locMastService.updateById(locMastEnd);
- continue;
- }
- }
+ }else {
+ locMastEnd.setModiUser(66L);
+ locMastService.updateById(locMastEnd);
+ continue;
+ }
+ }
// if (Cools.isEmpty(locMastStart) || Cools.isEmpty(locMastEnd)){
- ReturnT<String> result = locMoveAllHandler.start(locMastStart,locMastEnd,basCrnp.getCrnNo());
- if (!result.isSuccess()) {
- log.error("澶勭悊澶辫触");
- }
- }
+ ReturnT<String> result = locMoveAllHandler.start(locMastStart,locMastEnd,basCrnp.getCrnNo());
+ if (!result.isSuccess()) {
+ log.error("澶勭悊澶辫触");
+ }
+ }
+ }catch (Exception e){
+ log.error("澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e);
+ }
}
}
diff --git a/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java b/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java
index 923b229..6ae61d5 100644
--- a/src/main/java/com/zy/asrs/task/OneLouHangJiaScheduler.java
+++ b/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,14 +30,18 @@
// int[] staNos =new int[]{118,119};
int[] staNos =new int[]{118};
for (int staNo : staNos){
- 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)){
- break;
- }
- ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
- if (result.getCode()==200){
- break;
+ 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)){
+ break;
+ }
+ ReturnT<String> result = oneLouHangJiaHandler.start(147,staNo);
+ if (result.getCode()==200){
+ break;
+ }
+ }catch (Exception e){
+ log.error("閫�搴撴媶鐮佸灈"+staNo+"绔欑偣澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
index 61004e9..7c65a7c 100644
--- a/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
+++ b/src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
@@ -45,9 +45,14 @@
if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
List<Order> orders = orderService.selectComplete();
for (Order order : orders) {
- ReturnT<String> result = orderSyncHandler.start(order);
- if (!result.isSuccess()) {
+ 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);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/RailwayPlatformScheduler.java b/src/main/java/com/zy/asrs/task/RailwayPlatformScheduler.java
index 835660f..7dd5528 100644
--- a/src/main/java/com/zy/asrs/task/RailwayPlatformScheduler.java
+++ b/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,9 +22,13 @@
private void execute(){//涓婃姤鏈堝彴
int[] staNos =new int[]{144};
for (int staNo : staNos){
- ReturnT<String> result = railwayPlatformHandler.start(staNo);
- if (result.getCode()==200){
- break;
+ try{
+ ReturnT<String> result = railwayPlatformHandler.start(staNo);
+ if (result.getCode()==200){
+ break;
+ }
+ }catch (Exception e){
+ log.error("绔欑偣"+staNo+"涓婃姤鏈堝彴澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/ReportToDismantleTheStackScheduler.java b/src/main/java/com/zy/asrs/task/ReportToDismantleTheStackScheduler.java
index ac41c11..fe2980f 100644
--- a/src/main/java/com/zy/asrs/task/ReportToDismantleTheStackScheduler.java
+++ b/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,9 +22,13 @@
private void execute(){//鎷嗗灈淇℃伅涓婁紶
int[] staNos =new int[]{118,119,120,121};
for (int staNo : staNos){
- ReturnT<String> result = reportToDismantleTheStackHandler.start(staNo);
- if (result.getCode()==200){
- break;
+ try{
+ ReturnT<String> result = reportToDismantleTheStackHandler.start(staNo);
+ if (result.getCode()==200){
+ break;
+ }
+ }catch (Exception e){
+ log.error("绔欑偣"+staNo+"鎷嗗灈淇℃伅涓婁紶澶勭悊澶辫触锛屽紓甯镐俊鎭細"+e);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/WorkLogScheduler.java b/src/main/java/com/zy/asrs/task/WorkLogScheduler.java
index 449d644..fc4e244 100644
--- a/src/main/java/com/zy/asrs/task/WorkLogScheduler.java
+++ b/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);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
index 77bf00c..f61788a 100644
--- a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java
+++ b/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);
}
}
}
diff --git a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
index 51b1728..eb36dc9 100644
--- a/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
+++ b/src/main/java/com/zy/asrs/task/WrkMastStaInItScheduler.java
@@ -66,58 +66,63 @@
@Scheduled(cron = "0/3 * * * * ? ")
private void execute(){
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()<100 || wrkMast.getIoType()==110){
- if (!wrkMast.getStaNo().equals(122)){
+ 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.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
- continue;
- }
- if (wrkMast.getStaNo()==118 || wrkMast.getStaNo()==119 || wrkMast.getStaNo()==120 || wrkMast.getStaNo()==121){
- 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.getIoType()<100 || wrkMast.getIoType()==110){
+ if (!wrkMast.getStaNo().equals(122)){
continue;
- }else {
- System.out.println(staNo+"澶辫触锛�");
}
- } else {
- ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,23);//5锛氭弧鍙�
- if (result.getCode()==200){
- continue;
- }else {
- System.out.println(staNo+"澶辫触锛�");
+ }
+ if (wrkMast.getWrkSts()!=14 && wrkMast.getWrkSts()!=15){
+ continue;
+ }
+ if (wrkMast.getStaNo()==118 || wrkMast.getStaNo()==119 || wrkMast.getStaNo()==120 || wrkMast.getStaNo()==121){
+ 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+"澶辫触锛�");
+ }
+ } else {
+ ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,23);//5锛氭弧鍙�
+ if (result.getCode()==200){
+ continue;
+ }else {
+ System.out.println(staNo+"澶辫触锛�");
+ }
}
}
}
+ }catch (Exception e){
+ log.error("鑷姩琛ョ┖鏉縎TA_WORK_CU澶勭悊澶辫触锛屽綋鍓嶇珯鐐瑰彿锛�"+staNo+"寮傚父淇℃伅"+e);
}
}
for(Integer staNo : STA_WORK_RU){
- 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;
- }
+ 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.getWrkSts()!=2 || wrkMast.getIoType()==10){
- continue;
- }
+ if (wrkMast.getWrkSts()!=2 || wrkMast.getIoType()==10){
+ continue;
+ }
// boolean wrkTypeSign = fullKM(wrkMast);
- if (!Cools.isEmpty(wrkMast)){
+ if (!Cools.isEmpty(wrkMast)){
// if (wrkTypeSign){
ReturnT<String> result = wrkMastStaInItHandler.start(wrkMast,basDevp,13);
if (result.getCode()==200) {
@@ -125,7 +130,10 @@
} else {
System.out.println(staNo+"澶辫触锛�");
}
+ }
}
+ }catch (Exception e){
+ log.error("鑷姩琛ョ┖鏉縎TA_WORK_RU澶勭悊澶辫触锛屽綋鍓嶇珯鐐瑰彿锛�"+staNo+"寮傚父淇℃伅"+e);
}
}
}
--
Gitblit v1.9.1