zhaozhiqiang лет назад: 3
Родитель
Сommit
954ddd3e97

+ 177 - 0
RMYY_CallCenter_Api.Bll/T_Msg_Chat.cs

@@ -0,0 +1,177 @@
1
+using System;
2
+using System.Collections.Generic;
3
+using System.Data;
4
+using System.Linq;
5
+using System.Text;
6
+using System.Threading.Tasks;
7
+
8
+namespace RMYY_CallCenter_Api.Bll
9
+{
10
+   public  class T_Msg_Chat
11
+    {
12
+        private readonly Dal.T_Msg_Chat dal = new Dal.T_Msg_Chat();
13
+        public T_Msg_Chat()
14
+        { }
15
+        #region  BasicMethod
16
+
17
+        /// <summary>
18
+        /// 得到最大ID
19
+        /// </summary>
20
+        public int GetMaxId()
21
+        {
22
+            return dal.GetMaxId();
23
+        }
24
+
25
+        /// <summary>
26
+        /// 是否存在该记录
27
+        /// </summary>
28
+        public bool Exists(int Id)
29
+        {
30
+            return dal.Exists(Id);
31
+        }
32
+
33
+        /// <summary>
34
+        /// 增加一条数据
35
+        /// </summary>
36
+        public int Add(Model.T_Msg_Chat model)
37
+        {
38
+            return dal.Add(model);
39
+        }
40
+
41
+        /// <summary>
42
+        /// 更新一条数据
43
+        /// </summary>
44
+        public bool Update(Model.T_Msg_Chat model)
45
+        {
46
+            return dal.Update(model);
47
+        }
48
+
49
+        /// <summary>
50
+        /// 删除一条数据
51
+        /// </summary>
52
+        public bool Delete(int Id)
53
+        {
54
+
55
+            return dal.Delete(Id);
56
+        }
57
+        /// <summary>
58
+        /// 删除一条数据
59
+        /// </summary>
60
+        public bool DeleteList(string Idlist)
61
+        {
62
+            return dal.DeleteList(Idlist);
63
+        }
64
+
65
+        /// <summary>
66
+        /// 得到一个对象实体
67
+        /// </summary>
68
+        public Model.T_Msg_Chat GetModel(int Id)
69
+        {
70
+
71
+            return dal.GetModel(Id);
72
+        }
73
+
74
+        ///// <summary>
75
+        ///// 得到一个对象实体,从缓存中
76
+        ///// </summary>
77
+        //public Model.T_Msg_Chat GetModelByCache(int Id)
78
+        //{
79
+
80
+        //    string CacheKey = "T_Msg_ChatModel-" + Id;
81
+        //    object objModel = Common.DataCache.GetCache(CacheKey);
82
+        //    if (objModel == null)
83
+        //    {
84
+        //        try
85
+        //        {
86
+        //            objModel = dal.GetModel(Id);
87
+        //            if (objModel != null)
88
+        //            {
89
+        //                int ModelCache = Common.ConfigHelper.GetConfigInt("ModelCache");
90
+        //                Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero);
91
+        //            }
92
+        //        }
93
+        //        catch { }
94
+        //    }
95
+        //    return (Model.T_Msg_Chat)objModel;
96
+        //}
97
+
98
+        /// <summary>
99
+        /// 获得数据列表
100
+        /// </summary>
101
+        public DataSet GetList(string strWhere)
102
+        {
103
+            return dal.GetList(strWhere);
104
+        }
105
+        /// <summary>
106
+        /// 获得前几行数据
107
+        /// </summary>
108
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
109
+        {
110
+            return dal.GetList(Top, strWhere, filedOrder);
111
+        }
112
+        /// <summary>
113
+        /// 获得数据列表
114
+        /// </summary>
115
+        public List<Model.T_Msg_Chat> GetModelList(string strWhere)
116
+        {
117
+            DataSet ds = dal.GetList(strWhere);
118
+            return DataTableToList(ds.Tables[0]);
119
+        }
120
+        /// <summary>
121
+        /// 获得数据列表
122
+        /// </summary>
123
+        public List<Model.T_Msg_Chat> DataTableToList(DataTable dt)
124
+        {
125
+            List<Model.T_Msg_Chat> modelList = new List<Model.T_Msg_Chat>();
126
+            int rowsCount = dt.Rows.Count;
127
+            if (rowsCount > 0)
128
+            {
129
+                Model.T_Msg_Chat model;
130
+                for (int n = 0; n < rowsCount; n++)
131
+                {
132
+                    model = dal.DataRowToModel(dt.Rows[n]);
133
+                    if (model != null)
134
+                    {
135
+                        modelList.Add(model);
136
+                    }
137
+                }
138
+            }
139
+            return modelList;
140
+        }
141
+
142
+        /// <summary>
143
+        /// 获得数据列表
144
+        /// </summary>
145
+        public DataSet GetAllList()
146
+        {
147
+            return GetList("");
148
+        }
149
+
150
+        /// <summary>
151
+        /// 分页获取数据列表
152
+        /// </summary>
153
+        public int GetRecordCount(string strWhere)
154
+        {
155
+            return dal.GetRecordCount(strWhere);
156
+        }
157
+        /// <summary>
158
+        /// 分页获取数据列表
159
+        /// </summary>
160
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
161
+        {
162
+            return dal.GetListByPage(strWhere, orderby, startIndex, endIndex);
163
+        }
164
+        /// <summary>
165
+        /// 分页获取数据列表
166
+        /// </summary>
167
+        //public DataSet GetList(int PageSize,int PageIndex,string strWhere)
168
+        //{
169
+        //return dal.GetList(PageSize,PageIndex,strWhere);
170
+        //}
171
+
172
+        #endregion  BasicMethod
173
+        #region  ExtensionMethod
174
+
175
+        #endregion  ExtensionMethod
176
+    }
177
+}

+ 144 - 0
RMYY_CallCenter_Api.Bll/T_Msg_Chat_Map.cs

@@ -0,0 +1,144 @@
1
+using System;
2
+using System.Collections.Generic;
3
+using System.Data;
4
+using System.Linq;
5
+using System.Text;
6
+using System.Threading.Tasks;
7
+
8
+namespace RMYY_CallCenter_Api.Bll
9
+{
10
+   public  class T_Msg_Chat_Map
11
+    {
12
+        private readonly RMYY_CallCenter_Api.Dal.T_Msg_Chat_Map dal = new RMYY_CallCenter_Api.Dal.T_Msg_Chat_Map();
13
+        public T_Msg_Chat_Map()
14
+        { }
15
+        #region  BasicMethod
16
+        /// <summary>
17
+        /// 是否存在该记录
18
+        /// </summary>
19
+        public bool Exists(int Id)
20
+        {
21
+            return dal.Exists(Id);
22
+        }
23
+
24
+        /// <summary>
25
+        /// 增加一条数据
26
+        /// </summary>
27
+        public int Add(RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model)
28
+        {
29
+            return dal.Add(model);
30
+        }
31
+
32
+        /// <summary>
33
+        /// 更新一条数据
34
+        /// </summary>
35
+        public bool Update(RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model)
36
+        {
37
+            return dal.Update(model);
38
+        }
39
+
40
+        /// <summary>
41
+        /// 删除一条数据
42
+        /// </summary>
43
+        public bool Delete(int Id)
44
+        {
45
+
46
+            return dal.Delete(Id);
47
+        }
48
+        /// <summary>
49
+        /// 删除一条数据
50
+        /// </summary>
51
+        public bool DeleteList(string Idlist)
52
+        {
53
+            return dal.DeleteList(Idlist);
54
+        }
55
+
56
+        /// <summary>
57
+        /// 得到一个对象实体
58
+        /// </summary>
59
+        public RMYY_CallCenter_Api.Model.T_Msg_Chat_Map GetModel(int Id)
60
+        {
61
+
62
+            return dal.GetModel(Id);
63
+        }
64
+
65
+        /// <summary>
66
+        /// 获得数据列表
67
+        /// </summary>
68
+        public DataSet GetList(string strWhere)
69
+        {
70
+            return dal.GetList(strWhere);
71
+        }
72
+        /// <summary>
73
+        /// 获得前几行数据
74
+        /// </summary>
75
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
76
+        {
77
+            return dal.GetList(Top, strWhere, filedOrder);
78
+        }
79
+        /// <summary>
80
+        /// 获得数据列表
81
+        /// </summary>
82
+        public List<RMYY_CallCenter_Api.Model.T_Msg_Chat_Map> GetModelList(string strWhere)
83
+        {
84
+            DataSet ds = dal.GetList(strWhere);
85
+            return DataTableToList(ds.Tables[0]);
86
+        }
87
+        /// <summary>
88
+        /// 获得数据列表
89
+        /// </summary>
90
+        public List<RMYY_CallCenter_Api.Model.T_Msg_Chat_Map> DataTableToList(DataTable dt)
91
+        {
92
+            List<RMYY_CallCenter_Api.Model.T_Msg_Chat_Map> modelList = new List<RMYY_CallCenter_Api.Model.T_Msg_Chat_Map>();
93
+            int rowsCount = dt.Rows.Count;
94
+            if (rowsCount > 0)
95
+            {
96
+                RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model;
97
+                for (int n = 0; n < rowsCount; n++)
98
+                {
99
+                    model = dal.DataRowToModel(dt.Rows[n]);
100
+                    if (model != null)
101
+                    {
102
+                        modelList.Add(model);
103
+                    }
104
+                }
105
+            }
106
+            return modelList;
107
+        }
108
+
109
+        /// <summary>
110
+        /// 获得数据列表
111
+        /// </summary>
112
+        public DataSet GetAllList()
113
+        {
114
+            return GetList("");
115
+        }
116
+
117
+        /// <summary>
118
+        /// 分页获取数据列表
119
+        /// </summary>
120
+        public int GetRecordCount(string strWhere)
121
+        {
122
+            return dal.GetRecordCount(strWhere);
123
+        }
124
+        /// <summary>
125
+        /// 分页获取数据列表
126
+        /// </summary>
127
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
128
+        {
129
+            return dal.GetListByPage(strWhere, orderby, startIndex, endIndex);
130
+        }
131
+        /// <summary>
132
+        /// 分页获取数据列表
133
+        /// </summary>
134
+        //public DataSet GetList(int PageSize,int PageIndex,string strWhere)
135
+        //{
136
+        //return dal.GetList(PageSize,PageIndex,strWhere);
137
+        //}
138
+
139
+        #endregion  BasicMethod
140
+        #region  ExtensionMethod
141
+
142
+        #endregion  ExtensionMethod
143
+    }
144
+}

