修改--一建处理告警接口添加可选的查询参数number

This commit is contained in:
haotian 2025-06-06 15:29:59 +08:00
parent 5ce9dc2974
commit 6f9c10b404

View File

@ -330,8 +330,18 @@ class CRUDEvent(CRUDBase[Event, EventUpdate, EventUpdate]):
):
try:
if number:
update_stmt = ()
if number and len(number) > 0:
update_stmt = (
update(Message)
.values(
handle="1",
updateTime=datetime.now()
)
.where(Message.eventId == Event.eventId) # JOIN 条件放在 where()
.where(Event.number == number) # 过滤条件
.where(Message.handle == "0") # 过滤条件
)
print(number, "number")
else:
update_stmt = (
update(Message)
@ -351,7 +361,7 @@ class CRUDEvent(CRUDBase[Event, EventUpdate, EventUpdate]):
return True
except Exception as e:
print(f"更新OCR告警消息失败: {str(e)}")
print(f"更新告警消息失败: {str(e)}")
await db.rollback()
return False
async def handle_ocr_alert(