任务管理

代码/System.Model/T_Sys_TaskManagement.cs

@@ -54,12 +54,12 @@ namespace System.Model
         /// <summary>
         /// 目标金额
         /// </summary>
-        public decimal? F_Money
+        public float? F_Money
         { get; set; }
         /// <summary>
         /// 当前金额
         /// </summary>
-        public decimal? F_Currentamount
+        public float F_Currentamount
         { get; set; }
         /// <summary>
         /// 任务进度
@@ -111,7 +111,11 @@ namespace System.Model
         /// </summary>
         public string F_DeleteUser
         { get; set; }
-
+        /// <summary>
+        /// 
+        /// </summary>
+        public int  F_Parentid
+        { get; set; }
     }
 }
 

代码/TVShoppingCallCenter_ZLJ/Controllers/MediaCente/MediaCenteController.cs

@@ -35,6 +35,23 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.MediaCente
             _sys_areaRepository = sys_areaRepository;
         }
         /// <summary>
+        /// 分页获取产品列表
+        /// </summary>
+        /// <param name="input">筛选字段</param>
+        /// <returns></returns>
+        [HttpPost("getlistproduct")]
+        public async Task<IActionResult> GetListByPage()
+        {
+            List<IConditionalModel> conModels = new List<IConditionalModel>();
+            #region 条件筛选
+            conModels.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumDelState.Enabled).ToString() });
+            #endregion
+            var list = await _productRepository.GetListALL(conModels , " F_AddTime DESC");
+            var row = list.Where((x, i) => list.FindIndex(z => z.F_ProductNumber  == x.F_ProductNumber) == i);
+            return Success("成功", row);
+        }
+
+        /// <summary>
         /// 添加媒体投放
         /// </summary>
         /// <param name="input"></param>

代码/TVShoppingCallCenter_ZLJ/Controllers/TaskManagement/TaskManagementController.cs

@@ -1,12 +1,15 @@
 using System;
 using System.Collections.Generic;
 using System.Common;
+using System.Common.Helpers;
+using System.Data;
 using System.IRepositories;
 using System.Linq;
 using System.Model;
 using System.Security.Claims;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
+using SqlSugar;
 using TVShoppingCallCenter_ZLJ.Models.Inputs;
 
 namespace TVShoppingCallCenter_ZLJ.Controllers.TaskManagement
@@ -30,23 +33,31 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.TaskManagement
         [HttpPost("add")]
         public async Task<IActionResult> AddAsync(T_Sys_TaskManagement input)
         {
-            if (string .IsNullOrEmpty (input.F_Name ))
+            if (string.IsNullOrEmpty(input.F_Name))
                 return Error("请输入任务名称");
-            if (string.IsNullOrEmpty(input.F_Content ))
+            if (string.IsNullOrEmpty(input.F_Content))
                 return Error("请输入任务内容");
-            if (input .F_StartTime ==null )
+            if (input.F_StartTime == null)
                 return Error("请选择任务开始时间");
-            if (input .F_EndTime ==null )
+            if (input.F_EndTime == null)
                 return Error("请选择任务结束时间");
-            if (input.F_Type <0)
+            if (input.F_Type < 0)
                 return Error("请选择任务类型");
-            if (input.F_Deptid  < 0)
+            if (input.F_Deptid < 0)
                 return Error("请选择任务部门");
+            if (input.F_Money < 0)
+                return Error("请输入目标金额");
             // string user = "8000";
+            if (input.F_Remindertime == null)
+                input.F_Remindertime = input.F_EndTime.Value.AddDays(-3);
+            if (input.F_Currentamount > 0)
+                input.F_Taskprogress = string.Format("{0:f2}%", input.F_Currentamount / input.F_Money * 100);
+            else
+                input.F_Taskprogress = "0%";
             string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
-        //    var model = new T_Sys_MediaCente();
-        //    model = Transformation(model, input, user, 0);
-            var res = 1;
+            input.F_CreateTime = DateTime.Now;
+            input.F_CreateUser = user;
+            var res = await _sys_taskmanagement_Repository.Add(input);
             if (res > 0)
             {
                 return Success("添加成功");
@@ -56,5 +67,414 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.TaskManagement
                 return Error("添加失败");
             }
         }
