cbs8 sm2工具类、支付状态枚举类
This commit is contained in:
parent
1b2c85402d
commit
673885c091
|
|
@ -0,0 +1,71 @@
|
|||
package com.hzya.frame.cbs8.util;
|
||||
|
||||
/**
|
||||
* @Author:hecan
|
||||
* @Description:支付类型(支付状态)
|
||||
* @params:
|
||||
* @return:
|
||||
* @Date: 2023/3/14 15:05
|
||||
*/
|
||||
public enum PayState {
|
||||
a("a","待提交直联"),
|
||||
b("b","已提交直联"),
|
||||
c("c","银行已受理"),
|
||||
d("d","银行未受理"),
|
||||
e("e","可疑"),
|
||||
f("f","待人工确认"),
|
||||
g("g","支付成功"),
|
||||
h("h","支付失败"),
|
||||
i("i","部分成功"),
|
||||
j("j","退票"),
|
||||
k("k","取消支付"),
|
||||
n("n","其他"),
|
||||
p("p","支付中"),
|
||||
q("q","待支付"),
|
||||
one("1","待处理"),
|
||||
two("2","审批中"),
|
||||
three("3","处理失败"),
|
||||
four("4","审批通过"),
|
||||
five("5","审批撤销"),
|
||||
six("6","审批拒绝"),
|
||||
seven("7","待发送审批"),
|
||||
eight("8","集中受理中"),
|
||||
nine("9","审批退回"),
|
||||
ten("10","未处理");
|
||||
|
||||
|
||||
//类型
|
||||
private String type;
|
||||
//值
|
||||
private String value;
|
||||
|
||||
PayState(String type, String value){
|
||||
this.type=type;
|
||||
this.value=value;
|
||||
}
|
||||
|
||||
public String getType() {
|
||||
return type;
|
||||
}
|
||||
|
||||
public void setType(String type) {
|
||||
this.type = type;
|
||||
}
|
||||
|
||||
public String getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public void setValue(String value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
public static String payStateGetValue(String type){
|
||||
for (PayState payState : PayState.values()){
|
||||
if(payState.getType()==type||payState.getType().equals(type)){
|
||||
return payState.getValue().toString();
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,231 @@
|
|||
package com.hzya.frame.cbs8.util;
|
||||
|
||||
import org.bouncycastle.asn1.*;
|
||||
import org.bouncycastle.crypto.engines.SM2Engine;
|
||||
import org.bouncycastle.crypto.params.*;
|
||||
import org.bouncycastle.crypto.signers.SM2Signer;
|
||||
import org.bouncycastle.jce.ECNamedCurveTable;
|
||||
import org.bouncycastle.jce.spec.ECParameterSpec;
|
||||
import org.bouncycastle.math.ec.ECCurve;
|
||||
import org.bouncycastle.math.ec.ECPoint;
|
||||
import org.bouncycastle.util.encoders.Hex;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import java.io.ByteArrayInputStream;
|
||||
import java.math.BigInteger;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.security.SecureRandom;
|
||||
import java.util.Base64;
|
||||
import java.util.Enumeration;
|
||||
|
||||
/**
|
||||
* @author: xiang2lin
|
||||
* @time: 2024/6/14
|
||||
* @description: SM2加解密工具类
|
||||
*/
|
||||
|
||||
public class SM2Util {
|
||||
static Logger logger = LoggerFactory.getLogger(SM2Util.class);
|
||||
private SM2Util() {
|
||||
throw new IllegalStateException("Utility class");
|
||||
}
|
||||
|
||||
private static final String STD_NAME = "sm2p256v1";
|
||||
|
||||
/**
|
||||
* SM2加密算法
|
||||
*
|
||||
* @param publicKey 公钥
|
||||
* @param data 明文数据
|
||||
* @return
|
||||
*/
|
||||
public static byte[] encrypt(String publicKey, byte[] data) {
|
||||
ECPublicKeyParameters ecPublicKeyParameters = encodePublicKey(Hex.decode(publicKey));
|
||||
SM2Engine engine = new SM2Engine();
|
||||
engine.init(true, new ParametersWithRandom(ecPublicKeyParameters, new SecureRandom()));
|
||||
|
||||
byte[] bytes = null;
|
||||
try {
|
||||
byte[] cipherText = engine.processBlock(data, 0, data.length);
|
||||
bytes = C1C2C3ToC1C3C2(cipherText);
|
||||
} catch (Exception e) {
|
||||
logger.warn("SM2加密时出现异常:" + e.getMessage());
|
||||
}
|
||||
return bytes;
|
||||
}
|
||||
|
||||
/**
|
||||
* SM2解密算法
|
||||
*
|
||||
* @param privateKey 私钥
|
||||
* @param cipherData 密文数据
|
||||
* @return
|
||||
*/
|
||||
public static byte[] decrypt(String privateKey, byte[] cipherData) {
|
||||
ECPrivateKeyParameters ecPrivateKeyParameters = encodePrivateKey(Hex.decode(privateKey));
|
||||
SM2Engine engine = new SM2Engine();
|
||||
engine.init(false, ecPrivateKeyParameters);
|
||||
|
||||
byte[] bytes = null;
|
||||
try {
|
||||
cipherData = C1C3C2ToC1C2C3(cipherData);
|
||||
bytes = engine.processBlock(cipherData, 0, cipherData.length);
|
||||
} catch (Exception e) {
|
||||
logger.warn("SM2解密时出现异常:" + e.getMessage());
|
||||
}
|
||||
return bytes;
|
||||
}
|
||||
|
||||
/**
|
||||
* 签名算法
|
||||
*
|
||||
* @param privateKey 私钥
|
||||
* @param data 明文数据
|
||||
* @return
|
||||
*/
|
||||
public static byte[] sign(String privateKey, byte[] data) {
|
||||
ECPrivateKeyParameters ecPrivateKeyParameters = encodePrivateKey(hexToByte(privateKey));
|
||||
SM2Signer signer = new SM2Signer();
|
||||
ParametersWithID parameters = new ParametersWithID(ecPrivateKeyParameters, "1234567812345678".getBytes());
|
||||
signer.init(true, parameters);
|
||||
signer.update(data, 0, data.length);
|
||||
|
||||
byte[] signature = null;
|
||||
try {
|
||||
signature = decodeDERSignature(signer.generateSignature());
|
||||
} catch (Exception e) {
|
||||
logger.warn("SM2签名时出现异常:" + e.getMessage());
|
||||
}
|
||||
return signature;
|
||||
}
|
||||
|
||||
private static byte[] hexToByte(String hex)
|
||||
throws IllegalArgumentException {
|
||||
if (hex.length() % 2 != 0) {
|
||||
throw new IllegalArgumentException();
|
||||
}
|
||||
char[] arr = hex.toCharArray();
|
||||
byte[] b = new byte[hex.length() / 2];
|
||||
for (int i = 0, j = 0, l = hex.length(); i < l; i++, j++) {
|
||||
String swap = "" + arr[i++] + arr[i];
|
||||
int byteInt = Integer.parseInt(swap, 16) & 0xFF;
|
||||
b[j] = BigInteger.valueOf(byteInt).byteValue();
|
||||
}
|
||||
return b;
|
||||
}
|
||||
|
||||
private static byte[] C1C2C3ToC1C3C2(byte[] cipherText) throws Exception {
|
||||
if (cipherText != null && cipherText.length >= 97) {
|
||||
byte[] bytes = new byte[cipherText.length];
|
||||
System.arraycopy(cipherText, 0, bytes, 0, 65);
|
||||
System.arraycopy(cipherText, cipherText.length - 32, bytes, 65, 32);
|
||||
System.arraycopy(cipherText, 65, bytes, 97, cipherText.length - 97);
|
||||
return bytes;
|
||||
} else {
|
||||
throw new Exception("SM2 cipher text error, must be more than 96 bytes and in the format C1||C3||C2.");
|
||||
}
|
||||
}
|
||||
|
||||
private static byte[] C1C3C2ToC1C2C3(byte[] cipherText) throws Exception {
|
||||
if (cipherText != null && cipherText.length >= 97) {
|
||||
byte[] bytes = new byte[cipherText.length];
|
||||
System.arraycopy(cipherText, 0, bytes, 0, 65);
|
||||
System.arraycopy(cipherText, 97, bytes, 65, cipherText.length - 97);
|
||||
System.arraycopy(cipherText, 65, bytes, cipherText.length - 32, 32);
|
||||
return bytes;
|
||||
} else {
|
||||
throw new Exception("SM2 cipher text error, must be more than 96 bytes and in the format C1||C3||C2.");
|
||||
}
|
||||
}
|
||||
|
||||
private static ECPublicKeyParameters encodePublicKey(byte[] value) {
|
||||
byte[] x = new byte[32];
|
||||
byte[] y = new byte[32];
|
||||
System.arraycopy(value, 1, x, 0, 32);
|
||||
System.arraycopy(value, 33, y, 0, 32);
|
||||
BigInteger X = new BigInteger(1, x);
|
||||
BigInteger Y = new BigInteger(1, y);
|
||||
ECPoint Q = getSM2Curve().createPoint(X, Y);
|
||||
return new ECPublicKeyParameters(Q, getECDomainParameters());
|
||||
}
|
||||
|
||||
private static ECCurve getSM2Curve() {
|
||||
ECParameterSpec spec = ECNamedCurveTable.getParameterSpec(STD_NAME);
|
||||
return spec.getCurve();
|
||||
}
|
||||
|
||||
private static ECPrivateKeyParameters encodePrivateKey(byte[] value) {
|
||||
BigInteger d = new BigInteger(1, value);
|
||||
return new ECPrivateKeyParameters(d, getECDomainParameters());
|
||||
}
|
||||
|
||||
private static ECDomainParameters getECDomainParameters() {
|
||||
ECParameterSpec spec = ECNamedCurveTable.getParameterSpec(STD_NAME);
|
||||
return new ECDomainParameters(spec.getCurve(), spec.getG(), spec.getN(), spec.getH(), spec.getSeed());
|
||||
}
|
||||
|
||||
private static byte[] decodeDERSignature(byte[] signature) {
|
||||
ASN1InputStream stream = new ASN1InputStream(new ByteArrayInputStream(signature));
|
||||
|
||||
byte[] bytes = new byte[64];
|
||||
try {
|
||||
ASN1Sequence primitive = (ASN1Sequence) stream.readObject();
|
||||
Enumeration enumeration = primitive.getObjects();
|
||||
BigInteger R = ((ASN1Integer) enumeration.nextElement()).getValue();
|
||||
BigInteger S = ((ASN1Integer) enumeration.nextElement()).getValue();
|
||||
byte[] r = format(R.toByteArray());
|
||||
byte[] s = format(S.toByteArray());
|
||||
System.arraycopy(r, 0, bytes, 0, 32);
|
||||
System.arraycopy(s, 0, bytes, 32, 32);
|
||||
} catch (Exception e) {
|
||||
logger.warn("decodeDERSignature时出现异常:" + e.getMessage());
|
||||
}
|
||||
return bytes;
|
||||
}
|
||||
|
||||
public static byte[] encodeDERSignature(byte[] signature) {
|
||||
byte[] r = new byte[32];
|
||||
byte[] s = new byte[32];
|
||||
System.arraycopy(signature, 0, r, 0, 32);
|
||||
System.arraycopy(signature, 32, s, 0, 32);
|
||||
ASN1EncodableVector vector = new ASN1EncodableVector();
|
||||
vector.add(new ASN1Integer(new BigInteger(1, r)));
|
||||
vector.add(new ASN1Integer(new BigInteger(1, s)));
|
||||
|
||||
byte[] encoded = null;
|
||||
try {
|
||||
encoded = (new DERSequence(vector)).getEncoded();
|
||||
} catch (Exception e) {
|
||||
logger.warn("encodeDERSignature时出现异常:" + e.getMessage());
|
||||
}
|
||||
return encoded;
|
||||
}
|
||||
|
||||
private static byte[] format(byte[] value) {
|
||||
if (value.length == 32) {
|
||||
return value;
|
||||
} else {
|
||||
byte[] bytes = new byte[32];
|
||||
if (value.length > 32) {
|
||||
System.arraycopy(value, value.length - 32, bytes, 0, 32);
|
||||
} else {
|
||||
System.arraycopy(value, 0, bytes, 32 - value.length, value.length);
|
||||
}
|
||||
return bytes;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public static void main(String[] args) {
|
||||
String requestData = "hello啊";
|
||||
byte[] encrypt = encrypt("0452d60e72f6a3050d2f8e8f4505f874ef345e15da38fda8dd64b9e756b7231c056dff1674c4826ada424cc78ea36fd58afc50bcefb5d721bf25b179efac2ebb17", requestData.getBytes(StandardCharsets.UTF_8));
|
||||
String temp = new String(encrypt);
|
||||
byte[] decrypt = decrypt("c3509b6df8bdaf84c464daa1b6fa11a8fca77b0e4a6f076ee68487f288278a85", encrypt);
|
||||
System.out.println("解密完成"+new String(decrypt));
|
||||
|
||||
String encodeToString = Base64.getEncoder().encodeToString(encrypt);
|
||||
byte[] decode = Base64.getDecoder().decode(encodeToString);
|
||||
byte[] decrypt1 = decrypt("c3509b6df8bdaf84c464daa1b6fa11a8fca77b0e4a6f076ee68487f288278a85", decode);
|
||||
System.out.println("解密完成1"+new String(decrypt1));
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue