Merge branch 'dev/dev_xp' into dev/3.1_release_merge

src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java

@@ -294,6 +294,8 @@ public class GenerateConsumer {
                 exceptionInfo.put(generateResult.get("tasks_id"), generateResult.get("message"));
                 // 存redis
                 redisUtil.addToMap(exceptionMapKey, exceptionInfo);
+                // 记录失败状态并向用户发送提示消息
+                generateService.processPTFailSituation(generateResult.get("tasks_id"));
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -312,6 +314,8 @@ public class GenerateConsumer {
             exceptionInfo.put(String.valueOf(generateResult.get("tasks_id")), exceptionMessage);
             // 存redis
             redisUtil.addToMap(exceptionMapKey, exceptionInfo);
+            // 记录失败状态并向用户发送提示消息
+            generateService.processPTFailSituation(generateResult.get("tasks_id"));
         }
 
         long end = System.currentTimeMillis();