phzhik/gault-millau
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

disable ES

Browse Source
This commit is contained in:
Kuroshini 2020-01-22 21:25:09 +03:00
parent 8aefe9b0e9
commit cc9c641df3
1 changed files with 69 additions and 69 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

138
apps/search_indexes/signals.py
View File

@ -1,69 +1,69 @@
"""Search indexes app signals.""" # """Search indexes app signals."""
from django.db.models.signals import post_save # from django.db.models.signals import post_save
from django.dispatch import receiver # from django.dispatch import receiver
#
#
@receiver(post_save) # @receiver(post_save)
def update_document(sender, **kwargs): # def update_document(sender, **kwargs):
from establishment.models import Establishment # from establishment.models import Establishment
from search_indexes.tasks import es_update # from search_indexes.tasks import es_update
app_label = sender._meta.app_label # app_label = sender._meta.app_label
model_name = sender._meta.model_name # model_name = sender._meta.model_name
instance = kwargs['instance'] # instance = kwargs['instance']
#
app_label_model_name_to_filter = { # app_label_model_name_to_filter = {
('location', 'country'): 'address__city__country', # ('location', 'country'): 'address__city__country',
('location', 'city'): 'address__city', # ('location', 'city'): 'address__city',
('location', 'address'): 'address', # ('location', 'address'): 'address',
# todo: remove after migration # # todo: remove after migration
('establishment', 'establishmenttype'): 'establishment_type', # ('establishment', 'establishmenttype'): 'establishment_type',
('establishment', 'establishmentsubtype'): 'establishment_subtypes', # ('establishment', 'establishmentsubtype'): 'establishment_subtypes',
# ('tag', 'tag'): 'tags', # # ('tag', 'tag'): 'tags',
} # }
filter_name = app_label_model_name_to_filter.get((app_label, model_name)) # filter_name = app_label_model_name_to_filter.get((app_label, model_name))
if filter_name: # if filter_name:
qs = Establishment.objects.filter(**{filter_name: instance}) # qs = Establishment.objects.filter(**{filter_name: instance})
for item in qs: # for item in qs:
es_update(item) # es_update(item)
#
#
@receiver(post_save) # @receiver(post_save)
def update_news(sender, **kwargs): # def update_news(sender, **kwargs):
from news.models import News # from news.models import News
from search_indexes.tasks import es_update # from search_indexes.tasks import es_update
app_label = sender._meta.app_label # app_label = sender._meta.app_label
model_name = sender._meta.model_name # model_name = sender._meta.model_name
instance = kwargs['instance'] # instance = kwargs['instance']
app_label_model_name_to_filter = { # app_label_model_name_to_filter = {
('location', 'country'): 'country', # ('location', 'country'): 'country',
# ('news', 'newstype'): 'news_type', # # ('news', 'newstype'): 'news_type',
# ('tag', 'tag'): 'tags', # # ('tag', 'tag'): 'tags',
} # }
filter_name = app_label_model_name_to_filter.get((app_label, model_name)) # filter_name = app_label_model_name_to_filter.get((app_label, model_name))
if filter_name: # if filter_name:
qs = News.objects.filter(**{filter_name: instance}) # qs = News.objects.filter(**{filter_name: instance})
for item in qs: # for item in qs:
es_update(item) # es_update(item)
#
#
@receiver(post_save) # @receiver(post_save)
def update_product(sender, **kwargs): # def update_product(sender, **kwargs):
from product.models import Product # from product.models import Product
from search_indexes.tasks import es_update # from search_indexes.tasks import es_update
app_label = sender._meta.app_label # app_label = sender._meta.app_label
model_name = sender._meta.model_name # model_name = sender._meta.model_name
instance = kwargs['instance'] # instance = kwargs['instance']
app_label_model_name_to_filter = { # app_label_model_name_to_filter = {
('product', 'productstandard'): 'standards', # ('product', 'productstandard'): 'standards',
('product', 'producttype'): 'product_type', # ('product', 'producttype'): 'product_type',
# ('tag', 'tag'): 'tags', # # ('tag', 'tag'): 'tags',
# ('location', 'wineregion'): 'wine_region', # # ('location', 'wineregion'): 'wine_region',
# ('location', 'winesubregion'): 'wine_sub_region', # # ('location', 'winesubregion'): 'wine_sub_region',
# ('location', 'winevillage'): 'wine_village', # # ('location', 'winevillage'): 'wine_village',
('establishment', 'establishment'): 'establishment', # ('establishment', 'establishment'): 'establishment',
} # }
filter_name = app_label_model_name_to_filter.get((app_label, model_name)) # filter_name = app_label_model_name_to_filter.get((app_label, model_name))
if filter_name: # if filter_name:
qs = Product.objects.filter(**{filter_name: instance}) # qs = Product.objects.filter(**{filter_name: instance})
for product in qs: # for product in qs:
es_update(product) # es_update(product)