import { Application, BackendSession, HandlerService, } from 'pinus'; import { resResult } from '../../../pubUtils/util'; import { FIRST_GIFT_STATE, STATUS } from '../../../consts'; import { getPlayerFirstGiftData } from '../../../services/activity/firstGiftService'; import { RoleModel } from '../../../db/Role'; import { addReward, stringToRewardParam } from '../../../services/activity/giftPackageService'; import { ActivityFirstGiftModel } from '../../../db/ActivityFirstGift'; export default function (app: Application) { new HandlerService(app, {}); return new FirstGiftHandler(app); } export class FirstGiftHandler { constructor(private app: Application) { } /************************首充礼包****************************/ /**首冲活动按玩家注册时间 * 不充,首充活动就一直在那里 * @description 获取首充礼包数据 * @param {{ activityId: number, }} msg * @param {BackendSession} session * @memberof FirstGiftHandler */ async getFirstGiftActivity(msg: { activityId: number }, session: BackendSession) { const { activityId } = msg; const roleId = session.get('roleId'); const serverId = session.get('serverId'); let playerData = await getPlayerFirstGiftData(activityId, serverId, roleId); if (!playerData) { return resResult(STATUS.ACTIVITY_MISSING); } let { totalPay } = await RoleModel.findByRoleId(roleId); if (totalPay > 0) {//奖励开启 } return resResult(STATUS.SUCCESS, { playerData }); } /** * @description 领取礼包奖励 * @param {{ activityId: number, index: number}} msg * @param {BackendSession} session * @memberof FirstGiftHandler */ async getFirstGiftReward(msg: { activityId: number, index: number }, session: BackendSession) { const { activityId, index } = msg; const roleId = session.get('roleId'); const serverId = session.get('serverId'); const sid = session.get('sid'); const roleName = session.get('roleName'); let playerData = await getPlayerFirstGiftData(activityId, serverId, roleId); if (!playerData) { return resResult(STATUS.ACTIVITY_MISSING); } if (playerData.state === FIRST_GIFT_STATE.CLOSED) { return resResult(STATUS.ACTIVITY_FIRST_GIFT_NOT_OPEN); } let items = playerData.canReceiveItems(); if (items.length === 0) { return resResult(STATUS.ACTIVITY_REWARDED); } let rewardArray = []; let indexArray = []; for (let item of items) { rewardArray = rewardArray.concat(stringToRewardParam(item.reward)) indexArray.push(item.index) item.isReceive = true; } let result = await addReward(roleId, roleName, sid, serverId, rewardArray); let isOver = playerData.isComplete(); await ActivityFirstGiftModel.addRecord(activityId, roleId, indexArray, isOver); return resResult(STATUS.SUCCESS, Object.assign(result, { param: { activityId }, items: items })); } }