|
@@ -1203,6 +1203,43 @@ class ApiController {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ async maintenanceAll(ctx) {
|
|
|
|
|
+ let data = ctx.request.body
|
|
|
|
|
+
|
|
|
|
|
+ const servers = (await Server.getServerList('default'))
|
|
|
|
|
+
|
|
|
|
|
+ servers.forEach(function (element) {
|
|
|
|
|
+
|
|
|
|
|
+ let url = 'ws://' + element.ip + ':' + element.port
|
|
|
|
|
+ if (!url) {
|
|
|
|
|
+ ctx.body = {
|
|
|
|
|
+ code: 1,
|
|
|
|
|
+ msg: `区服id错误: serverId ${element.server_id}`
|
|
|
|
|
+ }
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ let param = JSON.stringify({
|
|
|
|
|
+ type: "kickAllUser"
|
|
|
|
|
+ })
|
|
|
|
|
+ // Msg.connect(url, Account);
|
|
|
|
|
+ let sendMsg = new Msg()
|
|
|
|
|
+ sendMsg.connect(url, Account);
|
|
|
|
|
+ new Promise((resolve) => {
|
|
|
|
|
+ setTimeout(async () => {
|
|
|
|
|
+ sendMsg.CG_TEST_PROTO("test", param)
|
|
|
|
|
+ }, 1000);
|
|
|
|
|
+ });
|
|
|
|
|
+
|
|
|
|
|
+ });
|
|
|
|
|
+
|
|
|
|
|
+ ctx.body = {
|
|
|
|
|
+ code: 0,
|
|
|
|
|
+ msg: "success"
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
async sendMail(ctx) {
|
|
async sendMail(ctx) {
|
|
|
let data = ctx.request.body
|
|
let data = ctx.request.body
|
|
|
let url = await getServerList(data.serverId, 'default')
|
|
let url = await getServerList(data.serverId, 'default')
|