From 47efb98ace2e67443fd4064cbfd22b059808a095 Mon Sep 17 00:00:00 2001
From: cloudroam <cloudroam>
Date: 星期四, 19 六月 2025 14:08:31 +0800
Subject: [PATCH] add:影视作品补充
---
src/main/java/com/mzl/flower/service/film/impl/FilmWorksServiceImpl.java | 161 ++++++++++++++++++++++++++++++++++++----
src/main/java/com/mzl/flower/mapper/film/FilmWorksMapper.java | 3
src/main/java/com/mzl/flower/entity/film/FilmWorks.java | 3
src/main/java/com/mzl/flower/web/film/FilmWorksController.java | 20 +++++
src/main/java/com/mzl/flower/constant/Constants.java | 9 ++
src/main/java/com/mzl/flower/service/film/FilmWorksService.java | 6 +
6 files changed, 183 insertions(+), 19 deletions(-)
diff --git a/src/main/java/com/mzl/flower/constant/Constants.java b/src/main/java/com/mzl/flower/constant/Constants.java
index 3f5e67b..0a0114e 100644
--- a/src/main/java/com/mzl/flower/constant/Constants.java
+++ b/src/main/java/com/mzl/flower/constant/Constants.java
@@ -68,8 +68,17 @@
}
public enum COMMON_PUBLISH_STATUS {
+ pending_create("待生成"),
+
+ create_failed("生成失败"), // 生成内容失败
+
published("已发布"),
unpublished("未发布"),
+ pending_review("待审核"), // 生成内容成功
+
+ approved("审核通过"),
+
+ rejected("审核驳回"),
;
COMMON_PUBLISH_STATUS(String desc) {
diff --git a/src/main/java/com/mzl/flower/entity/film/FilmWorks.java b/src/main/java/com/mzl/flower/entity/film/FilmWorks.java
index 24ea4c8..bbf25de 100644
--- a/src/main/java/com/mzl/flower/entity/film/FilmWorks.java
+++ b/src/main/java/com/mzl/flower/entity/film/FilmWorks.java
@@ -122,10 +122,9 @@
// 生成的文章内容
private String filmContent;
-
// 生成的图片
private String filmPictures;
-
+ private LocalDate auditDate;
}
diff --git a/src/main/java/com/mzl/flower/mapper/film/FilmWorksMapper.java b/src/main/java/com/mzl/flower/mapper/film/FilmWorksMapper.java
index e259f11..c792a10 100644
--- a/src/main/java/com/mzl/flower/mapper/film/FilmWorksMapper.java
+++ b/src/main/java/com/mzl/flower/mapper/film/FilmWorksMapper.java
@@ -30,4 +30,7 @@
//获取权重最高的数据
@Select("select * from film_works where sticky_weight = (select max(sticky_weight) from film_works) limit 1")
FilmWorks getTopStickyWeight();
+
+ @Select("select * from film_works where deleted = '0' and status = 'pending_create'")
+ List<FilmWorksVO> pendingCreate();
}
diff --git a/src/main/java/com/mzl/flower/service/film/FilmWorksService.java b/src/main/java/com/mzl/flower/service/film/FilmWorksService.java
index 1601e45..99ab182 100644
--- a/src/main/java/com/mzl/flower/service/film/FilmWorksService.java
+++ b/src/main/java/com/mzl/flower/service/film/FilmWorksService.java
@@ -28,6 +28,8 @@
Page<FilmWorksVO> queryPage(FilmWorksQueryDTO filmWorksQueryDTO, Page page);
List<FilmWorksVO> getFilmWorksAll();
+
+ List<FilmWorksVO> pendingCreate();
void changeStatus(Long id);
@@ -40,4 +42,8 @@
void batchPublish(BatchDTO dto);
FilmWorksVO detail(Long id);
+
+ void batchApproved(BatchDTO dto);
+
+ void batchRejected(BatchDTO dto);
}
diff --git a/src/main/java/com/mzl/flower/service/film/impl/FilmWorksServiceImpl.java b/src/main/java/com/mzl/flower/service/film/impl/FilmWorksServiceImpl.java
index 6abea29..397ee89 100644
--- a/src/main/java/com/mzl/flower/service/film/impl/FilmWorksServiceImpl.java
+++ b/src/main/java/com/mzl/flower/service/film/impl/FilmWorksServiceImpl.java
@@ -11,11 +11,14 @@
import com.mzl.flower.dto.request.system.UserInfoDTO;
import com.mzl.flower.dto.response.customer.CustomerDTO;
import com.mzl.flower.dto.response.film.FilmWorksVO;
+import com.mzl.flower.dto.response.system.MenuTreeDTO;
import com.mzl.flower.entity.film.FilmWorks;
+import com.mzl.flower.entity.system.Role;
import com.mzl.flower.mapper.customer.CustomerMapper;
import com.mzl.flower.mapper.film.FilmWorksMapper;
import com.mzl.flower.service.film.FilmWorksService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mzl.flower.service.system.RoleService;
import com.mzl.flower.utils.DateUtils;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
@@ -25,6 +28,7 @@
import org.springframework.util.ObjectUtils;
import java.time.LocalDate;
+import java.util.ArrayList;
import java.util.List;
/**
@@ -42,31 +46,63 @@
private final FilmWorksMapper filmWorksMapper;
private final CustomerMapper customerMapper;
+ private final RoleService roleService;
@Override
public void saveFilmWorks(FilmWorksDTO filmWorksDTO) {
+ //获取当前人员角色，判断是不是编辑角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("8f9ef89f6b2d4d8e9ea1fc8d2f25ce69")) {
+ throw new ValidationException("非编辑角色不能新增");
+ }
// 转换
FilmWorks filmWorks = new FilmWorks();
BeanUtils.copyProperties(filmWorksDTO, filmWorks);
filmWorks.create();
- filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.unpublished.name());
+ filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_review.name());
filmWorksMapper.insert(filmWorks);
}
@Override
public void updateFilmWorks(FilmWorksDTO filmWorksDTO) {
- FilmWorks filmWork = filmWorksMapper.selectById(filmWorksDTO.getId());
FilmWorks filmWorks = new FilmWorks();
- BeanUtils.copyProperties(filmWorksDTO,filmWorks);
+ //系统生成的内容无需管理
+ if ("sys".equals(filmWorksDTO.getType())) {
+ filmWorks = filmWorksMapper.selectById(filmWorksDTO.getId());
+ filmWorks.setFilmContent(filmWorksDTO.getFilmContent());
+ //生成之后变成待审核
+ if(StringUtils.isNotBlank(filmWorks.getFilmContent())){
+ filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_review.name());
+ }else{
+ filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.create_failed.name());
+ }
- if (filmWork != null) {
- filmWorks.setClassify(filmWork.getClassify());
- filmWorks.setCreateBy(filmWork.getCreateBy());
- filmWorks.setCreateTime(filmWork.getCreateTime());
- filmWorks.setStatus(filmWork.getStatus());
+ } else {
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("8f9ef89f6b2d4d8e9ea1fc8d2f25ce69")) {
+ throw new ValidationException("非编辑角色不能修改");
+ }
+ filmWorks = filmWorksMapper.selectById(filmWorksDTO.getId());
+ //判断影视作品状态
+ if(Constants.COMMON_PUBLISH_STATUS.published.name().equals(filmWorks.getStatus()) ){
+ throw new ValidationException("发布作品不能编辑");
+ }
+
+ if(Constants.COMMON_PUBLISH_STATUS.approved.name().equals(filmWorks.getStatus()) ){
+ throw new ValidationException("审核作品不能编辑");
+ }
+ BeanUtils.copyProperties(filmWorksDTO, filmWorks);
+ filmWorks.update(SecurityUtils.getUserId());
+ filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_review.name());
}
-
- filmWorks.update(SecurityUtils.getUserId());
filmWorksMapper.updateById(filmWorks);
}
@@ -98,7 +134,6 @@
} catch (Exception e) {
dto.setUserId(null);
}
-
List<FilmWorksVO> list = filmWorksMapper.queryPage(dto,page);
page.setRecords(list);
@@ -112,23 +147,50 @@
}
@Override
+ public List<FilmWorksVO> pendingCreate() {
+ return filmWorksMapper.pendingCreate();
+ }
+
+ @Override
public void changeStatus(Long id) {
+ //获取当前人员角色，判断是不是审核角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("77462b362bad4c88a7a5c64cbdd25d91")) {
+ throw new ValidationException("非运营角色不能发布");
+ }
FilmWorks filmWork = filmWorksMapper.selectById(id);
if (filmWork == null) {
throw new ValidationException("找不到id为" + id + "的公告");
}
- if (Constants.COMMON_PUBLISH_STATUS.published.name().equals(filmWork.getStatus())) {
- filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.unpublished.name());
- } else {
- filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.published.name());
- filmWork.setPublishDate(LocalDate.now());
+ if (Constants.COMMON_PUBLISH_STATUS.approved.name().equals(filmWork.getStatus()) || Constants.COMMON_PUBLISH_STATUS.published.name().equals(filmWork.getStatus()) || Constants.COMMON_PUBLISH_STATUS.unpublished.name().equals(filmWork.getStatus())) {
+ if (Constants.COMMON_PUBLISH_STATUS.published.name().equals(filmWork.getStatus())) {
+ filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.unpublished.name());
+ } else {
+ filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.published.name());
+ filmWork.setPublishDate(LocalDate.now());
+ }
+ filmWorksMapper.updateById(filmWork);
+ }else{
+ throw new ValidationException("非审核通过或者发布状态，不能操作");
}
- filmWorksMapper.updateById(filmWork);
}
@Override
public void changeTopState(Long id) {
+ //获取当前人员角色，判断是不是审核角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("77462b362bad4c88a7a5c64cbdd25d91")) {
+ throw new ValidationException("非运营角色不能置顶");
+ }
FilmWorks filmWork = filmWorksMapper.selectById(id);
if (filmWork == null) {
throw new ValidationException("找不到id为" + id + "的公告");
@@ -149,6 +211,15 @@
@Override
public void changeDownState(Long id) {
+ //获取当前人员角色，判断是不是审核角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("77462b362bad4c88a7a5c64cbdd25d91")) {
+ throw new ValidationException("非运营角色不能清除权重");
+ }
FilmWorks filmWork = filmWorksMapper.selectById(id);
if (filmWork == null) {
throw new ValidationException("找不到id为" + id + "的公告");
@@ -167,6 +238,16 @@
@Override
public void batchPublish(BatchDTO dto) {
+ //获取当前人员角色，判断是不是审核角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("77462b362bad4c88a7a5c64cbdd25d91")) {
+ throw new ValidationException("非运营角色不能发布");
+ }
+
List<FilmWorks> list = filmWorksMapper.selectList(new LambdaQueryWrapper<FilmWorks>().in(FilmWorks::getId, dto.getIds()));
for (FilmWorks filmWork : list) {
filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.published.name());
@@ -189,4 +270,50 @@
filmWorksVO.setAvatar(currentCustomer.getCover());
return filmWorksVO;
}
+
+ @Override
+ public void batchApproved(BatchDTO dto) {
+ //获取当前人员角色，判断是不是审核角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("86a36a0b789c4d0e840f7b807c09459b")) {
+ throw new ValidationException("非审核角色不能审批");
+ }
+ List<FilmWorks> list = filmWorksMapper.selectList(new LambdaQueryWrapper<FilmWorks>().in(FilmWorks::getId, dto.getIds()));
+ //判断所有的状态都是待审核
+ if (!list.stream().allMatch(filmWork -> Constants.COMMON_PUBLISH_STATUS.pending_review.name().equals(filmWork.getStatus()) || Constants.COMMON_PUBLISH_STATUS.rejected.name().equals(filmWork.getStatus()))) {
+ throw new ValidationException("只有待审核或者审核拒绝的才能批量审核");
+ }
+ for (FilmWorks filmWork : list) {
+ filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.approved.name());
+ filmWork.setAuditDate(LocalDate.now());
+ filmWorksMapper.updateById(filmWork);
+ }
+ }
+
+ @Override
+ public void batchRejected(BatchDTO dto) {
+ //获取当前人员角色，判断是不是审核角色
+ List<String> roleIds = new ArrayList<>();
+ List<Role> roleList = roleService.getUserRoleList(SecurityUtils.getUserId());
+ for (Role role : roleList) {
+ roleIds.add(role.getId());
+ }
+ if (!roleIds.contains("86a36a0b789c4d0e840f7b807c09459b")) {
+ throw new ValidationException("非审核角色不能审批");
+ }
+ List<FilmWorks> list = filmWorksMapper.selectList(new LambdaQueryWrapper<FilmWorks>().in(FilmWorks::getId, dto.getIds()));
+ //判断所有的状态都是待审核或者审核通过
+ if (!list.stream().allMatch(filmWork -> Constants.COMMON_PUBLISH_STATUS.pending_review.name().equals(filmWork.getStatus()) || Constants.COMMON_PUBLISH_STATUS.approved.name().equals(filmWork.getStatus()))) {
+ throw new ValidationException("只有待审核或者审核通过的状态才能批量审核");
+ }
+ for (FilmWorks filmWork : list) {
+ filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.rejected.name());
+ filmWork.setAuditDate(LocalDate.now());
+ filmWorksMapper.updateById(filmWork);
+ }
+ }
}
diff --git a/src/main/java/com/mzl/flower/web/film/FilmWorksController.java b/src/main/java/com/mzl/flower/web/film/FilmWorksController.java
index 1c26b3e..c0faba5 100644
--- a/src/main/java/com/mzl/flower/web/film/FilmWorksController.java
+++ b/src/main/java/com/mzl/flower/web/film/FilmWorksController.java
@@ -40,6 +40,12 @@
return returnData(R.SUCCESS.getCode(), filmWorksService.getFilmWorksAll());
}
+ @GetMapping("/filmWorks/pending/create")
+ @ApiOperation(value = "影视作品待生成列表", httpMethod = "GET")
+ public ResponseEntity<ReturnDataDTO<List<FilmWorksVO>>> pendingCreate() {
+ return returnData(R.SUCCESS.getCode(), filmWorksService.pendingCreate());
+ }
+
@GetMapping("/filmWorks/list")
@ApiOperation(value = "影视作品列表", httpMethod = "GET")
public ResponseEntity<ReturnDataDTO<Page<FilmWorksVO>>> getFilmWorksList(Page page, FilmWorksQueryDTO dto) {
@@ -105,6 +111,20 @@
return returnData(R.SUCCESS.getCode(), null);
}
+ @PostMapping("/filmWorks/approved/batch")
+ @ApiOperation(value = "批量通过", notes = "批量通过")
+ public ResponseEntity<ReturnDataDTO> batchApproved(@Validated @RequestBody BatchDTO dto) {
+ filmWorksService.batchApproved(dto);
+ return returnData(R.SUCCESS.getCode(), null);
+ }
+
+ @PostMapping("/filmWorks/rejected/batch")
+ @ApiOperation(value = "批量驳回", notes = "批量驳回")
+ public ResponseEntity<ReturnDataDTO> batchRejected(@Validated @RequestBody BatchDTO dto) {
+ filmWorksService.batchRejected(dto);
+ return returnData(R.SUCCESS.getCode(), null);
+ }
+
@GetMapping("/filmWorks/list/view")
@ApiOperation(value = "详情", notes = "详情")
public ResponseEntity<ReturnDataDTO<FilmWorksVO>> detail(@NotNull(message = "id不能为空") Long id) {
--
Gitblit v1.9.3