using System;
using System.Collections.Generic;
using System.Data;
using System.Data.OracleClient;
using WX.CRM.Common;

namespace WX.CRM.DAL.Wx
{
    public class WX_BONUSSALEUSER_DAL
    {
        public DataSet GetAchievementWeek(DateTime week)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                        new OracleParameter() { ParameterName = "p_week",  OracleType = OracleType.DateTime, Value = week },
                        new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.AchievementWeek", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataSet GetAchievementMonth(DateTime month)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                          new OracleParameter() { ParameterName = "p_month",  OracleType = OracleType.DateTime, Value = month },
                          new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.AchievementMonth", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataSet GetOrderCountWeek(DateTime week)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                        new OracleParameter() { ParameterName = "p_week",  OracleType = OracleType.DateTime, Value = week },
                        new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.OrderCountWeek", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataSet GetOrderCountMonth(DateTime month)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                          new OracleParameter() { ParameterName = "p_month",  OracleType = OracleType.DateTime, Value = month },
                          new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.OrderCountMonth", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataSet GetOrderPayMax(DateTime month)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                          new OracleParameter() { ParameterName = "p_month",  OracleType = OracleType.DateTime, Value = month },
                          new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.OrderPayMax", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataSet GetNewEntryOpenOrder()
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                          new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.NewEntryOpenOrder", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataSet GetGrouperBonusWeek(DateTime week)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p = new List<OracleParameter>()
                    {
                        new OracleParameter() { ParameterName = "p_week",  OracleType = OracleType.DateTime, Value = week },
                        new OracleParameter() { ParameterName = "p_list", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.GrouperBonusWeek", p.ToArray());
                    trans.Commit();
                    return ds;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public void SaveBonusSaleUser(decimal saveType, DateTime monthWeek, decimal operatorid, string operatorname)
        {
            try
            {
                var p = new List<OracleParameter>()
                {
                    new OracleParameter() {ParameterName = "p_savetype", OracleType = OracleType.Number, Value = saveType},
                    new OracleParameter() {ParameterName = "p_monthweek", OracleType = OracleType.DateTime, Value = monthWeek},
                    new OracleParameter() {ParameterName = "p_operatorid", OracleType = OracleType.Number, Value = operatorid},
                    new OracleParameter() {ParameterName = "p_operatorname", OracleType = OracleType.NVarChar, Value = operatorname}
                };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WX_SETTLEMENT.SaveBonusSaleUser", p.ToArray());
            }
            catch (Exception ex)
            {
                LogHelper.Error("SaveBonusSaleUser:" + ex.ToString());
                throw;
            }
        }
    }
}