兑换礼包记录

model/jyb.go

@@ -279,3 +279,16 @@ func Code2Id(code string) (uint64, error) {
 	}
 	return id, nil
 }
+
+type JybItem struct {
+	Id  int32 `json:"id"`
+	Num int32 `json:"num"`
+}
+
+type JybLog struct {
+	Ts    int64      `json:"ts"`
+	SnId  int32      `json:"snid"`
+	Tp    int32      `json:"tp"`   // 礼包类型 1:通用礼包 2:专属礼包
+	Name  string     `json:"name"` // 礼包名称
+	Award []*JybItem `json:"award"`
+}

mq/keyconf.go

@@ -15,6 +15,7 @@ const (
 	BackSystemPermitExchange = "back_permitexchange"
 	BackSystemPermitJoin     = "back_permitjoin"
 	BackSystemPermitTask     = "back_permittask"
+	BackSystemJyb            = "back_jyblog"
 )
 
 // dbproxy 消息

worldsrv/bagmgr.go

@@ -592,27 +592,45 @@ func (this *BagMgr) VerifyUpJybInfo(p *Player, args *model.VerifyUpJybInfoArgs)
 						p.dirty = true
 					}
 				}
+				jybLog := &model.JybLog{
+					Ts:   time.Now().Unix(),
+					SnId: p.SnId,
+					Tp:   jyb.CodeType,
+					Name: jyb.Name,
+				}
 				for _, v := range jyb.Award.Item {
 					//if _, code := BagMgrSingleton.UpBagInfo(p.SnId, p.Platform, v.ItemId, v.ItemNum); code == bag.OpResultCode_OPRC_Sucess { // 需修改
 					pack.GainItem.ItemId = append(pack.GainItem.ItemId, &playerproto.ItemInfo{
 						ItemId:  v.ItemId,
 						ItemNum: v.ItemNum,
 					})
+					jybLog.Award = append(jybLog.Award, &model.JybItem{
+						Id:  v.ItemId,
+						Num: int32(v.ItemNum),
+					})
 				}
 				if jyb.Award.Coin > 0 {
 					p.AddCoin(jyb.Award.Coin, 0, common.GainWay_ActJybAward, "system", "礼包码兑换")
 					if !p.IsRob {
 						LogChannelSingleton.WriteMQData(model.GenerateSystemFreeGive(p.SnId, p.Name, p.Platform, p.Channel, model.SystemFreeGive_GiveType_ActJybAward, model.SystemFreeGive_CoinType_Coin, int64(jyb.Award.Coin)))
 					}
+					jybLog.Award = append(jybLog.Award, &model.JybItem{
+						Id:  common.ItemIDCoin,
+						Num: int32(jyb.Award.Coin),
+					})
 				}
 				if jyb.Award.Diamond > 0 {
 					p.AddDiamond(jyb.Award.Diamond, 0, common.GainWay_ActJybAward, "system", "礼包码兑换")
 					if !p.IsRob {
 						LogChannelSingleton.WriteMQData(model.GenerateSystemFreeGive(p.SnId, p.Name, p.Platform, p.Channel, model.SystemFreeGive_GiveType_ActJybAward, model.SystemFreeGive_CoinType_Diamond, int64(jyb.Award.Diamond)))
 					}
+					jybLog.Award = append(jybLog.Award, &model.JybItem{
+						Id:  common.ItemIDDiamond,
+						Num: int32(jyb.Award.Coin),
+					})
 				}
 				// 领取日志
-
+				LogChannelSingleton.WriteLog(jybLog)
 				p.dirty = true
 				pack.GainItem.Coin = jyb.Award.Coin
 				pack.GainItem.Diamond = jyb.Award.Diamond

worldsrv/logchannel.go

@@ -70,4 +70,5 @@ func init() {
 	LogChannelSingleton.RegisterLogCName(mq.BackSystemPermitJoin, &model.BackendPermitJoin{})
 	LogChannelSingleton.RegisterLogCName(mq.BackSystemPermitTask, &model.BackendPermitTask{})
 	LogChannelSingleton.RegisterLogCName(mq.BackClientLog, &model.ClientLogMysql{})
+	LogChannelSingleton.RegisterLogCName(mq.BackSystemJyb, &model.JybLog{})
 }