From cd972e10ec91ea187843b64562c228fe315be23f Mon Sep 17 00:00:00 2001 From: Anyon Date: Wed, 31 Jan 2018 15:27:46 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=9B=B4=E6=96=B0]=E4=BF=AE=E6=94=B9=E9=A1=B9?= =?UTF-8?q?=E7=9B=AE=E5=91=BD=E5=90=8D=E7=A9=BA=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- WeChat/WeChat/Card.php | 616 ++++++++++++++++++ WeChat/WeChat/Contracts/Config.php | 124 ++++ WeChat/WeChat/Contracts/Error.php | 194 ++++++ WeChat/WeChat/Contracts/Prpcrypt.php | 189 ++++++ WeChat/WeChat/Contracts/Request.php | 227 +++++++ WeChat/WeChat/Contracts/Tools.php | 348 ++++++++++ WeChat/WeChat/Custom.php | 220 +++++++ .../Exceptions/InvalidArgumentException.php | 25 + .../Exceptions/InvalidDecryptException.php | 41 ++ .../Exceptions/InvalidResponseException.php | 41 ++ .../WeChat/Exceptions/LocalCacheException.php | 42 ++ WeChat/WeChat/Media.php | 183 ++++++ WeChat/WeChat/Menu.php | 109 ++++ WeChat/WeChat/Oauth.php | 93 +++ WeChat/WeChat/Pay.php | 212 ++++++ WeChat/WeChat/Product.php | 178 +++++ WeChat/WeChat/Qrcode.php | 72 ++ WeChat/WeChat/Receive.php | 164 +++++ WeChat/WeChat/Scan.php | 199 ++++++ WeChat/WeChat/Script.php | 102 +++ WeChat/WeChat/Shake.php | 364 +++++++++++ WeChat/WeChat/Tags.php | 109 ++++ WeChat/WeChat/Template.php | 110 ++++ WeChat/WeChat/User.php | 132 ++++ WeChat/WeChat/Wifi.php | 285 ++++++++ 25 files changed, 4379 insertions(+) create mode 100644 WeChat/WeChat/Card.php create mode 100644 WeChat/WeChat/Contracts/Config.php create mode 100644 WeChat/WeChat/Contracts/Error.php create mode 100644 WeChat/WeChat/Contracts/Prpcrypt.php create mode 100644 WeChat/WeChat/Contracts/Request.php create mode 100644 WeChat/WeChat/Contracts/Tools.php create mode 100644 WeChat/WeChat/Custom.php create mode 100644 WeChat/WeChat/Exceptions/InvalidArgumentException.php create mode 100644 WeChat/WeChat/Exceptions/InvalidDecryptException.php create mode 100644 WeChat/WeChat/Exceptions/InvalidResponseException.php create mode 100644 WeChat/WeChat/Exceptions/LocalCacheException.php create mode 100644 WeChat/WeChat/Media.php create mode 100644 WeChat/WeChat/Menu.php create mode 100644 WeChat/WeChat/Oauth.php create mode 100644 WeChat/WeChat/Pay.php create mode 100644 WeChat/WeChat/Product.php create mode 100644 WeChat/WeChat/Qrcode.php create mode 100644 WeChat/WeChat/Receive.php create mode 100644 WeChat/WeChat/Scan.php create mode 100644 WeChat/WeChat/Script.php create mode 100644 WeChat/WeChat/Shake.php create mode 100644 WeChat/WeChat/Tags.php create mode 100644 WeChat/WeChat/Template.php create mode 100644 WeChat/WeChat/User.php create mode 100644 WeChat/WeChat/Wifi.php diff --git a/WeChat/WeChat/Card.php b/WeChat/WeChat/Card.php new file mode 100644 index 0000000..2c34a58 --- /dev/null +++ b/WeChat/WeChat/Card.php @@ -0,0 +1,616 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 设置买单接口 + * @param string $card_id + * @param bool $is_open + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setPaycell($card_id, $is_open = true) + { + $url = "https://api.weixin.qq.com/card/paycell/set?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id, 'is_open' => $is_open]); + } + + /** + * 设置买单接口 + * @param string $card_id + * @param bool $is_open + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setConsumeCell($card_id, $is_open = true) + { + $url = "https://api.weixin.qq.com/card/selfconsumecell/set?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id, 'is_open' => $is_open]); + } + + /** + * 创建二维码接口 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function createQrc(array $data) + { + $url = "https://api.weixin.qq.com/card/qrcode/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 创建货架接口 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function createLandingPage(array $data) + { + $url = "https://api.weixin.qq.com/card/landingpage/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 导入自定义code + * @param string $card_id + * @param array $code + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deposit($card_id, array $code) + { + $url = "https://api.weixin.qq.com/card/code/deposit?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id, 'code' => $code]); + } + + /** + * 查询导入code数目 + * @param string $card_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getDepositCount($card_id) + { + $url = "https://api.weixin.qq.com/card/code/getdepositcount?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id]); + } + + /** + * 核查code接口 + * @param string $card_id 进行导入code的卡券ID + * @param array $code 已经微信卡券后台的自定义code，上限为100个 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function checkCode($card_id, array $code) + { + $url = "https://api.weixin.qq.com/card/code/checkcode?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id, 'code' => $code]); + } + + /** + * 图文消息群发卡券 + * @param string $card_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getNewsHtml($card_id) + { + $url = "https://api.weixin.qq.com/card/mpnews/gethtml?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id]); + } + + /** + * 设置测试白名单 + * @param array $openids + * @param array $usernames + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setTestWhiteList($openids = [], $usernames = []) + { + $url = "https://api.weixin.qq.com/card/testwhitelist/set?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid' => $openids, 'username' => $usernames]); + } + + /** + * 线下核销查询Code + * @param string $code 单张卡券的唯一标准 + * @param string $card_id 卡券ID代表一类卡券。自定义code卡券必填 + * @param bool $check_consume 是否校验code核销状态，填入true和false时的code异常状态返回数据不同 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCode($code, $card_id = null, $check_consume = null) + { + $data = ['code' => $code]; + is_null($card_id) || $data['card_id'] = $card_id; + is_null($check_consume) || $data['check_consume'] = $check_consume; + $url = "https://api.weixin.qq.com/card/code/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 线下核销核销Code + * @param string $code 需核销的Code码 + * @param null $card_id 券ID。创建卡券时use_custom_code填写true时必填。非自定义Code不必填写 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function consume($code, $card_id = null) + { + $data = ['code' => $code]; + is_null($card_id) || $data['card_id'] = $card_id; + $url = "https://api.weixin.qq.com/card/code/consume?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * Code解码接口 + * @param string $encrypt_code + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function decrypt($encrypt_code) + { + $url = "https://api.weixin.qq.com/card/code/decrypt?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['encrypt_code' => $encrypt_code]); + } + + /** + * 获取用户已领取卡券接口 + * @param string $openid + * @param null|string $card_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCardList($openid, $card_id = null) + { + $data = ['openid' => $openid]; + is_null($card_id) || $data['card_id'] = $card_id; + $url = "https://api.weixin.qq.com/card/user/getcardlist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查看卡券详情 + * @param string $card_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCard($card_id) + { + $url = "https://api.weixin.qq.com/card/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id]); + } + + /** + * 批量查询卡券列表 + * @param int $offset 查询卡列表的起始偏移量，从0开始，即offset: 5是指从从列表里的第六个开始读取 + * @param int $count 需要查询的卡片的数量（数量最大50） + * @param array $status_list 支持开发者拉出指定状态的卡券列表 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function batchGet($offset, $count = 50, array $status_list = []) + { + $data = ['offset' => $offset, 'count' => $count]; + empty($status_list) || $data['status_list'] = $status_list; + $url = "https://api.weixin.qq.com/card/batchget?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 更改卡券信息接口 + * @param string $card_id + * @param array $member_card + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateCard($card_id, array $member_card) + { + $url = "https://api.weixin.qq.com/card/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id, 'member_card' => $member_card]); + } + + /** + * 修改库存接口 + * @param string $card_id 卡券ID + * @param null|integer $increase_stock_value 增加多少库存，支持不填或填0 + * @param null|integer $reduce_stock_value 减少多少库存，可以不填或填0 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function modifyStock($card_id, $increase_stock_value = null, $reduce_stock_value = null) + { + $data = ['card_id' => $card_id]; + is_null($increase_stock_value) || $data['increase_stock_value'] = $increase_stock_value; + is_null($reduce_stock_value) || $data['reduce_stock_value'] = $reduce_stock_value; + $url = "https://api.weixin.qq.com/card/modifystock?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 更改Code接口 + * @param string $code 需变更的Code码 + * @param string $new_code 变更后的有效Code码 + * @param null|string $card_id 卡券ID + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateCode($code, $new_code, $card_id = null) + { + $data = ['code' => $code, 'new_code' => $new_code]; + is_null($card_id) || $data['card_id'] = $card_id; + $url = "https://api.weixin.qq.com/card/code/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除卡券接口 + * @param string $card_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deleteCard($card_id) + { + $url = "https://api.weixin.qq.com/card/delete?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id]); + } + + /** + * 设置卡券失效接口 + * @param string $code + * @param string $card_id + * @param null|string $reason + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function unAvailable($code, $card_id, $reason = null) + { + $data = ['code' => $code, 'card_id' => $card_id]; + is_null($reason) || $data['reason'] = $reason; + $url = "https://api.weixin.qq.com/card/code/unavailable?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 拉取卡券概况数据接口 + * @param string $begin_date 查询数据的起始时间 + * @param string $end_date 查询数据的截至时间 + * @param string $cond_source 卡券来源(0为公众平台创建的卡券数据 1是API创建的卡券数据) + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCardBizuininfo($begin_date, $end_date, $cond_source) + { + $data = ['begin_date' => $begin_date, 'end_date' => $end_date, 'cond_source' => $cond_source]; + $url = "https://api.weixin.qq.com/datacube/getcardbizuininfo?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 获取免费券数据接口 + * @param string $begin_date 查询数据的起始时间 + * @param string $end_date 查询数据的截至时间 + * @param integer $cond_source 卡券来源，0为公众平台创建的卡券数据、1是API创建的卡券数据 + * @param null $card_id 卡券ID + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCardCardinfo($begin_date, $end_date, $cond_source, $card_id = null) + { + $data = ['begin_date' => $begin_date, 'end_date' => $end_date, 'cond_source' => $cond_source]; + is_null($card_id) || $data['card_id'] = $card_id; + $url = "https://api.weixin.qq.com/datacube/getcardcardinfo?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 拉取会员卡概况数据接口 + * @param string $begin_date 查询数据的起始时间 + * @param string $end_date 查询数据的截至时间 + * @param string $cond_source 卡券来源(0为公众平台创建的卡券数据 1是API创建的卡券数据) + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCardMemberCardinfo($begin_date, $end_date, $cond_source) + { + $data = ['begin_date' => $begin_date, 'end_date' => $end_date, 'cond_source' => $cond_source]; + $url = "https://api.weixin.qq.com/datacube/getcardmembercardinfo?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 拉取单张会员卡数据接口 + * @param string $begin_date 查询数据的起始时间 + * @param string $end_date 查询数据的截至时间 + * @param string $card_id 卡券id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCardMemberCardDetail($begin_date, $end_date, $card_id) + { + $data = ['begin_date' => $begin_date, 'end_date' => $end_date, 'card_id' => $card_id]; + $url = "https://api.weixin.qq.com/datacube/getcardmembercarddetail?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 拉取会员信息（积分查询）接口 + * @param string $card_id 查询会员卡的cardid + * @param string $code 所查询用户领取到的code值 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCardMemberCard($card_id, $code) + { + $data = ['card_id' => $card_id, 'code' => $code]; + $url = "https://api.weixin.qq.com/card/membercard/userinfo/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 设置支付后投放卡券接口 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function payGiftCard(array $data) + { + $url = "https://api.weixin.qq.com/card/paygiftcard/add?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除支付后投放卡券规则 + * @param integer $rule_id 支付即会员的规则名称 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function delPayGiftCard($rule_id) + { + $url = "https://api.weixin.qq.com/card/paygiftcard/add?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['rule_id' => $rule_id]); + } + + /** + * 查询支付后投放卡券规则详情 + * @param integer $rule_id 要查询规则id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getPayGiftCard($rule_id) + { + $url = "https://api.weixin.qq.com/card/paygiftcard/getbyid?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['rule_id' => $rule_id]); + } + + /** + * 批量查询支付后投放卡券规则 + * @param integer $offset 起始偏移量 + * @param integer $count 查询的数量 + * @param bool $effective 是否仅查询生效的规则 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function batchGetPayGiftCard($offset = 0, $count = 10, $effective = true) + { + $data = ['type' => 'RULE_TYPE_PAY_MEMBER_CARD', 'offset' => $offset, 'count' => $count, 'effective' => $effective]; + $url = "https://api.weixin.qq.com/card/paygiftcard/batchget?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 创建支付后领取立减金活动 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addActivity(array $data) + { + $url = "https://api.weixin.qq.com/card/mkt/activity/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 开通券点账户接口 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function payActivate() + { + $url = "https://api.weixin.qq.com/card/pay/activate?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 对优惠券批价 + * @param string $card_id 需要来配置库存的card_id + * @param integer $quantity 本次需要兑换的库存数目 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getPayprice($card_id, $quantity) + { + $url = "POST https://api.weixin.qq.com/card/pay/getpayprice?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['card_id' => $card_id, 'quantity' => $quantity]); + } + + /** + * 查询券点余额接口 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCoinsInfo() + { + $url = "https://api.weixin.qq.com/card/pay/getcoinsinfo?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 确认兑换库存接口 + * @param string $card_id 需要来兑换库存的card_id + * @param integer $quantity 本次需要兑换的库存数目 + * @param string $order_id 仅可以使用上面得到的订单号，保证批价有效性 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function payConfirm($card_id, $quantity, $order_id) + { + $data = ['card_id' => $card_id, 'quantity' => $quantity, 'order_id' => $order_id]; + $url = "https://api.weixin.qq.com/card/pay/confirm?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 充值券点接口 + * @param integer $coin_count + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function payRecharge($coin_count) + { + $url = "https://api.weixin.qq.com/card/pay/recharge?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['coin_count' => $coin_count]); + } + + /** + * 查询订单详情接口 + * @param string $order_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function payGetOrder($order_id) + { + $url = "https://api.weixin.qq.com/card/pay/getorder?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['order_id' => $order_id]); + } + + /** + * 查询券点流水详情接口 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function payGetList(array $data) + { + $url = "https://api.weixin.qq.com/card/pay/getorderlist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + + +} \ No newline at end of file diff --git a/WeChat/WeChat/Contracts/Config.php b/WeChat/WeChat/Contracts/Config.php new file mode 100644 index 0000000..6e73ce7 --- /dev/null +++ b/WeChat/WeChat/Contracts/Config.php @@ -0,0 +1,124 @@ +config = $options; + } + + /** + * 设置配置项值 + * @param string $offset + * @param string|array|null|integer $value + */ + public function set($offset, $value) + { + $this->offsetSet($offset, $value); + } + + /** + * 获取配置项参数 + * @param string|null $offset + * @return array|string|null + */ + public function get($offset = null) + { + return $this->offsetGet($offset); + } + + /** + * 合并数据到对象 + * @param array $data 需要合并的数据 + * @param bool $append 是否追加数据 + * @return array + */ + public function merge(array $data, $append = false) + { + if ($append) { + return $this->config = array_merge($this->config, $data); + } + return array_merge($this->config, $data); + } + + /** + * 设置配置项值 + * @param string $offset + * @param string|array|null|integer $value + */ + public function offsetSet($offset, $value) + { + if (is_null($offset)) { + $this->config[] = $value; + } else { + $this->config[$offset] = $value; + } + } + + /** + * 判断配置Key是否存在 + * @param string $offset + * @return bool + */ + public function offsetExists($offset) + { + return isset($this->config[$offset]); + } + + /** + * 清理配置项 + * @param string|null $offset + */ + public function offsetUnset($offset = null) + { + if (is_null($offset)) { + $this->config = []; + } else { + unset($this->config[$offset]); + } + } + + /** + * 获取配置项参数 + * @param string|null $offset + * @return array|string|null + */ + public function offsetGet($offset = null) + { + if (is_null($offset)) { + return $this->config; + } + return isset($this->config[$offset]) ? $this->config[$offset] : null; + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Contracts/Error.php b/WeChat/WeChat/Contracts/Error.php new file mode 100644 index 0000000..016e72c --- /dev/null +++ b/WeChat/WeChat/Contracts/Error.php @@ -0,0 +1,194 @@ + '系统繁忙，此时请开发者稍候再试', + 0 => '请求成功', + 40001 => '获取 access_token 时 AppSecret 错误，或者 access_token 无效。请开发者认真比对 AppSecret 的正确性，或查看是否正在为恰当的公众号调用接口', + 40002 => '不合法的凭证类型', + 40003 => '不合法的 OpenID ，请开发者确认 OpenID （该用户）是否已关注公众号，或是否是其他公众号的 OpenID', + 40004 => '不合法的媒体文件类型', + 40005 => '不合法的文件类型', + 40006 => '不合法的文件大小', + 40007 => '不合法的媒体文件 id', + 40008 => '不合法的消息类型', + 40009 => '不合法的图片文件大小', + 40010 => '不合法的语音文件大小', + 40011 => '不合法的视频文件大小', + 40012 => '不合法的缩略图文件大小', + 40013 => '不合法的 AppID ，请开发者检查 AppID 的正确性，避免异常字符，注意大小写', + 40014 => '不合法的 access_token ，请开发者认真比对 access_token 的有效性（如是否过期），或查看是否正在为恰当的公众号调用接口', + 40015 => '不合法的菜单类型', + 40016 => '不合法的按钮个数', + 40017 => '不合法的按钮个数', + 40018 => '不合法的按钮名字长度', + 40019 => '不合法的按钮 KEY 长度', + 40020 => '不合法的按钮 URL 长度', + 40021 => '不合法的菜单版本号', + 40022 => '不合法的子菜单级数', + 40023 => '不合法的子菜单按钮个数', + 40024 => '不合法的子菜单按钮类型', + 40025 => '不合法的子菜单按钮名字长度', + 40026 => '不合法的子菜单按钮 KEY 长度', + 40027 => '不合法的子菜单按钮 URL 长度', + 40028 => '不合法的自定义菜单使用用户', + 40029 => '不合法的 oauth_code', + 40030 => '不合法的 refresh_token', + 40031 => '不合法的 openid 列表', + 40032 => '不合法的 openid 列表长度', + 40033 => '不合法的请求字符，不能包含 \\uxxxx 格式的字符', + 40035 => '不合法的参数', + 40038 => '不合法的请求格式', + 40039 => '不合法的 URL 长度', + 40050 => '不合法的分组 id', + 40051 => '分组名字不合法', + 40060 => '删除单篇图文时，指定的 article_idx 不合法', + 40117 => '分组名字不合法', + 40118 => 'media_id 大小不合法', + 40119 => 'button 类型错误', + 40120 => 'button 类型错误', + 40121 => '不合法的 media_id 类型', + 40132 => '微信号不合法', + 40137 => '不支持的图片格式', + 40155 => '请勿添加其他公众号的主页链接', + 41001 => '缺少 access_token 参数', + 41002 => '缺少 appid 参数', + 41003 => '缺少 refresh_token 参数', + 41004 => '缺少 secret 参数', + 41005 => '缺少多媒体文件数据', + 41006 => '缺少 media_id 参数', + 41007 => '缺少子菜单数据', + 41008 => '缺少 oauth code', + 41009 => '缺少 openid', + 42001 => 'access_token 超时，请检查 access_token 的有效期，请参考基础支持 - 获取 access_token 中，对 access_token 的详细机制说明', + 42002 => 'refresh_token 超时', + 42003 => 'oauth_code 超时', + 42007 => '用户修改微信密码， accesstoken 和 refreshtoken 失效，需要重新授权', + 43001 => '需要 GET 请求', + 43002 => '需要 POST 请求', + 43003 => '需要 HTTPS 请求', + 43004 => '需要接收者关注', + 43005 => '需要好友关系', + 43019 => '需要将接收者从黑名单中移除', + 44001 => '多媒体文件为空', + 44002 => 'POST 的数据包为空', + 44003 => '图文消息内容为空', + 44004 => '文本消息内容为空', + 45001 => '多媒体文件大小超过限制', + 45002 => '消息内容超过限制', + 45003 => '标题字段超过限制', + 45004 => '描述字段超过限制', + 45005 => '链接字段超过限制', + 45006 => '图片链接字段超过限制', + 45007 => '语音播放时间超过限制', + 45008 => '图文消息超过限制', + 45009 => '接口调用超过限制', + 45010 => '创建菜单个数超过限制', + 45011 => 'API 调用太频繁，请稍候再试', + 45015 => '回复时间超过限制', + 45016 => '系统分组，不允许修改', + 45017 => '分组名字过长', + 45018 => '分组数量超过上限', + 45047 => '客服接口下行条数超过上限', + 46001 => '不存在媒体数据', + 46002 => '不存在的菜单版本', + 46003 => '不存在的菜单数据', + 46004 => '不存在的用户', + 47001 => '解析 JSON/XML 内容错误', + 48001 => 'api 功能未授权，请确认公众号已获得该接口，可以在公众平台官网 - 开发者中心页中查看接口权限', + 48002 => '粉丝拒收消息（粉丝在公众号选项中，关闭了 “ 接收消息 ” ）', + 48004 => 'api 接口被封禁，请登录 mp.weixin.qq.com 查看详情', + 48005 => 'api 禁止删除被自动回复和自定义菜单引用的素材', + 48006 => 'api 禁止清零调用次数，因为清零次数达到上限', + 48008 => '没有该类型消息的发送权限', + 50001 => '用户未授权该 api', + 50002 => '用户受限，可能是违规后接口被封禁', + 61451 => '参数错误 (invalid parameter)', + 61452 => '无效客服账号 (invalid kf_account)', + 61453 => '客服帐号已存在 (kf_account exsited)', + 61454 => '客服帐号名长度超过限制 ( 仅允许 10 个英文字符，不包括 @ 及 @ 后的公众号的微信号 )(invalid kf_acount length)', + 61455 => '客服帐号名包含非法字符 ( 仅允许英文 + 数字 )(illegal character in kf_account)', + 61456 => '客服帐号个数超过限制 (10 个客服账号 )(kf_account count exceeded)', + 61457 => '无效头像文件类型 (invalid file type)', + 61450 => '系统错误 (system error)', + 61500 => '日期格式错误', + 65301 => '不存在此 menuid 对应的个性化菜单', + 65302 => '没有相应的用户', + 65303 => '没有默认菜单，不能创建个性化菜单', + 65304 => 'MatchRule 信息为空', + 65305 => '个性化菜单数量受限', + 65306 => '不支持个性化菜单的帐号', + 65307 => '个性化菜单信息为空', + 65308 => '包含没有响应类型的 button', + 65309 => '个性化菜单开关处于关闭状态', + 65310 => '填写了省份或城市信息，国家信息不能为空', + 65311 => '填写了城市信息，省份信息不能为空', + 65312 => '不合法的国家信息', + 65313 => '不合法的省份信息', + 65314 => '不合法的城市信息', + 65316 => '该公众号的菜单设置了过多的域名外跳（最多跳转到 3 个域名的链接）', + 65317 => '不合法的 URL', + 9001001 => 'POST 数据参数不合法', + 9001002 => '远端服务不可用', + 9001003 => 'Ticket 不合法', + 9001004 => '获取摇周边用户信息失败', + 9001005 => '获取商户信息失败', + 9001006 => '获取 OpenID 失败', + 9001007 => '上传文件缺失', + 9001008 => '上传素材的文件类型不合法', + 9001009 => '上传素材的文件尺寸不合法', + 9001010 => '上传失败', + 9001020 => '帐号不合法', + 9001021 => '已有设备激活率低于 50% ，不能新增设备', + 9001022 => '设备申请数不合法，必须为大于 0 的数字', + 9001023 => '已存在审核中的设备 ID 申请', + 9001024 => '一次查询设备 ID 数量不能超过 50', + 9001025 => '设备 ID 不合法', + 9001026 => '页面 ID 不合法', + 9001027 => '页面参数不合法', + 9001028 => '一次删除页面 ID 数量不能超过 10', + 9001029 => '页面已应用在设备中，请先解除应用关系再删除', + 9001030 => '一次查询页面 ID 数量不能超过 50', + 9001031 => '时间区间不合法', + 9001032 => '保存设备与页面的绑定关系参数错误', + 9001033 => '门店 ID 不合法', + 9001034 => '设备备注信息过长', + 9001035 => '设备申请参数不合法', + 9001036 => '查询起始值 begin 不合法', + ]; + + /** + * 异常代码解析描述 + * @param string $code + * @return string + */ + public static function toMessage($code) + { + return isset(self::$message[$code]) ? self::$message[$code] : $code; + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Contracts/Prpcrypt.php b/WeChat/WeChat/Contracts/Prpcrypt.php new file mode 100644 index 0000000..2b93c50 --- /dev/null +++ b/WeChat/WeChat/Contracts/Prpcrypt.php @@ -0,0 +1,189 @@ + PKCS7Encoder::$blockSize) { + $pad = 0; + } + return substr($text, 0, strlen($text) - $pad); + } + +} + +/** + * 公众号消息 - 加解密 + * Class Prpcrypt + */ +class Prpcrypt +{ + + public $key; + + /** + * Prpcrypt constructor. + * @param $key + */ + function __construct($key) + { + $this->key = base64_decode("{$key}="); + } + + /** + * 对明文进行加密 + * @param string $text 需要加密的明文 + * @param string $appid 公众号APPID + * @return array + */ + public function encrypt($text, $appid) + { + try { + $random = $this->getRandomStr(); + $iv = substr($this->key, 0, 16); + $pkcEncoder = new PKCS7Encoder(); + $text = $pkcEncoder->encode($random . pack("N", strlen($text)) . $text . $appid); + $encrypted = openssl_encrypt($text, 'AES-256-CBC', substr($this->key, 0, 32), OPENSSL_ZERO_PADDING, $iv); + return [ErrorCode::$OK, $encrypted]; + } catch (Exception $e) { + return [ErrorCode::$EncryptAESError, null]; + } + } + + /** + * 对密文进行解密 + * @param string $encrypted 需要解密的密文 + * @return array + */ + public function decrypt($encrypted) + { + try { + $iv = substr($this->key, 0, 16); + $decrypted = openssl_decrypt($encrypted, 'AES-256-CBC', substr($this->key, 0, 32), OPENSSL_ZERO_PADDING, $iv); + } catch (Exception $e) { + return [ErrorCode::$DecryptAESError, null]; + } + try { + $pkcEncoder = new PKCS7Encoder(); + $result = $pkcEncoder->decode($decrypted); + if (strlen($result) < 16) { + return [ErrorCode::$DecryptAESError, null]; + } + $content = substr($result, 16, strlen($result)); + $len_list = unpack("N", substr($content, 0, 4)); + $xml_len = $len_list[1]; + return [0, substr($content, 4, $xml_len), substr($content, $xml_len + 4)]; + } catch (Exception $e) { + return [ErrorCode::$IllegalBuffer, null]; + } + } + + /** + * 随机生成16位字符串 + * @param string $str + * @return string 生成的字符串 + */ + function getRandomStr($str = "") + { + $str_pol = "ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789abcdefghijklmnopqrstuvwxyz"; + $max = strlen($str_pol) - 1; + for ($i = 0; $i < 16; $i++) { + $str .= $str_pol[mt_rand(0, $max)]; + } + return $str; + } + +} + +/** + * 仅用作类内部使用 + * 不用于官方API接口的errCode码 + * Class ErrorCode + */ +class ErrorCode +{ + + public static $OK = 0; + public static $ParseXmlError = 40002; + public static $IllegalAesKey = 40004; + public static $IllegalBuffer = 40008; + public static $EncryptAESError = 40006; + public static $DecryptAESError = 40007; + public static $EncodeBase64Error = 40009; + public static $DecodeBase64Error = 40010; + public static $GenReturnXmlError = 40011; + public static $ValidateAppidError = 40005; + public static $ComputeSignatureError = 40003; + public static $ValidateSignatureError = 40001; + public static $errCode = [ + '0' => '处理成功', + '40001' => '校验签名失败', + '40002' => '解析xml失败', + '40003' => '计算签名失败', + '40004' => '不合法的AESKey', + '40005' => '校验AppID失败', + '40006' => 'AES加密失败', + '40007' => 'AES解密失败', + '40008' => '公众平台发送的xml不合法', + '40009' => 'Base64编码失败', + '40010' => 'Base64解码失败', + '40011' => '公众帐号生成回包xml失败', + ]; + + /** + * 获取错误消息内容 + * @param string $code 错误代码 + * @return bool + */ + public static function getErrText($code) + { + if (isset(self::$errCode[$code])) { + return self::$errCode[$code]; + } + return false; + } + +} diff --git a/WeChat/WeChat/Contracts/Request.php b/WeChat/WeChat/Contracts/Request.php new file mode 100644 index 0000000..94107d5 --- /dev/null +++ b/WeChat/WeChat/Contracts/Request.php @@ -0,0 +1,227 @@ +config = new Config($options); + $this->params = new Config($_REQUEST); + $this->appid = $this->config->get('appid'); + // 推送消息处理 + if ($_SERVER['REQUEST_METHOD'] == "POST") { + $this->postxml = file_get_contents("php://input"); + $this->encryptType = $this->params->get('encrypt_type'); + if ($this->encryptType == 'aes') { + if (empty($options['encodingaeskey'])) { + throw new InvalidArgumentException("Missing Config -- [encodingaeskey]"); + } + if (!class_exists('Prpcrypt', false)) { + require __DIR__ . '/Prpcrypt.php'; + } + $prpcrypt = new \Prpcrypt($this->config->get('encodingaeskey')); + $result = Tools::xml2arr($this->postxml); + $array = $prpcrypt->decrypt($result['Encrypt']); + if (intval($array[0]) > 0) { + throw new InvalidResponseException($array[1], $array[0]); + } + list($this->postxml, $this->appid) = [$array[1], $array[2]]; + } + $this->receive = new Config(Tools::xml2arr($this->postxml)); + } elseif ($_SERVER['REQUEST_METHOD'] == "GET" && $this->checkSignature()) { + @ob_clean(); + exit($this->params->get('echostr')); + } else { + throw new InvalidResponseException('Invalid interface request.', '0'); + } + } + + /** + * 验证来自微信服务器 + * @param string $str + * @return bool + */ + private function checkSignature($str = '') + { + $nonce = $this->params->get('nonce'); + $timestamp = $this->params->get('timestamp'); + $msg_signature = $this->params->get('msg_signature'); + $signature = empty($msg_signature) ? $this->params->get('signature') : $msg_signature; + $tmpArr = [$this->config->get('token'), $timestamp, $nonce, $str]; + sort($tmpArr, SORT_STRING); + if (sha1(implode($tmpArr)) == $signature) { + return true; + } + return false; + } + + /** + * 获取公众号推送对象 + * @return array + */ + public function getReceive() + { + return $this->receive->get(); + } + + /** + * 回复消息 + * @param array $data 消息内容 + * @param bool $return 是否返回XML内容 + * @return string + * @throws InvalidDecryptException + */ + public function reply(array $data = [], $return = false) + { + $xml = Tools::arr2xml(empty($data) ? $this->message : $data); + if ($this->encryptType == 'aes') { + if (!class_exists('Prpcrypt', false)) { + require __DIR__ . '/Prpcrypt.php'; + } + $prpcrypt = new \Prpcrypt($this->config->get('encodingaeskey')); + // 如果是第三方平台，加密得使用 component_appid + $component_appid = $this->config->get('component_appid'); + $appid = empty($component_appid) ? $this->appid : $component_appid; + $array = $prpcrypt->encrypt($xml, $appid); + if ($array[0] > 0) { + throw new InvalidDecryptException('Encrypt Error.', '0'); + } + list($timestamp, $encrypt) = [time(), $array[1]]; + $nonce = rand(77, 999) * rand(605, 888) * rand(11, 99); + $tmpArr = [$this->config->get('token'), $timestamp, $nonce, $encrypt]; + sort($tmpArr, SORT_STRING); + $signature = sha1(implode($tmpArr)); + $format = "%s"; + $xml = sprintf($format, $encrypt, $signature, $timestamp, $nonce); + } + if ($return) { + return $xml; + } + @ob_clean(); + echo $xml; + } + + /** + * 获取当前微信OPENID + * @return string + */ + public function getOpenid() + { + return $this->receive->get('FromUserName'); + } + + /** + * 获取当前推送消息内容 + * @return string + */ + public function getMsgType() + { + return $this->receive->get('MsgType'); + } + + /** + * 获取当前推送消息ID + * @return string + */ + public function getMsgId() + { + return $this->receive->get('MsgId'); + } + + /** + * 获取当前推送时间 + * @return integer + */ + public function getMsgTime() + { + return $this->receive->get('CreateTime'); + } + + /** + * 获取当前推送公众号 + * @return string + */ + public function getToOpenid() + { + return $this->receive->get('ToUserName'); + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Contracts/Tools.php b/WeChat/WeChat/Contracts/Tools.php new file mode 100644 index 0000000..e8766fe --- /dev/null +++ b/WeChat/WeChat/Contracts/Tools.php @@ -0,0 +1,348 @@ + $value) { + $params[] = "{$key}={$value}"; + } + return $method(join('&', $params)); + } + + /** + * 生成支付签名 + * @param array $data + * @param string $mchKey 商户密钥 + * @return string + */ + public static function getPaySign(array $data, $mchKey) + { + ksort($data); + $string = ""; + foreach ($data as $key => $value) { + $string .= "{$key}={$value}&"; + } + return strtoupper(hash_hmac('SHA256', "{$string}key={$mchKey}", $mchKey)); + } + + /** + * 根据文件后缀获取文件MINE + * @param array $ext 文件后缀 + * @param array $mine 文件后缀MINE信息 + * @return string + * @throws LocalCacheException + */ + public static function getExtMine($ext, $mine = []) + { + $mines = self::getMines(); + foreach (is_string($ext) ? explode(',', $ext) : $ext as $e) { + $mine[] = isset($mines[strtolower($e)]) ? $mines[strtolower($e)] : 'application/octet-stream'; + } + return join(',', array_unique($mine)); + } + + /** + * 获取所有文件扩展的mine + * @return array + * @throws LocalCacheException + */ + private static function getMines() + { + $mines = self::getCache('all_ext_mine'); + if (empty($mines)) { + $content = file_get_contents('http://svn.apache.org/repos/asf/httpd/httpd/trunk/docs/conf/mime.types'); + preg_match_all('#^([^\s]{2,}?)\s+(.+?)$#ism', $content, $matches, PREG_SET_ORDER); + foreach ($matches as $match) { + foreach (explode(" ", $match[2]) as $ext) { + $mines[$ext] = $match[1]; + } + } + self::setCache('all_ext_mine', $mines); + } + return $mines; + } + + /** + * 创建CURL文件对象 + * @param $filename + * @param string $mimetype + * @param string $postname + * @return \CURLFile|string + * @throws LocalCacheException + */ + public static function createCurlFile($filename, $mimetype = null, $postname = null) + { + is_null($postname) && $postname = basename($filename); + is_null($mimetype) && $mimetype = self::getExtMine(pathinfo($filename, 4)); + if (function_exists('curl_file_create')) { + return curl_file_create($filename, $mimetype, $postname); + } + return "@{$filename};filename={$postname};type={$mimetype}"; + } + + /** + * 以get访问模拟访问 + * @param string $url 访问URL + * @param array $query GET数 + * @param array $options + * @return bool|string + */ + public static function get($url, $query = [], $options = []) + { + $options['query'] = $query; + return self::doRequest('get', $url, $options); + } + + /** + * 以post访问模拟访问 + * @param string $url 访问URL + * @param array $data POST数据 + * @param array $options + * @return bool|string + */ + public static function post($url, $data = [], $options = []) + { + $options['data'] = $data; + return self::doRequest('post', $url, $options); + } + + /** + * 数组转XML内容 + * @param array $data + * @return string + */ + public static function arr2xml($data) + { + return "" . self::_arr2xml($data) . ""; + } + + /** + * XML内容生成 + * @param array $data 数据 + * @param string $content + * @return string + */ + private static function _arr2xml($data, $content = '') + { + foreach ($data as $key => $val) { + $content .= "<{$key}>"; + if (is_array($val) || is_object($val)) { + $content .= self::_arr2xml($val); + } elseif (is_string($val)) { + $content .= ''; + } else { + $content .= $val; + } + $content .= ""; + } + return $content; + } + + /** + * 解析XML内容到数组 + * @param string $xml + * @return array + */ + public static function xml2arr($xml) + { + return json_decode(self::arr2json(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true); + } + + /** + * 数组转xml内容 + * @param array $data + * @return null|string|string + */ + public static function arr2json($data) + { + return preg_replace_callback('/\\\\u([0-9a-f]{4})/i', function ($matches) { + return mb_convert_encoding(pack("H*", $matches[1]), "UTF-8", "UCS-2BE"); + }, json_encode($data)); + } + + /** + * 解析JSON内容到数组 + * @param string $json + * @return array + * @throws InvalidResponseException + */ + public static function json2arr($json) + { + $result = json_decode($json, true); + if (empty($result)) { + throw new InvalidResponseException('invalid response.', '0'); + } + if (!empty($result['errcode'])) { + throw new InvalidResponseException($result['errmsg'], $result['errcode'], $result); + } + return $result; + } + + /** + * CURL模拟网络请求 + * @param string $method 请求方法 + * @param string $url 请求方法 + * @param array $options 请求参数[headers,data,ssl_cer,ssl_key] + * @return bool|string + */ + protected static function doRequest($method, $url, $options = []) + { + $curl = curl_init(); + // GET参数设置 + if (!empty($options['query'])) { + $url .= (stripos($url, '?') !== false ? '&' : '?') . http_build_query($options['query']); + } + // CURL头信息设置 + if (!empty($options['headers'])) { + curl_setopt($curl, CURLOPT_HTTPHEADER, $options['headers']); + } + // POST数据设置 + if (strtolower($method) === 'post') { + curl_setopt($curl, CURLOPT_POST, true); + curl_setopt($curl, CURLOPT_POSTFIELDS, $options['data']); + } + // 证书文件设置 + if (!empty($options['ssl_cer'])) { + if (file_exists($options['ssl_cer'])) { + curl_setopt($curl, CURLOPT_SSLCERTTYPE, 'PEM'); + curl_setopt($curl, CURLOPT_SSLCERT, $options['ssl_cer']); + } else { + throw new InvalidArgumentException("Certificate files that do not exist. --- [{$options['ssl_cer']}]"); + } + } + // 证书文件设置 + if (!empty($options['ssl_key'])) { + if (file_exists($options['ssl_key'])) { + curl_setopt($curl, CURLOPT_SSLKEYTYPE, 'PEM'); + curl_setopt($curl, CURLOPT_SSLKEY, $options['ssl_key']); + } else { + throw new InvalidArgumentException("Certificate files that do not exist. --- [{$options['ssl_key']}]"); + } + } + curl_setopt($curl, CURLOPT_URL, $url); + curl_setopt($curl, CURLOPT_TIMEOUT, 60); + curl_setopt($curl, CURLOPT_HEADER, false); + curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); + curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); + curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); + list($content, $status) = [curl_exec($curl), curl_getinfo($curl), curl_close($curl)]; + return (intval($status["http_code"]) === 200) ? $content : false; + } + + /** + * 缓存配置与存储 + * @param string $name 缓存名称 + * @param string $value 缓存内容 + * @param int $expired 缓存时间(0表示永久缓存) + * @throws LocalCacheException + */ + public static function setCache($name, $value = '', $expired = 3600) + { + $cache_file = self::getCacheName($name); + $content = serialize(['name' => $name, 'value' => $value, 'expired' => time() + intval($expired)]); + if (!file_put_contents($cache_file, $content)) { + throw new LocalCacheException('local cache error.', '0'); + } + } + + /** + * 获取缓存内容 + * @param string $name 缓存名称 + * @return null|mixed + */ + public static function getCache($name) + { + $cache_file = self::getCacheName($name); + if (file_exists($cache_file) && ($content = file_get_contents($cache_file))) { + $data = unserialize($content); + if (isset($data['expired']) && (intval($data['expired']) === 0 || intval($data['expired']) >= time())) { + return $data['value']; + } + self::delCache($name); + } + return null; + } + + /** + * 移除缓存文件 + * @param string $name 缓存名称 + * @return bool + */ + public static function delCache($name) + { + $cache_file = self::getCacheName($name); + return file_exists($cache_file) ? unlink($cache_file) : true; + } + + /** + * 应用缓存目录 + * @param string $name + * @return string + */ + private static function getCacheName($name) + { + if (empty(self::$cache_path)) { + self::$cache_path = dirname(__DIR__) . DIRECTORY_SEPARATOR . 'Cache' . DIRECTORY_SEPARATOR; + } + self::$cache_path = rtrim(self::$cache_path, '/\\') . DIRECTORY_SEPARATOR; + file_exists(self::$cache_path) || mkdir(self::$cache_path, 0755, true); + return self::$cache_path . md5($name); + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Custom.php b/WeChat/WeChat/Custom.php new file mode 100644 index 0000000..4503378 --- /dev/null +++ b/WeChat/WeChat/Custom.php @@ -0,0 +1,220 @@ + $kf_account, 'nickname' => $nickname, 'password' => $password]; + $url = "https://api.weixin.qq.com/customservice/kfaccount/add?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 修改客服帐号 + * @param string $kf_account 客服账号 + * @param string $nickname 客服昵称 + * @param string $password 账号密码 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateAccount($kf_account, $nickname, $password) + { + $data = ['kf_account' => $kf_account, 'nickname' => $nickname, 'password' => $password]; + $url = "https://api.weixin.qq.com/customservice/kfaccount/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除客服帐号 + * @param string $kf_account 客服账号 + * @param string $nickname 客服昵称 + * @param string $password 账号密码 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deleteAccount($kf_account, $nickname, $password) + { + $data = ['kf_account' => $kf_account, 'nickname' => $nickname, 'password' => $password]; + $url = "https://api.weixin.qq.com/customservice/kfaccount/del?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 获取所有客服账号 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getAccountList() + { + $url = "https://api.weixin.qq.com/cgi-bin/customservice/getkflist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 客服接口-发消息 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function send(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 客服输入状态 + * @param string $openid 普通用户（openid） + * @param string $command Typing:正在输入,CancelTyping:取消正在输入 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function typing($openid, $command = 'Typing') + { + $url = "https://api.weixin.qq.com/cgi-bin/message/custom/typing?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['touser' => $openid, 'command' => $command]); + } + + /** + * 根据标签进行群发【订阅号与服务号认证后均可用】 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massSendAll(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/sendall?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 根据OpenID列表群发【订阅号不可用，服务号认证后可用】 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massSend(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/send?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除群发【订阅号与服务号认证后均可用】 + * @param integer $msg_id 发送出去的消息ID + * @param null|integer $article_idx 要删除的文章在图文消息中的位置，第一篇编号为1，该字段不填或填0会删除全部文章 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massDelete($msg_id, $article_idx = null) + { + $data = ['msg_id' => $msg_id]; + is_null($article_idx) || $data['article_idx'] = $article_idx; + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/delete?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 预览接口【订阅号与服务号认证后均可用】 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massPreview(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/preview?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询群发消息发送状态【订阅号与服务号认证后均可用】 + * @param integer $msg_id 群发消息后返回的消息id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massGet($msg_id) + { + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['msg_id' => $msg_id]); + } + + /** + * 获取群发速度 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massGetSeed() + { + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/speed/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, []); + } + + /** + * 设置群发速度 + * @param integer $speed 群发速度的级别 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function massSetSeed($speed) + { + $url = "https://api.weixin.qq.com/cgi-bin/message/mass/speed/set?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, []); + } + + +} \ No newline at end of file diff --git a/WeChat/WeChat/Exceptions/InvalidArgumentException.php b/WeChat/WeChat/Exceptions/InvalidArgumentException.php new file mode 100644 index 0000000..e9740c8 --- /dev/null +++ b/WeChat/WeChat/Exceptions/InvalidArgumentException.php @@ -0,0 +1,25 @@ +raw = $raw; + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Exceptions/InvalidResponseException.php b/WeChat/WeChat/Exceptions/InvalidResponseException.php new file mode 100644 index 0000000..d5a2c12 --- /dev/null +++ b/WeChat/WeChat/Exceptions/InvalidResponseException.php @@ -0,0 +1,41 @@ +raw = $raw; + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Exceptions/LocalCacheException.php b/WeChat/WeChat/Exceptions/LocalCacheException.php new file mode 100644 index 0000000..2814768 --- /dev/null +++ b/WeChat/WeChat/Exceptions/LocalCacheException.php @@ -0,0 +1,42 @@ +raw = $raw; + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Media.php b/WeChat/WeChat/Media.php new file mode 100644 index 0000000..7b1e7e9 --- /dev/null +++ b/WeChat/WeChat/Media.php @@ -0,0 +1,183 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['media' => Tools::createCurlFile($filename)], false); + } + + /** + * 获取临时素材 + * @param string $media_id + * @return bool|string + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function get($media_id) + { + $url = "https://api.weixin.qq.com/cgi-bin/media/get?access_token=ACCESS_TOKEN&media_id={$media_id}"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return Tools::get($url); + } + + /** + * 新增临时素材 + * @param array $data 文件名称 + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function addNews($data) + { + $url = "https://api.weixin.qq.com/cgi-bin/material/add_news?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 新增临时素材 + * @param string $media_id 要修改的图文消息的id + * @param int $index 要更新的文章在图文消息中的位置（多图文消息时，此字段才有意义），第一篇为0 + * @param array $news 文章内容 + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function updateNews($media_id, $index, $news) + { + $data = ['media_id' => $media_id, 'index' => $index, 'articles' => $news]; + $url = "https://api.weixin.qq.com/cgi-bin/material/update_news?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 上传图文消息内的图片获取URL + * @param string $filename + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function uploadImg($filename) + { + $url = "https://api.weixin.qq.com/cgi-bin/media/uploadimg?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['media' => Tools::createCurlFile($filename)], false); + } + + /** + * 新增其他类型永久素材 + * @param string $filename 文件名称 + * @param string $type 媒体文件类型(image|voice|video|thumb) + * @param array $description 包含素材的描述信息 + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function addMaterial($filename, $type = 'image', $description = []) + { + if (!in_array($type, ['image', 'voice', 'video', 'thumb'])) { + throw new InvalidResponseException('Invalid Media Type.', '0'); + } + $url = "https://api.weixin.qq.com/cgi-bin/material/add_material?access_token=ACCESS_TOKEN&type={$type}"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['media' => Tools::createCurlFile($filename), 'description' => Tools::arr2json($description)], false); + } + + /** + * 获取永久素材 + * @param string $media_id + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function getMaterial($media_id) + { + $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['media_id' => $media_id]); + } + + /** + * 删除永久素材 + * @param string $media_id + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function delMaterial($media_id) + { + $url = "https://api.weixin.qq.com/cgi-bin/material/del_material?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['media_id' => $media_id]); + } + + /** + * 获取素材总数 + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function getMaterialCount() + { + $url = "https://api.weixin.qq.com/cgi-bin/material/get_materialcount?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 获取素材列表 + * @param string $type + * @param int $offset + * @param int $count + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function batchGetMaterial($type = 'image', $offset = 0, $count = 20) + { + if (!in_array($type, ['image', 'voice', 'video', 'news'])) { + throw new InvalidResponseException('Invalid Media Type.', '0'); + } + $url = "https://api.weixin.qq.com/cgi-bin/material/batchget_material?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['type' => $type, 'offset' => $offset, 'count' => $count]); + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Menu.php b/WeChat/WeChat/Menu.php new file mode 100644 index 0000000..993b8d3 --- /dev/null +++ b/WeChat/WeChat/Menu.php @@ -0,0 +1,109 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 自定义菜单删除接口 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function delete() + { + $url = "https://api.weixin.qq.com/cgi-bin/menu/delete?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 自定义菜单创建 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function create(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 创建个性化菜单 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addConditional(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/menu/addconditional?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除个性化菜单 + * @param string $menuid + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function delConditional($menuid) + { + $url = "https://api.weixin.qq.com/cgi-bin/menu/delconditional?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['menuid' => $menuid]); + } + + /** + * 测试个性化菜单匹配结果 + * @param string $openid + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function tryConditional($openid) + { + $url = "https://api.weixin.qq.com/cgi-bin/menu/trymatch?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['user_id' => $openid]); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Oauth.php b/WeChat/WeChat/Oauth.php new file mode 100644 index 0000000..0a5aefb --- /dev/null +++ b/WeChat/WeChat/Oauth.php @@ -0,0 +1,93 @@ +config->get('appid'); + $redirect_uri = urlencode($redirect_url); + return "https://open.weixin.qq.com/connect/oauth2/authorize?appid={$appid}&redirect_uri={$redirect_uri}&response_type=code&scope={$scope}&state={$state}#wechat_redirect"; + } + + /** + * 通过 code 获取 AccessToken 和 openid + * @return bool|array + */ + public function getOauthAccessToken() + { + $appid = $this->config->get('appid'); + $appsecret = $this->config->get('appsecret'); + $code = isset($_GET['code']) ? $_GET['code'] : ''; + $url = " https://api.weixin.qq.com/sns/oauth2/access_token?appid={$appid}&secret={$appsecret}&code={$code}&grant_type=authorization_code"; + return $this->httpGetForJson($url); + } + + /** + * 刷新AccessToken并续期 + * @param string $refresh_token + * @return bool|array + */ + public function getOauthRefreshToken($refresh_token) + { + $appid = $this->config->get('appid'); + $url = "https://api.weixin.qq.com/sns/oauth2/refresh_token?appid={$appid}&grant_type=refresh_token&refresh_token={$refresh_token}"; + return $this->httpGetForJson($url); + } + + /** + * 检验授权凭证（access_token）是否有效 + * @param string $access_token 网页授权接口调用凭证,注意：此access_token与基础支持的access_token不同 + * @param string $openid 用户的唯一标识 + * @return array + */ + public function checkOauthAccessToken($access_token, $openid) + { + $url = "https://api.weixin.qq.com/sns/auth?access_token={$access_token}&openid={$openid}"; + return $this->httpGetForJson($url); + } + + /** + * 拉取用户信息(需scope为 snsapi_userinfo) + * @param string $openid 用户的唯一标识 + * @param string $lang 返回国家地区语言版本，zh_CN 简体，zh_TW 繁体，en 英语 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getUserInfo($openid, $lang = 'zh_CN') + { + $url = "https://api.weixin.qq.com/sns/userinfo?access_token=ACCESS_TOKEN&openid={$openid}&lang={$lang}"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Pay.php b/WeChat/WeChat/Pay.php new file mode 100644 index 0000000..6dafc29 --- /dev/null +++ b/WeChat/WeChat/Pay.php @@ -0,0 +1,212 @@ +config = new Config($options); + $this->params = new Config([ + 'appid' => $this->config->get('appid'), + 'mch_id' => $this->config->get('mch_id'), + 'nonce_str' => Tools::createNoncestr(), + ]); + } + + /** + * 统一下单 + * @param array $options + * @return array + */ + public function order(array $options) + { + $url = 'https://api.mch.weixin.qq.com/pay/unifiedorder'; + return $this->callPostApi($url, $options); + } + + /** + * 查询订单 + * @param array $options + * @return array + */ + public function queryOrder(array $options) + { + $url = 'https://api.mch.weixin.qq.com/pay/orderquery'; + return $this->callPostApi($url, $options); + } + + /** + * 关闭订单 + * @param string $out_trade_no 商户订单号 + * @return array + */ + public function close($out_trade_no) + { + $url = 'https://api.mch.weixin.qq.com/pay/closeorder'; + return $this->callPostApi($url, ['out_trade_no' => $out_trade_no]); + } + + /** + * 申请退款 + * @param array $options + * @return array + */ + public function refund(array $options) + { + $url = 'https://api.mch.weixin.qq.com/secapi/pay/refund'; + return $this->callPostApi($url, $options, true); + } + + /** + * 查询退款 + * @param array $options + * @return array + */ + public function queryRefund(array $options) + { + $url = 'https://api.mch.weixin.qq.com/pay/refundquery'; + return $this->callPostApi($url, $options); + } + + /** + * 交易保障 + * @param array $options + * @return array + */ + public function report(array $options) + { + $url = 'https://api.mch.weixin.qq.com/payitil/report'; + return $this->callPostApi($url, $options); + } + + /** + * 授权码查询openid + * @param string $authCode 扫码支付授权码，设备读取用户微信中的条码或者二维码信息 + * @return array + */ + public function queryAuthCode($authCode) + { + $url = 'https://api.mch.weixin.qq.com/tools/authcodetoopenid'; + return $this->callPostApi($url, ['auth_code' => $authCode]); + } + + /** + * 转换短链接 + * @param string $longUrl 需要转换的URL，签名用原串，传输需URLencode + * @return array + */ + public function shortUrl($longUrl) + { + $url = 'https://api.mch.weixin.qq.com/tools/shorturl'; + return $this->callPostApi($url, ['long_url' => $longUrl]); + } + + /** + * 下载对账单 + * @param array $options + * @return array + */ + public function bill(array $options) + { + $url = 'https://api.mch.weixin.qq.com/pay/downloadbill'; + return $this->callPostApi($url, $options); + } + + + /** + * 拉取订单评价数据 + * @param array $options + * @return array + */ + public function billCommtent(array $options) + { + $url = 'https://api.mch.weixin.qq.com/billcommentsp/batchquerycomment'; + return $this->callPostApi($url, $options, true); + } + + /** + * 获取微信支付通知 + * @return array + * @throws InvalidResponseException + */ + public function getNotify() + { + $data = Tools::xml2arr(file_get_contents('php://input')); + if (!empty($data['sign'])) { + if (Tools::getPaySign($data, $this->config->get('mch_key')) === $data['sign']) { + return $data; + } + } + throw new InvalidResponseException('Invalid Notify.', '0'); + } + + /** + * 以Post请求接口 + * @param string $url 请求 + * @param array $data 接口参数 + * @param bool $isCert 是否需要使用双向证书 + * @return array + */ + public function callPostApi($url, array $data, $isCert = false) + { + $option = []; + if ($isCert) { + foreach (['ssl_cer', 'ssl_key'] as $key) { + if (empty($options['ssl_cer'])) { + throw new InvalidArgumentException("Missing Config -- [{$key}]", '0'); + } + } + $option['ssl_cer'] = $this->config->get('ssl_cer'); + $option['ssl_key'] = $this->config->get('ssl_key'); + } + $params = $this->params->merge($data); + $params['sign_type'] = 'HMAC-SHA256'; + $params['sign'] = Tools::getPaySign($params, $this->config->get('mch_key')); + return Tools::xml2arr(Tools::post($url, Tools::arr2xml($params), $option)); + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Product.php b/WeChat/WeChat/Product.php new file mode 100644 index 0000000..e912f21 --- /dev/null +++ b/WeChat/WeChat/Product.php @@ -0,0 +1,178 @@ + $keystandard, 'keystr' => $keystr, 'status' => $status]; + $url = "https://api.weixin.qq.com/scan/product/modstatus?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 设置测试人员白名单 + * @param array $openids 测试人员的openid列表 + * @param array $usernames 测试人员的微信号列表 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setTestWhiteList(array $openids = [], array $usernames = []) + { + $data = ['openid' => $openids, 'username' => $usernames]; + $url = "https://api.weixin.qq.com/scan/testwhitelist/set?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 获取商品二维码 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @param integer $qrcode_size 二维码的尺寸（整型），数值代表边长像素数，不填写默认值为100 + * @param array $extinfo 由商户自定义传入，建议仅使用大小写字母、数字及-_().*这6个常用字符 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getQrcode($keystandard, $keystr, $qrcode_size, $extinfo = []) + { + $data = ['keystandard' => $keystandard, 'keystr' => $keystr, 'qrcode_size' => $qrcode_size]; + empty($extinfo) || $data['extinfo'] = $extinfo; + $url = "https://api.weixin.qq.com/scan/product/getqrcode?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询商品信息 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getProduct($keystandard, $keystr) + { + $data = ['keystandard' => $keystandard, 'keystr' => $keystr]; + empty($extinfo) || $data['extinfo'] = $extinfo; + $url = "https://api.weixin.qq.com/scan/product/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 批量查询商品信息 + * @param integer $offset 批量查询的起始位置，从0开始，包含该起始位置 + * @param integer $limit 批量查询的数量 + * @param null|string $status 支持按状态拉取。on为发布状态，off为未发布状态，check为审核中状态，reject为审核未通过状态，all为所有状态 + * @param string $keystr 支持按部分编码内容拉取。填写该参数后，可将编码内容中包含所传参数的商品信息拉出。类似关键词搜索 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getProductList($offset, $limit = 10, $status = null, $keystr = '') + { + $data = ['offset' => $offset, 'limit' => $limit]; + is_null($status) || $data['status'] = $status; + empty($keystr) || $data['keystr'] = $keystr; + $url = "https://api.weixin.qq.com/scan/product/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + + /** + * 更新商品信息 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateProduct(array $data) + { + $url = "https://api.weixin.qq.com/scan/product/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 清除商品信息 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function clearProduct($keystandard, $keystr) + { + $url = "https://api.weixin.qq.com/scan/product/clear?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['keystandard' => $keystandard, 'keystr' => $keystr]); + } + + + /** + * 检查wxticket参数 + * @param string $ticket + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function scanTicketCheck($ticket) + { + $url = "https://api.weixin.qq.com/scan/scanticket/check?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['ticket' => $ticket]); + } + + /** + * 清除扫码记录 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @param string $extinfo 调用“获取商品二维码接口”时传入的extinfo，为标识参数 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function clearScanticket($keystandard, $keystr, $extinfo) + { + $data = ['keystandard' => $keystandard, 'keystr' => $keystr, 'extinfo' => $extinfo]; + $url = "https://api.weixin.qq.com/scan/scanticket/check?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Qrcode.php b/WeChat/WeChat/Qrcode.php new file mode 100644 index 0000000..aff5d39 --- /dev/null +++ b/WeChat/WeChat/Qrcode.php @@ -0,0 +1,72 @@ + 'QR_LIMIT_SCENE', 'action_info' => ['scene' => ['scene_id' => $scene]]]; + } else { + $data = ['action_name' => 'QR_LIMIT_STR_SCENE', 'action_info' => ['scene' => ['scene_str' => $scene]]]; + } + empty($expire_seconds) || $data['expire_seconds'] = $expire_seconds; + $url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 通过ticket换取二维码 + * @param string $ticket + * @return string + */ + public function url($ticket) + { + return "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket={$ticket}"; + } + + /** + * 长链接转短链接接口 + * @param string $longUrl 需要转换的长链接 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function shortUrl($longUrl) + { + $url = "https://api.weixin.qq.com/cgi-bin/shorturl?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['action' => 'long2short', 'long_url' => $longUrl]); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Receive.php b/WeChat/WeChat/Receive.php new file mode 100644 index 0000000..1cb78cf --- /dev/null +++ b/WeChat/WeChat/Receive.php @@ -0,0 +1,164 @@ +message = [ + 'CreateTime' => time(), + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + 'MsgType' => 'transfer_customer_service', + ]; + empty($account) || $this->message['TransInfo'] = ['KfAccount' => $account]; + return $this; + } + + /** + * 设置文本消息 + * @param string $content 文本内容 + * @return $this + */ + public function text($content = '') + { + $this->message = [ + 'MsgType' => 'text', + 'CreateTime' => time(), + 'Content' => $content, + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + ]; + return $this; + } + + /** + * 设置回复图文 + * @param array $newsData + * @return $this + */ + public function news($newsData = []) + { + $this->message = [ + 'CreateTime' => time(), + 'MsgType' => 'mpnews', + 'Articles' => $newsData, + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + 'ArticleCount' => count($newsData), + ]; + return $this; + } + + /** + * 设置图片消息 + * @param string $mediaId 图片媒体ID + * @return $this + */ + public function image($mediaId = '') + { + $this->message = [ + 'MsgType' => 'image', + 'CreateTime' => time(), + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + 'Image' => ['MediaId' => $mediaId], + ]; + return $this; + } + + /** + * 设置语音回复消息 + * @param string $mediaid 语音媒体ID + * @return $this + */ + public function voice($mediaid = '') + { + $this->message = [ + 'CreateTime' => time(), + 'MsgType' => 'voice', + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + 'Voice' => ['MediaId' => $mediaid], + ]; + return $this; + } + + /** + * 设置视频回复消息 + * @param string $mediaid 视频媒体ID + * @param string $title 视频标题 + * @param string $description 视频描述 + * @return $this + */ + public function video($mediaid = '', $title = '', $description = '') + { + $this->message = [ + 'CreateTime' => time(), + 'MsgType' => 'video', + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + 'Video' => [ + 'Title' => $title, + 'MediaId' => $mediaid, + 'Description' => $description, + ], + ]; + return $this; + } + + /** + * 设置音乐回复消息 + * @param string $title 音乐标题 + * @param string $desc 音乐描述 + * @param string $musicurl 音乐地址 + * @param string $hgmusicurl 高清音乐地址 + * @param string $thumbmediaid 音乐图片缩略图的媒体id（可选） + * @return $this + */ + public function music($title, $desc, $musicurl, $hgmusicurl = '', $thumbmediaid = '') + { + $this->message = [ + 'CreateTime' => time(), + 'MsgType' => 'music', + 'ToUserName' => $this->getOpenid(), + 'FromUserName' => $this->getToOpenid(), + 'Music' => [ + 'Title' => $title, + 'Description' => $desc, + 'MusicUrl' => $musicurl, + 'HQMusicUrl' => $hgmusicurl, + ], + ]; + if ($thumbmediaid) { + $this->message['Music']['ThumbMediaId'] = $thumbmediaid; + } + return $this; + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Scan.php b/WeChat/WeChat/Scan.php new file mode 100644 index 0000000..54d5244 --- /dev/null +++ b/WeChat/WeChat/Scan.php @@ -0,0 +1,199 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 创建商品 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addProduct(array $data) + { + $url = "https://api.weixin.qq.com/scan/product/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 商品发布 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @param string $status 设置发布状态。on为提交审核，off为取消发布 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function modProduct($keystandard, $keystr, $status = 'on') + { + $data = ['keystandard' => $keystandard, 'keystr' => $keystr, 'status' => $status]; + $url = "https://api.weixin.qq.com/scan/product/modstatus?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 设置测试人员白名单 + * @param array $openids 测试人员的openid列表 + * @param array $usernames 测试人员的微信号列表 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setTestWhiteList($openids = [], $usernames = []) + { + $data = ['openid' => $openids, 'username' => $usernames]; + $url = "https://api.weixin.qq.com/scan/product/modstatus?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 获取商品二维码 + * @param string $keystandard + * @param string $keystr + * @param null|string $extinfo + * @param integer $qrcode_size + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getQrc($keystandard, $keystr, $extinfo = null, $qrcode_size = 64) + { + $data = ['keystandard' => $keystandard, 'keystr' => $keystr, 'qrcode_size' => $qrcode_size]; + is_null($extinfo) || $data['extinfo'] = $extinfo; + $url = "https://api.weixin.qq.com/scan/product/getqrcode?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询商品信息 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getProductInfo($keystandard, $keystr) + { + $url = "https://api.weixin.qq.com/scan/product/get?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['keystandard' => $keystandard, 'keystr' => $keystr]); + } + + /** + * 批量查询商品信息 + * @param integer $offset 批量查询的起始位置，从0开始，包含该起始位置。 + * @param integer $limit 批量查询的数量。 + * @param string $status 支持按状态拉取。on为发布状态，off为未发布状态，check为审核中状态，reject为审核未通过状态，all为所有状态。 + * @param string $keystr 支持按部分编码内容拉取。填写该参数后，可将编码内容中包含所传参数的商品信息拉出。类似关键词搜索。 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getProductList($offset = 1, $limit = 10, $status = null, $keystr = null) + { + $data = ['offset' => $offset, 'limit' => $limit]; + is_null($status) || $data['status'] = $status; + is_null($keystr) || $data['keystr'] = $keystr; + $url = "https://api.weixin.qq.com/scan/product/getlist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 更新商品信息 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateProduct(array $data) + { + $url = "https://api.weixin.qq.com/scan/product/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 清除商品信息 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function clearProduct($keystandard, $keystr) + { + $url = "https://api.weixin.qq.com/scan/product/clear?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['keystandard' => $keystandard, 'keystr' => $keystr]); + } + + /** + * 检查wxticket参数 + * @param string $ticket + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function checkTicket($ticket) + { + $url = "https://api.weixin.qq.com/scan/scanticket/check?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['ticket' => $ticket]); + } + + /** + * 清除扫码记录 + * @param string $keystandard 商品编码标准 + * @param string $keystr 商品编码内容 + * @param string $extinfo 调用“获取商品二维码接口”时传入的extinfo，为标识参数 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function clearScanTicket($keystandard, $keystr, $extinfo) + { + $url = "https://api.weixin.qq.com/scan/scanticket/check?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['keystandard' => $keystandard, 'keystr' => $keystr, 'extinfo' => $extinfo]); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Script.php b/WeChat/WeChat/Script.php new file mode 100644 index 0000000..7a96dde --- /dev/null +++ b/WeChat/WeChat/Script.php @@ -0,0 +1,102 @@ +config->get('appid'); + $cache_name = "WeChat_{$type}_ticket_{$appid}"; + Tools::delCache($cache_name); + } + + /** + * 获取JSAPI_TICKET接口 + * @param string $type TICKET类型(wx_card|jsapi) + * @param string $appid 强制指定有效APPID + * @return string + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getTicket($type = 'jsapi', $appid = null) + { + is_null($appid) && $appid = $this->config->get('appid'); + $cache_name = "WeChat_{$type}_ticket_{$appid}"; + $ticket = Tools::getCache($cache_name); + if (empty($ticket)) { + $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type={$type}"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + $result = $this->httpGetForJson($url); + if (empty($result['ticket'])) { + throw new InvalidResponseException('Invalid Resoponse Ticket.', '0'); + } + $ticket = $result['ticket']; + Tools::setCache($cache_name, $ticket, 5000); + } + return $ticket; + } + + /** + * 获取JsApi使用签名 + * @param string $url 网页的URL + * @param string $appid 用于多个appid时使用(可空) + * @param string $ticket 强制指定ticket + * @return array + * @throws Exceptions\LocalCacheException + * @throws InvalidResponseException + */ + public function getJsSign($url, $appid = null, $ticket = null) + { + list($url,) = explode('#', $url); + is_null($ticket) && $ticket = $this->getTicket('jsapi'); + is_null($appid) && $appid = $this->config->get('appid'); + $data = ["url" => $url, "timestamp" => '' . time(), "jsapi_ticket" => $ticket, "noncestr" => Tools::createNoncestr(16)]; + return [ + 'debug' => false, + "appId" => $appid, + "nonceStr" => $data['noncestr'], + "timestamp" => $data['timestamp'], + "signature" => Tools::getSignature($data, 'sha1'), + 'jsApiList' => [ + 'onWXDeviceBluetoothStateChange', 'onWXDeviceStateChange', + 'openProductSpecificView', 'addCard', 'chooseCard', 'openCard', + 'translateVoice', 'getNetworkType', 'openLocation', 'getLocation', + 'onMenuShareTimeline', 'onMenuShareAppMessage', 'onMenuShareQQ', 'onMenuShareWeibo', 'onMenuShareQZone', + 'chooseImage', 'previewImage', 'uploadImage', 'downloadImage', 'closeWindow', 'scanQRCode', 'chooseWXPay', + 'hideOptionMenu', 'showOptionMenu', 'hideMenuItems', 'showMenuItems', 'hideAllNonBaseMenuItem', 'showAllNonBaseMenuItem', + 'startScanWXDevice', 'stopScanWXDevice', 'onWXDeviceBindStateChange', 'onScanWXDeviceResult', 'onReceiveDataFromWXDevice', + 'startRecord', 'stopRecord', 'onVoiceRecordEnd', 'playVoice', 'pauseVoice', 'stopVoice', 'onVoicePlayEnd', 'uploadVoice', 'downloadVoice', + 'openWXDeviceLib', 'closeWXDeviceLib', 'getWXDeviceInfos', 'sendDataToWXDevice', 'disconnectWXDevice', 'getWXDeviceTicket', 'connectWXDevice', + ], + ]; + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Shake.php b/WeChat/WeChat/Shake.php new file mode 100644 index 0000000..6d8b2e4 --- /dev/null +++ b/WeChat/WeChat/Shake.php @@ -0,0 +1,364 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询审核状态 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function auditStatus() + { + $url = "https://api.weixin.qq.com/shakearound/account/auditstatus?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 申请设备ID + * @param string $quantity 申请的设备ID的数量，单次新增设备超过500个，需走人工审核流程 + * @param string $apply_reason 申请理由，不超过100个汉字或200个英文字母 + * @param null|string $comment 备注，不超过15个汉字或30个英文字母 + * @param null|string $poi_id 设备关联的门店ID，关联门店后，在门店1KM的范围内有优先摇出信息的机会。 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function createApply($quantity, $apply_reason, $comment = null, $poi_id = null) + { + $data = ['quantity' => $quantity, 'apply_reason' => $apply_reason]; + is_null($poi_id) || $data['poi_id'] = $poi_id; + is_null($comment) || $data['comment'] = $comment; + $url = "https://api.weixin.qq.com/shakearound/device/applyid?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询设备ID申请审核状态 + * @param integer $applyId 批次ID，申请设备ID时所返回的批次ID + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getApplyStatus($applyId) + { + $url = "https://api.weixin.qq.com/shakearound/device/applyid?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['apply_id' => $applyId]); + } + + /** + * 编辑设备信息 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateApply(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/device/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 配置设备与门店的关联关系 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function bindLocation(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/device/bindlocation?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询设备列表 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function search(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/device/search?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 页面管理 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function createPage(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/page/add?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 编辑页面信息 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updatePage(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/page/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询页面列表 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function searchPage(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/page/search?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除页面 + * @param integer page_id 指定页面的id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deletePage($page_id) + { + $url = "https://api.weixin.qq.com/shakearound/page/delete?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['page_id' => $page_id]); + } + + /** + * 上传图片素材 + * @param string $filename 图片名字 + * @param string $type Icon：摇一摇页面展示的icon图；License：申请开通摇一摇周边功能时需上传的资质文件；若不传type，则默认type=icon + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function upload($filename, $type = 'icon') + { + $url = "https://api.weixin.qq.com/shakearound/material/add?access_token=ACCESS_TOKEN&type={$type}"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['media' => Tools::createCurlFile($filename)]); + } + + /** + * 配置设备与页面的关联关系 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function bindPage(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/device/bindpage?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询设备与页面的关联关系 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function queryPage(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/relation/search?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 以设备为维度的数据统计接口 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function totalDevice(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/statistics/device?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 批量查询设备统计数据接口 + * @param integer $date 指定查询日期时间戳，单位为秒 + * @param integer $page_index 指定查询的结果页序号；返回结果按摇周边人数降序排序，每50条记录为一页 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function totalDeviceList($date, $page_index = 1) + { + $url = "https://api.weixin.qq.com/shakearound/statistics/devicelist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['date' => $date, 'page_index' => $page_index]); + } + + /** + * 以页面为维度的数据统计接口 + * @param integer $page_id 指定页面的设备ID + * @param integer $begin_date 起始日期时间戳，最长时间跨度为30天，单位为秒 + * @param integer $end_date 结束日期时间戳，最长时间跨度为30天，单位为秒 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function totalPage($page_id, $begin_date, $end_date) + { + $url = "https://api.weixin.qq.com/shakearound/statistics/page?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['page_id' => $page_id, 'begin_date' => $begin_date, 'end_date' => $end_date]); + } + + /** + * 编辑分组信息 + * @param integer $group_id 分组唯一标识，全局唯一 + * @param string $group_name 分组名称，不超过100汉字或200个英文字母 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function updateGroup($group_id, $group_name) + { + $url = "https://api.weixin.qq.com/shakearound/device/group/update?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['group_id' => $group_id, 'group_name' => $group_name]); + } + + /** + * 删除分组 + * @param integer $group_id 分组唯一标识，全局唯一 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deleteGroup($group_id) + { + $url = "https://api.weixin.qq.com/shakearound/device/group/delete?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['group_id' => $group_id]); + } + + /** + * 查询分组列表 + * @param integer $begin 分组列表的起始索引值 + * @param integer $count 待查询的分组数量，不能超过1000个 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getGroupList($begin = 0, $count = 10) + { + $url = "https://api.weixin.qq.com/shakearound/device/group/getlist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['begin' => $begin, 'count' => $count]); + } + + + /** + * 查询分组详情 + * @param integer $group_id 分组唯一标识，全局唯一 + * @param integer $begin 分组里设备的起始索引值 + * @param integer $count 待查询的分组里设备的数量，不能超过1000个 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getGroupDetail($group_id, $begin = 0, $count = 100) + { + $url = "https://api.weixin.qq.com/shakearound/device/group/getdetail?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['group_id' => $group_id, 'begin' => $begin, 'count' => $count]); + } + + /** + * 添加设备到分组 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addDeviceGroup(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/device/group/adddevice?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 从分组中移除设备 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deleteDeviceGroup(array $data) + { + $url = "https://api.weixin.qq.com/shakearound/device/group/deletedevice?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Tags.php b/WeChat/WeChat/Tags.php new file mode 100644 index 0000000..0301798 --- /dev/null +++ b/WeChat/WeChat/Tags.php @@ -0,0 +1,109 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 创建粉丝标签 + * @param string $name + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function createTags($name) + { + $url = "https://api.weixin.qq.com/cgi-bin/tags/create?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['tag' => ['name' => $name]]); + } + + /** + * 删除粉丝标签 + * @param int $tagId + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function deleteTags($tagId) + { + $url = 'https://api.weixin.qq.com/cgi-bin/tags/delete?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['tag' => ['id' => $tagId]]); + } + + /** + * 批量为用户打标签 + * @param array $openids + * @param integer $tagId + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function batchTagging(array $openids, $tagId) + { + $url = 'https://api.weixin.qq.com/cgi-bin/tags/members/batchtagging?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid_list' => $openids, $tagId]); + } + + /** + * 批量为用户取消标签 + * @param array $openids + * @param integer $tagId + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function batchUntagging(array $openids, $tagId) + { + $url = 'https://api.weixin.qq.com/cgi-bin/tags/members/batchuntagging?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid_list' => $openids, $tagId]); + } + + /** + * 获取用户身上的标签列表 + * @param string $openid + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getUserTagId($openid) + { + $url = 'https://api.weixin.qq.com/cgi-bin/tags/getidlist?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid' => $openid]); + } +} \ No newline at end of file diff --git a/WeChat/WeChat/Template.php b/WeChat/WeChat/Template.php new file mode 100644 index 0000000..7b2ba2a --- /dev/null +++ b/WeChat/WeChat/Template.php @@ -0,0 +1,110 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['industry_id1' => $industry_id1, 'industry_id2' => $industry_id2]); + } + + /** + * 获取设置的行业信息 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getIndustry() + { + $url = "https://api.weixin.qq.com/cgi-bin/template/get_industry?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 获得模板ID + * @param string $tpl_id 板库中模板的编号，有“TM**”和“OPENTMTM**”等形式 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addTemplate($tpl_id) + { + $url = "https://api.weixin.qq.com/cgi-bin/template/api_add_template?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['template_id_short' => $tpl_id]); + } + + /** + * 获取模板列表 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getAllPrivateTemplate() + { + $url = "https://api.weixin.qq.com/cgi-bin/template/get_all_private_template?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 获得模板ID + * @param string $tpl_id 公众帐号下模板消息ID + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function delPrivateTemplate($tpl_id) + { + $url = "https://api.weixin.qq.com/cgi-bin/template/del_private_template?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['template_id' => $tpl_id]); + } + + /** + * 发送模板消息 + * @param array $data + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function send(array $data) + { + $url = "https://api.weixin.qq.com/cgi-bin/template/del_private_template?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + +} \ No newline at end of file diff --git a/WeChat/WeChat/User.php b/WeChat/WeChat/User.php new file mode 100644 index 0000000..6e89494 --- /dev/null +++ b/WeChat/WeChat/User.php @@ -0,0 +1,132 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid' => $openid, 'remark' => $remark]); + } + + /** + * 获取用户基本信息（包括UnionID机制） + * @param string $openid + * @param string $lang + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getUserInfo($openid, $lang = 'zh_CN') + { + $url = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=ACCESS_TOKEN&openid={$openid}&lang=zh_CN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 批量获取用户基本信息 + * @param array $openids + * @param string $lang + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getBatchUserInfo(array $openids, $lang = 'zh_CN') + { + $url = 'https://api.weixin.qq.com/cgi-bin/user/info/batchget?access_token=ACCESS_TOKEN'; + $data = ['user_list' => []]; + foreach ($openids as $openid) { + $data['user_list'][] = ['openid' => $openid, 'lang' => $lang]; + } + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 获取用户列表 + * @param string $next_openid + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getUserList($next_openid = '') + { + $url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN&next_openid={$next_openid}"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpGetForJson($url); + } + + /** + * 获取公众号的黑名单列表 + * @param string $begin_openid + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getBlackList($begin_openid = '') + { + $url = "https://api.weixin.qq.com/cgi-bin/tags/members/getblacklist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['begin_openid' => $begin_openid]); + } + + /** + * 批量拉黑用户 + * @param array $openids + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function batchBlackList(array $openids) + { + $url = "https://api.weixin.qq.com/cgi-bin/tags/members/batchblacklist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid_list' => $openids]); + } + + /** + * 批量取消拉黑用户 + * @param array $openids + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function batchUnblackList(array $openids) + { + $url = "https://api.weixin.qq.com/cgi-bin/tags/members/batchunblacklist?access_token=ACCESS_TOKEN"; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['openid_list' => $openids]); + } + +} \ No newline at end of file diff --git a/WeChat/WeChat/Wifi.php b/WeChat/WeChat/Wifi.php new file mode 100644 index 0000000..0b29b81 --- /dev/null +++ b/WeChat/WeChat/Wifi.php @@ -0,0 +1,285 @@ +registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['pageindex' => $pageindex, 'pagesize' => $pagesize]); + } + + /** + * 查询门店Wi-Fi信息 + * @param integer $shop_id 门店ID + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getShopWifi($shop_id) + { + $url = 'https://api.weixin.qq.com/bizwifi/shop/list?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id]); + } + + /** + * 修改门店网络信息 + * @param integer $shop_id 门店ID + * @param string $old_ssid 旧的无线网络设备的ssid + * @param string $ssid 新的无线网络设备的ssid + * @param string $password 无线网络设备的密码(可选) + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function upShopWifi($shop_id, $old_ssid, $ssid, $password = null) + { + $data = ['shop_id' => $shop_id, 'old_ssid' => $old_ssid, 'ssid' => $ssid]; + is_null($password) || $data['password'] = $password; + $url = 'https://api.weixin.qq.com/bizwifi/shop/update?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 清空门店网络及设备 + * @param integer $shop_id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function clearShopWifi($shop_id) + { + $url = 'https://api.weixin.qq.com/bizwifi/shop/clean?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id]); + } + + /** + * 添加密码型设备 + * @param integer $shop_id 门店ID + * @param string $ssid 无线网络设备的ssid + * @param null|string $password 无线网络设备的密码 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addShopWifi($shop_id, $ssid, $password = null) + { + $data = ['shop_id' => $shop_id, 'ssid' => $ssid, 'password' => $password]; + $url = 'https://api.weixin.qq.com/bizwifi/device/add?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 添加portal型设备 + * @param integer $shop_id 门店ID + * @param string $ssid 无线网络设备的ssid + * @param bool $reset 重置secretkey，false-不重置，true-重置，默认为false + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function addShopPortal($shop_id, $ssid, $reset = false) + { + $data = ['shop_id' => $shop_id, 'ssid' => $ssid, 'reset' => $reset]; + $url = 'https://api.weixin.qq.com/bizwifi/apportal/register?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询设备 + * @param null|integer $shop_id 根据门店id查询 + * @param null|integer $pageindex 分页下标，默认从1开始 + * @param null|integer $pagesize 每页的个数，默认10个，最大20个 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function queryShopWifi($shop_id = null, $pageindex = null, $pagesize = null) + { + $data = []; + is_null($pagesize) || $data['pagesize'] = $pagesize; + is_null($pageindex) || $data['pageindex'] = $pageindex; + is_null($shop_id) || $data['shop_id'] = $shop_id; + $url = 'https://api.weixin.qq.com/bizwifi/device/list?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 删除设备 + * @param string $bssid 需要删除的无线网络设备无线mac地址，格式冒号分隔，字符长度17个，并且字母小写，例如：00:1f:7a:ad:5c:a8 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function delShopWifi($bssid) + { + $url = 'https://api.weixin.qq.com/bizwifi/device/delete?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['bssid' => $bssid]); + } + + /** + * 获取物料二维码 + * @param integer $shop_id 门店ID + * @param string $ssid 已添加到门店下的无线网络名称 + * @param integer $img_id 物料样式编号：0-纯二维码，可用于自由设计宣传材料；1-二维码物料，155mm×215mm(宽×高)，可直接张贴 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getQrc($shop_id, $ssid, $img_id = 1) + { + $url = 'https://api.weixin.qq.com/bizwifi/qrcode/get?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id, 'ssid' => $ssid, 'img_id' => $img_id]); + } + + /** + * 设置商家主页 + * @param integer $shop_id 门店ID + * @param integer $template_id 模板ID，0-默认模板，1-自定义url + * @param null|string $url 自定义链接，当template_id为1时必填 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setHomePage($shop_id, $template_id, $url = null) + { + $data = ['shop_id' => $shop_id, 'template_id' => $template_id]; + is_null($url) && $data['struct'] = ['url' => $url]; + $url = 'https://api.weixin.qq.com/bizwifi/homepage/set?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询商家主页 + * @param integer $shop_id 查询的门店id + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getHomePage($shop_id) + { + $url = 'https://api.weixin.qq.com/bizwifi/homepage/get?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id]); + } + + /** + * 设置微信首页欢迎语 + * @param integer $shop_id 门店ID + * @param integer $bar_type 微信首页欢迎语的文本内容：0--欢迎光临+公众号名称；1--欢迎光临+门店名称；2--已连接+公众号名称+WiFi；3--已连接+门店名称+Wi-Fi。 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setBar($shop_id, $bar_type = 1) + { + $url = 'https://api.weixin.qq.com/bizwifi/bar/set?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id, 'bar_type' => $bar_type]); + } + + /** + * 设置连网完成页 + * @param integer $shop_id 门店ID + * @param string $finishpage_url 连网完成页URL + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setFinishPage($shop_id, $finishpage_url) + { + $url = 'https://api.weixin.qq.com/bizwifi/finishpage/set?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id, 'finishpage_url' => $finishpage_url]); + } + + /** + * Wi-Fi 数据统计 + * @param string $begin_date 起始日期时间，格式yyyy-mm-dd，最长时间跨度为30天 + * @param string $end_date 结束日期时间戳，格式yyyy-mm-dd，最长时间跨度为30天 + * @param integer $shop_id 按门店ID搜索，-1为总统计 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function staticList($begin_date, $end_date, $shop_id = -1) + { + $url = 'https://api.weixin.qq.com/bizwifi/statistics/list?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id, 'begin_date' => $begin_date, 'end_date' => $end_date]); + } + + /** + * 设置门店卡券投放信息 + * @param integer $shop_id 门店ID，可设置为0，表示所有门店 + * @param integer $card_id 卡券ID + * @param string $card_describe 卡券描述，不能超过18个字符 + * @param string $start_time 卡券投放开始时间（单位是秒） + * @param string $end_time 卡券投放结束时间（单位是秒） 注：不能超过卡券的有效期时间 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function setCouponput($shop_id, $card_id, $card_describe, $start_time, $end_time) + { + $data = ['shop_id' => $shop_id, 'card_id' => $card_id, 'card_describe' => $card_describe, 'start_time' => $start_time, 'end_time' => $end_time]; + $url = 'https://api.weixin.qq.com/bizwifi/couponput/set?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, $data); + } + + /** + * 查询门店卡券投放信息 + * @param integer $shop_id 门店ID，可设置为0，表示所有门店 + * @return array + * @throws Exceptions\InvalidResponseException + * @throws Exceptions\LocalCacheException + */ + public function getCouponput($shop_id) + { + $url = 'https://api.weixin.qq.com/bizwifi/couponput/get?access_token=ACCESS_TOKEN'; + $this->registerApi($url, __FUNCTION__, func_get_args()); + return $this->httpPostForJson($url, ['shop_id' => $shop_id]); + } + +} \ No newline at end of file