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;
|
}
|
}
|
|
}
|
}
|
