* init

src/main/java/com/tdba/cxb/ares/api/service/UserService.java

@@ -78,14 +78,17 @@ public class UserService {
                                 .build());
                     }
                 }
+            }
 
-                //-- 追溯之前的数据
-                if((null != row.getSpread_uid()) && (0 < row.getSpread_uid())){
-                    relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
-                            .withUid(row.getUid())
-                            .withPid(row.getSpread_uid())
-                            .withDate(localDate)
-                            .build());
+            //-- 追溯之前的数据
+            if((null != row.getSpread_uid()) && (0 < row.getSpread_uid())){
+                relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                        .withUid(row.getUid())
+                        .withPid(row.getSpread_uid())
+                        .withDate(localDate)
+                        .build());
+
+                if(0 < num) {
                     //推荐人
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
                             .withCreate_time(currentTime)
@@ -94,9 +97,11 @@ public class UserService {
                             .withUid(row.getSpread_uid())
                             .withDate(localDate)
                             .build());
+                }
 
-                    //往前追溯的推荐人
-                    userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                //往前追溯的推荐人
+                userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
+                    if(0 < num) {
                         resultList.add(UserCount.UserCountBuilder.anUserCount()
                                 .withCreate_time(currentTime)
                                 .withNum(num)
@@ -104,19 +109,19 @@ public class UserService {
                                 .withUid(innerRow.getPid())
                                 .withDate(localDate)
                                 .build());
+                    }
 
-                        relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
-                                .withUid(row.getUid())
-                                .withPid(innerRow.getPid())
-                                .withDate(localDate)
-                                .build());
-                    });
-                }
-                if(!relateList.isEmpty()){
-                    userRelateMapper.insertSelectiveForeach(relateList);
-                }
-                relateList.clear();
+                    relateList.add(UserRelate.UserRelateBuilder.anUserRelate()
+                            .withUid(row.getUid())
+                            .withPid(innerRow.getPid())
+                            .withDate(localDate)
+                            .build());
+                });
+            }
+            if(!relateList.isEmpty()){
+                userRelateMapper.insertSelectiveForeach(relateList);
             }
+            relateList.clear();
         });
         if(!resultList.isEmpty()){
             userCountMapper.insertSelectiveForeach(resultList);