语料信息不完整,dcc加日志

This commit is contained in:
ZLI263
2025-09-18 14:41:43 +08:00
parent e2c1b5c224
commit 40c7d471b6
2 changed files with 3 additions and 3 deletions

View File

@@ -126,7 +126,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
log.info("重跑铭牌语料铭牌数据跑批结束 耗时:{}", System.currentTimeMillis() - startTime); log.info("重跑铭牌语料铭牌数据跑批结束 耗时:{}", System.currentTimeMillis() - startTime);
} }
public void processItem(TmNameplateCorpus item) { public synchronized void processItem(TmNameplateCorpus item) {
try { try {
Optional.ofNullable(item).filter(tmNameplateCorpus -> tmNameplateCorpus.getCustomerFlowId() != null && tmNameplateCorpus.getNameplateContent() != null).orElseThrow(() -> new RuntimeException("铭牌语料为空")); Optional.ofNullable(item).filter(tmNameplateCorpus -> tmNameplateCorpus.getCustomerFlowId() != null && tmNameplateCorpus.getNameplateContent() != null).orElseThrow(() -> new RuntimeException("铭牌语料为空"));
@@ -236,7 +236,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
} }
@Override @Override
public ResultMsg<Object> updateNameplate(String message) { public synchronized ResultMsg<Object> updateNameplate(String message) {
try { try {
if (StringUtils.isNotEmpty(message)) { if (StringUtils.isNotEmpty(message)) {

View File

@@ -164,7 +164,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
} }
private void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) { private synchronized void processItem(OdsVdqwMessageOTD item, String statTime, String endTime) {
log.info("企微语料内容FromUserId{}, AcceptUserId{}", item.getFromUserId(), item.getAcceptUserId()); log.info("企微语料内容FromUserId{}, AcceptUserId{}", item.getFromUserId(), item.getAcceptUserId());
// 1vdqw_workuserinfo 这个表对应是 B端认证中心userId // 1vdqw_workuserinfo 这个表对应是 B端认证中心userId
// 2vdqw_externalcontact 这个表对应是 企微客户unionId // 2vdqw_externalcontact 这个表对应是 企微客户unionId