|
|
@@ -33,6 +33,7 @@ import org.springframework.data.relational.core.query.Update;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
import reactor.core.publisher.Flux;
|
|
|
import reactor.core.publisher.Mono;
|
|
|
+
|
|
|
import java.time.ZonedDateTime;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Comparator;
|
|
|
@@ -43,13 +44,14 @@ import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* 计划
|
|
|
+ *
|
|
|
* @author lw12420
|
|
|
* @date 2024/05/21
|
|
|
*/
|
|
|
@RestController
|
|
|
@RequestMapping("in/planNew")
|
|
|
public class PlanNewController {
|
|
|
- //一天时间
|
|
|
+ // 一天时间
|
|
|
@Resource
|
|
|
private R2dbcEntityTemplate template;
|
|
|
|
|
|
@@ -61,27 +63,26 @@ public class PlanNewController {
|
|
|
private PlanServiceInterface planServiceInterface;
|
|
|
|
|
|
@GetMapping("tt")
|
|
|
- public String tt(){
|
|
|
- String str="{\"item\": [{\"a\": \"left\", \"c\": \"rgba(0, 0, 0, 1)\", \"h\": 20, \"s\": 14, \"t\": \"title\", \"v\": \"群聊,本地视频推荐\", \"w\": 140, \"x\": 100, \"y\": 100, \"fn\": \"ali-Regular\", \"rm\": \"备注\", \"bgc\": \"\", \"name\": \"海报标题\", \"uuid\": \"b3a10a5e-8c17-4a37-9a99-13600328868c\", \"warp\": false, \"weight\": 500}, {\"c\": \"rgba(0, 0, 0, 1)\", \"h\": 300, \"t\": \"qrcode\", \"v\": \"\", \"w\": 300, \"x\": 87, \"y\": 172, \"fn\": \"\", \"rm\": \"备注\", \"bgc\": \"#ffffff\", \"name\": \"二维码\", \"uuid\": \"2862c036-ad07-48d4-ab34-94fbb2c46c30\"}], \"width\": 458, \"height\": 709, \"bg_img_src\": \"\"}";
|
|
|
+ public String tt() {
|
|
|
+ String str = "{\"item\": [{\"a\": \"left\", \"c\": \"rgba(0, 0, 0, 1)\", \"h\": 20, \"s\": 14, \"t\": \"title\", \"v\": \"群聊,本地视频推荐\", \"w\": 140, \"x\": 100, \"y\": 100, \"fn\": \"ali-Regular\", \"rm\": \"备注\", \"bgc\": \"\", \"name\": \"海报标题\", \"uuid\": \"b3a10a5e-8c17-4a37-9a99-13600328868c\", \"warp\": false, \"weight\": 500}, {\"c\": \"rgba(0, 0, 0, 1)\", \"h\": 300, \"t\": \"qrcode\", \"v\": \"\", \"w\": 300, \"x\": 87, \"y\": 172, \"fn\": \"\", \"rm\": \"备注\", \"bgc\": \"#ffffff\", \"name\": \"二维码\", \"uuid\": \"2862c036-ad07-48d4-ab34-94fbb2c46c30\"}], \"width\": 458, \"height\": 709, \"bg_img_src\": \"\"}";
|
|
|
|
|
|
return goGenerateService.goGenerate(str);
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
/**
|
|
|
- *
|
|
|
* 分享、清水背景组-回显
|
|
|
+ *
|
|
|
* @param planNewId 计划id
|
|
|
- * @param qsOrFx 1:营销 2:清水
|
|
|
+ * @param qsOrFx 1:营销 2:清水
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link BackgroupImageRes}>>
|
|
|
*/
|
|
|
@GetMapping("backgroupSelectOne/{type}/{planNewId}/{qsOrFx}")
|
|
|
- public Mono<RStatus<List<PlanNewBackgroupPosterAllRes>>> backgroupSelectOne(@PathVariable("type") @NotNull Integer type,
|
|
|
- @PathVariable("planNewId") String planNewId,@PathVariable("qsOrFx") Integer qsOrFx ){
|
|
|
+ public Mono<RStatus<List<PlanNewBackgroupPosterAllRes>>> backgroupSelectOne(@PathVariable("type") @NotNull Integer type,
|
|
|
+ @PathVariable("planNewId") String planNewId, @PathVariable("qsOrFx") Integer qsOrFx) {
|
|
|
if (1 == type) {
|
|
|
Mono<List<PlanNewBackgroupPosterAllRes>> listMono = template.select(Query.query(Criteria.where("plan_new_id").is(planNewId)
|
|
|
- .and("qs_or_fx").is(qsOrFx)).sort(Sort.by(Sort.Order.asc("idx"))), PlanNewBackgroupPoster.class).flatMap(request->{
|
|
|
+ .and("qs_or_fx").is(qsOrFx)).sort(Sort.by(Sort.Order.asc("idx"))), PlanNewBackgroupPoster.class).flatMap(request -> {
|
|
|
PlanNewBackgroupPosterAllRes planNewBackgroupPosterAllRes =
|
|
|
new PlanNewBackgroupPosterAllRes(request.id(),
|
|
|
request.audioId(),
|
|
|
@@ -104,8 +105,8 @@ public class PlanNewController {
|
|
|
return RStatus.successList(listMono);
|
|
|
} else if (2 == type) {
|
|
|
Mono<List<PlanNewBackgroupPosterAllRes>> listMono = template.select(Query.query(Criteria.where("listening_plan_new_id").is(planNewId)
|
|
|
- .and("qs_or_fx").is(qsOrFx))
|
|
|
- .sort(Sort.by(Sort.Order.asc("idx"))), ListeningPlanNewBackgroupPoster.class).flatMap(request->{
|
|
|
+ .and("qs_or_fx").is(qsOrFx))
|
|
|
+ .sort(Sort.by(Sort.Order.asc("idx"))), ListeningPlanNewBackgroupPoster.class).flatMap(request -> {
|
|
|
PlanNewBackgroupPosterAllRes planNewBackgroupPosterAllRes =
|
|
|
new PlanNewBackgroupPosterAllRes(request.id(),
|
|
|
request.audioId(),
|
|
|
@@ -127,18 +128,19 @@ public class PlanNewController {
|
|
|
}).collectList();
|
|
|
return RStatus.successList(listMono);
|
|
|
}
|
|
|
- throw new BaseException("type异常");
|
|
|
+ throw new BaseException("type异常");
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 背景组详情接口
|
|
|
+ *
|
|
|
* @param id 背景组id
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link DataLists}>>
|
|
|
*/
|
|
|
@GetMapping("backgroupImageRes/{id}")
|
|
|
- public Mono<RStatus<BackgroupImageRes>> backgroupImageRes(@PathVariable("id") Long id){
|
|
|
+ public Mono<RStatus<BackgroupImageRes>> backgroupImageRes(@PathVariable("id") Long id) {
|
|
|
Mono<BackgroupImage> id1 = template.selectOne(Query.query(Criteria.where("id")
|
|
|
- .is(id)), BackgroupImage.class) .switchIfEmpty(Mono.error(new BaseException(" 通过code查询结果为空")))
|
|
|
+ .is(id)), BackgroupImage.class).switchIfEmpty(Mono.error(new BaseException(" 通过code查询结果为空")))
|
|
|
.onErrorResume(throwable -> Mono.error(new Exception(throwable.getMessage())));
|
|
|
Mono<List<BackgroupImageItem>> group_id = template.select(Query.query(Criteria.where("group_id")
|
|
|
.is(id)).sort(Sort.by(Sort.Order.asc("index"))), BackgroupImageItem.class).collectList();
|
|
|
@@ -154,11 +156,12 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 客服组-下拉 ( By status)
|
|
|
+ *
|
|
|
* @param status
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link List}<{@link ReturnLoop}>>>
|
|
|
*/
|
|
|
@GetMapping("serviceGroupSlt")
|
|
|
- public Mono<RStatus<List<ServiceGroup>>> serviceGroupSlt (@RequestParam("status") Integer status){
|
|
|
+ public Mono<RStatus<List<ServiceGroup>>> serviceGroupSlt(@RequestParam("status") Integer status) {
|
|
|
Mono<List<ServiceGroup>> status1 = template.select(Query.query(Criteria.where("status")
|
|
|
.is(2)), ServiceGroup.class).collectList();
|
|
|
return RStatus.successList(status1);
|
|
|
@@ -167,56 +170,63 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 素材、清水--分类下拉(groupType)名称模糊查询
|
|
|
+ *
|
|
|
* @param name
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Long}>>
|
|
|
*/
|
|
|
@GetMapping("groupTypeSlt")
|
|
|
- public Mono<RStatus<List<GroupType>>> groupTypeSlt (@RequestParam("name") String name,@RequestParam("groupType")String groupType){
|
|
|
- Criteria criteria= Criteria.where("group_type").is(groupType);
|
|
|
+ public Mono<RStatus<List<GroupType>>> groupTypeSlt(@RequestParam("name") String name, @RequestParam("groupType") String groupType) {
|
|
|
+ Criteria criteria = Criteria.where("group_type").is(groupType);
|
|
|
if (Objects.nonNull(name) && "" != name) {
|
|
|
- criteria = criteria.and("name").like("%"+name+"%");
|
|
|
+ criteria = criteria.and("name").like("%" + name + "%");
|
|
|
}
|
|
|
Mono<List<GroupType>> listMono = template.select(Query.query(criteria), GroupType.class).collectList();
|
|
|
return RStatus.success(listMono);
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 返回广告下拉名称模糊查询
|
|
|
+ *
|
|
|
* @param name
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Long}>>
|
|
|
*/
|
|
|
@GetMapping("retrunloopSlt")
|
|
|
- public Mono<RStatus<List<ReturnLoop>>> retrunloopSlt (@RequestParam("name") String name){
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
+ public Mono<RStatus<List<ReturnLoop>>> retrunloopSlt(@RequestParam("name") String name) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
if (Objects.nonNull(name) && "" != name) {
|
|
|
- criteria = criteria.and("name").like("%"+name+"%");
|
|
|
+ criteria = criteria.and("name").like("%" + name + "%");
|
|
|
}
|
|
|
Mono<List<ReturnLoop>> listMono = template.select(Query.query(criteria), ReturnLoop.class).collectList();
|
|
|
return RStatus.success(listMono);
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* (分享/清水)背景组设置下拉名称模糊查询
|
|
|
+ *
|
|
|
* @param name groupType
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Long}>>
|
|
|
*/
|
|
|
@GetMapping("backgroupSlt")
|
|
|
- public Mono<RStatus<List<BackgroupImage>>> backgroupSlt ( @RequestParam("name") String name,@RequestParam("groupType") String groupType){
|
|
|
- Criteria criteria= Criteria.where("group_type").is(groupType) ; //poster_template_id
|
|
|
+ public Mono<RStatus<List<BackgroupImage>>> backgroupSlt(@RequestParam("name") String name, @RequestParam("groupType") String groupType) {
|
|
|
+ Criteria criteria = Criteria.where("group_type").is(groupType); // poster_template_id
|
|
|
if (Objects.nonNull(name) && "" != name) {
|
|
|
- criteria = criteria.and("name").like("%"+name+"%");
|
|
|
+ criteria = criteria.and("name").like("%" + name + "%");
|
|
|
}
|
|
|
Mono<List<BackgroupImage>> listMono = template.select(Query.query(criteria), BackgroupImage.class).collectList();
|
|
|
return RStatus.success(listMono);
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 音频下拉名称模糊查询
|
|
|
+ *
|
|
|
* @param name
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Long}>>
|
|
|
*/
|
|
|
@GetMapping("audioSlt")
|
|
|
- public Mono<RStatus<List<Audio>>> audio (@RequestParam("name") String name){
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
+ public Mono<RStatus<List<Audio>>> audio(@RequestParam("name") String name) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
if (Objects.nonNull(name) && "" != name) {
|
|
|
- criteria = criteria.and("name").like("%"+name+"%");
|
|
|
+ criteria = criteria.and("name").like("%" + name + "%");
|
|
|
}
|
|
|
Mono<List<Audio>> listMono = template.select(Query.query(criteria), Audio.class).collectList();
|
|
|
return RStatus.success(listMono);
|
|
|
@@ -224,128 +234,142 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 海报保存
|
|
|
+ *
|
|
|
* @param posterRequset
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
|
|
|
*/
|
|
|
@PostMapping("savePoster")
|
|
|
- public Mono<RStatus<Poster>> savePoster(@RequestBody PosterRequest posterRequset){
|
|
|
+ public Mono<RStatus<Poster>> savePoster(@RequestBody PosterRequest posterRequset) {
|
|
|
return goGenerateService.savePoster(posterRequset);
|
|
|
}
|
|
|
+
|
|
|
@PostMapping("test11")
|
|
|
- public Mono<String> test11(){
|
|
|
+ public Mono<String> test11() {
|
|
|
return goGenerateService.updatePoster1();
|
|
|
}
|
|
|
+
|
|
|
@PostMapping("test12")
|
|
|
- public Mono<String> test112(){
|
|
|
+ public Mono<String> test112() {
|
|
|
String string = RandomUtil.randomString("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ", 6);
|
|
|
- return Mono.just(string);//goGenerateService.updatePoster12();
|
|
|
+ return Mono.just(string);// goGenerateService.updatePoster12();
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 海报修改
|
|
|
+ *
|
|
|
* @param posterRequset
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
|
|
|
*/
|
|
|
@PostMapping("updatePoster")
|
|
|
- public Mono<RStatus<Poster>> updatePoster(@RequestBody PosterRequest posterRequset){
|
|
|
+ public Mono<RStatus<Poster>> updatePoster(@RequestBody PosterRequest posterRequset) {
|
|
|
return goGenerateService.updatePoster(posterRequset);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 海报删除
|
|
|
+ *
|
|
|
* @param posterId
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Long}>>
|
|
|
*/
|
|
|
@DeleteMapping("deletePosterById/{posterId}")
|
|
|
- public Mono<RStatus<Long>> deletePosterById (@PathVariable("posterId") @NotNull Long 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 request
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Paged}<{@link PosterTemplate}>>>
|
|
|
*/
|
|
|
@PostMapping("posterList")
|
|
|
- public Mono<RStatus<Paged<Poster>>> posterList(@RequestBody PosterPage request) {
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
+ public Mono<RStatus<Paged<Poster>>> posterList(@RequestBody PosterPage request) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
criteria = criteria.and("poster_template_id").is(request.getPosterTemplateId());
|
|
|
Query query = Query.query(criteria);
|
|
|
Criteria finalCriteria = criteria;
|
|
|
- int skip = (request.getPage() - 1) * request.getSize();
|
|
|
- int limit = request.getSize();
|
|
|
+ int skip = (request.getPage() - 1) * request.getSize();
|
|
|
+ int limit = request.getSize();
|
|
|
Mono<Paged<Poster>> pagedMono = template.count(query, Poster.class).flatMap(fm ->
|
|
|
template.select(Query.query(finalCriteria)
|
|
|
- .offset(skip)
|
|
|
- .limit(limit)
|
|
|
- .sort(Sort.by(Sort.Order.asc("created_at"))),Poster.class)
|
|
|
+ .offset(skip)
|
|
|
+ .limit(limit)
|
|
|
+ .sort(Sort.by(Sort.Order.asc("created_at"))), Poster.class)
|
|
|
.collectList()
|
|
|
- .map(list -> new Paged<>(fm, list,request.getPage(),request.getSize()))
|
|
|
+ .map(list -> new Paged<>(fm, list, request.getPage(), request.getSize()))
|
|
|
);
|
|
|
return RStatus.successList(pagedMono);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 海报模版保存
|
|
|
+ *
|
|
|
* @param posterTemplateRequset
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
|
|
|
*/
|
|
|
@PostMapping("savePosterTem")
|
|
|
- public Mono<RStatus<PosterTemplate>> savePosterTem(@RequestBody PosterTemplateRequset posterTemplateRequset){
|
|
|
+ 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){
|
|
|
+ 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= update.set("poster_template_name",posterTemplateRequset.getPosterTemplateName());
|
|
|
+ if (Objects.nonNull(posterTemplateRequset.getPosterTemplateName()) && !"".equals(posterTemplateRequset.getPosterTemplateName())) {
|
|
|
+ update = update.set("poster_template_name", posterTemplateRequset.getPosterTemplateName());
|
|
|
}
|
|
|
Mono<Long> update1 = template.update(Query.query(empty), update, PosterTemplate.class);
|
|
|
- return RStatus.success(update1);
|
|
|
+ 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){
|
|
|
+ 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 posterTemplateId
|
|
|
* @return
|
|
|
*/
|
|
|
@GetMapping("posterTem/{planNewId}")
|
|
|
- public Mono<RStatus<PosterTemplate>> posterTem(@PathVariable("posterTemplateId") @NotNull Long posterTemplateId){
|
|
|
+ public Mono<RStatus<PosterTemplate>> posterTem(@PathVariable("posterTemplateId") @NotNull Long posterTemplateId) {
|
|
|
Mono<PosterTemplate> planNewMono = template
|
|
|
.selectOne(Query.query(Criteria.where("poster_template_id")
|
|
|
- .is(posterTemplateId)), PosterTemplate.class);
|
|
|
+ .is(posterTemplateId)), PosterTemplate.class);
|
|
|
return RStatus.success(planNewMono);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 海报模版下拉
|
|
|
+ *
|
|
|
* @param request
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Paged}<{@link PosterTemplate}>>>
|
|
|
*/
|
|
|
@PostMapping("posterTemSelect")
|
|
|
- public Mono<RStatus<List<PosterTemplate>>> posterTemSelect(@RequestBody PosterTemSelect request) {
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
+ public Mono<RStatus<List<PosterTemplate>>> posterTemSelect(@RequestBody PosterTemSelect request) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
if (Objects.nonNull(request.getName()) && "" != request.getName()) {
|
|
|
criteria = criteria.and("name").like(request.getName());
|
|
|
}
|
|
|
@@ -355,19 +379,20 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 海报模版-列表
|
|
|
+ *
|
|
|
* @param request
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Paged}<{@link PosterTemplate}>>>
|
|
|
*/
|
|
|
@PostMapping("posterTemList")
|
|
|
- public Mono<RStatus<Paged<PosterTemplateRes>>> posterTemList(@RequestBody PosterTemPage request) {
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
+ public Mono<RStatus<Paged<PosterTemplateRes>>> posterTemList(@RequestBody PosterTemPage request) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
if (Objects.nonNull(request.getName()) && "" != request.getName()) {
|
|
|
criteria = criteria.and("name").is(request.getName());
|
|
|
}
|
|
|
Query query = Query.query(criteria);
|
|
|
Criteria finalCriteria = criteria;
|
|
|
- int skip = (request.getPage() - 1) * request.getSize();
|
|
|
- int limit = request.getSize();
|
|
|
+ int skip = (request.getPage() - 1) * request.getSize();
|
|
|
+ int limit = request.getSize();
|
|
|
Mono<Long> count = template.count(query, PosterTemplate.class);
|
|
|
Flux<PosterTemplateRes> created_at = template.select(Query.query(finalCriteria)
|
|
|
.offset(skip)
|
|
|
@@ -394,21 +419,22 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 计划保存
|
|
|
+ *
|
|
|
* @param saveRequest
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
|
|
|
*/
|
|
|
@PostMapping("savePlan")
|
|
|
- public Mono<RStatus<String>> savePlan(@RequestBody PlanReq saveRequest){
|
|
|
- if(2==saveRequest.getType()){
|
|
|
- return listeningPlanService.savePlan(saveRequest);
|
|
|
- }else if(1==saveRequest.getType()){
|
|
|
+ public Mono<RStatus<String>> savePlan(@RequestBody PlanReq saveRequest) {
|
|
|
+ if (2 == saveRequest.getType()) {
|
|
|
+ return listeningPlanService.savePlan(saveRequest);
|
|
|
+ } else if (1 == saveRequest.getType()) {
|
|
|
String userName = BaseContextHandler.getUserName();
|
|
|
String userId = BaseContextHandler.getUserId();
|
|
|
saveRequest.setCode(IdUtil.fastSimpleUUID());
|
|
|
Long posterTemplateId = saveRequest.getPosterTemplateId();
|
|
|
Mono<String> stringMono1 = template
|
|
|
.select(Query.query(Criteria.where("poster_template_id")
|
|
|
- .is(posterTemplateId))
|
|
|
+ .is(posterTemplateId))
|
|
|
.sort(Sort.by(Sort.Order.asc("created_at"))), Poster.class)
|
|
|
.collectList().flatMap(f -> {
|
|
|
Poster poster = f.get(0);
|
|
|
@@ -418,21 +444,21 @@ public class PlanNewController {
|
|
|
BeanUtil.copyProperties(jsonObject, goRequest);
|
|
|
ServiceGroupSettingItemRequest serviceGroupSettingItemRequest = saveRequest.getBackgroupFxSetting().get(0);
|
|
|
Mono<String> stringMono = goGenerateService.saveAndUpdatePlanGenerateImage0(goRequest,
|
|
|
- goGenerateService.setCusqrcodeSetV(goRequest),//getStringBuilderMono(goRequest),
|
|
|
+ goGenerateService.setCusqrcodeSetV(goRequest),// getStringBuilderMono(goRequest),
|
|
|
serviceGroupSettingItemRequest,
|
|
|
saveRequest);
|
|
|
return stringMono;
|
|
|
});
|
|
|
- Mono<StringBuilder> stringBuilderMono ;
|
|
|
- if(saveRequest.getRedirectType()==2){
|
|
|
- stringBuilderMono =Mono.just(new StringBuilder()); //goGenerateService.byPlanNewIdGetUrl(saveRequest.getRedirectPlanId());
|
|
|
- }else {
|
|
|
- stringBuilderMono=Mono.just(new StringBuilder(saveRequest.getLink()));
|
|
|
+ Mono<StringBuilder> stringBuilderMono;
|
|
|
+ if (saveRequest.getRedirectType() == 2) {
|
|
|
+ stringBuilderMono = Mono.just(new StringBuilder()); // goGenerateService.byPlanNewIdGetUrl(saveRequest.getRedirectPlanId());
|
|
|
+ } else {
|
|
|
+ stringBuilderMono = Mono.just(new StringBuilder(saveRequest.getLink()));
|
|
|
}
|
|
|
- Mono<PlanNew> insert = Mono.zip(stringMono1, stringBuilderMono).flatMap(f->{
|
|
|
- String listButton="立即入群";
|
|
|
- if(Objects.nonNull(saveRequest.getListButton()) && !"".equals(saveRequest.getListButton().trim())){
|
|
|
- listButton=saveRequest.getListButton();
|
|
|
+ Mono<PlanNew> insert = Mono.zip(stringMono1, stringBuilderMono).flatMap(f -> {
|
|
|
+ String listButton = "立即入群";
|
|
|
+ if (Objects.nonNull(saveRequest.getListButton()) && !"".equals(saveRequest.getListButton().trim())) {
|
|
|
+ listButton = saveRequest.getListButton();
|
|
|
}
|
|
|
PlanNew plan = new PlanNew(IdUtil.fastSimpleUUID(),
|
|
|
saveRequest.getName(),
|
|
|
@@ -472,20 +498,21 @@ public class PlanNewController {
|
|
|
saveRequest.getTransferPageDomain(),
|
|
|
saveRequest.getTransferPageBl(),
|
|
|
saveRequest.getBackgroupDomain(),
|
|
|
- listButton
|
|
|
+ listButton,
|
|
|
+ saveRequest.getGroupListDisplay()
|
|
|
);
|
|
|
return template.insert(plan);
|
|
|
});
|
|
|
Mono<String> map = insert.flatMap(f -> {
|
|
|
Flux<PlanNewBackgroupPoster> just = getPlanNewBackgroupPosterFlux(saveRequest, f);
|
|
|
- return Mono.zip(batchInsert(just), Mono.just(f)).flatMap(ff -> {
|
|
|
+ return Mono.zip(batchInsert(just), Mono.just(f)).flatMap(ff -> {
|
|
|
PlanNew t2 = ff.getT2();
|
|
|
return Mono.just(t2.planNewId());
|
|
|
});
|
|
|
});
|
|
|
- return RStatus.success(map);
|
|
|
+ return RStatus.success(map);
|
|
|
}
|
|
|
- throw new BaseException("type类型错误");
|
|
|
+ throw new BaseException("type类型错误");
|
|
|
}
|
|
|
|
|
|
private Flux<PlanNewBackgroupPoster> getPlanNewBackgroupPosterFlux(PlanReq saveRequest, PlanNew f) {
|
|
|
@@ -509,8 +536,9 @@ public class PlanNewController {
|
|
|
.insert(PlanNewBackgroupPoster.class).using(entity)).collectList();
|
|
|
return listMono;
|
|
|
}
|
|
|
- public PlanNewBackgroupPoster fxBackgroupSettingsSave( ServiceGroupSettingItemRequest request,String planNewId,Integer qsOrFx){
|
|
|
- return new PlanNewBackgroupPoster(null,
|
|
|
+
|
|
|
+ public PlanNewBackgroupPoster fxBackgroupSettingsSave(ServiceGroupSettingItemRequest request, String planNewId, Integer qsOrFx) {
|
|
|
+ return new PlanNewBackgroupPoster(null,
|
|
|
request.getAudioId(),
|
|
|
request.getGroupId(),
|
|
|
request.getImage(),
|
|
|
@@ -525,7 +553,7 @@ public class PlanNewController {
|
|
|
ZonedDateTime.now(),
|
|
|
null,
|
|
|
null,
|
|
|
- planNewId,null,null);
|
|
|
+ planNewId, null, null);
|
|
|
// template.insert(planNewBackgroupPoster).subscribe(f->{
|
|
|
// JSONObject jsonObject = JSONUtil.parseObj(f);
|
|
|
// System.out.println(jsonObject);
|
|
|
@@ -534,12 +562,11 @@ public class PlanNewController {
|
|
|
}
|
|
|
|
|
|
|
|
|
-
|
|
|
@PostMapping("updatePlan")
|
|
|
- public Mono<RStatus<String>> updatePlan(@RequestBody PlanReq saveRequest){
|
|
|
- if(2==saveRequest.getType()){
|
|
|
- return listeningPlanService.savePlan(saveRequest);
|
|
|
- }else if(1==saveRequest.getType()){
|
|
|
+ public Mono<RStatus<String>> updatePlan(@RequestBody PlanReq saveRequest) {
|
|
|
+ if (2 == saveRequest.getType()) {
|
|
|
+ return listeningPlanService.savePlan(saveRequest);
|
|
|
+ } else if (1 == saveRequest.getType()) {
|
|
|
Long posterTemplateId = saveRequest.getPosterTemplateId();
|
|
|
Mono<String> stringMono1 = template
|
|
|
.select(Query.query(Criteria.where("poster_template_id").is(posterTemplateId)).sort(Sort.by(Sort.Order.asc("created_at"))), Poster.class)
|
|
|
@@ -551,26 +578,26 @@ public class PlanNewController {
|
|
|
BeanUtil.copyProperties(jsonObject, goRequest);
|
|
|
ServiceGroupSettingItemRequest serviceGroupSettingItemRequest = saveRequest.getBackgroupFxSetting().get(0);
|
|
|
Mono<String> stringMono = goGenerateService.saveAndUpdatePlanGenerateImage0(goRequest,
|
|
|
- // goGenerateService.getStringBuilderMono(goRequest),
|
|
|
+ // goGenerateService.getStringBuilderMono(goRequest),
|
|
|
goGenerateService.setCusqrcodeSetV(goRequest),
|
|
|
serviceGroupSettingItemRequest, saveRequest);
|
|
|
return stringMono;
|
|
|
});
|
|
|
Mono<PlanNew> plan_new_id1 = template.selectOne(Query.query(Criteria.where("plan_new_id").is(saveRequest.getPlanNewId())), PlanNew.class);
|
|
|
- Mono<StringBuilder> stringBuilderMono ;
|
|
|
- if(saveRequest.getRedirectType()==2){
|
|
|
- stringBuilderMono = Mono.just(new StringBuilder(""));//goGenerateService.byPlanNewIdGetUrl(saveRequest.getRedirectPlanId());
|
|
|
- }else {
|
|
|
- stringBuilderMono=Mono.just(new StringBuilder(saveRequest.getLink()));
|
|
|
+ Mono<StringBuilder> stringBuilderMono;
|
|
|
+ if (saveRequest.getRedirectType() == 2) {
|
|
|
+ stringBuilderMono = Mono.just(new StringBuilder(""));// goGenerateService.byPlanNewIdGetUrl(saveRequest.getRedirectPlanId());
|
|
|
+ } else {
|
|
|
+ stringBuilderMono = Mono.just(new StringBuilder(saveRequest.getLink()));
|
|
|
}
|
|
|
Mono<PlanNew> planNewMono = Mono.zip(stringMono1, plan_new_id1, stringBuilderMono).flatMap(f -> {
|
|
|
PlanNew map = f.getT2();
|
|
|
- String listButton="立即入群";
|
|
|
- if(Objects.nonNull(saveRequest.getListButton()) && !"".equals(saveRequest.getListButton().trim())){
|
|
|
- listButton=saveRequest.getListButton();
|
|
|
+ String listButton = "立即入群";
|
|
|
+ if (Objects.nonNull(saveRequest.getListButton()) && !"".equals(saveRequest.getListButton().trim())) {
|
|
|
+ listButton = saveRequest.getListButton();
|
|
|
}
|
|
|
PlanNew planNew = new PlanNew(
|
|
|
- saveRequest.getPlanNewId(),
|
|
|
+ saveRequest.getPlanNewId(),
|
|
|
saveRequest.getName(),
|
|
|
map.createUser(),
|
|
|
map.createId(),
|
|
|
@@ -608,17 +635,18 @@ public class PlanNewController {
|
|
|
saveRequest.getTransferPageDomain(),
|
|
|
saveRequest.getTransferPageBl(),
|
|
|
saveRequest.getBackgroupDomain(),
|
|
|
- listButton
|
|
|
+ listButton,
|
|
|
+ saveRequest.getGroupListDisplay()
|
|
|
);
|
|
|
return Mono.just(planNew);
|
|
|
}).flatMap(template::update);
|
|
|
- Mono<String> map = planNewMono.flatMap(f1->{
|
|
|
- Mono<Long> ml= template.delete(Query.query(Criteria.where("plan_new_id").is(f1.planNewId())),PlanNewBackgroupPoster.class);
|
|
|
- return Mono.zip(Mono.just(f1),ml).flatMap(ff->Mono.just(f1));
|
|
|
+ Mono<String> map = planNewMono.flatMap(f1 -> {
|
|
|
+ Mono<Long> ml = template.delete(Query.query(Criteria.where("plan_new_id").is(f1.planNewId())), PlanNewBackgroupPoster.class);
|
|
|
+ return Mono.zip(Mono.just(f1), ml).flatMap(ff -> Mono.just(f1));
|
|
|
}).flatMap(f -> {
|
|
|
Flux<PlanNewBackgroupPoster> just = getPlanNewBackgroupPosterFlux(saveRequest, f);
|
|
|
|
|
|
- return Mono.zip(batchInsert(just), Mono.just(f)).flatMap(ff -> {
|
|
|
+ return Mono.zip(batchInsert(just), Mono.just(f)).flatMap(ff -> {
|
|
|
PlanNew t2 = ff.getT2();
|
|
|
return Mono.just(t2.planNewId());
|
|
|
});
|
|
|
@@ -628,7 +656,8 @@ public class PlanNewController {
|
|
|
|
|
|
throw new BaseException("type类型错误");
|
|
|
}
|
|
|
- public PlanNewBackgroupPoster fxBackgroupSettingsUpdate( ServiceGroupSettingItemRequest request,String planNewId,Integer qsOrFx){
|
|
|
+
|
|
|
+ public PlanNewBackgroupPoster fxBackgroupSettingsUpdate(ServiceGroupSettingItemRequest request, String planNewId, Integer qsOrFx) {
|
|
|
PlanNewBackgroupPoster planNewBackgroupPoster = new PlanNewBackgroupPoster(request.getId(),
|
|
|
|
|
|
request.getAudioId(),
|
|
|
@@ -645,20 +674,22 @@ public class PlanNewController {
|
|
|
ZonedDateTime.now(),
|
|
|
ZonedDateTime.now(),
|
|
|
null,
|
|
|
- planNewId,null,null);
|
|
|
- // template.insert(planNewBackgroupPoster).subscribe();
|
|
|
+ planNewId, null, null);
|
|
|
+ // template.insert(planNewBackgroupPoster).subscribe();
|
|
|
return planNewBackgroupPoster;
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* 复制计划
|
|
|
+ *
|
|
|
* @param planNewId
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link PlanNew}>>
|
|
|
*/
|
|
|
@GetMapping("copyById/{type}/{planNewId}")
|
|
|
- public Mono<RStatus<String>> copyById (@PathVariable("type") @NotNull Integer type,@PathVariable("planNewId") @NotNull String planNewId){
|
|
|
+ public Mono<RStatus<String>> copyById(@PathVariable("type") @NotNull Integer type, @PathVariable("planNewId") @NotNull String planNewId) {
|
|
|
if (2 == type) {
|
|
|
- return listeningPlanService.copyById(planNewId);
|
|
|
- }else if (1==type){
|
|
|
+ return listeningPlanService.copyById(planNewId);
|
|
|
+ } else if (1 == type) {
|
|
|
String userName = BaseContextHandler.getUserName();
|
|
|
String userId = BaseContextHandler.getUserId();
|
|
|
Mono<PlanNew> plan_new_id = template.selectOne(Query.query(Criteria.where("plan_new_id").is(planNewId)), PlanNew.class)
|
|
|
@@ -700,11 +731,12 @@ public class PlanNewController {
|
|
|
saveRequest.transferPageDomain(),
|
|
|
saveRequest.transferPageBl(),
|
|
|
saveRequest.backgroupDomain(),
|
|
|
- saveRequest.listButton()
|
|
|
+ saveRequest.listButton(),
|
|
|
+ saveRequest.groupListDisplay()
|
|
|
)).flatMap(map -> template.insert(map));
|
|
|
Mono<List<PlanNewBackgroupPoster>> listening_plan_new_id1 =
|
|
|
template.select(Query.query(Criteria.where("plan_new_id")
|
|
|
- .is(planNewId)), PlanNewBackgroupPoster.class)
|
|
|
+ .is(planNewId)), PlanNewBackgroupPoster.class)
|
|
|
.collectList();
|
|
|
Mono<String> stringMono = Mono.zip(plan_new_id, listening_plan_new_id1).flatMap(f -> {
|
|
|
PlanNew t1 = f.getT1();
|
|
|
@@ -746,27 +778,28 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 删除计划
|
|
|
+ *
|
|
|
* @param planNewId
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Long}>>
|
|
|
*/
|
|
|
@DeleteMapping("deleteById/{type}/{planNewId}")
|
|
|
- public Mono<RStatus<Long>> deleteById (@PathVariable("type") @NotNull Integer type,@PathVariable("planNewId") @NotNull String planNewId ){
|
|
|
- if(1==type){
|
|
|
+ public Mono<RStatus<Long>> deleteById(@PathVariable("type") @NotNull Integer type, @PathVariable("planNewId") @NotNull String planNewId) {
|
|
|
+ if (1 == type) {
|
|
|
Query plan_new_id2 = Query.query(Criteria.where("plan_new_id").is(planNewId));
|
|
|
Mono<Long> plan_new_id = template.delete(plan_new_id2, PlanNew.class)
|
|
|
- .switchIfEmpty(Mono.error(new BaseException("计划id异常"))) //Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
- .onErrorResume(throwable -> Mono.error(new Exception("删除计划 " +planNewId+"---"+ type+"error:" + throwable.getMessage())));
|
|
|
+ .switchIfEmpty(Mono.error(new BaseException("计划id异常"))) // Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
+ .onErrorResume(throwable -> Mono.error(new Exception("删除计划 " + planNewId + "---" + type + "error:" + throwable.getMessage())));
|
|
|
Mono<Long> plan_new_id1 = template.count(plan_new_id2, PlanNewBackgroupPoster.class).filter(f -> f > 0)
|
|
|
.flatMap(f -> template.delete(plan_new_id2, PlanNewBackgroupPoster.class))
|
|
|
.switchIfEmpty(Mono.just(0L));
|
|
|
Mono<Long> longMono = Mono.zip(plan_new_id1, plan_new_id).flatMap(f -> Mono.just(f.getT1()));
|
|
|
return RStatus.success(longMono);
|
|
|
- }else if(2==type) {
|
|
|
+ } else if (2 == type) {
|
|
|
Query listening_plan_new_id1 = Query.query(Criteria.where("listening_plan_new_id")
|
|
|
.is(planNewId));
|
|
|
Mono<Long> listening_plan_new_id = template.delete(listening_plan_new_id1, ListeningPlanNew.class)
|
|
|
- .switchIfEmpty(Mono.error(new BaseException("计划id异常"))) //Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
- .onErrorResume(throwable -> Mono.error(new Exception("删除计划 " +planNewId+"---"+ type+"error:" + throwable.getMessage())));
|
|
|
+ .switchIfEmpty(Mono.error(new BaseException("计划id异常"))) // Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
+ .onErrorResume(throwable -> Mono.error(new Exception("删除计划 " + planNewId + "---" + type + "error:" + throwable.getMessage())));
|
|
|
Mono<Long> plan_new_id1 = template.count(listening_plan_new_id1, ListeningPlanNewBackgroupPoster.class).filter(f -> f > 0)
|
|
|
.flatMap(f -> template.delete(listening_plan_new_id1, ListeningPlanNewBackgroupPoster.class))
|
|
|
.switchIfEmpty(Mono.just(0L));
|
|
|
@@ -778,11 +811,12 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 计划-编辑回显详情
|
|
|
+ *
|
|
|
* @param planNewId
|
|
|
* @return
|
|
|
*/
|
|
|
@GetMapping("planNewInfo/{type}/{planNewId}")
|
|
|
- public Mono<RStatus<PlanNewAllRs>> planNewInfo(@PathVariable("type") @NotNull Integer type,@PathVariable("planNewId") @NotNull String planNewId){
|
|
|
+ public Mono<RStatus<PlanNewAllRs>> planNewInfo(@PathVariable("type") @NotNull Integer type, @PathVariable("planNewId") @NotNull String planNewId) {
|
|
|
if (1 == type) {
|
|
|
Mono<PlanNewAllRs> planNewAllRsMono = template.selectOne(Query.query(Criteria.where("plan_new_id").is(planNewId)), PlanNew.class)
|
|
|
.flatMap(saveRequest -> {
|
|
|
@@ -822,24 +856,25 @@ public class PlanNewController {
|
|
|
saveRequest.listButton(),
|
|
|
Objects.nonNull(saveRequest.importDomain()) && !"".equals(saveRequest.importDomain().trim()) ? Integer.valueOf(saveRequest.importDomain()) : null,
|
|
|
Objects.nonNull(saveRequest.landingPageDomain()) && !"".equals(saveRequest.landingPageDomain().trim()) ? Integer.valueOf(saveRequest.landingPageDomain()) : null,
|
|
|
- // saveRequest.landingPageDomain(),
|
|
|
- Objects.nonNull(saveRequest.transferPageDomain()) && !"".equals(saveRequest.transferPageDomain().trim()) ?Integer.valueOf(saveRequest.transferPageDomain()):null,
|
|
|
+ // saveRequest.landingPageDomain(),
|
|
|
+ Objects.nonNull(saveRequest.transferPageDomain()) && !"".equals(saveRequest.transferPageDomain().trim()) ? Integer.valueOf(saveRequest.transferPageDomain()) : null,
|
|
|
|
|
|
- //saveRequest.transferPageDomain(),
|
|
|
+ // saveRequest.transferPageDomain(),
|
|
|
saveRequest.transferPageBl(),
|
|
|
- Objects.nonNull(saveRequest.backgroupDomain()) && !"".equals(saveRequest.backgroupDomain().trim()) ?Integer.valueOf(saveRequest.backgroupDomain()):null
|
|
|
+ Objects.nonNull(saveRequest.backgroupDomain()) && !"".equals(saveRequest.backgroupDomain().trim()) ? Integer.valueOf(saveRequest.backgroupDomain()) : null,
|
|
|
+ saveRequest.groupListDisplay()
|
|
|
|
|
|
- // saveRequest.backgroupDomain()
|
|
|
+ // saveRequest.backgroupDomain()
|
|
|
);
|
|
|
return Mono.just(planNewAllRs);
|
|
|
}
|
|
|
- ).switchIfEmpty(Mono.error(new BaseException("计划id异常"))) //Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
+ ).switchIfEmpty(Mono.error(new BaseException("计划id异常"))) // Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
.onErrorResume(throwable -> Mono.error(new Exception("计划id异常")));
|
|
|
return RStatus.success(planNewAllRsMono);
|
|
|
- }else if (2 == type) {
|
|
|
+ } else if (2 == type) {
|
|
|
Mono<PlanNewAllRs> planNewAllRsMono = template
|
|
|
.selectOne(Query.query(Criteria.where("listening_plan_new_id").is(planNewId)),
|
|
|
- ListeningPlanNew.class)
|
|
|
+ ListeningPlanNew.class)
|
|
|
.flatMap(saveRequest -> {
|
|
|
PlanNewAllRs planNewAllRs = new PlanNewAllRs(saveRequest.listeningPlanNewId(),
|
|
|
saveRequest.name(),
|
|
|
@@ -879,12 +914,13 @@ public class PlanNewController {
|
|
|
null,
|
|
|
null,
|
|
|
null,
|
|
|
+ null,
|
|
|
null
|
|
|
|
|
|
);
|
|
|
return Mono.just(planNewAllRs);
|
|
|
}
|
|
|
- ).switchIfEmpty(Mono.error(new BaseException("计划id异常"))) //Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
+ ).switchIfEmpty(Mono.error(new BaseException("计划id异常"))) // Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
.onErrorResume(throwable -> Mono.error(new Exception("计划id异常")));
|
|
|
return RStatus.success(planNewAllRsMono);
|
|
|
}
|
|
|
@@ -894,35 +930,40 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 计划列表-下拉(查看自己创建的)(V2.0)
|
|
|
+ *
|
|
|
* @param request
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Paged}<{@link PlanNew}>>>
|
|
|
*/
|
|
|
@PostMapping("planSelectSelf")
|
|
|
- public Mono<RStatus<List<PlanNew>>> planSelectSelf(@RequestBody PosterTemSelectSelf request) {
|
|
|
+ public Mono<RStatus<List<SelectPlanRes1>>> planSelectSelf(@RequestBody PosterTemSelectSelf request) {
|
|
|
|
|
|
if (Objects.isNull(request.getUserId())) {
|
|
|
- request.setUserId( BaseContextHandler.getUserId());
|
|
|
+ request.setUserId(BaseContextHandler.getUserId());
|
|
|
}
|
|
|
- Criteria criteria= Criteria.where("create_id").is(request.getUserId()) ; //poster_template_id
|
|
|
- if (Objects.nonNull(request.getName()) && "" != request.getName()) {
|
|
|
- criteria = criteria.and("name").like("%"+request.getName()+"%");
|
|
|
+ Criteria criteria = Criteria.where("create_id").is(request.getUserId()); // poster_template_id
|
|
|
+ if (Objects.nonNull(request.getName()) && !request.getName().isEmpty()) {
|
|
|
+ criteria = criteria.and("name").like("%" + request.getName() + "%");
|
|
|
}
|
|
|
- Mono<List<PlanNew>> listMono = template.select(Query.query(criteria), PlanNew.class).collectList();
|
|
|
- return RStatus.successList(listMono);
|
|
|
+ return getPlanSelect(criteria);
|
|
|
}
|
|
|
|
|
|
|
|
|
/**
|
|
|
* 计划列表-下拉
|
|
|
+ *
|
|
|
* @param request
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link List}<{@link SelectPlanRes1}>>>
|
|
|
*/
|
|
|
@PostMapping("planSelect")
|
|
|
- public Mono<RStatus<List<SelectPlanRes1>>> planSelect(@RequestBody PosterTemSelect request) {
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
+ public Mono<RStatus<List<SelectPlanRes1>>> planSelect(@RequestBody PosterTemSelect request) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
if (Objects.nonNull(request.getName()) && "" != request.getName()) {
|
|
|
criteria = criteria.and("name").is(request.getName());
|
|
|
}
|
|
|
+ return getPlanSelect(criteria);
|
|
|
+ }
|
|
|
+
|
|
|
+ private Mono<RStatus<List<SelectPlanRes1>>> getPlanSelect( Criteria criteria) {
|
|
|
Mono<List<SelectPlanRes1>> listMono = template.select(Query.query(criteria), PlanNew.class).flatMap(fm -> {
|
|
|
SelectPlanRes1 selectPlanRes1 = new SelectPlanRes1();
|
|
|
selectPlanRes1.setName(fm.name());
|
|
|
@@ -937,12 +978,21 @@ public class PlanNewController {
|
|
|
selectPlanRes1.setPlanNewId(fm.listeningPlanNewId());
|
|
|
return Mono.just(selectPlanRes1);
|
|
|
}).collectList();
|
|
|
- Mono<List<SelectPlanRes1>> arrayListMono = Mono.zip(listMono, listMono1).flatMap(f -> {
|
|
|
+ Mono<List<SelectPlanRes1>> listMono2 = template.select(Query.query(criteria), PlanNewCommon.class).flatMap(fm -> {
|
|
|
+ SelectPlanRes1 selectPlanRes1 = new SelectPlanRes1();
|
|
|
+ selectPlanRes1.setName(fm.name());
|
|
|
+ selectPlanRes1.setType(3);
|
|
|
+ selectPlanRes1.setPlanNewId(fm.id());
|
|
|
+ return Mono.just(selectPlanRes1);
|
|
|
+ }).collectList();
|
|
|
+ Mono<List<SelectPlanRes1>> arrayListMono = Mono.zip(listMono, listMono1, listMono2).flatMap(f -> {
|
|
|
List<SelectPlanRes1> t1 = f.getT1();
|
|
|
List<SelectPlanRes1> t2 = f.getT2();
|
|
|
+ List<SelectPlanRes1> t3 = f.getT3();
|
|
|
ArrayList<SelectPlanRes1> objects = new ArrayList<>();
|
|
|
objects.addAll(t1);
|
|
|
objects.addAll(t2);
|
|
|
+ objects.addAll(t3);
|
|
|
return Mono.just(objects);
|
|
|
});
|
|
|
return RStatus.successList(arrayListMono);
|
|
|
@@ -951,51 +1001,57 @@ public class PlanNewController {
|
|
|
|
|
|
/**
|
|
|
* 计划列表
|
|
|
- * @param request
|
|
|
+ *
|
|
|
+ * @param request request
|
|
|
* @return {@link Mono}<{@link RStatus}<{@link Paged}<{@link ListeningPlanNewRes2}>>>
|
|
|
*/
|
|
|
@PostMapping("planList")
|
|
|
- public Mono<RStatus<Paged<ListeningPlanNewRes2>>> page(@RequestBody PlanReqPage request) {
|
|
|
- if (2 == request.getType()) {
|
|
|
- return listeningPlanService.page(request);
|
|
|
- }else {
|
|
|
- return getType1(request);
|
|
|
- }
|
|
|
- }
|
|
|
- private Mono<RStatus<Paged<ListeningPlanNewRes2>>> getType1(PlanReqPage request) {
|
|
|
- Criteria criteria= Criteria.empty() ; //poster_template_id
|
|
|
- if (Objects.nonNull(request.getCode()) && "" != request.getCode().trim()) {
|
|
|
- criteria = criteria.and("code").like("%"+request.getCode()+"%");
|
|
|
+ public Mono<RStatus<Paged<ListeningPlanNewRes2>>> page(@RequestBody PlanReqPage request) {
|
|
|
+ Criteria criteria = Criteria.empty(); // poster_template_id
|
|
|
+ if (Objects.nonNull(request.getCode()) && !request.getCode().trim().isEmpty()) {
|
|
|
+ criteria = criteria.and("code").like("%" + request.getCode() + "%");
|
|
|
}
|
|
|
- if (Objects.nonNull(request.getName()) && "" != request.getName().trim()) {
|
|
|
- criteria = criteria.and("name").like("%"+request.getName()+"%");
|
|
|
+ if (Objects.nonNull(request.getName()) && !request.getName().trim().isEmpty()) {
|
|
|
+ criteria = criteria.and("name").like("%" + request.getName() + "%");
|
|
|
}
|
|
|
- if (Objects.nonNull(request.getCreateUser()) && "" != request.getCreateUser().trim()) {
|
|
|
- criteria = criteria.and("create_user").like("%"+request.getCreateUser()+"%");
|
|
|
+ if (Objects.nonNull(request.getCreateUser()) && !request.getCreateUser().trim().isEmpty()) {
|
|
|
+ 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());
|
|
|
-// }
|
|
|
+ if (Objects.nonNull(request.getType()) && 0 != request.getType()) {
|
|
|
+ criteria = criteria.and("type").is(request.getType());
|
|
|
+ }
|
|
|
+ if (Objects.nonNull(request.getGroupId()) && 0L != request.getGroupId()) {
|
|
|
+ criteria = criteria.and("group_id").is(request.getType());
|
|
|
+ }
|
|
|
+ if (2 == request.getType()) {
|
|
|
+ return listeningPlanService.page(request, criteria);
|
|
|
+ } else if (1 == request.getType()) {
|
|
|
+ return getType1(request, criteria);
|
|
|
+ } else {
|
|
|
+ return planServiceInterface.page(request, criteria);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private Mono<RStatus<Paged<ListeningPlanNewRes2>>> getType1(PlanReqPage request, Criteria criteria) {
|
|
|
Query query = Query.query(criteria);
|
|
|
- Criteria finalCriteria = criteria;
|
|
|
- int skip = (request.getPage() - 1) * request.getSize();
|
|
|
- int limit = request.getSize();
|
|
|
+ int skip = (request.getPage() - 1) * request.getSize();
|
|
|
+ int limit = request.getSize();
|
|
|
Mono<Long> count = template.count(query, PlanNew.class);
|
|
|
- Flux<PlanNew> created_at = template.select(Query.query(finalCriteria)
|
|
|
+ Flux<PlanNew> created_at = template.select(Query.query(criteria)
|
|
|
.offset(skip)
|
|
|
.limit(limit)
|
|
|
.sort(Sort.by(Sort.Order.desc("created_at"))), PlanNew.class);
|
|
|
Mono<List<ListeningPlanNewRes2>> listMono = created_at.flatMap(f -> {
|
|
|
Mono<String> poster_template_id = template.selectOne(Query.query(Criteria.where("poster_template_id")
|
|
|
- .is(f.posterTemplateId())), PosterTemplate.class).flatMap(f0 -> Mono.just(f0.posterTemplateName()))
|
|
|
- .switchIfEmpty(Mono.just("")) //Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
+ .is(f.posterTemplateId())), PosterTemplate.class).flatMap(f0 -> Mono.just(f0.posterTemplateName()))
|
|
|
+ .switchIfEmpty(Mono.just("")) // Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
|
|
|
.onErrorResume(throwable -> Mono.error(new Exception("查询海报模版 id:" + f.posterTemplateId() + "error:" + throwable.getMessage())));
|
|
|
Mono<String> id = template.selectOne(Query.query(Criteria.where("id").is(f.groupId())), GroupType.class)
|
|
|
.flatMap(f1 -> Mono.just(f1.name()))
|
|
|
- .switchIfEmpty(Mono.just(""))//Mono.error(new BaseException("查询GroupType id:"+f.groupId()+"=>空"))
|
|
|
+ .switchIfEmpty(Mono.just(""))// Mono.error(new BaseException("查询GroupType id:"+f.groupId()+"=>空"))
|
|
|
.onErrorResume(throwable -> Mono.error(new Exception("查询GroupType id:" + f.groupId() + "error:" + throwable.getMessage())));
|
|
|
return Mono.zip(Mono.just(f), poster_template_id, id).flatMap(ff -> {
|
|
|
PlanNew t1 = ff.getT1();
|