优化

MrShi

2025-08-19 30e858fa504b268b9b436afca0a1259cf6e8c488

 server/src/main/java/com/doumee/service/business/impl/CategoryServiceImpl.java

@@ -1,20 +1,50 @@
package com.doumee.service.business.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.doumee.core.annotation.excel.ExcelImporter;
import com.doumee.core.constants.Constants;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.CategoryMapper;
import com.doumee.dao.business.model.Category;
import com.doumee.dao.business.model.Company;
import com.doumee.dao.business.vo.CategoryDcaProblemDto;
import com.doumee.dao.business.vo.CompanyTree;
import com.doumee.dao.web.vo.CategoryMapTree;
import com.doumee.dao.web.vo.CategoryVO;
import com.doumee.dao.web.vo.CategoryVOTree;
import com.doumee.dao.business.vo.CategoryTree;
import com.doumee.dao.system.model.SystemUser;
import com.doumee.service.business.CategoryService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import io.swagger.models.auth.In;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.usermodel.CellType;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;

import java.util.List;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.Serializable;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 分类信息表Service实现
@@ -24,18 +54,67 @@
@Service
public class CategoryServiceImpl implements CategoryService {

    @Resource(name="sessionRedisTemplate")
    private RedisTemplate<Object, Serializable> redisTemplate;
    @Autowired
    private CategoryMapper categoryMapper;

    @Override
    public Integer create(Category category) {
        if(StringUtils.isBlank(category.getName())){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        if(category.getType()==null){
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "对不起，组织类型不正确，请按要求填写~");
        }
  /*      //查询名称不能重复
        if(categoryMapper.selectCount(new QueryWrapper<Category>().lambda()
                .eq(Category::getName,category.getName())
                .eq(Category::getIsdeleted,Constants.ZERO)) >0){
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "对不起，名称不能重复~");
        }*/
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        category.setIdPath(category.getId()+"/");//名称路径
        category.setNamePath(category.getName());//名称路径
        String idPath = "";
        if(category.getParentId() !=null){
            Category parent = findById(category.getParentId());
            if(parent == null || Constants.equalsInteger(parent.getIsdeleted(),Constants.ONE)){
                throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "对不起，父级信息不存在~");
            }
            if(Constants.equalsInteger(parent.getType(),Constants.FOUR) && parent.getParentId()!=null){
                //如果是二级CDA主题,自己为观察项
                category.setType(Constants.SIX);
            }
            idPath = parent.getIdPath();
            category.setIdPath(parent.getIdPath()+category.getId()+"/");
            category.setNamePath(parent.getNamePath()+"/"+category.getName());
        }
        category.setCreateDate(new Date());
        category.setCreator(user.getId());
        category.setIsdeleted(Constants.ZERO);
        category.setStatus(Constants.ZERO);
        category.setEditDate(category.getCreateDate());
        category.setEditor(category.getCreator());
        categoryMapper.insert(category);

        Category com = new Category();
        com.setId(category.getId());
        com.setIdPath(idPath+"/"+category.getId()+"/");
        categoryMapper.updateById(com);
        return category.getId();

    }

    @Override
    public void deleteById(Integer id) {
        categoryMapper.deleteById(id);
        Category model = new Category();
        model.setId(id);
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        model.setEditor(user.getId());
        model.setEditDate(new Date());
        model.setIsdeleted(Constants.ONE);
        categoryMapper.updateById(model);
    }

    @Override
