package com.iplatform.base.cache;
|
|
import com.iplatform.base.CategoryCacheProvider;
|
import com.iplatform.base.Constants;
|
import com.iplatform.base.service.CategoryServiceImpl;
|
import com.iplatform.base.util.CategoryUtils;
|
import com.iplatform.base.util.cache.CategorySortComparator;
|
import com.iplatform.model.po.S_category;
|
import com.iplatform.model.vo.CategoryTreeVo;
|
import com.walker.cache.AbstractCacheProvider;
|
import com.walker.cache.Cachable;
|
import com.walker.cache.Cache;
|
import com.walker.infrastructure.utils.StringUtils;
|
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLDecoder;
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
|
public class LocalCategoryCacheProvider extends AbstractCacheProvider<S_category> implements CategoryCacheProvider {
|
|
private final CategorySortComparator sortComparator = new CategorySortComparator();
|
|
@Override
|
public List<CategoryTreeVo> getTree(Integer type, Integer status, String name, List<Integer> categoryIdList, int owner) {
|
List<S_category> allTree = new ArrayList<>();
|
S_category tempCategory = null;
|
|
for(Iterator<Cachable> it = this.getCache().getIterator(); it.hasNext();){
|
tempCategory = (S_category) it.next().getValue();
|
// if(owner != tempCategory.getOwner().intValue()){
|
// continue;
|
// }
|
// if(type != null && type.intValue() != tempCategory.getType().intValue()){
|
// continue;
|
// }
|
// if(status != null && status.intValue() != tempCategory.getStatus().intValue()){
|
// continue;
|
// }
|
// if(!StringUtils.isEmptyList(categoryIdList) && !categoryIdList.contains(tempCategory.getId())){
|
// logger.debug("不包含在给定的集合中'categoryIdList'");
|
// continue;
|
// }
|
if(CategoryUtils.isCondition(tempCategory, type, status, name, categoryIdList, owner)){
|
allTree.add(tempCategory);
|
}
|
}
|
|
return CategoryUtils.acquireListTree(allTree, sortComparator);
|
// // 重新排序
|
// Collections.sort(allTree, sortComparator);
|
//
|
// //
|
// List<CategoryTreeVo> treeList = new ArrayList<>();
|
// if(allTree.size() == 0){
|
// return treeList;
|
// }
|
//
|
// //
|
// for (S_category category : allTree) {
|
// treeList.add(CategoryUtils.toCategoryTreeVo(category));
|
// }
|
//
|
// Map<Integer, CategoryTreeVo> map = new HashMap<>(treeList.size());
|
// //ID 为 key 存储到map 中
|
// for (CategoryTreeVo categoryTreeVo : treeList) {
|
// map.put(categoryTreeVo.getId(), categoryTreeVo);
|
// }
|
//
|
// List<CategoryTreeVo> list = new ArrayList<>();
|
// CategoryTreeVo parentTree = null;
|
// for (CategoryTreeVo tree : treeList) {
|
// //子集ID返回对象，有则添加。
|
// parentTree = map.get(tree.getPid());
|
// if (parentTree != null) {
|
// parentTree.getChild().add(tree);
|
// } else {
|
// list.add(tree);
|
// }
|
// }
|
// return list;
|
}
|
|
@Override
|
public List<CategoryTreeVo> getListTree(Integer type, Integer status, String name, int owner) {
|
if(StringUtils.isNotEmpty(name)){
|
try {
|
name = URLDecoder.decode(name, StringUtils.DEFAULT_CHARSET_UTF8);
|
} catch (UnsupportedEncodingException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
return getTree(type, status, name, null, owner);
|
}
|
|
@Override
|
public S_category get(int id) {
|
return this.getCacheData(String.valueOf(id));
|
}
|
|
@Override
|
public void save(S_category category) {
|
this.putCacheData(String.valueOf(category.getId()), category);
|
}
|
|
@Override
|
public void update(S_category category) {
|
this.updateCacheData(String.valueOf(category.getId()), category);
|
}
|
|
@Override
|
public void remove(int id) {
|
this.removeCacheData(String.valueOf(id));
|
}
|
|
@Override
|
protected int loadDataToCache(Cache cache) {
|
List<S_category> data = this.categoryService.selectAll(new S_category());
|
if(!StringUtils.isEmptyList(data)){
|
for(S_category d : data){
|
cache.put(String.valueOf(d.getId()), d);
|
}
|
return data.size();
|
}
|
return 0;
|
}
|
|
@Override
|
public String getProviderName() {
|
return Constants.CACHE_NAME_CATEGORY;
|
}
|
|
@Override
|
public Class<?> getProviderType() {
|
return S_category.class;
|
}
|
|
public void setCategoryService(CategoryServiceImpl categoryService) {
|
this.categoryService = categoryService;
|
}
|
|
private CategoryServiceImpl categoryService;
|
}
|
