表阀一体机协议，根据王江海测试问题，进行修改完善

liurunyu

2025-06-20 71b9ac1d2459239d2c5340b384f1536b156fc003

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu3rd/src/main/java/com/dy/rtuMw3rd/http4Xjnk/HttpUnit.java

New file
@@ -0,0 +1,63 @@
package com.dy.rtuMw3rd.http4Xjnk;

import com.dy.common.mw.UnitAdapterInterface;
import com.dy.common.mw.UnitCallbackInterface;
import com.dy.common.mw.UnitInterface;
import com.dy.common.springUtil.SpringContextUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * @Author: liurunyu
 * @Date: 2025/3/19 15:14
 * @Description
 */
public class HttpUnit implements UnitInterface {

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

    private static HttpUnit instance = new HttpUnit() ;

    public static HttpUnitAdapter adapter ;
    public static HttpUnitConfigVo confVo ;

    private HttpUnit(){} ;

    public static HttpUnit getInstance(){
        return instance ;
    }

    @Override
    public void setAdapter(UnitAdapterInterface adapter) throws Exception {
        if(adapter == null){
            throw new Exception("Http模块适配器对象不能为空！") ;
        }
        HttpUnit.adapter = (HttpUnitAdapter)adapter ;
        HttpUnit.confVo = HttpUnit.adapter.getConfig() ;
        if(HttpUnit.confVo == null){
            throw new Exception("Http模块配置对象不能为空！") ;
        }
    }

    @Override
    public void start(UnitCallbackInterface callback) throws Exception {
        System.out.println("Http模块成功启动");
        this.doStart();
        callback.call(null) ;
    }


    @Override
    public void stop(UnitCallbackInterface callback) throws Exception {
        callback.call(null);
    }

    private void doStart(){
        Worker w = SpringContextUtil.getBean(Worker.class) ;
        w.setHttpsBaseUr(confVo.httpsBaseUr);
        w.setAppid(confVo.appid);
        w.setSecret(confVo.secret );
        w.setWorkInterval(confVo.flushDataFromSvInterval + 0L);
        w.start();
    }
}