tj

microservice-admin/src/main/java/com/devplatform/admin/modules/eq/bean/SimpleJob.java → microservice-admin/src/main/java/com/devplatform/admin/common/scheduling/SimpleJob.java

-package com.devplatform.admin.modules.eq.bean;
+package com.devplatform.admin.common.scheduling;
 
-import org.quartz.Job;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.quartz.JobKey;
+import org.quartz.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -17,7 +14,16 @@ public class SimpleJob implements Job {
     private static Logger LOG = LoggerFactory.getLogger(SimpleJob.class);
     @Override
     public void execute(JobExecutionContext context) throws JobExecutionException {
-        JobKey jobKey = context.getJobDetail().getKey();  //jobKey长这样：group1.job6
+        JobKey jobKey = context.getJobDetail().getKey();
         LOG.info("执行任务。SimpleJob says: " + jobKey + " executing at " + new Date());
+
+        JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
+        Integer type = (Integer) jobDataMap.get("type");
+        //type=1 开启设备
+        if(type == 1){
+
+        }else{
+            //否则关闭设备
+        }
     }
 }

microservice-admin/src/main/java/com/devplatform/admin/modules/eq/controller/EquipmentController.java

@@ -3,7 +3,7 @@ package com.devplatform.admin.modules.eq.controller;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.devplatform.admin.common.utils.AbstractController;
 import com.devplatform.admin.common.utils.Constants;
-import com.devplatform.admin.modules.eq.bean.SimpleJob;
+import com.devplatform.admin.common.scheduling.SimpleJob;
 import com.devplatform.admin.modules.eq.bean.TimedTask;
 import com.devplatform.admin.modules.eq.service.EquipmentService;
 import com.devplatform.admin.modules.eq.service.TimedTaskService;
@@ -89,6 +89,14 @@ public class EquipmentController extends AbstractController {
 		temp.setEndTime(time);
 		temp.setUpdateTime(time);
 		sysSystemRunningTimeService.save(temp);
+
+		//如果切换成节能模式，则关闭定时任务
+		if(type == Constants.INT_2){
+			TimedTask timedTask = timedTaskService.getOne(new LambdaQueryWrapper<TimedTask>().last("limit 1"));
+			if(timedTask != null){
+				this.timedTask(timedTask.getId(),timedTask.getStartTime(),timedTask.getEndTime(),Constants.INT_2,"");
+			}
+		}
 		return R.ok();
 	}