初始提交：闲鱼搜索API服务

.env.example

@@ -0,0 +1,2 @@
+# 闲鱼cookies（需包含_m_h5_tk和_m_h5_tk_enc）
+GOOFISH_COOKIES=_m_h5_tk=xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx_xxxxxxxxxx; _m_h5_tk_enc=xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx 

.github/workflows/main.yml

@@ -0,0 +1,25 @@
+name: Deploy to Hugging Face
+
+on:
+  push:
+    branches: [ main ]
+  workflow_dispatch:  # 允许手动触发
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+        with:
+          fetch-depth: 0
+      
+      - name: 推送到Hugging Face Spaces
+        env:
+          HF_TOKEN: ${{ secrets.HF_TOKEN }}
+          HF_USERNAME: ${{ secrets.HF_USERNAME }}
+          HF_SPACE_NAME: ${{ secrets.HF_SPACE_NAME }}
+        run: |
+          git config --global user.email "action@github.com"
+          git config --global user.name "GitHub Action"
+          git remote add space https://$HF_USERNAME:$HF_TOKEN@huggingface.co/spaces/$HF_USERNAME/$HF_SPACE_NAME
+          git push --force space main 

.gitignore

@@ -0,0 +1,37 @@
+# Python
+__pycache__/
+*.py[cod]
+*$py.class
+*.so
+.Python
+env/
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# 环境变量
+.env
+
+# 日志
+*.log
+
+# IDE
+.idea/
+.vscode/
+*.swp
+*.swo
+
+# 系统文件
+.DS_Store
+Thumbs.db 

Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3.9-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY . .
+
+# 设置环境变量
+ENV HOST=0.0.0.0
+ENV PORT=7860
+
+# 暴露端口（Hugging Face Spaces使用7860端口）
+EXPOSE 7860
+
+# 启动应用
+CMD ["python", "app.py"] 

README-HF.md

@@ -0,0 +1,74 @@
+# 闲鱼搜索API
+
+这是一个用于搜索闲鱼商品的API服务，提供快速、简单的方式获取闲鱼商品数据。
+
+## API文档
+
+访问 `/docs` 可查看完整的API文档。
+
+### 主要功能
+
+- 商品搜索（关键词搜索）
+- 价格区间筛选
+- 发布时间筛选
+- 分页功能
+
+### 使用示例
+
+1. 基本搜索：
+```
+/api/search?keyword=手机
+```
+
+2. 价格区间搜索：
+```
+/api/search?keyword=手机&min_price=100&max_price=500
+```
+
+3. 最近发布时间：
+```
+/api/search?keyword=手机&publish_days=3
+```
+
+4. 组合条件：
+```
+/api/search?keyword=手机&min_price=100&max_price=500&publish_days=3&page=1&page_size=20
+```
+
+## 返回数据格式
+
+```json
+{
+  "code": 0,
+  "message": "success",
+  "data": [
+    {
+      "title": "商品标题",
+      "price": 100.0,
+      "item_id": "123456789",
+      "area": "商品所在地区",
+      "seller_nick": "卖家昵称",
+      "publish_time": "发布时间",
+      "pics": ["商品图片URL"],
+      "want_count": 5,
+      "detail_url": "https://www.goofish.com/item?id=123456789"
+    },
+    ...
+  ],
+  "total": 30
+}
+```
+
+## 部署说明
+
+本API服务基于FastAPI构建，使用Docker部署在Hugging Face Spaces上。
+
+如需本地运行，请确保:
+
+1. 安装所需依赖：`pip install -r requirements.txt`
+2. 设置环境变量：在 `.env` 文件中添加 `GOOFISH_COOKIES=你的闲鱼cookies`
+3. 运行服务：`python api_server.py`
+
+## 免责声明
+
+本项目仅用于学习和研究目的，请勿用于商业用途。使用本API访问数据时请遵守闲鱼的使用条款和政策。 

README.md

