96 lines
3.8 KiB
TypeScript
96 lines
3.8 KiB
TypeScript
/**
|
|
* 体力系统
|
|
*/
|
|
|
|
import { scheduleJob } from 'node-schedule';
|
|
import { SystemConfigModel } from '../db/SystemConfig';
|
|
import PvpDefenseType,{ PvpDefenseModel } from '../db/PvpDefense';
|
|
import { PVP } from '../pubUtils/dicParam';
|
|
import { nowSeconds, getTodayZeroPoint } from '../pubUtils/timeUtil';
|
|
import { getPvpGkWarIds, getPvpRankRewards, getPvpHeroRewards, getPLvByScore } from '../pubUtils/data';
|
|
import { getRandomArr } from '../pubUtils/util';
|
|
const _ = require('underscore');
|
|
const PER_SECOND = 1 * 1000;
|
|
const PER_DAY = 24 * 60 * 60;
|
|
const SETTLE_DIFF = 29 * 60;
|
|
const LIMIT_NUM = 1000;
|
|
export async function init() {
|
|
let seasonEndTime = 0;
|
|
let systemConfig = await SystemConfigModel.findSystemConfig();
|
|
if (!systemConfig) {
|
|
let warIds = getPvpGkWarIds();
|
|
let warId = warIds[0];//TODO随机地图
|
|
seasonEndTime = PVP.PVP_SEASON_DAYS * PER_DAY + getTodayZeroPoint();
|
|
systemConfig = await SystemConfigModel.createSystemConfig( seasonEndTime, warId );
|
|
} else {
|
|
seasonEndTime = systemConfig.seasonEndTime;
|
|
if (systemConfig.seasonEndTime - SETTLE_DIFF <= nowSeconds()) {
|
|
await setPvpSeasonResult({name: 'simpleJobExample' + systemConfig.seasonNum});
|
|
seasonEndTime = PVP.PVP_SEASON_DAYS * PER_DAY + getTodayZeroPoint();
|
|
systemConfig.seasonNum++;
|
|
await SystemConfigModel.updateSystemConfig({ seasonEndTime, seasonNum: systemConfig.seasonNum});
|
|
}
|
|
}
|
|
let settleTime = (seasonEndTime - SETTLE_DIFF)* PER_SECOND;
|
|
scheduleJob(settleTime, setPvpSeasonResult)
|
|
scheduleJob("0 0 0 * * 1", resetPvpWarId)
|
|
}
|
|
|
|
export async function setPvpSeasonResult(obj:{ name:string }) {
|
|
console.log('exce setPvpSeasonResult'+ obj.name);
|
|
let { seasonNum } = await setNextPvpTime();
|
|
let pvpDefenses = await PvpDefenseModel.getPvpDef(LIMIT_NUM);
|
|
for (let pvpDefense of pvpDefenses) {
|
|
await setPvpDefResult(pvpDefense, seasonNum);
|
|
}
|
|
}
|
|
|
|
export async function setPvpDefResult(pvpDefense: PvpDefenseType, seasonNum: number) {
|
|
let pvpRankRewards = getPvpRankRewards();
|
|
let pvpHeroRewards = getPvpHeroRewards();
|
|
let goods = [];
|
|
let rankLv = 0;//TODO 排行榜
|
|
let pvpRankReward = getScore(pvpRankRewards, rankLv);
|
|
goods = goods.concat(pvpRankReward.reward);
|
|
let score = 0
|
|
for (let i = 0; i < pvpDefense.heroScores.length; i++) {
|
|
let heroScore = pvpDefense.heroScores[i];
|
|
let pvpHeroReward = getScore(pvpHeroRewards, heroScore.score);
|
|
goods = goods.concat(pvpHeroReward.reward);
|
|
heroScore.score = pvpHeroReward.heroscore;
|
|
score += heroScore.score;
|
|
}
|
|
let pLv = getPLvByScore(score);
|
|
pvpDefense = await PvpDefenseModel.updateInfo(pvpDefense.roleId, {score:score, pLv, heroScores: pvpDefense.heroScores, winStreakNum:0, seasonNum, refOppCnt:0, challengeCnt:PVP.PVP_CHALLENGE_COUNTS, challengeRefTime:0});
|
|
//TODO 下发邮件
|
|
return pvpDefense;
|
|
}
|
|
|
|
export async function resetPvpWarId() {
|
|
console.log('resetPvpWarId');
|
|
let systemConfig = await SystemConfigModel.findSystemConfig();
|
|
let warIds = getPvpGkWarIds();
|
|
let index = _.indexOf(warIds, systemConfig.warId);
|
|
if (index != -1) {
|
|
warIds.splice(index, 1);
|
|
}
|
|
let res = getRandomArr(warIds, 1);
|
|
let warId = res[0];//TODO随机地图
|
|
await SystemConfigModel.updateSystemConfig({ warId });
|
|
}
|
|
|
|
async function setNextPvpTime() {
|
|
let seasonEndTime = PVP.PVP_SEASON_DAYS * PER_DAY + getTodayZeroPoint();
|
|
let systemConfig = await SystemConfigModel.updateSeason(seasonEndTime);
|
|
let settleTime = (seasonEndTime - SETTLE_DIFF)* PER_SECOND;
|
|
scheduleJob(settleTime, setPvpSeasonResult);
|
|
return systemConfig;
|
|
}
|
|
|
|
function getScore(arr, score) {
|
|
for (let item of arr) {
|
|
if (item.max >= score && score < item.min) {
|
|
return item;
|
|
}
|
|
}
|
|
} |