1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
# coding=utf-8
from __future__ import unicode_literals, absolute_import, print_function
from gm_protocol import GmProtocol
from gm_types.error import ERROR as CODES
from gm_types.gaia import TOPIC_TYPE
from gm_types.push import PERSONAL_PUSH_TYPE, PUSH_INFO_TYPE, AUTOMATED_PUSH
from gm_rpcd.all import bind
from talos.cache.base import favor_cache
from talos.decorators import list_interface
from talos.manager.topic import topic_list_manager
from talos.models.topic import Problem
from talos.models.topic import ProblemFavor
from talos.services import get_user_from_context
from talos.tools.favor_tool import FavorTool
from utils.push import limit_push, push_task_to_user_multi
from utils.rpc import gen, logging_exception, get_current_user
from utils.stat_log import SocialStatLogForUserAction
@bind("topic/topics_favor_my")
# @bind_context("topic/my_favor_list")
@list_interface(offset_name='start_num', limit_name='count', element_model=Problem)
def get_topics_favor_my(count=10, start_num=0):
"""我收藏的话题列表
count: 每次请求记录条数, 默认为10
start_num: 起始条数, 默认为0
"""
user = get_current_user()
if not user:
return gen(CODES.LOGIN_REQUIRED)
favors = ProblemFavor.objects.filter(user_id=user.id, is_deleted=False)
favors = favors.order_by("-id")[start_num:start_num + count]
topic_ids = [f.problem_id for f in favors]
result = topic_list_manager.get_list_data_by_topic_ids(topic_ids, user.id)
return result
@bind("topic/read_favors")
def topics_favors_read():
user = get_current_user()
if not user:
return gen(CODES.LOGIN_REQUIRED)
topic_ids = list(Problem.objects.filter(user_id=user.id).values_list("id", flat=True))
ProblemFavor.objects.filter(
problem_id__in=topic_ids,
is_deleted=False,
unread=True
).update(unread=False)
# @bind_context('topic/favorite/create')
# @bind_context('topic/favorite_create')
# def api_topic_favorite_create(topic_id):
# """
# 收藏一个帖子
# """
# user = get_user_from_context()
# try:
# topic = Problem.objects.get(pk=topic_id)
# except Problem.DoesNotExist:
# return gen(CODES.TOPIC_NOT_FOUND)
#
# pf, _ = ProblemFavor.objects.get_or_create(user_id=user.id, problem_id=topic.id)
# if pf.is_deleted:
# pf.is_deleted = False
# pf.save()
# @bind_context('topic/favorite/delete')
# @bind_context('topic/favorite_delete')
# def api_topic_favorite_delete(topic_id):
# """
# 取消收藏帖子
# """
# user = get_user_from_context()
# topic = Problem.objects.get(pk=topic_id)
# ProblemFavor.objects.filter(user_id=user.id, problem_id=topic.id).update(is_deleted=True)
@bind('topic/user_favor/delete')
def delete_user_favor(problem_id):
user = get_current_user()
if not user:
return gen(CODES.LOGIN_REQUIRED)
try:
problem = Problem.objects.get(id=problem_id)
except Problem.DoesNotExist:
return gen(CODES.TOPIC_NOT_FOUND)
pf = ProblemFavor.objects.filter(user_id=user.id, problem_id=problem.id).first()
if pf:
pf.is_deleted=True
pf.save()
favor_tool = FavorTool(redis_c=favor_cache, user_id=problem.user_id)
favor_tool.receive_topic_favor(pf.id)
return None
@bind('topic/user_favor/get_or_create')
def get_or_create_user_favor(problem_id):
user = get_current_user()
if not user:
return gen(CODES.LOGIN_REQUIRED)
try:
problem = Problem.objects.get(id=problem_id)
except Problem.DoesNotExist:
logging_exception()
return gen(CODES.TOPIC_NOT_FOUND)
pf, _ = ProblemFavor.objects.get_or_create(user_id=user.id, problem_id=problem.id)
if pf.is_deleted:
pf.is_deleted = False
pf.save()
favor_tool = FavorTool(redis_c=favor_cache, user_id=problem.user_id)
favor_tool.receive_topic_favor(pf.id)
pushUrl = GmProtocol().get_topic_detail(id=problem_id)
push_task_to_user_multi(
user_ids=[problem.user_id],
extra={
'type': PUSH_INFO_TYPE.GM_PROTOCOL, # 推送信息类型
'pushUrl': pushUrl,
'push_url': pushUrl,
},
push_type=AUTOMATED_PUSH.JOURNAL_POST_IS_COLLECTED,
alert=u'{user_name} 收藏了你的日记贴，再接再厉哦~'.format(user_name=str(user.nick_name))
)
_topic_type = problem.topic_type
if _topic_type in [TOPIC_TYPE.ASK, TOPIC_TYPE.SHARE, TOPIC_TYPE.TOPIC]: # 日记帖
# 用户行为埋点，收藏相关
SocialStatLogForUserAction.stat_log_for_favor(
content_type=SocialStatLogForUserAction.CONTENT_TYPE.diary,
user_id=user.id,
content_id=problem.diary_id,
)