定时任务处理舆情异常

ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/entity/AiAnalysisErrors.java

@@ -18,6 +18,9 @@ public class AiAnalysisErrors extends BaseEntity {
     @TableField("ai_analysis_request_id")
     private String aiAnalysisRequestId;
 
+    @TableField("ai_analysis_request_type")
+    private String aiAnalysisRequestType;
+
     @TableField("dify_response")
     private String difyResponse; // JSON 字符串
 

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/MessageProcessJob.java

@@ -21,7 +21,7 @@ public class MessageProcessJob {
     public ResultMsg processMessageByTask() {
         try {
             log.info("communityMessageByTask 开始执行定时任务补偿处理消息");
-            mqMessageRecordService.processMessageByTask();
+            mqMessageRecordService.communityMessageByTask();
         } catch (Exception e) {
             log.error("communityMessageByTask 定时任务补偿处理消息异常",e.getMessage());
             throw new RuntimeException(e);

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/MqMessageRecordService.java

@@ -16,4 +16,9 @@ public interface MqMessageRecordService extends IService<MqMessageRecord> {
 
     //定时任务补偿处理消息
     void processMessageByTask();
+
+    //定时任务补偿处理消息
+    void communityMessageByTask();
 }
+
+

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java

@@ -4,6 +4,8 @@ import cn.hutool.core.date.DateUtil;
 import com.alibaba.cloud.commons.lang.StringUtils;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.volvo.ai.analytic.center.constant.Constant;
@@ -173,6 +175,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
                     .aiAnalysisRequestId(aiAnalysisRequestId)
                     .difyResponse(difResult.toJSONString())
                     .aiAnalysisErrorMessage(e.getMessage())
+                    .aiAnalysisRequestType(BusinessTypeEnum.COMMUNITYTARGET.getCode())
                     .build());
         }
         return true;
@@ -517,6 +520,20 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
         }
     }
 
+    /**
+     * 处理社区异常消息
+     */
+    @Override
+    public void communityMessageByTask() {
+
+        //捞取异常表中属于社区的异常数据
+        List<AiAnalysisErrors> aiAnalysisErrors = aiAnalysisErrorsMapper.selectList(new LambdaQueryWrapper<AiAnalysisErrors>()
+                .eq(AiAnalysisErrors::getAiAnalysisRequestType, BusinessTypeEnum.COMMUNITYTARGET.getCode())
+                .eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0")
+                .lt(AiAnalysisErrors::getRetryCount, 4));
+
+    }
+
     private String getUserStatus(String oldStr) {
         if (Objects.equals(MessageConvertEnum.CONFIRMED.getCode(), oldStr)) {
             return MessageConvertEnum.CONFIRMED.getMessage();