添加档案转移处理接口

代码/System.Model/T_Cus_Msg.cs

@@ -24,6 +24,10 @@ namespace System.Model
         /// </summary>				
         public string F_ToPerson { get; set; }
         /// <summary>
+        /// 消息内容
+        /// </summary>				
+        public string F_Notice { get; set; }
+        /// <summary>
         /// 状态：0未读，1已读但未处理，2同意转移，3拒绝
         /// </summary>				
         public int F_State { get; set; }

代码/TVShoppingCallCenter_ZLJ/Controllers/Customer/CusMsgController.cs

@@ -8,6 +8,7 @@ using System.Security.Claims;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
+using SqlSugar;
 
 // For more information on enabling MVC for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860
 
@@ -38,23 +39,18 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Customer
         /// <param name="input"></param>
         /// <returns></returns>
         [HttpPost("add")]
-        public async Task<IActionResult> AddAsync(int start, int getpercent, int getday, int startdebit, int debitpercent)
+        public async Task<IActionResult> AddAsync(int type, int vipid, string  toperson, string notifyperson,string notice)
         {
 
             var model = new T_Cus_Msg();
-            model.F_Type = start;
-            model.F_VipInfoID = getpercent;
-            model.F_ToPerson = "";
+            model.F_Type = 1;
+            model.F_VipInfoID = vipid;
+            model.F_ToPerson = toperson;
             model.F_State = 0;
-            model.F_NotifyPerson = "";
+            model.F_Notice = notice;
+            model.F_NotifyPerson = notifyperson;
             model.F_CreateBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
             model.F_CreateOn = DateTime.Now;
-
-            //if (await _cus_score_setRepository.GetCount(x => x.F_Name == input.name) > 0)
-            //{
-            //    return Error("添加失败，存在相同标签信息");
-            //}
-                  
             var res = await _cus_msgRepository.Add(model);
             if (res > 0)
             {
@@ -66,5 +62,59 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Customer
             }
 
         }
+
+        /// <summary>
+        /// 获取列表分页
+        /// </summary>
+        /// <param name="keyword"></param>
+        /// <param name="pageindex"></param>
+        /// <param name="pagesize"></param>
+        /// <returns></returns>
+        [HttpGet("getlistbypage")]
+        public async Task<IActionResult> GetListsByPageAsync(int getstate,string tousercode, string fromusercode, int type,int pageindex = 1, int pagesize = 20)//getstate传0时获取全部，传1时获取未处理，传2时获取已处理
+        {
+            List<IConditionalModel> conModels = new List<IConditionalModel>();
+            #region 条件筛选
+            if (getstate == 1)
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = getstate.ToString() });
+            }
+            else if (getstate == 2)
+            {
+                    conModels.Add(new ConditionalCollections()
+                    {
+                        ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
+                    {
+                        new  KeyValuePair<WhereType, ConditionalModel>(WhereType.And, new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = "2" }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = "3" })
+
+                    }
+                    });
+            }
+            if (!string.IsNullOrEmpty(tousercode))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_ToPerson", ConditionalType = ConditionalType.Equal , FieldValue = tousercode });
+            }
+            if (!string.IsNullOrEmpty(fromusercode))
+            {
+                conModels.Add(new ConditionalModel() { FieldName = "F_CreateBy", ConditionalType = ConditionalType.Equal, FieldValue = fromusercode });
+            }
+            //if (!string.IsNullOrEmpty(keyword))
+            //{
+            //    conModels.Add(new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = keyword });
+            //}
+            
+            #endregion
+            int recordCount = 0;
+            var list = await _cus_msgRepository.GetListByPage(conModels, new MyPageModel() { PageIndex = pageindex, PageSize = pagesize, PageCount = recordCount });
+            var obj = new
+            {
+                state = "success",
+                message = "成功",
+                rows = list,
+                total = recordCount,
+            };
+            return Content(obj.ToJson());
+        }
     }
 }

代码/TVShoppingCallCenter_ZLJ/Controllers/Customer/VIPInfoController.cs

