ticketservice.cs

现在需要全国联网销售火车票

using System;
using System.Data;
using System.Data.SqlClient;
using System.Collections.Generic;
using System.Text;
using MyTicketService.Models;

namespace MyTicketService.DAL
{

    public static partial class TicketService
    {
        // 根据车号、出发地、到达地、车票类型得到票信息
        public static Ticket GetTicketsByPlace(string trainNo, string fromPlace, string toPlace, int type)
        {
            string sql = "SELECT * FROM Ticket WHERE TrainNo=@TrainNo and FromPlace = @FromPlace and ToPlace=@ToPlace and Type=@Type";
            try
            {
                SqlParameter[] para = new SqlParameter[]
				{
                    new SqlParameter("@TrainNo", trainNo),
					new SqlParameter("@FromPlace", fromPlace),
					new SqlParameter("@ToPlace", toPlace),
					new SqlParameter("@Type", type)
				};

                SqlDataReader reader = DBHelper.GetReader(sql, para);
                if (reader.Read())
                {
                    Ticket ticket = new Ticket();

                    ticket.TicketId = (int)reader["TicketId"];
                    ticket.TrainNo = (string)reader["TrainNo"];
                    ticket.FromPlace = (string)reader["FromPlace"];
                    ticket.ToPlace = (string)reader["ToPlace"];
                    ticket.UnitPrice = (int)reader["UnitPrice"];
                    ticket.Num = (int)reader["Num"];
                    ticket.Type = (int)reader["Type"];
                    ticket.StartTime = (string)reader["StartTime"];

                    reader.Close();

                    return ticket;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }

        private static IList<Ticket> GetTicketsBySql(string safeSql)
        {
            List<Ticket> list = new List<Ticket>();

            try
            {
                DataTable table = DBHelper.GetDataSet(safeSql);

                foreach (DataRow row in table.Rows)
                {
                    Ticket ticket = new Ticket();

                    ticket.TicketId = (int)row["TicketId"];
                    ticket.TrainNo = (string)row["TrainNo"];
                    ticket.FromPlace = (string)row["FromPlace"];
                    ticket.ToPlace = (string)row["ToPlace"];
                    ticket.UnitPrice = (int)row["UnitPrice"];
                    ticket.Num = (int)row["Num"];
                    ticket.Type = (int)row["Type"];
                    ticket.StartTime = (string)row["StartTime"];

                    list.Add(ticket);
                }

                return list;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }
    }
}