package com.nova.sankuai.infra.utils.mxc;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.nova.sankuai.domain.dto.mxc.MxcDTO;
|
import com.nova.sankuai.domain.dto.mxc.MxcData;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.entity.StringEntity;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.util.EntityUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import java.nio.charset.StandardCharsets;
|
import java.util.Objects;
|
|
/**
|
* 芒小橙对接
|
*/
|
@Component
|
public class MxcUtil {
|
|
//撞库url
|
@Value("${mxc.url}")
|
private String url;
|
|
@Value("${mxc.aesKey}")
|
private String aesKey;
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
public String push(String idcard, String phone, String name) {
|
String respMsg = "";
|
log.info("芒小橙联登撞库开始： phone:{} name:{} idcard:{}", phone, name, idcard);
|
try {
|
JSONObject jsonObject = new JSONObject();
|
JSONObject jsonObject1 = new JSONObject();
|
jsonObject.put("partner_id","mxchycyp");
|
jsonObject1.put("idCard",idcard);
|
jsonObject1.put("name",name);
|
jsonObject1.put("phoneNum", phone);
|
// cn.hutool.crypto.symmetric.AES aes = new cn.hutool.crypto.symmetric.AES("ECB",
|
// "PKCS5Padding", "OZqKairb9ciGd9xWn4q8re1g".getBytes());
|
cn.hutool.crypto.symmetric.AES aes = new cn.hutool.crypto.symmetric.AES("ECB",
|
"PKCS5Padding", aesKey.getBytes());
|
String biz_data = aes.encryptBase64(jsonObject1.toJSONString());
|
jsonObject.put("biz_data",biz_data);
|
//发送请求
|
CloseableHttpClient httpClient = HttpClients.createDefault();
|
// HttpPost httpPost = new HttpPost("http://101.37.166.164:8885/ycNotify-server/rongbei/121/check");
|
HttpPost httpPost = new HttpPost(url);
|
httpPost.addHeader("Content-type", "application/json; charset=UTF-8");
|
httpPost.setEntity(new StringEntity(jsonObject.toJSONString(), StandardCharsets.UTF_8));
|
|
|
CloseableHttpResponse response = httpClient.execute(httpPost);
|
HttpEntity entity = response.getEntity();
|
respMsg = EntityUtils.toString(entity, StandardCharsets.UTF_8);
|
if (StringUtils.isBlank(respMsg)) {
|
log.error("芒小橙联登撞库失败： phone:{} name:{} idcard:{} 返回参数：{}", phone, name, idcard, respMsg);
|
}
|
else {
|
MxcDTO res = JSON.parseObject(respMsg, MxcDTO.class);
|
if (Objects.isNull(res)) {
|
log.error("芒小橙联登撞库失败： phone:{} name:{} idcard:{} 返回参数：{}", phone, name, idcard, respMsg);
|
} else {
|
if (1 == res.getStatus()) {
|
log.error("芒小橙联登撞库失败： phone:{} name:{} idcard:{} 返回参数：{}", phone, name, idcard, respMsg);
|
}
|
else {
|
String data = res.getData();
|
data = aes.decryptStr(data);
|
MxcData mxcData = JSON.parseObject(data, MxcData.class);
|
String appUrl = mxcData.getAppUrl();
|
if(StringUtils.isNotBlank(appUrl)) {
|
log.info("芒小橙联登撞库成功： phone:{} name:{} idcard:{} 返回参数：{}", phone, name, idcard, respMsg);
|
url = appUrl;
|
}
|
else {
|
log.error("芒小橙联登撞库失败： phone:{} name:{} idcard:{} 返回参数：{}", phone, name, idcard, respMsg);
|
}
|
}
|
}
|
}
|
|
} catch (Exception e) {
|
log.error("芒小橙联登撞库失败： phone:{} name:{} idcard:{} 返回参数：{} 错误：{}", phone, name, idcard, respMsg,e);
|
}
|
return url;
|
}
|
|
}
|
