windstormeye/watchDog

import itchatmp

itchatmp.update_config(itchatmp.WechatConfig(
  # 填写上一步在微信公众号的配置内容
   token='yourToken',
   appId = 'yourAppId',
   appSecret = 'yourAppSecret'))
   
@itchatmp.msg_register(itchatmp.content.TEXT)
   def text_reply(msg):
     return msg['Content']

itchatmp.run()

# 硬件表
class Hardware(Base):
   __tablename__ = 'hardware'

   id = Column(Integer, primary_key=True)
   name = Column(String(64), nullable=False)
   status = Column(Integer, nullable=False)
   num = Column(Integer, nullable=False)

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, String, Integer
from sqlalchemy.orm import sessionmaker

# '数据库类型+数据库驱动名称://用户名:口令@机器地址:端口号/数据库名'
engine = create_engine('mysql+mysqldb://root:mimamima@localhost:3306/restful?charset=utf8')
Base = declarative_base()
Base.metadata.create_all(engine)
Session = sessionmaker(bind = engine)
session = Session()

# 添加电子原件方法
# 原件name及针脚num需要配置
# 原件状态默认关闭
def addNewUnit(hardwareName, status, num):
     Base.metadata.create_all(engine)
     Session = sessionmaker(bind=engine)
     session = Session()
     unit = Hardware(
         name = hardwareName, 
         status = status,
         num = num)
     session.add(unit)
     session.commit()

# 执行write操作
def writeHardware(hardwarename, status, num):
     unit = readHardware(hardwarename)
     unit = session.query(Hardware).get(unit.id)
     if unit:
         unit.status = status
         if 'Unit' in hardwarename:
             unit.num = num;
         session.add(unit)
         session.commit()
         return '操作成功'
     return '操作失败，请联系管理员'

# 执行read操作
def readHardware(hardwarename):
     Base.metadata.create_all(engine)
     Session = sessionmaker(bind = engine)
     session = Session()
     unit = session.query(Hardware).filter_by(name=hardwarename).first()
     return unit

#  电子原件执行read或write筛选方法
def updateStatusWithHardware(tableName, operatorStatus, hardwarename, status):
     if tableName == 'hardware':
         if operatorStatus == 1:
             return writeHardware(hardwarename, status, 0)
         else:
             return readHardware(hardwarename)

import itchatmp
import test

# 配置微信公众号信息
itchatmp.update_config(itchatmp.WechatConfig(
    token='你的token',
    appId = '你的appId',
    appSecret = '你的appSecret'))

# 接收用户消息
@itchatmp.msg_register(itchatmp.content.TEXT)
def text_reply(msg):
    toUserName = msg['FromUserName']
    content = msg['Content']
    isContain = 0
    # pjhubs.txt为有权限的用户列表
    f = open("pjhubs.txt","r")
    lines = f.readlines()
    for line in lines:
        if line[:-1] == toUserName:
            isContain = 1;   
    if isContain == 0:
        return '该系统并未对您开放，请联系PJ进行配置'
    else:
        if content == '添加':
            # test.addNewUnit('tempUnit', 1, 2)
            return '操作成功!'
        elif content == '开灯':
            return test.updateStatusWithHardware('hardware', 1, 'redLED', 1)
        elif content == '关灯':
            return test.updateStatusWithHardware('hardware', 1, 'redLED', 0)
        elif content == '温度':
            unit = test.updateStatusWithHardware('hardware', 0, 'tempUnit', 1)
            returnString = '当前温度为：' + str(unit.num) + '°'
            return returnString
        elif content == '开风扇':
            return test.updateStatusWithHardware('hardware', 1, 'tempUnit', 1)
        elif content == '关风扇':
            return test.updateStatusWithHardware('hardware', 1, 'tempUnit', 0)
        
# 新用户关注公众号时
@itchatmp.msg_register(itchatmp.content.EVENT)
def user_management(event):
    if(event['Event']=='subscribe'):
        return u'欢迎来到PJHubs，如果你想试用室内环境智能监测系统，请联系PJ'
itchatmp.run()

from flask import Flask
from flask_restful import Resource, Api
from flask import jsonify, request
from flask import abort
from flask import make_response
import test

app = Flask(__name__)
api = Api(app)

@app.route('/')
def index():
    return 'Get out!🙂'

if __name__ == '__main__':
    app.run(host='0.0.0.0',debug=True)

# 获取所有硬件信息（求快可以这么写）
@app.route('/dachuang/api/v1/allHardware')
def get_allHardware():
    LED = test.readHardware('redLED')
    UNIT= test.readHardware('tempUnit')
    LEDres = { 'id' : LED.id,
            'name' : LED.name,
            'status' : LED.status,
            'num' : LED.num }
    UNITres = { 'id' : UNIT.id,
                'name' : UNIT.name,
                'status' : UNIT.status,
                'num' : UNIT.num }
    return jsonify([LEDres, UNITres])

# 更新固定元器件（求快用了GET，最好是POST）
@app.route('/dachuang/api/v1/updateHardware', methods=['GET'])
def get_updateHardware():
    hardwarename = request.args.get('hardwarename')
    status = request.args.get('status')
    num = request.args.get('num')
    if status == '3':
        unit = test.readHardware(hardwarename)
        test.writeHardware(hardwarename, unit.status, num)
    else:
        test.writeHardware(hardwarename, unit.status, num)
    return jsonify({'code' : '1'})

import serial
import urllib2
import json

hostname = 'http://你的地址/dachuang/api/v1/allHardware'
# /dev/ttyACM0 是树莓派上编号为0的USB口（可以在/dev目录下通过观察拔插对应的USB口找到对应的编号）
ser = serial.Serial('/dev/ttyACM0', 9600, timeout = 4)

while 1:
    r = urllib2.Request(hostname)
    r = urllib2.urlopen(r)
    res = r.read()
    result = json.loads(res)
    print result
    send = ''
    # 通过json库解析完后的数据就是字典
    if result[0]['status'] == 1:
        send += 'a'
    else:
        send += 'A'
    if result[1]['status'] == 1:
    send += 'b'
    else:
    send += 'B'
    # 从下位机Arduino上读取到的数据拼接URL发送回服务器，更新数据库
    ser.write(send)
    response = ser.readall()
    if '' != response:
        response = response[0:2]
        ret = urllib2.Request("http://你的地址/dachuang/api/v1/updateHardware?hardwarename=tempUnit&status=3" + '&num=' + response)
        ret = urllib2.urlopen(ret)