#
yxFwq
2024-11-28 519ae5fe0eeef687ec5926c7eab777c387cbe498
#
4个文件已修改
21 ■■■■ 已修改文件
src/main/java/com/zy/asrs/task/ScaleEscalationScheduler.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/asrs/task/StaEscalationScheduler.java 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/asrs/task/handler/ScaleEscalationHandler.java 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/asrs/task/handler/StaEscalationHandler.java 8 ●●●● 补丁 | 查看 | 原始文档 | 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;
        }