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:
ZLI263
2025-09-18 18:21:50 +08:00
parent bb5a2c4a91
commit ab13bb120d
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -164,7 +164,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
DiFyReq diFyImageReq = new DiFyReq(); DiFyReq diFyImageReq = new DiFyReq();
CorpusReportDTO corpusReportDTO = new CorpusReportDTO(); CorpusReportDTO corpusReportDTO = new CorpusReportDTO();
OdsVdqwMessageOTD finalMaxMsgTimeItem = new OdsVdqwMessageOTD(); OdsVdqwMessageOTD finalMaxMsgTimeItem = new OdsVdqwMessageOTD();
StringBuffer chatList = new StringBuffer(); StringBuilder chatList = new StringBuilder();
String unionId = ""; String unionId = "";
synchronized (this) {// 1，vdqw_workuserinfo 这个表对应是 B端认证中心userId synchronized (this) {// 1，vdqw_workuserinfo 这个表对应是 B端认证中心userId
// 2，vdqw_externalcontact 这个表对应是 企微客户unionId // 2，vdqw_externalcontact 这个表对应是 企微客户unionId
@@ -188,12 +188,12 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(BusinessTypeEnum.SMART_ASSISTANT_QIWEI.getCode()); List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(BusinessTypeEnum.SMART_ASSISTANT_QIWEI.getCode());
RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput(); RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput();
runMaskingRuleInput.setDataMaskingRules(maskingRuleItems); runMaskingRuleInput.setDataMaskingRules(maskingRuleItems);
chatList = new StringBuffer(); chatList = new StringBuilder();
StringBuffer chatList2 = new StringBuffer(); StringBuilder chatList2 = new StringBuilder();
StringBuffer chatList3 = new StringBuffer(); StringBuilder chatList3 = new StringBuilder();
StringBuffer chatList4 = new StringBuffer(); StringBuilder chatList4 = new StringBuilder();
AtomicInteger externalcontactCount = new AtomicInteger(); AtomicInteger externalcontactCount = new AtomicInteger();
StringBuffer finalChatList = chatList; StringBuilder finalChatList = chatList;
contetnList.forEach(contentItem -> { contetnList.forEach(contentItem -> {
String title = ""; String title = "";
if (tmOdsVdqwExternalcontact.getExternalUserId().equals(contentItem.getFromUserId())) { if (tmOdsVdqwExternalcontact.getExternalUserId().equals(contentItem.getFromUserId())) {
@@ -254,7 +254,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
long startTime2 = System.currentTimeMillis(); long startTime2 = System.currentTimeMillis();
OdsVdqwMessageOTD finalMaxMsgTimeItem2 = finalMaxMsgTimeItem; OdsVdqwMessageOTD finalMaxMsgTimeItem2 = finalMaxMsgTimeItem;
String finalUnionId = unionId; String finalUnionId = unionId;
StringBuffer finalChatList1 = chatList; StringBuilder finalChatList1 = chatList;
CompletableFuture<Void> portraitTask = CompletableFuture.runAsync(() -> { CompletableFuture<Void> portraitTask = CompletableFuture.runAsync(() -> {
executePortraitTask(finalUnionId, finalMaxMsgTimeItem2, finalChatList1, corpusReportDTO); executePortraitTask(finalUnionId, finalMaxMsgTimeItem2, finalChatList1, corpusReportDTO);
}, executor); }, executor);
@@ -322,7 +322,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
/** /**
* 执行客户画像任务 * 执行客户画像任务
*/ */
private void executePortraitTask(String unionId, OdsVdqwMessageOTD maxMsgTimeItem, StringBuffer chatList, CorpusReportDTO corpusReportDTO) { private void executePortraitTask(String unionId, OdsVdqwMessageOTD maxMsgTimeItem, StringBuilder chatList, CorpusReportDTO corpusReportDTO) {
try { try {
//"analysisScene": "分析类型", // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾) //"analysisScene": "分析类型", // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾)
DiFyReq diFyImageReq2 = new DiFyReq(); DiFyReq diFyImageReq2 = new DiFyReq();