基于SpringBoot从零构建博客网站- 新增创建、修改、删除专栏功能

守望博客是支持创建专栏的功能，即可以将一系列相关的文章归档到专栏中，方便用户管理和查阅文章。这里主要讲解专栏的创建、修改和删除功能，至于专栏还涉及其它的功能，例如关注专栏等后续会穿插着介绍。

1、创建专栏

接收和处理专栏相关功能的操作的方法会放在GroupController类中，首先创建专栏的页面为：

这里有两个地方需要特别说明：

第一这个分类数据，此处分类数据正是本博客网站的分类数据，这个分类数据是系统初始化时加入的，这个初始化的功能后续会加入，目前此处就是提前将数据先写入到数据库中，例如本博客作为技术类博客，则分类有：前端、架构、区块链、云计算等。

然后这个分类信息数据一般初始化后，就不会有修改，则这个数据是放入缓存中，即，CategoryCache：

/**
 * 缓存分类信息
 * 分类信息放到系统永久缓存中，存放形式为："_CATEGORY" + categoryId为key，value为分类信息对象
 *
 * @author lzj
 * @since 1.0
 * @date [2019-07-22]
 */
@Slf4j
@DependsOn("categoryService")
@Component("categoryCache")
public class CategoryCache implements ICache<list>> {
​
 /**
 * 注入基于Spring提供的Cache接口实例，默认由Ehcache实现
 * TODO 以后也可以是Redis、Memcached提供实现
 */
 @Autowired
 private CacheManager cacheManager;
​ 

 @Autowired
 private ICategoryService categoryService;
​
 /**
 * 缓存实例
 */
 private Cache cache;
​
 /**
 * key的前缀
 */
 private String keyPrefix = "_CATEGORY";
​
 /**
 * 分类信息根节点ID
 */
 public static final String ROOT_CATEGORY_ID = "0";
​
 @PostConstruct
 public void init() {
 // 获取系统永久缓存实例
 cache = cacheManager.getCache(Const.CACHE_SYSTEM_ETERNAL);
 log.info("获取系统永久缓存实例");
​
 log.debug("开始加载父分类信息");
 List<category> categorys = categoryService.getByParentId(ROOT_CATEGORY_ID);
 if (categorys != null && !categorys.isEmpty()) {
 put(keyPrefix + ROOT_CATEGORY_ID, categorys);
 }
 log.debug("加载完毕父分类信息");
 }
​
 @Override
 public List<category> get(Object key) {
 Cache.ValueWrapper valueWrapper = cache.get(keyPrefix + key);
 if (valueWrapper == null) {
 // 从数据库重新加载一次
 List<category> categorys = categoryService.getByParentId((String) key);
 if (categorys == null) {
 return null;
 }
​
 // 再次放到缓存中
 put(key, categorys); 

​
 return categorys;
 }
 return (List<category>) valueWrapper.get();
 }
​
 @Override
 public void put(Object key, List<category> value) {
 cache.put(keyPrefix + key, value);
 }
​
 @Override
 public void remove(Object key) {
 cache.evict(keyPrefix + key);
 }
}
/<category>/<category>/<category>/<category>/<category>/<list>

第二需要说明的是，此处的上传控制是用的webuploader，利用webuploader处理的上传文件的话，需要按如下方式初始化：

