tijian_tieying/web/dccdc.DAL/xcximgDal.cs

125 lines
4.0 KiB
C#
Raw Permalink Normal View History

2025-02-20 12:14:39 +08:00
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 xcximgDal
{
public List<xcximgModel> GetAllTreeList()
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
return conn.Query<xcximgModel>("select * from xcximg", new { @zt = 1 }).ToList();
}
}
public List<xcximgModel> GetAllList()
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
return conn.Query<xcximgModel>("select * from xcximg where zt=1 order by sort desc").ToList();
}
}
public List<xcximgModel> GetListByKey(string key)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string sql = "select * from xcximg where zt=1";
if (!string.IsNullOrEmpty(key))
{
sql += " and title like @key";
}
return conn.Query<xcximgModel>(sql, new { key = "%" + key + "%" }).ToList();
}
}
public xcximgModel GetmodelByName(string name)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
List<xcximgModel> model = conn.Query<xcximgModel>("select * from xcximg where title=@name", new { name = name }).ToList();
if (model.Any())
{
return model[0];
}
return null;
}
}
public List<xcximgModel> GetAllList(string id)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string param = "";
if (id != "")
{
param = " and id=@id";
}
return conn.Query<xcximgModel>("select * from xcximg where 1=1" + param, new { @id = id }).ToList();
}
}
public bool Add(xcximgModel model)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string sql = @"INSERT INTO [dccdc].[dbo].[xcximg]
([path]
,[url]
,[sort]
,[zt])
VALUES
(@path
,@url
,@sort
,@zt)";
return (conn.Execute(sql, model) != 0 ? true : false);
}
}
public bool Update(xcximgModel model)
{
using (IDbConnection conn = CommHelper.GetSqlConnection())
{
string sql = @"UPDATE [dccdc].[dbo].[xcximg]
SET [path] = @path
,[url] = @url
,[sort] = @sort
,[zt] = @zt
WHERE id=@id";
return (conn.Execute(sql, model) != 0 ? true : false);
}
}
public object delete(string id)
{
string sql = "delete from xcximg 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 };
}
}
}
}
}