temporderaccessor.cs

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

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

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

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

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

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

        //增加订单
        public bool Insert(TempOrder 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;
            string realName = entity.RealName;
            string phoneNum = entity.PhoneNum;
            string sql = "insert into TempOrder(OrderName,StartTime,EndTime,OrderTime,Price,RoomId,RealName,PhoneNum) values('" +
                orderName + "','" + startTime + "','" + endTime + "','" + orderTime + "'," + price + "," + roomId + ",'" +
                realName+"','"+phoneNum + "')";
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("增加订单时出现错误：" + ex.Message);
            }
        }

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

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