소스 검색

wip:活动id

wangshan 3 달 전
부모
커밋
0136621e49
2개의 변경된 파일14개의 추가작업 그리고 10개의 파일을 삭제
  1. 8 5
      handler/activity/lotteryDrawTask.go
  2. 6 5
      model/sse.go

+ 8 - 5
handler/activity/lotteryDrawTask.go

@@ -3,6 +3,7 @@ package activity
 import (
 	"app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/date"
+	"app.yhyue.com/moapp/jybase/encrypt"
 	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	"app.yhyue.com/moapp/message/db"
 	"app.yhyue.com/moapp/message/model"
@@ -12,6 +13,7 @@ import (
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gctx"
 	"regexp"
+	"strconv"
 	"time"
 )
 
@@ -226,10 +228,11 @@ func LotteryWinning(msg *model.Message) {
 	}
 	logger.Info("  sse  中奖信息通知:", msg)
 	util.SseBroadcast.SendToUsers(model.SseMessage{
-		Prize:  lb.PrizeName,
-		User:   userName,
-		State:  model.AllTarget,
-		Time:   time.Now().Format(date.Date_Full_Layout),
-		Remark: fmt.Sprintf("恭喜 %s 抽中 %s ", userName, lb.PrizeName),
+		Prize:    lb.PrizeName,
+		User:     userName,
+		State:    model.AllTarget,
+		Time:     time.Now().Format(date.Date_Full_Layout),
+		Remark:   fmt.Sprintf("恭喜 %s 抽中 %s ", userName, lb.PrizeName),
+		ActiveId: encrypt.SE.EncodeString(strconv.FormatInt(lb.ActiveId, 10)),
 	})
 }

+ 6 - 5
model/sse.go

@@ -6,9 +6,10 @@ const (
 
 // 消息结构体,用于传递 中奖信息
 type SseMessage struct {
-	Prize  string `json:"prize"`  //奖品信息 例如:腾讯视频会员周卡
-	User   string `json:"user"`   //中奖人信息 例如:157****0152
-	State  string `json:"state"`  // AllTarget
-	Time   string `json:"time"`   //
-	Remark string `json:"remark"` //
+	Prize    string `json:"prize"`     //奖品信息 例如:腾讯视频会员周卡
+	User     string `json:"user"`      //中奖人信息 例如:157****0152
+	State    string `json:"state"`     // AllTarget
+	Time     string `json:"time"`      //
+	Remark   string `json:"remark"`    //
+	ActiveId string `json:"active_id"` //加密后的活动id
 }