using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Xrm.Sdk.Client;
using Microsoft.Crm;
using System.Runtime.Serialization;
using Microsoft.Xrm.Client;
using Microsoft.Xrm.Client.Services;
using Microsoft.Xrm.Sdk;
using System.Data.SqlClient;
using System.Data;
using Microsoft.Xrm.Sdk.Query;


namespace Import_cust
{
    class importCust
    {
        //static string connectionString = "Url=http://192.168.0.237/TestDemo; Domain =petpackaging; Username=xrmcrm; Password=Xr`mpTEdcRm@2016;"; //pasijungimas
        static string connectionString = "Url=https://192.168.0.238/CRM; Domain =petpackaging; Username=xrmcrm; Password=Xr`mpTEdcRm@2016;"; //pasijungimas
        static string connectionDB = @"server = 192.168.0.250 ; database = Soltus ; user id = soltus; password = Soltus2011";
        static OrganizationService os;

        public static void Main(string[] args)
        {

            logIn();
            //createAccTest();
            getData();



        }

        public static void logIn()
        {

            CrmConnection connection = CrmConnection.Parse(connectionString);
            os = new OrganizationService(connection);
            System.Net.ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };

        }

        public static void createAcc(string no, string name, string regnr, string creditlimit, string currentdebt, string overduedebt ,string salesperson)
        {
            Entity account = new Entity("account");
            account["accountnumber"] = no;
            account["xs_customerid"] = no;
            account["name"] = name;
            account["xs_accountcode"] = regnr ;
            account["xs_navresponsible"] = salesperson;
            account["xs_creditlimit"] = new Money(Convert.ToDecimal(creditlimit));
            account["xs_currentdebt"] = new Money(Convert.ToDecimal(currentdebt));
            account["xs_overduedebt"] = new Money(Convert.ToDecimal(overduedebt));
            os.Create(account);
            Console.WriteLine("Account created: " + account["name"]);

        }

        public static void getData()
        {
            SqlConnection c = new SqlConnection(connectionDB); //prisijungimas i db
            SqlConnection c2 = new SqlConnection(connectionDB); // updeitinimo prisijungimas
            c.Open();
            c2.Open();
            SqlCommand co = new SqlCommand(
            @"SELECT  [No_]
            ,[Name]
            ,[regnr]
            ,[creditlimit]
            ,[currentdebt]
            ,[overduedebt]
            ,[Salesperson Code] as sp
            FROM [Soltus].[dbo].[getAccounts]
           "
               , c);

            SqlDataReader r = co.ExecuteReader();

            while (r.Read())
            {
                createAcc(
                    r["No_"].ToString(),
                    r["Name"].ToString(),
                    r["regnr"].ToString(),
                    r["creditlimit"].ToString(),
                    r["currentdebt"].ToString(),
                    r["overduedebt"].ToString(),
                    r["sp"].ToString()
                    );
                insertLog(r["No_"].ToString(), c2);

            }

            c.Close();
            c2.Close();
            Console.WriteLine("pabaiga");


        }

        public static void insertLog(string no,SqlConnection c2)
        {
            //iraso log'a
            SqlCommand co = new SqlCommand("dbo.insertLog",c2);
            co.CommandType = CommandType.StoredProcedure;
            co.Parameters.Add(new SqlParameter("@No",no));
            co.Parameters.Add(new SqlParameter("@Tipas", "Account"));
            co.Parameters.Add(new SqlParameter("@Veiksmas", "I"));
            co.ExecuteNonQuery();

            //updeitina timestamp
            co.CommandType = CommandType.Text;
            co.CommandText = @"update  f
            set f.Laikas = c.timestamp
            from [Soltus].[dbo].[CrmIntegracija] f
            join [NAVDB].[dbo].[Putokšnis$Customer] c
            on f.No_ = c.No_ collate Latin1_General_CI_AI
            where
            f.Veiksmas = 'I' and
            f.No_ = '" + no + "'";
            co.ExecuteNonQuery();



        }

        /*
        public static void createAccTest()
        {
            Entity account = new Entity("account");
            account["name"] = "Soltus2";
            account["accountnumber"] = "SOL";
            account["xs_accountcode"] = "SOL123" ;
            account["xs_creditlimit"] = new Money(Convert.ToDecimal("123,00")) ;
            account["xs_currentdebt"] = new Money(Convert.ToDecimal("456,00")) ;
            account["xs_overduedebt"] = new Money(Convert.ToDecimal("789,22")) ;
            os.Create(account);
            Console.WriteLine("Account created: " + account["name"]);

        }
        */



    }
}