677 lines
18 KiB
Go
677 lines
18 KiB
Go
package model
|
||
|
||
import (
|
||
"fmt"
|
||
"mh-server/common"
|
||
"mh-server/config"
|
||
"mh-server/lib/requests"
|
||
"strconv"
|
||
"sync"
|
||
"time"
|
||
|
||
"github.com/codinl/go-logger"
|
||
"github.com/pkg/errors"
|
||
)
|
||
|
||
const (
|
||
WxPublicAppId = "wxfdb1c5654f681c7e"
|
||
WxPublicAppSecret = "6e1908a71f31a80849ef0e59d90b7147"
|
||
)
|
||
|
||
var mutexLock = new(sync.Mutex)
|
||
|
||
func AccessToken() (string, error) {
|
||
response := struct {
|
||
AccessToken string `json:"access_token"`
|
||
ExpiresIn uint32 `json:"expires_in"`
|
||
Errcode uint32 `json:"errcode"`
|
||
Errmsg string `json:"errmsg"`
|
||
}{}
|
||
|
||
//config.AppConfig.WxAppId = "wxfdb1c5654f681c7e"
|
||
//config.AppConfig.WxAppSecret = "6e1908a71f31a80849ef0e59d90b7147"
|
||
//config.AppConfig.WxAppId = "wx806c079463b5b56c"
|
||
//config.AppConfig.WxAppSecret = "cb125688bf4e482f66e8c46062d568fc"
|
||
|
||
//fmt.Println("WxAppId:", config.AppConfig.WxAppId)
|
||
//fmt.Println("WxAppSecret:", config.AppConfig.WxAppSecret)
|
||
fmt.Println("WxAppId:", WxPublicAppId)
|
||
fmt.Println("WxAppSecret:", WxPublicAppSecret)
|
||
if err := requests.GetAndParseJson("https://api.weixin.qq.com/cgi-bin/token", map[string]string{
|
||
"grant_type": "client_credential",
|
||
"appId": WxPublicAppId,
|
||
"secret": WxPublicAppSecret,
|
||
}, &response); err != nil {
|
||
logger.Error(err)
|
||
return "", err
|
||
}
|
||
|
||
if response.Errcode != 0 {
|
||
logger.Error(response.Errcode, "===", response.Errmsg)
|
||
return "", errors.New(response.Errmsg)
|
||
}
|
||
|
||
logger.Infof("response=%+v", response)
|
||
|
||
return response.AccessToken, nil
|
||
}
|
||
|
||
func AppAccessToken() (string, error) {
|
||
response := struct {
|
||
AccessToken string `json:"access_token"`
|
||
ExpiresIn uint32 `json:"expires_in"`
|
||
Errcode uint32 `json:"errcode"`
|
||
Errmsg string `json:"errmsg"`
|
||
}{}
|
||
|
||
//config.AppConfig.WxAppId = "wxfdb1c5654f681c7e"
|
||
//config.AppConfig.WxAppSecret = "6e1908a71f31a80849ef0e59d90b7147"
|
||
config.AppConfig.WxAppId = "wx806c079463b5b56c"
|
||
config.AppConfig.WxAppSecret = "cb125688bf4e482f66e8c46062d568fc"
|
||
|
||
//fmt.Println("WxAppId:", config.AppConfig.WxAppId)
|
||
//fmt.Println("WxAppSecret:", config.AppConfig.WxAppSecret)
|
||
fmt.Println("WxAppId:", config.AppConfig.WxAppId)
|
||
fmt.Println("WxAppSecret:", config.AppConfig.WxAppSecret)
|
||
if err := requests.GetAndParseJson("https://api.weixin.qq.com/cgi-bin/token", map[string]string{
|
||
"grant_type": "client_credential",
|
||
"appId": config.AppConfig.WxAppId,
|
||
"secret": config.AppConfig.WxAppSecret,
|
||
}, &response); err != nil {
|
||
logger.Error(err)
|
||
return "", err
|
||
}
|
||
|
||
if response.Errcode != 0 {
|
||
logger.Error(response.Errcode, "===", response.Errmsg)
|
||
return "", errors.New(response.Errmsg)
|
||
}
|
||
|
||
logger.Infof("response=%+v", response)
|
||
|
||
return response.AccessToken, nil
|
||
}
|
||
|
||
// 获取 AccessToken 统一使用该方法,避免各自获取导致AccessToken 失效
|
||
func GetAccessToken() (string, error) {
|
||
fmt.Println("获取AccessToken1:")
|
||
accessToken := ""
|
||
var (
|
||
err error
|
||
tokenConfig Config
|
||
)
|
||
//mutexLock.Lock()
|
||
//defer mutexLock.Unlock()
|
||
if err := NewConfigQuerySet(DB).NameEq(common.CONFIG_Access_Token).One(&tokenConfig); err != nil && err != RecordNotFound {
|
||
logger.Error(err)
|
||
return "", nil
|
||
}
|
||
logger.Error("查询accessToken:", tokenConfig.Value)
|
||
accessToken = tokenConfig.Value
|
||
if tokenConfig.UpdatedAt.Before(time.Unix(time.Now().Unix()-int64(7200), 0)) || tokenConfig.Value == "" {
|
||
|
||
i := 0
|
||
tryTimes := 5
|
||
for ; i < tryTimes; i++ {
|
||
accessToken, err = AccessToken()
|
||
if err != nil {
|
||
logger.Error("GetAccessToken Fail...err=", err)
|
||
time.Sleep(time.Second * 2 * time.Duration(i))
|
||
continue
|
||
}
|
||
fmt.Println("accessToken:", accessToken)
|
||
if accessToken != "" {
|
||
logger.Info(accessToken)
|
||
break
|
||
}
|
||
}
|
||
|
||
if i >= tryTimes {
|
||
logger.Error("GetAccessToken Fail...")
|
||
return "", err
|
||
}
|
||
|
||
err = NewConfigQuerySet(DB).NameEq(common.CONFIG_Access_Token).GetUpdater().SetValue(accessToken).Update()
|
||
if err != nil {
|
||
logger.Error(err)
|
||
return "", err
|
||
}
|
||
}
|
||
fmt.Println("获取AccessToken3:")
|
||
return accessToken, nil
|
||
}
|
||
|
||
// 获取 AccessToken 统一使用该方法,避免各自获取导致AccessToken 失效
|
||
func AppGetAccessToken() (string, error) {
|
||
fmt.Println("获取AccessToken1:")
|
||
accessToken := ""
|
||
var (
|
||
err error
|
||
tokenConfig Config
|
||
)
|
||
//mutexLock.Lock()
|
||
//defer mutexLock.Unlock()
|
||
if err := NewConfigQuerySet(DB).NameEq(common.AppConfigAccessToken).One(&tokenConfig); err != nil && err != RecordNotFound {
|
||
logger.Error(err)
|
||
return "", nil
|
||
}
|
||
logger.Error("查询accessToken:", tokenConfig.Value)
|
||
accessToken = tokenConfig.Value
|
||
if tokenConfig.UpdatedAt.Before(time.Unix(time.Now().Unix()-int64(7200), 0)) || tokenConfig.Value == "" {
|
||
|
||
i := 0
|
||
tryTimes := 5
|
||
for ; i < tryTimes; i++ {
|
||
accessToken, err = AppAccessToken()
|
||
if err != nil {
|
||
logger.Error("GetAccessToken Fail...err=", err)
|
||
time.Sleep(time.Second * 2 * time.Duration(i))
|
||
continue
|
||
}
|
||
fmt.Println("accessToken:", accessToken)
|
||
if accessToken != "" {
|
||
logger.Info(accessToken)
|
||
break
|
||
}
|
||
}
|
||
|
||
if i >= tryTimes {
|
||
logger.Error("GetAccessToken Fail...")
|
||
return "", err
|
||
}
|
||
|
||
err = NewConfigQuerySet(DB).NameEq(common.AppConfigAccessToken).GetUpdater().SetValue(accessToken).Update()
|
||
if err != nil {
|
||
logger.Error(err)
|
||
return "", err
|
||
}
|
||
}
|
||
fmt.Println("获取AccessToken3:")
|
||
return accessToken, nil
|
||
}
|
||
|
||
// 获取 AccessToken 方法
|
||
func GenAccessToken() (string, error) {
|
||
accessToken := ""
|
||
var err error
|
||
i := 0
|
||
tryTimes := 5
|
||
for ; i < tryTimes; i++ {
|
||
accessToken, err = AccessToken()
|
||
if err != nil {
|
||
logger.Error("GetAccessToken Fail...err=", err)
|
||
time.Sleep(time.Second * 2 * time.Duration(i))
|
||
continue
|
||
}
|
||
if accessToken != "" {
|
||
logger.Info(accessToken)
|
||
break
|
||
}
|
||
}
|
||
|
||
if i >= tryTimes {
|
||
logger.Error("GetAccessToken Fail...")
|
||
return "", err
|
||
}
|
||
|
||
return accessToken, nil
|
||
}
|
||
|
||
type templeteMsgResponse struct {
|
||
Errcode int `json:"errcode"`
|
||
Errmsg string `json:"errmsg"`
|
||
TemplateID string `json:"template_id"`
|
||
}
|
||
|
||
// 传的字符串直接在手机上显示
|
||
// 中奖结果通知
|
||
// treasureName 奖品名称
|
||
// exchangeUsername 兑换者姓名
|
||
// exchangeTime 兑换时间
|
||
// treasureIssueCode 中奖编码
|
||
// result 开奖结果
|
||
//func PushPrizeResult(accessToken string, treasureName, exchangeUsername, exchangeTime, treasureIssueCode,
|
||
// result string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": treasureName,
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": exchangeUsername,
|
||
// },
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": exchangeTime,
|
||
// },
|
||
// "keyword5": map[string]interface{}{
|
||
// "value": treasureIssueCode,
|
||
// },
|
||
// "keyword6": map[string]interface{}{
|
||
// "value": result,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Prize_Result_Notify, userForm.FormId,
|
||
// "", "keyword1.DATA", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//// 物流状态提醒
|
||
//// trackingNo 运单号
|
||
//// adName 联系人
|
||
//// prizeName 奖品名称
|
||
//// user_prize 发货时间
|
||
//func PushLogistics(accessToken, trackingNo, adName, prizeName, userPrizeTime string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
// data := map[string]interface{}{
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": trackingNo,
|
||
// },
|
||
// "keyword5": map[string]interface{}{
|
||
// "value": adName,
|
||
// },
|
||
// "keyword7": map[string]interface{}{
|
||
// "value": prizeName,
|
||
// },
|
||
// "keyword9": map[string]interface{}{
|
||
// "value": userPrizeTime,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// go func() {
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Logistics_Notify, userForm.FormId,
|
||
// "", "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//// 客服回复通知
|
||
//// customName 客服姓名
|
||
//// respTime 回复时间
|
||
//// respContent 回复内容
|
||
//// info 温馨提示
|
||
//func PushCustomResponse(accessToken, customName, respTime, respContent, info string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": customName,
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": respTime,
|
||
// },
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": respContent,
|
||
// },
|
||
// "keyword4": map[string]interface{}{
|
||
// "value": info,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// go func() {
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Custom_Response_Notify, userForm.FormId,
|
||
// "", "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//// 签到提醒
|
||
//// signName 签到名称
|
||
//// signInfo 提醒内容
|
||
//// signCount 签到次数
|
||
//// signAward 今日签到
|
||
//// 签到名称 每日签到
|
||
//// 签到排名 第2名，共234人参与
|
||
//// 提醒内容 叮！该签到啦~锲而不舍,金石可镂。
|
||
//// 签到次数 第2次啦，加油嘞！
|
||
//// 今日签到 200积分
|
||
//func PushCheckin(accessToken string, checkinName, checkinInfo, checkinCount, checkinAward string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": checkinName,
|
||
// },
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": checkinInfo,
|
||
// },
|
||
// "keyword4": map[string]interface{}{
|
||
// "value": checkinCount,
|
||
// },
|
||
// "keyword6": map[string]interface{}{
|
||
// "value": checkinAward,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userFormId := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userFormId) == nil {
|
||
//
|
||
// openID := user.WxOpenID
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Checkin_Notify, userFormId.FormId,
|
||
// "", "", data); err != nil {
|
||
// logger.Error(err)
|
||
// continue
|
||
// }
|
||
//
|
||
// userFormId.Used = true
|
||
// _ = userFormId.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//// 日程提醒
|
||
//// scheduleTopic 日程主题
|
||
//// scheduleTime 日程时间
|
||
//// desc 任务描述
|
||
//func PushSchedule(accessToken string, scheduleTopic, scheduleTime, desc string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": scheduleTopic,
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": scheduleTime,
|
||
// },
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": desc,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// go func() {
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Schedule_Notify, userForm.FormId,
|
||
// "", "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//// 订单发货提醒
|
||
//// billCreatedAt 购买时间
|
||
//// prizeName 物品名称
|
||
//// user_prize 发货时间
|
||
//func PushUserGoodSend(accessToken string, billCreatedAt, prizeName, userPrize string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": billCreatedAt,
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": prizeName,
|
||
// },
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": userPrize,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// go func() {
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_UserPrize_Send_Notify, userForm.FormId,
|
||
// "", "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//func PushLotteryResult(accessToken string, did, lotteryPrizeName, SponsorName string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": lotteryPrizeName,
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": SponsorName,
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// go func() {
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Lottery_Result_Notify, userForm.FormId,
|
||
// fmt.Sprintf("pages/lottery/awardDetail/awardDetail?id=%s", did), "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//func PushStockRefresh(accessToken string, prizeName string, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": prizeName,
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": "收到你的喇叭喊话, 库存更新了",
|
||
// },
|
||
// "keyword3": map[string]interface{}{
|
||
// "value": "散步拿奖, 免费兑换奖品",
|
||
// },
|
||
// "keyword4": map[string]interface{}{
|
||
// "value": "快去看看, 慢了可能就抢光了~",
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// openID := user.WxOpenID
|
||
// go func() {
|
||
// if err := PushTemplate(openID, accessToken, common.TemplateID_Stock_Refresh_Notify, userForm.FormId,
|
||
// "", "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
//
|
||
//func PushInviteLotteryResult(accessToken string, id uint32, uid ...uint32) error {
|
||
// if len(uid) == 0 {
|
||
// return errors.New("userList is Empty !")
|
||
// }
|
||
//
|
||
// var users []User
|
||
// if err := NewUserQuerySet(DB).UidIn(uid...).All(&users); err != nil {
|
||
// logger.Error(err)
|
||
// return err
|
||
// }
|
||
//
|
||
// data := map[string]interface{}{
|
||
// "keyword1": map[string]interface{}{
|
||
// "value": "1~50元话费",
|
||
// },
|
||
// "keyword2": map[string]interface{}{
|
||
// "value": "官方发起的抽奖正在开奖, 点击查看中奖结果",
|
||
// },
|
||
// }
|
||
//
|
||
// for _, user := range users {
|
||
// userForm := new(UserFormId)
|
||
// if NewUserFormIdQuerySet(DB).UidEq(user.Uid).OrderAscByID().UsedEq(false).
|
||
// CreatedAtGt(time.Now().AddDate(0, 0, -6)).One(userForm) == nil {
|
||
// go func() {
|
||
// if err := PushTemplate(user.WxOpenID, accessToken, common.TemplateID_Lottery_Result_Notify, userForm.FormId,
|
||
// fmt.Sprintf("pages/lottery/awardDetail/awardDetail?id=%d&t=1", id), "", data); err != nil {
|
||
// logger.Error(err)
|
||
// }
|
||
// }()
|
||
// userForm.Used = true
|
||
// go userForm.Update(DB, UserFormIdDBSchema.Used)
|
||
// }
|
||
// }
|
||
//
|
||
// return nil
|
||
//}
|
||
|
||
func PushTemplate(openID, accessToken, templateID, formID, page, emphasisKeyword string, data map[string]interface{}) error {
|
||
params := map[string]interface{}{
|
||
"touser": openID, // openID
|
||
"template_id": templateID, // 模板消息ID
|
||
"form_id": formID,
|
||
"data": data,
|
||
}
|
||
|
||
if page != "" {
|
||
params["page"] = page // 点击模板卡片后的跳转页面, 示例index?foo=bar
|
||
}
|
||
|
||
if emphasisKeyword != "" {
|
||
params["emphasis_keyword"] = emphasisKeyword // 要放大的词, 示例: keyword1.DATA
|
||
}
|
||
|
||
var response templeteMsgResponse
|
||
if err := requests.PostAndParseJson(fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/message/wxopen/"+
|
||
"template/send?access_token=%s", accessToken), params, requests.JSON, &response); err != nil {
|
||
logger.Error(err)
|
||
return err
|
||
}
|
||
|
||
if response.Errcode != 0 {
|
||
return errors.New(strconv.Itoa(response.Errcode) + "===" + response.Errmsg)
|
||
}
|
||
|
||
return nil
|
||
}
|