*

L

2026-04-23 d074cb16f7b3ba11363766dd78802da60f4ec07d

*

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

@@ -57,6 +57,7 @@
    private boolean resetFlag2 = false;
    private boolean connectRgv = false;
    private boolean alarmChangeSign = false;
    private boolean csSign = true;//测试标记

    public RgvThread(RgvSlave slave) {
        this.slave = slave;
@@ -210,24 +211,57 @@
     * 初始化RGV状态
     */
    private void initRgv() {
       if (csSign){
           initRgvCS();
       } else {
           initRgvT();
       }
    }

    /**
     * 初始化RGV状态
     */
    private void initRgvT() {
        if (null == rgvProtocol) {
            rgvProtocol = new RgvProtocol();
        }
        rgvProtocol.setRgvNo(slave.getId());
//        rgvProtocol.setMode((short) -1);
//        rgvProtocol.setStatus((short)-1);
//        rgvProtocol.setTaskNo1((short)0);
//        rgvProtocol.setStatus1((short)-1);
//        rgvProtocol.setLoaded1((short)0);
//        rgvProtocol.setWalkPos((short)0);
//        rgvProtocol.setRgvPos(0L);
//        rgvProtocol.setTaskNo2((short)0);
//        rgvProtocol.setStatus2((short)-1);
//        rgvProtocol.setLoaded2((short)0);
//        rgvProtocol.setAlarm((short)0);
//        rgvProtocol.setxSpeed((short) 0);
//        rgvProtocol.setxDistance((short) 0);
//        rgvProtocol.setxDuration((short) 0);
        rgvProtocol.setMode((short) -1);
        rgvProtocol.setStatus((short)-1);
        rgvProtocol.setTaskNo1((short)0);
        rgvProtocol.setStatus1((short)-1);
        rgvProtocol.setLoaded1((short)0);
        rgvProtocol.setWalkPos((short)0);
        rgvProtocol.setRgvPos(0L);
        rgvProtocol.setTaskNo2((short)0);
        rgvProtocol.setStatus2((short)-1);
        rgvProtocol.setLoaded2((short)0);
        rgvProtocol.setAlarm((short)0);
        rgvProtocol.setxSpeed((short) 0);
        rgvProtocol.setxDistance((short) 0);
        rgvProtocol.setxDuration((short) 0);
        log.error("连接中断：RGV号："+slave.getId());
        try {
            // 根据实时信息更新数据库
            BasRgvService basRgvService = SpringUtils.getBean(BasRgvService.class);
            BasRgv basRgv = new BasRgv();
            basRgv.setRgvNo(slave.getId());
            basRgv.setRgvSts((int)rgvProtocol.getMode());
            basRgv.setLoaded2(rgvProtocol.getLoaded2().intValue());
            if (!basRgvService.updateById(rgvProtocol.toSqlModel(basRgv))){
                log.error("RGV plc数据库更新失败 ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
            }
        } catch (Exception ignore) {
        }
    }

    /**
     * 初始化RGV状态
     */
    private void initRgvCS() {
        if (null == rgvProtocol) {
            rgvProtocol = new RgvProtocol();
            rgvProtocol.setRgvNo(slave.getId());
        rgvProtocol.setMode((short) 3);
        rgvProtocol.setStatus((short)0);
        rgvProtocol.setTaskNo1((short)0);
@@ -237,7 +271,8 @@
        if (rgvProtocol.getRgvPos()==null ||  rgvProtocol.getRgvPos()==0){
            rgvProtocol.setRgvPos(1L+rgvProtocol.getRgvNo()*10000);
        }
        rgvProtocol.setRgvPos(rgvProtocol.getRgvPos()+1000);
//        rgvProtocol.setRgvPos(rgvProtocol.getRgvPos()+1000);
            rgvProtocol.setRgvPos(rgvProtocol.getRgvPos());
        rgvProtocol.setTaskNo2((short)0);
        rgvProtocol.setStatus2((short)-1);
        rgvProtocol.setLoaded2((short)0);
@@ -245,6 +280,7 @@
        rgvProtocol.setxSpeed((short) 0);
        rgvProtocol.setxDistance((short) 0);
        rgvProtocol.setxDuration((short) 0);
        }
//        log.error("连接中断：RGV号："+slave.getId());
        try {
            // 根据实时信息更新数据库