3 Commits

Author SHA1 Message Date
  guzeng 006a73e54a 修改创蓝地址,修改UMS返回参数 1 year ago
  guzeng 88657cb9ad 增加创蓝短信发送接口 1 year ago
  lijianbin be96e2c357 阿里云短信 1 year ago
11 changed files with 241 additions and 77 deletions
Split View
  1. +37
    -39
      aliyun.go
  2. +1
    -1
      aliyun_test.go
  3. +109
    -0
      chuanglan.go
  4. +23
    -0
      chuanglan_test.go
  5. +0
    -20
      common.go
  6. +0
    -1
      go.mod
  7. +2
    -5
      go.sum
  8. +11
    -2
      tencent.go
  9. +28
    -0
      tencent_test.go
  10. +27
    -7
      ums.go
  11. +3
    -2
      ums_test.go

+ 37
- 39
aliyun.go View File

@ -1,16 +1,14 @@
package sms
import (
"errors"
"log"
"git.tetele.net/tgo/helper"
dysmsapi "github.com/aliyun/alibaba-cloud-sdk-go/services/dysmsapi"
"errors"
"git.tetele.net/tgo/helper"
dysmsapi "github.com/aliyun/alibaba-cloud-sdk-go/services/dysmsapi"
"log"
)
/**
* 企业信息服务平台--阿里云短信九江食堂用
* 阿里云短信
* @accessKeyId 用来验证用户身份的keyId
* @accessKeySecret 用来验证用户身份的secret
* @signName 短信签名名称
@ -19,36 +17,36 @@ import (
* @teplateParam 短信内容
*/
func SendByALiYun(accessKeyId string, accessKeySecret string, phoneNumbers string, signName string, templateCode string, teplateParam string) (bool, error) {
if accessKeyId == "" || accessKeySecret == "" || phoneNumbers == "" || signName == "" || templateCode == "" || teplateParam == "" {
return false, errors.New("参数不全")
}
client, err := dysmsapi.NewClientWithAccessKey("cn-qingdao", accessKeyId, accessKeySecret)
/* use STS Token
client, err := dysmsapi.NewClientWithStsToken("cn-qingdao", "<your-access-key-id>", "<your-access-key-secret>", "<your-sts-token>")
*/
request := dysmsapi.CreateSendSmsRequest()
request.Scheme = "https"
request.PhoneNumbers = phoneNumbers //"1368846****" //接收短信的手机号码
request.SignName = signName //"阿里云" //短信签名名称
request.TemplateCode = templateCode //"SMS_20933****" //短信模板ID
request.TemplateParam = teplateParam
response, err := client.SendSms(request)
if err != nil {
log.Println("post err", err)
return false, err
}
// var reply_data map[string]interface{}
// err = json.Unmarshal(response, &reply_data)
// if err != nil {
// log.Println(string(response), err)
// return false, err
// }
if helper.ToStr(response.Code) != "OK" {
return false, errors.New("短信发送失败," + helper.ToStr(response.Message))
}
return true, nil
if accessKeyId == "" || accessKeySecret == "" || phoneNumbers == "" || signName == "" || templateCode == "" || teplateParam == "" {
return false, errors.New("参数不全")
}
client, err := dysmsapi.NewClientWithAccessKey("cn-qingdao", accessKeyId, accessKeySecret)
/* use STS Token
client, err := dysmsapi.NewClientWithStsToken("cn-qingdao", "<your-access-key-id>", "<your-access-key-secret>", "<your-sts-token>")
*/
request := dysmsapi.CreateSendSmsRequest()
request.Scheme = "https"
request.PhoneNumbers = phoneNumbers // 接收短信的手机号码
request.SignName = signName // 短信签名名称
request.TemplateCode = templateCode // 短信模板ID
request.TemplateParam = teplateParam
response, err := client.SendSms(request)
if err != nil {
log.Println("post err", err)
return false, err
}
// var reply_data map[string]interface{}
// err = json.Unmarshal(response, &reply_data)
// if err != nil {
// log.Println(string(response), err)
// return false, err
// }
if helper.ToStr(response.Code) != "OK" {
return false, errors.New("短信发送失败," + helper.ToStr(response.Message))
}
return true, nil
}

+ 1
- 1
aliyun_test.go View File

