二手家电回收
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xuhy
2025-02-18 9acb17a6871d84a85c373eb90b980f98894e30e0 
 ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/FranchiseeController.java


@@ -122,10 +122,13 @@


            @ApiImplicitParam(value = "管理员", name = "head", dataType = "String"),


            @ApiImplicitParam(value = "手机号码", name = "phone", dataType = "String"),


            @ApiImplicitParam(value = "管辖城市", name = "city", dataType = "String"),


            @ApiImplicitParam(value = "充值/扣款起始时间", name = "date1", dataType = "String"),


            @ApiImplicitParam(value = "充值/扣款结束时间", name = "date2", dataType = "String"),


            @ApiImplicitParam(value = "页码", name = "pageNum", dataType = "Integer", required = true),


            @ApiImplicitParam(value = "每页条数", name = "pageSize", dataType = "Integer", required = true)


    })


    public R<RencentBalance> recentmoney(String name, String head, String phone, String city,


                                         String date1,String date2,


                                         @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum,


                                         @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {


        BigDecimal balance = new BigDecimal(0);


@@ -140,11 +143,11 @@


        for (Franchisee franchisee : list) {


            balance = balance.add(franchisee.getBalance());


        }




        //充值的金额


        BigDecimal balance1 = new BigDecimal(0);


        List<TFranchiseeBalanceChange> list1 = balanceChangeService.lambdaQuery()


                .in(TFranchiseeBalanceChange::getFranchiseeId,collect)


                .between(date1!=null,TFranchiseeBalanceChange::getCreateTime, date1, date2)


                .eq(TFranchiseeBalanceChange::getType, 1).list();


        for (TFranchiseeBalanceChange franchiseeBalanceChange : list1) {


            balance1 = balance1.add(franchiseeBalanceChange.getAmount());


@@ -154,6 +157,7 @@


        List<TFranchiseeBalanceChange> list2 = balanceChangeService.lambdaQuery()


                .in(TFranchiseeBalanceChange::getFranchiseeId,collect)


                .eq(TFranchiseeBalanceChange::getType, 2)


                .between(date1!=null,TFranchiseeBalanceChange::getCreateTime, date1, date2)


                .eq(TFranchiseeBalanceChange::getIs_pay,1).list();


        for (TFranchiseeBalanceChange franchiseeBalanceChange : list2) {


            balance2 = balance2.add(franchiseeBalanceChange.getAmount());


@@ -188,6 +192,7 @@


                .like(moneyRecentQuery.getName() != null && !"".equals(moneyRecentQuery.getName()), TFranchiseeBalanceChange::getFranchiseeName, moneyRecentQuery.getName())


                .ge(moneyRecentQuery.getDate1() != null, TFranchiseeBalanceChange::getCreateTime, moneyRecentQuery.getDate1())


                .le(moneyRecentQuery.getDate2() != null, TFranchiseeBalanceChange::getCreateTime, moneyRecentQuery.getDate2())


                .eq(moneyRecentQuery.getFranchId()!=null, TFranchiseeBalanceChange::getFranchiseeId, moneyRecentQuery.getFranchId())


                .eq(TFranchiseeBalanceChange::getIs_pay,1)


                .orderByDesc(TFranchiseeBalanceChange::getCreateTime)


                .page(Page.of(moneyRecentQuery.getPageNum(), moneyRecentQuery.getPageSize()));


@@ -225,6 +230,7 @@


                    .eq(moneyRecentQuery.getName() != null && !"".equals(moneyRecentQuery.getName()), TFranchiseeBalanceChange::getFranchiseeName, moneyRecentQuery.getName())


                    .ge(moneyRecentQuery.getDate1() != null, TFranchiseeBalanceChange::getCreateTime, moneyRecentQuery.getDate1())


                    .le(moneyRecentQuery.getDate2() != null, TFranchiseeBalanceChange::getCreateTime, moneyRecentQuery.getDate2())


                    .eq(moneyRecentQuery.getFranchId()!=null, TFranchiseeBalanceChange::getFranchiseeId, moneyRecentQuery.getFranchId())


                    .eq(TFranchiseeBalanceChange::getIs_pay,1)


                    .orderByDesc(TFranchiseeBalanceChange::getCreateTime)


                    .list();


@@ -343,7 +349,7 @@


        map.put("p4_Cur", "1"); /**交易币种 */


        map.put("q5_OpenId", openId);


        map.put("p5_ProductName", "加盟商充值"); /** 商品名称 */


        map.put("p9_NotifyUrl", "https://v7ro848ar5jx.ngrok.xiaomiqiu123.top/admin/franchisee/callBack"); /** 服务器异步通知地址 */


        map.put("p9_NotifyUrl", "http://101.34.55.62:9100/admin/franchisee/callBack"); /** 服务器异步通知地址 */


        map.put("q1_FrpCode", "WEIXIN_APP3"); /** 交易类型*/


        map.put("q7_AppId", "wx1a4a7760be53a835"); /** 交易类型*/


        map.put("qa_TradeMerchantNo", "777165000859101"); /** 777开头的报备商户号   必填！*/


@@ -453,7 +459,89 @@


        map.put("p5_ProductName", "充值"); /** 商品名称 */


        map.put("p6_ProductDesc", "加盟商充值"); /** 商品名称 */


//        map.put("p7_Mp", ""); /** 如果商户请求时传递了该参数，则返回给商户时会原值传 回。 */


        map.put("p9_NotifyUrl", "https://v7ro848ar5jx.ngrok.xiaomiqiu123.top/admin/franchisee/callBack"); /** 服务器异步通知地址 */


        map.put("p9_NotifyUrl", "http://101.34.55.62:9100/admin/franchisee/callBack"); /** 服务器异步通知地址 */


        map.put("q1_FrpCode", "WEIXIN_NATIVE"); /** 微信扫码（主扫）【注：此为用户主扫，商户被扫】*/


        map.put("q4_IsShowPic", "1"); /** 是否展示二 维码图片 1表示输出*/


        map.put("q7_AppId", "wx1a4a7760be53a835"); /** 交易类型*/


        map.put("qa_TradeMerchantNo", "777165000859101"); /** 777开头的报备商户号   必填！*/


        map.put("qi_FqSellerPercen", "0"); /** 卖家承担收 费比例 目前仅支持传入 0 ，即用户承 担手续费！*/




        String Strmap = CreateLinkStringByGet1.createLinkStringByGet(map);




        // 签名


        String sign = "";


        sign = Md5_Sign.SignByMD5(Strmap, key);


        map.put("hmac", sign);/** 签名数据 */


        System.out.println("发送:" + JSON.toJSONString(map).toString());




        // post请求参数内容


        HttpRequester hr = new HttpRequester();


        HttpRespons HP = hr.sendPost("https://trade.joinpay.com/tradeRt/uniPay", map);


        System.out.println("接收返回参数：" + HP.getContent());


        JSONObject jsonObject = JSONObject.parseObject(HP.getContent());


        String rcResult = jsonObject.getString("rd_Pic");


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


        map2.put("rcResult", rcResult);


//        com.wechat.pay.java.service.payments.nativepay.model.PrepayRequest prepayRequest = new com.wechat.pay.java.service.payments.nativepay.model.PrepayRequest();


//            prepayRequest.setAppid(weChatConfig.appId);


//            prepayRequest.setMchid(weChatConfig.merchantId);


//            prepayRequest.setOutTradeNo(code);


//            prepayRequest.setDescription("购买资料");


//            prepayRequest.setNotifyUrl("http://www.zhipingwang.com.cn:9090/admin/franchisee/callBack");


//            com.wechat.pay.java.service.payments.nativepay.model.Amount amount = new com.wechat.pay.java.service.payments.nativepay.model.Amount();


//            amount.setTotal(i);


//            prepayRequest.setAmount(amount);


//            // 调用下单方法，得到应答


//            com.wechat.pay.java.service.partnerpayments.app.model.PrepayResponse response;


        try {


//                com.wechat.pay.java.service.payments.nativepay.model.PrepayResponse prepay = nativePayService.prepay(prepayRequest);


            //预支付成功，创建预支付订单


            TFranchiseeBalanceChange tFranchiseeBalanceChange = new TFranchiseeBalanceChange();


            tFranchiseeBalanceChange.setAmount(money);


            tFranchiseeBalanceChange.setIs_pay(0);


            tFranchiseeBalanceChange.setFranchiseeName(byId.getName());


            tFranchiseeBalanceChange.setFranchiseeId(String.valueOf(byId.getId()));


            tFranchiseeBalanceChange.setType(2);


            tFranchiseeBalanceChange.setCode(code);


            tFranchiseeBalanceChange.setRemark("加盟商扫码充值");


            balanceChangeService.save(tFranchiseeBalanceChange);








            PayDto payDto = new PayDto();


            payDto.setOrderId(tFranchiseeBalanceChange.getId());


            payDto.setQrCode(rcResult);




            return R.ok(payDto);


        } catch (HttpException e) { // 发送HTTP请求失败


//                log.error("发送HTTP请求失败: {}", e.getHttpRequest());


        } catch (ServiceException e) { // 服务返回状态小于200或大于等于300，例如500


//                log.error("服务返回状态异常: {}", e.getResponseBody());


        } catch (MalformedMessageException e) { // 服务返回成功，返回体类型不合法，或者解析返回体失败


//                log.error("返回体类型不合法: {}", e.getMessage());


        } catch (Exception e) {


//                log.error("预下单异常: {}", e.getMessage());


        }


        return null;




    }


    @ApiOperation(value = "扫码支付",tags = {"后台2.0-总平台"})


    @PostMapping(value = "/code/buyPlatform")


    public R buyPlatform(@RequestParam BigDecimal money,Integer id) throws AlipayApiException, IOException {


        Franchisee byId = franchiseeService.getById(id);


        String code = generateTradeNumber();


        int i = money.multiply(BigDecimal.valueOf(100)).intValue();


        String key = "ad273ceb5e1b49e68d5c565d28d1d305";/** md5密钥商户后台-商户中心-商户设置-密钥管理获取 必填！*/


        Map<String, String> map = new HashMap<String, String>();


        map.put("p0_Version", "2.5");/** 版本号 */


        map.put("p1_MerchantNo", "888122400007793");/** 商户编号 */


        map.put("p2_OrderNo", code); /**商户订单号*/


        map.put("p3_Amount", String.valueOf(money));/**订单金额*/


        map.put("p4_Cur", "1"); /**交易币种 */


        map.put("p5_ProductName", "充值"); /** 商品名称 */


        map.put("p6_ProductDesc", "加盟商充值"); /** 商品名称 */


//        map.put("p7_Mp", ""); /** 如果商户请求时传递了该参数，则返回给商户时会原值传 回。 */


        map.put("p9_NotifyUrl", "http://101.34.55.62:9100/admin/franchisee/callBack"); /** 服务器异步通知地址 */


        map.put("q1_FrpCode", "WEIXIN_NATIVE"); /** 微信扫码（主扫）【注：此为用户主扫，商户被扫】*/


        map.put("q4_IsShowPic", "1"); /** 是否展示二 维码图片 1表示输出*/


        map.put("q7_AppId", "wx1a4a7760be53a835"); /** 交易类型*/