From c4948017824b1efa71faeb163e3609bec91f5719 Mon Sep 17 00:00:00 2001
From: cuikaidong <ckd2942379034@163.com>
Date: 星期五, 15 八月 2025 10:02:00 +0800
Subject: [PATCH] MDC，IOT合并
---
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleJob.java | 41 ++++++++++++++++++++++++++++++++++++++---
1 files changed, 38 insertions(+), 3 deletions(-)
diff --git a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleJob.java b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleJob.java
index db37777..b51176e 100644
--- a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleJob.java
+++ b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/quartz/job/SampleJob.java
@@ -1,23 +1,58 @@
package org.jeecg.modules.quartz.job;
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 lombok.extern.slf4j.Slf4j;
+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 {
- log.info(" Job Execution key锛�"+jobExecutionContext.getJobDetail().getKey());
- log.info(String.format(" Jeecg-Boot 鏅�氬畾鏃朵换鍔� SampleJob ! 鏃堕棿:" + DateUtils.getTimestamp()));
+ 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();
+ // 鏌ヨ鏄惁瀛樺湪璁惧鐘舵��
+
}
}
--
Gitblit v1.9.3