|
|
@@ -73,6 +73,11 @@ public class DtsController {
|
|
|
record.commit(String.valueOf(record.getSourceTimestamp()));
|
|
|
return;
|
|
|
}
|
|
|
+ //过滤Users库存更新字段
|
|
|
+ if (changeFieldList.size() == 1 && changeFieldList.contains("StoreStock")) {
|
|
|
+ record.commit(String.valueOf(record.getSourceTimestamp()));
|
|
|
+ return;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
//去重数据
|
|
|
@@ -95,6 +100,9 @@ public class DtsController {
|
|
|
//密码操作
|
|
|
if ("UserMoveInfo".equals(dmlData.getTableName())) {
|
|
|
kxsUserService.changeUserPwd(dmlData);
|
|
|
+ //密码操作不存储原始数据
|
|
|
+ record.commit(String.valueOf(record.getSourceTimestamp()));
|
|
|
+ return;
|
|
|
}
|
|
|
//用户地址表
|
|
|
if ("UserAddress".equals(dmlData.getTableName())) {
|