diff --git a/modules/parkour/api_weekreward.go b/modules/parkour/api_weekreward.go index 7c961056b..6a5c8f8a6 100644 --- a/modules/parkour/api_weekreward.go +++ b/modules/parkour/api_weekreward.go @@ -73,5 +73,8 @@ func (this *apiComp) WeekReward(session comm.IUserSession, req *pb.ParkourWeekRe 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/parkour/module.go b/modules/parkour/module.go index 0e0346e29..4c80e54e8 100644 --- a/modules/parkour/module.go +++ b/modules/parkour/module.go @@ -581,6 +581,9 @@ func (this *Parkour) overtimer(task *timewheel.Task, args ...interface{}) { }, Award: award[v.GetUserId()], }) + go this.AsynHandleSession(v, func(session comm.IUserSession) { + this.WriteUserLog(session.GetUserId(), "ParkourRaceOverPush", award[v.GetUserId()]) + }) sessions = append(sessions, v) } diff --git a/modules/practice/api_getgymbuff.go b/modules/practice/api_getgymbuff.go index d12b56511..666c45483 100644 --- a/modules/practice/api_getgymbuff.go +++ b/modules/practice/api_getgymbuff.go @@ -64,6 +64,7 @@ func (this *apiComp) GetGymBuff(session comm.IUserSession, req *pb.PracticeGetGy session.SendMsg(string(this.module.GetType()), "getgymbuff", &pb.PracticeGetGymBuffResp{Buffid: buff.Id, Award: award}) go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "PracticeGetGymBuffReq", award) }) return } diff --git a/modules/practice/api_npcbattklefinish.go b/modules/practice/api_npcbattklefinish.go index 02fca9f75..1ba699499 100644 --- a/modules/practice/api_npcbattklefinish.go +++ b/modules/practice/api_npcbattklefinish.go @@ -91,6 +91,7 @@ func (this *apiComp) NPCBattkleFinish(session comm.IUserSession, req *pb.Practic go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "PracticeNPCBattkleFinishReq", award) }) return } diff --git a/modules/practice/api_receive.go b/modules/practice/api_receive.go index 0dcd7610f..944748b15 100644 --- a/modules/practice/api_receive.go +++ b/modules/practice/api_receive.go @@ -305,6 +305,7 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.PracticeReceiveR go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "PracticeReceiveReq", award) }) return } diff --git a/modules/privilege/api_buygift.go b/modules/privilege/api_buygift.go index 0b1d7367c..da54a4bbc 100644 --- a/modules/privilege/api_buygift.go +++ b/modules/privilege/api_buygift.go @@ -86,5 +86,9 @@ func (this *apiComp) BuyGift(session comm.IUserSession, req *pb.PrivilegeBuyGift Data: vip, Res: atno, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "PrivilegeBuyGiftReq", atno) + }) return } diff --git a/modules/shop/api_buy.go b/modules/shop/api_buy.go index 3cec53178..f6f8be261 100644 --- a/modules/shop/api_buy.go +++ b/modules/shop/api_buy.go @@ -238,6 +238,7 @@ func (this *apiComp) Buy(session comm.IUserSession, req *pb.ShopBuyReq) (errdata if len(tasks) > 0 { go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "ShopBuyResq", award) }) } return diff --git a/modules/shopcenter/api_receive.go b/modules/shopcenter/api_receive.go index bca17ff4a..59266e779 100644 --- a/modules/shopcenter/api_receive.go +++ b/modules/shopcenter/api_receive.go @@ -168,5 +168,8 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.ShopCenterReceiv } } session.SendMsg(string(this.module.GetType()), "receive", &pb.ShopCenterReceiveResp{Fid: req.Fid, Pid: req.Pid, Award: award}) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "ShopCenterReceiveReq", award) + }) return } diff --git a/modules/smithy/api_atlasaward.go b/modules/smithy/api_atlasaward.go index 5b9459228..f550d97c2 100644 --- a/modules/smithy/api_atlasaward.go +++ b/modules/smithy/api_atlasaward.go @@ -59,5 +59,8 @@ func (this *apiComp) AtlasAward(session comm.IUserSession, req *pb.SmithyAtlasAw Data: atlas, Reward: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "SmithyAtlasAwardReq", atno) + }) return } diff --git a/modules/smithy/api_forgeequip.go b/modules/smithy/api_forgeequip.go index 6a6c4b174..7d01cf800 100644 --- a/modules/smithy/api_forgeequip.go +++ b/modules/smithy/api_forgeequip.go @@ -374,6 +374,7 @@ func (this *apiComp) ForgeEquip(session comm.IUserSession, req *pb.SmithyForgeEq go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "SmithyForgeEquipReq", atno) }) return diff --git a/modules/smithy/api_receive.go b/modules/smithy/api_receive.go index 227c2e8af..4c65a1f77 100644 --- a/modules/smithy/api_receive.go +++ b/modules/smithy/api_receive.go @@ -60,5 +60,9 @@ func (this *apiComp) TaskAward(session comm.IUserSession, req *pb.SmithyTaskAwar TaskId: req.TaskId, Reward: atno, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "SmithyTaskAwardReq", atno) + }) return } diff --git a/modules/smithy/api_trade.go b/modules/smithy/api_trade.go index afc84faf4..1b2015600 100644 --- a/modules/smithy/api_trade.go +++ b/modules/smithy/api_trade.go @@ -70,5 +70,9 @@ func (this *apiComp) Sell(session comm.IUserSession, req *pb.SmithySellReq) (err } session.SendMsg(string(this.module.GetType()), "sell", rsp) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "SmithySellReq", atno) + }) return } diff --git a/modules/smithy/module.go b/modules/smithy/module.go index 3a6211e7f..82a2749a5 100644 --- a/modules/smithy/module.go +++ b/modules/smithy/module.go @@ -315,6 +315,9 @@ func (this *Smithy) GmSmithyAtlas(session comm.IUserSession) { if equip, errdata := this.ModuleEquipment.QueryEquipment(session.GetUserId(), ids...); errdata == nil { this.modelAtlas.CheckActivateEquipAtlas(session.GetUserId(), equip, 1) } + go this.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.WriteUserLog(session.GetUserId(), "GmSmithyAtlas", atno) + }) } if len(szLibrary) > 0 { @@ -323,4 +326,5 @@ func (this *Smithy) GmSmithyAtlas(session comm.IUserSession) { } } + } diff --git a/modules/sociaty/api_cross_activityreceive.go b/modules/sociaty/api_cross_activityreceive.go index c06433da2..6c954b385 100644 --- a/modules/sociaty/api_cross_activityreceive.go +++ b/modules/sociaty/api_cross_activityreceive.go @@ -91,5 +91,9 @@ func (this *apiComp) Activityreceive(session comm.IUserSession, req *pb.SociatyA SociatyId: sociaty.Id, Reward: atno, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "SociatyActivityReceiveReq", atno) + }) return } diff --git a/modules/sociaty/api_cross_receive.go b/modules/sociaty/api_cross_receive.go index 7e93d504b..df013fc40 100644 --- a/modules/sociaty/api_cross_receive.go +++ b/modules/sociaty/api_cross_receive.go @@ -121,5 +121,9 @@ func (this *apiComp) Receive(session comm.IUserSession, req *pb.SociatyReceiveRe } session.SendMsg(string(this.module.GetType()), SociatySubTypeReceive, rsp) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "SociatyReceiveReq", atno) + }) return } diff --git a/modules/sociaty/api_cross_sign.go b/modules/sociaty/api_cross_sign.go index 3e1c52be1..94e6110cc 100644 --- a/modules/sociaty/api_cross_sign.go +++ b/modules/sociaty/api_cross_sign.go @@ -108,5 +108,8 @@ func (this *apiComp) Sign(session comm.IUserSession, req *pb.SociatySignReq) (er } session.SendMsg(string(this.module.GetType()), SociatySubTypeSign, rsp) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "SociatySignReq", atno) + }) return } diff --git a/modules/stonehenge/api_event.go b/modules/stonehenge/api_event.go index 16e5e33db..9e7fc2f79 100644 --- a/modules/stonehenge/api_event.go +++ b/modules/stonehenge/api_event.go @@ -628,10 +628,15 @@ func (this *apiComp) Event(session comm.IUserSession, req *pb.StonehengeEventReq } } } - if len(tasks) > 0 { - go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + if len(tasks) > 0 { this.module.ModuleBuried.TriggerBuried(session, tasks...) - }) - } + } + if len(reward) > 0 { + this.module.WriteUserLog(session.GetUserId(), "StonehengeEventReq", reward) + } + }) + return } diff --git a/modules/stonehenge/api_finish.go b/modules/stonehenge/api_finish.go index 28b99f7f8..2f04c7c97 100644 --- a/modules/stonehenge/api_finish.go +++ b/modules/stonehenge/api_finish.go @@ -109,5 +109,9 @@ func (this *apiComp) Finish(session comm.IUserSession, req *pb.StonehengeFinishR Curintegral: curintegral, Reward: atno, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "StonehengeFinishReq", atno) + }) return } diff --git a/modules/turntable/api_draw.go b/modules/turntable/api_draw.go index 76e595d3e..08213643f 100644 --- a/modules/turntable/api_draw.go +++ b/modules/turntable/api_draw.go @@ -81,5 +81,9 @@ func (this *apiComp) Draw(session comm.IUserSession, req *pb.TurntableDrawReq) ( Atno: atno, Drawkey: drawkey, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "TurntableDrawReq", atno) + }) return } diff --git a/modules/uigame/api_latticefinish.go b/modules/uigame/api_latticefinish.go index 2c42cbc0d..002ba9acb 100644 --- a/modules/uigame/api_latticefinish.go +++ b/modules/uigame/api_latticefinish.go @@ -56,5 +56,8 @@ func (this *apiComp) LatticeFinish(session comm.IUserSession, req *pb.UiGameLatt Data: list, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGameLatticeFinishReq", atno) + }) return } diff --git a/modules/uigame/api_latticegrid.go b/modules/uigame/api_latticegrid.go index 50f768890..fc912d4d7 100644 --- a/modules/uigame/api_latticegrid.go +++ b/modules/uigame/api_latticegrid.go @@ -138,5 +138,8 @@ func (this *apiComp) LatticeGrid(session comm.IUserSession, req *pb.UiGameLattic Data: list, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGameLatticeGridReq", atno) + }) return } diff --git a/modules/uigame/api_latticereward.go b/modules/uigame/api_latticereward.go index 501dd3dd2..0e5395ce4 100644 --- a/modules/uigame/api_latticereward.go +++ b/modules/uigame/api_latticereward.go @@ -64,5 +64,8 @@ func (this *apiComp) LatticeReward(session comm.IUserSession, req *pb.UiGameLatt Data: list, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGameLatticeRewardReq", atno) + }) return } diff --git a/modules/uigame/api_minerfinish.go b/modules/uigame/api_minerfinish.go index 13a76e698..bbab7bb82 100644 --- a/modules/uigame/api_minerfinish.go +++ b/modules/uigame/api_minerfinish.go @@ -56,5 +56,8 @@ func (this *apiComp) MinerFinish(session comm.IUserSession, req *pb.UiGameMinerF Data: list, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGameMinerFinishReq", atno) + }) return } diff --git a/modules/uigame/api_minergrid.go b/modules/uigame/api_minergrid.go index 3cfe8e133..6b46fe02a 100644 --- a/modules/uigame/api_minergrid.go +++ b/modules/uigame/api_minergrid.go @@ -60,5 +60,8 @@ func (this *apiComp) MinerKey(session comm.IUserSession, req *pb.UiGameMinerKeyR Data: list, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGameMinerKeyReq", atno) + }) return } diff --git a/modules/uigame/api_puzzlegrid.go b/modules/uigame/api_puzzlegrid.go index f4d5e02f2..2bce6ba82 100644 --- a/modules/uigame/api_puzzlegrid.go +++ b/modules/uigame/api_puzzlegrid.go @@ -65,5 +65,9 @@ func (this *apiComp) PuzzleGrid(session comm.IUserSession, req *pb.UiGamePuzzleG Data: list, Atno: atno, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGamePuzzleGridReq", atno) + }) return } diff --git a/modules/uigame/api_puzzlereward.go b/modules/uigame/api_puzzlereward.go index 05d580600..0915d5394 100644 --- a/modules/uigame/api_puzzlereward.go +++ b/modules/uigame/api_puzzlereward.go @@ -48,5 +48,9 @@ func (this *apiComp) PuzzleReward(session comm.IUserSession, req *pb.UiGamePuzzl Data: list, Atno: atno, }) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "UiGamePuzzleRewardReq", atno) + }) return } diff --git a/modules/venture/api_lvreward.go b/modules/venture/api_lvreward.go index bb2aa234c..a1096abe5 100644 --- a/modules/venture/api_lvreward.go +++ b/modules/venture/api_lvreward.go @@ -80,5 +80,8 @@ func (this *apiComp) LvReward(session comm.IUserSession, req *pb.VentureLvReward Data: ventureLv, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "VentureLvRewardReq", atno) + }) return } diff --git a/modules/venture/api_signreward.go b/modules/venture/api_signreward.go index d1fb79539..cf09c8014 100644 --- a/modules/venture/api_signreward.go +++ b/modules/venture/api_signreward.go @@ -70,5 +70,8 @@ func (this *apiComp) SignReward(session comm.IUserSession, req *pb.VentureSignRe Sign: sign, Atno: atno, }) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "VentureSignRewardReq", atno) + }) return } diff --git a/modules/viking/api_challengeover.go b/modules/viking/api_challengeover.go index a33583551..872a043bb 100644 --- a/modules/viking/api_challengeover.go +++ b/modules/viking/api_challengeover.go @@ -251,6 +251,7 @@ func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.VikingChal if len(tasks) > 0 { go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "VikingChallengeOverReq", szAtno) }) } return diff --git a/modules/whackamole/api_award.go b/modules/whackamole/api_award.go index 1d21eb122..16203e843 100644 --- a/modules/whackamole/api_award.go +++ b/modules/whackamole/api_award.go @@ -35,5 +35,8 @@ func (this *apiComp) Award(session comm.IUserSession, req *pb.WhackamoleAwardReq } session.SendMsg(string(this.module.GetType()), "award", &pb.WhackamoleAwardResp{Id: req.Id, Award: award}) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "WhackamoleAwardReq", award) + }) return } diff --git a/modules/wtask/api_battlefinish.go b/modules/wtask/api_battlefinish.go index 62f5c54e4..a5fcb8111 100644 --- a/modules/wtask/api_battlefinish.go +++ b/modules/wtask/api_battlefinish.go @@ -102,6 +102,7 @@ func (this *apiComp) BattleFinish(session comm.IUserSession, req *pb.WTaskBattle if len(tasks) > 0 { go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "WTaskBattleFinishReq", atno) }) } return diff --git a/modules/wtask/api_boxreceive.go b/modules/wtask/api_boxreceive.go index 60a45cf1f..5bcc3137c 100644 --- a/modules/wtask/api_boxreceive.go +++ b/modules/wtask/api_boxreceive.go @@ -117,6 +117,7 @@ func (this *apiComp) BoxReceive(session comm.IUserSession, req *pb.WTaskBoxRecei if len(tasks) > 0 { go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "WTaskBoxReceiveReq", award) }) } return diff --git a/modules/wtask/api_chapterreward.go b/modules/wtask/api_chapterreward.go index 001d57e00..21b6d92ab 100644 --- a/modules/wtask/api_chapterreward.go +++ b/modules/wtask/api_chapterreward.go @@ -71,5 +71,8 @@ func (this *apiComp) ChapterReward(session comm.IUserSession, req *pb.WTaskChapt // }) // } session.SendMsg(string(this.module.GetType()), "chapterreward", &pb.WTaskChapterRewardResp{Group: req.Group, Award: award}) + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "WTaskChapterRewardReq", award) + }) return } diff --git a/modules/wtask/api_eventcomplete.go b/modules/wtask/api_eventcomplete.go index 23aa96e29..b5c310be5 100644 --- a/modules/wtask/api_eventcomplete.go +++ b/modules/wtask/api_eventcomplete.go @@ -94,6 +94,7 @@ func (this *apiComp) EventComplete(session comm.IUserSession, req *pb.WTaskEvent go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleBuried.TriggerBuried(session, tasks...) + this.module.WriteUserLog(session.GetUserId(), "WTaskEventCompleteReq", award) }) return } diff --git a/modules/wtask/api_exchange.go b/modules/wtask/api_exchange.go index f9c004bd0..420e1b8f6 100644 --- a/modules/wtask/api_exchange.go +++ b/modules/wtask/api_exchange.go @@ -85,5 +85,9 @@ func (this *apiComp) Exchange(session comm.IUserSession, req *pb.WTaskExchangeRe return } session.SendMsg(string(this.module.GetType()), "exchange", &pb.WTaskExchangeResp{Eid: req.Eid, Award: award}) + + go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { + this.module.WriteUserLog(session.GetUserId(), "WTaskExchangeReq", award) + }) return } diff --git a/modules/wtask/api_finish.go b/modules/wtask/api_finish.go index 00d5e0adb..49c64243f 100644 --- a/modules/wtask/api_finish.go +++ b/modules/wtask/api_finish.go @@ -152,6 +152,7 @@ func (this *apiComp) Finish(session comm.IUserSession, req *pb.WTaskFinishReq) ( } go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.ModuleSys.CheckOpenCond(session.Clone(), comm.OpencondTypeWorldtaskid, req.Tid) + this.module.WriteUserLog(session.GetUserId(), "WTaskFinishReq", award) }) return }