wechat_send_msg.go 10 KB

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