Sfoglia il codice sorgente

1. 永诚优化部分代码1

ligang134 2 anni fa
parent
commit
b24dcc1026

+ 22 - 12
src/main/java/com/ydtech/modules/ins/controller/InsAlltrustApiController.java

@@ -170,20 +170,30 @@ public class InsAlltrustApiController {
     }
 
 
+//    /**
+//     * 获取地区 通过身份证地址
+//     */
+//    @ApiOperation(value = "永诚API方式 - 身份证地址获取地区")
+//    @PostMapping("/addressGainArea")
+//    public HttpResult syncAccidentInsure(String address) {
+//        Map<String, String> ownerMap = insYongchengApiService.gainRegionCode(address);
+//
+//        if (null == ownerMap) {
+//            throw new SystemException("地区获取失败,请检查参数是否正确。");
+//
+//        }
+//
+//        return HttpResult.ok(ownerMap);
+//    }
+
     /**
-     * 获取地区 通过身份证地址
+     * 手动补传回调
      */
-    @ApiOperation(value = "永诚API方式 - 身份证地址获取地区")
-    @PostMapping("/addressGainArea")
-    public HttpResult syncAccidentInsure(String address) {
-        Map<String, String> ownerMap = insYongchengApiService.gainRegionCode(address);
-
-        if (null == ownerMap) {
-            throw new SystemException("地区获取失败,请检查参数是否正确。");
-
-        }
-
-        return HttpResult.ok(ownerMap);
+    @ApiOperation(value = "永诚API方式 - 同步保司订单状态")
+    @GetMapping("/syncInsOrderStatus")
+    public HttpResult syncInsOrderStatus() {
+        insYongchengApiService.callbackAnOrder();
+        return HttpResult.ok();
     }
 
 

+ 2 - 1
src/main/java/com/ydtech/modules/ins/model/vo/RiskInfoVo.java

@@ -23,6 +23,7 @@ public class RiskInfoVo {
     @CheckDateTime(message = "起保日期的正确格式为yyyy-MM-dd HH:mm:ss")
     private String endDate;
 
+    //注释添加 是否即使起保 1:是即使  空为否   lig 2023-10-07
     private String instantFlag;
 
     public double getAmount() {
@@ -72,4 +73,4 @@ public class RiskInfoVo {
     public void setInstantFlag(String instantFlag) {
         this.instantFlag = instantFlag;
     }
-}
+}

+ 10 - 9
src/main/java/com/ydtech/modules/ins/model/yc/YcBuildData.java

@@ -283,19 +283,20 @@ public class YcBuildData {
 
 
         //交强险出险字符串
-        StringBuffer ciSB = new StringBuffer("交强险-");
+        StringBuffer ciSB = new StringBuffer("交强险-【无法获取】");
         //商业险出险字符串
-        StringBuffer biSB = new StringBuffer("商业险-");
-        if (null != rd.getVehicleAdjust()) {
-            //交强险过往出险记录
-            String jQRecordDanger = StringUtils.toString(rd.getVehicleAdjust().getJQRecordDanger(),"");
-            ciSB.append("交强险过往出险记录:");
-            ciSB.append(jQRecordDanger);
-        }
+        StringBuffer biSB = new StringBuffer();
+//        if (null != rd.getVehicleAdjust()) {
+//            //交强险过往出险记录
+//            String jQRecordDanger = StringUtils.toString(rd.getVehicleAdjust().getJQRecordDanger(),"");
+//            ciSB.append("交强险过往出险记录:");
+//            ciSB.append(jQRecordDanger);
+//        }
 
         if (null != rd.getPrmCoef()) {
             //商业险   连续承保期间出险次数
             int nClaimTimes = StringUtils.toInt(rd.getPrmCoef().getNClaimTimes());
+            biSB.append(",商业险-");
             biSB.append("连续承保期间出险次数:");
             biSB.append(nClaimTimes);
 
@@ -305,7 +306,7 @@ public class YcBuildData {
         }
 
         //出险信息
-        quoteRespVo.setAccidentInfoStr(String.format("%s , %s", ciSB.toString(), biSB.toString()));
+        quoteRespVo.setAccidentInfoStr(String.format("%s%s", ciSB.toString(), biSB.toString()));
 
         //平台返回信息
         if (null != rd.getTfiWarnList()) {

+ 0 - 3
src/main/java/com/ydtech/modules/ins/model/yc/ruote/Ruote.java

@@ -156,8 +156,6 @@ public class Ruote {
      * @date: 2023年02月08日 0008
      */
     public static Ruote buildQuoteParam(YaQuoteInfoVo yaQuoteInfoVo, YcConfigureParameters ycConfigureParameters, InsAlltrustRequestApiComponents apiComponents, AccidentalDrivingVo adVo) {
-//    public static Ruote buildQuoteParam(YaQuoteInfoVo yaQuoteInfoVo, AuthorityDataXml authorityDataXml, Agent agent, InsAlltrustRequestApiComponents apiComponents, AccidentalDrivingVo adVo) {
-//    public static Ruote buildQuoteParam(YaQuoteInfoVo yaQuoteInfoVo, AuthorityDataXml authorityDataXml,Agent agent) {
 
         Ruote m = new Ruote();
         Ruote.RequestLabel requestLabel = new Ruote.RequestLabel();
@@ -177,7 +175,6 @@ public class Ruote {
 
 
 
-
         /**
          * 基本信息 base
          */

+ 19 - 19
src/main/java/com/ydtech/modules/ins/scheduler/InsOrderScheduler.java

@@ -46,25 +46,25 @@ public class InsOrderScheduler {
 
 
 
-//    /**
-//     * 永诚定时任务
-//     * 补传回调
-//     * 每隔300秒执行
-//     * fixedRate / 1000  = 秒
-//     *
-//     * #:0 0/5 7,22 * * ?  7点到22点 每隔5分钟执行
-//     *
-//     */
-////    @Scheduled(fixedRate = 300000)
-////    @Scheduled(cron = "0 0/5 7,22 * * ? ")
-//    @Scheduled(cron = "0 0/5 * * * ?")
-//    public void alltrustCallbackTask() {
-////        logger.info("【定时任务执行 - 永城 - 补传回调】开始时间:" + dateFormat.format(new Date()) + "");
-//
-//        insYongchengApiService.callbackAnOrder();
-//
-////        logger.info("【定时任务执行 - 永城 - 补传回调】结束时间:" + dateFormat.format(new Date())+ "" );
-//    }
+    /**
+     * 永诚定时任务
+     * 补传回调
+     * 每隔300秒执行
+     * fixedRate / 1000  = 秒
+     *
+     * #:0 0/5 7,22 * * ?  7点到22点 每隔5分钟执行
+     *
+     */
+//    @Scheduled(fixedRate = 300000)
+//    @Scheduled(cron = "0 0/5 7,22 * * ? ")
+    @Scheduled(cron = "0 0/5 * * * ?")
+    public void alltrustCallbackTask() {
+//        logger.info("【定时任务执行 - 永城 - 补传回调】开始时间:" + dateFormat.format(new Date()) + "");
+
+        insYongchengApiService.callbackAnOrder();
+
+//        logger.info("【定时任务执行 - 永城 - 补传回调】结束时间:" + dateFormat.format(new Date())+ "" );
+    }
 
 
     /**

+ 7 - 7
src/main/java/com/ydtech/modules/ins/service/InsAlltrustApiService.java

@@ -99,13 +99,13 @@ public interface InsAlltrustApiService {
     HttpResult getPolicyPrintApi(PolicyPrintVo policyPrintVo);
 
 
-    /**
-     * 获取地区编码   通过身份证地址
-     *
-     * @author: lig
-     * @date: 2023年04月12日 0012
-     */
-    Map<String, String> gainRegionCode(String address);
+//    /**
+//     * 获取地区编码   通过身份证地址
+//     *
+//     * @author: lig
+//     * @date: 2023年04月12日 0012
+//     */
+//    Map<String, String> gainRegionCode(String address);
 
 
 //

+ 44 - 44
src/main/java/com/ydtech/modules/ins/service/impl/InsAlltrustApiServiceImpl.java

@@ -1690,51 +1690,51 @@ public class InsAlltrustApiServiceImpl implements InsAlltrustApiService {
     }
 
 
-    @Override
-    public Map<String, String> gainRegionCode(String address) {
-
-        log.debug("*********永诚API方式 - 身份证地址解析 参数:" + address);
-        Map<String, String> m = IDCardUtils.addressResolution(address);
-        if (null == m) return null;
-        String city = m.get("city");
-        String district = m.get("district");
-//        if(StringUtils.isNullOrEmpty(district)){
-//            //第二级赋值到第三级
-//            district = city;
+//    @Override
+//    public Map<String, String> gainRegionCode(String address) {
+//
+//        log.debug("*********永诚API方式 - 身份证地址解析 参数:" + address);
+//        Map<String, String> m = IDCardUtils.addressResolution(address);
+//        if (null == m) return null;
+//        String city = m.get("city");
+//        String district = m.get("district");
+////        if(StringUtils.isNullOrEmpty(district)){
+////            //第二级赋值到第三级
+////            district = city;
+////        }
+//
+//        List<InsAlltrustRegion> areaList = new ArrayList<>();
+//        if (StringUtils.isNotEmpty(district)) {
+//            //查询地区
+//            LambdaQueryWrapper<InsAlltrustRegion> lqw = new LambdaQueryWrapper<>();
+//            lqw.eq(InsAlltrustRegion::getArea, district);
+//            areaList = insAlltrustRegionMapper.selectList(lqw);
 //        }
-
-        List<InsAlltrustRegion> areaList = new ArrayList<>();
-        if (StringUtils.isNotEmpty(district)) {
-            //查询地区
-            LambdaQueryWrapper<InsAlltrustRegion> lqw = new LambdaQueryWrapper<>();
-            lqw.eq(InsAlltrustRegion::getArea, district);
-            areaList = insAlltrustRegionMapper.selectList(lqw);
-        }
-
-
-        //如果地区查不到 用城市当地区查
-        if (null == areaList || areaList.size() < 1) {
-            LambdaQueryWrapper<InsAlltrustRegion> cityLqw = new LambdaQueryWrapper<>();
-            cityLqw.eq(InsAlltrustRegion::getArea, city);
-            areaList = insAlltrustRegionMapper.selectList(cityLqw);
-        }
-        //如果地区查不到 用城市当地区查
-        if (null == areaList || areaList.size() < 1) {
-            LambdaQueryWrapper<InsAlltrustRegion> cityLqw = new LambdaQueryWrapper<>();
-            cityLqw.eq(InsAlltrustRegion::getArea, city);
-            areaList = insAlltrustRegionMapper.selectList(cityLqw);
-        }
-
-
-        if (null != areaList && areaList.size() > 0) {
-            Map rMap = new HashMap();
-            rMap.put("provinceCode", areaList.get(0).getProvinceCode());
-            rMap.put("cityCode", areaList.get(0).getCityCode());
-            rMap.put("areaCode", areaList.get(0).getAreaCode());
-            return rMap;
-        }
-        return null;
-    }
+//
+//
+//        //如果地区查不到 用城市当地区查
+//        if (null == areaList || areaList.size() < 1) {
+//            LambdaQueryWrapper<InsAlltrustRegion> cityLqw = new LambdaQueryWrapper<>();
+//            cityLqw.eq(InsAlltrustRegion::getArea, city);
+//            areaList = insAlltrustRegionMapper.selectList(cityLqw);
+//        }
+//        //如果地区查不到 用城市当地区查
+//        if (null == areaList || areaList.size() < 1) {
+//            LambdaQueryWrapper<InsAlltrustRegion> cityLqw = new LambdaQueryWrapper<>();
+//            cityLqw.eq(InsAlltrustRegion::getArea, city);
+//            areaList = insAlltrustRegionMapper.selectList(cityLqw);
+//        }
+//
+//
+//        if (null != areaList && areaList.size() > 0) {
+//            Map rMap = new HashMap();
+//            rMap.put("provinceCode", areaList.get(0).getProvinceCode());
+//            rMap.put("cityCode", areaList.get(0).getCityCode());
+//            rMap.put("areaCode", areaList.get(0).getAreaCode());
+//            return rMap;
+//        }
+//        return null;
+//    }
 
 
     private void buildRegion(Ruote m, BaseQuoteInfoVo yaQuoteInfoVo) {

+ 72 - 70
src/main/java/com/ydtech/utils/HttpXmlUtil.java

@@ -41,7 +41,7 @@ public class HttpXmlUtil {
     public static String sendPost(String url, String xmlString) {
         System.out.println("请求参数=" + xmlString);
         System.out.println("请求参数=" + XMLFormat.format(xmlString));
-        Response response;
+        Response response = null;
         String responseString = null;
         try {
 
@@ -66,6 +66,8 @@ public class HttpXmlUtil {
             }
         } catch (Exception e) {
             e.printStackTrace();
+        } finally {
+            response.close();
         }
 
         System.out.println("返回参数=" + responseString);
@@ -89,77 +91,77 @@ public class HttpXmlUtil {
     }
 
 
-    /**
-     * 发送xml请求到server端
-     *
-     * @param url       xml请求数据地址
-     * @param xmlString 发送的xml数据流
-     * @return map   key:requestData  key:responseData
-     */
-    public static InsApiLog sendXmlPost(String url, String xmlString) {
-
-        System.out.println("请求参数=" + xmlString);
-        log.debug("XML请求url:{},请求参数:{}", url, xmlString);
-        InsApiLog lon = new InsApiLog();
-
-        lon.setUrl(url);
-        lon.setRequestData(xmlString);
-        Response response = null;
-        String responseString = null;
-        try {
-
-            OkHttpClient client = new OkHttpClient.Builder()
-                    .connectTimeout(60, TimeUnit.SECONDS)
-                    .writeTimeout(60, TimeUnit.SECONDS)
-                    .readTimeout(60, TimeUnit.SECONDS)
-                    .build();
-
-            MediaType mediaType = MediaType.parse("text/xml");
-            RequestBody body = RequestBody.create(mediaType, xmlString);
-            Request request = new Request.Builder()
-                    .url(url)
-                    .post(body)
-                    .addHeader("Content-Type", "text/xml")
-                    .addHeader("cache-control", "no-cache")
-                    .build();
-
-            response = client.newCall(request).execute();
-            if (response.isSuccessful()) {
-                responseString = response.body().string();
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-            lon.setExceptionMsg(e.getMessage());
-            return lon;
-        } finally {
-            System.out.println("返回参数=" + responseString);
-            response.close();
-            log.debug("XML返回url:{},响应参数:{}", url, responseString);
-        }
-
-
-        String[] patterns = new String[]{
-                // This will remove empty elements that look like <ElementName/>
-                "\\s*<\\w+/>",
-                // This will remove empty elements that look like <ElementName></ElementName>
-                "\\s*<\\w+></\\w+>",
-                // This will remove empty elements that look like
-                // <ElementName>
-                // </ElementName>
-                "\\s*<\\w+>\n*\\s*</\\w+>"
-        };
-        for (String pattern : patterns) {
-            Matcher matcher = Pattern.compile(pattern).matcher(responseString);
-            responseString = matcher.replaceAll("");
-        }
+//    /**
+//     * 发送xml请求到server端
+//     *
+//     * @param url       xml请求数据地址
+//     * @param xmlString 发送的xml数据流
+//     * @return map   key:requestData  key:responseData
+//     */
+//    public static InsApiLog sendXmlPost(String url, String xmlString) {
+//
+//        System.out.println("请求参数=" + xmlString);
+//        log.debug("XML请求url:{},请求参数:{}", url, xmlString);
+//        InsApiLog lon = new InsApiLog();
+//
+//        lon.setUrl(url);
+//        lon.setRequestData(xmlString);
+//        Response response = null;
+//        String responseString = null;
+//        try {
+//
+//            OkHttpClient client = new OkHttpClient.Builder()
+//                    .connectTimeout(60, TimeUnit.SECONDS)
+//                    .writeTimeout(60, TimeUnit.SECONDS)
+//                    .readTimeout(60, TimeUnit.SECONDS)
+//                    .build();
+//
+//            MediaType mediaType = MediaType.parse("text/xml");
+//            RequestBody body = RequestBody.create(mediaType, xmlString);
+//            Request request = new Request.Builder()
+//                    .url(url)
+//                    .post(body)
+//                    .addHeader("Content-Type", "text/xml")
+//                    .addHeader("cache-control", "no-cache")
+//                    .build();
+//
+//            response = client.newCall(request).execute();
+//            if (response.isSuccessful()) {
+//                responseString = response.body().string();
+//            }
+//        } catch (Exception e) {
+//            e.printStackTrace();
+//            lon.setExceptionMsg(e.getMessage());
+//            return lon;
+//        } finally {
+//            System.out.println("返回参数=" + responseString);
+//            response.close();
+//            log.debug("XML返回url:{},响应参数:{}", url, responseString);
+//        }
+//
+//
+//        String[] patterns = new String[]{
+//                // This will remove empty elements that look like <ElementName/>
+//                "\\s*<\\w+/>",
+//                // This will remove empty elements that look like <ElementName></ElementName>
+//                "\\s*<\\w+></\\w+>",
+//                // This will remove empty elements that look like
+//                // <ElementName>
+//                // </ElementName>
+//                "\\s*<\\w+>\n*\\s*</\\w+>"
+//        };
+//        for (String pattern : patterns) {
+//            Matcher matcher = Pattern.compile(pattern).matcher(responseString);
+//            responseString = matcher.replaceAll("");
+//        }
+//
+//        lon.setResponseData(responseString);
+//        return lon;
+//    }
 
-//        System.out.println("返回参数==" + responseString);
-        lon.setResponseData(responseString);
-        return lon;
-    }
 
     /**
-     * 发送xml请求到server端
+     * 发送xml请求到server端  最新
      *
      * @param url       xml请求数据地址
      * @param xmlString 发送的xml数据流
@@ -199,7 +201,7 @@ public class HttpXmlUtil {
             log.error(textHead + "请求异常:"+e.getMessage() + ",原始返回:" + response);
             throw new SystemException("远程接口请求失败,请联系管理员。");
         } finally {
-            if(null != log) log.debug(textHead + "XML返回url:{},\n响应参数:{}", url, responseString);
+            if(null != log) log.debug(textHead + "XML返回url:{},\n响应参数:{}", url, responseString.replaceAll("\n",""));
             response.close();
         }