坐席组管理

代码/System.Common/IRepositories/IRepository.cs

@@ -21,6 +21,7 @@ namespace System.Common
         /// <returns></returns>
         Task<List<T>> GetList();
         Task<List<T>> GetListALL(Expression<Func<T, bool>> whereExpression);
+        Task<List<T>> GetListALL(List<IConditionalModel> conModels, string orderby);
         Task<List<T>> GetListALL(Expression<Func<T, bool>> whereExpression, Expression<Func<T, object>> orderExpression, OrderByType ordertype = OrderByType.Asc);
 
         /// <summary>
@@ -28,6 +29,9 @@ namespace System.Common
         /// </summary>
         /// <returns></returns>
         Task<PageData<T>> GetListByPage(List<IConditionalModel> conModels, PageModel pagemodel);
+        Task<PageData<T>> GetListByPage(List<IConditionalModel> conModels, PageModel pagemodel, string orderby);
+        Task<PageData<T>> GetListByPage(Expression<Func<T, bool>> whereExpression, PageModel pagemodel);
+        Task<PageData<T>> GetListByPage(Expression<Func<T, bool>> whereExpression, PageModel pagemodel, string orderby);
 
         Task<T> GetSingle(Expression<Func<T, bool>> whereExpression);
 

代码/System.Common/Repositories/BaseRepository.cs

