From 091782d000fb0fe7232497981c0a1df8d7c14b6e Mon Sep 17 00:00:00 2001
From: YBZX <qimint@outlook.com>
Date: Thu, 12 May 2022 23:46:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=A0=91=E8=8E=93=E6=B4=BEsd?=
 =?UTF-8?q?k?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../__pycache__/aes.cpython-37.pyc            | Bin 0 -> 7251 bytes
 sdk/RaspberryPi/aes.py                        | 210 +++++++++++
 sdk/RaspberryPi/main_sdk.py                   | 335 ++++++++++++++++++
 3 files changed, 545 insertions(+)
 create mode 100644 sdk/RaspberryPi/__pycache__/aes.cpython-37.pyc
 create mode 100644 sdk/RaspberryPi/aes.py
 create mode 100644 sdk/RaspberryPi/main_sdk.py

diff --git a/sdk/RaspberryPi/__pycache__/aes.cpython-37.pyc b/sdk/RaspberryPi/__pycache__/aes.cpython-37.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..65d7f5de60afee42eb1c1c9e88b5fde93bb1459a
GIT binary patch
literal 7251
zcmcIpTXP)66`r2U?(AxJEy=R5!G;9`VIAXuF}5QJF%mW;l!aqe1!_yl)M|T-SC&?y
zXJkt%xdO2r0>PM~2qAG5wOd?FAlM-fDS-|Aj8x5Qw7NX;z#A{gce-b1FOpm)<&3<i
zr>A?S&-wbC(_gpy)9Iv!Yy0Wxk$-K`w0~2je#LQf06*_72(EE9rj4^aV|1^N>3Ln2
zM&5W*;|4d+YTP`d=S|cs9z!jLn&rlL{Ddyv;C4RF6M5UU+_=j|6RypZyo0CCTlpkU
z=R4eFCFOQhSw8J%c*advHdM7UI@9pHQ`N$@4Q`sAbA3q5b*?}&Eyn`m@q<HyMXJ;<
z12+fo^L`ECYI(*rD7;xJ%JPO%F>mrXx6f*Mizj#zWsFop8Ru!9L22_1yc1=DckynN
zNxqTypzPqAcrVHnzXfV+39Q3U6#T-s7)txjn(~j`zrRQd&_$(=-vEAIC&V0^(;RJ1
zhlEmioek#nz~uNqkSZQ8h(ghK#gOagjKK8Vv11~Jw*<|`Up0|H@!cc5Z@B-t{BUuC
zm&(r%KVR}E#l)yv^oLJPjk~4$z43zZhdq8`_-MhK9C3x1IZ_%fxZbYGnZS0OQn}<i
zj*U-wCWNNP*lb3cu&dr!B%SFZ{b^9C|Gl{JVF71n^b6gm^*Ox)Yew}dyy98-#V@p@
z+H)vjl|C5gr$)$ziAlE{Sf@k@W|1j5L(tH9`%r1j9W0Ey0Xrt`Qi2>Zu)V@bmoQDE
zrj%r<NXdF*q$DXzib^GWa5Kj$8Wdwy0vk||lDhzCBZ#?Wz~)Lkl{&gqN1;rXHmQ+3
zCML#*d;yfZ&=M+=VY8hItwwW;Dpp;UTXExSz=%~y38ShMGI4Jzg{&YpQt;fpdxFHs
z-aXuvy3ttQL&1LeflUnsds-A!%`FN>SanAVu13lpDU}Oeu~Z7;h2100ad-O0@OsLf
z24u)4b-XZfO?av1B11b}R7UD#PysfCnDnY}(&V^7EJTMQA;;9Dwau69PpH}2hCZHj
z;mB#~O>2)#ktt_Nj$1LRVPu+OBU<F-gpMPlk*r%^2ZeYReOBoZPR5$nudhQd=@1{;
zU5I8u;=8^E3gqo;X|M+Vq>T(6vW@UpxHC21YeOCPC;Df6*Q1nBw=%7wB5Y{^nj&5f
zLH%d!Ijy1*#HQx66G@R}@B@aSD>^+5QwYVYpb!cY2d9hfq+gmSi>;`yV|UzfJYP6Y
z4qZGNP-8l?8NxMGENn-<6_ob`#c3{08L^Bs<TydnamFY3)EM2T9Os3p!kB6i9n_yD
zNKnWK3O2Es1nDQ061UUc9VG4~(Qr+9M`=xvqm%o3l%s5xv}`l{Gi>=Mdlb<aUG&NU
z{Jhs8qJ``pZgT4^Eo4|<u@ITu<_VM*t*R(vJjK%}<2=JRptN}>??Rd2-Fzd;B=6yy
zP<HTMehbPJmc}h8)BIL`8_Epd%D181z;EYwpzP#XekaN<eiz@4vYX!xAGtS3V&N@{
znMr>_1em75i6aG0Yf^m`B!{AlN(x8m0{7vjc@>;9WRkWZjXC5-$K;f@ExE=UQ@?_H
zCbQwS`0m--)h`z2UtE~~7-QG2e7^iyHEKQK&h%xMF1@qz<_F(gd#(2ApO#<!ZSCDZ
zEdKHDi{~##y)eaYUv}Zkub1BXXz`<J?b-$EeBtB83vVoZb#Y<-{iRFi@dTgWb@-Vl
z4mtz<13R-(?chLv^rh0tZ?63%TRK^L>B7>bt1B<d53Mumq(bJf9K2Tjq;~FHH2BKZ
zca|@|zcBwr1mMnW?ZTCn7hj1UK%u-V>iD8|<mrK-heNo->b|fV>DNpr`m(@d>2Dvd
zT>RbAwYQflFGals#pGZv78t-UFbSSOFP)StP|(q&x5@`Gm3k@4#10ZaB(akO`F4}z
zOP{C6*^Qr<g3uB%R{xvb*l?cJyo0<Y@)#P1SjRr?G@IT^4CD;sdM|kA2}9gnZ+Rj4
zELz}~=HRz7!LG=FrCZ{NV{RFNPkBMw(WYlU?Kn*U_oG{wLu}Sf++%Z#woP5vURfVg
zDuXtk)3=b?JKNOW4^qImS!Jg|4>;Qb`V3<-N3<6*p&8cT%71W)U8FKuA?}BO4L?E=
z!~~LEY4Um|bvq6%hm%dpK807+Ou(jYmV^ZP+ty-R`#X_=l#3#6^8hNGg+{SnZL>yv
zkn3RkTRFo$BX&rHyNc&M+AXxISc45~R>-6vHdgZeF}H3NR&Zy8)|HSY%BjlRW!L3H
zrCGOq(mEYS#(`6J{Uc<b%Ke?l{U)2et;M$1-Yu3<j*|I_Qo5QFvZ4a64m)&iRKatl
zcL}mxkW-6?AfWq$biar06}eSv*JEcb%{PT})2h%f@rjUS+H97RPMBR0AaYt-yGQy{
zq|oe0{g2~@R&mZS7dw2oR}?L}xSb+|7TP&*(IKteCwrRc`B>wrd}f`{y`%CjhSp)U
z8tNS%+om&e9|$z;LGc5O*O=CzqsiTZlvFs(OR83%sws-jh57S~Z(Uh@?WM3w&Qh5~
zy7*?N0YFQ12Di1ew1N^?lOXK=^#TL29;P+gW8|TSN6Wf~c<5xNo<f;qJuIoWMSast
zYeRn&ABmvv0b~H5V3yA)H12DAW&q?zWh+g=p~e*W*rP@u$3l=F#^=Re68j+52GEoM
z2HRQ?Y7glkySlj*MbU>5u7@F#i$}>NoHzpVdA#BghbJKApDsacO)u?lwICU#d|Epc
zN#GQ8`qW`Oh?cD7%U>;hd3n7B?Z%e9LC{EAu<Ayxv3La=Jl7v++LH_PS8Ugsy|v+-
zyV|<lph@L5Oll$qk+q7j+zdiMHq%O7w^^>=4W>$<2N@U>PAZX=nI@CBw3^)1E3%lf
zP?U+Xs9=S_Mx3+rv?k~(??|SnRZJrLm|6$jB4Zb>zCI#1w2GyuIbN9mhpH}reQ~);
z)NJ|Ed$lXSi{5g}zB}#rWfj$1`s^xb9~>=eug|q58MY!SlEhQi4|-an0sBm%v|%cz
z69f8oV2zWHx2-@ySJ?XyP73;^-Y?>d9(`7`QbZiKHi5RP^G(I=xH}D-|L?fTeGeHZ
zehN`v@ea^~$4RvLQ!_$p^Z5#T-2g)2PL)yuUH^+`wImIAR^&}L(~oHBP?Yj}<1r-9
zmfpk%ZU7I}Ir137B}$i+b;CUs79AN^Z0Z?2j3NNmFMRPD?5_R(pWnxN$;P6uAaOKi
zK4jAeFiiWTcQ$)E@wtoWq?nBb!r4s9+IzMb7^M<A0%<?hs~^)$710=}h&|!zX|BCm
zX-*d$k&F$|SLf98s6RGR%^3tcvX&%biq@mKw#0!GBAGbW-(>_{VIN8tYChj<0E3f?
z=47#|YjmPQrxy_sA0=c!_k1==4C5}JfvDktk)GjaRgKfEyd&&ERPI1?kE)K=lpn{D
zZb<3CL2y1Zn!wJ4=x=fkwD+{(cgz`Q<Vrj^MTs*aZp&Z)8T)0mmCdEpj*#3ku<M)W
zz$m+?gxoLERxxbAK3Z~&pq1q{Q7q|cK|F*(ChnXmH*kT0!)(Q|k)78_%lU-kgztTV
zAwzbTV!gEM(XlU(9B;O#DK$qgL@1N*MJSJ<5@L9BP-YF3{Uk8&Ae=EmitFd;wA#2H
z&LMM2H{ceuvlBlf5g{#pPE{guK|G8y6}@Cx8$*Pjw{ST{jl$gwrBU@}g6^asu0Sw{
zAD%~5{{Mysh$EO;%4h>Q>`q5}_tLlI=HWiv<u;1D=)rapcaxx#1F@gPBP4!I;!zS$
zlc3}#enNt_+M=Jt0Es6^93=51i9;kPF*l{C$N+H<8ff$8Wg&1P*J;OW8$Z)d+Z}cs
ze+l`Ahjv=_rsKl#La7Y;OB<L6cR#e};l2Cz*Gu{EfwoH!ai3NHGlUEpos~?{nMmz}
zFX`W>A1-`enIg@Qs21OT87E7!w)oELs+Q}@rw8O&+pdAq<Z=A34uzRKpB9uI6|*6O
z6p%T(qkvPc(U?PmC9s4H8*&bHd?^8xz%+#9gZ87~pEwhJjP~muoxi5Av$oC5j?8bg
QUfN@utVcIN_%rzXFW!0a9smFU

literal 0
HcmV?d00001

diff --git a/sdk/RaspberryPi/aes.py b/sdk/RaspberryPi/aes.py
new file mode 100644
index 00000000..ae52cd0f
--- /dev/null
+++ b/sdk/RaspberryPi/aes.py
@@ -0,0 +1,210 @@
+from Crypto.Cipher import AES
+import base64
+import binascii
+
+
+# 数据类
+class MData():
+    def __init__(self, data = b"",characterSet='utf-8'):
+        # data肯定为bytes
+        self.data = data
+        self.characterSet = characterSet
+  
+    def saveData(self,FileName):
+        with open(FileName,'wb') as f:
+            f.write(self.data)
+
+    def fromString(self,data):
+        self.data = data.encode(self.characterSet)
+        return self.data
+
+    def fromBase64(self,data):
+        self.data = base64.b64decode(data.encode(self.characterSet))
+        return self.data
+
+    def fromHexStr(self,data):
+        self.data = binascii.a2b_hex(data)
+        return self.data
+
+    def toString(self):
+        return self.data.decode(self.characterSet)
+
+    def toBase64(self):
+        return base64.b64encode(self.data).decode() #decode()转成字符串形式，否则为字节型数据
+
+    def toHexStr(self):
+        return binascii.b2a_hex(self.data).decode()
+
+    def toBytes(self):
+        return self.data
+
+    def __str__(self):
+        try:
+            return self.toString()
+        except Exception:
+            return self.toBase64()
+
+
+### 封装类
+class AEScryptor():
+    def __init__(self,key,mode,iv = '',paddingMode= "NoPadding",characterSet ="utf-8"):
+        '''
+        构建一个AES对象
+        key: 秘钥，字节型数据
+        mode: 使用模式，只提供两种，AES.MODE_CBC, AES.MODE_ECB
+        iv： iv偏移量，字节型数据
+        paddingMode: 填充模式，默认为NoPadding, 可选NoPadding，ZeroPadding，PKCS5Padding，PKCS7Padding
+        characterSet: 字符集编码
+        '''
+        self.key = key
+        self.mode = mode
+        self.iv = iv
+        self.characterSet = characterSet
+        self.paddingMode = paddingMode
+        self.data = ""
+
+    def __ZeroPadding(self,data):
+        data += b'\x00'
+        while len(data) % 16 != 0:
+            data += b'\x00'
+        return data
+
+    def __StripZeroPadding(self,data):
+        data = data[:-1]
+        while len(data) % 16 != 0:
+            data = data.rstrip(b'\x00')
+            if data[-1] != b"\x00":
+                break
+        return data
+
+    def __PKCS5_7Padding(self,data):
+        needSize = 16-len(data) % 16
+        if needSize == 0:
+            needSize = 16
+        return data + needSize.to_bytes(1,'little')*needSize
+
+    def __StripPKCS5_7Padding(self,data):
+        paddingSize = data[-1]
+        return data.rstrip(paddingSize.to_bytes(1,'little'))
+
+    def __paddingData(self,data):
+        if self.paddingMode == "NoPadding":
+            if len(data) % 16 == 0:
+                return data
+            else:
+                return self.__ZeroPadding(data)
+        elif self.paddingMode == "ZeroPadding":
+            return self.__ZeroPadding(data)
+        elif self.paddingMode == "PKCS5Padding" or self.paddingMode == "PKCS7Padding":
+            return self.__PKCS5_7Padding(data)
+        else:
+            print("不支持Padding")
+
+    def __stripPaddingData(self,data):
+        if self.paddingMode == "NoPadding":
+            return self.__StripZeroPadding(data)
+        elif self.paddingMode == "ZeroPadding":
+            return self.__StripZeroPadding(data)
+
+        elif self.paddingMode == "PKCS5Padding" or self.paddingMode == "PKCS7Padding":
+            return self.__StripPKCS5_7Padding(data)
+        else:
+            print("不支持Padding")
+
+    def setCharacterSet(self,characterSet):
+        '''
+        设置字符集编码
+        characterSet: 字符集编码
+        '''
+        self.characterSet = characterSet
+
+    def setPaddingMode(self,mode):
+        '''
+        设置填充模式
+        mode: 可选NoPadding，ZeroPadding，PKCS5Padding，PKCS7Padding
+        '''
+        self.paddingMode = mode
+
+    def decryptFromBase64(self,entext):
+        '''
+        从base64编码字符串编码进行AES解密
+        entext: 数据类型str
+        '''
+        mData = MData(characterSet=self.characterSet)
+        self.data = mData.fromBase64(entext)
+        return self.__decrypt()
+
+    def decryptFromHexStr(self,entext):
+        '''
+        从hexstr编码字符串编码进行AES解密
+        entext: 数据类型str
+        '''
+        mData = MData(characterSet=self.characterSet)
+        self.data = mData.fromHexStr(entext)
+        return self.__decrypt()
+
+    def decryptFromString(self,entext):
+        '''
+        从字符串进行AES解密
+        entext: 数据类型str
+        '''
+        mData = MData(characterSet=self.characterSet)
+        self.data = mData.fromString(entext)
+        return self.__decrypt()
+
+    def decryptFromBytes(self,entext):
+        '''
+        从二进制进行AES解密
+        entext: 数据类型bytes
+        '''
+        self.data = entext
+        return self.__decrypt()
+
+    def encryptFromString(self,data):
+        '''
+        对字符串进行AES加密
+        data: 待加密字符串，数据类型为str
+        '''
+        self.data = data.encode(self.characterSet)
+        return self.__encrypt()
+
+    def __encrypt(self):
+        if self.mode == AES.MODE_CBC:
+            aes = AES.new(self.key,self.mode,self.iv) 
+        elif self.mode == AES.MODE_ECB:
+            aes = AES.new(self.key,self.mode) 
+        else:
+            print("不支持这种模式")  
+            return           
+
+        data = self.__paddingData(self.data)
+        enData = aes.encrypt(data)
+        return MData(enData)
+
+    def __decrypt(self):
+        if self.mode == AES.MODE_CBC:
+            aes = AES.new(self.key,self.mode,self.iv) 
+        elif self.mode == AES.MODE_ECB:
+            aes = AES.new(self.key,self.mode) 
+        else:
+            print("不支持这种模式")  
+            return           
+        data = aes.decrypt(self.data)
+        # mData = MData(self.__stripPaddingData(data),characterSet=self.characterSet)
+        # return mData()
+        return MData(self.__stripPaddingData(data),characterSet=self.characterSet)
+
+
+if __name__ == '__main__':
+    key = b"1234567812345678"
+    iv =  b"0000000000000000"
+    aes = AEScryptor(key,AES.MODE_CBC,iv,paddingMode= "ZeroPadding",characterSet='utf-8')
+    
+    data = "好好学习"
+    rData = aes.encryptFromString(data)
+    print("密文：",rData.toBase64())
+    rData = aes.decryptFromBase64(rData.toBase64())
+    print("明文：",rData)
+# ————————————————
+# 版权声明：本文为CSDN博主「Hello_wshuo」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
+# 原文链接：https://blog.csdn.net/chouzhou9701/article/details/122019967
\ No newline at end of file
diff --git a/sdk/RaspberryPi/main_sdk.py b/sdk/RaspberryPi/main_sdk.py
new file mode 100644
index 00000000..f752cf19
--- /dev/null
+++ b/sdk/RaspberryPi/main_sdk.py
@@ -0,0 +1,335 @@
+# /***********************************************************
+#  * author: xiaoY [物美智能 wumei-smart]
+#  * create: 2022-05-10
+#  * email：qimint@outlook.com
+#  * source:https://github.com/kerwincui/wumei-smart
+#  * board:raspberry 4b
+#  ***********************************************************/
+
+import time
+import requests
+import json
+from aes import AEScryptor,AES
+import paho.mqtt.client as mqtt
+import random
+import threading #导入线程模块，用作定时器
+
+#################################################################
+# 需要连接好外部网络
+#################################################################
+
+# 作为python的AES的iv,应该为16位，字节型数据
+wumei_iv = b"wumei-smart-open"
+
+# NTP地址（用于获取时间,可选的修改为自己部署项目的地址）
+ntpServer = "http://120.24.218.158:8080/iot/tool/ntp?deviceSendTime="
+
+# 设备信息配置
+deviceNum = "DW43CI6RM8GMG23H"
+userId = "1"
+productId = "4"
+firmwareVersion = "1.0"
+# Mqtt配置
+mqttHost = "120.24.218.158"
+
+mqttPort = 1883
+mqttUserName = "wumei-smart"
+mqttPwd = "P261I5G3RY3MCIGG"
+# 作为python的AES的key,应该为16位，字节型数据
+mqttSecret = b"K2IB784BM0O01GG6"
+
+monitorCount =5      #发布监测数据的最大次数
+# 使用esp8266单片机时，服务器传来的间隔单位为毫秒，本程序由于定时运行需要的是秒，将转化为秒，如需毫秒运行，自行更改程序
+monitorInterval  =5 # 发布监测数据的间隔，默认5秒 
+
+g_rc=-1 # 连接成功标志位
+
+global t2 #全局变量，管理定时监测
+
+
+
+
+# 订阅的主题
+prefix = "/" + productId + "/" + deviceNum
+sOtaTopic = prefix + "/ota/get"
+sNtpTopic = prefix + "/ntp/get"
+sPropertyTopic = prefix + "/property/get"
+sFunctionTopic = prefix + "/function/get"
+sPropertyOnline = prefix + "/property-online/get"
+sFunctionOnline = prefix + "/function-online/get"
+sMonitorTopic = prefix + "/monitor/get"
+# 发布的主题
+pInfoTopic = prefix + "/info/post"
+pNtpTopic = prefix + "/ntp/post"
+pPropertyTopic = prefix + "/property/post"
+pFunctionTopic = prefix + "/function/post"
+pMonitorTopic = prefix + "/monitor/post"
+pEventTopic = prefix + "/event/post"
+
+# 初始化
+# 连接（客户端ID = 设备编号 & 产品ID）
+clientId = deviceNum + "&" + productId
+client=mqtt.Client(clientId)
+
+#加密 (AES-CBC-128-pkcs5padding)
+def encrypt(plain_data,wumei_key,wumei_iv):
+    aes=AEScryptor(wumei_key,AES.MODE_CBC,wumei_iv,paddingMode="PKCS5Padding",characterSet='utf-8')
+    rData=aes.encryptFromString(plain_data)
+    printMsg("密码(已加密)："+rData.toBase64())
+    return rData.toBase64()
+
+#回调函数。当尝试与MQTT broker 建立连接时，触发该函数。
+#client 是本次连接的客户端实例。
+#userdata 是用户的信息，一般为空。但如果有需要，也可以通过 user_data_set 函数设置。
+#flags 保存服务器响应标志的字典
+#rc 是响应码。
+# 0: 连接成功
+# 1: 连接失败-不正确的协议版本
+# 2: 连接失败-无效的客户端标识符
+# 3: 连接失败-服务器不可用
+# 4: 连接失败-错误的用户名或密码
+# 5: 连接失败-未授权
+# 6-255: 未定义.
+#一般情况下，我们只需要关注rc响应码是否为0就可以了。
+def on_connect(client,userdata,flags,rc):
+    if rc==0:
+        printMsg("连接成功")
+        # 放在on_connect下可以保证重连重新订阅
+        # 订阅(OTA、NTP、属性、功能、实时监测)
+
+        client.subscribe(sOtaTopic, 1)
+        client.subscribe(sNtpTopic, 1)
+        client.subscribe(sPropertyTopic, 1)
+        client.subscribe(sFunctionTopic, 1)
+        client.subscribe(sPropertyOnline, 1)
+        client.subscribe(sFunctionOnline, 1)
+        client.subscribe(sMonitorTopic, 1)
+
+        printMsg("订阅主题：" + sOtaTopic)
+        printMsg("订阅主题：" + sNtpTopic)
+        printMsg("订阅主题：" + sPropertyTopic)
+        printMsg("订阅主题：" + sFunctionTopic)
+        printMsg("订阅主题：" + sPropertyOnline)
+        printMsg("订阅主题：" + sFunctionOnline)
+        printMsg("订阅主题：" + sMonitorTopic)
+        # 发布设备信息
+        publishInfo()
+        global g_rc
+        g_rc=0
+    else:
+        printMsg("连接失败，rc="+str(rc))
+        printMsg("3秒后重连...")
+        time.sleep(3)
+        connectMqtt()
+
+#  物模型-属性处理
+def processProperty(payload):
+    data=json.loads(payload)
+    for item in data:
+        #  匹配云端定义的属性（不包含属性中的监测数据）
+        id = item["id"]
+        value=item["value"]
+        printMsg(str(id)+":"+str(value))
+    #  最后发布属性，服务端订阅存储（重要）
+    publishProperty(json.dumps(data))
+
+#  物模型-功能处理
+def processFunction(payload):
+    data=json.loads(payload)
+    for item in data:
+        # 匹配云端定义的功能
+        id = item["id"]
+        value=item["value"]
+        if(id=="switch"):
+            printMsg("开关 switch："+ str(value))
+        elif(id=="gear"):
+            printMsg("档位 gear："+ str(value))
+        elif(id=="light_color"):
+            printMsg("灯光颜色 light_color："+ str(value))
+        elif(id=="message"):
+            printMsg("屏显消息 message："+ str(value))
+        elif(id=="report_monitor"):
+            msg=randomPropertyData();
+            printMsg("订阅到上报监测数据指令，上报数据：")
+            printMsg(msg)
+            publishProperty(msg)
+    #  最后发布属性，服务端订阅存储（重要）
+    publishProperty(json.dumps(data))
+
+# 回调函数，在客户端订阅的主题上接收到消息时调用，“message”变量是一个MQTT消息描述所有消息特征
+def on_message(client,userdata,msg):
+    printMsg("接收数据:"+msg.topic+" "+str(msg.payload))
+    if(msg.topic==sOtaTopic):
+        printMsg("订阅到设备升级指令...")
+    elif(msg.topic==sNtpTopic):
+        printMsg("订阅到NTP时间..."); 
+        jsonData=json.loads(msg.payload)
+        deviceSendTime = jsonData["deviceSendTime"]
+        serverSendTime = jsonData["serverSendTime"]
+        serverRecvTime = jsonData["serverRecvTime"]
+        deviceRecvTime = round(time.time()*1000)
+        now = (serverSendTime + serverRecvTime + deviceRecvTime - deviceSendTime) / 2
+        printMsg("当前时间："+str(round(now)))
+    elif(msg.topic==sPropertyTopic or msg.topic==sPropertyOnline):
+        printMsg("订阅到属性指令...")
+        processProperty(msg.payload)
+    elif(msg.topic==sFunctionTopic or msg.topic==sFunctionOnline):
+        printMsg("订阅到功能指令...")
+        processFunction(msg.payload)
+    elif(msg.topic==sMonitorTopic):
+        # python全局变量的使用
+        global t2
+        global monitorCount
+        global monitorInterval
+        printMsg("订阅到实时监测指令...")
+        jsonData=json.loads(msg.payload)
+        monitorCount = jsonData["count"]
+        monitorInterval = jsonData["interval"]/1000
+        t2.cancel()
+        t2=threading.Timer(monitorInterval,timing_publishMonitor)
+        t2.start()
+
+# 1.发布设备信息
+def publishInfo():
+    # rssi值 树莓派中暂时不处理wifi信号问题
+    #  信号强度（信号极好4格[-55— 0]，信号好3格[-70— -55]，信号一般2格[-85— -70]，信号差1格[-100— -85]）
+    # status值 （1-未激活，2-禁用，3-在线，4-离线）
+    doc={"rssi":1,"firmwareVersion":firmwareVersion,"status":3,"userId":userId}
+    #     client.publish('raspberry/topic',payload=i,qos=0,retain=False) 
+    jsonData=json.dumps(doc)
+    printMsg("发布设备信息："+pInfoTopic+" "+jsonData)
+    client.publish(pInfoTopic,jsonData)
+
+#  2.发布时钟同步信，用于获取当前时间(可选) 
+def publishNtp():
+    data={"deviceSendTime":round(time.time()*1000)}
+    jsonData=json.dumps(data)
+    printMsg("发布NTP信息"+jsonData)
+    client.publish(pNtpTopic,jsonData)
+
+# 3.发布属性
+# msg 接收格式json
+def publishProperty(msg):
+    printMsg("发布属性:" + msg)
+    client.publish(pPropertyTopic, msg)
+
+#  4.发布功能
+def publishFunction( msg):
+    printMsg("发布功能:" + msg)
+    client.publish(pFunctionTopic, msg)
+
+# 5.发布事件
+def publishEvent():
+    objTmeperature={"id":"height_temperature","value":40,"remark":"温度过高警告"}
+    objException={"id":"exception","value":"异常消息，消息内容XXXXXXXX","remark":"设备发生错误"}
+    data=[objTmeperature,objException]
+    jsonData=json.dumps(data)
+    printMsg("发布事件:"+jsonData)
+    client.publish(pEventTopic,jsonData)
+
+# 6.发布实时监测数据
+def publishMonitor():
+    msg=randomPropertyData()
+    # 发布为实时监测数据，不会存储
+    printMsg("发布实时监测数据："+msg)
+    client.publish(pMonitorTopic,msg)
+
+# 随机生成监测值
+def randomPropertyData():
+    # 匹配云端定义的监测数据，随机数代替监测结果
+    # random.randint(0,10) #生成数据包括0,10 
+    # random.uniform(30,60)生成数据为浮点型
+    objTmeperature={"id":"temperature","value":str(round(random.uniform(10,30),2)),"remark":""}
+    objHumidity={"id":"humidity","value":str(round(random.uniform(30,60),2)),"remark":""}
+    objCo2={"id":"co2","value":str(random.randint(400,1000)),"remark":""}
+    objBrightness={"id":"brightness","value":str(random.randint(1000,10000)),"remark":""}
+    printMsg("随机生成监测数据值:")
+    data=[objTmeperature,objHumidity,objCo2,objBrightness]
+    print(json.dumps(data))
+    return json.dumps(data)
+
+#连接mqtt
+def connectMqtt():
+    printMsg("连接Mqtt服务器")
+    # 生成mqtt认证密码（密码 = mqtt密码 & 用户ID & 过期时间）
+    password = generationPwd()
+    encryptPassword=encrypt(password,mqttSecret,wumei_iv)
+    # 生成mqtt认证密码（密码 = mqtt密码 & 用户ID & 过期时间） 
+    client.username_pw_set(mqttUserName,encryptPassword)
+    client.on_connect=on_connect
+    client.on_message=on_message
+    client.connect(mqttHost,mqttPort,10)
+
+
+
+
+#打印提示信息
+def printMsg(msg):
+    print("[{}] {}".format(time.strftime("%Y-%m-%d %H:%M:%S"),msg))
+# 生成密码
+def generationPwd():
+    try:
+        doc=json.loads(getTime())
+    except:
+        printMsg("Json解析失败")
+        exit()
+    deviceSendTime = doc["deviceSendTime"]
+    serverSendTime = doc["serverSendTime"]
+    serverRecvTime = doc["serverRecvTime"]
+    deviceRecvTime = round(time.time()*1000)
+    now = (serverSendTime + serverRecvTime + deviceRecvTime - deviceSendTime) / 2
+    expireTime = int(now + 1 * 60 * 60 * 1000)
+    password = mqttPwd + "&" + userId + "&" + str(expireTime)
+    printMsg("密码(未加密):" + password)
+    return password
+# HTTP获取时间
+def getTime():
+    try:
+        r=requests.get(ntpServer+str(round(time.time()*1000)))
+        if(r.status_code>0):
+            if(r.status_code==200 or r.status_code==301):
+                printMsg("获取时间成功，data:"+r.text)
+                return r.text
+        else:
+            printMsg("获取时间失败，error:"+r.status_code)
+    except:
+        printMsg("连接Http失败")
+        
+
+def timing_publishProperty():
+    printMsg("执行定时上报")
+    #发布事件
+    publishEvent()
+    #发布时钟同步
+    publishNtp()
+    #  发布属性(监测值)
+    msg=randomPropertyData()
+    publishProperty(msg)
+    t1=threading.Timer(60,timing_publishProperty)
+    t1.start()
+def timing_publishMonitor():
+    global monitorCount
+    monitorCount=monitorCount-1
+    printMsg("执行监测")
+    publishMonitor()
+    if(monitorCount>0):
+        t2=threading.Timer(monitorInterval,timing_publishMonitor)
+        t2.start()
+        
+if __name__ == '__main__':
+    connectMqtt()
+    client.loop_start()
+    printMsg("等待连接MQTT")
+    while(g_rc!=0):
+        print("-",end=" ")
+        time.sleep(1)
+    t1=threading.Timer(60,timing_publishProperty)
+    t1.setDaemon(True) #当主线程被关闭后，子线程也关闭
+    t1.start()
+    t2=threading.Timer(monitorInterval,timing_publishMonitor)
+    t2.setDaemon(True) #当主线程被关闭后，子线程也关闭
+    t2.start()
+
+    while True:
+        time.sleep(10) #定时上报、检测上报都是线程执行，主线程可以做自己的任务
+