mirror of
https://gitee.com/zoujingli/WeChatDeveloper.git
synced 2025-04-05 09:52:47 +08:00
[提交]上传微信开发工具包
This commit is contained in:
Anyon
commit
4ae6a5d9ec
628
Wechat/Card.php
Normal file
628
Wechat/Card.php
Normal file
@ -0,0 +1,628 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 卡券管理
|
||||
* Class Card
|
||||
* @package Wechat
|
||||
*/
|
||||
class Card extends Wechat
|
||||
{
|
||||
/**
|
||||
* 创建卡券
|
||||
* @param array $data
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function create(array $data)
|
||||
{
|
||||
$url = "https://api.weixin.qq.com/card/create?access_token=ACCESS_TOKEN";
|
||||
$this->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);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取JSAPI_TICKET接口
|
||||
* @param string $type TICKET类型(wx_card|jsapi)
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function getTicket($type = 'jsapi')
|
||||
{
|
||||
$url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type={$type}";
|
||||
$this->registerApi($url, __FUNCTION__, func_get_args());
|
||||
return $this->httpGetForJson($url);
|
||||
}
|
||||
|
||||
}
|
||||
110
Wechat/Contracts/Config.php
Normal file
110
Wechat/Contracts/Config.php
Normal file
@ -0,0 +1,110 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Contracts;
|
||||
|
||||
use ArrayAccess;
|
||||
|
||||
/**
|
||||
* Class Config
|
||||
* @package Wechat
|
||||
*/
|
||||
class Config implements ArrayAccess
|
||||
{
|
||||
|
||||
/**
|
||||
* 当前配置值
|
||||
* @var array
|
||||
*/
|
||||
private $config = [];
|
||||
|
||||
/**
|
||||
* Config constructor.
|
||||
* @param array $options
|
||||
*/
|
||||
public function __construct(array $options)
|
||||
{
|
||||
$this->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 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;
|
||||
}
|
||||
}
|
||||
194
Wechat/Contracts/Error.php
Normal file
194
Wechat/Contracts/Error.php
Normal file
@ -0,0 +1,194 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Contracts;
|
||||
|
||||
/**
|
||||
* 错误消息处理
|
||||
* Class Error
|
||||
* @package Wechat\Contracts
|
||||
*/
|
||||
class Error
|
||||
{
|
||||
/**
|
||||
* 接口代码错误
|
||||
* @var array
|
||||
*/
|
||||
static $message = [
|
||||
-1 => '系统繁忙，此时请开发者稍候再试',
|
||||
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;
|
||||
}
|
||||
|
||||
}
|
||||
317
Wechat/Contracts/Request.php
Normal file
317
Wechat/Contracts/Request.php
Normal file
@ -0,0 +1,317 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Contracts;
|
||||
|
||||
use Wechat\Exceptions\InvalidArgumentException;
|
||||
use Wechat\Exceptions\InvalidResponseException;
|
||||
use Wechat\Exceptions\LocalCacheException;
|
||||
|
||||
/**
|
||||
* 网络请求支持
|
||||
* Class Request
|
||||
* @package Wechat
|
||||
*/
|
||||
class Request
|
||||
{
|
||||
/**
|
||||
* 缓存路径
|
||||
* @var null
|
||||
*/
|
||||
public static $cache_path = null;
|
||||
|
||||
/**
|
||||
* 根据文件后缀获取文件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 = '', $postname = '')
|
||||
{
|
||||
$basename = $postname ?: basename($filename);
|
||||
$basemine = $mimetype ?: self::getExtMine(pathinfo($filename, 4));
|
||||
if (function_exists('curl_file_create')) {
|
||||
return curl_file_create($filename, $basemine, $basename);
|
||||
}
|
||||
return "@{$filename};filename={$basename};type={$basemine}";
|
||||
}
|
||||
|
||||
/**
|
||||
* 以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 toXml($data)
|
||||
{
|
||||
return "<xml>" . self::_data_to_xml($data) . "</xml>";
|
||||
}
|
||||
|
||||
/**
|
||||
* XML内容生成
|
||||
* @param array $data 数据
|
||||
* @param string $content
|
||||
* @return string
|
||||
*/
|
||||
private static function _data_to_xml($data, $content = '')
|
||||
{
|
||||
foreach ($data as $key => $val) {
|
||||
$content .= "<{$key}>";
|
||||
if (is_array($val) || is_object($val)) {
|
||||
$content .= self::_data_to_xml($val);
|
||||
} elseif (is_string($val)) {
|
||||
$content .= '<![CDATA[' . preg_replace("/[\\x00-\\x08\\x0b-\\x0c\\x0e-\\x1f]/", '', $val) . ']]>';
|
||||
} else {
|
||||
$content .= $val;
|
||||
}
|
||||
$content .= "</{$key}>";
|
||||
}
|
||||
return $content;
|
||||
}
|
||||
|
||||
/**
|
||||
* 解析XML内容到数组
|
||||
* @param string $xml
|
||||
* @return array
|
||||
*/
|
||||
public static function fromXml($xml)
|
||||
{
|
||||
return json_decode(self::toJson(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
|
||||
}
|
||||
|
||||
/**
|
||||
* 数组转xml内容
|
||||
* @param array $data
|
||||
* @return null|string|string
|
||||
*/
|
||||
public static function toJson($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 fromJson($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']);
|
||||
}
|
||||
// POST数据设置
|
||||
if (strtolower($method) === 'post') {
|
||||
curl_setopt($curl, CURLOPT_POST, true);
|
||||
curl_setopt($curl, CURLOPT_POSTFIELDS, self::build($options['data']));
|
||||
}
|
||||
// CURL头信息设置
|
||||
if (!empty($options['headers'])) {
|
||||
curl_setopt($curl, CURLOPT_HTTPHEADER, $options['headers']);
|
||||
}
|
||||
// 证书文件设置
|
||||
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_SSL_VERIFYPEER, false);
|
||||
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
|
||||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
|
||||
list($content, $status) = [curl_exec($curl), curl_getinfo($curl), curl_close($curl)];
|
||||
return (intval($status["http_code"]) === 200) ? $content : false;
|
||||
}
|
||||
|
||||
/**
|
||||
* POST数据过滤处理
|
||||
* @param array $data
|
||||
* @return array
|
||||
*/
|
||||
private static function build($data)
|
||||
{
|
||||
if (is_array($data)) {
|
||||
foreach ($data as $key => $value) {
|
||||
if (is_string($value) && class_exists('CURLFile', false) && stripos($value, '@') === 0) {
|
||||
$filename = realpath(trim($value, '@'));
|
||||
if ($filename && file_exists($filename)) {
|
||||
$data[$key] = new \CURLFile($filename);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return $data;
|
||||
}
|
||||
|
||||
/**
|
||||
* 缓存配置与存储
|
||||
* @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);
|
||||
}
|
||||
}
|
||||
158
Wechat/Contracts/Wechat.php
Normal file
158
Wechat/Contracts/Wechat.php
Normal file
@ -0,0 +1,158 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Contracts;
|
||||
|
||||
use Wechat\Exceptions\InvalidArgumentException;
|
||||
use Wechat\Exceptions\InvalidResponseException;
|
||||
|
||||
/**
|
||||
* Class Wechat
|
||||
* @package Wechat\Contracts
|
||||
*/
|
||||
class Wechat
|
||||
{
|
||||
|
||||
/**
|
||||
* 当前微信配置
|
||||
* @var Config
|
||||
*/
|
||||
public $config;
|
||||
|
||||
/**
|
||||
* 访问AccessToken
|
||||
* @var string
|
||||
*/
|
||||
public $access_token = '';
|
||||
|
||||
/**
|
||||
* 当前请求方法参数
|
||||
* @var array
|
||||
*/
|
||||
private $currentMethod = [];
|
||||
|
||||
/**
|
||||
* 当前模式
|
||||
* @var bool
|
||||
*/
|
||||
private $isTry = false;
|
||||
|
||||
/**
|
||||
* Wechat constructor.
|
||||
* @param array $options
|
||||
*/
|
||||
public function __construct(array $options)
|
||||
{
|
||||
if (empty($options['appid'])) {
|
||||
throw new InvalidArgumentException("Missing Config -- [appid]");
|
||||
}
|
||||
if (empty($options['secret'])) {
|
||||
throw new InvalidArgumentException("Missing Config -- [secret]");
|
||||
}
|
||||
$this->config = new Config($options);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取访问accessToken
|
||||
* @return string
|
||||
* @throws \Wechat\Exceptions\InvalidResponseException
|
||||
* @throws \Wechat\Exceptions\LocalCacheException
|
||||
*/
|
||||
public function getAccesstoken()
|
||||
{
|
||||
if (!empty($this->access_token)) {
|
||||
return $this->access_token;
|
||||
}
|
||||
$cacheKey = $this->config->get('appid') . '_accesstoken';
|
||||
$this->access_token = Request::getCache($cacheKey);
|
||||
if (!empty($this->access_token)) {
|
||||
return $this->access_token;
|
||||
}
|
||||
list($appid, $secret) = [$this->config->get('appid'), $this->config->get('secret')];
|
||||
$url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appid}&secret={$secret}";
|
||||
$result = Request::fromJson(Request::get($url));
|
||||
if (!empty($result['access_token'])) {
|
||||
Request::setCache($cacheKey, $result['access_token'], 6000);
|
||||
}
|
||||
return $result['access_token'];
|
||||
}
|
||||
|
||||
/**
|
||||
* 清理删除accessToken
|
||||
* @return bool
|
||||
*/
|
||||
public function delAccessToken()
|
||||
{
|
||||
$this->access_token = '';
|
||||
return Request::delCache($this->config->get('appid') . '_accesstoken');
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 以GET获取接口数据并转为数组
|
||||
* @param string $url 接口地址
|
||||
* @return array
|
||||
*/
|
||||
protected function httpGetForJson($url)
|
||||
{
|
||||
try {
|
||||
return Request::fromJson(Request::get($url));
|
||||
} catch (InvalidResponseException $e) {
|
||||
if (!$this->isTry && in_array($e->getCode(), ['40014', '40001', '41001', '42001'])) {
|
||||
$this->delAccessToken();
|
||||
$this->isTry = true;
|
||||
return call_user_func_array([$this, $this->currentMethod['method']], $this->currentMethod['arguments']);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 以POST获取接口数据并转为数组
|
||||
* @param string $url 接口地址
|
||||
* @param array $data 请求数据
|
||||
* @param bool $buildToJson
|
||||
* @return array
|
||||
*/
|
||||
protected function httpPostForJson($url, array $data, $buildToJson = true)
|
||||
{
|
||||
try {
|
||||
return Request::fromJson(Request::post($url, $buildToJson ? Request::toJson($data) : $data));
|
||||
} catch (InvalidResponseException $e) {
|
||||
if (!$this->isTry && in_array($e->getCode(), ['40014', '40001', '41001', '42001'])) {
|
||||
$this->delAccessToken();
|
||||
$this->isTry = true;
|
||||
return call_user_func_array([$this, $this->currentMethod['method']], $this->currentMethod['arguments']);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 注册当前请求接口
|
||||
* @param string $url 接口地址
|
||||
* @param string $method 当前接口方法
|
||||
* @param array $arguments 请求参数
|
||||
* @return mixed
|
||||
* @throws \Wechat\Exceptions\InvalidResponseException
|
||||
* @throws \Wechat\Exceptions\LocalCacheException
|
||||
*/
|
||||
protected function registerApi(&$url, $method, $arguments = [])
|
||||
{
|
||||
$this->currentMethod = ['method' => $method, 'arguments' => $arguments];
|
||||
if (empty($this->access_token)) {
|
||||
$this->access_token = $this->getAccesstoken();
|
||||
}
|
||||
return $url = str_replace('ACCESS_TOKEN', $this->access_token, $url);
|
||||
}
|
||||
|
||||
}
|
||||
220
Wechat/Custom.php
Normal file
220
Wechat/Custom.php
Normal file
@ -0,0 +1,220 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 客服消息处理
|
||||
* Class Custom
|
||||
* @package Wechat
|
||||
*/
|
||||
class Custom extends Wechat
|
||||
{
|
||||
/**
|
||||
* 添加客服帐号
|
||||
* @param string $kf_account 客服账号
|
||||
* @param string $nickname 客服昵称
|
||||
* @param string $password 账号密码
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function addAccount($kf_account, $nickname, $password)
|
||||
{
|
||||
$data = ['kf_account' => $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) ?: $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/preview?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, []);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
25
Wechat/Exceptions/InvalidArgumentException.php
Normal file
25
Wechat/Exceptions/InvalidArgumentException.php
Normal file
@ -0,0 +1,25 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Exceptions;
|
||||
|
||||
/**
|
||||
* 参数异常
|
||||
* Class InvalidArgumentException
|
||||
* @package Wechat
|
||||
*/
|
||||
class InvalidArgumentException extends \InvalidArgumentException
|
||||
{
|
||||
|
||||
}
|
||||
41
Wechat/Exceptions/InvalidResponseException.php
Normal file
41
Wechat/Exceptions/InvalidResponseException.php
Normal file
@ -0,0 +1,41 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Exceptions;
|
||||
|
||||
/**
|
||||
* 返回异常
|
||||
* Class InvalidResponseException
|
||||
* @package Wechat
|
||||
*/
|
||||
class InvalidResponseException extends \Exception
|
||||
{
|
||||
/**
|
||||
* @var array
|
||||
*/
|
||||
public $raw = [];
|
||||
|
||||
/**
|
||||
* InvalidResponseException constructor.
|
||||
* @param $message
|
||||
* @param $code
|
||||
* @param array $raw
|
||||
*/
|
||||
public function __construct($message, $code, $raw = [])
|
||||
{
|
||||
parent::__construct($message, intval($code));
|
||||
$this->raw = $raw;
|
||||
}
|
||||
|
||||
}
|
||||
42
Wechat/Exceptions/LocalCacheException.php
Normal file
42
Wechat/Exceptions/LocalCacheException.php
Normal file
@ -0,0 +1,42 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat\Exceptions;
|
||||
|
||||
/***
|
||||
* 本地缓存异常
|
||||
* Class LocalCacheException
|
||||
* @package Wechat
|
||||
*/
|
||||
class LocalCacheException extends \Exception
|
||||
{
|
||||
|
||||
/**
|
||||
* @var array
|
||||
*/
|
||||
public $raw = [];
|
||||
|
||||
/**
|
||||
* InvalidResponseException constructor.
|
||||
* @param $message
|
||||
* @param $code
|
||||
* @param array $raw
|
||||
*/
|
||||
public function __construct($message, $code, $raw = [])
|
||||
{
|
||||
parent::__construct($message, intval($code));
|
||||
$this->raw = $raw;
|
||||
}
|
||||
|
||||
}
|
||||
183
Wechat/Media.php
Normal file
183
Wechat/Media.php
Normal file
@ -0,0 +1,183 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Request;
|
||||
use Wechat\Contracts\Wechat;
|
||||
use Wechat\Exceptions\InvalidResponseException;
|
||||
|
||||
/**
|
||||
* 微信素材管理
|
||||
* Class Media
|
||||
* @package Wechat
|
||||
*/
|
||||
class Media extends Wechat
|
||||
{
|
||||
/**
|
||||
* 新增临时素材
|
||||
* @param string $filename 文件名称
|
||||
* @param string $type 媒体文件类型(image|voice|video|thumb)
|
||||
* @return array
|
||||
* @throws Exceptions\LocalCacheException
|
||||
* @throws InvalidResponseException
|
||||
*/
|
||||
public function upload($filename, $type = 'image')
|
||||
{
|
||||
if (!in_array($type, ['image', 'voice', 'video', 'thumb'])) {
|
||||
throw new InvalidResponseException('Invalid Media Type.', '0');
|
||||
}
|
||||
$url = "https://api.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type={$type}";
|
||||
$this->registerApi($url, __FUNCTION__, func_get_args());
|
||||
return $this->httpPostForJson($url, ['media' => Request::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 Request::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' => Request::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' => Request::createCurlFile($filename), 'description' => Request::toJson($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, $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]);
|
||||
}
|
||||
}
|
||||
109
Wechat/Menu.php
Normal file
109
Wechat/Menu.php
Normal file
@ -0,0 +1,109 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 微信菜单管理
|
||||
* Class Menu
|
||||
* @package Wechat
|
||||
*/
|
||||
class Menu extends Wechat
|
||||
{
|
||||
|
||||
/**
|
||||
* 自定义菜单查询接口
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function get()
|
||||
{
|
||||
$url = "https://api.weixin.qq.com/cgi-bin/menu/get?access_token=ACCESS_TOKEN";
|
||||
$this->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]);
|
||||
}
|
||||
|
||||
}
|
||||
178
Wechat/Product.php
Normal file
178
Wechat/Product.php
Normal file
@ -0,0 +1,178 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 商店管理
|
||||
* Class Product
|
||||
* @package Wechat
|
||||
*/
|
||||
class Product extends Wechat
|
||||
{
|
||||
/**
|
||||
* 提交审核/取消发布商品
|
||||
* @param string $keystandard 商品编码标准
|
||||
* @param string $keystr 商品编码内容
|
||||
* @param string $status 设置发布状态。on为提交审核，off为取消发布
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function modStatus($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(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);
|
||||
}
|
||||
|
||||
}
|
||||
72
Wechat/Qrcode.php
Normal file
72
Wechat/Qrcode.php
Normal file
@ -0,0 +1,72 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 二维码管理
|
||||
* Class Qrcode
|
||||
* @package Wechat
|
||||
*/
|
||||
class Qrcode extends Wechat
|
||||
{
|
||||
|
||||
/**
|
||||
* 创建二维码ticket
|
||||
* @param string|integer $scene 场景
|
||||
* @param int $expire_seconds 有效时间
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function create($scene, $expire_seconds = 0)
|
||||
{
|
||||
if (is_numeric($scene)) {
|
||||
$data = ['action_name' => '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]);
|
||||
}
|
||||
|
||||
}
|
||||
109
Wechat/Tags.php
Normal file
109
Wechat/Tags.php
Normal file
@ -0,0 +1,109 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 用户标签管理
|
||||
* Class Tags
|
||||
* @package Wechat
|
||||
*/
|
||||
class Tags extends Wechat
|
||||
{
|
||||
/**
|
||||
* 获取粉丝标签列表
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function getTags()
|
||||
{
|
||||
$url = "https://api.weixin.qq.com/cgi-bin/tags/get?access_token=ACCESS_TOKEN";
|
||||
$this->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]);
|
||||
}
|
||||
}
|
||||
110
Wechat/Template.php
Normal file
110
Wechat/Template.php
Normal file
@ -0,0 +1,110 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 模板消息
|
||||
* Class Template
|
||||
* @package Wechat
|
||||
*/
|
||||
class Template extends Wechat
|
||||
{
|
||||
/**
|
||||
* 设置所属行业
|
||||
* @param string $industry_id1 公众号模板消息所属行业编号
|
||||
* @param string $industry_id2 公众号模板消息所属行业编号
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function setIndustry($industry_id1, $industry_id2)
|
||||
{
|
||||
$url = "https://api.weixin.qq.com/cgi-bin/template/api_set_industry?access_token=ACCESS_TOKEN";
|
||||
$this->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);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
131
Wechat/User.php
Normal file
131
Wechat/User.php
Normal file
@ -0,0 +1,131 @@
|
||||
<?php
|
||||
|
||||
// +----------------------------------------------------------------------
|
||||
// | WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
// | 版权所有 2014~2018 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||||
// +----------------------------------------------------------------------
|
||||
// | 官方网站: http://think.ctolog.com
|
||||
// +----------------------------------------------------------------------
|
||||
// | 开源协议 ( https://mit-license.org )
|
||||
// +----------------------------------------------------------------------
|
||||
// | github开源项目：https://github.com/zoujingli/WeChatDeveloper
|
||||
// +----------------------------------------------------------------------
|
||||
|
||||
namespace Wechat;
|
||||
|
||||
use Wechat\Contracts\Wechat;
|
||||
|
||||
/**
|
||||
* 微信粉丝管理
|
||||
* Class User
|
||||
* @package Wechat
|
||||
*/
|
||||
class User extends Wechat
|
||||
{
|
||||
|
||||
/**
|
||||
* 设置用户备注名
|
||||
* @param string $openid
|
||||
* @param string $remark
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function updatereMark($openid, $remark)
|
||||
{
|
||||
$url = 'https://api.weixin.qq.com/cgi-bin/user/info/updateremark?access_token=ACCESS_TOKEN';
|
||||
$this->registerApi($url, __FUNCTION__, func_get_args());
|
||||
return $this->httpPostForJson($url, ['openid' => $openid, 'remark' => $remark]);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取用户基本信息（包括UnionID机制）
|
||||
* @param string $openid
|
||||
* @return array
|
||||
* @throws Exceptions\InvalidResponseException
|
||||
* @throws Exceptions\LocalCacheException
|
||||
*/
|
||||
public function getUserInfo($openid)
|
||||
{
|
||||
$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]);
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
x
Reference in New Issue
Block a user