Memberpress非订阅交易企业账户ID获取异常处理：基于事件钩子的延时策略

add_action('mepr-event-transaction-completed', 'my_custom_corporate_logic');

function my_custom_corporate_logic($event) {
  $transaction = $event->get_data();
  $membership_type_ids = array(1, 2, 4); // 假设这些是需要处理的会员类型ID

  // 确保是指定的会员类型且是支付交易
  if (in_array($transaction->product_id, $membership_type_ids) && $transaction->txn_type == 'payment') {
    $org_id = $transaction->corporate_account_id; // 在非订阅交易中，这里可能返回 0

    // 如果 org_id 为 0，说明获取失败
    if (empty($org_id)) {
      // 记录日志或进行其他错误处理
      error_log('Memberpress: Corporate account ID is 0 for transaction ' . $transaction->trans_num);
    } else {
      // 成功获取到企业ID，执行自定义函数
      my_custom_function($org_id);
    }
  }
}

function my_custom_function($corporate_account_id) {
  // 实际的业务逻辑，例如将用户添加到企业组、发送通知等
  // ...
}

/**
 * Memberpress交易完成事件处理函数
 * 用于处理非订阅交易中企业账户ID获取异常的问题。
 */
add_action('mepr-event-transaction-completed', 'handle_memberpress_corporate_transaction');

function handle_memberpress_corporate_transaction($event) {
  $transaction = $event->get_data();
  $membership_type_ids = array(1, 2, 4); // 假设这些是需要处理的会员类型ID

  // 检查是否为指定的会员类型且是支付交易
  if (in_array($transaction->product_id, $membership_type_ids) && $transaction->txn_type == 'payment') {

    // 尝试获取企业账户ID
    $corporate_id = $transaction->corporate_account_id;

    // 检查 corporate_id 是否为 0 或空
    if (!empty($corporate_id) && $corporate_id !== "0") {
      // 如果企业ID有效，直接执行自定义逻辑
      my_custom_corporate_function($corporate_id, $transaction);
    } else {
      // 如果企业ID为 0 或空，说明可能存在时序问题，调度一个延时任务
      error_log('Memberpress: Corporate ID returned 0 for transaction ' . $transaction->trans_num . '. Scheduling a delayed fix.');

      // 调度一个在2分钟后执行的单次任务
      // 'send_fix_for_zero_transaction' 是自定义的cron钩子名称
      // array($transaction) 是传递给回调函数的参数
      // false 表示不检查是否已存在相同事件，每次都调度
      wp_schedule_single_event(strtotime("+2 minutes"), 'send_fix_for_zero_transaction', array($transaction), false);

      // 立即返回，等待定时任务处理
      return;
    }
  }
}

/**
 * 自定义钩子回调函数，用于处理延时任务。
 * 当 'send_fix_for_zero_transaction' 钩子触发时执行。
 *
 * @param MeprTransaction $original_transaction 原始交易对象（可能不完整）
 */
add_action('send_fix_for_zero_transaction', 'single_transaction_create_corporate_delayed');

function single_transaction_create_corporate_delayed($original_transaction) {
  // 通过交易号重新获取完整的交易对象
  $trans_num = $original_transaction->trans_num;
  $full_transaction = MeprTransaction::get_one_by_trans_num($trans_num);

  // 再次检查企业账户ID
  $corporate_id = $full_transaction->corporate_account_id;

  if (!empty($corporate_id) && $corporate_id !== "0") {
    // 此时企业ID应该已正确获取，执行自定义逻辑
    my_custom_corporate_function($corporate_id, $full_transaction);
    error_log('Memberpress: Successfully processed delayed corporate transaction ' . $trans_num . ' with ID ' . $corporate_id);
  } else {
    // 如果延时后仍然获取失败，可能存在其他问题，需要进一步调查
    error_log('Memberpress: Delayed processing failed for transaction ' . $trans_num . '. Corporate ID still 0.');
  }
}

/**
 * 实际的自定义业务逻辑函数。
 *
 * @param int $corporate_account_id 企业账户ID
 * @param MeprTransaction $transaction 完整的交易对象
 */
function my_custom_corporate_function($corporate_account_id, $transaction) {
  // 在这里实现您的业务逻辑
  // 例如：
  // echo "处理企业ID: " . $corporate_account_id . " 的交易: " . $transaction->trans_num;
  // MeprCorporateAccount::add_user_to_corporate_account($transaction->user_id, $corporate_account_id);
  // ...
}