Просмотр исходного кода

接口返回的信息中非关键信息隐藏,比如记录创建时间,更新时间,操作人,创建人信息 1

MOKASZ\lw12420 2 лет назад
Родитель
Сommit
e6b35a7606

+ 10 - 7
launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/PlanNewCommonOutController.java

@@ -195,7 +195,7 @@ public class PlanNewCommonOutController {
      */
     @PostMapping("kefuList")
     public Mono<RStatus<byte[]>> kefuList(@RequestBody KefuRequest request) {
-        Mono<PlanNewCommon> code = template.selectOne(Query.query(Criteria.where("code").is(request.getCode())), PlanNewCommon.class)
+        Mono<PlanNewCommon> code = template.selectOne(Query.query(Criteria.where("code").is(request.getCode())).columns(COLUMNARRAYCOMMON), PlanNewCommon.class)
                 .switchIfEmpty(Mono.error(new BaseException("code查询返回结构为空")))
                 .onErrorResume(throwable -> Mono.error(new BaseException("code查询返回结构为空")));
         Mono<DataListsKefu> dataListsKefuMono = code.flatMap(planNew -> {
@@ -518,7 +518,8 @@ public class PlanNewCommonOutController {
      */
     @PostMapping("getCommonMaterial")
     public Mono<RStatus<PlanNewCommonMaterialRes>> getCommonMaterial(@RequestBody PlanNewCommonMaterialReq request) {
-        Mono<PlanNewCommon> planNewCommonMono = template.selectOne(Query.query(Criteria.where("code").is(request.getCode())), PlanNewCommon.class)
+        Mono<PlanNewCommon> planNewCommonMono = template.selectOne(Query.query(Criteria.where("code").is(request.getCode()))
+                .columns(COLUMNARRAYCOMMON), PlanNewCommon.class)
                 .switchIfEmpty(Mono.error(new BaseException("计划code异常 返回结果为空")))
                 .onErrorResume(throwable -> Mono.error(new BaseException("计划code异常")));
         Mono<PlanNewCommonMaterialRes> materialResMono = planNewCommonMono.flatMap(plan -> {
@@ -532,7 +533,8 @@ public class PlanNewCommonOutController {
                 returnLoop = Mono.just(getReturnLoop());
             } else {
                 returnLoop = template.selectOne(Query.query(Criteria.where("id").is(request.getReturnLoopId())
-                                .and("deleted_at").isNull()), ReturnLoop.class)
+                                .and("deleted_at").isNull())
+                        .columns("id,name,group_type,group_type_name,group_type_id,domain,is_show_list,return_list,return_number,type,domain_id".split(",")), ReturnLoop.class)
                         .switchIfEmpty(Mono.just(getReturnLoop()))
                         .onErrorResume(throwable -> Mono.error(new BaseException("查询返回广告异常")));
             }
@@ -578,7 +580,8 @@ public class PlanNewCommonOutController {
         if (Objects.isNull(id) || id <= 0) {
             return Mono.just(getAudio());
         }
-        return template.selectOne(Query.query(Criteria.where("id").is(id)), Audio.class)
+        String col="id,url,name,type";
+        return template.selectOne(Query.query(Criteria.where("id").is(id)).columns(col.split(",")), Audio.class)
                 .switchIfEmpty(Mono.error(new BaseException(StrUtil.format("通过计划retAudioId:{}查询音频为空", id))))
                 .onErrorResume(throwable -> Mono.error(new BaseException(StrUtil.format("通过计划retAudioId:{}查询音频Error::{}", id, throwable.getMessage()))));
         // String value = redisTemplate.opsForValue().get(RedisKey.FISSION_AUDIO + id);
@@ -605,7 +608,6 @@ public class PlanNewCommonOutController {
     private ReturnLoop getReturnLoop() {
         return new ReturnLoop(-1L, null, null, null, null, null, null, null, null, null, null, null, null, null);
     }
-
     /**
      * H5分享
      *
@@ -617,7 +619,8 @@ public class PlanNewCommonOutController {
         if (request.getCode() == null || request.getCode().isEmpty()) {
             throw new BaseException("code不能为空");
         }
-        Mono<PlanNewCommon> planNewCommonMono = template.selectOne(Query.query(Criteria.where("code").is(request.getCode())), PlanNewCommon.class)
+        Mono<PlanNewCommon> planNewCommonMono = template.selectOne(Query.query(Criteria.where("code").is(request.getCode()))
+                .columns(COLUMNARRAYCOMMON), PlanNewCommon.class)
                 .switchIfEmpty(Mono.error(new BaseException(" code错误")))
                 .onErrorResume(throwable -> Mono.error(new BaseException(" code错误")));
         // 记录访问
@@ -912,7 +915,7 @@ public class PlanNewCommonOutController {
 
     private Mono<PosterTemplate> getPosterTemplate(Mono<PlanNewCommon> code) {
         return code.flatMap(plan -> template.selectOne(Query.query(Criteria.where("poster_template_id")
-                .is(plan.posterTemplateId())), PosterTemplate.class));
+                .is(plan.posterTemplateId())).columns("poster_template_id,poster_template_name".split(",")), PosterTemplate.class));
     }
 
     private Mono<StringBuilder> getEwm(Mono<PlanNewCommon> code) {

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

@@ -217,7 +217,7 @@ public class PlanNewOutController {
 
     @PostMapping("kefuList")
     public Mono<RStatus<DataListsKefu>> kefuList(@RequestBody KefuRequest request){
-        Mono<PlanNew> code = template.selectOne(Query.query(Criteria.where("code").is(request.getCode())), PlanNew.class)
+        Mono<PlanNew> code = template.selectOne(Query.query(Criteria.where("code").is(request.getCode())).columns(COLUMNARRAYPLANNEW), PlanNew.class)
                 .switchIfEmpty(Mono.error(new BaseException("code查询返回结构为空"))) //Mono.error(new BaseException("查询海报模版 id:"+f.posterTemplateId()+"=>空"))
                 .onErrorResume(throwable -> Mono.error(new BaseException("通过code查询计划异常::" + throwable.getMessage())));
         Mono<DataListsKefu> dataListsKefuMono = code.flatMap(planNew -> {
@@ -274,7 +274,7 @@ public class PlanNewOutController {
                     .switchIfEmpty(Mono.just(List.of()));
             Mono<Audio> retAudioId = Mono.just(planNew).flatMap(plan -> {
                 if(Objects.nonNull(plan.retAudioId())){
-                   return template.selectOne(Query.query(Criteria.where("id").is(plan.retAudioId())), Audio.class)
+                   return template.selectOne(Query.query(Criteria.where("id").is(plan.retAudioId())).columns("id,url,name,type".split(",")), Audio.class)
                            .switchIfEmpty(Mono.error(new BaseException(StrUtil.format("通过计划retAudioId:{}查询音频为空",plan.retAudioId()))))
                            .onErrorResume(throwable -> Mono.error(new BaseException(StrUtil.format("通过计划retAudioId:{}查询音频Error::",plan.retAudioId(),throwable.getMessage()))));
                 }else {
@@ -441,21 +441,22 @@ public class PlanNewOutController {
                     return Mono.just(new Audio(null,null,null,null,null,null,null,null));
                 }else {
                     return  template.selectOne(
-                            Query.query(Criteria.where("id").is(plan.listAudioId()).and("deleted_at").isNull()),
+                            Query.query(Criteria.where("id").is(plan.listAudioId()).and("deleted_at").isNull())
+                                    .columns("id,url,name,type".split(",")),
                             Audio.class);
                 } }
             ).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"1")));
             Mono<Audio> retAudioId = code.flatMap(plan -> template.selectOne(Query.query(Criteria.where("id")
-                    .is(plan.retAudioId()).and("deleted_at").isNull()), Audio.class)).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"2")));
+                    .is(plan.retAudioId()).and("deleted_at").isNull()) .columns("id,url,name,type".split(",")), Audio.class)).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"2")));
             Mono<ReturnLoop> returnLoop = code.flatMap(plan -> {
                 if (Objects.isNull(plan.returnLoopId())) {
                     return Mono.just(getReturnLoop());
                 } else {
-                    return template.selectOne(Query.query(Criteria.where("id").is(plan.returnLoopId()).and("deleted_at").isNull()), ReturnLoop.class).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"3")));
+                    return template.selectOne(Query.query(Criteria.where("id").is(plan.returnLoopId()).and("deleted_at").isNull()).columns("id,name,group_type,group_type_name,group_type_id,domain,is_show_list,return_list,return_number,type,domain_id".split(",")), ReturnLoop.class).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"3")));
                 }
             }).switchIfEmpty(Mono.just(getReturnLoop()));
-            Mono<List<Ad>> adtop = template.select(Query.query(Criteria.where("type").is(1).and("deleted_at").isNull()), Ad.class).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"4"))).collectList();////广告类型1顶部2底部3返回4安卓,ios的返回
-            Mono<List<Ad>> bottom = template.select(Query.query(Criteria.where("type").is(2).and("deleted_at").isNull()), Ad.class).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"5"))).collectList();
+            Mono<List<Ad>> adtop = template.select(Query.query(Criteria.where("type").is(1).and("deleted_at").isNull()).columns("id,name,type,image,show_beg_at,show_end_at,link".split(",")), Ad.class).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"4"))).collectList();////广告类型1顶部2底部3返回4安卓,ios的返回
+            Mono<List<Ad>> bottom = template.select(Query.query(Criteria.where("type").is(2).and("deleted_at").isNull()).columns("id,name,type,image,show_beg_at,show_end_at,link".split(",")), Ad.class).onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage()+"5"))).collectList();
 
 
             Mono<DataLists> dataListsMono = Mono.zip(code, listAudio, retAudioId, returnLoop, arrayListMono, adtop, bottom, wx_user_id).flatMap(f -> {
@@ -788,15 +789,18 @@ public class PlanNewOutController {
     private Mono<DataLists0> setAudioV(HftRequest request, Mono<DataLists0> dataLists0Mono) {
         Mono<DataLists0> zip = dataLists0Mono.flatMap(f -> {
             Mono<Audio> id = null;
+            String col="id,url,name,type";
             if (Objects.nonNull(request.getWx_user_id()) && !"".equals(request.getWx_user_id())) {
                 PlanNewBackgroupPoster qsSetting = f.getQsSetting();
                 if (Objects.nonNull(qsSetting) && Objects.nonNull(qsSetting.audioId()) && 0 != qsSetting.audioId()) {
-                    id = template.selectOne(Query.query(Criteria.where("id").is(qsSetting.audioId()).and("deleted_at").isNull()), Audio.class);
+                    id = template.selectOne(Query.query(Criteria.where("id").is(qsSetting.audioId()).and("deleted_at").isNull())
+                            .columns(col.split(",")), Audio.class);
                 }
             } else {
                 PlanNewBackgroupPoster fxSetting = f.getFxSetting();
                 if (Objects.nonNull(fxSetting) && Objects.nonNull(fxSetting.audioId()) && 0 != fxSetting.audioId()) {
-                    id = template.selectOne(Query.query(Criteria.where("id").is(fxSetting.audioId()).and("deleted_at").isNull()), Audio.class);
+                    id = template.selectOne(Query.query(Criteria.where("id").is(fxSetting.audioId()).and("deleted_at").isNull())
+                                    .columns(col.split(",")), Audio.class);
                 }
             }
             if (Objects.isNull(id)) {
@@ -824,18 +828,22 @@ public class PlanNewOutController {
 
     private Mono<List<PlanNewBackgroupPoster>> getPlanNewBackgroupPoster(Mono<PlanNew> code) {
         return code.flatMap(plan -> template.select(Query.query(Criteria.where("plan_new_id")
-                .is(plan.planNewId())).sort(Sort.by(Sort.Order.asc("idx"))), PlanNewBackgroupPoster.class)
+                .is(plan.planNewId())).sort(Sort.by(Sort.Order.asc("idx")))
+                .columns("id,audio_id,group_id,image,kefu,limit_time,limit_time_remark,status,idx,service_group_id,service_group_type,qs_or_fx,plan_new_id,generate_images_json,generate_images_url".split(",")), PlanNewBackgroupPoster.class)
                 .collectList());
     }
 
+
     private Mono<List<Poster>> getPoster(Mono<PlanNew> code) {
         return code.flatMap(plan -> template.select(Query.query(Criteria.where("poster_template_id")
-                .is(plan.posterTemplateId())).sort(Sort.by(Sort.Order.asc("created_at"))), Poster.class).collectList());
+                .is(plan.posterTemplateId()))
+                .columns("poster_id,poster_template_id,poster_template,generate_images_json,generate_images_url".split(","))
+                .sort(Sort.by(Sort.Order.asc("created_at"))), Poster.class).collectList());
     }
 
     private Mono<PosterTemplate> getPoster_template_id(Mono<PlanNew> code) {
         return code.flatMap(plan -> template.selectOne(Query.query(Criteria.where("poster_template_id")
-                .is(plan.posterTemplateId())), PosterTemplate.class));
+                .is(plan.posterTemplateId())).columns("poster_template_id,poster_template_name".split(",")), PosterTemplate.class));
     }
     private StringBuilder getStringBuilder(GoRequest goRequest) {
         Optional<Item> first = goRequest.getItem().stream().filter(ff -> "cover".equals(ff.getT()) ).findFirst();