using System;
using System.Data;
using System.Text;
using WMS.Model.Base;
using WMS.IData.ISystemManage;
using WMS.IData;using Oracle.ManagedDataAccess.Client;
using WMS.Common;
using WMS.DBUtility;
using WMS.Model.SystemManage;
using Oracle.ManagedDataAccess.Client;

namespace WMS.SqlServerData.SystemManageData
{
	/// <summary>
	/// 数据访问类:T_SYS_SCHEDULING
	/// </summary>
    public partial class SchedulingData : IScheduling
	{
		#region  BasicMethod
		/// <summary>
		/// 增加一条数据
		/// </summary>
		public void Add(SchedulingModel model)
		{
			StringBuilder strSql=new StringBuilder();
			strSql.Append("insert into T_SYS_SCHEDULING(");
            strSql.Append("S_DATE,S_USER,S_TYPE,S_STORAGE,STATUS,S_KIND,S_STARTIME,S_ENDTIME,ID,REMARK)");
			strSql.Append(" values (");
            strSql.Append(":S_DATE,:S_USER,:S_TYPE,:S_STORAGE,:STATUS,:S_KIND,:S_STARTIME,:S_ENDTIME,:ID,:REMARK)");
			OracleParameter[] parameters = {
					new OracleParameter(":S_DATE", OracleDbType.Date),
					new OracleParameter(":S_USER",OracleDbType.Varchar2),
					new OracleParameter(":S_TYPE",OracleDbType.Varchar2),
					new OracleParameter(":S_STORAGE",OracleDbType.Varchar2),
					new OracleParameter(":STATUS",OracleDbType.Varchar2),
					new OracleParameter(":S_KIND",OracleDbType.Varchar2),
					new OracleParameter(":S_STARTIME", OracleDbType.Date),
					new OracleParameter(":S_ENDTIME", OracleDbType.Date),
					new OracleParameter(":ID",OracleDbType.Varchar2),
                   new OracleParameter(":ID",OracleDbType.Varchar2)};
			parameters[0].Value = model.S_DATE;
			parameters[1].Value = model.S_USER;
			parameters[2].Value = model.S_TYPE;
			parameters[3].Value = model.S_STORAGE;
			parameters[4].Value = model.STATUS;
			parameters[5].Value = model.S_KIND;
			parameters[6].Value = model.S_STARTIME;
			parameters[7].Value = model.S_ENDTIME;
			parameters[8].Value = model.ID;
            parameters[8].Value = model.REMARK;

            SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
		}
		/// <summary>
		/// 更新一条数据
		/// </summary>
		public void Update(SchedulingModel model)
		{
			StringBuilder strSql=new StringBuilder();
			strSql.Append("update T_SYS_SCHEDULING set ");
			strSql.Append("S_DATE=:S_DATE,");
			strSql.Append("S_USER=:S_USER,");
			strSql.Append("S_TYPE=:S_TYPE,");
			strSql.Append("S_STORAGE=:S_STORAGE,");
			strSql.Append("STATUS=:STATUS,");
			strSql.Append("S_KIND=:S_KIND,");
			strSql.Append("S_STARTIME=:S_STARTIME,");
			strSql.Append("S_ENDTIME=:S_ENDTIME,");
            strSql.Append("REMARK=:REMARK");
			strSql.Append(" where ");
            strSql.Append("ID=:ID");
			OracleParameter[] parameters = {
					new OracleParameter(":S_DATE", OracleDbType.Date),
					new OracleParameter(":S_USER",OracleDbType.Varchar2),
					new OracleParameter(":S_TYPE",OracleDbType.Varchar2),
					new OracleParameter(":S_STORAGE",OracleDbType.Varchar2),
					new OracleParameter(":STATUS",OracleDbType.Varchar2),
					new OracleParameter(":S_KIND",OracleDbType.Varchar2),
					new OracleParameter(":S_STARTIME", OracleDbType.Date),
					new OracleParameter(":S_ENDTIME", OracleDbType.Date),
                   new OracleParameter(":REMARK",OracleDbType.Varchar2),
					new OracleParameter(":ID",OracleDbType.Varchar2)};
			parameters[0].Value = model.S_DATE;
			parameters[1].Value = model.S_USER;
			parameters[2].Value = model.S_TYPE;
			parameters[3].Value = model.S_STORAGE;
			parameters[4].Value = model.STATUS;
			parameters[5].Value = model.S_KIND;
			parameters[6].Value = model.S_STARTIME;
			parameters[7].Value = model.S_ENDTIME;
			parameters[8].Value = model.REMARK;
            parameters[9].Value = model.ID;

            SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
		}

