init

app/www/controllers/WxOpenController.php

@@ -154,16 +154,16 @@ class WxOpenController extends PublicController
 		$upData['wxRefreshToken'] = $authorize_refresh_token;
 		$upData['status'] = 1;//审核通过
 		xhMerchantService::updateById($id, $upData);
-
+		
 		//还没有完成初始化先进行初始化
 		$extend = MerchantExtendClass::getByMerchantId($id);
 		if (isset($extend['init']) && $extend['init'] == 0) {
-			$data = ['merchantId' => $merchantId, 'platform' => 1];
+			$data = ['merchantId' => $merchantId];
 			$producer = Yii::$app->rabbitmq->getProducer('openShopInitProducer');
 			$msg = serialize($data);
 			$producer->publish($msg, 'openShopInitExchange', 'openShopInitRoute');
 		}
-
+		
 		echo 'ok';
 	}
 	

common/components/rabbitmq/consumer/openShopInitConsumer.php

@@ -29,7 +29,7 @@ class openShopInitConsumer implements ConsumerInterface
 			$merchantName = $merchant['merchantName'];
 			sms::freeSend(15280215347, "花店：{$merchantName}（{$merchantId}）初始化没有成功。", $merchant);
 		}
-		//print_r($data);
+		print_r($data);
 		//return ConsumerInterface::MSG_REQUEUE;
 		return ConsumerInterface::MSG_ACK;
 	}