Merge branch 'master' of http://gitea.dctpay.com/hurui/youtao

bweb/src/main/java/com/hfkj/controller/BsUserController.java

@@ -0,0 +1,159 @@
+package com.hfkj.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.hfkj.common.exception.ErrorCode;
+import com.hfkj.common.exception.ErrorHelp;
+import com.hfkj.common.exception.SysCode;
+import com.hfkj.common.utils.ResponseMsgUtil;
+import com.hfkj.entity.BsUser;
+import com.hfkj.entity.BsUserParentRel;
+import com.hfkj.model.ResponseData;
+import com.hfkj.service.user.BsUserGradeService;
+import com.hfkj.service.user.BsUserParentRelService;
+import com.hfkj.service.user.BsUserService;
+import com.hfkj.sysenum.user.UserGradeEnum;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @className: CmsController
+ * @author: HuRui
+ * @date: 2024/9/24
+ **/
+@Controller
+@RequestMapping(value = "/bsUser")
+@Api(value = "用户管理")
+public class BsUserController {
+    private static Logger log = LoggerFactory.getLogger(BsUserController.class);
+    @Resource
+    private BsUserService userService;
+    @Resource
+    private BsUserGradeService userGradeService;
+    @Resource
+    private BsUserParentRelService userParentRelService;
+
+    @RequestMapping(value="/gradeAdjust",method = RequestMethod.POST)
+    @ResponseBody
+    @ApiOperation(value = "等级调整")
+    public ResponseData gradeAdjust(@RequestBody JSONObject body) {
+        try {
+            if (body == null || body.getLong("userId") == null || body.getInteger("grade") == null) {
+                throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, "");
+            }
+
+            userGradeService.gradeAdjust(body.getLong("userId"), UserGradeEnum.getDataByType(body.getInteger("grade")));
+
+            return ResponseMsgUtil.success("操作成功");
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value="/ban",method = RequestMethod.POST)
+    @ResponseBody
+    @ApiOperation(value = "封禁")
+    public ResponseData ban(@RequestBody JSONObject body) {
+        try {
+            if (body == null || body.getLong("userId") == null) {
+                throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, "");
+            }
+
+            userService.ban(body.getLong("userId"));
+
+            return ResponseMsgUtil.success("操作成功");
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value="/restore",method = RequestMethod.POST)
+    @ResponseBody
+    @ApiOperation(value = "恢复")
+    public ResponseData restore(@RequestBody JSONObject body) {
+        try {
+            if (body == null || body.getLong("userId") == null) {
+                throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, "");
+            }
+
+            userService.restore(body.getLong("userId"));
+
+            return ResponseMsgUtil.success("操作成功");
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value="/getDetail",method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询详情")
+    public ResponseData getDetail(@RequestParam(name = "userId", required = true) Long userId) {
+        try {
+            // 查询用户
+            BsUser user = userService.getUser(userId);
+            if (user == null) {
+                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未知的用户");
+            }
+            Map<String,Object> param = new HashMap<>();
+            param.put("user", user);
+            // 授权
+            param.put("platform_authorize", new ArrayList<>());
+            // 邀请人
+            param.put("inviteUser", user.getInviteUserId()!=null?userService.getUser(user.getInviteUserId()):null);
+            // 贡献关系
+            Map<String,Object> contribute = new HashMap<>();
+            param.put("contribute", contribute);
+            if (user.getInviteUserId() != null) {
+                // 查询用户上级
+                BsUserParentRel parent = userParentRelService.getDetailByUserId(userId);
+
+            }
+
+
+            return ResponseMsgUtil.success(param);
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value="/queryList",method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询列表")
+    public ResponseData queryList(@RequestParam(name = "userId", required = false) Long userId,
+                                  @RequestParam(name = "name", required = false) String name,
+                                  @RequestParam(name = "phone", required = false) Integer phone,
+                                  @RequestParam(name = "grade", required = false) Integer grade,
+                                  @RequestParam(name = "status", required = false) Integer status,
+                                  @RequestParam(name = "pageNum", required = true) Integer pageNum,
+                                  @RequestParam(name = "pageSize", required = true) Integer pageSize) {
+        try {
+            Map<String,Object> param = new HashMap<>();
+            param.put("id", userId);
+            param.put("name", name);
+            param.put("phone", phone);
+            param.put("grade", grade);
+            param.put("status", status);
+
+            PageHelper.startPage(pageNum, pageSize);
+            return ResponseMsgUtil.success(new PageInfo<>(userService.getList(param)));
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+}

bweb/src/main/java/com/hfkj/controller/CmsController.java

@@ -64,6 +64,7 @@ public class CmsController {
                 cmsContent = new CmsContent();
                 cmsContent.setStatus(CmsStatusEnum.status1.getStatus());
             }
+            cmsContent.setName(body.getName());
             cmsContent.setType(body.getType());
             cmsContent.setImgUrl(body.getImgUrl());
             cmsContent.setJumpType(body.getJumpType());

service/src/main/java/com/hfkj/service/user/BsUserGradeService.java

@@ -1,5 +1,7 @@
 package com.hfkj.service.user;
 
+import com.hfkj.sysenum.user.UserGradeEnum;
+
 import java.util.Map;
 
 /**
@@ -9,6 +11,13 @@ import java.util.Map;
  **/
 public interface BsUserGradeService {
 
+    /**
+     * 等级调整
+     * @param userId
+     * @param userGrade
+     */
+    void gradeAdjust(Long userId, UserGradeEnum userGrade);
+
     /**
      * 等级晋升
      * @param userId

service/src/main/java/com/hfkj/service/user/BsUserService.java

@@ -46,6 +46,18 @@ public interface BsUserService {
      */
     void bindInviteUser(Long userId, Long inviteUseId) throws Exception;
 
+    /**
+     * 封号
+     */
+    void ban(Long userId) throws Exception;
+
+    /**
+     * 恢复
+     * @param userId
+     * @throws Exception
+     */
+    void restore(Long userId) throws Exception;
+
     /**
      * 注销账户
      * @param userId

service/src/main/java/com/hfkj/service/user/impl/BsUserGradeServiceImpl.java

@@ -34,6 +34,22 @@ public class BsUserGradeServiceImpl implements BsUserGradeService {
     private BsUserAccountRecordService userAccountRecordService;
     @Resource
     private BsUserParentRelService userParentRelService;
+
+    @Override
+    @Transactional(propagation= Propagation.REQUIRED,rollbackFor= {RuntimeException.class})
+    public void gradeAdjust(Long userId, UserGradeEnum userGrade) {
+        // 查询详情
+        BsUser user = userService.getUser(userId);
+        if (user == null) {
+            throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "");
+        }
+        user.setGrade(userGrade.getCode());
+        userService.editData(user);
+
+        // 修改上下级关系等级
+        userParentRelService.updateParentGrade(user.getId(), userGrade);
+    }
+
     @Override
     @Transactional(propagation= Propagation.REQUIRED,rollbackFor= {RuntimeException.class})
     public void promote(Long userId) {

service/src/main/java/com/hfkj/service/user/impl/BsUserServiceImpl.java

@@ -15,6 +15,7 @@ import com.hfkj.sysenum.user.UserAccountStatusEnum;
 import com.hfkj.sysenum.user.UserGradeEnum;
 import com.hfkj.sysenum.user.UserLoginType;
 import com.hfkj.sysenum.user.UserStatusEnum;
+import org.apache.catalina.User;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -161,6 +162,37 @@ public class BsUserServiceImpl implements BsUserService {
         userCenter.save(sessionObject);
     }
 
+    @Override
+    public void ban(Long userId) throws Exception {
+        // 查询用户
+        BsUser user = getUser(userId);
+        if (user == null) {
+            throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未找到用户");
+        }
+        if (!user.getStatus().equals(UserStatusEnum.status1.getCode())) {
+            throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "状态不正确，无法封禁");
+        }
+        user.setStatus(UserStatusEnum.status2.getCode());
+        updateInfo(user);
+
+        // 退出登录
+        userCenter.remove(userToken(user.getId()));
+    }
+
+    @Override
+    public void restore(Long userId) throws Exception {
+        // 查询用户
+        BsUser user = getUser(userId);
+        if (user == null) {
+            throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未找到用户");
+        }
+        if (!user.getStatus().equals(UserStatusEnum.status1.getCode())) {
+            throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "状态不正确，无法封禁");
+        }
+        user.setStatus(UserStatusEnum.status1.getCode());
+        updateInfo(user);
+    }
+
     @Override
     @Transactional(propagation= Propagation.REQUIRES_NEW,rollbackFor= {RuntimeException.class})
     public void delete(Long userId) throws Exception {
@@ -221,8 +253,27 @@ public class BsUserServiceImpl implements BsUserService {
     @Override
     public List<BsUser> getList(Map<String, Object> param) {
         BsUserExample example = new BsUserExample();
-        example.createCriteria().andStatusNotEqualTo(0);
+        BsUserExample.Criteria criteria = example.createCriteria().andStatusNotEqualTo(0);
+
+        if (MapUtils.getLong(param, "id") != null) {
+            criteria.andIdEqualTo(MapUtils.getLong(param, "id"));
+        }
 
+        if (StringUtils.isNotBlank(MapUtils.getString(param, "name"))) {
+            criteria.andNameLike("%"+MapUtils.getString(param, "name")+"%");
+        }
+
+        if (StringUtils.isNotBlank(MapUtils.getString(param, "phone"))) {
+            criteria.andPhoneLike("%"+MapUtils.getString(param, "phone")+"%");
+        }
+
+        if (MapUtils.getInteger(param, "grade") != null) {
+            criteria.andGradeEqualTo(MapUtils.getInteger(param, "grade"));
+        }
+
+        if (MapUtils.getInteger(param, "status") != null) {
+            criteria.andStatusEqualTo(MapUtils.getInteger(param, "status"));
+        }
 
         example.setOrderByClause("create_time desc");
         return userMapper.selectByExample(example);