sms.go 4.1 KB

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