228 lines
8.4 KiB
TypeScript
228 lines
8.4 KiB
TypeScript
import { BossInstanceType, BossInstanceModel } from '../db/BossInstance';
|
|
import { getZeroPoint } from '../pubUtils/timeUtil';
|
|
import { lockData } from '../services/redLockService';
|
|
import { findIndex } from 'underscore';
|
|
import { MailModel, MailType } from '../db/Mail';
|
|
import { sismemberAsync, smembersAsync, saddAsync, delAsync, getRoleOnlineInfo } from '../services/redisService';
|
|
import { pinus } from 'pinus';
|
|
import { STATUS } from '../consts/statusCode';
|
|
import { deepCopy, resResult } from '../pubUtils/util';
|
|
import { BattleRecordModel } from '../db/BattleRecord';
|
|
import { getArmyBossRank, gameData } from '../pubUtils/data';
|
|
import { getMailContent } from '../services/mailService';
|
|
import { pushMail } from '../pubUtils/interface';
|
|
import { MAIL_TYPE, AUCTION_SOURCE } from '../consts';
|
|
import { GUILD_BOSS_STATUS } from '../consts/constModules/guildConst';
|
|
import { genAuction } from './auctionService';
|
|
/**
|
|
* 获得boss界面
|
|
* @param bossInstance
|
|
* @param roleId
|
|
*/
|
|
export async function getBossInstanceInfo(bossInstance: BossInstanceType, roleId:string) {
|
|
let { warId, ranks, bossHp, bossLv, winWarId, winTime, roleIdRecords, guildCode, startTime, winBossLv } = bossInstance;
|
|
ranks.sort(function(a, b) {
|
|
return b.score - a.score + a.time - b.time;
|
|
});
|
|
let result:any = {};
|
|
if (!!winWarId && winTime > getZeroPoint() && roleIdRecords.indexOf(roleId) == -1) {
|
|
//今日通关过，且首次点开boss界面，提示某某boss已通关
|
|
result = { showParam: { winWarId, winBossLv } };
|
|
await BossInstanceModel.recordRoleIdWhenCheck(guildCode, roleId);
|
|
}
|
|
if ( bossHp <= 0 ) {
|
|
result = { warId };
|
|
if (startTime < getZeroPoint()) {
|
|
//今日未开启过boss，等待开启
|
|
result.status = GUILD_BOSS_STATUS.WAIT_OPEN;
|
|
return result;
|
|
} else {
|
|
//今日已开启，且boss通关
|
|
result.status = GUILD_BOSS_STATUS.OPENED;
|
|
return result;
|
|
}
|
|
}
|
|
let isBattled = false;
|
|
let myRank = {};
|
|
let lastRanks = ranks.map(({roleId: battleRoleId, score, time}, index) => {
|
|
if (roleId == battleRoleId) {
|
|
myRank = { roleId, score, rankLv: index + 1 };
|
|
if (time >= getZeroPoint())
|
|
isBattled = true;
|
|
}
|
|
return {roleId, score, rankLv: index + 1};
|
|
});
|
|
return { warId, ranks: lastRanks, myRank, bossHp, status: GUILD_BOSS_STATUS.OPEN, isBattled, bossLv };
|
|
}
|
|
/**
|
|
* 战斗结束返回
|
|
* @param bossInstance
|
|
* @param roleId
|
|
* @param battleNum
|
|
*/
|
|
export async function getBossInstanceWhenEnd(bossInstance: BossInstanceType, roleId:string, battleNum:number) {
|
|
let { warId, ranks, bossHp, winWarId, guildCode, recordRanks, winNum, bossLv, winBossLv } = bossInstance;
|
|
let pushRanks;
|
|
let result:any = {};
|
|
if (battleNum == winNum) { //检查当前战斗回调是否是上一次战斗的回调，若是返回上次排名的结果
|
|
pushRanks = deepCopy(recordRanks);
|
|
result = {warId: winWarId, bossHp: 0, bossLv: winBossLv, status: GUILD_BOSS_STATUS.OPEN};
|
|
await BossInstanceModel.recordRoleIdWhenCheck(guildCode, roleId);
|
|
} else {
|
|
pushRanks = deepCopy(ranks);
|
|
result = {warId, bossHp, bossLv, status: GUILD_BOSS_STATUS.OPEN};
|
|
}
|
|
pushRanks.sort(function(a, b) {
|
|
return b.score - a.score + a.time - b.time;
|
|
});
|
|
let isBattled = false;
|
|
let myRank = {};
|
|
pushRanks.forEach(({roleId: battleRoleId, score, time}, index) => {
|
|
if (roleId == battleRoleId) {
|
|
myRank = {roleId, score, rankLv: index + 1};
|
|
if (time >= getZeroPoint())
|
|
isBattled = true;
|
|
}
|
|
return {roleId, score, rankLv: index + 1};
|
|
});
|
|
result.myRank = myRank;
|
|
result.ranks = pushRanks;
|
|
result.isBattled = isBattled;
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* 结算战斗
|
|
* @param code
|
|
* @param serverId
|
|
* @param dataName
|
|
* @param damage
|
|
* @param roleId
|
|
*/
|
|
export async function bossResult(code: string, serverId: number, dataName: string, roleId: string, damage: number) {
|
|
let res:any = await lockData(serverId, dataName, code);//加锁
|
|
if (!!res.err)
|
|
return true;
|
|
let {winSettled, ranks, num, warId, bossHp, bossLv, code: bossCode } = await BossInstanceModel.findBossInstance(code);//锁定关卡信息
|
|
if (winSettled) {
|
|
res.releaseCallback();//解锁
|
|
await BossInstanceModel.recordRoleIdWhenCheck(code, roleId);
|
|
return true;
|
|
}
|
|
let index = findIndex(ranks, {roleId});
|
|
if (index == -1) {
|
|
res.releaseCallback();//解锁
|
|
return false;
|
|
}
|
|
ranks[index].score += bossHp;
|
|
if (bossHp > damage) {//检查造成的伤害是否会让boss死亡
|
|
res.releaseCallback();//解锁
|
|
return true;
|
|
}
|
|
let { recordRanks } = await BossInstanceModel.updateBossInstance(code, { bossHp: 0, winSettled: true, ranks, recordRanks: ranks, winNum: num, winWarId: warId, winBossLv: bossLv, roleIdRecords:[roleId]}, );
|
|
await pushBossHpMessage(code, serverId, 0, true);
|
|
res.releaseCallback();//数据修改解锁
|
|
recordRanks.sort(function(a, b) {
|
|
return b.score - a.score + a.time - b.time;
|
|
});
|
|
//下发邮件奖励
|
|
let mails = new Array<MailType>();
|
|
let pushMessage = new Array<pushMail>();
|
|
recordRanks.forEach(async function({ roleId }, index){
|
|
let rankLv = index + 1;
|
|
let goods = getArmyBossRankReward(rankLv);
|
|
if (!goods || !goods.length)
|
|
return;
|
|
await getMailContent(roleId, MAIL_TYPE.GUILD_BOSS_REWARD, [JSON.stringify(rankLv)], goods, mails, pushMessage);
|
|
});
|
|
await MailModel.addMails(mails);
|
|
pushMessage.forEach(({route, data, uids })=>{
|
|
pinus.app.channelService.pushMessageByUids(route, resResult(STATUS.SUCCESS, { mails: data }), uids);
|
|
});
|
|
// 加入拍卖行
|
|
let dicBossBase = gameData.bossBaseByBossLv.get(bossLv);
|
|
if(dicBossBase) {
|
|
await genAuction(code, AUCTION_SOURCE.BOSS, bossCode, serverId, dicBossBase.reward);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
/**
|
|
* 获得排名区间奖励
|
|
* @param rankLv
|
|
*/
|
|
export function getArmyBossRankReward(rankLv: number) {
|
|
let armybossRankReward = getArmyBossRank();
|
|
for (let item of armybossRankReward) {
|
|
if (item.rankMin <= rankLv && (rankLv <= item.rankMax || item.rankMax == -1)) {
|
|
return item.reward;
|
|
}
|
|
}
|
|
}
|
|
/**
|
|
* 将玩家加入到正在挑战boss队列中
|
|
* @param code
|
|
* @param serverId
|
|
* @param roleId
|
|
*/
|
|
export async function addBossInstance(code: string, serverId:number, roleId: string) {
|
|
let hisOnlineInfo = await getRoleOnlineInfo(roleId);
|
|
if(hisOnlineInfo.isOnline) {
|
|
let key = 'serverId_' + serverId + 'guildCode_' + code;
|
|
let value = roleId+ '|' + hisOnlineInfo.sid;
|
|
await saddAsync(key, [value]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 给当前正在挑战的玩家下发血量同步信息
|
|
* @param code
|
|
* @param serverId
|
|
* @param bossHp
|
|
* @param isDelKey
|
|
*/
|
|
export async function pushBossHpMessage(code: string, serverId:number, bossHp:number, isDelKey?: boolean ) {
|
|
let key = 'serverId_' + serverId + 'guildCode_' + code;
|
|
let members = await smembersAsync(key);
|
|
let uids = members.map(member=>{
|
|
let arr = member.split('|');
|
|
let uid = arr[0];
|
|
let sid = arr[1];
|
|
return {uid, sid};
|
|
});
|
|
pinus.app.channelService.pushMessageByUids('onBossHpUpdate', resResult(STATUS.SUCCESS, {bossHp}), uids);
|
|
if (isDelKey) {
|
|
delAsync(key);
|
|
}
|
|
}
|
|
/**
|
|
* 检查该玩家当前是否正在挑战boss的队列中
|
|
* @param code
|
|
* @param serverId
|
|
* @param roleId
|
|
* @param battleCode
|
|
*/
|
|
export async function checkBossBattleMemberExists(code: string, serverId:number, roleId: string, battleCode:string ) {
|
|
let hisOnlineInfo = await getRoleOnlineInfo(roleId);
|
|
let key = 'serverId_' + serverId + 'guildCode_' + code ;
|
|
let value = roleId+ '|' + hisOnlineInfo.sid;
|
|
let flag = await sismemberAsync(key, value);
|
|
if (!flag) {
|
|
const battleRecord = await BattleRecordModel.getBattleRecordByCode(battleCode, true);
|
|
if(!battleRecord || battleRecord.status != 0 || roleId != battleRecord.roleId) {
|
|
return false;
|
|
}
|
|
await addBossInstance(code, serverId, roleId);
|
|
flag = true;
|
|
}
|
|
return flag;
|
|
}
|
|
/**
|
|
* 成员退出，删除boss关排行信息
|
|
* @param guildCode
|
|
* @param roleId
|
|
*/
|
|
export async function removeBossRank(guildCode: string, roleId: string) {
|
|
await BossInstanceModel.removeBossRank(guildCode, roleId);
|
|
}
|