微信运维交互机器人的示例代码

# 引用企业微信JDK
from WXcrypt.WXBizMsgCrypt import WXBizMsgCrypt

def work_weixin_api(request):
 # 获取微信Post参数
 msg_signature = request.GET.get('msg_signature', '')
 timestamp = request.GET.get('timestamp', '')
 nonce = request.GET.get('nonce', '')
 echostr = request.GET.get('echostr', '')

 # 构造微信信息解析方法
 wxcpt = WXBizMsgCrypt(WXTOKEN, WXENCODINGAESKEY, WXCROPID)
 if request.method == 'POST':
  eagle_branch = request.POST.get('eagle_branch', 'master')

  if eagle_branch == "master":
   request_data = request.body
   # 解析接收到的文本
   ret, msg = wxcpt.DecryptMsg(request_data, msg_signature, timestamp,
          nonce)
   request_xml = ET.fromstring(msg)

   # 获取信息内容
   content = request_xml.find("Content").text

   # 获取信息类型
   msg_type = request_xml.find("MsgType").text

   # 获取发送人
   from_user = request_xml.find("FromUserName").text
  else:
   content = request.POST.get('content', '')
   from_user = request.POST.get('from_user', '')

# 加密
def enc_dict(d):

 # 加密
 s = URLSafeSerializer('1234')
 st = s.dumps(d)

 # 加密后再生成基于时间戳的令牌
 t = TimestampSigner('4567')
 ts = t.sign(st)
 return ts

# 菜单功能的基类
class Function:
 def __init__(self, data):
  self._data = data
  self._functions = []

 # 传入的方法的描述
 def __str__(self):
  return str(self._data())

 # 返回当前对象类型
 def f_type(self):
  return self._data.f_type

 # 返回当前对象
 def getData(self):
  return self._data

 # 返回所有子菜单
 def getFunctions(self):
  return self._functions

 # 新增子菜单
 def add(self, function):
  self._functions.append(function)

 # 递归搜索
 def go(self, num):
  for _, i in enumerate(self._functions):
   if int(num) == _ :
    return i
  return None

 # 新增一个类型属性
 def f_type(self):
  return self._data.f_type

 # 递归搜索
 def go(self, num):
  for _, i in enumerate(self._functions):
   f_type = i._data().f_type
   # 如果类型是默认且存在列表中，或动态生成类型的，直接返回
   if f_type == "default" and int(num) == _ or f_type == "dynamic":
    return i
  return None

class Menu:
 def __init__(self):
  self._head = Function(FunctionNodeBase())
  self.input_text = None

 # 链接
 def linkToHead(self, function):
  self._head.add(function)

 # 搜索
 def search(self, text):
  cur = self._head
  for i in text.split('-'):
   if cur.go(i) == None:
    return None
   else:
    self.input_text = i
    cur = cur.go(i)
  return cur

# 空的功能Node
class FunctionNodeBase:
 __metaclass__ = ABCMeta

 def __init__(self,
     user=None,
     f_type="default",
     input_text=None,
     sub_text=None):
  self.user = user
  self.sub_text = sub_text
  self.input_text = input_text
  self.f_type = f_type
  self.f_mark = []

 # 菜单通过run方法执行与生成文本
 @abstractmethod
 def run(self):
  return self.__str__()

 # 描述
 @abstractmethod
 def __str__(self):
  return "菜单树顶层"

# 动态生成
class SelectDeploymentTop(FunctionNodeBase):
 # 动态生成的菜单需要声明f_type
 def __init__(self):
  super().__init__()
  self.f_type = "dynamic"

 def run(self):

  text       = "请选择事业部\n\n"
  deployment_list = [i for i in FunctionList.keys()]

  for _, i in enumerate(deployment_list):
   self.f_mark.append(_)
   text += "%s %s\n" % (_, i)

  return text

 # 微信显示的文本信息
 def __str__(self):
  return "选择事业部"

# 静态
class MySQLFunctionTop(FunctionNodeBase):
 def __init__(self):
  super().__init__()

 def run(self):
  text = "您选择的是%s,请选择您想要操作:\n" % str(self.__str__())
  text += "%s\n" % self.sub_text
  return text

 def __str__(self):
  return "MySQL操作"

def api(tid,user):

 # 实例化
 menu    = Menu()
 top     = Function(SelectDeploymentTop)
 function_top = Function(FunctionTop)
 mysql_top  = Function(MySQLFunctionTop)

 # 链接
 top.add(function_top
 function_top.add(mysql_top)

 # 关联菜单树
 menu.linkToHead(top)

 # 递归搜索
 function = menu.search(tid)

class redis_db:
 def __init__(self):
  # 按符号隔开
  self.mark = '-'
  self.redis_db = redis.StrictRedis(
   host = host, port=6379, db=1, decode_responses=True)

 # 默认回话过期600秒,每次存储 '-'隔开
 def add(self,key,text,Timeout=600):
  if key not in self.keys():
   self.redis_db.set(key,'',ex=Timeout)
  if self.get(key):
   self.redis_db.append(key,self.mark)
  self.redis_db.append(key,text)