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 Oracle.ManagedDataAccess.Client;


namespace WMS.SqlServerData.SCData
{
    public class ProcessData : IProcess
    {
        #region 获取详情
        /// <summary>
        /// 获取详情
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public DataTable GetProcess(ScProcessModel 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(ScProcessModel model)
        {
            string sqlUpdate = string.Format(@"update T_SC_PROCESS set GOODS_NUM={0},FINISH_NUM={1},FINISH_DATE='{2}',
            LAST_NUM={3},RECORD_PER='{4}',REMARK='{5}',VERSION='{6}',GROUP_ID='{7}',GROUP_ID='{8}'
            where STORAGE_ID='{9}' and TASK_ID='{10}' and GOODS_ID='{11}' and RECORDDATE='{12}'",
              model.GOODS_NUM,
            model.FINISH_NUM,
            model.FINISH_DATE,
            model.LAST_NUM,
            model.RECORD_PER,
            model.REMARK,
            model.VERSION,
            model.Group_id,
            model.Status,
            model.STORAGE_ID,
            model.TASK_ID,
            model.GOODS_ID,
            model.RecordDate);
            SystemDataObject.Instance.ExecuteSql(sqlUpdate);
        }
        #endregion

        #region 新增
        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        public void AddProcess(ScProcessModel model)
        {
            string sqlInsert = string.Format(@"insert into T_SC_PROCESS(STORAGE_ID,TASK_ID,GOODS_ID,GOODS_NUM,FINISH_NUM,FINISH_DATE,
                LAST_NUM,RECORD_PER,REMARK,VERSION,GROUP_ID,RECORDDATE,status)values (
                '{0}','{1}','{2}','{3}','{4}','{5}','{6}','{7}','{8}','{9}','{10}','{11}','{12}')", model.STORAGE_ID,
             model.TASK_ID,
            model.GOODS_ID,
            model.GOODS_NUM,
            model.FINISH_NUM,
             model.FINISH_DATE,
            model.LAST_NUM,
            model.RECORD_PER,
             model.REMARK,
             model.VERSION,
            model.Group_id,
            model.RecordDate,
            model.Status
                );
            SystemDataObject.Instance.ExecuteSql(sqlInsert);
        }
        #endregion

        #region 删除
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="model"></param>
        public void DeleteProcess(ScProcessModel model)
        {
            string sqlDelete = string.Format(@"delete from T_SC_PROCESS where STORAGE_ID='{0}' and TASK_ID='{1}' and GOODS_ID='{2}' and RECORDDATE ='{3}'",
            model.STORAGE_ID,
             model.TASK_ID,
            model.GOODS_ID,
            model.RecordDate);
            SystemDataObject.Instance.ExecuteSql(sqlDelete);
        }
        #endregion
    }
}