update 报告相关接口
This commit is contained in:
parent
d61793650e
commit
12b394aa79
|
@ -1,4 +1,5 @@
|
|||
from DBHelper.MongoHelperInstance import DB_GUA
|
||||
from Utils.CommonUtil import trans_fields_name
|
||||
|
||||
|
||||
class RatingResultImpl(object):
|
||||
|
@ -6,17 +7,17 @@ class RatingResultImpl(object):
|
|||
@staticmethod
|
||||
def search(**kwargs):
|
||||
total = DB_GUA.find_all_data_with_count(
|
||||
"评级数据",
|
||||
"得分级别",
|
||||
{"信用级别": kwargs["level"]}
|
||||
"企业数据",
|
||||
"公司概览",
|
||||
{"信用评级": {"$regex": kwargs["level"]}}
|
||||
)
|
||||
|
||||
items = DB_GUA.find_data_by_page_with_sort(
|
||||
"评级数据",
|
||||
"得分级别",
|
||||
{"企业名称": kwargs["level"]},
|
||||
["企业ID", "企业名称", "所在省份", "所在城市", "信用评级", "评级日期", "公司标签"],
|
||||
{"更新时间": -1},
|
||||
"企业数据",
|
||||
"公司概览",
|
||||
{"信用评级": {"$regex": kwargs["level"]}},
|
||||
["信用评级", "企业名称", "所在省份", "评级日期"],
|
||||
{"评级日期": -1},
|
||||
kwargs["page_size"],
|
||||
kwargs["page_no"]
|
||||
)
|
||||
|
@ -26,8 +27,8 @@ class RatingResultImpl(object):
|
|||
for item in items:
|
||||
trans_item = trans_fields_name(
|
||||
item,
|
||||
["企业ID", "所在省份", "所在城市", "信用评级", "评级日期", "公司标签"],
|
||||
["cid", "省份", "地级市", "级别", "日期", "标签"]
|
||||
["信用评级", "企业名称", "所在省份", "评级日期"],
|
||||
["级别", "企业名称", "省份", "日期"]
|
||||
)
|
||||
trans_items.append(trans_item)
|
||||
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
from flask import Blueprint, request
|
||||
|
||||
from Modules.AdminUser.UserAuthUtils import verify_token
|
||||
from Modules.Result.ResultImpl import RatingResultImpl
|
||||
from Utils.ErrorUtil import AttrCheckError, APIReturnError
|
||||
from Utils.RouteUtil import RouteParamsCheck
|
||||
|
||||
|
@ -20,7 +21,7 @@ def search_routes(**kwargs):
|
|||
impl = RatingResultImpl()
|
||||
|
||||
result = impl.search(
|
||||
company_name=company_name,
|
||||
level=level,
|
||||
page_size=page_size,
|
||||
page_no=page_no
|
||||
)
|
||||
|
@ -35,6 +36,20 @@ def search_routes(**kwargs):
|
|||
@verify_token
|
||||
def info_routes(**kwargs):
|
||||
"""评级信息"""
|
||||
RouteParamsCheck(request.args, ["company_name", "rating_date"]).required()
|
||||
level = request.args["level"]
|
||||
page_size = request.args["page_size"]
|
||||
page_no = request.args["page_no"]
|
||||
|
||||
impl = RatingResultImpl()
|
||||
|
||||
result = impl.search(
|
||||
level=level,
|
||||
page_size=page_size,
|
||||
page_no=page_no
|
||||
)
|
||||
|
||||
return {"info": "评级搜索", "result": result}, 200
|
||||
|
||||
|
||||
@result_route.route('/rank', methods=['GET'])
|
||||
|
@ -45,5 +60,5 @@ def rank_routes(**kwargs):
|
|||
|
||||
@result_route.route('/report', methods=['GET'])
|
||||
@verify_token
|
||||
def search_routes(**kwargs):
|
||||
def report_routes(**kwargs):
|
||||
"""评级搜索"""
|
2
app.py
2
app.py
|
@ -6,6 +6,7 @@ from Modules.Company.CompanyRoutes import company_route
|
|||
from Modules.DashBoard.DashBoardRoutes import board_route
|
||||
from Modules.File.FielRoutes import file_route
|
||||
from Modules.Rating.RatingRoutes import rating_route
|
||||
from Modules.Result.ResultRoutes import result_route
|
||||
|
||||
app = Flask(__name__)
|
||||
CORS(app, supports_credentials=True)
|
||||
|
@ -16,6 +17,7 @@ app.register_blueprint(user_route, url_prefix='/admin/user')
|
|||
app.register_blueprint(company_route, url_prefix='/admin/company')
|
||||
app.register_blueprint(rating_route, url_prefix='/admin/rating')
|
||||
app.register_blueprint(file_route, url_prefix='/admin/file')
|
||||
app.register_blueprint(result_route, url_prefix='/admin/result')
|
||||
# app.register_blueprint(board_route, url_prefix='/admin/board')
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue