dzxj_dtu/backend/config.py

"""
系统配置文件
用于管理系统参数，如缓冲区大小、超时设置等
"""

import os
from dotenv import load_dotenv

# 加载环境变量
load_dotenv()

# 缓冲区配置
MAX_BUFFER_SIZE = 1000  # 数据缓冲区最大条目数
SERIAL_READ_BUFFER_SIZE = 4096  # 串口读取缓冲区大小（字节）

# 串口配置
DEFAULT_BAUDRATE = 9600  # 默认波特率
DEFAULT_SERIAL_TIMEOUT = 1  # 默认串口超时时间（秒）
SERIAL_RECONNECT_INTERVAL = 5  # 串口重连间隔（秒）
SERIAL_RECONNECT_MAX_RETRIES = 5  # 串口最大重连次数

# MQTT配置
DEFAULT_MQTT_PORT = 1883  # 默认MQTT端口
DEFAULT_MQTT_TLS_PORT = 8883  # 默认MQTT TLS端口
DEFAULT_MQTT_KEEPALIVE = 60  # 默认MQTT心跳时间（秒）
MQTT_RECONNECT_INTERVAL = 5  # MQTT重连间隔（秒）
MQTT_RECONNECT_MAX_RETRIES = 5  # MQTT最大重连次数
DEFAULT_MQTT_CLIENT_ID_PREFIX = "serial_mqtt_gateway_"  # 默认MQTT客户端ID前缀
DEFAULT_MQTT_PUBLISH_TOPIC = "serial/data"  # 默认MQTT发布主题
DEFAULT_MQTT_SUBSCRIBE_TOPIC = "command/serial"  # 默认MQTT订阅主题

# WebSocket配置
SOCKETIO_ASYNC_MODE = 'threading'  # SocketIO异步模式
SOCKETIO_MESSAGE_QUEUE = None  # SocketIO消息队列，生产环境可配置Redis
SOCKETIO_TRANSPORTS = ['websocket', 'polling']  # SocketIO传输方式
SOCKETIO_ALLOWED_ORIGINS = '*'  # SocketIO允许的来源

# Flask配置
FLASK_SECRET_KEY = os.getenv('FLASK_SECRET_KEY', 'serial_mqtt_gateway_secret_key')
FLASK_DEBUG = os.getenv('FLASK_DEBUG', 'False').lower() == 'true'
FLASK_HOST = os.getenv('FLASK_HOST', '0.0.0.0')
FLASK_PORT = int(os.getenv('FLASK_PORT', '5001'))

# 日志配置
LOG_LEVEL = os.getenv('LOG_LEVEL', 'INFO')
LOG_FORMAT = '%(asctime)s - %(name)s - %(levelname)s - %(message)s'
LOG_FILE = os.getenv('LOG_FILE', None)  # 如果设置了值，则将日志写入文件

# 性能配置
MAX_CONCURRENT_SOCKETIO_CLIENTS = 100  # 最大并发SocketIO客户端数
SOCKETIO_HEARTBEAT_INTERVAL = 25  # SocketIO心跳间隔（秒）
SOCKETIO_HEARTBEAT_TIMEOUT = 30  # SocketIO心跳超时（秒）

# 转发配置
DEFAULT_FORWARD_SERIAL_TO_MQTT = False  # 默认是否启用串口到MQTT转发
DEFAULT_FORWARD_MQTT_TO_SERIAL = False  # 默认是否启用MQTT到串口转发

# 主题配置
SOCKETIO_NAMESPACE_DATA = '/data'  # 数据命名空间
SOCKETIO_NAMESPACE_STATUS = '/status'  # 状态命名空间
SOCKETIO_NAMESPACE_CONTROL = '/control'  # 控制命名空间

# API路径配置
API_PREFIX = '/api'
API_SERIAL_PREFIX = f'{API_PREFIX}/serial'
API_MQTT_PREFIX = f'{API_PREFIX}/mqtt'
API_DATA_PREFIX = f'{API_PREFIX}/data'
API_FORWARD_PREFIX = f'{API_PREFIX}/forward'
API_HEALTH = f'{API_PREFIX}/health'

# 错误码定义
ERROR_CODES = {
    'SUCCESS': 0,
    'SERIAL_CONNECTION_ERROR': 1001,
    'SERIAL_SEND_ERROR': 1002,
    'SERIAL_RECEIVE_ERROR': 1003,
    'MQTT_CONNECTION_ERROR': 2001,
    'MQTT_PUBLISH_ERROR': 2002,
    'MQTT_SUBSCRIBE_ERROR': 2003,
    'CONFIG_ERROR': 3001,
    'NETWORK_ERROR': 4001,
    'UNKNOWN_ERROR': 9999
}

# 错误消息定义
ERROR_MESSAGES = {
    ERROR_CODES['SUCCESS']: '成功',
    ERROR_CODES['SERIAL_CONNECTION_ERROR']: '串口连接失败',
    ERROR_CODES['SERIAL_SEND_ERROR']: '串口发送数据失败',
    ERROR_CODES['SERIAL_RECEIVE_ERROR']: '串口接收数据失败',
    ERROR_CODES['MQTT_CONNECTION_ERROR']: 'MQTT连接失败',
    ERROR_CODES['MQTT_PUBLISH_ERROR']: 'MQTT发布消息失败',
    ERROR_CODES['MQTT_SUBSCRIBE_ERROR']: 'MQTT订阅主题失败',
    ERROR_CODES['CONFIG_ERROR']: '配置错误',
    ERROR_CODES['NETWORK_ERROR']: '网络错误',
    ERROR_CODES['UNKNOWN_ERROR']: '未知错误'
}