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