| | |
| | | import com.java110.utils.constant.WechatConstant; |
| | | import com.java110.utils.factory.ApplicationContextFactory; |
| | | import com.java110.utils.util.StringUtil; |
| | | |
| | | import org.apache.commons.codec.binary.Base64; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import com.java110.core.log.LoggerFactory; |
| | | import org.springframework.http.HttpStatus; |
| | | import org.springframework.http.ResponseEntity; |
| | | import org.springframework.web.client.RestTemplate; |
| | | import sun.misc.BASE64Decoder; |
| | | |
| | | import javax.crypto.Cipher; |
| | | import javax.crypto.spec.IvParameterSpec; |
| | |
| | | * @return |
| | | */ |
| | | private static String refreshAccessToken(String appId, String appSecure) { |
| | | String getAccessToken = MappingCache.getRemark(WechatConstant.WECHAT_DOMAIN,WechatConstant.GET_ACCESS_TOKEN_URL); |
| | | if(StringUtil.isEmpty(getAccessToken)){ |
| | | String getAccessToken = MappingCache.getRemark(WechatConstant.WECHAT_DOMAIN, WechatConstant.GET_ACCESS_TOKEN_URL); |
| | | if (StringUtil.isEmpty(getAccessToken)) { |
| | | getAccessToken = WechatConstant.GET_ACCESS_TOKEN; |
| | | } |
| | | String url = getAccessToken.replace("APPID", appId) |
| | | .replace("SECRET", appSecure); |
| | | RestTemplate outRestTemplate = ApplicationContextFactory.getBean("outRestTemplate", RestTemplate.class); |
| | | String response = outRestTemplate.getForObject(url, String.class); |
| | | if(outRestTemplate == null){ |
| | | throw new IllegalArgumentException("查询token 失败"); |
| | | } |
| | | ResponseEntity<String> responseEntity = outRestTemplate.getForEntity(url, String.class); |
| | | logger.debug("获取access_token 入参:" + url + " 返回参数" + responseEntity); |
| | | |
| | | logger.debug("获取access_token 入参:" + url + " 返回参数" + response); |
| | | if (responseEntity.getStatusCode() != HttpStatus.OK) { |
| | | throw new IllegalArgumentException("查询token 失败"); |
| | | } |
| | | |
| | | JSONObject responseObj = JSONObject.parseObject(response); |
| | | JSONObject responseObj = JSONObject.parseObject(responseEntity.getBody()); |
| | | |
| | | |
| | | if (responseObj.containsKey("access_token")) { |
| | | String accessToken = responseObj.getString("access_token"); |
| | |
| | | |
| | | public static String decryptS5(String sSrc, String encodingFormat, String sKey, String ivParameter) { |
| | | try { |
| | | BASE64Decoder decoder = new BASE64Decoder(); |
| | | byte[] raw = decoder.decodeBuffer(sKey); |
| | | Base64 base64 = new Base64(); |
| | | byte[] raw = base64.decode(sKey); |
| | | SecretKeySpec skeySpec = new SecretKeySpec(raw, "AES"); |
| | | IvParameterSpec iv = new IvParameterSpec(decoder.decodeBuffer(ivParameter)); |
| | | IvParameterSpec iv = new IvParameterSpec(base64.decode(ivParameter)); |
| | | Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding"); |
| | | cipher.init(Cipher.DECRYPT_MODE, skeySpec, iv); |
| | | byte[] myendicod = decoder.decodeBuffer(sSrc); |
| | | byte[] myendicod = base64.decode(sSrc); |
| | | byte[] original = cipher.doFinal(myendicod); |
| | | String originalString = new String(original, encodingFormat); |
| | | return originalString; |