mac 2 vuotta sitten
vanhempi
commit
e9e3d4258e

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

@@ -135,13 +135,13 @@ public class DtsController {
                 kxsUserAmountService.changeData(dmlData);
                 kxsUserAmountService.changeData(dmlData);
             }
             }
             //用户预扣款表
             //用户预扣款表
-//            if ("ToChargeBackRecord".equals(dmlData.getTableName())) {
-//                kxsUserAdvanceService.changeData(dmlData);
-//            }
-//            //用户账户余额日志
-//            if ("UserAccountRecord".equals(dmlData.getTableName())) {
-//                kxsUserAmountLogService.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())) {
             if ("UserCashRecord".equals(dmlData.getTableName()) && "KxsProfitServer".equals(dmlData.getDatabaseName())) {
                 kxsUserWithdrawalService.changeData(dmlData);
                 kxsUserWithdrawalService.changeData(dmlData);
@@ -164,61 +164,61 @@ public class DtsController {
             }
             }
 
 
 
 
-//            //商品表同步
-//            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 ("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())) {
 //            if ("StoreHouse".equals(dmlData.getTableName())) {
 //                kxsWarehouseService.changeData(dmlData);
 //                kxsWarehouseService.changeData(dmlData);
 //            }
 //            }
 //            //机具表
 //            //机具表
-//            if ("PosMachinesTwo".equals(dmlData.getTableName())) {
-//                kxsMachineService.changeData(dmlData);
-//            }
-//            //商户表
-//            if ("PosMerchantInfo".equals(dmlData.getTableName())) {
-//                kxsMerchantService.changeData(dmlData);
-//            }
-//            //机具回收表
-//            if ("RecycMachineOrder".equals(dmlData.getTableName())) {
-//                kxsMachineRecycleService.changeData(dmlData);
-//            }
-//            if ("RecycMachineOrderPos".equals(dmlData.getTableName())) {
-//                kxsMachineRecycleService.changeInfoData(dmlData);
-//            }
-//            //机具押金调整记录
-//            if ("MerchantDepositSet".equals(dmlData.getTableName())) {
-//                kxsMachinePledgeService.changeData(dmlData);
-//            }
-//            //机具费率调整记录
-//            if ("PosMachinesFeeChangeRecord".equals(dmlData.getTableName())) {
-//                kxsMachineRatioService.changeData(dmlData);
-//            }
-//            //券码表同步
-//            if ("PosCoupons".equals(dmlData.getTableName())) {
-//                kxsTicketService.changeData(dmlData);
-//            }
-//            //券码划拨表同步
-//            if ("PosCouponOrders".equals(dmlData.getTableName())) {
-//                kxsTicketTransferService.changeData(dmlData);
-//            }
-//            //券码划拨明细表同步
-//            if ("PosCouponRecord".equals(dmlData.getTableName())) {
-//                kxsTicketTransferService.changeInfoData(dmlData);
-//            }
+            if ("PosMachinesTwo".equals(dmlData.getTableName())) {
+                kxsMachineService.changeData(dmlData);
+            }
+            //商户表
+            if ("PosMerchantInfo".equals(dmlData.getTableName())) {
+                kxsMerchantService.changeData(dmlData);
+            }
+            //机具回收表
+            if ("RecycMachineOrder".equals(dmlData.getTableName())) {
+                kxsMachineRecycleService.changeData(dmlData);
+            }
+            if ("RecycMachineOrderPos".equals(dmlData.getTableName())) {
+                kxsMachineRecycleService.changeInfoData(dmlData);
+            }
+            //机具押金调整记录
+            if ("MerchantDepositSet".equals(dmlData.getTableName())) {
+                kxsMachinePledgeService.changeData(dmlData);
+            }
+            //机具费率调整记录
+            if ("PosMachinesFeeChangeRecord".equals(dmlData.getTableName())) {
+                kxsMachineRatioService.changeData(dmlData);
+            }
+            //券码表同步
+            if ("PosCoupons".equals(dmlData.getTableName())) {
+                kxsTicketService.changeData(dmlData);
+            }
+            //券码划拨表同步
+            if ("PosCouponOrders".equals(dmlData.getTableName())) {
+                kxsTicketTransferService.changeData(dmlData);
+            }
+            //券码划拨明细表同步
+            if ("PosCouponRecord".equals(dmlData.getTableName())) {
+                kxsTicketTransferService.changeInfoData(dmlData);
+            }
 
 
             //存储历史数据
             //存储历史数据
             KxsDtsLog kxsDtsLog = new KxsDtsLog();
             KxsDtsLog kxsDtsLog = new KxsDtsLog();