修改bug

Pu Zhibing

7 天以前 8d9c26c91eff811b8c4193e31f7b9e3e4dd56812

 DriverQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/zhenglian/ZhengLianUtil.java

@@ -1,7 +1,15 @@
package com.stylefeng.guns.modular.system.util.zhenglian;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.stylefeng.guns.modular.system.util.SpringContextsUtil;
import com.stylefeng.guns.modular.system.util.UUIDUtil;
import com.stylefeng.guns.modular.system.util.zhenglian.model.MessageBody;
import com.stylefeng.guns.modular.system.util.zhenglian.model.TradeTerminalInfo;
import com.stylefeng.guns.modular.system.util.zhenglian.model.ZLUserInfo;
import com.zlpay.assist.encrypt.sm4.SM4Util;
import com.zlpay.assist.sign.sm2.SM2Cert;
import com.zlpay.assist.sign.sm2.SM2Util;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.RandomStringUtils;

@@ -9,7 +17,11 @@
import java.io.FileInputStream;
import java.io.IOException;
import java.security.cert.X509Certificate;
import java.text.SimpleDateFormat;
import java.util.Base64;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * @author zhibing.pu
@@ -20,6 +32,90 @@
   
   private static ZhengLianConfig zhengLianConfig = SpringContextsUtil.getBean(ZhengLianConfig.class).getZhengLianConfig();
   
	
	
	
	
   /**
    * 获取用户详情
    * @param appUserId
    * @param tradeTerminalInfo
    * @return
    * @throws Exception
    */
   public static ZLUserInfo getUserInfo(String appUserId, TradeTerminalInfo tradeTerminalInfo) throws Exception {
      SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
      Map<String,String> headerMap = new HashMap<String,String>();
      MessageBody body = new MessageBody();
      headerMap.put("msgId", UUIDUtil.getRandomCode());
      headerMap.put("merchNo", "B00000871");
      headerMap.put("txCode", "ZLPAY.ACC.T0009");
      headerMap.put("version", "1.0.1");
      headerMap.put("signa", "1");
      headerMap.put("signNo", zhengLianConfig.getSignNo());
      headerMap.put("encrp", "1");
      headerMap.put("encrpNo", zhengLianConfig.getEncrpNo());
      headerMap.put("timestamp", sdf.format(new Date()));
		
      Map<String, Object> map = new HashMap<>();
      map.put("appId", zhengLianConfig.getAppid());
      map.put("appUserId", appUserId);
      map.put("tradeTerminalInfo", tradeTerminalInfo);
      String reqBO = JSON.toJSONString(map);
      // 生成对称加密秘钥
      String key = ZhengLianUtil.generateKey(16);
      // 加密数据
      String jsonData = SM4Util.sm4EcbEncrypt(key, reqBO, "NoPadding");
      //加密对称加密的秘钥
      // 获取公钥
      String publicKey = ZhengLianUtil.getPublicKey();
      String secrtKey = SM2Util.encrypt(publicKey, key);
		
      // 将密文放入body
      body.setData(jsonData);
      body.setSign(ZhengLianUtil.sign(jsonData));
      body.setSecret(secrtKey);
      String result = ZLHttpClientUtil.doPost(zhengLianConfig.getUrl(), headerMap, JSON.toJSONString(body));
		
      System.out.println("应答内容："+ result);
      MessageBody respBody = JSON.parseObject(result,MessageBody.class);
      // 验签
      boolean checkResult = SM2Util.verify(publicKey, zhengLianConfig.getEncrpNo(), respBody.getSign(), respBody.getData());
      System.out.println("验签结果：" + checkResult);
      // 获取私钥
      String privateKey = ZhengLianUtil.getPrivateKey();
      // 解密对称秘钥
      String k = SM2Util.decrypt(privateKey, respBody.getSecret());
      System.out.println("对称秘钥：" + k);
      // 解密业务报文
      String backData = SM4Util.sm4EcbDecrypt(k, respBody.getData());
      System.out.println("返回业务报文：" + backData);
      JSONObject jsonObject = JSON.parseObject(backData);
      String sysRtnCode = jsonObject.getString("sysRtnCode");
      if(!"000000".equals(sysRtnCode)){
         log.error("查询用户信息失败！{}", jsonObject.getString("sysRtnMsg"));
         throw new Exception(jsonObject.getString("sysRtnMsg"));
      }
      JSONObject bizData = jsonObject.getJSONObject("bizData");
      String resCode = bizData.getString("resCode");
      if("F010900".equals(resCode)){
         return null;
      }
      if(!"S010000".equals(resCode)){
         log.error("查询用户信息失败！{}", bizData.getString("resMsg"));
         throw new Exception(jsonObject.getString("resMsg"));
      }
      JSONObject resData = bizData.getJSONObject("resData");
      ZLUserInfo zlUserInfo = resData.toJavaObject(ZLUserInfo.class);
      return zlUserInfo;
   }
	
	
	
	
	
	
	
   /**
    * @Description: 从公钥证书获取公钥串
    * @return