listUser(@RequestBody BaseRequestVO baseRequestVO) {
+ return userService.listUser(baseRequestVO);
+ }
+
+ /**
+ * 修改用户状态
+ *
+ * flag = true：解禁
+ * flag = false：封禁
+ */
+ @GetMapping("/user/changeUserStatus")
+ @LoginCheck(0)
+ public PoetryResult changeUserStatus(@RequestParam("userId") Integer userId, @RequestParam("flag") Boolean flag) {
+ if (userId.intValue() == PoetryUtil.getAdminUser().getId().intValue()) {
+ return PoetryResult.fail("站长状态不能修改！");
+ }
+
+ LambdaUpdateChainWrapper updateChainWrapper = userService.lambdaUpdate().eq(User::getId, userId);
+ if (flag) {
+ updateChainWrapper.eq(User::getUserStatus, PoetryEnum.STATUS_DISABLE.getCode()).set(User::getUserStatus, PoetryEnum.STATUS_ENABLE.getCode()).update();
+ } else {
+ updateChainWrapper.eq(User::getUserStatus, PoetryEnum.STATUS_ENABLE.getCode()).set(User::getUserStatus, PoetryEnum.STATUS_DISABLE.getCode()).update();
+ }
+ logout(userId);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 修改用户赞赏
+ */
+ @GetMapping("/user/changeUserAdmire")
+ @LoginCheck(0)
+ public PoetryResult changeUserAdmire(@RequestParam("userId") Integer userId, @RequestParam("admire") String admire) {
+ userService.lambdaUpdate()
+ .eq(User::getId, userId)
+ .set(User::getAdmire, admire)
+ .update();
+ PoetryCache.remove(CommonConst.ADMIRE);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 修改用户类型
+ */
+ @GetMapping("/user/changeUserType")
+ @LoginCheck(0)
+ public PoetryResult changeUserType(@RequestParam("userId") Integer userId, @RequestParam("userType") Integer userType) {
+ if (userId.intValue() == PoetryUtil.getAdminUser().getId().intValue()) {
+ return PoetryResult.fail("站长类型不能修改！");
+ }
+
+ if (userType != 0 && userType != 1 && userType != 2) {
+ return PoetryResult.fail(CodeMsg.PARAMETER_ERROR);
+ }
+ userService.lambdaUpdate().eq(User::getId, userId).set(User::getUserType, userType).update();
+
+ logout(userId);
+ return PoetryResult.success();
+ }
+
+ private void logout(Integer userId) {
+ if (PoetryCache.get(CommonConst.ADMIN_TOKEN + userId) != null) {
+ String token = (String) PoetryCache.get(CommonConst.ADMIN_TOKEN + userId);
+ PoetryCache.remove(CommonConst.ADMIN_TOKEN + userId);
+ PoetryCache.remove(token);
+ }
+
+ if (PoetryCache.get(CommonConst.USER_TOKEN + userId) != null) {
+ String token = (String) PoetryCache.get(CommonConst.USER_TOKEN + userId);
+ PoetryCache.remove(CommonConst.USER_TOKEN + userId);
+ PoetryCache.remove(token);
+ }
+ TioWebsocketStarter tioWebsocketStarter = TioUtil.getTio();
+ if (tioWebsocketStarter != null) {
+ Tio.removeUser(tioWebsocketStarter.getServerTioConfig(), String.valueOf(userId), "remove user");
+ }
+
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ArticleController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ArticleController.java
new file mode 100644
index 0000000..53b3de3
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ArticleController.java
@@ -0,0 +1,99 @@
+package com.ld.poetry.controller;
+
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.service.ArticleService;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.utils.cache.PoetryCache;
+import com.ld.poetry.utils.PoetryUtil;
+import com.ld.poetry.vo.ArticleVO;
+import com.ld.poetry.vo.BaseRequestVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ *
+ * 文章表 前端控制器
+ *
+ *
+ * @author sara
+ * @since 2021-08-13
+ */
+@RestController
+@RequestMapping("/article")
+public class ArticleController {
+
+ @Autowired
+ private ArticleService articleService;
+
+
+ /**
+ * 保存文章
+ */
+ @LoginCheck(1)
+ @PostMapping("/saveArticle")
+ public PoetryResult saveArticle(@Validated @RequestBody ArticleVO articleVO) {
+ PoetryCache.remove(CommonConst.USER_ARTICLE_LIST + PoetryUtil.getUserId().toString());
+ PoetryCache.remove(CommonConst.ARTICLE_LIST);
+ PoetryCache.remove(CommonConst.SORT_ARTICLE_LIST);
+ return articleService.saveArticle(articleVO);
+ }
+
+
+ /**
+ * 删除文章
+ */
+ @GetMapping("/deleteArticle")
+ @LoginCheck(1)
+ public PoetryResult deleteArticle(@RequestParam("id") Integer id) {
+ PoetryCache.remove(CommonConst.USER_ARTICLE_LIST + PoetryUtil.getUserId().toString());
+ PoetryCache.remove(CommonConst.ARTICLE_LIST);
+ PoetryCache.remove(CommonConst.SORT_ARTICLE_LIST);
+ return articleService.deleteArticle(id);
+ }
+
+
+ /**
+ * 更新文章
+ */
+ @PostMapping("/updateArticle")
+ @LoginCheck(1)
+ public PoetryResult updateArticle(@Validated @RequestBody ArticleVO articleVO) {
+ PoetryCache.remove(CommonConst.ARTICLE_LIST);
+ PoetryCache.remove(CommonConst.SORT_ARTICLE_LIST);
+ return articleService.updateArticle(articleVO);
+ }
+
+
+ /**
+ * 查询文章List
+ */
+ @PostMapping("/listArticle")
+ public PoetryResult listArticle(@RequestBody BaseRequestVO baseRequestVO) {
+ return articleService.listArticle(baseRequestVO);
+ }
+
+ /**
+ * 查询分类文章List
+ */
+ @GetMapping("/listSortArticle")
+ public PoetryResult>> listSortArticle() {
+ return articleService.listSortArticle();
+ }
+
+ /**
+ * 查询文章
+ */
+ @GetMapping("/getArticleById")
+ public PoetryResult getArticleById(@RequestParam("id") Integer id, @RequestParam(value = "password", required = false) String password) {
+ return articleService.getArticleById(id, password);
+ }
+}
+
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/CollectController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/CollectController.java
new file mode 100644
index 0000000..29da522
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/CollectController.java
@@ -0,0 +1,54 @@
+package com.ld.poetry.controller;
+
+import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.dao.ResourcePathMapper;
+import com.ld.poetry.entity.ResourcePath;
+import com.ld.poetry.vo.ResourcePathVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 资源聚合里的收藏夹，其他接口在ResourceAggregationController
+ *
+ *
+ * @author sara
+ * @since 2021-09-14
+ */
+@RestController
+@RequestMapping("/webInfo")
+public class CollectController {
+
+ @Autowired
+ private ResourcePathMapper resourcePathMapper;
+
+ /**
+ * 查询收藏
+ */
+ @GetMapping("/listCollect")
+ public PoetryResult>> listCollect() {
+ LambdaQueryChainWrapper wrapper = new LambdaQueryChainWrapper<>(resourcePathMapper);
+ List resourcePaths = wrapper.eq(ResourcePath::getType, CommonConst.RESOURCE_PATH_TYPE_FAVORITES)
+ .eq(ResourcePath::getStatus, Boolean.TRUE)
+ .orderByAsc(ResourcePath::getTitle)
+ .list();
+ Map> collect = new HashMap<>();
+ if (!CollectionUtils.isEmpty(resourcePaths)) {
+ collect = resourcePaths.stream().map(rp -> {
+ ResourcePathVO resourcePathVO = new ResourcePathVO();
+ BeanUtils.copyProperties(rp, resourcePathVO);
+ return resourcePathVO;
+ }).collect(Collectors.groupingBy(ResourcePathVO::getClassify));
+ }
+ return PoetryResult.success(collect);
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/CommentController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/CommentController.java
new file mode 100644
index 0000000..17ec818
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/CommentController.java
@@ -0,0 +1,85 @@
+package com.ld.poetry.controller;
+
+
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.aop.SaveCheck;
+import com.ld.poetry.service.CommentService;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.utils.CommonQuery;
+import com.ld.poetry.utils.cache.PoetryCache;
+import com.ld.poetry.utils.StringUtil;
+import com.ld.poetry.vo.BaseRequestVO;
+import com.ld.poetry.vo.CommentVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ *
+ * 文章评论表 前端控制器
+ *
+ *
+ * @author sara
+ * @since 2021-08-13
+ */
+@RestController
+@RequestMapping("/comment")
+public class CommentController {
+
+
+ @Autowired
+ private CommentService commentService;
+
+ @Autowired
+ private CommonQuery commonQuery;
+
+
+ /**
+ * 保存评论
+ */
+ @PostMapping("/saveComment")
+ @LoginCheck
+ @SaveCheck
+ public PoetryResult saveComment(@Validated @RequestBody CommentVO commentVO) {
+ String content = StringUtil.removeHtml(commentVO.getCommentContent());
+ if (!StringUtils.hasText(content)) {
+ return PoetryResult.fail("评论内容不合法！");
+ }
+ commentVO.setCommentContent(content);
+
+ PoetryCache.remove(CommonConst.COMMENT_COUNT_CACHE + commentVO.getSource().toString() + "_" + commentVO.getType());
+ return commentService.saveComment(commentVO);
+ }
+
+
+ /**
+ * 删除评论
+ */
+ @GetMapping("/deleteComment")
+ @LoginCheck
+ public PoetryResult deleteComment(@RequestParam("id") Integer id) {
+ return commentService.deleteComment(id);
+ }
+
+
+ /**
+ * 查询评论数量
+ */
+ @GetMapping("/getCommentCount")
+ public PoetryResult getCommentCount(@RequestParam("source") Integer source, @RequestParam("type") String type) {
+ return PoetryResult.success(commonQuery.getCommentCount(source, type));
+ }
+
+
+ /**
+ * 查询评论
+ */
+ @PostMapping("/listComment")
+ public PoetryResult listComment(@RequestBody BaseRequestVO baseRequestVO) {
+ return commentService.listComment(baseRequestVO);
+ }
+}
+
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/FamilyController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/FamilyController.java
new file mode 100644
index 0000000..b656757
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/FamilyController.java
@@ -0,0 +1,149 @@
+package com.ld.poetry.controller;
+
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.entity.Family;
+import com.ld.poetry.service.FamilyService;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.utils.CommonQuery;
+import com.ld.poetry.utils.cache.PoetryCache;
+import com.ld.poetry.utils.PoetryUtil;
+import com.ld.poetry.vo.BaseRequestVO;
+import com.ld.poetry.vo.FamilyVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Collections;
+import java.util.List;
+
+/**
+ *
+ * 家庭信息 前端控制器
+ *
+ *
+ * @author sara
+ * @since 2023-01-03
+ */
+@RestController
+@RequestMapping("/family")
+public class FamilyController {
+
+ @Autowired
+ private FamilyService familyService;
+
+ @Autowired
+ private CommonQuery commonQuery;
+
+ /**
+ * 保存
+ */
+ @PostMapping("/saveFamily")
+ @LoginCheck
+ public PoetryResult saveFamily(@Validated @RequestBody FamilyVO familyVO) {
+ Integer userId = PoetryUtil.getUserId();
+ familyVO.setUserId(userId);
+ Family oldFamily = familyService.lambdaQuery().select(Family::getId).eq(Family::getUserId, userId).one();
+ Family family = new Family();
+ BeanUtils.copyProperties(familyVO, family);
+ if (userId.intValue() == PoetryUtil.getAdminUser().getId().intValue()) {
+ family.setStatus(Boolean.TRUE);
+ } else {
+ family.setStatus(Boolean.FALSE);
+ }
+
+ if (oldFamily != null) {
+ family.setId(oldFamily.getId());
+ familyService.updateById(family);
+ } else {
+ family.setId(null);
+ familyService.save(family);
+ }
+ if (userId.intValue() == PoetryUtil.getAdminUser().getId().intValue()) {
+ PoetryCache.put(CommonConst.ADMIN_FAMILY, family);
+ }
+ PoetryCache.remove(CommonConst.FAMILY_LIST);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 删除
+ */
+ @GetMapping("/deleteFamily")
+ @LoginCheck(0)
+ public PoetryResult deleteFamily(@RequestParam("id") Integer id) {
+ familyService.removeById(id);
+ PoetryCache.remove(CommonConst.FAMILY_LIST);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 获取
+ */
+ @GetMapping("/getFamily")
+ @LoginCheck
+ public PoetryResult getFamily() {
+ Integer userId = PoetryUtil.getUserId();
+ Family family = familyService.lambdaQuery().eq(Family::getUserId, userId).one();
+ if (family == null) {
+ return PoetryResult.success();
+ } else {
+ FamilyVO familyVO = new FamilyVO();
+ BeanUtils.copyProperties(family, familyVO);
+ return PoetryResult.success(familyVO);
+ }
+ }
+
+ /**
+ * 获取
+ */
+ @GetMapping("/getAdminFamily")
+ public PoetryResult getAdminFamily() {
+ Family family = (Family) PoetryCache.get(CommonConst.ADMIN_FAMILY);
+ if (family == null) {
+ return PoetryResult.fail("请初始化表白墙");
+ }
+ FamilyVO familyVO = new FamilyVO();
+ BeanUtils.copyProperties(family, familyVO);
+ return PoetryResult.success(familyVO);
+ }
+
+ /**
+ * 查询随机家庭
+ */
+ @GetMapping("/listRandomFamily")
+ public PoetryResult> listRandomFamily(@RequestParam(value = "size", defaultValue = "10") Integer size) {
+ List familyList = commonQuery.getFamilyList();
+ if (familyList.size() > size) {
+ Collections.shuffle(familyList);
+ familyList = familyList.subList(0, size);
+ }
+ return PoetryResult.success(familyList);
+ }
+
+ /**
+ * 查询
+ */
+ @PostMapping("/listFamily")
+ @LoginCheck(0)
+ public PoetryResult listFamily(@RequestBody BaseRequestVO baseRequestVO) {
+ familyService.lambdaQuery()
+ .eq(baseRequestVO.getStatus() != null, Family::getStatus, baseRequestVO.getStatus())
+ .orderByDesc(Family::getCreateTime).page(baseRequestVO);
+ return PoetryResult.success(baseRequestVO);
+ }
+
+ /**
+ * 修改状态
+ */
+ @GetMapping("/changeLoveStatus")
+ @LoginCheck(0)
+ public PoetryResult changeLoveStatus(@RequestParam("id") Integer id, @RequestParam("flag") Boolean flag) {
+ familyService.lambdaUpdate().eq(Family::getId, id).set(Family::getStatus, flag).update();
+ PoetryCache.remove(CommonConst.FAMILY_LIST);
+ return PoetryResult.success();
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/FriendController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/FriendController.java
new file mode 100644
index 0000000..19f1b7c
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/FriendController.java
@@ -0,0 +1,82 @@
+package com.ld.poetry.controller;
+
+import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.aop.SaveCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.dao.ResourcePathMapper;
+import com.ld.poetry.entity.ResourcePath;
+import com.ld.poetry.utils.PoetryUtil;
+import com.ld.poetry.vo.ResourcePathVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 资源聚合里的友链，其他接口在ResourceAggregationController
+ *
+ *
+ * @author sara
+ * @since 2021-09-14
+ */
+@RestController
+@RequestMapping("/webInfo")
+public class FriendController {
+
+ @Autowired
+ private ResourcePathMapper resourcePathMapper;
+
+ /**
+ * 保存友链
+ */
+ @LoginCheck
+ @PostMapping("/saveFriend")
+ @SaveCheck
+ public PoetryResult saveFriend(@RequestBody ResourcePathVO resourcePathVO) {
+ if (!StringUtils.hasText(resourcePathVO.getTitle()) || !StringUtils.hasText(resourcePathVO.getCover()) ||
+ !StringUtils.hasText(resourcePathVO.getUrl()) || !StringUtils.hasText(resourcePathVO.getIntroduction())) {
+ return PoetryResult.fail("信息不全！");
+ }
+ ResourcePath friend = new ResourcePath();
+ friend.setClassify(CommonConst.DEFAULT_FRIEND);
+ friend.setTitle(resourcePathVO.getTitle());
+ friend.setIntroduction(resourcePathVO.getIntroduction());
+ friend.setCover(resourcePathVO.getCover());
+ friend.setUrl(resourcePathVO.getUrl());
+ friend.setRemark(PoetryUtil.getUserId().toString());
+ friend.setType(CommonConst.RESOURCE_PATH_TYPE_FRIEND);
+ friend.setStatus(Boolean.FALSE);
+ resourcePathMapper.insert(friend);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 查询友链
+ */
+ @GetMapping("/listFriend")
+ public PoetryResult>> listFriend() {
+ LambdaQueryChainWrapper wrapper = new LambdaQueryChainWrapper<>(resourcePathMapper);
+ List resourcePaths = wrapper.eq(ResourcePath::getType, CommonConst.RESOURCE_PATH_TYPE_FRIEND)
+ .eq(ResourcePath::getStatus, Boolean.TRUE)
+ .orderByAsc(ResourcePath::getCreateTime)
+ .list();
+ Map> collect = new HashMap<>();
+ if (!CollectionUtils.isEmpty(resourcePaths)) {
+ collect = resourcePaths.stream().map(rp -> {
+ ResourcePathVO resourcePathVO = new ResourcePathVO();
+ BeanUtils.copyProperties(rp, resourcePathVO);
+ return resourcePathVO;
+ }).collect(Collectors.groupingBy(ResourcePathVO::getClassify));
+ }
+ return PoetryResult.success(collect);
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/MusicController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/MusicController.java
new file mode 100644
index 0000000..538dd95
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/MusicController.java
@@ -0,0 +1,68 @@
+package com.ld.poetry.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.aop.SaveCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.dao.ResourcePathMapper;
+import com.ld.poetry.entity.ResourcePath;
+import com.ld.poetry.vo.ResourcePathVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ *
+ * 资源聚合里的音乐，其他接口在ResourceAggregationController
+ *
+ *
+ * @author sara
+ * @since 2021-09-14
+ */
+@RestController
+@RequestMapping("/webInfo")
+public class MusicController {
+
+ @Autowired
+ private ResourcePathMapper resourcePathMapper;
+
+ /**
+ * 查询音乐
+ */
+ @GetMapping("/listFunny")
+ public PoetryResult>> listFunny() {
+ QueryWrapper queryWrapper = new QueryWrapper<>();
+ queryWrapper.select("classify, count(*) as count")
+ .eq("status", Boolean.TRUE)
+ .eq("type", CommonConst.RESOURCE_PATH_TYPE_FUNNY)
+ .groupBy("classify");
+ List> maps = resourcePathMapper.selectMaps(queryWrapper);
+ return PoetryResult.success(maps);
+ }
+
+ /**
+ * 保存音乐
+ */
+ @LoginCheck
+ @SaveCheck
+ @PostMapping("/saveFunny")
+ public PoetryResult saveFunny(@RequestBody ResourcePathVO resourcePathVO) {
+ if (!StringUtils.hasText(resourcePathVO.getClassify()) || !StringUtils.hasText(resourcePathVO.getCover()) ||
+ !StringUtils.hasText(resourcePathVO.getUrl()) || !StringUtils.hasText(resourcePathVO.getTitle())) {
+ return PoetryResult.fail("信息不全！");
+ }
+ ResourcePath funny = new ResourcePath();
+ funny.setClassify(resourcePathVO.getClassify());
+ funny.setTitle(resourcePathVO.getTitle());
+ funny.setCover(resourcePathVO.getCover());
+ funny.setUrl(resourcePathVO.getUrl());
+ funny.setType(CommonConst.RESOURCE_PATH_TYPE_FUNNY);
+ funny.setStatus(Boolean.FALSE);
+ resourcePathMapper.insert(funny);
+ return PoetryResult.success();
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/PictureController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/PictureController.java
new file mode 100644
index 0000000..62cc24e
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/PictureController.java
@@ -0,0 +1,73 @@
+package com.ld.poetry.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.aop.SaveCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.dao.ResourcePathMapper;
+import com.ld.poetry.entity.ResourcePath;
+import com.ld.poetry.utils.PoetryUtil;
+import com.ld.poetry.vo.ResourcePathVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+/**
+ *
+ * 资源聚合里的图片，其他接口在ResourceAggregationController
+ *
+ *
+ * @author sara
+ * @since 2021-09-14
+ */
+@RestController
+@RequestMapping("/webInfo")
+public class PictureController {
+
+ @Autowired
+ private ResourcePathMapper resourcePathMapper;
+
+ /**
+ * 查询爱情
+ */
+ @GetMapping("/listAdminLovePhoto")
+ public PoetryResult>> listAdminLovePhoto() {
+ QueryWrapper queryWrapper = new QueryWrapper<>();
+ queryWrapper.select("classify, count(*) as count")
+ .eq("status", Boolean.TRUE)
+ .eq("remark", PoetryUtil.getAdminUser().getId().toString())
+ .eq("type", CommonConst.RESOURCE_PATH_TYPE_LOVE_PHOTO)
+ .groupBy("classify");
+ List> maps = resourcePathMapper.selectMaps(queryWrapper);
+
+ return PoetryResult.success(maps);
+ }
+
+ /**
+ * 保存爱情
+ */
+ @LoginCheck
+ @SaveCheck
+ @PostMapping("/saveLovePhoto")
+ public PoetryResult saveLovePhoto(@RequestBody ResourcePathVO resourcePathVO) {
+ if (!StringUtils.hasText(resourcePathVO.getClassify()) || !StringUtils.hasText(resourcePathVO.getCover()) ||
+ !StringUtils.hasText(resourcePathVO.getTitle())) {
+ return PoetryResult.fail("信息不全！");
+ }
+ ResourcePath lovePhoto = new ResourcePath();
+ lovePhoto.setClassify(resourcePathVO.getClassify());
+ lovePhoto.setTitle(resourcePathVO.getTitle());
+ lovePhoto.setCover(resourcePathVO.getCover());
+ lovePhoto.setRemark(PoetryUtil.getUserId().toString());
+ lovePhoto.setType(CommonConst.RESOURCE_PATH_TYPE_LOVE_PHOTO);
+ lovePhoto.setStatus(Boolean.FALSE);
+ resourcePathMapper.insert(lovePhoto);
+ return PoetryResult.success();
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/QiniuController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/QiniuController.java
new file mode 100644
index 0000000..fb69409
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/QiniuController.java
@@ -0,0 +1,34 @@
+package com.ld.poetry.controller;
+
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.aop.SaveCheck;
+import com.ld.poetry.utils.storage.QiniuUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 七牛云
+ */
+@RestController
+@RequestMapping("/qiniu")
+@ConditionalOnBean(QiniuUtil.class)
+public class QiniuController {
+
+ @Autowired
+ private QiniuUtil qiniuUtil;
+
+ /**
+ * 获取覆盖凭证，用于七牛云
+ */
+ @GetMapping("/getUpToken")
+ @LoginCheck
+ @SaveCheck
+ public PoetryResult getUpToken(@RequestParam(value = "key") String key) {
+ return PoetryResult.success(qiniuUtil.getToken(key));
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ResourceAggregationController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ResourceAggregationController.java
new file mode 100644
index 0000000..17db3ca
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ResourceAggregationController.java
@@ -0,0 +1,126 @@
+package com.ld.poetry.controller;
+
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.metadata.OrderItem;
+import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.dao.ResourcePathMapper;
+import com.ld.poetry.entity.ResourcePath;
+import com.ld.poetry.utils.PoetryUtil;
+import com.ld.poetry.vo.BaseRequestVO;
+import com.ld.poetry.vo.ResourcePathVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 资源聚合 前端控制器
+ *
+ *
+ * @author sara
+ * @since 2021-09-14
+ */
+@RestController
+@RequestMapping("/webInfo")
+public class ResourceAggregationController {
+
+ @Autowired
+ private ResourcePathMapper resourcePathMapper;
+
+ /**
+ * 保存
+ */
+ @LoginCheck(0)
+ @PostMapping("/saveResourcePath")
+ public PoetryResult saveResourcePath(@RequestBody ResourcePathVO resourcePathVO) {
+ if (!StringUtils.hasText(resourcePathVO.getTitle()) || !StringUtils.hasText(resourcePathVO.getType())) {
+ return PoetryResult.fail("标题和资源类型不能为空！");
+ }
+ if (CommonConst.RESOURCE_PATH_TYPE_LOVE_PHOTO.equals(resourcePathVO.getType())) {
+ resourcePathVO.setRemark(PoetryUtil.getAdminUser().getId().toString());
+ }
+ ResourcePath resourcePath = new ResourcePath();
+ BeanUtils.copyProperties(resourcePathVO, resourcePath);
+ resourcePathMapper.insert(resourcePath);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 删除
+ */
+ @GetMapping("/deleteResourcePath")
+ @LoginCheck(0)
+ public PoetryResult deleteResourcePath(@RequestParam("id") Integer id) {
+ resourcePathMapper.deleteById(id);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 更新
+ */
+ @PostMapping("/updateResourcePath")
+ @LoginCheck(0)
+ public PoetryResult updateResourcePath(@RequestBody ResourcePathVO resourcePathVO) {
+ if (!StringUtils.hasText(resourcePathVO.getTitle()) || !StringUtils.hasText(resourcePathVO.getType())) {
+ return PoetryResult.fail("标题和资源类型不能为空！");
+ }
+ if (resourcePathVO.getId() == null) {
+ return PoetryResult.fail("Id不能为空！");
+ }
+ if (CommonConst.RESOURCE_PATH_TYPE_LOVE_PHOTO.equals(resourcePathVO.getType())) {
+ resourcePathVO.setRemark(PoetryUtil.getAdminUser().getId().toString());
+ }
+ ResourcePath resourcePath = new ResourcePath();
+ BeanUtils.copyProperties(resourcePathVO, resourcePath);
+ resourcePathMapper.updateById(resourcePath);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 查询资源
+ */
+ @PostMapping("/listResourcePath")
+ public PoetryResult listResourcePath(@RequestBody BaseRequestVO baseRequestVO) {
+ LambdaQueryChainWrapper wrapper = new LambdaQueryChainWrapper<>(resourcePathMapper);
+ wrapper.eq(StringUtils.hasText(baseRequestVO.getResourceType()), ResourcePath::getType, baseRequestVO.getResourceType());
+ wrapper.eq(StringUtils.hasText(baseRequestVO.getClassify()), ResourcePath::getClassify, baseRequestVO.getClassify());
+
+ Integer userId = PoetryUtil.getUserId();
+ if (!PoetryUtil.getAdminUser().getId().equals(userId)) {
+ wrapper.eq(ResourcePath::getStatus, Boolean.TRUE);
+ } else {
+ wrapper.eq(baseRequestVO.getStatus() != null, ResourcePath::getStatus, baseRequestVO.getStatus());
+ }
+
+ OrderItem orderItem = new OrderItem();
+ orderItem.setColumn(StringUtils.hasText(baseRequestVO.getOrder()) ? StrUtil.toUnderlineCase(baseRequestVO.getOrder()) : "create_time");
+ orderItem.setAsc(!baseRequestVO.isDesc());
+ List orderItemList = new ArrayList<>();
+ orderItemList.add(orderItem);
+ baseRequestVO.setOrders(orderItemList);
+
+ wrapper.page(baseRequestVO);
+
+ List resourcePaths = baseRequestVO.getRecords();
+ if (!CollectionUtils.isEmpty(resourcePaths)) {
+ List resourcePathVOs = resourcePaths.stream().map(rp -> {
+ ResourcePathVO resourcePathVO = new ResourcePathVO();
+ BeanUtils.copyProperties(rp, resourcePathVO);
+ return resourcePathVO;
+ }).collect(Collectors.toList());
+ baseRequestVO.setRecords(resourcePathVOs);
+ }
+ return PoetryResult.success(baseRequestVO);
+ }
+}
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ResourceController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ResourceController.java
new file mode 100644
index 0000000..35b2a71
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/ResourceController.java
@@ -0,0 +1,144 @@
+package com.ld.poetry.controller;
+
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.entity.Resource;
+import com.ld.poetry.enums.PoetryEnum;
+import com.ld.poetry.service.ResourceService;
+import com.ld.poetry.utils.storage.StoreService;
+import com.ld.poetry.utils.*;
+import com.ld.poetry.utils.storage.FileStorageService;
+import com.ld.poetry.vo.BaseRequestVO;
+import com.ld.poetry.vo.FileVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 资源信息 前端控制器
+ *
+ *
+ * @author sara
+ * @since 2022-03-06
+ */
+@RestController
+@RequestMapping("/resource")
+public class ResourceController {
+
+ @Autowired
+ private ResourceService resourceService;
+
+ @Autowired
+ private FileStorageService fileStorageService;
+
+ /**
+ * 保存
+ */
+ @PostMapping("/saveResource")
+ @LoginCheck
+ public PoetryResult saveResource(@RequestBody Resource resource) {
+ if (!StringUtils.hasText(resource.getType()) || !StringUtils.hasText(resource.getPath())) {
+ return PoetryResult.fail("资源类型和资源路径不能为空！");
+ }
+ Resource re = new Resource();
+ re.setPath(resource.getPath());
+ re.setType(resource.getType());
+ re.setSize(resource.getSize());
+ re.setOriginalName(resource.getOriginalName());
+ re.setMimeType(resource.getMimeType());
+ re.setStoreType(resource.getStoreType());
+ re.setUserId(PoetryUtil.getUserId());
+ resourceService.save(re);
+ return PoetryResult.success();
+ }
+
+ /**
+ * 上传文件
+ */
+ @PostMapping("/upload")
+ @LoginCheck
+ public PoetryResult upload(@RequestParam("file") MultipartFile file, FileVO fileVO) {
+ if (file == null || !StringUtils.hasText(fileVO.getType()) || !StringUtils.hasText(fileVO.getRelativePath())) {
+ return PoetryResult.fail("文件和资源类型和资源路径不能为空！");
+ }
+
+ fileVO.setFile(file);
+ StoreService storeService = fileStorageService.getFileStorage(fileVO.getStoreType());
+ FileVO result = storeService.saveFile(fileVO);
+
+ Resource re = new Resource();
+ re.setPath(result.getVisitPath());
+ re.setType(fileVO.getType());
+ re.setSize(Integer.valueOf(Long.toString(file.getSize())));
+ re.setMimeType(file.getContentType());
+ re.setStoreType(fileVO.getStoreType());
+ re.setOriginalName(fileVO.getOriginalName());
+ re.setUserId(PoetryUtil.getUserId());
+ resourceService.save(re);
+ return PoetryResult.success(result.getVisitPath());
+ }
+
+ /**
+ * 删除
+ */
+ @PostMapping("/deleteResource")
+ @LoginCheck(0)
+ public PoetryResult deleteResource(@RequestParam("path") String path) {
+ Resource resource = resourceService.lambdaQuery().select(Resource::getStoreType).eq(Resource::getPath, path).one();
+ if (resource == null) {
+ return PoetryResult.fail("文件不存在：" + path);
+ }
+
+ StoreService storeService = fileStorageService.getFileStorageByStoreType(resource.getStoreType());
+ storeService.deleteFile(Collections.singletonList(path));
+ return PoetryResult.success();
+ }
+
+ /**
+ * 查询表情包
+ */
+ @GetMapping("/getImageList")
+ @LoginCheck
+ public PoetryResult> getImageList() {
+ List list = resourceService.lambdaQuery().select(Resource::getPath)
+ .eq(Resource::getType, CommonConst.PATH_TYPE_INTERNET_MEME)
+ .eq(Resource::getStatus, PoetryEnum.STATUS_ENABLE.getCode())
+ .eq(Resource::getUserId, PoetryUtil.getAdminUser().getId())
+ .orderByDesc(Resource::getCreateTime)
+ .list();
+ List paths = list.stream().map(Resource::getPath).collect(Collectors.toList());
+ return PoetryResult.success(paths);
+ }
+
+ /**
+ * 查询资源
+ */
+ @PostMapping("/listResource")
+ @LoginCheck(0)
+ public PoetryResult listResource(@RequestBody BaseRequestVO baseRequestVO) {
+ resourceService.lambdaQuery()
+ .eq(StringUtils.hasText(baseRequestVO.getResourceType()), Resource::getType, baseRequestVO.getResourceType())
+ .orderByDesc(Resource::getCreateTime).page(baseRequestVO);
+ return PoetryResult.success(baseRequestVO);
+ }
+
+ /**
+ * 修改资源状态
+ */
+ @GetMapping("/changeResourceStatus")
+ @LoginCheck(0)
+ public PoetryResult changeResourceStatus(@RequestParam("id") Integer id, @RequestParam("flag") Boolean flag) {
+ resourceService.lambdaUpdate().eq(Resource::getId, id).set(Resource::getStatus, flag).update();
+ return PoetryResult.success();
+ }
+}
+
diff --git a/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/SortLabelController.java b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/SortLabelController.java
new file mode 100644
index 0000000..2c93cba
--- /dev/null
+++ b/poetize-server/poetry-web/src/main/java/com/ld/poetry/controller/SortLabelController.java
@@ -0,0 +1,161 @@
+package com.ld.poetry.controller;
+
+import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+import com.ld.poetry.aop.LoginCheck;
+import com.ld.poetry.config.PoetryResult;
+import com.ld.poetry.constants.CommonConst;
+import com.ld.poetry.dao.LabelMapper;
+import com.ld.poetry.dao.SortMapper;
+import com.ld.poetry.entity.Label;
+import com.ld.poetry.entity.Sort;
+import com.ld.poetry.utils.CommonQuery;
+import com.ld.poetry.utils.cache.PoetryCache;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ *
+ * 分类标签 前端控制器
+ *
+ *
+ * @author sara
+ * @since 2021-09-14
+ */
+@RestController
+@RequestMapping("/webInfo")
+public class SortLabelController {
+
+ @Autowired
+ private SortMapper sortMapper;
+
+ @Autowired
+ private LabelMapper labelMapper;
+
+ @Autowired
+ private CommonQuery commonQuery;
+
+ /**
+ * 获取分类标签信息
+ */
+ @GetMapping("/getSortInfo")
+ public PoetryResult> getSortInfo() {
+ return PoetryResult.success(commonQuery.getSortInfo());
+ }
+
+ /**
+ * 保存
+ */
+ @PostMapping("/saveSort")
+ @LoginCheck(0)
+ public PoetryResult saveSort(@RequestBody Sort sort) {
+ if (!StringUtils.hasText(sort.getSortName()) || !StringUtils.hasText(sort.getSortDescription())) {
+ return PoetryResult.fail("分类名称和分类描述不能为空！");
+ }
+
+ if (sort.getPriority() == null) {
+ return PoetryResult.fail("分类必须配置优先级！");
+ }
+
+ sortMapper.insert(sort);
+ PoetryCache.remove(CommonConst.SORT_INFO);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 删除
+ */
+ @GetMapping("/deleteSort")
+ @LoginCheck(0)
+ public PoetryResult deleteSort(@RequestParam("id") Integer id) {
+ sortMapper.deleteById(id);
+ PoetryCache.remove(CommonConst.SORT_INFO);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 更新
+ */
+ @PostMapping("/updateSort")
+ @LoginCheck(0)
+ public PoetryResult updateSort(@RequestBody Sort sort) {
+ sortMapper.updateById(sort);
+ PoetryCache.remove(CommonConst.SORT_INFO);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 查询List
+ */
+ @GetMapping("/listSort")
+ public PoetryResult> listSort() {
+ return PoetryResult.success(new LambdaQueryChainWrapper<>(sortMapper).list());
+ }
+
+
+ /**
+ * 保存
+ */
+ @PostMapping("/saveLabel")
+ @LoginCheck(0)
+ public PoetryResult saveLabel(@RequestBody Label label) {
+ if (!StringUtils.hasText(label.getLabelName()) || !StringUtils.hasText(label.getLabelDescription()) || label.getSortId() == null) {
+ return PoetryResult.fail("标签名称和标签描述和分类Id不能为空！");
+ }
+ labelMapper.insert(label);
+ PoetryCache.remove(CommonConst.SORT_INFO);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 删除
+ */
+ @GetMapping("/deleteLabel")
+ @LoginCheck(0)
+ public PoetryResult deleteLabel(@RequestParam("id") Integer id) {
+ labelMapper.deleteById(id);
+ PoetryCache.remove(CommonConst.SORT_INFO);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 更新
+ */
+ @PostMapping("/updateLabel")
+ @LoginCheck(0)
+ public PoetryResult updateLabel(@RequestBody Label label) {
+ labelMapper.updateById(label);
+ PoetryCache.remove(CommonConst.SORT_INFO);
+ return PoetryResult.success();
+ }
+
+
+ /**
+ * 查询List
+ */
+ @GetMapping("/listLabel")
+ public PoetryResult> listLabel() {
+ return PoetryResult.success(new LambdaQueryChainWrapper<>(labelMapper).list());
+ }
+
+
+ /**
+ * 查询List
+ */
+ @GetMapping("/listSortAndLabel")
+ public PoetryResult