package com.nova.sankuai.domain.api.zhongan;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.nova.sankuai.domain.entity.City;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.enums.SourceTypeEnum;
|
import com.nova.sankuai.domain.enums.customerinfo.EnterpriseInfoEnum;
|
import com.nova.sankuai.domain.enums.customerinfo.MaritalStatusEnum;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.service.ICityService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang.StringUtils;
|
import org.apache.commons.lang.time.DateFormatUtils;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.Assert;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* <p>
|
* description
|
* </p>
|
*
|
* @author denglb 2021/11/16
|
*/
|
@Component
|
@Slf4j
|
public class ZhongAnUtil {
|
|
@Value("${rsa.local.privateKey}")
|
private String localPrivateKey;
|
@Value("${rsa.local.publicKey}")
|
private String localPublicKey;
|
@Value("${rsa.zhongan.publicKey}")
|
private String zhonganPublicKey;
|
@Value("${rsa.zhongan.appKey}")
|
private String zhonganAppKey;
|
@Value("${rsa.zhongan.creditApplyService}")
|
private String creditApplyService;
|
@Value("${rsa.zhongan.url}")
|
private String zhonganUrl;
|
@Value("${rsa.zhongan.callbackService}")
|
private String callbackService;
|
|
@Resource
|
private ICityService cityService;
|
|
private static final String API_NAME = "apiName";
|
private static final String CHANNEL_NO = "channelNo";
|
private static final String SUPPLIER_NO = "supplierNo";
|
private static final String REQ_DATE = "reqDate";
|
private static final String REQ_NO = "reqNo";
|
private static final String RESP_CODE = "respCode";
|
private static final String RESP_MSG = "respMsg";
|
private static final String RESP_NO = "respNo";
|
private static final String RESULT = "result";
|
private static final String THIRD_USER_NO = "thirdUserNo";
|
private static final String APPKEY = "appKey";
|
private static final String SERVICE_NAME = "serviceName";
|
private static final String BIZ_CONTENT = "bizContent";
|
private static final String TIMESTAMP = "timestamp";
|
private static final String FORMAT = "format";
|
private static final String SIGN_TYPE = "signType";
|
private static final String CHARSET = "charset";
|
private static final String VERSION = "version";
|
private static final String SIGN = "sign";
|
private static final String CERTI_NO = "certiNo";
|
private static final String PHONE = "phone";
|
private static final String IS_ALLOW_CREDIT = "isAllowCredit";
|
private static final String ERROR_CODE = "errorCode";
|
private static final String ERROR_MSG = "errorMsg";
|
private static final String VAL_CHANNEL_NO = "DL-ZAXD001";
|
private static final String VAL_CHARSET_DEFAULT = "UTF-8";
|
private static final String VAL_FORMAT_DEFAULT = "json";
|
private static final String VAL_SIGN_TYPE_DEFAULT = "RSA";
|
private static final String VAL_SUCCESS_CODE = "0000";
|
private static final String VAL_SUCCESS_MSG = "";
|
private static final String VAL_VERSION = "1.0.0";
|
|
public String buildAvailAmountResult(Customer customer, DuolaiRequest request) {
|
if (customer == null) {
|
throw new CommonException("未查询到相关信息");
|
}
|
AvailAmountQuery query = queryZhonganCustomerCardNo(request);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|
AvailAmountResult result = new AvailAmountResult();
|
result.setCreditAmount(BigDecimal.valueOf(customer.getLoanAmount()));
|
result.setUsedAmount(BigDecimal.valueOf(0));
|
result.setFrozenAmount(BigDecimal.valueOf(0));
|
result.setAvailableAmount(BigDecimal.valueOf(customer.getLoanAmount()));
|
result.setStartLoanAmount(BigDecimal.valueOf(customer.getLoanAmount()));
|
String applyDate = sdf.format(customer.getApplyDate());
|
result.setEffectiveDate(applyDate);
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(customer.getApplyDate());
|
cal.add(Calendar.YEAR, 1);
|
result.setExpireDate(sdf.format(cal.getTime()));
|
result.setStatus(1);
|
result.setMaxLoanPeriods(12);
|
result.setSupportPeriods(Collections.singletonList(12));
|
Map<String, Object> respInner = new HashMap<>();
|
respInner.put(RESULT, result);
|
respInner.put(RESP_CODE, "0000");
|
respInner.put(RESP_MSG, "成功");
|
respInner.put(RESP_NO, UUID.randomUUID().toString());
|
respInner.put(REQ_NO, query.getReqNo());
|
//使用众安的公钥加密
|
String bizContent = SignUtil.encryptByPublicKeyWithNoOrderForLongData(JSONObject.toJSONString(respInner),
|
zhonganPublicKey);
|
return bizContent;
|
}
|
|
public Map<String, Object> buildAvailAmountResp(String bizContent, String resultCode, String resultMsg) {
|
Map<String, Object> resp = new HashMap<>();
|
resp.put(BIZ_CONTENT, bizContent);// 业务数据
|
resp.put(CHARSET, VAL_CHARSET_DEFAULT);// 字节编码
|
resp.put(FORMAT, VAL_FORMAT_DEFAULT);// 格式化类型
|
resp.put(TIMESTAMP, DateFormatUtils.format(new Date(), "yyyyMMddHHmmssSSS"));// 时间戳
|
resp.put(SIGN_TYPE, VAL_SIGN_TYPE_DEFAULT);// 签名类型
|
resp.put(ERROR_CODE, resultCode == null ? "" : resultCode);// 错误码
|
resp.put(ERROR_MSG, resultMsg == null ? "" : resultMsg);// 错误信息
|
// 供应商的私钥加签
|
String sign = SignUtil.doSign(resp, localPrivateKey);
|
// sign签名当成请求入参
|
resp.put(SIGN, sign);
|
return resp;
|
}
|
|
public AvailAmountQuery queryZhonganCustomerCardNo(DuolaiRequest request) {
|
Map<String, Object> req = buildZhonganReq(request, creditApplyService);
|
String getSign = String.valueOf(req.get(SIGN));
|
// 使用众安的公钥验签
|
boolean verify = SignUtil.rsa256CheckContent(req, getSign, zhonganPublicKey);
|
Assert.isTrue(verify, "验签失败");
|
// 使用供应商的私钥解密
|
String decryptBizContent = SignUtil.decryptRSAByPrivateKeyForLongData(String.valueOf(req.get(BIZ_CONTENT)),
|
localPrivateKey);
|
log.info("众安参数：" + decryptBizContent);
|
AvailAmountQuery query = JSONObject.parseObject(decryptBizContent, AvailAmountQuery.class);
|
if (query == null || StringUtils.isBlank(query.getCertiNo())) {
|
log.error("接收参数异常：{}", query);
|
throw new CommonException("接收参数异常");
|
}
|
return query;
|
}
|
|
private DuolaiDto queryDuolaiDto(DuolaiRequest request) {
|
if (request == null) {
|
throw new CommonException("未接受到参数");
|
}
|
Map<String, Object> req = buildZhonganReq(request, creditApplyService);
|
String getSign = String.valueOf(req.get(SIGN));
|
// 使用众安的公钥验签
|
// boolean verify = SignUtil.rsa256CheckContent(req, getSign, zhonganPublicKey);
|
// Assert.isTrue(verify, "验签失败");
|
// 使用供应商的私钥解密
|
String decryptBizContent = SignUtil.decryptRSAByPrivateKeyForLongData(String.valueOf(req.get(BIZ_CONTENT)),
|
localPrivateKey);
|
log.info("众安参数：" + decryptBizContent);
|
DuolaiDto dto = JSONObject.parseObject(decryptBizContent, DuolaiDto.class);
|
return dto;
|
}
|
|
public Customer buildZhongAnCustomer(DuolaiRequest request) {
|
DuolaiDto dto = queryDuolaiDto(request);
|
Customer customer = new Customer();
|
OcrInfoDto infoDto = dto.getOcrInfoDto();
|
customer.setName(infoDto.getName());
|
customer.setPhone(dto.getMobile());
|
customer.setIdCard(infoDto.getCertiNo());
|
OtherCreditInfo otherCreditInfo = dto.getOtherCreditInfo();
|
City one = cityService.getOne(new LambdaQueryWrapper<City>().like(City::getName, otherCreditInfo.getContactCity()));
|
if (one != null) {
|
customer.setCity(one.getCityId());
|
customer.setCityName(one.getName());
|
}
|
customer.setSourceChannel(SourceTypeEnum.ZhongAn.getCode());
|
customer.setApplyDate(dto.getCreditApplyTime());
|
customer.setIdCardFrontPath(dto.getCertFrontImageId());
|
customer.setIdCardBackPath(dto.getCertBackImageId());
|
if (otherCreditInfo.getContact1Relation().equals(RelationshipEnum.PARENT.getCode())) {
|
customer.setRelationship("0");
|
customer.setRelationshipName(otherCreditInfo.getContact1Name());
|
customer.setRelationshipPhone(otherCreditInfo.getContact1Mobile());
|
} else if (otherCreditInfo.getContact1Relation().equals(RelationshipEnum.CHILD.getCode())) {
|
customer.setRelationship("1");
|
customer.setRelationshipName(otherCreditInfo.getContact1Name());
|
customer.setRelationshipPhone(otherCreditInfo.getContact1Mobile());
|
} else {
|
customer.setContact1Name(otherCreditInfo.getContact1Name());
|
customer.setContact1Phone(otherCreditInfo.getContact1Mobile());
|
}
|
if (otherCreditInfo.getContact2Relation().equals(RelationshipEnum.PARENT.getCode())) {
|
customer.setRelationship1("0");
|
customer.setRelationship1Name(otherCreditInfo.getContact2Name());
|
customer.setRelationship1Phone(otherCreditInfo.getContact2Mobile());
|
} else if (otherCreditInfo.getContact2Relation().equals(RelationshipEnum.CHILD.getCode())) {
|
customer.setRelationship1("1");
|
customer.setRelationship1Name(otherCreditInfo.getContact2Name());
|
customer.setRelationship1Phone(otherCreditInfo.getContact2Mobile());
|
} else {
|
customer.setContactName(otherCreditInfo.getContact2Name());
|
customer.setContactPhone(otherCreditInfo.getContact2Mobile());
|
}
|
customer.setEducation(queryEducation(otherCreditInfo.getFilledDegree()));
|
customer.setMaritalStatus(queryMarital(otherCreditInfo.getMarriage()));
|
customer.setMonthlyIncome(queryInCome(otherCreditInfo.getMonthlyPay()));
|
customer.setAddress(otherCreditInfo.getDetailedAddress());
|
customer.setAge(getAge(dto.getOcrInfoDto().getBirthday()));
|
if (StringUtils.isBlank(otherCreditInfo.getCompanyName())) {
|
customer.setEnterpriseInfo(EnterpriseInfoEnum.Enterprise_1.getCode());
|
} else {
|
customer.setEnterpriseInfo(EnterpriseInfoEnum.Enterprise_2.getCode());
|
}
|
customer.setLoanAmount(buildLoanAmount());
|
return customer;
|
}
|
|
private Double buildLoanAmount() {
|
Random random = new Random();
|
int i = random.nextInt(5) + 1;
|
return i * 10000.00;
|
}
|
|
private Integer getAge(String strDate) {
|
if (StringUtils.isBlank(strDate)) {
|
return null;
|
}
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date birthDay = null;
|
try {
|
birthDay = sdf.parse(strDate);
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
Calendar cal = Calendar.getInstance();
|
if (cal.before(birthDay)) { //出生日期晚于当前时间，无法计算
|
throw new IllegalArgumentException(
|
"The birthDay is before Now.It's unbelievable!");
|
}
|
int yearNow = cal.get(Calendar.YEAR); //当前年份
|
int monthNow = cal.get(Calendar.MONTH); //当前月份
|
int dayOfMonthNow = cal.get(Calendar.DAY_OF_MONTH); //当前日期
|
cal.setTime(birthDay);
|
int yearBirth = cal.get(Calendar.YEAR);
|
int monthBirth = cal.get(Calendar.MONTH);
|
int dayOfMonthBirth = cal.get(Calendar.DAY_OF_MONTH);
|
int age = yearNow - yearBirth; //计算整岁数
|
if (monthNow <= monthBirth) {
|
if (monthNow == monthBirth) {
|
if (dayOfMonthNow < dayOfMonthBirth) {
|
age--;
|
}//当前日期在生日之前，年龄减一
|
} else {
|
age--;//当前月份在生日之前，年龄减一1
|
}
|
}
|
return age;
|
}
|
|
private Integer queryInCome(Integer monthlyPay) {
|
for (MonthPayEnum m : MonthPayEnum.values()) {
|
if (m.getCode().equals(monthlyPay)) {
|
return m.getSys();
|
}
|
}
|
return null;
|
}
|
|
private String queryMarital(Integer marriage) {
|
for (MaritalStatusEnum maritalStatusEnum : MaritalStatusEnum.values()) {
|
return maritalStatusEnum.getSys();
|
}
|
return null;
|
}
|
|
private String queryEducation(Integer zhonganEducation) {
|
for (ZhonganEducationEnum educationEnum : ZhonganEducationEnum.values()) {
|
if (educationEnum.getCode().equals(zhonganEducation)) {
|
return educationEnum.getSys();
|
}
|
}
|
return null;
|
}
|
|
private Map<String, Object> buildZhonganReq(DuolaiRequest request, String serviceName) {
|
Map<String, Object> req = new HashMap<>();
|
req.put(APPKEY, zhonganAppKey);// appKey
|
req.put(SERVICE_NAME, serviceName);// serviceName
|
req.put(BIZ_CONTENT, request.getBizContent());// 业务数据
|
req.put(TIMESTAMP, DateFormatUtils.format(new Date(), "yyyyMMddHHmmssSSS"));// 时间戳
|
req.put(FORMAT, VAL_FORMAT_DEFAULT);// 格式化类型
|
req.put(SIGN_TYPE, VAL_SIGN_TYPE_DEFAULT);// 签名类型
|
req.put(CHARSET, VAL_CHARSET_DEFAULT);// 字节编码
|
req.put(VERSION, VAL_VERSION);// API版本号
|
req.put(SIGN, request.getSign());
|
return req;
|
}
|
|
public Map<String, Object> buildZhonganResp(DuolaiRequest request, String status, String resultCode, String resultMsg) {
|
DuolaiDto dto = queryDuolaiDto(request);
|
CreditApplyResult result = new CreditApplyResult();
|
result.setOuterCreditApplyNo(result.getOuterCreditApplyNo());
|
result.setStatus(status);
|
result.setResultCode(resultCode);
|
result.setResultMsg(resultMsg);
|
|
Map<String, Object> respInner = new HashMap<>();
|
respInner.put(RESULT, result);
|
respInner.put(RESP_CODE, resultCode == null ? "0000" : resultCode);
|
respInner.put(RESP_MSG, resultMsg);
|
respInner.put(RESP_NO, UUID.randomUUID().toString());
|
respInner.put(REQ_NO, dto.getReqNo());
|
//使用众安的公钥加密
|
String bizContent = SignUtil.encryptByPublicKeyWithNoOrderForLongData(JSONObject.toJSONString(respInner),
|
zhonganPublicKey);
|
Map<String, Object> resp = new HashMap<>();
|
resp.put(BIZ_CONTENT, bizContent);// 业务数据
|
resp.put(CHARSET, VAL_CHARSET_DEFAULT);// 字节编码
|
resp.put(FORMAT, VAL_FORMAT_DEFAULT);// 格式化类型
|
resp.put(TIMESTAMP, DateFormatUtils.format(new Date(), "yyyyMMddHHmmssSSS"));// 时间戳
|
resp.put(SIGN_TYPE, VAL_SIGN_TYPE_DEFAULT);// 签名类型
|
resp.put(ERROR_CODE, resultCode == null ? "" : resultCode);// 错误码
|
resp.put(ERROR_MSG, resultMsg == null ? "" : resultMsg);// 错误信息
|
// 供应商的私钥加签
|
String sign = SignUtil.doSign(resp, localPrivateKey);
|
// sign签名当成请求入参
|
resp.put(SIGN, sign);
|
return resp;
|
}
|
|
public void callback(DuolaiRequest request, String status, Double money) {
|
DuolaiDto dto = queryDuolaiDto(request);
|
Map<String, Object> map = new HashMap<>();
|
map.put(CHANNEL_NO, dto.getChannelNo());
|
map.put(REQ_DATE, dto.getReqDate());
|
map.put(REQ_NO, dto.getReqNo());
|
map.put(THIRD_USER_NO, dto.getThirdUserNo());
|
map.put("productCode", dto.getProductCode());
|
map.put("creditApplyNo", dto.getOuterCreditApplyNo());
|
map.put("status", status);
|
map.put("creditApplyTime", DateFormatUtils.format(dto.getCreditApplyTime(), "yyyy-MM-dd HH:mm:ss"));
|
if (ZhongAnStatus.STATUS_3.getCode().equals(status)) {
|
map.put("creditAmount", BigDecimal.valueOf(money));
|
map.put("availableAmount", BigDecimal.valueOf(money));
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(dto.getCreditApplyTime());
|
cal.add(Calendar.YEAR, 1);
|
map.put("quotaInvalidDate", DateFormatUtils.format(cal.getTime(), "yyyy-MM-dd HH:mm:ss"));
|
} else {
|
map.put("resultMsg", "订单常见失败");
|
}
|
|
//使用众安的公钥加密
|
String bizContent = SignUtil.encryptByPublicKeyWithNoOrderForLongData(JSONObject.toJSONString(map),
|
zhonganPublicKey);
|
Map<String, Object> req = new HashMap<>();
|
req.put(APPKEY, zhonganAppKey);// appKey
|
req.put(SERVICE_NAME, callbackService);// serviceName
|
req.put(BIZ_CONTENT, bizContent);// 业务数据
|
req.put(TIMESTAMP, DateFormatUtils.format(new Date(), "yyyyMMddHHmmssSSS"));// 时间戳
|
req.put(FORMAT, VAL_FORMAT_DEFAULT);// 格式化类型
|
req.put(SIGN_TYPE, VAL_SIGN_TYPE_DEFAULT);// 签名类型
|
req.put(CHARSET, VAL_CHARSET_DEFAULT);// 字节编码
|
req.put(VERSION, VAL_VERSION);// API版本号
|
req.put(SUPPLIER_NO, request.getSupplierNo());//TODO 供应商发起请求该值必填，值为众安侧分配的编码
|
// 供应商的私钥加签
|
String sign = SignUtil.doSign(req, localPrivateKey);
|
// sign签名当成请求入参
|
req.put(SIGN, sign);
|
// HttpUtil.post(zhonganUrl, req);
|
}
|
}
|
