// 每个农庄/每个田一条记录,这个田被其他人用了之后会覆盖 import BaseModel from './BaseModel'; import { index, getModelForClass, prop, DocumentType, } from '@typegoose/typegoose'; import { getFutureTime, nowSeconds } from '../pubUtils/timeUtil'; import { genCode } from '../pubUtils/util'; import { GVG } from '../pubUtils/dicParam'; @index({ leagueCode: 1, configId: 1 }) @index({ fieldId: 1 }) @index({ batchCode: 1 }) export default class GVGLeagueFarm extends BaseModel { @prop({ required: true }) leagueCode: string; // 联军唯一code @prop({ required: true }) configId: number; @prop({ required: true }) farmId: number; // 农庄id @prop({ required: true }) type: number; // 农庄类型 @prop({ required: true }) fieldId: number; // 农庄id @prop({ required: true }) unlockTime: number; // 解锁时间,农场:打开界面时预锁定一批填,种下去之后锁定时间延长到收获时间,林场&矿场:开始小游戏时锁定时间 @prop({ required: true }) lockRoleId: string; // 锁定的人 @prop({ required: true }) lockRoleName: string; @prop({ required: true }) harvestTime: number; // 收获时间,农庄:种植下去后将时间更新,收获之后设为0,林场&矿场:小游戏结束时更新 @prop({ required: true }) seedType: number; // 仅农庄使用,实际种的种子类型 @prop({ required: true }) addType: number; // 仅农庄使用,种子加成 @prop({ required: true }) batchCode: string; // 批量号 @prop({ required: true }) itemId: number; // 仅矿山使用,使用的铲子id @prop({ required: true }) output: number; // 产量,农庄:种下去时可以预估产量,林场&矿场:小游戏结束时根据结果更新 @prop({ required: true }) outputStr: string; // 产量计算公式 public static async findByType(configId: number, leagueCode: string, type: number) { const result: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ configId, leagueCode, type }).select('-_id').lean(); return result; } public static async findByFarmId(configId: number, leagueCode: string, farmId: number) { const result: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ configId, leagueCode, farmId }).select('-_id').lean(); return result; } public static async findLockedByFarmId(configId: number, leagueCode: string, farmId: number) { const result: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ configId, leagueCode, farmId, unlockTime: { $gte: nowSeconds() }}).select('-_id').lean(); return result; } public static async findPlantedByFarmId(configId: number, leagueCode: string, farmId: number) { const result: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ configId, leagueCode, farmId, unlockTime: { $gte: nowSeconds() }, harvestTime: { $gte: nowSeconds() }}).select('-_id').lean(); return result; } public static async findByFieldIds(configId: number, leagueCode: string, farmId: number, fieldIds: number[]) { const result: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ configId, leagueCode, farmId, fieldId: { $in: fieldIds } }).select('-_id').lean(); return result; } /** * 首次打开页面时锁定田 * @param configId * @param leagueCode * @param lands [{fieldId: number, time: number, addType: number}] fieldId:田地id, time: 锁定时间 addType: 种子加成 * @returns */ public static async lockFields(configId: number, leagueCode: string, farmId: number, roleId: string, roleName: string, lands: { fieldId: number, addType: number }[]) { // 先创建 await GVGLeagueFarmModel.bulkWrite(lands.map(({ fieldId }) => { return { updateOne: { filter: { configId, leagueCode, farmId, fieldId }, update: { $setOnInsert: { unlockTime: 0, harvestTime: 0, seedType: 0, addType: 0 } }, upsert: true} } })); const result = await GVGLeagueFarmModel.bulkWrite(lands.map(({ fieldId, addType }) => { return { updateOne: { filter: { configId, leagueCode, farmId, fieldId, $or:[{ unlockTime: { $lt: nowSeconds() }}, {lockRoleId: roleId, lockRoleName: roleName} ] }, update: { $set: { addType, unlockTime: nowSeconds() + GVG.GVG_FARM_LOCK_TIME, lockRoleId: roleId } } } } })); return result; } public static async findByFarmIdAndRoleId(configId: number, leagueCode: string, farmId: number, roleId: string) { const result: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ configId, leagueCode, farmId, lockRoleId: roleId, unlockTime: { $gte: nowSeconds() } }).sort({ fieldId: 1 }).select('-_id -createdAt -updatedAt -__v -leagueCode -configId -roleId').lean(); return result; } public static async plant(configId: number, leagueCode: string, farmId: number, fields: { fieldId: number, seedType: number, time: number, output: number, outputStr: string }[], roleId: string) { const batchCode = genCode(10); const result = await GVGLeagueFarmModel.bulkWrite(fields.map(({ fieldId, seedType, time, output, outputStr }) => { return { updateOne: { filter: { configId, leagueCode, farmId, fieldId, lockRoleId: roleId }, update: { $set: { seedType, unlockTime: getFutureTime(), harvestTime: nowSeconds() + time, batchCode, output, outputStr }} } } })); if(result.modifiedCount == 0) return []; const fieldResult: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ batchCode }).sort({ fieldId: 1 }).select('-_id -createdAt -updatedAt -__v -configId -leagueCode').lean(); return fieldResult; } public static async harvest(configId: number, leagueCode: string, farmId: number, fieldIds: number[], roleId: string) { const batchCode = genCode(10); const result = await GVGLeagueFarmModel.bulkWrite(fieldIds.map(fieldId => { return { updateOne: { filter: { configId, leagueCode, farmId, fieldId, lockRoleId: roleId, harvestTime: { $lt: nowSeconds() } }, update: { $set: { unlockTime: 0, harvestTime: 0, lockRoleId: '', lockRoleName: '', batchCode }} } } })); if(result.modifiedCount == 0) return []; const fieldResult: GVGLeagueFarmType[] = await GVGLeagueFarmModel.find({ batchCode }).sort({ fieldId: 1 }).select('-_id -createdAt -updatedAt -__v -configId -leagueCode').lean(); return fieldResult; } public static async helpHarvest(configId: number, leagueCode: string, farmId: number, fieldId: number) { const result: GVGLeagueFarmType = await GVGLeagueFarmModel.findOneAndUpdate( { configId, leagueCode, farmId, fieldId, harvestTime: { $lt: nowSeconds() }, unlockTime: { $gt: nowSeconds() } }, { $set: { unlockTime: 0, harvestTime: 0, lockRoleId: '', lockRoleName: '' }}, { new: true }).lean(); return result } public static async releaseLock(configId: number, leagueCode: string, farmId: number, roleId: string) { await GVGLeagueFarmModel.updateMany({ configId, leagueCode, farmId, lockRoleId: roleId }, { $set: { unlockTime: 0, lockRoleId: '', lockRoleName: '' } }); } public static async lockMineOrForestry(configId: number, leagueCode: string, farmId: number, type: number, roleId: string, fieldId: number, itemId: number) { // 先创建 await GVGLeagueFarmModel.findOneAndUpdate({ configId, leagueCode, farmId, fieldId }, { $setOnInsert: { unlockTime: 0, itemId: 0, type } }, { upsert: true }); const result: GVGLeagueFarmType = await GVGLeagueFarmModel.findOneAndUpdate( { configId, leagueCode, farmId, fieldId, $or:[{ unlockTime: { $lt: nowSeconds() } }, {lockRoleId: roleId}] }, { $set: { unlockTime: nowSeconds() + GVG.GVG_FARM_LOCK_TIME, lockRoleId: roleId, itemId } }, { new: true }).lean(); return result; } public static async findByField(configId: number, leagueCode: string, farmId: number, fieldId: number) { const result: GVGLeagueFarmType = await GVGLeagueFarmModel.findOne({ configId, leagueCode, farmId, fieldId }).lean(); return result; } public static async mineOrForestryEnd(configId: number, leagueCode: string, farmId: number, roleId: string, fieldId: number, output: number, outputStr: string) { const result: GVGLeagueFarmType = await GVGLeagueFarmModel.findOneAndUpdate( { configId, leagueCode, farmId, fieldId, lockRoleId: roleId,unlockTime: { $gte: nowSeconds() } }, { $set: { output, outputStr, unlockTime: getFutureTime(), harvestTime: nowSeconds() } }, { new: true }).lean(); return result; } } export const GVGLeagueFarmModel = getModelForClass(GVGLeagueFarm); export interface GVGLeagueFarmType extends Pick, keyof GVGLeagueFarm> { id: number; }; export type GVGLeagueFarmUpdate = Partial; // 将所有字段变成可选项