liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

道具获得消耗来源记录

Browse Source
This commit is contained in:
meixiongfeng 2023-11-10 10:27:32 +08:00
parent 7201854d7c
commit b344f1b983
46 changed files with 158 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
modules/achieve/api_award.go
View File

@ -73,10 +73,15 @@ func (this *apiComp) Award(session comm.IUserSession, req *pb.AchieveAwardReq) (
if errdata, atno = this.module.DispenseAtno(session, conf.TaskReward, true); errdata != nil {
return
}
info.Receive[req.Id] = true
this.module.model.Change(session.GetUserId(), map[string]interface{}{
"receive": info.Receive,
})
session.SendMsg(string(this.module.GetType()), "award", &pb.AchieveAwardResp{Id: req.Id, Award: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "AchieveAwardReq", conf.TaskReward)
})
return
}

4
modules/activity/api_getreward.go
View File

@ -96,5 +96,9 @@ func (this *apiComp) GetReward(session comm.IUserSession, req *pb.ActivityGetRew
Data: data,
Atno: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "ActivityGetRewardReq", reward)
})
return
}

4
modules/caninerabbit/api_award.go
View File

@ -61,5 +61,9 @@ func (this *apiComp) Award(session comm.IUserSession, req *pb.CanineRabbitAwardR
"award": info.Award,
})
session.SendMsg(string(this.module.GetType()), "award", &pb.CanineRabbitAwardResp{Type: req.Type, Awardmap: info.Award, Award: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CanineRabbitAwardReq", res)
})
return
}

3
modules/capturesheep/api_allweekreward.go
View File

@ -70,5 +70,8 @@ func (this *apiComp) AllWeekReward(session comm.IUserSession, req *pb.Captureshe
return
}
session.SendMsg(string(this.module.GetType()), "allweekreward", &pb.CapturesheepAllWeekRewardResp{Weekreward: info.Weekreward, Award: award})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CapturesheepAllWeekRewardReq", award)
})
return
}

4
modules/capturesheep/api_over.go
View File

@ -132,5 +132,9 @@ func (this *apiComp) Over(session comm.IUserSession, req *pb.CapturesheepOverReq
Dan: info.Dan,
Award: award,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CapturesheepOverReq", award)
})
return
}

4
modules/capturesheep/api_weekreward.go
View File

@ -72,5 +72,9 @@ func (this *apiComp) WeekReward(session comm.IUserSession, req *pb.CapturesheepW
return
}
session.SendMsg(string(this.module.GetType()), "weekreward", &pb.CapturesheepWeekRewardResp{Id: req.Id, Award: award})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CapturesheepWeekRewardReq", award)
})
return
}

4
modules/caravan/api_getreward.go
View File

@ -97,5 +97,9 @@ func (this *apiComp) GetReward(session comm.IUserSession, req *pb.CaravanGetRewa
Reward: caravan.Reward,
Anto: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CaravanGetRewardReq", atno)
})
return
}

4
modules/catchbugs/api_award.go
View File

@ -52,5 +52,9 @@ func (this *apiComp) Award(session comm.IUserSession, req *pb.CatchbugsAwardReq)
"award": info.Awards,
})
session.SendMsg(string(this.module.GetType()), "award", &pb.CatchbugsAwardResp{Awardmap: info.Awards, Award: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CatchbugsAwardReq", atno)
})
return
}

4
modules/dailytask/api_receive.go
View File

@ -56,5 +56,9 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.DailytaskReceive
return
}
session.SendMsg(string(this.module.GetType()), "receive", &pb.DailytaskReceiveResp{Award: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "DailytaskReceiveReq", atno)
})
return
}

4
modules/dcolor/api_award.go
View File

@ -79,5 +79,9 @@ func (this *apiComp) Award(session comm.IUserSession, req *pb.DColorAwardReq) (e
"weektime": info.Weektime,
})
session.SendMsg(string(this.module.GetType()), "award", &pb.DColorAwardResp{Atype: req.Atype, Award: atno, Awardmap: awards})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "DColorAwardReq", atno)
})
return
}

1
modules/dragon/api_train.go
View File

@ -170,6 +170,7 @@ func (this *apiComp) Train(session comm.IUserSession, req *pb.DragonTrainReq) (e
if curLv > preLv { // 升级后统计任务
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, comm.GetBuriedParam(comm.Rtype235, dragon.Lv, utils.ToInt32(dragon.Dragonid)))
this.module.WriteUserLog(session.GetUserId(), "DragonTrainReq", atno)
})
}
return

