feat(活动): 月基金

This commit is contained in:
luying
2023-03-24 16:18:34 +08:00
parent 2deb1d5289
commit 6e22a21f5d
10 changed files with 389 additions and 0 deletions

View File

@@ -0,0 +1,73 @@
import { Application, BackendSession, HandlerService, } from 'pinus';
import { resResult } from '../../../pubUtils/util';
import { ITEM_CHANGE_REASON, STATUS } from '../../../consts';
import { getMonthlyFundData, getMonthlyFundDataShow } from '../../../services/activity/monthlyFundService';
import { ActivityWeeklyFundModel } from '../../../db/ActivityWeeklyFund';
import { addReward, stringToRewardParam } from '../../../services/activity/giftPackageService';
import { ActivityMonthlyFundModel } from '../../../db/ActivityMonthlyFund';
export default function (app: Application) {
new HandlerService(app, {});
return new MonthlyFundHandler(app);
}
export class MonthlyFundHandler {
constructor(private app: Application) {
}
/************************月基金****************************/
/**
* @description 获取数据
* @param {BackendSession} session
* @memberof MonthlyFundHandler
*/
async getData(msg: { activityId: number }, session: BackendSession) {
const { activityId } = msg;
const roleId = session.get('roleId');
const serverId = session.get('serverId');
let playerData = await getMonthlyFundDataShow(activityId, serverId, roleId);
if (!playerData) return resResult(STATUS.ACTIVITY_MISSING);
return resResult(STATUS.SUCCESS, playerData);
}
/**
* @description 签到
* @param {BackendSession} session
* @memberof MonthlyFundHandler
*/
async sign(msg: { activityId: number, pageIndex: number, dayIndex: number }, session: BackendSession) {
const { activityId, pageIndex, dayIndex } = msg;
const roleId = session.get('roleId');
const roleName = session.get('roleName');
const sid = session.get('sid');
const serverId = session.get('serverId');
let playerData = await getMonthlyFundData(activityId, serverId, roleId);
if (!playerData) return resResult(STATUS.ACTIVITY_MISSING);
let pageData = playerData.findPage(pageIndex);
if (!pageData) return resResult(STATUS.ACTIVITY_MISSING);
if(!pageData.hasBought) return resResult(STATUS.ACTIVITY_MONTHLY_FUND_NOT_BOUGHT);
let signReward = pageData.findSignReward(dayIndex);
if(!signReward) return resResult(STATUS.ACTIVITY_MONTHLY_FUND_NOT_FOUND);
if(signReward.hasReceived) return resResult(STATUS.ACTIVITY_MONTHLY_FUND_HAS_SIGN);
if(signReward.dayIndex > playerData.todayIndex) return resResult(STATUS.ACTIVITY_MONTHLY_FUND_LOCK);
let record = await ActivityMonthlyFundModel.sign(serverId, activityId, roleId, playerData.roundIndex, pageIndex, dayIndex, playerData.todayIndex);
if(!record) return resResult(STATUS.ACTIVITY_MONTHLY_FUND_HAS_SIGN);
let rewardParamArr = stringToRewardParam(signReward.reward);
let { goods, addHeros } = await addReward(roleId, roleName, sid, serverId, rewardParamArr, ITEM_CHANGE_REASON.ACT_MONTHLY_FUND_SIGN);
return resResult(STATUS.SUCCESS, {
activityId, dayIndex, pageIndex, goods, addHeros
});
}
}