+ 129 - 0
RMYY_CallCenter_Api.Bll/T_Msg_NoticeInfo.cs

@@ -0,0 +1,129 @@
1
+using System;
2
+using System.Collections.Generic;
3
+using System.Data;
4
+using System.Linq;
5
+using System.Text;
6
+using System.Threading.Tasks;
7
+
8
+namespace RMYY_CallCenter_Api.Bll
9
+{
10
+   public  class T_Msg_NoticeInfo
11
+    {
12
+        private readonly RMYY_CallCenter_Api.Dal.T_Msg_NoticeInfo dal = new RMYY_CallCenter_Api.Dal.T_Msg_NoticeInfo();
13
+        public T_Msg_NoticeInfo()
14
+        { }
15
+        #region  BasicMethod
16
+        /// <summary>
17
+        /// 增加一条数据
18
+        /// </summary>
19
+        public int Add(RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model)
20
+        {
21
+            return dal.Add(model);
22
+        }
23
+
24
+        /// <summary>
25
+        /// 更新一条数据
26
+        /// </summary>
27
+        public bool Update(RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model)
28
+        {
29
+            return dal.Update(model);
30
+        }
31
+
32
+        /// <summary>
33
+        /// 删除一条数据
34
+        /// </summary>
35
+        public bool Delete(int F_NoticeId)
36
+        {
37
+
38
+            return dal.Delete(F_NoticeId);
39
+        }
40
+        /// <summary>
41
+        /// 删除一条数据
42
+        /// </summary>
43
+        public bool DeleteList(string F_NoticeIdlist)
44
+        {
45
+            return dal.DeleteList(F_NoticeIdlist);
46
+        }
47
+
48
+        /// <summary>
49
+        /// 得到一个对象实体
50
+        /// </summary>
51
+        public RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo GetModel(int F_NoticeId)
52
+        {
53
+
54
+            return dal.GetModel(F_NoticeId);
55
+        }
56
+
57
+        /// <summary>
58
+        /// 获得数据列表
59
+        /// </summary>
60
+        public DataSet GetList(string strWhere)
61
+        {
62
+            return dal.GetList(strWhere);
63
+        }
64
+        /// <summary>
65
+        /// 获得前几行数据
66
+        /// </summary>
67
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
68
+        {
69
+            return dal.GetList(Top, strWhere, filedOrder);
70
+        }
71
+        /// <summary>
72
+        /// 获得数据列表
73
+        /// </summary>
74
+        public List<RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo> GetModelList(string strWhere)
75
+        {
76
+            DataSet ds = dal.GetList(strWhere);
77
+            return DataTableToList(ds.Tables[0]);
78
+        }
79
+        /// <summary>
80
+        /// 获得数据列表
81
+        /// </summary>
82
+        public List<RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo> DataTableToList(DataTable dt)
83
+        {
84
+            List<RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo> modelList = new List<RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo>();
85
+            int rowsCount = dt.Rows.Count;
86
+            if (rowsCount > 0)
87
+            {
88
+                RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model;
89
+                for (int n = 0; n < rowsCount; n++)
90
+                {
91
+                    model = dal.DataRowToModel(dt.Rows[n]);
92
+                    if (model != null)
93
+                    {
94
+                        modelList.Add(model);
95
+                    }
96
+                }
97
+            }
98
+            return modelList;
99
+        }
100
+
101
+        /// <summary>
102
+        /// 获得数据列表
103
+        /// </summary>
104
+        public DataSet GetAllList()
105
+        {
106
+            return GetList("");
107
+        }
108
+
109
+        /// <summary>
110
+        /// 分页获取数据列表
111
+        /// </summary>
112
+        public int GetRecordCount(string strWhere)
113
+        {
114
+            return dal.GetRecordCount(strWhere);
115
+        }
116
+        /// <summary>
117
+        /// 分页获取数据列表
118
+        /// </summary>
119
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
120
+        {
121
+            return dal.GetListByPage(strWhere, orderby, startIndex, endIndex);
122
+        }
123
+
124
+        #endregion  BasicMethod
125
+        #region  ExtensionMethod
126
+
127
+        #endregion  ExtensionMethod
128
+    }
129
+}

+ 361 - 0
RMYY_CallCenter_Api.Dal/T_Msg_Chat.cs

@@ -0,0 +1,361 @@
1
+using RMYY_CallCenter_Api.DB;
2
+using System;
3
+using System.Collections.Generic;
4
+using System.Data;
5
+using System.Data.SqlClient;
6
+using System.Linq;
7
+using System.Text;
8
+using System.Threading.Tasks;
9
+
10
+namespace RMYY_CallCenter_Api.Dal
11
+{
12
+   public  class T_Msg_Chat
13
+    {
14
+        public T_Msg_Chat()
15
+        { }
16
+        #region  BasicMethod
17
+
18
+        /// <summary>
19
+        /// 得到最大ID
20
+        /// </summary>
21
+        public int GetMaxId()
22
+        {
23
+            return DbHelperSQL.GetMaxID("Id", "T_Msg_Chat");
24
+        }
25
+
26
+        /// <summary>
27
+        /// 是否存在该记录
28
+        /// </summary>
29
+        public bool Exists(int Id)
30
+        {
31
+            StringBuilder strSql = new StringBuilder();
32
+            strSql.Append("select count(1) from T_Msg_Chat");
33
+            strSql.Append(" where Id=@Id");
34
+            SqlParameter[] parameters = {
35
+                    new SqlParameter("@Id", SqlDbType.Int,4)
36
+            };
37
+            parameters[0].Value = Id;
38
+
39
+            return DbHelperSQL.Exists(strSql.ToString(), parameters);
40
+        }
41
+
42
+
43
+        /// <summary>
44
+        /// 增加一条数据
45
+        /// </summary>
46
+        public int Add(Model.T_Msg_Chat model)
47
+        {
48
+            StringBuilder strSql = new StringBuilder();
49
+            strSql.Append("insert into T_Msg_Chat(");
50
+            strSql.Append("Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete)");
51
+            strSql.Append(" values (");
52
+            strSql.Append("@Content,@VoiceUrl,@CreateDate,@FromUserId,@ToUserId,@ToRoleId,@IsToAll,@IsDelete)");
53
+            strSql.Append(";select @@IDENTITY");
54
+            SqlParameter[] parameters = {
55
+                    new SqlParameter("@Content", SqlDbType.NText),
56
+                    new SqlParameter("@VoiceUrl", SqlDbType.NVarChar,200),
57
+                    new SqlParameter("@CreateDate", SqlDbType.DateTime),
58
+                    new SqlParameter("@FromUserId", SqlDbType.Int,4),
59
+                    new SqlParameter("@ToUserId", SqlDbType.Int,4),
60
+                    new SqlParameter("@ToRoleId", SqlDbType.Int,4),
61
+                    new SqlParameter("@IsToAll", SqlDbType.Int,4),
62
+                    new SqlParameter("@IsDelete", SqlDbType.Int,4)};
63
+            parameters[0].Value = model.Content;
64
+            parameters[1].Value = model.VoiceUrl;
65
+            parameters[2].Value = model.CreateDate;
66
+            parameters[3].Value = model.FromUserId;
67
+            parameters[4].Value = model.ToUserId;
68
+            parameters[5].Value = model.ToRoleId;
69
+            parameters[6].Value = model.IsToAll;
70
+            parameters[7].Value = model.IsDelete;
71
+
72
+            object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
73
+            if (obj == null)
74
+            {
75
+                return 0;
76
+            }
77
+            else
78
+            {
79
+                return Convert.ToInt32(obj);
80
+            }
81
+        }
82
+        /// <summary>
83
+        /// 更新一条数据
84
+        /// </summary>
85
+        public bool Update(Model.T_Msg_Chat model)
86
+        {
87
+            StringBuilder strSql = new StringBuilder();
88
+            strSql.Append("update T_Msg_Chat set ");
89
+            strSql.Append("Content=@Content,");
90
+            strSql.Append("VoiceUrl=@VoiceUrl,");
91
+            strSql.Append("CreateDate=@CreateDate,");
92
+            strSql.Append("FromUserId=@FromUserId,");
93
+            strSql.Append("ToUserId=@ToUserId,");
94
+            strSql.Append("ToRoleId=@ToRoleId,");
95
+            strSql.Append("IsToAll=@IsToAll,");
96
+            strSql.Append("IsDelete=@IsDelete");
97
+            strSql.Append(" where Id=@Id");
98
+            SqlParameter[] parameters = {
99
+                    new SqlParameter("@Content", SqlDbType.NText),
100
+                    new SqlParameter("@VoiceUrl", SqlDbType.NVarChar,200),
101
+                    new SqlParameter("@CreateDate", SqlDbType.DateTime),
102
+                    new SqlParameter("@FromUserId", SqlDbType.Int,4),
103
+                    new SqlParameter("@ToUserId", SqlDbType.Int,4),
104
+                    new SqlParameter("@ToRoleId", SqlDbType.Int,4),
105
+                    new SqlParameter("@IsToAll", SqlDbType.Int,4),
106
+                    new SqlParameter("@IsDelete", SqlDbType.Int,4),
107
+                    new SqlParameter("@Id", SqlDbType.Int,4)};
108
+            parameters[0].Value = model.Content;
109
+            parameters[1].Value = model.VoiceUrl;
110
+            parameters[2].Value = model.CreateDate;
111
+            parameters[3].Value = model.FromUserId;
112
+            parameters[4].Value = model.ToUserId;
113
+            parameters[5].Value = model.ToRoleId;
114
+            parameters[6].Value = model.IsToAll;
115
+            parameters[7].Value = model.IsDelete;
116
+            parameters[8].Value = model.Id;
117
+
118
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
119
+            if (rows > 0)
120
+            {
121
+                return true;
122
+            }
123
+            else
124
+            {
125
+                return false;
126
+            }
127
+        }
128
+
129
+        /// <summary>
130
+        /// 删除一条数据
131
+        /// </summary>
132
+        public bool Delete(int Id)
133
+        {
134
+
135
+            StringBuilder strSql = new StringBuilder();
136
+            strSql.Append("delete from T_Msg_Chat ");
137
+            strSql.Append(" where Id=@Id");
138
+            SqlParameter[] parameters = {
139
+                    new SqlParameter("@Id", SqlDbType.Int,4)
140
+            };
141
+            parameters[0].Value = Id;
142
+
143
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
144
+            if (rows > 0)
145
+            {
146
+                return true;
147
+            }
148
+            else
149
+            {
150
+                return false;
151
+            }
152
+        }
153
+        /// <summary>
154
+        /// 批量删除数据
155
+        /// </summary>
156
+        public bool DeleteList(string Idlist)
157
+        {
158
+            StringBuilder strSql = new StringBuilder();
159
+            strSql.Append("delete from T_Msg_Chat ");
160
+            strSql.Append(" where Id in (" + Idlist + ")  ");
161
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
162
+            if (rows > 0)
163
+            {
164
+                return true;
165
+            }
166
+            else
167
+            {
168
+                return false;
169
+            }
170
+        }
171
+
172
+
173
+        /// <summary>
174
+        /// 得到一个对象实体
175
+        /// </summary>
176
+        public Model.T_Msg_Chat GetModel(int Id)
177
+        {
178
+
179
+            StringBuilder strSql = new StringBuilder();
180
+            strSql.Append("select  top 1 Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete from T_Msg_Chat ");
181
+            strSql.Append(" where Id=@Id");
182
+            SqlParameter[] parameters = {
183
+                    new SqlParameter("@Id", SqlDbType.Int,4)
184
+            };
185
+            parameters[0].Value = Id;
186
+
187
+            Model.T_Msg_Chat model = new Model.T_Msg_Chat();
188
+            DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
189
+            if (ds.Tables[0].Rows.Count > 0)
190
+            {
191
+                return DataRowToModel(ds.Tables[0].Rows[0]);
192
+            }
193
+            else
194
+            {
195
+                return null;
196
+            }
197
+        }
198
+
199
+
200
+        /// <summary>
201
+        /// 得到一个对象实体
202
+        /// </summary>
203
+        public Model.T_Msg_Chat DataRowToModel(DataRow row)
204
+        {
205
+            Model.T_Msg_Chat model = new Model.T_Msg_Chat();
206
+            if (row != null)
207
+            {
208
+                if (row["Id"] != null && row["Id"].ToString() != "")
209
+                {
210
+                    model.Id = int.Parse(row["Id"].ToString());
211
+                }
212
+                if (row["Content"] != null)
213
+                {
214
+                    model.Content = row["Content"].ToString();
215
+                }
216
+                if (row["VoiceUrl"] != null)
217
+                {
218
+                    model.VoiceUrl = row["VoiceUrl"].ToString();
219
+                }
220
+                if (row["CreateDate"] != null && row["CreateDate"].ToString() != "")
221
+                {
222
+                    model.CreateDate = DateTime.Parse(row["CreateDate"].ToString());
223
+                }
224
+                if (row["FromUserId"] != null && row["FromUserId"].ToString() != "")
225
+                {
226
+                    model.FromUserId = int.Parse(row["FromUserId"].ToString());
227
+                }
228
+                if (row["ToUserId"] != null && row["ToUserId"].ToString() != "")
229
+                {
230
+                    model.ToUserId = int.Parse(row["ToUserId"].ToString());
231
+                }
232
+                if (row["ToRoleId"] != null && row["ToRoleId"].ToString() != "")
233
+                {
234
+                    model.ToRoleId = int.Parse(row["ToRoleId"].ToString());
235
+                }
236
+                if (row["IsToAll"] != null && row["IsToAll"].ToString() != "")
237
+                {
238
+                    model.IsToAll = int.Parse(row["IsToAll"].ToString());
239
+                }
240
+                if (row["IsDelete"] != null && row["IsDelete"].ToString() != "")
241
+                {
242
+                    model.IsDelete = int.Parse(row["IsDelete"].ToString());
243
+                }
244
+            }
245
+            return model;
246
+        }
247
+
248
+        /// <summary>
249
+        /// 获得数据列表
250
+        /// </summary>
251
+        public DataSet GetList(string strWhere)
252
+        {
253
+            StringBuilder strSql = new StringBuilder();
254
+            strSql.Append("select Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete ");
255
+            strSql.Append(" FROM T_Msg_Chat ");
256
+            if (strWhere.Trim() != "")
257
+            {
258
+                strSql.Append(" where " + strWhere);
259
+            }
260
+            return DbHelperSQL.Query(strSql.ToString());
261
+        }
262
+
263
+        /// <summary>
264
+        /// 获得前几行数据
265
+        /// </summary>
266
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
267
+        {
268
+            StringBuilder strSql = new StringBuilder();
269
+            strSql.Append("select ");
270
+            if (Top > 0)
271
+            {
272
+                strSql.Append(" top " + Top.ToString());
273
+            }
274
+            strSql.Append(" Id,Content,VoiceUrl,CreateDate,FromUserId,ToUserId,ToRoleId,IsToAll,IsDelete ");
275
+            strSql.Append(" FROM T_Msg_Chat ");
276
+            if (strWhere.Trim() != "")
277
+            {
278
+                strSql.Append(" where " + strWhere);
279
+            }
280
+            strSql.Append(" order by " + filedOrder);
281
+            return DbHelperSQL.Query(strSql.ToString());
282
+        }
283
+
284
+        /// <summary>
285
+        /// 获取记录总数
286
+        /// </summary>
287
+        public int GetRecordCount(string strWhere)
288
+        {
289
+            StringBuilder strSql = new StringBuilder();
290
+            strSql.Append("select count(1) FROM T_Msg_Chat ");
291
+            if (strWhere.Trim() != "")
292
+            {
293
+                strSql.Append(" where " + strWhere);
294
+            }
295
+            object obj = DbHelperSQL.GetSingle(strSql.ToString());
296
+            if (obj == null)
297
+            {
298
+                return 0;
299
+            }
300
+            else
301
+            {
302
+                return Convert.ToInt32(obj);
303
+            }
304
+        }
305
+        /// <summary>
306
+        /// 分页获取数据列表
307
+        /// </summary>
308
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
309
+        {
310
+            StringBuilder strSql = new StringBuilder();
311
+            strSql.Append("SELECT * FROM ( ");
312
+            strSql.Append(" SELECT ROW_NUMBER() OVER (");
313
+            if (!string.IsNullOrEmpty(orderby.Trim()))
314
+            {
315
+                strSql.Append("order by T." + orderby);
316
+            }
317
+            else
318
+            {
319
+                strSql.Append("order by T.Id desc");
320
+            }
321
+            strSql.Append(")AS Row, T.*  from T_Msg_Chat T ");
322
+            if (!string.IsNullOrEmpty(strWhere.Trim()))
323
+            {
324
+                strSql.Append(" WHERE " + strWhere);
325
+            }
326
+            strSql.Append(" ) TT");
327
+            strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
328
+            return DbHelperSQL.Query(strSql.ToString());
329
+        }
330
+
331
+        /*
332
+		/// <summary>
333
+		/// 分页获取数据列表
334
+		/// </summary>
335
+		public DataSet GetList(int PageSize,int PageIndex,string strWhere)
336
+		{
337
+			SqlParameter[] parameters = {
338
+					new SqlParameter("@tblName", SqlDbType.VarChar, 255),
339
+					new SqlParameter("@fldName", SqlDbType.VarChar, 255),
340
+					new SqlParameter("@PageSize", SqlDbType.Int),
341
+					new SqlParameter("@PageIndex", SqlDbType.Int),
342
+					new SqlParameter("@IsReCount", SqlDbType.Bit),
343
+					new SqlParameter("@OrderType", SqlDbType.Bit),
344
+					new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
345
+					};
346
+			parameters[0].Value = "T_Msg_Chat";
347
+			parameters[1].Value = "Id";
348
+			parameters[2].Value = PageSize;
349
+			parameters[3].Value = PageIndex;
350
+			parameters[4].Value = 0;
351
+			parameters[5].Value = 0;
352
+			parameters[6].Value = strWhere;	
353
+			return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
354
+		}*/
355
+
356
+        #endregion  BasicMethod
357
+        #region  ExtensionMethod
358
+
359
+        #endregion  ExtensionMethod
360
+    }
361
+}

+ 325 - 0
RMYY_CallCenter_Api.Dal/T_Msg_Chat_Map.cs

@@ -0,0 +1,325 @@
1
+using RMYY_CallCenter_Api.DB;
2
+using System;
3
+using System.Collections.Generic;
4
+using System.Data;
5
+using System.Data.SqlClient;
6
+using System.Linq;
7
+using System.Text;
8
+using System.Threading.Tasks;
9
+
10
+namespace RMYY_CallCenter_Api.Dal
11
+{
12
+   public  class T_Msg_Chat_Map
13
+    {
14
+        public T_Msg_Chat_Map()
15
+        { }
16
+        #region  BasicMethod
17
+        /// <summary>
18
+        /// 是否存在该记录
19
+        /// </summary>
20
+        public bool Exists(int Id)
21
+        {
22
+            StringBuilder strSql = new StringBuilder();
23
+            strSql.Append("select count(1) from T_Msg_Chat_Map");
24
+            strSql.Append(" where Id=@Id");
25
+            SqlParameter[] parameters = {
26
+                    new SqlParameter("@Id", SqlDbType.Int,4)
27
+            };
28
+            parameters[0].Value = Id;
29
+
30
+            return DbHelperSQL.Exists(strSql.ToString(), parameters);
31
+        }
32
+
33
+
34
+        /// <summary>
35
+        /// 增加一条数据
36
+        /// </summary>
37
+        public int Add(RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model)
38
+        {
39
+            StringBuilder strSql = new StringBuilder();
40
+            strSql.Append("insert into T_Msg_Chat_Map(");
41
+            strSql.Append("ChatId,FromUserId,ToUserId,CreateDate,IsRead)");
42
+            strSql.Append(" values (");
43
+            strSql.Append("@ChatId,@FromUserId,@ToUserId,@CreateDate,@IsRead)");
44
+            strSql.Append(";select @@IDENTITY");
45
+            SqlParameter[] parameters = {
46
+                    new SqlParameter("@ChatId", SqlDbType.Int,4),
47
+                    new SqlParameter("@FromUserId", SqlDbType.Int,4),
48
+                    new SqlParameter("@ToUserId", SqlDbType.Int,4),
49
+                    new SqlParameter("@CreateDate", SqlDbType.DateTime),
50
+                    new SqlParameter("@IsRead", SqlDbType.Int,4)};
51
+            parameters[0].Value = model.ChatId;
52
+            parameters[1].Value = model.FromUserId;
53
+            parameters[2].Value = model.ToUserId;
54
+            parameters[3].Value = model.CreateDate;
55
+            parameters[4].Value = model.IsRead;
56
+
57
+            object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
58
+            if (obj == null)
59
+            {
60
+                return 0;
61
+            }
62
+            else
63
+            {
64
+                return Convert.ToInt32(obj);
65
+            }
66
+        }
67
+        /// <summary>
68
+        /// 更新一条数据
69
+        /// </summary>
70
+        public bool Update(RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model)
71
+        {
72
+            StringBuilder strSql = new StringBuilder();
73
+            strSql.Append("update T_Msg_Chat_Map set ");
74
+            strSql.Append("ChatId=@ChatId,");
75
+            strSql.Append("FromUserId=@FromUserId,");
76
+            strSql.Append("ToUserId=@ToUserId,");
77
+            strSql.Append("CreateDate=@CreateDate,");
78
+            strSql.Append("IsRead=@IsRead");
79
+            strSql.Append(" where Id=@Id");
80
+            SqlParameter[] parameters = {
81
+                    new SqlParameter("@ChatId", SqlDbType.Int,4),
82
+                    new SqlParameter("@FromUserId", SqlDbType.Int,4),
83
+                    new SqlParameter("@ToUserId", SqlDbType.Int,4),
84
+                    new SqlParameter("@CreateDate", SqlDbType.DateTime),
85
+                    new SqlParameter("@IsRead", SqlDbType.Int,4),
86
+                    new SqlParameter("@Id", SqlDbType.Int,4)};
87
+            parameters[0].Value = model.ChatId;
88
+            parameters[1].Value = model.FromUserId;
89
+            parameters[2].Value = model.ToUserId;
90
+            parameters[3].Value = model.CreateDate;
91
+            parameters[4].Value = model.IsRead;
92
+            parameters[5].Value = model.Id;
93
+
94
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
95
+            if (rows > 0)
96
+            {
97
+                return true;
98
+            }
99
+            else
100
+            {
101
+                return false;
102
+            }
103
+        }
104
+
105
+        /// <summary>
106
+        /// 删除一条数据
107
+        /// </summary>
108
+        public bool Delete(int Id)
109
+        {
110
+
111
+            StringBuilder strSql = new StringBuilder();
112
+            strSql.Append("delete from T_Msg_Chat_Map ");
113
+            strSql.Append(" where Id=@Id");
114
+            SqlParameter[] parameters = {
115
+                    new SqlParameter("@Id", SqlDbType.Int,4)
116
+            };
117
+            parameters[0].Value = Id;
118
+
119
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
120
+            if (rows > 0)
121
+            {
122
+                return true;
123
+            }
124
+            else
125
+            {
126
+                return false;
127
+            }
128
+        }
129
+        /// <summary>
130
+        /// 批量删除数据
131
+        /// </summary>
132
+        public bool DeleteList(string Idlist)
133
+        {
134
+            StringBuilder strSql = new StringBuilder();
135
+            strSql.Append("delete from T_Msg_Chat_Map ");
136
+            strSql.Append(" where Id in (" + Idlist + ")  ");
137
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
138
+            if (rows > 0)
139
+            {
140
+                return true;
141
+            }
142
+            else
143
+            {
144
+                return false;
145
+            }
146
+        }
147
+
148
+
149
+        /// <summary>
150
+        /// 得到一个对象实体
151
+        /// </summary>
152
+        public RMYY_CallCenter_Api.Model.T_Msg_Chat_Map GetModel(int Id)
153
+        {
154
+
155
+            StringBuilder strSql = new StringBuilder();
156
+            strSql.Append("select  top 1 ChatId,FromUserId,ToUserId,CreateDate,IsRead,Id from T_Msg_Chat_Map ");
157
+            strSql.Append(" where Id=@Id");
158
+            SqlParameter[] parameters = {
159
+                    new SqlParameter("@Id", SqlDbType.Int,4)
160
+            };
161
+            parameters[0].Value = Id;
162
+
163
+            RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model = new RMYY_CallCenter_Api.Model.T_Msg_Chat_Map();
164
+            DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
165
+            if (ds.Tables[0].Rows.Count > 0)
166
+            {
167
+                return DataRowToModel(ds.Tables[0].Rows[0]);
168
+            }
169
+            else
170
+            {
171
+                return null;
172
+            }
173
+        }
174
+
175
+
176
+        /// <summary>
177
+        /// 得到一个对象实体
178
+        /// </summary>
179
+        public RMYY_CallCenter_Api.Model.T_Msg_Chat_Map DataRowToModel(DataRow row)
180
+        {
181
+            RMYY_CallCenter_Api.Model.T_Msg_Chat_Map model = new RMYY_CallCenter_Api.Model.T_Msg_Chat_Map();
182
+            if (row != null)
183
+            {
184
+                if (row["ChatId"] != null && row["ChatId"].ToString() != "")
185
+                {
186
+                    model.ChatId = int.Parse(row["ChatId"].ToString());
187
+                }
188
+                if (row["FromUserId"] != null && row["FromUserId"].ToString() != "")
189
+                {
190
+                    model.FromUserId = int.Parse(row["FromUserId"].ToString());
191
+                }
192
+                if (row["ToUserId"] != null && row["ToUserId"].ToString() != "")
193
+                {
194
+                    model.ToUserId = int.Parse(row["ToUserId"].ToString());
195
+                }
196
+                if (row["CreateDate"] != null && row["CreateDate"].ToString() != "")
197
+                {
198
+                    model.CreateDate = DateTime.Parse(row["CreateDate"].ToString());
199
+                }
200
+                if (row["IsRead"] != null && row["IsRead"].ToString() != "")
201
+                {
202
+                    model.IsRead = int.Parse(row["IsRead"].ToString());
203
+                }
204
+                if (row["Id"] != null && row["Id"].ToString() != "")
205
+                {
206
+                    model.Id = int.Parse(row["Id"].ToString());
207
+                }
208
+            }
209
+            return model;
210
+        }
211
+
212
+        /// <summary>
213
+        /// 获得数据列表
214
+        /// </summary>
215
+        public DataSet GetList(string strWhere)
216
+        {
217
+            StringBuilder strSql = new StringBuilder();
218
+            strSql.Append("select ChatId,FromUserId,ToUserId,CreateDate,IsRead,Id ");
219
+            strSql.Append(" FROM T_Msg_Chat_Map ");
220
+            if (strWhere.Trim() != "")
221
+            {
222
+                strSql.Append(" where " + strWhere);
223
+            }
224
+            return DbHelperSQL.Query(strSql.ToString());
225
+        }
226
+
227
+        /// <summary>
228
+        /// 获得前几行数据
229
+        /// </summary>
230
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
231
+        {
232
+            StringBuilder strSql = new StringBuilder();
233
+            strSql.Append("select ");
234
+            if (Top > 0)
235
+            {
236
+                strSql.Append(" top " + Top.ToString());
237
+            }
238
+            strSql.Append(" ChatId,FromUserId,ToUserId,CreateDate,IsRead,Id ");
239
+            strSql.Append(" FROM T_Msg_Chat_Map ");
240
+            if (strWhere.Trim() != "")
241
+            {
242
+                strSql.Append(" where " + strWhere);
243
+            }
244
+            strSql.Append(" order by " + filedOrder);
245
+            return DbHelperSQL.Query(strSql.ToString());
246
+        }
247
+
248
+        /// <summary>
249
+        /// 获取记录总数
250
+        /// </summary>
251
+        public int GetRecordCount(string strWhere)
252
+        {
253
+            StringBuilder strSql = new StringBuilder();
254
+            strSql.Append("select count(1) FROM T_Msg_Chat_Map ");
255
+            if (strWhere.Trim() != "")
256
+            {
257
+                strSql.Append(" where " + strWhere);
258
+            }
259
+            object obj = DbHelperSQL.GetSingle(strSql.ToString());
260
+            if (obj == null)
261
+            {
262
+                return 0;
263
+            }
264
+            else
265
+            {
266
+                return Convert.ToInt32(obj);
267
+            }
268
+        }
269
+        /// <summary>
270
+        /// 分页获取数据列表
271
+        /// </summary>
272
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
273
+        {
274
+            StringBuilder strSql = new StringBuilder();
275
+            strSql.Append("SELECT * FROM ( ");
276
+            strSql.Append(" SELECT ROW_NUMBER() OVER (");
277
+            if (!string.IsNullOrEmpty(orderby.Trim()))
278
+            {
279
+                strSql.Append("order by T." + orderby);
280
+            }
281
+            else
282
+            {
283
+                strSql.Append("order by T.Id desc");
284
+            }
285
+            strSql.Append(")AS Row, T.*  from T_Msg_Chat_Map T ");
286
+            if (!string.IsNullOrEmpty(strWhere.Trim()))
287
+            {
288
+                strSql.Append(" WHERE " + strWhere);
289
+            }
290
+            strSql.Append(" ) TT");
291
+            strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
292
+            return DbHelperSQL.Query(strSql.ToString());
293
+        }
294
+
295
+        /*
296
+		/// <summary>
297
+		/// 分页获取数据列表
298
+		/// </summary>
299
+		public DataSet GetList(int PageSize,int PageIndex,string strWhere)
300
+		{
301
+			SqlParameter[] parameters = {
302
+					new SqlParameter("@tblName", SqlDbType.VarChar, 255),
303
+					new SqlParameter("@fldName", SqlDbType.VarChar, 255),
304
+					new SqlParameter("@PageSize", SqlDbType.Int),
305
+					new SqlParameter("@PageIndex", SqlDbType.Int),
306
+					new SqlParameter("@IsReCount", SqlDbType.Bit),
307
+					new SqlParameter("@OrderType", SqlDbType.Bit),
308
+					new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
309
+					};
310
+			parameters[0].Value = "T_Msg_Chat_Map";
311
+			parameters[1].Value = "Id";
312
+			parameters[2].Value = PageSize;
313
+			parameters[3].Value = PageIndex;
314
+			parameters[4].Value = 0;
315
+			parameters[5].Value = 0;
316
+			parameters[6].Value = strWhere;	
317
+			return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
318
+		}*/
319
+
320
+        #endregion  BasicMethod
321
+        #region  ExtensionMethod
322
+
323
+        #endregion  ExtensionMethod
324
+    }
325
+}

