huahuibao/app/openend/controllers/WxController.php

<?php

namespace openend\controllers;

use biz\tool\services\GuaGuaService;
use biz\user\services\UserService;
use biz\weixin\services\WxSceneService;
use Yii;
use common\services\xhCouponService;
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\weixinUtil;
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;
use common\services\xhAdminToMerchantService;
use common\components\qqFaceUtil;

class WxController extends PublicController
{
	public $enableCsrfValidation = false;
	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);
		$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['openName'] . "，解密未成功，错误代码：" . $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); // 消息内容
		$merchant = xhMerchantService::getByAppId($appId);
		$account = 0;
		$merchantId = 0;
		$merchantExtend = [];
		$now = time();
		if (!empty($merchant)) {
			$account = $merchant['id'];
			$merchantId = $merchant['id'];
			Yii::$app->params['merchantId'] = $merchantId;
			$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 = weixinUtil::userInfo($this->fromUsername, $merchant);//从微信接口获取用户信息
					$source = UserService::$userSourceId['official']['name'];
					Yii::info('关注公众号，获得用户信息：' . json_encode($getUserInfo));
					$user = UserService::replaceUser($getUserInfo, $source, $merchantId);
					$userId = $user['id'];
					$text = $this->replyTextContent("等您好久，终于等到您~\n\n注册会员享折扣哦，<a href='" . Yii::$app->params['frontUrl'] . "/center/right?account={$merchant['id']}'>详情</a>");
					if ($merchant['merchantName'] == '花卉宝') {
						$text = $this->replyTextContent("等您好久，终于等到您 /::)");
					}
					
					if (isset($merchantExtend['giveCoupon']) && !empty($merchantExtend['giveCoupon'])) {//关注公众号，赠送代金劵
						if (empty($user['hasSubscribe'])) {//没有关注过公众号
							$giveCouponPrice = $merchantExtend['giveCouponPrice'];
							$couponMeetPrice = $merchantExtend['couponMeetPrice'];
							//xhCouponService::focusGiveCoupon($userId, $merchant, $merchantExtend);
							//$text = $this->replyTextContent("等您好久，终于等到您~\n\n恭喜您，获得一张<a href='" . Yii::$app->params['frontUrl'] . "/center/coupon?account={$merchant['id']}'>代金劵</a>，注册会员更多福利哦，<a href='" . Yii::$app->params['frontUrl'] . "/center/right?account={$merchant['id']}'>详情</a>");
						}
					}
					
					//响应扫码的场景事件 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 = '';
					$pc->encryptMsg($text, $timestamp, $nonce, $encryptMsg);//加密
					echo $encryptMsg;
					
					$admin = xhAdminService::getByOpenId($this->fromUsername);
					if (!empty($admin)) {
						$adminId = $admin['id'];
						xhAdminService::updateById($adminId, ['subscribe' => 1]);
					}
					
					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 = weixinOpenUtil::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);
				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"]
								]
							];
							weixinUtil::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"]
							]
						];
						weixinUtil::sendTaskInform($data, $merchant);
					}
					util::end();
				}
				//刮刮卡
				if ($Content == '我要花') {
					$id = GuaGuaService::getNewestId();//取最新的活动id
					$text = $this->replyTextContent("会员日抽奖链接：".Yii::$app->params['mobileUrl']."/gua/index?account={$merchantId}&id=" . $id);//没有管理员返回的信息
				} else {
					$text = $this->replyTextContent("^_^");//没有管理员返回的信息
				}
				
				$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"]]];
					weixinUtil::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"]]];
					weixinUtil::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;
	}
}