add batch_recommend_user

libs/es.py

@@ -197,7 +197,7 @@ class ESPerform(object):
                         result_dict["aggregations"] = res["aggregations"]
                     return result_dict
             else:
-                res = es_cli.msearch(body="\n".join(str(query_item) for query_item in query_body), index=official_index_name, doc_type=doc_type)
+                res = es_cli.msearch(body=query_body index=official_index_name, doc_type=doc_type)
 
                 logging.info("duan add,msearch res:%s" % str(res))
                 return res

search/utils/user.py

@@ -244,7 +244,10 @@ class UserUtils(object):
                     batch_query_list.append(q)
 
 
-            result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name="user", query_body=batch_query_list,
+            query_body = ""
+            for query_item in batch_query_list:
+                query_body += "%s \n" % json.dumps(query_item)
+            result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name="user", query_body=query_body,
                                                        batch_search=True)
             return result_dict
         except: