联调后后联调后后联调后后联调后后

//package com.jd.jdt.ftdev.qed.link.backend.controller.gatewaytools; // //import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; //import com.baomidou.mybatisplus.extension.plugins.pagination.Page; //import com.jd.jdt.ftdev.qed.link.backend.common.controller.BaseController; //import com.mashape.unirest.http.HttpResponse; //import com.mashape.unirest.http.Unirest; //import com.mashape.unirest.http.exceptions.UnirestException; //import lombok.extern.slf4j.Slf4j; //import net.sf.json.JSONObject; //import org.apache.commons.lang3.StringUtils; //import org.apache.commons.lang3.time.StopWatch; //import org.apache.shiro.authz.annotation.RequiresPermissions; //import org.springframework.http.HttpHeaders; //import org.springframework.http.HttpStatus; //import org.springframework.http.ResponseEntity; //import org.springframework.stereotype.Controller; //import org.springframework.web.bind.annotation.*; //import org.springframework.web.client.RestTemplate; // //import javax.servlet.http.HttpServletResponse; //import java.net.URLEncoder; //import java.text.MessageFormat; //import java.text.SimpleDateFormat; //import java.util.*; // //@Controller //@Slf4j //@RequestMapping("/gatewaytools") //public class GatewayController extends BaseController { // // private final TypeService typeService; // private final KeyService keyService; // private final UserService userService; // private final RoleService roleService; // private final MerchantService merchantService; // private final CreditUserService creditUserService; // // private String message; // // public GatewayController(TypeService typeService, KeyService keyService, UserService userService, RoleService roleService, MerchantService merchantService, CreditUserService creditUserService) { // Unirest.setTimeouts(1000 * 50, 1000 * 50); // this.typeService = typeService; // this.keyService = keyService; // this.userService = userService; // this.roleService = roleService; // this.merchantService = merchantService; // this.creditUserService = creditUserService; // } // // public GateWayResponse req(GateWayRequest model) { // GatewayEntity req = new GatewayEntity(); // req.setMerchantCode(model.getMerchantCode()); // 白条测提供， 每个商户唯一 // req.setMerchantUserId(model.getMerchantUserId()); // 商户的用户ID，唯一标识一个用户 // req.setJrOpenId(StringUtils.isEmpty(model.getJrOpenId()) ? "" : model.getJrOpenId()); // 京东金融openId // req.setCharset("UTF-8"); // 默认utf-8 // req.setType(model.getTypeCode()); // 白条测研发提供，对应唯一接口 // req.setVersion("1.0"); // 默认1.0，对接前和白条研发确定 //// if ("2".equals(model.getGateVersion())) { //// req.setToken(model.getToken()); //// } // if(model.getToken() != null && model.getToken().length() != 0){ // req.setToken(model.getToken()); // } // // String bodyStr = model.getBodyString(); // GateWayResponse gateWayResponse = new GateWayResponse(); // try { // // 1、使用RSA算法生成签名 // String signStr = (new StringBuffer()) // .append(req.getMerchantCode()) // .append(req.getMerchantUserId()) // .append(req.getJrOpenId()) // .append(req.getCharset()) // .append(req.getType()) // .append(req.getVersion()) // .append(bodyStr) // .toString(); // req.setSign(RSA.sign(signStr, model.getMerchantPrivatekey())); // 签名 // // 2、随机生成16位AES密钥 // String aesKey = RandomUtil.getRandom(16); // System.out.println("aesKey:" + aesKey); // gateWayResponse.setAesKey(aesKey); // // 3、使用AES算法加密入参 // String bodyStrEncrypted = AES.encryptToBase64(bodyStr, aesKey); // req.setBody(bodyStrEncrypted); // 加密后报文 // // // 4、使用RSA算法加密aesKey // //4.1、白条公钥实时获取 // List<Key> keys = keyService.selKey(model.getMerchantCode()); // String publicKey = ""; // /*if (keys.size()>1){ // ArrayList<Float> versions = new ArrayList<Float>(); // for (Key k:keys){ // Float version = Float.valueOf(k.getVersion()); // versions.add(version); // } // //将版本号从大到小排序 // Collections.sort(versions, Collections.reverseOrder()); // for (Key k:keys){ // if (k.getVersion().equals(String.valueOf(versions.get(0)))){ // publicKey = k.getPublicKey(); // } // } // }else { // publicKey = keys.get(0).getPublicKey(); // }*/ // publicKey = model.getBaitiaoPublickey(); // String aesKeyEncrypted = RSA.encrypt(aesKey, publicKey);//model.getBaitiaoPublickey() // // req.setKey(aesKeyEncrypted); // 加密后的aesKey // System.out.println("网关入参组装完毕：" + GsonUtil.toJson(req)); // // gateWayResponse.setRequestData(GsonUtil.toJson(req)); // StopWatch stopWatch = new StopWatch(); // stopWatch.start(); // // 5、http调用 // HttpResponse<String> responseData = doPostTest( GsonUtil.toJson(req)); // stopWatch.stop(); // gateWayResponse.setMs(stopWatch.getTime()); // if (responseData.getStatus() == 200) { // // 6、转化响应结果 // GatewayEntity responseEntity = GsonUtil.fromJson(responseData.getBody(), GatewayEntity.class); // if (Objects.nonNull(responseEntity.getResult()) && !Boolean.valueOf(String.valueOf(responseEntity.getResult().get("success")))) { // gateWayResponse.setResponseData(responseData.getBody()); // } else { // // 7、RSA算法解密aes密钥 // String responseAesKey = RSA.decrypt(responseEntity.getKey(), model.getMerchantPrivatekey()); // System.out.println("响应报文aesKey为：" + responseAesKey); // // 8、AES算法解密报文 // String decryptedBody = AES.decryptFromBase64(responseEntity.getBody(), responseAesKey); // System.out.println("解密后的报文：" + decryptedBody); // gateWayResponse.setResponseData(decryptedBody); // // 9、RSA算法验签 // String responseSignStr = (new StringBuffer()).append(responseEntity.getMerchantCode()).append(responseEntity.getMerchantUserId()).append(responseEntity.getJrOpenId()).append(responseEntity.getCharset()). // append(responseEntity.getType()).append(responseEntity.getVersion()).append(decryptedBody).toString(); // boolean signRes = RSA.checkSign(responseSignStr, responseEntity.getSign(), model.getBaitiaoPublickey()); // System.out.println("验签结果：" + signRes); // gateWayResponse.setSignRes(signRes); // } // } else { // gateWayResponse.setResponseData(responseData.getBody()); // } // } catch (Exception ex) { // ex.printStackTrace(); // gateWayResponse.setResponseData(ex.getMessage()); // } // // return gateWayResponse; // } // // public static HttpResponse<String> doPostTest(String requestJson) throws UnirestException { // HttpResponse<String> response = Unirest.post("http://test.btgateway.jd.com/service/gatewayproxy") // .header("Content-Type", "a