查看用户下线

platform-admin/src/main/java/com/platform/controller/TbCfUserInfoController.java

@@ -7,14 +7,18 @@ import com.platform.service.TbCfUserInfoService;
 import com.platform.utils.PageUtils;
 import com.platform.utils.Query;
 import com.platform.utils.R;
+import com.platform.vo.Network;
 import com.platform.vo.StatisticalVo;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.ibatis.annotations.Param;
 import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -210,11 +214,29 @@ public class TbCfUserInfoController {
         return R.ok();
     }
 
-    @GetMapping("/getUserNetwork/{userId}")
-    @ResponseBody
-    public R getUserNetwork(@PathVariable String userId) {
-        List<TbCfUserInfoEntity> networks = tbCfUserInfoService.getUserNetwork(userId);
-        return R.ok().put("list",networks);
+    @GetMapping("/getUserNetwork")
+    @ResponseBody
+    public R getUserNetwork(@RequestParam Map<String, Object> params) {//查询列表数据
+        if (params.isEmpty()) {
+            return R.error("参数不能为空");
+        }
+        String userId = (String) params.get("userId");
+        if (StringUtils.isBlank(userId)) {
+            return R.error("参数[userId]不能为空");
+        }
+        Map<String, Object> result = new HashMap<>();
+        TbCfUserInfoEntity parentUser = tbCfUserInfoService.queryObject(userId);
+        Network parent=new Network();
+        BeanUtils.copyProperties(parentUser,parent);
+        parent.setNum(tbCfUserInfoService.getUserNetworkCount(params));
+        Query query = new Query(params);
+        List<Network> networks = tbCfUserInfoService.getUserNetwork(query);
+        int total = tbCfUserInfoService.getUserNetworkCount(query);
+        PageUtils pageUtil = new PageUtils(networks, total, query.getLimit(), query.getPage());
+        result.put("parent", parent);
+        result.put("networks", pageUtil);
+        return R.ok().put("list", result);
     }
 
+
 }

platform-admin/src/main/java/com/platform/dao/TbCfUserInfoDao.java

@@ -2,6 +2,7 @@ package com.platform.dao;
 
 import com.platform.entity.TbCfUserInfoEntity;
 import com.platform.entity.VirtualUserEntity;
+import com.platform.vo.Network;
 import com.platform.vo.StatisticalVo;
 import org.apache.ibatis.annotations.Param;
 
@@ -50,9 +51,9 @@ public interface TbCfUserInfoDao extends BaseDao<TbCfUserInfoEntity> {
 
     String selectRandomUser();
 
-    List<TbCfUserInfoEntity> getUserNetwork(String userId);
+    List<Network> getUserNetwork(Map<String, Object> params);
 
-    int getUserNetworkCount(String userId);
+    int getUserNetworkCount(Map<String, Object> params);
 
     BigDecimal getUserBonus(String userId);
 }

platform-admin/src/main/java/com/platform/service/TbCfUserInfoService.java

@@ -3,6 +3,7 @@ package com.platform.service;
 import com.platform.entity.TbCfUserInfoEntity;
 import com.platform.entity.VirtualUserEntity;
 import com.platform.utils.R;
+import com.platform.vo.Network;
 import com.platform.vo.StatisticalVo;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -103,5 +104,7 @@ public interface TbCfUserInfoService {
 
     void exportData();
 
-    List<TbCfUserInfoEntity> getUserNetwork(String userId);
+    List<Network> getUserNetwork(Map<String, Object> params);
+
+    int getUserNetworkCount(Map<String, Object> params);
 }

platform-admin/src/main/java/com/platform/service/impl/TbCfUserInfoServiceImpl.java

@@ -8,7 +8,9 @@ import com.platform.utils.IdUtil;
 import com.platform.utils.R;
 import com.platform.utils.excel.ExcelExport;
 import com.platform.utils.excel.ExcelImport;
+import com.platform.vo.Network;
 import com.platform.vo.StatisticalVo;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
