数据库表，显示所有平台工单

CallCenterApi/CallCenterApi.BLL/CallCenterApi.BLL.csproj

@@ -84,6 +84,7 @@
     <Compile Include="T_CTI_TaskVoiceTemp.cs" />
     <Compile Include="T_Cus_AddressBook.cs" />
     <Compile Include="T_Cus_CustomerBase.cs" />
+    <Compile Include="T_DataBase.cs" />
     <Compile Include="T_Email_EmailList.cs" />
     <Compile Include="T_Email_EmailMessage_Map.cs" />
     <Compile Include="T_Email_SendEmail.cs" />

CallCenterApi/CallCenterApi.BLL/T_Bus_WorkOrder.cs

@@ -109,6 +109,14 @@ namespace CallCenterApi.BLL
         /// <summary>
         /// 获得数据列表
         /// </summary>
+        public List<CallCenterApi.Model.T_Bus_WorkOrder> GetModelList(string strWhere,string connectionString)
+        {
+            DataSet ds = dal.GetList(strWhere,  connectionString);
+            return DataTableToList(ds.Tables[0]);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
         public List<CallCenterApi.Model.T_Bus_WorkOrder> DataTableToList(DataTable dt)
         {
             List<CallCenterApi.Model.T_Bus_WorkOrder> modelList = new List<CallCenterApi.Model.T_Bus_WorkOrder>();

CallCenterApi/CallCenterApi.BLL/T_DataBase.cs

@@ -0,0 +1,142 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+namespace CallCenterApi.BLL
+{
+    /// <summary>
+    /// T_DataBase
+    /// </summary>
+    public partial class T_DataBase
+    {
+        
+        private readonly CallCenterApi.DAL.T_DataBase dal = new CallCenterApi.DAL.T_DataBase();
+        public T_DataBase()
+        { }
+        #region  BasicMethod
+
+        /// <summary>
+        /// 增加一条数据
+        /// </summary>
+        public int Add(Model.T_DataBase model)
+        {
+            return dal.Add(model);
+        }
+
+        /// <summary>
+        /// 更新一条数据
+        /// </summary>
+        public bool Update(Model.T_DataBase model)
+        {
+            return dal.Update(model);
+        }
+
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool Delete(int F_ID)
+        {
+
+            return dal.Delete(F_ID);
+        }
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool DeleteList(string F_IDlist)
+        {
+            return dal.DeleteList(F_IDlist);
+        }
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public Model.T_DataBase GetModel(int F_ID)
+        {
+
+            return dal.GetModel(F_ID);
+        }
+
+      
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere)
+        {
+            return dal.GetList(strWhere);
+        }
+        /// <summary>
+        /// 获得前几行数据
+        /// </summary>
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
+        {
+            return dal.GetList(Top, strWhere, filedOrder);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public List<Model.T_DataBase> GetModelList(string strWhere)
+        {
+            DataSet ds = dal.GetList(strWhere);
+            return DataTableToList(ds.Tables[0]);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public List<Model.T_DataBase> DataTableToList(DataTable dt)
+        {
+            List<Model.T_DataBase> modelList = new List<Model.T_DataBase>();
+            int rowsCount = dt.Rows.Count;
+            if (rowsCount > 0)
+            {
+               Model.T_DataBase model;
+                for (int n = 0; n < rowsCount; n++)
+                {
+                    model = dal.DataRowToModel(dt.Rows[n]);
+                    if (model != null)
+                    {
+                        modelList.Add(model);
+                    }
+                }
+            }
+            return modelList;
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetAllList()
+        {
+            return GetList("");
+        }
+
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public int GetRecordCount(string strWhere)
+        {
+            return dal.GetRecordCount(strWhere);
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+        {
+            return dal.GetListByPage(strWhere, orderby, startIndex, endIndex);
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        //public DataSet GetList(int PageSize,int PageIndex,string strWhere)
+        //{
+        //return dal.GetList(PageSize,PageIndex,strWhere);
+        //}
+
+        #endregion  BasicMethod
+        #region  ExtensionMethod
+
+        #endregion  ExtensionMethod
+    }
+}

CallCenterApi/CallCenterApi.DAL/CallCenterApi.DAL.csproj

@@ -84,6 +84,7 @@
     <Compile Include="T_CTI_TaskVoiceTemp.cs" />
     <Compile Include="T_Cus_AddressBook.cs" />
     <Compile Include="T_Cus_CustomerBase.cs" />
+    <Compile Include="T_DataBase.cs" />
     <Compile Include="T_Email_EmailList.cs" />
     <Compile Include="T_Email_EmailMessage_Map.cs" />
     <Compile Include="T_Email_SendEmail.cs" />

CallCenterApi/CallCenterApi.DAL/T_Bus_WorkOrder.cs

@@ -753,7 +753,19 @@ namespace CallCenterApi.DAL
             }
             return model;
         }
-
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere,string connectionString)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select * FROM T_Bus_WorkOrder  WITH(NOLOCK)");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            return DbHelperSQL.Query(strSql.ToString(), connectionString);
+        }
         /// <summary>
         /// 获得数据列表
         /// </summary>

CallCenterApi/CallCenterApi.DAL/T_DataBase.cs

@@ -0,0 +1,315 @@
+using CallCenterApi.DB;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Data.SqlClient;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace CallCenterApi.DAL
+{
+    /// <summary>
+    /// 数据访问类:T_DataBase
+    /// </summary>
+    public partial class T_DataBase
+    {
+        public T_DataBase()
+        { }
+        #region  BasicMethod
+
+
+
+        /// <summary>
+        /// 增加一条数据
+        /// </summary>
+        public int Add(Model.T_DataBase model)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("insert into T_DataBase(");
+            strSql.Append("F_Name,F_Tablename,F_Theserver,F_UserID,F_pwd)");
+            strSql.Append(" values (");
+            strSql.Append("@F_Name,@F_Tablename,@F_Theserver,@F_UserID,@F_pwd)");
+            strSql.Append(";select @@IDENTITY");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_Name", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Tablename", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Theserver", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_UserID", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_pwd", SqlDbType.VarChar,50)};
+            parameters[0].Value = model.F_Name;
+            parameters[1].Value = model.F_Tablename;
+            parameters[2].Value = model.F_Theserver;
+            parameters[3].Value = model.F_UserID;
+            parameters[4].Value = model.F_pwd;
+
+            object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
+            if (obj == null)
+            {
+                return 0;
+            }
+            else
+            {
+                return Convert.ToInt32(obj);
+            }
+        }
+        /// <summary>
+        /// 更新一条数据
+        /// </summary>
+        public bool Update(Model.T_DataBase model)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("update T_DataBase set ");
+            strSql.Append("F_Name=@F_Name,");
+            strSql.Append("F_Tablename=@F_Tablename,");
+            strSql.Append("F_Theserver=@F_Theserver,");
+            strSql.Append("F_UserID=@F_UserID,");
+            strSql.Append("F_pwd=@F_pwd");
+            strSql.Append(" where F_ID=@F_ID");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_Name", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Tablename", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Theserver", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_UserID", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_pwd", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_ID", SqlDbType.Int,4)};
+            parameters[0].Value = model.F_Name;
+            parameters[1].Value = model.F_Tablename;
+            parameters[2].Value = model.F_Theserver;
+            parameters[3].Value = model.F_UserID;
+            parameters[4].Value = model.F_pwd;
+            parameters[5].Value = model.F_ID;
+
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool Delete(int F_ID)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("delete from T_DataBase ");
+            strSql.Append(" where F_ID=@F_ID");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_ID", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_ID;
+
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+        /// <summary>
+        /// 批量删除数据
+        /// </summary>
+        public bool DeleteList(string F_IDlist)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("delete from T_DataBase ");
+            strSql.Append(" where F_ID in (" + F_IDlist + ")  ");
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public Model.T_DataBase GetModel(int F_ID)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select  top 1 F_ID,F_Name,F_Tablename,F_Theserver,F_UserID,F_pwd from T_DataBase ");
+            strSql.Append(" where F_ID=@F_ID");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_ID", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_ID;
+
+            Model.T_DataBase model = new Model.T_DataBase();
+            DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
+            if (ds.Tables[0].Rows.Count > 0)
+            {
+                return DataRowToModel(ds.Tables[0].Rows[0]);
+            }
+            else
+            {
+                return null;
+            }
+        }
+
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public Model.T_DataBase DataRowToModel(DataRow row)
+        {
+            Model.T_DataBase model = new Model.T_DataBase();
+            if (row != null)
+            {
+                if (row["F_ID"] != null && row["F_ID"].ToString() != "")
+                {
+                    model.F_ID = int.Parse(row["F_ID"].ToString());
+                }
+                if (row["F_Name"] != null)
+                {
+                    model.F_Name = row["F_Name"].ToString();
+                }
+                if (row["F_Tablename"] != null)
+                {
+                    model.F_Tablename = row["F_Tablename"].ToString();
+                }
+                if (row["F_Theserver"] != null)
+                {
+                    model.F_Theserver = row["F_Theserver"].ToString();
+                }
+                if (row["F_UserID"] != null)
+                {
+                    model.F_UserID = row["F_UserID"].ToString();
+                }
+                if (row["F_pwd"] != null)
+                {
+                    model.F_pwd = row["F_pwd"].ToString();
+                }
+            }
+            return model;
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select F_ID,F_Name,F_Tablename,F_Theserver,F_UserID,F_pwd ");
+            strSql.Append(" FROM T_DataBase ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /// <summary>
+        /// 获得前几行数据
+        /// </summary>
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select ");
+            if (Top > 0)
+            {
+                strSql.Append(" top " + Top.ToString());
+            }
+            strSql.Append(" F_ID,F_Name,F_Tablename,F_Theserver,F_UserID,F_pwd ");
+            strSql.Append(" FROM T_DataBase ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            strSql.Append(" order by " + filedOrder);
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /// <summary>
+        /// 获取记录总数
+        /// </summary>
+        public int GetRecordCount(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select count(1) FROM T_DataBase ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            object obj = DbHelperSQL.GetSingle(strSql.ToString());
+            if (obj == null)
+            {
+                return 0;
+            }
+            else
+            {
+                return Convert.ToInt32(obj);
+            }
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("SELECT * FROM ( ");
+            strSql.Append(" SELECT ROW_NUMBER() OVER (");
+            if (!string.IsNullOrEmpty(orderby.Trim()))
+            {
+                strSql.Append("order by T." + orderby);
+            }
+            else
+            {
+                strSql.Append("order by T.F_ID desc");
+            }
+            strSql.Append(")AS Row, T.*  from T_DataBase T ");
+            if (!string.IsNullOrEmpty(strWhere.Trim()))
+            {
+                strSql.Append(" WHERE " + strWhere);
+            }
+            strSql.Append(" ) TT");
+            strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /*
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		public DataSet GetList(int PageSize,int PageIndex,string strWhere)
+		{
+			SqlParameter[] parameters = {
+					new SqlParameter("@tblName", SqlDbType.VarChar, 255),
+					new SqlParameter("@fldName", SqlDbType.VarChar, 255),
+					new SqlParameter("@PageSize", SqlDbType.Int),
+					new SqlParameter("@PageIndex", SqlDbType.Int),
+					new SqlParameter("@IsReCount", SqlDbType.Bit),
+					new SqlParameter("@OrderType", SqlDbType.Bit),
+					new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
+					};
+			parameters[0].Value = "T_DataBase";
+			parameters[1].Value = "F_ID";
+			parameters[2].Value = PageSize;
+			parameters[3].Value = PageIndex;
+			parameters[4].Value = 0;
+			parameters[5].Value = 0;
+			parameters[6].Value = strWhere;	
+			return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
+		}*/
+
+        #endregion  BasicMethod
+        #region  ExtensionMethod
+
+        #endregion  ExtensionMethod
+    }
+}
+

CallCenterApi/CallCenterApi.DB/DbHelperSQL.cs

@@ -571,6 +571,26 @@ namespace CallCenterApi.DB
             }
 
         }
