Compare commits
1 Commits
11f1c4f55b
...
c875cf383b
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c875cf383b |
@@ -187,21 +187,11 @@ async def handle_heartbeat(data: dict) -> str | None:
|
||||
|
||||
|
||||
def handle_timestamp(data: dict) -> str:
|
||||
"""处理时间同步请求
|
||||
|
||||
TimeStamp 请求格式:
|
||||
{
|
||||
"Method": "TimeStamp",
|
||||
"Params": {
|
||||
"Device_id": "2345",
|
||||
"TimeZone": "Asia/Shanghai"
|
||||
}
|
||||
}
|
||||
|
||||
返回格式参考 PGLC 协议 3.5 节。
|
||||
"""
|
||||
"""处理时间同步请求(也是设备交互)"""
|
||||
params = data.get("Params", {})
|
||||
device_id = params.get("Device_id", "")
|
||||
if device_id:
|
||||
record_interaction(device_id)
|
||||
return make_timestamp_response(device_id, int(time.time()))
|
||||
|
||||
|
||||
|
||||
@@ -37,6 +37,7 @@ from src.handlers import (
|
||||
device_status_monitor,
|
||||
set_udp_sender,
|
||||
)
|
||||
from src.models import insert_device_log
|
||||
|
||||
logging.basicConfig(
|
||||
level=getattr(logging, LOG_LEVEL),
|
||||
@@ -75,6 +76,7 @@ class EDCProtocol:
|
||||
logger.info(f"UDP {msg} from {addr}")
|
||||
|
||||
method = msg.get("Method", "")
|
||||
method_lower = method.lower()
|
||||
logger.debug(f"UDP {method} from {addr}")
|
||||
|
||||
try:
|
||||
@@ -82,11 +84,11 @@ class EDCProtocol:
|
||||
if method == "Count_Off":
|
||||
# 设备登录上报,只处理不回复
|
||||
await handle_count_off(msg, addr)
|
||||
elif method == "Heartbeat":
|
||||
elif method_lower == "heartbeat":
|
||||
response = await handle_heartbeat(msg)
|
||||
elif method == "TSReport":
|
||||
elif method_lower == "tsreport":
|
||||
response = await handle_tsreport(msg)
|
||||
elif method == "SerialNet":
|
||||
elif method_lower == "serialnet":
|
||||
response = await handle_serial_net(msg)
|
||||
|
||||
if response and self.transport:
|
||||
@@ -105,24 +107,36 @@ async def handle_tcp_client(reader: asyncio.StreamReader,
|
||||
- 紧凑 JSON (无换行)
|
||||
"""
|
||||
addr = writer.get_extra_info("peername")
|
||||
addr_ip = addr[0] if addr else ""
|
||||
logger.info(f"TCP 连接: {addr}")
|
||||
|
||||
# TCP 连接事件日志
|
||||
try:
|
||||
asyncio.ensure_future(insert_device_log(
|
||||
serial="", ip=addr_ip,
|
||||
event_type="tcp_connect",
|
||||
content=f"TCP 连接: {addr}",
|
||||
))
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
buffer = b""
|
||||
|
||||
async def process_message(msg: dict):
|
||||
"""处理单条消息并返回响应文本"""
|
||||
logger.info(f"TCP get_rcv {msg} from {addr}")
|
||||
method = msg.get("Method", "")
|
||||
method_lower = method.lower()
|
||||
logger.debug(f"TCP {method} from {addr}")
|
||||
|
||||
try:
|
||||
if method == "TimeStamp":
|
||||
if method_lower == "timestamp":
|
||||
return handle_timestamp(msg)
|
||||
elif method == "TSReport":
|
||||
elif method_lower == "tsreport":
|
||||
return await handle_tsreport(msg)
|
||||
elif method == "SerialNet":
|
||||
elif method_lower == "serialnet":
|
||||
return await handle_serial_net(msg)
|
||||
elif method == "Heartbeat":
|
||||
elif method_lower == "heartbeat":
|
||||
return await handle_heartbeat(msg)
|
||||
else:
|
||||
logger.debug(f"TCP 未知方法: {method}")
|
||||
@@ -176,6 +190,15 @@ async def handle_tcp_client(reader: asyncio.StreamReader,
|
||||
pass
|
||||
finally:
|
||||
logger.info(f"TCP 断开: {addr}")
|
||||
# TCP 断开事件日志
|
||||
try:
|
||||
asyncio.ensure_future(insert_device_log(
|
||||
serial="", ip=addr_ip,
|
||||
event_type="tcp_disconnect",
|
||||
content=f"TCP 断开: {addr}",
|
||||
))
|
||||
except Exception:
|
||||
pass
|
||||
writer.close()
|
||||
await writer.wait_closed()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user