[R.M.C] 用python实现微信控制电脑端虾米音乐(3)

接上篇 用python实现微信控制电脑端虾米音乐(2)

上篇里介绍了如何接受用户发送到微信的消息,做了个简单的echo程序,这次我们来讲SAE中完整的代码写完。

一、指令的处理以及储存

也就是图上画红圈的部分:

我们给weixinInterface.py里的POST方法中加上处理指令的代码(weixinInterface.py改后完整的代码见文章末尾):

# 检测是否为命令(是否为"cmd "开头)
if content.startswith("cmd "):
    command = content[4:] # 截取指令的内容
    mc = pylibmc.Client() # 获取Memcache实例
    old = mc.get(fromUser + "_cmd") # 获取该用户缓存的指令
    if not old: # 如果没有缓存的指令,设置成空列表
        old = []
    
    # 将之前缓存的指令与新的指令形成的列表
    # 存放在"用户名_cmd"的键下
    mc.set(fromUser + "_cmd", old + [command])
    content = "命令[{}]已接收".format(command) # 修改回复的内容
Memcache在这里的作用:

先说明一下Memcache在这里的作用,SAE是我们的我们的网络应用,每次我们访问一次我们网络应用的URL就会运行一遍我们的代码,所以如果我们只是单纯的创建一个变量将我们的数据储存在内存中,下一次访问的时候,这些数据都会重置,不能储存下来,所以我们需要Memcache这个缓存服务来讲我们需要储存的数据储存下来,以便之后使用。还有我们创建的这个网络应用时选的是共享环境,所以每次运行我们代码的服务器可能都不一样,所以需要Memcache来缓存我们的数据。Memcache是以键值对的形式来管理数据的,就像Python中的字典一样。

在Memcache中储存命令的形式:

将用户的所有命令已字符串的形式存在列表中,并将该列表储存在Memcache中以”用户名_cmd”的键下

处理命令的具体步骤如下:
  1. 判断用户发送的消息是否为”cmd空格”开头
  2. 截取指令部分即cmd空格之后的内容
  3. 获取pylibmc实例(pylibmc库是一个让Python管理Memcache的库)
  4. 从Memcache中获取用户的旧指令
  5. 将新指令连接到旧指令列表中,储存进Memcache

二、客户端指令的接收

思路

这里让客户端使用GET方法来获取用户储存在SAE的指令。指令以json的形式传递,接收到的将是json形式的列表,列表内以字符串的形式存放着所有未获得的指令。这里为了简单起见,定义:如果使用GET方法访问我们SAE的URL时,有usercmd这个参数表明要获取以这个参数为名称的用户所存放的所有指令。当然这里存在一点安全隐患,因为任何人都可以随意的访问我们这个URL来读取用户的指令列表,可以采取一些简单的加密来提高安全性,这里简单起见就不做这些处理了。

SAE端的设置

首先在weixinInterface.py的GET方法中添加(weixinInterface.py改后完整的代码见文章末尾):

try: # 来自电脑客户端的请求
    user = params.usercmd # 获取usercmd参数
    mc = pylibmc.Client() # 获取Memcache实例
    cmdlist = mc.get(user + "_cmd") # 获取用户对应的所有指令
    if not cmdlist:
        cmdlist = []
    mc.set(user + "_cmd", []) # 将用户对应的指令列表清空
    return json.dumps(cmdlist) # 将指令列表以json的格式作为响应返回

except: # 错误请求
    pass

 

客户端的设置

再在电脑本地创建一个client.py文件,作为我们的客户端程序,之后将使用它来访问我们的SAE来获取指令,我们先写个简单的测试程序:

import requests
import json
import time


if __name__ == "__main__":
    while True:
        user = "LeiZiTing" # 这里填入你企业微信中用户的名称,可以在企业微信的成员管理中找到
        # 访问SAE,并添加参数usercmd
        r = requests.get("http://timpcfanwx01.applinzi.com/weixin?usercmd=" + user)
        cmdlist = json.loads(r.text) # 读取获得的json数据,得到指令列表
        for command in cmdlist: # 处理指令列表中每一条指令
            print(time.strftime("%D %H:%M:%S ") + command)
        time.sleep(1) # 休息一秒钟~

运行我们的测试程序,然后在微信上发以”cmd空格”开头的指令试试看~

效果图:

我们成功将微信上发的内容传递到电脑上了,接下来我们就可以做任何我们想做的事了。

随时随地使用微信给自己的电脑发送指令,通过python完成一些简单的任务,是不是很棒棒xD

以下附上修改后完整的weixinInterface.py:(修改的部分使用注释标明)

# -*- coding: utf-8 -*-
import hashlib
import web
import lxml
import time
import os
import urllib2, json, urllib
from lxml import etree
from WXBizMsgCrypt import WXBizMsgCrypt
import pylibmc # 需要在SAE中申请创建Memcached
import json # 处理json

