diff --git a/modules/rtask/module.go b/modules/rtask/module.go index a39a2e777..65a14c63e 100644 --- a/modules/rtask/module.go +++ b/modules/rtask/module.go @@ -278,62 +278,62 @@ func (this *ModuleRtask) processOneTask(session comm.IUserSession, rtaskType com } //任务完成则推送 - if code := this.CheckCondi(uid, conf.Id); code == pb.ErrorCode_Success { + if code = this.CheckCondi(uid, conf.Id); code == pb.ErrorCode_Success { module, err := this.service.GetModule(comm.ModuleWorldtask) if err == nil { - go func() { - defer func() { - if r := recover(); r != nil { - log.Errorf("[worldtask ] err:%v ", r) - } - }() + // go func() { + // defer func() { + // if r := recover(); r != nil { + // log.Errorf("[worldtask ] err:%v ", r) + // } + // }() - if worldtask, ok := module.(comm.IWorldtask); ok { - if err := worldtask.TaskcondNotify(session, conf.Id); err != nil { - log.Error("任务条件达成通知", - log.Field{Key: "uid", Value: uid}, - log.Field{Key: "condId", Value: conf.Id}, - log.Field{Key: "err", Value: err.Error()}, - ) - } + if worldtask, ok := module.(comm.IWorldtask); ok { + if err := worldtask.TaskcondNotify(session, conf.Id); err != nil { + log.Error("任务条件达成通知", + log.Field{Key: "uid", Value: uid}, + log.Field{Key: "condId", Value: conf.Id}, + log.Field{Key: "err", Value: err.Error()}, + ) } - }() + } + // }() } userModule, err := this.service.GetModule(comm.ModuleUser) if err == nil { - go func() { - defer func() { //程序异常 收集异常信息传递给前端显示 - if r := recover(); r != nil { - log.Errorf("[sociatytask ] err:%v ", r) + // go func() { + // defer func() { //程序异常 收集异常信息传递给前端显示 + // if r := recover(); r != nil { + // log.Errorf("[sociatytask ] err:%v ", r) + // } + // }() + // 公会 + if user, ok := userModule.(comm.IUser); ok { + ex, err := user.GetUserExpand(uid) + if err == nil && ex.SociatyId != "" { + sociatyModule, err := this.service.GetModule(comm.ModuleSociaty) + if err != nil { + return } - }() - // 公会 - if user, ok := userModule.(comm.IUser); ok { - ex, err := user.GetUserExpand(uid) - if err == nil && ex.SociatyId != "" { - sociatyModule, err := this.service.GetModule(comm.ModuleSociaty) - if err != nil { - return - } - if sociaty, ok := sociatyModule.(comm.ISociaty); ok { - if err2 := sociaty.TaskcondNotify(uid, ex.SociatyId, conf.Id); err2 != nil { - log.Error("公会任务条件达成通知", - log.Field{Key: "uid", Value: uid}, - log.Field{Key: "sociatyId", Value: ex.SociatyId}, - log.Field{Key: "condId", Value: conf.Id}, - log.Field{Key: "err", Value: err2.Error()}, - ) - } - this.processOneTask(session, comm.Rtype156, 1) - // if module, err := this.service.GetModule(comm.ModuleRtask); err == nil { - // if iRtask, ok := module.(comm.IRtask); ok { - // iRtask.SendToRtask(session, comm.Rtype156, 1) - // } - // } + if sociaty, ok := sociatyModule.(comm.ISociaty); ok { + if err2 := sociaty.TaskcondNotify(uid, ex.SociatyId, conf.Id); err2 != nil { + log.Error("公会任务条件达成通知", + log.Field{Key: "uid", Value: uid}, + log.Field{Key: "sociatyId", Value: ex.SociatyId}, + log.Field{Key: "condId", Value: conf.Id}, + log.Field{Key: "err", Value: err2.Error()}, + ) } + this.processOneTask(session, comm.Rtype156, 1) + // if module, err := this.service.GetModule(comm.ModuleRtask); err == nil { + // if iRtask, ok := module.(comm.IRtask); ok { + // iRtask.SendToRtask(session, comm.Rtype156, 1) + // } + // } } } - }() + } + // }() } }