package com.nova.sankuai.infra.utils.syh; import cn.hutool.core.util.IdUtil; import cn.hutool.crypto.SecureUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.nova.sankuai.domain.api.hjqb.HjqbResponse; import com.nova.sankuai.domain.api.syh.SyhCallback; import com.nova.sankuai.domain.api.syh.SyhData; import com.nova.sankuai.domain.api.syh.SyhIncomeResponse; import com.nova.sankuai.domain.api.syh.SyhResponse; import com.nova.sankuai.domain.dto.callback.syh.SyhCallbackRequestDTO; import com.nova.sankuai.domain.entity.*; import com.nova.sankuai.domain.enums.capitalInfo.CapitalInfoStatusEnum; import com.nova.sankuai.domain.enums.capitalInfo.CapitalInfoTypeCodeEnum; import com.nova.sankuai.domain.vo.capitalresult.LvdiPushResultVo; import com.nova.sankuai.infra.config.CommonException; import com.nova.sankuai.infra.mapper.CustomerCapitalResultMapper; import com.nova.sankuai.infra.mapper.CustomerMapper; import com.nova.sankuai.infra.utils.RbUtil; import com.nova.sankuai.infra.utils.ResultJson; import com.nova.sankuai.infra.utils.UserUtil; import com.nova.sankuai.security.HttpClientUtil; import com.nova.sankuai.security.UserDetail; import com.nova.sankuai.service.IChannelInfoService; import com.nova.sankuai.service.ICustomerScyIncomeService; import com.nova.sankuai.service.ICustomerUserService; import com.nova.sankuai.service.IPlatformCapitalService; import lombok.RequiredArgsConstructor; import org.apache.commons.lang3.StringUtils; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import org.slf4j.Logger; import org.slf4j.LoggerFactory; 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.UnsupportedEncodingException; import java.nio.charset.StandardCharsets; import java.time.LocalDate; import java.time.format.DateTimeFormatter; import java.time.temporal.ChronoUnit; import java.util.Calendar; import java.util.Objects; import java.util.Random; /** * 随易花对接 */ @Component @RequiredArgsConstructor public class SyhUtil { private static final Logger log = LoggerFactory.getLogger("capitalLogger"); private static final String encryptKey = "MCXBIjANke"; // 随易花在capital_info数据库中的ID private static final Long capitalId = 36L; @Value("${syh.callBackUrl}") private String callBackUrl; @Value("${syh.domain}") private String syhUrl; @Value("${syh.source}") private String source; /** * 获取工作年限 1： 6个月以下； 2 ：6-12个月； 3 ： 12 个月 */ private String getJobAage(String workStartTime, String workEndTime) { if (StringUtils.isBlank(workStartTime)) {// 若为空，则不取该条数据 return ""; } workStartTime = workStartTime.substring(0, 10); LocalDate endDate = null; DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); LocalDate startDate = LocalDate.parse(workStartTime, formatter); if (StringUtils.isNotBlank(workEndTime)) { workEndTime = workEndTime.substring(0, 10); endDate = LocalDate.parse(workEndTime, formatter); } else { endDate = LocalDate.now(); } // LocalDate now = LocalDate.now(); // LocalDate dateTime = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate(); long month = ChronoUnit.MONTHS.between(startDate, endDate); // 1： 6个月以下； 2 ：6-12个月； 3 ： 12 个月 if (month < 6) { return "1"; } else if (month >= 6 && month < 12) { return "2"; } return "3"; } private final CustomerMapper customerMapper; private final CustomerCapitalResultMapper capitalResultMapper; private final ICustomerUserService customerUserService; private final CustomerCapitalResultMapper customerCapitalResultMapper; private final IChannelInfoService channelInfoService; public SyhResponse callback(SyhCallbackRequestDTO body) { String logNumber = IdUtil.randomUUID(); try { if (body == null) { SyhResponse resp = new SyhResponse(); resp.setResult(400); resp.setMessage("请求体为空"); log.error("日志编号：{} 随易花资方回调请求体为空", logNumber); return resp; } String timestamp = body.getTimestamp(); String signs = body.getSigns(); if (StringUtils.isBlank(timestamp) || StringUtils.isBlank(signs)) { SyhResponse resp = new SyhResponse(); resp.setResult(400); resp.setMessage("请求体为空"); log.error("日志编号：{} 随易花资方回调请求体为空", logNumber); return resp; } String signsRes = decrypt(timestamp, signs);// 解密 if (StringUtils.isBlank(signsRes)) { SyhResponse resp = new SyhResponse(); resp.setResult(400); resp.setMessage("请求体signs解析失败!"); log.error("日志编号：{} 随易花回调请求体signs解析失败，timestamp：{}，signs：{}", logNumber, timestamp, signs); return resp; } SyhCallback callback = JSON.parseObject(signsRes, SyhCallback.class); String mobile = callback.getPhone(); if (StringUtils.isBlank(mobile)) {// 手机号为空 SyhResponse resp = new SyhResponse(); resp.setResult(400); resp.setMessage("手机号不能为空"); log.error("日志编号：{} 随易花资方回调返回手机号为空，timestamp：{}，signs：{}", logNumber, timestamp, signs); return resp; } Customer customer = customerMapper.getLatestCustomerRecord(mobile); CustomerUser customerUser = customerUserService.getOne(new LambdaQueryWrapper().eq(CustomerUser::getPhone, mobile)); if (customer == null || customerUser == null) { SyhResponse resp = new SyhResponse(); resp.setResult(500); resp.setMessage("该用户已注销"); log.error("日志编号：{} 随易花资方返回的用户已注销，timestamp：{}，signs：{}", logNumber, timestamp, signs); return resp; } LambdaQueryWrapper wr = new LambdaQueryWrapper<>(); wr.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId()) .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId()) .eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.SYH.getCode()) .last(" limit 1 "); CustomerCapitalResult capitalResult = customerCapitalResultMapper.selectOne(wr); if (capitalResult == null) { SyhResponse resp = new SyhResponse(); resp.setResult(500); resp.setMessage("该数据不存在"); log.error("日志编号：{} 随易花资方回调返回的用户不存在，timestamp：{}，signs：{}", logNumber, timestamp, signs); return resp; } Integer status = CapitalInfoStatusEnum.APPLY_PASS.getCode(); LambdaUpdateWrapper updateWrapper = Wrappers.lambdaUpdate(CustomerCapitalResult.class); updateWrapper.eq(CustomerCapitalResult::getId, capitalResult.getId()). set(CustomerCapitalResult::getStatus, status); customerCapitalResultMapper.update(null, updateWrapper); SyhResponse resp = new SyhResponse(); resp.setResult(200); resp.setMessage("成功接收数据"); log.info("日志编号：{} 随易花资方回调返回数据入库成功：{}", logNumber, body); return resp; } catch (Exception e) { SyhResponse resp = new SyhResponse(); resp.setResult(500); resp.setMessage(e.getMessage()); log.error("日志编号：{} 随易花资方回调返回数据入库失败：{} 错误原因：{}", logNumber, body, e); return resp; } } private JSONObject getParam(Customer customer) { JSONObject param = new JSONObject(); Random random = new Random(); // 获取source_channel Integer sourceChannel = customer.getSourceChannel(); Integer version2Type = 0;//判断是否2.0开关子参数 if (!Objects.isNull(sourceChannel)) { ChannelInfo channelInfo = channelInfoService.getOne(new LambdaQueryWrapper().eq(ChannelInfo::getCode, sourceChannel).last(" limit 1 ")); version2Type = channelInfo.getVersion2Type(); } /** * 参数名称 参数类型 是否必须 参数示例 参数说明 * timestamp string 是 1717724899024 时间戳字符串 * signs string 是 01f32b38b7b208a574c512a40d30cff0 业务数据AES加密内容 * signs字段加密前的内容，转成jsonstr进行加密，主体使用的 * String key = String.format("%s%s", "MCXBIjANke", timestamp).substring(0, 16); * String signs= SecureUtil.aes(key.getBytes(StandardCharsets.UTF_8)).encryptHex(value); */ /* mobile String 是 17711223344 手机号*/ String phone = customer.getPhone(); param.put("mobile", phone); /* name string 是 测试 姓名 */ param.put("name", customer.getName()); /* city string 是 上海 城市 不带"市" */ String city = customer.getCityName(); param.put("city", StringUtils.isNotBlank(city) ? city.replace("市", "") : ""); /* nativePlace string 否 1 是否本地户籍，0:非本地户籍、1:本地户籍 */ param.put("nativePlace", "1"); /* limitScope int 是 50000 额度范围(1:''0-3万'' ；2:''3万-5万'' ；3: ''5万-10万'' ；4: ''10万-20万'' ; 5: ''20万-50万'' ;6:''50万以上'' )（额度大于 3w）*/ /*Double la = customer.getLoanAmount(); double loanAmount = 0; loanAmount = la == null ? 0 : la.doubleValue(); int limitScope = 2; if (loanAmount >= 0 && loanAmount < 50000) { limitScope = 3; } else if (loanAmount >= 50000 && loanAmount < 100000) { limitScope = 4; } else if (loanAmount >= 200000 && loanAmount < 500000) { limitScope = 5; } else { limitScope = 6; }*/ int[] values = {2, 3, 3, 4, 5, 6}; param.put("limitScope", values[random.nextInt(values.length)]); int car = 1; int house = 1; int soci = 1; int accu = 1; String hasPolicy = "1"; int creditCard = 1; if (version2Type == 1) { //线上放款 /* car 无论选什么,均在"2.全款 3.按揭"中随机匹配 */ values = new int[]{2, 3}; car = values[random.nextInt(values.length)]; /* house 无论选什么,均在"5:有本地房产 6:有外地房产 50:都有"中随机匹配*/ values = new int[]{5, 6, 50}; house = values[random.nextInt(values.length)]; /* 公积金 无论选什么 均在"2.6个月以下 3.6个月以上"中随机匹配*/ values = new int[]{2, 3}; accu = values[random.nextInt(values.length)]; /* 社保 无论选什么 均在"2.6个月以下 3.6个月以上"中随机匹配*/ soci = values[random.nextInt(values.length)]; /* 保单 无论选什么 均在"2.缴纳未满一年 3.缴纳一年以上"中随机匹配*/ hasPolicy = String.valueOf(values[random.nextInt(values.length)]); /* 信用卡额度 随机生成2：1万以下 3：1万-3万 4：3万以上*/ values = new int[]{2, 3, 4}; creditCard = values[random.nextInt(values.length)]; } else { //银行直贷 /* car int 否 1 车产类型 (1无 2全款 3按揭) */ Integer carStatus = customer.getCarStatus(); int cs = Objects.isNull(carStatus) ? 0 : carStatus.intValue(); if (cs == 4) {// 有按揭车 car = 3; } else if (cs == 5) {// 全款车 car = 2; } /* house int 否 1 1:无房产 5:有本地房产 6:有外地房产 50:都有 备注：我们只有是否有房产*/ /** * { * text: '有按揭商品房', * value: 4, * }, * { * text: '有全款商品房', * value: 5, * }, * { * text: '仅外地有房', * value: 6, * }, * { * text: '无', * value: 0, * }, */ Integer houseStatus = customer.getHouseStatus(); int hs = Objects.isNull(houseStatus) ? 0 : houseStatus.intValue(); if (hs == 3) { house = 5; } else if (hs == 6) { house = 6; } else if (hs == 4 || hs == 5) { house = 5; } /* accumulation int 否 1 公积金(1:无公积金 2:6个月以下 3:6个月以上)*/ /** * { * text: '无', * value: 0, * }, * { * text: '6个月以内', * value: 1, * }, * { * text: '6个月以上', * value: 2, * }, */ Integer accumulation = customer.getProvidentFund(); int at = Objects.isNull(accumulation) ? 0 : accumulation.intValue(); if (at == 1) accu = 2; else if (at == 2) accu = 3; /* social int 否 1 社保(1:无社保 2:6个月以下 3:6个月以上)*/ /** * { * text: '无', * value: 0, * }, * { * text: '6个月以内', * value: 1, * }, * { * text: '6个月以上', * value: 2, * }, */ Integer social = customer.getSocialSecurity(); int soc = Objects.isNull(social) ? 0 : social.intValue(); if (soc == 1) { soci = 2; } else if (soc == 2) { soci = 3; } /* hasPolicy string 否 1 保单 1:无 2：缴纳未满一年 3：缴纳一年以上*/ /** * { * text: '投保人寿险且保两年以下', * value: 6, * }, * { * text: '投保人寿险且保两年以上', * value: 7, * }, * { * text: '无保险', * value: 0, * }, */ Integer insurancePolicy = customer.getInsurancePolicy(); int ipy = Objects.isNull(insurancePolicy) ? 0 : insurancePolicy.intValue(); if (ipy == 6) { hasPolicy = "2"; } else if (ipy == 7) { hasPolicy = "3"; } /* creditCard int 否 1 信用卡额度 1：无 2：1万以下 3：1万-3万 4：3万以上*/ /** * { * text: '1万', * value: 3, * }, * { * text: '1万-3万', * value: 4, * }, * { * text: '3万以上', * value: 5, * }, * { * text: '无', * value: 0, * }, */ Integer cc = customer.getCreditCard(); int ccV = Objects.isNull(cc) ? 0 : cc.intValue(); if (ccV == 3) { creditCard = 2; } else if (ccV == 4) { creditCard = 3; } else if (ccV == 5) { creditCard = 4; } } param.put("car", car); param.put("house", house); param.put("accumulation", accu); param.put("social", soci); param.put("hasPolicy", hasPolicy); param.put("creditCard", creditCard); /* sex int 是 1 性别 1-男 2-女 */ String sex = RbUtil.getGenderByIDCard(customer.getIdCard()); String sexStr = "男".equals(sex) ? "1" : "2"; param.put("sex", sexStr); /* age String 是 25 年龄（25-55之间）*/ param.put("age", RbUtil.calculateAgeFromIdNumber(customer.getIdCard())); /* osType String 是 1 设备标识(0 安卓 1苹果) */ String os = customer.getOs(); String osType = "ios".equals(os) ? "1" : "0"; param.put("osType", osType); /* deviceId String 是 1dfghh 设备id，可传空字符串 */ // param.put("deviceId", StringUtils.defaultString(customer.getDeviceId())); param.put("deviceId", ""); /* ip string 是 127.0.0.1 用户ip */ param.put("ip", !StringUtils.isEmpty(customer.getClientIp()) ? customer.getClientIp() : "127.0.0.1"); /* ipCity string 否 上海 记录ip城市 * chooseCity string 否 上海 记录手选城市 * gpsCity string 否 上海 录gps城市 * phoneCity string 否 上海 记录手机归属地城市 * 以上四个不搞 */ /* sesame string 是 4 芝麻分 1:无芝麻分 4：700分以上 5:650分以下 6：650-700分*/ Integer customerSesame = customer.getSesame(); int cus = Objects.isNull(customerSesame) ? 1 : customerSesame.intValue(); String sesame = "1";// 默认 1 无 if (cus == 2) { sesame = "5"; } else if (cus == 3) { sesame = "6"; } else if (cus == 4) { sesame = "4"; } param.put("sesame", sesame); /* carPay int 否 1 车产价值 1：0-6万；2：6-15万； 3：15-20万 这个不搞 */ /* job String 否 1 职位： 1 上班族 2自由职业 3 企业主 */ /* { text: '上班族', value: 0, }, { text: '自由职业', value: 1, }, { text: '企业主', value: 2, }, { text: '个体户', value: 3, }, { text: '公务员', value: 4, }, job String 是 1 上班族 2自由职业 3 企业主 4.公务员/事业/国企 这个是以前的 */ Integer pi = customer.getProfessionInfo(); int professionInfo = 1;// 默认自由职业 int job = 0; if (!Objects.isNull(pi)) { professionInfo = pi.intValue(); } if (professionInfo == 0) { job = 1; } else if (professionInfo == 1) { job = 2; } else if (professionInfo == 2 || professionInfo == 3) { job = 3; } else if (professionInfo == 4) { values = new int[]{1, 2, 3}; job = values[random.nextInt(values.length)]; } param.put("job", String.valueOf(job)); /* jobAge String 否 1 工作年限 1： 6个月以下； 2 ：6-12个月； 3 ： 12 个月 */ /* String workStartTime = customer.getWorkStartTime(); String workEndTime = customer.getWorkEndTime(); String jobAage = getJobAage(workStartTime, workEndTime);*/ values = new int[]{1, 2, 3}; param.put("jobAage", String.valueOf(values[random.nextInt(values.length)])); param.put("moneyType", String.valueOf(values[random.nextInt(values.length)])); /* moneyType String 否 1 工资发放形式 1： 银行转账 ；2：银行代发 ； 3：现金发放 这个不搞 */ /* monthlyIncomeLevel int 否 1 月收入区间(1: 5000以下;2: 5001-10000;3: 10001-15000;4: 15001-20000;5: 25001-30000;6: 30000元以上)*/ /** * INCOME_3Q_UNDER(0, "3000以下"), 1 * * Income_5Q_UNDER(6, "5000元以下"), 1 * Income_6(5, "未知"), 1 * * Income_3Q_6Q(1, "3000-6000"), 2 * Income_6Q_1W(2, "6000-10000"), 2 * Income_5Q_1W(7, "5000 - 10000元"), 2 * Income_1W_UNDER(13, "10000以下"); 2 * * Income_1W_1W5(8, "10001 - 15000元"), 3 * * * Income_1W_3W(3, "10000-30000"), 4 * Income_1W5_2W(9, "15001 - 20000元"), 4 * * * Income_2W_2W5(10, "20001 - 25000元"), 5 * Income_2W5_3W(11, "25001 - 30000元"), 5 * * * Income_3W_UPPER_1(12, "30000元以上"), 6 * Income_3W_UPPER(4, "30000以上"), 6 * */ Integer monthlyIncome = customer.getMonthlyIncome(); int mi = monthlyIncome == null ? 1 : monthlyIncome.intValue(); int monthlyIncomeLevel = 1; /* if (mi == 0 || mi == 6 || mi == 5) { monthlyIncomeLevel = 1; } else if (mi == 1 || mi == 2 || mi == 7 || mi == 13) { monthlyIncomeLevel = 2; } else if (mi == 8) { monthlyIncomeLevel = 3; } else if (mi == 3 || mi == 9) { monthlyIncomeLevel = 4; } else if (mi == 10 || mi == 11) { monthlyIncomeLevel = 5; } else if (mi == 12 || mi == 4) { monthlyIncomeLevel = 6; }*/ if (mi == 13) { values = new int[]{1, 2}; monthlyIncomeLevel = values[random.nextInt(values.length)]; } else if (mi == 3) { values = new int[]{3, 4, 6}; monthlyIncomeLevel = values[random.nextInt(values.length)]; } else if (mi == 4) { monthlyIncomeLevel = 6; } param.put("monthlyIncomeLevel", monthlyIncomeLevel); /* companyAge String 否 1 企业年限 1： 1年以下 ；2：1-3年 ； 3：3年以上 这个不搞*/ values = new int[]{1, 2, 3}; param.put("companyAge", values[random.nextInt(values.length)]); /* jdIous string 否 1 京东白条(短信流) 1:无 2:有 * jdIousRp string 否 1 京东白条(落地页) 1:无 2:0-5000 3:5000以上 * 以上两个不搞 */ param.put("jdIous", 2); values = new int[]{2, 3}; param.put("jdIousRp", values[random.nextInt(values.length)]); /* spendBai string 否 1 花呗 1:无 2:3000以下 3:3000---1万 4:一万以上 这个不搞 */ values = new int[]{2, 3, 4}; param.put("spendBai", values[random.nextInt(values.length)]); /* credit int 否 1 信用情况 1：信用良好 无逾期 2：1年内逾期少于3次 3：1年内逾期大于3次 这个不搞 */ values = new int[]{1, 2, 3}; param.put("spendBai", values[random.nextInt(values.length)]); /* education string 否 1 学历 1：高中及以下 2：专科 3：本科 4：硕士 5:博士及以上*/ /* education String 是 学历 1：高中及以下 2：专科 3：本科 4：硕士 5:博士及以上 PRIMARY_SCHOOL("01", "小学"), JUNIOR_HIGH_SCHOOL("02", "初中"), HIGH_SCHOOL("03", "高中"), COLLEGE_DEGREE("04", "大专"), BACHELOR_DEGREE("05", "本科"), MASTER_CANDIDATE("06", "研究生"), DOCTORAL_CANDIDATE("07", "博士"), */ String et = customer.getEducation(); String education = "1"; if ("01".equals(et) || "02".equals(et) || "03".equals(et)) { education = "1"; } else if ("04".equals(et)) { education = "2"; } else if ("05".equals(et)) { education = "3"; } else if ("06".equals(et)) { education = "4"; } else if ("07".equals(et)) { education = "5"; } param.put("education", education); /* source string 是 TL 品牌来源*/ param.put("source", source); /* system String 是 H5-ORDER 系统来源val3*/ param.put("system", source); /* channelMark String 是 H5-ORDER 渠道标识val2*/ param.put("channelMark", source); /* appName String 是 H5-ORDER app名称 sourceName val4 */ param.put("appName", source); return param; } /** * 中诚易数据推送到随容花操作 */ public boolean zcyPushToSyh(Customer customer, String logNumber) { boolean isSucc = false; log.info("日志编号：" + logNumber + "，手机号：{}，中诚易数据推送到随易花流程开始", customer.getPhone()); try { JSONObject param = getParam(customer); isSucc = push(customer, param, logNumber); Integer syh = 0; if (!isSucc) { log.error("日志编号：" + logNumber + "，手机号：{}，中诚易数据推送到随易花失败", customer.getPhone()); } else { syh = 1; } saveStatus(customer, syh); } catch (Exception ex) { log.error("日志编号：" + logNumber + "，手机号：{}，中诚易数据推送到随易花失败：", customer.getPhone(), ex); } return isSucc; } /** * 我来贷数据推送到随容花操作 */ public boolean wldPushToSyh(Customer customer, String logNumber) { boolean isSucc = false; log.info("日志编号：{}，手机号：{}，【我来贷】数据推送到随易花流程开始", logNumber, customer.getPhone()); try { JSONObject param = getParam(customer); isSucc = push(customer, param, logNumber); Integer syh = 0; if (!isSucc) { log.error("日志编号：{}，手机号：{}，【我来贷】数据推送到随易花失败", logNumber, customer.getPhone()); } else { syh = 1; } saveStatus(customer, syh); if (isSucc) { isSucc = wldIncomeToSyh(customer, param, logNumber); } } catch (Exception ex) { log.error("日志编号：{}，手机号：{}，【我来贷】数据推送到随易花失败：{}", logNumber, customer.getPhone(), ex.getMessage()); isSucc = false; } return isSucc; } /** * 推送操作 */ public LvdiPushResultVo syhPush(CustomerUser customerUser, String channelCode) { String logNumber = IdUtil.randomUUID(); log.info("日志编号：" + logNumber + "随易花 channelCode:" + channelCode + " 推送流程开始"); Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone()); CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(new LambdaQueryWrapper() .eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId()) .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId()) .eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.SYH.getCode())); if (capitalResult == null) { log.info("日志编号：" + logNumber + " 手机号：" + customerUser.getPhone() + " 随易花数据库结果不存在, customerUser id:" + customerUser.getId() + " customer id:" + customer.getId()); throw new CommonException("资方对接结果不存在"); } JSONObject param = getParam(customer); boolean isSucc = push(customer, param, logNumber); if (!isSucc) { return null; } // 开始进件操作 // 转成 LvdiPushResultVo LvdiPushResultVo result = new LvdiPushResultVo(); // SyhIncomeResponse response = income(customer, platformCapital, logNumber); result.setCheckResult(true); result.setUrlType("1");// APP下载链接 // result.setUrl(Objects.isNull(data) ? null : data.getApplyUrl()); return result; } private final IPlatformCapitalService platformCapitalService; private final ICustomerScyIncomeService customerZcyIncomeService; private boolean push(Customer customer, JSONObject body, String logNumber) { // 转参 String timestamp = String.valueOf(System.currentTimeMillis()); String key = getKey(timestamp); String signs = SecureUtil.aes(key.getBytes(StandardCharsets.UTF_8)).encryptHex(body.toJSONString().getBytes(StandardCharsets.UTF_8)); JSONObject jsonData = new JSONObject(); jsonData.put("timestamp", timestamp); jsonData.put("signs", signs); log.info("日志编号：" + logNumber + " 开始推送手机号：" + customer.getPhone() + "的资料给资方【随易花】"); String result = null; String url = syhUrl + "/goodsKey/bs/queryGoodsKey"; try { result = HttpClientUtil.getInstance().postJsonData(url, jsonData.toJSONString()); log.info("日志编号：" + logNumber + " 手机号为：" + customer.getPhone() + ",【随易花】推送原始返回参数:{}", result); } catch (Exception ex) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】推送失败，传参：{} ex：{}", customer.getPhone(), jsonData, ex.getMessage()); } if (StringUtils.isBlank(result)) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】推送原始返回数据为空，传参：{} ", customer.getPhone(), jsonData); } try { SyhResponse res = JSON.parseObject(result, SyhResponse.class); if (res.getResult().intValue() == 200) { log.info("日志编号：" + logNumber + " 手机号为：" + customer.getPhone() + ",【随易花】推送成功"); // 解析 返回的signs SyhData data = res.getData(); String timestampRes = data.getTimestamp(); String signsRes = data.getSigns(); if (StringUtils.isBlank(signsRes)) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】推送原始返回参数signs为空，jsonData：{}", customer.getPhone(), jsonData); return false; } String signsResult = decrypt(timestampRes, signsRes);// 解密 if (StringUtils.isBlank(signsResult)) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】推送原始返回参数signs解密失败，jsonData：{}", customer.getPhone(), jsonData); return false; } PlatformCapital platformCapital = JSON.parseObject(signsResult, PlatformCapital.class); // 删除同一资方的同一用户数据 LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(PlatformCapital::getCustomerId, customer.getId()); wrapper.eq(PlatformCapital::getCapitalId, capitalId); platformCapitalService.remove(wrapper); // 录入到数据库 platformCapital.setCustomerId(customer.getId()); platformCapital.setCapitalId(capitalId); platformCapitalService.save(platformCapital); return true; } else { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】推送失败：{}，jsonData：{}", customer.getPhone(), res.getMessage(), jsonData); } } catch (Exception ex) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】推送原始返回参数转换失败，jsonData：{} ex：{}", customer.getPhone(), jsonData, ex.getMessage()); } return false; } /** * 中诚易进件数据给随易花操作 */ public void zcyIncomeToSyh(Customer customer, String logNumber) { log.info("日志编号：" + logNumber + "，手机号：{}，中诚易数据进件到随易花流程开始", customer.getPhone()); try { Integer syh = 3; ResultJson rs = getPushResult(logNumber, customer); if (rs == null) { log.error("日志编号：" + logNumber + "，手机号：{}，中诚易数据进件到随易花失败", customer.getPhone()); } else { syh = 4; log.info("日志编号：" + logNumber + "，手机号：{}，中诚易数据进件到随易花成功", customer.getPhone()); } saveStatus(customer, syh); } catch (Exception ex) { log.error("日志编号：" + logNumber + "，手机号：{}，中诚易数据进件到随易花失败", customer.getPhone()); } } /** * 我来贷进件数据给随易花操作 */ public boolean wldIncomeToSyh(Customer customer, JSONObject param, String logNumber) { boolean isSucc = false; log.info("日志编号：{}，手机号：{}，【我来贷】数据进件到随易花流程开始", logNumber, customer.getPhone()); try { Integer syh = 3; isSucc = getWldPushResult(logNumber, param, customer); if (!isSucc) { log.error("日志编号：{}，手机号：{}，【我来贷】数据进件到随易花失败", logNumber, customer.getPhone()); } else { syh = 4; log.info("日志编号：{}，手机号：{}，【我来贷】数据进件到随易花成功", logNumber, customer.getPhone()); } saveStatus(customer, syh); } catch (Exception ex) { log.error("日志编号：{}，手机号：{}，【我来贷】数据进件到随易花失败： {}", logNumber, customer.getPhone(), ex.getMessage()); } return isSucc; } private void saveStatus(Customer customer, Integer syh) { // 录入或更新到customer_scy_income表 LambdaQueryWrapper wr = new LambdaQueryWrapper<>(); wr.eq(CustomerScyIncome::getCustomerZcyId, customer.getId()); wr.last(" limit 1 "); CustomerScyIncome csi = customerZcyIncomeService.getOne(wr); if (Objects.isNull(csi)) { csi = new CustomerScyIncome(); } csi.setCustomerZcyId(customer.getId()); csi.setSyh(syh); customerZcyIncomeService.saveOrUpdate(csi); } /** * 进件操作 */ public ResultJson income(HttpServletRequest request) { String logNumber = IdUtil.randomUUID(); log.info("日志编号：" + logNumber + " 随易花进件流程开始"); String token = request.getHeader("Authorization"); UserDetail user = UserUtil.getUser(token); if (user == null) { log.info("日志编号：" + logNumber + " 随易花进件失败，原因：用户Token无效"); throw new CommonException("用户Token无效"); } Customer customer = customerMapper.getLatestCustomerRecord(user.getPhone()); LambdaQueryWrapper wr = new LambdaQueryWrapper<>(); wr.eq(CustomerUser::getPhone, user.getPhone()); wr.eq(CustomerUser::getDeleteFlag, 0); wr.last(" limit 1 "); CustomerUser customerUser = customerUserService.getOne(wr); if (customerUser == null) { log.info("日志编号：" + logNumber + " 手机号：" + user.getPhone() + " 随易花进件失败，原因：用户不存在"); throw new CommonException("用户不存在"); } CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(new LambdaQueryWrapper() .eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId()) .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId()) .eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.SYH.getCode())); if (capitalResult == null) { log.info("日志编号：" + logNumber + " 手机号：" + customerUser.getPhone() + "进件失败，原因：随易花数据库结果不存在, customerUser id:" + customerUser.getId() + " customer id:" + customer.getId()); throw new CommonException("资方对接结果不存在"); } return getPushResult(logNumber, customer); } @Nullable private ResultJson getPushResult(String logNumber, Customer customer) { // 判断是否数据库中是否有数据，有过数据就不推送了 LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(PlatformCapital::getCustomerId, customer.getId()); wrapper.eq(PlatformCapital::getCapitalId, capitalId); wrapper.last(" limit 1 "); PlatformCapital platformCapital = platformCapitalService.getOne(wrapper); if (Objects.isNull(platformCapital)) {// 若没有数据 log.info("日志编号：" + logNumber + " 手机号：" + customer.getPhone() + "进件失败，原因：随易花推送结果不存在, customer id:" + customer.getId()); throw new CommonException("资方推送结果不存在"); } if (platformCapital.getIncomeStatus() == 1) {// 已进件成功 log.info("日志编号：" + logNumber + " 手机号：" + customer.getPhone() + "进件失败，原因：随易花已经进件成功过，不再进件, customer id:" + customer.getId()); return null; } /** * uuid string 是 1587992123923271680 数据记录uuid * type string 是 api 数据业务类型 * productKey string 是 YiUl10zCu 产品key */ JSONObject param = new JSONObject(); param.put("uuid", platformCapital.getUuid()); param.put("type", platformCapital.getType()); param.put("productKey", platformCapital.getProductKey()); param.put("url", callBackUrl); String timestamp = String.valueOf(System.currentTimeMillis()); String key = getKey(timestamp); String signs = SecureUtil.aes(key.getBytes(StandardCharsets.UTF_8)).encryptHex(param.toJSONString().getBytes(StandardCharsets.UTF_8)); JSONObject jsonData = new JSONObject(); jsonData.put("timestamp", timestamp); jsonData.put("signs", signs); // jsonData.put("url", callBackUrl); log.info("日志编号：" + logNumber + " 手机号：" + customer.getPhone() + "开始进件给资方【随易花】，参数：{}", jsonData); String result = null; String url = syhUrl + "/goodsKey/bs/incoming"; try { result = HttpClientUtil.getInstance().postJsonData(url, jsonData.toJSONString()); log.info("日志编号：" + logNumber + " 手机号为：" + customer.getPhone() + ",【随易花】进件原始返回参数:{}", result); } catch (Exception ex) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件失败，传参：{} ex：{}", customer.getPhone(), jsonData, ex); } if (StringUtils.isBlank(result)) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件返回数据为空，传参：{} ", customer.getPhone(), jsonData); } try { SyhIncomeResponse res = JSON.parseObject(result, SyhIncomeResponse.class); if (res.getResult().intValue() == 200) { log.info("日志编号：" + logNumber + " 手机号为：" + customer.getPhone() + ",【随易花】进件成功"); // 更新数据库 platformCapital.setIncomeStatus(1); platformCapitalService.updateById(platformCapital); LvdiPushResultVo rs = new LvdiPushResultVo(); rs.setCheckResult(true); rs.setUrlType("1");// APP下载链接 return ResultJson.ok(rs); } else { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件失败：{}，jsonData：{}", customer.getPhone(), res.getMessage(), jsonData); } } catch (Exception ex) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件原始返回参数转换失败，jsonData：{} ex：{}", customer.getPhone(), jsonData, ex); } return null; } private boolean getWldPushResult(String logNumber, JSONObject param, Customer customer) { // 判断是否数据库中是否有数据，有过数据就不推送了 LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(PlatformCapital::getCustomerId, customer.getId()); wrapper.eq(PlatformCapital::getCapitalId, capitalId); wrapper.last(" limit 1 "); PlatformCapital platformCapital = platformCapitalService.getOne(wrapper); if (Objects.isNull(platformCapital)) {// 若没有数据 log.info("日志编号：" + logNumber + " 手机号：" + customer.getPhone() + "进件失败，原因：随易花推送结果不存在, customer id:" + customer.getId()); return false; } if (platformCapital.getIncomeStatus() == 1) {// 已进件成功 log.info("日志编号：" + logNumber + " 手机号：" + customer.getPhone() + "进件失败，原因：随易花已经进件成功过，不再进件, customer id:" + customer.getId()); return false; } /** * uuid string 是 1587992123923271680 数据记录uuid * type string 是 api 数据业务类型 * productKey string 是 YiUl10zCu 产品key */ param.put("uuid", platformCapital.getUuid()); param.put("type", platformCapital.getType()); param.put("productKey", platformCapital.getProductKey()); param.put("url", callBackUrl); String timestamp = String.valueOf(System.currentTimeMillis()); String key = getKey(timestamp); String signs = SecureUtil.aes(key.getBytes(StandardCharsets.UTF_8)).encryptHex(param.toJSONString().getBytes(StandardCharsets.UTF_8)); JSONObject jsonData = new JSONObject(); jsonData.put("timestamp", timestamp); jsonData.put("signs", signs); log.info("日志编号：" + logNumber + " 手机号：" + customer.getPhone() + "开始进件给资方【随易花】，参数：{}", jsonData); String result = null; String url = syhUrl + "/goodsKey/bs/incoming"; try { result = HttpClientUtil.getInstance().postJsonData(url, jsonData.toJSONString()); log.info("日志编号：" + logNumber + " 手机号为：" + customer.getPhone() + ",【随易花】进件原始返回参数:{}", result); } catch (Exception ex) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件失败，传参：{} ex：{}", customer.getPhone(), jsonData, ex); } if (StringUtils.isBlank(result)) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件返回数据为空，传参：{} ", customer.getPhone(), jsonData); } try { SyhIncomeResponse res = JSON.parseObject(result, SyhIncomeResponse.class); if (res.getResult().intValue() == 200) { log.info("日志编号：" + logNumber + " 手机号为：" + customer.getPhone() + ",【随易花】进件成功"); // 更新数据库 platformCapital.setIncomeStatus(1); platformCapitalService.updateById(platformCapital); LvdiPushResultVo rs = new LvdiPushResultVo(); rs.setCheckResult(true); rs.setUrlType("1");// APP下载链接 return true; } else { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件失败：{}，jsonData：{}", customer.getPhone(), res.getMessage(), jsonData); } } catch (Exception ex) { log.error("日志编号：" + logNumber + " 手机号为：{},【随易花】进件原始返回参数转换失败，jsonData：{} ex：{}", customer.getPhone(), jsonData, ex); } return false; } @NotNull private String getKey(String timestamp) { return String.format("%s%s", encryptKey, timestamp).substring(0, 16); } /** * 解密 * * @param * @param encrypted * @return */ public String decrypt(String timestamp, String encrypted) { String key = String.format("%s%s", encryptKey, timestamp).substring(0, 16); String str = null; try { str = SecureUtil.aes(key.getBytes("UTF-8")).decryptStr(encrypted); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } return str; } }