php app支付寶回調(diào)（異步通知）詳解

/** rsaCheckV1  rsaCheckV2
  * 驗(yàn)證簽名
  * 在使用本方法前，必須初始化AopClient且傳入公鑰參數(shù)。
  * 公鑰是否是讀取字符串還是讀取文件，是根據(jù)初始化傳入的值判斷的。
  **/
 public function rsaCheckV1($params, $rsaPublicKeyFilePath,$signType='RSA') {
  $sign = $params['sign'];
  $params['sign_type'] = null;
  $params['sign'] = null;
  $this->alipayrsaPublicKey = $rsaPublicKeyFilePath;

  return $this->verify($this->getSignContent($params), $sign, $rsaPublicKeyFilePath,$signType);
 }
 public function rsaCheckV2($params, $rsaPublicKeyFilePath, $signType='RSA') {
  $sign = $params['sign'];
  $params['sign'] = null;
  return $this->verify($this->getSignContent($params), $sign, $rsaPublicKeyFilePath, $signType);
 }
 function verify($data, $sign, $rsaPublicKeyFilePath, $signType = 'RSA') {

  if($this->checkEmpty($this->alipayPublicKey)){

   $pubKey= $this->alipayrsaPublicKey;
   $res = "-----BEGIN PUBLIC KEY-----\n" .
    wordwrap($pubKey, 64, "\n", true) .
    "\n-----END PUBLIC KEY-----";
  }else {
   //讀取公鑰文件
   $pubKey = file_get_contents($rsaPublicKeyFilePath);
   //轉(zhuǎn)換為openssl格式密鑰
   $res = openssl_get_publickey($pubKey);
  }

  ($res) or die('支付寶RSA公鑰錯誤。請檢查公鑰文件格式是否正確'); 

  //調(diào)用openssl內(nèi)置方法驗(yàn)簽，返回bool值
  if ("RSA2" == $signType) {
   $result = (bool)openssl_verify($data, base64_decode($sign), $res, OPENSSL_ALGO_SHA256);
  } else {
   $result = (bool)openssl_verify($data, base64_decode($sign), $res);
  }

  if(!$this->checkEmpty($this->alipayPublicKey)) {
   //釋放資源
   openssl_free_key($res);
  }

  return $result;
 }

public function check($receipt_amount,$buyer_pay_amount,$order_price,$app_id,$seller_email){
  if($receipt_amount !== $order_price || $buyer_pay_amount !== $order_price){
//    echo 1;
   return $this->log('訂單支付金額有誤!');
  }
  //支付寶支付的所有參數(shù)
  $alipay_config = Config::get('alipay_config');
  if($app_id !== $alipay_config['appid']){
//   echo 2;
    return $this->log('商家編號有誤!');
  }

  //驗(yàn)證收款商家是否正確
  if($seller_email !== $alipay_config['seller_id']){
//   echo 3;
   return $this->log('收款商家有誤!');
  }
  return 'success';
 }

public function index($order_sn='')
 {
  if(isset($_POST['order_sn'])  empty($order_sn)){
   $order_sn = $_POST['order_sn'];
  }

  $table = self::order_info($order_sn);
  if($table == 'failure'){return 'false';}
  $oid = $table['order_id'];
  //通過訂單id $oid 查詢出訂單中物品的id
  $goodsTable = Db::name('goods');
  $allgoods = Db::name("test1")->where('o_id', $oid)->field('g_id,g_num')->select();
  foreach ($allgoods as $k => $v) {
   //事務(wù)處理
   $goodsTable->startTrans();//事物開始
   try {
    //判斷庫存數(shù)量
    $goodsTable->query('update test2 set g_num = g_num-' . $v['g_num'] . ' where g_num >= ' . $v['g_num'] . ' and gid =' . $v['g_id']);

   } catch (\Exception $e) {
    $goodsTable->rollBack();//事物回滾
   }

   $goodsTable->commit();// 事物提交
  }

  //修改訂單
  $res = Db::name('test3')->where('order_sn',$order_sn)->update(['order_state' => '1','pay_time'=>time()]);
  if($res != 0){
   return 'success';
  }
 }