税务预检使用情况

core/src/main/java/com/kakarote/core/feign/crm/service/CrmUserAnalyseService.java

@@ -0,0 +1,18 @@
+package com.kakarote.core.feign.crm.service;
+
+
+import com.kakarote.core.common.Result;
+import com.kakarote.core.feign.crm.service.impl.CrmServiceImpl;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+
+import java.time.LocalDate;
+
+@FeignClient(name = "crm" , contextId = "UserAnalyse")
+public interface CrmUserAnalyseService {
+
+    @PostMapping("/crmGetV3Data/getTaxPreCheckUsage")
+    Result getTaxPreCheckUsage();
+}

job/src/main/java/com/kakarote/job/crm/CrmTaxPreCheckUsageJob.java

@@ -0,0 +1,35 @@
+package com.kakarote.job.crm;
+
+import com.kakarote.core.common.Result;
+import com.kakarote.core.feign.crm.service.CrmUserAnalyseService;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 定时通过日期获取使用用户数，活跃用户数，新增企业数，注册用户数。
+ */
+@Component
+@Slf4j
+public class CrmTaxPreCheckUsageJob {
+
+    @Autowired
+    private CrmUserAnalyseService crmUserAnalyseService;
+
+    @XxlJob("CrmTaxPreCheckUsageJob")
+    ReturnT<String> crmTaxPreCheckUsageJobHandler(String param){
+
+        Result result = crmUserAnalyseService.getTaxPreCheckUsage();
+
+        if (!result.hasSuccess()) {
+            ReturnT<String> fail = ReturnT.FAIL;
+            fail.setMsg(result.getMsg());
+            return fail;
+        }
+
+        return ReturnT.SUCCESS;
+    }
+
+}