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 BankrollItem:IBankrollItem
 11    ...{
 12        private ConfigInfo configInfo = new ConfigInfo();
 13        private string tableName = "Ljh_BankrollItem";
 14
 15        public BankrollItem()
 16        ...{
 17            if (!string.IsNullOrEmpty(configInfo.TablePrefix.Trim()))
 18                tableName = configInfo.TablePrefix + "BankrollItem";
 19
 20        }
 21        IBankrollItem 成员#region IBankrollItem 成员
 22
 23        /**//// <summary>
 24        /// 添加 
 25        /// </summary>
 26        /// <param name="model"></param>
 27        /// <returns>返回ID, 如果发生错误则返回-1</returns>
 28        public int Add(BankrollItemInfo model)
 29        ...{
 30            if (model == null)
 31            ...{
 32                return -1;
 33            }
 34            string commandText = "insert into " + this.tableName + "([userName],clientId,dateAndTime,[money],moneyType,currencyType,eBankId,[bank],income_payout,orderId,paymentId,[remark],[logTime],[inputer],[ip])  values(@userName,@clientId,@dateAndTime,@money,@moneyType,@currencyType,@eBankId,@bank,@income_payout,@orderId,@paymentId,@remark,@logTime,@inputer,@ip)   ";
 35            OleDbParameter[] commandParameters = ...{
 36                    Database.MakeInParam("@UserName", OleDbType.VarWChar,50,model.UserName),
 37                    Database.MakeInParam("@ClientId", OleDbType.Integer,4,model.ClientId),
 38                    Database.MakeInParam("@DateAndTime", OleDbType.Date,8,model.DateAndTime),
 39                    Database.MakeInParam("@Money", OleDbType.Currency,8,model.Money),
 40                    Database.MakeInParam("@MoneyType", OleDbType.Integer,4,model.MoneyType),
 41                    Database.MakeInParam("@CurrencyType", OleDbType.Integer,4,model.CurrencyType),
 42                    Database.MakeInParam("@EBankId", OleDbType.Integer,4,model.EBankId),
 43                    Database.MakeInParam("@Bank", OleDbType.VarWChar,50,model.Bank),
 44                    Database.MakeInParam("@Income_Payout", OleDbType.Integer,4,model.Income_Payout),
 45                    Database.MakeInParam("@OrderId", OleDbType.Integer,4,model.OrderId),
 46                    Database.MakeInParam("@PaymentId", OleDbType.Integer,4,model.PaymentId),
 47                    Database.MakeInParam("@Remark", OleDbType.VarWChar,255,model.Remark),
 48                    Database.MakeInParam("@LogTime", OleDbType.Date,8,model.LogTime),
 49                    Database.MakeInParam("@Inputer", OleDbType.VarWChar,50,model.Inputer),
 50                    Database.MakeInParam("@Ip", OleDbType.VarWChar,50,model.Ip)
 51                                                           };
 52            int intIdentity = -1;
 53            try
 54            ...{
 55                Database.ExecuteNonQuery(CommandType.Text, out intIdentity, commandText, commandParameters);
 56            }
 57            catch (Exception exception)
 58            ...{
 59                throw exception;
 60            }
 61            return intIdentity;
 62        }
 63
 64        /**//// <summary>
 65        /// 删除会员 
 66        /// </summary>
 67        /// <param name="filter">where后面的条件语句，不加where</param>
 68        /// <returns>返回影响行数</returns>
 69        public int Delete(string filter)
 70        ...{
 71            int count = -1;
 72            string sql = @"delete from " + tableName;
 73            if (!string.IsNullOrEmpty(filter.Trim()))
 74            ...{
 75                sql = sql + "  where  " + filter;
 76            }
 77            try
 78            ...{
 79
 80                count = Database.ExecuteNonQuery(sql);
 81            }
 82            catch (Exception ex)
 83            ...{
 84                throw ex;
 85            }
 86            return count;
 87        }
 88
 89        /**//// <summary>
 90        /// 判断是否存在
 91        /// </summary>
 92        /// <param name="filter"></param>
 93        /// <returns></returns>
 94        public bool Exist(string filter)
 95        ...{
 96            bool result = false;
 97            string sql = @"select * from " + tableName;
 98            if (!string.IsNullOrEmpty(filter.Trim()))
 99            ...{
100                sql = sql + "  where  " + filter;
101            }
102            try
103            ...{
104
105
106                DataSet dataset = new DataSet();
107                dataset = Database.ExecuteDataSet(sql);
108                if (dataset.Tables[0].Rows.Count > 0)
109                ...{
110                    result = true;
111                }
112            }
113            catch (Exception ex)
114            ...{
115                throw ex;
116            }
117            return result;
118        }
119
120        /**//// <summary>
121        /// 返回所有
122        /// </summary>
123        /// <returns>返回所有</returns>
124        public DataSet GetDataSet()
125        ...{
126            string sql = "select * from " + tableName;
127            DataSet dataset = new DataSet();
128            try
129            ...{
130
131                dataset = Database.ExecuteDataSet(sql);
132
133            }
134            catch (Exception ex)
135            ...{
136                throw ex;
137            }
138            return dataset;
139        }
140
141        /**//// <summary>
142        /// 
143        /// </summary>
144        /// <param name="filter"></param>
145        /// <returns></returns>
146        public DataSet GetDataSet(string filter)
147        ...{
148            if (string.IsNullOrEmpty(filter))
149                return null;
150
151            string sql = "select * from " + tableName + " where " + filter;
152            DataSet dataset = new DataSet();
153            try
154            ...{
155
156                dataset = Database.ExecuteDataSet(sql);
157            }
158            catch (Exception ex)
159            ...{
160                throw ex;
161            }
162            return dataset;
163        }
164
165        /**//// <summary>
166        /// /
167        /// </summary>
168        /// <param name="dr"></param>
169        /// <returns></returns>
170        public BankrollItemInfo GetModel(DataRow dr)
171        ...{
172            if (dr == null)
173                return null;
174            BankrollItemInfo model = new BankrollItemInfo();
175
176            if (dr["ItemId"].ToString() != "") model.ItemId = int.Parse( dr["ItemId"].ToString());
177            if (dr["UserName"].ToString() != "") model.UserName = dr["UserName"].ToString();
178            if (dr["ClientId"].ToString() != "") model.ClientId = int.Parse (dr["ClientId"].ToString());
179            if (dr["DateAndTime"].ToString() != "") model.DateAndTime = dr["DateAndTime"].ToString();
180            if (dr["Money"].ToString() != "") model.Money = decimal.Parse( dr["Money"].ToString());
181            if (dr["MoneyType"].ToString() != "") model.MoneyType = int.Parse( dr["MoneyType"].ToString());
182            if (dr["CurrencyType"].ToString() != "") model.CurrencyType = int.Parse( dr["CurrencyType"].ToString());
183            if (dr["EBankId"].ToString() != "") model.EBankId = int.Parse( dr["EBankId"].ToString());
184            if (dr["Bank"].ToString() != "") model.Bank = dr["Bank"].ToString();
185            if (dr["Income_payout"].ToString() != "") model.Income_Payout = int.Parse( dr["Income_payout"].ToString());
186            if (dr["OrderId"].ToString() != "") model.OrderId = int.Parse(  dr["OrderId"].ToString());
187            if (dr["PaymentId"].ToString() != "") model.PaymentId = int.Parse(  dr["PaymentId"].ToString());
188            if (dr["Remark"].ToString() != "") model.Remark = dr["Remark"].ToString();
189            if (dr["LogTime"].ToString() != "") model.LogTime = dr["LogTime"].ToString();
190            if (dr["Inputer"].ToString() != "") model.Inputer = dr["Inputer"].ToString();
191            if (dr["Ip"].ToString() != "") model.Ip = dr["Ip"].ToString();
192            return model;
193        }
194
195        /**//// <summary>
196        /// 
197        /// </summary>
198        /// <param name="sql"></param>
199        /// <returns></returns>
200        public DataSet Query(string sql)
201        ...{
202            if (string.IsNullOrEmpty(sql))
203                return null;
204
205            DataSet dataset = new DataSet();
206            try
207            ...{
208
209                dataset = Database.ExecuteDataSet(sql);
210            }
211            catch (Exception ex)
212            ...{
213                throw ex;
214            }
215            return dataset;
216        }
217
218        /**//// <summary>
219        /// 
220        /// </summary>
221        /// <param name="model"></param>
222        /// <param name="filter"></param>
223        /// <returns></returns>
224        public int Update(BankrollItemInfo model, string filter)
225        ...{
226            int result;
227            if (string.IsNullOrEmpty(filter))
228            ...{
229                throw new Exception("The 'filter' can not be null!");
230            }
231            string sql = @"update " + tableName + " set  UserName=@UserName,clientId=@clientId,dateAndTime=@dateAndTime,money=@money,moneyType=@moneyType,currencyType=@currencyType,eBankId=@eBankId,bank=@bank,income_payout=@income_payout,orderId=@orderId,paymentId=@paymentId,Remark=@Remark,logTime=@logTime,inputer=@inputer,ip=@ip " + " where " + filter;
232            OleDbParameter[] prams = ...{
233                            Database.MakeInParam("@UserName", OleDbType.VarWChar,50,model.UserName),
234                            Database.MakeInParam("@ClientId", OleDbType.Integer,4,model.ClientId),
235                            Database.MakeInParam("@DateAndTime", OleDbType.Date,8,model.DateAndTime),
236                            Database.MakeInParam("@Money", OleDbType.Currency,8,model.Money),
237                            Database.MakeInParam("@MoneyType", OleDbType.Integer,4,model.MoneyType),
238                            Database.MakeInParam("@CurrencyType", OleDbType.Integer,4,model.CurrencyType),
239                            Database.MakeInParam("@EBankId", OleDbType.Integer,4,model.EBankId),
240                            Database.MakeInParam("@Bank", OleDbType.VarWChar,50,model.Bank),
241                            Database.MakeInParam("@Income_Payout", OleDbType.Integer,4,model.Income_Payout),
242                            Database.MakeInParam("@OrderId", OleDbType.Integer,4,model.OrderId),
243                            Database.MakeInParam("@PaymentId", OleDbType.Integer,4,model.PaymentId),
244                            Database.MakeInParam("@Remark", OleDbType.VarWChar,255,model.Remark),
245                            Database.MakeInParam("@LogTime", OleDbType.Date,8,model.LogTime),
246                            Database.MakeInParam("@Inputer", OleDbType.VarWChar,50,model.Inputer),
247                            Database.MakeInParam("@Ip", OleDbType.VarWChar,50,model.Ip)
248                                                           };
249
250            try
251            ...{
252
253                result = Database.ExecuteNonQuery(sql, prams);
254            }
255            catch (Exception ex)
256            ...{
257                throw ex;
258            }
259