plan-java v0.01

(cherry picked from commit fbe289ed5f5bbcdf9c0b63f43ea466253668f50a)

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

@@ -0,0 +1,332 @@
+package com.webflux.launchadmin.mysql.controller.planNew;
+
+import com.webflux.launchadmin.config.BaseContextHandler;
+import com.webflux.launchadmin.mysql.controller.lbOut.resp.DataList;
+import com.webflux.launchadmin.mysql.controller.planNew.req.*;
+import com.webflux.launchadmin.mysql.entity.lb.HomePageTempItem;
+import com.webflux.launchadmin.mysql.entity.planNew.*;
+import com.webflux.launchcommon.returnObj.Paged;
+import com.webflux.launchcommon.returnObj.RStatus;
+import jakarta.annotation.Resource;
+import jakarta.validation.constraints.NotNull;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.relational.core.query.Criteria;
+import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
+import org.springframework.data.relational.core.query.Query;
+import org.springframework.data.relational.core.query.Update;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Mono;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * 计划
+ * @author lw12420
+ * @date 2024/05/21
+ */
+@RestController
+@RequestMapping("in/planNew")
+public class PlanNewController {
+    @Resource
+    private R2dbcEntityTemplate template;
+
+
+
+
+
+
+    /**
+     * 返回广告下拉名称模糊查询
+     * @param request
+     * @return {@link Mono}<{@link RStatus}<{@link Long}>>
+     */
+    @GetMapping("retrunloopSlt")
+    public Mono<RStatus<List<ReturnLoop>>> retrunloopSlt (@RequestBody ReturnLoopRequest request){
+        Criteria criteria= Criteria.empty() ; //poster_template_id
+        if (Objects.nonNull(request.getName()) && "" != request.getName()) {
+            criteria = criteria.and("name").like(request.getName());
+        }
+        Mono<List<ReturnLoop>> listMono = template.select(Query.query(criteria), ReturnLoop.class).collectList();
+        return RStatus.success(listMono);
+    }
+    /**
+     * 背景组设置下拉名称模糊查询
+     * @param backgroupRequest
+     * @return {@link Mono}<{@link RStatus}<{@link Long}>>
+     */
+    @GetMapping("backgroupSlt")
+    public Mono<RStatus<List<BackgroupImage>>> backgroupSlt (@RequestBody BackgroupRequest backgroupRequest){
+        Criteria criteria= Criteria.empty() ; //poster_template_id
+        if (Objects.nonNull(backgroupRequest.getName()) && "" != backgroupRequest.getName()) {
+            criteria = criteria.and("name").like(backgroupRequest.getName());
+        }
+        Mono<List<BackgroupImage>> listMono = template.select(Query.query(criteria), BackgroupImage.class).collectList();
+        return RStatus.success(listMono);
+    }
+    /**
+     * 音频下拉名称模糊查询
+     * @param audioRequest
+     * @return {@link Mono}<{@link RStatus}<{@link Long}>>
+     */
+    @GetMapping("audioSlt")
+    public Mono<RStatus<List<Audio>>> audio (@RequestBody AudioRequest audioRequest){
+        Criteria criteria= Criteria.empty() ; //poster_template_id
+        if (Objects.nonNull(audioRequest.getName()) && "" != audioRequest.getName()) {
+            criteria = criteria.and("name").like(audioRequest.getName());
+        }
+        Mono<List<Audio>> listMono = template.select(Query.query(criteria), Audio.class).collectList();
+        return RStatus.success(listMono);
+    }
+
+    /**
+     * 海报保存
+     * @param posterRequset
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @PostMapping("savePoster")
+    public Mono<RStatus<Poster>> savePoster(@RequestBody PosterRequest posterRequset){
+        Poster poster = new Poster(null, posterRequset.getPosterTemplateId()
+                ,posterRequset.getPosterTemplate(), BaseContextHandler.getUserName(),
+                BaseContextHandler.getUserId(), ZonedDateTime.now(),
+                ZonedDateTime.now());
+        Mono<Poster> insert = template.insert(poster);
+        return RStatus.success(insert);
+
+    }
+
+    /**
+     * 海报修改
+     * @param posterRequset
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @PostMapping("updatePoster")
+    public Mono<RStatus<Long>> updatePoster(@RequestBody PosterRequest posterRequset){
+
+        Criteria empty = Criteria.where("poster_id").is(posterRequset.getPosterId());
+        Update update = Update.update("updated_at", ZonedDateTime.now());
+        if(Objects.nonNull(posterRequset.getPosterTemplate()) && !"".equals(posterRequset.getPosterTemplate())){
+            update.set("poster_template",posterRequset.getPosterTemplate());
+        }
+        Mono<Long> update1 = template.update(Query.query(empty), update, Poster.class);
+        return  RStatus.success(update1);
+    }
+
+    /**
+     * 海报删除
+     * @param posterId
+     * @return {@link Mono}<{@link RStatus}<{@link Long}>>
+     */
+    @DeleteMapping("deletePosterById/{posterId}")
+    public Mono<RStatus<Long>> deletePosterById (@PathVariable("posterId")  @NotNull Long posterId){
+        Mono<Long> plan_new_id = template.delete(Query.query(Criteria.where("poster_id").is(posterId)), Poster.class);
+        return RStatus.success(plan_new_id);
+    }
+
+    /**
+     * 海报模版保存
+     * @param posterTemplateRequset
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @PostMapping("savePosterTem")
+    public Mono<RStatus<PosterTemplate>> savePosterTem(@RequestBody PosterTemplateRequset posterTemplateRequset){
+        PosterTemplate posterTemplate = new PosterTemplate(null, posterTemplateRequset.getPosterTemplateName(), BaseContextHandler.getUserName(),
+                BaseContextHandler.getUserId(), ZonedDateTime.now(),
+                ZonedDateTime.now());
+        Mono<PosterTemplate> insert = template.insert(posterTemplate);
+        return RStatus.success(insert);
+
+    }
+    /**
+     * 海报模版修改
+     * @param posterTemplateRequset
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @PostMapping("updatePosterTem")
+    public Mono<RStatus<Long>> updatePosterTem(@RequestBody PosterTemplateRequset posterTemplateRequset){
+
+        Criteria empty = Criteria.where("poster_template_id").is(posterTemplateRequset.getPosterTemplateId());
+        Update update = Update.update("updated_at", ZonedDateTime.now());
+        if(Objects.nonNull(posterTemplateRequset.getPosterTemplateName()) && !"".equals(posterTemplateRequset.getPosterTemplateName())){
+            update.set("poster_template_name",posterTemplateRequset.getPosterTemplateName());
+        }
+        Mono<Long> update1 = template.update(Query.query(empty), update, PosterTemplate.class);
+        return  RStatus.success(update1);
+    }
+    /**
+     * 海报模版删除
+     * @param posterTemplateId
+     * @return {@link Mono}<{@link RStatus}<{@link Long}>>
+     */
+    @DeleteMapping("deletePosterTemById/{posterTemplateId}")
+    public Mono<RStatus<Long>> deletePosterTemById (@PathVariable("posterTemplateId")  @NotNull Long posterTemplateId){
+        Mono<Long> plan_new_id = template.delete(Query.query(Criteria.where("poster_template_id").is(posterTemplateId)), PosterTemplate.class);
+        return RStatus.success(plan_new_id);
+    }
+
+
+    /**
+     * 计划保存
+     * @param saveRequest
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @PostMapping("savePlan")
+    public Mono<RStatus<PlanNew>> savePlan(@RequestBody PlanReq saveRequest){
+        PlanNew plan = new PlanNew(null,
+                saveRequest.getName(),
+                BaseContextHandler.getUserName(),
+                BaseContextHandler.getUserId(),
+                ZonedDateTime.now(),
+                ZonedDateTime.now(),
+                null,
+                saveRequest.getType(),
+                saveRequest.getCode(),
+                saveRequest.getGroupId(),
+                saveRequest.getPosterTemplateId(),
+                saveRequest.getPageShow(),
+                saveRequest.getPageLine(),
+                saveRequest.getCount(),
+                saveRequest.getListAudioId(),
+                saveRequest.getRetAudioId(),
+                saveRequest.getLink(),
+                saveRequest.getIsAddQun(),
+                saveRequest.getBackgroundGroupId(),
+                saveRequest.getHomePageId(),
+                saveRequest.getTopAdvNum(),
+                saveRequest.getBottomAdvNum(),
+                saveRequest.getReturnLoopId()
+        );
+        Mono<PlanNew> insert = template.insert(plan);
+        return  RStatus.success(insert);
+    }
+
+    /**
+     * 修改计划
+     * @param saveRequest
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @PostMapping("updatePlan")
+    public Mono<RStatus<PlanNew>> updatePlan(@RequestBody PlanReq saveRequest){
+        Mono<PlanNew> plan_new_id = template.selectOne(Query.query(Criteria.where("plan_new_id").is(saveRequest.getPlanNewId())), PlanNew.class)
+                .map(map -> new PlanNew(saveRequest.getPlanNewId(),
+                        saveRequest.getName(),
+                        map.createUser(),
+                        map.createId(),
+                        map.createdAt(),
+                        ZonedDateTime.now(),
+                        map.deletedAt(),
+                        saveRequest.getType(),
+                        saveRequest.getCode(),
+                        saveRequest.getGroupId(),
+                        saveRequest.getPosterTemplateId(),
+                        saveRequest.getPageShow(),
+                        saveRequest.getPageLine(),
+                        saveRequest.getCount(),
+                        saveRequest.getListAudioId(),
+                        saveRequest.getRetAudioId(),
+                        saveRequest.getLink(),
+                        saveRequest.getIsAddQun(),
+                        saveRequest.getBackgroundGroupId(),
+                        saveRequest.getHomePageId(),
+                        saveRequest.getTopAdvNum(),
+                        saveRequest.getBottomAdvNum(),
+                        saveRequest.getReturnLoopId()
+                )).map(map -> {
+                    template.update(map);
+                    return map;
+                });
+        return RStatus.success(plan_new_id);
+
+    }
+
+    /**
+     * 复制计划
+     * @param planNewId
+     * @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
+     */
+    @GetMapping("copyById/{planNewId}")
+    public Mono<RStatus<PlanNew>> copyById (@PathVariable("planNewId")  @NotNull Long planNewId){
+        Mono<PlanNew> plan_new_id = template.selectOne(Query.query(Criteria.where("plan_new_id").is(planNewId)), PlanNew.class)
+                .map(saveRequest -> new PlanNew(saveRequest.planNewId(),
+                        saveRequest.name(),
+                        BaseContextHandler.getUserName(),
+                        BaseContextHandler.getUserId(),
+                        ZonedDateTime.now(),
+                        ZonedDateTime.now(),
+                        null,
+                        saveRequest.type(),
+                        saveRequest.code(),
+                        saveRequest.groupId(),
+                        saveRequest.posterTemplateId(),
+                        saveRequest.pageShow(),
+                        saveRequest.pageLine(),
+                        saveRequest.count(),
+                        saveRequest.listAudioId(),
+                        saveRequest.retAudioId(),
+                        saveRequest.link(),
+                        saveRequest.isAddQun(),
+                        saveRequest.backgroundGroupId(),
+                        saveRequest.homePageId(),
+                        saveRequest.topAdvNum(),
+                        saveRequest.bottomAdvNum(),
+                        saveRequest.returnLoopId()
+                )).map(map -> {
+                    template.update(map);
+                    return map;
+                });
+        return RStatus.success(plan_new_id);
+    }
+
+    /**
+     * 删除计划
+     * @param planNewId
+     * @return {@link Mono}<{@link RStatus}<{@link Long}>>
+     */
+    @DeleteMapping("deleteById/{planNewId}")
+    public Mono<RStatus<Long>> deleteById (@PathVariable("planNewId")  @NotNull Long planNewId){
+        Mono<Long> plan_new_id = template.delete(Query.query(Criteria.where("plan_new_id").is(planNewId)), PlanNew.class);
+        return RStatus.success(plan_new_id);
+    }
+    /**
+     * 计划列表
+     * @param request
+     * @return {@link Mono}<{@link RStatus}<{@link Paged}<{@link PlanNew}>>>
+     */
+    @PostMapping("planList")
+    public Mono<RStatus<Paged<PlanNew>>> page(@RequestBody PlanReqPage request)   {
+        Criteria criteria= Criteria.empty() ; //poster_template_id
+        if (Objects.nonNull(request.getCode()) && "" != request.getCode()) {
+            criteria = criteria.and("code").is(request.getCode());
+        }
+        if (Objects.nonNull(request.getName()) && "" != request.getName()) {
+            criteria = criteria.and("name").is(request.getName());
+        }
+        if (Objects.nonNull(request.getCreateUser()) && "" != request.getCreateUser()) {
+            criteria = criteria.and("create_user").like(request.getCreateUser());
+        }
+        if (Objects.nonNull(request.getPosterTemplateId()) && 0L != request.getPosterTemplateId()) {
+            criteria = criteria.and("poster_template_id").is(request.getPosterTemplateId());
+        }
+        if (Objects.nonNull(request.getType()) && 0L != request.getType()) {
+            criteria = criteria.and("type").is(request.getType());
+        }
+        Query query = Query.query(criteria);
+        Criteria finalCriteria = criteria;
+        int skip  = (request.getPage() - 1) * request.getSize();
+        int limit = request.getPage() * request.getSize();
+        Mono<Paged<PlanNew>> pagedMono = template.count(query, PlanNew.class).flatMap(fm ->
+                template.select(Query.query(finalCriteria)
+                        .offset(skip)
+                        .limit(limit)
+                        .sort(Sort.by(Sort.Order.desc("create_time"))),PlanNew.class)
+                        .collectList()
+                        .map(list -> new Paged<>(fm, list,request.getPage(),request.getSize()))
+        );
+        return RStatus.successList(pagedMono);
+    }
+
+
+
+
+}

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

