去重删除time_release比较,公司实体同步Redis新增credit_code

BaseDataMaintenance/maintenance/dataflow.py

@@ -2203,7 +2203,7 @@ class Dataflow_dumplicate(Dataflow):
                 createComsumer(listener,self.doc_delete_queue)
 
 
-    def get_dict_time(self,_extract,keys=["time_bidclose","time_bidopen","time_bidstart","time_commencement","time_completion","time_earnestMoneyEnd","time_earnestMoneyStart","time_getFileEnd","time_getFileStart","time_publicityEnd","time_publicityStart","time_registrationEnd","time_registrationStart","time_release"]):
+    def get_dict_time(self,_extract,keys=["time_bidclose","time_bidopen","time_bidstart","time_commencement","time_completion","time_earnestMoneyEnd","time_earnestMoneyStart","time_getFileEnd","time_getFileStart","time_publicityEnd","time_publicityStart","time_registrationEnd","time_registrationStart"]):
         dict_time = {}
         for k in keys:
             dict_time[k] = _extract.get(k)

BaseDataMaintenance/maintenance/enterprise/enterprise2Redis.py

@@ -136,14 +136,16 @@ class enterprise2Redis():
                     legal_name_num += 1
                     _json = {"have_business": 1, "zhao_biao_number": zhao_biao_number,
                              "zhong_biao_number": zhong_biao_number,
-                             "dai_li_number": dai_li_number, "bid_number": bid_number}
+                             "dai_li_number": dai_li_number, "bid_number": bid_number,
+                             "credit_code":credit_code}
                     _json = json.dumps(_json, ensure_ascii=False)
                     add_redis_list.append((name, _json))
                 elif num == 0 and bid_number > 0 and len(name) > 4:
                     legal_name_num += 1
                     _json = {"have_business": 0, "zhao_biao_number": zhao_biao_number,
                              "zhong_biao_number": zhong_biao_number,
-                             "dai_li_number": dai_li_number, "bid_number": bid_number}
+                             "dai_li_number": dai_li_number, "bid_number": bid_number,
+                             "credit_code":credit_code}
                     _json = json.dumps(_json, ensure_ascii=False)
                     add_redis_list.append((name, _json))
 

BaseDataMaintenance/maintenance/preproject/fillColumns.py

@@ -543,8 +543,8 @@ class PreprojectFill():
                         # in_doctextcon, last_doctitle, last_tenderee_contact, last_tenderee_phone
 
                         _preproject = Preproject(result_row)
-                        if not _preproject.exists_row(self.ots_client):
-                            _preproject.update_row(self.ots_client)
+                        # if not _preproject.exists_row(self.ots_client):
+                        _preproject.update_row(self.ots_client)
 
         _mul = MultiThreadHandler(self.purchaseIntention_process_queue,comsumer_handle,None,20)
         _mul.run()