| | |
|---|
| | | List<XpActivity> list = xpActicityService.list(new QueryWrapper<XpActivity>().in("status", Arrays.asList(1, 2)).eq("is_deleted", 0)); |
|---|
| | | for (XpActivity xpActivity : list) { |
|---|
| | | Integer status = xpActivity.getStatus(); |
|---|
| | | //即将开始的活动推送socket给前端用户 |
|---|
| | | if(1 == status && LocalDateTime.now().isBefore(xpActivity.getStartTime())){ |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //即将结束的活动推送给前端用户 |
|---|
| | | |
|---|
| | | //生效的活动修改状态和发放一次优惠券 |
|---|
| | | if(1 == status && LocalDateTime.now().isAfter(xpActivity.getStartTime()) && LocalDateTime.now().isBefore(xpActivity.getEndTime())){ |
|---|
| | | xpActivity.setStatus(2); |
|---|
| | | //发放优惠券-发放一次的优惠券 |
|---|
| | |
|---|
| | | pushCoupon(xpActivity, xpActicityStrategy); |
|---|
| | | } |
|---|
| | | |
|---|
| | | }else if(2 == status & LocalDateTime.now().isAfter(xpActivity.getEndTime())){ |
|---|
| | | } |
|---|
| | | //到期的活动修改状态为已结束 |
|---|
| | | if(2 == status & LocalDateTime.now().isAfter(xpActivity.getEndTime())){ |
|---|
| | | xpActivity.setStatus(3); |
|---|
| | | } |
|---|
| | | xpActicityService.updateById(xpActivity); |
|---|
