自动外呼对接中间件，自动外呼通话记录表

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

@@ -0,0 +1,16 @@
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.Model.Call;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace System.IRepositories.Call
+{
+   
+    public interface ICall_CallOutboundRepository : IRepository<T_Call_CallOutbound>
+    {
+        Task<int> GetCallNumber(string DeptCode, int teamid, DateTime dtime);
+        Task<int> GetTotleCallNumber(string DeptCode, int teamid, DateTime dtime);
+    }
+}

代码/System.IRepositories/Call/Iauto_cdrRepository.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 Iauto_cdrRepository : IRepository<auto_cdr>
+    {
+    }
+}

代码/System.IRepositories/Call/ItaskRepository.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 ItaskRepository : IRepository<task>
+    {
+    }
+}

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

@@ -0,0 +1,571 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace System.Model.Call
+{
+    /// <summary>
+    /// 通话记录表
+    /// </summary>
+    [Serializable]
+    public partial class T_Call_CallOutbound
+    {
+        public T_Call_CallOutbound()
+        { }
+        #region Model
+        private int _id;
+        private int _cdrid;
+        private string _callid;
+        private string _turnid;
+        private string _callnumber;
+        private string _relaynumber;
+        private int? _cusid;
+        private string _cuscode;
+        private int? _calltype = 0;
+        private int? _callstate;
+        private int? _dealtype;
+        private DateTime? _begintime = DateTime.Now;
+        private DateTime? _ivrstarttime;
+        private DateTime? _ivrendtime;
+        private DateTime? _ringstarttime;
+        private DateTime? _ringendtime;
+        private DateTime? _talkstarttime;
+        private DateTime? _talkendtime;
+        private DateTime? _endtime = DateTime.Now;
+        private int? _longtime;
+        private int? _ivrlongtime;
+        private int? _ringlongtime;
+        private int? _talklongtime;
+        private int? _userid;
+        private string _usercode;
+        private string _username;
+        private string _extnumber;
+        private string _filepath;
+        private bool _isexitworkorder = false;
+        private int? _isdeal = 0;
+        private int? _operatetype;
+        private string _operateobject;
+        private DateTime? _operatetime;
+        private string _remark;
+        private int? _myd;
+        private int? _businesstype;
+        private string _location;
+        private DateTime? _waitstarttime;
+        private DateTime? _waitendtime;
+        private int? _waitlongtime = 0;
+        private int? _nocallstate = 0;
+        private int? _worktimesdiff;
+        private int? _f_qcstate = 0;
+        private decimal? _f_qcscore = 0M;
+        private string _f_qcremark;
+        private int? _f_qcuserid;
+        private string _f_qcusername;
+        private DateTime? _f_qctime;
+        private int? _f_qcisselect;
+        private string _f_qcquestion;
+        private string _f_qcadvise;
+        private int? _f_zxreasonid;
+        private int? _f_lsreasonid;
+        private int? _f_zsreasonid;
+        private string _tasktype;
+        private string _taskphoneid;
+        private string _taskid;
+        private int? _actionid = 1;
+        private int? _actiontype = 0;
+        private string _groupcode;
+        /// <summary>
+        /// 来电Id
+        /// </summary>
+        public int Id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// cdr自增id 用于同步
+        /// </summary>
+        public int CdrId
+        {
+            set { _cdrid = value; }
+            get { return _cdrid; }
+        }
+        /// <summary>
+        /// 电话流转ID 从始至终贯穿 无论中间换过多少次通话
+        /// </summary>
+        public string TurnId
+        {
+            set { _turnid = value; }
+            get { return _turnid; }
+        }
+
+        /// <summary>
+        /// 呼叫编号
+        /// </summary>
+        public string CallId
+        {
+            set { _callid = value; }
+            get { return _callid; }
+        }
+        /// <summary>
+        /// 主叫号码
+        /// </summary>
+        public string Caller
+        {
+            set { _callnumber = value; }
+            get { return _callnumber; }
+        }
+        /// <summary>
+        /// 客户id
+        /// </summary>
+        public int? CusId
+        {
+            set { _cusid = value; }
+            get { return _cusid; }
+        }
+        /// <summary>
+        /// 客户编号
+        /// </summary>
+        public string CusCode
+        {
+            set { _cuscode = value; }
+            get { return _cuscode; }
+        }
+        /// <summary>
+        /// 中继号
+        /// </summary>
+        public string RelayNumber
+        {
+            set { _relaynumber = value; }
+            get { return _relaynumber; }
+        }
+
+        /// <summary>
+        /// 呼叫类型,0呼入1呼出
+        /// </summary>
+        public int? CallType
+        {
+            set { _calltype = value; }
+            get { return _calltype; }
+        }
+        /// <summary>
+        /// 呼叫状态,0:未接通电话1已接通电话
+        /// </summary>
+        public int? CallState
+        {
+            set { _callstate = value; }
+            get { return _callstate; }
+        }
+        /// <summary>
+        /// 处理方式0:IVR处理1骚扰电话2自助服务3转值班电话4留言5呼损6人工处理
+        /// </summary>
+        public int? DealType
+        {
+            set { _dealtype = value; }
+            get { return _dealtype; }
+        }
+        /// <summary>
+        /// 开始时间
+        /// </summary>
+        public DateTime? BeginTime
+        {
+            set { _begintime = value; }
+            get { return _begintime; }
+        }
+        /// <summary>
+        /// ivr开始时间
+        /// </summary>
+        public DateTime? IvrStartTime
+        {
+            set { _ivrstarttime = value; }
+            get { return _ivrstarttime; }
+        }
+        /// <summary>
+        /// ivr结束时间
+        /// </summary>
+        public DateTime? IvrEndTime
+        {
+            set { _ivrendtime = value; }
+            get { return _ivrendtime; }
+        }
+        /// <summary>
+        /// 振铃开始时间
+        /// </summary>
+        public DateTime? RingStartTime
+        {
+            set { _ringstarttime = value; }
+            get { return _ringstarttime; }
+        }
+        /// <summary>
+        /// 振铃结束时间
+        /// </summary>
+        public DateTime? RingEndTime
+        {
+            set { _ringendtime = value; }
+            get { return _ringendtime; }
+        }
+        /// <summary>
+        /// 通话开始时间
+        /// </summary>
+        public DateTime? TalkStartTime
+        {
+            set { _talkstarttime = value; }
+            get { return _talkstarttime; }
+        }
+        /// <summary>
+        /// 通话结束时间
+        /// </summary>
+        public DateTime? TalkEndTime
+        {
+            set { _talkendtime = value; }
+            get { return _talkendtime; }
+        }
+        /// <summary>
+        /// 结束时间
+        /// </summary>
+        public DateTime? EndTime
+        {
+            set { _endtime = value; }
+            get { return _endtime; }
+        }
+        /// <summary>
+        /// 总时长(s)
+        /// </summary>
+        public int? LongTime
+        {
+            set { _longtime = value; }
+            get { return _longtime; }
+        }
+        /// <summary>
+        /// IVR时长(s)
+        /// </summary>
+        public int? IvrLongTime
+        {
+            set { _ivrlongtime = value; }
+            get { return _ivrlongtime; }
+        }
+        /// <summary>
+        /// 振铃时长(s)
+        /// </summary>
+        public int? RingLongTime
+        {
+            set { _ringlongtime = value; }
+            get { return _ringlongtime; }
+        }
+        /// <summary>
+        /// 通话时长(s)
+        /// </summary>
+        public int? TalkLongTime
+        {
+            set { _talklongtime = value; }
+            get { return _talklongtime; }
+        }
+        /// <summary>
+        /// 坐席id
+        /// </summary>
+        public int? UserId
+        {
+            set { _userid = value; }
+            get { return _userid; }
+        }
+        /// <summary>
+        /// 坐席工号
+        /// </summary>
+        public string UserCode
+        {
+            set { _usercode = value; }
+            get { return _usercode; }
+        }
+        /// <summary>
+        /// 坐席姓名
+        /// </summary>
+        public string UserName
+        {
+            set { _username = value; }
+            get { return _username; }
+        }
+        /// <summary>
+        /// 被叫号码 如果是座机显示的是 中继号后的分机号
+        /// </summary>
+        public string Callee
+        {
+            set { _extnumber = value; }
+            get { return _extnumber; }
+        }
+        /// <summary>
+        /// 用于获取录音的编号
+        /// </summary>
+        public string FilePath
+        {
+            set { _filepath = value; }
+            get { return _filepath; }
+        }
+        /// <summary>
+        /// 是否录入工单
+        /// </summary>
+        public bool IsExitWorkOrder
+        {
+            set { _isexitworkorder = value; }
+            get { return _isexitworkorder; }
+        }
+        /// <summary>
+        /// 是否处理0未处理1已处理2注销
+        /// </summary>
+        public int? IsDeal
+        {
+            set { _isdeal = value; }
+            get { return _isdeal; }
+        }
+        /// <summary>
+        /// 操作类型，0正常1转移2三方通话
+        /// </summary>
+        public int? OperateType
+        {
+            set { _operatetype = value; }
+            get { return _operatetype; }
+        }
+        /// <summary>
+        /// 操作目标
+        /// </summary>
+        public string OperateObject
+        {
+            set { _operateobject = value; }
+            get { return _operateobject; }
+        }
+        /// <summary>
+        /// 操作时间
+        /// </summary>
+        public DateTime? OperateTime
+        {
+            set { _operatetime = value; }
+            get { return _operatetime; }
+        }
+        /// <summary>
+        /// 备注
+        /// </summary>
+        public string Remark
+        {
+            set { _remark = value; }
+            get { return _remark; }
+        }
+        /// <summary>
+        /// 满意度，1非常满意、2基本满意、3不满意
+        /// </summary>
+        public int? MYD
+        {
+            set { _myd = value; }
+            get { return _myd; }
+        }
+        /// <summary>
+        /// IVR中选择的业务类型
+        /// </summary>
+        public int? BusinessType
+        {
+            set { _businesstype = value; }
+            get { return _businesstype; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string Location
+        {
+            set { _location = value; }
+            get { return _location; }
+        }
+
+        /// <summary>
+        /// 排队开始时间
+        /// </summary>
+        public DateTime? WaitStartTime
+        {
+            set { _waitstarttime = value; }
+            get { return _waitstarttime; }
+        }
+        /// <summary>
+        /// 排队结束时间
+        /// </summary>
+        public DateTime? WaitEndTime
+        {
+            set { _waitendtime = value; }
+            get { return _waitendtime; }
+        }
+        /// <summary>
+        /// 排队时长
+        /// </summary>
+        public int? WaitLongTime
+        {
+            set { _waitlongtime = value; }
+            get { return _waitlongtime; }
+        }
+        /// <summary>
+        /// 未接通状态（0其他、1坐席未登录、2坐席忙、3振铃）
+        /// </summary>
+        public int? NoCallState
+        {
+            set { _nocallstate = value; }
+            get { return _nocallstate; }
+        }
+        /// <summary>
+        /// 与工作时间间隔秒数
+        /// </summary>
+        public int? WorkTimesDiff
+        {
+            set { _worktimesdiff = value; }
+            get { return _worktimesdiff; }
+        }
+
+
+        #region 质检
+        /// <summary>
+        /// 质检状态（0未质检、1已质检）
+        /// </summary>
+        public int? F_QCState
+        {
+            set { _f_qcstate = value; }
+            get { return _f_qcstate; }
+        }
+        /// <summary>
+        /// 质检分值
+        /// </summary>
+        public decimal? F_QCScore
+        {
+            set { _f_qcscore = value; }
+            get { return _f_qcscore; }
+        }
+        /// <summary>
+        /// 质检备注
+        /// </summary>
+        public string F_QCRemark
+        {
+            set { _f_qcremark = value; }
+            get { return _f_qcremark; }
+        }
+        /// <summary>
+        /// 质检人Id
+        /// </summary>
+        public int? F_QCUserId
+        {
+            set { _f_qcuserid = value; }
+            get { return _f_qcuserid; }
+        }
+        /// <summary>
+        /// 质检人名称
+        /// </summary>
+        public string F_QCUserName
+        {
+            set { _f_qcusername = value; }
+            get { return _f_qcusername; }
+        }
+        /// <summary>
+        /// 质检时间
+        /// </summary>
+        public DateTime? F_QCTime
+        {
+            set { _f_qctime = value; }
+            get { return _f_qctime; }
+        }
+
+
+
+        /// <summary>
+        /// 质检客服-存在的问题
+        /// </summary>
+        public string F_QCQuestion
+        {
+            set { _f_qcquestion = value; }
+            get { return _f_qcquestion; }
+        }
+        /// <summary>
+        /// 质检客服-修改意见
+        /// </summary>
+        public string F_QCAdvise
+        {
+            set { _f_qcadvise = value; }
+            get { return _f_qcadvise; }
+        }
+        #endregion
+
+
+        /// <summary>
+        /// 是否推荐
+        /// </summary>
+        public int? F_QCIsSelect
+        {
+            set { _f_qcisselect = value; }
+            get { return _f_qcisselect; }
+        }
+        /// <summary>
+        /// 咨询来电原因ID
+        /// </summary>
+        public int? F_ZXReasonID
+        {
+            set { _f_zxreasonid = value; }
+            get { return _f_zxreasonid; }
+        }
+        /// <summary>
+        /// 临时来电原因ID
+        /// </summary>
+        public int? F_LSReasonID
+        {
+            set { _f_lsreasonid = value; }
+            get { return _f_lsreasonid; }
+        }
+        /// <summary>
+        /// 招商来电原因ID
+        /// </summary>
+        public int? F_ZSReasonID
+        {
+            set { _f_zsreasonid = value; }
+            get { return _f_zsreasonid; }
+        }
+        /// <summary>
+        /// 拨号类型：0:拨号外呼；1:95005回访外呼；2:电销回访外呼
+        /// </summary>
+        public string TaskType
+        {
+            set { _tasktype = value; }
+            get { return _tasktype; }
+        }
+        /// <summary>
+        /// 回访的电话ID
+        /// </summary>
+        public string TaskPhoneID
+        {
+            set { _taskphoneid = value; }
+            get { return _taskphoneid; }
+        }
+        /// <summary>
+        /// 回访记录编号：GUID编号唯一
+        /// </summary>
+        public string TaskID
+        {
+            set { _taskid = value; }
+            get { return _taskid; }
+        }
+        /// <summary>
+        /// 区别正常呼入呼出、转移、三方通话
+        /// </summary>
+        public int? ActionID
+        {
+            set { _actionid = value; }
+            get { return _actionid; }
+        }
+        /// <summary>
+        /// 1正常呼入呼出、2转移、3三方通话
+        /// </summary>
+        public int? ActionType
+        {
+            set { _actiontype = value; }
+            get { return _actiontype; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string GroupCode
+        {
+            set { _groupcode = value; }
+            get { return _groupcode; }
+        }
+        #endregion Model
+
+    }
+}

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

@@ -0,0 +1,127 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace System.Model.Call
+{
+    /// <summary>
+    /// auto_cdr:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class auto_cdr
+    {
+        public auto_cdr()
+        { }
+        #region Model
+        private long _id;
+        private string _uuid;
+        private string _agent;
+        private string _caller;
+        private string _callee;
+        private DateTime? _create_time;
+        private DateTime? _ring_time;
+        private DateTime? _answer_time;
+        private DateTime? _end_time;
+        private string _record_path;
+        private long? _task_id;
+        private string _hangup_cause;
+        /// <summary>
+        /// auto_increment
+        /// </summary>
+        public long id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string uuid
+        {
+            set { _uuid = value; }
+            get { return _uuid; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string agent
+        {
+            set { _agent = value; }
+            get { return _agent; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string caller
+        {
+            set { _caller = value; }
+            get { return _caller; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string callee
+        {
+            set { _callee = value; }
+            get { return _callee; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? create_time
+        {
+            set { _create_time = value; }
+            get { return _create_time; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? ring_time
+        {
+            set { _ring_time = value; }
+            get { return _ring_time; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? answer_time
+        {
+            set { _answer_time = value; }
+            get { return _answer_time; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? end_time
+        {
+            set { _end_time = value; }
+            get { return _end_time; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string record_path
+        {
+            set { _record_path = value; }
+            get { return _record_path; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public long? task_id
+        {
+            set { _task_id = value; }
+            get { return _task_id; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string hangup_cause
+        {
+            set { _hangup_cause = value; }
+            get { return _hangup_cause; }
+        }
+        #endregion Model
+
+    }
+}

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

@@ -0,0 +1,97 @@
+using System;
+namespace System.Model.Call
+{
+    /// <summary>
+    /// task:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class task
+    {
+        public task()
+        { }
+        #region Model
+        private long _id;
+        private string _agent;
+        private string _number;
+        private int? _state;
+        private int? _type;
+        private string _content;
+        private DateTime? _op_time;
+        private int? _outbound_id;
+        private int? _status;
+        /// <summary>
+        /// auto_increment
+        /// </summary>
+        public long id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string agent
+        {
+            set { _agent = value; }
+            get { return _agent; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string number
+        {
+            set { _number = value; }
+            get { return _number; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? state
+        {
+            set { _state = value; }
+            get { return _state; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? type
+        {
+            set { _type = value; }
+            get { return _type; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string content
+        {
+            set { _content = value; }
+            get { return _content; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public DateTime? op_time
+        {
+            set { _op_time = value; }
+            get { return _op_time; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? outbound_id
+        {
+            set { _outbound_id = value; }
+            get { return _outbound_id; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public int? status
+        {
+            set { _status = value; }
+            get { return _status; }
+        }
+        #endregion Model
+
+    }
+}

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

@@ -83,6 +83,7 @@ namespace System.Model.Sys
             set { _f_isdelete = value; }
             get { return _f_isdelete; }
         }
+
         #endregion Model
 
     }

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

@@ -0,0 +1,70 @@
+using System;
+using System.Collections.Generic;
+using System.Common;
+using System.Data;
+using System.IRepositories.Call;
+using System.Model.Call;
+using System.Text;
+using System.Threading.Tasks;
+using SqlSugar;
+
+namespace System.Repositories.Call
+{
+    
+    public class Call_CallOutboundRepository : BaseRepository<T_Call_CallOutbound>, ICall_CallOutboundRepository
+    {
+
+        public async Task<int> GetCallNumber(string DeptCode, int teamid, DateTime dtime)
+        {
+            string sql = "SELECT COUNT(1) FROM T_Call_CallOutbound where  TalkLongTime>0 AND BeginTime BETWEEN @stime AND @etime ";
+            if (!string.IsNullOrEmpty(DeptCode))
+            {
+                sql += $" AND UserCode in (SELECT F_UserCode FROM `T_Sys_UserAccount` WHERE F_DeptId IN(SELECT F_DeptId FROM  T_Sys_Department WHERE F_DeptCode LIKE '{DeptCode}%'))";
+                DeptCode = "|0|1|";
+            }
+
+            if (teamid > 0)
+            {
+                sql += $" AND UserCode in (SELECT F_UserCode FROM `T_Sys_UserAccount` WHERE F_DeptTeamId ={teamid})";
+            }
+            List<SugarParameter> sugarParameter = new List<SugarParameter>()
+            {
+                new SugarParameter("@stime",dtime),
+                new SugarParameter("@etime",dtime.AddMonths(1)),
+            };
+
+            DataTable dt = await GetTableSugar(sql, sugarParameter);
+            if (dt != null && dt.Rows.Count > 0)
+            {
+                return dt.Rows[0][0].ObjToInt();
+            }
+            return 0;
+        }
+        public async Task<int> GetTotleCallNumber(string DeptCode, int teamid, DateTime dtime)
+        {
+            string sql = "SELECT COUNT(1) FROM T_Call_CallOutbound where  BeginTime BETWEEN @stime AND @etime ";
+            if (!string.IsNullOrEmpty(DeptCode))
+            {
+                sql += $" AND UserCode in (SELECT F_UserCode FROM `T_Sys_UserAccount` WHERE F_DeptId IN(SELECT F_DeptId FROM  T_Sys_Department WHERE F_DeptCode LIKE '{DeptCode}%'))";
+                DeptCode = "|0|1|";
+            }
+
+            if (teamid > 0)
+            {
+                sql += $" AND UserCode in (SELECT F_UserCode FROM `T_Sys_UserAccount` WHERE F_DeptTeamId ={teamid})";
+            }
+
+            List<SugarParameter> sugarParameter = new List<SugarParameter>()
+            {
+                new SugarParameter("@stime",dtime),
+                new SugarParameter("@etime",dtime.AddMonths(1)),
+            };
+            DataTable dt = await GetTableSugar(sql, sugarParameter);
+            if (dt != null && dt.Rows.Count > 0)
+            {
+                return dt.Rows[0][0].ObjToInt();
+            }
+            return 0;
+        }
+    }
+}

代码/System.Repositories/Call/auto_cdrRepository.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 auto_cdrRepository : BaseMysqlRepository<auto_cdr>, Iauto_cdrRepository
+    {
+    }
+}

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

@@ -0,0 +1,15 @@
+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 taskRepository : BaseMysqlRepository<task>, ItaskRepository
+    {
+    }
+}

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

@@ -3,12 +3,13 @@ using System.Collections.Generic;
 using System.Common;
 using System.Common.Helpers;
 using System.Data;
+using System.IRepositories.Call;
 using System.IRepositories.Sys;
 using System.Linq;
+using System.Model.Call;
 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;
@@ -20,12 +21,14 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
     public class OutboundTaskController : BaseController
     {
         private readonly ISys_OutboundTaskReposity _sys_outboundTaskrepository;
+        private readonly ItaskRepository _taskrepository;
         private readonly ISys_AutoDialRepository _sys_autodialrepository;
         public OutboundTaskController(ISys_OutboundTaskReposity sys_outboundTaskrepository
-            , ISys_AutoDialRepository sys_autodialrepository)
+            , ISys_AutoDialRepository sys_autodialrepository, ItaskRepository taskrepository)
         {
             _sys_outboundTaskrepository = sys_outboundTaskrepository;
             _sys_autodialrepository = sys_autodialrepository;
+            _taskrepository = taskrepository;
         }
         /// <summary>
         /// 添加外呼任务
@@ -130,7 +133,6 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
         /// <summary>
         /// 添加中间件外呼任务
         /// </summary>
-        /// <param name="input"></param>
         /// <returns></returns>
         [HttpPost("addmiddleware")]
         public async Task<IActionResult> Addmiddleware()
@@ -150,6 +152,7 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
             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");
+            int n = 0;
             if (list != null)
             {
                 if (list.Count > 0)
@@ -160,6 +163,7 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
                         #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() });
+                        conModel.Add(new ConditionalModel() { FieldName = "F_ISOutbound", ConditionalType = ConditionalType.Equal, FieldValue = "0" });
                         #endregion
                         var modellist = await _sys_autodialrepository.GetListALL (conModels, "  F_ID  asc");
                         if (modellist!=null )
@@ -173,10 +177,20 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.AutoDial
                                 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)
+                                {
+                                  n=  n + 1;
+
+                                }
                             }
                         }
                     }
+                    if (n >0)
                     return Success("任务启动", list.Count);
+                    else
+                     return Success("暂无任务", 0);
                 }
                 else
                     return Success("暂无任务", 0);

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

@@ -2,8 +2,12 @@
 using System.Collections.Generic;
 using System.Common;
 using System.IRepositories;
+using System.IRepositories.Call;
+using System.IRepositories.Sys;
 using System.Linq;
 using System.Model;
+using System.Model.Call;
+using System.Model.Sys;
 using System.Security.Claims;
 using System.Threading.Tasks;
 using System.Utility;
@@ -26,10 +30,16 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.CallCenter
         private readonly IConfiguration config;
         private readonly ISys_MobileDataRepository busMobileDataRepository;
         private readonly ICall_CallRecordsRepository busCallRecordsRepository;
+        private readonly ICall_CallOutboundRepository CallOutboundRecordsRepository;
         private readonly ICDRRepository busCdrRepository;
+        private readonly Iauto_cdrRepository auto_cdrRepository;
+        private readonly ItaskRepository taskRepository;
+        private readonly ISys_AutoDialRepository sys_autodialrepository;
         private readonly ISys_SystemConfigRepository busSystemConfigRepository;
         private readonly ICus_VipInfoRepository _cus_vip_infoRepository;//客户
-        public CallFunctionController(ISys_SystemConfigRepository _busSystemConfigRepository,ICDRRepository _busCdrRepository,ICall_CallRecordsRepository _busCallRecordsRepository,IConfiguration _configuration, ISys_MobileDataRepository _busMobileDataRepository, ICus_VipInfoRepository cus_vip_infoRepository)
+        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)
         {
             busSystemConfigRepository = _busSystemConfigRepository;
             busCdrRepository = _busCdrRepository;
@@ -37,7 +47,10 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.CallCenter
             config = _configuration;
             busMobileDataRepository = _busMobileDataRepository;
             _cus_vip_infoRepository = cus_vip_infoRepository;
-
+            CallOutboundRecordsRepository = _CallOutboundRecordsRepository;
+            auto_cdrRepository = _auto_cdrRepository;
+            taskRepository = _taskRepository;
+            sys_autodialrepository = _sys_autodialrepository;
     }
 
         /// <summary>
@@ -223,7 +236,144 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.CallCenter
             }
             return $"同步情况  成功/总数 = {n1}/{totle}";
         }
-        #endregion
+        /// <summary>
+        /// 同步自动外呼通话记录
+        /// </summary>
+        /// <returns></returns>
+        [NonAction]
+        internal async Task<string> SyncOutbound()
+        {
+            DateTime dtime = DateTime.Now.AddYears(-10);
+            int maxid = 0;
+            T_Call_CallOutbound modelCallRecord = await CallOutboundRecordsRepository.GetFirst(q => q.CdrId > 0, o => new { o.CdrId }, OrderByType.Desc);
+            if (modelCallRecord != null)
+            {
+                maxid = modelCallRecord.CdrId;
+            }
+            modelCallRecord = await CallOutboundRecordsRepository.GetFirst(q => q.CdrId > 0, o => new { o.EndTime }, OrderByType.Desc);
+            if (modelCallRecord != null)
+            {
+                if (modelCallRecord.EndTime != null)
+                    dtime = modelCallRecord.EndTime.GetValueOrDefault();
+            }
+            List<auto_cdr > modellist = await auto_cdrRepository.GetListALL(q => q.id > maxid || q.end_time >= dtime);
+            int totle = 0;
+            int n = 0;
+            int n1 = 0;
+            if (modellist != null && modellist.Count > 0)
+            {
+                string url = "请配置videoURL/";
+                T_Sys_SystemConfig model = await busSystemConfigRepository.GetSingle(q => q.F_ParamCode == "videoURL");
+                if (model != null)
+                {
+                    url = model.F_ParamValue;
+                }
+                totle = modellist.Count;
+                List<T_Call_CallOutbound> modelRecordList = new List<T_Call_CallOutbound>();
+                foreach (auto_cdr modelcdr in modellist)
+                {
+
+                    T_Call_CallOutbound modelRecord = new T_Call_CallOutbound();
+                    modelRecord.ActionID =1;
+                    modelRecord.TalkStartTime = modelcdr.answer_time;
+                    modelRecord.Callee = modelcdr.callee;
+                     modelRecord.UserCode = modelcdr.agent ;
+                        string tel = modelcdr.callee.TrimStart('0');
+                        modelRecord.UserCode = modelcdr.agent;
+                        var cus = await _cus_vip_infoRepository.GetListALL(x => x.F_State == 1 && x.F_Phone
+                       == modelcdr.caller || x.F_Phone
+                       == tel);
+                        if (cus != null && cus.Count > 0)
+                        {
+                            modelRecord.CusCode = cus.FirstOrDefault().F_Name;
+                            modelRecord.CusId = cus.FirstOrDefault().F_ID;
+                        }
+                    modelRecord.Caller = modelcdr.caller;
+                    modelRecord.CallType = 1;
+                    modelRecord.BeginTime = modelcdr.create_time;
+                    modelRecord.EndTime = modelcdr.end_time;
+                    //  modelcdr.hangup_cause;挂机原因不赋值  HangUpReason
+                    //  modelcdr.leave_path 留言 赋值给了FilePath
+                    modelRecord.FilePath = url + modelcdr.record_path;
+                    if (string.IsNullOrEmpty(modelcdr.record_path))
+                    {
+                        modelRecord.FilePath = url + modelcdr.record_path;
+                    }
+                    modelRecord.RingStartTime = modelcdr.ring_time;
+                    modelRecord.CallId = modelcdr.uuid;
+                    modelRecord.Location = await GetLocationFunc(modelcdr.caller, 1);
+                    #region 计算时长
+                    modelRecord.LongTime = (int)DateTimeConvert.DateDiff(DateInterval.Second, modelcdr.create_time.GetValueOrDefault(), modelcdr.end_time.GetValueOrDefault());
+
+                    if (modelcdr.answer_time != null)
+                        modelRecord.TalkLongTime = (int)DateTimeConvert.DateDiff(DateInterval.Second, modelcdr.answer_time.GetValueOrDefault(), modelcdr.end_time.GetValueOrDefault());
+                    else
+                        modelRecord.TalkLongTime = 0;
+                    #endregion
+                    n++;
+                    n1++;
+                    modelRecordList.Add(modelRecord);
+                    if (n >= 2000)
+                    {
+                        await CallOutboundRecordsRepository.AddAndUpdateList(modelRecordList);
+                        modelRecordList.Clear();
+                        n = 0;
+                    }
+
+                }
+                await CallOutboundRecordsRepository.AddAndUpdateList(modelRecordList);
+            }
+            return $"同步情况  成功/总数 = {n1}/{totle}";
+        }
+
+        /// <summary>
+        /// 同步外呼状态
+        /// </summary>
+        /// <returns></returns>
+        [NonAction]
+        internal async Task<string> SyncAutodial()
+        {
+            List<task > modellist = await taskRepository.GetListALL(q => q.status  ==0 &&q .state ==1);
+            int totle = 0;
+            int n = 0;
+            int n1 = 0;
+            if (modellist != null && modellist.Count > 0)
+            {
+                List<T_Sys_AutoDial> modelAutoDial = new List<T_Sys_AutoDial>();
+                List<task> taskList  = new List<task>();
+                foreach (task  it  in modellist)
+                {
+                    var AutoDial = await sys_autodialrepository.GetSingle (q => q.F_ID  == it.outbound_id );
+                    if (AutoDial!=null )
+                    {
+                        AutoDial.F_ISOutbound = 1;
+                        modelAutoDial.Add(AutoDial);
+                        n++;
+                    }
+                    it.status = 1;
+                    taskList.Add(it);
+                    #endregion
+                    n1++;
+                    if (n >= 2000)
+                    {
+                        await sys_autodialrepository.AddAndUpdateList(modelAutoDial);
+                        modelAutoDial.Clear();
+                        n = 0;
+                    }
+                    if (n1 >=2000)
+                    {
+                        await taskRepository.AddAndUpdateList(taskList);
+                        taskList.Clear();
+                        n1 = 0;
+                    }
+                }
+                await sys_autodialrepository.AddAndUpdateList(modelAutoDial);
+                await taskRepository.AddAndUpdateList(taskList);
+
+            }
+            return $"同步情况  成功/总数 = {n1}/{totle}";
+        }
+       
 
     }
 }

代码/TVShoppingCallCenter_ZLJ/Controllers/hangfire/HangfireController.cs

@@ -185,7 +185,31 @@ namespace TVShoppingCallCenter_ZLJ.Controllers.hangfire
         }
         #endregion
 
-
+        /// <summary>
+        /// 同步自动外呼通话记录
+        /// </summary>
+        /// <returns></returns>
+        [NonAction]
+        public async Task<IActionResult> MinutelyOutbound()
+        {
+            string str = "";
+            //同步通话记录
+            str = await busCallFunctionController.SyncOutbound();
+            return Success(str);
+        }
+        /// <summary>
+        /// 同步自动外呼通话记录
+        /// </summary>
+        /// <returns></returns>
+        [NonAction]
+        public async Task<IActionResult> AutodialOutbound()
+        {
+            string str = "";
+            //同步通话记录
+            str = await busCallFunctionController.SyncAutodial();
+            return Success(str);
+        }
+        
         #region 月12循环 
 
         /// <summary>

代码/TVShoppingCallCenter_ZLJ/Startup.cs

@@ -206,6 +206,9 @@ namespace TVShoppingCallCenter_ZLJ
             services.AddTransient<ISys_AutoDialRepository, Sys_AutoDialRepository>();
 
             services.AddTransient<ItaskRepository, taskRepository>();
+            services.AddTransient<Iauto_cdrRepository , auto_cdrRepository>();
+            services.AddTransient<ICall_CallOutboundRepository, Call_CallOutboundRepository>();
+            
             #endregion
 
 
@@ -248,7 +251,7 @@ namespace TVShoppingCallCenter_ZLJ
 
             app.UseHangfireServer(new BackgroundJobServerOptions
             {
-                Queues = new[] { "daily", "minutely", "monthly", "month12" },//队列名称，只能为小写
+                Queues = new[] { "daily", "minutely", "monthly", "outbound", "autodial", "month12" },//队列名称，只能为小写
                 WorkerCount = Environment.ProcessorCount * 3, //并发任务数
                 ServerName = "hangfireMysql",//服务器名称
             });//启动Hangfire服务  有可选参数
@@ -260,7 +263,8 @@ 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.MinutelyOutbound(), Cron.Minutely, TimeZoneInfo.Local, "outbound");
+            RecurringJob.AddOrUpdate<HangfireController>(a => a.AutodialOutbound(), Cron.Minutely, TimeZoneInfo.Local, "autodial");
             //秒 分 时 日   *每
             RecurringJob.AddOrUpdate<HangfireController>(a => a.Month12Recurring(), "0 0 0 12 * ?", TimeZoneInfo.Local, "month12");
             #region steeltoe