From ef1eb698617843ac91515cb83aa5000562eaa642 Mon Sep 17 00:00:00 2001 From: DXY <1731678236@qq.com> Date: Wed, 21 Aug 2024 18:56:43 +0800 Subject: [PATCH] =?utf8?q?=E5=88=A0=E9=99=A4=E6=96=87=E4=BB=B6=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- cat1modem/src/ftpService.py | 694 ------------------------------------ 1 file changed, 694 deletions(-) delete mode 100644 cat1modem/src/ftpService.py diff --git a/cat1modem/src/ftpService.py b/cat1modem/src/ftpService.py deleted file mode 100644 index 996a154e3..000000000 --- a/cat1modem/src/ftpService.py +++ /dev/null @@ -1,694 +0,0 @@ -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() - - -- 2.17.1