定时任务

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteSafetyCheckService.java

@@ -0,0 +1,48 @@
+package com.xunmei.system.api;
+
+import com.xunmei.common.core.constant.ServiceNameConstants;
+import com.xunmei.common.core.domain.R;
+import com.xunmei.common.core.web.domain.AjaxResult;
+import com.xunmei.system.api.factory.RemoteEduTrainingFallbackFactory;
+import com.xunmei.system.api.factory.RemoteResumptionTaskFallbackFactory;
+import com.xunmei.system.api.factory.RemoteSafetyCheckTaskFallbackFactory;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.Date;
+
+/**
+ * 检查任务
+ *
+ * @author xunmei
+ */
+@FeignClient(contextId = "remoteSafetyCheckTaskService", value = ServiceNameConstants.CORE_SERVICE, fallbackFactory = RemoteSafetyCheckTaskFallbackFactory.class)
+public interface RemoteSafetyCheckService {
+
+    /**
+     * 生成每日检查任务
+     *
+     * @return
+     */
+    @GetMapping(value = "checkplan/DayTask")
+    R<Boolean> dayTask();
+
+    /**
+     * 生成每周履职任务
+     *
+     * @return
+     */
+    @GetMapping(value = "checkplan/WeekTask")
+    R<Boolean> weekTask();
+
+    /**
+     * 生成每月、季、半年、年履职任务
+     *
+     * @return
+     */
+    @GetMapping(value = "checkplan/MonthTask")
+    R<Boolean> monthTask();
+
+
+}

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteSafetyCheckTaskFallbackFactory.java

@@ -0,0 +1,28 @@
+package com.xunmei.system.api.factory;
+
+import com.xunmei.common.core.domain.R;
+import com.xunmei.system.api.RemoteRoleService;
+import com.xunmei.system.api.RemoteSafetyCheckService;
+import org.springframework.cloud.openfeign.FallbackFactory;
+
+public class RemoteSafetyCheckTaskFallbackFactory implements FallbackFactory<RemoteSafetyCheckService> {
+    @Override
+    public RemoteSafetyCheckService create(Throwable cause) {
+        return new RemoteSafetyCheckService() {
+            @Override
+            public R<Boolean> dayTask() {
+                return null;
+            }
+
+            @Override
+            public R<Boolean> weekTask() {
+                return null;
+            }
+
+            @Override
+            public R<Boolean> monthTask() {
+                return null;
+            }
+        };
+    }
+}

soc-api/soc-api-system/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -10,4 +10,5 @@ com.xunmei.system.api.factory.RemoteDictDataFallbackFactory
 com.xunmei.system.api.factory.RemoteRetrievalTaskFallbackFactory
 com.xunmei.system.api.factory.RemoteEduTrainingFallbackFactory
 com.xunmei.system.api.factory.RemoteResumptionTaskFallbackFactory
-com.xunmei.system.api.factory.RemoteWeatherFallbackFactory
+com.xunmei.system.api.factory.RemoteWeatherFallbackFactory
+com.xunmei.system.api.factory.RemoteSafetyCheckTaskFallbackFactory

soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/CoreSafetyCheckTask.java

@@ -0,0 +1,42 @@
+package com.xunmei.job.task;
+
+import com.alibaba.fastjson2.JSON;
+import com.xunmei.common.core.domain.R;
+import com.xunmei.system.api.RemoteResumptionTaskService;
+import com.xunmei.system.api.RemoteSafetyCheckService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+@Slf4j
+@Component("CoreSafetyCheckTask")
+public class CoreSafetyCheckTask {
+    @Autowired
+    RemoteSafetyCheckService checkService;
+
+    public void buildDayTask() {
+        log.info("开始执行每日检查定时任务,当前任务 当前时间:{}", new Date());
+        R<Boolean> result = checkService.dayTask();
+        log.info("执行每日检查定时任务结束....,当前任务 当前时间:{},结果:{}", new Date(), JSON.toJSONString(result));
+    }
+
+    public void buildWeekTask() {
+        log.info("开始执行每周检查定时任务，当前任务 时间：{}",new Date());
+        R<Boolean> result = checkService.weekTask();
+        log.info("执行每周检查定时任务结束，当前任务 时间：{}，结果：{}", new Date(), JSON.toJSONString(result));
+    }
+
+    public void buildMonthTask() {
+        log.info("开始执行每月检查定时任务，当前任务 时间：{}",new Date());
+        R<Boolean> result = checkService.monthTask();
+        log.info("执行执行每月检查定时任务结束，当前任务 时间：{}，结果：{}", new Date(), JSON.toJSONString(result));
+    }
+
+//    public void updateTaskStatus(){
+//        log.info("开始更新检查任务状态 时间：{}",new Date());
+//        R<Boolean> result = remoteResumptionTaskService.updateTaskStatus();
+//        log.info("更新检查任务状态结束，当前任务 时间：{}，结果：{}", new Date(), JSON.toJSONString(result));
+//    }
+}