package logic

import (
	"app.yhyue.com/moapp/MessageCenter/rpc/messageclient"
	"context"
	"log"

	"app.yhyue.com/moapp/MessageCenter/api/internal/svc"
	"app.yhyue.com/moapp/MessageCenter/api/internal/types"

	"github.com/zeromicro/go-zero/core/logx"
)

type MessageFindLogic struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewMessageFindLogic(ctx context.Context, svcCtx *svc.ServiceContext) MessageFindLogic {
	return MessageFindLogic{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

func (l *MessageFindLogic) MessageFind(req types.MessageFindReq) (*types.MessageFindRes, error) {
	// todo: add your logic here and delete this line
	result := &types.MessageFindRes{}
	log.Println(req)
	lsi := l.svcCtx.MessageCenter
	resp, err := lsi.FindUserMsg(l.ctx, &messageclient.FindUserMsgReq{
		MsgType:       req.MsgType,
		Appid:         req.AppId,
		UserId:        req.UserId,
		ReceiveUserId: req.ReceiveUserId,
		Read:          req.IsRead,
		OffSet:        req.Offset,
		PageSize:      req.PageSize,
	})
	if err != nil {
		return nil, err
	}
	//data := make([]map[string]interface{}, 0)

	result.Code = resp.Code
	result.Message = resp.Message
	result.Total = resp.Count
	for _, v := range resp.Data {
		result.Data = append(result.Data, map[string]interface{}{
			"id":           v.Id,
			"appid":        v.Appid,
			"receive_name": v.ReceiveName,
			"send_userid":  v.SendUserId,
			"send_name":    v.SendName,
			"createtime":   v.Createtime,
			"title":        v.Title,
			"msg_type":     v.MsgType,
			"link":         v.Link,
			"cite_id":      v.CiteId,
			"content":      v.Content,
			"isRead":       v.IsRead,
			"msgLogId":     v.MsgLogId,
		})

	}

	return result, nil
}