当前文件路径：ClothesShop/OleDbDAL/cart.cs

		            
  1using System;
  2using System.Collections.Generic;
  3using System.Text;
  4using System.Data.OleDb;
  5using ClothesShop.DBUtility;
  6using System.Data;
  7//该源码下载自www.51aspx.com(５１aｓｐｘ．ｃｏｍ)
  8
  9namespace ClothesShop.OleDbDAL
 10...{
 11    public class cart:ClothesShop.IDAL.Icart
 12    ...{
 13        /**//// <summary>
 14        /// 添加到购物车
 15        /// </summary>
 16        /// <param name="product"></param>
 17        /// <param name="count"></param>
 18        /// <param name="checkout"></param>
 19        /// <returns></returns>
 20        public int createcart(int productid,int userid, int count, bool checkout)
 21        ...{
 22            StringBuilder sb = new StringBuilder();
 23            sb.Append("insert into cart (productid,[userid],[count],checkout) ");
 24            sb.Append("values (@productid,@userid,@count,@checkout)");
 25            OleDbParameter[] parem =
 26                                   ...{
 27                                       OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"productid",productid),
 28                                       OleDbHelper.GetParameter("@userid",OleDbType.Integer,4,"[userid]",userid),
 29                                       OleDbHelper.GetParameter("@count",OleDbType.Integer,4,"[count]",count),
 30                                       OleDbHelper.GetParameter("@checkout",OleDbType.Boolean,1,"checkout",checkout)
 31                                   };
 32            return OleDbHelper.ExecuteSql(sb.ToString(), parem);
 33        }
 34
 35        /**//// <summary>
 36        /// 删除一件商品
 37        /// </summary>
 38        /// <param name="cartid"></param>
 39        /// <returns></returns>
 40        public int deletecart(int cartid)
 41        ...{
 42            StringBuilder sb = new StringBuilder();
 43            sb.Append("delete from cart where cartid=@cartid");
 44            OleDbParameter[] param = ...{ OleDbHelper.GetParameter("@cartid", OleDbType.Integer, 4, "cartid", cartid) };
 45            return OleDbHelper.ExecuteSql(sb.ToString(), param);
 46        }
 47
 48        /**//// <summary>
 49        /// 批量删除商品
 50        /// </summary>
 51        /// <param name="cartids"></param>
 52        /// <returns></returns>
 53        public int deltecartlist(int[] cartids)
 54        ...{
 55            List<OleDbParameter []> paramlist = new List<OleDbParameter []>();
 56            List<string> sqls = new List<string>();
 57            for (int i = 0; i < cartids.Length; i++)
 58            ...{
 59                sqls.Add("delete from cart where cartid=@cartid" + i.ToString());
 60                OleDbParameter[] param = ...{ OleDbHelper.GetParameter("@cartid" + i.ToString(), OleDbType.Integer, 4, "cartid", cartids[i]) };
 61                paramlist.Add(param);
 62            }
 63            return OleDbHelper.ExecuteSqls(sqls.ToArray(), paramlist);
 64        }
 65
 66        /**//// <summary>
 67        /// 获得购物列表
 68        /// </summary>
 69        /// <returns></returns>
 70        public DataTable selectcartlist()
 71        ...{
 72            StringBuilder sb = new StringBuilder();
 73            sb.Append("SELECT cart.cartid, cart.[count], cart.checkout,cart.[userid], ");
 74            sb.Append("cart.productid, products.productname, products.recommended, products.specials, products.price, ");
 75            sb.Append("products.userprice, products.specialsprice ");
 76            sb.Append("FROM cart INNER JOIN products ON cart.productid = products.productid where cart.checkout=false");
 77            return OleDbHelper.ExecuteDt(sb.ToString());
 78        }
 79
 80        /**//// <summary>
 81        /// 获得某个用户的购物列表
 82        /// </summary>
 83        /// <param name="userid"></param>
 84        /// <returns></returns>
 85        public DataTable getcartlist(int userid)
 86        ...{
 87            StringBuilder sb = new StringBuilder();
 88            sb.Append("SELECT cart.cartid, cart.[count], cart.checkout, cart.productid, cart.[userid],");
 89            sb.Append("products.productname, products.recommended, products.specials, products.price,");
 90            sb.Append("products.userprice, products.specialsprice ");
 91            sb.Append("FROM cart INNER JOIN products ON cart.productid=products.productid ");
 92            sb.Append("WHERE cart.checkout=false and cart.[userid]=@userid");
 93            OleDbParameter[] param = ...{ OleDbHelper.GetParameter("@userid", OleDbType.Integer, 4, "cart.[userid]", userid) };
 94            return OleDbHelper.ExecuteDt(sb.ToString(),param);
 95        }
 96
 97        /**//// <summary>
 98        /// 修改购物列表的购买数量
 99        /// </summary>
100        /// <param name="cartids"></param>
101        /// <param name="count"></param>
102        /// <returns></returns>
103        public int updatecartlist(int[] cartids, int[] count)
104        ...{
105            List<OleDbParameter[]> paramlist = new List<OleDbParameter[]>();
106            List<string> sqls = new List<string>();
107            for (int i = 0; i < cartids.Length; i++)
108            ...{
109                sqls.Add("update cart set [count]=@count " + i.ToString() + "where cartid=@cartid" + i.ToString());
110                OleDbParameter[] param = 
111                                        ...{
112                                            OleDbHelper.GetParameter("@count" + i.ToString(),OleDbType.Integer,4,"[count]",count[i]),
113                                            OleDbHelper.GetParameter("@cartid" + i.ToString(),OleDbType.Integer,4,"cartid",cartids[i])
114                                        };
115                paramlist.Add(param);
116            }
117
118            return OleDbHelper.ExecuteSqls(sqls.ToArray(), paramlist);
119        }
120
121        public int updatecart(int productid,int userid, int count)
122        ...{
123            StringBuilder sb = new StringBuilder();
124            sb.Append("update cart set [count]=@count where productid=@productid and [userid]=@userid");
125            OleDbParameter[] param = 
126                                    ...{
127                                        OleDbHelper.GetParameter("@count",OleDbType.Integer,4,"[count]",count),
128                                        OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"productid",productid),
129                                        OleDbHelper.GetParameter("@userid",OleDbType.Integer,4,"[userid]",userid)
130                                    };
131            return OleDbHelper.ExecuteSql(sb.ToString(), param);
132        }
133
134        /**//// <summary>
135        /// 商品是否存在购物车里
136        /// </summary>
137        /// <param name="productid"></param>
138        /// <returns></returns>
139        public bool isexitproduct(int productid,int userid)
140        ...{
141            StringBuilder sb = new StringBuilder();
142            sb.Append("select productid from cart where checkout=false and productid=@productid and [userid]=@userid");
143            OleDbParameter[] param = 
144                                    ...{
145                                        OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"productid",productid),
146                                        OleDbHelper.GetParameter("@userid",OleDbType.Integer,4,"[userid]",userid)
147                                    };
148            return OleDbHelper.ExecuteDt(sb.ToString(), param).Rows.Count > 0 ? true : false;
149        }
150
151        /**//// <summary>
152        /// 根据某一购物商品的数量
153        /// </summary>
154        /// <param name="cartid"></param>
155        /// <returns></returns>
156        public int updatecart(int productid,int userid)
157        ...{
158            StringBuilder sb = new StringBuilder();
159            sb.Append("update cart set [count]=[count]+1 where productid=@productid and [userid]=@userid");
160            OleDbParameter[] param = 
161                                    ...{
162                                        OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"productid",productid),
163                                        OleDbHelper.GetParameter("@userid",OleDbType.Integer,4,"[userid]",userid)
164                                    };
165            return OleDbHelper.ExecuteSql(sb.ToString(), param);
166        }
167
168        /**//// <summary>
169        /// 修改商品的购物状态
170        /// </summary>
171        /// <param name="cartid"></param>
172        /// <returns></returns>
173        public int updatestate(int productid,int userid, bool checkout)
174        ...{
175            StringBuilder sb = new StringBuilder();
176            sb.Append("update cart set checkout=@checkout where productid=@productid and [userid]=@userid");
177            OleDbParameter[] param = 
178                                    ...{
179                                         OleDbHelper.GetParameter("@checkout",OleDbType.Boolean,1,"checkout",checkout),
180                                        OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"productid",productid),
181                                        OleDbHelper.GetParameter("@userid",OleDbType.Integer,4,"[userid]",userid)
182                                    };
183            return OleDbHelper.ExecuteSql(sb.ToString(), param);
184        }
185
186        /**//// <summary>
187        /// 购物成功后商品数量减一
188        /// </summary>
189        /// <param name="productid"></param>
190        public void updateproduct(int productid,int num)
191        ...{
192            StringBuilder sb = new StringBuilder();
193            sb.Append("update products set [count]=[count]-" + num + ",sellcount=sellcount +" + num +" where productid=@productid");
194            OleDbParameter[] param = 
195                                    ...{
196                                        OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"productid",productid),
197                                        //OleDbHelper.GetParameter("@num",OleDbType.Integer,num)
198                                    };
199            OleDbHelper.ExecuteSql(sb.ToString(), param);
200        }
201
202        /**//// <summary>
203        /// 获得一条购物纪录
204        /// </summary>
205        /// <param name="productid"></param>
206        /// <returns></returns>
207        public DataRow getonecartbyproductid(int productid)
208        ...{
209            StringBuilder sb = new StringBuilder();
210            sb.Append("SELECT cart.count ,products.productname, products.recommended, products.specials, products.price, products.userprice, products.specialsprice");
211            sb.Append(" FROM cart INNER JOIN products ON cart.productid = products.productid");
212            sb.Append(" WHERE products.productid=@productid");
213            OleDbParameter[] param = 
214                                    ...{
215                                        OleDbHelper.GetParameter("@productid",OleDbType.Integer,4,"products.productid",productid)
216                                    };
217            return OleDbHelper.ExecuteDt(sb.ToString(), param).Rows[0];
218        }
219
220        /**//// <summary>
221        /// 根据商品ID获得一条购物纪录的数量
222        /// </summary>
223        /// <param name="productid"></param>
224        /// <returns></returns>
225        public int getcartnum(int cartid)
226        ...{
227            StringBuilder sb = new StringBuilder();
228            sb.Append("select [count] from cart where cartid=@cartid");
229            OleDbParameter[] param = 
230                                    ...{
231                                        OleDbHelper.GetParameter("@cartid",OleDbType.Integer,4,"cartid",cartid)
232                                    };
233            return int.Parse(OleDbHelper.ExecuteDt(sb.ToString(), param).Rows[0]["count"].ToString());
234        }
235    }
236}
237