huahuibao/app/saas/controllers/WxController.php

<?php

namespace saas\controllers;

use biz\admin\services\AdminService;
use biz\coupon\services\CouponAssetService;
use biz\user\classes\UserClass;
use biz\user\services\UserService;
use biz\wx\services\WxBaseService;
use biz\wx\services\WxOpenService;
use biz\wx\services\WxSceneService;
use Yii;
use common\services\xhMerchantExtendService;
use common\services\xhShopService;
use common\services\xhWxMenuService;
use common\services\xhAdminService;
use common\services\xhUserAssetService;
use common\services\xhWxOpenService;
use common\components\wxUtil;
use common\components\configDict;
use common\components\stringUtil;
use common\components\util;
use common\services\xhMerchantService;
use common\services\xhUserService;
use common\services\xhTMessageService;
use linslin\yii2\curl;

/**
 * 微信公众号相关
 */
class WxController extends PublicController
{
	
	public $fromUsername, $toUsername, $msgType;
	
	/**
	 * 首页入口地址
	 */
	public function actionApi()
	{
		$postData = file_get_contents('php://input');
		if (isset ($postData) == false || empty($postData)) {
			util::stop('没有接收到POST数据');
		}
		$get = Yii::$app->request->get();
		if (isset($get['appId']) == false || empty($get['appId'])) {
			util::stop('没有取到公众号的appId');
		}
		$weixinSecret = Yii::getAlias("@vendor/weixinSecret");
		require_once($weixinSecret . '/wxBizMsgCrypt.php');
		$appId = $get['appId'];//公众号appId
		$encryptMsg = $postData;
		//取开放平台信息
		$openId = configDict::getConfig('openId');
		$open = xhWxOpenService::getById($openId);
		$wxBaseId = isset($open['wx_base_id']) ? $open['wx_base_id'] : 0;
		if (empty($wxBaseId)) {
			Yii::warning('平台还没有绑定公众号');
			Yii::$app->end();
		}
		$wxBase = WxBaseService::getById($wxBaseId);
		if (empty($wxBase)) {
			Yii::warning('平台公众号信息无效');
			Yii::$app->end();
		}
		$wxBaseAppId = isset($wxBase['wxAppId']) ? $wxBase['wxAppId'] : '';
		
		$encodingAesKey = $open['aesKey'];
		$openToken = $open['token'];
		$openAppId = $open['appId'];
		$signature = isset($get['signature']) ? $get['signature'] : '';
		$encrypt_type = isset($get['encrypt_type']) ? $get['encrypt_type'] : '';//签名串，对应URL参数的msg_signature
		$msg_signature = isset($get['msg_signature']) ? $get['msg_signature'] : '';
		$timestamp = isset($get['timestamp']) ? $get['timestamp'] : '';
		$nonce = isset($get['nonce']) ? $get['nonce'] : '';
		$xml_tree = new \DOMDocument();
		$xml_tree->loadXML($encryptMsg);
		$array_e = $xml_tree->getElementsByTagName('Encrypt');
		$encrypt = $array_e->item(0)->nodeValue;
		$format = "<xml><ToUserName><![CDATA[toUser]]></ToUserName><Encrypt><![CDATA[%s]]></Encrypt></xml>";
		$from_xml = sprintf($format, $encrypt);
		
		//签名串，对应URL参数的msg_signature -- (接收微信传过来的加密会出问题，故只在自己测试时打开以下注释)
		/*$array_s = $xml_tree->getElementsByTagName('MsgSignature');
		$msg_sign = $array_s->item(0)->nodeValue;
		if($msg_signature == ''){
			$msg_signature = $msg_sign;
		}*/
		
		// 第三方收到公众号平台发送的消息
		$pc = new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
		$msg = '';//解密后的消息
		$errCode = $pc->decryptMsg($msg_signature, $timestamp, $nonce, $from_xml, $msg);//解密
		if ($errCode != 0) {
			$errMsg = '商户：' . $open['name'] . "，解密未成功，错误代码：" . $errCode;
			Yii::warning($errMsg, __METHOD__);
			Yii::$app->end();
		}
		$postObj = simplexml_load_string($msg, 'SimpleXMLElement', LIBXML_NOCDATA);
		$this->fromUsername = $postObj->FromUserName; // 发送方账号 openId
		$this->toUsername = $postObj->ToUserName; // 开发者微信账号
		$times = $postObj->CreateTime; // 消息创建时间
		$Location_X = $postObj->Location_X; // 地理位置纬度(用户主动发送)
		$Location_Y = $postObj->Location_Y; // 地理位置经度(用户主动发送)
		$Scale = $postObj->Scale; // 地图缩放大小(用户主动发送)
		$Label = $postObj->Label; // 地理位置信息(用户主动发送)
		$PicUrl = $postObj->PicUrl; // 图片链接
		$this->msgType = $postObj->MsgType; // 消息类型
		$MsgId = $postObj->MsgId; // 消息ID
		$Url = $postObj->Url; // 消息链接
		$Event = strtolower($postObj->Event); // 事件类型
		$EventKey = $postObj->EventKey; // 事件KEY值
		$ticket = $postObj->Ticket;//扫描二维码的TICKET
		$Latitude = $postObj->Latitude; // 地理位置纬度(自动获取)
		$Longitude = $postObj->Longitude;//地理位置经度(自动获取)
		$Precision = $postObj->Precision;//地理位置精度(自动获取)
		$MediaId = $postObj->MediaId;//图片媒体id
		$Content = trim($postObj->Content); // 消息内容

		Yii::info('$wxBaseAppId:' . $wxBaseAppId . " $appId:" . $appId);

		if ($wxBaseAppId == $appId) {
			if ($this->msgType == 'event') {
				
				switch ($Event) {
					//关注
					case 'subscribe':
						$merchant = WxOpenService::getWxInfo();
						$getUserInfo = wxUtil::userInfo($this->fromUsername, $merchant, 1);
						$source = UserClass::$userSourceId['official']['name'];
						$getUserInfo['subscribe'] = 1;
						AdminService::replaceAdmin($getUserInfo, $source);
						$text = $this->replyTextContent("等您好久，终于等到您 /::)");
						$pc = new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
						$encryptMsg = '';
						$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
						echo $encryptMsg;
						break;
					//取消关注
					case 'unsubscribe':
						$admin = AdminService::getByOpenId($this->fromUsername);
						if (!empty($admin)) {
							$adminId = $admin['id'];
							AdminService::unFocus($adminId);
						}
						break;
					default:
				}
			}
		} else {
			$merchant = xhMerchantService::getByAppId($appId);
			$account = 0;
			$merchantId = 0;
			$merchantExtend = [];
			$now = time();
			if (!empty($merchant)) {
				$account = $merchant['id'];
				$merchantId = $merchant['id'];
				$merchantExtend = xhMerchantExtendService::getByMerchantId($merchantId);
			}
			$user = xhUserService::getByOpenId($this->fromUsername, $merchantId);
			$userId = 0;
			$userAsset = [];
			if (!empty($user)) {
				$userId = $user['id'];
				$userAsset = xhUserAssetService::getByUserId($userId);
			}
			
			
			if ($this->msgType == 'event') {
				/*
							//全网发布，1 事件消息响应
							$content = $postObj->Event."from_callback";
							$createTime = time (); // 响应当前时间
							$type = "text";
							$text = "<xml>
							<ToUserName><![CDATA[{$this->fromUsername}]]></ToUserName>
							<FromUserName><![CDATA[gh_3c884a361561]]></FromUserName>
							<CreateTime>{$createTime}</CreateTime>
							<MsgType><![CDATA[{$type}]]></MsgType>
							<Content><![CDATA[{$content}]]></Content>
							</xml>";
							$pc									= new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
							$encryptMsg							= '';
							$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
							echo $encryptMsg;
							Yii::$app->end();
				*/
				switch ($Event) {
					//关注
					case 'subscribe':
						$getUserInfo = wxUtil::userInfo($this->fromUsername, $merchant);//从微信接口获取用户信息
						if (!empty($getUserInfo)) {
							$source = UserClass::$userSourceId['official']['name'];
							$user = UserService::replaceUser($getUserInfo, $source, $merchantId);
							$userId = $user['id'];
							UserService::focus($user, $merchant);
							//响应扫码的场景事件 shish 2019.9.5
							if (strstr($EventKey, 'qrscene_')) {
								Yii::info($EventKey);
								$sceneId = str_replace('qrscene_', '', $EventKey);
								WxSceneService::respondScanEvent($merchant, $user, (string)$sceneId);
							}
						}
						$pc = new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
						$encryptMsg = '';
						$text = $this->replyTextContent("等您好久，终于等到您 /::)");
						$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
						echo $encryptMsg;
						
						//获得新优惠券通知
						CouponAssetService::hasNewCouponNotice($user, $merchant);
						
						break;
					//取消关注
					case 'unsubscribe':
						UserService::unFocus($userId, $merchantId);
						break;
					//自定义菜单回复
					case 'click':
						$menuKey = $EventKey;
						$menu = xhWxMenuService::getByMenuKey($menuKey);
						$wxMenuOption = $menu['menuOption'];
						$wxMenuOptionList = configDict::getConfig('wxMenuOption');
						switch ($wxMenuOption) {
							case $wxMenuOptionList['showText']://链接到-文字
								$replyContent = $menu['replyText'];
								$text = $this->replyTextContent($replyContent);
								$pc = new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
								$encryptMsg = '';
								$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
								echo $encryptMsg;
								break;
							default:
						}
						break;
					
					//门店申请
					case 'poi_check_notify':
						if ($postObj->Result == 'succ') {
							$shop['status'] = 2;
							xhShopService::updateByPoiId($postObj->PoiId, $shop);
							Yii::warning('poiId: ' . $postObj->PoiId . '<=>微信门店审核记录： ' . $postObj->msg . '， 时间：' . date('Y-m-d H:i:s', time()));
						} elseif ($postObj->Result == 'fail') {
							$shop['status'] = 4;
							xhShopService::updateByPoiId($postObj->PoiId, $shop);
							Yii::warning('poiId: ' . $postObj->PoiId . '<=>微信门店审核失败： ' . $postObj->msg . '， 时间：' . date('Y-m-d H:i:s', time()));
						} else {
							Yii::warning('poiId: ' . $postObj->PoiId . '<=>微信门店审核异常记录： ' . $postObj->msg . '， 时间：' . date('Y-m-d H:i:s', time()));
							throw new \Exception('微信门店申请返回异常');
						}
						break;
					
					case 'view':
						break;
					case 'scan':
						//响应扫码的场景事件 shish 2019.9.5
						Yii::info('a' . $EventKey);
						
						WxSceneService::respondScanEvent($merchant, $user, (string)$EventKey);
						break;
					default:
						Yii::warning("该EVENT类型未定义，EVENT:" . $Event);
				}
				
			} elseif ($this->msgType == 'text') {
				/*
							//全网发布，3 api客服接口回应
							if(strpos($Content,'QUERY_AUTH_CODE:') !== false){
								//返回空字符，表示暂不回复
								$content	= "";
								$FuncFlag = 0;
								$type	= "text";
								$createTime = time (); // 响应当前时间
								$text = "<xml>
								<ToUserName><![CDATA[{$this->fromUsername}]]></ToUserName>
								<FromUserName><![CDATA[gh_3c884a361561]]></FromUserName>
								<CreateTime>{$createTime}</CreateTime>
								<MsgType><![CDATA[{$type}]]></MsgType>
								<Content><![CDATA[{$content}]]></Content>
								</xml>";
								$pc					= new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
								$encryptMsg			= '';
								$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
								echo $encryptMsg;

								$ticket = str_replace('QUERY_AUTH_CODE:','',$Content);
								$authorizer = wxUtil::getAuthorizer($ticket);
								//Yii::warning("authorizer:".json_encode($authorizer));
								$info 							= $authorizer['authorization_info'];
								$authorizer_appid				= $info['authorizer_appid'];
								$authorizer_access_token		= $info['authorizer_access_token'];
								//Yii::warning("authorizer_access_token:".$authorizer_access_token);
								$url		= "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token={$authorizer_access_token}";
								$con		= $ticket."_from_api";
								$data		= ["touser" => "{$this->fromUsername}","msgtype" => "text","text"=>["content" => $con]];
								$curl		= new curl\Curl();
								$result		= $curl->setOption(CURLOPT_POSTFIELDS,json_encode($data))->post($url);
								$result		= Json::decode($result);
								//Yii::warning("fromUsername:".$this->fromUsername.' toUsername:'.$this->toUsername);
								//Yii::warning(" ticket: ~ ".$ticket.' | json:'.json_encode($result),__METHOD__);
								Yii::$app->end();
							}

							switch($Content){
								 //全网发布，2 发送文本消息
								case 'TESTCOMPONENT_MSG_TYPE_TEXT':
								$content	= "TESTCOMPONENT_MSG_TYPE_TEXT_callback";
								$FuncFlag = 0;
								$type	= "text";
								$createTime = time ();
								$text = "<xml>
								<ToUserName><![CDATA[{$this->fromUsername}]]></ToUserName>
								<FromUserName><![CDATA[gh_3c884a361561]]></FromUserName>
								<CreateTime>{$createTime}</CreateTime>
								<MsgType><![CDATA[{$type}]]></MsgType>
								<Content><![CDATA[{$content}]]></Content>
								</xml>";
								$pc					= new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
								$encryptMsg			= '';
								$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);
								echo $encryptMsg;
								break;

						}
				*/
				$adminSendMsg = false;
				$openMerchant = xhWxOpenService::getMerchant();
				$openMerchantId = $openMerchant['id'];
				
				if ($adminSendMsg == false) {
					$lastTimeKey = "customer_{$userId}:merchant_{$merchantId}_new_msg_last_time";//最后一次会话时间key
					//将消息内容转发到管理员微信上
					//$admin = xhAdminToMerchantService::getAdminByMerchantId($merchantId);
					$admin = [];
					if (!empty($admin)) {
						$adminOpenId = $admin['openId'];
						$adminId = $admin['id'];
						//获取最后一次会话时间。如果是首次会话或中断对话持续100秒，则通过发公众号通知有新消息
						$connect = Yii::$app->redis->executeCommand('GET', [$lastTimeKey]);
						if (empty($connect) || ($now - $connect) >= 100) {
							$allTM = xhTMessageService::getList($openMerchantId);
							$shortTempId = 'OPENTM200605630';
							if (isset($allTM[$shortTempId])) {
								$tempId = $allTM[$shortTempId];
								$data = [
									"touser" => $adminOpenId,
									"template_id" => $tempId,
									"url" => Yii::$app->params['adminUrl'] . "/chat/index?customId=" . $userId,
									"data" => ["first" => ["value" => "{$user['userName']} 向您的公众号发来新消息", "color" => "#173177"],
										"keyword1" => ["value" => '新消息', "color" => "#173177"],
										"keyword2" => ["value" => '文字', "color" => "#173177"],
										"remark" => ["value" => '点击查看详情', "color" => "#173177"]
									]
								];
								wxUtil::sendTaskInform($data, $openMerchant);
							}
							//设置商家与用户最后一次会话时间。
							Yii::$app->redis->executeCommand('SET', [$lastTimeKey, $now]);
							Yii::$app->redis->executeCommand('EXPIRE', [$lastTimeKey, 100]);//过期
						}
						
						//swoole:商家是否在线
						$customId = $userId;//客户uid
						xhUserService::getById($customId);//把客户用户数据存入缓存，预防清缓存，取不到客户数据
						
						//在线，通过socket给商家发消息
						define('WEBPATH', __DIR__);
						define('ROOT_PATH', __DIR__);
						//Swoole框架自动载入器初始化
//					\Swoole\Loader::vendorInit();
//					$serverIp = util::serverIP();
//					$client = new \Swoole\Client\WebSocket($serverIp, 9503, '/');
//					if (!$client->connect()) {
//						echo "connect to server failed.\n";
//						exit;
//					}
						//from: 客户的clientId(无)； to：商家的clientId
						$sendData = [
							'cmd' => 'sendMsgC2M',
							'from' => -1,//可能未在线
							'to' => 0,
							'uid' => $customId,//客户id
							'chatUid' => $merchantId,//商家id
							'chatLogKey' => "merchant_history_{$merchantId}_{$customId}",//消息记录缓存key
							'channal' => 1,
							'data' => $Content,
							'type' => 'text'
						];

//					$client->send(json_encode($sendData));
						//$message = $client->recv();
						
						
						//表情替换
						/*$imgUrl			= $this->imgUrl;
						$emotionCode	= qqFaceUtil::getEmojiCode($imgUrl);
						foreach($emotionCode as $key => $val){
							$zz			= $val[0];
							$img		= $val[1];
							$name		= $val[2];
							$Content 	= str_replace($zz,$img,$Content);
						}
						Yii::$app->redis->executeCommand('LPUSH', ["merchant_get_{$merchantId}_{$userId}", $now.'{~CHAT~}themself{~CHAT~}'.$Content]);*/
						//util::end();
					}
					
					//给客户微信返回（打开聊天界面的模板消息通知）
					$userTest = false;
					if (!empty($userTest)) {
						$userOpenId = $user['openId'];
						
						$allTM = xhTMessageService::getList($merchantId);
						$shortTempId = 'OPENTM200605630';
						if (isset($allTM[$shortTempId])) {
							$tempId = $allTM[$shortTempId];
							$data = [
								"touser" => $userOpenId,
								"template_id" => $tempId,
								"url" => Yii::$app->params['frontUrl'] . "/chat/index?account=" . $account,
								"data" => ["first" => ["value" => "亲，有什么需要可以帮到您，点此联系客服。", "color" => "#173177"],
									"keyword1" => ["value" => '前往聊天页', "color" => "#173177"],
									"keyword2" => ["value" => '文字', "color" => "#173177"],
									"remark" => ["value" => '点击与客服聊天', "color" => "#173177"]
								]
							];
							wxUtil::sendTaskInform($data, $merchant);
						}
						util::end();
					}
					//$text = $this->replyTextContent("^_^");
					$text = $this->replyTextContent(Yii::$app->params['mallDomain'] . '/#/?account=' . $merchantId);
					$pc = new \WXBizMsgCrypt($openToken, $encodingAesKey, $openAppId);
					$encryptMsg = '';
					$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
					echo $encryptMsg;
				}
			} elseif ($this->msgType == 'image') {
				$PicUrl = (string)$PicUrl;
				if (empty($PicUrl)) {
					util::end();
				}
				$folder = Yii::getAlias('@webroot') . '/../../images';
				$pre = '/weixinChat/' . date('Y') . '/' . date('m') . '/' . date("d") . '/';
				if (!file_exists($folder . $pre)) {
					mkdir($folder . $pre, 0777, true);
				}
				$preFileName = substr(md5($userId), -4);
				$preName = $preFileName . stringUtil::buildOrderNo();
				$extName = '.jpg';
				$name = $preName . $extName;
				$fullFileName = $folder . $pre . $name;
				$fileName = $pre . $name;
				$curl = new curl\Curl();
				$result = $curl->get($PicUrl);
				$fp2 = @fopen($fullFileName, 'a');//文件大小
				fwrite($fp2, $result);
				fclose($fp2);
				//生成300缩略图
				$dstImg300 = $folder . $pre . $preName . '_300.' . $extName;
				$img2thumbReturn = util::img2thumb($fullFileName, $dstImg300, $width = 300, $height = 0, $cut = 0, $proportion = 0);
				$srcImgWidth = isset($img2thumbReturn['width']) ? $img2thumbReturn['width'] : 0;
				$srcImgHeight = isset($img2thumbReturn['height']) ? $img2thumbReturn['height'] : 0;
				$invalid = '/images/invalid.jpg';
				$Content = '<img onclick="previewImg(this)" onerror="javascript:this.src=\'' . $invalid . '\'" src="' . $this->imgUrl . $pre . $preName . '_300.' . $extName . '" bigImgSrc="' . $this->imgUrl . $pre . $preName . $extName . '" widthNum="' . $srcImgWidth . '" heightNum="' . $srcImgHeight . '" style="width:100px;height:auto;"  />';
				//将图片转发到管理员微信上
				$adminId = $merchant['adminId'];
				$admin = xhAdminService::getById($adminId);
				if (empty($admin)) {
					util::stop('没有管理员');
				}
				$adminOpenId = $admin['openId'];
				$adminId = $admin['id'];
				//获取商家与用户最后一次会话时间。如果是首次会话或中断对话持续100秒，则通过发公众号通知有新消息
				$connect = Yii::$app->redis->executeCommand('GET', ["merchant_{$merchantId}_new_msg_last_time"]);
				if (empty($connect) || ($now - $connect) > 100) {
					$allTM = xhTMessageService::getList($merchantId);
					$shortTempId = 'OPENTM200605630';
					if (isset($allTM[$shortTempId])) {
						$tempId = $allTM[$shortTempId];
						$data = [
							"touser" => $adminOpenId, "template_id" => $tempId, "url" => "",
							"data" => ["first" => ["value" => "{$user['userName']} 发来图片", "color" => "#173177"],
								"keyword1" => ["value" => '新消息', "color" => "#173177"],
								"keyword2" => ["value" => '图片', "color" => "#173177"],
								"remark" => ["value" => '请登陆后台查看', "color" => "#173177"]]];
						wxUtil::sendTaskInform($data, $merchant);
					}
				}
				//记录商家的新消息用户有谁。
				Yii::$app->redis->executeCommand('ZADD', ["merchant_{$merchantId}_new_msg", $now, "{$userId}"]);
				//记录商家的最近联系人
				Yii::$app->redis->executeCommand('ZADD', ["merchant_{$merchantId}_history_chat_user", $now, "{$userId}"]);
				//设置商家与用户最后一次会话时间。
				Yii::$app->redis->executeCommand('SETEX', ["merchant_{$merchantId}_new_msg_last_time", 100, $now]);
				//商家需要接收的消息。key里 第二个参数 ourself表示自己的消息 themself表示对方的消息 {~CHAT~} 表示分隔符
				Yii::$app->redis->executeCommand('LPUSH', ["merchant_get_{$merchantId}_{$userId}", $now . '{~CHAT~}themself{~CHAT~}' . $Content]);
			} elseif ($this->msgType == 'voice') {
				$Content = '<span voiceId="' . $MediaId . '">【提示】客户发来一条语音消息，请登陆微信公众号后台查看。</span>';
				$adminId = $merchant['adminId'];
				$admin = xhAdminService::getById($adminId);
				if (empty($admin)) {
					Yii::warning("没有管理员,merchantId:" . $merchantId);
					util::end();
				}
				$adminOpenId = $admin['openId'];
				$adminId = $admin['id'];
				//获取商家与用户最后一次会话时间。如果是首次会话或中断对话持续100秒，则通过发公众号通知有新消息
				$connect = Yii::$app->redis->executeCommand('GET', ["merchant_{$merchantId}_new_msg_last_time"]);
				if (empty($connect) || ($now - $connect) > 100) {
					$allTM = xhTMessageService::getList($merchantId);
					$shortTempId = 'OPENTM200605630';
					if (isset($allTM[$shortTempId])) {
						$tempId = $allTM[$shortTempId];
						$data = ["touser" => $adminOpenId, "template_id" => $tempId, "url" => "",
							"data" => [
								"first" => ["value" => "{$user['userName']} 发来语音", "color" => "#173177"],
								"keyword1" => ["value" => '新消息', "color" => "#173177"],
								"keyword2" => ["value" => '语音', "color" => "#173177"],
								"remark" => ["value" => '消息内容：请登陆后台查看', "color" => "#173177"]]];
						wxUtil::sendTaskInform($data, $merchant);
					}
				}
				//记录商家的新消息用户有谁。
				Yii::$app->redis->executeCommand('ZADD', ["merchant_{$merchantId}_new_msg", $now, "{$userId}"]);
				//记录商家的最近联系人
				Yii::$app->redis->executeCommand('ZADD', ["merchant_{$merchantId}_history_chat_user", $now, "{$userId}"]);
				//设置商家与用户最后一次会话时间。
				Yii::$app->redis->executeCommand('SETEX', ["merchant_{$merchantId}_new_msg_last_time", 100, $now]);
				//商家需要接收的消息。key里 第二个参数 ourself表示自己的消息 themself表示对方的消息 {~CHAT~} 表示分隔符
				Yii::$app->redis->executeCommand('LPUSH', ["merchant_get_{$merchantId}_{$userId}", $now . '{~CHAT~}themself{~CHAT~}' . $Content]);
			} elseif ($this->msgType == 'video') {
			
			} elseif ($this->msgType == 'location') {
			
			} elseif ($this->msgType == 'link') {
			
			} else {
			
			}
		}
	}
	
