|
@@ -129,7 +129,7 @@ public class DtsController {
|
|
|
//去重数据
|
|
//去重数据
|
|
|
KxsDtsLog dtsLog = kxsDtsLogService.getOne(Wrappers.<KxsDtsLog>lambdaQuery().eq(KxsDtsLog::getDataId, dataId));
|
|
KxsDtsLog dtsLog = kxsDtsLogService.getOne(Wrappers.<KxsDtsLog>lambdaQuery().eq(KxsDtsLog::getDataId, dataId));
|
|
|
if (dtsLog != null) {
|
|
if (dtsLog != null) {
|
|
|
- log.info("dts的数据重复:{},dataID:{}", dmlData.getValidFieldDataMap(), dataId);
|
|
|
|
|
|
|
+// log.info("dts的数据重复:{},dataID:{}", dmlData.getValidFieldDataMap(), dataId);
|
|
|
record.commit(String.valueOf(record.getSourceTimestamp()));
|
|
record.commit(String.valueOf(record.getSourceTimestamp()));
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|