保存审核记录

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

@@ -0,0 +1,70 @@
+package com.volvo.ai.analytic.center.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("tt_ai_analytic_warranty_audit")
+public class AiAnalyticWarrantyAudit {
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 配置版本
+     */
+    @TableField(value = "audit_count")
+    private Integer auditCount;
+
+    @TableField(value = "new_bie_after_sales_id")
+    private String newBieAfterSalesId;
+    /**
+     * 删除标识（0-未删除，1-已删除）
+     */
+    @TableField(value = "is_deleted")
+    private Integer isDeleted;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 创建人
+     */
+    @TableField(value = "create_by")
+    private String createBy;
+
+    /**
+     * 更新人
+     */
+    @TableField(value = "update_by")
+    private String updateBy;
+
+    /**
+     * 乐观锁
+     */
+    @TableField(value = "versions")
+    private Integer versions;
+}

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mapper/AiAnalyticWarrantyAuditMapper.java

@@ -0,0 +1,9 @@
+package com.volvo.ai.analytic.center.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.volvo.ai.analytic.center.entity.AiAnalyticWarrantyAudit;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface AiAnalyticWarrantyAuditMapper  extends BaseMapper<AiAnalyticWarrantyAudit> {
+}

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

@@ -13,9 +13,11 @@ import com.volvo.ai.analytic.center.dto.req.DiFyReq;
 import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput;
 import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
 import com.volvo.ai.analytic.center.entity.AiAnalyticBusinessConfig;
+import com.volvo.ai.analytic.center.entity.AiAnalyticWarrantyAudit;
 import com.volvo.ai.analytic.center.entity.DataMaskingRule;
 import com.volvo.ai.analytic.center.enums.BusinessTypeEnum;
 import com.volvo.ai.analytic.center.enums.ClaimVerificationFileTypeEnums;
+import com.volvo.ai.analytic.center.mapper.AiAnalyticWarrantyAuditMapper;
 import com.volvo.ai.analytic.center.service.DataMaskingRuleService;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.text.StringEscapeUtils;
@@ -71,6 +73,9 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
 
     @Autowired
     private DataMaskingRuleService dataMaskingRuleService;
+
+    @Autowired
+    private AiAnalyticWarrantyAuditMapper aiAnalyticWarrantyAuditMapper;
     @Override
     public void consumerMessageByMQ(String message) {
         log.info("售后索赔检核MQ message: {}", message);
@@ -228,12 +233,35 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
                 log.info("索赔检核审计报告发送回调MQ完成: {}", data);
                 //异步更新请求日志表的difyResponse字段
                 syncUpdateDiFyResponse(diFyObject, aiAnalysisRequestId);
+                //审核次数记录
+                saveAuditCount(claimVerificationFileAnalysisDTO);
             }
         }else {
             throw new RuntimeException("售后索赔检核业务类型错误");
         }
     }
 
+    //异步保存审核次数
+    @Async
+    protected void saveAuditCount(ClaimVerificationFileDTO claimVerificationFileAnalysisDTO) {
+        AiAnalyticWarrantyAudit warrantyAudit = aiAnalyticWarrantyAuditMapper.selectOne(
+                Wrappers.<AiAnalyticWarrantyAudit>lambdaQuery()
+                        .eq(AiAnalyticWarrantyAudit::getNewBieAfterSalesId, claimVerificationFileAnalysisDTO.getNewBieAfterSalesId())
+                        .eq(AiAnalyticWarrantyAudit::getIsDeleted, 0)
+        );
+        if (warrantyAudit != null) {
+            //存在则auditCount+1
+            warrantyAudit.setAuditCount(warrantyAudit.getAuditCount() + 1);
+            aiAnalyticWarrantyAuditMapper.updateById(warrantyAudit);
+        } else {
+            //不存在则新增一条记录
+            AiAnalyticWarrantyAudit warrantyAuditNew = new AiAnalyticWarrantyAudit();
+            warrantyAuditNew.setNewBieAfterSalesId(claimVerificationFileAnalysisDTO.getNewBieAfterSalesId());
+            warrantyAuditNew.setAuditCount(1);
+            aiAnalyticWarrantyAuditMapper.insert(warrantyAuditNew);
+        }
+    }
+
     private void uploadFileToObs(List<String> fileObsPath, List<HashMap<String, String>> fileIds) {
         if(fileObsPath != null && fileObsPath.size() > 0){
             for (String filePath : fileObsPath) {