From 9ba4c9a98d92b87c3fe204256d5f08abed9f187d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=9C=E5=88=9A?= <53732908@qq.com> Date: Tue, 25 Mar 2025 14:29:14 +0800 Subject: [PATCH] =?UTF-8?q?=E5=86=B3=E7=AD=96=E5=BC=95=E6=93=8E=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=20=20=E5=86=B3=E7=AD=96=E6=B5=81=E7=9B=91=E6=8E=A7?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=86=99=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../runner/business/impl/RiskEngineBusinessImpl.java | 7 ++++++- .../monitor/controller/decisionflow/MonitorController.java | 4 +++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java b/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java index 80f0966..c2e93e5 100644 --- a/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java +++ b/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); } diff --git a/ddp/ddp-monitor/src/main/java/com/fibo/ddp/monitor/controller/decisionflow/MonitorController.java b/ddp/ddp-monitor/src/main/java/com/fibo/ddp/monitor/controller/decisionflow/MonitorController.java index 1f45c0e..a4b1b75 100644 --- a/ddp/ddp-monitor/src/main/java/com/fibo/ddp/monitor/controller/decisionflow/MonitorController.java +++ b/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 resultSets = MonitorCenterFactory.getMonitorCenterServiceImp(MonitorStorageType.HBase).getEngineResultSetBySegment(param); + // MonitorStorageType.HBase + // 20250325 MonitorStorageType.Mysql + List resultSets = MonitorCenterFactory.getMonitorCenterServiceImp(MonitorStorageType.Mysql).getEngineResultSetBySegment(param); PageInfo pageInfo = new PageInfo<>(resultSets); HashMap modelMap = new HashMap<>(); modelMap.put("pager", pageInfo);