562 lines
25 KiB
TypeScript
562 lines
25 KiB
TypeScript
import { GVGTeamMem } from "../../domain/battleField/gvgBattle";
|
|
import { GVGLeagueModel, GVGLeagueType } from "../../db/GVGLeague";
|
|
import { GVGTeamModel, GVGTeamType, GVGTeamUpdate } from "../../db/GVGTeam";
|
|
import { GVGCityModel, GVGCityType } from "../../db/GVGCity";
|
|
import { gameData, getGVGBattleRankReward } from "../../pubUtils/data";
|
|
import { GVG_AREA_TYPE, GVG_BATTLE_RANK_TYPE, GVG_PERIOD, GVG_TECH_TYPE, MAIL_TYPE, PUSH_ROUTE, REDIS_KEY, STATUS } from "../../consts";
|
|
import { getTimeFun, nowSeconds } from "../../pubUtils/timeUtil";
|
|
import { DicGVGAreaPoint } from "../../pubUtils/dictionary/DicGVGAreaPoint";
|
|
import { getGVGBattleData, getGVGBattleMap } from "./gvgBattleMemory";
|
|
import { GVGAttackSpine, GVGCityMapInfo, GVGTeamInList, GVGTeamInListOnPoint, GVGTeamSpineInMap } from "../../domain/gvgField/returnData";
|
|
import { GVG } from "../../pubUtils/dicParam";
|
|
import { GVGHeroInfo, PvpEnemies, PvpHeroInfo } from "../../domain/dbGeneral";
|
|
import { getGroupKey, getGVGConfig } from "./gvgService";
|
|
import { GVGLeaguePrepareModel } from "../../db/GVGLeaguePrepare";
|
|
import { pinus } from "pinus";
|
|
import { dispatch } from "../../pubUtils/dispatcher";
|
|
import { Rank } from "../rankService";
|
|
import { LeagueRankInfo, RoleRankInfo } from "../../domain/rank";
|
|
import { findKeys, getAllServerName } from "../redisService";
|
|
import { sendMessageToGVGAreaByTeamWithSuc, sendMessageToGVGAreaWithSuc, sendMessageToGVGCityWithSuc } from "../pushService";
|
|
import { sendMailByContent, sendMailToLeagueByContent } from "../mailService";
|
|
import { GVGCityAreaPointModel } from "../../db/GVGCityAreaPoint";
|
|
import { addCityGuardMessage } from "./gvgRecService";
|
|
import { GVGUserDataModel } from "../../db/GVGUserData";
|
|
import { RoleModel } from "../../db/Role";
|
|
import { getFightTimeByPeriod } from "./gvgFightService";
|
|
|
|
/**
|
|
* 获取本联军上周占领的城池
|
|
* @param league
|
|
* @returns number[] 城池id
|
|
*/
|
|
export async function getGVGCities(league: GVGLeagueType) {
|
|
let { configId } = getGVGConfig();
|
|
let cities = await GVGCityModel.findGuardCityByLeague(configId, league.leagueCode, 'cityId');
|
|
return cities.map(city => city.cityId);
|
|
}
|
|
|
|
/**
|
|
* 获取当前城池状态
|
|
* @returns [{cityId: number, guardLeagueCode: string, guardLeagueName: string, teamCnt: number }]
|
|
*/
|
|
export async function getGVGCitiesInfo(configId: number, groupKey: string, league?: GVGLeagueType) {
|
|
let cities = await GVGCityModel.findGuardCity(configId, groupKey);
|
|
let result: GVGCityMapInfo[] = [];
|
|
for(let city of cities) {
|
|
let obj = new GVGCityMapInfo(city);
|
|
if(league) {
|
|
let players = (city.players||[]).filter(cur => cur.leagueCode == league.leagueCode);
|
|
obj.setTeamCnt(players.length);
|
|
let r = new Rank(REDIS_KEY.GVG_BATTLE_LEAGUE_RANK_BY_CITY, { configId, groupKey, cityId: city.cityId });
|
|
let score = await r.getMyScore({ leagueCode: league.leagueCode });
|
|
obj.setScore(score||0);
|
|
}
|
|
result.push(obj);
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* 获取内存中队伍的数据结构
|
|
*/
|
|
export function getGVGTeamMemInfo(team: GVGTeamType): GVGTeamMem {
|
|
const teamMem = new GVGTeamMem(team);
|
|
teamMem.isMoving = false;
|
|
teamMem.startMoveTime = 0;
|
|
teamMem.stopMoveTime = 0;
|
|
return teamMem;
|
|
}
|
|
|
|
/**
|
|
* 获取 重新进入城池/复活 所在的区域
|
|
* @param city GVGCity
|
|
* @param leagueCode 联军id
|
|
* @returns
|
|
*/
|
|
export function getBirthAreaOfCity(city: GVGCityType, leagueCode: string) {
|
|
let isGuard = city.guardLeague == leagueCode;
|
|
let dicGVGCity = gameData.gvgCity.get(city.cityId);
|
|
return isGuard? dicGVGCity.defenseBirth: dicGVGCity.attackBirth;
|
|
}
|
|
|
|
/**
|
|
* 玩家是否可以进入城池
|
|
* @param city
|
|
* @param leagueCode
|
|
* @returns
|
|
*/
|
|
export function checkEnterCityTime(city: GVGCityType, leagueCode: string) {
|
|
let isGuard = city?.guardLeague == leagueCode;
|
|
let { startFightTime, endFightTime } = getFightTimeByPeriod(GVG_PERIOD.BATTLE);
|
|
if(isGuard && startFightTime - GVG.GVG_GUARD_START_TIME > nowSeconds()) return false;
|
|
if(!isGuard && startFightTime > nowSeconds()) return false;
|
|
if(endFightTime < nowSeconds()) return false;
|
|
return true
|
|
}
|
|
|
|
// guild.gvgBattleHandler.startMove 检测
|
|
export function checkMoveStatus(team: GVGTeamType, cityId: number, areaId: number) {
|
|
if(!team) return STATUS.GVG_BATTLE_TEAM_NOT_FOUND;
|
|
if(team.cityId != cityId) return STATUS.GVG_BATTLE_IS_NOT_IN_CITY;
|
|
if(team.pointId > 0) return STATUS.GVG_BATTLE_TEAM_IS_SELLTED;
|
|
if(team.stopMoveTime > nowSeconds()) return STATUS.GVG_BATTLE_IS_MOVING;
|
|
if(team.moveCdTime > nowSeconds()) return STATUS.GVG_BATTLE_IS_MOVING_CD;
|
|
let dicArea = gameData.gvgArea.get(areaId);
|
|
if(!dicArea) return STATUS.DIC_DATA_NOT_FOUND;
|
|
if(dicArea.relateArea.indexOf(team.areaId) == -1) return STATUS.GVG_BATTLE_AREA_NOT_RELATE;
|
|
return STATUS.SUCCESS;
|
|
}
|
|
|
|
export async function initRobots(configId: number, groupKey: string, city: GVGCityType | { cityId: number, guardLeague: string }) {
|
|
let { cityId, guardLeague = '' } = city;
|
|
if(guardLeague) return [];
|
|
let robotTeams = await GVGTeamModel.findRobotTeams(groupKey, cityId);
|
|
let updateDicPoints: DicGVGAreaPoint[] = [];
|
|
let { areaIds = []} = gameData.gvgCity.get(cityId);
|
|
for(let [_, point] of gameData.gvgAreaPoint) {
|
|
if(areaIds.indexOf(point.areaId) == -1) continue;
|
|
let robotTeam = robotTeams.find(team => team.pointId == point.pointId);
|
|
if(!robotTeam || (!robotTeam.isBroken && robotTeam.configId != configId) ) {
|
|
updateDicPoints.push(point);
|
|
}
|
|
}
|
|
if(updateDicPoints.length > 0) {
|
|
let lv = gameData.war.get(GVG.GVG_ROBOT_WARJSON)?.level||50;
|
|
robotTeams = await GVGTeamModel.initRobots(configId, groupKey, cityId, updateDicPoints, lv);
|
|
// 存入内存
|
|
let teamObj = getGVGBattleData(groupKey);
|
|
teamObj.enterCity(...robotTeams);
|
|
}
|
|
return robotTeams;
|
|
}
|
|
|
|
export function checkAreaIsInCity(cityId: number, areaIds: number[]) {
|
|
let dicCity = gameData.gvgCity.get(cityId);
|
|
if(!dicCity) return false;
|
|
for(let areaId of areaIds) {
|
|
if(dicCity.areaIds.indexOf(areaId) == -1) return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
export function calBattleScoreByCe(isSuccess: boolean, lineupCe: number) {
|
|
let winScore = Math.floor(lineupCe/GVG.GVG_BATTLE_SCORE);
|
|
if(winScore <= 0) winScore = 1;
|
|
return isSuccess? winScore: 0;
|
|
}
|
|
|
|
export async function refreshTeams(configId: number, groupKey: string, roleId: string, roleName: string, guildCode: string, myLeague: GVGLeagueType) {
|
|
let oldTeams = await GVGTeamModel.findByRole(roleId, '-_id');
|
|
let teams: GVGTeamType[] = [];
|
|
for(let team of oldTeams) {
|
|
if(team.configId != configId) {
|
|
let { teamCode, maxDurability } = team;
|
|
let { lv } = await RoleModel.findByRoleId(roleId, 'lv');
|
|
let newTeam = await GVGTeamModel.refreshByConfig(teamCode, { configId, lv, durability: maxDurability, cityId: 0, areaId: 0, pointId: 0, roleName, guildCode, leagueCode: myLeague.leagueCode, leagueName: myLeague.name, groupKey });
|
|
teams.push(newTeam);
|
|
} else {
|
|
teams.push(team);
|
|
}
|
|
}
|
|
return teams
|
|
}
|
|
|
|
/**
|
|
* 离开城池
|
|
* 当玩家占领据点的时候，可以保留据点；不占领的时候，不保留；退出游戏的时候，全不保留
|
|
* @param isForce 是否是玩家关闭游戏的那种离开
|
|
* @param roleId
|
|
* @param serverId
|
|
* @param guildCode
|
|
* @param myLeague
|
|
* @returns
|
|
*/
|
|
export async function leaveCity(isForce: boolean, roleId: string, serverId: number, guildCode: string, myLeague?: GVGLeagueType) {
|
|
if(!myLeague) myLeague = await GVGLeagueModel.findLeagueByGuild(guildCode);
|
|
if(!myLeague) return;
|
|
let groupKey = await getGroupKey(serverId);
|
|
let { configId } = getGVGConfig();
|
|
let teams = await GVGTeamModel.findByRole(roleId);
|
|
let hasPoint = !!teams.find(team => team.pointId > 0);
|
|
|
|
if(isForce || !hasPoint) {
|
|
await GVGTeamModel.leaveCity(roleId);
|
|
await GVGCityModel.decreasePlayer(configId, groupKey, roleId);
|
|
await GVGUserDataModel.changeCity(configId, myLeague.leagueCode, roleId, 0);
|
|
// 处理内存数据
|
|
let teamObj = getGVGBattleData(groupKey);
|
|
teamObj.leaveCity(roleId);
|
|
}
|
|
}
|
|
|
|
// 复活cd
|
|
export async function getTechReviveMinus(configId: number, leagueCode: string) {
|
|
let leaguePrepare = await GVGLeaguePrepareModel.findByLeague(configId, leagueCode);
|
|
let minusCd = 0;
|
|
let activeTech = leaguePrepare?.activeTech||[];
|
|
for(let techId of activeTech) {
|
|
let dicTech = gameData.gvgTech.get(techId);
|
|
if(dicTech && dicTech.type == GVG_TECH_TYPE.BATTLE_REVIVE_GAP) {
|
|
minusCd += dicTech.param[0];
|
|
}
|
|
}
|
|
let cd = GVG.GVG_DEFAULT_REVIVE_CD - minusCd;
|
|
if(cd < 0) cd = 0;
|
|
return cd;
|
|
}
|
|
|
|
// 诸葛连弩的伤害
|
|
export async function getTechKnifeHurt(configId: number, leagueCode: string) {
|
|
let leaguePrepare = await GVGLeaguePrepareModel.findByLeague(configId, leagueCode);
|
|
let hurt = 0;
|
|
let activeTech = leaguePrepare?.activeTech||[];
|
|
for(let techId of activeTech) {
|
|
let dicTech = gameData.gvgTech.get(techId);
|
|
if(dicTech && dicTech.type == GVG_TECH_TYPE.BATTLE_ITEM_KNIFE) {
|
|
if(dicTech.param[2] > hurt) hurt = dicTech.param[2];
|
|
}
|
|
}
|
|
return hurt
|
|
}
|
|
|
|
export function getGVGWarId(defenseTeam: GVGTeamType) {
|
|
if(!defenseTeam.isRobot) return GVG.GVG_CITY_BGMAP_GKID; // 玩家防守地图
|
|
if(!defenseTeam.isCatapult) return GVG.GVG_CATAPULT_WARJSON; // 投石车使用
|
|
return GVG.GVG_ROBOT_WARJSON; // 据点守卫使用
|
|
}
|
|
|
|
// guild.gvgBattleHandler.battleStart 里的heroes返回
|
|
export function getOppHeroes(warId: number, isRobot: boolean, lineup: GVGHeroInfo[]) {
|
|
let heroes: PvpEnemies[] = [];
|
|
const dicWar = gameData.war.get(warId);
|
|
if(!dicWar) { console.error(`warId ${warId} not found`); return [] }
|
|
const dicWarJson = gameData.warJson.get(dicWar.dispatchJsonId)||[];
|
|
for(let warJson of dicWarJson) {
|
|
if(!isRobot) {
|
|
let heroInfo = lineup.find(cur => cur.dataId == warJson.dataId);
|
|
if(!heroInfo) continue;
|
|
let hero = new PvpEnemies(warJson, heroInfo);
|
|
heroes.push(hero);
|
|
} else {
|
|
if(warJson.relation == 2) {
|
|
let dicHero = gameData.hero.get(warJson.actorId);
|
|
if(!dicHero) continue;
|
|
let heroInfo = new PvpHeroInfo();
|
|
heroInfo.setRobotInfo(dicHero, warJson.lv);
|
|
let hero = new PvpEnemies(warJson, heroInfo);
|
|
heroes.push(hero);
|
|
}
|
|
}
|
|
}
|
|
return heroes
|
|
}
|
|
|
|
// guild.gvgBattleHandler.battleStart 检测
|
|
export function checkGVGBattleStart(roleId: string, attackTeam: GVGTeamType, defenseTeam: GVGTeamType) {
|
|
|
|
if(!attackTeam || !defenseTeam) return STATUS.GVG_BATTLE_TEAM_INVALID;
|
|
if(attackTeam.roleId != roleId) return STATUS.GVG_TEAM_IS_NOT_MINE;
|
|
if(attackTeam.leagueCode == defenseTeam.leagueCode) return STATUS.GVG_SAME_LEAGUE_CANNOT_ATTACK;
|
|
if(attackTeam.areaId != defenseTeam.areaId) return STATUS.GVG_TEAM_NOT_SAME_AREA;
|
|
|
|
if(attackTeam.attackTime > nowSeconds()) return STATUS.GVG_TEAM_ATTACKING;
|
|
if(defenseTeam.defenseTime > nowSeconds() || defenseTeam.lockTime > nowSeconds()) return STATUS.GVG_TEAM_DEFENSEING;
|
|
if(attackTeam.durability <= 0) return STATUS.GVG_ATTACK_TEAM_BROKEN;
|
|
if(defenseTeam.durability <= 0) return STATUS.GVG_DEFENSE_TEAM_BROKEN;
|
|
|
|
return STATUS.SUCCESS;
|
|
}
|
|
|
|
// —————————— 定时器相关 —————————— //
|
|
// gvg激战期开始定时器
|
|
export async function gvgBattleStart() {
|
|
let servers = pinus.app.getServersByType('guild');
|
|
|
|
let { configId } = getGVGConfig();
|
|
let guardCities = await GVGCityModel.findAllGuardCities(configId);
|
|
for(let { cityId, groupKey, guardLeague, guardLeagueName } of guardCities) {
|
|
let sid = dispatch(cityId.toString(), servers)?.id;
|
|
await pinus.app.rpc.guild.guildRemote.initCatapult.toServer(sid, cityId, groupKey, guardLeague, guardLeagueName);
|
|
}
|
|
}
|
|
|
|
// 每次活动开始初始化投石车
|
|
export async function initCatapult(cityId: number, groupKey: string, leagueCode: string, leagueName: string) {
|
|
let { configId } = getGVGConfig();
|
|
|
|
let leaguePrepare = await GVGLeaguePrepareModel.findByLeague(configId, leagueCode);
|
|
let activeTech = leaguePrepare?.activeTech||[];
|
|
let hasCatapult = false, atk = 0, durability = 0;
|
|
for(let techId of activeTech) {
|
|
let dicTech = gameData.gvgTech.get(techId);
|
|
if(dicTech && dicTech.type == GVG_TECH_TYPE.BATTLE_ITEM_CATAPULT) {
|
|
hasCatapult = true, atk = dicTech.param[0]; durability = dicTech.param[1];
|
|
}
|
|
}
|
|
if(hasCatapult) {
|
|
let dicCity = gameData.gvgCity.get(cityId);
|
|
let areaIds = (dicCity?.areaIds||[]).filter(areaId => {
|
|
let dicArea = gameData.gvgArea.get(areaId);
|
|
return dicArea && dicArea.areaType == GVG_AREA_TYPE.CATAPULT;
|
|
});
|
|
|
|
let lv = gameData.war.get(GVG.GVG_CATAPULT_WARJSON)?.level||50;
|
|
let teams = await GVGTeamModel.initCatapult(configId, groupKey, cityId, leagueCode, leagueName, areaIds, atk, durability, lv);
|
|
// 处理内存
|
|
let teamObj = getGVGBattleData(groupKey);
|
|
teamObj.enterCity(...teams);
|
|
}
|
|
}
|
|
|
|
// 投石车投伤害
|
|
export async function catapultHurt() {
|
|
let { configId } = getGVGConfig();
|
|
for(let [_key, teamObj] of getGVGBattleMap()) {
|
|
let teams = teamObj.findCatapult();
|
|
for(let catapult of teams) {
|
|
if(catapult.isBroken) continue;
|
|
let dicArea = gameData.gvgArea.get(catapult.areaId);
|
|
let relateArea = dicArea?.relateArea||[];
|
|
let teamCodes = teamObj.findCatapultAttackTeam(relateArea, catapult.leagueCode);
|
|
let dicGVGCity = gameData.gvgCity.get(catapult.cityId);
|
|
let teams = await GVGTeamModel.attackByCatapult(teamCodes, catapult.captapultAtk, dicGVGCity.attackBirth);
|
|
teamObj.battleEnd(teams);
|
|
if(teams.length > 0) {
|
|
await sendMessageToGVGAreaByTeamWithSuc(teamObj.groupKey, catapult.areaId, PUSH_ROUTE.GVG_TEAM_ATTACKED, {
|
|
cityId: catapult.cityId, areaId: catapult.areaId, attackType: 1, teams: teams.map(team => new GVGTeamInList(team))
|
|
});
|
|
await sendMessageToGVGAreaWithSuc(teamObj.groupKey, catapult.areaId, PUSH_ROUTE.GVG_SPINE_ATTACKED, {
|
|
cityId: catapult.cityId, areaId: catapult.areaId, attackType: 1, teams: teams.map(team => new GVGAttackSpine(team, catapult.captapultAtk))
|
|
});
|
|
for(let team of teams) {
|
|
await pushTeamBeHurtMessage(team);
|
|
if(team.curTeamBreak && team.originPointId > 0) {
|
|
await GVGCityAreaPointModel.leavePoint(configId, teamObj.groupKey, team.originPointId);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// 战斗积分更新
|
|
export async function redisAddBattleScore(gvgTeam: GVGTeamType, incScore: number) {
|
|
let { configId, groupKey, cityId, roleId, isRobot } = gvgTeam;
|
|
if(isRobot) return;
|
|
let nextWeek = <number>getTimeFun().getAfterDayWithHour(7);
|
|
|
|
let r = new Rank(REDIS_KEY.GVG_BATTLE_RANK, { configId, groupKey, cityId });
|
|
await r.setExpire(nextWeek);
|
|
await r.setRankWithRoleInfo(roleId, incScore, Date.now(), null, true);
|
|
}
|
|
|
|
export async function redisAddSettleScore(gvgTeam: GVGTeamType, incScore: number) {
|
|
let { configId, groupKey, cityId, leagueCode, isRobot } = gvgTeam;
|
|
if(isRobot) return;
|
|
let nextWeek = <number>getTimeFun().getAfterDayWithHour(7);
|
|
|
|
let r1 = new Rank(REDIS_KEY.GVG_BATTLE_LEAGUE_RANK, { configId, groupKey });
|
|
await r1.setExpire(nextWeek);
|
|
await r1.setRankWithLeagueInfo(leagueCode, incScore, Date.now(), null, true);
|
|
|
|
let r2 = new Rank(REDIS_KEY.GVG_BATTLE_LEAGUE_RANK_BY_CITY, { configId, groupKey, cityId });
|
|
await r2.setExpire(nextWeek);
|
|
await r2.setRankWithLeagueInfo(leagueCode, incScore, Date.now(), null, true);
|
|
}
|
|
|
|
// 获取排行榜
|
|
export async function getBattleRanksByCity(configId: number, groupKey: string, cityId: number, myLeague?: GVGLeagueType) {
|
|
let teamObj = getGVGBattleData(groupKey);
|
|
let pointByLeague = teamObj.findSettledPointMapByLeague();
|
|
let r = new Rank(REDIS_KEY.GVG_BATTLE_LEAGUE_RANK_BY_CITY, { configId, groupKey, cityId });
|
|
r.setGenerFieldsFun((obj => {
|
|
if(obj instanceof LeagueRankInfo) {
|
|
let pointIds = pointByLeague.get(obj.code)||[];
|
|
let incScore = 0;
|
|
for(let pointId of pointIds) incScore += gameData.gvgAreaPoint.get(pointId)?.score||0;
|
|
return { rank: obj.rank, leagueCode: obj.code, leagueName: obj.name, score: obj.num, incScore }
|
|
}
|
|
return obj
|
|
}));
|
|
|
|
let { ranks, myRank } = await r.getRankListWithMyRank({ leagueCode: myLeague?.leagueCode });
|
|
if (myLeague && !myRank) {
|
|
myRank = await r.generMyRankWithLeague(myLeague.leagueCode, 0, 0, myLeague);
|
|
}
|
|
return { ranks, myRank }
|
|
}
|
|
|
|
// 每5秒一次结算
|
|
export async function gvgBattleSeconds() {
|
|
const { configId } = getGVGConfig();
|
|
const serverNames = await getAllServerName();
|
|
let keys: { groupKey: string, cityId: number }[] = []
|
|
for(let [_key, teamObj] of getGVGBattleMap()) {
|
|
// 每5秒给据点上的人加积分
|
|
let teams = teamObj.findSettledPoint();
|
|
for(let teamMem of teams) {
|
|
if(teamMem.isBroken || teamMem.durability <= 0) continue;
|
|
let addScore = gameData.gvgAreaPoint.get(teamMem.pointId)?.score||0;
|
|
let team = await GVGTeamModel.addScore(teamMem.teamCode, 0, addScore);
|
|
await redisAddSettleScore(team, addScore);
|
|
}
|
|
// 向下推送区域数据
|
|
let spinesByCity = new Map<number, GVGTeamSpineInMap[]>();
|
|
for(let areaId of teamObj.findAreas()) {
|
|
let dicArea = gameData.gvgArea.get(areaId);
|
|
let teams = teamObj.findTeamsByArea(areaId);
|
|
let spines = teams.map(team => new GVGTeamSpineInMap(team, serverNames));
|
|
if(!spinesByCity.has(dicArea.cityId)) spinesByCity.set(dicArea.cityId, []);
|
|
spinesByCity.get(dicArea.cityId).push(...spines);
|
|
let index = keys.findIndex(cur => cur.cityId == dicArea.cityId && cur.groupKey == teamObj.groupKey);
|
|
if(index == -1) keys.push({ groupKey: teamObj.groupKey, cityId: dicArea.cityId });
|
|
}
|
|
for(let [cityId, spines] of spinesByCity) {
|
|
await sendMessageToGVGCityWithSuc(teamObj.groupKey, cityId, PUSH_ROUTE.GVG_AREA_SPINE_CHANGE, { cityId, spines });
|
|
}
|
|
|
|
}
|
|
|
|
for(let { groupKey, cityId } of keys) {
|
|
let { ranks } = await getBattleRanksByCity(configId, groupKey, cityId);
|
|
await sendMessageToGVGCityWithSuc(groupKey, cityId, PUSH_ROUTE.GVG_CITY_RANK_UPDATE, { cityId, ranks });
|
|
}
|
|
|
|
}
|
|
|
|
export async function gvgBattleEnd() {
|
|
console.log('######### gvgBattleEnd #######')
|
|
let { configId } = getGVGConfig();
|
|
let guardLeagueCnt = new Map<string, number>();
|
|
|
|
// 城池占领情况
|
|
let keys = await findKeys(`${REDIS_KEY.GVG_BATTLE_LEAGUE_RANK_BY_CITY}:${configId}:`);
|
|
let rankKeys = keys.map(key => {
|
|
let [,, groupKey, _cityId] = key.split(':');
|
|
return { groupKey, cityId: parseInt(_cityId) };
|
|
}).sort((a, b) => b.cityId - a.cityId);
|
|
let lastCities = await GVGCityModel.findByConfig(configId);
|
|
for(let { cityId, groupKey } of lastCities) {
|
|
let hasKey = rankKeys.find(cur => cur.cityId == cityId && cur.groupKey == groupKey);
|
|
if(!hasKey) rankKeys.push({ cityId, groupKey });
|
|
}
|
|
|
|
for(let { groupKey, cityId } of rankKeys) {
|
|
let dicCity = gameData.gvgCity.get(cityId);
|
|
if(!dicCity) continue;
|
|
|
|
let r = new Rank(REDIS_KEY.GVG_BATTLE_LEAGUE_RANK_BY_CITY, { configId, groupKey, cityId });
|
|
let ranks = await r.getRankByRange();
|
|
// 排名最高占领城池
|
|
for(let obj of ranks) {
|
|
let rankInfo = <LeagueRankInfo>obj;
|
|
let cnt = guardLeagueCnt.get(rankInfo.code)||0;
|
|
if(cnt < GVG.GVG_CITY_OCCUPIED_NUMBER) {
|
|
await addGuardCity(configId, groupKey, cityId, rankInfo.code);
|
|
guardLeagueCnt.set(rankInfo.code, cnt + 1);
|
|
break;
|
|
}
|
|
}
|
|
|
|
let guardCity = lastCities.find(city => city.cityId == cityId && city.groupKey == groupKey);
|
|
if(guardCity) {
|
|
let cnt = guardLeagueCnt.get(guardCity.guardLeague)||0;
|
|
if(cnt < GVG.GVG_CITY_OCCUPIED_NUMBER) {
|
|
await addGuardCity(configId, groupKey, cityId, guardCity.guardLeague);
|
|
guardLeagueCnt.set(guardCity.guardLeague, cnt + 1);
|
|
}
|
|
}
|
|
}
|
|
for(let { cityId, groupKey, guardLeague } of lastCities) {
|
|
let hasKey = rankKeys.find(cur => cur.cityId == cityId && cur.groupKey == groupKey);
|
|
if(hasKey) continue;
|
|
await addGuardCity(configId, groupKey, cityId, guardLeague);
|
|
}
|
|
|
|
// 联军排行榜发放奖励
|
|
let leagueKeys = await findKeys(`${REDIS_KEY.GVG_BATTLE_LEAGUE_RANK}:${configId}:`);
|
|
for(let key of leagueKeys) {
|
|
let [,, groupKey] = key.split(':');
|
|
let r = new Rank(REDIS_KEY.GVG_BATTLE_LEAGUE_RANK, { configId, groupKey });
|
|
let ranks = await r.getRankByRange();
|
|
// 联军排行榜发放奖励
|
|
for(let _obj of ranks) {
|
|
let obj = <LeagueRankInfo>_obj;
|
|
let dicRank = getGVGBattleRankReward(GVG_BATTLE_RANK_TYPE.LEAGUE, obj.rank);
|
|
await sendMailToLeagueByContent(MAIL_TYPE.GVG_BATTLE_LEAGUE_RANK_REWARD, obj.code, { params: [`${obj.rank}`], goods: dicRank.reward });
|
|
}
|
|
}
|
|
|
|
// 个人排行榜发放奖励
|
|
let playerKeys = await findKeys(`${REDIS_KEY.GVG_BATTLE_RANK}:${configId}:`);
|
|
for(let key of playerKeys) {
|
|
let [,, groupKey] = key.split(':');
|
|
let r = new Rank(REDIS_KEY.GVG_BATTLE_RANK, { configId, groupKey });
|
|
let ranks = await r.getRankByRange();
|
|
|
|
for(let _obj of ranks) {
|
|
let obj = <RoleRankInfo>_obj;
|
|
let dicRank = getGVGBattleRankReward(GVG_BATTLE_RANK_TYPE.PLAYER, obj.rank);
|
|
await sendMailByContent(MAIL_TYPE.GVG_BATTLE_PLAYER_RANK_REWARD, obj.roleId, { params: [`${obj.rank}`], goods: dicRank.reward });
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
async function addGuardCity(configId: number, groupKey: string, cityId: number, leagueCode: string) {
|
|
let dicCity = gameData.gvgCity.get(cityId);
|
|
let dicCityAdd = gameData.gvgCityAdd.get(dicCity.cityType);
|
|
let league = await GVGLeagueModel.findByCodeWithoutPopulate(leagueCode);
|
|
await GVGCityModel.guardCity(configId, groupKey, cityId, league);
|
|
await sendMailToLeagueByContent(MAIL_TYPE.GVG_GUARD_CITY_REWARD, leagueCode, { params: [dicCity.cityName], goods: dicCityAdd.occupyReward }, league);
|
|
await addCityGuardMessage(league, cityId);
|
|
await GVGLeagueModel.removeAuto(leagueCode);
|
|
}
|
|
|
|
// —————————— 定时器相关 end —————————— //
|
|
|
|
// —————————— 推送相关 —————————— //
|
|
// 推送
|
|
export async function battleEndSendMessage(groupKey: string, cityId: number, defenseTeam: GVGTeamType, attackTeam: GVGTeamType) {
|
|
let areaId = defenseTeam.curTeamBreak? defenseTeam.fromAreaId: defenseTeam.areaId;
|
|
// 推送伤害
|
|
await sendMessageToGVGAreaByTeamWithSuc(groupKey, areaId, PUSH_ROUTE.GVG_TEAM_ATTACKED, {
|
|
cityId, areaId, attackType: 3, teams: [new GVGTeamInList(defenseTeam), new GVGTeamInList(attackTeam)]
|
|
});
|
|
await pushTeamBeHurtMessage(defenseTeam, attackTeam);
|
|
await pushTeamBeHurtMessage(attackTeam);
|
|
}
|
|
|
|
// 队伍移动
|
|
export async function pushTeamBeHurtMessage(team: GVGTeamType, replaceTeam?: GVGTeamType) {
|
|
|
|
if(team.curTeamBreak && team.originPointId > 0) {
|
|
await sendMessageToGVGAreaByTeamWithSuc(team.groupKey, team.fromAreaId, PUSH_ROUTE.GVG_AREA_POINT_CHANGE, {
|
|
cityId: team.cityId, areaId: team.fromAreaId, point: new GVGTeamInListOnPoint(team.originPointId, replaceTeam && !replaceTeam.curTeamBreak, replaceTeam)
|
|
});
|
|
}
|
|
|
|
await pushTeamMoveMessage(team);
|
|
if(team.isRobot && team.isBroken) {
|
|
await sendMessageToGVGAreaByTeamWithSuc(team.groupKey, team.fromAreaId, PUSH_ROUTE.GVG_PLAYER_LEAVE_AREA, {
|
|
cityId: team.cityId, areaId: team.fromAreaId, teamCode: team.teamCode
|
|
});
|
|
}
|
|
}
|
|
|
|
export async function pushTeamMoveMessage(team: GVGTeamType) {
|
|
if(team.fromAreaId != team.areaId) {
|
|
if(team.fromAreaId > 0) {
|
|
await sendMessageToGVGAreaByTeamWithSuc(team.groupKey, team.fromAreaId, PUSH_ROUTE.GVG_PLAYER_LEAVE_AREA, {
|
|
cityId: team.cityId, areaId: team.fromAreaId, teamCode: team.teamCode
|
|
});
|
|
}
|
|
if(team.areaId > 0) {
|
|
await sendMessageToGVGAreaByTeamWithSuc(team.groupKey, team.areaId, PUSH_ROUTE.GVG_PLAYER_AREA_ADD, {
|
|
cityId: team.cityId, areaId: team.fromAreaId, player: new GVGTeamInList(team)
|
|
});
|
|
}
|
|
}
|
|
}
|
|
// —————————— 推送相关 end —————————— //
|