From 1c32e2b5c57fb58b2396929727647485f4e97046 Mon Sep 17 00:00:00 2001
From: houxinyu <hxinyu2000@163.com>
Date: Sun, 2 Jul 2023 00:46:37 +0800
Subject: [PATCH] add redisson

---
 .../liteflow-rule-redis/pom.xml               |  6 +++
 .../parser/redis/util/RedisParserHelper.java  | 38 +++++++++++++++++++
 pom.xml                                       |  1 +
 3 files changed, 45 insertions(+)

diff --git a/liteflow-rule-plugin/liteflow-rule-redis/pom.xml b/liteflow-rule-plugin/liteflow-rule-redis/pom.xml
index 9233cdbce..183bacb09 100644
--- a/liteflow-rule-plugin/liteflow-rule-redis/pom.xml
+++ b/liteflow-rule-plugin/liteflow-rule-redis/pom.xml
@@ -20,6 +20,12 @@
             <optional>true</optional>
             <scope>provided</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.redisson</groupId>
+            <artifactId>redisson</artifactId>
+            <version>${redisson.version}</version>
+        </dependency>
     </dependencies>
 
 </project>
\ No newline at end of file
diff --git a/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserHelper.java b/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserHelper.java
index d361cb742..964c4de2e 100644
--- a/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserHelper.java
+++ b/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserHelper.java
@@ -1,9 +1,47 @@
 package com.yomahub.liteflow.parser.redis.util;
 
+import cn.hutool.core.util.ObjectUtil;
+import com.yomahub.liteflow.parser.redis.exception.RedisException;
 import com.yomahub.liteflow.parser.redis.vo.RedisParserVO;
+import com.yomahub.liteflow.spi.holder.ContextAwareHolder;
+import org.redisson.api.RedissonClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class RedisParserHelper {
 
+    private static final Logger LOG = LoggerFactory.getLogger(RedisParserHelper.class);
+
     private RedisParserVO redisParserVO;
 
+    private final String CHAIN_XML_PATTERN = "<chain name=\"{}\">{}</chain>";
+
+    private final String NODE_XML_PATTERN = "<nodes>{}</nodes>";
+
+    private static final String NODE_ITEM_XML_PATTERN = "<node id=\"{}\" name=\"{}\" type=\"{}\"><![CDATA[{}]]></node>";
+
+    private static final String NODE_ITEM_WITH_LANGUAGE_XML_PATTERN = "<node id=\"{}\" name=\"{}\" type=\"{}\" language=\"{}\"><![CDATA[{}]]></node>";
+
+    private static final String XML_PATTERN = "<?xml version=\"1.0\" encoding=\"UTF-8\"?><flow>{}{}</flow>";
+
+    private RedissonClient redissonClient;
+
+    public RedisParserHelper(RedisParserVO redisParserVO) {
+        this.redisParserVO = redisParserVO;
+
+        try{
+            try{
+                this.redissonClient = ContextAwareHolder.loadContextAware().getBean(RedissonClient.class);
+            }
+            catch (Exception ignored){
+            }
+            if(ObjectUtil.isNull(redissonClient)){
+                //todo get client
+            }
+        }
+        catch (Exception e){
+            throw new RedisException(e.getMessage());
+        }
+
+    }
 }
diff --git a/pom.xml b/pom.xml
index 0cfbdd3ff..c61e7dfe8 100644
--- a/pom.xml
+++ b/pom.xml
@@ -74,6 +74,7 @@
 		<luaj.version>3.0.1</luaj.version>
 		<aviator.version>5.3.3</aviator.version>
 		<common-io.version>2.11.0</common-io.version>
+		<redisson.version>3.20.0</redisson.version>
 	</properties>
 
 	<dependencyManagement>