From c84edaf2ff9da2047cc3aaea74cf2590f5db5167 Mon Sep 17 00:00:00 2001
From: xtaodada <xtao@xtaolink.cn>
Date: Sat, 23 Apr 2022 11:25:22 +0800
Subject: [PATCH] =?UTF-8?q?shangliu=20=E4=BF=AE=E5=A4=8D=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 list.json   |  4 ++--
 shangliu.py | 22 ++++++++++++++--------
 2 files changed, 16 insertions(+), 10 deletions(-)

diff --git a/list.json b/list.json
index 154e2d6..b9dd0d6 100644
--- a/list.json
+++ b/list.json
@@ -252,10 +252,10 @@
         },
         {
             "name": "shangliu",
-            "version": "1.011",
+            "version": "1.02",
             "section": "chat",
             "maintainer": "TNTcraftHIM",
-            "size": "2.5 kb",
+            "size": "2.6 kb",
             "supported": true,
             "des-short": "上流对话工具",
             "des": "让你可以随时放彩虹屁，毒鸡汤，或者变身营销号（迫真，配合-tts食用更佳）。命令：chp，djt，yxh。"
diff --git a/shangliu.py b/shangliu.py
index 9c597e8..79cb31d 100644
--- a/shangliu.py
+++ b/shangliu.py
@@ -2,7 +2,7 @@ from time import sleep
 from requests import get
 from pagermaid import version
 from pagermaid.listener import listener
-from pagermaid.utils import alias_command
+from pagermaid.utils import alias_command, client
 
 
 @listener(is_plugin=True, outgoing=True, command=alias_command("chp"),
@@ -11,10 +11,10 @@ async def chp(context):
     await context.edit("获取中 . . .")
     status = False
     for _ in range(20):  # 最多尝试20次
-        req = get("https://chp.shadiao.app/api.php?from=tntcrafthim")
+        req = await client.get("https://api.shadiao.app/chp")
         if req.status_code == 200:
-            res = req.text
-            await context.edit(res, parse_mode='html', link_preview=False)
+            res = req.json()
+            await context.edit(res.get("data", {}).get("text", "什么都没有找到"), parse_mode='html', link_preview=False)
             status = True
             break
         else:
@@ -31,10 +31,10 @@ async def djt(context):
     await context.edit("获取中 . . .")
     status = False
     for _ in range(20):  # 最多尝试20次
-        req = get("https://du.shadiao.app/api.php?from=tntcrafthim")
+        req = await client.get("https://api.shadiao.app/du")
         if req.status_code == 200:
-            res = req.text
-            await context.edit(res, parse_mode='html', link_preview=False)
+            res = req.json()
+            await context.edit(res.get("data", {}).get("text", "什么都没有找到"), parse_mode='html', link_preview=False)
             status = True
             break
         else:
@@ -50,7 +50,13 @@ async def djt(context):
 async def yxh(context):
     try:
         await context.edit("生成中 . . .")
-        text = f"{context.parameter[0]}{context.parameter[1]}是怎么回事呢？{context.parameter[0]}相信大家都很熟悉，但是{context.parameter[0]}{context.parameter[1]}是怎么回事呢，下面就让小编带大家一起了解吧。\n{context.parameter[0]}{context.parameter[1]}，其实就是{context.parameter[2]}，大家可能会很惊讶{context.parameter[0]}怎么会{context.parameter[1]}呢？但事实就是这样，小编也感到非常惊讶。\n这就是关于{context.parameter[0]}{context.parameter[1]}的事情了，大家有什么想法呢，欢迎在评论区告诉小编一起讨论哦！"
+        text = f"{context.parameter[0]}{context.parameter[1]}是怎么回事呢？" \
+               f"{context.parameter[0]}相信大家都很熟悉，" \
+               f"但是{context.parameter[0]}{context.parameter[1]}是怎么回事呢，下面就让小编带大家一起了解吧。\n" \
+               f"{context.parameter[0]}{context.parameter[1]}，其实就是{context.parameter[2]}，" \
+               f"大家可能会很惊讶{context.parameter[0]}怎么会{context.parameter[1]}呢？但事实就是这样，" \
+               f"小编也感到非常惊讶。\n这就是关于{context.parameter[0]}{context.parameter[1]}的事情了，" \
+               f"大家有什么想法呢，欢迎在评论区告诉小编一起讨论哦！"
     except IndexError:
         await context.edit("使用方法：-yxh <主体> <事件> <原因>")
         return