@@ -0,0 +1,43 @@
+package com.webflux.launchadmin.mysql.controller.planNew;
+
+import com.webflux.launchadmin.config.BaseContextHandler;
+import com.webflux.launchadmin.mysql.controller.lbOut.request.HomePageItemOutRequest;
+import com.webflux.launchadmin.mysql.controller.lbOut.resp.DataList;
+import com.webflux.launchadmin.mysql.controller.planNew.req.*;
+import com.webflux.launchadmin.mysql.entity.lb.HomePageTempItem;
+import com.webflux.launchadmin.mysql.entity.planNew.*;
+import com.webflux.launchcommon.returnObj.Paged;
+import com.webflux.launchcommon.returnObj.RStatus;
+import jakarta.annotation.Resource;
+import jakarta.validation.constraints.NotNull;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
+import org.springframework.data.relational.core.query.Criteria;
+import org.springframework.data.relational.core.query.Query;
+import org.springframework.data.relational.core.query.Update;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Mono;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * 计划
+ * @author lw12420
+ * @date 2024/05/21
+ */
+@RestController
+@RequestMapping("out/planNew")
+public class PlanNewOutController {
+    @Resource
+    private R2dbcEntityTemplate template;
+
+
+//    @PostMapping("pageTempItem")
+//    public Mono<RStatus<DataList<HomePageTempItem>>> pageTempItem(@RequestBody HomePageItemOutRequest request){
+//
+//    }
+
+
+}

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

