能否从后端向Google dataLayer发数据？WordPress+LearnDash替代SSE方案咨询

针对你遇到的SSE持久连接导致CPU负载过高的问题，以下是几个轻量可靠的替代方案，适配不同触发场景：

方案1：页面同步渲染时直接注入GTM事件脚本 #

适用于用户完成课程/课时后会触发页面跳转或刷新的场景（比如完成后回到课程列表、显示完成提示页）。

直接在LearnDash的动作钩子中，输出dataLayer.push()脚本到页面，无需中间存储或持久连接。

示例代码：

add_action( 'ld_after_mark_lesson_complete', 'gtm_push_lesson_complete_event', 10, 3 );
function gtm_push_lesson_complete_event( $lesson_id, $user_id, $progress ) {
    // 组装GTM事件数据
    $gtm_event = [
        'event' => 'lessonCompleted',
        'lessonId' => $lesson_id,
        'lessonTitle' => get_the_title( $lesson_id ),
        'userId' => $user_id,
        'completedAt' => current_time( 'mysql' )
    ];

    // 把脚本输出到页面底部（确保在GTM代码之后加载）
    add_action( 'wp_footer', function() use ( $gtm_event ) {
        echo "<script>
window.dataLayer = window.dataLayer || [];
dataLayer.push(" . json_encode( $gtm_event ) . ");
</script>";
    }, 20 );
}

优点：零额外服务器负载，GTM直接捕获事件，无延迟。
缺点：仅适用于有页面刷新的场景，异步完成动作时不生效。

方案2：AJAX定时拉取数据库事件（异步场景适配） #

保留你现有的“钩子触发时存数据库”逻辑，改用前端定时AJAX拉取未同步事件，避免持久连接。

后端注册AJAX接口 #

add_action( 'wp_ajax_fetch_gtm_pending_events', 'fetch_gtm_pending_events' );
function fetch_gtm_pending_events() {
    if ( !is_user_logged_in() ) {
        wp_send_json_error( '未登录用户无法访问' );
    }

    $user_id = get_current_user_id();
    global $wpdb;

    // 拉取当前用户未同步的事件
    $pending_events = $wpdb->get_results( $wpdb->prepare(
        "SELECT * FROM your_event_table WHERE user_id = %d AND is_synced = 0",
        $user_id
    ), ARRAY_A );

    if ( empty( $pending_events ) ) {
        wp_send_json_success( [] );
    }

    // 标记事件为已同步，避免重复推送
    $event_ids = wp_list_pluck( $pending_events, 'id' );
    $placeholders = implode( ',', array_fill( 0, count( $event_ids ), '%d' ) );
    $wpdb->query( $wpdb->prepare(
        "UPDATE your_event_table SET is_synced = 1 WHERE id IN ($placeholders)",
        $event_ids
    ) );

    wp_send_json_success( $pending_events );
}

前端定时拉取脚本 #

// 每30秒拉取一次未同步事件
setInterval(() => {
    jQuery.post( ajaxurl, { action: 'fetch_gtm_pending_events' }, function( res ) {
        if ( res.success && res.data.length > 0 ) {
            res.data.forEach( event => {
                window.dataLayer = window.dataLayer || [];
                dataLayer.push({
                    event: event.event_name,
                    lessonId: event.lesson_id,
                    userId: event.user_id
                    // 其他字段根据你的数据库结构调整
                });
            });
        }
    });
}, 30000);

优点：服务器负载低，适配异步完成场景。
缺点：存在一定延迟（可根据需求调整拉取间隔），需要维护数据库事件状态。

方案3：监听LearnDash AJAX完成事件，实时拉取 #

针对异步完成动作的场景，直接监听LearnDash的AJAX请求完成事件，触发一次拉取，避免定时轮询的延迟。

示例前端代码：

// 监听LearnDash的课时完成AJAX请求
jQuery(document).ajaxComplete( function( event, xhr, settings ) {
    if ( settings.data?.includes('action=mark_lesson_complete') ) {
        // 请求完成后立即拉取事件
        jQuery.post( ajaxurl, { action: 'fetch_gtm_pending_events' }, function( res ) {
            if ( res.success && res.data.length > 0 ) {
                res.data.forEach( event => {
                    window.dataLayer = window.dataLayer || [];
                    dataLayer.push( event );
                });
            }
        });
    }
});

优点：延迟极低，仅在触发动作后拉取，服务器负载更低。
缺点：需要准确识别LearnDash的AJAX动作，可能随插件版本更新变化。

方案4：服务器端直接调用分析工具API #

如果不需要前端触发GTM事件，可直接在LearnDash钩子中调用Google Analytics Measurement Protocol（或其他支持服务器端上报的工具），完全跳过前端环节。

示例代码：

add_action( 'ld_after_mark_course_complete', 'send_course_complete_to_ga', 10, 3 );
function send_course_complete_to_ga( $course_id, $user_id, $progress ) {
    $user = get_userdata( $user_id );
    // 从用户元数据中获取GA Client ID（需提前前端存储到用户元数据）
    $ga_cid = get_user_meta( $user_id, '_ga_client_id', true );

    $payload = [
        'v' => 1,
        'tid' => 'UA-XXXXXXXXX-X', // 替换为你的GA跟踪ID
        'cid' => $ga_cid,
        't' => 'event',
        'ec' => 'Courses',
        'ea' => 'CourseCompleted',
        'el' => get_the_title( $course_id ),
        'uid' => $user_id
    ];

    // 异步发送请求，不阻塞页面加载
    wp_remote_post( 'https://www.google-analytics.com/collect', [
        'body' => http_build_query( $payload ),
        'timeout' => 5,
        'blocking' => false
    ] );
}

优点：完全脱离前端，无页面性能影响，服务器端直接上报。
缺点：需要提前同步用户的GA Client ID到数据库，仅支持有服务器端API的分析工具。

内容的提问来源于stack exchange，提问作者Kaho chan