se/SE/se-lib/Route/UrlAction/JPK.php

<?php

Lib::loadClass('RouteBase');
Lib::loadClass('ProcesHelper');

class Route_UrlAction_JPK extends RouteBase {

	private $REFERER, $LAST_REFERER;
	private $JPK, $BO;
	private $NIPerrors = array();
	private $JPK_VAT_Wariant = null;
	private $tns = [
		2 => "http://jpk.mf.gov.pl/wzor/2016/10/26/10261/",
		3 => "http://jpk.mf.gov.pl/wzor/2017/11/13/1113/",
	];

	public function handleAuth() {
		if (!User::logged()) {
			throw new HttpException('Unauthorized', 401);
		}

		$this->LAST_REFERER = $_SERVER['HTTP_REFERER'];
		if (($this->REFERER=V::get('REFERER','',$_POST))=='') $this->REFERER = $_SERVER['HTTP_REFERER'];

		try {
			if (!($ID_JPK = V::get('ID_JPK',0,$_GET,'int'))) throw new Exception("Błąd parametru");
			if ($result = DB::getPDO()->fetchall("select * from JPK where ID='{$ID_JPK}'")) $this->JPK = $result[0]; 
			else throw new Exception("Dostęp zabroniony");
			if ($result = DB::getPDO()->fetchall("select * from BILLING_OWNER where ID='{$this->JPK['ID_BILLING_OWNER']}'")) $this->BO = $result[0];
			else throw new Exception("Błąd spójności danych");
			if ($this->JPK['A_STATUS'] != 'WAITING') {
				if (!$this->JPK['MONTH']) throw new Exception("Błąd daty w rekordzie JPK_VAT");
				$this->JPK_VAT_Wariant = self::getWariant($this->JPK['MONTH']);
			}
		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger',$e->getMessage());
?>
<div class="container" style="text-align:center">
  <a href="<?=$this->REFERER?>" class="btn btn-primary">Powrót</a>
</div>
<?php
			SE_Layout::dol();
			die();
		}
	}

	private static function getWariant($month) {
		$year = date("Y", strtotime($month));
		if ($year < 2018) return 2;
		else return 3;
	}

