package cn.iocoder.yudao.module.trade.controller.app.brokerage;
|
|
import cn.hutool.core.date.LocalDateTimeUtil;
|
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.trade.controller.app.brokerage.vo.user.*;
|
import cn.iocoder.yudao.module.trade.convert.brokerage.BrokerageRecordConvert;
|
import cn.iocoder.yudao.module.trade.convert.brokerage.BrokerageUserConvert;
|
import cn.iocoder.yudao.module.trade.dal.dataobject.brokerage.BrokerageUserDO;
|
import cn.iocoder.yudao.module.trade.enums.brokerage.BrokerageRecordBizTypeEnum;
|
import cn.iocoder.yudao.module.trade.enums.brokerage.BrokerageRecordStatusEnum;
|
import cn.iocoder.yudao.module.trade.enums.brokerage.BrokerageWithdrawStatusEnum;
|
import cn.iocoder.yudao.module.trade.service.brokerage.BrokerageRecordService;
|
import cn.iocoder.yudao.module.trade.service.brokerage.BrokerageUserService;
|
import cn.iocoder.yudao.module.trade.service.brokerage.BrokerageWithdrawService;
|
import cn.iocoder.yudao.module.trade.service.brokerage.bo.BrokerageWithdrawSummaryRespBO;
|
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.Resource;
|
import jakarta.validation.Valid;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.format.annotation.DateTimeFormat;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.time.LocalDateTime;
|
import java.util.Collections;
|
import java.util.Map;
|
import java.util.Optional;
|
|
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.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
|
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
|
import static java.util.Arrays.asList;
|
|
@Tag(name = "用户 APP - 分销用户")
|
@RestController
|
@RequestMapping("/trade/brokerage-user")
|
@Validated
|
@Slf4j
|
public class AppBrokerageUserController {
|
|
@Resource
|
private BrokerageUserService brokerageUserService;
|
@Resource
|
private BrokerageRecordService brokerageRecordService;
|
@Resource
|
private BrokerageWithdrawService brokerageWithdrawService;
|
@Resource
|
private MemberUserApi memberUserApi;
|
|
@GetMapping("/get")
|
@Operation(summary = "获得个人分销信息")
|
public CommonResult<AppBrokerageUserRespVO> getBrokerageUser() {
|
Optional<BrokerageUserDO> user = Optional.ofNullable(brokerageUserService.getOrCreateBrokerageUser(getLoginUserId()));
|
// 返回数据
|
AppBrokerageUserRespVO respVO = new AppBrokerageUserRespVO()
|
.setBrokerageEnabled(user.map(BrokerageUserDO::getBrokerageEnabled).orElse(false))
|
.setBrokeragePrice(user.map(BrokerageUserDO::getBrokeragePrice).orElse(0))
|
.setFrozenPrice(user.map(BrokerageUserDO::getFrozenPrice).orElse(0));
|
return success(respVO);
|
}
|
|
@PutMapping("/bind")
|
@Operation(summary = "绑定推广员")
|
public CommonResult<Boolean> bindBrokerageUser(@Valid @RequestBody AppBrokerageUserBindReqVO reqVO) {
|
return success(brokerageUserService.bindBrokerageUser(getLoginUserId(), reqVO.getBindUserId()));
|
}
|
|
@GetMapping("/get-summary")
|
@Operation(summary = "获得个人分销统计")
|
public CommonResult<AppBrokerageUserMySummaryRespVO> getBrokerageUserSummary() {
|
// 查询当前登录用户信息
|
Long userId = getLoginUserId();
|
BrokerageUserDO brokerageUser = brokerageUserService.getBrokerageUser(userId);
|
// 统计用户昨日的佣金
|
LocalDateTime yesterday = LocalDateTime.now().minusDays(1);
|
LocalDateTime beginTime = LocalDateTimeUtil.beginOfDay(yesterday);
|
LocalDateTime endTime = LocalDateTimeUtil.endOfDay(yesterday);
|
Integer yesterdayPrice = brokerageRecordService.getSummaryPriceByUserId(userId,
|
BrokerageRecordBizTypeEnum.ORDER, BrokerageRecordStatusEnum.SETTLEMENT, beginTime, endTime);
|
// 统计用户提现的佣金
|
Integer withdrawPrice = brokerageWithdrawService.getWithdrawSummaryListByUserId(Collections.singleton(userId),
|
asList(BrokerageWithdrawStatusEnum.AUDIT_SUCCESS, BrokerageWithdrawStatusEnum.WITHDRAW_SUCCESS)).stream()
|
.findFirst().map(BrokerageWithdrawSummaryRespBO::getPrice).orElse(0);
|
// 统计分销用户数量（一级）
|
Long firstBrokerageUserCount = brokerageUserService.getBrokerageUserCountByBindUserId(userId, 1);
|
// 统计分销用户数量（二级）
|
Long secondBrokerageUserCount = brokerageUserService.getBrokerageUserCountByBindUserId(userId, 2);
|
|
// 拼接返回
|
return success(BrokerageUserConvert.INSTANCE.convert(yesterdayPrice, withdrawPrice, firstBrokerageUserCount, secondBrokerageUserCount, brokerageUser));
|
}
|
|
@GetMapping("/rank-page-by-user-count")
|
@Operation(summary = "获得分销用户排行分页（基于用户量）")
|
public CommonResult<PageResult<AppBrokerageUserRankByUserCountRespVO>> getBrokerageUserRankPageByUserCount(AppBrokerageUserRankPageReqVO pageReqVO) {
|
// 分页查询
|
PageResult<AppBrokerageUserRankByUserCountRespVO> pageResult = brokerageUserService.getBrokerageUserRankPageByUserCount(pageReqVO);
|
// 拼接数据
|
Map<Long, MemberUserRespDTO> userMap = memberUserApi.getUserMap(convertSet(pageResult.getList(), AppBrokerageUserRankByUserCountRespVO::getId));
|
return success(BrokerageUserConvert.INSTANCE.convertPage03(pageResult, userMap));
|
}
|
|
@GetMapping("/rank-page-by-price")
|
@Operation(summary = "获得分销用户排行分页（基于佣金）")
|
public CommonResult<PageResult<AppBrokerageUserRankByPriceRespVO>> getBrokerageUserChildSummaryPageByPrice(AppBrokerageUserRankPageReqVO pageReqVO) {
|
// 分页查询
|
PageResult<AppBrokerageUserRankByPriceRespVO> pageResult = brokerageRecordService.getBrokerageUserChildSummaryPageByPrice(pageReqVO);
|
// 拼接数据
|
Map<Long, MemberUserRespDTO> userMap = memberUserApi.getUserMap(convertSet(pageResult.getList(), AppBrokerageUserRankByPriceRespVO::getId));
|
return success(BrokerageRecordConvert.INSTANCE.convertPage03(pageResult, userMap));
|
}
|
|
@GetMapping("/child-summary-page")
|
@Operation(summary = "获得下级分销统计分页")
|
public CommonResult<PageResult<AppBrokerageUserChildSummaryRespVO>> getBrokerageUserChildSummaryPage(
|
AppBrokerageUserChildSummaryPageReqVO pageReqVO) {
|
PageResult<AppBrokerageUserChildSummaryRespVO> pageResult = brokerageUserService.getBrokerageUserChildSummaryPage(pageReqVO, getLoginUserId());
|
return success(pageResult);
|
}
|
|
@GetMapping("/get-rank-by-price")
|
@Operation(summary = "获得分销用户排行（基于佣金）")
|
@Parameter(name = "times", description = "时间段", required = true)
|
public CommonResult<Integer> getRankByPrice(
|
@RequestParam("times") @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) LocalDateTime[] times) {
|
return success(brokerageRecordService.getUserRankByPrice(getLoginUserId(), times));
|
}
|
|
}
|
