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

namespace WX.CRM.DAL.Res
{
    public class RES_DISTRIBUTE_DAL
    {
        public void DistbuteDataQueryAndInsert(decimal resTypeId, decimal ActivityId, DateTime? stime, DateTime? etime, decimal userId, int hasRole, ref int count, ref decimal importId)
        {
            var conn = new OracleConnection(OracleHelper.AYCRMConn);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            try
            {
                using (var trans = conn.BeginTransaction())
                {
                    var p2 = new List<OracleParameter>
                    {
                        new OracleParameter() {ParameterName = "p_sd1", OracleType = OracleType.DateTime, Value =stime},
                        new OracleParameter() {ParameterName = "p_sd2", OracleType = OracleType.DateTime, Value = etime},
                        //new OracleParameter() {ParameterName = "p_Memotime1", OracleType = OracleType.DateTime, Value =Memostime},
                        //new OracleParameter() {ParameterName = "p_Memotime2", OracleType = OracleType.DateTime, Value = Memoetime},
                        new OracleParameter(){ ParameterName = "p_restypeId",OracleType = OracleType.Number,Value = resTypeId},
                        new OracleParameter(){ ParameterName = "p_activityId",OracleType = OracleType.Number,Value = ActivityId},
                        new OracleParameter(){ ParameterName = "p_userId", OracleType = OracleType.Number, Value = userId},
                        new OracleParameter(){ ParameterName = "p_hasRole", OracleType = OracleType.Number, Value = hasRole },

                        //saleDeptId.HasValue
                        //? new OracleParameter(){ ParameterName = "p_saleDeptId", OracleType = OracleType.Number, Value = saleDeptId.Value }
                        //: new OracleParameter(){ ParameterName = "p_saleDeptId", OracleType = OracleType.Number, Value = DBNull.Value },

                        //string.IsNullOrEmpty(choices)
                        //? new OracleParameter() { ParameterName = "p_choices", OracleType = OracleType.VarChar, Value = DBNull.Value }
                        //: new OracleParameter() { ParameterName = "p_choices", OracleType = OracleType.VarChar, Value = choices },

                         //new OracleParameter() { ParameterName = "p_excludeWeixinRes", OracleType = OracleType.VarChar, Value = excludeWeixinRes },
                         //new OracleParameter() { ParameterName = "p_excludeOrderRes", OracleType = OracleType.VarChar, Value = excludeOrderRes },
                         //new OracleParameter() { ParameterName = "p_excludeSpecialMemo", OracleType = OracleType.VarChar, Value = excludeSpecialMemo },
                         //new OracleParameter() { ParameterName = "p_excludeAddWeixin", OracleType = OracleType.VarChar, Value = excludeAddWeixin },
                         //new OracleParameter() { ParameterName = "p_excludeForbidCall", OracleType = OracleType.VarChar, Value = excludeForbidCall },
                         //new OracleParameter() { ParameterName = "p_excludeEmptyNum", OracleType = OracleType.VarChar, Value = excludeEmptyNum },

                        new OracleParameter() { ParameterName = "p_rowCount", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output },
                        new OracleParameter() { ParameterName = "p_importid", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output }
                    };
                    var ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.Res_distributeQueryAndInsert", p2.ToArray());
                    trans.Commit();
                    if (ds.Tables[0].Rows.Count > 0 && null != ds)
                        count = Convert.ToInt32(ds.Tables[0].Rows[0][0]);
                    if (ds.Tables[1].Rows.Count > 0 && null != ds)
                        importId = Convert.ToDecimal(ds.Tables[1].Rows[0][0]);
                }
            }
            catch (Exception ex)
            {
                throw;
            }
            finally
            {
                conn.Close();
            }
        }

        public void UpdateAllocate(decimal v_pkid, decimal v_UserId)
        {
            try
            {
                var p2 = new List<OracleParameter>
                    {
                        new OracleParameter() {ParameterName = "v_pkid", OracleType = OracleType.Number, Value =v_pkid},
                        new OracleParameter() {ParameterName = "v_UserId", OracleType = OracleType.Number, Value = v_UserId}
                    };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_RES_ALLOCATE.UpdateAllocate", p2.ToArray());
            }
            catch (Exception ex) { LogHelper.Error(ex.ToString()); }
        }
        public void UpdateAllocate2(decimal v_pkid, decimal v_UserId, decimal fenpeiUserId)
        {
            try
            {
                var p2 = new List<OracleParameter>
                    {
                        new OracleParameter() {ParameterName = "v_pkid", OracleType = OracleType.Number, Value =v_pkid},
                        new OracleParameter() {ParameterName = "v_UserId", OracleType = OracleType.Number, Value = v_UserId},
                        new OracleParameter() {ParameterName = "v_fenpeiUserId", OracleType = OracleType.Number, Value = fenpeiUserId}
                    };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_RES_ALLOCATE.UpdateAllocateAndFPR", p2.ToArray());
            }
            catch (Exception ex) { LogHelper.Error(ex.ToString()); }
        }

