From 6018c6604a59927ce2c6d52331b30620af2d0aa2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E6=80=9D=E5=B7=9D?= <sichanwong0527@gmail.com>
Date: Thu, 16 Jun 2022 19:27:43 +0800
Subject: [PATCH] Changes

---
 Modules/DashBoard/DashBoardImpl.py   | 16 +++++++++++++
 Modules/DashBoard/DashBoardRoutes.py | 35 +++++++---------------------
 2 files changed, 25 insertions(+), 26 deletions(-)

diff --git a/Modules/DashBoard/DashBoardImpl.py b/Modules/DashBoard/DashBoardImpl.py
index 3fa29ae..290fac2 100644
--- a/Modules/DashBoard/DashBoardImpl.py
+++ b/Modules/DashBoard/DashBoardImpl.py
@@ -88,6 +88,22 @@ class DashBoardImpl(object):
 
         return result
 
+    @staticmethod
+    def rank_levels_distribute(**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
     def latest_rating_result(**kwargs):
 
diff --git a/Modules/DashBoard/DashBoardRoutes.py b/Modules/DashBoard/DashBoardRoutes.py
index 76501d6..fed8cc9 100644
--- a/Modules/DashBoard/DashBoardRoutes.py
+++ b/Modules/DashBoard/DashBoardRoutes.py
@@ -57,30 +57,14 @@ def statistics_route(**kwargs):
 @board_route.route('/distribute')
 @verify_token
 def distribute_route(**kwargs):
-    """"""
+    """信用级别分布"""
 
-    demo_data = {
-        "info": "查询成功",
-        "result": [
-            {
-                "AAA": 3
-            },
-            {
-                "AA+": 8
-            },
-            {
-                "AA": 4
-            },
-            {
-                "AA-": 8
-            },
-            {
-                "A+": 5
-            }
-        ]
-    }
-
-    return demo_data
+    try:
+        impl = DashBoardImpl()
+        result = impl.rank_levels_distribute()
+        return {"info": "信用级别分布", "result": result}
+    except APIReturnError as e:
+        return {"info": e.__str__()}, e.status_code
 
 
 @board_route.route('/map/country', methods=['GET'])
@@ -94,7 +78,7 @@ def map_country_route(**kwargs):
         return {"info": e.__str__()}, e.status_code
 
 
-@board_route.route('/map/province')
+@board_route.route('/map/province', methods=['GET'])
 @verify_token
 def map_province_route(**kwargs):
     """评级结果地图(省份)"""
@@ -115,7 +99,7 @@ def map_province_route(**kwargs):
         return {"info": e.__str__()}, e.status_code
 
 
-@board_route.route('/map/city')
+@board_route.route('/map/city', methods=['GET'])
 @verify_token
 def map_city_route(**kwargs):
     """评级结果地图(省份)"""
@@ -134,4 +118,3 @@ def map_city_route(**kwargs):
         return result
     except APIReturnError as e:
         return {"info": e.__str__()}, e.status_code
-