二手家电回收
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
昨天 1442f149019ee0590389abd7a88a79c4d9b59034 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/WithdrawServiceImpl.java


@@ -1,4 +1,6 @@


package com.ruoyi.order.service.impl;


import java.io.InputStream;


import java.util.Date;




import com.alibaba.fastjson2.JSONObject;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


@@ -6,31 +8,39 @@


import com.ruoyi.common.core.constant.Constants;


import com.ruoyi.common.core.constant.OrderConstants;


import com.ruoyi.common.core.constant.WechatConstants;


import com.ruoyi.common.core.domain.R;


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


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


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


import com.ruoyi.common.core.vo.UserDto;


import com.ruoyi.common.redis.service.RedisService;


import com.ruoyi.order.entity.Order;


import com.ruoyi.order.entity.Withdraw;


import com.ruoyi.order.entity.WithdrawDetail;


import com.ruoyi.order.entity.WithdrawalSetting;


import com.ruoyi.order.mapper.WithdrawMapper;


import com.ruoyi.order.request.WithdrawExportRequest;


import com.ruoyi.order.service.OrderService;


import com.ruoyi.order.service.WithdrawDetailService;


import com.ruoyi.order.service.WithdrawService;


import com.ruoyi.order.service.WithdrawalSettingService;


import com.ruoyi.order.vo.MoneyQueryRequest;


import com.ruoyi.order.vo.UserWithdrawRecordVO;


import com.ruoyi.order.vx.HttpUtil;


import com.ruoyi.user.api.feignClient.UserClient;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.core.io.ClassPathResource;


import org.springframework.stereotype.Service;




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.time.LocalDate;


import java.time.Month;


import java.time.Year;


import java.time.temporal.TemporalAdjusters;


import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;




/**


@@ -48,7 +58,8 @@


    private WithdrawalSettingService withdrawalSettingService;


    @Resource


    private OrderService orderService;




    @Resource


    private RedisService redisService;


    /**


     * 雪花算法类


     */


@@ -79,10 +90,20 @@


     */


    @Value("wx.transferRemark")


    private String transferRemark;


    @Resource


    private UserClient userClient;




    @Override


    public Page<UserWithdrawRecordVO> withdrawPage(String nickname, String userPhone, String applyForTime, Integer state, Page<UserWithdrawRecordVO> page) {


        return baseMapper.withdrawPage(nickname, userPhone, applyForTime, state, page);


    public Page<UserWithdrawRecordVO> withdrawPage(List<Integer> userIds,String nickname, String userPhone, String applyForTime, Integer state, Page<UserWithdrawRecordVO> page) {


        Page<UserWithdrawRecordVO> userWithdrawRecordVOPage = baseMapper.withdrawPage(userIds,nickname, userPhone, applyForTime, state, page);




        return userWithdrawRecordVOPage;


    }


    @Override


    public Page<UserWithdrawRecordVO> withdrawPage1(List<String> cityList,List<Integer> userIds,String nickname, String userPhone, String applyForTime, Integer state, Page<UserWithdrawRecordVO> page,List<String> siteIds) {


        Page<UserWithdrawRecordVO> userWithdrawRecordVOPage = baseMapper.withdrawPage1(cityList,userIds,nickname, userPhone, applyForTime, state, page,siteIds);




        return userWithdrawRecordVOPage;


    }




    @Override


@@ -99,6 +120,11 @@


        } else {


            list = baseMapper.exportList(nickname, userPhone, applyForTime, state);


        }


        for (UserWithdrawRecordVO userWithdrawRecordVO : list) {


            R<UserDto> user = userClient.getUser(userWithdrawRecordVO.getUserId());


            userWithdrawRecordVO.setUserNo(user.getData().getUserNo());


            userWithdrawRecordVO.setNickname(user.getData().getNickname());


        }


        return list;


    }




@@ -111,7 +137,8 @@


        if (stateList.contains(Constants.ONE)) {


            throw new GlobalException("当前订单提现申请已通过！");


        }


        return weChatPay(order.getOrderMoney(), openId);




        return weChatPay(order.getSubsidy()!=null?order.getSubsidy().add(order.getOrderMoney()):order.getOrderMoney(), openId,list.get(0).getId(),order.getServeName());


    }




    @Override


