数据同步合并盟主和运营中心

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

@@ -16,6 +16,7 @@ import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Map;
 
@@ -129,7 +130,10 @@ public class KxsLeaderServiceImpl extends ServiceImpl<KxsLeaderMapper, KxsLeader
             }
         }
         KxsLeader kxsLeader = baseMapper.selectById(leader.getId());
-        if(kxsLeader != null){
+        if(kxsLeader == null){
+            leader.setLastBuyDate(LocalDateTime.now());
+            baseMapper.insert(leader);
+        }else{
             baseMapper.updateById(leader);
         }
     }

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

@@ -227,6 +227,7 @@ public class KxsUserServiceImpl extends ServiceImpl<KxsUserMapper, KxsUser> impl
                                 leader.setLeaderType(LeaderTypeEnum.TC_LEADER.getType());
                                 leader.setLeaderLevel(LeaderTypeEnum.TC_LEADER.getLevel());
                             }
+                            leader.setLastBuyDate(LocalDateTime.now());
                             kxsLeaderMapper.insert(leader);
                         }else{
                             if(userType == 1){