From af571fb456e00965d132fcfd649d29c42d25481f Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Tue, 22 Nov 2022 16:16:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=95=86=E5=BA=97=E5=92=8C=E5=85=B3=E5=8D=A1?= =?UTF-8?q?=E7=BC=96=E8=BE=91=E5=9F=8B=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/combat/api_challengereceive.go | 1 + modules/combat/api_drop.go | 1 + modules/shop/api_getlist.go | 2 ++ 3 files changed, 4 insertions(+) diff --git a/modules/combat/api_challengereceive.go b/modules/combat/api_challengereceive.go index 204ba5f12..a566aecef 100644 --- a/modules/combat/api_challengereceive.go +++ b/modules/combat/api_challengereceive.go @@ -88,6 +88,7 @@ func (this *apiComp) ChallengeReceive(session comm.IUserSession, req *pb.CombatC return } this.module.DispenseRes(session, level.Award, true) + this.module.ModuleRtask.SendToRtask(session, comm.Rtype140, level.Id) } } diff --git a/modules/combat/api_drop.go b/modules/combat/api_drop.go index 941f484a1..32717e106 100644 --- a/modules/combat/api_drop.go +++ b/modules/combat/api_drop.go @@ -94,6 +94,7 @@ func (this *apiComp) Drop(session comm.IUserSession, req *pb.CombatDropReq) (cod return } this.module.DispenseRes(session, level.Award, true) + this.module.ModuleRtask.SendToRtask(session, comm.Rtype140, level.Id) } session.SendMsg(string(this.module.GetType()), "drop", &pb.CombatDropResp{Code: code, Atns: atns, Pass: pass}) diff --git a/modules/shop/api_getlist.go b/modules/shop/api_getlist.go index 42e70a0b4..38b35b912 100644 --- a/modules/shop/api_getlist.go +++ b/modules/shop/api_getlist.go @@ -133,6 +133,7 @@ func (this *apiComp) Getlist(session comm.IUserSession, req *pb.ShopGetListReq) } } } + this.module.ModuleRtask.SendToRtask(session, comm.Rtype105, 1) this.module.modelShop.Change(session.GetUserId(), map[string]interface{}{filed: sdata}) } else if !req.IsManualRefresh { if tdata > ltime { //达到刷新时间 可以刷新商品列表 @@ -159,6 +160,7 @@ func (this *apiComp) Getlist(session comm.IUserSession, req *pb.ShopGetListReq) } goods = transGoods(items, sdata) this.module.modelShop.Change(session.GetUserId(), map[string]interface{}{filed: sdata}) + this.module.ModuleRtask.SendToRtask(session, comm.Rtype105, 1) } else { //返回以前的商品列表 if items, err = this.module.configure.GetShopItemsConfigureByIds(sdata.Items...); err != nil { code = pb.ErrorCode_SystemError