250309-1代码。

routers/api/resourceProvison/MaterialReserveManagement/dispatch.py

@@ -177,6 +177,7 @@ async def update_dispatch(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -236,6 +237,7 @@ async def get_pattern_info(
 @router.get("/list")
 async def get_pattern_list(
     # dispatch_details: str = Query(None, description='名称'),
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)
@@ -327,6 +329,7 @@ async def create_pattern(
 
 @router.get("/review/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)

routers/api/resourceProvison/MaterialReserveManagement/m_count.py

@@ -26,6 +26,7 @@ router = APIRouter()
 
 @router.get("/data")
 async def get_count_info(
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -41,6 +42,7 @@ async def get_count_info(
         raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
 @router.get("/count_room_material")
 async def get_count_info(
+    user_id=Depends(valid_access_token),
     warehouseId:str = Query(None),
     db: Session = Depends(get_db)
 ):

routers/api/resourceProvison/MaterialReserveManagement/material.py

@@ -187,6 +187,7 @@ async def update_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -260,6 +261,7 @@ async def get_pattern_info(
 
 @router.get("/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     material_id: str = Query(None, description='名称'),
     material_name: str = Query(None, description='名称'),
     warehouse_id: str = Query(None, description='名称'),
@@ -358,6 +360,7 @@ async def get_pattern_list(
 @router.delete("/delete/{id}")
 async def delete_pattern(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -380,6 +383,7 @@ async def delete_pattern(
 
 @router.get("/barcode/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     name: str = Query(None, description='名称'),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),

routers/api/resourceProvison/MaterialReserveManagement/material_type.py

@@ -76,6 +76,7 @@ async def update_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -98,6 +99,7 @@ async def get_pattern_info(
 
 @router.get("/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     name: str = Query(None, description='名称'),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),
@@ -136,6 +138,7 @@ async def get_pattern_list(
 @router.delete("/delete/{id}")
 async def delete_pattern(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:

routers/api/resourceProvison/MaterialReserveManagement/procurement.py

@@ -142,6 +142,7 @@ async def update_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -202,6 +203,7 @@ async def get_pattern_info(
 @router.get("/list")
 async def get_pattern_list(
     # declaration_details: str = Query(None, description='名称'),
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)
@@ -294,6 +296,7 @@ async def create_pattern(
 
 @router.get("/review/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)

routers/api/resourceProvison/MaterialReserveManagement/warehouse.py

@@ -95,6 +95,7 @@ async def update_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -128,6 +129,7 @@ async def get_pattern_info(
 @router.get("/list")
 async def get_pattern_list(
     # name: str = Query(None, description='名称'),
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(None, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)
@@ -177,6 +179,7 @@ async def get_pattern_list(
 @router.delete("/delete/{id}")
 async def delete_pattern(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:

routers/api/resourceProvison/MaterialReserveManagement/warehouse_inbound.py

@@ -111,6 +111,7 @@ async def create_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -161,6 +162,7 @@ async def get_pattern_info(
 @router.get("/list")
 async def get_pattern_list(
     # warehouse_id: str = Query(None, description='名称'),
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(100, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)

routers/api/resourceProvison/MaterialReserveManagement/warehouse_movement.py

@@ -26,6 +26,7 @@ router = APIRouter()
 
 @router.get("/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     material_id: str = Query(None, description='物资id'),
     io_number: str = Query(None, description='出入库单号'),
     io_flag: str = Query(None, description='出入库标识'),

routers/api/resourceProvison/MaterialReserveManagement/warehouse_outbound.py

@@ -109,6 +109,7 @@ async def create_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -157,6 +158,7 @@ async def get_pattern_info(
 @router.get("/list")
 async def get_pattern_list(
     # warehouse_id: str = Query(None, description='名称'),
+    user_id=Depends(valid_access_token),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(100, gt=0, description='每页条目数量'),
     db: Session = Depends(get_db)

routers/api/resourceProvison/MaterialReserveManagement/warehouse_root.py

@@ -88,6 +88,7 @@ async def update_pattern(
 @router.get("/info/{id}")
 async def get_pattern_info(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:
@@ -123,6 +124,7 @@ async def get_pattern_info(
 
 @router.get("/list")
 async def get_pattern_list(
+    user_id=Depends(valid_access_token),
     warehouse_id: str = Query(None, description='名称'),
     page: int = Query(1, gt=0, description='页码'),
     pageSize: int = Query(100, gt=0, description='每页条目数量'),
@@ -173,6 +175,7 @@ async def get_pattern_list(
 @router.delete("/delete/{id}")
 async def delete_pattern(
     id: str,
+    user_id=Depends(valid_access_token),
     db: Session = Depends(get_db)
 ):
     try:

routers/api/resourceProvison/emergency_resources.py

@@ -173,7 +173,8 @@ class UnitListSchema(BaseModel):
         orm_mode = True
 #创建
 @router.post("/rescue_units/")
-def create_units(unit_list_data: UnitListSchema, db: Session = Depends(get_db)):
+def create_units(unit_list_data: UnitListSchema,
+    user_id=Depends(valid_access_token), db: Session = Depends(get_db)):
     units = unit_list_data.units
     if not units:  # 确保列表不为空
         raise HTTPException(status_code=400, detail="单位列表不能为空")
@@ -297,7 +298,8 @@ class RescuePersonnelListSchema(BaseModel):
         orm_mode = True
 #创建
 @router.post("/rescue_personnel/")
-def create_rescue_personnel(personnel_list_data: RescuePersonnelListSchema, db: Session = Depends(get_db)):
+def create_rescue_personnel(personnel_list_data: RescuePersonnelListSchema,
+    user_id=Depends(valid_access_token), db: Session = Depends(get_db)):
     personnel_list = personnel_list_data.personnel_list
     if not personnel_list:  # 确保列表不为空
         raise HTTPException(status_code=400, detail="人员列表不能为空")
@@ -316,7 +318,8 @@ def create_rescue_personnel(personnel_list_data: RescuePersonnelListSchema, db:
 
 #删除
 @router.delete("/rescue_personnel/{personnel_id}/")
-def delete_rescue_personnel(personnel_id: int, db: Session = Depends(get_db)):
+def delete_rescue_personnel(personnel_id: int,
+    user_id=Depends(valid_access_token),db: Session = Depends(get_db)):
     personnel = db.query(RescuePersonnel).get(personnel_id)
     if not personnel:
         raise HTTPException(status_code=404, detail="救灾人员不存在")