@@ -0,0 +1,66 @@
+---
+layout: default
+title: 闲鱼搜索API
+description: 一个用于搜索闲鱼商品的API服务
+---
+
+# 闲鱼搜索API
+
+这是一个用于搜索闲鱼商品的API服务，提供快速、简单的方式获取闲鱼商品数据。
+
+## 功能特点
+
+- 商品搜索（关键词搜索）
+- 价格区间筛选
+- 发布时间筛选
+- 分页功能
+- 完整的API文档
+
+## 使用方法
+
+### 安装依赖
+
+```bash
+pip install -r requirements.txt
+```
+
+### 设置环境变量
+
+创建一个 `.env` 文件，添加以下内容：
+
+```
+GOOFISH_COOKIES=你的闲鱼cookies
+```
+
+### 启动服务
+
+```bash
+python api_server.py
+```
+
+访问 http://localhost:8000/docs 查看API文档
+
+## API使用示例
+
+1. 基本搜索：
+```
+http://localhost:8000/api/search?keyword=手机
+```
+
+2. 价格区间搜索：
+```
+http://localhost:8000/api/search?keyword=手机&min_price=100&max_price=500
+```
+
+3. 最近发布时间：
+```
+http://localhost:8000/api/search?keyword=手机&publish_days=3
+```
+
+## 部署到Hugging Face Spaces
+
+本项目可以部署到Hugging Face Spaces，详情请参考 `README-HF.md`。
+
+## 免责声明
+
+本项目仅用于学习和研究目的，请勿用于商业用途。使用本API访问数据时请遵守闲鱼的使用条款和政策。 

api_server.py

@@ -0,0 +1,74 @@
+import os
+from fastapi import FastAPI, Query, HTTPException
+from fastapi.staticfiles import StaticFiles
+from fastapi.responses import RedirectResponse
+from typing import List, Optional
+from pydantic import BaseModel
+from goofish_api import GoofishAPI
+from data_parser import ItemDetail, parse_search_result
+
+# 定义搜索响应模型
+class SearchResponse(BaseModel):
+    code: int = 0
+    message: str = "success"
+    data: List[ItemDetail]
+    total: int = 0
+
+app = FastAPI(
+    title="闲鱼搜索API", 
+    description="搜索闲鱼商品的API服务",
+    version="1.0.0"
+)
+
+# 挂载静态文件
+app.mount("/static", StaticFiles(directory="static"), name="static")
+
+# 初始化API客户端
+goofish_client = GoofishAPI()
+
+@app.get("/", include_in_schema=False)
+async def root():
+    return RedirectResponse(url="/static/index.html")
+
+@app.get("/api/search", response_model=SearchResponse, tags=["搜索"])
+async def search(
+    keyword: str = Query(..., description="搜索关键词"),
+    page: int = Query(1, description="页码，从1开始"),
+    page_size: int = Query(10, description="每页结果数量，最大40"),
+    min_price: Optional[float] = Query(None, description="最低价格"),
+    max_price: Optional[float] = Query(None, description="最高价格"),
+    publish_days: Optional[int] = Query(None, description="最近发布天数，例如3表示最近3天发布的商品")
+):
+    """
+    搜索闲鱼商品
+    """
+    try:
+        # 调用GoofishAPI的search方法，参数名称要与GoofishAPI.search方法一致
+        raw_result = goofish_client.search(
+            keyword=keyword,
+            page_number=page,
+            rows_per_page=page_size,
+            min_price=min_price,
+            max_price=max_price,
+            publish_days=publish_days
+        )
+        
+        # 解析结果
+        items = parse_search_result(raw_result)
+        total = len(items)
+        
+        # 构建响应
+        return SearchResponse(
+            code=0,
+            message="success",
+            data=items,
+            total=total
+        )
+    except Exception as e:
+        print(f"搜索出错: {str(e)}")
+        raise HTTPException(status_code=500, detail=f"搜索出错：{str(e)}")
+
+if __name__ == "__main__":
+    port = int(os.environ.get("PORT", 8000))
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=port) 

app.py

