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
# coding:utf-8
from __future__ import absolute_import, unicode_literals
import datetime
import operator
from functools import reduce
from django.conf import settings
from django.db.models import Q
from celery import shared_task
from utils.rpc import rpc_client, logging_exception
from talos.services import UserService
from talos.models.topic import Problem
from talos.models.topic import TopicReply
from talos.models.diary import Diary
@shared_task
def crash_check():
"""查询包含crash相关关键字的帖子／日记／回复
邮件发送至
邮件格式：用户ID－帖子时间－帖子类型（含帖子ID）－内容
"""
text = []
yesterday = datetime.datetime.now() + datetime.timedelta(days=settings.DAYS_BEFORE_TODAY)
q_diary = []
q_problem = []
q_reply = []
# 拼关键字查询条件Q
for keyword in settings.CRASH_KEYWORDS:
for field in settings.MODEL_FIELDS['diary']:
item_q = Q(**{field + '__icontains': keyword})
q_diary.append(item_q)
for keyword in settings.CRASH_KEYWORDS:
for field in settings.MODEL_FIELDS['problem']:
q_problem.append(Q(**{field + '__icontains': keyword}))
for keyword in settings.CRASH_KEYWORDS:
for field in settings.MODEL_FIELDS['topicreply']:
q_reply.append(Q(**{field + '__icontains': keyword}))
try:
# check
crash_diary_set = Diary.objects.filter(reduce(operator.or_, q_diary)).exclude(
created_time__lte=yesterday).select_related()
for crash_item in crash_diary_set:
text.append(email_body_format(crash_item.user_id, crash_item.last_modified,
Diary._meta.verbose_name, crash_item.id,
crash_item.title, crash_item.created_time))
crash_set_problem = Problem.objects.filter(reduce(operator.or_, q_problem)).exclude(
created_time__lte=yesterday).select_related()
for cp in crash_set_problem:
text.append(email_body_format(cp.user_id, cp.last_modified, Problem._meta.verbose_name,
cp.pk, cp.ask + cp.answer, cp.created_time))
crash_set_reply = TopicReply.objects.filter(reduce(operator.or_, q_reply)).exclude(
reply_date__lte=yesterday).select_related()
for cr in crash_set_reply:
text.append(email_body_format(cr.user_id, cr.reply_date,
TopicReply._meta.verbose_name,
cr.pk, cr.content, cr.reply_date))
# 发邮件
if not text:
text.append(u'未发现crash相关帖子信息！')
rpc_client['internal_email/send'](
to=settings.SENDTO,
subject=settings.SUBJECT,
text=''.join(text)
).unwrap()
except:
logging_exception()
def email_body_format(userid=None, time=None, type_content=None, content_id=None, content_text=None,
create_time=None):
"""格式化邮件内容
"""
try:
user = UserService.get_user_by_user_id(user_id=userid)
device = user.devices.last()
device_info = u'设备: {}\n 系统版本：{}\n 平台：{}'.format(device.model, device.os_version, device.platform)
except:
device_info = '未知设备'
return u'用户ID：{userid}\n 创建时间：{create_time}\n 时间：{time}\n ' \
u'帖子类型：{type_content}({content_id}):\n 帖子内容：{content_text}\n'.format( \
userid=userid, time=time, type_content=type_content,
content_id=content_id, content_text=content_text, create_time=create_time) + device_info