支付业务开发【待测试】

src/main/java/com/chuanghai/ihotel/component/PayComponent.java

@@ -26,6 +26,7 @@ import java.util.Enumeration;
 import java.util.HashMap;
 import java.util.LinkedHashMap;
 import java.util.Map;
+import java.util.TreeMap;
 
 /**
  * @Author: codingliang
@@ -37,6 +38,7 @@ import java.util.Map;
 @Component
 public class PayComponent {
 
+    private ObjectMapper mapper = new ObjectMapper();
     @Autowired
     private JXNXSPayConfig jxnxsPayConfig;
     @Autowired
@@ -83,41 +85,93 @@ public class PayComponent {
     }
 
     /**
+     * 退款
+     * @param orderNo 订单编号
+     * @param refundOrderNo 退款订单编号
+     * @param refundAmount 退款金额
+     */
+    public Map<String, String> payRefund(String orderNo, String refundOrderNo, Integer refundAmount) {
+        try {
+            TreeMap<String, String> dataMap = new TreeMap<>();    // data参数的map
+            dataMap.put("out_no", orderNo);
+            dataMap.put("refund_out_no", refundOrderNo);
+            dataMap.put("refund_ord_name", "消费退款");
+            dataMap.put("refund_amount", refundAmount + "");
+//            dataMap.put("remark", "");
+            dataMap.put("shop_pass", ""); // TODO shopPass
+
+            return doRequest("payrefund", dataMap);
+        } catch (Exception e) {
+            throw new RRException(BizCodeEnume.JXNXS_ORDER_QUERY_ERROR);
+        }
+    }
+
+    /**
      * 支付结果查询
      * @param orderNo 订单编号
      * @return
      */
     public Map<String, String> queryOrderStatus(String orderNo) {
         try {
+            Map<String, String> dataMap = new LinkedHashMap<>();    // data参数
+            dataMap.put("out_no", orderNo);
+            dataMap.put("ord_no", "");
+
+            return doRequest("paystatus", dataMap);
+        } catch (Exception e) {
+            throw new RRException(BizCodeEnume.JXNXS_ORDER_QUERY_ERROR);
+        }
+    }
+
+    /**
+     * 发送请求
+     * @param uri
+     * @param dataMap 参数
+     * @return
+     */
+    private Map<String, String> doRequest(String uri, Map<String, String> dataMap) {
+        try {
             // 构建请求参数
             Map<String, String> postParam = new LinkedHashMap<>();
             postParam.put("open_id", jxnxsPayConfig.getOpenId());
             postParam.put("timestamp", new Date().getTime() / 1000 + "");
-            Map<String, String> dataMap = new LinkedHashMap<>();    // data参数
-            dataMap.put("out_no", orderNo);
-            dataMap.put("ord_no", "");
-            ObjectMapper mapper = new ObjectMapper();
+
+            // data加密
             String data = JXNXSPayUtil.handleEncrypt(mapper.writeValueAsString(dataMap), jxnxsPayConfig.getOpenKey());
             postParam.put("data", data);
             postParam.put("open_key", jxnxsPayConfig.getOpenKey());
             String sign = JXNXSPayUtil.sign(postParam);
             postParam.put("sign", sign);
 
-            MultiValueMap<String,String> params = new LinkedMultiValueMap<>();
-            params.setAll(postParam);
+
             // 发送请求
             HttpHeaders headers = new HttpHeaders();
             MediaType type = MediaType.parseMediaType("application/x-www-form-urlencoded");
             headers.setContentType(type);
 
+            MultiValueMap<String,String> params = new LinkedMultiValueMap<>();
+            params.setAll(postParam);
             HttpEntity<MultiValueMap<String,String>> formEntity = new HttpEntity<>(params, headers);
 
             RestTemplate client = new RestTemplate();
-            String url = "https://api.jxnxs.com/mct1/paystatus";
+            String url = "https://api.jxnxs.com/mct1/" + uri;
 
             ResponseEntity<String> resp = client.postForEntity(url, formEntity, String.class);
             String body = resp.getBody();
 
+            return analysisResult(body);
+        } catch (Exception e) {
+            throw new RRException(BizCodeEnume.JXNXS_ORDER_QUERY_ERROR, e.getMessage());
+        }
+    }
+
+    /**
+     * 解析结果
+     * @param body
+     * @return
+     */
+    private Map<String, String> analysisResult(String body) {
+        try {
             Map<String, String> map = mapper.readValue(body, new TypeReference<HashMap<String, String>>() {});
             if (JXNXSPayUtil.verifySign(map, jxnxsPayConfig.getOpenKey())) {
                 // data 解密
@@ -127,7 +181,7 @@ public class PayComponent {
                 return map;
             }
         } catch (Exception e) {
-            throw new RRException(BizCodeEnume.JXNXS_ORDER_QUERY_ERROR);
+            throw new RRException(BizCodeEnume.JXNXS_ORDER_QUERY_ERROR, "农商行返回结果解析失败");
         }
     }
 }

src/main/java/com/chuanghai/ihotel/controller/PayController.java

@@ -0,0 +1,56 @@
+package com.chuanghai.ihotel.controller;
+
+import com.chuanghai.ihotel.component.PayComponent;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 支付接口
+ * @author codingliang
+ * @email codingliang@gmail.com
+ * @date 2021-08-12 15:52:41
+ */
+@Controller
+@RequestMapping("pay")
+public class PayController {
+
+    @Value("${fontEndUrl}")
+    private String fontEndUrl;
+    @Autowired
+    private PayComponent payComponent;
+
+    /**
+     * 【农商行】支付结果异步通知
+     * @param request
+     * @since 0.1.0
+     * @return
+     */
+    @ResponseBody
+    @GetMapping("jxnxs/notify")
+    public String jxnxsNotify(HttpServletRequest request) {
+        boolean isSuccess = payComponent.notify(request);
+        if (isSuccess) {
+            return "notify_success";
+        } else {
+            return "notify_fail";
+        }
+    }
+
+    /**
+     * 【农商行】支付成功跳转地址
+     * @param orderNo 订单号
+     * @since 0.1.0
+     * @return
+     */
+    @GetMapping("jxnxs/success")
+    public String jxnxsSuccess(@RequestParam("ord_no") String orderNo) {
+        return "redirect:" + fontEndUrl + "/#/pages/paySuccess/paySuccess?orderNo=" + orderNo;
+    }
+}

src/main/resources/application.yml

@@ -65,11 +65,15 @@ aliyun:
 
 # 江西农商行相关配置
 jxnxs:
-  openId: 5494ec3310685daa218382619dd20e27
-  openKey: 611764d05a545bb7bb08cbd457f7dac1
+  openId: 74969401869b175660817b4369e5a911
+  openKey: ba5c30ce48fbfb4464a5a855a960c802
+  shopPass: ""
   notifyUrl: http://chuanghai-dev.natappfree.cc/pay/jxnxs/notify
   payUrl: https://q.jxnxs.com/newpay?O=${jxnxs.openId}&out_no=%s&amount=%s&appoint_notify=${jxnxs.notifyUrl}
 
+# 前端服务地址
+font-end-url: http://192.168.31.111:8080/jiaofei/jiaofeiH5
+
 # 水电服务配置
 water-electric:
   # 运营商标识