package l_msg_api

import (
	"encoding/json"
)

type MessageCenter struct {
	Host         string // 消息中心地址
	ClientKey    string // 客户端id,获取授权token需要
	ClientSecret string
	header       map[string]string
	base
}

func NewMessageCenter(host, clientKey, clientSecret, serverIndex, tempIndex string) (*MessageCenter, error) {
	msg := &MessageCenter{
		Host:         host,
		ClientKey:    clientKey,
		ClientSecret: clientSecret,
		base: base{
			ServerIndex: serverIndex,
			TempIndex:   tempIndex,
		},
	}
	msg.header = map[string]string{"content-type": "application/json; charset=utf-8"}
	accessToken, err := msg.getAccessToken()
	msg.header = map[string]string{"Authorization": accessToken, "content-type": "application/json; charset=utf-8"}

	return msg, err
}

// OACreate 发起OA审批
func (m *MessageCenter) OACreate(dTalkUserId, treadNo string, formModel *FormsData) (data OAResponse, err error) {
	formModel.FormBase = FormBase{
		OutTradeNo:       treadNo,
		OriginatorUserId: dTalkUserId,
	}
	err = m.post(oaCreat, m.parseOACreateParam(formModel), &data)
	if err != nil {
		return
	}
	return
}

// OAGetDetail OA详情
func (m *MessageCenter) OAGetDetail(outTradeNo string) (data OAGetDetailData, err error) {
	param, _ := json.Marshal(oAGetDetailRequest{
		Base:       m.base,
		OutTradeNo: outTradeNo,
	})
	err = m.post(oaGet, param, &data)
	if err != nil {
		return
	}
	return
}

// SendSms 短信
func (m *MessageCenter) SendSms(tels []string, jsonParam string) (data SmsSend, err error) {
	param := m.parseSmsSendParam(tels, jsonParam)
	err = m.post(sendSms, param, &data)
	if err != nil {
		return
	}
	return
}

// BlackboardReceiverView struct {

// }
// SendBlackBoard 钉钉公告
// deptidList  //接收部门ID列表，最大的列表长度为20。
// UseridList  //接收部用户ID列表，最大的列表长度为20。
func (m *MessageCenter) SendBlackBoard(title, content string, deptidList []int, useridList []string) (data Default, err error) {
	receiver := blackboardReceiverView{
		deptidList, useridList,
	}
	err = m.post(sendSms, m.parseSendBlackBoardParam(title, content, receiver), &data)
	if err != nil {
		return
	}
	return
}

// OAComment OA评论,CommentUserId为空则默认审核发起人评论
func (m *MessageCenter) OAComment(outTradeNo, text, commentUserId string, file *DingOACommentReqFile) (data OAResponse, err error) {
	req := &oACommentRequest{
		Base:          m.base,
		OutTradeNo:    outTradeNo,
		Text:          text,
		CommentUserId: commentUserId,
	}
	if file != nil {
		req.File = *file
	}
	param, _ := json.Marshal(req)

	err = m.post(oaComment, param, &data)
	if err != nil {
		return
	}
	return
}