|

sri-server-bg02/lib/MessageListener.py

@@ -4,6 +4,12 @@ import threading
 import time
 import json
 
+# for linux
+save_dir = f"/home/server/logs"
+
+# for windows
+save_dir = r'C:\SRI-DINO.Server-py\logs'
+
 
 class MessageListener(object):
     """
@@ -13,7 +19,7 @@ class MessageListener(object):
     def decorate_method(client, userdata, message):
         """消息处理方法"""
         file_name = methods.now_string('%Y-%m-%d.log')
-        log_file_path = f"/home/server/logs/{file_name}"
+        log_file_path = f"{save_dir}/{file_name}"
         log_dict = json.loads(message.payload)
         # methods.debug_log(f"MessageListener.20", f"#log_dict: {log_dict}")
 
@@ -22,16 +28,15 @@ class MessageListener(object):
             v = str(log_dict.get(str(i)))
             log_list.append(v)
         methods.write_text(log_file_path, '|'.join(log_list) + '\n', 'a')
-        methods.debug_log(f"MessageListener.24", f"#message.payload: {json.loads(message.payload)}")
+        methods.debug_log(f"MessageListener25", f"#message.payload: {json.loads(message.payload)}")
 
     @classmethod
     def start_check_loop(cls):
-
+        """"""
         # --- check ---
-        save_dir = f"/home/server/logs"
-        if not methods.is_dir(save_dir):
-            out = methods.run_command(f'mkdir -p {save_dir}', callback=True)
-            methods.debug_log('MessageListener.33', f"#out: {out}")
+        # if not methods.is_dir(save_dir):
+        #     out = methods.run_command(f'mkdir -p {save_dir}', callback=True)
+        #     methods.debug_log('MessageListener33', f"#out: {out}")
 
         Global.emqx.start_subscribe_loop(
             decorate_method=MessageListener.decorate_method,

sri-server-bg02/main.py

@@ -1,21 +1,27 @@
 # from app import generate_app
 # app = generate_app()
+import traceback
+
 
 def main():
-    # 定时任务
-    from lib.JobManage import JobManage
-    JobManage.run()
+    try:
+        # 定时任务
+        from lib.JobManage import JobManage
+        JobManage.run()
 
-    # 监听mqtt消息服务
-    from lib.MessageListener import MessageListener
-    MessageListener.run_background(background_is=False)
+        # 监听mqtt消息服务
+        from lib.MessageListener import MessageListener
+        MessageListener.run_background(background_is=False)
 
-    # 给websocket发数据的
-    # from factories.line_manage import LineManage
-    # LineManage.run_background()
+        # 给websocket发数据的
+        # from factories.line_manage import LineManage
+        # LineManage.run_background()
 
-    # websocket服务 与 api服务
-    # app.run(address='0.0.0.0', port=5042, debug=True)
+        # websocket服务 与 api服务
+        # app.run(address='0.0.0.0', port=5042, debug=True)
+    except Exception as exception:
+        print(f"main23: {exception.__class__.__name__}")
+        print(f"main23: {traceback.format_exc()}")
 
 
 if __name__ == '__main__':