开始 > 分组 > 聚合 > 决策选项 聚合之后节点不会执行问题bugfix

bugs/note.txt

@@ -0,0 +1,25 @@
+
+BUG：
+基础指标模版下载报错
+数据源指标编辑 ， 这些变量值 没有绑定到界面上，接口返回是ok的 ，前端需要改一下 
+引擎列表 点名称 一直加载中
+决策复制版本 ，报错 
+
+
+
+t_machine_learning_models  model_field （模型解析字段） 字段长度太小
+ALTER TABLE t_machine_learning_models MODIFY COLUMN model_field varchar(4096) NOT NULL DEFAULT '' COMMENT '模型解析字段';
+
+
+
+优化点：
+数据中心 / 接口源 / 接口新建 修改 查看   请求地址 输入框加长 
+
+
+
+com.fibo.ddp.common.model.strategyx.decisiontable.DecisionTablesResult
+TODO 注意  添加决策表 时  实际对应的字段是 ro 和   colum ,待确认 ！！！
+
+
+
+

ddp/ddp-common/ddp-model/src/main/java/com/fibo/ddp/common/model/strategyx/decisiontable/DecisionTablesResult.java

@@ -1,6 +1,7 @@
 package com.fibo.ddp.common.model.strategyx.decisiontable;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.AllArgsConstructor;
