对外接口2

launch-admin/src/main/java/com/webflux/launchadmin/mysql/service/otherServices/OtherServicesImpl.java

@@ -112,7 +112,7 @@ public class OtherServicesImpl implements   OtherServicesInterface {
                         }
                         //saveRequest.setImportDomain(String.valueOf(saveRequest.getGroupId()));
                     }
-                    return getDomainSetV(groupId, code);
+                    return getDomainSetV(groupId, code,2);
                 });
     }
     private Mono<ByCodeGetImportDomainRes> getNewListeningNewPlan(String code, Query query) {
@@ -132,7 +132,7 @@ public class OtherServicesImpl implements   OtherServicesInterface {
                     if (Objects.isNull(groupId)) {
                         return Mono.error(new BaseException("查询裂变计划 groupId 值为 null"));
                     }
-                    return getDomainSetV(groupId, code);
+                    return getDomainSetV(groupId, code,1);
                 });
     }
 
@@ -159,14 +159,14 @@ public class OtherServicesImpl implements   OtherServicesInterface {
                     }catch (Exception e){
                         return Mono.error(new BaseException("查询听书计划入口域名类型值解析错误"+e.getMessage()));
                     }
-                    return getDomainSetV(groupId, code);
+                    return getDomainSetV(groupId, code,1);
                 });
     }
 
-    private Mono<ByCodeGetImportDomainRes> getDomainSetV( Long  groupId, String code) {
+    private Mono<ByCodeGetImportDomainRes> getDomainSetV( Long  groupId, String code,Integer type) {
         return template.select(Query.query(Criteria.where("group_type_id").is(groupId)
                 .and("status").is(1)
-                .and("type").is(1)
+                .and("type").is(type)
                 .and("deleted_at").isNull()),
                 DomainSelect.class)
                 .collectList()