using System;
using System.Data.OleDb;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text.Json;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System.Collections.Generic;
using System.Reflection.Metadata;
using Pipefy;
class Program
{
    static async Task Main(string[] args)
    {
        // URL da API que você deseja chamar
        string apiUrl = "https://api.pipefy.com/graphql";
        string PipefyToken = "eyJhbGciOiJIUzUxMiJ9.eyJpc3MiOiJQaXBlZnkiLCJpYXQiOjE2OTg4NTYyMjcsImp0aSI6IjM2N2Y4M2NhLWZjODYtNGRhOC04ODEyLTkzODRkZGZkODc0MiIsInN1YiI6MzAyNTM0MzY2LCJ1c2VyIjp7ImlkIjozMDI1MzQzNjYsImVtYWlsIjoiYmFjazVAZW5lcmdpYXNtYXJ0LmNvbS5iciIsImFwcGxpY2F0aW9uIjozMDAyODkyNDgsInNjb3BlcyI6W119LCJpbnRlcmZhY2VfdXVpZCI6bnVsbH0.o13j9c_y3G3HX35qhX4PmkkibGsmlHsk5dL_Bxsr1CKV5Jlgj218kJdEmriS7aHiw0-P7sfs-bu4YcElfuyiqg";
        string ConnSourcePath = @"C:\Users\contratos\Documents\Giuliano\Pipefy.accdb";
        string PipefyTokenTableID = "b9t-7uD5";

        string? cursor = "null";

        string query = $"{{\"query\":\"query GetRecords($cursor: String){{    table_records(table_id: \\\"{PipefyTokenTableID}\\\",first:50,after:$cursor){{        pageInfo{{            hasNextPage            endCursor        }}        edges{{            node{{                record_fields{{                    field {{                        id                    }}                    value                    array_value                }}            }}        }}    }}}}\",\"variables\":{{\"cursor\":{cursor}}}}}";
        Console.WriteLine(query);
        bool hasNextPage = true;
        bool hasSucceeded = true;
        JArray allRecords = new JArray();

        while (hasNextPage)
        {
            var httpClient = new HttpClient();
            // Defina os headers da requisição (opcional)
            httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer " + PipefyToken);

            var request = new HttpRequestMessage(HttpMethod.Post, apiUrl);
            request.Headers.Add("Accept", "application/json");

            var content = new StringContent(query, null, "application/json");
            request.Content = content;
            var response = await httpClient.SendAsync(request);

            if (response.IsSuccessStatusCode)
            {
                var responseContent = await response.Content.ReadAsStringAsync();
                var responseData = JObject.Parse(responseContent);

                var records = responseData["data"]["table_records"]["edges"];
                foreach (var record in records)
                {
                    allRecords.Add(record);
                }

                hasNextPage = responseData["data"]["table_records"]["pageInfo"]["hasNextPage"].Value<bool>();
                cursor = responseData["data"]["table_records"]["pageInfo"]["endCursor"].Value<string>();
                query = $"{{\"query\":\"query GetRecords($cursor: String){{    table_records(table_id: \\\"{PipefyTokenTableID}\\\",first:50,after:$cursor){{        pageInfo{{            hasNextPage            endCursor        }}        edges{{            node{{                record_fields{{                    field {{                        id                    }}                    value                    array_value                }}            }}        }}    }}}}\",\"variables\":{{\"cursor\":\"{cursor}\"}}}}";

            }
            else
            {
                Console.WriteLine($"Erro na solicitação GraphQL: {response.StatusCode}");
                hasSucceeded = false;
                break;
            }
        }
        if (hasSucceeded)
        {
            string strJson = JsonConvert.SerializeObject(allRecords);
            // Desserialize o JSON em objetos C#
            var jsonData = JsonConvert.DeserializeObject<Pipefy.RootObject>(strJson);

            // Consulte os dados da tabela no banco de dados Access
            List<ClasseEmpresas> databaseData = GetDataFromDatabase(ConnSourcePath);

            // Compare os dados e encontre os registros ausentes no JSON
            List<ClasseEmpresas> recordsMissingInJson = CompareData(databaseData, jsonData);

            // Faça algo com os registros ausentes
            foreach (var record in recordsMissingInJson)
            {
                Console.WriteLine($"Registro ausente no JSON - ID: {record.c_odigo_smart}, Nome: {record.nome_da_empresa}");
            }
        }
    }

