plan-java v0.24

(cherry picked from commit 5a57ee81b31a4012a3e10e2d9e60a8797627489a)

launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/PlanNewController.java

@@ -1,6 +1,7 @@
 package com.webflux.launchadmin.mysql.controller.planNew;
 
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.RandomUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.webflux.launchadmin.config.BaseContextHandler;
@@ -58,6 +59,29 @@ public class PlanNewController {
 
 
     /**
+     *通过 code and type 查询 domain
+     * @param code
+     * @param type
+     * @return {@link Mono}<{@link RStatus}<{@link DomainSelectRes}>>
+     */
+    @GetMapping("domain/select")
+    public Mono<RStatus<DomainSelectRes>> domainSelect(@RequestParam("code") String code,@RequestParam("type") String type ){
+        Mono<PlanNew> code1 = template.selectOne(Query.query(Criteria.where("code").is(code)), PlanNew.class);
+        Mono<DomainSelectRes> domainSelectResMono1 = code1.flatMap(f -> template.select(Query.query(Criteria.where("group_type_id").is(f.groupId())
+                .and("status").is(1).and("type").is(type)), DomainSelect.class)
+                .switchIfEmpty(Mono.error(new BaseException(" code错误")))
+                .onErrorResume(throwable -> Mono.error(new Exception(throwable.getMessage()))).collectList().flatMap(fm -> {
+                    DomainSelectRes domainSelectRes = new DomainSelectRes();
+                    int i = RandomUtil.randomInt(0, fm.size());
+                    domainSelectRes.setDomain(fm.get(i).domain());
+                    domainSelectRes.setPath("");
+                    domainSelectRes.setUnique(IdUtil.fastSimpleUUID());
+                    return Mono.just(domainSelectRes);
+                }));
+        return RStatus.success(domainSelectResMono1);
+    }
+    /**
+     *
      * 分享、清水背景组-回显
      * @param planNewId 计划id
      * @param qsOrFx 1：分享 2：清水

launch-admin/src/main/java/com/webflux/launchadmin/mysql/controller/planNew/res/DomainSelectRes.java

@@ -0,0 +1,10 @@
+package com.webflux.launchadmin.mysql.controller.planNew.res;
+
+import lombok.Data;
+
+@Data
+public class DomainSelectRes {
+   private String domain ;
+    private String path ;
+    private String unique ;
+}

launch-admin/src/main/java/com/webflux/launchadmin/mysql/entity/planNew/DomainSelect.java

@@ -0,0 +1,15 @@
+package com.webflux.launchadmin.mysql.entity.planNew;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+@Table("domain")
+public record DomainSelect(
+        @Id Long id,
+        Integer groupType, //类型 1素材分类2清水分类
+        String domain, //域名
+        String type,
+        String status,
+        Integer groupTypeId
+) {
+}