@@ -29,8 +30,13 @@ public class DecisionTablesResult implements Serializable {
 
     private Long versionId;//决策表版本id
 
+    //   注意  添加决策表 时  实际对应的字段是 ro 和   colum ,待确认 ！！！
+
+    // 先注释 ， 数据库表加字段 解决 
+    // @TableField(value = "rowss")
     private Integer ro;//行数
 
+    // @TableField(value = "columnss")
     private Integer colum;//列数
 
     private String resultValue;//结果集二维数组

ddp/ddp-common/ddp-service/src/main/java/com/fibo/ddp/common/service/strategyx/aimodel/PMMLExecutor/impl/PMMLExecutorRFImpl.java

@@ -76,6 +76,9 @@ public class PMMLExecutorRFImpl implements PMMLExecutor {
         }
 
         Map<FieldName, ?> results = evaluator.evaluate(arguments);
+
+        System.out.println("pmml_predict_results: " + results);
+
         List<TargetField> targetFields = evaluator.getTargetFields();
 
         TargetField targetField = targetFields.get(0);
@@ -92,10 +95,10 @@ public class PMMLExecutorRFImpl implements PMMLExecutor {
             value_1 = tmpnum.doubleValue();
         }
 
-        //  TODO 不知道啥含义 先注释掉 返回结果
+        //  TODO   模型取值逻辑待确认
-        // if (targetFieldValue instanceof ProbabilityDistribution) {
+        if (targetFieldValue instanceof ProbabilityDistribution) {
-        //    value_1 = ((ProbabilityDistribution) targetFieldValue).getValue("1");
+            value_1 = ((ProbabilityDistribution) targetFieldValue).getValue("1");
-       // }
+        }
 
 
 

ddp/ddp-common/ddp-utils/src/main/java/com/fibo/ddp/common/utils/constant/ServiceFilterConstant.java

@@ -13,6 +13,7 @@ public class ServiceFilterConstant {
 		uriSet.add("/Riskmanage/v2/datamanage/datamanage/downTemplate");// 指标模板下载
 		uriSet.add("/Riskmanage/v2/datamanage/listmanage/downTemplate");// 名单库模板下载
 		uriSet.add("/Riskmanage/v3/analyse/decision");
+		uriSet.add("/Riskmanage/info/status");
 	}
 
 	public static boolean isSessionFilter(String uri) {

ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java

@@ -223,7 +223,12 @@ public class RiskEngineBusinessImpl implements RiskEngineBusiness {
                 resultSet.setOutput(JSONObject.toJSONString(tmpJsonObject));
                 resultSetMapper.insertResultSet(resultSet);
                 Integer resultId = resultSet.getId();
-//                this.monitorDecisionFlow(inputParam, engine, engineVersion, engineNodeList, outMap, paramJson, resultId);
+                // 20250325  去掉注释 ，写入监控表
+                try {
+                    this.monitorDecisionFlow(inputParam, engine, engineVersion, engineNodeList, outMap, paramJson, resultId);
+                }catch(Exception e){
+                    logger.error("monitorDecisionFlow_error", e);
+                }
                 // 正常返回结果回调
                 decisionCallback(engine.getCallbackUrl(), paramJson, result);
             }
@@ -318,11 +323,16 @@ public class RiskEngineBusinessImpl implements RiskEngineBusiness {
                     nextEngineNode = engineNodeMap.get(outMap.get("nextNode"));
                     outMap.remove("nextNode");
                 }
-
+                // 会导致 开始 > 分组 > 聚合 > 决策选项  不会执行 ，先注释掉  20250427
-                if (nextEngineNode != null && nextEngineNode.getNodeType() == NodeTypeEnum.AGGREGATION.getValue()) {
+                // if (nextEngineNode != null && nextEngineNode.getNodeType() == NodeTypeEnum.AGGREGATION.getValue()) {
                     // 并行节点后面的分支为多线程执行，执行到聚合节点则结束
-                    resultNode = nextEngineNode;
+                    //resultNode = nextEngineNode;
-                } else {
+                //} else {
+                    // resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap);
+                //}
+
+                //  20250427 之前的逻辑 会导致 开始 > 分组 > 聚合 > 决策选项  不会执行 ， 使用以下代码
+                if (nextEngineNode != null){
                     resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap);
                 }
             }

ddp/ddp-monitor/src/main/java/com/fibo/ddp/monitor/controller/decisionflow/MonitorController.java

@@ -47,7 +47,9 @@ public class MonitorController {
         Integer pageNo = param.get("pageNo") == null ? 1 : Integer.valueOf(param.get("pageNo").toString());
         Integer pageSize = param.get("pageSize") == null ? 10 : Integer.valueOf(param.get("pageSize").toString());
         PageHelper.startPage(pageNo, pageSize);
-        List<EngineResultSet> resultSets = MonitorCenterFactory.getMonitorCenterServiceImp(MonitorStorageType.HBase).getEngineResultSetBySegment(param);
+        // MonitorStorageType.HBase
+        // 20250325 MonitorStorageType.Mysql
+        List<EngineResultSet> resultSets = MonitorCenterFactory.getMonitorCenterServiceImp(MonitorStorageType.Mysql).getEngineResultSetBySegment(param);
         PageInfo<EngineResultSet> pageInfo = new PageInfo<>(resultSets);
         HashMap<String, Object> modelMap = new HashMap<>();
         modelMap.put("pager", pageInfo);

ddp/ddp-runner-api/src/main/resources/logging-config.xml

@@ -77,7 +77,7 @@
     <loggers>
 
         <!--过滤掉spring和mybatis的一些无用的DEBUG信息-->
-        <logger name="org.mybatis" level="info" additivity="false">
+        <logger name="org.mybatis" level="debug" additivity="false">
             <AppenderRef ref="Console"/>
         </logger>
         <!--监控系统信息-->
@@ -86,7 +86,7 @@
             <AppenderRef ref="Console"/>
         </Logger>
 
-        <root level="info">
+        <root level="debug">
             <appender-ref ref="Console"/>
             <appender-ref ref="Filelog"/>
             <appender-ref ref="RollingFileInfo"/>

h5-datax-manager/src/components/common/cont.vue

@@ -2,7 +2,7 @@
 
 <template>
 	<div class="cont_cont">
-		<!-- <div class="cont_left" v-loading="leftloading">
+		 <div class="cont_left" v-loading="leftloading">
 			<div class="cont_header">
 				<p class="cont_header_title">{{title}}</p>
 				<p class="cont_header_subtitle">{{title}}</p>
@@ -14,7 +14,7 @@
 				 @updatafilelist="updatafilelist" @delectFun="delectFun">
 				</fileHome>
 			</div>
-		</div> -->
+		</div>
 		<div 
       class="cont_right" 
       v-loading="contloading" 

h5-enginex-manager/src/components/page/EngineListV2.vue

@@ -214,7 +214,7 @@
 			// 表格中点击
 			engineDisplay: function(id) {
 				//alert(id);
-				let h5Path = '';
+				let h5Path = '/enginex';
 				window.localStorage.setItem("engineId", id);
 				bus.$emit('EngineSwitchover',id)
 				

sql/ddp-2.0.sql

@@ -481,6 +481,8 @@ CREATE TABLE `t_decision_tables_result` (
   `version_id` int(11) NOT NULL DEFAULT '0' COMMENT '决策表版本id',
   `rows` int(11) DEFAULT NULL COMMENT '行数',
   `columns` int(11) DEFAULT NULL COMMENT '列数',
+  `ro` int(11) DEFAULT NULL COMMENT '行数new',
+  `colum` int(11) DEFAULT NULL COMMENT '列数new',
   `result_value` longtext COMMENT '结果集二维数组',
   `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
   `update_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',

sql/update.sql

@@ -0,0 +1,31 @@
+
+
+
+
+create table t_list_db_version(
+ id int(11) NOT NULL AUTO_INCREMENT COMMENT '主键id',
+ list_db_id int(11) NOT NULL,
+ version_code varchar(255) DEFAULT NULL,
+ description varchar(4096) DEFAULT NULL,
+ result_field_en varchar(255) DEFAULT NULL,
+ status int(4)  DEFAULT NULL,
+ table_column varchar(1024) DEFAULT NULL,
+ match_type int(4)  DEFAULT NULL,
+ query_type int(4)  DEFAULT NULL,
+ query_field varchar(255) DEFAULT NULL ,
+ organ_id int(11) NOT NULL DEFAULT '0' COMMENT '组织id',
+ create_user_id int(11) NOT NULL DEFAULT '0' COMMENT '创建者id',
+ update_user_id int(11) NOT NULL DEFAULT '0' COMMENT '修改者id',
+ create_time datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建日期',
+ update_time datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改日期',
+ snapshot json DEFAULT NULL COMMENT '名单库版本配置快照',
+  PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC;
+
+
+ALTER TABLE t_machine_learning_models MODIFY COLUMN model_field varchar(4096) NOT NULL DEFAULT '' COMMENT '模型解析字段';
+
+ALTER TABLE t_decision_tables_result ADD COLUMN `ro` int DEFAULT NULL COMMENT '行数';
+ALTER TABLE t_decision_tables_result ADD COLUMN `colum` int DEFAULT NULL COMMENT '列数';
+
+