上传任务埋点60,61 修改

This commit is contained in:
liwei1dao 2024-03-13 13:50:38 +08:00
parent 4cfb103d37
commit 34c96d5684
3 changed files with 29 additions and 22 deletions

View File

@ -28,7 +28,7 @@ func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.MainlineCh
isWin bool
first bool // 判断是否是首通
star int32 // 评星
tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
// tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
err error
changExp map[string]int32
res []*cfg.Gameatn
@ -191,11 +191,11 @@ func (this *apiComp) ChallengeOver(session comm.IUserSession, req *pb.MainlineCh
Reward: atno,
})
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
// tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
// tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
// this.module.ModuleBuried.TriggerBuried(session, tasks...)
// this.module.ModuleSys.CheckOpenCond(session, comm.OpencondTypeMaxmapid, req.Level)
this.module.WriteUserLog(session.GetUserId(), req, comm.GMResAddType, "MainlineChallengeOverReq", atno)
})

View File

@ -28,7 +28,7 @@ func (this *apiComp) LevelPass(session comm.IUserSession, req *pb.MainlineLevelP
aeward []*pb.UserAtno = make([]*pb.UserAtno, 0)
first bool // 判断是否是首通
star int32 // 评星
tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
// tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
err error
// consumPs int32
)
@ -140,11 +140,8 @@ func (this *apiComp) LevelPass(session comm.IUserSession, req *pb.MainlineLevelP
return
}
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level)))
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
// this.module.ModuleBuried.TriggerBuried(session, tasks...)
// this.module.ModuleSys.CheckOpenCond(session, comm.OpencondTypeMaxmapid, req.Level)
this.module.WriteUserLog(session.GetUserId(), req, comm.GMResAddType, "MainlineLevelPassReq", aeward)
})

View File

@ -15,6 +15,7 @@ func (this *apiComp) SetPolts(session comm.IUserSession, req *pb.MainlineSetPolt
var (
info *pb.DBMainline
err error
tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0)
)
if errdata = this.SetPoltsCheck(session, req); errdata != nil {
return // 参数校验失败直接返回
@ -28,6 +29,10 @@ func (this *apiComp) SetPolts(session comm.IUserSession, req *pb.MainlineSetPolt
}
return
}
if !info.Plots[req.Pid] {
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1))
tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Pid)))
}
info.Plots[req.Pid] = req.State
if err = this.module.modelMline.Change(session.GetUserId(), map[string]interface{}{
@ -43,7 +48,12 @@ func (this *apiComp) SetPolts(session comm.IUserSession, req *pb.MainlineSetPolt
session.SendMsg(string(this.module.GetType()), "setpolts", &pb.MainlineSetPoltsResp{
Plots: info.Plots,
}) // 数据推送
})
if len(tasks) > 0 {
go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
this.module.ModuleBuried.TriggerBuried(session, tasks...)
})
}
return
}