功能:启用工单创建,VLM复核通过后自动调IoT创建工单并存orderId

This commit is contained in:
2026-03-23 11:48:02 +08:00
parent 2dccb75dcb
commit bbcd2e5bbe

View File

@@ -163,30 +163,30 @@ async def process_alarm_notification(alarm_data: Dict):
else:
logger.warning(f"个人卡片发送失败: {alarm_id}")
# ---- 4. 创建安保工单(暂未上线,待本地测试通过后启用) ----
# wo_client = get_work_order_client()
# if wo_client.enabled:
# wo_area_id = _get_alarm_area_id(alarm_id) or area_id_int
# if wo_area_id:
# type_name = ALARM_TYPE_NAMES.get(alarm_type, alarm_type)
# wo_title = f"{type_name}告警"
# trigger_source = _get_trigger_source(alarm_id)
# permanent_url = _get_permanent_url(snapshot_url)
# order_id = await wo_client.create_order(
# title=wo_title,
# area_id=wo_area_id,
# alarm_id=alarm_id,
# alarm_type=type_name,
# description=description,
# priority=alarm_level,
# trigger_source=trigger_source,
# camera_id=device_id,
# image_url=permanent_url,
# )
# if order_id:
# _save_order_id(alarm_id, order_id)
# else:
# logger.warning(f"告警无 area_id跳过工单创建: {alarm_id}")
# ---- 4. 创建安保工单 ----
wo_client = get_work_order_client()
if wo_client.enabled:
wo_area_id = _get_alarm_area_id(alarm_id) or area_id_int
if wo_area_id:
type_name = ALARM_TYPE_NAMES.get(alarm_type, alarm_type)
wo_title = f"{type_name}告警"
trigger_source = _get_trigger_source(alarm_id)
permanent_url = _get_permanent_url(snapshot_url)
order_id = await wo_client.create_order(
title=wo_title,
area_id=wo_area_id,
alarm_id=alarm_id,
alarm_type=type_name,
description=description,
priority=alarm_level,
trigger_source=trigger_source,
camera_id=device_id,
image_url=permanent_url,
)
if order_id:
_save_order_id(alarm_id, order_id)
else:
logger.warning(f"告警无 area_id跳过工单创建: {alarm_id}")
except Exception as e:
logger.error(f"告警通知处理失败: {alarm_id}, error={e}", exc_info=True)