From b25ea618ee8d25d49d0589b7071d6b5d1ba53065 Mon Sep 17 00:00:00 2001
From: ZZM <1105966949@qq.com>
Date: Tue, 29 Jul 2025 15:59:51 +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(=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../crm/service/CrmUserAnalyseService.java    | 13 ++++++++
 .../impl/CrmUserAnalyseServiceImpl.java       | 25 +++++++++++----
 .../job/crm/CrmTaxPreCheckUsageJob.java       | 32 +++++++++++++++++++
 3 files changed, 64 insertions(+), 6 deletions(-)
 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..c4432eb
--- /dev/null
+++ b/core/src/main/java/com/kakarote/core/feign/crm/service/CrmUserAnalyseService.java
@@ -0,0 +1,13 @@
+package com.kakarote.core.feign.crm.service;
+
+import com.kakarote.core.common.Result;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@FeignClient(name = "crm" , contextId = "UserAnalyse")
+public interface CrmUserAnalyseService {
+
+    @PostMapping("/crmGetV3Data/getTaxPreCheckUsage")
+    Result getTaxPreCheckUsage();
+
+}
diff --git a/crm/src/main/java/com/kakarote/crm/service/impl/CrmUserAnalyseServiceImpl.java b/crm/src/main/java/com/kakarote/crm/service/impl/CrmUserAnalyseServiceImpl.java
index d13a2ad..bbfdcf0 100644
--- a/crm/src/main/java/com/kakarote/crm/service/impl/CrmUserAnalyseServiceImpl.java
+++ b/crm/src/main/java/com/kakarote/crm/service/impl/CrmUserAnalyseServiceImpl.java
@@ -3,6 +3,7 @@ package com.kakarote.crm.service.impl;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.google.gson.Gson;
+import com.google.gson.JsonParseException;
 import com.kakarote.core.feign.crm.entity.BiParams;
 import com.kakarote.core.servlet.BaseServiceImpl;
 import com.kakarote.crm.entity.DTO.CrmTaxPreCheckUsageDTO;
@@ -33,26 +34,38 @@ public class CrmUserAnalyseServiceImpl extends BaseServiceImpl<CrmUserAnalyseMap
     @Value("${app.base_url}")
     private String BASE_URL;
 
+    private String getUrl() {
+        return BASE_URL;
+    }
+
     @Override
     public int addUserAnalyse() throws IOException {
 
-        //测试数据
-        //LocalDate today = LocalDate.of(2023, 9, 28);
+        // 每天凌晨一点把昨天的数据存入数据库中
 
-        //获取当天凌晨1点的日期
+        // 获取当天凌晨1点的日期
         LocalDate today = LocalDate.now();
 
-        //再获取昨天的日期
+        // 再获取昨天的日期
         LocalDate queryDate = today.minusDays(1);
 
-        CrmUserAnalyse userAnalyse = getCrmUserAnalyse(queryDate);
+        LocalDate date = LocalDate.of(2025, 6, 4);
+
+        CrmUserAnalyse userAnalyse = getCrmUserAnalyse(date);
 
         return crmUserAnalyseMapper.insert(userAnalyse);
     }
 
     public CrmUserAnalyse getCrmUserAnalyse(LocalDate queryDate) throws IOException {
 
-        String json = OkHttpClientUtil.get(BASE_URL, queryDate);
+        String url = getUrl();
+
+        String json = OkHttpClientUtil.get(url, queryDate);
+
+        //  检查是否是有效的JSON对象
+        if (json == null || json.trim().isEmpty()) {
+            throw new JsonParseException("响应内容为空");
+        }
 
         Gson gson = new Gson();
         CrmTaxPreCheckUsageVO vo = gson.fromJson(json, CrmTaxPreCheckUsageVO.class);
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..94e169e
--- /dev/null
+++ b/job/src/main/java/com/kakarote/job/crm/CrmTaxPreCheckUsageJob.java
@@ -0,0 +1,32 @@
+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;
+    }
+}