reply.py

# -*- coding: utf-8 -*-
import json
import datetime
from django.conf import settings
from django.db.models import Q
from gm_types.mimas import (
    TRACTATE_PLATFORM,
    TRACTATE_REPLY_HIGHLIGHT
)
from gm_types.error import ERROR as CODES
from gm_types.gaia import USER_TYPE, DOCTOR_TYPE
from gm_dataquery.dict_mixin import to_dict

from gm_rpcd.all import RPCDFaultException
from utils.rpc import gen, get_current_user
from talos.portal import get_doctor_from_user_ids
from talos.cache.base import reply_cache as reply_msg_cache
from talos.tools.replies_tool import ReplyTool

from talos.libs.datetime_utils import get_timestamp_or_none
from qa.utils.decorator import listing
from talos.rpc import bind_context, bind
from talos.services import (
    get_user_from_context,
    UserService,
    UserConvertService,
)

from talos.services.doctor import DoctorService
from talos.services.soft_article.soft_article import SoftArticleService
from talos.tools.tractate_reply_tool import reply_update_cache
from talos.tasks.tractate import doctor_reply_push
from talos.services.soft_article.reply import SoftArticleReplyService, SoftArticle, SoftArticleReply
from talos.services.soft_article.vote import SoftArticleReplyVoteService

uri_pre = 'mimas/soft_article_reply'

class Test():
    pass


def handle_args(conditions):
    base_query = Q()
    if conditions.get("start_time"):
        times = datetime.datetime.fromtimestamp(conditions.get("start_time"))
        base_query &= Q(create_time__gte=times)
    if conditions.get("end_time"):
        times = datetime.datetime.fromtimestamp(conditions.get("end_time"))
        base_query &= Q(create_time__lte=times)
    if conditions.get("status", None) != None:
        base_query &= Q(is_reply=conditions.get("status"))
    if conditions.get('title'):
        s_article_ids = SoftArticle.objects.using(settings.SLAVE_DB_NAME)\
                                           .filter(title__contains=conditions.get('title'))\
                                           .values_list('id', flat=True)
        base_query &= Q(softarticle_id__in=list(s_article_ids))
    return base_query


