package org.nuclet.beispielxrechnung; 

import eu.ce.en16931._2017.xoev_de.kosit.standard.xrechnung_1.*;
import org.nuclet.xrechnung.imp.AktualisiereERechnungsimport;
import org.nuclet.xrechnung.imp.ERechnungsimport;
import org.nuclet.xrechnung.imp.ImportiereERechnungen;
import org.nuclos.api.businessobject.Flag;
import org.nuclos.api.businessobject.facade.Modifiable;
import org.nuclos.api.provider.QueryProvider;
import org.nuclos.api.rule.GenerateRule;
import org.nuclos.api.context.GenerateContext; 
import org.nuclos.api.annotation.Rule; 
import org.nuclos.api.exception.BusinessException;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import static org.nuclet.xrechnung.imp.ImportiereERechnungen.*;
import static org.nuclet.xrechnung.imp.ImportiereERechnungen.getTextValue;

/** @name        
  * @description 
  * @usage       
  * @change      
*/
@Rule(name="ErstelleEingangsrechnung", description="ErstelleEingangsrechnung")
public class ErstelleEingangsrechnung implements GenerateRule {

	public void generate(GenerateContext context) throws BusinessException {
		ERechnungsimport imp = context.getSourceObject(ERechnungsimport.class);
		Rechnung rechnung = context.getTargetObject(Rechnung.class);
		setFields(imp, rechnung);
	}

	public static void setFields(ERechnungsimport imp, Rechnung rechnung) throws BusinessException {
		AktualisiereERechnungsimport.checkUpdate(imp, "Zu diesem Import wurde bereits eine Eingangsrechnung erstellt.");
		Invoice xRechnung = AktualisiereERechnungsimport.getXRechnung(imp);
		rechnung.setErechnungsimportId(imp.getId());
		rechnung.setRechnungsnummer(xRechnung.getInvoiceNumber().getValue());
		rechnung.setRechnungsdatum(getDate(xRechnung.getInvoiceIssueDate()));
        rechnung.setCoderechnungsart(getCodeValue(xRechnung.getInvoiceTypeCode()));
		rechnung.setFaelligkeit(getDate(xRechnung.getPaymentDueDate()));
		DocumentReference purchaseOrderReference = xRechnung.getPurchaseOrderReference();
		if (purchaseOrderReference != null) {
			rechnung.setBestellnummer(purchaseOrderReference.getValue());
		}
		rechnung.setZahlungskonditionen(getTextValue(xRechnung.getPaymentTerms()));
		SELLERType seller = xRechnung.getSELLER();
        if (seller != null) {
			SELLERCONTACTType sellerContact = seller.getSELLERCONTACT();
            if (sellerContact != null) {
				rechnung.setAnsprechpartnername(getTextValue(sellerContact.getSellerContactPoint()));
				rechnung.setAnsprechpartnertelefon(getTextValue(sellerContact.getSellerContactTelephoneNumber()));
				rechnung.setAnsprechpartneradresse(getTextValue(sellerContact.getSellerContactEmailAddress()));
			}
			String ustIdNr = getIdValue(seller.getSellerVATIdentifier());
            if (ustIdNr != null) {
				List<Kunde> kundeList = QueryProvider.execute(QueryProvider.create(Kunde.class).where(Kunde.Ustidnr.eq(ustIdNr)).setChunkSize(2L));
				int size = kundeList.size();
				Long kundeId = null;
				if (size == 1) {
                    kundeId = kundeList.iterator().next().getId();
                } else if (size == 0) {
					Kunde kunde = new Kunde();
					kunde.setName(getTextValue(seller.getSellerName()));
					kunde.setLeitweg(getTextValue(xRechnung.getBuyerReference()));
					SELLERPOSTALADDRESSType sellerpostaladdress = seller.getSELLERPOSTALADDRESS();
                    if (sellerpostaladdress != null) {
						kunde.setStrasse(getTextValue(sellerpostaladdress.getSellerAddressLine1()));
						kunde.setPlz(getTextValue(sellerpostaladdress.getSellerPostCode()));
						kunde.setOrt(getTextValue(sellerpostaladdress.getSellerCity()));
						kunde.setLaendercode(getCodeValue(sellerpostaladdress.getSellerCountryCode()));
					}
					kunde.setUstidnr(ustIdNr);
					kunde.save();
					kundeId = kunde.getId();
				}
                if (kundeId != null) {
					rechnung.setKundenreferenzId(kundeId);
                }
			}
		}
		rechnung.setWaehrung(getCodeValue(xRechnung.getInvoiceCurrencyCode()));
		List<VATBREAKDOWNType> vatbreakdown = xRechnung.getVATBREAKDOWN();
        if (vatbreakdown.size() == 1) {
			VATBREAKDOWNType breakdown = vatbreakdown.iterator().next();
			rechnung.setSteuercode(getCodeValue(breakdown.getVATCategoryCode()));
			rechnung.setSteuersatz(getBigDecimal(breakdown.getVATCategoryRate()));
        }
		for (INVOICELINEType line : xRechnung.getINVOICELINE()) {
			Rechnungsposition pos = new Rechnungsposition();
			ITEMINFORMATIONType iteminformation = line.getITEMINFORMATION();
            if (iteminformation != null) {
				pos.setBezeichnung(getTextValue(iteminformation.getItemName()));
			}
			pos.setMenge(getBigDecimal(line.getInvoicedQuantity()));
			pos.setEinheit(getCodeValue(line.getInvoicedQuantityUnitOfMeasureCode()));
			pos.setNettobetrag(getBigDecimal(line.getInvoiceLineNetAmount()));
			pos.setBestellposition(getIdValue(line.getInvoiceLineIdentifier()));
			INVOICELINEPERIODType period = line.getINVOICELINEPERIOD();
            if (period != null) {
				pos.setLeistungszeitraumvon(getDate(period.getInvoiceLinePeriodStartDate()));
				pos.setLeistungszeitraumbis(getDate(period.getInvoiceLinePeriodEndDate()));
			}
			rechnung.insertRechnungsposition(pos);
		}
	}

	public static class InvoiceHelperImpl implements InvoiceHelper {

		public Modifiable<?> newEingangsrechnung() {
			return new Rechnung();
		}

		public List<? extends Modifiable<?>> getEingangsrechnung(ERechnungsimport imp, Flag... flags) {
			List<Rechnung> list = new ArrayList<>();
			org.nuclet.beispielxrechnung.ERechnungsimport rechnungsimport = org.nuclet.beispielxrechnung.ERechnungsimport.get(imp.getId());
            if (rechnungsimport != null) {
                list = rechnungsimport.getRechnung(flags);
            }
			return list;
		}

		public void setFields(ERechnungsimport imp, Modifiable<?> eingangsrechnung) throws BusinessException {
			ErstelleEingangsrechnung.setFields(imp, (Rechnung) eingangsrechnung);
		}
	}
}