规则构建返回符合规则条件的数据集合

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/domain/BaseRequest.java

 package cn.ibizlab.core.extensions.domain;
 
 import cn.ibizlab.core.lite.extensions.domain.ModelObj;
+import cn.ibizlab.core.rule.domain.ExecResult;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.annotation.JSONField;
 import com.fasterxml.jackson.annotation.JsonIgnore;
@@ -58,6 +59,7 @@ public class BaseRequest
 	private String batch;
 	private List<String> rules;
 	private List<String> ruleIds;
+	private List<ExecResult> results;
 
 	private HashSet<String> fillpropertys;
 

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/service/AnalyseEntityServiceImpl.java

@@ -32,7 +32,6 @@ import java.util.List;
 @Service("AnalyseEntityServiceImpl")
 @ConditionalOnExpression("!''.equals('${cassandra.host:}')")
 public class AnalyseEntityServiceImpl extends BaseEntityServiceImpl {
-    public static final String Tag_SaveResults = "SAVERESULTS";
 
     @Autowired
     private MsgProducerService defaultMQProducerService;

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/service/BaseEntityServiceImpl.java

@@ -50,7 +50,7 @@ import java.util.List;
 @Slf4j
 public class BaseEntityServiceImpl implements BaseEntityService
 {
-
+	public static final String Tag_SaveResults = "SAVERESULTS";
 	public static final String Tag_EngineId = "engineId";
 	public static final String Tag_Batch_SyncRun = "SYNCRUN";
 
@@ -76,6 +76,13 @@ public class BaseEntityServiceImpl implements BaseEntityService
 		result.setName(RU_EXECRESULTNAME);
 		result.setRetValue(RETVALUE);
 
+		List<ExecResult> saveResults;
+		if(param.containsKey(Tag_SaveResults)){
+			saveResults = (List<ExecResult>) param.get(Tag_SaveResults);
+		}else{
+			saveResults = new ArrayList<>();
+			param.set(Tag_SaveResults, saveResults);
+		}
 
 		if(KEYVALUEFIELD==null)
 			KEYVALUEFIELD=param.getEmpty();
@@ -228,7 +235,7 @@ public class BaseEntityServiceImpl implements BaseEntityService
 
 				result2.setId(result2.getDefaultKey(true).toString());
 				result2.setRuleId(RULECODE);
-
+				saveResults.add(result2);
 				if (bSyncRun){
 					ruExecResultService.save(result2);
 				}else {
@@ -514,6 +521,16 @@ public class BaseEntityServiceImpl implements BaseEntityService
 					}
 					processRule(modelObj, modelObj.getRowKey(),strResId);
 
+					//设置符合规则条件的数据集合
+					Object saveResults = modelObj.get(Tag_SaveResults);
+					if(saveResults != null && saveResults instanceof List){
+						List<ExecResult> results = msg.getResults();
+						if(results == null){
+							msg.setResults((List<ExecResult>)saveResults);
+						}else{
+							results.addAll((List<ExecResult>)saveResults);
+						}
+					}
 				}
 				catch (Exception e)
 				{