Compare commits

...

5 Commits
v1.2.0 ... v1

6 changed files with 45 additions and 32 deletions

View File

@ -44,17 +44,18 @@ type (
}
Finance struct {
CheckUserId string `json:"checkUserId"` //审核人
Sync int64 `json:"sync"` //是否是异步,如果为异步,付款申请和业务申请是同时进行
Amount string `json:"amount"` //金额
GoodsInfo string `json:"goodsInfo"` //商品信息
PaymentAccount string `json:"payment_account"` //付款方账户
TaxAmount string `json:"tax_amount"` //税率
CallbackUrl string `json:"callback_url"` //回调地址
Remark string `json:"remark"` //备注
CheckUserId string `json:"checkUserId"` //审核人
Sync int64 `json:"sync"` //是否是异步,如果为异步,付款申请和业务申请是同时进行
Amount string `json:"amount"` //金额
GoodsInfo string `json:"goodsInfo"` //商品信息
PaymentAccount string `json:"paymentAccount"` //付款方账户
TaxAmount string `json:"taxAmount"` //税率
CallbackUrl string `json:"callbackUrl"` //回调地址
Remark string `json:"remark"`
SystemName string `json:"systemName"` //业务系统名称
SubjectName string `json:"subjectName"` //户名
BankInfo BankInfo `json:"bankInfo"`
}
BankInfo struct {
ResellerName string `json:"resellerName"` //供应商名称
BankName string `json:"bankName"` //银行名称

View File

@ -1,8 +1,8 @@
package l_msg_api
const (
ServerHost = "http://127.0.0.1:8001"
TimeOut = 80000000
serverHost = "http://127.0.0.1:8001"
timeOut = 60
)
const (
@ -14,9 +14,9 @@ const (
)
const (
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"
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"
)

2
go.mod
View File

@ -1,6 +1,6 @@
module gitea.cdlsxd.cn/self-tools/l_msg_api
go 1.23.6
go 1.22.2
require github.com/valyala/fasthttp v1.59.0

16
msg.go
View File

@ -31,9 +31,11 @@ func NewMessageCenter(host, clientKey, clientSecret, serverIndex, tempIndex stri
// OACreate 发起OA审批
func (m *MessageCenter) OACreate(dTalkUserId, treadNo string, formModel *FormsData) (data OAResponse, err error) {
formModel.formBase.OutTradeNo = treadNo
formModel.formBase.OriginatorUserId = dTalkUserId
err = m.post(OaCreat, m.parseOACreateParam(formModel), &data)
formModel.FormBase = FormBase{
OutTradeNo: treadNo,
OriginatorUserId: dTalkUserId,
}
err = m.post(oaCreat, m.parseOACreateParam(formModel), &data)
if err != nil {
return
}
@ -46,7 +48,7 @@ func (m *MessageCenter) OAGetDetail(outTradeNo string) (data OAGetDetailData, er
Base: m.base,
OutTradeNo: outTradeNo,
})
err = m.post(OaGet, param, &data)
err = m.post(oaGet, param, &data)
if err != nil {
return
}
@ -56,7 +58,7 @@ func (m *MessageCenter) OAGetDetail(outTradeNo string) (data OAGetDetailData, er
// SendSms 短信
func (m *MessageCenter) SendSms(tels []string, jsonParam string) (data SmsSend, err error) {
param := m.parseSmsSendParam(tels, jsonParam)
err = m.post(SendSms, param, &data)
err = m.post(sendSms, param, &data)
if err != nil {
return
}
@ -73,7 +75,7 @@ func (m *MessageCenter) SendBlackBoard(title, content string, deptidList []int,
receiver := blackboardReceiverView{
deptidList, useridList,
}
err = m.post(SendSms, m.parseSendBlackBoardParam(title, content, receiver), &data)
err = m.post(sendSms, m.parseSendBlackBoardParam(title, content, receiver), &data)
if err != nil {
return
}
@ -93,7 +95,7 @@ func (m *MessageCenter) OAComment(outTradeNo, text, commentUserId string, file *
}
param, _ := json.Marshal(req)
err = m.post(OaComment, param, &data)
err = m.post(oaComment, param, &data)
if err != nil {
return
}

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
}
@ -45,7 +45,7 @@ func (m *MessageCenter) getAccessToken() (string, error) {
var data accessTokenResponse
var authParam, _ = json.Marshal(map[string]string{"client_key": m.ClientKey, "client_secret": m.ClientSecret})
err := m.accessPost(AccessToken, authParam, &data)
err := m.accessPost(accessToken, authParam, &data)
if err != nil {
return "", err
}
@ -55,7 +55,7 @@ func (m *MessageCenter) getAccessToken() (string, 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)
res, err := httpclient.FastHttpPost(fmt.Sprintf("%s%s", m.Host, path), m.header, data, timeOut)
if err != nil {
return
}
@ -79,7 +79,7 @@ func (m *MessageCenter) post(path string, data []byte, resReflect interface{}) (
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)
res, err := httpclient.FastHttpPost(fmt.Sprintf("%s%s", m.Host, path), m.header, data, timeOut)
if err != nil {
return
}

View File

@ -1,6 +1,7 @@
package test
import (
"context"
"fmt"
"gitea.cdlsxd.cn/self-tools/l_msg_api"
"testing"
@ -9,10 +10,12 @@ import (
const (
ClientKey = "ymt"
ClientSecret = "ymt"
serverHost = "http://120.55.12.245:8200"
local = "http://127.0.0.1:8001"
)
func TestSms(t *testing.T) {
msg, err := l_msg_api.NewMessageCenter(ClientKey, ClientSecret, "smssass", "sasssms")
msg, err := l_msg_api.NewMessageCenter(serverHost, ClientKey, ClientSecret, "smssass", "sasssms")
if err != nil {
panic(err)
}
@ -23,7 +26,7 @@ func TestSms(t *testing.T) {
}
func TestOaCreate(t *testing.T) {
msg, err := l_msg_api.NewMessageCenter(ClientKey, ClientSecret, "sw_oa", "sw_oa_purchase")
msg, err := l_msg_api.NewMessageCenter(local, ClientKey, ClientSecret, "sw_oa", "sw_oa_purchase")
if err != nil {
panic(err)
}
@ -35,7 +38,7 @@ func TestOaCreate(t *testing.T) {
{Name: "采购总金额", Value: "11.22"},
{Name: "预计到货时间", Value: "2025-03-21"},
}
res, err := msg.OACreate("17101201090101570", "123456789123bgff", &l_msg_api.FormsData{
res, err := msg.OACreate("17101201090101570", "cxvxvxcgfgfvxvxv", &l_msg_api.FormsData{
FormComponentValues: form,
Finance: &l_msg_api.Finance{
Amount: "11.22",
@ -46,6 +49,8 @@ func TestOaCreate(t *testing.T) {
CallbackUrl: "www.baidu.com",
Remark: "测试备注",
Sync: 1,
SystemName: "货易通",
SubjectName: "成都蓝色兄弟网络科技有限公司(0802)",
BankInfo: l_msg_api.BankInfo{
BankName: "中国银行",
BankAccount: "43243243434",
@ -59,10 +64,15 @@ func TestOaCreate(t *testing.T) {
}
func TestOaComment(t *testing.T) {
msg, err := l_msg_api.NewMessageCenter(ClientKey, ClientSecret, "sw_oa", "sw_oa_purchase")
msg, err := l_msg_api.NewMessageCenter(serverHost, ClientKey, ClientSecret, "sw_oa", "sw_oa_purchase")
if err != nil {
panic(err)
}
res, err := msg.OAComment("P24110515152043136-20250318181554", "sdk测试", "", nil)
fmt.Println(res, err)
}
func TestContext(*testing.T) {
c := context.Background()
c.Done()
}