xinyuxi/ZYZ
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

✨ feat(db): 修改role表数据库操作方式

Browse Source
This commit is contained in:
liangtongchuan
2023-05-06 15:48:16 +08:00
parent 2ff9f8c5f1
commit e65efa4192
79 changed files with 423 additions and 423 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
game-server/app/servers/role/handler/roleHandler.ts
View File

@@ -1,5 +1,5 @@
import { STATUS } from '../../../consts/statusCode';
import { RoleModel, RoleUpdate } from './../../../db/Role';
import Role, { RoleUpdate } from './../../../db/Role';
import { HeroModel, HeroType, HeroUpdate } from '../../../db/Hero';
import { resResult, decodeIdCntArrayStr, parseGoodStr, genCode } from '../../../pubUtils/util';
import { Application, BackendSession, pinus, HandlerService, } from 'pinus';
@@ -48,14 +48,14 @@ export class RoleHandler {
let { roleName } = msg;
let role = await RoleModel.findByRoleId(roleId, 'roleName hasInit title teraphs lv', true);
let role = await Role.findByRoleId(roleId, 'roleName hasInit title teraphs lv', true);
if (role.hasInit) return resResult(STATUS.ROLE_HAS_INIT);
let checkName = await RoleModel.checkName(roleName, serverId);
let checkName = await Role.checkName(roleName, serverId);
if (checkName) return resResult(STATUS.NAME_HAS_USED);
let { resultHeroes: heroes } = await createHeroes(roleId, roleName, sid, serverId, DEFAULT_HEROES.map(hid => ({hid, count: 1})), { roleName, hasInit: true, title: role.title, teraphs: role.teraphs, lv: role.lv });
// role = await RoleModel.updateRoleInfo(roleId, { roleName, hasInit: true }); // 在算战力的时候一起更新
// role = await Role.updateRoleInfo(roleId, { roleName, hasInit: true }); // 在算战力的时候一起更新
session.set('roleName', roleName);
session.push('roleName', () => { });
@@ -74,7 +74,7 @@ export class RoleHandler {
async getRoleInfo(msg: { targetRoleId: string }, session: BackendSession) {
let { targetRoleId } = msg;
let { roleId, roleName, head = EXTERIOR.EXTERIOR_FACE, frame = EXTERIOR.EXTERIOR_FACECASE, spine = EXTERIOR.EXTERIOR_APPEARANCE, ce = 0, topLineup, topLineupCe = 0 } = await RoleModel.findByRoleId(targetRoleId);
let { roleId, roleName, head = EXTERIOR.EXTERIOR_FACE, frame = EXTERIOR.EXTERIOR_FACECASE, spine = EXTERIOR.EXTERIOR_APPEARANCE, ce = 0, topLineup, topLineupCe = 0 } = await Role.findByRoleId(targetRoleId);
return resResult(STATUS.SUCCESS, { roleId, roleName, head, frame, spine, ce, topLineup, topLineupCe });
}
@@ -85,7 +85,7 @@ export class RoleHandler {
const serverId = session.get('serverId');
let role = await RoleModel.findByRoleId(roleId);
let role = await Role.findByRoleId(roleId);
let { title } = role;
let titleInfo = getTitle(title + 1);
@@ -115,7 +115,7 @@ export class RoleHandler {
let serverId: number = session.get('serverId');
let role = await RoleModel.findByRoleId(roleId, 'roleId teraphs gold coin');
let role = await Role.findByRoleId(roleId, 'roleId teraphs gold coin');
let teraphs = role.teraphs;
let index = findIndex(teraphs, { id });
if (index < 0)
@@ -149,7 +149,7 @@ export class RoleHandler {
const serverId = session.get('serverId');
let role = await RoleModel.findByRoleId(roleId);
let role = await Role.findByRoleId(roleId);
let teraphs = role.teraphs;
let index = findIndex(teraphs, { id });
if (index < 0)
@@ -353,7 +353,7 @@ export class RoleHandler {
return resResult(STATUS.LINEUP_MAX);
}
let role = await RoleModel.updateRoleInfo(roleId, { showLineup });
let role = await Role.updateRoleInfo(roleId, { showLineup });
let r = new Rank(REDIS_KEY.SHOW_LINEUP, {});
await r.generParamAndSet(REDIS_KEY.SHOW_LINEUP, { roleId }, { role });
@@ -368,7 +368,7 @@ export class RoleHandler {
if(isGoodsHidden(id)) return resResult(STATUS.ITEM_IS_HIDDEN);
let role = await RoleModel.findByRoleId(roleId, ROLE_SELECT.GET_HEADS);
let role = await Role.findByRoleId(roleId, ROLE_SELECT.GET_HEADS);
if (!role) return resResult(STATUS.ROLE_NOT_FOUND);
let { heads } = role;
@@ -383,7 +383,7 @@ export class RoleHandler {
}
curHead.enable = true;
role = await RoleModel.updateRoleInfo(roleId, { heads });
role = await Role.updateRoleInfo(roleId, { heads });
await updateUserInfo(REDIS_KEY.USER_INFO, roleId, [{ field: 'head', value: id }]);
if(role.isGuildLeader) {
await updateUserInfo(REDIS_KEY.GUILD_INFO, guildCode, [{ field: 'leader', value: new GuildLeader(role) }]);
@@ -400,7 +400,7 @@ export class RoleHandler {
if(isGoodsHidden(id)) return resResult(STATUS.ITEM_IS_HIDDEN);
let role = await RoleModel.findByRoleId(roleId, ROLE_SELECT.GET_HEADS);
let role = await Role.findByRoleId(roleId, ROLE_SELECT.GET_HEADS);
if (!role) return resResult(STATUS.ROLE_NOT_FOUND);
let { frames } = role;
@@ -415,7 +415,7 @@ export class RoleHandler {
}
curFrame.enable = true;
role = await RoleModel.updateRoleInfo(roleId, { frames });
role = await Role.updateRoleInfo(roleId, { frames });
await updateUserInfo(REDIS_KEY.USER_INFO, roleId, [{ field: 'frame', value: id }]);
if(role.isGuildLeader) {
await updateUserInfo(REDIS_KEY.GUILD_INFO, guildCode, [{ field: 'leader', value: new GuildLeader(role) }]);
@@ -432,7 +432,7 @@ export class RoleHandler {
if(isGoodsHidden(id)) return resResult(STATUS.ITEM_IS_HIDDEN);
let role = await RoleModel.findByRoleId(roleId, ROLE_SELECT.GET_HEADS);
let role = await Role.findByRoleId(roleId, ROLE_SELECT.GET_HEADS);
if (!role) return resResult(STATUS.ROLE_NOT_FOUND);
let { spines } = role;
@@ -447,7 +447,7 @@ export class RoleHandler {
}
curSpine.enable = true;
role = await RoleModel.updateRoleInfo(roleId, { spines });
role = await Role.updateRoleInfo(roleId, { spines });
await updateUserInfo(REDIS_KEY.USER_INFO, roleId, [{ field: 'spine', value: id }]);
if(role.isGuildLeader) {
await updateUserInfo(REDIS_KEY.GUILD_INFO, guildCode, [{ field: 'leader', value: new GuildLeader(role) }]);
@@ -465,17 +465,17 @@ export class RoleHandler {
let sid = session.get('sid');
if(!roleName) return resResult(STATUS.WRONG_PARMS);
let checkName = await RoleModel.checkName(roleName, serverId);
let checkName = await Role.checkName(roleName, serverId);
if (checkName) return resResult(STATUS.NAME_HAS_USED);
let role = await RoleModel.findByRoleId(roleId, 'renameCnt');
let role = await Role.findByRoleId(roleId, 'renameCnt');
let costGold = role.renameCnt >= dicParam.NAMEPLATE.NAMEPLATE_FREECOST? dicParam.NAMEPLATE.NAMEPLATE_FEECOST: 0;
if(costGold > 0) {
let result = await handleCost(roleId, sid, [getGoldObject(costGold)], ITEM_CHANGE_REASON.RENAME);
if(!result) return resResult(STATUS.BATTLE_GOLD_NOT_ENOUGH);
}
role = await RoleModel.incRoleInfo(roleId, { renameCnt: 1 }, { roleName });
role = await Role.incRoleInfo(roleId, { renameCnt: 1 }, { roleName });
session.set('roleName', role.roleName);
session.push('roleName', () => { });
await updateUserInfo(REDIS_KEY.USER_INFO, roleId, [{ field: 'roleName', value: roleName }]);
@@ -498,7 +498,7 @@ export class RoleHandler {
if(ids == undefined || ids.length <= 0) {
return resResult(STATUS.WRONG_PARMS);
}
let role = await RoleModel.saveGuide(roleId, ids);
let role = await Role.saveGuide(roleId, ids);
return resResult(STATUS.SUCCESS, {
guide: role.guide
});
@@ -508,7 +508,7 @@ export class RoleHandler {
const roleId = session.get('roleId');
const { isClosePush } = msg;
let role = await RoleModel.setPushMsgOpen(roleId, isClosePush);
let role = await Role.setPushMsgOpen(roleId, isClosePush);
if(!role) return resResult(STATUS.ROLE_NOT_FOUND);
return resResult(STATUS.SUCCESS, {
isClosePush: role.isClosePush
@@ -519,7 +519,7 @@ export class RoleHandler {
const roleId = session.get('roleId');
const { hasComment } = msg;
let role = await RoleModel.setHasComment(roleId, hasComment);
let role = await Role.setHasComment(roleId, hasComment);
if(!role) return resResult(STATUS.ROLE_NOT_FOUND);
return resResult(STATUS.SUCCESS, {
hasComment: role.hasComment
@@ -581,7 +581,7 @@ export class RoleHandler {
}
let roleId = session.get('roleId');
let role = await RoleModel.findByRoleId(roleId);
let role = await Role.findByRoleId(roleId);
if(!role) return resResult(STATUS.ROLE_NOT_FOUND);
if(role.hasInit) {
await deletRole(roleId);
@@ -598,7 +598,7 @@ export class RoleHandler {
let roleId = session.get('roleId');
let roleLvInfo = gameData.kingexp.get(lv - 1);
let role = await RoleModel.updateRoleInfo(roleId, { lv, exp: roleLvInfo.sum });
let role = await Role.updateRoleInfo(roleId, { lv, exp: roleLvInfo.sum });
return resResult(STATUS.SUCCESS, { lv: role.lv });
}
@@ -610,7 +610,7 @@ export class RoleHandler {
if (magicWord !== DEBUG_MAGIC_WORD) {
return resResult(STATUS.TOKEN_ERR);
}
let role = await RoleModel.updateRoleInfo(roleId, params);
let role = await Role.updateRoleInfo(roleId, params);
return resResult(STATUS.SUCCESS, { role });
@@ -624,7 +624,7 @@ export class RoleHandler {
if (magicWord !== DEBUG_MAGIC_WORD) {
return resResult(STATUS.TOKEN_ERR);
}
let role = await RoleModel.findByRoleId(roleId);
let role = await Role.findByRoleId(roleId);
let user = await UserModel.findUserByUid(role.userInfo.uid);
reportTAEvent(roleId, 'test', { serverId }, user.ip);