@@ -49,12 +128,67 @@
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        categoryMapper.deleteBatchIds(ids);
        for(Integer id :ids){
            deleteById(id);
        }
    }

    @Override
    public void updateById(Category category) {
        categoryMapper.updateById(category);
        if( category.getId() == null){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        if(Constants.equalsInteger(category.getId(),category.getParentId())){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，父级不能设置为自身！");
        }
        category.setType(null);//类型不支持修改
        Category model = categoryMapper.selectById(category.getId());
        if(model ==null || Constants.equalsInteger(model.getIsdeleted(),Constants.ONE)) {
            throw new BusinessException(ResponseStatus.DATA_EMPTY);
        }
      /*  //查询名称不能重复
        if(categoryMapper.selectCount(new QueryWrapper<Category>().lambda()
                .eq(Category::getName,category.getName())
                .eq(Category::getType,model.getType())
                .ne(Category::getId,category.getId())
                .eq(Category::getIsdeleted,Constants.ZERO)) >0){
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "对不起，名称不能重复~");
        }*/
        String oldIdPath = model.getIdPath();
        String oldNamePath = model.getNamePath();
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        category.setIdPath(category.getId()+"/");//名称路径
        category.setNamePath(category.getName());//名称路径
        if(category.getParentId() !=null ){
            //如果父级发生改变
            Category parent = findById(category.getParentId());
            if(parent == null || Constants.equalsInteger(parent.getIsdeleted(),Constants.ONE)){
                throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "对不起，父级信息不存在~");
            }
            category.setIdPath(parent.getIdPath()+category.getId()+"/");
            category.setNamePath(parent.getNamePath()+"/"+category.getName());
        }
        category.setEditDate(new Date());
        category.setEditor(user.getId());
        categoryMapper.update(null,new UpdateWrapper<Category>().lambda()
                        .eq(Category::getId,category.getId())
                        .set(Category::getEditDate,category.getEditDate())
                        .set(Category::getEditor,category.getEditor())
                        .set(Category::getName,category.getName())
                        .set(Category::getParentId,category.getParentId())
                        .set(Category::getSortnum,category.getSortnum())
                        .set(Category::getRemark,category.getRemark())
                        .set(Category::getNamePath,category.getNamePath())
                        .set(Category::getIdPath,category.getId())
        );
        //修改全部下级的编码和名称路径
        categoryMapper.update(null,new UpdateWrapper<Category>().lambda()
                .likeRight(Category::getIdPath,oldIdPath)
                .set(Category::getEditDate,category.getEditDate())
                .set(Category::getEditor,category.getEditor())
                .setSql("id_path=replace(id_path,'"+oldIdPath+"','"+category.getIdParentPath()+"')")
                .setSql("name_path=replace(name_path,'"+oldNamePath+"/','"+category.getName()+"/')")
        );
    }

    @Override
@@ -80,17 +214,49 @@

    @Override
    public List<Category> findList(Category category) {
        QueryWrapper<Category> wrapper = new QueryWrapper<>(category);
        return categoryMapper.selectList(wrapper);
        category.setIsdeleted(Constants.ZERO);
        MPJLambdaWrapper<Category> queryWrapper = new MPJLambdaWrapper<>();
        queryWrapper.selectAll(Category.class);
        queryWrapper.selectAs(SystemUser::getUsername,Category::getEditorName);
        queryWrapper.select("t1.name",Category::getParentName);
        queryWrapper.select("t1.id_path",Category::getIdParentPath);
        queryWrapper.leftJoin(Category.class,Category::getId,Category::getParentId);
        queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,Category::getEditor);
        queryWrapper.eq(category.getId() != null, Category::getId, category.getId())
                .eq(category.getCreator() != null, Category::getCreator, category.getCreator())
                .ge(category.getCreateDate() != null, Category::getCreateDate, Utils.Date.getStart(category.getCreateDate()))
                .le(category.getCreateDate() != null, Category::getCreateDate, Utils.Date.getEnd(category.getCreateDate()))
                .eq(category.getEditor() != null, Category::getEditor, category.getEditor())
                .ge(category.getEditDate() != null, Category::getEditDate, Utils.Date.getStart(category.getEditDate()))
                .le(category.getEditDate() != null, Category::getEditDate, Utils.Date.getEnd(category.getEditDate()))
                .eq(category.getIsdeleted() != null, Category::getIsdeleted, category.getIsdeleted())
                .like(category.getName() != null, Category::getName, category.getName())
                .eq(category.getRemark() != null, Category::getRemark, category.getRemark())
                .eq(category.getStatus() != null, Category::getStatus, category.getStatus())
                .eq(category.getSortnum() != null, Category::getSortnum, category.getSortnum())
                .eq(category.getImgurl() != null, Category::getImgurl, category.getImgurl())
                .eq(category.getType() != null, Category::getType, category.getType())
                .eq(category.getParentId() != null, Category::getParentId, category.getParentId())
                .eq(category.getNamePath() != null, Category::getNamePath, category.getNamePath())
                .isNull(category.getIsRoot() != null &&category.getIsRoot().equals(Constants.ONE), Category::getParentId)
                .eq(category.getIdPath() != null, Category::getIdPath, category.getIdPath())
                .orderByAsc( Category::getSortnum);
        return categoryMapper.selectJoinList(Category.class,queryWrapper);
    }
  
    @Override
    public PageData<Category> findPage(PageWrap<Category> pageWrap) {
        IPage<Category> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<Category> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        queryWrapper.lambda()
                .eq(pageWrap.getModel().getId() != null, Category::getId, pageWrap.getModel().getId())
        pageWrap.getModel().setIsdeleted(Constants.ZERO);
        MPJLambdaWrapper<Category> queryWrapper = new MPJLambdaWrapper<>();
        queryWrapper.selectAll(Category.class);
        queryWrapper.selectAs(SystemUser::getUsername,Category::getEditorName);
        queryWrapper.select("t1.name",Category::getParentName);
        queryWrapper.select("t1.id_path",Category::getIdParentPath);
        queryWrapper.leftJoin(Category.class,Category::getId,Category::getParentId);
        queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,Category::getEditor);
        queryWrapper.eq(pageWrap.getModel().getId() != null, Category::getId, pageWrap.getModel().getId())
                .eq(pageWrap.getModel().getCreator() != null, Category::getCreator, pageWrap.getModel().getCreator())
                .ge(pageWrap.getModel().getCreateDate() != null, Category::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()))
                .le(pageWrap.getModel().getCreateDate() != null, Category::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()))
