岐济生
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
luofl
2025-03-06 2ed6444f45d227e2acc6de65c3e8b582440fb83a 
 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/controller/ShopBalanceStatementController.java


@@ -1,27 +1,36 @@


package com.ruoyi.other.controller;






import com.alibaba.fastjson2.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


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.common.core.domain.R;


import com.ruoyi.common.core.exception.ServiceException;


import com.ruoyi.common.core.utils.StringUtils;


import com.ruoyi.common.core.utils.poi.ExcelUtil;


import com.ruoyi.common.security.service.TokenService;


import com.ruoyi.other.api.domain.Shop;


import com.ruoyi.other.api.domain.ShopBalanceStatement;


import com.ruoyi.other.api.domain.ShopBalanceStatementCopy;


import com.ruoyi.other.api.domain.ShopWithdraw;


import com.ruoyi.other.dto.ShopBalanceDto;


import com.ruoyi.other.mapper.ShopBalanceStatementCopyMapper;


import com.ruoyi.other.mapper.ShopBalanceStatementMapper;


import com.ruoyi.other.service.ShopBalanceStatementService;


import com.ruoyi.other.service.ShopService;


import com.ruoyi.other.service.ShopWithdrawService;


import com.ruoyi.other.vo.ShopBalanceStatementDetailPage;


import com.ruoyi.other.vo.ShopCommission;


import com.ruoyi.other.vo.ShopCommissionDetail;


import com.ruoyi.other.vo.ShopCommissionStatisticsVO;


import com.ruoyi.system.api.domain.SysUser;


import com.ruoyi.system.api.feignClient.SysUserClient;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import io.swagger.annotations.ApiParam;


import org.apache.commons.lang3.tuple.Pair;


import org.springframework.web.bind.annotation.*;




import javax.annotation.Resource;


@@ -29,9 +38,11 @@


import java.math.BigDecimal;


import java.time.LocalDateTime;


import java.time.LocalTime;


import java.util.Collection;


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.List;


import java.util.List;


import java.util.stream.Collectors;


import java.util.stream.Stream;




/**


 * <p>


@@ -57,9 +68,8 @@


    private SysUserClient sysUserClient;


    @Resource


    private ShopBalanceStatementCopyMapper shopBalanceStatementCopyMapper;


    


    


    


    @Resource


    private ShopWithdrawService shopWithdrawService;


    




    /**


@@ -73,6 +83,7 @@


        ShopCommissionStatisticsVO shopCommissionStatisticsVO = shopBalanceStatementService.shopCommissionStatistics(Page.of(pageNum, pageSize), shopBalanceStatement);


        return R.ok(shopCommissionStatisticsVO);


    }




    /**


     * 导出门店分佣统计


     */


