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();
|
}
|
}
|