+ 352 - 0
RMYY_CallCenter_Api.Dal/T_Msg_NoticeInfo.cs

@@ -0,0 +1,352 @@
1
+using RMYY_CallCenter_Api.DB;
2
+using System;
3
+using System.Collections.Generic;
4
+using System.Data;
5
+using System.Data.SqlClient;
6
+using System.Linq;
7
+using System.Text;
8
+using System.Threading.Tasks;
9
+
10
+namespace RMYY_CallCenter_Api.Dal
11
+{
12
+   public  class T_Msg_NoticeInfo
13
+    {
14
+        public T_Msg_NoticeInfo()
15
+        { }
16
+        #region  BasicMethod
17
+
18
+        /// <summary>
19
+        /// 增加一条数据
20
+        /// </summary>
21
+        public int Add(RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model)
22
+        {
23
+            StringBuilder strSql = new StringBuilder();
24
+            strSql.Append("insert into T_Msg_NoticeInfo(");
25
+            strSql.Append("F_Title,F_Content,F_StartDate,F_EndDate,F_CreateOn,F_CreateBy,F_ModifyBy,F_ModifyDate,F_UserId,F_RoleId,F_File,F_Frequency)");
26
+            strSql.Append(" values (");
27
+            strSql.Append("@F_Title,@F_Content,@F_StartDate,@F_EndDate,@F_CreateOn,@F_CreateBy,@F_ModifyBy,@F_ModifyDate,@F_UserId,@F_RoleId,@F_File,@F_Frequency)");
28
+            strSql.Append(";select @@IDENTITY");
29
+            SqlParameter[] parameters = {
30
+                    new SqlParameter("@F_Title", SqlDbType.NVarChar,100),
31
+                    new SqlParameter("@F_Content", SqlDbType.NText),
32
+                    new SqlParameter("@F_StartDate", SqlDbType.DateTime),
33
+                    new SqlParameter("@F_EndDate", SqlDbType.DateTime),
34
+                    new SqlParameter("@F_CreateOn", SqlDbType.DateTime),
35
+                    new SqlParameter("@F_CreateBy", SqlDbType.Int,4),
36
+                    new SqlParameter("@F_ModifyBy", SqlDbType.Int,4),
37
+                    new SqlParameter("@F_ModifyDate", SqlDbType.DateTime),
38
+                    new SqlParameter("@F_UserId", SqlDbType.NVarChar,2000),
39
+                     new SqlParameter("@F_File", SqlDbType.NVarChar,100),
40
+                      new SqlParameter("@F_Frequency", SqlDbType.Int ,4),
41
+
42
+                    new SqlParameter("@F_RoleId", SqlDbType.NVarChar,2000)};
43
+            parameters[0].Value = model.F_Title;
44
+            parameters[1].Value = model.F_Content;
45
+            parameters[2].Value = model.F_StartDate;
46
+            parameters[3].Value = model.F_EndDate;
47
+            parameters[4].Value = model.F_CreateOn;
48
+            parameters[5].Value = model.F_CreateBy;
49
+            parameters[6].Value = model.F_ModifyBy;
50
+            parameters[7].Value = model.F_ModifyDate;
51
+            parameters[8].Value = model.F_UserId;
52
+            parameters[9].Value = model.F_File;
53
+            parameters[10].Value = model.F_Frequency;
54
+            parameters[11].Value = model.F_RoleId;
55
+
56
+            object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
57
+            if (obj == null)
58
+            {
59
+                return 0;
60
+            }
61
+            else
62
+            {
63
+                return Convert.ToInt32(obj);
64
+            }
65
+        }
66
+        /// <summary>
67
+        /// 更新一条数据
68
+        /// </summary>
69
+        public bool Update(RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model)
70
+        {
71
+            StringBuilder strSql = new StringBuilder();
72
+            strSql.Append("update T_Msg_NoticeInfo set ");
73
+            strSql.Append("F_Title=@F_Title,");
74
+            strSql.Append("F_Content=@F_Content,");
75
+            strSql.Append("F_StartDate=@F_StartDate,");
76
+            strSql.Append("F_EndDate=@F_EndDate,");
77
+            strSql.Append("F_CreateOn=@F_CreateOn,");
78
+            strSql.Append("F_CreateBy=@F_CreateBy,");
79
+            strSql.Append("F_ModifyBy=@F_ModifyBy,");
80
+            strSql.Append("F_ModifyDate=@F_ModifyDate,");
81
+            strSql.Append("F_UserId=@F_UserId,");
82
+            strSql.Append("F_File=@F_File,");
83
+            strSql.Append("F_Frequency=@F_Frequency,");
84
+
85
+            strSql.Append("F_RoleId=@F_RoleId");
86
+            strSql.Append(" where F_NoticeId=@F_NoticeId");
87
+            SqlParameter[] parameters = {
88
+                    new SqlParameter("@F_Title", SqlDbType.NVarChar,100),
89
+                    new SqlParameter("@F_Content", SqlDbType.NText),
90
+                    new SqlParameter("@F_StartDate", SqlDbType.DateTime),
91
+                    new SqlParameter("@F_EndDate", SqlDbType.DateTime),
92
+                    new SqlParameter("@F_CreateOn", SqlDbType.DateTime),
93
+                    new SqlParameter("@F_CreateBy", SqlDbType.Int,4),
94
+                    new SqlParameter("@F_ModifyBy", SqlDbType.Int,4),
95
+                    new SqlParameter("@F_ModifyDate", SqlDbType.DateTime),
96
+                    new SqlParameter("@F_UserId", SqlDbType.NVarChar,2000),
97
+                    new SqlParameter("@F_File", SqlDbType.NVarChar,100),
98
+                     new SqlParameter("@F_Frequency", SqlDbType.Int ,4),
99
+
100
+                    new SqlParameter("@F_RoleId", SqlDbType.NVarChar,2000),
101
+                    new SqlParameter("@F_NoticeId", SqlDbType.Int,4)};
102
+            parameters[0].Value = model.F_Title;
103
+            parameters[1].Value = model.F_Content;
104
+            parameters[2].Value = model.F_StartDate;
105
+            parameters[3].Value = model.F_EndDate;
106
+            parameters[4].Value = model.F_CreateOn;
107
+            parameters[5].Value = model.F_CreateBy;
108
+            parameters[6].Value = model.F_ModifyBy;
109
+            parameters[7].Value = model.F_ModifyDate;
110
+            parameters[8].Value = model.F_UserId;
111
+            parameters[9].Value = model.F_File;
112
+            parameters[10].Value = model.F_Frequency;
113
+
114
+            parameters[11].Value = model.F_RoleId;
115
+            parameters[12].Value = model.F_NoticeId;
116
+
117
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
118
+            if (rows > 0)
119
+            {
120
+                return true;
121
+            }
122
+            else
123
+            {
124
+                return false;
125
+            }
126
+        }
127
+
128
+        /// <summary>
129
+        /// 删除一条数据
130
+        /// </summary>
131
+        public bool Delete(int F_NoticeId)
132
+        {
133
+
134
+            StringBuilder strSql = new StringBuilder();
135
+            strSql.Append("delete from T_Msg_NoticeInfo ");
136
+            strSql.Append(" where F_NoticeId=@F_NoticeId");
137
+            SqlParameter[] parameters = {
138
+                    new SqlParameter("@F_NoticeId", SqlDbType.Int,4)
139
+            };
140
+            parameters[0].Value = F_NoticeId;
141
+
142
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
143
+            if (rows > 0)
144
+            {
145
+                return true;
146
+            }
147
+            else
148
+            {
149
+                return false;
150
+            }
151
+        }
152
+        /// <summary>
153
+        /// 批量删除数据
154
+        /// </summary>
155
+        public bool DeleteList(string F_NoticeIdlist)
156
+        {
157
+            StringBuilder strSql = new StringBuilder();
158
+            strSql.Append("delete from T_Msg_NoticeInfo ");
159
+            strSql.Append(" where F_NoticeId in (" + F_NoticeIdlist + ")  ");
160
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
161
+            if (rows > 0)
162
+            {
163
+                return true;
164
+            }
165
+            else
166
+            {
167
+                return false;
168
+            }
169
+        }
170
+
171
+
172
+        /// <summary>
173
+        /// 得到一个对象实体
174
+        /// </summary>
175
+        public RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo GetModel(int F_NoticeId)
176
+        {
177
+
178
+            StringBuilder strSql = new StringBuilder();
179
+            strSql.Append("select  top 1 F_NoticeId,F_Title,F_Content,F_StartDate,F_EndDate,F_CreateOn,F_CreateBy,F_ModifyBy,F_ModifyDate,F_UserId,F_RoleId,F_File,F_Frequency from T_Msg_NoticeInfo ");
180
+            strSql.Append(" where F_NoticeId=@F_NoticeId");
181
+            SqlParameter[] parameters = {
182
+                    new SqlParameter("@F_NoticeId", SqlDbType.Int,4)
183
+            };
184
+            parameters[0].Value = F_NoticeId;
185
+
186
+            RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model = new RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo();
187
+            DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
188
+            if (ds.Tables[0].Rows.Count > 0)
189
+            {
190
+                return DataRowToModel(ds.Tables[0].Rows[0]);
191
+            }
192
+            else
193
+            {
194
+                return null;
195
+            }
196
+        }
197
+
198
+
199
+        /// <summary>
200
+        /// 得到一个对象实体
201
+        /// </summary>
202
+        public RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo DataRowToModel(DataRow row)
203
+        {
204
+            RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo model = new RMYY_CallCenter_Api.Model.T_Msg_NoticeInfo();
205
+            if (row != null)
206
+            {
207
+                if (row["F_NoticeId"] != null && row["F_NoticeId"].ToString() != "")
208
+                {
209
+                    model.F_NoticeId = int.Parse(row["F_NoticeId"].ToString());
210
+                }
211
+                if (row["F_Frequency"] != null && row["F_Frequency"].ToString() != "")
212
+                {
213
+                    model.F_Frequency = int.Parse(row["F_Frequency"].ToString());
214
+                }
215
+                if (row["F_Title"] != null)
216
+                {
217
+                    model.F_Title = row["F_Title"].ToString();
218
+                }
219
+                if (row["F_Content"] != null)
220
+                {
221
+                    model.F_Content = row["F_Content"].ToString();
222
+                }
223
+                if (row["F_StartDate"] != null && row["F_StartDate"].ToString() != "")
224
+                {
225
+                    model.F_StartDate = DateTime.Parse(row["F_StartDate"].ToString());
226
+                }
227
+                if (row["F_EndDate"] != null && row["F_EndDate"].ToString() != "")
228
+                {
229
+                    model.F_EndDate = DateTime.Parse(row["F_EndDate"].ToString());
230
+                }
231
+                if (row["F_CreateOn"] != null && row["F_CreateOn"].ToString() != "")
232
+                {
233
+                    model.F_CreateOn = DateTime.Parse(row["F_CreateOn"].ToString());
234
+                }
235
+                if (row["F_CreateBy"] != null && row["F_CreateBy"].ToString() != "")
236
+                {
237
+                    model.F_CreateBy = int.Parse(row["F_CreateBy"].ToString());
238
+                }
239
+                if (row["F_ModifyBy"] != null && row["F_ModifyBy"].ToString() != "")
240
+                {
241
+                    model.F_ModifyBy = int.Parse(row["F_ModifyBy"].ToString());
242
+                }
243
+                if (row["F_ModifyDate"] != null && row["F_ModifyDate"].ToString() != "")
244
+                {
245
+                    model.F_ModifyDate = DateTime.Parse(row["F_ModifyDate"].ToString());
246
+                }
247
+                if (row["F_UserId"] != null)
248
+                {
249
+                    model.F_UserId = row["F_UserId"].ToString();
250
+                }
251
+                if (row["F_RoleId"] != null)
252
+                {
253
+                    model.F_RoleId = row["F_RoleId"].ToString();
254
+                }
255
+                if (row["F_File"] != null)
256
+                {
257
+                    model.F_File = row["F_File"].ToString();
258
+                }
259
+
260
+            }
261
+            return model;
262
+        }
263
+
264
+        /// <summary>
265
+        /// 获得数据列表
266
+        /// </summary>
267
+        public DataSet GetList(string strWhere)
268
+        {
269
+            StringBuilder strSql = new StringBuilder();
270
+            strSql.Append("select F_NoticeId,F_Title,F_Content,F_StartDate,F_EndDate,F_CreateOn,F_CreateBy,F_ModifyBy,F_ModifyDate,F_UserId,F_RoleId,F_File,F_Frequency ");
271
+            strSql.Append(" FROM T_Msg_NoticeInfo ");
272
+            if (strWhere.Trim() != "")
273
+            {
274
+                strSql.Append(" where " + strWhere);
275
+            }
276
+            return DbHelperSQL.Query(strSql.ToString());
277
+        }
278
+
279
+        /// <summary>
280
+        /// 获得前几行数据
281
+        /// </summary>
282
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
283
+        {
284
+            StringBuilder strSql = new StringBuilder();
285
+            strSql.Append("select ");
286
+            if (Top > 0)
287
+            {
288
+                strSql.Append(" top " + Top.ToString());
289
+            }
290
+            strSql.Append(" F_NoticeId,F_Title,F_Content,F_StartDate,F_EndDate,F_CreateOn,F_CreateBy,F_ModifyBy,F_ModifyDate,F_UserId,F_RoleId,F_File,F_Frequency ");
291
+            strSql.Append(" FROM T_Msg_NoticeInfo ");
292
+            if (strWhere.Trim() != "")
293
+            {
294
+                strSql.Append(" where " + strWhere);
295
+            }
296
+            strSql.Append(" order by " + filedOrder);
297
+            return DbHelperSQL.Query(strSql.ToString());
298
+        }
299
+
300
+        /// <summary>
301
+        /// 获取记录总数
302
+        /// </summary>
303
+        public int GetRecordCount(string strWhere)
304
+        {
305
+            StringBuilder strSql = new StringBuilder();
306
+            strSql.Append("select count(1) FROM T_Msg_NoticeInfo ");
307
+            if (strWhere.Trim() != "")
308
+            {
309
+                strSql.Append(" where " + strWhere);
310
+            }
311
+            object obj = DbHelperSQL.GetSingle(strSql.ToString());
312
+            if (obj == null)
313
+            {
314
+                return 0;
315
+            }
316
+            else
317
+            {
318
+                return Convert.ToInt32(obj);
319
+            }
320
+        }
321
+        /// <summary>
322
+        /// 分页获取数据列表
323
+        /// </summary>
324
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
325
+        {
326
+            StringBuilder strSql = new StringBuilder();
327
+            strSql.Append("SELECT * FROM ( ");
328
+            strSql.Append(" SELECT ROW_NUMBER() OVER (");
329
+            if (!string.IsNullOrEmpty(orderby.Trim()))
330
+            {
331
+                strSql.Append("order by T." + orderby);
332
+            }
333
+            else
334
+            {
335
+                strSql.Append("order by T.F_NoticeId desc");
336
+            }
337
+            strSql.Append(")AS Row, T.*  from T_Msg_NoticeInfo T ");
338
+            if (!string.IsNullOrEmpty(strWhere.Trim()))
339
+            {
340
+                strSql.Append(" WHERE " + strWhere);
341
+            }
342
+            strSql.Append(" ) TT");
343
+            strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
344
+            return DbHelperSQL.Query(strSql.ToString());
345
+        }
346
+
347
+        #endregion  BasicMethod
348
+        #region  ExtensionMethod
349
+
350
+        #endregion  ExtensionMethod
351
+    }
352
+}

