huahuibao/app/saas/controllers/WxOpenController.php

<?php

namespace saas\controllers;

use biz\merchant\services\MerchantService;
use biz\wx\services\WxBaseService;
use biz\wx\services\WxMiniBaseService;
use common\components\util;
use Yii;
use common\components\wxUtil;
use biz\ad\classes\AdClass;
use biz\merchant\classes\MerchantExtendClass;
use biz\wx\classes\WxBaseClass;
use biz\wx\services\WxOpenService;
use common\services\xhMerchantExtendService;
use common\services\xhMerchantService;
use common\services\xhInviteService;
use common\components\configDict;
use common\services\xhWxOpenService;
use biz\wx\classes\WxMiniBaseClass;
use biz\wx\classes\WxOpenClass;


class WxOpenController extends PublicController
{

    public $withoutLoginAction = ['bind-open'];

    //开放平台开始授权 shish 2020.1.16
    public function actionBeginAuth()
    {
        $sjId = Yii::$app->request->get('id', 0);
        $open = WxOpenService::getOpen();
        //1只显示公众号 2只显示小程序  3显示公众号和小程序
        $authType = Yii::$app->request->get('authType', 3);
        $pre = wxUtil::getPreAuthCode($open);
        $appId = $open['appId'];
        $oData = [];
        $oData['preAuthCodeTime'] = date("Y-m-d H:i:s");
        //设置预授码过期，让下个用户可以获取新的预授码
        xhWxOpenService::updateById(1, $oData);
        $url = Yii::$app->params['saasHost'] . '/wx-open-callback/' . $sjId;
        echo "<a href='https://mp.weixin.qq.com/cgi-bin/componentloginpage?component_appid={$appId}&pre_auth_code={$pre}&redirect_uri={$url}&auth_type={$authType}'>授权</a>";
    }

