116 lines
4.7 KiB
TypeScript
116 lines
4.7 KiB
TypeScript
import { Application, BackendSession } from 'pinus';
|
|
import { resResult } from '../../../pubUtils/util';
|
|
import { CURRENCY_BY_TYPE, CURRENCY_TYPE, STATUS } from '../../../consts';
|
|
import { handleCost } from '../../../services/rewardService';
|
|
import { getPlayerDailyCoinData, mergeData } from '../../../services/dailyCoinService';
|
|
import { DailyCoinItem } from '../../../domain/activityField/dailyCoinField';
|
|
import { ActivityDailyCoinModel } from '../../../db/ActivityDailyCoin';
|
|
import { addReward, stringToConsumeParam, stringToRewardParam } from '../../../services/giftPackageService';
|
|
import { RewardParam } from '../../../domain/activityField/rewardField';
|
|
import { ItemInter } from '../../../pubUtils/interface';
|
|
|
|
|
|
export default function (app: Application) {
|
|
return new DailyCoinHandler(app);
|
|
}
|
|
|
|
export class DailyCoinHandler {
|
|
constructor(private app: Application) {
|
|
}
|
|
|
|
|
|
/************************每日兑换铜币****************************/
|
|
|
|
/**
|
|
* @description 获取每日铜币活动数据
|
|
* @param {{ activityId: number}} msg
|
|
* @param {BackendSession} session
|
|
* @memberof DailyCoinHandler
|
|
*/
|
|
async getDailyCoinActivity(msg: { activityId: number }, session: BackendSession) {
|
|
const { activityId } = msg;
|
|
const roleId = session.get('roleId');
|
|
const serverId = session.get('serverId');
|
|
|
|
let playerData = await getPlayerDailyCoinData(activityId, serverId, roleId)
|
|
|
|
if (!playerData) return resResult(STATUS.ACTIVITY_MISSING);
|
|
|
|
delete playerData.list;
|
|
return resResult(STATUS.SUCCESS, playerData);
|
|
}
|
|
|
|
/**
|
|
* @description 兑换
|
|
* @param {{ activityId: number, count:number}} msg
|
|
* @param {BackendSession} session
|
|
* @memberof DailyCoinHandler
|
|
*/
|
|
async exchangeCoin(msg: { activityId: number, count: number }, session: BackendSession) {
|
|
const { activityId, count } = msg;
|
|
const roleId = session.get('roleId');
|
|
const serverId = session.get('serverId');
|
|
const sid = session.get('sid');
|
|
const roleName = session.get('roleName');
|
|
const funcs = session.get('funcs');
|
|
|
|
let playerData = await getPlayerDailyCoinData(activityId, serverId, roleId)
|
|
if (!playerData) return resResult(STATUS.ACTIVITY_MISSING);
|
|
let curIndex = playerData.exchangeCount;
|
|
if (curIndex + count > playerData.list.length) {
|
|
return resResult(STATUS.ACTIVITY_MAX_COUNT);
|
|
}
|
|
let allConsume: Array<ItemInter> = []
|
|
let allReward: Array<RewardParam> = [];
|
|
for (let i = 1; i <= count; i++) {
|
|
let index = curIndex + i;
|
|
console.log('第几次抽奖', index)
|
|
let item: DailyCoinItem = playerData.findItem(index);
|
|
if (item.consume) {//消耗资源
|
|
let consume = stringToConsumeParam(item.consume)
|
|
allConsume = allConsume.concat(consume)
|
|
}
|
|
let rate = item.getRate()//翻几倍
|
|
let baseRewardParamArr: Array<RewardParam> = stringToRewardParam(item.baseReward);
|
|
console.log('基础奖励翻倍', JSON.stringify(baseRewardParamArr), rate)
|
|
for (let reward of baseRewardParamArr) {
|
|
reward.count = reward.count * rate;
|
|
}
|
|
allReward = allReward.concat(baseRewardParamArr);
|
|
if (item.extraReward) {//额外奖励
|
|
let extraRewardParamArr: Array<RewardParam> = stringToRewardParam(item.extraReward);
|
|
console.log('额外奖励', JSON.stringify(extraRewardParamArr))
|
|
allReward = allReward.concat(extraRewardParamArr);
|
|
}
|
|
}
|
|
|
|
let newConsume = mergeData(allConsume);
|
|
let newReward = mergeData(allReward);
|
|
console.log('所有消耗', JSON.stringify(newConsume))
|
|
console.log('所有奖励', JSON.stringify(newReward))
|
|
|
|
//检查资源
|
|
let consumeResult = await handleCost(roleId, sid, newConsume);
|
|
if (!consumeResult) return resResult(STATUS.ACTIVITY_RES_NOT_ENOUGH);
|
|
|
|
let addCoin = 0
|
|
let coinId = CURRENCY_BY_TYPE.get(CURRENCY_TYPE.COIN);
|
|
for (let obj of newReward) {
|
|
if (obj.id === coinId) {
|
|
addCoin += obj.count;
|
|
}
|
|
}
|
|
|
|
//免费期间
|
|
let result = await addReward(roleId, roleName, sid, serverId, funcs, newReward)
|
|
await ActivityDailyCoinModel.addExchangeRecord(serverId, activityId, roleId, playerData.beginTime, count, addCoin);
|
|
|
|
let exchangeCount = playerData.exchangeCount + count;
|
|
return resResult(STATUS.SUCCESS, Object.assign(result, {
|
|
param: { activityId, count },
|
|
item: { exchangeCount },
|
|
}));
|
|
}
|
|
|
|
}
|