日志记录补充

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
 }

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)
 		}
 

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
 }

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
 }

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
 }

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
 }

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

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
 }

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
 }

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

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
 }

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
 }

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) {
 		}
 
 	}
+
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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
 }

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

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
 }

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

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

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
 }

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
 }

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
 }

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
 }