+        public static DataSet Query(string SQLString,string connect)
+        {
+
+            using (SqlConnection connection = new SqlConnection(connect))
+            {
+                DataSet ds = new DataSet();
+                try
+                {
+                    connection.Open();
+                    SqlDataAdapter command = new SqlDataAdapter(SQLString, connection);
+                    command.Fill(ds, "ds");
+                }
+                catch (System.Data.SqlClient.SqlException ex)
+                {
+                    throw new Exception(ex.Message);
+                }
+                return ds;
+            }
+
+        }
         /// <summary>
         /// 执行查询语句，返回DataSet
         /// </summary>

CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/InfoController.cs

@@ -1,4 +1,5 @@
-using CallCenterApi.DB;
+using CallCenter.Utility;
+using CallCenterApi.DB;
 using CallCenterApi.Interface.Controllers.Base;
 using System;
 using System.Collections.Generic;
@@ -15,7 +16,83 @@ namespace CallCenterApi.Interface.Controllers
         private BLL.T_Call_CallRecords callBLL = new BLL.T_Call_CallRecords();
         private BLL.T_Sys_DictionaryValue dicValueBLL = new BLL.T_Sys_DictionaryValue();
         private BLL.T_Sys_Department departmentBLL = new BLL.T_Sys_Department();
