增加部门团队管理

代码/System.IRepositories/ISys_DeptTeamRepository.cs

@@ -0,0 +1,15 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.Model;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace System.IRepositories
+{
+    public interface ISys_DeptTeamRepository : IRepository<T_Sys_DeptTeam>
+    {
+        Task<PageData<V_DeptTeam>> GetListViewByPage(List<IConditionalModel> conModels, MyPageModel pagemodel, string orderby);
+    }
+}

代码/System.Model/T_Sys_DeptTeam.cs

@@ -0,0 +1,55 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace System.Model
+{
+    [Serializable]
+    public partial class T_Sys_DeptTeam
+    {
+        /// <summary>
+        /// 自增id
+        /// </summary>
+        public int F_Id { get; set; }
+        /// <summary>
+        /// 部门ID
+        /// </summary>
+        public int F_DeptId { get; set; }
+        /// <summary>
+		/// 职位名称
+		/// </summary>
+		public string F_Name { get; set; }
+        /// <summary>
+        /// 描述说明
+        /// </summary>
+        public string F_Des { get; set; }
+        /// <summary>
+        /// 状态
+        /// </summary>
+        public int? F_State { get; set; }
+        /// <summary>
+        /// 添加时间
+        /// </summary>
+        public DateTime? F_CreateOn { get; set; }
+        /// <summary>
+        /// 添加工号
+        /// </summary>
+        public string F_CreateBy { get; set; }
+        /// <summary>
+        /// 最后一次修改时间
+        /// </summary>
+        public DateTime? F_LastModifyOn { get; set; }
+        /// <summary>
+        /// 最后一次修改工号
+        /// </summary>
+        public string F_LastModifyBy { get; set; }
+        /// <summary>
+        /// 删除时间
+        /// </summary>
+        public DateTime? F_DeleteOn { get; set; }
+        /// <summary>
+        /// 删除工号
+        /// </summary>
+        public string F_DeleteBy { get; set; }
+    }
+}

代码/System.Model/V_DeptTeam.cs

@@ -0,0 +1,55 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace System.Model
+{
+    public class V_DeptTeam
+    {
+        /// <summary>
+        /// 自增id
+        /// </summary>
+        public int F_Id { get; set; }
+        /// <summary>
+        /// 部门ID
+        /// </summary>
+        public int F_DeptId { get; set; }
+        public string F_DeptName { get; set; }
+        /// <summary>
+		/// 职位名称
+		/// </summary>
+		public string F_Name { get; set; }
+        /// <summary>
+        /// 描述说明
+        /// </summary>
+        public string F_Des { get; set; }
+        /// <summary>
+        /// 状态
+        /// </summary>
+        public int? F_State { get; set; }
+        /// <summary>
+        /// 添加时间
+        /// </summary>
+        public DateTime? F_CreateOn { get; set; }
+        /// <summary>
+        /// 添加工号
+        /// </summary>
+        public string F_CreateBy { get; set; }
+        /// <summary>
+        /// 最后一次修改时间
+        /// </summary>
+        public DateTime? F_LastModifyOn { get; set; }
+        /// <summary>
+        /// 最后一次修改工号
+        /// </summary>
+        public string F_LastModifyBy { get; set; }
+        /// <summary>
+        /// 删除时间
+        /// </summary>
+        public DateTime? F_DeleteOn { get; set; }
+        /// <summary>
+        /// 删除工号
+        /// </summary>
+        public string F_DeleteBy { get; set; }
+    }
+}

代码/System.Repositories/Sys_DeptTeamRepository.cs

@@ -0,0 +1,37 @@
+using SqlSugar;
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.IRepositories;
+using System.Model;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace System.Repositories
+{
+    public class Sys_DeptTeamRepository : BaseRepository<T_Sys_DeptTeam>, ISys_DeptTeamRepository
+    {
+        public async Task<PageData<V_DeptTeam>> GetListViewByPage(List<IConditionalModel> conModels, MyPageModel pagemodel, string orderby)
+        {
+            var userlist = await Db.SqlQueryable<V_DeptTeam>("select * from T_Sys_DeptTeam").Where(conModels).OrderBy(orderby).ToPageListAsync(pagemodel.PageIndex, pagemodel.PageSize, pagemodel.PageCount);
+
+            var seatlist = await Db.Queryable<T_Sys_Department>().With(SqlWith.NoLock).Where(c => c.F_State == (int)EnumDelState.Enabled).ToListAsync();
+
+            var list = new List<V_DeptTeam>();
+            foreach (var item in userlist)
+            {
+                var newmodel = item;
+
+                var seatmodel = seatlist.Find(a => a.F_DeptId == item.F_DeptId);
+                if (seatmodel != null)
+                    newmodel.F_DeptName = seatmodel.F_DeptName;
+
+                list.Add(newmodel);
+            }
+            PageData<V_DeptTeam> pd = new PageData<V_DeptTeam>();
+            pd.Rows = list;
+            pd.Totals = pagemodel.PageCount;
+            return pd;
+        }
+    }
+}

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

@@ -0,0 +1,239 @@
+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 DeptTeamController : BaseController
+    {
+        private readonly ISys_DeptTeamRepository _sys_deptteamRepository;
+        public DeptTeamController(ISys_DeptTeamRepository sys_deptteamRepository)
+        {
+            _sys_deptteamRepository = sys_deptteamRepository;
+        }
+        /// <summary>
+        /// 获取列表
+        /// </summary>
+        /// <param name="filter"></param>
+        /// <returns></returns>
+        [Authorize]
+        [HttpGet("getlistbypage")]
+        public async Task<IActionResult> GetListsByPage(string key, int deptid = 0, int pageindex = 1, int pagesize = 20)
+        {
+            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.And, new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = key }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_Des", ConditionalType = ConditionalType.Like, FieldValue = key })
+                    }
+                });
+            }
+            if (deptid > 0)
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_DeptId", ConditionalType = ConditionalType.Equal, FieldValue = deptid.ToString() });
+            }
+            #endregion
+            int recordCount = 0;
+            var list = await _sys_deptteamRepository.GetListViewByPage(conModels, new MyPageModel() { PageIndex = pageindex, PageSize = pagesize, PageCount = recordCount }, "F_CreateOn desc");
+
+            return Success("成功", list);
+        }
+
+        [Authorize]
+        [HttpGet("getlistdrop")]
+        public async Task<IActionResult> GetListDrop(string key,int deptid=0)
+        {
+            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.And, new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = key }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_Des", ConditionalType = ConditionalType.Like, FieldValue = key })
+                    }
+                });
+
+            }
+            if (deptid > 0)
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_DeptId", ConditionalType = ConditionalType.Equal, FieldValue = deptid.ToString() });
+            }
+            #endregion
+            var list = await _sys_deptteamRepository.GetListALL(conModels, "F_CreateOn desc");
+            var result = list.Select(x => new {
+                x.F_Id,
+                x.F_DeptId,
+                x.F_Name,
+                x.F_Des
+            });
+            return Success("获取全部数据成功", result);
+        }
+
+        /// <summary>
+        /// 获取实体
+        /// </summary>
+        [Authorize]
+        [HttpGet("getdetails")]
+        public async Task<IActionResult> GetDetails(int id)
+        {
+            if (id > 0)
+            {
+                var dModel = await _sys_deptteamRepository.GetSingle(x => x.F_Id == id && x.F_State == (int)EnumDelState.Enabled);
+
+                if (dModel != null)
+                {
+                    return Success("获取成功", dModel);
+                }
+                else
+                {
+                    return Error("获取失败");
+                }
+            }
+            else
+            {
+                return Error("获取参数失败");
+            }
+        }
+
+        /// <summary>
+        /// 添加
+        /// </summary>
+        [Authorize]
+        [HttpPost("add")]
+        public async Task<IActionResult> Add(string name, string des,int deptid=0)
+        {
+            #region 验证
+            if (deptid <= 0)
+                return Error("请选择部门");
+            if (string.IsNullOrWhiteSpace(name))
+                return Error("团队名称不能为空");
+            if (await GetExistByNameAsync(name,deptid, 0))
+                return Error("团队名称不能重复，请重新输入！");
+            #endregion
+            T_Sys_DeptTeam clmodel = new T_Sys_DeptTeam();
+            clmodel.F_DeptId = deptid;
+            clmodel.F_Name = name;
+            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_deptteamRepository.Add(clmodel);
+            if (res > 0)
+                return Success("保存成功");
+            else
+            {
+                return Error("保存失败");
+            }
+        }
+
+        /// <summary>
+        /// 修改
+        /// </summary>
+        [Authorize]
+        [HttpPost("update")]
+        public async Task<IActionResult> Edit(string name, string des, int id = 0, int deptid = 0)
+        {
+            #region
+            if (id <= 0)
+                return Error("请选择要编辑的");
+            if (deptid <= 0)
+                return Error("请选择部门");
+            if (string.IsNullOrWhiteSpace(name))
+                return Error("团队名称不能为空");
+            if (await GetExistByNameAsync(name, deptid, 0))
+                return Error("团队名称不能重复，请重新输入！");
+            #endregion
+
+            var clmodel = await _sys_deptteamRepository.GetSingle(x => x.F_Id == id && x.F_State == (int)EnumDelState.Enabled);
+            if (clmodel == null)
+                return Error("信息获取失败");
+            clmodel.F_DeptId = deptid;
+            clmodel.F_Name = name;
+            clmodel.F_Des = des;
+
+            clmodel.F_LastModifyBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+            clmodel.F_LastModifyOn = DateTime.Now;
+
+            var res = await _sys_deptteamRepository.Update(clmodel);
+
+            if (res)
+                return Success("保存成功");
+            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_deptteamRepository.GetSingle(x => x.F_Id == item);
+                    ml.F_State = (int)EnumDelState.Delete;
+                    if (await _sys_deptteamRepository.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>
+        /// <returns></returns>
+        private async Task<bool> GetExistByNameAsync(string name,int deptid, int id)
+        {
+            long c = 0;
+            Expression<Func<T_Sys_DeptTeam, bool>> eq = a => a.F_State == (int)EnumDelState.Enabled;
+            eq = eq.And(b => b.F_Name.Equals(name));
+            eq = eq.And(b => b.F_DeptId.Equals(deptid));
+            if (id > 0)
+                eq = eq.Or(b => b.F_Id != id);
+
+            c = await _sys_deptteamRepository.GetCount(eq);
+            return c > 0;
+        }
+        #endregion
+    }
+}

代码/TVShoppingCallCenter_ZLJ/Startup.cs

@@ -123,7 +123,8 @@ namespace TVShoppingCallCenter_ZLJ
             services.AddTransient<ISys_AreaRepository, Sys_AreaRepository>();
             services.AddTransient<ISys_CallDutyNumberRepository, Sys_CallDutyNumberRepository>();
             services.AddTransient<ISys_CallBlacklistRepository, Sys_CallBlacklistRepository>();
-            services.AddTransient<ISys_PositionRepository, Sys_PositionRepository>(); 
+            services.AddTransient<ISys_PositionRepository, Sys_PositionRepository>();
+            services.AddTransient<ISys_DeptTeamRepository, Sys_DeptTeamRepository>(); 
 
             services.AddTransient<IBus_ProductClassRepository, Bus_ProductClassRepository>();
             services.AddTransient<IBus_ProductRepository, Bus_ProductRepository>();