From b34724884237e53b14883546eb7dd50796d36df4 Mon Sep 17 00:00:00 2001
From: luodangjia <luodangjia>
Date: 星期五, 03 一月 2025 14:15:36 +0800
Subject: [PATCH] 11.6

---
 ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/FranchiseeController.java |  108 ++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 72 insertions(+), 36 deletions(-)

diff --git a/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/FranchiseeController.java b/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/FranchiseeController.java
index 2d10e75..857b0a4 100644
--- a/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/FranchiseeController.java
+++ b/ruoyi-service/ruoyi-admin/src/main/java/com/ruoyi/admin/controller/FranchiseeController.java
@@ -6,6 +6,8 @@
 import com.alibaba.excel.ExcelWriter;
 import com.alibaba.excel.write.builder.ExcelWriterBuilder;
 import com.alibaba.excel.write.metadata.WriteSheet;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.alipay.api.AlipayApiException;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
@@ -15,6 +17,10 @@
 import com.ruoyi.admin.service.*;
 import com.ruoyi.admin.utils.MD5AndKL;
 import com.ruoyi.admin.utils.WeChatUtil;
+import com.ruoyi.admin.utils.util.CreateLinkStringByGet1;
+import com.ruoyi.admin.utils.util.HttpRequester;
+import com.ruoyi.admin.utils.util.HttpRespons;
+import com.ruoyi.admin.utils.util.Md5_Sign;
 import com.ruoyi.admin.vo.InfoDto;
 import com.ruoyi.admin.vo.MoneyRecentQuery;
 import com.ruoyi.admin.vo.PayDto;
@@ -273,7 +279,7 @@
 
     @ApiOperation(value = "js支付", tags = {"2.0-支付"})
     @GetMapping(value = "/js/wxPay")