@@ -128,15 +155,18 @@


        String startDateStr = String.valueOf(startDate);


        String endDateStr = String.valueOf(endDate);


        BigDecimal withdrawalTotalMoney;


        if (request.getSiteIds()==null){


            request.setSiteIds(new ArrayList<>());


        }


        if (OrderConstants.QUARTER.equals(type)) {


            // 用户提现总额


            withdrawalTotalMoney = baseMapper.withdrawalTotalMoney(cityList, startDateStr, endDateStr);


            withdrawalTotalMoney = baseMapper.withdrawalTotalMoney(cityList, startDateStr, endDateStr,request.getSiteIds());


        } else if (OrderConstants.YEAR.equals(type)) {


            // 用户提现总额


            withdrawalTotalMoney = baseMapper.withdrawalTotalMoneyByYear(cityList);


            withdrawalTotalMoney = baseMapper.withdrawalTotalMoneyByYear(cityList,request.getSiteIds());


        } else if (OrderConstants.MONTH.equals(type)) {


            // 用户提现总额


            withdrawalTotalMoney = baseMapper.withdrawalTotalMoneyByMonth(cityList);


            withdrawalTotalMoney = baseMapper.withdrawalTotalMoneyByMonth(cityList,request.getSiteIds());


        } else {


            // 数量初始化


            withdrawalTotalMoney = BigDecimal.ZERO;


@@ -162,7 +192,30 @@




    @Override


    public Page<UserWithdrawRecordVO> withdrawList(Integer userId, Page<UserWithdrawRecordVO> page) {


        return baseMapper.withdrawList(userId, page);


        Page<UserWithdrawRecordVO> userWithdrawRecordVOPage = baseMapper.withdrawList(userId, page);


        for (UserWithdrawRecordVO record : userWithdrawRecordVOPage.getRecords()) {


            R<UserDto> user = userClient.getUser(record.getUserId());


            System.err.println("==="+user.getData());


            record.setNickname(user.getData().getNickname());


            record.setProfilePicture(user.getData().getProfilePicture());


            record.setUserPhone(user.getData().getPhone());


            record.setUserNo(record.getUserNo());


        }


        return userWithdrawRecordVOPage;


    }




    @Override


    public Page<UserWithdrawRecordVO> withdrawList1(List<String> cityList,Integer userId, Page<UserWithdrawRecordVO> page,List<String> siteIds) {


        Page<UserWithdrawRecordVO> userWithdrawRecordVOPage = baseMapper.withdrawList1(cityList,userId, page,siteIds);


        for (UserWithdrawRecordVO record : userWithdrawRecordVOPage.getRecords()) {


            R<UserDto> user = userClient.getUser(record.getUserId());


            System.err.println("==="+user.getData());


            record.setNickname(user.getData().getNickname());


            record.setProfilePicture(user.getData().getProfilePicture());


            record.setUserPhone(user.getData().getPhone());


            record.setUserNo(user.getData().getUserNo());


        }


        return userWithdrawRecordVOPage;


    }




    @Override


@@ -178,98 +231,210 @@


                .eq(Withdraw::getOrderId, orderId).list();


        List<Integer> stateList = list.stream().map(Withdraw::getState).collect(Collectors.toList());


        if (stateList.contains(Constants.ZERO)) {


            throw new GlobalException("当前订单已提交提现申请，请等待审核！");


            return  false;


//            throw new GlobalException("当前订单已提交提现申请，请等待审核！");


        } else if (stateList.contains(Constants.ONE)) {


            throw new GlobalException("当前订单已完成提现，请勿重复提现！");


        }


        // 系统审核设置


        WithdrawalSetting withdrawalSetting = withdrawalSettingService.lambdaQuery().one();


        Withdraw withdraw = new Withdraw();


        // 未开启全局 提现审核，则用户提现不需要后台审核


        if (Constants.ZERO.equals(withdrawalSetting.getEnableProcess())) {


            // 已通过


            withdraw.setState(Constants.ONE);


            // 商家微信打款至微信零钱


            boolean update = weChatPay(order.getOrderMoney(), openId);


            if (!update) {


                throw new GlobalException("交易提现失败，请检查是否绑定微信！");


            }


        } else {


            // 待审核


            withdraw.setState(Constants.ZERO);


        }


        withdraw.setUserId(userId);


        withdraw.setUserPhone(userPhone);


        withdraw.setApplyForTime(new Date());


        withdraw.setApplyForMoney(order.getOrderMoney());


        withdraw.setOrderId(orderId);


        return this.save(withdraw);


    }


        withdraw.setCityCode(order.getCityCode());




    private boolean weChatPay(BigDecimal orderMoney, String openId) {


        this.save(withdraw);


        // 未开启全局 提现审核，则用户提现不需要后台审核


        if (Constants.ZERO.equals(withdrawalSetting.getEnableProcess())) {


            // 已通过


            withdraw.setState(Constants.ONE);


            // 商家微信打款至微信零钱


            boolean update = weChatPay(order.getOrderMoney(), openId,withdraw.getId(),order.getServerName());


//            if (!update) {


//                throw new GlobalException("交易提现失败，请检查是否绑定微信！");


//            }


        } else {


            // 待审核


            withdraw.setState(Constants.ZERO);


        }








        order.setIsWithdrawal(1);


        orderService.updateById(order);


        redisService.deleteObject(orderId);




        return this.updateById(withdraw);


    }


    @Resource


    private WithdrawDetailService withdrawDetailService;




