楚江ERP-客户开发-新增/修改时防止客户名称重复

@@ -4,13 +4,11 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
-import com.lframework.starter.bpm.dto.FlowTaskDto;
-import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
 import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.bpm.service.FlowTaskWrapperService;
-import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.utils.*;
+import com.lframework.xingyun.basedata.service.customer.CustomerService;
 import com.lframework.xingyun.sc.bo.customer.develop.CustomerDevelopPlanStatisticsBo;
 import com.lframework.xingyun.sc.entity.CustomerDevelopPlan;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
@@ -37,7 +35,6 @@ import org.springframework.stereotype.Service;
 import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.stream.Collectors;
 
 
 @Service
@@ -49,8 +46,6 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
 
 
     @Resource
-    private FlowTaskWrapperMapper flowTaskWrapperMapper;
-    @Resource
     private FlowInstanceWrapperService flowInstanceWrapperService;
     @Resource
     private FlowTaskWrapperService flowTaskWrapperService;
@@ -140,7 +135,13 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
         data.setId(id);
         // 审核中
         data.setStatus(CustomerDevelopStatus.AUDIT);
-        data.setCustomerId(vo.getCustomerId());
+        String customerId = vo.getCustomerId();
+        // 检查客户是否已存在
+        List<CustomerDevelopPlan> planList = listByCustomerId(customerId);
+        if (CollectionUtils.isNotEmpty(planList)) {
+            throw new DefaultClientException("当前客户名称已存在，请勿重复添加！");
+        }
+        data.setCustomerId(customerId);
         if (!StringUtil.isBlank(vo.getCustomerType())) {
             data.setCustomerType(vo.getCustomerType());
         }
@@ -210,6 +211,15 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
         if (!CustomerDevelopStatus.REFUSE.equals(status)) {
             throw new DefaultClientException("仅驳回状态下可编辑！");
         }
+        // 检查客户名称是否重复
+        List<CustomerDevelopPlan> planList = listByCustomerId(vo.getCustomerId());
+        if (CollectionUtils.isNotEmpty(planList)) {
+            for (CustomerDevelopPlan plan : planList) {
+                if (!vo.getId().equals(plan.getId())) {
+                    throw new DefaultClientException("当前客户名称已存在，请勿重复添加！");
+                }
+            }
+        }
         // 重新发起流程
         Instance instance = flowInstanceWrapperService.startInstance("CUSTOMER_DEVELOP", vo.getId(), BPM_FLAG, data);
 
@@ -298,4 +308,22 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
 
         return statisticsBo;
     }
+
+    /**
+     * 根据客户ID获取有效的开发计划
+     *
+     * @param customerId    客户ID
+     * @return              List<CustomerDevelopPlan>
+     */
+    @Override
+    public List<CustomerDevelopPlan> listByCustomerId(String customerId) {
+        if (StringUtils.isBlank(customerId)) {
+            return new ArrayList<>();
+        }
+        LambdaQueryWrapper<CustomerDevelopPlan> queryWrapper = Wrappers.lambdaQuery(CustomerDevelopPlan.class);
+        queryWrapper.eq(CustomerDevelopPlan::getCustomerId, customerId)
+                .ne(CustomerDevelopPlan::getStatus, CustomerDevelopStatus.CANCEL.getCode());
+
+        return getBaseMapper().selectList(queryWrapper);
+    }
 }

@@ -84,4 +84,12 @@ public interface CustomerDevelopPlanService extends BaseMpService<CustomerDevelo
      * @return  CustomerDevelopPlanStatisticsBo
      */
     CustomerDevelopPlanStatisticsBo todoTypeStatistics(QueryCustomerDevelopPlanVo vo);
+
+    /**
+     * 根据客户ID获取有效的开发计划
+     *
+     * @param customerId    客户ID
+     * @return              List<CustomerDevelopPlan>
+     */
+    List<CustomerDevelopPlan> listByCustomerId(String customerId);
 }