# 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)