qixin/HJ_Server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix:

Browse Source 
修复终身卡每周奖励未发放bug
This commit is contained in:
xcy 2023-12-28 11:49:21 +08:00
parent 3898cee713
commit b79d80beed
1 changed files with 33 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/public/scheduler/scheduler_newDay.ts
View File

@ -1,8 +1,9 @@
import { Scheduler, schedulerType } from './scheduler'; import { Scheduler, schedulerType } from './scheduler';
import {PublicShared} from "../../shared/public/public"; import { PublicShared } from "../../shared/public/public";
import {Wjjl} from "../../module/collection_wjjl"; import { Wjjl } from "../../module/collection_wjjl";
import {ZhanLingTasks} from "../zhanling"; import { ZhanLingTasks } from "../zhanling";
import { setGud } from '../gud'; import { setGud } from '../gud';
import { EmailFun } from '../email';
export class SchedulerNewDayLocalCtor extends Scheduler { export class SchedulerNewDayLocalCtor extends Scheduler {
@ -23,8 +24,8 @@ export class SchedulerNewDayLocalCtor extends Scheduler {
async start() { async start() {
let users = Object.values(G.server.uid_connections) let users = Object.values(G.server.uid_connections)
if(users.length) { if (users.length) {
for (let item of users){ for (let item of users) {
let gud = item.gud let gud = item.gud
let add: k_v<any> = {}; let add: k_v<any> = {};
//每天首次登陆 //每天首次登陆
@ -36,23 +37,46 @@ export class SchedulerNewDayLocalCtor extends Scheduler {
if (gud.logoutTime && PublicShared.getToWeekMondayZeroTime(gud.logoutTime) < PublicShared.getToWeekMondayZeroTime(G.time)) { if (gud.logoutTime && PublicShared.getToWeekMondayZeroTime(gud.logoutTime) < PublicShared.getToWeekMondayZeroTime(G.time)) {
ZhanLingTasks.clearLog(gud.uid, 'week'); ZhanLingTasks.clearLog(gud.uid, 'week');
} }
G.emit('FIRST_LOGIN_EVERY_DAY', gud, G.time - 24 * 3600, G.time); G.emit('FIRST_LOGIN_EVERY_DAY', gud, gud.loginTime, G.time);
} }
gud.loginTime = G.time; gud.loginTime = G.time;
add.loginTime = G.time; add.loginTime = G.time;
if (Object.keys(add).length > 0) { if (Object.keys(add).length > 0) {
G.mongodb.collection('user').updateOne({ bindUid: gud.bindUid,sid:gud.sid }, { G.mongodb.collection('user').updateOne({ bindUid: gud.bindUid, sid: gud.sid }, {
$set: { $set: {
...add ...add
} }
}); });
setGud(gud.uid,add); setGud(gud.uid, add);
} }
G.server.sendMsgByUid(gud.uid, 'msg_s2c/PlayerChange', gud) G.server.sendMsgByUid(gud.uid, 'msg_s2c/PlayerChange', gud)
} }
G.server.broadcastClusterMsg('msg_s2c/NewDay', {time: this.zeroTime}); G.server.broadcastClusterMsg('msg_s2c/NewDay', { time: this.zeroTime });
} }
(async () => {
// 每周一，发放终身卡
if (PublicShared.getWeek(G.time) != 1) return;
let logs = await G.mongodb.collection("payLogNew").find(
{ key: "zhongshengka", del_time: { $exists: false } }, { projection: { _id: 0, } }
).toArray();
let con = G.gc.payEmail.zhongshenka.filter(e => e.day == 7)[0];
for (let i = 0; i < logs.length; i++) {
// 发送邮件
EmailFun.addEmail({
uid: logs[i].uid,
type: con.type,
title: con.title,
content: con.content,
contentInsertArr: [],
createTime: G.time,
prize:con.prize,
})
}
})()
} }
} }