jobs消息队列

jobs消息队列

目录结构

├─jobs
│      LiveJob.php
│      OrderJob.php
│      PinkJob.php
│      PosterJob.php
│      RoutineTemplateJob.php
│      SmsAdminJob.php
│      TakeOrderJob.php
│      TaskJob.php
│      UnpaidOrderCancelJob.php
│      UnpaidOrderSend.php
│      WechatTemplateJob.php

消费类	描述
LiveJob	直播数据处理消息队列
OrderCreateAfterJob	订单创建后数据处理消息队列
OrderJob	订单数据处理消息队列
PinkJob	拼团数据处理消息队列
PosterJob	生成海报消息队列
ProductLogJob	商品记录数据处理消息队列
RoutineTemplateJob	小程序订阅消息数据处理消息队列
SmsAdminJob	业务短信发送数据处理消息队列
TakeOrderJob	自动收货数据处理消息队列
TaskJob	清除任务或修改数据记录处理消息队列
UnpaidOrderCancelJob	未支付订单到期处理消息队列
UnpaidOrderSend	未支付订单短信提醒处理消息队列
UserJob	用户数据处理消息队列
WechatTemplateJob	公众号模板消息处理队列

LiveJob直播消息队列

主要更新直播商品状态和同步直播间状态 使用实例，使用在直播房间创建后加入消息队列进行执行

use crmeb\utils\Queue;

Queue::instance()->job(\crmeb\jobs\LiveJob::class)->secs(120)->push();

OrderJob订单消息队列

使用在订单支付后的后置消息发送和后置事件 使用实例：

use crmeb\utils\Queue;

Queue::instance()->job(\crmeb\jobs\OrderJob::class)->data($orderInfo)->push();

PinkJob拼团消息队列

使用在拼团时效到期取消拼团使用 使用实例：

use crmeb\utils\Queue;

Queue::instance()->job(PinkJob::class)->secs(($product->effective_time * 3600) + 60)->data($pink['id'])->push();

PosterJob海报生成

使用在api应用下用来异步生成海报，调用spreadPoster方法

use crmeb\utils\Queue;

Queue::instance()->do('spreadPoster')->job(PosterJob::class)->data($user, $isssl)->push();

RoutineTemplateJob和WechatTemplateJob为模板消息

目前发送模板消息全部都由消息队列发送，此消息队列类属于多任务类型，内置很多个子任务这里只调用一种作为实例

use crmeb\utils\Queue;

Queue::instance()->do('sendBargainSuccess')->job(RoutineTemplateJob::class)->data($userOpenid['openid'], $bargainInfo, $bargainUserInfo, $bargainUserUid)->push();

SmsAdminJob短信消息发送

发送管理员退款消息任务和确认收货管理员短信提醒，此消息队列类属于多任务类型

TakeOrderJob自动收货，已调整为定时任务执行

UnpaidOrderCancelJob取消订单，已调整为定时任务执行

UnpaidOrderSend未支付10分钟发送短信提醒