Merge branch 'houta' into 'master'

add

See merge request alpha/physical!207

search/utils/topic.py

@@ -584,6 +584,12 @@ class TopicUtils(object):
 
         for k, v in filters.items():
 
+            if k == "is_complaint":
+                f.append({
+                    "term": {k: v},
+                })
+
+
             if not v:
                 continue
 
@@ -723,3 +729,68 @@ class TopicUtils(object):
                 "hits": [],
                 "total_count": 0
             }
+
+
+    @classmethod
+    def business_topic_ids(cls, filters, nfilters, sorts_by, offset=0, size=10, index_name="topic", filter_online=True):
+
+        must = cls.process_filters(filters, filter_online=filter_online)
+        query = ''
+        for k, v in filters.items():
+            if k == "content":
+                query = filters[k]
+        q = {}
+        q["query"] = {
+            "function_score": {
+                "functions": [{
+                    "filter": {
+                        "bool": {
+                            "must": must,
+                            "must_not": cls.process_nfilters(nfilters),
+                        }
+                    },
+                    "weight": 1
+                }],
+                "query": {
+                    "multi_match": {
+                        "fields":["content"],
+                        "type": "cross_fields",
+                        "operator": "and",
+                        "query": query
+
+                    }
+                }
+            }
+
+        }
+        if query == '':
+            q["query"] = {
+                "bool": {
+                    "must": must,
+                    "must_not": cls.process_nfilters(nfilters),
+                    }
+
+            }
+
+        logging.info("get query business_topic:%s" % q)
+        if sorts_by:
+            sorts = cls.process_sort(sorts_by)
+            if sorts:
+                q["sort"] = sorts
+
+        try:
+            result_dict = ESPerform.get_search_results(
+                ESPerform.get_cli(), sub_index_name=index_name,
+                query_body=q, offset=offset, size=size
+            )
+
+            return {
+                "hits": result_dict["hits"],
+                "total_count": result_dict["total_count"]
+            }
+        except:
+            logging.error("catch exception,err_msg:%s" % traceback.format_exc())
+            return {
+                "hits": [],
+                "total_count": 0
+            }