using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CY.IDAL;
using System.Data.SqlClient;
using System.Data;
using CY.Infrastructure.Query;

namespace CY.SQLDAL
{
    public class OA_WarehouseInfoDAL : IOA_WarehouseInfoDAL
    {

        private Database _dataBase = null;

        public OA_WarehouseInfoDAL()
        {
            _dataBase = new Database();
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_WarehouseInfo trueModel = model as Model.OA_WarehouseInfo;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@FirmId",trueModel.FirmId),
					new SqlParameter("@WarehouseName",trueModel.WarehouseName),
					new SqlParameter("@WarehouseAddress",trueModel.WarehouseAddress),
					new SqlParameter("@Phone",trueModel.Phone),
					new SqlParameter("@QQ",trueModel.QQ),
					new SqlParameter("@WarehouseKeeper",trueModel.WarehouseKeeper),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Operator",trueModel.Operator),
					new SqlParameter("@Remark",trueModel.Remark) 
                    ,new SqlParameter("@OrderNum",trueModel.OrderNum)
                     ,new SqlParameter("@WarehouserNumber",trueModel.WarehouserNumber)
            };
            try
            {
                _dataBase.Query("sp_OA_WarehouseInfo_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_WarehouseInfo trueModel = model as Model.OA_WarehouseInfo;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {	new SqlParameter("@Keyid",trueModel.Keyid),
                new SqlParameter("@FirmId",trueModel.FirmId),
					new SqlParameter("@WarehouseName",trueModel.WarehouseName),
					new SqlParameter("@WarehouseAddress",trueModel.WarehouseAddress),
					new SqlParameter("@Phone",trueModel.Phone),
					new SqlParameter("@QQ",trueModel.QQ),
					new SqlParameter("@WarehouseKeeper",trueModel.WarehouseKeeper),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Operator",trueModel.Operator),
					new SqlParameter("@Remark",trueModel.Remark) 
                    ,new SqlParameter("@OrderNum",trueModel.OrderNum)
                            ,new SqlParameter("@WarehouserNumber",trueModel.WarehouserNumber)
            };
            try
            {
                _dataBase.Query("sp_OA_WarehouseInfo_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_WarehouseInfo trueModel = model as Model.OA_WarehouseInfo;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_OA_WarehouseInfo_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="query"></param>
        /// <param name="pagination"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_WarehouseInfo> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

        public IEnumerable<Model.OA_WarehouseInfo> getAllModel(Pagination pa, Guid FirmId, string WarehouseName, string WarehouserNumber)
        {
            string Condition = "  where FirmId='" + FirmId + "'";
            if (!string.IsNullOrEmpty(WarehouseName))
            {

                Condition += "and  WarehouseName like '%" + WarehouseName + "%'";
            }
            if (!string.IsNullOrEmpty(WarehouserNumber))
            {

                Condition += "and  WarehouserNumber like '%" + WarehouserNumber + "%'";
            }
            string selectTarget = " * ";
            string fromSource = " OA_WarehouseInfo " + Condition;
            return _dataBase.SelectModelPage<Model.OA_WarehouseInfo>(pa, selectTarget, fromSource, " OrderNum ");
        }

        public IEnumerable<Model.OA_WarehouseInfo> getAllWarehouseInfo(Guid FirmId)
        {
            string Condition = "  where FirmId='" + FirmId + "'";
            string selectTarget = " * ";
            string fromSource = " OA_WarehouseInfo " + Condition;
            return _dataBase.SelectModel<Model.OA_WarehouseInfo>(selectTarget, fromSource);
        }

        /// <summary>
        /// 单个查询
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_WarehouseInfo> SelectAllModel(Infrastructure.Query.Query query)
        {
            throw new NotImplementedException();
        }

        public Model.OA_WarehouseInfo getSingleModel(string Keyid)
        {
            if (_dataBase.SelectModel<Model.OA_WarehouseInfo>(" * ", " OA_WarehouseInfo ", " Keyid='" + Keyid + "' ").Count > 0)
            {
                return _dataBase.SelectModel<Model.OA_WarehouseInfo>(" * ", " OA_WarehouseInfo ", " Keyid='" + Keyid + "' ")[0];

            }
            else
            {
                return null;
            }

        }

        /// <summary>
        /// 获取最大的仓库编号
        /// </summary>
        /// <param name="FirmId"></param>
        /// <param name="TName"></param>
        /// <returns></returns>
        public string GetMaxWarehouserNumber(Guid FirmId, string TName)
        {

            string selTarget = " MAX(WarehouserNumber) ";
            string fromSource = TName + " where  FirmId= '" + FirmId + "'";
            DataTable dt = _dataBase.SelectModel(selTarget, fromSource);
            if (dt.Rows.Count > 0)
            {
                if (string.IsNullOrEmpty(dt.Rows[0][0].ToString()))
                {
                    return "0";
                }
                else
                    return (Convert.ToInt32(dt.Rows[0][0]) + 1).ToString();
            }
            else
            {

                return "0";
            }

        }
    }
}