def _constructSolrQuery()

in plugins/samos/json/Writer.py [0:0]
77 lines of code
41 McCabe index (conditional complexity)

    def _constructSolrQuery(self, startIndex, entriesPerPage, parameters, facets):
        # if no QC flag is given, default to only good
        if not "qualityFlag" in list(parameters.keys()):
            parameters['qualityFlag'] = 1

        queries = []
        filterQueries = []
        sort = None

        for key, value in parameters.items():
            if value != "":
                if key == 'keyword':
                    queries.append(urllib.parse.quote(value))
                elif key == 'startTime':
                    filterQueries.append('time:['+value+'%20TO%20*]')
                elif key == 'endTime':
                    filterQueries.append('time:[*%20TO%20'+value+']')
                elif key == 'bbox':
                    coordinates = value.split(",")
                    filterQueries.append('loc:[' + coordinates[1] + ',' + coordinates[0] + '%20TO%20' + coordinates[3] + ',' + coordinates[2] + ']')
                elif key == 'variable':
                    if value.lower() == 'sss':
                        filterQueries.append('SSS:[*%20TO%20*]')
                    elif value.lower() == 'sst':
                        filterQueries.append('SST:[*%20TO%20*]')
                    elif value.lower() == 'wind':
                        filterQueries.append('wind_speed:[*%20TO%20*]')
                elif key == "minDepth":
                    if 'variable' in parameters:
                        if parameters['variable'].lower() == 'sss':
                            filterQueries.append('(SSS_depth:['+value+'%20TO%20*]+OR+(*:*%20NOT%20SSS_depth:*))')
                        elif parameters['variable'].lower() == 'sst':
                            filterQueries.append('(SST_depth:['+value+'%20TO%20*]+OR+(*:*%20NOT%20SST_depth:*))')
                        elif parameters['variable'].lower() == 'wind':
                            filterQueries.append('(wind_depth:['+value+'%20TO%20*]+OR+(*:*%20NOT%20wind_depth:*))')
                elif key == "maxDepth":
                    if 'variable' in parameters:
                        if parameters['variable'].lower() == 'sss':
                            filterQueries.append('(SSS_depth:[*%20TO%20'+value+']+OR+(*:*%20NOT%20SSS_depth:*))')
                        elif parameters['variable'].lower() == 'sst':
                            filterQueries.append('(SST_depth:[*%20TO%20'+value+']+OR+(*:*%20NOT%20SST_depth:*))')
                        elif parameters['variable'].lower() == 'wind':
                            filterQueries.append('(wind_depth:[*%20TO%20'+value+']+OR+(*:*%20NOT%20wind_depth:*))')
                # include data only at specified quality level and have default at good in UI
                elif key == "qualityFlag":
                    if 'variable' in parameters:
                        if parameters['variable'].lower() == 'sss':
                            if type(value) is list:
                                filterQueries.append('(SSS_quality:(' + '+OR+'.join(value) + '))')
                            else:
                                filterQueries.append('(SSS_quality:(' + value + '))')
                        elif parameters['variable'].lower() == 'sst':
                            if type(value) is list:
                                filterQueries.append('(SST_quality:(' + '+OR+'.join(value) + '))')
                            else:
                                filterQueries.append('(SST_quality:(' + value + '))')
                        elif parameters['variable'].lower() == 'wind':
                            if type(value) is list:
                                filterQueries.append('(wind_speed_quality:(' + '+OR+'.join(value) + '))')
                                filterQueries.append('(wind_component_quality:(' + '+OR+'.join(value) + '))')
                            else:
                                filterQueries.append('(wind_speed_quality:(' + value + '))')
                                filterQueries.append('(wind_component_quality:(' + value + '))')
                elif key == 'platform':
                    if type(value) is list:
                        filterQueries.append('platform:(' + '+OR+'.join(value) + ')')
                    else:
                        filterQueries.append('platform:'+value)

        if len(queries) == 0:
            queries.append('*:*')

        query = 'q='+'+AND+'.join(queries)+'&wt=json&start='+str(startIndex)+'&rows='+str(entriesPerPage)

        if len(filterQueries) > 0:
            query += '&fq='+'+AND+'.join(filterQueries)

        if sort is not None:
            query += '&sort=' + sort

        if 'stats' in parameters and parameters['stats'].lower() == 'true':
            query += '&stats=true&stats.field={!min=true%20max=true}SSS_depth&stats.field={!min=true%20max=true}SST_depth&stats.field={!min=true%20max=true}wind_depth'

        if 'facet' in parameters and parameters['facet'].lower() == 'true':
            query += '&facet=true&facet.field=platform&facet.field=device&facet.limit=-1&facet.mincount=1'

        logging.debug('solr query: '+query)

        return query