    //创建平台使用的公众号
    public function actionCallback()
    {
        $get = Yii::$app->request->get();
        if (isset($get['auth_code']) == false) {
            util::stop('公众号授权回调未成功');
        }
        $id = $get['id'] ?? 0;

        $code = $get['auth_code'];
        //使用授权码换取公众号的接口调用凭据和授权信息
        $authorize = wxUtil::getAuthorizer($code);
        if (isset($authorize['authorization_info']) == false) {
            util::stop('未换取公众号的接口调用凭据和授权信息');
        }
        $info = $authorize['authorization_info'];
        $authorizeAppId = $info['authorizer_appid'];
        $authorize_access_token = $info['authorizer_access_token'];
        $expires_in = $info['expires_in'];//7200
        $authorize_refresh_token = $info['authorizer_refresh_token'];
        //获取授权方的公众号帐号基本信息
        $authorizeDetailInfo = wxUtil::getAuthorizerInfo($authorizeAppId);
        if (isset($authorizeDetailInfo['authorizer_info']) == false) {
            util::stop('没有获取到公众号帐号基本信息');
        }
        $authorize_info = $authorizeDetailInfo['authorizer_info'];
        //$nick_name = $authorize_info['nick_name'];
        $head_img = $authorize_info['head_img'];
        $service_type_info = $authorize_info['service_type_info'];
        if ($service_type_info['id'] != 2) {
            if (isset($authorize_info['MiniProgramInfo']) == false || empty($authorize_info['MiniProgramInfo'])) {
                util::stop('公众号不是服务号');
            }
        }
        $verify_type_info = $authorize_info['verify_type_info'];
        if ($verify_type_info['id'] != 0) {
            if (isset($authorize_info['MiniProgramInfo']) == false || empty($authorize_info['MiniProgramInfo'])) {
                util::stop('公众号还没有认证哦');
            }
        }
        $user_name = $authorize_info['user_name'];
        $alias = $authorize_info['alias'];
        $qrCodeUrl = $authorize_info['qrcode_url'];
        $accessTokenTime = date("Y-m-d H:i:s", (time() + $expires_in - 100));//安全起见，将过期时间设置得比微信里还短100秒

        if ($id == 0) {
            //这是供货商
            $sjWxInfo = WxOpenClass::getGhsWxInfo();
        } elseif ($id == -1) {
            //这是零售商
            $sjWxInfo = WxOpenClass::getWxInfo();
        } else {
            $sjWxInfo = MerchantExtendClass::getByMerchantId($id);
        }

        $open = WxOpenService::getOpen();

        //如果授权的是小程序
        if (isset($authorize_info['MiniProgramInfo']) && !empty($authorize_info['MiniProgramInfo'])) {

            if (isset($sjWxInfo['miniAppId']) && !empty($sjWxInfo['miniAppId'])) {
                if ($sjWxInfo['miniAppId'] != $authorizeAppId) {
                    util::stop('授权的小程序与商家已绑定的小程序不一致');
                }
            } else {
                util::stop('数据库请先填写小程序 miniAppId miniAppSecret');
            }

            $miniData = [
                'miniAppId' => $authorizeAppId,
                'miniAuth' => 1,
                'miniAccessToken' => $authorize_access_token,
                'miniAccessTokenTime' => $accessTokenTime,
                'miniRefreshToken' => $authorize_refresh_token,
            ];

            if ($id <= 0) {
                $wxMiniBaseId = 0;
                if ($id == 0) {
                    //供货商
                    $wxMiniBaseId = $open['wxGhsMiniBaseId'] ?? 0;
                } elseif ($id == -1) {
                    //零售店
                    $wxMiniBaseId = $open['wxMiniBaseId'] ?? 0;
                }
                if (empty($wxMiniBaseId)) {
                    util::stop('没有小程序信息...');
                }
                $miniInfo = WxMiniBaseClass::getById($wxMiniBaseId);
                if (empty($miniInfo)) {
                    util::stop('没有小程序信息，请先配置：xhWxMiniBase表 和 xhWxOpen的相关字段');
                }
                WxMiniBaseClass::updateById($wxMiniBaseId, $miniData);
                util::stop('开放平台成功绑定小程序');
            } else {
                xhMerchantExtendService::updateByMerchantId($id, $miniData);
                MerchantService::updateById($id, ['miniAppId' => $authorizeAppId]);
                Yii::info('小程序信息更新成功：' . json_encode($authorize_info));
                util::stop("小程序信息更新成功");
            }
        } else {

            //如果授权的公众号

            if (isset($sjWxInfo['wxAppId']) && !empty($sjWxInfo['wxAppId'])) {
                if ($sjWxInfo['wxAppId'] != $authorizeAppId) {
                    util::stop('授权的公众号与商家已绑定的公众号不一致');
                }
            }

            $wxData = [];
            $appData['wxUserName'] = $user_name;
            $appData['wxAliasName'] = $alias;
            //公众号logo
            $wxData['logo'] = WxBaseClass::saveLogo($head_img, $id);
            //公众号二维码
            $wxData['wxQrCodeUrl'] = WxBaseClass::saveQrCode($qrCodeUrl, $id);
            $wxData['wxAppId'] = $authorizeAppId;
            $wxData['wxAccessToken'] = $authorize_access_token;
            $wxData['wxAccessTokenTime'] = $accessTokenTime;
            $wxData['wxRefreshToken'] = $authorize_refresh_token;


            if ($id <= 0) {

                $wxBaseId = 0;
                $msg = '未知状态';
                if ($id == 0) {
                    //供货商公众号
                    $wxBaseId = $open['wxGhsBaseId'] ?? 0;
                    $msg = '供货商公众号绑定成功';
                } elseif ($id == -1) {
                    //零售商公众号
                    $wxBaseId = $open['wxBaseId'] ?? 0;
                    $msg = '零售商公众号绑定成功';
                } else {

                }

                WxBaseClass::updateById($wxBaseId, [
                    'wxAccessToken' => $authorize_access_token,
                    'wxRefreshToken' => $authorize_refresh_token,
                    'wxAccessTokenTime' => date("Y-m-d H:i:s", (time() + $expires_in - 100))
                ]);
                echo $msg;
                Yii::$app->end();
            } else {

                $wxData['status'] = 1;//审核通过
                xhMerchantService::updateById($id, $wxData);
                MerchantExtendClass::updateByCondition(['merchantId' => $id], ['wxAppId' => $authorizeAppId, 'wxAuth' => 1]);

                //还没有完成初始化先进行初始化
                if (isset($sjWxInfo['init']) && $sjWxInfo['init'] == 0) {
                    $data = ['merchantId' => $id];
                    $producer = Yii::$app->rabbitmq->getProducer('openShopInitProducer');
                    $msg = serialize($data);
                    $producer->publish($msg, 'openShopInitExchange', 'openShopInitRoute');
                }
                echo 'ok';
            }
        }

    }


