From 46715d892da947c31f07796fdc79dbbef06677b3 Mon Sep 17 00:00:00 2001
From: cloudroam <cloudroam>
Date: 星期一, 14 七月 2025 09:53:19 +0800
Subject: [PATCH] add:定时任务配置,热门城市

---
 src/main/java/com/mzl/flower/service/film/impl/FilmWorksServiceImpl.java |   60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 57 insertions(+), 3 deletions(-)

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 397ee89..f777319 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
@@ -27,6 +27,9 @@
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.ObjectUtils;
 
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
 import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.List;
@@ -59,11 +62,16 @@
         if (!roleIds.contains("8f9ef89f6b2d4d8e9ea1fc8d2f25ce69")) {
             throw new ValidationException("非编辑角色不能新增");
         }
+        // 判断系统是否存在重复的名称+类型+年份,如果有就不保存
+        FilmWorks filmWorksByName = filmWorksMapper.getFilmWorksByName(filmWorksDTO.getNameCn(), filmWorksDTO.getType(), filmWorksDTO.getReleaseYear());
+        if (!ObjectUtils.isEmpty(filmWorksByName)) {
+            throw new ValidationException("系统已存在名称为【" + filmWorksDTO.getNameCn() + "】,类型为【" + filmWorksDTO.getType() + "】,年份为【" + filmWorksDTO.getReleaseYear() + "】的影视作品");
+        }
         //  转换
         FilmWorks filmWorks = new FilmWorks();
         BeanUtils.copyProperties(filmWorksDTO, filmWorks);
         filmWorks.create();
-        filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_review.name());
+        filmWorks.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_create.name());
         filmWorksMapper.insert(filmWorks);
     }
 
@@ -135,6 +143,18 @@
             dto.setUserId(null);
         }
         List<FilmWorksVO> list =  filmWorksMapper.queryPage(dto,page);
+        // 测试前端展示用代码,部署发布不适用
+//        list.forEach(l->{
+//            if (l.getCoverUrl().contains("doubanio")) {
+//                String encodedUrl = null;
+//                try {
+//                    encodedUrl = URLEncoder.encode(l.getCoverUrl(), String.valueOf(StandardCharsets.UTF_8));
+//                } catch (UnsupportedEncodingException e) {
+//                    throw new RuntimeException(e);
+//                }
+//                l.setCoverUrl("https://images.weserv.nl/?url=" + encodedUrl);
+//            }
+//        });
         page.setRecords(list);
 
 
@@ -176,6 +196,37 @@
             filmWorksMapper.updateById(filmWork);
         }else{
             throw new ValidationException("非审核通过或者发布状态,不能操作");
+        }
+    }
+
+
+    @Override
+    public void changeCreateStatus(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("8f9ef89f6b2d4d8e9ea1fc8d2f25ce69")) {
+            throw new ValidationException("非编辑角色不能操作");
+        }
+        FilmWorks filmWork = filmWorksMapper.selectById(id);
+        if (filmWork == null) {
+            throw new ValidationException("找不到id为" + id + "的作品");
+        }
+        if (Constants.COMMON_PUBLISH_STATUS.pending_create.name().equals(filmWork.getStatus()) || Constants.COMMON_PUBLISH_STATUS.create_cancel.name().equals(filmWork.getStatus()) || Constants.COMMON_PUBLISH_STATUS.create_failed.name().equals(filmWork.getStatus())) {
+            if (Constants.COMMON_PUBLISH_STATUS.create_cancel.name().equals(filmWork.getStatus())) {
+                filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_create.name());
+            } else if (Constants.COMMON_PUBLISH_STATUS.create_failed.name().equals(filmWork.getStatus())) {
+                filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.pending_create.name());
+            } else {
+                filmWork.setStatus(Constants.COMMON_PUBLISH_STATUS.create_cancel.name());
+                filmWork.setPublishDate(LocalDate.now());
+            }
+            filmWorksMapper.updateById(filmWork);
+        }else{
+            throw new ValidationException("当前状态,不能操作");
         }
     }
 
@@ -266,8 +317,11 @@
             return null;
         }
         CustomerDTO currentCustomer = customerMapper.getCurrentCustomer(filmWorksVO.getCreateBy());
-        filmWorksVO.setNickname(currentCustomer.getNickName());
-        filmWorksVO.setAvatar(currentCustomer.getCover());
+        if(!ObjectUtils.isEmpty(currentCustomer)){
+            filmWorksVO.setNickname(currentCustomer.getNickName());
+            filmWorksVO.setAvatar(currentCustomer.getCover());
+        }
+
         return filmWorksVO;
     }
 

--
Gitblit v1.9.3