save

test2.py

@@ -8,7 +8,7 @@ import base64
 from urllib.parse import quote, urlparse, parse_qsl
 from io import BytesIO
 
-# ==================== 配置（全部填好，直接运行） ====================
+# ==================== 配置 ====================
 CLIENT_ID = "amzn1.application-oa2-client.9f775d35077a4c7598116e5a89b60222"
 CLIENT_SECRET = "amzn1.oa2-cs.v1.6909777baa82b796555a431cd23709342e8e01434abcad1f8b59cadf048b51c3"
 REFRESH_TOKEN = "Atzr|IwEBICh_fojh7qAfrePzSjOZhQxTnHRZCYOuWNvSAHGaBs1WfkjR4qjC1Dmv0uK3oyq_L-R9SRKK4cYmPwF1MQXQdqKlpzOAGItWeXnNzh-SyhHHISv0_vCt3D6hluVmIEmF2kA7ro_XF-PslD41g3Eq6bv0Qq4y4pQbkDj-9dudDuz7nku8UL-nc4EWgJCrHCJTAs8TK48Yvrfi3E35uv97tYhs6qb8D9d4dR9C7daaC49eoDqP88qyUHThQV1Kqon8xukx4AT2_wLqWNcabpADzuK-5w7D-vvFFtvzfkbmtfzoPeEdHPulG6scc59BPFTyBlGU7a3d1JSFg2ROHIlrljRm"
@@ -17,15 +17,14 @@ AWS_ACCESS_KEY = "AKIA24CLQSVTW2K4S6RP"
 AWS_SECRET_KEY = "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"
 AWS_REGION = "us-east-1"
 
-SELLER_ID = "A1H50Z0WYYLEGQ"
-SKU = "bar table pink"
 MARKETPLACE_ID = "ATVPDKIKX0DER"
 ASIN = "B0FR1WRK4M"
-
-CONTENT_KEY = f"amzn1.aplus.content.v1.{uuid.uuid4()}"
 IMAGE_URL = "https://cunchu.site/temp/8c7a90e1-a5a1-41af-a119-41b1ca74b40d.png"
 
-# ==================== 签名工具（复用你之前的） ====================
+TARGET_WIDTH = 970
+TARGET_HEIGHT = 600
+
+# ==================== 签名工具 ====================
 def sha256_hash(data): 
     return hashlib.sha256(data.encode("utf-8")).hexdigest()
 
@@ -39,8 +38,7 @@ def get_signature_key(secret_key, date_stamp, region, service):
     return hmac_sha256(k_service, "aws4_request")
 
 def get_access_token():
