zwhui 2 년 전
부모
커밋
9a4a329fcc
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      netflix-service/src/main/java/com/cyksj/service/midjourney/impl/MidjourneyServiceImpl.java

+ 2 - 2
netflix-service/src/main/java/com/cyksj/service/midjourney/impl/MidjourneyServiceImpl.java

@@ -50,7 +50,7 @@ public class MidjourneyServiceImpl implements MidjourneyService {
 
     private static final List<String> progress = List.of("100%");
 
-    private static final List<String> status = List.of("MODAL","CANCEL");
+    private static final List<String> status = List.of("MODAL","CANCEL","FAILURE");
 
     private static final GlobalThreadPoolTaskExecutor TASK_EXECUTOR = GlobalThreadPoolTaskExecutor.getInstance();
 
@@ -198,7 +198,7 @@ public class MidjourneyServiceImpl implements MidjourneyService {
 
 
     public void sync(MidjourneyUserConversation conversation) throws IOException {
-        if ((StringUtils.isNotBlank(conversation.getProgress()) && progress.contains(conversation.getProgress())) || status.contains(conversation.getStatus())) {
+        if (progress.contains(conversation.getProgress()) || status.contains(conversation.getStatus())) {
             log.info("同步任务:{},进度:{}",conversation.getTaskId(),conversation.getProgress());
             MidjourneyUserConversation dbConversation = conversationMapper.selectOne(Wrappers.lambdaQuery(MidjourneyUserConversation.class).eq(MidjourneyUserConversation::getTaskId, conversation.getTaskId())
                     .eq(MidjourneyUserConversation::getUserId, conversation.getUserId()).last("limit 1"));