433 lines
19 KiB
TypeScript
433 lines
19 KiB
TypeScript
import { ACTIVITY_TYPE, PUSH_ROUTE, STATUS } from '../../consts';
|
|
import { getPlayerFirstGiftDataShow } from './firstGiftService';
|
|
import { getPlayerSignInData, } from './signInService';
|
|
import { getPlayerGrowthFundData, } from './growthFundService';
|
|
import { getPlayerLimitPackageData, } from './limitPackageService';
|
|
import { getPlayerYuanbaoShopData, } from './yuanbaoService';
|
|
import { getPlayerMonthlyTicketData, } from './monthlyTicketService';
|
|
import { getPlayerRechargeMoneyDataShow, } from './rechargeMoneyService';
|
|
import { getPlayerThirtyDaysData, playerThirtyDaysActivityDays, } from './thirtyDaysService';
|
|
import { getPlayerVipRechargeMoneyData, } from './vipRechargeMoneyService';
|
|
import { getPlayerActivityData, } from './selfServiceShopActivityService';
|
|
import { ActivitySelfServiceGoodsModel } from '../../db/ActivitySelfServiceGoods';
|
|
import moment = require('moment');
|
|
import { getPlayerTreasureHuntData, getTreasureHuntData } from './treasureHuntService';
|
|
import { getPopUpShopDataShow } from './popUpShopService';
|
|
import { getPlayerSevenDaysData } from './sevenDaysService';
|
|
import { getPlayerDailyMealData } from './dailyMealService';
|
|
import { getPlayerDailyCoinData } from './dailyCoinService';
|
|
import { getPlayerDailyRMBGiftsData } from './dailyRMBGiftsService';
|
|
import { getPlayerDailyGKData } from './dailyGKService';
|
|
import { getPlayerRefreshShopData } from './refreshShopService';
|
|
import { getPlayerRefreshTaskData } from './refreshTaskService';
|
|
import { getPlayerMonopolyData } from './monopolyService';
|
|
import { getPlayerNewHeroGiftsData, newHeroGiftPoint } from './newHeroGiftsService';
|
|
import { getPlayerNewHeroGKData } from './newHeroGKService';
|
|
import { getPlayerNewHeroGachaData } from './newHeroGachaService';
|
|
import { BackendSession, pinus } from 'pinus';
|
|
import { ActivityModel, ActivityModelType } from '../../db/Activity';
|
|
import { getRandSingleEelm, resResult } from '../../pubUtils/util';
|
|
import { SignInData } from '../../domain/activityField/signInField';
|
|
import { ActivityGroupModel } from '../../db/ActivityGroup';
|
|
import { ActivityGroupTypeModel } from '../../db/ActivityGroupType';
|
|
import { ServerlistModel } from '../../db/Serverlist';
|
|
import { ActivityInRemote, transActivityInRemoteToModelType } from '../../domain/activityField/activityField';
|
|
import { getPlayerLuckyTurntableDataShow } from './luckyTurntableService';
|
|
import { getTimeLimitRankDataShow } from './timeLimitRankService';
|
|
import { ActivityTaskPointModel } from '../../db/ActivityTaskPoint';
|
|
import { getRoleOnlineInfo } from '../redisService';
|
|
import { addTaskPassPoint, getTaskPassDataShow } from './taskPassService';
|
|
import { getGuildChannelSid } from '../chatService';
|
|
import { getGuildPayDataShow } from './guildPayService';
|
|
import { PopUpShopItemShow } from '../../domain/activityField/popUpShopField';
|
|
import { sendMessageToGuildWithSuc, sendMessageToUser, sendMessageToUserWithSuc } from '../pushService';
|
|
|
|
/**
|
|
* 获取活动数据
|
|
*
|
|
* @param {number} serverId 区Id
|
|
* @param {number} activityId 活动Id
|
|
* @param {string} roleId 角色Id
|
|
*
|
|
*/
|
|
export async function getActivity(serverId: number, roleId: string, guildCode: string, activityId: number, activityType: number) {
|
|
let activityData = null;
|
|
switch (activityType) {
|
|
case ACTIVITY_TYPE.SIGN_IN://签到 4
|
|
case ACTIVITY_TYPE.SIGN_IN_VIP://高级签到 5
|
|
case ACTIVITY_TYPE.NEW_PLAYER_SIGN_IN://新手签到 25
|
|
{
|
|
activityData = await getPlayerSignInData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.GROWTH_FUND_MAIN://成长基金 6
|
|
case ACTIVITY_TYPE.GROWTH_FUND_MAIN_VIP://高阶成长基金 7
|
|
case ACTIVITY_TYPE.GROWTH_FUND_TOWER://镇念塔成长基金 8
|
|
case ACTIVITY_TYPE.GROWTH_FUND_TOWER_VIP://高阶镇念塔成长基金 9
|
|
case ACTIVITY_TYPE.GROWTH_FUND_MAIN_ELITE://精英成长基金 10
|
|
case ACTIVITY_TYPE.GROWTH_FUND_MAIN_ELITE_VIP://高阶精英成长基金 11
|
|
{
|
|
activityData = await getPlayerGrowthFundData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.THIRTY_DAYS://30天目标活动 12
|
|
{
|
|
let data = await getPlayerThirtyDaysData(activityId, serverId, roleId);
|
|
let todayIndex = await playerThirtyDaysActivityDays(roleId);
|
|
activityData = { playerData: data, todayIndex, canShow: () => data.canShow }
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.SELF_SERVICE_SHOP://自选商店 糜家商队 13
|
|
{
|
|
let data = await getPlayerActivityData(activityId, serverId, roleId);
|
|
let playerGoods = await ActivitySelfServiceGoodsModel.findData(activityId, roleId, data.roundIndex, true);
|
|
activityData = { playerData: data, playerGoods: playerGoods ? playerGoods : [], canShow: () => data.canShow }
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.FIRST_GIFT://首冲礼包活动 14
|
|
{
|
|
activityData = await getPlayerFirstGiftDataShow(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.NEW_PLAYER_LIMIT_PACKAGE://新手限定RMB购买礼包 15
|
|
{
|
|
activityData = await getPlayerLimitPackageData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.LIMIT_PACKAGE_SHOP_DAILY://每日限购礼包，RMB购买礼包 16
|
|
case ACTIVITY_TYPE.LIMIT_PACKAGE_SHOP_WEEKLY://每周限购礼包，RMB购买礼包 17
|
|
{
|
|
activityData = await getPlayerLimitPackageData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.YUAN_BAO_SHOP://元宝商店 18
|
|
{
|
|
activityData = await getPlayerYuanbaoShopData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.MONTHLY_TICKET_1://月卡1 19
|
|
case ACTIVITY_TYPE.MONTHLY_TICKET_2://月卡2 20
|
|
{
|
|
activityData = await getPlayerMonthlyTicketData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.RECHARGE_MONEY://累计充值RMB活动 21
|
|
{
|
|
activityData = await getPlayerRechargeMoneyDataShow(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.DAILY_RMB_GIFTS://每日特惠RMB购买，一次性购买7天礼包 22
|
|
{
|
|
activityData = await getPlayerDailyRMBGiftsData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.TREASURE_HUNT://寻宝骑兵活动 23
|
|
{
|
|
let { huntActivityId, huntBeginTime, huntEndTime, huntRoundIndex } = await getTreasureHuntData(serverId, roleId);
|
|
activityData = await getPlayerTreasureHuntData(activityId, serverId, roleId, huntRoundIndex, huntBeginTime, huntEndTime);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.POP_UP_SHOP://弹出商店 24
|
|
{
|
|
activityData = await getPopUpShopDataShow(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.VIP_RECHARGE_MONEY://vip累计充值活动 26
|
|
{
|
|
activityData = await getPlayerVipRechargeMoneyData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.SEVEN_DAY://七天乐活动 27
|
|
case ACTIVITY_TYPE.FOURTEEN_DAY://十四天乐活动 28
|
|
case ACTIVITY_TYPE.COMMON_SEVEN_DAY://通用七天乐活动 29
|
|
{
|
|
activityData = await getPlayerSevenDaysData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.DAILY_MEAL://每日领取免费午饭、晚饭活动 30
|
|
{
|
|
activityData = await getPlayerDailyMealData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.DAILY_COIN://每日兑换铜币活动 31
|
|
{
|
|
activityData = await getPlayerDailyCoinData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.DAILY_GK://每日关卡（每日开启一关） 32
|
|
{
|
|
activityData = await getPlayerDailyGKData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.REFRESH_SHOP://通用的刷新商店（分页，可刷新，限制购买次数，支持rmb与资源兑换） 33
|
|
{
|
|
activityData = await getPlayerRefreshShopData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.REFRESH_TASK://通用的刷新任务（分页，可刷新，限制领取次数） 34
|
|
{
|
|
activityData = await getPlayerRefreshTaskData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.MONOPOLY://大富翁游戏 35
|
|
{
|
|
activityData = await getPlayerMonopolyData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.COMMON_SIGN_IN://通用签到 36
|
|
{
|
|
activityData = await getPlayerSignInData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.NEW_HERO_GIFTS://新将好礼(很多红包，用积分兑换一遍结束) 37
|
|
{
|
|
activityData = await getPlayerNewHeroGiftsData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.NEW_HERO_GK://新将演绎 (配置N个武将，每个武将有X个关卡；活动期间，*天(时间自定义)开启每个武将对应的一个关卡，只有第一次通关会获得奖励)
|
|
{
|
|
activityData = await getPlayerNewHeroGKData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.NEW_HERO_GACHA://新将擢迁（新武将抽取）
|
|
{
|
|
activityData = await getPlayerNewHeroGachaData(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.LUCKY_TURNTABLE://幸运转盘
|
|
{
|
|
activityData = await getPlayerLuckyTurntableDataShow(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.TIME_LIMIT_RANK: // 限时排行
|
|
{
|
|
activityData = await getTimeLimitRankDataShow(activityId, serverId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.TASK_PASS: // 限时排行
|
|
{
|
|
activityData = await getTaskPassDataShow(activityId, serverId, roleId);
|
|
break;
|
|
}
|
|
case ACTIVITY_TYPE.GUILD_PAY:
|
|
{
|
|
activityData = await getGuildPayDataShow(serverId, activityId, roleId, guildCode);
|
|
}
|
|
default: {
|
|
console.log('未知活动类型.........', activityType)
|
|
break;
|
|
}
|
|
}
|
|
if(activityData && activityData.canShow && !activityData.canShow()) {
|
|
return null
|
|
}
|
|
return activityData;
|
|
}
|
|
|
|
export async function getActivityById(activityId: number) {
|
|
let serverType = pinus.app.getServerType();
|
|
let activity: ActivityInRemote;
|
|
if(serverType == 'activity') {
|
|
activity = _getActivityById(activityId);
|
|
} else {
|
|
let servers = pinus.app.getServersByType('activity');
|
|
let server = getRandSingleEelm(servers);
|
|
activity = <ActivityInRemote>await pinus.app.rpc.activity.activityRemote.getActivityById.toServer(server.id, activityId);
|
|
}
|
|
return transActivityInRemoteToModelType(activity)
|
|
}
|
|
|
|
export async function getActivitiesByType(serverId: number, type: number) {
|
|
let serverType = pinus.app.getServerType();
|
|
let activities: ActivityInRemote[] = [];
|
|
if(serverType == 'activity') {
|
|
activities = _getActivitiesByType(serverId, type);
|
|
} else {
|
|
let servers = pinus.app.getServersByType('activity');
|
|
let server = getRandSingleEelm(servers);
|
|
activities = await pinus.app.rpc.activity.activityRemote.getActivitiesByType.toServer(server.id, serverId, type);
|
|
}
|
|
return activities.map(transActivityInRemoteToModelType);
|
|
}
|
|
|
|
export async function getActivities() {
|
|
let serverType = pinus.app.getServerType();
|
|
if(serverType == 'activity') {
|
|
return _getActivities();
|
|
} else {
|
|
let servers = pinus.app.getServersByType('activity');
|
|
let server = getRandSingleEelm(servers);
|
|
return <ActivityInRemote[]>await pinus.app.rpc.activity.activityRemote.getActivities.toServer(server.id);
|
|
}
|
|
}
|
|
|
|
export async function getActivityByServerId(serverId: number) {
|
|
let activities: ActivityInRemote[] = [];
|
|
let serverType = pinus.app.getServerType();
|
|
if(serverType == 'activity') {
|
|
activities = _getActivitiesByServerId(serverId);
|
|
} else {
|
|
let servers = pinus.app.getServersByType('activity');
|
|
let server = getRandSingleEelm(servers);
|
|
activities = await pinus.app.rpc.activity.activityRemote.getActivitiesByServerId.toServer(server.id, serverId);
|
|
}
|
|
return activities.map(transActivityInRemoteToModelType);
|
|
}
|
|
|
|
export function _getActivityById(activityId: number) {
|
|
return <ActivityInRemote>pinus.app.get('activities')?.get(activityId);
|
|
}
|
|
|
|
export function _getActivitiesByType(serverId: number, type: number) {
|
|
let activityByType = pinus.app.get('activityByType')?.get(serverId)?.get(type)||[];
|
|
let activities: Map<number, ActivityInRemote> = pinus.app.get('activities');
|
|
let result: ActivityInRemote[] = [];
|
|
for(let activityId of activityByType) {
|
|
let activity = activities.get(activityId);
|
|
if(activity && activity.beginTime <= Date.now() && activity.endTime >= Date.now()) {
|
|
result.push(activity);
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
export function _getActivitiesByServerId(serverId: number) {
|
|
let activityByServerId = pinus.app.get('activityByServer')?.get(serverId)||[]
|
|
let activities: Map<number, ActivityInRemote> = pinus.app.get('activities');
|
|
let result: ActivityInRemote[] = [];
|
|
for(let activityId of activityByServerId) {
|
|
let activity = activities.get(activityId);
|
|
if(activity && activity.beginTime <= Date.now()) {
|
|
result.push(activity);
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
export function _getActivities() {
|
|
try {
|
|
let activities = pinus.app.get('activities');
|
|
// console.log('***** activities', activities);
|
|
let result: ActivityInRemote[] = [];
|
|
for(let [_, activity] of activities) {
|
|
result.push(activity);
|
|
}
|
|
return result;
|
|
} catch(e) {
|
|
console.log('******** activity e', e)
|
|
}
|
|
}
|
|
|
|
|
|
export async function checkActivityEditable(activities: ActivityModelType[]) {
|
|
let now = new Date();
|
|
|
|
for(let activity of activities) {
|
|
if(!activity || (activity.beginTime < now && activity.endTime > now)) {
|
|
|
|
if(activity.type == ACTIVITY_TYPE.SIGN_IN || activity.type == ACTIVITY_TYPE.SIGN_IN_VIP) {
|
|
// 签到活动的不显示期内也可以编辑
|
|
let signInObj = new SignInData(activity, 0, 0);
|
|
if(signInObj.beginTime < now.getTime() && signInObj.endTime > now.getTime() ) {
|
|
return false;
|
|
}
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
|
|
export async function checkActivityGroupTypeWithId(groupId: number, activities: ActivityModelType[]) {
|
|
|
|
let activityGroup = await ActivityGroupModel.findGroupData(groupId);
|
|
if(!activityGroup) return false;
|
|
if(activityGroup.type != 0) {
|
|
return await checkActivityGroupType(activityGroup.type, activities);
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
|
|
export async function checkActivityGroupType(groupType: number, activities: ActivityModelType[]) {
|
|
if(groupType != 0) {
|
|
let activityGroupType = await ActivityGroupTypeModel.findByGroupType(groupType);
|
|
if(!activityGroupType) return false;
|
|
let dic = activityGroupType.activityTypes;
|
|
for(let { type } of activities) {
|
|
let index = dic.findIndex(cur => cur.activityType == type);
|
|
if(index == -1) {
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
/**
|
|
* 达成任务可活动活动积分
|
|
* @param type 任务类型，主线、每日、成就
|
|
* @param id
|
|
* @param point
|
|
* @param session
|
|
*/
|
|
export async function addActvityTaskPoint(type: number, id: number, session: BackendSession) {
|
|
let serverId: number = session.get('serverId');
|
|
let roleId: string = session.get('roleId');
|
|
let sid: string = session.get('sid');
|
|
let activityTaskPoint = await ActivityTaskPointModel.findData(type, id);
|
|
let result: pushActivityInter[] = [];
|
|
for (let { activityId, activityType, point } of activityTaskPoint) {
|
|
console.log('##### activityTaskPoint:', activityId, activityType, point)
|
|
if(activityType == ACTIVITY_TYPE.NEW_HERO_GIFTS) { // 新武将活动
|
|
let totalPoint = await newHeroGiftPoint(serverId, activityId, roleId, point);
|
|
result.push({ activityId, activityType, param: { totalPoint } });
|
|
} else if (activityType == ACTIVITY_TYPE.TASK_PASS) {
|
|
let totalPoint = await addTaskPassPoint(serverId, activityId, roleId, point);
|
|
result.push({ activityId, activityType, param: { totalPoint } });
|
|
} else {
|
|
break;
|
|
}
|
|
}
|
|
await pushActivities(result, roleId, sid);
|
|
}
|
|
|
|
|
|
interface pushActivityParamInter {
|
|
ticketCnt?: number; // 木签活动的签数(type21)
|
|
totalPoint?: number; // 新将好礼（type37）和战令（type42）更新后的积分
|
|
payMemberCnt?: number; // 军团充值活动，你的军团充值的人数
|
|
payMember?: string; // 军团充值活动，充值人员名字，添加到payRecord里面
|
|
payRecord?: string[]; // 军团全部充值人名字
|
|
popUpShopItems?: PopUpShopItemShow[]; // 弹出礼包
|
|
}
|
|
|
|
export interface pushActivityInter {
|
|
activityId: number,
|
|
activityType: number,
|
|
param: pushActivityParamInter;
|
|
}
|
|
|
|
export async function pushSingleActivity(activityId: number, activityType: number, param: pushActivityParamInter, roleId: string, sid?: string) {
|
|
await pushActivities([{ activityId, activityType, param }], roleId, sid);
|
|
}
|
|
|
|
export async function pushActivities(arr: pushActivityInter[], roleId: string, sid?: string) {
|
|
if(!sid) {
|
|
let onlineUser = await getRoleOnlineInfo(roleId);
|
|
sid = onlineUser.sid;
|
|
}
|
|
if(!!sid && arr.length > 0) {
|
|
sendMessageToUserWithSuc(roleId, PUSH_ROUTE.ACTIVITY_UPDATE, { activities: arr }, sid);
|
|
}
|
|
return arr
|
|
}
|
|
|
|
export async function pushActivitiesToGuild(arr: pushActivityInter[], guildCode: string) {
|
|
if(arr.length > 0) await sendMessageToGuildWithSuc(guildCode, PUSH_ROUTE.ACTIVITY_UPDATE, { activities: arr })
|
|
} |