Merge branch 'feature/sun_topic2es' into 'master'

Feature/sun topic2es

See merge request !200

search/utils/topic.py

@@ -579,27 +579,25 @@ class TopicUtils(object):
         f = [
             {"term": {"is_deleted": False}},
         ]
+        _range = {}
         if not filters:
             return f
 
         for k, v in filters.items():
 
+            if not v:
+                continue
+
             if k in ["create_time_gte", "create_time_lte"]:
 
                 if k == "create_time_gte":
                     op = "gte"
+                    _range.update({op:v})
                 elif k == "create_time_lte":
                     op = "lte"
-
-                f.append({
-                    "range": {
-                        "create_time_val": {
-                            op: v,
-                        }
-                    }
-                })
+                    _range.update({op: v})
             else:
-                if isinstance(k, list):
+                if isinstance(v, list):
                     f.append({
                         "terms": {k: v},
                     })
@@ -607,7 +605,7 @@ class TopicUtils(object):
                     f.append({
                         "term": {k: v},
                     })
-
+        f.append({"range": {"create_time_val": _range}})
         if filter_online:
             f.append({"term": {"is_online": True}})
 
@@ -631,6 +629,7 @@ class TopicUtils(object):
         """处理排序部分。"""
 
         sort_rule = []
+        if isinstance(sorts_by, int):
             if sorts_by == TOPIC_SEARCH_SORT.VOTE_NUM:
                 sort_rule.append({
                     "vote_num":{
@@ -641,22 +640,39 @@ class TopicUtils(object):
                     },
                 })
 
-        elif sorts_by == TOPIC_SEARCH_SORT.VOTE_NUM:
-            pass
-
-        elif sorts_by == '2':
+        elif isinstance(sorts_by, list):
+            for sort_by in sorts_by:
+                if sort_by == TOPIC_SEARCH_SORT.ID_AEC:
+                    sort_rule.append({
+                        "id":{
+                            "order":"asc"
+                        },
+                    })
+                elif sort_by == TOPIC_SEARCH_SORT.ID_DESC:
                     sort_rule.append({
                         "id":{
                             "order":"desc"
                         },
                     })
+                elif sort_by == TOPIC_SEARCH_SORT.SCORE_AEC:
+                    sort_rule.append({
+                        "sort_score":{
+                            "order":"asc"
+                        },
+                    })
+                elif sort_by == TOPIC_SEARCH_SORT.SCORE_DESC:
+                    sort_rule.append({
+                        "sort_score":{
+                            "order":"desc"
+                        },
+                    })
 
         return sort_rule
 
     @classmethod
     def list_topic_ids(cls, filters, nfilters, sorts_by, offset=0, size=10, index_name="topic", filter_online=True):
 
-        must = cls.process_filters(filters, filter_online=True)
+        must = cls.process_filters(filters, filter_online=filter_online)
         q = {
             "query": {
                 "bool": {
@@ -668,6 +684,7 @@ class TopicUtils(object):
 
         if sorts_by:
             sorts = cls.process_sort(sorts_by)
+            if sorts:
                 q["sort"] = sorts
 
         try: