processor.php
1.47 KB
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
<?php
/**
* [WeEngine System] Copyright (c) 2014 WE7.CC
* WeEngine is NOT a free software, it under the license terms, visited http://www.we7.cc/ for more details.
*/
defined('IN_IA') or exit('Access Denied');
class PaycenterModuleProcessor extends WeModuleProcessor {
public function respond() {
global $_W;
$rid = $this->rule;
$sql = "SELECT * FROM " . tablename('wxcard_reply') . " WHERE rid = :rid ORDER BY RAND() LIMIT 1";
$reply = pdo_fetch($sql, array(':rid' => $rid));
if (empty($reply)) {
return false;
}
load()->classs('weixin.account');
load()->classs('coupon');
$coupon = new coupon($_W['acid']);
if(is_error($coupon)) {
$this->error($reply, $coupon['message']);
die;
}
$card = $coupon->BuildCardExt($reply['cid']);
if(is_error($card)) {
$this->error($reply, $card['message']);
die;
}
$data = array(
'touser' => $_W['openid'],
'msgtype' => 'wxcard',
'wxcard' => array(
'card_id' => $card['card_id'],
'card_ext' => $card['card_ext'],
)
);
$acc = WeAccount::create($_W['acid']);
$status = $acc->sendCustomNotice($data);
if(is_error($status)) {
$this->error($reply, $status['message']);
die;
}
if(!empty($reply['success'])) {
return $this->respText($reply['success']);
die;
}
return true;
}
public function error($reply, $msg) {
if(empty($reply['error'])) {
if(empty($msg)) {
return true;
}
return $this->respText($msg);
} else {
return $this->respText($reply['error']);
}
}
}