liutongsz/fibo-rule
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

决策引擎接口 决策流监控数据写入

Browse Source
This commit is contained in:
杜刚
2025-03-25 14:29:14 +08:00
parent 90f055b7eb
commit 9ba4c9a98d
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -223,7 +223,12 @@ public class RiskEngineBusinessImpl implements RiskEngineBusiness {
resultSet.setOutput(JSONObject.toJSONString(tmpJsonObject)); resultSet.setOutput(JSONObject.toJSONString(tmpJsonObject));
resultSetMapper.insertResultSet(resultSet); resultSetMapper.insertResultSet(resultSet);
Integer resultId = resultSet.getId(); 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); decisionCallback(engine.getCallbackUrl(), paramJson, result);
} }

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

@@ -47,7 +47,9 @@ public class MonitorController {
Integer pageNo = param.get("pageNo") == null ? 1 : Integer.valueOf(param.get("pageNo").toString()); 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()); Integer pageSize = param.get("pageSize") == null ? 10 : Integer.valueOf(param.get("pageSize").toString());
PageHelper.startPage(pageNo, pageSize); 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); PageInfo<EngineResultSet> pageInfo = new PageInfo<>(resultSets);
HashMap<String, Object> modelMap = new HashMap<>(); HashMap<String, Object> modelMap = new HashMap<>();
modelMap.put("pager", pageInfo); modelMap.put("pager", pageInfo);