huahuibao/app/business/controllers/ChatController.php

<?php

namespace business\controllers;

use biz\goods\services\GoodsService;
use biz\merchant\services\MerchantService;
use biz\user\services\UserService;
use common\components\business;
use Yii;
use common\components\util;
use GatewayClient\Gateway;

class ChatController extends BaseController
{
	
	//聊天 shish 2019.12.28
	public function actionIndex()
	{
		$get = Yii::$app->request->get();
		$userId = isset($get['userId']) ? $get['userId'] : 0;
		$user = UserService::getById($userId);
		UserService::valid($user, $this->merchantId);
		return $this->renderPartial('index', ['userId' => $userId]);
	}
	
	//绑定 shish 2019.12.28
	public function actionBind()
	{
		$post = Yii::$app->request->post();
		$clientId = isset($post['clientId']) ? $post['clientId'] : '';
		$id = 'merchant_' . $this->merchantId;
		Gateway::bindUid($clientId, $id);
	}
	
	//发消息给客户 shish 2019.12.28
	public function actionSend()
	{
		$post = Yii::$app->request->post();
		$type = isset($post['type']) ? $post['type'] : 'text';
		$userId = isset($post['userId']) ? $post['userId'] : 0;
		$user = UserService::getById($userId);
		UserService::valid($user, $this->merchantId);
		$arr = [];
		$arr['type'] = $type;
		
		switch ($type) {
			case 'text':
				//文字
				$content = $post['content'];
				$arr['content'] = $content;
				break;
			case 'img':
				//图片
				$shortUrl = $post['shortUrl'];
				$return = business::formatUploadImg($shortUrl);
				$arr['url'] = $return['url'];
				$arr['smallUrl'] = $return['smallUrl'];
				break;
			case 'link':
				//常用链接
				$id = $post['id'];
				$respond = MerchantService::getCommonUrl($id);
				$arr['name'] = $respond['name'];
				$arr['img'] = $respond['img'];
				$arr['url'] = $respond['url'];
				break;
			case 'goods':
				//商品
				$id = $post['id'];
				$info = GoodsService::getGoodsInfo($id);
				GoodsService::valid($info, $this->merchantId);
				$arr['goodsName'] = $info['goodsName'];
				$arr['img'] = isset($info['smallImgList'][0]) ? $info['smallImgList'][0] : '';
				$arr['price'] = isset($info['price']) ? $info['price'] : 300;
				break;
		}

		$data[] = $arr;

		//每隔三分钟显示时间
		$minute = (int)date("i");
		if ($minute % 3 == 0) {
			$time = date("i:s");
			$data[] = ['type' => 'time', 'time' => $time];
		}
		Gateway::sendToUid($userId, json_encode($data));
		util::success($data);
	}

}