OSBA 模块 — 开发者手册

public class User extends EditableObject<User> {

    private final PropertyInfo<Long> id = registerProperty(Long.class, "id");

    @DisplayName("User Name")
    @Required(message = "name is valid")
    private final PropertyInfo<String> name = registerProperty(String.class, "name");

    @DisplayName("User age")
    private final PropertyInfo<Integer> age = registerProperty(Integer.class, "age");

    public Long getId() { return getProperty(id); }
    public void setId(Long id) { loadProperty(this.id, id); }

    public String getName() { return getProperty(this.name); }
    public void setName(String name) { setProperty(this.name, name); }

    public int getAge() { return getProperty(age); }
    public void setAge(int age) { setProperty(this.age, age); }

    @Override
    protected void addRules() {
        super.addRules();
        getRules().addRule(new UserNameRule(this.name));
        getRules().addRule(new LambdaRule<>(this.age,
            (age, context) -> age != null && age >= 18,
            "Age must be at least 18"));
    }

    @FactoryCreate
    protected void create(String name) {
        super.create();
        setName(name);
        setId(Objects.requireNonNull(ObjectId.snowflake().getValue(Long.class)));
    }
}

// 继承 RuleBase 定义嵌套的自定义规则
public class UserNameRule extends RuleBase {
    public UserNameRule(PropertyInfo<?> property) { super(property); }

    @Override
    public CompletableFuture<Void> executeAsync(RuleContext context) {
        return CompletableFuture.runAsync(() -> {
            if (!(context.getTarget() instanceof User user)) return;
            var name = user.getName();
            if (name == null || name.trim().isEmpty()) {
                context.addErrorResult(
                    String.format("%s 不能为空", getProperty().getFriendlyName()));
            } else if (name.length() < 12) {
                context.addErrorResult(
                    String.format("%s 必须为 12 个字符", getProperty().getFriendlyName()));
            }
        });
    }
}

// 创建工厂
BusinessObjectFactory factory = new BusinessObjectFactory(serviceProvider);

// 创建新的 User 实例
User user = factory.create(User.class, "张三");

// 验证
boolean isValid = user.isValid();
if (!isValid) {
    BrokenRuleCollection brokenRules = user.getBrokenRules();
    // 处理验证错误
}

// 保存（异步）
user.save(false).thenRun(() -> {
    System.out.println("User saved: " + user.getId());
});

getRules().addRule(new LambdaRule<>(this.age,
    (age, context) -> {
        if (age == null || age < 18) {
            context.addErrorResult("年龄必须至少为 18 岁");
        }
        if (age != null && age > 150) {
            context.addErrorResult("年龄不能超过 150 岁");
        }
    })
);

@DisplayName("邮箱")
@Required(message = "邮箱不能为空")
@RegularExpression(value = "^[\\w.-]+@[\\w.-]+\\.[a-z]{2,}$", message = "邮箱格式不正确")
private final PropertyInfo<String> email = registerProperty(String.class, "email");

// addRules() 中添加 DataAnnotationRule 即可自动应用所有注解约束
@Override
protected void addRules() {
    super.addRules();
    getRules().addRule(new DataAnnotationRule(this.email));
}

user.addPropertyChangeListener(evt -> {
    System.out.println("属性变更: " + evt.getPropertyName()
        + " = " + evt.getOldValue() + " → " + evt.getNewValue());
});

user.setName("新用户名");
// 输出: 属性变更: name = 张三 → 新用户名

ObservableObject<User> user = new User();
// user.getEditState() == ObjectEditState.NONE

user.setName("张三");
// user.getEditState() == ObjectEditState.NEW（如果是新对象）或 ObjectEditState.CHANGED

user.markAsUnchanged();
// 清除变更历史

// 检查对象状态
boolean changed = user.isChanged();   // 是否有未保存的变更
boolean valid = user.isValid();       // 是否通过所有规则验证
boolean busy = user.isBusy();         // 是否有挂起的异步操作

@FactoryCreate
protected void create(String name) {
    super.create();
    setName(name);
    // 初始化默认值、生成 ID、发布事件等
}

@FactoryFetch
protected void fetch(Long id) {
    // 从持久层加载数据
    loadProperty(this.id, id);
    // loadProperty 会将字段标记为"未变更"，避免假变更检测
}

@FactoryUpdate
protected void update(String name, int age) {
    setProperty(this.name, name);  // 追踪变更
    setProperty(this.age, age);
}

@FactoryDelete
protected void delete() {
    // 标记为已删除
    markDeleted();
}

BusinessObjectFactory factory = new BusinessObjectFactory(serviceProvider);

// 创建并保存
User user = factory.create(User.class, "张三");
factory.insert(user);

// 获取
User existing = factory.fetch(User.class, 123L);

// 更新
existing.setName("新名称");
factory.update(existing);

// 删除
factory.delete(existing);