|
|
package msg_handler
|
|
|
|
|
|
import (
|
|
|
"encoding/json"
|
|
|
"git.noahlan.cn/northlan/ntools-go/kafka"
|
|
|
"live-gateway/config"
|
|
|
"live-gateway/pb/mq"
|
|
|
pbVars "live-gateway/pb/vars"
|
|
|
kfk "live-gateway/pkg/kafka"
|
|
|
"strconv"
|
|
|
)
|
|
|
|
|
|
type (
|
|
|
SendGift struct {
|
|
|
Action string `json:"action"` // 动作,投喂等
|
|
|
BatchComboId string `json:"batch_combo_id"` // 礼物连击ID
|
|
|
BatchComboSend interface{} `json:"batch_combo_send"` // ???
|
|
|
BeatId string `json:"beatId"` // ???
|
|
|
BizSource string `json:"biz_source"` // ?? :live
|
|
|
BlindGift *BlindGift `json:"blind_gift"` // ??
|
|
|
BroadcastId int `json:"broadcast_id"` // 广播ID ??
|
|
|
CoinType string `json:"coin_type"` // 瓜子类型, gold金瓜子 silver银瓜子(免费礼物)
|
|
|
ComboResourcesId int `json:"combo_resources_id"` // ???
|
|
|
ComboSend interface{} `json:"combo_send"` // ???
|
|
|
ComboStayTime int `json:"combo_stay_time"` // 连击停留时间??? 秒?
|
|
|
ComboTotalCoin int `json:"combo_total_coin"` // 连击总币数???
|
|
|
CritProb int `json:"crit_prob"` // ???
|
|
|
Demarcation int `json:"demarcation"` // ???: 1
|
|
|
DiscountPrice int `json:"discount_price"` // 折扣价???
|
|
|
DMScore int `json:"dmscore"` // 活动积分，普通道具为0
|
|
|
Draw int `json:"draw"` // ???
|
|
|
Effect int `json:"effect"` // ???
|
|
|
EffectBlock int `json:"effect_block"` // ???
|
|
|
Face string `json:"face"` // 头像?
|
|
|
GiftId int64 `json:"giftId"` // 礼物ID
|
|
|
GiftName string `json:"giftName"` // 礼物名称
|
|
|
GiftType int `json:"giftType"` // 礼物类型 普通，弹幕，活动
|
|
|
Gold int `json:"gold"` // 用户剩余金瓜子
|
|
|
GuardLevel int `json:"guard_level"` // 舰队等级
|
|
|
IsFirst bool `json:"is_first"` // 是否首次投喂?
|
|
|
IsSpecialBatch int `json:"is_special_batch"` // ???
|
|
|
Magnification int `json:"magnification"` // 是否放大???
|
|
|
MedalInfo FansMedal `json:"medal_info"` // 佩戴勋章的主播信息
|
|
|
NameColor string `json:"name_color"` // 名 颜色
|
|
|
Num int64 `json:"num"` // 数量
|
|
|
OriginalGiftName string `json:"original_gift_name"` // 原始礼物名称???
|
|
|
Price int64 `json:"price"` // 价格? 但不是电池
|
|
|
RCost int `json:"rcost"` // ???
|
|
|
Remain int `json:"remain"` // 用户道具包裹剩余数量
|
|
|
Rnd string `json:"rnd"` // 随机数?
|
|
|
SendMaster interface{} `json:"send_master"` // ???
|
|
|
Silver int `json:"silver"` // 用户剩余银瓜子
|
|
|
Super int `json:"super"` // ???
|
|
|
SuperBatchGiftNum int `json:"super_batch_gift_num"` // ???
|
|
|
SuperGiftNum int `json:"super_gift_num"` // ???
|
|
|
SvgaBlock int `json:"svga_block"` // ???
|
|
|
TagImage string `json:"tag_image"` // ???
|
|
|
Timestamp int64 `json:"timestamp"` // 赠送时间
|
|
|
TopList interface{} `json:"top_list"` // ???
|
|
|
TotalCoin int `json:"total_coin"` // 总值 瓜子数
|
|
|
Uid int64 `json:"uid"` // 用户ID
|
|
|
Uname string `json:"uname"` // 用户名
|
|
|
}
|
|
|
// BlindGift 宝箱类礼物
|
|
|
BlindGift struct {
|
|
|
BlindGiftConfigId int64 `json:"blind_gift_config_id"` // id
|
|
|
From int64 `json:"from"` // ??
|
|
|
GiftAction string `json:"gift_action"` // 爆出/投喂
|
|
|
OriginalGiftId int64 `json:"original_gift_id"` // 原始礼物ID
|
|
|
OriginalGiftName string `json:"original_gift_name"` // 原始礼物名
|
|
|
}
|
|
|
)
|
|
|
|
|
|
type SendGiftHandler struct {
|
|
|
producer *kafka.Producer
|
|
|
liveRoomId int64
|
|
|
}
|
|
|
|
|
|
func NewSendGiftHandler(liveRoomId int64) *SendGiftHandler {
|
|
|
cfg := config.Config.Kafka.Gift
|
|
|
return &SendGiftHandler{
|
|
|
producer: kafka.NewKafkaProducer(kfk.DefaultProducerConfig, cfg.Addr, cfg.Topic),
|
|
|
liveRoomId: liveRoomId,
|
|
|
}
|
|
|
}
|
|
|
|
|
|
func (h *SendGiftHandler) CMD() string {
|
|
|
return "SEND_GIFT"
|
|
|
}
|
|
|
|
|
|
func (h *SendGiftHandler) HandlerMessage(data []byte) {
|
|
|
var baseMsg struct {
|
|
|
CMD string `json:"cmd"`
|
|
|
Data *SendGift `json:"data"`
|
|
|
}
|
|
|
if err := json.Unmarshal(data, &baseMsg); err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
//logger.SLog.Infof("%s %s礼物 %s x%d", baseMsg.Data.Uname, baseMsg.Data.Action, baseMsg.Data.GiftName, baseMsg.Data.Num)
|
|
|
|
|
|
dmMsg := &pbMq.MqGift{
|
|
|
Platform: pbVars.Platform_name[int32(pbVars.Platform_Bilibili)],
|
|
|
LiveRoomId: h.liveRoomId,
|
|
|
MsgId: "",
|
|
|
Timestamp: baseMsg.Data.Timestamp,
|
|
|
Uid: baseMsg.Data.Uid,
|
|
|
Uname: baseMsg.Data.Uname,
|
|
|
Avatar: baseMsg.Data.Face,
|
|
|
NobilityLevel: int64(baseMsg.Data.GuardLevel),
|
|
|
GiftId: baseMsg.Data.GiftId,
|
|
|
GiftName: baseMsg.Data.GiftName,
|
|
|
GiftNum: baseMsg.Data.Num,
|
|
|
Price: baseMsg.Data.Price,
|
|
|
IsPaid: IsPaidGift(baseMsg.Data.CoinType),
|
|
|
Type: pbMq.MqGift_NORMAL,
|
|
|
PackGift: nil,
|
|
|
|
|
|
FansMedalWearingStatus: baseMsg.Data.MedalInfo.AnchorRoomId == h.liveRoomId,
|
|
|
FansMedalName: baseMsg.Data.MedalInfo.MedalName,
|
|
|
FansMedalLevel: baseMsg.Data.MedalInfo.MedalLevel,
|
|
|
}
|
|
|
// type - pack
|
|
|
if baseMsg.Data.BlindGift != nil {
|
|
|
dmMsg.Type = pbMq.MqGift_PACK
|
|
|
dmMsg.PackGift = &pbMq.MqGift_PackGift{
|
|
|
GiftId: baseMsg.Data.BlindGift.OriginalGiftId,
|
|
|
GiftName: baseMsg.Data.BlindGift.OriginalGiftName,
|
|
|
}
|
|
|
}
|
|
|
|
|
|
_ = h.producer.SendMessageAsync(dmMsg, strconv.FormatInt(dmMsg.Uid, 10))
|
|
|
}
|