调整保持数据库JSON对象

This commit is contained in:
zhangfan
2024-12-25 16:20:54 +08:00
parent bb36ee422f
commit 52711e7337
2 changed files with 5 additions and 4 deletions

View File

@@ -3,7 +3,7 @@ package com.volvo.ai.analytic.center.enums;
public enum CategoryEnum { public enum CategoryEnum {
ENTERPRISE_WECHAT("企微", "企微记录"), ENTERPRISE_WECHAT("企微", "企微记录"),
PHONE_VOICE("语音", "语音记录"), PHONE_VOICE("语音", "语音电话"),
OTHER("未知", "未知记录"), OTHER("未知", "未知记录"),
; ;
private String code; private String code;

View File

@@ -107,7 +107,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
DiffDefeatanAlysis diffDefeatanAlysis = JSON.parseObject(JSON.toJSONString(oldItem.getData()), DiffDefeatanAlysis.class); DiffDefeatanAlysis diffDefeatanAlysis = JSON.parseObject(JSON.toJSONString(oldItem.getData()), DiffDefeatanAlysis.class);
DiffDefeatAnalyseOutputResult response = this.processChatRecord(diffDefeatanAlysis); DiffDefeatAnalyseOutputResult response = this.processChatRecord(diffDefeatanAlysis);
DiffDefeatAnalyseOutput output = response.getDiffDefeatAnalyseOutput(); DiffDefeatAnalyseOutput output = response.getDiffDefeatAnalyseOutput();
log.info("数据分析完成"); log.info("数据分析完成,分析返回对象output数据为 {}", output);
DiffDefeatResult diffDefeatResult; DiffDefeatResult diffDefeatResult;
if(Objects.equals(HandleStatusEnum.ANALYSIS_NORMAL.getCode(),output.getHandleStatus())){ if(Objects.equals(HandleStatusEnum.ANALYSIS_NORMAL.getCode(),output.getHandleStatus())){
diffDefeatResult = JSONObject.parseObject(output.getResultStr(), DiffDefeatResult.class); diffDefeatResult = JSONObject.parseObject(output.getResultStr(), DiffDefeatResult.class);
@@ -274,6 +274,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
vocStr.append(RoleEnum.OTHER.getMessage()).append("").append(segment.getResult().getText()).append("\n"); vocStr.append(RoleEnum.OTHER.getMessage()).append("").append(segment.getResult().getText()).append("\n");
} }
} }
contentStr.append(CategoryEnum.PHONE_VOICE.getMessage()).append("\n");
contentStr.append(vocStr); contentStr.append(vocStr);
} }
} }
@@ -282,7 +283,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
if (StringUtils.isEmpty(contentStr.toString())) { if (StringUtils.isEmpty(contentStr.toString())) {
output.setHandleStatus(HandleStatusEnum.ANALYSIS_CONTENT_EMPTY.getCode()); output.setHandleStatus(HandleStatusEnum.ANALYSIS_CONTENT_EMPTY.getCode());
output.setResultStr(HandleStatusEnum.ANALYSIS_CONTENT_EMPTY.getMessage()); output.setResultStr(HandleStatusEnum.ANALYSIS_CONTENT_EMPTY.getMessage());
return new DiffDefeatAnalyseOutputResult(output, contentStr.toString()); return new DiffDefeatAnalyseOutputResult(output, "{\"Content\": \""+contentStr.toString()+"\"}");
} }
//获取脱敏配置信息 //获取脱敏配置信息
List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC); List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC);
@@ -306,7 +307,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
output.setHandleStatus(HandleStatusEnum.ANALYSIS_NORMAL.getCode()); output.setHandleStatus(HandleStatusEnum.ANALYSIS_NORMAL.getCode());
output.setResultStr(difResult.getString("result")); output.setResultStr(difResult.getString("result"));
log.info("DiFy平台处理结果:{}", output.getResultStr()); log.info("DiFy平台处理结果:{}", output.getResultStr());
return new DiffDefeatAnalyseOutputResult(output, contentStr.toString()); return new DiffDefeatAnalyseOutputResult(output, "{\"Content\": \""+contentStr.toString()+"\"}");
} }
@Override @Override