# coding=utf-8
|
|
from driver import GPIO
|
import network
|
import ujson
|
import utime as time
|
import modem
|
import _thread
|
from aliyunIoT import Device
|
import ota
|
import kv
|
|
ICCID=None
|
g_connect_status = False
|
net = None
|
device = None
|
deviceSecret = None
|
deviceName = None
|
import app_uart
|
productKey = ""
|
productSecret = ""
|
device_dyn_resigter_succed = False
|
#是否iot已连接
|
iot_connected=False
|
# 定义需要升级的模块和版本号
|
module_name = 'default'
|
default_ver = '2.0.5'
|
# 定义升级包的下载和安装路径，其中url,hash_type和hash 会通过服务端推送被保存下来
|
|
info = {
|
'url': '',
|
'store_path': '/data/pyamp/app.zip',
|
'install_path': '/data/pyamp/',
|
'length': 0,
|
'hash_type': '',
|
'hash': ''
|
}
|
|
# ota 消息推送的接受函数
|
def on_trigger(data):
|
global info
|
# 保存服务端推送的ota信息
|
info['url'] = data['url']
|
info['length'] = data['length']
|
info['module_name'] = data['module_name']
|
info['version'] = data['version']
|
info['hash'] = data['hash']
|
info['hash_type'] = data['hash_type']
|
# 开始ota 包下载
|
dl_data = {}
|
dl_data['url'] = info['url']
|
dl_data['store_path'] = info['store_path']
|
ota.download(dl_data)
|
|
|
|
# ota 升级包下载结果回调函数
|
def on_download(data):
|
global info
|
if data >= 0:
|
print('Ota download succeed')
|
# 开始ota包校验
|
param = {}
|
param['length'] = info['length']
|
param['store_path'] = info['store_path']
|
param['hash_type'] = info['hash_type']
|
param['hash'] = info['hash']
|
ota.verify(param)
|
|
# ota 升级包校验结果回调函数
|
def on_verify(data):
|
global info
|
print(data)
|
if data >= 0 :
|
print('Ota verify succeed')
|
print('Start Upgrade')
|
# 开始ota升级
|
param = {}
|
param['length'] = info['length']
|
param['store_path'] = info['store_path']
|
param['install_path'] = info['install_path']
|
ota.upgrade(param)
|
|
# ota 升级包结果回调函数
|
def on_upgrade(data):
|
if data >= 0 :
|
print('Ota succeed')
|
#ota升完级后 重启设备
|
reboot()
|
|
#当iot设备连接到物联网平台的时候触发'connect' 事件
|
def on_connect(data):
|
global module_name,default_ver,productKey,deviceName,deviceSecret,on_trigger,on_download,on_verify,on_upgrade,iot_connected
|
print('***** connect lp succeed****')
|
print('物联网链接成功')
|
#联网成功在打印版本信息
|
_thread.start_new_thread(masgDefault_ver,(3,))
|
iot_connected=True
|
data_handle = {}
|
data_handle['device_handle'] = device.getDeviceHandle()
|
# 初始化ota服务
|
ota.init(data_handle)
|
# ota 回调函数注册
|
ota.on(1,on_trigger)
|
ota.on(2,on_download)
|
ota.on(3,on_verify)
|
ota.on(4,on_upgrade)
|
report_info = {
|
"device_handle": data_handle['device_handle'],
|
"product_key": productKey ,
|
"device_name": deviceName ,
|
"module_name": module_name ,
|
"version": default_ver
|
}
|
# 上报本机ota相关信息,上报版本信息返回以后程序返回，知道后台推送ota升级包，才会调用on_trigger函数
|
ota.report(report_info)
|
#当连接断开时，触发'disconnect'事件
|
def on_disconnect():
|
print('linkkit is disconnected')
|
|
#当iot云端下发属性设置时，触发'props'事件
|
def on_props(request):
|
params=request['params']
|
print('clound req data is {}'.format(params))
|
data_all=eval(params)
|
if(data_all['key']==1):
|
app_uart.sund_key()
|
# print('clound req data is {}'.format(request))
|
|
#当iot云端调用设备service时，触发'service'事件
|
def on_service(id,request):
|
print('clound req id is {} , req is {}'.format(id,request))
|
#当设备跟iot平台通信过程中遇到错误时，触发'error'事件
|
def on_error(err):
|
print('err msg is {} '.format(err))
|
|
#网络连接的回调函数
|
def on_4g_cb(args):
|
global g_connect_status
|
pdp = args[0]
|
netwk_sta = args[1]
|
if netwk_sta == 1:
|
g_connect_status = True
|
else:
|
g_connect_status = False
|
|
#网络连接
|
def connect_network():
|
global net,on_4g_cb,g_connect_status
|
#NetWorkClient该类是一个单例类，实现网络管理相关的功能，包括初始化，联网，状态信息等.
|
net = network.NetWorkClient()
|
g_register_network = False
|
if net._stagecode is not None and net._stagecode == 3 and net._subcode == 1:
|
g_register_network = True
|
else:
|
g_register_network = False
|
if g_register_network:
|
#注册网络连接的回调函数on(self,id,func); 1代表连接，func 回调函数 ；return 0 成功
|
net.on(1,on_4g_cb)
|
net.connect(None)
|
else:
|
print('网络注册失败')
|
while True:
|
if g_connect_status:
|
print('网络连接成功')
|
break
|
time.sleep_ms(20)
|
|
#动态注册回调函数
|
def on_dynreg_cb(data):
|
global deviceSecret,device_dyn_resigter_succed
|
deviceSecret = data
|
device_dyn_resigter_succed = True
|
|
|
# 连接物联网平台
|
def dyn_register_device(productKey,productSecret,deviceName):
|
global on_dynreg_cb,device,deviceSecret,device_dyn_resigter_succed
|
key = '_amp_customer_devicesecret'
|
deviceSecretdict = kv.get(key)
|
print("deviceSecretdict:",deviceSecretdict)
|
if isinstance(deviceSecretdict,str):
|
deviceSecret = deviceSecretdict
|
|
if deviceSecretdict is None or deviceSecret is None:
|
key_info = {
|
'productKey': productKey ,
|
'productSecret': productSecret ,
|
'deviceName': deviceName
|
}
|
# 动态注册一个设备，获取设备的deviceSecret
|
#下面的if防止多次注册，当前若是注册过一次了，重启设备再次注册就会卡住，
|
if not device_dyn_resigter_succed:
|
device.register(key_info,on_dynreg_cb)
|
|
|
def iotInit(device_name,product_key,product_secret):
|
global g_connect_status,device,deviceSecret,deviceName,productKey,productSecret,device
|
deviceName=device_name
|
productSecret=product_secret
|
productKey=product_key
|
#初始化物联网平台Device类，获取device实例
|
device = Device()
|
#链接参数
|
key_info = {
|
'region' : 'cn-shanghai' ,
|
'productKey': productKey ,
|
'deviceName': deviceName ,
|
'deviceSecret': productSecret ,
|
'keepaliveSec': 60,
|
}
|
#device.ON_CONNECT 是事件，on_connect是事件处理函数/回调函数
|
device.on(device.ON_CONNECT,on_connect)
|
device.on(device.ON_DISCONNECT,on_disconnect)
|
device.on(device.ON_PROPS,on_props)
|
device.on(device.ON_SERVICE,on_service)
|
device.on(device.ON_ERROR,on_error)
|
print('准备链接iot平台。。。')
|
device.connect(key_info)
|
#透传
|
def sudDataIot(usertestdata ):
|
if iot_connected:
|
postdata={'param':usertestdata}
|
ret = device.postRaw(postdata)
|
if ret == 0 :
|
print('RAW数据上报成功')
|
else :
|
print('RAW数据上报失败')
|
# 物模型上传
|
def sudDataPostProps(usertestdata ):
|
if iot_connected:
|
tem_hum_str=ujson.dumps(usertestdata)
|
data={
|
'params':tem_hum_str
|
}
|
device.postProps(data)
|
def get_mqtt_connect_flag():
|
global iot_connected
|
return iot_connected
|
def masgDefault_ver(id):
|
while True:
|
print('当前App版本号:' + default_ver)
|
print('等待Ota升级包.....')
|
print('--------------------------------------------------------------------')
|
time.sleep(30)
|
