Merge branch 'feature-dgy-调整消费者信息添加条件' into DuGuYang

Service/Main1/ConsumersService.cs

@@ -0,0 +1,235 @@
+/*
+ * 消费者
+ */
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Data;
+using MySystem.Models.Main1;
+using Library;
+using LitJson;
+
+namespace MySystem.Service.Main1
+{
+    public class ConsumersService
+    {
+        static string _conn = ConfigurationManager.AppSettings["ZsSqlConnStr"].ToString();
+
+        /// <summary>
+        /// 查询列表
+        /// </summary>
+        /// <param name="relationData">关联表</param>
+        /// <param name="condition">查询条件(sql语句)</param>
+        /// <param name="count">总数（输出）</param>
+        /// <param name="page">页码</param>
+        /// <param name="limit">每页条数</param>
+        /// <returns></returns>
+        public static List<Dictionary<string, object>> List(List<RelationData> relationData, string condition, out int count, int page = 1, int limit = 30, string orderBy = "Sort desc,Id desc")
+        {
+            List<string> fields = new List<string>(); //要显示的列
+            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<string, object> obj = new DbService(AppConfig.Base.mainTables, _conn).IndexData("Consumers", relationData, orderBy, page, limit, condition, fields);
+            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
+            count = int.Parse(obj["count"].ToString());
+            return diclist;
+        }
+        public static List<Dictionary<string, object>> List(List<RelationData> relationData, string condition, int page = 1, int limit = 30, string orderBy = "Sort desc,Id desc")
+        {
+            List<string> fields = new List<string>(); //要显示的列
+            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<string, object> obj = new DbService(AppConfig.Base.mainTables, _conn).IndexData("Consumers", relationData, orderBy, page, limit, condition, fields);
+            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
+            return diclist;
+        }
+
+        /// <summary>
+        /// 查询一条记录
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static Consumers Query(int Id)
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            Consumers editData = db.Consumers.FirstOrDefault(m => m.Id == Id) ?? new Consumers();
+            db.Dispose();
+            return editData;
+        }
+        public static Consumers Query(string condition, string fields = "*")
+        {
+            var consumers = new DbService(AppConfig.Base.mainTables, _conn).Query(fields, "Consumers", condition);
+            if (consumers.Count > 0)
+            {
+                return Newtonsoft.Json.JsonConvert.DeserializeObject<Consumers>(Newtonsoft.Json.JsonConvert.SerializeObject(consumers));
+            }
+            return new Consumers();
+        }
+
+        public static decimal Sum(string condition, string field)
+        {
+            var dt = new DbService(AppConfig.Base.mainTables, _conn).Query("Sum(" + field + ") " + field, "Consumers", condition);
+            decimal amount = 0;
+            if (dt.Count > 0)
+            {
+                amount = decimal.Parse(dt[field].ToString());
+            }
+            return amount;
+        }
+
+        /// <summary>
+        /// 查询记录数
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static int Count(string condition = "", string field = "Id")
+        {
+            var dt = new DbService(AppConfig.Base.mainTables, _conn).Query("Count(" + field + ") " + field, "Consumers", condition);
+            int result = 0;
+            if (dt.Count > 0)
+            {
+                result = int.Parse(dt[field].ToString());
+            }
+            return result;
+        }
+
+        /// <summary>
+        /// 查询是否存在
+        /// </summary>
+        /// <param name="WechatOpenId">WechatOpenId</param>
+        /// <returns></returns>
+        public static bool Exist(string WechatOpenId)
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            bool check = db.Consumers.Any(m => m.WechatOpenId == WechatOpenId);
+            db.Dispose();
+            return check;
+        }
+
+        /// <summary>
+        /// 添加数据
+        /// </summary>
+        /// <param name="Fields">要设置的字段</param>
+        /// <returns></returns>
+        public static AppResultJson Add(Dictionary<string, object> fields, bool check = true)
+        {
+            if (check)
+            {
+            }
+            int Id = new DbService(AppConfig.Base.mainTables, _conn).Add("Consumers", fields, 0);
+            return new AppResultJson() { Status = "1", Data = Id };
+        }
+
+        /// <summary>
+        /// 修改数据
+        /// </summary>
+        /// <param name="Fields">要设置的字段</param>
+        /// <param name="Id">主键Id</param>
+        public static AppResultJson Edit(Dictionary<string, object> fields, int Id, bool check = true)
+        {
+            if (check)
+            {
+                if (string.IsNullOrEmpty(fields["NickName"].ToString()))
+                {
+                    return new AppResultJson() { Status = "-1", Info = "请填写昵称" };
+                }
+
+            }
+            new DbService(AppConfig.Base.mainTables, _conn).Edit("Consumers", fields, Id);
+            return new AppResultJson() { Status = "1", Data = Id };
+        }
+
+        /// <summary>
+        /// 逻辑删除
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        public static void Remove(int Id)
+        {
+            Dictionary<string, object> fields = new Dictionary<string, object>();
+            fields.Add("Status", -1);
+            new DbService(AppConfig.Base.mainTables, _conn).Edit("Consumers", fields, Id);
+        }
+
+        /// <summary>
+        /// 删除数据
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        public static void Delete(int Id)
+        {
+            new DbService(AppConfig.Base.mainTables, _conn).Delete("Consumers", Id);
+        }
+
+        /// <summary>
+        /// 排序
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <param name="Sort">排序序号</param>
+        public static void Sort(int Id, int Sort)
+        {
+            new DbService(AppConfig.Base.mainTables, _conn).Sort("Consumers", Sort, Id);
+        }
+
+        /// <summary>
+        /// 导入数据
+        /// </summary>
+        /// <param name="ExcelData">json数据</param>
+        public static 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();
+        }
+
+        /// <summary>
+        /// 导出excel表格
+        /// </summary>
+        /// <param name="fields">查询条件(单个字段)</param>
+        /// <param name="condition">查询条件(sql语句)</param>
+        /// <returns></returns>
+        // public static void ExportExcel(List<RelationData> relationData, string condition)
+        // {
+
+        // }
+    }
+}