diff --git a/src/main/java/com/peanut/modules/mq/Consumer/UserVipConsumer.java b/src/main/java/com/peanut/modules/mq/Consumer/UserVipConsumer.java
index 91da1f53..aabd6041 100644
--- a/src/main/java/com/peanut/modules/mq/Consumer/UserVipConsumer.java
+++ b/src/main/java/com/peanut/modules/mq/Consumer/UserVipConsumer.java
@@ -5,10 +5,13 @@ import com.peanut.modules.common.dao.MyUserDao;
 import com.peanut.modules.common.dao.UserVipDao;
 import com.peanut.modules.common.entity.MyUserEntity;
 import com.peanut.modules.common.entity.UserVip;
+import org.apache.commons.lang.time.DateUtils;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
+
 //超v过期死信操作
 @Component
 public class UserVipConsumer {
@@ -21,15 +24,15 @@ public class UserVipConsumer {
     @RabbitListener(queues = DelayQueueConfig.USERVIP_QUEUE)
     public void userVipConsumer(String userVipId) {
         UserVip userVip = userVipDao.selectById(userVipId);
-        if(userVip == null){
-            return;
-        }else {
-            userVip.setState(1);
-            userVipDao.updateById(userVip);
-            MyUserEntity user = userDao.selectById(userVip.getUserId());
-            user.setVip("0");
-            userDao.updateById(user);
-            System.out.println(user.getName()+"-"+user.getTel()+"-"+user.getEmail()+"超v过期,vip更新完成");
+        if(userVip != null){
+            if(DateUtils.addSeconds(new Date(),3).getTime()>userVip.getEndTime().getTime()){
+                userVip.setState(1);
+                userVipDao.updateById(userVip);
+                MyUserEntity user = userDao.selectById(userVip.getUserId());
+                user.setVip("0");
+                userDao.updateById(user);
+                System.out.println(user.getName()+"-"+user.getTel()+"-"+user.getEmail()+"超v过期,vip更新完成");
+            }
         }
     }