diff --git a/modules/horoscope/api_upgrade.go b/modules/horoscope/api_upgrade.go index e12b88b4a..555bb3915 100644 --- a/modules/horoscope/api_upgrade.go +++ b/modules/horoscope/api_upgrade.go @@ -52,6 +52,9 @@ func (this *apiComp) Upgrade(session comm.IUserSession, req *pb.HoroscopeUpgrade return } info.Nodes[conf.NodeId] = conf.Lv + 1 + if info.Nodes[conf.NodeId] == 1 { //解锁 + go this.module.ModuleRtask.TriggerTask(session.GetUserId(), comm.GettaskParam(comm.Rtype173, 1)) + } if err = this.module.modelHoroscope.updateInfo(session, info); err != nil { code = pb.ErrorCode_DBError return diff --git a/modules/rtask/module.go b/modules/rtask/module.go index 9eb0be7e5..8eff9d946 100644 --- a/modules/rtask/module.go +++ b/modules/rtask/module.go @@ -317,7 +317,7 @@ func (this *ModuleRtask) TriggerTask(uid string, taskParams ...*comm.TaskParam) } func (this *ModuleRtask) processTasks(session comm.IUserSession, taskParams ...*comm.TaskParam) { - + lock, _ := this.modelRtask.userlock(session.GetUserId()) err := lock.Lock() if err != nil {