ok

biz/weixin/classes/WxOpenClass.php

@@ -7,13 +7,22 @@ use biz\base\classes\BaseClass;
 
 class WxOpenClass extends BaseClass
 {
-	
+
 	public static $baseFile = '\biz\weixin\models\WxOpen';
-	
+
+	//平台管理员的手机号
+	const ADMIN_MOBILE = 15280215347;
+
 	//获取开放平台 shish 2020.2.11
 	public static function getOpen()
 	{
 		return self::getById(1);
 	}
 	
+	//获取平台管理员的手机号 shish 2020.3.4
+	public static function getAdminMobile()
+	{
+		return self::ADMIN_MOBILE;
+	}
+	
 }

biz/weixin/models/WxOpen.php

@@ -10,4 +10,6 @@ class WxOpen extends Base
 		return 'xhWxOpen';
 	}
 
+	
+	
 }

biz/weixin/services/WxOpenService.php

@@ -17,4 +17,10 @@ class WxOpenService extends BaseService
 		return WxOpenClass::getOpen();
 	}
 	
+	//获取平台管理员手机号 shish 2020.3.4
+	public static function getAdminMobile()
+	{
+		return WxOpenClass::getAdminMobile();
+	}
+	
 }

common/components/rabbitmq/consumer/openShopInitConsumer.php

@@ -10,6 +10,7 @@ namespace common\components\rabbitmq\consumer;
 
 
 use biz\merchant\services\MerchantService;
+use biz\weixin\services\WxOpenService;
 use common\components\sms;
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;
@@ -20,7 +21,6 @@ class openShopInitConsumer implements ConsumerInterface
 	//开店初始化
 	public function execute(AMQPMessage $msg)
 	{
-		echo 'aaa';
 		$data = unserialize($msg->body);
 		$merchantId = isset($data['merchantId']) ? $data['merchantId'] : 0;
 		$return = MerchantService::openShopInit(['merchantId' => $merchantId]);
@@ -28,11 +28,10 @@ class openShopInitConsumer implements ConsumerInterface
 			//没有初始化成功短信通知管理员
 			$merchant = MerchantService::getMerchantById($merchantId);
 			$merchantName = $merchant['merchantName'];
-			sms::freeSend(15280215347, "花店：{$merchantName}（{$merchantId}）初始化没有成功。", $merchant);
+			$adminMobile = WxOpenService::getAdminMobile();
+			sms::freeSend($adminMobile, "花店：{$merchantName}（{$merchantId}）初始化没有成功。", $merchant);
 		}
-		print_r($data);
-		//return ConsumerInterface::MSG_REQUEUE;
 		return ConsumerInterface::MSG_ACK;
 	}
-	
+
 }