This commit is contained in:
wucongxing 2023-08-02 13:43:06 +08:00
parent 91f829f26e
commit 8cfb0f3894

View File

@ -23,7 +23,6 @@ use Hyperf\Amqp\Producer;
use Hyperf\Utils\ApplicationContext;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
use function _PHPStan_503e82092\RingCentral\Psr7\str;
/**
* 消息推送业务类
@ -362,8 +361,6 @@ class MessagePush extends BaseService
* 患者的问诊服务结束
* 站内、订阅
* @return void
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/
public function patientInquiryFinish(): void
{
@ -442,7 +439,9 @@ class MessagePush extends BaseService
$data['sub_data'] = $sub_data;
$data['sms_data'] = array();
dump($data);
$message = new SendSubMessageProducer($data);
dump($message->payload());
$result = $producer->produce($message);
if (!$result) {
Log::getInstance("MessagePush")->error("错误:加入推送队列失败" . json_encode($data, JSON_UNESCAPED_UNICODE));