排行榜:排行榜首通榜
This commit is contained in:
@@ -171,14 +171,9 @@ export class RoleHandler {
|
|||||||
let dicReward = gameData.generalRankReward.get(id);
|
let dicReward = gameData.generalRankReward.get(id);
|
||||||
if (!dicReward || dicReward.rankId != type) continue;
|
if (!dicReward || dicReward.rankId != type) continue;
|
||||||
|
|
||||||
let redisKey = RANK_TYPE_TO_KEY.get(type);
|
let rankFirst: RankFirstType = pinus.app.get('rankFirstRewards').get(serverId)?.get(id);
|
||||||
let r = new Rank(redisKey, { serverId }, false, 1);
|
console.log('*******', pinus.app.get('rankFirstRewards'), rankFirst);
|
||||||
let ranks = await r.getRankByRange();
|
if (!rankFirst) continue;
|
||||||
let num = ranks.length > 0 ? ranks[0].num : 0;
|
|
||||||
if (num < dicReward.condition) continue;
|
|
||||||
|
|
||||||
console.log('*******receiveReward', id, redisKey, type, num, dicReward.condition)
|
|
||||||
|
|
||||||
if (role.rankReceived.includes(id)) continue;
|
if (role.rankReceived.includes(id)) continue;
|
||||||
|
|
||||||
let reward = dicReward.reward;
|
let reward = dicReward.reward;
|
||||||
|
|||||||
@@ -45,10 +45,12 @@ export class RoleRemote {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public setRankFirst(rank: RankFirstType) {
|
public setRankFirst(rank: RankFirstType) {
|
||||||
|
console.log('****** setRankFirst', rank.serverId, rank.id, rank)
|
||||||
if(!this.rankFirstRewards.has(rank.serverId)) {
|
if(!this.rankFirstRewards.has(rank.serverId)) {
|
||||||
this.rankFirstRewards.set(rank.serverId, new Map());
|
this.rankFirstRewards.set(rank.serverId, new Map());
|
||||||
}
|
}
|
||||||
this.rankFirstRewards.get(rank.serverId).set(rank.id, rank);
|
this.rankFirstRewards.get(rank.serverId).set(rank.id, rank);
|
||||||
|
this.app.set('rankFirstRewards', this.rankFirstRewards);
|
||||||
}
|
}
|
||||||
|
|
||||||
public getRankFirstById(serverId: number, id: number) {
|
public getRankFirstById(serverId: number, id: number) {
|
||||||
|
|||||||
@@ -39,10 +39,13 @@ export default class HangUpRecord extends BaseModel {
|
|||||||
received: boolean; // 是否已经领取,true-领取,false-未领取
|
received: boolean; // 是否已经领取,true-领取,false-未领取
|
||||||
|
|
||||||
public static async initRecord(roleId: string, roleName: string, lean = true) {
|
public static async initRecord(roleId: string, roleName: string, lean = true) {
|
||||||
|
console.log('****** initRecord before')
|
||||||
const curTime = new Date();
|
const curTime = new Date();
|
||||||
const recDoc = new HangUpRecordModel();
|
const recDoc = new HangUpRecordModel();
|
||||||
const update = Object.assign(recDoc.toJSON(), {roleId, roleName, startTime: curTime, startLv: dicParam.TOWER_HANG_UP.TOWER_HANG_UP_ENABLE_LV + 1});
|
const update = Object.assign(recDoc.toJSON(), {roleId, roleName, startTime: curTime, startLv: dicParam.TOWER_HANG_UP.TOWER_HANG_UP_ENABLE_LV + 1});
|
||||||
const rec: HangUpRecordType = await HangUpRecordModel.findOneAndUpdate({roleId, startLv: dicParam.TOWER_HANG_UP.TOWER_HANG_UP_ENABLE_LV + 1}, update, {upsert: true, new: true}).lean(lean);
|
const rec: HangUpRecordType = await HangUpRecordModel.findOneAndUpdate({roleId, startLv: dicParam.TOWER_HANG_UP.TOWER_HANG_UP_ENABLE_LV + 1}, { $setOnInsert: update }, {upsert: true, new: true}).lean(lean);
|
||||||
|
|
||||||
|
console.log('****** initRecord after')
|
||||||
return rec;
|
return rec;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user