ConexaoProdutos.cs

using MySql.Data.MySqlClient;
using Mysqlx.Crud;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using static New1.FormRegistarVenda;

namespace New1
{
    internal class ConexaoProdutos
    {

        //contar clientes na label do FormM
        public static int ContarProdutos()
        {
            using (MySqlConnection conn = ConexaoDB.ObterConexao())
            {
                conn.Open();
                MySqlCommand cmd = new MySqlCommand("SELECT COUNT(*) FROM produtos", conn);
                return Convert.ToInt32(cmd.ExecuteScalar());
            }

        }

        public static DataTable ObterTaxas()
        {
            DataTable tabela = new DataTable();

            using (var conn = ConexaoDB.ObterConexao())
            {
                conn.Open();
                string sql = "SELECT id, nome, valor FROM taxas ORDER BY nome ASC;";

                MySqlCommand cmd = new MySqlCommand(sql, conn);

                using (var adapter = new MySqlDataAdapter(cmd))
                {
                    adapter.Fill(tabela);
                }
            }

            return tabela;
        }


        // Método para carregar os produtos
        public DataTable CarregarProdutos()
        {
            DataTable dt = new DataTable();
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    string query = @"
            SELECT 
                    p.id, 
                    p.nome, 
                    c.descricao AS categoria,
                    p.quantidade, 
                    IFNULL(p.validade, '1900-01-01') AS validade,
                    p.cod_barras
                FROM 
                    produtos p
                INNER JOIN 
                    categorias c ON p.categoria = c.id
                ORDER BY 
                    p.id DESC;

            ";

                    MySqlDataAdapter da = new MySqlDataAdapter(query, conn);
                    da.Fill(dt);
                }

                // Formatação da validade
                foreach (DataRow row in dt.Rows)
                {
                    if (row["validade"] != DBNull.Value)
                    {
                        if (DateTime.TryParse(row["validade"].ToString(), out DateTime validade))
                        {
                            row["validade"] = validade;
                        }
                        else
                        {
                            row["validade"] = DateTime.MinValue;
                        }
                    }
                    else
                    {
                        row["validade"] = DateTime.MinValue;
                    }
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao carregar produtos: " + ex.Message);
            }

            return dt;
        }

        public DataTable CarregarPrecos()
        {
            DataTable tabela = new DataTable();

            try
            {
                using (var conn = ConexaoDB.ObterConexao())
                {
                    conn.Open();
                    string sql = @"
                SELECT 
                    p.id AS id_A, 
                    p.nome AS nome_A, 
                    p.pcusto AS pcusto_A, 
                    p.margem1 AS margem1_A, p.margem2 AS margem2_A, p.margem3 AS margem3_A, 
                    p.margem4 AS margem4_A, p.margem5 AS margem5_A,
                    p.pvp_iliquido1 AS pvp_iliquido1_A, p.pvp_iliquido2 AS pvp_iliquido2_A, p.pvp_iliquido3 AS pvp_iliquido3_A, 
                    p.pvp_iliquido4 AS pvp_iliquido4_A, p.pvp_iliquido5 AS pvp_iliquido5_A,
                    p.pvp_liquido1 AS pvp_liquido1_A, p.pvp_liquido2 AS pvp_liquido2_A, p.pvp_liquido3 AS pvp_liquido3_A, 
                    p.pvp_liquido4 AS pvp_liquido4_A, p.pvp_liquido5 AS pvp_liquido5_A,
                    p.valor_margem1 AS valor_margem1_A, p.valor_margem2 AS valor_margem2_A, p.valor_margem3 AS valor_margem3_A, 
                    p.valor_margem4 AS valor_margem4_A, p.valor_margem5 AS valor_margem5_A,
                    t.nome AS taxa_nome_A
                FROM produtos p
                LEFT JOIN taxas t ON p.taxa_id = t.id
                ORDER BY p.id ASC;";

                    using (MySqlCommand cmd = new MySqlCommand(sql, conn))
                    using (MySqlDataReader reader = cmd.ExecuteReader())
                    {
                        tabela.Load(reader); // Alternativa ao Fill()
                    }
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show("Erro ao carregar preços: " + ex.Message);
            }

            return tabela;
        }




        //Obter dados de produtos para para tabela do formEstoque 
        public DataTable ObterEstoque()
        {
            DataTable dt = new DataTable();
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    string query = @"
                SELECT 
                    p.id, 
                    p.nome, 
                     
                    p.validade, 
                    p.categoria AS id_categoria, 
                    c.descricao AS categoria, 
                    p.quantidade, 
                    p.cod_barras
                FROM produtos p
                INNER JOIN categorias c ON p.categoria = c.id
                ORDER BY p.nome";
                    MySqlDataAdapter da = new MySqlDataAdapter(query, conn);
                    da.Fill(dt);
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao obter estoque: " + ex.Message);
            }
            return dt;
        }

