EXCELIA_DBARR/custom/bbus/class/bbtickethandler.class.php

<?php

require_once DOL_DOCUMENT_ROOT . '/product/class/product.class.php';


// require_once DOL_DOCUMENT_ROOT.'//class/.class.php';
// require_once DOL_DOCUMENT_ROOT.'//class/.class.php';
// require_once DOL_DOCUMENT_ROOT.'//class/.class.php';


class BbTicketHandler
{
    private $user;
    private $db;
    private $datec;
    private $fils = [];
    private $pere = [];
    private $validperiod;
    private $occasions;

    public function __construct()
    {
        global $db, $user;

        $this->db = $db;
        $this->user = $user;
    }

    public function addTicket($object, $action)
    {
        if ($object->subprice >= 0) {
            $GroupUsersObj = new GroupUsers($this->db);
            $groupUsersResult = $GroupUsersObj->fetchAll('DESC', 'rowid', 1, 0, ['customsql' => "fk_user = {$this->user->id}"]);
            foreach($groupUsersResult as $group){
                $group_id = $group->fk_settlements_group;
            }
            $factureObj = new Facture($this->db);
            $result = $factureObj->fetch($object->fk_facture);
            if ($factureObj->fk_facture_source != '') {
                $oldTickets = new BbTicket($this->db);
                $resultOldBbtickets = $oldTickets->fetchAll('DESC', 'rowid', 0, 0, ['customsql' => "fk_facture = {$factureObj->fk_facture_source} AND ticket_id= {$object->fk_product}"]);
                //print_r($resultOldBbtickets);exit;
                foreach ($resultOldBbtickets as $ticket) {
                    $newticket = new BbTicket($this->db);
                    $newticket->fk_facture = $object->fk_facture;
                    $newticket->bundle_id = $ticket->bundle_id;
                    $newticket->usable_occasions = $ticket->usable_occasions;
                    $newticket->usage = $ticket->usage;
                    $newticket->available_at = $ticket->available_at;
                    $newticket->validated_at = $ticket->validated_at;
                    $newticket->expire_at = $ticket->expire_at;
                    $newticket->ticket_id = $ticket->ticket_id;
                    $newticket->fk_settlements_group_id = $group_id;
                    if ($newticket->create($this->user) == -1) {
                        dol_syslog("Nem sikerult a ticketek mentese. facture_id: " . $object->fk_facture);
                    }
                }
            } else {
                $this->getProductAssociationPere($object);
                $this->getDatecFromFacture($object);

                foreach ($this->pere as $pere) {
                    $ticket = $this->createTicketObject2($pere, $object, $group_id);
                    if ($ticket->create($this->user) == -1) {
                        dol_syslog("Nem sikerult a ticketek mentese. facture_id: " . $object->fk_facture);
                    }
                }
            }
        }
    }

    public function deleteTicket($object)
    {
        global $user;
        $ticketObj = new BbTicket($this->db);
        $result = $ticketObj->fetchAll('ASC', 'rowid', 0, 0, ['customsql' => "fk_facture = {$object->fk_facture} AND ticket_id = {$object->fk_product}"]);
        foreach ($result as $key => $value) {
            $ticketDelObj = new BbTicket($this->db);
            if ($ticketDelObj->deleteLine($user, $key) == -1) {
                setEventMessages($ticketDelObj->error, $ticketDelObj->errors, 'errors');
            }
        }
    }


    public function addTicketForPrinting($object)
    {
        $ticketIds = [];
        $this->getProductAssociationFils($object);
        $this->getDatecFromFacture($object);

        foreach ($object->fk_product as $record) {
            $ticket = $this->createTicketObject($this->pere[0], $record, $object->fk_facture);
            $insertedTicket = $ticket->create($this->user);
            if ($insertedTicket == -1) {
                dol_syslog("Nem sikerult a ticketek mentese. facture_id: " . $object->fk_facture);
            }
            $ticketIds[$insertedTicket] = $record;
        }
        return $ticketIds;
    }

