-
Notifications
You must be signed in to change notification settings - Fork 7
/
down_release2_0.py
188 lines (166 loc) · 6.83 KB
/
down_release2_0.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
"""
上下架商品
"""
from selenium import webdriver
from selenium.webdriver.chrome.options import Options
from selenium.webdriver.common.by import By
import time
from selenium.webdriver.common.keys import Keys
import requests
import json
import math
def list_to_json(cookie): # 将selenium获取的cookie列表整理成字典
cookie_json = {}
for i in cookie:
cookie_json[i['name']] = i['value']
return cookie_json
def json_to_string(cookies): # 将cookies字典整理成字符串
cookie = ''
for i in cookies:
cookie += i + '=' + cookies[i] + ';'
return cookie
def list_to_str(_list): # 将列表转换为参数需要的字符串格式
s = '['
for i in _list:
s += '"' + i + '"' + ','
s = s[:-1] + ']'
return s
def get_on_sale_data(): # 获取出售中的数据总量
url2 = 'https://item.upload.taobao.com/taobao/manager/table.htm'
headers2 = {
'cookie': cookie + f'XSRF-TOKEN={set_cookie["XSRF-TOKEN"]}',
'referer': f'https://item.upload.taobao.com/taobao/manager/render.htm?pagination.current=1&pagination.pageSize=20&tab=on_sale&table.sort.startDate_m=desc',
'user-agent': ua,
'x-xsrf-token': set_cookie["XSRF-TOKEN"]
}
# current为请求的页码
data2 = {
'jsonBody': '{"filter": {}, "pagination": {"current": 1, "pageSize": 20}, "table": {"sort": {}}, "tab": "on_sale"}'
}
resp2 = requests.post(url2, headers=headers2, data=data2)
print(resp2)
# print(resp2.text)
# print(resp2.headers)
resp2_json = json.loads(resp2.text)
total = int(resp2_json['data']['pagination']['total'])
print(f"出售中的商品总数：{total}，共{math.ceil(total / int(resp2_json['data']['pagination']['pageSize']))}页")
return total
# uid = ''
# pwd = ''
options = Options()
options.add_argument('--disable-blink-features=AutomationControlled')
driver = webdriver.Chrome(options=options)
driver.maximize_window()
driver.get('https://myseller.taobao.com/') # 登录页面
time.sleep(1)
# 自动登录
# iframe = driver.find_element(By.ID, 'alibaba-login-box')
# driver.switch_to.frame(iframe)
# driver.find_element(By.ID, 'fm-login-id').send_keys(uid, Keys.TAB, pwd, Keys.ENTER) # 输入账号密码登录，第一次登录需要手机验证码
# driver.switch_to.default_content()
# 手动登录
# 如果有手机验证码或滑块验证码要手动过验证码之后，在主页面的时候才能继续运行程序
while 1:
func_type = int(input("1、下架\n2、上架\n选择并开始："))
if func_type == 1: # 下架
params = 'tab=on_sale&table.sort.startDate_m=desc'
state = 'on_sale'
optType = 'batchDownShelf'
break
elif func_type == 2: # 上架
params = 'tab=in_stock&table.sort.endDate_m=desc'
state = 'in_stock'
optType = 'batchUpShelf'
break
else:
print('无效输入')
username = driver.find_element(By.CLASS_NAME, 'user-nick').text
cookies = driver.get_cookies()
cookie = json_to_string(list_to_json(cookies))
print(cookie)
print('=' * 100)
ua = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/102.0.5005.115 Safari/537.36'
# 获取x-xsrf-token，从XSRF-TOKEN
# 'https://item.upload.taobao.com/taobao/manager/render.htm?tab=on_sale&table.sort.startDate_m=desc' # 下架
# 'https://item.upload.taobao.com/taobao/manager/render.htm?tab=in_stock&table.sort.endDate_m=desc' # 上架
url = f'https://item.upload.taobao.com/taobao/manager/render.htm?{params}'
headers = {
'cookie': cookie,
'user-agent': ua
}
resp = requests.get(url, headers=headers)
print(resp)
# print(resp.text)
# print(resp.headers)
set_cookie = requests.utils.dict_from_cookiejar(resp.cookies) # 从响应头整理出set-cookie
print(set_cookie)
print('=' * 100)
resp.close()
current_page = 1 # 当前页
is_no_data = False # 判断标志：是否还有数据
n = 50
while 1:
# 因为我这边的要求是不能全部上架完，所以加了个判断，每50次判断一次
if func_type == 2 and n % 50 == 0:
if get_on_sale_data() > 197500:
input('已上架足够的数量，是否继续？按任意键继续：')
print(username)
print(f'第{current_page}页')
# 获取一页的itemId
url2 = 'https://item.upload.taobao.com/taobao/manager/table.htm'
headers2 = {
'cookie': cookie + f'XSRF-TOKEN={set_cookie["XSRF-TOKEN"]}',
'referer': f'https://item.upload.taobao.com/taobao/manager/render.htm?pagination.current={current_page}&pagination.pageSize=20&{params}',
'user-agent': ua,
'x-xsrf-token': set_cookie["XSRF-TOKEN"]
}
# current为请求的页码
data2 = {
'jsonBody': '{"filter": {}, "pagination": {"current": ' + str(current_page) + ', "pageSize": 20}, "table": {"sort": {}}, "tab": "' + state + '"}'
}
resp2 = requests.post(url2, headers=headers2, data=data2)
print(resp2)
# print(resp2.text)
# print(resp2.headers)
resp2_json = json.loads(resp2.text)
print(
f"总数：{resp2_json['data']['pagination']['total']}，共{math.ceil(int(resp2_json['data']['pagination']['total']) / int(resp2_json['data']['pagination']['pageSize']))}页")
itemId_list = []
for i in resp2_json['data']['table']['dataSource']:
itemId_list.append(i['itemId'])
if len(itemId_list) == 0:
if is_no_data: # 连续两次数据为0才会执行，证明已没有数据
print('暂无数据hhh')
break
print('已是最后一页hhh')
current_page = 1
is_no_data = True
continue
print(itemId_list)
resp2.close()
# 下架商品
# 'https://item.upload.taobao.com/taobao/manager/batchFastEdit.htm?optType=batchDownShelf&action=submit' # 下架
# 'https://item.upload.taobao.com/taobao/manager/batchFastEdit.htm?optType=batchUpShelf&action=submit' # 上架
url3 = f'https://item.upload.taobao.com/taobao/manager/batchFastEdit.htm?optType={optType}&action=submit'
data3 = {
'jsonBody': '{"auctionids":' + list_to_str(itemId_list) + '}'
}
# 请求频繁会出现“亲~人太多，被挤爆了！”
try:
resp3 = requests.post(url3, headers=headers2, data=data3, timeout=(3.05, 8))
except:
print('超时')
resp3 = requests.post(url3, headers=headers2, data=data3)
print(resp3)
if '亲~人太多，被挤爆了！' in resp3.text:
print('亲~人太多，被挤爆了！hhh')
time.sleep(5)
else: # 下架成功
print(resp3.text)
current_page += 1
time.sleep(1)
print('=' * 100)
resp3.close()
is_no_data = False
n += 1
input('按任意键退出：')