java - 我应该根据哪个数据对象创建 Drools/Kie session ？

Question

我有以下 POJO:

public class Transaction {

    @Id
    private long id;

    private String organisationId;

    private String resposibleName;

    private DateTime transactionTime;

    private BigDecimal amount;

    ...

}

我想应用我的规则。例如，示例规则可能是关于其金额:

rule "SampleRule"
    when
        $transaction : Transaction( amount > 10)
    then
        $transaction.setStatus(Status.INVALID);
end

我还想应用一些更复杂的规则，例如:

1. WHEN每个相同交易的金额字段总和 organisationId上周内(基于 transactionTime )大于 x , THEN $transaction.setStatus(Status.INVALID);
2. WHEN过去有一笔相同的交易 responsibleName与当前正在评估的交易一样，但不同 organisationId比当前的THEN $transaction.setStatus(Status.INVALID);

当对 RESTful 端点进行查询时:

1. 我正在创建一个新的 KieSession
2. 添加单个Transaction反对 session ，
3. 使用不同的 POJO 添加可能与当前交易对象相关的更多交易对象(例如，将 PastTransaction 作为与 Transaction 具有相同字段的精确副本，我将添加由相同 organisationId 进行的多个交易使用 PastTransaction POJO，以便我可以在这些字段上累积金额字段，同时能够在我的 Transaction 对象上应用更多基本规则。
4. 以同样的方式，我添加由同一 responsibleName 进行的所有交易与 ResponsibleNameTransaction POJO，并编写一条规则来检查其中是否有一个不等于我的单Transaction中的一个KieSession 中的对象.

我想知道是否有一种更简单/更优化的方法来实现我一直在做的事情，并根据我正在形成的实体进行优化 KieSession是为了。我想将方法​​写入我的 Transaction POJO 并在规则执行中命中数据库(例如，编写一个返回列表的方法 getAllTransactionsByTheResponsibleName ，然后检查是否存在具有不同 organisationId 的对象)。以同样的方式，我可以将相关交易作为列表添加到 KieSession然后查询规则中的列表，这至少可以使我免于在不同名称下使用相同的 POJO。

更新:

根据评论进一步阐述，保留大约十亿个是否可行Transaction s 在工作内存中(所有事务的 session )？或者，我可以将每个负责/组织的交易放入 KieSession (每个负责人/组织的 session )。那么当 session 中有多个事务时(例如 $transaction.setStatus(Status.INVALID); 当 #1 为 true 时，$transaction 是一个)，我如何才能仅在正在评估的最新事务的字段上应用一些规则(甚至在其上设置一个字段)当前正在评估)？

Answer 1

让您的非技术人员完全独立地玩耍可能是不可能的。对您可能需要添加的内容进行全面讨论需要充分了解所有规则，而我没有这些知识。然而，即使有数十亿事务通过您的工作内存，您的 Q 中的 #1 和 #2 也可以得到处理。

用例 1:可以通过为每个账户保留 n 个每日金额的辅助事实(“AccountSums”)来检查某个时间范围内每个账户的阈值。对于任何新的交易，要么更新最后的总和，要么“移动”总和添加 0 总和并设置最后的总和，或者创建新的 AccountSums；维护最后 n 笔金额的总计 - 技术人员可以仅根据 AccountSums(或结合(最后)匹配的交易)编写支票。

rule "check 7 days limit"
when
    $t: Transaction( $orgId: organisationId,
                     $transT: transactionTime,
                     amount > 0, status == Status.VALID )
    AccountSums( organisationId == $orgId,
                 lastTransactionTime == $transT,
                 runningWeeklySum > 1000000 )
then
    modify( $t ){ setStatus( Status.INVALId ) }
end

rule "create AccountSums"
when
    $t: Transaction( $orgId: organisationId,
                     amount > 0 )
    not AccountSums( organisationId == $orgId )
then
    insert( new AccountSums( $orgId ) );
end 

您至少需要一条附加规则来“转移”总和等。

用例 2:维护一个辅助事实(“NameId”)，其中包含负责名称和组织 ID 的实例(或包含 Map 的单个实例)。如果另一个事务到达，则创建一个新的 NameId(或 Map 条目) ，或比较相等和不相等的 Id。

如果您的数据量如您所指示的那样，则必须压缩历史记录。也许可以让研究人员编写简单的评估规则，但是按照我在这里概述的思路设计规则模式，至少是为了压缩元数据，而不是你可以留给麻瓜的事情。