紫金添加自主定价系数

src/main/java/com/ydtech/modules/order/components/zijin/ZijinRequestApiComponents.java

@@ -55,7 +55,8 @@ public class ZijinRequestApiComponents {
 
     private final Map<String, ResponseMessageAbstractHandler> handlerMap;
 
-    public ZijinRequestApiComponents(InsCrawlerOrderComponents insCrawlerOrderComponents, ZijinApiConfigurationProperties zijinApiConfigurationProperties,
+    public ZijinRequestApiComponents(InsCrawlerOrderComponents insCrawlerOrderComponents,
+                                     ZijinApiConfigurationProperties zijinApiConfigurationProperties,
                                      ConfigureParametersComponents configureParametersComponents, StringRedisTemplate redisTemplate,
                                      RedissonClient redissonClient, Map<String, ResponseMessageAbstractHandler> handlerMap) {
         this.insCrawlerOrderComponents = insCrawlerOrderComponents;
@@ -72,7 +73,8 @@ public class ZijinRequestApiComponents {
         return b;
     }
 
-    public <T, B extends BaseResponse> B requestQuotation(RequestUrl requestUrl, T requestBody, Class<B> responseType, HttpHeaders httpHeaders) {
+    public <T, B extends BaseResponse> B requestQuotation(RequestUrl requestUrl, T requestBody, Class<B> responseType,
+                                                          HttpHeaders httpHeaders) {
         String url = zijinApiConfigurationProperties.getUrl() + requestUrl.getUri();
         B b = insCrawlerOrderComponents.request(url, InsuranceEnum.ZKIC, requestUrl.getDesc(), requestBody, responseType, httpHeaders);
         ResultEnum.verifyQuotation(b.getRtnCode(), b.getRtnMsg());
@@ -93,7 +95,8 @@ public class ZijinRequestApiComponents {
      */
     private HttpHeaders getToken(ZjConfigureParameters zjConfigureParameters, HttpHeaders httpHeaders) {
         // 1 为接入方提供获取token服务
-        GetAccessTokenRequest getAccessTokenRequest = new GetAccessTokenRequest(zjConfigureParameters.getAppKey(), zjConfigureParameters.getAppSecret());
+        GetAccessTokenRequest getAccessTokenRequest = new GetAccessTokenRequest(zjConfigureParameters.getAppKey(),
+                zjConfigureParameters.getAppSecret());
         GetAccessTokenResponse accessToken = getAccessToken(getAccessTokenRequest);
         httpHeaders.set(AUTHORIZATION, accessToken.getToken());
         // 2 车险业务获取token服务
@@ -184,7 +187,8 @@ public class ZijinRequestApiComponents {
      */
     public GetAccessTokenResponse getAccessToken(GetAccessTokenRequest getAccessTokenRequest) {
         String url = zijinApiConfigurationProperties.getAccessTokenUrl();
-        GetAccessTokenResponse response = insCrawlerOrderComponents.request(url, InsuranceEnum.ZKIC, "为接入方提供获取token服务", getAccessTokenRequest, GetAccessTokenResponse.class);
+        GetAccessTokenResponse response = insCrawlerOrderComponents.request(url, InsuranceEnum.ZKIC, "为接入方提供获取token服务",
+                getAccessTokenRequest, GetAccessTokenResponse.class);
         ResultEnum.verify(response.getRtnCode(), response.getRtnMsg());
         return response;
     }
@@ -236,12 +240,15 @@ public class ZijinRequestApiComponents {
      * @param message                 传输信息
      * @return 出参实体
      */
-    public CalculatePremiumResponse calculatePremium(CalculatePremiumRequest calculatePremiumRequest, HttpHeaders httpHeaders, ModelQueryRequest modelQueryRequest, String message,QueryActualValueRequest queryActualValueRequest, boolean retry ) {
-        CalculatePremiumResponse calculatePremiumResponse = requestQuotation(RequestUrl.CALCULATE_PREMIUM, calculatePremiumRequest, CalculatePremiumResponse.class, httpHeaders);
+    public CalculatePremiumResponse calculatePremium(CalculatePremiumRequest calculatePremiumRequest, HttpHeaders httpHeaders,
+                                                     ModelQueryRequest modelQueryRequest, String message,
+                                                     QueryActualValueRequest queryActualValueRequest, boolean retry) {
+        CalculatePremiumResponse calculatePremiumResponse = requestQuotation(RequestUrl.CALCULATE_PREMIUM, calculatePremiumRequest,
+                CalculatePremiumResponse.class, httpHeaders);
         // 清空转保业务码
         CalculatePremiumRequest.BaseInfoDTO baseInfo = calculatePremiumRequest.getBaseInfo();
 
-        if(!calculatePremiumResponse.getRtnCode().equals(ResultEnum.C_999)){
+        if (!calculatePremiumResponse.getRtnCode().equals(ResultEnum.C_999)) {
             baseInfo.setAnswerCI(null);
             baseInfo.setAnswer(null);
             baseInfo.setDemandNoCI(null);
@@ -249,9 +256,11 @@ public class ZijinRequestApiComponents {
         }
 
         // 通过状态码获取处理器处理
-        ResponseMessageAbstractHandler responseMessageAbstractHandler = handlerMap.get(ResponseMessageAbstractHandler.CALCULATE_PREMIUM_COMPONENTS + calculatePremiumResponse.getRtnCode());
+        ResponseMessageAbstractHandler responseMessageAbstractHandler =
+                handlerMap.get(ResponseMessageAbstractHandler.CALCULATE_PREMIUM_COMPONENTS + calculatePremiumResponse.getRtnCode());
         if (!ObjectUtils.isEmpty(responseMessageAbstractHandler)) {
-            calculatePremiumResponse = responseMessageAbstractHandler.messageHandler(calculatePremiumRequest, calculatePremiumResponse, httpHeaders, modelQueryRequest, message, queryActualValueRequest, retry);
+            calculatePremiumResponse = responseMessageAbstractHandler.messageHandler(calculatePremiumRequest, calculatePremiumResponse,
+                    httpHeaders, modelQueryRequest, message, queryActualValueRequest, retry);
         }
 
 
@@ -305,7 +314,8 @@ public class ZijinRequestApiComponents {
      * @return 出参实体
      */
     public ZbfAggregatePayResponse zbfAggregatePay(ZbfAggregatePayRequest zbfAggregatePayRequest, HttpHeaders httpHeaders) {
-        return request(zijinApiConfigurationProperties.getPayUrl(), RequestUrl.ZBF_AGGREGATE_PAY.getDesc(), zbfAggregatePayRequest, ZbfAggregatePayResponse.class, httpHeaders);
+        return request(zijinApiConfigurationProperties.getPayUrl(), RequestUrl.ZBF_AGGREGATE_PAY.getDesc(), zbfAggregatePayRequest,
+                ZbfAggregatePayResponse.class, httpHeaders);
     }
 
     /**
@@ -326,7 +336,8 @@ public class ZijinRequestApiComponents {
      * @return 出参实体
      */
     public QueryOrderStateResponse queryOrderDetail(QueryOrderDetailRequest queryOrderDetailRequest, HttpHeaders httpHeaders) {
-        return request(zijinApiConfigurationProperties.getOrderDetailUrl(), RequestUrl.QUERY_ORDER_DETAIL.getDesc(), queryOrderDetailRequest, QueryOrderStateResponse.class, httpHeaders);
+        return request(zijinApiConfigurationProperties.getOrderDetailUrl(), RequestUrl.QUERY_ORDER_DETAIL.getDesc(),
+                queryOrderDetailRequest, QueryOrderStateResponse.class, httpHeaders);
     }
 
 

src/main/java/com/ydtech/modules/order/controller/ZijinOrderApiController.java

@@ -50,6 +50,7 @@ public class ZijinOrderApiController {
     @PostMapping("/quote")
     @ApiOperation("报价")
     public HttpResult<QuoteRespVo> quote(@RequestBody BaseQuoteVo<List<ZjQuoteAccidentVo>> quoteVo) {
+        quoteVo.setCoefficient("1");
         BaseQuoteInfoVo quoteInfo = this.insOrdersComponents.getQuoteInfo(quoteVo.getOrderNo(), quoteVo.getAgreementId());
         return this.zijinOrderApiService.quote(quoteInfo, quoteVo);
     }

src/main/java/com/ydtech/modules/order/entity/api/zijin/constants/enums/ProfitCode.java

@@ -0,0 +1,24 @@
+package com.ydtech.modules.order.entity.api.zijin.constants.enums;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @description: 紫金财险 费率因子代码
+ * @author: wenks
+ * @date: 2024/1/9 14:05
+ **/
+@Getter
+@AllArgsConstructor
+public enum ProfitCode {
+
+    C31("C31", "自主定价系数"),
+    C32("C32", "传1，兼容非费改");
+
+    private final String code;
+
+    private final String name;
+
+
+}

src/main/java/com/ydtech/modules/order/entity/api/zijin/request/CalculatePremiumRequest.java

@@ -10,18 +10,17 @@ import com.ydtech.modules.ins.model.vo.CustomerInfoVo;
 import com.ydtech.modules.ins.model.vo.KindInfoVo;
 import com.ydtech.modules.ins.model.vo.RiskInfoVo;
 import com.ydtech.modules.order.constants.InsuranceTypeCorrespondence;
+import com.ydtech.modules.order.entity.api.zhongmei.constants.TimeConstants;
 import com.ydtech.modules.order.entity.api.zijin.constants.DateTimeConstants;
-import com.ydtech.modules.order.entity.api.zijin.constants.enums.CalculateFlagEnum;
-import com.ydtech.modules.order.entity.api.zijin.constants.enums.CarKindDetailIdEnum;
-import com.ydtech.modules.order.entity.api.zijin.constants.enums.MotorVehicleInsuranceEnum;
-import com.ydtech.modules.order.entity.api.zijin.constants.enums.RiskCodeEnum;
+import com.ydtech.modules.order.entity.api.zijin.constants.enums.*;
 import com.ydtech.modules.order.entity.api.zijin.response.ModelQueryResponse;
-import com.ydtech.modules.order.entity.api.zhongmei.constants.TimeConstants;
 import com.ydtech.modules.order.entity.config.ZjConfigureParameters;
 import com.ydtech.modules.order.entity.vo.BaseQuoteInfoVo;
+import com.ydtech.modules.order.entity.vo.BaseQuoteVo;
 import com.ydtech.modules.order.entity.vo.VehicleAndVesselTax;
 import com.ydtech.modules.order.entity.vo.zj.ZjQuoteAccidentVo;
 import com.ydtech.modules.order.utils.InsuranceTimeProcessing;
+import com.ydtech.utils.StringUtils;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
@@ -32,6 +31,7 @@ import lombok.NoArgsConstructor;
 import java.io.Serializable;
 import java.math.BigDecimal;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -66,6 +66,12 @@ public class CalculatePremiumRequest implements Serializable {
     @JsonProperty("itemKindList")
     private List<ItemKindListDTO> itemKindList;
 
+    /**
+     * 浮动因子信息
+     */
+    @JsonProperty("profitDataList")
+    private List<ProfitDataListDTO> profitDataList;
+
     /**
      * 意健险险种代码
      */
@@ -114,7 +120,10 @@ public class CalculatePremiumRequest implements Serializable {
     @JsonProperty("demandNoCheckFlag")
     private String demandNoCheckFlag = "1";
 
-    public CalculatePremiumRequest(BaseQuoteInfoVo quoteInfoVo, ModelQueryResponse.VehicleModelInfosDTO vehicleModelInfosDTO, String actualValue, List<ZjQuoteAccidentVo> zjQuoteAccidentVos, ZjConfigureParameters zjConfigureParameters, ModelQueryResponse modelQueryResponse) {
+    public CalculatePremiumRequest(BaseQuoteInfoVo quoteInfoVo, ModelQueryResponse.VehicleModelInfosDTO vehicleModelInfosDTO,
+                                   String actualValue, BaseQuoteVo<List<ZjQuoteAccidentVo>> quoteVo,
+                                   ZjConfigureParameters zjConfigureParameters, ModelQueryResponse modelQueryResponse) {
+        List<ZjQuoteAccidentVo> accidentalDrivingVo = quoteVo.getAccidentalDrivingVo();
         // 基本信息
         this.baseInfo = new BaseInfoDTO(quoteInfoVo.getRiskList());
         // 车主信息
@@ -122,9 +131,12 @@ public class CalculatePremiumRequest implements Serializable {
         // 投被保人信息
         this.insuredList = InsuredListDTO.toInsuredListDTOList(quoteInfoVo.getPolicyHolderInfo(), quoteInfoVo.getInsuredPersonInfo());
         // 险别信息
-        this.itemKindList = ItemKindListDTO.toItemKindListDTOList(actualValue, quoteInfoVo.getKindList(), Integer.parseInt(quoteInfoVo.getCarInfo().getSeatCount()) - 1, vehicleModelInfosDTO);
+        this.itemKindList = ItemKindListDTO.toItemKindListDTOList(actualValue, quoteInfoVo.getKindList(),
+                Integer.parseInt(quoteInfoVo.getCarInfo().getSeatCount()) - 1, vehicleModelInfosDTO);
+        // 浮动因子信息
+        this.profitDataList = ProfitDataListDTO.toCoefficient(quoteVo.getCoefficient());
         // 驾意险
-        this.carPolicySubInfoList = CarPolicySubInfoListDTO.toCarPolicySubInfoListDTO(zjQuoteAccidentVos);
+        this.carPolicySubInfoList = CarPolicySubInfoListDTO.toCarPolicySubInfoListDTO(accidentalDrivingVo);
         // 交强险
         if (!"1".equals(this.baseInfo.calculateFlag)) {
             itemKindList.add(ItemKindListDTO.getCompulsoryInsurance());
@@ -839,7 +851,7 @@ public class CalculatePremiumRequest implements Serializable {
         @JsonProperty("isInvokeJingYou")
         private String isInvokeJingYou;
         /**
-         *新能源车标志
+         * 新能源车标志
          */
         @JsonProperty("newEnergyFlag")
         private String newEnergyFlag;
@@ -902,14 +914,14 @@ public class CalculatePremiumRequest implements Serializable {
             this.oriModelName = vehicleModelInfosDTO.getModelName();
             this.vehicleStyleUniqueId = vehicleModelInfosDTO.getVehicleId();
             this.isInvokeJingYou = "1";
-            if("D6,D8,D12,".contains(vehicleModelInfosDTO.getPowerTypeCode()+",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
+            if ("D6,D8,D12,".contains(vehicleModelInfosDTO.getPowerTypeCode() + ",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
                 this.newEnergyFlag = "1";
                 this.pureRange = "";
-                if("D6".equals(vehicleModelInfosDTO.getPowerTypeCode())){
+                if ("D6".equals(vehicleModelInfosDTO.getPowerTypeCode())) {
                     this.fuelType = "1";
-                }else if("D8".equals(vehicleModelInfosDTO.getPowerTypeCode())){
+                } else if ("D8".equals(vehicleModelInfosDTO.getPowerTypeCode())) {
                     this.fuelType = "2";
-                }else {
+                } else {
                     this.fuelType = "3";
                 }
             }
@@ -1096,7 +1108,7 @@ public class CalculatePremiumRequest implements Serializable {
          * 服务次数
          */
         @JsonProperty("serviceTimes")
-        private String  serviceTimes;
+        private String serviceTimes;
 
 
         public static ItemKindListDTO getCompulsoryInsurance() {
@@ -1108,10 +1120,11 @@ public class CalculatePremiumRequest implements Serializable {
             return insuredListDTO;
         }
 
-        public static List<ItemKindListDTO> toItemKindListDTOList(String actualValue, List<KindInfoVo> kindList, int quantity, ModelQueryResponse.VehicleModelInfosDTO vehicleModelInfosDTO) {
+        public static List<ItemKindListDTO> toItemKindListDTOList(String actualValue, List<KindInfoVo> kindList, int quantity,
+                                                                  ModelQueryResponse.VehicleModelInfosDTO vehicleModelInfosDTO) {
             List<ItemKindListDTO> list = new ArrayList<>();
             String[] insuranceType = InsuranceTypeCorrespondence.getZjConnectInsuranceType();
-            if("D6,D8,D12,".contains(vehicleModelInfosDTO.getPowerTypeCode()+",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
+            if ("D6,D8,D12,".contains(vehicleModelInfosDTO.getPowerTypeCode() + ",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
                 insuranceType = InsuranceTypeCorrespondence.getZjConnectInsuranceTypeNewEnergy();
             }
             for (KindInfoVo kindInfoVo : kindList) {
@@ -1134,12 +1147,13 @@ public class CalculatePremiumRequest implements Serializable {
                 else if (ArrayUtil.indexOf(InsuranceTypeCorrespondence.getPassenger(), code) >= 0) {
                     itemKindListDTO.quantity = String.valueOf(quantity);
                     itemKindListDTO.unitAmount = String.valueOf(kindInfoVo.getUnitAmount());
-                    itemKindListDTO.amount = BigDecimal.valueOf(kindInfoVo.getUnitAmount()).multiply(BigDecimal.valueOf(quantity)).toString();
+                    itemKindListDTO.amount =
+                            BigDecimal.valueOf(kindInfoVo.getUnitAmount()).multiply(BigDecimal.valueOf(quantity)).toString();
                 }
                 // 绝对免赔
                 else if (ArrayUtil.indexOf(InsuranceTypeCorrespondence.getAbsoluteDeductible(), code) >= 0) {
                     itemKindListDTO.deductibleRate = kindInfoVo.getDeductibleRate();
-                }else if (ArrayUtil.indexOf(InsuranceTypeCorrespondence.getSpecialContractClause(), code) >= 0) {
+                } else if (ArrayUtil.indexOf(InsuranceTypeCorrespondence.getSpecialContractClause(), code) >= 0) {
                     itemKindListDTO.serviceTimes = String.valueOf(kindInfoVo.getServiceTimes());
                 } else if (InsurKind.A.getCode().equals(code)) {
                     itemKindListDTO.amount = actualValue;
@@ -1153,6 +1167,48 @@ public class CalculatePremiumRequest implements Serializable {
         }
     }
 
+    /**
+     * 浮动因子信息
+     */
+    @NoArgsConstructor
+    @Data
+    public static class ProfitDataListDTO implements Serializable {
+
+        private static final long serialVersionUID = 7236883928075142401L;
+
+        /**
+         * 费率因子代码 C31(自主定价系数)C32(传1，兼容非费改)
+         */
+        @JsonProperty("profitCode")
+        private String profitCode;
+
+        /**
+         * 费率因子值
+         */
+        @JsonProperty("profitRate")
+        private String profitRate;
+
+        public static List<ProfitDataListDTO> toCoefficient(String coefficient) {
+            if (!StringUtils.isEmpty(coefficient)) {
+                ArrayList<ProfitDataListDTO> list = new ArrayList<>();
+
+                ProfitDataListDTO profitDataListDTO1 = new ProfitDataListDTO();
+                profitDataListDTO1.setProfitCode(ProfitCode.C31.getCode());
+                profitDataListDTO1.setProfitRate(coefficient);
+                list.add(profitDataListDTO1);
+
+                ProfitDataListDTO profitDataListDTO2 = new ProfitDataListDTO();
+                profitDataListDTO2.setProfitCode(ProfitCode.C32.getCode());
+                profitDataListDTO2.setProfitRate("1");
+                list.add(profitDataListDTO2);
+
+                return list;
+            }
+            return Collections.emptyList();
+        }
+
+    }
+
     @NoArgsConstructor
     @AllArgsConstructor
     @Data

src/main/java/com/ydtech/modules/order/entity/crawler/request/CrawlerQuoteRequest.java

@@ -19,4 +19,15 @@ public class CrawlerQuoteRequest extends BaseQuoteInfoVo {
      * 驾意险信息
      */
     private Object accidentalDriving;
+
+    /**
+     * 自主定价系数
+     */
+    private String coefficient;
+
+    /**
+     * 折扣
+     */
+    private String discount;
+
 }

src/main/java/com/ydtech/modules/order/entity/vo/BaseQuoteVo.java

@@ -37,5 +37,10 @@ public class BaseQuoteVo<T> {
     @ApiModelProperty("归属机构-代客录单时需要传，选择业务员的归属机构")
     private String deptId;
 
+    @ApiModelProperty("自主定价系数")
+    private String coefficient;
+
+    @ApiModelProperty("折扣")
+    private String discount;
 
 }

src/main/java/com/ydtech/modules/order/service/impl/DaJiaOrderServiceImpl.java

@@ -197,10 +197,11 @@ public class DaJiaOrderServiceImpl implements DaJiaOrderService {
 
             String fuelType = odr1008Response.getResult().getVehicleInfo().getVehicleFuelType();
             boolean isEnergy = false;
-            if ("1,2,3,".contains(fuelType + ",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
+            if ("D6,D8,D12,".contains(fuelType + ",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
                 isEnergy = true;
             }
             //查询车辆商业起保日期
+
             InsOrders insOrders = insOrdersService.getById(quoteInfoVo.getOrderNo());
             String bxStartDate = Objects.isNull(insOrders.getSystartdate()) ?
                     insOrders.getJqstartdate() : insOrders.getSystartdate();

src/main/java/com/ydtech/modules/order/service/impl/InsCrawlerOrderServiceImpl.java

@@ -104,6 +104,11 @@ public class InsCrawlerOrderServiceImpl implements InsCrawlerOrderService {
         crawlerQuoteRequest.setUsername(ptlAgreementAttribution.getUsername());
         // 前端传入的驾意险信息
         crawlerQuoteRequest.setAccidentalDriving(t.getAccidentalDrivingVo());
+        //  自主定价系数
+        crawlerQuoteRequest.setCoefficient(t.getCoefficient());
+        //  折扣
+        crawlerQuoteRequest.setDiscount(t.getDiscount());
+
         // 发送请求
         CrawlerQuoteResponse response = insCrawlerOrderComponents.request(apiUrl, ptlAgreementAttribution.getInsCompanyId(),
                 PtlCrawlerApiType.API_2.getDesc(), crawlerQuoteRequest, CrawlerQuoteResponse.class);
@@ -323,7 +328,7 @@ public class InsCrawlerOrderServiceImpl implements InsCrawlerOrderService {
         quoteRespVo.setWarnMessageList(strings);
 
         List<String> infoList = response.getOther().getInfoList();
-        if(!ObjectUtils.isEmpty(infoList)){
+        if (!ObjectUtils.isEmpty(infoList)) {
             quoteRespVo.getWarnMessageList().addAll(infoList);
         }
         return quoteRespVo;

src/main/java/com/ydtech/modules/order/service/impl/ZijinOrderApiServiceImpl.java

@@ -141,7 +141,7 @@ public class ZijinOrderApiServiceImpl implements ZijinOrderApiService {
                 httpHeaders);
         // 4. 报价
         CalculatePremiumRequest calculatePremiumRequest = new CalculatePremiumRequest(quoteInfoVo, vehicleModelInfosDTO,
-                queryActualValueResponse.getActualValue(), quoteVo.getAccidentalDrivingVo(), zjConfigureParameters, modelQueryResponse);
+                queryActualValueResponse.getActualValue(), quoteVo, zjConfigureParameters, modelQueryResponse);
         boolean isEnergy = false;
         if ("D6,D8,D12,".contains(vehicleModelInfosDTO.getPowerTypeCode() + ",")) {//纯电动 燃料电池 插电式混合动力 归属为新能源产品
             isEnergy = true;
@@ -523,7 +523,7 @@ public class ZijinOrderApiServiceImpl implements ZijinOrderApiService {
         insAreaCompanyService.insertCompanyAndOrders(insAreaCompany);
         quoteRespVo.setCompanyId(orderNo);
         //添加调用费用匹配功能
-        feeRuleSchemeService.dealFeeOrderInfo(quoteInfoVo, quoteRespVo, ptlAgreementAttribution.getId(), insAreaCompany.getId());
+//        feeRuleSchemeService.dealFeeOrderInfo(quoteInfoVo, quoteRespVo, ptlAgreementAttribution.getId(), insAreaCompany.getId());
         return HttpResult.ok("报价成功", quoteRespVo);
     }