package services import ( "bytes" "encoding/json" "fmt" "hongze/hongze_clpt/models" "hongze/hongze_clpt/utils" "io/ioutil" "net/http" "strconv" "time" ) //发送报告提问消息提醒 func SendWxMsgWithAsk(name, askTime, askMsg, title string, openIdList []*models.OpenIdList, articleId int) (err error) { var msg string defer func() { if err != nil { go utils.SendEmail("发送模版消息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers) go utils.SendAlarmMsg(fmt.Sprint("发送报告提问消息提醒模版消息失败,用户名", name, "文章ID:", articleId), 2) utils.FileLog.Info("发送模版消息失败,Err:%s", err.Error()) } fmt.Println("line 21", err, msg) }() utils.FileLog.Info("%s", "services SendMsg") //accessToken, err := models.GetWxAccessToken() accessToken, err := models.GetWxAccessTokenByXzs() if err != nil { msg = "GetWxAccessToken Err:" + err.Error() return } if accessToken == "" { msg = "accessToken is empty" return } var first string var keyword1 string var keyword3 string var keyword4 string var remark string first = "研选报告有新的提问,请及时处理" keyword1 = name keyword3 = askTime keyword4 = askMsg remark = title sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken //templateId := utils.WxMsgTemplateIdAskMsg templateId := utils.WxMsgTemplateIdAskMsgXzs sendMap := make(map[string]interface{}) sendData := make(map[string]interface{}) sendMap["template_id"] = templateId sendMap["miniprogram"] = map[string]interface{}{"appid": utils.WxAppId, "pagepath": "pages/reportDetail/reportDetail?id=" + strconv.Itoa(articleId)} //sendMap["miniprogram"] = map[string]interface{}{"appid": utils.WxAppId, "path": "article/detail?ArticleId=1000001"} sendData["first"] = map[string]interface{}{"value": first, "color": "#173177"} sendData["keyword1"] = map[string]interface{}{"value": keyword1, "color": "#173177"} sendData["keyword2"] = map[string]interface{}{"value": "", "color": "#173177"} sendData["keyword3"] = map[string]interface{}{"value": keyword3, "color": "#173177"} sendData["keyword4"] = map[string]interface{}{"value": keyword4, "color": "#173177"} sendData["remark"] = map[string]interface{}{"value": remark, "color": "#173177"} sendMap["data"] = sendData WxSendTemplateMsg(sendUrl, sendMap, openIdList, strconv.Itoa(articleId), utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD) return } func WxSendTemplateMsg(sendUrl string, sendMap map[string]interface{}, items []*models.OpenIdList, resource string, sendType int) (err error) { for _, v := range items { sendMap["touser"] = v.OpenId data, err := json.Marshal(sendMap) if err != nil { fmt.Println("SendTemplateMsgOne Marshal Err:", err.Error()) return err } utils.FileLog.Info("One SendData:%s", string(data)) fmt.Println(string(data)) err = SendTemplateMsg(sendUrl, data, resource, sendType, v) if err != nil { fmt.Println("send err:", err.Error()) return err } } return } func SendTemplateMsg(sendUrl string, data []byte, resource string, sendType int, dataItem *models.OpenIdList) (err error) { client := http.Client{} resp, err := client.Post(sendUrl, "application/json", bytes.NewBuffer(data)) if err != nil { return } defer resp.Body.Close() body, _ := ioutil.ReadAll(resp.Body) utils.FileLog.Info("SendResult:%s", string(body)) var templateResponse SendTemplateResponse err = json.Unmarshal(body, &templateResponse) fmt.Println(templateResponse.Errcode) fmt.Println(templateResponse.Errmsg) if err != nil { return err } //新增模板消息推送记录 { tr := new(models.UserTemplateRecord) tr.UserId = dataItem.UserId tr.OpenId = dataItem.OpenId tr.Resource = resource tr.SendData = string(data) tr.Result = string(body) tr.CreateDate = time.Now().Format(utils.FormatDate) tr.CreateTime = time.Now().Format(utils.FormatDateTime) if templateResponse.Errcode == 0 { tr.SendStatus = 1 } else { tr.SendStatus = 0 } tr.SendType = sendType go func() { err = models.AddUserTemplateRecord(tr) if err != nil { utils.FileLog.Info(fmt.Sprintf("AddUserTemplateRecord Err:%s", err.Error())) } }() } return } //活动带问提醒 func SendActivityAskApplyTemplateMsgV2(keyword1, keyword2, keyword3, keyword4, remark string, itemOpenid *models.OpenIdList, itemAct *models.ActivityDetail) (err error) { var msg string defer func() { if err != nil { go utils.SendEmail("发送模版消息失败"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToUsers) go utils.SendAlarmMsg("活动带问提醒发送模版消息失败"+remark, 2) } if msg != "" { utils.FileLog.Info("发送模版消息失败,msg:%s", msg) } }() var accessToken string accessToken, err = models.GetWxAccessTokenByXzs() if err != nil { msg = "GetWxAccessToken Err:" + err.Error() return } if accessToken == "" { msg = "accessToken is empty" return } activityId := itemAct.ArticleId //fmt.Println("itemAct.Host", itemAct.Host) if itemAct.ChartPermissionId != utils.CHART_PERMISSION_ID_YANXUAN && itemAct.Host != "" { keyword2 += ",会议主持人:" + itemAct.Host } sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken sendMap := make(map[string]interface{}) sendData := make(map[string]interface{}) first := "有新的客户提问" //keyword1 := applyName //keyword2 := "-" //keyword3 := applyTime //keyword4 := askContent //remark := activityName fontColor := "#D9001B" sendData["first"] = map[string]interface{}{"value": first, "color": fontColor} sendData["keyword1"] = map[string]interface{}{"value": keyword1, "color": fontColor} sendData["keyword2"] = map[string]interface{}{"value": keyword2, "color": fontColor} sendData["keyword3"] = map[string]interface{}{"value": keyword3, "color": fontColor} sendData["keyword4"] = map[string]interface{}{"value": keyword4, "color": fontColor} sendData["remark"] = map[string]interface{}{"value": remark, "color": fontColor} if utils.RunMode == "release" { sendMap["template_id"] = utils.WxMsgTemplateIdApplyXzs } else { sendMap["template_id"] = utils.WxMsgTemplateIdApply } sendMap["miniprogram"] = map[string]interface{}{"appid": utils.WxAppId, "pagepath": "activityPages/activityDetail/activityDetail?id=" + strconv.Itoa(activityId)} sendMap["data"] = sendData sendTemplateMsg(sendUrl, sendMap, itemOpenid, strconv.Itoa(activityId), utils.TEMPLATE_MSG_CYGX_ACTIVITY_ADD) fmt.Println("send end") return }