hlm_pl_mall/app/api/controller/Wechat.php

<?php

/**
 * 公众号行为处理
 */

namespace app\api\controller;

use think\facade\Db;
use app\api\controller\WechatApi;

/**
 * ============================================================================
 * 
 * ============================================================================
 * 
 * ----------------------------------------------------------------------------
 * 
 * ============================================================================
 * 微信控制器
 */
class Wechat extends MobileMall
{
    public $type;
    public $wxid;
    public $data;
    public $weixin;

    public function index()
    {
        //获取配置信息
        $wxConfig = model('wechat')->getOneWxconfig();
        $this->weixin = new WechatApi($wxConfig);
        $this->weixin->valid();
        $this->type = $this->weixin->getRev()->getRevType();  //获取消息类型MsgType
        $this->wxid = $this->weixin->getRev()->getRevFrom();  //获取消息类型MsgId
        $this->data = $this->weixin->getRevData();            //把获取的消息进行转码
        $reMsg = '';

        switch ($this->type) {
                //接收普通消息-文本消息
            case 'text':
                $content = $this->weixin->getRev()->getRevContent();
                break;
                //接收事件推送 事件类型，subscribe(订阅)、unsubscribe(取消订阅)
            case 'event':
                $event = $this->weixin->getRev()->getRevEvent();
                $content = json_encode($event);
                break;
                //接收普通消息-图片消息
            case 'image':
                $content = json_encode($this->weixin->getRev()->getRevPic());
                $reMsg = "图片很美！";
                break;
            default:
                $reMsg = '未识别信息';
        }
        /**
         *处理事件
         */
        if (!empty($reMsg)) {
            echo $this->weixin->text($reMsg)->reply();
            exit;
        }
        //一.接收事件推送
        if ($this->type == 'event') {
            //1.订阅(关注)事件
            if (isset($event['event']) && $event['event'] == 'subscribe') {
                $welcome = '欢迎关注';

                //当待了事件KEY值,则自动注册  KEY一般为推荐人ID
                if ($event['key']) {
                    $qrscene = explode("qrscene_", $event['key']);
                    $inviter_id = intval($qrscene[1]);
                    $config = model('wechat')->getOneWxconfig();
                    $wechat = new WechatApi($config);
                    $expire_time = $config['expires_in'];
                    if ($expire_time > TIMESTAMP) {
                        //有效期内
                        $wechat->access_token_ = $config['access_token'];
                    } else {
                        $access_token = $wechat->checkAuth();
                        $web_expires = TIMESTAMP + 7000; // 提前200秒过期
                        Db::name('wxconfig')->where(array('id' => $config['id']))->update(array('access_token' => $access_token, 'expires_in' => $web_expires));
                    }
                    $userinfo = $wechat->getwxUserInfo($this->wxid);
                    $reg_info = array(
                        'member_wxopenid' => $this->wxid,
                        'member_wxunionid' => $userinfo['unionid'],
                        'nickname' => isset($userinfo['nickname']) ? $userinfo['nickname'] : '',
                        'headimgurl' => isset($userinfo['headimgurl']) ? $userinfo['headimgurl'] : '',
                        'inviter_id' => $inviter_id
                    );

                    $logic_connect_api = model('connectapi', 'logic');
                    $wx_member = $logic_connect_api->wx_register($reg_info, 'wx');

                    if (!empty($wx_member)) {
                        $member_model = model('member');
                        $member_model->getBuyerToken($wx_member['member_id'], $wx_member['member_name'], 'wap', $wx_member['member_wxopenid']);
                    }
                }

                $mbusertoken = Db::name('mbusertoken')->where('member_openid', $this->wxid)->find();
                if (!empty($mbusertoken)) {
                    $ret_url = '。系统已为您自动注册了一个账号，请<a href="' . config('ds_config.h5_site_url') . '/pages/member/index/Index?key=' . $mbusertoken['member_token'] . '&username=' . $mbusertoken['member_name'] . '">点击修改信息</a>';
                } else {
                    $ret_url = '';
                }
                echo $this->weixin->text($welcome . $ret_url)->reply();
                exit;
            }

            //2.扫码已关注
            if (isset($event['event']) && $event['event'] == 'SCAN') {
                $welcome = '已关注';
                echo $this->weixin->text($welcome)->reply();
                exit;
            }

            //4.点击菜单拉取消息时的事件推送
            if ($event['event'] == 'CLICK') {
                $click = $event['key'];
                switch ($click) {
                    case "commend": //店铺推荐商品
                    case "hot":  //点击率商品
                    case "sale": //销售量
                    case "collect": //收藏量
                        $reMsg = $this->getGoods($click);
                        if (!empty($reMsg)) {
                            $this->MsgTypeNews($reMsg);
                        } else {
                            echo $this->weixin->text("success")->reply();
                            exit;
                        }
                        break;
                        //{后续可待添加}
                    default:
                        //从关键词回复中获取
                        $this->MsgTypeText($click);
                        echo $this->weixin->text("未定义此菜单事件{$click}")->reply();
                        exit;
                }
            }
        }

        //二.文本消息(关键字回复/商品显示)
        if ($this->type == 'text') {
            //处理关键字
            $this->MsgTypeText($content);

            //处理商品的情况
            $reMsg = $this->getGoodsByKey($content);
            if (!empty($reMsg)) {
                $this->MsgTypeNews($reMsg);
            }
            /*处理其他输入文字*/
            echo $this->weixin->text("抱歉，暂时无法对您的输入作出处理。")->reply();
            exit;
        }
    }