-
+        private BLL.T_DataBase branchBLL = new BLL.T_DataBase();
+        /// <summary>
+        /// 获取网点列表
+        /// </summary>
+        /// <returns></returns>
+        [Authority]
+        public ActionResult GetBranchList()
+        {
+            DataTable dt = branchBLL.GetList(" F_IsDelete=0 ").Tables[0];
+            return Success("加载成功", dt);
+        }
+        #region 获取所有平台的工单列表
+        public ActionResult GetWorkOrderList(string strstarttime, string strendtime, int id=0)
+        {
+            List<Model.T_DataBase> list = new List<Model.T_DataBase>();
+           
+            if (id > 0)
+            {
+                var Branch = new BLL.T_DataBase().GetModel (id);
+                if (Branch !=null )
+                {
+                    list.Add(Branch);
+                }
+                else
+                {
+                    return Error("数据查询失败");
+                }
+            }
+            else
+            {
+                list = new BLL.T_DataBase().GetModelList("F_ID>0");
+                if (list.Count == 0)
+                {
+                    return Error("查询失败");
+                }
+            }
+            string sql = "  F_IsDelete=0 ";
+            if (!string .IsNullOrEmpty (strstarttime))
+            {
+                sql += " and datediff(day,F_CreateTime,'" + strstarttime + "')<=0 ";
+            }
+            else
+            {
+                sql += " and datediff(day,F_CreateTime,'" +DateTime .Now.ToString ("yyyy-MM-01") + "')<=0 ";
+            }
+            if (!string.IsNullOrEmpty(strendtime))
+            {
+                sql += " and datediff(day,F_CreateTime,'" + strendtime + "')>=0   ";
+            }
+            else
+            {
+                sql += " and datediff(day,F_CreateTime,'" + DateTime.Now.ToString("yyyy-MM-dd") + "')>=0   ";
+            }
+            
+            List<Model.T_Bus_WorkOrder> t_Bus_WorkOrders = new List<Model.T_Bus_WorkOrder>();
+            foreach (var it in list)
+            {
+             string connectionString = "Data Source="+ it .F_Theserver + ";User ID="+ it.F_UserID + ";pwd="+ it.F_pwd +";Initial Catalog=" +it .F_Tablename +";";
+            var modellist = new BLL.T_Bus_WorkOrder().GetModelList(sql, connectionString);
+                if (modellist!=null )
+                {
+                    foreach (var iv in modellist)
+                    {
+                        t_Bus_WorkOrders.Add(iv);
+                    }
+                }
+            }
+            var obj = new
+            {
+                state = "success",
+                message = "成功",
+                rows = t_Bus_WorkOrders,
+               
+            };
+            return Content(obj.ToJson());
+        }
+        #endregion
         #region no user
         #region  获取数据
         //来源渠道情况

