83 lines
3.4 KiB
TypeScript
83 lines
3.4 KiB
TypeScript
import {Application, BackendSession, pinus} from 'pinus';
|
||
import { RoleModel } from '../../../db/Role';
|
||
import { EventRecordModel } from '../../../db/EventRecord';
|
||
import { getEvent } from '../../../services/eventSercive';
|
||
import { resResult } from '../../../pubUtils/util';
|
||
import { STATUS } from '../../../consts/statusCode';
|
||
import { GMMailModel } from '../../../db/GMMail';
|
||
import { setGmMails } from '../../../pubUtils/gmData/gmDataUtil';
|
||
import { getRoleOnlineInfo } from '../../../services/redisService';
|
||
export default function(app: Application) {
|
||
return new GmHandler(app);
|
||
}
|
||
|
||
export class GmHandler {
|
||
constructor(private app: Application) {
|
||
}
|
||
|
||
async pushEvent(msg: { uid: number, serverId: number }, session: BackendSession) {
|
||
let sid = session.get('sid');
|
||
|
||
let { uid, serverId } = msg;
|
||
let role = await RoleModel.findByUid(uid, serverId);
|
||
if(!role) return resResult(STATUS.GM_ROLE_NOT_FOUND);
|
||
let {roleId, roleName, eventStatus } = role;
|
||
|
||
let channelService = this.app.get('channelService');
|
||
let channel = channelService.getChannel(roleId, true);
|
||
let users = channel.getMembers();
|
||
if (users.indexOf(roleId) === -1) {
|
||
channel.add(roleId, sid);
|
||
}
|
||
|
||
let event = await getEvent(eventStatus, roleId, roleName);
|
||
|
||
let tsid = channel.getMember(roleId)['sid'];
|
||
channelService.pushMessageByUids('onSpecialEvent', resResult(STATUS.SUCCESS, { event }), [{
|
||
uid: roleId,
|
||
sid: tsid
|
||
}]);
|
||
return resResult(STATUS.SUCCESS, { list: event });
|
||
}
|
||
|
||
async clearEvent(msg: { }, session: BackendSession) {
|
||
let roleId = session.get('roleId');
|
||
|
||
await EventRecordModel.deleteAccount(roleId);
|
||
return resResult(STATUS.SUCCESS);
|
||
}
|
||
|
||
|
||
async pushMessage(msg: { uid: number, serverId: number, eventName: string, message: string }, session: BackendSession) {
|
||
|
||
let { uid, serverId, eventName, message } = msg;
|
||
|
||
let content = {};
|
||
try {
|
||
content = JSON.parse(message);
|
||
} catch(e) {
|
||
return resResult(STATUS.GM_JSON_FORMAT_ERR);
|
||
}
|
||
console.log(uid, serverId)
|
||
let role = await RoleModel.findByUid(uid, serverId);
|
||
if(!role) return resResult(STATUS.GM_ROLE_NOT_FOUND);
|
||
let { roleId } = role;
|
||
|
||
let hisOnlineInfo = await getRoleOnlineInfo(role.roleId);
|
||
if(hisOnlineInfo.isOnline) {
|
||
let sid = hisOnlineInfo.sid;
|
||
if (!!sid) {//下发邮件，对应前端红点提示
|
||
pinus.app.channelService.pushMessageByUids(eventName, resResult(STATUS.SUCCESS, content), [{uid: roleId, sid}]);
|
||
}
|
||
}
|
||
return resResult(STATUS.SUCCESS, { msg: content });
|
||
}
|
||
|
||
//对接gm后台，下发邮件
|
||
async addMail(msg: { endTime: number, serverId: number, sendName: string, content: string, goods, sendRoles:[{roleId: string, status: number}], gmMailType: number, sendTime: number }) {
|
||
let {sendRoles, endTime, content, sendName, gmMailType, sendTime, goods, serverId} = msg;
|
||
let mail = await GMMailModel.addMail({serverId, sendRoles, sendName, endTime, content, gmMailType, sendTime, goods});
|
||
setGmMails([mail]);//更新邮件缓存
|
||
this.app.rpc.role.roleRemote.sendGmMailsToRoles.toServer('role-server-1',[mail]);//检查是否是群体邮件，并下发群体邮件，非群体邮件通过Filter刷新下发
|
||
}
|
||
} |