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_TS_QUNWORALIAS_DAL
    {
        /// <summary>
        /// 获取服务微信号
        /// </summary>
        /// <returns></returns>
        public DataTable GetServiceAlias()
        {
            DataTable table = null;
            try
            {
                var para = new List<OracleParameter>();
                para.Add(new OracleParameter() { ParameterName = "v_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output });
                table = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_WX_TSQUN.GetServiceAlias", para.ToArray()).Tables[0];
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex.ToString());
            }
            return table;
        }

        /// <summary>
        /// 获取服务微信号
        /// </summary>
        /// <returns></returns>
        public DataTable GetNeedSend()
        {
            DataTable table = null;
            try
            {
                var para = new List<OracleParameter>();
                para.Add(new OracleParameter() { ParameterName = "v_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output });
                table = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_WX_TSQUN.GetNeedSend", para.ToArray()).Tables[0];
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex.ToString());
            }
            return table;
        }

        public bool UpdatePiciStatus(decimal v_pici, decimal v_status, string v_erro)
        {

            bool resut = false;
            try
            {
                var param1 = new List<OracleParameter>()
                {
                      new OracleParameter() { ParameterName = "v_pici",  OracleType = OracleType.Number, Value =v_pici },
                      new OracleParameter() { ParameterName = "v_status",  OracleType = OracleType.Number, Value =v_status },
                      new OracleParameter() { ParameterName = "v_erro",  OracleType = OracleType.VarChar, Value =v_erro }
                };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WX_TSQUN.UpdatePiciStatus", param1.ToArray());
                resut = true;
            }
            catch (Exception ex)
            {
                LogHelper.Error("UpdatePiciStatus:" + ex.ToString());
            }
            return resut;
        }
        /// <summary>
        /// 上传并修 执行状态
        /// </summary>
        /// <param name="v_pici"></param>
        /// <param name="v_isStart"></param>
        /// <param name="v_startTime"></param>
        /// <param name="v_isEnd"></param>
        /// <param name="v_endTime"></param>
        /// <param name="errors"></param>
        /// <returns></returns>
        public bool UpdatePiciExecStatus(long v_pici, int? v_isStart, DateTime? v_startTime, int? v_isEnd, DateTime? v_endTime, string v_erromsg, ref ValidationErrors errors)
        {
            bool resut = false;
            try
            {
                var param1 = new List<OracleParameter>()
                {
                      new OracleParameter() { ParameterName = "v_pici",  OracleType = OracleType.Number, Value =v_pici },
                      new OracleParameter() { ParameterName = "v_isStart",  OracleType = OracleType.Number, Value =v_isStart },
                      new OracleParameter() { ParameterName = "v_startTime",  OracleType = OracleType.DateTime, Value =v_startTime },
                      new OracleParameter() { ParameterName = "v_isEnd",  OracleType = OracleType.Number, Value =v_isEnd },
                      new OracleParameter() { ParameterName = "v_endTime",  OracleType = OracleType.DateTime, Value =v_endTime },
                      string.IsNullOrEmpty(v_erromsg)?new OracleParameter() { ParameterName = "v_erromsg",  OracleType = OracleType.VarChar, Value =DBNull.Value }:
                      new OracleParameter() { ParameterName = "v_erromsg",  OracleType = OracleType.VarChar, Value =v_erromsg }
                };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WX_TSQUN.UpdatePiciExecStatus", param1.ToArray());
                resut = true;
            }
            catch (Exception ex)
            {
                errors.Add(ex.ToString());
                LogHelper.Error("UpdatePiciExecStatus:" + ex.ToString());
            }
            return resut;
        }
    }
}