| | |
| | | |
| | | private static OperatorClient operatorClient = SpringUtils.getBean(OperatorClient.class); |
| | | |
| | | private static Map<Long, Integer> map = new HashMap<>(); |
| | | public static Map<Long, Integer> map = new HashMap<>(); |
| | | |
| | | |
| | | /** |
| | | * 获取token |
| | | */ |
| | | public static String queryToken(Operator operator){ |
| | | HttpRequest post = HttpUtil.createPost(""); |
| | | HttpRequest post = HttpUtil.createPost(operator.getTestUrl() + InterfaceUrlEnum.QUERY_TOKEN.getUrl()); |
| | | post.contentType("application/json;charset=utf-8"); |
| | | JSONObject body = new JSONObject(); |
| | | body.put("OperatorID", OperatorID); |
| | | body.put("OperatorID", operator.getOurOperatorId()); |
| | | body.put("OperatorSecret", operator.getOurOperatorSecret()); |
| | | post.body(body.toJSONString()); |
| | | HttpResponse execute = post.execute(); |
| | |
| | | post.contentType("application/json;charset=utf-8"); |
| | | post.header("Authorization", "Bearer " + getToken(operator)); |
| | | BaseRequest baseRequest = new BaseRequest(); |
| | | baseRequest.setOperatorID(OperatorID); |
| | | baseRequest.setOperatorID(operator.getOurOperatorId()); |
| | | baseRequest.setTimeStamp(timeStamp); |
| | | baseRequest.setSeq(String.format("%04d", integer)); |
| | | String jsonString = JSON.toJSONString(o); |
| | | String encrypt = AESUtil.encrypt(jsonString, operator.getDataSecret(), operator.getDataSecretIv()); |
| | | String encrypt = AESUtil.encrypt(jsonString, operator.getOurDataSecret(), operator.getOurDataSecretIv()); |
| | | baseRequest.setData(encrypt); |
| | | baseRequest.setOperator(operator); |
| | | baseRequest.setSig(buildSign(baseRequest)); |
| | | baseRequest.setSig(ourBuildSign(baseRequest)); |
| | | post.body(JSON.toJSONString(baseRequest)); |
| | | //清空小于当前时间的map中的无效数据 |
| | | for (Long k : map.keySet()) { |
| | |
| | | */ |
| | | public static String buildSign(BaseModel model){ |
| | | Operator operator = model.getOperator(); |
| | | if(null == operator){ |
| | | return ""; |
| | | } |
| | | //签名秘钥SigSecret |
| | | String key = operator.getSigSecret(); |
| | | String sign = ""; |
| | |
| | | return sign; |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 构建签名字符串 |
| | | * @param model |
| | | * @return |
| | | */ |
| | | public static String ourBuildSign(BaseModel model){ |
| | | Operator operator = model.getOperator(); |
| | | if(null == operator){ |
| | | return ""; |
| | | } |
| | | //签名秘钥SigSecret |
| | | String key = operator.getOurSigSecret(); |
| | | String sign = ""; |
| | | switch (operator.getName()){ |
| | | case "XinDianTu": |
| | | //进行字符串拼接、计算 |
| | | String m = new StringBuilder(operator.getOurOperatorId()).append(model.getData()).append(model.getTimeStamp()).append(model.getSeq()).toString(); |
| | | byte[] hmacMd5 = SignUtil.getHMacMD5Bytes(key.getBytes(), m.getBytes()); |
| | | // 打印计算得到的签名Sig |
| | | sign = SignUtil.bytesToHexString(hmacMd5); |
| | | break; |
| | | case "KuaiDian": |
| | | sign = SignUtil.hmacSign(model.getData(), key); |
| | | break; |
| | | } |
| | | return sign; |
| | | } |
| | | |
| | | |
| | | } |