|
@@ -37,26 +37,28 @@ class processor extends queue\ILooper
|
|
|
$input = $params['params'];
|
|
|
if (empty($channel) || empty($params))
|
|
|
continue;
|
|
|
-// $this->mProxy->notify($channel, $input);
|
|
|
- } elseif ($method == 'notify_mechant') {
|
|
|
- $order_id = intval($params['order_id']);
|
|
|
- $manual = $params['manual'] ?? false;
|
|
|
- $this->mProxy->notify_merchant($order_id, $manual);
|
|
|
- } elseif ($method == 'query') {
|
|
|
- $order_id = intval($params['order_id']);
|
|
|
- $this->mProxy->query($order_id);
|
|
|
- } elseif ($method == 'query_net') {
|
|
|
- $order_id = intval($params['order_id']);
|
|
|
- $this->mProxy->query_net($order_id);
|
|
|
- } elseif ($method == 'manual_success') {
|
|
|
- $order_id = intval($params['order_id']);
|
|
|
- $this->mProxy->manual_success($order_id);
|
|
|
- } elseif ($method == 'manual_cancel') {
|
|
|
- $order_id = intval($params['order_id']);
|
|
|
- $this->mProxy->manual_cancel($order_id);
|
|
|
- } elseif ($method == 'addthird') {
|
|
|
- $this->mProxy->addthird($params);
|
|
|
- } else {
|
|
|
+ $this->mProxy->notify($channel, $input);
|
|
|
+ }
|
|
|
+// elseif ($method == 'notify_mechant') {
|
|
|
+// $order_id = intval($params['order_id']);
|
|
|
+// $manual = $params['manual'] ?? false;
|
|
|
+// $this->mProxy->notify_merchant($order_id, $manual);
|
|
|
+// } elseif ($method == 'query') {
|
|
|
+// $order_id = intval($params['order_id']);
|
|
|
+// $this->mProxy->query($order_id);
|
|
|
+// } elseif ($method == 'query_net') {
|
|
|
+// $order_id = intval($params['order_id']);
|
|
|
+// $this->mProxy->query_net($order_id);
|
|
|
+// } elseif ($method == 'manual_success') {
|
|
|
+// $order_id = intval($params['order_id']);
|
|
|
+// $this->mProxy->manual_success($order_id);
|
|
|
+// } elseif ($method == 'manual_cancel') {
|
|
|
+// $order_id = intval($params['order_id']);
|
|
|
+// $this->mProxy->manual_cancel($order_id);
|
|
|
+// } elseif ($method == 'addthird') {
|
|
|
+// $this->mProxy->addthird($params);
|
|
|
+// }
|
|
|
+ else {
|
|
|
Log::record("Error Method={$method}", Log::DEBUG);
|
|
|
}
|
|
|
}
|