diff --git a/src/main/java/com/peanut/modules/job/task/CourseTask.java b/src/main/java/com/peanut/modules/job/task/CourseTask.java
index 3c4bf41b..80b1fbcb 100644
--- a/src/main/java/com/peanut/modules/job/task/CourseTask.java
+++ b/src/main/java/com/peanut/modules/job/task/CourseTask.java
@@ -21,9 +21,8 @@ public class CourseTask implements ITask{
     private RabbitTemplate rabbitTemplate;
 
     @Override
-    public void run(String userId) {
+    public void run(String params) {
         LambdaQueryWrapper<UserCourseBuyEntity> wrapper = new LambdaQueryWrapper();
-        wrapper.eq(UserCourseBuyEntity::getUserId,userId);
         List<UserCourseBuyEntity> list = userCourseBuyDao.selectList(wrapper);
         if (list.size() > 0) {
             for (UserCourseBuyEntity userCourseBuyEntity : list) {
diff --git a/src/main/java/com/peanut/modules/job/task/UserVipTask.java b/src/main/java/com/peanut/modules/job/task/UserVipTask.java
index 6e4eaed6..af840480 100644
--- a/src/main/java/com/peanut/modules/job/task/UserVipTask.java
+++ b/src/main/java/com/peanut/modules/job/task/UserVipTask.java
@@ -32,10 +32,9 @@ public class UserVipTask implements ITask{
     private RabbitTemplate rabbitTemplate;
 
     @Override
-    public void run(String userId) {
+    public void run(String params) {
         LambdaQueryWrapper<UserVip> wrapper = new LambdaQueryWrapper();
         wrapper.eq(UserVip::getState,0);
-        wrapper.eq(UserVip::getUserId,userId);
         List<UserVip> list = vipService.list(wrapper);
         if (list.size() > 0) {
             for (UserVip userVip : list) {