pythonTest/爱回收.py

import tkinter as tk
from tkinter import ttk, messagebox
import json
import requests
import threading
from datetime import datetime
import uuid
import time
import os

class PhoneQueryApp:
    def __init__(self, root):
        self.root = root
        self.root.title("手机数据查询系统")
        self.root.geometry("1200x800")
        
        # 商品数据
        self.current_products = []
        self.is_loading_cycles = False
        self.collected_items = []
        
        # 从文件读取cookie
        self.cookie = self.load_cookie()
        
        # 创建界面
        self.create_widgets()
        
    def load_cookie(self):
        """从cookie.txt文件读取cookie"""
        cookie_file = "cookie.txt"
        if os.path.exists(cookie_file):
            try:
                with open(cookie_file, 'r', encoding='utf-8') as f:
                    cookie = f.read().strip()
                    print(f"已加载cookie: {cookie[:50]}...")
                    return cookie
            except Exception as e:
                print(f"读取cookie文件失败: {e}")
                return ""
        else:
            print("cookie.txt文件不存在，请创建并放入cookie")
            return ""
        
    def get_headers(self):
        """获取请求头"""
        return {
            "Connection": "keep-alive",
            "content-type": "application/json;charset=UTF-8",
            "ahs-app-version": "7.49.3",
            "Ahs-Timestamp": str(int(datetime.now().timestamp())),
            "Ahs-Token": "601cbf5a87f04ab78f4e7a75703027d0",
            "Ahs-Session-Id": str(uuid.uuid4()),
            "Ahs-App-Id": "10007",
            "Ahs-Device-Id": "cdf81407-32a7-4aa1-8900-d9fed9c930f8",
            "Ahs-Sign": "5c3478fe911b5eadfb38fb5e92626fb1",
            "User-Agent": "Mozilla/5.0 (iPhone; CPU iPhone OS 26_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 MicroMessenger/8.0.74(0x18004a2c) NetType/WIFI Language/zh_CN",
            "Referer": "https://servicewechat.com/wx7e490492b4c23e98/1055/page-frame.html",
            "Accept": "*/*",
            "Accept-Encoding": "gzip, deflate, br",
            "Cookie": self.cookie
        }
        
    def create_widgets(self):
        """创建界面组件"""
        main_frame = ttk.Frame(self.root, padding="10")
        main_frame.grid(row=0, column=0, sticky=(tk.W, tk.E, tk.N, tk.S))
        
        self.root.columnconfigure(0, weight=1)
        self.root.rowconfigure(0, weight=1)
        main_frame.columnconfigure(0, weight=1)
        main_frame.rowconfigure(2, weight=1)
        
        # 查询区域
        query_frame = ttk.LabelFrame(main_frame, text="查询条件", padding="10")
        query_frame.grid(row=0, column=0, sticky=(tk.W, tk.E), pady=(0, 10))
        query_frame.columnconfigure(1, weight=1)
        
        ttk.Label(query_frame, text="机型:", font=("Arial", 11)).grid(row=0, column=0, sticky=tk.W, padx=(0, 10))
        self.model_entry = ttk.Entry(query_frame, width=50, font=("Arial", 11))
        self.model_entry.grid(row=0, column=1, sticky=(tk.W, tk.E), padx=(0, 10))
        self.model_entry.insert(0, "iPhone 15 Pro")
        
        self.search_btn = ttk.Button(query_frame, text="搜索", command=self.search_products, width=15)
        self.search_btn.grid(row=0, column=2)
        
        # 筛选区域
        filter_frame = ttk.LabelFrame(main_frame, text="筛选条件", padding="10")
        filter_frame.grid(row=1, column=0, sticky=(tk.W, tk.E), pady=(0, 10))
        
        # 价格区间
        price_frame = ttk.LabelFrame(filter_frame, text="价格区间", padding="5")
        price_frame.grid(row=0, column=0, sticky=(tk.W, tk.E), padx=5, pady=5)
        
        self.price_vars = {}
        price_options = ["0-1499", "1500-1999", "2000-2999", "3000-3999", "4000以上"]
        for i, option in enumerate(price_options):
            var = tk.BooleanVar()
            self.price_vars[option] = var
            cb = ttk.Checkbutton(price_frame, text=option, variable=var)
            cb.grid(row=0, column=i, sticky=tk.W, padx=10, pady=2)
        
        # 成色
        fineness_frame = ttk.LabelFrame(filter_frame, text="成色", padding="5")
        fineness_frame.grid(row=0, column=1, sticky=(tk.W, tk.E), padx=5, pady=5)
        
        self.fineness_vars = {}
        fineness_options = ["全新仅拆封", "准新机", "99新", "95新", "9成新", "8成新", "7成新"]
        for i, option in enumerate(fineness_options):
            var = tk.BooleanVar()
            self.fineness_vars[option] = var
            cb = ttk.Checkbutton(fineness_frame, text=option, variable=var)
            cb.grid(row=0, column=i, sticky=tk.W, padx=10, pady=2)
        
        filter_frame.columnconfigure(0, weight=1)
        filter_frame.columnconfigure(1, weight=1)
        
        # 结果显示区域
        result_frame = ttk.LabelFrame(main_frame, text="查询结果", padding="10")
        result_frame.grid(row=2, column=0, sticky=(tk.W, tk.E, tk.N, tk.S))
        result_frame.columnconfigure(0, weight=1)
        result_frame.rowconfigure(0, weight=1)
        
        columns = ("名称", "价格", "循环次数", "成色", "内存", "颜色", "网络制式")
        self.result_tree = ttk.Treeview(result_frame, columns=columns, show="headings", height=15)
        
        self.result_tree.heading("名称", text="名称")
        self.result_tree.heading("价格", text="价格")
        self.result_tree.heading("循环次数", text="循环次数")
        self.result_tree.heading("成色", text="成色")
        self.result_tree.heading("内存", text="内存")
        self.result_tree.heading("颜色", text="颜色")
        self.result_tree.heading("网络制式", text="网络制式")
        
        self.result_tree.column("名称", width=400)
        self.result_tree.column("价格", width=100)
        self.result_tree.column("循环次数", width=100)
        self.result_tree.column("成色", width=100)
        self.result_tree.column("内存", width=80)
        self.result_tree.column("颜色", width=100)
        self.result_tree.column("网络制式", width=100)
        
        scrollbar = ttk.Scrollbar(result_frame, orient=tk.VERTICAL, command=self.result_tree.yview)
        self.result_tree.configure(yscrollcommand=scrollbar.set)
        self.result_tree.grid(row=0, column=0, sticky=(tk.W, tk.E, tk.N, tk.S))
        scrollbar.grid(row=0, column=1, sticky=(tk.N, tk.S))
        
        # 底部收藏栏
        bottom_frame = ttk.Frame(main_frame)
        bottom_frame.grid(row=3, column=0, sticky=(tk.W, tk.E), pady=(10, 0))
        
        ttk.Label(bottom_frame, text="循环次数小于:", font=("Arial", 10)).pack(side=tk.LEFT, padx=(0, 5))
        self.cycle_threshold = ttk.Entry(bottom_frame, width=10, font=("Arial", 10))
        self.cycle_threshold.pack(side=tk.LEFT, padx=(0, 5))
        self.cycle_threshold.insert(0, "600")
        ttk.Label(bottom_frame, text="次的机型自动收藏", font=("Arial", 10)).pack(side=tk.LEFT, padx=(0, 20))
        
        self.collect_btn = ttk.Button(bottom_frame, text="启动", command=self.start_collect, width=10)
        self.collect_btn.pack(side=tk.LEFT)
        
        self.progress_var = tk.StringVar()
        self.progress_var.set("")
        ttk.Label(bottom_frame, textvariable=self.progress_var, font=("Arial", 9)).pack(side=tk.LEFT, padx=(20, 0))
        
        self.collect_count_var = tk.StringVar()
        self.collect_count_var.set("")
        ttk.Label(bottom_frame, textvariable=self.collect_count_var, font=("Arial", 9), foreground="green").pack(side=tk.LEFT, padx=(10, 0))
        
        # 状态栏
        self.status_var = tk.StringVar()
        self.status_var.set("就绪")
        status_bar = ttk.Label(main_frame, textvariable=self.status_var, relief=tk.SUNKEN)
        status_bar.grid(row=4, column=0, sticky=(tk.W, tk.E), pady=(10, 0))
        
    def get_selected_prices(self):
        price_map = {
            "0-1499": (0, 1499),
            "1500-1999": (1500, 1999),
            "2000-2999": (2000, 2999),
            "3000-3999": (3000, 3999),
            "4000以上": (4000, 20000)
        }
        for option, var in self.price_vars.items():
            if var.get():
                return price_map[option]
        return (0, 20000)
        
    def get_selected_fineness(self):
        fineness_map = {
            "全新仅拆封": 111,
            "准新机": 100,
            "99新": 99,
            "95新": 95,
            "9成新": 90,
            "8成新": 80,
            "7成新": 70
        }
        selected = []
        for option, var in self.fineness_vars.items():
            if var.get():
                selected.append(fineness_map[option])
        return selected if selected else [99, 100, 111, 95, 90, 80, 70]
        
    def search_products(self):
        keyword = self.model_entry.get().strip()
        if not keyword:
            messagebox.showwarning("警告", "请输入机型")
            return
            
        for item in self.result_tree.get_children():
            self.result_tree.delete(item)
        self.current_products.clear()
        self.collected_items.clear()
        self.progress_var.set("")
        self.collect_count_var.set("")
        self.collect_btn.config(state="normal")
            
        self.status_var.set("正在搜索...")
        self.search_btn.config(state="disabled")
        
        thread = threading.Thread(target=self.do_search, args=(keyword,))
        thread.daemon = True
        thread.start()
        
    def do_search(self, keyword):
        try:
            min_price, max_price = self.get_selected_prices()
            fineness_ids = self.get_selected_fineness()
            
            request_data = {
                "minPrice": min_price,
                "maxPrice": max_price,
                "sortValue": "sort_composite",
                "gaeaPricePpvIds": {},
                "gaeaFinenessIds": fineness_ids,
                "conditionTagList": [],
                "scene": "search",
                "keyword": keyword,
                "sirReq": False,
                "cityId": 324,
                "pageIndex": 0,
                "pageSize": 50
            }
            
            url = "https://dubai-mp.aihuishou.com/ahs-yanxuan-service/products/search-goods-v2"
            response = requests.post(url, json=request_data, headers=self.get_headers(), timeout=30)
            result = response.json()
            
            self.root.after(0, self.display_results, result)
            
        except Exception as e:
            self.root.after(0, self.show_error, str(e))
            
    def parse_product_info(self, product):
        name = product.get('name', '')
        sale_goods_no = product.get('saleGoodsNo', '')
        product_no = product.get('productNo', '')
        
        color = ""
        memory = product.get('memoryDesc', '')
        
        if '黑色' in name:
            color = "黑色"
        elif '白色' in name:
            color = "白色"
        elif '蓝色' in name:
            color = "蓝色"
        elif '原色' in name:
            color = "原色"
            
        return {
            'name': name[:50],
            'price': product.get('price', 0),
            'cycle_count': '',
            'fineness': product.get('gaeaFinenessName', ''),
            'memory': memory,
            'color': color,
            'network': "全网通",
            'saleGoodsNo': sale_goods_no,
            'productNo': product_no
        }
        
    def display_results(self, result):
        self.search_btn.config(state="normal")
        
        if result.get('code') != 0:
            self.status_var.set(f"查询失败: {result.get('resultMessage', '未知错误')}")
            messagebox.showerror("错误", result.get('resultMessage', '查询失败'))
            return
            
        data = result.get('data', [])
        if not data:
            self.status_var.set("未找到相关产品")
            messagebox.showinfo("提示", "未找到相关产品")
            return
            
        for product in data:
            info = self.parse_product_info(product)
            item_id = self.result_tree.insert("", tk.END, values=(
                info['name'], f"¥{info['price']}", info['cycle_count'],
                info['fineness'], info['memory'], info['color'], info['network']
            ))
            self.current_products.append({
                'item_id': item_id,
                'saleGoodsNo': info['saleGoodsNo'],
                'productNo': info['productNo'],
                'info': info
            })
            
        self.status_var.set(f"共找到 {len(data)} 条结果")
        
    def get_cycle_count(self, sale_goods_no):
        """获取商品的电池循环次数"""
        try:
            url = f"https://dubai-mp.aihuishou.com/ahs-yanxuan-service/products/goods-tag-param?saleGoodsNo={sale_goods_no}"
            response = requests.get(url, headers=self.get_headers(), timeout=10)
            result = response.json()
            
            if result.get('code') == 0 and 'data' in result:
                data = result['data']
                if 'machineConditionList' in data:
                    for item in data['machineConditionList']:
                        if item.get('name') == '充电次数':
                            return item.get('value', '')
                if 'aggConditionTagParamList' in data:
                    for group in data['aggConditionTagParamList']:
                        if group.get('groupName') == '核心机况':
                            for item in group.get('valueList', []):
                                if item.get('name') == '充电次数':
                                    return item.get('value', '')
            return ''
        except Exception as e:
            print(f"获取循环次数失败: {e}")
            return ''
            
    def add_to_collection(self, item_no):
        """调用收藏接口添加收藏"""
        try:
            url = "https://dubai-mp.aihuishou.com/ahs-yanxuan-service/collect/save"
            payload = json.dumps({"itemNo": item_no, "type": 1})
            headers = self.get_headers()
            
            response = requests.post(url, data=payload, headers=headers, timeout=10)
            result = response.json()
            
            # 根据实际返回判断：code为200且data为True表示成功
            if result.get('code') == 200 and result.get('data') == True:
                return True, "收藏成功"
            else:
                return False, result.get('resultMessage', '收藏失败')
        except Exception as e:
            return False, str(e)
            
    def start_collect(self):
        if not self.current_products:
            messagebox.showwarning("警告", "请先搜索商品")
            return
        if self.is_loading_cycles:
            messagebox.showinfo("提示", "正在处理中，请稍候...")
            return
            
        if not self.cookie:
            result = messagebox.askyesno("提示", "未找到cookie.txt文件或cookie为空，是否继续？")
            if not result:
                return
            
        try:
            threshold = int(self.cycle_threshold.get().strip())
        except ValueError:
            messagebox.showerror("错误", "请输入有效的循环次数")
            return
            
        thread = threading.Thread(target=self.process_collect, args=(threshold,))
        thread.daemon = True
        thread.start()
        
    def process_collect(self, threshold):
        """处理收藏：获取循环次数并收藏符合条件的商品"""
        self.is_loading_cycles = True
        self.collect_btn.config(state="disabled")
        self.collected_items.clear()
        
        total = len(self.current_products)
        collected_count = 0
        
        for i, product in enumerate(self.current_products):
            self.root.after(0, lambda txt=f"处理: {i+1}/{total}": self.progress_var.set(txt))
            self.root.after(0, lambda i=i: self.status_var.set(f"正在获取循环次数 ({i+1}/{total})..."))
            
            cycle_count = self.get_cycle_count(product['saleGoodsNo'])
            
            if cycle_count:
                values = list(self.result_tree.item(product['item_id'], 'values'))
                values[2] = cycle_count
                self.root.after(0, lambda pid=product['item_id'], vals=values: self.result_tree.item(pid, values=vals))
                
                try:
                    cycle_num = int(cycle_count)
                    
                    if cycle_num < threshold:
                        item_no = product['productNo'] or product['saleGoodsNo']
                        success, msg = self.add_to_collection(item_no)
                        
                        if success:
                            collected_count += 1
                            self.collected_items.append(f"{product['info']['name']} ({cycle_num}次)")
                            self.root.after(0, lambda: self.status_var.set(f"✓ 已收藏: {product['info']['name'][:30]}"))
                except ValueError:
                    pass
            
            time.sleep(0.3)
            
        self.root.after(0, lambda: self.finish_collect(collected_count, threshold))
        
    def finish_collect(self, collected_count, threshold):
        self.is_loading_cycles = False
        self.collect_btn.config(state="normal")
        self.progress_var.set("")
        self.collect_count_var.set(f"已收藏: {collected_count} 件")
        self.status_var.set(f"完成！处理 {len(self.current_products)} 条，收藏 {collected_count} 件")
        
        if collected_count > 0:
            detail = "\n".join(self.collected_items[:5])
            if len(self.collected_items) > 5:
                detail += f"\n... 等共{collected_count}件"
            messagebox.showinfo("收藏完成", f"已成功收藏 {collected_count} 件商品\n\n{detail}")
        else:
            messagebox.showinfo("完成", f"没有找到循环次数小于 {threshold} 的商品")
        
    def show_error(self, error_msg):
        self.search_btn.config(state="normal")
        self.status_var.set(f"查询失败: {error_msg}")
        messagebox.showerror("错误", f"查询失败: {error_msg}")

def main():
    root = tk.Tk()
    app = PhoneQueryApp(root)
    root.mainloop()

if __name__ == "__main__":
    main()