huahuibao/common/components/rabbitmq/openShopInitConsumer.php

<?php
/**
 * 通知的消费者
 * User: ssh <ssh@zhhinc.com>
 * Date: 2019/9/9 0009
 * Time: 14:54
 */

namespace common\components\rabbitmq;


use biz\sj\services\MerchantService;
use bizHd\wx\services\WxOpenService;
use common\components\sms;
use mikemadisonweb\rabbitmq\components\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;

class openShopInitConsumer implements ConsumerInterface
{
	
	//开店初始化
	public function execute(AMQPMessage $msg)
	{
		$data = unserialize($msg->body);
		$sjId = isset($data['sjId']) ? $data['sjId'] : 0;
		$return = MerchantService::openShopInit(['sjId' => $sjId]);
		if ($return == false) {
			//没有初始化成功短信通知管理员
			$merchant = MerchantService::getMerchantById($sjId);
			$name = $merchant['name'];
			$adminMobile = WxOpenService::getAdminMobile();
			sms::freeSend($adminMobile, "花店：{$name}（{$sjId}）初始化没有成功。", $merchant);
		}
		return ConsumerInterface::MSG_ACK;
	}

}