增加一个四合一规则刷新

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");
     }
 
+
+
 }
 

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();
+    }
+}

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();
 }