Skip to content

P
physical
Commit 42003a85 authored by lixiaofang's avatar lixiaofang
Browse files
Options

add

parents 5db6ed6e 2ec7bbc9
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 1149 additions and 105 deletions
libs/es.py
View file @ 42003a85
...@@ -447,6 +447,53 @@ class ESPerform(object): ...@@ -447,6 +447,53 @@ class ESPerform(object):
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return list() return list()
@classmethod
def get_tag_pictorial_id_list(cls, tag_id, have_read_lin_pictorial_id_list, size=100):
try:
q = {
"query": {
"function_score": {
"query": {
"bool": {
"must": [
{"term": {"is_online": True}},
{"term": {"is_deleted": False}},
{"terms": {"edit_tag_id": tag_id}},
{"term": {"is_recommend": True}}
]
}
},
"boost_mode": "sum",
"score_mode": "sum",
}
},
"_source": {
"include": ["id"]
},
"sort": [
{"real_user_activate_time": {"order": "desc"}},
{"create_time": {"order": "desc"}},
],
}
if len(have_read_lin_pictorial_id_list) > 0:
q["query"]["function_score"]["query"]["bool"]["must_not"] = {
"terms": {
"id": have_read_lin_pictorial_id_list
}
}
result_dict = ESPerform.get_search_results(ESPerform.get_cli(), sub_index_name="pictorial",
query_body=q,
offset=0, size=size)
pictorial_id_list = [item["_source"]["id"] for item in result_dict["hits"]]
# logging.info("topic_id_list:%s" % str(topic_id_list))
# topic_id_dict = [{str(item["_source"]["id"]):item["_source"]["user_id"]} for item in result_dict["hits"]]
return pictorial_id_list
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return list()
@classmethod @classmethod
def get_highlight(cls, fields=[]): def get_highlight(cls, fields=[]):
field_highlight = { field_highlight = {
......
libs/tools.py
View file @ 42003a85
...@@ -39,3 +39,22 @@ def get_have_read_topic_id_list(device_id, user_id, query_type): ...@@ -39,3 +39,22 @@ def get_have_read_topic_id_list(device_id, user_id, query_type):
except: except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return list() return list()
def get_have_read_lin_pictorial_id_list(device_id,user_id,query_type):
try:
if user_id and int(user_id) > 0:
redis_key = "physical:home_pictorial_recommend" + ":user_id:" + str(user_id) + ":query_type:" + str(query_type)
else:
redis_key = "physical:home_pictorial_recommend" + ":device_id:" + str(device_id) + ":query_type:" + str(query_type)
have_read_lin_pictorial_id_list = list()
redis_field_list = ['have_read_pictorial_list']
redis_field_val_list = redis_client.hmget(redis_key, redis_field_list)
if redis_field_val_list[0]:
have_read_lin_pictorial_id_list = list(json.loads(redis_field_val_list[0]))
return have_read_lin_pictorial_id_list
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return list()
linucb/views/collect_data.py
View file @ 42003a85
This diff is collapsed.
linucb/views/linucb.py
View file @ 42003a85
...@@ -10,7 +10,7 @@ import traceback ...@@ -10,7 +10,7 @@ import traceback
import json import json
import pickle import pickle
from django.conf import settings from django.conf import settings
from libs.error import logging_exception
class LinUCB: class LinUCB:
d = 2 d = 2
...@@ -29,10 +29,11 @@ class LinUCB: ...@@ -29,10 +29,11 @@ class LinUCB:
cls.default_tag_list = json.loads(redis_tag_data) if redis_tag_data else [] cls.default_tag_list = json.loads(redis_tag_data) if redis_tag_data else []
if len(cls.default_tag_list) == 0: if len(cls.default_tag_list) == 0:
cls.default_tag_list = Tag.objects.using(settings.SLAVE_DB_NAME).filter(is_online=True,collection=1).values_list("id",flat=True)[0:100] cls.default_tag_list = Tag.objects.using(settings.SLAVE1_DB_NAME).filter(is_online=True,collection=1).values_list("id",flat=True)[0:100]
return cls.default_tag_list return cls.default_tag_list
except: except:
logging_exception()
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return list() return list()
...@@ -103,6 +104,7 @@ class LinUCB: ...@@ -103,6 +104,7 @@ class LinUCB:
logging.info("duan add,device_id:%s,sorted_np_score_list:%s,np_score_dict:%s" % (str(device_id), str(sorted_np_score_list), str(np_score_dict))) logging.info("duan add,device_id:%s,sorted_np_score_list:%s,np_score_dict:%s" % (str(device_id), str(sorted_np_score_list), str(np_score_dict)))
return (top_tag_dict,top_tag_set) return (top_tag_dict,top_tag_set)
except: except:
logging_exception()
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return ({},()) return ({},())
...@@ -126,6 +128,7 @@ class LinUCB: ...@@ -126,6 +128,7 @@ class LinUCB:
return True return True
except: except:
logging_exception()
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return False return False
...@@ -164,5 +167,6 @@ class LinUCB: ...@@ -164,5 +167,6 @@ class LinUCB:
redis_cli.hset(redis_key, tag_id, pickle.dumps(user_tag_dict)) redis_cli.hset(redis_key, tag_id, pickle.dumps(user_tag_dict))
return True return True
except: except:
logging_exception()
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return False return False
\ No newline at end of file
search/utils/group.py
View file @ 42003a85
...@@ -221,7 +221,7 @@ class GroupUtils(object): ...@@ -221,7 +221,7 @@ class GroupUtils(object):
multi_fields = { multi_fields = {
'name': 4, 'name': 4,
'description': 4, 'description': 4,
'tag_name': 4 'edit_tag_name': 4
} }
query_fields = ['^'.join((k, str(v))) for (k, v) in multi_fields.items()] query_fields = ['^'.join((k, str(v))) for (k, v) in multi_fields.items()]
multi_match = { multi_match = {
...@@ -255,12 +255,7 @@ class GroupUtils(object): ...@@ -255,12 +255,7 @@ class GroupUtils(object):
} }
q["sort"] = [ q["sort"] = [
{ {
"_script": { "real_user_activate_time": {
"type": "number",
"script": {
"lang": "expression",
"source": "_score+doc['offline_score']"
},
"order": "desc" "order": "desc"
} }
}, },
......
search/utils/user.py
View file @ 42003a85
...@@ -275,21 +275,21 @@ class UserUtils(object): ...@@ -275,21 +275,21 @@ class UserUtils(object):
for query_item in batch_query_list: for query_item in batch_query_list:
query_body += "{}\n{}\n".format(json.dumps(search_header_dict),json.dumps(query_item)) query_body += "{}\n{}\n".format(json.dumps(search_header_dict),json.dumps(query_item))
result_dict = ESPerform.get_search_results(es_cli_obj, sub_index_name="user", query_body=query_body,
batch_search=True)
ret_dict = dict() ret_dict = dict()
user_index = 0 if len(query_body)>0:
for res_item in result_dict["responses"]: result_dict = ESPerform.get_search_results(es_cli_obj, sub_index_name="user", query_body=query_body,
recommend_user_list = list() batch_search=True)
for item in res_item["hits"]["hits"]: user_index = 0
recommend_user_list.append(item["_source"]["user_id"]) for res_item in result_dict["responses"]:
recommend_user_list = list()
for item in res_item["hits"]["hits"]:
recommend_user_list.append(item["_source"]["user_id"])
logging.info("duan add,attention_user_id_list:%s,user_index:%d" % (str(attention_user_id_list), user_index)) logging.info("duan add,attention_user_id_list:%s,user_index:%d" % (str(attention_user_id_list), user_index))
ret_dict[str(attention_user_id_list[user_index])] = recommend_user_list ret_dict[str(attention_user_id_list[user_index])] = recommend_user_list
user_index += 1 user_index += 1
logging.info("duan add,ret_dict:%s" % str(ret_dict))
return ret_dict return ret_dict
except: except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
......
search/views/group.py
View file @ 42003a85
...@@ -13,6 +13,7 @@ from libs.es import ESPerform ...@@ -13,6 +13,7 @@ from libs.es import ESPerform
from search.utils.group import GroupUtils from search.utils.group import GroupUtils
from search.utils.common import GroupSortTypes from search.utils.common import GroupSortTypes
from libs.es import ESPerform from libs.es import ESPerform
from trans2es.models.topic import CommunityCategoryTagRelation
from trans2es.models.pictorial import PictorialTopics from trans2es.models.pictorial import PictorialTopics
from trans2es.models.pictorial import CommunityPictorialActivity from trans2es.models.pictorial import CommunityPictorialActivity
from alpha_types.venus import PICTORIAL_ACTIVITY_SORT, PICTORIAL_TOPIC_SORT from alpha_types.venus import PICTORIAL_ACTIVITY_SORT, PICTORIAL_TOPIC_SORT
...@@ -96,6 +97,10 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0, ...@@ -96,6 +97,10 @@ def pictorial_sort(user_id=-1, sort_type=GroupSortTypes.HOT_RECOMMEND, offset=0,
@bind("physical/search/pictorial_topic") @bind("physical/search/pictorial_topic")
def pictorial_topic(topic_id=-1, offset=0, size=10): def pictorial_topic(topic_id=-1, offset=0, size=10):
""" """
帖子详情页的榜单推荐
先获取该帖子所属榜单 过滤下线的无帖子的被删除的榜单
再根据该帖子下的标签去获取有这些标签的榜单
最后根据该标签对应的分类标签去获取榜单
:remark 入选画报 :remark 入选画报
:param user_id: :param user_id:
:param sort_type: :param sort_type:
...@@ -108,7 +113,7 @@ def pictorial_topic(topic_id=-1, offset=0, size=10): ...@@ -108,7 +113,7 @@ def pictorial_topic(topic_id=-1, offset=0, size=10):
# 获取es链接对象 # 获取es链接对象
es_cli_obj = ESPerform.get_cli() es_cli_obj = ESPerform.get_cli()
q = {} q = {}
# 获取帖子从属的画报 # 获取帖子及该帖子的标签
q["query"] = { q["query"] = {
"bool": { "bool": {
"must": [ "must": [
...@@ -143,26 +148,30 @@ def pictorial_topic(topic_id=-1, offset=0, size=10): ...@@ -143,26 +148,30 @@ def pictorial_topic(topic_id=-1, offset=0, size=10):
for item in result_dict["hits"]: for item in result_dict["hits"]:
pict_pictorial_ids_list = item["_source"]["pictorial_id"] pict_pictorial_ids_list = item["_source"]["pictorial_id"]
topic_tag_list = item["_source"]["tag_list"] topic_tag_list = item["_source"]["tag_list"]
##先拿到当前帖子对应的标签的分类ID
tag_type_ids = CommunityCategoryTagRelation.objects.filter(tag_id__in=topic_tag_list,
is_online=True, is_deleted=False).values_list(
"category_tag_id", flat=True)
logging.info("get tag_type_ids:%s" % tag_type_ids)
# 拿到所属榜单
if len(pict_pictorial_ids_list) > 0:
q["query"] = { q["query"] = {
"bool": { "bool": {
"must": [{ "must": [{
"terms": { "terms": {
"id": pict_pictorial_ids_list "id": pict_pictorial_ids_list
} }
}, },
{ {
"term": { "term": {
"is_online": True "is_online": True
} }
}, },
{ {
"term": { "term": {
"is_deleted": False "is_deleted": False
} }
}, },
] ]
} }
...@@ -183,13 +192,18 @@ def pictorial_topic(topic_id=-1, offset=0, size=10): ...@@ -183,13 +192,18 @@ def pictorial_topic(topic_id=-1, offset=0, size=10):
pictorial_id = item["_source"]["id"] pictorial_id = item["_source"]["id"]
pictorial_id_list.append(pictorial_id) pictorial_id_list.append(pictorial_id)
if len(pictorial_id_list) < 10: functions_list = []
all_tag = []
all_tag.extend(topic_tag_list)
all_tag.extend(tag_type_ids)
# 如果不够10个去拿所属标签的榜单和所属分类的标签的榜单
if len(pictorial_id_list) < 10 and len(all_tag) > 0:
num = 10 - len(pictorial_id_list) num = 10 - len(pictorial_id_list)
q["query"] = { query = {
"bool": { "bool": {
"must": [{ "must": [{
"terms": { "terms": {
"tag_id": topic_tag_list "tag_id": all_tag
}}, { }}, {
"term": { "term": {
"is_online": True "is_online": True
...@@ -208,31 +222,56 @@ def pictorial_topic(topic_id=-1, offset=0, size=10): ...@@ -208,31 +222,56 @@ def pictorial_topic(topic_id=-1, offset=0, size=10):
}] }]
} }
} }
functions_list.append({
"filter": {
"constant_score": {
"filter": {
"terms": {
"tag_id": topic_tag_list
}
}
}
},
"weight": 200
})
q = {
"query": {
"function_score": {
"query": query,
"score_mode": "sum",
"boost_mode": "replace",
"functions": functions_list
}
}
}
q["_source"] = { q["_source"] = {
"includes": ["id", "tag_id"]} "includes": ["id", "tag_id"]}
q["sort"] = { q["sort"] = [
'update_time': { {
'order': 'desc' "_score": {
"order": "desc"
}} }
q["from"] = 0 },
q["size"] = 10 {
'update_time': {
'order': 'desc'
result_dict = ESPerform.get_search_results(es_cli_obj, "pictorial", q, offset, size) }
}
]
result_dict = ESPerform.get_search_results(es_cli_obj, "pictorial", q, 0, 10)
logging.info("get result_dict:%s" % result_dict)
if len(result_dict["hits"]) > 0: if len(result_dict["hits"]) > 0:
for item in result_dict["hits"]: for item in result_dict["hits"]:
id = item["_source"]["id"] id = item["_source"]["id"]
if id not in pictorial_id_list: if id not in pictorial_id_list:
pictorial_id_list.append(id) # pictorial_id_list.append(id) #
pictorial_list = pictorial_id_list if len(pictorial_id_list) < 10 else pictorial_id_list[:10] pictorial_list = pictorial_id_list if len(pictorial_id_list) < 10 else pictorial_id_list[:10]
return {"pictorial_ids_list": pictorial_list} return {"pictorial_ids_list": pictorial_list}
else: else:
return {"pictorial_ids_list": pictorial_id_list} return {"pictorial_ids_list": pictorial_id_list}
except: except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return {"pictorial_ids_list": []} return {"pictorial_ids_list": []}
...@@ -283,7 +322,6 @@ def pictorial_topic_sort(pictorial_id=-1, offset=0, size=10, sort_type=PICTORIAL ...@@ -283,7 +322,6 @@ def pictorial_topic_sort(pictorial_id=-1, offset=0, size=10, sort_type=PICTORIAL
if not isinstance(pictorial_id, int): if not isinstance(pictorial_id, int):
pictorial_id = -1 pictorial_id = -1
q = { q = {
"query": { "query": {
"bool": { "bool": {
......
search/views/topic.py
View file @ 42003a85
This diff is collapsed.
trans2es/mapping/pictorial.json
View file @ 42003a85
...@@ -21,7 +21,12 @@ ...@@ -21,7 +21,12 @@
"is_default":{"type":"long"}, "is_default":{"type":"long"},
"is_cover":{"type":"boolean"}, "is_cover":{"type":"boolean"},
"topic_vote_number":{"type":"long"}, "topic_vote_number":{"type":"long"},
"activity_join":{"type":"long"} "activity_join":{"type":"long"},
"latest_real_reply_time":{"type":"date", "format":"date_time_no_millis"},
"latest_real_topic_time":{"type":"date", "format":"date_time_no_millis"},
"real_user_activate_time":{"type":"date", "format":"date_time_no_millis"},
"edit_tag_id":{"type":"long"},
"edit_tag_name":{"type":"text","analyzer":"gm_default_index","search_analyzer":"gm_default_search"}
} }
} }
trans2es/models/pictorial.py
View file @ 42003a85
...@@ -2,9 +2,11 @@ import datetime ...@@ -2,9 +2,11 @@ import datetime
from django.db import models from django.db import models
import logging import logging
import traceback import traceback
from django.conf import settings
from trans2es.models.topic import Reply
from .tag import Tag from .tag import Tag
from .topic import Topic, TopicBillBoard from .topic import Topic, TopicBillBoard
from .user_extra import UserExtra
class PictorialFollow(models.Model): class PictorialFollow(models.Model):
...@@ -111,7 +113,8 @@ class Pictorial(models.Model): ...@@ -111,7 +113,8 @@ class Pictorial(models.Model):
def get_tag_by_id(self): def get_tag_by_id(self):
try: try:
tag_id_list = list( tag_id_list = list(
PictorialTag.objects.filter(pictorial_id=self.id, is_online=True).values_list("tag_id", flat=True)) PictorialTag.objects.filter(pictorial_id=self.id, is_online=True, is_collection=1).values_list("tag_id",
flat=True))
return tag_id_list return tag_id_list
except: except:
...@@ -127,6 +130,27 @@ class Pictorial(models.Model): ...@@ -127,6 +130,27 @@ class Pictorial(models.Model):
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return [] return []
def get_edit_tag_id(self):
try:
tag_id_list = list(
PictorialTag.objects.filter(pictorial_id=self.id, is_online=True, is_collection=1).values_list("tag_id",
flat=True))
return tag_id_list
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return []
def get_edit_tag_name(self, tag_id):
try:
tag_name_list = list(
Tag.objects.filter(id__in=tag_id, is_online=True).values_list("name", flat=True))
return tag_name_list
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return []
def get_is_cover(self, topic_id_list): def get_is_cover(self, topic_id_list):
try: try:
effective_num = 0 effective_num = 0
...@@ -171,6 +195,108 @@ class Pictorial(models.Model): ...@@ -171,6 +195,108 @@ class Pictorial(models.Model):
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return [] return []
def get_latest_real_reply_time(self):
try:
reply_query_results = Reply.objects.using(settings.SLAVE_DB_NAME).filter(pictorial_id=self.id, is_deleted=0,
is_online=1).values("user_id",
"create_time")
datetime_list = list()
if reply_query_results.count() > 0:
for reply in reply_query_results:
UserExtra_results = UserExtra.objects.using(settings.SLAVE_DB_NAME).filter(
user_id=reply['user_id']).values('is_shadow')
if UserExtra_results.count() > 0:
if not UserExtra_results[0]['is_shadow']:
datetime_list.append(reply['create_time'])
else:
datetime_list.append(reply['create_time'])
if len(datetime_list) > 0:
dt = max(datetime_list)
return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second,
tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
else:
return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
except:
return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
def get_latest_real_topic_time(self):
try:
topic_id_list = list(
PictorialTopics.objects.filter(pictorial_id=self.id, is_online=True, is_deleted=False).values_list(
"topic_id", flat=True))
logging.info("get topic_id_list:%s" % topic_id_list)
topic_info = Topic.objects.filter(id__in=topic_id_list).values("user_id", "create_time")
logging.info("get topic_info:%s" % topic_info)
datetime_list = list()
if topic_info.count() > 0:
for topic in topic_info:
UserExtra_results = UserExtra.objects.using(settings.SLAVE_DB_NAME).filter(
user_id=topic['user_id']).values('is_shadow')
if UserExtra_results.count() > 0:
if not UserExtra_results[0]['is_shadow']:
datetime_list.append(topic['create_time'])
else:
datetime_list.append(topic['create_time'])
logging.info("get datetime_list:%s" % datetime_list)
if len(datetime_list) > 0:
dt = max(datetime_list)
logging.info("get max datetime_list:%s" % dt)
return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second,
tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
else:
return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
except:
return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
def get_real_user_activate_time(self):
try:
reply_query_results = Reply.objects.using(settings.SLAVE_DB_NAME).filter(pictorial_id=self.id, is_deleted=0,
is_online=1).values("user_id",
"create_time")
datetime_list = list()
if reply_query_results.count() > 0:
for reply in reply_query_results:
UserExtra_results = UserExtra.objects.using(settings.SLAVE_DB_NAME).filter(
user_id=reply['user_id']).values('is_shadow')
if UserExtra_results.count() > 0:
if not UserExtra_results[0]['is_shadow']:
datetime_list.append(reply['create_time'])
else:
datetime_list.append(reply['create_time'])
topic_id_list = list(
PictorialTopics.objects.filter(pictorial_id=self.id, is_online=True, is_deleted=False).values_list(
"topic_id", flat=True))
topic_info = Topic.objects.filter(id__in=topic_id_list, is_online=1).values("user_id", "create_time")
if topic_info.count() > 0:
for topic in topic_info:
UserExtra_results = UserExtra.objects.using(settings.SLAVE_DB_NAME).filter(
user_id=topic['user_id']).values('is_shadow')
if UserExtra_results.count() > 0:
if not UserExtra_results[0]['is_shadow']:
datetime_list.append(topic['create_time'])
else:
datetime_list.append(topic['create_time'])
logging.info("get datetime_list:%s" % datetime_list)
if len(datetime_list) > 0:
dt = max(datetime_list)
logging.info("get max datetime_list:%s" % dt)
return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second,
tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
else:
return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
except:
return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
class PictorialTag(models.Model): class PictorialTag(models.Model):
"""画报关注标签""" """画报关注标签"""
...@@ -186,6 +312,7 @@ class PictorialTag(models.Model): ...@@ -186,6 +312,7 @@ class PictorialTag(models.Model):
pictorial_id = models.BigIntegerField(verbose_name=u'画报ID', max_length=20) pictorial_id = models.BigIntegerField(verbose_name=u'画报ID', max_length=20)
tag_id = models.BigIntegerField(verbose_name=u'标签ID', max_length=20) tag_id = models.BigIntegerField(verbose_name=u'标签ID', max_length=20)
is_online = models.BooleanField(verbose_name=u'是否上线', max_length=1) is_online = models.BooleanField(verbose_name=u'是否上线', max_length=1)
is_collection = models.IntegerField(verbose_name=u"是否编辑标签")
class CommunityPictorialActivity(models.Model): class CommunityPictorialActivity(models.Model):
...@@ -214,3 +341,15 @@ class CommunityPictorialActivityRelation(models.Model): ...@@ -214,3 +341,15 @@ class CommunityPictorialActivityRelation(models.Model):
is_deleted = models.BooleanField(verbose_name=u'是否被删除', max_length=1) is_deleted = models.BooleanField(verbose_name=u'是否被删除', max_length=1)
pictorial_activity_id = models.BigIntegerField(verbose_name=u'活动ID', max_length=20) pictorial_activity_id = models.BigIntegerField(verbose_name=u'活动ID', max_length=20)
pictorial_id = models.BigIntegerField(verbose_name=u'榜单ID', max_length=20) pictorial_id = models.BigIntegerField(verbose_name=u'榜单ID', max_length=20)
class CommunityPictorialHomeFeed(models.Model):
"""运营榜单"""
class Meta:
verbose_name = u"运营画报"
app_label = "community"
db_table = "community_pictorial_home_feed"
is_online = models.BooleanField(verbose_name=u'是否上线', max_length=1)
is_deleted = models.BooleanField(verbose_name=u'是否被删除', max_length=1)
pictorial_id = models.BigIntegerField(verbose_name=u'榜单ID', max_length=20)
trans2es/models/tag.py
View file @ 42003a85
...@@ -53,6 +53,7 @@ class Tag(models.Model): ...@@ -53,6 +53,7 @@ class Tag(models.Model):
is_own = models.IntegerField(verbose_name=u"是否ins上自带") is_own = models.IntegerField(verbose_name=u"是否ins上自带")
create_time = models.DateTimeField(verbose_name=u'创建时间', default=datetime.datetime.fromtimestamp(0)) create_time = models.DateTimeField(verbose_name=u'创建时间', default=datetime.datetime.fromtimestamp(0))
update_time = models.DateTimeField(verbose_name=u'更新时间', default=datetime.datetime.fromtimestamp(0)) update_time = models.DateTimeField(verbose_name=u'更新时间', default=datetime.datetime.fromtimestamp(0))
is_category = models.IntegerField(verbose_name=u"是否大分类")
class CommunityTagFollow(models.Model): class CommunityTagFollow(models.Model):
......
trans2es/models/topic.py
View file @ 42003a85
...@@ -96,6 +96,8 @@ class Topic(models.Model): ...@@ -96,6 +96,8 @@ class Topic(models.Model):
is_shadow = models.BooleanField(verbose_name="是否是马甲账户", default=False) is_shadow = models.BooleanField(verbose_name="是否是马甲账户", default=False)
platform = models.IntegerField(verbose_name=u'平台来源', choices=GRAP_PLATFORM, default=GRAP_PLATFORM.ALPHA) platform = models.IntegerField(verbose_name=u'平台来源', choices=GRAP_PLATFORM, default=GRAP_PLATFORM.ALPHA)
platform_id = models.BigIntegerField(verbose_name='用平台ID', null=True) platform_id = models.BigIntegerField(verbose_name='用平台ID', null=True)
have_face = models.BooleanField(verbose_name=u"是否有图片", default=False)
def get_virtual_vote_num(self): def get_virtual_vote_num(self):
...@@ -319,22 +321,25 @@ class Topic(models.Model): ...@@ -319,22 +321,25 @@ class Topic(models.Model):
datetime_list = list() datetime_list = list()
if reply_query_results.count() > 0: if reply_query_results.count() > 0:
for reply in reply_query_results: for reply in reply_query_results:
UserExtra_results = UserExtra.objects.using(settings.SLAVE_DB_NAME).filter(user_id=reply['user_id']).values('is_shadow') UserExtra_results = UserExtra.objects.using(settings.SLAVE_DB_NAME).filter(
if UserExtra_results.count()>0: user_id=reply['user_id']).values('is_shadow')
if not UserExtra_results[0]['is_shadow']: if UserExtra_results.count() > 0:
datetime_list.append(reply['create_time']) if not UserExtra_results[0]['is_shadow']:
if len(datetime_list)>0: datetime_list.append(reply['create_time'])
dt = max(datetime_list) if len(datetime_list) > 0:
return datetime.datetime(dt.year,dt.month,dt.day,dt.hour, dt.minute, dt.second,tzinfo=datetime.timezone(datetime.timedelta(hours=8))) dt = max(datetime_list)
return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second,
tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
else: else:
dt = self.create_time dt = self.create_time
return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second, return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second,
tzinfo=datetime.timezone(datetime.timedelta(hours=8))) tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
else: else:
dt = self.create_time dt = self.create_time
return datetime.datetime(dt.year,dt.month,dt.day,dt.hour, dt.minute, dt.second,tzinfo=datetime.timezone(datetime.timedelta(hours=8))) return datetime.datetime(dt.year, dt.month, dt.day, dt.hour, dt.minute, dt.second,
tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
except: except:
return datetime.datetime(1980,1,1,0,0,0,tzinfo=datetime.timezone(datetime.timedelta(hours=8))) return datetime.datetime(1980, 1, 1, 0, 0, 0, tzinfo=datetime.timezone(datetime.timedelta(hours=8)))
class TopicComplaint(models.Model): class TopicComplaint(models.Model):
...@@ -411,6 +416,7 @@ class TopicBillBoard(models.Model): ...@@ -411,6 +416,7 @@ class TopicBillBoard(models.Model):
class Reply(models.Model): class Reply(models.Model):
"""帖子回复""" """帖子回复"""
class Meta: class Meta:
verbose_name = "帖子回复" verbose_name = "帖子回复"
db_table = "reply" db_table = "reply"
...@@ -420,4 +426,30 @@ class Reply(models.Model): ...@@ -420,4 +426,30 @@ class Reply(models.Model):
create_time = models.DateTimeField(verbose_name=u'创建时间') create_time = models.DateTimeField(verbose_name=u'创建时间')
is_deleted = models.BooleanField(verbose_name=u'是否删除') is_deleted = models.BooleanField(verbose_name=u'是否删除')
is_online = models.BooleanField(verbose_name=u'是否上线') is_online = models.BooleanField(verbose_name=u'是否上线')
pictorial_id = models.IntegerField(verbose_name=u"榜单ID")
class CommunityTopicProduct(models.Model):
"""帖子商品信息"""
class Meta:
verbose_name = "帖子商品信息"
db_table = "community_topic_product"
topic_id = models.IntegerField(verbose_name=u"帖子ID")
product_id = models.IntegerField(verbose_name=u'商品ID')
create_time = models.DateTimeField(verbose_name=u'创建时间')
is_deleted = models.BooleanField(verbose_name=u'是否删除')
class CommunityCategoryTagRelation(models.Model):
class Meta:
verbose_name = u"标签分类对应关系"
db_table = "community_category_tag_relation"
id = models.IntegerField(primary_key=True, verbose_name=u"主键ID")
is_deleted = models.BooleanField(verbose_name=u"是否删除")
is_online = models.BooleanField(verbose_name=u"是否上线")
tag_id = models.IntegerField(verbose_name=u"标签ID")
category_tag_id = models.IntegerField(verbose_name=u"标签类型ID")
create_time = models.DateTimeField(verbose_name=u'创建时间', default=datetime.datetime.fromtimestamp(0))
update_time = models.DateTimeField(verbose_name=u'更新时间', default=datetime.datetime.fromtimestamp(0))
trans2es/utils/pictorial_transfer.py
View file @ 42003a85
...@@ -70,6 +70,12 @@ class PictorialTransfer(object): ...@@ -70,6 +70,12 @@ class PictorialTransfer(object):
res["is_cover"] = instance.get_is_cover(res["topic_id_list"]) res["is_cover"] = instance.get_is_cover(res["topic_id_list"])
res["topic_vote_number"] = instance.get_topic_vote_number() res["topic_vote_number"] = instance.get_topic_vote_number()
res["activity_join"] = instance.get_activity_join() res["activity_join"] = instance.get_activity_join()
res["latest_real_reply_time"] = instance.get_latest_real_reply_time()
res["latest_real_topic_time"] = instance.get_latest_real_topic_time()
res["real_user_activate_time"] = instance.get_real_user_activate_time()
res["edit_tag_id"] = instance.get_edit_tag_id()
res["edit_tag_name"] = instance.get_edit_tag_name(res["edit_tag_id"])
logging.info("get data:%s" % res)
return res return res
except: except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc()) logging.error("catch exception,err_msg:%s" % traceback.format_exc())
......
vest/data/beauty_reply_data.txt 0 → 100644
View file @ 42003a85
我是干皮，美妆小白一个😂不知道怎么选😁就是想让自己的肤色看上去白一点,本身肤色偏黄，小仙女能不能推荐一款啊谢谢:-)
想要想要想要想要
卧槽也太好看了。。
太好看了！！！想入手！
这个色调透露一种高贵冷艳的气质，也太显白了叭
我加入购物车了！
冲冲冲！！！好爱了喔
妈耶！太好看了吧！黄皮女孩的福音
一直在犹豫买哪个色号结果到最后手里零花钱所剩无几
没用过他家的东西诶，怎么样啊
看了就想买系列
感觉很润的样子
你太美了 唇色好喜欢
妈呀！太干净舒服了吧！果断收藏、转发
用的是什么相机啊！！
颜色看起来还不错，哈哈哈
这个好漂亮啊，我要种草了
这个无敌是最爱了
这个系列超级难卸啊啊啊，我用Mac眼唇卸妆液，擦到脸发麻了还卸不掉
我有这个、不知道是不是买到假货了、感觉颜色久了会很深
好看，很适合日常哇！
我比较想看粉底液的，毕竟底妆真的很重要
想看你试试国货橘朵的唇釉，最近经常看到小姐姐在推
听说这个系列的质地不是很好，不敢下手
瞬间种草了，这个颜色发现也很适合我、买买
想知道夏天干皮用什么底妆，技能持久，又不脱妆
好温柔的颜色！好好看！想看美宝莲才出的小灯管SRD04或56
诶嘛，终于更新了
这个颜色，我先下单了，然后又退……
怎么这么好看(｡･ω･｡)ﾉ♡
太好看了吧！！！我喜欢眼影！！！可以推一下吗！！！！
omg！！
妆效感人
哇撒，太美了
很有参考价值
已经种草，这个是真的好用
紧紧捂着钱包看你的帖子哈哈哈哈哈哈
每次看你发的东西，我都超级超级想买呢！！！
好喜欢，可是又是我愿望清单之一，买不起系列愿望清单
嘻嘻嘻码住，最近正在纠结粉底液。
最近真的需要。家里囤货基本没了
好激动！！终于可以出现在前排了呀~~好好看哦~~测评也是超级用心~
我的妈呀被种草啦 要去找代购啦
皮肤状态也太好了吧
这个颜色好好看啊！是什么色啊
她来了她来了，她带着美貌来啦
这个颜色好配你啊！
蹲个色号！
想问一下 你平时定妆都用什么
它家的东西真的强 我还没买过不喜欢的
这太考验化妆技术了，，，
\ No newline at end of file
vest/data/face_reply_data.txt 0 → 100644
View file @ 42003a85
谁能不爱这颜值
每日看好看的脸回血
你真是生活动力
我太爱你的颜值了
舔屏
长得好看，横着竖着斜着拍都好看
太优越了
优越本人
暴击
盛世美颜
这是什么绝世颜值啊
来品品这个style
来品品这个风格
除了哇我还能说什么
真的是好看呢
这颜值，可真的是顶不住了
咋就这么好看呢
这颜值超级超级棒哦！
你真的好好看
好看到起鸡皮疙瘩
好看的立刻粉了
这个照片不够看的，求更多
太击中我了
诚邀各位欣赏这盛世美颜啊
请问这是什么神仙颜值
颜值真的太高了
好看到合不拢嘴，想要联系方式
哇，一直在感叹
火速存到手机，想拿去做头像
我真的看不够，多发几张来看看
看一万遍还是看不够
破音呐喊，太好看啦
咦，谁在发光哦
发什么都美呆了!
好看的人就是治愈良药
期待你的每天更新
看你就是是生活必备品
每日看一万遍好看的颜值
不愧是你
真的很吃这种颜
不愧是宁
点进来就出不去了
谁看了能不爱
真的喜欢这个风格
对这种风格无法抵抗
我没法冷静了
都给我看！
神仙颜值没错了
我真实的发出尖叫声
我来了！！！这个系列都好看
神仙颜值！摇旗呐喊
对这种颜无法抵抗
颜值大发
是什么神仙颜值呢
当场昏厥
这是什么绝色啊
绝色！！
颜狗来了！
真的可太棒了呢
好看到词穷
随便拍都会好看的
在发光啊
怎么拍都好看啊
这什么颜值!
为你喊破喉咙
什么都做得好
你好看的让我魂牵梦绕
顶不住啊顶不住
想把你的照片偷来当头像
好看到我分分钟昏厥
每一张都想拿去当头像
超超超超美的
颜值模板吧你，太好看了
很想知道滤镜，太好看了吧！
你咋这么好看
疯狂鸡叫
好看的人怎么拍都好看
一秒内爱上
awsl
进来看颜王的照片
美美哒
你怎么这么好看呢
我天，真好看
我的妈!你超美啊！
爱辽
心动辽
你怎么可以这么好看
同款姿势可以拥有，颜值拥有不了了。
可惜国家不分配颜值
长得好看是王道
好看的人随便怎么拍都在这么好看
这个颜值，怕是要在线夺命
谁能不喜欢呢
你简直是就是优越本身
你简直是是优越代名词
你好看到仿佛是来索命的
你又来索命了吗！这个颜值，献上小命
哇惊叹着
你真的是宝藏，太好看了
你是什么宝藏哦，偷偷摸摸关注一下
神仙颜值！！！
你也太好看了吧！！！
你好好看啊，好喜欢你的颜值
你真的好好看！！
哇，你也太好看了
哇，你是什么神仙颜值！
图二超级好看！
图一的角度，非常好看了吧
图一真的太好看了吧
你的颜是我吃的那一挂哎
这颜值是我喜欢的类型了
这颜值是长在我的上审美了
这颜真是长我审美点上了
哇塞，好可爱啊
好可爱啊
喜欢！太可爱了
哇塞，喜欢这个颜值
粉了粉了
我是你的颜值粉
这颜值戳到我了
神仙颜值
是戳我审美点的颜了
是戳我审美点的可爱哇
是戳我审美点的好看哇
喜欢这个发色
脸型好棒
这个鼻子是我的爱
颜值好好看
这个颜值一定是穿什么都好看
想学习这个妆容
是戳我审美点的眼睛了
是戳我审美点的高鼻梁了
是戳我审美点的唇形了
是戳我审美点的眉毛了
五官好精致啊
眼睛真的好看
脸型好棒啊，喜欢这个脸型
鼻子好好看
整体看着好舒服
喜欢这种风格
这构图很好啊
想学习你的拍照技巧
这什么神仙颜值！！！！
人好看还会还会拍
人这么好看还会拍，慕了！
羡慕长得好看的人
羡慕给你拍照的人
颜粉儿来报道
你是我的私藏神仙颜值！
怎么会这么好看的人！
这世上怎么会有这么好看的人呢！
是戳我审美点的发色了
是戳我审美点的发型了
你的头发，眼睛，鼻子，仿佛都长成了我最爱的样子
怎么会有人长得和我喜欢的样子这么像
喜欢你的颜值！！
这是什么神仙颜值诶~
好看到直戳我心
看完你的照片。心跳漏一拍
可以得到你的联系方式吗。
立刻粉了！喜欢这个颜值
等到你的新照片，开心
颜值一级！
请你每天多更几张照片好吗
图片是加滤镜了吗 真好看呀
这个颜值我真的是欲罢不能，看了好几遍
我会告诉你我看了好几遍吗
立刻粉了，为了这个颜值
ღ( ´･ᴗ･` )比心
给你笔芯
在线比心漂亮姐姐
给这个颜值在线打call
给你，我的小心心
请收下我的小心心
请收下我的疯狂笔芯
给你我所有的爱意，喜欢！
怎么会这么好看。老天造人不公平
这颜值，人生肯定特别顺利
为你在线打call
喜欢你的每一张照片!请多更新
可盐可甜的风格！
什么风格都好看！
这无处安放的魅力啊
立刻粉了！！
第一张也太好看了吧！
喜欢喜欢，在线打call
我是你的颜值粉，请多更新好吗
这张和我的同学好像！
我，我，我，可以认识你吗
又好看又会拍
喜欢了！
神仙颜值，每天都想催更新
为这个神仙颜值打call！！！
这个颜值真的是我的最喜欢的那一卦！
平时不发言，但这个颜值我必须说话！
不爱说话的我，必须发言了。喜欢你
这个角度能hold，长得好看果然可以随便拍
这个角度能抗住，这得什么神仙颜值
这个角度还这么好看啊
又好看又会拍照，厉害了
你怎么这么好看
真的太美了我很喜欢！！
你以为你长得美就可以不回我吗
我是新来的，都是神仙照片啊，放图吧，我还扛得住
好好看 我哭 我什么时候可以再好看一点
真的是 喜欢到不行！
好好看呀 我也想拍这么好看的
我对你的爱意值高达百分之两百噢
喜欢各种各样的你  嘿嘿
哇哦 这是谁的神仙大宝贝啊
为什么会有这么好看的人
超爱这种感jio！！！！！
每天看到这么好看的颜，美梦鸭
是我梦想的颜值
完全就是我喜欢的类型吧！
吼吼看呀美颜暴击
总是莫名的 怎么照都好看
人美怎样拍都好看
这是什么神仙颜值 爱liao 爱liao
该有的感觉你都有
不说啥了。只想夸夸这神仙颜值
博主的颜真耐打
都好看到哭啊，小北鼻
第一瞬间就戳中了我
嘤嘤嘤 我都爱死了！！
我要有这么好看我也很爱自拍了
因为好看 所以爱自拍
真的长的超级精致
一直都超喜欢看你的照片哎
不行了 我 你太好看了我要晕倒了
您也是真的hin好看诶
会拍你就多拍点 顺便也多发点哈哈哈哈 可爱^_^
看来老天确实不是公平的
这颜值让我变成了柠檬精
实名制羡慕！
天啦！我第一次看到这么好看的人！！！
到底为什么会这么好看！！！
这也太好看啦叭 一眼沦陷 我对你 就是爱！死！了！
大概是从天而降的仙女吧
太美了 我宣布我已经血空
为什么会有这么好看的人在人间
天啦噜！！！这也太好看了
这谁顶得住啊太好看了！
我希望我在梦里可以长这个样子
这到底是什么仙女了啦
啊啊啊啊啊啊看到这么美的你！俺心情也好好！
看到美女心情就更好啦！！！
甜甜的你 温暖我的心 
请问如何才能像博主一样美
这么美丽冻人直戳人心真的好吗
哭唧唧看这里！！！！好看哭泣
究竟怎么做到这种妆容的 有点爱
你是人间天使吗？
果然人好看怎么拍都好看呢
您真是好看极了!!
请告诉我怎么拍都好看的秘诀
太好看了吧 皮卡皮卡
亲亲 那么好看建议你多拍哦
我真的夸不动了，为什么有这么可爱美丽的女孩纸
真的好美，你到底要让我夸多少遍才够
太好看了8 永远看不够
看你我就觉得可以开心一年接着一年
我的宝藏女孩 啊啊真滴太美了 人间仙女
真的太美了！怎么会有这么美的女孩
这是什么美丽的精灵
嘻嘻，好美一女的，爱了爱了
被天使亲吻过的脸
太美了，我要窒息了
未闻花名 但知其人
太美了！！！一眼沦陷！
爱死了你这个颜值
上辈子肯定拯救了上帝，让你这么好看
哇哇哇，你也太好看了叭
太好看了吧！！救命！！
上帝是不是造你的时候偏心啦！
好了 这个真的美哭了
啊我心中的天使
妈呀，你也太好看了吧
说不出哪里喜欢 就是哪哪都喜欢
求求您 停止散发你的魅力！！！！！
特别有气质，加油
好美啊，初恋的面孔
我天，真的太好看了
看到你，就看到了生活的希望，看到人间还有如此好看的人
本颜粉儿来报道啦
是神颜没错了
为什么可以这么好看
我死了 你为什么这么好看，我就地死亡
画里走出来的叭
今天的您仍然是我的心动嘉宾呦
用来当壁纸真的贼好看
太美了吧我看呆了555
我也要像你一样闪闪发光
这个真的超级美丽了
这是什么散落人间的仙子
我天……这是什么神仙颜值
这神仙颜值，立刻粉了
wei，110吗，这里有人好看到让我想报警诶!
太好看了吧 ！哭泣了
好看到爆炸(｡･ω･｡)ﾉ♡
\ No newline at end of file
vest/data/hairstyle_reply_data.txt 0 → 100644
View file @ 42003a85
一看就会，一学就废 ╥﹏╥
这个发量，有护发的东西安利吗？
别人家的头发，做了都很好看系列
婴儿肥怎么办，适合这个发型吗
老师！我没有学会！
手残党真是看着就知道自己做不到了
学渣想问，打理起来有手把手分步骤讲解图吗！！
我决定把图留着，等去找tony老师！
一个发型狗啃一般的我，也不知道为啥，认认真真看完了每一个字。。
wow 真的好看哎，一进来就被这张美到了
发际线高，额头凸出，适合什么发型或者刘海啊
不知道自己的脸型适合什么发型。。。
秃头少女想问，有发际线技巧吗！
正在苦苦留长的我……
讲真……奉劝各位 不要剪不要烫……除非你长的很时尚
请问 我头大呢 适合什么发型？
这发型真适合走活力少女路线！
每次看小姐姐们的发型，都觉得是自己颜值水平拉低了tony的技术水平
我之前剪了这个发型！全部人都说好看，回家我妈还以为我打了瘦脸针！！！
细软少还脸圆plus。。。我只能留着中分。
求推荐发型啊，想要蓬松一点的，现在长发有点贴头皮
我的TONY严肃地叫我不要剪。。然后我不信，他就拿出了假发给我戴上看大概效果
但我头发还是细软少，哭了
看了一天贴有点动心。。。谢谢！！
我剪了类似这种，不过自己吹出来没有tony吹的那么美！
想起来上次剪头发，发型师帮我卷了像高晓松，第二天睡醒，直了像刘胡兰，现在像马大姐╥﹏╥
太少女了吧！！
今天的彩虹屁我要全部给你！太好看了吧！！！
这是谁家的仙女！！
小个子女生该留怎样的发型好！留了六年刘海最近近年留中分 想剪短发又怕不好看！求支招
中分发型不化妆是否会显得人没精神啊？中分适合什么脸型吗？
脸大有点方 应该留什么发型呀= =
换了个发型，被嘲笑了半个月了
求问，头发少，留什么发型显头发多？
头发少到tony都说好心酸的地步了，羡慕小姐姐
今天剪了个巨丑的发型，想哭
换了十万种发型以后发现，头发靠吹，不会打理都见鬼 *^▽^*
贾玲适合什么发型啊？不过贾玲还比我好看。
我是细软，我最近两次烫的都是那种自然的大卷，烫回家我爸妈都说我没烫…
不知道秃头女孩适合什么发型
头发又多又硬又自来卷，折腾头发都不敢想，哭了
头发老贴头皮咋办？
发际线如何打碎？
艾玛 马住以后剪头发时候用
发量不多不少，大圆脸，适合斜刘海还是无刘海？
刚烫了羊毛卷，风太大太让人失去理智了！
我至今没有遇到 我可以顺利交流的tony… 导致我至今没有过合理的发型，全靠自然生长o(╥﹏╥)o
最近想换发型了，做一个新的发型，新鲜感溢出天际那种！小姐姐有推荐的吗~
我也种草了这个发型，但是我头发细软还容易油 呜呜呜
小姐姐看我！！！我现在就是这种发型！我觉得还行，染了一点颜色，还蛮洋气的
\ No newline at end of file
vest/data/product_reply_data.txt 0 → 100644
View file @ 42003a85
This diff is collapsed.
vest/data/skincare_reply_data.txt 0 → 100644
View file @ 42003a85
看完会省不少钱
超有用的！
心动惹
哈哈哈哈哈哈护肤博主＝大型自主实验田
马一下
什么时候开始用眼霜比较好呀？
有什么好用的精华推荐吗？
有什么适合混油皮的护肤品推荐吗?
课代表在哪里
求出个油皮护肤大法
终于更新了！！
怎么知道自己是哪种类型的皮肤鸭
一键get
功课不怕多，我又学到了好多~~
满满的干货，辛苦啦~
干皮还不停长痘怎么办
油皮防晒，求推荐～
求适合干皮的身体乳，冬夏都可以用的
已经不晓得自己是什么皮了，一会油一会干的感觉
敏感肌真的太南了呜呜…不知道用什么好
羡慕皮肤好的人
真的很实用啊
敏感肌可以用吗？
干货！
感觉最主要的还是吃好睡好！睡眠充足了，饮食健康了，皮肤自然就好了
真心求问，黑眼圈还有得救吗？
种草了
有没有适合学生党的水乳呀？
想试试
喜欢！！！
来啦来啦，又来种草啦
性价比很高了！
我爱了
安排上！
看起来不错
最近正好缺，可以试下
感觉还是要用适合自己肤质的护肤品，才能有效果
夏天油，冬天干，有的救吗？
看起来很好用，种草小大人
比心❤
赞赞赞
哇哇哇！想要
实名心动
学习了
默默加入了购物车
我也有同款诶
良心推荐爱了爱了
真的很用心~
求个适合干皮还容易脸泛红的
又想尝试又怕不适合自己…
\ No newline at end of file
vest/data/topic_models.py 0 → 100644
View file @ 42003a85
import traceback
import logging
from trans2es.models.topic import TopicTag, TopicImage, CommunityTopicProduct, Topic, CommunityCategoryTagRelation
from django.conf import settings
from trans2es.models.pictorial import PictorialTag
from random import randint
from trans2es.models.user_extra import UserExtra
from django.db import models
def get_edit_tag_id_list(topic_id):
try:
tag_id_list = list(TopicTag.objects.using(settings.SLAVE_DB_NAME).filter(topic_id=topic_id,
is_collection=1).values_list("tag_id",
flat=True))
logging.info("get ---tag_id_list:%s" % tag_id_list)
logging.info("get ---topic_id:%s" % topic_id)
return tag_id_list
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return []
def topic_has_image(topic_id):
try:
has_image = Topic.objects.using(settings.SLAVE_DB_NAME).filter(id=topic_id, is_deleted=False,
is_online=True).values_list("have_face",
flat=True)
if has_image[0] == 1:
return True
else:
return False
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return False
def get_topic_product_info(topic_id):
try:
has_product = False
query_list = CommunityTopicProduct.objects.using(settings.SLAVE_DB_NAME).filter(topic_id=topic_id,
is_deleted=False)
if len(query_list) > 0:
has_product = True
return has_product
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return []
def get_pictorial_tag_by_id(pictorial_id):
try:
tag_id_list = list(
PictorialTag.objects.filter(pictorial_id=pictorial_id, is_online=True, is_collection=1).values_list(
"tag_id", flat=True))
return tag_id_list
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return []
# def get_topic_data(numtime, numitme2):
# try:
#
# result_topic = Topic.objects.filter(create_time__lte=numitme2, create_time__gte=numtime,
# is_online=True).values("user_id", "id")
#
# if len(result_topic) > 0:
# for i in result_topic:
# shadow_judge = UserExtra.objects.filter(user_id=i[0], is_online=Topic, is_deleted=False).values_list(
# "is_shadow", flat=True)
#
# return shadow_judge
# except:
# logging.error("catch exception,err_msg:%s" % traceback.format_exc())
# return []
def get_category_tag_id(edit_tag_list):
try:
logging.info("get -----------")
# 拿到搜索的分类
all_category_tag_list = list(
CommunityCategoryTagRelation.objects.filter(tag_id__in=edit_tag_list, is_online=True,
is_deleted=False).values_list(
"category_tag_id", flat=True))
if len(all_category_tag_list) > 0:
index = randint(0, len(all_category_tag_list) - 1)
return all_category_tag_list[index]
else:
return 0
except:
logging.error("catch exception,err_msg:%s" % traceback.format_exc())
return -1
vest/data/wear_repy_data.txt 0 → 100644
View file @ 42003a85
每一个搭配都好好看呀
 哪有什么上身好看的裤子 只有上身好看的腿
时髦青春我统统都要！
这波穿搭真的很有逼格我太喜欢
有木有肩宽胯窄女孩的穿搭
想要链接！
秋天露腿真的不冷么？
我缺的是搭配法则吗，我缺的是穿这些衣服的身材
女人没有四季 只有衣服好看
穿的这么Fashion 去逛该吗
瘦就是最有效的穿搭法则
有不露腿长裤的穿搭吗
确认过眼神 是我喜欢的风格
请问这些衣服哪里买？有链接吗？
我把这套锁的死死滴了哟
小个子适合可爱风
其实主要就是要突出高腰线啊
短衣配长裤！好看炸！！
超舒服的一套
就想问问157 的大胸小个子怎么穿
这个风格 简单好看
可爱在性感面前不值一提 
我不管.穿出自己的感觉.我也是超膜～
显瘦满分的穿搭 
好看的衣服就应该配一个好看的包包，不怕买不起那种
身材不好的话一件hold不住
喜欢这套穿搭
我再说一遍！我没有这个身材！！！！！
可盐可甜了.童话公主的配色了
这个是我的style了
？真心发问，1米8的姐妹都在哪里买的裤子
真好看～今天我的穿搭是阔腿裤嘻嘻
不是穿搭好看，真是人好看
来来来.我的腿长一米七的裤子，该上场了！！
55555今年真的爱这条！！！
挺可爱挺精神的 很有朝气
有点复古的感觉哦
想穿上漂亮的仙女裙去谈一场甜甜的恋爱
大长腿无敌了
超爱这样的搭配
衣服那么多，实名羡慕
这个女人穿什么都好看
好想知道楼主体重哇 感觉身材超棒
找到最适合自己的穿衣风格，才是日常穿搭的第一步啊
 正好要开学了，赶紧买几件备着，到时候好穿
这种五颜六色的我真的驾驭不住
白颜色真的怎么搭配都好看
适合我这种不会穿衣服的
看别人穿在身上是挺好看的，自己买回来穿在身上又是另一回事了
哈哈，不知道高中会不会允许我这样穿
特别喜欢这种穿搭 希望多出一点
\ No newline at end of file
vest/pictorial/no_reply_principal.py
View file @ 42003a85
...@@ -15,12 +15,15 @@ def get_data(): ...@@ -15,12 +15,15 @@ def get_data():
print("....") print("....")
pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306) pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
cursor = pc.cursor() cursor = pc.cursor()
cursor.execute( cursor.execute("select count(*),pictorial_id from reply group by pictorial_id")
"select creator_id,id from community_pictorial where is_online =True and id not in (select pictorial_id from reply group by pictorial_id)")
data = cursor.fetchall() data = cursor.fetchall()
topic_id = list(data) topic_id = list(data)
data_all = []
for i in topic_id:
if i[0] <= 4:
data_all.append(i)
logging.info("Database version : %s " % topic_id) logging.info("Database version : %s " % topic_id)
return topic_id return data_all
except: except:
logging.error("catch exception,get_data:%s" % traceback.format_exc()) logging.error("catch exception,get_data:%s" % traceback.format_exc())
...@@ -31,9 +34,9 @@ def no_reply_principal(): ...@@ -31,9 +34,9 @@ def no_reply_principal():
try: try:
logging.info("comment offline pictorial") logging.info("comment offline pictorial")
user_id = get_data() user_id = get_data()
dicts = {}
for i in user_id: for i in user_id:
for num in range(4): follow_num = random.randint(1, 5)
for num in range(follow_num):
majia_user_id = get_majia_reply(i[0]) majia_user_id = get_majia_reply(i[0])
cook = logins(majia_user_id) cook = logins(majia_user_id)
comment = get_pictorial_comment() comment = get_pictorial_comment()
......
vest/pictorial/principal_offline_comment1.py
View file @ 42003a85
...@@ -28,13 +28,13 @@ def get_data(): ...@@ -28,13 +28,13 @@ def get_data():
def principal_offline_comment1(): def principal_offline_comment1():
try: try:
logging.info("comment offline pictorial") logging.info("comment offline pictorial")
user_id = get_data() user_id = get_data()
dicts = {} dicts = {}
for i in user_id: for i in user_id:
for num in range(4): follow_num = random.randint(5, 20)
for num in range(follow_num):
majia_user_id = get_majia_reply(i[0]) majia_user_id = get_majia_reply(i[0])
cook = logins(majia_user_id) cook = logins(majia_user_id)
comment = get_pictorial_comment() comment = get_pictorial_comment()
......
vest/pictorial/principal_online_comment1.py
View file @ 42003a85
...@@ -2,8 +2,11 @@ import pymysql ...@@ -2,8 +2,11 @@ import pymysql
import random import random
import traceback import traceback
import logging import logging
from vest.request.auto_request import logins, pictorial_reply, get_majia, get_pictorial_comment, time_conv_minute from vest.request.auto_request import logins, pictorial_reply, get_majia, get_pictorial_comment, time_conv_minute, \
judge_pictorial_info_get_comment
from vest.request.auto_request import host, user, db, passwd from vest.request.auto_request import host, user, db, passwd
from vest.data.topic_models import get_pictorial_tag_by_id
""" """
榜单新增内容(仅限在线的） 榜单新增内容(仅限在线的）
...@@ -60,7 +63,7 @@ def principal_online_comment1(): ...@@ -60,7 +63,7 @@ def principal_online_comment1():
logging.info("comment offline pictorial") logging.info("comment offline pictorial")
numtime1, numtime2, minute = time_conv_minute(30, 0) numtime1, numtime2, minute = time_conv_minute(30, 0)
user_id, data_vote = get_data(numtime1, numtime2) user_id, data_vote = get_data(numtime1, numtime2)
dicts = {}
random_num = 0 random_num = 0
if user_id: if user_id:
for i in user_id: for i in user_id:
...@@ -73,7 +76,7 @@ def principal_online_comment1(): ...@@ -73,7 +76,7 @@ def principal_online_comment1():
for num in range(random_num): for num in range(random_num):
majia_user_id = get_majia() majia_user_id = get_majia()
cook = logins(majia_user_id) cook = logins(majia_user_id)
comment = get_pictorial_comment() comment = judge_pictorial_info_get_comment(i[0])
if cook is not None: if cook is not None:
pictorial_reply(cook, i[0], comment) pictorial_reply(cook, i[0], comment)
if data_vote: if data_vote:
...@@ -82,7 +85,7 @@ def principal_online_comment1(): ...@@ -82,7 +85,7 @@ def principal_online_comment1():
for num in range(random_num): for num in range(random_num):
majia_user_id = get_majia() majia_user_id = get_majia()
cook = logins(majia_user_id) cook = logins(majia_user_id)
comment = get_pictorial_comment() comment = judge_pictorial_info_get_comment(i[0])
if cook is not None: if cook is not None:
pictorial_reply(cook, i[0], comment) pictorial_reply(cook, i[0], comment)
......
vest/reply/true_comment_one.py
View file @ 42003a85
import pymysql import pymysql
import traceback import traceback
import logging import logging
from vest.request.auto_request import login, time_conv, get_comment, reply from vest.request.auto_request import login, time_conv, get_comment, reply, get_product_comment, get_face_comment, \
get_category_tag_id, get_category_reply_commtent,judge_topic_info_get_comment
from vest.request.auto_request import host, user, db, passwd from vest.request.auto_request import host, user, db, passwd
from libs.error import logging_exception from libs.error import logging_exception
from vest.data.topic_models import get_edit_tag_id_list, get_pictorial_tag_by_id, get_topic_product_info, \
topic_has_image
import random
def get_data(numtime, numtime2): def get_data(numtime, numtime2):
...@@ -44,11 +48,10 @@ def true_comment_one(): ...@@ -44,11 +48,10 @@ def true_comment_one():
logging.info("comment one") logging.info("comment one")
numtime1, numtime2 = time_conv(5, 0) numtime1, numtime2 = time_conv(5, 0)
user_id = get_data(numtime1, numtime2) user_id = get_data(numtime1, numtime2)
dicts = {}
if user_id: if user_id:
for i in user_id: for i in user_id:
cook = login() cook = login()
comment = get_comment() comment = judge_topic_info_get_comment(i[1])
if cook is not None: if cook is not None:
reply(cook, i[1], comment) reply(cook, i[1], comment)
else: else:
...@@ -56,3 +59,22 @@ def true_comment_one(): ...@@ -56,3 +59,22 @@ def true_comment_one():
except: except:
logging_exception() logging_exception()
logging.error("catch exception,main:%s" % traceback.format_exc()) logging.error("catch exception,main:%s" % traceback.format_exc())
#
#
# def true_comment_one():
# try:
# logging.info("comment one")
# numtime1, numtime2 = time_conv(5, 0)
# user_id = get_data(numtime1, numtime2)
# if user_id:
# for i in user_id:
#
#
# cookie = login()
# if cookie is not None:
# reply(cookie, i[1], comment)
# else:
# logging.error("catch exception,main:%s" % traceback.format_exc())
# except:
# logging_exception()
# logging.error("catch exception,main:%s" % traceback.format_exc())
vest/reply/true_comment_three.py
View file @ 42003a85
...@@ -3,7 +3,7 @@ import pymysql ...@@ -3,7 +3,7 @@ import pymysql
import random import random
import traceback import traceback
import logging import logging
from vest.request.auto_request import login, time_conv, get_comment, reply from vest.request.auto_request import login, time_conv, get_comment, reply, judge_topic_info_get_comment
from vest.request.auto_request import host, user, db, passwd from vest.request.auto_request import host, user, db, passwd
from libs.error import logging_exception from libs.error import logging_exception
...@@ -51,8 +51,7 @@ def true_comment_three(): ...@@ -51,8 +51,7 @@ def true_comment_three():
rand_num = random.randint(0, 1) rand_num = random.randint(0, 1)
if rand_num == 1: if rand_num == 1:
cook = login() cook = login()
logging.info("get cook;%s" % cook) comment = judge_topic_info_get_comment(i[1])
comment = get_comment()
if cook is not None: if cook is not None:
reply(cook, i[1], comment) reply(cook, i[1], comment)
else: else:
......
vest/reply/true_comment_two.py
View file @ 42003a85
...@@ -2,7 +2,7 @@ import pymysql ...@@ -2,7 +2,7 @@ import pymysql
import random import random
import traceback import traceback
import logging import logging
from vest.request.auto_request import login, time_conv, get_comment, reply from vest.request.auto_request import login, time_conv, get_comment, reply, judge_topic_info_get_comment
from vest.request.auto_request import host, user, db, passwd from vest.request.auto_request import host, user, db, passwd
from libs.error import logging_exception from libs.error import logging_exception
...@@ -51,7 +51,7 @@ def true_comment_two(): ...@@ -51,7 +51,7 @@ def true_comment_two():
rand_num = random.randint(0, 1) rand_num = random.randint(0, 1)
if rand_num == 1: if rand_num == 1:
cook = login() cook = login()
comment = get_comment() comment = judge_topic_info_get_comment(i[1])
if cook is not None: if cook is not None:
reply(cook, i[1], comment) reply(cook, i[1], comment)
else: else:
......
vest/request/auto_request.py
View file @ 42003a85
...@@ -12,6 +12,8 @@ from email.mime.text import MIMEText ...@@ -12,6 +12,8 @@ from email.mime.text import MIMEText
from email.utils import formataddr from email.utils import formataddr
from physical.settings_local import DATABASES from physical.settings_local import DATABASES
from physical.settings_local import REDIS_URL from physical.settings_local import REDIS_URL
from vest.data.topic_models import get_pictorial_tag_by_id, get_topic_product_info, get_edit_tag_id_list, \
get_category_tag_id, topic_has_image
my_sender = 'lixiaofang@igengmei.com' my_sender = 'lixiaofang@igengmei.com'
my_pass = 'tg5AVKBB8jLQGBET' my_pass = 'tg5AVKBB8jLQGBET'
...@@ -22,41 +24,11 @@ my_user6 = "lixiaofang@igengmei.com" ...@@ -22,41 +24,11 @@ my_user6 = "lixiaofang@igengmei.com"
# auto_follow_url = "http://earth.gmapp.env/api/v1/follow" # auto_follow_url = "http://earth.gmapp.env/api/v1/follow"
# auto_urge_url = "http://earth.gmapp.env/api/v1/user/urge" # auto_urge_url = "http://earth.gmapp.env/api/v1/user/urge"
# DATABASES = {
# 'default': {
# 'ENGINE': 'django.db.backends.mysql',
# 'NAME': 'alpha',
# 'USER': 'work',
# 'PASSWORD': 'Gengmei123!',
# 'HOST': 'bj-cdb-55ejhsjy.sql.tencentcdb.com',
# 'PORT': '62177',
# 'OPTIONS': {
# "init_command": "SET foreign_key_checks = 0;",
# "charset": "utf8mb4",
# },
# }
# }
auto_click_url = "http://earth.iyanzhi.com/api/v1/like" auto_click_url = "http://earth.iyanzhi.com/api/v1/like"
auto_reply_url = "http://earth.iyanzhi.com/api/v1/reply/create" auto_reply_url = "http://earth.iyanzhi.com/api/v1/reply/create"
auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow" auto_follow_url = "http://earth.iyanzhi.com/api/v1/follow"
auto_urge_url = "http://earth.iyanzhi.com/api/v1/user/urge" auto_urge_url = "http://earth.iyanzhi.com/api/v1/user/urge"
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': 'alpha',
'USER': 'work',
'PASSWORD': 'oars152!traipseize738',
'HOST': '172.17.40.136',
'PORT': '3306',
'OPTIONS': {
"init_command": "SET foreign_key_checks = 0;",
"charset": "utf8mb4",
}
}
}
host = DATABASES['default']['HOST'] host = DATABASES['default']['HOST']
user = DATABASES['default']['USER'] user = DATABASES['default']['USER']
...@@ -235,7 +207,6 @@ def get_comment(): ...@@ -235,7 +207,6 @@ def get_comment():
num = random.randint(0, len(list_guanshui)) num = random.randint(0, len(list_guanshui))
comment = list_guanshui[num - 1] comment = list_guanshui[num - 1]
return comment return comment
except: except:
...@@ -462,9 +433,8 @@ def pictorial_reply(cookies_get, id, content): ...@@ -462,9 +433,8 @@ def pictorial_reply(cookies_get, id, content):
data=post_dict) data=post_dict)
logging.info("response.text:%s" % response.text) logging.info("response.text:%s" % response.text)
get_error(response.text,"pictorial_reply",id) get_error(response.text, "pictorial_reply", id)
except: except:
logging.error("catch exception,logins:%s" % traceback.format_exc()) logging.error("catch exception,logins:%s" % traceback.format_exc())
...@@ -479,8 +449,159 @@ def get_pictorial_comment(): ...@@ -479,8 +449,159 @@ def get_pictorial_comment():
comment = list_guanshui[num - 1] comment = list_guanshui[num - 1]
logging.info("get comment:%s" % comment)
return comment return comment
except: except:
logging.error("catch exception,logins:%s" % traceback.format_exc())
return None
def get_product_comment():
try:
data = open("/srv/apps/physical/vest/data/product_reply_data.txt", "r")
list_guanshui = []
for i in data:
list_guanshui.append(i)
num = random.randint(0, len(list_guanshui))
comment = list_guanshui[num - 1]
return comment
except:
return None
def get_face_comment():
try:
data = open("/srv/apps/physical/vest/data/face_reply_data.txt", "r")
list_guanshui = []
for i in data:
list_guanshui.append(i)
num = random.randint(0, len(list_guanshui))
comment = list_guanshui[num - 1]
return comment
except:
return None
def get_category_reply_commtent(category_id):
try:
# 发型42、穿搭46、美妆3、护肤4、美甲21972、香水17576、瘦身32605、配饰5305608
file = ""
if category_id == 3: # 美妆
logging.info("3-------------")
file = "/srv/apps/physical/vest/data/beauty_reply_data.txt"
elif category_id == 42: # 发型
logging.info("42-------------")
file = "/srv/apps/physical/vest/data/hairstyle_reply_data.txt"
elif category_id == 4: # 护肤
logging.info("4-------------")
file = "/srv/apps/physical/vest/data/skincare_reply_data.txt"
elif category_id == 46: # 穿搭
logging.info("46-------------")
file = "/srv/apps/physical/vest/data/wear_repy_data.txt"
else:
comment = get_comment()
return comment
data = open(file, "r")
list_guanshui = []
for i in data:
list_guanshui.append(i)
num = random.randint(0, len(list_guanshui))
comment = list_guanshui[num - 1]
logging.info("get comment:%s" % comment)
return comment
except:
logging.error("catch exception,logins:%s" % traceback.format_exc())
return None
def judge_topic_info_get_comment(topic_id):
try:
comment = ""
# 先判断是不是编辑标签
edit_tag_list = get_edit_tag_id_list(topic_id)
logging.info("get topic_tag:%s" % edit_tag_list)
if len(edit_tag_list) > 0:
# 如果有编辑标签
# 去拿他的所属分类 根据分类去拿对应的标签（随机拿一个）
category_tag_id = get_category_tag_id(edit_tag_list)
if category_tag_id > 0:
comment = get_category_reply_commtent(category_tag_id)
else:
product_judge = get_topic_product_info(topic_id)
logging.info("get product_judge:%s" % product_judge)
if product_judge:
comment = get_product_comment()
else:
# 判断有没有人脸
face_judge = topic_has_image(topic_id)
logging.info("get face_judge:%s" % face_judge)
if face_judge:
comment = get_face_comment()
# 原始评论
else:
comment = get_comment()
else:
# 判断有没有商品信息
product_judge = get_topic_product_info(topic_id)
if product_judge:
comment = get_product_comment()
logging.info("get product_judge:%s" % product_judge)
else:
# 判断有没有人脸
face_judge = topic_has_image(topic_id)
logging.info("get face_judge:%s" % face_judge)
if face_judge:
comment = get_face_comment()
# 原始评论
else:
comment = get_comment()
logging.info("get judge_topic_info_get_comment:%s" % comment)
return comment
except:
logging.error("catch exception,logins:%s" % traceback.format_exc())
return None
def judge_pictorial_info_get_comment(pictorial_id):
try:
comment = ""
# 先判断是不是编辑标签
edit_tag_list = get_pictorial_tag_by_id(pictorial_id)
if len(edit_tag_list) > 0:
# 如果有编辑标签
# 去拿他的所属分类 根据分类去拿对应的标签（随机拿一个）
category_tag_id = get_category_tag_id(edit_tag_list)
logging.info("get category_tag_id:%s" % category_tag_id)
if category_tag_id > 0:
comment = get_category_reply_commtent(category_tag_id)
else:
logging.info("get -------------+++++++++++")
comment = get_pictorial_comment()
else:
# 原始评论
comment = get_pictorial_comment()
logging.info("get judge_topic_info_get_comment:%s" % comment)
return comment
except:
logging.error("catch exception,logins:%s" % traceback.format_exc())
return None return None
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment