390 lines
15 KiB
PHP
390 lines
15 KiB
PHP
<?php
|
|
namespace OCA\Gestion\Db;
|
|
|
|
use OCA\Gestion\Constants\OrderStatusConstant;
|
|
use OCA\Gestion\Constants\ThanatoTypeConstant;
|
|
use OCA\Gestion\Helpers\OrderHelpers;
|
|
use OCP\IDBConnection;
|
|
use \Datetime;
|
|
use OCA\Gestion\Constants\BddConstant;
|
|
use Ramsey\Uuid\Uuid;
|
|
|
|
class OrderBdd {
|
|
private $orderTablePrefix;
|
|
|
|
private $defaultTablePrefix;
|
|
private IDbConnection $pdo;
|
|
|
|
public function __construct(IDbConnection $db) {
|
|
$this->orderTablePrefix = BddConstant::DEFAULT_TABLE_PREFIX ."gestion_";
|
|
$this->defaultTablePrefix = BddConstant::DEFAULT_TABLE_PREFIX;
|
|
$this->pdo = $db;
|
|
}
|
|
|
|
private function execSQL($sql, $conditions){
|
|
$stmt = $this->pdo->prepare($sql);
|
|
$stmt->execute($conditions);
|
|
$data = $stmt->fetchAll(\PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
return json_encode($data);
|
|
}
|
|
|
|
private function execSQLNoData($sql, $conditions){
|
|
$stmt = $this->pdo->prepare($sql);
|
|
$stmt->execute($conditions);
|
|
$stmt->closeCursor();
|
|
}
|
|
|
|
private function execSQLNoJsonReturn($sql, $conditions){
|
|
$stmt = $this->pdo->prepare($sql);
|
|
$stmt->execute($conditions);
|
|
$data = $stmt->fetchAll(\PDO::FETCH_ASSOC);
|
|
$stmt->closeCursor();
|
|
return $data;
|
|
}
|
|
|
|
private function getLastOrderNumber(){
|
|
$sql = "SELECT max(orders.order_number) as order_last_number FROM "
|
|
.$this->orderTablePrefix."orders as orders";
|
|
|
|
$result = $this->execSQLNoJsonReturn($sql,[]);
|
|
$lastNumber = 0;
|
|
if(!empty($result)){
|
|
$lastNumber = $result[0]["order_last_number"];
|
|
}
|
|
return $lastNumber;
|
|
}
|
|
|
|
private function insertOrderProduct(int $orderId,int $productId){
|
|
$sql = "INSERT INTO ".$this->orderTablePrefix."order_product (fk_order_id, fk_product_id, quantity) VALUES (?,?,1)";
|
|
$this->execSQLNoData($sql, array($orderId, $productId));
|
|
return true;
|
|
}
|
|
|
|
private function updateOrderNumber($orderId,$datetime){
|
|
$lastOrderNumber = $this->getLastOrderNumber();
|
|
$currentOrderNumber = $lastOrderNumber + 1;
|
|
$currentOrderFullNumber = OrderHelpers::GetFullOrderNumberByDateAndOrderNumber($datetime,$currentOrderNumber);
|
|
$sql = "UPDATE ".$this->orderTablePrefix."orders as orders
|
|
SET orders.order_number = ?,orders.order_full_number = ?
|
|
WHERE orders.id = ?
|
|
";
|
|
$this->execSQLNoData($sql,[$currentOrderNumber,$currentOrderFullNumber,$orderId]);
|
|
}
|
|
|
|
private function updateOrderDate($orderId,$orderDate){
|
|
$sql = "UPDATE ".$this->orderTablePrefix."orders as orders
|
|
SET orders.order_date = ?
|
|
WHERE orders.id = ?
|
|
";
|
|
|
|
$this->execSQLNoData($sql,[$orderDate,$orderId]);
|
|
}
|
|
|
|
private function getProductPriceByThanatoId($thanatoId,$productId){
|
|
$sql = "SELECT *
|
|
FROM ".$this->orderTablePrefix ."thanato_product_discount as thanato_product_discount
|
|
WHERE thanato_product_discount.fk_thanato_id = ? AND
|
|
thanato_product_discount.fk_product_id = ?;
|
|
";
|
|
$thanatoProductDiscount = $this->execSQLNoJsonReturn(
|
|
$sql,
|
|
[$thanatoId,$productId]);
|
|
if(!empty($thanatoProductDiscount)){
|
|
return $thanatoProductDiscount[0]['ht_price'];
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public function getOrderByCalendarUuid($calendarUuid){
|
|
$sql = "SELECT * FROM ".$this->orderTablePrefix."orders as orders
|
|
WHERE orders.fk_calendar_uuid = ? LIMIT 1";
|
|
|
|
$result = $this->execSQLNoJsonReturn($sql,[$calendarUuid]);
|
|
if(!empty($result)){
|
|
return $result[0];
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public function insertOrderProductsByProductIds(int $orderId,array $productIds){
|
|
if (!empty($productIds)) {
|
|
foreach ($productIds as $productId) {
|
|
$this->insertOrderProduct(
|
|
$orderId,
|
|
$productId
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
public function insertOrderFromVCalendarPropertyAndReturnId($thanatoId,$clientId,$locationId,$defuntId,$calendarUuid,$date,$idNextCloud = BddConstant::DEFAULT_ADMIN_ID_NEXTCLOUD){
|
|
$dateTime = new DateTime($date);
|
|
|
|
$lastOrderNumber = $this->getLastOrderNumber();
|
|
$thisOrderNumber = $lastOrderNumber + 1;
|
|
$thisOrderFullNumber = OrderHelpers::GetFullOrderNumberByDateAndOrderNumber($dateTime,$thisOrderNumber);
|
|
$sql = "INSERT INTO `".$this->orderTablePrefix."orders` (
|
|
`order_date`,
|
|
`order_number`,
|
|
`order_full_number`,
|
|
`fk_defunt_id`,
|
|
`fk_lieu_id`,
|
|
`fk_client_id`,
|
|
`fk_thanato_id`,
|
|
`fk_order_status_key`,
|
|
`fk_calendar_uuid`,
|
|
`id_nextcloud`
|
|
)
|
|
VALUES (?,?,?,?,?,?,?,?,?,?);";
|
|
$this->execSQLNoData($sql, array(
|
|
$date,
|
|
$thisOrderNumber,
|
|
$thisOrderFullNumber,
|
|
$defuntId,
|
|
$locationId,
|
|
$clientId,
|
|
$thanatoId,
|
|
OrderStatusConstant::ORDERED_KEY,
|
|
$calendarUuid,
|
|
$idNextCloud
|
|
)
|
|
);
|
|
|
|
$order = $this->getOrderByCalendarUuid($calendarUuid);
|
|
return $order['id'];
|
|
}
|
|
|
|
public function updateOrderStatus($orderId,$statusKey){
|
|
$sql= "UPDATE ".$this->orderTablePrefix."orders as orders
|
|
SET orders.fk_order_status_key = ?
|
|
WHERE orders.id = ?";
|
|
|
|
$this->execSQLNoData($sql,[$statusKey,$orderId]);
|
|
}
|
|
public function getOrderProductsByOrderId($orderId){
|
|
$sql = "SELECT
|
|
order_product.id as order_product_id,
|
|
order_product.quantity as order_product_quantity,
|
|
produit.id as produit_id,
|
|
produit.reference as produit_reference,
|
|
produit.description as produit_description,
|
|
produit.prix_unitaire as produit_ht_price,
|
|
orders.fk_thanato_id as order_thanato_id
|
|
FROM ".$this->orderTablePrefix."order_product as order_product
|
|
LEFT JOIN ".$this->orderTablePrefix."produit as produit on order_product.fk_product_id = produit.id
|
|
LEFT JOIN ".$this->orderTablePrefix."orders as orders on order_product.fk_order_id = orders.id
|
|
WHERE order_product.fk_order_id = ?;";
|
|
$produitsList = $this->execSQLNoJsonReturn(
|
|
$sql,
|
|
[$orderId]);
|
|
|
|
$finalProduitList = [];
|
|
foreach($produitsList as &$produit){
|
|
if($produit['produit_id'] != null){
|
|
$htPrice = $produit['produit_ht_price'];
|
|
$orderThanatoId = $produit["order_thanato_id"];
|
|
if($orderThanatoId != null){
|
|
$productPrice = $this->getProductPriceByThanatoId($orderThanatoId,$produit['id']);
|
|
$htPrice = $productPrice ?? $htPrice;
|
|
$produit['produit_ht_price'] = $htPrice * $produit['order_product_quantity'];
|
|
}
|
|
$finalProduitList[] = $produit;
|
|
}
|
|
}
|
|
return $finalProduitList;
|
|
}
|
|
|
|
public function getOrdersWithDetails(){
|
|
$sql = "SELECT
|
|
orders.id,
|
|
orders.order_date,
|
|
orders.order_number,
|
|
orders.order_full_number,
|
|
orders.order_comment,
|
|
orders.fk_defunt_id,
|
|
orders.fk_lieu_id,
|
|
orders.fk_client_id,
|
|
orders.fk_thanato_id,
|
|
orders.fk_order_status_key,
|
|
orders.fk_provider_id,
|
|
thanato.id as thanato_id,
|
|
thanato.nom as thanato_nom,
|
|
thanato.prenom as thanato_prenom,
|
|
client.id as client_id,
|
|
client.nom as client_nom,
|
|
client.prenom as client_prenom,
|
|
client.entreprise as client_entreprise,
|
|
defunt.id as defunt_id,
|
|
defunt.nom as defunt_nom,
|
|
lieu.id as lieu_id,
|
|
lieu.adresse as lieu_adresse,
|
|
lieu.nom as lieu_nom,
|
|
order_status.status_label as order_status_label,
|
|
provider.provider_name as provider_name,
|
|
provider.provider_last_name as provider_last_name,
|
|
provider.provider_company_name as provider_company_name
|
|
FROM "
|
|
.$this->orderTablePrefix."orders as orders
|
|
LEFT JOIN ".$this->orderTablePrefix."thanato as thanato on orders.fk_thanato_id = thanato.id
|
|
LEFT JOIN ".$this->orderTablePrefix."client as client on orders.fk_client_id = client.id
|
|
LEFT JOIN ".$this->orderTablePrefix."defunt as defunt on orders.fk_defunt_id = defunt.id
|
|
LEFT JOIN ".$this->orderTablePrefix."lieu as lieu on orders.fk_lieu_id = lieu.id
|
|
LEFT JOIN ".$this->orderTablePrefix."provider as provider on orders.fk_provider_id = provider.id
|
|
LEFT JOIN ".$this->orderTablePrefix."order_status as order_status on orders.fk_order_status_key = order_status.status_key
|
|
ORDER BY orders.id DESC;
|
|
"
|
|
;
|
|
|
|
return $this->execSQLNoJsonReturn($sql,[]);
|
|
}
|
|
|
|
public function createDefaultOrder($idNextCloud){
|
|
$currentDatetime = new Datetime();
|
|
$currentDate = $currentDatetime->format('Y-m-d');
|
|
$lastOrderNumber = $this->getLastOrderNumber();
|
|
$currentOrderNumber = $lastOrderNumber + 1;
|
|
$currentOrderFullNumber = OrderHelpers::GetFullOrderNumberByDateAndOrderNumber($currentDatetime,$currentOrderNumber);
|
|
|
|
$sql = "INSERT INTO `".$this->orderTablePrefix."orders` (
|
|
`order_date`,
|
|
`order_number`,
|
|
`order_full_number`,
|
|
`fk_order_status_key`,
|
|
`id_nextcloud`
|
|
)
|
|
VALUES (?,?,?,?,?);";
|
|
$this->execSQLNoData($sql, array(
|
|
$currentDate,
|
|
$currentOrderNumber,
|
|
$currentOrderFullNumber,
|
|
OrderStatusConstant::NEW_KEY,
|
|
$idNextCloud
|
|
)
|
|
);
|
|
}
|
|
|
|
public function updateOrderDateAndSetNewOrderNumber($orderId,$date){
|
|
$this->updateOrderDate($orderId,$date);
|
|
$datetime = new Datetime($date);
|
|
$this->updateOrderNumber($orderId,$datetime);
|
|
}
|
|
|
|
public function getThanatoProductDiscountList(){
|
|
$sql = "SELECT
|
|
thanato_product_discount.id,
|
|
thanato_product_discount.fk_thanato_id,
|
|
thanato_product_discount.fk_product_id,
|
|
thanato.nom as thanato_nom,
|
|
thanato.prenom as thanato_prenom,
|
|
produit.reference as produit_reference,
|
|
produit.description as produit_description,
|
|
produit.prix_unitaire as produit_ht_price
|
|
FROM ".$this->orderTablePrefix."thanato_product_discount as thanato_product_discount
|
|
LEFT JOIN ".$this->orderTablePrefix."thanato as thanato on thanato_product_discount.fk_thanato_id = thanato.id
|
|
LEFT JOIN ".$this->orderTablePrefix."produit as produit on thanato_product_discount.fk_product_id = produit.id
|
|
ORDER BY thanato_product_discount.id DESC
|
|
";
|
|
|
|
return $this->execSQLNoJsonReturn($sql,[]);
|
|
}
|
|
|
|
public function createDefaultThanatoProductFee(){
|
|
$sql = "INSERT INTO `".$this->orderTablePrefix."thanato_product_discount` (`fk_thanato_id`,`fk_product_id`,`ht_price`) VALUES (0,0,0);";
|
|
$this->execSQLNoData($sql, []);
|
|
}
|
|
|
|
public function getOrderCount(){
|
|
$count = 0;
|
|
$sql = "SELECT COUNT(orders.id) as order_count
|
|
FROM ".$this->orderTablePrefix."orders as orders;";
|
|
|
|
$result = $this->execSQLNoJsonReturn($sql,[]);
|
|
if(!empty($result)){
|
|
$count = $result[0]["order_count"];
|
|
}
|
|
return $count;
|
|
}
|
|
|
|
public function getThanatoProductFeeCount(){
|
|
$count = 0;
|
|
$sql = "SELECT COUNT(thanato_product_discount.id) as thanato_product_fee_count
|
|
FROM ".$this->orderTablePrefix."thanato_product_discount as thanato_product_discount;";
|
|
|
|
$result = $this->execSQLNoJsonReturn($sql,[]);
|
|
if(!empty($result)){
|
|
$count = $result[0]["thanato_product_fee_count"];
|
|
}
|
|
return $count;
|
|
}
|
|
|
|
public function getOrderByIdWithDetails($orderId){
|
|
$sql = "SELECT
|
|
orders.id,
|
|
orders.order_date,
|
|
orders.order_number,
|
|
orders.order_full_number,
|
|
orders.order_comment,
|
|
orders.fk_defunt_id,
|
|
orders.fk_lieu_id,
|
|
orders.fk_client_id,
|
|
orders.fk_thanato_id,
|
|
orders.fk_order_status_key,
|
|
thanato.id as thanato_id,
|
|
thanato.nom as thanato_nom,
|
|
thanato.prenom as thanato_prenom,
|
|
client.id as client_id,
|
|
client.nom as client_nom,
|
|
client.prenom as client_prenom,
|
|
client.entreprise as client_entreprise,
|
|
client.adresse as client_adresse,
|
|
client.mail as client_mail,
|
|
client.telephone as client_phone,
|
|
client.legal_one as client_legal_one,
|
|
defunt.id as defunt_id,
|
|
defunt.nom as defunt_nom,
|
|
defunt.sexe as defunt_sexe,
|
|
lieu.id as lieu_id,
|
|
lieu.adresse as lieu_adresse,
|
|
lieu.nom as lieu_nom,
|
|
order_status.status_label as order_status_label
|
|
FROM "
|
|
.$this->orderTablePrefix."orders as orders
|
|
LEFT JOIN ".$this->orderTablePrefix."thanato as thanato on orders.fk_thanato_id = thanato.id
|
|
LEFT JOIN ".$this->orderTablePrefix."client as client on orders.fk_client_id = client.id
|
|
LEFT JOIN ".$this->orderTablePrefix."defunt as defunt on orders.fk_defunt_id = defunt.id
|
|
LEFT JOIN ".$this->orderTablePrefix."lieu as lieu on orders.fk_lieu_id = lieu.id
|
|
LEFT JOIN ".$this->orderTablePrefix."order_status as order_status on orders.fk_order_status_key = order_status.status_key
|
|
WHERE orders.id = ?
|
|
LIMIT 1;
|
|
"
|
|
;
|
|
|
|
$result = $this->execSQLNoJsonReturn($sql,[$orderId]);
|
|
if(!empty($result)){
|
|
return $result[0];
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
public function getOrderTotalAmount($orderId,$tva){
|
|
$totalHt = 0;
|
|
$totalTtc = 0;
|
|
$totalTvaAmount = 0;
|
|
$orderProducts = $this->getOrderProductsByOrderId($orderId);
|
|
foreach($orderProducts as $orderProduct){
|
|
$totalHt += $orderProduct["produit_ht_price"] * $orderProduct["order_product_quantity"];
|
|
$totalTvaAmount += $orderProduct["produit_ht_price"] * $tva / 100;
|
|
$totalTtc += ($totalHt * ($tva + 100)) / 100;
|
|
}
|
|
|
|
return [
|
|
"totalHt" => $totalHt,
|
|
"totalTtc" => $totalTtc,
|
|
"totalTvaAmount" => $totalTvaAmount,
|
|
"tva" => $tva
|
|
];
|
|
}
|
|
|
|
} |