        //serve para actualizar a quantidade de itens em estoque na bd
        public void AtualizarQuantidadeEstoque(int idProduto, int novaQuantidade)
        {
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    string query = "UPDATE produtos SET quantidade = @quantidade WHERE id = @id";
                    MySqlCommand cmd = new MySqlCommand(query, conn);
                    cmd.Parameters.AddWithValue("@quantidade", novaQuantidade);
                    cmd.Parameters.AddWithValue("@id", idProduto);
                    conn.Open();
                    cmd.ExecuteNonQuery();
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao atualizar quantidade: " + ex.Message);
            }
        }



        //Se você tentar cadastrar um produto com um código de barras já existente, ele aumentará a quantidade do produto existente.
        //Se for um novo código, ele cadastra normalmente.
        public void AdicionarOuAtualizarProduto(string nome, int quantidade, string categoria, DateTime validade, string codBarras)
        {
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    conn.Open();

                    string selectQuery = "SELECT id, quantidade FROM produtos WHERE cod_barras = @codBarras";
                    MySqlCommand selectCmd = new MySqlCommand(selectQuery, conn);
                    selectCmd.Parameters.AddWithValue("@codBarras", codBarras);

                    using (MySqlDataReader reader = selectCmd.ExecuteReader())
                    {
                        if (reader.Read())
                        {
                            // Atualiza quantidade
                            int produtoId = reader.GetInt32("id");
                            int quantidadeExistente = reader.GetInt32("quantidade");
                            int novaQuantidade = quantidadeExistente + quantidade;
                            reader.Close();

                            string updateQuery = @"UPDATE produtos 
                                           SET quantidade = @quantidade
                                           WHERE id = @id";
                            MySqlCommand updateCmd = new MySqlCommand(updateQuery, conn);
                            updateCmd.Parameters.AddWithValue("@quantidade", novaQuantidade);
                            updateCmd.Parameters.AddWithValue("@id", produtoId);
                            updateCmd.ExecuteNonQuery();
                        }
                        else
                        {
                            reader.Close();
                            string insertQuery = @"
                    INSERT INTO produtos (nome,  quantidade, categoria, validade, cod_barras)
                    VALUES (@nome, @quantidade, @categoria, @validade, @codBarras)";
                            MySqlCommand insertCmd = new MySqlCommand(insertQuery, conn);
                            insertCmd.Parameters.AddWithValue("@nome", nome);
                            //insertCmd.Parameters.AddWithValue("@preco", preco);
                            insertCmd.Parameters.AddWithValue("@quantidade", quantidade);
                            insertCmd.Parameters.AddWithValue("@categoria", categoria);
                            insertCmd.Parameters.AddWithValue("@validade", validade == DateTime.MinValue ? (object)DBNull.Value : validade);
                            insertCmd.Parameters.AddWithValue("@codBarras", codBarras);
                            insertCmd.ExecuteNonQuery();
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao cadastrar ou atualizar produto: " + ex.Message);
            }
        }



        public DataTable ObterCategorias()
        {
            DataTable dt = new DataTable();
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    string query = "SELECT id, descricao FROM categorias ORDER BY descricao";
                    MySqlDataAdapter da = new MySqlDataAdapter(query, conn);
                    da.Fill(dt);
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao carregar categorias: " + ex.Message);
            }
            return dt;
        }


        // Método para editar um produto
        public void EditarProduto(int id, string nome, string categoria, int quantidade, DateTime validade, string codBarras)
        {
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    conn.Open();

                    string query = @"
                UPDATE produtos 
                SET 
                    nome = @nome, 
                    categoria = @categoria, 
                    quantidade = @quantidade, 
                    validade = @validade, 
                    cod_barras = @cod_barras
                WHERE id = @id";

                    MySqlCommand cmd = new MySqlCommand(query, conn);
                    cmd.Parameters.AddWithValue("@nome", nome);
                    cmd.Parameters.AddWithValue("@categoria", categoria);
                    cmd.Parameters.AddWithValue("@quantidade", quantidade);
                    cmd.Parameters.AddWithValue("@validade", validade);
                    cmd.Parameters.AddWithValue("@cod_barras", codBarras);
                    cmd.Parameters.AddWithValue("@id", id);

                    cmd.ExecuteNonQuery();
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao editar produto: " + ex.Message);
            }
        }

        // Método para excluir um produto
        public void ExcluirProduto(int id)
        {
            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    conn.Open();
                    string query = "DELETE FROM produtos WHERE id = @id";
                    MySqlCommand cmd = new MySqlCommand(query, conn);
                    cmd.Parameters.AddWithValue("@id", id);
                    cmd.ExecuteNonQuery();
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao excluir produto: " + ex.Message);
            }
        }

        public static DataTable PesquisarProdutos(string filtro)
        {
            DataTable tabela = new DataTable();

            using (var conn = ConexaoDB.ObterConexao())
            {
                conn.Open();
                string sql = @"SELECT 
    p.id AS id_A, 
    p.nome AS nome_A, 
    p.pcusto AS pcusto_A, 
    p.margem1 AS margem1_A, p.margem2 AS margem2_A, p.margem3 AS margem3_A, 
    p.margem4 AS margem4_A, p.margem5 AS margem5_A,
    p.pvp_iliquido1 AS pvp_iliquido1_A, p.pvp_iliquido2 AS pvp_iliquido2_A, p.pvp_iliquido3 AS pvp_iliquido3_A, 
    p.pvp_iliquido4 AS pvp_iliquido4_A, p.pvp_iliquido5 AS pvp_iliquido5_A,
    p.pvp_liquido1 AS pvp_liquido1_A, p.pvp_liquido2 AS pvp_liquido2_A, p.pvp_liquido3 AS pvp_liquido3_A, 
    p.pvp_liquido4 AS pvp_liquido4_A, p.pvp_liquido5 AS pvp_liquido5_A,
    p.valor_margem1 AS valor_margem1_A, p.valor_margem2 AS valor_margem2_A, p.valor_margem3 AS valor_margem3_A, 
    p.valor_margem4 AS valor_margem4_A, p.valor_margem5 AS valor_margem5_A,
    t.nome AS taxa_nome_A
FROM produtos p
LEFT JOIN taxas t ON p.taxa_id = t.id
WHERE p.id = @filtro OR p.nome LIKE @filtro 
ORDER BY p.id ASC;";



                MySqlCommand cmd = new MySqlCommand(sql, conn);
                filtro = filtro.Replace("'", "''"); // Corrige possíveis erros de SQL Injection
                cmd.Parameters.AddWithValue("@filtro", "%" + filtro + "%");


                using (var adapter = new MySqlDataAdapter(cmd))
                {
                    adapter.Fill(tabela);
                }
            }

            return tabela;
        }

        public void EditarPrecosProduto(int id, decimal pcusto, decimal[] margem, decimal[] pvpIliquido, decimal[] pvpLiquido, decimal[] valorMargem, int taxaId)
        {
            if (id <= 0)
            {
                MessageBox.Show("ID do produto inválido!", "Erro", MessageBoxButtons.OK, MessageBoxIcon.Error);
                return;
            }

            try
            {
                using (MySqlConnection conn = ConexaoDB.ObterConexao())
                {
                    conn.Open();

                    string query = @"
            UPDATE produtos 
            SET 
                pcusto = @pcusto, 
                margem1 = @margem1, margem2 = @margem2, margem3 = @margem3, margem4 = @margem4, margem5 = @margem5,
                pvp_iliquido1 = @pvp_iliquido1, pvp_iliquido2 = @pvp_iliquido2, pvp_iliquido3 = @pvp_iliquido3, pvp_iliquido4 = @pvp_iliquido4, pvp_iliquido5 = @pvp_iliquido5,
                pvp_liquido1 = @pvp_liquido1, pvp_liquido2 = @pvp_liquido2, pvp_liquido3 = @pvp_liquido3, pvp_liquido4 = @pvp_liquido4, pvp_liquido5 = @pvp_liquido5,
                valor_margem1 = @valor_margem1, valor_margem2 = @valor_margem2, valor_margem3 = @valor_margem3, valor_margem4 = @valor_margem4, valor_margem5 = @valor_margem5,
                taxa_id = @taxa_id
            WHERE id = @id";

                    using (MySqlCommand cmd = new MySqlCommand(query, conn))
                    {
                        cmd.Parameters.AddWithValue("@pcusto", pcusto);
                        cmd.Parameters.AddWithValue("@margem1", margem[0]);
                        cmd.Parameters.AddWithValue("@margem2", margem[1]);
                        cmd.Parameters.AddWithValue("@margem3", margem[2]);
                        cmd.Parameters.AddWithValue("@margem4", margem[3]);
                        cmd.Parameters.AddWithValue("@margem5", margem[4]);
                        cmd.Parameters.AddWithValue("@pvp_iliquido1", pvpIliquido[0]);
                        cmd.Parameters.AddWithValue("@pvp_iliquido2", pvpIliquido[1]);
                        cmd.Parameters.AddWithValue("@pvp_iliquido3", pvpIliquido[2]);
                        cmd.Parameters.AddWithValue("@pvp_iliquido4", pvpIliquido[3]);
                        cmd.Parameters.AddWithValue("@pvp_iliquido5", pvpIliquido[4]);
                        cmd.Parameters.AddWithValue("@pvp_liquido1", pvpLiquido[0]);
                        cmd.Parameters.AddWithValue("@pvp_liquido2", pvpLiquido[1]);
                        cmd.Parameters.AddWithValue("@pvp_liquido3", pvpLiquido[2]);
                        cmd.Parameters.AddWithValue("@pvp_liquido4", pvpLiquido[3]);
                        cmd.Parameters.AddWithValue("@pvp_liquido5", pvpLiquido[4]);
                        cmd.Parameters.AddWithValue("@valor_margem1", valorMargem[0]);
                        cmd.Parameters.AddWithValue("@valor_margem2", valorMargem[1]);
                        cmd.Parameters.AddWithValue("@valor_margem3", valorMargem[2]);
                        cmd.Parameters.AddWithValue("@valor_margem4", valorMargem[3]);
                        cmd.Parameters.AddWithValue("@valor_margem5", valorMargem[4]);

                        // Tratamento seguro para taxa_id (evita problemas caso seja nulo)
                        if (taxaId > 0)
                        {
                            cmd.Parameters.AddWithValue("@taxa_id", taxaId);
                        }
                        else
                        {
                            cmd.Parameters.AddWithValue("@taxa_id", DBNull.Value);
                        }

                        cmd.Parameters.AddWithValue("@id", id);

                        cmd.ExecuteNonQuery();
                    }
                }
            }
            catch (Exception ex)
            {
                throw new Exception("Erro ao editar preços do produto: " + ex.Message);
            }
        }


    }
}