From d0cdc5eb71081341fd94b8095dc70954512d2d83 Mon Sep 17 00:00:00 2001
From: ZZM <1105966949@qq.com>
Date: Fri, 27 Jun 2025 17:28:38 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A8=8E=E5=8A=A1=E9=A2=84=E6=A3=80=E4=BD=BF?=
 =?UTF-8?q?=E7=94=A8=E6=83=85=E5=86=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../crm/service/CrmUserAnalyseService.java    | 18 ++++++++++
 .../job/crm/CrmTaxPreCheckUsageJob.java       | 35 +++++++++++++++++++
 2 files changed, 53 insertions(+)
 create mode 100644 core/src/main/java/com/kakarote/core/feign/crm/service/CrmUserAnalyseService.java
 create mode 100644 job/src/main/java/com/kakarote/job/crm/CrmTaxPreCheckUsageJob.java

diff --git a/core/src/main/java/com/kakarote/core/feign/crm/service/CrmUserAnalyseService.java b/core/src/main/java/com/kakarote/core/feign/crm/service/CrmUserAnalyseService.java
new file mode 100644
index 0000000..57f37c4
--- /dev/null
+++ b/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();
+}
diff --git a/job/src/main/java/com/kakarote/job/crm/CrmTaxPreCheckUsageJob.java b/job/src/main/java/com/kakarote/job/crm/CrmTaxPreCheckUsageJob.java
new file mode 100644
index 0000000..33f8efb
--- /dev/null
+++ b/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;
+    }
+
+}