3
modules/egghunt/api_award.go
View File

@ -33,5 +33,8 @@ func (this *apiComp) Award(session comm.IUserSession, req *pb.EgghuntAwardReq) (
}
session.SendMsg(string(this.module.GetType()), "info", &pb.EgghuntAwardResp{Id: req.Id, Award: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "EgghuntAwardReq", atno)
})
return
}

4
modules/entertainment/api_boxreward.go
View File

@ -86,5 +86,9 @@ func (this *apiComp) BoxReward(session comm.IUserSession, req *pb.EntertainBoxRe
Box: list.Box,
Reward: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "EntertainBoxRewardReq", atno)
})
return
}

4
modules/entertainment/api_getreward.go
View File

@ -64,5 +64,9 @@ func (this *apiComp) Reward(session comm.IUserSession, req *pb.EntertainRewardRe
Data: list,
Reward: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "EntertainRewardReq", atno)
})
return
}

3
modules/entertainment/room.go
View File

@ -581,6 +581,9 @@ func (this *Room) GameOver() (errdata *pb.ErrorData) {
if errdata, atno = this.module.DispenseAtno(this.szSession[winindex], res, true); errdata != nil {
return
}
go this.module.AsynHandleSession(this.szSession[winindex], func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "xxlGame", atno)
})
this.szSession[winindex].Push()
}
}

3
modules/equipment/api_sellI.go
View File

@ -109,5 +109,8 @@ func (this *apiComp) Sell(session comm.IUserSession, req *pb.EquipmentSellReq) (
return
}
session.SendMsg(string(this.module.GetType()), "sell", &pb.EquipmentSellResp{IsSucc: true, Reward: reward})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "EquipmentSellReq", reward)
})
return
}

7
modules/equipment/module.go
View File

@ -416,6 +416,10 @@ func (this *Equipment) SellEquipments(session comm.IUserSession, equs []string)
if errdata = this.DelEquipments(session, equs, true); errdata != nil {
return
}
go func() {
this.WriteUserLog(session.GetUserId(), "SellEquipments", atno)
}()
return
}
@ -510,6 +514,9 @@ func (this *Equipment) RecycleEquipments(session comm.IUserSession, equs []strin
if errdata = this.DelEquipments(session, equs, true); errdata != nil {
return
}
go func() {
this.WriteUserLog(session.GetUserId(), "RecycleEquipments", atno)
}()
return
}

4
modules/growtask/api_advreceive.go
View File

@ -114,5 +114,9 @@ func (this *apiComp) Advreceive(session comm.IUserSession, req *pb.GrowtaskAdvRe
TaskType: req.TaskType,
Reward: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "GrowtaskAdvReceiveReq", atno)
})
return
}

4
modules/growtask/api_receive.go
View File

@ -75,5 +75,9 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.GrowtaskReceiveR
TaskId: req.TaskId,
Reward: reward,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "GrowtaskReceiveReq", reward)
})
return
}

4
modules/hero/api_drawCard.go
View File

@ -370,5 +370,9 @@ func (this *apiComp) DrawCard(session comm.IUserSession, req *pb.HeroDrawCardReq
session.SendMsg(string(this.module.GetType()), DrawCard, rsp)
// 任务统计
this.module.SendTaskMsg(session, szStar, req.DrawCount, req.DrawType)
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "HeroDrawCardReq", atno)
})
return
}

4
modules/hero/api_peachreward.go
View File

@ -98,5 +98,9 @@ func (this *apiComp) PeachReward(session comm.IUserSession, req *pb.HeroPeachRew
}
rsp.Peach = heroRecord.Peach
session.SendMsg(string(this.module.GetType()), HeroPeachRewardReq, rsp)
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "HeroPeachRewardReq", reward)
})
return
}

9
modules/hero/model_hero.go
View File

