using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using Model;

namespace DAL
{
    /// <summary>
    /// FriendsDAL類(lèi) 
    /// </summary>
    public class FriendsDAL : IDisposable
    {

        public FriendsInfo Select(int id)
        {
            string strSQL = "SELECT * FROM Friends where id="+id;
            FriendsInfo objInfo = new FriendsInfo();

            using (SqlDataReader rdr = SqlHelper.ExecuteReader(SqlHelper.ConnString, CommandType.Text, strSQL, null))
            {
                if (rdr.Read())
                {
                    objInfo.Id = Convert.ToInt32(rdr["Id"]);
                    objInfo.Host =new UsersInfo(Convert.ToInt32(rdr["HostId"]));
                    objInfo.Friend =new UsersInfo( Convert.ToInt32(rdr["FriendId"]));
                }
            }

            return objInfo;
        }

        /// <summary>
        ///   判斷好友是否已經(jīng)添加過(guò)
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public bool IsExists(FriendsInfo entity)
        {
            string strSQL = "SELECT 1 FROM Friends where hostId =" + entity.Host.Id + " and friendId =" + entity.Friend.Id;
            FriendsInfo objInfo = new FriendsInfo();

            using (SqlDataReader rdr = SqlHelper.ExecuteReader(SqlHelper.ConnString, CommandType.Text, strSQL, null))
            {
                if (rdr.HasRows)
                    return true;
            }

            return false;
        }

        public List<FriendsInfo> SelectAll()
        {
            string strSQL = "SELECT * FROM Friends";
            List<FriendsInfo> objItems = new List<FriendsInfo>();

            using (SqlDataReader rdr = SqlHelper.ExecuteReader(SqlHelper.ConnString, CommandType.Text, strSQL, null))
            {
                while (rdr.Read())
                {
                    FriendsInfo objInfo = new FriendsInfo();
                    objInfo.Id = Convert.ToInt32(rdr["Id"]);
                    objInfo.Host = new UsersInfo(Convert.ToInt32(rdr["HostId"]));
                    objInfo.Friend = new UsersInfo(Convert.ToInt32(rdr["FriendId"]));
                    objItems.Add(objInfo);
                }
            }

            return objItems;
        }

        /// <summary>
        /// 獲得用戶的所有好友列表
        /// </summary>
        /// <param name="hostId"></param>
        /// <returns></returns>
        public List<FriendsInfo> GetFriends(int hostId)
        {
            string strSQL = "SELECT * FROM Friends WHERE HostId="+hostId;
            List<FriendsInfo> objItems = new List<FriendsInfo>();
            UsersDAL udal = new UsersDAL();
            using (SqlDataReader rdr = SqlHelper.ExecuteReader(SqlHelper.ConnString, CommandType.Text, strSQL, null))
            {
                while (rdr.Read())
                {
                    FriendsInfo objInfo = new FriendsInfo();
                    objInfo.Id = Convert.ToInt32(rdr["Id"]);
                    objInfo.Host = new UsersInfo(Convert.ToInt32(rdr["HostId"]));
                    objInfo.Friend = udal.Select(Convert.ToInt32(rdr["FriendId"]));
                    objItems.Add(objInfo);
                }
            }

            return objItems;
        }

        /// <summary>
        /// 添加到好友列表
        /// </summary>
        /// <param name="entity"></param>
        public void AddToFriends(FriendsInfo entity)
        {
            if (IsExists(entity))
                throw new Exception(" 您已經(jīng)把對(duì)方加為好友了，不必重復(fù)添加！");

            string strSQL = "INSERT INTO [Friends](HostId,FriendId) VALUES(@HostId,@FriendId)";

            SqlParameter[] pars = new SqlParameter[]{
                    new SqlParameter("@HostId",entity.Host.Id),
                    new SqlParameter("@FriendId",entity.Friend.Id)
            };

            SqlHelper.ExecuteNonQuery(SqlHelper.ConnString, CommandType.Text, strSQL, pars);

        }

        /// <summary>
        ///   刪除好友
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public void DeleteFriend(int hostId,int friendId)
        {
            string strSQL = string.Format("delete Friends where hostId={0} and FriendId={1}",hostId,+ friendId);
            SqlDataReader rdr = SqlHelper.ExecuteReader(SqlHelper.ConnString, CommandType.Text, strSQL, null);
        }



        #region IDisposable 成員
        public void Dispose()
        {
            GC.SuppressFinalize(this);
        }
        #endregion

    }
}