UsersController.php
7.0 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
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
<?php
/**
* Created by PhpStorm.
* User: ruidiudiu
* Date: 2018/11/23
* Time: 18:26
*/
namespace app\portal\controller;
use cmf\controller\HomeBaseController;
use EasyWeChat\Foundation\Application;
use think\Db;
use wxapp\pay\WeixinPay;
/**
* @title 用户相关接口
* @description 用户相关接口
* @group 用户相关接口
*/
class UsersController extends HomeBaseController{
protected $options;
function _initialize()
{
parent::_initialize();
$this->options = [
'app_id' => config('wechat_config.app_id'),
'secret' => config('wechat_config.secret'),
'payment' => config('wechat_config.payment'),
];
}
/**
* @title 状态验证
* @description 开锁前判断是否有未支付订单与是否提交押金
* @author 董瑞恩
* @url /portal/users/lock_check
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
* @return is_use:是否在使用设备
* @return is_deposit:是否交付押金
* @return is_order:是否有未支付订单
*/
public function lock_check(){
$users_id=$this->request->param('users_id');
//获取提交押金的状态
$users=Db::name('users')->where('id',$users_id)->find();
$data=[
'is_use'=>$users['is_use'],
'is_deposit' => $users['is_deposit']
];
$order=Db::name('order')->where(['users_id'=>$users_id,'state'=>2])->find();
if (empty($order)){
$data['is_order']=0;
}else{
$data['is_order']=1;
}
$this->apiResponse(200,'success',$data);
}
// /**
// * @title 用户使用状态验证
// * @description 判断用户当前是否在使用设备
// * @author 董瑞恩
// * @url /portal/users/isUse
// * @method GET
// *
// * @param name:users_id type:String require:1 default:无 other: desc:用户id
// *
// *
// */
public function isUse(){
$users_id=$this->request->param('users_id');
$users=Db::name('users')->where('id',$users_id)->find();
if ($users['is_use']==1){
$this->apiResponse(200,'用户正在使用设备');
}else{
$this->apiResponse(301,'用户尚未使用设备');
}
}
/**
* @title 用户查询订单
* @description 用户查询订单
* @author 董瑞恩
* @url /portal/users/getOrder
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
* @return data:下单返回值
*/
public function getOrder(){
$users_id=$this->request->param('users_id');
$order=Db::name('order')->where(['users_id'=>$users_id])->select();
$this->apiResponse(200,'success',$order);
}
/**
* @title 用户交纳押金
* @description 交纳押金
* @author 董瑞恩
* @url /portal/users/payDeposit
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
* @return data:下单返回值
*/
public function payDeposit(){
$users_id=$this->request->param('users_id');
$users=Db::name('users')->where('id',$users_id)->find();
$openId=$users['open_id'];
$order_no = cmf_get_order_sn();
$body="押金-支付";
$price=300*100;//数据库查询
$notify_url=url('users/notify','','',true);//回调地址
$wxPay=new WeixinPay($openId,$order_no,$body,$price,$notify_url);
$data=$wxPay->pay();
if (isset($data['package'])){
try{
Db::name('users')->where(['id'=>$users_id])->update(['deposit_order_no'=>$order_no]);
}catch (\Exception $exception){
}
$this->apiResponse(200,'下单成功',$data);//微信支付下单成功,返回调用支付的参数
}
}
//支付回调接口
public function notify(){
$param = $this->request->param();
if ($param == null) {
$param = file_get_contents("php://input");
if ($param == null) {
$param = $GLOBALS['HTTP_RAW_POST_DATA'];
}
}
$wxPay=new WeixinPay();
$data = $wxPay->xmlToArray($param);
$Sign = $data['sign'];
//支付成功回调后变更订单状态
$mySign = $wxPay->getSign($data);
$order_no = $data['out_trade_no'];
if ($Sign===$mySign && $data['return_code'] == 'SUCCESS') {
$data=[
'is_deposit' => 1,
'deposit' => $data['total_fee'],
];
try{
Db::name('order')->where(['order_no'=>$order_no])->update($data);
}catch (\Exception $exception){
$this->apiResponse(301,'error:'.$exception->getMessage());
}
return "<xml>
<return_code><![CDATA[SUCCESS]]></return_code>
<return_msg><![CDATA[OK]]></return_msg>
</xml>";
}
}
/**
* @title 用户退回押金
* @description 用户退回押金
* @author 董瑞恩
* @url /portal/users/refundDeposit
* @method GET
*
* @param name:users_id type:String require:1 default:无 other: desc:用户id
*
* @return result:退款接口返回值
*/
public function refundDeposit(){
$users_id=$this->request->param('users_id');
$users=Db::name('users')->where('id',$users_id)->find();
$orderNo=$users['deposit_order_no'];//需要退款的订单
$price=$users['deposit'];
Db::startTrans();
try{
Db::name('users')->where('id',$users_id)->update(['is_deposit'=>0,'deposit'=>null,'deposit_order_no'=>null]);
}catch (\Exception $exception){
$this->apiResponse(301,'数据库修改失败');
}
$app= new Application($this->options);
$payment = $app->payment;
//使用商户订单号退款 PS.其他形式参考文档
$refundNo =cmf_get_order_sn();//退款单号
$result = $payment->refund($orderNo, $refundNo, $price); // 总金额 100, 退款 80,refundFee可选(为空时全额退款)
if ($result['return_code']==='SUCCESS' && $result['result_code']==='SUCCESS'){
Db::commit();
}else{
Db::rollback();
}
return json_decode($result,true);
}
/**
* 退款结果回调
*/
public function refundNotify() {
$app = new Application($this->options);
$response = $app->payment->handleRefundNotify(function ($message, $reqInfo) {
cache('message',$message);
cache('reqInfo',$reqInfo);
// 其中 $message['req_info'] 获取到的是加密信息
// $reqInfo 为 message['req_info'] 解密后的信息
// 你的业务逻辑...
return true; // 返回 true 告诉微信“我已处理完成”
// 或返回错误原因 $fail('参数格式校验错误');
});
$response->send();
}
}