922 lines
30 KiB
TypeScript
922 lines
30 KiB
TypeScript
|
import PlayerMgr from "../object/PlayerMgr";
|
|||
|
|
import PaiHangMgr from "../core/PaiHangMgr";
|
|||
|
|
import { BattleType, EEventType, ERaceType, MsgCode } from "../role/EEnum";
|
|||
|
|
import DB from "../utils/DB";
|
|||
|
|
import * as schedule from "node-schedule";
|
|||
|
|
import SKLogger from "../gear/SKLogger";
|
|||
|
|
import Player from "../object/Player";
|
|||
|
|
import SKDataUtil from "../gear/SKDataUtil";
|
|||
|
|
import ActivityDefine from "./ActivityDefine";
|
|||
|
|
import GTimer from "../common/GTimer";
|
|||
|
|
import TeamMgr from "../core/TeamMgr";
|
|||
|
|
import Currency from "../activity/Currency";
|
|||
|
|
import NoticeMgr from "../core/NoticeMgr";
|
|||
|
|
import SpecialEffect from "../object/SpecialEffect";
|
|||
|
|
export default class TianTi {
|
|||
|
|
static shared = new TianTi();
|
|||
|
|
schedule: any;// 定时器：每天更新排行榜
|
|||
|
|
schedule2: any;// 定时器：每月结算奖励
|
|||
|
|
reportlist: any[];
|
|||
|
|
// 奖励列表
|
|||
|
|
JiangLiList: any[];
|
|||
|
|
/**限制击杀表 */
|
|||
|
|
limtlist: any[];
|
|||
|
|
|
|||
|
|
/**定时时间（毫秒单位） */
|
|||
|
|
state_time: any = {
|
|||
|
|
sign_time: 1000, // 通知完2分钟后开始报名
|
|||
|
|
sat_time: 60 * 60 * 1000 *5 // 巅峰对决（35分钟）
|
|||
|
|
}
|
|||
|
|
/**比赛阶段 */
|
|||
|
|
match_state: any = {
|
|||
|
|
|
|||
|
|
/** 备战-巅峰对决*/
|
|||
|
|
beizhantianti: 1, //
|
|||
|
|
/** 巅峰对决*/
|
|||
|
|
tiantizhan: 2 //
|
|||
|
|
}
|
|||
|
|
/**战斗状态 */
|
|||
|
|
FightState: any = {
|
|||
|
|
Wait: 1, // 等待
|
|||
|
|
FightEnd: 2, // 结束战斗
|
|||
|
|
Fighting: 3, // 等待状态
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**赛季 */
|
|||
|
|
season: number;
|
|||
|
|
/**参战队伍 报名加入 */
|
|||
|
|
match_team: any[];
|
|||
|
|
name: any;
|
|||
|
|
player_list: any;
|
|||
|
|
/** 天梯状态 */
|
|||
|
|
activity_state: any;
|
|||
|
|
/**通知时间 */
|
|||
|
|
inform_time: any;
|
|||
|
|
/**比赛阶段 */
|
|||
|
|
game_state: any;
|
|||
|
|
/**奖励 */
|
|||
|
|
goods_award: any[];
|
|||
|
|
/**定时匹配队伍 */
|
|||
|
|
matching_cancel: any;
|
|||
|
|
/**定时调整队伍 */
|
|||
|
|
adjust_cancel: any;
|
|||
|
|
|
|||
|
|
|
|||
|
|
constructor() {
|
|||
|
|
this.JiangLiList = [];//奖励列表
|
|||
|
|
this.reportlist = [];//天梯排行数据
|
|||
|
|
// this.goods_award = [50014, 50015, 10406, 10110, 10609, 10604, 50016, 95142, 50033];//奖励列表
|
|||
|
|
this.goods_award =[];
|
|||
|
|
this.limtlist = [];
|
|||
|
|
|
|||
|
|
|
|||
|
|
this.name = '天梯巅峰战';
|
|||
|
|
/**赛季 */
|
|||
|
|
this.season = 1;
|
|||
|
|
/**参数队伍 */
|
|||
|
|
this.match_team = [];
|
|||
|
|
this.player_list = {};
|
|||
|
|
this.game_state = 0;
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
OnNewDay() {
|
|||
|
|
this.limtlist = [];
|
|||
|
|
}
|
|||
|
|
init() {
|
|||
|
|
this.activity_state = ActivityDefine.activityState.Close;//天梯状态
|
|||
|
|
|
|||
|
|
|
|||
|
|
schedule.scheduleJob("0 0 12 ? * *", () => {
|
|||
|
|
//先更新排行数据
|
|||
|
|
this.reportlist = []; //先清空 //在读取
|
|||
|
|
let sql = `SELECT * FROM qy_tianti;`;
|
|||
|
|
DB.query(sql, (error: any, rows: any) => {
|
|||
|
|
if (error) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
for (let i = 0; i < rows.length; i++) {
|
|||
|
|
SKLogger.debug('开始读取天梯数据')
|
|||
|
|
this.reportlist.push({
|
|||
|
|
roleid: rows[i].roleid,
|
|||
|
|
resid: rows[i].resid,
|
|||
|
|
jifen: rows[i].jifen,
|
|||
|
|
name: rows[i].name,
|
|||
|
|
baichang: rows[i].baichang,
|
|||
|
|
shengchang: rows[i].shengchang,
|
|||
|
|
wingId: Number(rows[i].wingId),
|
|||
|
|
effid: rows[i].effid,
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
// 修改状态为准备报名
|
|||
|
|
this.open();
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
this.schedule2 = schedule.scheduleJob("50 59 23 L * ?", () => {
|
|||
|
|
// var date = new Date(2022,2,15,19,0,0);
|
|||
|
|
// this.schedule2 =schedule.scheduleJob(date, () => {
|
|||
|
|
this.reportlist = []; //先清空 //在读取
|
|||
|
|
let sql = `SELECT * FROM qy_tianti;`;
|
|||
|
|
// let sql = `DELETE FROM qy_tianti;`;
|
|||
|
|
DB.query(sql, (error: any, rows: any) => {
|
|||
|
|
if (error) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
for (let i = 0; i < rows.length; i++) {
|
|||
|
|
SKLogger.debug('开始发放天梯奖励')
|
|||
|
|
PlayerMgr.shared.getPlayerByRoleId(rows[i].roleid).addItem(70004, 1200 - (i * 200),true);
|
|||
|
|
let notice:any;
|
|||
|
|
notice.interval=5;
|
|||
|
|
notice.isgm = true
|
|||
|
|
notice.times=3;
|
|||
|
|
notice.type = 3;
|
|||
|
|
NoticeMgr.shared.addNewNotice(notice);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
sql = `DELETE FROM qy_tianti;`;
|
|||
|
|
DB.query(sql, (error: any, rows: any) => {
|
|||
|
|
if (error) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
this.reportlist = []; //先清空 //在读取
|
|||
|
|
let sql = `SELECT * FROM qy_tianti;`;
|
|||
|
|
DB.query(sql, (error: any, rows: any) => {
|
|||
|
|
if (error) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
for (let i = 0; i < rows.length; i++) {
|
|||
|
|
|
|||
|
|
this.reportlist.push({
|
|||
|
|
roleid: rows[i].roleid,
|
|||
|
|
resid: rows[i].resid,
|
|||
|
|
jifen: rows[i].jifen,
|
|||
|
|
name: rows[i].name,
|
|||
|
|
baichang: rows[i].baichang,
|
|||
|
|
shengchang: rows[i].shengchang,
|
|||
|
|
wingId: rows[i].wingId,
|
|||
|
|
effid: rows[i].effid,
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
SKLogger.debug('读取天梯数据成功！！')
|
|||
|
|
})
|
|||
|
|
//读取兑换奖励
|
|||
|
|
|
|||
|
|
this.JiangLiList = []; //先清空 //在读取
|
|||
|
|
sql = `SELECT * FROM prop_tiantijiangli;`;
|
|||
|
|
DB.query(sql, (error: any, rows: any) => {
|
|||
|
|
if (error) {
|
|||
|
|
SKLogger.debug('读取天梯奖励奖励失败')
|
|||
|
|
return;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
for (let i = 0; i < rows.length; i++) {
|
|||
|
|
|
|||
|
|
this.JiangLiList.push({
|
|||
|
|
id: rows[i].id,
|
|||
|
|
itemid: rows[i].itemid,
|
|||
|
|
price: rows[i].price,
|
|||
|
|
name: rows[i].name,
|
|||
|
|
des: rows[i].des,
|
|||
|
|
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
SKLogger.debug('读取天梯奖励数据成功！！===================================')
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
//读取掉落奖励
|
|||
|
|
this.goods_award = []; //先清空 //在读取
|
|||
|
|
sql = `SELECT * FROM qy_tianti_diaoluo;`;
|
|||
|
|
DB.query(sql, (error: any, rows: any) => {
|
|||
|
|
if (error) {
|
|||
|
|
SKLogger.debug('读取掉落奖励失败')
|
|||
|
|
return;
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
for (let i = 0; i < rows.length; i++) {
|
|||
|
|
|
|||
|
|
this.goods_award.push( rows[i].itemid);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
|
|||
|
|
// this.open();//测试直接开启
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 活动开始-报名
|
|||
|
|
*/
|
|||
|
|
open() {
|
|||
|
|
this.player_list = {};
|
|||
|
|
this.match_team = [];
|
|||
|
|
this.activity_state = ActivityDefine.activityState.Opening;//报名状态
|
|||
|
|
let msg = `${this.name}开启，请打开界面天梯巅峰战，进入决战地图匹配！`;
|
|||
|
|
PlayerMgr.shared.broadcast('s2c_notice', {
|
|||
|
|
strRichText: msg
|
|||
|
|
});
|
|||
|
|
PlayerMgr.shared.broadcast('s2c_game_chat', {
|
|||
|
|
scale: 3,
|
|||
|
|
msg: msg,
|
|||
|
|
name: '',
|
|||
|
|
resid: 0,
|
|||
|
|
teamid: 0,
|
|||
|
|
});
|
|||
|
|
this.inform_time = GTimer.getTime();
|
|||
|
|
// 开始巅峰对决
|
|||
|
|
setTimeout(() => {
|
|||
|
|
this.inform_time = GTimer.getTime();
|
|||
|
|
this.SatPk();
|
|||
|
|
}, 5 * 1000);
|
|||
|
|
SKLogger.info(`活动(${this.name})已经开启！${this.name}状态改变 当前状态：开始报名`);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 进入-巅峰对决
|
|||
|
|
*/
|
|||
|
|
SatPk() {
|
|||
|
|
|
|||
|
|
// 即将关闭活动定时
|
|||
|
|
setTimeout(() => {
|
|||
|
|
this.inform_time = GTimer.getTime();
|
|||
|
|
// 即将关闭（活动结束前两分钟通知）
|
|||
|
|
this.readyClose();
|
|||
|
|
}, this.state_time.sat_time - (2 * 60 * 1000));
|
|||
|
|
|
|||
|
|
// 关闭活动定时
|
|||
|
|
setTimeout(() => {
|
|||
|
|
this.inform_time = GTimer.getTime();
|
|||
|
|
// 活动结束-关闭
|
|||
|
|
this.close();
|
|||
|
|
}, this.state_time.sat_time);
|
|||
|
|
|
|||
|
|
// 通知队伍中玩家比赛状态-巅峰对决
|
|||
|
|
// for (const teamId in this.player_list) {
|
|||
|
|
// if (this.player_list.hasOwnProperty(teamId)) {
|
|||
|
|
// this.sayStage(TeamMgr.shared.getTeamInfo(teamId), this.match_state.sat, this.state_time.sat_time);
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// 开始比赛
|
|||
|
|
this.matching();
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 开始比赛
|
|||
|
|
*/
|
|||
|
|
matching() {
|
|||
|
|
SKLogger.info(`天梯状态改变 当前状态：开始比赛`);
|
|||
|
|
this.checkMatch(this.match_team);
|
|||
|
|
//'*'表示通配符，匹配任意，当秒是'*'时，表示任意秒数都触发，其它类推
|
|||
|
|
// 6个占位符从左到右分别代表：秒、分、时、日、月、周几
|
|||
|
|
this.matching_cancel = schedule.scheduleJob("0/10 * * * * ? ", () => {
|
|||
|
|
this.checkMatch(this.match_team);
|
|||
|
|
})
|
|||
|
|
this.adjust_cancel = schedule.scheduleJob("0/10 * * * * ? ", () => {
|
|||
|
|
this.checkFightTime();
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 战斗休息10秒
|
|||
|
|
*/
|
|||
|
|
checkFightTime() {
|
|||
|
|
let nowtime = Date.now();
|
|||
|
|
for (const teaminfo of this.match_team) {
|
|||
|
|
if (teaminfo.fight_state == this.FightState.FightEnd) {
|
|||
|
|
if (nowtime - teaminfo.fight_end_time > 10 * 1000) {
|
|||
|
|
teaminfo.fight_end_time = 0;
|
|||
|
|
teaminfo.fight_state = this.FightState.Wait;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 匹配队伍进行战斗
|
|||
|
|
*/
|
|||
|
|
checkMatch(match: any) {
|
|||
|
|
SKLogger.debug('匹配队伍进行战斗:' + match.length);
|
|||
|
|
if (match.length <= 1) {
|
|||
|
|
// this.close();
|
|||
|
|
return;
|
|||
|
|
} else {
|
|||
|
|
let peak_team_all: any = [];
|
|||
|
|
let peak_team: any = [];
|
|||
|
|
let num = Math.floor(match.length / 2);//判断队伍是否对战数量
|
|||
|
|
let flag = true;
|
|||
|
|
|
|||
|
|
for (let i = 0; i < num; i++) {
|
|||
|
|
let count = 0;
|
|||
|
|
while (flag) {
|
|||
|
|
if (peak_team.length < 2) {
|
|||
|
|
if (count >= 5) {
|
|||
|
|
flag = false;
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
count++;
|
|||
|
|
let ran = Math.floor(Math.random() * match.length);
|
|||
|
|
if (peak_team_all.indexOf(match[ran]) != -1 || match[ran].fight_state != this.FightState.Wait) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
peak_team.push(match[ran]);
|
|||
|
|
peak_team_all.push(match[ran]);
|
|||
|
|
} else {
|
|||
|
|
flag = false;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (peak_team.length >= 2) {
|
|||
|
|
if (peak_team[0].teamid != peak_team[1].teamid) {
|
|||
|
|
this.beforeFight(peak_team[0], peak_team[1]);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
peak_team = [];
|
|||
|
|
flag = true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 战斗开始之前的 10秒
|
|||
|
|
beforeFight(t1: any, t2: any) {
|
|||
|
|
let team = TeamMgr.shared.getTeamInfo(t1.teamid);
|
|||
|
|
let eteam = TeamMgr.shared.getTeamInfo(t2.teamid);
|
|||
|
|
if (team && eteam) {
|
|||
|
|
let selfTeam = [];
|
|||
|
|
for (let index = 0; index < team.playerlist.length; index++) {
|
|||
|
|
let member = team.playerlist[index];
|
|||
|
|
let satRole: any = {};
|
|||
|
|
satRole.onlyid = member.onlyid;
|
|||
|
|
satRole.roleid = member.roleid;
|
|||
|
|
satRole.resid = member.resid;
|
|||
|
|
satRole.level = member.level;
|
|||
|
|
satRole.name = member.name;
|
|||
|
|
selfTeam.push(satRole);
|
|||
|
|
if (this.hasLimt(satRole.onlyid)) {//存在记录
|
|||
|
|
for (let index = 0; index < this.limtlist.length; index++) {
|
|||
|
|
const lim = this.limtlist[index]; //限制
|
|||
|
|
if (lim.roleid == satRole.onlyid) {
|
|||
|
|
if (lim.num >= 10) {
|
|||
|
|
member.send('s2c_notice', {
|
|||
|
|
strRichText: '已达到最大匹配次数！'
|
|||
|
|
})
|
|||
|
|
// return;
|
|||
|
|
} else {
|
|||
|
|
lim.num++;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
} else {//没有记录
|
|||
|
|
let info: any = {};
|
|||
|
|
info.roleid = satRole.onlyid;
|
|||
|
|
info.num = 0;
|
|||
|
|
this.limtlist.push(info)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
let enemyTeam = [];
|
|||
|
|
for (let index = 0; index < eteam.playerlist.length; index++) {
|
|||
|
|
let member = eteam.playerlist[index];
|
|||
|
|
let satRole: any = {};
|
|||
|
|
satRole.onlyid = member.onlyid;
|
|||
|
|
satRole.roleid = member.roleid;
|
|||
|
|
satRole.resid = member.resid;
|
|||
|
|
satRole.level = member.level;
|
|||
|
|
satRole.name = member.name;
|
|||
|
|
enemyTeam.push(satRole);
|
|||
|
|
if (this.hasLimt(satRole.onlyid)) {//存在记录
|
|||
|
|
for (let index = 0; index < this.limtlist.length; index++) {
|
|||
|
|
const lim = this.limtlist[index]; //限制
|
|||
|
|
if (lim.roleid == satRole.onlyid) {
|
|||
|
|
if (lim.num >= 10) {
|
|||
|
|
member.send('s2c_notice', {
|
|||
|
|
strRichText: '已达到最大匹配次数！'
|
|||
|
|
})
|
|||
|
|
// return;
|
|||
|
|
} else {
|
|||
|
|
lim.num++;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
} else {//没有记录
|
|||
|
|
let info: any = {};
|
|||
|
|
info.roleid = satRole.onlyid;
|
|||
|
|
info.num = 0;
|
|||
|
|
this.limtlist.push(info)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
TeamMgr.shared.broadcast(t1.teamid, 's2c_tiantisat_match', {
|
|||
|
|
teamS: selfTeam,
|
|||
|
|
teamE: enemyTeam,
|
|||
|
|
});
|
|||
|
|
TeamMgr.shared.broadcast(t2.teamid, 's2c_tiantisat_match', {
|
|||
|
|
teamS: enemyTeam,
|
|||
|
|
teamE: selfTeam,
|
|||
|
|
});
|
|||
|
|
t1.fight_state = this.FightState.Fighting;
|
|||
|
|
t2.fight_state = this.FightState.Fighting;
|
|||
|
|
setTimeout(() => {
|
|||
|
|
this.startFight(t1, t2);
|
|||
|
|
}, 9 * 1000);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
hasLimt(roleid: any): boolean {
|
|||
|
|
for (let rid of this.limtlist) {
|
|||
|
|
if (rid.roleid == roleid) {
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 进入战斗
|
|||
|
|
* @param t1
|
|||
|
|
* @param t2
|
|||
|
|
*/
|
|||
|
|
startFight(t1: any, t2: any) {
|
|||
|
|
let team = TeamMgr.shared.getTeamInfo(t1.teamid);
|
|||
|
|
let eteam = TeamMgr.shared.getTeamInfo(t2.teamid);
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
delete this.player_list[t1.teamid];
|
|||
|
|
delete this.player_list[t2.teamid];
|
|||
|
|
for (let i = 0; i < this.match_team.length; i++) {
|
|||
|
|
let info: any = this.match_team[i];
|
|||
|
|
if (info.teamid != t1.teamid) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
this.match_team.splice(i, 1);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
for (let i = 0; i < this.match_team.length; i++) {
|
|||
|
|
let info: any = this.match_team[i];
|
|||
|
|
if (info.teamid != t2.teamid) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
this.match_team.splice(i, 1);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
if (team && eteam) {
|
|||
|
|
let eonlyid = eteam.leader.onlyid;
|
|||
|
|
team.leader.playerBattle(eonlyid, BattleType.TianTIFight);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 通知队伍中玩家比赛状态
|
|||
|
|
* @param team
|
|||
|
|
*/
|
|||
|
|
sayStage(team: any, type: number, countDown: number) {
|
|||
|
|
if (team != null) {
|
|||
|
|
countDown = countDown - (GTimer.getTime() - this.inform_time);
|
|||
|
|
for (let i = 0; i < team.playerlist.length; i++) {
|
|||
|
|
const mem = team.playerlist[i];
|
|||
|
|
// 通知前端改为巅峰
|
|||
|
|
if (type == this.match_state.prepare_sat) {
|
|||
|
|
let teamInfo = this.player_list[team.teamid];
|
|||
|
|
if (teamInfo) {
|
|||
|
|
mem.send('s2c_update_say_peak', {
|
|||
|
|
score: teamInfo.peak
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// 通知前端更改比赛状态
|
|||
|
|
mem.send('s2c_say_stage', {
|
|||
|
|
type: type,
|
|||
|
|
countDown: countDown,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 即将关闭活动进行通知
|
|||
|
|
*/
|
|||
|
|
readyClose() {
|
|||
|
|
this.activity_state = ActivityDefine.activityState.ReadyClose;
|
|||
|
|
// 关闭定时调整队伍
|
|||
|
|
this.adjust_cancel.cancel();
|
|||
|
|
// 关闭定时匹配队伍
|
|||
|
|
this.matching_cancel.cancel();
|
|||
|
|
let msg = `${this.name} 即将关闭，大家抓紧时间！`;
|
|||
|
|
PlayerMgr.shared.broadcast('s2c_notice', {
|
|||
|
|
strRichText: msg
|
|||
|
|
});
|
|||
|
|
PlayerMgr.shared.broadcast('s2c_game_chat', {
|
|||
|
|
scale: 3,
|
|||
|
|
msg: msg,
|
|||
|
|
name: '',
|
|||
|
|
resid: 0,
|
|||
|
|
teamid: 0,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 关闭活动
|
|||
|
|
*/
|
|||
|
|
close() {
|
|||
|
|
if (this.activity_state == ActivityDefine.activityState.Close) {
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
// 关闭定时调整队伍
|
|||
|
|
if (this.adjust_cancel != undefined && this.adjust_cancel != null) {
|
|||
|
|
this.adjust_cancel.cancel();
|
|||
|
|
}
|
|||
|
|
// 关闭定时匹配队伍
|
|||
|
|
if (this.matching_cancel != undefined && this.matching_cancel != null) {
|
|||
|
|
this.matching_cancel.cancel();
|
|||
|
|
}
|
|||
|
|
// 活动状态
|
|||
|
|
this.activity_state = ActivityDefine.activityState.Close;
|
|||
|
|
|
|||
|
|
// 清理在场队伍跳转长安
|
|||
|
|
for (const teamId in this.player_list) {
|
|||
|
|
if (this.player_list.hasOwnProperty(teamId)) {
|
|||
|
|
let team = this.player_list[teamId];
|
|||
|
|
this.leaveSat(PlayerMgr.shared.getPlayerByRoleId(team.pid), teamId);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// 清理数据
|
|||
|
|
this.match_team = [];
|
|||
|
|
this.player_list = {};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 请求离开天梯
|
|||
|
|
*/
|
|||
|
|
leaveSat(player: any, teamId: any) {
|
|||
|
|
if (player) {
|
|||
|
|
let team = this.player_list[teamId];
|
|||
|
|
if (team != null && team != undefined) {
|
|||
|
|
if (team.pid == player.roleid) {
|
|||
|
|
delete this.player_list[teamId];
|
|||
|
|
} else {
|
|||
|
|
player.send_notice("您不是队长不可以次操作！");
|
|||
|
|
player.send('s2c_leave_sat', {
|
|||
|
|
code: MsgCode.FAILED
|
|||
|
|
});
|
|||
|
|
return;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
for (let i = 0; i < this.match_team.length; i++) {
|
|||
|
|
let info: any = this.match_team[i];
|
|||
|
|
if (info.teamid != teamId) {
|
|||
|
|
continue;
|
|||
|
|
}
|
|||
|
|
this.match_team.splice(i, 1);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
// 通知当前队伍成员将证道大会标题取消显示
|
|||
|
|
// let team_list = TeamMgr.shared.getTeamInfo(teamId);
|
|||
|
|
// if (team_list) {
|
|||
|
|
// for (const member of team_list.playerlist) {
|
|||
|
|
// member.send('s2c_leave_sat', {
|
|||
|
|
// code: MsgCode.SUCCESS
|
|||
|
|
// });
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 获得匹配队伍
|
|||
|
|
* @param teamid
|
|||
|
|
*/
|
|||
|
|
getMatchTeamInfo(teamid: any): any {
|
|||
|
|
for (let teaminfo of this.match_team) {
|
|||
|
|
if (teaminfo.teamid == teamid) {
|
|||
|
|
return teaminfo;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 奖励
|
|||
|
|
* @param playid
|
|||
|
|
* @param isWin 1 胜利 0 失败
|
|||
|
|
*/
|
|||
|
|
sendReward(playid: any, isWin: any) {
|
|||
|
|
|
|||
|
|
let play = PlayerMgr.shared.getPlayerByOnlyId(playid);
|
|||
|
|
if (play) {
|
|||
|
|
// 获取队伍战斗分数（胜利 人数 * 10，失败 人数 * 5）
|
|||
|
|
let score = isWin == 1 ? 100 : 50;
|
|||
|
|
play.tianti_integral+=score;
|
|||
|
|
// 更新参数队伍的积分
|
|||
|
|
// let dataScore = this.updateMatchScore(isWin, score, teamId, type, team, teamInfo);
|
|||
|
|
// 获取随机道具
|
|||
|
|
let item = this.goods_award[Math.floor((Math.random() * this.goods_award.length))];
|
|||
|
|
let exp = play.level * 6000 + play.relive * 50000;
|
|||
|
|
let pExp = Math.floor(exp * 1.2);
|
|||
|
|
play.addExp(exp);
|
|||
|
|
// 随机发送几个道具
|
|||
|
|
play.addItem(item, Math.floor(Math.random() * 3) + 1, false, "天梯奖励！")
|
|||
|
|
play.curPet && (play.curPet.addExp(pExp));
|
|||
|
|
// 天梯积分积分
|
|||
|
|
play.tianti_integral += score;
|
|||
|
|
|
|||
|
|
let baichang = isWin == 1 ? 0 : 1;;
|
|||
|
|
let shengchang = isWin == 1 ? 1 : 0;
|
|||
|
|
for (const key in this.reportlist) {
|
|||
|
|
if (Object.prototype.hasOwnProperty.call(this.reportlist, key)) {
|
|||
|
|
const element = this.reportlist[key];
|
|||
|
|
if (element.roleid == play.roleid) {
|
|||
|
|
let effid = SpecialEffect.shared.getSuiEffect(play.roleid);
|
|||
|
|
element.jifen += score;
|
|||
|
|
baichang = element.baichang += baichang;
|
|||
|
|
element.baichang = baichang;
|
|||
|
|
shengchang = element.shengchang += shengchang;
|
|||
|
|
element.shengchang = shengchang;
|
|||
|
|
element.wingId = play.wingId,
|
|||
|
|
element.effid = effid
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//更新数据库
|
|||
|
|
let effid = SpecialEffect.shared.getSuiEffect(play.roleid);
|
|||
|
|
DB.tiantidata(play, play.tianti_integral, baichang, shengchang, effid, () => {
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
// 通知前端更新积分信息
|
|||
|
|
play.send('s2c_match_battles', {
|
|||
|
|
type: 3, // 1 元魔 0 证道
|
|||
|
|
isWin: isWin, // 1 胜利 0 失败
|
|||
|
|
icon: item, // 图标
|
|||
|
|
exp: exp, // 人物经验
|
|||
|
|
petExp: pExp, // 宠物经验
|
|||
|
|
score: score, // 当前获得分数
|
|||
|
|
peak: 0, // 当前巅峰积分
|
|||
|
|
satScore: 0, // 队伍证道积分
|
|||
|
|
matchScore: 0 // 队伍元魔积分
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
// 巅峰对决（巅峰积分小于等于0清理出场）
|
|||
|
|
// if (type == 0 && isWin == 0) {
|
|||
|
|
// let info = this.player_list[teamId];
|
|||
|
|
// if (info.peak <= 0) {
|
|||
|
|
// for (const member of team.playerlist) {
|
|||
|
|
// member.send_notice("由于你所在队伍的巅峰积分不足,失去继续比赛资格！")
|
|||
|
|
// }
|
|||
|
|
// this.leaveSat(PlayerMgr.shared.getPlayerByRoleId(info.pid), teamId);
|
|||
|
|
// // 当前队伍小于2个队伍直接结束活动
|
|||
|
|
// let count_player: number = Object.keys(this.player_list).length
|
|||
|
|
// if (count_player <= 1) {
|
|||
|
|
// this.close();
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 更新参数队伍的积分
|
|||
|
|
* @param isWin 1 胜利 0 失败
|
|||
|
|
* @param score 分数
|
|||
|
|
* @param teamId 队伍ID
|
|||
|
|
* @param type 1：元魔 0：证道
|
|||
|
|
*/
|
|||
|
|
updateMatchScore(isWin: number, score: number, teamId: any, type: number, team: any, player_team: any): any {
|
|||
|
|
let data: any = {};
|
|||
|
|
if (type == 1) {
|
|||
|
|
player_team.magic_score += score;
|
|||
|
|
} else {
|
|||
|
|
player_team.sat_score += score;
|
|||
|
|
if (isWin == 1) {
|
|||
|
|
player_team.peak += 50;
|
|||
|
|
} else {
|
|||
|
|
player_team.peak -= 50;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
// 巅峰积分
|
|||
|
|
data.peak = player_team.peak;
|
|||
|
|
// 元魔积分
|
|||
|
|
data.satScore = player_team.sat_score;
|
|||
|
|
// 证道积分
|
|||
|
|
data.matchScore = player_team.magic_score;
|
|||
|
|
|
|||
|
|
|
|||
|
|
// 更新 队伍积分状态集合
|
|||
|
|
this.player_list[teamId] = {
|
|||
|
|
name: team.leader.name + '的队伍',
|
|||
|
|
pid: team.leader.roleid, // 队长角色编号
|
|||
|
|
teamid: teamId, // 队伍编号
|
|||
|
|
magic_score: data.matchScore, // 元魔积分
|
|||
|
|
sat_score: data.satScore, // 证道积分
|
|||
|
|
peak: data.peak, // 队伍巅峰积分
|
|||
|
|
num: team.playerlist.length, // 队伍人数
|
|||
|
|
}
|
|||
|
|
return data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
//获取天梯数据
|
|||
|
|
getTianTidata(player: any, type: any) {
|
|||
|
|
|
|||
|
|
let report = [];
|
|||
|
|
let selfjifen = 0;
|
|||
|
|
let selfpaiming = 0;
|
|||
|
|
let shengchang = 0;
|
|||
|
|
let baichang = 0;
|
|||
|
|
for (let i = 0; i < this.reportlist.length; i++) {
|
|||
|
|
let items = this.reportlist[i];
|
|||
|
|
report.push({
|
|||
|
|
roleid: items.roleid,
|
|||
|
|
resid: items.resid,
|
|||
|
|
jifen: items.jifen,
|
|||
|
|
name: items.name,
|
|||
|
|
baichang: items.baichang,
|
|||
|
|
shengchang: items.shengchang,
|
|||
|
|
wingId: Number(items.wingId),
|
|||
|
|
effid: items.effid
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
report.sort((a, b) => { return b.jifen - a.jifen });//排序
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
for (const key in report) {
|
|||
|
|
if (Object.prototype.hasOwnProperty.call(report, key)) {
|
|||
|
|
const element = report[key];
|
|||
|
|
if (element.roleid == player.roleid) {
|
|||
|
|
selfjifen = element.jifen;
|
|||
|
|
selfpaiming = Number(key) + 1;
|
|||
|
|
shengchang = element.shengchang;
|
|||
|
|
baichang = element.baichang;
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
report.sort((a, b) => {
|
|||
|
|
return a.jifen < b.jifen ? 1 : -1;
|
|||
|
|
});
|
|||
|
|
let frist = report.splice(0, 6);
|
|||
|
|
|
|||
|
|
// 数据发送前端
|
|||
|
|
player.send('s2c_TianTi_info', {
|
|||
|
|
selfjifen: selfjifen,
|
|||
|
|
selfpaiming: selfpaiming,
|
|||
|
|
shengchang: shengchang,
|
|||
|
|
baichang: baichang,
|
|||
|
|
tiantijizhenshifen:player.tianti_integral,
|
|||
|
|
list: SKDataUtil.toJson(frist, "{}")
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//获取天梯奖励数据
|
|||
|
|
getJiangLidata(player: any) {
|
|||
|
|
SKLogger.debug('获取天梯奖励数据')
|
|||
|
|
// 数据发送前端
|
|||
|
|
let report = [];
|
|||
|
|
for (let i = 0; i < this.JiangLiList.length; i++) {
|
|||
|
|
let items = this.JiangLiList[i];
|
|||
|
|
report.push({
|
|||
|
|
id: items.id,
|
|||
|
|
itemid: items.itemid,
|
|||
|
|
price: items.price,
|
|||
|
|
name: items.name,
|
|||
|
|
des: items.des,
|
|||
|
|
|
|||
|
|
})
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
// 数据发送前端
|
|||
|
|
player.send('s2c_TianTijiangli_info', {
|
|||
|
|
jiangli: SKDataUtil.toJson(this.JiangLiList, "{}"),
|
|||
|
|
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
report() {
|
|||
|
|
let callback = (ret: any, rows: any) => {
|
|||
|
|
if (ret == MsgCode.SUCCESS) {
|
|||
|
|
for (let i = 0; i < rows.length; i++) {
|
|||
|
|
this.reportlist.push({
|
|||
|
|
sroleid: rows[i].sroleid,
|
|||
|
|
eresid: rows[i].eresid,
|
|||
|
|
eroleid: rows[i].eroleid,
|
|||
|
|
erolename: rows[i].erolename,
|
|||
|
|
iswin: rows[i].iswin,
|
|||
|
|
ranking: rows[i].ranking,
|
|||
|
|
cdate: rows[i].cdate
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
DB.selectReport(callback);
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 天梯巅峰战：玩家报名
|
|||
|
|
*/
|
|||
|
|
playerSign(player: any) {
|
|||
|
|
// 天梯没有开启
|
|||
|
|
if (this.activity_state == ActivityDefine.activityState.Close) {
|
|||
|
|
return MsgCode.TIANTI_NOT_OPEN;
|
|||
|
|
}
|
|||
|
|
// // 不在天梯报名时间
|
|||
|
|
// if (this.activity_state != ActivityDefine.activityState.ReadyOpen) {
|
|||
|
|
// return MsgCode.TIANTI_NOT_SIGN_TIME;
|
|||
|
|
// }
|
|||
|
|
let team = TeamMgr.shared.getTeamInfo(player.teamid);
|
|||
|
|
// // 天梯必须3人以上组队参加
|
|||
|
|
// if (team == null || team.playerlist.length < 3) {
|
|||
|
|
// return MsgCode.TIANTI_SIGN_TEAM;
|
|||
|
|
// }
|
|||
|
|
// // 天梯必须3人以上组队参加
|
|||
|
|
// for (let i = 0; i < team.playerlist.length; i++) {
|
|||
|
|
// const mem = team.playerlist[i];
|
|||
|
|
// if (mem.level < 80) {
|
|||
|
|
// return MsgCode.TIANTI_SIGN_LEVEL_80;
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// 只能队长报名
|
|||
|
|
if (team.leader.roleid != player.roleid) {
|
|||
|
|
return MsgCode.SIGN_TEAM_LEADER;
|
|||
|
|
}
|
|||
|
|
if (this.player_list[player.teamid] != null) {
|
|||
|
|
return MsgCode.SIGN_ALREADY;
|
|||
|
|
}
|
|||
|
|
SKLogger.debug('天梯报名成功')
|
|||
|
|
this.player_list[player.teamid] = {
|
|||
|
|
name: player.name + '的队伍',
|
|||
|
|
pid: player.roleid, // 队长角色编号
|
|||
|
|
teamid: player.teamid, // 队伍编号
|
|||
|
|
peak: 0, // 队伍巅峰积分\
|
|||
|
|
num: team.playerlist.length,// 队伍人数
|
|||
|
|
}
|
|||
|
|
// this.sayStage(team, this.match_state.beizhantianti, this.state_time.sign_time)
|
|||
|
|
this.matchTeam(team);
|
|||
|
|
return MsgCode.SUCCESS;
|
|||
|
|
}
|
|||
|
|
matchTeam(team: any) {
|
|||
|
|
let team_data: any = {};
|
|||
|
|
team_data.teamid = team.teamid; // 队伍编号
|
|||
|
|
team_data.wtime = 0;
|
|||
|
|
team_data.ltime = 0;
|
|||
|
|
team_data.fight_state = this.FightState.Wait;
|
|||
|
|
team_data.fight_end_time = 0;
|
|||
|
|
team_data.battle_index = 0;
|
|||
|
|
this.match_team.push(team_data);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**现金奖励 */
|
|||
|
|
starCurrency(battle: any, task_name: string) {
|
|||
|
|
if (battle != null && battle.campA != undefined) {
|
|||
|
|
for (let role of battle.campA.broles) {
|
|||
|
|
// 如果是玩家
|
|||
|
|
if (role.living_type == 1) {
|
|||
|
|
let player = PlayerMgr.shared.getPlayerByOnlyId(role.onlyid)
|
|||
|
|
if (player) {
|
|||
|
|
Currency.shared.obtain_currency(player, task_name)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|