hemall.terabimsoft.com.cn/app/frontend/modules/wechat/controllers/IndexController.php

<?php

namespace app\frontend\modules\wechat\controllers;

use app\common\components\BaseController;
use app\common\facades\EasyWeChat;
use app\common\models\AccountWechats;
use app\common\models\frame\Rule;
use app\common\models\frame\RuleKeyword;
use app\common\models\QrCode;

/**
 * Created by PhpStorm.
 * Author: 芸众商城 www.yunzshop.com
 * Date: 2017/3/3
 * Time: 22:16
 */
class IndexController extends BaseController
{
    public function __construct()
    {
        $this->init();
    }

    public function init()
    {
        $uniacid = request('id');

        //设置uniacid
        \YunShop::app()->uniacid = $uniacid;
        \Setting::$uniqueAccountId = $uniacid;
        //设置公众号信息
        AccountWechats::setConfig(AccountWechats::getAccountByUniacid($uniacid));
    }

    public function index()
    {
        \Log::debug('----------公众号消息---------',$_GET);
        // 接入判断
        if ( isset( $_GET["signature"] ) && isset( $_GET["timestamp"] ) && isset( $_GET["nonce"] ) && isset( $_GET["echostr"] ) ) {
            $signature = $_GET["signature"];
            $timestamp = $_GET["timestamp"];
            $nonce     = $_GET["nonce"];
            $token = \Setting::get('plugin.wechat.token');
            $tmpArr    = [ $token, $timestamp, $nonce ];
            sort( $tmpArr, SORT_STRING );
            $tmpStr = implode( $tmpArr );
            $tmpStr = sha1( $tmpStr );
            if ( $tmpStr == $signature ) {
                \Log::debug('----------公众号接入成功---------',$_GET);
                \Setting::set('plugin.wechat.status', 1);
                \Log::debug('----------公众号接入成功状态---------',\Setting::get('plugin.wechat.status'));
                ob_clean();
                return $_GET["echostr"];
            } else {
                \Log::debug('----------公众号接入失败---------',$_GET);
            }
        } else {// 不是接入，则触发事件，交给监听者处理.
            // 获取第三方库easyWechat的app对象
            $wechatApp = EasyWeChat::officialAccount();
            $server = $wechatApp->server;
            try {
                $message = $server->getMessage();// 异常代码

                $plugin = $this->checkPlugin($message);
                event(new \app\common\events\WechatMessage($wechatApp,$server,$message,$plugin));

                if (\Setting::get('plugin.wechat.is_open')) {//公众号开启，才进行事件触发
//                    event(new \app\common\events\WechatMessage($wechatApp,$server,$message,$plugin));
                    if($message['Event']=="subscribe" && app('plugins')->isEnabled('pet')){
                        event(new \app\common\events\PetWeChatEvent($_GET));
                    }
                }
                return 'success';
            } catch (\Exception $exception) {
                \Log::debug('----------公众号异常---------',$exception->getMessage());
            }
        }
    }

    protected function checkPlugin($message)
    {
        if ($message['MsgType'] == 'event') {
            $keyword = '';
            if ($message['Event'] == 'SCAN') {
                $eventKey = $message['EventKey'];
                $qrCode = QrCode::uniacid()->where('scene_str', $eventKey)->first();
                if (empty($qrCode)) {
                    return '';
                }
                $keyword = $qrCode->keyword;
            } elseif ($message['Event'] == 'CLICK') {
                $keyword = $message['EventKey'];
            } elseif ($message['Event'] == 'TEMPLATESENDJOBFINISH') {
                exit('success');    //发送模板消息的回调推送事件直接返回success
            }
        } elseif ($message['MsgType'] == 'text') {
            $keyword = $message['Content'];
        } else {
             return '';
        }

        if (!$keyword) {
            return '';
        }
        $keyword = RuleKeyword::uniacid()->where(['content'=>$keyword, 'status'=>1])->first();
        if (!$keyword) {
            return '';
        }
        $rule = Rule::find($keyword->rid);
        if (!$rule) {
            return '';
        }
        $names = explode(':', $rule['name']);
        $plugin = isset($names[1]) ? $names[1] : '';

        return $plugin;
    }
}