假视频 广告 v0.06

(cherry picked from commit 570cfb8817a571bc8ed5491b19a0edcda82901f1)

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

@@ -2,6 +2,7 @@ package com.webflux.launchadmin.mysql.service.sourceMaterial.materialManagement;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONArray;
 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.sourceMaterial.data.BackgroupGroup.*;
@@ -552,17 +553,13 @@ public class MaterialManagementImpl implements MaterialManagementInterface {
         Mono<Boolean> then = Flux.fromIterable(list).flatMap(item ->
                 {
                     AlbumItem albumItem = new AlbumItem(null, item.getUrl(), item.getStatus());
-                    return albumItemRepository.save(albumItem)
-                            .flatMap(f->{
-                                System.out.println("f.id()");
-                                System.out.println(f.id());
-                                return   Mono.just(f);
-                            })
-                            //  template.insert(new AlbumItem(null, item.getUrl(), item.getStatus()))
+                    return //albumItemRepository.save(albumItem)
+                              template.insert(albumItem)
                             //albumItemRepository.save(new AlbumItem(null, item.getUrl(), item.getStatus()))
                             .flatMap(f->{
                                 return albumItemInterface.saveMysqlAndRedisCache(f)
-                                        .onErrorResume(throwable -> Mono.error(new BaseException("cache-"+throwable.getMessage()+"--"+JSONUtil.toJsonStr(f))));
+                                        .onErrorResume(throwable ->
+                                                Mono.error(new BaseException("cache-"+throwable.getMessage()+"------"+f.id())));
                             });
                 }
         )