import BaseModel from './BaseModel'; import { index, getModelForClass, prop, DocumentType } from '@typegoose/typegoose'; import { genCode } from '../pubUtils/util'; import { PopShopItem } from '../domain/activityField/popUpShopField'; import { Reward } from '../domain/battleField/pvp'; export class PopUpShopItem { @prop({ required: true }) id: number; // 分档礼包id @prop({ required: true }) productID: string; // 商品id @prop({ required: true }) hasBoughtCnt: number = 0; // 已购买次数 @prop({ required: true, _id: false, type: Reward }) rewards: Reward[] = []; // 已购买次数 constructor(item: PopShopItem) { this.id = item.id; this.productID = item.productID; this.rewards = item.rewardInter; } } /** * 活动系统 - 弹出商店 */ @index({ roleId: 1 }) export default class Activity_Pop_Up_Shop extends BaseModel { @prop({ required: true }) serverId: number; // 服id @prop({ required: true }) activityId: number; // 活动Id @prop({ required: true }) roleId: string; // 用户Id @prop({ required: true }) beginTime: Date; // 开始时间 @prop({ required: true }) endTime: Date; // 结束时间 @prop({ required: true }) effectBeginTime: Date; // 刷新等生效开始时间 @prop({ required: true }) effectEndTime: Date; // 刷新等生效结束时间 @prop({ required: true }) id: number; // 礼包id @prop({ required: true }) code: string; // 本礼包本次推送的唯一code @prop({ required: true, type: PopUpShopItem, _id: false }) items: PopUpShopItem[]; // 礼包id @prop({ required: true }) hasBought: boolean; // 是否购买了 @prop({ required: true }) isLast: boolean; // 是否是最后一个 /** * 获取自然日内的次数 * @param roleId * @param beginTime * @param endTime */ public static async findAllEffectData(serverId: number, activityId: number, roleId: string) { let now = new Date(); let rec: ActivityPopUpShopModelType[] = await ActivityPopUpShopModel.find({ roleId, serverId, activityId, effectBeginTime: { $lte: now }, effectEndTime: { $gte: now } }).lean(); return rec; } public static async findAllLastData(serverId: number, activityId: number, roleId: string) { let rec: ActivityPopUpShopModelType[] = await ActivityPopUpShopModel.find({ roleId, serverId, activityId, isLast: true }).lean(); return rec; } public static async createRecord(param: ActivityPopUpShopModelTypeParam) { let { serverId, activityId, roleId, id,} = param; await ActivityPopUpShopModel.updateMany({ serverId, activityId, roleId, id, isLast: true }, { $set: { isLast: false } }); let code = genCode(8); let rec: ActivityPopUpShopModelType = await ActivityPopUpShopModel.findOneAndUpdate({ code }, { $set: {...param, hasBought: false, isLast: true } }, { new: true, upsert: true }).lean(); return rec; } public static async findByCode(serverId: number, activityId: number, roleId: string, code: string) { let rec: ActivityPopUpShopModelType = await ActivityPopUpShopModel.findOne({ serverId, activityId, roleId, code }).lean(); return rec; } public static async addRecord(serverId: number, activityId: number, roleId: string, code: string, productID: string) { let rec: ActivityPopUpShopModelType = await ActivityPopUpShopModel.findOneAndUpdate( { serverId, activityId, roleId, code, 'items.productID': productID }, { $set: { hasBought: true }, $inc: { 'items.$.hasBoughtCnt': 1 } }, { new: true} ).lean(); return rec; } public static async addRecordById(serverId: number, activityId: number, roleId: string, code: string, itemid: number) { let rec: ActivityPopUpShopModelType = await ActivityPopUpShopModel.findOneAndUpdate( { serverId, activityId, roleId, code, 'items.id': itemid }, { $set: { hasBought: true }, $inc: { 'items.$.hasBoughtCnt': 1 } }, { new: true} ).lean(); return rec; } } export const ActivityPopUpShopModel = getModelForClass(Activity_Pop_Up_Shop); export interface ActivityPopUpShopModelType extends Pick, keyof Activity_Pop_Up_Shop> { } export type ActivityPopUpShopModelTypeParam = Partial; // 将所有字段变成可选项