创客预设职级同步

kxs-transfer/src/main/java/com/kxs/transfer/api/controller/DtsController.java

@@ -103,78 +103,78 @@ public class DtsController {
                 record.commit(String.valueOf(record.getSourceTimestamp()));
                 return;
             }
-//            if (!"UserMoveInfo".equals(dmlData.getTableName())) {
-//                log.info("开始消费:{}表的数据，dataID:{}, 表名：{}", dmlData.getTableName(), dataId, dmlData.getDatabaseName());
-//            }
-//
-//            //用户表
-//            if ("Users".equals(dmlData.getTableName())) {
-//                kxsUserService.changeUser(dmlData);
-//            }
-//            //用户预设职级表
-//            if ("UserRankWhite".equals(dmlData.getTableName())) {
-//                kxsUserPresetLogService.changeUser(dmlData);
-//            }
-//            //密码操作
-//            if ("UserMoveInfo".equals(dmlData.getTableName())) {
-//                kxsUserService.changeUserPwd(dmlData);
-//                //密码操作不存储原始数据
-//                record.commit(String.valueOf(record.getSourceTimestamp()));
-//                return;
-//            }
-//            //用户地址表
-//            if ("UserAddress".equals(dmlData.getTableName())) {
-//                kxsUserAddressService.changeData(dmlData);
-//            }
-//            //用户账户
-//            if ("UserAccount".equals(dmlData.getTableName()) && "KxsProfitServer".equals(dmlData.getDatabaseName())) {
-//                kxsUserAmountService.changeData(dmlData);
-//            }
-//            //用户预扣款表
-//            if ("ToChargeBackRecord".equals(dmlData.getTableName())) {
-//                kxsUserAdvanceService.changeData(dmlData);
-//            }
-//            //用户账户余额日志
-//            if ("UserAccountRecord".equals(dmlData.getTableName())) {
-//                kxsUserAmountLogService.changeData(dmlData);
-//            }
-//            //用户提现申请记录
-//            if ("UserCashRecord".equals(dmlData.getTableName()) && "KxsProfitServer".equals(dmlData.getDatabaseName())) {
-//                kxsUserWithdrawalService.changeData(dmlData);
-//            }
-//            //盟主表
-//            if ("Leaders".equals(dmlData.getTableName())) {
-//                kxsLeaderService.changeData(dmlData);
-//            }
-//            //盟主金额变动记录表
-//            if ("LeaderReserveRecord".equals(dmlData.getTableName())) {
-//                kxsLeaderAmountLogService.changeData(dmlData);
-//            }
-//            //合伙人表
-//            if ("OperatorRankWhite".equals(dmlData.getTableName())) {
-//                kxsPartnerService.changeData(dmlData);
-//            }
-//            //合伙人账户 -> 合伙人表
-//            if ("UserAccount".equals(dmlData.getTableName()) && "KxsOpServer".equals(dmlData.getDatabaseName())) {
-//                kxsPartnerService.changeAccountData(dmlData);
-//            }
-//
-//
-//            //商品表同步
-//            if ("Products".equals(dmlData.getTableName())) {
-//                kxsShopGoodsService.changeData(dmlData);
-//            }
-//            //每日晨会同步
-//            if ("SchoolMorningMeet".equals(dmlData.getTableName())) {
-//                kxsMorningService.changeData(dmlData);
-//            }
-//            if ("SchoolMorningMeetLog".equals(dmlData.getTableName())) {
-//                kxsMorningService.changeLogData(dmlData);
-//            }
-//            //创客学堂
-//            if ("SchoolMakerStudy".equals(dmlData.getTableName())) {
-//                kxsSchoolStudyService.changeData(dmlData);
-//            }
+            if (!"UserMoveInfo".equals(dmlData.getTableName())) {
+                log.info("开始消费:{}表的数据，dataID:{}, 表名：{}", dmlData.getTableName(), dataId, dmlData.getDatabaseName());
+            }
+
+            //用户表
+            if ("Users".equals(dmlData.getTableName())) {
+                kxsUserService.changeUser(dmlData);
+            }
+            //用户预设职级表
+            if ("UserRankWhite".equals(dmlData.getTableName())) {
+                kxsUserPresetLogService.changeUser(dmlData);
+            }
+            //密码操作
+            if ("UserMoveInfo".equals(dmlData.getTableName())) {
+                kxsUserService.changeUserPwd(dmlData);
+                //密码操作不存储原始数据
+                record.commit(String.valueOf(record.getSourceTimestamp()));
+                return;
+            }
+            //用户地址表
+            if ("UserAddress".equals(dmlData.getTableName())) {
+                kxsUserAddressService.changeData(dmlData);
+            }
+            //用户账户
+            if ("UserAccount".equals(dmlData.getTableName()) && "KxsProfitServer".equals(dmlData.getDatabaseName())) {
+                kxsUserAmountService.changeData(dmlData);
+            }
+            //用户预扣款表
+            if ("ToChargeBackRecord".equals(dmlData.getTableName())) {
+                kxsUserAdvanceService.changeData(dmlData);
+            }
+            //用户账户余额日志
+            if ("UserAccountRecord".equals(dmlData.getTableName())) {
+                kxsUserAmountLogService.changeData(dmlData);
+            }
+            //用户提现申请记录
+            if ("UserCashRecord".equals(dmlData.getTableName()) && "KxsProfitServer".equals(dmlData.getDatabaseName())) {
+                kxsUserWithdrawalService.changeData(dmlData);
+            }
+            //盟主表
+            if ("Leaders".equals(dmlData.getTableName())) {
+                kxsLeaderService.changeData(dmlData);
+            }
+            //盟主金额变动记录表
+            if ("LeaderReserveRecord".equals(dmlData.getTableName())) {
+                kxsLeaderAmountLogService.changeData(dmlData);
+            }
+            //合伙人表
+            if ("OperatorRankWhite".equals(dmlData.getTableName())) {
+                kxsPartnerService.changeData(dmlData);
+            }
+            //合伙人账户 -> 合伙人表
+            if ("UserAccount".equals(dmlData.getTableName()) && "KxsOpServer".equals(dmlData.getDatabaseName())) {
+                kxsPartnerService.changeAccountData(dmlData);
+            }
+
+
+            //商品表同步
+            if ("Products".equals(dmlData.getTableName())) {
+                kxsShopGoodsService.changeData(dmlData);
+            }
+            //每日晨会同步
+            if ("SchoolMorningMeet".equals(dmlData.getTableName())) {
+                kxsMorningService.changeData(dmlData);
+            }
+            if ("SchoolMorningMeetLog".equals(dmlData.getTableName())) {
+                kxsMorningService.changeLogData(dmlData);
+            }
+            //创客学堂
+            if ("SchoolMakerStudy".equals(dmlData.getTableName())) {
+                kxsSchoolStudyService.changeData(dmlData);
+            }
 
             //仓库表
             if ("StoreHouse".equals(dmlData.getTableName())) {