@@ -0,0 +1,8 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+
+import lombok.Data;
+
+@Data
+public class AudioRequest {
+    private String  name;
+}

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

@@ -0,0 +1,8 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+
+import lombok.Data;
+
+@Data
+public class BackgroupRequest {
+    private String  name;
+}

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

@@ -0,0 +1,78 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+import lombok.Data;
+
+@Data
+public class PlanReq {
+
+    private Long planNewId;
+    /**
+     * 计划名
+     */
+    private String name; //计划名
+//    private String createUser;
+//    private String createId;
+    /**
+     * // 1加群裂变2短剧裂变3会话裂变4红包裂变5小说裂变
+     */
+    private  Integer type;
+    /**
+     *
+     */
+    private  String code;
+    /**
+     *分类id
+     */
+    private Long  groupId; //分类id
+    /**
+     *海报id
+     */
+    private  Long posterTemplateId;//海报id
+    /**
+     *群数量
+     */
+    private  Integer pageShow;//群数量
+    /**
+     *单行数量
+     */
+    private Integer pageLine;//单行数量
+    /**
+     *清水分类/展示次数
+     */
+    private Integer count;//清水分类/展示次数
+    /**
+     *列表音频id
+     */
+    private Long listAudioId;//	列表音频id
+    /**
+     *返回音频id
+     */
+    private  Long retAudioId;//返回音频id
+    /**
+     *入群链接
+     */
+    private String link;//入群链接
+    /**
+     *加群确认页开关
+     */
+    private Boolean  isAddQun;//加群确认页开关
+    /**
+     *背景组id
+     */
+    private Long backgroundGroupId;//背景组id
+    /**
+     *首页模版id
+     */
+    private  Long homePageId;//首页模版id
+    /**
+     *顶部广告 -1 false  其他true
+     */
+    private Integer topAdvNum;//顶部广告 -1 false  其他true
+    /**
+     *底部广告 -1 false  其他true
+     */
+    private Integer bottomAdvNum;//	底部广告 -1 false  其他true
+    /**
+     *返回广告 -1 false  其他true
+     */
+    private Long returnLoopId;//	返回广告 -1 false  其他true
+}

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