@bind(uri_pre + '/list')
def get_my_reply_list(merchant_id, conditions={}, page=1, count=10):
    """医生后台专用列表"""
    SECOND_COUNT, START_INDEX = 5, 0
    offset = count * (page - 1)
    r_query = handle_args(conditions)
    reply_all = SoftArticleReply.objects.filter(r_query, merchant_id=merchant_id, top_id=0).order_by('-id')
    replies = list(reply_all[offset:offset+count].values())

    top_reply_user_ids = [item.get('user_id') for item in replies]
    top_users = UserService.get_users_by_user_ids(top_reply_user_ids)

    second_user_ids, second_doctor_ids, repied_ids, article_ids = [], [], [], []
    for top_reply_info in replies:
        article_ids.append(top_reply_info.get('softarticle_id'))
        second_reply = SoftArticleReplyService.get_second_reply_by_top_id(top_id=top_reply_info.get('id'),
                                                                          count=SECOND_COUNT, offset=START_INDEX)
        top_reply_info['create_time'] = int(top_reply_info['create_time'].timestamp())
        top_reply_info['update_time'] = int(top_reply_info['update_time'].timestamp())
        top_reply_info['reply_count'] = int(SoftArticleReplyService.top_reply_count(top_reply_info.get('id'))) or 0

        second_user_ids.extend([reply.get('user_id') for reply in second_reply])
        second_doctor_ids.extend([reply.get('doctor_id') for reply in second_reply])
        repied_ids.extend([reply.get('replied_id') for reply in second_reply])


        # 处理一级评论的用户信息
        top_reply_info['replies'] = second_reply
        if top_reply_info.get('user_id') not in top_users:
            continue
        top_reply_info['user_name'] = top_users[top_reply_info.get('user_id')].nickname
        top_reply_info['user_portrait'] = top_users[top_reply_info.get('user_id')].portrait

    relations = SoftArticleService.get_relation_data(soft_article_ids=article_ids)
    soft_articles = SoftArticleService.get_dict_by_soft_article_ids(soft_article_ids=article_ids)

    # 处理二级评论、被评论用户信息
    replied_infos = SoftArticleReplyService.get_replies_info(reply_ids=repied_ids)
    replyed_user_ids = [value.get('user_id') for key, value in replied_infos.items()]
    second_user_ids = list(set(second_user_ids + replyed_user_ids))
    second_users = UserService.get_users_by_user_ids(second_user_ids)

    replyed_doctor_ids = [value.get('doctor_id') for key, value in replied_infos.items()]
    second_doctor_ids = list(set(second_doctor_ids + replyed_doctor_ids))
    doctor_infos = DoctorService.get_doctor_by_doctor_ids_v1(doctor_ids=second_doctor_ids)
    second_doctors = {doctor_key: doctor_values.get('meta') for doctor_key, doctor_values in doctor_infos.items()}

    # 给二级评论补充用户信息
    for top_reply_info in replies:
        top_reply_info['service_data'] = relations.get(top_reply_info.get('softarticle_id')).get('service')
        top_reply_info['diary_data'] = relations.get(top_reply_info.get('softarticle_id')).get('diary')
        top_reply_info['article_info'] = soft_articles.get(top_reply_info.get('softarticle_id'))
        for second_reply in top_reply_info['replies']:
            if second_reply.get('doctor_id') in second_doctors:
                second_reply['doctor_name'] = second_doctors[second_reply.get('doctor_id')].get('name')
                second_reply['doctor_portrait'] = second_doctors[second_reply.get('doctor_id')].get('portrait')

            if second_reply.get('user_id') in second_users:
                second_reply['user_name'] = second_users[second_reply.get('user_id')].nickname
                second_reply['user_portrait'] = second_users[second_reply.get('user_id')].portrait

            replied_info = replied_infos.get(second_reply.get('replied_id'), {})
            if replied_info.get('user_id') in second_users:
                second_reply['replied_user_id'] = second_users[replied_info.get('user_id')].id
                second_reply['replied_user_name'] = second_users[replied_info.get('user_id')].nickname
                second_reply['replied_user_portrait'] = second_users[replied_info.get('user_id')].portrait

            if replied_info.get('doctor_id') in second_doctors:
                second_reply['replied_doctor_id'] = replied_info.get('doctor_id')
                second_reply['replied_doctor_name'] = second_doctors[replied_info.get('doctor_id')].get('name')
                second_reply['replied_doctor_portrait'] = second_doctors[replied_info.get('doctor_id')].get('portrait')

    return {"total": reply_all.count(), "data": replies}


@bind(uri_pre + '/reply_create')
def reply_create(soft_article_id, top_id, reply_id=None, content=None):
    """
    医生后台帖子回复
    :return:
    """

    soft_article = SoftArticle.objects.filter(id=soft_article_id, platform=TRACTATE_PLATFORM.DOCTOR).first()
    if not soft_article:
        return {"error": 1, "msg": "帖子不存在或已下线"}

    reply = SoftArticleReplyService.create(content=content, doctor_id=soft_article.doctor_id,
                                           soft_article_id=soft_article_id, merchant_id=soft_article.merchant_id,
                                           extra={"top_id": top_id, "replied_id": reply_id,
                                                  "source_id": TRACTATE_PLATFORM.DOCTOR})

    SoftArticleReplyService.update_reply_count(top_reply_id=top_id)

    if reply_id:
        s_reply = SoftArticleReplyService.get_by_id(pk=reply_id)
        s_reply.is_reply = True
        s_reply.save()

    doctor_reply_push.delay(soft_article_id=soft_article_id, reply_id=reply.id)

    doctor_info = DoctorService.get_doctor_from_doctor_id(reply.doctor_id)

    return {
        "id": reply.id,
        "soft_article_id": reply.softarticle_id,
        "replied_id": reply.replied_id,
        "doctor_id": reply.doctor_id,
        "doctor_name": doctor_info.name,
        "doctor_portrait": doctor_info.portrait,
        "content": reply.content,
        "vote_num": 0,
        "create_time": reply.create_time.timestamp(),
        "is_vote": False,
        "replied_user_id": "",
        "replied_user_name": "",
        "replied_user_portrait": "",
    }


