|
|
@@ -56,10 +56,15 @@ public class PlanServiceImpl implements PlanServiceInterface {
|
|
|
.limit(limit)
|
|
|
.sort(Sort.by(Sort.Order.desc("created_at"))), PlanNewCommon.class);
|
|
|
Mono<List<ListeningPlanNewRes2>> listMono = createdAt.flatMap(f -> {
|
|
|
- Mono<String> posterTemplateId = template.selectOne(Query.query(Criteria.where("poster_template_id")
|
|
|
- .is(f.posterTemplateId())), PosterTemplate.class).flatMap(f0 -> Mono.just(f0.posterTemplateName()))
|
|
|
- .switchIfEmpty(Mono.just(""))
|
|
|
- .onErrorResume(throwable -> Mono.error(new Exception("查询海报模版 id:" + f.posterTemplateId() + "error:" + throwable.getMessage())));
|
|
|
+ Mono<String> posterTemplateId ;
|
|
|
+ if(f.type()==8){
|
|
|
+ posterTemplateId=Mono.just("");
|
|
|
+ }else {
|
|
|
+ posterTemplateId = template.selectOne(Query.query(Criteria.where("poster_template_id")
|
|
|
+ .is(f.posterTemplateId())), PosterTemplate.class).flatMap(f0 -> Mono.just(f0.posterTemplateName()))
|
|
|
+ .switchIfEmpty(Mono.just(""))
|
|
|
+ .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(""))
|