using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.IData.ISC;
using WMS.Model.SC;
using System.Data;
using WMS.IData;using System.Data.SqlClient;


namespace WMS.SqlServerData.SCData
{
    public class ProcessData : IProcess
    {
        #region 获取详情
        /// <summary>
        /// 获取详情
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public DataTable GetProcess(ProcessModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append(" select  ");
            strSql.Append(" b.goods_name goods_name,c.storage_name storage_name,e.team_name group_name,d.plan_name task_name,");
            strSql.Append(" a.RECORDDATE,a.STORAGE_ID,a.TASK_ID,a.GOODS_ID,a.GOODS_NUM,a.FINISH_NUM,a.FINISH_DATE,a.LAST_NUM,a.RECORD_PER,a.REMARK,a.VERSION,a.GROUP_ID,a.status");
            strSql.Append(" from t_sc_process a ");
            strSql.Append(" left join t_base_goods b on a.goods_id = b.goods_id ");
            strSql.Append(" left join  t_base_storageinfo c on a.storage_id = c.storage_id");
            strSql.Append(" left join t_sc_process_plan d on a.task_id = d.plan_id");
            strSql.Append(" left join t_sys_team e on a.group_id = e.team_id");
            strSql.Append(" where 1=1 ");

            if (!string.IsNullOrEmpty(model.TASK_ID))
            {
                strSql.Append(" and a.TASK_ID ='" + model.TASK_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.STORAGE_ID))
            {
                strSql.Append(" and a.STORAGE_ID = '" + model.STORAGE_ID + "'");
            }
            if (!string.IsNullOrEmpty(model.GOODS_ID))
            {
                strSql.Append(" and a.GOODS_ID = '" + model.GOODS_ID + "'");
            }

            return SystemDataObject.Instance.GetDataTable(strSql.ToString());
        }
        #endregion

        #region 修改详情
        /// <summary>
        /// 修改详情
        /// </summary>
        /// <param name="model"></param>
        public void UpdateProcess(ProcessModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("update T_SC_PROCESS set ");
            strSql.Append("GOODS_NUM=@GOODS_NUM,");
            strSql.Append("FINISH_NUM=@FINISH_NUM,");
            strSql.Append("FINISH_DATE=@FINISH_DATE,");
            strSql.Append("LAST_NUM=@LAST_NUM,");
            strSql.Append("RECORD_PER=@RECORD_PER,");
            strSql.Append("REMARK=@REMARK,");
            strSql.Append("VERSION=@VERSION,");
            strSql.Append("GROUP_ID=@GROUP_ID,");
            strSql.Append("GROUP_ID=@status");
            strSql.Append(" where STORAGE_ID=@STORAGE_ID and TASK_ID=@TASK_ID and GOODS_ID=@GOODS_ID and RECORDDATE=@RECORDDATE");
            SqlParameter[] parameters = {
					
					new SqlParameter("@GOODS_NUM", SqlDbType.Decimal,4),
					new SqlParameter("@FINISH_NUM", SqlDbType.Decimal,4),
					new SqlParameter("@FINISH_DATE", SqlDbType.Date),
					new SqlParameter("@LAST_NUM", SqlDbType.Decimal,4),
					new SqlParameter("@RECORD_PER", SqlDbType.VarChar,50),
					new SqlParameter("@REMARK", SqlDbType.VarChar,500),
					new SqlParameter("@VERSION", SqlDbType.VarChar,50),
                   new SqlParameter("@GROUP_ID", SqlDbType.VarChar,50),
                   new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
					new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
					new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
                   new SqlParameter("@RECORDDATE",SqlDbType.Date)};

            parameters[0].Value = model.GOODS_NUM;
            parameters[1].Value = model.FINISH_NUM;
            parameters[2].Value = model.FINISH_DATE;
            parameters[3].Value = model.LAST_NUM;
            parameters[4].Value = model.RECORD_PER;
            parameters[5].Value = model.REMARK;
            parameters[6].Value = model.VERSION;
            parameters[7].Value = model.Group_id;
            parameters[8].Value = model.Status;
            parameters[9].Value = model.STORAGE_ID;
            parameters[10].Value = model.TASK_ID;
            parameters[11].Value = model.GOODS_ID;
            parameters[12].Value = model.RecordDate;

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

        #region 新增
        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        public void AddProcess(ProcessModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("insert into T_SC_PROCESS(");
            strSql.Append("STORAGE_ID,TASK_ID,GOODS_ID,GOODS_NUM,FINISH_NUM,FINISH_DATE,LAST_NUM,RECORD_PER,REMARK,VERSION,GROUP_ID,RECORDDATE,status)");
            strSql.Append(" values (");
            strSql.Append("@STORAGE_ID,@TASK_ID,@GOODS_ID,@GOODS_NUM,@FINISH_NUM,@FINISH_DATE,@LAST_NUM,@RECORD_PER,@REMARK,@VERSION,@GROUP_ID,@RECORDDATE,@status)");
            SqlParameter[] parameters = {
					new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
					new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
					new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
					new SqlParameter("@GOODS_NUM", SqlDbType.Decimal,4),
					new SqlParameter("@FINISH_NUM", SqlDbType.Decimal,4),
					new SqlParameter("@FINISH_DATE", SqlDbType.Date),
					new SqlParameter("@LAST_NUM", SqlDbType.Decimal,4),
					new SqlParameter("@RECORD_PER", SqlDbType.VarChar,50),
					new SqlParameter("@REMARK", SqlDbType.VarChar,500),
					new SqlParameter("@VERSION", SqlDbType.VarChar,50),
                   new SqlParameter("@GROUP_ID", SqlDbType.VarChar,50),
                   new SqlParameter("@RECORDDATE", SqlDbType.Date),
                   new SqlParameter("@status", SqlDbType.VarChar)};
            parameters[0].Value = model.STORAGE_ID;
            parameters[1].Value = model.TASK_ID;
            parameters[2].Value = model.GOODS_ID;
            parameters[3].Value = model.GOODS_NUM;
            parameters[4].Value = model.FINISH_NUM;
            parameters[5].Value = model.FINISH_DATE;
            parameters[6].Value = model.LAST_NUM;
            parameters[7].Value = model.RECORD_PER;
            parameters[8].Value = model.REMARK;
            parameters[9].Value = model.VERSION;
            parameters[10].Value = model.Group_id;
            parameters[11].Value = model.RecordDate;
            parameters[12].Value = model.Status;
            SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
        }
        #endregion

        #region 删除
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="model"></param>
        public void DeleteProcess(ProcessModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("delete from T_SC_PROCESS ");
            strSql.Append(" where STORAGE_ID=@STORAGE_ID and TASK_ID=@TASK_ID and GOODS_ID=@GOODS_ID and RECORDDATE =@RECORDDATE");
            SqlParameter[] parameters = {
					new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
					new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
					new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
                   new SqlParameter("@RECORDDATE",SqlDbType.Date)};
            parameters[0].Value = model.STORAGE_ID;
            parameters[1].Value = model.TASK_ID;
            parameters[2].Value = model.GOODS_ID;
            parameters[3].Value = model.RecordDate;

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