From dc9239d73b15b9a51c46a9e8d25c0d4400e613ce Mon Sep 17 00:00:00 2001 From: luodangjia <luodangjia> Date: 星期一, 29 七月 2024 09:17:54 +0800 Subject: [PATCH] 7.29 --- ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/UserManageController.java | 127 ++++++++++++++++++++++-------------------- 1 files changed, 67 insertions(+), 60 deletions(-) diff --git a/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/UserManageController.java b/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/UserManageController.java index 260bd64..5e310fa 100644 --- a/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/UserManageController.java +++ b/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/UserManageController.java @@ -3,14 +3,22 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; -import com.ruoyi.admin.entity.*; -import com.ruoyi.admin.service.*; -import com.ruoyi.admin.vo.EvaluatePageVO; -import com.ruoyi.admin.vo.UserWithdrawRecordVO; -import com.ruoyi.common.core.constant.Constants; +import com.ruoyi.admin.entity.User; +import com.ruoyi.admin.service.UserService; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.exception.GlobalException; import com.ruoyi.common.core.utils.StringUtils; +import com.ruoyi.common.security.annotation.Logical; +import com.ruoyi.common.security.annotation.RequiresPermissions; +import com.ruoyi.common.security.service.TokenService; +import com.ruoyi.order.api.entity.EvaluatePageVO; +import com.ruoyi.order.api.entity.Order; +import com.ruoyi.order.api.entity.UserWithdrawRecordVO; +import com.ruoyi.order.api.entity.WithdrawalSetting; +import com.ruoyi.order.api.feignClient.EvaluateClient; +import com.ruoyi.order.api.feignClient.OrderClient; +import com.ruoyi.order.api.feignClient.WithdrawClient; +import com.ruoyi.system.api.model.LoginUser; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; @@ -36,15 +44,15 @@ public class UserManageController { @Resource - private OrderService orderService; - @Resource - private EvaluateService evaluateService; - @Resource - private WithdrawService withdrawService; - @Resource private UserService userService; @Resource - private WithdrawalSettingService withdrawalSettingService; + private OrderClient orderClient; + @Resource + private EvaluateClient evaluateClient; + @Resource + private WithdrawClient withdrawClient; + @Resource + private TokenService tokenService; /** * 用户信息分页列表 @@ -52,6 +60,7 @@ * @param pageNum 页码 * @param pageSize 每页显示条数 */ + @RequiresPermissions("user_list") @ApiOperation(value = "用户管理-用户分页列表", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/page") @ApiImplicitParams({ @@ -79,6 +88,7 @@ * * @param id 前台用户id */ + @RequiresPermissions("user_detail") @ApiOperation(value = "用户管理-用户详情", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/detail") @ApiImplicitParams({ @@ -93,6 +103,7 @@ * * @param ids 前台用户多条id拼接 */ + @RequiresPermissions("user_delete") @ApiOperation(value = "用户管理-批量删除用户", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/batchDelete") @ApiImplicitParams({ @@ -113,18 +124,23 @@ * @param pageSize 每页显示条数 * @return 分页列表 */ + @RequiresPermissions("user_detail") @ApiOperation(value = "用户详情-订单记录分页列表", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/orderList") @ApiImplicitParams({ - @ApiImplicitParam(value = "用户id", name = "userId", dataType = "Integer"), + @ApiImplicitParam(value = "用户id", name = "userId", dataType = "Integer", required = true), @ApiImplicitParam(value = "页码", name = "pageNum", dataType = "Integer", required = true), @ApiImplicitParam(value = "每页条数", name = "pageSize", dataType = "Integer", required = true) }) - public R<IPage<Order>> orderList(Integer userId, + public R<IPage<Order>> orderList(@RequestParam("userId") Integer userId, @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { - return R.ok(orderService.lambdaQuery().eq(Order::getUserId, userId) - .eq(Order::getIsDelete, 0).page(Page.of(pageNum, pageSize))); + LoginUser loginUser = tokenService.getLoginUser(); + if (null == loginUser) { + return R.loginExpire("登录失效!"); + } + R<Page<Order>> iPageR = orderClient.orderList(userId, pageNum, pageSize); + return R.ok(iPageR.getData()); } /** @@ -135,6 +151,7 @@ * @param pageSize 每页显示条数 * @return 分页列表 */ + @RequiresPermissions("user_detail") @ApiOperation(value = "用户详情-评价记录分页列表", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/evaluateList") @ApiImplicitParams({ @@ -142,10 +159,10 @@ @ApiImplicitParam(value = "页码", name = "pageNum", dataType = "Integer", required = true), @ApiImplicitParam(value = "每页条数", name = "pageSize", dataType = "Integer", required = true) }) - public R<IPage<EvaluatePageVO>> evaluateList(Integer userId, - @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, - @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { - return R.ok(evaluateService.evaluateList(userId, Page.of(pageNum, pageSize))); + public R<Page<EvaluatePageVO>> evaluateList(Integer userId, + @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, + @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { + return evaluateClient.evaluateList(userId, pageNum, pageSize); } /** @@ -153,15 +170,14 @@ * * @param id 评价记录id */ + @RequiresPermissions("user_detail") @ApiOperation(value = "用户详情-删除评价记录", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/deleteEvaluateRecord") @ApiImplicitParams({ @ApiImplicitParam(value = "评价记录id", name = "id", dataType = "Integer", required = true) }) - public R<Void> deleteEvaluateRecord(@RequestParam Integer id) { - Evaluate evaluate = evaluateService.getById(id); - evaluate.setIsDelete(1); - return evaluateService.updateById(evaluate) ? R.ok() : R.fail(); + public R<String> deleteEvaluateRecord(@RequestParam Integer id) { + return evaluateClient.batchDelete(String.valueOf(id)); } /** @@ -169,13 +185,14 @@ * * @return 操作结果 */ + @RequiresPermissions("user_withdrawal_setting") @ApiOperation(value = "关闭/开启审核", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/enableProcess") @ApiImplicitParams({ @ApiImplicitParam(value = "审核状态(0:未开启,1:已开启)", name = "enableProcess", dataType = "Integer", required = true) }) public R<Boolean> enableProcess(@RequestParam("enableProcess") Integer enableProcess) { - return R.ok(withdrawService.enableProcess(enableProcess)); + return withdrawClient.enableProcess(enableProcess); } /** @@ -186,7 +203,7 @@ */ @GetMapping(value = "/withdrawProcess") public R<WithdrawalSetting> withdrawProcess() { - return R.ok(withdrawService.withdrawProcess()); + return withdrawClient.withdrawProcess(); } /** @@ -195,9 +212,7 @@ @ApiOperation(value = "全局审核状态", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/withdrawState") public R<WithdrawalSetting> withdrawState() { - // 全局审核设置 - WithdrawalSetting setting = withdrawalSettingService.lambdaQuery().one(); - return R.ok(setting); + return withdrawClient.withdrawProcess(); } /** @@ -208,6 +223,7 @@ * @param pageSize 每页显示条数 * @return 分页列表 */ + @RequiresPermissions("user_detail") @ApiOperation(value = "用户详情-提现记录分页列表", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/withdrawList") @ApiImplicitParams({ @@ -215,10 +231,10 @@ @ApiImplicitParam(value = "页码", name = "pageNum", dataType = "Integer", required = true), @ApiImplicitParam(value = "每页条数", name = "pageSize", dataType = "Integer", required = true) }) - public R<IPage<UserWithdrawRecordVO>> withdrawList(@RequestParam Integer userId, - @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, - @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { - return R.ok(withdrawService.withdrawList(userId, Page.of(pageNum, pageSize))); + public R<Page<UserWithdrawRecordVO>> withdrawList(@RequestParam Integer userId, + @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, + @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { + return withdrawClient.withdrawList(userId, pageNum, pageSize); } /** @@ -226,15 +242,14 @@ * * @param id 提现记录id */ + @RequiresPermissions(value = {"user_detail", "user_withdrawal_delete"}, logical = Logical.OR) @ApiOperation(value = "用户详情/用户提现管理-删除提现记录", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/deleteWithdrawRecord") @ApiImplicitParams({ @ApiImplicitParam(value = "提现记录id", name = "id", dataType = "Integer", required = true) }) - public R<Void> deleteWithdrawRecord(@RequestParam Integer id) { - Withdraw withdraw = withdrawService.getById(id); - withdraw.setIsDelete(1); - return withdrawService.updateById(withdraw) ? R.ok() : R.fail(); + public R<String> deleteWithdrawRecord(@RequestParam Integer id) { + return withdrawClient.batchDelete(String.valueOf(id)); } /** @@ -244,6 +259,7 @@ * @param state 审批结果 * @param opinion 审批意见 */ + @RequiresPermissions(value = {"user_detail", "user_withdrawal_audit"}, logical = Logical.OR) @ApiOperation(value = "用户详情/用户提现管理-提现审批", tags = {"后台-用户管理-用户列表"}) @GetMapping(value = "/withdrawExamine") @ApiImplicitParams({ @@ -251,32 +267,23 @@ @ApiImplicitParam(value = "审批意见", name = "opinion", dataType = "String"), @ApiImplicitParam(value = "审批同意/不同意(1同意;2驳回)", name = "state", dataType = "Integer", required = true) }) - public R<String> withdrawExamine(@RequestParam Integer id, @RequestParam Integer state, String opinion) { - Withdraw withdraw = withdrawService.lambdaQuery().eq(Withdraw::getId, id).eq(Withdraw::getIsDelete, 0) - .eq(Withdraw::getState, 0).one(); + public R<String> withdrawExamine(@RequestParam Long id, @RequestParam Integer state, String opinion) { + com.ruoyi.order.api.entity.Withdraw withdraw = withdrawClient.withdrawRecordDetail(id).getData(); if (null == withdraw) { - return R.fail(503, "当前提现记录审批状态异常!"); + throw new GlobalException("提现记录不存在或已删除!"); } - // 修改审批状态及审批意见 - withdraw.setState(state); - withdraw.setOpinion(opinion); - // 同意提现申请,更改订单提现状态 - boolean update = true; - if (Constants.ONE.equals(state)) { - update = orderService.lambdaUpdate().set(Order::getIsWithdrawal, Constants.ONE) - .eq(Order::getId, withdraw.getOrderId()).eq(Order::getIsDelete, 0).update(); - // 商家打款至用户微信零钱 - User user = userService.lambdaQuery().eq(User::getId, withdraw.getUserId()) - .eq(User::getIsDelete, 0).one(); - Order order = orderService.lambdaQuery().eq(Order::getId, withdraw.getOrderId()) - .eq(Order::getIsDelete, 0).one(); - if (null == order) { - throw new GlobalException("订单信息异常!"); - } - Boolean b = withdrawService.confirmWithdraw(user, order); + User user = userService.lambdaQuery() + .eq(User::getId, withdraw.getUserId()) + .eq(User::getIsDelete, 0).one(); + if (null == user) { + throw new GlobalException("提交申请的用户信息不存在!"); } - update = update && withdrawService.updateById(withdraw); - return update ? R.ok(null, "审批成功!") : R.fail("审批失败!"); + Boolean data = withdrawClient.withdrawExamine(id, state, opinion, user.getOpenId(), user.getId()).getData(); + if (null != data) { + return data ? R.ok(null, "审批成功!") : R.fail("审批失败!"); + } else { + return R.fail("审批失败!"); + } } } -- Gitblit v1.7.1