Skip to content

Commit

Permalink
Merge pull request #272 from Giftia/dev
Browse files Browse the repository at this point in the history 
Dev
  • Loading branch information
@Giftia
Giftia authored Jul 15, 2022
2 parents dc18c43 + 966926f commit 1b18092
Show file tree
Hide file tree
Showing 6 changed files with 84 additions and 165 deletions.
Binary file modified config/db.db
View file
Binary file not shown.
221 changes: 72 additions & 149 deletions plugins/danceCube.js
View file
Original file line number Diff line number Diff line change
@@ -1,11 +1,10 @@
/**
* authorization.token 文件内容为玩家账户密钥，向服务器请求数据时会携带该参数鉴权，具有修改账户的最高权限，需要自行抓包获取，请勿透露给不信任的他人，否则最糟糕的情况可能会导致游戏账户被恶意注销
*/
// 用于插眼所需要的百度地理编码密钥，需要自己去申请：https://lbsyun.baidu.com/index.php?title=webapi/guide/webservice-geocoding
const baiduAk = "";

module.exports = {
插件名: "公测·舞立方信息查询插件",
指令: "^[/!]?(绑定|个人信息|战绩|机台状态|关注机台|我要出勤)(.*)",
版本: "1.1",
插件名: "舞立方信息查询插件",
指令: "^[/!]?(绑定|个人信息|战绩|插眼|我要出勤)(.*)",
版本: "2.0",
作者: "Giftina",
描述: "舞立方信息查询，可以查询玩家信息以及机台状态。数据来源以及素材版权归属 胜骅科技 https://www.arccer.com/ ，如有侵权请联系作者删除。",
使用示例: "个人信息",
Expand Down Expand Up @@ -55,59 +54,36 @@ module.exports = {
}

const musicIndex = args[2] || defaultMusicIndex;
reply = await GetPlayerRank(playerId, musicIndex);
}
// 机台状态
else if (getMachineStateCommand.test(msg)) {
let province = args[1];
let city = province?.includes("市") ? "市辖区" : args[2];

// 如果没有携带参数，则从绑定信息中获取，没有则提示绑定
const playerData = await DanceCubeModel.findOne({ where: { userId } });
if (!args[1]) {
if (!playerData) {
return { type: "text", content: errorNoData };
} else {
const location = await AnalysisLocation(playerData.location);
console.log(`将绑定信息地址 ${playerData.location} 解析为 ${location.province + location.city}`.log);
if (!location) {
return { type: "text", content: "解析你的地区失败了，对不起呀，你还可以手动查询，指令如：机台状态 浙江省 杭州市" };
} else {
province = location.province;
city = location.city;
}
}
const playerRank = await GetPlayerRank(playerId, musicIndex);
if (playerRank.error) {
reply = `查询战绩失败：${playerRank.error}`;
} else {
reply = playerRank;
}

if (!province || !city) {
return { type: "text", content: "没有正确指定省份或城市噢，正确指令如：机台状态 浙江省 杭州市，市辖区示例：机台状态 上海市" };
}

reply = await GetMachineListByPlace(province, city);
}
// 关注机台
else if (focusMachineCommand.test(msg)) {
// 如果没有携带 playerId 参数，则查询用户有没有绑定玩家，没有则提示绑定
// 插眼
else if (setLocationCommand.test(msg)) {
// 查询用户有没有绑定玩家，没有则提示绑定
const playerData = await DanceCubeModel.findOne({ where: { userId } });
if (!playerData) {
return { type: "text", content: errorNoData };
}
// 如果没有指定机台ID，需要引导用户输入机台ID
// 如果没有指定地名，需要引导用户输入地名
else if (!args[1]) {
return { type: "text", content: "好像没有指定机台ID噢，请发送 机台状态 指令来查询你附近的机台的ID吧" };
return { type: "text", content: "好像没有指定地名噢，请发送 插眼 地名 在指定位置插眼吧" };
}

const machineId = args[1];
reply = await FocusMachine(userId, machineId);
const location = args[1];
reply = await Geocoding(userId, location);
}
// 我要出勤
else if (goGoGOCommand.test(msg)) {
// 查询用户关注的机台状态，如果没有关注机台，则提示用户关注机台
// 查询用户设定的坐标附近的机台状态，如果没有插眼，则提示用户插眼
const playerData = await DanceCubeModel.findOne({ where: { userId } });
if (!playerData) {
return { type: "text", content: errorNoData };
} else if (!playerData.focusMachine) {
return { type: "text", content: "你还没有关注机台呢，禁止出勤，请发送 机台状态 来查询你附近的机台的ID吧" };
} else if (!playerData.location) {
return { type: "text", content: "你还没有插眼呢，禁止出勤，请发送 插眼 地名 在指定位置插眼吧" };
}

reply = await GoGoGo(userId);
Expand All @@ -120,8 +96,7 @@ module.exports = {
const bindCommand = new RegExp(/^[/!]?绑定(.*)/);
const getPlayerInfoCommand = new RegExp(/^[/!]?个人信息(.*)/);
const getRankCommand = new RegExp(/^[/!]?战绩(.*)/);
const getMachineStateCommand = new RegExp(/^[/!]?机台状态(.*)/);
const focusMachineCommand = new RegExp(/^[/!]?关注机台(.*)/);
const setLocationCommand = new RegExp(/^[/!]?插眼(.*)/);
const goGoGOCommand = new RegExp(/^[/!]?我要出勤/);

const defaultMusicIndex = 6; // 音乐类型，1 最新，2 国语，3 粤语，4 韩文，5 欧美，6 其他
Expand All @@ -131,6 +106,9 @@ const { createCanvas, loadImage, registerFont } = require("canvas"); // 用于
const path = require("path");
const fs = require("fs");
const axios = require("axios").default;
/**
* authorization.token 文件内容为玩家账户密钥，向服务器请求数据时会携带该参数鉴权，具有修改账户的最高权限，需要自行抓包获取，请勿透露给不信任的他人，否则最糟糕的情况可能会导致游戏账户被恶意注销
*/
const authorization = fs.readFileSync(
path.join(__dirname, "danceCube", "authorization.token"),
"utf-8",
Expand All @@ -150,8 +128,8 @@ const headers = {
const api = {
playerInfo: baseURL + "Dance/api/User/GetInfo",
playerRank: baseURL + "Dance/api/User/GetMyRank",
machineList: baseURL + "Dance/OAuth/GetMachineList",
machineListByPlace: baseURL + "Dance/OAuth/GetMachineListByPlace",
geocoding: "https://api.map.baidu.com/geocoding/v3",
machineListByLocation: baseURL + "Dance/OAuth/GetMachineListByLocation",
};
//加载字体
const titleFontName = "优设标题圆";
Expand Down Expand Up @@ -269,7 +247,7 @@ async function AnalysisPlayerInfo(playerId) {
ctx.font = `160px '${eventFontName}'`;
ctx.fillStyle = "rgba(99, 99, 99, 0.2)";
ctx.textAlign = "center";
ctx.fillText("公 测", canvas.width / 2, canvas.height / 2 + 80);
ctx.fillText("测 试", canvas.width / 2, canvas.height / 2 + 80);

// 保存图片
const fileName = `${playerId}.png`;
Expand Down Expand Up @@ -319,8 +297,12 @@ async function GetPlayerRank(playerId, musicIndex) {
musicIndex: musicIndex,
userId: playerId,
},
validateStatus: (status) => status < 500,
})
.then(async function (response) {
if (response.status !== 200) {
return { error: response.data.Message };
}
const results = response.data;
const reply = results.map((result) => {
const musicName = result.Name;
Expand Down Expand Up @@ -420,7 +402,7 @@ async function GetPlayerRank(playerId, musicIndex) {
ctx.font = `170px '${eventFontName}'`;
ctx.fillStyle = "rgba(33, 33, 33, 0.4)";
ctx.textAlign = "center";
ctx.fillText("公 测", canvas.width / 2, canvas.height / 2 + 80);
ctx.fillText("测 试", canvas.width / 2, canvas.height / 2 + 80);

// 保存图片
const fileName = `${playerId}.png`;
Expand All @@ -432,152 +414,93 @@ async function GetPlayerRank(playerId, musicIndex) {
}

/**
* 根据省市查询机台状态
* @param {string} province 省
* @param {string} city 市
*/
async function GetMachineListByPlace(province, city) {
const machineList = await axios.get(api.machineListByPlace, {
headers: headers,
params: {
province: province,
city: city,
},
})
.then(async function (response) {
const machineList = response.data;
const reply = machineList.map((machine) => {
const machineName = machine.PlaceName.replace(/\n/g, "");
const address = machine.Address.replace(/\n/g, "");
const status = machine.Online ? "🟢" : "🔴";
const machineGeneration = machine.Img1.includes("9700") ? "Ⅰ代" : "Ⅱ代"; // 按机台图片名判断其实不是很准确，但是大致看了下八九不离十
const machineTerminalID = machine.MachineTerminalID;
return `${status}${machineName} ${machineGeneration}\nID: ${machineTerminalID}\n${address}\n`;
});
return `${province}${city}机台状态：
${reply.join("\n")}
发送 关注机台 机台ID 可以关注机台
（机台在线状态和世代仅供参考，以实际状态为准）
`;
})
.catch(function (error) {
console.log(`获取机台状态失败: ${error}`.error);
return "获取机台状态失败: ", error;
});
return machineList;
}

/**
* 根据 location 解析省市
* @param {string} location 省市
*/
async function AnalysisLocation(location) {
// 简陋的省份解析
let province = location.split("省")[0];
const city = location.split("省")[1];

if (!province || !city) {
return;
}

province += "省";
return { province, city };
}

/**
* 关注机台，后续出勤时直接查询该机台号
* @param {string} machineTerminalID 机台号
* 插眼，根据玩家提供的地名查询经纬度并存入玩家数据库
* @param {string} location 位置
*/
async function FocusMachine(userId, machineTerminalID) {
// 先验证机台是否存在
const machineInfo = await axios.get(api.machineList, {
headers: headers,
async function Geocoding(userId, location) {
// 百度地理编码
const { lng, lat, error } = await axios.get(api.geocoding, {
params: {
onlyPassed: true,
getUserInfo: false, // 舞立方点灯计划的点灯玩家
address: location,
ak: baiduAk,
output: "json",
},
})
.then(async function (response) {
const machine = response.data.find((machine) => {
return machine.MachineTerminalID === machineTerminalID;
});
return machine;
if (response.data.status !== 0) {
console.log(`地理编码失败：${response.data.message} `.log);
return { error: response.data.message };
}
return response.data.result.location;
})
.catch(function (error) {
console.log(`获取玩家资料失败: ${error}`.error);
return "获取玩家资料失败: ", error;
console.log(`地理编码失败: ${error} `.log);
return { error };
});

if (!machineInfo) {
return "这个机台不存在呢，是不是输错了呢，请发送 机台状态 指令来查询机台ID吧";
if (!lng || !lat) {
return `插眼失败：${error}，可能是这个地名不太好找，请换个地名再试试`;
}

// 再获取机台位置
const province = machineInfo.ProvinceAndCity.split(" ")[0];
const city = machineInfo.ProvinceAndCity.split(" ")[1];

await DanceCubeModel.update({
focusMachine: {
machineTerminalID: machineTerminalID,
province: province,
city: city,
},
location: { lng, lat },
}, {
where: {
userId: userId,
}
});

return `关注成功，现在你关注的机台是 ${machineInfo.PlaceName}，发送 我要出勤 查询你关注的机台情况`;
return "插眼成功，发送 我要出勤 查询你附近的机台状态";
}

/**
* 查询出勤状态
* 查询眼位附近机台状态
* @param {*} userId 用户id
*/
async function GoGoGo(userId) {
/**
* focusMachine: { machineTerminalID, province, city }
* location: { lng, lat }
*/
const { focusMachine } = await DanceCubeModel.findOne({
const { location } = await DanceCubeModel.findOne({
where: {
userId: userId,
},
attributes: ["focusMachine"],
attributes: ["location"],
});

const machine = await axios.get(api.machineListByPlace, {
const machineList = await axios.get(api.machineListByLocation, {
headers: headers,
params: {
province: focusMachine.province,
city: focusMachine.city,
},
params: { ...location },
})
.then(async function (response) {
const machineList = response.data;
const machine = machineList.find((machine) => {
return machine.MachineTerminalID === focusMachine.machineTerminalID;
});
return machine;
console.log(`查询眼位附近机台状态：${response.data} `);
return response.data;
})
.catch(function (error) {
console.log(`获取机台状态失败: ${error}`.error);
return "获取机台状态失败: ", error;
console.log(`获取机台状态失败：${error} `.error);
return "获取机台状态失败：", error;
});

if (machineList.length === 0) {
return "获取机台状态失败：附近没有找到任何机台";
}

const machineCount = machineList.length;
const machine = machineList[0]; // 选择最近的一台舞立方
const machineName = machine.PlaceName.replace(/\n/g, "");
const provinceAndCity = machine.ProvinceAndCity.replace(/\n/g, "");
const address = machine.Address.replace(/\n/g, "");
const longitudeAndLatitude = `${machine.Longitude}, ${machine.Latitude}`; // 经纬度
const longitudeAndLatitude = `${machine.Longitude}, ${machine.Latitude} `; // 经纬度
const status = machine.Online ? "🟢机台在线，立即出勤" : "🔴机台离线，散了吧";
const machineGeneration = machine.Img1.includes("9700") ? "Ⅰ代机" : "Ⅱ代机";
const machinePicture1Link = `https://dancedemo.shenghuayule.com/Dance/${machine.Img1}`;
const machinePicture2Link = `https://dancedemo.shenghuayule.com/Dance/${machine.Img2}`;
return `${status}
return `眼位附近有${machineCount}台舞立方，下面播报距离眼位最近的舞立方状态：
${status}
${machineName} ${machineGeneration}
${provinceAndCity} ${address}
坐标：${longitudeAndLatitude}
[CQ:image,file=${machinePicture1Link}][CQ:image,file=${machinePicture2Link}]`;
}

const DanceCubeModel = require(path.join(process.cwd(), "plugins", "system", "model", "danceCubeModel.js"));
const DanceCubeModel = require(path.join(process.cwd(), "plugins", "system", "model", "danceCubeModel.js"));
2 changes: 1 addition & 1 deletion plugins/danceCube/authorization.token
View file
Original file line number Diff line number Diff line change
@@ -1 +1 @@
bearer pSiCl4tEZErNct1IVA-w1pViMWASW6GRTVVW-KbLbw1BKbdwoMiMUDUxv-vclIUiUjfhcf8QcZeH5bjUaHG3hAk0S4gFPbrIw-EPshC8EMJgsOhh02A8b4tFXDJcA2GV23RTKc5oSXAPoFRLHQCxtVYBSv29gnxE5hW8TGZUNNNAFSdCYdx37xS_XByEAgevNuslcBQ7CWa6pN1lzg0fm5T5Si3Rvl8JTXu-GcQy05h8LTgKwzcgtAYrrgaVJInLl4K2P93MnuXyJ-wV4OeCdWWiSrnAkIuQU4w7uL3AgNrpoCF66ICC_oiVB4CMzNcW1Mqscvj5wvptx5NtGiLhW95CS0wZubaODq_tQ8AZs2u0hFw2AeNiRPJAYxjBetL9MBzy6oMt78Sg7bAlBxlKHvM7QyA8R2p_iJXSNwJ8oGGINiD2P2OxTf5zog7nU9puibhNUSK6WtkUwR6havcfmncWfPEOVSKfTOagCcbZohRvbN6YxUwUEKY21qC6fqNPVxnorJGfhQpWABf0s0i2ReAw6DyysaUvfHaHfbSZL4wJs4Cs66qvJqgNMIVWQIBUx-7FfxZ0a98M_MppmJFsY9Qq_x2lyjZb263gxUsoBiu0fMa4xQx1HtRX3EkhnDQ4BXOuUw1LVLV3mKRdcz9m1BqZrSm6hICQ3pLoBr7CXHYIkjiXVDPTzJ_cpzwNEblPjxHB9UbKhQcJEQAwM2Dy-V0ppVxH73INJ5J3-FCplXs3I5N7ORIcn_F4LaVcFlr1TeNYqLq53paGmCstmkWjyKOvnFfUOjxjHOgxtcIoX3VH3pW59zzwyFBqC5ib6s3SaPTA0sUXkvg3OjXHf83AsQCcYykq8LixMNaC_rSC2FhTDejcMsqX648sV1ByIKNgvJCY_Sd7YNO-F9f7Xb443OkI_e72Ym-Q9Gf8YThVC9IPa5dYS30UlV32U6PxbJs5
bearer KexZ0pfDx6GnIxUx2QBxoeBVVtPcktcUB086NooJGXQTzmbusxfQ7--wOkQVKDqvSOHxTetNHLwPTqeH-ZlJrIekFLw6dO63_Up500OxThO_vhFFA6P_Aa9gGpi9jArLEhZoD7sATPJpnr9pa4AgWGdiNBr4cJgWfbCgBrvbRpskmjpDyqNqw0hHjw9p6aDJemRvMjmpDlMC8_ub7NjPN33gAr6LQMja9BmuKXzf_1LD1ddwHmdkq9ryqx82wqpLOVk1XH6gH30DK3RDaJ8xSFzNctA8ES7lP5gOmJWasAiYZpgR79FF_8fLM6LHrxeAbS7AU2PsruPvz34eC6wuH0VDcQKEemPNSvvcr4otTmZpKWiPlnn7JRK4s051xTT1n45AW1iR5t1TNpiZal-E8lBEQm-ROFWOoUGRL5CgKza3pUWQLOcPnxYVD-qlJTyNmU-24fIN1EcRxPK2GFUyiiJb7gt1AOO2ZhdyLwIuFA9APT5i2hcWP3IXVT_VsqBb7WEEA9xLE6fuvGryD3JbjodeTpcIIxGJlLbwnC-XLhuh6mogGN8fQtFzwXsa5Y59zpTsSAzpzf4nrd7KRGKc53gT2rOUb-vksigmbjTLezBd2GquelivoFmbTWyWsCCz5ci4sk5D1cPk51iaR1Jn-ioMB7xbo5o-kelcNubMC9qz9zcZidOt7-msModY0yBPb7HEK3ukJROa6CRig4RXczjo0wz3MENxzc11RZjwsDteu0O1mhs-B-PxW-UNixXC1qtyskrifjFBZZxhgtVIFmwRb-dqs5kKzz4al1JHfA3afVvKCTbDZ6j9hQjL5R9cz-zNVvbTZia5lwOVqMitZGdV7RV6062niQTXqcWGxsHvR0U--Bxy-hjtDLXPhavnRQYFam2ljwOCGDoolRXsrxNUy-iVuv50uBtAvBlPqd4EmvHKnojfmAygoZJfDf0K
16 changes: 8 additions & 8 deletions plugins/balabalaTeach.js → plugins/perfunctoryTeach.js
View file
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
module.exports = {
插件名: "敷衍语料教学插件",
指令: "^[/!]?说不出话 (.*)",
版本: "2.1",
版本: "2.2",
作者: "Giftina",
描述: "balabala敷衍教学，教给小夜一些比较通用的回复。对于一些难以回复的对话，小夜的词库中没有搜索到回复的时候，小夜会随机回复这些回复作为敷衍，回复了，但完全没有回复的意义。",
描述: "敷衍语料教学，教给小夜一些比较通用的回复。对于一些难以回复的对话，小夜的词库中没有搜索到回复的时候，小夜会随机回复这些回复作为敷衍，回复了，但完全没有回复的意义。",
使用示例: "说不出话 ？",
预期返回: "哇！小夜学会啦！小夜可能在说不出话的时候说 ？ 噢",
预期返回: "哇！小夜学会啦！小夜可能在说不出话的时候回复 ？ 噢",

execute: async function (msg, userId, userName, groupId, groupName, options) {
const teachMsg = new RegExp(module.exports.指令).exec(msg)[1];
const teachMsgChecked = teachMsg.replace(/'/g, ""); // 防爆
console.log(
`${userId}(${userName}) 想要教给小夜balabala: ${teachMsgChecked}，现在开始检测合法性`.log,
`${userId}(${userName}) 想要教给小夜敷衍语料: ${teachMsgChecked}，现在开始检测合法性`.log,
);
for (let i in CHAT_BAN_WORDS) {
if (
Expand All @@ -23,19 +23,19 @@ module.exports = {
.indexOf(CHAT_BAN_WORDS[i].toLowerCase()) !== -1
) {
console.log(
`balabala教学: 检测到不允许的词: ${CHAT_BAN_WORDS[i]}，退出教学`.error,
`敷衍语料教学: 检测到不允许的词: ${CHAT_BAN_WORDS[i]}，退出教学`.error,
);
return { type: "text", content: "你教的内容里有主人不允许小夜学习的词qwq" };
}
}
console.log("balabala教学: 没有检测到问题，可以学习".log);
console.log("敷衍语料教学: 没有检测到问题，可以学习".log);

await PerfunctoryModel.create({ content: teachMsgChecked })
.then(() => {
console.log("balabala教学: 学习成功".log);
console.log("敷衍语料教学: 学习成功".log);
});

return { type: "text", content: `哇！小夜学会啦！小夜可能在说不出话的时候说 ${teachMsgChecked} 噢` };
return { type: "text", content: `哇！小夜学会啦！小夜可能在说不出话的时候回复 ${teachMsgChecked} 噢` };
},
};

Expand Down
Loading

0 comments on commit 1b18092

Please sign in to comment.