update

task/daily_search_word_count_last_two_year.py

@@ -16,6 +16,7 @@ import pymysql
 from elasticsearch import Elasticsearch
 import datetime
 
+
 # from maintenance.func_send_email_with_file import send_file_email
 # import zipfile
 
@@ -29,8 +30,6 @@ import datetime
 #     }])
 
 
-
-
 def get_all_tag():
     res_dict = {}
     sql = "select name from api_tag where is_online = 1 and tag_type = 3"
@@ -60,21 +59,11 @@ def from_es_get_service_num(query):
         }
     ])
 
-    q = {
-        "query": {
-            "bool": {
-                "must": {
-                    "multi_match": {
-                        "query": query,
-                        "fields": ["name", "sku_list.name"],
-                        "operator": "and",
-                        "type": "best_fields",
-                        "analyzer": "ik_max_word"
-                    }
-                }
-            }
-        }
-    }
+    q = {"query": {"bool": {"must": {"multi_match": {"query": query,
+                                                     "fields": ["short_description", "name", "closure_tags",
+                                                                "sku_list.show_short_description", "sku_list.name",
+                                                                "sku_list.new_sku_tags"], "operator": "and",
+                                                     "type": "best_fields", "analyzer": "ik_max_word"}}}}, "size": 0}
 
     results = es.search(
         index='gm-dbmw-service',
@@ -308,7 +297,7 @@ for t in range(1, task_days):
         pv = name.all_search_pv
         uv = name.all_search_uv
         is_tag = tag_dict.get(keywords, 0)
-        
+
         is_delete = 0 if keyword_dict.get(keywords) else 1
         if not is_delete:
             servise_num = from_es_get_service_num(keywords)