1using System;
  2using System.Collections.Generic;
  3using System.Data;
  4using System.Data.OleDb;
  5using MyShop.IDAL;
  6using MyShop.Model;
  7
  8namespace MyShop.AccessDAL
  9...{
 10     public class Log:ILog
 11    ...{
 12        private ConfigInfo configInfo = new ConfigInfo();
 13        private string tableName = "Ljh_Log";
 14
 15        public Log()
 16        ...{
 17            if (!string.IsNullOrEmpty(configInfo.TablePrefix.Trim()))
 18                tableName = configInfo.TablePrefix + "Log";
 19        }
 20
 21        ILog member#region ILog member
 22
 23
 24        /**//// <summary>
 25        /// add  
 26        /// </summary>
 27        /// <param name="model"></param>
 28        /// <returns>返回ID, 如果发生错误则返回-1</returns>
 29        public int Add(LogInfo model)
 30        ...{
 31            if (model == null)
 32            ...{
 33                return -1;
 34            }
 35            string commandText = "insert into " + this.tableName + "(LogType,ChannelID,LogTime,UserName,UserIP,LogContent,ScriptName,PostString)  values(@LogType,@ChannelID,@LogTime,@UserName,@UserIP,@LogContent,@ScriptName,@PostString)  ";
 36            OleDbParameter[] commandParameters = ...{
 37                Database.MakeInParam("@LogType",OleDbType.Integer,4,model.LogType),
 38                Database.MakeInParam("@ChannelID",OleDbType.Integer,4,model.ChannelID),
 39                Database.MakeInParam("@LogTime",OleDbType.Date,8,model.LogTime),
 40                Database.MakeInParam("@UserName",OleDbType.VarWChar,20,model.UserName),
 41                Database.MakeInParam("@UserIP",OleDbType.VarWChar,15,model.UserIP),
 42                Database.MakeInParam("@LogContent",OleDbType.VarWChar,255,model.LogContent),
 43                Database.MakeInParam("@ScriptName",OleDbType.VarWChar,255,model.ScriptName),
 44                Database.MakeInParam("@PostString",OleDbType.VarWChar,0,model.PostString),
 45                Database.MakeInParam("@LogType",OleDbType.Integer,4,model.LogType),
 46                Database.MakeInParam("@ChannelID",OleDbType.Integer,4,model.ChannelID),
 47                Database.MakeInParam("@LogTime",OleDbType.Date,8,model.LogTime),
 48                Database.MakeInParam("@UserName",OleDbType.VarWChar,20,model.UserName),
 49                Database.MakeInParam("@UserIP",OleDbType.VarWChar,15,model.UserIP),
 50                Database.MakeInParam("@LogContent",OleDbType.VarWChar,255,model.LogContent),
 51                Database.MakeInParam("@ScriptName",OleDbType.VarWChar,255,model.ScriptName),
 52                Database.MakeInParam("@PostString",OleDbType.VarWChar,0,model.PostString)
 53
 54         };
 55            int intIdentity = -1;
 56            try
 57            ...{
 58                Database.ExecuteNonQuery(CommandType.Text, out intIdentity, commandText, commandParameters);
 59            }
 60            catch (Exception exception)
 61            ...{
 62                throw exception;
 63            }
 64            return intIdentity;
 65        }
 66
 67
 68
 69
 70        /**//// <summary>
 71        /// 删除 
 72        /// </summary>
 73        /// <param name="filter">where后面的条件语句，不加where</param>
 74        /// <returns>返回影响行数</returns>
 75        public int Delete(string filter)
 76        ...{
 77            int count = -1;
 78            string sql = @"delete from " + tableName;
 79            if (!string.IsNullOrEmpty(filter.Trim()))
 80            ...{
 81                sql = sql + "  where  " + filter;
 82            }
 83            try
 84            ...{
 85                
 86                count = Database.ExecuteNonQuery(sql);
 87            }
 88            catch (Exception ex)
 89            ...{
 90                throw ex;
 91            }
 92            return count;
 93        }
 94
 95        /**//// <summary>
 96        /// 
 97        /// </summary>
 98        /// <param name="filter"></param>
 99        /// <returns></returns>
100        public bool Exist(string filter)
101        ...{
102            bool result = false;
103            string sql = @"select * from " + tableName;
104            if (!string.IsNullOrEmpty(filter))
105            ...{
106                sql = sql + "  where  " + filter;
107            }
108            try
109            ...{
110                
111
112                DataSet dataset = new DataSet();
113                dataset = Database.ExecuteDataSet(sql);
114                if (dataset.Tables[0].Rows.Count > 0)
115                ...{
116                    result = true;
117                }
118            }
119            catch (Exception ex)
120            ...{
121                throw ex;
122            }
123            return result;
124        }
125
126        /**//// <summary>
127        /// 返回所有
128        /// </summary>
129        /// <returns>返回所有</returns>
130        public DataSet GetDataSet()
131        ...{
132            string sql = "select * from " + tableName;
133            DataSet dataset = new DataSet();
134            try
135            ...{
136                
137                dataset = Database.ExecuteDataSet(sql);
138
139            }
140            catch (Exception ex)
141            ...{
142                throw ex;
143            }
144            return dataset;
145        }
146
147        public DataSet GetDataSet(string filter)
148        ...{
149            if (string.IsNullOrEmpty(filter))
150                return null;
151
152            string sql = "select * from " + tableName + " where " + filter;
153            DataSet dataset = new DataSet();
154            try
155            ...{
156                
157                dataset = Database.ExecuteDataSet(sql);
158            }
159            catch (Exception ex)
160            ...{
161                throw ex;
162            }
163            return dataset;
164        }
165
166        /**//// <summary>
167        ///
168        /// </summary>
169        /// <param name="dr"></param>
170        /// <returns></returns>
171        public LogInfo GetModel(DataRow dr)
172        ...{
173            if (dr == null)
174                return null;
175            LogInfo model = new LogInfo();
176
177            if (dr["LogID"].ToString() != "") model.LogID = Convert.ToInt32( dr["LogID"]);
178            if (dr["LogType"].ToString() != "") model.LogType = Convert.ToInt32( dr["LogType"]);
179            if (dr["ChannelID"].ToString() != "") model.ChannelID =Convert.ToInt32( dr["ChannelID"]);
180            if (dr["LogTime"].ToString() != "") model.LogTime = dr["LogTime"].ToString();
181            if (dr["UserName"].ToString() != "") model.UserName = dr["UserName"].ToString();
182            if (dr["UserIP"].ToString() != "") model.UserIP = dr["UserIP"].ToString();
183            if (dr["LogContent"].ToString() != "") model.LogContent = dr["LogContent"].ToString();
184            if (dr["ScriptName"].ToString() != "") model.ScriptName = dr["ScriptName"].ToString();
185            if (dr["PostString"].ToString() != "") model.PostString = dr["PostString"].ToString();
186
187
188
189            return model;
190        }
191
192        /**//// <summary>
193        /// 
194        /// </summary>
195        /// <param name="sql"></param>
196        /// <returns></returns>
197        public DataSet Query(string sql)
198        ...{
199            if (string.IsNullOrEmpty(sql))
200                return null;
201
202            DataSet dataset = new DataSet();
203            try
204            ...{
205                
206                dataset = Database.ExecuteDataSet(sql);
207            }
208            catch (Exception ex)
209            ...{
210                throw ex;
211            }
212            return dataset;
213        }
214
215
216        /**//// <summary>
217        /// update  
218        /// </summary>
219        /// <param name="model"></param>
220        /// <param name="filter"></param>
221        /// <returns></returns>
222        public int Update(LogInfo model, string filter)
223        ...{
224            int result;
225            if (string.IsNullOrEmpty(filter))
226            ...{
227                throw new Exception("The 'filter' can not be null!");
228            }
229            string sql = @"update " + tableName + " set  LogType=@LogType,ChannelID=@ChannelID,LogTime=@LogTime,UserName=@UserName,UserIP=@UserIP,LogContent=@LogContent,ScriptName=@ScriptName,PostString=@PostString " + " where " + filter;
230
231
232            OleDbParameter[] prams = ...{
233                Database.MakeInParam("@LogType",OleDbType.Integer,4,model.LogType),
234                Database.MakeInParam("@ChannelID",OleDbType.Integer,4,model.ChannelID),
235                Database.MakeInParam("@LogTime",OleDbType.Date,8,model.LogTime),
236                Database.MakeInParam("@UserName",OleDbType.VarWChar,20,model.UserName),
237                Database.MakeInParam("@UserIP",OleDbType.VarWChar,15,model.UserIP),
238                Database.MakeInParam("@LogContent",OleDbType.VarWChar,255,model.LogContent),
239                Database.MakeInParam("@ScriptName",OleDbType.VarWChar,255,model.ScriptName),
240                Database.MakeInParam("@PostString",OleDbType.VarWChar,0,model.PostString),
241                Database.MakeInParam("@LogType",OleDbType.Integer,4,model.LogType),
242                Database.MakeInParam("@ChannelID",OleDbType.Integer,4,model.ChannelID),
243                Database.MakeInParam("@LogTime",OleDbType.Date,8,model.LogTime),
244                Database.MakeInParam("@UserName",OleDbType.VarWChar,20,model.UserName),
245                Database.MakeInParam("@UserIP",OleDbType.VarWChar,15,model.UserIP),
246                Database.MakeInParam("@LogContent",OleDbType.VarWChar,255,model.LogContent),
247                Database.MakeInParam("@ScriptName",OleDbType.VarWChar,255,model.ScriptName),
248                Database.MakeInParam("@PostString",OleDbType.VarWChar,0,model.PostString)
249
250         };
251
252
253            try
254            ...{
255                
256                result = Database.ExecuteNonQuery(sql, prams);
257            }
258            catch (Exception ex)
259            ...{
260                throw ex;
261            }
262            return result;
263        }
264
265
266        #endregion
267
268        /**//// <summary>
269        /// 删除两天以前的日志
270        /// </summary>
271        /// <returns></returns>
272         public int DeleteLogBeforeTwoDays()
273         ...{
274             return this.Delete("  DateDiff('d',logtime,now()) > 2 ");
275         }
276
277
278    }
279}
280