Browse Source

打通job定时发送工作报告

fuyuchuan 7 months ago
parent
commit
85c217e5f9

+ 2 - 0
service-iot/service-iot-biz/src/main/java/com/usky/iot/service/impl/PmWorkReportServiceImpl.java

@@ -595,6 +595,8 @@ public class PmWorkReportServiceImpl extends AbstractCrudService<PmWorkReportMap
                 report.setReportStatus(1);
                 pmWorkReportMapper.updateById(report);
             }
+        } else {
+            log.info("当前没有定时工作报告可发送");
         }
         log.info("定时报告任务结束---------------------------");
     }

+ 6 - 0
service-job/pom.xml

@@ -57,6 +57,12 @@
             <groupId>com.usky</groupId>
             <artifactId>ruoyi-common-swagger</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.usky</groupId>
+            <artifactId>service-iot-api</artifactId>
+            <version>0.0.1</version>
+            <scope>compile</scope>
+        </dependency>
 
     </dependencies>
 

+ 17 - 12
service-job/src/main/java/com/ruoyi/job/task/RyTask.java

@@ -1,39 +1,44 @@
 package com.ruoyi.job.task;
 
-import com.usky.common.core.utils.SpringUtils;
+import com.usky.common.core.utils.StringUtils;
 import com.usky.fire.RemoteFireService;
+import com.usky.iot.RemotePmService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
-import com.usky.common.core.utils.StringUtils;
 
 /**
  * 定时任务调度测试
- * 
+ *
  * @author ruoyi
  */
 @Component("ryTask")
-public class RyTask
-{
+public class RyTask {
     @Autowired
     private RemoteFireService remoteFireService;
 
-    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
-    {
+    @Autowired
+    private RemotePmService remotePmService;
+
+    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
         System.out.println(StringUtils.format("执行多参方法: 字符串类型{},布尔类型{},长整型{},浮点型{},整形{}", s, b, l, d, i));
     }
 
-    public void ryParams(String params)
-    {
+    public void ryParams(String params) {
         System.out.println("执行有参方法:" + params);
     }
 
-    public void ryNoParams()
-    {
+    public void ryNoParams() {
         System.out.println("执行无参方法");
     }
 
-    public void addPatrolInspectionAbnormalData(){
+    public void addPatrolInspectionAbnormalData() {
         remoteFireService.addPatrolInspectionAbnormalData();
         System.out.println("addPatrolInspectionAbnormalData");
     }
+
+    public void executeTimedSending() {
+        System.out.println("executeTimedSending start........");
+        remotePmService.executeTimedSending();
+    }
+
 }