|
|
@@ -481,6 +481,36 @@ async def list_registered(
|
|
|
"data": data
|
|
|
}
|
|
|
|
|
|
+# 列出有个不分页的查询 不是临时事件、未结束、未关闭的事件列表接口
|
|
|
+@router.post("/list_active")
|
|
|
+async def list_active(
|
|
|
+ request: Request,
|
|
|
+ db: Session = Depends(get_db)
|
|
|
+):
|
|
|
+ where = and_(EventBase.del_flag == '0', EventBase.event_status.in_(['0', '1']))
|
|
|
+ rows = db.query(EventBase).filter(where).order_by(EventBase.event_time.asc()).all()
|
|
|
+ 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)
|
|
|
+ }
|
|
|
+ for row in rows
|
|
|
+ ]
|
|
|
+
|
|
|
+ # 返回结果
|
|
|
+ return {
|
|
|
+ "code": 200,
|
|
|
+ "msg": "查询成功",
|
|
|
+ "data": data
|
|
|
+ }
|
|
|
+
|
|
|
# 将临时事件绑定成正式事件
|
|
|
@router.post("/update_event_id")
|
|
|
async def update_event_id(
|
