wxz
4 years ago
28 changed files with 1160 additions and 142 deletions
@ -0,0 +1,19 @@ |
|||||
|
package com.epmet.dto.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
/** |
||||
|
* @Description 第三方平台及其支持的action result |
||||
|
* @author wxz |
||||
|
* @date 2021.08.30 17:06:42 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class ThirdPlatformActionsResultDTO { |
||||
|
|
||||
|
private String platformId; |
||||
|
private String platformKey; |
||||
|
private String platformName; |
||||
|
private String actionKey; |
||||
|
private String apiUrl; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,18 @@ |
|||||
|
package com.epmet.dto.result.privateepmet; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
/** |
||||
|
* @Description 获取accesstoken结果 |
||||
|
* @author wxz |
||||
|
* @date 2021.08.30 17:40:25 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class GetAccessTokenResultDTO { |
||||
|
|
||||
|
// token
|
||||
|
private String accessToken; |
||||
|
// 有效时长
|
||||
|
private Long expireTime; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,169 @@ |
|||||
|
package com.epmet.apiservice.impl; |
||||
|
|
||||
|
import com.alibaba.fastjson.JSON; |
||||
|
import com.alibaba.fastjson.TypeReference; |
||||
|
import com.epmet.apiservice.ApiService; |
||||
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
||||
|
import com.epmet.commons.tools.exception.ExceptionUtils; |
||||
|
import com.epmet.commons.tools.exception.RenException; |
||||
|
import com.epmet.commons.tools.feign.ResultDataResolver; |
||||
|
import com.epmet.commons.tools.utils.ConvertUtils; |
||||
|
import com.epmet.commons.tools.utils.HttpClientManager; |
||||
|
import com.epmet.commons.tools.utils.Result; |
||||
|
import com.epmet.constant.ThirdPlatformActions; |
||||
|
import com.epmet.dto.form.AuthorizerAccessTokenFormDTO; |
||||
|
import com.epmet.dto.form.ComponentAccessTokenFormDTO; |
||||
|
import com.epmet.dto.result.privateepmet.GetAccessTokenResultDTO; |
||||
|
import com.epmet.openapi.sdk.sign.OpenApiSignUtils; |
||||
|
import com.epmet.redis.ThirdPlatformCache; |
||||
|
import lombok.extern.slf4j.Slf4j; |
||||
|
import org.apache.commons.lang3.StringUtils; |
||||
|
import org.springframework.stereotype.Component; |
||||
|
|
||||
|
import java.util.HashMap; |
||||
|
import java.util.Map; |
||||
|
import java.util.UUID; |
||||
|
import java.util.concurrent.TimeUnit; |
||||
|
|
||||
|
@Component("pingyinPrivateEpmetApiService") |
||||
|
@Slf4j |
||||
|
public class PingyinPrivateEpmetApiService extends ApiService<Result> implements ResultDataResolver { |
||||
|
|
||||
|
// 认证方式
|
||||
|
private String authType = "take_token"; |
||||
|
|
||||
|
@Override |
||||
|
public String getAccessTokenHeaderName() { |
||||
|
return "AccessToken"; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String getAccessToken(String platformId) { |
||||
|
String accessTokenFromCache = super.getAccessTokenFromCache(platformId); |
||||
|
if (StringUtils.isBlank(accessTokenFromCache)) { |
||||
|
ThirdPlatformCache thirdPlatformInfo = super.getThirdPlatformInfo(platformId); |
||||
|
String apiUrl = getThirdPlatformActionUrl(platformId, ThirdPlatformActions.GET_ACCESS_TOKEN); |
||||
|
String baseUrl = thirdPlatformInfo.getBaseUrl(); |
||||
|
String platformKey = thirdPlatformInfo.getPlatformKey(); |
||||
|
String platformSecret = thirdPlatformInfo.getPlatformSecret(); |
||||
|
String uuid = UUID.randomUUID().toString(); |
||||
|
long currentTimeMillis = System.currentTimeMillis(); |
||||
|
|
||||
|
try { |
||||
|
String sign = createSign(platformKey, platformSecret, uuid, currentTimeMillis, authType, null); |
||||
|
log.info("【调用平阴私有化平台获取AccessToken】参数列表:sign:{}, app_id:{}, auth_type:{}, nonce:{}, timestamp:{}", sign, platformKey, platformSecret, uuid, currentTimeMillis); |
||||
|
String urlParams = super.convertQueryParams2String(constructCommonUrlParamsMap(platformKey, authType, uuid, currentTimeMillis, sign)); |
||||
|
String requestUrl = baseUrl.concat(apiUrl).concat(urlParams); |
||||
|
Result<String> stringResult = HttpClientManager.getInstance().sendPostByHttps(requestUrl, "{}"); |
||||
|
String remoteResultString = getResultDataOrThrowsException(stringResult, "【调用平阴私有化平台获取AccessToken】", EpmetErrorCode.SERVER_ERROR.getCode(), null); |
||||
|
Result<GetAccessTokenResultDTO> remoteResult = parsePlatformResponseResult(remoteResultString, GetAccessTokenResultDTO.class); |
||||
|
log.info("【调用平阴私有化平台获取AccessToken】结果:{}", remoteResultString); |
||||
|
accessTokenFromCache = remoteResult.getData().getAccessToken(); |
||||
|
//(15 * 60 * 1000)为提前获取token。对方token有效期2小时，我们设置有效期为1小时45分钟，留15分钟容错时间，防止时间差
|
||||
|
long expire = remoteResult.getData().getExpireTime() - System.currentTimeMillis() - (15 * 60 * 1000); |
||||
|
super.addAccessTokenToCache(platformId, accessTokenFromCache, expire, TimeUnit.MILLISECONDS); |
||||
|
} catch (Exception e) { |
||||
|
throw new RenException(ExceptionUtils.getErrorStackTrace(e)); |
||||
|
} |
||||
|
} |
||||
|
return accessTokenFromCache; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 创建签名 |
||||
|
* @param platformKey |
||||
|
* @param platformSecret |
||||
|
* @param nonce |
||||
|
* @param timeMillis |
||||
|
* @param authType |
||||
|
* @return java.lang.String |
||||
|
* @author wxz |
||||
|
* @date 2021.08.31 15:37:58 |
||||
|
*/ |
||||
|
private String createSign(String platformKey, String platformSecret, String nonce, Long timeMillis, String authType, Map<String, String> requestBodyMap) { |
||||
|
HashMap<String, String> contentMap = new HashMap<>(); |
||||
|
contentMap.put("app_id", platformKey); |
||||
|
contentMap.put("auth_type", authType); |
||||
|
contentMap.put("nonce", nonce); |
||||
|
contentMap.put("timestamp", String.valueOf(timeMillis)); |
||||
|
|
||||
|
if (requestBodyMap != null && requestBodyMap.size() > 0) { |
||||
|
contentMap.putAll(requestBodyMap); |
||||
|
} |
||||
|
|
||||
|
String sign; |
||||
|
try { |
||||
|
sign = OpenApiSignUtils.createSign(contentMap, platformSecret); |
||||
|
} catch (Exception e) { |
||||
|
String detail = ExceptionUtils.getErrorStackTrace(e); |
||||
|
log.error(detail); |
||||
|
throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode(), "【平阴私有化平台apService】创建签名失败"); |
||||
|
} |
||||
|
return sign; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 构造url参数map |
||||
|
* @param platformKey |
||||
|
* @param authType |
||||
|
* @param nonce |
||||
|
* @param timeMillis |
||||
|
* @param sign |
||||
|
* @return java.util.Map<java.lang.String,java.lang.String> |
||||
|
* @author wxz |
||||
|
* @date 2021.08.31 14:19:41 |
||||
|
*/ |
||||
|
private Map<String, String> constructCommonUrlParamsMap(String platformKey, String authType, String nonce, Long timeMillis, String sign) { |
||||
|
HashMap<String, String> map = new HashMap<>(); |
||||
|
map.put("app_id", platformKey); |
||||
|
map.put("auth_type", authType); |
||||
|
map.put("nonce", nonce); |
||||
|
map.put("timestamp", String.valueOf(timeMillis)); |
||||
|
map.put("sign", sign); |
||||
|
return map; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public <T> Result<T> parsePlatformResponseResult(String resultString, Class<T> clazz) { |
||||
|
Result<T> result; |
||||
|
try { |
||||
|
result = JSON.parseObject(resultString, new TypeReference<Result<T>>(clazz){}); |
||||
|
} catch (Exception e) { |
||||
|
String errorStackTrace = ExceptionUtils.getErrorStackTrace(e); |
||||
|
log.error(errorStackTrace); |
||||
|
throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode(), "【调用平阴私有化服务器，解析返回结果失败】"); |
||||
|
} |
||||
|
if (!result.success()) { |
||||
|
throw new RenException(String.format("【请求平阴私有化平台】失败，返回结果string:%s", resultString)); |
||||
|
} |
||||
|
return result; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public void pushComponentAccessToken(ComponentAccessTokenFormDTO form, String platformId, String platformKey) { |
||||
|
ThirdPlatformCache thirdPlatformInfo = getThirdPlatformInfo(platformId); |
||||
|
String nonce = UUID.randomUUID().toString(); |
||||
|
long timeMillis = System.currentTimeMillis(); |
||||
|
|
||||
|
Map<String, String> bodyMap = null; |
||||
|
try { |
||||
|
bodyMap = ConvertUtils.entityToMap(form); |
||||
|
} catch (Exception e) { |
||||
|
String detail = ExceptionUtils.getErrorStackTrace(e); |
||||
|
log.error(detail); |
||||
|
throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode(), "【推送ComponentAccessToken】requestBody转化为map失败"); |
||||
|
} |
||||
|
|
||||
|
String sign = createSign(platformKey, thirdPlatformInfo.getPlatformSecret(), nonce, timeMillis, authType, bodyMap); |
||||
|
Map<String, String> urlParams = constructCommonUrlParamsMap(platformKey, authType, nonce, timeMillis, sign); |
||||
|
|
||||
|
String jsonString = JSON.toJSONString(form); |
||||
|
Result result = super.sendPostRequest(platformId, ThirdPlatformActions.PUSH_COMPONENT_ACCESS_TOKEN, jsonString, null, urlParams); |
||||
|
getResultDataOrThrowsException(result, "【平阴私有化平台】推送ComponentAccessToken", EpmetErrorCode.SERVER_ERROR.getCode(), null); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public void pushAuthorizerAccessToken(AuthorizerAccessTokenFormDTO form, String platformId, String platformKey) { |
||||
|
|
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,50 @@ |
|||||
|
package com.epmet.controller; |
||||
|
|
||||
|
import com.epmet.commons.tools.utils.Result; |
||||
|
import com.epmet.dto.form.AuthorizerAccessTokenFormDTO; |
||||
|
import com.epmet.dto.form.ComponentAccessTokenFormDTO; |
||||
|
import com.epmet.service.PrivateEpmetService; |
||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||
|
import org.springframework.web.bind.annotation.PostMapping; |
||||
|
import org.springframework.web.bind.annotation.RequestBody; |
||||
|
import org.springframework.web.bind.annotation.RequestMapping; |
||||
|
import org.springframework.web.bind.annotation.RestController; |
||||
|
|
||||
|
/** |
||||
|
* @Description 私有化平台相关controller |
||||
|
* @author wxz |
||||
|
* @date 2021.08.30 15:18:51 |
||||
|
*/ |
||||
|
@RestController |
||||
|
@RequestMapping("/private-epmet") |
||||
|
public class PrivateEpmetController { |
||||
|
|
||||
|
@Autowired |
||||
|
private PrivateEpmetService privateEpmetService; |
||||
|
|
||||
|
/** |
||||
|
* @Description 接收推送component access |
||||
|
* @param input |
||||
|
* @return com.epmet.commons.tools.utils.Result |
||||
|
* @author wxz |
||||
|
* @date 2021.08.30 15:18:57 |
||||
|
*/ |
||||
|
@PostMapping("push-component-access-token") |
||||
|
public Result pushComponentAccessToken(@RequestBody ComponentAccessTokenFormDTO input) { |
||||
|
privateEpmetService.pushComponentAccessToken(input); |
||||
|
return new Result(); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 接收推送AuthorizerTokens |
||||
|
* @param input |
||||
|
* @return com.epmet.commons.tools.utils.Result |
||||
|
* @author wxz |
||||
|
* @date 2021.08.30 16:36:02 |
||||
|
*/ |
||||
|
@PostMapping("push-authorizer-tokens") |
||||
|
public Result pushAuthorizerTokens(@RequestBody AuthorizerAccessTokenFormDTO input) { |
||||
|
privateEpmetService.pushAuthorizerTokens(input); |
||||
|
return new Result(); |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,30 @@ |
|||||
|
package com.epmet.controller; |
||||
|
|
||||
|
import com.epmet.commons.tools.utils.Result; |
||||
|
import com.epmet.dto.form.ComponentAccessTokenFormDTO; |
||||
|
import com.epmet.service.ComponentVerifyTicketService; |
||||
|
import com.epmet.service.PrivateEpmetService; |
||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||
|
import org.springframework.web.bind.annotation.PostMapping; |
||||
|
import org.springframework.web.bind.annotation.RequestMapping; |
||||
|
import org.springframework.web.bind.annotation.RestController; |
||||
|
|
||||
|
import java.util.Date; |
||||
|
|
||||
|
@RestController |
||||
|
@RequestMapping("test") |
||||
|
public class TestConttroller { |
||||
|
|
||||
|
@Autowired |
||||
|
private ComponentVerifyTicketService componentVerifyTicketService; |
||||
|
|
||||
|
@PostMapping("push-component-access-token") |
||||
|
public Result testPushComponentAccessToken() { |
||||
|
ComponentAccessTokenFormDTO form = new ComponentAccessTokenFormDTO(); |
||||
|
form.setComponentAccessToken("token..."); |
||||
|
form.setExpiresInTime(new Date()); |
||||
|
componentVerifyTicketService.pushComponentAccessToken2PrivateEpmetPlatforms(form); |
||||
|
return new Result(); |
||||
|
} |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,19 @@ |
|||||
|
package com.epmet.redis; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
/** |
||||
|
* @Description 第三方平台缓存对象 |
||||
|
* @author wxz |
||||
|
* @date 2021.08.31 14:41:49 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class ThirdPlatformCache { |
||||
|
//String platformKey, String platformSecret, String platformName, String apiService, String baseUrl
|
||||
|
private String platformId; |
||||
|
private String platformKey; |
||||
|
private String platformSecret; |
||||
|
private String platformName; |
||||
|
private String apiService; |
||||
|
private String baseUrl; |
||||
|
} |
||||
@ -0,0 +1,19 @@ |
|||||
|
package com.epmet.service; |
||||
|
|
||||
|
import com.epmet.dto.form.AuthorizerAccessTokenFormDTO; |
||||
|
import com.epmet.dto.form.ComponentAccessTokenFormDTO; |
||||
|
|
||||
|
public interface PrivateEpmetService { |
||||
|
void pushAuthorizerTokens(AuthorizerAccessTokenFormDTO input); |
||||
|
|
||||
|
/** |
||||
|
* @Description 推送component access token |
||||
|
* @param input |
||||
|
* @return void |
||||
|
* @author wxz |
||||
|
* @date 2021.08.30 16:17:48 |
||||
|
*/ |
||||
|
void pushComponentAccessToken(ComponentAccessTokenFormDTO input); |
||||
|
|
||||
|
void pushVerifyTicket(String ticket); |
||||
|
} |
||||
@ -0,0 +1,71 @@ |
|||||
|
package com.epmet.service.impl; |
||||
|
|
||||
|
import com.epmet.constant.ThirdRunTimeInfoConstant; |
||||
|
import com.epmet.dao.AuthorizationInfoDao; |
||||
|
import com.epmet.dao.ComponentAccessTokenDao; |
||||
|
import com.epmet.dao.ComponentVerifyTicketDao; |
||||
|
import com.epmet.dto.form.AuthorizationInfoFormDTO; |
||||
|
import com.epmet.dto.form.AuthorizerAccessTokenFormDTO; |
||||
|
import com.epmet.dto.form.ComponentAccessTokenFormDTO; |
||||
|
import com.epmet.dto.result.AuthorizationInfoResultDTO; |
||||
|
import com.epmet.redis.RedisThird; |
||||
|
import com.epmet.service.PrivateEpmetService; |
||||
|
import lombok.extern.slf4j.Slf4j; |
||||
|
import org.springframework.beans.BeanUtils; |
||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||
|
import org.springframework.stereotype.Service; |
||||
|
import org.springframework.transaction.annotation.Transactional; |
||||
|
|
||||
|
@Service |
||||
|
@Slf4j |
||||
|
public class PrivateEpmetServiceImpl implements PrivateEpmetService { |
||||
|
|
||||
|
@Autowired |
||||
|
private ComponentVerifyTicketDao componentVerifyTicketDao; |
||||
|
|
||||
|
@Autowired |
||||
|
private AuthorizationInfoDao authorizationInfoDao; |
||||
|
|
||||
|
@Autowired |
||||
|
private ComponentAccessTokenDao componentAccessTokenDao; |
||||
|
|
||||
|
@Autowired |
||||
|
private RedisThird redisThird; |
||||
|
|
||||
|
@Transactional(rollbackFor = RuntimeException.class) |
||||
|
@Override |
||||
|
public void pushAuthorizerTokens(AuthorizerAccessTokenFormDTO input) { |
||||
|
System.out.println("收到AuthorizerAccessTokenFormDTO：" + input); |
||||
|
|
||||
|
//AuthorizationInfoFormDTO authorizationInfo = new AuthorizationInfoFormDTO();
|
||||
|
//BeanUtils.copyProperties(input,authorizationInfo);
|
||||
|
//authorizationInfo.setAuthorizerAppid(input.getAuthAppid());
|
||||
|
////先逻辑删除，在插入
|
||||
|
//authorizationInfoDao.deleteOldAuthorizerAccessToken(input.getCustomerId(), input.getClientType());
|
||||
|
//authorizationInfoDao.insertAuthorizerAccessToken(input);
|
||||
|
////缓存 refreshAuthorizerAccessToken
|
||||
|
//redisThird.setAuthorizerRefreshToken(authorizationInfo);
|
||||
|
//AuthorizationInfoResultDTO resultDTO = new AuthorizationInfoResultDTO();
|
||||
|
//resultDTO.setAuthorizer_access_token(input.getAuthorizerAccessToken());
|
||||
|
//resultDTO.setAuthorizer_refresh_token(input.getAuthorizerRefreshToken());
|
||||
|
//resultDTO.setAuthorizer_appid(input.getAuthAppid());
|
||||
|
//resultDTO.setExpires_in(7200);
|
||||
|
//redisThird.setAuthInfo(resultDTO,input.getCustomerId(),input.getClientType());
|
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
@Transactional(rollbackFor = RuntimeException.class) |
||||
|
public void pushComponentAccessToken(ComponentAccessTokenFormDTO componentAccessToken) { |
||||
|
System.out.println("收到componentAccessToken：" + componentAccessToken); |
||||
|
//先逻辑删，在插入
|
||||
|
//componentAccessTokenDao.deleteOldComponentAccessToken();
|
||||
|
//componentAccessTokenDao.insertComponentAccessToken(componentAccessToken);
|
||||
|
////存缓存
|
||||
|
//redisThird.setComponentAccessToken(componentAccessToken.getComponentAccessToken());
|
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public void pushVerifyTicket(String ticket) { |
||||
|
|
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,15 @@ |
|||||
|
<?xml version="1.0" encoding="UTF-8"?> |
||||
|
<project xmlns="http://maven.apache.org/POM/4.0.0" |
||||
|
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
||||
|
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
||||
|
<parent> |
||||
|
<artifactId>epmet-openapi</artifactId> |
||||
|
<groupId>com.epmet</groupId> |
||||
|
<version>2.0.0</version> |
||||
|
</parent> |
||||
|
<modelVersion>4.0.0</modelVersion> |
||||
|
|
||||
|
<artifactId>epmet-openapi-sdk</artifactId> |
||||
|
|
||||
|
|
||||
|
</project> |
||||
@ -0,0 +1,133 @@ |
|||||
|
package com.epmet.openapi.sdk.encrypt; |
||||
|
|
||||
|
import java.io.UnsupportedEncodingException; |
||||
|
import java.security.MessageDigest; |
||||
|
import java.security.NoSuchAlgorithmException; |
||||
|
|
||||
|
public class Md5Util { |
||||
|
/** |
||||
|
* 加密盐 值 |
||||
|
*/ |
||||
|
public static final String SALT = "EPMET_UMD_SALT"; |
||||
|
|
||||
|
public static String md5(String string) throws Exception { |
||||
|
if (string == null || string.trim().length() == 0) { |
||||
|
return null; |
||||
|
} |
||||
|
return getMD5(string.getBytes("GBK")); |
||||
|
} |
||||
|
|
||||
|
private static final char hexDigits[] = { // 用来将字节转换成 16 进制表示的字符
|
||||
|
'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'}; |
||||
|
|
||||
|
private static String getMD5(byte[] source) throws Exception { |
||||
|
String s = null; |
||||
|
MessageDigest md = MessageDigest.getInstance("MD5"); |
||||
|
md.update(source); |
||||
|
byte tmp[] = md.digest(); // MD5 的计算结果是一个 128 位的长整数，
|
||||
|
// 用字节表示就是 16 个字节
|
||||
|
char str[] = new char[16 * 2]; // 每个字节用 16 进制表示的话，使用两个字符，
|
||||
|
// 所以表示成 16 进制需要 32 个字符
|
||||
|
int k = 0; // 表示转换结果中对应的字符位置
|
||||
|
for (int i = 0; i < 16; i++) { // 从第一个字节开始，对 MD5 的每一个字节
|
||||
|
// 转换成 16 进制字符的转换
|
||||
|
byte byte0 = tmp[i]; // 取第 i 个字节
|
||||
|
str[k++] = hexDigits[byte0 >>> 4 & 0xf]; // 取字节中高 4 位的数字转换,
|
||||
|
// >>> 为逻辑右移，将符号位一起右移
|
||||
|
str[k++] = hexDigits[byte0 & 0xf]; // 取字节中低 4 位的数字转换
|
||||
|
} |
||||
|
s = new String(str); // 换后的结果转换为字符串
|
||||
|
return s; |
||||
|
} |
||||
|
|
||||
|
private static String byteArrayToHexString(byte b[]) { |
||||
|
StringBuffer resultSb = new StringBuffer(); |
||||
|
for (int i = 0; i < b.length; i++) |
||||
|
resultSb.append(byteToHexString(b[i])); |
||||
|
|
||||
|
return resultSb.toString(); |
||||
|
} |
||||
|
|
||||
|
private static String byteToHexString(byte b) { |
||||
|
int n = b; |
||||
|
if (n < 0) |
||||
|
n += 256; |
||||
|
int d1 = n / 16; |
||||
|
int d2 = n % 16; |
||||
|
return hexDigits[d1] + "" + hexDigits[d2]; |
||||
|
} |
||||
|
|
||||
|
public static String MD5Encode(String origin, String charsetname) throws Exception { |
||||
|
String resultString = null; |
||||
|
resultString = new String(origin); |
||||
|
MessageDigest md = MessageDigest.getInstance("MD5"); |
||||
|
if (charsetname == null || "".equals(charsetname)) |
||||
|
resultString = byteArrayToHexString(md.digest(resultString |
||||
|
.getBytes())); |
||||
|
else |
||||
|
resultString = byteArrayToHexString(md.digest(resultString |
||||
|
.getBytes(charsetname))); |
||||
|
return resultString; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
public static void main(String[] args) { |
||||
|
for (int i = 0; i < 5; i++) { |
||||
|
String uuid = "03a1dcd8cb1811eabac1c03fd56f7847"; |
||||
|
System.out.println(get12Char(uuid)); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* 获取短字符 |
||||
|
* |
||||
|
* @param str |
||||
|
* @return 大写 |
||||
|
*/ |
||||
|
public static String get12Char(String str) { |
||||
|
String arr[] = ShortText(str); |
||||
|
String rst = (arr[0] + arr[1]).toUpperCase(); |
||||
|
return rst.substring(0, 4) + rst.substring(4, 8) + rst.substring(8, 12); |
||||
|
} |
||||
|
|
||||
|
private static String[] ShortText(String string) { |
||||
|
String[] chars = new String[]{ // 要使用生成URL的字符
|
||||
|
"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", |
||||
|
"o", "p", "q", "r", "s", "t", "u", "v", "w", "x", "y", "z", |
||||
|
"0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "A", "B", |
||||
|
"C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M", "N", |
||||
|
"O", "P", "Q", "R", "S", "T", "U", "V", "W", "X", "Y", "Z"}; |
||||
|
|
||||
|
String hex = ""; |
||||
|
|
||||
|
MessageDigest md = null; |
||||
|
try { |
||||
|
md = MessageDigest.getInstance("MD5"); |
||||
|
hex = byteArrayToHexString(md.digest(SALT.concat(string) |
||||
|
.getBytes("utf-8"))); |
||||
|
} catch (Exception e) { |
||||
|
e.printStackTrace(); |
||||
|
} |
||||
|
|
||||
|
int hexLen = hex.length(); |
||||
|
int subHexLen = hexLen / 8; |
||||
|
String[] ShortStr = new String[4]; |
||||
|
|
||||
|
for (int i = 0; i < subHexLen; i++) { |
||||
|
String outChars = ""; |
||||
|
int j = i + 1; |
||||
|
String subHex = hex.substring(i * 8, j * 8); |
||||
|
long idx = Long.valueOf("3FFFFFFF", 16) & Long.valueOf(subHex, 16); |
||||
|
|
||||
|
for (int k = 0; k < 6; k++) { |
||||
|
int index = (int) (Long.valueOf("0000003D", 16) & idx); |
||||
|
outChars += chars[index]; |
||||
|
idx = idx >> 5; |
||||
|
} |
||||
|
ShortStr[i] = outChars; |
||||
|
} |
||||
|
|
||||
|
return ShortStr; |
||||
|
} |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,109 @@ |
|||||
|
package com.epmet.openapi.sdk.sign; |
||||
|
|
||||
|
import com.epmet.openapi.sdk.encrypt.Md5Util; |
||||
|
|
||||
|
import java.util.*; |
||||
|
|
||||
|
/** |
||||
|
* OpenApi签名工具 |
||||
|
*/ |
||||
|
public class OpenApiSignUtils { |
||||
|
|
||||
|
/** |
||||
|
* @Description 创建签名 |
||||
|
* @return |
||||
|
* @author wxz |
||||
|
* @date 2021.03.22 16:47 |
||||
|
*/ |
||||
|
public static String createSign(Map<String, String> contentMap, String signKey) throws Exception { |
||||
|
String str2beSigned = mapToSignStr(contentMap); |
||||
|
str2beSigned = str2beSigned.concat("&sign_key=").concat(signKey); |
||||
|
return Md5Util.md5(str2beSigned); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 验签 |
||||
|
* @return |
||||
|
* @author wxz |
||||
|
* @date 2021.03.22 16:51 |
||||
|
*/ |
||||
|
public static boolean checkSign(Map<String, String> contentMap, String signKey) throws Exception { |
||||
|
String newSign = createSign(contentMap, signKey); |
||||
|
return newSign.equals(contentMap.get("sign")); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description map转化为签名明文 |
||||
|
* @return |
||||
|
* @author wxz |
||||
|
* @date 2021.03.22 16:47 |
||||
|
*/ |
||||
|
public static String mapToSignStr(Map<String, String> map) { |
||||
|
Set<String> keySet = map.keySet(); |
||||
|
String[] keyArray = (String[])keySet.toArray(new String[keySet.size()]); |
||||
|
Arrays.sort(keyArray); |
||||
|
StringBuilder sb = new StringBuilder(); |
||||
|
|
||||
|
for(int i = 0; i < keyArray.length; ++i) { |
||||
|
String key = keyArray[i]; |
||||
|
String val = (String)map.get(key); |
||||
|
if (val != null && val.trim().length() > 0 && !"sign".equals(key)) { |
||||
|
if (!sb.toString().isEmpty()) { |
||||
|
sb.append("&"); |
||||
|
} |
||||
|
|
||||
|
sb.append(key).append("=").append((String)map.get(key)); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return sb.toString(); |
||||
|
} |
||||
|
|
||||
|
public static void main(String[] args) throws Exception { |
||||
|
generateGetAccessTokenSign(); |
||||
|
System.out.println("=============="); |
||||
|
generateGetOrgDetailSign(); |
||||
|
} |
||||
|
|
||||
|
private static void generateGetAccessTokenSign() throws Exception { |
||||
|
long now = System.currentTimeMillis(); |
||||
|
System.out.println(now); |
||||
|
|
||||
|
String uuid = UUID.randomUUID().toString().replace("-", ""); |
||||
|
|
||||
|
HashMap<String, String> content = new HashMap<>(); |
||||
|
content.put("app_id", "7d98b8af2d05752b4225709c4cfd4bd0"); |
||||
|
content.put("timestamp", String.valueOf(now)); |
||||
|
content.put("nonce", uuid); |
||||
|
content.put("auth_type", "take_token"); |
||||
|
|
||||
|
String secret = "3209ee9f41704482be1a1fb5873a25376f2899191ca846119d44168316bc3e44"; |
||||
|
|
||||
|
String sign = createSign(content, secret); |
||||
|
|
||||
|
System.out.println("时间戳:" + now); |
||||
|
System.out.println("随机数:" + uuid); |
||||
|
System.out.println("签名：" + sign); |
||||
|
} |
||||
|
|
||||
|
private static void generateGetOrgDetailSign() throws Exception { |
||||
|
long now = System.currentTimeMillis(); |
||||
|
String uuid = UUID.randomUUID().toString().replace("-", "");; |
||||
|
System.out.println("时间戳:" + now); |
||||
|
System.out.println("随机数:" + uuid); |
||||
|
|
||||
|
HashMap<String, String> content = new HashMap<>(); |
||||
|
//content.put("orgId", "aaa");
|
||||
|
//content.put("test", null);
|
||||
|
content.put("gridId", "12128e0f614f1c00a058ea9a107033b2"); |
||||
|
content.put("app_id", "7d98b8af2d05752b4225709c4cfd4bd0"); |
||||
|
content.put("timestamp", String.valueOf(now)); |
||||
|
content.put("nonce", uuid); |
||||
|
content.put("auth_type", "take_token"); |
||||
|
|
||||
|
String secret = "3209ee9f41704482be1a1fb5873a25376f2899191ca846119d44168316bc3e44"; |
||||
|
|
||||
|
String sign = createSign(content, secret); |
||||
|
System.out.println("签名：" + sign); |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue