1 Star 0 Fork 0

lyc7751/我的公用工具

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
sms.go 3.02 KB
一键复制 编辑 原始数据 按行查看 历史
lee 提交于 2024-04-16 23:13 +08:00 . 打印参数
package utils
import (
"crypto/hmac"
"crypto/sha1"
"encoding/base64"
"encoding/json"
"errors"
"fmt"
"io/ioutil"
"math/rand"
"net/http"
"net/url"
"sort"
"strings"
"time"
)
// SendSmsReply 发送短信返回
type SendSmsReply struct {
Code string `json:"Code,omitempty"`
Message string `json:"Message,omitempty"`
}
func replace(in string) string {
rep := strings.NewReplacer("+", "%20", "*", "%2A", "%7E", "~")
return rep.Replace(url.QueryEscape(in))
}
// alisms 短信处理类
type alisms struct {
AliyunKey string // key
AliyunSecret string // secret
AliyunSMSName string // 签名
AliyunSMSCode string // 模板
}
// Sms 当前时间处理
func Sms() *alisms {
return &alisms{}
}
// Send 发送验证码
func (a *alisms) Send(phone string, code int64) (bool, string) {
AccessKeyId := a.AliyunKey // conf.GetString("aliyun.key")
AccessKeySecret := a.AliyunSecret // conf.GetString("aliyun.secret")
sign_name := a.AliyunSMSName // conf.GetString("aliyun.sms_register_name")
sign_code := a.AliyunSMSCode // conf.GetString("aliyun.sms_register_code")
strcode := fmt.Sprintf(`{"code":%d}`, code)
err := a.sendSms(AccessKeyId, AccessKeySecret, phone, sign_name, strcode, sign_code)
if err == nil {
return true, ""
} else {
return false, err.Error()
}
}
// SendSms 发送短信
func (a *alisms) sendSms(accessKeyID, accessSecret, phoneNumbers, signName, templateParam, templateCode string) error {
paras := map[string]string{
"SignatureMethod": "HMAC-SHA1",
"SignatureNonce": fmt.Sprintf("%d", rand.Int63()),
"AccessKeyId": accessKeyID,
"SignatureVersion": "1.0",
"Timestamp": time.Now().UTC().Format("2006-01-02T15:04:05Z"),
"Format": "JSON",
"Action": "SendSms",
"Version": "2017-05-25",
"RegionId": "cn-hangzhou",
"PhoneNumbers": phoneNumbers,
"SignName": signName,
"TemplateParam": templateParam,
"TemplateCode": templateCode,
}
fmt.Println("paras", paras)
var keys []string
for k := range paras {
keys = append(keys, k)
}
sort.Strings(keys)
var sortQueryString string
for _, v := range keys {
sortQueryString = fmt.Sprintf("%s&%s=%s", sortQueryString, replace(v), replace(paras[v]))
}
stringToSign := fmt.Sprintf("GET&%s&%s", replace("/"), replace(sortQueryString[1:]))
mac := hmac.New(sha1.New, []byte(fmt.Sprintf("%s&", accessSecret)))
mac.Write([]byte(stringToSign))
sign := replace(base64.StdEncoding.EncodeToString(mac.Sum(nil)))
str := fmt.Sprintf("http://dysmsapi.aliyuncs.com/?Signature=%s%s", sign, sortQueryString)
resp, err := http.Get(str)
if err != nil {
return err
}
defer resp.Body.Close()
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
return err
}
ssr := &SendSmsReply{}
// fmt.Println(string(body))
if err := json.Unmarshal(body, ssr); err != nil {
return err
}
if ssr.Code == "SignatureNonceUsed" {
return a.sendSms(accessKeyID, accessSecret, phoneNumbers, signName, templateParam, templateCode)
} else if ssr.Code != "OK" {
return errors.New(ssr.Code)
}
return nil
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/lyc7751/utils.git
git@gitee.com:lyc7751/utils.git
lyc7751
utils
我的公用工具
v0.0.8

搜索帮助