no message

routers/api/eventManagement/event.py

@@ -471,6 +471,66 @@ async def list_registered(
         "data": data
     }
 
+# 将临时事件绑定成正式事件
+@router.post("/update_event_id")
+async def update_event_id(
+    request: Request,  
+    body = Depends(remove_xss_json), 
+    db: Session = Depends(get_db)
+):
+    temp_event_id = body['temp_event_id'] # 临时事件ID
+    event_id = body['event_id'] # 正式（未开始指挥）事件ID
+
+    row = db.query(EventBase).filter(EventBase.event_code == event_id).first()
+    if row is not None:
+        info = get_model_dict(row)
+
+        row = db.query(EventBase).filter(and_(EventBase.event_code == temp_event_id,  EventBase.event_status == "0")).first()
+        if row is not None:
+            # 目前只是改变名称和事发地址
+            row.event_title = info['event_title']
+            row.del_flag = '0' # 正式事件
+
+            if row.address == "":
+                row.address = info['address']
+                row.longitude = info['longitude']
+                row.latitude = info['latitude']
+            db.commit()
+
+            # 把之前的事件ID改为已删除
+            db.query(EventBase).filter(EventBase.event_code == event_id).update({"del_flag": "2"})
+            db.commit()
+
+            # 返回当前事件信息
+            row = db.query(EventBase).filter(EventBase.event_code == temp_event_id).first()
+            data = {
+                "event_id": row.event_code,
+                "event_title": row.event_title,
+                "event_type": row.event_type,
+                "event_level": row.event_level,
+                "event_status": row.event_status,
+                "latitude": row.latitude,
+                "longitude": row.longitude,
+                "address": row.address,
+                "event_time": get_datetime_str(row.event_time)
+            }
+
+            return {
+                "code": 200,
+                "msg": "绑定成功",
+                "data": data
+            }
+    
+    return {
+        "code": 500,
+        "msg": "查询错误，事件不存在"
+    }
+
+
+
+    
+
+
 # 登记事发地点
 @router.post("/save_address")
 async def list_registered(
@@ -752,4 +812,5 @@ def get_sent_status_text(sent_status) -> str:
         return '发送失败'
     else:
         return str(sent_status)
-    
+    
+