add

search/views/group.py

@@ -165,7 +165,7 @@ def pictorial_topic(topic_id=-1, offset=0, size=10):
                         "term": {
                             "is_online": True
                         }
-                    },{
+                    }, {
                         "term": {
                             "is_deleted": False
                         }
@@ -200,3 +200,44 @@ def pictorial_topic(topic_id=-1, offset=0, size=10):
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
         return {"pictorial_ids_list": []}
+
+
+@bind("physical/search/pictorial_topic_sort")
+def pictorial_topic_sort(pictorial_id=-1, offset=0, size=10):
+    """
+    :remark 小组排序,缺少：前1天发评论人数＊x
+    :param user_id:
+    :param sort_type:
+    :param offset:
+    :param size:
+    :return:
+    """
+    try:
+        if not isinstance(pictorial_id, int):
+            user_id = -1
+
+        q = {
+            "query":{
+                "term":{
+                    "pictorial_id": pictorial_id}
+            },
+            "sort":{
+                "vote_num":{"order":"desc"}
+            }
+        }
+        pict_pictorial_ids_list =[]
+        # 获取es链接对象
+        es_cli_obj = ESPerform.get_cli()
+        result_dict = ESPerform.get_search_results(es_cli_obj, "topic", q, offset, size)
+
+        logging.info("get pictorial_topic_sort res:%s"%result_dict)
+
+        for item in result_dict["hits"]:
+            topic_id = item["_source"]["id"]
+            pict_pictorial_ids_list.append(topic_id)
+
+        return {"pict_pictorial_ids_list":pict_pictorial_ids_list}
+
+    except:
+        logging.error("catch exception,err_msg:%s" % traceback.format_exc())
+        return {"pict_pictorial_ids_list": []}