    //开放平台设置相关操作 shish 2020.1.18
    public function actionBindOpen()
    {
        $isOpen = Yii::$app->request->get('isOpen', 1);

        $merchantId = 0;
        if ($isOpen == 0) {
            //其它
            $merchantId = Yii::$app->request->get('account', 0);
            $merchant = MerchantService::getById($merchantId);
            if (empty($merchant)) {
                util::fail('没有找到商家');
            }
            $wxAppId = $merchant['wxAppId'];
            $miniAppId = $merchant['miniAppId'];
            $openAppId = $merchant['openAppId'];
        } elseif ($isOpen == 1) {
            //零售
            $merchant = WxOpenClass::getWxInfo();
            $miniAppId = $merchant['miniAppId'];
            $wxAppId = $merchant['wxAppId'];
            $openAppId = $merchant['openAppId'];
        } elseif ($isOpen == 2) {
            //供货商
            $merchant = WxOpenClass::getGhsWxInfo();
            $miniAppId = $merchant['miniAppId'];
            $wxAppId = $merchant['wxAppId'];
            $openAppId = $merchant['openAppId'];
        }
        echo "<pre>";

        $id = Yii::$app->request->get('actId', 0);

        //创建平台，并将公众号绑定到平台
        if ($id == 1) {
            wxUtil::createOpenAccount($wxAppId, $merchant, $isOpen);
            $return = wxUtil::getOpenAccount($wxAppId, $merchant, false, $isOpen);
            print_r($return);
            if ($return['errcode'] == 0) {
                $openAppId = $return['open_appid'];
                if ($isOpen == 0) {
                    xhMerchantService::updateById($merchantId, ['openAppId' => $openAppId]);
                    MerchantExtendService::updateByCondition(['merchantId' => $merchantId], ['openAppId' => $openAppId, 'openAppBind' => 1, 'wxAuth' => 1]);
                } elseif ($isOpen == 1) {
                    $open = WxOpenClass::getOpen();
                    $wxMiniBaseId = isset($open['wxMiniBaseId']) ? $open['wxMiniBaseId'] : 0;
                    $wxBaseId = isset($open['wxBaseId']) ? $open['wxBaseId'] : 0;
                    WxMiniBaseClass::updateById($wxMiniBaseId, ['openAppId' => $openAppId]);
                    WxBaseClass::updateById($wxBaseId, ['openAppId' => $openAppId]);
                } elseif ($isOpen == 2) {
                    $open = WxOpenClass::getOpen();
                    $wxMiniBaseId = isset($open['wxGhsMiniBaseId']) ? $open['wxGhsMiniBaseId'] : 0;
                    $wxBaseId = isset($open['wxGhsBaseId']) ? $open['wxGhsBaseId'] : 0;
                    WxMiniBaseClass::updateById($wxMiniBaseId, ['openAppId' => $openAppId]);
                    WxBaseClass::updateById($wxBaseId, ['openAppId' => $openAppId]);
                }
            }
        }
        //将小程序绑定到平台
        if ($id == 2) {
            $openAppId = $merchant['openAppId'];
            $r = wxUtil::bindOpenAccount($miniAppId, $openAppId, $merchant, true, $isOpen);
            //MerchantExtendService::updateByCondition(['merchantId' => $merchantId], ['openAppBind' => 3, 'miniAuth' => 1]);
            print_r($r);
        }
        //查询公众号 小程序的绑定情况
        if ($id == 3) {
            Yii::info("查询公众号 小程序的绑定情况 wxAppId:{$wxAppId} isOpen:{$isOpen}");
            $return = wxUtil::getOpenAccount($wxAppId, $merchant, false, $isOpen);
            echo "公众号绑定情况：<br />";
            print_r($return);
            $return = wxUtil::getOpenAccount($miniAppId, $merchant, true, $isOpen);
            echo "小程序绑定情况：<br />";
            print_r($return);
        }

        //设置小程序服务器域名
        if ($id == 4) {
            wxUtil::setDomain($merchant, $isOpen);
            wxUtil::setWebViewDomain($merchant, $isOpen);
        }

        //为授权的小程序帐号上传小程序代码
        if ($id == 5) {
            //模板id
            $tId = Yii::$app->request->get('tId');
            wxUtil::miniCommit($merchant, $tId, $isOpen);
        }

        //获取小程序体验码
        if ($id == 6) {
            wxUtil::getExperienceQrCode($merchant, '', $isOpen);
        }

        //获取授权小程序帐号已设置的类目
        if ($id == 7) {
            wxUtil::getMiniCategory($merchant, $isOpen);
        }

        //获取小程序的第三方提交代码的页面配置
        if ($id == 8) {
            wxUtil::getMiniPage($merchant, $isOpen);
        }

        //将第三方提交的代码包提交审核
        if ($id == 9) {
            wxUtil::miniSubmitAudit($merchant, '', $isOpen);
        }

        //查询最新一次提交的审核状态
        if ($id == 10) {
            wxUtil::miniGetLatestAuditStatus($merchant, $isOpen);
        }

        //发布已通过审核的小程序
        if ($id == 11) {
            $respond = wxUtil::miniRelease($merchant, $isOpen);
            dd($respond);
        }

        //撤回审核
        if ($id == 12) {
            wxUtil::rollbackCheck($merchant, $isOpen);
        }
        //生成 申请会员页 的小程序码
        if ($id == 13) {
            wxUtil::generateMemberCode($merchant, $isOpen);
        }
        //解绑小程序和公众号绑定的平台
        if ($id == 14) {
            wxUtil::unbindAccount($merchant, $isOpen);
            wxUtil::unbindMiniProgram($merchant, $isOpen);
        }
        Yii::$app->end();

        $r = wxUtil::bindOpenAccount($miniAppId, $openAppId, $merchant, true, $isOpen);
        print_r($r);
        echo $miniAppId . ' ' . $openAppId . ' ';

        $return = wxUtil::getOpenAccount($wxAppId, $merchant, false, $isOpen);
        print_r($return);
        die;

        $return = wxUtil::createOpenAccount($wxAppId, $merchant, $isOpen);
        print_r($return);
        die;

        $r = wxUtil::bindOpenAccount($miniAppId, $openAppId, $merchant, false, $isOpen);
        print_r($r);
        echo $miniAppId . ' ' . $openAppId . ' ';

        $return = wxUtil::getOpenAccount($wxAppId, $merchant, false, $isOpen);
        print_r($return);
        $return = wxUtil::getOpenAccount($miniAppId, $merchant, false, $isOpen);
        print_r($return);
    }


