1

src/main/java/com/fdkankan/manage/common/ResultCode.java

@@ -106,6 +106,7 @@ public enum ResultCode  {
     RTK_USERNAME_EXIST(50082, "用户名称已存在"),
 
     RTK_USERNAME_TEMPLATE_EMPTY(50083, "批量导入数据为空或账号不存在"),
+    AGENT_HAVE_SUB(50084, "当前分销商存在下级，请删除下级后再重试"),
     ;
 
     private Integer code;

src/main/java/com/fdkankan/manage/controller/AgentNewController.java

@@ -109,6 +109,10 @@ public class AgentNewController {
         if(param.getId() == null ){
             throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
         }
+        List<AgentNew> agentNews = agentNewService.getByParentId(param.getId());
+        if(!agentNews.isEmpty()){
+            throw new BusinessException(ResultCode.AGENT_HAVE_SUB);
+        }
         agentNewService.removeById(param.getId());
         cameraDetailService.delAgentId(param.getId());
         userIncrementService.delAgentId(param.getId());

src/main/java/com/fdkankan/manage/entity/AgentNew.java

@@ -83,4 +83,6 @@ public class AgentNew implements Serializable {
     @TableField("major_use_num")
     private Integer majorUseNum;
 
+    @TableField("parent_id")
+    private Integer parentId;
 }

src/main/java/com/fdkankan/manage/service/IAgentNewService.java

@@ -9,6 +9,7 @@ import com.fdkankan.manage.vo.response.AgentVo;
 
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
+import java.util.List;
 
 /**
  * <p>
@@ -31,4 +32,6 @@ public interface IAgentNewService extends IService<AgentNew> {
     AgentNew getByName(String agentName);
 
     void checkUserName(String userName);
+
+    List<AgentNew> getByParentId(Integer id);
 }

src/main/java/com/fdkankan/manage/service/impl/AgentNewServiceImpl.java

@@ -134,6 +134,13 @@ public class AgentNewServiceImpl extends ServiceImpl<IAgentNewMapper, AgentNew>
     }
 
     @Override
+    public List<AgentNew> getByParentId(Integer id) {
+        LambdaQueryWrapper<AgentNew> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(AgentNew::getParentId,id);
+        return this.list(wrapper);
+    }
+
+    @Override
     public void export(HttpServletRequest req, HttpServletResponse resp) {
         AgentNewLogParam param = CacheUtil.agentParam;
         List<AgentNewLogVo> voList = agentNewLogService.getVoList(param);