@@ -84,6 +95,7 @@


        ExcelUtil<ShopBalanceStatement> util = new ExcelUtil<>(ShopBalanceStatement.class);


        util.exportExcel(response, statementIPage.getRecords(), "用户积分统计");


    }




    @GetMapping("/commissionStatistics/list")


    @ApiOperation(value = "门店余额明细", notes = "门店余额明细", tags = {"门店后台"})


    public R<Page<ShopBalanceStatement>> shopCommissionStatisticslist(@ApiParam("页码") @RequestParam Integer pageNum,


@@ -186,10 +198,6 @@


    }














    @PostMapping("/getList")


    public R<List<ShopBalanceStatement>> getList(@RequestBody ShopBalanceStatement shopBalanceStatement){


        return R.ok(shopBalanceStatementMapper.selectShopBalanceStatementList(shopBalanceStatement));


@@ -198,6 +206,7 @@


    


    /**


     * 保存门店余额流水


     *


     * @param shopBalanceStatement


     */


    @PostMapping("/saveShopBalanceStatement")


@@ -226,9 +235,9 @@


    }


    






    /**


     * 获取门店流水数据


     *


     * @param types


     * @param objectId


     * @return


@@ -253,5 +262,157 @@


        List<ShopBalanceStatement> list = shopBalanceStatementService.list(queryWrapper);


        return R.ok(list);


    }






    /**


     * 获取门店佣金


     *


     * @param shopId


     * @return


     */


    @GetMapping("getShopCommission")


    @ApiOperation(value = "获取门店佣金", notes = "获取门店佣金", tags = {"小程序-个人中心-门店管理-门店钱包"})


    public R<ShopCommission> getShopCommission(@RequestParam("shopId") Integer shopId) {


        // 合并查询逻辑


        List<ShopBalanceStatementCopy> copies = shopBalanceStatementCopyMapper.selectList(


                new LambdaQueryWrapper<ShopBalanceStatementCopy>()


                        .eq(ShopBalanceStatementCopy::getShopId, shopId));




        List<ShopBalanceStatement> statements = shopBalanceStatementService.list(


                new LambdaQueryWrapper<ShopBalanceStatement>()


                        .eq(ShopBalanceStatement::getShopId, shopId));




        // 合并计算


        Map<Integer, BigDecimal> result = Stream.concat(


                copies.stream().map(e -> Pair.of(e.getType(), e.getVariableAmount())),


                statements.stream().map(e -> Pair.of(e.getType(), e.getVariableAmount()))


        ).collect(Collectors.groupingBy(


                Pair::getKey,


                Collectors.mapping(Pair::getValue, Collectors.reducing(BigDecimal.ZERO, BigDecimal::add))


        ));




        // 待审核佣金


        BigDecimal waitingAudit = shopWithdrawService.list(new LambdaQueryWrapper<ShopWithdraw>()


                        .eq(ShopWithdraw::getShopId, shopId)


                        .eq(ShopWithdraw::getAuditStatus, 0))


                .stream()


                .map(ShopWithdraw::getMoney)


                .reduce(BigDecimal.ZERO, BigDecimal::add);




        // 店铺信息校验


        Shop shop = shopService.getById(shopId);


        if (shop == null) {


            throw new ServiceException("店铺不存在");


        }




        // 构建结果




        List<ShopWithdraw> list = shopWithdrawService.lambdaQuery().eq(ShopWithdraw::getShopId, shopId)


                .eq(ShopWithdraw::getAuditStatus, 0).list();


        BigDecimal withdrawAuditMoney = list.stream().map(ShopWithdraw::getMoney).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);




        ShopCommission commission = new ShopCommission();


        commission.setCanWithdrawCommission(shop.getCanWithdrawMoney());


        commission.setWithdrawnCommission(shop.getWithdrawMoney().subtract(withdrawAuditMoney));


        commission.setCommissionAmount(


                result.getOrDefault(1, BigDecimal.ZERO)


                        .add(result.getOrDefault(2, BigDecimal.ZERO)


                                .add(result.getOrDefault(3, BigDecimal.ZERO))


                        ));


        commission.setWaitingAuditCommission(waitingAudit);


        commission.setTotalAmount(commission.getCommissionAmount());




        return R.ok(commission);


    }




    /**


     * 获取门店佣金明细


     */


    @GetMapping("/getshopCommissionStatisticsDetail")


    @ApiOperation(value = "门店返佣明细", notes = "门店返佣明细", tags = {"小程序-个人中心-门店管理-门店钱包"})


    public R<ShopBalanceStatementDetailPage> shopCommissionStatisticsDetail(@ApiParam("店铺id") Integer shopId,


                                                                            @ApiParam("类型") Integer type,


                                                                            @ApiParam("开始时间") String createTime,


                                                                            @ApiParam("页码") Integer pageNum,


                                                                            @ApiParam("每一页数据大小") Integer pageSize) {




        LocalDateTime startDate = null;


        LocalDateTime endDate = null;


        if (StringUtils.isNotEmpty(createTime)){


            startDate = LocalDateTime.parse(createTime + " 00:00:00", DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));


            endDate = LocalDateTime.parse(createTime + " 23:59:59", DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));


        }




        List<ShopBalanceStatementCopy> copies = shopBalanceStatementCopyMapper.selectList(


                new LambdaQueryWrapper<ShopBalanceStatementCopy>()


                        .eq(ShopBalanceStatementCopy::getShopId, shopId)


                        .eq(type != null, ShopBalanceStatementCopy::getType, type)


                        .between(startDate != null && endDate != null, ShopBalanceStatementCopy::getCreateTime,


                                startDate, endDate));




        List<ShopBalanceStatement> statements = shopBalanceStatementService.list(


                new LambdaQueryWrapper<ShopBalanceStatement>()


                        .eq(ShopBalanceStatement::getShopId, shopId)


                        .eq(type != null, ShopBalanceStatement::getType, type)


                        .between(startDate != null && endDate != null, ShopBalanceStatement::getCreateTime,


                                startDate, endDate));




        Map<Integer, String> itemMap = new HashMap<>();


        itemMap.put(1, "服务商分佣");


        itemMap.put(2, "高级服务商分佣");


        itemMap.put(3, "核销门店服务费");


        itemMap.put(4, "提现");




        List<ShopCommissionDetail> list = new ArrayList<>();


        for (ShopBalanceStatementCopy copy : copies) {


            ShopCommissionDetail detail = new ShopCommissionDetail();


            detail.setItem(itemMap.get(copy.getType()));


            detail.setTime(copy.getCreateTime());


            detail.setAmount(copy.getVariableAmount());




            BigDecimal beforeAmount = copy.getHistoricalBalance();


            BigDecimal afterAmount = copy.getBalance();


            if (beforeAmount.compareTo(afterAmount) > 0) {


                detail.setType(2);


            } else {


                detail.setType(1);


            }


            list.add(detail);


        }




        for (ShopBalanceStatement statement : statements) {


            ShopCommissionDetail detail = new ShopCommissionDetail();


            detail.setItem(itemMap.get(statement.getType()));


            detail.setTime(statement.getCreateTime());


            detail.setAmount(statement.getVariableAmount());




            BigDecimal beforeAmount = statement.getHistoricalBalance();


            BigDecimal afterAmount = statement.getBalance();


            if (beforeAmount.compareTo(afterAmount) > 0) {


                detail.setType(2);


            } else {


                detail.setType(1);


            }


            list.add(detail);


        }




        // 按时间排序加手动分页


        Integer total = list.size();


        list.sort(Comparator.comparing(ShopCommissionDetail::getTime).reversed());


        if (pageNum != null && pageSize != null) {


            int fromIndex = (pageNum - 1) * pageSize;


            int toIndex = Math.min(fromIndex + pageSize, list.size());


            list = list.subList(fromIndex, toIndex);


        }




        ShopBalanceStatementDetailPage page = new ShopBalanceStatementDetailPage();


        page.setRecords(list);


        page.setTotal(total);


        page.setPageSize(pageSize);


        page.setPageNum(pageNum);


        return R.ok(page);


    }






}