+++ /dev/null
-from misc import Power
-import usocket
-import log
-import utime
-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
-import binascii
-import ujson
-import uos
-import slip
-
-CAT1_SERVICE_HEAD = "FE"
-
-
-
-CAT1_REPLAY_STATE="00"
-CAT1_CREAT_DIR_FAILE= "01"
-CAT1_CREAT_DIR_OK= "02"
-CAT1_NO_REPLAY_OTA_OK= "03"
-CAT1_WRITE_FILE_SUCC= "04"
-CAT1_WRITE_FILE_ERROR = "05"
-CAT1_CRC_ERROR = "06"
-CAT1_SEND_HEAD_ERR = "07"
-CAT1_OTA_TIMEOUT_BLE_NO_REPLAY = "08"
-CAT1_CREAT_FILE_ERROR = "09"
-CAT1_CREAT_FILE_SUCC = "0A"
-CAT1_ALLPY_FILE_TRANSFER_END = "0B"
-CAT1_REPLAY_OTA_SUCC = "0C"
-CAT1_REPLAY_OTA_FALIE = "0D"
-CAT1_REPLAY_FILE_SIZE_OK = "0E"
-CAT1_REPLAY_FILE_SIZE_ERR = "0F"
-CAT1_REPLAY_OTA_END_FAILE = "10" #升级完之后 CAT1回复升级失败
-
-CAT1_NEED_UPDATE_OTA = "11" #提示用户强制升级
-
-BLE_STOP_OTA = 0 #结束OTA升级
-BLE_START_OTA = 1 #ble 开始发送OTA标识 -》 CAT1
-BLE_START_SEND_SINGLE_FILE_INFO= 2 #//ble 开始发送单个文件信息 -> CAT1 创建单个文件名
-BLE_START_SEND_FILE_DATA= 3 #//BLE开始发送文件数据额 ----》CAT1 接收文件数据写文件
-BLE_START_OTA_FAILE = 4 #BLE 发送OTA失败 取消文件传输
-BLE_START_OTA_SUCC = 5 #//BLE 发送OTA成功标识
-BLE_START_SEND_ALLFILE_FINESH = 6 #/所有PY文件传输完成
-BLE_START_SEND_SINGLE_FINESH = 7 #//单个文件传输完成
-BLE_START_ERROR_INFO = 255 #/发送错误信息结束进程
-
-# 创建gpio对象
-gpioWakeBT = Pin(Pin.GPIO21, Pin.OUT, Pin.PULL_DISABLE, 1)
-# 设置输入输出模式
-gpioWakeBT.set_dir(Pin.OUT)
-
-# 设置引脚电平
-gpioWakeBT.write(0)
-FILE_TRANSFER_TIMEOUT=60 #超时时间 60s没有收到BLE的发送数据就结束了
-class ftp_Service:
- AP = 0 # SLIP_INNER
- STA = 1 # SLIP_OUTER
-
- def __init__(self, uart=UART.UART4, mode=AP):
- self.__uart = uart
- self.__mode = mode
- self.Cat1FileState = 0
- self.Cat1FileReplayBle = 0
- self.Cat1TimeCount = 0
- self.Cat1PyFileTimout = FILE_TRANSFER_TIMEOUT
- self.Cat1FileTransTimer = osTimer()
- self.Cat1OtaTimeOut = osTimer()
- self.crc_err = 0
- self.allPyRecvFlag = 0
- self.ota_state =0
- self.ota_bstate =0
- self.fileNameTmp = ""
- self.fileNameList = []
- self.fileSizeList = []
- self.fileSize = 0
- self.updateTimer = osTimer()
- self.updateTimerCount = 0
- self.updateTimerFlag = 0
- self.sock = None
-
- slip.destroy()
- ret = slip.construct(self.__uart,self.__mode, 0)
- if ret != 0:
- print('slip netif construct fail')
- return None
-
- self.__sock_file = None
- self.__sock_file = self.__socket_file_init()
- self.__thread_file = _thread.start_new_thread(self.__Socket_File_Thread, ())
- print("ftp_Service :{}\r\n".format(self.__sock_file))
- # 封装tlv数据包
- def __pack_tlv_format(self, head, content):
- head1 = head
- content1 = content
- if len(content1) == 0 or len(content1) > 9999 or len(head1) != 2:
- print('illegal pack tlv content file')
- return -1
- len_str ='%04d' % len(content1)
- tlv_pack = CAT1_SERVICE_HEAD+head1+len_str+content1
- return tlv_pack
- # 解码tlv数据包
- def __unpack_tlv_format(self, msg):
- print('__unpack_tlv_format file {}\r\n'.format(msg))
- msg_tmp = str(msg)[2:]#这是去除head FE
- tag = msg_tmp[0:2]
- length = msg_tmp[2:6]
- value = msg_tmp[6:]
- len_str ='%04d' % len(value)
- if len(value) == 0 or len(value) > 9999 or len(tag) != 2 or len_str != msg_tmp[2:6]:
- print('__unpack_tlv_format err file')
- return -1
- print('__unpack_tlv_format: {} {} {}\r\n'.format(tag,length,value))
- unpack = (tag,length,value)
- return unpack
- def __socket_init(self):
-
- # 创建一个socket实例
- self.sock = usocket.socket(usocket.AF_INET, usocket.SOCK_STREAM)
- self.sock.setsockopt(usocket.SOL_SOCKET, usocket.SO_REUSEADDR, 1)
- return self.sock
-
- def __socket_file_init(self): #文件传输Socket
- self.sock = usocket.socket(usocket.AF_INET, usocket.SOCK_DGRAM, usocket.TCP_CUSTOMIZE_PORT)
- self.sock.setsockopt(usocket.SOL_SOCKET, usocket.SO_REUSEADDR, 1)
- # 绑定IP
- bind_addr = ('172.16.1.2', 5001)
- self.sock.bind(bind_addr)
- self.sock.settimeout(10)
- return self.sock
- def __socket_file_reinit(self):
- print("self.__sock_file reinit:{}\r\n".format(self.__sock_file))
- if self.__sock_file != None:
- self.sock.close()
- return self.__socket_file_init()
-
- def __Socket_UDP_file_noreply(self, head, content):
- head1 = head
- content1 = content
- gpioWakeBT.write(1)
- utime.sleep_ms(2)
- gpioWakeBT.write(0)
- utime.sleep_ms(20)
- # 消息处理
- msg = self.__pack_tlv_format(head1,content1)
- if msg == -1: #无效数据
- return 0
- # 向服务端发送消息
- server_addr = ('172.16.1.5',1001) #服务端口也需要更改
-
- print("__Socket_UDP_file_noreply send msg {}".format(msg))
- try:
- data_size = self.__sock_file.sendto(msg,server_addr)
- print("self.__sock_file data_size {}".format(data_size))
- except Exception as e:
- print("self.__sock_file error {}".format(e))
- return 0
- # py文件传输
- # //py文件传输
- # // {"Code":1} 开始OTA
- # // {"Code":2,"fileName":"cat1Service.py","fileSize":123435} fileCode: 文件ID fileName:文件名称 fileSize:文件大小
- # // {"Code":3,"head+datalen+data+CRC":"数据"} // Code: 2开始发送文件数据
- # // {"Code":4} BLE 主动发送OTA失败
- # // {"Code":5} BLE 主动发送OTA成功
- # // {"Code":6} BLE 所有PY文件传输完成
- # // {"Code":7} BLE 单个文件传输完成
- def __Socket_File_Thread(self):
- while True:
- try:
- print(" __Socket_File_Thread recv====22222")
- data=self.__sock_file.recv(1024*10)
- if not data:
- print("__Socket_File_Thread data null:\r\n")
- else:
- self.file_data(data.decode('uft-8'))
- # print("__Socket_File_Thread end:{}\r\n".format(data.decode()))
-
- except Exception as e:
- print("__Socket_File_Thread:e{}\r\n".format(e))
- self.__sock_file = self.__socket_file_reinit()
- # print("End __Socket_File_Thread Thread")
-
- def cat1FileTimerCb(self,*argc):
- print("timer test\r\n")
- if self.Cat1PyFileTimout > 0:
- self.Cat1PyFileTimout-=1
- if self.Cat1PyFileTimout == 0:
- self.Cat1PyFileTimout = 0
- self.Cat1FileState = 0
- self.deleteTmpFile()
- self.deleteUsrTmpFile()
- self.__Socket_UDP_file_noreply(CAT1_OTA_TIMEOUT_BLE_NO_REPLAY,"ota error") #结束文件接收不完整的
- self.Cat1FileTransTimer.stop() #//关闭定时器
- pass
-
- def crc_cal(self,msg):
- bytes_data = msg.encode('utf-8')
- hex_data = binascii.hexlify(bytes_data)
- hex_data = hex_data.decode()
- # print("hex_data:{}\r\n".format(hex_data))
- data = hex_data
- crcValue = 0
- j = 0
- i = 0
- json_state = 0
- crcbuf = 0
- print("len(data) :{}\r\n".format(len(data)))
- data_len = len(str(data))
- try:
- if data_len % 2 != 0:
- json_state = 0
- return [json_state,crcbuf]
- except Exception as e:
- json_state = 0
- print("不合法的的十六进制数据!!\r\n")
-
- for i in range(data_len):
- if j >= data_len:
- break
- try:
- decimal_number = int(str(data[j:j+2]), 16)
-
- crcValue=crcValue+decimal_number
- crcValue = crcValue&0xff
- except Exception as e:
- print("不合法的的十六进制数据!!\r\n")
- j+=2
-
- crcbuf = crcValue%256
- crcbuf = 256-crcbuf
- crcbuf = crcbuf%256
-
- print("crcbuf:{}\r\n".format(crcbuf))
- return [json_state,"%02x"%(crcbuf)]
- #删除临时创建的文件夹
- def deleteTmpFile(self):
- tmp_dir = ql_fs.path_exists("/usr/TmpPyFile")
- if tmp_dir == True:
- ql_fs.rmdirs("/usr/TmpPyFile")
-
- #删除usr临时创建的文件夹
- def deleteUsrTmpFile(self):
- return
- tmp_dir = ql_fs.path_exists("/usr/UsrTmpPyFile")
- if tmp_dir == True:
- ql_fs.rmdirs("/usr/UsrTmpPyFile")
-
- def file_data(self,data):
- mk_dir_state = 0
- print("data!!!!!{}\r\n".format(len(data)))
- if self.updateTimerFlag == 0:
- self.updateTimerFlag = 1
- self.updateTimer.stop()
- msg = {}
- json_state = 0
- try:
- msg = ujson.loads(data)
- json_state = 1
- except Exception as e:
-
- json_state = 0
-
- # print("msg type msg {} {}\r\n".format(msg,type(data)))
- if "Code" in msg and json_state == 1 :
-
- Code = int(msg["Code"])
- print("Code {} self.Cat1FileState:{}\r\n".format(Code,self.Cat1FileState))
- if Code == BLE_STOP_OTA: #OTA失败
- self.allPyRecvFlag = 0
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- self.deleteTmpFile()
- self.deleteUsrTmpFile()
- pass
- elif Code == BLE_START_OTA: #BLE 开始OTA cat1创建临时文件夹记录传输的文件数据 文件名
- self.ota_state =0
- self.ota_bstate =0
- self.allPyRecvFlag = 0
- self.fileNameList = []
- self.fileSizeList = []
- print("BLE_START_OTA {} \r\n".format(BLE_START_OTA))
- self.allPyRecvFlag = 0
- self.Cat1FileState = 0
- self.deleteUsrTmpFile()
- self.Cat1OtaTimeOut.stop()
- check_dir = ql_fs.path_exists("/usr/TmpPyFile")
- mk_dir_state = 0
- if check_dir == True:
- try:
- self.deleteTmpFile()
- except Exception as e:
- print("移除失败!!!!\r\n")
- check_dir = ql_fs.path_exists("/usr/TmpPyFile")
- if check_dir == False: #文件夹不存在 创建目录文件夹
- try:
- ql_fs.mkdirs("/usr/TmpPyFile")
- mk_dir_state = 1
- print("创建临时文件 创建成功!!!!\r\n")
- except Exception as e:
- mk_dir_state = 0
- print("创建临时文件失败没有内存!!!!\r\n")
- else: #已经存在目录了
- mk_dir_state = 1
- print("创建成功!!!!{}\r\n".format(mk_dir_state))
- if mk_dir_state == 0:
- self.__Socket_UDP_file_noreply(CAT1_CREAT_DIR_FAILE,"creat dir error!")
- else:
- self.Cat1FileState = 1
- self.fileNameList = []
- self.fileSizeList = []
- self.Cat1PyFileTimout = FILE_TRANSFER_TIMEOUT #超时时间10s
- self.Cat1FileTransTimer.stop()
- self.Cat1FileTransTimer.start(1000,1,self.cat1FileTimerCb)
- self.__Socket_UDP_file_noreply(CAT1_CREAT_DIR_OK,"creat dir success!")
-
-
- elif Code == BLE_START_SEND_SINGLE_FILE_INFO and self.Cat1FileState == 1: #包含文件名 文件大小
- print("BLE_START_SEND_SINGLE_FILE_INFO {} \r\n".format(BLE_START_SEND_SINGLE_FILE_INFO))
- self.Cat1PyFileTimout = FILE_TRANSFER_TIMEOUT #超时时间60s
- # {"Code":1,"fileName":"testpy.py","fileSize":1040}
- # print("msg {}\r\n".format(msg))
- self.fileNameTmp = str(msg["fileName"])
- self.fileSize = msg["fileSize"]
- self.fileNameList = msg["fileNameList"]
- # self.fileSizeList.append({"fileName":self.fileNameTmp,"fileSize":int(self.fileSize)})
- path = "/usr/TmpPyFile/{}".format(self.fileNameTmp)
- print("self.fileNameTmp {} self.fileSize:{} self.fileNameList:{} self.fileSizeList:{}\r\n".format(self.fileNameTmp,self.fileSize,self.fileNameList,self.fileSizeList))
- check_touch = ql_fs.path_exists("/usr/TmpPyFile/{}".format(self.fileNameTmp))
- if check_touch == True:
- try:
- uos.remove("/usr/TmpPyFile/{}".format(self.fileNameTmp))
- except Exception as e:
- print("移除文件失败\r\n")
- try:
- with open(path,"w+") as fd:
- fd.write("")
- fd.close() #关闭文件流
- self.__Socket_UDP_file_noreply(CAT1_CREAT_FILE_SUCC,"1creat file or dir success!")
- except Exception as e:
- print("创建文件失败\r\n")
- self.__Socket_UDP_file_noreply(CAT1_CREAT_FILE_ERROR,"1creat file or dir err!")
- else:
- try:
- print("self.fileNameTmp 111111{}\r\n".format(self.fileNameTmp))
- with open(path,"w+") as fd:
- fd.write("")
- fd.close() #关闭文件流
- self.crc_err = 0
- print("self.fileNameTmp {}\r\n".format(self.fileNameTmp))
- self.__Socket_UDP_file_noreply(CAT1_CREAT_FILE_SUCC,"2creat file or dir success!")
- except Exception as e:
- self.__Socket_UDP_file_noreply(CAT1_CREAT_FILE_ERROR,"2creat file or dir err!")
- print("创建文件失败\r\n")
-
- elif Code == BLE_START_SEND_FILE_DATA and self.Cat1FileState == 1: #文件数据
- self.Cat1PyFileTimout = FILE_TRANSFER_TIMEOUT #超时时间10s
- print("BLE_START_SEND_FILE_DATA {} self.fileNameTmp:{}\r\n".format(BLE_START_SEND_FILE_DATA,self.fileNameTmp))
- # {"Code":2,"data":"89ggjdggsjgdj"}
- if len(self.fileNameTmp) == 0: #文件名不能为空
- return
- data = msg["data"]
- if len(data) == 0:
- return
- print(" (data):{}\r\n".format(len(data)))
- tmpdata = str(data)
- head = tmpdata[0:2] #FE
- if head != "FE" and len(tmpdata) <= 8: #必须大于8 FE+012C+DATA+crc(一个字节89)
- print("head {}\r\n".format(head))
- self.__Socket_UDP_file_noreply(CAT1_SEND_HEAD_ERR,"head error!")
- return
- datalen = str(tmpdata[2:6]) #012c
- datalen = int("0x" + datalen, 16) #转换成十进制数
- data_buf = tmpdata[6:] # 数据
- data_buf = data_buf[:-2] #最后两个往前的数据
- crc = tmpdata[-2:] # 最后两个字符是 crc 一个字节
- print("crc ===!111111:{} {} len:{} {}\r\n".format(crc,type(crc),datalen,len(str(data_buf))))
- if len(str(data_buf)) == 0 or len(str(data_buf)) != datalen: #数据为空
- self.__Socket_UDP_file_noreply(CAT1_WRITE_FILE_ERROR,"crc error or data null!")
- return
- crclist=self.crc_cal(data_buf)
- newcrc = crclist[1]
- news = crclist[0]
- if len(str(crc)) == 0:
- self.__Socket_UDP_file_noreply(CAT1_CRC_ERROR,"crc error!")
- return
- decnumCrcCal = int("0x" + str(newcrc), 16) #转换成十进制数
- decnumCrc = int("0x" + str(crc), 16) #转换成十进制数
- print("crc:{} newcrc:{}\r\n".format(crc,newcrc,decnumCrc,decnumCrcCal))
- if decnumCrcCal != decnumCrc and news == 0:
- print("newcrc is not === crc crc校验出错不一致\r\n")
- self.__Socket_UDP_file_noreply(CAT1_CRC_ERROR,"crc error!")
- return
- data = str(data_buf)
- path = "/usr/TmpPyFile/{}".format(str(self.fileNameTmp))
- print("py path:{} self.fileNameTmp:{}\r\n".format(path,self.fileNameTmp))
- try:
- with open(path,"a") as fd:
- fd.write(data)
- fd.close() #关闭文件流
- self.__Socket_UDP_file_noreply(CAT1_WRITE_FILE_SUCC,"write file success!")
- print("写文件成功!!!!!\r\n")
- except Exception as e:
- self.__Socket_UDP_file_noreply(CAT1_WRITE_FILE_ERROR,"write file error!")
- print("写文件失败没有内存!!!!!\r\n")
- elif Code == BLE_START_OTA_FAILE and self.Cat1FileState == 1: #取消文件传输 OTA失败 移除目录文件
- print("BLE_START_OTA_FAILE {} \r\n".format(BLE_START_OTA_FAILE))
- self.allPyRecvFlag = 0
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"OTA FAILE")
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- self.deleteTmpFile()
- self.deleteUsrTmpFile()
- pass
- elif Code == BLE_START_SEND_ALLFILE_FINESH and self.Cat1FileState == 1: #全部文件传输完成
-
- tmp_dir = ql_fs.path_exists("/usr/TmpPyFile")
- if tmp_dir == True:
- filenamesList = uos.listdir("/usr/TmpPyFile")
- list1 = sorted(filenamesList)
- list2 = sorted(self.fileNameList)
- print("filenamesList:{} self.fileNameList:{} {}{}\r\n".format(filenamesList,self.fileNameList,type(filenamesList),type(self.fileNameList)))
- if list1 != list2: #传输的文件列表和BLE不一致说明有文件没有传输完成不再重启CAT1
- self.deleteTmpFile()
- self.Cat1FileState = 0
- print("self.Cat1PyFile444!!!:{}\r\n".format(self.Cat1FileState))
- self.Cat1FileTransTimer.stop()
- self.deleteUsrTmpFile()
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota end faile!")
- return
-
- try:
- copy_state = 1
- compare_flag = 1
- copy_flag = 0
- filenamesList = uos.listdir("/usr/TmpPyFile")
- for tmp in filenamesList: #将传输的文件 copy到usr目录下
- print("filenamesList for :{}\r\n".format(filenamesList))
- dst_path = "/usr/{}".format(tmp) #目标目录文件
- if ql_fs.path_exists(dst_path) == True:
- try:
- copy_flag = 1
- uos.remove(dst_path)
- except Exception as e:
- print("移除文件失败!!!!!\r\n")
- try:
- copy_flag = 1
- ql_fs.touch(dst_path,"")
- except Exception as e:
- print("创建文件失败!!!!!\r\n")
-
- if copy_flag == 0:
- print("创建文件失败!!!!!copy_flag\r\n")
- copy_state = 0
- break
- src_path = "/usr/TmpPyFile/{}".format(tmp) #源目录文件
- ret = False
- file_size = 0
-
- try:
- ret = ql_fs.file_copy(dst_path,src_path)
- print("copy ret!!!!!:{}\r\n".format(ret))
- if ret == True:
- dstfile_size = ql_fs.path_getsize(dst_path)
- srcfile_size = ql_fs.path_getsize(src_path)
-
- print("copy dstfile_size:{} srcfile_size:{}\r\n".format(dstfile_size,srcfile_size))
- if dstfile_size != srcfile_size:
- compare_flag = 0
- break
- else: #拷贝完之后比较大小一致移除文件
- try:
- compare_flag = 1
- uos.remove(src_path)
- filenamesList = uos.listdir("/usr/TmpPyFile")
- print("remove filenamesList :{}\r\n".format(filenamesList))
- except Exception as e:
- print("copy file \r\n")
- else:
- compare_flag = 0
- break
-
- except Exception as e:
- print("copy file \r\n")
-
-
- if copy_state == 0 or compare_flag == 0 : #比较失败 或者copy失败没有内存了
- self.deleteUsrTmpFile()
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota faile!22") #传输文件完之后最后提示是否成功失败
- return
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_SUCC,"ota success!") #传输文件完之后最后提示是否成功失败
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- print("重启 auto:\r\n")
- self.Cat1OtaTimeOut.stop()
- self.Cat1TimeCount = 0
- self.ota_state = 1
- self.allPyRecvFlag = 1 #所有的py文件接收完成
- self.Cat1OtaTimeOut.start(5000,0,self.otaTimeOut)
- except Exception as e:
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota faile!33") #传输文件完之后最后提示是否成功失败
- self.deleteUsrTmpFile()
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- else:
- if self.ota_state == 1:
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_SUCC,"ota success!") #传输文件完之后最后提示是否成功失败
- pass
- else:
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- self.deleteUsrTmpFile()
- print("cat1 ota\r\n")
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota end faile!")
-
-
- elif Code == BLE_START_OTA_SUCC and self.Cat1FileState == 1:
- if self.allPyRecvFlag == 0: #没有接收完成就发送OTA成功的标识
- self.deleteTmpFile()
- self.deleteUsrTmpFile()
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota end faile!")
- return
- tmp_dir = ql_fs.path_exists("/usr/TmpPyFile")
- if tmp_dir == True:
- filenamesList = uos.listdir("/usr/TmpPyFile")
- list1 = sorted(filenamesList)
- list2 = sorted(self.fileNameList)
- print("filenamesList:{} self.fileNameList:{} {}{}\r\n".format(filenamesList,self.fileNameList,type(filenamesList),type(self.fileNameList)))
- if list1 != list2: #传输的文件列表和BLE不一致说明有文件没有传输完成不再重启CAT1
- self.deleteTmpFile()
- self.Cat1FileState = 0
- print("self.Cat1PyFile444!!!:{}\r\n".format(self.Cat1FileState))
- self.Cat1FileTransTimer.stop()
- self.deleteUsrTmpFile()
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota end faile!")
- return
-
- try:
- copy_state = 1
- compare_flag = 1
- copy_flag = 0
- filenamesList = uos.listdir("/usr/TmpPyFile")
- for tmp in filenamesList: #将传输的文件 copy到usr目录下
- print("filenamesList for :{}\r\n".format(filenamesList))
- dst_path = "/usr/{}".format(tmp) #目标目录文件
- if ql_fs.path_exists(dst_path) == True:
- try:
- copy_flag = 1
- uos.remove(dst_path)
- except Exception as e:
- print("移除文件失败!!!!!\r\n")
- try:
- copy_flag = 1
- ql_fs.touch(dst_path,"")
- except Exception as e:
- print("创建文件失败!!!!!\r\n")
-
- if copy_flag == 0:
- print("创建文件失败!!!!!copy_flag\r\n")
- copy_state = 0
- break
- src_path = "/usr/TmpPyFile/{}".format(tmp) #源目录文件
- ret = False
- file_size = 0
-
- try:
- ret = ql_fs.file_copy(dst_path,src_path)
- print("copy ret!!!!!:{}\r\n".format(ret))
- if ret == True:
- dstfile_size = ql_fs.path_getsize(dst_path)
- srcfile_size = ql_fs.path_getsize(src_path)
-
- print("copy dstfile_size:{} srcfile_size:{}\r\n".format(dstfile_size,srcfile_size))
- if dstfile_size != srcfile_size:
- compare_flag = 0
- break
- else: #拷贝完之后比较大小一致移除文件
- try:
- compare_flag = 1
- uos.remove(src_path)
- filenamesList = uos.listdir("/usr/TmpPyFile")
- print("remove filenamesList :{}\r\n".format(filenamesList))
- except Exception as e:
- print("copy file \r\n")
- else:
- compare_flag = 0
- break
-
- except Exception as e:
- print("copy file \r\n")
-
-
- if copy_state == 0 or compare_flag == 0 : #比较失败 或者copy失败没有内存了
- self.deleteUsrTmpFile()
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota faile!22") #传输文件完之后最后提示是否成功失败
- return
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_SUCC,"ota success!") #传输文件完之后最后提示是否成功失败
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- print("重启 auto:\r\n")
- self.Cat1OtaTimeOut.stop()
- self.Cat1TimeCount = 0
- self.ota_bstate = 1
- self.Cat1OtaTimeOut.start(10000,0,self.otaTimeOut)
- except Exception as e:
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota faile!33") #传输文件完之后最后提示是否成功失败
- self.deleteUsrTmpFile()
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- else:
- if self.ota_bstate == 1:
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_SUCC,"ota success!") #传输文件完之后最后提示是否成功失败
- pass
- else:
- self.deleteTmpFile()
- self.Cat1FileState = 0
- self.Cat1FileTransTimer.stop()
- self.deleteUsrTmpFile()
- print("cat1 ota\r\n")
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_FALIE,"ota end faile!")
-
- elif Code == BLE_START_SEND_SINGLE_FINESH and self.Cat1FileState == 1: #单个文件传输完成
- print("BLE_START_SEND_SINGLE_FINESH {} self.fileNameTmp:{}\r\n".format(BLE_START_SEND_SINGLE_FINESH,self.fileNameTmp))
- self.Cat1PyFileTimout = FILE_TRANSFER_TIMEOUT #超时时间10s
- tmp_dir = ql_fs.path_exists("/usr/TmpPyFile")
- if tmp_dir == True:
- tmp_file = ql_fs.path_exists("/usr/TmpPyFile/{}".format(self.fileNameTmp))
- if tmp_file == True: #文件存在
- file_size = ql_fs.path_getsize("/usr/TmpPyFile/{}".format(self.fileNameTmp))
- print("file size :file_size:{} self.fileSize:{}\r\n".format(file_size,self.fileSize))
- if self.fileSize != file_size: #文件大小不一致 传输出错
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_FILE_SIZE_ERR,"file size err") #结束文件接收不完整的
- pass
- else:
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_FILE_SIZE_OK,"file size ok") #结束文件接收完整的
- pass
- else:
- self.__Socket_UDP_file_noreply(CAT1_CREAT_FILE_ERROR,"creat file or dir err!")
- pass
- else:
- self.__Socket_UDP_file_noreply(CAT1_CREAT_DIR_FAILE,"creat file or dir error!")
- pass
-
-
- else:
- if self.Cat1FileState == 0:
- if self.Cat1FileReplayBle == 1:
- return
- self.Cat1FileReplayBle = 1
- self.__Socket_UDP_file_noreply(CAT1_REPLAY_OTA_SUCC,"reset start!") #结束文件接收不完整的
- print("错误信息!!!!!\r\n")
- self.Cat1FileState == 0
- self.Cat1FileTransTimer.stop() #//关闭定时器
- self.Cat1PyFileTimout = 0
- self.fileNameList=[]
- self.deleteTmpFile()
- self.deleteUsrTmpFile()
-
-
- def otaTimeOut(self,*argc):
- print("重启成功！！！！！！！！\r\n")
- Power.powerRestart()
-
-FtpService = ftp_Service()
-
-
projects / mirrors / FD230.git / commitdiff