mirror of
https://github.com/FH-Complete/FHC-Core.git
synced 2026-06-01 20:29:29 +00:00
Andreas Österreicher
7f3b1417fd
Anpassung am Gehaltsimport: - All-In Bestandteile werden als Zulage importiert - Zusatzvereinbarungen im neuem Typ Zusatzvereinbarung - Import funktioniert jetzt auch für Personen die ihr DV nicht mit Monatsersten starten sondern ein paar Tage später
466 lines
12 KiB
PHP
466 lines
12 KiB
PHP
<?php
|
|
/*
|
|
* Job zur einmaligen Import der Gehälter
|
|
*
|
|
* Aufruf (Encode / im Filenmae mit %2F):
|
|
* php index.ci.php system/MigrateSalary/import filename
|
|
*
|
|
*/
|
|
/*
|
|
AUFBAU CSV:
|
|
SVNR;Pers-Nr;Name;Dienstverhältnis;LA-Nr;Bezeichnung;2022-09-01;2022-10-01;2022-11-01;2022-12-01;2023-01-01;2023-02-01;2023-03-01
|
|
XXXX XXXXXX;00;Name;5;1000;Gehalt;1.111,10;1.211,10;1.311,10;1.411,10;1.511,10;1.611,10;1.711,10
|
|
*/
|
|
|
|
if (! defined('BASEPATH')) exit('No direct script access allowed');
|
|
|
|
class MigrateSalary extends CLI_Controller
|
|
{
|
|
private $OE_DEFAULT = 'gst';
|
|
private $GEHALT_BEGINN_SPALTE = 6; // Beginnend mit 0 => G
|
|
private $INDEX_LOHNART = 4;
|
|
private $INDEX_BEZEICHNUNG = 5;
|
|
|
|
/**
|
|
* Constructor
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
|
|
$this->load->model('vertragsbestandteil/Gehaltsbestandteil_model', 'GehaltsbestandteilModel');
|
|
$this->load->model('vertragsbestandteil/Dienstverhaeltnis_model','DienstverhaeltnisModel');
|
|
$this->load->model('vertragsbestandteil/Vertragsbestandteil_model','VertragsbestandteilModel');
|
|
$this->load->model('vertragsbestandteil/VertragsbestandteilStunden_model','VertragsbestandteilStundenModel');
|
|
$this->load->model('vertragsbestandteil/VertragsbestandteilFreitext_model','VertragsbestandteilFreitextModel');
|
|
$this->load->model('vertragsbestandteil/VertragsbestandteilFunktion_model','VertragsbestandteilFunktionModel');
|
|
|
|
}
|
|
|
|
// -----------------------------------------------------------------------------------------------------------------
|
|
// Public methods
|
|
|
|
/**
|
|
* Everything has a beginning
|
|
*/
|
|
public function import($file)
|
|
{
|
|
|
|
// CSV Laden
|
|
$file = urldecode($file);
|
|
if($handle = fopen($file, "r"))
|
|
{
|
|
$csvrow = -1;
|
|
$lastuser = '';
|
|
$monate = array();
|
|
$gehaltsarr = array();
|
|
$gehaltsindex = 0;
|
|
|
|
while (($data = fgetcsv($handle, null, ';')) !== FALSE)
|
|
{
|
|
$csvrow++;
|
|
// Kopfzeile ueberspringen
|
|
if($csvrow == 0)
|
|
{
|
|
for($i = $this->GEHALT_BEGINN_SPALTE; $i < count($data); $i++)
|
|
{
|
|
$monate[] = $data[$i];
|
|
}
|
|
continue;
|
|
}
|
|
|
|
// User zur SVNR ermitteln
|
|
$svnr = str_replace(' ', '',$data[0]);
|
|
$resultuser = $this->_getUser($svnr);
|
|
|
|
if(!hasData($resultuser))
|
|
{
|
|
echo getError($resultuser);
|
|
break;
|
|
}
|
|
|
|
$user = getData($resultuser)[0]->mitarbeiter_uid;
|
|
echo "\nUser:".$user;
|
|
|
|
if($user != $lastuser && $lastuser != '')
|
|
{
|
|
$this->_saveGehalt($lastuser, $gehaltsarr);
|
|
$gehaltsarr = array();
|
|
$gehaltsindex = 0;
|
|
$lastuser = $user;
|
|
}
|
|
else
|
|
{
|
|
$lastuser = $user;
|
|
}
|
|
|
|
// Gehalt Clustern
|
|
|
|
$monat = 0;
|
|
for ($i = $this->GEHALT_BEGINN_SPALTE; $i < count($data); $i++)
|
|
{
|
|
if (count($gehaltsarr) == 0 && $data[$i] != '')
|
|
{
|
|
$gehaltsarr[$gehaltsindex]['betrag'] = $data[$i];
|
|
$gehaltsarr[$gehaltsindex]['lohnart'] = $data[$this->INDEX_LOHNART];
|
|
$gehaltsarr[$gehaltsindex]['bezeichnung'] = $data[$this->INDEX_BEZEICHNUNG];
|
|
$gehaltsarr[$gehaltsindex]['beginn'] = $monate[$monat];
|
|
}
|
|
else
|
|
{
|
|
if ($data[$i] != ''
|
|
&& isset($gehaltsarr[$gehaltsindex]) && isset($gehaltsarr[$gehaltsindex]['betrag'])
|
|
&& $gehaltsarr[$gehaltsindex]['betrag'] == $data[$i])
|
|
{
|
|
// Gehalt bleibt gleich
|
|
}
|
|
else
|
|
{
|
|
if ($data[$i] != '')
|
|
{
|
|
// Gehalt hat sich geändert
|
|
if ($monat != 0 && isset($gehaltsarr[$gehaltsindex]))
|
|
$gehaltsarr[$gehaltsindex]['ende'] = $monate[$monat-1];
|
|
|
|
$gehaltsindex++;
|
|
|
|
$gehaltsarr[$gehaltsindex]['betrag'] = $data[$i];
|
|
$gehaltsarr[$gehaltsindex]['lohnart'] = $data[$this->INDEX_LOHNART];
|
|
$gehaltsarr[$gehaltsindex]['bezeichnung'] = $data[$this->INDEX_BEZEICHNUNG];
|
|
$gehaltsarr[$gehaltsindex]['beginn'] = $monate[$monat];
|
|
}
|
|
elseif(isset($gehaltsarr[$gehaltsindex]))
|
|
{
|
|
// Gehalt wurde beendet
|
|
if($monat!=0)
|
|
$gehaltsarr[$gehaltsindex]['ende'] = $monate[$monat-1];
|
|
$gehaltsindex++;
|
|
}
|
|
}
|
|
}
|
|
|
|
$monat++;
|
|
}
|
|
|
|
// Zeile zu Ende - Ende Datum setzen wenn nicht für alle Monate ein Eintrag vorhanden ist
|
|
if($monat < count($monate) && isset($gehaltsarr[$gehaltsindex]))
|
|
$gehaltsarr[$gehaltsindex]['ende'] == $monate[$monat-1];
|
|
|
|
}
|
|
$this->_saveGehalt($lastuser, $gehaltsarr);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Ermittelt das passende Dienstverhaeltnis uns speichert den
|
|
* Gehaltsbestandteil
|
|
*/
|
|
private function _saveGehalt($uid, $gehaltsarr)
|
|
{
|
|
$failed = false;
|
|
$this->db->trans_begin();
|
|
|
|
foreach($gehaltsarr as $row_gehalt)
|
|
{
|
|
$auszahlungen = 14;
|
|
$dvid = '';
|
|
$vbsid = '';
|
|
$typ = '';
|
|
$allin = false;
|
|
|
|
//DV und VBS Ermitteln
|
|
$dv = $this->DienstverhaeltnisModel->getDVByPersonUID($uid, $this->OE_DEFAULT, $row_gehalt['beginn']);
|
|
|
|
if (!hasData($dv))
|
|
{
|
|
$date = new DateTime($row_gehalt['beginn']);
|
|
$date->modify('last day of this month');
|
|
$last_day_this_month = $date->format('Y-m-d');
|
|
|
|
// Wenn mit Monatsersten kein DV gefunden wird, wird stattdessen mit Monatsletzten gesucht um DVs zu finden
|
|
// für Personen die erst später im Monat in ihr DV einsteigen
|
|
$dv = $this->DienstverhaeltnisModel->getDVByPersonUID($uid, $this->OE_DEFAULT, $last_day_this_month);
|
|
|
|
if (!hasData($dv))
|
|
{
|
|
echo "\nKein passendes DV gefunden für User ".$uid." und Datum ".$row_gehalt['beginn']." -> ROLLBACK\n";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
else
|
|
{
|
|
// Gehaltsstart wird auf den Start des DV korrigiert wenn nicht der Monatserste
|
|
$row_gehalt['beginn'] = getData($dv)[0]->von;
|
|
}
|
|
}
|
|
|
|
$resultdata = getData($dv);
|
|
if (count($resultdata) !== 1)
|
|
{
|
|
echo "Kein oder Mehrere DVs gefunden -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
|
|
$dvid = $resultdata[0]->dienstverhaeltnis_id;
|
|
|
|
$allin = $this->_isAllIn($dvid, $row_gehalt['beginn']);
|
|
|
|
$db = new DB_Model();
|
|
|
|
$resultVBS = $this->_getVBS($dvid, $row_gehalt['beginn']);
|
|
|
|
if (hasData($resultVBS))
|
|
{
|
|
$vbsid = getData($resultVBS)[0]->vertragsbestandteil_id;
|
|
}
|
|
else
|
|
{
|
|
echo "Vertragsbestandteil wurde nicht gefunden -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
|
|
if ($row_gehalt['lohnart'] == 1000)
|
|
{
|
|
if($allin)
|
|
$typ = 'grundgehalt';
|
|
else
|
|
$typ = 'basisgehalt';
|
|
}
|
|
elseif ($row_gehalt['lohnart']==1041 // 14x
|
|
|| $row_gehalt['lohnart']==1042 // 12x
|
|
|| $row_gehalt['lohnart']==3410) // USTDPausch
|
|
{
|
|
$typ = 'zusatzvereinbarung';
|
|
|
|
// Freitextbestandteil anlegen fuer die Zulage
|
|
// Gaehalt wird der Zuglage zugeordnet
|
|
|
|
$data = array(
|
|
'dienstverhaeltnis_id' => $dvid,
|
|
'von' => $row_gehalt['beginn'],
|
|
'vertragsbestandteiltyp_kurzbz' => 'freitext',
|
|
'insertamum' => date('Y-m-d H:i:s'),
|
|
'insertvon' => 'MigrateSalary'
|
|
);
|
|
if (isset($row_gehalt['ende']) && $row_gehalt['ende']!='')
|
|
$data['bis'] = $row_gehalt['ende'];
|
|
|
|
$resultVBS = $this->VertragsbestandteilModel->Insert($data);
|
|
if(!isSuccess($resultVBS))
|
|
{
|
|
echo "VBS kann nicht erstellt werden -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
$vbsid = getData($resultVBS);
|
|
|
|
$data = array(
|
|
'vertragsbestandteil_id' => $vbsid,
|
|
'freitexttyp_kurzbz' => 'zusatzvereinbarung',
|
|
'titel' => $row_gehalt['bezeichnung'],
|
|
'anmerkung' => $row_gehalt['bezeichnung'],
|
|
);
|
|
$resultVBSFreitext = $this->VertragsbestandteilFreitextModel->Insert($data);
|
|
if(!isSuccess($resultVBSFreitext))
|
|
{
|
|
echo "VBS Freitext Zusatz kann nicht erstellt werden -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
}
|
|
elseif ($row_gehalt['lohnart']==9999) // All-In Custom Lohnart nicht per Default vorhanden
|
|
{
|
|
$typ = 'zulage';
|
|
|
|
// Freitextbestandteil anlegen fuer die Zulage
|
|
// Gaehalt wird der Zuglage zugeordnet
|
|
|
|
$data = array(
|
|
'dienstverhaeltnis_id' => $dvid,
|
|
'von' => $row_gehalt['beginn'],
|
|
'vertragsbestandteiltyp_kurzbz' => 'freitext',
|
|
'insertamum' => date('Y-m-d H:i:s'),
|
|
'insertvon' => 'MigrateSalary'
|
|
);
|
|
if (isset($row_gehalt['ende']) && $row_gehalt['ende']!='')
|
|
$data['bis'] = $row_gehalt['ende'];
|
|
|
|
$resultVBS = $this->VertragsbestandteilModel->Insert($data);
|
|
if(!isSuccess($resultVBS))
|
|
{
|
|
echo "VBS AllIn kann nicht erstellt werden -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
$vbsid = getData($resultVBS);
|
|
|
|
$data = array(
|
|
'vertragsbestandteil_id' => $vbsid,
|
|
'freitexttyp_kurzbz' => 'allin',
|
|
'titel' => $row_gehalt['bezeichnung'],
|
|
'anmerkung' => $row_gehalt['bezeichnung'],
|
|
);
|
|
$resultVBSFreitext = $this->VertragsbestandteilFreitextModel->Insert($data);
|
|
if(!isSuccess($resultVBSFreitext))
|
|
{
|
|
echo "VBS Freitext AllIn Zusatz kann nicht erstellt werden -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
}
|
|
elseif($row_gehalt['lohnart']==5500) // ATZ
|
|
{
|
|
$typ = 'lohnausgleichatz';
|
|
}
|
|
else
|
|
{
|
|
$typ = 'unbekannt - '.$row_gehalt['lohnart'];
|
|
echo "\nGehaltstyp unbekannt Lohnart: ".$row_gehalt['lohnart']." -> ROLLBACK";
|
|
$failed = true;
|
|
break;
|
|
}
|
|
|
|
// Zulage 12x und Zulage 14x aus der Bezeichnung ermitteln
|
|
if(strstr($row_gehalt['bezeichnung'], '12x'))
|
|
{
|
|
$auszahlungen = 12;
|
|
}
|
|
|
|
// Format ist 7.777,77 und wird umformattiert in 7777.77
|
|
$betrag = str_replace('.','', $row_gehalt['betrag']);
|
|
$betrag = str_replace(',','.',$betrag);
|
|
|
|
$data = array(
|
|
'dienstverhaeltnis_id' => $dvid,
|
|
'vertragsbestandteil_id' => $vbsid,
|
|
'gehaltstyp_kurzbz' => $typ,
|
|
'von' => $row_gehalt['beginn'],
|
|
'grundbetrag' => $betrag,
|
|
'betrag_valorisiert' => $betrag,
|
|
'anmerkung' => $row_gehalt['bezeichnung'],
|
|
'valorisierung' => true,
|
|
'auszahlungen' => $auszahlungen,
|
|
'insertamum' => date('Y-m-d H:i:s'),
|
|
'insertvon' => 'MigrateSalary',
|
|
'updateamum' => date('Y-m-d H:i:s'),
|
|
'updatevon' => 'MigrateSalary'
|
|
);
|
|
|
|
if (isset($row_gehalt['ende']) && $row_gehalt['ende'] != '')
|
|
{
|
|
// Im Ende steht noch der Monatserste des letzten Monats
|
|
// Das muss geaendert werden auf den Monatsletzten oder das Ende des DVs
|
|
$date = new DateTime($row_gehalt['ende']);
|
|
$date->modify('last day of this month');
|
|
$last_day_this_month = $date->format('Y-m-d');
|
|
|
|
// TODO: wenn das Dienstverhaeltnis in diesem Monat endet und nicht der Monatsletzte ist,
|
|
// dann muss hier das Ende Datum des DV stehen bzw das Ende
|
|
// oder das Ende des VBS falls die Person in der Monatsmitte Stunden wechselt
|
|
$data['bis'] = $last_day_this_month;
|
|
}
|
|
|
|
$ret = $this->GehaltsbestandteilModel->insert($data,
|
|
$this->GehaltsbestandteilModel->getEncryptedColumns()
|
|
);
|
|
}
|
|
|
|
if(!$failed)
|
|
{
|
|
$this->db->trans_commit();
|
|
}
|
|
else
|
|
{
|
|
echo "ROLLBACK";
|
|
$this->db->trans_rollback();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Prueft ob ein AllIn Vertrag vorhanden ist
|
|
*/
|
|
private function _isAllIn($dvid, $datum)
|
|
{
|
|
$db = new DB_Model();
|
|
|
|
$qry = "
|
|
SELECT
|
|
*
|
|
FROM
|
|
hr.tbl_vertragsbestandteil
|
|
JOIN hr.tbl_vertragsbestandteil_freitext USING(vertragsbestandteil_id)
|
|
WHERE
|
|
dienstverhaeltnis_id=".$db->escape($dvid)."
|
|
AND vertragsbestandteiltyp_kurzbz='freitext'
|
|
AND ".$db->escape($datum)." BETWEEN von AND COALESCE(bis, '2999-12-31')
|
|
AND freitexttyp_kurzbz='allin'";
|
|
|
|
$resultAllIn = $db->execReadOnlyQuery($qry);
|
|
|
|
if (hasData($resultAllIn))
|
|
return true;
|
|
else
|
|
return false;
|
|
}
|
|
|
|
private function _getVBS($dvid, $datum)
|
|
{
|
|
$db = new DB_Model();
|
|
|
|
$qry = "
|
|
SELECT
|
|
*
|
|
FROM
|
|
hr.tbl_vertragsbestandteil
|
|
WHERE
|
|
dienstverhaeltnis_id=".$db->escape($dvid)."
|
|
AND vertragsbestandteiltyp_kurzbz='stunden'
|
|
AND ".$db->escape($datum)." BETWEEN von AND COALESCE(bis, '2999-12-31')";
|
|
|
|
$resultVBS = $db->execReadOnlyQuery($qry);
|
|
|
|
return $resultVBS;
|
|
}
|
|
|
|
/**
|
|
* Ermittelt den User zu einer SVNR
|
|
*/
|
|
private function _getUser($svnr)
|
|
{
|
|
$db = new DB_Model();
|
|
|
|
$qry = "
|
|
SELECT
|
|
mitarbeiter_uid
|
|
FROM
|
|
public.tbl_person
|
|
JOIN public.tbl_benutzer using(person_id)
|
|
JOIN public.tbl_mitarbeiter ON(uid=mitarbeiter_uid)
|
|
WHERE
|
|
tbl_person.svnr = ". $db->escape($svnr)."
|
|
AND EXISTS(
|
|
SELECT
|
|
1
|
|
FROM
|
|
hr.tbl_dienstverhaeltnis
|
|
WHERE
|
|
mitarbeiter_uid=tbl_mitarbeiter.mitarbeiter_uid
|
|
AND oe_kurzbz=". $db->escape($this->OE_DEFAULT)."
|
|
)
|
|
ORDER BY tbl_benutzer.aktiv DESC
|
|
LIMIT 1;
|
|
";
|
|
|
|
$result = $db->execReadOnlyQuery($qry);
|
|
|
|
if (hasdata($result))
|
|
{
|
|
return $result;
|
|
}
|
|
else
|
|
return error('Kein Benutzer mit DV und SVNR:'.$svnr.' gefunden');
|
|
}
|
|
}
|