    static List<ClasseEmpresas> GetDataFromDatabase(string ConnSourcePath)
    {
        string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + ConnSourcePath;
        List<ClasseEmpresas> data = new List<ClasseEmpresas>();

        using (OleDbConnection connection = new OleDbConnection(connectionString))
        {
            connection.Open();

            // Execute uma consulta SQL para recuperar dados da tabela no banco de dados Access
            string sqlQuery = "SELECT * FROM tblEmpresas";
            using (OleDbCommand command = new OleDbCommand(sqlQuery, connection))
            {
                using (OleDbDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        ClasseEmpresas record = new ClasseEmpresas
                        {
                            c_odigo_smart = (int)reader["Código Smart"],
                            nome_da_empresa = (string)reader["Nome da empresa"],
                            modalidade = (string)reader["modalidade"],
                            gestores = (string)reader["gestores"],

                            // Adicione outras propriedades conforme necessário
                        };
                        data.Add(record);
                    }
                }
            }
        }

        return data;
    }

    static List<ClasseEmpresas> CompareData(List<ClasseEmpresas> databaseData, Pipefy.RootObject jsonData)
    {
        if (jsonData == null)
        {
            return databaseData;
        }

        List<ClasseEmpresas> recordsMissingInJson = new List<ClasseEmpresas>();

        foreach (var record in databaseData)
        {
            //if (jsonData.node.Any(item => item.recordFields[0].value.ToString() == record.c_odigo_smart.ToString()))
            //{
            //    continue;
            //}
            recordsMissingInJson.Add(record);
        }

        return recordsMissingInJson;
    }
}



class ClasseEmpresas
{
    public int c_odigo_smart { get; set; }
    public string nome_da_empresa { get; set; }
    public string modalidade { get; set; }
    public string gestores { get; set; }
    // Adicione outras propriedades conforme necessário
}











//using System;
//using System.Data.OleDb;
//using System.Net.Http;
//using System.Net.Http.Headers;
//using System.Text.Json;
//using System.Threading.Tasks;
//using Newtonsoft.Json;
//using Newtonsoft.Json.Linq;
//using System.Collections.Generic;

//class Program
//{
//	static async Task Main(string[] args)
//	{
//		// URL da API que você deseja chamar
//		string apiUrl = "https://api.pipefy.com/graphql";
//		string PipefyToken = "eyJhbGciOiJIUzUxMiJ9.eyJpc3MiOiJQaXBlZnkiLCJpYXQiOjE2OTg4NTYyMjcsImp0aSI6IjM2N2Y4M2NhLWZjODYtNGRhOC04ODEyLTkzODRkZGZkODc0MiIsInN1YiI6MzAyNTM0MzY2LCJ1c2VyIjp7ImlkIjozMDI1MzQzNjYsImVtYWlsIjoiYmFjazVAZW5lcmdpYXNtYXJ0LmNvbS5iciIsImFwcGxpY2F0aW9uIjozMDAyODkyNDgsInNjb3BlcyI6W119LCJpbnRlcmZhY2VfdXVpZCI6bnVsbH0.o13j9c_y3G3HX35qhX4PmkkibGsmlHsk5dL_Bxsr1CKV5Jlgj218kJdEmriS7aHiw0-P7sfs-bu4YcElfuyiqg";
//		string ConnSourcePath = @"C:\Users\contratos\Documents\Giuliano\Pipefy.accdb";
//		string PipefyTokenTableID = "b9t-7uD5";


//        // Crie uma instância HttpClient
//        using (HttpClient httpClient = new HttpClient())
//		{
//			// Defina os headers da requisição (opcional)
//			httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
//			httpClient.DefaultRequestHeaders.Add("Accept", "application/json");
//			httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer " + PipefyToken);

