数据同步合并

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

@@ -52,6 +52,7 @@ public class KxsUserServiceImpl extends ServiceImpl<KxsUserMapper, KxsUser> impl
     private final KxsUserBankMapper kxsUserBankMapper;
 
     private final KxsLeaderMapper kxsLeaderMapper;
+    private final KxsPartnerMapper kxsPartnerMapper;
 
     private final KxsUserAmountMapper kxsUserAmountMapper;
 
@@ -212,33 +213,73 @@ public class KxsUserServiceImpl extends ServiceImpl<KxsUserMapper, KxsUser> impl
                             leader.setUserId(Integer.valueOf(userId));
                             if(userType == 1){
                                 leader.setLeaderType(LeaderTypeEnum.OP_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.OP_LEADER.getLevel());
                             }
                             if(userType == 2){
                                 leader.setLeaderType(LeaderTypeEnum.GOLD_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.GOLD_LEADER.getLevel());
                             }
                             if(userType == 3){
                                 leader.setLeaderType(LeaderTypeEnum.DI_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.DI_LEADER.getLevel());
                             }
                             if(userType == 4){
                                 leader.setLeaderType(LeaderTypeEnum.TC_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.TC_LEADER.getLevel());
                             }
-                            leader.setLeaderType(9);
                             kxsLeaderMapper.insert(leader);
                         }else{
                             if(userType == 1){
                                 leader.setLeaderType(LeaderTypeEnum.OP_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.OP_LEADER.getLevel());
                             }
                             if(userType == 2){
                                 leader.setLeaderType(LeaderTypeEnum.GOLD_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.GOLD_LEADER.getLevel());
                             }
                             if(userType == 3){
                                 leader.setLeaderType(LeaderTypeEnum.DI_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.DI_LEADER.getLevel());
                             }
                             if(userType == 4){
                                 leader.setLeaderType(LeaderTypeEnum.TC_LEADER.getType());
+                                leader.setLeaderLevel(LeaderTypeEnum.TC_LEADER.getLevel());
                             }
                             kxsLeaderMapper.updateById(leader);
                         }
+                        KxsPartner partner = kxsPartnerMapper.selectOne(Wrappers.<KxsPartner>lambdaQuery().eq(KxsPartner::getUserId, userId));
+                        if (partner == null){
+                            partner = new KxsPartner();
+                            partner.setId(Integer.valueOf(userId));
+                            partner.setUserId(Integer.valueOf(userId));
+                            if(userType == 1){
+                                partner.setPartnerType(0);
+                            }
+                            if(userType == 2){
+                                partner.setPartnerType(1);
+                            }
+                            if(userType == 3){
+                                partner.setPartnerType(2);
+                            }
+                            if(userType == 4){
+                                partner.setPartnerType(3);
+                            }
+                            kxsPartnerMapper.insert(partner);
+                        }else{
+                            if(userType == 1){
+                                partner.setPartnerType(0);
+                            }
+                            if(userType == 2){
+                                partner.setPartnerType(1);
+                            }
+                            if(userType == 3){
+                                partner.setPartnerType(2);
+                            }
+                            if(userType == 4){
+                                partner.setPartnerType(3);
+                            }
+                            kxsPartnerMapper.updateById(partner);
+                        }
                     }
                     break;
             }

kxs-user/kxs-user-api/src/main/java/com/kxs/user/api/model/KxsLeader.java

@@ -72,9 +72,9 @@ public class KxsLeader extends Model<KxsLeader> implements Serializable {
 
 
     /**
-     * 盟主类型 小盟主=1 大盟主=2
+     * 盟主类型 小盟主=1 大盟主=2 运营中心=3 黄金=4 钻石=5 战略=6
      */
-    @Schema(description = "盟主类型 小盟主=1 大盟主=2")
+    @Schema(description = "盟主类型 小盟主=1 大盟主=2 运营中心=3 黄金=4 钻石=5 战略=6")
     private Integer leaderType;