do not modify globally

This commit is contained in:
Xuwznln
2025-12-26 02:31:23 +08:00
parent 7e9e93b29c
commit 3433766bc5

View File

@@ -4,7 +4,6 @@ HTTP客户端模块
提供与远程服务器通信的客户端功能只有host需要用 提供与远程服务器通信的客户端功能只有host需要用
""" """
from copy import deepcopy
import json import json
import os import os
import time import time
@@ -76,26 +75,6 @@ class HTTPClient:
Returns: Returns:
Dict[str, str]: 旧UUID到新UUID的映射关系 {old_uuid: new_uuid} Dict[str, str]: 旧UUID到新UUID的映射关系 {old_uuid: new_uuid}
""" """
# 遍历 resources 及其所有子节点,将 pose.position.y 全部变为 -y
def invert_x_position(resource_instance, size_y: float = 0):
# 处理当前节点
pose = getattr(resource_instance.res_content, "pose", None)
if pose and hasattr(pose, "position"):
position = getattr(pose, "position", None)
pose_size = getattr(pose, "size", None)
if position and hasattr(position, "y") and pose_size and hasattr(pose_size, "height"):
position.y = size_y - position.y - pose_size.height
# 递归处理子节点
for child in getattr(resource_instance, "children", []):
_size_y = 0
if pose and hasattr(pose, "size"):
_size_y = pose.size.height
invert_x_position(child, _size_y)
# 处理所有树的所有节点,从树的根节点递归
resources_reversed = deepcopy(resources)
for tree in getattr(resources_reversed, "trees", []):
invert_x_position(getattr(tree, "root_node", tree))
with open(os.path.join(BasicConfig.working_dir, "req_resource_tree_add.json"), "w", encoding="utf-8") as f: with open(os.path.join(BasicConfig.working_dir, "req_resource_tree_add.json"), "w", encoding="utf-8") as f:
payload = {"nodes": [x for xs in resources.dump() for x in xs], "mount_uuid": mount_uuid} payload = {"nodes": [x for xs in resources.dump() for x in xs], "mount_uuid": mount_uuid}
f.write(json.dumps(payload, indent=4)) f.write(json.dumps(payload, indent=4))
@@ -106,14 +85,14 @@ class HTTPClient:
info(f"首次添加资源,当前远程地址: {self.remote_addr}") info(f"首次添加资源,当前远程地址: {self.remote_addr}")
response = requests.post( response = requests.post(
f"{self.remote_addr}/edge/material", f"{self.remote_addr}/edge/material",
json={"nodes": [x for xs in resources_reversed.dump() for x in xs], "mount_uuid": mount_uuid}, json={"nodes": [x for xs in resources.dump() for x in xs], "mount_uuid": mount_uuid},
headers={"Authorization": f"Lab {self.auth}"}, headers={"Authorization": f"Lab {self.auth}"},
timeout=60, timeout=60,
) )
else: else:
response = requests.put( response = requests.put(
f"{self.remote_addr}/edge/material", f"{self.remote_addr}/edge/material",
json={"nodes": [x for xs in resources_reversed.dump() for x in xs], "mount_uuid": mount_uuid}, json={"nodes": [x for xs in resources.dump() for x in xs], "mount_uuid": mount_uuid},
headers={"Authorization": f"Lab {self.auth}"}, headers={"Authorization": f"Lab {self.auth}"},
timeout=10, timeout=10,
) )