队列消息

src/spa_search.py

@@ -235,6 +235,7 @@ def process_large_items(item_list, relation_data):
         relation = relation_data.get(asin, {})
 
         processed_item = item.copy()
+        processed_item.pop("Title")
         processed_item.pop("Asin")
         processed_item['Asin'] = asin
         processed_item['ERP SKU'] = relation.get("erp_sku")
@@ -258,12 +259,14 @@ def process_small_items(item_list, coop, relation_data):
         rebate = item.get("Rebate In Agreement Currency", None)
         vendor_funding = item.get("Vendor Funding In Agreement Currency", None)
 
-        processed_item = coop.copy()  # 复制 coop 数据
+        processed_item = coop.copy()
+        processed_item.pop("Agreement title")
+        processed_item["Order Date"] = item.get("Order Date")
+        processed_item["Agreement Currency"] = item.get("Agreement Currency")
         processed_item["Asin"] = asin
         processed_item["ERP SKU"] = relation.get("erp_sku")
         processed_item["Group Name"] = relation.get("name")
         processed_item["Original balance"] = rebate or vendor_funding
-
         processed_items.append(processed_item)
     return processed_items
 
@@ -308,11 +311,11 @@ def push_data_queue(file_name):
         push_data = {
             'ad_date': item_row.get('Order Date', ""),  # spa费用数据日期
             'erp_sku': item_row.get('ERP SKU', ""),  # ERP SKU
-            'ad_amount': item_row.get('Order Date', ""),  # spa费用金额
+            'ad_amount': item_row.get('Original balance', ""),  # spa费用金额
             'ad_amount_currency': item_row.get('Agreement Currency', ""),  # spa费用币制
             'amount_type': item_row.get('Order Date', ""),  # 费用类型
             'group_name': item_row.get('Group Name', ""),  # 组别 运营一组 运营二组
-            'group_code': item_row.get('Order Date', ""),  # 组别 T1 T2
+            'group_code': item_row.get('Group Code', ""),  # 组别 T1 T2
             'asin': item_row.get('Asin', ""),  # ASIN
             'shop_code': shop_code,  # 店铺code
             'type': 2,  # 1 sheet1 2 其他sheet