sms.go 4.1 KB

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