<?php
// ...

$di->setShared('wechat', function () use ($di) {
  $options = [
    'debug'  => $di->get('config')->wechat['DEBUG'],
    'app_id' => $di->get('config')->wechat['WECHAT_APPID'],
    'secret' => $di->get('config')->wechat['WECHAT_SECRET'],
    'token'  => $di->get('config')->wechat['WECHAT_TOKEN'],
    // 'aes_key' => null, // 可选
  
    'log' => [
      'level' => 'debug',
      'file'  => DIR_LOG . '/easywechat.log',
    ],

    'oauth' => [
      'scopes'   => ['snsapi_userinfo'],    // 公众平台网页授权获取用户信息
      'callback' => '/wechat/authcallback', // 获取用户信息后的回调页面
    ],

    'payment' => [
      'merchant_id' => $di->get('config')->wechat['MERCHAT_ID'],
      'key'         => $di->get('config')->wechat['MERCHAT_KEY'],
      'cert_path'   => $di->get('config')->wechat['CERT_PATH'],
      'key_path'    => $di->get('config')->wechat['KEY_PATH'],
      'notify_url'  => $di->get('config')->wechat['NOTIFY_URL'], 
    ],
];

  $wechatApplication = new Application($options);
  return $wechatApplication;
});

<?php
// ...

public function jsSdkAction()
{
  $this->wechat->js->setUrl(urldecode($this->input['url']));

  // getBrandWCPayRequest为需要调用的wx js接口
  return $this->responseData($this->wechat->js->config(
    $apiArray = ['getBrandWCPayRequest',]
  ));
}

<?php
// ...

// wechat/authpage
public function authpageAction()
{
  /* 
    用户将实际需要访问的页面的路由作为参数来访问该路由
    比如需要访问http://mobile.demo.com/jsWxPayDemo.html，而该页面需要用到open_id，那么实际的访问地址为：
    http://mobile.demo.com/wechat/authpage?redirect=jsWxPayDemo.html
  */
  
  $page = $this->input[self::REDIRECT_PAGE];
  if (empty($page)) {
    $page = '';
  }

  // 判断open_id是否已存在，只有在不存在的情况下才需要获取
  $openId = $this->cookieData['open_id'];
  if (!empty($openId)) {
    // open_id已存在，则直接跳转相应的页面
    $this->redirectPage($page);
  }
  else {
    // open_id不存在，需要走获取open_id的流程：
    // 将当期用户需要访问的页面路由存入session中；
    $this->session->set(self::REDIRECT_PAGE, $page);

    // 重定向至微信OAuth认证页面
    return $this->wechat->oauth->redirect()->send();
  }
}

<?php
// ...

// wechat/authcallback
public function authcallbackAction()
{
  $openId = '';

  try {
    $oauth = $this->wechat->oauth;
    $user = $oauth->user();
    $openId = $user->getId();
  } catch (\Exception $e) {
    $this->log->error('openId获取失败！');
    $this->log->error(json_encode($e));
  }

  // 将获取到的微信用户信息存入cookie中
  CommonBusiness::instance()->updateCookies(CookieKeys::COOKIES_USER_INFO, [
    'open_id' => $openId,
  ]);

  // 从session中获取用户的实际访问路由
  $page = $this->session->get(self::REDIRECT_PAGE);

  // 重定向至用户路由
  $this->redirectPage($page);
}

<?php
// ...

// wechat/chargePayConfig
public function chargePayConfigAction()
{
  // 判断登录态 & 获取当前用户信息
  $userInfo = UserBusiness::instance()->getCurrentUser();
  if(empty($userInfo)){
    return $this->responseError('请登录！');
  }

  // 获取充值点数
  $chance = intval($this->input['chance']);
  if($chance < 1){
    return $this->responseError('充值点数非法！');
  }

  // 新建充值记录信息（充值记录类似订单）
  $chargeInfo = new ChanceChargeInfo();
  $chargeInfo->chance = $this->input['chance'];
  $chargeInfo->userId = $userInfo->id;
  $chargeInfo->paidAmount = $chance * 1;  // 1个充值点数 = 1分钱人民币
  $chargeInfo->status = ChanceChargeStatus::UNPAID; // 充值记录的状态为待付款

  $service = new ChanceChargeInfoService();
  $ret = $service->add($chargeInfo);
  if(!$ret){
    return $this->responseError('充值记录创建失败！');
  }

  // 获取本次充值记录的微信支付配置（最终通过调用微信支付统一下单接口得到）
  $ret =  WechatBusiness::instance()->getChargePayConfig($chargeInfo);
  if(false === $ret){
    return $this->responseError('充值订单创建失败！');
  }

  return $this->responseData($ret);
}

