pvp数据

game-server/app/servers/battle/handler/pvpHandler.ts

@@ -9,13 +9,14 @@ import { SystemConfigModel } from '../../../db/SystemConfig'
 
 import { PvpDefenseModel, PvpDefenseType, OppPlayers } from '../../../db/PvpDefense';
 import { oppHeroesDefenseInter, pvpEndParamInter } from '../../../pubUtils/interface';
-import { PVP_HERO_POS, ROBOT_NAME } from '../../../consts';
+import { PVP_HERO_POS } from '../../../consts';
 
 import { HeroType, HeroModel } from '../../../db/Hero';
 import { CeAttrNumber } from '../../../db/generalField';
 import { checkBattleHeroesByHid } from '../../../services/normalBattleService';
 import { BattleRecordModel } from '../../../db/BattleRecord';
 import { PvpRecordModel, HeroesRecord } from '../../../db/PvpRecord';
+import { setPvpDefResult } from '../../../services/timeTaskService';
 export default function(app: Application) {
     return new PvpHandler(app);
 }
@@ -33,15 +34,17 @@ export class PvpHandler {
 
     async getData (msg: {}, session: BackendSession) {
         let roleId = session.get('roleId');
-        let {heroes, score, pLv, winStreakNum, oppPlayers: oppPlayerInfos, refOppCnt, challengeCnt, challengeRefTime, receivedBox, hisScore, heroScores, seasonNum: playerSeaSonNum} = await PvpDefenseModel.findByRoleIdIncludeAll(roleId);
-        let oppPlayers = getEnemies(oppPlayerInfos, winStreakNum);
+        let pvpDefense = await PvpDefenseModel.findByRoleIdIncludeAll(roleId);
+        let oppPlayers = getEnemies(pvpDefense.oppPlayers, pvpDefense.winStreakNum);
         let {warId, seasonNum, seasonEndTime} = await SystemConfigModel.findSystemConfig();
-        if (playerSeaSonNum !== seasonNum) {
+        let {heroes, score, pLv, winStreakNum, refOppCnt, challengeCnt, challengeRefTime, receivedBox, hisScore, heroScores} = pvpDefense;
+        if (pvpDefense.seasonNum !== seasonNum) {
             //TODO去结算
+            let {score, pLv, winStreakNum} = await setPvpDefResult(pvpDefense)
         }
         let myRank = 999;//TODO去redis中获取
         let data = {warId, seasonNum, seasonEndTime, myRank, oppPlayers, heroes, score, pLv, winStreakNum, refOppCnt, challengeCnt, challengeRefTime, receivedBox, hisScore, heroScores}
-        return resResult(STATUS.SUCCESS, { data: data });
+        return resResult(STATUS.SUCCESS, data);
     }
 
 
@@ -328,4 +331,6 @@ export class PvpHandler {
             return resResult(STATUS.SUCCESS, { data: { heroes: resHeroes } });
         }
     }
+
+
 }

game-server/app/services/timeTaskService.ts

@@ -7,7 +7,7 @@ import { SystemConfigModel } from '../db/SystemConfig';
 import PvpDefenseType,{ PvpDefenseModel } from '../db/PvpDefense';
 import { PVP } from '../pubUtils/dicParam';
 import { nowSeconds, getTodayZeroPoint } from '../pubUtils/timeUtil';
-import { getPvpGkWarIds } from '../pubUtils/data';
+import { getPvpGkWarIds, getPvpRankRewards, getPvpHeroRewards, getPLvByScore } from '../pubUtils/data';
 import { getRandomArr } from '../pubUtils/util';
 const _ = require('underscore');
 const PER_SECOND = 1 * 1000;
@@ -45,8 +45,25 @@ export async function setPvpSeasonResult(obj:{ name:string }) {
     await setNextPvpTime();
 }
 
-async function setPvpDefResult(pvpDefense: PvpDefenseType) {
-    await PvpDefenseModel.updateInfo(pvpDefense.roleId, {score:100, pLv: 1});
+export async function setPvpDefResult(pvpDefense: PvpDefenseType) {
+    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});
+    //TODO 下发邮件
+    return pvpDefense;
 }
 
 export async function resetPvpWarId() {
@@ -68,3 +85,11 @@ async function setNextPvpTime() {
     let settleTime = (seasonEndTime - SETTLE_DIFF)* PER_SECOND;
     scheduleJob(settleTime, setPvpSeasonResult);
 }
+
+function getScore(arr, score) {
+    for (let item of arr) {
+        if (item.max >= score && score < item.min) {
+            return item;
+        }
+    }
+}