@@ -0,0 +1,18 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+import lombok.Data;
+
+@Data
+public class PlanReqPage {
+
+
+    private Integer page;
+    private Integer size;
+
+
+    private String name; //计划名
+    private String createUser;
+    private  Integer type;// 1加群裂变2短剧裂变3会话裂变4红包裂变5小说裂变
+    private  String code;
+    private  Long posterTemplateId;//海报id
+
+}

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

@@ -0,0 +1,9 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+
+import lombok.Data;
+
+@Data
+public class PosterReq {
+   private Long posterTemplateId;
+   private String posterTemplate;
+}

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

@@ -0,0 +1,17 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+
+import lombok.Data;
+
+@Data
+public class PosterRequest {
+
+   private Long posterId;
+    /**
+     * 模版Id
+     */
+   private Long posterTemplateId;
+    /**
+     * 内容
+     */
+   private String posterTemplate;
+}

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

@@ -0,0 +1,13 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+
+import lombok.Data;
+
+@Data
+public class PosterTemplateRequset {
+
+    private Long posterTemplateId;
+    /**
+     * 海报模板名称
+     */
+    private String    posterTemplateName;//
+}

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

@@ -0,0 +1,8 @@
+package com.webflux.launchadmin.mysql.controller.planNew.req;
+
+import lombok.Data;
+
+@Data
+public class ReturnLoopRequest {
+    private String  name;
+}

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