sCorpID = 'YOUR_CORPID' # 企业微信的CorpID
AGENTID_RMC = 'YOUR_AGENTID' # 应用的AgentId
SECRET_RMC = 'YOUR_SECRET' # 应用的Secret
sToken = 'Token00000'
sEncodingAESKey = 'EncodingAESKey00000000000000000000000000000'


class WeixinInterface:
    def __init__(self):
        self.app_root = os.path.dirname(__file__)
        self.templates_root = os.path.join(self.app_root, 'templates')
        self.render = web.template.render(self.templates_root)
        self.wxcpt = WXBizMsgCrypt(sToken, sEncodingAESKey, sCorpID)

    def GET(self):
        # 获取URL参数
        params = web.input()

        try: # 来自微信的请求
            signature = params.msg_signature
            timestamp = params.timestamp
            nonce = params.nonce
            echostr = params.echostr
            ret, echostr = self.wxcpt.VerifyURL(signature, timestamp, nonce, echostr)
            if ret == 0:
                return echostr
           	
        except:
            try: # 来自电脑客户端的请求
                user = str(params.usercmd) # 获取usercmd参数,并转化为str类型(原本是unicode类型)
                mc = pylibmc.Client() # 获取Memcache实例
                cmdlist = mc.get(user + "_cmd") # 获取用户对应的所有指令
                if not cmdlist:
                    cmdlist = []
                mc.set(user + "_cmd", []) # 将用户对应的指令列表清空
                print cmdlist
                return json.dumps(cmdlist) # 将指令列表以json的格式作为响应返回
            
            except: # 错误请求
                pass
                
        
    def POST(self):
        # 获取URL参数
        params = web.input()

        # 获取POST的数据
        data = web.data()

        signature = params.msg_signature
        timestamp = params.timestamp
        nonce = params.nonce

        # 解密消息
        ret, msg = self.wxcpt.DecryptMsg(data, signature, timestamp, nonce)
        if ret != 0:
            print "ERR: DecryptMsg ret: " + str(ret)
            return ''

        xml = etree.fromstring(msg)
        content = xml.find("Content").text
        msgType = xml.find("MsgType").text
        fromUser = xml.find("FromUserName").text
        toUser = xml.find("ToUserName").text
        msgid = xml.find("MsgId").text
        
        # 检测是否为命令(是否为"cmd "开头)
        if content.startswith("cmd "):
            command = content[4:] # 截取指令的内容
            mc = pylibmc.Client() # 获取Memcache实例
            old = mc.get(fromUser + "_cmd") # 获取该用户缓存的指令
            if not old: # 如果没有缓存的指令,设置成空列表
                old = []
            # 将之前缓存的指令与新的指令形成的列表
            # 存放在"用户名_cmd"的键下
            mc.set(fromUser + "_cmd", old + [command])
            content = "命令[{}]已接收".format(command) # 修改回复的内容

        msg_xml = self.render.reply_text(fromUser, toUser, timestamp, content, msgid, AGENTID_RMC)
        # 将产生的数据加密
        ret, encryptmsg = self.wxcpt.EncryptMsg(str(msg_xml), nonce, timestamp)
        if ret != 0:
            print "ERR: EncryptMsg ret: " + str(ret)
            return ''
        # 将加密的数据返回给用户
        return encryptmsg

 

待续未完~

 

[R.M.C] 用python实现微信控制电脑端虾米音乐(1)

前言

这个计划的代号叫RMC,至于什么意思呢,你猜嘿嘿。。

嘛,用微信控制虾米这个想法的起源是:有一天,我躺在宿舍的床上,我们宿舍是标准的上床下桌,我的电脑在下面,插着扬声器在外放音乐,当时随机到一首特别嘈杂的歌,听得很难受,我想切歌,又不想下床orz,实在没办法只好自己下床换了一首歌。。

