事件分类修改

esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/redis/RedisKeys.java

@@ -124,6 +124,13 @@ public class RedisKeys {
      * @date 2019/11/28 09:56
      */
     public static String getAdminUserDeptOptionKey(Long userId) {
-        return rootPrefix.concat("sys:user:dept:options:").concat(String.valueOf(userId));
+        return rootPrefix.concat("options:dept:user:").concat(String.valueOf(userId));
+    }
+
+    /**
+     * 事件分类
+     */
+    public static String getEventsCategoryKey() {
+        return rootPrefix.concat("options:category:events");
     }
 }

esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/category/CategoryOption.java

@@ -0,0 +1,15 @@
+package com.elink.esua.epdc.dto.category;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Description 事件类别树
+ * @Author yinzuomei
+ * @Date 2019/12/3 18:03
+ */
+@Data
+public class CategoryOption<T> {
+	private List<T> options;
+}

esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/dto/category/CategoryTreeDTO.java

@@ -0,0 +1,37 @@
+package com.elink.esua.epdc.dto.category;
+
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Description
+ * @Author yinzuomei
+ * @Date 2019/12/3 14:34
+ */
+@Data
+public class CategoryTreeDTO implements Serializable {
+
+	private static final long serialVersionUID = 8751086975269527708L;
+	/**
+	 * id
+	 */
+	private Long id;
+	/**
+	 * 上级分类ID
+	 */
+	private Long pid;
+
+	/**
+	 * 分类名称
+	 */
+	private String categoryName;
+
+	private String value;
+
+	private String label;
+
+	private List<CategoryTreeDTO> children;
+}

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/category/controller/CategoryController.java

@@ -26,6 +26,7 @@ import com.elink.esua.epdc.commons.tools.validator.group.AddGroup;
 import com.elink.esua.epdc.commons.tools.validator.group.UpdateGroup;
 import com.elink.esua.epdc.commons.tools.validator.group.DefaultGroup;
 import com.elink.esua.epdc.dto.category.CategoryDTO;
+import com.elink.esua.epdc.dto.category.CategoryOption;
 import com.elink.esua.epdc.modules.category.excel.CategoryExcel;
 import com.elink.esua.epdc.modules.category.service.CategoryService;
 import io.swagger.annotations.ApiOperation;
@@ -102,4 +103,28 @@ public class CategoryController {
         return  categoryService.insertPartyList(file);
     }
 
+    /**
+     * @param
+     * @return com.elink.esua.epdc.commons.tools.utils.Result
+     * @Author yinzuomei
+     * @Description 组装事件类别
+     * @Date 2019/12/3 18:19
+     **/
+    @GetMapping("packageCategoryOption")
+    public Result packageCategoryOption() {
+        categoryService.packageCategoryOption();
+        return new Result();
+    }
+
+    /**
+     * @param
+     * @return com.elink.esua.epdc.commons.tools.utils.Result<com.elink.esua.epdc.dto.category.CategoryOption>
+     * @Author yinzuomei
+     * @Description 查询事件类别树, 供下拉框调用
+     * @Date 2019/12/3 18:07
+     **/
+    @GetMapping("getCategoryTree")
+    public Result<CategoryOption> getCategoryTree() {
+        return categoryService.getCategoryTree();
+    }
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/category/dao/CategoryDao.java

@@ -18,6 +18,7 @@
 package com.elink.esua.epdc.modules.category.dao;
 
 import com.elink.esua.epdc.commons.mybatis.dao.BaseDao;
+import com.elink.esua.epdc.dto.category.CategoryTreeDTO;
 import com.elink.esua.epdc.modules.category.entity.CategoryEntity;
 import org.apache.ibatis.annotations.Mapper;
 
