zm/nuttyreading-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

超v定时任务修改

Browse Source
This commit is contained in:
wuchunlei
2024-07-04 15:57:29 +08:00
parent 5eb03fca02
commit e5839ca3e7
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/main/java/com/peanut/modules/mq/Consumer/UserVipConsumer.java
View File

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