	private function initialize() {
		SE_Layout::gora();
		SE_Layout::menu();
		try {

			if (V::get('action','',$_POST) == 'initialize') {
				$month = V::get('MONTH','',$_POST);
				$purpose = V::get('PURPOSE','',$_POST);
				if (!preg_match("/^[[:digit:]]{4}-[[:digit:]]{2}$/",$month)) throw new Exception("błędny format daty (YYYY-MM)");
				switch ($purpose) {
					case "1":
						$lastMonth = DB::getPDO()->fetchValue("select max(MONTH) from JPK where ID_BILLING_OWNER='{$this->JPK['ID_BILLING_OWNER']}' and TYPE='{$this->JPK['TYPE']}'
							and ((MONTH < '2018-01' and PURPOSE='1') or (MONTH >= '2018-01' and PURPOSE = '0'))");
						if (strtotime($month) <= strtotime($lastMonth)) throw new Exception("błędny miesiąc (deklaracja z tego okresu lub późniejszego już istnieje)");
						break;
					case "2":
						$JPKexists = DB::getPDO()->fetchValue("select ID from JPK where ID_BILLING_OWNER='{$this->JPK['ID_BILLING_OWNER']}' and TYPE='{$this->JPK['TYPE']}' and MONTH='{$month}'
							and ((MONTH < '2018-01' and PURPOSE='1') or (MONTH >= '2018-01' and PURPOSE = 0))");
						if (!$JPKexists) throw new Exception("brak deklaracji z tego okresu - nie ma czego korygować");
						break;
					default:
						throw new Exception("błędne określenie celu złożenia deklaracji");
				}

				if (self::getWariant($month) > 2) {
					if ($purpose == 1) $purpose = (int) 0;
					else $purpose = DB::getPDO()->fetchValue("select max(PURPOSE) + 1 from JPK where ID_BILLING_OWNER='{$this->JPK['ID_BILLING_OWNER']}' and TYPE='{$this->JPK['TYPE']}' and MONTH='{$month}'");
				}

				$sqlObj = new stdClass();
				$sqlObj->ID = $this->JPK['ID'];
				$sqlObj->A_STATUS = 'NORMAL';
				$sqlObj->A_STATUS_INFO = 'W trakcie tworzenia';
				$sqlObj->MONTH = $month;
				$sqlObj->PURPOSE = $purpose;

				$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj);
				if ($affected) {
					SE_Layout::alert('success','Pomyślnie zainicjalizowano deklarację JPK.');
?>
<div class="container" style="text-align:center">
  <form method="post">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Edytuj</button>
    <a href="<?=$this->REFERER?>" class="btn btn-default">Powrót</a>
  </form>
</div>
<?php
				}
				else {
					SE_Layout::alert('warning','Wystąpił nieznany błąd podczas inicjalizowania deklaracji JPK.');
?>
<div class="container" style="text-align:center">
  <a href="<?=$this->REFERER?>" class="btn btn-primary">Powrót</a>
</div>
<?php
				}
			} else {
?>
<div class="container" style="margin-top:20px">
  <form class="form-horizontal" method="post">
    <legend>Inicjalizacja deklaracji JPK</legend>
    <div class="form-group">
      <label class="col-sm-3 control-label">Operator</label>
      <div class="col-sm-9" style="margin-top:7px;"><?=$this->BO['name1']?></div>
    </div>
    <div class="form-group">
      <label class="col-sm-3 control-label">Typ JPK</label>
      <div class="col-sm-9" style="margin-top:7px;"><?=$this->JPK['TYPE']?></div>
    </div>
    <div class="form-group">
      <label class="col-sm-3 control-label">Miesiąc, którego dotyczy deklaracja</label>
      <div class="col-sm-2">
	<div class="input-group">
	  <input type="text" id="MONTH" class="form-control se_type-date" name="MONTH" value="2017-01" maxlength="7"/>
	    <span class="input-group-addon">
	      <span class="glyphicon glyphicon-calendar"/>
	    </span>
	  </input>
	</div>
      </div>
    </div>
    <div class="form-group">
      <label class="col-sm-3 control-label">Cel złożenia deklaracji za dany okres</label>
      <div class="col-sm-3">
	<select class="form-control" name="PURPOSE">
	  <option value="1">Złożenie po raz pierwszy</option>
	  <option value="2">Korekta</option>
	</select>
      </div>
    </div>
    <div class="form-group">
      <div class="col-sm-offset-3 col-sm-9">
        <button type="submit" class="btn btn-primary" name="action" value="initialize">Zapisz</button>
        <a href="<?=$this->REFERER?>" class="btn btn-default">Anuluj</a>
      </div>
    </div>
  <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
  </form>
</div>
<script>
jQuery(document.getElementById('MONTH')).parent().datetimepicker({
format: 'YYYY-MM'
, locale: 'pl'
, showTodayButton: false
, minDate: '2017-01-01'
, maxDate: '<?=date("Y-m", strtotime("-1 month"))?>-28'
});
</script>
<?php
			}
		} catch (Exception $e) {
			SE_Layout::alert('danger', "Wystąpił problem z inicjalizacją deklaracji JPK - " . $e->getMessage());
?>
<div class="container" style="text-align:center">
  <a href="<?=$this->REFERER?>" class="btn btn-primary">Powrót</a>
</div>
<?php
		}
		SE_Layout::dol();	
	}

	private $fieldsDescrJPK_VAT = [
		2 => [
			"KodFormularza" => "Kod formularza",
			"WariantFormularza" => "Wariant formularza",
			"CelZlozenia" => "Cel złożenia",
			"DataWytworzeniaJPK" => "Data wytworzenia JPK",
			"DataOd" => "Data od",
			"DataDo" => "Data do",
			"DomyslnyKodWaluty" => "Waluta",
			"KodUrzedu" => "Kod urzędu skarbowego",
			"NIP" => "NIP",
			"PelnaNazwa" => "Nazwa podmiotu",
			"REGON" => "Regon",
			"KodKraju" => "Kod kraju",
			"Wojewodztwo" => "Województwo",
			"Powiat" => "Powiat",
			"Gmina" => "Gmina",
			"Miejscowosc" => "Miejscowość",
			"Ulica" => "Ulica",
			"NrDomu" => "Nr domu",
			"NrLokalu" => "Nr lokalu",
			"KodPocztowy" => "Kod pocztowy",
			"Poczta" => "Poczta",
			"LiczbaWierszySprzedazy" => "Liczba dokumentów sprzedaży",
			"PodatekNalezny" => "Podatek należny",
			"LiczbaWierszyZakupow" => "Liczba dokumentów zakupu",
			"PodatekNaliczony" => "Podatek naliczony",
		],
		3 => [
			"KodFormularza" => "Kod formularza",
			"WariantFormularza" => "Wariant formularza",
			"CelZlozenia" => "Cel złożenia",
			"DataWytworzeniaJPK" => "Data wytworzenia JPK",
			"DataOd" => "Data od",
			"DataDo" => "Data do",
			"NazwaSystemu" => "Nazwa systemu",
			"NIP" => "NIP",
			"PelnaNazwa" => "Nazwa podmiotu",
			"Email" => "Adres email",
			"LiczbaWierszySprzedazy" => "Liczba dokumentów sprzedaży",
			"PodatekNalezny" => "Podatek należny",
			"LiczbaWierszyZakupow" => "Liczba dokumentów zakupu",
			"PodatekNaliczony" => "Podatek naliczony",
		],
	];

	private static function getNamespaces($xml) {
		$ns = $xml->getNamespaces(true);
		if (!isset($ns['tns'])) {
			if (isset($ns[''])) {
				$ns['tns'] = $ns[''];
				unset($ns['']);
			} else throw new Exception('Błędna struktura namespace');
		}
		foreach ($ns as $k => $v) $xml->registerXPathNamespace($k, $v);
		return $ns;
	}

	private function showJPK_VAT($xml) {
		$ns = self::getNamespaces($xml);
		$summaryJPK_VAT = $this->getSummaryJPK_VAT($xml);

		$result['KodFormularza'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:KodFormularza')[0];
		$result['WariantFormularza'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:WariantFormularza')[0];
		$result['CelZlozenia'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:CelZlozenia')[0];
		$result['DataWytworzeniaJPK'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:DataWytworzeniaJPK')[0];
		$result['DataOd'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:DataOd')[0];
		$result['DataDo'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:DataDo')[0];
		if ($this->JPK_VAT_Wariant == 2) {
			$result['DomyslnyKodWaluty'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:DomyslnyKodWaluty')[0];
			$result['KodUrzedu'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:KodUrzedu')[0];
			$result['NIP'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:IdentyfikatorPodmiotu/etd:NIP')[0];
			$result['PelnaNazwa'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:IdentyfikatorPodmiotu/etd:PelnaNazwa')[0];
			$result['REGON'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:IdentyfikatorPodmiotu/etd:REGON')[0];
			$result['KodKraju'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:KodKraju')[0];
			$result['Wojewodztwo'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:Wojewodztwo')[0];
			$result['Powiat'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:Powiat')[0];
			$result['Gmina'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:Gmina')[0];
			$result['Ulica'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:Ulica')[0];
			$result['NrDomu'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:NrDomu')[0];
			$result['NrLokalu'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:NrLokalu')[0];
			$result['Miejscowosc'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:Miejscowosc')[0];
			$result['KodPocztowy'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:KodPocztowy')[0];
			$result['Poczta'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:AdresPodmiotu/tns:Poczta')[0];
		} elseif ($this->JPK_VAT_Wariant == 3) {
			$result['NazwaSystemu'] = $xml->xpath('/tns:JPK/tns:Naglowek/tns:NazwaSystemu')[0];
			$result['NIP'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:NIP')[0];
			$result['PelnaNazwa'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:PelnaNazwa')[0];
			$result['Email'] = $xml->xpath('/tns:JPK/tns:Podmiot1/tns:Email')[0];
		}
		$result['LiczbaWierszySprzedazy'] = $summaryJPK_VAT['LiczbaWierszySprzedazy'] ?: "";
		$result['PodatekNalezny'] = $summaryJPK_VAT['LiczbaWierszySprzedazy'] ? number_format($summaryJPK_VAT['PodatekNalezny'], 2, ',', '.'): "";
		$result['LiczbaWierszyZakupow'] = $summaryJPK_VAT['LiczbaWierszyZakupow'] ?: "";
		$result['PodatekNaliczony'] = $summaryJPK_VAT['LiczbaWierszyZakupow'] ? number_format($summaryJPK_VAT['PodatekNaliczony'], 2, ',', '.'): "";

		return $result;
	}

	private function showTable() {
?>
    <div class="form-group">
      <div class="col-sm-12">
         <table class="table table-bordered table-hover table-striped">
           <thead>
              <tr style="text-align:center; background-color:lightgray"><td width="19%"></td><td witdh="27%">Insert</td><td width="27%">L1</td><td width="27%">Dane wynikowe</td></tr>
           </thead>
           <tbody>
<?php
		if ($this->JPK['IN_INSERT']) {
			$xmlIN_INSERT = simplexml_load_string($this->JPK['IN_INSERT']);
			$IN_INSERT = $this->showJPK_VAT($xmlIN_INSERT);
		}
		if ($this->JPK['IN_L1']) {
			$xmlIN_L1 = simplexml_load_string($this->JPK['IN_L1']);
			$IN_L1 = $this->showJPK_VAT($xmlIN_L1);
		}
		if ($this->JPK['OUT_MERGED']) {
			$xmlOUT_MERGED = simplexml_load_string($this->JPK['OUT_MERGED']);
			$OUT_MERGED = $this->showJPK_VAT($xmlOUT_MERGED);
		}

		foreach ($this->fieldsDescrJPK_VAT[$this->JPK_VAT_Wariant] as $fieldKey => $fieldName) {
			echo "<tr><td>{$fieldName}</td><td>";
			if ($this->JPK['IN_INSERT']) echo $IN_INSERT[$fieldKey];
			echo "</td><td>";
			if ($this->JPK['IN_L1']) echo $IN_L1[$fieldKey];
			echo "</td><td>";
			if ($this->JPK['OUT_MERGED']) echo $OUT_MERGED[$fieldKey];
			echo "</td></tr>\n";
		}
?>
           </tbody>
         </table>
      </div>
    </div>
<?php
	}

	private function show() {
		if (V::get('action','',$_POST) == "getJPK") {
			try {
				if (!$this->JPK['OUT_MERGED']) throw new Exception("Błąd danych - nie wygenerowano wynikowego pliku JPK");
				$xml = simplexml_load_string($this->JPK['OUT_MERGED']);
				$ns = $xml->getNamespaces(true);
				$this->validateJPK_VAT($xml);
				$fileName = preg_replace("/[: \.]/", "_", "JPK_VAT_{$this->JPK['MONTH']}_" . str_replace('"', '', $xml->Podmiot1->IdentyfikatorPodmiotu->children($ns['etd'])->PelnaNazwa));
				$output = $xml->asXml();
				header("Content-Type: application/xml");
				header("Content-Disposition: attachment; filename={$fileName};");
				header("Content-Transfer-Encoding: binary");
				header("Content-Length: " . strlen($output));
				echo $output;
			} catch (Exception $e) {
				SE_Layout::gora();
				SE_Layout::menu();
				SE_Layout::alert('danger', $e->getMessage());
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
				SE_Layout::dol();
			}
		} else {
			SE_Layout::gora();
			SE_Layout::menu();
?>
<div class="container" style="margin-top:20px">
  <form class="form-horizontal" method="post" target="_blank">
    <legend>
      Podgląd deklaracjii JPK :: <?=$this->JPK['TYPE']?> - <?=$this->JPK['MONTH'] . " (" . ((($this->JPK_VAT_Wariant == 2 && $this->JPK['PURPOSE'] == 1) || ($this->JPK_VAT_Wariant == 3 && $this->JPK['PURPOSE'] === 0)) ? "pierwsze złożenie" : "korekta") . ")"?>
      <span class="pull-right">
        <?=$this->BO['name1']?>
      </span>
    </legend>
    <div class="form-group">
    <div class="form-group">
      <div class="col-sm-10">
	<button type="submit" class="btn-sm btn-primary" name="action" value="getJPK">Pobierz plik JPK</button>
      </div>
    </div>
<?=$this->showTable();?>
    <div class="form-group" style="text-align:center">
      <div class="col-sm-12">
        <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
        <a href="<?=$this->REFERER?>" class="btn btn-default">Powrót</a>
      </div>
    </div>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function edit() {
		SE_Layout::gora();
		SE_Layout::menu();
?>
<div class="container" style="margin-top:20px">
  <form class="form-horizontal" method="post" enctype="multipart/form-data">
    <legend>
      Edycja deklaracji JPK :: <?=$this->JPK['TYPE']?> - <?=$this->JPK['MONTH']." (".((($this->JPK_VAT_Wariant == 2 && $this->JPK['PURPOSE'] == 1) || ($this->JPK_VAT_Wariant == 3 && $this->JPK['PURPOSE'] === 0)) ? "pierwsze złożenie" : "korekta").")"?>
      <span class="pull-right">
        <?=$this->BO['name1']?>
      </span>
    </legend>
    <div class="form-group">
      <label class="col-sm-3 control-label"><?=($this->JPK['IN_INSERT'] ? "Usuń dane zaimportowane" : "Dodaj plik JPK")?> z pakietu Insert</label>
<?php
		if ($this->JPK['IN_INSERT']) {
?>
      <div class="col-sm-9" style="margin-top:3px;">
	<button type="submit" class="btn-xs btn-default" name="action" value="delete_insert_jpk">Usuń</button>
      </div>
<?php
		} else {
?>
      <div class="col-sm-9" style="margin-top:7px;">
	<input type="hidden" name="action" value="upload_insert_jpk"/>
	<input type="file" name="IN_INSERT" onchange="javascript:this.form.submit();"/>
      </div>
<?php
		}
?>
    </div>
    <div class="form-group">
      <label class="col-sm-3 control-label"><?=($this->JPK['IN_L1'] ? "Usuń" : "Pobierz")?> dane z L1</label>
      <div class="col-sm-9" style="margin-top:3px;">
	<button type="submit" class="btn-xs btn-default" name="action" value=<?=($this->JPK['IN_L1'] ? '"delete_l1_jpk">Usuń' : '"import_l1_jpk">Pobierz')?></button>
      </div>
    </div>
<?php
		if (!($this->JPK['IN_INSERT'] || $this->JPK['IN_L1'])) {
?>
    <div class="form-group">
      <label class="col-sm-3 control-label">Reinicjalizuj deklarację</label>
      <div class="col-sm-9" style="margin-top:3px;">
        <button type="submit" class="btn-xs btn-default" name="action" value="reinitialize">Reinicjalizuj</button>
      </div>
    </div>
<?php
		}
		if ($this->JPK['IN_INSERT'] && $this->JPK['IN_L1'] && (!$this->JPK['OUT_MERGED'])) {
?>
    <div class="form-group">
      <label class="col-sm-3 control-label">Importuj dane podmiotu z</label>
      <div class="col-sm-9" style="margin-top:3px;">
	<input type="radio" name="SRC_PODMIOT" value="Insert" checked> Insert<br/>
	<input type="radio" name="SRC_PODMIOT" value="L1"> L1
      </div>
    </div>
    <div class="form-group">
      <label class="col-sm-3 control-label">Generuj deklarację wynikową</label>
      <div class="col-sm-9" style="margin-top:3px;">
        <button type="submit" class="btn-xs btn-default" name="action" value="generate_merged_jpk">Generuj</button>
      </div>
    </div>
<?php
		}
		if ($this->JPK['OUT_MERGED']) {
?>
    <div class="form-group">
      <label class="col-sm-3 control-label">Zamknij deklarację JPK</label>
      <div class="col-sm-9" style="margin-top:3px;">
        <button type="submit" class="btn-xs btn-default" name="action" value="close_jpk">Zamknij</button>
	<p class="help-block">(tej operacji nie można cofnąć)</p>
      </div>
    </div>
<?php
		}
?>
<?=$this->showTable()?>
    <div class="form-group" style="text-align:center">
      <div class="col-sm-12">
	<input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
	<input type="hidden" name="_task" value="edit">
        <a href="<?=$this->REFERER?>" class="btn btn-primary">Powrót</a>
      </div>
    </div>
  </form>
</div>
<?php
		SE_Layout::dol();
	}

	public function editAction() {
		$allowedActions = array("upload_insert_jpk", "delete_insert_jpk", "import_l1_jpk", "delete_l1_jpk", "generate_merged_jpk", "close_jpk", "reinitialize");

		if (in_array(($action = V::get('action','',$_POST)), $allowedActions)) $this->$action();
		else {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', "Wykryto abuse! Wysłano informację do administratora.");
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function getSummaryJPK_VAT($xml) {
		$ns = $xml->getNamespaces(true);
		$tns = $this->tns[$this->JPK_VAT_Wariant];
		if (array_search($tns, $ns) === false) throw new Exception("Błąd struktury pliku XML - błędny namespace");

		$PodatekNaleznyFields = array("K_16" => "1", "K_18" => "1", "K_20" => "1", "K_24" => "1", "K_26" => "1", "K_28" => "1",
			"K_30" => "1", "K_33" => "1", "K_35" => "1", "K_36" => "1", "K_37" => "1", "K_38" => "-1", "K_39" => "-1");
		$PodatekNaliczonyFields = array("K_44" => 1, "K_46" => 1, "K_47" => 1, "K_48" => 1, "K_49" => 1, "K_50" => 1);

		$result = array(
			"LiczbaWierszySprzedazy" => 0,
			"PodatekNalezny" => 0,
			"LiczbaWierszyZakupow" => 0,
			"PodatekNaliczony" => 0);

		foreach ($xml->children($tns)->SprzedazWiersz as $SprzedazWiersz) {
			foreach ($PodatekNaleznyFields as $PodatekNaleznyField => $sign) {
				if (isset($SprzedazWiersz->children($tns)->$PodatekNaleznyField)) {
					$result["PodatekNalezny"] += round((float) $SprzedazWiersz->children($tns)->$PodatekNaleznyField * $sign, 2);
				}
			}
			$result["LiczbaWierszySprzedazy"]++;
		}

		foreach ($xml->children($tns)->ZakupWiersz as $ZakupWiersz) {
			foreach ($PodatekNaliczonyFields as $PodatekNaliczonyField => $sign) {
				if (isset($ZakupWiersz->children($tns)->$PodatekNaliczonyField)) {
					$result["PodatekNaliczony"] += round((float) $ZakupWiersz->children($tns)->$PodatekNaliczonyField * $sign, 2);
				}
			}
			$result["LiczbaWierszyZakupow"]++;
		}

		$result["PodatekNalezny"] = round($result["PodatekNalezny"], 2);
		$result["PodatekNaliczony"] = round($result["PodatekNaliczony"], 2);
		return $result;
	}

	private function validateJPK_VAT(&$xml) {
		$ns = self::getNamespaces($xml);

		if ($xml->xpath('/tns:JPK/tns:Naglowek/tns:KodFormularza')[0] != "JPK_VAT") throw new Exception("Błędny typ deklaracji JPK");
		if ($xml->xpath('/tns:JPK/tns:Naglowek/tns:WariantFormularza')[0] != $this->JPK_VAT_Wariant) throw new Exception("Błędna wersja deklaracji JPK");
		if ($this->JPK_VAT_Wariant == 2) {
			if ($xml->xpath('/tns:JPK/tns:Naglowek/tns:CelZlozenia')[0] != $this->JPK['PURPOSE']) throw new Exception("Niezgodny cel złożenia deklaracji JPK");
		} elseif ($this->JPK_VAT_Wariant == 3) {
			if (((int) $xml->xpath('/tns:JPK/tns:Naglowek/tns:CelZlozenia')[0]) xor ((int) $this->JPK['PURPOSE'])) throw new Exception("Niezgodny cel złożenia deklaracji JPK");
		}
		if ($xml->xpath('/tns:JPK/tns:Naglowek/tns:DataOd')[0] != ($this->JPK['MONTH'] . "-01")) throw new Exception("Błędna data 'od' deklaracji JPK");
		if ($xml->xpath('/tns:JPK/tns:Naglowek/tns:DataDo')[0] != date("Y-m-d", strtotime($xml->xpath('/tns:JPK/tns:Naglowek/tns:DataOd')[0] . " + 1 month - 1 day"))) throw new Exception("Błędna data 'do' deklaracji JPK");
		if ($this->JPK_VAT_Wariant == 2) {
			if  ($xml->xpath('/tns:JPK/tns:Naglowek/tns:DomyslnyKodWaluty')[0] != "PLN") throw new Exception("Błędna waluta deklaracji JPK");
			if (trim(str_replace('-', '', $xml->xpath('/tns:JPK/tns:Podmiot1/tns:IdentyfikatorPodmiotu/etd:NIP')[0])) != trim(str_replace('-', '', $this->BO['nip']))) throw new Exception("Niezgodny NIP podmiotu w deklaracji JPK");
		} elseif ($this->JPK_VAT_Wariant == 3) {
			if (trim(str_replace('-', '', $xml->xpath('/tns:JPK/tns:Podmiot1/tns:NIP')[0])) != trim(str_replace('-', '', $this->BO['nip']))) throw new Exception("Niezgodny NIP podmiotu w deklaracji JPK");
			if (!$xml->Podmiot1->Email) unset($xml->Podmiot1->Email);
		}
		$summaryJPK_VAT = $this->getSummaryJPK_VAT($xml);
		if ($summaryJPK_VAT["LiczbaWierszySprzedazy"]) {
			if ($xml->xpath('/tns:JPK/tns:SprzedazCtrl/tns:LiczbaWierszySprzedazy')[0] != $summaryJPK_VAT["LiczbaWierszySprzedazy"]) throw new Exception("Brak spójności liczby wierszy sprzedaży w deklaracji JPK");
			if (((float) $xml->xpath('/tns:JPK/tns:SprzedazCtrl/tns:PodatekNalezny')[0]) != $summaryJPK_VAT["PodatekNalezny"]) throw new Exception("Brak spójności wartości podatku należnego w deklaracji JPK");
		}
		if ($summaryJPK_VAT["LiczbaWierszyZakupow"]) {
			if ($xml->xpath('/tns:JPK/tns:ZakupCtrl/tns:LiczbaWierszyZakupow')[0] != $summaryJPK_VAT["LiczbaWierszyZakupow"]) throw new Exception("Brak spójności liczby wierszy zakupów w deklaracji JPK");
			if (((float) $xml->xpath('/tns:JPK/tns:ZakupCtrl/tns:PodatekNaliczony')[0]) != $summaryJPK_VAT["PodatekNaliczony"]) throw new Exception("Brak spójności wartości podatku naliczonego w deklaracji JPK");
		}

		set_error_handler(function ($errno, $errstr, $errfile, $errline) {
			if ($errno==E_WARNING && (substr_count($errstr,"DOMDocument::loadXML()")>0)) throw new DOMException($errstr);
			else return false;
		});

		try {
			$dom = new DOMDocument();
			$dom->preserveWhiteSpace = false;
			$dom->formatOutput = true;
			$dom->loadXML($xml->asXML());
		} catch (Exception $e) {
			throw new Exception("Błąd parsowania pliku JPK");
		}

		restore_error_handler();

		$xsd = [
			2 => 'Schemat_JPK_VAT(2)_v1-0.xsd',
			3 => 'Schemat_JPK_VAT(3)_v1-1.xsd',
		];

		libxml_use_internal_errors(true);
		if (!$dom->schemaValidate(APP_PATH_SCHEMA . "/jpk/" . $xsd[$this->JPK_VAT_Wariant])) {
			$errors = '';
			foreach (libxml_get_errors() as $libxml_error) $errors .= "<br/>{$libxml_error->message}";
			throw new Exception("Plik JPK niezgodny ze schematem XSD{$errors}<pre>" . htmlentities($dom->saveXML()) . "</pre>");
		}

		$xml = simplexml_load_string($dom->saveXML());
	}

	private function upload_insert_jpk() {
		try {
			if ($_FILES['IN_INSERT']['type'] != "text/xml") throw new Exception("Błędny plik JPK");
			$xml = simplexml_load_file($_FILES['IN_INSERT']['tmp_name']);
			$this->validateJPK_VAT($xml);

			if ($this->JPK['IN_L1']) $info = "Zaimportowano dane z Insert i L1";
			else $info = "Zaimportowano dane z Insert";

			$sqlObj = new stdClass();
			$sqlObj->ID = $this->JPK['ID'];
			$sqlObj->A_STATUS_INFO = $info;
			$sqlObj->IN_INSERT = $xml->asXml();
			if (!$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj)) throw new Exception("Wystąpił błąd, prawdopodobnie Ten plik JPK został wgrany już wcześniej");
			$this->handleAuth();
			$this->edit();
		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', $e->getMessage());
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function delete_insert_jpk() {
		try {
			$info = "Usunięto dane z Insert";
			if ($this->JPK['IN_L1']) $info .= " (pozostawiono dane z L1)";

			$sqlObj = new stdClass();
			$sqlObj->ID = $this->JPK['ID'];
			$sqlObj->A_STATUS_INFO = $info;
			$sqlObj->IN_INSERT = null;
			$sqlObj->OUT_MERGED = null;
			if (!$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj)) throw new Exception("Wystąpił nieznany błąd");
			$this->handleAuth();
			$this->edit();
		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', $e->getMessage());
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function validateNIP($nip_orig, $name, $type) {
		$nip = str_replace("-", "", trim($nip_orig));
		$error = false;
		if ($nip == "" || $nip == "Brak") return true;

		$prefix = substr($nip, 0, 2);
		if (!is_numeric($prefix)) $nip = substr($nip, 2);
		else $prefix = null;

		if ($prefix && $prefix != "PL") return true;
		if (strlen($nip) != 10 || (!is_numeric($nip))) $error = true;
		else {
			$control = (($nip[0] * 6 + $nip[1] * 5 + $nip[2] * 7 + $nip[3] * 2 + $nip[4] * 3 + $nip[5] * 4 + $nip[6] * 5 + $nip[7] * 6 + $nip[8] * 7) % 11 ) % 10;
			$error = ($control != $nip[9]);
		}
		if ($error) {
			$this->NIPerrors[] = "NIP: {$nip_orig}, nazwa: {$name}, rodzaj dokumentu: {$type}";
			return false;
		}
		return true;
	}

	private function import_l1_jpk() {

		$xmlSchemaWarianty = [];
		$xmlSchemaWarianty[2] = <<<EOT
<?xml version="1.0" encoding="UTF-8" standalone="no" ?>
<JPK xmlns="{$this->tns[$this->JPK_VAT_Wariant]}" xmlns:etd="http://crd.gov.pl/xml/schematy/dziedzinowe/mf/2016/01/25/eD/DefinicjeTypy/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <Naglowek>
    <KodFormularza kodSystemowy="JPK_VAT (2)" wersjaSchemy="1-0">JPK_VAT</KodFormularza>
    <WariantFormularza>2</WariantFormularza>
    <CelZlozenia></CelZlozenia>
    <DataWytworzeniaJPK></DataWytworzeniaJPK>
    <DataOd></DataOd>
    <DataDo></DataDo>
    <DomyslnyKodWaluty>PLN</DomyslnyKodWaluty>
    <KodUrzedu></KodUrzedu>
  </Naglowek>
  <Podmiot1>
    <IdentyfikatorPodmiotu>
      <etd:NIP></etd:NIP>
      <etd:PelnaNazwa></etd:PelnaNazwa>
      <etd:REGON></etd:REGON>
    </IdentyfikatorPodmiotu>
    <AdresPodmiotu>
      <KodKraju></KodKraju>
      <Wojewodztwo></Wojewodztwo>
      <Powiat></Powiat>
      <Gmina></Gmina>
      <Ulica></Ulica>
      <NrDomu></NrDomu>
      <NrLokalu></NrLokalu>
      <Miejscowosc></Miejscowosc>
      <KodPocztowy></KodPocztowy>
      <Poczta></Poczta>
    </AdresPodmiotu>
  </Podmiot1>
</JPK>
EOT;

		$xmlSchemaWarianty[3] = <<<EOT
<?xml version="1.0" encoding="UTF-8" standalone="no" ?>
<JPK xmlns="{$this->tns[$this->JPK_VAT_Wariant]}" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <Naglowek>
    <KodFormularza kodSystemowy="JPK_VAT (3)" wersjaSchemy="1-1">JPK_VAT</KodFormularza>
    <WariantFormularza>3</WariantFormularza>
    <CelZlozenia></CelZlozenia>
    <DataWytworzeniaJPK></DataWytworzeniaJPK>
    <DataOd></DataOd>
    <DataDo></DataDo>
    <NazwaSystemu>Procesy5</NazwaSystemu>
  </Naglowek>
  <Podmiot1>
    <NIP></NIP>
    <PelnaNazwa></PelnaNazwa>
    <Email></Email>
  </Podmiot1>
</JPK>
EOT;

		$xmlSchema = $xmlSchemaWarianty[$this->JPK_VAT_Wariant];

		$queryFVAT = <<<EOT
select
bn.ID as BN_ID,
if (bu.TAXPAYER_ID_BILLING_USERS > 0, concat(bua_tp.P_NAME, if(bua_tp.P_NAME_SECOND='','',concat(' ',bua_tp.P_NAME_SECOND))), concat(bua.P_NAME, if(bua.P_NAME_SECOND='','',concat(' ',bua.P_NAME_SECOND)))) AS NazwaKontrahenta,
if (bu.TAXPAYER_ID_BILLING_USERS > 0, concat(bua_tp.P_ADDRESS_STREET,' ',bua_tp.P_ADDRESS_HOUSE, if(bua_tp.P_ADDRESS_HOME='','',concat('/',bua_tp.P_ADDRESS_HOME)),', ',bua_tp.P_ADDRESS_POST_CODE,' ',bua_tp.P_ADDRESS_CITY), concat(bua.P_ADDRESS_STREET,' ',bua.P_ADDRESS_HOUSE, if(bua.P_ADDRESS_HOME='','',concat('/',bua.P_ADDRESS_HOME)),', ',bua.P_ADDRESS_POST_CODE,' ',bua.P_ADDRESS_CITY)) AS AdresKontrahenta,
bf.SELL_DATE AS 'DataWystawienia',
concat(bn.NUMBER,'/',bn.ID_BILLING_PREFIXES) AS 'DowodSprzedazy',
if (bu.TAXPAYER_ID_BILLING_USERS > 0, if(bua_tp.is_firma=0,'Brak',coalesce(bua_tp.P_NIP,'')), if(bua.is_firma=0,'Brak',coalesce(bua.P_NIP,''))) AS 'NrKontrahenta',
round(bfp.AMMOUNT * bfp.PRICE, 2) as Netto,
round(round(bfp.AMMOUNT * bfp.PRICE, 2) * bfp.VAT/100, 2) as VAT,
bfp.VAT_NAME as 'VAT_NAME'
from BILLING_NUMBERS bn
join BILLS_FVAT bf on bn.ID=bf.ID_BILLING_NUMBERS
join BILLS_FVAT_POS bfp on bf.ID=bfp.ID_BILLS_FVAT
join BILLING_USERS_ADD bua on bua.id_users=bn.ID_BILLING_USERS
join BILLING_USERS bu on bu.ID=bn.ID_BILLING_USERS
left join BILLING_USERS_ADD bua_tp on bu.TAXPAYER_ID_BILLING_USERS = bua_tp.id_users
where bn.ID_BILLING_NUMBERS_TYPE='1' and bf.BILL_DATE like '{$this->JPK['MONTH']}%'
and bu.BILLING_OWNER='{$this->BO['ID']}'
order by bf.BILL_DATE,bn.ID
EOT;

		$queryKORV = <<<EOT
select
bn.ID AS BN_ID,
concat(bua.P_NAME, if(bua.P_NAME_SECOND='','',concat(' ',bua.P_NAME_SECOND))) AS NazwaKontrahenta,
concat(bua.P_ADDRESS_STREET,' ',bua.P_ADDRESS_HOUSE, if(bua.P_ADDRESS_HOME='','',concat('/',bua.P_ADDRESS_HOME)),', ',P_ADDRESS_POST_CODE,' ',P_ADDRESS_CITY) AS AdresKontrahenta,
bk.BILL_DATE AS 'DataWystawienia',
bk.SELL_DATE AS 'DataSprzedazy',
concat(bn.NUMBER,'/',bn.ID_BILLING_PREFIXES) AS 'DowodSprzedazy',
if(is_firma=0,'Brak',coalesce(bua.P_NIP,'')) AS 'NrKontrahenta',
bkp.AMMOUNT AS AMMOUNT,
bkp.PRICE AS PRICE,
bkp.VAT AS VAT,
bkp.VAT_NAME AS VAT_NAME,
bkp.N_AMMOUNT AS N_AMMOUNT,
bkp.N_PRICE AS N_PRICE,
bkp.N_VAT AS N_VAT,
bkp.N_VAT_NAME AS N_VAT_NAME,
bkp.TYP_KOREKTY AS TYP_KOREKTY
from BILLING_NUMBERS bn
join BILLS_KORV bk on bn.ID=bk.ID_BILLING_NUMBERS
join BILLS_KORV_POS bkp on bk.ID=bkp.ID_BILLS_FVAT
join BILLING_USERS_ADD bua on bua.id_users=bn.ID_BILLING_USERS
join BILLING_USERS bu on bu.ID=bn.ID_BILLING_USERS
where bn.ID_BILLING_NUMBERS_TYPE='3'
and bk.BILL_DATE like '{$this->JPK['MONTH']}%'
and bkp.TYP_KOREKTY IS NOT NULL
and bu.BILLING_OWNER='{$this->BO['ID']}'
order by bk.BILL_DATE,bn.ID
EOT;

		$xmlVAT = [
			'ZW' => ['netto' => ['K_10']],
			'0' => ['netto' => ['K_13']],
			'7' => ['netto' => ['K_17'], 'vat' => 'K_18'],
			'8' => ['netto' => ['K_17'], 'vat' => 'K_18'],
			'22' => ['netto' => ['K_19'], 'vat' => 'K_20'],
			'23' => ['netto' => ['K_19'], 'vat' => 'K_20'],
			'OO UE' => ['netto' => ['K_11', 'K_12']],
		];

		try {
			if (DB::getPDO(931)->fetchValue("select sum(c) from (select count(*) as c from BILLS_FVAT where OPEN='y' union select count(*) as c from BILLS_KORV where OPEN='y') as c;")) {
				throw new Exception("wykryto niezamknięte faktury lub korekty faktur");
			}

			$xml = new SimpleXMLElement($xmlSchema);
			$ns = $xml->getNamespaces(true);

			$xml->Naglowek->CelZlozenia = $this->JPK['PURPOSE'];
			$xml->Naglowek->DataWytworzeniaJPK = date("Y-m-d\TH:i:s");
			$xml->Naglowek->DataOd = $this->JPK['MONTH'] . "-01";
			$xml->Naglowek->DataDo = date("Y-m-d", strtotime($xml->Naglowek->DataOd . "+ 1 month - 1 day"));
			if ($this->JPK_VAT_Wariant == 2) {
				if (!($xml->Naglowek->KodUrzedu = $this->BO['kodUrzeduSkarbowego'])) throw new Exception("blędne dane podmiotu - brak kodu urzędu skarbowego");
				if (!($xml->Podmiot1->IdentyfikatorPodmiotu->children($ns['etd'])->NIP = trim(str_replace("-", "", $this->BO['nip'])))) throw new Exception("blędne dane podmiotu - brak NIP");
				if (!($xml->Podmiot1->IdentyfikatorPodmiotu->children($ns['etd'])->PelnaNazwa = $this->BO['name1'])) throw new Exception("blędne dane podmiotu - brak nazwy podmiotu");
				if ($this->BO['name2']) $xml->Podmiot1->IdentyfikatorPodmiotu->children($ns['etd'])->PelnaNazwa .= " " . $this->BO['name2'];
				if (!($xml->Podmiot1->IdentyfikatorPodmiotu->children($ns['etd'])->REGON = $this->BO['regon'])) unset($xml->Podmiot1->IdentyfikatorPodmiotu->children($ns['etd'])->REGON);
				if (!($xml->Podmiot1->AdresPodmiotu->KodKraju = $this->BO['kodKraju'])) throw new Exception("blędne dane podmiotu - brak kodu kraju");
				if (!($xml->Podmiot1->AdresPodmiotu->Wojewodztwo = $this->BO['wojewodztwo'])) unset($xml->Podmiot1->AdresPodmiotu->Wojewodztwo);
				if (!($xml->Podmiot1->AdresPodmiotu->Powiat = $this->BO['powiat'])) unset($xml->Podmiot1->AdresPodmiotu->Powiat);
				if (!($xml->Podmiot1->AdresPodmiotu->Gmina = $this->BO['gmina'])) unset($xml->Podmiot1->AdresPodmiotu->Gmina);
				if (!($xml->Podmiot1->AdresPodmiotu->Ulica = $this->BO['ulica'])) unset($xml->Podmiot1->AdresPodmiotu->Ulica);
				if (!($xml->Podmiot1->AdresPodmiotu->NrDomu = $this->BO['numer_dom'])) unset($xml->Podmiot1->AdresPodmiotu->NrDomu);
				if (!($xml->Podmiot1->AdresPodmiotu->NrLokalu = $this->BO['numer_pos'])) unset($xml->Podmiot1->AdresPodmiotu->NrLokalu);
				if (!($xml->Podmiot1->AdresPodmiotu->Miejscowosc = $this->BO['miasto'])) throw new Exception("blędne dane podmiotu - brak nazwy miejscowości");
				if (!($xml->Podmiot1->AdresPodmiotu->KodPocztowy = $this->BO['kod'])) unset($xml->Podmiot1->AdresPodmiotu->KodPocztowy);
				if (!($xml->Podmiot1->AdresPodmiotu->Poczta = $this->BO['poczta'])) unset($xml->Podmiot1->AdresPodmiotu->Poczta);
			} elseif ($this->JPK_VAT_Wariant == 3) {
				if (!($xml->Podmiot1->NIP = trim(str_replace("-", "", $this->BO['nip'])))) throw new Exception("blędne dane podmiotu - brak NIP");
				if (!($xml->Podmiot1->PelnaNazwa = $this->BO['name1'])) throw new Exception("blędne dane podmiotu - brak nazwy podmiotu");
				$mailRegex = '/^(?!(?:(?:\x22?\x5C[\x00-\x7E]\x22?)|(?:\x22?[^\x5C\x22]\x22?)){255,})(?!(?:(?:\x22?\x5C[\x00-\x7E]\x22?)|(?:\x22?[^\x5C\x22]\x22?)){65,}@)(?:(?:[\x21\x23-\x27\x2A\x2B\x2D\x2F-\x39\x3D\x3F\x5E-\x7E]+)|(?:\x22(?:[\x01-\x08\x0B\x0C\x0E-\x1F\x21\x23-\x5B\x5D-\x7F]|(?:\x5C[\x00-\x7F]))*\x22))(?:\.(?:(?:[\x21\x23-\x27\x2A\x2B\x2D\x2F-\x39\x3D\x3F\x5E-\x7E]+)|(?:\x22(?:[\x01-\x08\x0B\x0C\x0E-\x1F\x21\x23-\x5B\x5D-\x7F]|(?:\x5C[\x00-\x7F]))*\x22)))*@(?:(?:(?!.*[^.]{64,})(?:(?:(?:xn--)?[a-z0-9]+(?:-[a-z0-9]+)*\.){1,126}){1,}(?:(?:[a-z][a-z0-9]*)|(?:(?:xn--)[a-z0-9]+))(?:-[a-z0-9]+)*)|(?:\[(?:(?:IPv6:(?:(?:[a-f0-9]{1,4}(?::[a-f0-9]{1,4}){7})|(?:(?!(?:.*[a-f0-9][:\]]){7,})(?:[a-f0-9]{1,4}(?::[a-f0-9]{1,4}){0,5})?::(?:[a-f0-9]{1,4}(?::[a-f0-9]{1,4}){0,5})?)))|(?:(?:IPv6:(?:(?:[a-f0-9]{1,4}(?::[a-f0-9]{1,4}){5}:)|(?:(?!(?:.*[a-f0-9]:){5,})(?:[a-f0-9]{1,4}(?::[a-f0-9]{1,4}){0,3})?::(?:[a-f0-9]{1,4}(?::[a-f0-9]{1,4}){0,3}:)?)))?(?:(?:25[0-5])|(?:2[0-4][0-9])|(?:1[0-9]{2})|(?:[1-9]?[0-9]))(?:\.(?:(?:25[0-5])|(?:2[0-4][0-9])|(?:1[0-9]{2})|(?:[1-9]?[0-9]))){3}))\]))$/iD';
				if (preg_match($mailRegex, $this->BO['BILLING_OWNER_EMAIL'])) $xml->Podmiot1->Email = $this->BO['BILLING_OWNER_EMAIL'];
				else unset($xml->Podmiot1->Email);
			}

			$data = array();
			$allVAT = 0;

			$result = DB::getPDO(931)->fetchall($queryFVAT);
			foreach ($result as $row) {
				$data[$row['BN_ID']][0]['NrKontrahenta'] = trim(str_replace("-", "", $row['NrKontrahenta']));
				$data[$row['BN_ID']][0]['NazwaKontrahenta'] = $row['NazwaKontrahenta'];
				$data[$row['BN_ID']][0]['AdresKontrahenta'] = $row['AdresKontrahenta'];
				$data[$row['BN_ID']][0]['DowodSprzedazy'] = $row['DowodSprzedazy'];
				$data[$row['BN_ID']][0]['DataWystawienia'] = $row['DataWystawienia'];
				if (!in_array($row['VAT_NAME'],array_keys($xmlVAT))) throw new Exception("Problem ze stawką VAT (1) - {$row['VAT_NAME']}");
				foreach ($xmlVAT[$row['VAT_NAME']]['netto'] as $netto) $data[$row['BN_ID']][1][$netto] += $row['Netto'];
				if ($row['VAT'] > 0) {
					if (!isset($xmlVAT[$row['VAT_NAME']]['vat'])) throw new Exception("Problem ze stawką VAT (2) - {$row['VAT_NAME']}");
					$data[$row['BN_ID']][1][$xmlVAT[$row['VAT_NAME']]['vat']] += $row['VAT'];
					$allVAT += $row['VAT'];
				}
			}

			$result = DB::getPDO(931)->fetchall($queryKORV);
			foreach ($result as $row) {
				$data[$row['BN_ID']][0]['NrKontrahenta'] = trim(str_replace("-", "", $row['NrKontrahenta']));
				$data[$row['BN_ID']][0]['NazwaKontrahenta'] = $row['NazwaKontrahenta'];
				$data[$row['BN_ID']][0]['AdresKontrahenta'] = $row['AdresKontrahenta'];
				$data[$row['BN_ID']][0]['DowodSprzedazy'] = $row['DowodSprzedazy'];
				$data[$row['BN_ID']][0]['DataWystawienia'] = $row['DataWystawienia'];
				$data[$row['BN_ID']][0]['DataSprzedazy'] = $row['DataSprzedazy'];
				if (!(in_array($row['VAT_NAME'], array_keys($xmlVAT)) && in_array($row['N_VAT_NAME'], array_keys($xmlVAT)))) throw new Exception("Problem ze stawką VAT (3) - {$row['VAT_NAME']}");
				if ((($row['VAT'] > 0) && !(isset($xmlVAT[$row['VAT_NAME']]['vat']))) || (($row['N_VAT'] > 0) && !(isset($xmlVAT[$row['N_VAT_NAME']]['vat'])))) throw new Exception("Problem ze stawką VAT (4) - {$row['VAT_NAME']}");
				if ($row['VAT_NAME'] == $row['N_VAT_NAME']) {
					foreach ($xmlVAT[$row['VAT_NAME']]['netto'] as $netto) $data[$row['BN_ID']][1][$netto] += round($row['AMMOUNT']*$row['PRICE'],2);
					if ($row['VAT'] > 0) {
						$data[$row['BN_ID']][1][$xmlVAT[$row['VAT_NAME']]['vat']] += round(round($row['AMMOUNT']*$row['PRICE'],2)*$row['VAT']/100,2);
						$allVAT += round(round($row['AMMOUNT']*$row['PRICE'],2)*$row['VAT']/100,2);
					}
				} else {
					foreach ($xmlVAT[$row['VAT_NAME']]['netto'] as $netto) $data[$row['BN_ID']][1][$netto] += round($row['N_AMMOUNT']*$row['N_PRICE'],2) + round($row['AMMOUNT']*$row['PRICE'],2);
					foreach ($xmlVAT[$row['N_VAT_NAME']]['netto'] as $netto) $data[$row['BN_ID']][1][$netto] -= round($row['N_AMMOUNT']*$row['N_PRICE'],2);
					if ($row['VAT'] > 0) {
						$data[$row['BN_ID']][1][$xmlVAT[$row['VAT_NAME']]['vat']] += round(round($row['N_AMMOUNT']*$row['N_PRICE'],2)*$row['VAT']/100,2)
							+ round(round($row['AMMOUNT']*$row['PRICE'],2)*$row['VAT']/100,2);
						$allVAT += round(round($row['N_AMMOUNT']*$row['N_PRICE'],2)*$row['VAT']/100,2) + round(round($row['AMMOUNT']*$row['PRICE'],2)*$row['VAT']/100,2);
					}
					if ($row['N_VAT'] > 0) {
						$data[$row['BN_ID']][1][$xmlVAT[$row['N_VAT_NAME']]['vat']] -= round(round($row['N_AMMOUNT']*$row['N_PRICE'],2)*$row['N_VAT']/100,2);
						$allVAT -= round(round($row['N_AMMOUNT']*$row['N_PRICE'],2)*$row['N_VAT']/100,2);
					}
				}
			}

			ksort($data);

			$addCdata = function(&$node, $value) {
				$dom_node = dom_import_simplexml($node);
				$dom_owner = $dom_node->ownerDocument;
				$dom_node->appendChild($dom_owner->createCDATASection($value));
			};

			$i = 0;
			foreach ($data as $pos) {
				$this->validateNIP($pos[0]['NrKontrahenta'], $pos[0]['NazwaKontrahenta'], 'Sprzedaż L1');
				$x = $xml->addChild('SprzedazWiersz');
				if ($this->JPK_VAT_Wariant == 2) $x->addAttribute('typ', 'G');
				$x->addChild('LpSprzedazy', ++$i);
				ksort($pos[1]);
				foreach ($pos as $subpos) foreach ($subpos as $key => $value) {
					$x->addChild($key, $value);
					if (!strlen($x->$key)) $addCdata($x->$key, $value);
				}
			}
			if ($this->NIPerrors) throw new Exception("Błędne numery NIP:<br/>" . implode("<br/>", $this->NIPerrors));

			$xml->SprzedazCtrl->LiczbaWierszySprzedazy = count($data);
			$xml->SprzedazCtrl->PodatekNalezny = $allVAT;

			$this->validateJPK_VAT($xml);

			if ($this->JPK['IN_INSERT']) $info = "Zaimportowano dane z Insert i L1";
			else $info = "Zaimportowano dane z L1";
			$sqlObj = new stdClass();
			$sqlObj->ID = $this->JPK['ID'];
			$sqlObj->A_STATUS_INFO = $info;
			$sqlObj->IN_L1 = $xml->asXml();
			if (!$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj)) throw new Exception("Wystąpił nieznany błąd bazy danych");
			$this->handleAuth();
			$this->edit();
		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', "Błąd w trakcie importu danych z L1. {$e->getMessage()}");
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function delete_l1_jpk() {
		try {
			$info = "Usunięto dane z L1";
			if ($this->JPK['IN_INSERT']) $info .= " (pozostawiono dane z Insert)";

			$sqlObj = new stdClass();
			$sqlObj->ID = $this->JPK['ID'];
			$sqlObj->A_STATUS_INFO = $info;
			$sqlObj->IN_L1 = null;
			$sqlObj->OUT_MERGED = null;
			if (!$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj)) throw new Exception("Wystąpił nieznany błąd");
			$this->handleAuth();
			$this->edit();
		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', $e->getMessage());
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private static function removeTnsNamespace(&$xml) {
		$ns = $xml->getNamespaces(true);
		if (isset($ns[''])) return;
		if ((!isset($ns['tns']) || isset($ns['xsi']))) throw new Exception("Błędna struktura pliku XML - błędne namespace");

		$dom = dom_import_simplexml($xml);
		$ns_uri = $dom->lookupNamespaceURI('tns');
		$dom->removeAttributeNS($ns_uri, 'tns');
		$xml->addAttribute('xmlns', $ns['tns']);
		$xml->addAttribute('xmlns:xmlns:xsi', 'http://www.w3.org/2001/XMLSchema-instance');
		$xml = simplexml_load_string($xml->asXML());
	}

	private function generate_merged_jpk() {

		$xmlSchemaWariant = [];
		$xmlSchemaWariant[2] = <<<EOT
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<JPK xmlns="{$this->tns[$this->JPK_VAT_Wariant]}" xmlns:etd="http://crd.gov.pl/xml/schematy/dziedzinowe/mf/2016/01/25/eD/DefinicjeTypy/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
</JPK>
EOT;
		$xmlSchemaWariant[3] = <<<EOT
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<JPK xmlns="{$this->tns[$this->JPK_VAT_Wariant]}" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
</JPK>
EOT;
		$xmlSchema = $xmlSchemaWariant[$this->JPK_VAT_Wariant];

		$xml_append = function(SimpleXMLElement $to, SimpleXMLElement $from) {
			$toDom = dom_import_simplexml($to);
			$fromDom = dom_import_simplexml($from);
			$toDom->appendChild($toDom->ownerDocument->importNode($fromDom, true));
		};

		try {
			if (!($this->JPK['IN_INSERT'] && $this->JPK['IN_L1'])) throw new Exception("Błąd danych");

			$xmlInsert = simplexml_load_string($this->JPK['IN_INSERT']);
			self::removeTnsNamespace($xmlInsert);
			$xmlL1 = simplexml_load_string($this->JPK['IN_L1']);
			$xml = simplexml_load_string($xmlSchema);
			$tns = $this->tns[$this->JPK_VAT_Wariant];

			switch (V::get('SRC_PODMIOT','',$_POST)) {
				case "Insert":
					$xml_append($xml, $xmlInsert->children($tns)->Naglowek);
					$xml_append($xml, $xmlInsert->children($tns)->Podmiot1);
					if ($this->JPK_VAT_Wariant == 3) {
						$xml->Naglowek->NazwaSystemu .= "; " . $xmlL1->Naglowek->NazwaSystemu;
						if ((!isset($xml->Podmiot1->Email)) && isset($xmlL1->Podmiot1->Email)) $xml->Podmiot1->Email = $xmlL1->Podmiot1->Email;
					}
					break;
				case "L1":
					$xml_append($xml, $xmlL1->children($tns)->Naglowek);
					$xml_append($xml, $xmlL1->children($tns)->Podmiot1);
					if ($this->JPK_VAT_Wariant == 3) {
						$xml->Naglowek->NazwaSystemu .= "; " . $xmlInsert->Naglowek->NazwaSystemu;
						if ((!isset($xml->Podmiot1->Email)) && isset($xmlInsert->Podmiot1->Email)) $xml->Podmiot1->Email = $xmlInsert->Podmiot1->Email;
					}
					break;
				default:
					throw new Exception("Błąd formularza");
			}

			$xml->Naglowek->DataWytworzeniaJPK = date("Y-m-d\TH:i:s");
			$xml->Naglowek->CelZlozenia = $this->JPK['PURPOSE'];

			$i = 0;
			foreach ($xmlInsert->SprzedazWiersz as $sprzedazWiersz) {
				$this->validateNIP($sprzedazWiersz->NrKontrahenta, $sprzedazWiersz->NazwaKontrahenta, "Sprzedaż Insert");
				$sprzedazWiersz->LpSprzedazy = ++$i;
				$xml_append($xml, $sprzedazWiersz);
			}
			foreach ($xmlL1->SprzedazWiersz as $sprzedazWiersz) {
				$this->validateNIP($sprzedazWiersz->NrKontrahenta, $sprzedazWiersz->NazwaKontrahenta, "Sprzedaż L1");
				$sprzedazWiersz->LpSprzedazy = ++$i;
				$xml_append($xml, $sprzedazWiersz);
			}
			$xml->addChild("SprzedazCtrl");

			$i = 0;
			foreach ($xmlInsert->ZakupWiersz as $zakupWiersz) {
				$this->validateNIP($zakupWiersz->NrDostawcy, $zakupWiersz->NazwaDostawcy, "Zakup Insert");
				$zakupWiersz->LpZakupu = ++$i;
				$xml_append($xml, $zakupWiersz);
			}
			foreach ($xmlL1->ZakupWiersz as $zakupWiersz) {
				$this->validateNIP($zakupWiersz->NrDostawcy, $zakupWiersz->NazwaDostawcy, "Zakup L1");
				$zakupWiersz->LpZakupu = ++$i;
				$xml_append($xml, $zakupWiersz);
			}
			$xml->addChild("ZakupCtrl");

			if ($this->NIPerrors) throw new Exception("Błędne numery NIP:<br/>" . implode("<br/>", $this->NIPerrors));

			$sumaryJPK_VAT = $this->getSummaryJPK_VAT($xml);
			$xml->SprzedazCtrl->LiczbaWierszySprzedazy = $sumaryJPK_VAT['LiczbaWierszySprzedazy'];
			$xml->SprzedazCtrl->PodatekNalezny = $sumaryJPK_VAT['PodatekNalezny'];
			$xml->ZakupCtrl->LiczbaWierszyZakupow = $sumaryJPK_VAT['LiczbaWierszyZakupow'];
			$xml->ZakupCtrl->PodatekNaliczony = $sumaryJPK_VAT['PodatekNaliczony'];
			$this->validateJPK_VAT($xml);

			$sqlObj = new stdClass();
			$sqlObj->ID = $this->JPK['ID'];
			$sqlObj->A_STATUS_INFO = "Wygenerowano wynikowy plik JPK";
			$sqlObj->OUT_MERGED = $xml->asXml();
			if (!$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj)) throw new Exception("Wystąpił nieznany błąd bazy danych");
			$this->handleAuth();
			$this->edit();

		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', $e->getMessage());
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function close_jpk() {
		try {
			$sqlObj = new stdClass();
			$sqlObj->ID = $this->JPK['ID'];
			$sqlObj->A_STATUS = 'OFF_HARD';
			$sqlObj->A_STATUS_INFO = "Zamknięto deklarację JPK";
			if (!$affected = DB::getDB()->UPDATE_OBJ('JPK', $sqlObj)) throw new Exception("Wystąpił nieznany błąd bazy danych");
			$this->handleAuth();
			$this->show();
		} catch (Exception $e) {
			SE_Layout::gora();
			SE_Layout::menu();
			SE_Layout::alert('danger', $e->getMessage());
?>
<div class="container" style="text-align:center">
  <form method="post" action="<?=$this->LAST_REFERER?>">
    <input type="hidden" name="REFERER" value="<?=$this->REFERER?>"/>
    <button type="submit" class="btn btn-primary">Powrót</button>
  </form>
</div>
<?php
			SE_Layout::dol();
		}
	}

	private function reinitialize() {
		$sqlObj = new stdClass();
		$sqlObj->ID = $this->JPK['ID'];
		$sqlObj->A_STATUS = 'WAITING';
		$sqlObj->A_STATUS_INFO = "Oczekuje na inicjalizację";
		$sqlObj->MONTH = "NULL";
		$sqlObj->PURPOSE = "NULL";
		DB::getDB()->UPDATE_OBJ('JPK', $sqlObj);
		$this->initialize();
}

	public function defaultAction() {
		switch ($this->JPK['A_STATUS']) {
			case "WAITING":
				$this->initialize();
				break;
			case "NORMAL":
				$this->edit();
				break;
			case "OFF_HARD":
				$this->show();
				break;
			default:
				SE_Layout::alert('danger', "Błędny status rekordu.");
		}
	}

}