tencent_sms.go 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  1. package notify
  2. import (
  3. "encoding/json"
  4. errors2 "errors"
  5. "iot_manager_service/config"
  6. "strings"
  7. "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
  8. "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/errors"
  9. "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"
  10. sms "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/sms/v20210111" // 引入sms
  11. )
  12. // SendTencentSms 发送腾讯云短信通知
  13. // @param receiverPhoneNumbers 接收的手机号列表
  14. // @param smsTemplateId 短信模板ID
  15. // @param values 短信模板参数
  16. func SendTencentSms(receiverPhoneNumbers []string, smsTemplateId string, values []string) error {
  17. mainConfig := config.Instance().MonitNotice.Sms.Tencent
  18. /* 必要步骤:
  19. * 实例化一个认证对象,入参需要传入腾讯云账户密钥对secretId,secretKey。
  20. * 这里采用的是从环境变量读取的方式,需要在环境变量中先设置这两个值。
  21. * 你也可以直接在代码中写死密钥对,但是小心不要将代码复制、上传或者分享给他人,
  22. * 以免泄露密钥对危及你的财产安全。
  23. * SecretId、SecretKey 查询: https://console.cloud.tencent.com/cam/capi */
  24. credential := common.NewCredential(
  25. mainConfig.SecretID,
  26. mainConfig.SecretKey,
  27. )
  28. /* 非必要步骤:
  29. * 实例化一个客户端配置对象,可以指定超时时间等配置 */
  30. cpf := profile.NewClientProfile()
  31. /* SDK默认使用POST方法。
  32. * 如果你一定要使用GET方法,可以在这里设置。GET方法无法处理一些较大的请求 */
  33. cpf.HttpProfile.ReqMethod = "POST"
  34. /* SDK有默认的超时时间,非必要请不要进行调整
  35. * 如有需要请在代码中查阅以获取最新的默认值 */
  36. // cpf.HttpProfile.ReqTimeout = 5
  37. /* 指定接入地域域名,默认就近地域接入域名为 sms.tencentcloudapi.com ,也支持指定地域域名访问,例如广州地域的域名为 sms.ap-guangzhou.tencentcloudapi.com */
  38. cpf.HttpProfile.Endpoint = "sms.tencentcloudapi.com"
  39. /* SDK默认用TC3-HMAC-SHA256进行签名,非必要请不要修改这个字段 */
  40. cpf.SignMethod = "HmacSHA1"
  41. /* 实例化要请求产品(以sms为例)的client对象
  42. * 第二个参数是地域信息,可以直接填写字符串ap-guangzhou,支持的地域列表参考 https://cloud.tencent.com/document/api/382/52071#.E5.9C.B0.E5.9F.9F.E5.88.97.E8.A1.A8 */
  43. client, _ := sms.NewClient(credential, "ap-guangzhou", cpf)
  44. /* 实例化一个请求对象,根据调用的接口和实际情况,可以进一步设置请求参数
  45. * 你可以直接查询SDK源码确定接口有哪些属性可以设置
  46. * 属性可能是基本类型,也可能引用了另一个数据结构
  47. * 推荐使用IDE进行开发,可以方便的跳转查阅各个接口和数据结构的文档说明 */
  48. request := sms.NewSendSmsRequest()
  49. /* 基本类型的设置:
  50. * SDK采用的是指针风格指定参数,即使对于基本类型你也需要用指针来对参数赋值。
  51. * SDK提供对基本类型的指针引用封装函数
  52. * 帮助链接:
  53. * 短信控制台: https://console.cloud.tencent.com/smsv2
  54. * 腾讯云短信小助手: https://cloud.tencent.com/document/product/382/3773#.E6.8A.80.E6.9C.AF.E4.BA.A4.E6.B5.81 */
  55. /* 短信应用ID: 短信SdkAppId在 [短信控制台] 添加应用后生成的实际SdkAppId,示例如1400006666 */
  56. // 应用 ID 可前往 [短信控制台](https://console.cloud.tencent.com/smsv2/app-manage) 查看
  57. request.SmsSdkAppId = common.StringPtr(mainConfig.AppID)
  58. /* 短信签名内容: 使用 UTF-8 编码,必须填写已审核通过的签名 */
  59. // 签名信息可前往 [国内短信](https://console.cloud.tencent.com/smsv2/csms-sign) 或 [国际/港澳台短信](https://console.cloud.tencent.com/smsv2/isms-sign) 的签名管理查看
  60. request.SignName = common.StringPtr(mainConfig.SmsKey)
  61. /* 模板 ID: 必须填写已审核通过的模板 ID */
  62. // 模板 ID 可前往 [国内短信](https://console.cloud.tencent.com/smsv2/csms-template) 或 [国际/港澳台短信](https://console.cloud.tencent.com/smsv2/isms-template) 的正文模板管理查看
  63. request.TemplateId = common.StringPtr(smsTemplateId)
  64. /* 模板参数: 模板参数的个数需要与 TemplateId 对应模板的变量个数保持一致,若无模板参数,则设置为空*/
  65. request.TemplateParamSet = common.StringPtrs(values)
  66. /* 下发手机号码,采用 E.164 标准,+[国家或地区码][手机号]
  67. * 示例如:+8613711112222, 其中前面有一个+号 ,86为国家码,13711112222为手机号,最多不要超过200个手机号*/
  68. request.PhoneNumberSet = common.StringPtrs(receiverPhoneNumbers)
  69. /* 用户的 session 内容(无需要可忽略): 可以携带用户侧 ID 等上下文信息,server 会原样返回 */
  70. request.SessionContext = common.StringPtr("")
  71. /* 短信码号扩展号(无需要可忽略): 默认未开通,如需开通请联系 [腾讯云短信小助手] */
  72. request.ExtendCode = common.StringPtr("")
  73. /* 国际/港澳台短信 SenderId(无需要可忽略): 国内短信填空,默认未开通,如需开通请联系 [腾讯云短信小助手] */
  74. request.SenderId = common.StringPtr("")
  75. // 通过client对象调用想要访问的接口,需要传入请求对象
  76. response, err := client.SendSms(request)
  77. // 处理异常
  78. if _, ok := err.(*errors.TencentCloudSDKError); ok {
  79. return err
  80. }
  81. // 非SDK异常,直接失败。实际代码中可以加入其他的处理。
  82. if err != nil {
  83. return err
  84. }
  85. b, _ := json.Marshal(response.Response)
  86. //if strings.Contains(string(b), "insufficient balance in SMS package") {
  87. // return errors2.New("短信系统没余额了")
  88. //}
  89. //if strings.Contains(string(b), "the number of sms messages sent from a single mobile number every day exceeds the upper limit") {
  90. // return errors2.New("单个手机号超过上限")
  91. //}
  92. if !strings.Contains(string(b), "OK") {
  93. return errors2.New(string(b))
  94. }
  95. // 打印返回的json字符串
  96. return nil
  97. /* 当出现以下错误码时,快速解决方案参考
  98. * [FailedOperation.SignatureIncorrectOrUnapproved](https://cloud.tencent.com/document/product/382/9558#.E7.9F.AD.E4.BF.A1.E5.8F.91.E9.80.81.E6.8F.90.E7.A4.BA.EF.BC.9Afailedoperation.signatureincorrectorunapproved-.E5.A6.82.E4.BD.95.E5.A4.84.E7.90.86.EF.BC.9F)
  99. * [FailedOperation.TemplateIncorrectOrUnapproved](https://cloud.tencent.com/document/product/382/9558#.E7.9F.AD.E4.BF.A1.E5.8F.91.E9.80.81.E6.8F.90.E7.A4.BA.EF.BC.9Afailedoperation.templateincorrectorunapproved-.E5.A6.82.E4.BD.95.E5.A4.84.E7.90.86.EF.BC.9F)
  100. * [UnAuthorizedOperation.SmsSdkAppIdVerifyFail](https://cloud.tencent.com/document/product/382/9558#.E7.9F.AD.E4.BF.A1.E5.8F.91.E9.80.81.E6.8F.90.E7.A4.BA.EF.BC.9AunAuthorizedoperation.smssdkappidverifyfail-.E5.A6.82.E4.BD.95.E5.A4.84.E7.90.86.EF.BC.9F)
  101. * [UnsupportedOperation.ContainDomesticAndInternationalPhoneNumber](https://cloud.tencent.com/document/product/382/9558#.E7.9F.AD.E4.BF.A1.E5.8F.91.E9.80.81.E6.8F.90.E7.A4.BA.EF.BC.9Aunsupportedoperation.containdomesticandinternationalphonenumber-.E5.A6.82.E4.BD.95.E5.A4.84.E7.90.86.EF.BC.9F)
  102. * 更多错误,可咨询[腾讯云助手](https://tccc.qcloud.com/web/im/index.html#/chat?webAppId=8fa15978f85cb41f7e2ea36920cb3ae1&title=Sms)
  103. */
  104. }