package com.nova.sankuai.domain.api.yinsheng;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.parser.Feature;
|
import com.nova.sankuai.domain.entity.VipCardOrder;
|
import com.nova.sankuai.domain.vo.vipcard.VipCardVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.tomcat.util.codec.binary.Base64;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* @author weikangdi
|
* @create 2022/3/2
|
*/
|
@Component
|
@Slf4j
|
public class YinShengUtil {
|
@Value("${yinsheng.notify_url}")
|
private String notify_url;
|
|
@Value("${yinsheng.h5.partner_id}")
|
private String partner_id;
|
|
@Value("${yinsheng.h5.seller_id}")
|
private String seller_id;
|
|
@Value("${yinsheng.h5.seller_name}")
|
private String seller_name;
|
|
@Value("${yinsheng.h5.business_code}")
|
private String business_code;
|
|
@Value("${yinsheng.h5.password}")
|
private String password;
|
|
@Value("${yinsheng.h5.private_key_path}")
|
private String privateKeyPath;
|
|
@Value("${yinsheng.h5.public_key_path}")
|
private String publicKeyPath;
|
|
/**
|
* wap支付，手机收银台
|
*/
|
public final static String WAP_METHOD = "ysepay.online.wap.directpay.createbyuser";
|
|
|
public Map<String, String> generateParam(VipCardVo cardVo, String orderNo) {
|
Map<String, String> mapData = new HashMap<>();
|
//组装请求参数报文
|
mapData.put("method", WAP_METHOD);
|
mapData.put("partner_id", partner_id);
|
mapData.put("timestamp", DateUtil.getDateNow());
|
mapData.put("charset", "utf-8");
|
mapData.put("sign_type", "SM");
|
mapData.put("notify_url", notify_url + "/api/v1/vipCardOrder/notifyByYinSheng");
|
//银盛支付处理完请求后，当前页面自动跳转到商户网站里指定页面的http路径。若不想回调，则需传入银盛指定地址
|
mapData.put("return_url", cardVo.getUrl());
|
mapData.put("version", "3.0");
|
|
mapData.put("out_trade_no", orderNo);
|
mapData.put("shopdate", DateUtil.getDateNowYmd());
|
mapData.put("subject", cardVo.getName());
|
mapData.put("total_amount", cardVo.parseSellingPrice());
|
mapData.put("currency", "CNY");
|
mapData.put("seller_id", seller_id);
|
mapData.put("seller_name", seller_name);
|
mapData.put("timeout_express", "30m");
|
mapData.put("business_code", business_code);
|
// mapData.put("pay_mode", "native");
|
// mapData.put("bank_type", "1903000");
|
try {
|
log.info("待验签数据：" + CommonUtil.mapToString(mapData));
|
String sign = sign(mapData);
|
mapData.put("sign", sign);
|
} catch (Exception e) {
|
log.error("签名异常：", e);
|
throw new CommonException("参数异常");
|
}
|
return mapData;
|
}
|
|
/**
|
* 异步通知参数验签
|
*/
|
public boolean asynVerifyYs(Map<String, String> reqMap) throws Exception {
|
//获取银盛公钥
|
GMCertInfo verifyCertInfo = GMSignUtils.getVerifyCertInfo(publicKeyPath);
|
//验签
|
String sign = reqMap.get("sign");
|
System.out.println("签名原文:" + reqMap);
|
String content = StringUtil.createLinkString(CommonUtil.paraFilter(reqMap));
|
System.out.println("验签数据" + content + "," + sign);
|
byte[] srcData = content.getBytes("utf-8");
|
boolean validateSignResult = GMSignUtils.verifyMsgSignSM2(verifyCertInfo, Base64.decodeBase64(sign.getBytes("utf-8")), srcData);
|
return validateSignResult;
|
}
|
|
/**
|
* 同步请求参数签名
|
*/
|
public String sign(Map<String, String> mapData) throws Exception {
|
//商户私钥地址
|
//将所有外层报文参数（sign除外）进行字典排序，组成字符串得到待签名内容
|
String signContent = CommonUtil.mapToString(mapData);
|
log.info("待签名内容：{}", signContent);
|
//执行签名
|
String sign = GMSignUtils.signMsgSM2(privateKeyPath, password, signContent);
|
return sign;
|
}
|
|
public JSONObject getOrderStatus(VipCardOrder order) {
|
Map<String, String> mapData = new HashMap<>();
|
//组装请求参数报文
|
mapData.put("method", "ysepay.online.trade.order.query");
|
mapData.put("partner_id", partner_id);
|
mapData.put("timestamp", DateUtil.getDateNow());
|
mapData.put("charset", "utf-8");
|
mapData.put("sign_type", "SM");
|
mapData.put("version", "3.0");
|
JSONObject biz_content = new JSONObject();
|
biz_content.put("out_trade_no", order.getPartnerThirdOrderId());
|
biz_content.put("shopdate", cn.hutool.core.date.DateUtil.format(order.getCreationDate(), "yyyyMMdd"));
|
mapData.put("biz_content", biz_content.toJSONString());
|
try {
|
log.info("待验签数据：" + CommonUtil.mapToString(mapData));
|
String sign = sign(mapData);
|
mapData.put("sign", sign);
|
} catch (Exception e) {
|
log.error("签名异常：", e);
|
throw new CommonException("参数异常");
|
}
|
//调用银盛接口查询状态
|
String result = HttpRequest.sendPost("https://search.ysepay.com/gateway.do", CommonUtil.mapToString(mapData));
|
try {
|
JSONObject jsonObject = JSON.parseObject(result, Feature.OrderedField);
|
log.info("银盛查询明细返回原始参数：jsonObject:" + jsonObject);
|
JSONObject response = jsonObject.getJSONObject("ysepay_online_trade_order_query_response");
|
String content = response.toString();
|
String sign = jsonObject.get("sign").toString();
|
log.info("sign:" + sign);
|
log.info("content:" + content);
|
boolean verify = resultVerify(sign, content);
|
log.info("同步请求验签结果:{}", verify);
|
if (verify && "Success".equals(response.getString("msg"))) {
|
return response;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("同步请求验签异常" + result);
|
throw new CommonException("同步请求验签异常");
|
}
|
return null;
|
}
|
|
public boolean resultVerify(String sign, String content) throws Exception {
|
//获取银盛公钥
|
GMCertInfo verifyCertInfo = GMSignUtils.getVerifyCertInfo(publicKeyPath);
|
//验签
|
byte[] srcData = content.getBytes("utf-8");
|
boolean validateSignResult = GMSignUtils.verifyMsgSignSM2(verifyCertInfo, Base64.decodeBase64(sign.getBytes("utf-8")), srcData);
|
return validateSignResult;
|
}
|
|
}
|
