Drools融合会话伪时钟未按预期工作

Question

在运行规则之前，我正在尝试将KieSessiondate设置为与我对象中的日期变量相同的日期。我使用此配置来创建我的KieSession

KieSessionConfiguration configuration = KieServices.Factory.get().newKieSessionConfiguration();
configuration.setOption(ClockTypeOption.get("pseudo"));

在运行规则之前，我使用AdvanceTime（）将会话的日期设置为所需日期。

final SessionPseudoClock clock = kSession.getSessionClock();
clock.advanceTime(object.getDate().getTime() - System.currentTimeMillis(), TimeUnit.MILLISECONDS);

final List<Command<?>> commands = new ArrayList<>();

commands.add(CommandFactory.newInsertElements(objects)
commands.add(CommandFactory.newInsert(object, "object"));

final ExecutionResults results = kSession.execute(CommandFactory.newBatchExecution(commands));

这导致使用滑动窗口的规则出现错误。比如说，检查1小时内通过的对象，而我在最后一个小时内没有任何对象。前一天我只有3件物品。下面是一个对象数据集示例。

objects: [
  {
    clientId: "id",
    date: 2021-02-09T12:00:38.249Z,
    ...
  }
  {
    clientId: "id",
    date: 2021-02-09T13:00:38.249Z,
    ...
  }
  {
    clientId: "id",
    date: 2021-02-09T14:00:38.249Z,
    ...
  }
]

我有一条规则，检查在1小时内是否有超过2个对象具有相同的客户ID。

$object : Object($clientId : clientId)
List( size > 2 ) from collect ( Object( this before $object, clientId == $clientId ) over window:time(1h))

当我用这些值传递对象时。上面的规则返回true，但我们显然没有任何日期在最后一个小时内的对象。

  { clientId: "id", date: 2021-02-10T14:00:38.249Z, ... }

我相信这是因为它以前工作的新配置而损坏的（当我没有尝试更改会话时钟时），但我希望会话日期等于对象日期。任何人都知道这里有什么问题以及如何解决它？

Answer 1

正如冷冻豌豆的Roddy所说，您需要在每次插入事件之间操纵SessionPseudoClock。我将执行一个新的命令，扩展插入元素命令和覆盖它的执行方法：

    @Override
    public Collection<FactHandle> execute(Context context) {

        KieSession kSession = ((RegistryContext) context).lookup(KieSession.class);
        List<FactHandle> handles = new ArrayList<>();

        Object workingMemory = StringUtils.isEmpty(super.getEntryPoint()) ?
                kSession :
                kSession.getEntryPoint(super.getEntryPoint());

        SessionPseudoClock clock = kSession.getSessionClock();

        super.objects.forEach(event -> {
            clock.advanceTime(((YourObject) event).getDate().getTime() - clock.getCurrentTime(), TimeUnit.MILLISECONDS);
            handles.add(((EntryPoint) workingMemory).insert(event));
        });

        ...

        return handles;
    }

而不是：

commands.add(CommandFactory.newInsertElements(objects));

我会：

commands.add(new YourInsertElementsCommand(objects));