@bind_context(uri_pre + '/create')
def create_reply(ctx, soft_article_id, content, top_id=None, reply_id=None):
    """
    用户发布评论
    """
    user = get_user_from_context(ctx)
    if not user:
        return gen(CODES.LOGIN_REQUIRED)

    article = SoftArticleService.healthy(soft_article_id)

    result = {
        "replied_user_id": "",
        "replied_user_portrait": "",
        "replied_user_name": ""
    }

    if not top_id and not reply_id:
        top_id = 0
    if reply_id and not top_id:
        top_id = reply_id

    if reply_id:
        replied_info = SoftArticleReplyService.get_by_id(pk=reply_id)
        if replied_info.user_id:
            replied_user_info = UserConvertService.get_user_info_by_user_id(replied_info.user_id)
            result.update({
                "replied_user_id": replied_info.user_id,
                "replied_user_portrait": replied_user_info.get("portrait", ""),
                "replied_user_name": replied_user_info.get("user_name", ""),
                "replied_user_type": USER_TYPE.NORMAL,
                "replied_user_info": replied_user_info,
            })
        if replied_info.doctor_id:
            doctor_info = UserConvertService.format_doctor_analogy_user_info_by_doctor_id(replied_info.doctor_id)
            result.update({
                "replied_user_id": doctor_info.get("user_id", 0),
                "replied_user_portrait": doctor_info.get("portrait", ""),
                "replied_user_name": doctor_info.get("user_name", ""),
                "replied_user_type": USER_TYPE.EXPERT,
                "replied_user_info": doctor_info,
            })

    reply = SoftArticleReplyService.create(content=content, user_id=user.id, merchant_id=article.merchant_id,
                                           soft_article_id=soft_article_id, extra={"top_id": top_id, "replied_id": reply_id,
                                                  "source_id": TRACTATE_PLATFORM.GM})

    # replied_user_id = replied_info.user_id if reply_id else None
    # if replied_user_id and user.id != replied_user_id:
    #     rt = ReplyTool(reply_msg_cache, replied_user_id)
    #     rt.receive_soft_article_reply(reply.id)

    doctor_reply_push.delay(soft_article_id=soft_article_id, reply_id=reply.id)

    # 更新一级评论下的评论数
    if top_id:
        result.update({"top_id": int(top_id)})
        SoftArticleReplyService.update_reply_count(top_reply_id=top_id)
    else:
        result.update({"replies": []})

    SoftArticleService.incr_article_reply(soft_article_id=soft_article_id)

    result.update({
        'id': reply.id,
        'content': reply.content,
        'user_type': USER_TYPE.NORMAL,
        'create_time': get_timestamp_or_none(reply.create_time),
        "replied_id": int(reply_id) if reply_id else '',
        "user_name": user.nickname,
        "user_id": user.id,
        "user_portrait": user.portrait,
        "is_vote": False,
        "vote_num": 0,
        "status": TRACTATE_REPLY_HIGHLIGHT.DARK,
        "reply_count": 0,
        'reply_user_info': UserConvertService.get_user_info_by_user_id(user.id)
    })
    return result


@bind(uri_pre + '/top_list')
def top_reply_list(soft_article_id, offset=0, count=10):
    """一级评论列表"""

    top_infos = SoftArticleReplyService.list_top_reply_by_soft_article_id(
        soft_article_id=soft_article_id, offset=offset, count=count)

    user_ids = [top.get("user_id") for top in top_infos]

    user_infos = UserConvertService.get_user_info_by_user_ids(user_ids=user_ids)

    for top_info in top_infos:
        _user_info = user_infos.get(top_info.get('user_id', 0), {})
        top_info.update({
            "user_name": _user_info.get("user_name", ""),
            "user_portrait": _user_info.get("user_portrait", ""),
            "reply_user_info": _user_info,
        })

    return top_infos


