get schedules

app/Business/SchedulesBusiness.php

@@ -0,0 +1,123 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 10/1/16
+ * Time: 5:32 PM
+ */
+
+namespace App\Business;
+
+
+use App\DataAccess\SchedulesDataAccess;
+use App\Dbo\StopsLiteRoutesLiteDbo;
+use App\Dbo\StopsLiteRoutesLiteDboArray;
+use App\Dbo\StopsSchedulesDbo;
+use Carbon\Carbon;
+use Luticate\Utils\Dbo\LuPaginatedDbo;
+
+class SchedulesBusiness
+{
+    public static $days = ["sunday", "monday", "tuesday", "wednesday", "thursday", "friday", "saturday"];
+    public static $dateFormat = "Y-m-d";
+    public static $timeFormat = "H:i:s";
+
+    protected static function getDataAccess()
+    {
+        return new SchedulesDataAccess();
+    }
+
+    public static function getScheduleTypeForDate(array $config, Carbon $date)
+    {
+
+        foreach ($config["scheduleTypes"] as $scheduleType) {
+            if ($scheduleType["type"] == static::$days[$date->dayOfWeek]) {
+                $from = Carbon::createFromFormat(static::$dateFormat, $scheduleType["dateFrom"]);
+                $to = Carbon::createFromFormat(static::$dateFormat, $scheduleType["dateTo"]);
+                if ($date->between($from, $to)) {
+                    return $scheduleType;
+                }
+            }
+        }
+
+        foreach ($config["scheduleTypes"] as $scheduleType) {
+            if ($scheduleType["type"] == static::$days[$date->dayOfWeek]) {
+                return $scheduleType;
+            }
+        }
+
+        foreach ($config["scheduleTypes"] as $scheduleType) {
+            if ($scheduleType["type"] == "week") {
+                $from = Carbon::createFromFormat(static::$dateFormat, $scheduleType["dateFrom"]);
+                $to = Carbon::createFromFormat(static::$dateFormat, $scheduleType["dateTo"]);
+                if ($date->between($from, $to)) {
+                    return $scheduleType;
+                }
+            }
+        }
+
+        foreach ($config["scheduleTypes"] as $scheduleType) {
+            if ($scheduleType["type"] == "week") {
+                return $scheduleType;
+            }
+        }
+
+        return $config["scheduleTypes"][0];
+    }
+
+    public static function getSchedulesForDate(array $schedules, Carbon $date)
+    {
+        foreach ($schedules as $schedule) {
+            if (in_array($date->dayOfWeek, $schedule["week_days"])) {
+                return $schedule["schedule"];
+            }
+        }
+        return null;
+    }
+
+    public static function getSingle(array $scheduleType, StopsLiteRoutesLiteDbo $stop, Carbon $date, int $count)
+    {
+        $data = static::getDataAccess()->get($scheduleType["resourceId"], "allweek", $stop->getStopId(), $stop->getRouteId());
+        $schedules = static::getSchedulesForDate($data["data"]["schedules"], $date);
+
+        $schedulesCarbon = [];
+
+        for ($i = 0; $i < min($count, count($schedules)); ++$i) {
+            $scheduleDate = Carbon::createFromFormat(static::$timeFormat . " " . static::$dateFormat, $schedules[$i] . " " . $date->toDateString());
+            if ($scheduleDate->gte($date)) {
+                $schedulesCarbon[] = $scheduleDate;
+            }
+        }
+
+        $dbo = new StopsSchedulesDbo();
+        $dbo->setRouteId($stop->getRouteId());
+        $dbo->setStopId($stop->getStopId());
+        $dbo->setSchedules($schedulesCarbon);
+        return $dbo;
+    }
+
+    public static function getMultiple(StopsLiteRoutesLiteDboArray $stops, Carbon $date, int $count)
+    {
+        $config = MiscBusiness::getConfig();
+
+        $scheduleType = static::getScheduleTypeForDate($config, $date);
+
+        $dbos = [];
+
+        foreach ($stops->getArray() as $stop) {
+            $dbo = static::getSingle($scheduleType, $stop, $date, $count);
+            if (count($dbo->getSchedules()) < $count) {
+                $count2 = $count - count($dbo->getSchedules());
+                $date2 = $date->copy();
+                $date2->addDay(1);
+                $date2->setTime(0, 0, 0);
+                $scheduleType2 = static::getScheduleTypeForDate($config, $date2);
+                $dbo2 = static::getSingle($scheduleType2, $stop, $date2, $count2);
+                $dbo->setSchedules(array_merge($dbo->getSchedules(), $dbo2->getSchedules()));
+            }
+            $dbos[] = $dbo;
+        }
+
+        return $dbos;
+    }
+}

app/Controller/SchedulesController.php

