合伙人账户表同步

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

@@ -41,7 +41,7 @@ public class DtsController {
     private final KxsUserPresetLogService kxsUserPresetLogService;
     private final KxsUserAddressService kxsUserAddressService;
     private final KxsUserAmountService kxsUserAmountService;
-    private final KxsUserAdvanceService kxsUserAdvanceService ;
+    private final KxsUserAdvanceService kxsUserAdvanceService;
     private final KxsUserAmountLogService kxsUserAmountLogService;
     private final KxsUserWithdrawalService kxsUserWithdrawalService;
     private final KxsLeaderService kxsLeaderService;
@@ -63,7 +63,7 @@ public class DtsController {
                     record.commit(String.valueOf(record.getSourceTimestamp()));
                     return;
                 }
-               if (changeFieldList.size() == 1 && changeFieldList.contains("DeviceId")) {
+                if (changeFieldList.size() == 1 && changeFieldList.contains("DeviceId")) {
                     // 如果changeFieldList的大小为1，且changeFieldList包含DeviceId，则提交记录
                     record.commit(String.valueOf(record.getSourceTimestamp()));
                     return;
@@ -127,15 +127,15 @@ public class DtsController {
                 kxsUserWithdrawalService.changeData(dmlData);
             }
             //盟主表
-            if ("Leaders".equals(dmlData.getTableName()) ) {
+            if ("Leaders".equals(dmlData.getTableName())) {
                 kxsLeaderService.changeData(dmlData);
             }
             //盟主金额变动记录表
-            if ("LeaderReserveRecord".equals(dmlData.getTableName()) ) {
+            if ("LeaderReserveRecord".equals(dmlData.getTableName())) {
                 kxsLeaderAmountLogService.changeData(dmlData);
             }
             //合伙人表
-            if ("OperatorRankWhite".equals(dmlData.getTableName()) ) {
+            if ("OperatorRankWhite".equals(dmlData.getTableName())) {
                 kxsPartnerService.changeData(dmlData);
             }
             //合伙人账户 -> 合伙人表
@@ -145,12 +145,11 @@ public class DtsController {
 
 
             //商品表同步
-            if ("Products".equals(dmlData.getTableName()) ) {
+            if ("Products".equals(dmlData.getTableName())) {
                 kxsShopGoodsService.changeData(dmlData);
             }
 
 
-
             //存储历史数据
             KxsDtsLog kxsDtsLog = new KxsDtsLog();
             kxsDtsLog.setDataId(dataId);

kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsPartnerServiceImpl.java

@@ -96,7 +96,7 @@ public class KxsPartnerServiceImpl extends ServiceImpl<KxsPartnerMapper, KxsPart
                     break;
             }
         }
-        KxsPartner kxsPartner = baseMapper.selectById(Wrappers.<KxsPartner>lambdaQuery().eq(KxsPartner::getUserId, partner.getUserId()));
+        KxsPartner kxsPartner = baseMapper.selectById(partner.getId());
         if(kxsPartner == null){
             partner.setPartnerLevel(9);
             baseMapper.insert(partner);

kxs-transfer/src/main/resources/import.txt

@@ -72,7 +72,6 @@ FROM LeaderReserveRecord
 SELECT a.Id as id, a.Id as user_id, CASE a.UserType WHEN 1 THEN 0 WHEN 2 THEN 1 END partner_type, 9 as partner_level,
 b.CreateDate as create_time, b.UpdateDate as expired_date,
 c.ValidForGetAmount as withdrawal_amount, c.TotalAmt as amount, c.ValidAmount as store_amount
-
 FROM Users a left join OperatorRankWhite b on a.Id = b.UserId
 left join KxsOpServer.UserAccount c on a.Id = c.UserId
 WHERE UserType > 0