fix:更改微信配置

controllers/wechat.go

@@ -6,6 +6,7 @@ import (
 	"eta/eta_mini_bridge/services"
 	"eta/eta_mini_bridge/services/alarm_msg"
 	"eta/eta_mini_bridge/utils"
+	"fmt"
 	"html"
 	"strconv"
 )
@@ -164,6 +165,11 @@ func (this *WeChatController) SendTemplateMsg() {
 	sendData["keyword2"] = map[string]interface{}{"value": report.Title, "color": "#173177"}
 	sendData["keyword3"] = map[string]interface{}{"value": report.PublishTime, "color": "#173177"}
 	sendData["keyword4"] = map[string]interface{}{"value": report.Abstract, "color": "#173177"}
+	// 推送模板消息
+	go func(sendData map[string]interface{}, items []*services.OpenIdList, sendType, reportId int) {
+		fmt.Println("推送模板消息:", reportId)
+		_ = services.SendMultiTemplateMsg(sendData, openIds, 1, reportId)
+	}(sendData, openIds, 1, reportId)
 	err = services.SendMultiTemplateMsg(sendData, openIds, 1, reportId)
 	if err != nil {
 		br.Msg = "发送失败"

services/template_msg.go

@@ -143,9 +143,6 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 		return
 	}
 
-	var WxAppId = `wxb059c872d79b9967` // 研报小程序appid
-	// var WxAppId = `wx9b5d7291e581233a`
-	// var WxAppSecret = `1737c73e9f69a21de1a345b8f0800258`
 	var wxAppPath string
 	if utils.RunMode == "debug" {
 		wxAppPath = fmt.Sprintf("pages-question/answerDetail?id=%d", 3800)
@@ -156,7 +153,7 @@ func SendMultiTemplateMsg(sendData map[string]interface{}, items []*OpenIdList,
 	for _, item := range items {
 		sendMap["template_id"] = utils.TEMPLATE_ID_BY_PRODUCT
 		sendMap["miniprogram"] = map[string]interface{}{
-			"appid":    WxAppId,
+			"appid":    utils.WX_MINI_APPID,
 			"pagepath": wxAppPath,
 		}
 		sendMap["touser"] = item.OpenId

services/wechat.go

@@ -22,8 +22,8 @@ func GetWxChat() (officialAccount *officialaccount.OfficialAccount) {
 	wc := wechat.NewWechat()
 	memory := cache.NewMemory()
 	conf := &config.Config{
-		AppID:          utils.WX_APPID,
-		AppSecret:      utils.WX_APP_SECRET,
+		AppID:          utils.DW_WX_APPID,
+		AppSecret:      utils.DW_WX_APP_SECRET,
 		Token:          "",
 		EncodingAESKey: "",
 		Cache:          memory,
@@ -42,7 +42,7 @@ func (wechat WechatAccessToken) GetAccessToken() (accessToken string, err error)
 	}
 
 	// 缓存中没有取到数据，那么就需要强制刷新的accessToken
-	tmpAccessToken, expires, tmpErr := getTokenFromServer(utils.WX_APPID, utils.WX_APP_SECRET)
+	tmpAccessToken, expires, tmpErr := getTokenFromServer(utils.DW_WX_APPID, utils.DW_WX_APP_SECRET)
 	if tmpAccessToken == "" {
 		err = errors.New("获取微信token失败，Err:" + tmpErr.Error())
 		return

utils/config.go

@@ -40,14 +40,12 @@ var AlarmMsgUrl string
 
 // 微信相关
 var (
-	WX_MINI_APPID          string
+	WX_MINI_APPID          string // 小程序appid
 	WX_MINI_APP_SECRET     string
 	DW_WX_Id               string //微信原始ID
-	DW_WX_APPID            string
+	DW_WX_APPID            string // 东吴公众号的appid
 	DW_WX_APP_SECRET       string
-	TEMPLATE_ID_BY_PRODUCT string
-	WX_APPID               string // 弘则投研测试公众号
-	WX_APP_SECRET          string
+	TEMPLATE_ID_BY_PRODUCT string // 模板id
 )
 
 // ES配置
@@ -102,14 +100,6 @@ func init() {
 	DW_WX_APP_SECRET = config["dw_wx_app_secret"]
 	TEMPLATE_ID_BY_PRODUCT = config["template_id_by_product"]
 
-	// 测试微信配置
-	// WX_APPID = config["wx_appid"]
-	// WX_APP_SECRET = config["wx_app_secret"]
-	// 仅测试
-	TEMPLATE_ID_BY_PRODUCT = `-YjuPOB7Fqd-S3ilabYa6wvjDY9aXmeEfPN6DCiy-EY`
-	WX_APPID = "wx9b5d7291e581233a" // 投研公众号
-	WX_APP_SECRET = "f4d52e34021eee262dce9682b31f8861"
-	AlarmMsgUrl = "http://127.0.0.1:8606/api/alarm/send"
 	// redis缓存配置
 	REDIS_CACHE = config["beego_cache"]
 	if len(REDIS_CACHE) <= 0 {