/*
-- @Time : 2022/6/8 11:24
-- @Author : raoxiaoya
-- @Desc :
*/
package dingtalk

import (
?? ?"encoding/json"
?? ?"errors"

?? ?"voteapi/pkg/curl"
)

type Response struct {
?? ?Errcode int
?? ?Errmsg ?string
}

const KeywordMonitor = "Monitor"
const MessageRobot = "https://oapi.dingtalk.com/robot/send?access_token=xxxxxxxxxxxxxxxxxxxx"

// 發(fā)送簡單文本消息
func SendDingTalkMessage(messageContent, messagePrefix string) (err error) {
?? ?defer func() {
?? ??? ?if er := recover(); er != nil {
?? ??? ??? ?err = errors.New("SendDingTalkMessage panic")
?? ??? ?}
?? ?}()
?? ?headers := map[string]string{
?? ??? ?"Content-Type": "application/json",
?? ?}

?? ?text := map[string]string{
?? ??? ?"content": messagePrefix + ": " + messageContent,
?? ?}

?? ?postData := map[string]interface{}{
?? ??? ?"msgtype": "text",
?? ??? ?"text": ? ?text,
?? ?}
?? ?body, _ := json.Marshal(postData)
?? ?resp, err := curl.HttpRequest(MessageRobot, "POST", headers, string(body))

?? ?if err != nil {
?? ??? ?return err
?? ?}

?? ?var re Response
?? ?_ = json.Unmarshal([]byte(resp), &re)
?? ?if re.Errcode > 0 {
?? ??? ?return errors.New(resp)
?? ?}

?? ?return nil
}

dingtalk.SendDingTalkMessage(fmt.Sprintf("service [%s] reboot success", v.Name), dingtalk.KeywordMonitor)