Merge branch 'a157444434989308_filter_comp_dialogue_stage1_tenders'

openprocurement · Dec 2, 2016 · dabc1fd · dabc1fd
2 parents 5593391 + b97996c
commit dabc1fd
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/openprocurement/contracting/api/databridge.py b/openprocurement/contracting/api/databridge.py
@@ -197,6 +197,10 @@ def get_tenders(self, params={}, direction=""):
                 delay = self.full_stack_sync_delay
                 logger.info("Client {} params: {}".format(direction, params))
             for tender in tenders_list:
+                if tender.get('procurementMethodType') in ['competitiveDialogueUA', 'competitiveDialogueEU']:
+                    logger.info('Skipping {} tender {}'.format(tender['procurementMethodType'], tender['id']),
+                                extra=journal_context({"MESSAGE_ID": DATABRIDGE_INFO}, params={"TENDER_ID": tender['id']}))
+                    continue
                 if tender['status'] in ("active.qualification",
                                         "active.awarded", "complete"):
                     if hasattr(tender, "lots"):
@@ -396,7 +400,7 @@ def retry_put_contracts(self):
 
     def get_tender_contracts_forward(self):
         logger.info('Start forward data sync worker...')
-        params = {'opt_fields': 'status,lots', 'mode': '_all_'}
+        params = {'opt_fields': 'status,lots,procurementMethodType', 'mode': '_all_'}
         try:
             for tender_data in self.get_tenders(params=params, direction="forward"):
                 logger.info('Forward sync: Put tender {} to process...'.format(tender_data['id']),
@@ -412,7 +416,7 @@ def get_tender_contracts_forward(self):
 
     def get_tender_contracts_backward(self):
         logger.info('Start backward data sync worker...')
-        params = {'opt_fields': 'status,lots', 'descending': 1, 'mode': '_all_'}
+        params = {'opt_fields': 'status,lots,procurementMethodType', 'descending': 1, 'mode': '_all_'}
         try:
             for tender_data in self.get_tenders(params=params, direction="backward"):
                 stored = self.cache_db.get(tender_data['id'])