import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public List<String> determineWorkgroups(TaskTemplate taskTemplate, TaskInstance taskInstance) throws StrategyException {
    KieBase knowledgeBase = getKnowledgeBase();

    StatelessKieSession knowledgeSession = knowledgeBase.newStatelessKieSession();

    List<Object> facts = new ArrayList<Object>();
    facts.add(getParameters());
    knowledgeSession.setGlobal("taskTemplate", taskTemplate);
    knowledgeSession.setGlobal("taskInstance", taskInstance);
    knowledgeSession.setGlobal("now", new Date());

    knowledgeSession.execute(CommandFactory.newInsertElements(facts));

    return taskInstance.getWorkgroups();
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public Date determineDueDate(TaskTemplate taskTemplate) throws StrategyException {

    TaskInstance taskInstanceVO = new TaskInstance();  // for holding values

    // execute rules only once (results are stored in taskInstanceVO)
    KieBase knowledgeBase = getKnowledgeBase();
    StatelessKieSession knowledgeSession = knowledgeBase.newStatelessKieSession();

    List<Object> facts = new ArrayList<Object>();
    facts.add(getParameters());
    knowledgeSession.setGlobal("taskTemplate", taskTemplate);
    knowledgeSession.setGlobal("taskInstance", taskInstanceVO);

    knowledgeSession.execute(CommandFactory.newInsertElements(facts));

    return Date.from(taskInstanceVO.getDue());
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
public Meal recommendMeal(Person person) throws BusinessException {
    StatelessKieSession kieSession = kContainer.newStatelessKieSession();

    InsertObjectCommand insertObjectCommand = new InsertObjectCommand(person);
    FireAllRulesCommand fireAllRulesCommand = new FireAllRulesCommand();
    QueryCommand queryCommand = new QueryCommand("results", "getMeal", (Object[]) null);
    List<GenericCommand<?>> commands = new ArrayList<GenericCommand<?>>();
    commands.add(insertObjectCommand);
    commands.add(fireAllRulesCommand);
    commands.add(queryCommand);
    BatchExecutionCommand batch = new BatchExecutionCommandImpl(commands);

    ExecutionResults results = kieSession.execute(batch);
    QueryResults queryResults = (QueryResults) results.getValue("results");
    Iterator<QueryResultsRow> iterator = queryResults.iterator();
    while (iterator.hasNext()) {
        Meal meal = (Meal) iterator.next().get("$m");
        if (meal != null) {
            System.out.println("Meal : " + meal);
            return meal;
        }
    }

    return null;
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public Object execute(Asset rulesAsset, Operand input) throws ExecutionException {

    ClassLoader cloudClassLoader = null;
    if (input.getContext() != null && input.getContext().getPackage() != null)
        cloudClassLoader = input.getContext().getPackage().getCloudClassLoader();
    if (cloudClassLoader == null) // fall back to rules asset pkg classloader
        cloudClassLoader = PackageCache.getPackage(rulesAsset.getPackageName()).getCloudClassLoader();

    KnowledgeBaseAsset kbAsset = DroolsKnowledgeBaseCache
            .getKnowledgeBaseAsset(rulesAsset.getName(), null, null, cloudClassLoader);
    if (kbAsset == null) {
        throw new ExecutionException("Cannot load KnowledgeBase asset: "
                + rulesAsset.getPackageName() + "/" + rulesAsset.getLabel());
    }

    KieBase knowledgeBase = kbAsset.getKnowledgeBase();

    StatelessKieSession kSession = knowledgeBase.newStatelessKieSession();

    List<Object> facts = new ArrayList<Object>();
    if (input.getInput() != null) {
        facts.add(input.getInput()); // direct access
        if (input.getInput() instanceof Jsonable)
            facts.add(((Jsonable)input.getInput()).getJson());
    }

    kSession.setGlobal("operand", input);
    kSession.execute(CommandFactory.newInsertElements(facts));
    return input.getResult();
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public String getSubTaskPlan(TaskRuntimeContext masterTaskContext) throws StrategyException {
    TaskInstance masterTaskInstance = masterTaskContext.getTaskInstance();
    KieBase knowledgeBase = getKnowledgeBase();

    StatelessKieSession knowledgeSession = knowledgeBase.newStatelessKieSession();

    List<Object> facts = new ArrayList<Object>();
    facts.add(getParameters());
    knowledgeSession.setGlobal("masterTaskInstance", masterTaskInstance);
    SubTaskPlan subTaskPlan = new SubTaskPlan();
    knowledgeSession.setGlobal("subTaskPlan", subTaskPlan);
    knowledgeSession.setGlobal("now", new Date());

    knowledgeSession.execute(CommandFactory.newInsertElements(facts));
    try {
        String planXml = marshalJaxb(subTaskPlan);
        if (logger.isDebugEnabled()) {
            logger.debug("SubTask plan XML: " + planXml);
        }
        return planXml;
    }
    catch (Exception ex) {
        throw new StrategyException(ex.getMessage(), ex);
    }

}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public RuleServlet() {
    Inspector inspector = new Inspector();
    KieServices kieServices = KieServices.Factory.get();
    // returns default session
    StatelessKieSession kieSession = kieServices.getKieClasspathContainer().newStatelessKieSession();
    KieBase kieBase = kieSession.getKieBase();
    this.rules = inspector.inspectBase(kieBase);
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
private StatelessKieSession getStatelessKieSessionFromResource(Resource resource) {
    KieServices ks = KieServices.Factory.get();
    KieFileSystem kfs = ks.newKieFileSystem();

    kfs.write(resource);

    KieBuilder kieBuilder = ks.newKieBuilder(kfs).buildAll();

    List<Message> errors = kieBuilder.getResults().getMessages(Message.Level.ERROR);
    if (!errors.isEmpty()) {
        fail("" + errors);
    }

    return ks.newKieContainer(ks.getRepository().getDefaultReleaseId()).newStatelessKieSession();
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
private StatelessKieSession getStatelessKieSessionFromResource(Resource resource) throws Exception {
    KieServices ks = KieServices.Factory.get();
    KieFileSystem kfs = ks.newKieFileSystem();

    kfs.write(resource);

    KieBuilder kieBuilder = ks.newKieBuilder(kfs).buildAll();

    List<Message> errors = kieBuilder.getResults().getMessages(Message.Level.ERROR);
    if (!errors.isEmpty()) {
        fail("" + errors);
    }

    return ks.newKieContainer(ks.getRepository().getDefaultReleaseId()).newStatelessKieSession();
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testManualFireAllRules() throws Exception {
    String str = "";
    str += "package org.kie \n";
    str += "import org.kie.camel.testdomain.Cheese \n";
    str += "global java.util.List list1 \n";
    str += "rule rule1 \n";
    str += "  when \n";
    str += "    $c : Cheese() \n";
    str += " \n";
    str += "  then \n";
    str += "    $c.setPrice( $c.getPrice() + 5 ); \n";
    str += "    list1.add( $c );";
    str += "end\n";

    StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
    setExec(ksession);

    String outXml = execContent("testManualFireAllRules.in.1");

    ExecutionResults result = unmarshalOutXml(outXml, ExecutionResults.class);

    assertXMLEqual(getContent("testManualFireAllRules.expected.1", ((FactHandle)result.getFactHandle("outBrie")).toExternalForm()), outXml);

    // brie should not have been added to the list
    List list = (List)result.getValue("list1");
    Cheese stilton25 = new Cheese("stilton", 30);
    Cheese stilton30 = new Cheese("stilton", 35);

    Set expectedList = new HashSet();
    expectedList.add(stilton25);
    expectedList.add(stilton30);

    assertEquals(expectedList, new HashSet(list));

    // brie should not have changed
    Cheese brie10 = new Cheese("brie", 10);
    brie10.setOldPrice(5);
    assertEquals(brie10, result.getValue("outBrie"));
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public void execute() throws ActivityException {

    String knowledgeBaseName = null;
    String knowledgeBaseVersion = null;
    try {
        knowledgeBaseName = getAttributeValueSmart(KNOWLEDGE_BASE);
        knowledgeBaseVersion = getAttributeValueSmart(KNOWLEDGE_BASE_ASSET_VERSION);
    }
    catch (PropertyException ex) {
        throw new ActivityException(ex.getMessage(), ex);
    }

    if (StringHelper.isEmpty(knowledgeBaseName))
        throw new ActivityException("Missing attribute: " + KNOWLEDGE_BASE);

    KieBase knowledgeBase = getKnowledgeBase(knowledgeBaseName, knowledgeBaseVersion);
    if (knowledgeBase == null)
        throw new ActivityException("Cannot load KnowledgeBase: " + knowledgeBaseName);

    // TODO stateful session option
    StatelessKieSession kSession = knowledgeBase.newStatelessKieSession();

    List<Object> facts = new ArrayList<Object>();
    Map<String,Object> values = new HashMap<String,Object>();

    for (VariableInstance variableInstance : getParameters()) {
        Object value = getVariableValue(variableInstance.getName());
        values.put(variableInstance.getName(), value);
    }
    facts.add(values);

    setGlobalValues(kSession);

    kSession.execute(CommandFactory.newInsertElements(facts));

    String temp = getAttributeValue(OUTPUTDOCS);
    setOutputDocuments(temp == null ? new String[0] : StringHelper.parseList(temp).toArray(new String[0]));

    // TODO handle document variables
    Process processVO = getProcessDefinition();
    for (Variable variable : processVO.getVariables()) {
        Object newValue = values.get(variable.getName());
        if (newValue != null)
            setVariableValue(variable.getName(), variable.getType(), newValue);
    }
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
protected void setGlobalValues(StatelessKieSession knowledgeSession) throws ActivityException {
    knowledgeSession.setGlobal("activity", this); // TODO deprecate
    knowledgeSession.setGlobal("runtimeContext", getRuntimeContext());
    knowledgeSession.setGlobal("now", new Date());
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public static StatelessKieSession getStatelessKnowledgeSession(KieContainer kieContainer, String sessionName) {
     StatelessKieSession kSession = kieContainer.newStatelessKieSession(sessionName);

    return kSession;
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public static StatelessKieSession getStatelessKnowledgeSession(KieContainer kieContainer, String sessionName) {
    StatelessKieSession kSession = kieContainer.newStatelessKieSession(sessionName);

    return kSession;
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
private DroolsSession<?> createStatelessSessionSingleRuleFile() {
    StatelessKieSession statelessKieSession = kieBase.newStatelessKieSession();
    return new DroolsStatelessSession(statelessKieSession);
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
public DroolsStatelessSession(StatelessKieSession statelessKieSession) {
    this.kSession = statelessKieSession;
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
/**
 * @param ksession the ksession to set
 */
public void setKsession(StatelessKieSession ksession) {
    this.ksession = ksession;
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Override
public StatelessKieSession newStatelessKieSession() {
    return kieContainer.newStatelessKieSession();
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testInsertElements() throws Exception {
    String str = "";
    str += "package org.drools \n";
    str += "import org.kie.camel.testdomain.Cheese \n";
    str += "global java.util.List list \n";
    str += "rule rule1 \n";
    str += "  when \n";
    str += "    $c : Cheese() \n";
    str += " \n";
    str += "  then \n";
    str += "    $c.setPrice( $c.getPrice() + 5 ); \n";
    str += "     list.add( $c );";
    str += "end\n";

    String inXml = "";
    inXml += "<batch-execution>";
    inXml += "  <set-global identifier='list' out-identifier='list' return-objects='true'>";
    inXml += "    <list/>";
    inXml += "  </set-global>";
    inXml += "  <insert-elements>";
    inXml += "    <org.kie.camel.testdomain.Cheese>";
    inXml += "      <type>stilton</type>";
    inXml += "      <price>25</price>";
    inXml += "      <oldPrice>0</oldPrice>";
    inXml += "    </org.kie.camel.testdomain.Cheese>";
    inXml += "    <org.kie.camel.testdomain.Cheese>";
    inXml += "      <type>stilton</type>";
    inXml += "      <price>30</price>";
    inXml += "      <oldPrice>0</oldPrice>";
    inXml += "    </org.kie.camel.testdomain.Cheese>";
    inXml += "  </insert-elements>";
    inXml += "</batch-execution>";

    StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
    setExec(ksession);

    String outXml = template.requestBody("direct:exec", inXml, String.class);

    String expectedXml = "";
    expectedXml += "<execution-results>\n";
    expectedXml += "  <result identifier='list'>\n";
    expectedXml += "    <list>\n";
    expectedXml += "      <org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "        <type>stilton</type>\n";
    expectedXml += "        <price>35</price>\n";
    expectedXml += "        <oldPrice>0</oldPrice>\n";
    expectedXml += "      </org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "      <org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "        <type>stilton</type>\n";
    expectedXml += "        <price>30</price>\n";
    expectedXml += "        <oldPrice>0</oldPrice>\n";
    expectedXml += "      </org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "    </list>\n";
    expectedXml += "  </result>\n";
    expectedXml += "</execution-results>\n";

    assertXMLEqual(expectedXml, outXml);

    ExecutionResults result = template.requestBody("direct:unmarshal", outXml, ExecutionResults.class);

    List list = (List)result.getValue("list");
    Cheese stilton25 = new Cheese("stilton", 30);
    Cheese stilton30 = new Cheese("stilton", 35);

    Set expectedList = new HashSet();
    expectedList.add(stilton25);
    expectedList.add(stilton30);

    assertEquals(expectedList, new HashSet(list));
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testSetGlobal() throws Exception {
    String str = "";
    str += "package org.drools \n";
    str += "import org.kie.camel.testdomain.Cheese \n";
    str += "global java.util.List list1 \n";
    str += "global java.util.List list2 \n";
    str += "global java.util.List list3 \n";
    str += "rule rule1 \n";
    str += "  when \n";
    str += "    $c : Cheese() \n";
    str += " \n";
    str += "  then \n";
    str += "    $c.setPrice( 30 ); \n";
    str += "    list1.add( $c ); \n";
    str += "    list2.add( $c ); \n";
    str += "    list3.add( $c ); \n";
    str += "end\n";

    String inXml = "";
    inXml += "<batch-execution>";
    inXml += "  <set-global identifier='list1'>";
    inXml += "    <list/>";
    inXml += "  </set-global>";
    inXml += "  <set-global identifier='list2' out-identifier='list2'>";
    inXml += "    <list/>";
    inXml += "  </set-global>";
    inXml += "  <set-global identifier='list3' out-identifier='outList3'>";
    inXml += "    <list/>";
    inXml += "  </set-global>";
    inXml += "  <insert>";
    inXml += "    <org.kie.camel.testdomain.Cheese>";
    inXml += "      <type>stilton</type>";
    inXml += "      <price>5</price>";
    inXml += "      <oldPrice>0</oldPrice>";
    inXml += "  </org.kie.camel.testdomain.Cheese>";
    inXml += "  </insert>";
    inXml += "</batch-execution>";

    StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
    setExec(ksession);

    String outXml = template.requestBody("direct:exec", inXml, String.class);

    String expectedXml = "";
    expectedXml += "<execution-results>\n";
    expectedXml += "  <result identifier='list2'>\n";
    expectedXml += "    <list>\n";
    expectedXml += "      <org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "        <type>stilton</type>\n";
    expectedXml += "        <price>30</price>\n";
    expectedXml += "        <oldPrice>0</oldPrice>\n";
    expectedXml += "      </org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "    </list>\n";
    expectedXml += "  </result>\n";
    expectedXml += "  <result identifier='outList3'>\n";
    expectedXml += "    <list>\n";
    expectedXml += "      <org.kie.camel.testdomain.Cheese reference='../../../result/list/org.kie.camel.testdomain.Cheese'/>\n";
    expectedXml += "    </list>\n";
    expectedXml += "  </result>\n";
    expectedXml += "</execution-results>\n";

    assertXMLEqual(expectedXml, outXml);

    ExecutionResults result = (ExecutionResults)BatchExecutionHelper.newXStreamMarshaller().fromXML(outXml);
    Cheese stilton = new Cheese("stilton", 30);

    assertNull(result.getValue("list1"));

    List list2 = (List)result.getValue("list2");
    assertEquals(1, list2.size());
    assertEquals(stilton, list2.get(0));

    List list3 = (List)result.getValue("outList3");
    assertEquals(1, list3.size());
    assertEquals(stilton, list3.get(0));
}
 

import org.kie.api.runtime.StatelessKieSession; //导入依赖的package包/类
@Test
public void testGetGlobal() throws Exception {
    String str = "";
    str += "package org.drools \n";
    str += "import org.kie.camel.testdomain.Cheese \n";
    str += "global java.util.List list \n";
    str += "rule rule1 \n";
    str += "  when \n";
    str += "    $c : Cheese() \n";
    str += " \n";
    str += "  then \n";
    str += "    list.add( $c ); \n";
    str += "end\n";

    String inXml = "";
    inXml += "<batch-execution>";
    inXml += "  <set-global identifier='list'>";
    inXml += "    <list/>";
    inXml += "  </set-global>";
    inXml += "  <insert>";
    inXml += "    <org.kie.camel.testdomain.Cheese>";
    inXml += "      <type>stilton</type>";
    inXml += "      <price>25</price>";
    inXml += "      <oldPrice>0</oldPrice>";
    inXml += "    </org.kie.camel.testdomain.Cheese>";
    inXml += "  </insert>";
    inXml += "  <get-global identifier='list' out-identifier='out-list'/>";
    inXml += "</batch-execution>";

    StatelessKieSession ksession = getStatelessKieSession(ResourceFactory.newByteArrayResource(str.getBytes()));
    setExec(ksession);

    String outXml = template.requestBody("direct:exec", inXml, String.class);

    String expectedXml = "";
    expectedXml += "<execution-results>\n";
    expectedXml += "  <result identifier=\"out-list\">\n";
    expectedXml += "    <list>\n";
    expectedXml += "      <org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "        <type>stilton</type>\n";
    expectedXml += "        <price>25</price>\n";
    expectedXml += "        <oldPrice>0</oldPrice>\n";
    expectedXml += "      </org.kie.camel.testdomain.Cheese>\n";
    expectedXml += "    </list>\n";
    expectedXml += "  </result>\n";
    expectedXml += "</execution-results>\n";

    assertXMLEqual(expectedXml, outXml);
}