package cn.iocoder.yudao.module.trade.controller.admin.brokerage;
|
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.module.member.api.user.MemberUserApi;
|
import cn.iocoder.yudao.module.member.api.user.dto.MemberUserRespDTO;
|
import cn.iocoder.yudao.module.pay.api.notify.dto.PayTransferNotifyReqDTO;
|
import cn.iocoder.yudao.module.trade.controller.admin.brokerage.vo.withdraw.BrokerageWithdrawRejectReqVO;
|
import cn.iocoder.yudao.module.trade.controller.admin.brokerage.vo.withdraw.BrokerageWithdrawPageReqVO;
|
import cn.iocoder.yudao.module.trade.controller.admin.brokerage.vo.withdraw.BrokerageWithdrawRespVO;
|
import cn.iocoder.yudao.module.trade.convert.brokerage.BrokerageWithdrawConvert;
|
import cn.iocoder.yudao.module.trade.dal.dataobject.brokerage.BrokerageWithdrawDO;
|
import cn.iocoder.yudao.module.trade.enums.brokerage.BrokerageWithdrawStatusEnum;
|
import cn.iocoder.yudao.module.trade.service.brokerage.BrokerageWithdrawService;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import jakarta.annotation.security.PermitAll;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import jakarta.annotation.Resource;
|
import jakarta.validation.Valid;
|
import java.util.Map;
|
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
|
import static cn.iocoder.yudao.framework.common.util.servlet.ServletUtils.getClientIP;
|
|
@Tag(name = "管理后台 - 佣金提现")
|
@RestController
|
@RequestMapping("/trade/brokerage-withdraw")
|
@Validated
|
@Slf4j
|
public class BrokerageWithdrawController {
|
|
@Resource
|
private BrokerageWithdrawService brokerageWithdrawService;
|
|
@Resource
|
private MemberUserApi memberUserApi;
|
|
@PutMapping("/approve")
|
@Operation(summary = "通过申请")
|
@PreAuthorize("@ss.hasPermission('trade:brokerage-withdraw:audit')")
|
public CommonResult<Boolean> approveBrokerageWithdraw(@RequestParam("id") Long id) {
|
brokerageWithdrawService.auditBrokerageWithdraw(id,
|
BrokerageWithdrawStatusEnum.AUDIT_SUCCESS, "", getClientIP());
|
return success(true);
|
}
|
|
@PutMapping("/reject")
|
@Operation(summary = "驳回申请")
|
@PreAuthorize("@ss.hasPermission('trade:brokerage-withdraw:audit')")
|
public CommonResult<Boolean> rejectBrokerageWithdraw(@Valid @RequestBody BrokerageWithdrawRejectReqVO reqVO) {
|
brokerageWithdrawService.auditBrokerageWithdraw(reqVO.getId(),
|
BrokerageWithdrawStatusEnum.AUDIT_FAIL, reqVO.getAuditReason(), getClientIP());
|
return success(true);
|
}
|
|
@GetMapping("/get")
|
@Operation(summary = "获得佣金提现")
|
@Parameter(name = "id", description = "编号", required = true, example = "1024")
|
@PreAuthorize("@ss.hasPermission('trade:brokerage-withdraw:query')")
|
public CommonResult<BrokerageWithdrawRespVO> getBrokerageWithdraw(@RequestParam("id") Long id) {
|
BrokerageWithdrawDO brokerageWithdraw = brokerageWithdrawService.getBrokerageWithdraw(id);
|
return success(BrokerageWithdrawConvert.INSTANCE.convert(brokerageWithdraw));
|
}
|
|
@GetMapping("/page")
|
@Operation(summary = "获得佣金提现分页")
|
@PreAuthorize("@ss.hasPermission('trade:brokerage-withdraw:query')")
|
public CommonResult<PageResult<BrokerageWithdrawRespVO>> getBrokerageWithdrawPage(@Valid BrokerageWithdrawPageReqVO pageVO) {
|
// 分页查询
|
PageResult<BrokerageWithdrawDO> pageResult = brokerageWithdrawService.getBrokerageWithdrawPage(pageVO);
|
|
// 拼接信息
|
Map<Long, MemberUserRespDTO> userMap = memberUserApi.getUserMap(
|
convertSet(pageResult.getList(), BrokerageWithdrawDO::getUserId));
|
return success(BrokerageWithdrawConvert.INSTANCE.convertPage(pageResult, userMap));
|
}
|
|
@PostMapping("/update-transferred")
|
@Operation(summary = "更新佣金提现的转账结果") // 由 pay-module 支付服务，进行回调，可见 PayNotifyJob
|
@PermitAll // 无需登录，安全由 BrokerageWithdrawService 内部校验实现
|
public CommonResult<Boolean> updateBrokerageWithdrawTransferred(@RequestBody PayTransferNotifyReqDTO notifyReqDTO) {
|
log.info("[updateAfterRefund][notifyReqDTO({})]", notifyReqDTO);
|
brokerageWithdrawService.updateBrokerageWithdrawTransferred(
|
Long.parseLong(notifyReqDTO.getMerchantTransferId()), notifyReqDTO.getPayTransferId());
|
return success(true);
|
}
|
|
}
|