    public function actionResult()
    {
        $get = Yii::$app->request->get();
        $id = isset($get['id']) ? $get['id'] : 0;
        $merchant = xhMerchantService::getById($id);
        $status = configDict::getConfig('merchantStatusName');
        $orMechantId = configDict::getConfig('merchantId');
        $originalMerchant = xhMerchantService::getById($orMechantId);
        return $this->renderPartial('result', ['originalMerchant' => $originalMerchant, 'merchant' => $merchant, 'status' => $status]);
    }

    public function actionCheckInviteCode()
    {
        $get = Yii::$app->request->get();
        $code = isset($get['code']) ? $get['code'] : '';
        $invite = xhInviteService::getByCode($code);
        if (empty($invite)) {
            util::fail('邀请码错误');
        }
        $now = time();
        if ($now > $invite['deadline']) {
            util::fail('邀请码已经失效');
        }
        if (!empty($invite['takeStatus'])) {
            util::fail('邀请码已经使用');
        }
        util::success($invite);
    }

    public function actionSelect()
    {
        $isWx = util::isWx();
        if ($isWx == false) {
            return $this->renderPartial('notWeixin');
        }
        return $this->renderPartial('select');
    }

    public function actionApi()
    {
        $openData = file_get_contents('php://input');
        if (isset ($openData) == false || empty($openData)) {
            util::stop('has no post data');
        }
        $weixinSecret = Yii::getAlias("@vendor/weixinSecret");
        require_once($weixinSecret . '/wxBizMsgCrypt.php');
        $get = Yii::$app->request->get();
        $encryptMsg = $openData;
        $openId = configDict::getConfig('openId');
        $open = xhWxOpenService::getById($openId);
        $encodingAesKey = $open['aesKey'];
        $token = $open['token'];
        $appId = $open['appId'];
        $appSecret = $open['appSecret'];
        $signature = isset($get['signature']) ? $get['signature'] : '';
        $timestamp = isset($get['timestamp']) ? $get['timestamp'] : '';
        $nonce = isset($get['nonce']) ? $get['nonce'] : '';
        $encrypt_type = isset($get['encrypt_type']) ? $get['encrypt_type'] : '';
        $msg_signature = isset($get['msg_signature']) ? $get['msg_signature'] : '';
        $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);