		/// <summary>
		/// 删除一条数据
		/// </summary>
        public void Delete(SchedulingModel model)
		{
			//该表无主键信息，请自定义主键/条件字段
			StringBuilder strSql=new StringBuilder();
			strSql.Append("delete from T_SYS_SCHEDULING ");
            strSql.Append(" where 1=1 ");
            if (!string.IsNullOrEmpty(model.S_USER))
            {
                strSql.Append(" and  t.S_USER ='" + model.S_USER + "'");
            }
            if (!string.IsNullOrEmpty(model.S_STORAGE))
            {
                strSql.Append(" and  t.S_STORAGE = '" + model.S_STORAGE + "'");
            }
			OracleParameter[] parameters = {
			};

            SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
		}
		/// <summary>
		/// 获得数据列表
		/// </summary>
        public DataTable GetList(SchedulingModel model)
		{
			StringBuilder strSql=new StringBuilder();
            strSql.Append("select t.S_DATE,");
            strSql.Append("t.S_USER,");
            strSql.Append("b.NAME as S_USER_NAME,");
            strSql.Append("t.S_TYPE,");
            strSql.Append("a.WORK_NAME S_TYPE_NAME,");
            strSql.Append("t.S_STORAGE,");
            strSql.Append("c.STORAGE_NAME S_STORAGE_NAME,");
            strSql.Append("t.STATUS,");
            strSql.Append("t.S_KIND,");
            strSql.Append("t.S_STARTIME,");
            strSql.Append("t.S_ENDTIME,");
            strSql.Append("t.REMARK,");
            strSql.Append("t.ID ");
			strSql.Append(" FROM T_SYS_SCHEDULING t");
            strSql.Append(" LEFT JOIN T_BASE_USERINFO b ON  b.USER_ID = t.S_USER");
            strSql.Append(" LEFT JOIN T_BASE_WORKTYPE a ON  a.WORK_ID = t.S_TYPE");
            strSql.Append(" LEFT JOIN T_BASE_STORAGEINFO c ON  c.STORAGE_ID = t.S_STORAGE");
            strSql.Append(" where 1=1 ");
            if (!string.IsNullOrEmpty(model.S_USER))
            {
                strSql.Append(" and  t.S_USER ='" + model.S_USER + "'");
            }
            if (!string.IsNullOrEmpty(model.S_STORAGE))
            {
                strSql.Append(" and  t.S_STORAGE = '" + model.S_STORAGE + "'");
            }
            if (!string.IsNullOrEmpty(model.STATUS))
            {
                strSql.Append(" and  t.STATUS = '" + model.STATUS + "'");
            }
            if (model.S_DATE_STAR != DateTime.MinValue && model.S_DATE_END != DateTime.MinValue)
            {
                strSql.Append(" and   t.S_DATE between convert(varchar(100),'" + model.S_DATE_STAR.ToString("yyyy-MM-dd") + "',23) and convert(varchar(100),'" + model.S_DATE_END.ToString("yyyy-MM-dd") + "',23)");
            }
            strSql.Append(" order by t.S_DATE desc");
            return SystemDataObject.Instance.GetDataTable(strSql.ToString());
		}

        /// <summary>
        /// 获取流水号
        /// </summary>
        /// <returns></returns>
        public string GetSerialNum()
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("select  NEXT VALUE FOR [SEQ_SCHEDULING] ");
            DataSet ds =   SystemDataObject.Instance.GetDataSet( strSql.ToString());
            return ds.Tables[0].Rows[0][0].ToString();
        }
		#endregion  BasicMethod
	}
}