增加备注
This commit is contained in:
@@ -46,6 +46,7 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
|
|||||||
if(StringUtils.isEmpty(aiAnalysisRequestType) ){
|
if(StringUtils.isEmpty(aiAnalysisRequestType) ){
|
||||||
aiAnalysisRequestType= analysisRecordId.substring(0,analysisRecordId.indexOf("-"));
|
aiAnalysisRequestType= analysisRecordId.substring(0,analysisRecordId.indexOf("-"));
|
||||||
}
|
}
|
||||||
|
// "isLike": "1" // 1:点赞,2:点踩
|
||||||
tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder()
|
tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder()
|
||||||
.aiAnalysisRequestId(execDifyFlow.getString("analysisRecordId"))
|
.aiAnalysisRequestId(execDifyFlow.getString("analysisRecordId"))
|
||||||
.analysisResult(execDifyFlow.toJSONString())
|
.analysisResult(execDifyFlow.toJSONString())
|
||||||
|
|||||||
@@ -104,8 +104,6 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
|
|||||||
log.info("runDify execDifyFlow {}",execDifyFlow);
|
log.info("runDify execDifyFlow {}",execDifyFlow);
|
||||||
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
|
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
|
||||||
|
|
||||||
String aiAnalysisRequestId = null;
|
|
||||||
String message = null;
|
|
||||||
try {
|
try {
|
||||||
JSONObject outputsJson = execDifyFlow.getJSONObject("outputs");
|
JSONObject outputsJson = execDifyFlow.getJSONObject("outputs");
|
||||||
// 咨询
|
// 咨询
|
||||||
@@ -127,13 +125,13 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
|
|||||||
complainDTO.setContactName(consultDTO.getContactName());
|
complainDTO.setContactName(consultDTO.getContactName());
|
||||||
complainDTO.setContactTelephone(consultDTO.getContactTelephone());
|
complainDTO.setContactTelephone(consultDTO.getContactTelephone());
|
||||||
FourInOneResponseDTO fourInOneResponseDTO = new FourInOneResponseDTO();
|
FourInOneResponseDTO fourInOneResponseDTO = new FourInOneResponseDTO();
|
||||||
aiAnalysisRequestId = execDifyFlow.getString("aiAnalysisRequestId");
|
String aiAnalysisRequestId = execDifyFlow.getString("aiAnalysisRequestId");
|
||||||
fourInOneResponseDTO.setAiAnalysisRequestId(aiAnalysisRequestId);
|
fourInOneResponseDTO.setAiAnalysisRequestId(aiAnalysisRequestId);
|
||||||
fourInOneResponseDTO.setComplain(complainDTO);
|
fourInOneResponseDTO.setComplain(complainDTO);
|
||||||
fourInOneResponseDTO.setConsult(consultDTO);
|
fourInOneResponseDTO.setConsult(consultDTO);
|
||||||
fourInOneResponseDTO.setWorkOrderId(fourInOneRequestDTO.getWorkOrderId());
|
fourInOneResponseDTO.setWorkOrderId(fourInOneRequestDTO.getWorkOrderId());
|
||||||
// 发送MQ
|
// 发送MQ
|
||||||
message = JSONObject.toJSONString(fourInOneResponseDTO);
|
String message = JSONObject.toJSONString(fourInOneResponseDTO);
|
||||||
log.info("send mq {}",message);
|
log.info("send mq {}",message);
|
||||||
sendMq(message);
|
sendMq(message);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user