package com.nova.sankuai.infra.utils.zhxyp;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import org.apache.commons.lang3.StringUtils;
|
import com.nova.sankuai.security.HttpClientUtil;
|
import lombok.RequiredArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Objects;
|
|
/**
|
* Describe: 纵星优品接口
|
* Author: 纪新雷
|
* CreateTime: 2024-09-04
|
*
|
*/
|
@Component
|
@RequiredArgsConstructor
|
public class ZhxypUtil {
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
//撞库url
|
@Value("${zhxyp.zkUrl}")
|
private String zkUrl;
|
|
/**
|
* Describe: 撞库
|
* @param idcard : String 身份证
|
* @param phone : String 手机号
|
* @param name : String 姓名
|
* @return code = 0 不成功, code = 1 表示成功
|
* {code :0 ,data:[],msg:’’”}
|
* {code :1,data:[url:’’,sn:’’],msg:””}
|
* Author: 纪新雷
|
* CreateTime: 2024-09-04
|
*
|
*/
|
public String check(String idcard, String phone, String name) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：{} idcard:{} phone:{} name:{} 撞库流程开始",logNumber, idcard, phone, name);
|
|
|
// if(StringUtils.isBlank(idcard)) {
|
// log.info("日志编号：" + logNumber + " 身份证入参为空");
|
// return null;
|
// }
|
//
|
if(StringUtils.isBlank(phone)) {
|
log.info("日志编号：" + logNumber + " 手机号入参为空");
|
return null;
|
}
|
//
|
if(StringUtils.isBlank(name)) {
|
log.info("日志编号：" + logNumber + " 姓名入参为空");
|
// throw new CommonException("姓名不能为空");
|
return null;
|
}
|
//
|
//
|
|
JSONObject body = new JSONObject();
|
body.put("idcard", StringUtils.defaultString(idcard));
|
body.put("phone", phone);
|
body.put("name", name);
|
|
|
String result = null;
|
try {
|
// 撞库
|
result = HttpClientUtil.getInstance().postJsonData(zkUrl, body.toJSONString());
|
log.info("日志编号：{} idcard:{} phone:{} name:{} , 撞库返回参数:{}",logNumber, idcard, phone, name, result);
|
} catch (Exception ex) {
|
log.error("日志编号：{} idcard:{} phone:{} name:{} , 撞库失败，传参：{} ex：{}",logNumber, idcard, phone, name, body, ex);
|
return null;
|
}
|
try {
|
// ChannelUnionCollisionResponse res = JSON.parseObject(result, ChannelUnionCollisionResponse.class);
|
// JSONObject resultObj = (JSONObject)JSONObject.toJSON(res);
|
// return resultObj.toJSONString();
|
String rtnValue = null;
|
//result = "{\"code\":1,\"data\":{\"url\":\"https:\\/\\/www.zhxyp.com\\/index\\/index\\/down2\",\"sn\":\"27x20240908152837164051\"},\"msg\":\"\\u6570\\u636e\\u5141\\u8bb8\\u51c6\\u5165!\"}";
|
JSONObject res = JSON.parseObject(result);
|
if (res.containsKey("code") && 1 == res.getInteger("code")) {
|
log.info("日志编号：{} idcard:{} phone:{} name:{} , 撞库成功",logNumber, idcard, phone, name);
|
JSONObject dataObj = res.getJSONObject("data");
|
if(null != dataObj && !Objects.isNull(dataObj)
|
) {
|
if(dataObj.containsKey("url") && !StringUtils.isBlank(dataObj.getString("url"))
|
) {
|
rtnValue = dataObj.getString("url");
|
}
|
}
|
|
|
|
return rtnValue;
|
} else {
|
log.info("日志编号：{} idcard:{} phone:{} name:{} , 撞库失败",logNumber, idcard, phone, name);
|
return null;
|
}
|
} catch (Exception ex) {
|
log.error("日志编号：{} idcard:{} phone:{} name:{} , 撞库原始返回参数转换失败，传参：{} ex：{}",logNumber, idcard, phone, name, body, ex);
|
// throw new CommonException("撞库原始返回参数转换失败");
|
return null;
|
}
|
|
}
|
|
}
|
