You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
258 lines
8.7 KiB
258 lines
8.7 KiB
from flask import Flask, request
|
|
from flask_restful import Resource, Api, abort
|
|
|
|
import requests
|
|
import json
|
|
import datetime
|
|
|
|
|
|
app = Flask( __name__ )
|
|
api = Api( app )
|
|
|
|
|
|
|
|
def send_request(url, raw):
|
|
|
|
headers = {
|
|
"User-Agent": "EGO Genel Mudurlugu-EGO Cepte-3.1.0 GT-I9500 7.1.2",
|
|
"Content-Type": "application/x-www-form-urlencoded", "Content-Length": str(len(raw))
|
|
}
|
|
|
|
r = requests.post(url, headers=headers, data=raw)
|
|
content = r.content.decode("cp1252")
|
|
replace_chars = {"Ý": "I", "ý": "i", "ð": "g", "þ": "s", "Þ": "S"}
|
|
|
|
for key in replace_chars:
|
|
content.replace(key, replace_chars[key])
|
|
|
|
content = content.replace("'", '"')
|
|
content = json.loads(content)
|
|
return content
|
|
|
|
|
|
conn1 = send_request(
|
|
'http://88.255.141.70/mbl/android/connect.asp?SID=0.392509188312098&VER=3.1.0&LAN=tr&UID=%7BACB78701'
|
|
'-2727-4E9A-AE62-28491D671A7D%7D-130570234&FNC=Connect',
|
|
"UID=%7BACB78701-2727-4E9A-AE62-28491D671A7D%7D-130570234&UPS=TRUE")
|
|
conn2 = send_request(
|
|
'http://88.255.141.66/mbl/android/connect.asp?SID=0.392509188312098&VER=3.1.0&LAN=tr&UID=%7BACB78701'
|
|
'-2727-4E9A-AE62-28491D671A7D%7D-130570234&FNC=Start', "")
|
|
bus_data = open("databases/bus.json","r")
|
|
|
|
bus_json = json.loads(bus_data.read())
|
|
|
|
routes = bus_json["stops"]
|
|
bus_data.close()
|
|
print('\n',conn1, '\n\n', conn2, '\n')
|
|
|
|
def time_diff(t1, t2):
|
|
time1 = datetime.datetime.strptime(t1,"%H:%M")
|
|
time2 = datetime.datetime.strptime(t2,"%H:%M")
|
|
response = ""
|
|
if time2.hour-time1.hour < 10:
|
|
response += "0"
|
|
response += str(time2.hour-time1.hour)
|
|
response += ":"
|
|
|
|
if time2.minute-time1.minute < 10:
|
|
response += "0"
|
|
response += str(time2.minute-time1.minute)
|
|
return response
|
|
|
|
|
|
def time_sum(t1,t2):
|
|
time1 = datetime.datetime.strptime(t1,"%H:%M")
|
|
time2 = datetime.datetime.strptime(t2,"%H:%M")
|
|
response = ""
|
|
if time2.hour+time1.hour < 10:
|
|
response += "0"
|
|
response += str(time2.hour+time1.hour)
|
|
response += ":"
|
|
|
|
if time2.minute+time1.minute < 10:
|
|
response += "0"
|
|
response += str(time2.minute+time1.minute)
|
|
return response
|
|
|
|
|
|
def get_closest_time(times, time):
|
|
closest = [0, 0]
|
|
for i in times[0]:
|
|
if i.hour < time.hour or (i.hour == time.hour and i.minute-6 < time.minute):
|
|
continue
|
|
else:
|
|
if closest[0] == 0:
|
|
closest[0] = i
|
|
continue
|
|
if abs(i.hour - time.hour) < abs(closest[0].hour - time.hour):
|
|
closest[0] = i
|
|
continue
|
|
elif abs(i.hour - time.hour) == abs(closest[0].hour - time.hour):
|
|
if i.minute - time.minute < closest[0].minute - time.minute:
|
|
closest[0] = i
|
|
|
|
if closest[0] == 0:
|
|
return []
|
|
|
|
for i in times[1]:
|
|
if i.hour < closest[0].hour or (i.hour == closest[0].hour and i.minute-6 < closest[0].minute):
|
|
continue
|
|
else:
|
|
if closest[1] == 0:
|
|
closest[1] = i
|
|
continue
|
|
if abs(i.hour - time.hour) < abs(closest[1].hour - time.hour):
|
|
closest[1] = i
|
|
continue
|
|
elif abs(i.hour - time.hour) == abs(closest[1].hour - time.hour):
|
|
if i.minute - time.minute < closest[1].minute - time.minute:
|
|
closest[1] = i
|
|
if closest[1] == 0:
|
|
return []
|
|
return [closest[0].strftime("%H:%M"), closest[1].strftime("%H:%M")]
|
|
|
|
|
|
|
|
|
|
class Transit(Resource):
|
|
|
|
def post(self):
|
|
|
|
change = False
|
|
args = request.form
|
|
stops_raw = {"user": {}, "dest": {}}
|
|
stops_arr = {"user": {}, "dest": {}}
|
|
|
|
url_closestops = "http://88.255.141.66/mbl/android/action.asp?SID=0.392509188312098&VER=3.1.0&LAN=tr&UID" \
|
|
"=%7BACB78701"\
|
|
"-2727-4E9A-AE62-28491D671A7D%7D-130570234&FNC=YakinDuraklar"
|
|
|
|
closestops = send_request(url_closestops, "LAT={0}&LNG={1}&MSF=500".format(args["lat_usr"], args["lng_usr"]))
|
|
for stop in closestops["data"][0]["table"]:
|
|
stops_arr["user"][stop["kod"]] = stop["hatlar"].split(",")
|
|
|
|
closestops = send_request(url_closestops, "LAT={0}&LNG={1}&MSF=500".format(args["lat_dest"], args["lng_dest"]))
|
|
for stop in closestops["data"][0]["table"]:
|
|
stops_arr["dest"][stop["kod"]] = stop["hatlar"].split(",")
|
|
|
|
one_bus = {k.strip():
|
|
[dict({x: n for n in stops_arr["user"] for x in stops_arr["user"][n]})[k],
|
|
dict({x: n for n in stops_arr["dest"] for x in stops_arr["dest"][n]})[k]]
|
|
|
|
for k in(list(set([x for n in stops_arr["user"] for x in stops_arr["user"][n]])
|
|
& set([x for n in stops_arr["dest"] for x in stops_arr["dest"][n]])))}
|
|
|
|
travel = {"routes": [], "total":[]}
|
|
# time_cur = datetime.datetime.today().time()
|
|
time_cur =datetime.datetime.strptime("13:00","%H:%M")
|
|
|
|
if len(one_bus) > 0:
|
|
for i in one_bus:
|
|
travel["routes"].append([{"name":i,"stops":[one_bus[i][0],one_bus[i][1]]}])
|
|
|
|
else:
|
|
routes_arr = {"user": {}, "dest": {}}
|
|
stopno = {}
|
|
|
|
for i in stops_arr["user"]:
|
|
for j in stops_arr["user"][i]:
|
|
routes_arr["user"][j.strip()] = bus_json["stops"][j.strip()]
|
|
stopno[j.strip()] = i
|
|
|
|
for i in stops_arr["dest"]:
|
|
for j in stops_arr["dest"][i]:
|
|
routes_arr["dest"][j.strip()] = bus_json["stops"][j.strip()]
|
|
stopno[j.strip()] = i
|
|
|
|
for i in routes_arr["user"]:
|
|
for j in routes_arr["user"][i]:
|
|
for k in routes_arr["dest"]:
|
|
for x in routes_arr["dest"][k]:
|
|
if j.strip() == x.strip():
|
|
travel["routes"].append([
|
|
{"name": i.strip(), "stops": [stopno[i.strip()], x.strip()]},
|
|
{"name": k.strip(), "stops": [x.strip(), stopno[k.strip()]]}])
|
|
|
|
for i in range(len(travel["routes"])):
|
|
for k in range(len(travel["routes"][i])):
|
|
|
|
url = "http://88.255.141.66/mbl/android/action.asp?SID=0.4474110208361718&VER=3.1.0&LAN=tr&UID"\
|
|
"=%7BACB78701-2727-4E9A-AE62-28491D671A7D%7D-130570234&FNC=DuraktanGecisSaatleri "
|
|
weekno = datetime.datetime.today().weekday()
|
|
times_anal = [[], []]
|
|
for j in range(2):
|
|
try:
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]]
|
|
except Exception:
|
|
bus_json["times"][travel["routes"][i][k]["name"]] = {}
|
|
|
|
try:
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]
|
|
except Exception:
|
|
bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]] ={}
|
|
|
|
if weekno < 5:
|
|
try:
|
|
weekday = "HAFTA+%C4%B0%C3%87%C4%B0"
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["weekday"]
|
|
except KeyError:
|
|
bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["weekday"] = send_request(url, "HAT={0}&DURAK={1}&TUR={2}".format(travel["routes"][i][k]["name"], travel["routes"][i][k]["stops"][j], weekday))["data"][0]["table"]
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["weekday"]
|
|
change = True
|
|
elif weekno == 5:
|
|
try:
|
|
weekday = "CUMARTES%C4%B0"
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["saturday"]
|
|
except KeyError:
|
|
bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["saturday"] = send_request(url, "HAT={0}&DURAK={1}&TUR={2}".format(travel["routes"][i][k]["name"], travel["routes"][i][k]["stops"][j], weekday))["data"][0]["table"]
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["saturday"]
|
|
change = True
|
|
|
|
else:
|
|
try:
|
|
weekday = "PAZAR"
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["sunday"]
|
|
except KeyError:
|
|
bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["sunday"] = send_request(url, "HAT={0}&DURAK={1}&TUR={2}".format(travel["routes"][i][k]["name"], travel["routes"][i][k]["stops"][j], weekday))["data"][0]["table"]
|
|
times_raw = bus_json["times"][travel["routes"][i][k]["name"]][travel["routes"][i][k]["stops"][j]]["sunday"]
|
|
change = True
|
|
|
|
|
|
for time in times_raw:
|
|
times_anal[j].append(datetime.datetime.strptime("{0}:{1}".format(time["saat"], time["dakika"]), "%H:%M"))
|
|
closest_times = get_closest_time([times_anal[0], times_anal[1]], time_cur)
|
|
travel["routes"][i][k]["time"] = closest_times
|
|
|
|
empty = []
|
|
for i in range(len(travel["routes"])):
|
|
remove=True
|
|
for k in range(len(travel["routes"][i])):
|
|
if remove:
|
|
if len(travel["routes"][i][k]["time"]) == 0:
|
|
empty.append(i-len(empty))
|
|
remove = False
|
|
|
|
|
|
for i in empty:
|
|
travel["routes"].pop(i)
|
|
|
|
if change:
|
|
bus_data = open("databases/bus.json","w")
|
|
bus_data.write(json.dumps(bus_json,indent=4, sort_keys=True))
|
|
bus_data.close()
|
|
|
|
for route in travel["routes"]:
|
|
start = route[0]["time"][0]
|
|
end = route[-1]["time"][1]
|
|
diff = time_diff(start, end)
|
|
diff = time_sum(diff, time_diff(time_cur.strftime("%H:%M"), start))
|
|
diff = time_sum(diff, "00:05")
|
|
travel["total"].append(diff)
|
|
|
|
return travel
|
|
|
|
|
|
if __name__ == '__main__':
|
|
api.add_resource(Transit, '/transit', '/transit/')
|
|
|
|
app.run( host='0.0.0.0', port=5000 )
|