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