|
|
@@ -0,0 +1,440 @@
|
|
|
+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()
|
PUGE