消息提醒

代码/TVShoppingCallCenter_ZLJ/Controllers/InternalMessages/InternalMessagesController.cs

     {
         private readonly ISMS_InternalMessagesReposytory _sys_internalMessagesrepository;
         private readonly ISys_UserAccountRepository _sys_useraccountRepository;
+
         public InternalMessagesController(ISMS_InternalMessagesReposytory sys_internalMessagesrepository, ISys_UserAccountRepository sys_useraccountRepository)
         {
             _sys_useraccountRepository = sys_useraccountRepository;
         /// <param name="receiveUserCode"></param>
         /// <param name="sendUserCode"></param>
         /// <returns></returns>
-        public bool AddInternalMessagesInfo(string title, string content, string sendUserCode, int smstype = 0, int smstop = 0,int deptid=0, string receiveUserCode="",int receivingType=0)
+        public bool AddInternalMessagesInfo(int id,string title, string content, string sendUserCode, DateTime time, int smstype = 0, int smstop = 0,  int deptid=0,  string receiveUserCode="",int receivingType=0)
         {
             if (!string.IsNullOrEmpty (title) && !string.IsNullOrEmpty(content) && !string.IsNullOrEmpty(sendUserCode))
             {
                     return false;
 
                 T_SMS_InternalMessages model = new  T_SMS_InternalMessages();
+                model.F_ID = id;
                 model.SMS_Title = title;
                 model.SMS_Content = content;
                 model.SMS_ReceiveUserCode = receiveUserCode;
                 model.SMS_SendUserCode = sendUserCode;
                 model.SMS_IsRead = 0;
                 model.SMS_SendTime = DateTime.Now;
+                model.SMS_Remindertime = time;
                 model.SMS_Deptid = deptid;
                 model.SMS_IsDelete = 0;
                 model.SMS_Order = 0;
             {
                 conModels.Add(new ConditionalModel() { FieldName = "SMS_ReceiveUserCode", ConditionalType = ConditionalType.Equal, FieldValue = user });
             }
+            conModels.Add(new ConditionalModel() { FieldName = "SMS_Remindertime", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = DateTime .Now .ToString () });
             #endregion
             int recordCount = 0;
             if (pageindex > 0 && pagesize > 0)
                 return Error("请选择要操作的记录");
         }
 
+        
     }
 }

代码/TVShoppingCallCenter_ZLJ/Controllers/ManagementCenter/TodoManagementController.cs

     public class TodoManagementController : BaseController
     {
         private readonly ISys_TodoManagementRepository _sys_todomanagementrepository;
-     
-        public TodoManagementController(ISys_TodoManagementRepository sys_todomanagementrepository)
+        private readonly ISMS_InternalMessagesReposytory _sys_internalMessagesrepository;
+        private readonly ISys_UserAccountRepository _sys_useraccountRepository;
+        public TodoManagementController(ISys_TodoManagementRepository sys_todomanagementrepository, ISys_UserAccountRepository sys_useraccountRepository, ISMS_InternalMessagesReposytory sys_internalMessagesrepository)
         {
             _sys_todomanagementrepository = sys_todomanagementrepository;
+            _sys_useraccountRepository = sys_useraccountRepository;
+            _sys_internalMessagesrepository = sys_internalMessagesrepository;
         }
         /// <summary>
         /// 添加待办
             input.F_CreateTime = DateTime.Now;
             input.F_CreateUser = user;
             input.F_IsDelete = 0;
-            var res = await _sys_todomanagementrepository.Add(input);
-            if (res > 0)
+            string title = "", count = "";
+            if (input.F_Type == 0)
+            {
+                title = "日程提醒";
+                count = input.F_Content;
+            }
+            else
             {
+                title = "待联系人提醒";
+                count = "待联系人"+ input.F_PeopleName ;
+            }
+                var res = await _sys_todomanagementrepository.Add(input);
+            if (res > 0)
+            {    try
+                {
+                    bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(res, title, count, user, DateTime.Parse(input.F_Remindertime.ToString()) , 1, 1, 0, user, 1);
+                }
+                catch
+                {
+
+                }
                 return Success("添加成功");
             }
             else
             input.F_CreateTime = model.F_CreateTime;
             input.F_UpdateTime = DateTime.Now;
             input.F_UpdateUser = user;
+            string title = "", count = "";
+            if (input.F_Type == 0)
+            {
+                title = "日程提醒";
+                count = input.F_Content;
+            }
+            else
+            {
+                title = "待联系人提醒";
+                count = "待联系人" + input.F_PeopleName;
+            }
             // model.F_UpdateUser = "8000";
             var b = await _sys_todomanagementrepository.Update(input);
             if (b)
+            {
+                try
+                {
+                    var InternalMessages = _sys_internalMessagesrepository.GetSingle(x => x.F_ID == model.F_ID).Result;
+                    if (InternalMessages!=null )
+                    {
+                        InternalMessages.SMS_Title  = title;
+                        InternalMessages.SMS_Content = count;
+                        InternalMessages.SMS_Remindertime = input.F_Remindertime;
+                        InternalMessages.SMS_ReceiveUserCode = user ;
+                        bool n = await _sys_internalMessagesrepository.Update(InternalMessages);
+                    }
+                    else
+                    {
+                        bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(model.F_ID, title, count, user, DateTime.Parse(input.F_Remindertime.ToString()), 1, 1, 0, user, 1);
+                    }
+                  
+                }
+                catch
+                {
+
+                }
                 return Success("修改成功");
+            }
+               
             return Error("修改失败");
         }
         /// <summary>

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

         private readonly ISys_MediaManagementRepository _sys_mediaManagement_Repository;
         private readonly IBus_ProductRepository _productRepository;
         private readonly ISys_DepartmentRepository _sys_departmentRepository;
-        public MediaCenteController(ISys_MediaCenteRepository sys_mediacenter_Repository, ISys_PlanManagemenRepository sys_planmanagemenRepository,
-            ISys_DictionaryValueRepository sys_dictionaryRepository, ISys_MediaManagementRepository sys_mediaManagement_Repository, IBus_ProductRepository productRepository, ISys_DepartmentRepository sys_departmentRepository,ISys_AreaRepository sys_areaRepository)
+        private readonly ISMS_InternalMessagesReposytory _sys_internalMessagesrepository;
+        private readonly ISys_UserAccountRepository _sys_useraccountRepository;
+        public MediaCenteController(ISys_MediaCenteRepository sys_mediacenter_Repository, ISys_PlanManagemenRepository sys_planmanagemenRepository, ISys_UserAccountRepository sys_useraccountRepository,
+            ISys_DictionaryValueRepository sys_dictionaryRepository, ISys_MediaManagementRepository sys_mediaManagement_Repository, IBus_ProductRepository productRepository, ISys_DepartmentRepository sys_departmentRepository,ISys_AreaRepository sys_areaRepository, ISMS_InternalMessagesReposytory sys_internalMessagesrepository
+           )
         {
             _sys_mediacenter_Repository = sys_mediacenter_Repository;
             _sys_planmanagemenRepository = sys_planmanagemenRepository;
             _productRepository = productRepository;
             _sys_departmentRepository = sys_departmentRepository;
             _sys_areaRepository = sys_areaRepository;
+            _sys_internalMessagesrepository = sys_internalMessagesrepository;
+            _sys_useraccountRepository = sys_useraccountRepository;
+
         }
         /// <summary>
         /// 产品列表
             var res = await _sys_mediacenter_Repository.Add(model);
             if (res > 0)
             {
+                if (input.F_IsRemind >0)
+                {
+                    try
+                    {
+                        DateTime time = DateTime.Parse(input.F_ReminderTime.ToString());
+                        bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(res, "媒体中心提醒", _sys_mediaManagement_Repository.GetSingle(x => x.F_ID == input.F_Name).Result.F_Name + "媒体提醒", user, time, 1, 1, int.Parse(input.F_DeptId.Split(',')[input.F_DeptId.Split(',').Length - 1]), "", 0);
+                    }
+                    catch
+                    {
+
+                    }
+                  
+                }
+               
                 return Success("添加成功");
             }
             else
             var res = await _sys_mediacenter_Repository.Update (model);
             if (res)
             {
+                var InternalMessages = _sys_internalMessagesrepository.GetSingle(x => x.F_ID == model.F_ID).Result ;
+                if (InternalMessages!=null )
+                {
+                    if (input.F_IsRemind > 0)
+                    {
+                        try
+                        {
+                            InternalMessages.SMS_Content = _sys_mediaManagement_Repository.GetSingle(x => x.F_ID == input.F_Name).Result.F_Name + "媒体提醒";
+                            InternalMessages.SMS_Remindertime = input.F_ReminderTime;
+                            InternalMessages.SMS_Deptid = int.Parse(input.F_DeptId.Split(',')[input.F_DeptId.Split(',').Length - 1]);
+                            bool n = await _sys_internalMessagesrepository.Update(InternalMessages);
+                        }
+                        catch
+                        {
+
+                        }
+                    }
+                }
+                else
+                {
+                    if (input.F_IsRemind > 0)
+                    {
+                        try
+                        {
+                            bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(model.F_ID, "媒体中心提醒", _sys_mediaManagement_Repository.GetSingle(x => x.F_ID == input.F_Name).Result.F_Name + "媒体提醒", user, DateTime.Parse(input.F_ReminderTime.ToString()), 1, 1, int.Parse(input.F_DeptId.Split(',')[input.F_DeptId.Split(',').Length - 1]), "", 0);
+                        }
+                        catch
+                        {
+
+                        }
+                      
+                      
+                    }
+
+                }
+               
                 return Success("修改成功");
             }
             else
             model.F_IsRemind = input.F_IsRemind;// 是否提醒 0否1是
             if (model.F_IsRemind>0)
             {
+               
+               
                 model.F_DeptId = input.F_DeptId;// 提醒部门
                 model.F_ReminderTime = input.F_ReminderTime;// 提醒时间
+                
             }
             string MediaChangeid = "";
             if (input.F_MediaChangeList != null)
             model.F_IsDelete = 0;
             return model;
         }
