diff --git a/modules/arena/api_challengereward.go b/modules/arena/api_challengereward.go
index 5fd46ab2f..fabc3f7f5 100644
--- a/modules/arena/api_challengereward.go
+++ b/modules/arena/api_challengereward.go
@@ -76,8 +76,7 @@ func (this *apiComp) ChallengeReward(session comm.IUserSession, req *pb.ArenaCha
 			redstate = pb.BattleRecordState_AttackWin
 			bulestate = pb.BattleRecordState_DefendLost
 		}
-		// this.module.ModuleRtask.SendToRtask(session, comm.Rtype131, 1)
-		go this.module.ModuleBuried.TriggerBuried(session.Clone(), comm.GetBuriedParam(comm.Rtype131, 1))
+		tasks = append(tasks, comm.GetBuriedParam(comm.Rtype131, 1))
 	} else {
 		info.Streak = 0
 		if req.Revengeid != "" {
diff --git a/modules/caravan/api_buyorsell.go b/modules/caravan/api_buyorsell.go
index 4dbf5ecb5..b0eeb4888 100644
--- a/modules/caravan/api_buyorsell.go
+++ b/modules/caravan/api_buyorsell.go
@@ -251,8 +251,11 @@ func (this *apiComp) BuyOrSell(session comm.IUserSession, req *pb.CaravanBuyOrSe
 		// Rtype211 TaskType = 211 // 向指定X城市，贩卖价值X虚拟币以上的对应城市急需货物
 		tasks = append(tasks, comm.GetBuriedParam(comm.Rtype211, req.City, sellSpValue))
 	}
-	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
-		this.module.ModuleBuried.TriggerBuried(session, tasks...)
-	})
+	if len(tasks) > 0 {
+		go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
+			this.module.ModuleBuried.TriggerBuried(session, tasks...)
+		})
+	}
+
 	return
 }
diff --git a/modules/moonfantasy/modelDream.go b/modules/moonfantasy/modelDream.go
index 8ef7db52b..d10e1265c 100644
--- a/modules/moonfantasy/modelDream.go
+++ b/modules/moonfantasy/modelDream.go
@@ -134,7 +134,6 @@ func (this *modelDreamComp) trigger(session comm.IUserSession) {
 	}
 	this.module.modelDream.noticeuserfriend(session, mdata.Id, chat)
 	session.SendMsg(string(this.module.GetType()), "trigger", &pb.MoonfantasyTriggerPush{Issucc: true, Mid: mdata.Id, Monster: mdata.Monster})
-	// this.module.ModuleRtask.SendToRtask(session, comm.Rtype87, 1)
 	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
 		this.module.ModuleBuried.TriggerBuried(session, comm.GetBuriedParam(comm.Rtype87, 1))
 	})
diff --git a/modules/wtask/api_eventcomplete.go b/modules/wtask/api_eventcomplete.go
index 85a0500d8..5c9d4542a 100644
--- a/modules/wtask/api_eventcomplete.go
+++ b/modules/wtask/api_eventcomplete.go
@@ -98,10 +98,10 @@ func (this *apiComp) EventComplete(session comm.IUserSession, req *pb.WTaskEvent
 	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype206, 1))
 	tasks = append(tasks, comm.GetBuriedParam(comm.Rtype207, 1, req.Group))
 
+	session.SendMsg(string(this.module.GetType()), "eventcomplete", &pb.WTaskEventCompleteResp{Group: req.Group, Event: event, Award: award})
+
 	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
 		this.module.ModuleBuried.TriggerBuried(session, tasks...)
 	})
-
-	session.SendMsg(string(this.module.GetType()), "eventcomplete", &pb.WTaskEventCompleteResp{Group: req.Group, Event: event, Award: award})
 	return
 }