企微企微语料问题 ,加日志
This commit is contained in:
@@ -134,7 +134,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
|
|||||||
int offset = (i - 1) * pageSize;
|
int offset = (i - 1) * pageSize;
|
||||||
List<OdsVdqwMessageOTD> messageList = tmOdsVdqwMessagearchivingMapper.queryOdsVdqwMessageByData(statTime, endTime, offset, pageSize, retry);
|
List<OdsVdqwMessageOTD> messageList = tmOdsVdqwMessagearchivingMapper.queryOdsVdqwMessageByData(statTime, endTime, offset, pageSize, retry);
|
||||||
// 处理查询到的数据
|
// 处理查询到的数据
|
||||||
log.info("待处理企微聊天列表messageList",messageList.toString());
|
log.info("待处理企微聊天列表messageList,{}",messageList.toString());
|
||||||
// 使用 CompletableFuture 并行处理
|
// 使用 CompletableFuture 并行处理
|
||||||
messageList.forEach(item -> {
|
messageList.forEach(item -> {
|
||||||
long startTime2 = System.currentTimeMillis();
|
long startTime2 = System.currentTimeMillis();
|
||||||
@@ -205,7 +205,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
|
|||||||
runMaskingRuleInput.setOldStr(chat);
|
runMaskingRuleInput.setOldStr(chat);
|
||||||
String corpusChat = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
|
String corpusChat = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
|
||||||
chatList.append(corpusChat).append("\n");
|
chatList.append(corpusChat).append("\n");
|
||||||
log.info("第几循环次数{} ,掩码前:{} ,掩码后:{}", externalcontactCount.get(), chat,chatList.toString());
|
log.info("第几循环次数{} ,掩码前:{} ,掩码后:{},合并后的总语料数据 :{}", externalcontactCount.get(), chat,corpusChat,chatList.toString());
|
||||||
});
|
});
|
||||||
if (externalcontactCount.get() < 1) {
|
if (externalcontactCount.get() < 1) {
|
||||||
log.info("没有客户回复的语料,无需解析");
|
log.info("没有客户回复的语料,无需解析");
|
||||||
|
|||||||
Reference in New Issue
Block a user