wechat_send_msg.go 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274
  1. package services
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "errors"
  6. "fmt"
  7. "hongze/hongze_clpt/models"
  8. "hongze/hongze_clpt/utils"
  9. "io/ioutil"
  10. "net/http"
  11. "strconv"
  12. "strings"
  13. "time"
  14. )
  15. // 访谈申请
  16. func SendInterviewApplyTemplateMsg(realName, companyName, mobile, articleTitle string, itemOpenid *models.OpenIdList) (err error) {
  17. defer func() {
  18. if err != nil {
  19. go utils.SendAlarmMsg(fmt.Sprint("访谈申请模板消息推送消息失败,手机号", mobile, "公司:", companyName, "手机号:", mobile), 2)
  20. }
  21. }()
  22. keyword1 := realName + "【" + companyName + "】"
  23. first := "您有一条新的访谈申请,请及时处理。"
  24. keyword2 := mobile
  25. keyword3 := time.Now().Format(utils.FormatDateTime)
  26. keyword4 := articleTitle
  27. openIdArr := make([]string, 0)
  28. openIdArr = append(openIdArr, itemOpenid.OpenId)
  29. redirectUrl := ""
  30. sendInfo := new(SendWxTemplate)
  31. sendInfo.First = first
  32. sendInfo.Keyword1 = keyword1
  33. sendInfo.Keyword2 = keyword2
  34. sendInfo.Keyword3 = keyword3
  35. sendInfo.Keyword4 = keyword4
  36. sendInfo.TemplateId = utils.WxMsgTemplateIdApplyXzs
  37. sendInfo.RedirectUrl = redirectUrl
  38. sendInfo.RedirectTarget = 3
  39. //sendInfo.Resource =
  40. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_APPLY
  41. sendInfo.OpenIdArr = openIdArr
  42. err = PublicSendTemplateMsg(sendInfo)
  43. return
  44. }
  45. // 访谈申请取消
  46. func SendInterviewApplyCancelTemplateMsg(realName, companyName, mobile, articleTitle string, itemOpenid *models.OpenIdList) (err error) {
  47. defer func() {
  48. if err != nil {
  49. go utils.SendAlarmMsg(fmt.Sprint("访谈申请取消模板消息推送消息失败,手机号", mobile, "公司:", companyName, "手机号:", mobile), 2)
  50. }
  51. }()
  52. keyword1 := articleTitle
  53. keyword2 := time.Now().Format(utils.FormatDateTime)
  54. openIdArr := make([]string, 0)
  55. openIdArr = append(openIdArr, itemOpenid.OpenId)
  56. redirectUrl := ""
  57. sendInfo := new(SendWxTemplate)
  58. sendInfo.Keyword1 = keyword1
  59. sendInfo.Keyword2 = keyword2
  60. sendInfo.TemplateId = utils.WxMsgTemplateIdApplyCancelXzs
  61. sendInfo.RedirectUrl = redirectUrl
  62. sendInfo.RedirectTarget = 3
  63. //sendInfo.Resource =
  64. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_APPLY
  65. sendInfo.OpenIdArr = openIdArr
  66. err = PublicSendTemplateMsg(sendInfo)
  67. fmt.Println("send end")
  68. return
  69. }
  70. // 权限申请
  71. func SendPermissionApplyTemplateMsg(realName, companyName, mobile, applyMethod, redirectUrl string, user *models.WxUserItem) (err error) {
  72. defer func() {
  73. if err != nil {
  74. go utils.SendAlarmMsg(fmt.Sprint("权限申请模板消息推送消息失败,手机号", mobile, "公司:", companyName, "手机号:", mobile), 2)
  75. }
  76. }()
  77. companyId := user.CompanyId
  78. //权益客户
  79. raiCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_RAI_ID)
  80. if e != nil {
  81. err = errors.New("GetCompanyProductCount, Err: " + e.Error())
  82. return
  83. }
  84. var mobileOpenid string
  85. if raiCount == 0 {
  86. mobileOpenid = utils.WxMsgTemplateIdAskMsgMobilePublic
  87. } else {
  88. sealldetail, e := models.GetRaiSellerByCompanyId(companyId)
  89. if e != nil {
  90. err = errors.New("GetRaiSellerByCompanyId, Err: " + e.Error())
  91. return
  92. }
  93. mobileOpenid = sealldetail.Mobile
  94. }
  95. openIdList, e := models.GetWxOpenIdByMobileList(mobileOpenid)
  96. if e != nil {
  97. err = errors.New("GetRaiSellerByCompanyId, Err: " + e.Error())
  98. return
  99. }
  100. if len(openIdList) == 0 {
  101. return
  102. }
  103. openIdArr := make([]string, 0)
  104. for _, v := range openIdList {
  105. openIdArr = append(openIdArr, v.OpenId)
  106. }
  107. var first string
  108. var keyword1 string
  109. var keyword2 string
  110. var keyword3 string
  111. var keyword4 string
  112. var remark string
  113. //var redirectUrl string
  114. detail, e := models.GetCygxApplyRecordByMobile(mobile)
  115. if e != nil {
  116. err = errors.New("GetCygxApplyRecordByMobile" + e.Error())
  117. return
  118. }
  119. //如果是潜在客户就推送可查看详情的模版消息
  120. if detail.ApplyMethod == 2 {
  121. redirectUrl = utils.WX_MSG_PATH_APPLY_DETAIL + strconv.Itoa(detail.ApplyRecordId)
  122. }
  123. keyword1 = "权限申请:" + realName + "【" + companyName + "】"
  124. keyword2 = mobile
  125. keyword3 = time.Now().Format(utils.FormatDateTime)
  126. keyword4 = applyMethod
  127. sendInfo := new(SendWxTemplate)
  128. sendInfo.First = first
  129. sendInfo.Keyword1 = keyword1
  130. sendInfo.Keyword2 = keyword2
  131. sendInfo.Keyword3 = keyword3
  132. sendInfo.Keyword4 = keyword4
  133. sendInfo.Remark = remark
  134. sendInfo.TemplateId = utils.WxMsgTemplateIdApplyXzs
  135. sendInfo.RedirectUrl = redirectUrl
  136. sendInfo.RedirectTarget = 3
  137. sendInfo.Resource = mobile
  138. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_APPLY
  139. sendInfo.OpenIdArr = openIdArr
  140. err = PublicSendTemplateMsg(sendInfo)
  141. return
  142. }
  143. func sendTemplateMsg(sendUrl string, sendMap map[string]interface{}, itemOpenid *models.OpenIdList, resource string, sendType int) (err error) {
  144. sendMap["touser"] = itemOpenid.OpenId
  145. data, err := json.Marshal(sendMap)
  146. if err != nil {
  147. fmt.Println("SendTemplateMsgOne Marshal Err:", err.Error())
  148. return err
  149. }
  150. err = toSendTemplateMsg(sendUrl, data, resource, sendType, itemOpenid)
  151. if err != nil {
  152. fmt.Println("send err:", err.Error())
  153. }
  154. return
  155. }
  156. func toSendTemplateMsg(sendUrl string, data []byte, resource string, sendType int, dataItem *models.OpenIdList) (err error) {
  157. client := http.Client{}
  158. resp, err := client.Post(sendUrl, "application/json", bytes.NewBuffer(data))
  159. if err != nil {
  160. return
  161. }
  162. defer resp.Body.Close()
  163. body, _ := ioutil.ReadAll(resp.Body)
  164. var templateResponse SendTemplateResponse
  165. err = json.Unmarshal(body, &templateResponse)
  166. fmt.Println(templateResponse)
  167. utils.FileLog.Info("SendResult %s:", string(body))
  168. if err != nil {
  169. utils.FileLog.Info("SendResult Unmarshal Err:%s", err.Error())
  170. return err
  171. }
  172. //新增模板消息推送记录
  173. {
  174. tr := new(models.UserTemplateRecord)
  175. tr.UserId = dataItem.UserId
  176. tr.OpenId = dataItem.OpenId
  177. tr.Resource = resource
  178. tr.SendData = string(data)
  179. tr.Result = string(body)
  180. tr.CreateDate = time.Now().Format(utils.FormatDate)
  181. tr.CreateTime = time.Now().Format(utils.FormatDateTime)
  182. if templateResponse.Errcode == 0 {
  183. tr.SendStatus = 1
  184. } else {
  185. tr.SendStatus = 0
  186. }
  187. tr.SendType = sendType
  188. go func() {
  189. err = models.AddUserTemplateRecord(tr)
  190. if err != nil {
  191. utils.FileLog.Info(fmt.Sprintf("AddUserTemplateRecord Err:%s", err.Error()))
  192. }
  193. }()
  194. }
  195. return
  196. }
  197. type SendTemplateResponse struct {
  198. Errcode int `json:"errcode"`
  199. Errmsg string `json:"errmsg"`
  200. MsgID int `json:"msgid"`
  201. }
  202. type SendWxTemplate struct {
  203. WxAppId string `description:"公众号appId"`
  204. First string `description:"模板消息first字段"`
  205. Keyword1 string `description:"模板消息keyword1字段"`
  206. Keyword2 string `description:"模板消息keyword2字段"`
  207. Keyword3 string `description:"模板消息keyword3字段"`
  208. Keyword4 string `description:"模板消息keyword4字段"`
  209. Remark string `description:"模板消息remark字段"`
  210. TemplateId string `description:"模板id"`
  211. RedirectUrl string `description:"跳转地址"`
  212. RedirectTarget int `description:"小程序跳转目标:1:弘则研报小程序,2:随手办公小程序"`
  213. Resource string `description:"资源唯一标识"`
  214. SendType int `description:"发送的消息类型:1:报告,2:指标更新提醒,3:审批通知,4:销售领取客户通知,5:活动取消通知,6活动更改时间通知,7:关注的作者发布报告通知,8:发送日报(周报、双周报、月报)模板消息,9:活动预约/报名时间通知"`
  215. OpenIdArr []string `description:"消息接收者openid"`
  216. }
  217. // 推送模板消息
  218. func PublicSendTemplateMsg(sendInfo *SendWxTemplate) (err error) {
  219. postData, err := json.Marshal(sendInfo)
  220. if err != nil {
  221. utils.SendAlarmMsg("SendTemplateMsg json.Marshal Err:"+err.Error(), 1)
  222. return err
  223. }
  224. body := ioutil.NopCloser(strings.NewReader(string(postData)))
  225. client := &http.Client{}
  226. req, err := http.NewRequest("POST", utils.SendWxTemplateMsgUrl, body)
  227. if err != nil {
  228. utils.SendAlarmMsg("SendTemplateMsg http.NewRequest Err:"+err.Error(), 1)
  229. return err
  230. }
  231. contentType := "application/json;charset=utf-8"
  232. req.Header.Set("Content-Type", contentType)
  233. req.Header.Set("Authorization", utils.SendTemplateMsgAuthorization)
  234. resp, err := client.Do(req)
  235. if err != nil {
  236. fmt.Println("http client.Do Err:" + err.Error())
  237. return err
  238. }
  239. defer resp.Body.Close()
  240. b, err := ioutil.ReadAll(resp.Body)
  241. if err != nil {
  242. return err
  243. }
  244. result := new(models.BaseResponse)
  245. err = json.Unmarshal(b, &result)
  246. if err != nil {
  247. return err
  248. }
  249. if result.Ret != 200 {
  250. err = errors.New(string(b))
  251. return err
  252. }
  253. return
  254. }