From a4a8b52c8ce54e5964b787f065fe8e428e8f6538 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Thu, 27 Mar 2025 10:29:18 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java  | 2 +-
 .../service/impl/TmOdsVdqwMessagearchivingServiceImpl.java     | 3 ++-
 2 files changed, 3 insertions(+), 2 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 79adb7d..59fcee0 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
@@ -36,7 +36,7 @@ public class QiWeiCorpusJob {
     /**
      * 企微语料处理
      */
-    @XxlJob("QiWeiCorpusTask")
+    @XxlJob("qiWeiCorpusTask")
     public ResultMsg qiWeiCorpusTask(@RequestBody String paramJson) {
         try {
             // 获取任务参数
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java
index 7052c99..a60feb1 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java
@@ -92,6 +92,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
 
 	@Override
 	public void runQiWeiCorpusDify(String paramJson) {
+		long startTime = System.currentTimeMillis();
 		log.info("runQiWeiCorpusDify paramJson {}", paramJson);
 		// 获取当前日期
 		LocalDate today = LocalDate.now();
@@ -142,7 +143,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
 		}
 		// 关闭线程池
 		executor.shutdown();
-
+		log.info("企微数据跑批结束 耗时：{}",System.currentTimeMillis()-startTime);
 	}
 
 	private void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {