push

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiAppointmentServiceImpl.java

@@ -1160,6 +1160,30 @@ public class ApiAppointmentServiceImpl implements ApiAppointmentService {
             appointment.setStatus(AppointmentStatusEnum.YQX.getItemValue());
         }
         iAppointmentService.saveOrUpdate(appointment);
+
+        //取消预约-更新新单跟进状态为：取消预约
+        if (2 == request.getOprType()) {
+            //取消预约-更新新单跟进状态为取消预约
+            editFollowStatus(request.getAppointmentBizId());
+        }
+        return Result.success();
+    }
+
+    /**
+     * 取消预约-更新新单跟进状态为取消预约
+     * @return
+     */
+    public Result editFollowStatus(String appointmentBizId) {
+        List<PolicyFollow> followList = policyFollowService.queryListByAppointmentBizId(appointmentBizId);
+        if (!CollectionUtils.isEmpty(followList)) {
+            //更新当前预约ID绑定新单记录更新新单状态为取消预约。
+            followList = followList.stream().map(dto -> {
+                //取消预约
+                dto.setStatus("QX_YY");
+                return dto;
+            }).collect(Collectors.toList());
+            policyFollowService.saveOrUpdateBatch(followList);
+        }
         return Result.success();
     }
 

yd-csf-service/src/main/java/com/yd/csf/service/service/PolicyFollowService.java

@@ -88,4 +88,6 @@ public interface PolicyFollowService extends IService<PolicyFollow> {
     Page<PolicyNumberResponseVO> queryPolicyNumbers(PolicyNosQueryRequest policyNosQueryRequest);
 
     List<PolicyFollow> queryList(List<String> policyNoList);
+
+    List<PolicyFollow> queryListByAppointmentBizId(String appointmentBizId);
 }

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/PolicyFollowServiceImpl.java

@@ -859,6 +859,14 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         return list;
     }
 
+    @Override
+    public List<PolicyFollow> queryListByAppointmentBizId(String appointmentBizId) {
+        List<PolicyFollow> list = baseMapper.selectList(new LambdaQueryWrapper<PolicyFollow>()
+                .eq(StringUtils.isNotBlank(appointmentBizId), PolicyFollow::getAppointmentBizId, appointmentBizId)
+        );
+        return list;
+    }
+
     /**
      * 转换为保单号查询响应视图
      *