import React from 'react';
import { BlockSceneEnum, CollectionBlockModel } from '@nocobase/client-v2';
import { MultiRecordResource } from '@nocobase/flow-engine';
import { tExpr } from '../locale';

export class ManyRecordBlockModel extends CollectionBlockModel {
  static scene = BlockSceneEnum.many;

  // 声明使用 MultiRecordResource 管理数据
  createResource() {
    return this.context.makeResource(MultiRecordResource);
  }

  get resource() {
    return this.context.resource as MultiRecordResource;
  }

  renderComponent() {
    const data = this.resource.getData();   // TDataItem[]
    const count = this.resource.getCount(); // 总记录数

    return (
      <div>
        <h3>共 {count} 条记录（第 {this.resource.getPage()} 页）</h3>
        <pre>{JSON.stringify(data, null, 2)}</pre>
      </div>
    );
  }
}

ManyRecordBlockModel.define({
  label: tExpr('Many records block'),
});

import { ActionModel, ActionSceneEnum } from '@nocobase/client-v2';
import { MultiRecordResource } from '@nocobase/flow-engine';
import { tExpr } from '../locale';

export class NewTodoActionModel extends ActionModel {
  static scene = ActionSceneEnum.collection;

  defaultProps = {
    type: 'primary',
    children: tExpr('New todo'),
  };
}

NewTodoActionModel.define({
  label: tExpr('New todo'),
});

NewTodoActionModel.registerFlow({
  key: 'newTodoFlow',
  title: tExpr('New todo'),
  on: 'click',
  steps: {
    openForm: {
      async handler(ctx) {
        // 拿到当前区块的 resource
        const resource = ctx.blockModel?.resource as MultiRecordResource;
        if (!resource) return;

        ctx.viewer.dialog({
          title: ctx.t('New todo'),
          content: (view) => (
            <MyForm
              onSubmit={async (values) => {
                // 创建记录，创建后 resource 会自动 refresh
                await resource.create(values);
                ctx.message.success(ctx.t('Created successfully'));
                view.close();
              }}
              onCancel={() => view.close()}
            />
          ),
        });
      },
    },
  },
});

async handler(ctx) {
  const resource = ctx.blockModel?.resource as MultiRecordResource;

  // --- 创建 ---
  await resource.create({ title: 'New item', completed: false });
  // 不自动刷新
  await resource.create({ title: 'Draft' }, { refresh: false });

  // --- 读取 ---
  const items = resource.getData();     // TDataItem[]
  const count = resource.getCount();    // 总记录数
  const item = await resource.get(1);   // 通过主键获取单条

  // --- 更新 ---
  await resource.update(1, { title: 'Updated' });

  // --- 删除 ---
  await resource.destroy(1);            // 单条删除
  await resource.destroy([1, 2, 3]);    // 批量删除

  // --- 分页 ---
  resource.setPage(2);
  resource.setPageSize(50);
  await resource.refresh();
  // 或者用快捷方法
  await resource.goto(3);
  await resource.next();
  await resource.previous();

  // --- 刷新 ---
  await resource.refresh();
}

import React from 'react';
import { BlockSceneEnum, CollectionBlockModel } from '@nocobase/client-v2';
import { SingleRecordResource } from '@nocobase/flow-engine';
import { tExpr } from '../locale';

export class DetailBlockModel extends CollectionBlockModel {
  static scene = BlockSceneEnum.one;

  createResource() {
    return this.context.makeResource(SingleRecordResource);
  }

  get resource() {
    return this.context.resource as SingleRecordResource;
  }

  renderComponent() {
    const data = this.resource.getData(); // 单个对象或 null
    if (!data) return <div>加载中...</div>;

    return (
      <div>
        <h3>{data.title}</h3>
        <p>{data.content}</p>
      </div>
    );
  }
}

DetailBlockModel.define({
  label: tExpr('Detail block'),
});

async handler(ctx) {
  const resource = ctx.model.context.resource as SingleRecordResource;

  // --- 新建记录 ---
  resource.isNewRecord = true;
  await resource.save({ name: 'John', age: 30 });
  // save 内部调用 create action，完成后自动 refresh

  // --- 编辑已有记录 ---
  resource.setFilterByTk(1);  // 自动设置 isNewRecord = false
  await resource.refresh();   // 先加载当前数据
  const data = resource.getData();
  await resource.save({ ...data, name: 'Jane' });
  // save 内部调用 update action

  // --- 删除当前记录 ---
  await resource.destroy();   // 使用已设置的 filterByTk
}

resource.on('saved', (data) => {
  console.log('记录已保存:', data);
});

// 等于
{ status: { $eq: 'active' } }

// 不等于
{ status: { $ne: 'deleted' } }

// 大于
{ age: { $gt: 18 } }

// 包含（模糊匹配）
{ name: { $includes: 'test' } }

// 组合条件
{
  $and: [
    { status: { $eq: 'active' } },
    { age: { $gt: 18 } },
  ]
}

// 或条件
{
  $or: [
    { status: { $eq: 'active' } },
    { role: { $eq: 'admin' } },
  ]
}

// 添加多个过滤组
resource.addFilterGroup('status', { status: { $eq: 'active' } });
resource.addFilterGroup('age', { age: { $gt: 18 } });
// getFilter() 自动聚合为: { $and: [...] }

// 移除某个过滤组
resource.removeFilterGroup('status');

// 刷新应用过滤
await resource.refresh();