Browse Source

开放平台相关

shish 5 năm trước cách đây
mục cha
commit
67f6edc038
3 tập tin đã thay đổi với 521 bổ sung572 xóa
  1. 1 1
      app/pt/config/main.php
  2. 517 568
      app/pt/controllers/WxOpenController.php
  3. 3 3
      biz/wx/classes/WxOpenClass.php

+ 1 - 1
app/pt/config/main.php

@@ -40,7 +40,7 @@ return [
             'rules' => [
 
 				//供货商 授权事件接收URL的重写
-                'wx-open-api/<id:\w+>' => 'wx-open/api',
+                'wx-open-api/<style:\w+>' => 'wx-open/api',
 
                 //公众号消息与事件接收地址
                 'wx/<appId:\w+>' => 'wx/api',

+ 517 - 568
app/pt/controllers/WxOpenController.php

@@ -23,572 +23,521 @@ use bizHd\wx\classes\WxOpenClass;
 
 class WxOpenController extends PublicController
 {
-
-    public $guestAccessAction = ['bind-open'];
-
-    //开放平台开始授权 shish 2020.1.16
-    public function actionBeginAuth()
-    {
-        $sjId = Yii::$app->request->get('id', 'hd');
-        $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'] ?? 'hd';
-
-        $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 == 'ghs') {
-            //这是供货商
-            $sjWxInfo = WxOpenClass::getGhsWxInfo();
-        } elseif ($id == 'hd') {
-            //这是零售商
-            $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 (is_numeric($id) == false) {
-                $wxMiniBaseId = 0;
-                $msg = '未知状态';
-                if ($id == 'ghs') {
-                    //供货商
-                    $wxMiniBaseId = $open['wxGhsMiniBaseId'] ?? 0;
-                    $msg = '供货商小程序绑定成功';
-                } elseif ($id == 'hd') {
-                    //零售店
-                    $wxMiniBaseId = $open['wxMiniBaseId'] ?? 0;
-                    $msg = '零售店小程序绑定成功';
-                }
-                if (empty($wxMiniBaseId)) {
-                    util::stop('没有小程序信息...');
-                }
-                $miniInfo = WxMiniBaseClass::getById($wxMiniBaseId);
-                if (empty($miniInfo)) {
-                    util::stop('没有小程序信息,请先配置:xhWxMiniBase表 和 xhWxOpen的相关字段');
-                }
-                WxMiniBaseClass::updateById($wxMiniBaseId, $miniData);
-                util::stop($msg);
-            } 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("授权的公众号与商家已绑定的公众号不一致,授权公众号appId:{$authorizeAppId} 商家公众号:{$sjWxInfo['wxAppId']}");
-                }
-            }
-
-            $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 (is_numeric($id) == false) {
-
-                $wxBaseId = 0;
-                $msg = '未知状态';
-                if ($id == 'ghs') {
-                    //供货商公众号
-                    $wxBaseId = $open['wxGhsBaseId'] ?? 0;
-                    $msg = '供货商公众号绑定成功';
-                } elseif ($id == 'hd') {
-                    //零售商公众号
-                    $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) {
-            echo '<pre>';
-            Yii::info("解绑信息:" . json_encode($merchant));
-            $r = wxUtil::unbindAccount($merchant, $isOpen);
-            print_r($r);
-            $r = wxUtil::unbindMiniProgram($merchant, $isOpen);
-            print_r($r);
-            Yii::$app->end();
-        }
-        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()
-    {
-        $get = Yii::$app->request->get();
-        Yii::info('参数:'.json_encode($get));
-
-        $openData = file_get_contents('php://input');
-        if (isset ($openData) == false || empty($openData)) {
-            util::stop('has no post data');
-        }
-        $wxSecret = Yii::getAlias("@vendor/weixinSecret");
-        require_once($wxSecret . '/wxBizMsgCrypt.php');
-
-
-        $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();
-    }
-
+	
+	public $guestAccessAction = ['bind-open'];
+	
+	//开放平台开始授权 shish 2020.1.16
+	public function actionBeginAuth()
+	{
+		$sjId = Yii::$app->request->get('id', 'hd');
+		$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'] ?? 'hd';
+		$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 == 'ghs') {
+			//这是供货商
+			$sjWxInfo = WxOpenClass::getGhsWxInfo();
+		} elseif ($id == 'hd') {
+			//这是零售商
+			$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 (is_numeric($id) == false) {
+				$wxMiniBaseId = 0;
+				$msg = '未知状态';
+				if ($id == 'ghs') {
+					//供货商
+					$wxMiniBaseId = $open['wxGhsMiniBaseId'] ?? 0;
+					$msg = '供货商小程序绑定成功';
+				} elseif ($id == 'hd') {
+					//零售店
+					$wxMiniBaseId = $open['wxMiniBaseId'] ?? 0;
+					$msg = '零售店小程序绑定成功';
+				}
+				if (empty($wxMiniBaseId)) {
+					util::stop('没有小程序信息...');
+				}
+				$miniInfo = WxMiniBaseClass::getById($wxMiniBaseId);
+				if (empty($miniInfo)) {
+					util::stop('没有小程序信息,请先配置:xhWxMiniBase表 和 xhWxOpen的相关字段');
+				}
+				WxMiniBaseClass::updateById($wxMiniBaseId, $miniData);
+				util::stop($msg);
+			} 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("授权的公众号与商家已绑定的公众号不一致,授权公众号appId:{$authorizeAppId} 商家公众号:{$sjWxInfo['wxAppId']}");
+				}
+			}
+			
+			$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 (is_numeric($id) == false) {
+				
+				$wxBaseId = 0;
+				$msg = '未知状态';
+				if ($id == 'ghs') {
+					//供货商公众号
+					$wxBaseId = $open['wxGhsBaseId'] ?? 0;
+					$msg = '供货商公众号绑定成功';
+				} elseif ($id == 'hd') {
+					//零售商公众号
+					$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) {
+			echo '<pre>';
+			Yii::info("解绑信息:" . json_encode($merchant));
+			$r = wxUtil::unbindAccount($merchant, $isOpen);
+			print_r($r);
+			$r = wxUtil::unbindMiniProgram($merchant, $isOpen);
+			print_r($r);
+			Yii::$app->end();
+		}
+		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()
+	{
+		$get = Yii::$app->request->get();
+		$style = $get['style'] ?? \biz\wx\classes\WxOpenClass::OPEN_STYLE_HD;
+		$openData = file_get_contents('php://input');
+		if (isset ($openData) == false || empty($openData)) {
+			util::stop('has no post data');
+		}
+		$wxSecret = Yii::getAlias("@vendor/weixinSecret");
+		require_once($wxSecret . '/wxBizMsgCrypt.php');
+		$encryptMsg = $openData;
+		$open = \biz\wx\classes\WxOpenClass::getByCondition(['style' => $style]);
+		$openId = $open['id'];
+		$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':
+				//这里没有往下操作,请看本文件callback()方法
+				break;
+			//授权成功通知
+			case 'authorized':
+				$AppId = $postObj->AppId;
+				$authorizeAppId = $postObj->AuthorizerAppid;
+				$CreateTime = $postObj->CreateTime;//公众号
+				$authorizeAppId = $postObj->AuthorizerAppid;//授权码,可用于换取公众号的接口调用凭据,详细见上面的说明
+				$AuthorizationCode = $postObj->AuthorizationCode;
+				$AuthorizationCodeExpiredTime = $postObj->AuthorizationCodeExpiredTime;//授权码过期时间
+				//这里没有往下操作,请看本文件callback()方法
+				break;
+			//授权更新通知
+			case 'updateauthorized':
+				$AppId = $postObj->AppId;
+				$authorizeAppId = $postObj->AuthorizerAppid;
+				$CreateTime = $postObj->CreateTime;
+				$authorizeAppId = $postObj->AuthorizerAppid;
+				$AuthorizationCode = $postObj->AuthorizationCode;
+				$AuthorizationCodeExpiredTime = $postObj->AuthorizationCodeExpiredTime;
+				//这里没有往下操作,请看本文件callback()方法
+				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();
+	}
+	
 }

+ 3 - 3
biz/wx/classes/WxOpenClass.php

@@ -12,7 +12,7 @@ class WxOpenClass extends BaseClass
 	
 	public static $baseFile = '\biz\wx\models\WxOpen';
 	
-	const OPEN_STYLE_RETAIL = 1;
+	const OPEN_STYLE_HD = 1;
 	const OPEN_STYLE_GHS = 2;
 	
 	//获取所有的小程序信息 shish 2021.2.25
@@ -34,13 +34,13 @@ class WxOpenClass extends BaseClass
 	public static function getGhsOpen()
 	{
 		//暂时只有一个平台,取一个平台
-		return self::getByCondition(['style' => self::OPEN_STYLE_RETAIL]);
+		return self::getByCondition(['style' => self::OPEN_STYLE_HD]);
 	}
 	
 	//取零售平台信息 shish 2021.2.25
 	public static function getRetailOpen()
 	{
-		return self::getByCondition(['style' => self::OPEN_STYLE_RETAIL]);
+		return self::getByCondition(['style' => self::OPEN_STYLE_HD]);
 	}
 	
 }