From e3ce7c037e370399050d39b38fa43267de462d24 Mon Sep 17 00:00:00 2001 From: Changhua Date: Sun, 16 Jul 2023 21:59:27 +0800 Subject: [PATCH] v39.0.1.0 --- clients/http/setup.py | 2 +- clients/http/wcfhttp/core.py | 20 +++++++++++++++++--- 2 files changed, 18 insertions(+), 4 deletions(-) diff --git a/clients/http/setup.py b/clients/http/setup.py index 68d0a17..5e3d4b4 100644 --- a/clients/http/setup.py +++ b/clients/http/setup.py @@ -33,7 +33,7 @@ setup( "setuptools", "fastapi", "uvicorn[standard]", - "wcferry>=39.0.0.0", + "wcferry>=39.0.1.0", ], classifiers=[ "Environment :: Win32 (MS Windows)", diff --git a/clients/http/wcfhttp/core.py b/clients/http/wcfhttp/core.py index 8a018eb..ea4e982 100644 --- a/clients/http/wcfhttp/core.py +++ b/clients/http/wcfhttp/core.py @@ -8,11 +8,11 @@ from threading import Thread from typing import Any import requests -from fastapi import Body, FastAPI +from fastapi import Body, Query, FastAPI from pydantic import BaseModel from wcferry import Wcf, WxMsg -__version__ = "39.0.0.1" +__version__ = "39.0.1.0" class Msg(BaseModel): @@ -50,6 +50,7 @@ class Http(FastAPI): self.add_api_route("/friends", self.get_friends, methods=["GET"], summary="获取好友列表") self.add_api_route("/dbs", self.get_dbs, methods=["GET"], summary="获取所有数据库") self.add_api_route("/{db}/tables", self.get_tables, methods=["GET"], summary="获取 db 中所有表") + self.add_api_route("/pyq/", self.refresh_pyq, methods=["GET"], summary="刷新朋友圈（数据从消息回调中查看）") self.add_api_route("/text", self.send_text, methods=["POST"], summary="发送文本消息") self.add_api_route("/image", self.send_image, methods=["POST"], summary="发送图片消息") @@ -59,10 +60,11 @@ class Http(FastAPI): self.add_api_route("/sql", self.query_sql, methods=["POST"], summary="执行 SQL，如果数据量大注意分页，以免 OOM") self.add_api_route("/new-friend", self.accept_new_friend, methods=["POST"], summary="通过好友申请") self.add_api_route("/chatroom-member", self.add_chatroom_members, methods=["POST"], summary="添加群成员") - self.add_api_route("/chatroom-member", self.del_chatroom_members, methods=["DELETE"], summary="删除群成员") self.add_api_route("/transfer", self.receive_transfer, methods=["POST"], summary="接收转账") self.add_api_route("/dec-image", self.decrypt_image, methods=["POST"], summary="解密图片") + self.add_api_route("/chatroom-member", self.del_chatroom_members, methods=["DELETE"], summary="删除群成员") + def _forward_msg(self, msg, cb): data = {} data["id"] = msg.id @@ -342,6 +344,18 @@ class Http(FastAPI): ret = self.wcf.receive_transfer(wxid, transferid, transactionid) return {"status": ret, "message": "成功"if ret == 1 else "失败"} + def refresh_pyq(self, id: int = Query(0, description="开始 id，0 为最新页")) -> dict: + """刷新朋友圈 + + Args: + id (int): 开始 id，0 为最新页 + + Returns: + int: 1 为成功，其他失败 + """ + ret = self.wcf.refresh_pyq(id) + return {"status": ret, "message": "成功"if ret == 1 else "失败"} + def decrypt_image(self, src: str = Body("C:\\...", description="加密的图片路径，从图片消息中获取"), dst: str = Body("C:\\...", description="解密的图片路径")) -> dict: