更新

PaymentClient/src/main/java/com/zhongshu/payment/client/payModel/unionFrictionlessPay/model/UnionSuperParam.java

@@ -13,7 +13,7 @@ public class UnionSuperParam {
     /**
      * 签名算法
      */
-    private final String signType = "SHA256";
+//    private final String signType;
 
     /**
      * 签名

PaymentServer/src/main/java/com/zhongshu/payment/server/core/service/pay/impl/unionFrictionlessPay/UnionFrictionlessPayMainService.java

@@ -107,7 +107,6 @@ public class UnionFrictionlessPayMainService extends SuperPayService {
         jsonObject.set("certifId", "511304198608153312");
         jsonObject.set("customerNm", "唐仁祥");
         signParam.setCustInfo(AesUtils.base64Encode(jsonObject.toString()));
-        signParam.setPayKey(UnionPaymentConfig.payKey);
 
         String url = payApiConfig.getUrl(UnionFrictionlessPayApiConfig.sign);
         SuperResponseModel requestAPI = unionRequestService.requestUnionAPI(url, signParam, SignResponse.class);

PaymentServer/src/main/java/com/zhongshu/payment/server/core/service/pay/impl/unionFrictionlessPay/UnionRequestService.java

@@ -26,6 +26,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.StopWatch;
 
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLConnection;
 import java.net.URLEncoder;
 import java.util.*;
 
@@ -66,17 +72,23 @@ public class UnionRequestService extends SuperService {
             apiConfParam.setApiName(url);
             apiConfParam.setMethodType(MethodType.Json);
 
-            data = "A";
+//            data = "A";
+//            JSONObject jsonObject = new JSONObject();
+//            jsonObject.set("requestTimestamp", "2024-08-30 14:54:41");
+//            data = jsonObject.toString();
+//            log.info("data: {}", data);
+
 //            String sign = sign(JSONUtil.parseObj(JSONUtil.toJsonStr(data)));
-            String sign = AesUtils.signData(String.valueOf(data));
+            String str = JSONUtil.toJsonStr(data);
+            log.info("str: {}", str);
+            String sign = AesUtils.signData(str);
             log.info("sign: {}", sign);
-
+//            url += "?requestTimestamp=2024-08-30 14:54:41";
 
             // 请求时间记时
             StopWatch stopWatch = new StopWatch();
             stopWatch.start();
 
-
             String timestamp = DateUtils.paresTime(System.currentTimeMillis(), DateUtils.unionAuth);
             String nonce = CommonUtil.UUID();
             Map<String, Object> header = new HashMap<>();
@@ -85,29 +97,28 @@ public class UnionRequestService extends SuperService {
             log.info("appId: {}", UnionPaymentConfig.appId);
             log.info("timestamp: {}", timestamp);
             log.info("nonce: {}", nonce);
+            log.info("appKey: {}", UnionPaymentConfig.appKey);
 
-            String signature = AesUtils.signMacSHA256(c, UnionPaymentConfig.payKey);
+            String signature = AesUtils.signMacSHA256(c, UnionPaymentConfig.appKey);
             log.info("signature: {}", signature);
-            String sig = String.format("AppId=%s,Timestamp=%s,Nonce=%s,Signature=%s",
-                    UnionPaymentConfig.appId, timestamp, nonce, signature);
 
-            header.put("OPEN-BODY-SIG", sig);
+            String sig = "OPEN-BODY-SIG AppId=" + "\"" + UnionPaymentConfig.appId + "\""
+                    + ",Timestamp=" + "\"" + timestamp + "\""
+                    + ",Nonce=" + "\"" + nonce + "\""
+                    + ",Signature=" + "\"" + signature + "\"";
+            log.info("sig: {}", sig);
 
-            header.put("Authorization", sig);
+            header.put("authorization", sig);
+            header.put("Content-Type", "application/json");
+            header.put("Accept_Charset", "UTF-8");
 
-            header.put("AppId", UnionPaymentConfig.appId);
-            header.put("Timestamp", timestamp);
-            header.put("Nonce", nonce);
-            header.put("Signature", signature);
-
-            // 发送请求
+            log.info("url: {}", url);
             HttpModel httpModel = HttpModel.builder()
                     .url(url).method(apiConfParam.getMethodType())
                     .charset("utf-8").body(data).build();
 
             httpModel.setHeader(header);
             ResponseModel request = HttpClientUtil.request(httpModel);
-
             int code = request.getCode();
             if (code == 200) {
                 BeanUtil.copyProperties(request.getBody(), responseModel);
@@ -116,7 +127,7 @@ public class UnionRequestService extends SuperService {
             } else {
                 BeanUtil.copyProperties(request.getBody(), responseModel);
             }
-            log.info("response: {}", responseModel.getErrCode());
+            log.info("response: {} {}", responseModel.getErrCode(), code);
             responseModel.setCode(code);
             stopWatch.stop();
             responseModel.setMillis(stopWatch.getTotalTimeMillis());

PaymentServer/src/main/java/com/zhongshu/payment/server/core/service/pay/impl/unionFrictionlessPay/config/UnionFrictionlessPayApiConfig.java

@@ -49,6 +49,9 @@ public class UnionFrictionlessPayApiConfig {
     // 申请扣款
     public static String senselessPay = "senselessPay";
 
+    // 交易查询
+    public static String netPayQuery = "netPayQuery";
+
     // 支付并签约
     public static String senselessPayAndOpen = "senselessPayAndOpen";
 
@@ -61,6 +64,8 @@ public class UnionFrictionlessPayApiConfig {
     // 云闪付 订单查询
     public static String orderQuery = "orderQuery";
 
+
+
     private static List<UnionPayApi> apis = new ArrayList<>();
 
     static {
@@ -139,6 +144,10 @@ public class UnionFrictionlessPayApiConfig {
                 .prodUrl("https://api-mop.chinaums.com/v1/netpay/uac/query")
                 .build());
 
+        apis.add(UnionPayApi.builder().apiKey(netPayQuery)
+                .devUrl("https://test-api-open.chinaums.com/v1/netpay/query")
+                .prodUrl("https://api-mop.chinaums.com/v1/netpay/query")
+                .build());
 
     }
 

PaymentServer/src/main/java/com/zhongshu/payment/server/core/service/pay/impl/unionFrictionlessPay/config/UnionPaymentConfig.java

@@ -9,7 +9,7 @@ package com.zhongshu.payment.server.core.service.pay.impl.unionFrictionlessPay.c
 public class UnionPaymentConfig {
 
     // 无感支付 秘钥
-    public static final String payKey = "GAhPWQ8D4hXanneneaydaHYHiwn64p7y3A46Jpss87aKWsy5";
+    public static final String notifySecret = "GAhPWQ8D4hXanneneaydaHYHiwn64p7y3A46Jpss87aKWsy5";
     //
     public static final String appId = "10037e6f803bc8ab01805fd07db4000d";
 

PaymentServer/src/main/java/com/zhongshu/payment/server/core/utils/Query.java

@@ -0,0 +1,153 @@
+package com.zhongshu.payment.server.core.utils;
+
+import com.zhongshu.payment.server.core.service.pay.impl.unionFrictionlessPay.config.UnionBalanceConfig;
+import com.zhongshu.payment.server.core.service.pay.impl.unionFrictionlessPay.config.UnionPaymentConfig;
+import org.apache.commons.codec.binary.Base64;
+import org.apache.commons.codec.digest.DigestUtils;
+
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLConnection;
+
+/**
+ * @author kkqiao
+ * 网银支付订单交易查询接口
+ * 说明：
+ * 钱包支付时，因通讯故障、服务器故障等原因，造成收银机最终没有收到支付结果通知，收银员不确定
+ * 该笔支付后台处理结果，可以在收银机上发起“查询”交易，查询该笔交易订单在钱包后台的支付结果，
+ * 并将支付结果返回给收银机。
+ *  测试环境：http://58.247.0.18:29015/v1/netpay/query
+ *  生产环境：https://api-mop.chinaums.com/v1/netpay/query
+ */
+public class Query {
+
+//    static String appid = UnionBalanceConfig.appId;
+//    static String appkey = UnionBalanceConfig.appKey;
+
+    static String appid = UnionPaymentConfig.appId;
+    static String appkey = UnionPaymentConfig.appKey;
+
+    static String url = "https://test-api-open.chinaums.com/v1/inip/sign/uac/entrust-pay/sign";
+
+    public static void main(String[] args) throws Exception{
+        //1. 组建请求报文
+        QueryBody reqBody = new QueryBody();
+        reqBody.requestTimestamp = "2019-08-12 15:40:55";
+        reqBody.merOrderId = "101771154dc89774b477474d929f29bc150b80c9";
+        reqBody.mid = "898310148160568";
+        reqBody.tid = "88880001";
+        reqBody.instMid = "H5DEFAULT";
+        System.out.println("request body:\n"+reqBody);
+
+        //2. 获取认证报文，timestamp为当前日期，老旧日期无法请求成功
+        String authorization = getAuthorization(appid,appkey,"20190812154100","nonce",reqBody.toString());
+        System.out.println("authorization:\n"+authorization);
+
+        //3. 发送http请求，并解析返回信息
+        String response = request(url,authorization,reqBody.toString());
+        System.out.println("response:\n"+response);
+    }
+
+    /**
+     * 发送http请求
+     * @param url 请求url
+     * @param authorization 认证报文
+     * @param reqBody  请求体
+     * @return response
+     */
+    static String request(String url, String authorization, String reqBody){
+        String response = "";
+        PrintWriter out = null;
+        BufferedReader in = null;
+        try{
+            URL realUrl = new URL(url);
+            URLConnection conn = realUrl.openConnection();
+            HttpURLConnection httpUrlConnection = (HttpURLConnection) conn;
+            httpUrlConnection.setRequestProperty("Content-Type", "application/json");
+            httpUrlConnection.setRequestProperty("authorization",authorization);
+            httpUrlConnection.setDoOutput(true);
+            httpUrlConnection.setDoInput(true);
+            out = new PrintWriter(httpUrlConnection.getOutputStream());
+            out.write(reqBody);
+            out.flush();
+            httpUrlConnection.connect();
+            in = new BufferedReader(new InputStreamReader(httpUrlConnection.getInputStream()));
+            String line;
+            while ((line = in.readLine()) != null) {
+                response += line;
+            }
+        }catch(Exception e){
+            e.printStackTrace();
+        } finally {
+            try {
+                if (out != null) { out.close();}
+                if (in != null) {in.close();}
+            } catch (Exception ex) {
+                ex.printStackTrace();
+            }
+        }
+        return response;
+    }
+
+    /**
+     * 获取签名头
+     * @param appid
+     * @param appkey
+     * @param timestamp 格式:"yyyyMMddHHmmss"
+     * @param nonce 随机字符串，
+     * @param body 请求体
+     * @return authorization 认证报文
+     * @throws Exception
+     */
+    static String getAuthorization(String appid, String appkey, String timestamp, String nonce, String body) throws Exception {
+        byte[] data = body.getBytes("utf-8");
+        InputStream is = new ByteArrayInputStream(data);
+        String testSH = DigestUtils.sha256Hex(is);
+        String s1 = appid+timestamp+nonce+testSH;
+        Mac mac = Mac.getInstance("HmacSHA256");
+        mac.init(new SecretKeySpec(appkey.getBytes("utf-8"),"HmacSHA256"));
+        byte[] localSignature = mac.doFinal(s1.getBytes("utf-8"));
+        String localSignatureStr = Base64.encodeBase64String(localSignature);
+        return  "OPEN-BODY-SIG AppId="+"\""+appid+"\""+", Timestamp="+"\""+timestamp+"\""+", Nonce="+"\""+nonce+"\""+", Signature="+"\""+localSignatureStr+"\"";
+    }
+
+    static class QueryBody{
+        //消息ID
+        String msgId;
+        //报文请求时间，格式yyyy-MM-ddHH:mm:ss
+        String requestTimestamp;
+        //请求系统预留字段
+        String srcReserve;
+        //商户号
+        String mid;
+        //终端号
+        String tid;
+        //业务类型
+        String instMid;
+        //商户订单号
+        String merOrderId;
+
+        String toJson(){
+            StringBuilder sb = new StringBuilder();
+            sb.append("{");
+            if (this.msgId != null) sb.append("\"msgId\":\"" + this.msgId + "\",");
+            if (this.requestTimestamp != null) sb.append("\"requestTimestamp\":\"" + this.requestTimestamp + "\",");
+            if (this.srcReserve != null) sb.append("\"srcReserve\":\"" + this.srcReserve + "\",");
+            if (this.mid != null) sb.append("\"mid\":\"" + this.mid + "\",");
+            if (this.tid != null) sb.append("\"tid\":\"" + this.tid + "\",");
+            if (this.instMid != null) sb.append("\"instMid\":\"" + this.instMid + "\",");
+            if (this.merOrderId != null) sb.append("\"merOrderId\":\"" + this.merOrderId + "\",");
+            if (sb.charAt(sb.length() - 1) == ',')
+                sb.deleteCharAt(sb.length() - 1);
+            sb.append("}");
+            return sb.toString();
+        }
+        public String toString(){
+            return this.toJson();
+        }
+    }
+
+}