重写

1. 拉取最新企业数据
2. 更新基本工商信息

Implements/CompanyDataJob/BasicBusinessInfoDataJob.py

@@ -34,6 +34,7 @@ class CheckDataInitialed(DataProcess):
 
 
 class ProcessBasicInfo(DataProcess):
+    """处理工商信息"""
 
     def extract(self):
 
@@ -77,6 +78,7 @@ class ProcessBasicInfo(DataProcess):
 
 
 class ProcessShareHolders(DataProcess):
+    """处理股东信息"""
 
     def extract(self):
 
@@ -161,6 +163,7 @@ class ProcessShareHolders(DataProcess):
 
 
 class ProcessMainMembers(DataProcess):
+    """处理主要成员信息"""
 
     def extract(self):
 
@@ -199,6 +202,7 @@ class ProcessMainMembers(DataProcess):
 
 
 class SaveBasicBusinessInfo(DataProcess):
+    """保存基本工商信息数据"""
 
     def extract(self):
         pass
@@ -224,9 +228,32 @@ class SaveBasicBusinessInfo(DataProcess):
         )
 
 
+class DeleteBasicBusinessInfo(DataProcess):
+    """删除基本工商信息数据"""
+
+    def extract(self):
+        pass
+
+    def transform(self):
+        pass
+
+    def load(self):
+        target = self.target
+
+        DB_TFSE.delete_single_data(
+            "企业数据",
+            "基本工商信息",
+            {
+                "企业ID": target.cid,
+                "更新日期": target.update_time
+            }
+        )
+
+
 class BasicBusinessInfoDataJob(BasicBusinessInfo):
 
-    def init_basic_business_info(self):
+    def update_basic_business_info(self):
+        """更新基本工商信息"""
 
         data_job = DataJob(
             instance=self,
@@ -237,7 +264,6 @@ class BasicBusinessInfoDataJob(BasicBusinessInfo):
         )
 
         data_job.processes = [
-            CheckDataInitialed,
             ProcessBasicInfo,
             ProcessShareHolders,
             ProcessMainMembers,
@@ -245,3 +271,20 @@ class BasicBusinessInfoDataJob(BasicBusinessInfo):
         ]
 
         data_job.start()
+
+    def delete_basic_business_info(self):
+        """删除基本工商信息"""
+
+        data_job = DataJob(
+            instance=self,
+            title="删除企业工商信息",
+            job_type="删除数据",
+            status="正常",
+            detail="企业ID->{}; 企业名称->{}; 删除更新时间->{}; ".format(self.cid, self.name, self.update_time)
+        )
+
+        data_job.processes = [
+            DeleteBasicBusinessInfo
+        ]
+
+        data_job.start()

Implements/Other/TYCDataJob.py

@@ -35,7 +35,7 @@ class TYCDataJob(TYCApiReqBody):
         data_job = DataJob(
             instance=self,
             title="初始企业工商信息",
-            job_type="初始数据",
+            job_type="处理准备",
             status="正常",
             detail="企业名称->{}; ".format(self.company_name)
         )

Routes/CompanyRoutes.py

@@ -30,10 +30,10 @@ def drag_data_from_tyc_db_route():
         return {"info": e.error_info}, e.status_code
 
 
-@company_route.route('/init_business_info', methods=['GET'])
+@company_route.route('/update_business_info', methods=['GET'])
 @verify_token
 def init_business_info_route():
-    """初始化企业工商信息"""
+    """更新基本工商信息"""
 
     try:
         args = request.args
@@ -41,9 +41,9 @@ def init_business_info_route():
 
         data_job = BasicBusinessInfoDataJob()
         data_job.cid, data_job.name = args['cid'], args['company_name']
-        data_job.init_basic_business_info()
+        data_job.update_basic_business_info()
 
-        return {"info": "企业数据初始化成功"}, 200
+        return {"info": "基本工商信息更新成功"}, 200
 
     except APIReturnError as e:
         return {"info": e.error_info}, e.status_code