Parcourir la source

plan-java v0.31

(cherry picked from commit 8e5f076cc8f4872fd36987405b806a99657eba2e)
MOKASZ\lw12420 il y a 2 ans
Parent
commit
93a4d4d324

+ 23 - 21
launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/PlanNewController.java

@@ -458,7 +458,12 @@ public class PlanNewController {
                         saveRequest.getBackgroundGroupIdNewAdd()
                 )).flatMap(map -> template.update(map));
 
-        Mono<PlanNew> map = plan_new_id.map(f -> {
+
+
+        Mono<PlanNew> map = plan_new_id.map(f->{
+            template.delete(Query.query(Criteria.where("plan_new_id").is(f.planNewId())),PlanNewBackgroupPoster.class).subscribe();
+            return f;
+        }).map(f -> {
             List<ServiceGroupSettingItemRequest> backgroupFxSetting = saveRequest.getBackgroupFxSetting();
             backgroupFxSetting.forEach(fx -> fxBackgroupSettingsUpdate(fx, f.planNewId(), 1));
             List<ServiceGroupSettingItemRequest> backgroupQsSetting = saveRequest.getBackgroupQsSetting();
@@ -469,26 +474,23 @@ public class PlanNewController {
 
     }
     public void fxBackgroupSettingsUpdate( ServiceGroupSettingItemRequest request,Long planNewId,Integer qsOrFx){
-        template.selectOne(Query.query(Criteria.where("id").is(request.getId())), PlanNewBackgroupPoster.class).map(m->{
-            PlanNewBackgroupPoster planNewBackgroupPoster = new PlanNewBackgroupPoster(request.getId(),
-                    request.getAudioId(),
-                    request.getGroupId(),
-                    request.getImage(),
-                    request.getKefu(),
-                    request.getLimitTime(),
-                    request.getLimitTimeRemark(),
-                    request.getStatus(),
-                    request.getIndex(),
-                    request.getServiceGroupId(),
-                    request.getServiceGroupType(),
-                    qsOrFx,
-                    m.createdAt(),
-                    ZonedDateTime.now(),
-                    null,
-                    planNewId,null,null);
-            template.update(planNewBackgroupPoster);
-            return m;
-        });
+        PlanNewBackgroupPoster planNewBackgroupPoster = new PlanNewBackgroupPoster(request.getId(),
+                request.getAudioId(),
+                request.getGroupId(),
+                request.getImage(),
+                request.getKefu(),
+                request.getLimitTime(),
+                request.getLimitTimeRemark(),
+                request.getStatus(),
+                request.getIndex(),
+                request.getServiceGroupId(),
+                request.getServiceGroupType(),
+                qsOrFx,
+                ZonedDateTime.now(),
+                ZonedDateTime.now(),
+                null,
+                planNewId,null,null);
+        template.insert(planNewBackgroupPoster).subscribe();
 
     }
     /**