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 PushDataDAL : BaseMySQLDAL
    {
        public List<PushDataPage> GetPushDataIsId(int UserId)
        {
            using (IDbConnection connection = new MySqlConnection(connectionString))
            {
                var sql = $"SELECT id,ispolicy,isdeclarationnotice,ispublicannouncement,islawsandregulations,isemailpush,email,userid,modificationtime,region,keyword FROM pushdata WHERE userid= '{UserId}'";
                return connection.Query<PushDataPage>(sql).ToList();
            }
        }
        public bool UpdatePushData(PushDataPage pushDataPage)
        {
            using (IDbConnection connection = new MySqlConnection(connectionString))
            {
                var sql = @"
               UPDATE pushdata
               SET
                   ispolicy = @IsPolicy,
                   isdeclarationnotice = @IsDeclarationNotice,
                   ispublicannouncement = @IsPublicAnnouncement,
                   islawsandregulations = @IsLawsAndRegulations,
                   isemailpush = @IsEmailPush,
                   email = @Email,
                   keyword = @Keyword,
                   region = @Region,
                   modificationtime = NOW()
               WHERE userid = @UserId";
                 
                var parameters = new
                {
                    IsPolicy = pushDataPage.IsPolicy,
                    IsDeclarationNotice = pushDataPage.IsDeclarationNotice,
                    IsPublicAnnouncement = pushDataPage.IsPublicAnnouncement,
                    IsLawsAndRegulations = pushDataPage.IsLawsAndRegulations,
                    IsEmailPush = pushDataPage.IsEmailPush,
                    Email = pushDataPage.Email,
                    Keyword = pushDataPage.Keyword,
                    Region = pushDataPage.Region,
                    UserId = pushDataPage.UserId
                };

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

        public bool AddPushData(int UserId)
        {
            using (IDbConnection connection = new MySqlConnection(connectionString))
            {
                var sql = @"
                INSERT INTO pushdata (ispolicy, isdeclarationnotice, ispublicannouncement, islawsandregulations, isemailpush, inbox,modificationtime,region,keyword,userid)
                VALUES ( 0, 0, 0,0, 0,NULL,NOW(),NULL,NULL,@UserId)";

                var parameters = new
                {
                    UserId = UserId
                };

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

    }
}