72 lines
2.3 KiB
PHP
72 lines
2.3 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Amqp\Consumer;
|
|
|
|
use App\Model\MessageNotice;
|
|
use App\Services\ImService;
|
|
use App\Utils\Log;
|
|
use Hyperf\Amqp\Result;
|
|
use Hyperf\Amqp\Annotation\Consumer;
|
|
use Hyperf\Amqp\Message\ConsumerMessage;
|
|
use PhpAmqpLib\Message\AMQPMessage;
|
|
|
|
/**
|
|
* 站内消息推送
|
|
*/
|
|
#[Consumer(exchange: 'amqp.direct', routingKey: 'SendStationMessage', queue: 'send.station.message.queue',nums: 1)]
|
|
class SendStationMessageConsumer extends ConsumerMessage
|
|
{
|
|
public function consumeMessage($data, AMQPMessage $message): string
|
|
{
|
|
Log::getInstance()->info("开始执行 站内消息推送 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
|
|
|
|
// 验证参数
|
|
if (!isset($data['notice_id'])){
|
|
Log::getInstance()->info("站内消息推送失败：参数错误");
|
|
return Result::DROP;
|
|
}
|
|
|
|
// 获取推送信息数据
|
|
$params = array();
|
|
$params['notice_id'] = $data['notice_id'];
|
|
$message_notice = MessageNotice::getOne($params);
|
|
if (empty($message_notice)){
|
|
Log::getInstance()->info("站内消息推送失败：无推送表数据");
|
|
return Result::DROP;
|
|
}
|
|
|
|
try {
|
|
// 发送消息
|
|
$ImService = new ImService();
|
|
|
|
// 自定义消息
|
|
$cloud_custom_data = array();
|
|
$cloud_custom_data['order_inquiry_id'] = "";
|
|
$cloud_custom_data['is_system'] = 1;
|
|
$cloud_custom_data['inquiry_type'] = "";
|
|
$cloud_custom_data['message_rounds'] = "";
|
|
|
|
// 消息内容
|
|
$message_content_data = array();
|
|
$message_content_data['message_type'] = 1;
|
|
$message_content_data['content'] = "--等待医生接诊--";
|
|
$message_content_data['desc'] = "温馨提示：您可继续补充问诊内容，便于更快确认病情，医生均在临床一线工作，还请耐心等待，医生接诊会第一时间短信通知您。";
|
|
$message_content = [
|
|
'Data' => json_encode($message_content_data,JSON_UNESCAPED_UNICODE),
|
|
];
|
|
|
|
|
|
} catch (\Exception $e) {
|
|
Log::getInstance()->error("站内消息推送执行失败：" . $e->getMessage());
|
|
}
|
|
|
|
|
|
|
|
|
|
Log::getInstance()->info("站内消息推送成功");
|
|
return Result::ACK;
|
|
}
|
|
}
|