修改队列备注

This commit is contained in:
wucongxing 2023-12-05 13:50:23 +08:00
parent 11bf031bd4
commit 811acd7880
6 changed files with 19 additions and 0 deletions

View File

@ -30,6 +30,9 @@ use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface; use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface; use Psr\Container\NotFoundExceptionInterface;
/**
* 快速-购药分配医生
*/
#[Consumer(nums: 1)] #[Consumer(nums: 1)]
class AssignDoctorDelayDirectConsumer extends ConsumerMessage class AssignDoctorDelayDirectConsumer extends ConsumerMessage
{ {

View File

@ -31,6 +31,9 @@ use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface; use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface; use Psr\Container\NotFoundExceptionInterface;
/**
* 药师审核并ca签章
*/
#[Consumer(nums: 1)] #[Consumer(nums: 1)]
class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage
{ {

View File

@ -29,6 +29,10 @@ use Hyperf\DbConnection\Db;
use Hyperf\Snowflake\IdGeneratorInterface; use Hyperf\Snowflake\IdGeneratorInterface;
use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Message\AMQPMessage;
/**
* 检测订单自动完成延迟队列
* 当接收到检测报告时,如当时患者-医生存在问诊中订单,则加入此延迟队列,等待问诊结束后,检测订单才会接收
*/
#[Consumer(nums: 1)] #[Consumer(nums: 1)]
class DetectionCompleteDelayDirectConsumer extends ConsumerMessage class DetectionCompleteDelayDirectConsumer extends ConsumerMessage
{ {

View File

@ -16,6 +16,9 @@ use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db; use Hyperf\DbConnection\Db;
use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Message\AMQPMessage;
/**
* 再次发放用户优惠卷
*/
#[Consumer(nums: 1)] #[Consumer(nums: 1)]
class GrantUserCouponDelayDirectConsumer extends ConsumerMessage class GrantUserCouponDelayDirectConsumer extends ConsumerMessage
{ {

View File

@ -15,6 +15,9 @@ use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\Redis\Redis; use Hyperf\Redis\Redis;
use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Message\AMQPMessage;
/**
* 用户在线状态
*/
#[Consumer(nums: 1)] #[Consumer(nums: 1)]
class UserImOffDelayDirectConsumer extends ConsumerMessage class UserImOffDelayDirectConsumer extends ConsumerMessage
{ {

View File

@ -9,6 +9,9 @@ use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
use Hyperf\Amqp\Message\ProducerMessage; use Hyperf\Amqp\Message\ProducerMessage;
use Hyperf\Amqp\Message\Type; use Hyperf\Amqp\Message\Type;
/**
* 再次发放用户优惠卷
*/
#[Producer] #[Producer]
class GrantUserCouponDelayDirectProducer extends ProducerMessage class GrantUserCouponDelayDirectProducer extends ProducerMessage
{ {