From 034dcbde7c22dfd0cc7028427cd56ccfe41de3e5 Mon Sep 17 00:00:00 2001
From: yeyang <746659424@qq.com>
Date: Fri, 6 Jan 2023 20:24:20 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/assistant.js    | 104 +++++++++++++++++++++-----------------
 model/QQInterface.js | 116 ++++++++++++++++++++++++-------------------
 2 files changed, 124 insertions(+), 96 deletions(-)

diff --git a/apps/assistant.js b/apps/assistant.js
index b2b9e6d..cefe2f7 100644
--- a/apps/assistant.js
+++ b/apps/assistant.js
@@ -1,7 +1,6 @@
 import plugin from '../../../lib/plugins/plugin.js';
 import { segment } from "oicq";
-import fetch from 'node-fetch';
-import { Cfg, QQInterface } from '../model/index.js';
+import { Cfg, QQInterface, common } from '../model/index.js';
 import lodash from 'lodash'
 import moment from 'moment'
 
@@ -333,24 +332,10 @@ export class example extends plugin {
 
     if (!signs) return e.reply("❎ 状态不为空，可选值：我在线上，离开，隐身，忙碌，Q我吧，请勿打扰");
 
-    let res = {
-      "离开": 31,
-      "忙碌": 50,
-      "隐身": 41,
-      "Q我吧": 60,
-      "请勿打扰": 70,
-      "我在线上": 11,
-    }
+    let status = common.status, statusMirr = lodash.invert(status)
+    if (!(signs in statusMirr)) return e.reply("❎ 可选值：我在线上，离开，隐身，忙碌，Q我吧，请勿打扰")
 
-    let status = {};
-    for (let k in res) {
-      status[res[k]] = k;
-    }
-
-    if (!(signs in res)) return e.reply("❎ 可选值：我在线上，离开，隐身，忙碌，Q我吧，请勿打扰")
-
-    await Bot.setOnlineStatus(res[signs])
-      .then(() => e.reply("✅ 在线状态修改成功"))
+    await Bot.setOnlineStatus(statusMirr[signs])
       .then(() => e.reply(`✅ 现在的在线状态为【${status[Bot.status]}】`))
       .catch(err => {
         e.reply("❎ 在线状态修改失败");
@@ -425,7 +410,7 @@ export class example extends plugin {
     })
 
     let groupids = gpid.split(",");
-    console.log(groupidList.length);
+
     if (!groupids.every(item => item <= groupidList.length)) return e.reply("❎ 序号超过合法值！！！")
 
     groupids.forEach((item) => {
@@ -605,7 +590,7 @@ export class example extends plugin {
   async Qzonelist(e) {
     if (!e.isMaster) return;
 
-    let page = e.msg.replace(/#|取说说列表/g, "").trim()
+    let page = e.msg.replace(/#|获?取说说列表/g, "").trim()
     if (!page) {
       page = 0
     } else {
@@ -613,8 +598,11 @@ export class example extends plugin {
     }
 
     //获取说说列表
-    let list = await QQInterface.getQzone(e, page * 5, 5)
-    if (!list) return
+    let list = await QQInterface.getQzone(page * 5, 5)
+
+    if (!list) return e.reply("❎ 取说说列表失败")
+    if (list.total == 0) return e.reply(`✅ 说说列表为空`)
+
     let msg = [
       "✅ 获取成功，说说列表如下:\n",
       ...list.msglist.map((item, index) =>
@@ -628,13 +616,42 @@ export class example extends plugin {
   /** 删除说说 */
   async Qzonedel(e) {
     if (!e.isMaster) return;
-    QQInterface.delQzone(e)
+    let pos = e.msg.match(/\d+/)
+    //获取说说列表
+    let list = await QQInterface.getQzone(pos - 1, 1)
+
+    if (!list) return e.reply("❎ 取说说列表失败")
+    if (!list.msglist) return e.reply(`❎ 未获取到该说说`)
+
+    //要删除的说说
+    let domain = list.msglist[0]
+    //请求接口
+    let result = await QQInterface.delQzone(domain.tid, domain.t1_source)
+    if (!result) return e.reply(`❎ 接口请求失败`)
+    //debug
+    logger.debug(`[椰奶删除说说]`, result)
+
+    if (result.subcode != 0) e.reply(`❎ 未知错误` + JSON.parse(result))
+    //发送结果
+    e.reply(`✅ 删除说说成功：\n ${pos}.${lodash.truncate(domain.content, { "length": 15 })} \n - [${domain.secret ? "私密" : "公开"}] | ${moment(domain.created_time * 1000).format("MM/DD HH:mm")} | ${domain.commentlist?.length || 0} 条评论`)
+
   }
 
   /** 发说说 */
   async Qzonesay(e) {
     if (!e.isMaster) return;
-    QQInterface.setQzone(e)
+    let con = e.msg.replace(/#|发说说/g, "").trim()
+    let result = await QQInterface.setQzone(con, e.img)
+    if (!result) return e.reply("❎ 出错辣，请稍后重试")
+
+    if (result.code != 0) return e.reply(`❎ 说说发表失败\n${JSON.stringify(result)}`)
+
+    let msg = [`✅ 说说发表成功，内容：\n`, lodash.truncate(result.content, { "length": 15 })]
+    if (result.pic) {
+      msg.push(segment.image(result.pic[0].url1))
+    }
+    msg.push(`\n- [${result.secret ? "私密" : "公开"}] | ${moment(result.t1_ntime * 1000).format("MM/DD HH:mm")}`)
+    e.reply(msg)
   }
 
   /** 清空说说和留言*/
@@ -655,16 +672,14 @@ export class example extends plugin {
     let msg = this.e.msg
     if (/#?确认清空/.test(msg)) {
       this.finish('QzonedelAll')
-      let ck = Cfg.getck('qzone.qq.com')
-      let url
+      let result
       if (Qzonedetermine) {
-        url = `https://xiaobai.klizi.cn/API/qqgn/ss_empty.php?data=&uin=${Bot.uin}&skey=${ck.skey}&pskey=${ck.p_skey}`
+        result = await QQInterface.delQzoneAll()
       } else {
-        url = `https://xiaobai.klizi.cn/API/qqgn/qzone_emptymsgb.php?data=&uin=${Bot.uin}&skey=${ck.skey}&pskey=${ck.p_skey}`
+        result = await QQInterface.delQzoneMsgbAll()
       }
 
-      let result = await fetch(url).then(res => res.text()).catch(err => console.log(err))
-      this.e.reply(`✅ ${result}`)
+      this.e.reply(result)
       return true;
 
     } else if (/#?取消/.test(msg)) {
@@ -686,23 +701,20 @@ export class example extends plugin {
     if (/群列表/.test(e.msg)) {
       //获取群列表并转换为数组
       let listMap = Array.from(Bot.gl.values())
-      //添加有几个群
-      msg.push(`群列表如下，共${listMap.length}个群`)
-      //遍历添加
-      msg.push(listMap.map((item, index) => `${index + 1}、${item.group_name}(${item.group_id})`).join("\n"))
-      //提示信息
-      msg.push("可使用 #退群123456789 来退出某群")
-      msg.push("可使用 #发群列表 <序号> <消息> 来快速发送消息")
-      msg.push(`多个群聊请用 "," 分隔 不能大于3 容易寄`)
-    } else if (/好友列表/.test(e.msg)) {
+      msg = [
+        `群列表如下，共${listMap.length}个群`,
+        listMap.map((item, index) => `${index + 1}、${item.group_name}(${item.group_id})`).join("\n"),
+        "可使用 #退群123456789 来退出某群",
+        `可使用 #发群列表 <序号> <消息> 来快速发送消息，多个群聊请用 "," 分隔 不能大于3 容易寄`
+      ]
+    } else {
       //获取好友列表并转换为数组
       let listMap = Array.from(Bot.fl.values())
-      //添加有多少个好友
-      msg.push(`好友列表如下，共${listMap.length}个好友`)
-      //遍历添加
-      msg.push(listMap.map((item, index) => `${index + 1}、${item.nickname}(${item.user_id})`).join("\n"))
-      //提示信息
-      msg.push("可使用 #删好友123456789 来删除某人")
+      msg = [
+        `好友列表如下，共${listMap.length}个好友`,
+        listMap.map((item, index) => `${index + 1}、${item.nickname}(${item.user_id})`).join("\n"),
+        "可使用 #删好友123456789 来删除某人"
+      ]
     }
 
     Cfg.getforwardMsg(e, msg)
diff --git a/model/QQInterface.js b/model/QQInterface.js
index efd2782..d71febf 100644
--- a/model/QQInterface.js
+++ b/model/QQInterface.js
@@ -26,67 +26,52 @@ export default new class assistant {
      * @param {Number} num 数量
      * @return {Object} QQ空间数据
      */
-    async getQzone(e, pos = 0, num = 20) {
+    async getQzone(pos = 0, num = 20) {
         let url = `https://user.qzone.qq.com/proxy/domain/taotao.qq.com/cgi-bin/emotion_cgi_msglist_v6?uin=${Bot.uin}&ftype=0&sort=0&pos=${pos}&num=${num}&replynum=100&g_tk=${Bot.bkn}&code_version=1&format=json&need_private_comment=1`
-        let list = await fetch(url, {
+        return await fetch(url, {
             headers: {
                 "Cookie": Bot.cookies["qzone.qq.com"],
             }
         }).then(res => res.json()).catch(err => console.log(err))
-
-        if (!list) {
-            e.reply("❎ 取说说列表失败")
-            return false;
-        } else if (!list.msglist) {
-            e.reply(`❎ 未获取到说说列表`)
-            return false;
-        } else {
-            return list
-        }
     }
 
-    /** 删除说说 */
-    async delQzone(e) {
-        let pos = e.msg.match(/\d+/)
-        //获取说说列表
-        let list = await this.getQzone(e, pos - 1, 1)
-
-        if (!list) return false;
-
-        //要删除的说说
-        let domain = list.msglist[0]
-
+    /**
+     * @description: 删除说说
+     * @param {String} tid tid参数
+     * @param {String} t1_source t1_source参数
+     */
+    async delQzone(tid, t1_source) {
         let url = `https://user.qzone.qq.com/proxy/domain/taotao.qzone.qq.com/cgi-bin/emotion_cgi_delete_v6?&g_tk=${Bot.bkn}`
         //发送请求
-        let result = await fetch(url, {
+        return await fetch(url, {
             method: 'POST',
-            body: `hostuin=${Bot.uin}&tid=${domain.tid}&t1_source=${domain.t1_source}&code_version=1&format=json`,
+            body: `hostuin=${Bot.uin}&tid=${tid}&t1_source=${t1_source}&code_version=1&format=json`,
             headers: {
                 "Cookie": Bot.cookies["qzone.qq.com"],
             }
         }).then(res => res.json()).catch(err => console.log(err))
-        if (!result) return e.reply(`❎ 接口请求失败`)
-        logger.debug(`[椰奶删除说说]`, result)
-        if (result.subcode == 0) {
-            e.reply(`✅ 删除说说成功：\n ${pos}.${lodash.truncate(domain.content, { "length": 15 })} \n - [${domain.secret ? "私密" : "公开"}] | ${moment(domain.created_time * 1000).format("MM/DD HH:mm")} | ${domain.commentlist?.length || 0} 条评论`)
-        } else {
-            e.reply(`❎ 未知错误` + JSON.parse(result))
-        }
     }
 
+    /**删除全部说说 */
+    async delQzoneAll() {
+        let list = await this.getQzone(0, -1)
+        if (list.total == 0) return `❎ 说说列表空空`
+        for (let item of list.msglist) {
+            let res = await this.delQzone(item.tid, item.t1_source)
+            if (res.code != 0) return `❎ 遇到错误 ${JSON.stringify(res)}`
+        }
+        return `✅ 已清空全部说说`
+    }
     /**发送说说 */
-    async setQzone(e) {
-        let con = e.msg.replace(/#|发说说/g, "").trim()
+    async setQzone(con, img) {
         let ck = Cfg.getck('qzone.qq.com')
 
-        let url;
-        let result
-        if (e.img) {
-            url = `http://xiaobai.klizi.cn/API/qqgn/ss_sendimg.php?uin=${Bot.uin}&skey=${ck.skey}&pskey=${ck.p_skey}&url=${e.img[0]}&msg=${con}`
-            result = await fetch(url).then(res => res.json()).catch(err => console.log(err))
+        if (img) {
+            let url = `http://xiaobai.klizi.cn/API/qqgn/ss_sendimg.php?uin=${Bot.uin}&skey=${ck.skey}&pskey=${ck.p_skey}&url=${img[0]}&msg=${con}`
+            return await fetch(url).then(res => res.json()).catch(err => console.log(err))
         } else {
-            url = `https://user.qzone.qq.com/proxy/domain/taotao.qzone.qq.com/cgi-bin/emotion_cgi_publish_v6?&g_tk=${Bot.bkn}`
-            result = await fetch(url, {
+            let url = `https://user.qzone.qq.com/proxy/domain/taotao.qzone.qq.com/cgi-bin/emotion_cgi_publish_v6?&g_tk=${Bot.bkn}`
+            return await fetch(url, {
                 method: 'POST',
                 body: `syn_tweet_verson=1&paramstr=1&con=${con}&feedversion=1&ver=1&ugc_right=1&to_sign=1&hostuin=${Bot.uin}&code_version=1&format=json`,
                 headers: {
@@ -94,17 +79,48 @@ export default new class assistant {
                 }
             }).then(res => res.json()).catch(err => console.log(err))
         }
+    }
+    /**
+     * @description: 获取留言
+     * @param {Number} num 数量为0时返回为全部
+     * @param {Number} start 偏移量/开始的位置
+     * @return {*}
+     */
+    async getQzoneMsgb(num = 0, start = 0) {
+        let url = `https://user.qzone.qq.com/proxy/domain/m.qzone.qq.com/cgi-bin/new/get_msgb?uin=${Bot.uin}&hostUin=${Bot.uin}&start=${start}&s=0.45779069937151884&format=json&num=${num}&inCharset=utf-8&outCharset=utf-8&g_tk=${Bot.bkn}`
+        return await fetch(url, {
+            "headers": {
+                "cookie": Bot.cookies["qzone.qq.com"],
+            },
+        }).then(res => res.json());
+    }
+    /**
+     * @description: 删除留言
+     * @param {*} id 留言id
+     * @param {*} uinId
+     * @return {*}
+     */
+    async delQzoneMsgb(id, uinId) {
+        let delurl = `https://h5.qzone.qq.com/proxy/domain/m.qzone.qq.com/cgi-bin/new/del_msgb?&g_tk=${Bot.bkn}`
+        return await fetch(delurl, {
+            method: "POST",
+            headers: {
+                "Cookie": Bot.cookies['qzone.qq.com'],
+            },
+            body: `hostUin=${Bot.uin}&idList=${id}&uinList=${uinId}&format=json&iNotice=1&inCharset=utf-8&outCharset=utf-8&ref=qzone&json=1&g_tk=${Bot.bkn}`
+        }).then(res => res.json());
+    }
 
-        if (!result) return e.reply("接口失效")
-
-        if (result.code != 0) return e.reply(`❎ 说说发表失败\n错误信息:${result.message}`)
-
-        let msg = [`✅ 说说发表成功，内容：\n`, lodash.truncate(result.content, { "length": 15 })]
-        if (result.pic) {
-            msg.push(segment.image(result.pic[0].url1))
+    /**删除全部留言 */
+    async delQzoneMsgbAll() {
+        let list = await this.getQzoneMsgb()
+        if (list.code != 0) return `❎ 获取列表错误 ${JSON.stringify(list)}`
+        if (list.data.total == 0) return `❎ 留言列表空空`
+        for (let item of list.data.commentList) {
+            let res = await this.delQzoneMsgb(item.id, item.uin)
+            if (res.code != 0) return `❎ 遇到错误 ${JSON.stringify(res)}`
         }
-        msg.push(`\n- [${result.secret ? "私密" : "公开"}] | ${moment(result.t1_ntime * 1000).format("MM/DD HH:mm")}`)
-        e.reply(msg)
+        return `✅ 已清空全部留言`
     }
 
     // ----------------------------------------------------公告---------------------------------------------