diff --git a/modules/worldtask/module.go b/modules/worldtask/module.go
index 267b92c9a..2d1e64a25 100644
--- a/modules/worldtask/module.go
+++ b/modules/worldtask/module.go
@@ -64,7 +64,7 @@ func (this *Worldtask) TaskCondFinishNotify(session comm.IUserSession, condId in
 		return err
 	}
 
-	var groupId int32
+	var groupId, taskId int32
 	// 检索condId是否是世界任务的完成条件
 	finishedTaskIds := make(map[int32]int32) //达成的任务条件
 	for _, c := range this.worldtaskConf.GetDataList() {
@@ -72,6 +72,7 @@ func (this *Worldtask) TaskCondFinishNotify(session comm.IUserSession, condId in
 			if v == condId {
 				finishedTaskIds[c.Group] = c.Key
 				groupId = c.Group
+				taskId = c.Key
 				break
 			}
 		}
@@ -101,14 +102,12 @@ func (this *Worldtask) TaskCondFinishNotify(session comm.IUserSession, condId in
 	}
 	this.modelWorldtask.Change(uid, update)
 
-	for k, v := range userTask.CurrentTask {
-		session.SendMsg(string(this.GetType()), "completecondis", &pb.WorldtaskCompletecondisPush{
-			GroupId:  k,
-			TaskId:   v.TaskId,
-			CondiIds: wt.CondiIds,
-		})
-		this.Debug("推送完成条件", log.Field{Key: "condiIds", Value: v.TaskId})
-	}
+	session.SendMsg(string(this.GetType()), "completecondis", &pb.WorldtaskCompletecondisPush{
+		GroupId:  groupId,
+		TaskId:   taskId,
+		CondiIds: wt.CondiIds,
+	})
+	this.Debug("推送完成条件", log.Field{Key: "condiIds", Value: taskId})
 
 	return nil
 }