@@ -7,7 +7,7 @@ using System.Threading.Tasks;
 
 namespace System.Common
 {
-    public class BaseRepository<T> : BaseContext,IRepository<T> where T : class, new()
+    public class BaseRepository<T> : BaseContext, IRepository<T> where T : class, new()
     {
         //public SimpleClient<T> CurrentDb => new SimpleClient<T>(Db);
 
@@ -16,12 +16,12 @@ namespace System.Common
         /// </summary>
         /// <param name="whereExpression"></param>
         /// <returns></returns>
-        public async Task<int> GetCount(Expression<Func<T, bool>> whereExpression=null)
+        public async Task<int> GetCount(Expression<Func<T, bool>> whereExpression = null)
         {
             if (whereExpression != null)
-                return await Db.Queryable<T>().CountAsync(whereExpression);
+                return await Db.Queryable<T>().With(SqlWith.NoLock).CountAsync(whereExpression);
             else
-                return await Db.Queryable<T>().CountAsync();
+                return await Db.Queryable<T>().With(SqlWith.NoLock).CountAsync();
         }
 
         /// <summary>
@@ -30,16 +30,22 @@ namespace System.Common
         /// <returns></returns>
         public async Task<List<T>> GetList()
         {
-            return await Db.Queryable<T>().ToListAsync();
+            return await Db.Queryable<T>().With(SqlWith.NoLock).ToListAsync();
             //return CurrentDb.GetList();
         }
         public async Task<List<T>> GetListALL(Expression<Func<T, bool>> whereExpression)
         {
-            return await Db.Queryable<T>().Where(whereExpression).ToListAsync();
+            return await Db.Queryable<T>().With(SqlWith.NoLock).Where(whereExpression).ToListAsync();
         }
+
+        public async Task<List<T>> GetListALL(List<IConditionalModel> conModels, string orderby)
+        {
+            return await Db.Queryable<T>().With(SqlWith.NoLock).Where(conModels).OrderBy(orderby).ToListAsync();
+        }
+
         public async Task<List<T>> GetListALL(Expression<Func<T, bool>> whereExpression, Expression<Func<T, object>> orderExpression, OrderByType ordertype = OrderByType.Asc)
         {
-            return await Db.Queryable<T>().Where(whereExpression).OrderBy(orderExpression,ordertype).ToListAsync();
+            return await Db.Queryable<T>().With(SqlWith.NoLock).Where(whereExpression).OrderBy(orderExpression,ordertype).ToListAsync();
         }
 
         /// <summary>
@@ -48,9 +54,36 @@ namespace System.Common
         /// <param name="conModels"></param>
         /// <param name="pagemodel"></param>
         /// <returns></returns>
+        public async Task<PageData<T>> GetListByPage(List<IConditionalModel> conModels, PageModel pagemodel,string orderby)
+        {
+            var list= await Db.Queryable<T>().With(SqlWith.NoLock).Where(conModels).OrderBy(orderby).ToPageListAsync(pagemodel.PageIndex, pagemodel.PageSize, pagemodel.PageCount);
+            PageData<T> pd = new PageData<T>();
+            pd.Rows = list;
+            pd.Totals = pagemodel.PageCount;
+            return pd;// CurrentDb.GetPageList(conModels, pagemodel);
+        }
+
         public async Task<PageData<T>> GetListByPage(List<IConditionalModel> conModels, PageModel pagemodel)
         {
-            var list= await Db.Queryable<T>().With(SqlWith.NoLock).Where(conModels).ToPageListAsync(pagemodel.PageIndex, pagemodel.PageSize, pagemodel.PageCount);
+            var list = await Db.Queryable<T>().With(SqlWith.NoLock).Where(conModels).ToPageListAsync(pagemodel.PageIndex, pagemodel.PageSize, pagemodel.PageCount);
+            PageData<T> pd = new PageData<T>();
+            pd.Rows = list;
+            pd.Totals = pagemodel.PageCount;
+            return pd;// CurrentDb.GetPageList(conModels, pagemodel);
+        }
+
+        public async Task<PageData<T>> GetListByPage(Expression<Func<T, bool>> whereExpression, PageModel pagemodel)
+        {
+            var list = await Db.Queryable<T>().With(SqlWith.NoLock).Where(whereExpression).ToPageListAsync(pagemodel.PageIndex, pagemodel.PageSize, pagemodel.PageCount);
+        PageData<T> pd = new PageData<T>();
+        pd.Rows = list;
+            pd.Totals = pagemodel.PageCount;
+            return pd;// CurrentDb.GetPageList(conModels, pagemodel);
+        }
+
+        public async Task<PageData<T>> GetListByPage(Expression<Func<T, bool>> whereExpression, PageModel pagemodel, string orderby)
+        {
+            var list = await Db.Queryable<T>().With(SqlWith.NoLock).Where(whereExpression).OrderBy(orderby).ToPageListAsync(pagemodel.PageIndex, pagemodel.PageSize, pagemodel.PageCount);
             PageData<T> pd = new PageData<T>();
             pd.Rows = list;
             pd.Totals = pagemodel.PageCount;
@@ -59,7 +92,7 @@ namespace System.Common
 
         public async Task<T> GetSingle(Expression<Func<T, bool>> whereExpression)
         {
-            return await Db.Queryable<T>().Where(whereExpression).SingleAsync();
+            return await Db.Queryable<T>().With(SqlWith.NoLock).Where(whereExpression).SingleAsync();
             //return CurrentDb.GetSingle(whereExpression);
         }
 

代码/TVShoppingCallCenter_ZLJ/Controllers/System/SeatGroupController.cs

@@ -0,0 +1,302 @@
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.IRepositories;
+using System.Linq;
+using System.Linq.Expressions;
+using System.Model;
+using System.Security.Claims;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using SqlSugar;
+
+namespace TVShoppingCallCenter_ZLJ.Controllers.System
+{
+    [Authorize]
+    [Produces("application/json")]
+    [Route("api/[controller]")]
+    public class SeatGroupController : BaseController
+    {
+        private readonly ISys_SeatGroupRepository _sys_seatgroupRepository;
+        public SeatGroupController(ISys_SeatGroupRepository sys_seatgroupRepository)
+        {
+            _sys_seatgroupRepository = sys_seatgroupRepository;
+        }
+        /// <summary>
+        /// 获取坐席组列表
+        /// </summary>
+        /// <param name="filter"></param>
+        /// <returns></returns>
+        [Authorize]
+        [HttpGet("getlistbypage")]
+        public async Task<IActionResult> GetListsByPage(string key, int pageindex = 1, int pagesize = 10)
+        {
+            List<IConditionalModel> conModels = new List<IConditionalModel>();
+            #region 条件筛选
+            conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumDelState.Enabled).ToString() });
+
+            List<IConditionalModel> conModels1 = new List<IConditionalModel>();
+            if (!string.IsNullOrEmpty(key))
+            {
+                conModels.Add(new ConditionalCollections()
+                {
+                    ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
+                    {
+                        new  KeyValuePair<WhereType, ConditionalModel>(WhereType.And, new ConditionalModel() { FieldName = "F_ZXZName", ConditionalType = ConditionalType.Like, FieldValue = key }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_ZXZCode", ConditionalType = ConditionalType.Like, FieldValue = key }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or, new ConditionalModel() { FieldName = "F_ZXAtt", ConditionalType = ConditionalType.Like, FieldValue = key })
+                    }
+                });
+            }
+            #endregion
+            int recordCount = 0;
+            var list = await _sys_seatgroupRepository.GetListByPage(conModels, new PageModel() { PageIndex = pageindex, PageSize = pagesize, PageCount = recordCount }, "F_CreateOn desc");
+
+            return Success("成功", list);
+        }
+
+        [Authorize]
+        [HttpGet("getlist")]
+        public async Task<IActionResult> GetList(string key)
+        {
+            List<IConditionalModel> conModels = new List<IConditionalModel>();
+            #region 条件筛选
+            conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumDelState.Enabled).ToString() });
+
+            if (!string.IsNullOrEmpty(key))
+            {
+                conModels.Add(new ConditionalCollections()
+                {
+                    ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
+                    {
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_ZXZCode", ConditionalType = ConditionalType.Like, FieldValue = key }),
+                        new  KeyValuePair<WhereType, ConditionalModel>(WhereType.Or, new ConditionalModel() { FieldName = "F_ZXZName", ConditionalType = ConditionalType.Like, FieldValue = key }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or, new ConditionalModel() { FieldName = "F_ZXAtt", ConditionalType = ConditionalType.Like, FieldValue = key })
+                    }
+                });
+
+            }
+            #endregion
+            var list = await _sys_seatgroupRepository.GetListALL(conModels, "F_CreateOn desc");
+
+            return Success("根据条件获取数据成功", list);
+        }
+
+        /// <summary>
+        /// 获取实体
+        /// </summary>
+        [Authorize]
+        [HttpGet("getsingle")]
+        public async Task<IActionResult> GetSingle(int id)
+        {
+            if (id > 0)
+            {
+                var dModel = await _sys_seatgroupRepository.GetSingle(x => x.F_ZXZID == id);
+
+                if (dModel != null)
+                {
+                    return Success("获取坐席组成功", dModel);
+                }
+                else
+                {
+                    return Error("获取坐席组失败");
+                }
+            }
+            else
+            {
+                return Error("获取参数失败");
+            }
+        }
+
+        /// <summary>
+        /// 添加坐席组
+        /// </summary>
+        [Authorize]
+        [HttpPost("add")]
+        public async Task<IActionResult> Add(string zxzcode, string zxzname, string zxatt,
+            string whwdkey, string whbdkey, int ivrkey, string outcallnum, string des)
+        {
+            T_Sys_SeatGroup clmodel = new T_Sys_SeatGroup();
+            if (await GetExistByCodeAsync(zxzcode, 0) || await GetExistByNameAsync(zxzname, 0))
+            {
+                return Error("坐席组编号和名称必须唯一，请重新输入！");
+            }
+            if (!string.IsNullOrWhiteSpace(zxzcode))
+                clmodel.F_ZXZCode = zxzcode.Trim();
+            else
+            {
+                return Error("编号不能为空");
+            }
+            if (!string.IsNullOrWhiteSpace(zxzname))
+                clmodel.F_ZXZName = zxzname.Trim();
+            else
+            {
+                return Error("名称不能为空");
+            }
+            if (!string.IsNullOrWhiteSpace(zxatt))
+                clmodel.F_ZXAtt = zxatt.Trim();
+            else
+            {
+                return Error("坐席地区号不能为空");
+            }
+            if (!string.IsNullOrWhiteSpace(whwdkey))
+                clmodel.F_WHWDKey = whwdkey.Trim();
+            else
+            {
+                return Error("外呼外地前缀不能为空");
+            }
+            if (!string.IsNullOrWhiteSpace(whbdkey))
+                clmodel.F_WHBDKey = whbdkey.Trim();
+            else
+            {
+                return Error("外呼本地前缀不能为空");
+            }
+            if (!ValidateString.IsNumberStr(whwdkey.Trim().ToString()))
+            {
+                return Error("外呼外地前缀必须为数字");
+            }
+            if (!ValidateString.IsNumberStr(whbdkey.Trim().ToString()))
+            {
+                return Error("外呼本地前缀必须为数字");
+            }
+
+            clmodel.F_IVRKey = ivrkey;
+            clmodel.F_Des = des;
+            clmodel.F_CreateBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value; //"8000";
+            clmodel.F_CreateOn = DateTime.Now;
+            clmodel.F_State = (int)EnumDelState.Enabled;
+
+            var res = await _sys_seatgroupRepository.Add(clmodel);
+            if (res > 0)
+                return Success("坐席组保存成功");
+            else
+            {
+                return Error("坐席组保存失败");
+            }
+        }
+
+        /// <summary>
+        /// 修改坐席组
+        /// </summary>
+        [Authorize]
+        [HttpPost("update")]
+        public async Task<IActionResult> Edit(int id, string zxzcode, string zxzname, string zxatt,
+            string whwdkey, string whbdkey, int ivrkey, string outcallnum, string des)
+        {
+            if (id > 0)
+            {
+                if (await GetExistByCodeAsync(zxzcode, id) || await GetExistByNameAsync(zxzname, id))
+                {
+                    return Error("坐席组编号和名称必须唯一，请重新输入！");
+                }
+                if (string.IsNullOrWhiteSpace(whwdkey))
+                    return Error("外呼外地前缀不能为空");
+                if (string.IsNullOrWhiteSpace(whbdkey))
+                    return Error("外呼本地前缀不能为空");
+
+                if (!ValidateString.IsNumberStr(whwdkey.Trim().ToString()))
+                {
+                    return Error("外呼外地前缀必须为数字");
+                }
+                if (!ValidateString.IsNumberStr(whbdkey.Trim().ToString()))
+                {
+                    return Error("外呼本地前缀必须为数字");
+                }
+
+                var res = false;
+                var clmodel = await _sys_seatgroupRepository.GetSingle(x => x.F_ZXZID == id);
+                if (clmodel != null)
+                {
+                    if (!string.IsNullOrWhiteSpace(zxzcode))
+                        clmodel.F_ZXZCode = zxzcode.Trim();
+                    if (!string.IsNullOrWhiteSpace(zxzname))
+                        clmodel.F_ZXZName = zxzname.Trim();
+                    if (!string.IsNullOrWhiteSpace(zxatt))
+                        clmodel.F_ZXAtt = zxatt.Trim();
+                    if (!string.IsNullOrWhiteSpace(whwdkey))
+                        clmodel.F_WHWDKey = whwdkey.Trim();
+                    if (!string.IsNullOrWhiteSpace(whbdkey))
+                        clmodel.F_WHBDKey = whbdkey.Trim();
+
+                    clmodel.F_IVRKey = ivrkey;
+                    if (!string.IsNullOrWhiteSpace(des))
+                        clmodel.F_Des = des;
+
+                    clmodel.F_LastModifyBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value; //"8000";
+                    clmodel.F_LastModifyOn = DateTime.Now;
+
+                    res = await _sys_seatgroupRepository.Update(clmodel);
+                }
+                if (res)
+                    return Success("坐席组保存成功");
+                else
+                {
+                    return Error("坐席组保存失败");
+                }
+            }
+            else
+                return Error("请选择要编辑的坐席组");
+        }
+
+        [Authorize]
+        [HttpPost("delete")]
+        public async Task<IActionResult> Remove(int[] ids)
+        {
+            //使用逻辑删除
+            //物理删除的数据无法恢复
+            var res = 0;
+            if (ids != null && ids.Length > 0)
+            {
+                foreach (var item in ids)
+                {
+                    var ml = await _sys_seatgroupRepository.GetSingle(x => x.F_ZXZID == item);
+                    ml.F_State = (int)EnumDelState.Delete;
+                    if (await _sys_seatgroupRepository.Update(ml))
+                        res += 1;
+                }
+                if (res == ids.Length)
+                    return Success("删除成功");
+                else if (res > 0 && res < ids.Length)
+                    return Error("部分删除失败，请查看后重新操作");
+                else
+                    return Error("删除失败，请查看后重新操作");
+            }
+            else
+                return Error("请选择要删除的记录");
+        }
+
+        #region 私有方法
+        /// <summary>
+        /// 根据坐席组编号查询是否存在此坐席组编号
+        /// </summary>
+        /// <param name="code"></param>
+        /// <returns></returns>
+        private async Task<bool> GetExistByCodeAsync(string code, int id)
+        {
+            long c = 0;
+            if (id > 0)
+                c = await _sys_seatgroupRepository.GetCount(x => x.F_ZXZCode.Equals(code) && x.F_ZXZID != id);
+            else
+                c = await _sys_seatgroupRepository.GetCount(x => x.F_ZXZCode.Equals(code));
+
+            return c > 0;
+        }
+        /// <summary>
+        /// 根据坐席组名称查询是否存在此坐席组编号
+        /// </summary>
+        /// <param name="code"></param>
+        /// <returns></returns>
+        private async Task<bool> GetExistByNameAsync(string name, int id)
+        {
+            long c = 0;
+            if (id > 0)
+                c = await _sys_seatgroupRepository.GetCount(x => x.F_ZXZName.Equals(name) && x.F_ZXZID != id);
+            else
+                c = await _sys_seatgroupRepository.GetCount(x => x.F_ZXZName.Equals(name));
+            
+            return c > 0;
+        }
+        #endregion
+    }
+}