baseCore增加redis重连

base/BaseCore.py

@@ -473,6 +473,10 @@ class BaseCore:
 
     # 从Redis的List中获取并移除一个元素
     def redicPullData(self, key):
+        try:
+            self.r.ping()
+        except:
+            self.r = redis.Redis(host="114.115.236.206", port=6379, password='clbzzsn', db=6)
         item = self.r.lpop(key)
         return item.decode() if item else None
 
@@ -686,6 +690,10 @@ class BaseCore:
 
     # 对失败或者断掉的企业 重新放入redis
     def rePutIntoR(self, key, item):
+        try:
+            self.r.ping()
+        except:
+            self.r = redis.Redis(host="114.115.236.206", port=6379, password='clbzzsn', db=6)
         self.r.rpush(key, item)
 
     # 增加计数器的值并返回增加后的值