8小时后台--

更改保全增员逻辑

src/main/java/cn/timer/api/controller/insure/CallBackContorll.java

@@ -126,9 +126,7 @@ public class CallBackContorll {
             log.info("增员核保回调参数:- {}",JSON.toJSONString(callBack));
             log.info("增员核保回调参数:- {}",JSON.toJSONString(callBack));
             if (callBack.getCallback_type().equals("1")) {
             if (callBack.getCallback_type().equals("1")) {
                 List<InsureUser> insureUserList = InsureUser.builder().build().selectList(new QueryWrapper<InsureUser>().lambda().eq(InsureUser::getTransId, callBack.getOrder_import_info().getThird_uuid()));
                 List<InsureUser> insureUserList = InsureUser.builder().build().selectList(new QueryWrapper<InsureUser>().lambda().eq(InsureUser::getTransId, callBack.getOrder_import_info().getThird_uuid()));
-                if(insureUserList.size()<=0){
-                    insureUserList = InsureUser.builder().build().selectList(new QueryWrapper<InsureUser>().lambda().eq(InsureUser::getBatchNo, callBack.getOrder_import_info().getUuid()));
-                }
+
                 InsurePolicy insurePolicy = InsurePolicy.builder().id(insureUserList.get(0).getPolicyId()).build().selectById();
                 InsurePolicy insurePolicy = InsurePolicy.builder().id(insureUserList.get(0).getPolicyId()).build().selectById();
                 if (callBack.getStatus().equals("1")) {
                 if (callBack.getStatus().equals("1")) {
                     if (insureUserList.size() > 0) {
                     if (insureUserList.size() > 0) {
@@ -141,6 +139,10 @@ public class CallBackContorll {
                         insurePolicy.updateById();
                         insurePolicy.updateById();
 
 
                     }
                     }
+                    insureUserList.stream().forEach(v->{
+                        v.setBatchNo(callBack.getOrder_import_info().getUuid());
+                        v.updateById();
+                    });
                     InsureLog.builder().type(7)
                     InsureLog.builder().type(7)
                             .requestData(sb.toString()).createTime(new Date()).requestType(1).returnBody(JSONObject.toJSONString(callBack)).requestPath(base_api_url + "/callBack/policy/addpPayCallBack")
                             .requestData(sb.toString()).createTime(new Date()).requestType(1).returnBody(JSONObject.toJSONString(callBack)).requestPath(base_api_url + "/callBack/policy/addpPayCallBack")
                             .returnCode(callBack.getStatus()).returnMsg("核保通过").policyId(insurePolicy.getId()).build().insert();
                             .returnCode(callBack.getStatus()).returnMsg("核保通过").policyId(insurePolicy.getId()).build().insert();