+        /// <summary>
+        /// 修改任务
+        /// </summary>
+        [HttpPost("update")]
+        public async Task<IActionResult> UpdateAsync(T_Sys_TaskManagement input)
+        {
+            if (input.F_ID <= 0)
+                return Error("参数错误");
+            if (string.IsNullOrEmpty(input.F_Name))
+                return Error("请输入任务名称");
+            if (string.IsNullOrEmpty(input.F_Content))
+                return Error("请输入任务内容");
+            if (input.F_StartTime == null)
+                return Error("请选择任务开始时间");
+            if (input.F_EndTime == null)
+                return Error("请选择任务结束时间");
+            if (input.F_Type < 0)
+                return Error("请选择任务类型");
+            if (input.F_Deptid < 0)
+                return Error("请选择任务部门");
+            if (input.F_Money < 0)
+                return Error("请输入目标金额");
+            var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == input.F_ID);
+            if (model == null)
+                return Error("操作失败");
+            if (input.F_Remindertime == null)
+                input.F_Remindertime = input.F_EndTime.Value.AddDays(-3);
+            if (input.F_Currentamount > 0)
+                input.F_Taskprogress = string.Format("{0:f2}%", input.F_Currentamount / input.F_Money * 100);
+            else
+                input.F_Taskprogress = "0%";
+            //  string user = "8000";
+            string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+            input.F_IsDelete = 0;
+            input.F_UpdateUser = user;
+            input.F_UpdateTime = DateTime.Now;
+            input.F_UpdateTime = DateTime.Now;
+            input.F_UpdateUser = user;
+            // model.F_UpdateUser = "8000";
+            var b = await _sys_taskmanagement_Repository.Update(input);
+            if (b)
+                return Success("修改成功");
+            return Error("修改失败");
+        }
+        /// <summary>
+        /// 删除任务
+        /// </summary>
+        /// <param name="ids"></param>
+        /// <returns></returns>
+        [HttpPost("delete")]
+        public async Task<IActionResult> Remove(int[] ids)
+        {
+            var res = 0;
+            if (ids != null && ids.Length > 0)
+            {
+                foreach (var item in ids)
+                {
+                    var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == item);
+                    model.F_IsDelete = (int)EnumUserCountState.Delete;
+                    model.F_DeleteTime = DateTime.Now.ToLocalTime();
+                    model.F_DeleteUser = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                    if (_sys_taskmanagement_Repository.Update(model).Result)
+                        res += 1;
+                }
+                if (res == ids.Length)
+                    return Success("删除成功");
+                else if (res > 0 && res < ids.Length)
+                    return Error("部分删除失败，请查看后重新操作");
+                else
+                    return Error("删除失败，请查看后重新操作");
+            }
+            else
+                return Error("请选择要删除的记录");
+        }
+        /// <summary>
+        /// 操作任务
+        /// </summary>
+        /// <param name="id">id</param>
+        /// <returns></returns>
+        [HttpGet("operation")]
+        public async Task<IActionResult> GetOperationAsync(int id, int state)
+        {
+            if (id <= 0)
+                return Error("参数错误");
+
+            var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == id);
+            if (model == null)
+            {
+                return Error("获取失败");
+            }
+            model.F_State = state;
+            var obj = await _sys_taskmanagement_Repository.Update(model);
+            if (obj)
+                return Success("操作成功");
+            else
+                return Error("操作失败");
+        }
+        /// <summary>
+        /// 获取任务列表
+        /// </summary>
+        /// <param name="keyword"></param>
+        /// <param name="pageindex"></param>
+        /// <param name="pagesize"></param>
+        /// <returns></returns>
+        [HttpGet("getlist")]
+        public async Task<IActionResult> GetListMark(string keyword, string name,string parentname, string starttime, string endtime, string tasker,
+      int deptid = 0, int type = -1, int pageindex = 1, int pagesize = 20)
+        {
+            List<IConditionalModel> conModels = new List<IConditionalModel>();
+            #region 条件筛选
+            conModels.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumUserCountState.Enabled).ToString() });
+            if (!string.IsNullOrEmpty(name))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = name });
+            }
+            if (!string.IsNullOrEmpty(tasker))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_Tasker", ConditionalType = ConditionalType.Like, FieldValue = tasker });
+            }
+            if (!string.IsNullOrEmpty(parentname))
+            {
+                if (_sys_taskmanagement_Repository.GetSingle (x=>x .F_Name == parentname).Result!=null  )
+                {
+                    conModels.Add(new ConditionalModel() { FieldName = "F_Parentid", ConditionalType = ConditionalType.Like, FieldValue = _sys_taskmanagement_Repository.GetSingle(x => x.F_Name == parentname).Result.F_ID .ToString ()    });
+                }
+            }
+            if (type > -1)
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_Type", ConditionalType = ConditionalType.Like, FieldValue = type.ToString() });
+            }
+            if (deptid > 0)
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_Deptid", ConditionalType = ConditionalType.Equal, FieldValue = deptid.ToString() });
+            }
+            if (!string.IsNullOrEmpty(keyword))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = keyword });
+                new KeyValuePair<WhereType, ConditionalModel>(WhereType.Or, new ConditionalModel() { FieldName = "F_Content", ConditionalType = ConditionalType.Like, FieldValue = keyword });
+                new KeyValuePair<WhereType, ConditionalModel>(WhereType.Or, new ConditionalModel() { FieldName = "F_Tasker", ConditionalType = ConditionalType.Like, FieldValue = keyword });
+            }
+
+            if (!string.IsNullOrEmpty(starttime))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_StartTime", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = starttime });
+            }
+            if (!string.IsNullOrEmpty(endtime))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_EndTime", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = endtime });
+            }
+            #endregion
+            int recordCount = 0;
+            var list = await _sys_taskmanagement_Repository.GetListByPage(conModels, new MyPageModel() { PageIndex = pageindex, PageSize = pagesize, PageCount = recordCount });
+            var obj = new
+            {
+                state = "success",
+                message = "成功",
+                rows = ConvertAsync(list),
+                total = list.Totals,
+            };
+
+            return Content(obj.ToJson());
+        }
+    
+        /// <summary>
+        /// 获取媒体投放详情
+        /// </summary>
+        /// <param name="id">id</param>
+        /// <returns></returns>
+        [HttpGet("getdetails")]
+        public async Task<IActionResult> GetDetailsAsync(int id)
+        {
+            if (id <= 0)
+                return Error("参数错误");
+
+            var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == id);
+            if (model == null)
+            {
+                return Error("获取失败");
+            }
+            return Success("获取成功！", Convert(model, 1));
+        }
+        public bool UpdateTaskAmount(int id, int money)
+        {
+            bool n = true;
+            var model =  _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == id).Result;
+            if (model == null)
+              return   false ;
+            model.F_Currentamount += money;
+            model.F_Taskprogress = string.Format("{0:f2}%", model.F_Currentamount / model.F_Money * 100);
+            var res = _sys_taskmanagement_Repository.Update(model);
+            if (!res.Result)
+                return false;
+            if (model.F_Parentid > 0)
+            {
+                n= TreeRecursion(model.F_Parentid, money);
+            }
+             return  n;
+        }
+        /// <summary>
+        /// 递归算法
+        /// </summary>
+        /// <param name="data"></param>
+        /// <param name="parentId"></param>
+        /// <returns></returns>
+        private bool  TreeRecursion( int parentId = 0,int money=0)
+        {
+            bool n = true;
+            var model = _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == parentId).Result;
+            if (model == null)
+                return false;
+            model.F_Currentamount += money;
+            model.F_Taskprogress = string.Format("{0:f2}%", model.F_Currentamount / model.F_Money * 100);
+            var res = _sys_taskmanagement_Repository.Update(model);
+            if (!res.Result)
+                return false;
+            if (model.F_Parentid > 0)
+            {
+                n = TreeRecursion(model.F_Parentid, money);
+            }
+            return n;
+        }
+        /// <summary>
+        /// 上传文件并导入数据库
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("importexcel")]
+        public async Task<IActionResult> ImportExcel(int headrow = 0,int parentid=0)
+        {
+            Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
+            if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
+                return Error($"请正确上传Excel文件：file.ContentType={_upfile.ContentType}");
+            NPOIHelper npoi = new NPOIHelper();
+            var dtExcel = npoi.ExcelToTable1(_upfile, headrow);
+            int num = dtExcel.Rows.Count;
+            var cols = dtExcel.Columns;
+            int colnum = cols.Count;
+            string errmsg = string.Empty;
+            if (num > 0)
+            {
+                int index = 1;
+                foreach (DataRow dr in dtExcel.Rows)
+                {
+                    var model = new T_Sys_TaskManagement();
+                    string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                    model.F_Name = dr["任务名称"].ToString();
+                    model.F_Content = dr["任务内容"].ToString();
+                    if (string .IsNullOrEmpty (dr["任务开始时间"].ToString()))
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！请输入任务开始时间";
+                        continue;
+                    }
+                    if (string.IsNullOrEmpty(dr["任务结束时间"].ToString()))
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！请输入任务结束时间";
+                        continue;
+                    }
+                    if (string.IsNullOrEmpty(dr["目标金额"].ToString()))
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！请输入目标金额";
+                        continue;
+                    }
+                    try
+                    {
+                        model.F_StartTime = DateTime.Parse(dr["任务开始时间"].ToString());
+                    }
+                    catch
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！任务开始时间格式错误";
+                        continue;
+                    }
+                    try
+                    {
+                        model.F_EndTime = DateTime.Parse(dr["任务结束时间"].ToString());
+                    }
+                    catch
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！任务结束时间格式错误";
+                        continue;
+                    }
+                    if (dr["任务类型"].ToString() == "月")
+                        model.F_Type = 2;
+                    else if (dr["任务类型"].ToString() == "周")
+                        model.F_Type = 1;
+                    else
+                        model.F_Type = 0;
+                     if (_sys_departmentRepository.GetSingle(x => x.F_DeptName == dr["任务部门"].ToString()).Result !=null )
+                    {
+                        model.F_Deptid = _sys_departmentRepository.GetSingle(x => x.F_DeptName == dr["任务部门"].ToString()).Result.F_DeptId;
+                    }
+                     else
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！请检查任务部门";
+                        continue;
+                    }
+                    model.F_Tasker = dr["任务人"].ToString();
+                    try
+                    {
+                        model.F_Money = float .Parse(dr["目标金额"].ToString());
+                    }
+                    catch
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！请输入正确的目标金额";
+                        continue;
+                    }
+                    if (string.IsNullOrEmpty(dr["当前金额"].ToString()))
+                        model.F_Currentamount = 0;
+                    try
+                    {
+                        model.F_Currentamount = float.Parse(dr["当前金额"].ToString());
+                    }
+                    catch
+                    {
+                        errmsg = errmsg + "\r\n第" + index + "行导入失败！请输入正确的当前金额";
+                        continue;
+                    }
+                    if (!string .IsNullOrEmpty (dr["任务提醒时间"].ToString()))
+                    {
+                        try
+                        {
+                            model.F_Remindertime = DateTime.Parse(dr["任务提醒时间"].ToString());
+                        }
+                        catch
+                        {
+                            errmsg = errmsg + "\r\n第" + index + "行导入失败！任务提醒时间格式错误";
+                            continue;
+                        }
+                    }
+                    else
+                    {
+                        model.F_Remindertime = model.F_EndTime.Value.AddDays(-3);
+                    }
+                    model.F_Taskprogress = string.Format("{0:f2}%", model.F_Currentamount / model.F_Money * 100);
+                    if (dr["任务类型"].ToString() == "终止")
+                        model.F_State = 2;
+                    else if (dr["任务类型"].ToString() == "暂停")
+                        model.F_State = 1;
+                    else
+                        model.F_State = 0;
+                    model.F_CreateTime = DateTime.Now;
+                    model.F_CreateUser  = user;
+                    int b = await _sys_taskmanagement_Repository.Add(model);
+                    if (b <= 0)
+                    {
+                        if (!string.IsNullOrEmpty(errmsg))
+                        {
+                            errmsg = errmsg + "\r\n第" + index + "行导入失败！";
+                        }
+                        else
+                        {
+                            errmsg = "第" + index + "行导入失败！";
+                        }
+                    }
+                    index++;
+
+                }
+            }
+            else
+            {
+                return Error("文件中无数据");
+            }
+
+            if (!string.IsNullOrEmpty(errmsg))
+            {
+                return Error(errmsg);
+            }
+
+            return Success("导入成功");
+        }
+        #region 私有方法
+        private TaskManagementInput Convert(T_Sys_TaskManagement it, int type = 0)
+        {
+            TaskManagementInput task  = new TaskManagementInput();
+            task.F_Name = it.F_Name;
+            task.F_Content = it.F_Content;
+            task.F_StartTime = it.F_StartTime;
+            task.F_EndTime = it.F_EndTime;
+            task.F_Type = it.F_Type;
+            task.F_Deptid = it.F_Deptid;
+            task.F_DeptName = _sys_departmentRepository.GetSingle(x => x.F_DeptId  == it.F_Deptid).Result != null ? _sys_departmentRepository.GetSingle(x => x.F_DeptId == it.F_Deptid).Result.F_DeptName  : "";// 部门名称
+            task.F_Tasker = it.F_Tasker;
+            task.F_Money = it.F_Money;
+            task.F_Currentamount = it.F_Currentamount;
+            task.F_Taskprogress = it.F_Taskprogress;
+            task.F_State = it.F_State;
+            task.F_Remindertime = it.F_Remindertime;
+            task.F_Parentid = it.F_Parentid;
+            task.F_ParentName = _sys_taskmanagement_Repository.GetSingle(x => x.F_ID  == it.F_Parentid).Result != null ? _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == it.F_Parentid).Result.F_Name  : "";// 部门名称
+            return task;
+        }
+        /// model转input
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        private List<TaskManagementInput> ConvertAsync(PageData<T_Sys_TaskManagement> model)
+        {
+            List<TaskManagementInput> input = new List<TaskManagementInput>();
+            if (model != null)
+            {
+
+                foreach (var it in model.Rows)
+                {
+                    TaskManagementInput marketing = new TaskManagementInput();
+                    marketing = Convert(it);
+                    input.Add(marketing);
+                }
+            }
+            return input;
+        }
+        #endregion
     }
 }

