feat:黄旗酒馆
This commit is contained in:
parent
d2ed18117f
commit
7550fdf237
@ -19,7 +19,7 @@ export default async function (call: ApiCall<ReqZhaoMu, ResZhaoMu>) {
|
|||||||
let prize = [];
|
let prize = [];
|
||||||
let mydata = await HQJGFun.getMydata(call, call.req.hdid);
|
let mydata = await HQJGFun.getMydata(call, call.req.hdid);
|
||||||
|
|
||||||
for (let n = 0; n < call.req.num; n++) {
|
for (let n = 1; n <= call.req.num; n++) {
|
||||||
let num = mydata.zhaomu.num + n;
|
let num = mydata.zhaomu.num + n;
|
||||||
let baodi = hd.data.baodi.filter(x => x.num == num);
|
let baodi = hd.data.baodi.filter(x => x.num == num);
|
||||||
if (baodi.length > 0) {
|
if (baodi.length > 0) {
|
||||||
|
@ -214,10 +214,13 @@ export default class HQJGFun {
|
|||||||
/**
|
/**
|
||||||
* 每日伤害等级奖励结算
|
* 每日伤害等级奖励结算
|
||||||
*/
|
*/
|
||||||
static async dayDpsLvPrize() {
|
static async dayDpsLvPrize(time: number) {
|
||||||
|
console.log(
|
||||||
|
"黄旗酒馆 每日伤害等级奖励结算 开始执行。。。"
|
||||||
|
)
|
||||||
// 取stime小于当前时间的最后一条数据
|
// 取stime小于当前时间的最后一条数据
|
||||||
let hdinfo = await G.mongodb.collection("hdinfo").find({
|
let hdinfo = await G.mongodb.collection("hdinfo").find({
|
||||||
htype: this.htype, stime: { $lte: G.time }
|
htype: this.htype, stime: { $lte: time }
|
||||||
}, { sort: { stime: -1 } }).limit(1).toArray();
|
}, { sort: { stime: -1 } }).limit(1).toArray();
|
||||||
|
|
||||||
// 没有活动数
|
// 没有活动数
|
||||||
@ -227,6 +230,7 @@ export default class HQJGFun {
|
|||||||
|
|
||||||
let hd = hdinfo[0];
|
let hd = hdinfo[0];
|
||||||
let hdid = hdinfo[0].hdid;
|
let hdid = hdinfo[0].hdid;
|
||||||
|
// 活动结束
|
||||||
if (hd.etime < G.time - 300) {
|
if (hd.etime < G.time - 300) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -260,17 +264,26 @@ export default class HQJGFun {
|
|||||||
contentInsertArr: [lvprize.lv],
|
contentInsertArr: [lvprize.lv],
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
console.log(
|
||||||
|
"黄旗酒馆 每日伤害等级奖励结算 执行完成!!!"
|
||||||
|
)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 最大伤害排行奖励结算
|
* 最大伤害排行奖励结算
|
||||||
*/
|
*/
|
||||||
static async endDpsRankPrize() {
|
static async endDpsRankPrize(time: number) {
|
||||||
// 取stime小于当前时间的最后一条数据
|
console.log(
|
||||||
|
"黄旗酒馆 最大伤害排行奖励结算 开始执行。。。"
|
||||||
|
)
|
||||||
|
let today = PublicShared.getToDayZeroTime(time + 300);
|
||||||
|
let yesterday = PublicShared.getToDayZeroTime(time - 300);
|
||||||
|
|
||||||
|
// 查询昨天23:59:00或者今天00:00:00结束的活动
|
||||||
let hdinfo = await G.mongodb.collection("hdinfo").find({
|
let hdinfo = await G.mongodb.collection("hdinfo").find({
|
||||||
htype: this.htype, stime: { $lte: G.time }
|
htype: this.htype, rtime: { $gt: yesterday, $lte: today }
|
||||||
}, { sort: { stime: -1 } }).limit(1).toArray();
|
}).toArray();
|
||||||
|
|
||||||
// 没有活动数
|
// 没有活动数
|
||||||
if (hdinfo.length <= 0) {
|
if (hdinfo.length <= 0) {
|
||||||
@ -279,7 +292,7 @@ export default class HQJGFun {
|
|||||||
|
|
||||||
let hd = hdinfo[0];
|
let hd = hdinfo[0];
|
||||||
let hdid = hdinfo[0].hdid;
|
let hdid = hdinfo[0].hdid;
|
||||||
if (hd.etime < G.time - 300) {
|
if (hd.data.sendrank) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -306,5 +319,16 @@ export default class HQJGFun {
|
|||||||
contentInsertArr: [rank],
|
contentInsertArr: [rank],
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
// 标记已发送
|
||||||
|
await G.mongodb.collection("hdinfo").updateOne(
|
||||||
|
{ hdid: hdid }, { $set: { "data.sendrank": true } }
|
||||||
|
);
|
||||||
|
|
||||||
|
console.log(
|
||||||
|
"黄旗酒馆 最大伤害排行奖励结算 执行结束!!!"
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
G.on("NEW_DAY", HQJGFun.dayDpsLvPrize.bind(HQJGFun));
|
||||||
|
G.on("NEW_DAY", HQJGFun.endDpsRankPrize.bind(HQJGFun));
|
@ -16,12 +16,13 @@ import { player } from './shared/protocols/user/type';
|
|||||||
import { PublicShared } from './shared/public/public';
|
import { PublicShared } from './shared/public/public';
|
||||||
import { setGud } from './public/gud';
|
import { setGud } from './public/gud';
|
||||||
import { checkResetBuyLog } from "./api_s2c/event/zhoumolibao/ApiOpen";
|
import { checkResetBuyLog } from "./api_s2c/event/zhoumolibao/ApiOpen";
|
||||||
import {Christmasfun} from "./api_s2c/event/christmas/fun";
|
|
||||||
import { PushGiftFun } from "./public/pushgift";
|
import { PushGiftFun } from "./public/pushgift";
|
||||||
import { LeiChongLiBaoBuyGift } from "./api_s2c/event/leichonglibao/ApiReceive";
|
import { LeiChongLiBaoBuyGift } from "./api_s2c/event/leichonglibao/ApiReceive";
|
||||||
import { HongDianChange } from './api_s2c/hongdian/fun';
|
import { HongDianChange } from './api_s2c/hongdian/fun';
|
||||||
|
|
||||||
export type gEventType = {
|
export type gEventType = {
|
||||||
|
/**新的一天 */
|
||||||
|
NEW_DAY: (time: number) => void;
|
||||||
/**玩家断开连接 */
|
/**玩家断开连接 */
|
||||||
PLAYER_DISCONNECT: (uid: string) => void;
|
PLAYER_DISCONNECT: (uid: string) => void;
|
||||||
/**玩家修改名字 */
|
/**玩家修改名字 */
|
||||||
|
@ -59,6 +59,9 @@ export class SchedulerNewDayLocalCtor extends Scheduler {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
})()
|
})()
|
||||||
|
|
||||||
|
// 转点刷新事件
|
||||||
|
G.emit('NEW_DAY', G.time);
|
||||||
})
|
})
|
||||||
|
|
||||||
let users = Object.values(G.server.uid_connections)
|
let users = Object.values(G.server.uid_connections)
|
||||||
|
Loading…
Reference in New Issue
Block a user