Compare commits

..

No commits in common. "v1" and "v1.8.0" have entirely different histories.
v1 ... v1.8.0

4 changed files with 18 additions and 66 deletions

View File

@ -31,7 +31,7 @@ type (
}
FormsData struct {
formBase
FormBase
FormComponentValues []FormComponentValues `json:"form_component_values"` // 审批表单数据
Finance *Finance `json:"finance"` // 财务模块调用
}
@ -65,7 +65,7 @@ type (
}
// 创建OA基础数据
formBase struct {
FormBase struct {
OutTradeNo string `json:"out_trade_no"` // 流水号
OriginatorUserId string `json:"originator_user_id"` // 钉钉申请人id
}

View File

@ -13,39 +13,10 @@ const (
DDDateField = "DDDateField"
)
type RequestPath string
const (
accessToken RequestPath = "/oauth/v1/accesstoken"
oaCreat RequestPath = "/msg/v1/dingtalk/oa/create"
oaGet RequestPath = "/msg/v1/dingtalk/oa/get"
oaComment RequestPath = "/msg/v1/dingtalk/oa/comment"
sendSms RequestPath = "/msg/v1/sms/send"
sendSmsHs RequestPath = "/msg/v1/sms/send/hs"
accessToken = "/oauth/v1/accesstoken"
oaCreat = "/msg/v1/dingtalk/oa/create"
oaGet = "/msg/v1/dingtalk/oa/get"
oaComment = "/msg/v1/dingtalk/oa/comment"
sendSms = "/msg/v1/sms/send"
)
type SmsBusiness string
const (
SmsBusinessHs SmsBusiness = "hs"
SmsBusinessDefault SmsBusiness = "aliyun"
)
var smsBusinessWithRequestPath = map[SmsBusiness]RequestPath{
SmsBusinessHs: sendSmsHs,
SmsBusinessDefault: sendSms,
}
type (
SmsOption func(*SmsOptionData)
SmsOptionData struct {
Business SmsBusiness
}
)
func WithBusiness(business SmsBusiness) SmsOption {
return func(OptionData *SmsOptionData) {
OptionData.Business = business
}
}

35
msg.go
View File

@ -2,7 +2,6 @@ package l_msg_api
import (
"encoding/json"
"errors"
)
type MessageCenter struct {
@ -24,15 +23,15 @@ func NewMessageCenter(host, clientKey, clientSecret, serverIndex, tempIndex stri
},
}
msg.header = map[string]string{"content-type": "application/json; charset=utf-8"}
token, err := msg.getAccessToken()
msg.header = map[string]string{"Authorization": token, "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{
formModel.FormBase = FormBase{
OutTradeNo: treadNo,
OriginatorUserId: dTalkUserId,
}
@ -57,36 +56,18 @@ func (m *MessageCenter) OAGetDetail(outTradeNo string) (data OAGetDetailData, er
}
// SendSms 短信
// business SmsBusiness
func (m *MessageCenter) SendSms(tels []string, jsonParam string, args ...SmsOption) (data SmsSend, err error) {
var (
e = new(SmsOptionData)
)
if len(tels) == 0 {
err = errors.New("手机号不能为空")
return
}
for _, arg := range args {
arg(e)
}
if e.Business != "" {
if _, ex := smsBusinessWithRequestPath[e.Business]; !ex {
err = errors.New("business参数错误")
return
}
} else {
e.Business = SmsBusinessDefault
}
path := smsBusinessWithRequestPath[e.Business]
func (m *MessageCenter) SendSms(tels []string, jsonParam string) (data SmsSend, err error) {
param := m.parseSmsSendParam(tels, jsonParam)
err = m.post(path, param, &data)
err = m.post(sendSms, param, &data)
if err != nil {
return
}
return
}
// BlackboardReceiverView struct {
// }
// SendBlackBoard 钉钉公告
// deptidList //接收部门ID列表最大的列表长度为20。
// UseridList //接收部用户ID列表最大的列表长度为20。

View File

@ -14,7 +14,7 @@ func (m *MessageCenter) parseOACreateParam(formModel *FormsData) (out []byte) {
}
req.FormComponentValues = formModel.FormComponentValues
req.Finance = formModel.Finance
req.formBase = formModel.formBase
req.FormBase = formModel.FormBase
out, _ = json.Marshal(req)
return
}
@ -53,7 +53,7 @@ func (m *MessageCenter) getAccessToken() (string, error) {
return data.AccessToken, err
}
func (m *MessageCenter) post(path RequestPath, data []byte, resReflect interface{}) (err error) {
func (m *MessageCenter) post(path string, data []byte, resReflect interface{}) (err error) {
var body responseBody
res, err := httpclient.FastHttpPost(fmt.Sprintf("%s%s", m.Host, path), m.header, data, timeOut)
if err != nil {
@ -77,7 +77,7 @@ func (m *MessageCenter) post(path RequestPath, data []byte, resReflect interface
return
}
func (m *MessageCenter) accessPost(path RequestPath, data []byte, resReflect interface{}) (err error) {
func (m *MessageCenter) accessPost(path string, data []byte, resReflect interface{}) (err error) {
var body responseBody
res, err := httpclient.FastHttpPost(fmt.Sprintf("%s%s", m.Host, path), m.header, data, timeOut)
if err != nil {