+ 97 - 0
RMYY_CallCenter_Api.Model/T_Msg_Chat.cs

@@ -0,0 +1,97 @@
1
+using System;
2
+using System.Collections.Generic;
3
+using System.Linq;
4
+using System.Text;
5
+using System.Threading.Tasks;
6
+
7
+namespace RMYY_CallCenter_Api.Model
8
+{
9
+   public  class T_Msg_Chat
10
+    {
11
+        public T_Msg_Chat()
12
+        { }
13
+        #region Model
14
+        private int _id;
15
+        private string _content;
16
+        private string _voiceurl;
17
+        private DateTime? _createdate = DateTime.Now;
18
+        private int? _fromuserid;
19
+        private int? _touserid;
20
+        private int? _toroleid;
21
+        private int? _istoall;
22
+        private int? _isdelete;
23
+        /// <summary>
24
+        /// Id
25
+        /// </summary>
26
+        public int Id
27
+        {
28
+            set { _id = value; }
29
+            get { return _id; }
30
+        }
31
+        /// <summary>
32
+        /// 及时通讯内容
33
+        /// </summary>
34
+        public string Content
35
+        {
36
+            set { _content = value; }
37
+            get { return _content; }
38
+        }
39
+        /// <summary>
40
+        /// 语音路径
41
+        /// </summary>
42
+        public string VoiceUrl
43
+        {
44
+            set { _voiceurl = value; }
45
+            get { return _voiceurl; }
46
+        }
47
+        /// <summary>
48
+        /// 开始时间
49
+        /// </summary>
50
+        public DateTime? CreateDate
51
+        {
52
+            set { _createdate = value; }
53
+            get { return _createdate; }
54
+        }
55
+        /// <summary>
56
+        /// 发送人Id
57
+        /// </summary>
58
+        public int? FromUserId
59
+        {
60
+            set { _fromuserid = value; }
61
+            get { return _fromuserid; }
62
+        }
63
+        /// <summary>
64
+        /// 接收人Id
65
+        /// </summary>
66
+        public int? ToUserId
67
+        {
68
+            set { _touserid = value; }
69
+            get { return _touserid; }
70
+        }
71
+        /// <summary>
72
+        /// 接收角色Id
73
+        /// </summary>
74
+        public int? ToRoleId
75
+        {
76
+            set { _toroleid = value; }
77
+            get { return _toroleid; }
78
+        }
79
+        /// <summary>
80
+        /// 是否群发(0不群发1群发)
81
+        /// </summary>
82
+        public int? IsToAll
83
+        {
84
+            set { _istoall = value; }
85
+            get { return _istoall; }
86
+        }
87
+        /// <summary>
88
+        /// 是否删除(0正常1已删除)
89
+        /// </summary>
90
+        public int? IsDelete
91
+        {
92
+            set { _isdelete = value; }
93
+            get { return _isdelete; }
94
+        }
95
+        #endregion Model
96
+    }
97
+}

