import { Application, BackendSession } from 'pinus'; import { UserGuildModel } from '../../../db/UserGuild'; import { resResult } from '../../../pubUtils/util'; import { STATUS } from '../../../consts'; import { DonationModel } from '../../../db/Donation'; import { nowSeconds } from '../../../pubUtils/timeUtil'; import { getArmyDonateBaseByLv, getArmyDonateBoxBaseById } from '../../../pubUtils/data'; import { GuildModel } from '../../../db/Guild'; import { GUILD_STRUCTURE } from '../../../consts/constModules/guildConst'; import { findWhere } from 'underscore'; import { handleCost, addItems } from '../../../services/rewardService'; import { CHAT_SERVER } from '../../../consts'; export default function(app: Application) { return new DonationHandler(app); } export class DonationHandler { constructor(private app: Application) { } async getDonation(msg: {}, session: BackendSession) { const roleId: string = session.get('roleId'); let userGuild = await UserGuildModel.getMyGuild(roleId,'donateCnt receiveBoxs guildCode'); if (!userGuild) return resResult(STATUS.WRONG_PARMS); const { guildCode: code, donateCnt, receiveBoxs } = userGuild; let { donateFund, reports } = await DonationModel.getDonation(code); return resResult(STATUS.SUCCESS, { receiveBoxs, donateFund, reports, donateCnt }); } async donate(msg: {id: number}, session: BackendSession) { const { id } = msg; const roleId: string = session.get('roleId'); const roleName: string = session.get('roleName'); const serverId: number = parseInt(session.get('serverId')); const sid: string = session.get('sid'); let userGuild = await UserGuildModel.getMyGuild(roleId,'donateCnt receiveBoxs guildCode'); if (!userGuild) return resResult(STATUS.WRONG_PARMS); const { guildCode: code, donateCnt: resdonateCnt } = userGuild; if (resdonateCnt <= 0) return resResult(STATUS.SUCCESS); let { structure } = await GuildModel.findGuild(code, serverId, 'structure'); let { lv } = findWhere(structure, {id: GUILD_STRUCTURE.DONATE}); let { donateReward } = getArmyDonateBaseByLv(lv); let { rewardGood, rewardFund, cosume } = donateReward.get(id); let result = await handleCost(roleId, sid, [cosume]); if(!result) return resResult(STATUS.ROLE_MATERIAL_NOT_ENOUGH); let { donateCnt } = await UserGuildModel.donateFund(roleId, 1); let { donateFund, reports } = await DonationModel.donation(code, rewardFund, { reports: {id, roleName, time: nowSeconds()}}); let goods = await addItems(roleId, roleName, sid, [rewardGood]); //增加基金 const { fund } = await GuildModel.updateInfo(code, {}, { fund: rewardFund }, 'fund'); this.app.rpc.chat.guildRemote.updateInfo.toServer(CHAT_SERVER, code, { fund }); return resResult(STATUS.SUCCESS, { donateFund, reports, donateCnt, goods }); } async receiveBox(msg: {id: number}, session: BackendSession) { const { id } = msg; const roleId: string = session.get('roleId'); const roleName: string = session.get('roleName'); const sid: string = session.get('sid'); let userGuild = await UserGuildModel.getMyGuild(roleId,'donateCnt receiveBoxs guildCode'); if (!userGuild) return resResult(STATUS.WRONG_PARMS); const { guildCode: code, donateCnt: resdonateCnt, receiveBoxs: resReceiveBoxs } = userGuild; if (resReceiveBoxs.indexOf(id) != -1) return resResult(STATUS.SUCCESS); let { boxRewards, fund } = getArmyDonateBoxBaseById(id); if (resdonateCnt <= 0) return resResult(STATUS.SUCCESS); resReceiveBoxs.push(id); let { receiveBoxs } = await UserGuildModel.updateInfo(roleId, { receiveBoxs: resReceiveBoxs }, {}, 'receiveBoxs'); let goods = await addItems(roleId, roleName, sid, boxRewards); const { fund: resFund } = await GuildModel.updateInfo(code, {}, { fund }, 'fund'); this.app.rpc.chat.guildRemote.updateInfo.toServer(CHAT_SERVER, code, { fund: resFund }); return resResult(STATUS.SUCCESS, { receiveBoxs, goods }); } }