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

namespace WX.CRM.DAL.TS
{
    public class WX_TSADDPICI_DAL
    {
        public DataTable TsaddpicihisByDay(DateTime? beginTime, DateTime? endTime, decimal groupId, decimal deptId)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var parms = new List<OracleParameter>()
                    {
                        beginTime.HasValue ? new OracleParameter() { ParameterName = "p_beginTime", OracleType = OracleType.DateTime, Value = beginTime.Value } : new OracleParameter() { ParameterName = "p_beginTime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                        endTime.HasValue ? new OracleParameter() { ParameterName = "p_endTime", OracleType = OracleType.DateTime, Value = endTime.Value } : new OracleParameter() { ParameterName = "p_endTime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                        new OracleParameter() {ParameterName="p_groupId",OracleType=OracleType.Number,Value=groupId },
                        new OracleParameter() {ParameterName="p_dept",OracleType=OracleType.Number,Value=deptId },
                        new OracleParameter() { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output },
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_TSADDPICI.TsaddpicihisByDay", parms.ToArray());
                    trans.Commit();
                    return ds.Tables[0];
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return null;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataTable GetUserTsaddpicihisByDay(DateTime? beginTime, DateTime? endTime, decimal groupId, decimal? type)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var parms = new List<OracleParameter>()
                    {
                        type.HasValue ? new OracleParameter() { ParameterName = "p_type", OracleType = OracleType.Number, Value = type.Value } : new OracleParameter() { ParameterName = "p_type", OracleType = OracleType.Number, Value = 0 },
                        beginTime.HasValue ? new OracleParameter() { ParameterName = "p_beginTime", OracleType = OracleType.DateTime, Value = beginTime.Value } : new OracleParameter() { ParameterName = "p_beginTime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                        endTime.HasValue ? new OracleParameter() { ParameterName = "p_endTime", OracleType = OracleType.DateTime, Value = endTime.Value } : new OracleParameter() { ParameterName = "p_endTime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                        new OracleParameter() {ParameterName="p_groupId",OracleType=OracleType.Number,Value=groupId },
                        new OracleParameter() { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output },
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_TSADDPICI.GetUserTsaddpicihisByDay", parms.ToArray());
                    trans.Commit();
                    return ds.Tables[0];
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return null;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataTable GetDismissUserList(DateTime? beginTime, DateTime? endTime, decimal groupId, decimal dept)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var parms = new List<OracleParameter>()
                    {
                        beginTime.HasValue ? new OracleParameter() { ParameterName = "p_beginTime", OracleType = OracleType.DateTime, Value = beginTime.Value } : new OracleParameter() { ParameterName = "p_beginTime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                        endTime.HasValue ? new OracleParameter() { ParameterName = "p_endTime", OracleType = OracleType.DateTime, Value = endTime.Value } : new OracleParameter() { ParameterName = "p_endTime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                        new OracleParameter() {ParameterName="p_groupId",OracleType=OracleType.Number,Value=groupId },
                        new OracleParameter() {ParameterName="p_dept",OracleType=OracleType.Number,Value=dept },
                        new OracleParameter() { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output },
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_TSADDPICI.GetDismissUserList", parms.ToArray());
                    trans.Commit();
                    return ds.Tables[0];
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return null;
            }
            finally
            {
                conn.Close();
            }
        }

        public DataTable GetSaleUserList(decimal groupId, decimal deptid)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var parms = new List<OracleParameter>()
                    {
                        new OracleParameter() {ParameterName="p_groupId",OracleType=OracleType.Number,Value=groupId },
                        new OracleParameter() {ParameterName="p_dept",OracleType=OracleType.Number,Value=deptid },
                         new OracleParameter() { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output },
                    };
                    DataSet ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_WX_TSADDPICI.GetSaleUserList", parms.ToArray());
                    trans.Commit();
                    return ds.Tables[0];
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return null;
            }
            finally
            {
                conn.Close();
            }
        }

    }


}