@@ -0,0 +1,8 @@
+import os
+from api_server import app
+import uvicorn
+
+# Hugging Face Spaces默认使用端口7860
+if __name__ == "__main__":
+    port = int(os.environ.get("PORT", 7860))
+    uvicorn.run(app, host="0.0.0.0", port=port) 

data_parser.py

@@ -0,0 +1,109 @@
+from typing import List, Dict, Optional
+from pydantic import BaseModel, Field
+import json
+
+class ItemLocation(BaseModel):
+    area: str
+
+class ItemPrice(BaseModel):
+    price: float
+    
+class ItemDetail(BaseModel):
+    title: str
+    price: float
+    item_id: str
+    area: str
+    seller_nick: str
+    publish_time: Optional[str]
+    pics: List[str]
+    want_count: int = 0
+    detail_url: str = ""  # 添加商品详情页URL字段
+    
+def safe_int(value: str, default: int = 0) -> int:
+    """安全地将字符串转换为整数"""
+    try:
+        if not value:
+            return default
+        return int(value)
+    except (ValueError, TypeError):
+        return default
+
+def safe_float(value: str, default: float = 0.0) -> float:
+    """安全地将字符串转换为浮点数"""
+    try:
+        if not value:
+            return default
+        return float(value)
+    except (ValueError, TypeError):
+        return default
+    
+def parse_search_result(raw_data: Dict) -> List[ItemDetail]:
+    """解析搜索结果数据"""
+    print("开始解析数据...")
+    
+    if not raw_data or 'data' not in raw_data:
+        print("无效的数据格式：缺少 'data' 字段")
+        return []
+        
+    if 'resultList' not in raw_data['data']:
+        print("无效的数据格式：缺少 'resultList' 字段")
+        print(f"可用的字段: {list(raw_data['data'].keys())}")
+        return []
+        
+    items = []
+    items_array = raw_data['data'].get('resultList', [])
+    print(f"找到 {len(items_array)} 个商品")
+    
+    for idx, item_data in enumerate(items_array):
+        try:
+            if 'data' not in item_data:
+                print(f"商品 {idx} 缺少 'data' 字段")
+                continue
+                
+            if 'item' not in item_data['data']:
+                print(f"商品 {idx} 缺少 'item' 字段")
+                continue
+                
+            item = item_data['data']['item']
+            if 'main' not in item:
+                print(f"商品 {idx} 缺少 'main' 字段")
+                continue
+                
+            if 'exContent' not in item['main']:
+                print(f"商品 {idx} 缺少 'exContent' 字段")
+                continue
+                
+            ex_content = item['main']['exContent']
+            detail_params = ex_content.get('detailParams', {})
+            
+            # 提取价格
+            price = safe_float(detail_params.get('soldPrice', 0))
+            
+            # 提取商品ID
+            item_id = ex_content.get('itemId', '')
+            
+            # 构建商品详情页URL
+            detail_url = f"https://www.goofish.com/item?id={item_id}" if item_id else ""
+            
+            # 构建商品详情
+            item_detail = ItemDetail(
+                title=ex_content.get('title', ''),
+                price=price,
+                item_id=item_id,
+                area=ex_content.get('area', ''),
+                seller_nick=ex_content.get('userNickName', ''),
+                publish_time=str(detail_params.get('publishTime', '')),
+                pics=[ex_content.get('picUrl', '')] if ex_content.get('picUrl') else [],
+                want_count=safe_int(ex_content.get('want', '0')),
+                detail_url=detail_url
+            )
+            
+            items.append(item_detail)
+            print(f"成功解析商品 {idx}: {item_detail.title[:30]}...")
+            
+        except Exception as e:
+            print(f"解析商品 {idx} 时出错: {str(e)}")
+            continue
+        
+    print(f"成功解析 {len(items)} 个商品")
+    return items 

goofish_api.py