@ -11,7 +11,7 @@ func Test_SendByALiYun(t *testing.T) {
phoneNumbers := "13790717280"
templateCode := "SMS_224500006"
params := make(map[string]string, 0)
params["code"] = "今晚打球吗"
params["code"] = "666666"
TemplateParam, _ := json.Marshal(params)
ret, err := SendByALiYun(accessKeyId, accessKeySecret, phoneNumbers, signName, templateCode, string(TemplateParam))


+ 109
- 0
chuanglan.go View File

@ -0,0 +1,109 @@
package sms
import (
"log"
"git.tetele.net/tgo/helper"
)
/**
* 创蓝253发送短信
*
* @param string $mobile 手机号码
* @param string $msg 短信内容
* @param string $sms_sign 短信签名
* @param string $needstatus 是否需要状态报告
* @return success bool, reply map[string]string, err error
*/
var CL_ACCOUNT string = "N3402351"
var CL_PASSWORD string = "zmkj64U5A"
// const CL_VARIABLE_SMS_URL string = "http://XXX/msg/variable/json"
func SendByCL(account, password, mobile, sms_sign, msg string) (bool, map[string]interface{}, error) {
const CL_SIMPLE_SMS_URL string = "https://smssh1.253.com/msg/v1/send/json" // "http://smssh1.253.com/msg/send/json"
if account == "" {
account = CL_ACCOUNT
}
if password == "" {
password = CL_PASSWORD
}
//创蓝接口参数
data := map[string]string{
"account": account,
"password": password,
"msg": StringJoin("【", sms_sign, "】", msg),
"phone": mobile,
"report": "true",
}
response, err := PostJsonData(CL_SIMPLE_SMS_URL, data)
if err != nil {
return false, nil, err
}
var reply map[string]interface{}
err = json.Unmarshal(response, &reply)
if err != nil {
log.Println(string(response), err)
return false, nil, err
}
if helper.ToStr(reply["code"]) != "0" {
return false, reply, nil
}
return true, reply, err
}
/**
* 查询额度
*
*/
func QueryRemaining(account, password string) (bool, string, map[string]interface{}, error) {
const URL string = "https://smssh1.253.com/msg/balance/json"
if account == "" {
account = CL_ACCOUNT
}
if password == "" {
password = CL_PASSWORD
}
data := map[string]string{
"account": account,
"password": password,
}
response, err := PostJsonData(URL, data)
/** 返回示例
{"code":0,"balance":"9156","time":"20230217150940","errorMsg":""}
{"code":"130","msgId":"","time":"20230217145243","errorMsg":"请求参数错误"}
{"code":"101","msgId":"","time":"20230217151029","errorMsg":"无此用户"}
*/
if err != nil {
return false, "", nil, err
}
var reply map[string]interface{}
err = json.Unmarshal(response, &reply)
if err != nil {
log.Println(string(response), err)
return false, "", nil, err
}
if helper.ToStr(reply["code"]) != "0" {
return false, "", reply, nil
}
return true, helper.ToStr(reply["balance"]), reply, err
}

+ 23
- 0
chuanglan_test.go View File

@ -0,0 +1,23 @@
package sms
import (
"testing"
)
func Test_SendByCL(t *testing.T) {
msg := "罗您好,您的商店新增2单物理灭蚊仪-天眼款,请及时登录商家后台处理!"
ret, reply, err := SendByCL("", "", "18607565510", "平沙数字云店", msg)
t.Log(ret)
t.Log(reply)
t.Log(err)
}
func Test_QueryRemaining(t *testing.T) {
ret, total, reply, err := QueryRemaining("", "")
t.Log(ret)
t.Log(total)
t.Log(reply)
t.Log(err)
}

+ 0
- 20
common.go View File

@ -4,15 +4,11 @@ import (
"bytes"
"crypto/md5"
"encoding/hex"
"git.tetele.net/tgo/helper"
"io/ioutil"
"log"
"net/http"
"net/url"
"strings"
"github.com/json-iterator/go"
"github.com/tjfoc/gmsm/sm3"
)
var json = jsoniter.ConfigCompatibleWithStandardLibrary
@ -86,19 +82,3 @@ func PostJsonData(url string, param interface{}, header ...map[string]string) ([
return body, nil
}
// ums验签
func UmsSetSign(data, header map[string]string,secretKey string) string {
str := helper.HttpBuildQuery(data)
// url encode
str = url.QueryEscape(str)
str = header["x-sp-code"] + header["x-app-key"] + secretKey + str + header["x-request-id"]
log.Println("加密前数据: ", str)
// ms3加密
hash := sm3.New()
hash.Write([]byte(str))
sign_byte := hash.Sum(nil)
sign := hex.EncodeToString(sign_byte)
log.Println("加密后数据: ", sign)
return sign
}

+ 0
- 1
go.mod View File

@ -3,7 +3,6 @@ module git.tetele.net/tgo/sms
go 1.16
require (
git.tetele.net/tgo/crypter v0.2.2
git.tetele.net/tgo/helper v0.3.2
github.com/aliyun/alibaba-cloud-sdk-go v1.61.1716
github.com/json-iterator/go v1.1.12


+ 2
- 5
go.sum View File

@ -1,6 +1,4 @@
cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
git.tetele.net/tgo/crypter v0.2.2 h1:YMQJh2Gj5Po4ZfelJUmXBKi01UbmtiSy3bmqRfnYQMo=
git.tetele.net/tgo/crypter v0.2.2/go.mod h1:vfvRLZA8+lHNgNXneOcgvVhDyuv25ZRb+C6xHOmXNx0=
git.tetele.net/tgo/helper v0.3.2 h1:3Pd3Ih3Ux+zFSjNZZv+4MSsVQiZ5HOfQmSus5+7rKR0=
git.tetele.net/tgo/helper v0.3.2/go.mod h1:89mQwyfqZ+t8YXiVwzSxA70gLlUNqoZGDEUxvV46jXk=
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
@ -40,7 +38,6 @@ github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHm
github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 h1:ZqeYNhU3OHLH3mGKHDcjJRFFRrJa6eAM5H+CtDdOsPc=
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@ -51,8 +48,8 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/testify v1.3.0 h1:TivCn/peBQ7UY8ooIcPgZFpTNSz0Q2U6UrFlUfqbe0Q=
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.365 h1:WBjY/1zAWHINPh8UB90HY/cMkbfUTtnb/H4TDqGwI/Q=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.365/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
@ -62,7 +59,6 @@ github.com/tjfoc/gmsm v1.4.1 h1:aMe1GlZb+0bLjn+cKTPEvvn9oUEBlJitaZiiBwsbgho=
github.com/tjfoc/gmsm v1.4.1/go.mod h1:j4INPkHWMrhJb38G+J6W4Tw0AbuN8Thu3PbdVYhVcTE=
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
golang.org/x/crypto v0.0.0-20201012173705-84dcc777aaee h1:4yd7jl+vXjalO5ztz6Vc1VADv+S/80LGJmyl1ROJ2AI=
golang.org/x/crypto v0.0.0-20201012173705-84dcc777aaee/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
@ -109,6 +105,7 @@ gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8
gopkg.in/ini.v1 v1.66.2 h1:XfR1dOYubytKy4Shzc2LHrrGhU0lDCfDGG1yLPmpgsI=
gopkg.in/ini.v1 v1.66.2/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b h1:h8qDotaEPuJATrMmW04NCwg7v22aHH28wwpauUhK9Oo=
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=

+ 11
- 2
tencent.go View File

@ -16,8 +16,12 @@ import (
* @signname 签名
* @templateId 模板id
* @params 参数值
* @region 区域, ap-guangzhou|ap-beijing|ap-shanghai
* @return *requestId,[]*sendStatus,error
*
*/
func SendByTencent(secretId, secretKey, smsAppId string, signname string, mobiles []string, templateId string, params []string) (*string, []*sms.SendStatus, error) {
func SendByTencent(secretId, secretKey, smsAppId string, signname string, mobiles []string, templateId string, params []string, region ...string) (*string, []*sms.SendStatus, error) {
credential := common.NewCredential(
secretId,
@ -25,7 +29,12 @@ func SendByTencent(secretId, secretKey, smsAppId string, signname string, mobile
)
cpf := profile.NewClientProfile()
cpf.HttpProfile.Endpoint = "sms.tencentcloudapi.com"
client, _ := sms.NewClient(credential, "ap-guangzhou", cpf)
region_default := "ap-guangzhou"
if len(region) > 0 {
region_default = region[0]
}
client, _ := sms.NewClient(credential, region_default, cpf)
request := sms.NewSendSmsRequest()


+ 28
- 0
tencent_test.go View File

@ -0,0 +1,28 @@
package sms
import (
"testing"
)
func Test_SendByTencent(t *testing.T) {
secretId := "AKIDObaKq9NRFn6A2iBaOxGKBoqeEbjdT5Vg"
secretKey := "0mLiqlU0IMwIOEqGWYMxLVREsMelhT3R"
smsAppId := "1400705248"
signname := "智企易创"
mobiles := []string{"18607565510"}
templateId := "1478144"
params := []string{"666555", "5"}
requestId, status, err := SendByTencent(secretId, secretKey, smsAppId, signname, mobiles, templateId, params, "ap-beijing")
t.Log(*requestId)
if len(status) > 0 {
for _, v := range status {
t.Log(*v.SerialNo, *v.PhoneNumber, *v.Code, *v.Message, *v.Fee, *v.SessionContext, *v.IsoCode)
}
}
t.Log(err)
}

+ 27
- 7
ums.go View File

@ -1,10 +1,14 @@
package sms
import (
"encoding/hex"
"errors"
"git.tetele.net/tgo/helper"
"log"
"net/url"
"time"
"git.tetele.net/tgo/helper"
"github.com/tjfoc/gmsm/sm3"
)
/**
@ -16,9 +20,9 @@ import (
* @mobiles 手机号多个用逗号隔开
* @content 短信内容
*/
func SendByUms(spCode, appKey, secretKey, mobiles, templateId, content string) (bool, error) {
func SendByUms(spCode, appKey, secretKey, mobiles, templateId, content string) (bool, []byte, error) {
if spCode == "" || appKey == "" || secretKey == "" || mobiles == "" || templateId == "" || content == "" {
return false, errors.New("参数不全")
return false, []byte(""), errors.New("参数不全")
}
api := "https://api.ums86.com/api/sms/send"
@ -52,7 +56,7 @@ func SendByUms(spCode, appKey, secretKey, mobiles, templateId, content string) (
if err != nil {
log.Println("post err", err)
return false, err
return false, reply, err
}
var reply_data map[string]interface{}
@ -61,12 +65,28 @@ func SendByUms(spCode, appKey, secretKey, mobiles, templateId, content string) (
if err != nil {
log.Println(string(reply), err)
return false, err
return false, reply, err
}
if helper.ToStr(reply_data["code"]) != "0" {
return false, errors.New("短信发送失败," + helper.ToStr(reply_data["msg"]))
return false, reply, errors.New("短信发送失败," + helper.ToStr(reply_data["msg"]))
}
return true, nil
return true, reply, nil
}
// ums验签
func UmsSetSign(data, header map[string]string, secretKey string) string {
str := helper.HttpBuildQuery(data)
// url encode
str = url.QueryEscape(str)
str = header["x-sp-code"] + header["x-app-key"] + secretKey + str + header["x-request-id"]
log.Println("加密前数据: ", str)
// ms3加密
hash := sm3.New()
hash.Write([]byte(str))
sign_byte := hash.Sum(nil)
sign := hex.EncodeToString(sign_byte)
log.Println("加密后数据: ", sign)
return sign
}

+ 3
- 2
ums_test.go View File

@ -8,11 +8,12 @@ func Test_SendByUms(t *testing.T) {
spCode := "257980"
appKey := "zx_jfsw"
secretKey := "cRgpvZ0242l7tE"
mobiles := "13790717280"
mobiles := "18607565510"
templateId := "1011012121170"
content := "您好!您的园区消费的账号为88888,初始密码为666666aa。请尽快修改初始密码,密码设置需包含字母、数字、特殊字符2种以上且最少8位。密码修改方式:微信小程序搜索“园区消费”,首次登录会自动进入修改密码页面,后续修改密码请登录后选择“我的”——更多服务——修改密码。如有问题,请联系信息技术中心。"
ret, err := SendByUms(spCode,appKey,secretKey,mobiles,templateId,content)
ret, data, err := SendByUms(spCode, appKey, secretKey, mobiles, templateId, content)
t.Log(ret)
t.Log(string(data))
t.Log(err)
}

Loading…
Cancel
Save