修复退款通知处理

WePayV3/Contracts/BasicWePay.php

@@ -16,7 +16,6 @@ namespace WePayV3\Contracts;
 
 use WeChat\Contracts\Tools;
 use WeChat\Exceptions\InvalidArgumentException;
-use WeChat\Exceptions\InvalidDecryptException;
 use WeChat\Exceptions\InvalidResponseException;
 use WeChat\Exceptions\LocalCacheException;
 use WePayV3\Cert;
@@ -217,24 +216,4 @@ abstract class BasicWePay
             return Tools::setCache($name, base64_encode($content), 7200);
         }
     }
-
-    /**
-     * 支付通知
-     * @return array
-     * @throws InvalidDecryptException
-     */
-    public function notify()
-    {
-        $body = file_get_contents('php://input');
-        $data = json_decode($body, true);
-        if (isset($data['resource'])) {
-            $aes = new DecryptAes($this->config['mch_v3_key']);
-            $data['result'] = $aes->decryptToString(
-                $data['resource']['associated_data'],
-                $data['resource']['nonce'],
-                $data['resource']['ciphertext']
-            );
-        }
-        return $data;
-    }
 }

WePayV3/Order.php

@@ -16,8 +16,10 @@ namespace WePayV3;
 
 use WeChat\Contracts\Tools;
 use WeChat\Exceptions\InvalidArgumentException;
+use WeChat\Exceptions\InvalidDecryptException;
 use WeChat\Exceptions\InvalidResponseException;
 use WePayV3\Contracts\BasicWePay;
+use WePayV3\Contracts\DecryptAes;
 
 /**
  * 订单支付接口
@@ -80,4 +82,25 @@ class Order extends BasicWePay
         $pathinfo = "/v3/pay/transactions/out-trade-no/{$orderNo}";
         return $this->doRequest('GET', "{$pathinfo}?mchid={$this->config['mch_id']}", '', true);
     }
+
+    /**
+     * 支付通知
+     * @return array
+     * @throws InvalidDecryptException
+     */
+    public function notify()
+    {
+        $body = file_get_contents('php://input');
+        $data = json_decode($body, true);
+        if (isset($data['resource'])) {
+            $aes = new DecryptAes($this->config['mch_v3_key']);
+            $data['result'] = $aes->decryptToString(
+                $data['resource']['associated_data'],
+                $data['resource']['nonce'],
+                $data['resource']['ciphertext']
+            );
+        }
+        return $data;
+    }
+
 }

WePayV3/Refund.php

@@ -14,6 +14,8 @@
 
 namespace WePayV3;
 
+use WeChat\Contracts\Tools;
+use WeChat\Exceptions\InvalidDecryptException;
 use WeChat\Exceptions\InvalidResponseException;
 use WePayV3\Contracts\BasicWePay;
 
@@ -47,4 +49,27 @@ class Refund extends BasicWePay
         return $this->doRequest('GET', "{$pathinfo}?sub_mchid={$this->config['mch_id']}", '', true);
     }
 
+    /**
+     * 获取退款通知
+     * @return array
+     * @throws InvalidDecryptException
+     * @throws InvalidResponseException
+     */
+    public function notify()
+    {
+        $data = Tools::xml2arr(file_get_contents("php://input"));
+        if (!isset($data['return_code']) || $data['return_code'] !== 'SUCCESS') {
+            throw new InvalidResponseException('获取退款通知XML失败！');
+        }
+        try {
+            $key = md5($this->config['mch_v3_key']);
+            $decrypt = base64_decode($data['req_info']);
+            $response = openssl_decrypt($decrypt, 'aes-256-ecb', $key, OPENSSL_RAW_DATA);
+            $data['result'] = Tools::xml2arr($response);
+            return $data;
+        } catch (\Exception $exception) {
+            throw new InvalidDecryptException($exception->getMessage(), $exception->getCode());
+        }
+    }
+
 }