package id.co.sofcograha.gajiidapi.domain.hris.payroll.rpt.rekappenghasilankaryawan.repositories;

import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.Map;

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
import org.springframework.stereotype.Repository;

import id.co.sofcograha.gajiidapi.base.constants.BaseConstants;
import id.co.sofcograha.gajiidapi.base.utils.TimeUtil;

@Repository
public class RptRekapPenghasilanKaryawanRepository {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    private SimpleJdbcCall simpleJdbcCallInsertInqRekapPenghasilanKaryawan;
    private SimpleJdbcCall simpleJdbcCallGetInqRekapPenghasilanKaryawan;
    private SimpleJdbcCall simpleJdbcCallDeleteInqRekapPenghasilanKaryawan;

    @PostConstruct
    void init() {
        jdbcTemplate.setResultsMapCaseInsensitive(true);
        simpleJdbcCallInsertInqRekapPenghasilanKaryawan = new SimpleJdbcCall(jdbcTemplate)
                                                            .withFunctionName("spHPY_Insert_Inq_Data_Rekap_Penghasilan_Karyawan")
                                                            .withSchemaName(BaseConstants.PUBLIC_SCHEMA);

        simpleJdbcCallGetInqRekapPenghasilanKaryawan = new SimpleJdbcCall(jdbcTemplate)
                                                            .withFunctionName("spHPY_Get_Inq_Data_Rekap_Penghasilan_Karyawan")
                                                            .withSchemaName(BaseConstants.PUBLIC_SCHEMA);

        simpleJdbcCallDeleteInqRekapPenghasilanKaryawan = new SimpleJdbcCall(jdbcTemplate)
                                                            .withFunctionName("spHPY_Delete_Inq_Data_Rekap_Penghasilan_Karyawan")
                                                            .withSchemaName(BaseConstants.PUBLIC_SCHEMA);
    }

    public void insertRekapPenghasilanKaryawan(String sessId,
                                               Date tanggalProses,
                                               String jamProses,
                                               String userId,
                                               String tahunBulanGajiAwal,
                                               String tahunBulanGajiAkhir) {

        SqlParameterSource params = new MapSqlParameterSource()
                                        .addValue("$1", sessId)
                                        .addValue("$2", TimeUtil.convertDatetoSQLDateString(tanggalProses))
                                        .addValue("$3", jamProses)
                                        .addValue("$4", userId)
                                        .addValue("$5", tahunBulanGajiAwal)
                                        .addValue("$6", tahunBulanGajiAkhir);

        simpleJdbcCallInsertInqRekapPenghasilanKaryawan.executeFunction(Boolean.class, params);
    }

    @SuppressWarnings("unchecked")
    public List<Object> getRekapPenghasilanKaryawan(String sessId,
                                                    Date tanggalProses,
                                                    String jamProses,
                                                    String gridFields,
                                                    String groupBy,
                                                    String orderBy,
                                                    String tahunBulanGajiAwal,
                                                    String tahunBulanGajiAkhir,
                                                    String jenisPembayaran,
                                                    String kelompokPayrollId,
                                                    String nik,
                                                    String nama,
                                                    String npwpId,
                                                    String statusKaryawanId,
                                                    String departemenId,
                                                    String jabatanId,
                                                    String levelJabatanId,
                                                    String lokasiKerjaId,
                                                    String attribute1Id,
                                                    String attribute1value,
                                                    String attribute2Id,
                                                    String attribute2value,
                                                    String attribute3Id,
                                                    String attribute3value,
                                                    String attribute4Id,
                                                    String attribute4value,
                                                    String attribute5Id,
                                                    String attribute5value,
                                                    String attribute6Id,
                                                    String attribute6value,
                                                    String attribute7Id,
                                                    String attribute7value,
                                                    String attribute8Id,
                                                    String attribute8value,
                                                    String attribute9Id,
                                                    String attribute9value,
                                                    String attribute10Id,
                                                    String attribute10value) {

        SqlParameterSource params = new MapSqlParameterSource()
                                        .addValue("$1", sessId)
                                        .addValue("$2", TimeUtil.convertDatetoSQLDateString(tanggalProses))
                                        .addValue("$3", jamProses)
                                        .addValue("$4", gridFields)
                                        .addValue("$5", groupBy)
                                        .addValue("$6", orderBy)
                                        .addValue("$7", tahunBulanGajiAwal)
                                        .addValue("$8", tahunBulanGajiAkhir)
                                        .addValue("$9", jenisPembayaran)
                                        .addValue("$10", kelompokPayrollId)
                                        .addValue("$11", nik)
                                        .addValue("$12", nama)
                                        .addValue("$13", npwpId)
                                        .addValue("$14", statusKaryawanId)
                                        .addValue("$15", departemenId)
                                        .addValue("$16", jabatanId)
                                        .addValue("$17", levelJabatanId)
                                        .addValue("$18", lokasiKerjaId)
                                        .addValue("$19", attribute1Id)
                                        .addValue("$20", attribute1value)
                                        .addValue("$21", attribute2Id)
                                        .addValue("$22", attribute2value)
                                        .addValue("$23", attribute3Id)
                                        .addValue("$24", attribute3value)
                                        .addValue("$25", attribute4Id)
                                        .addValue("$26", attribute4value)
                                        .addValue("$27", attribute5Id)
                                        .addValue("$28", attribute5value)
                                        .addValue("$29", attribute6Id)
                                        .addValue("$30", attribute6value)
                                        .addValue("$31", attribute7Id)
                                        .addValue("$32", attribute7value)
                                        .addValue("$33", attribute8Id)
                                        .addValue("$34", attribute8value)
                                        .addValue("$35", attribute9Id)
                                        .addValue("$36", attribute9value)
                                        .addValue("$37", attribute10Id)
                                        .addValue("$38", attribute10value);

        Map<String, Object> out = simpleJdbcCallGetInqRekapPenghasilanKaryawan.execute(params);

        if (out == null) {
            return Collections.emptyList();
        } else {
            return (List<Object>) out.get("returnvalue");
        }
    }

    public void deleteRekapPenghasilanKaryawan(String sessId, Date tanggalProses, String jamProses) {
        SqlParameterSource params = new MapSqlParameterSource()
                                        .addValue("$1", sessId)
                                        .addValue("$2", TimeUtil.convertDatetoSQLDateString(tanggalProses))
                                        .addValue("$3", jamProses);

        simpleJdbcCallDeleteInqRekapPenghasilanKaryawan.execute(params);
    }
}