会员绑定坐席

代码/System.IRepositories/Call/Ipoint_agentRepository.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.Model.Call;
+using System.Text;
+
+namespace System.IRepositories.Call
+{
+    
+    public interface Ipoint_agentRepository : IRepository<point_agent>
+    {
+    }
+}

代码/System.Model/Call/point_agent.cs

@@ -0,0 +1,43 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace System.Model.Call
+{
+    [Serializable]
+    public partial class point_agent
+    {
+        public point_agent()
+        { }
+        #region Model
+        private long _id;
+        private string _caller;
+        private string _agent;
+        /// <summary>
+        /// auto_increment
+        /// </summary>
+        public long id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string caller
+        {
+            set { _caller = value; }
+            get { return _caller; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string agent
+        {
+            set { _agent = value; }
+            get { return _agent; }
+        }
+        #endregion Model
+
+    }
+}

代码/System.Repositories/Call/point_agentRepository.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.IRepositories.Call;
+using System.Model.Call;
+using System.Text;
+
+namespace System.Repositories.Call
+{
+   
+    public class point_agentRepository : BaseMysqlRepository<point_agent>, Ipoint_agentRepository
+    {
+    }
+}

代码/TVShoppingCallCenter_ZLJ/Controllers/AutoDial/OutboundTaskController.cs

@@ -137,7 +137,7 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
         [HttpPost("addmiddleware")]
         public async Task<IActionResult> Addmiddleware()
         {
-            string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+            string user ="8000";
             List<IConditionalModel> conModels = new List<IConditionalModel>();
             conModels.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumUserCountState.Enabled).ToString() });
              conModels.Add(new ConditionalCollections()
@@ -148,8 +148,8 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
                         new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_Type", ConditionalType = ConditionalType.Equal , FieldValue = "0" })
                     }
                 });
-            conModels.Add(new ConditionalModel() { FieldName = "F_StartTime", ConditionalType = ConditionalType.GreaterThan , FieldValue = DateTime .Now .ToString() });
-            conModels.Add(new ConditionalModel() { FieldName = "F_EndTime", ConditionalType = ConditionalType.LessThanOrEqual , FieldValue = DateTime.Now.ToString() });
+            conModels.Add(new ConditionalModel() { FieldName = "F_StartTime", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = DateTime .Now .ToString() });
+            conModels.Add(new ConditionalModel() { FieldName = "F_EndTime", ConditionalType = ConditionalType.GreaterThan, FieldValue = DateTime.Now.ToString() });
             conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal , FieldValue = "1" });
             var list = await _sys_outboundTaskrepository.GetListALL (conModels,  "  F_AddTime  desc");
             int n = 0;
@@ -165,26 +165,27 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
                         conModel.Add(new ConditionalModel() { FieldName = "F_Parentid", ConditionalType = ConditionalType.Equal, FieldValue = it.F_ID .ToString() });
                         conModel.Add(new ConditionalModel() { FieldName = "F_ISOutbound", ConditionalType = ConditionalType.Equal, FieldValue = "0" });
                         #endregion
-                        var modellist = await _sys_autodialrepository.GetListALL (conModels, "  F_ID  asc");
+                        var modellist = await _sys_autodialrepository.GetListALL (conModel, "  F_ID  asc");
                         if (modellist!=null )
                         {
                             foreach (var iv in modellist)
                             {
-                                task tasks = new task();
-                                tasks.agent = user;
-                                tasks.number  = iv .F_Tel ;
-                                tasks.state  =0;
-                                tasks.type  = it .F_Type ;
-                                tasks.content  = it.F_Content ;
-                                tasks.outbound_id   = iv .F_ID ;
-                                tasks.status = 0;
-                                var res = await _taskrepository.Add (tasks);
-                                if (res>0)
+                                var model = await _taskrepository.GetListALL(x => x.outbound_id == iv.F_ID);
+                                if (model==null || model.Count <=0)
                                 {
-                                  n=  n + 1;
-
+                                    task tasks = new task();
+                                    tasks.agent = user;
+                                    tasks.number = iv.F_Tel;
+                                    tasks.state = 0;
+                                    tasks.type = it.F_Type;
+                                    tasks.content = it.F_Content;
+                                    tasks.outbound_id = iv.F_ID;
+                                    tasks.status = 0;
+                                    var res = await _taskrepository.Add(tasks);
+                                   
                                 }
                             }
+                            n = modellist.Count ();
                         }
                     }
                     if (n >0)

代码/TVShoppingCallCenter_ZLJ/Controllers/CallCenter/CallFunctionController.cs

@@ -37,9 +37,11 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.CallCenter
         private readonly ISys_AutoDialRepository sys_autodialrepository;
         private readonly ISys_SystemConfigRepository busSystemConfigRepository;
         private readonly ICus_VipInfoRepository _cus_vip_infoRepository;//客户
+        private readonly Ipoint_agentRepository _point_agentrepository;
         public CallFunctionController(ISys_SystemConfigRepository _busSystemConfigRepository,ICDRRepository _busCdrRepository,ICall_CallRecordsRepository _busCallRecordsRepository,IConfiguration _configuration, ISys_MobileDataRepository _busMobileDataRepository, ICus_VipInfoRepository cus_vip_infoRepository,
             ICall_CallOutboundRepository _CallOutboundRecordsRepository, Iauto_cdrRepository _auto_cdrRepository
-            , ItaskRepository _taskRepository, ISys_AutoDialRepository _sys_autodialrepository)
+            , ItaskRepository _taskRepository, ISys_AutoDialRepository _sys_autodialrepository,
+            Ipoint_agentRepository point_agentrepository)
         {
             busSystemConfigRepository = _busSystemConfigRepository;
             busCdrRepository = _busCdrRepository;
@@ -51,7 +53,8 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.CallCenter
             auto_cdrRepository = _auto_cdrRepository;
             taskRepository = _taskRepository;
             sys_autodialrepository = _sys_autodialrepository;
-    }
+            _point_agentrepository = point_agentrepository;
+        }
 
         /// <summary>
         /// 电话归属地查询
@@ -173,6 +176,14 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.CallCenter
                         {
                             modelRecord.CusCode = cus.FirstOrDefault ().F_Name ;
                             modelRecord.CusId = cus.FirstOrDefault().F_ID ;
+                            var point = await _point_agentrepository.GetListALL(x => x.agent == modelcdr.callee_agent);
+                            if (point==null && point.Count ()<=0)
+                            {
+                                point_agent point_Agent = new point_agent();
+                                point_Agent.caller = modelcdr.caller;
+                                point_Agent.agent  = modelcdr.callee_agent;
+                                var res = _point_agentrepository.Add(point_Agent);
+                            }
                         }
                     }
                     else

代码/TVShoppingCallCenter_ZLJ/Startup.cs

@@ -208,6 +208,7 @@ namespace TVShoppingCallCenter_ZLJ
             services.AddTransient<ItaskRepository, taskRepository>();
             services.AddTransient<Iauto_cdrRepository , auto_cdrRepository>();
             services.AddTransient<ICall_CallOutboundRepository, Call_CallOutboundRepository>();
+            services.AddTransient<Ipoint_agentRepository, point_agentRepository>();
             
             #endregion