假视频 广告 v0.10

(cherry picked from commit d9a760c33c81653d5ed565abba5aa9f93edfc370)

launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/AlbumOutController.java

@@ -0,0 +1,29 @@
+package com.webflux.launchadmin.mysql.controller.planNew;
+
+import com.webflux.launchadmin.mysql.controller.planNew.res.AlbumDataRes;
+import com.webflux.launchadmin.mysql.service.sourceMaterial.materialManagement.MaterialManagementInterface;
+import com.webflux.launchcommon.returnObj.RStatus;
+import jakarta.annotation.Resource;
+import jakarta.validation.constraints.NotNull;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping("out/album")
+public class AlbumOutController {
+
+    @Resource
+    private MaterialManagementInterface sourceMaterialInterface;
+
+
+    /**
+     * 相册根据id获取信息
+     * @param id
+     * @return {@link Mono}<{@link RStatus}<{@link AlbumDataRes}>>
+     */
+    @GetMapping("info/{id}")
+    public Mono<RStatus<AlbumDataRes>> infoOut(@PathVariable("id") @NotNull Long[] id){
+        Mono<AlbumDataRes> mono= sourceMaterialInterface.infoOut(id);
+        return RStatus.success(mono);
+    }
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/res/AlbumDataRes.java

@@ -0,0 +1,10 @@
+package com.webflux.launchadmin.mysql.controller.planNew.res;
+
+import com.webflux.launchadmin.mysql.controller.sourceMaterial.data.album.AlbumReq;
+import lombok.Data;
+
+import java.util.List;
+@Data
+public class AlbumDataRes {
+    private List<AlbumReq> albumList;
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/service/sourceMaterial/materialManagement/MaterialManagementImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.webflux.launchadmin.config.BaseContextHandler;
 import com.webflux.launchadmin.global.BaseException;
+import com.webflux.launchadmin.mysql.controller.planNew.res.AlbumDataRes;
 import com.webflux.launchadmin.mysql.controller.sourceMaterial.data.BackgroupGroup.*;
 import com.webflux.launchadmin.mysql.controller.sourceMaterial.data.album.AlbumDto;
 import com.webflux.launchadmin.mysql.controller.sourceMaterial.data.album.AlbumItemReq;
@@ -549,6 +550,19 @@ public class MaterialManagementImpl implements MaterialManagementInterface {
         });
         return RStatus.success(booleanMono);
     }
+
+    @Override
+    public Mono<AlbumDataRes> infoOut(Long[] ids) {
+        if (Objects.isNull(ids) || ids.length == 0) {
+            return Mono.error(new BaseException("请求参数异常"));
+        }
+        return Flux.fromIterable(List.of(ids)).flatMap(this::infoAlbum).collectList().flatMap(list -> {
+            AlbumDataRes albumDataRes = new AlbumDataRes();
+            albumDataRes.setAlbumList(list);
+            return Mono.just(albumDataRes);
+        });
+    }
+
     private Mono<RStatus<Boolean>> addAlbum(AlbumReq albumReq, String userName, String userId, List<AlbumItemReq> list) {
         Mono<Boolean> then = Flux.fromIterable(list).flatMap(item ->
                 {

launch-admin/src/main/java/com/webflux/launchadmin/mysql/service/sourceMaterial/materialManagement/MaterialManagementInterface.java

@@ -1,5 +1,6 @@
 package com.webflux.launchadmin.mysql.service.sourceMaterial.materialManagement;
 
+import com.webflux.launchadmin.mysql.controller.planNew.res.AlbumDataRes;
 import com.webflux.launchadmin.mysql.controller.planNew.res.BackgroupImageRes;
 import com.webflux.launchadmin.mysql.controller.sourceMaterial.data.BackgroupGroup.*;
 import com.webflux.launchadmin.mysql.controller.sourceMaterial.data.album.AlbumDto;
@@ -74,4 +75,6 @@ public interface MaterialManagementInterface {
     Mono<AlbumReq> infoAlbum(Long id);
 
     Mono<RStatus<Boolean>> deleteAlbum(Long id);
+
+    Mono<AlbumDataRes> infoOut(Long[] id);
 }