notification

Author: recca0120

src/Gateway.php

@@ -3,6 +3,9 @@
 namespace Omnipay\WanPay;
 
 use Omnipay\Common\AbstractGateway;
+use Omnipay\Common\Message\NotificationInterface;
+use Omnipay\Common\Message\RequestInterface;
+use Omnipay\WanPay\Message\AcceptNotificationRequest;
 use Omnipay\WanPay\Message\CompletePurchaseRequest;
 use Omnipay\WanPay\Message\FetchTransactionRequest;
 use Omnipay\WanPay\Message\PurchaseRequest;
@@ -39,6 +42,14 @@ public function completePurchase(array $options = [])
         return $this->createRequest(CompletePurchaseRequest::class, $options);
     }
 
+    /**
+     * @return RequestInterface|NotificationInterface
+     */
+    public function acceptNotification(array $options = [])
+    {
+        return $this->createRequest(AcceptNotificationRequest::class, $options);
+    }
+
     public function fetchTransaction(array $options = [])
     {
         return $this->createRequest(FetchTransactionRequest::class, $options);

src/Message/AcceptNotificationRequest.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace Omnipay\WanPay\Message;
+
+use Omnipay\Common\Message\NotificationInterface;
+
+class AcceptNotificationRequest extends CompletePurchaseRequest implements NotificationInterface
+{
+    /**
+     * @param  array  $data
+     * @return AcceptNotificationResponse
+     */
+    public function sendData($data)
+    {
+        return $this->response = new AcceptNotificationResponse($this, $data);
+    }
+
+    /**
+     * @return string
+     */
+    public function getTransactionStatus()
+    {
+        return $this->getNotificationResponse()->getTransactionStatus();
+    }
+
+    /**
+     * @return string|null
+     */
+    public function getMessage()
+    {
+        return $this->getNotificationResponse()->getMessage();
+    }
+
+    /**
+     * @return AcceptNotificationResponse
+     */
+    private function getNotificationResponse()
+    {
+        return ! $this->response ? $this->send() : $this->response;
+    }
+
+    /**
+     * @return string
+     */
+    public function getReply()
+    {
+        return $this->getNotificationResponse()->getReply();
+    }
+}

src/Message/AcceptNotificationResponse.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Omnipay\WanPay\Message;
+
+use Omnipay\Common\Message\NotificationInterface;
+
+class AcceptNotificationResponse extends CompletePurchaseResponse implements NotificationInterface
+{
+    /**
+     * @return string
+     */
+    public function getTransactionStatus()
+    {
+        return $this->isSuccessful() ? self::STATUS_COMPLETED : self::STATUS_FAILED;
+    }
+
+    /**
+     * @return string
+     */
+    public function getReply()
+    {
+        return 'success';
+    }
+}

tests/GatewayTest.php

@@ -2,6 +2,7 @@
 
 namespace Omnipay\WanPay\Tests;
 
+use Omnipay\Common\Message\NotificationInterface;
 use Omnipay\Tests\GatewayTestCase;
 use Omnipay\WanPay\Gateway;
 
@@ -62,6 +63,25 @@ public function testCompletePurchase()
         self::assertEquals('核准', $response->getMessage());
     }
 
+    public function testAcceptNotification()
+    {
+        $response = 'https://member.healthchain.com.tw/MHC01SSV2TEST/Checkout/CheckOutShowResultWangPay.aspx?authcode=154566&bankcard=552199******1898&nonce_str=46444248&orgno=21001719&out_trade_no=040911560243087HRC&result=核准&secondtimestamp=1586404583&status=0000&total_fee=100&orderdate=2020-04-09 11:56:02&trxtoken=&storename=旺旺電子商務-快點付&details=固定金額 免收件地址&payername=0409&payermobile=0409&payeremail=0409&sign=C720CD30C24DB5A372A33B90D2906C46';
+        $parsed = parse_url($response);
+        $options = [];
+        parse_str($parsed['query'], $options);
+
+        $request = $this->gateway->acceptNotification($options);
+        self::assertEquals('核准', $request->getMessage());
+        self::assertEquals(NotificationInterface::STATUS_COMPLETED, $request->getTransactionStatus());
+
+        $response = $request->send();
+
+        self::assertTrue($response->isSuccessful());
+        self::assertEquals('040911560243087HRC', $response->getTransactionId());
+        self::assertEquals('0000', $response->getCode());
+        self::assertEquals('success', $response->getReply());
+    }
+
     public function testFetchTransaction()
     {
         $this->setMockHttpResponse('FetchTransaction.txt');