@bind(uri_pre + '/list_top_reply')
def get_top_list_by_soft_articles(soft_article_ids=[], offset=0, top_count=2, sort_condition=None):
    """多个软文的一级评论"""
    result, user_ids = {}, []
    for soft_article_id in soft_article_ids:
        soft_article_info = SoftArticleReplyService.list_top_reply_by_soft_article_id(
            soft_article_id=soft_article_id, offset=offset, count=top_count, sort_condition=sort_condition)
        user_ids.extend([reply.get('user_id') for reply in soft_article_info])
        result[str(soft_article_id)] = soft_article_info

    users = UserConvertService.get_user_info_by_user_ids(user_ids)

    for k, item in result.items():
        for reply in item:
            _user_info = users.get(reply.get("user_id", 0), {})
            if not _user_info:
                continue

            reply.update({
                "user_nickname": _user_info.get("user_name", ""),
                "user_portrait": _user_info.get("portrait", ""),
                "reply_user_info": _user_info,
            })

    return result


@bind(uri_pre + '/second_list')
def get_second_list_by_top_id(top_id, offset=0, count=10, is_doctor=False):
    """一级评论的子评论"""
    if not is_doctor:
        second_list = SoftArticleReplyService.get_second_reply_by_top_id(top_id=top_id, offset=offset, count=count)
    else:
        second_list = SoftArticleReplyService.get_second_reply_by_top_id(top_id=top_id, offset=offset)

    user_ids, replied_ids, doctor_ids = set(), set(), set()
    for second_info in second_list:
        _user_id = second_info.get("user_id", 0)
        _replied_id = second_info.get("replied_id", 0)
        _doctor_id = second_info.get("doctor_id", "")

        if _user_id:
            user_ids.add(_user_id)

        if _replied_id:
            replied_ids.add(_replied_id)

        if _doctor_id:
            doctor_ids.add(_doctor_id)

    replied_infos = SoftArticleReplyService.get_replies_info(reply_ids=replied_ids)
    user_ids.update(set(reply_value.get('user_id', 0) for reply_key, reply_value in replied_infos.items()))
    doctor_ids.update(set(reply_value.get('doctor_id', "") for reply_key, reply_value in replied_infos.items()))

    user_infos = UserConvertService.get_user_info_by_user_ids(user_ids=user_ids)
    doctor_infos = UserConvertService.format_doctor_analogy_user_info_by_doctor_ids(doctor_ids)

    for second_info in second_list:
        _user_info = user_infos.get(second_info.get('user_id', 0), {})
        _doctor_info = doctor_infos.get(second_info.get('doctor_id', ""), {})

        if _user_info:
            second_info.update({
                "user_type": USER_TYPE.NORMAL,
                "user_name": _user_info.get("user_name", ""),
                "user_portrait": _user_info.get("portrait", ""),
                "reply_user_info": _user_info,
            })

        if _doctor_info:
            second_info.update({
                "doctor_id": _doctor_info.get("doctor_id", ""),
                "doctor_name": _doctor_info.get("user_name", ""),
                "doctor_portrait": _doctor_info.get("portrait", ""),
                "reply_doctor_info": _doctor_info,
            })

            if _doctor_info.get('doctor_type') == DOCTOR_TYPE.OFFICER:
                second_info['user_type'] = USER_TYPE.OFFICER
                second_info['doctor_id'] = _doctor_info.get('hospital_id', "")

        reply_data = replied_infos.get(second_info.get('replied_id'), {})
        _replied_user_info = user_infos.get(reply_data.get('user_id', 0), {})
        _replied_doctor_info = doctor_infos.get(reply_data.get('doctor_id', ""), {})

        if _replied_user_info:
            second_info.update({
                "replied_user_type": USER_TYPE.NORMAL,
                "replied_user_id": reply_data.get('user_id'),
                "replied_user_name": _replied_user_info.get("user_name", ""),
                "replied_user_portrait": _replied_user_info.get("portrait", ""),
                "replied_user_info": _replied_user_info,
            })

        if _replied_doctor_info:
            second_info.update({
                "replied_doctor_id": reply_data.get('doctor_id'),
                "replied_doctor_name": _doctor_info.get("user_name", ""),
                "replied_doctor_portrait": _doctor_info.get("portrait", ""),
                "replied_doctor_info": _replied_doctor_info,
            })

            if _doctor_info.get('doctor_type') == DOCTOR_TYPE.OFFICER:
                second_info['replied_user_type'] = USER_TYPE.OFFICER
                second_info['replied_doctor_id'] = _doctor_info.get('hospital_id', "")

    return second_list