@@ -0,0 +1,36 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 10/1/16
+ * Time: 5:33 PM
+ */
+
+namespace App\Controller;
+
+use App\Business\SchedulesBusiness;
+use App\Dbo\StopsLiteRoutesLiteDboArray;
+use Luticate\Utils\Controller\LuController;
+use Luticate\Utils\Dbo\LuDateTimeDbo;
+use Luticate\Utils\Dbo\LuIntDbo;
+use Luticate\Utils\Dbo\LuPaginatedDbo;
+
+class SchedulesController extends LuController
+{
+    protected function getBusiness()
+    {
+        return new SchedulesBusiness();
+    }
+
+    /**
+     * Get schedules for multiple stops/routes
+     * @param StopsLiteRoutesLiteDboArray $stops The stops and routes to retrieve
+     * @param LuDateTimeDbo $date The date to get the schedules
+     * @param LuIntDbo $count The maximum number of schedules per stops/routes
+     * @return LuPaginatedDbo
+     */
+    public function getMultiple(StopsLiteRoutesLiteDboArray $stops, LuDateTimeDbo $date, LuIntDbo $count)
+    {
+        return static::getBusiness()->getMultiple($stops, $date->getDateTime(), $count->getInt());
+    }
+}

app/DataAccess/SchedulesDataAccess.php

@@ -0,0 +1,25 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 10/1/16
+ * Time: 5:32 PM
+ */
+
+namespace App\DataAccess;
+
+
+use GuzzleHttp\Client;
+use Luticate\Utils\Controller\LuticateApplication;
+
+class SchedulesDataAccess
+{
+    public static function get(string $resourceId, string $type, string $stopId, string $routeId)
+    {
+        $client = new Client();
+        $entrypoint = LuticateApplication::getInstance()->getSetting("API_ENTRYPOINT");
+        $response = $client->request("GET", $entrypoint . "transit/${resourceId}/${type}/stops/${stopId}/routes/${routeId}/schedule.json");
+        $data = json_decode($response->getBody(), true);
+        return $data;
+    }
+}

app/Dbo/StopsLiteRoutesLiteDbo.php

@@ -0,0 +1,57 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 10/1/16
+ * Time: 5:39 PM
+ */
+
+namespace App\Dbo;
+
+use Luticate\Utils\Dbo\LuDbo;
+
+class StopsLiteRoutesLiteDbo extends LuDbo
+{
+    /**
+     * @var $_stopId string
+     */
+    protected $_stopId;
+
+    /**
+     * @var $_routeId string
+     */
+    protected $_routeId;
+
+    /**
+     * @return string
+     */
+    public function getStopId(): string
+    {
+        return $this->_stopId;
+    }
+
+    /**
+     * @param string $stopId
+     */
+    public function setStopId(string $stopId)
+    {
+        $this->_stopId = $stopId;
+    }
+
+    /**
+     * @return string
+     */
+    public function getRouteId(): string
+    {
+        return $this->_routeId;
+    }
+
+    /**
+     * @param string $routeId
+     */
+    public function setRouteId(string $routeId)
+    {
+        $this->_routeId = $routeId;
+    }
+
+}

app/Dbo/StopsLiteRoutesLiteDboArray.php

@@ -0,0 +1,55 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 10/1/16
+ * Time: 5:52 PM
+ */
+
+namespace App\Dbo;
+
+use Luticate\Utils\Dbo\LuDbo;
+use Luticate\Utils\Dbo\LuDboDeserializeException;
+
+class StopsLiteRoutesLiteDboArray extends LuDbo
+{
+    /**
+     * @var StopsLiteRoutesLiteDbo[]
+     */
+    protected $_array;
+    public function getArray()
+    {
+        return $this->_array;
+    }
+    public function setArray($value)
+    {
+        $this->_array = $value;
+    }
+
+    public function jsonSerialize()
+    {
+        return $this->_array;
+    }
+
+    public static function jsonDeserialize($json)
+    {
+        if (!is_array($json)) {
+            throw new LuDboDeserializeException("Invalid array value");
+        }
+        $dbo = new self();
+        $array = [];
+        foreach ($json as $data) {
+            $array[] = StopsLiteRoutesLiteDbo::jsonDeserialize($data);
+        }
+        $dbo->setArray($array);
+        return $dbo;
+    }
+
+    public static function generateSample()
+    {
+        return [
+            StopsLiteRoutesLiteDbo::generateSample(),
+            StopsLiteRoutesLiteDbo::generateSample()
+        ];
+    }
+}

app/Dbo/StopsSchedulesDbo.php

@@ -0,0 +1,37 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 10/1/16
+ * Time: 9:45 PM
+ */
+
+namespace App\Dbo;
+
+use Carbon\Carbon;
+
+class StopsSchedulesDbo extends StopsLiteRoutesLiteDbo
+{
+    /**
+     * @var $_schedules Carbon[]
+     */
+    protected $_schedules;
+
+    /**
+     * @return \Carbon\Carbon[]
+     */
+    public function getSchedules(): array
+    {
+        return $this->_schedules;
+    }
+
+    /**
+     * @param \Carbon\Carbon[] $schedules
+     */
+    public function setSchedules(array $schedules)
+    {
+        $this->_schedules = $schedules;
+    }
+
+
+}

app/routes.php

@@ -13,3 +13,5 @@ $route = $app->getRouter();
 $route->get("/routes", "Routes", "getAll");
 
 $route->get("/stops", "Stops", "getAll");
+
+$route->post("/schedules/multiple", "Schedules", "getMultiple");