From f8fb7378e70cbda040d3b43d82cf00ddefdf1cf0 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Wed, 2 Apr 2025 18:48:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=B8=80=E4=B8=AA=E5=9B=9B?=
 =?UTF-8?q?=E5=90=88=E4=B8=80=E8=A7=84=E5=88=99=E5=88=B7=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/controller/TestController.java     |  6 +++-
 .../ai/analytic/center/job/CommonsJob.java    | 30 +++++++++++++++++++
 .../service/IntelligentCustomerService.java   |  8 +++--
 3 files changed, 40 insertions(+), 4 deletions(-)
 create mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CommonsJob.java

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
index c558670..34c6021 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java
@@ -1,6 +1,7 @@
 package com.volvo.ai.analytic.center.controller;
 
 
+import com.alibaba.fastjson.JSONObject;
 import com.volvo.common.core.util.ResultMsg;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -29,9 +30,12 @@ public class TestController {
     @PostMapping("/mockMq")
     @ApiOperation(value = "补偿处理消息")
     public ResultMsg<Object> mockMq(@RequestBody String message) {
-        rocketMQTemplate.syncSend("COMMUNITY_POST_TO_AI_TOPIC", message);
+        JSONObject messageJson = JSONObject.parseObject(message);
+        rocketMQTemplate.syncSend(messageJson.getString("topic"), messageJson.getString("message"));
         return ResultMsg.ok("ok");
     }
 
+
+
 }
 
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CommonsJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CommonsJob.java
new file mode 100644
index 0000000..9549d02
--- /dev/null
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CommonsJob.java
@@ -0,0 +1,30 @@
+package com.volvo.ai.analytic.center.job;
+
+import com.volvo.ai.analytic.center.service.IntelligentCustomerService;
+import com.volvo.common.core.util.ResultMsg;
+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;
+import org.springframework.web.bind.annotation.RestController;
+
+
+@Slf4j
+@Component
+@RestController
+public class CommonsJob {
+
+    @Autowired
+    private IntelligentCustomerService intelligentCustomerService;
+
+
+
+    /**
+     * 企微语料处理
+     */
+    @XxlJob("reflushTcIntelligentCustomer")
+    public ResultMsg reflushTcIntelligentCustomer() {
+        intelligentCustomerService.queryTcIntelligentCustomer();
+        return ResultMsg.ok();
+    }
+}
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/IntelligentCustomerService.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/IntelligentCustomerService.java
index 81791a2..c226cb7 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/IntelligentCustomerService.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/IntelligentCustomerService.java
@@ -1,9 +1,9 @@
 package com.volvo.ai.analytic.center.service;
 
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.volvo.ai.analytic.center.dto.corpus.AicorpusTelephoneDTO;
 import com.volvo.ai.analytic.center.dto.req.FourInOneRequestDTO;
-import com.volvo.ai.analytic.center.entity.TmTelephoneCorpus;
+
+import java.util.List;
+import java.util.Map;
 
 /**
  * @description 电话语料表-同步表
@@ -17,4 +17,6 @@ public interface IntelligentCustomerService{
 
 
 	void sendMq( String message);
+
+	Map<String, List<String>> queryTcIntelligentCustomer();
 }
\ No newline at end of file