ordersaccessor.cs

本系统是基于三层架构和Ajax控件结合的酒店预订系统

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using DBaoBookingManagement.Entity;

namespace DBaoBookingManagement.DataAccess
{
    /// <summary>
    /// 对Orders表进行操作的类
    /// </summary>
    public class OrdersAccessor:DataAccessor
    {
        //根据订单ID查询订单
        public DataTable QueryById(int id)
        {
            string sql = "select * from Orders where OrderId=" + id;
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据订单ID查询订单时出现错误：" + ex.Message);
            }
        }

        //根据会员ID查询订单
        public DataTable QueryByUserId(int userId)
        {
            string sql = "select * from Orders where UserId=" + userId;
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据会员ID查询订单时出现错误：" + ex.Message);
            }
        }

        //根据下订时间查询订单
        public DataTable QueryByOrderTime(DateTime begin,DateTime end)
        {
            string sql = "select * from Orders where OrderTime>='" + begin.ToString() + "' and OrderTime<='" + end.ToString() + "'";
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据下订时间查询订单时出现错误：" + ex.Message);
            }
        }

        //查询所有订单
        public DataTable QueryAll()
        {
            string sql = "select * from Orders";
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("查询所有订单时出现错误：" + ex.Message);
            }
        }

        //根据订单名称查询订单
        public DataTable QueryByNum(string orderName)
        {
            string sql = "select * from Orders where OrderName='" + orderName+"'";
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据订单名称查询订单时出现错误：" + ex.Message);
            }
        }

        //增加订单
        public bool Insert(Orders entity)
        {
            string orderName = entity.OrderName;
            DateTime startTime = entity.StartTime;
            DateTime endTime = entity.EndTime;
            DateTime orderTime = entity.OrderTime;
            double price = entity.Price;
            int roomId = entity.RoomId;
            int userId = entity.UserId;
            string realName = entity.RealName;
            string phoneNum = entity.PhoneNum;
            string sql = "insert into Orders(OrderName,StartTime,EndTime,OrderTime,Price,RoomId,UserId,RealName,PhoneNum)" +
                " values('" +orderName + "','" + startTime + "','" + endTime + "','" + orderTime + "'," + 
                price + "," + roomId + "," + userId + ",'"+realName+"','"+phoneNum+"')";
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("增加订单时出现错误：" + ex.Message);
            }
        }

        //修改订单
        public bool Update(Orders entity)
        {
            int id = entity.OrderId;
            string orderName = entity.OrderName;
            DateTime startTime = entity.StartTime;
            DateTime endTime = entity.EndTime;
            DateTime orderTime = entity.OrderTime;
            double price = entity.Price;
            int roomId = entity.RoomId;
            int userId = entity.UserId;
            string realName = entity.RealName;
            string phoneNum = entity.PhoneNum;
            string sql = "update Orders set OrderName='" + orderName + "',StartTime='" + startTime +
                "',EndTime='" + endTime + "',OrderTime='" + orderTime + "',Price=" + price + ",RoomId=" +
                roomId + ",UserId=" + userId + ",RealName='" + realName + "',PhoneNum='"+
                phoneNum+"' where OrderId=" + id;
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("修改订单时出现错误：" + ex.Message);
            }
        }

        //根据订单ID删除订单
        public bool DeleteById(int id)
        {
            string sql = "delete Orders where OrderId=" + id;
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据订单ID删除订单时出现错误：" + ex.Message);
            }
        }
    }
}