7、高并发抢红包示例（非事务版本）

'use strict';
module.exports = {
  /**
   * 高并发抢红包示例
   * @url db_api/sys/concurrent 前端调用的url参数地址
   */
  main: async (event) => {
    let { data = {}, userInfo, util, filterResponse, originalParam } = event;
    let { customUtil, config, pubFun, vk, db, _ } = util;
    let { uid } = data;
    let res = { code: 0, msg: '' };
    // 业务逻辑开始-----------------------------------------------------------
    let money = 1; // 每次抢红包的金额

    res.num = await vk.baseDao.update({
      dbName: 'vk-test', // 红包测试表
      whereJson: {
        _id: _id, // 红包id,
        money: _.gte(money), // 判断当前红包金额必须>=要扣除的金额
        receive_uid: _.nin([uid]), // 只有我没领过才可以领
      },
      dataJson: {
        money: _.inc(money * -1), // 减当前红包金额
        receive_uid: _.push(uid), // 将当前登录用户的id写入该红包，防止重复领取
      },
    });
    // 利用update + where 形成数据库乐观锁达到控制高并发下不会扣成负数。
    if (res.num <= 0) {
      return { code: -1, msg: '未抢到红包，您已抢过或红包已抢完!' };
    }
    // 给用户加余额
    await vk.baseDao.update({
      dbName: 'vk-test-balance', // 用户余额测试表
      whereJson: {
        user_id: uid,
      },
      dataJson: {
        balance: _.inc(money), // 加抢到的当前红包金额
      },
    });
    res.msg = `恭喜,抢到了${money}元红包`;

    // 业务逻辑结束-----------------------------------------------------------
    return res;
  },
};