志愿者抽取定时任务

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/ic/IcVolunteerDataExtractionTask.java

@@ -0,0 +1,45 @@
+package com.epmet.task.ic;
+
+import com.alibaba.fastjson.JSON;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.extract.form.ExtractOriginFormDTO;
+import com.epmet.feign.EpmetUserOpenFeignClient;
+import com.epmet.task.ITask;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * @Description
+ * @Author zhaoqifeng
+ * @Date 2022/5/23 10:58
+ */
+@Slf4j
+@Component("icVolunteerDataExtractionTask")
+public class IcVolunteerDataExtractionTask implements ITask {
+
+    @Resource
+    private EpmetUserOpenFeignClient epmetUserOpenFeignClient;
+
+    /**
+     * 执行定时任务接口
+     *
+     * @param params 参数，多参数使用JSON数据
+     */
+    @Override
+    public void run(String params) {
+        log.info("icVolunteerDataExtractionTask定时任务正在执行，参数为：{}", params);
+        ExtractOriginFormDTO formDTO = new ExtractOriginFormDTO();
+        if (StringUtils.isNotBlank(params)) {
+            formDTO = JSON.parseObject(params, ExtractOriginFormDTO.class);
+        }
+        Result result = epmetUserOpenFeignClient.volunteerDataExtraction(formDTO.getCustomerId());
+        if (result.success()) {
+            log.info("icVolunteerDataExtractionTask定时任务正在执行定时任务执行成功");
+        } else {
+            log.warn("icVolunteerDataExtractionTask定时任务正在执行定时任务执行失败:" + result.getMsg());
+        }
+    }
+}

epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java

@@ -752,4 +752,7 @@ public interface EpmetUserOpenFeignClient {
 
     @PostMapping("/epmetuser/icresiuser/icPartyMemberSync")
     Result<com.epmet.resi.partymember.dto.partymember.IcPartyMemberDTO> icPartyMemberSync(@RequestBody IcPartyMemberDTO formDTO);
+
+    @PostMapping("/epmetuser/icVolunteerPoly/volunteerDataExtraction/{customerId}")
+    Result volunteerDataExtraction(@PathVariable("customerId") String customerId);
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/feign/fallback/EpmetUserOpenFeignClientFallback.java

@@ -554,4 +554,9 @@ public class EpmetUserOpenFeignClientFallback implements EpmetUserOpenFeignClien
         return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "icPartyMemberSync", formDTO);
     }
 
+    @Override
+    public Result volunteerDataExtraction(String customerId) {
+        return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "volunteerDataExtraction", customerId);
+    }
+
 }