* init

src/main/java/com/tdba/cxb/ares/api/model/UserDto.java

@@ -23,6 +23,9 @@ public class UserDto {
      */
     private Integer num;
 
+    /** 用户ID 多个逗号隔开*/
+    private String uid_concat;
+
     public Integer getUid() {
         return uid;
     }
@@ -47,11 +50,19 @@ public class UserDto {
         this.num = num;
     }
 
+    public String getUid_concat() {
+        return uid_concat;
+    }
+
+    public void setUid_concat(String uid_concat) {
+        this.uid_concat = uid_concat;
+    }
 
     public static final class UserDtoBuilder {
         private Integer uid;
         private Integer spread_uid;
         private Integer num;
+        private String uid_concat;
 
         private UserDtoBuilder() {
         }
@@ -75,11 +86,17 @@ public class UserDto {
             return this;
         }
 
+        public UserDtoBuilder withUid_concat(String uid_concat) {
+            this.uid_concat = uid_concat;
+            return this;
+        }
+
         public UserDto build() {
             UserDto userDto = new UserDto();
             userDto.setUid(uid);
             userDto.setSpread_uid(spread_uid);
             userDto.setNum(num);
+            userDto.setUid_concat(uid_concat);
             return userDto;
         }
     }

src/main/java/com/tdba/cxb/ares/api/repository/UserRelateMapper.java

@@ -37,4 +37,7 @@ public interface UserRelateMapper {
 
     List<DetailListResp> selectByPid(@Param("pid") Integer pid,
                                      @Param("userType") Integer userType);
+
+    Integer updateByUidList(@Param("userType") Integer userType,
+                        @Param("uid_concat") String uid_concat);
 }

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

@@ -1,5 +1,6 @@
 package com.tdba.cxb.ares.api.service;
 
+import com.tdba.cxb.ares.api.controller.UserController;
 import com.tdba.cxb.ares.api.model.*;
 import com.tdba.cxb.ares.api.repository.UserBindMapper;
 import com.tdba.cxb.ares.api.repository.UserCountMapper;
@@ -152,7 +153,7 @@ public class UserService {
                         .withUser_type(UserTypeEnum.DACANG.ordinal())
                         .withCreate_time(currentTime)
                         .build());
-                userRelateMapper.updateByUid(UserTypeEnum.DACANG.ordinal(), row.getSpread_uid());
+                userRelateMapper.updateByUidList(UserTypeEnum.DACANG.ordinal(), row.getUid_concat());
 
                 userRelateMapper.selectByUid(row.getSpread_uid()).stream().forEach(innerRow -> {
                     resultList.add(UserCount.UserCountBuilder.anUserCount()
@@ -172,10 +173,12 @@ public class UserService {
                             .withUid(row.getKey())
                             .withUser_type(UserTypeEnum.DACANG.ordinal())
                             .withDate(localDate)
-                            .withNum(row.getValue().size())
+                            .withNum(row.getValue().stream().mapToInt(UserCount::getNum).sum())
                             .withCreate_time(currentTime)
                             .build()).toList());
         }
+
+        //更新
     }
 
     /**

src/main/resources/mapper/UserMapper.xml

@@ -17,7 +17,8 @@
     <select id="selectDacang" resultType="com.tdba.cxb.ares.api.model.UserDto">
         select
             count(1) 'num',
-            u.spread_uid
+            u.spread_uid,
+            group_concat(u.uid) 'uid_concat'
         from
             rrx_da_cang_user da
         left join

src/main/resources/mapper/UserRelateMapper.xml

@@ -126,6 +126,24 @@
         where uid = #{uid}
     </select>
 
+    <select id="updateByUidList">
+        update user_relate set
+        <if test="userType == 1">
+            is_dacang = 1
+        </if>
+        <if test="userType == 2">
+            is_merchant = 1
+        </if>
+        <if test="userType == 3">
+            is_channel = 1
+        </if>
+        <if test="userType == 4">
+            is_agent = 1
+        </if>
+
+        where uid in ( #{uid_concat} )
+    </select>
+
     <select id="countByUid" resultType="java.lang.Integer">
         select
             count(1)