zhaoziyi/jiuxing_analysis
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
MATRIX\29620 2025-03-28 17:56:56 +08:00
parent 04271e628a
commit d5b2ccd0b2
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
charging_pile_proxy/hejin_forward/charge_order_processor.py
View File

@ -1,4 +1,4 @@
import taosrest # 使用 taosrest 连接 TDengine import taosrest
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
import binascii import binascii
import json import json
@ -118,7 +118,6 @@ class ChargingPileProcessor:
return None return None
def parse_message(self, data): def parse_message(self, data):
"""根据协议解析充电桩报文"""
if not data or len(data) < 1: if not data or len(data) < 1:
logging.error("报文数据无效。") logging.error("报文数据无效。")
return None return None
@ -126,7 +125,6 @@ class ChargingPileProcessor:
# 检查报文类型（第一个字节） # 检查报文类型（第一个字节）
msg_type = data[0] msg_type = data[0]
if msg_type != 0x23: # 23H 最新充电订单 if msg_type != 0x23: # 23H 最新充电订单
# 仅在第一次遇到该类型时记录跳过日志
if msg_type not in self.skipped_msg_types: if msg_type not in self.skipped_msg_types:
logging.info(f"报文类型 {hex(msg_type)} 不是充电订单（23H），跳过。") logging.info(f"报文类型 {hex(msg_type)} 不是充电订单（23H），跳过。")
self.skipped_msg_types.add(msg_type) self.skipped_msg_types.add(msg_type)