@@ -98,24 +264,18 @@
                .ge(pageWrap.getModel().getEditDate() != null, Category::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()))
                .le(pageWrap.getModel().getEditDate() != null, Category::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()))
                .eq(pageWrap.getModel().getIsdeleted() != null, Category::getIsdeleted, pageWrap.getModel().getIsdeleted())
                .eq(pageWrap.getModel().getName() != null, Category::getName, pageWrap.getModel().getName())
                .like(pageWrap.getModel().getName() != null, Category::getName, pageWrap.getModel().getName())
                .eq(pageWrap.getModel().getRemark() != null, Category::getRemark, pageWrap.getModel().getRemark())
                .eq(pageWrap.getModel().getStatus() != null, Category::getStatus, pageWrap.getModel().getStatus())
                .eq(pageWrap.getModel().getSortnum() != null, Category::getSortnum, pageWrap.getModel().getSortnum())
                .eq(pageWrap.getModel().getImgurl() != null, Category::getImgurl, pageWrap.getModel().getImgurl())
                .eq(pageWrap.getModel().getType() != null, Category::getType, pageWrap.getModel().getType())
                .eq(pageWrap.getModel().getParentId() != null, Category::getParentId, pageWrap.getModel().getParentId())
                .isNull(pageWrap.getModel().getIsRoot() != null && pageWrap.getModel().getIsRoot().equals(Constants.ONE), Category::getParentId)
                .eq(pageWrap.getModel().getNamePath() != null, Category::getNamePath, pageWrap.getModel().getNamePath())
                .eq(pageWrap.getModel().getIdPath() != null, Category::getIdPath, pageWrap.getModel().getIdPath())
        ;
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(categoryMapper.selectPage(page, queryWrapper));
                .orderByAsc( Category::getSortnum);
        return PageData.from(categoryMapper.selectJoinPage(page,Category.class, queryWrapper));
    }

    @Override