    private function getProductAssociationFils($object)
    {
        $arrayForIN = implode(",",$object->fk_product);
        $sql = "SELECT fk_product_pere FROM " . $this->db->prefix() . "product_association WHERE fk_product_fils IN (" . $arrayForIN . ")";
        $result = $this->db->query($sql);
        if (pg_num_rows($result) == 0) {
            $this->pere[] = $object->fk_product[0];
        } else {
            while ($sqlDataResult = pg_fetch_assoc($result)) {
                $this->pere[0] = $sqlDataResult['fk_product_pere'];
            }
        }
    }

    private function getProductAssociationPere($object)
    {
        $sql = "SELECT fk_product_pere FROM " . $this->db->prefix() . "product_association WHERE fk_product_fils = " . $object->fk_product;
        $result = $this->db->query($sql);
        if (pg_num_rows($result) == 0) {
            $this->pere[] = $object->fk_product;
        } else {
            while ($sqlDataResult = pg_fetch_assoc($result)) {
                $this->pere[] = $sqlDataResult['fk_product_pere'];
            }
        }
    }

    private function getDatecFromFacture($object)
    {
        $sql = "SELECT datec FROM " . $this->db->prefix() . "facture WHERE rowid = " . $object->fk_facture;
        $result = $this->db->query($sql);
        while ($sqlDataResult = pg_fetch_assoc($result)) {
            $datec = $sqlDataResult['datec'];
        }
        $this->datec = $datec;
    }

    private function getDurationFromProductsByFilsID($filsId)
    {
        $sql = "SELECT validperiod, occasions FROM " . $this->db->prefix() . "product_extrafields WHERE fk_object = " . $filsId;
        $result = $this->db->query($sql);
        while ($sqlDataResult = pg_fetch_assoc($result)) {
            $this->validperiod = $sqlDataResult['validperiod'] ? $sqlDataResult['validperiod'] : 366;
            $this->occasions = $sqlDataResult['occasions'];
        }
    }

    /* private function getPeriodByPeriodSelector($sqlDataResult){
        $sql = "SELECT occasion_duration FROM " . $this->db->prefix() . "bbus_bboccasionsdurations WHERE occasion_key = " . $sqlDataResult['period_selector'];
        echo $sql;
        $result = $this->db->query($sql);
        while ($sqlDataResult = pg_fetch_assoc($result)) {
            $this->validperiod = $sqlDataResult['occasion_duration'];
        }
    }
 */
    private function createTicketObject($pere, $ticket_id, $facture_id)
    {
        $this->getDurationFromProductsByFilsID($ticket_id);
        $ticket = new BbTicket($this->db);
        $ticket->fk_facture = $facture_id;
        $ticket->bundle_id = $pere;
        $ticket->usable_occasions = $this->occasions;
        $ticket->usage = '0';
        $ticket->available_at = $this->getAvailableAtDate($this->datec, $this->validperiod);
        $ticket->ticket_id = $ticket_id;
        return $ticket;
    }

    private function createTicketObject2($pere, $object, $group_id)
    {
        $this->getDurationFromProductsByFilsID($object->fk_product);
        $ticket = new BbTicket($this->db);
        $ticket->fk_facture = $object->fk_facture;
        $ticket->bundle_id = $pere;
        $ticket->usable_occasions = $this->occasions;
        $ticket->usage = '0';
        $ticket->available_at = $this->getAvailableAtDate($this->datec, $this->validperiod);
        $ticket->ticket_id = $object->fk_product;
        $ticket->fk_settlements_group_id = $group_id;
        return $ticket;
    }

    private function getAvailableAtDate($date, $validperiod)
    {
        $available_at = date('Y-m-d H:i:s', strtotime($date . ' +' . $validperiod . ' days'));
        return $available_at;
    }
}