嗯。。于是呢,我就想,有没有什么方法可以用手机控制我电脑换歌的。当然可以用各种vnc远程控制桌面,但感觉太小题大做了,而且要专门控制鼠标去点击播放键实在有点麻烦,一点都不优雅。我就想如果手机端的虾米能控制电脑端的虾米就好了。。当然,用过电脑版虾米的人都知道,电脑版虾米就是个x(笑。这种功能靠虾米官方肯定是不存在的。。

就在这时,我看到了一篇文章,是使用python+微信来实现运维报警的。他是用微信企业号,使用python向企业号api发送消息,来实现运维报警的。我于是想到,我能不能也弄个微信企业号或公众号什么的,通过给它发消息,来控制我的电脑。

想了想感觉还是可以实现的,于是去学习了一下微信公众号的开发,通过这篇文章,简单了解了微信公众号的开发方法。

先来看看整体的思路:

使用微信发送消息至企业号,企业号转发给我的服务器(这里用新浪SAE),服务器管理着用户发的指令,电脑端程序访问新浪SAE来请求新的指令,然后执行相应操作来控制虾米音乐。

下面是详细的流程图

接下来,我来说下实现微信控制电脑端虾米的具体步骤了。

准备

  1.  申请一个微信企业号(订阅号和服务号理论上都可以,企业号的话比较安全,个人申请的话选组织-》没有组织机构代码证,继续注册
  2.  申请一个新浪SAE云应用
  3.  电脑端需要安装python(我这里使用的是python3.6但SAE上使用的是python2.7
  4.  电脑端需要安装python模块pyautogui用来控制虾米(可以直接在命令行中使用pip install pyautogui命令来安装)

具体步骤

第一步、SAE的基本配置

1、在SAE上创建一个python云应用,这里我给它起名叫wx01

(因为我已经创建过了,所以提示名称已占用)

2、打开应用的管理界面,点数据库与缓存服务-》Memcached-》创建memcached,申请一个最小的空间即可,这个是为接下来做准备,在这一节中暂时不会用到。

3、打开应用的管理界面,点应用-》代码管理-》创建版本

SAE是个好东西,相当于小型的web服务器,我们可以通过网页版的代码编辑器来编辑SAE的代码,也可以使用git或svn来进行代码管理。这里我们为了方便直接使用网页版编辑器。

首先编写config.yaml配置文件,打开网页版编辑器,新建一个文件config.yaml,并将下面的代码复制进去,保存。该配置文件指定了SAE上python使用的模块的版本,如果提示python找不到某某模块一般是这个配置文件设置错了。

name: trystanlei
version: 1

libraries:
- name: webpy 
  version: "0.36"

- name: lxml
  version: "2.3.4"

- name: PyCrypto
  version: "2.6"

...

第二步、微信的对接

登录企业微信后台,企业应用-》自建应用-》创建应用,填写好应用名称,在可见范围中选好自己

创建完后,就可以在应用管理这个界面中看到应用的AgentIdSecret,这两个就是这个应用的标识了。

然后我们点 接收消息设置API接收 

按照根据自己情况设置:

这时候点保存会报错:回调URL测试失败。 别紧张,是因为我们SAE上面还没设置完呢~

我们再打开SAE的在线代码编辑器,我们来写ndex.wsgi这个文件:

# encoding: UTF-8

import sae
import web
import os

from weixinInterface import WeixinInterface # 我们即将创建,不要担心

urls = (
'/weixin','WeixinInterface'
) # 将 "你的域名/weixin" 这个地址指向WeixinInterface这个应用


app_root = os.path.dirname(__file__)
templates_root = os.path.join(app_root, 'templates')
render = web.template.render(templates_root)

app = web.application(urls, globals()).wsgifunc()
application = sae.create_wsgi_app(app)

这里使用的是webpy框架,想了解的话就百度一下吧,这里我们不需要详细的理解它就能实现我们的应用。

现在我们下载企业微信的python加密库,可以在这个连接中找到。将下载的python.zip直接上传到SAE代码库。可以直接在SAE应用的代码管理界面上传。

上传完以后是这样的:

其中WXBizMsgCrypt.py就是企业微信的加密库 Readme.txt和Sample.py是介绍和演示可以右键删除掉。

我们再来创建一个weixinInterface.py文件,在里面写上

# -*- coding: utf-8 -*-
import hashlib
import web
import lxml
import time
import os
import urllib2, json, urllib
from lxml import etree
from WXBizMsgCrypt import WXBizMsgCrypt

sCorpID = 'YOUR_CORPID' # 企业微信的CorpID在 我的企业-》企业信息 中可以找到
AGENTID_RMC = 'YOUR_AGENTID' # 应用的AgentId
SECRET_RMC = 'YOUR_SECRET' # 应用的Secret
sToken = 'Token00000' # 设置接收消息时的Token
sEncodingAESKey = 'EncodingAESKey00000000000000000000000000000' # 设置接收消息时的EncodingASEKey


class WeixinInterface:
    def __init__(self):
        self.app_root = os.path.dirname(__file__)
        self.templates_root = os.path.join(self.app_root, 'templates')
        self.render = web.template.render(self.templates_root)
        self.wxcpt = WXBizMsgCrypt(sToken, sEncodingAESKey, sCorpID)

    def GET(self):
        # 获取URL参数
        params = web.input()

        try: # 来自微信的请求
            signature = params.msg_signature
            timestamp = params.timestamp
            nonce = params.nonce
            echostr = params.echostr
            ret, echostr = self.wxcpt.VerifyURL(signature, timestamp, nonce, echostr)

            # 如果是来自微信的请求,则回复echostr
            if ret == 0:
                return echostr
            
        except:
            pass

之后点击全部保存

我们再切换到微信设置接收消息的页面,点击保存试试能不能保存成功吧~

如果保存成功,说明前面的设置都没问题啦 🙂

最后可以看到,接收消息这里显示已启用API接收

好了,现在我们准备工作就做完了。我们下一篇见~

用python实现微信控制电脑端虾米音乐(2)