package org.jeecg.modules.quartz.job;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.jeecg.common.util.DateUtils;
|
import org.jeecg.modules.iot.entity.MqttParameter;
|
import org.jeecg.modules.iot.entity.ServerDeploy;
|
import org.jeecg.modules.iot.mqtt.config.MqttCustomerClient;
|
import org.jeecg.modules.iot.service.IServerDeployService;
|
import org.quartz.Job;
|
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionException;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.List;
|
|
/**
|
* 示例不带参定时任务
|
*
|
* @Author Scott
|
*/
|
@Slf4j
|
public class SampleJob implements Job {
|
@Autowired
|
private IServerDeployService serverDeployService;
|
@Autowired
|
private MqttCustomerClient mqttCustomerClient;
|
|
@Override
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
List<ServerDeploy> serverDeploys = serverDeployService.list();
|
if (serverDeploys != null) {
|
serverDeploys.forEach(sd -> {
|
if (sd.getGuardState().equals(1)) {
|
// 发送心跳信号
|
MqttParameter mqttParameter = new MqttParameter();
|
mqttParameter.setId(sd.getServerCode());
|
mqttParameter.setType("palpitate");
|
mqttParameter.setParameter1("0");
|
mqttCustomerClient.pushlish(2, false, sd.getServerCode(), mqttParameter);
|
// 发送采集状态
|
MqttParameter parameter = new MqttParameter();
|
parameter.setId(sd.getServerCode());
|
parameter.setType("collect");
|
parameter.setParameter1("0");
|
mqttCustomerClient.pushlish(2, false, sd.getServerCode(), parameter);
|
log.info("心跳♥采集状态发送成功! 服务器编号:" + sd.getServerCode() + " 时间:" + DateUtils.getTimestamp());
|
}
|
});
|
}
|
|
// 查询虚设备下参数存在oporation的虚设备列表
|
List<ServerDeploy> serverDeploy = serverDeployService.list();
|
// 查询是否存在设备状态
|
|
}
|
}
|
