mirror of
https://github.com/Karaka-Management/oms-Billing.git
synced 2026-01-11 15:18:42 +00:00
555 lines
19 KiB
PHP
Executable File
555 lines
19 KiB
PHP
Executable File
<?php
|
|
/**
|
|
* Jingga
|
|
*
|
|
* PHP Version 8.1
|
|
*
|
|
* @package Modules\Billing\Models
|
|
* @copyright Dennis Eichhorn
|
|
* @license OMS License 2.0
|
|
* @version 1.0.0
|
|
* @link https://jingga.app
|
|
*/
|
|
declare(strict_types=1);
|
|
|
|
namespace Modules\Billing\Models;
|
|
|
|
use Modules\ClientManagement\Models\ClientMapper;
|
|
use phpOMS\DataStorage\Database\Query\Builder;
|
|
use phpOMS\Localization\Defaults\CountryMapper;
|
|
use phpOMS\Stdlib\Base\FloatInt;
|
|
|
|
/**
|
|
* Mapper class.
|
|
*
|
|
* @package Modules\Billing\Models
|
|
* @license OMS License 2.0
|
|
* @link https://jingga.app
|
|
* @since 1.0.0
|
|
*/
|
|
final class SalesBillMapper extends BillMapper
|
|
{
|
|
/**
|
|
* Model to use by the mapper.
|
|
*
|
|
* @var class-string<T>
|
|
* @since 1.0.0
|
|
*/
|
|
public const MODEL = Bill::class;
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getSalesBeforePivot(
|
|
mixed $pivot,
|
|
?string $column = null,
|
|
int $limit = 50,
|
|
int $depth = 3,
|
|
?Builder $query = null
|
|
) : array
|
|
{
|
|
return self::getAll()
|
|
->with('type')
|
|
->where('id', $pivot, '<')
|
|
->where('type/transferType', BillTransferType::SALES)
|
|
->limit($limit)
|
|
->execute();
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getSalesAfterPivot(
|
|
mixed $pivot,
|
|
?string $column = null,
|
|
int $limit = 50,
|
|
int $depth = 3,
|
|
?Builder $query = null
|
|
) : array
|
|
{
|
|
return self::getAll()
|
|
->with('type')
|
|
->where('id', $pivot, '>')
|
|
->where('type/transferType', BillTransferType::SALES)
|
|
->limit($limit)
|
|
->execute();
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getSalesByItemId(int $id, \DateTime $start, \DateTime $end) : FloatInt
|
|
{
|
|
$query = new Builder(self::$db);
|
|
|
|
/** @var array $result */
|
|
$result = $query->select('SUM(billing_bill_element_total_netsalesprice)')
|
|
->from(self::TABLE)
|
|
->leftJoin(BillElementMapper::TABLE)
|
|
->on(self::TABLE . '.billing_bill_id', '=', BillElementMapper::TABLE . '.billing_bill_element_bill')
|
|
->where(BillElementMapper::TABLE . '.billing_bill_element_item', '=', $id)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '>=', $start)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '<=', $end)
|
|
->execute()
|
|
?->fetch() ?? [];
|
|
|
|
return new FloatInt((int) ($result[0] ?? 0));
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getSalesByClientId(int $id, \DateTime $start, \DateTime $end) : FloatInt
|
|
{
|
|
$query = new Builder(self::$db);
|
|
|
|
/** @var array $result */
|
|
$result = $query->select('SUM(billing_bill_netsales)')
|
|
->from(self::TABLE)
|
|
->where(self::TABLE . '.billing_bill_client', '=', $id)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '>=', $start)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '<=', $end)
|
|
->execute()
|
|
?->fetch() ?? [];
|
|
|
|
return new FloatInt((int) ($result[0] ?? 0));
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemAvgSalesPrice(int $item, \DateTime $start, \DateTime $end) : FloatInt
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT
|
|
SUM(billing_bill_element_single_netsalesprice) as net_sales,
|
|
COUNT(billing_bill_element_total_netsalesprice) as net_count
|
|
FROM billing_bill_element
|
|
JOIN billing_bill ON billing_bill_element.billing_bill_element_bill = billing_bill.billing_bill_id
|
|
WHERE
|
|
billing_bill_element_item = {$item}
|
|
AND billing_bill_performance_date >= '{$start->format('Y-m-d H:i:s')}'
|
|
AND billing_bill_performance_date <= '{$end->format('Y-m-d H:i:s')}';
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return isset($result[0]['net_count'])
|
|
? new FloatInt((int) ($result[0]['net_sales'] ?? 0) / ($result[0]['net_count']))
|
|
: new FloatInt(0);
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getLastOrderDateByItemId(int $id) : ?\DateTimeImmutable
|
|
{
|
|
// @todo only delivers/invoice/production (no offers ...)
|
|
$query = new Builder(self::$db);
|
|
|
|
/** @var false|array $result */
|
|
$result = $query->select('billing_bill_performance_date')
|
|
->from(self::TABLE)
|
|
->leftJoin(BillElementMapper::TABLE)
|
|
->on(self::TABLE . '.billing_bill_id', '=', BillElementMapper::TABLE . '.billing_bill_element_bill')
|
|
->where(BillElementMapper::TABLE . '.billing_bill_element_item', '=', $id)
|
|
->orderBy('billing_bill_id', 'DESC')
|
|
->limit(1)
|
|
->execute()
|
|
?->fetch() ?? false;
|
|
|
|
return $result === false ? null : new \DateTimeImmutable($result[0]);
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getLastOrderDateByClientId(int $id) : ?\DateTimeImmutable
|
|
{
|
|
// @todo only delivers/invoice/production (no offers ...)
|
|
$query = new Builder(self::$db);
|
|
|
|
/** @var false|array $result */
|
|
$result = $query->select('billing_bill_performance_date')
|
|
->from(self::TABLE)
|
|
->where(self::TABLE . '.billing_bill_client', '=', $id)
|
|
->orderBy('billing_bill_id', 'DESC')
|
|
->limit(1)
|
|
->execute()
|
|
?->fetch() ?? false;
|
|
|
|
return $result === false ? null : new \DateTimeImmutable($result[0]);
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemRetentionRate(int $id, \DateTime $start, \DateTime $end) : float
|
|
{
|
|
return 0.0;
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemLivetimeValue(int $id, \DateTime $start, \DateTime $end) : FloatInt
|
|
{
|
|
return new FloatInt();
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getNewestItemInvoices(int $id, int $limit = 10) : array
|
|
{
|
|
$query = self::getQuery();
|
|
$query->leftJoin(BillElementMapper::TABLE, BillElementMapper::TABLE . '_d1')
|
|
->on(self::TABLE . '_d1.billing_bill_id', '=', BillElementMapper::TABLE . '_d1.billing_bill_element_bill')
|
|
->where(BillElementMapper::TABLE . '_d1.billing_bill_element_item', '=', $id)
|
|
->limit($limit);
|
|
|
|
/** @phpstan-ignore-next-line */
|
|
if (!empty(self::CREATED_AT)) {
|
|
$query->orderBy(self::TABLE . '_d1.' . self::COLUMNS[self::CREATED_AT]['name'], 'DESC');
|
|
} else {
|
|
$query->orderBy(self::TABLE . '_d1.' . self::COLUMNS[self::PRIMARYFIELD]['name'], 'DESC');
|
|
}
|
|
|
|
return self::getAll()->execute($query);
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getNewestClientInvoices(int $id, int $limit = 10) : array
|
|
{
|
|
$query = self::getQuery();
|
|
$query->where(self::TABLE . '_d1.billing_bill_client', '=', $id)
|
|
->limit($limit);
|
|
|
|
/** @phpstan-ignore-next-line */
|
|
if (!empty(self::CREATED_AT)) {
|
|
$query->orderBy(self::TABLE . '_d1.' . self::COLUMNS[self::CREATED_AT]['name'], 'DESC');
|
|
} else {
|
|
$query->orderBy(self::TABLE . '_d1.' . self::COLUMNS[self::PRIMARYFIELD]['name'], 'DESC');
|
|
}
|
|
|
|
return self::getAll()->execute($query);
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemTopClients(int $id, \DateTime $start, \DateTime $end, int $limit = 10) : array
|
|
{
|
|
$query = new Builder(self::$db);
|
|
$query->selectAs(ClientMapper::TABLE . '.clientmgmt_client_id', 'client')
|
|
->selectAs('SUM(' . BillElementMapper::TABLE . '.billing_bill_element_total_netsalesprice)', 'net_sales')
|
|
->from(ClientMapper::TABLE)
|
|
->leftJoin(self::TABLE)
|
|
->on(ClientMapper::TABLE . '.clientmgmt_client_id', '=', self::TABLE . '.billing_bill_client')
|
|
->leftJoin(BillElementMapper::TABLE)
|
|
->on(self::TABLE . '.billing_bill_id', '=', BillElementMapper::TABLE . '.billing_bill_element_bill')
|
|
->where(BillElementMapper::TABLE . '.billing_bill_element_item', '=', $id)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '>=', $start)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '<=', $end)
|
|
->orderBy('net_sales', 'DESC')
|
|
->limit($limit)
|
|
->groupBy('client');
|
|
|
|
$stmt = $query->execute();
|
|
$data = $stmt?->fetchAll() ?? [];
|
|
|
|
$clientIds = [];
|
|
foreach ($data as $client) {
|
|
$clientIds[] = $client['client'];
|
|
}
|
|
|
|
$clients = [];
|
|
if (!empty($clientIds)) {
|
|
$clients = ClientMapper::getAll()
|
|
->with('account')
|
|
->with('mainAddress')
|
|
->where('id', $clientIds, 'IN')
|
|
->execute();
|
|
}
|
|
|
|
return [$clients, $data];
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemBills(int $id, \DateTime $start, \DateTime $end) : array
|
|
{
|
|
$query = self::reader()
|
|
->with('type')
|
|
->with('type/l11n')
|
|
->where('type/l11n/language', 'en')
|
|
->getQuery();
|
|
|
|
$query->leftJoin(BillElementMapper::TABLE, BillElementMapper::TABLE . '_d1')
|
|
->on(self::TABLE . '_d1.billing_bill_id', '=', BillElementMapper::TABLE . '_d1.billing_bill_element_bill')
|
|
->where(BillElementMapper::TABLE . '_d1.billing_bill_element_item', '=', $id);
|
|
|
|
/** @phpstan-ignore-next-line */
|
|
if (!empty(self::CREATED_AT)) {
|
|
$query->orderBy(self::TABLE . '_d1.' . self::COLUMNS[self::CREATED_AT]['name'], 'DESC');
|
|
} else {
|
|
$query->orderBy(self::TABLE . '_d1.' . self::COLUMNS[self::PRIMARYFIELD]['name'], 'DESC');
|
|
}
|
|
|
|
return self::getAll()
|
|
->with('type')
|
|
->with('type/l11n')
|
|
->execute($query);
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getClientBills(int $id, string $language, \DateTime $start, \DateTime $end) : array
|
|
{
|
|
return self::getAll()
|
|
->with('type')
|
|
->with('type/l11n')
|
|
->where('client', $id)
|
|
->where('type/l11n/language', $language)
|
|
->where('billDate', $start, '>=')
|
|
->where('billDate', $end, '<=')
|
|
->execute();
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getClientItem(int $client, \DateTime $start, \DateTime $end) : array
|
|
{
|
|
return BillElementMapper::getAll()
|
|
->with('bill')
|
|
->with('bill/type')
|
|
->where('bill/client', $client)
|
|
->where('bill/type/transferStock', true)
|
|
->execute();
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemCountrySales(int $id, \DateTime $start, \DateTime $end, int $limit = 10) : array
|
|
{
|
|
$query = new Builder(self::$db);
|
|
$result = $query->select(CountryMapper::TABLE . '.country_code2')
|
|
->selectAs('SUM(billing_bill_element_total_netsalesprice)', 'net_sales')
|
|
->from(self::TABLE)
|
|
->leftJoin(BillElementMapper::TABLE)
|
|
->on(self::TABLE . '.billing_bill_id', '=', BillElementMapper::TABLE . '.billing_bill_element_bill')
|
|
->leftJoin(CountryMapper::TABLE)
|
|
->on(self::TABLE . '.billing_bill_billCountry', '=', CountryMapper::TABLE . '.country_code2')
|
|
->where(BillElementMapper::TABLE . '.billing_bill_element_item', '=', $id)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '>=', $start)
|
|
->andWhere(self::TABLE . '.billing_bill_performance_date', '<=', $end)
|
|
->groupBy(CountryMapper::TABLE . '.country_code2')
|
|
->orderBy('net_sales', 'DESC')
|
|
->limit($limit)
|
|
->execute()
|
|
?->fetchAll(\PDO::FETCH_KEY_PAIR);
|
|
|
|
return $result ?? [];
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getItemMonthlySalesCosts(array $items, \DateTime $start, \DateTime $end) : array
|
|
{
|
|
$item = \implode(',', $items);
|
|
|
|
$sql = <<<SQL
|
|
SELECT
|
|
billing_bill_element_item,
|
|
SUM(billing_bill_element_total_netsalesprice) as net_sales,
|
|
SUM(billing_bill_element_total_netpurchaseprice) as net_costs,
|
|
YEAR(billing_bill_performance_date) as year,
|
|
MONTH(billing_bill_performance_date) as month
|
|
FROM billing_bill_element
|
|
JOIN billing_bill ON billing_bill_element.billing_bill_element_bill = billing_bill.billing_bill_id
|
|
WHERE
|
|
billing_bill_element_item IN ({$item})
|
|
AND billing_bill_performance_date >= '{$start->format('Y-m-d H:i:s')}'
|
|
AND billing_bill_performance_date <= '{$end->format('Y-m-d H:i:s')}'
|
|
GROUP BY billing_bill_element_item, year, month
|
|
ORDER BY billing_bill_element_item, year ASC, month ASC;
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return $result ?? [];
|
|
}
|
|
|
|
public static function getItemMonthlySalesQuantity(array $items, \DateTime $start, \DateTime $end) : array
|
|
{
|
|
$item = \implode(',', $items);
|
|
|
|
$sql = <<<SQL
|
|
SELECT
|
|
billing_bill_element_item,
|
|
SUM(billing_bill_element_quantity) as quantity,
|
|
YEAR(billing_bill_performance_date) as year,
|
|
MONTH(billing_bill_performance_date) as month
|
|
FROM billing_bill_element
|
|
JOIN billing_bill ON billing_bill_element.billing_bill_element_bill = billing_bill.billing_bill_id
|
|
WHERE
|
|
billing_bill_element_item IN ({$item})
|
|
AND billing_bill_performance_date >= '{$start->format('Y-m-d H:i:s')}'
|
|
AND billing_bill_performance_date <= '{$end->format('Y-m-d H:i:s')}'
|
|
GROUP BY billing_bill_element_item, year, month
|
|
ORDER BY billing_bill_element_item, year ASC, month ASC;
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return $result ?? [];
|
|
}
|
|
|
|
/**
|
|
* Placeholder
|
|
*/
|
|
public static function getClientMonthlySalesCosts(int $client, \DateTime $start, \DateTime $end) : array
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT
|
|
SUM(billing_bill_netsales) as net_sales,
|
|
SUM(billing_bill_netcosts) as net_costs,
|
|
YEAR(billing_bill_performance_date) as year,
|
|
MONTH(billing_bill_performance_date) as month
|
|
FROM billing_bill
|
|
WHERE
|
|
billing_bill_client = {$client}
|
|
AND billing_bill_performance_date >= '{$start->format('Y-m-d H:i:s')}'
|
|
AND billing_bill_performance_date <= '{$end->format('Y-m-d H:i:s')}'
|
|
GROUP BY year, month
|
|
ORDER BY year ASC, month ASC;
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return $result ?? [];
|
|
}
|
|
|
|
public static function getItemNetSales(int $item, \DateTime $start, \DateTime $end) : FloatInt
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT SUM(billing_bill_element_single_netsalesprice) as net_sales
|
|
FROM billing_bill_element
|
|
JOIN billing_bill ON billing_bill_element.billing_bill_element_bill = billing_bill.billing_bill_id
|
|
WHERE
|
|
billing_bill_element_item = {$item}
|
|
AND billing_bill_performance_date >= '{$start->format('Y-m-d H:i:s')}'
|
|
AND billing_bill_performance_date <= '{$end->format('Y-m-d H:i:s')}';
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return new FloatInt((int) ($result[0]['net_sales'] ?? 0));
|
|
}
|
|
|
|
public static function getILVHistoric(int $item) : FloatInt
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT SUM(billing_bill_element_single_netsalesprice) as net_sales
|
|
FROM billing_bill_element
|
|
JOIN billing_bill ON billing_bill_element.billing_bill_element_bill = billing_bill.billing_bill_id
|
|
WHERE billing_bill_element_item = {$item}
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return new FloatInt((int) ($result[0]['net_sales'] ?? 0));
|
|
}
|
|
|
|
public static function getItemMRR() : FloatInt
|
|
{
|
|
return new FloatInt(0);
|
|
}
|
|
|
|
public static function getItemLastOrder(int $item) : ?\DateTime
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT billing_bill_created_at
|
|
FROM billing_bill
|
|
JOIN billing_bill_element ON billing_bill.billing_bill_id = billing_bill_element.billing_bill_element_id
|
|
WHERE billing_bill_element_item = {$item}
|
|
ORDER BY billing_bill_created_at DESC
|
|
LIMIT 1;
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return isset($result[0]['billing_bill_created_at'])
|
|
? new \DateTime(($result[0]['billing_bill_created_at']))
|
|
: null;
|
|
}
|
|
|
|
public static function getClientNetSales(int $client, \DateTime $start, \DateTime $end) : FloatInt
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT SUM(billing_bill_netsales) as net_sales
|
|
FROM billing_bill
|
|
WHERE
|
|
billing_bill_client = {$client}
|
|
AND billing_bill_performance_date >= '{$start->format('Y-m-d H:i:s')}'
|
|
AND billing_bill_performance_date <= '{$end->format('Y-m-d H:i:s')}';
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return new FloatInt((int) ($result[0]['net_sales'] ?? 0));
|
|
}
|
|
|
|
public static function getCLVHistoric(int $client) : FloatInt
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT SUM(billing_bill_netsales) as net_sales
|
|
FROM billing_bill
|
|
WHERE billing_bill_client = {$client};
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return new FloatInt((int) ($result[0]['net_sales'] ?? 0));
|
|
}
|
|
|
|
public static function getClientMRR() : FloatInt
|
|
{
|
|
return new FloatInt(0);
|
|
}
|
|
|
|
public static function getClientLastOrder(int $client) : ?\DateTime
|
|
{
|
|
$sql = <<<SQL
|
|
SELECT billing_bill_created_at
|
|
FROM billing_bill
|
|
WHERE billing_bill_client = {$client}
|
|
ORDER BY billing_bill_created_at DESC
|
|
LIMIT 1;
|
|
SQL;
|
|
|
|
$query = new Builder(self::$db);
|
|
$result = $query->raw($sql)->execute()->fetchAll(\PDO::FETCH_ASSOC);
|
|
|
|
return isset($result[0]['billing_bill_created_at'])
|
|
? new \DateTime(($result[0]['billing_bill_created_at']))
|
|
: null;
|
|
}
|
|
}
|