一款面向模板开发，支持静态生成的CMS 系统,其支持前后端分离部署,是一款好用的 cms 系统

package com.thinkit.cms.service.content; import cn.hutool.core.io.FileUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.google.common.collect.Lists; import com.thinkit.cms.api.category.CategoryModelRelationService; import com.thinkit.cms.api.category.CategoryService; import com.thinkit.cms.api.content.ContentAttachService; import com.thinkit.cms.api.content.ContentAttrService; import com.thinkit.cms.api.content.ContentRelatedService; import com.thinkit.cms.api.content.ContentService; import com.thinkit.cms.api.model.ModelService; import com.thinkit.cms.api.site.SiteService; import com.thinkit.cms.api.tag.TagService; import com.thinkit.cms.config.ActuatorComponent; import com.thinkit.cms.dto.category.CategoryDto; import com.thinkit.cms.dto.content.*; import com.thinkit.cms.dto.model.ModelDto; import com.thinkit.cms.dto.tag.TagDto; import com.thinkit.cms.entity.content.Content; import com.thinkit.cms.mapper.content.ContentMapper; import com.thinkit.cms.strategy.checker.ContentChecker; import com.thinkit.cms.strategy.checker.PublishChecker; import com.thinkit.core.base.BaseContextKit; import com.thinkit.core.base.BaseServiceImpl; import com.thinkit.core.constant.Channel; import com.thinkit.core.constant.Constants; import com.thinkit.core.handler.CustomException; import com.thinkit.nosql.base.BaseRedisService; import com.thinkit.nosql.base.BaseSolrService; import com.thinkit.nosql.enums.SolrCoreEnum; import com.thinkit.processor.channel.ChannelThreadLocal; import com.thinkit.processor.message.MessageSend; import com.thinkit.utils.enums.*; import com.thinkit.utils.model.*; import com.thinkit.utils.properties.ThinkItProperties; import com.thinkit.utils.utils.Checker; import com.thinkit.utils.utils.ModelFieldUtil; import org.apache.commons.lang3.StringUtils; import org.apache.solr.client.solrj.SolrServerException; import org.apache.solr.common.SolrDocument; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Transactional; import java.io.IOException; import java.math.BigDecimal; import java.util.*; import java.util.concurrent.CompletableFuture; /** * <p> * 内容 服务实现类 * </p> * * @author lg * @since 2020-08-15 */ @Service public class ContentServiceImpl extends BaseServiceImpl<ContentDto, Content, ContentMapper> implements ContentService { @Autowired CategoryService categoryService; @Autowired ContentAttrService contentAttrService; @Autowired ContentAttachService attachService; @Autowired ModelService modelService; @Autowired MessageSend messageSend; @Autowired SiteService siteService; @Autowired CategoryModelRelationService modelRelationService; @Autowired ContentRelatedService relatedService; @Autowired TagService tagService; @Autowired BaseRedisService baseRedisService; @Autowired ActuatorComponent actuatorComponent; @Autowired BaseSolrService baseSolrService; // @Autowired // ArticleService articleService; @Autowired ThinkItProperties thinkItProperties; @Override public PageDto<ContentDto> listPage(PageDto<ContentDto> pageDto){ filterCategory(pageDto); IPage<ContentDto> pages = new Page<>(pageDto.getPageNo(), pageDto.getPageSize()); IPage<ContentDto> result = baseMapper.listPage(pages, pageDto.getDto()); if(Checker.BeNotEmpty(result.getRecords()))filterCover(result.getRecords()); PageDto<ContentDto> resultSearch = new PageDto(result.getTotal(), result.getPages(), result.getCurrent(), Checker.BeNotEmpty(result.getRecords()) ? result.getRecords() : Lists.newArrayList()); return resultSearch; } @Override public PageDto<ContentDto> pageRecycler(PageDto<ContentDto> pageDto) { filterCategory(pageDto); IPage<ContentDto> pages = new Page<>(pageDto.getPageNo(), pageDto.getPageSize()); IPage<ContentDto> result = baseMapper.pageRecycler(pages, pageDto.getDto()); if(Checker.BeNotEmpty(result.getRecords()))filterCover(result.getRecords()); PageDto<ContentDto> resultSearch = new PageDto(result.getTotal(), result.getPages(), result.getCurrent(), Checker.BeNotEmpty(result.getRecords()) ? result.getRecords() : Lists.newArrayList()); return resultSearch; } private void filterCover(List<ContentDto> contents){ for(ContentDto content:contents){ if(Checker.BeNotBlank(content.getCoverStr())){ content.setCover(JSONUtil.toList(JSONUtil.parseArray(content.getCoverStr()),Map.class)); } } } private void filterCategory(PageDto<ContentDto> pageDto){ if (Checker.BeNotBlank(pageDto.getDto().getCategoryId())) { List<String> childcategoryIds = new ArrayList<>(); childcategoryIds.add(pageDto.getDto().getCategoryId()); List<String> newChildCategoryIds = new ArrayList<>(); recursionCategoryIds(childcategoryIds, newChildCategoryIds); pageDto.getDto().setCategoryIds(newChildCategoryIds); } } private void recursionCategoryIds(List<String> childcategoryIds, List<String> newChildcategoryIds) { if (Checker.BeNotEmpty(childcategoryIds)) { newChildcategoryIds.addAll(childcategoryIds); for (String categoryId : childcategoryIds) { if (Checker.BeNotBlank(categoryId)) { List<String> childCategs = getCategoryChildByParentId(categoryId); recursionCategoryIds(childCategs, newChildcategoryIds); } } } } private List<String> getCategoryChildByParentId(String categoryId) { List<String> categoryIds = new ArrayList<>(); List<CategoryDto> cmsCategoryDtos = categoryService.listCategoryByPid(categoryId); if (Checker.BeNotEmpty(cmsCategoryDtos)) { for (CategoryDto cmsCategoryDto : cmsCategoryDtos) { categoryIds.add(cmsCategoryDto.getId()); } } return categoryIds; } @Override public IPage<ContentDto> pageContentForNoSql(Integer pageNo, Integer pageSize) { IPage<Map<String,String>> pages = new Page<>(pageNo, pageSize); IPage<ContentDto> result = baseMapper.pageContentForNoSql(pages, getSiteId()); if (Checker.BeNotEmpty(result.getRecords())) { // 处理格式化 for(ContentDto contentDto:result.getRecords()){ if(Checker.BeNotBlank(contentDto.getAttrData())){ Map<String,Object> params = ModelFieldUtil.jsonStrToMap(contentDto.getAttrData()); contentDto.setParams(params); } if(Checker.BeNotBlank(contentDto.getCoverStr())){ contentDto.setCover(JSONUtil.toList(JSONUtil.parseArray(contentDto.getCoverStr()),Map.class)); } } return result; } return null; } @Override public Tree<CategoryDto> treeCategory() { return categoryService.treeCategoryForContent(); } @Override public List<DynamicModel> getFormDesign(String modelId) { ModelDto model = modelService.getModel(modelId); Boolean hasfile =model.getHasFiles(); List<DynamicModel> dynamicModels=ModelFieldUtil.jsonStrToModel(model.getAllFieldList()); if(hasfile){ List<DynamicModel> attachField = ModelFieldUtil.loadModel(BelongEnum.ATTACH); if(Checker.BeNotEmpty(attachField)){ dynamicModels.addAll(attachField); } } return dynamicModels; } @Transactional @Override public void save(ContentDto