#改造

cpT

2025-06-30 5aa831dffdfb0ca524362e8d649c28babc681ece

 src/main/java/com/zy/core/thread/SiemensCrnThread.java

@@ -10,9 +10,13 @@
import com.core.common.SpringUtils;
import com.zy.asrs.entity.BasCrnOpt;
import com.zy.asrs.entity.BasCrnp;
import com.zy.asrs.entity.BasErrLog;
import com.zy.asrs.service.BasCrnOptService;
import com.zy.asrs.service.BasCrnpService;
import com.zy.asrs.service.BasErrLogService;
import com.zy.asrs.service.DeviceErrorService;
import com.zy.core.CrnThread;
import com.zy.core.cache.CrnErrCache;
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.OutputQueue;
import com.zy.core.enums.CrnStatusType;
@@ -49,6 +53,7 @@
     * 堆垛机是否在回原点运动中标记
     */
    private boolean backHpFlag = false;
    public Long currentTimeMilliConnectCrn= 0L;

    public SiemensCrnThread(CrnSlave slave) {
        this.slave = slave;
@@ -91,6 +96,11 @@
                        command.setDestinationPosY((short)0);     // 目标库位列
                        command.setDestinationPosZ((short)0);     // 目标库位层
                        write(command);
                        break;
                    // 复位
                    case 4:
                        CrnCommand command4 = (CrnCommand) task.getData();
                        write(command4);
                        break;
                    default:
                        break;
@@ -217,6 +227,21 @@
                initCrn();
                OutputQueue.CRN.offer(MessageFormat.format("【{0}】读取堆垛机plc状态信息失败 ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()));
                log.error("读取堆垛机plc状态信息失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
                if (System.currentTimeMillis()-currentTimeMilliConnectCrn>1000*60*10){
                    try{
                        DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                        deviceErrorService.addDeviceError("CrnErr", slave.getId(), "读取堆垛机plc状态信息失败");
                    } catch (Exception e2){
                        Thread.sleep(1000);
//                log.error("e2:"+e2.getMessage());
                    }
                    if (currentTimeMilliConnectCrn == 0){
                        currentTimeMilliConnectCrn = System.currentTimeMillis()-1000*60*10-1;
                    } else {
                        currentTimeMilliConnectCrn = System.currentTimeMillis();

                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
@@ -242,6 +267,20 @@
        if (null == command) {
            log.error("堆垛机写入命令为空");
            return false;
        }
        CrnErrCache.updateCrnErr(slave.getId(), "-");
        try{
            DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
            deviceErrorService.addDeviceError("crnWrite", slave.getId(), "巷道号"+command.getLaneNo()+";堆垛机指令下发:"+JSON.toJSONString(command.getNowTask()));
        } catch (Exception e2){
        }
        try{
            BasErrLogService basErrLogService = SpringUtils.getBean(BasErrLogService.class);
            BasErrLog basErrLog = new BasErrLog(command,"","非异常，任务下发记录");
            if (!basErrLogService.insert(basErrLog)) {
                log.error("堆垛机plc异常记录失败 ===>> [id:{}] [error:{}]", slave.getId(), "任务下发记录失败");
            }
        } catch (Exception e3){
        }
//        convertRow(command);
        command.setCrnNo(slave.getId());
@@ -276,7 +315,23 @@
                if (!command.getTaskNo().equals(one.getTaskNo())
                ){
                    i++;
                    CrnErrCache.updateCrnErr(slave.getId(), "堆垛机命令地址写入后回读失败");

                    log.error("堆垛机命令地址写入后回读失败[id:{}]>>>>重写[{}] >>>>> 写入[{}],===>>回读[{}]", slave.getId(), i,JSON.toJSON(command),JSON.toJSON(one));

                    try{
                        DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                        deviceErrorService.addDeviceError("crnErr", slave.getId(), "巷道号"+command.getLaneNo()+";写入次数"+i+";堆垛机命令地址写入后回读失败:"+JSON.toJSONString(command.getNowTask()));
                    } catch (Exception e2){
                    }
                    try{
                        BasErrLogService basErrLogService = SpringUtils.getBean(BasErrLogService.class);
                        BasErrLog basErrLog = new BasErrLog(command,"堆垛机命令地址写入后回读失败","");
                        if (!basErrLogService.insert(basErrLog)) {
                            log.error("堆垛机plc异常记录失败 ===>> [id:{}] [error:{}]", slave.getId(), "堆垛机命令地址写入后回读失败记录失败");
                        }
                    } catch (Exception e3){
                    }
                    result = siemensNet.Write("DB100.0", array);
                }else{
                    break;
@@ -297,6 +352,20 @@
                if (transInt16 != commandFinish){
                    log.info("下发DB100.18  回读失败" + "commandFinish:"+commandFinish);
                    log.info("下发DB100.18  回读失败" + "array:"+ JSON.toJSONString(array));
                    CrnErrCache.updateCrnErr(slave.getId(), "下发DB100.18  回读失败");
                    try{
                        DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                        deviceErrorService.addDeviceError("crnErr", slave.getId(), "巷道号"+command.getLaneNo()+";写入次数"+signFinish+";下发DB100.18  回读失败:"+JSON.toJSONString(command.getNowTask()));
                    } catch (Exception e2){
                    }
                    try{
                        BasErrLogService basErrLogService = SpringUtils.getBean(BasErrLogService.class);
                        BasErrLog basErrLog = new BasErrLog(command,"下发DB100.18  回读失败","");
                        if (!basErrLogService.insert(basErrLog)) {
                            log.error("堆垛机plc异常记录失败 ===>> [id:{}] [error:{}]", slave.getId(), "下发DB100.18  回读失败记录失败");
                        }
                    } catch (Exception e3){
                    }
                    result = siemensNet.Write("DB100.18", commandFinish);
                    signFinish++;
                }else {
@@ -339,6 +408,8 @@
        } else {
            OutputQueue.CRN.offer(MessageFormat.format("【{0}】写入堆垛机plc数据失败 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
            log.error("写入堆垛机plc数据失败 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
            CrnErrCache.updateCrnErr(slave.getId(), "写入堆垛机plc数据失败");

            return false;
        }
    }
@@ -469,4 +540,12 @@
        isRunning = false;
    }


    /**
     * 清除作业启动中
     */
    @Override
    public void setWrkSign() {
    }

}