//    private boolean weChatPay(BigDecimal orderMoney, String openId,String withdrawId) {


//        if (StringUtils.isBlank(openId)) {


//            return false;


//        }


//


//        BigDecimal maxTransferAmount = new BigDecimal("20000"); // 单次转账限额，单位为分


//        int totalTransfers = orderMoney.multiply(new BigDecimal("100")).divide(maxTransferAmount, 0, RoundingMode.UP).intValue();


//        boolean allTransfersSuccessful = true;


//


//        for (int i = 0; i < totalTransfers; i++) {


//            BigDecimal transferAmount;


//            if (i < totalTransfers - 1) {


//                transferAmount = maxTransferAmount;


//            } else {


//                // 最后一笔转账，金额为剩余金额


//                transferAmount = orderMoney.multiply(new BigDecimal("100")).subtract(maxTransferAmount.multiply(new BigDecimal(i))).setScale(0, RoundingMode.DOWN);


//            }


//


//            Map<String, Object> postMap = new HashMap<>(8);


//            postMap.put(WechatConstants.APP_ID, "wx98563d0ec9cf21c8");


//            postMap.put(WechatConstants.OUT_BATCH_NO, String.valueOf(UUID.randomUUID()).replaceAll("-", ""));


//            System.err.println("====="+postMap.get(WechatConstants.OUT_BATCH_NO));


//            postMap.put(WechatConstants.BATCH_NAME, "二手回收提现");


//            postMap.put(WechatConstants.BATCH_REMARK, "二手回收提现");


//            postMap.put(WechatConstants.TOTAL_AMOUNT, transferAmount);


//            postMap.put(WechatConstants.TOTAL_NUM, Constants.ONE);


//


//            List<Map<String, Object>> list = new ArrayList<>();


//            Map<String, Object> subMap = new HashMap<>(4);


//            subMap.put(WechatConstants.OUT_DETAIL_NO, String.valueOf(SNOW_FLAKE_ID_WORKER.nextId()));


//            subMap.put(WechatConstants.TRANSFER_AMOUNT, transferAmount);


//            subMap.put(WechatConstants.TRANSFER_REMARK, "二手回收提现到账");


//            subMap.put(WechatConstants.OPEN_ID, openId);


//            list.add(subMap);


//            postMap.put(WechatConstants.TRANSFER_DETAIL_LIST, list);


//


//            // 使用类加载器获取资源 URL


////            String path = ClassLoader.getSystemResource("/usr/local/vx/apiclient_key.pem").getPath();


//


////            String result = HttpUtil.postTransBatRequest(


////                    WechatConstants.WE_CHAT_URL_PRE,


////                    JSONObject.toJSONString(postMap),


////                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",


////                    "1665330417",


////                    "/usr/local/vx/apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);


//            String result = HttpUtil.postTransBatRequest(


//                    WechatConstants.WE_CHAT_URL_PRE,


