添加查询多个节点收益接口

api/node.py

 from typing import List
 
 from motor.core import AgnosticCollection
-from pydantic import Field
 
 import dependencies
 from exception.api import APIError
 from exception.db import ExistDataError, NotFundError
-from exception.http import RequestInvalidParamsError
 from model import BaseResponse, Response, PageResponse, Page
 from fastapi import APIRouter, Depends, Query
 
@@ -125,6 +123,18 @@ async def get_node_blocks(
     return PageResponse[ValidatorBlock](data=validator_blocks.data, **page.dict(), total=validator_blocks.total)
 
 
+@router.get(
+    "/validator/incomes/",
+    response_model=Response[List[ValidatorIncome]],
+    summary="查询多个节点收益", description="")
+async def get_all_node_income(
+        pub_key: List[str] = Query(..., description='查询节点'),
+        beacon_service: BeaconChaService = Depends(BeaconChaService)
+):
+    list_res = await beacon_service.get_validator_income(index_or_pubkey=','.join(pub_key))
+    return Response[List[ValidatorIncome]](data=list_res)
+
+
 @router.get(
     "/validator/income/{pub_key}/",
     response_model=Response[ValidatorIncome],