using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;

using WMS.DBUtility;
using WMS.IData.ICK;
using WMS.IData;using System.Data.SqlClient;
using WMS.Model.CK;
using WMS.Model.SC;
using WMS.IData.ISC;

namespace WMS.SqlServerData.SCData
{
    /// <summary>
    /// 数据访问类@_PROCESS_PLAN
    /// </summary>
    public partial class ProcessPlanData : IProcessPlan
    {
        #region  BasicMethod

        /// <summary>
        /// 增加一条数据
        /// </summary>
        public void Add(ProcessPlanModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("insert into T_SC_PROCESS_PLAN(");
            strSql.Append("PLAN_ID,PLAN_NAME,PLAN_USERID,PLAN_DESCRIPTION,PLAN_STARTDATE,PLAN_CREATETIME,STATUS,STORAGE_ID,PLAN_ENDDATE)");
            strSql.Append(" values (");
            strSql.Append("@PLAN_ID,@PLAN_NAME,@PLAN_USERID,@PLAN_DESCRIPTION,@PLAN_STARTDATE,@PLAN_CREATETIME,@STATUS,@STORAGE_ID,@PLAN_ENDDATE)");
            SqlParameter[] parameters = {
					new SqlParameter("@PLAN_ID", SqlDbType.VarChar),
					new SqlParameter("@PLAN_NAME", SqlDbType.VarChar),
					new SqlParameter("@PLAN_USERID", SqlDbType.VarChar),
					new SqlParameter("@PLAN_DESCRIPTION", SqlDbType.VarChar),
					new SqlParameter("@PLAN_STARTDATE", SqlDbType.Date),
					new SqlParameter("@PLAN_CREATETIME", SqlDbType.Date),
                   new SqlParameter("@STATUS", SqlDbType.VarChar),
					new SqlParameter("@STORAGE_ID", SqlDbType.VarChar),
                   new SqlParameter("@PLAN_ENDDATE", SqlDbType.Date),};
            parameters[0].Value = model.PLAN_ID;
            parameters[1].Value = model.PLAN_NAME;
            parameters[2].Value = model.PLAN_USERID;
            parameters[3].Value = model.PLAN_DESCRIPTION;
            parameters[4].Value = model.PLAN_STARTDATE;
            parameters[5].Value = model.PLAN_CREATETIME;
            parameters[6].Value = model.STATUS;
            parameters[7].Value = model.STORAGE_ID;
            parameters[8].Value = model.PLAN_ENDDATE;

            SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
        }
        /// <summary>
        /// 更新一条数据
        /// </summary>
        public void Update(ProcessPlanModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("update T_SC_PROCESS_PLAN set ");
            strSql.Append("PLAN_NAME=@PLAN_NAME,");
            strSql.Append("PLAN_USERID=@PLAN_USERID,");
            strSql.Append("PLAN_DESCRIPTION=@PLAN_DESCRIPTION,");
            strSql.Append("PLAN_STARTDATE=@PLAN_STARTDATE,");
            strSql.Append("PLAN_CREATETIME=@PLAN_CREATETIME,");
            strSql.Append("STATUS=@STATUS,");
            strSql.Append("STORAGE_ID=@STORAGE_ID,");
            strSql.Append("PLAN_ENDDATE=@PLAN_ENDDATE");
            strSql.Append(" where PLAN_ID=@PLAN_ID ");
            SqlParameter[] parameters = {
					new SqlParameter("@PLAN_NAME", SqlDbType.VarChar),
					new SqlParameter("@PLAN_USERID", SqlDbType.VarChar),
					new SqlParameter("@PLAN_DESCRIPTION", SqlDbType.VarChar),
					new SqlParameter("@PLAN_STARTDATE", SqlDbType.Date),
					new SqlParameter("@PLAN_CREATETIME", SqlDbType.Date),
                   new SqlParameter("@STATUS", SqlDbType.VarChar),
					new SqlParameter("@STORAGE_ID", SqlDbType.VarChar),
                   new SqlParameter("@PLAN_ENDDATE", SqlDbType.Date),
					new SqlParameter("@PLAN_ID", SqlDbType.VarChar)};
            parameters[0].Value = model.PLAN_NAME;
            parameters[1].Value = model.PLAN_USERID;
            parameters[2].Value = model.PLAN_DESCRIPTION;
            parameters[3].Value = model.PLAN_STARTDATE;
            parameters[4].Value = model.PLAN_CREATETIME;
            parameters[5].Value = model.STATUS;
            parameters[6].Value = model.STORAGE_ID;
            parameters[7].Value = model.PLAN_ENDDATE;
            parameters[8].Value = model.PLAN_ID;

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

        /// <summary>
        /// 删除一条数据
        /// </summary>
        public void Delete(ProcessPlanModel model)
        {

            StringBuilder strSql = new StringBuilder();
            strSql.Append("delete from T_SC_PROCESS_PLAN ");
            strSql.Append(" where PLAN_ID=@PLAN_ID ");
            SqlParameter[] parameters = {
					new SqlParameter("@PLAN_ID", SqlDbType.VarChar)			};
            parameters[0].Value = model.PLAN_ID;

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


        /// <summary>
        /// 获得数据列表
        /// </summary>
        public DataTable GetList(ProcessPlanModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("select t.PLAN_ID,");
            strSql.Append("t.PLAN_NAME,");
            strSql.Append("t.PLAN_USERID,");
            strSql.Append("b.NAME PLAN_USERNAME,");
            strSql.Append("t.PLAN_DESCRIPTION,");
            strSql.Append("t.PLAN_STARTDATE,");
            strSql.Append("t.PLAN_CREATETIME,");
            strSql.Append("t.PLAN_ENDDATE,");
            strSql.Append("t.STATUS,");
            strSql.Append("t.STORAGE_ID,");
            strSql.Append("a.STORAGE_NAME STORAGE_NAME");
            strSql.Append(" FROM T_SC_PROCESS_PLAN t");
            strSql.Append(" LEFT JOIN T_BASE_USERINFO b ON  b.USER_ID = t.plan_userid");
            strSql.Append(" LEFT JOIN T_BASE_STORAGEINFO a ON  a.STORAGE_ID = t.STORAGE_ID");
            strSql.Append(" where 1=1 ");
            if (!string.IsNullOrEmpty(model.PLAN_NAME))
            {
                strSql.Append(" and t.PLAN_NAME='" + model.PLAN_NAME + "' ");
            }
            if (!string.IsNullOrEmpty(model.STATUS))
            {
                strSql.Append(" and t.STATUS='" + model.STATUS + "' ");
            }
            if (model.DATESTAR != DateTime.MinValue && model.DATEEND != DateTime.MinValue)
            {
                strSql.Append(" and   t.PLAN_CREATETIME between convert(varchar(100),'" + model.DATESTAR.ToString("yyyy-MM-dd") + "',23) and convert(varchar(100),'" + model.DATEEND.ToString("yyyy-MM-dd") + "',23)");
            }
            if (!string.IsNullOrEmpty(model.Str_goods_ids) && model.Str_goods_ids != "()")
            {
                strSql.Append(" and t.PLAN_ID in (select PLAN_ID from T_SC_PLANGOODS where GOODS_ID in " + model.Str_goods_ids + ")");
            }
            return SystemDataObject.Instance.GetDataTable(strSql.ToString());
        }
        /// <summary>
        /// 获取流水号
        /// </summary>
        /// <returns></returns>
        public string GetSerialNum()
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("select NEXT VALUE FOR SEQ_SC_PLANGOODS_ID ");
            DataSet ds =   SystemDataObject.Instance.GetDataSet( strSql.ToString());
            return ds.Tables[0].Rows[0][0].ToString();
        }

        #endregion  BasicMethod
    }
}