//                    JSONObject.toJSONString(postMap),


//                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",


//                    "1665330417",


//                    "D:\\study\\JiaDianHuiShou\\ruoyi-service\\ruoyi-order\\src\\main\\java\\com\\ruoyi\\order\\vx\\apiclient_key.pem", WechatConstants.WE_CHAT_URL_SUF);


//


//            JSONObject jsonObject = JSONObject.parseObject(result);


//


//            WithdrawDetail withdrawDetail = new WithdrawDetail();


//            withdrawDetail.setWithdrawId(withdrawId);


//            withdrawDetail.setMoney(transferAmount);


//            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));


//            withdrawDetailService.save(withdrawDetail);


//


//            if (jsonObject.containsKey(WechatConstants.CREATE_TIME)) {


//                // 转账成功


//                //保存转账明细


////                WithdrawDetail withdrawDetail = new WithdrawDetail();


////                withdrawDetail.setWithdrawId(withdrawId);


////                withdrawDetail.setMoney(transferAmount);


////                withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));


////                withdrawDetailService.save(withdrawDetail);


//


//


//            } else {


//                allTransfersSuccessful = false;


//                break;


//            }


//


//        }


//


//        return allTransfersSuccessful;


//    }




    // 上架打款到用户零钱接口已弃用 用新版商家转账接口


    private boolean weChatPay(BigDecimal orderMoney, String openId,String withdrawId,String serverName) {


        if (StringUtils.isBlank(openId)) {


            return false;


        }


        Map<String, Object> postMap = new HashMap<>(8);


        // 小程序 id


        postMap.put(WechatConstants.APP_ID, appId);


        postMap.put(WechatConstants.OUT_BATCH_NO, String.valueOf(UUID.randomUUID()).replaceAll("-", ""));


        // 该笔批量转账的名称


        postMap.put(WechatConstants.BATCH_NAME, batchName);


        // 转账说明，UTF8编码，最多允许32个字符


        postMap.put(WechatConstants.BATCH_REMARK, batchName);


        // 转账金额单位为“分”。 总金额


        postMap.put(WechatConstants.TOTAL_AMOUNT, orderMoney.multiply(new BigDecimal(Constants.ONE_HUNDRED)));


        // 转账总笔数


        postMap.put(WechatConstants.TOTAL_NUM, Constants.ONE);


        List<Map<String, Object>> list = new ArrayList<>();


        Map<String, Object> subMap = new HashMap<>(4);


        // 商家明细单号 该商家下唯一


        // subMap.put("out_detail_no", RandomUtil.randomString(32))


        subMap.put(WechatConstants.OUT_DETAIL_NO, SNOW_FLAKE_ID_WORKER.nextId());


        // 转账金额


        subMap.put(WechatConstants.TRANSFER_AMOUNT, orderMoney);


        // 转账备注


        subMap.put(WechatConstants.TRANSFER_REMARK, transferRemark);


        // 用户在直连商户应用下的用户标示


        subMap.put(WechatConstants.OPEN_ID, openId);


        // 大金额需要传入真实姓名


        /*subMap.put("user_name",


        RsaCryptoUtil.encryptOAEP(userName,WechatPayV3Util.getSaveCertificates(privatekeypath)))*/


        list.add(subMap);


        postMap.put(WechatConstants.TRANSFER_DETAIL_LIST, list);


        // 使用类加载器获取资源 URL


        ClassPathResource classPathResource = new ClassPathResource("vx/apiclient_key.pem");


        /*// 获取 resources 目录下的文件路径，假设文件路径为 "resources/data/example.txt"


        String filePath = "resources/data/vx/apiclient_key.pem";


        File file = new File(filePath);


        // 输出文件的绝对路径


        String absolutePath = file.getAbsolutePath();*/


        String result = HttpUtil.postTransBatRequest(


                WechatConstants.WE_CHAT_URL_PRE,


                JSONObject.toJSONString(postMap),


                // 支付证书序列号


                wechatPayserialNo,


                // 商户号


                mchId,


                classPathResource.getPath(), WechatConstants.WE_CHAT_URL_SUF);


        JSONObject jsonObject = JSONObject.parseObject(result);


        /*


         * 成功示例


         * {


         *   "out_batch_no": "plfk2020042013",


         *   "batch_id": "1030000071100999991182020050700019480001",


         *   "create_time": "2015-05-20T13:29:35.120+08:00"


         * }


         */


        if (null == jsonObject || null != jsonObject.get(WechatConstants.CREATE_TIME)) {


            //转账成功


            return Boolean.TRUE;


        } else {


            return Boolean.FALSE;


        BigDecimal maxTransferAmount = new BigDecimal("200000"); // 单次转账限额，单位为分


        int totalTransfers = orderMoney.multiply(new BigDecimal("100")).divide(maxTransferAmount, 0, RoundingMode.UP).intValue();


        boolean allTransfersSuccessful = true;


        for (int i = 0; i < totalTransfers; i++) {


            BigDecimal transferAmount;


            if (i < totalTransfers - 1) {


                transferAmount = maxTransferAmount;


            } else {


                // 最后一笔转账，金额为剩余金额


                transferAmount = orderMoney.multiply(new BigDecimal("100")).subtract(maxTransferAmount.multiply(new BigDecimal(i))).setScale(0, RoundingMode.DOWN);


            }




            Map<String, Object> postMap = new HashMap<>(8);


            postMap.put(WechatConstants.APP_ID, "wx98563d0ec9cf21c8");


            // 订单号


            postMap.put("out_bill_no", String.valueOf(UUID.randomUUID()).replaceAll("-", ""));


            System.err.println("====="+postMap.get("out_bill_no"));


            postMap.put(WechatConstants.OPEN_ID, openId);


            // 转账金额


            postMap.put("transfer_amount", transferAmount);


            postMap.put("transfer_scene_id", "1010");


            // 转账备注


            postMap.put("transfer_remark", "二手回收提现确认收款");


            // 回调地址


            postMap.put("notify_url", "https://hyhsbqgc.com/api/ruoyi-order/wx/wxChatPay");


            // 转账场景报备信息


            List<Map<String, Object>> list = new ArrayList<>();


            Map<String, Object> info = new HashMap<>();


            info.put("info_type","回收商品名称");


            info.put("info_content",serverName);


            list.add(info);


            postMap.put("transfer_scene_report_infos", list);


            String result = HttpUtil.postTransBatRequest(


                    WechatConstants.WE_CHAT_PAY_URL_PRE,


                    JSONObject.toJSONString(postMap),


                    "7EEA04429B006E12AAA421C002EC48BBEED5BE94",


                    "1665330417",


                    "/usr/local/vx/apiclient_key.pem", "/v3/fund-app/mch-transfer/transfer-bills");


            JSONObject jsonObject = JSONObject.parseObject(result);


//            WithdrawDetail withdrawDetail = new WithdrawDetail();


//            withdrawDetail.setWithdrawId(withdrawId);


//            withdrawDetail.setMoney(transferAmount);


//            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));


//            withdrawDetailService.save(withdrawDetail);


            System.err.println(jsonObject);


//            WithdrawDetail withdrawDetail = new WithdrawDetail();


//            withdrawDetail.setWithdrawId(withdrawId);


//            withdrawDetail.setMoney(transferAmount);


//            withdrawDetail.setOutBatchNo((String) postMap.get(WechatConstants.OUT_BATCH_NO));


//            withdrawDetailService.save(withdrawDetail);


            if (jsonObject.containsKey(WechatConstants.CREATE_TIME)) {


                String string = jsonObject.getString("package_info");


                Withdraw withdraw = this.getById(withdrawId);




                Order order = orderService.getById(withdraw.getOrderId());


                order.setIsWithdrawal(2);


                order.setPackageInfo(string);


                orderService.updateById(order);


                // 转账成功


                //保存转账明细


                WithdrawDetail withdrawDetail = new WithdrawDetail();


                withdrawDetail.setWithdrawId(withdrawId);


                withdrawDetail.setMoney(transferAmount);


                withdrawDetail.setOutBatchNo(postMap.get("out_bill_no")+"");


                withdrawDetailService.save(withdrawDetail);






            } else {


                allTransfersSuccessful = false;


                break;


            }




        }




        return allTransfersSuccessful;


    }






    /**


     * 根据当前月份获取当前季度的开始月份


     */