perf: cname记录支持批量导入和导出

packages/ui/certd-server/src/controller/user/cert/domain-controller.ts

@@ -1,6 +1,7 @@
 import { ALL, Body, Controller, Inject, Post, Provide, Query } from '@midwayjs/core';
 import { Constants, CrudController } from '@certd/lib-server';
 import {DomainService} from "../../../modules/cert/service/domain-service.js";
+import { checkPlus } from '@certd/plus-core';
 
 /**
  * 授权
@@ -79,12 +80,13 @@ export class DomainController extends CrudController<DomainService> {
   }
 
 
-  @Post('/sync/submit', { summary: Constants.per.authOnly })
-  async syncSubmit(@Body(ALL) body: any) {
+  @Post('/sync/import', { summary: Constants.per.authOnly })
+  async syncImport(@Body(ALL) body: any) {
     const { dnsProviderType, dnsProviderAccessId } = body;
     const req = {
       dnsProviderType, dnsProviderAccessId, userId: this.getUserId(),
     }
+    checkPlus()
     await this.service.doSyncFromProvider(req);
     return this.ok();
   }

packages/ui/certd-server/src/controller/user/cname/cname-record-controller.ts

@@ -99,4 +99,15 @@ export class CnameRecordController extends CrudController<CnameRecordService> {
     const res = await this.service.resetStatus(body.id);
     return this.ok(res);
   }
+ @Post('/import', { summary: Constants.per.authOnly })
+  async import(@Body(ALL) body: { domainList: string; cnameProviderId: any }) {
+    const userId = this.getUserId();
+    const res = await this.service.doImport({
+      userId,
+      domainList: body.domainList,
+      cnameProviderId: body.cnameProviderId,
+    });
+    return this.ok(res);
+  }
+
 }

packages/ui/certd-server/src/modules/cert/service/domain-service.ts

@@ -350,9 +350,9 @@ export class DomainService extends BaseService<DomainEntity> {
     const getDomainPage = async (pager: Pager) => {
       const pageRes = await this.page({
         query: query,
-        buildQuery(bq) {
-          bq.andWhere(" (expiration_date is null or expiration_date < :now) ", { now: dayjs().add(1, 'month').valueOf() })
-        },
+        // buildQuery(bq) {
+        //   bq.andWhere(" (expiration_date is null or expiration_date < :now) ", { now: dayjs().add(1, 'month').valueOf() })
+        // },
         page: {
           offset: pager.getOffset(),
           limit: pager.pageSize,

packages/ui/certd-server/src/modules/cert/service/task-executor.ts

@@ -9,7 +9,7 @@ export class BackTaskExecutor {
     }
     const oldTask = this.tasks[type][task.key]
     if (oldTask && oldTask.status === "running") {
-      throw new Error(`任务 ${task.key} 正在运行中`)
+      throw new Error(`任务 ${type}—${task.key} 正在运行中`)
     }
     this.tasks[type][task.key] = task
     this.run(type, task);
@@ -39,7 +39,7 @@ export class BackTaskExecutor {
 
   private async run(type: string, task: any) {
     if (task.status === "running") {
-      throw new Error(`任务 ${task.key} 正在运行中`)
+      throw new Error(`任务 ${type}—${task.key} 正在运行中`)
     }
     task.startTime = Date.now();
     task.clearTimeout();
@@ -47,7 +47,7 @@ export class BackTaskExecutor {
       task.status = "running";
       return await task.run(task);
     } catch (e) {
-      logger.error(`任务 ${task.title}[${task.key}] 执行失败`, e.message);
+      logger.error(`任务 ${task.title}[${type}-${task.key}] 执行失败`, e.message);
       task.status = "failed";
       task.error = e.message;
     } finally {

packages/ui/certd-server/src/modules/cname/service/cname-record-service.ts

@@ -22,6 +22,7 @@ import punycode from "punycode.js";
 import { SubDomainService } from "../../pipeline/service/sub-domain-service.js";
 import { SubDomainsGetter } from "../../pipeline/service/getter/sub-domain-getter.js";
 import { TaskServiceBuilder } from "../../pipeline/service/getter/task-service-getter.js";
+import { BackTask, taskExecutor } from "../../cert/service/task-executor.js";
 
 type CnameCheckCacheValue = {
   validating: boolean;
@@ -487,4 +488,49 @@ export class CnameRecordService extends BaseService<CnameRecordEntity> {
     }
     await this.getRepository().update(id, { status: "cname", mainDomain: "" });
   }
+
+  async doImport(req:{ userId: number; domainList: string; cnameProviderId: any }) {
+    const {userId,cnameProviderId,domainList} = req;
+    const domains = domainList.split("\n").map(item => item.trim()).filter(item => item.length > 0);
+    if (domains.length === 0) {
+      throw new ValidateException("域名列表不能为空");
+    }
+    if (!req.cnameProviderId) {
+      throw new ValidateException("CNAME服务提供商不能为空");
+    }
+   
+    taskExecutor.start("cnameImport",new BackTask({
+      key: "user_"+userId,
+      title: "导入CNAME记录",
+      run: async (task) => {
+        await this._import({ userId, domains, cnameProviderId },task);
+      }
+    }));
+  }
+
+  async _import(req :{ userId: number; domains: string[]; cnameProviderId: any },task:BackTask) {
+    const userId = req.userId;
+    for (const domain of req.domains) {
+      const old = await this.getRepository().findOne({
+        where: {
+          userId: req.userId,
+          domain,
+        },
+      });
+      if (old) {
+        logger.warn(`域名${domain}已存在，跳过`);
+      }
+      //开始导入
+      try{
+          await this.add({
+            userId,
+            domain: domain,
+            cnameProviderId: req.cnameProviderId,
+          });
+      }catch(e){
+        logger.error(`导入域名${domain}失败：${e.message}`);
+      }
+    }
+   
+  }
 }