package com.dy.rtuMw3rd.http4Xjnk;
|
|
|
import java.util.*;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.dy.rtuMw3rd.http4Xjnk.deal.XjnkDealer;
|
import com.dy.rtuMw3rd.http4Xjnk.protocol.XjnkResVo;
|
import com.dy.rtuMw3rd.http4Xjnk.protocol.controller.ControllerVo;
|
import com.dy.rtuMw3rd.http4Xjnk.protocol.mainController.MainControllerVo;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import com.dy.rtuMw3rd.http4Xjnk.protocol.XjnkProtocol;
|
import com.dy.rtuMw3rd.http4Xjnk.protocol.accessToken.Res4AccessTokenVo;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2025/3/19 15:53
|
* @Description
|
*/
|
@Slf4j
|
@Component()
|
public class Worker extends TimerTask {
|
|
private HttpsRq httpsRq ;
|
private XjnkDealer dealer ;
|
|
public String httpsBaseUr ;
|
public String appid ;
|
public String secret ;
|
private Long workInterval ;//循环任务间隔
|
|
private Timer timer;
|
|
private boolean stop;
|
|
private boolean first = true ;
|
private boolean isAccessTokenGot = false ;
|
private List<MainControllerVo> mainControllerVos ;
|
private List<ControllerVo> controllerVos ;
|
|
@Autowired
|
public void setHttpsRq(HttpsRq httpsRq){
|
this.httpsRq = httpsRq ;
|
}
|
@Autowired
|
private void setDealer(XjnkDealer dealer){
|
this.dealer = dealer;
|
}
|
public void setHttpsBaseUr(String httpsBaseUr){
|
this.httpsBaseUr = httpsBaseUr ;
|
}
|
public void setAppid(String appid){
|
this.appid = appid ;
|
}
|
public void setSecret(String secret){
|
this.secret = secret ;
|
}
|
public void setWorkInterval(Long workInterval){
|
this.workInterval = workInterval ;
|
}
|
|
public void stop(){
|
this.stop = true ;
|
if(this.timer != null){
|
this.timer.cancel();
|
}
|
}
|
|
public boolean isStop(){
|
return this.stop ;
|
}
|
|
public void start(){
|
this.timer = new Timer();
|
this.stop = false ;
|
new Thread(() -> {
|
while(true){
|
try {
|
getAccessToken() ;
|
}catch (Exception e){
|
log.error("新疆农垦--获得AccessToken异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
|
}
|
try{
|
Thread.sleep(10000);
|
}catch (Exception e){
|
}
|
if(isAccessTokenGot){
|
timer.schedule(this, 0, this.workInterval);
|
break ;
|
}
|
}
|
}).start();
|
}
|
|
@Override
|
public void run() {
|
if(first){
|
first = false ;
|
}else{
|
try{
|
getAccessToken() ;
|
}catch(Exception e){
|
log.error("新疆农垦--获得AccessToken异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
|
}
|
}
|
if(isAccessTokenGot) {
|
try {
|
getMainControllers();
|
} catch (Exception e) {
|
log.error("新疆农垦--获得主控制器异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
|
}
|
try {
|
getControllers();
|
} catch (Exception e) {
|
log.error("新疆农垦--获得控制器异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
|
}
|
}
|
}
|
|
public void getAccessToken() throws Exception{
|
this.httpsRq.get4JsonBySync(this.httpsBaseUr + "/thirdapi/token?appid=" + this.appid + "&secret=" + this.secret,
|
null,
|
(statusCode, charset, body) -> {
|
// 打印响应状态码
|
//System.out.println("Status Code: " + statusCode);
|
// 打印响应内容编码类型
|
//System.out.println("Response encoding: " + charset);
|
// 打印响应体内容
|
//System.out.println("Response Body: " + body);
|
if(statusCode != null && statusCode.equals(XjnkProtocol.SuccessCode)){
|
Res4AccessTokenVo vo = JSON.parseObject(body, Res4AccessTokenVo.class);
|
if(vo != null && vo.errcode != null && vo.errcode.length() > 0){
|
log.error("新疆农垦--获取AccessToken失败，errcode：" + vo.errcode + "，errmsg：" + vo.errmsg);
|
}else{
|
isAccessTokenGot = true ;
|
XjnkProtocol.AccessToken = vo.accessToken ;
|
XjnkProtocol.AccessTokenExpires = vo.expires ;
|
log.info("新疆农垦--获取AccessToken成功，accessToken：" + vo.accessToken + "，expires：" + vo.expires);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取主控制器
|
* @throws Exception
|
*/
|
public void getMainControllers() throws Exception{
|
this.httpsRq.get4JsonBySync(this.httpsBaseUr + "/thirdapi/pridevice/all?access_token=" + XjnkProtocol.AccessToken,
|
null,
|
(statusCode, charset, body) -> {
|
if(statusCode != null && statusCode.equals(XjnkProtocol.SuccessCode)){
|
try{
|
//首先认为返回的是错误信息，进行尝试
|
XjnkResVo vo = JSON.parseObject(body, XjnkResVo.class);
|
if(vo != null && vo.errcode != null && vo.errcode.length() > 0){
|
log.error("新疆农垦--获取主控制器失败，errcode：" + vo.errcode + "，errmsg：" + vo.errmsg);
|
}
|
}catch (Exception e){
|
//如果不是错误信息，那就是正确信息
|
try{
|
mainControllerVos = JSON.parseArray(body, MainControllerVo.class);
|
log.info("新疆农垦--获取主控制器成功：");
|
if(mainControllerVos != null && mainControllerVos.size() > 0){
|
this.dealer.dealMainController(mainControllerVos);
|
for(MainControllerVo cvo : mainControllerVos){
|
log.info("主控制器：" + cvo);
|
}
|
}
|
}catch (Exception ee){
|
log.error("新疆农垦--获取主控制器异常" + (ee.getMessage() == null ? "" : (":" + ee.getMessage())), ee);
|
}
|
}
|
}
|
});
|
}
|
/**
|
* 获取控制器
|
* @throws Exception
|
*/
|
public void getControllers() throws Exception{
|
if(this.mainControllerVos != null && this.mainControllerVos.size() > 0){
|
for(MainControllerVo mcvo : this.mainControllerVos){
|
Map<String, String> params = new HashMap<>() ;
|
params.put("pdId", "" + mcvo.id) ;
|
this.httpsRq.post4JsonBySync(this.httpsBaseUr + "/thirdapi/control_device/query?access_token=" + XjnkProtocol.AccessToken,
|
params,
|
(statusCode, charset, body) -> {
|
if(statusCode != null && statusCode.equals(XjnkProtocol.SuccessCode)){
|
try{
|
//首先认为返回的是错误信息，进行尝试
|
XjnkResVo vo = JSON.parseObject(body, XjnkResVo.class);
|
if(vo != null && vo.errcode != null && vo.errcode.length() > 0){
|
log.error("新疆农垦--获取控制器失败，errcode：" + vo.errcode + "，errmsg：" + vo.errmsg);
|
}
|
}catch (Exception e){
|
//如果不是错误信息，那就是正确信息
|
try{
|
controllerVos = JSON.parseArray(body, ControllerVo.class);
|
log.info("新疆农垦--获取控制器成功：");
|
if(controllerVos != null && controllerVos.size() > 0){
|
this.dealer.dealController(controllerVos);
|
for(ControllerVo cvo : controllerVos){
|
log.info("控制器：" + cvo);
|
}
|
}
|
}catch (Exception ee){
|
log.error("新疆农垦--获取控制器异常" + (ee.getMessage() == null ? "" : (":" + ee.getMessage())), ee);
|
}
|
}
|
}
|
});
|
}
|
}
|
}
|
}
|