@ -933,8 +933,9 @@ func (this *ModelHero) CheckDrawCardRes(session comm.IUserSession, drawConf *cfg
}
func (this *ModelHero) GetDrawCardReward(session comm.IUserSession, szCards []string) (wish *pb.UserAtno, szStar []int32, rsp []*pb.AtnoData, errdata *pb.ErrorData) {
for _, heroId := range szCards {
var reward []*cfg.Gameatn
for _, heroId := range szCards {
if c, err := this.module.configure.GetHeroConfig(heroId); err != nil {
szStar = append(szStar, c.Star) // 获得许愿石
var tmp *cfg.Gameatn
@ -962,10 +963,14 @@ func (this *ModelHero) GetDrawCardReward(session comm.IUserSession, szCards []st
T: heroId,
N: 1,
})
}
var atno []*pb.UserAtno
if errdata, atno = this.module.DispenseAtno(session, reward, true); errdata == nil {
rsp = append(rsp, &pb.AtnoData{Atno: atno})
}
}
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "GetDrawCardReward", rsp)
})
return
}

1
modules/hunting/api_challengeover.go
View File

@ -204,6 +204,7 @@ func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.HuntingCha
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype200, 1))
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
this.module.WriteUserLog(session.GetUserId(), "HuntingChallengeOverReq", szAtno)
})
return
}

4
modules/island/api_complete.go
View File

@ -91,5 +91,9 @@ func (this *apiComp) Complete(session comm.IUserSession, req *pb.IsLandCompleteR
"islands": info.Islands,
})
session.SendMsg(string(this.module.GetType()), "complete", &pb.IsLandCompleteResp{Level: req.Level, Award: award})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "IsLandCompleteReq", award)
})
return
}

4
modules/island/api_receive.go
View File

@ -68,5 +68,9 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.IsLandReceiveReq
"payprogress": info.Payprogress,
})
session.SendMsg(string(this.module.GetType()), "receive", &pb.IsLandReceiveResp{Info: info, Award: award})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "IsLandReceiveReq", award)
})
return
}

3
modules/items/api_buyphysical.go
View File

@ -108,5 +108,8 @@ func (this *apiComp) BuyPhysical(session comm.IUserSession, req *pb.ItemsBuyPhys
"physicalbuyLasttime": user.PhysicalbuyLasttime,
})
session.SendMsg(string(this.module.GetType()), "buyphysical", &pb.ItemsBuyPhysicalResp{Issucc: true, PhysicalBuyNum: user.Physicalbuynum, Asets: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "ItemsBuyPhysicalReq", atno)
})
return
}

4
modules/items/api_decompose.go
View File

@ -90,5 +90,9 @@ func (this *apiComp) Decompose(session comm.IUserSession, req *pb.ItemsDecompose
return
}
session.SendMsg(string(this.module.GetType()), "decompose", &pb.ItemsDecomposeResp{GridId: req.GridId, Amount: req.Amount, Issucc: true, Asets: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "ItemsDecomposeReq", atno)
})
return
}

3
modules/items/api_sellItem.go
View File

@ -72,5 +72,8 @@ func (this *apiComp) SellItem(session comm.IUserSession, req *pb.ItemsSellItemRe
return
}
session.SendMsg(string(this.module.GetType()), "sellitem", &pb.ItemsSellItemResp{GridId: req.GridId, Amount: req.Amount, Issucc: true, Asets: atno})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "ItemsSellItemReq", atno)
})
return
}

4
modules/items/modelitems.go
View File

@ -820,5 +820,9 @@ func (this *ModelItemsComp) useitem(session comm.IUserSession, gid string, amoun
}
return
}
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "useitem", atno)
})
return
}

3
modules/items/module.go
View File

@ -364,6 +364,9 @@ func (this *Items) SellItem(session comm.IUserSession, items map[string]int32, b
if len(change) > 0 && bPush {
this.itemsChangePush(session, change) //推送道具背包变化
}
go this.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.WriteUserLog(session.GetUserId(), "SellItem", atno)
})
return
}

4
modules/jielong/api_reward.go
View File

@ -90,5 +90,9 @@ func (this *apiComp) Reward(session comm.IUserSession, req *pb.JielongRewardReq)
Data: list,
Res: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "JielongRewardReq", atno)
})
return
}

4
modules/library/api_getstoryreward.go
View File

@ -106,5 +106,9 @@ func (this *apiComp) GetStoryReward(session comm.IUserSession, req *pb.LibraryGe
Data: _heroFetter,
Reward: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "LibraryGetStoryRewardReq", atno)
})
return
}

3
modules/library/api_lvreward.go
View File

@ -72,5 +72,8 @@ func (this *apiComp) LvReward(session comm.IUserSession, req *pb.LibraryLvReward
Data: _heroFetter,
Reward: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "LibraryLvRewardReq", atno)
})
return
}

