Compare commits
106 Commits
1.1.1
...
eb2eee53bd
| Author | SHA1 | Date | |
|---|---|---|---|
| eb2eee53bd | |||
| 53b0bd6894 | |||
| 1e4815d47a | |||
| f3169bcb32 | |||
| 652ad0db7e | |||
| 5b424a2345 | |||
| 710c31551e | |||
| 0042fda5cc | |||
| 646383fb6a | |||
| f9c58edccd | |||
| 9ec3291a6a | |||
| 373fd1641b | |||
| 46065dae1a | |||
| 295a968581 | |||
| ebe40785fa | |||
| 4cf1c2f90b | |||
| e40391eb4c | |||
| 4095037b69 | |||
| b7ebf7374a | |||
| 45343c9121 | |||
| 653f94f9c9 | |||
| 632f76aceb | |||
| cbf143c7a0 | |||
| 7920172735 | |||
| 914310dab8 | |||
| 8e8ef8fe04 | |||
| de4915972c | |||
| 9c2405dd3f | |||
| da6a8f86c2 | |||
| 2c40fb0e61 | |||
| 5314a6a70a | |||
|
|
f772532309 | ||
|
|
17159e811f | ||
|
|
76d8b7d9cf | ||
|
|
f30304cbe9 | ||
| dc287aadc6 | |||
| 708a5eeae0 | |||
|
|
7352eea270 | ||
|
|
e97d976705 | ||
| beb717f9b9 | |||
| 2471a61076 | |||
|
|
a01174b414 | ||
| 512de51d08 | |||
|
|
e6e8f2fc15 | ||
| 6246ad8692 | |||
|
|
d18abc6159 | ||
| 5832ac583f | |||
|
|
8f87a6bbf0 | ||
| ef1b7b8a9e | |||
| b0134accfa | |||
|
|
ae0f9b3be7 | ||
|
|
5c2777999a | ||
|
|
71279025ae | ||
| f334ba0232 | |||
|
|
81f9c863c7 | ||
| 7eb7bf3eb2 | |||
|
|
ac1f0af5ae | ||
| 35aea9dd7e | |||
|
|
62239bd052 | ||
| 22e59a2438 | |||
|
|
585f1336d2 | ||
| a26ad401df | |||
|
|
3705990be1 | ||
| c65f0fdb3e | |||
| d6bcffc3e1 | |||
| faf9c8a480 | |||
| 14104f61a4 | |||
| 44254ed12a | |||
|
|
d9740a86d0 | ||
|
|
bd62a23854 | ||
| 2dc4dc778d | |||
|
|
85e32554ef | ||
| ebd48cfbf6 | |||
|
|
369bacc38c | ||
| 277257fda2 | |||
|
|
0e5d76313f | ||
| 54488f0b19 | |||
|
|
a6b108cb74 | ||
|
|
0db4bacff4 | ||
| 37680b0c91 | |||
|
|
0e8c312f5e | ||
| 685bff3ffc | |||
|
|
11284e59ea | ||
| 50305d5b5d | |||
|
|
f963dcd4c8 | ||
|
|
48ee68f71a | ||
| f1c0ec6b3a | |||
| 0168290340 | |||
|
|
f451bfca0e | ||
|
|
c280abe484 | ||
|
|
7053716924 | ||
| a911d614e0 | |||
|
|
58562746a3 | ||
|
|
5ee1bba812 | ||
| 3d47726a81 | |||
|
|
fee7495cfe | ||
|
|
53b6d33ab9 | ||
|
|
3cc5d73758 | ||
|
|
d043e8efb1 | ||
|
|
2b595c1403 | ||
|
|
f2e6cba2f5 | ||
|
|
e13a0acce1 | ||
|
|
77732689d8 | ||
|
|
22cc3f699b | ||
|
|
a1b6d65137 | ||
|
|
7ee8df32f9 |
4
.gitignore
vendored
4
.gitignore
vendored
@@ -1,3 +1,5 @@
|
|||||||
/vendor/
|
/vendor/
|
||||||
.idea
|
.idea
|
||||||
database.sqlite
|
*.sqlite
|
||||||
|
var/cache/
|
||||||
|
.env.local
|
||||||
@@ -1,13 +1,15 @@
|
|||||||
FROM php:8.3-cli
|
FROM php:8.4-cli
|
||||||
|
|
||||||
WORKDIR /usr/src/app
|
WORKDIR /usr/src/app
|
||||||
|
ENV PHP_MEMORY_LIMIT=1500M
|
||||||
|
RUN echo "memory_limit=1500M" > /usr/local/etc/php/conf.d/memory-limit.ini
|
||||||
RUN apt-get update && apt-get install -y \
|
RUN apt-get update && apt-get install -y \
|
||||||
git \
|
git \
|
||||||
unzip \
|
unzip \
|
||||||
|
libicu-dev \
|
||||||
libzip-dev
|
libzip-dev
|
||||||
|
|
||||||
RUN docker-php-ext-install zip
|
RUN docker-php-ext-install zip intl
|
||||||
|
|
||||||
RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
|
RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
|
||||||
|
|
||||||
|
|||||||
35
README.md
35
README.md
@@ -4,7 +4,34 @@
|
|||||||
|
|
||||||
1. Clone repository using `git clone https://git.techtube.pl/krzysiej/ryobi-crawler.git`
|
1. Clone repository using `git clone https://git.techtube.pl/krzysiej/ryobi-crawler.git`
|
||||||
2. Cd into project directory `cd ryobi-crawler`
|
2. Cd into project directory `cd ryobi-crawler`
|
||||||
3. Build and start docker container `docker compose up -d`
|
3. Build and start docker container `docker compose up -d --build --force-recreate`
|
||||||
4. Run `docker compose exec php-app php index.php app:migrate` file to create `database.sqlite` and create tables.
|
4. Run `docker compose exec php-app php console.php app:migrate` file to create `database.sqlite` and create tables.
|
||||||
5. Run `docker compose exec php-app php index.php app:scrape` command to scrape all the products from the ryobi website.
|
5. Run `docker compose exec php-app php console.php app:scrape` command to scrape all the products from the ryobi website.
|
||||||
6. Access web interface using `localhost:9000` address in web browser.
|
6. Access web interface using `localhost:9001` address in web browser.
|
||||||
|
|
||||||
|
|
||||||
|
## Update project
|
||||||
|
|
||||||
|
1. Cd into project directory
|
||||||
|
2. Run `git pull`
|
||||||
|
3. Refresh cache on production by removing cache directory: `rm -rf var/cache`
|
||||||
|
4. Start and build image in one go with command: `docker compose up -d --build --force-recreate`
|
||||||
|
|
||||||
|
## Bonus
|
||||||
|
|
||||||
|
### Install composer package
|
||||||
|
|
||||||
|
1. Run `bin/composer require vendor/package-name`
|
||||||
|
|
||||||
|
|
||||||
|
## Running Cron
|
||||||
|
|
||||||
|
For now only way of running `app:scrape` command on schedule is to use host crontab.
|
||||||
|
1. Run `crontab -e` command to edit a host crontab job file
|
||||||
|
2. Add a new line with e.g. line like this `0 1 * * * cd /var/project/directory/ && docker compose exec php-app php console.php app:scrape`
|
||||||
|
3. Save and exit file editor. Cron will execute `app:scrape` once per day.
|
||||||
|
|
||||||
|
## Screenshots
|
||||||
|
|
||||||
|
### Main screen of the web view
|
||||||
|

