fix

sri-server-bg02/lib/MessageListener.py

@@ -13,8 +13,6 @@ import os
 save_dir = r'C:\logs'  # sri内网测试环境
 
 
-# last_log_key = str()
-
 class MessageListener(object):
     """
     """
@@ -26,7 +24,7 @@ class MessageListener(object):
         UserWorkRecord.init()
 
         from lib.MessageListenerC001 import subscribe_c001
-        # from lib.MessageListenerV001 import subscribe_v001
+        from lib.MessageListenerV001 import subscribe_v001
 
         thread_list = [
             threading.Thread(target=subscribe_c001),

sri-server-bg02/lib/MessageListenerC001.py

@@ -72,8 +72,8 @@ def method_c001(client, userdata, message):
     }
     """
     # --- print ---
-    methods.debug_log(f"MessageListenerC001|19", f"#message.payload: {message.payload}")
-    log_dict = json.loads(message.payload)
+    methods.debug_log(f"method_c001|75", f"#message.payload: {message.payload}")
+    # log_dict = json.loads(message.payload)
     # try:
     #     log_dict = json.loads(message.payload)
     #     methods.debug_log(f"MessageListenerC001|19", f"#message.payload: {repr(log_dict)}")
@@ -146,7 +146,7 @@ def method_c001(client, userdata, message):
 
     # --- save ---
     log_file_path = os.path.join(save_dir, f'{log_uuid}.log')
-    methods.debug_log(f"MessageListener24", f"#log_list: {log_list}")
+    methods.debug_log(f"MessageListener|149", f"#log_list: {log_list}")
     methods.write_text(log_file_path, ' | '.join(log_list) + '\n', 'a')
 
 

sri-server-bg02/lib/MessageListenerV001.py

@@ -22,8 +22,8 @@ class LocalClass(object):
 def method_v001(client, userdata, message):
     """消息处理方法"""
     # --- log ---
-    # print(f'MessageListener24: #message.payload: {message.payload}', flush=True)
-    # methods.debug_log(f"MessageListener24", f"#message.payload: {message.payload}")
+    # methods.debug_log(f"method_v001|26", f"#message.payload: {message.payload}")
+    # return
 
     # --- check ---
     # if not methods.is_dir(save_dir):
@@ -32,12 +32,12 @@ def method_v001(client, userdata, message):
 
     # --- fill log_list ---
     log_dict = json.loads(message.payload)
-    log_time = int(log_dict.get('timestamp')) / 1000)
+    log_time = int(log_dict.get('timestamp')) / 1000
     user_uuid = log_dict.get('userID')
     log_uuid = UserWorkRecord.get_log_uuid(user_uuid, log_time)
     log_list = [
 
-        f"timestamp: {methods.ts_to_string(log_time}",  # 时间
+        f"timestamp: {methods.ts_to_string(log_time)}",  # 时间
         f"topic: Vehicle/ControlVehicle/Veh001",  # 话题
         # f"userID: {log_dict.get('userID')}",  # 用户id
         # f"VehicleID: {log_dict.get('VehicleID')}",  # 车id