-    public R jsPay(@RequestParam String openId,@RequestParam BigDecimal money,@RequestParam Integer userId) {
+    public R jsPay(@RequestParam String openId,@RequestParam BigDecimal money,@RequestParam Integer userId) throws IOException {
         SysUser byId1 = sysUserService.getById(userId);
         this.privateKey = PemUtil.loadPrivateKey(getPrivateKeyStream());
         this.privateKeySigner = new PrivateKeySigner(weChatConfig.merchantSerialNumber, privateKey);
@@ -283,37 +289,66 @@
         Franchisee byId = franchiseeService.getById(byId1.getFranchiseeId());
 
 
-        PrepayRequest prepayRequest = new PrepayRequest();
-        prepayRequest.setAppid(weChatConfig.appId);
-        prepayRequest.setMchid(weChatConfig.merchantId);
-        prepayRequest.setDescription("加盟商充值");
-        prepayRequest.setOutTradeNo(code);
-        prepayRequest.setNotifyUrl("http://www.zhipingwang.com.cn:9090/admin/franchisee/callBack");
-        Amount amount = new Amount();
-        amount.setTotal(i);
-        prepayRequest.setAmount(amount);
-        Payer payer = new Payer();
-        payer.setOpenid(openId);
-        prepayRequest.setPayer(payer);
-        PrepayResponse prepay = jsapiService.prepay(prepayRequest);
-        String timeStamp = String.valueOf(System.currentTimeMillis() / 1000);
-        String packageStr = "prepay_id=" + prepay.getPrepayId();
+        //
+        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("q5_OpenId", openId);
+        map.put("p5_ProductName", "加盟商充值"); /** 商品名称 */
+        map.put("p9_NotifyUrl", "http://www.zhipingwang.com.cn:9100/admin/franchisee/callBack"); /** 服务器异步通知地址 */
+        map.put("q1_FrpCode", "WEIXIN_APP3"); /** 交易类型*/
+        map.put("q7_AppId", "wx1a4a7760be53a835"); /** 交易类型*/
+        map.put("qa_TradeMerchantNo", "777165000859101"); /** 777开头的报备商户号   必填!*/
 
-        String prepay_id = prepay.getPrepayId();
-        //重新进行签名后返回给前端
+        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://www.joinpay.com/trade/uniPayApi.action", map);
+        System.out.println("接收返回参数:" + HP.getContent());
+        JSONObject jsonObject = JSONObject.parseObject(HP.getContent());
+        JSONObject rcResult = JSONObject.parseObject(jsonObject.getString("rc_Result"));
         Map<String, Object> map2 = new HashMap<>();
-        map2.put("appid", weChatConfig.getAppId());
-        map2.put("noncestr", code);
-        map2.put("package", "Sign=WXPay");
-        map2.put("partnerid", weChatConfig.getMerchantId());
-        map2.put("prepayid", prepay_id);
-        map2.put("timestamp", timeStamp);
-//        String s1 = this.weixinSignature(map2);
-        String signStr = Stream.of(weChatConfig.getAppId(), timeStamp, code, packageStr).collect(Collectors.joining("\n", "", "\n"));
-        String packageSign = privateKeySigner.sign(signStr.getBytes(StandardCharsets.UTF_8)).getSign();
-        
-        map2.put("sign", packageSign);
-        System.err.println(map2);
+        map2.put("rcResult", rcResult);
+//        map2.put("timestamp", rcResult.get("timeStamp"));
+//        map2.put("prepayid", rcResult.get("package"));
+//        map2.put("sign", rcResult.get("paySign"));
+
+        //
+//        PrepayRequest prepayRequest = new PrepayRequest();
+//        prepayRequest.setAppid(weChatConfig.appId);
+//        prepayRequest.setMchid(weChatConfig.merchantId);
+//        prepayRequest.setDescription("加盟商充值");
+//        prepayRequest.setOutTradeNo(code);
+//        prepayRequest.setNotifyUrl("http://www.zhipingwang.com.cn:9090/admin/franchisee/callBack");
+//        Amount amount = new Amount();
+//        amount.setTotal(i);
+//        prepayRequest.setAmount(amount);
+//        Payer payer = new Payer();
+//        payer.setOpenid(openId);
+//        prepayRequest.setPayer(payer);
+//        PrepayResponse prepay = jsapiService.prepay(prepayRequest);
+//        String timeStamp = String.valueOf(System.currentTimeMillis() / 1000);
+//        String packageStr = "prepay_id=" + prepay.getPrepayId();
+//
+//        String prepay_id = prepay.getPrepayId();
+//        //重新进行签名后返回给前端
+
+////        String s1 = this.weixinSignature(map2);
+//        String signStr = Stream.of(weChatConfig.getAppId(), timeStamp, code, packageStr).collect(Collectors.joining("\n", "", "\n"));
+//        String packageSign = privateKeySigner.sign(signStr.getBytes(StandardCharsets.UTF_8)).getSign();
+//
+//        System.err.println(map2);
 
 
         TFranchiseeBalanceChange tFranchiseeBalanceChange = new TFranchiseeBalanceChange();
@@ -423,13 +458,14 @@
     @ApiOperation(value = "支付回调",tags = {"微信支付回调"})
     @RequestMapping (value = "/callBack")
     @Transactional
-    public R payNotify(HttpServletRequest request) throws Exception{
+    public R payNotify(HttpServletRequest request,String r2_OrderNo) throws Exception{
         System.err.println("======回调开始");
-        Transaction transaction;
-        transaction = notificationParser.parse(WeChatUtil.handleNodifyRequestParam(request), Transaction.class);
-        if (transaction.getTradeState() == Transaction.TradeStateEnum.SUCCESS) {
+        System.err.println("======回调开始"+r2_OrderNo);
+//        Transaction transaction;
+//        transaction = notificationParser.parse(WeChatUtil.handleNodifyRequestParam(request), Transaction.class);
+//        if (transaction.getTradeState() == Transaction.TradeStateEnum.SUCCESS) {
             //将记录变为已支付
-            TFranchiseeBalanceChange one = balanceChangeService.lambdaQuery().eq(TFranchiseeBalanceChange::getCode, transaction.getOutTradeNo()).one();
+            TFranchiseeBalanceChange one = balanceChangeService.lambdaQuery().eq(TFranchiseeBalanceChange::getCode,r2_OrderNo).one();
             if (one.getIs_pay()==0) {
                 //将加盟商的余额增加
                 Franchisee byId = franchiseeService.getById(one.getFranchiseeId());
@@ -438,7 +474,7 @@
                 one.setIs_pay(1);
                 balanceChangeService.updateById(one);
 
-            }
+//            }
 
         }
         return R.ok(null,"SUCCESS");

--
Gitblit v1.7.1