sms.go 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. package services
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "hongze/hongze_mobile_admin/services/alarm_msg"
  6. "hongze/hongze_mobile_admin/utils"
  7. "io/ioutil"
  8. "net/http"
  9. "net/url"
  10. )
  11. func SendSmsCode(mobile, vCode string) bool {
  12. tplId := "65692"
  13. result, err := sendSms(mobile, tplId, vCode)
  14. if err != nil {
  15. fmt.Println("发送短信失败")
  16. return false
  17. }
  18. fmt.Println("result", string(result))
  19. var netReturn map[string]interface{}
  20. err = json.Unmarshal(result, &netReturn)
  21. if err != nil {
  22. //go SendEmail("短信验证码发送失败", "err:"+err.Error()+" result"+string(result), utils.EmailSendToUsers)
  23. go alarm_msg.SendAlarmMsg("短信验证码发送失败, Err:"+err.Error()+";Result:"+string(result), 2)
  24. return false
  25. }
  26. if netReturn["error_code"].(float64) == 0 {
  27. fmt.Printf("接口返回result字段是:\r\n%v", netReturn["result"])
  28. return true
  29. } else {
  30. // 忽略错误的手机号码这种错误
  31. if netReturn["error_code"].(float64) != 205401 {
  32. go alarm_msg.SendAlarmMsg("短信验证码发送失败, Result:"+string(result), 2)
  33. }
  34. return false
  35. }
  36. }
  37. func sendSms(mobile, tplId, code string) (rs []byte, err error) {
  38. var Url *url.URL
  39. apiURL := "http://v.juhe.cn/sms/send"
  40. //初始化参数
  41. param := url.Values{}
  42. //配置请求参数,方法内部已处理urlencode问题,中文参数可以直接传参
  43. param.Set("mobile", mobile) //接受短信的用户手机号码
  44. param.Set("tpl_id", tplId) //您申请的短信模板ID,根据实际情况修改
  45. param.Set("tpl_value", "#code#="+code) //您设置的模板变量,根据实际情况
  46. param.Set("key", utils.JhGnAppKey) //应用APPKEY(应用详细页查询)
  47. Url, err = url.Parse(apiURL)
  48. if err != nil {
  49. fmt.Printf("解析url错误:\r\n%v", err)
  50. return nil, err
  51. }
  52. //如果参数中有中文参数,这个方法会进行URLEncode
  53. Url.RawQuery = param.Encode()
  54. resp, err := http.Get(Url.String())
  55. if err != nil {
  56. fmt.Println("err:", err)
  57. return nil, err
  58. }
  59. defer resp.Body.Close()
  60. return ioutil.ReadAll(resp.Body)
  61. }
  62. // SendSmsCodeGj 发送国际短信
  63. func SendSmsCodeGj(mobile, vCode, areaNum string) bool {
  64. result, err := sendSmsGj(mobile, vCode, areaNum)
  65. if err != nil {
  66. fmt.Println("发送短信失败")
  67. return false
  68. }
  69. fmt.Println("result", string(result))
  70. var netReturn map[string]interface{}
  71. err = json.Unmarshal(result, &netReturn)
  72. if err != nil {
  73. //go SendEmail("短信验证码发送失败", "err:"+err.Error()+" result"+string(result), utils.EmailSendToUsers)
  74. go alarm_msg.SendAlarmMsg("短信验证码发送失败, Err:"+err.Error()+";Result:"+string(result), 2)
  75. return false
  76. }
  77. if netReturn["error_code"].(float64) == 0 {
  78. fmt.Printf("接口返回result字段是:\r\n%v", netReturn["result"])
  79. return true
  80. } else {
  81. // 忽略错误的手机号码这种错误
  82. if netReturn["error_code"].(float64) != 205401 {
  83. go alarm_msg.SendAlarmMsg("短信验证码发送失败, Result:"+string(result), 2)
  84. }
  85. return false
  86. }
  87. }
  88. // sendSmsGj 发送国际短信
  89. func sendSmsGj(mobile, code, areaNum string) (rs []byte, err error) {
  90. var Url *url.URL
  91. apiURL := "http://v.juhe.cn/smsInternational/send.php"
  92. //初始化参数
  93. param := url.Values{}
  94. //配置请求参数,方法内部已处理urlencode问题,中文参数可以直接传参
  95. param.Set("mobile", mobile) //接受短信的用户手机号码
  96. param.Set("tplId", "10054") //您申请的短信模板ID,根据实际情况修改
  97. param.Set("tplValue", "#code#="+code) //您设置的模板变量,根据实际情况
  98. param.Set("key", utils.JhGjAppKey) //应用APPKEY(应用详细页查询)
  99. param.Set("areaNum", areaNum) //应用APPKEY(应用详细页查询)
  100. Url, err = url.Parse(apiURL)
  101. if err != nil {
  102. fmt.Printf("解析url错误:\r\n%v", err)
  103. return nil, err
  104. }
  105. //如果参数中有中文参数,这个方法会进行URLEncode
  106. Url.RawQuery = param.Encode()
  107. resp, err := http.Get(Url.String())
  108. if err != nil {
  109. fmt.Println("err:", err)
  110. return nil, err
  111. }
  112. defer resp.Body.Close()
  113. return ioutil.ReadAll(resp.Body)
  114. }