CopyToDb.php

<?php

require_once(__DIR__ . '/Constants.php');
require_once(__DIR__ . '/Database.php');


class CopyToDb {

    private $db = null;

    public function __construct() {
        $this->db = new Database(DB_INDEX_DEFAULT);

    }

    /**
     * @param $module
     * @return array
     */
    private function cleanModule($module) {
        foreach ($module as $key => $value) {
            $new[$key] = $value[0] ?? null;
        }
        return ($new);
    }

    /**
     * Parse and write all MODULES
     *
     * @param $moduleAll
     * @return void
     * @throws Exception
     */
    private function module($moduleAll) {

        print "Copy Module to DB.\n";
        $this->db->sql("TRUNCATE module_tab");

        foreach ($moduleAll as $module) {

            $module = $this->cleanModule($module);
            $this->db->sql("INSERT INTO module_tab
             
                           (`otype`,`objid`,`langu`,`short`,`stext`,`sm_category`,`buchbar`,`valid_begda`,
                           `valid_endda`,`cancel_begda`,`cancel_endda`,`cpmax`,`vvz_url`,`vb_tab`,`diszip_tab`)
                            
                           VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)", ROW_REGULAR,

                [$module['OTYPE'] ?? '', $module['OBJID'] ?? '', $module['LANGU'] ?? '', $module['SHORT'] ?? '',
                    $module['STEXT'] ?? '', $module['SM_CATEGORY'] ?? '', $module['BUCHBAR'] ?? '',
                    $module['VALID_BEGDA'] ?? '', $module['VALID_ENDDA'] ?? '', $module['CANCEL_BEGDA'] ?? '',
                    $module['CANCEL_ENDDA'] ?? '', $module['CPMAX'] ?? '', $module['VVZ_URL'] ?? '', 'vb_tab', 'diszip_tab']);
        }
    }

    /**
     * @param $eventAll
     * @return void
     * @throws Exception
     */
    private function termin($objid, array $terminEvent) {

//        print "Copy Termin to DB.\n";
        foreach ($terminEvent as $termin) {
            $raum ='';
            if (isset($termin['RAUM_TAB'])) {
                if (is_array($termin['RAUM_TAB']['RAUM']??'')) {
                    $raum = $termin['RAUM_TAB']['RAUM'][0];
                }
            }
            $this->db->sql("INSERT INTO termin_tab (`event_objid`,`evdat`,`beguz`,`enduz`,`raum`) VALUES (?,?,?,?,?)"
                , ROW_REGULAR, [$objid, $termin['EVDAT'][0] ?? '', $termin['BEGUZ'][0] ?? '', $termin['ENDUZ'][0] ?? '', $raum]);
        }
    }

    /**
     * @param $eventAll
     * @return void
     * @throws Exception
     */
    private function event($eventAll) {

        print "Copy Event/Termin/Raum to DB.\n";
        $this->db->sql("TRUNCATE event_tab");
        $this->db->sql("TRUNCATE termin_tab");

        foreach ($eventAll as $event) {
            $this->db->sql("INSERT INTO event_tab (`objid`,`short`,`stext`,`vvz_url`) VALUES (?,?,?,?)"
                , ROW_REGULAR, [$event['OBJID'][0] ?? '', $event['SHORT'][0] ?? '', $event['STEXT'][0] ?? '', $event['VVZ_URL'][0] ?? '']);

            if (isset($event['TERMIN_TAB'])) {
                $this->termin($event['OBJID'][0] , $event['TERMIN_TAB']);
            }
        }
    }

    /**
     * @param $personAll
     * @return void
     * @throws Exception
     */
    private function person($personAll) {

        print "Copy Person to DB." . PHP_EOL;
        $this->db->sql("TRUNCATE person_tab");

        foreach ($personAll as $person) {
            $this->db->sql("INSERT INTO person_tab (`pernr`, `vname`, `name1`, `itim_short`, `itim_mail`, `email`, `gesch`, `pub_titel`, `titel`, `persk`, `spsl`, `funktionscode`, `fachrunicode`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)"
                , ROW_REGULAR, [$person['PERNR'][0] ?? '', $person['VNAME'][0] ?? '', $person['NAME1'][0] ?? '', $person['ITIM_SHORT'][0] ?? '', $person['ITIM_MAIL'][0] ?? '', $person['EMAIL'][0] ?? '', $person['GESCH'][0] ?? '', $person['PUB_TITEL'][0] ?? '', $person['TITEL'][0] ?? '', $person['PERSK'][0] ?? '', $person['SPSL'][0] ?? '', $person['FUNKTIONSCODE'][0] ?? '', $person['FACHRUNICODE'][0] ?? '']);
        }
    }

    public function personSingle($person) {
        $this->db->sql("INSERT INTO person_tab (`pernr`, `vname`, `name1`, `itim_short`, `itim_mail`, `email`, `gesch`, `pub_titel`, `titel`, `persk`, `sprsl`, `funktionscode`, `fachrunicode`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)"
            , ROW_REGULAR, [$person['PERNR'] ?? '', $person['VNAME'] ?? '', $person['NAME1'] ?? '', $person['ITIM_SHORT'] ?? '', $person['ITIM_MAIL'] ?? '', $person['EMAIL'] ?? '', $person['GESCH'] ?? 0, $person['PUB_TITEL'] ?? '', $person['TITEL'] ?? '', $person['PERSK'] ?? '', $person['SPRSL'] ?? '', $person['FUNKTIONSCODE'] ?? '', $person['FACHRUNICODE'] ?? '']);
    }

    private function relation($relationAll) {
        print "Copy Relations to DB." . PHP_EOL;
        $this->db->sql("TRUNCATE relation_tab");

        foreach ($relationAll as $relation) {
            $this->db->sql("INSERT INTO relation_tab (`otype`, `objid`, `relat`, `sclas`, `sobid`, `aw_based`) VALUES (?,?,?,?,?,?)"
                , ROW_REGULAR, [$relation['OTYPE'][0] ?? '', $relation['OBJID'][0] ?? '', $relation['RELAT'][0] ?? '', $relation['SCLAS'][0] ?? '', $relation['SOBID'][0] ?? '', $relation['AW_BASED'][0] ?? NULL]);
        }
    }




    /**
     * Write Data
     *
     * @param array $fullData
     * @return void
     * @throws Exception
     */
    public function process(array $fullData) {

//        $this->module($fullData['DATA'][0]['MASTERDATA']['MODULE_TAB']);
        $this->event($fullData['DATA'][0]['MASTERDATA']['EVENT_TAB']);
        $this->person($fullData['DATA'][0]['MASTERDATA']['PERSON_TAB']);
        $this->relation($fullData['DATA'][0]['MASTERDATA']['RELATION_TAB']);

    }
}