语料信息不完整,dcc加日志
This commit is contained in:
@@ -140,17 +140,12 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
|
||||
long startTime2 = System.currentTimeMillis();
|
||||
log.info("处理企微语料开始 FromUserId={}, AcceptUserId={}",
|
||||
item.getFromUserId(), item.getAcceptUserId());
|
||||
|
||||
CompletableFuture.runAsync(() -> {
|
||||
//第一个业务场景 开始: 总结和分类业务场景
|
||||
try {
|
||||
processItem(item, finalStatTime, finalEndTime);
|
||||
} catch (Exception e) {
|
||||
log.error("处理企微语料失败: FromUserId={}, AcceptUserId={}, 异常: {}",
|
||||
item.getFromUserId(), item.getAcceptUserId(), e.getMessage(), e);
|
||||
}
|
||||
}, executor);
|
||||
|
||||
log.info("处理企微语料 调用完成: 结束时间:{}, 总用时: {}", System.currentTimeMillis(), System.currentTimeMillis() - startTime2);
|
||||
|
||||
});
|
||||
@@ -210,6 +205,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
|
||||
runMaskingRuleInput.setOldStr(chat);
|
||||
String corpusChat = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
|
||||
chatList.append(corpusChat).append("\n");
|
||||
log.info("第几循环次数{} ,掩码前:{} ,掩码后:{}", externalcontactCount.get(), chat,chatList.toString());
|
||||
});
|
||||
if (externalcontactCount.get() < 1) {
|
||||
log.info("没有客户回复的语料,无需解析");
|
||||
|
||||
Reference in New Issue
Block a user