@bind(uri_pre + '/reply_popup')
# @listing()
def get_reply_in_popup(soft_article_id, offset=0, count=5, user_id=None, sort_condition=None):
    """评论弹窗~获取评论（一级和二级）"""
    SECOND_COUNT, START_INDEX = 2, 0
    SoftArticleService.healthy(soft_article_id)

    # 一级评论数据
    top_reply_infos = SoftArticleReplyService.list_top_reply_by_soft_article_id(
        soft_article_id=int(soft_article_id), offset=int(offset), count=int(count), sort_condition=sort_condition
    )

    top_reply_user_ids, vote_reply_ids = set(), []
    second_user_ids, repied_ids, second_doctor_ids = set(), [], set()

    # 一级评论处理用户，点赞状态，二级评论及子评论逻辑
    for item in top_reply_infos:
        _user_id = item.get("user_id", 0)
        _id = item.get("id", 0)

        if _user_id:
            top_reply_user_ids.add(_user_id)

        if _id:
            vote_reply_ids.append(_id)

        # 二级评论
        second_reply = SoftArticleReplyService.get_second_reply_by_top_id(
            top_id=_id,
            count=SECOND_COUNT,
            offset=START_INDEX,
            sort_condition=sort_condition
        )

        # 处理一级评论的子评论
        item['replies'] = second_reply
        for reply in second_reply:
            _reply_user_id = reply.get("user_id", 0)
            _replied_id = reply.get("replied_id", 0)
            _second_reply_id = reply.get("id", 0)
            _second_doctor_id = reply.get("doctor_id", "")

            if _reply_user_id:
                second_user_ids.add(_reply_user_id)
            if _replied_id:
                repied_ids.append(_replied_id)
            if _second_reply_id:
                vote_reply_ids.append(_second_reply_id)
            if _second_doctor_id:
                second_doctor_ids.add(_second_doctor_id)

    # 处理二级评论、被评论用户信息
    replied_infos = SoftArticleReplyService.get_replies_info(reply_ids=repied_ids)
    replyed_user_ids, replyed_doctor_ids = set(), set()
    for key, value in replied_infos.items():
        _replyed_user_id = value.get("user_id", 0)
        _replyed_doctor_id = value.get("doctor_id", "")

        if _replyed_user_id:
            replyed_user_ids.add(_replyed_user_id)

        if _replyed_doctor_id:
            replyed_doctor_ids.add(_replyed_doctor_id)

    # 取所有用户信息
    _all_user_ids = top_reply_user_ids | second_user_ids | replyed_user_ids
    all_user_infos = UserConvertService.get_user_info_by_user_ids(_all_user_ids)
    # 取所有医生信息
    _all_doctor_ids = second_doctor_ids | replyed_doctor_ids
    second_doctors = UserConvertService.format_doctor_analogy_user_info_by_doctor_ids(_all_doctor_ids)

    # 取所有已经被点赞的评论id
    voted_reply_ids = SoftArticleReplyVoteService.get_vote_status(
        user_id=user_id, softarticle_id=soft_article_id, reply_ids=vote_reply_ids)

    # 评论信息处理
    for top_reply_info in top_reply_infos:

        top_reply_user_info = all_user_infos.get(top_reply_info.get("user_id", 0), {})
        if not top_reply_user_info:
            continue

        top_reply_info.update({
            "user_name": top_reply_user_info.get("user_name", ""),
            "user_portrait": top_reply_user_info.get("portrait", ""),
            "is_vote": bool(top_reply_info.get("id", 0) in voted_reply_ids),
            "top_reply_user_info": top_reply_user_info,
        })

        # 二级评论信息处理
        for second_reply in top_reply_info.get('replies', []):
            second_reply_user_info = all_user_infos.get(second_reply.get('user_id', 0), {})
            second_reply_doctor_info = second_doctors.get(second_reply.get('doctor_id', ""), {})

            second_reply['is_vote'] = True if second_reply['id'] in voted_reply_ids else False

            if second_reply_user_info:
                second_reply.update({
                    "user_type": USER_TYPE.NORMAL,
                    "user_name": second_reply_user_info.get("user_name", ""),
                    "user_portrait": second_reply_user_info.get("portrait", ""),
                    "second_reply_user_info": second_reply_user_info,
                })

            if second_reply_doctor_info:
                second_reply.update({
                    "doctor_id": second_reply.get('doctor_id', ""),
                    "doctor_name": second_reply_doctor_info.get("user_name", ""),
                    "doctor_portrait": second_reply_doctor_info.get("portrait", ""),
                    "second_reply_doctor_info": second_reply_doctor_info,
                })
                if second_reply_doctor_info.get('doctor_type') == DOCTOR_TYPE.OFFICER:
                    second_reply['user_type'] = USER_TYPE.OFFICER
                    second_reply['doctor_id'] = second_reply_doctor_info.get('hospital_id', "")

            replied_info = replied_infos.get(second_reply.get('replied_id'), {})
            replied_info_user_info = all_user_infos.get(replied_info.get("user_id", 0), {})
            replied_info_doctor_info = second_doctors.get(replied_info.get("doctor_id", ""), {})

            if replied_info_user_info:
                second_reply.update({
                    "replied_user_type": USER_TYPE.NORMAL,
                    "replied_user_id": replied_info.get('user_id'),
                    "replied_user_name": replied_info_user_info.get("user_name", ""),
                    "replied_user_portrait": replied_info_user_info.get("portrait", ""),
                    "replied_user_info": replied_info_user_info,
                })

            if replied_info_doctor_info:
                second_reply.update({
                    "replied_doctor_id": replied_info.get('doctor_id'),
                    "replied_doctor_name": replied_info_doctor_info.get("user_name", ""),
                    "replied_doctor_portrait": replied_info_doctor_info.get("portrait", ""),
                    "replied_doctor_info": replied_info_doctor_info,
                })

                if replied_info_doctor_info.get('doctor_type') == DOCTOR_TYPE.OFFICER:
                    second_reply['replied_user_type'] = USER_TYPE.OFFICER
                    second_reply['replied_doctor_id'] = replied_info_doctor_info.get('hospital_id', "")

    return top_reply_infos