@@ -0,0 +1,9 @@
+package com.webflux.launchadmin.mysql.controller.planNew.res;
+
+import java.util.List;
+
+public record DataList<T,E,R>(
+        List<T> audio,
+        List<E> backgroupImage,
+        List<R> backgroupImageItem) {
+}

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

@@ -0,0 +1,13 @@
+package com.webflux.launchadmin.mysql.controller.planNew.res;
+
+import com.webflux.launchadmin.mysql.entity.planNew.Audio;
+import com.webflux.launchadmin.mysql.entity.planNew.PlanNew;
+
+public class DataLists {
+    private PlanNew planNew;
+    /**
+     * 列表音频
+     */
+    private Audio audioList;
+
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/Audio.java

@@ -0,0 +1,20 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.time.ZonedDateTime;
+@Table("audio")
+public record Audio(@Id Long id,
+                    String url,
+                    String createUser,
+                    String name,
+                    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime createdAt,
+                    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime updatedAt,
+                    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime deletedAt,
+
+                    Integer type
+                    ) {
+
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/BackgroupImage.java

@@ -0,0 +1,23 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.time.ZonedDateTime;
+
+@Table("bacigroup_image")
+public record BackgroupImage(
+        @Id Long id,
+        String name,
+        String createUser,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime createdAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime updatedAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime deletedAt,
+        Boolean groupType,
+        String groupTypeName,
+        Integer groupTypeId
+
+) {
+
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/BackgroupImageItem.java

@@ -0,0 +1,11 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+@Table("backgroup_image_item")
+public record BackgroupImageItem(@Id Long id,
+                                 String image,
+                                 Integer index,
+                                 Long groupId) {
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/PlanNew.java

@@ -0,0 +1,37 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.time.ZonedDateTime;
+
+@Table("plan_new")
+public record PlanNew(
+        @Id
+        Long planNewId,
+        String name, //计划名
+        String createUser,
+        String createId,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime createdAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime updatedAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime deletedAt,
+        Integer type,// 1加群裂变2短剧裂变3会话裂变4红包裂变5小说裂变
+        String code,
+        Long  groupId, //分类id
+        Long posterTemplateId,//海报id
+        Integer pageShow,//群数量
+        Integer pageLine,//单行数量
+        Integer count,//清水分类/展示次数
+        Long listAudioId,//	列表音频id
+        Long retAudioId,//返回音频id
+        String link,//入群链接
+        Boolean  isAddQun,//加群确认页开关
+        Long backgroundGroupId,//背景组id
+        Long homePageId,//首页模版id
+        Integer topAdvNum,//顶部广告 -1 false  其他true
+        Integer bottomAdvNum,//	底部广告 -1 false  其他true
+        Long returnLoopId//	返回广告 -1 false  其他true
+
+) {
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/Poster.java

@@ -0,0 +1,19 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.time.ZonedDateTime;
+
+@Table("plan_new_poster")
+public record Poster(
+        @Id  Long posterId,
+        Long posterTemplateId,
+        String posterTemplate,
+        String createUser,
+        String createId,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime createdAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime updatedAt
+) {
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/PosterTemplate.java

@@ -0,0 +1,20 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.time.ZonedDateTime;
+
+@Table("plan_new_poster_template")
+public record PosterTemplate(
+        @Id Long posterTemplateId,
+        String posterTemplateName,//海报模板名称
+        String createUser,
+        String createId,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime createdAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime updatedAt
+
+) {
+}
+

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/ReturnLoop.java

@@ -0,0 +1,28 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.r2dbc.spi.Parameter;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+import java.time.ZonedDateTime;
+
+@Table("return_loop")
+public record ReturnLoop(
+        @Id Long id,
+        String name,
+        String createUser,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime createdAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime updatedAt,
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") ZonedDateTime deletedAt,
+        Boolean groupType, //	类型 1素材分类2清水分类
+        String groupTypeName,
+        Integer groupTypeId,
+        Integer isShowList,
+        String returnList,
+        Integer returnNumber,
+        Integer type,
+        Integer domainId
+) {
+
+}