86 lines
2.7 KiB
TypeScript
86 lines
2.7 KiB
TypeScript
import {Application, BackendSession} 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';
|
|
|
|
|
|
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;
|
|
console.log(uid, serverId)
|
|
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', {
|
|
msg: { 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 sid = session.get('sid');
|
|
|
|
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 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 tsid = channel.getMember(roleId)['sid'];
|
|
channelService.pushMessageByUids(eventName, {
|
|
msg: content
|
|
}, [{
|
|
uid: roleId,
|
|
sid: tsid
|
|
}]);
|
|
return resResult(STATUS.SUCCESS, { msg: content });
|
|
}
|
|
} |