@bind(uri_pre + '/light_reply')
def get_light_reply(soft_article_id, user_id=None, target_reply_id=None):
    """获取高亮评论  针对用户"""
    SECOND_COUNT, START_INDEX = 2, 0
    more_highlight = True

    if not target_reply_id:
        return gen(CODES.PARAMS_INCOMPLETE)

    top_info = SoftArticleReplyService.get_highlight_reply(target_reply_id=target_reply_id)

    if not top_info:
        return []

    user_ids, replied_ids, vote_reply_ids, doctor_ids = set(), set(), set(), set()
    user_ids.add(top_info.get('user_id'))
    vote_reply_ids.add(top_info.get('id'))
    doctor_ids.add(top_info.get('doctor_id'))

    second_replies = SoftArticleReplyService.get_second_reply_by_top_id(
        top_id=top_info.get('id'), count=SECOND_COUNT, target_reply_id=target_reply_id
    )
    for reply in second_replies:
        _replied_id = reply.get('replied_id', 0)
        _reply_user_id = reply.get('user_id', 0)
        _reply_doctor_id = reply.get('doctor_id', "")
        _second_reply_id = reply.get("id", 0)

        if _reply_user_id:
            user_ids.add(_reply_user_id)

        if _replied_id:
            replied_ids.add(_replied_id)

        if _reply_doctor_id:
            doctor_ids.add(_reply_doctor_id)

        if _second_reply_id:
            vote_reply_ids.add(_second_reply_id)

    #获取用户是否点过赞
    voted_reply_ids = SoftArticleReplyVoteService.get_vote_status(
        user_id=user_id, softarticle_id=soft_article_id, reply_ids=vote_reply_ids)

    replied_infos = SoftArticleReplyService.get_replies_info(reply_ids=replied_ids)
    for key, value in replied_infos.items():
        user_ids.add(value.get('user_id', 0))
        doctor_ids.add(value.get('doctor_id', ""))

    all_user = UserConvertService.get_user_info_by_user_ids(user_ids)
    second_doctors = UserConvertService.format_doctor_analogy_user_info_by_doctor_ids(doctor_ids)

    for second_reply in second_replies:
        second_reply_user_info = all_user.get(second_reply.get("user_id", 0), {})
        second_reply_doctor_info = all_user.get(second_reply.get("doctor_id", ""), {})

        if not top_info['status'] and second_reply['status'] == TRACTATE_REPLY_HIGHLIGHT.LIGHT:
            more_highlight = False

        second_reply['is_vote'] = True if second_reply.get('id') in voted_reply_ids else False

        if second_reply_user_info:
            second_reply.update({
                "user_name": second_reply_user_info.get("user_name", ""),
                "user_portrait": second_reply_user_info.get("portrait", ""),
                "second_user_info": second_reply_user_info,
            })

        if second_reply_doctor_info:
            second_reply.update({
                "doctor_name": second_reply_doctor_info.get("user_name", ""),
                "doctor_portrait": second_reply_doctor_info.get("portrait", ""),
                "second_doctor_info": second_reply_doctor_info,
            })

        replied_info = replied_infos.get(second_reply.get('replied_id'), {})
        replied_info_user_info = all_user.get(replied_info.get("user_id", 0), {})
        replied_info_doctor_info = second_doctors.get(replied_info.get("doctor_id", ""), {})

        if replied_info_user_info:
            second_reply.update({
                "replied_user_id": replied_info.get('user_id'),
                "replied_user_name": replied_info_user_info.get("user_name", ""),
                "replied_user_portrait": replied_info_user_info.get("portrait", ""),
                "replied_user_info": replied_info_user_info,
            })

        if replied_info_doctor_info:
            second_reply.update({
                "replied_doctor_id": replied_info.get('doctor_id'),
                "replied_doctor_name": replied_info_doctor_info.get("user_name", ""),
                "replied_doctor_portrait": replied_info_doctor_info.get("portrait", ""),
                "replied_doctor_info": replied_info_doctor_info,
            })

    top_user_info = all_user.get(top_info.get("user_id", 0), {})
    top_info.update({
        "replies": second_replies,
        "user_id": top_user_info.get("user_id", 0),
        "user_name": top_user_info.get("user_name", ""),
        "user_portrait": top_user_info.get("portrait", ""),
        "is_vote": True if top_info.get('id') in voted_reply_ids else False,
        "top_reply_user_info": top_user_info,
    })

    if not top_info['status'] and more_highlight:
        top_info['status'] = TRACTATE_REPLY_HIGHLIGHT.MORE_LIGHT

    return [top_info]


