package com.nova.sankuai.domain.api.xinyongfei;
|
|
import com.alibaba.fastjson.JSON;
|
import com.nova.sankuai.security.HttpClientUtil;
|
import com.nova.sankuai.security.MD5Encryption;
|
import io.swagger.annotations.ApiModel;
|
import io.swagger.annotations.ApiModelProperty;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.DigestUtils;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.IOException;
|
import java.util.HashMap;
|
|
@ApiModel(value = "信用飞对接")
|
@Data
|
@Slf4j
|
@Component
|
public class XinYongFeiUtil {
|
|
@Value("${xinyongfei.conf.collision_url}")
|
@ApiModelProperty(value = "撞库接口URL地址")
|
private String collisionUrl;
|
|
@Value("${xinyongfei.conf.auto_url}")
|
@ApiModelProperty(value = "联登接口URL地址")
|
private String autoUrl;
|
|
@Value("${xinyongfei.conf.secretKey}")
|
@ApiModelProperty(value = "接口密钥")
|
private String secretKey;
|
|
@ApiModelProperty(value = "信用飞下载地址")
|
private static final String DOWNLOAD_ADDRESS = "https://m-v3.xinyongfei.cn/activity/landingpage?type=XYF12&app_name=xyf01&utm_source=QD-CPS-XYF01-DDH01";
|
|
//获取撞库sign
|
public String getCollisionLibrarySign(String phone) {
|
String md5 = MD5Encryption.getMD5(phone);
|
String phoneString = "mobile" + "=" + md5;
|
String signString = phoneString + secretKey;
|
String sign = "";
|
try {
|
sign = DigestUtils.md5DigestAsHex(signString.getBytes());
|
} catch (Exception e) {
|
log.error("信用飞错误，撞库对接数据md5加秘签名失败:{}", e);
|
return null;
|
}
|
return sign;
|
}
|
|
//获取联登sign
|
public String getAutoSign(String phone, HttpServletRequest request) {
|
String agent = request.getHeader("User-Agent");
|
log.info("获取os:{}", agent);
|
String phoneString = "mobile" + "=" + phone;
|
String signString = phoneString + "&os=" + agent + secretKey;
|
String sign = "";
|
try {
|
sign = DigestUtils.md5DigestAsHex(signString.getBytes());
|
} catch (Exception e) {
|
log.error("信用飞错误，联登对接数据md5加秘签名失败:{}", e);
|
return null;
|
}
|
return sign;
|
}
|
|
//获取撞库对接数据
|
public String getCollisionLibraryJson(String phoneString, String sign) {
|
HashMap<String, String> map = new HashMap<>();
|
map.put("mobile", phoneString);
|
map.put("sign", sign);
|
String result = "";
|
try {
|
result = JSON.toJSONString(map);
|
} catch (Exception e) {
|
log.error("信用飞错误，撞库对接数据转换json失败:{}", e);
|
return null;
|
}
|
return result;
|
}
|
|
//获取联登对接数据
|
public static String getAutoJson(String phone, String agent, String sign) {
|
HashMap<String, String> map = new HashMap<>();
|
map.put("mobile", phone);
|
map.put("os", agent);
|
map.put("sign", sign);
|
String result = "";
|
try {
|
result = JSON.toJSONString(map);
|
} catch (Exception e) {
|
log.error("信用飞错误，联登对接数据转换json失败:{}", e);
|
return null;
|
}
|
return result;
|
}
|
|
/**
|
* 撞库
|
*
|
* @param phone
|
* @return
|
*/
|
public XinYongFeiResponse collisionLibraryRequest(String phone) {
|
String collisionLibrarySign = getCollisionLibrarySign(phone);
|
String collisionLibraryJson = getCollisionLibraryJson(MD5Encryption.getMD5(phone), collisionLibrarySign);
|
String result = "";
|
try {
|
result = HttpClientUtil.getInstance().postJsonData(collisionUrl , collisionLibraryJson);
|
log.info("信用飞原始数据：{}",result);
|
} catch (IOException e) {
|
log.error("信用飞错误，原始返回为：{}",result+"撞库连接获取信息失败:{}", e);
|
e.printStackTrace();
|
return null;
|
}
|
XinYongFeiResponse xinYongFeiResponse = null;
|
try {
|
xinYongFeiResponse = JSON.parseObject(result, XinYongFeiResponse.class);
|
} catch (Exception e) {
|
log.error("信用飞错误，撞库对接数据转换json失败:{}", e);
|
return null;
|
}
|
return xinYongFeiResponse;
|
}
|
|
/**
|
* 联登
|
*
|
* @param phone
|
* @param request
|
* @return
|
*/
|
public XinYongFeiResponse autoRequest(String phone, HttpServletRequest request) {
|
String autoSign = getAutoSign(phone, request);
|
String agent = request.getHeader("User-Agent");
|
String autoJson = getAutoJson(phone, agent, autoSign);
|
String result = "";
|
try {
|
result = HttpClientUtil.getInstance().postJsonData(autoUrl , autoJson);
|
} catch (IOException e) {
|
log.error("信用飞错误，联登连接获取信息失败:{}", e);
|
e.printStackTrace();
|
return null;
|
}
|
XinYongFeiResponse xinYongFeiResponse = null;
|
try {
|
xinYongFeiResponse = JSON.parseObject(result, XinYongFeiResponse.class);
|
} catch (Exception e) {
|
log.error("信用飞错误，联登对接数据转换json失败:{}", e);
|
return null;
|
}
|
return xinYongFeiResponse;
|
}
|
|
public String getDownloadAddress() {
|
return DOWNLOAD_ADDRESS;
|
}
|
|
}
|
