Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
P
py12306
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
python
py12306
Commits
b72f7ec5
Commit
b72f7ec5
authored
Jan 18, 2019
by
Jalin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
车次支持大小写
parent
ecd809dc
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
5 additions
and
5 deletions
+5
-5
cdn.py
py12306/helpers/cdn.py
+2
-2
query_log.py
py12306/log/query_log.py
+1
-1
job.py
py12306/query/job.py
+2
-2
No files found.
py12306/helpers/cdn.py
View file @
b72f7ec5
...
@@ -71,7 +71,7 @@ class Cdn:
...
@@ -71,7 +71,7 @@ class Cdn:
CommonLog
.
add_quick_log
(
CommonLog
.
MESSAGE_CDN_START_TO_CHECK
.
format
(
len
(
self
.
items
)))
.
flush
()
CommonLog
.
add_quick_log
(
CommonLog
.
MESSAGE_CDN_START_TO_CHECK
.
format
(
len
(
self
.
items
)))
.
flush
()
self
.
restore_items
()
self
.
restore_items
()
for
i
in
range
(
self
.
thread_num
):
# 多线程
for
i
in
range
(
self
.
thread_num
):
# 多线程
create_thread_and_run
(
jobs
=
self
,
callback_name
=
'check_available'
,
wait
=
Const
.
IS_TEST
)
create_thread_and_run
(
jobs
=
self
,
callback_name
=
'check_available'
,
wait
=
False
)
def
load_items
(
self
):
def
load_items
(
self
):
with
open
(
Config
()
.
CDN_ITEM_FILE
,
encoding
=
'utf-8'
)
as
f
:
with
open
(
Config
()
.
CDN_ITEM_FILE
,
encoding
=
'utf-8'
)
as
f
:
...
@@ -149,7 +149,7 @@ class Cdn:
...
@@ -149,7 +149,7 @@ class Cdn:
CommonLog
.
add_quick_log
(
CommonLog
.
add_quick_log
(
CommonLog
.
MESSAGE_CDN_START_TO_RECHECK
.
format
(
len
(
self
.
items
),
time_now
()))
.
flush
()
CommonLog
.
MESSAGE_CDN_START_TO_RECHECK
.
format
(
len
(
self
.
items
),
time_now
()))
.
flush
()
for
i
in
range
(
self
.
thread_num
):
# 多线程
for
i
in
range
(
self
.
thread_num
):
# 多线程
create_thread_and_run
(
jobs
=
self
,
callback_name
=
'check_available'
,
wait
=
Const
.
IS_TEST
)
create_thread_and_run
(
jobs
=
self
,
callback_name
=
'check_available'
,
wait
=
False
)
stay_second
(
self
.
retry_num
)
stay_second
(
self
.
retry_num
)
def
destroy
(
self
):
def
destroy
(
self
):
...
...
py12306/log/query_log.py
View file @
b72f7ec5
...
@@ -26,7 +26,7 @@ class QueryLog(BaseLog):
...
@@ -26,7 +26,7 @@ class QueryLog(BaseLog):
LOG_INIT_JOBS
=
''
LOG_INIT_JOBS
=
''
MESSAGE_GIVE_UP_CHANCE_CAUSE_TICKET_NUM_LESS_THAN_SPECIFIED
=
'余票数小于乘车人数,放弃此次提交机会'
MESSAGE_GIVE_UP_CHANCE_CAUSE_TICKET_NUM_LESS_THAN_SPECIFIED
=
'余票数小于乘车人数,放弃此次提交机会'
MESSAGE_QUERY_LOG_OF_EVERY_TRAIN
=
'{}
-{}
'
MESSAGE_QUERY_LOG_OF_EVERY_TRAIN
=
'{}'
MESSAGE_QUERY_LOG_OF_TRAIN_INFO
=
'{} {}'
MESSAGE_QUERY_LOG_OF_TRAIN_INFO
=
'{} {}'
MESSAGE_QUERY_START_BY_DATE
=
'出发日期 {}: {} - {}'
MESSAGE_QUERY_START_BY_DATE
=
'出发日期 {}: {} - {}'
...
...
py12306/query/job.py
View file @
b72f7ec5
...
@@ -103,8 +103,8 @@ class Job:
...
@@ -103,8 +103,8 @@ class Job:
tmp_start_time
=
time
.
time
()
tmp_start_time
=
time
.
time
()
response
=
self
.
query_by_date
(
date
)
response
=
self
.
query_by_date
(
date
)
tmp_end_time
=
time
.
time
()
# 耗时
tmp_end_time
=
time
.
time
()
# 耗时
QueryLog
.
add_query_time_log
(
tmp_start_time
,
tmp_end_time
,
is_cdn
=
self
.
is_cdn
)
self
.
handle_response
(
response
)
self
.
handle_response
(
response
)
QueryLog
.
add_query_time_log
(
tmp_start_time
,
tmp_end_time
,
is_cdn
=
self
.
is_cdn
)
if
not
self
.
is_alive
:
return
if
not
self
.
is_alive
:
return
self
.
safe_stay
()
self
.
safe_stay
()
if
is_main_thread
():
if
is_main_thread
():
...
@@ -233,7 +233,7 @@ class Job:
...
@@ -233,7 +233,7 @@ class Job:
def
is_trains_number_valid
(
self
,
ticket_info
):
def
is_trains_number_valid
(
self
,
ticket_info
):
if
self
.
allow_train_numbers
:
if
self
.
allow_train_numbers
:
return
self
.
get_info_of_train_number
()
in
self
.
allow_train_numbers
return
self
.
get_info_of_train_number
()
.
upper
()
in
map
(
str
.
upper
,
self
.
allow_train_numbers
)
return
True
return
True
def
is_member_number_valid
(
self
,
seat
):
def
is_member_number_valid
(
self
,
seat
):
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment