Skip to content

Commit 31c9f9a

Browse files
committed
物料更新也是用父节点进行报送
1 parent 02cd8de commit 31c9f9a

File tree

4 files changed

+114
-88
lines changed

4 files changed

+114
-88
lines changed

unilabos/app/ws_client.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -848,7 +848,7 @@ async def _handle_resource_tree_update(self, resource_uuid_list: List[WSResource
848848
device_action_groups[key_add].append(item["uuid"])
849849

850850
logger.info(
851-
f"[MessageProcessor] Resource migrated: {item['uuid'][:8]} from {device_old_id} to {device_id}"
851+
f"[资源同步] 跨站Transfer: {item['uuid'][:8]} from {device_old_id} to {device_id}"
852852
)
853853
else:
854854
# 正常update
@@ -863,11 +863,11 @@ async def _handle_resource_tree_update(self, resource_uuid_list: List[WSResource
863863
device_action_groups[key] = []
864864
device_action_groups[key].append(item["uuid"])
865865

866-
logger.info(f"触发物料更新 {action} 分组数量: {len(device_action_groups)}, 总数量: {len(resource_uuid_list)}")
866+
logger.trace(f"[资源同步] 动作 {action} 分组数量: {len(device_action_groups)}, 总数量: {len(resource_uuid_list)}")
867867

868868
# 为每个(device_id, action)创建独立的更新线程
869869
for (device_id, actual_action), items in device_action_groups.items():
870-
logger.info(f"设备 {device_id} 物料更新 {actual_action} 数量: {len(items)}")
870+
logger.trace(f"[资源同步] {device_id} 物料动作 {actual_action} 数量: {len(items)}")
871871

872872
def _notify_resource_tree(dev_id, act, item_list):
873873
try:

unilabos/resources/resource_tracker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1143,7 +1143,7 @@ def remove_resource(self, resource) -> bool:
11431143
for key in keys_to_remove:
11441144
self.resource2parent_resource.pop(key, None)
11451145

1146-
logger.debug(f"成功移除资源: {resource}")
1146+
logger.trace(f"[ResourceTracker] 成功移除资源: {resource}")
11471147
return True
11481148

11491149
def clear_resource(self):

0 commit comments

Comments
 (0)