        $formString = " token：" . $token . "\n encodingAesKey：" . $encodingAesKey . "\n appId：" . $appId . "\n msg_signature：" . $msg_signature . "\n appSecret：" . $appSecret . "\n timestamp：" . $timestamp . "\n nonce：" . $nonce;
        Yii::warning($formString);

        $formString2 = "from_xml：" . $from_xml;
        Yii::warning($formString2);

        //第三方收到公众号平台发送的消息
        $pc = new \WXBizMsgCrypt($token, $encodingAesKey, $appId);
        $msg = '';//解密后的消息
        $errCode = $pc->decryptMsg($msg_signature, $timestamp, $nonce, $from_xml, $msg);
        if ($errCode != 0) {
            Yii::warning("解密未成功，错误代码：" . $errCode . "。（出现过的情况汇总：-40001 有可能token、encodingAesKey、appId等填写不对，请仔细核对每个值）");
            util::stop();
        }
        $postObj = simplexml_load_string($msg, 'SimpleXMLElement', LIBXML_NOCDATA);
        $infoType = $postObj->InfoType;
        switch ($infoType) {
            //推送 componentVerifyTicket
            case 'component_verify_ticket':
                $componentVerifyTicket = $postObj->ComponentVerifyTicket;
                if (!empty($componentVerifyTicket)) {
                    $oData = [];
                    $oData['verifyTicket'] = (string)$componentVerifyTicket;
                    $oData['verifyTicketTime'] = date("Y-m-d H:i:s", $timestamp + 600);//每10分钟（600秒）推一次
                    xhWxOpenService::updateById($openId, $oData);
                    Yii::warning("component_verify_ticket:" . (string)$componentVerifyTicket);
                    util::stop('success');
                }
                break;
            //取消授权通知
            case 'unauthorized':
                $AppId = $postObj->AppId;
                $authorizeAppid = $postObj->AuthorizerAppid;
                $merchant = xhMerchantService::getByAppId($authorizeAppid);
                if (!empty($merchant)) {
                    $merchantId = $merchant['id'];
                    //自主冻结
                    xhMerchantService::updateById($merchantId, ['status' => 5]);
                }
                break;
            //授权成功通知
            case 'authorized':
                $AppId = $postObj->AppId;//第三方平台appid
                $CreateTime = $postObj->CreateTime;//公众号
                $authorizeAppid = $postObj->AuthorizerAppid;//授权码，可用于换取公众号的接口调用凭据，详细见上面的说明
                $AuthorizationCode = $postObj->AuthorizationCode;
                $AuthorizationCodeExpiredTime = $postObj->AuthorizationCodeExpiredTime;//授权码过期时间
                break;
            //授权更新通知
            case 'updateauthorized':
                $AppId = $postObj->AppId;
                $CreateTime = $postObj->CreateTime;
                $authorizeAppid = $postObj->AuthorizerAppid;
                $AuthorizationCode = $postObj->AuthorizationCode;
                $AuthorizationCodeExpiredTime = $postObj->AuthorizationCodeExpiredTime;

                util::stop();

                $authorize = wxUtil::getAuthorizer($AuthorizationCode);
                if (isset($authorize['authorization_info']) == false) {
                    $msg = '授权回调获取到auth_code，但未换取公众号的接口调用凭据和授权信息！！';
                    Yii::warning($msg, __METHOD__);
                    Yii::$app->end();
                }
                $info = $authorize['authorization_info'];
                $authorizeAppId = $info['authorizer_appid'];
                $authorize_access_token = $info['authorizer_access_token'];
                $expires_in = $info['expires_in'];//7200
                $authorize_refresh_token = $info['authorizer_refresh_token'];

                //查询是否零售或供货商使用的公众号
                $hasChange = false;
                $wxBase = WxBaseClass::getAllByCondition(['id>' => 0], null, '*');
                if (!empty($wxBase)) {
                    foreach ($wxBase as $wx) {
                        if (isset($wx['wxAppId']) && $wx['wxAppId'] == $authorizeAppId) {
                            $id = $wx['id'];
                            WxBaseClass::updateById($id, [
                                'wxAccessToken' => $authorize_access_token,
                                'wxRefreshToken' => $authorize_refresh_token,
                                'wxAccessTokenTime' => date("Y-m-d H:i:s", (time() + $expires_in - 100))
                            ]);
                            $hasChange = true;
                        }
                    }
                }
                if ($hasChange == false) {
                    $merchant = xhMerchantService::getByAppId($authorizeAppId);
                    if (empty($merchant)) {
                        return false;
                    }
                    $merchantId = $merchant['id'];
                    $wxData = [];
                    $wxData['wxAccessToken'] = $authorize_access_token;
                    $wxData['wxRefreshToken'] = $authorize_refresh_token;
                    $wxData['wxAccessTokenTime'] = date("Y-m-d H:i:s", (time() + $expires_in - 100));
                    $wxData['status'] = 1;
                    xhMerchantService::updateById($merchantId, $wxData);
                }
                break;
            default:
        }
        Yii::warning("---wx open data end--- \n");
    }

    //获取平台信息 shish 2020.4.12
    public function actionGetWxOpen()
    {
        $open = WxOpenService::getOpen();
        util::success($open);
    }


    //平台没有绑定商家公众号时初始化一个商家 shish 2020.2.11
    public function actionAddMerchant()
    {
        AdClass::initAdd(12362);
        $return = MerchantService::initOpenMerchant();
        dd($return);
    }

    public function actionCheckMerchantName()
    {
        $get = Yii::$app->request->get();
        $merchantName = isset($get['merchantName']) ? $get['merchantName'] : '';
        $m = xhMerchantService::getByMerchantName($merchantName);
        if (!empty($m)) {
            util::fail('公众号名称已经使用');
        }
        util::complete();
    }

    /**
     * 下载微信里的图片到服务器
     */
    public function actionDownloadWxImg()
    {
        $get = Yii::$app->request->get();
        $mediaId = isset($get['mediaId']) ? $get['mediaId'] : '';
        $imgList = wxUtil::downloadmediaIdImg($this->merchant, $mediaId);
        if (!empty($imgList)) {
            util::success($imgList);
        }
        util::fail();
    }

}