|
||||||
2
bin/cacheclean
Executable file
2
bin/cacheclean
Executable file
@@ -0,0 +1,2 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
bin/cli rm -rf var/cache
|
||||||
2
bin/cachewarmup
Executable file
2
bin/cachewarmup
Executable file
@@ -0,0 +1,2 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
bin/cli php console.php app:cache:warm-twig
|
||||||
3
bin/cli
Executable file
3
bin/cli
Executable file
@@ -0,0 +1,3 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
[ -z "$1" ] && echo "Please specify a CLI command (ex. ls)" && exit
|
||||||
|
docker compose exec php-app "$@"
|
||||||
3
bin/composer
Executable file
3
bin/composer
Executable file
@@ -0,0 +1,3 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
[ -z "$1" ] && bin/cli composer list && exit
|
||||||
|
bin/cli composer "$@"
|
||||||
6
bin/update
Executable file
6
bin/update
Executable file
@@ -0,0 +1,6 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
echo "Updating project"
|
||||||
|
git pull origin master
|
||||||
|
bin/cacheclean
|
||||||
|
bin/composer install --no-dev
|
||||||
|
echo "Project updated"
|
||||||
42
browser.php
42
browser.php
@@ -1,42 +0,0 @@
|
|||||||
<?php
|
|
||||||
|
|
||||||
include_once 'vendor/autoload.php';
|
|
||||||
|
|
||||||
use Illuminate\Database\Capsule\Manager as Capsule;
|
|
||||||
use Krzysiej\RyobiCrawler\Models\Product;
|
|
||||||
use Twig\{Environment, Loader\FilesystemLoader};
|
|
||||||
|
|
||||||
if (!file_exists('database.sqlite')) {
|
|
||||||
exit('Database file <code>database.sqlite</code> missing. Run docker compose <blockquote>docker compose exec php-app php index.php app:migrate</blockquote> to create it.');
|
|
||||||
}
|
|
||||||
|
|
||||||
$capsule = new Capsule;
|
|
||||||
$capsule->addConnection(['driver' => 'sqlite', 'database' => __DIR__ . '/database.sqlite']);
|
|
||||||
$capsule->setAsGlobal();
|
|
||||||
$capsule->bootEloquent();
|
|
||||||
$loader = new FilesystemLoader(__DIR__ . '/src/templates');
|
|
||||||
$twig = new Environment($loader);
|
|
||||||
if (isset($_GET['product_id'])) {
|
|
||||||
$template = 'product.html.twig';
|
|
||||||
$product = Product::with('price')->find($_GET['product_id']);
|
|
||||||
}
|
|
||||||
if (isset($_GET['category'])) {
|
|
||||||
$template = 'productList.html.twig';
|
|
||||||
$products = Product::with('price')->selectRaw('products.*')->fromRaw('products, json_each(products.categories)')->whereRaw('json_each.value = ?', [$_GET['category']])
|
|
||||||
->orderByDesc('starred')->orderByDesc('created_by')->get();
|
|
||||||
}
|
|
||||||
if (isset($_GET['search'])) {
|
|
||||||
$template = 'productList.html.twig';
|
|
||||||
$products = Product::with('price')
|
|
||||||
->orWhere([['name', 'like', "%{$_GET['search']}%"]])
|
|
||||||
->orWhere([['subTitle', 'like', "%{$_GET['search']}%"]])->get();
|
|
||||||
}
|
|
||||||
if (isset($_GET['star'])) {
|
|
||||||
Product::find($_GET['star'])->toggleStarred()->save();
|
|
||||||
header('Location: '.$_SERVER['HTTP_REFERER']);
|
|
||||||
}
|
|
||||||
if (empty($_GET)) {
|
|
||||||
$template = 'productList.html.twig';
|
|
||||||
$products = Product::with('price')->orderByDesc('starred')->orderByDesc('created_by')->get();
|
|
||||||
}
|
|
||||||
$twig->display($template, ['products' => $products ?? [], 'product' => $product ?? [], 'search' => $_GET['search'] ?? '']);
|
|
||||||
@@ -1,15 +1,26 @@
|
|||||||
{
|
{
|
||||||
"require": {
|
"require": {
|
||||||
"guzzlehttp/guzzle": "^7.0",
|
"guzzlehttp/guzzle": "^7.0",
|
||||||
"symfony/var-dumper": "^7.0",
|
|
||||||
"illuminate/database": "11.26.0.0",
|
"illuminate/database": "11.26.0.0",
|
||||||
"ext-json": "*",
|
"ext-json": "*",
|
||||||
"twig/twig": "3.14.0.0",
|
"symfony/console": "^7.0",
|
||||||
"symfony/console": "^7.0"
|
"symfony/routing": "^7.1",
|
||||||
|
"laravel/serializable-closure": "^1.3",
|
||||||
|
"symfony/http-kernel": "^7.1",
|
||||||
|
"symfony/framework-bundle": "^7.1",
|
||||||
|
"symfony/twig-bundle": "^7.1",
|
||||||
|
"symfony/dotenv": "^7.1",
|
||||||
|
"twig/intl-extra": "^3.13",
|
||||||
|
"twig/extra-bundle": "^3.13",
|
||||||
|
"symfony/cache": "^7.2",
|
||||||
|
"twig/cache-extra": "^3.21"
|
||||||
},
|
},
|
||||||
"autoload": {
|
"autoload": {
|
||||||
"psr-4": {
|
"psr-4": {
|
||||||
"Krzysiej\\RyobiCrawler\\": "src/"
|
"Krzysiej\\RyobiCrawler\\": "src/"
|
||||||
}
|
}
|
||||||
|
},
|
||||||
|
"require-dev": {
|
||||||
|
"symfony/var-dumper": "^7.1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
2592
composer.lock
generated
2592
composer.lock
generated
File diff suppressed because it is too large
Load Diff
17
console.php
Normal file
17
console.php
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
include_once 'vendor/autoload.php';
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Kernel;
|
||||||
|
use Symfony\Bundle\FrameworkBundle\Console\Application;
|
||||||
|
|
||||||
|
if (php_sapi_name() !== 'cli') {
|
||||||
|
header('Location: browser.php');
|
||||||
|
echo 'Execute this script in cli only';
|
||||||
|
exit;
|
||||||
|
}
|
||||||
|
$kernel = new Kernel('dev', true);
|
||||||
|
$application = new Application($kernel);
|
||||||
|
$application->setName('Ryobi website scraper application');
|
||||||
|
$application->setVersion('1.2.0');
|
||||||
|
$application->run();
|
||||||
@@ -1,9 +1,10 @@
|
|||||||
services:
|
services:
|
||||||
php-app:
|
php-app:
|
||||||
|
restart: unless-stopped
|
||||||
build: .
|
build: .
|
||||||
volumes:
|
volumes:
|
||||||
- .:/usr/src/app
|
- .:/usr/src/app
|
||||||
command: >
|
command: >
|
||||||
sh -c "composer install && php -S 0.0.0.0:8000 -t /usr/src/app"
|
sh -c "composer install && php -S 0.0.0.0:8000 -t /usr/src/app"
|
||||||
ports:
|
ports:
|
||||||
- "9000:8000"
|
- "9001:8000"
|
||||||
24
index.php
24
index.php
@@ -1,19 +1,15 @@
|
|||||||
<?php
|
<?php
|
||||||
|
|
||||||
include_once 'vendor/autoload.php';
|
use Krzysiej\RyobiCrawler\Kernel;
|
||||||
|
use Symfony\Component\Dotenv\Dotenv;
|
||||||
|
use Symfony\Component\HttpFoundation\Request;
|
||||||
|
|
||||||
use Krzysiej\RyobiCrawler\Command\Migrate;
|
require 'vendor/autoload.php';
|
||||||
use Krzysiej\RyobiCrawler\Command\ScrapeWebsite;
|
|
||||||
|
|
||||||
use Symfony\Component\Console\Application;
|
(new Dotenv())->bootEnv(__DIR__.'/.env');
|
||||||
|
|
||||||
if (php_sapi_name() !== 'cli') {
|
$kernel = new Kernel($_SERVER['APP_ENV'], (bool) $_SERVER['APP_DEBUG']);
|
||||||
header('Location: browser.php');
|
$request = Request::createFromGlobals();
|
||||||
echo 'Execute this script in cli only';
|
$response = $kernel->handle($request);
|
||||||
exit;
|
$response->send();
|
||||||
}
|
$kernel->terminate($request, $response);
|
||||||
|
|
||||||
$application = new Application('Ryobi website scraper application', '1.1.1');
|
|
||||||
$application->add(new ScrapeWebsite());
|
|
||||||
$application->add(new Migrate());
|
|
||||||
$application->run();
|
|
||||||
BIN
screenshot1.png
Normal file
BIN
screenshot1.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 282 KiB |
84
src/Command/CacheWarmCommand.php
Normal file
84
src/Command/CacheWarmCommand.php
Normal file
@@ -0,0 +1,84 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
declare(strict_types=1);
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Command;
|
||||||
|
|
||||||
|
use Symfony\Component\Console\Helper\ProgressBar;
|
||||||
|
use Symfony\Component\HttpFoundation\Request;
|
||||||
|
use Illuminate\Database\Capsule\Manager as Capsule;
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\Cache\Adapter\FilesystemAdapter;
|
||||||
|
use Symfony\Component\Console\Attribute\AsCommand;
|
||||||
|
use Symfony\Component\Console\Command\Command;
|
||||||
|
use Symfony\Component\Console\Input\InputInterface;
|
||||||
|
use Symfony\Component\Console\Output\OutputInterface;
|
||||||
|
use Symfony\Component\HttpFoundation\RequestStack;
|
||||||
|
use Twig\Environment;
|
||||||
|
|
||||||
|
#[AsCommand(name: 'app:cache:warm-twig', description: 'Warmup twig cache')]
|
||||||
|
class CacheWarmCommand extends Command
|
||||||
|
{
|
||||||
|
public function __construct(
|
||||||
|
private Environment $twig,
|
||||||
|
private RequestStack $requestStack,
|
||||||
|
private FilesystemAdapter $cache,
|
||||||
|
) {
|
||||||
|
parent::__construct();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function execute(InputInterface $input, OutputInterface $output): int
|
||||||
|
{
|
||||||
|
$this->cache->clear();
|
||||||
|
|
||||||
|
$capsule = new Capsule;
|
||||||
|
$capsule->addConnection([
|
||||||
|
'driver' => 'sqlite',
|
||||||
|
'database' => __DIR__ . '/../../database.sqlite',
|
||||||
|
]);
|
||||||
|
$capsule->setAsGlobal();
|
||||||
|
$capsule->bootEloquent();
|
||||||
|
|
||||||
|
$progress = new ProgressBar($output);
|
||||||
|
$progress->start();
|
||||||
|
$products = Product::with([
|
||||||
|
'price' => fn($query) => $query->orderByDesc('created_at'),
|
||||||
|
'stock' => fn($query) => $query->orderByDesc('created_at'),
|
||||||
|
])->get();
|
||||||
|
$progress->setMaxSteps(count($products));
|
||||||
|
|
||||||
|
$request = Request::create('/cache-warm');
|
||||||
|
$this->requestStack->push($request);
|
||||||
|
|
||||||
|
foreach ($products as $product) {
|
||||||
|
$priceList = $product->price()->pluck('price');
|
||||||
|
$stockList = $product->stock()->pluck('stock');
|
||||||
|
$priceDates = $product->price()->pluck('created_at')->map(fn($date) => $date->format('Y-m-d'))->toArray();
|
||||||
|
$stockDates = $product->stock()->pluck('created_at')->map(fn($date) => $date->format('Y-m-d'))->toArray();
|
||||||
|
$this->twig->render('product.html.twig', [
|
||||||
|
'product' => $product,
|
||||||
|
'price_list' => $this->prepareChartData($priceDates, $priceList),
|
||||||
|
'stock_list' => $this->prepareChartData($stockDates, $stockList),
|
||||||
|
'price_dates' => implode("','", $priceDates),
|
||||||
|
]);
|
||||||
|
$progress->advance();
|
||||||
|
}
|
||||||
|
|
||||||
|
$progress->finish();
|
||||||
|
$output->writeln('');
|
||||||
|
$output->writeln('DONE');
|
||||||
|
|
||||||
|
return Command::SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
private function prepareChartData($set1, $set2): string
|
||||||
|
{
|
||||||
|
$data = [];
|
||||||
|
foreach ($set1 as $key => $value) {
|
||||||
|
$data[] = ['x' => $value, 'y' => $set2[$key]];
|
||||||
|
}
|
||||||
|
$stringData = json_encode($data);
|
||||||
|
|
||||||
|
return str_replace(['"x"', '"y"'], ['x', 'y'], $stringData);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -6,17 +6,30 @@ namespace Krzysiej\RyobiCrawler\Command;
|
|||||||
|
|
||||||
use Illuminate\Database\Capsule\Manager as Capsule;
|
use Illuminate\Database\Capsule\Manager as Capsule;
|
||||||
use Illuminate\Database\Schema\Blueprint;
|
use Illuminate\Database\Schema\Blueprint;
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Country;
|
||||||
use Symfony\Component\Console\Attribute\AsCommand;
|
use Symfony\Component\Console\Attribute\AsCommand;
|
||||||
use Symfony\Component\Console\Command\Command;
|
use Symfony\Component\Console\Command\Command;
|
||||||
use Symfony\Component\Console\Input\InputInterface;
|
use Symfony\Component\Console\Input\InputInterface;
|
||||||
|
use Symfony\Component\Console\Input\InputOption;
|
||||||
use Symfony\Component\Console\Output\OutputInterface;
|
use Symfony\Component\Console\Output\OutputInterface;
|
||||||
|
use function Symfony\Component\Clock\now;
|
||||||
|
|
||||||
#[AsCommand(name: 'app:migrate', description: 'Create database and rum migrations')]
|
#[AsCommand(name: 'app:migrate', description: 'Create database and rum migrations')]
|
||||||
class Migrate extends Command
|
class Migrate extends Command
|
||||||
{
|
{
|
||||||
|
private const RECREATE_OPTION = 'recreate';
|
||||||
|
|
||||||
protected function configure(): void
|
protected function configure(): void
|
||||||
{
|
{
|
||||||
|
$this->addOption(self::RECREATE_OPTION, null, InputOption::VALUE_OPTIONAL, 'Recreate database file event if exist and has data.');
|
||||||
|
}
|
||||||
|
|
||||||
|
public function execute(InputInterface $input, OutputInterface $output): int
|
||||||
|
{
|
||||||
|
if ($input->getOption(self::RECREATE_OPTION)) {
|
||||||
|
unlink(__DIR__ . '/../../database.sqlite');
|
||||||
touch(__DIR__ . '/../../database.sqlite');
|
touch(__DIR__ . '/../../database.sqlite');
|
||||||
|
}
|
||||||
$capsule = new Capsule;
|
$capsule = new Capsule;
|
||||||
$capsule->addConnection([
|
$capsule->addConnection([
|
||||||
'driver' => 'sqlite',
|
'driver' => 'sqlite',
|
||||||
@@ -24,13 +37,12 @@ class Migrate extends Command
|
|||||||
]);
|
]);
|
||||||
$capsule->setAsGlobal();
|
$capsule->setAsGlobal();
|
||||||
$capsule->bootEloquent();
|
$capsule->bootEloquent();
|
||||||
}
|
|
||||||
|
|
||||||
public function execute(InputInterface $input, OutputInterface $output): int
|
|
||||||
{
|
|
||||||
$this->createProductsTable();
|
$this->createProductsTable();
|
||||||
$this->createPricesTable();
|
$this->createPricesTable();
|
||||||
$this->createStocksTable();
|
$this->createStocksTable();
|
||||||
|
$this->addColumns();
|
||||||
|
$this->createCountriesTable();
|
||||||
|
$this->index();
|
||||||
|
|
||||||
return Command::SUCCESS;
|
return Command::SUCCESS;
|
||||||
}
|
}
|
||||||
@@ -42,9 +54,7 @@ class Migrate extends Command
|
|||||||
$table->increments('id');
|
$table->increments('id');
|
||||||
$table->string('name');
|
$table->string('name');
|
||||||
$table->integer('skuID')->unique();
|
$table->integer('skuID')->unique();
|
||||||
$table->integer('agilityID');
|
|
||||||
$table->integer('availableQuantity');
|
$table->integer('availableQuantity');
|
||||||
$table->integer('stock');
|
|
||||||
$table->json('categories');
|
$table->json('categories');
|
||||||
$table->string('image');
|
$table->string('image');
|
||||||
$table->string('subTitle');
|
$table->string('subTitle');
|
||||||
@@ -71,6 +81,51 @@ class Migrate extends Command
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function createCountriesTable(): void
|
||||||
|
{
|
||||||
|
if (!Capsule::schema()->hasTable('countries')) {
|
||||||
|
Capsule::schema()->create('countries', function (Blueprint $table) {
|
||||||
|
$table->increments('id');
|
||||||
|
$table->text('countryName');
|
||||||
|
$table->text('productsUrl');
|
||||||
|
$table->text('cultureCode');
|
||||||
|
$table->text('currency');
|
||||||
|
$table->text('locale');
|
||||||
|
$table->timestamps();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (Capsule::schema()->hasTable('countries') && !Country::where('countryName', 'Poland')->exists()) {
|
||||||
|
$id = Capsule::table('countries')->insertGetId(
|
||||||
|
[
|
||||||
|
'countryName' => 'Poland',
|
||||||
|
'productsUrl' => 'https://pl.ryobitools.eu/api/product-listing/get-products',
|
||||||
|
'cultureCode' => 'pl-PL',
|
||||||
|
'currency' => 'PLN',
|
||||||
|
'locale' => 'pl',
|
||||||
|
'created_at' => now(),
|
||||||
|
'updated_at' => now(),
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
if (Capsule::schema()->hasTable('countries') && !Country::where('countryName', 'UK')->exists()) {
|
||||||
|
Capsule::table('countries')->insert([
|
||||||
|
'countryName' => 'UK',
|
||||||
|
'productsUrl' => 'https://uk.ryobitools.eu/api/product-listing/get-products',
|
||||||
|
'cultureCode' => 'en-GB',
|
||||||
|
'currency' => 'GBP',
|
||||||
|
'locale' => 'en',
|
||||||
|
'created_at' => now(),
|
||||||
|
'updated_at' => now(),
|
||||||
|
]
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'country_id')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) use ($id) {
|
||||||
|
$table->foreignId('country_id')->default($id)->references('id')->on('countries');
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public function createStocksTable(): void
|
public function createStocksTable(): void
|
||||||
{
|
{
|
||||||
if (!Capsule::schema()->hasTable('stocks')) {
|
if (!Capsule::schema()->hasTable('stocks')) {
|
||||||
@@ -88,4 +143,57 @@ class Migrate extends Command
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function addColumns(): void
|
||||||
|
{
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'priceCurrent')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->float('priceCurrent')->default(0);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'priceLowest')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->float('priceLowest')->default(0);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'productStandardPrice')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->float('productStandardPrice')->default(0);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'lowestProductPrice30Days')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->float('lowestProductPrice30Days')->default(0);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'lastSeen')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->date('lastSeen')->nullable();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Capsule::schema()->hasColumn('products', 'stock')) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->integer('stock')->nullable();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public function index(): void
|
||||||
|
{
|
||||||
|
if (!count(Capsule::select('SELECT name FROM sqlite_master WHERE type = "index" and name = "products_skuid_country_id_unique"'))) {
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->integer('skuID')->unique(false)->change();
|
||||||
|
$table->unique(['skuID', 'country_id']);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
Capsule::schema()->table('products', function (Blueprint $table) {
|
||||||
|
$table->foreign('id')->references('product_id')->on('stocks');
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ namespace Krzysiej\RyobiCrawler\Command;
|
|||||||
use GuzzleHttp\Client;
|
use GuzzleHttp\Client;
|
||||||
use GuzzleHttp\Exception\GuzzleException;
|
use GuzzleHttp\Exception\GuzzleException;
|
||||||
use Illuminate\Database\Capsule\Manager as Capsule;
|
use Illuminate\Database\Capsule\Manager as Capsule;
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Country;
|
||||||
use Krzysiej\RyobiCrawler\Models\Price;
|
use Krzysiej\RyobiCrawler\Models\Price;
|
||||||
use Krzysiej\RyobiCrawler\Models\Product;
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
use Krzysiej\RyobiCrawler\Models\Stock;
|
use Krzysiej\RyobiCrawler\Models\Stock;
|
||||||
@@ -21,54 +22,80 @@ class ScrapeWebsite extends Command
|
|||||||
{
|
{
|
||||||
private Client $client;
|
private Client $client;
|
||||||
|
|
||||||
|
public function __construct(protected Capsule $database)
|
||||||
|
{
|
||||||
|
parent::__construct();
|
||||||
|
}
|
||||||
|
|
||||||
protected function configure(): void
|
protected function configure(): void
|
||||||
{
|
{
|
||||||
$capsule = new Capsule;
|
|
||||||
$capsule->addConnection([
|
|
||||||
'driver' => 'sqlite',
|
|
||||||
'database' => __DIR__ . '/../../database.sqlite',
|
|
||||||
]);
|
|
||||||
$capsule->setAsGlobal();
|
|
||||||
$capsule->bootEloquent();
|
|
||||||
$this->client = new Client();
|
$this->client = new Client();
|
||||||
}
|
}
|
||||||
|
|
||||||
public function execute(InputInterface $input, OutputInterface $output): int
|
public function execute(InputInterface $input, OutputInterface $output): int
|
||||||
{
|
{
|
||||||
|
$output->writeln('Scrape products');
|
||||||
$progress = new ProgressBar($output);
|
$progress = new ProgressBar($output);
|
||||||
|
$countries = Country::all();
|
||||||
|
foreach($countries as $country) {
|
||||||
|
$output->writeln('Country name: ' . $country->countryName."\n");
|
||||||
$progress->start();
|
$progress->start();
|
||||||
$products = $this->getProducts();
|
$products = $this->getProducts($country);
|
||||||
$progress->setMaxSteps(count($products));
|
$progress->setMaxSteps(count($products));
|
||||||
foreach ($products as $product) {
|
foreach ($products as $product) {
|
||||||
$this->saveProduct($product);
|
$this->saveProduct($product, $country);
|
||||||
$progress->advance();
|
$progress->advance();
|
||||||
}
|
}
|
||||||
$progress->finish();
|
$progress->finish();
|
||||||
$output->writeln('');
|
$output->writeln('');
|
||||||
$output->writeln('DONE');
|
$output->writeln('Scrape products - DONE');
|
||||||
|
$output->writeln('');
|
||||||
|
}
|
||||||
|
|
||||||
|
$output->writeln('Update prices');
|
||||||
|
$products = Product::all();
|
||||||
|
$progress->setMaxSteps(count($products));
|
||||||
|
$progress->start();
|
||||||
|
foreach($products as $product) {
|
||||||
|
$newestPrice = $product->newestPrice;
|
||||||
|
$currentStock = $product->currentStock;
|
||||||
|
$product->priceCurrent = $newestPrice->price;
|
||||||
|
$product->productStandardPrice = $newestPrice->productStandardPrice;
|
||||||
|
$product->lowestProductPrice30Days = $newestPrice->lowestProductPrice30Days;
|
||||||
|
$product->priceLowest = $product->lowestPrice->price;
|
||||||
|
$product->lastSeen = $newestPrice->created_at->format('Y-m-d');
|
||||||
|
$product->stock = $currentStock->stock;
|
||||||
|
$product->save(['timestamps' => false]);
|
||||||
|
$progress->advance();
|
||||||
|
}
|
||||||
|
$progress->finish();
|
||||||
|
$output->writeln('');
|
||||||
|
$output->writeln('Update prices - DONE');
|
||||||
|
$output->writeln('COMMAND - DONE');
|
||||||
|
|
||||||
return Command::SUCCESS;
|
return Command::SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
private function getProducts(): array
|
private function getProducts(Country $country): array
|
||||||
{
|
{
|
||||||
$products = [];
|
$products = [];
|
||||||
$page = 0;
|
$page = 0;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
try {
|
try {
|
||||||
$res = $this->client->request('POST', 'https://pl.ryobitools.eu/api/product-listing/get-products', [
|
$res = $this->client->request('POST', $country->productsUrl, [
|
||||||
'form_params' => [
|
'form_params' => [
|
||||||
"includePreviousPages" => false,
|
"includePreviousPages" => false,
|
||||||
"pageIndex" => $page,
|
"pageIndex" => $page,
|
||||||
"pageSize" => 100,
|
"pageSize" => 100,
|
||||||
"cultureCode" => "pl-PL",
|
"cultureCode" => $country->cultureCode,
|
||||||
]
|
]
|
||||||
]);
|
]);
|
||||||
$responseObject = json_decode($res->getBody()->getContents());
|
$responseObject = json_decode($res->getBody()->getContents());
|
||||||
$products = array_merge($products, $responseObject->products);
|
$products = array_merge($products, $responseObject->products);
|
||||||
$page++;
|
$page++;
|
||||||
$canLoadMore = $responseObject->canLoadMore;
|
$canLoadMore = $responseObject->canLoadMore;
|
||||||
} catch (GuzzleException $e) {
|
} catch (GuzzleException) {
|
||||||
return $products;
|
return $products;
|
||||||
}
|
}
|
||||||
} while ($canLoadMore);
|
} while ($canLoadMore);
|
||||||
@@ -76,23 +103,27 @@ class ScrapeWebsite extends Command
|
|||||||
return $products;
|
return $products;
|
||||||
}
|
}
|
||||||
|
|
||||||
private function saveProduct(\stdClass $product): void
|
private function saveProduct(\stdClass $product, Country $country): void
|
||||||
{
|
{
|
||||||
/** @var Product $productModel */
|
/** @var Product $productModel */
|
||||||
$productModel = Product::firstOrNew(['skuID' => $product->skuID]);
|
$productModel = Product::firstOrNew(['skuID' => $product->skuID, 'country_id' => $country->id]);
|
||||||
|
|
||||||
$productModel->skuID = $product->skuID;
|
$productModel->skuID = $product->skuID;
|
||||||
$productModel->name = $product->name;
|
$productModel->name = $product->name;
|
||||||
$productModel->availableQuantity = $product->availableQuantity;
|
$productModel->availableQuantity = $product->availableQuantity;
|
||||||
$productModel->stock = $product->stock;
|
$productModel->categories = str_replace(['/', ' '], '', $product->categories);
|
||||||
$productModel->categories = json_encode($product->categories);
|
|
||||||
$productModel->image = $product->image;
|
$productModel->image = $product->image;
|
||||||
$productModel->subTitle = $product->subTitle;
|
$productModel->subTitle = $product->subTitle;
|
||||||
$productModel->variantCode = $product->variantCode;
|
$productModel->variantCode = $product->variantCode;
|
||||||
$productModel->modelCode = $product->modelCode;
|
$productModel->modelCode = $product->modelCode;
|
||||||
$productModel->url = $product->url;
|
$productModel->url = $product->url;
|
||||||
|
$productModel->lastSeen = date("Y-m-d");
|
||||||
|
$productModel->touch('updated_at');
|
||||||
|
$productModel->country()->associate($country);
|
||||||
$productModel->save();
|
$productModel->save();
|
||||||
$priceExists = $productModel->price()->whereRaw("strftime('%Y-%m-%d', created_at) = ?", [date('Y-m-d')])->exists();
|
$priceExists = $productModel->price()->whereRaw("strftime('%Y-%m-%d', created_at) = ?", [date('Y-m-d')])->exists();
|
||||||
if (!$priceExists) {
|
|
||||||
|
if (false === $priceExists) {
|
||||||
$price = new Price();
|
$price = new Price();
|
||||||
$price->price = $product->productPrice;
|
$price->price = $product->productPrice;
|
||||||
$price->productStandardPrice = $product->productStandardPrice;
|
$price->productStandardPrice = $product->productStandardPrice;
|
||||||
@@ -100,7 +131,7 @@ class ScrapeWebsite extends Command
|
|||||||
$productModel->price()->save($price);
|
$productModel->price()->save($price);
|
||||||
}
|
}
|
||||||
$stockExist = $productModel->stock()->whereRaw("strftime('%Y-%m-%d', created_at) = ?", [date('Y-m-d')])->exists();
|
$stockExist = $productModel->stock()->whereRaw("strftime('%Y-%m-%d', created_at) = ?", [date('Y-m-d')])->exists();
|
||||||
if (!$stockExist) {
|
if (false === $stockExist) {
|
||||||
$stock = new Stock();
|
$stock = new Stock();
|
||||||
$stock->availableQuantity = $product->availableQuantity;
|
$stock->availableQuantity = $product->availableQuantity;
|
||||||
$stock->stock = $product->stock;
|
$stock->stock = $product->stock;
|
||||||
|
|||||||
17
src/Controller/BaseController.php
Normal file
17
src/Controller/BaseController.php
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
|
||||||
|
use Symfony\Component\Cache\Adapter\FilesystemAdapter;
|
||||||
|
use Twig\Environment;
|
||||||
|
use Illuminate\Database\Capsule\Manager as Capsule;
|
||||||
|
|
||||||
|
class BaseController extends AbstractController
|
||||||
|
{
|
||||||
|
protected Environment $twig;
|
||||||
|
|
||||||
|
public function __construct(protected FilesystemAdapter $cache, protected Capsule $database)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
50
src/Controller/CategoryController.php
Normal file
50
src/Controller/CategoryController.php
Normal file
@@ -0,0 +1,50 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
final class CategoryController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/category/{category}', name: 'app_category')]
|
||||||
|
public function __invoke(string $category): Response
|
||||||
|
{
|
||||||
|
// if($this->cache->getItem('list_category_'.$category)->isHit()) {
|
||||||
|
// return $this->render('productList.html.twig', ['listType' => 'category_'.$category]);
|
||||||
|
// }
|
||||||
|
|
||||||
|
/** @var Product[] $products */
|
||||||
|
$products = Product::with(['price', 'lowestPrice'])
|
||||||
|
->selectRaw('products.*')
|
||||||
|
->distinct('products.id')
|
||||||
|
->fromRaw('products, json_each(products.categories)')
|
||||||
|
->whereRaw('json_each.value = ?', [$category])
|
||||||
|
->orderByDesc('starred')
|
||||||
|
->orderByDesc('created_by')
|
||||||
|
->get();
|
||||||
|
|
||||||
|
$categoriesTree = [];
|
||||||
|
|
||||||
|
foreach ($products as $product) {
|
||||||
|
$categoriesTree = $this->addToTree($product->categories, $categoriesTree);
|
||||||
|
}
|
||||||
|
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products, 'listType' => 'category_' . $category, 'category' => $category, 'categoryTree' => $categoriesTree]);
|
||||||
|
}
|
||||||
|
|
||||||
|
private function addToTree(array $categories, mixed $categoriesTree)
|
||||||
|
{
|
||||||
|
$tmp = &$categoriesTree;
|
||||||
|
foreach ($categories as $category) {
|
||||||
|
if (empty($tmp[$category])) {
|
||||||
|
$tmp[$category] = ['count' => 0];
|
||||||
|
}
|
||||||
|
$tmp = &$tmp[$category];
|
||||||
|
$tmp['count']++;
|
||||||
|
}
|
||||||
|
|
||||||
|
return $categoriesTree;
|
||||||
|
}
|
||||||
|
}
|
||||||
26
src/Controller/DiscontinuedController.php
Normal file
26
src/Controller/DiscontinuedController.php
Normal file
@@ -0,0 +1,26 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
use function Symfony\Component\Clock\now;
|
||||||
|
|
||||||
|
final class DiscontinuedController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/discontinued', name: 'app_discontinued')]
|
||||||
|
public function __invoke(): Response
|
||||||
|
{
|
||||||
|
if($this->cache->getItem('list_discontinued')->isHit()) {
|
||||||
|
return $this->render('productList.html.twig', ['listType' => 'discontinued']);
|
||||||
|
}
|
||||||
|
|
||||||
|
$products = Product::where('lastSeen', '<', now()->format('Y-m-d'))
|
||||||
|
->orderByDesc('starred')
|
||||||
|
->orderByDesc('created_by')
|
||||||
|
->get();
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products, 'listType' => 'discontinued']);
|
||||||
|
}
|
||||||
|
}
|
||||||
24
src/Controller/IndexController.php
Normal file
24
src/Controller/IndexController.php
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
final class IndexController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/', name: 'app_home')]
|
||||||
|
public function __invoke(): Response
|
||||||
|
{
|
||||||
|
if ($this->cache->getItem('list_all')->isHit()) {
|
||||||
|
return $this->render('productList.html.twig', ['listType' => 'all']);
|
||||||
|
}
|
||||||
|
$products = Product::with(['currentStock'])
|
||||||
|
->orderByDesc('starred')
|
||||||
|
->orderByDesc('created_by')
|
||||||
|
->get();
|
||||||
|
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products, 'listType' => 'all']);
|
||||||
|
}
|
||||||
|
}
|
||||||
29
src/Controller/LowestPriceController.php
Normal file
29
src/Controller/LowestPriceController.php
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
use function Symfony\Component\Clock\now;
|
||||||
|
|
||||||
|
final class LowestPriceController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/lowest-price', name: 'app_lowest_price', methods: ['GET'])]
|
||||||
|
public function __invoke(): Response
|
||||||
|
{
|
||||||
|
$listType = 'lowest_price';
|
||||||
|
if($this->cache->getItem('lowest_price')->isHit()) {
|
||||||
|
return $this->render('productList.html.twig', ['listType' => $listType]);
|
||||||
|
}
|
||||||
|
|
||||||
|
$products = Product::whereRaw('priceCurrent = priceLowest')
|
||||||
|
->whereRaw('lastSeen = "'.now()->format('Y-m-d').'"')
|
||||||
|
->whereRaw('priceCurrent < productStandardPrice')
|
||||||
|
->orderByDesc('starred')
|
||||||
|
->orderByDesc('created_by')
|
||||||
|
->with(['currentPrice', 'lowestPrice'])
|
||||||
|
->get();
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products, 'listType' => $listType]);
|
||||||
|
}
|
||||||
|
}
|
||||||
27
src/Controller/NewController.php
Normal file
27
src/Controller/NewController.php
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
use function Symfony\Component\Clock\now;
|
||||||
|
|
||||||
|
final class NewController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/new', name: 'app_new')]
|
||||||
|
public function __invoke(): Response
|
||||||
|
{
|
||||||
|
if($this->cache->getItem('list_new')->isHit()) {
|
||||||
|
return $this->render('productList.html.twig', ['listType' => 'new']);
|
||||||
|
}
|
||||||
|
$date = now()->modify('-30 days')->format('Y-m-d');
|
||||||
|
$products = Product::where('created_at', '>', $date)
|
||||||
|
->with(['country', 'stock'])
|
||||||
|
->orderByDesc('starred')
|
||||||
|
->orderByDesc('created_by')
|
||||||
|
->get();
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products, 'listType' => 'new']);
|
||||||
|
}
|
||||||
|
}
|
||||||
63
src/Controller/ProductController.php
Normal file
63
src/Controller/ProductController.php
Normal file
@@ -0,0 +1,63 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
use Twig\Error\LoaderError;
|
||||||
|
use Twig\Error\RuntimeError;
|
||||||
|
use Twig\Error\SyntaxError;
|
||||||
|
|
||||||
|
final class ProductController extends BaseController
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* @throws SyntaxError
|
||||||
|
* @throws RuntimeError
|
||||||
|
* @throws LoaderError
|
||||||
|
*/
|
||||||
|
#[Route('/product/{productId<\d+>}', name: 'app_product')]
|
||||||
|
public function __invoke(int $productId): Response
|
||||||
|
{
|
||||||
|
if ($this->cache->getItem('product' . $productId)->isHit()) {
|
||||||
|
return $this->render('product.html.twig', ['product' => ['id' => $productId]]);
|
||||||
|
}
|
||||||
|
|
||||||
|
$product = Product::with([
|
||||||
|
'price' => fn($query) => $query->orderBy('created_at', 'desc'),
|
||||||
|
'stock' => fn($query) => $query->orderBy('created_at', 'desc'),
|
||||||
|
])->find($productId);
|
||||||
|
if (null === $product) {
|
||||||
|
throw $this->createNotFoundException('Product not found');
|
||||||
|
}
|
||||||
|
$priceList = $product->price()->pluck('price', 'created_at')->mapWithKeys(fn($price, $createdAt) => [explode(' ', $createdAt)[0] => $price])->toArray();
|
||||||
|
$stockList = $product->stock()->pluck('stock', 'created_at')->mapWithKeys(fn($stock, $createdAt) => [explode(' ', $createdAt)[0] => $stock])->toArray();
|
||||||
|
return $this->render('product.html.twig', [
|
||||||
|
'product' => $product,
|
||||||
|
'price_list' => $this->prepareChartData($priceList),
|
||||||
|
'stock_list' => $this->prepareChartData($stockList),
|
||||||
|
'price_dates' => implode("','", $this->dateRange(array_key_first($priceList), array_key_last($priceList))),
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
private function prepareChartData($set1): string
|
||||||
|
{
|
||||||
|
$dates = $this->dateRange(array_key_first($set1), array_key_last($set1));
|
||||||
|
$data = array_map(fn($date) => ['x' => $date, 'y' => $set1[$date] ?? null], $dates);
|
||||||
|
$stringData = json_encode($data);
|
||||||
|
|
||||||
|
return str_replace(['"x"', '"y"'], ['x', 'y'], $stringData);
|
||||||
|
}
|
||||||
|
|
||||||
|
private function dateRange($dateStart, $dateEnd): array
|
||||||
|
{
|
||||||
|
$from = new \DateTime($dateStart);
|
||||||
|
$to = new \DateTime($dateEnd);
|
||||||
|
$range = [];
|
||||||
|
for ($date = clone $from; $date < $to; $date->modify('+1 day')) {
|
||||||
|
$range[] = $date->format('Y-m-d');
|
||||||
|
}
|
||||||
|
|
||||||
|
return $range;
|
||||||
|
}
|
||||||
|
}
|
||||||
25
src/Controller/PromosController.php
Normal file
25
src/Controller/PromosController.php
Normal file
@@ -0,0 +1,25 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
final class PromosController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/promos', name: 'app_promos')]
|
||||||
|
public function __invoke(): Response
|
||||||
|
{
|
||||||
|
if($this->cache->getItem('list_promos')->isHit()) {
|
||||||
|
return $this->render('productList.html.twig', ['listType' => 'promos']);
|
||||||
|
}
|
||||||
|
|
||||||
|
$products = Product::whereRaw('priceCurrent < productStandardPrice')
|
||||||
|
->orderByDesc('starred')
|
||||||
|
->orderByDesc('created_by')
|
||||||
|
->with(['currentPrice', 'lowestPrice'])
|
||||||
|
->get();
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products, 'listType' => 'promos']);
|
||||||
|
}
|
||||||
|
}
|
||||||
22
src/Controller/SearchController.php
Normal file
22
src/Controller/SearchController.php
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Request;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
final class SearchController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/search', name: 'app_search')]
|
||||||
|
public function __invoke(Request $request): Response
|
||||||
|
{
|
||||||
|
$search = $request->query->get('search');
|
||||||
|
$products = Product::with('price')
|
||||||
|
->orWhere([['name', 'like', "%$search%"]])
|
||||||
|
->orWhere([['subTitle', 'like', "%$search%"]])->get();
|
||||||
|
|
||||||
|
return $this->render('productList.html.twig', ['products' => $products ?? [], 'search' => $search, 'listType' => 'search_'.$search]);
|
||||||
|
}
|
||||||
|
}
|
||||||
29
src/Controller/StarController.php
Normal file
29
src/Controller/StarController.php
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Controller;
|
||||||
|
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Symfony\Component\HttpFoundation\Request;
|
||||||
|
use Symfony\Component\HttpFoundation\Response;
|
||||||
|
use Symfony\Component\Routing\Attribute\Route;
|
||||||
|
|
||||||
|
final class StarController extends BaseController
|
||||||
|
{
|
||||||
|
#[Route('/star/{productId<\d+>}', name: 'app_star')]
|
||||||
|
public function __invoke(int $productId, Request $request): Response
|
||||||
|
{
|
||||||
|
$this->cache->deleteItems(['list_all', 'list_promos', 'list_new', 'list_discontinued']);
|
||||||
|
$referer = $request->headers->get('referer');
|
||||||
|
if (str_contains($referer, '/category/')) {
|
||||||
|
preg_match('#/category/(.*)#i', $referer, $matches);
|
||||||
|
$this->cache->deleteItem('list_category_'.urldecode($matches[1]));
|
||||||
|
}
|
||||||
|
if (str_contains($referer, '/search?search=')) {
|
||||||
|
preg_match('#/search\?search=(.*)#i', $referer, $matches);
|
||||||
|
$this->cache->deleteItem('list_search_'.urldecode($matches[1]));
|
||||||
|
}
|
||||||
|
|
||||||
|
Product::find($productId)->toggleStarred()->save();
|
||||||
|
return $this->redirect($referer);
|
||||||
|
}
|
||||||
|
}
|
||||||
14
src/DatabaseFactory.php
Normal file
14
src/DatabaseFactory.php
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler;
|
||||||
|
|
||||||
|
use Illuminate\Database\Capsule\Manager as Capsule;
|
||||||
|
class DatabaseFactory
|
||||||
|
{
|
||||||
|
public static function create(Capsule $capsule): void
|
||||||
|
{
|
||||||
|
$capsule->addConnection(['driver' => 'sqlite', 'database' => __DIR__ . '/../database.sqlite']);
|
||||||
|
$capsule->setAsGlobal();
|
||||||
|
$capsule->bootEloquent();
|
||||||
|
}
|
||||||
|
}
|
||||||
53
src/Kernel.php
Normal file
53
src/Kernel.php
Normal file
@@ -0,0 +1,53 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler;
|
||||||
|
|
||||||
|
use Illuminate\Database\Capsule\Manager;
|
||||||
|
use Krzysiej\RyobiCrawler\Twig\AppExtension;
|
||||||
|
use Symfony\Bundle\FrameworkBundle\FrameworkBundle;
|
||||||
|
use Symfony\Bundle\FrameworkBundle\Kernel\MicroKernelTrait;
|
||||||
|
use Symfony\Bundle\TwigBundle\TwigBundle;
|
||||||
|
use Symfony\Component\Cache\Adapter\FilesystemAdapter;
|
||||||
|
use Symfony\Component\DependencyInjection\Loader\Configurator\ContainerConfigurator;
|
||||||
|
use Symfony\Component\DependencyInjection\Reference;
|
||||||
|
use Symfony\Component\HttpKernel\Kernel as BaseKernel;
|
||||||
|
use Symfony\Component\Routing\Loader\Configurator\RoutingConfigurator;
|
||||||
|
use Twig\Extra\Cache\CacheExtension;
|
||||||
|
use Twig\Extra\Cache\CacheRuntime;
|
||||||
|
use Twig\Extra\TwigExtraBundle\TwigExtraBundle;
|
||||||
|
|
||||||
|
class Kernel extends BaseKernel
|
||||||
|
{
|
||||||
|
use MicroKernelTrait;
|
||||||
|
|
||||||
|
public function registerBundles(): iterable
|
||||||
|
{
|
||||||
|
return [
|
||||||
|
new FrameworkBundle(),
|
||||||
|
new TwigBundle(),
|
||||||
|
new TwigExtraBundle(),
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function configureContainer(ContainerConfigurator $container): void
|
||||||
|
{
|
||||||
|
$container->extension('framework', [
|
||||||
|
'secret' => 'S0ME_SECRET'
|
||||||
|
]);
|
||||||
|
$services = $container->services()->defaults()->autowire()->autoconfigure();
|
||||||
|
$services->set(Manager::class)->configurator([DatabaseFactory::class, 'create']);
|
||||||
|
$services->load('Krzysiej\\RyobiCrawler\\', __DIR__ )
|
||||||
|
->exclude('../src/{Models,Twig,DatabaseFactory.php,Kernel.php}');
|
||||||
|
$services->set('twig.extension.cache', AppExtension::class)->tag('twig.extension');
|
||||||
|
$services->set(CacheExtension::class)->tag('twig.extension');
|
||||||
|
$services->set(FilesystemAdapter::class)->args([
|
||||||
|
'$directory' => __DIR__ . '/../var/cache/twig_blocks'
|
||||||
|
]);
|
||||||
|
$services->set('twig.runtime.cache', CacheRuntime::class)->args([new Reference(FilesystemAdapter::class)])->tag('twig.runtime');
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function configureRoutes(RoutingConfigurator $routes): void
|
||||||
|
{
|
||||||
|
$routes->import(__DIR__ . '/Controller/', 'attribute');
|
||||||
|
}
|
||||||
|
}
|
||||||
24
src/Models/Country.php
Normal file
24
src/Models/Country.php
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Models;
|
||||||
|
|
||||||
|
use Illuminate\Database\Eloquent\Model;
|
||||||
|
use Illuminate\Database\Eloquent\Relations\BelongsTo;
|
||||||
|
use Illuminate\Database\Eloquent\Relations\HasMany;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @property string $countryName
|
||||||
|
* @property string $productsUrl
|
||||||
|
* @property string $cultureCode
|
||||||
|
* @property string $currency
|
||||||
|
* @property string $locale
|
||||||
|
*/
|
||||||
|
class Country extends Model
|
||||||
|
{
|
||||||
|
public $timestamps = true;
|
||||||
|
|
||||||
|
public function products(): HasMany
|
||||||
|
{
|
||||||
|
return $this->hasMany(Product::class);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -2,48 +2,98 @@
|
|||||||
|
|
||||||
namespace Krzysiej\RyobiCrawler\Models;
|
namespace Krzysiej\RyobiCrawler\Models;
|
||||||
|
|
||||||
|
use Carbon\Traits\Date;
|
||||||
use Illuminate\Database\Eloquent\Casts\Attribute;
|
use Illuminate\Database\Eloquent\Casts\Attribute;
|
||||||
use Illuminate\Database\Eloquent\Model;
|
use Illuminate\Database\Eloquent\Model;
|
||||||
|
use Illuminate\Database\Eloquent\Relations\BelongsTo;
|
||||||
use Illuminate\Database\Eloquent\Relations\HasMany;
|
use Illuminate\Database\Eloquent\Relations\HasMany;
|
||||||
|
use Illuminate\Database\Eloquent\Relations\HasOne;
|
||||||
|
|
||||||
|
use function Symfony\Component\Clock\now;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @property integer $skuID
|
* @property integer $skuID
|
||||||
* @property integer $agilityID
|
|
||||||
* @property string $name
|
* @property string $name
|
||||||
* @property integer $availableQuantity
|
* @property integer $availableQuantity
|
||||||
* @property integer $stock
|
|
||||||
* @property string[] $categories
|
* @property string[] $categories
|
||||||
* @property string $image
|
* @property string $image
|
||||||
* @property string $subTitle
|
* @property string $subTitle
|
||||||
* @property string $variantCode
|
* @property string $variantCode
|
||||||
* @property string $modelCode
|
* @property string $modelCode
|
||||||
* @property string $url
|
* @property string $url
|
||||||
* @property boolean $starred
|
* @property int $starred
|
||||||
|
* @property float $priceCurrent
|
||||||
|
* @property float $priceLowest
|
||||||
|
* @property float $productStandardPrice
|
||||||
|
* @property float $lowestProductPrice30Days
|
||||||
|
* @property Date $lastSeen
|
||||||
|
* @property integer $stock
|
||||||
*/
|
*/
|
||||||
class Product extends Model
|
class Product extends Model
|
||||||
{
|
{
|
||||||
public $timestamps = true;
|
public $timestamps = true;
|
||||||
public $fillable = ['skuID'];
|
public $fillable = ['skuID', 'country_id'];
|
||||||
|
|
||||||
|
public function country(): BelongsTo
|
||||||
|
{
|
||||||
|
return $this->belongsTo(Country::class);
|
||||||
|
}
|
||||||
|
|
||||||
public function price(): HasMany
|
public function price(): HasMany
|
||||||
{
|
{
|
||||||
return $this->hasMany(Price::class);
|
return $this->hasMany(Price::class);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function isStarred(): bool
|
||||||
|
{
|
||||||
|
return (bool)$this->starred;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function currentPrice(): HasOne
|
||||||
|
{
|
||||||
|
return $this->hasOne(Price::class)->latestOfMany('created_at');
|
||||||
|
}
|
||||||
|
|
||||||
|
public function lowestPrice(): HasOne
|
||||||
|
{
|
||||||
|
return $this->hasOne(Price::class)->ofMany('price', 'MIN');
|
||||||
|
}
|
||||||
|
public function newestPrice(): HasOne
|
||||||
|
{
|
||||||
|
return $this->hasOne(Price::class)->latest();
|
||||||
|
}
|
||||||
|
|
||||||
public function stock(): HasMany
|
public function stock(): HasMany
|
||||||
{
|
{
|
||||||
return $this->hasMany(Stock::class);
|
return $this->hasMany(Stock::class);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function currentStock(): HasOne
|
||||||
|
{
|
||||||
|
return $this->stock()->one()->ofMany()->withDefault(fn (Stock $stock) => $stock->stock = 0);
|
||||||
|
}
|
||||||
|
|
||||||
public function toggleStarred(): self
|
public function toggleStarred(): self
|
||||||
{
|
{
|
||||||
$this->starred = !$this->starred;
|
$this->starred = !$this->starred;
|
||||||
|
|
||||||
return $this;
|
return $this;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected function categories(): Attribute
|
public function categories(): Attribute
|
||||||
{
|
{
|
||||||
return Attribute::make(
|
return Attribute::make(
|
||||||
get: fn(string $value) => array_reverse(json_decode($value, 1)),
|
get: fn(string $value) => array_reverse(json_decode($value, 1)),
|
||||||
|
set: fn(array $value) => json_encode($value),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function isDiscontinued(): bool
|
||||||
|
{
|
||||||
|
return $this->lastSeen < now()->format('Y-m-d');
|
||||||
|
}
|
||||||
|
public function isNew(): bool
|
||||||
|
{
|
||||||
|
return $this->created_at->format('Y-m-d') > now()->modify('-30 days')->format('Y-m-d');
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
97
src/Twig/AppExtension.php
Normal file
97
src/Twig/AppExtension.php
Normal file
@@ -0,0 +1,97 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Krzysiej\RyobiCrawler\Twig;
|
||||||
|
|
||||||
|
use Illuminate\Database\Eloquent\Collection;
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Price;
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Product;
|
||||||
|
use Krzysiej\RyobiCrawler\Models\Stock;
|
||||||
|
use Symfony\Component\Routing\RouterInterface;
|
||||||
|
use Twig\Extension\AbstractExtension;
|
||||||
|
use Twig\TwigFilter;
|
||||||
|
use Twig\TwigFunction;
|
||||||
|
|
||||||
|
use function Symfony\Component\Clock\now;
|
||||||
|
|
||||||
|
class AppExtension extends AbstractExtension
|
||||||
|
{
|
||||||
|
public function __construct(public RouterInterface $route)
|
||||||
|
{
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getFunctions(): array
|
||||||
|
{
|
||||||
|
return [
|
||||||
|
new TwigFunction('promosCount', [$this, 'promosCount']),
|
||||||
|
new TwigFunction('allCount', [$this, 'allCount']),
|
||||||
|
new TwigFunction('newCount', [$this, 'newCount']),
|
||||||
|
new TwigFunction('discontinuedCount', [$this, 'discontinuedCount']),
|
||||||
|
new TwigFunction('lowestPriceCount', [$this, 'lowestPriceCount']),
|
||||||
|
new TwigFunction('renderCategoryTree', [$this, 'renderCategoryTree']),
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getFilters(): array
|
||||||
|
{
|
||||||
|
return [
|
||||||
|
new TwigFilter('findByCreatedAtDate', [$this, 'findByCreatedAtDate']),
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
public function allCount(): int
|
||||||
|
{
|
||||||
|
return Product::count();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function promosCount(): int
|
||||||
|
{
|
||||||
|
return Product::whereRaw('priceCurrent < productStandardPrice')->count();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function newCount(): int
|
||||||
|
{
|
||||||
|
return Product::where('created_at', '>', now()->modify('-30 days')->format('Y-m-d'))->count();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function discontinuedCount(): int
|
||||||
|
{
|
||||||
|
return Product::where('lastSeen', '<>', now()->format('Y-m-d'))->count();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function lowestPriceCount(): int
|
||||||
|
{
|
||||||
|
return Product::whereRaw('priceCurrent = priceLowest')
|
||||||
|
->whereRaw('lastSeen = "' . now()->format('Y-m-d') . '"')
|
||||||
|
->whereRaw('priceCurrent < productStandardPrice')
|
||||||
|
->count();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function findByCreatedAtDate(Collection $items, string $date): Stock|Price|null
|
||||||
|
{
|
||||||
|
return $items->first(fn($item) => str_starts_with($item->created_at, $date));
|
||||||
|
}
|
||||||
|
|
||||||
|
public function renderCategoryTree($categories, $current, $level = 0): string
|
||||||
|
{
|
||||||
|
$tree = '';
|
||||||
|
if ($level == 0) {
|
||||||
|
$tree .= '<ul class="list-group list-group-flush">';
|
||||||
|
}
|
||||||
|
foreach ($categories as $categoryName => $category) {
|
||||||
|
$currentClass = $categoryName == $current ? 'list-group-item-primary' : '';
|
||||||
|
$tree .= '<a class="list-group-item list-group-item-action '.$currentClass.' text-decoration-none ms-' . ($level * 2) . '" href="' . $this->route->generate('app_category', ['category' => $categoryName]) . '">' . $categoryName . ' <span class="badge bg-primary rounded-pill">' . $category['count'] . '</span></a>';
|
||||||
|
|
||||||
|
unset($category['count']);
|
||||||
|
if (is_array($category) && count($category) >= 1) {
|
||||||
|
foreach ($category as $subcategoryName => $subCategory) {
|
||||||
|
$tree .= $this->renderCategoryTree([$subcategoryName => $subCategory], $current, $level + 1);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if ($level == 0) {
|
||||||
|
$tree .= '</ul>';
|
||||||
|
}
|
||||||
|
return $tree;
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,42 +0,0 @@
|
|||||||
{% extends "template.html.twig" %}
|
|
||||||
|
|
||||||
{% block content %}
|
|
||||||
<table class='table table-hover'>
|
|
||||||
<tr>
|
|
||||||
<td><img src='{{ product.image }}&width=150' class='img-fluid' alt='{{ product.name }}'/></td>
|
|
||||||
<td><a href='?product_id={{ product.id }}'>{{ product.name }}</a></td>
|
|
||||||
<td>{{ product.subTitle }}</td>
|
|
||||||
<td>
|
|
||||||
<ul class='nav'>
|
|
||||||
{% for category in product.categories %}
|
|
||||||
<li class="nav-item"><a class="nav-link" href="?category={{ category }}"> {{ category }} </a></li>
|
|
||||||
{% endfor %}
|
|
||||||
</ul>
|
|
||||||
</td>
|
|
||||||
<td><a href='https://pl.ryobitools.eu/{{ product.url }}'>link</a></td>
|
|
||||||
</tr>
|
|
||||||
<tr>
|
|
||||||
<td colspan="4">
|
|
||||||
|
|
||||||
<table class='table table-hover table-sm mb-0'>
|
|
||||||
<thead>
|
|
||||||
<tr>
|
|
||||||
<th>price</th>
|
|
||||||
<th>lowest product price in 30 days</th>
|
|
||||||
<th colspan='2'>standard price</th>
|
|
||||||
</tr>
|
|
||||||
</thead>
|
|
||||||
{% for price in product.price %}
|
|
||||||
<tr>
|
|
||||||
<td>{{ price.price }}</td>
|
|
||||||
<td>{{ price.lowestProductPrice30Days }}</td>
|
|
||||||
<td>{{ price.productStandardPrice }}</td>
|
|
||||||
<td>{{ price.created_at }}</td>
|
|
||||||
</tr>
|
|
||||||
{% endfor %}
|
|
||||||
</table>
|
|
||||||
</td>
|
|
||||||
</tr>
|
|
||||||
</table>
|
|
||||||
{% endblock %}
|
|
||||||
|
|
||||||
@@ -1,23 +0,0 @@
|
|||||||
{% extends "template.html.twig" %}
|
|
||||||
|
|
||||||
{% block content %}
|
|
||||||
<table class='table table-hover'>
|
|
||||||
{% for product in products %}
|
|
||||||
<tr>
|
|
||||||
<td class="align-middle font-weight-bold h3"><a class="text-warning text-decoration-none" href="?star={{ product.id }}">{% if product.starred %}★{% else %} ☆ {% endif %}</a></td>
|
|
||||||
<td><img src='{{ product.image }}&width=70' class='img-fluid' alt='{{ product.name }}'/></td>
|
|
||||||
<td class="align-middle"><a href='?product_id={{ product.id }}'>{{ product.name }}</a></td>
|
|
||||||
<td class="align-middle">{{ product.subTitle }}</td>
|
|
||||||
<td class="align-middle">
|
|
||||||
<ul class='nav'>
|
|
||||||
{% for category in product.categories %}
|
|
||||||
<li class="nav-item"><a class="nav-link" href="?category={{ category }}"> {{ category }} </a></li>
|
|
||||||
{% endfor %}
|
|
||||||
</ul>
|
|
||||||
</td>
|
|
||||||
<td class="align-middle"><a href='https://pl.ryobitools.eu/{{ product.url }}'>link</a></td>
|
|
||||||
<td class="align-middle">{{ product.price.last.price }}</td>
|
|
||||||
</tr>
|
|
||||||
{% endfor %}
|
|
||||||
</table>
|
|
||||||
{% endblock %}
|
|
||||||
@@ -1,24 +0,0 @@
|
|||||||
<!doctype html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
|
|
||||||
<meta http-equiv="X-UA-Compatible" content="ie=edge">
|
|
||||||
<title>Ryobi crawler</title>
|
|
||||||
<link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet" integrity="sha384-QWTKZyjpPEjISv5WaRU9OFeRpok6YctnYmDr5pNlyT2bRjXh0JMhjY6hW+ALEwIH"
|
|
||||||
crossorigin="anonymous"/>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<nav class="navbar sticky-top bg-body-tertiary border-bottom border-secondary border-1">
|
|
||||||
<div class="container-fluid">
|
|
||||||
<a class="navbar-brand" href="/browser.php">Crawler</a>
|
|
||||||
<form class="d-flex w-50" role="search">
|
|
||||||
<input class="form-control me-2" type="search" name="search" placeholder="Search term eg. 36v or RCS18X" value="{{ search }}" aria-label="Search">
|
|
||||||
<button class="btn btn-outline-success" type="submit">Search</button>
|
|
||||||
</form>
|
|
||||||
</div>
|
|
||||||
</nav>
|
|
||||||
{% block content %}{% endblock %}
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
|
|
||||||
6
templates/css/bootstrap.min.css
vendored
Normal file
6
templates/css/bootstrap.min.css
vendored
Normal file
File diff suppressed because one or more lines are too long
1
templates/css/bootstrap.min.css.map
Normal file
1
templates/css/bootstrap.min.css.map
Normal file
File diff suppressed because one or more lines are too long
7
templates/js/bootstrap.bundle.min.js
vendored
Normal file
7
templates/js/bootstrap.bundle.min.js
vendored
Normal file
File diff suppressed because one or more lines are too long
1
templates/js/bootstrap.bundle.min.js.map
Normal file
1
templates/js/bootstrap.bundle.min.js.map
Normal file
File diff suppressed because one or more lines are too long
4
templates/js/script.js
Normal file
4
templates/js/script.js
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
(function() {
|
||||||
|
const tooltipTriggerList = document.querySelectorAll('[data-bs-toggle="tooltip"]')
|
||||||
|
const tooltipList = [...tooltipTriggerList].map(tooltipTriggerEl => new bootstrap.Tooltip(tooltipTriggerEl))
|
||||||
|
})();
|
||||||
137
templates/product.html.twig
Normal file
137
templates/product.html.twig
Normal file
@@ -0,0 +1,137 @@
|
|||||||
|
{% extends "template.html.twig" %}
|
||||||
|
|
||||||
|
{% block content %}
|
||||||
|
{% cache 'product' ~ product.id %}
|
||||||
|
<div class="table-responsive">
|
||||||
|
<table class='table table-hover'>
|
||||||
|
<tr>
|
||||||
|
<td class="align-middle font-weight-bold h3"><a class="text-warning text-decoration-none"
|
||||||
|
href="{{ path('app_star', {'productId': product.id}) }}">{% if product.starred %}★{% else %} ☆ {% endif %}</a></td>
|
||||||
|
<td><img src='{{ product.image }}&width=150' class='border rounded p-1' alt='{{ product.name }}'/></td>
|
||||||
|
<td>
|
||||||
|
<a href='{{ path('app_product', {'productId': product.id}) }}' class="text-decoration-none">{{ product.name }}</a>
|
||||||
|
<span class="badge text-bg-light"><a href="{{ path('app_search', {'search': product.subTitle}) }}" class="link-underline link-underline-opacity-0 link-dark">{{ product.subTitle }}</a></span>
|
||||||
|
</td>
|
||||||
|
<td>
|
||||||
|
<nav aria-label="breadcrumb" style="--bs-breadcrumb-divider: '>';">
|
||||||
|
<ol class="breadcrumb">
|
||||||
|
{% for category in product.categories %}
|
||||||
|
<li class="breadcrumb-item" aria-current="page"><a class="breadcrumb-item text-decoration-none"
|
||||||
|
href="{{ path('app_category', {'category': category}) }}">{{ category }}</a></li>
|
||||||
|
{% endfor %}
|
||||||
|
</ol>
|
||||||
|
</nav>
|
||||||
|
</td>
|
||||||
|
<td><a href='https://pl.ryobitools.eu/{{ product.url }}'>link</a></td>
|
||||||
|
</tr>
|
||||||
|
<tr>
|
||||||
|
<td colspan="5">
|
||||||
|
<div style="width: 800px;">
|
||||||
|
<canvas id="price"></canvas>
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
<tr>
|
||||||
|
<td colspan="5">
|
||||||
|
<table class='table table-hover table-sm mb-0'>
|
||||||
|
<thead>
|
||||||
|
<tr>
|
||||||
|
<th>price</th>
|
||||||
|
<th>lowest product price in 30 days</th>
|
||||||
|
<th colspan='2'>standard price</th>
|
||||||
|
<th>Stock</th>
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
{% set stock = product.stock().get() %}
|
||||||
|
{% for price in product.price %}
|
||||||
|
<tr>
|
||||||
|
<td>{{ price.price | format_currency(product.country.currency, {}, product.country.locale) }}</td>
|
||||||
|
<td>{{ price.lowestProductPrice30Days | format_currency(product.country.currency, {}, product.country.locale) }}</td>
|
||||||
|
<td>{{ price.productStandardPrice | format_currency(product.country.currency, {}, product.country.locale) }}</td>
|
||||||
|
<td>{{ price.created_at }}</td>
|
||||||
|
<td>{{ (stock | findByCreatedAtDate(price.created_at | slice(0,10))).stock ?? '' }}</td>
|
||||||
|
</tr>
|
||||||
|
{% endfor %}
|
||||||
|
</table>
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
<script src="https://cdn.jsdelivr.net/npm/chart.js"></script>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
const ctx = document.getElementById('price').getContext('2d');
|
||||||
|
|
||||||
|
new Chart(ctx, {
|
||||||
|
type: 'line',
|
||||||
|
data: {
|
||||||
|
labels: ['{{ price_dates|raw }}'],
|
||||||
|
datasets: [
|
||||||
|
{
|
||||||
|
label: 'Price ({{ product.country.currency }})',
|
||||||
|
data: {{ price_list|raw }},
|
||||||
|
yAxisID: 'yPrice',
|
||||||
|
tension: 0.1,
|
||||||
|
borderWidth: 1
|
||||||
|
},
|
||||||
|
{
|
||||||
|
label: 'Stock (units)',
|
||||||
|
data: {{ stock_list|raw }},
|
||||||
|
yAxisID: 'yStock',
|
||||||
|
tension: 0.1,
|
||||||
|
borderWidth: 1
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
options: {
|
||||||
|
spanGaps: false,
|
||||||
|
responsive: true,
|
||||||
|
animation: false,
|
||||||
|
scales: {
|
||||||
|
x: {
|
||||||
|
title: {
|
||||||
|
display: true,
|
||||||
|
text: 'Date'
|
||||||
|
}
|
||||||
|
},
|
||||||
|
yPrice: {
|
||||||
|
type: 'linear',
|
||||||
|
position: 'left',
|
||||||
|
beginAtZero: true,
|
||||||
|
title: {
|
||||||
|
display: true,
|
||||||
|
text: 'Price ({{ product.country.currency }})'
|
||||||
|
},
|
||||||
|
grid: {
|
||||||
|
drawOnChartArea: false
|
||||||
|
}
|
||||||
|
},
|
||||||
|
yStock: {
|
||||||
|
type: 'linear',
|
||||||
|
position: 'right',
|
||||||
|
beginAtZero: true,
|
||||||
|
title: {
|
||||||
|
display: true,
|
||||||
|
text: 'Stock (units)'
|
||||||
|
},
|
||||||
|
grid: {
|
||||||
|
drawOnChartArea: false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
plugins: {
|
||||||
|
legend: {
|
||||||
|
display: true,
|
||||||
|
position: 'top'
|
||||||
|
},
|
||||||
|
title: {
|
||||||
|
display: true,
|
||||||
|
text: 'Price and Stock in time'
|
||||||
|
},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
</script>
|
||||||
|
{% endcache %}
|
||||||
|
{% endblock %}
|
||||||
|
|
||||||
75
templates/productList.html.twig
Normal file
75
templates/productList.html.twig
Normal file
@@ -0,0 +1,75 @@
|
|||||||
|
{% extends "template.html.twig" %}
|
||||||
|
|
||||||
|
{% block content %}
|
||||||
|
{% cache 'list_' ~ listType %}
|
||||||
|
|
||||||
|
{% if listType starts with 'category_' %}
|
||||||
|
{{ renderCategoryTree(categoryTree, category) | raw }}
|
||||||
|
{% endif %}
|
||||||
|
|
||||||
|
<div class="table-responsive">
|
||||||
|
<table class='table table-hover'>
|
||||||
|
<thead>
|
||||||
|
<tr>
|
||||||
|
<th></th>
|
||||||
|
<th></th>
|
||||||
|
<th>Name</th>
|
||||||
|
<th>Categories</th>
|
||||||
|
<th></th>
|
||||||
|
<th class="text-end">Lowest Price</th>
|
||||||
|
<th class="text-end">Current Price</th>
|
||||||
|
<th></th>
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
{% for product in products %}
|
||||||
|
<tr>
|
||||||
|
<td class="align-middle font-weight-bold h3"><a class="text-warning text-decoration-none"
|
||||||
|
href="{{ path('app_star', {'productId': product.id}) }}">{% if product.starred == true %}★{% else %} ☆ {% endif %}</a></td>
|
||||||
|
<td class="align-middle" style="width: 120px;"><img src='{{ product.image }}&width=70' class='img-thumbnail' alt='{{ product.name }}'/></td>
|
||||||
|
<td class="align-middle">
|
||||||
|
<a href='{{ path('app_product', {'productId': product.id}) }}' class="text-decoration-none">{{ product.name }}</a>
|
||||||
|
{% if product.stock > 0 %}
|
||||||
|
<span class="badge text-bg-light">stock: {{ product.stock }}</span>
|
||||||
|
{% else %}
|
||||||
|
<span class="badge text-bg-warning">out of stock</span>
|
||||||
|
{% endif %}
|
||||||
|
{% if product.isDiscontinued() %}
|
||||||
|
<span class="badge text-bg-secondary" data-bs-toggle="tooltip" data-bs-title="Last update: {{ product.lastSeen }}">is discontinued</span>
|
||||||
|
{% endif %}
|
||||||
|
{% if product.isNew() %}
|
||||||
|
<span class="badge text-bg-success">is new</span>
|
||||||
|
{% endif %}
|
||||||
|
<span class="badge text-bg-light"><a href="{{ path('app_search', {'search': product.subTitle}) }}" class="link-underline link-underline-opacity-0 link-dark">{{ product.subTitle }}</a></span>
|
||||||
|
</td>
|
||||||
|
<td class="align-middle">
|
||||||
|
<nav aria-label="breadcrumb" style="--bs-breadcrumb-divider: '>';" >
|
||||||
|
<ol class="breadcrumb mb-0">
|
||||||
|
{% for category in product.categories %}
|
||||||
|
<li class="breadcrumb-item" aria-current="page"><a class="breadcrumb-item text-decoration-none" href="{{ path('app_category', {'category': category}) }}">{{ category }}</a></li>
|
||||||
|
{% endfor %}
|
||||||
|
</ol>
|
||||||
|
</nav>
|
||||||
|
</td>
|
||||||
|
<td class="align-middle"><a href='https://pl.ryobitools.eu/{{ product.url }}'>link</a></td>
|
||||||
|
<td class="align-middle text-end">
|
||||||
|
{% if product.isDiscontinued() or product.priceCurrent == product.productStandardPrice %}
|
||||||
|
{{ product.priceLowest | format_currency(product.country.currency, {}, product.country.locale) }}
|
||||||
|
{% else %}
|
||||||
|
{% if product.priceLowest != product.priceCurrent %}{{ product.priceLowest | format_currency(product.country.currency, {}, product.country.locale) }}{%else%}<span class="badge text-bg-info">now lowest</span>{% endif %}</td>
|
||||||
|
{% endif %}
|
||||||
|
|
||||||
|
<td class="align-middle text-end">{{ product.priceCurrent | format_currency(product.country.currency, {}, product.country.locale) }}</td>
|
||||||
|
<td class="align-middle">
|
||||||
|
<div class="d-flex flex-row">
|
||||||
|
{% if product.priceCurrent != product.productStandardPrice %}<span
|
||||||
|
class="badge text-bg-warning text-decoration-line-through flex-fill">{{ product.productStandardPrice | format_currency(product.country.currency, {}, product.country.locale) }}</span> <span
|
||||||
|
class="badge text-bg-success flex-fill">{{ ((1 - product.priceCurrent / product.productStandardPrice)*100)|number_format(0) }}%</span>
|
||||||
|
{% endif %}
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
{% endfor %}
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
{% endcache %}
|
||||||
|
{% endblock %}
|
||||||
53
templates/template.html.twig
Normal file
53
templates/template.html.twig
Normal file
@@ -0,0 +1,53 @@
|
|||||||
|
<!doctype html>
|
||||||
|
<html lang="en" data-bs-theme="light">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
|
||||||
|
<meta http-equiv="X-UA-Compatible" content="ie=edge">
|
||||||
|
<title>Ryobi crawler</title>
|
||||||
|
<link href="/templates/css/bootstrap.min.css" rel="stylesheet" />
|
||||||
|
<script src="/templates/js/script.js" defer></script>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<nav class="navbar navbar-expand-lg sticky-top bg-body-tertiary border-bottom border-secondary border-1">
|
||||||
|
<div class="container-fluid">
|
||||||
|
<a class="navbar-brand" href="{{ path('app_home') }}">Crawler</a>
|
||||||
|
|
||||||
|
<button class="navbar-toggler" type="button" data-bs-toggle="collapse" data-bs-target="#navbarNav" aria-controls="navbarNav" aria-expanded="false" aria-label="Toggle navigation">
|
||||||
|
<span class="navbar-toggler-icon"></span>
|
||||||
|
</button>
|
||||||
|
<div class="collapse navbar-collapse" id="navbarNav">
|
||||||
|
<ul class="navbar-nav me-auto mb-2 mb-lg-0">
|
||||||
|
{% cache "menu_count" ~ listType|default('') %}
|
||||||
|
<li class="nav-item">
|
||||||
|
<a class="nav-link {% if app.request.pathinfo == path('app_home') %}active shadow-sm bg-body rounded{% endif %}" aria-current="page" href="{{ path('app_home') }}">All products <span class="badge text-bg-secondary">{{ allCount() }}</span></a>
|
||||||
|
</li>
|
||||||
|
<li class="nav-item">
|
||||||
|
<a class="nav-link {% if app.request.pathinfo == path('app_promos') %}active shadow-sm bg-body rounded{% endif %}" aria-current="page" href="{{ path('app_promos') }}">Promos <span class="badge text-bg-secondary">{{ promosCount() }}</span></a>
|
||||||
|
</li>
|
||||||
|
<li class="nav-item">
|
||||||
|
<a class="nav-link {% if app.request.pathinfo == path('app_lowest_price') %}active shadow-sm bg-body rounded{% endif %}" aria-current="page" href="{{ path('app_lowest_price') }}">Lowest price <span class="badge text-bg-secondary">{{ lowestPriceCount() }}</span></a>
|
||||||
|
</li>
|
||||||
|
<li class="nav-item">
|
||||||
|
<a class="nav-link {% if app.request.pathinfo == path('app_new') %}active shadow-sm bg-body rounded{% endif %}" aria-current="page" href="{{ path('app_new') }}">New in last 30 days <span class="badge text-bg-secondary">{{ newCount() }}</span></a>
|
||||||
|
</li>
|
||||||
|
<li class="nav-item">
|
||||||
|
<a class="nav-link {% if app.request.pathinfo == path('app_discontinued') %}active shadow-sm bg-body rounded{% endif %}" aria-current="page" href="{{ path('app_discontinued') }}">Discontinued <span class="badge text-bg-secondary">{{ discontinuedCount() }}</span></a>
|
||||||
|
</li>
|
||||||
|
{% endcache %}
|
||||||
|
</ul>
|
||||||
|
|
||||||
|
<form class="form-floating d-flex col-lg-6 col-sm-8" role="search" action="{{ path('app_search') }}">
|
||||||
|
<input class="form-control me-2 form-control-sm" type="search" id="floatingInputValue" name="search" placeholder="Search term eg. 36v or RCS18X" value="{{ search|default('') }}">
|
||||||
|
<button class="btn btn-outline-success" type="submit">Search</button>
|
||||||
|
<label for="floatingInputValue">Search term eg. 36v or RCS18X</label>
|
||||||
|
</form>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
</nav>
|
||||||
|
{% block content %}{% endblock %}
|
||||||
|
<script src="/templates/js/bootstrap.bundle.min.js"></script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
|
|
||||||
Reference in New Issue
Block a user