From 009b989a6468e49e0622ef4b58c2b1b78b380c8d Mon Sep 17 00:00:00 2001 From: wenxianping <931128603@qq.com> Date: Mon, 11 Jun 2018 23:14:28 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E4=BF=AE=E6=94=B9=E5=B0=8F=E9=BB=91?= =?UTF-8?q?=E5=B1=8B=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/inspectionProfiles/profiles_settings.xml | 0 init/SelectTicketInfoFast.py | 11 +++++------ inter/Query.py | 6 ++---- 3 files changed, 7 insertions(+), 10 deletions(-) mode change 100644 => 100755 .idea/inspectionProfiles/profiles_settings.xml diff --git a/.idea/inspectionProfiles/profiles_settings.xml b/.idea/inspectionProfiles/profiles_settings.xml old mode 100644 new mode 100755 diff --git a/init/SelectTicketInfoFast.py b/init/SelectTicketInfoFast.py index 49cb19b..15460df 100755 --- a/init/SelectTicketInfoFast.py +++ b/init/SelectTicketInfoFast.py @@ -14,6 +14,7 @@ import collections from agency.cdn_utils import CDNProxy from config import urlConf +from config.TicketEnmu import ticket from config.emailConf import sendEmail from config.ticketConf import _get_yaml from init import login @@ -53,7 +54,6 @@ class selectFast: self.cdn_list = [] self.is_check_user = dict() self.ticket_black_list = dict() - self.black_train_no = "" self.passengerTicketStrList = "" self.oldPassengerStr = "" @@ -176,10 +176,8 @@ class selectFast: to_station_h=self.to_station, _station_seat=self._station_seat, station_trains=self.station_trains, - station_dates=self.station_dates, - black_train_no=self.black_train_no) + station_dates=self.station_dates,) queryResult = q.sendQuery() - self.black_train_no = "" # 重置小黑屋名单 # 查询接口 if queryResult.get("status", False): secretStr = queryResult.get("secretStr", "") @@ -193,7 +191,7 @@ class selectFast: if self.ticket_black_list.has_key(train_no) and ( datetime.datetime.now() - self.ticket_black_list[train_no]).seconds / 60 < int( self.ticket_black_list_time): - print(u"该车次{} 正在被关小黑屋,跳过此车次".format(train_no)) + print(ticket.QUEUE_WARNING_MSG.format(train_no)) else: # 获取联系人 if not self.passengerTicketStrList and not self.oldPassengerStr: @@ -229,7 +227,8 @@ class selectFast: getQueueCountAsyncResult = g.sendGetQueueCountAsync() time.sleep(submitResult.get("ifShowPassCodeTime", 1)) if getQueueCountAsyncResult.get("is_black", False): - self.black_train_no = getQueueCountAsyncResult.get("train_no", "") + black_train_no = getQueueCountAsyncResult.get("train_no", "") + self.ticket_black_list[black_train_no] = datetime.datetime.now() if getQueueCountAsyncResult.get("status", False): # 请求订单快读接口 c = confirmSingleForQueueAsys(session=self, diff --git a/inter/Query.py b/inter/Query.py index 7c6a6e3..f87a2f7 100644 --- a/inter/Query.py +++ b/inter/Query.py @@ -13,7 +13,7 @@ class query: """ def __init__(self, session, from_station, to_station, from_station_h, to_station_h, _station_seat, station_trains, - black_train_no, station_dates=None, ): + station_dates=None, ): self.session = session self.from_station = from_station self.to_station = to_station @@ -23,7 +23,6 @@ class query: self._station_seat = _station_seat if isinstance(_station_seat, list) else list(_station_seat) self.station_dates = station_dates if isinstance(station_dates, list) else list(station_dates) self.ticket_black_list = dict() - self.black_train_no = black_train_no def station_seat(self, index): """ @@ -46,8 +45,7 @@ class query: 查询 :return: """ - if self.black_train_no: - self.ticket_black_list[self.black_train_no] = datetime.datetime.now() + for station_date in self.station_dates: select_url = copy.copy(self.session.urls["select_url"]) select_url["req_url"] = select_url["req_url"].format(