使用场景概览

// 返回要创建的子项目列表
const autoCreateSubProject = (ctx: AutoCreateSubProjectContext) : Promise<CreateProjectTaskDto[]>

// 返回要创建的子项目列表
interface AutoCreateSubProjectContext extends ServerProjectContext {
  // 此标识用于识别是否由订阅触发， 脚本中可以借用此标识规避一些副作用(比如运行创建子流程脚本时需要额外创建一些数据)
  trigger_by_subscription: boolean;
}

type CreateProjectTaskDto = {
  flow_type: string;
  key: string;
  /**
   * 若为true, 会先把对应的用户创建的项目删除再走创建操作
   * @see packages/huanpingtong-server/src/model/project.ts#createProjectByTask
   */
  delete: boolean;
  data: CreateProjectTaskDataDto;
}
type CreateProjectTaskDataDto = {
  form: SimpleFormValue;
  contract_id?:string;
  subscribe?: {
    // 是否跟随新的task结果自动删除
    auto_delete?: boolean
    // 是否跟随新的task结果自动创建新的子流程项目
    auto_add?: boolean;
    subscriptions: SubscriptionItem[]
  };
} & ProjectCreateDto;

export interface BasicSubscriptionItem {
  // 处理类型和设置
  handle: string;
  setting?: Record<string, any>;
  // 被订阅者表名
  publisher_table: string;
  // 被订阅者表单id
  publisher_id: number;
  // 是否激活
  enable: boolean;
}
// 处理类型声明
export interface FormSubscriptionItem extends BasicSubscriptionItem {
  handle: 'form';
  setting?: Record<string, any>;
}
export interface ProjectSubscriptionItem extends BasicSubscriptionItem {
  handle: 'project';
  setting?: {
    // 要同步的子项目基础字段
    // 特别的，当存在ext_config 字段时, 会和当前数据库中的project.ext_config 进行Object.assign 合并操作
    fields?: (keyof ProjectCreateDto)[];
  };
}

export type SubscriptionItem = FormSubscriptionItem | ProjectSubscriptionItem;

// 根据主项目的表单数据创建多个子流程
const itemList = ctx.$META_FORM_KEY.sub_form_list || [];

// 为每个列表项创建一个子流程
return itemList.map((item, index) => {
  return {
    // 使用唯一ID作为contract_id，用于订阅时后续更新或删除
    contract_id: `item_${item.id}`,
    
    // 子项目名称
    name: `${ctx.project.name}-子项目${index + 1}`,
    // 子项目表单数据
    form: {
      key_to_value: {
        name: item.name,
        price: item.price,
      }
    },
    
    // 订阅父项目的表单变化
    subscribe: {
      auto_delete: true,  // 当父项目中对应项被删除时，自动删除子项目
      auto_add: true,     // 当父项目中新增项时，自动创建新的子项目
      subscriptions: [
        {
          handle: 'form',
          publisher_table: 'form',
          publisher_id: mainFormId,
          enable: true
        },
        {
          handle: 'project',
          publisher_table: 'project',
          publisher_id: ctx.project.id,
          enable: true,
          setting: {
            fields: ['name', 'status', 'ext_config'] // 同步项目基本信息
          }
        }
      ]
    }
  };
});

// 创建子项目并订阅父项目的基本信息变更
return [
  {
    contract_id: "main_sub_project",
    flow_type: "flow_type_B",
    key: "key_B",
    delete: false,
    data: {
      name: `${ctx.project.name}-辅助项目`,
      form: {
        key_to_value: {
          reference_id: ctx.project.id
        }
      },
      subscribe: {
        auto_delete: true,
        subscriptions: [
          // 订阅父项目的基本信息变更
          {
            handle: 'project',
            publisher_table: 'project',
            publisher_id: ctx.project.id,
            enable: true,
            setting: {
              // 指定需要同步的字段
              fields: ['name', 'status', 'ext_config']
            }
          }
        ]
      }
    }
  }
];