From b344f1b9837b369c84ca17e6db17c4011ea8f5a4 Mon Sep 17 00:00:00 2001 From: meixiongfeng <766881921@qq.com> Date: Fri, 10 Nov 2023 10:27:32 +0800 Subject: [PATCH] =?UTF-8?q?=E9=81=93=E5=85=B7=E8=8E=B7=E5=BE=97=E6=B6=88?= =?UTF-8?q?=E8=80=97=E6=9D=A5=E6=BA=90=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/achieve/api_award.go | 5 +++++ modules/activity/api_getreward.go | 4 ++++ modules/caninerabbit/api_award.go | 4 ++++ modules/capturesheep/api_allweekreward.go | 3 +++ modules/capturesheep/api_over.go | 4 ++++ modules/capturesheep/api_weekreward.go | 4 ++++ modules/caravan/api_getreward.go | 4 ++++ modules/catchbugs/api_award.go | 4 ++++ modules/dailytask/api_receive.go | 4 ++++ modules/dcolor/api_award.go | 4 ++++ modules/dragon/api_train.go | 1 + modules/egghunt/api_award.go | 3 +++ modules/entertainment/api_boxreward.go | 4 ++++ modules/entertainment/api_getreward.go | 4 ++++ modules/entertainment/room.go | 3 +++ modules/equipment/api_sellI.go | 3 +++ modules/equipment/module.go | 7 +++++++ modules/growtask/api_advreceive.go | 4 ++++ modules/growtask/api_receive.go | 4 ++++ modules/hero/api_drawCard.go | 4 ++++ modules/hero/api_peachreward.go | 4 ++++ modules/hero/model_hero.go | 15 ++++++++++----- modules/hunting/api_challengeover.go | 1 + modules/island/api_complete.go | 4 ++++ modules/island/api_receive.go | 4 ++++ modules/items/api_buyphysical.go | 3 +++ modules/items/api_decompose.go | 4 ++++ modules/items/api_sellItem.go | 3 +++ modules/items/modelitems.go | 4 ++++ modules/items/module.go | 3 +++ modules/jielong/api_reward.go | 4 ++++ modules/library/api_getstoryreward.go | 4 ++++ modules/library/api_lvreward.go | 3 +++ modules/mail/api_getAttachment.go | 3 +++ modules/mainline/api_booschallengeover.go | 4 +++- modules/mainline/api_challengeover.go | 1 + modules/mainline/api_levelpass.go | 1 + modules/mainline/api_receiveaward.go | 4 ++++ modules/mainline/api_shopbuy.go | 1 + modules/mainline/api_taskchaptereward.go | 4 ++++ modules/mainline/api_taskreceive.go | 4 ++++ modules/modulebase.go | 1 - modules/pagoda/api_getReward.go | 3 +++ modules/pagoda/api_racechallengeover.go | 1 + modules/parkour/api_allweekreward.go | 3 +++ modules/user/api_create.go | 2 ++ 46 files changed, 158 insertions(+), 7 deletions(-) diff --git a/modules/achieve/api_award.go b/modules/achieve/api_award.go index 5b37e30fb..81f0eaa7c 100644 --- a/modules/achieve/api_award.go +++ b/modules/achieve/api_award.go @@ -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 } diff --git a/modules/activity/api_getreward.go b/modules/activity/api_getreward.go index 1a01df89a..3580181cf 100644 --- a/modules/activity/api_getreward.go +++ b/modules/activity/api_getreward.go @@ -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 } diff --git a/modules/caninerabbit/api_award.go b/modules/caninerabbit/api_award.go index a5fffc3da..01dd7781c 100644 --- a/modules/caninerabbit/api_award.go +++ b/modules/caninerabbit/api_award.go @@ -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 } diff --git a/modules/capturesheep/api_allweekreward.go b/modules/capturesheep/api_allweekreward.go index 2007be53c..00922c0fa 100644 --- a/modules/capturesheep/api_allweekreward.go +++ b/modules/capturesheep/api_allweekreward.go @@ -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 } diff --git a/modules/capturesheep/api_over.go b/modules/capturesheep/api_over.go index 85ea08966..b9c73a72b 100644 --- a/modules/capturesheep/api_over.go +++ b/modules/capturesheep/api_over.go @@ -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 } diff --git a/modules/capturesheep/api_weekreward.go b/modules/capturesheep/api_weekreward.go index 07514ae2f..b6b13a4ff 100644 --- a/modules/capturesheep/api_weekreward.go +++ b/modules/capturesheep/api_weekreward.go @@ -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 } diff --git a/modules/caravan/api_getreward.go b/modules/caravan/api_getreward.go index fcd829d53..2403abad2 100644 --- a/modules/caravan/api_getreward.go +++ b/modules/caravan/api_getreward.go @@ -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 } diff --git a/modules/catchbugs/api_award.go b/modules/catchbugs/api_award.go index 21b6cc244..493550e23 100644 --- a/modules/catchbugs/api_award.go +++ b/modules/catchbugs/api_award.go @@ -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 } diff --git a/modules/dailytask/api_receive.go b/modules/dailytask/api_receive.go index 2245e79d1..5abff5d9a 100644 --- a/modules/dailytask/api_receive.go +++ b/modules/dailytask/api_receive.go @@ -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 } diff --git a/modules/dcolor/api_award.go b/modules/dcolor/api_award.go index a7f9a9fa8..05cf45609 100644 --- a/modules/dcolor/api_award.go +++ b/modules/dcolor/api_award.go @@ -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 } diff --git a/modules/dragon/api_train.go b/modules/dragon/api_train.go index 1694aac10..94e259bec 100644 --- a/modules/dragon/api_train.go +++ b/modules/dragon/api_train.go @@ -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 diff --git a/modules/egghunt/api_award.go b/modules/egghunt/api_award.go index 14196fdd1..8525d6766 100644 --- a/modules/egghunt/api_award.go +++ b/modules/egghunt/api_award.go @@ -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 } diff --git a/modules/entertainment/api_boxreward.go b/modules/entertainment/api_boxreward.go index 8f6e8dbe8..173b1a11e 100644 --- a/modules/entertainment/api_boxreward.go +++ b/modules/entertainment/api_boxreward.go @@ -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 } diff --git a/modules/entertainment/api_getreward.go b/modules/entertainment/api_getreward.go index 8ce54a9f6..f6ac5ddf8 100644 --- a/modules/entertainment/api_getreward.go +++ b/modules/entertainment/api_getreward.go @@ -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 } diff --git a/modules/entertainment/room.go b/modules/entertainment/room.go index f77512152..463a26f16 100644 --- a/modules/entertainment/room.go +++ b/modules/entertainment/room.go @@ -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() } } diff --git a/modules/equipment/api_sellI.go b/modules/equipment/api_sellI.go index ed06bf06a..25328c012 100644 --- a/modules/equipment/api_sellI.go +++ b/modules/equipment/api_sellI.go @@ -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 } diff --git a/modules/equipment/module.go b/modules/equipment/module.go index 81fdb4493..5dd3d3d8e 100644 --- a/modules/equipment/module.go +++ b/modules/equipment/module.go @@ -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 } diff --git a/modules/growtask/api_advreceive.go b/modules/growtask/api_advreceive.go index 18ed34e57..06b47697f 100644 --- a/modules/growtask/api_advreceive.go +++ b/modules/growtask/api_advreceive.go @@ -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 } diff --git a/modules/growtask/api_receive.go b/modules/growtask/api_receive.go index 8e12d19f7..47e2a572c 100644 --- a/modules/growtask/api_receive.go +++ b/modules/growtask/api_receive.go @@ -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 } diff --git a/modules/hero/api_drawCard.go b/modules/hero/api_drawCard.go index 3fec93fce..452c839ad 100644 --- a/modules/hero/api_drawCard.go +++ b/modules/hero/api_drawCard.go @@ -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 } diff --git a/modules/hero/api_peachreward.go b/modules/hero/api_peachreward.go index 3acacf663..3292a1c0c 100644 --- a/modules/hero/api_peachreward.go +++ b/modules/hero/api_peachreward.go @@ -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 } diff --git a/modules/hero/model_hero.go b/modules/hero/model_hero.go index 0f65a0383..1ec97099c 100644 --- a/modules/hero/model_hero.go +++ b/modules/hero/model_hero.go @@ -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) { + var reward []*cfg.Gameatn + for _, heroId := range szCards { - var reward []*cfg.Gameatn 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}) - } + } + 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 } diff --git a/modules/hunting/api_challengeover.go b/modules/hunting/api_challengeover.go index 7ea1ece99..879deb9f7 100644 --- a/modules/hunting/api_challengeover.go +++ b/modules/hunting/api_challengeover.go @@ -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 } diff --git a/modules/island/api_complete.go b/modules/island/api_complete.go index a5c5b1d52..8842c8fa4 100644 --- a/modules/island/api_complete.go +++ b/modules/island/api_complete.go @@ -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 } diff --git a/modules/island/api_receive.go b/modules/island/api_receive.go index 92e857443..1f57c1ae8 100644 --- a/modules/island/api_receive.go +++ b/modules/island/api_receive.go @@ -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 } diff --git a/modules/items/api_buyphysical.go b/modules/items/api_buyphysical.go index c16f2ad3c..9b47daebf 100644 --- a/modules/items/api_buyphysical.go +++ b/modules/items/api_buyphysical.go @@ -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 } diff --git a/modules/items/api_decompose.go b/modules/items/api_decompose.go index efd6115c3..52cee4667 100644 --- a/modules/items/api_decompose.go +++ b/modules/items/api_decompose.go @@ -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 } diff --git a/modules/items/api_sellItem.go b/modules/items/api_sellItem.go index 7cef37568..aa1d75553 100644 --- a/modules/items/api_sellItem.go +++ b/modules/items/api_sellItem.go @@ -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 } diff --git a/modules/items/modelitems.go b/modules/items/modelitems.go index 2af9842ac..8a3fd4691 100644 --- a/modules/items/modelitems.go +++ b/modules/items/modelitems.go @@ -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 } diff --git a/modules/items/module.go b/modules/items/module.go index f2ada41ce..057451d6e 100644 --- a/modules/items/module.go +++ b/modules/items/module.go @@ -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 } diff --git a/modules/jielong/api_reward.go b/modules/jielong/api_reward.go index ca9345fb4..c456987cb 100644 --- a/modules/jielong/api_reward.go +++ b/modules/jielong/api_reward.go @@ -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 } diff --git a/modules/library/api_getstoryreward.go b/modules/library/api_getstoryreward.go index 8900fa800..2dc620d2d 100644 --- a/modules/library/api_getstoryreward.go +++ b/modules/library/api_getstoryreward.go @@ -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 } diff --git a/modules/library/api_lvreward.go b/modules/library/api_lvreward.go index 7b6e66e5f..9da7a3a1b 100644 --- a/modules/library/api_lvreward.go +++ b/modules/library/api_lvreward.go @@ -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 } diff --git a/modules/mail/api_getAttachment.go b/modules/mail/api_getAttachment.go index 015f19c26..519b0e1c2 100644 --- a/modules/mail/api_getAttachment.go +++ b/modules/mail/api_getAttachment.go @@ -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 } diff --git a/modules/mainline/api_booschallengeover.go b/modules/mainline/api_booschallengeover.go index a0daa091c..4514cc182 100644 --- a/modules/mainline/api_booschallengeover.go +++ b/modules/mainline/api_booschallengeover.go @@ -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 } diff --git a/modules/mainline/api_challengeover.go b/modules/mainline/api_challengeover.go index edfbf9035..299ac0029 100644 --- a/modules/mainline/api_challengeover.go +++ b/modules/mainline/api_challengeover.go @@ -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 } diff --git a/modules/mainline/api_levelpass.go b/modules/mainline/api_levelpass.go index a1e14fb3a..1e5061b43 100644 --- a/modules/mainline/api_levelpass.go +++ b/modules/mainline/api_levelpass.go @@ -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 } diff --git a/modules/mainline/api_receiveaward.go b/modules/mainline/api_receiveaward.go index 4316e0766..29d3bc0aa 100644 --- a/modules/mainline/api_receiveaward.go +++ b/modules/mainline/api_receiveaward.go @@ -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 } diff --git a/modules/mainline/api_shopbuy.go b/modules/mainline/api_shopbuy.go index c19a8e8a8..6f4cf1270 100644 --- a/modules/mainline/api_shopbuy.go +++ b/modules/mainline/api_shopbuy.go @@ -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 } diff --git a/modules/mainline/api_taskchaptereward.go b/modules/mainline/api_taskchaptereward.go index 4d11867ba..7ea542d47 100644 --- a/modules/mainline/api_taskchaptereward.go +++ b/modules/mainline/api_taskchaptereward.go @@ -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 } diff --git a/modules/mainline/api_taskreceive.go b/modules/mainline/api_taskreceive.go index d6771949b..4a16d08a8 100644 --- a/modules/mainline/api_taskreceive.go +++ b/modules/mainline/api_taskreceive.go @@ -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 } diff --git a/modules/modulebase.go b/modules/modulebase.go index f92e9d02b..902f427d1 100644 --- a/modules/modulebase.go +++ b/modules/modulebase.go @@ -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 } diff --git a/modules/pagoda/api_getReward.go b/modules/pagoda/api_getReward.go index 7784a13ec..767cae9a1 100644 --- a/modules/pagoda/api_getReward.go +++ b/modules/pagoda/api_getReward.go @@ -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 } diff --git a/modules/pagoda/api_racechallengeover.go b/modules/pagoda/api_racechallengeover.go index 686f1e65e..8fb03bf05 100644 --- a/modules/pagoda/api_racechallengeover.go +++ b/modules/pagoda/api_racechallengeover.go @@ -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 } diff --git a/modules/parkour/api_allweekreward.go b/modules/parkour/api_allweekreward.go index 9c5c96c70..af7aff417 100644 --- a/modules/parkour/api_allweekreward.go +++ b/modules/parkour/api_allweekreward.go @@ -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 } diff --git a/modules/user/api_create.go b/modules/user/api_create.go index c4072aba7..a418ca3d6 100644 --- a/modules/user/api_create.go +++ b/modules/user/api_create.go @@ -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 }