--- /dev/null
+import _thread
+import usys
+import ql_fs
+CHINA_TELECOM_DM_FUN_ENABLE = 1 #是否开启电信入库的功能
+CHINA_MOBILE_DM_FUN_ENABLE = 1 #开启移动入库功能
+class EventStore(object):
+ def __init__(self):
+ self.map = dict()
+ self.log = None
+ self.__filters = []
+
+ def add_filter(self, flt):
+ self.__filters.append(flt)
+
+ def append(self, event, cb):
+ self.map[event] = cb
+
+ def fire_async(self, event, msg,thread_size):
+ if event in self.map:
+ #print("fire_async:thread_size:{}".format(thread_size))
+ if thread_size != None:
+ _thread.stack_size(thread_size)
+ #print("fire_async:thread_size:{}".format(thread_size))
+ _thread.start_new_thread(self.map[event], (event, msg))
+ if thread_size != None:
+ _thread.stack_size(8*1024)
+ if self.log:
+ self.log.info("ASYNC executed (event) -> {} (params) -> {} (result) -> {}".format(event, msg, None))
+
+ def fire_sync(self, event, msg):
+ res = None
+ try:
+ if event in self.map:
+ res = self.map[event](event, msg)
+ except Exception as e:
+ usys.print_exception(e)
+ if self.log:
+ self.log.info("ERROR executed (event) -> {} (params) -> {} (result) -> {}".format(event, msg, res))
+ if event not in self.__filters:
+ if self.log:
+ self.log.info("SYNC executed (event) -> {} (params) -> {} (result) -> {}".format(event, msg, res))
+ return res
+
+ def subscribe(self,event, cb):
+ """
+ subscribe event and cb
+ """
+ return self.append(event, cb)
+
+
+ def publish(self,event, msg=None):
+ """
+ publish event and msg
+ """
+ return self.publish_sync(event, msg)
+
+
+ def publish_async(self,event, msg=None,thread_size = None):
+ """
+ 异步发送
+ """
+ return self.fire_async(event, msg,thread_size)
+
+
+ def publish_sync(self,event, msg=None):
+ """
+ 同步发送
+ """
+ return self.fire_sync(event, msg)
+
+
+ def set_log(self,log_adapter):
+ self,log = log_adapter
+
+
+ def add_filter(self,flt):
+ self.add_filter(flt)
+
+eventMesh = EventStore()
+
+
+
+
+
+
+
--- /dev/null
+# Copyright (c) Quectel Wireless Solution, Co., Ltd.All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+
+# net.getNetMode()
+# (0, '460', '11', 7)
+
+# net.getSignal(1)
+# ([99, 99, 255, 255], [-84, -117, -15, 255, -3])
+
+# net.nitzTime()
+# ('24/02/26 11:17:42 8 0', 1708946262, 0)
+
+
+import usocket
+import log
+import utime
+import slip
+import audio
+from machine import UART
+import _thread
+from queue import Queue
+from machine import Pin
+from machine import ExtInt
+import dataCall
+import voiceCall
+import net
+import uping
+import example
+import osTimer
+import sim
+import modem
+import utime
+import checkNet
+import atcmd
+import fota
+import request
+import ql_fs
+import pm
+import sms
+from usr.EventMesh import eventMesh
+
+from usr.telecom_dmp import telecomDmpCb
+from usr.china_mobile_dmp import chinamobileCb
+
+def msg_cb(args):
+ index = args[1]
+ storage = args[2]
+ sms_data = sms.getSaveLoc()
+ if sms_data == -1:
+ return
+ sms_max = sms_data[0][2]
+ if index != -1:
+ eventMesh.publish("send_singal_data_toBle",index)
+
+ if index >= sms_max-1:#删除短信
+ eventMesh.publish("delete_sms_event")#删除短信
+
+sms.setCallback(msg_cb)#sms注册回调
+
+CAT1_SERVICE_HEAD = 'FE' #固定head
+
+PROJECT_NAME = "Cat1SlipUDPService"
+PROJECT_VERSION = "PY_SRV_V13"
+CONFIG_JSON="/usr/system_config.json"
+CURRENT_APP_TYPE="pysrv"
+
+
+# 设置日志输出级别
+log.basicConfig(level=log.INFO)
+cat1service_log = log.getLogger("cat1service")
+
+# lpm_fd = pm.create_wakelock("system_lock", len("system_lock"))
+pm.autosleep(1)
+# pm.wakelock_lock(lpm_fd)
+cat1service_log.info("create_wakelock {}".format(pm.get_wakelock_num()))
+telecomTimerCount = 0
+def get_versionkeyname_by_py(app_type):
+ return str("{}version".format(app_type))
+
+def get_default_versionvalue_by_py(app_type):
+ if (app_type == "pymain"):
+ return "PY_MAIN_V2"
+ elif (app_type == "pyota"):
+ return "PY_OTA_V13"
+ elif (app_type == "pysrv"):
+ return "PY_SRV_V13"
+
+#如果没有configfile则创建它
+if not ql_fs.path_exists(CONFIG_JSON):
+ data = {str(get_versionkeyname_by_py(CURRENT_APP_TYPE)):get_default_versionvalue_by_py(CURRENT_APP_TYPE)}
+ ql_fs.touch(CONFIG_JSON,data)
+
+def set_version_to_json_config(app_type,keyvalue):
+ config_data = ql_fs.read_json(CONFIG_JSON)
+ config_data.update( {str(get_versionkeyname_by_py(app_type)):keyvalue})
+ ql_fs.touch(CONFIG_JSON, config_data)
+ cat1service_log.info("{}={}".format(get_versionkeyname_by_py(app_type),keyvalue))
+ cat1service_log.info("{}".format(config_data))
+
+def get_version_from_json_config(app_type):
+ config_data = ql_fs.read_json(CONFIG_JSON)
+ keyvalue = config_data.get( get_versionkeyname_by_py(app_type),get_default_versionvalue_by_py(app_type))
+ cat1service_log.info("{}={}".format(get_versionkeyname_by_py(app_type),keyvalue))
+ return keyvalue
+
+set_version_to_json_config(CURRENT_APP_TYPE,PROJECT_VERSION)
+
+
+audio.set_qdai_cfg(1,0,0,1,0,0,1,1)
+
+# GPIO21 - 引脚 86 KP_MKOUT1 唤醒主控
+# GPIO22 - 引脚 87 KP_MKIN 被主控唤醒
+
+# GPIOn - GPIO号，int类型，点此查看GPIO引脚编号与物理引脚的映射关系。
+
+# direction - 输入输出模式，int类型，IN - 输入模式，OUT - 输出模式。
+
+# pullMode - 上下拉模式，int类型，说明如下：
+# PULL_DISABLE - 浮空模式
+# PULL_PU - 上拉模式
+# PULL_PD - 下拉模式
+
+# level - 引脚电平，int类型，0 - 设置引脚为低电平, 1- 设置引脚为高电平。
+# recvDataPin = Pin(Pin.GPIO22, Pin.IN, Pin.PULL_PU, 0)
+def ExtIntfun(args):
+ # cat1service_log.info('### interrupt {} ###'.format(args)) # args[0]:gpio号 args[1]:上升沿或下降沿
+ if args[1] == 0:
+ cat1service_log.info("disable autosleep")
+ pm.autosleep(0)
+ # pm.wakelock_lock(lpm_fd)
+ elif args[1] == 1:
+ cat1service_log.info("enable autosleep")
+ # pm.wakelock_unlock(lpm_fd)
+ pm.autosleep(1)
+ # cat1service_log.info("recvDataPin={}".format(recvDataPin.read()))
+extint = ExtInt(ExtInt.GPIO22, ExtInt.IRQ_RISING_FALLING, ExtInt.PULL_DISABLE, ExtIntfun)
+extint.enable()
+
+
+# 创建gpio对象
+gpioWakeBT = Pin(Pin.GPIO21, Pin.OUT, Pin.PULL_DISABLE, 1)
+# 设置输入输出模式
+gpioWakeBT.set_dir(Pin.OUT)
+
+# 设置引脚电平
+gpioWakeBT.write(0)
+
+UDP_CMD_GET_CAT1VER = '0' #获取 Cat1 版本号
+UDP_CMD_DIAL_NUMB = '1' #拨打电话
+UDP_CMD_HUNGUP = '2' #挂断电话
+UDP_CMD_ANSWER = '3' #接听电话
+UDP_CMD_CAT1_OTA_UPDATE = '4' #触发Cat1 OTA升级，mcu提供url
+UDP_CMD_SEND_SMS = '5' #发送SMS短信，mcu提供电话号及短信内容
+UDP_CMD_GET_TIME = '6' #获取Cat1 时间 ，YYYYMMDD HHmmss zone
+UDP_CMD_GET_RECV_NETWORKSTAT = '7' #获取Cat1 信号信息，VOLTE信息，信号强度，SIM卡状态 // 内容同UDP_CMD_GET_NETWORKSTAT，CAT主动发给MCU
+UDP_MSG_SMS = '8' # CAT1接收到的SMS信息给MCU，包含电话号及短信内容
+UDP_CMD_ATCMD = '9' # 执行AT指令
+UDP_MSG_CALL_CONNECTED = 'A' # CAT1 电话接听消息
+UDP_MSG_CALL_DISCONNECTED = 'B' # CAT1 电话挂断消息
+UDP_MSG_COMMING_CALL = 'C' # CAT1 来电消息，包含电话号
+UDP_MSG_REPLY = 'F' # 返回值
+
+
+
+def result(args):
+ print('download status:',args[0],'download process:',args[1])
+def download_fota_img( srcurl ):
+ fota_obj = fota() # 创建Fota对象
+ cat1service_log.info("httpDownload... {} , {}".format("{}/dfota_1.bin".format(srcurl),"{}/dfota_2.bin".format(srcurl)))
+ res = fota_obj.httpDownload(url1="{}/dfota_1.bin".format(srcurl),url2="{}/dfota_2.bin".format(srcurl),callback=result)
+ #差分升级FTP方式
+ #res = fota_obj.httpDownload(url1="ftp://user:password@ip:port/fota.bin",callback=result) #其中user,password,ip,port需要填写具体使用的FTP服务器信息
+ if res != 0:
+ cat1service_log.error("httpDownload error")
+
+def check_fota():
+ modem_ver = modem.getDevFwVersion()
+ imei = modem.getDevImei()
+ url = "http://icfota.snicker.com.cn:8089/fd230ota.jsp?product=FD230&pkgver={0}&imei={1}".format(modem_ver,imei)
+ response = request.get(url)
+ cat1service_log.info(url)
+ data = response.json()
+ if(data['UptoDate'] == False):
+ cat1service_log.info("Need update python application")
+ srcurl = data['url']
+ #差分升级方式
+ # res = fota_obj.httpDownload(url1="http://www.example.com/fota.bin",callback=result)
+ # mini fota方式
+ return srcurl
+ else:
+ cat1service_log.info("No need update python application")
+ return ""
+
+class Cat1Service:
+ AP = 0 # SLIP_INNER
+ STA = 1 # SLIP_OUTER
+
+ def __init__(self, uart=UART.UART4, mode=AP):
+
+ self.__uart = uart
+ self.__mode = mode
+ self.__message = ''
+ self.__err = 0
+ self.__net_connected = 0
+ # self.__value = None
+ self.__wait_resp = 0
+ self.__waiting_netstat = 0
+ # slip.destroy()
+ # print('slip uart={0}'.format (self.__uart))
+
+ # ret = slip.construct(self.__uart, self.__mode, 0)
+ # if ret != 0:
+ # print('slip netif construct fail')
+ # return None
+ print('slip network card create success')
+ # self.__queue = Queue(1)
+ self.__sock = self.__socket_init()
+ self.__threadid = _thread.start_new_thread(self.__Socket_Thread, ())
+ self.telecom_init_flag = 0
+ self.telecomTimer = osTimer()
+ eventMesh.subscribe("cat1_reply_iccid_to_ble",self.cat1_reply_iccid_to_ble)
+ eventMesh.subscribe("cat1_reply_timesec_to_ble",self.cat1_reply_timesec_to_ble)
+
+ self.iccid_data = ""
+ self.software_version = ""
+ self.deletSmsTimer = osTimer()
+
+ self.volte_switch = 1 #默认是开启VOLTE通话功能
+ eventMesh.subscribe("set_dmp_change_mode",self.set_dmp_change_mode)
+ eventMesh.subscribe("get_dmp_change_mode",self.get_dmp_change_mode)
+ eventMesh.subscribe("delete_sms_event",self.delete_sms_event)
+ eventMesh.subscribe("remove_all_sms_cb", self.remove_all_sms_cb)#
+ eventMesh.subscribe("send_sms_max_to_Ble",self.send_sms_max_to_Ble)
+ eventMesh.subscribe("get_all_sms_data",self.get_all_sms_data) #获取所有的短信内容
+ eventMesh.subscribe("send_singal_data_toBle",self.send_singal_data_toBle)
+ eventMesh.subscribe("delete_sms_single_data",self.delete_sms_single_data)
+
+ eventMesh.subscribe("get_factory_status",self.get_factory_status)
+ eventMesh.subscribe("set_factory_status",self.set_factory_status)
+ eventMesh.subscribe("send_dmp_cm_address_toBLE",self.send_dmp_cm_address_toBLE)
+ eventMesh.subscribe("set_volte_switch",self.set_volte_switch)
+ eventMesh.subscribe("get_volte_switch",self.get_volte_switch)
+ eventMesh.publish("delete_sms_event")
+
+
+ self.telecom_dmp_switch = 0
+
+ self.send_data = []
+ self.code_old = 0
+ self.code_old_num = 1
+ self.tmp_data = []
+ self.total_num = 0
+ #
+ self.msg_nums = 0
+ self.msg_nums_old = 0
+ self.china_mobile_init = 0
+ self.factory_status = 0
+
+ return None
+
+ def __socket_init(self):
+ # 创建一个socket实例
+ sock = usocket.socket(usocket.AF_INET, usocket.SOCK_DGRAM, usocket.TCP_CUSTOMIZE_PORT)
+ sock.setsockopt(usocket.SOL_SOCKET, usocket.SO_REUSEADDR, 1)
+ # 绑定IP
+ bind_addr = ('172.16.1.2', 5000)
+ sock.bind(bind_addr)
+ sock.settimeout(10)
+ return sock
+
+ def __socket_reinit(self):
+ return self.__socket_init()
+
+ def bootup_msg_to_bt(self):
+ modem_ver = modem.getDevFwVersion()
+ self.reply_cmd('0F',"BOOTUP@pyVer:{}@modemVer:{}".format(PROJECT_VERSION,modem_ver))
+
+ def btmcu_cmd_handler(self,cmd,parm):
+
+ # cmd = ""
+ # cmd_tmp= int(cmd_data)#将十进制数转换成int 再转换成十六进制
+ # cell_data = hex(cmd_tmp)
+ # decimal_number = int(cell_data, 16)
+ # cmd = "%02x"%(decimal_number) # 使用两位表示，不足前面补0
+ print(cmd) # 输出: 07
+ print("btmcu_cmd_handler cmd {0} , args {1}".format(cmd,parm))
+ if cmd == "00":
+ print(cmd)
+ # UDP_CMD_GET_CAT1VER
+ modem_ver = modem.getDevFwVersion()
+ self.reply_cmd('00',"pyVer:{}@modemVer:{}".format(PROJECT_VERSION,modem_ver))
+ elif cmd == "01":
+ # UDP_CMD_DIAL_NUMB
+ if eventMesh.publish("get_volte_switch") == 1: #只有BLE开了VOLTE才允许打电话
+ ret = voiceCall.callStart(str(parm))
+ print("ret={} {} {}".format(ret,cmd,parm))
+ elif cmd == "02":
+ print(cmd)
+ # UDP_CMD_HUNGUP
+ voiceCall.callEnd()
+ elif cmd == "03":
+ print(cmd)
+ # UDP_CMD_ANSWER
+ voiceCall.callAnswer()
+ elif cmd == "04":
+ print(cmd)
+ result = check_fota()
+ if result == "":
+ self.reply_cmd('04',"no need update!")
+ else:
+ self.reply_cmd('04',"start ota {} please wait...".format(result))
+ download_fota_img(result)
+ elif cmd == "05":
+ print(cmd)
+ # UDP_CMD_SEND_SMS
+ elif cmd == "06":
+ print(cmd)
+ # UDP_CMD_GET_TIME
+ time=utime.localtime()
+ zone=utime.getTimeZone()
+ #(2024, 3, 2, 18, 31, 32, 5, 62),8
+ # 返回当前时间戳，参数为元组
+ # timestamp = utime.mktime(time)
+ # cat1service_log.info(timestamp)
+ self.reply_cmd('06',"{0}@{1}".format(time,zone))
+ elif cmd == "07":
+ print("cmd ==== 07!")
+ # UDP_CMD_GET_RECV_NETWORKSTAT
+ simstat = sim.getStatus()
+ imei = modem.getDevImei()
+ netstat = "0,10,0,10"
+ netstat_ = net.getState()
+ if netstat_ != -1 :
+ netstat = "{},{},{},{}".format(netstat_[0][0],netstat_[0][3],netstat_[1][0],netstat_[1][3])
+ # ([voice_state, voice_lac, voice_cid, voice_rat, voice_reject_cause, voice_psc], [data_state, data_lac, data_cid, data_rat, data_reject_cause, data_psc])
+ operator = net.operatorName()
+ signal = net.csqQueryPoll()
+ print("imei:{0},sim:{1},oper:{2},signal:{3},net:{4}".format(imei,simstat,operator,signal,netstat))
+ self.reply_cmd('07',"imei:{0}@sim:{1}@oper:{2}@signal:{3}@net:{4}".format(imei,simstat,operator,signal,netstat))
+ elif cmd == "09":
+ print("{},{}".format(cmd,parm))
+ # UDP_CMD_ATCMD
+ # net.setModemFun(0)
+ # net.setModemFun(1)
+ resp=bytearray(50)
+ ret=atcmd.sendSync("{}\r\n".format(parm),resp,'',10)
+ if ret == 0:
+ print("reply:{},ret:{}".format(resp.decode(),ret))
+ self.reply_cmd('09',"{}".format(resp.decode()))
+ else:
+ print("cmd error ret:{}".format(ret))
+ self.reply_cmd('09',"{}".format("at error"))
+
+ elif cmd == "10" or cmd == "12" or cmd == "14": #获取固件版本号或者获取BT保存的SIM卡的ICCID BLE那边是否开启电信入库功能
+ if 1: #CHINA_TELECOM_DM_FUN_ENABLE == 1 :
+ if eventMesh.publish("get_dmp_change_mode") == 1:
+ self.telecom_recv_cmd(cmd,parm)
+ else:
+ pass
+
+ if 1:#CHINA_MOBILE_DM_FUN_ENABLE == 1:
+ if eventMesh.publish("get_dmp_change_mode") > 1:
+ self.china_mobile_recv_cmd(cmd,parm)
+ else:
+ pass
+ pass
+ elif cmd == "13":
+ on = int(parm)
+ print("set_dmp_change_mode on:{}".format(on))
+ eventMesh.publish("set_dmp_change_mode",on)
+
+ elif cmd == "16":
+ if 1: #CHINA_MOBILE_DM_FUN_ENABLE == 1:
+ if eventMesh.publish("get_dmp_change_mode") > 1:
+ self.china_mobile_recv_cmd(cmd,parm)
+ else:
+ pass
+ elif cmd == "17": #用于CAT1恢复出厂需要清空数据的标识通用
+ eventMesh.publish("set_factory_status",int(parm))
+ elif cmd == "18":
+ eventMesh.publish("set_dmp_cm_address",str(parm))
+ elif cmd == "19": #DTMF功能
+ voiceCall.startDtmf(str(parm),100) #100ms 持续时间 100-1000
+ elif cmd == "1A":
+ eventMesh.publish("set_volte_switch",int(parm))
+
+ def telecom_recv_cmd(self,cmd,parm):
+ if cmd == "10":
+ self.software_version = str(parm)
+ eventMesh.publish("set_dev_version",self.software_version)
+ print("software_version:{},{}".format(self.software_version,parm))
+ elif cmd == "12":
+ pass
+ elif cmd == "14":#
+ pass
+
+ pass
+
+ def set_volte_switch(self,event,msg): #设置VOLTE开关
+ self.volte_switch = int(msg)
+
+
+ def get_volte_switch(self,event,msg): #获取VOLTE开关
+
+ return self.volte_switch
+
+
+ def china_mobile_recv_cmd(self,cmd,parm): #移动入库相关指令
+ if cmd == "10":
+ self.software_version = str(parm)
+ eventMesh.publish("set_dev_version",self.software_version)
+ print("software_version:{},{}".format(self.software_version,parm))
+ elif cmd == "16": #获取BLE mac地址
+ eventMesh.publish("set_dev_mac",str(parm))
+ print("parm:{}\r\n".format(parm))
+
+ pass
+ def get_factory_status(self,event,msg):
+ return self.factory_status
+ def set_factory_status(self,event,msg):
+ self.factory_status = int(msg)
+ if self.factory_status == 0: #只有为的时候才设置进去 1不再设置
+ self.reply_cmd('17',"{}".format(1))
+
+ def send_dmp_cm_address_toBLE(self,event,msg):
+ buf_tmp = "address:"+str(msg)
+ self.reply_cmd('18',"{}".format(buf_tmp))
+
+ def set_dmp_change_mode(self,event,msg):
+ self.telecom_dmp_switch = msg
+ def delete_sms_single_data(self,event,msg): #删除单条信息
+ sms.deleteMsg(int(msg))
+
+ def get_dmp_change_mode(self,event,msg):
+ return self.telecom_dmp_switch
+ def delete_sms_event(self,event,msg):
+ self.deletSmsTimer.start(2*1000,0,self.delete_sms_cb)
+ def delete_sms_cb(self,*argc):
+ eventMesh.publish_async("remove_all_sms_cb","",1*1024)
+ def remove_all_sms_cb(self, event, msg):
+ print("remove_all_sms_cb\r\n")
+ msg_nums = sms.getMsgNums() #短信数量
+ if msg_nums == -1:
+ msg_nums = 0
+ sms_data = sms.getSaveLoc()
+ print("{}\r\n".format(sms_data))
+ if sms_data == -1:
+ return
+ sms_max = sms_data[0][2] #最大存储短信数量
+ if sms_max >= msg_nums and sms_max > 0:
+ sms.deleteMsg(1,4) #删除所有的sms信息
+
+ def send_singal_data_toBle(self,event,msg):
+ msg_nums = sms.getMsgNums() #短信数量
+ if msg_nums == -1:
+ msg_nums = 0
+ sms_data = sms.getSaveLoc()
+ if sms_data == -1:
+ return
+ sms_max = sms_data[0][2] #最大存储短信数量
+ print("recv:{}".format(int(msg)))
+ message=self.sms_get_message_info(int(msg))
+ if message == -1: #说明没有这条短信
+ return
+ message_pdu = sms.decodePdu(message[5],20)
+
+ if message_pdu != -1: #解码出来的内容
+
+ message_ref = message[0] #编码
+ message_total_num = message[1] #总共条数
+ message_seq = message[2] #当前第几条
+ data = message[5] #内容
+ data_len = len(data) #内容长度
+ # ref ：短信参考标识，同一个标识表明为同一条短信
+ # total_num ：此条长短信总条数 大于1属于长短信
+ # seq ：此条短信在长短信中的序号
+ # print("message:{} {}\r\n".format(message,message_pdu))
+ msg_total = "ref:"+str(message_ref)+"@total_num:"+str(message_total_num)+"@seq:"+str(message_seq)+"@data:"+str(message[5])
+ self.reply_cmd('15',msg_total)
+
+ eventMesh.publish("delete_sms_single_data",int(msg))
+
+ def sms_deal_phone_number(self,args):
+ data=enumerate(args)
+ data_str1=""
+ data_str2=""
+ data_str3=""
+ for index,value in data:
+ if index % 2 == 0:
+ data_str1=data_str1+value
+ else:
+ data_str2=data_str2+value
+ for i in range(0,len(data_str1)):
+ data_str3=data_str3+data_str2[i]
+ data_str3=data_str3+data_str1[i]
+ return data_str3
+ def sms_get_message_info(self,index):
+ """
+ ：param index ：短信索引值
+ ：tyoe index ：整形
+
+ ：return ：元组类型
+ 元组内容：
+ （message_ref，message_total_num，message_seq，sub_message_data，pdu_tye，sub_message_len）
+
+ ：message_ref ：短信参考标识，同一个标识表明为同一条短信
+ ：message_total_num ：此条长短信总条数
+ ：message_seq ：此条短信在长短信中的序号
+ ：sub_message_data ：词条短信的内容
+ ：pdu_tye ：PDU类型，bit 6标记是否包含用户报文头，长短信需要
+ ：sub_message_len ：此条短信内容长度
+
+ """
+
+ message0=sms.searchPduMsg(index)
+ #print("sms_get_message_info:message0:{}".format(message0))
+ if message0 == -1:
+ return -1
+
+ sca_num = int(message0[0:2],16) - 1
+ data_len = 2
+ addr_type= message0[data_len:data_len+1*2]
+ data_len = data_len+1*2
+
+ sca = message0[data_len:data_len+sca_num*2]
+ # 电话号码高低位需要转换
+ sca = self.sms_deal_phone_number(sca)
+
+ # if sca_num % 2 == 1:
+ # print("Get SCA phone {}".format(sca[:-1]))
+ # else:
+ # print("Get SCA phone {}".format(sca))
+
+ data_len = data_len+sca_num*2
+
+ pdu_tye = int(message0[data_len:data_len+1*2],16)
+ data_len = data_len+1*2
+
+ oa_num = int(message0[data_len:data_len+1*2],16)
+ data_len = data_len+1*2
+ oa_addr_type = message0[data_len:data_len+1*2]
+ data_len = data_len+1*2
+
+ if oa_num % 2 == 1:
+ oa_num_t = int((oa_num + 1)/2)
+ else:
+ oa_num_t = int((oa_num )/2)
+
+ oa = message0[data_len:data_len+oa_num_t*2]
+ # 电话号码高低位需要转换
+ oa = self.sms_deal_phone_number(oa)
+
+ # if oa_num % 2 == 1:
+ # print("Get OA phone {}".format(oa[:-1]))
+ # else:
+ # print("get OA phone {}".format(oa))
+
+ data_len = data_len+oa_num_t*2
+ pid = message0[data_len:data_len+1*2]
+
+ data_len = data_len+1*2
+ dcs = message0[data_len:data_len+1*2]
+ data_len = data_len+1*2
+ scts = message0[data_len:data_len+7*2]
+ data_len = data_len+7*2
+ sub_message_len = int(message0[data_len:data_len+1*2],16)
+ data_len = data_len+1*2
+ sub_message_head = message0[data_len:data_len+6*2]
+ data_len = data_len+6*2
+
+ # 或短信用户数据
+ sub_message_data = message0[data_len:data_len+sub_message_len*2]
+
+ #长短信
+ if ((pdu_tye & 0x40 ) >> 6) == 1:
+ #长短信,处理长短信用户报文头
+ message_ref = int(sub_message_head[6:8],16)
+ message_total_num = int(sub_message_head[8:10],16)
+ message_seq = int(sub_message_head[10:12],16)
+ return [message_ref,message_total_num,message_seq,pdu_tye,sub_message_len,message0]
+ else:
+ # 短短信
+ return [0,1,1,pdu_tye,sub_message_len,message0]
+
+
+
+ def send_sms_max_to_Ble(self,event,msg):
+ msg_nums = sms.getMsgNums()#短信数量
+ if msg_nums == -1:
+ msg_nums = 0
+ sms_data = sms.getSaveLoc()
+ if sms_data != -1:
+ sms_max = sms_data[0][2]#最大存储短信数量
+ self.reply_cmd('15',"@sms_max:"+str(sms_max)+"@current_num:"+str(msg_nums))
+ pass
+
+ def get_all_sms_data(self,event,msg):
+ msg_total = ""
+ SMS_lis={}
+ SMS_lis_count = 0
+ sms_data = sms.getSaveLoc()
+ print(sms_data)
+ if sms_data == -1:
+ return
+ sms_max = sms_data[0][2]#最大存储短信数量
+ print(sms_max)
+ self.msg_nums = sms.getMsgNums()
+ if self.msg_nums_old != self.msg_nums:
+ self.send_data = []
+ self.msg_nums_old = self.msg_nums
+ if self.send_data == [] :
+ for i in range(self.msg_nums):
+ phonenum = ""
+ data =""
+ time = ""
+ data_len = 0
+ message=self.sms_get_message_info(self.msg_nums-i-1)
+ if message == -1:
+ break
+ data = message[5]
+ sms_data = []
+ code = message[0]#编码
+ num = message[1]#总共条数
+ curren_num = message[2]#当前第几条
+ data_len = message[4]
+ sms_data.append(code)#编码 编码相同是同一条短信的内容
+ sms_data.append(num)
+ sms_data.append(curren_num)
+ sms_data.append(data)
+ sms_data.append(data_len)
+ self.send_data.append(sms_data)
+ count = len(self.send_data)
+ for i in range(count):
+ text = self.send_data[i]
+ print("text:{} {} {}\r\n".format(text[0],text[1],text[2]))
+
+ msg_total = "@code:"+str(text[0])+"@totalcodenum:"+str(text[1])+"@currcodeid:"+str(text[2])+"@data:"+str(text[3])
+ self.reply_cmd('17',msg_total)
+
+ # 来电提醒
+ def notifyIncomingcall(self, incomming_numb):
+ self.clear_remain()
+ __head = '0C'
+ self.__message = str(incomming_numb)
+ self.__Socket_UDP(__head, self.__message)
+ # if self.__err == 1 or self.__value[2] != 'OK':
+ # return -1
+ return 0
+
+ # 电话接听消息
+ def notifyConnecteCall(self, phone_numb):
+ self.clear_remain()
+ __head = '0A'
+ self.__message = str(phone_numb)
+ self.__Socket_UDP(__head, self.__message)
+ # if self.__err == 1 or self.__value[2] != 'OK':
+ # return -1
+ return 0
+
+ # 电话拒接消息
+ def notifyDisconnectCall(self, phone_numb):
+ self.clear_remain()
+ __head = '0B'
+ self.__message = str(phone_numb)
+ self.__Socket_UDP(__head, self.__message)
+ # if self.__err == 1 or self.__value[2] != 'OK':
+ # return -1
+ return 0
+
+ def wait_network_ready(self):
+ if(self.__waiting_netstat == 1):
+ return 0
+ self.__waiting_netstat = 1
+ stage, state = checkNet.waitNetworkReady(30)
+ # pm.wakelock_unlock(lpm_fd)
+ if stage == 3 and state == 1:
+ print('Network connection successful.')
+ self.set_network_config()
+ self.__net_connected = 1
+ eventMesh.publish("set_network_state",self.__net_connected)
+ self.__waiting_netstat = 0
+ return 0
+ else:
+ print('Network connection failed, stage={}, state={}'.format(stage, state))
+ self.reset_network_config()
+ self.__net_connected = 0
+ eventMesh.publish("set_network_state",self.__net_connected)
+
+ self.__waiting_netstat = 0
+ return -1
+
+ # 查询网卡状态
+ def timesync(self,_timesync):
+ self.clear_remain()
+ self.__message = str(_timesync)
+ self.__Socket_UDP('0D', self.__message)
+ return 0
+
+ def reply_timesync(self,_timesync):
+ self.clear_remain()
+ self.__message = str(_timesync)
+ self.__Socket_UDP_noreply('0D', self.__message)
+ return 0
+
+ def reply_cmd(self,cmd,_timesync):
+ self.clear_remain()
+ self.__message = str(_timesync)
+ self.__Socket_UDP_noreply(cmd, self.__message)
+ return 0
+
+ def clear_remain(self):
+ # if self.__queue.empty() == False:
+ # self.__queue.get()
+ self.__err = 0
+ # self.__value = None
+ #添加路由信息
+ def router_add(self, ip='192.168.4.1', mask='255.255.255.0'):
+ self.ip = ip
+ self.mask = mask
+
+ return slip.router_add(self.ip, self.mask)
+
+ # 获取slip的网络配置
+ def ipconfig(self):
+ return slip.ipconfig()
+
+ # 设置dns服务器
+ def set_dns(self, pri_dns='8.8.8.8', sec_dns='114.114.114.114'):
+ self.pri_dns = pri_dns
+ self.sec_dns = sec_dns
+ return slip.set_dns(self.pri_dns,self.sec_dns)
+
+ # 设置默认网卡
+ def set_default_NIC(self, ip_str):
+ self.ip_str = ip_str
+ return slip.set_default_netif(self.ip_str)
+
+ def reset_network_config(self):
+ if (self.__net_connected == 0):
+ print("skip reset_network_config")
+ return 0
+ Info = dataCall.getInfo(1,0)
+ print("Info{}".format(Info))
+ default_NIC_ip = Info[2][2] # 假设默认网卡ip地址为10.10.1.1，请根据实际情况更改
+ segment_ip = '172.16.4.0' # 假设ap模式网段范围是[192.168.4.0 ~ 192.168.4.255]，请根据实际情况更改
+ mask = '255.255.255.0' # 假设子网掩码为255.255.255.0，请根据实际情况更改
+ # 配置默认网卡，通过默认网卡进行网络转发
+ cat1service.set_default_NIC(default_NIC_ip)
+ print("default_NIC_ip {0} segment_ip {1}".format(default_NIC_ip,segment_ip))
+ #添加路由规则，只有该网段IP才进行转发
+ cat1service.router_add(segment_ip, mask)
+
+ pri_dns = '8.8.8.8' # 假设DNS首选地址为8.8.8.8，请根据实际情况更改
+ sec_dns = '114.114.114.114' # 假设DNS备选地址为114.114.114.114，请根据实际情况更改
+ # 配置网卡DNS服务器
+ cat1service.set_dns(pri_dns, sec_dns)
+ # 网卡IP信息查询
+ cat1service.ipconfig()
+
+ def set_network_config(self):
+
+
+ if (self.__net_connected == 1) :
+ print("skip set_network_config")
+ return 0
+ Info = dataCall.getInfo(1,0)
+ print("Info{}".format(Info))
+ default_NIC_ip = Info[2][2] # 假设默认网卡ip地址为10.10.1.1，请根据实际情况更改
+ segment_ip = '172.16.1.0' # 假设ap模式网段范围是[192.168.4.0 ~ 192.168.4.255]，请根据实际情况更改
+ mask = '255.255.255.0' # 假设子网掩码为255.255.255.0，请根据实际情况更改
+ # 配置默认网卡，通过默认网卡进行网络转发
+ cat1service.set_default_NIC(default_NIC_ip)
+ print("default_NIC_ip {0} segment_ip {1}".format(default_NIC_ip,segment_ip))
+ #添加路由规则，只有该网段IP才进行转发
+ cat1service.router_add(segment_ip, mask)
+
+ pri_dns = '8.8.8.8' # 假设DNS首选地址为8.8.8.8，请根据实际情况更改
+ sec_dns = '114.114.114.114' # 假设DNS备选地址为114.114.114.114，请根据实际情况更改
+ # 配置网卡DNS服务器
+ cat1service.set_dns(pri_dns, sec_dns)
+ # 网卡IP信息查询
+ cat1service.ipconfig()
+ if eventMesh.publish("get_dmp_change_mode") == 0:#入库功能关闭
+ return
+ if 1: #CHINA_TELECOM_DM_FUN_ENABLE == 1:#电信入库功能 不使用设置 0 防止两边不同步修改
+ if eventMesh.publish("get_dmp_change_mode") == 1:
+ eventMesh.publish("set_network_state",1)
+ telecomDmpCb.telecom_dmp_power_on_init()
+ if 1: #CHINA_MOBILE_DM_FUN_ENABLE == 1:
+ if eventMesh.publish("get_dmp_change_mode") > 1:
+ eventMesh.publish("set_network_state",1)
+ if self.china_mobile_init == 1:
+ return
+ self.china_mobile_init = 1
+ chinamobileCb.china_mobile_init()
+
+ def cat1_reply_iccid_to_ble(self,event,msg):
+ ICCID_DATA = str("ICCID:")+str(msg)
+ self.reply_cmd('11',"{}".format(ICCID_DATA))
+ pass
+ def cat1_reply_timesec_to_ble(self,event,msg):
+
+ self.reply_cmd('14',"REGIST_TIME:{}".format(msg))
+ pass
+ # 释放slip网卡
+ def stop(self):
+ slip.destroy()
+ return 0
+
+
+ # 封装tlv数据包
+ def __pack_tlv_format(self, head, content):
+ self.head = head
+ self.content = content
+ if len(self.content) == 0 or len(self.content) > 9999 or len(self.head) != 2:
+ print('illegal pack tlv content')
+ return -1
+ len_str ='%04d' % len(self.content)
+ tlv_pack = CAT1_SERVICE_HEAD+self.head+len_str+self.content
+ return tlv_pack
+ # 解码tlv数据包
+ def __unpack_tlv_format(self, msg):
+ print('__unpack_tlv_format {}\r\n'.format(msg))
+ self.msg = str(msg)[2:]#这是去除head FE
+ tag = self.msg[0:2]
+ length = self.msg[2:6]
+ value = self.msg[6:]
+ len_str ='%04d' % len(value)
+ if len(value) == 0 or len(value) > 9999 or len(tag) != 2 or len_str != self.msg[2:6]:
+ print('__unpack_tlv_format err')
+ return -1
+ print('__unpack_tlv_format: {} {} {}\r\n'.format(tag,length,value))
+ unpack = (tag,length,value)
+ return unpack
+ # socket通信(UDP)模块
+ def __Socket_UDP(self, head, content):
+ try:
+ self.head = head
+ self.content = content
+ gpioWakeBT.write(1)
+ utime.sleep_ms(2)
+ gpioWakeBT.write(0)
+ utime.sleep_ms(20)
+ # 消息处理
+ msg = self.__pack_tlv_format(self.head, self.content)
+
+ # 向服务端发送消息
+ server_addr = ('172.16.1.5',1000)
+ print("__Socket_UDP send msg {}".format(msg))
+ self.__err = 0
+ self.__sock.sendto(msg,server_addr)
+ self.__wait_resp = 1
+ # data = self.__queue.get()
+ self.__wait_resp = 0
+ # return data
+ return 1
+ except Exception as error:
+ print(error)
+ return 0
+
+ def __Socket_UDP_noreply(self, head, content):
+ self.head = head
+ self.content = content
+ gpioWakeBT.write(1)
+ utime.sleep_ms(2)
+ gpioWakeBT.write(0)
+ utime.sleep_ms(20)
+ # 消息处理
+ msg = self.__pack_tlv_format(self.head, self.content)
+
+ # 向服务端发送消息
+ server_addr = ('172.16.1.5',1000)
+
+ print("__Socket_UDP_noreply send msg {}".format(msg))
+ self.__err = 0
+ data_size = self.__sock.sendto(msg,server_addr)
+ print("self.__sock data_size {}".format(data_size))
+ self.__wait_resp = 0
+ return 0
+
+ # socket通信(UDP)模块
+ def __Socket_Thread(self):
+ while True:
+ try:
+ print("recv====")
+ data=self.__sock.recv(1024)
+ print("data:{}".format(data))
+ if data:
+ value = self.__unpack_tlv_format(data.decode())
+ if value != -1:
+ print('mode: {0}, recv {1} bytes, Data: {2}'.format (value[0],len(data), value[2]))
+ if value[1] == 'FF':
+ self.btmcu_cmd_handler(value[0],value[2])
+ else:
+ # self.__value = value
+ # self.__queue.put('1')
+ self.btmcu_cmd_handler(value[0],value[2])
+ print("End else Thread")
+ else:
+ print("data error!!")
+ except Exception as recverr:
+ print("recverr:{}\r\n".format(recverr))
+ if "110" in str(recverr):
+ self.__err = 1
+ # if self.__wait_resp == 1:
+ # self.__queue.put('0')
+ else:
+ utime.sleep(1)
+ self.__sock = self.__socket_reinit()
+
+
+
+ print("End Socket Thread")
+
+
+
+
+# UDP_CMD_GET_CAT1VER = '0', // 获取 Cat1 版本号
+# UDP_CMD_DIAL_NUMB = '1', // 拨打电话
+# UDP_CMD_HUNGUP = '2', // 挂断电话
+# UDP_CMD_ANSWER = '3', // 接听电话
+# UDP_CMD_CAT1_OTA_UPDATE = '4', // 触发Cat1 OTA升级，mcu提供url
+# UDP_CMD_SEND_SMS = '5', // 发送SMS短信，mcu提供电话号及短信内容
+# UDP_CMD_GET_TIME = '6', // 获取Cat1 时间 ，YYYYMMDD HHmmss zone
+# UDP_CMD_GET_NETWORKSTAT = '7', //获取Cat1 信号信息，VOLTE信息，信号强度，SIM卡状态
+# 下文进行系统配置
+print("Cat1Service start")
+
+cat1service = Cat1Service()
+
+
+
+#voice call callback function
+def voice_callback(args):
+ if args[0] == 10:
+ print('voicecall incoming call, PhoneNO: ', args[6])
+ if eventMesh.publish("get_volte_switch") == 0: #关闭VOLTE功能
+ print('voicecall auto end:')
+ voiceCall.callEnd()
+ else:
+ # gpioWakeBT.write(1)
+ cat1service.notifyIncomingcall(args[6])
+ elif args[0] == 11:
+ if eventMesh.publish("get_volte_switch") == 1: #开启VOLTE功能
+ print('voicecall connected, PhoneNO: ', args[6])
+ cat1service.notifyConnecteCall(args[6])
+ elif args[0] == 12:
+ print('voicecall disconnect')
+ if eventMesh.publish("get_volte_switch") == 1: #开启VOLTE功能
+ print('voicecall disconnected, PhoneNO: ', args[6])
+ cat1service.notifyDisconnectCall(args[6])
+ elif args[0] == 13:
+ print('voicecall is waiting, PhoneNO: ', args[6])
+ elif args[0] == 14:
+ print('voicecall dialing, PhoneNO: ', args[6])
+ elif args[0] == 15:
+ print('voicecall alerting, PhoneNO: ', args[6])
+ elif args[0] == 16:
+ print('voicecall holding, PhoneNO: ', args[6])
+
+#电话消息反馈
+voiceCall.setCallback(voice_callback)
+
+
+def checknet_cb(arg):
+ print("start checktime!!")
+ if 1: #CHINA_TELECOM_DM_FUN_ENABLE == 1:#这是手表每30s检查一次
+ if eventMesh.publish("get_dmp_change_mode") == 1:
+ telecomDmpCb.telecom_dmp_power_on_count()
+
+ _thread.start_new_thread(cat1service.wait_network_ready, ())
+ # time=utime.localtime()
+ # zone=utime.getTimeZone()
+ #(2024, 3, 2, 18, 31, 32, 5, 62),8
+ # cat1service.timesync("{0},{1}".format(time,zone))
+# _thread.start_new_thread(cat1service.wait_network_ready, ())
+timer = osTimer()
+# checknet_cb(())
+timer.start(30000,1,checknet_cb)
+
+def bootupmsg_cb(arg):
+ cat1service.bootup_msg_to_bt()
+
+
+delaybootupmsg_timer = osTimer()
+delaybootupmsg_timer.start(1000,0,bootupmsg_cb)
+
+# def checkpin_cb(arg):
+# cat1service_log.info("recvDataPin={}".format(recvDataPin.read()))
+
+# timerCheckRevPin = osTimer()
+# timerCheckRevPin.start(1000,1,checkpin_cb)
+
+
+# while True:
+# utime.sleep(5)
+
+
+# uping.ping("172.16.1.5")
+ # 获取网卡当前工作状态
+
+# gpioWakeBT.write(1)
+# utime.sleep(1)
+
+# timesync = net.nitzTime()
+# cat1service.timesync(timesync)
+
+
+#url = "http://zzhc.vnet.cn:9998/"
+
+
--- /dev/null
+import app_fota
+from misc import Power
+import modem
+import ujson
+import request
+import ql_fs
+import checkNet
+import sys
+
+#远程升级
+
+import fota
+import utime
+import log
+import uos
+
+PROJECT_VERSION="PY_OTA_V13"
+CONFIG_JSON="/usr/system_config.json"
+CURRENT_APP_TYPE="pyota"
+# 设置日志输出级别
+log.basicConfig(level=log.INFO)
+fota_log = log.getLogger("Fota")
+
+
+def get_versionkeyname_by_py(app_type):
+ return str("{}version".format(app_type))
+
+def get_default_versionvalue_by_py(app_type):
+ if (app_type == "pyota"):
+ return "PY_OTA_V13"
+
+
+#如果没有configfile则创建它
+if not ql_fs.path_exists(CONFIG_JSON):
+ data = {str(get_versionkeyname_by_py(CURRENT_APP_TYPE)):get_default_versionvalue_by_py(CURRENT_APP_TYPE)}
+ try:
+ ql_fs.touch(CONFIG_JSON,data)
+ except Exception as e:
+ print("checkota 创建出错 {}".format(e))
+
+def set_version_to_json_config(app_type,keyvalue):
+ try:
+ config_data = ql_fs.read_json(CONFIG_JSON)
+ config_data.update( {str(get_versionkeyname_by_py(app_type)):keyvalue})
+
+ ql_fs.touch(CONFIG_JSON, config_data)
+ print("{}={}".format(get_versionkeyname_by_py(app_type),keyvalue))
+ print("{}".format(config_data))
+ except Exception as e:
+ print("checkota 创建出错 {}".format(e))
+
+def get_version_from_json_config(app_type):
+ try:
+ config_data = ql_fs.read_json(CONFIG_JSON)
+ keyvalue = config_data.get( get_versionkeyname_by_py(app_type),get_default_versionvalue_by_py(app_type))
+ print("{}={}".format(get_versionkeyname_by_py(app_type),keyvalue))
+ return keyvalue
+ except Exception as e:
+ print("get_version_from_json_config出错 {}".format(e))
+ return ""
+
+def result(args):
+ print('download status:',args[0],'download process:',args[1])
+
+def check_fota():
+ modem_ver = modem.getDevFwVersion()
+ imei = modem.getDevImei()
+ url = "http://icfota.snicker.com.cn:8089/fd230ota.jsp?product=FD230&pkgver={0}&imei={1}".format(modem_ver,imei)
+ response = request.get(url)
+ print(url)
+ data = response.json()
+ if(data['UptoDate'] == False):
+ print("Need update python application")
+ fota_obj = fota() # 创建Fota对象
+ print("httpDownload...")
+ srcurl = data['url']
+ #差分升级方式
+ # res = fota_obj.httpDownload(url1="http://www.example.com/fota.bin",callback=result)
+ # mini fota方式
+ print("{},{}".format("{}/dfota_1.bin".format(srcurl),"{}/dfota_2.bin".format(srcurl)))
+ res = fota_obj.httpDownload(url1="{}/dfota_1.bin".format(srcurl),url2="{}/dfota_2.bin".format(srcurl),callback=result)
+ #差分升级FTP方式
+ #res = fota_obj.httpDownload(url1="ftp://user:password@ip:port/fota.bin",callback=result) #其中user,password,ip,port需要填写具体使用的FTP服务器信息
+ if res != 0:
+ print("httpDownload error")
+ return
+ print("wait httpDownload update...")
+ else:
+ print("No need update python application")
+
+def do_app_update_internal(app_type):
+ fota = app_fota.new()
+ imei = modem.getDevImei()
+ pythonversion=get_version_from_json_config(app_type)
+ url = "http://icfota.snicker.com.cn:8089/fd230ota.jsp?product=FD230&pkgver={0}&imei={1}".format(pythonversion,imei)
+ try:
+ response = request.get(url)
+ print(url)
+ data = response.json()
+ if data['UptoDate'] == False:
+ print("Need update python application {}".format(data["appcount"]))
+ for app_update in data["apps"]:
+ srcurl = app_update['url']
+ print("run start...")
+ targetpyname = app_update['OtaPackageName']
+ version = app_update['OtaPackageVersion']
+ tmpfile_path = "/usr/.updater/{}".format(targetpyname)
+ targetfile_path = "/usr/{}".format(targetpyname)
+ print("download {0} to {1}".format(srcurl,targetfile_path))
+ if ql_fs.path_exists(tmpfile_path):
+ try:
+ uos.remove(tmpfile_path)
+ except Exception as e:
+ print("update remove出错 {}".format(e))
+ ret = fota.download(srcurl,targetpyname)
+ if ret == 0 :
+ try:
+ ql_fs.file_copy(targetfile_path, tmpfile_path)
+ set_version_to_json_config(app_type,version)
+ print("ota success")
+ if ql_fs.path_exists(tmpfile_path):
+ try:
+ uos.remove(tmpfile_path)
+ except Exception as e:
+ print("update remove出错 {}".format(e))
+ except Exception as e:
+ print("ota failed!")
+ else:
+ print("ota failed")
+ # 升级后重启
+ Power.powerRestart()
+ else:
+ print("No need update python application")
+ except Exception as e:
+ print("nonetwork:{}".format(e))
+
+if __name__ == '__main__':
+ print("check ota start!!!!!!!!!!")
+ set_version_to_json_config(CURRENT_APP_TYPE,PROJECT_VERSION)
+ stage, state = checkNet.waitNetworkReady(1)
+ if stage == 3 and state == 1:
+ print('Network connection successful.')
+ do_app_update_internal("pyota")
+ # check_fota()
+ else:
+ print('Network connection failed, stage={}, state={}'.format(stage, state))
+
+# res = uos.statvfs("/usr")
+# res = list(res)
+# print('总ext空间:{} MB，剩余空间:{} MB'.format((((res[0] * res[2]) / 1024 / 1024)),((res[0] * res[3]) / 1024 / 1024)))
\ No newline at end of file
--- /dev/null
+import app_fota
+from misc import Power
+import modem
+import ujson
+import request
+import ql_fs
+import checkNet
+import sys
+import sim
+
+from queue import Queue
+import usys
+import _thread
+import fota
+import utime
+import log
+import uos
+import osTimer
+import net
+import ql_fs
+from ucryptolib import aes
+import hashlib
+from usr.EventMesh import eventMesh
+# 设置日志输出级别
+log.basicConfig(level=log.INFO)
+fota_log = log.getLogger("china_mobile")
+import modem
+import base64
+import request
+import ujson
+BLOCK_SIZE = 16
+NEED_SAVE_CONFIG_FILE = 0 #是否需要保存上报次数 异常重试次数 时间戳到配置文件 0不保存 1保存
+#中国移动入库
+class chinamobile:
+ def __init__(self):
+ self.multiDayResend_timer = osTimer()#12小时定时器 多日重发的机制
+
+ self.multimer_count = 0#多日重发机制周期Count
+ self.multimer_init = 0
+ self.power_on_multiflag = 0
+ self.timer_count = 0
+ self.timerPowerNum = 0
+ self.telecom_init_state = 0#初始化状态开机检查标识
+ self.isRegistOk = 0#注册成功
+ self.config_data = {}
+
+ self.__net_connected = 0
+ self.regist_timeSec = 0
+ self.iccid_data = ""
+ self.software_version = ""
+ self.mac_data =""
+ self.address = "a.fxltsbl.com"
+
+ self.new_address = "a.fxltsbl.com"
+
+ self.retryInterval = 10
+ self.retryNum = 1#异常重试最大次数
+ self.heartBeatTime = 1440#心跳上报频率 单位分钟
+ self.reportTime = 1440#最大上报频率 自注册+心跳上报的频率次数不能大于最大上报频率次数
+ self.reportNum = 8 #最大上报次数
+
+
+ self.reportTime_Sec = 0 #保存本地 保存时间戳下一次开机使用
+ self.report_Num_old = 0#保存本地
+ self.retryNum_old = 0#保存本地
+ self.init_flag = 0#初始化状态指初始化一次
+ self.retryTimer = osTimer()#异常重试定时器
+ self.retpoertTimerC = osTimer()#上报次数大于下一个周期再触发
+ self.heartreportTimer = osTimer()#心跳上报定时器
+
+ eventMesh.subscribe("get_network_state",self.get_network_state)#订阅消息
+ eventMesh.subscribe("set_network_state",self.set_network_state)#订阅消息
+
+ eventMesh.subscribe("set_dev_version",self.set_dev_version)#订阅消息
+ eventMesh.subscribe("get_dev_version",self.get_dev_version)#订阅消息
+
+ eventMesh.subscribe("set_dev_mac",self.set_dev_mac)#订阅消息
+ eventMesh.subscribe("get_dev_mac",self.get_dev_mac)#订阅消息
+
+ eventMesh.subscribe("set_dmp_cm_address",self.set_dmp_cm_address)#订阅消息
+ eventMesh.subscribe("get_dmp_cm_address",self.get_dmp_cm_address)#订阅消息
+
+ pass
+
+ def set_dmp_cm_address(self,event,msg):#设置网络是否正常
+ self.address = str(msg)
+ self.new_address = str(msg)
+
+ def get_dmp_cm_address(self,event,msg):#获取网络是否正常
+ return self.address
+
+ def set_network_state(self,event,msg):#设置网络是否正常
+ self.__net_connected = int(msg)
+
+ def get_network_state(self,event,msg):#获取网络是否正常
+ return self.__net_connected
+
+ def set_dev_version(self,event,msg):#获取固件版本号
+ self.software_version = str(msg)
+
+ def get_dev_version(self,event,msg):#获取固件版本号
+ return self.software_version
+
+ def set_dev_mac(self,event,msg):#设置BLE MAC地址
+ self.mac_data = str(msg)
+
+ def get_dev_mac(self,event,msg):#获取BLE MAC地址
+ return self.mac_data
+
+ def sha256_encode(self,key,data):#对数据进行AES256加密
+ h = hashlib.sha256()
+ h.update(key)
+ crypto_key = h.digest()
+ #IV是偏移量 默认16个十六进制00
+ IV = b"\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00"
+
+ crypto = aes(crypto_key, 2, IV)
+
+ #进行PKCS7Padding填充。
+ block_num = len(data) // BLOCK_SIZE+1
+ k = len(data) % BLOCK_SIZE
+ j = len(data) // BLOCK_SIZE
+ padding = BLOCK_SIZE - k
+ i = 0
+ szDataIn = bytearray(data)
+ # print(szDataIn)
+ szDataIn = szDataIn+bytearray(block_num * BLOCK_SIZE -len(data))
+ # print(szDataIn)
+
+ for i in range(padding):
+ szDataIn[j * BLOCK_SIZE + k + i] = padding
+ # print("szDataIn:{} {} {}\r\n".format(szDataIn,j * BLOCK_SIZE + k + i,padding))
+
+ indata = bytes(szDataIn)
+ enc = crypto.encrypt(indata)
+ #最后将加密AES256的数据转换成base64的编码格式
+ msg_tmp = base64.b64encode(enc)
+ data_encode = msg_tmp.decode('ascii')#转换成字符串
+ return data_encode
+
+ #写文件信息
+ def write_config_msg_file(self,msg):
+
+ print("write_config_msg_file msg:{}\r\n".format(msg))
+ with open("/usr/china_mobie_config.json",'w+',encoding="utf-8") as fd:
+ ujson.dump(msg,fd)
+ #读文件信息
+ def read_config_msg_file(self):
+ IFEXIST = ql_fs.path_exists("/usr/china_mobie_config.json") #不存在
+ if IFEXIST == True:
+ with open("/usr/china_mobie_config.json","r",encoding='utf-8') as fd:
+ self.config_data = ujson.load(fd)
+ print("read_config_msg_file self.config_data:{}\r\n".format(self.config_data))
+
+ def china_mobile_first_get_config(self,url):
+ ##############第一步#######获取采集规则配置#######
+ brand = "KUMI"#品牌
+
+ model = "Watch Soar"#型号
+ appKey = "M100001131"#不需要就填***appKey 厂商标识
+ sdkVersion = "***"#非SDK传输
+ apiVersion = "4.0.1"#接口定义 固定4.0.1
+ apiType = "I"#非Android
+ templateId = "TY000014"#根据产品分类在平台查询
+ IMEI = modem.getDevImei()
+ imei1 = IMEI#IMEI1或者CMEI
+ imei2 = "***"
+ configType = "autoRegist"#自注册填autoRegist 心跳配置传输 keepAlive
+ preField1 = "***"#预留字段1
+ preField2 = "***"#预留字段2
+ preField3 = "***"#预留字段3
+
+
+
+ #配置拉取数据格式
+ config_data = {"endpoint":"{}||{}||{}||{}||{}||{}||{}||{}||{}||{}||{}||{}".format(brand,model,appKey,sdkVersion,apiVersion,apiType,templateId,imei1,imei2,preField1,preField2,preField3),"configType":"{}".format(configType)}
+
+ #配置拉取数据上报地址
+ url = "https://{}//dm-multi-accept/multi/getMultiTerminalConfig".format(self.address)
+ headers_T ={"Content-Type":"application/json"}
+ print("ujson.dumps(config_data):{}".format(ujson.dumps(config_data)))
+ request_result = 0
+ result_json = ""
+ try:
+ response = request.post(url, data=ujson.dumps(config_data),headers =headers_T)
+ request_result = 1
+ if response.status_code == 200:#服务器响应成功并返回数据
+ content = response.content
+ c = next(content)
+ result_json = ujson.loads(c)
+ print("response.json:{}".format(ujson.loads(c)))
+ except Exception as e:
+ print("response:{}".format(e))
+ request_result = 0
+
+
+ if request_result == 0: #请求出错了
+ return ""
+
+
+ return result_json
+
+
+ def first_get_config_json(self):#开机上电获取配置信息
+ getresult = 0
+ print("first_get_config_json false",self.__net_connected)
+ if self.__net_connected != 1:#网络不正常
+ return getresult
+ url = "https://{}//dm-multi-accept/multi/getMultiTerminalConfig".format(self.address)
+ result_json = self.china_mobile_first_get_config(url)
+ if result_json == "":
+ return 0
+ # {
+ # "reportTime":1440,
+ # "reportNum":8,
+ # "heartBeatTime":1440,
+ # "retryInterval":10,
+ # "retryNum":1
+ # }#默认采集规则配置
+ #默认参数
+
+ retryInterval = self.retryInterval
+ heartBeatTime = self.heartBeatTime
+ reportTime = self.reportTime
+ reportNum = self.reportNum
+ retryNum = self.retryNum
+ new_address = self.address
+ print("get_config_json old:{} {} {} {} {} {}\r\n".format(reportTime,heartBeatTime,reportNum,retryInterval,retryNum,new_address))
+ if "rspCode" in result_json:#返回结课code 0000成功 其他参考文档
+ rspCode = result_json["rspCode"]
+ rspCode_zh = result_json["rspMsg"]
+ if rspCode == "0000" or rspCode_zh == "成功":
+ getresult = 1
+ if "result" in result_json:
+ msg_data = result_json["result"] #采集规则配置信息
+ if "ruleConfig" in msg_data:#不存在就是空
+ msg_data = msg_data["ruleConfig"]
+ msg_data = ujson.loads(msg_data)#转换成json格式
+ if "reportTime" in msg_data:
+ self.reportTime = int(msg_data["reportTime"])
+ if "heartBeatTime" in msg_data:
+ self.heartBeatTime = int(msg_data["heartBeatTime"])
+ if "reportNum" in msg_data:
+ self.reportNum = int(msg_data["reportNum"])
+ if "retryInterval" in msg_data:
+ self.retryInterval = int(msg_data["retryInterval"])
+ if "retryNum" in msg_data:
+ self.retryNum = int(msg_data["retryNum"])
+ if "address" in msg_data:
+ self.address = str(msg_data["address"])
+ print("get_config_json new:{} {} {} {} {}\r\n".format(self.reportTime,self.heartBeatTime,self.reportNum,self.retryInterval,self.retryNum,self.address))
+
+ print("true")
+ else:
+ print("false")
+
+ if getresult == 1:#请求配置文件成功
+ if (self.retryInterval != retryInterval) or (self.retryNum != retryNum) or (self.heartBeatTime != heartBeatTime) or\
+ (self.reportTime != reportTime) or (self.reportNum != reportNum) or (self.address != new_address):
+ #重新走注册流程 清空报错次数 记录当前时间戳
+ print("new config not old config!!!\r\n")#拉取的配置文件和保存本地的不一致
+ self.config_data["reportTime"] = self.reportTime
+ self.config_data["heartBeatTime"] = self.heartBeatTime
+ self.config_data["reportNum"] = self.reportNum
+ self.config_data["retryNum"] = self.retryNum
+ self.config_data["retryInterval"] = self.retryInterval
+ # self.config_data["address"] = str(self.address)
+ if new_address != self.address : #服务器下发和本地不一致需要用服务器下发的最新的IP 并把这个IP发送到BLE保存
+ eventMesh.publish("send_dmp_cm_address_toBLE",str(self.address))
+
+ self.write_config_msg_file(self.config_data) #保存新的配置文件
+ return 2
+ return getresult #1 获取成功 0 获取失败
+
+
+ def china_mobile_autoregist_infor(self,url,configType_data):
+ #########################第二步############自注册上报###################
+ #设备自注册上报
+ dev_autoregist_result = 0 #默认是1成功 0是失败
+ if self.__net_connected != 1:#网络不正常
+ return dev_autoregist_result
+ #密钥
+ key = "f74c005251dc40c4b64a283827da3812"
+
+ brand = "{}".format("KUMI")#品牌
+
+ model = "Watch Soar"#型号
+ appKey = "M100001131"#不需要就填***appKey 厂商标识
+ sdkVersion = "***"#非SDK传输
+ apiVersion = "4.0.1"#接口定义 固定4.0.1
+ apiType = "I"#非Android
+ templateId = "TY000014"#根据产品分类在平台查询
+ IMEI = modem.getDevImei()
+ imei1 = IMEI#IMEI1或者CMEI
+ imei2 = "***"
+ configType = configType_data#自注册填autoRegist 心跳配置传输 keepAlive 暂时不用
+ preField1 = "***"#预留字段1
+ preField2 = "***"#预留字段2
+ preField3 = "***"#预留字段3
+
+ #不需要加密 #||分隔符不能超过11个 否则平台会解析出错
+ config_data = "{}||{}||{}||{}||{}||{}||{}||{}||{}||{}||{}||{}".format(brand,model,appKey,sdkVersion,apiVersion,apiType,templateId,imei1,imei2,configType,preField1,preField2)
+
+ #需要加密的数据明文
+ if (len(self.mac_data) == 0):#获取失败了
+ self.mac_data = "***"
+
+ MAC = self.mac_data
+ # base64_MAC = sha256_encode(key,MAC)
+ RAM = "32MB"
+ # base64_RAM = sha256_encode(key,RAM)
+ ROM = "144MB"
+ # base64_ROM = sha256_encode(key,ROM)
+ CPU = "YH601S"
+ # base64_CPU = sha256_encode(key,CPU)
+ sysVersion = "OpenHarmony 3.2"
+ # base64_sysVersion = sha256_encode(key,sysVersion)
+ if (len(self.software_version) == 0):#获取失败了
+ self.software_version = "Watch Soar V1.0"
+ softwareVer = self.software_version
+ # base64_softwareVer = sha256_encode(key,softwareVer)
+ softwareName ="FD230"
+ # base64_softwareName = sha256_encode(key,softwareName)
+ volte="0" #0:开;1:关;-1:不支持
+ # base64_volte = sha256_encode(key,volte)
+ netType="4G"
+ # base64_netType = sha256_encode(key,netType)
+
+ resolution="466*466"
+ # base64_resolution = sha256_encode(key,resolution)
+
+ screenSize = "1.43"
+ # base64_screenSize = sha256_encode(key,screenSize)
+ wearingStatus ="-1"
+ # base64_wearingStatus = sha256_encode(key,wearingStatus)
+
+ networkStatus ="1"#1:连接;0:未连接;-1:不支持
+
+ routerMac = "***"
+
+ wifiMac = "***"
+ # base64_networkStatus = sha256_encode(key,networkStatus)
+ encyr_data = [MAC,RAM,ROM,CPU,sysVersion,softwareVer,softwareName,volte,netType,resolution,screenSize,wearingStatus,networkStatus,routerMac,wifiMac]
+ print(len(encyr_data))
+ encyr_new_data=[]
+ for i in range(len(encyr_data)):
+ tmp_data = self.sha256_encode(key,encyr_data[i])
+ encyr_new_data.append(tmp_data)
+
+ # deviceInfo_tmp = {
+ # "bluetoothMac":"{}".format(base64_MAC),#mac地址可填可不填
+ # "ram":"{}".format(base64_RAM),#ram信息
+ # "rom":"{}".format(base64_ROM),#rom信息
+ # "cpu":"{}".format(base64_CPU),#cpu信息
+ # "sysVersion":"{}".format(base64_sysVersion),#操作系统版本号
+ # "softwareVer":"{}".format(base64_softwareVer),#固件版本号
+ # "softwareName":"{}".format(base64_softwareName),#固件名称
+ # "volte":"{}".format(base64_volte),#volte开关 默认是开
+ # "netType":"{}".format(base64_netType),#当前网络类型4G
+ # "resolution":"{}".format(base64_resolution),#屏幕分辨率466*466
+ # "screenSize":"{}".format(base64_screenSize),#屏幕尺寸默认1.43
+ # "wearingStatus":"{}".format(base64_wearingStatus),#佩戴状态不支持
+ # "networkStatus":"{}".format(base64_networkStatus)#网络状态
+
+ # }
+ deviceInfo_tmp = {
+ "bluetoothMac":"{}".format(encyr_new_data[0]),#mac地址可填可不填
+ "ram":"{}".format(encyr_new_data[1]),#ram信息
+ "rom":"{}".format(encyr_new_data[2]),#rom信息
+ "cpu":"{}".format(encyr_new_data[3]),#cpu信息
+ "sysVersion":"{}".format(encyr_new_data[4]),#操作系统版本号
+ "softwareVer":"{}".format(encyr_new_data[5]),#固件版本号
+ "softwareName":"{}".format(encyr_new_data[6]),#固件名称
+ "volte":"{}".format(encyr_new_data[7]),#volte开关 默认是开
+ "netType":"{}".format(encyr_new_data[8]),#当前网络类型4G
+ "resolution":"{}".format(encyr_new_data[9]),#屏幕分辨率466*466
+ "screenSize":"{}".format(encyr_new_data[10]),#屏幕尺寸默认1.43
+ "wearingStatus":"{}".format(encyr_new_data[11]),#佩戴状态不支持
+ "networkStatus":"{}".format(encyr_new_data[12]),#网络状态
+ "routerMac":"{}".format(encyr_new_data[13]), #路由mac地址 ***
+ "mac":"{}".format(encyr_new_data[14]) #wifi mac
+ }
+ json_data = ujson.dumps(deviceInfo_tmp)#需要转义的字符串
+
+ send_autoregist = {
+ "endpoint":config_data,
+ "deviceInfo":"{}".format(json_data)
+ }
+
+ test_data = ujson.dumps(send_autoregist)#需要转义的字符串
+ print("test_data:{}".format(test_data))
+ headers_T ={"Content-Type":"application/json"}
+ request_result = 0
+ print("shangbao address:{}\r\n".format(url))
+ try:
+ response = request.post(url, data=ujson.dumps(send_autoregist),headers =headers_T)
+ request_result = 1
+ result_json = ""
+ print("response success:response.status_code{}\r\n".format(response.status_code))
+ if response.status_code == 200:
+ dev_autoregist_result = 1
+ content = response.content
+ c = next(content)
+ result_json = ujson.loads(c)#解析成json格式
+ else:
+ dev_autoregist_result = 0
+
+
+ if "rspCode" in result_json:
+ rspCode = result_json["rspCode"]
+ rspMsg = result_json["rspMsg"]
+ print("response success:rspCode{} {}\r\n".format(rspMsg,rspCode))
+ if rspCode == "0000" or rspMsg == "成功":
+ dev_autoregist_result = 1
+ else:
+ dev_autoregist_result = 0
+ else:
+ dev_autoregist_result = 0
+ print("response success:\r\n")
+ return dev_autoregist_result
+
+ except Exception as e:
+ print("response:{}".format(e))
+ request_result = 0
+
+ if request_result == 0:#请求出错了
+ dev_autoregist_result = 0
+ return dev_autoregist_result
+
+
+ def read_config_file(self):#获取配置文件，一开机是没有配置文件的
+
+ self.read_config_msg_file()#读文件信息
+ if self.config_data != {}:
+ if "retryInterval" in self.config_data:
+ self.retryInterval = int(self.config_data["retryInterval"])
+ if "retryNum" in self.config_data:
+ self.retryNum = int(self.config_data["retryNum"])
+ if "heartBeatTime" in self.config_data:
+ self.heartBeatTime = int(self.config_data["heartBeatTime"])
+ if "reportTime" in self.config_data:
+ self.reportTime = int(self.config_data["reportTime"])
+ if "reportNum" in self.config_data:
+ self.reportNum = int(self.config_data["reportNum"])
+ if "address" in self.config_data:
+ self.address = str(self.config_data["address"])
+
+ #终端本地需要保存本地的数据
+ # self.reportTime_Sec = 0 #保存本地 保存时间戳下一次开机使用
+ # self.report_Num_old = 0#保存本地
+ # self.retryNum_old = 3#保存本地
+ if NEED_SAVE_CONFIG_FILE == 1:
+ if "reportTime_Sec" in self.config_data:
+ self.reportTime_Sec = int(self.config_data["reportTime_Sec"])
+ if "report_Num_old" in self.config_data:
+ self.report_Num_old = int(self.config_data["report_Num_old"])
+ if "retryNum_old" in self.config_data:
+ self.retryNum_old = int(self.config_data["retryNum_old"])
+
+ print("read_config_file self.config_data:{} ".format(self.config_data))
+ def retryTimerCb(self,*argc):#异常重试机制定时器回调
+ #保存本地
+ self.retryNum_old+=1 #1 self.reportNum = 1
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["retryNum_old"] = self.retryNum_old
+ self.write_config_msg_file(self.config_data)
+ print("retryTimerCb self.retryNum_old:{}\r\n".format(self.retryNum_old))
+ self.search_report_num_step()
+ pass
+ def reportTimerIntervalError(self):
+ self.retryNum_old = 0#保存
+ self.report_Num_old = 0#保存 定时清空数据
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ self.reportTime_Sec = time_tmp+self.reportTime*60 #(记录时间+reportTime)标识旧的时间
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["reportTime_Sec"] = self.reportTime_Sec
+ self.config_data["retryNum_old"] = self.retryNum_old
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ self.search_report_num_step()#重新查询
+ pass
+ def error_retryNum_step(self):#判读报错次数是否大于self.retryNum 步骤
+ print("error_retryNum_step:self.retryNum_oldd:{} self.retryNum:{} self.reportTime:{}\r\n".format(self.retryNum_old,self.retryNum,self.reportTime))
+
+ if self.retryNum_old >= self.retryNum and self.retryNum_old != 0:#self.retryNum_old > 10#结束HTPP下一个最大频率周期时间间隔流程
+ print("error_retryNum_step:self.retryNum_old >= self.retryNum\r\n")
+ self.reportTimerIntervalError()
+ # self.retpoertTimerC.start(self.reportTime*60*1000,0,self.reportTimerIntervalError)#重新开始 需要清空数据
+ else:
+ get_result = self.first_get_config_json()#发起向服务端请求配置信息下发到设备端
+ if get_result == 0:#获取失败或者没有网络 走异常重试机制
+ self.report_Num_old+=1#请求错误请求失败都要保存上报次数
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ print("error_retryNum_step:self.retryTimer.start :{} {} {}\r\n".format(self.retryInterval,self.report_Num_old,self.reportNum))
+ self.checkMaxReportNum()#检查上报最大次数
+ self.retryTimer.start(self.retryInterval*60*1000,0,self.retryTimerCb)
+ pass
+ else:#
+
+ #第一步触发自注册
+ if get_result == 2:#请求的配置文件和本地不一致重启
+ self.retryNum_old = 0#保存本地 配置文件不同重启模组 清空异常重试的报错次数
+ # self.report_Num_old+=1#请求错误请求失败都要保存上报次数
+ # if NEED_SAVE_CONFIG_FILE == 1:
+ # self.config_data["report_Num_old"] = self.report_Num_old
+ # self.config_data["retryNum_old"] = self.retryNum_old
+ # self.write_config_msg_file(self.config_data)
+
+ self.china_mobile_init_param()#重新走流程读配置文件->判断上报总数->判断报错次数->获取配置文件
+ self.search_report_num_step()
+ return
+
+ self.report_Num_old+=1#请求错误请求失败都要保存上报次数
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ print("error_retryNum_step self.report_Num_old:{}\r\n".format(self.report_Num_old))
+ if self.checkMaxReportNum() == 1:#检查上报最大次数
+ self.search_report_num_step()#重新查询
+ return
+ report_result = self.onself_regist_report_cb()#注册
+
+ #第二步触发心跳上报次数
+ if report_result == 1:#注册完成之后根据服务端下发的配置 间隔上报心跳
+ self.heartreportTimer.stop()
+ self.heartreportTimer.start(self.heartBeatTime*60*1000,1,self.heartreportTimerCb)
+
+ def heartreportTimerCb(self,*argc):
+ self.heart_report_cb()
+
+ def retpoertTimerClear(self):
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ print("retpoertTimerCB time_tmp -self.reportTime_Sec:{} time_tmp :{} self.reportTime_Sec:{}\r\n".format(self.reportTime_Sec-time_tmp,time_tmp,self.reportTime_Sec))
+ self.report_Num_old = 0#清空上报总次数 #保存本地
+ self.retryNum_old = 0#清空上报错误次数 #保存本地
+ self.reportTime_Sec = time_tmp+self.reportTime*60#记录当前时间+reportTime的时间用于下次错判断
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["reportTime_Sec"] = self.reportTime_Sec
+ self.config_data["retryNum_old"] = self.retryNum_old
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ self.retpoertTimerC.stop()#关闭定时器
+ self.error_retryNum_step()#清空报错次数重新走判断报错次数
+ pass
+ def check_current_time(self):#检测当前时间是否超过self.reportTime 超过清空报错次数 清空上报总次数
+ #
+ date_tmp = utime.localtime()
+ currentTime = utime.mktime(date_tmp)#获取时间戳
+ reportTime = self.reportTime_Sec
+ print("check_current_time:time_tmp - self.reportTime_Sec:{} currentTime:{} self.reportTime*60:{}".format(reportTime, currentTime,self.reportTime*60))
+ if currentTime >= reportTime:#当前时间是否大于上次记录的时间 currentTime >= reportTime 直接清空 不超过定时清空数据不再上报数据
+ #在规定时间内上报次数大于8次就要等下一个10分钟 或者1440分了开个定时器
+ print("currentTime >= reportTime:\r\n")
+ self.retpoertTimerClear()
+ else:#否则次数置零，记录一下（当前时间+reportTime）时间
+ time_count = (reportTime - currentTime) #self.reportTime_Sec永远比time_tmp大
+ print("time_count:{}".format(time_count))
+ print("currentTime < reportTime:\r\n")
+ self.retpoertTimerC.start(time_count*1000,0,self.retpoertTimerCB)
+
+
+ # 第一次请求的时候，记录一下（当前时间+reportTime）时间与次数，如果次数小于最大次数，直接返回true。
+ # 如果次数大于最大次数，则判断一下当前时间是否超过上次设置的时间，如果超过了，则表示超过最大次数；否则次数置零，记录一下（当前时间+reportTime）时间。
+ def retpoertTimerCB(self,*argc):#按照剩余的时间做定时器
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ print("retpoertTimerCB time_tmp -self.reportTime_Sec:{} time_tmp :{} self.reportTime_Sec:{}\r\n".format(self.reportTime_Sec-time_tmp,time_tmp,self.reportTime_Sec))
+ self.report_Num_old = 0#清空上报总次数 #保存本地
+ self.retryNum_old = 0#清空上报错误次数 #保存本地
+ self.reportTime_Sec = time_tmp+self.reportTime*60#记录当前时间+reportTime的时间用于下次错判断
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["reportTime_Sec"] = self.reportTime_Sec
+ self.config_data["retryNum_old"] = self.retryNum_old
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ self.error_retryNum_step()#清空报错次数重新走判断报错次数
+
+
+ def search_report_num_step(self):#查询上报总数步骤
+ print("search_report_num_step:self.retryInterval:{} self.retryNum:{}".format(self.report_Num_old,self.reportNum))
+ if self.report_Num_old >= self.reportNum and self.report_Num_old != 0:#查询上报的总次数是否大于存储上报总次数
+ self.check_current_time()#检测当前时间是否超过self.reportTime 超过清空报错次数 清空上报总次数
+ else:#
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ self.reportTime_Sec = time_tmp+self.reportTime*60 #(记录时间+reportTime)标识旧的时间
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["reportTime_Sec"] = self.reportTime_Sec
+ self.write_config_msg_file(self.config_data)
+ self.error_retryNum_step()#查询上报错误次数
+
+ def search_report_num_step_init(self):#查询上报总数步骤
+ print("search_report_num_step:self.retryInterval:{} self.retryNum:{} self.reportTime_Sec:{}\r\n".format(self.report_Num_old,self.reportNum,self.reportTime_Sec))
+ if self.report_Num_old >= self.reportNum and self.report_Num_old != 0:#查询上报的总次数是否大于存储上报总次数
+ self.check_current_time()#检测当前时间是否超过self.reportTime 超过清空报错次数 清空上报总次数
+ else:#
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ if self.reportTime_Sec == 0:
+ self.reportTime_Sec = time_tmp+self.reportTime*60 #(记录时间+reportTime)标识旧的时间
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["reportTime_Sec"] = self.reportTime_Sec
+ self.write_config_msg_file(self.config_data)
+ self.error_retryNum_step()#查询上报错误次数
+
+
+ def reportTimerIntervalCb(self,*argc):#最大上报频率时间间隔定时器 要清空数据
+ print("reportTimerIntervalCb\r\n")
+ self.search_report_num_step()#重新查询
+
+ def onself_regist_report_cb(self):#自注册上报信息
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ print("onself_regist_report_cb:self.report_Num_old:{} self.reportNum:{} self.reportTime_Sec:{}\r\n".format(self.report_Num_old,self.reportNum,self.reportTime_Sec))
+ self.report_Num_old+=1 ##保存本地
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ #设备自注册上报信息
+ url = "https://{}//dm-multi-accept/multi/acceptMultiTerminalRegInfo".format(self.address)#上报地址
+ confing_type = "autoRegist"#上报传输配置
+ result = self.china_mobile_autoregist_infor(url,confing_type)
+
+
+ if result != 1:
+ #触发异常重试进制
+ self.checkMaxReportNum()#检查上报最大次数
+ if self.checkMaxRetryNum() == 1:
+ print("retryTimerCb timer22")#异常重试过多重新间隔reportTime注册流程 关闭所有的定时器
+ self.search_report_num_step()#重新查询
+ return 0
+ self.retryTimer.start(self.retryInterval*60*1000,0,self.retryTimerCb)
+ return 0
+ else:
+ if self.checkMaxReportNum() == 1:
+ self.search_report_num_step()#重新查询
+ # self.retpoertTimerC.start(self.reportTime*60*1000,0,self.reportTimerIntervalCb)
+ return 0
+ else:
+ return 1
+ def checkMaxReportNum(self):#检查上报次数最大值
+ print("checkMaxReportNum :self.reportNum :{} self.report_Num_old:{}\r\n".format(self.reportNum,self.report_Num_old))
+ if self.report_Num_old >= self.reportNum and self.report_Num_old != 0:
+ self.retryTimer.stop()#关定时器
+ self.retpoertTimerC.stop()
+ self.heartreportTimer.stop()
+ return 1
+ else:
+ return 0
+
+ def checkMaxRetryNum(self):#检查上报错误次数
+ print("checkMaxRetryNum :self.retryNum:{} self.retryNum_old:{}\r\n".format(self.retryNum_old,self.retryNum))
+ if self.retryNum_old >= self.retryNum and self.retryNum_old != 0:#异常重试过多重新间隔reportTime注册流程
+ self.retryTimer.stop()#关定时器
+ self.retpoertTimerC.stop()
+ self.heartreportTimer.stop()#关闭心跳定时器
+ return 1
+ else:
+ return 0
+
+ def heart_report_cb(self):#心跳上报信息
+
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ self.report_Num_old+=1#保存本地
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.write_config_msg_file(self.config_data)
+ print("heart_report_cb:self.report_Num_old:{} self.reportNum:{} self.reportTime:{} self.reportTime_Sec:{}\r\n".format(self.report_Num_old,self.reportNum,self.reportTime,self.reportTime_Sec))
+
+ url = "https://{}//dm-multi-accept/multi/acceptMultiTerminalHeartbeatInfo".format(self.address)#上报地址
+ confing_type = "keepAlive"#上报传输配置
+ result = self.china_mobile_autoregist_infor(url,confing_type)
+ if result != 1:
+ #触发异常重试进制
+ self.checkMaxReportNum()
+ if self.checkMaxRetryNum() == 1:#异常重试过多重新间隔reportTime注册流程
+ self.search_report_num_step()#重新查询
+ return
+ self.retryTimer.start(self.retryInterval*60*1000,0,self.retryTimerCb)
+ return
+ if self.checkMaxReportNum() == 1:#上报次数大于8次
+ self.search_report_num_step()#重新查询
+ return
+
+ def china_mobile_init_param(self):#初始化
+
+ status = eventMesh.publish("get_factory_status")
+ if status == None:
+ status = 0
+ print("get_factory_status:{}\r\n".format(status))
+ if status == 0:#恢复出厂或者新的机器需要清空不必要的数据
+ if self.init_flag == 0:#只初始化一次
+ IFEXIST = ql_fs.path_exists("/usr/telecom_config.json") #不存在
+ if IFEXIST == True:
+ uos.remove("/usr/telecom_config.json")
+ isStorage = ql_fs.path_exists("/usr/china_mobie_config.json")#移动入库的配置文件移除
+ if isStorage == True:
+ uos.remove("/usr/china_mobie_config.json")
+ #先清空再写入默认参数
+ self.init_flag = 1
+ self.retryInterval = 10
+ self.retryNum = 1#异常重试最大次数
+ self.heartBeatTime = 1440#心跳上报频率 单位分钟
+ self.reportTime = 1440#最大上报频率 自注册+心跳上报的频率次数不能大于最大上报频率次数
+ self.reportNum = 8 #最大上报次数
+
+ self.reportTime_Sec = 0 #保存本地 保存时间戳下一次开机使用
+ self.report_Num_old = 0#保存本地
+ self.retryNum_old = 0#保存本地
+ get_address = eventMesh.publish("get_dmp_cm_address")
+ if get_address == None:#获取出来地址是空的使用适配地址
+ self.address = "a.fxltsbl.com"#默认
+ else: #恢复出厂使用BLE传送过来的地址
+ self.address = str(eventMesh.publish("get_dmp_cm_address"))
+
+ self.config_data["retryInterval"] = self.retryInterval
+ self.config_data["retryNum"] = self.retryNum
+ self.config_data["heartBeatTime"] = self.heartBeatTime
+ self.config_data["reportTime"] = self.reportTime
+ self.config_data["reportNum"] = self.reportNum
+ # self.config_data["address"] = self.address
+ if NEED_SAVE_CONFIG_FILE == 1:
+ self.config_data["reportTime_Sec"] = self.reportTime_Sec
+ self.config_data["report_Num_old"] = self.report_Num_old
+ self.config_data["retryNum_old"] = self.retryNum_old
+
+ self.write_config_msg_file(self.config_data)
+ #读配置文件
+ self.read_config_file()#只读一下配置文件
+
+ self.retryTimer.stop()#关定时器
+ self.retpoertTimerC.stop()
+ self.heartreportTimer.stop()
+ def china_mobile_init(self):
+ self.china_mobile_init_param()
+ #查询上报总数流程
+ self.search_report_num_step_init()
+
+
+
+
+chinamobileCb = chinamobile()
+
+
+
+
+
+
+
+
+
+
+
+
--- /dev/null
+import example
+main_flag = 1
+try:
+ from usr.slipService import slipservice
+ from usr.tcpService import TcpService
+ import usr.checkota
+ example.exec('/usr/main_init.py')
+ print("启动成功!!!!!\r\n")
+except Exception as e:
+ main_flag = 0
+ print("启动失败!!!!!\r\n".format(e))
+
+
+
+
--- /dev/null
+import example
+import osTimer
+import ql_fs
+import log
+import sms
+from misc import Power
+ota_flag = 0
+try:
+ from usr.EventMesh import eventMesh
+ from usr.telecom_dmp import telecomDmpCb
+ from usr.china_mobile_dmp import chinamobileCb
+ from usr.cat1Service import cat1service
+ ota_flag = 1
+ print("检测文件成功!!!!!!!\r\n")
+except Exception as e:
+ print("检测文件失败!!!!!!!{}\r\n".format(e))
+ ota_flag = 0
+tmp_dir = ql_fs.path_exists("/usr/TmpPyFile") #临时存放的文件夹
+if tmp_dir == True:
+ try:
+ ql_fs.rmdirs("/usr/TmpPyFile")
+ print("移除 TmpPyFile 成功!!!!!!!\r\n")
+ except Exception as e:
+ print("移除 TmpPyFile 失败!!!!!!!{}\r\n".format(e))
+
+sms_get = sms.getSaveLoc()
+if(sms_get != -1):
+ sms_lacv = sms_get[0][0]
+ if sms_lacv != 'SM': #每次开机设置一下短信的存储位置
+ sms.setSaveLoc('SM', 'SM', 'SM')
+
+PROJECT_VERSION = "PY_MAIN_V3"
+CONFIG_JSON="/usr/system_config.json"
+CURRENT_APP_TYPE="pymain"
+
+
+# 设置日志输出级别
+log.basicConfig(level=log.INFO)
+cat1service_log = log.getLogger("pymain")
+
+
+def get_versionkeyname_by_py(app_type):
+ return str("{}version".format(app_type))
+
+def get_default_versionvalue_by_py(app_type):
+ if (app_type == "pymain"):
+ return "PY_MAIN_V2"
+ elif (app_type == "pyota"):
+ return "PY_OTA_V2"
+ elif (app_type == "pysrv"):
+ return "PY_SRV_V2"
+
+#如果没有configfile则创建它
+if not ql_fs.path_exists(CONFIG_JSON):
+ data = {str(get_versionkeyname_by_py(CURRENT_APP_TYPE)):get_default_versionvalue_by_py(CURRENT_APP_TYPE)}
+ ql_fs.touch(CONFIG_JSON,data)
+
+def set_version_to_json_config(app_type,keyvalue):
+ config_data = ql_fs.read_json(CONFIG_JSON)
+ config_data.update( {str(get_versionkeyname_by_py(app_type)):keyvalue})
+ ql_fs.touch(CONFIG_JSON, config_data)
+ cat1service_log.info("{}={}".format(get_versionkeyname_by_py(app_type),keyvalue))
+ cat1service_log.info("{}".format(config_data))
+
+set_version_to_json_config(CURRENT_APP_TYPE,PROJECT_VERSION)
+
+
+def checkota_cb(arg):
+ print("start checkota!!")
+ example.exec('/usr/checkota.py')
+# 创建os定时器
+
+timer = osTimer()
+# 启动定时器，参数依次为时间、是否循环、回调函数 定时器超时的时间(单位ms)
+# 开机delay 20秒后执行一次ota升级
+timer.start(20000,0,checkota_cb)
+print("checkota py end!!")
--- /dev/null
+
+import log
+import slip
+from machine import UART
+class slipServiceInit:
+ AP = 0 # SLIP_INNER
+ STA = 1 # SLIP_OUTER
+ def __init__(self, uart=UART.UART4, mode=AP):
+ self.__uart = uart
+ self.__mode = mode
+ slip.destroy()
+ print('slip uart={0}'.format (self.__uart))
+
+ ret = slip.construct(self.__uart, self.__mode, 0)
+ if ret != 0:
+ print('slip netif construct fail')
+ else:
+ print('slip netif construct success')
+
+slipservice = slipServiceInit()
\ No newline at end of file
--- /dev/null
+import app_fota
+from misc import Power
+import modem
+import ujson
+import request
+import ql_fs
+import checkNet
+import sys
+import sim
+
+from queue import Queue
+import usys
+import _thread
+import fota
+import utime
+import log
+import uos
+import osTimer
+import net
+import ql_fs
+from usr.EventMesh import eventMesh,CHINA_TELECOM_DM_FUN_ENABLE
+# 设置日志输出级别
+log.basicConfig(level=log.INFO)
+fota_log = log.getLogger("telecom_dmp")
+import modem
+import base64
+import request
+import ujson
+REGIST_MAX_NUM=10 #自注册的最大次数 现在是默认是10次
+REGIST_INTERVAL_TIMER=60*60 #自注册失败的间隔时间 1小时
+REGIST_POWER_ON_TIME=5*60 #开机5分钟内就必须自注册触发
+MULTI_DAY_RESEND_T = 30*24*60*60-12*60*60#多日重发的机制的周期T 30天
+MULTI_DAY_RESEND_t = 12*60*60#多日重发的机制的周期t 0.5天
+def get_report_url_website(mode = None):#获取上报网址
+ url = "http://zzhc.vnet.cn:9998/"#上报网址
+ return url
+
+class telecomDmp:
+ def __init__(self):
+ self.config_data = {}
+ self.check_timer = osTimer()#1小时定时器
+ self.multiDayResend_timer = osTimer()#12小时定时器 多日重发的机制
+ self.telecomTimer = osTimer()
+ self.multimer_count = 0#多日重发机制周期Count
+ self.multimer_init = 0
+ self.power_on_multiflag = 0
+ self.timer_count = 0
+ self.timerPowerNum = 0
+ self.telecom_init_state = 0#初始化状态开机检查标识
+ self.isRegistOk = 0#注册成功
+ eventMesh.subscribe("get_telecom_init_state",self.get_telecom_init_state)
+ eventMesh.subscribe("set_telecom_init_state",self.set_telecom_init_state)
+
+ eventMesh.subscribe("set_dmp_power_num",self.set_dmp_power_num)
+ eventMesh.subscribe("get_dmp_power_num",self.get_dmp_power_num)
+
+ eventMesh.subscribe("get_dmp_power_timer_count",self.get_dmp_power_timer_count)
+
+ self.regist_queue = Queue()
+ _thread.stack_size(10*1024)
+ _thread.start_new_thread(self.regist_queue_thread, ())
+ _thread.stack_size(8*1024)
+
+ eventMesh.subscribe("publish_message_event_registinfor",self.publish_message_event_registinfor)
+ self.__net_connected = 0
+ eventMesh.subscribe("get_network_state",self.get_network_state)#订阅消息
+ eventMesh.subscribe("set_network_state",self.set_network_state)#订阅消息
+
+ eventMesh.subscribe("set_dev_version",self.set_dev_version)#订阅消息
+ eventMesh.subscribe("get_dev_version",self.get_dev_version)#订阅消息
+
+ eventMesh.subscribe("save_iccid_data",self.save_iccid_data)#订阅消息 保存ICCID
+ eventMesh.subscribe("get_iccid_data",self.get_iccid_data)#订阅消息 保存ICCID
+
+ eventMesh.subscribe("set_regist_time",self.set_regist_time)#订阅消息 保存ICCID
+ eventMesh.subscribe("get_regist_time",self.get_regist_time)#订阅消息 保存ICCID
+
+ self.regist_timeSec = 0
+ self.iccid_data = ""
+ self.software_version = ""
+ self.mulit_day_timesec = 0#多日重发的开始的时间戳
+ pass
+ def regist_queue_thread(self):
+ while True:
+ data = self.regist_queue.get()
+ #EventMesh.debug_log("regist_queue:data = {}".format(data))
+ if data != None:
+ try:
+ data["func"](data["data"])
+ except Exception as e:
+ print("regist_queue:ERROR:{}".format(e))
+ usys.print_exception(e)
+ def publish_message_event_registinfor(self,event,msg):
+ self.regist_queue.put(msg)
+
+ def publish_regist_event_cb(self, *args, **kwargs):
+ eventMesh.publish("publish_message_event_registinfor",{"func":self.timer_cb,"data":0})
+
+ def set_network_state(self,event,msg):#设置网络是否正常
+ self.__net_connected = int(msg)
+
+ def get_network_state(self,event,msg):#获取网络是否正常
+ return self.__net_connected
+
+ def set_dev_version(self,event,msg):#获取固件版本号
+ self.software_version = str(msg)
+
+ def get_dev_version(self,event,msg):#获取固件版本号
+ return self.software_version
+
+ def save_iccid_data(self,event,msg):
+ self.iccid_data = str(msg)[6:]#ICCID:
+ print("write_config_msg_file msg:{}\r\n".format(msg))
+ self.config_data["ICCID"]=self.iccid_data
+ with open("/usr/telecom_config.json",'w+',encoding="utf-8") as fd:
+ ujson.dump(self.config_data,fd)
+ #读文件信息
+ def get_iccid_data(self,event,msg):
+
+ IFEXIST = ql_fs.path_exists("/usr/telecom_config.json") #不存在
+ if IFEXIST == True:
+ with open("/usr/telecom_config.json","r",encoding='utf-8') as fd:
+ self.config_data = ujson.load(fd)
+ print("get_iccid_data self.config_data:{}\r\n".format(self.config_data))
+ if self.config_data != {}:
+ if "ICCID" in self.config_data:
+ value = self.config_data["ICCID"]
+ self.iccid_data = str(value)
+ else:
+ self.iccid_data = ""
+ print("get_iccid_data self.config_data end:{}\r\n".format(self.config_data))
+ return self.iccid_data
+
+ def set_regist_time(self,event,msg):#
+ self.regist_timeSec = str(msg)[7:]#REGIST:
+ print("set_regist_time msg:{}\r\n".format(msg))
+ self.config_data["REGIST"]=self.regist_timeSec
+ with open("/usr/telecom_config.json",'w+',encoding="utf-8") as fd:
+ ujson.dump(self.config_data,fd)
+
+ def get_regist_time(self,event,msg):#
+ IFEXIST = ql_fs.path_exists("/usr/telecom_config.json") #不存在
+ if IFEXIST == True:
+ with open("/usr/telecom_config.json","r",encoding='utf-8') as fd:
+ self.config_data = ujson.load(fd)
+ print("get_regist_time self.config_data:{}\r\n".format(self.config_data))
+ if self.config_data != {}:
+ if "REGIST" in self.config_data:
+ value = self.config_data["REGIST"]
+ self.regist_timeSec = int(value)
+ else:
+ self.regist_timeSec = 0
+ return self.regist_timeSec
+
+
+ def get_sim_state(self):#获取sim状态 不为1是sim异常
+ return sim.getStatus()
+
+ def get_sim_iccid(self):#获取sim的iccid
+ return sim.getIccid()
+
+ def get_sim_imsi(self):#获取sim的imsi
+ return sim.getImsi()
+ def get_dev_imei(self):#获取设备的imei号
+ return modem.getDevImei()
+
+ def telecom_regeist_infor(self):#自注册信息 可变更
+ network_state = eventMesh.publish("get_network_state")
+ print("telecom_regeist_infor :",network_state,self.isRegistOk,REGIST_INTERVAL_TIMER,MULTI_DAY_RESEND_T,MULTI_DAY_RESEND_t,REGIST_POWER_ON_TIME)
+ if network_state == 0:# 第一次进入网络不正常就需要开启1小时定时器 等待下一个周期判断网络是否正常 需要判断网络是否正常 不正常就不去触发自注册了 就等待下一次 如果10次都不成功 就等一下次开机再去自注册
+ self.timer_count+=1
+ print("self.timer_count:{}".format(self.timer_count))
+ if self.timer_count < REGIST_MAX_NUM:#总共是10次 10次结束还没有自注册成功就等下一次开机自注册
+ self.check_timer.start(REGIST_INTERVAL_TIMER*1000,0,self.publish_regist_event_cb)#不需要循环定时器
+ else:
+ self.multiple_day_resend()
+ return
+ iccid = self.get_sim_iccid()
+ read_iccid = eventMesh.publish("get_iccid_data")
+ if read_iccid == None:
+ read_iccid = ""
+
+ print("iccid!!!!!!!!!!iccid {} read_iccid:{}".format(iccid,read_iccid))
+ if read_iccid != "":
+ if str(read_iccid) == str(iccid):#两者相同 并且本地有保存 不再自注册了 说明已经自注册过了
+ print("already registed!!!!!!") #已自注册过
+ self.isRegistOk = 1
+
+ if self.isRegistOk == 1:
+ print("multiple_day_resend!!!!!!\r\n")
+ self.multiple_day_resend()
+ return
+ self.telecom_regist_infor_init()#自注册初始化函数
+ if self.isRegistOk == 0:
+ self.timer_count+=1
+ print("self.timer_count:{}".format(self.timer_count))
+ if self.timer_count < REGIST_MAX_NUM:#总共是10次 10次结束还没有自注册成功就等下一次开机自注册
+ self.check_timer.start(REGIST_INTERVAL_TIMER*1000,0,self.publish_regist_event_cb)#不需要循环定时器
+ else:
+ self.multiple_day_resend()
+
+ def telecom_regist_infor_init(self):#自注册的数据部分
+ iccid = self.get_sim_iccid()
+ read_iccid = eventMesh.publish("get_iccid_data")
+ if read_iccid == None:
+ read_iccid = ""
+ url = get_report_url_website(None)#上报网址 根据需要更改上报网址
+ if iccid == -1:
+ iccid = str("FF")#为空就填写FF
+
+ IMSI = self.get_sim_imsi()
+ if IMSI == -1:#没有卡 则填FF
+ IMSI = str("FF")
+ imei = self.get_dev_imei()
+ if imei == -1:
+ imei = str("FF")
+
+ data_tmp = net.getCellInfo() #会适当卡个3-5s
+ i = 0
+ cell_data = 0
+ if(len(data_tmp) >= 1):
+ for cell in data_tmp:
+ if i == 2:#在list里面最多就三个元素 最后一个是LTE的数据
+ if cell != []:
+ for tup in cell:
+ print("tup:{}".format(tup))
+ if tup[0] == 0 and len(tup) > 0:#第0个代表当前服务的小区CELLID 7位16进制数
+ cell_data = tup[1]#这个是十进制数需要自行转换成十六进制数
+ print(cell_data)
+ break
+ i+=1
+ # cell_data = 0
+ cell_data = "%07x"%(cell_data)#7位16进制数不够前面补0
+ print(cell_data)
+ sendCellid = "{}".format(cell_data)
+ REGVER = "12.0"#当前数据域协议版本号
+ MODEL = "TXB-Watch Soar"#机型字段 -前面是厂商名 -后面是设备名
+ get_dev_version = eventMesh.publish("get_dev_version")#订阅消息
+ if get_dev_version == None:
+ get_dev_version = ""
+ SWVER = get_dev_version #软件版本号
+ UETYPE = "12"#终端类型 12是智能手表 11是儿童手表
+ SIM1ICCID = iccid
+ SIM1LTEIMSI = IMSI
+ MACID = ""#可用WALN的地址 终端布支持WLAN 就是不可上网
+ OSVER = "RTOS"#操作系统版本号
+ IMEI1 = imei#"876226002021717"#imei
+ SIM1CELLID = sendCellid#下发的小区ID
+ data = {
+ "REGVER":REGVER,
+ "MODEL":MODEL,
+ "SWVER":SWVER,
+ "UETYPE":UETYPE,
+ "SIM1ICCID":SIM1ICCID,
+ "SIM1LTEIMSI":IMSI,
+ "MACID":MACID,
+ "OSVER":OSVER,
+ "IMEI1":IMEI1,
+ "SIM1CELLID":SIM1CELLID,
+ "NETWORKTYPE":4
+ }
+ data_infor=ujson.dumps(data)#将字典转换成json格式
+ json_bytes = bytes(data_infor, 'utf-8')#转换成字节数
+ data_encode = base64.b64encode(json_bytes)#再转换成base64的编码格式 密文
+ print("data_infor:{} data:{}".format(data_encode,data))
+ headers_T = {'Content-Type':'application/encrypted-json'} #请求头信息 按照实际要求填写
+ request_result = 0
+ try:
+ response = request.post("http://zzhc.vnet.cn:9998/", data=data_encode,headers =headers_T)
+ request_result = 1
+ if response.status_code == 200 : #返回状态码 200服务器正常解析数据
+ content = response.content#后台返回的结果
+ c = next(content)
+
+ jsload_data = ujson.loads(c)
+ print("jsload_data:{}".format(ujson.loads(c))) #{"resultCode": "0","resultDesc": "Success"}
+ if "resultCode" in jsload_data or "resultDesc" in jsload_data:#返回结果码值
+ resultCode = jsload_data["resultCode"]#结果解析 "0" 成功 "1" 解码错误 "2" 校验错误
+ resultDesc = jsload_data["resultDesc"]#Success 表示自注册成功
+
+ if resultCode == "0" or resultDesc == "Success":#注册成功退出当前注册 保存当前的ICCID 不在进行自注册了
+ iccid = self.get_sim_iccid()#获取当前SIM的ICCID
+ if iccid != -1:#读到ICCID
+ self.timer_count = 0
+ self.check_timer.stop()
+ self.isRegistOk = 1#已完成自注册的标识
+ iccid_buf =str("ICCID:")+str(str(iccid))
+ eventMesh.publish("save_iccid_data",iccid_buf)
+ self.multiple_day_resend()
+ #上报成功后 需要29.5或者30.5天后重发 初始值为0.5也就是12小时 30天后再重发一次也是一个月后重发数据自注册域
+ print("regist success:!!!!!")
+ return 1
+ if resultCode == "1":
+ print("Decode error")#解码错误 设备编码不正确
+ return 0
+
+ if resultCode == "2":#
+ print("Check error")#校验错误 设备里面数据不正确 有些数据不应该为空
+ return 0
+
+ except Exception as e:
+ print("response:{}".format(e))
+ request_result = 0
+ return 0
+
+ def timer_cb(self,data):#定时器回调
+ self.telecom_regeist_infor()#重新进行自注册
+ pass
+ # 多日重发功能要求：
+ # 1) 多日重发是指：在重发周期 T 内，如果没有功能性触发数据域自注册（触发发送且发送成功），
+ # 则终端应根据当前终端实时信息组织数据域自注册（不能直接拿上一周期的内容不变而重发）内容
+ # 并发送的过程；
+ # 2) 多日重发的时间间隔周期 T 设置为 30 天；
+ # 3) 多日重发的过程应设置为：功能性（比如换卡等）触发数据域自注册后，立即启动定时器 t（t
+ # 的初始值应设为 0.5 天）开始重发计时，以后每当 t 时间等于 T 的整数倍（t=N*T）时，终端就进
+ # 行数据域自注册发送，发送后 t 不要清零不要初始化，只有当功能性触发数据域自注册后，t 才初
+ # 始化，t 的初始化值为 0.5 天。
+ # Multiple day resend
+ def multiple_day_resend(self):#多日重发机制函数 没有发送数据域或者发送成功
+
+ t = 12 #计时周期 按照0.5天 也就是12小时来计算
+ T = 30*24 #周期为30天 计算30天的总共小时数
+ # t = N*T#只有t为T的整数倍就需要重发数据域自注册
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)#获取时间戳
+ if self.multimer_init == 1:#已注册过或者开机5分钟之内没有注册 或者注册成功就开始出发多日重发机制
+ self.mulit_day_timesec = time_tmp+MULTI_DAY_RESEND_t#初始值多加12小时 #初始化t = 0.5天
+ REGIST_buf = str("REGIST:")+str(self.mulit_day_timesec)
+ eventMesh.publish("set_regist_time",REGIST_buf)
+ return
+ self.multimer_init = 1
+ #设置开始时间戳
+ get_timesec = eventMesh.publish("get_regist_time")#一开机初始化为0 没有保存过数据 如果保存过就用保存的时间
+ if get_timesec == 0:
+ self.mulit_day_timesec = time_tmp+MULTI_DAY_RESEND_t
+ REGIST_buf = str("REGIST:")+str(self.mulit_day_timesec)
+ eventMesh.publish("set_regist_time",REGIST_buf)
+ else:
+ self.mulit_day_timesec = get_timesec
+ self.multiDayResend_timer.start(60*60*1000,1,self.multiDayResendTimer_Cb)#一分钟计时
+
+ def multiDayResendTimer_Cb(self,*argc):#多日重发机制定时器回调函数
+ T = 30*24*60*60
+ date_tmp = utime.localtime()
+ time_tmp = utime.mktime(date_tmp)+MULTI_DAY_RESEND_t#获取时间戳
+
+ if time_tmp < self.mulit_day_timesec:#如果当前时间戳小于保存的时间戳
+ self.mulit_day_timesec = time_tmp
+ print("time_tmp: self.mulit_day_timesec:\r\n",time_tmp,self.mulit_day_timesec)
+
+ if time_tmp - self.mulit_day_timesec >= MULTI_DAY_RESEND_T:#一个周期的时间到了重发注册一次
+ network_state = eventMesh.publish("get_network_state")
+ print("get_network_state:\r\n",network_state)
+ if network_state == 0:#网络不正常就不需要重发了等下一个周期
+ return
+ result = self.telecom_regist_infor_init()#要自注册数据域信息发送完才初始化t
+ if result == 0: #上报出错了
+ return
+ self.mulit_day_timesec = time_tmp+MULTI_DAY_RESEND_t # 重发后 初始化t = 0.5天
+ REGIST_buf = str("REGIST:")+str(self.mulit_day_timesec)
+ eventMesh.publish("set_regist_time",REGIST_buf)
+
+
+ def set_telecom_init_state(self,event,msg):#开机5分钟内检查是否有联网 有一次联网就关闭检查
+ self.telecom_init_state = msg
+
+ def get_telecom_init_state(self,event,msg):
+ return self.telecom_init_state
+
+ def get_dmp_power_timer_count(self,event,msg):#开机后限定5分钟内完成自注册
+ return REGIST_POWER_ON_TIME
+
+ def get_dmp_power_num(self,event,msg):#开机限定次数最多十次 十次不成功就等下一次开机 或者多日重发机制
+ print("get_dmp_power_num:{}".format(self.timerPowerNum))
+ return self.timerPowerNum
+
+ def set_dmp_power_num(self,event,msg):
+ print("set_dmp_power_num:{}".format(msg))
+ self.timerPowerNum = msg
+ def clear_storage_data(self):
+ IFEXIST = ql_fs.path_exists("/usr/telecom_config.json") #不存在
+ if IFEXIST == True:
+ uos.remove("/usr/telecom_config.json")
+ isStorage = ql_fs.path_exists("/usr/china_mobie_config.json")#移动入库的配置文件移除
+ if isStorage == True:
+ uos.remove("/usr/china_mobie_config.json")
+ print("clear_storage_data;{} {}".format(IFEXIST,isStorage))
+
+
+ def telecom_dmp_power_on_init(self):#开机初始化一次检测
+ if eventMesh.publish("get_telecom_init_state") == 1:#发送消息获取对应的值
+ return
+ if eventMesh.publish("get_dmp_power_num") < (eventMesh.publish("get_dmp_power_timer_count")*1000)/30000:#开机检查
+ if eventMesh.publish("get_telecom_init_state") == 0:#开机初始化一次
+ status = eventMesh.publish("get_factory_status")
+ if status == None:
+ status = 0
+ if status == 0:#恢复出厂过需要清空存储数据
+ self.clear_storage_data()
+ pass
+ self.telecomTimer.start(1*1000,0,self.fun_cb)
+ eventMesh.publish("set_telecom_init_state",1)
+
+ def fun_cb(self,*argc):
+ self.telecom_regeist_infor()#开机初始一次自注册信息
+ pass
+ def telecom_dmp_power_on_count(self):#开机计时判断最多十次
+ if eventMesh.publish("get_telecom_init_state") != 1:#在开机五分钟之内只要一次联网正常就不需要再检查是否网络正常去自注册了
+ if eventMesh.publish("get_dmp_power_num") < (eventMesh.publish("get_dmp_power_timer_count")*1000)/30000:#10+1
+ num = eventMesh.publish("get_dmp_power_num") #开机计时 如果开机5分钟内没有一次网络正常的话 当前开机自注册不生效 等待下一次开机自注册触发 或者触发多日重发机制
+ num+=1
+ eventMesh.publish("set_dmp_power_num",num)#次数累计加一
+ else:
+ if self.power_on_multiflag == 1:
+ return
+ self.power_on_multiflag = 1
+ self.multiple_day_resend()
+ pass
+
+telecomDmpCb = telecomDmp()
+
+
+
+
+
+
+
+
+
+
+
+
projects / mirrors / FD230.git / commitdiff