This commit is contained in:
王思川 2022-06-16 19:17:06 +08:00
parent 07650a6288
commit 9af5fdccd7
2 changed files with 27 additions and 0 deletions

View File

@ -4,6 +4,22 @@ from Utils.CommonUtil import trans_fields_name
class DashBoardImpl(object): class DashBoardImpl(object):
@staticmethod
def static_all_country(**kwargs):
items = DB_GUA.find_data_with_aggregate(
"评级数据",
"评级记录",
[
{'$match': {'评级状态': "完成"}},
{'$group': {'_id': "$所在省份", 'count': {'$sum': 1}}}
]
)
result = list()
for item in items:
result.append({"省份": item['_id'], "数量": item["count"]})
return result
@staticmethod @staticmethod
def static_by_province(**kwargs): def static_by_province(**kwargs):

View File

@ -83,6 +83,17 @@ def distribute_route(**kwargs):
return demo_data return demo_data
@board_route.route('/map/country', methods=['GET'])
@verify_token
def map_country_route(**kwargs):
try:
impl = DashBoardImpl()
result = impl.static_all_country()
return {"info": "评级结果地图(全国)", "result": result}
except APIReturnError as e:
return {"info": e.__str__()}, e.status_code
@board_route.route('/map/province') @board_route.route('/map/province')
@verify_token @verify_token
def map_province_route(**kwargs): def map_province_route(**kwargs):