import _ from 'lodash'; export async function sleepAsync(sleepms) { return new Promise((resolve, reject) => { setTimeout(() => { resolve(); }, sleepms) }); } export async function randomSleepAsync(end) { let sleep = 3 * 1000 + _.random((end||5) * 1000); await sleepAsync(sleep); } export function randomString(length,os=false) { let randomStr = ''; for (let i = 0; i < length; i++) { randomStr += _.sample(os?'0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz':'abcdefghijklmnopqrstuvwxyz0123456789'); } return randomStr; } export async function redisGet(userId,type='bbs'){ await redis.get(`xiaoyao:${type}:${userId}`); } export async function redisSet(userId,type='bbs',data){ var time = moment(Date.now()).add('days', 1).format('YYYY-MM-DD 00:00:00') var new_date = (new Date(time).getTime() - new Date().getTime()) / 1000 //获取隔天凌晨的时间差 await redis.set(`xiaoyao:${type}:${userId}`,JSON.stringify(data),{EX:parseInt(new_date)}); } /** * 发送私聊消息,仅给好友发送 * @param user_id qq号 * @param msg 消息 */ export async function relpyPrivate(userId, msg) { userId = Number(userId) let friend = Bot.fl.get(userId) if (friend) { Bot.logger.mark(`发送好友消息[${friend.nickname}](${userId})`) return await Bot.pickUser(userId).sendMsg(msg).catch((err) => { Bot.logger.mark(err) }) } } export async function replyMake(e, _msg, lenght) { let nickname = Bot.nickname; if (e.isGroup) { let info = await Bot.getGroupMemberInfo(e.group_id, Bot.uin) nickname = info.card || info.nickname } let msgList = []; for (let [index, item] of Object.entries(_msg)) { if (index < lenght) { continue; } msgList.push({ message: item, nickname: nickname, user_id: Bot.uin }) } if(e._reply){ e._reply(await Bot.makeForwardMsg(msgList)); }else { e.reply(await Bot.makeForwardMsg(msgList)); } } export function getServer (uid) { switch (String(uid)[0]) { case '1': case '2': return 'cn_gf01' // 官服 case '5': return 'cn_qd01' // B服 case '6': return 'os_usa' // 美服 case '7': return 'os_euro' // 欧服 case '8': return 'os_asia' // 亚服 case '9': return 'os_cht' // 港澳台服 } return 'cn_gf01' } export async function getCookieMap(cookie) { let cookieArray = cookie.replace(/\s*/g, "").split(";"); let cookieMap = new Map(); for (let item of cookieArray) { let entry = item.split("="); if (!entry[0]) continue; cookieMap.set(entry[0], entry[1]); } return cookieMap||{}; } export default { sleepAsync,getServer, randomSleepAsync, replyMake, randomString,redisGet,redisSet, relpyPrivate, getCookieMap }