上传：异步调用 通知

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);
     }

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;