admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

审核流程配置

Browse Source
This commit is contained in:
lxu75
2025-04-11 15:52:48 +08:00
parent 8e0c6c7e5b
commit 4749318ac2
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/ClaimVerificationConsumer.java
View File

@@ -10,8 +10,8 @@ import org.springframework.stereotype.Component;
@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer..group}",
topic = "${rocketmq.consumer.topic}",
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.claimVerification.group}",
topic = "${rocketmq.consumer.claimVerification.topic}",
enableMsgTrace = true)
public class ClaimVerificationConsumer implements RocketMQListener<MessageExt>{

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

@@ -49,9 +49,6 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
@Autowired
private DiFyService diFyService;
@Value("${dify.claimVerification.user}")
private String claimVerificationUser;
@Value("${dify.claimVerification.fileToken}")
private String fileToken;
@@ -160,6 +157,7 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType());
data.put("fileType", claimVerificationFileAnalysisDTO.getFileType());
data.put("fileData",difyToAfter);
data.put("aiAnalysisRequestId",aiAnalysisRequestId);
//返回结果推送到Newbie的MQ
rocketMQTemplate.syncSend(topic, data);
log.info("索赔检核文件分析发送回调MQ完成: {}", data);
@@ -206,9 +204,12 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
data.put("newBieAfterSalesId", claimVerificationFileAnalysisDTO.getNewBieAfterSalesId());
data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType());
data.put("warrantyAuditReport",audiResToAfter);
data.put("aiAnalysisRequestId",aiAnalysisRequestId);
//返回结果推送到Newbie的MQ
rocketMQTemplate.syncSend(topic, data);
log.info("索赔检核审计报告发送回调MQ完成: {}", data);
//异步更新请求日志表的difyResponse字段
syncUpdateDiFyResponse(diFyObject, aiAnalysisRequestId);
}
}else {
throw new RuntimeException("售后索赔检核业务类型错误");