全开源短剧源码解析：含小程序与App的双端实现方案

// Node.js+Express用户注册接口
const bcrypt = require('bcrypt');
const jwt = require('jsonwebtoken');

app.post('/api/register', async (req, res) => {
  const { username, password, email } = req.body;
  const hashedPassword = await bcrypt.hash(password, 10);
  const user = await db.query(
    'INSERT INTO users (username, password, email) VALUES (?, ?, ?)',
    [username, hashedPassword, email]
  );
  res.status(201).json({ id: user.insertId, username, email });
});

<!-- H5端视频组件示例 -->
<template>
  <video ref="videoPlayer" class="video-js"></video>
</template>

<script>
import videojs from 'video.js';

export default {
  mounted() {
    this.player = videojs(this.$refs.videoPlayer, {
      controls: true,
      sources: [{
        src: 'https://cdn.example.com/stream.m3u8',
        type: 'application/x-mpegURL'
      }]
    });
  }
};
</script>

// 用户注册接口（bcrypt加密）
const bcrypt = require('bcrypt');
const jwt = require('jsonwebtoken');
app.post('/api/register', async (req, res) => {
  const { username, password, email } = req.body;
  const hashedPassword = await bcrypt.hash(password, 10);
  const user = await db.query(
    'INSERT INTO users (username, password, email) VALUES (?, ?, ?)',
    [username, hashedPassword, email]
  );
  res.status(201).json({ id: user.insertId, username, email });
});

// JWT登录验证
app.post('/api/login', async (req, res) => {
  const { username, password } = req.body;
  const user = await db.query('SELECT * FROM users WHERE username = ?', [username]);
  if (!user || !await bcrypt.compare(password, user.password)) {
    return res.status(401).json({ error: 'Invalid credentials' });
  }
  const token = jwt.sign({ id: user.id }, 'your_secret_key', { expiresIn: '1h' });
  res.json({ token });
});

// 微信OpenID绑定（小程序端）
wx.login({
  success: async (res) => {
    const { code } = res;
    const { data } = await http.post('/api/auth/wechat', { code });
    wx.setStorageSync('token', data.token);
  }
});

// 视频转码为HLS格式
const ffmpeg = require('fluent-ffmpeg');
ffmpeg('input.mp4')
  .outputOptions([
    '-c:v libx264',
    '-c:a aac',
    '-hls_time 10',
    '-hls_list_size 0'
  ])
  .output('output.m3u8')
  .run();

// 前端播放器集成
import videojs from 'video.js';
const player = videojs(document.querySelector('#videoPlayer'), {
  controls: true,
  sources: [{
    src: 'https://cdn.example.com/stream.m3u8',
    type: 'application/x-mpegURL'
  }]
});

// 自适应码率控制
player.ready(() => {
  player.on('loadedmetadata', () => {
    const networkSpeed = getNetworkSpeed();
    const qualityLevel = networkSpeed > 5 ? '720p' : '360p';
    player.src({ src: `stream_${qualityLevel}.m3u8`, type: 'application/x-mpegURL' });
  });
});

// 评论数据模型
@Schema()
export class Comment {
  @Prop({ type: String, required: true })
  userId: string;

  @Prop({ type: String, required: true })
  dramaId: string;

  @Prop({ type: String })
  content: string;

  @Prop({ type: [{ type: String }] })
  replies: string[]; // 存储回复ID
}

// 发布评论接口
@Post('/comments')
async createComment(@Body() dto: CreateCommentDto) {
  const comment = new this.commentModel(dto);
  await comment.save();
  
  // 更新短剧评论计数
  await this.dramaModel.updateOne(
    { _id: dto.dramaId },
    { $inc: { commentCount: 1 } }
  );
  
  return { id: comment._id };
}

// 评论列表分页查询
@Get('/comments/:dramaId')
async getComments(
  @Param('dramaId') dramaId: string,
  @Query('page') page: number = 1,
  @Query('limit') limit: number = 20
) {
  const comments = await this.commentModel
    .find({ dramaId })
    .sort({ createdAt: -1 })
    .skip((page - 1) * limit)
    .limit(limit)
    .populate('userId', 'username avatar');
  
  return { data: comments };
}

// 创建支付订单
const axios = require('axios');
const crypto = require('crypto');

app.post('/api/payment', async (req, res) => {
  const { amount, openid, dramaId } = req.body;
  
  // 生成微信支付预支付订单
  const result = await axios.post('https://api.mch.weixin.qq.com/pay/unifiedorder', {
    mch_id: 'YOUR_MCH_ID',
    nonce_str: Math.random().toString(36).slice(2),
    body: '短剧观看权限',
    out_trade_no: Date.now().toString(),
    total_fee: amount * 100, // 单位转为分
    spbill_create_ip: req.ip,
    notify_url: 'https://yourdomain.com/api/payment/notify',
    trade_type: 'JSAPI',
    openid: openid
  }, {
    headers: { 'Content-Type': 'application/xml' }
  });
  
  // 返回支付参数给前端
  const paySign = generatePaySign(result.data);
  res.json({
    appId: 'wx1234567890abcdef',
    timeStamp: Date.now().toString(),
    nonceStr: result.data.nonce_str,
    package: `prepay_id=${result.data.prepay_id}`,
    signType: 'MD5',
    paySign: paySign
  });
});

// 支付结果回调处理
app.post('/api/payment/notify', (req, res) => {
  const { openid, out_trade_no } = req.body;
  
  // 更新用户订阅状态
  db.query(
    'UPDATE users SET subscription_expiry = ? WHERE openid = ?',
    [new Date(Date.now() + 30 * 24 * 60 * 60 * 1000), openid]
  );
  
  // 记录支付成功日志
  fs.appendFileSync('payment.log', `${out_trade_no}: SUCCESS\n`);
  
  res.send('<xml><return_code><![CDATA[SUCCESS]]></return_code></xml>');
});

// 条件编译实现多端兼容
const isWechat = typeof wx !== 'undefined';
const player = isWechat 
  ? wx.createVideoContext('livePlayer') 
  : document.querySelector('#videoPlayer');

// 微信支付适配
if (isWechat) {
  wx.requestPayment({
    timeStamp: paymentData.timeStamp,
    nonceStr: paymentData.nonceStr,
    package: paymentData.package,
    signType: paymentData.signType,
    paySign: paymentData.paySign,
    success: () => showSuccessModal()
  });
}

// 视频播放器组件
VideoPlayerController _controller = VideoPlayerController.network(
  'https://cdn.example.com/stream.m3u8'
);

// 支付集成
Easypay.pay(
  amount: 9.99,
  currency: 'USD',
  paymentMethod: PaymentMethod.creditCard,
  onSuccess: (payment) => showSuccessScreen(),
);