diff --git a/core/async_task.py b/core/async_task.py index dc1d252..edaf1d7 100644 --- a/core/async_task.py +++ b/core/async_task.py @@ -110,7 +110,7 @@ class AsyncTask: async def init_tasks(self): settings = [ ("kfjk", "开服监控", lambda: self.jx3fun.kaifu("梦江南")), - ("xwzx", "新闻资讯", lambda: self.jx3fun.xinwei()), + ("xwzx", "新闻资讯", lambda: self.jx3fun.xinwen()), ] for key, name, fetch in settings: diff --git a/core/jx3_service.py b/core/jx3_service.py index d841888..7573dff 100644 --- a/core/jx3_service.py +++ b/core/jx3_service.py @@ -24,13 +24,13 @@ class JX3Service: if self.token == "": logger.info("获取配置token失败,请正确填写token,否则部分功能无法正常使用") else: - logger.info(f"获取配置token成功。{self.token}") + logger.debug(f"获取配置token成功。{self.token}") # 获取配置中的 ticket self.ticket = self._config.get("jx3api_ticket", "") if self.ticket == "": logger.info("获取配置ticket失败,请正确填写ticket,否则部分功能无法正常使用") else: - logger.info(f"获取配置ticket成功。{self.ticket}") + logger.debug(f"获取配置ticket成功。{self.ticket}") async def close(self): @@ -407,7 +407,7 @@ class JX3Service: return return_data - async def xinwei(self) -> Dict[str, Any]: + async def xinwen(self) -> Dict[str, Any]: """新闻资讯""" return_data = self._init_return_data() @@ -937,4 +937,55 @@ class JX3Service: return_data["data"] = result_msg return_data["code"] = 200 + return return_data + + + async def pianzhi(self, uid: str) -> Dict[str, Any]: + """骗子查询""" + return_data = self._init_return_data() + + # 1. 构造请求参数 + params = {"uid": uid, "token": self.token} + + # 2. 调用基础请求 + data: Optional[Dict[str, Any]] = await self._base_request( + "jx3_pianzhi", "GET", params=params + ) + + if not data: + return_data["msg"] = "获取接口信息失败" + return return_data + + # 3. 处理返回数据 + try: + records = data["records"] + + if not records: + result_msg = "未找到该用户行骗记录,很棒!继续保持!" + else: + result_msg = "" + + for record in records: + result_msg += f"区服:{record['server']} 标签:{record['tieba']}\n" + + list_id = 1 + for item in record["data"]: + result_msg += f"{list_id}、标题:{item['title']}\n" + result_msg += f"地址:{item['url']}\n" + result_msg += f"ID:{item['tid']}\n" + result_msg += f"内容:{item['text']}\n" + result_msg += ( + f"时间:{datetime.fromtimestamp(item['time']).strftime('%Y-%m-%d %H:%M:%S')}\n" + ) + list_id += 1 + + result_msg += "\n" + + except Exception as e: + logger.error(f"处理返回数据失败: {e}") + return_data["msg"] = "处理返回数据失败" + + return_data["data"] = result_msg + return_data["code"] = 200 + return return_data \ No newline at end of file diff --git a/data/api_config.json b/data/api_config.json index 2652292..36ec3d0 100644 --- a/data/api_config.json +++ b/data/api_config.json @@ -219,5 +219,14 @@ "params":{ "name": "穹野卫" } + }, + "jx3_pianzhi":{ + "url":"https://www.jx3api.com/data/fraud/detailed", + "method":"GET", + "description":"此接口用于通过用户的 QQ 号搜索其在贴吧上的行骗记录,包括贴吧名称、记录标题和详细内容。", + "params":{ + "uid": "", + "token": "" + } } } \ No newline at end of file diff --git a/main.py b/main.py index 909ec59..af5cbbf 100644 --- a/main.py +++ b/main.py @@ -489,6 +489,21 @@ class Jx3ApiPlugin(Star): yield event.plain_result("猪脑过载,请稍后再试") + @jx3.command("骗子") + async def jx3_pianzhi(self, event: AstrMessageEvent,qq: str = ""): + """剑三 骗子 服务器 天数""" + try: + data= await self.jx3fun.pianzhi(qq) + if data["code"] == 200: + yield event.plain_result(data["data"]) + else: + yield event.plain_result(data["msg"]) + return + except Exception as e: + logger.error(f"功能函数执行错误: {e}") + yield event.plain_result("猪脑过载,请稍后再试") + + @jx3.command("开服监控") async def jx3_kaifhujiank(self, event: AstrMessageEvent): """剑三 开服监控"""