wechat_send_msg.go 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191
  1. package services
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "fmt"
  6. "hongze/hongze_mobile_admin/models/tables/report"
  7. "hongze/hongze_mobile_admin/models/tables/wx_user"
  8. "hongze/hongze_mobile_admin/utils"
  9. "io/ioutil"
  10. "net/http"
  11. "strconv"
  12. "time"
  13. )
  14. func SendWxTemplateMsg(reportId int) (err error) {
  15. var msg string
  16. defer func() {
  17. if err != nil {
  18. go utils.SendEmail("发送模版消息失败"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  19. utils.FileLog.Info("发送模版消息失败,Err:%s,%s", err.Error(), msg)
  20. }
  21. if msg != "" {
  22. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  23. }
  24. }()
  25. utils.FileLog.Info("%s", "services SendMsg")
  26. report, err := report.GetReportById(reportId)
  27. if err != nil {
  28. msg = "GetReportInfo Err:" + err.Error()
  29. return
  30. }
  31. if report == nil {
  32. utils.FileLog.Info("报告信息不存在")
  33. return
  34. }
  35. accessToken, err := WxGetAccessToken()
  36. if err != nil {
  37. msg = "GetWxAccessToken Err:" + err.Error()
  38. return
  39. }
  40. if accessToken == "" {
  41. msg = "accessToken is empty"
  42. return
  43. }
  44. //获取openid列表
  45. openIdStr := WxUsersGet()
  46. openIdList, err := wx_user.GetOpenIdList(openIdStr)
  47. if err != nil {
  48. msg = "get openIdList err:" + err.Error()
  49. return
  50. }
  51. fmt.Println("openIdListCount:", len(openIdList))
  52. sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
  53. fmt.Println("send start")
  54. utils.FileLog.Info("send start")
  55. //if report.MsgIsSend == 0 {
  56. sendMap := make(map[string]interface{})
  57. sendData := make(map[string]interface{})
  58. redirectUrl := utils.TemplateRedirectUrl + strconv.Itoa(reportId)
  59. keyword1 := "弘则日度点评"
  60. first := "Hi,最新一期日度点评已上线,欢迎查看"
  61. keyword2 := report.Title
  62. //keyword3 := report.PublishTime.Format(utils.FormatDateTime)
  63. keyword3 := report.PublishTime
  64. keyword4 := report.Abstract
  65. sendData["first"] = map[string]interface{}{"value": first, "color": "#173177"}
  66. sendData["keyword1"] = map[string]interface{}{"value": keyword1, "color": "#173177"}
  67. sendData["keyword2"] = map[string]interface{}{"value": keyword2, "color": "#173177"}
  68. sendData["keyword3"] = map[string]interface{}{"value": keyword3, "color": "#173177"}
  69. sendData["keyword4"] = map[string]interface{}{"value": keyword4, "color": "#173177"}
  70. sendMap["template_id"] = utils.TemplateIdByProduct
  71. sendMap["url"] = redirectUrl
  72. sendMap["data"] = sendData
  73. sendTemplateMsg(sendUrl, sendMap, openIdList)
  74. //}
  75. fmt.Println("send end")
  76. utils.FileLog.Info("send end")
  77. return
  78. }
  79. func sendTemplateMsg(sendUrl string, sendMap map[string]interface{}, items []*wx_user.OpenIdList) (err error) {
  80. for _, v := range items {
  81. sendMap["touser"] = v.OpenId
  82. data, err := json.Marshal(sendMap)
  83. if err != nil {
  84. fmt.Println("SendTemplateMsgOne Marshal Err:", err.Error())
  85. utils.FileLog.Info("SendTemplateMsgOne Marshal Err:%s", err.Error())
  86. return err
  87. }
  88. err = toSendTemplateMsg(sendUrl, data)
  89. if err != nil {
  90. fmt.Println("send err:", err.Error())
  91. utils.FileLog.Info("ToSendTemplateMsg Err:%s", err.Error())
  92. }
  93. }
  94. return
  95. }
  96. func toSendTemplateMsg(sendUrl string, data []byte) (err error) {
  97. utils.FileLog.Info("Send:%s", string(data))
  98. client := http.Client{}
  99. resp, err := client.Post(sendUrl, "application/json", bytes.NewBuffer(data))
  100. if err != nil {
  101. return
  102. }
  103. defer resp.Body.Close()
  104. body, _ := ioutil.ReadAll(resp.Body)
  105. utils.FileLog.Info("SendResult:%s", string(body))
  106. var templateResponse SendTemplateResponse
  107. err = json.Unmarshal(body, &templateResponse)
  108. if err != nil {
  109. utils.FileLog.Info("SendResult Unmarshal Err:%s", err.Error())
  110. return err
  111. }
  112. return
  113. }
  114. type SendTemplateResponse struct {
  115. Errcode int `json:"errcode"`
  116. Errmsg string `json:"errmsg"`
  117. MsgID int `json:"msgid"`
  118. }
  119. func SendCompanyApplyWxTemplateMsg(mobile, applyType string) (err error) {
  120. var msg string
  121. defer func() {
  122. if err != nil {
  123. go utils.SendEmail("发送模版消息失败"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers)
  124. utils.FileLog.Info("发送模版消息失败,Err:%s,%s", err.Error(), msg)
  125. }
  126. if msg != "" {
  127. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  128. }
  129. }()
  130. utils.FileLog.Info("%s", "services SendMsg")
  131. accessToken, err := WxGetAccessToken()
  132. if err != nil {
  133. msg = "GetWxAccessToken Err:" + err.Error()
  134. return
  135. }
  136. if accessToken == "" {
  137. msg = "accessToken is empty"
  138. return
  139. }
  140. utils.FileLog.Info("mobile:%s", mobile)
  141. //获取openid列表
  142. openIdStr := WxUsersGet()
  143. openIdList, err := wx_user.GetOpenIdListByMobile(mobile, openIdStr)
  144. if err != nil {
  145. msg = "get openIdList err:" + err.Error()
  146. return
  147. }
  148. utils.FileLog.Info("openIdListCount:%s", len(openIdList))
  149. //fmt.Println("openIdListCount:", len(openIdList))
  150. if len(openIdList) > 0 && utils.TemplateIdByCompanyApply != "" {
  151. utils.FileLog.Info("start send")
  152. sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
  153. fmt.Println("send start")
  154. utils.FileLog.Info("send start")
  155. sendMap := make(map[string]interface{})
  156. sendData := make(map[string]interface{})
  157. redirectUrl := "" //utils.TemplateRedirectUrl + strconv.Itoa(reportId)
  158. keyword1 := applyType
  159. first := "Hi,有新的订单需要审批"
  160. keyword2 := time.Now().Format(utils.FormatDateTime)
  161. keyword3 := ""
  162. remark := ""
  163. sendData["first"] = map[string]interface{}{"value": first, "color": "#173177"}
  164. sendData["keyword1"] = map[string]interface{}{"value": keyword1, "color": "#173177"}
  165. sendData["keyword2"] = map[string]interface{}{"value": keyword2, "color": "#173177"}
  166. sendData["keyword3"] = map[string]interface{}{"value": keyword3, "color": "#173177"}
  167. sendData["remark"] = map[string]interface{}{"value": remark, "color": "#173177"}
  168. sendMap["template_id"] = utils.TemplateIdByCompanyApply
  169. sendMap["url"] = redirectUrl
  170. sendMap["data"] = sendData
  171. sendTemplateMsg(sendUrl, sendMap, openIdList)
  172. }
  173. utils.FileLog.Info("send end")
  174. return
  175. }