From c1e44856e910210799c6a87121e114d160723e18 Mon Sep 17 00:00:00 2001 From: zren25 Date: Mon, 24 Mar 2025 16:21:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=81=E5=BE=AE=E8=AF=AD=E6=96=99=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/job/QiWeiCorpusJob.java | 13 +++++++------ .../mapper/TmOdsVdqwMessagearchivingMapper.xml | 8 ++++---- 2 files changed, 11 insertions(+), 10 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java index 5fc6187..33f20b4 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java +++ b/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); diff --git a/ai-analytic-center-biz/src/main/resources/mapper/TmOdsVdqwMessagearchivingMapper.xml b/ai-analytic-center-biz/src/main/resources/mapper/TmOdsVdqwMessagearchivingMapper.xml index ea9ad8a..391cda3 100644 --- a/ai-analytic-center-biz/src/main/resources/mapper/TmOdsVdqwMessagearchivingMapper.xml +++ b/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, - tovm.accept_user_id + LEAST(tovm.from_user_id, tovm.accept_user_id), + GREATEST(tovm.from_user_id, tovm.accept_user_id); ) tab @@ -33,8 +33,8 @@ AND tovm.msg_time between #{statTime} and #{endTime} AND tovm.chat_type = 0 GROUP BY - tovm.from_user_id, - tovm.accept_user_id + LEAST(tovm.from_user_id, tovm.accept_user_id), + GREATEST(tovm.from_user_id, tovm.accept_user_id); LIMIT #{offset}, #{pageSize}