//			// Crie a consulta GraphQL
//            //string rawGraphQuery = @"{""query"":""query{\r\n  table_records(table_id: \""" + PipefyTokenTableID + @"\"") {\r\n    edges {\r\n      node {\r\n        id\r\n        record_fields{\r\n          field{\r\n            id\r\n          }\r\n          value\r\n        }\r\n      }\r\n    }\r\n  }\r\n}"",""variables"":{}}";
//            string rawGraphQuery = "{\"query\":\"query { table_records(table_id: \\\"" + PipefyTokenTableID + "\\\") { edges { node { id record_fields { field { id } value } } } } }\",\"variables\":{}}";
//            string query = /*lang=json,strict*/ rawGraphQuery;

//			// Defina o conteúdo do corpo da requisição
//			var content = new StringContent(query, System.Text.Encoding.UTF8, "application/json");

//			// Envie a requisição POST com a consulta GraphQL
//			var response = await httpClient.PostAsync(apiUrl, content);

//			if (response.IsSuccessStatusCode)
//			{
//				string responseBody = await response.Content.ReadAsStringAsync();

//				Console.WriteLine("Resposta bem-sucedida:");
//				Console.WriteLine(responseBody);

//                // Desserialize o JSON em objetos C#
//                var jsonData = JsonConvert.DeserializeObject<Root>(responseBody);

//                // Consulte os dados da tabela no banco de dados Access
//                List<ClasseEmpresas> databaseData = GetDataFromDatabase(ConnSourcePath);

//                // Compare os dados e encontre os registros ausentes no JSON
//                List<ClasseEmpresas> recordsMissingInJson = CompareData(databaseData, jsonData);

//                // Faça algo com os registros ausentes
//                foreach (var record in recordsMissingInJson)
//                {
//                    Console.WriteLine($"Registro ausente no JSON - ID: {record.Id}, Nome: {record.Nome}");
//                }
//			}
//			else
//			{
//				Console.WriteLine($"Erro na requisição: {response.StatusCode}");
//			}
//		}
//	}
//    static List<ClasseEmpresas> GetDataFromDatabase(string ConnSourcePath)
//    {
//        string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=" + ConnSourcePath;
//        List<ClasseEmpresas> data = new List<ClasseEmpresas>();

//        using (OleDbConnection connection = new OleDbConnection(connectionString))
//        {
//            connection.Open();

//            // Execute uma consulta SQL para recuperar dados da tabela no banco de dados Access
//            string sqlQuery = "SELECT * FROM tblEmpresas";
//            using (OleDbCommand command = new OleDbCommand(sqlQuery, connection))
//            {
//                using (OleDbDataReader reader = command.ExecuteReader())
//                {
//                    while (reader.Read())
//                    {
//                        ClasseEmpresas record = new ClasseEmpresas
//                        {
//                            Id = (int)reader["id"],
//                            Nome = (string)reader["nome"],
//                            // Adicione outras propriedades conforme necessário
//                        };
//                        data.Add(record);
//                    }
//                }
//            }
//        }

//        return data;
//    }

//    static List<ClasseEmpresas> CompareData(List<ClasseEmpresas> databaseData, Root? jsonData)
//    {
//        if(jsonData == null) {  return databaseData; }

//        List<ClasseEmpresas> recordsMissingInJson = new List<ClasseEmpresas>();

//        foreach (var record in databaseData)
//        {
//            if (!jsonData.Any(item => item.id == record.id))
//            {
//                recordsMissingInJson.Add(record);
//            }
//        }

//        return recordsMissingInJson;
//    }
//}

//class Root
//{
//    public required List<ClasseEmpresas> jsonData { get; set; }

//    internal bool Any(Func<object, bool> value)
//    {
//        throw new NotImplementedException();
//    }
//}
//class ClasseEmpresas
//{
//    public int Id { get; set; }
//    public required string Nome { get; set; }

//    internal bool Any(Func<object, bool> value)
//    {
//        throw new NotImplementedException();
//    }
//    // Adicione outras propriedades conforme necessário
//}