代码/TVShoppingCallCenter_ZLJ/Models/Inputs/PlanManagemenInput.cs

@@ -160,5 +160,7 @@ namespace TVShoppingCallCenter_ZLJ.Models.Inputs
         {
             get; set;
         }
+     
+       
     }
 }

代码/TVShoppingCallCenter_ZLJ/Models/Inputs/TaskManagementInput.cs

@@ -0,0 +1,126 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace TVShoppingCallCenter_ZLJ.Models.Inputs
+{
+    public class TaskManagementInput
+    {
+        /// <summary>
+        /// 任务id
+        /// </summary>
+        public int F_ID
+        { get; set; }
+        /// <summary>
+        /// 任务名称
+        /// </summary>
+        public string F_Name
+        { get; set; }
+        /// <summary>
+        /// 任务内容
+        /// </summary>
+        public string F_Content
+        { get; set; }
+        /// <summary>
+        /// 任务开始时间
+        /// </summary>
+        public DateTime? F_StartTime
+        { get; set; }
+        /// <summary>
+        /// 任务结束时间
+        /// </summary>
+        public DateTime? F_EndTime
+        { get; set; }
+        /// <summary>
+        /// 任务类型
+        /// </summary>
+        public int? F_Type
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? F_Deptid
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string  F_DeptName
+        { get; set; }
+        /// <summary>
+        /// 任务人
+        /// </summary>
+        public string F_Tasker
+        { get; set; }
+        /// <summary>
+        /// 目标金额
+        /// </summary>
+        public float? F_Money
+        { get; set; }
+        /// <summary>
+        /// 当前金额
+        /// </summary>
+        public float? F_Currentamount
+        { get; set; }
+        /// <summary>
+        /// 任务进度
+        /// </summary>
+        public string F_Taskprogress
+        { get; set; }
+        /// <summary>
+        /// 任务状态
+        /// </summary>
+        public int? F_State
+        { get; set; }
+        /// <summary>
+        /// 提醒时间
+        /// </summary>
+        public DateTime? F_Remindertime
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_CreateUser
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? F_CreateTime
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? F_UpdateTime
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_UpdateUser
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? F_IsDelete
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? F_DeleteTime
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_DeleteUser
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int F_Parentid
+        { get; set; }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_ParentName
+        { get; set; }
+    }
+}