        public void UpdateCategory()
        {
            try
            {
                var p2 = new List<OracleParameter> { };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_RES_ALLOCATE.UpdateCategoryFPR", p2.ToArray());
            }
            catch (Exception ex) { LogHelper.Error(ex.ToString()); }
        }

        public void UpdateDistributeRes()
        {
            try
            {
                var p2 = new List<OracleParameter> { };
                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_RES_ALLOCATE.UpdateCategoryFPR", p2.ToArray());
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex.ToString());
                throw;
            }
        }

        public void UpdateCacheResCountActiveFlag(string resId, DateTime lastActiveTime)
        {
            try
            {
                var sql = "update cache_res_resource_count set hasactive=1,lastactivetime = :lastactivetime where resid = :resid";
                var p = new List<OracleParameter>
                {
                    new OracleParameter() {ParameterName="lastactivetime",OracleType = OracleType.DateTime,Value = lastActiveTime},
                    new OracleParameter() {ParameterName="resid",OracleType= OracleType.Char,Value=resId }
                };
                OracleHelper.ExecuteNonQuery(CommandType.Text, sql, p.ToArray());
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }
        }

        public void UpdateCacheResCountLastCallTime(string resId, DateTime lastCallTime)
        {
            try
            {
                var sql = "update cache_res_resource_count set LASTCALLTIME = :LASTCALLTIME where resid = :resid";
                var p = new List<OracleParameter>
                {
                    new OracleParameter() {ParameterName="LASTCALLTIME",OracleType = OracleType.DateTime,Value = lastCallTime},
                    new OracleParameter() {ParameterName="resid",OracleType= OracleType.Char,Value=resId }
                };
                OracleHelper.ExecuteNonQuery(CommandType.Text, sql, p.ToArray());
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }
        }

        public DataSet Res_DistributeCount(DateTime sTime, DateTime eTime)
        {
            try
            {
                List<OracleParameter> p = new List<OracleParameter>()
                {
                    new OracleParameter {ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = sTime},
                    new OracleParameter {ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = eTime},
                    new OracleParameter {ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output}
                };
                var ds = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.Res_DistributeCount", p.ToArray());
                return ds;
            }
            catch
            {
                throw;
            }
        }

        public DataSet Res_DistributeUnCount(DateTime sTime, DateTime eTime, decimal saleid)
        {
            try
            {
                List<OracleParameter> p = new List<OracleParameter>()
                {
                    new OracleParameter {ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = sTime},
                    new OracleParameter {ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = eTime},
                    new OracleParameter {ParameterName = "p_salesid", OracleType = OracleType.Number, Value = saleid},
                    new OracleParameter {ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output}
                };
                var ds = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.Res_DistributeUnCount", p.ToArray());
                return ds;
            }
            catch
            {
                throw;
            }
        }

