|
@@ -14,7 +14,7 @@ import (
|
|
|
)
|
|
|
|
|
|
// 活动预开始模版消息通知
|
|
|
-func SendWxMsgWithFrequency(first, activityName, reserveResults, activityTime, activityAddress, remark string, openIdList []*models.OpenIdList, activityId int) (err error) {
|
|
|
+func SendWxMsgWithFrequency(keyword2, activityName, reserveResults, activityTime, activityAddress, remark string, openIdList []*models.OpenIdList, activityId int) (err error) {
|
|
|
var msg string
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -23,29 +23,47 @@ func SendWxMsgWithFrequency(first, activityName, reserveResults, activityTime, a
|
|
|
}
|
|
|
fmt.Println("line 21", err, msg)
|
|
|
}()
|
|
|
- utils.FileLog.Info("%s", "services SendMsg")
|
|
|
- accessToken, err := models.GetWxAccessTokenByXzs()
|
|
|
- if err != nil {
|
|
|
- msg = "GetWxAccessToken Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if accessToken == "" {
|
|
|
- msg = "accessToken is empty"
|
|
|
- return
|
|
|
- }
|
|
|
+ //utils.FileLog.Info("%s", "services SendMsg")
|
|
|
+ //accessToken, err := models.GetWxAccessTokenByXzs()
|
|
|
+ //if err != nil {
|
|
|
+ // msg = "GetWxAccessToken Err:" + err.Error()
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //if accessToken == "" {
|
|
|
+ // msg = "accessToken is empty"
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
|
|
|
+ //templateId := utils.WxMsgTemplateIdActivityApplyXzs
|
|
|
+ //sendMap := make(map[string]interface{})
|
|
|
+ //sendData := make(map[string]interface{})
|
|
|
+ //sendMap["template_id"] = templateId
|
|
|
+ //sendMap["miniprogram"] = map[string]interface{}{"appid": utils.WxAppId, "pagepath": utils.WX_MSG_PATH_ACTIVITY_DETAIL + strconv.Itoa(activityId)}
|
|
|
+ ////sendData["first"] = map[string]interface{}{"value": first, "color": "#173177"}
|
|
|
+ //sendData["keyword1"] = map[string]interface{}{"value": activityName, "color": "#173177"}
|
|
|
+ //sendData["keyword2"] = map[string]interface{}{"value": keyword2, "color": "#173177"}
|
|
|
+ //sendData["remark"] = map[string]interface{}{"value": remark, "color": "#173177"}
|
|
|
+ //sendMap["data"] = sendData
|
|
|
+ //WxSendTemplateMsg(sendUrl, sendMap, openIdList, strconv.Itoa(activityId), utils.TEMPLATE_MSG_CYGX_ACTIVITY_ADD)
|
|
|
|
|
|
- sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
|
|
|
- templateId := utils.WxMsgTemplateIdActivityApplyXzs
|
|
|
- sendMap := make(map[string]interface{})
|
|
|
- sendData := make(map[string]interface{})
|
|
|
- sendMap["template_id"] = templateId
|
|
|
- sendMap["miniprogram"] = map[string]interface{}{"appid": utils.WxAppId, "pagepath": utils.WX_MSG_PATH_ACTIVITY_DETAIL + strconv.Itoa(activityId)}
|
|
|
- sendData["first"] = map[string]interface{}{"value": first, "color": "#173177"}
|
|
|
- sendData["keyword1"] = map[string]interface{}{"value": activityName, "color": "#173177"}
|
|
|
- sendData["keyword2"] = map[string]interface{}{"value": activityTime, "color": "#173177"}
|
|
|
- sendData["remark"] = map[string]interface{}{"value": remark, "color": "#173177"}
|
|
|
- sendMap["data"] = sendData
|
|
|
- WxSendTemplateMsg(sendUrl, sendMap, openIdList, strconv.Itoa(activityId), utils.TEMPLATE_MSG_CYGX_ACTIVITY_ADD)
|
|
|
+ redirectUrl := utils.WX_MSG_PATH_ACTIVITY_DETAIL + strconv.Itoa(activityId)
|
|
|
+ sendInfo := new(SendWxTemplate)
|
|
|
+
|
|
|
+ sendInfo.Keyword1 = activityName
|
|
|
+ sendInfo.Keyword2 = keyword2
|
|
|
+ openIdArr := make([]string, 0)
|
|
|
+ for _, v := range openIdList {
|
|
|
+ openIdArr = append(openIdArr, v.OpenId)
|
|
|
+ }
|
|
|
+ sendInfo.Remark = remark
|
|
|
+ sendInfo.TemplateId = utils.WxMsgTemplateIdAskMsgXzs
|
|
|
+ sendInfo.RedirectUrl = redirectUrl
|
|
|
+ sendInfo.RedirectTarget = 3
|
|
|
+ sendInfo.Resource = strconv.Itoa(activityId)
|
|
|
+ sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ACTIVITY_ADD
|
|
|
+ sendInfo.OpenIdArr = openIdArr
|
|
|
+ err = PublicSendTemplateMsg(sendInfo)
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -400,59 +418,24 @@ func SendActivityAskApplyTemplateMsgV2(keyword1, keyword2, keyword3, keyword4, r
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- var accessToken string
|
|
|
- if utils.RunMode == "release" {
|
|
|
- accessToken, err = models.GetWxAccessTokenByXzs()
|
|
|
- if err != nil {
|
|
|
- msg = "GetWxAccessToken Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if accessToken == "" {
|
|
|
- msg = "accessToken is empty"
|
|
|
- return
|
|
|
- }
|
|
|
- } else {
|
|
|
- accessToken, err = models.GetWxAccessToken()
|
|
|
- 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")
|
|
|
+ var redirectUrl string
|
|
|
+ redirectUrl = utils.WX_MSG_PATH_ACTIVITY_DETAIL + strconv.Itoa(activityId)
|
|
|
+ openIdArr := make([]string, 0)
|
|
|
+ openIdArr = append(openIdArr, itemOpenid.OpenId)
|
|
|
+ sendInfo := new(SendWxTemplate)
|
|
|
+ sendInfo.Keyword1 = keyword1
|
|
|
+ sendInfo.Keyword2 = keyword2
|
|
|
+ sendInfo.Keyword3 = keyword3
|
|
|
+ sendInfo.Keyword4 = keyword4
|
|
|
+ sendInfo.Remark = remark
|
|
|
+ sendInfo.TemplateId = utils.WxMsgTemplateIdApplyXzs
|
|
|
+ sendInfo.RedirectUrl = redirectUrl
|
|
|
+ sendInfo.RedirectTarget = 3
|
|
|
+ sendInfo.Resource = strconv.Itoa(activityId)
|
|
|
+ sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ACTIVITY_ADD
|
|
|
+ sendInfo.OpenIdArr = openIdArr
|
|
|
+ err = PublicSendTemplateMsg(sendInfo)
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -699,7 +682,7 @@ func SendCommentWxTemplateMsg(req models.AddCygxArticleCommentReq, user *models.
|
|
|
|
|
|
first = "【" + articleInfo.Title + "】有新的留言,请及时处理"
|
|
|
keyword1 = user.CompanyName + "——" + user.RealName + "(" + companyItem.SellerName + ")"
|
|
|
- keyword2 = "-"
|
|
|
+ keyword2 = "留言:" + articleInfo.Title
|
|
|
keyword3 = time.Now().Format(utils.FormatDateTime)
|
|
|
keyword4 = req.Content
|
|
|
remark = "点击查看报告详情"
|
|
@@ -736,35 +719,6 @@ func SendCommentWxTemplateMsg(req models.AddCygxArticleCommentReq, user *models.
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
- //accessToken, err := models.GetWxAccessTokenByXzs()
|
|
|
- //if err != nil {
|
|
|
- // msg = "GetWxAccessToken Err:" + err.Error()
|
|
|
- // return
|
|
|
- //}
|
|
|
- //if accessToken == "" {
|
|
|
- // msg = "accessToken is empty"
|
|
|
- // return
|
|
|
- //}
|
|
|
- //var first string
|
|
|
- //first = "【" + title + "】有新的留言,请及时处理"
|
|
|
- //keyword1 := companyName + "--" + userName + "(" + sellerName + ")"
|
|
|
- //keyword2 := "-"
|
|
|
- //keyword3 := createTime
|
|
|
- //keyword4 := content
|
|
|
- //sendUrl := "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken
|
|
|
- //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": utils.WX_MSG_PATH_ARTICLE_DETAIL + strconv.Itoa(articleId)}
|
|
|
- //sendData["first"] = map[string]interface{}{"value": first, "color": "#173177"}
|
|
|
- //sendData["keyword1"] = map[string]interface{}{"value": keyword1, "color": "#173177"}
|
|
|
- //sendData["keyword2"] = map[string]interface{}{"value": keyword2, "color": "#173177"}
|
|
|
- //sendData["keyword3"] = map[string]interface{}{"value": keyword3, "color": "#173177"}
|
|
|
- //sendData["keyword4"] = map[string]interface{}{"value": keyword4, "color": "#173177"}
|
|
|
- //sendMap["data"] = sendData
|
|
|
- //WxSendTemplateMsg(sendUrl, sendMap, openIdList, strconv.Itoa(articleId), utils.TEMPLATE_MSG_CYGX_COMMENT)
|
|
|
return
|
|
|
}
|
|
|
|