before

package az.com.cybernet.avis.integ.business.mlspp;

import java.util.Calendar;
import java.util.Date;
import java.util.List;
import org.json.JSONObject;
import org.tempuri.GetInsuredPeopleByDateIntervalForTaxResponseCustom;
import org.tempuri.Service1SoapStub;
import az.com.cybernet.avis.integ.business.IntUtilBsn;
import az.com.cybernet.avis.integ.entity.SsnDataEnt;
import az.com.cybernet.avis.tools.business.CoreBsn;
import az.com.cybernet.avis.tools.business.DataValidator;
import net.x_rd.az.voen1700093011.producer.AipisInsuredPersonForTax;
import tr.com.cs.aurora.auroracore.utility.CSBag;
import tr.com.cs.aurora.auroracore.utility.CSException;
import tr.gov.ggm.vedop2.dal.dalwrapper.TransactionBag;

public class MlsppGetInsuredpeopleBsn extends CoreBsn{
    public static CSBag getInsuredPeopleByDateIntervalForTax(CSBag inBag) throws CSException{
        try {
            inBag.put("firsRun", 1);
            while(MlsppUtil.isRoll(inBag)){
                Date srvStartTime = new Date();
                renovateSsnData(inBag);
                Date srvEndTime = new Date();
                inBag.put("srvStartTime", srvStartTime.getTime());
                inBag.put("srvEndTime", srvEndTime.getTime());
                inBag.put("msg", "INTEG_MLSPP_GET_INSUREDPEOPLE -- GOZLEME #SANIYE: ");
            }
        } catch (Exception e) {
            getInsuredPeopleByDateIntervalForTax(inBag);
        }
        return inBag;
    }

    public static void renovateSsnData(CSBag inBag) throws CSException{
        try {
            Service1SoapStub stub = MlsppUtil.getMlsppStub();
            JSONObject json = getStartEndDate(inBag);
            String startDate = json.getString("startDate");
            String endDate = json.getString("endDate");

            System.out.println("INTEG_MLSPP_GET_INSUREDPEOPLE -- START #StartDate: " + startDate + "\t#EndDate: " + endDate);
            GetInsuredPeopleByDateIntervalForTaxResponseCustom incaliDateContracts = stub.getInsuredPeopleByDateIntervalForTax(startDate, endDate);
            AipisInsuredPersonForTax[] personForTaxs = incaliDateContracts.getResponse().getResponse().getInsuredPersons();

            if(personForTaxs==null){
                inBag.put("startDate", endDate);
                inBag.put("newEndDate", DataValidator.plusMinusToDate(endDate, 1, Calendar.SECOND));
                return;
            }
            for(int i=0; i<personForTaxs.length; i++){
                AipisInsuredPersonForTax personForTax = personForTaxs[i];
                TransactionBag.setTransactionBag(new TransactionBag());
                SsnDataEnt ssnData = new SsnDataEnt();
                ssnData.setSsn(personForTax.getInsured().getSsn());
                SsnDataEnt oldSsnData = ifExists(ssnData);
                ssnData.setRegistrationDate(DataValidator.calendarUTCToString(personForTax.getInsured().getSsnDate(), "yyyyMMddHHmmss"));
                ssnData.setName(personForTax.getPerson().getName());
                ssnData.setMiddleName(personForTax.getPerson().getPatronymic());
                ssnData.setFin(personForTax.getPerson().getPin());
                ssnData.setSurname(personForTax.getPerson().getSurname());
                ssnData.setBirthDate(DataValidator.calendarUTCToString(personForTax.getPerson().getBirthdate(), "yyyyMMdd"));
                ssnData.setIssync("0");

                startDate = ssnData.getRegistrationDate();

                String oper = "";
                if(oldSsnData != null){
                    ssnData.setLastUpdate(oldSsnData.getLastUpdate());
                    ssnData.setModificationDate(oldSsnData.getModificationDate());
                    ssnData.setStatus(oldSsnData.getStatus());
                    ssnData.setOid(oldSsnData.getOid());
                    update(ssnData);
                    oper = "U \u2B8D ";
                } else{
                    insert(ssnData, true, true);
                    oper = "I \u2B87 ";
                }
                System.out.println("INTEG_MLSPP_GET_INSUREDPEOPLE #SSN: "+ssnData.getSsn()+" #DATE: "+ ssnData.getRegistrationDate()+" #LOOP   " + (i+1) + " of "+ personForTaxs.length +"  \033[1;32;40m" + oper +"\u23E9\u23E9\u23E9"+"\u001B[0m");
                IntUtilBsn.commitTransaction();
                long secund = DataValidator.getDateDiffByString(startDate, endDate);
                if(secund>86400000){
                    startDate = endDate;
                }
                inBag.put("startDate", DataValidator.plusMinusToDate(startDate, 1, Calendar.SECOND));
                inBag.put("newEndDate", endDate);
            }
        } catch (Exception e) {
            System.out.println("Error: "+"INTEG_MLSPP_GET_INSUREDPEOPLE#"+e.getMessage());
            throw new CSException(e);
        }
    }

    private static SsnDataEnt ifExists(SsnDataEnt ssnData) throws Exception{
        @SuppressWarnings("unchecked")
        List<SsnDataEnt> ssnDataEnt = (List<SsnDataEnt>)selectByTemplate(ssnData);
        if(ssnDataEnt.size()==0){
            return null;
        } else{
            return ssnDataEnt.get(0);
        }
    }

    private static JSONObject getStartEndDate (CSBag inBag) throws Exception{
        StringBuilder sql = new StringBuilder();
        sql.append("SELECT\n");
        sql.append("    MAX( REGISTRATION_DATE ) TARIX\n");
        sql.append("FROM\n");
        sql.append("    INT_SSN_DATA\n");
        sql.append("HAVING MAX(REGISTRATION_DATE) IS NOT NULL");
        return MlsppUtil.getStartEndDate(inBag, sql.toString());
    }
}