package com.nova.sankuai.infra.utils;
|
|
import cfca.sadk.extend.session.util.TextUtils;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.TypeReference;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.nova.sankuai.domain.api.zzxf.ZzxfDataImportVo;
|
import com.nova.sankuai.domain.api.zzxf.ZzxfResponse;
|
import com.nova.sankuai.domain.api.zzxf.ZzxfTokenResponse;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.enums.customerinfo.SesameStatusEnum;
|
import com.nova.sankuai.security.HttpClientUtil;
|
import com.nova.sankuai.service.IChannelInfoService;
|
import org.apache.commons.lang.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.security.NoSuchAlgorithmException;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* @Description 中赞信服工具类
|
* @Author CWR
|
* @Date 2022/5/20 12:06
|
*/
|
@Component
|
public class ZzxfUtil {
|
|
/**
|
* host
|
*/
|
@Value("${zzxf.host}")
|
private String host;
|
|
/**
|
* 渠道
|
*/
|
@Value("${zzxf.channel}")
|
private String channel;
|
|
/**
|
* 密钥
|
*/
|
@Value("${zzxf.secret}")
|
private String secret;
|
|
/**
|
* AES密钥
|
*/
|
@Value("${zzxf.aes-secret}")
|
private String aesSecret;
|
|
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
|
|
private static final Logger logger = LoggerFactory.getLogger("capitalLogger");
|
|
@Resource
|
IChannelInfoService channelInfoService;
|
|
/**
|
* 请求token
|
*
|
* @return
|
* @throws NoSuchAlgorithmException
|
*/
|
@SuppressWarnings("checked")
|
public ZzxfTokenResponse getToken() {
|
try {
|
// 生成随机字符串
|
String random = AesSecretUtils.getRandomString(16);
|
// 获取时间戳
|
String timestamp = String.valueOf(AesSecretUtils.getTimeStamp());
|
String data = this.channel + ";" + this.secret + ";" + random + ";" + timestamp;
|
logger.info("中赞获取平台token接口参数->:签名前字符串{}", data);
|
// 使用SHA-1对data进行签名
|
String sign = AesSecretUtils.sha1(data);
|
Map<String, Object> param = new HashMap<>(16);
|
param.put("channel", this.channel);
|
param.put("random", random);
|
param.put("times", timestamp);
|
param.put("sign", sign);
|
|
logger.info("中赞获取平台token接口参数->:{}", param);
|
String responseString = HttpClientUtil.getInstance().postJsonData(host + "big/data2022/gettoken", OBJECT_MAPPER.writeValueAsString(param));
|
logger.info("中赞获取平台token返回->:{}", responseString);
|
if (!TextUtils.isEmpty(responseString)) {
|
// ZzxfResponse<ZzxfTokenResponse> response = OBJECT_MAPPER.readValue(responseString, ZzxfResponse.class);
|
ZzxfResponse<ZzxfTokenResponse> response = JSON.parseObject(responseString, new TypeReference<ZzxfResponse<ZzxfTokenResponse>>() {
|
});
|
// 请求成功
|
if (0 == response.getResponseCode()) {
|
return response.getData();
|
}
|
}
|
} catch (Exception e) {
|
logger.error("中赞获取平台token接口出错");
|
e.printStackTrace();
|
return null;
|
}
|
return null;
|
}
|
|
/**
|
* 导入数据接口
|
*
|
* @param vo 导入数据vo
|
* @return
|
*/
|
public ZzxfResponse dataImport(Customer vo) {
|
ZzxfDataImportVo zzxfDataImportVo = new ZzxfDataImportVo();
|
zzxfDataImportVo.setAge(vo.getAge());
|
if (vo.getAge() == null && !StringUtils.isEmpty(vo.getBirthday())) {
|
calcuAge(zzxfDataImportVo, vo.getBirthday());
|
}
|
zzxfDataImportVo.setBaitiao(0);
|
zzxfDataImportVo.setChildSource(null);
|
if (vo.getCityName() != null) {
|
String cityName = vo.getCityName();
|
if (cityName.endsWith("市")) {
|
cityName = cityName.substring(0, cityName.length() - 1);
|
}
|
zzxfDataImportVo.setCity(cityName);
|
}
|
zzxfDataImportVo.setExt1(null);
|
zzxfDataImportVo.setHuabei(0);
|
zzxfDataImportVo.setIdcard(vo.getIdCard());
|
zzxfDataImportVo.setName(vo.getName());
|
zzxfDataImportVo.setMobile(vo.getPhone());
|
Integer integer = vo.parseLoadAmount();
|
zzxfDataImportVo.setMoneyDemand(integer);
|
if (vo.getCarStatus() != null) {
|
zzxfDataImportVo.setIsCar(vo.getCarStatus() == 3 ? "Y" : "N");
|
} else {
|
zzxfDataImportVo.setIsCar("N");
|
}
|
if (vo.getHouseStatus() != null) {
|
zzxfDataImportVo.setIsHouse(vo.getHouseStatus() == 3 ? "Y" : "N");
|
} else {
|
zzxfDataImportVo.setIsHouse("N");
|
}
|
if (vo.getInsurancePolicy() != null) {
|
zzxfDataImportVo.setIsInsurance(vo.getInsurancePolicy() == 0 ? "N" : "Y");
|
} else {
|
zzxfDataImportVo.setIsInsurance("N");
|
}
|
if (vo.getProvidentFund() != null) {
|
zzxfDataImportVo.setIsFund(vo.getProvidentFund() == 0 ? "N" : "Y");
|
} else {
|
zzxfDataImportVo.setIsFund("N");
|
}
|
if (vo.getSocialSecurity() != null) {
|
zzxfDataImportVo.setIsSocial(vo.getSocialSecurity() == 0 ? "N" : "Y");
|
} else {
|
zzxfDataImportVo.setIsSocial("N");
|
}
|
if (vo.getSesame() != null) {
|
if (SesameStatusEnum.Sesame_1.getCode().equals(vo.getSesame())) {
|
zzxfDataImportVo.setZhimascore(vo.getSesame());
|
} else if (SesameStatusEnum.Sesame_2.getCode().equals(vo.getSesame())) {
|
zzxfDataImportVo.setZhimascore(600);
|
} else if (SesameStatusEnum.Sesame_3.getCode().equals(vo.getSesame())) {
|
zzxfDataImportVo.setZhimascore(650);
|
} else if (SesameStatusEnum.Sesame_4.getCode().equals(vo.getSesame())) {
|
zzxfDataImportVo.setZhimascore(700);
|
} else {
|
zzxfDataImportVo.setZhimascore(701);
|
}
|
} else {
|
zzxfDataImportVo.setZhimascore(0);
|
}
|
try {
|
// 首先获取token
|
ZzxfTokenResponse token = getToken();
|
if (token == null || token.getToken() == null) {
|
throw new Exception("token为空");
|
}
|
Map<String, Object> param = new HashMap<>(16);
|
logger.info("中赞导入数据接口原始参数->:{}", zzxfDataImportVo.toString());
|
param.put("channel", this.channel);
|
param.put("token", token.getToken());
|
// 请求数据加密
|
String data = AesSecretUtils.encrypt(OBJECT_MAPPER.writeValueAsString(zzxfDataImportVo), this.aesSecret);
|
param.put("data", data);
|
logger.info("中赞导入数据接口参数->:{}", param);
|
String responseJson = HttpClientUtil.getInstance().postJsonData(host + "big/data2022/putdata", OBJECT_MAPPER.writeValueAsString(param));
|
logger.info("中赞导入数据接口返回->:{}", responseJson);
|
if (!TextUtils.isEmpty(responseJson)) {
|
return OBJECT_MAPPER.readValue(responseJson, ZzxfResponse.class);
|
}
|
} catch (Exception e) {
|
logger.error("中赞导入数据接口出错");
|
e.printStackTrace();
|
return null;
|
}
|
return null;
|
}
|
|
public void calcuAge(ZzxfDataImportVo zzxfDataImportVo, String birthday) {
|
Long yearmoi = (long) 365 * 24 * 60 * 60 * 1000;
|
Date today = new Date();
|
SimpleDateFormat bDate = new SimpleDateFormat("yyyyMMdd");
|
try {
|
long birthdayMi = bDate.parse(birthday).getTime();
|
long todayMi = today.getTime();
|
long liveMi = todayMi - birthdayMi;
|
int age = (int) (liveMi / yearmoi);
|
zzxfDataImportVo.setAge(age);
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
