package web

import (
	"context"
	"go_dreamfactory/comm"
	"go_dreamfactory/lego/sys/gin"
	"go_dreamfactory/lego/sys/gin/engine"
	"go_dreamfactory/pb"
	"go_dreamfactory/sys/db"
	"net/http"
	"time"

	"go.mongodb.org/mongo-driver/bson/primitive"
)

type CrateMailReq struct {
	Uid    string           `json:"uid"`    // uid
	Title  string           `json:"title"`  // 邮件标题
	Contex string           `json:"contex"` // 邮件内容 支持自定义
	Items  []*pb.UserAssets `json:"items"`  // 附件
	Cid    string           `json:"cid"`    // 多语言表id
	Param  []string         `json:"param"`  // 自定义参数
	Sign   string           `json:"sign"`
}

//创建邮件
func (this *Api_Comp) CreateMail(c *engine.Context) {

	req := &CrateMailReq{}
	err := c.BindJSON(&req)
	this.module.Debugf("CrateMail:%+v err:%v", req, err)
	var (
		errdata *pb.ErrorData
		data    interface{}
	)
	if db.IsCross() { // 跨服服务器不能发邮件
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_ReqParameterError,
			Title: pb.ErrorCode_ReqParameterError.ToString(),
		}
		return
	}
	defer func() {
		c.JSON(http.StatusOK, &Respond{Code: errdata.Code, Message: errdata.Message, Data: data})
	}()
	if orgin, sign := gin.ParamSign(this.options.Key, map[string]interface{}{
		"uid":    req.Uid,
		"title":  req.Title,
		"contex": req.Contex,
		"cid":    req.Cid,
	}); sign != req.Sign {
		this.module.Errorf("CreateMail SignError orgin:%s sgin:%s", orgin, sign)
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_SignError,
			Title: pb.ErrorCode_SignError.ToString(),
		}
		return
	}

	mail := &pb.DBMailData{
		ObjId:      primitive.NewObjectID().Hex(),
		Uid:        req.Uid,
		Title:      req.Title,
		Contex:     req.Contex,
		CreateTime: uint64(time.Now().Unix()),
		DueTime:    uint64(time.Now().Unix() + 30*24*3600),
		Check:      false,
		Reward:     true,
		Items:      req.Items,
		Cid:        req.Cid,
		Param:      req.Param,
	}

	if len(mail.GetItems()) > 0 {
		mail.Reward = false
	}
	ctr, _ := context.WithTimeout(context.Background(), time.Second*5)
	if _, err = this.module.service.RpcGo(
		ctr,
		comm.Service_Worker,
		string(comm.Rpc_Mail),
		mail, nil); err != nil {
		this.module.Errorln(err)
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_RpcFuncExecutionError,
			Title: pb.ErrorCode_RpcFuncExecutionError.ToString(),
		}
		return
	}
	errdata = &pb.ErrorData{
		Code:  pb.ErrorCode_Success,
		Title: pb.ErrorCode_Success.ToString(),
	}
}