<?php

namespace Model;

class Partners extends Model {


    public function getPartnerek() {
        if ($_SESSION['structure_parent']!='') {
            $folders[] = $_SESSION['structure_parent'];
            foreach ($_SESSION['structure_childrens'] as $child) {
                $folders[] = $child;
            }

            $this->prepare("SELECT * FROM dr_partnerek AS part 
            LEFT JOIN dr_partner_structure_index AS csop ON csop.psi_partner_id=part.partner_id 
            WHERE 
            part.partner_status<>? AND 
            part.partner_ceg = ? AND 
            csop.psi_status<>? AND 
            csop.psi_ps_id IN (".implode(',',$folders).") 
            ORDER BY part.partner_id ASC;");

            $this->execute('0',$_SESSION['user_company_id'],'0');
            $result = $this->fetchAll();

            return $result;
        }
        elseif ($_SESSION['group_parent']!='') {
            $folders[] = $_SESSION['group_parent'];
            foreach ($_SESSION['group_childrens'] as $child) {
                $folders[] = $child;
            }

            $this->prepare("SELECT * FROM dr_partnerek AS part 
            LEFT JOIN dr_partner_csoport_index AS csop ON csop.pcsi_partner_id=part.partner_id 
            WHERE 
            part.partner_status<>? AND 
            part.partner_ceg = ? AND 
            csop.pcsi_status<>? AND 
            csop.pcsi_pcs_id IN (".implode(',',$folders).") 
            ORDER BY part.partner_id ASC;");

            $this->execute('0',$_SESSION['user_company_id'],'0');
            $result = $this->fetchAll();

            return $result;
        }
        else {
            //die("SELECT * FROM dr_partnerek WHERE partner_ceg = '".$_SESSION['user_company_id']."' AND partner_status <> '0' ORDER BY partner_id ASC;");
            $this->prepare("SELECT * FROM dr_partnerek WHERE partner_ceg = ? AND partner_status <> ? ORDER BY partner_id ASC;");

            $this->execute($_SESSION['user_company_id'],'0');
            $result = $this->fetchAll();

            if (sizeof($result)>0) {
                foreach ($result as $row) {
                    /*if ($row['partner_customer_id']!='0') {
                        $this->prepare("SELECT * FROM dr_customers WHERE customer_id = ?;");
                        $this->execute($row['partner_customer_id']);
                        $customer = $this->fetch();
                        $row['partner_code'] = $customer['customer_code'];
                        $row['partner_name'] = $customer['customer_name'];
                        $row['partner_email'] = $customer['customer_email'];
                        $row['partner_telefon'] = $customer['customer_phone'];
                    }*/

                    if ($_SESSION['partnergroup_notassigned']=='y') {
                        if ($this->isNotAssigned($row['partner_id'])) {
                            $row['partner_szcim'] = $this->getPartnerSzallitasiCim($row['partner_id']);
                            $return[] = $row;
                        }
                    }
                    elseif ($_SESSION['partnerstructure_notassigned']=='y') {
                        if ($this->isNotAssignedStructure($row['partner_id'])) {
                            $row['partner_szcim'] = $this->getPartnerSzallitasiCim($row['partner_id']);
                            $return[] = $row;
                        }
                    }
                    else {
                        $row['partner_szcim'] = $this->getPartnerSzallitasiCim($row['partner_id']);
                        $return[] = $row;
                    }
                }
                if ($_SESSION['partnergroup_notassigned']=='y') $_SESSION['partnergroup_notassigned'] = '';
                if ($_SESSION['partnerstructure_notassigned']=='y') $_SESSION['partnerstructure_notassigned'] = '';
                return $return;
            }
            else {
                return false;
            }
        }
    }


    public function getTRVs($defaultList) {
        $this->prepare("SELECT 
        customer_id AS partner_id, 
        customer_code AS partner_code, 
        customer_name AS partner_name, 
        CONCAT(cc_irsz,' ',cc_telepules,' ',cc_kozterulet) AS partner_szcim, 
        customer_phone AS partner_telefon, 
        customer_email AS partner_email 
        FROM dr_customers 
        LEFT JOIN dr_customer_cimek ON cc_customer_id=customer_id 
        WHERE customer_status <> ? AND cc_tipus = ? AND cc_status <> ?;");

        $this->execute('0','Számlázási cím','0');

        foreach ($this->fetchAll() as $row) {
            $defaultList[] = $row;
        }

        return $defaultList;
    }


    public function isNotAssigned($partner_id) {
        if ($partner_id!='') {
            $this->prepare("SELECT * FROM dr_partner_csoport_index WHERE pcsi_partner_id = ? AND pcsi_status = ?;");
            $this->execute($partner_id,'1');
            $result = $this->fetchAll();

            if (sizeof($result)>0) {
                return false;
            }
            else {
                return true;
            }
        }
        else {
            return true;
        }
    }


    public function isNotAssignedStructure($partner_id) {
        if ($partner_id!='') {
            $this->prepare("SELECT * FROM dr_partner_structure_index WHERE psi_partner_id = ? AND psi_status = ?;");
            $this->execute($partner_id,'1');
            $result = $this->fetchAll();

            if (sizeof($result)>0) {
                return false;
            }
            else {
                return true;
            }
        }
        else {
            return true;
        }
    }

    public function getPartner($partnerid) {
        if ($partnerid!='') {
            $this->prepare("SELECT * FROM dr_partnerek WHERE partner_id = ?");
            $this->execute($partnerid);
            return $this->fetch();
        }
        else {
            return false;
        }
    }


    public function savePartner($data) {
        if ($data['partner_id']!='') {
            $this->prepare("UPDATE dr_partnerek SET 
            partner_code = ?, 
            partner_srs = ?, 
            partner_name = ?, 
            partner_cegtipus = ?, 
            partner_adoszam = ?, 
            partner_artipus = ?, 
            partner_fizmod = ?, 
            partner_nyelv = ?, 
            partner_telefon = ?, 
            partner_email = ?, 
            partner_felelos = ?, 
            partner_ceg = ?, 
            partner_szallitas = ? WHERE partner_id = ?;");

            if ($data['partner_felelos']=='') $data['partner_felelos'] = '0';

            $this->execute(
                $data['partner_code'], 
                $data['partner_srs'], 
                $data['partner_name'], 
                $data['partner_cegtipus'], 
                $data['partner_adoszam'], 
                $data['partner_artipus'], 
                $data['partner_fizmod'], 
                $data['partner_nyelv'], 
                $data['partner_telefon'], 
                $data['partner_email'], 
                $data['partner_felelos'], 
                $data['partner_ceg'], 
                $data['partner_szallitas'], 
                $data['partner_id']
            );

            foreach ($data['partner_meta'] as $meta) {
                if ($meta!='') {
                    $raw = explode("#",$meta);
                    $hash = md5($data['partner_id'].'partner'.$raw[1]);
                    if ($raw[0]!='') {
                        $this->prepare("UPDATE dr_meta_values SET mv_value = ? WHERE mv_id = ?;");
                        $this->execute($raw[2],$raw[0]);
                    }
                    else {
                        $this->prepare("INSERT INTO dr_meta_values SET 
                        mv_meta_id = ?, 
                        mv_hash = ?, 
                        mv_value = ?, 
                        mv_createuser = ?;");
                        $this->execute($raw[1],$hash,$raw[2],$_SESSION['admin']['user_id']);
                    }
                }
            }
            
            return true;
        }
        else {
            return false;
        }
    }


    public function cancelPartner($data) {
        if ($data['partner_id']!='') {
            $this->prepare("DELETE FROM dr_partnerek WHERE partner_id = ?");
            $this->execute($data['partner_id']);
            return true;
        }
        else {
            return false;
        }
    }


    public function getPartnerSzallitasiCim($partnerid) {
        $this->prepare("SELECT CONCAT(pc_irsz,' ',pc_telepules,' ',pc_kozterulet) AS partner_szcim FROM dr_partner_cimek WHERE pc_partner_id = ? AND pc_tipus = ? AND pc_status <> ? ORDER BY pc_createdate DESC;");
        $this->execute($partnerid,'Számlázási cím','0');
        $result = $this->fetchAll();
        if (sizeof($result)>0) {
            return $result[0]['partner_szcim'];
        }
        else {
            return 'Nincs megadva...';
        }
    }


    public function getGroups() {
        $this->prepare("SELECT pcs_id AS id, pcs_name AS text, pcs_parent AS parent FROM dr_partner_csoportok WHERE pcs_status <> ?;");
        $this->execute('0');
        $result = $this->fetchAll();

        if (sizeof($result)>0) {
            foreach ($result as $row) {
                if ($row['parent']=='0') {
                    $row['parent'] = '#';
                }
                $data[] = $row;
            }
            return $data;
        }
        else {
            return false;
        }
    }


    public function getGroup($data) {
        $this->prepare("SELECT * FROM dr_partner_csoportok WHERE pcs_id = ?;");
        $this->execute($data['id']);
        return $this->fetch();
    }


    public function insertGroup($data) {
        $this->prepare("INSERT INTO dr_partner_csoportok SET pcs_parent = ?, pcs_name = ?, pcs_createuser = ?;");
        $this->execute($data['parent'],$data['text'],$_SESSION['admin']['user_id']);
        return true;
    }


    public function updateGroup($data) {
        $this->prepare("UPDATE dr_partner_csoportok SET pcs_name = ? WHERE pcs_id = ?;");
        $this->execute($data['name'],$data['id']);
        return true;
    }


    public function getTreeNames($tree,$root='') {
        $treeView = '';
        foreach ($tree as $item) {
            if ($item=='#') $item = $root;
            $this->prepare("SELECT * FROM dr_partner_csoportok WHERE pcs_id = ?");
            $this->execute($item);
            $result = $this->fetch();
            $treeView.= $result['pcs_name']."/";
        }
        return rtrim($treeView,"/");
    }


    public function getPartnersGroups($data) {
        $partners = array();

        foreach ($data['items'] as $item) {
            $this->prepare("SELECT * FROM dr_partnerek WHERE partner_id = ?");
            $this->execute($item);
            $partner = $this->fetch();

            $this->prepare("SELECT * FROM dr_partner_csoport_index WHERE pcsi_partner_id = ? AND pcsi_status <> ?");
            $this->execute($item,'0');
            $result = $this->fetchAll();
            if (sizeof($result)>0) {
                foreach ($result as $row) {
                    $row['tree'] = $this->getTreeNames(array_reverse(explode(",",$row['tree'])),$row['pcsi_pcs_id']);
                    $partner['groups'][] = $row;
                }
            }

            $partners[] = $partner;
        }

        return $partners;
    }


    public function checkPartnerInGroup($partnerid,$groupid) {
        if ($partnerid!='' && $groupid!='') {
            $this->prepare("SELECT * FROM dr_partner_csoport_index WHERE pcsi_partner_id = ? AND pcsi_pcs_id = ? AND pcsi_status <> ?");
            $this->execute($partnerid,$groupid,'0');
            $check = $this->fetchAll();
            if (sizeof($check)>0) {
                return false;
            }
            else {
                return true;
            }
        }
        else {
            return false;
        }
    }


    public function appendPartnerToGroup($data) {
        foreach ($data['items'] as $item) {
            if ($this->checkPartnerInGroup($item,$data['id'])) {
                $this->prepare("INSERT INTO dr_partner_csoport_index SET pcsi_partner_id = ?, pcsi_pcs_id = ?, pcsi_createuser = ?, tree = ?");
                $tree = implode(',',$data['parents']);
                $this->execute($item,$data['id'],$_SESSION['admin']['user_id'],$tree);
            }
        }
        return true;
    }


    public function movePartnerToGroup($data) {
        foreach ($data['items'] as $item) {
            $this->prepare("DELETE FROM dr_partner_csoport_index WHERE pcsi_partner_id = ?");
            $this->execute($item);

            if ($this->checkPartnerInGroup($item,$data['id'])) {
                $this->prepare("INSERT INTO dr_partner_csoport_index SET pcsi_partner_id = ?, pcsi_pcs_id = ?, pcsi_createuser = ?, tree = ?");
                $tree = implode(',',$data['parents']);
                $this->execute($item,$data['id'],$_SESSION['admin']['user_id'],$tree);
            }
        }
        return true;
    }


    public function deletePartnerFromGroup($id) {
        $this->prepare("UPDATE dr_partner_csoport_index SET pcsi_status = ? WHERE pcsi_id = ?");
        $this->execute('0',$id);
        return true;
    }


    public function deleteGroup($data) {
        $this->prepare("UPDATE dr_partner_csoportok SET pcs_status = ? WHERE pcs_id = ?;");
        $this->execute('0',$_REQUEST['id']);
        
        foreach ($_REQUEST['childrens'] as $id) {
            $this->prepare("UPDATE dr_partner_csoportok SET pcs_status = ? WHERE pcs_id = ?;");
            $this->execute('0',$id);
        }

        return true;
    }


    public function deletePartner($partnerid) {
        $this->prepare("UPDATE dr_partnerek SET partner_status = ? WHERE partner_id = ?");
        $this->execute('0',$partnerid);
        return true;
    }


    public function getCegtipusok() {
        $this->prepare("SELECT * FROM dr_cegtipusok WHERE cegtipus_status <> ? ORDER BY cegtipus_id ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getArtipusok() {
        $this->prepare("SELECT * FROM dr_artipusok WHERE artipus_status = ? AND artipus_mod = ? ORDER BY artipus_id ASC;");
        $this->execute('1','Partner');
        return $this->fetchAll();
    }


    public function getFizmodtipusok() {
        $this->prepare("SELECT * FROM dr_fizetesimodtipusok WHERE fizetesimodtipus_status <> ? ORDER BY fizetesimodtipus_id ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getNyelvek() {
        $this->prepare("SELECT * FROM dr_nyelvek WHERE nyelv_status <> ? ORDER BY nyelv_id ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getUsers() {
        $this->prepare("SELECT * FROM dr_users WHERE user_status <> ? ORDER BY user_name ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getPartnerCimek($partnerid) {
        $this->prepare("SELECT * FROM dr_partner_cimek WHERE pc_partner_id = ? AND pc_status <> ? ORDER BY pc_id ASC;");
        $this->execute($partnerid,'0');
        return $this->fetchAll();
    }


    public function getCimByID($cimid) {
        $this->prepare("SELECT * FROM dr_partner_cimek WHERE pc_id = ?;");
        $this->execute($cimid);
        $res = $this->fetch();
        return "(".$res['pc_tipus'].")".$res['pc_irsz'].". ".$res['pc_telepules']." ".$res['pc_kozterulet']." ".$res['pc_kozterulet_tipus']." ".$res['pc_hazszam']." ".$res['pc_epulet']." ".$res['pc_emelet']." ".$res['pc_ajto'];
    }


    public function getPartnerContacts($partnerid) {
        $this->prepare("SELECT * FROM dr_partner_kapcsolattartok WHERE pk_partner_id = ? AND pk_status <> ? ORDER BY pk_id ASC;");
        $this->execute($partnerid,'0');
        $result = $this->fetchAll();

        foreach ($result as $row) {
            $row['pk_cim_text'] = $this->getCimByID($row['pk_cim']);
            $return[] = $row;
        }

        return $return;
    }


    public function getCimtipusok() {
        $this->prepare("SELECT * FROM dr_cimtipusok WHERE cimtipus_status <> ? ORDER BY cimtipus_id ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getVarosok() {
        $this->prepare("SELECT * FROM dr_varosok WHERE varos_status <> ? ORDER BY varos_id ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getKoztipusok() {
        $this->prepare("SELECT * FROM dr_kozteruletek WHERE kozterulet_status <> ? ORDER BY kozterulet_id ASC;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function getStructures() {
        $this->prepare("SELECT ps_id AS id, ps_name AS text, ps_parent AS parent FROM dr_partner_structures WHERE ps_status <> ?;");
        $this->execute('0');
        $result = $this->fetchAll();

        if (sizeof($result)>0) {
            foreach ($result as $row) {
                if ($row['parent']=='0') {
                    $row['parent'] = '#';
                }
                $data[] = $row;
            }
            return $data;
        }
        else {
            return false;
        }
    }


    public function getStructure($data) {
        $this->prepare("SELECT * FROM dr_partner_structures WHERE ps_id = ?;");
        $this->execute($data['id']);
        return $this->fetch();
    }


    public function insertStructure($data) {
        $this->prepare("INSERT INTO dr_partner_structures SET ps_parent = ?, ps_name = ?, ps_createuser = ?;");
        $this->execute($data['parent'],$data['text'],$_SESSION['admin']['user_id']);
        return true;
    }


    public function updateStructure($data) {
        $this->prepare("UPDATE dr_partner_structures SET ps_name = ? WHERE ps_id = ?;");
        $this->execute($data['name'],$data['id']);
        return true;
    }


    public function getTreeNamesStructure($tree,$root='') {
        $treeView = '';
        foreach ($tree as $item) {
            if ($item=='#') $item = $root;
            $this->prepare("SELECT * FROM dr_partner_structures WHERE ps_id = ?");
            $this->execute($item);
            $result = $this->fetch();
            $treeView.= $result['ps_name']."/";
        }
        return rtrim($treeView,"/");
    }


    public function getPartnersStructures($data) {
        $partners = array();

        foreach ($data['items'] as $item) {
            $this->prepare("SELECT * FROM dr_partnerek WHERE partner_id = ?");
            $this->execute($item);
            $partner = $this->fetch();

            $this->prepare("SELECT * FROM dr_partner_structure_index WHERE psi_partner_id = ? AND psi_status <> ?");
            $this->execute($item,'0');
            $result = $this->fetchAll();
            if (sizeof($result)>0) {
                foreach ($result as $row) {
                    $row['tree'] = $this->getTreeNamesStructure(array_reverse(explode(",",$row['tree'])),$row['psi_ps_id']);
                    $partner['structures'][] = $row;
                }
            }

            $partners[] = $partner;
        }

        return $partners;
    }


    public function checkPartnerInStructure($partnerid,$structureid) {
        if ($partnerid!='' && $structureid!='') {
            $this->prepare("SELECT * FROM dr_partner_structure_index WHERE psi_partner_id = ? AND psi_ps_id = ? AND psi_status <> ?");
            $this->execute($partnerid,$structureid,'0');
            $check = $this->fetchAll();
            if (sizeof($check)>0) {
                return false;
            }
            else {
                return true;
            }
        }
        else {
            return false;
        }
    }


    public function appendPartnerToStructure($data) {
        foreach ($data['items'] as $item) {
            if ($this->checkPartnerInStructure($item,$data['id'])) {
                $this->prepare("INSERT INTO dr_partner_structure_index SET psi_partner_id = ?, psi_ps_id = ?, psi_createuser = ?, tree = ?");
                $tree = implode(',',$data['parents']);
                $this->execute($item,$data['id'],$_SESSION['admin']['user_id'],$tree);
            }
        }
        return true;
    }


    public function movePartnerToStructure($data) {
        foreach ($data['items'] as $item) {
            $this->prepare("DELETE FROM dr_partner_structure_index WHERE psi_partner_id = ?");
            $this->execute($item);

            if ($this->checkPartnerInStructure($item,$data['id'])) {
                $this->prepare("INSERT INTO dr_partner_structure_index SET psi_partner_id = ?, psi_ps_id = ?, psi_createuser = ?, tree = ?");
                $tree = implode(',',$data['parents']);
                $this->execute($item,$data['id'],$_SESSION['admin']['user_id'],$tree);
            }
        }
        return true;
    }

    
    public function deletePartnerFromStructure($id) {
        $this->prepare("UPDATE dr_partner_structure_index SET psi_status = ? WHERE psi_id = ?");
        $this->execute('0',$id);
        return true;
    }


    public function deleteStructure($data) {
        $this->prepare("UPDATE dr_partner_structures SET ps_status = ? WHERE ps_id = ?;");
        $this->execute('0',$_REQUEST['id']);
        
        foreach ($_REQUEST['childrens'] as $id) {
            $this->prepare("UPDATE dr_partner_structures SET ps_status = ? WHERE ps_id = ?;");
            $this->execute('0',$id);
        }

        return true;
    }


    public function isPartnerInGroup($groupid) {
        if ($groupid!='') {
            $this->prepare("SELECT * FROM dr_partner_csoport_index WHERE pcsi_partner_id = ? AND pcsi_pcs_id = ? AND pcsi_status = ?;");
            $this->execute($_SESSION['partner_id'],$groupid,'1');
            $check = $this->fetch();
            if ($check['pcsi_id']!='') {
                return ' checked';
            }
            else {
                return '';
            }
        }
        else {
            return '';
        }
    }


    public function getGroupsByPartner($partnerid) {
        if ($partnerid!='') {
            $this->prepare("SELECT * FROM dr_partner_csoport_index 
            LEFT JOIN dr_partner_csoportok ON pcs_id=pcsi_pcs_id 
            WHERE pcsi_partner_id = ? AND pcsi_status = ?;");

            $this->execute($partnerid,'1');

            $res = $this->fetchAll();
            $result = '';

            foreach ($res as $row) {
                $result.= $row['pcs_name'].',';
            }
            
            return trim($result,',');
        }
        else {
            return false;
        }
    }


    public function getGroupsJSON() {
        $this->prepare("SELECT pcs_id AS id, pcs_name AS text, pcs_parent AS parent_id FROM dr_partner_csoportok WHERE pcs_status <> ?;");
        $this->execute('0');
        $result = $this->fetchAll();

        $data = array();
        
        if (sizeof($result)>0) {
            foreach ($result as $row) { 
                $tmp = array();
                $tmp['id'] = $row['id'];
                $tmp['check'] = $this->isPartnerInGroup($row['id']);
                $tmp['title'] = $row['text'];
                $tmp['parent_id'] = $row['parent_id'];
                array_push($data, $tmp);
            }
            $itemsByReference = array();
            
            foreach($data as $key => &$item) {
                $itemsByReference[$item['id']] = &$item;
                $itemsByReference[$item['id']]['subs'] = array();
            }
            
            foreach($data as $key => &$item)  {
                if($item['parent_id'] && isset($itemsByReference[$item['parent_id']])) {
                    $itemsByReference[$item['parent_id']]['subs'][] = &$item;
                }
            }

            $i=0;
            foreach ($data as $sor) {
                if ($sor['parent_id']!='0') {
                    unset($data[$i]);
                }
                $i++;
            }

            return $data;
        }
        else {
            return false;
        }
    }


    public function getStructuresJSON() {
        $this->prepare("SELECT ps_id AS id, ps_name AS text, ps_parent AS parent_id FROM dr_partner_structures WHERE ps_status <> ?;");
        $this->execute('0');
        $result = $this->fetchAll();

        $data = array();
        
        if (sizeof($result)>0) {
            foreach ($result as $row) { 
                $tmp = array();
                $tmp['id'] = $row['id'];
                $tmp['title'] = $row['text'];
                $tmp['parent_id'] = $row['parent_id'];
                array_push($data, $tmp);
            }
            $itemsByReference = array();
            
            foreach($data as $key => &$item) {
                $itemsByReference[$item['id']] = &$item;
                $itemsByReference[$item['id']]['subs'] = array();
            }
            
            foreach($data as $key => &$item)  {
                if($item['parent_id'] && isset($itemsByReference[$item['parent_id']])) {
                    $itemsByReference[$item['parent_id']]['subs'][] = &$item;
                }
            }

            $i=0;
            foreach ($data as $sor) {
                if ($sor['parent_id']!='0') {
                    unset($data[$i]);
                }
                $i++;
            }

            return $data;
        }
        else {
            return false;
        }
    }


    public function getCegek() {
        $this->prepare("SELECT ceg_id,ceg_name FROM dr_cegek WHERE ceg_status <> ?;");
        $this->execute('0');
        return $this->fetchAll();
    }


    public function addPartner() {
        $this->prepare("INSERT INTO dr_partnerek SET partner_createuser = ?, partner_ceg = ?;");
        $this->execute($_SESSION['admin']['user_id'],$_SESSION['user_company_id']);
        return $this->lastInsertID();
    }


    public function addCim($data) {
        $this->prepare("INSERT INTO dr_partner_cimek SET 
        pc_partner_id = ?, 
        pc_tipus = ?, 
        pc_telepules = ?, 
        pc_irsz = ?, 
        pc_kozterulet = ?, 
        pc_kozterulet_tipus = ?, 
        pc_hazszam = ?, 
        pc_epulet = ?, 
        pc_lepcsohaz = ?, 
        pc_emelet = ?, 
        pc_ajto = ?, 
        pc_hrsz = ?, 
        pc_telefon = ?, 
        pc_email = ?, 
        pc_createuser = ?;");

        $this->execute(
            $_SESSION['partner_id'], 
            $data['pc_tipus'], 
            $data['pc_telepules'], 
            $data['pc_irsz'], 
            $data['pc_kozterulet'], 
            $data['pc_kozterulet_tipus'], 
            $data['pc_hazszam'], 
            $data['pc_epulet'], 
            $data['pc_lepcsohaz'], 
            $data['pc_emelet'], 
            $data['pc_ajto'], 
            $data['pc_hrsz'], 
            $data['pc_telefon'], 
            $data['pc_email'], 
            $_SESSION['admin']['user_id']
        );

        return true;
    }


    public function updateCim($data) {
        $this->prepare("UPDATE dr_partner_cimek SET 
        pc_tipus = ?, 
        pc_telepules = ?, 
        pc_irsz = ?, 
        pc_kozterulet = ?, 
        pc_kozterulet_tipus = ?, 
        pc_hazszam = ?, 
        pc_epulet = ?, 
        pc_lepcsohaz = ?, 
        pc_emelet = ?, 
        pc_ajto = ?, 
        pc_hrsz = ?, 
        pc_telefon = ?, 
        pc_email = ? WHERE pc_id = ?;");

        $this->execute(
            $data['pc_tipus'], 
            $data['pc_telepules'], 
            $data['pc_irsz'], 
            $data['pc_kozterulet'], 
            $data['pc_kozterulet_tipus'], 
            $data['pc_hazszam'], 
            $data['pc_epulet'], 
            $data['pc_lepcsohaz'], 
            $data['pc_emelet'], 
            $data['pc_ajto'], 
            $data['pc_hrsz'], 
            $data['pc_telefon'], 
            $data['pc_email'], 
            $data['pc_id']
        );

        return true;
    }


    public function deleteCim($data) {
        $this->prepare("UPDATE dr_partner_cimek SET pc_status = ? WHERE pc_id = ?");
        $this->execute('0',$data['pc_id']);
        return true;
    }


    public function getPartnerCim($pc_id) {
        $this->prepare("SELECT * FROM dr_partner_cimek WHERE pc_id = ?");
        $this->execute($pc_id);
        return $this->fetch();
    }


    public function addContact($data) {
        $this->prepare("INSERT INTO dr_partner_kapcsolattartok SET 
        pk_partner_id = ?, 
        pk_nev = ?, 
        pk_titulus = ?, 
        pk_tel = ?, 
        pk_mobil = ?, 
        pk_email = ?, 
        pk_cim = ?, 
        pk_createuser = ?;");

        $this->execute(
            $_SESSION['partner_id'], 
            $data['pk_nev'], 
            $data['pk_titulus'], 
            $data['pk_tel'], 
            $data['pk_mobil'], 
            $data['pk_email'], 
            $data['pk_cim'], 
            $_SESSION['admin']['user_id']
        );

        return true;
    }


    public function updateContact($data) {
        $this->prepare("UPDATE dr_partner_kapcsolattartok SET 
        pk_nev = ?, 
        pk_titulus = ?, 
        pk_tel = ?, 
        pk_mobil = ?, 
        pk_email = ?, 
        pk_cim = ? WHERE pk_id = ?;");

        $this->execute(
            $data['pk_nev'], 
            $data['pk_titulus'], 
            $data['pk_tel'], 
            $data['pk_mobil'], 
            $data['pk_email'], 
            $data['pk_cim'], 
            $data['pk_id']
        );

        return true;
    }


    public function deleteContact($data) {
        $this->prepare("UPDATE dr_partner_kapcsolattartok SET pk_status = ? WHERE pk_id = ?");
        $this->execute('0',$data['pk_id']);
        return true;
    }


    public function getPartnerContact($pk_id) {
        $this->prepare("SELECT * FROM dr_partner_kapcsolattartok WHERE pk_id = ?");
        $this->execute($pk_id);
        return $this->fetch();
    }


    public function getMetaFields($id,$module) {
        if ($module!='') {
            $this->prepare("SELECT * FROM dr_meta_fields WHERE meta_module = ? AND meta_status = ? ORDER BY meta_order ASC;");
            $this->execute($module,'1');
            $metas = $this->fetchAll();

            if (count($metas)>0) {
                foreach ($metas as $meta) {
                    $hash = md5($id.$module.$meta['meta_id']);
                    $this->prepare("SELECT * FROM dr_meta_values WHERE mv_meta_id = ? AND mv_hash = ? AND mv_status = ?;");
                    $this->execute($meta['meta_id'],$hash,'1');
                    $value = $this->fetch();
                    if ($value['mv_meta_id']!='') {
                        $meta['mv_value'] = $value['mv_value'];
                        $meta['mv_id'] = $value['mv_id'];
                    }
                    $result[] = $meta;
                }
                return $result;
            }
            else {
                return false;
            }
        }
        else {
            return false;
        }
    }


    public function getCikkek($partnerid) {
        $this->prepare("SELECT * FROM dr_cikkek WHERE cikk_status <> ? ORDER BY cikk_name ASC;");

        $this->execute('0');
        $result = $this->fetchAll();

        if (sizeof($result)>0) {
            foreach ($result as $row) {
                $this->prepare("SELECT * FROM dr_cikk_partners_index WHERE cpi_cikk_id = ? AND cpi_partner_id = ? AND cpi_status = ?;");
                $this->execute($row['cikk_id'],$partnerid,'1');
                $check = $this->fetch();
                if ($check['cpi_id']!='') {
                    $row['checked'] = ' checked';
                }
                else {
                    $row['checked'] = '';
                }
                $return[] = $row;
            }

            return $return;
        }
        else {
            return false;
        }
    }


    public function addCikkView($data) {
        $this->prepare("INSERT INTO dr_cikk_partners_index SET 
        cpi_cikk_id = ?, 
        cpi_partner_id = ?, 
        cpi_create_user = ?;");
        
        $this->execute($data['cikk_id'],$data['partner_id'],$_SESSION['admin']['user_id']);

        return true;
    }


    public function deleteCikkView($data) {
        $this->prepare("DELETE FROM dr_cikk_partners_index WHERE 
        cpi_cikk_id = ? AND 
        cpi_partner_id = ? AND 
        cpi_status = ?;");

        $this->execute($data['cikk_id'],$data['partner_id'],'1');

        return true;
    }


    public function getRaktarak($partnerid) {
        $this->prepare("SELECT * FROM dr_raktarak WHERE raktar_status <> ? ORDER BY raktar_name ASC;");

        $this->execute('0');
        $result = $this->fetchAll();

        if (sizeof($result)>0) {
            foreach ($result as $row) {
                $this->prepare("SELECT * FROM dr_raktar_partners_index WHERE rpi_raktar_id = ? AND rpi_partner_id = ? AND rpi_status = ?;");
                $this->execute($row['raktar_id'],$partnerid,'1');
                $check = $this->fetch();
                if ($check['rpi_id']!='') {
                    $row['checked'] = ' checked';
                }
                else {
                    $row['checked'] = '';
                }
                $return[] = $row;
            }

            return $return;
        }
        else {
            return false;
        }
    }


    public function addRaktarView($data) {
        $this->prepare("INSERT INTO dr_raktar_partners_index SET 
        rpi_raktar_id = ?, 
        rpi_partner_id = ?, 
        rpi_create_user = ?;");
        
        $this->execute($data['raktar_id'],$data['partner_id'],$_SESSION['admin']['user_id']);

        return true;
    }


    public function deleteRaktarView($data) {
        $this->prepare("DELETE FROM dr_raktar_partners_index WHERE 
        rpi_raktar_id = ? AND 
        rpi_partner_id = ? AND 
        rpi_status = ?;");

        $this->execute($data['raktar_id'],$data['partner_id'],'1');

        return true;
    }


    public function copyPartnerToClient($id) {
        $this->prepare("SELECT * FROM dr_partnerek WHERE partner_id = ?;");
        $this->execute($id);
        $adat = $this->fetch();

        $this->prepare("SELECT * FROM dr_partner_cimek WHERE pc_partner_id = ? AND pc_tipus = ? AND pc_status = ?;");
        $this->execute($id,'Székhely','1');
        $cim = $this->fetch();
        $address = $cim['pc_irsz'].'. '.$cim['pc_telepules'].', '.$cim['pc_kozterulet'].' '.$cim['pc_kozterulet_tipus'].' '.$cim['pc_hazszam'].' '.$cim['pc_epulet'];

        $this->prepare("INSERT INTO dr_customers SET 
        customer_name='".$adat['partner_name']."', 
        customer_age='0', 
        customer_status='1', 
        customer_createuser='".$adat['partner_createuser']."', 
        customer_email='".$adat['partner_email']."', 
        customer_phone='".$adat['partner_telefon']."', 
        customer_origin='partners', 
        cim='".$address."';");

        $this->execute();
        $newid = $this->lastInsertID();
        
        $this->generateCustomerNumber($newid);
        
        $this->prepare("INSERT INTO dr_customer_cimek SET 
        cc_customer_id='".$newid."', 
        cc_tipus='Számlázási cím', 
        cc_telepules='".$cim['pc_telepules']."', 
        cc_irsz='".$cim['pc_irsz']."', 
        cc_kozterulet='".$cim['pc_kozterulet']."', 
        cc_kozterulet_tipus='".$cim['pc_kozterulet_tipus']."', 
        cc_hazszam='".$cim['pc_hazszam']."', 
        cc_epulet='".$cim['pc_epulet']."', 
        cc_emelet='".$cim['pc_emelet']."', 
        cc_ajto='".$cim['pc_ajto']."', 
        cc_hrsz='".$cim['pc_hrsz']."', 
        cc_lepcsohaz='".$cim['pc_lepcsohaz']."', 
        cc_createuser='".$_SESSION['admin']['user_id']."';");
        
        $this->execute();

        $this->prepare("UPDATE dr_partnerek SET partner_converted='1', partner_customer_id='".$newid."' WHERE partner_id='".$id."';");
        $this->execute();

        return $newid;
    }


    public function generateCustomerNumber($id) {
        $this->prepare("SELECT REPLACE(REPLACE(customer_code,'R',''),'D','') AS szam FROM dr_customers WHERE customer_code LIKE 'D%' OR customer_code LIKE 'R%' ORDER BY CAST(szam AS DECIMAL) DESC;");
        $this->execute();
        $row = $this->fetch();
        $lastCode = intval($row['szam']);
        $nextCode = $lastCode+1;
        if ($_SESSION['trvtype']=='reg') {
            $customerCode = 'R'.$nextCode;
        }
        else {
            $customerCode = 'D'.$nextCode;
        }
        $this->prepare("UPDATE dr_customers SET customer_code='".$customerCode."' WHERE customer_id='".$id."';");
        $this->execute();
        return $customerCode;
    }


}

?>