3
modules/mail/api_getAttachment.go
View File

@ -119,5 +119,8 @@ func (this *apiComp) GetAllMailAttachment(session comm.IUserSession, req *pb.Mai
Reward: atno,
Ids: mailIds,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "MailGetAllMailAttachmentReq", atno)
})
return
}

4
modules/mainline/api_booschallengeover.go
View File

@ -86,6 +86,8 @@ func (this *apiComp) BoosChallengeOver(session comm.IUserSession, req *pb.Mainli
Boosid: req.Boosid,
Reward: aeward,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "MainlineBoosChallengeOverReq", aeward)
})
return
}

1
modules/mainline/api_challengeover.go
View File

@ -193,6 +193,7 @@ func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.MainlineCh
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
this.module.ModuleSys.CheckOpenCond(session, comm.OpencondTypeMaxmapid, req.Level)
this.module.WriteUserLog(session.GetUserId(), "MainlineChallengeOverReq", reward)
})
return
}

1
modules/mainline/api_levelpass.go
View File

@ -137,6 +137,7 @@ func (this *apiComp) LevelPass(session comm.IUserSession, req *pb.MainlineLevelP
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
this.module.WriteUserLog(session.GetUserId(), "MainlineLevelPassReq", aeward)
})
return
}

4
modules/mainline/api_receiveaward.go
View File

@ -154,5 +154,9 @@ func (this *apiComp) ReceiveAward(session comm.IUserSession, req *pb.MainlineRec
Stage: req.Stage,
Reward: reward,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "MainlineReceiveAwardReq", reward)
})
return
}

1
modules/mainline/api_shopbuy.go
View File

@ -92,6 +92,7 @@ func (this *apiComp) ShopBuy(session comm.IUserSession, req *pb.MainlineShopBuyR
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
this.module.WriteUserLog(session.GetUserId(), "MainlineShopBuyReq", atno)
})
return
}

4
modules/mainline/api_taskchaptereward.go
View File

@ -94,5 +94,9 @@ func (this *apiComp) TaskChapteReward(session comm.IUserSession, req *pb.Mainlin
Task: dtask,
Award: award,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "MainlineTaskChapteRewardReq", award)
})
return
}

4
modules/mainline/api_taskreceive.go
View File

@ -76,5 +76,9 @@ func (this *apiComp) TaskReceive(session comm.IUserSession, req *pb.MainlineTask
"tasks": dtask.Tasks,
})
session.SendMsg(string(this.module.GetType()), "taskreceive", &pb.MainlineTaskReceiveResp{Id: req.Id, Award: award})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "MainlineTaskReceiveReq", award)
})
return
}

1
modules/modulebase.go
View File

@ -902,7 +902,6 @@ func (this *ModuleBase) DispenseAtno(session comm.IUserSession, res []*cfg.Gamea
this.Debugf("发放三消卡片资源资源: %v errdata: %v", xxl, errdata)
}
this.WriteUserLog(session.GetUserId(), "userlog", res)
return
}

3
modules/pagoda/api_getReward.go
View File

@ -67,6 +67,9 @@ func (this *apiComp) GetReward(session comm.IUserSession, req *pb.PagodaGetRewar
Data: pagoda,
Atno: atno,
})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "PagodaGetRewardReq", atno)
})
}
return
}

1
modules/pagoda/api_racechallengeover.go
View File

@ -188,6 +188,7 @@ func (this *apiComp) ChallengeRaceOver(session comm.IUserSession, req *pb.Pagoda
}
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
this.module.WriteUserLog(session.GetUserId(), "PagodaChallengeRaceOverReq", atno)
})
return
}

3
modules/parkour/api_allweekreward.go
View File

@ -70,5 +70,8 @@ func (this *apiComp) AllWeekReward(session comm.IUserSession, req *pb.ParkourAll
return
}
session.SendMsg(string(this.module.GetType()), "allweekreward", &pb.CapturesheepAllWeekRewardResp{Weekreward: info.Weekreward, Award: award})
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.WriteUserLog(session.GetUserId(), "CapturesheepAllWeekRewardReq", award)
})
return
}

2
modules/user/api_create.go
View File

@ -122,6 +122,8 @@ func (this *apiComp) Create(session comm.IUserSession, req *pb.UserCreateReq) (e
if len(tasks) > 0 {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
}
this.module.WriteUserLog(session.GetUserId(), "UserCreateReq", res)
})
return
}