suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: 优化规则日志记录逻辑

This commit is contained in:
zhouhao 2023-11-28 17:02:34 +08:00
parent 4f1c89ccc2
commit acf38bc7e1
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/event/handler/RuleLogHandler.java
View File

@ -1,6 +1,8 @@
package org.jetlinks.community.rule.engine.event.handler;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.hswebframework.web.bean.FastBeanCopier;
import org.jetlinks.community.elastic.search.service.ElasticSearchService;
import org.jetlinks.community.gateway.annotation.Subscribe;
import org.jetlinks.community.rule.engine.entity.RuleEngineExecuteEventInfo;
@ -19,14 +21,15 @@ public class RuleLogHandler {
@Autowired
private ElasticSearchService elasticSearchService;
@Subscribe("/rule-engine/*/*/event/*")
@Subscribe("/rule-engine/*/*/event/${rule.engine.event.level:error}")
public Mono<Void> handleEvent(TopicPayload event) {
return elasticSearchService.commit(RuleEngineLoggerIndexProvider.RULE_EVENT_LOG, RuleEngineExecuteEventInfo.of(event));
}
@Subscribe("/rule-engine/*/*/logger/*")
@Subscribe("/rule-engine/*/*/logger/${rule.engine.logging.level:info,warn,error}")
public Mono<Void> handleLog(LogEvent event) {
return elasticSearchService.commit(RuleEngineLoggerIndexProvider.RULE_LOG, event);
JSONObject jsonObject = FastBeanCopier.copy(event, new JSONObject());
jsonObject.put("createTime", System.currentTimeMillis());
return elasticSearchService.commit(RuleEngineLoggerIndexProvider.RULE_LOG, jsonObject);
}
}