@@ -0,0 +1,138 @@
+import requests
+import time
+import hashlib
+import json
+from dotenv import load_dotenv
+import os
+
+def parse_cookies(cookie_str):
+    """将cookie字符串解析为字典"""
+    cookies = {}
+    for item in cookie_str.split(';'):
+        if '=' in item:
+            name, value = item.strip().split('=', 1)
+            cookies[name] = value
+    return cookies
+
+class GoofishAPI:
+    def __init__(self):
+        self.base_url = "https://h5api.m.goofish.com"
+        self.app_key = "34839810"
+        self.headers = {
+            'accept': 'application/json',
+            'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8',
+            'content-type': 'application/x-www-form-urlencoded',
+            'origin': 'https://www.goofish.com',
+            'referer': 'https://www.goofish.com/',
+            'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36 Edg/134.0.0.0'
+        }
+        # 从环境变量加载cookie
+        load_dotenv()
+        cookie_str = os.getenv('GOOFISH_COOKIES', '')
+        
+        # 如果没有找到环境变量，尝试使用默认cookie
+        if not cookie_str:
+            print("警告：未找到GOOFISH_COOKIES环境变量，使用内置默认cookie")
+            # 设置一个简单的默认cookie，可能无法正常工作
+            cookie_str = "_m_h5_tk=6e9d46fed73aae0bf6be61ee132e9a06_1742723039105; _m_h5_tk_enc=6eb4c709b4fbcad1a927c771c7beef21"
+        
+        self.cookies = parse_cookies(cookie_str)
+
+    def _get_sign(self, t, data):
+        """生成签名"""
+        token = self.cookies.get('_m_h5_tk', '').split('_')[0]
+        sign_str = f"{token}&{t}&{self.app_key}&{data}"
+        return hashlib.md5(sign_str.encode('utf-8')).hexdigest()
+
+    def search(self, keyword, page_number=1, rows_per_page=30, min_price=None, max_price=None, publish_days=None):
+        """
+        搜索商品
+        
+        Args:
+            keyword (str): 搜索关键词
+            page_number (int): 页码，从1开始
+            rows_per_page (int): 每页数量
+            min_price (float, optional): 最低价格
+            max_price (float, optional): 最高价格
+            publish_days (int, optional): 发布时间范围（天）
+        """
+        t = str(int(time.time() * 1000))
+        
+        # 构建搜索过滤条件
+        search_filters = []
+        
+        # 添加价格区间
+        if min_price is not None or max_price is not None:
+            min_price = min_price if min_price is not None else 0
+            max_price = max_price if max_price is not None else ''
+            search_filters.append(f"priceRange:{min_price},{max_price}")
+            
+        # 添加发布时间
+        if publish_days is not None:
+            search_filters.append(f"publishDays:{publish_days}")
+            
+        # 构建propValueStr
+        prop_value_str = {}
+        if search_filters:
+            prop_value_str["searchFilter"] = ";".join(search_filters)
+        
+        # 构建请求数据
+        data = {
+            "pageNumber": page_number,
+            "keyword": keyword,
+            "fromFilter": bool(search_filters),  # 如果有过滤条件则为True
+            "rowsPerPage": rows_per_page,
+            "sortValue": "",
+            "sortField": "",
+            "customDistance": "",
+            "gps": "",
+            "propValueStr": prop_value_str,
+            "customGps": "",
+            "searchReqFromPage": "pcSearch",
+            "extraFilterValue": "{}",
+            "userPositionJson": "{}"
+        }
+        
+        data_str = json.dumps(data)
+        sign = self._get_sign(t, data_str)
+        
+        # 构建URL参数
+        params = {
+            'jsv': '2.7.2',
+            'appKey': self.app_key,
+            't': t,
+            'sign': sign,
+            'v': '1.0',
+            'type': 'originaljson',
+            'accountSite': 'xianyu',
+            'dataType': 'json',
+            'timeout': '20000',
+            'api': 'mtop.taobao.idlemtopsearch.pc.search',
+            'sessionOption': 'AutoLoginOnly',
+            'spm_cnt': 'a21ybx.search.0.0',
+            'spm_pre': 'a21ybx.home.searchInput.0'
+        }
+        
+        url = f"{self.base_url}/h5/mtop.taobao.idlemtopsearch.pc.search/1.0/"
+        
+        try:
+            response = requests.post(
+                url,
+                params=params,
+                data={'data': data_str},
+                headers=self.headers,
+                cookies=self.cookies
+            )
+            return response.json()
+        except Exception as e:
+            print(f"请求失败: {str(e)}")
+            return None
+
+def main():
+    api = GoofishAPI()
+    # 测试搜索手机
+    result = api.search("手机")
+    print(json.dumps(result, ensure_ascii=False, indent=2))
+
+if __name__ == "__main__":
+    main() 

