redis = new \Redis(); $this->redis->connect('127.0.0.1', 6379); } /** * @title 超时订单 * @url /task/Order/payTimeout * @method POST * @param string page 用户名/手机号 / 是 * @param string limit 密码 / 是 * @return string msg 返回信息 * @return int code 状态码 200:成功;>=400:失败 */ public function payTimeout(){ try { if($this->redis->get('payTimeout') > 0){ return ; } $this->redis->set('payTimeout', 1, 20); $orderService = new OrderService(); Db::startTrans(); $orderService->payTimeout(); Db::commit(); $this->redis->set('payTimeout', 0); return _success('成功'); }catch(\Exception $e){ Db::rollback(); $this->redis->set('payTimeout', 0); return _error($e->getMessage(), $e->getCode() ?: 400, $e); } } /** * @title 用户下载资源状态 * @url /task/Order/orderSourceDownload * @method POST * @return string msg 返回信息 * @return int code 状态码 200:成功;>=400:失败 */ public function orderSourceDownload(){ try { if($this->redis->get('orderSourceDownload') > 0){ return ; } $this->redis->set('orderSourceDownload', 1); $orderService = new OrderService(); Db::startTrans(); $orderService->orderSourceDownload(); Db::commit(); $this->redis->set('orderSourceDownload', 0); return _success('成功'); }catch(\Exception $e){ Db::rollback(); $this->redis->set('orderSourceDownload', 0); return _error($e->getMessage(), $e->getCode() ?: 400, $e); } } /** * @title 支付完成 * @url /task/Order/payComplete * @method POST * @return string msg 返回信息 * @return int code 状态码 200:成功;>=400:失败 */ public function payComplete(){ try { if($this->redis->get('payComplete') > 0){ return ; } $this->redis->set('payComplete', 1, 60); $payService = new PayService(); $result = $payService->payComplete(); $this->redis->set('payComplete', 0); return _success('成功', $result); }catch(\Exception $e){ $this->redis->set('payComplete', 0); return _error($e->getMessage(), $e->getCode() ?: 400, $e); } } /** * @title 订单结算 * @url /task/Order/orderClose * @method POST * @return string msg 返回信息 * @return int code 状态码 200:成功;>=400:失败 */ public function orderClose(){ try { if($this->redis->get('orderClose') > 0){ return ; } $this->redis->set('orderClose', 1); $orderService = new OrderService(); $orderService->orderClose(); $this->redis->set('orderClose', 0); return _success('成功'); }catch(\Exception $e){ $this->redis->set('orderClose', 0); return _error($e->getMessage(), $e->getCode() ?: 400, $e); } } /** * @title 订单生成发票 * @url /task/Order/orderCreateBill * @method POST * @return string msg 返回信息 * @return int code 状态码 200:成功;>=400:失败 */ public function orderCreateBill(){ try { if($this->redis->get('orderCreateBill') > 0){ return ; } $this->redis->set('orderCreateBill', 1, 30); $orderService = new OrderService(); $orderService->orderCreateBill(); $this->redis->set('orderCreateBill', 0); return _success('成功'); }catch(\Exception $e){ $this->redis->set('orderCreateBill', 0); return _error($e->getMessage(), $e->getCode() ?: 400, $e); } } /** * @title 支付完成 * @url /api/Pay/payComplete * @method POST * @return string msg 返回信息 * @return int code 状态码 200:成功;>=400:失败 */ public function test(){ try { $payService = new PayService(); $result = $payService->test(); return _success('成功', $result); }catch(\Exception $e){ return _error($e->getMessage(), $e->getCode() ?: 400, $e); } } }