@@ -44,4 +45,5 @@ public interface CategoryDao extends BaseDao<CategoryEntity> {
      */
     List<Long> getSubCategoryIdList(String id);
 
+	List<CategoryTreeDTO> selectListCategoryTreeDTO();
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/category/service/CategoryService.java

@@ -20,6 +20,7 @@ package com.elink.esua.epdc.modules.category.service;
 import com.elink.esua.epdc.commons.mybatis.service.BaseService;
 import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.dto.category.CategoryDTO;
+import com.elink.esua.epdc.dto.category.CategoryOption;
 import com.elink.esua.epdc.modules.category.entity.CategoryEntity;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -101,4 +102,22 @@ public interface CategoryService extends BaseService<CategoryEntity> {
      * 导入分类表格
      */
     Result insertPartyList(MultipartFile file);
+
+    /**
+     * @param
+     * @return void
+     * @Author yinzuomei
+     * @Description 组装事件类别
+     * @Date 2019/12/3 18:20
+     **/
+    void packageCategoryOption();
+
+    /**
+     * @param
+     * @return com.elink.esua.epdc.commons.tools.utils.Result<com.elink.esua.epdc.dto.category.CategoryOption>
+     * @Author yinzuomei
+     * @Description 查询事件类别树, 供下拉框调用
+     * @Date 2019/12/3 18:04
+     **/
+    Result<CategoryOption> getCategoryTree();
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/category/service/impl/CategoryServiceImpl.java

@@ -17,32 +17,35 @@
 
 package com.elink.esua.epdc.modules.category.service.impl;
 
-import cn.afterturn.easypoi.excel.ExcelImportUtil;
-import cn.afterturn.easypoi.excel.entity.ImportParams;
-import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl;
 import com.elink.esua.epdc.commons.tools.constant.Constant;
+import com.elink.esua.epdc.commons.tools.constant.NumConstant;
 import com.elink.esua.epdc.commons.tools.exception.ErrorCode;
 import com.elink.esua.epdc.commons.tools.exception.RenException;
-import com.elink.esua.epdc.commons.tools.page.PageData;
+import com.elink.esua.epdc.commons.tools.redis.RedisKeys;
+import com.elink.esua.epdc.commons.tools.redis.RedisUtils;
 import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
-import com.elink.esua.epdc.commons.tools.constant.FieldConstant;
 import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.commons.tools.utils.TreeUtils;
 import com.elink.esua.epdc.dto.category.CategoryDTO;
+import com.elink.esua.epdc.dto.category.CategoryOption;
+import com.elink.esua.epdc.dto.category.CategoryTreeDTO;
 import com.elink.esua.epdc.modules.category.dao.CategoryDao;
 import com.elink.esua.epdc.modules.category.entity.CategoryEntity;
 import com.elink.esua.epdc.modules.category.redis.CategoryRedis;
 import com.elink.esua.epdc.modules.category.service.CategoryService;
+import com.google.common.collect.Lists;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 
-import java.io.File;
 import java.util.*;
 
 /**
@@ -56,6 +59,10 @@ public class CategoryServiceImpl extends BaseServiceImpl<CategoryDao, CategoryEn
 
 	@Autowired
 	private CategoryRedis categoryRedis;
+	@Autowired
+	private RedisUtils redisUtils;
+
+	private Logger logger = LoggerFactory.getLogger(getClass());
 
 	@Override
 	public List<CategoryDTO> list(Map<String, Object> params) {
@@ -101,6 +108,7 @@ public class CategoryServiceImpl extends BaseServiceImpl<CategoryDao, CategoryEn
 			entity.setPids(pids);
 		}
 		insert(entity);
+		this.packageCategoryOption();
 	}
 
 	@Override
@@ -164,7 +172,6 @@ public class CategoryServiceImpl extends BaseServiceImpl<CategoryDao, CategoryEn
 	}
 
 
-
 	@Override
 	@Transactional(rollbackFor = Exception.class)
 	public void update(CategoryDTO dto) {
@@ -194,6 +201,7 @@ public class CategoryServiceImpl extends BaseServiceImpl<CategoryDao, CategoryEn
 			entity.setPids(pids);
 		}
 		updateById(entity);
+		this.packageCategoryOption();
 	}
 
 	@Override
@@ -208,7 +216,7 @@ public class CategoryServiceImpl extends BaseServiceImpl<CategoryDao, CategoryEn
 
 		// 逻辑删除（@TableLogic 注解）
 		//logicDelete(new Long[]{id}, CategoryEntity.class);
-
+		this.packageCategoryOption();
 	}
 
 	@Override
@@ -223,4 +231,117 @@ public class CategoryServiceImpl extends BaseServiceImpl<CategoryDao, CategoryEn
 
 		return new Result();
 	}
+
+	/**
+	 * @param
+	 * @return com.elink.esua.epdc.commons.tools.utils.Result
+	 * @Author yinzuomei
+	 * @Description 查询事件类别树, 供下拉框调用
+	 * @Date 2019/12/3 18:07
+	 **/
+	@Override
+	public Result<CategoryOption> getCategoryTree() {
+		String eventsCategoryKey = RedisKeys.getEventsCategoryKey();
+		Object obj = redisUtils.get(eventsCategoryKey);
+		if (null == obj) {
+			this.packageCategoryOption();
+			obj = redisUtils.get(eventsCategoryKey);
+		}
+		return new Result<CategoryOption>().ok((CategoryOption) obj);
+	}
+
+	/**
+	 * @param
+	 * @return void
+	 * @Author yinzuomei
+	 * @Description 组装事件类别
+	 * @Date 2019/12/3 18:18
+	 **/
+	@Override
+	public void packageCategoryOption() {
+		List<CategoryTreeDTO> dtoList = baseDao.selectListCategoryTreeDTO();
+		JSONObject node;
+		JSONArray headNodes = new JSONArray();
+		for (CategoryTreeDTO categoryTreeDto : dtoList) {
+
+			if (categoryTreeDto.getPid().longValue() == NumConstant.ZERO_L) {
+				node = new JSONObject();
+				node.put("value", categoryTreeDto.getId());
+				node.put("label", categoryTreeDto.getCategoryName());
+				headNodes.add(node);
+			}
+		}
+
+		// 用于存放所有父级节点
+		JSONArray parent;
+		// 用于存放所有子级节点
+		JSONArray allChildren = new JSONArray();
+		JSONArray children;
+		// 用于存放单个子级节点
+		JSONObject childNode;
+
+		parent = headNodes;
+		// 存放其余未处理的类别(节点)
+		List<CategoryTreeDTO> others = this.getOtherCategory(dtoList, parent);
+
+		while (!others.isEmpty()) {
+			for (int i = 0; i < parent.size(); i++) {
+				node = parent.getJSONObject(i);
+				children = new JSONArray();
+				for (CategoryTreeDTO categoryTreeDto : others) {
+					if (categoryTreeDto.getPid().equals(node.get("value"))) {
+						childNode = new JSONObject();
+						childNode.put("value", categoryTreeDto.getId());
+						childNode.put("label", categoryTreeDto.getCategoryName());
+
+						children.add(childNode);
+						allChildren.add(childNode);
+					}
+				}
+				if (!children.isEmpty()) {
+					node.put("children", children);
+				}
+			}
+			parent = allChildren;
+
+			others = this.getOtherCategory(others, parent);
+
+		}
+//		JSONObject treeNodes = new JSONObject();
+//		treeNodes.put("options", headNodes);
+//		logger.info(treeNodes.toJSONString());
+		//存放到redis中
+		List<JSONArray> cache = Lists.newArrayList();
+		cache.add(headNodes);
+		CategoryOption option = new CategoryOption();
+		option.setOptions(cache.get(0));
+		redisUtils.set(RedisKeys.getEventsCategoryKey(), option);
+	}
+
+	/*
+	 * @param dtoList 上次进行筛选的分类集合
+	 * @param parent 已处理过的上级节点
+	 * @return java.util.List<com.elink.esua.epdc.dto.category.CategoryTreeDTO>
+	 * @Author yinzuomei
+	 * @Description 组装其余未处理过的分类集合
+	 * @Date 2019/12/3 17:27
+	 **/
+	private List<CategoryTreeDTO> getOtherCategory(List<CategoryTreeDTO> dtoList, JSONArray parent) {
+		List<Long> already = Lists.newArrayList();
+		for (int i = 0; i < parent.size(); i++) {
+			already.add((Long) parent.getJSONObject(i).get("value"));
+		}
+
+		List<CategoryTreeDTO> others = Lists.newArrayList();
+
+		for (CategoryTreeDTO categoryTreeDto : dtoList) {
+			Long categoryTreeDtoId = categoryTreeDto.getId();
+			if (!already.contains(categoryTreeDtoId)) {
+				others.add(categoryTreeDto);
+			}
+		}
+		return others;
+	}
+
+
 }

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/resources/mapper/category/CategoryDao.xml

@@ -34,4 +34,18 @@
         select id from epdc_category where pids like #{id} and del_flag = 0
     </select>
 
+    <select id="selectListCategoryTreeDTO" resultType="com.elink.esua.epdc.dto.category.CategoryTreeDTO">
+        SELECT
+            t1.id,
+            t1.pid,
+            t1.category_name as categoryName,
+            t1.id AS VALUE,
+            t1.category_name AS label
+        FROM
+            epdc_category t1
+        WHERE
+            t1.del_flag = 0
+        ORDER BY
+            t1.sort ASC
+    </select>
 </mapper>