基于Javascript的ThinkItCMS Java CMS系统设计源码

package com.thinkit.cms.boot.service.category; import cn.hutool.core.date.DateField; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.crypto.SecureUtil; import cn.hutool.extra.spring.SpringUtil; import cn.hutool.json.JSONUtil; import com.alicp.jetcache.anno.CacheInvalidate; import com.alicp.jetcache.anno.CacheType; import com.alicp.jetcache.anno.Cached; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.google.common.collect.Lists; import com.thinkit.cms.annotation.Site; import com.thinkit.cms.api.category.CategoryService; import com.thinkit.cms.api.categoryformmodel.CategoryFormModelService; import com.thinkit.cms.api.formdata.FormDataService; import com.thinkit.cms.api.formmodel.FormModelService; import com.thinkit.cms.api.formmodeltmp.FormModelTmpFunService; import com.thinkit.cms.api.site.SiteService; import com.thinkit.cms.boot.entity.category.CategoryEntity; import com.thinkit.cms.boot.entity.content.ContentEntity; import com.thinkit.cms.boot.events.CategoryEvent; import com.thinkit.cms.boot.mapper.category.CategoryMapper; import com.thinkit.cms.boot.mapper.content.ContentMapper; import com.thinkit.cms.boot.mapper.formmodel.FormModelMapper; import com.thinkit.cms.constant.SysConst; import com.thinkit.cms.core.base.BaseServiceImpl; import com.thinkit.cms.core.handler.CustomException; import com.thinkit.cms.directive.emums.ActuatorEnum; import com.thinkit.cms.directive.kit.Kv; import com.thinkit.cms.directive.task.TaskDto; import com.thinkit.cms.directive.task.TaskService; import com.thinkit.cms.directive.wrapper.CategoryMData; import com.thinkit.cms.directive.wrapper.ModelAndView; import com.thinkit.cms.dto.category.AddEditCategory; import com.thinkit.cms.dto.category.CategoryDto; import com.thinkit.cms.dto.category.CategoryJob; import com.thinkit.cms.dto.category.PublishCategory; import com.thinkit.cms.dto.site.SiteDto; import com.thinkit.cms.dto.sysmenu.CategoryTree; import com.thinkit.cms.enums.EventEnum; import com.thinkit.cms.enums.ModelEnum; import com.thinkit.cms.enums.TaskEnum; import com.thinkit.cms.enums.TaskStatusEnum; import com.thinkit.cms.model.PageTemp; import com.thinkit.cms.user.SiteConf; import com.thinkit.cms.user.User; import com.thinkit.cms.utils.BuildTree; import com.thinkit.cms.utils.Checker; import com.thinkit.cms.utils.CmsFolderUtil; import com.thinkit.cms.utils.Tree; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.*; import java.util.concurrent.CompletableFuture; /** * @author LG */ @Slf4j @Service public class CategoryServiceImpl extends BaseServiceImpl<CategoryDto,CategoryEntity,CategoryMapper> implements CategoryService{ @Autowired private CategoryFormModelService categoryFormModelService; @Autowired private FormDataService formDataService; @Autowired private FormModelTmpFunService tmpFunService; @Resource private ContentMapper contentMapper; @Resource private FormModelMapper formModelMapper; @Autowired private FormModelService formModelService; @Autowired private SiteService siteService; @Autowired private TaskService taskService; @Override public Tree<CategoryTree> categoryTree(String pid) { List<String> keys = new ArrayList<>(); CategoryTree tree = new CategoryTree(); List<CategoryDto> categories = baseMapper.selectCategorys(getSiteId(true), pid,null); tree.setName("全部栏目"); tree.setId(BuildTree.rootNode); tree.setChildren(categoryToTree(categories, CategoryTree.class,false)); if(Checker.BeNotEmpty(categories)){ categories.forEach(category->keys.add(category.getId())); tree.setExpandedKeys(keys); } return tree; } @Override public List<Tree<CategoryTree>> treeTable(String pid) { Tree tree = new CategoryTree(); SiteConf siteConf = getUserCtx().getSite(true); String domain = CmsFolderUtil.getSiteDomain(siteConf.getDomain()); List<CategoryDto> categories = baseMapper.selectCategorys(getSiteId(true), null,domain); tree = BuildTree.build(categoryToTree(categories, CategoryTree.class,false)); List<Tree<CategoryTree>> trees = BuildTree.treeList(tree); if(!BuildTree.rootNode.equals(pid)){ trees.removeIf(t->!t.getId().equals(pid)); } return trees; } @Override public List<Tree<CategoryTree>> treeTableForContent(String pid) { Tree tree = new CategoryTree(); SiteConf siteConf = getUserCtx().getSite(true); String domain = CmsFolderUtil.getSiteDomain(siteConf.getDomain()); List<CategoryDto> categories = baseMapper.selectCategorys(getSiteId(true), null,domain); tree = BuildTree.build(categoryToTree(categories, CategoryTree.class,true)); List<Tree<CategoryTree>> trees = BuildTree.treeList(tree); if(!BuildTree.rootNode.equals(pid)){ trees.removeIf(t->!t.getId().equals(pid)); } return trees; } @Transactional(rollbackFor = Exception.class) @Override public boolean deletes(List<String> categoryIds) { super.deleteLogicByPks(categoryIds); initIndexTemp(getSiteId(true)); return true; } @Override public void executer(User user, String siteId, String taskId, TaskEnum taskEnum) { List<CategoryDto> categoryDtos = baseMapper.queryCategorys(siteId); if(Checker.BeNotEmpty(categoryDtos)){ CategoryService categoryService = SpringUtil.getBean(CategoryService.class); List<Date> startEndTime =new ArrayList<>(); DateTime endTime = new DateTime(); Date startTime = DateUtil.offset(endTime, DateField.MONTH,-12); startEndTime.add(startTime); startEndTime.add(endTime); for(CategoryDto categoryDto:categoryDtos){ if(taskService.isStop(taskId)){ break; } PublishCategory publishCategory = new PublishCategory(); publishCategory.setCategoryId(categoryDto.getId()); publishCategory.setContainChild(false); publishCategory.setContainTimes(true); publishCategory.setStartEndTime(startEndTime); publishCategory.setForceGen(false); publishCategory.setAsync(true); publishCategory.setTaskId(taskId); publishCategory.setUser(user); categoryService.jobCreateTmpHome(publishCategory); } } } @Override public void clearTaskId(String categoryId) { taskService.clear(taskKey(categoryId)); } private String taskKey(String categoryId){ StringBuffer stringBuffer = new StringBuffer(SysConst.task); stringBuffer.append(getSiteId(true)); stringBuffer.append(SysConst.colon); stringBuffer.append(TaskEnum.CATEGORY_TASK.getVal()); stringBuffer.append(SysConst.colon); stringBuffer.append(categoryId); String key = stringBuffer.toString(); return key; } @Override public void upStatus(String categoryId,TaskStatusEnum taskStatusEnum) { String key = taskKey(categoryId); taskService.upStatus(key, taskStatusEnum); } @Override public Set<String> listIds(String siteId) { return baseMapper.listIds(siteId); } @Cached(name = "cached::", key = "targetObject.class+'.queryCode.'+#categoryId" ,expire = 7200, cacheType = CacheType.REMOTE) @Override public String queryCode(String categoryId) { return baseMapper.queryCode(categoryId); } @Site @Transact