+
         /// model转input
         /// </summary>
         /// <param name="input"></param>

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

     [Route("api/[controller]")]
     public class TaskManagementController : BaseController
     {
+        private readonly ISMS_InternalMessagesReposytory _sys_internalMessagesrepository;
         private readonly ISys_UserAccountRepository _sys_useraccountRepository;
         private readonly ISys_TaskManagementRepository _sys_taskmanagement_Repository;
         private readonly ISys_DepartmentRepository _sys_departmentRepository;
         public TaskManagementController(ISys_TaskManagementRepository sys_taskmanagement_Repository, ISys_DepartmentRepository sys_departmentRepository,
-            ISys_UserAccountRepository sys_useraccountRepository)
+            ISys_UserAccountRepository sys_useraccountRepository, ISMS_InternalMessagesReposytory sys_internalMessagesrepository)
         {
             _sys_taskmanagement_Repository = sys_taskmanagement_Repository;
             _sys_departmentRepository = sys_departmentRepository;
             _sys_useraccountRepository = sys_useraccountRepository;
+            _sys_internalMessagesrepository = sys_internalMessagesrepository;
         }
         /// <summary>
         /// 添加任务
             input.F_CreateTime = DateTime.Now;
             input.F_CreateUser = user;
             input.F_IsDelete = 0;