    /**
     *文本格式消息回复
     */
    private function MsgTypeText($content)
    {
        //先处理是关键字的情况
        $value = $this->keywordsReply($content);
        if (!empty($value)) {
            echo $this->weixin->text($value['text'])->reply();
            exit;
        }
    }


    /**商品图文回复*/
    private function MsgTypeNews($reMsg)
    {
        $k = 0;
        foreach ($reMsg as $v) {
            $newsData[$k]['Title'] = $v['goods_name'];
            $newsData[$k]['Description'] = strip_tags($v['goods_name']);
            $newsData[$k]['PicUrl'] = goods_cthumb($v['goods_image']);
            $newsData[$k]['Url'] = config('ds_config.h5_site_url') . '/pages/home/goodsdetail/Goodsdetail?goods_id=' . $v['goods_id'];
            $k++;
        }
        echo $this->weixin->news($newsData)->reply();
        exit;
    }

    /**
     *关键字回复信息
     */
    public function keywordsReply($content)
    {
        //关键字查询
        $condition = array();
        $condition[] = array('k.keyword', '=', $content);
        $value = model('wechat')->getOneJoinWxkeyword($condition, $field = 't.text');
        return $value;
    }

    /**关键字商品信息*/
    public function getGoodsByKey($key)
    {
        $condi = "(goods_name like '%{$key}%' or goods_advword like '%{$key}%' or store_name like '%{$key}%')";
        $condi .= " and goods_state = 1 and goods_verify = 1";
        $res = Db::name('goods')->where($condi)->limit(4)->field('goods_id,goods_name,goods_image')->select()->toArray();
        $res = ds_change_arraykey($res, 'goods_id');
        return $res;
    }

    /**菜单事件商品信息*/
    public function getGoods($type)
    {
        //条件
        //后续可待添加
        $types = array('hot' => 'goods_click', 'sale' => 'goods_salenum', 'collect' => 'goods_collect', 'commend' => 'goods_commend');
        $condition = $types[$type] . ' DESC';
        $where = "goods_state = 1 and goods_verify = 1";
        $res = Db::name('goods')->field('goods_id,goods_name,goods_image')->where($where)->limit(4)->order($condition)->select()->toArray();
        $res = ds_change_arraykey($res, 'goods_id');
        return $res;
    }
}