交友-自定义二维码选择加群计划v0.02

(cherry picked from commit 373dfa06e123e9d7a30277e38ca4472df23f0e84)

launch-admin/src/main/java/com/webflux/launchadmin/mysql/service/planNew/goGenerate/GoGenerateService.java

@@ -1253,17 +1253,19 @@ public class GoGenerateService {
                 } else {
                     throw new BaseException("type错误::" + type);
                 }
-                Query query = Query.query(Criteria.where(column).is(planId)).columns("group_id", "code");
+
                 Mono<StringBuilder> stringMono;
                 if (1 == type) {
+                    Query query = Query.query(Criteria.where(column).is(planId)).columns("group_id", "code","import_domain");
                     stringMono = template.selectOne(query, PlanNew.class)
                             .switchIfEmpty(Mono.error(new BaseException("自定义二维码:裂变计划查询::PlanId 返回空结果::" + planId)))
                             .onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage())))
                             .flatMap(f1 -> {
                                 String code = f1.code();
-                                return getDomainSetV(ftm, planId, type, f1.groupId(), code);
+                                return getDomainSetV(ftm, planId, type, Long.valueOf(f1.importDomain()), code);
                             });
                 } else if (2 == type) {
+                    Query query = Query.query(Criteria.where(column).is(planId)).columns("group_id", "code");
                     stringMono = template.selectOne(query, ListeningPlanNew.class)
                             .switchIfEmpty(Mono.error(new BaseException("自定义二维码:听书计划查询::PlanId  返回空结果::" + planId)))
                             .onErrorResume(throwable -> Mono.error(new BaseException("select ListeningPlanNew::" + throwable.getMessage())))
@@ -1272,12 +1274,13 @@ public class GoGenerateService {
                                 return getDomainSetV(ftm, planId, type, f1.groupId(), code);
                             });
                 } else {
+                    Query query = Query.query(Criteria.where(column).is(planId)).columns("group_id", "code","import_domain");
                     stringMono = template.selectOne(query, PlanNewCommon.class)
                             .switchIfEmpty(Mono.error(new BaseException("自定义二维码:交友计划查询::PlanId 返回空结果::" + planId)))
                             .onErrorResume(throwable -> Mono.error(new BaseException(throwable.getMessage())))
                             .flatMap(f1 -> {
                                 String code = f1.code();
-                                return getDomainSetV(ftm, planId, type, f1.groupId(), code);
+                                return getDomainSetV(ftm, planId, type, Long.valueOf(f1.importDomain()), code);
                             });
                 }
                 return stringMono;