企业主页模块 财务要素分析&经营风险分析 变更至v0.21版本

company/company_db.py

@@ -7,38 +7,6 @@ DB_PORT = "27021"
 CLIENT = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format(DB_USER, DB_PASS, DB_HOST, DB_PORT))
 
 
-def FIND_DATA_IN_COMPANY(param1, param2):
-    """
-    从企业数据库中查询数据
-    Parameters:
-        param1 str 数据表
-        param2 dict 查询条件
-    Returns:
-        record: 查询结果
-    """
-    collection = CLIENT['企业'][param1]
-    data = collection.find(param2, {'_id': False})
-    record = list(data)
-    return record
-
-
-def FIND_DATA_IN_MACRO_INDUSTRY_ANALYSIS(industry):
-    """
-    从宏观行业分析数据库中查询行业宏观分析信息
-    Parameters:
-        industry: str 行业
-    Returns:
-        record: 查询结果
-    """
-    collection = CLIENT['宏观']['行业宏观分析']
-    data = collection.find({"行业": industry}, {'_id': False})
-    record = list(data)
-    if record:
-        return record[0]
-    else:
-        return False
-
-
 def FIND_SINGLE_COLUMN_BY_REQ(param1, param2, param3, param4):
     """
     查询符合条件的第一条数据的某个制定字段值

company/company_impl.py

@@ -1,4 +1,4 @@
-from company.company_db import FIND_DATA_IN_COMPANY, FIND_SINGLE_DATA_BY_REQ_WITH_SORT, FIND_SINGLE_DATA_BY_REQ
+from company.company_db import FIND_SINGLE_DATA_BY_REQ_WITH_SORT, FIND_SINGLE_DATA_BY_REQ
 from company.company_utils import judge_industry
 
 
@@ -69,9 +69,25 @@ def get_esg_rating_impl(cid):
     Case Fail:
         data: dict 空字典
     """
-    data = FIND_SINGLE_DATA_BY_REQ('企业数据', 'ESG评价分析', {"企业ID": cid}, ["更新日期", "ESG评级", "维度得分情况", "实质性议题得分情况", "实质性议题"])
+    data = FIND_SINGLE_DATA_BY_REQ_WITH_SORT('企业数据', 'ESG评价分析', {"企业ID": cid}, ["更新日期", "ESG评级", "维度得分情况", "实质性议题得分情况", "实质性议题"], {"更新日期": -1})
 
     if data is False:
         return {}
 
     return data
+
+
+def get_financial_elements_impl(cid):
+    """
+    财务要素分析
+    """
+    data = FIND_SINGLE_DATA_BY_REQ_WITH_SORT('企业数据', '财务要素分析', {"企业ID": cid}, ["更新日期", "财报期", "同行对比图", "去年对比图", "去年对比表", "同行对比表", "指标详情"], {"更新日期": -1})
+    return data
+
+
+def get_operating_risk_impl(cid):
+    """
+    经营风险分析
+    """
+    data = FIND_SINGLE_DATA_BY_REQ_WITH_SORT('企业数据', '经营风险分析', {"企业ID": cid}, ["更新日期", "风险分数", "风险级别", "列入失信名单", "合规风险", "经营风险", "周边风险", "变更记录"], {"更新日期": -1})
+    return data

company/company_obj.py

@@ -1,5 +1,6 @@
-from company.company_impl import get_head_info_impl, get_industry_analysis_impl, get_esg_rating_impl, get_cc_rating_impl, \
-    get_basic_info_impl
+from company.company_impl import get_head_info_impl, get_industry_analysis_impl, get_esg_rating_impl, \
+    get_cc_rating_impl, \
+    get_basic_info_impl, get_financial_elements_impl, get_operating_risk_impl
 
 
 class CompanyIndex:
@@ -26,3 +27,9 @@ class CompanyIndex:
 
     def get_esg_rating(self):
         return get_esg_rating_impl(self.cid)
+
+    def get_financial_elements(self):
+        return get_financial_elements_impl(self.cid)
+
+    def get_operating_risk(self):
+        return get_operating_risk_impl(self.cid)

company/company_routes.py

@@ -49,13 +49,27 @@ def industry_analysis_route(**kwargs):
 @verify_token
 def esg_rating_route(**kwargs):
     """
-    ESG分析数据
-    Parameters:
-        param desc
-    Returns:
-        res: desc
+    ESG评价分析
     """
     company_index = CompanyIndex()
     company_index.cid = kwargs['cid']
     result = company_index.get_esg_rating()
     return {"info": "查询结果", "result": result}
+
+
+@company_route.route('/financial_elements', methods=['GET'])
+@verify_token
+def financial_elements_route(**kwargs):
+    company_index = CompanyIndex()
+    company_index.cid = kwargs['cid']
+    result = company_index.get_financial_elements()
+    return {"info": "查询结果", "result": result}
+
+
+@company_route.route('/operating_risk', methods=['GET'])
+@verify_token
+def operating_risk_route(**kwargs):
+    company_index = CompanyIndex()
+    company_index.cid = kwargs['cid']
+    result = company_index.get_operating_risk()
+    return {"info": "查询结果", "result": result}