新版L2与老版L2模式切换

Administrator

2025-03-11 2c04737679957659e3eae0e3b69469ae5d7c5095

 l2/subscript/l2_subscript_manager.py

@@ -5,11 +5,14 @@
import multiprocessing
import random
import threading
import time

import msgpack
import zmq

from huaxin_client import l2_data_transform_protocol
from log_module import async_log_util
from log_module.log import logger_debug
from utils import shared_memery_util

process_manager = None
@@ -85,6 +88,8 @@
    L2数据监听
    """

    last_log_time = time.time()

    def __init__(self, channel_list):
        """

@@ -123,10 +128,14 @@
        while True:
            data = socket.recv()
            try:
                #接收数据
                # 接收数据
                data = msgpack.unpackb(data)
                shared_memery_id = data["data"]["memery_number"]
                datas = shared_memery_util.read_datas(self.shared_memery_num_object_dict.get(shared_memery_id))

                if time.time() - self.last_log_time > 10:
                    async_log_util.info(logger_debug, f"L2-V2获取到数据：{datas}")
                    self.last_log_time = time.time()
                if data["type"] == 1:
                    # 委托
                    code, data_list, timestamp = datas[0], datas[1], datas[2]