tijian_tieying/web/dccdc.DAL/dicsDal.cs
2025-02-20 12:14:39 +08:00

128 lines
4.1 KiB
C#

using Dapper;
using dccdc.Models;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace dccdc.DAL
{
public class dicsDal
{
public List<dicsModel> GetAllTreeList()
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
return conn.Query<dicsModel>("select * from dics", new { @zt = 1 }).ToList();
}
}
public List<dicsModel> GetAllList()
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
return conn.Query<dicsModel>("select * from dics where zt=1 ").ToList();
}
}
public List<dicsModel> GetListByKey(string key)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string sql = "select * from dics where zt=1";
if (!string.IsNullOrEmpty(key))
{
sql += " and remark like @key";
}
return conn.Query<dicsModel>(sql, new { key = "%" + key + "%" }).ToList();
}
}
public dicsModel GetmodelByName(string name)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
List<dicsModel> model = conn.Query<dicsModel>("select * from dics where key=@name", new { name = name }).ToList();
if (model.Any())
{
return model[0];
}
return null;
}
}
public List<dicsModel> GetAllList(string id)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string param = "";
if (id != "")
{
param = " and id=@id";
}
return conn.Query<dicsModel>("select * from dics where 1=1" + param, new { @id = id }).ToList();
}
}
public bool Add(dicsModel model)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string sql = @"INSERT INTO [dccdc].[dbo].[dics]
([key]
,[value]
,[remark]
,[addtime]
,[zt])
VALUES
(@key
,@value
,@remark
,@addtime
,@zt)";
return (conn.Execute(sql, model) != 0 ? true : false);
}
}
public bool Update(dicsModel model)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string sql = @"UPDATE [dccdc].[dbo].[dics]
SET [key] = @key
,[value] = @value
,[remark] = @remark
,[addtime] = @addtime
,[zt] = @zt
WHERE id=@id";
return (conn.Execute(sql, model) != 0 ? true : false);
}
}
public object delete(string id)
{
string sql = "delete from dics where id=@id";
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
try
{
int result = conn.Execute(sql, new { id = id });
if (result > 0)
{
return new { State = 1, Message = "操作成功!" };
}
else
return new { State = 0, Message = "操作失败!" };
}
catch (Exception ex)
{
return new { State = 0, Message = ex.Message };
}
}
}
}
}