|
@@ -6,6 +6,7 @@ require_once(BASE_HELPER_RAPI_PATH . '/liantongzx/config.php');
|
|
|
|
|
|
use refill;
|
|
|
use Log;
|
|
|
+use QueueClient;
|
|
|
|
|
|
class RefillPhone extends refill\IRefillPhone
|
|
|
{
|
|
@@ -44,7 +45,18 @@ class RefillPhone extends refill\IRefillPhone
|
|
|
if (empty($resp)) {
|
|
|
return [false, '网络错误', true];
|
|
|
} elseif ($resp['code'] === '00000') {
|
|
|
- return [true, $resp['data']['id'], false];
|
|
|
+ $status = $resp['data']['status'];
|
|
|
+ if ($status === 1) {
|
|
|
+ return [true, $resp['data']['id'], false];
|
|
|
+ } elseif ($status === 2) {
|
|
|
+ QueueClient::async_push("QueryRefillState", ['order_id' => $params['order_id']], 1);
|
|
|
+ return [true, $resp['data']['id'], false];
|
|
|
+ } elseif ($status === 3) {
|
|
|
+ return [false, $resp['msg'], false];
|
|
|
+ } else {
|
|
|
+ $net_errno = "HTTP-{$status}";
|
|
|
+ return [true, $resp['msg'], true];
|
|
|
+ }
|
|
|
} elseif ($resp['code'] === '20008' || $resp['code'] === '99999') {
|
|
|
$net_errno = "HTTP-{$resp['code']}";
|
|
|
return [true, $resp['msg'], true];
|