result数据保存bug修复

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

@@ -50,8 +50,13 @@ public class AnalyseEntityServiceImpl extends BaseEntityServiceImpl {
     {
         if(0==RETVALUE)
             return;
-
-        List<ExecResult> saveResults = new ArrayList<>();
+        List<ExecResult> saveResults;
+        if(param.containsKey(Tag_SaveResults)){
+            saveResults = (List<ExecResult>) param.get(Tag_SaveResults);
+        }else{
+            saveResults = new ArrayList<>();
+            param.set(Tag_SaveResults, saveResults);
+        }
         ExecResult result=new ExecResult();
         result.setRuleid(RULEID);
         result.setRulename(RULENAME);
@@ -147,9 +152,6 @@ public class AnalyseEntityServiceImpl extends BaseEntityServiceImpl {
                 }
             }
 
-            if(saveResults.size() > 0){
-                param.set(Tag_SaveResults, saveResults);
-            }
         }
 
     }

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

 package cn.ibizlab.core.extensions.service;
 
 import cn.ibizlab.core.analysis.domain.DABuild;
-import cn.ibizlab.core.analysis.domain.DADimension;
 import cn.ibizlab.core.analysis.domain.DAMetric;
-import cn.ibizlab.core.analysis.filter.DABuildSearchContext;
-import cn.ibizlab.core.analysis.filter.DADimensionSearchContext;
 import cn.ibizlab.core.analysis.filter.DAMetricSearchContext;
 import cn.ibizlab.core.analysis.service.IDABuildService;
 import cn.ibizlab.core.analysis.service.IDADimensionService;
@@ -18,7 +15,6 @@ import cn.ibizlab.core.lite.extensions.model.DataModel;
 import cn.ibizlab.core.lite.extensions.model.Property;
 import cn.ibizlab.core.lite.extensions.service.LiteModelService;
 import cn.ibizlab.core.lite.filter.DstDataSourceSearchContext;
-import cn.ibizlab.core.lite.filter.MetaFieldSearchContext;
 import cn.ibizlab.core.lite.service.*;
 import cn.ibizlab.core.lite.service.impl.MetaModelServiceImpl;
 import cn.ibizlab.core.rule.domain.RuleItem;
@@ -29,7 +25,6 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.base.Joiner;
-import liquibase.pro.packaged.D;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;

ibzdst-core/src/main/java/cn/ibizlab/core/extensions/util/DefaultMQProducerService.java

@@ -43,6 +43,7 @@ public class DefaultMQProducerService {
     public void sendToMQ(ResultsMQMsg resultMQMsg, String tags) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
         String msg = JSON.toJSONString(resultMQMsg);
         Message sendMsg = new Message(resultsTopic, tags, msg.getBytes());
+        sendMsg.setKeys(resultMQMsg.getKeyValueField());
         SendResult sendResult = defaultMQProducer.send(sendMsg);
         log.info("构建消息发送响应：" + sendResult.toString());
     }