xmengnet/XZZ
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

add redis db

Browse source
This commit is contained in:
SiHuan 2020-03-20 22:46:11 +08:00
parent 9c3abb4c7e
commit cff7dac933
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
zzcore.py
View file

@ -1,7 +1,8 @@
import requests import requests, json, redis
import json
from config import APIURL, ALLWORKERS, AUTHORIZATION from config import APIURL, ALLWORKERS, AUTHORIZATION
from worker import emmm from worker import emmm
pool = redis.ConnectionPool(host='127.0.0.1', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)
class StdAns(): class StdAns():
AllowGroup = [] AllowGroup = []
@ -18,6 +19,11 @@ class StdAns():
self.role = role self.role = role
self.raw_msg = raw_msg self.raw_msg = raw_msg
def DATAGET(self):
return r.hgetall(self.parms[0])
def DATASET(self,data):
r.hmset(self.parms[0],data)
def CheckPermission(self): def CheckPermission(self):
if self.AllowGroup and self.gid not in self.AllowGroup: if self.AllowGroup and self.gid not in self.AllowGroup:
@ -43,4 +49,4 @@ class StdAns():
'group_id' : self.gid, 'group_id' : self.gid,
'message': msg 'message': msg
} }
requests.post(url = url, data = json.dumps(data),headers = Headers) return requests.post(url = url, data = json.dumps(data),headers = Headers).json()['data']['message_id']