@bind_context(uri_pre + 'receive', with_context=True)
def get_replies_by_ids(ctx, replies_ids):

    user = get_user_from_context(ctx)
    if not user:
        return gen(CODES.LOGIN_REQUIRED)

    if not replies_ids:
        return {}

    replies_dict = SoftArticleReplyService.get_replies_info(reply_ids=replies_ids)

    user_ids = []
    replied_ids = []
    soft_article_ids = []
    for _, reply in replies_dict.items():
        user_ids.append(reply["user_id"])
        replied_ids.append(reply["replied_id"])
        soft_article_ids.append(reply["softarticle_id"])

    replied_dict = SoftArticleReplyService.get_replies_info(reply_ids=replied_ids)
    users_dict = UserService.get_users_by_user_ids(user_ids)
    #Todo需要修改
    soft_article_dict = SoftArticleService.get_soft_article_by_ids(soft_article_ids)

    result = {}
    for reply_id, reply in replies_dict.items():

        reply_user = users_dict.get(reply["user_id"], {})

        replied = {}
        if reply["replied_id"]:
            item = replied_dict.get(reply["replied_id"], {})
            if item:
                replied = {
                    "id": reply["replied_id"],
                    "content": reply["content"],
                }

        soft_article = {}
        soft_article_obj = soft_article_dict.get(reply["softarticle_id"])
        if soft_article_obj:
            soft_article = {
                "id": soft_article_obj.id,
                "content": soft_article_obj.content,
                "user_id": soft_article_obj.user_id
            }

        info = {
            "id": reply["id"],

            "reply_date": reply["create_time"],
            "reply_content": reply["content"],

            "soft_article": soft_article,

            "replied": replied,
            "reply_user": {
                "id": reply_user.id,
                "name": reply_user.nickname,
                "portrait": reply_user.portrait,
            },
            "author": {
                "id": user.id,
                "name": user.nickname,
                "portrait": user.portrait,
            },
        }
        result[str(reply_id)] = info

    return result