奖励下发
This commit is contained in:
@@ -118,13 +118,13 @@ export async function setPvpDefResult(pvpDefense: PvpDefenseType, seasonNum: num
|
|||||||
}
|
}
|
||||||
let {score, pLv, heroScores, winStreakNum, challengeCnt, challengeRefTime, goods } = await checkResult(pvpDefense, seasonNum, seasonEndTime);
|
let {score, pLv, heroScores, winStreakNum, challengeCnt, challengeRefTime, goods } = await checkResult(pvpDefense, seasonNum, seasonEndTime);
|
||||||
pvpDefense = await PvpDefenseModel.updateInfo(pvpDefense.roleId, {score:score, pLv, heroScores, winStreakNum, seasonNum, challengeCnt, challengeRefTime, seasonEndTime});
|
pvpDefense = await PvpDefenseModel.updateInfo(pvpDefense.roleId, {score:score, pLv, heroScores, winStreakNum, seasonNum, challengeCnt, challengeRefTime, seasonEndTime});
|
||||||
let { roleName, lv, vLv, headHid, sHid, title } = role;
|
let { roleName, lv, vLv, headHid, sHid, title , roleId } = role;
|
||||||
let params = new RankParam(roleName, lv, vLv, headHid, sHid, title);
|
let params = new RankParam(roleName, lv, vLv, headHid, sHid, title);
|
||||||
setRank(REDIS_KEY.PVP_RANK, 0, pvpDefense.roleId, pvpDefense.score, pvpDefense.updatedAt.getTime(), params);
|
setRank(REDIS_KEY.PVP_RANK, 0, pvpDefense.roleId, pvpDefense.score, pvpDefense.updatedAt.getTime(), params);
|
||||||
//下发邮件
|
//下发邮件
|
||||||
let sendTime = seasonEndTime - PVP.PVP_SEASON_DAYS * PER_DAY + SETTLE_DIFF;
|
let sendTime = seasonEndTime - PVP.PVP_SEASON_DAYS * PER_DAY + SETTLE_DIFF;
|
||||||
let mail = await MailModel.addMail({ goods, sendName: '系统', mailId: 1, sendTime: sendTime});
|
let mail = await MailModel.addMail({roleId, goods, sendName: '系统', mailId: 1, sendTime: sendTime});
|
||||||
let key = 'login_roleId_' + pvpDefense.roleId;
|
let key = 'login_roleId_' + roleId;
|
||||||
let sid = await getRedis(key);
|
let sid = await getRedis(key);
|
||||||
if (!!sid) {
|
if (!!sid) {
|
||||||
pinus.app.rpc.connector.connectorRemote.pushMessage.toServer(sid, pvpDefense.roleId, 'onMailsAdd', [mail]);
|
pinus.app.rpc.connector.connectorRemote.pushMessage.toServer(sid, pvpDefense.roleId, 'onMailsAdd', [mail]);
|
||||||
|
|||||||
+1
-1
@@ -25,7 +25,7 @@ export default class Mail extends BaseModel {
|
|||||||
await MailModel.insertMany(mails);
|
await MailModel.insertMany(mails);
|
||||||
}
|
}
|
||||||
|
|
||||||
public static async addMail(params:{ goods: Array<RewardInter>, sendName: string, mailId: number, sendTime?: number}) {
|
public static async addMail(params:{roleId: string, goods: Array<RewardInter>, sendName: string, mailId: number, sendTime?: number}) {
|
||||||
const doc = new MailModel();
|
const doc = new MailModel();
|
||||||
const mail = Object.assign(doc.toJSON(), params);
|
const mail = Object.assign(doc.toJSON(), params);
|
||||||
const mailInfo: MailType = await MailModel.create(mail);
|
const mailInfo: MailType = await MailModel.create(mail);
|
||||||
|
|||||||
Reference in New Issue
Block a user