@@ -123,4 +283,594 @@
        QueryWrapper<Category> wrapper = new QueryWrapper<>(category);
        return categoryMapper.selectCount(wrapper);
    }

    @Override
    public List<Category> treeList(Category param ) {
        MPJLambdaWrapper<Category> queryWrapper = new MPJLambdaWrapper<>();
        queryWrapper.selectAll(Category.class);
        queryWrapper.selectAs(SystemUser::getUsername,Category::getEditorName);
        queryWrapper.select("t1.name",Category::getParentName);
        queryWrapper.select("t1.id_path",Category::getIdParentPath);
        queryWrapper.leftJoin(Category.class,Category::getId,Category::getParentId);
        queryWrapper.leftJoin(SystemUser.class,SystemUser::getId,Category::getEditor);
        queryWrapper.eq(Category::getIsdeleted, Constants.ZERO);
        queryWrapper.eq(Category::getType, param.getType());
        queryWrapper.orderByAsc( Category::getSortnum);
        List<Category> companyList = categoryMapper.selectJoinList(Category.class,queryWrapper);
        CategoryTree treeBuild = new CategoryTree(companyList);
        companyList = treeBuild.buildTree();
        return companyList;
    }





    @Override
    public List<CategoryVO>  getCategoryVOTree(String categoryType,Integer categoryId){
        List<Category> categoryList = categoryMapper.selectList(new QueryWrapper<Category>().lambda()
                .eq(Category::getIsdeleted, Constants.ZERO)
                .in(Objects.nonNull(categoryType),Category::getType,categoryType.split(","))
                .apply(Objects.nonNull(categoryId)," find_in_set("+categoryId+", REPLACE(ID_PATH,'/',',')  )  ")
                .orderByAsc(Category::getSortnum,Category::getId)
        );
        List<CategoryVO>  categoryVOList = new ArrayList<>();
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(categoryList)){
            for (Category category:categoryList) {
                CategoryVO categoryVO = new CategoryVO();
                categoryVO.setId(category.getId());
                categoryVO.setName(category.getName());
                categoryVO.setParentId(category.getParentId());
                categoryVOList.add(categoryVO);
            }
            CategoryVOTree treeBuild = new CategoryVOTree(categoryVOList);
            categoryVOList = treeBuild.buildTree();
        }
        return categoryVOList;
    }


    @Override
    public List<CategoryVO>  getCategoryVOForGCXTree(Integer categoryId){
        List<Category> categoryList = categoryMapper.selectList(new QueryWrapper<Category>().lambda()
                .eq(Category::getIsdeleted, Constants.ZERO)
                .eq(Category::getType, Constants.FOUR)
                .and( ms->ms.eq(Category::getId,categoryId).or().eq(Category::getParentId,categoryId))
                .orderByAsc(Category::getSortnum,Category::getId)
        );
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(categoryList)){
            categoryList.addAll(
                    categoryMapper.selectList(new QueryWrapper<Category>().lambda()
                            .eq(Category::getIsdeleted, Constants.ZERO)
                            .eq(Category::getType, Constants.SIX)
                            .in(Category::getParentId,categoryList.stream().map(i->i.getId()).collect(Collectors.toList()))
                            .orderByAsc(Category::getSortnum,Category::getId))
            );
        }
        List<CategoryVO>  categoryVOList = new ArrayList<>();
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(categoryList)){
            for (Category category:categoryList) {
                CategoryVO categoryVO = new CategoryVO();
                categoryVO.setId(category.getId());
                categoryVO.setName(category.getName());
                categoryVO.setParentId(category.getParentId());
                categoryVOList.add(categoryVO);
            }
            CategoryVOTree treeBuild = new CategoryVOTree(categoryVOList);
            categoryVOList = treeBuild.buildTree();
        }
        return categoryVOList;
    }




    @Override
    public List<CategoryVO>  getCategoryVOList(Integer categoryType,Integer isRoot){
        List<Category> categoryList = categoryMapper.selectList(new QueryWrapper<Category>().lambda()
                .eq(Category::getIsdeleted, Constants.ZERO)
                .eq(Objects.nonNull(categoryType),Category::getType,categoryType)
                .isNull(Constants.equalsInteger(isRoot,Constants.ONE),Category::getParentId)
                .orderByAsc(Category::getSortnum,Category::getId)
        );
        List<CategoryVO>  categoryVOList = new ArrayList<>();
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(categoryList)){
            for (Category category:categoryList) {
                CategoryVO categoryVO = new CategoryVO();
                categoryVO.setId(category.getId());
                categoryVO.setName(category.getName());
                categoryVO.setParentId(category.getParentId());
                categoryVOList.add(categoryVO);
            }
        }
        return categoryVOList;
    }
    public   List<Category>  findAllListForDca() {
        List<Category> categoryList = categoryMapper.selectList(new QueryWrapper<Category>().lambda()
                .eq(Category::getIsdeleted, Constants.ZERO)
                .in(Category::getType, Constants.FOUR, Constants.SIX)//主题和观察项
                .orderByAsc(Category::getSortnum)
        );
        return  categoryList;
    }
    public   List<Category>  findListForDcaTree(   List<Category> categoryList) {
        if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(categoryList)) {
            long index = 1;
            List<Category> pList = new ArrayList<>();
            for (Category category : categoryList) {
                if (category.getParentId() == null) {
                    category.setChildList(new ArrayList<>());
                    for (Category cc : categoryList) {
                        if (Constants.equalsInteger(cc.getParentId(), category.getId())) {
                            cc.setChildList(new ArrayList<>());
                            for (Category ccc : categoryList) {
                                if (Constants.equalsInteger(ccc.getParentId(), cc.getId())) {
                                    cc.getChildList().add(ccc);
                                }
                            }
                            category.getChildList().add(cc);
                        }
                    }
                    pList.add(category);
                }
            }
            return pList;
        }
        return  null;
    }
    public   List<Category>  findImportTreeForDca (  List<CategoryDcaProblemDto> categoryList,LoginUserInfo user, Date date) {
        List<Category> pList = new ArrayList<>();
        if (com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(categoryList)) {
            Integer index = 1;
            for (CategoryDcaProblemDto categoryDcaProblemDto : categoryList) {
                if(StringUtils.isBlank(categoryDcaProblemDto.getProblem())
                        &&StringUtils.isBlank(categoryDcaProblemDto.getParentName())
                        &&StringUtils.isBlank(categoryDcaProblemDto.getTypeName()) ){
                    //去空行
                    continue;
                }
                if(StringUtils.isBlank(categoryDcaProblemDto.getParentName())){
                    throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，表格第【"+(index + 1)+"】行一级主题信息不能为空，请返回检查表格信息！");
                }
                categoryDcaProblemDto.setProblem(StringUtils.defaultString(categoryDcaProblemDto.getProblem(),"").trim());
                categoryDcaProblemDto.setTypeName(StringUtils.defaultString(categoryDcaProblemDto.getTypeName(),"").trim());
                categoryDcaProblemDto.setParentName(StringUtils.defaultString(categoryDcaProblemDto.getParentName(),"").trim());
                Category first = getNewCateFromListByName(categoryDcaProblemDto.getParentName(), pList);
                if(first == null){
                    first = new Category();
                    first.setIsdeleted(Constants.ZERO);
                    first.setCreateDate(date);
                    first.setCreator(user.getId());
                    first.setIsdeleted(Constants.ZERO);
                    first.setStatus(Constants.ZERO);
                    first.setEditDate(date);
                    first.setEditor(user.getId());
                    first.setName(categoryDcaProblemDto.getParentName());
                    first.setType(Constants.FOUR);//主题
                    first.setSortnum(index++);
                    first.setChildList(new ArrayList<>());
                    pList.add(first);
                    List<Category> childList = getSecondListFromImport(first,0,categoryList);
                    first.setChildList(childList);
                }
            }
        }
        return  pList;
    }

    private List<Category> getSecondListFromImport(Category parent,int type,   List<CategoryDcaProblemDto> categoryList) {
        List<Category> pList = new ArrayList<>();
        Integer index = 1;
        for (CategoryDcaProblemDto categoryDcaProblemDto : categoryList) {
            if(type ==0 && (StringUtils.isBlank(categoryDcaProblemDto.getTypeName()) || StringUtils.isBlank(categoryDcaProblemDto.getProblem()))){
                //去空行
                continue;
            }
            if(type ==1 &&(StringUtils.isBlank(categoryDcaProblemDto.getProblem()))){
                //去空行
                continue;
            }
            if(type ==0 && StringUtils.isBlank(categoryDcaProblemDto.getTypeName())){
                throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，表格第【"+(index + 1)+"】行二级主题信息不能为空，请返回检查表格信息！");
            }
            if(type == 0 && !StringUtils.equals(categoryDcaProblemDto.getParentName(),parent.getName())){
                //只处理子级
                continue;
            }
            if(type == 1 && !StringUtils.equals(categoryDcaProblemDto.getTypeName(),parent.getName())){
                //只处理子级
                continue;
            }
            Category model = getNewCateFromListByName(type == 0 ?categoryDcaProblemDto.getTypeName():categoryDcaProblemDto.getProblem(), pList);
            if(model == null){
                model = new Category();
                model.setIsdeleted(Constants.ZERO);
                model.setCreateDate(parent.getCreateDate());
                model.setCreator(parent.getCreator());
                model.setIsdeleted(Constants.ZERO);
                model.setStatus(Constants.ZERO);
                model.setEditDate(parent.getCreateDate());
                model.setEditor(parent.getCreator());
                model.setName(type == 0 ?categoryDcaProblemDto.getTypeName():categoryDcaProblemDto.getProblem());
                model.setType(type == 0 ? Constants.FOUR:Constants.SIX);//
                model.setSortnum(index++);
                model.setChildList(new ArrayList<>());
                pList.add(model);
            }
            if(type == 0){
                //如果是二级主题处理获取子集部门
                List<Category> childList = getSecondListFromImport(model,1,categoryList);
                model.setChildList(childList);
            }
        }
        return  pList;
    }

    private Category getNewCateFromListByName(String parentName, List<Category> pList) {
        if(pList ==null){
            return  null;
        }
        for(Category cate : pList){
            if(StringUtils.equals(parentName,cate.getName())){
                    return cate;
            }
        }
        return null;
    }
    private Category getNewCateFromListByNameAndParent(String parentName,int type,boolean isRoot, List<Category> pList) {
        for(Category cate : pList){
            if(StringUtils.equals(parentName,cate.getName()) && Constants.equalsInteger(cate.getType(),type)){
                if(isRoot && cate.getParentId()==null){
                    return cate;
                }else  if(isRoot && cate.getParentId()==null){
                    return cate;
                }
            }
        }
        return null;
    }

    @Override
    public   List<CategoryDcaProblemDto>  findListForDca(Category param){
        long index =1;
        List<CategoryDcaProblemDto>  categoryVOList = new ArrayList<>();
        List<Category> pList = findListForDcaTree( findAllListForDca());
        for (Category category:pList) {
            if(category.getChildList().size() ==0){
                CategoryDcaProblemDto categoryVO = new CategoryDcaProblemDto();
                categoryVO.setIndex(index);
                categoryVO.setParentName(category.getName());
                index++;
                categoryVOList.add(categoryVO);
            }else{
                for (Category cc:category.getChildList()) {
                    if(cc.getChildList().size() ==0){
                        CategoryDcaProblemDto categoryVO = new CategoryDcaProblemDto();
                        categoryVO.setIndex(index);
                        categoryVO.setParentName(category.getName());
                        categoryVO.setTypeName(cc.getName());
                        index++;
                        categoryVOList.add(categoryVO);
                    }else{
                        for (Category ccc:cc.getChildList()) {
                            CategoryDcaProblemDto categoryVO = new CategoryDcaProblemDto();
                            categoryVO.setIndex(index);
                            categoryVO.setParentName(category.getName());
                            categoryVO.setTypeName(cc.getName());
                            categoryVO.setProblem(ccc.getName());
                            index++;
                            categoryVOList.add(categoryVO);

                        }
                    }
                }
            }
        }
        return categoryVOList;
    }


    @Override
    @PostConstruct
    public String initRedis(){
        redisTemplate.delete(Constants.RedisKeys.IMPORTING_CATEGORY);
        return  "";
    }
    @Override
    @Transactional(rollbackFor = {BusinessException.class,Exception.class})
    public String importDcaBatch(MultipartFile file){
        Boolean importing = (Boolean) redisTemplate.opsForValue().get(Constants.RedisKeys.IMPORTING_CATEGORY);
        if(importing!=null && importing){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，已存在员工导入任务正在执行中，请稍后再试！");
        }
        redisTemplate.opsForValue().set(Constants.RedisKeys.IMPORTING_CATEGORY,true);
        try {
            ExcelImporter ie = null;
            List<CategoryDcaProblemDto> dataList =null;
            try {
                ie = new ExcelImporter(file,0,0, CellType.STRING); // 确保单元格类型为字符串);
                dataList = ie.getDataList(CategoryDcaProblemDto.class,null);
            }  catch (Exception e) {
                e.printStackTrace();
            }
            if(dataList == null || dataList.size() ==0){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，录入数据为空！");
            }
            Date date = new Date();
            LoginUserInfo user = (LoginUserInfo)SecurityUtils.getSubject().getPrincipal();
            List<Category> treeImportList =   findImportTreeForDca(dataList,user,date);//查询现有的全部主题观察项数据
            if(treeImportList == null || treeImportList.size() ==0){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，录入的有效数据为空！");
            }
            //查询现有的全部主题观察项数据
            List<Category> list = categoryMapper.selectJoinList(Category.class,new MPJLambdaWrapper<Category>()
                             .selectAll(Category.class)
//                             .select("t1.name",Category::getParentName)
//                             .select("t2.name",Category::getRootName)
//                             .leftJoin(Category.class,Category::getId,Category::getParentId)
//                             .leftJoin( "category t2 on t1.parent_id=t2.id")
                            .eq(Category::getIsdeleted, Constants.ZERO)
                            .in(Category::getType, Constants.FOUR, Constants.SIX)//主题和观察项
                            .orderByAsc(Category::getSortnum)
            ) ;
            List<Category> treeList =   findListForDcaTree(list);//查询现有的全部主题观察项数据
            List<Integer> allUpdateIds = new ArrayList<>();
            dealImportNewOrUpdateBiz(treeList,treeImportList,allUpdateIds);
            dealDeletedList(list,allUpdateIds,user,date);//处理删除的数据信息
            dealTreePathInfo(treeImportList);
            return "导入成功";
        }catch (BusinessException e){
            throw e;
        }catch (Exception e){
            throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"员工信息导入失败，请稍后重试");
        }finally {
            redisTemplate.delete(Constants.RedisKeys.IMPORTING_CATEGORY);
        }
    }

    private void dealImportNewOrUpdateBiz(List<Category> treeList, List<Category> treeImportList, List<Integer> allUpdateIds) {
        List<Category> newList = new ArrayList<>();
        List<Category> updateList = new ArrayList<>();
        for(Category tmodel :treeImportList){

            //处理一级主题增改逻辑
            //查询是否存在名称相同的一级主题，存在则更新，不存在则新增
            Category first = getNewCateFromListByName(tmodel.getName(),treeList);
            if(first!=null){
                tmodel.setId(first.getId());
                tmodel.setChildMatchList(first.getChildList());
                allUpdateIds.add(first.getId());
                updateList.add(tmodel);
            }else{
                newList.add(tmodel);
            }
        }

        //先批量处理一级主题的增改数据，刷新一级主题对象的编码
        if(newList.size() >0){
            categoryMapper.insert(newList);
        }
        if( updateList.size() >0){
            for(Category update :updateList){
                categoryMapper.updateById(update);
            }
        }
        dealSecChildList(newList,updateList,allUpdateIds,1);//处理二级数据
    }

    private void dealDeletedList(List<Category> list, List<Integer> allUpdateIds, LoginUserInfo user, Date date) {
        List<Integer> deleteList = new ArrayList<>();
        for(Category cate : list){
            for(Integer nowId : allUpdateIds){
                if(Constants.equalsInteger(cate.getId(),nowId)){
                    continue;
                }
                deleteList.add(cate.getId());
            }
        }
        if(deleteList.size() >0){
            //删除不存在的
            categoryMapper.update(null,new UpdateWrapper<Category>().lambda()
                    .set(Category::getIsdeleted,Constants.ONE)
                    .set(Category::getEditor,user.getId())
                    .set(Category::getEditDate,date)
                    .in(Category::getId,deleteList));
        }
    }

    private void dealSecChildList(List<Category> newList, List<Category> updateList,List<Integer> allUpdateIds,int level) {
        List<Category> childNewList = new ArrayList<>();
        List<Category> childUpdateList = new ArrayList<>();
        if(newList.size() >0 || updateList.size()>0) {
            for(Category c : newList){
                if(c.getChildList()!=null && c.getChildList().size()>0){
                    for(Category sec : c.getChildList()){
                        sec.setParentId(c.getId());
                    }
                    childNewList.addAll(c.getChildList());
                }
            }
            for(Category c : updateList){
                if(c.getChildList()!=null && c.getChildList().size()>0){
                    List<Category> tList = c.getChildMatchList();
                    for(Category sec : c.getChildList()){
                        sec.setParentId(c.getId());
                        Category mmodel = getNewCateFromListByName(sec.getName(),tList);
                        if(mmodel!=null){
                            sec.setId(mmodel.getId());
                            sec.setChildMatchList(mmodel.getChildList());
                            allUpdateIds.add(mmodel.getId());
                            childUpdateList.add(sec);
                        }else{
                            childNewList.add(sec);
                        }
                    }
                }
            }
        }
        if(childNewList.size() >0){
            categoryMapper.insert(childNewList);
        }
        if( childUpdateList.size() >0){
            for(Category update :childUpdateList){
                categoryMapper.updateById(update);
            }
        }
        if(level == 1){
            dealSecChildList(childNewList,childUpdateList,allUpdateIds,2);//处理三级级数据
        }
    }
    private void dealTreePathInfo(List<Category> tree) {
        if(tree!=null || tree.size()>0){
            for(Category t : tree){
                t.setIdPath(t.getId()+"/");
                t.setNamePath(t.getName());
                categoryMapper.updateById(t);
                dealChildParentId(t,t.getChildList());
            }
        }
    }

    private void dealChildParentId(Category t, List<Category> childList) {
        if(childList ==null || childList.size()==0){
            return;
        }
        for(Category c : childList){
            c.setParentId(t.getId());
            c.setIdPath(t.getIdPath()+c.getId()+"/");
            c.setNamePath(t.getNamePath()+"/"+c.getName());
            categoryMapper.updateById(c);
            if(t.getChildList()!=null || t.getChildList().size()==0){
                //递归处理子集
                dealChildParentId(c,c.getChildList());
            }
        }
    }



    @Override
    public void dealjson(){
        String json = "";
        BufferedReader reader = null;
        try {
            reader = new BufferedReader(new FileReader("d://file.txt"));
            String line;
            while ((line = reader.readLine()) != null) {
                json = json + line;
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (reader != null){
                    reader.close();
                };
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        JSONObject jsonObject = JSONObject.parseObject(json);
        JSONArray jsonArray = jsonObject.getJSONArray("data");

        List<Map<String,Object>> mapList = new ArrayList<>();
        for (int i = 0; i < jsonArray.size(); i++) {
            JSONObject jsons = jsonArray.getJSONObject(i);
            Map<String,Object> map = new HashMap<>();
            map.put("id",jsons.getString("id"));
            map.put("level",jsons.getInteger("level"));
            map.put("name",jsons.getString("name"));
            map.put("parentId",jsons.getString("parentId"));
            mapList.add(map);
        }
        CategoryMapTree categoryMapTree = new CategoryMapTree(mapList);
        mapList = categoryMapTree.buildTree();

        for (Map<String,Object> map:mapList) {
            Category category = new Category();
            category.setCreateDate(new Date());
            category.setIsdeleted(Constants.ZERO);
            category.setStatus(Constants.ZERO);
            category.setType(Constants.SIX);
            category.setName(map.get("name").toString());
            category.setNamePath(map.get("name").toString());
            categoryMapper.insert(category);
            if(Objects.nonNull(map.get("childTree"))){
                List<Map<String,Object>> childOneMap = (List<Map<String, Object>>) map.get("childTree");
                for (Map<String,Object> oneMap:childOneMap) {
                    Category oneCategory = new Category();
                    oneCategory.setCreateDate(new Date());
                    oneCategory.setIsdeleted(Constants.ZERO);
                    oneCategory.setStatus(Constants.ZERO);
                    oneCategory.setType(Constants.SIX);
                    oneCategory.setName(oneMap.get("name").toString());
                    oneCategory.setNamePath(category.getNamePath()+"/"+oneCategory.getName());
                    oneCategory.setParentId(category.getId());
                    categoryMapper.insert(oneCategory);

                    if(Objects.nonNull(oneMap.get("childTree"))){
                        List<Map<String,Object>> childTwoMap = (List<Map<String, Object>>) oneMap.get("childTree");
                        for (Map<String,Object> twoMap:childTwoMap) {
                            Category twoCategory = new Category();
                            twoCategory.setCreateDate(new Date());
                            twoCategory.setIsdeleted(Constants.ZERO);
                            twoCategory.setStatus(Constants.ZERO);
                            twoCategory.setType(Constants.SIX);
                            twoCategory.setName(twoMap.get("name").toString());
                            twoCategory.setNamePath(oneCategory.getNamePath() + "/" + twoCategory.getName());
                            twoCategory.setParentId(oneCategory.getId());
                            categoryMapper.insert(twoCategory);
                        }
                    }
                }






            }

        }




//        for (int i = 0; i < jsonArray.size(); i++) {
//            JSONObject  jsonObject1 = jsonArray.getJSONObject(i);
//            if(Constants.equalsInteger(jsonObject1.getInteger("level"),Constants.ONE)){
//                Boolean iHavaChild = false;
//                for (int k = 0; i < jsonArray.size(); i++) {
//                    JSONObject  jsonObject2 = jsonArray.getJSONObject(k);
//
//                    Boolean kHavaChild = false;
//                    if(Constants.equalsInteger(jsonObject2.getInteger("level"),Constants.TWO)
//                            &&jsonObject2.getString("parentId").equals(jsonObject1.getString("id"))){
//                        iHavaChild = true;
//
//                        for (int g = 0; i < jsonArray.size(); i++) {
//                            JSONObject jsonObject3 = jsonArray.getJSONObject(g);
//                            if(Constants.equalsInteger(jsonObject3.getInteger("level"),Constants.THREE)
//                                    &&jsonObject3.getString("parentId").equals(jsonObject2.getString("id"))) {
//                                kHavaChild = true;
//
//                                System.out.println(j.getString("id")+"---"+j.getString("name").replace("\n","")+"---"+j.getInteger("level")+"---"+j.getString("parentId"));
//                            }
//                        }
//
//                    }
//                }
//                if(!iHavaChild){
//
//                }
//            }
//
//
////            System.out.println(j.getString("id")+"---"+j.getString("name").replace("\n","")+"---"+j.getInteger("level")+"---"+j.getString("parentId"));
//        }



    }

}