浏览代码

no message

libushang 8 月之前
父节点
当前提交
9a1f824c2d
共有 2 个文件被更改,包括 8 次插入3 次删除
  1. 2 2
      routers/api/emergencyPlans/__init__.py
  2. 6 1
      routers/api/infoPublish/back.py

+ 2 - 2
routers/api/emergencyPlans/__init__.py

@@ -282,7 +282,7 @@ async def create_emergency_plan(
         publish_date = form_data.publishDate  # 如果没有提供发布日期,则使用当前时间
         organizing_unit = form_data.organizingUnit  # 使用用户位置作为编制单位
         document_number = form_data.document
-        event_type = form.event_type
+        event_type = form_data.event_type
 
         # 创建新的预案记录
         new_plan = EmergencyPlan(
@@ -388,7 +388,7 @@ async def delete_emergency_plans(
         # 提取请求数据
         query = db.query(EmergencyPlan)
         query = query.filter(EmergencyPlan.del_flag != '2')
-        query = query.filter(EmergencyPlan.plan_id.in_(planUids))
+        query = query.filter(EmergencyPlan.plan_number.in_(planUids))
         plans = query.all()
         if not plans:
             detail = "预案不存在"

+ 6 - 1
routers/api/infoPublish/back.py

@@ -27,6 +27,7 @@ from config import settings
 
 router = APIRouter()
 
+# 信息发布创建
 @router.post('/create')
 async def create_emergency_plan(
     db: Session = Depends(get_db),
@@ -112,7 +113,7 @@ async def create_emergency_plan(
         # 处理异常
         raise HTTPException(status_code=500, detail=str(e))
 
-
+# 信息发布分页查询
 @router.get('/list')
 async def get_publish_list(
     publish_group: str = Query('', description='发布单位'),
@@ -202,6 +203,7 @@ async def get_publish_list(
         traceback.print_exc()
         raise HTTPException(status_code=500, detail=str(e))
 
+# 信息发布查看
 @router.get('/edit')
 async def get_edit_info(
     request: Request, 
@@ -231,6 +233,7 @@ async def get_edit_info(
         "data": data
     }
 
+# 信息发布编辑保存
 @router.post('/edit')
 async def post_edit_info(
     request: Request, 
@@ -250,6 +253,7 @@ async def post_edit_info(
         "msg": "保存信息成功"
     }
 
+# 信息发布提交审核
 @router.post('/examine')
 async def post_examine_info(
     request: Request, 
@@ -278,6 +282,7 @@ async def post_examine_info(
         "msg": "保存审批记录成功"
     }
 
+# 信息发布查看发送列表
 @router.get("send_list")
 async def get_send_list(
     info_id: str = Query('', description='信息ID'),