diff --git a/s2f.py b/s2f.py index bcf8552..b4eaece 100644 --- a/s2f.py +++ b/s2f.py @@ -13,7 +13,7 @@ def save2file(data,isR=1): if not os.path.exists(p): os.makedirs(p) - l=f"{'[R]' if isR else '[T]'} - {t} --- {data.hex(' ')}\n" + l=f"{'[R]' if isR else '[T]'} - {t} --- {data}\n" f=open('/'.join(['trlog',d,'trlog.txt']),'a') f.write(l) f.close \ No newline at end of file diff --git a/server.py b/server.py index c33c140..535a367 100755 --- a/server.py +++ b/server.py @@ -285,7 +285,7 @@ def tt_hh(addr, data): msg[-1] = crc add_timestamp() addr.send(msg) - s2f.save2file(msg,0) + s2f.save2file(f"[SERVER --> {get_ccid(addr).decode() if get_ccid(addr) else 'None'}][{len(msg)}] {msg.hex(' ')}",0) logger.debug("服务器回复心跳包。") # 从缓存中匹配到数据才重发 @@ -300,7 +300,7 @@ def tt_hh(addr, data): add_timestamp() # 按缓存先后顺序发送 addr.send(msgs[i]) - s2f.save2file(msg) + s2f.save2file(f"[SERVER --> {get_ccid(addr).decode() if get_ccid(addr) else 'None'}][{len(msg)}] {msg.hex(' ')}") time.sleep(1) # 成功则清空已发送成功的缓存数据 cache[ccid].pop(0) @@ -378,7 +378,7 @@ def tt_trans(addr, data): try: add_timestamp() taddr.send(msg) - s2f.save2file(msg,0) + s2f.save2file(f"[SERVER --> {get_ccid(taddr).decode() if get_ccid(taddr) else 'None'}][{len(msg)}] {msg.hex(' ')}",0) logger.info(f"数据发送成功。 {sccid} --> {tccid}") s2wx("","",f"匹配到在线终端, 数据发送成功。 \n{sccid.decode()} ---> {tccid.decode()}") except Exception: @@ -428,7 +428,7 @@ def data_split(addr): for i in range(len(dlist)): flen = (dlist[i][5]<<8)+dlist[i][6] if flen != len(dlist[i]) : - logger.error("第{}数据帧不完整{}--{}",i+1,flen,len(dlist[i])) + logger.warning("第{}数据帧不匹配,应收{}<-->实收{}",i+1,flen,len(dlist[i])) # 清空缓存 recCache[addr].clear() @@ -436,7 +436,7 @@ def data_split(addr): # 因为无帧尾,需添加帧是否完整的校验 if len(dlist) : # 目前情形多为两包粘包,故最后一包肯定不完整 - logger.debug(bytes(dlist[-1]).hex(" ")) + # logger.debug(bytes(dlist[-1]).hex(" ")) flen = (dlist[-1][5]<<8)+dlist[-1][6] if flen <= len(dlist[-1]) : recCache[addr].extend(dlist[-1][flen:]) @@ -512,7 +512,7 @@ class MyServer(socketserver.BaseRequestHandler): add_timestamp() self.recDataBuff.extend(data) # logger.debug("[R] {}",data.hex(" ")) - s2f.save2file(data) + s2f.save2file(f"[{get_ccid(conn).decode() if get_ccid(conn) else 'None'} --> SERVER][{len(data)}] {data.hex(' ')}") t = f"从{str(self.client_address)}<->[{get_ccid(conn).decode() if get_ccid(conn) else 'None'}]接收到新数据,长度{len(data)}字节。" logger.info(t) logger.debug("[R] - {}",data.hex(" "))