@@ -20,11 +20,13 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Customer
     {
         private readonly ICus_VipInfoRepository _cus_vip_infoRepository;
         private readonly ISys_UserAccountRepository _sys_user_accountRepository;
+        private readonly ICus_MsgRepository _cus_msgRepository;
 
-        public VipInfoController(ICus_VipInfoRepository cus_vip_infoRepository, ISys_UserAccountRepository sys_user_accountRepository)
+        public VipInfoController(ICus_VipInfoRepository cus_vip_infoRepository, ISys_UserAccountRepository sys_user_accountRepository, ICus_MsgRepository cus_msgRepository)
         {
             _cus_vip_infoRepository = cus_vip_infoRepository;
             _sys_user_accountRepository = sys_user_accountRepository;
+            _cus_msgRepository = cus_msgRepository;
         }
 
         [HttpGet]
@@ -316,22 +318,90 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.Customer
                 foreach (var item in ids)
                 {
                     var ml = await _cus_vip_infoRepository.GetSingle(x => x.F_ID == item);
+                    if (ml != null)
+                    {
+                        #region 创建消息提醒
+                        var model = new T_Cus_Msg();
+                        model.F_Type = 1;
+                        model.F_VipInfoID = item;
+                        model.F_ToPerson = toperson;
+                        model.F_State = 0;
+                        model.F_NotifyPerson = ml.F_Saleperson;
+                        model.F_CreateBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                        model.F_CreateOn = DateTime.Now;
+                        var su = await _cus_msgRepository.Add(model);
+                        if (su > 0)
+                        {
+                            res += 1;
+                        }
+                        #endregion
+                    }                  
+                    //ml.F_Saleperson = toperson;
+                    //ml.F_LastModifyOn = DateTime.Now.ToLocalTime();
+                    //ml.F_LastModifyBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                    //if (_cus_vip_infoRepository.Update(ml).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="ids"></param>
+        /// <returns></returns>
+        [HttpPost("deal")]
+        public async Task<IActionResult> Deal(int[] ids, int notagree)//同意传0，不同意传1
+        {
+            var res = 0;
+            if (ids != null && ids.Length > 0)
+            {
+                foreach (var item in ids)
+                {
+                    var ml = await _cus_msgRepository.GetSingle(x => x.F_ID == item);
+                    
+                    if (ml != null)
+                    {
+                        #region 创建消息提醒
+                        //var model = new T_Cus_Msg();
+                        ml.F_Type = 1;                       
+                        ml.F_State = notagree +2;                        
+                        ml.F_LastModifyBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                        ml.F_LastModifyOn = DateTime.Now;
+                        if (_cus_msgRepository.Update(ml).Result)
+                        {
+                            if (notagree == 0)//同意转移时更新会员信息
+                            {
+                                var m = await _cus_vip_infoRepository.GetSingle(x => x.F_ID == ml.F_VipInfoID );
+                                m.F_Saleperson = ml.F_ToPerson ;
+                                m.F_LastModifyOn = DateTime.Now.ToLocalTime();
+                                m.F_LastModifyBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                                if (_cus_vip_infoRepository.Update(m).Result)
+                                { }
+                            }
+                            res += 1;
+                        }
+                        #endregion
+                    }
                     
-                    ml.F_Saleperson = toperson;
-                    ml.F_LastModifyOn = DateTime.Now.ToLocalTime();
-                    ml.F_LastModifyBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
-                    if (_cus_vip_infoRepository.Update(ml).Result)
-                        res += 1;
                 }
                 if (res == ids.Length)
-                    return Success("转移成功");
+                    return Success("处理成功");
                 else if (res > 0 && res < ids.Length)
-                    return Error("部分转移失败，请查看后重新操作");
+                    return Error("部分消息处理失败，请查看后重新操作");
                 else
-                    return Error("转移失败，请查看后重新操作");
+                    return Error("处理消息失败，请查看后重新操作");
             }
             else
-                return Error("请选择要删除的记录");
+                return Error("请选择要处理的记录");
         }
     }
 }