package heimdall.ui.test;

import com.jolbox.bonecp.BoneCPDataSource;
import heimdall.alert.infrastructure.summary.AlertSummaryRepositoryDbi;
import heimdall.alert.projection.summary.AlertSummary;
import heimdall.alert.projection.summary.AlertSummaryRepository;
import heimdall.alert.projection.summary.ComposerSummary;
import no.ums.event.Transaction;

import javax.sql.DataSource;
import java.time.Instant;
import java.util.List;

/**
 * @author <a href="mailto:su@ums.no">Ståle Undheim</a>
 */
public class CopyAlerts {

    public static void main(String[] args) {
        final DataSource source = getSource();
        final DataSource dest = getDest();

        final AlertSummaryRepository sourceRepository = AlertSummaryRepositoryDbi.create(source);
        final AlertSummaryRepository destRepository = AlertSummaryRepositoryDbi.create(dest);

        final List<AlertSummary> alertSummaries = sourceRepository.getAlertSummaries(
                new long[]{-1},
                Instant.EPOCH,
                Integer.MAX_VALUE
        );

        final ComposerSummary composer = new ComposerSummary();
        composer.setComposerName("SAAS-1789 Admin");
        composer.setComposerUser("admin@1789");
        composer.setUserId(new Long("10348561095321333"));
        composer.setOwnerName("ORG-1789");
        composer.setOwnerId(new Long("31923739991718774"));

//                final ComposerSummary composer = new ComposerSummary();
//        composer.setComposerName("Sender Sender");
//        composer.setComposerUser("sender@sos");
//        composer.setUserId(new Long("3150899947099486"));
//        composer.setOwnerName("SOS");
//        composer.setOwnerId(new Long("12711919709513788"));

        for (AlertSummary alertSummary : alertSummaries) {
            try {

                System.out.println(alertSummary.getRefno().getRefno());
                alertSummary.setName("IMPORTED : "+ alertSummary.getName());
                Transaction.execute(() -> {
                    destRepository.update(alertSummary.getRefno().getRefno(), output -> {
                        output.setComposer(composer);
                        output.setName("IMPORTED: " + alertSummary.getName());
                        output.setStatus(alertSummary.getStatus());
                        output.setMessage(alertSummary.getMessage());
                        output.setRecipients(alertSummary.getRecipients());
                    });
                });
            } catch (Exception e) {
                e.printStackTrace();
            }

        }



    }
    public  static BoneCPDataSource getDest() {
        final BoneCPDataSource dataSource = new BoneCPDataSource();
        dataSource.setDriverClass("com.microsoft.sqlserver.jdbc.SQLServerDriver");
        dataSource.setJdbcUrl("jdbc:sqlserver://192.168.3.55;databaseName=heimdall_saas_qa_1602");
        //dataSource.setDriverClass("org.h2.Driver");
        //dataSource.setJdbcUrl("jdbc:h2:/Users/Rakesh/Documents/UMS-DEV/heimdall/spring-runtime/db/heimdall");
        dataSource.setUsername("sa");
        dataSource.setPassword("");
        return  dataSource;
    }

    public  static BoneCPDataSource getSource() {
        final BoneCPDataSource dataSource = new BoneCPDataSource();
        dataSource.setDriverClass("com.microsoft.sqlserver.jdbc.SQLServerDriver");
        dataSource.setJdbcUrl("jdbc:sqlserver://192.168.3.55;databaseName=heimdall_prod_20151103");
        dataSource.setUsername("sa");
        dataSource.setPassword("Diginform2011");
        return  dataSource;
    }
}