/* * 消费者 */ using System; using System.Collections.Generic; using System.Linq; using System.Data; using MySystem.Models.Main; using Library; using LitJson; namespace MySystem.Service.Main { public class ConsumersService { string _conn = ""; public ConsumersService() { _conn = ConfigurationManager.AppSettings["SqlConnStr"].ToString(); } /// /// 查询列表 /// /// 关联表 /// 查询条件(sql语句) /// 总数(输出) /// 页码 /// 每页条数 /// public List> List(List relationData, string condition, out int count, int page = 1, int limit = 30, string orderBy = "Sort desc,Id desc") { List fields = new List(); //要显示的列 fields.Add("Id"); fields.Add("CreateDate"); //添加时间 fields.Add("Status"); //状态 fields.Add("NickName"); //昵称 fields.Add("Mobile"); //手机号 fields.Add("TotalDividend"); //累计分红 fields.Add("TotalIntegral"); //累计积分 fields.Add("CurIntgegral"); //当前积分 fields.Add("WechatUnionid"); //微信Unionid fields.Add("TotalAmount"); //累计消费金额 fields.Add("TotalConsumCount"); //累计消费次数 fields.Add("LastConsumDate"); //最近消费时间 fields.Add("WeChatPayFlag"); //微信付款标记 fields.Add("AlipayFlag"); //支付宝付款标记 fields.Add("CardFlag"); //是否领取会员卡 Dictionary obj = new DbService(AppConfig.Base.dbTables, _conn).IndexData("Consumers", relationData, orderBy, page, limit, condition, fields); List> diclist = obj["data"] as List>; count = int.Parse(obj["count"].ToString()); return diclist; } public List> List(List relationData, string condition, int page = 1, int limit = 30, string orderBy = "Sort desc,Id desc") { List fields = new List(); //要显示的列 fields.Add("Id"); fields.Add("CreateDate"); //添加时间 fields.Add("Status"); //状态 fields.Add("NickName"); //昵称 fields.Add("Mobile"); //手机号 fields.Add("TotalDividend"); //累计分红 fields.Add("TotalIntegral"); //累计积分 fields.Add("CurIntgegral"); //当前积分 fields.Add("WechatUnionid"); //微信Unionid fields.Add("TotalAmount"); //累计消费金额 fields.Add("TotalConsumCount"); //累计消费次数 fields.Add("LastConsumDate"); //最近消费时间 fields.Add("WeChatPayFlag"); //微信付款标记 fields.Add("AlipayFlag"); //支付宝付款标记 fields.Add("CardFlag"); //是否领取会员卡 Dictionary obj = new DbService(AppConfig.Base.dbTables, _conn).IndexData("Consumers", relationData, orderBy, page, limit, condition, fields); List> diclist = obj["data"] as List>; return diclist; } /// /// 查询一条记录 /// /// 主键Id /// public Consumers Query(int Id) { WebCMSEntities db = new WebCMSEntities(); Consumers editData = db.Consumers.FirstOrDefault(m => m.Id == Id) ?? new Consumers(); db.Dispose(); return editData; } /// /// 查询记录数 /// /// 主键Id /// public int Count(string condition = "") { int result = 0; DataTable dt = CustomerSqlConn.dtable("select count(Id) from Consumers where 1=1" + condition, _conn); if(dt.Rows.Count > 0) { result = int.Parse(function.CheckInt(dt.Rows[0][0].ToString())); } return result; } /// /// 查询是否存在 /// /// 主键Id /// public bool Exist(int Id) { WebCMSEntities db = new WebCMSEntities(); bool check = db.Consumers.Any(m => m.Id == Id); db.Dispose(); return check; } /// /// 添加数据 /// /// 要设置的字段 /// public AppResultJson Add(Dictionary fields, bool check = true) { if(check) { if (string.IsNullOrEmpty(fields["NickName"].ToString())) { return new AppResultJson() { Status = "-1", Info = "请填写昵称" }; } } int Id = new DbService(AppConfig.Base.dbTables, _conn).Add("Consumers", fields, 0); return new AppResultJson(){ Status = "1", Data = Id }; } /// /// 修改数据 /// /// 要设置的字段 /// 主键Id public AppResultJson Edit(Dictionary fields, int Id, bool check = true) { if(check) { if (string.IsNullOrEmpty(fields["NickName"].ToString())) { return new AppResultJson() { Status = "-1", Info = "请填写昵称" }; } } new DbService(AppConfig.Base.dbTables, _conn).Edit("Consumers", fields, Id); return new AppResultJson(){ Status = "1", Data = Id }; } /// /// 逻辑删除 /// /// 主键Id public void Remove(int Id) { Dictionary fields = new Dictionary(); fields.Add("Status", -1); new DbService(AppConfig.Base.dbTables, _conn).Edit("Consumers", fields, Id); } /// /// 删除数据 /// /// 主键Id public void Delete(int Id) { new DbService(AppConfig.Base.dbTables, _conn).Delete("Consumers", Id); } /// /// 排序 /// /// 主键Id /// 排序序号 public void Sort(int Id, int Sort) { new DbService(AppConfig.Base.dbTables, _conn).Sort("Consumers", Sort, Id); } /// /// 导入数据 /// /// json数据 public void Import(string ExcelData) { WebCMSEntities db = new WebCMSEntities(); JsonData list = JsonMapper.ToObject(ExcelData); for (int i = 1; i < list.Count;i++ ) { JsonData dr = list[i]; db.Consumers.Add(new Consumers() { CreateDate = DateTime.Now, UpdateDate = DateTime.Now, }); db.SaveChanges(); } db.Dispose(); } /// /// 导出excel表格 /// /// 查询条件(单个字段) /// 查询条件(sql语句) /// // public void ExportExcel(List relationData, string condition) // { // } } }