add send wx message

conf/wechat.conf

@@ -1 +1,6 @@
 messageTplID = EB1Bto8JmW-vC-A0NTe8NtxgMFm6s86l3g2Bc-1OP6U
+
+# 中奖ID
+luckdrawMessageTplID = 8t7WQTrx-D566ohRD6RgdMkiu8DUiAxG_Jajg33YHVI
+luckdrawNoticeURL = http://dev.ycjcjy.com/game/luckdraw/#/lotteryList?tab=1
+flashBuyNoticeURL = http://dev.ycjcjy.com/game/luckdraw/#/lotteryList?tab=2

controllers/config.go

@@ -41,4 +41,10 @@ func (c *BaseController) initConfig() {
 		c.Configer[SMSConf] = smsConf
 	}
 	utils.ResetSMSEngine(smsConf)
+
+	// 微信
+	wechatConf, _ := utils.GetConfiger("conf/wechat.conf")
+	if wechatConf != nil {
+		c.Configer[WeChatConf] = wechatConf
+	}
 }

controllers/flashbuy/flashbuy.go

@@ -137,6 +137,10 @@ func (c *FlashBuyController) Verify() {
 // FlashBuy 抢购
 func (c *FlashBuyController) FlashBuy() {
 	id := c.GetString(":id")
+
+	c.Context.Set("clienturl", c.Configer[controllers.WeChatConf].String("flashBuyNoticeURL"))
+	c.Context.Set("tplid", c.Configer[controllers.WeChatConf].String("luckdrawMessageTplID"))
+
 	err := c.dao.FlashBuy(id)
 	if err != nil {
 		c.ResponseError(err)

controllers/luckdraw/luckdraw.go

@@ -191,6 +191,9 @@ func (c *LuckDrawController) LuckDraw() {
 
 	user := userRaw.(model.TaCustomer)
 
+	c.Context.Set("clienturl", c.Configer[controllers.AppConf].String("luckdrawNoticeURL"))
+	c.Context.Set("tplid", c.Configer[controllers.WeChatConf].String("luckdrawMessageTplID"))
+
 	prize, detail, err := c.serv.LuckDraw(id, &user)
 	if err != nil {
 		c.ResponseError(err)

service/flashbuy/flashbuy.go

@@ -2,6 +2,7 @@ package flashbuy
 
 import (
 	"errors"
+	"fmt"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/flashbuy"
@@ -258,7 +259,7 @@ func (s *FlashBuyServ) FlashBuy(id string) error {
 	custQRCode := model.TaCustomerCourseQrcode{
 		CustomerCourseId: recored.CustomerFlashBuyId,
 		CustomerQrcode:   utils.GenerateQRCode(),
-		CreateDate:       time.Now(),
+		CreateDate:       time.Now().Local(),
 		Status:           models.STATUS_NORMAL,
 		QrcodeType:       models.QRCODE_TYPE_FLASH,
 	}
@@ -268,6 +269,40 @@ func (s *FlashBuyServ) FlashBuy(id string) error {
 		return errors.New("写入中奖二维码失败")
 	}
 
+	// 推送微信消息
+	userMap := s.ctx.Get("userMap").(model.TaUserMapping)
+	userCases := s.ctx.Get("cases").([]model.SysUserCase)
+	clienturl := s.ctx.Get("clienturl").(string)
+	tplID := s.ctx.Get("tplid").(string)
+
+	var caseName string
+	if userCases != nil && len(userCases) > 0 {
+		for _, cs := range userCases {
+			if cs.CaseId == recored.CaseId {
+				caseName = cs.CaseName
+				break
+			}
+		}
+	}
+
+	remarkTpl := "请在%s日前, 前往%s兑换"
+
+	message := utils.Message{
+		To: utils.ClientID{ID: userMap.Openid},
+		Data: map[string]interface{}{
+			"orgid": recored.OrgId,
+			"tplid": tplID,
+			"link":  clienturl,
+			"data": map[string]string{
+				"first":    "抢券成功提醒",
+				"keyword1": flashbuy.FlashBuyName,
+				"keyword2": time.Now().Local().Format("2006-01-02"),
+				"remark":   fmt.Sprintf(remarkTpl, recored.ValidateEnd.Format("2006-01-02"), caseName),
+			},
+		},
+	}
+	go utils.SendWechat(message)
+
 	return nil
 }
 

service/luckdraw/luckdraw.go

@@ -2,6 +2,7 @@ package luckdraw
 
 import (
 	"errors"
+	"fmt"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/luckdraw"
@@ -328,6 +329,40 @@ func (s *LuckdrawServ) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuc
 		return nil, nil, errors.New("写入中奖二维码失败")
 	}
 
+	// 推送微信消息
+	userMap := s.ctx.Get("userMap").(model.TaUserMapping)
+	userCases := s.ctx.Get("cases").([]model.SysUserCase)
+	clienturl := s.ctx.Get("clienturl").(string)
+	tplID := s.ctx.Get("tplid").(string)
+
+	var caseName string
+	if userCases != nil && len(userCases) > 0 {
+		for _, cs := range userCases {
+			if cs.CaseId == recored.CaseId {
+				caseName = cs.CaseName
+				break
+			}
+		}
+	}
+
+	remarkTpl := "请在%s日前, 前往%s兑换"
+
+	message := utils.Message{
+		To: utils.ClientID{ID: userMap.Openid},
+		Data: map[string]interface{}{
+			"orgid": recored.OrgId,
+			"tplid": tplID,
+			"link":  clienturl,
+			"data": map[string]string{
+				"first":    "抢券成功提醒",
+				"keyword1": prize.PrizeName,
+				"keyword2": time.Now().Local().Format("2006-01-02"),
+				"remark":   fmt.Sprintf(remarkTpl, recored.VerificationEnd.Format("2006-01-02"), caseName),
+			},
+		},
+	}
+	go utils.SendWechat(message)
+
 	return prize, prizeDetail, nil
 }
 

utils/message.go

@@ -2,6 +2,7 @@ package utils
 
 import (
 	"github.com/zjxpcyc/websocket"
+	"github.com/zjxpcyc/wechat/wx"
 )
 
 // ClientID 消息对象
@@ -29,17 +30,37 @@ func SendWs(message Message) {
 		Data: message.Data,
 	}
 
-	LogError("发送 Websocket 消息: ", msg)
-
 	websocket.Send(msg)
 }
 
+func SendWechat(message Message) {
+	dt := message.Data.(map[string]interface{})
+	org := dt["orgid"].(string)
+	tplID := dt["tplid"].(string)
+	tplLink := dt["link"].(string)
+	tplData := dt["data"].(map[string]string)
+
+	var data map[string]wx.TplMessageData
+	if tplData != nil {
+		data = make(map[string]wx.TplMessageData)
+		for k, v := range tplData {
+			data[k] = wx.TplMessageData{Value: v}
+		}
+	}
+
+	err := WxClientFor(org).SendTplMessage(message.To.ID, tplID, tplLink, data)
+	if err != nil {
+		LogError("推送微信消息失败: ", err)
+	}
+}
+
 // SendMessage 发送消息
 func SendMessage(message Message, msgType string) {
 	switch msgType {
 	case WsMessage:
 		SendWs(message)
 	case WechatMessage:
+
 	case SMSMessage:
 	default:
 	}