假视频 广告 v0.07

(cherry picked from commit b28891d196700daf37919ccbb1ec7424d2e04f4c)

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

@@ -557,7 +557,7 @@ public class MaterialManagementImpl implements MaterialManagementInterface {
                               template.insert(albumItem)
                             //albumItemRepository.save(new AlbumItem(null, item.getUrl(), item.getStatus()))
                             .flatMap(f->{
-                                return albumItemInterface.saveMysqlAndRedisCache(f)
+                                return albumItemInterface.saveMysqlAndRedisCache(f.id(),f)
                                         .onErrorResume(throwable ->
                                                 Mono.error(new BaseException("cache-"+throwable.getMessage()+"------"+f.id())));
                             });
@@ -594,7 +594,9 @@ public class MaterialManagementImpl implements MaterialManagementInterface {
             }
             return then.then(Flux.fromIterable(list).flatMap(item -> albumItemRepository
                     .save(new AlbumItem(null, item.getUrl(), item.getStatus()))
-                    .flatMap(albumItemInterface::saveMysqlAndRedisCache))
+                    .flatMap(f->{
+                      return   albumItemInterface.saveMysqlAndRedisCache(f.id(),f);
+                    }))
                     .collectList().switchIfEmpty(Mono.just(List.of()))
                     .flatMap(items -> {
                         Album albumNew = new Album(albumReq.getAlbumId(),

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

@@ -21,8 +21,8 @@ public class AlbumItemService implements AlbumItemInterface {
     private AlbumItemRepository albumItemRepository;
 
     @Override
-    @CachePut(cacheNames = MaterialManagementRedisKey.ALBUMITEM, key = "#albumItem.id()")
-    public Mono<AlbumItem> saveMysqlAndRedisCache(AlbumItem albumItem) {
+    @CachePut(cacheNames = MaterialManagementRedisKey.ALBUMITEM, key = "#id")
+    public Mono<AlbumItem> saveMysqlAndRedisCache(Long id,AlbumItem albumItem) {
         return Mono.just(albumItem);
     }
 

launch-admin/src/main/java/com/webflux/launchadmin/mysql/service/sourceMaterial/materialManagement/redisCache/interfacelist/AlbumItemInterface.java

@@ -5,7 +5,7 @@ import com.webflux.launchadmin.mysql.entity.sourceMaterial.AlbumItem;
 import reactor.core.publisher.Mono;
 
 public interface AlbumItemInterface {
-    Mono<AlbumItem> saveMysqlAndRedisCache(AlbumItem albumItem);
+    Mono<AlbumItem> saveMysqlAndRedisCache(Long id,AlbumItem albumItem);
     Mono<Void> deleteMysqlAndRedisCache(Long id);
     Mono<AlbumItem> getRedisOrMysql(Long id);
 }