| | |
| | | } |
| | | comActRaffle.setStatus(3); |
| | | comActRaffleDao.updateById(comActRaffle); |
| | | rabbitTemplate.convertAndSend("raffle.exchange", "raffle.key", comActRaffleVO, message -> { |
| | | message.getMessageProperties().setHeader("x-delay", dateToSecond(comActRaffle.getRaffleStopTime())); |
| | | return message; |
| | | }); |
| | | } |
| | | if(comActRaffle!=null&&comActRaffle.getStatus()==0&&comActRaffle.getStartTime().before(new Date())){ |
| | | comActRaffle.setStatus(1); |
| | |
| | | return message; |
| | | }); |
| | | } |
| | | if(comActRaffle!=null&&comActRaffle.getStatus()==3&&comActRaffle.getRaffleStopTime().before(new Date())){ |
| | | comActRaffleRecordDao.updateStatusByRaffleId(comActRaffle.getId()); |
| | | } |
| | | } |
| | | private Long dateToSecond(Date expireTime){ |
| | | return DateUtil.between(new Date(),expireTime, DateUnit.MS); |