fitlers fixes
This commit is contained in:
IGNY8 VPS (Salman)
@@ -272,6 +272,167 @@ class TasksViewSet(SiteSectorModelViewSet):
|
||||
status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
|
||||
request=request
|
||||
)
|
||||
|
||||
@action(detail=False, methods=['get'], url_path='filter_options', url_name='filter_options')
|
||||
def filter_options(self, request):
|
||||
"""
|
||||
Get distinct filter values from current data with cascading support.
|
||||
Returns only values that exist based on other active filters.
|
||||
"""
|
||||
import logging
|
||||
from django.db.models import Q
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
try:
|
||||
queryset = self.get_queryset()
|
||||
|
||||
# Get filter parameters for cascading
|
||||
status_filter = request.query_params.get('status', '')
|
||||
content_type_filter = request.query_params.get('content_type', '')
|
||||
content_structure_filter = request.query_params.get('content_structure', '')
|
||||
cluster_filter = request.query_params.get('cluster', '')
|
||||
source_filter = request.query_params.get('source', '')
|
||||
search = request.query_params.get('search', '')
|
||||
|
||||
# Apply search to base queryset
|
||||
base_qs = queryset
|
||||
if search:
|
||||
base_qs = base_qs.filter(
|
||||
Q(title__icontains=search) | Q(keywords__icontains=search)
|
||||
)
|
||||
|
||||
# Get statuses (filtered by other fields)
|
||||
status_qs = base_qs
|
||||
if content_type_filter:
|
||||
status_qs = status_qs.filter(content_type=content_type_filter)
|
||||
if content_structure_filter:
|
||||
status_qs = status_qs.filter(content_structure=content_structure_filter)
|
||||
if cluster_filter:
|
||||
status_qs = status_qs.filter(cluster_id=cluster_filter)
|
||||
if source_filter:
|
||||
status_qs = status_qs.filter(source=source_filter)
|
||||
statuses = list(set(status_qs.values_list('status', flat=True)))
|
||||
statuses = sorted([s for s in statuses if s])
|
||||
status_labels = {
|
||||
'queued': 'Queued',
|
||||
'processing': 'Processing',
|
||||
'completed': 'Completed',
|
||||
'failed': 'Failed',
|
||||
}
|
||||
status_options = [
|
||||
{'value': s, 'label': status_labels.get(s, s.title())}
|
||||
for s in statuses
|
||||
]
|
||||
|
||||
# Get content types (filtered by other fields)
|
||||
type_qs = base_qs
|
||||
if status_filter:
|
||||
type_qs = type_qs.filter(status=status_filter)
|
||||
if content_structure_filter:
|
||||
type_qs = type_qs.filter(content_structure=content_structure_filter)
|
||||
if cluster_filter:
|
||||
type_qs = type_qs.filter(cluster_id=cluster_filter)
|
||||
if source_filter:
|
||||
type_qs = type_qs.filter(source=source_filter)
|
||||
content_types = list(set(type_qs.values_list('content_type', flat=True)))
|
||||
content_types = sorted([t for t in content_types if t])
|
||||
type_labels = {
|
||||
'post': 'Post',
|
||||
'page': 'Page',
|
||||
'product': 'Product',
|
||||
'taxonomy': 'Taxonomy',
|
||||
}
|
||||
content_type_options = [
|
||||
{'value': t, 'label': type_labels.get(t, t.title())}
|
||||
for t in content_types
|
||||
]
|
||||
|
||||
# Get content structures (filtered by other fields)
|
||||
structure_qs = base_qs
|
||||
if status_filter:
|
||||
structure_qs = structure_qs.filter(status=status_filter)
|
||||
if content_type_filter:
|
||||
structure_qs = structure_qs.filter(content_type=content_type_filter)
|
||||
if cluster_filter:
|
||||
structure_qs = structure_qs.filter(cluster_id=cluster_filter)
|
||||
if source_filter:
|
||||
structure_qs = structure_qs.filter(source=source_filter)
|
||||
structures = list(set(structure_qs.values_list('content_structure', flat=True)))
|
||||
structures = sorted([s for s in structures if s])
|
||||
structure_labels = {
|
||||
'article': 'Article', 'guide': 'Guide', 'comparison': 'Comparison',
|
||||
'review': 'Review', 'listicle': 'Listicle', 'landing_page': 'Landing Page',
|
||||
'business_page': 'Business Page', 'service_page': 'Service Page',
|
||||
'general': 'General', 'cluster_hub': 'Cluster Hub',
|
||||
'product_page': 'Product Page', 'category_archive': 'Category Archive',
|
||||
'tag_archive': 'Tag Archive', 'attribute_archive': 'Attribute Archive',
|
||||
}
|
||||
content_structure_options = [
|
||||
{'value': s, 'label': structure_labels.get(s, s.replace('_', ' ').title())}
|
||||
for s in structures
|
||||
]
|
||||
|
||||
# Get clusters (filtered by other fields)
|
||||
cluster_qs = base_qs
|
||||
if status_filter:
|
||||
cluster_qs = cluster_qs.filter(status=status_filter)
|
||||
if content_type_filter:
|
||||
cluster_qs = cluster_qs.filter(content_type=content_type_filter)
|
||||
if content_structure_filter:
|
||||
cluster_qs = cluster_qs.filter(content_structure=content_structure_filter)
|
||||
if source_filter:
|
||||
cluster_qs = cluster_qs.filter(source=source_filter)
|
||||
from igny8_core.modules.planner.models import Clusters
|
||||
cluster_ids = list(set(
|
||||
cluster_qs.exclude(cluster_id__isnull=True)
|
||||
.values_list('cluster_id', flat=True)
|
||||
))
|
||||
clusters = Clusters.objects.filter(id__in=cluster_ids).values('id', 'name').order_by('name')
|
||||
cluster_options = [
|
||||
{'value': str(c['id']), 'label': c['name']}
|
||||
for c in clusters
|
||||
]
|
||||
|
||||
# Get sources (filtered by other fields)
|
||||
source_qs = base_qs
|
||||
if status_filter:
|
||||
source_qs = source_qs.filter(status=status_filter)
|
||||
if content_type_filter:
|
||||
source_qs = source_qs.filter(content_type=content_type_filter)
|
||||
if content_structure_filter:
|
||||
source_qs = source_qs.filter(content_structure=content_structure_filter)
|
||||
if cluster_filter:
|
||||
source_qs = source_qs.filter(cluster_id=cluster_filter)
|
||||
sources = list(set(source_qs.values_list('source', flat=True)))
|
||||
sources = sorted([s for s in sources if s])
|
||||
source_labels = {
|
||||
'manual': 'Manual',
|
||||
'planner': 'Planner',
|
||||
'ai': 'AI',
|
||||
}
|
||||
source_options = [
|
||||
{'value': s, 'label': source_labels.get(s, s.title())}
|
||||
for s in sources
|
||||
]
|
||||
|
||||
return success_response(
|
||||
data={
|
||||
'statuses': status_options,
|
||||
'content_types': content_type_options,
|
||||
'content_structures': content_structure_options,
|
||||
'clusters': cluster_options,
|
||||
'sources': source_options,
|
||||
},
|
||||
request=request
|
||||
)
|
||||
except Exception as e:
|
||||
logger.error(f"Error in filter_options: {str(e)}", exc_info=True)
|
||||
return error_response(
|
||||
error=f'Failed to fetch filter options: {str(e)}',
|
||||
status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
|
||||
request=request
|
||||
)
|
||||
|
||||
|
||||
@extend_schema_view(
|
||||
|
||||
Reference in New Issue
Block a user