【CouponHub项目开发】分发优惠券
在之前的创建分发任务,然后使用线程池异步解析Excel表格并使用Redission延时队列来进行兜底的时候,有一个如果是立即执行的任务,就直接发送消息队列去执行优惠券分发任务,如果是定时任务就通过xxl-job监测到时间后发送消息。
这一节我们就来实现发送消息后的消费者:
首先我们先进行信息的验证,如果验证正确,再去执行后续逻辑
之后我们创建一个Excel监听器,并且通过EasyExcel去调用它的read方法
在监听器当中,我们先去判断数据库中数据是否充足,并进行扣减。
接着我们构建用户领券记录,并且将其添加到数据库当中,接着再把优惠券添加到Redis中的用户领券记录中