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 GetAllTreeList() { using (IDbConnection conn = CommHelper.GetSqlConnection()) { return conn.Query("select * from xcximg", new { @zt = 1 }).ToList(); } } public List GetAllList() { using (IDbConnection conn = CommHelper.GetSqlConnection()) { return conn.Query("select * from xcximg where zt=1 order by sort desc").ToList(); } } public List 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(sql, new { key = "%" + key + "%" }).ToList(); } } public xcximgModel GetmodelByName(string name) { using (IDbConnection conn = CommHelper.GetSqlConnection()) { List model = conn.Query("select * from xcximg where title=@name", new { name = name }).ToList(); if (model.Any()) { return model[0]; } return null; } } public List GetAllList(string id) { using (IDbConnection conn = CommHelper.GetSqlConnection()) { string param = ""; if (id != "") { param = " and id=@id"; } return conn.Query("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 }; } } } } }