diff --git a/game-server/app/services/timeTaskService.ts b/game-server/app/services/timeTaskService.ts index 83a805890..dd0025463 100644 --- a/game-server/app/services/timeTaskService.ts +++ b/game-server/app/services/timeTaskService.ts @@ -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); 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); 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 mail = await MailModel.addMail({ goods, sendName: '系统', mailId: 1, sendTime: sendTime}); - let key = 'login_roleId_' + pvpDefense.roleId; + let mail = await MailModel.addMail({roleId, goods, sendName: '系统', mailId: 1, sendTime: sendTime}); + let key = 'login_roleId_' + roleId; let sid = await getRedis(key); if (!!sid) { pinus.app.rpc.connector.connectorRemote.pushMessage.toServer(sid, pvpDefense.roleId, 'onMailsAdd', [mail]); diff --git a/shared/db/Mail.ts b/shared/db/Mail.ts index b9ec8e3ca..541adc0fd 100644 --- a/shared/db/Mail.ts +++ b/shared/db/Mail.ts @@ -25,7 +25,7 @@ export default class Mail extends BaseModel { await MailModel.insertMany(mails); } - public static async addMail(params:{ goods: Array, sendName: string, mailId: number, sendTime?: number}) { + public static async addMail(params:{roleId: string, goods: Array, sendName: string, mailId: number, sendTime?: number}) { const doc = new MailModel(); const mail = Object.assign(doc.toJSON(), params); const mailInfo: MailType = await MailModel.create(mail);