|
|
@@ -1,4 +1,4 @@
|
|
|
-package com.jzg.quote.hengbang.crawler.service.Impl;
|
|
|
+package com.jzg.quotation.hengbang.crawler.service.Impl;
|
|
|
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
import cn.hutool.crypto.digest.DigestUtil;
|
|
|
@@ -8,25 +8,25 @@ import com.jzg.commons.entity.quote.vo.CarInfoVo;
|
|
|
import com.jzg.commons.entity.quote.vo.QuoteVo;
|
|
|
import com.jzg.commons.entity.quote.vo.RiskInfoVo;
|
|
|
import com.jzg.commons.entity.quote.vo.aggregated.*;
|
|
|
+import com.jzg.commons.entity.quote.vo.base.LoginBase;
|
|
|
+import com.jzg.commons.entity.quote.vo.image.InsuranceImageVo;
|
|
|
import com.jzg.commons.exception.SystemException;
|
|
|
import com.jzg.quotation.commons.annotation.QuoteCrawlerService;
|
|
|
import com.jzg.quotation.commons.constant.InsuranceCode;
|
|
|
-import com.jzg.commons.entity.quote.vo.base.LoginBase;
|
|
|
-import com.jzg.commons.entity.quote.vo.image.InsuranceImageVo;
|
|
|
import com.jzg.quotation.commons.filter.CarModelsFilterUtils;
|
|
|
import com.jzg.quotation.commons.standard.conversion.ConfigureParametersConversion;
|
|
|
-import com.jzg.quote.hengbang.crawler.build.HbCrawlerQuoteResultVoBuild;
|
|
|
-import com.jzg.quote.hengbang.crawler.component.HengBangCrawlerRequestComponent;
|
|
|
-import com.jzg.quote.hengbang.crawler.constant.RequestConstant;
|
|
|
-import com.jzg.quote.hengbang.crawler.constant.enums.RequestUrl;
|
|
|
-import com.jzg.quote.hengbang.crawler.entity.HengBangCrawlerConfigureParameters;
|
|
|
-import com.jzg.quote.hengbang.crawler.entity.dto.HbEncDTO;
|
|
|
-import com.jzg.quote.hengbang.crawler.entity.po.HbCrawlerOrder;
|
|
|
-import com.jzg.quote.hengbang.crawler.entity.request.*;
|
|
|
-import com.jzg.quote.hengbang.crawler.entity.response.*;
|
|
|
-import com.jzg.quote.hengbang.crawler.properties.HengBangCrawlerProperties;
|
|
|
-import com.jzg.quote.hengbang.crawler.service.HbCrawlerOrderService;
|
|
|
-import com.jzg.quote.hengbang.crawler.service.HengBangCrawlerRequest;
|
|
|
+import com.jzg.quotation.hengbang.crawler.build.HbCrawlerQuoteResultVoBuild;
|
|
|
+import com.jzg.quotation.hengbang.crawler.component.HengBangCrawlerRequestComponent;
|
|
|
+import com.jzg.quotation.hengbang.crawler.constant.RequestConstant;
|
|
|
+import com.jzg.quotation.hengbang.crawler.constant.enums.RequestUrl;
|
|
|
+import com.jzg.quotation.hengbang.crawler.entity.HengBangCrawlerConfigureParameters;
|
|
|
+import com.jzg.quotation.hengbang.crawler.entity.dto.HbEncDTO;
|
|
|
+import com.jzg.quotation.hengbang.crawler.entity.po.HbCrawlerOrder;
|
|
|
+import com.jzg.quotation.hengbang.crawler.entity.request.*;
|
|
|
+import com.jzg.quotation.hengbang.crawler.entity.response.*;
|
|
|
+import com.jzg.quotation.hengbang.crawler.properties.HengBangCrawlerProperties;
|
|
|
+import com.jzg.quotation.hengbang.crawler.service.HbCrawlerOrderService;
|
|
|
+import com.jzg.quotation.hengbang.crawler.service.HengBangCrawlerRequest;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import org.springframework.http.HttpHeaders;
|
|
|
|
|
|
@@ -48,6 +48,7 @@ public class HengBangCrawlerRequestImpl implements HengBangCrawlerRequest {
|
|
|
private final HbCrawlerOrderService hbCrawlerOrderService;
|
|
|
|
|
|
private final HengBangCrawlerProperties hbCrawlerProperties;
|
|
|
+
|
|
|
/**
|
|
|
* 登录
|
|
|
* @param loginBase 登录信息
|
|
|
@@ -136,7 +137,7 @@ public class HengBangCrawlerRequestImpl implements HengBangCrawlerRequest {
|
|
|
|
|
|
HbCrawlerPayUrlResponse payUrlResponse = hbCrawlerRequestComponent.getPayUrl(hbCrawlerOrder.getPlyappno(), headers);
|
|
|
PaymentLinkResultsVo paymentLinkResultsVo = new PaymentLinkResultsVo();
|
|
|
- paymentLinkResultsVo.setPayLinkStatus("0".equals(payUrlResponse.getShowSms()) ? true : false);
|
|
|
+ paymentLinkResultsVo.setPayLinkStatus("0".equals(payUrlResponse.getShowSms()));
|
|
|
paymentLinkResultsVo.setPaymentLink(payUrlResponse.getPayUrl());
|
|
|
|
|
|
return paymentLinkResultsVo;
|
|
|
@@ -148,9 +149,11 @@ public class HengBangCrawlerRequestImpl implements HengBangCrawlerRequest {
|
|
|
*/
|
|
|
@Override
|
|
|
public void uploadImage(InsuranceUploadImageVo insuranceUploadImageVo) {
|
|
|
- AttributionInformationVo attributionInformationVo = insuranceUploadImageVo.getOrder().getAttributionInformationVo();
|
|
|
+ AttributionInformationVo attributionInformationVo = insuranceUploadImageVo.getOrder()
|
|
|
+ .getAttributionInformationVo();
|
|
|
HttpHeaders headers = hbCrawlerRequestComponent.getHeaders(attributionInformationVo.getUsername(), attributionInformationVo.getPassword());
|
|
|
- HbCrawlerOrder hbCrawlerOrder = hbCrawlerOrderService.findByOrdersNo(insuranceUploadImageVo.getOrder().getOrdersNo());
|
|
|
+ HbCrawlerOrder hbCrawlerOrder = hbCrawlerOrderService.findByOrdersNo(insuranceUploadImageVo.getOrder()
|
|
|
+ .getOrdersNo());
|
|
|
//暂时将图片默认为01,06,09,投保业务-旧车-其他资料
|
|
|
Integer fileNum = 0;
|
|
|
StringBuilder fileBuff = new StringBuilder();
|
|
|
@@ -163,19 +166,19 @@ public class HengBangCrawlerRequestImpl implements HengBangCrawlerRequest {
|
|
|
List<InsuranceImageVo.ImageDTO> imageBase64List = insuranceImageVo.getImageBase64List();
|
|
|
if (imageBase64List != null && !imageBase64List.isEmpty()) {
|
|
|
for (InsuranceImageVo.ImageDTO imageBase64 : imageBase64List) {
|
|
|
- if (fileBuff.length() > 0) {
|
|
|
+ if (!fileBuff.isEmpty()) {
|
|
|
fileBuff.append("||");
|
|
|
}
|
|
|
fileBuff.append(imageBase64.getImageBase64Str());
|
|
|
- if (fileType.length() > 0) {
|
|
|
+ if (!fileType.isEmpty()) {
|
|
|
fileType.append("||");
|
|
|
}
|
|
|
fileType.append(RequestConstant.IMAGE_TYPE);
|
|
|
- if (mark3.length() > 0) {
|
|
|
+ if (!mark3.isEmpty()) {
|
|
|
mark3.append(",");
|
|
|
}
|
|
|
mark3.append(mark3Num++);
|
|
|
- fileNum+=1;
|
|
|
+ fileNum += 1;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -204,13 +207,18 @@ public class HengBangCrawlerRequestImpl implements HengBangCrawlerRequest {
|
|
|
getPolicyRequest.setCarMark(parameters.getLicenseNo());
|
|
|
HbCrawlerGetPolicyResponse policyResponse = hbCrawlerRequestComponent.getPolicy(getPolicyRequest, headers);
|
|
|
List<String> downloadUrls = new ArrayList<>();
|
|
|
- List<HbCrawlerGetPolicyResponse.ResponseBodyDTO.ContentDTO> contentDTOList = policyResponse.getResponseBody().getContent();
|
|
|
+ List<HbCrawlerGetPolicyResponse.ResponseBodyDTO.ContentDTO> contentDTOList = policyResponse.getResponseBody()
|
|
|
+ .getContent();
|
|
|
if (contentDTOList != null && !contentDTOList.isEmpty()) {
|
|
|
contentDTOList.forEach(contentDTO -> {
|
|
|
//获取参数sign的值
|
|
|
String sign = getSign(contentDTO.getPOLICY_CATEGORY(), contentDTO.getBUSINESS_NO());
|
|
|
StringBuilder downloadUrl = new StringBuilder(RequestUrl.DOWNLOAD_POLICY.getRequestUrl(hbCrawlerProperties.getBaseUrl()));
|
|
|
- downloadUrl.append(contentDTO.getPOLICY_CATEGORY()).append("/").append(contentDTO.getBUSINESS_NO()).append("?sign=").append(sign);
|
|
|
+ downloadUrl.append(contentDTO.getPOLICY_CATEGORY())
|
|
|
+ .append("/")
|
|
|
+ .append(contentDTO.getBUSINESS_NO())
|
|
|
+ .append("?sign=")
|
|
|
+ .append(sign);
|
|
|
downloadUrls.add(downloadUrl.toString());
|
|
|
});
|
|
|
}
|