@@ -40,7 +42,9 @@ public class TbCfUserInfoServiceImpl implements TbCfUserInfoService {
         List<TbCfUserInfoEntity> users = tbCfUserInfoDao.queryList(map);
         users.stream().forEach(user -> {
             //查询下线人数
-            user.setNetwork(tbCfUserInfoDao.getUserNetworkCount(user.getUserId()));
+            Map params = new HashMap(3);
+            params.put("userId", user.getUserId());
+            user.setNetwork(tbCfUserInfoDao.getUserNetworkCount(params));
             user.setBonus(tbCfUserInfoDao.getUserBonus(user.getUserId()));
         });
         return users;
@@ -217,8 +221,20 @@ public class TbCfUserInfoServiceImpl implements TbCfUserInfoService {
     }
 
     @Override
-    public List<TbCfUserInfoEntity> getUserNetwork(String userId) {
-        return tbCfUserInfoDao.getUserNetwork(userId);
+    public List<Network> getUserNetwork(Map<String, Object> params) {
+        List<Network> networks = tbCfUserInfoDao.getUserNetwork(params);
+        networks.stream().forEach(network -> {
+            HashMap<String, Object> map = new HashMap<>(15);
+            map.put("userId", network.getUserId());
+            network.setNum(tbCfUserInfoDao.getUserNetworkCount(map));
+        });
+
+        return networks;
+    }
+
+    @Override
+    public int getUserNetworkCount(Map<String, Object> params) {
+        return tbCfUserInfoDao.getUserNetworkCount(params);
     }
 
     /**

platform-admin/src/main/java/com/platform/vo/Network.java

+package com.platform.vo;
+
+import io.swagger.models.auth.In;
+
+import java.util.List;
+
+/**
+ * @Auther: wudepeng
+ * @Date: 2021/03/12
+ * @Description:下线
+ */
+public class Network {
+
+    private String userId;
+    private String account;
+    private String avatar;
+    private String nick;
+    private String country;
+    private String email;
+    private String phone;
+    private Integer num;
+
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getAccount() {
+        return account;
+    }
+
+    public void setAccount(String account) {
+        this.account = account;
+    }
+
+    public String getAvatar() {
+        return avatar;
+    }
+
+    public void setAvatar(String avatar) {
+        this.avatar = avatar;
+    }
+
+    public String getNick() {
+        return nick;
+    }
+
+    public void setNick(String nick) {
+        this.nick = nick;
+    }
+
+    public String getCountry() {
+        return country;
+    }
+
+    public void setCountry(String country) {
+        this.country = country;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getPhone() {
+        return phone;
+    }
+
+    public void setPhone(String phone) {
+        this.phone = phone;
+    }
+
+    public Integer getNum() {
+        return num;
+    }
+
+    public void setNum(Integer num) {
+        this.num = num;
+    }
+
+}

platform-admin/src/main/resources/com/platform/dao/TbCfUserInfoDao.xml

@@ -339,12 +339,16 @@
     </select>
 
     <!--查看用户的下线-->
-    <select id="getUserNetwork" resultType="com.platform.entity.TbCfUserInfoEntity">
-        SELECT user_id,account,avatar,nick,country,email,phone from tb_cf_user_info u  inner join (select network_info_user_id from network where user_info_user_id=#{userId}) temp on u.user_id=temp.network_info_user_id
+    <select id="getUserNetwork" resultType="com.platform.vo.Network" parameterType="map">
+        SELECT user_id,account,avatar,nick,country,email,phone from tb_cf_user_info u inner join (select
+        network_info_user_id from network where user_info_user_id=#{userId}) temp on u.user_id=temp.network_info_user_id
+        <if test="offset != null and limit != null">
+            limit #{offset}, #{limit}
+        </if>
     </select>
 
     <!--查看用户的下线人数-->
-    <select id="getUserNetworkCount" resultType="int">
+    <select id="getUserNetworkCount" resultType="int" parameterType="map">
         select count(1) from network where user_info_user_id=#{userId}
     </select>