Przeglądaj źródła

增加履职任务生成的定时任务

jiawuxian 2 lat temu
rodzic
commit
172625e769

+ 45 - 0
soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteResumptionTaskService.java

@@ -0,0 +1,45 @@
+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 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 = "remoteResumptionTaskService", value = ServiceNameConstants.CORE_SERVICE, fallbackFactory = RemoteResumptionTaskFallbackFactory.class)
+public interface RemoteResumptionTaskService {
+
+    /**
+     * 生成每日履职任务
+     *
+     * @return
+     */
+    @GetMapping(value = "resumption/task/dayTask")
+    R<Boolean> dayTask();
+
+    /**
+     * 生成每周履职任务
+     *
+     * @return
+     */
+    @GetMapping(value = "resumption/task/weekTask")
+    R<Boolean> weekTask();
+
+    /**
+     * 生成每月、季、半年、年履职任务
+     *
+     * @return
+     */
+    @GetMapping(value = "resumption/task/monthTask")
+    R<Boolean> monthTask();
+}

+ 58 - 0
soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteResumptionTaskFallbackFactory.java

@@ -0,0 +1,58 @@
+package com.xunmei.system.api.factory;
+
+import com.xunmei.common.core.domain.R;
+import com.xunmei.common.core.web.domain.AjaxResult;
+import com.xunmei.system.api.RemoteEduTrainingService;
+import com.xunmei.system.api.RemoteOrgService;
+import com.xunmei.system.api.RemoteResumptionTaskService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.openfeign.FallbackFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
+
+/**
+ * 字典服务降级处理
+ *
+ * @author xunmei
+ */
+@Component
+public class RemoteResumptionTaskFallbackFactory implements FallbackFactory<RemoteResumptionTaskService> {
+    private static final Logger log = LoggerFactory.getLogger(RemoteResumptionTaskFallbackFactory.class);
+
+    @Override
+    public RemoteResumptionTaskService create(Throwable throwable) {
+        return new RemoteResumptionTaskService() {
+            /**
+             * 生成每日履职任务
+             *
+             * @return
+             */
+            @Override
+            public R<Boolean> dayTask() {
+                return null;
+            }
+
+            /**
+             * 生成每周履职任务
+             *
+             * @return
+             */
+            @Override
+            public R<Boolean> weekTask() {
+                return null;
+            }
+
+            /**
+             * 生成每月、季、半年、年履职任务
+             *
+             * @return
+             */
+            @Override
+            public R<Boolean> monthTask() {
+                return null;
+            }
+        };
+    }
+
+}

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

@@ -9,3 +9,4 @@ com.xunmei.system.api.factory.RemoteTaskFallbackFactory
 com.xunmei.system.api.factory.RemoteDictDataFallbackFactory
 com.xunmei.system.api.factory.RemoteRetrievalTaskFallbackFactory
 com.xunmei.system.api.factory.RemoteEduTrainingFallbackFactory
+com.xunmei.system.api.factory.RemoteResumptionTaskFallbackFactory

+ 1 - 1
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/controller/TaskController.java

@@ -34,7 +34,7 @@ import java.util.stream.Collectors;
  * @author LuoJun
  */
 @RestController
-@RequestMapping("/task")
+@RequestMapping("resumption/task")
 public class TaskController {
     @Autowired
     ResumptionTaskBusiness taskBusiness;

+ 39 - 0
soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/CoreResumptionTask.java

@@ -0,0 +1,39 @@
+package com.xunmei.job.task;
+
+import cn.hutool.core.lang.UUID;
+import com.alibaba.fastjson2.JSON;
+import com.xunmei.common.core.domain.R;
+import com.xunmei.common.core.web.domain.AjaxResult;
+import com.xunmei.system.api.RemoteEduTrainingService;
+import com.xunmei.system.api.RemoteResumptionTaskService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+@Slf4j
+@Component("CoreResumptionTask")
+public class CoreResumptionTask {
+
+    @Autowired
+    RemoteResumptionTaskService remoteResumptionTaskService;
+
+    public void buildDayTask() {
+        log.info("开始执行每日履职定时任务,当前任务 当前时间:{}", new Date());
+        R<Boolean> result = remoteResumptionTaskService.dayTask();
+        log.info("执行每日履职定时任务结束....,当前任务 当前时间:{},结果:{}", new Date(), JSON.toJSONString(result));
+    }
+
+    public void buildWeekTask() {
+        log.info("开始执行每周履职定时任务,当前任务 时间:{}",new Date());
+        R<Boolean> result = remoteResumptionTaskService.weekTask();
+        log.info("执行教育培训定时任务结束,当前任务 时间:{},结果:{}", new Date(), JSON.toJSONString(result));
+    }
+
+    public void buildMonthTask() {
+        log.info("开始执行每周履职定时任务,当前任务 时间:{}",new Date());
+        R<Boolean> result = remoteResumptionTaskService.monthTask();
+        log.info("执行教育培训定时任务结束,当前任务 时间:{},结果:{}", new Date(), JSON.toJSONString(result));
+    }
+}