From 56c67cc89f10feaf6b35e09c69fcf62acb9c88bb Mon Sep 17 00:00:00 2001
From: sunxiqing <2240398334@qq.com>
Date: Fri, 8 Aug 2025 16:52:11 +0800
Subject: [PATCH] =?UTF-8?q?refactor(llm):=20=E8=B0=83=E6=95=B4=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E9=9B=86=E5=90=8C=E6=AD=A5=E4=BB=BB=E5=8A=A1=E6=89=A7?=
 =?UTF-8?q?=E8=A1=8C=E5=91=A8=E6=9C=9F=E5=B9=B6=E4=BC=98=E5=8C=96=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E8=BE=93=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将数据集同步任务的执行周期从每 20 秒调整为每 60 秒
- 在同步任务开始时增加数据集数量的日志输出，以便更好地监控任务处理情况
---
 .../module/llm/service/dataset/DatasetTaskSyncService.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/dataset/DatasetTaskSyncService.java b/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/dataset/DatasetTaskSyncService.java
index 25132740f..28c065f0c 100644
--- a/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/dataset/DatasetTaskSyncService.java
+++ b/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/service/dataset/DatasetTaskSyncService.java
@@ -23,7 +23,7 @@ public class DatasetTaskSyncService {
     @Resource
     private AsyncDataSetService dataSetService;
 
-    @Scheduled(cron ="0/20 * * * * ?")
+    @Scheduled(cron ="0/60 * * * * ?")
     public void syncDatasetAigcTask() {
         log.info("[syncDatasetAigcTask][开始同步任务]");
         // 查询已经标注完成的数据集
@@ -32,6 +32,7 @@ public class DatasetTaskSyncService {
                 .and(w->w.isNull(DatasetDO::getJobId)
                         .or().eq(DatasetDO::getJobId, ""));
         List<DatasetDO> datasetList = datasetMapper.selectList(wrapper);
+        log.info("[syncDatasetAigcTask][开始同步任务，数据集数量：{}]", datasetList.size());
         datasetList.forEach(datasetDO -> {
             List<DatasetQuestionRespVO> datasetQuestionList = datasetQuestionService.getDatasetQuestionList(datasetDO.getId());
             dataSetService.JsonFileWrite(datasetDO,datasetQuestionList);