# coding=utf8
from __future__ import unicode_literals, absolute_import, print_function
from django.conf import settings
from django.db import models
from django.utils import timezone
from django.utils.functional import cached_property
from django.utils.html import escape
from gm_types.gaia import AUTHOR_TYPE
from gm_types.gaia import CONST_STRINGS as const_strings
from gm_types.gaia import PRIVATE_STATUS
from gm_types.gaia import PROBLEM_FLAG_CHOICES
from gm_types.gaia import PROBLEM_REVIEW_STATUS_CHOICES
from gm_types.gaia import PROBLEM_STATUS_CHOICES
from gm_types.gaia import SLIDE_TYPE
from gm_types.gaia import TOPIC_TYPE
from gm_upload import IMG_TYPE
from gm_upload import ImgUrlField
from talos.cache.viewrecord import ViewRecord
from talos.libs.datetime_utils import get_timestamp
from talos.libs.datetime_utils import get_timestamp_or_none
from talos.libs.image_utils import get_full_path
from talos.models.diary.diary import Diary
from talos.services import other, UserConvertService
from talos.services.doctor import DoctorService
from talos.services.goods import GoodsService
from talos.services.hospital import HospitalService
from talos.services.tag import TagService
from talos.services.user import UserService
from utils.rpc import logging_exception
from . import Activity
from .pgcclassify import PgcClassify
class ShareTopicManager(models.Manager):
def get_queryset(self):
return super(ShareTopicManager, self).get_queryset().filter(topic_type=TOPIC_TYPE.SHARE,
private_status=PRIVATE_STATUS.NORMAL,
is_online=True, flag='n')
class Problem(models.Model):
"""topic.
NOTE:
update model ActivityWinlist's topic definition if pk replace with non-default field(`id`)
"""
class Meta:
verbose_name = u'01. 帖子'
verbose_name_plural = u'01. 帖子'
db_table = 'api_problem'
permissions = (
("can_answer", "Can answer user questions."),
)
app_label = 'talos'
def __unicode__(self):
id1 = u"%d : " % self.id
if self.ask:
return id1 + escape(self.ask[:40])
else:
return id1
objects = models.Manager()
share_topics = ShareTopicManager()
user_id = models.IntegerField(default=None, null=True, blank=True, verbose_name=u"提问用户外键id")
order = models.IntegerField(default=20, verbose_name=u"展示顺序", help_text=u"小的排在前，大的排在后")
title = models.CharField(max_length=200, db_index=True, null=True, blank=True, default=None, verbose_name=u"标题")
ask = models.TextField(default='', blank=True, verbose_name=u'话题标题')
answer = models.TextField(default='', blank=True, verbose_name=u'话题内容')
diary = models.ForeignKey(Diary, null=True, related_name=u'topics')
created_time = models.DateTimeField(db_index=True, verbose_name=u"问题创建时间", default=timezone.now)
last_modified = models.DateTimeField(db_index=True, verbose_name=u"最后修改时间", default=timezone.now, null=True)
# 用户的状态(用户删除)
flag = models.CharField(max_length=1, default=PROBLEM_FLAG_CHOICES.NORMAL,
choices=PROBLEM_FLAG_CHOICES, db_index=True)
status = models.CharField(max_length=1, default=PROBLEM_STATUS_CHOICES.NEW,
choices=PROBLEM_STATUS_CHOICES, db_index=True)
review_status = models.IntegerField(choices=PROBLEM_REVIEW_STATUS_CHOICES,
default=PROBLEM_REVIEW_STATUS_CHOICES.NOT_REVIEW)
# 是哪个医生回答的(两者修改最好同步)
# 指定给哪个医生回答，私信的医生，也是这个
assigned_doctor_id = models.IntegerField(default=None, null=True, blank=True, verbose_name=u'指定的医生外键id')
doctor_id = models.CharField(max_length=100, default=None, null=True, blank=True)
has_answer = models.BooleanField(default=False, db_index=True, verbose_name=u"有回答")
is_online = models.BooleanField(default=True, help_text=u"是否可以上线", verbose_name=u"上线", db_index=True)
is_push = models.BooleanField(u'所长发帖页面是否为推荐的专栏', default=False, db_index=True)
can_video_cover = models.BooleanField(default=True, help_text=u"是否使用此日记贴的短视频作为封面", verbose_name=u"使用此日记贴的短视频作为封面")
# 该问题是否公开
is_public = models.BooleanField(default=True, help_text=u"是否公开", verbose_name=u"公开", db_index=True)
is_sink = models.BooleanField(default=False, help_text=u"是否下沉", verbose_name=u"下沉")
is_headline = models.BooleanField(default=False, verbose_name=u"首页推荐", db_index=True)
channel_headline = models.BooleanField(default=False, verbose_name=u"频道推荐", db_index=True)
is_spam = models.BooleanField(verbose_name=u'是否为疑似广告', default=False, db_index=True)
apply_phone = models.CharField(default='', max_length=20, verbose_name=u'活动报名手机号')
# 是否私信问题
private_status = models.CharField(max_length=1,
choices=PRIVATE_STATUS,
default=PRIVATE_STATUS.NORMAL,
verbose_name=u"隐私状态",
db_index=True, null=True)
# this field is reused as elite(essence) flag
selected_qa = models.BooleanField(default=False, help_text=u"优选问答", verbose_name=u"优选问答")
is_recommend = models.BooleanField(verbose_name=u"频道置顶", default=False, db_index=True)
is_recommend_all = models.BooleanField(verbose_name=u"全局置顶", default=False, db_index=True)
# 如果为话题，则所有的回答都在 TopicReply中
# 如果是问答，则将原有的问答转换成为话题呢? 首先: assigned_doctor必须有效
is_topic = models.BooleanField(default=True, verbose_name=u"是否为话题")
# 参考: api.management.commands.problem_meta_update
doctor_num = models.IntegerField(default=0, verbose_name=u"有多少医生回复")
reply_num = models.IntegerField(default=0, verbose_name=u"有多少回复")
author_reply_num = models.IntegerField(default=0, verbose_name=u'楼主回复的数量')
# 话题类型
topic_type = models.CharField(max_length=10, null=False, verbose_name=u'话题类型',
default=TOPIC_TYPE.ASK, choices=TOPIC_TYPE, db_index=True)
service_id = models.IntegerField(null=True, blank=True, verbose_name=u'关联美购外键id')
# 案例相关字段 Since 3.7
link_doctor_id = models.CharField(max_length=100, null=True, blank=True, verbose_name=u'关联医生外键id')
raw_doctor = models.CharField(verbose_name=u'医生（名称）', blank=True, default='', max_length=200)
link_hospital_id = models.CharField(max_length=100, null=True, blank=True, verbose_name=u'关联医院外键id')
raw_hospital = models.CharField(verbose_name=u'医院（名称）', blank=True, default='', max_length=200)
rating = models.IntegerField(verbose_name=u'评价', blank=True, default=0)
price = models.IntegerField(verbose_name=u'价格', blank=True, default=0)
operation_time = models.DateField(verbose_name=u'手术日期', blank=True, null=True, default=None)
# v 7.6.25 新加字段 用于记录用户自己选择的术后日期
operation_date = models.DateTimeField(db_index=True, verbose_name=u"用户选择的术后日期", default=timezone.now)
pre_operation_image = ImgUrlField(img_type=IMG_TYPE.TOPIC, verbose_name=u'术前图', max_length=128, default='',
blank=True, null=True)
post_operation_image = ImgUrlField(img_type=IMG_TYPE.TOPIC, verbose_name=u'术后图', max_length=128, default='',
blank=True, null=True)
activity = models.ForeignKey(Activity, null=True, default=None) # added @5.5
device_id = models.CharField(verbose_name=u'发帖时的设备号', max_length=64, blank=True, default=None,
null=True) # added at 5.7
is_mixed = models.BooleanField(default=False, help_text=u"是否是图文混排", verbose_name=u"图文混排")
# 分享文案相关
share_id = models.IntegerField(default=None, null=True, verbose_name=u'分享文案外键id')
# pgc相关
pgc_classfy = models.ForeignKey(PgcClassify, null=True, blank=True, related_name='topics',
verbose_name=u'分类')
audit_status = models.BooleanField(default=True, help_text=u"审核状态", verbose_name=u"审核状态")
# 所长发帖添加富文本
answer_richtext = models.TextField(default='', blank=True, verbose_name=u'话题内容')
link_doctor_item_id = models.IntegerField(default=None, null=True)
new_vote_num = models.IntegerField(default=0, null=False)
remark = models.TextField('精华点评', default='')
"""
FIELDS DEPRECATED
mysql fields:
`activity_title` varchar(100) DEFAULT NULL,
`body_part_id` int(11) DEFAULT NULL,
`bodypart_subitem_id` int(11) DEFAULT NULL,
`collect_num` int(11) NOT NULL DEFAULT '0',
`other_item` varchar(100) DEFAULT '',
`has_activity` tinyint(1) NOT NULL,
`jump_type` varchar(1) NOT NULL,
`jump_value` varchar(100) DEFAULT NULL,
`link_doctor_item_id` int(11) DEFAULT NULL,
`is_viewed` tinyint(1) NOT NULL DEFAULT '1',
`is_alerted` tinyint(1) NOT NULL,
`patient_image` varchar(255) DEFAULT NULL,
"""
has_activity = models.BooleanField(verbose_name=u'是否有活动链接', default=False)
jump_type = models.CharField(max_length=1, null=False, choices=SLIDE_TYPE, default=SLIDE_TYPE.CREATE_TOPIC)
is_alerted = models.BooleanField(help_text=u"是否已经提醒", verbose_name=u"已经提醒", default=False)
# FIELDS DEPRECATED END
@property
def is_offline(self):
"""is_online=False or flag != Normal."""
return not self.is_online or self.flag != PROBLEM_FLAG_CHOICES.NORMAL
def get_tags(self):
"""problems's tags."""
ts = []
for tag in self.tags:
data = {
'name': tag.name,
'tag_id': tag.id,
'tag_type': tag.tag_type,
}
ts.append(data)
return ts
@classmethod
def get_redis_vote_key(cls):
#const_strings.TOPIC_VOTE 替换成 topic_vote_v1
topic_vote_v1 = "topic_vote_v1"
return topic_vote_v1
@staticmethod
def _get_vote_amount_of_id(topic_id):
# 原来的 return int(ViewRecord(const_strings.TOPIC_VOTE)[topic_id] or 0)
topic_vote_v1 = Problem.get_redis_vote_key()
return int(ViewRecord(topic_vote_v1)[topic_id] or 0) # TODO CR ViewRecord & const_strings
@classmethod
def get_amount_of_topic_ids_by_type(cls, topic_ids, amount_type=''):
"""批量获取帖子的点赞/浏览数"""
if not topic_ids:
return {}
if amount_type.lower() == 'vote':
amount_key = cls.get_redis_vote_key()
elif amount_type.lower() == 'view':
amount_key = const_strings.TOPIC_VIEW
amount_list = ViewRecord(amount_key).view_hmget(topic_ids)
amount_map = dict(zip(topic_ids, map(lambda x: int(x or 0), amount_list)))
return amount_map
@classmethod
def get_vote_amount_of_topic_ids(cls, topic_ids):
"""批量获取帖子的点赞数"""
return cls.get_amount_of_topic_ids_by_type(topic_ids, 'vote')
@property
def vote_amount(self):
"""7720修改 日记帖的点赞数*7 现在干掉 """
return int(self._get_vote_amount_of_id(self.id) or 0)
@staticmethod
def get_view_amount_of_id(topic_id):
return int(ViewRecord(const_strings.TOPIC_VIEW)[topic_id] or 0) # TODO CR ViewRecord & const_strings
@classmethod
def get_view_amount_of_topic_ids(cls, topic_ids):
"""批量获取帖子的浏览数"""
return cls.get_amount_of_topic_ids_by_type(topic_ids, 'view')
@staticmethod
def set_view_amount_of_id(topic_id, num):
ViewRecord(const_strings.TOPIC_VIEW)[topic_id] = str(num) # TODO CR ViewRecord & const_strings
@property
def view_amount(self):
"""7720修改 日记帖的浏览量*13"""
return int(self.get_view_amount_of_id(self.id)) * 13
@property
def author_type(self):
return AUTHOR_TYPE.USER
@property
def get_title_style_type(self):
return ''
def get_title(self):
t = self.title or self.ask or ''
return escape(t)
@property
def content(self):
if self.topic_type in (TOPIC_TYPE.COLUMN_ARTICLE, TOPIC_TYPE.USER_ARTICLE):
return self.ask
if self.user_id == settings.SUOZHANG_UID or self.topic_type == TOPIC_TYPE.WEIXIN_NUM:
_content = self.answer
else:
_content = escape(self.answer)
return _content
def get_topic_info_from_db(self, user=None):
user_info = UserConvertService.get_user_info_by_user_id(self.user_id, simple=False)
user_info.update({
"city": user_info.pop("city_name", "") or u'中国',
"vote_num_gained": user_info.pop("vote_count", 0),
"topic_num_posted": user_info.pop("topic_count", 0),
})
if self.diary and self.diary.operation_time:
operation_time = get_timestamp(self.diary.operation_time)
else:
operation_time = None
data = {
'user': user_info,
'problem': {
'topic_id': self.id,
'topic_type_id': self.topic_type,
'is_topic': self.is_topic,
'title': self.get_title(),
'content': self.content,
'ask': self.ask,
'images': [],
'images_raw': [], # dict of images info
'pre_operation_images': [],
'is_private': False,
'last_modified_time': get_timestamp_or_none(self.last_modified),
'created_time': get_timestamp_or_none(self.created_time),
'doctor_num': self.doctor_num,
'reply_num': self.reply_num,
'is_voted': False,
'vote_num': 0,
'view_num': 0,
'title_style_type': self.get_title_style_type,
'operation_time': operation_time, # 对应日记本设置的治疗时间
'operation_date': get_timestamp_or_none(self.operation_date), # 对应该日记贴选择的术后时间
'tags': self.get_tags(),
'is_favord': False,
'interval': '',
'activity_id': self.activity and self.activity.id or None,
'activity_title': self.activity and self.activity.title or None,
'is_mixed': self.is_mixed,
'from_weixin': True if self.topic_type == TOPIC_TYPE.WEIXIN_NUM else False,
'user_name': user_info.get("user_name", ""),
'rich_text': self.answer_richtext,
'author_type': self.author_type,
'operation_record': self.operation_record,
# NOTE: deprecated
'is_recommend': self.is_recommend,
'is_recommend_all': self.is_recommend_all,
'doctor_id': '',
'service_name': None,
'patient_image': '',
'patient_image_thumb': '',
'zone_list': [],
# NOTE: deprecated end
},
'replies': [], # for compitable
'share_data': self.get_topic_share_data_from_db(),
}
if data['problem']['from_weixin']: # 产品的锅
data['title_replace_content'] = True
else:
data['title_replace_content'] = False
data['problem']['pre_id'] = ''
data['problem']['next_id'] = ''
try:
data['problem']['favord_count'] = self.favor_problem.filter(is_deleted=False).count()
except:
# 无收藏数据
data['problem']['favord_count'] = 0
if self.diary:
data['operation_info'] = self.diary.get_operation_info_for_topic_detail()
data['diary'] = {
'diary_id': self.diary.id,
'topic_num': self.diary.topics.filter(flag=PROBLEM_FLAG_CHOICES.NORMAL, is_online=True).count(),
'operator_is_hospital_officer': self.diary.operator_is_hospital_officer,
'title': self.diary.title,
'tags': self.diary.tags_new_era,
# NOTE: checked topic/detail list page, seems like diary's vote num is not used
'vote_num': 0,
}
# 返回当前帖子是日记本中第几篇帖子
# v 7.6.25 修改排序规则，之前按照 created_time 现在按照新加字段 operation_date 排序
topics = self.diary.topics.filter(is_online=True).values_list("id", flat=True).order_by('-operation_date',
"-id")
if topics.exists():
topics_id = list(topics)
try:
cur_index = topics_id.index(self.id)
data['problem']['diary_num'] = len(topics_id) - cur_index
data['problem']['pre_id'] = topics_id[cur_index - 1] if not cur_index == 0 else ''
data['problem']['next_id'] = topics_id[cur_index + 1] if not (cur_index + 1) == len(
topics_id) else ''
except:
pass # NOTE: 帖子下线 不需要处理
else:
data['problem']['diary_num'] = 1
else:
data['diary'] = None
data['operation_info'] = None
if self.pre_operation_image:
data['problem']['pre_operation_images'].append(get_full_path(self.pre_operation_image))
else:
for image in self.pre_operation_images.order_by('id'):
data['problem']['pre_operation_images'].append(get_full_path(image.image_url))
if self.post_operation_image:
data['problem']['images'].append(get_full_path(self.post_operation_image))
for image in self.images.order_by('id'):
img_url = get_full_path(image.image_url)
data['problem']['images'].append(img_url)
data['problem']['images_raw'].append({
'image_url': img_url,
'taken_time': get_timestamp_or_none(image.taken_time),
})
if self.topic_type == TOPIC_TYPE.SHARE and self.diary and self.diary.operation_time:
interval = self.created_time - self.diary.operation_time
if interval.days >= 0:
data['problem']['interval'] = u'{}'.format(interval.days + 1)
else:
data['problem']['interval'] = u'以前'
# 当只有一张图的时候，显示大图
data['problem']['show_large_images'] = len(data['problem']['images']) == 1
data['problem'].update(self.get_video_info())
data['problem']['replay'] = self.get_live_replay_info()
data['problem']['replay_app'] = self.get_live_replay_info_to_app(user=user)
return data
@classmethod
def get_extra_obj_of_topic_ids(cls, topic_ids, extra_model, rel_field='topic_id'):
"""批量获取关联的额外数据model对象"""
if not topic_ids:
return {}
filters = {'{}__in'.format(rel_field): topic_ids}
objs = extra_model.objects.filter(**filters)
obj_map = {getattr(obj, rel_field): obj for obj in objs if getattr(obj, rel_field)}
return obj_map
@classmethod
def get_extra_info_of_topic_ids(cls, topic_ids, extra_model, rel_field='topic_id',
extra_objs=None, info_method=None, default_info=None):
if extra_objs is None:
obj_map = cls.get_extra_obj_of_topic_ids(topic_ids, extra_model, rel_field)
else:
obj_map = extra_objs
info_map = {}
for topic_id in topic_ids:
try:
_info = getattr(obj_map[topic_id], info_method)() if topic_id in obj_map else default_info
except Exception:
logging_exception()
_info = default_info
info_map[topic_id] = _info
return info_map
@classmethod
def get_live_replay_info_of_topic_ids(cls, topic_ids, stream_map=None):
"""批量获取直播回放数据"""
from live.models import LiveStream
_default_info = {
'source': '',
'cover': '',
'content': '',
}
return cls.get_extra_info_of_topic_ids(
topic_ids, extra_model=LiveStream, extra_objs=stream_map,
info_method='get_topic_replay_info',
default_info=_default_info)
def get_live_replay_info(self):
try:
return self.stream.get_topic_reply_info()
except:
return {
'source': '',
'cover': '',
'content': ''
}
@classmethod
def get_live_replay_info_to_app_of_topic_ids(cls, topic_ids, stream_map=None):
"""批量获取直播回放数据"""
from live.models import LiveStream
_default_info = {}
return cls.get_extra_info_of_topic_ids(
topic_ids, extra_model=LiveStream, extra_objs=stream_map,
info_method='replay_data',
default_info=_default_info)
def get_live_replay_info_to_app(self, user):
try:
return self.stream.replay_data(user)
except:
return {}
def get_topic_share_data_from_db(self):
if self.share:
return {
'share_title': self.share.title,
'share_content': self.share.content,
'share_moments': self.share.moments,
'share_weibo': self.share.weibo,
'share_image': self.share.image
}
else:
return None
def is_voted(self, user_id):
is_voted = self.votes.filter(user_id=user_id).exists() if user_id else False
return is_voted
def is_author_followed_by(self, user_id):
if user_id:
from social.models import SocialInfo # TODO CR social 相关
social_info = SocialInfo(uid=user_id)
return social_info.is_following_user(self.user_id)
return False
def is_favored_by(self, user_id):
return self.favor_problem.filter(
user_id=user_id, is_deleted=False
).exists()
def get_topic_info_of_user(self, user):
return {
'is_following': self.is_author_followed_by(user.id) if user else False,
'is_voted': self.is_voted(user.id) if user else False,
'is_favord': bool(user) and self.is_favored_by(user.id) or False,
'is_private': self.user_id == user.id if user else False,
}
@classmethod
def get_topic_info_from_redis(cls, topic_id):
"""7720日记帖浏览量*13 点赞*7"""
return {
'vote_num': cls._get_vote_amount_of_id(topic_id),
'view_num': int(cls.get_view_amount_of_id(topic_id)) * 13,
}
@property
def view_num(self):
return self.get_view_amount_of_id(self.id)
@staticmethod
def get_topic_info_combined(from_db, of_user, from_redis):
from_db['problem'].update(of_user)
from_db['problem'].update(from_redis)
return from_db
def get_topic_info(self, user=None):
return self.get_topic_info_combined(
from_db=self.get_topic_info_from_db(user=user),
of_user=self.get_topic_info_of_user(user=user),
from_redis=self.get_topic_info_from_redis(self.id),
)
@classmethod
def get_video_info_of_topic_ids(cls, topic_ids, video_map=None):
"""批量获取视频数据"""
from .video import Video
_default_info = {
'video_url': '',
'video_pic': '',
'short_video_url': '',
}
return cls.get_extra_info_of_topic_ids(
topic_ids, extra_model=Video, extra_objs=video_map,
info_method='get_video_info',
default_info=_default_info)
def get_video_info(self):
try:
return self.video.get_video_info()
except:
return {
'video_url': '',
'video_pic': '',
'short_video_url': '',
}
def data(self):
_data = {}
_data["topic"] = topic = {}
topic["content"] = escape(self.answer)
images_data = []
for image in self.images.order_by('id'):
img_url = get_full_path(image.image_url)
image_data = {}
image_data['image'] = img_url
image_data["image_name"] = image.image_url
image_data["image_type"] = image.image_type
images_data.append(image_data)
topic["images"] = images_data
return _data
def set_review_status(self, image_count):
if (len(self.answer) < settings.CASHBACK_TOPIC_CONTENT_WORDS_LIMIT or
image_count < settings.CASHBACK_TOPIC_IMAGE_LIMIT):
self.review_status = PROBLEM_REVIEW_STATUS_CHOICES.CONTENT_LIMIT
else:
self.review_status = PROBLEM_REVIEW_STATUS_CHOICES.NOT_REVIEW
def update_reply_num(self, is_online=False, reply_num=0):
if not self.diary:
return False
if not reply_num:
reply_num = self.reply_num
if is_online:
self.diary.reply_num += reply_num
else:
self.diary.reply_num -= reply_num
if self.diary.reply_num < 0:
return False
self.diary.save()
return True
@property
def visible(self):
return self.is_online and self.flag == PROBLEM_FLAG_CHOICES.NORMAL
@classmethod
def get_by_id(cls, id):
try:
t = cls.objects.get(id=id)
return t
except cls.DoesNotExist:
return None
@property
def user(self):
return UserService.get_user_by_user_id(self.user_id)
@property
def service(self):
return GoodsService.get_service_by_service_id(self.service_id)
@property
def share(self):
return other.get_share_by_share_id(self.share_id)
@property
def assigned_doctor(self):
# TODO: error ?
return UserService.get_user_by_user_id(self.assigned_doctor_id)
@property
def doctor(self):
return DoctorService.get_doctor_from_doctor_id(self.doctor_id)
@property
def operations(self):
from .problem_operations import ProblemOperations # 避免循环引用
os = ProblemOperations.objects.filter(problem=self)
return os
@cached_property
def tag_ids(self):
from .problemtag import ProblemTag # 避免循环引用
tag_ids = ProblemTag.objects.filter(problem=self).values_list('tag_id', flat=True)
return list(tag_ids)
@cached_property
def tags(self):
_tags = TagService.get_tags_by_tag_ids(self.tag_ids)
return _tags or []
def add_tags(self, tag_ids):
from .problemtag import ProblemTag # 避免循环引用
for tag_id in tag_ids:
ProblemTag.objects.get_or_create(problem_id=self.id, tag_id=tag_id)
def upd_tags(self, tag_ids):
new_tags = set([int(tag_id) for tag_id in tag_ids if str(tag_id).isdigit()])
old_tags = set(self.tag_ids)
self.add_tags(list(new_tags - old_tags))
self.del_tags(list(old_tags - new_tags))
def del_tags(self, tag_ids):
from .problemtag import ProblemTag # 避免循环引用
ProblemTag.objects.filter(problem_id=self.id, tag_id__in=tag_ids).delete()
def clear_tags(self):
from .problemtag import ProblemTag # 避免循环引用
ProblemTag.objects.filter(problem_id=self.id).delete()
@property
def link_doctor(self):
return DoctorService.get_doctor_from_doctor_id(self.link_doctor_id)
@property
def link_hospital(self):
return HospitalService.get_hospital_from_hospital_id(self.link_hospital_id)
@property
def operation_record(self):
if not (self.diary and self.diary.operation_time):
return ''
timedel = self.created_time - self.diary.operation_time
if timedel.days == 0:
return u"#手术当日#"
elif timedel.days < 0:
return u""
else:
return u'#术后第{}天＃'.format(timedel.days)
@property
def operation_after_days(self):
if not (self.diary and self.diary.operation_time): # 没有日记本及治疗时间
return {"days": 0, "content": u""} # 前端通过content字段判断 时间展示。
postoperative_time = self.operation_date or self.created_time # 日记贴的术后时间
timedel = postoperative_time - self.diary.operation_time
if timedel.days == 0:
return {'days': timedel.days, 'content': u"手术当日"}
elif timedel.days < 0:
return {'days': timedel.days, 'content': u""}
else:
return {'days': timedel.days, 'content': u'术后{}天'.format(timedel.days)}
def get_operate_after_days(self, operation_time):
"""获取术后天数 负数为无效，无法计算术后天数"""
if not operation_time:
return -1
postoperative_time = self.operation_date or self.created_time
timedel = postoperative_time - self.diary.operation_time
return timedel.days
def get_operation_after_days_v1(self, operation_time):
after_days = self.get_operate_after_days(operation_time)
if after_days == 0:
return u"#手术当日#"
elif after_days < 0:
return u""
else:
return u'#术后第{}天＃'.format(after_days)
def get_operation_after_days_v2(self, operation_time):
after_days = self.get_operate_after_days(operation_time)
if after_days == 0:
return {'days': after_days, 'content': u"手术当日"}
elif after_days < 0:
return {'days': after_days, 'content': u""}
else:
return {'days': after_days, 'content': u'术后{}天'.format(after_days)}
class TopicAggr(models.Model):
"""数据组同步的model"""
class Meta:
app_label = 'talos'
db_table = 'api_topic_aggregate'
topic = models.ForeignKey(Problem, verbose_name=u'话题', related_name='aggr')
real_comment_num = models.IntegerField(verbose_name=u'真实评论数', null=True, blank=True)
is_deleted = models.IntegerField(verbose_name=u"是否删除")
create_time = models.DateTimeField(verbose_name=u"创建时间", auto_now_add=True)
update_time = models.DateTimeField(verbose_name=u"更新时间", auto_now=True)