using System;
using System.Collections.Generic;
using System.Data;
using System.Drawing.Printing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using CommonHelper;
using Dapper;
using GasolineBlend.Entity;
using Google.Protobuf.WellKnownTypes;
using Microsoft.Office.Interop.Excel;
using MySql.Data.MySqlClient;

namespace GasolineBlend.DAL
{
    public class DefaultCompanyDAL : BaseMySQLDAL
    {
        public List<DefaultCompany> GetDefaultCompanyIsId(int UserId)
        {
            using (IDbConnection connection = new MySqlConnection(connectionString))
            {
                var sql = $"SELECT id,company,userid,createtime FROM defaultcompany WHERE userid= '{UserId}'";
                return connection.Query<DefaultCompany>(sql).ToList();
            }
        }
        public bool UpdateDefaultCompany(DefaultCompany defaultCompany)
        {
            using (IDbConnection connection = new MySqlConnection(connectionString))
            {
                var sql = @"
               UPDATE defaultcompany
               SET
                   company = @Company,
                   createtime = NOW()
               WHERE userid = @UserId";

                var parameters = new
                {
                    Company = defaultCompany.Company,
                    UserId = defaultCompany.UserId
                };

                connection.Open(); // 打开数据库连接
                int affectedRows = connection.Execute(sql, parameters); // 执行更新操作
                return affectedRows > 0;
            }
        }

        public bool AddDefaultCompany(int UserId)
        {
            using (IDbConnection connection = new MySqlConnection(connectionString))
            {
                var sql = @"
                INSERT INTO defaultcompany (company,createtime,userid)
                VALUES (NULL,NOW(),@UserId)";

                var parameters = new
                {
                    UserId = UserId
                };

                connection.Open(); // 打开数据库连接
                int affectedRows = connection.Execute(sql, parameters); // 执行更新操作
                return affectedRows > 0;
            }
        }

    }
}