+ 70 - 0
RMYY_CallCenter_Api.Model/T_Msg_Chat_Map.cs

@@ -0,0 +1,70 @@
1
+using System;
2
+using System.Collections.Generic;
3
+using System.Linq;
4
+using System.Text;
5
+using System.Threading.Tasks;
6
+
7
+namespace RMYY_CallCenter_Api.Model
8
+{
9
+  public   class T_Msg_Chat_Map
10
+    {
11
+        public T_Msg_Chat_Map()
12
+        { }
13
+        #region Model
14
+        private int _chatid;
15
+        private int? _fromuserid;
16
+        private int? _touserid;
17
+        private DateTime? _createdate = DateTime.Now;
18
+        private int? _isread;
19
+        private int _id;
20
+        /// <summary>
21
+        /// ChatId
22
+        /// </summary>
23
+        public int ChatId
24
+        {
25
+            set { _chatid = value; }
26
+            get { return _chatid; }
27
+        }
28
+        /// <summary>
29
+        /// 发送人Id
30
+        /// </summary>
31
+        public int? FromUserId
32
+        {
33
+            set { _fromuserid = value; }
34
+            get { return _fromuserid; }
35
+        }
36
+        /// <summary>
37
+        /// 接收人Id
38
+        /// </summary>
39
+        public int? ToUserId
40
+        {
41
+            set { _touserid = value; }
42
+            get { return _touserid; }
43
+        }
44
+        /// <summary>
45
+        /// 开始时间
46
+        /// </summary>
47
+        public DateTime? CreateDate
48
+        {
49
+            set { _createdate = value; }
50
+            get { return _createdate; }
51
+        }
52
+        /// <summary>
53
+        /// 是否已读(0未读,1已读)
54
+        /// </summary>
55
+        public int? IsRead
56
+        {
57
+            set { _isread = value; }
58
+            get { return _isread; }
59
+        }
60
+        /// <summary>
61
+        /// 
62
+        /// </summary>
63
+        public int Id
64
+        {
65
+            set { _id = value; }
66
+            get { return _id; }
67
+        }
68
+        #endregion Model
69
+    }
70
+}

