企微语料查询调整

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java

@@ -2,17 +2,15 @@ package com.volvo.ai.analytic.center.job;
 
 import com.volvo.ai.analytic.center.service.TmOdsVdqwMessagearchivingService;
 import com.volvo.common.core.util.ResultMsg;
+import com.xxl.job.core.context.XxlJobHelper;
 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.PostMapping;
-import org.springframework.web.bind.annotation.RestController;
 
 
 @Slf4j
 @Component
-@RestController
 public class QiWeiCorpusJob {
 
     @Autowired
@@ -22,11 +20,14 @@ public class QiWeiCorpusJob {
      * 企微语料处理
      */
     @XxlJob("QiWeiCorpusTask")
-    @PostMapping("qiWeiCorpusTask")
     public ResultMsg qiWeiCorpusTask(String paramJson) {
         try {
-            log.info("qiWeiCorpusTask 企微语料查询处理:{}",paramJson);
+            // 获取任务参数
-            tmOdsVdqwMessagearchivingService.runQiWeiCorpusDify(paramJson);
+            String param = XxlJobHelper.getJobParam();
+            // 执行业务逻辑
+            XxlJobHelper.log("任务参数: {}", param);
+            log.info("qiWeiCorpusTask 企微语料查询处理:{}",param);
+            tmOdsVdqwMessagearchivingService.runQiWeiCorpusDify(param);
         } catch (Exception e) {
             log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage());
             throw new RuntimeException(e);

ai-analytic-center-biz/src/main/resources/mapper/TmOdsVdqwMessagearchivingMapper.xml

@@ -15,8 +15,8 @@
         AND tovm.msg_time between #{statTime} and #{endTime}
         AND tovm.chat_type = 0
         GROUP BY
-        tovm.from_user_id,
+            LEAST(tovm.from_user_id, tovm.accept_user_id),
-        tovm.accept_user_id
+            GREATEST(tovm.from_user_id, tovm.accept_user_id);
         ) tab
     </select>
 
@@ -33,8 +33,8 @@
         AND tovm.msg_time between #{statTime} and #{endTime}
         AND tovm.chat_type = 0
         GROUP BY
-        tovm.from_user_id,
+            LEAST(tovm.from_user_id, tovm.accept_user_id),
-        tovm.accept_user_id
+            GREATEST(tovm.from_user_id, tovm.accept_user_id);
         LIMIT #{offset}, #{pageSize}
     </select>