-
Notifications
You must be signed in to change notification settings - Fork 1
/
dbd.py
156 lines (139 loc) · 6.03 KB
/
dbd.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
import requests
import os
import re
import time
import json
from userAgent import Agent
from random import randint
from lxml import etree
from selenium import webdriver
basedir = os.path.abspath(os.path.dirname(__file__))
class jddbd:
# 初始化
def __init__(self):
self.baseurl = "http://dbd.jd.com/"
self.loginurl = "https://passport.jd.com/new/login.aspx?ReturnUrl=http%3A%2F%2Fdbd.jd.com%2Findex.html"
self.driver = webdriver.Chrome()
try:
with open(basedir + '/cookies.txt', 'r') as f:
self.cookies = f.readline()
except:
self.getCookies()
with open(basedir + '/cookies.txt', 'r') as f:
self.cookies = f.readline()
# 获取cookies保存到文件中
def getCookies(self):
self.driver.get(self.loginurl)
time.sleep(20)
print(self.driver.current_url)
if self.driver.current_url == 'http://dbd.jd.com/index.html':
# print(self.driver.page_source)
cookie = [item["name"] + "=" + item["value"] for item in self.driver.get_cookies()]
cookiestr = ';'.join(item for item in cookie)
with open(basedir + '/cookies.txt', 'w') as f:
f.write(cookiestr)
else:
pass
def queryCurrentPrice(self, paimaiid):
s = requests.session()
headers = {
"Host": "dbditem.jd.com",
"Connection": "close",
"User-Agent": Agent[randint(0, 3)]['User-Agent'],
}
query_url = 'http://dbditem.jd.com/services/currentList.action?paimaiIds={0}&curPaimaiId={1}&callback=jsonp_1507620597893&_=1507620597893' \
.format(paimaiid, paimaiid)
try:
r = s.get(query_url, headers=headers,timeout=1)
result_json = re.search(r'{.*}', r.text)
result_dict = json.loads(result_json.group())
return result_dict
except:
print("查询商品价格超过1s")
# 获取拍卖商品封顶价格
def queryMaxPrice(self, paimaiid):
s = requests.session()
headers = {
"Host": "dbditem.jd.com",
"Connection": "close",
"User-Agent": Agent[randint(0, 3)]['User-Agent'],
}
query_url = "http://dbditem.jd.com/json/current/queryJdPrice?paimaiId={0}".format(paimaiid)
try:
r = s.get(query_url, headers=headers,timeout=1)
max_price = json.loads(r.text)['jdPrice']
return int(max_price)
except:
print("查询最大价格超过1s")
# 出价
def setPrice(self, paimaiid):
s = requests.session()
headers = {
"Accept": "application/json,text/javascript,*/*;q=0.01",
"Accept-Encoding": "gzip,deflate",
"Accep-Language": "zh-CN,zh;q=0.8",
"Connection": "keep-alive",
"Cookie": self.cookies,
"Host": "dbditem.jd.com",
"Referer": "http://dbditem.jd.com/" + paimaiid,
"User-Agent": Agent[randint(0, 3)]['User-Agent'],
"X-Requested-With": "XMLHttpRequest",
}
current_result = self.queryCurrentPrice(paimaiid)
currentPrice = int(current_result['currentPriceStr'].split('.')[0])
price_url = "http://dbditem.jd.com/services/bid.action?t=116989&paimaiId={0}&price={1}&proxyFlag=0&bidSource=0".format(
paimaiid,currentPrice+1)
r = s.get(price_url, headers=headers)
message = json.loads(r.text)['message']
# 如果cookies过期则重新获取cookies
print("message:"+message)
if message == u"尚未登录，稍后将跳转至登陆页面":
self.getCookies()
else:
print(message)
myPrice = 0
while True:
try:
# 对产品当前价格及时间进行查询确定
current_result = self.queryCurrentPrice(paimaiid)
currentPrice = int(current_result['currentPriceStr'].split('.')[0])
remainTime = current_result['remainTime']
accessNum = current_result['accessNum']
maxprice = self.queryMaxPrice(paimaiid)
if remainTime == -1:
print("商品{0}竞拍结束".format(paimaiid))
break
else:
pass
info_str = """当前请求商品id:{0}\n当前价格为:{1}\n竞拍剩余时间:{2}ms\n竞拍次数:{3}\n竞拍原价:{4}\n
""".format(paimaiid, currentPrice, remainTime, accessNum, maxprice)
print(info_str)
#当前价格不等于自己出过得价格，10秒内
if remainTime<=10000 and myPrice!=currentPrice and currentPrice<=2050:#maxprice*0.65:
price_url = "http://dbditem.jd.com/services/bid.action?t=116989&paimaiId={0}&price={1}&proxyFlag=0&bidSource=0".format(
paimaiid,currentPrice+1)
print("当前出价:{0}".format(currentPrice+1))
r = s.get(price_url, headers=headers)
message = json.loads(r.text)['message']
print("接口返回消息:{0}".format(message))
#如果出价频率过快则暂停1秒钟
if message == u"拍卖出价频率过快":
time.sleep(1)
elif message == u"尚未登录，稍后将跳转至登陆页面":
self.getCookies()
elif message == u"出价成功":
print("出价成功")
myPrice = currentPrice+1
else:
print("接口返回:{0}".format(message))
else:
print("没达到出价条件不出价..")
except:
print("接口超时")
def __del__(self):
self.driver.close()
if __name__ == '__main__':
jddb1 = jddbd()
paimaiid_list = ['16605838']
for paimaiid in paimaiid_list:
jddb1.setPrice(paimaiid)