redis 断后重试

src/main/java/com/hxgk/lowcode/service/impl/CustomerFormServiceImpl.java

@@ -18,6 +18,10 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.http.protocol.HTTP;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.RedisConnectionFailureException;
+import org.springframework.data.redis.RedisSystemException;
+import org.springframework.retry.annotation.Backoff;
+import org.springframework.retry.annotation.Retryable;
 import org.springframework.stereotype.Service;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -62,6 +66,11 @@ public class CustomerFormServiceImpl implements CustomerFormService {
 
     //根据用户权限查询表单列表
     //@Override
+    @Retryable(
+            value = {RedisConnectionFailureException.class, RedisSystemException.class},//
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 100, multiplier = 2)
+    )
     public Tree getCustomerFormListOld(String key, String token) {
 
 
@@ -314,6 +323,11 @@ public class CustomerFormServiceImpl implements CustomerFormService {
 
     @Override
     //根据用户权限查询表单列表
+    @Retryable(
+            value = {RedisConnectionFailureException.class, RedisSystemException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 100, multiplier = 2)
+    )
     public Tree getCustomerFormList(String key, String token) {
 
         //查询出所有表单
@@ -906,6 +920,11 @@ public class CustomerFormServiceImpl implements CustomerFormService {
 
     */
     @Override
+    @Retryable(
+            value = {RedisConnectionFailureException.class, RedisSystemException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 100, multiplier = 2)
+    )
     public ArrayList<CustomerFormTableSingleFieldValue> getAsfDataTitles(String key, String token,String glbbddbd,String formId, String dataTitle,String rangeFormula, String rangeString, String hideFormula, String hideString,String masterOnField, String fillFieldsMaster, JSONArray fillFieldsChild) {
         //关联表单的id
         String AsfFormId = formId;
@@ -2279,6 +2298,11 @@ public class CustomerFormServiceImpl implements CustomerFormService {
     }
     //返回boolean      currentUser的maindeparment是否在targetOrgOrPerson及其直接父级组织列表中
     @Override
+    @Retryable(
+            value = {RedisConnectionFailureException.class, RedisSystemException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 100, multiplier = 2)
+    )
     public Boolean queryIfOrgOrPersonContainsCurrentUser(String key, String token, String targetOrgOrPerson, String condition, String right) {
         if(right.equals("当前用户")){
             //获取当前用户信息    从redis中根据userkey和usertoken拿到userdetail
@@ -2409,6 +2433,11 @@ public class CustomerFormServiceImpl implements CustomerFormService {
     }
 
     @Override
+    @Retryable(
+            value = {RedisConnectionFailureException.class, RedisSystemException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 100, multiplier = 2)
+    )
     public Boolean queryHideRoleCondition(String key, String token, String targetOrgOrPerson, String condition, String currentUser) {
         //获取用户信息    从redis中根据userkey和usertoken拿到userdetail
         Map<String,String> keytokenmap = new HashMap<>();
@@ -2439,6 +2468,11 @@ public class CustomerFormServiceImpl implements CustomerFormService {
     }
 
     @Override
+    @Retryable(
+            value = {RedisConnectionFailureException.class, RedisSystemException.class},
+            maxAttempts = 3,
+            backoff = @Backoff(delay = 100, multiplier = 2)
+    )
     public ArrayList<AsfTableFillResult> getAsfTableFill(String key, String token, String asfFormId, String glbbddbd, String currentVal,JSONArray fillFieldsChild) {
         //获取当前用户信息    从redis中根据userkey和usertoken拿到userdetail
         Map<String,String> keytokenmap = new HashMap<>();