	/**
	 * 回复文字消息
	 */
	private function replyTextContent($content)
	{
		$createTime = time();//响应当前时间
		$con = "<xml>
		<ToUserName><![CDATA[{$this->fromUsername}]]></ToUserName>
		<FromUserName><![CDATA[{$this->toUsername}]]></FromUserName>
		<CreateTime>{$createTime}</CreateTime>
		<MsgType><![CDATA[text]]></MsgType>
		<Content><![CDATA[{$content}]]></Content>
		</xml>";
		return $con;
	}
	
	/**
	 * 回复图片消息
	 */
	private function replyPicContent($media_id)
	{
		$createTime = time();
		$con = "<xml>
        <ToUserName><![CDATA[{$this->toUsername}]]></ToUserName>
        <FromUserName><![CDATA[{$this->fromUsername}]]></FromUserName>
        <CreateTime>{$createTime}</CreateTime>
        <MsgType><![CDATA[image]]></MsgType>
        <Image>
        <MediaId><![CDATA[{$media_id}]]></MediaId>
        </Image>
        </xml>";
		return $con;
	}
	
	/**
	 * 回复单图文消息
	 */
	private function replyNewsContent($title, $desc, $picUrl, $url)
	{
		$createTime = time();//响应当前时间
		$con = "<xml>
		<ToUserName><![CDATA[{$this->fromUsername}]]></ToUserName>
		<FromUserName><![CDATA[{$this->toUsername}]]></FromUserName>
		<CreateTime>{$createTime}</CreateTime>
		<MsgType><![CDATA[news]]></MsgType>
		<ArticleCount>1</ArticleCount><Articles>
		<item>
			<Title><![CDATA[{$title}]]></Title>
			<Description><![CDATA[{$desc}]]></Description>
			<PicUrl><![CDATA[{$picUrl}]]></PicUrl>
			<Url><![CDATA[{$url}]]></Url>
		</item>
		</Articles></xml>";
		return $con;
	}
	
	/**
	 * 回复视频消息
	 * @param $title
	 * @param $media_id
	 * @param $description
	 * @return string
	 */
	private function replyVideoContent($title, $media_id, $description)
	{
		
		$createTime = time();//响应当前时间
		$con = "<xml>
        <ToUserName><![CDATA[{$this->toUsername}]]></ToUserName>
        <FromUserName><![CDATA[{$this->fromUsername}]]></FromUserName>
        <CreateTime>{$createTime}</CreateTime>
        <MsgType><![CDATA[video]]></MsgType>
        <Video>
        <MediaId><![CDATA[{$media_id}]]></MediaId>
        <Title><![CDATA[{$title}]]></Title>
        <Description><![CDATA[{$description}]]></Description>
        </Video> 
        </xml>";
		
		return $con;
	}
}