外呼任务

代码/System.Model/Sys/T_Sys_OutboundTask.cs

@@ -19,7 +19,9 @@ namespace System.Model.Sys
         private string _f_adduser;
         private string _f_taskuser;
         private int? _f_isdelete;
+        private int? _f_type;
         private string _f_remarks;
+        private string _f_content;
         private DateTime? _f_starttime;
         private DateTime? _f_endtime;
         private int? _f_state;
@@ -92,6 +94,22 @@ namespace System.Model.Sys
             set { _f_isdelete = value; }
             get { return _f_isdelete; }
         }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? F_Type
+        {
+            set { _f_type = value; }
+            get { return _f_type; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_Content
+        {
+            set { _f_content = value; }
+            get { return _f_content; }
+        }
         #endregion Model
 
     }

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

@@ -8,6 +8,7 @@ using System.Linq;
 using System.Model.Sys;
 using System.Security.Claims;
 using System.Threading.Tasks;
+using Maticsoft.Model;
 using Microsoft.AspNetCore.Mvc;
 using SqlSugar;
 using TVShoppingCallCenter_ZLJ.Models.Inputs.System;
@@ -71,6 +72,8 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
             model.F_AddUser = user;
             model.F_TaskUser = input.F_TaskUser;
             model.F_IsDelete = 0;
+            model.F_Type  = input.F_Type ;
+            model.F_Content  = input.F_Content; ;
             model.F_State = input.F_State;
             model.F_StartTime = input.F_StartTime;
             model.F_EndTime = input.F_EndTime;
@@ -125,6 +128,65 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
             }
         }
         /// <summary>
+        /// 添加中间件外呼任务
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        [HttpPost("addmiddleware")]
+        public async Task<IActionResult> Addmiddleware()
+        {
+            string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+            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()
+                {
+                    ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
+                    {
+                        new  KeyValuePair<WhereType, ConditionalModel>(WhereType.And, new ConditionalModel() { FieldName = "F_TaskUser", ConditionalType = ConditionalType.Like, FieldValue = user }),
+                        new  KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_Type", ConditionalType = ConditionalType.Like, 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_State", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = "1" });
+            var list = await _sys_outboundTaskrepository.GetListALL (conModels,  "  F_AddTime  desc");
+            if (list != null)
+            {
+                if (list.Count > 0)
+                {
+                    foreach (var it in list)
+                    {
+                        List<IConditionalModel> conModel = new List<IConditionalModel>();
+                        #region 条件筛选
+                        conModel.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumUserCountState.Enabled).ToString() });
+                        conModel.Add(new ConditionalModel() { FieldName = "F_Parentid", ConditionalType = ConditionalType.Equal, FieldValue = it.F_ID .ToString() });
+                        #endregion
+                        var modellist = await _sys_autodialrepository.GetListALL (conModels, "  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 ;
+                            }
+                        }
+                    }
+                    return Success("任务启动", list.Count);
+                }
+                else
+                    return Success("暂无任务", 0);
+            }
+            else
+                return Success("暂无任务",0);
+
+            
+        }
+        /// <summary>
         /// 添加自动外呼
         /// </summary>
         /// <param name="input"></param>

代码/TVShoppingCallCenter_ZLJ/Startup.cs

@@ -32,6 +32,8 @@ using Hangfire.MySql.Core;
 using System.Data;
 using System.Repositories.Sys;
 using System.IRepositories.Sys;
+using System.IRepositories.Call;
+using System.Repositories.Call;
 
 namespace TVShoppingCallCenter_ZLJ
 {
@@ -202,6 +204,8 @@ namespace TVShoppingCallCenter_ZLJ
 
             services.AddTransient<ISys_OutboundTaskReposity, Sys_OutboundTaskReposity>();
             services.AddTransient<ISys_AutoDialRepository, Sys_AutoDialRepository>();
+
+            services.AddTransient<ItaskRepository, taskRepository>();
             #endregion
 
 
@@ -256,6 +260,7 @@ namespace TVShoppingCallCenter_ZLJ
 
             RecurringJob.AddOrUpdate<HangfireController>(a => a.DailyRecurring(), Cron.Daily, TimeZoneInfo.Local, "daily");
             RecurringJob.AddOrUpdate<HangfireController>(a => a.MinutelyRecurring(), Cron.Minutely, TimeZoneInfo.Local, "minutely");
+           
             //秒 分 时 日   *每
             RecurringJob.AddOrUpdate<HangfireController>(a => a.Month12Recurring(), "0 0 0 12 * ?", TimeZoneInfo.Local, "month12");
             #region steeltoe