From 58a6b4c4129e17057436b3e73a2cb3ddef0ba99d Mon Sep 17 00:00:00 2001
From: yq183 <645046984@qq.com>
Date: Tue, 1 Apr 2025 15:04:21 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=EF=BC=9A=E5=BC=82=E6=AD=A5?=
 =?UTF-8?q?=E8=B0=83=E7=94=A8=20=20=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sample/media/service/impl/MediaServiceImpl.java        | 7 +++++--
 .../wayline/service/impl/AiCompareQueueServiceImpl.java    | 2 ++
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/media/service/impl/MediaServiceImpl.java b/dk-modules/sample/src/main/java/org/dromara/sample/media/service/impl/MediaServiceImpl.java
index 2b25936..d2f3bc2 100644
--- a/dk-modules/sample/src/main/java/org/dromara/sample/media/service/impl/MediaServiceImpl.java
+++ b/dk-modules/sample/src/main/java/org/dromara/sample/media/service/impl/MediaServiceImpl.java
@@ -15,6 +15,7 @@ import org.dromara.sample.media.model.MediaFileDTO;
 import org.dromara.sample.media.service.IFileService;
 import org.dromara.sample.media.service.IMediaRedisService;
 import org.dromara.sample.media.service.IMediaService;
+import org.dromara.sample.wayline.service.IAiCompareQueueService;
 import org.dromara.sample.wayline.service.IWaylineJobService;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.extern.slf4j.Slf4j;
@@ -50,7 +51,8 @@ public class MediaServiceImpl extends AbstractMediaService implements IMediaServ
     @Autowired
     private IDeviceService deviceService;
 
-
+    @Autowired
+    private IAiCompareQueueService aiCompareQueueService;
     @Autowired
     private IDeviceRedisService deviceRedisService;
 
@@ -185,7 +187,8 @@ public class MediaServiceImpl extends AbstractMediaService implements IMediaServ
         } else {
             mediaRedisService.setMediaCount(request.getGateway(), jobId, mediaFileCount);
         }
-
+        //11
+        aiCompareQueueService.addWaylineJobToQueue(jobId);
         webSocketMessageService.sendBatch(dock.getWorkspaceId(), UserTypeEnum.WEB.getVal(),
                 BizCodeEnum.FILE_UPLOAD_CALLBACK.getCode(), mediaFileCount);
     }
diff --git a/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/AiCompareQueueServiceImpl.java b/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/AiCompareQueueServiceImpl.java
index c1286ec..db23fc6 100644
--- a/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/AiCompareQueueServiceImpl.java
+++ b/dk-modules/sample/src/main/java/org/dromara/sample/wayline/service/impl/AiCompareQueueServiceImpl.java
@@ -29,6 +29,7 @@ import org.dromara.sample.wayline.model.entity.AiCompareEntity;
 import org.dromara.sample.wayline.model.entity.AiCompareQueueEntity;
 import org.dromara.sample.wayline.model.entity.WaylineJobEntity;
 import org.dromara.sample.wayline.service.IAiCompareQueueService;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -92,6 +93,7 @@ public class AiCompareQueueServiceImpl implements IAiCompareQueueService {
         return aiCompareQueueMapper.updateStatus(ids,queueType);
     }
 
+    @Async
     @Override
     public Boolean addWaylineJobToQueue(String jobId) {
         boolean flag = false;