requirements.txt

@@ -0,0 +1,7 @@
+fastapi==0.104.0
+uvicorn==0.23.2
+requests==2.31.0
+python-dotenv==1.0.0
+pydantic==2.4.2
+starlette==0.27.0
+httpx==0.24.1 

space.yaml

@@ -0,0 +1,8 @@
+title: 闲鱼搜索API
+emoji: 🦑
+colorFrom: blue
+colorTo: purple
+sdk: docker
+app_port: 7860
+pinned: false
+license: mit 

static/index.html

@@ -0,0 +1,92 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>闲鱼搜索API</title>
+    <style>
+        body {
+            font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
+            line-height: 1.6;
+            color: #333;
+            max-width: 800px;
+            margin: 0 auto;
+            padding: 20px;
+        }
+        h1 {
+            color: #2c3e50;
+            border-bottom: 2px solid #3498db;
+            padding-bottom: 10px;
+        }
+        h2 {
+            color: #2980b9;
+            margin-top: 30px;
+        }
+        pre {
+            background-color: #f8f9fa;
+            border: 1px solid #e9ecef;
+            border-radius: 4px;
+            padding: 15px;
+            overflow-x: auto;
+        }
+        code {
+            font-family: Consolas, Monaco, 'Andale Mono', monospace;
+            color: #e74c3c;
+        }
+        .btn {
+            display: inline-block;
+            background-color: #3498db;
+            color: white;
+            padding: 10px 15px;
+            text-decoration: none;
+            border-radius: 4px;
+            margin-top: 10px;
+        }
+        .btn:hover {
+            background-color: #2980b9;
+        }
+    </style>
+</head>
+<body>
+    <h1>🦑 闲鱼搜索API</h1>
+    <p>欢迎使用闲鱼搜索API服务，本服务提供简单易用的API接口，帮助您快速获取闲鱼商品数据。</p>
+    
+    <a href="/docs" class="btn">查看完整API文档</a>
+    
+    <h2>API使用示例</h2>
+    
+    <h3>基本搜索</h3>
+    <pre><code>GET /api/search?keyword=手机</code></pre>
+    
+    <h3>带价格区间的搜索</h3>
+    <pre><code>GET /api/search?keyword=手机&min_price=1000&max_price=2000</code></pre>
+    
+    <h3>搜索最近3天发布的商品</h3>
+    <pre><code>GET /api/search?keyword=手机&publish_days=3</code></pre>
+    
+    <h3>分页</h3>
+    <pre><code>GET /api/search?keyword=手机&page=2&page_size=20</code></pre>
+    
+    <h2>返回数据格式</h2>
+    <pre><code>{
+  "code": 0,
+  "message": "success",
+  "data": [
+    {
+      "item_id": "商品ID",
+      "title": "商品标题",
+      "price": "价格",
+      "pics": ["图片URL列表"],
+      "location": "地点",
+      "publish_time": "发布时间",
+      "detail_url": "详情页URL"
+    },
+    ...
+  ],
+  "total": 商品总数
+}</code></pre>
+
+    <h2>免责声明</h2>
+    <p>本项目仅用于学习和研究目的，请勿用于商业用途。使用本API访问数据时请遵守闲鱼的使用条款和政策。</p>
+</body>
+</html>