活动:转盘
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
import { Application, BackendSession, HandlerService, } from 'pinus';
|
||||
import { resResult } from '../../../pubUtils/util';
|
||||
import { FIRST_GIFT_STATE, ITEM_CHANGE_REASON, STATUS } from '../../../consts';
|
||||
import { getPlayerFirstGiftData } from '../../../services/activity/firstGiftService';
|
||||
import { getPlayerFirstGiftData, getPlayerFirstGiftDataShow } from '../../../services/activity/firstGiftService';
|
||||
import { RoleModel } from '../../../db/Role';
|
||||
import { addReward, stringToRewardParam } from '../../../services/activity/giftPackageService';
|
||||
import { ActivityFirstGiftModel } from '../../../db/ActivityFirstGift';
|
||||
@@ -30,7 +30,7 @@ export class FirstGiftHandler {
|
||||
const roleId = session.get('roleId');
|
||||
const serverId = session.get('serverId');
|
||||
|
||||
let playerData = await getPlayerFirstGiftData(activityId, serverId, roleId);
|
||||
let playerData = await getPlayerFirstGiftDataShow(activityId, serverId, roleId);
|
||||
if (!playerData) {
|
||||
return resResult(STATUS.ACTIVITY_MISSING);
|
||||
}
|
||||
|
||||
@@ -0,0 +1,98 @@
|
||||
import { Application, BackendSession, HandlerService, } from 'pinus';
|
||||
import { resResult } from '../../../pubUtils/util';
|
||||
import { ITEM_CHANGE_REASON, STATUS } from '../../../consts';
|
||||
import { getPlayerLuckyTurntableDataShow, getPlayerLuckyTurntableData } from '../../../services/activity/luckyTurntableService';
|
||||
import { addItems, combineItems, handleCost } from '../../../services/rewardService';
|
||||
import { ActivityTurntableModel } from '../../../db/ActivityTurntableRec';
|
||||
import { pick } from 'underscore';
|
||||
import { addReward, stringToRewardInter, stringToRewardParam } from '../../../services/activity/giftPackageService';
|
||||
|
||||
|
||||
export default function (app: Application) {
|
||||
new HandlerService(app, {});
|
||||
return new LuckyTurntableHandler(app);
|
||||
}
|
||||
|
||||
export class LuckyTurntableHandler {
|
||||
constructor(private app: Application) {
|
||||
}
|
||||
|
||||
/************************幸运转盘****************************/
|
||||
/**
|
||||
* @description 幸运转盘活动
|
||||
* @param {{ activityId: number, }} msg
|
||||
* @param {BackendSession} session
|
||||
* @memberof LuckyTurntableHandler
|
||||
*/
|
||||
async getTurntableData(msg: { activityId: number }, session: BackendSession) {
|
||||
const { activityId } = msg;
|
||||
const roleId = session.get('roleId');
|
||||
const serverId = session.get('serverId');
|
||||
|
||||
let playerData = await getPlayerLuckyTurntableDataShow(activityId, serverId, roleId);
|
||||
if (!playerData) {
|
||||
return resResult(STATUS.ACTIVITY_MISSING);
|
||||
}
|
||||
|
||||
return resResult(STATUS.SUCCESS, { playerData });
|
||||
}
|
||||
|
||||
/**
|
||||
* @description 转转盘
|
||||
* @param {{ activityId: number, }} msg
|
||||
* @param {BackendSession} session
|
||||
* @memberof LuckyTurntableHandler
|
||||
*/
|
||||
async pull(msg: { activityId: number, count: number }, session: BackendSession) {
|
||||
const { activityId, count } = msg;
|
||||
const roleId = session.get('roleId');
|
||||
const roleName = session.get('roleName');
|
||||
const sid = session.get('sid');
|
||||
const serverId = session.get('serverId');
|
||||
|
||||
let playerData = await getPlayerLuckyTurntableData(activityId, serverId, roleId);
|
||||
if (!playerData) {
|
||||
return resResult(STATUS.ACTIVITY_MISSING);
|
||||
}
|
||||
|
||||
let cost = playerData.getCost(count);
|
||||
let costResult = await handleCost(roleId, sid, cost, ITEM_CHANGE_REASON.ACT_TURNTABLE_PULL);
|
||||
if(!costResult) return resResult(STATUS.ROLE_MATERIAL_NOT_ENOUGH);
|
||||
|
||||
let { result, records, goodResult } = playerData.pull(roleName, count);
|
||||
await ActivityTurntableModel.updateData(serverId, activityId, roleId, pick(playerData, ['todayCount', 'count', 'records', 'greatRewardCount']));
|
||||
let goods = await addItems(roleId, roleName, sid, goodResult, ITEM_CHANGE_REASON.ACT_TURNTABLE_PULL);
|
||||
|
||||
return resResult(STATUS.SUCCESS, { result, records, goods: combineItems(goods) });
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @description 领宝箱
|
||||
* @param {{ activityId: number, boxCount: number }} msg
|
||||
* @param {BackendSession} session
|
||||
* @memberof LuckyTurntableHandler
|
||||
*/
|
||||
async receiveBox(msg: { activityId: number, boxCount: number }, session: BackendSession) {
|
||||
const { activityId, boxCount } = msg;
|
||||
const roleId = session.get('roleId');
|
||||
const roleName = session.get('roleName');
|
||||
const sid = session.get('sid');
|
||||
const serverId = session.get('serverId');
|
||||
|
||||
let playerData = await getPlayerLuckyTurntableData(activityId, serverId, roleId);
|
||||
if (!playerData) {
|
||||
return resResult(STATUS.ACTIVITY_MISSING);
|
||||
}
|
||||
|
||||
let canReceive = playerData.canReceive(boxCount);
|
||||
if(!canReceive) return resResult(STATUS.BOX_CAN_NOT_RECEIVE);
|
||||
|
||||
let box = playerData.findBox(boxCount);
|
||||
let rewardArray = stringToRewardParam(box.reward)
|
||||
let result = await addReward(roleId, roleName, sid, serverId, rewardArray, ITEM_CHANGE_REASON.BUY_LIMIT_PACKAGE);
|
||||
await ActivityTurntableModel.receiveBox(serverId, activityId, roleId, boxCount);
|
||||
|
||||
return resResult(STATUS.SUCCESS, { ...result, box: {...box, isReceived: true} });
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user