package com.java110.common.charge.factory.kehang;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.annotation.Java110Synchronized;
|
import com.java110.core.factory.AuthenticationFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.utils.cache.JWTCache;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.factory.ApplicationContextFactory;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.PayUtil;
|
import com.java110.utils.util.StringUtil;
|
import org.slf4j.Logger;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.web.client.HttpStatusCodeException;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.crypto.Mac;
|
import javax.crypto.SecretKey;
|
import javax.crypto.spec.SecretKeySpec;
|
import java.util.*;
|
|
public class KeHangChargeUtils {
|
|
private static Logger logger = LoggerFactory.getLogger(KeHangChargeUtils.class);
|
|
|
public static final String KE_HANG_DOMAIN = "KE_HANG_CHARGE";
|
|
|
public static final String KE_HANG_APP_ID = "APP_ID";
|
public static final String KE_HANG_APP_SECURE = "APP_SECURE";
|
|
public static final String URL = "https://api.poseidong.com/api/gateway";
|
|
|
|
/**
|
* 请求充电桩 接口
|
* <p>
|
* MappingCache.getValue(DING_DING_DOMAIN, DING_DING_APP_ID),
|
* MappingCache.getValue(DING_DING_DOMAIN, DING_DING_APP_SECURE
|
*
|
* @param api
|
* @param body
|
* @param httpMethod
|
* @return
|
* @throws Exception
|
*/
|
public static String execute(String api, String body, HttpMethod httpMethod) throws Exception {
|
RestTemplate outRestTemplate = ApplicationContextFactory.getBean("outRestTemplate", RestTemplate.class);
|
HttpHeaders httpHeaders = new HttpHeaders();
|
httpHeaders.add("app_id", MappingCache.getValue(KE_HANG_DOMAIN, KE_HANG_APP_ID));
|
httpHeaders.add("psd_entry", DateUtil.getCurrentDate().getTime() + "");
|
|
JSONObject bodyObj = JSONObject.parseObject(body);
|
bodyObj.put("api",api);
|
bodyObj.put("nonce", PayUtil.makeUUID(16));
|
bodyObj.put("sign",getSign(bodyObj));
|
|
HttpEntity httpEntity = new HttpEntity(body, httpHeaders);
|
ResponseEntity<String> response = null;
|
try {
|
response = outRestTemplate.exchange(URL, httpMethod, httpEntity, String.class);
|
} catch (HttpStatusCodeException e) {
|
logger.error("请求异常", e.getResponseBodyAsString());
|
throw new IllegalArgumentException(e.getResponseBodyAsString());
|
}
|
|
return response.getBody();
|
}
|
|
|
|
|
private static String getSign(JSONObject bodyObj) throws Exception {
|
|
SortedMap map = new TreeMap();
|
|
for (String key: bodyObj.keySet()) {
|
String vlaue = bodyObj.getString("key");
|
map.put(key, vlaue);
|
}
|
|
StringBuffer sb = new StringBuffer();
|
Set es = map.entrySet();
|
Iterator<?> it = es.iterator();
|
while (it.hasNext()) {
|
Map.Entry entry = (Map.Entry) it.next();
|
String k = (String) entry.getKey();
|
if (entry.getValue() != null || !"".equals(entry.getValue())) {
|
String v = String.valueOf(entry.getValue());
|
if (null != v && !"".equals(v) && !"sign".equals(k) && !"key".equals(k)) {
|
sb.append(k + "=" + v + "&");
|
}
|
}
|
}
|
sb.append("key=" + MappingCache.getValue(KE_HANG_DOMAIN, KE_HANG_APP_SECURE));
|
String sign = AuthenticationFactory.md5(sb.toString()).toUpperCase();
|
return sign;
|
}
|
}
|
