|
|
@@ -45,6 +45,7 @@ import com.jzg.quotation.guoren.api.properties.GuoRenApiConfigurationProperties;
|
|
|
import com.jzg.quotation.guoren.api.service.GuoRenApiOrderService;
|
|
|
import com.jzg.quotation.guoren.api.service.GuoRenApiRequest;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
+import org.apache.commons.compress.utils.IOUtils;
|
|
|
import org.apache.commons.httpclient.methods.multipart.FilePart;
|
|
|
import org.apache.commons.httpclient.methods.multipart.Part;
|
|
|
import org.apache.commons.httpclient.methods.multipart.StringPart;
|
|
|
@@ -55,6 +56,7 @@ import org.springframework.util.ObjectUtils;
|
|
|
|
|
|
import java.io.File;
|
|
|
import java.io.FileOutputStream;
|
|
|
+import java.io.InputStream;
|
|
|
import java.math.BigDecimal;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
@@ -62,6 +64,7 @@ import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* description:
|
|
|
+ *
|
|
|
* @author: shenwd
|
|
|
* @date: 2025/3/14 09:58
|
|
|
**/
|
|
|
@@ -82,6 +85,8 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
|
|
|
private final PlatformClient platformClient;
|
|
|
|
|
|
+ private final MinioUtils minioUtils;
|
|
|
+
|
|
|
public String getApiUrl(String companyId) {
|
|
|
// 获取保司配置url地址
|
|
|
HttpResult<PtlAgreementUrl> ptlAgreementUrl = platformClient.getAgreementUrlByCompanyId(companyId);
|
|
|
@@ -90,6 +95,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
|
|
|
/**
|
|
|
* 报价
|
|
|
+ *
|
|
|
* @param quoteVo 报价实体
|
|
|
* @return 报价信息
|
|
|
*/
|
|
|
@@ -106,11 +112,11 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
vinQueryRequest.setFrameNo(carInfoVo.getVinNo());
|
|
|
vinQueryRequest.setLicenseNo(carInfoVo.getLicenseNo());
|
|
|
|
|
|
- VinQueryResponse.DataDTO vinQuery = vinQuery(vinQueryRequest, parameters,url);
|
|
|
+ VinQueryResponse.DataDTO vinQuery = vinQuery(vinQueryRequest, parameters, url);
|
|
|
AssertionUtils.isEmpty(vinQuery, "未找到匹配的车辆信息");
|
|
|
|
|
|
//车价查询
|
|
|
- CarPriceResponse.DataDTO carPriceQuery = carPriceQuery(quoteVo, vinQuery, parameters,url);
|
|
|
+ CarPriceResponse.DataDTO carPriceQuery = carPriceQuery(quoteVo, vinQuery, parameters, url);
|
|
|
AssertionUtils.isEmpty(carPriceQuery, "车价获取失败");
|
|
|
|
|
|
//创建非车订单
|
|
|
@@ -145,11 +151,11 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
guoRenApiOrder.setId(orderBase.getOrdersNo());
|
|
|
guoRenApiOrder.setOrdersNo(orderBase.getOrdersNo());
|
|
|
guoRenApiOrder.setProductsCode(orderBase.getProductId());
|
|
|
- return handleFailedQuote(guoRenApiOrder,quoteVo,premiumResponse);
|
|
|
+ return handleFailedQuote(guoRenApiOrder, quoteVo, premiumResponse);
|
|
|
} else {
|
|
|
//保存投保单 该接口返回投保单号
|
|
|
InsuranceSlipResponse insuranceSlipResponse = guoRenRequestApiComponent.insuranceSlip(quoteVo,
|
|
|
- carPriceQuery.getInputvo(), orderCode, specialAgreements,url);
|
|
|
+ carPriceQuery.getInputvo(), orderCode, specialAgreements, url);
|
|
|
if (insuranceSlipResponse.getResultCode() == 1) {
|
|
|
throw new SystemException(insuranceSlipResponse.getResultMsg());
|
|
|
}
|
|
|
@@ -166,22 +172,21 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
guoRenApiOrder.setCarTax(BigDecimal.valueOf(premiumResponse.getData().getSumPayTax()));
|
|
|
guoRenApiOrder.setOthBusinessNo(carPriceQuery.getInputvo());
|
|
|
guoRenApiOrder.setNoCarOrderNo(nonAutoInsOrderResponse != null ? nonAutoInsOrderResponse.getData().getOrderCode() : "");
|
|
|
- return handleSuccessQuote(guoRenApiOrder,quoteVo, premiumResponse,nonAutoInsOrderResponse);
|
|
|
+ return handleSuccessQuote(guoRenApiOrder, quoteVo, premiumResponse, nonAutoInsOrderResponse);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private QuoteResultsVo handleFailedQuote(GuoRenApiOrder guoRenApiOrder,QuoteVo quoteVo,PremiumResponse response) {
|
|
|
+ private QuoteResultsVo handleFailedQuote(GuoRenApiOrder guoRenApiOrder, QuoteVo quoteVo, PremiumResponse response) {
|
|
|
guoRenApiOrderService.save(guoRenApiOrder);
|
|
|
return GuoRenApiQuoteResultsVoBuild.buildQuoteFailResultsVo(response);
|
|
|
}
|
|
|
|
|
|
- private QuoteResultsVo handleSuccessQuote(GuoRenApiOrder guoRenApiOrder,QuoteVo quoteVo,PremiumResponse response,NonAutoInsOrderResponse nonAutoInsOrderResponse) {
|
|
|
+ private QuoteResultsVo handleSuccessQuote(GuoRenApiOrder guoRenApiOrder, QuoteVo quoteVo, PremiumResponse response, NonAutoInsOrderResponse nonAutoInsOrderResponse) {
|
|
|
guoRenApiOrderService.save(guoRenApiOrder);
|
|
|
- return GuoRenApiQuoteResultsVoBuild.buildQuoteResultsVo(quoteVo,response,nonAutoInsOrderResponse);
|
|
|
+ return GuoRenApiQuoteResultsVoBuild.buildQuoteResultsVo(quoteVo, response, nonAutoInsOrderResponse);
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
/**
|
|
|
* 提交核保 子订单
|
|
|
*
|
|
|
@@ -195,7 +200,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
GuoRenConfigureParameters parameters = ConfigureParametersConversion.conversionEntity(GuoRenConfigureParameters.class, orderBase.getAttributionInformationVo().getConfigInfo());
|
|
|
GuoRenApiOrder guoRenApiOrder = guoRenApiOrderService.findByOrdersNo(orderBase.getOrdersNo());
|
|
|
|
|
|
- SubmitAuditResponse auditResponse = guoRenRequestApiComponent.submitAudit(guoRenApiOrder, parameters,url);
|
|
|
+ SubmitAuditResponse auditResponse = guoRenRequestApiComponent.submitAudit(guoRenApiOrder, parameters, url);
|
|
|
UnderwritingResultsVo underwritingResultsVo = new UnderwritingResultsVo();
|
|
|
String jqStatus = auditResponse.getData().get(0).getUnderWriteFlagCI();
|
|
|
String syStatus = auditResponse.getData().get(0).getUnderWriteFlagBI();
|
|
|
@@ -203,14 +208,14 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
// 0初始值/1通过/2不通过/3无需核保/9人工核保
|
|
|
if (StringUtils.isEmpty(jqStatus) && StringUtils.isEmpty(syStatus)) {
|
|
|
underwritingResultsVo.setUnderwritingStatus(InsOrderStatusEnum.AUDIT_FAIL);
|
|
|
- underwritingResultsVo.setUnderwritingResult("核保失败:"+ message);
|
|
|
+ underwritingResultsVo.setUnderwritingResult("核保失败:" + message);
|
|
|
return underwritingResultsVo;
|
|
|
}
|
|
|
// 单交核保状态
|
|
|
if (StringUtils.isNotEmpty(jqStatus) && StringUtils.isEmpty(syStatus)) {
|
|
|
if (jqStatus.equals("1") || jqStatus.equals("3")) {
|
|
|
underwritingResultsVo.setUnderwritingStatus(InsOrderStatusEnum.PAY_PENDING);
|
|
|
- SignatureResponse signature = getSignature(guoRenApiOrder,url);
|
|
|
+ SignatureResponse signature = getSignature(guoRenApiOrder, url);
|
|
|
underwritingResultsVo.setPaymentLink(signature.getQrCode());
|
|
|
} else if (jqStatus.equals("2") || jqStatus.equals("0")) {
|
|
|
underwritingResultsVo.setUnderwritingStatus(InsOrderStatusEnum.AUDIT_FAIL);
|
|
|
@@ -221,7 +226,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
if (StringUtils.isEmpty(syStatus) && StringUtils.isNotEmpty(syStatus)) {
|
|
|
if (syStatus.equals("1") || syStatus.equals("3")) {
|
|
|
underwritingResultsVo.setUnderwritingStatus(InsOrderStatusEnum.PAY_PENDING);
|
|
|
- SignatureResponse signature = getSignature(guoRenApiOrder,url);
|
|
|
+ SignatureResponse signature = getSignature(guoRenApiOrder, url);
|
|
|
underwritingResultsVo.setPaymentLink(signature.getQrCode());
|
|
|
|
|
|
} else if (syStatus.equals("2") || syStatus.equals("0")) {
|
|
|
@@ -237,11 +242,11 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
underwritingResultsVo.setUnderwritingResult(message);
|
|
|
} else if (jqStatus.equals("1") && syStatus.equals("1")) {
|
|
|
underwritingResultsVo.setUnderwritingStatus(InsOrderStatusEnum.PAY_PENDING);
|
|
|
- SignatureResponse signature = getSignature(guoRenApiOrder,url);
|
|
|
+ SignatureResponse signature = getSignature(guoRenApiOrder, url);
|
|
|
underwritingResultsVo.setPaymentLink(signature.getQrCode());
|
|
|
} else if (jqStatus.equals("3") && syStatus.equals("3")) {
|
|
|
underwritingResultsVo.setUnderwritingStatus(InsOrderStatusEnum.PAY_PENDING);
|
|
|
- SignatureResponse signature = getSignature(guoRenApiOrder,url);
|
|
|
+ SignatureResponse signature = getSignature(guoRenApiOrder, url);
|
|
|
underwritingResultsVo.setPaymentLink(signature.getQrCode());
|
|
|
}
|
|
|
}
|
|
|
@@ -251,13 +256,14 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
/**
|
|
|
* 通过二维码扫描获取电子投保单签名
|
|
|
*/
|
|
|
- public SignatureResponse getSignature(GuoRenApiOrder guoRenApiOrder,String url) {
|
|
|
- return guoRenRequestApiComponent.signature(guoRenApiOrder,url);
|
|
|
+ public SignatureResponse getSignature(GuoRenApiOrder guoRenApiOrder, String url) {
|
|
|
+ return guoRenRequestApiComponent.signature(guoRenApiOrder, url);
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
* 获取支付链接
|
|
|
+ *
|
|
|
* @param paymentLinkVo
|
|
|
*/
|
|
|
@Override
|
|
|
@@ -267,7 +273,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
GuoRenConfigureParameters parameters = ConfigureParametersConversion.conversionEntity(GuoRenConfigureParameters.class, paymentLinkVo.getOrder().getAttributionInformationVo().getConfigInfo());
|
|
|
GuoRenApiOrder guoRenApiOrder = guoRenApiOrderService.findByOrdersNo(paymentLinkVo.getOrder().getOrdersNo());
|
|
|
|
|
|
- PayResponse.DataDTO dataDTO = guoRenRequestApiComponent.getPaid(guoRenApiOrder, parameters,url);
|
|
|
+ PayResponse.DataDTO dataDTO = guoRenRequestApiComponent.getPaid(guoRenApiOrder, parameters, url);
|
|
|
PaymentLinkResultsVo resultsVo = new PaymentLinkResultsVo();
|
|
|
resultsVo.setPaymentLink(dataDTO.getPayUrl());
|
|
|
return resultsVo;
|
|
|
@@ -275,6 +281,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
|
|
|
/**
|
|
|
* 上传影像
|
|
|
+ *
|
|
|
* @param insuranceUploadImageVo
|
|
|
*/
|
|
|
@Override
|
|
|
@@ -294,6 +301,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
|
|
|
/**
|
|
|
* 下载保单
|
|
|
+ *
|
|
|
* @param downloadPolicyVo
|
|
|
*/
|
|
|
@Override
|
|
|
@@ -307,16 +315,16 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
String syPolicyNo = policie.getSyPolicyNo();
|
|
|
String jyPolicyNo = policie.getJyPolicyNo();
|
|
|
if (jqPolicyNo != null) {
|
|
|
- PolicyResponse jqResponse = guoRenRequestApiComponent.policyPrint(jqPolicyNo,url);
|
|
|
+ PolicyResponse jqResponse = guoRenRequestApiComponent.policyPrint(jqPolicyNo, url);
|
|
|
downloadPolicyResultVo.setJqFlagUrl(properties.getPolicyFlagUrl() + jqResponse.getData());
|
|
|
downloadPolicyResultVo.setJqUrl(properties.getPolicyUrl() + jqResponse.getData());
|
|
|
}
|
|
|
if (syPolicyNo != null) {
|
|
|
- PolicyResponse syResponse = guoRenRequestApiComponent.policyPrint(syPolicyNo,url);
|
|
|
+ PolicyResponse syResponse = guoRenRequestApiComponent.policyPrint(syPolicyNo, url);
|
|
|
downloadPolicyResultVo.setSyUrl(properties.getPolicyUrl() + syResponse.getData());
|
|
|
}
|
|
|
if (jyPolicyNo != null) {
|
|
|
- String jyResponse = guoRenRequestApiComponent.noCarElectronicPolicy(properties.getChannelCode(),guoRenApiOrder.getOthBusinessNo(),jyPolicyNo,url);
|
|
|
+ String jyResponse = guoRenRequestApiComponent.noCarElectronicPolicy(properties.getChannelCode(), guoRenApiOrder.getOthBusinessNo(), jyPolicyNo, url);
|
|
|
downloadPolicyResultVo.setJyUrl(jyResponse);
|
|
|
}
|
|
|
return downloadPolicyResultVo;
|
|
|
@@ -334,7 +342,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
InsOrders insOrders = orderBase.getInsOrders();
|
|
|
String url = getApiUrl(orderBase.getOrder().getInsuranceCompanyId());
|
|
|
// 获取保司订单状态
|
|
|
- OrderStateResponse orderStateResponse = insOrderStatus(insOrdersPolicy,url);
|
|
|
+ OrderStateResponse orderStateResponse = insOrderStatus(insOrdersPolicy, url);
|
|
|
GuoRenApiOrder guoRenApiOrder = guoRenApiOrderService.findByOrdersNo(orderBase.getOrder().getOrdersNo());
|
|
|
OrderStatusResultVo orderStatusResultVo = new OrderStatusResultVo();
|
|
|
if (null != orderStateResponse && CollUtil.isNotEmpty(orderStateResponse.getData())) {
|
|
|
@@ -373,7 +381,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
// 支付
|
|
|
if (updateFlag) {
|
|
|
orderStatusResultVo.setOrderStatus(InsOrderStatusEnum.UNDERWRITED);
|
|
|
- List<DrivingInsuranceDTO> drivingInsuranceDTOList = guoRenRequestApiComponent.queryNoCarPolicyNo(guoRenApiOrder,url);
|
|
|
+ List<DrivingInsuranceDTO> drivingInsuranceDTOList = guoRenRequestApiComponent.queryNoCarPolicyNo(guoRenApiOrder, url);
|
|
|
drivingInsuranceDTOList.forEach(drivingInsuranceDTO -> {
|
|
|
orderStatusResultVo.setJyPolicyno(drivingInsuranceDTO.getPolicyNumber());
|
|
|
orderStatusResultVo.setJyApplyNo(drivingInsuranceDTO.getApplicationNumber());
|
|
|
@@ -384,7 +392,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
- public OrderStateResponse insOrderStatus(InsOrdersPolicy insOrdersPolicy,String url) {
|
|
|
+ public OrderStateResponse insOrderStatus(InsOrdersPolicy insOrdersPolicy, String url) {
|
|
|
OrderStateRequest orderStateRequest = new OrderStateRequest();
|
|
|
// 交强投保单号
|
|
|
orderStateRequest.addProposalNos(insOrdersPolicy.getJqApplyNo());
|
|
|
@@ -392,19 +400,20 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
orderStateRequest.addProposalNos(insOrdersPolicy.getSyApplyNo());
|
|
|
//投保单状态查询
|
|
|
return guoRenRequestApiComponent.request(orderStateRequest, PlatformInterfaceCode.API_IIRBT00010,
|
|
|
- OrderStateResponse.class,url);
|
|
|
+ OrderStateResponse.class, url);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* vin码查询车辆信息
|
|
|
+ *
|
|
|
* @return VinQueryResp.DataDTO
|
|
|
* @author: lig
|
|
|
* @date: 2023年08月18日 0018
|
|
|
*/
|
|
|
- public VinQueryResponse.DataDTO vinQuery(VinQueryRequest vinQueryReq, GuoRenConfigureParameters parameters,String url) {
|
|
|
+ public VinQueryResponse.DataDTO vinQuery(VinQueryRequest vinQueryReq, GuoRenConfigureParameters parameters, String url) {
|
|
|
VinQueryRequest req = new VinQueryRequest(vinQueryReq, parameters);
|
|
|
VinQueryResponse resp = guoRenRequestApiComponent.request(req, PlatformInterfaceCode.API_IIRBT00009,
|
|
|
- VinQueryResponse.class,url);
|
|
|
+ VinQueryResponse.class, url);
|
|
|
if (resp.getResultCode() == 1) {
|
|
|
throw new SystemException(resp.getResultMsg() == null ? "未找到车辆信息" : resp.getResultMsg());
|
|
|
}
|
|
|
@@ -415,10 +424,10 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
* 车价查询
|
|
|
*/
|
|
|
public CarPriceResponse.DataDTO carPriceQuery(QuoteVo quoteVo, VinQueryResponse.DataDTO vinQ,
|
|
|
- GuoRenConfigureParameters parameters,String url) {
|
|
|
+ GuoRenConfigureParameters parameters, String url) {
|
|
|
|
|
|
CarPriceRequest req = CarPriceRequest.buildCarPriceParam(quoteVo, vinQ, parameters);
|
|
|
- JSONObject request = guoRenRequestApiComponent.request(req, PlatformInterfaceCode.API_IIRBT00003,url);
|
|
|
+ JSONObject request = guoRenRequestApiComponent.request(req, PlatformInterfaceCode.API_IIRBT00003, url);
|
|
|
Object cars = request.get("cars");
|
|
|
|
|
|
if (ObjectUtils.isEmpty(cars)) {
|
|
|
@@ -441,7 +450,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
//车辆年款不能超过注册日期
|
|
|
List<CarPriceMuchResponse.DataDTO.CarsDTO> vehicleInfoList =
|
|
|
respMuch.getData().getCars().stream().filter(a -> DateTimeUtil.dateIsAfter(carInfo.getRegisterDate(),
|
|
|
- a.getCarYear())).collect(Collectors.toList());
|
|
|
+ a.getCarYear())).collect(Collectors.toList());
|
|
|
|
|
|
//匹配的车辆信息数据 为空
|
|
|
if (CollUtil.isEmpty(vehicleInfoList)) {
|
|
|
@@ -461,7 +470,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
confirmCarMuch = vehicleInfoList.get(0);
|
|
|
}
|
|
|
}
|
|
|
- return carPriceQueryMuch(respMuch.getData().getInputvo(), confirmCarMuch,url
|
|
|
+ return carPriceQueryMuch(respMuch.getData().getInputvo(), confirmCarMuch, url
|
|
|
);
|
|
|
}
|
|
|
}
|
|
|
@@ -471,12 +480,12 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
/**
|
|
|
* (多条)车价查询
|
|
|
*/
|
|
|
- public CarPriceResponse.DataDTO carPriceQueryMuch(String uuid, CarPriceMuchResponse.DataDTO.CarsDTO carsDTO,String url) {
|
|
|
+ public CarPriceResponse.DataDTO carPriceQueryMuch(String uuid, CarPriceMuchResponse.DataDTO.CarsDTO carsDTO, String url) {
|
|
|
//构造请求参数
|
|
|
CarPriceMuchRequest req = new CarPriceMuchRequest();
|
|
|
req.setUuid(uuid);
|
|
|
req.setCarPriceMuchResp(carsDTO);
|
|
|
- JSONObject request = guoRenRequestApiComponent.request(req, PlatformInterfaceCode.API_IIRBT00017,url);
|
|
|
+ JSONObject request = guoRenRequestApiComponent.request(req, PlatformInterfaceCode.API_IIRBT00017, url);
|
|
|
CarPriceResponse resp = request.toJavaObject(CarPriceResponse.class);
|
|
|
if (resp.getResultCode() == 1) {
|
|
|
throw new SystemException(resp.getResultMsg() == null ? "未获取到车价信息,请联系管理员" : resp.getResultMsg());
|
|
|
@@ -487,6 +496,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
|
|
|
/**
|
|
|
* 意外险转换
|
|
|
+ *
|
|
|
* @param accidentalDrivingVoList
|
|
|
* @return
|
|
|
*/
|
|
|
@@ -507,23 +517,25 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
|
|
|
/**
|
|
|
* 创建非车订单
|
|
|
+ *
|
|
|
* @author: lig
|
|
|
* @date: 2023-09-28
|
|
|
*/
|
|
|
public NonAutoInsOrderResponse nonAutoInsOrder(QuoteVo quoteVo,
|
|
|
GuoRenAccidentalDrivingVo accidentalDrivingVo,
|
|
|
String carPriceUuid, GuoRenConfigureParameters channelInfo,
|
|
|
- VinQueryResponse.DataDTO vinQ,String url) {
|
|
|
+ VinQueryResponse.DataDTO vinQ, String url) {
|
|
|
//构造请求参数
|
|
|
NonAutoInsOrderRequest nonAutoInsOrderReq = new NonAutoInsOrderRequest(quoteVo, vinQ, accidentalDrivingVo,
|
|
|
channelInfo,
|
|
|
carPriceUuid, properties.getChannelCode());
|
|
|
return guoRenRequestApiComponent.request(nonAutoInsOrderReq, PlatformInterfaceCode.API_IIIRBT00054,
|
|
|
- NonAutoInsOrderResponse.class,url);
|
|
|
+ NonAutoInsOrderResponse.class, url);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 查询国任特约数据
|
|
|
+ *
|
|
|
* @param quoteVo 原参数为agreementId,以后看orderbase中的配置信息map中是否可以获取
|
|
|
* @return
|
|
|
*/
|
|
|
@@ -554,7 +566,6 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
// }
|
|
|
// return list;
|
|
|
// }
|
|
|
-
|
|
|
public List<GuoRenSpecialAgreementVo> getSpecialAgreements(QuoteVo quoteVo) {
|
|
|
List<InsCompanyClause> companyClauseVos = quoteVo.getSpecialInfoVo();
|
|
|
List<GuoRenSpecialAgreementVo> list = new ArrayList<>();
|
|
|
@@ -566,7 +577,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
}
|
|
|
|
|
|
public PremiumResponse premiumQuery(QuoteVo quoteVo, CarPriceResponse.DataDTO carPriceQuery, VinQueryResponse.DataDTO vinQuery, Boolean isNoCar,
|
|
|
- List<GuoRenSpecialAgreementVo> specialAgreements, String noCarPremium, String goodsCode,String url) {
|
|
|
+ List<GuoRenSpecialAgreementVo> specialAgreements, String noCarPremium, String goodsCode, String url) {
|
|
|
boolean boo;
|
|
|
//请求信息列表
|
|
|
List<String> requestInfoList = new ArrayList<>();
|
|
|
@@ -575,7 +586,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
PremiumResponse premiumResponse;
|
|
|
int a = 0;
|
|
|
for (; ; ) {
|
|
|
- premiumResponse = guoRenRequestApiComponent.request(premiumRequest, PlatformInterfaceCode.API_IIRBT00004, PremiumResponse.class,url);
|
|
|
+ premiumResponse = guoRenRequestApiComponent.request(premiumRequest, PlatformInterfaceCode.API_IIRBT00004, PremiumResponse.class, url);
|
|
|
|
|
|
premiumRequest.getCi().getPrpTmain().setAnswer(null);
|
|
|
premiumRequest.getBi().getPrpTmain().setAnswer(null);
|
|
|
@@ -620,7 +631,7 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
*/
|
|
|
public void imageUpdate(GuoRenApiOrder guoRenApiOrder, GuoRenConfigureParameters parameters, InsuranceUploadImageVo insuranceUploadImageVo) {
|
|
|
// 获取交强险投保单号(交商同保传交强)
|
|
|
- String businessNo = guoRenApiOrder.getJqApplyNo();
|
|
|
+ String businessNo = "T263050000507031021";
|
|
|
if (StringUtils.isEmpty(businessNo)) {
|
|
|
logger.error("国任上传影像失败,交强险投保单号为空");
|
|
|
throw new SystemException("国任,影像上传失败,投保单号为空");
|
|
|
@@ -677,15 +688,16 @@ public class GuoRenApiRequestImpl implements GuoRenApiRequest {
|
|
|
// 获取文件名
|
|
|
fileName = uploadFile.getFileName();
|
|
|
|
|
|
- // 获取预签名URL
|
|
|
- String presignedUrl = MinioUtils.getPresignedObjectUrl(uploadFile.getBucketName(), fileName);
|
|
|
- if (StringUtils.isEmpty(presignedUrl)) {
|
|
|
+ // 获取文件流
|
|
|
+// String presignedUrl = MinioUtils.getPresignedObjectUrl(uploadFile.getBucketName(), fileName);
|
|
|
+ InputStream inputStream = minioUtils.getObject(uploadFile.getBucketName(), fileName);
|
|
|
+ if (inputStream == null) {
|
|
|
logger.error("国任上传影像失败,获取文件预签名URL失败,imageId:{}", imageDTO.getImageId());
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
// 下载文件内容为byte[]
|
|
|
- imageBytes = HttpUtil.getUrlBytes(presignedUrl);
|
|
|
+ imageBytes = IOUtils.toByteArray(inputStream);
|
|
|
if (imageBytes == null || imageBytes.length == 0) {
|
|
|
logger.error("国任上传影像失败,文件内容为空,imageId:{}", imageDTO.getImageId());
|
|
|
continue;
|