基于 Java Spring Boot + Vue3 + uni-app 打造「私域直播」能力（附源码）

backend/
├── member   # 内容、直播、IM、语聊
├── mall     # 商城（货架跳转下单）
├── pay      # 支付
├── infra    # 配置、文件、WebSocket、定时任务
└── system   # 权限 / 租户

admin-ui/    # Vue3 管理端
mobile/      # uni-app
sql/         # yudao-full.sql + quartz.sql + xhs-init.sql

int maxMinutes = getLiveMaxMinutes();
resp.setMaxMinutes(maxMinutes);
if (maxMinutes > 0 && note.getLiveStartTime() != null) {
    resp.setLiveExpireTime(note.getLiveStartTime().plusMinutes(maxMinutes));
}
return resp;

private int endExperienceExpiredLives() {
    int maxMinutes = getLiveMaxMinutes();
    if (maxMinutes <= 0) {
        return 0;
    }
    LocalDateTime startDeadline = LocalDateTime.now().minusMinutes(maxMinutes);
    List<MemberNoteDO> expired = memberNoteMapper.selectExperienceExpiredLiving(startDeadline);
    // ... doEndLive(note, "experience_timeout", tipMessage);
}

<view v-if="state.countdownVisible"
      class="live__exp-cd"
      :class="{ 'live__exp-cd--warn': state.remainSec <= 60 }">
  <text class="live__exp-cd__label">体验剩余</text>
  <text class="live__exp-cd__time">{{ state.countdownText }}</text>
</view>

export function createExperienceCountdown(options) {
  const expireAtMs = Number(options?.expireAtMs) || 0;
  const onTick = options?.onTick;
  const onExpire = options?.onExpire;
  let timer = null;

  const tick = () => {
    const remain = Math.max(0, Math.ceil((expireAtMs - Date.now()) / 1000));
    if (typeof onTick === 'function') onTick(remain, formatRemain(remain));
    if (remain <= 0) {
      clearInterval(timer);
      if (typeof onExpire === 'function') onExpire();
    }
  };

  return {
    start() {
      tick();
      timer = setInterval(tick, 1000);
    },
    stop() {
      if (timer) clearInterval(timer);
    },
  };
}

// 直播间内：
experienceCountdown = createExperienceCountdown({
  expireAtMs: parseTimeMs(data.liveExpireTime),
  onTick: (remain, text) => {
    state.remainSec = remain;
    state.countdownText = text;
  },
  onExpire: () => onForceEnded('体验时长已到，自动关闭。如需体验请联系管理员', true),
});
experienceCountdown.start();

export function buildLiveInviteLink(noteId) {
  // #ifdef H5
  if (typeof location !== 'undefined') {
    const base = `${location.origin}${location.pathname || '/'}`;
    return `${base}#/pages/note/live?id=${encodeURIComponent(noteId)}`;
  }
  // #endif
  return `/pages/note/live?id=${noteId}`;
}

export function buildVoiceRoomInviteLink(roomNo) {
  // #ifdef H5
  if (typeof location !== 'undefined') {
    const base = `${location.origin}${location.pathname || '/'}`;
    return `${base}#/pages/voice-room/room?roomNo=${encodeURIComponent(roomNo)}`;
  }
  // #endif
  return `/pages/voice-room/room?roomNo=${roomNo}`;
}

INSERT INTO `infra_config`
  (`category`, `type`, `name`, `config_key`, `value`, `visible`, `remark`,
   `creator`, `create_time`, `updater`, `update_time`, `deleted`)
SELECT 'member', 2, '会员直播-单场最长分钟', 'member.live.max-minutes', '30', b'1',
       '体验限制：开播超过该分钟数自动关播；0=不限制',
       '1', NOW(), '1', NOW(), b'0'
FROM DUAL
WHERE NOT EXISTS (
  SELECT 1 FROM `infra_config`
  WHERE `config_key` = 'member.live.max-minutes' AND `deleted` = b'0'
);

主播                后端                 TRTC                观众
 │    开播/拿凭证     │                    │                   │
 │──────────────────►│ 写直播状态 + 签 UserSig                  │
 │◄──── credentials ─│                    │                   │
 │  enterRoom+推流   │───────────────────────────────────────►│
 │                   │◄── 观众 credentials─┼───────────────────│
 │  公屏/点赞/货架   │◄────── WS/HTTP ────┼───────────────────│
 │  心跳             │ 扫描超时/体验到期   │                   │
 │  结束             │ 推结束事件          │──────────────────►│