From d5cdfa9ba4373ccb8f71876ec74c20f3490a0c90 Mon Sep 17 00:00:00 2001 From: George Date: Wed, 25 Mar 2026 22:52:45 +0800 Subject: [PATCH] =?UTF-8?q?20260325:=E5=9C=BA=E6=99=AF=E8=81=94=E5=8A=A8?= =?UTF-8?q?=E6=94=AF=E6=8C=81=E8=B4=9F=E6=95=B0=E5=8C=B9=E9=85=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fastbee/iot/data/ruleEngine/SceneContext.java | 10 +++++----- .../fastbee/ruleEngine/core/FlowLogExecutor.java | 13 +++++++------ 2 files changed, 12 insertions(+), 11 deletions(-) diff --git a/fastbee-iot-data/src/main/java/com/fastbee/iot/data/ruleEngine/SceneContext.java b/fastbee-iot-data/src/main/java/com/fastbee/iot/data/ruleEngine/SceneContext.java index 0e39daf2..d461ad02 100644 --- a/fastbee-iot-data/src/main/java/com/fastbee/iot/data/ruleEngine/SceneContext.java +++ b/fastbee-iot-data/src/main/java/com/fastbee/iot/data/ruleEngine/SceneContext.java @@ -88,7 +88,7 @@ public class SceneContext { /** * 处理规则脚本 - * + * 静默时间:silent,在静默时间内即使满足触发条件也不执行动作 * @return */ private boolean process(String json) throws InterruptedException { @@ -678,7 +678,7 @@ public class SceneContext { } // silent:scene_场景编号 scene_logger.info("[{}]=====+>检查静默时间!", requestId); - String key = "silent:" + "scene_" + sceneId + ":" + serialNumber; + String key = "silent:" + "scene_" + sceneId + ":" + serialNumber; // silent:scene_2:D6C7C9B0593C Calendar calendar = Calendar.getInstance(); // 查询静默截止时间 Long expireTime = redisCache.getCacheObject(key); @@ -688,8 +688,8 @@ public class SceneContext { redisCache.setCacheObject(key, calendar.getTimeInMillis()); return true; } else { - long NowTimestamp = Calendar.getInstance().getTimeInMillis(); - return NowTimestamp > expireTime; + long nowTimestamp = Calendar.getInstance().getTimeInMillis(); + return nowTimestamp > expireTime; } } @@ -714,7 +714,7 @@ public class SceneContext { * 判断字符串是否为整数或小数 */ private boolean isNumeric(String str) { - Pattern pattern = compile("[0-9]*\\.?[0-9]+"); + Pattern pattern = compile("-?[0-9]*\\.?[0-9]+"); Matcher isNum = pattern.matcher(str); if (!isNum.matches()) { return false; diff --git a/fastbee-plugs/fastbee-ruleEngine/src/main/java/com/fastbee/ruleEngine/core/FlowLogExecutor.java b/fastbee-plugs/fastbee-ruleEngine/src/main/java/com/fastbee/ruleEngine/core/FlowLogExecutor.java index 636b3498..d38aead2 100644 --- a/fastbee-plugs/fastbee-ruleEngine/src/main/java/com/fastbee/ruleEngine/core/FlowLogExecutor.java +++ b/fastbee-plugs/fastbee-ruleEngine/src/main/java/com/fastbee/ruleEngine/core/FlowLogExecutor.java @@ -53,13 +53,14 @@ public class FlowLogExecutor { } public void printContextBean(Object... contextBeanArray) { - log.info("=====+>规则引擎执行前,上下文变量值"); + log.info("=====+>printContextBean规则引擎执行前,上下文变量值"); for (Object contextBean : contextBeanArray) { - log.info("上下文数值:{}", contextBean); + log.info("printContextBean上下文数值:{}", contextBean); } - log.info("=====+>规则引擎正在执行......"); + log.info("=====+>printContextBean规则引擎正在执行......"); } + // 规则执行 public void printContextBeanWithRid(String requestId, Object... contextBeanArray) { Logger ruleLogger; String[] parts = requestId.split("/"); @@ -71,11 +72,11 @@ public class FlowLogExecutor { } else { ruleLogger = log; } - ruleLogger.info("[{}]=====+>规则引擎执行前,上下文变量值", requestId); + ruleLogger.info("[{}]=====+>printContextBeanWithRid规则引擎执行前,上下文变量值", requestId); for (Object contextBean : contextBeanArray) { - ruleLogger.info("[{}]=====+>上下文数值:{}", requestId, contextBean); + ruleLogger.info("[{}]=====+>printContextBeanWithRid上下文数值:{}", requestId, contextBean); } - ruleLogger.info("[{}]=====+>规则引擎正在执行......", requestId); + ruleLogger.info("[{}]=====+>printContextBeanWithRid规则引擎正在执行......", requestId); } }