✨ feat(活动): 七夕活动接口

2023-07-17 19:14:06 +08:00
parent 69abcb7c01
commit a726681d25
11 changed files with 399 additions and 1 deletions
@@ -0,0 +1,75 @@
+import BaseModel from './BaseModel';
+import { index, getModelForClass, prop, DocumentType } from '@typegoose/typegoose';
+
+/**
+  * 七夕雀巢
+*/
+
+export class QixiRecord {
+  @prop({ required: true })
+  todayIndex: number;				    // 今天index
+  @prop({ required: true })
+  gameCode: string;				    // 唯一挑战id
+  @prop({ required: true })
+  progress: number;				    // 到哪个进度
+  @prop({ required: true })
+  afterProgress: number;				    // 到哪个进度
+  @prop({ required: true })
+  time: Date;				            // 时间
+  @prop({ required: true })
+  rewards: string;				    // 奖励
+  @prop({ required: true })
+  hasPass: boolean;				    // 奖励
+}
+
+@index({ roleId: 1, activityId: 1 })
+
+export default class Activity_Qixi_Rec extends BaseModel {
+  @prop({ required: true })
+  serverId: number;				    // 服Id
+
+  @prop({ required: true })
+  activityId: number;				  // 活动Id
+
+  @prop({ required: true })
+  roundIndex: number;			  	// 第几轮
+
+  @prop({ required: true })
+  roleId: string;			        // 用户Id
+
+  @prop({ required: true })
+  buyCnt: number;			        // 购买次数
+
+  @prop({ required: true, type: QixiRecord, _id: false })
+  record: QixiRecord[];  // 记录
+
+  public static async findData(serverId: number, activityId: number, roundIndex: number, roleId: string) {
+    let result: ActivityQixiRecModelType = await ActivityQixiRecModel.findOne({ serverId, roleId, activityId, roundIndex }).lean();
+    return result;
+  }
+
+  public static async record(serverId: number, activityId: number, roundIndex: number, roleId: string, record: QixiRecord) {
+    let result: ActivityQixiRecModelType = await ActivityQixiRecModel.findOneAndUpdate({ serverId, roleId, activityId, roundIndex }, { $push: { record }, $setOnInsert: { buyCnt: 0 } }, { new: true, upsert: true }).lean();
+    return result;
+  }
+
+  public static async addProgress(serverId: number, activityId: number, roundIndex: number, roleId: string, gameCode: string, addProgress: number, time: Date) {
+    let result: ActivityQixiRecModelType = await ActivityQixiRecModel.findOneAndUpdate({ serverId, roleId, activityId, roundIndex, 'record.gameCode': gameCode }, { $inc: { 'record.$.afterProgress': addProgress }, $set: { 'record.$.time': time, 'record.$.hasPass': true } }, { new: true }).lean();
+    return result;
+  }
+
+  public static async recordReward(serverId: number, activityId: number, roundIndex: number, roleId: string, gameCode: string, rewards: string) {
+    let result: ActivityQixiRecModelType = await ActivityQixiRecModel.findOneAndUpdate({ serverId, roleId, activityId, roundIndex, 'record.gameCode': gameCode }, { $set: { 'record.$.rewards': rewards } }, { new: true }).lean();
+    return result;
+  }
+
+  public static async buyCnt(serverId: number, activityId: number, roundIndex: number, roleId: string, count: number) {
+    let result: ActivityQixiRecModelType = await ActivityQixiRecModel.findOneAndUpdate({ serverId, roleId, activityId, roundIndex }, { $inc: { buyCnt: count }, $setOnInsert: { record: [] } }, { new: true, upsert: true }).lean();
+    return result;
+  }
+}
+
+export const ActivityQixiRecModel = getModelForClass(Activity_Qixi_Rec);
+
+export interface ActivityQixiRecModelType extends Pick<DocumentType<Activity_Qixi_Rec>, keyof Activity_Qixi_Rec> { }
+export type ActivityQixiRecModelTypeParam = Partial<ActivityQixiRecModelType>; // 将所有字段变成可选项