python/config.ini

@@ -4,7 +4,7 @@ app_name=智慧拍-后端应用
 # 应用版本号
 version=1.0.0
 # 应用host地址
-host=10.56.42.176
+host=127.0.0.1
 # 应用服务启动名称
 app_run=api:app
 # 端口号
@@ -19,4 +19,6 @@ log_file_name=app.log
 #最大字节数
 max_bytes=102400 
 #备份数量
-backup_counts=3 
+backup_counts=3
+# 地址
+hlm_host=https://dev2.pubdata.cn

python/index.py

@@ -1,3 +1,4 @@
+import asyncio
 import sys
 import uvicorn
 import signal
@@ -8,6 +9,8 @@ import uvicorn.protocols.http.auto
 import uvicorn.protocols.websockets.auto
 import uvicorn.lifespan.on
 from multiprocessing import Process, freeze_support
+from service.init_load_source import init_load_source
+
 
 def handle_shutdown(signum, frame):
     """关闭系统应用服务"""
@@ -16,18 +19,26 @@ def handle_shutdown(signum, frame):
     loop.call_soon_threadsafe(loop.stop)
     sys.exit(0)
 
-if __name__ == "__main__":
-    signal.signal(signal.SIGINT, handle_shutdown)
-    signal.signal(signal.SIGTERM, handle_shutdown)
-    # 控制台默认关闭输出信息，如果想要查看控制台输出，请单独启动服务 npm run dev-python
-    print("python server is running at port:", PORT)
-    # uvicorn会多创建一个进程，并且stdio独立于控制台，如果（开发时）出现进程没有关闭，可尝试关闭终端
-    print("python server is running at port:", APP_RUN)
-    isDebug = True if IS_DEBUG == "true" else False
-    uvicorn.run(
+async def run_server():
+    # 启动uvicorn服务器
+    config = uvicorn.Config(
         APP_RUN,
         host=APP_HOST,
         port=int(PORT),
         reload=isDebug,
         workers=int(APP_WORKS),
     )
+    server = uvicorn.Server(config)
+    await server.serve()
+
+async def main():
+    await  asyncio.gather(run_server(), init_load_source().load_source())
+
+
+if __name__ == "__main__":
+    signal.signal(signal.SIGINT, handle_shutdown)
+    signal.signal(signal.SIGTERM, handle_shutdown)
+    print("python server is running at port:", PORT)
+    print("python server is running at port:", APP_RUN)
+    isDebug = True if IS_DEBUG == "true" else False
+    asyncio.run(main())

python/service/init_load_source.py

@@ -0,0 +1,79 @@
+import asyncio
+import json
+import time
+from settings import HLM_HOST
+import aiohttp
+import os
+from utils.utils_func import get_md5, get_modified_time, compare_two_times, check_path
+
+class init_load_source:
+
+    async def load_source(self):
+        await self.down_resouce()
+
+    async def down_resouce(self):
+        response_data = await self.get_update_file()
+        if response_data:
+            for relative_file_path, value in response_data.items():
+                file_path = f"{os.getcwd()}/{relative_file_path}"
+                if os.path.exists(file_path):
+                    file_md5 = get_md5(file_path)
+                    if file_md5 != value["file_md5"]:
+                        print(f"md5 不同 开始下载：{file_path}")
+                        await self.async_download_file(value["url"], file_path)
+                    else:
+                        pass
+                else:
+                    print(f"文件不存在 开始下载：{file_path}")
+                    await self.async_download_file(value["url"], file_path)
+        else:
+            print("获取更新文件内容失败")
+
+    async def get_update_file(self, type="client_camera", plugins_name="plugins_A"):
+        """异步获取指定类型的插件文件更新信息
+
+        Args:
+            type (str, optional): 设备类型标识，默认为"client_camera"
+            plugins_name (str, optional): 需要查询的插件名称，默认为"plugins_A"
+
+        Returns:
+            dict or None: 成功时返回插件文件的JSON数据，失败或未找到时返回None
+        """
+        url = HLM_HOST + "/api/openai/query_client_addons"
+        params = {"type": type}
+        try:
+            async with aiohttp.ClientSession() as session:
+                # 发送初始请求获取插件列表数据
+                async with session.get(url, params=params, timeout=10) as response:
+                    response.raise_for_status()
+                    raw_data = await response.json()
+
+                    if not raw_data or not raw_data.get("data"):
+                        return None
+
+                # 从插件列表中查找匹配的插件项
+                item = next(
+                    (item for item in raw_data["data"]["list"] if item["name"] == plugins_name),
+                    None
+                )
+                if item:
+                    # 根据插件项中的URL获取具体文件内容
+                    url = item["url"]
+                    async with session.get(url, timeout=10) as item_response:
+                        item_response.raise_for_status()
+                        return await item_response.json()
+                return None
+        except Exception as e:
+            print(f"An error occurred: {e}")
+            return None
+
+
+    async def async_download_file(self, url: str, file_path: str):
+        """异步下载文件"""
+        async with aiohttp.ClientSession() as session:
+            async with session.get(url) as response:
+                root_path, file_name = os.path.split(file_path)
+                check_path(root_path)
+                with open(file_path, 'wb') as f:
+                    async for chunk in response.content.iter_chunked(1024):
+                        f.write(chunk)

python/settings.py

@@ -27,3 +27,5 @@ MAX_BYTES = config.get("log", "max_bytes")
 print("Max bytes is", MAX_BYTES)
 # 备份数量
 BACKUP_COUNTS = config.get("log", "backup_counts")
+# 远程服务器地址
+HLM_HOST = config.get("log", "hlm_host")

python/utils/utils_func.py

@@ -0,0 +1,61 @@
+
+import os
+from hashlib import sha256, md5
+from datetime import datetime
+import requests
+
+def get_md5(file_path):
+    data_md5 = None
+    if os.path.isfile(file_path):
+        f = open(file_path, 'rb')
+        md5_obj = md5()
+        md5_obj.update(f.read())
+        hash_code = md5_obj.hexdigest()
+        f.close()
+        data_md5 = str(hash_code).lower()
+    return data_md5
+
+def get_modified_time(file_path):
+    # 获取文件最后修改的时间戳
+    timestamp = os.path.getmtime(file_path)
+    # 将时间戳转换为datetime对象，并格式化为指定格式的字符串
+    modified_time = datetime.fromtimestamp(timestamp).strftime('%Y-%m-%d %H:%M:%S')
+    return modified_time
+
+def compare_two_times(time_str1, time_str2):
+    # 定义时间格式
+    time_format = "%Y-%m-%d %H:%M:%S"
+    # 将时间字符串解析为datetime对象
+    time1 = datetime.strptime(time_str1, time_format)
+    time2 = datetime.strptime(time_str2, time_format)
+
+    # 比较两个时间
+    if time1 > time2:
+        # print(f"{time_str1} 比 {time_str2} 新。")
+        return "left_new"
+    elif time1 < time2:
+        # print(f"{time_str2} 比 {time_str1} 新。")
+        return "right_new"
+    else:
+        # print("两个时间相等。")
+        return "is_same"
+
+
+async def download_file(url, file_path):
+    try:
+        root_path, file_name = os.path.split(file_path)
+        check_path(root_path)
+        response = requests.get(url)
+        _content = response.content
+        with open(file_path, 'wb') as f:
+            f.write(_content)
+        print("下载成功:{}".format(file_path))
+    except:
+        print("下载失败:{}".format(file_path))
+
+def check_path(_path):
+    if not os.path.exists(_path):
+        # 创建多级目录
+        os.makedirs(_path, exist_ok=True)
+        # os.mkdir(_path)
+    return True