部分公共代码db和const放到shared目录
This commit is contained in:
liangtongchuan
12
shared/consts/consts.ts
Normal file
12
shared/consts/consts.ts
Normal file
@@ -0,0 +1,12 @@
|
||||
export const TURBO_CORE_URL = 'https://coresrv.tgamebox.cn';
|
||||
export const APP_ID = 'AXaXmIHPs9eONvzrBesD8aSKQNXYdALF';
|
||||
export const TURBO_PARM_SECRET = 'ipqw05du6ob4x130w89t31yrqd6xs005zzltcmg2zpqnvrjp1s';
|
||||
|
||||
export const ENCRYPT_IV = 'f7182j5f04e377ux';
|
||||
export const ENCRYPT_KEY = 'fiqaxijabbantusmprc234fj';
|
||||
|
||||
export const AUTH_SMS_CNT_PER_DAY = 8;
|
||||
|
||||
export const COUNTER = {
|
||||
UID: 'uid',
|
||||
};
|
||||
24
shared/db/BaseModel.ts
Normal file
24
shared/db/BaseModel.ts
Normal file
@@ -0,0 +1,24 @@
|
||||
import { prop, pre } from '@typegoose/typegoose';
|
||||
|
||||
/**
|
||||
* BaseModel
|
||||
*/
|
||||
@pre<BaseModel>('save', function(next) {
|
||||
if (!this.createdAt || this.isNew) {
|
||||
this.createdAt = this.updatedAt = new Date();
|
||||
} else {
|
||||
this.updatedAt = new Date();
|
||||
}
|
||||
next();
|
||||
})
|
||||
|
||||
export default class BaseModel {
|
||||
|
||||
_id?: string
|
||||
|
||||
@prop()
|
||||
createdAt: Date
|
||||
|
||||
@prop()
|
||||
updatedAt: Date
|
||||
}
|
||||
23
shared/db/Counter.ts
Normal file
23
shared/db/Counter.ts
Normal file
@@ -0,0 +1,23 @@
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop } from '@typegoose/typegoose';
|
||||
|
||||
/**
|
||||
* 自增 ID
|
||||
*/
|
||||
@index({ name: 1 })
|
||||
export default class Counter extends BaseModel {
|
||||
|
||||
@prop({ required: true })
|
||||
name: string;
|
||||
|
||||
@prop({ required: true, default: 1 })
|
||||
seq: number;
|
||||
|
||||
public static async getNewCounter(name: string, lean = true) {
|
||||
const counter = await CounterModel.findOneAndUpdate({ name }, { $inc: { seq: 1 } }, { new: true, upsert: true }).lean(lean);
|
||||
return counter?.seq;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
export const CounterModel = getModelForClass(Counter);
|
||||
60
shared/db/Equip.ts
Normal file
60
shared/db/Equip.ts
Normal file
@@ -0,0 +1,60 @@
|
||||
import { COUNTER } from './../consts/consts';
|
||||
import { CounterModel } from './Counter';
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop } from '@typegoose/typegoose';
|
||||
|
||||
|
||||
@index({ roleId: 1, hid: 1, eid: 1 })
|
||||
@index({ seqId: 1 })
|
||||
export default class Equip extends BaseModel {
|
||||
@prop({ required: true })
|
||||
roleId: string; // 角色 id
|
||||
@prop({ required: true })
|
||||
roleName: string; // 角色名称
|
||||
|
||||
@prop({ required: true })
|
||||
eid: number; // 装备 id
|
||||
@prop({ required: true })
|
||||
type: number; // 装备类型
|
||||
@prop({ required: true })
|
||||
eName: string; // 装备名称
|
||||
@prop({ required: true })
|
||||
seqId: number; // 装备表自增 id
|
||||
@prop({ required: false })
|
||||
hid: number; // 装备此装备的武将 id
|
||||
|
||||
@prop({ required: true, default: 1 })
|
||||
lv: number; // 强化等级
|
||||
@prop({ required: false, default: [] })
|
||||
randSe: [{ // 强化随机属性
|
||||
seType: number; // 属性类型
|
||||
value: number; // 属性数值
|
||||
}];
|
||||
|
||||
@prop({ required: true, default: 0 })
|
||||
randRange: number; // 物攻策攻数值浮动上下限变化率，浮点数
|
||||
@prop({ required: true, default: 0 })
|
||||
initHoleCnt: number; // 初始珠宝孔位个数
|
||||
@prop({ required: true, default: [] })
|
||||
holes: [{
|
||||
id: number; // 宝石 id，待定，也可能是 type + lv
|
||||
lv: number; // 宝石等级
|
||||
}];
|
||||
|
||||
public static async findbyRole(roleId: string, lean = true) {
|
||||
const equips = await EquipModel.find({ roleId }).lean(lean);
|
||||
return equips;
|
||||
}
|
||||
|
||||
public static async createEquip(equipInfo: {roleId: string, roleName: string, eid: number, seqId: number, type: number, eName: string}, lean = true) {
|
||||
const equip = await EquipModel.findOneAndUpdate({ seqId: equipInfo.seqId }, equipInfo, {upsert: true, new: true}).lean();
|
||||
return equip;
|
||||
}
|
||||
|
||||
public static async putOn(hid: number, equipId: string, lean = true) {
|
||||
const equip = await EquipModel.findOneAndUpdate({ _id: equipId }, {hid}, {new: true});
|
||||
return equip;
|
||||
}
|
||||
}
|
||||
|
||||
export const EquipModel = getModelForClass(Equip);
|
||||
74
shared/db/Game.ts
Normal file
74
shared/db/Game.ts
Normal file
@@ -0,0 +1,74 @@
|
||||
import { APP_ID } from '../../game-server/app/consts/consts';
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop } from '@typegoose/typegoose';
|
||||
|
||||
class ServerInfo {
|
||||
@prop({ required: true })
|
||||
name: string;
|
||||
|
||||
@prop({ required: true })
|
||||
host: string;
|
||||
|
||||
@prop({ required: false })
|
||||
port: number;
|
||||
|
||||
@prop({ required: true })
|
||||
status: number;
|
||||
|
||||
@prop({ required: true })
|
||||
createTime: Date;
|
||||
|
||||
@prop({ required: true })
|
||||
serverType: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏字段接口
|
||||
*/
|
||||
@index({ id: 1 })
|
||||
export default class Game extends BaseModel {
|
||||
|
||||
@prop({ required: true })
|
||||
id: number;
|
||||
|
||||
@prop({ required: true })
|
||||
name: string;
|
||||
|
||||
@prop({ required: true })
|
||||
nameEn: string;
|
||||
|
||||
@prop({ required: true })
|
||||
des: string;
|
||||
|
||||
@prop({ required: true })
|
||||
serverList: Array<ServerInfo>;
|
||||
|
||||
@prop({ required: true })
|
||||
iconUrl: string;
|
||||
|
||||
@prop({ required: true })
|
||||
version: string;
|
||||
|
||||
@prop({ required: true })
|
||||
versionCode: number;
|
||||
|
||||
public static async getServerListByType(serverType: string) {
|
||||
let game = await GameModel.findOne().lean();
|
||||
if (!game) {
|
||||
const serverInfo: ServerInfo = { name: '常山少年', host: 'pinus_test.trgame.cn', port: 3014, status: 1, createTime: new Date(), serverType: 'official' };
|
||||
const iconUrl = `https://download.tgamebox.cn/avatar/${APP_ID}/1.png`;
|
||||
game = await GameModel.findOneAndUpdate(
|
||||
{},
|
||||
{ id: 1, name: '赵云传', nameEn: 'zyz', des: '牛逼的战棋', iconUrl, version: '0.0.1', versionCode: 1, $push: { serverList: serverInfo } },
|
||||
{ upsert: true, new: true },
|
||||
).lean();
|
||||
}
|
||||
console.log(serverType, game);
|
||||
let serverList: Array<ServerInfo> = game ? game.serverList : [];
|
||||
serverList = serverList.filter(item => { return item.serverType === serverType; });
|
||||
console.log(serverType, serverList);
|
||||
return serverList;
|
||||
}
|
||||
}
|
||||
|
||||
export const GameModel = getModelForClass(Game);
|
||||
71
shared/db/Hero.ts
Normal file
71
shared/db/Hero.ts
Normal file
@@ -0,0 +1,71 @@
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop, arrayProp, Ref, mongoose } from '@typegoose/typegoose';
|
||||
import Equip from './Equip';
|
||||
|
||||
/**
|
||||
* 英雄表
|
||||
*/
|
||||
@index({ roleId: 1, hid: 1 })
|
||||
export default class Hero extends BaseModel {
|
||||
|
||||
@prop({ required: true })
|
||||
roleId: string; // 角色 id
|
||||
@prop({ required: true })
|
||||
roleName: string; // 角色名称
|
||||
|
||||
@prop({ required: true })
|
||||
hid: number; // 武将 id
|
||||
@prop({ required: true })
|
||||
hName: string; // 武将名
|
||||
@prop({ required: true })
|
||||
seqId: number; // 武将表自增 id
|
||||
|
||||
@prop({ required: true, default: 0 })
|
||||
exp: number; // 经验值
|
||||
@prop({ required: true, default: 1 })
|
||||
lv: number; // 武将等级
|
||||
@prop({ required: true, default: 100 })
|
||||
ce: number; // 武将战力
|
||||
|
||||
@prop({ required: true })
|
||||
star: number; // 星级
|
||||
@prop({ required: true, default: 1 })
|
||||
rank: number; // 阶数
|
||||
@prop({ required: true, default: 0 })
|
||||
favour: number; // 好感度
|
||||
@prop({ required: true, default: 1 })
|
||||
favourLv: number; // 好感等级
|
||||
@prop({ required: true, default: [] })
|
||||
conections: [{ // 羁绊
|
||||
id: number; // 羁绊编号
|
||||
name: string; // 羁绊名称
|
||||
valid: boolean; // 是否开启
|
||||
}];
|
||||
@prop({ required: true, default: [] })
|
||||
skins: [{ // 皮肤
|
||||
id: number; // id
|
||||
enable: boolean; // 是否装备
|
||||
}]
|
||||
|
||||
@prop({ ref: Equip, type: mongoose.Schema.Types.ObjectId })
|
||||
equips: Ref<Equip>[]; // 武将装备引用数组
|
||||
|
||||
public static async findByRole(roleId: string, lean = true) {
|
||||
const heros = await HeroModel.find({ roleId }).populate('equips').lean(lean);
|
||||
return heros || [];
|
||||
}
|
||||
|
||||
public static async addEquip(roleId: string, hid: number, equipId: string, lean = true) {
|
||||
const hero = await HeroModel.findOneAndUpdate({ roleId, hid }, {$push: {equips: equipId}}, {new: true}).lean(lean);
|
||||
await Equip.putOn(hero.hid, equipId);
|
||||
return hero;
|
||||
}
|
||||
|
||||
public static async createHero(heroInfo: {roleId: string, roleName: string, hid: number, hName: string, seqId: number}, lean = true) {
|
||||
const hero = await HeroModel.findOneAndUpdate({roleId: heroInfo.roleId, hid: heroInfo.hid}, heroInfo, {upsert: true, new: true}).lean(lean);
|
||||
return hero;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
export const HeroModel = getModelForClass(Hero);
|
||||
105
shared/db/Role.ts
Normal file
105
shared/db/Role.ts
Normal file
@@ -0,0 +1,105 @@
|
||||
import { CounterModel } from './Counter';
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop } from '@typegoose/typegoose';
|
||||
import User from './User';
|
||||
|
||||
/**
|
||||
* 角色字段接口
|
||||
*/
|
||||
@index({ roleId: 1 })
|
||||
// @index({ userInfo.uid: 1, serverId: 1 })
|
||||
export default class Role extends BaseModel {
|
||||
|
||||
@prop({ required: true })
|
||||
userInfo: User;
|
||||
|
||||
@prop({ required: true })
|
||||
seqId: number;
|
||||
|
||||
@prop({ required: true })
|
||||
roleId: string; // 角色 id，生成编码
|
||||
@prop({ required: true })
|
||||
roleName: string; // 角色名
|
||||
@prop({ required: true })
|
||||
serverType: string; // 服务器类型
|
||||
@prop({ required: true })
|
||||
serverId: number; // 区服 id
|
||||
@prop({ required: true, default: false })
|
||||
blocked: boolean; // 是否屏蔽
|
||||
@prop({ required: true })
|
||||
code: string; // 邀请码
|
||||
|
||||
@prop({ required: true, default: 0 })
|
||||
exp: number; // 经验值
|
||||
@prop({ required: true, default: 1 })
|
||||
lv: number; // 主公等级
|
||||
@prop({ required: true, default: 0 })
|
||||
ce: number; // 总战力
|
||||
@prop({ required: true, default: 100 })
|
||||
tili: number; // 体力值
|
||||
|
||||
@prop({ required: true, default: 0 })
|
||||
vLv: number; // VIP 等级
|
||||
@prop({ required: true, default: 100 })
|
||||
gold: number; // 总金币
|
||||
@prop({ required: true, default: 0 })
|
||||
paidGold: number; // 支付所得金币
|
||||
@prop({ required: true, default: 100 })
|
||||
giftGold: number; // 赠送所得金币
|
||||
@prop({ required: true, default: 0 })
|
||||
totalPay: number; // 总支付金额
|
||||
@prop({ required: true, default: 0 })
|
||||
totalBuy: number; // 总金币购买
|
||||
@prop({ required: true, default: 0 })
|
||||
totalCost: number; // 金币总花费
|
||||
@prop({ required: true, default: [] })
|
||||
payRecord: [{ // 支付记录
|
||||
id: string; // 购买项 product id
|
||||
cnt: number; // 购买次数
|
||||
}];
|
||||
|
||||
@prop({ required: true, default: [] })
|
||||
consumeGoods: [{ // 消耗品
|
||||
id: number; // id
|
||||
cnt: number; // 数量
|
||||
}];
|
||||
@prop({ required: true, default: [] })
|
||||
souls: [{ // 将魂
|
||||
id: number; // 武将 id
|
||||
cnt: number; // 数量
|
||||
}];
|
||||
@prop({ required: true, default: [] })
|
||||
pieces: [{ // 装备碎片
|
||||
id: number; // 装备 id
|
||||
cnt: number; // 数量
|
||||
}];
|
||||
@prop({ required: true, default: [] })
|
||||
jewels: [{ // 珠宝
|
||||
id: number; // 待定，也可能是 type + lv
|
||||
cnt: number; // 数量
|
||||
}];
|
||||
|
||||
@prop({ required: true, default: [] })
|
||||
warStar: [{ // 关卡星级
|
||||
id: number; // 关卡 id
|
||||
star: number; // 星级
|
||||
}];
|
||||
|
||||
@prop({ required: true, default: 1 })
|
||||
loginCnt: number; // 登录次数
|
||||
@prop({ required: true })
|
||||
createTime: Date; // 创建时间
|
||||
@prop({ required: true })
|
||||
loginTime: Date; // 更新 / 登录时间
|
||||
|
||||
public static async findByUid(uid: number, serverId: number, lean = true) {
|
||||
const role = await RoleModel.findOne({ 'userInfo.uid': uid, serverId }).lean(lean);
|
||||
return role;
|
||||
}
|
||||
|
||||
public static async createRole(userInfo: User, serverType: string, serverId: number, roleName: string) {
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
export const RoleModel = getModelForClass(Role);
|
||||
64
shared/db/Sms.ts
Normal file
64
shared/db/Sms.ts
Normal file
@@ -0,0 +1,64 @@
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop } from '@typegoose/typegoose';
|
||||
const moment = require('moment');
|
||||
|
||||
/**
|
||||
* 短信字段接口
|
||||
*/
|
||||
@index({ tel: 1 })
|
||||
export default class Sms extends BaseModel {
|
||||
|
||||
@prop({ required: true })
|
||||
tel: string;
|
||||
|
||||
@prop({ required: true })
|
||||
telHash: string;
|
||||
|
||||
@prop({ required: true })
|
||||
code: string;
|
||||
|
||||
@prop({ required: true })
|
||||
used: boolean;
|
||||
|
||||
@prop({ required: true })
|
||||
updateTime: Date;
|
||||
|
||||
@prop({ required: true })
|
||||
countToday: number;
|
||||
|
||||
public static async findByTel(tel: string, lean = true) {
|
||||
const sms = await smsModel.findOne({ tel }).lean(lean);
|
||||
return sms;
|
||||
}
|
||||
|
||||
public static async updateByTel(tel: string, code: string, used: boolean, updateTime: Date, countToday: number, lean = true) {
|
||||
await smsModel.findOneAndUpdate({ tel }, { code, used, updateTime, countToday }, { upsert: true }).lean(lean);
|
||||
}
|
||||
|
||||
public static async validateSms(tel: string, code: string, lean = true) {
|
||||
const record = await smsModel.findOneAndUpdate({ tel, code, used: false }, { used: true }).lean(lean);
|
||||
return !!record;
|
||||
}
|
||||
|
||||
public async timeLimit(interval: number) {
|
||||
if (Date.now() > this.updateTime.getTime() + interval) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
public async cntLimit(cnt: number) {
|
||||
console.log('hasSendToday:', this.hasSendToday());
|
||||
if (await this.hasSendToday() && this.countToday >= cnt) {
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
public async hasSendToday() {
|
||||
console.log(moment(this.updateTime).format('YYYY-MM-DD'), moment(Date.now()).format('YYYY-MM-DD'));
|
||||
return moment(this.updateTime).format('YYYY-MM-DD') === moment(Date.now()).format('YYYY-MM-DD');
|
||||
}
|
||||
}
|
||||
|
||||
export const smsModel = getModelForClass(Sms);
|
||||
91
shared/db/User.ts
Normal file
91
shared/db/User.ts
Normal file
@@ -0,0 +1,91 @@
|
||||
import { COUNTER } from './../consts/consts';
|
||||
import { CounterModel } from './Counter';
|
||||
import BaseModel from './BaseModel';
|
||||
import { index, getModelForClass, prop } from '@typegoose/typegoose';
|
||||
|
||||
/**
|
||||
* 用户字段接口
|
||||
*/
|
||||
@index({ tel: 1 })
|
||||
@index({ uid: 1 })
|
||||
export default class User extends BaseModel {
|
||||
|
||||
@prop({ required: true })
|
||||
uid: number;
|
||||
|
||||
@prop({ required: true })
|
||||
username: string;
|
||||
|
||||
@prop({ required: true })
|
||||
token: string;
|
||||
|
||||
@prop({ required: true })
|
||||
tel: string;
|
||||
|
||||
@prop({ required: true })
|
||||
telHash: string;
|
||||
|
||||
@prop({ required: true })
|
||||
channelId: string;COUNTER
|
||||
|
||||
@prop({ required: true })
|
||||
guestId: string;
|
||||
|
||||
// 最后登录 IP
|
||||
@prop({ required: true })
|
||||
ip: string;
|
||||
|
||||
@prop({ required: true })
|
||||
lastLoginTime: Date;
|
||||
|
||||
@prop({ required: true })
|
||||
createTime: Date;
|
||||
|
||||
platform: string;
|
||||
@prop({ required: true })
|
||||
platforms: [{
|
||||
platform: string; // 平台：ios, android, web, pc
|
||||
unionId: string; // 用户标识
|
||||
}];
|
||||
|
||||
@prop({ required: true })
|
||||
pkgName: string;
|
||||
|
||||
// 服务器类型：official, channel, ios, oversea
|
||||
@prop({ required: true })
|
||||
serverType: string;
|
||||
|
||||
// 账号是否被屏蔽
|
||||
@prop({ required: true })
|
||||
blocked: boolean;
|
||||
|
||||
public static async updateToken(tel: string, token: string, platform: string, pkgName: string, serverType: string, lean = true) {
|
||||
let user = await UserModel.findOne({ tel }).lean();
|
||||
const curTime: Date = new Date();
|
||||
let update = {};
|
||||
if (!user) {
|
||||
const uid = await CounterModel.getNewCounter(COUNTER.UID);
|
||||
update = Object.assign(update, { platform, pkgName, serverType, createTime: curTime, uid, username: `用户${uid}` });
|
||||
}
|
||||
update = Object.assign(update, { token, lastLoginTime: curTime });
|
||||
user = await UserModel.findOneAndUpdate({ tel }, update, { upsert: true, new: true }).lean(lean);
|
||||
return user;
|
||||
}
|
||||
|
||||
public static async findUserByToken(token: string, lean = true) {
|
||||
const user = await UserModel.findOne({ token }).select('uid token').lean(lean);
|
||||
return user;
|
||||
}
|
||||
|
||||
public static async findUserByTel(tel: string, lean = true) {
|
||||
const user = await UserModel.findOne({ tel }).select('uid tel').lean(lean);
|
||||
return user;
|
||||
}
|
||||
|
||||
public static async findUserByUid(uid: number, lean = true) {
|
||||
const user = await UserModel.findOne({ uid }).select('uid tel').lean(lean);
|
||||
return user;
|
||||
}
|
||||
}
|
||||
|
||||
export const UserModel = getModelForClass(User);
|
||||
Reference in New Issue
Block a user