Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

liurunyu

2025-04-23 e5c29d6ac2b210a9385723598d79a42ae5a9679e

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu3rd/src/main/java/com/dy/rtuMw3rd/tcp4Bjnl/Worker.java

New file
@@ -0,0 +1,127 @@
package com.dy.rtuMw3rd.tcp4Bjnl;

import com.alibaba.fastjson2.JSON;
import com.dy.rtuMw3rd.tcp4Bjnl.protocol.*;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.util.Timer;
import java.util.TimerTask;

/**
 * @Author: liurunyu
 * @Date: 2025/2/26 14:39
 * @Description
 */
public class Worker extends TimerTask {

    private static final Logger log = LogManager.getLogger(Worker.class) ;

    private static Worker instance = new Worker() ;

    private String apikey ;
    private String secretkey ;
    private Long workInterval ;//循环任务间隔

    private Timer timer;

    private boolean stop;

    private boolean first = true ;
    private static boolean isLogined = false ;

    private Worker(){
        this.timer = new Timer();
        this.stop = false ;
    }

    public static Worker getInstance(){
        return instance ;
    }


    public void setApikey(String apikey){
        this.apikey = apikey ;
    }
    public void setSecretkey(String secretkey){
        this.secretkey = secretkey ;
    }
    public void setWorkInterval(Long workInterval){
        this.workInterval = workInterval ;
    }

    public void setLogined(){
        log.info("北京农林--请求登录成功");
        isLogined = true ;
    }

    public void stop(){
        this.stop = true ;
        if(this.timer != null){
            this.timer.cancel();
        }
    }
    public boolean isStop(){
        return this.stop ;
    }

    public void start(){
        new Thread(() -> {
            while(true){
                try {
                    login() ;
                }catch (Exception e){
                    log.error("北京农林--请求登录异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
                }
                try{
                    Thread.sleep(10000);
                }catch (Exception e){
                }
                if(isLogined){
                    timer.schedule(this, 0, this.workInterval);
                    break ;
                }
            }
        }).start();
    }

    @Override
    public void run() {
        if(first){
            first = false ;
        }else{
            if(TcpConnect.isConnected() && isLogined) {
                try{
                    heartbeat() ;
                }catch(Exception e){
                    log.error("北京农林--发送心跳异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
                }
            }
        }
    }

    private void login(){
        ParamLogin pl = new ParamLogin() ;
        pl.protocol = new ParamProtocol() ;
        pl.auth = new ParamAuth() ;
        pl.protocol.version = BjnlProtocol.ProtocolVersion ;
        pl.protocol.protocolcode = BjnlProtocol.Protocolcode ;
        pl.auth.apikey = apikey ;
        pl.auth.secretkey = secretkey ;

        String json = JSON.toJSONString(pl) ;
        byte[] bs = BjnlCommon.wrap(json) ;
        try {
            TcpConnect.output(bs);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
    private void heartbeat() throws Exception{
        try {
            TcpConnect.output(BjnlProtocol.HeartBeat);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
}