$(function() {
 var _list = $('#fileList');
 var ratio = window.devicePixelRatio || 1;
 var thumbnailWidth = 100 * ratio;
 var thumbnailHeight = 100 * ratio;
​
 // 初始化Web Uploader
 var uploader = WebUploader.create({
​
 // 选完文件后，是否自动上传。
 auto: true,
​
 // swf文件路径
 swf: '${rc.contextPath}/static/plugins/webuploader/Uploader.swf',
​
 // 文件接收服务端。
 server: '${rc.contextPath}/upload',
​
 // 选择文件的按钮。可选。
 // 内部根据当前运行是创建，可能是input元素，也可能是flash. 

 pick: '#filePicker',
​
 fileVal: "_uploadFile",
​
 formData: {
 _distId:'_distId',
 _distType:'_groupLogo',
 },
​
 // 只允许选择图片文件。
 accept: {
 title: 'Images',
 extensions: 'gif,jpg,jpeg,png',
 mimeTypes: 'image/*'
 },
​
 fileNumLimit: 1,
 fileSizeLimit: 2 * 1024 * 1024, // 2 M
 fileSingleSizeLimit: 2 * 1024 * 1024 // 2 M
 });
​
 // 当有文件添加进来的时候
 uploader.on( 'fileQueued', function( file ) {
 var li = $(
 '
' +
 '' +
 // '
' + file.name + '
' +
 '
'
 ),
 img = li.find('img');
​
​
 // _list为容器jQuery实例
 _list.append( li );
​
 // 创建缩略图
 // 如果为非图片文件，可以不用调用此方法。
 // thumbnailWidth x thumbnailHeight 为 100 x 100
 uploader.makeThumb( file, function( error, src ) {
 if ( error ) { 

 img.replaceWith('不能预览');
 return;
 }
​
 img.attr( 'src', src );
 }, thumbnailWidth, thumbnailHeight );
 });
​
 // 文件上传过程中创建进度条实时显示。
 uploader.on( 'uploadProgress', function( file, percentage ) {
 });
​
 // 文件上传成功，给item添加成功class, 用样式标记上传成功。
 uploader.on( 'uploadSuccess', function(file, response) {
 $( '#'+file.id ).addClass('upload-state-done');
 $( '#'+file.id ).append(' ' )
 $("#logo").val(response.url);
 });
​
 // 文件上传失败，显示上传出错。
 uploader.on( 'uploadError', function( file ) {
 var li = $( '#'+file.id ),
 error = li.find('div.error');
​
 // 避免重复创建
 if ( !error.length ) {
 error = $('
').appendTo( li );
 }
​
 error.text('上传失败');
 });
​
 // 完成上传完了，成功或者失败，先删除进度条。
 uploader.on( 'uploadComplete', function( file ) {
 });
​
 // 执行删除方法
 _list.on('click', '.del', function () {
 var Id = $(this).parent().attr('id');
 //删除该图片 

 uploader.removeFile(uploader.getFile(Id, true));
 $(this).parent().remove();
 $("#logo").val("");
 });
});

这里后台需要处理专栏的Logo图片的信息，根据上一章节的方式处理，即有UploadGroupLogoHandler类，如：

/**
 * 上传专栏Logo处理类
 *
 * @author lzj
 * @since 1.0
 * @date [2019-07-23]
 */
@Slf4j
@Component("_groupLogo")
public class UploadGroupLogoHandler implements IUploadHandler {
​
 @Resource(name = "configCache")
 private ICache<config> configCache;
​
 @Override
 public Object upload(MultipartFile file, String distType, String userId) throws Exception {
 Map<string> result = new HashMap<string>();
 try {
 // 获取图片的原始名称
 String originalName = file.getOriginalFilename();
​
 // 判断图片的类型
 if (!(originalName.endsWith(".jpg") || originalName.endsWith(".JPG") || originalName.endsWith(".png") || originalName.endsWith(".PNG") || originalName.endsWith(".gif") || originalName.endsWith(".GIF") || originalName.endsWith(".jpeg") || originalName.endsWith(".JPEG"))) {
 throw new TipException("您上传的图片类型有误，请上传格式为jpg、png或gif");
 }
​
 // 获取图片的大小
 long fileSize = file.getSize();
​
 // 图片大小不能超过2M, 2M = 2 * 1024 * 1024B = 2097152B
 if (fileSize > 2097152L) {
 throw new TipException("您上传的图片超过2M"); 

 }
​
 Config config = configCache.get(Config.CONFIG_IMG_GROUP_LOGO_PATH);
 // 保存头像的根目录
 String basePath = config.getConfigValue();
 if (!(basePath.endsWith("/") || basePath.endsWith("\\\\"))) {
 basePath += "/";
 }
​
 // 根据当前时间构建yyyyMM的文件夹，建立到月的文件夹
 String dateDirName = DateUtil.date2Str(new Date(), DateUtil.YEAR_MONTH_FORMAT);
 basePath += dateDirName;
​
 File imageDir = new File(basePath);
 if (!imageDir.exists()) {
 imageDir.mkdirs();
 }
​
 String fileNewName = IdGenarator.guid() + originalName.substring(originalName.lastIndexOf("."));
 FileUtil.copy(file.getInputStream(), new FileOutputStream(new File(imageDir, fileNewName)));
​
 result.put("url", dateDirName + "/" + fileNewName);
 result.put("msg", "上传成功");
 } catch (TipException e) {
 result.put("url", "");
 result.put("msg", e.getMessage());
 } catch (Exception e) {
 log.error("上传失败", e);
 result.put("url", "");
 result.put("msg", "上传失败");
 }
 return result;
 }
​
 @Override
 public void download(String fileId, HttpServletResponse response) throws Exception {
 }
​
 @Override
 public Object list(String distType, String userId) throws Exception {
 return null;
 }
}
/<string>/<string>/<config>

最后创建专栏的核心代码如下：

/**
 * 创建专栏
 *
 * @param request
 * @param session
 * @return
 */
@RequestMapping(value = "/user/group/add", method = RequestMethod.POST)
@ResponseBody
public Result add(HttpServletRequest request, HttpSession session) {
 Result result = new Result();
 try {
 // 接收参数
 String categoryId = request.getParameter("categoryId");
 String name = request.getParameter("name");
 String logo = request.getParameter("logo");
 String introduce = request.getParameter("introduce");
​
 // 校验参数
 if (StringUtils.isEmpty(categoryId) || StringUtils.isEmpty(name) || StringUtils.isEmpty(logo) || StringUtils.isEmpty(introduce)) {
 throw new TipException("缺少必要参数");
 }
​
 // 获取登录信息
 User tempUser = (User) session.getAttribute(Const.SESSION_USER);
 String userId = tempUser.getUserId();
​
 // 构建专栏对象
 Group group = new Group();
 group.setGroupId(IdGenarator.longIdStr());
 group.setName(name);
 group.setLogo(logo);
 group.setIntroduce(introduce);
 group.setCategoryId(categoryId);
 group.setCreator(userId);
 group.setCreateTime(new Date());
 // 从系统配置项获取专栏是否审核
 Config config = configCache.get(Config.CONFIG_GROUP_AUDIT);
 if (config != null && "1".equals(config.getConfigValue())) {
 // 需要审核
 group.setStatus(Group.STATUS_NO);
 } else {
 // 不需要审核
 group.setStatus(Group.STATUS_SUCCESS); 

 }
​
 // 保存专栏信息
 boolean flag = groupService.save(group);
 if (!flag) {
 throw new TipException("创建专栏失败");
 }
​
 result.setCode(Result.CODE_SUCCESS);
 result.setMsg("成功创建专栏");
 } catch (TipException e) {
 result.setCode(Result.CODE_EXCEPTION);
 result.setMsg(e.getMessage());
 } catch (Exception e) {
 log.error("创建专栏失败", e);
 result.setCode(Result.CODE_EXCEPTION);
 result.setMsg("创建专栏失败");
 }
 return result;
}

2、修改专栏

有了前面新增专栏的基础，其实修改专栏的功能就相对简单很多了，此处只列出处理修改的核心代码即可，如：

/**
 * 修改专栏
 *
 * @param groupId
 * @param request
 * @param session
 * @return
 */
@RequestMapping(value = "/user/group/edit/{groupId}", method = RequestMethod.POST)
@ResponseBody
public Result edit(@PathVariable("groupId") String groupId, HttpServletRequest request, HttpSession session) {
 Result result = new Result();
 try {
 // 根据id获取专栏信息 

 Group group = groupService.getById(groupId);
 if (group == null || StringUtils.isEmpty(group.getGroupId())) {
 log.error("groupId: " + groupId + ": 该专栏不存在");
 throw new TipException("该专栏不存在");
 }
​
 // 获取用户信息
 User tempUser = (User) session.getAttribute(Const.SESSION_USER);
 String userId = tempUser.getUserId();
 if (!userId.equals(group.getCreator())) {
 log.error("userId: " + userId + "修改别人的groupId: " + groupId);
 throw new TipException("不能修改别人的专栏");
 }
​
 // 接收参数
 String categoryId = request.getParameter("categoryId");
 String name = request.getParameter("name");
 String introduce = request.getParameter("introduce");
 String logo = request.getParameter("logo");
​
 // 校验参数
 if (StringUtils.isEmpty(categoryId) || StringUtils.isEmpty(name) || StringUtils.isEmpty(introduce)) {
 throw new TipException("缺少必要参数");
 }
​
 group.setCategoryId(categoryId);
 group.setName(name);
 group.setIntroduce(introduce);
 if (!StringUtils.isEmpty(logo)) {
 group.setLogo(logo);
 }
 group.setUpdateTime(new Date());
​
 // 修改
 boolean flag = groupService.updateById(group);
 if (!flag) {
 throw new TipException("修改专栏失败");
 }
​
 result.setCode(Result.CODE_SUCCESS);
 result.setMsg("修改专栏成功");
 } catch (TipException e) {
 result.setCode(Result.CODE_EXCEPTION);
 result.setMsg(e.getMessage()); 

 } catch (Exception e) {
 log.error("修改专栏失败", e);
 result.setCode(Result.CODE_EXCEPTION);
 result.setMsg("修改专栏失败");
​
 }
 return result;
}

3、删除专栏

删除专栏功能是很简单的，但是需要考虑到，删除专栏后，需要处理其它与之关联的数据信息，此处由于其它模块还没有完成，所以先将加一个TODO，后续会再处理。那删除专栏的核心代码如下：

/**
 * 根据ID删除专栏
 *
 * @param groupId
 * @param session
 * @return
 */
@RequestMapping(value = "/user/group/delete/{groupId}", method = RequestMethod.GET)
@ResponseBody
public Result delete(@PathVariable("groupId") String groupId, HttpSession session) {
 Result result = new Result();
 try {
 // 根据id获取专栏信息
 Group group = groupService.getById(groupId);
 if (group == null || StringUtils.isEmpty(group.getGroupId())) {
 log.error("groupId: " + groupId + ": 该专栏不存在");
 throw new TipException("该专栏不存在");
 }
​
 // 获取用户信息
 User tempUser = (User) session.getAttribute(Const.SESSION_USER); 

 String userId = tempUser.getUserId();
 if (!userId.equals(group.getCreator())) {
 log.error("userId: " + userId + "删除别人的groupId: " + groupId);
 throw new TipException("不能删除别人的专栏");
 }
​
 // 删除
 boolean flag = groupService.removeById(groupId);
 if (!flag) {
 throw new TipException("删除专栏失败");
 }
​
 // TODO 删除专栏后，需要处理其它关联的数据，由于其它模块还没有，此处后续处理
​
 result.setCode(Result.CODE_SUCCESS);
 result.setMsg("删除专栏成功");
 } catch (TipException e) {
 result.setCode(Result.CODE_EXCEPTION);
 result.setMsg(e.getMessage());
 } catch (Exception e) {
 log.error("删除专栏失败", e);
 result.setCode(Result.CODE_EXCEPTION);
 result.setMsg("删除专栏失败");
 }
 return result;
}