src/main/java/com/zy/asrs/task/ScaleEscalationScheduler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/StaEscalationScheduler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/handler/ScaleEscalationHandler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/asrs/task/handler/StaEscalationHandler.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/zy/asrs/task/ScaleEscalationScheduler.java
@@ -2,11 +2,13 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.zy.asrs.domain.enums.LedErrorAreaType; import com.zy.asrs.entity.RgvOneSign; import com.zy.asrs.mapper.RgvOneSignMapper; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.ScaleEscalationHandler; import com.zy.asrs.task.handler.StaEscalationHandler; import com.zy.asrs.utils.LedErrorThreadUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; @@ -24,7 +26,7 @@ private ScaleEscalationHandler scaleEscalationHandler; @Scheduled(cron = "0/3 * * * * ? ") private void execute(){//2楼翻转倒料信息上传 private void execute(){//1楼翻转倒料重量上传 int[] staNos =new int[]{460,453}; for (int staNo : staNos){ try{ @@ -33,7 +35,8 @@ break; } }catch (Exception e){ log.error("站点"+staNo+"2楼翻转倒料信息上传处理失败,异常信息:"+e); LedErrorThreadUtil.ledErrorThread("1楼翻转倒料重量上报erp失败!站点号:"+staNo,4, LedErrorAreaType.ONE_OTHER.getDesc()); log.error("站点"+staNo+"1楼翻转倒料重量上传处理失败,异常信息:"+e); } } } src/main/java/com/zy/asrs/task/StaEscalationScheduler.java
@@ -1,7 +1,9 @@ package com.zy.asrs.task; import com.zy.asrs.domain.enums.LedErrorAreaType; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.StaEscalationHandler; import com.zy.asrs.utils.LedErrorThreadUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; @@ -28,6 +30,7 @@ break; } }catch (Exception e){ LedErrorThreadUtil.ledErrorThread("2楼翻转倒料上报erp失败!站点号:"+staNo,4, LedErrorAreaType.ONE_OTHER.getDesc()); log.error("站点"+staNo+"2楼翻转倒料信息上传处理失败,异常信息:"+e); } } src/main/java/com/zy/asrs/task/handler/ScaleEscalationHandler.java
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.domain.enums.LedErrorAreaType; import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.RgvOneSign; import com.zy.asrs.entity.WrkDetl; @@ -15,6 +16,7 @@ import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.escalationParam.ScaleEscalationParam; import com.zy.asrs.task.escalationParam.StaEscalationParam; import com.zy.asrs.utils.LedErrorThreadUtil; import com.zy.common.utils.HttpHandler; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.SlaveType; @@ -79,6 +81,7 @@ basDevpService.updateById(basDevp); return SUCCESS; }else { LedErrorThreadUtil.ledErrorThread("1楼翻转倒料重量上报erp失败!站点号:"+staNo,4, LedErrorAreaType.ONE_OTHER.getDesc()); log.error("1楼翻转重量信息上传失败"); } } src/main/java/com/zy/asrs/task/handler/StaEscalationHandler.java
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.domain.enums.LedErrorAreaType; import com.zy.asrs.entity.BasDevp; import com.zy.asrs.entity.WrkDetl; import com.zy.asrs.entity.WrkMast; @@ -12,6 +13,7 @@ import com.zy.asrs.task.AbstractHandler; import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.escalationParam.StaEscalationParam; import com.zy.asrs.utils.LedErrorThreadUtil; import com.zy.common.utils.HttpHandler; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.SlaveType; @@ -103,12 +105,14 @@ basDevp.setReportSign(1); basDevpService.updateById(basDevp); return SUCCESS; }else { log.error("2楼翻转倒料信息上传失败"); } else { LedErrorThreadUtil.ledErrorThread("翻转上报erp失败!站点号:"+staNo,4, LedErrorAreaType.ONE_OTHER.getDesc()); log.error("2楼翻转倒料信息上传失败!站点号:"+staNo); } } } }catch (Exception e){ LedErrorThreadUtil.ledErrorThread("翻转上传异常!站点号:"+staNo,4, LedErrorAreaType.ONE_OTHER.getDesc()); log.error("异常4!!!"+e); return FAIL; }