diff --git a/app/crud/event.py b/app/crud/event.py index 77f3ce6..0837a0d 100644 --- a/app/crud/event.py +++ b/app/crud/event.py @@ -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(