+ 122 - 0
RMYY_CallCenter_Api.Model/T_Msg_NoticeInfo.cs

@@ -0,0 +1,122 @@
1
+using System;
2
+using System.Collections.Generic;
3
+using System.Linq;
4
+using System.Text;
5
+using System.Threading.Tasks;
6
+
7
+namespace RMYY_CallCenter_Api.Model
8
+{
9
+   public  class T_Msg_NoticeInfo
10
+    {
11
+        public T_Msg_NoticeInfo()
12
+        { }
13
+        #region Model
14
+        private int _f_noticeid;
15
+        private string _f_title;
16
+        private string _f_content;
17
+        private DateTime? _f_startdate;
18
+        private DateTime? _f_enddate;
19
+        private DateTime? _f_createon = DateTime.Now;
20
+        private int? _f_createby;
21
+        private int? _f_modifyby;
22
+        private DateTime? _f_modifydate = DateTime.Now;
23
+        private string _f_userid;
24
+        private string _f_roleid;
25
+        private string _f_file;
26
+        /// <summary>
27
+        /// 公告Id
28
+        /// </summary>
29
+        public int F_NoticeId
30
+        {
31
+            set { _f_noticeid = value; }
32
+            get { return _f_noticeid; }
33
+        }
34
+        /// <summary>
35
+        /// 公告标题
36
+        /// </summary>
37
+        public string F_Title
38
+        {
39
+            set { _f_title = value; }
40
+            get { return _f_title; }
41
+        }
42
+        /// <summary>
43
+        /// 公告内容
44
+        /// </summary>
45
+        public string F_Content
46
+        {
47
+            set { _f_content = value; }
48
+            get { return _f_content; }
49
+        }
50
+        /// <summary>
51
+        /// 有效期开始时间
52
+        /// </summary>
53
+        public DateTime? F_StartDate
54
+        {
55
+            set { _f_startdate = value; }
56
+            get { return _f_startdate; }
57
+        }
58
+        /// <summary>
59
+        /// 有效期结束时间
60
+        /// </summary>
61
+        public DateTime? F_EndDate
62
+        {
63
+            set { _f_enddate = value; }
64
+            get { return _f_enddate; }
65
+        }
66
+        /// <summary>
67
+        /// 添加时间
68
+        /// </summary>
69
+        public DateTime? F_CreateOn
70
+        {
71
+            set { _f_createon = value; }
72
+            get { return _f_createon; }
73
+        }
74
+        /// <summary>
75
+        /// 添加人Id
76
+        /// </summary>
77
+        public int? F_CreateBy
78
+        {
79
+            set { _f_createby = value; }
80
+            get { return _f_createby; }
81
+        }
82
+        /// <summary>
83
+        /// 修改人Id
84
+        /// </summary>
85
+        public int? F_ModifyBy
86
+        {
87
+            set { _f_modifyby = value; }
88
+            get { return _f_modifyby; }
89
+        }
90
+        /// <summary>
91
+        /// 修改时间
92
+        /// </summary>
93
+        public DateTime? F_ModifyDate
94
+        {
95
+            set { _f_modifydate = value; }
96
+            get { return _f_modifydate; }
97
+        }
98
+        /// <summary>
99
+        /// 权限用户Id
100
+        /// </summary>
101
+        public string F_UserId
102
+        {
103
+            set { _f_userid = value; }
104
+            get { return _f_userid; }
105
+        }
106
+        /// <summary>
107
+        /// 权限角色Id
108
+        /// </summary>
109
+        public string F_RoleId
110
+        {
111
+            set { _f_roleid = value; }
112
+            get { return _f_roleid; }
113
+        }
114
+        public string F_File
115
+        {
116
+            set { _f_file = value; }
117
+            get { return _f_file; }
118
+        }
119
+        public int? F_Frequency { set; get; }
120
+        #endregion Model
121
+    }
122
+}