<?php
// ...

public function getChargePayConfig(ChanceChargeInfo $info)
{
  // 设置参数
  $attributes = [
    'trade_type'   => 'JSAPI',      // 通过jsSDK拉起微信支付
    'body'         => '充值测试',  
    'detail'       => '充值支付详情', 
    'out_trade_no' => $info->id, // 重要！用于支付成功后回调时判断是哪个订单
    'total_fee'    => $info->paidAmount, // 单位：分
    'notify_url'   => $this->config->env['host'].'/callback/chargePaid', // 重要！用于告诉微信，支付成功后的回调
    'openid'       => $this->cookieData['open_id'], // 用户的open_id
  ];

  // 创建微信支付订单
  $order = new Order($attributes);

  // 获取支付配置
  $ret = $this->wechat->payment->prepare($order);

  if ($ret->return_code == 'SUCCESS' && $ret->result_code == 'SUCCESS') {
    return $this->wechat->payment->configForJSSDKPayment($ret->prepay_id);
  } else {
    return FALSE;
  }
}

<?php
// ...

// callback/chargePaid
public function chargePaidAction()
{
  // $this->log->info($this->request->get());
  $response =  ChanceBusiness::instance()->paidCallback();
  $response->send();
}

<?php
// ...

public function paidCallback()
{
  $response = $this->wechat->payment->handleNotify(function ($notify, $successful) {
            
  // 获取充值订单
  $chanceChargeInfoService = new ChanceChargeInfoService();
  $chanceChargeInfo = $chanceChargeInfoService->findById($notify->out_trade_no);
    if (!$chanceChargeInfo) {
      return FALSE;  // 通知微信,充值订单不存在
    }

    // 如果已支付,或者已取消,则跳过(因为可能多次通知)
    if ($chanceChargeInfo->status != ChanceChargeStatus::UNPAID) {
      return TRUE;
    }

    // 更新用户充值信息
    $chanceInfoService = new ChanceInfoService();
    $chanceInfo = new ChanceInfo();
    $chanceInfo->userId = $chanceChargeInfo->userId;
    $chanceInfo = $chanceInfoService->findUnique($chanceInfo);
  
    if (empty($chanceInfo)) {
      // 出错
      if (FALSE === $chanceInfo) {
        return FALSE;
      }

      // 尚无记录,新建一条
      $chanceInfo = new ChanceInfo();
      $chanceInfo->userId = $chanceChargeInfo->userId;
      $chanceInfo->chance = 0;
      $chanceInfo = $chanceInfoService->add($chanceInfo);
      if (!$chanceInfo) {
        return FALSE;
      }
    }

    // 使用事务更新相关订单
    $transactionConn = TransactionManager::start($chanceChargeInfoService, $chanceInfoService);
    if ($successful) { // 支付成功
      $chanceChargeInfo->status = ChanceChargeStatus::PAID;
      $chanceChargeInfo->transactionId = $notify->transaction_id;
      $chanceChargeInfo->remark = json_encode($notify);
      $chanceInfo->chance += $chanceChargeInfo->chance;
    } else { // 支付失败
      $chanceChargeInfo->status = ChanceChargeStatus::CANCELED;
      $chanceChargeInfo->remark = '支付失败';
    }
    
    // 修改充值订单状态
    if (!$chanceChargeInfoService->update($chanceChargeInfo)) {
      TransactionManager::rollback($transactionConn);
      $this->log->error('充值记录付款回调失败: ' . json_encode($chanceChargeInfo));
      return FALSE;
    }
    
    // 修改用户当前点数
    if (!$chanceInfoService->update($chanceInfo)) {
      TransactionManager::rollback($transactionConn);
      $this->log->error('用户充值点数更新失败: ' . json_encode($chanceInfo));
      return FALSE;
    }

    TransactionManager::commit($transactionConn);

    return TRUE;
  });

  return $response;
}