        public DataSet GetDistbuteRes(ref Pager pg, string resid, decimal? inneruserid, string groupId, string resourcetag, decimal resourcetypeid)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    new OracleParameter {ParameterName = "p_ResourceTypeId", OracleType = OracleType.Number, Value = resourcetypeid},
                    new OracleParameter {ParameterName = "p_ResourceTag", OracleType = OracleType.VarChar, Value = resourcetag},
                    string.IsNullOrEmpty(resid) ?new OracleParameter(){ ParameterName = "p_ResId",OracleType = OracleType.VarChar,Value = DBNull.Value} :new OracleParameter(){ ParameterName = "p_ResId",OracleType = OracleType.VarChar,Value = resid},
                    string.IsNullOrEmpty(groupId) ?new OracleParameter {ParameterName = "p_GroupId", OracleType = OracleType.VarChar, Value = DBNull.Value} :new OracleParameter {ParameterName = "p_GroupId", OracleType = OracleType.VarChar, Value = groupId},
                    inneruserid.HasValue ?new OracleParameter {ParameterName = "p_UserId", OracleType = OracleType.Number, Value = inneruserid} :new OracleParameter {ParameterName = "p_UserId", OracleType = OracleType.Number, Value = DBNull.Value},
                    new OracleParameter {ParameterName = "p_pageIndex", OracleType = OracleType.Number, Value = pg.page},
                    new OracleParameter {ParameterName = "p_pageSize", OracleType = OracleType.Number, Value = pg.rows},
                    new OracleParameter {ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output},
                };

                return OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.GetDistbuteRes", p.ToArray());
            }
            catch (Exception ex)
            {
                throw;
            }
        }

        public DataSet GetDistbuteResCount(ref Pager pg, decimal? inneruserid, string groupId, DateTime? sTime, DateTime? eTime, decimal? resourcetypeid, decimal? resourceactivityid, decimal? hasNum = null, decimal? hasOrder = null, decimal? hasRecord = null, decimal? hasMemo = null)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    resourcetypeid.HasValue ? new OracleParameter { ParameterName = "p_ResourceTypeId", OracleType = OracleType.Number, Value = resourcetypeid } : new OracleParameter { ParameterName = "p_ResourceTypeId", OracleType = OracleType.Number, Value = DBNull.Value},
                    resourceactivityid.HasValue ? new OracleParameter { ParameterName = "p_ResourceActivityId", OracleType = OracleType.Number, Value = resourceactivityid } : new OracleParameter { ParameterName = "p_ResourceActivityId", OracleType = OracleType.Number, Value = DBNull.Value },
                    string.IsNullOrEmpty(groupId) ? new OracleParameter { ParameterName = "p_GroupId", OracleType = OracleType.VarChar, Value = DBNull.Value} : new OracleParameter { ParameterName = "p_GroupId", OracleType = OracleType.VarChar, Value = groupId },
                    inneruserid.HasValue ? new OracleParameter { ParameterName = "p_UserId", OracleType = OracleType.Number, Value = inneruserid } :new OracleParameter { ParameterName = "p_UserId", OracleType = OracleType.Number, Value = DBNull.Value},
                    sTime.HasValue ? new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = sTime } : new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                    eTime.HasValue ? new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = eTime } : new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                    hasNum.HasValue ? new OracleParameter { ParameterName = "p_hasNum", OracleType = OracleType.Number, Value = hasNum.Value } : new OracleParameter { ParameterName = "p_hasNum", OracleType = OracleType.Number, Value = DBNull.Value },
                    hasOrder.HasValue ? new OracleParameter { ParameterName = "p_hasOrder", OracleType = OracleType.Number, Value = hasOrder.Value } : new OracleParameter { ParameterName = "p_hasOrder", OracleType = OracleType.Number, Value = DBNull.Value },
                    hasRecord.HasValue ? new OracleParameter { ParameterName = "p_hasRecord", OracleType = OracleType.Number, Value = hasRecord.Value } : new OracleParameter { ParameterName = "p_hasRecord", OracleType = OracleType.Number, Value = DBNull.Value },
                    hasMemo.HasValue ? new OracleParameter { ParameterName = "p_hasMemo", OracleType = OracleType.Number, Value = hasMemo.Value } : new OracleParameter { ParameterName = "p_hasMemo", OracleType = OracleType.Number, Value = DBNull.Value },
                    new OracleParameter { ParameterName = "p_pageIndex", OracleType = OracleType.Number, Value = pg.page },
                    new OracleParameter { ParameterName = "p_pageSize", OracleType = OracleType.Number, Value = pg.rows },
                    new OracleParameter { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output },
                };

                return OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.GetDistbuteResCount", p.ToArray());
            }
            catch (Exception ex)
            {
                throw;
            }
        }

        public void ExecDistbuteRecycle(decimal? inneruserid, string groupId, DateTime? sTime, DateTime? eTime, decimal? resourcetypeid, decimal? resourceactivityid, decimal? hasNum = null, decimal? hasOrder = null, decimal? hasRecord = null, decimal? hasMemo = null, decimal? tranResTypeId = null, decimal? tranResActivityId = null, string tranResTag = null, decimal? tranCompanyId = null, decimal? num = null)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    resourcetypeid.HasValue ? new OracleParameter { ParameterName = "p_ResourceTypeId", OracleType = OracleType.Number, Value = resourcetypeid } : new OracleParameter { ParameterName = "p_ResourceTypeId", OracleType = OracleType.Number, Value = DBNull.Value},
                    resourceactivityid.HasValue ? new OracleParameter { ParameterName = "p_ResourceActivityId", OracleType = OracleType.Number, Value = resourceactivityid } : new OracleParameter { ParameterName = "p_ResourceActivityId", OracleType = OracleType.Number, Value = DBNull.Value },
                    string.IsNullOrEmpty(groupId) ? new OracleParameter { ParameterName = "p_GroupId", OracleType = OracleType.VarChar, Value = DBNull.Value} : new OracleParameter { ParameterName = "p_GroupId", OracleType = OracleType.VarChar, Value = groupId },
                    inneruserid.HasValue ? new OracleParameter { ParameterName = "p_UserId", OracleType = OracleType.Number, Value = inneruserid } :new OracleParameter { ParameterName = "p_UserId", OracleType = OracleType.Number, Value = DBNull.Value},
                    sTime.HasValue ? new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = sTime } : new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                    eTime.HasValue ? new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = eTime } : new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = DBNull.Value },
                    hasNum.HasValue ? new OracleParameter { ParameterName = "p_hasNum", OracleType = OracleType.Number, Value = hasNum.Value } : new OracleParameter { ParameterName = "p_hasNum", OracleType = OracleType.Number, Value = DBNull.Value },
                    hasOrder.HasValue ? new OracleParameter { ParameterName = "p_hasOrder", OracleType = OracleType.Number, Value = hasOrder.Value } : new OracleParameter { ParameterName = "p_hasOrder", OracleType = OracleType.Number, Value = DBNull.Value },
                    hasRecord.HasValue ? new OracleParameter { ParameterName = "p_hasRecord", OracleType = OracleType.Number, Value = hasRecord.Value } : new OracleParameter { ParameterName = "p_hasRecord", OracleType = OracleType.Number, Value = DBNull.Value },
                    hasMemo.HasValue ? new OracleParameter { ParameterName = "p_hasMemo", OracleType = OracleType.Number, Value = hasMemo.Value } : new OracleParameter { ParameterName = "p_hasMemo", OracleType = OracleType.Number, Value = DBNull.Value },
                    tranResTypeId.HasValue ? new OracleParameter { ParameterName = "p_tranResTypeId", OracleType = OracleType.Number, Value = tranResTypeId.Value } : new OracleParameter { ParameterName = "p_tranResTypeId", OracleType = OracleType.Number, Value = DBNull.Value },
                    tranResActivityId.HasValue ? new OracleParameter { ParameterName = "p_tranResActivityId", OracleType = OracleType.Number, Value = tranResActivityId.Value } : new OracleParameter { ParameterName = "p_tranResActivityId", OracleType = OracleType.Number, Value = DBNull.Value },
                    string.IsNullOrEmpty(tranResTag) ? new OracleParameter { ParameterName = "p_tranResTag", OracleType = OracleType.VarChar, Value = DBNull.Value } : new OracleParameter{ ParameterName = "p_tranResTag", OracleType = OracleType.VarChar, Value = tranResTag },
                    tranCompanyId.HasValue ? new OracleParameter { ParameterName = "p_tranCompanyId", OracleType = OracleType.Number, Value = tranCompanyId.Value } : new OracleParameter { ParameterName = "p_tranCompanyId", OracleType = OracleType.Number, Value = DBNull.Value },
                    num.HasValue ? new OracleParameter { ParameterName = "p_num", OracleType = OracleType.Number, Value = num.Value } : new OracleParameter { ParameterName = "p_num", OracleType = OracleType.Number, Value = DBNull.Value },
                };

                OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.ExecDistbuteRecycle", p.ToArray());
            }
            catch (Exception ex)
            {
                throw;
            }
        }

        public void UpdateHFStatus(string resId,int status)
        {
            try
            {
                var sql = @"UPDATE CSVR_CALLRECORDUN SET ISHF = :V_Status WHERE ISHF != 1 AND RESID IN
                    (
                        SELECT B.RESID FROM RES_CUSTOMER A
                        LEFT JOIN RES_CUSTOMER B ON A.CUSTOMERID = B.CUSTOMERID
                        WHERE A.RESID =  :resid
                    )";
                var p = new List<OracleParameter>
                {
                    new OracleParameter() {ParameterName="V_Status",OracleType= OracleType.Int32,Value=status },
                    new OracleParameter() {ParameterName="resid",OracleType= OracleType.Char,Value=resId }
                };
                OracleHelper.ExecuteNonQuery(CommandType.Text, sql, p.ToArray());
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }
        }

        public int GetRegisterResouceNotice()
        {
            var p = new List<OracleParameter>
            {
                new OracleParameter { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output }
            };

            return Convert.ToInt32(OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.GetRegisterResouceNotice", p.ToArray()).Tables[0].Rows[0][0]);
        }

        public DataSet GetDistbuteHisCount(DateTime? stime, DateTime? etime, string deptId, string groupId, string innerUserId)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    new OracleParameter {ParameterName = "v_stime", OracleType = OracleType.DateTime, Value = stime},
                    new OracleParameter {ParameterName = "v_etime", OracleType = OracleType.DateTime, Value = etime},
                    new OracleParameter { ParameterName = "v_deptId", OracleType = OracleType.VarChar, Value = deptId },
                    new OracleParameter { ParameterName = "v_groupId", OracleType = OracleType.VarChar, Value = groupId },
                    new OracleParameter { ParameterName = "v_userId", OracleType = OracleType.VarChar, Value = innerUserId },
                    new OracleParameter
                    {
                            ParameterName = "v_sqldata",
                            OracleType = OracleType.Cursor,
                            Direction = ParameterDirection.Output
                    }
                };

                return OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE.Res_DistributeHisCount", p.ToArray());
            }
            catch (Exception ex)
            {
                throw;
            }
        }

        public DataSet GetResDistributeHisEffect(string pici, decimal? restypeid, DateTime? stime, DateTime? etime)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    string.IsNullOrEmpty(pici) ? new OracleParameter { ParameterName = "p_pici", OracleType = OracleType.VarChar, Value = DBNull.Value } : new OracleParameter { ParameterName = "p_pici", OracleType = OracleType.VarChar, Value = pici },
                    restypeid.HasValue ? new OracleParameter { ParameterName = "p_restypeid", OracleType = OracleType.Number, Value = restypeid } : new OracleParameter { ParameterName = "p_restypeid", OracleType = OracleType.Number, Value = DBNull.Value },
                    stime.HasValue ? new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = stime.Value} : new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = DBNull.Value},
                    etime.HasValue ? new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = etime.Value} : new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = DBNull.Value},
                    new OracleParameter { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output }
                };

                return OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE_EFFECT.Proc_Res_DistributeHis_Effect", p.ToArray());
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        public DataSet GetResAllcoteLogEffect(string groupId, decimal? userId, decimal? restypeid, DateTime? stime, DateTime? etime)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    string.IsNullOrEmpty(groupId) ? new OracleParameter { ParameterName = "p_groupId", OracleType = OracleType.VarChar, Value = DBNull.Value } : new OracleParameter { ParameterName = "p_groupId", OracleType = OracleType.VarChar, Value = groupId },
                    userId.HasValue ? new OracleParameter { ParameterName = "p_userId", OracleType = OracleType.Number, Value = userId } : new OracleParameter { ParameterName = "p_userId", OracleType = OracleType.Number, Value = DBNull.Value },
                    restypeid.HasValue ? new OracleParameter { ParameterName = "p_restypeid", OracleType = OracleType.Number, Value = restypeid } : new OracleParameter { ParameterName = "p_restypeid", OracleType = OracleType.Number, Value = DBNull.Value },
                    stime.HasValue ? new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = stime.Value} : new OracleParameter { ParameterName = "p_stime", OracleType = OracleType.DateTime, Value = DBNull.Value},
                    etime.HasValue ? new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = etime.Value} : new OracleParameter { ParameterName = "p_etime", OracleType = OracleType.DateTime, Value = DBNull.Value},
                    new OracleParameter { ParameterName = "p_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output }
                };

                return OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_DISTRIBUTE_EFFECT.Proc_Res_AllcoteLog_Effect", p.ToArray());
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        public string Bei3Allocate(string resId, decimal eid, decimal resTypeId, string resTag)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    new OracleParameter{ ParameterName = "v_resId", OracleType = OracleType.VarChar, Value = resId },
                    new OracleParameter{ ParameterName = "v_eid", OracleType = OracleType.Number, Value = eid },
                    new OracleParameter{ ParameterName = "v_resTypeId", OracleType = OracleType.Number, Value = resTypeId },
                    new OracleParameter{ ParameterName = "v_resTag", OracleType = OracleType.VarChar, Value = resTag },
                    new OracleParameter{ ParameterName = "v_msg", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output},
                };

                var ds = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_ALLOCATE.Bei3Allocate", p.ToArray());
                return string.Format("{0}", ds.Tables[0].Rows[0][0]);
            }
            catch (Exception ex)
            {
                throw;
            }
        }

        public string GiveUp(string resId, decimal userId)
        {
            try
            {
                var p = new List<OracleParameter>
                {
                    new OracleParameter{ ParameterName = "v_resId", OracleType = OracleType.VarChar, Value = resId },
                    new OracleParameter{ ParameterName = "v_userId", OracleType = OracleType.Number, Value = userId },
                    new OracleParameter {ParameterName = "v_msg", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output},
                };

                var ds = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_RES_ALLOCATE.GiveUp", p.ToArray());
                return string.Format("{0}", ds.Tables[0].Rows[0][0]);
            }
            catch (Exception ex)
            {
                throw;
            }
        }

    }
}