From ec879802c4b36d67bb6b245c1551f0056bc86ed2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E6=80=9D=E5=B7=9D?= <sichanwong0527@gmail.com>
Date: Mon, 18 Apr 2022 12:23:22 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Manage/Company/CompanyImpl.py   | 15 ++++++++++++++-
 Manage/Company/CompanyObj.py    | 22 +++++++++++++++++++++-
 Manage/Company/CompanyRoutes.py | 16 ++++++++++++++++
 3 files changed, 51 insertions(+), 2 deletions(-)

diff --git a/Manage/Company/CompanyImpl.py b/Manage/Company/CompanyImpl.py
index f203cd7..91ce034 100644
--- a/Manage/Company/CompanyImpl.py
+++ b/Manage/Company/CompanyImpl.py
@@ -70,7 +70,7 @@ class CompanyIndexApiImpl(CompanyIndexApi):
     db = MongoHelper("tfse_v0.21")
 
     head_info = CompanyIndexApi.HeadInfo()
-    update_tine = CompanyIndexApi
+    update_time = CompanyIndexApi.UpdateTime()
     basic_info = CompanyIndexApi
     financial_data = CompanyIndexApi
     operating_risk = CompanyIndexApi
@@ -97,3 +97,16 @@ class CompanyIndexApiImpl(CompanyIndexApi):
 
         self.head_info.name = result['企业名称']
         self.head_info.industry = result['一级行业']
+
+    def get_update_time(self):
+        """"""
+
+        results = self.db.find_all_data_with_single_sort(
+            "企业数据",
+            self.update_time.table_map[self.update_time.table],
+            {"企业ID": self.update_time.cid},
+            ["更新日期"],
+            {"更新日期": -1}
+        )
+
+        self.update_time.update_time = [result['更新日期'] for result in results]
diff --git a/Manage/Company/CompanyObj.py b/Manage/Company/CompanyObj.py
index c15d02f..3592f9b 100644
--- a/Manage/Company/CompanyObj.py
+++ b/Manage/Company/CompanyObj.py
@@ -121,10 +121,30 @@ class CompanyIndexApi(SpecObject):
             "industry": "所属行业",
         }
 
+    class UpdateTime(SpecObject):
+        """更新时间"""
+        table_map = {
+            "工商信息": "基本工商信息",
+            "经营风险": "经营风险分析",
+            "财务分析": "财务要素分析",
+            "综合信用分析": "综合信用分析",
+            "ESG评价分析": "ESG评价分析"
+        }
+
+        cid = ValidateAttr(field='cid', type=str, length=8)
+        table = ValidateAttr(field='table', type=str, in_list=list(table_map.keys()))
+        update_time = ValidateAttr(field='update_time', type=list)
+
+        fields_map = {
+            "cid": "企业ID",
+            "table": "table",
+            "update_time": "update_time"
+        }
+
     def get_head_info(self):
         """头部信息"""
 
-    def get_update_tine(self):
+    def get_update_time(self):
         """更新时间"""
 
     def get_basic_info(self):
diff --git a/Manage/Company/CompanyRoutes.py b/Manage/Company/CompanyRoutes.py
index a788109..88fd30b 100644
--- a/Manage/Company/CompanyRoutes.py
+++ b/Manage/Company/CompanyRoutes.py
@@ -67,6 +67,22 @@ def head_info_route(**kwargs):
         return {"info": e.failed_info}, e.status_code
 
 
+@company_route.route('/update_time', methods=['POST'])
+@verify_token
+def update_time_route(**kwargs):
+    """更新时间"""
+    try:
+        req = request.json
+        impl = CompanyIndexApiImpl()
+        impl.update_time.cid = req['cid']
+        impl.update_time.table = req['table']
+        impl.get_update_time()
+        result = impl.update_time.dict_to_show(columns=['table', 'update_time'])
+        return result, 200
+    except ReturnConditionCheckFailed as e:
+        return {"info": e.failed_info}, e.status_code
+
+
 @company_route.route('/index', methods=['POST'])
 @verify_token
 def index_route(**kwargs):