huahuibao/app/saas/controllers/WxController.php

<?php

namespace saas\controllers;

use biz\user\classes\UserClass;
use biz\user\services\UserService;
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);
        $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'];
            $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);//从微信接口获取用户信息
                    $source = UserClass::$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("等您好久，终于等到您 /::)");
                    }

                    //响应扫码的场景事件 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 = 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("^_^");//没有管理员返回的信息
                $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;
    }
}