上传推送礼包 用户会话释放导致推送异常bug
This commit is contained in:
parent
0c39c60bff
commit
4a182ed2d8
@ -599,8 +599,7 @@ func (this *Buried) trigger(session comm.IUserSession, burieds ...*pb.BuriedPara
|
|||||||
nmodule.BuriedsNotify(session, v)
|
nmodule.BuriedsNotify(session, v)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
// this.wtask.BuriedsNotify(session, changes)
|
|
||||||
// this.smithy.BuriedsNotify(session, changes)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 更新并校验完成
|
// 更新并校验完成
|
||||||
|
@ -200,10 +200,10 @@ func (this *Pay) Rpc_ModulePayDelivery(ctx context.Context, args *pb.PayDelivery
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
go func() {
|
go func(_session comm.IUserSession) {
|
||||||
this.ModuleHero.RechargeMoney(args.Uid, args.Price)
|
this.ModuleHero.RechargeMoney(args.Uid, args.Price)
|
||||||
this.ModuleBuried.TriggerBuried(session.Clone(), comm.GetBuriedParam(comm.Rtype229, 1, conf.Pid))
|
this.ModuleBuried.TriggerBuried(_session, comm.GetBuriedParam(comm.Rtype229, 1, conf.Pid))
|
||||||
}()
|
}(session.Clone())
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
@ -192,6 +192,7 @@ func (this *PushGiftbag) BuriedsNotify(session comm.IUserSession, condis []*pb.C
|
|||||||
this.model.Change(session.GetUserId(), map[string]interface{}{
|
this.model.Change(session.GetUserId(), map[string]interface{}{
|
||||||
"item": info.Item,
|
"item": info.Item,
|
||||||
})
|
})
|
||||||
|
this.Debug("推送礼包", log.Field{Key: "礼包", Value: info.Item})
|
||||||
session.SendMsg(string(this.GetType()), "chanage", &pb.PushGiftbagChanagePush{Item: info.Item})
|
session.SendMsg(string(this.GetType()), "chanage", &pb.PushGiftbagChanagePush{Item: info.Item})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user