CallCenterApi/CallCenterApi.Model/CallCenterApi.Model.csproj

@@ -61,6 +61,7 @@
     <Compile Include="T_Check_Base.cs" />
     <Compile Include="T_Check_List.cs" />
     <Compile Include="T_Cus_AddressBook.cs" />
+    <Compile Include="T_DataBase.cs" />
     <Compile Include="T_Email_EmailMessage_Map.cs" />
     <Compile Include="T_Material_Info.cs" />
     <Compile Include="T_Sina_Msg.cs" />

CallCenterApi/CallCenterApi.Model/T_DataBase.cs

@@ -0,0 +1,71 @@
+using System;
+namespace CallCenterApi.Model
+{
+    /// <summary>
+    /// T_DataBase:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class T_DataBase
+    {
+        public T_DataBase()
+        { }
+        #region Model
+        private int _f_id;
+        private string _f_name;
+        private string _f_tablename;
+        private string _f_theserver;
+        private string _f_userid;
+        private string _f_pwd;
+        /// <summary>
+        /// 
+        /// </summary>
+        public int F_ID
+        {
+            set { _f_id = value; }
+            get { return _f_id; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_Name
+        {
+            set { _f_name = value; }
+            get { return _f_name; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_Tablename
+        {
+            set { _f_tablename = value; }
+            get { return _f_tablename; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_Theserver
+        {
+            set { _f_theserver = value; }
+            get { return _f_theserver; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_UserID
+        {
+            set { _f_userid = value; }
+            get { return _f_userid; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_pwd
+        {
+            set { _f_pwd = value; }
+            get { return _f_pwd; }
+        }
+        #endregion Model
+
+    }
+}
+