-    url = "https://api.amazon.com/auth/o2/token"
-    resp = requests.post(url, data={
+    resp = requests.post("https://api.amazon.com/auth/o2/token", data={
         "grant_type": "refresh_token",
         "refresh_token": REFRESH_TOKEN,
         "client_id": CLIENT_ID,
@@ -98,107 +96,91 @@ def spapi_request(method, path, query, body=None, access_token=None):
     url = f"https://{host}{path}?{query}"
     return requests.request(method, url, headers=headers, data=payload or None)
 
-# ==================== Step 1: 下载图片并计算 MD5 ====================
-def download_and_hash_image(image_url):
-    print(f"⬇️ 下载图片: {image_url}")
-    resp = requests.get(image_url, timeout=30)
-    resp.raise_for_status()
-    image_binary = resp.content
-    print(f"   图片大小: {len(image_binary)} bytes")
+# ==================== 主程序 ====================
+if __name__ == "__main__":
+    print("=" * 60)
+    print("A+ Content 完整流程 - marketplaceId 修正版")
+    print("=" * 60)
     
-    md5_hash = hashlib.md5(image_binary).digest()
-    content_md5 = base64.b64encode(md5_hash).decode('utf-8')
-    print(f"   Content-MD5: {content_md5}")
+    # Step 0
+    print("\n🔑 Step 0: 获取 Access Token...")
+    token = get_access_token()
+    print("   ✅ Token 获取成功")
+    
+    # Step 1
+    print("\n📥 Step 1: 下载图片并调整尺寸...")
+    img_resp = requests.get(IMAGE_URL, timeout=30)
+    img_resp.raise_for_status()
     
-    width, height = 1940, 1200
     try:
         from PIL import Image
-        img = Image.open(BytesIO(image_binary))
-        width, height = img.size
-        print(f"   图片尺寸: {width}x{height}")
+        img = Image.open(BytesIO(img_resp.content))
+        print(f"   原图尺寸: {img.size}")
+        img_resized = img.resize((TARGET_WIDTH, TARGET_HEIGHT), Image.LANCZOS)
+        buffer = BytesIO()
+        img_resized.save(buffer, format="PNG")
+        image_binary = buffer.getvalue()
+        print(f"   ✅ 调整后尺寸: {TARGET_WIDTH}x{TARGET_HEIGHT}")
     except ImportError:
-        print(f"   未安装 Pillow，使用默认尺寸: {width}x{height}")
+        print("   ❌ 需要安装 Pillow: pip install Pillow")
+        exit(1)
     
-    return image_binary, content_md5, width, height
-
-# ==================== Step 2: 创建上传目标（官方修正版） ====================
-def create_upload_destination(access_token, content_md5, content_type):
-    """
-    官方修正：resource 固定为 aplus/2020-11-01/contentDocuments
-    不需要 contentDocumentId，不需要图片文件名！
-    """
-    resource = "aplus/2020-11-01/contentDocuments"  # ← 关键修正：固定字符串
-    encoded_resource = quote(resource, safe="/")
-    
-    path = f"/uploads/2020-11-01/uploadDestinations/{encoded_resource}"
-    query = f"marketplaceIds={MARKETPLACE_ID}&contentMD5={quote(content_md5, safe='')}&contentType={quote(content_type, safe='')}"
-    
-    print(f"\n📝 创建上传目标...")
-    print(f"   Resource: {resource}")
-    print(f"   Content-MD5: {content_md5}")
-    print(f"   Content-Type: {content_type}")
-    
-    resp = spapi_request("POST", path, query, access_token=access_token)
-    print(f"📤 状态码: {resp.status_code}")
-    print(f"📄 响应: {resp.text}")
-    
-    if resp.status_code != 200:
-        return None, None
-    
-    data = resp.json()
-    upload_destination_id = data.get("uploadDestinationId")
-    url = data.get("url")
-    
-    print(f"✅ uploadDestinationId: {upload_destination_id}")
-    print(f"✅ upload URL: {url[:120]}...")
-    
-    return upload_destination_id, url
-
-# ==================== Step 3: Multipart Form POST 上传图片到 S3 ====================
-def upload_image_to_s3(upload_url, image_binary, content_type):
-    print(f"\n⬆️ 解析预签名 URL 并上传图片...")
+    md5_hash = hashlib.md5(image_binary).digest()
+    content_md5 = base64.b64encode(md5_hash).decode('utf-8')
+    print(f"   图片大小: {len(image_binary)} bytes")
     
-    parsed = urlparse(upload_url)
-    base_url = f"{parsed.scheme}://{parsed.netloc}{parsed.path}"
-    query_params = dict(parse_qsl(parsed.query))
+    # Step 2: Uploads API 用 marketplaceIds（复数）✅
+    print("\n📝 Step 2: 创建上传目标...")
+    resource = "aplus/2020-11-01/contentDocuments"
+    path = f"/uploads/2020-11-01/uploadDestinations/{quote(resource, safe='/')}"
+    query = f"marketplaceIds={MARKETPLACE_ID}&contentMD5={quote(content_md5, safe='')}&contentType=image%2Fpng"
     
-    print(f"   Base URL: {base_url}")
-    print(f"   Form fields: {list(query_params.keys())}")
+    resp = spapi_request("POST", path, query, access_token=token)
+    print(f"   状态码: {resp.status_code}")
     
-    files = {
-        "File": ("image.png", image_binary, content_type)
-    }
+    if resp.status_code not in [200, 201]:
+        print(f"   ❌ 失败: {resp.text}")
+        exit(1)
     
-    resp = requests.post(base_url, data=query_params, files=files, timeout=60)
-    print(f"📤 S3 上传状态码: {resp.status_code}")
+    payload = resp.json().get("payload", {})
+    upload_id = payload.get("uploadDestinationId")
+    upload_url = payload.get("url")
+    print(f"   ✅ uploadDestinationId: {upload_id}")
     
-    if resp.text:
-        print(f"📄 S3 响应: {resp.text[:500]}")
+    # Step 3
+    print("\n⬆️ Step 3: 上传图片到 S3...")
+    parsed = urlparse(upload_url)
+    base_url = f"{parsed.scheme}://{parsed.netloc}{parsed.path}"
+    query_params = dict(parse_qsl(parsed.query))
+    files = {"File": ("image.png", image_binary, "image/png")}
+    s3_resp = requests.post(base_url, data=query_params, files=files, timeout=60)
+    print(f"   S3 状态码: {s3_resp.status_code}")
     
-    return resp.status_code in [200, 201, 204]
-
-# ==================== Step 4: 创建 A+ Content 文档 ====================
-def create_content_document(access_token, content_key, upload_id, img_width, img_height):
-    path = "/aplus/2020-11-01/contentDocuments"
-    query = f"marketplaceIds={MARKETPLACE_ID}"
-    
-    body = {
-        "contentDocument": {
-            "name": "Product Detail Image",
-            "contentReference": {
-                "key": content_key,
-                "version": "0"
-            },
-            "contentModuleList": [
-                {
-                    "moduleType": "STANDARD_SINGLE_IMAGE",
-                    "standardSingleImage": {
+    if s3_resp.status_code not in [200, 201, 204]:
+        print("   ❌ S3 上传失败")
+        exit(1)
+    print("   ✅ S3 上传成功")
+    
+    # 构建 contentDocument
+    content_doc = {
+        "name": "Product Image",
+        "contentType": "EMC",
+        "locale": "en-US",
+        "contentModuleList": [
+            {
+                "contentModuleType": "STANDARD_HEADER_IMAGE_TEXT",
+                "standardHeaderImageText": {
+                    "headline": {
+                        "value": "Premium Quality Bar Table",
+                        "decoratorSet": []
+                    },
+                    "block": {
                         "image": {
                             "uploadDestinationId": upload_id,
                             "imageCropSpecification": {
                                 "size": {
-                                    "width": {"value": img_width, "units": "pixels"},
-                                    "height": {"value": img_height, "units": "pixels"}
+                                    "width": {"value": TARGET_WIDTH, "units": "pixels"},
+                                    "height": {"value": TARGET_HEIGHT, "units": "pixels"}
                                 },
                                 "offset": {
                                     "x": {"value": 0, "units": "pixels"},
@@ -206,86 +188,87 @@ def create_content_document(access_token, content_key, upload_id, img_width, img
                                 }
                             },
                             "altText": "Product detail image"
+                        },
+                        "headline": {
+                            "value": "Elegant Design for Modern Living",
+                            "decoratorSet": []
+                        },
+                        "body": {
+                            "textList": [
+                                {
+                                    "value": "Space-saving bar-height table comfortably seats 2-6 people. Adjustable height, durable engineered wood construction, and smart storage shelves make it perfect for any home.",
+                                    "decoratorSet": []
+                                }
+                            ]
                         }
                     }
                 }
-            ]
-        }
+            }
+        ]
     }
     
-    print(f"\n📝 创建 A+ Content 文档...")
-    print(f"   Content Key: {content_key}")
-    resp = spapi_request("POST", path, query, body=body, access_token=access_token)
-    print(f"📤 状态码: {resp.status_code}")
-    print(resp.text)
-    return resp
-
-# ==================== Step 5: 绑定 ASIN ====================
-def associate_asin(access_token, content_key, asin):
-    path = f"/aplus/2020-11-01/contentDocuments/{content_key}/asins"
-    query = f"marketplaceIds={MARKETPLACE_ID}"
-    body = {"asinSet": [asin]}
-    
-    print(f"\n🔗 绑定 ASIN: {asin}")
-    resp = spapi_request("POST", path, query, body=body, access_token=access_token)
-    print(f"📤 状态码: {resp.status_code}")
-    print(resp.text)
-    return resp
-
-# ==================== Step 6: 提交审核 ====================
-def submit_approval(access_token, content_key):
-    path = f"/aplus/2020-11-01/contentDocuments/{content_key}/approvalSubmissions"
-    query = f"marketplaceIds={MARKETPLACE_ID}"
-    
-    print(f"\n📋 提交审核...")
-    resp = spapi_request("POST", path, query, access_token=access_token)
-    print(f"📤 状态码: {resp.status_code}")
-    print(resp.text)
-    return resp
-
-# ==================== 主程序 ====================
-if __name__ == "__main__":
-    print("🔑 获取 Access Token...")
-    token = get_access_token()
-    print("✅ 令牌获取成功")
+    # Step 4: 验证 - A+ API 用 marketplaceId（单数）❌ 之前错了
+    print("\n📝 Step 4: 验证内容文档...")
+    validate_body = {"contentDocument": content_doc}
     
-    print(f"\n🆔 Content Key: {CONTENT_KEY}")
-    print(f"🖼️ 图片URL: {IMAGE_URL}")
-    print(f"🔗 ASIN: {ASIN}")
+    # 关键修正：A+ Content API 用 marketplaceId（单数）
+    resp = spapi_request("POST", "/aplus/2020-11-01/contentAsinValidations", f"marketplaceId={MARKETPLACE_ID}", body=validate_body, access_token=token)
+    print(f"   验证状态码: {resp.status_code}")
+    print(f"   验证响应: {resp.text[:800]}")
     
-    # Step 1
-    print("\n=== Step 1: 下载图片 ===")
-    image_binary, content_md5, img_width, img_height = download_and_hash_image(IMAGE_URL)
+    # Step 5: 创建文档 - A+ API 用 marketplaceId（单数）❌ 之前错了
+    print("\n📝 Step 5: 创建 Content Document...")
     
-    # Step 2（官方修正版）
-    print("\n=== Step 2: 创建上传目标 ===")
-    upload_id, upload_url = create_upload_destination(token, content_md5, "image/png")
+    # 关键修正：A+ Content API 用 marketplaceId（单数）
+    resp = spapi_request("POST", "/aplus/2020-11-01/contentDocuments", f"marketplaceId={MARKETPLACE_ID}", body={"contentDocument": content_doc}, access_token=token)
+    print(f"   状态码: {resp.status_code}")
+    print(f"   响应: {resp.text}")
     
-    if not upload_id or not upload_url:
-        print("\n⛔ 创建上传目标失败，终止")
+    if resp.status_code not in [200, 201]:
+        print("\n   ❌ 创建失败")
         exit(1)
     
-    # Step 3
-    print("\n=== Step 3: 上传图片到 S3 ===")
-    success = upload_image_to_s3(upload_url, image_binary, "image/png")
-    if not success:
-        print("\n⛔ 图片上传失败，终止")
+    doc_data = resp.json()
+    content_ref = doc_data.get("contentReference", {})
+    content_key = content_ref.get("key")
+    
+    if not content_key:
+        print("   ❌ 响应中缺少 contentReference.key")
         exit(1)
-    print("✅ 图片上传成功")
     
-    # Step 4
-    print("\n=== Step 4: 创建内容文档 ===")
-    create_content_document(token, CONTENT_KEY, upload_id, img_width, img_height)
+    print(f"   ✅ 创建成功，Content Key: {content_key}")
+    
+    # Step 6: 绑定 ASIN - A+ API 用 marketplaceId（单数）❌ 之前错了
+    print("\n🔗 Step 6: 绑定 ASIN...")
+    body = {"asinSet": [ASIN]}
     
-    # Step 5
-    print("\n=== Step 5: 绑定ASIN ===")
-    associate_asin(token, CONTENT_KEY, ASIN)
+    # 关键修正：A+ Content API 用 marketplaceId（单数）
+    resp = spapi_request("POST", f"/aplus/2020-11-01/contentDocuments/{content_key}/asins", f"marketplaceId={MARKETPLACE_ID}", body=body, access_token=token)
+    print(f"   状态码: {resp.status_code}")
+    print(f"   响应: {resp.text[:500]}")
     
-    # Step 6
-    print("\n=== Step 6: 提交审核 ===")
-    submit_approval(token, CONTENT_KEY)
+    if resp.status_code not in [200, 201]:
+        print("   ❌ 绑定失败")
+        exit(1)
+    print("   ✅ ASIN 绑定成功")
     
-    print("\n🎉 全部步骤执行完毕！")
-    print("   A+ 内容已提交审核，通常需要 1-7 个工作日")
-    print(f"   Content Key: {CONTENT_KEY}")
-    print("   请保存此 Key 以便后续查询状态")
+    # Step 7: 提交审核 - A+ API 用 marketplaceId（单数）❌ 之前错了
+    print("\n📋 Step 7: 提交审核...")
+    
+    # 关键修正：A+ Content API 用 marketplaceId（单数）
+    resp = spapi_request("POST", f"/aplus/2020-11-01/contentDocuments/{content_key}/approvalSubmissions", f"marketplaceId={MARKETPLACE_ID}", access_token=token)
+    print(f"   状态码: {resp.status_code}")
+    print(f"   响应: {resp.text[:500]}")
+    
+    if resp.status_code not in [200, 201]:
+        print("   ❌ 提交失败")
+        exit(1)
+    print("   ✅ 审核提交成功")
+    
+    print("\n" + "=" * 60)
+    print("🎉 全部步骤执行成功！")
+    print(f"   Content Key: {content_key}")
+    print(f"   ASIN: {ASIN}")
+    print("=" * 60)
+    print("\n⚠️ 请保存 Content Key，用于后续查询状态")
+    print("   审核通常需要 1-7 个工作日")

天龙八部拍卖行.py

@@ -112,7 +112,7 @@ class AuctionBot:
             self.log("正在识别价格（本地Tesseract）...")
             
             # 只识别数字和小数点
-            custom_config = r'--psm 6 -c tessedit_char_whitelist=0123456789.'
+            custom_config = r'--psm 8 -c tessedit_char_whitelist=0123456789.'
             text = pytesseract.image_to_string(img, config=custom_config)
             
             text = text.strip()

注册.py

@@ -0,0 +1,25 @@
+import requests
+
+url = "https://www.greenmangaming.com/api/v2/register"
+
+payload = "{\"username\":\"adasdcc\",\"email\":\"asddsd@qq.com\",\"password\":\"asdasdasd\",\"confirmPassword\":\"asdasdasd\",\"isEmailFromExternal\":false,\"languagePreferenceCode\":\"zh\",\"isThirdPartyRegister\":false,\"currentLocationUrl\":\"/zh/\",\"radioCommunityEmailsOptIn\":null,\"radioMarketingEmailsOptIn\":null,\"hideBirthdayForm\":false,\"isExternalSignUp\":false,\"isPlayfireSignUp\":false,\"ReturnUrl\":\"/zh/\",\"newsletterOptIn\":false,\"termsAndConditions\":true,\"day\":\"01\",\"month\":\"03\",\"year\":\"2021\",\"Fingerprint\":\"DQ1MOkxlSt5BmkfA0f4w\"}"
+headers = {
+    "accept": "application/json, text/plain, */*",
+    "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,zh-TW;q=0.7",
+    "cache-control": "no-cache",
+    "content-type": "application/json;charset=UTF-8",
+    "current-url": "https://www.greenmangaming.com/zh/",
+    "dnt": "1",
+    "gmg-accept-language": "zh",
+    "origin": "https://www.greenmangaming.com",
+    "pragma": "no-cache",
+    "priority": "u=1, i",
+    "referer": "https://www.greenmangaming.com/zh/",
+    "sec-fetch-mode": "cors",
+    "sec-fetch-site": "same-origin",
+    "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/151.0.0.0 Safari/537.36"
+}
+
+response = requests.request("POST", url, data=payload, headers=headers)
+
+print(response.text)