forked from wxpusher/wxpusher-sdk-php
-
Notifications
You must be signed in to change notification settings - Fork 0
/
wxpusher.class.php
295 lines (280 loc) · 10.1 KB
/
wxpusher.class.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
<?php
/**
* +----------------------------------------------------------------------
* | wxpusher-sdk-php
* +----------------------------------------------------------------------
* | Copyright (c) 2020 Meloncn All rights reserved.
* +----------------------------------------------------------------------
* | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
* +----------------------------------------------------------------------
* | Github： ( https://github.com/wxpusher/wxpusher-sdk-php )
* +----------------------------------------------------------------------
* | Version： v1.1
* +----------------------------------------------------------------------
* | LastUpdate： 2020-03-19
* +----------------------------------------------------------------------
*/
class Wxpusher
{
protected $appToken;
protected $appMsgCheckGate;
protected $appMsgGate;
protected $appUserFunGate;
protected $appQrCreatGate;
function __construct($Token = 0){
$this->appToken = $Token;
$this->appMsgGate = 'http://wxpusher.zjiecode.com/api/send/message';
$this->appMsgCheckGate = 'http://wxpusher.zjiecode.com/api/send/query';
$this->appUserFunGate = 'http://wxpusher.zjiecode.com/api/fun/wxuser';
$this->appQrCreatGate = 'http://wxpusher.zjiecode.com/api/fun/create/qrcode';
}
/**
* Post请求工具
* 用于向服务器快速发送json格式数据
*/
private function post_json($url, $jsonStr){
$ch = curl_init();
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonStr);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
'Content-Type: application/json; charset=utf-8',
'Content-Length: ' . strlen($jsonStr)
));
$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
return $response;
}
/**
* 快速发送文本信息
* 使用方法：
* $wx->quickSend('用户id','主题id','内容','http://domain',false);
* 成功返回 true
* 失败返回 服务器提示信息
*
* 用户ID与主题ID使用哪一个填写哪一个，不使用留空
*
* 最后一个参数debug （bool）
* true 失败返回服务器提示信息
* false 失败返回false
*/
public function quickSend($uid = null , $topicId = null , $content = 'Hello',$url = null,$debug = false){
$data = http_build_query(
array(
'appToken' => $this->appToken,
'content' => $content,
'uid' => $uid,
'topicId' => $topicId,
'url' => urlencode($url),
));
$result = json_decode(file_get_contents($this->appMsgGate.'/?'.$data),TRUE);
if ($result['data'][0]['code'] == 1000){
return true;
}else{
if ($debug){
return $result['data'][0]['status'];
}else{
return false;
}
}
}
/**
* @param null $content
* @param int $contentType
* @param int $summary
* @param bool $isUids
* @param array int $id
* @param string $url
* @return string
*
* 标准信息发送方式
* 需调用CURL
*
* $content: 您要发送的内容 \n换行
* $summary: 消息摘要 \n换行 可为空
* $contentType:
* |- 1表示文字
* |- 2表示html
* |- 3表示markdown
*
* $isUids:
* |- true 发送到用户
* |- false 发送到主题
*
* $url 需要添加协议头 http://或https://
*
* $array_id: 单条可使用int类型，多条使用数组方式
*
* 执行结果：
* 是否开启$getMessageId:
* |—true 执行完毕后返回messageId和错误信息 多维数组形式
* |—false 执行完毕后仅返回错误信息，若无错误返回TRUE
*
* 使用方法实例：
* $wx->send('内容','摘要','类型','是否为用户id',id或数组id,'需传送的url',是否返回messageID))
*/
public function send($content = null,$summary = null,$contentType = 1,$isUids = true,$array_id = [],$url = '',$getMessageId = false,$verifyPay = false)
{
{
$type = $isUids?'uids':'topicIds';
// 若 $array_id 直接输入int则此处进行转换
if (!is_array($array_id)){
$array_id = ["$array_id"];
}
$postdata = array(
'appToken' => $this->appToken,
'content' => $content,
'summary' => $summary,
$type => $array_id,
'url' => $url,
'verifyPay' => $verifyPay,
);
$jsonStr = json_encode($postdata);
$result_Original = json_decode($this->post_json($this->appMsgGate, $jsonStr),TRUE);//取出data内执行信息
if ($result_Original['success']){ //判断服务器是否回复成功识别指令
$result = $result_Original['data']; //获取执行结果
//记录错误信息
$error = [];
foreach ($result as $key => $k){
if ($k['code'] !== 1000){
$error[] = $k;
}
}
//记录发送成功MessageID
if ($getMessageId){
foreach ($result as $key => $k){
if ($k['code'] == 1000){
$messageId[] = $k['messageId'];
}
}
if (empty($messageId)){
$messageId = [];
}
}
if (empty($error)){ // 没有出现错误
if ($getMessageId){ //判断是否需要输出messageId
return $messageId; //输出messageID
}else{
return true; // 不需要输出MessageID直接True
}
}else{ //出错状态
if ($getMessageId){ //判断是否需要输出Id
return array('error' => $error,'messageId' => $messageId); //输出错误信息和ID
}else{
return $error; //仅输出错误
}
}
}else{
return $result_Original['msg']; //输出服务器指令识别失败状态
}
}
}
/**
* @param string $extra
* @param int $validTime
* @return mixed
*
* 创建自定义二维码
* $extra 自定义参数，为空则根据当前时间随机生成，最长不可超过64位
* $validTime 时间，单位秒。默认1800秒即30分钟
*
* 执行成功后返回多维数组
* |
* | -- 'expires' 过期时间
* | -- 'code'
* | -- 'shortUrl 生成二维码短连接
* | -- 'extra' 传递进的参数
* | -- 'url' 二维码长链接
*
* 执行失败返回错误原因 （string）
*/
public function Qrcreate($extra = '',$validTime = 1800){
if ($extra == ''){
$extra = md5(time().microtime().'wxpusher');
}
$postdata = array(
'appToken' => $this->appToken,
'extra' => $extra,
'validTime' => $validTime,
);
$jsonStr = json_encode($postdata);
$result = json_decode($this->post_json($this->appQrCreatGate, $jsonStr),TRUE);
if ($result['success']){
return $result['data'];
}else{
return $result['msg'];
}
}
/**
* @param $messageId
* @return bool
* 信息查询状态
* 信息发送成功返回 True
* 其余状态返回服务器提示信息(msg)
*/
public function checkStatus($messageId){
$result = json_decode(file_get_contents($this->appMsgCheckGate.'/'.$messageId));
if ($result->code == 1000){
return true;
}else{
return $result->msg;
}
}
/**
* @param int $page
* @param int $pageSize
* @param string $uid
* @return null|string
*
* 获取关注用户信息
* $uid 默认为空，返回所有关注用户数据 多维数组
* 输入uid，输出指定用户信息 多维数组
*
* 远程服务器执行返回success继续执行
* 否则返回远程服务器错误信息
*
* 查询数据
* 得到数据返回多维数组
* 空数据返回 NULL
*/
public function getFunInfo($page = 1,$pageSize = 100,$uid = ''){
$data = http_build_query(
array(
'appToken' => $this->appToken,
'page' => $page,
'pageSize' => $pageSize,
'uid' => $uid
));
$result = json_decode($result = file_get_contents($this->appUserFunGate.'/?'.$data),true);
if ($result['code'] == 1000){ //判断服务器是否执行成功
$data = $result['data']['records'];
if (empty($data)){
return null;
}else{
return $data;
}
}else{
return $result['msg']; //反馈服务器给出的错误信息
}
}
/**
* @return mixed
* 返回用户关注总数 int
*/
public function getFunTotal(){
$data = http_build_query(
array(
'appToken' => $this->appToken,
'page' => 1,
'pageSize' => 1,
));
$result = json_decode($result = file_get_contents($this->appUserFunGate.'/?'.$data),true);
if ($result['code'] == 1000){ //判断服务器是否执行成功
return $result['data']['total'];
}else{
return $result['msg']; //反馈服务器给出的错误信息
}
}
}