+
+           
+            
             var res = await _sys_taskmanagement_Repository.Add(input);
             if (res > 0)
             {
+                try
+                {
+                    DateTime time = DateTime.Parse(input.F_Remindertime.ToString());
+                    if (input .F_Tasker >0)
+                    {
+                        string usercode = _sys_useraccountRepository.GetSingle(x => x.F_UserId == input.F_Tasker).Result.F_UserCode;
+                        bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(res, "任务提醒", input.F_Name + "任务提醒", user, time, 1, 1, 0, usercode, 1);
+                    }
+                    else
+                    {
+                        bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(res, "任务提醒", input.F_Name + "任务提醒", user, time, 1, 1, int.Parse(input.F_Deptid.Split(',')[input.F_Deptid.Split(',').Length - 1]), "", 0);
+                    }
+                   
+                }
+                catch
+                {
+
+                }
                 return Success("添加成功");
             }
             else
             // model.F_UpdateUser = "8000";
             var b = await _sys_taskmanagement_Repository.Update(input);
             if (b)
+            {
+                DateTime time = DateTime.Parse(input.F_Remindertime.ToString());
+                var InternalMessages = _sys_internalMessagesrepository.GetSingle(x => x.F_ID == model.F_ID).Result;
+                if (InternalMessages!=null )
+                {
+                    try
+                    {
+                        if (input.F_Tasker > 0)
+                        {
+                            string usercode = _sys_useraccountRepository.GetSingle(x => x.F_UserId == input.F_Tasker).Result.F_UserCode;
+                            InternalMessages.SMS_Content = input.F_Name + "任务提醒";
+                            InternalMessages.SMS_Remindertime = input.F_Remindertime;
+                            InternalMessages.SMS_ReceiveUserCode = usercode;
+                            bool n = await _sys_internalMessagesrepository.Update(InternalMessages);
+                        }
+                        else
+                        {
+                            InternalMessages.SMS_Content = input.F_Name + "任务提醒";
+                            InternalMessages.SMS_Remindertime = input.F_Remindertime;
+                            InternalMessages.SMS_Deptid = int.Parse(input.F_Deptid.Split(',')[input.F_Deptid.Split(',').Length - 1]);
+                            bool n = await _sys_internalMessagesrepository.Update(InternalMessages);
+                        }
+                    }
+                    catch
+                    {
+
+                    }
+                 
+                }
+                else
+                {
+                    try
+                    {
+                        if (input.F_Tasker > 0)
+                        {
+                            string usercode = _sys_useraccountRepository.GetSingle(x => x.F_UserId == input.F_Tasker).Result.F_UserCode;
+                            bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(model.F_ID, "任务提醒", input.F_Name + "任务提醒", user, time, 1, 1, 0, usercode, 1);
+                        }
+                        else
+                        {
+                            bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(model.F_ID, "任务提醒", input.F_Name + "任务提醒", user, time, 1, 1, int.Parse(input.F_Deptid.Split(',')[input.F_Deptid.Split(',').Length - 1]), "", 0);
+                        }
+                    }
+                    catch
+                    {
+
+                    }
+                  
+                }
+               
+                
                 return Success("修改成功");
+            }
+               
             return Error("修改失败");
         }
+        
         /// <summary>
         /// 删除任务
         /// </summary>