from ext.common import Abstract
from ext.lcd import tp_cst816
from ext.btn_device_ec800m import BtnDevice
- from ext.protocol import LK_ProtoCol,PING_ProtoCol,HEART_ProtoCol,OXYGEN_ProtoCol,OXYGEN_One_ProtoCol,HRSTART_ProtoCol,WT_ProtoCol,UD_ProtoCol,REMIND_ProtoCol, CR_ProtoCol,KA_ProtoCol,FIND_ProtoCol,POWEROFF_ProtoCol,ProtoColResolver,PHL_ProtoCol
+ from ext.protocol import LK_ProtoCol,PING_ProtoCol,HEART_ProtoCol,OXYGEN_ProtoCol,OXYGEN_One_ProtoCol,HRSTART_ProtoCol,temp_ProtoCol,\
+ WT_ProtoCol,UD_ProtoCol,REMIND_ProtoCol, CR_ProtoCol,KA_ProtoCol,FIND_ProtoCol,POWEROFF_ProtoCol,ProtoColResolver,PHL_ProtoCol
import ext.mgr as mgr
print("init1:{}".format(utime.localtime()))
import ext.ui as _ui
pcr.add_support(HEART_ProtoCol())
pcr.add_support(OXYGEN_ProtoCol())
pcr.add_support(OXYGEN_One_ProtoCol())
+ pcr.add_support(temp_ProtoCol())
sm = SockManager()
sm.add_support_resolver(pcr)
app.append_manager(sm)
def handler(self, event, msg):
self.password = EventMesh.publish(constants.EVENT.GET_PASSWORD)
- self.imei = EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166" #EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI) #"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI) #"867387060319166"#"867387060319188"#"867387060319177"#"867387060319166"#"860132060004322"#"867387060319166"#"860132060004322"#EventMesh.publish(constants.EVENT.GET_IMEI)
+ self.imei = "867387060319166" #EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166" #EventMesh.publish(constants.EVENT.GET_IMEI)#"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI) #"867387060319166"#EventMesh.publish(constants.EVENT.GET_IMEI) #"867387060319166"#"867387060319188"#"867387060319177"#"867387060319166"#"860132060004322"#"867387060319166"#"860132060004322"#EventMesh.publish(constants.EVENT.GET_IMEI)
self.cid = EventMesh.publish(constants.EVENT.GET_CID)
self.imsi = EventMesh.publish(constants.EVENT.GET_IMSI)
self.key = EventMesh.publish(constants.EVENT.GET_KEY)
#EventMesh.publish(constants.PROTOCOL.OXYGEN_SEND)
class OXYGEN_One_ProtoCol(ProtoCol):#单次测量
- """上传血氧测试数据"""
+ """上传单次测量测试数据"""
TYPE = "oxstart"
# 终端发送[XT*YYYYYYYYYYYYYYY*LEN*oxygen,x]
EventMesh.publish("set_spo2_state",3)#3代表单次测量
EventMesh.publish(constants.PROTOCOL.OXSTART_SEND)
-#设置和获取心率上传频率时间
+class temp_ProtoCol(ProtoCol):
+ """上传体温测试数据"""
+ TYPE = "temp"
+ def send(self, event, msg):
+ # [SZKW*334588000000156*len*heart,x]
+ # print("temp:send:{}".format(msg))
+ len_size = len(str(msg))+5
+ # 实例:[XT*334588000000156*0009*temp,36.2]
+ # 代表终端的温度为:36.2
+ # 平台回复:
+ # [XT*334588000000156*0004*temp]
+ send_data = "SZKW*%s*%04X*temp"%(self.imei,len_size)
+ MD5_SIGN = self.pack_MD5_head(send_data)
+ data = "[%s%s,%d.%d]"%(str(MD5_SIGN),send_data,msg[0],msg[1])
+ # print("temp:data:%s"%(data))
+ # 通过socket发送到服务器端
+ EventMesh.publish(constants.EVENT.CHANNEL_SOCKET_SEND,data)
+ def recv(self, event, msg):
+ """
+ @param event: 心率数据下发
+ @param msg: 接收到的下行数据
+ """
+ # print("HRSTART_ProtoCol RECV msg:")
+ #EventMesh.publish(constants.PROTOCOL.TEMP_SEND)
class ProtoColResolver(object):
def __init__(self):
self.protocol_list = []