表阀一体机与测控一体阀协议中的阀门状态不兼容，做兼容处理。

liurunyu

2 天以前 7f85ca5468e097f1749ab1ed812046cb8eb979b7

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/TimerTaskJobTest.java

New file
@@ -0,0 +1,48 @@
package com.dy.common.util;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * @Author: liurunyu
 * @Date: 2024/11/20 18:29
 * @Description
 */
public class TimerTaskJobTest extends TimerTaskJob implements Callback {

    private static int count = 0 ;

    public static void main(String[] args) throws Exception {
        TimerTaskJobTest obj = new TimerTaskJobTest() ;
        obj.start(1000L,  1000L, obj);
    }

    public Object execute() {
        count++ ;
        System.out.println("执行伺服线程" + count + "次");
        if(count == 10) {
            stop() ;
        }
        return true ;
    }

    ////////////////////////////////////////////////////
    //
    // 升级状态通知工作线程执行完成后回调的方法，
    // 也就是上面execute方法执行完成返回或抛出异常后，执行下面三个方法
    //
    ////////////////////////////////////////////////////
    @Override
    public void call(Object obj) {
        //线程工作执行一次，obj = Boolean(true)
        System.out.println("伺服线程执行一次回调");
    }
    @Override
    public void call(Object... objs) {
    }
    @Override
    public void exception(Exception e) {
        e.printStackTrace();
        System.out.println("伺服线程发生异常" + e.getMessage());
    }
}