using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.IData;using Oracle.ManagedDataAccess.Client;
using System.Data;

using WMS.DBUtility;
using WMS.Model.Stock;
using WMS.IData.IStock;

namespace WMS.SqlServerData.StockData
{
    public class MIStockOccupyData : IMIStockOccupy
    {
        /// <summary>
        /// 获取库存占用表
        /// </summary>
        /// <returns>库存占用表</returns>
        public DataTable GetMIStockOccupyDT(MIStockOccupyModel model)
        {
            StringBuilder strSql = new StringBuilder();

            strSql.Append("select STOCK_ID,PUTIN_ID,STORAGE_ID,AREA_ID,LOCATION_ID,GOODS_ID,DOCCTNUMBER,OCCUPY_NUM ");
            strSql.Append(" FROM T_MI_STOCK_OCCUPY ");
            strSql.AppendLine(" where 1 = 1 ");
            if (!string.IsNullOrEmpty(model.STOCK_ID))
            {
                strSql.AppendLine(" and STOCK_ID = '" + model.STOCK_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.PUTIN_ID))
            {
                strSql.AppendLine(" and PUTIN_ID = '" + model.PUTIN_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.LOCATION_ID))
            {
                strSql.AppendLine(" and LOCATION_ID = '" + model.LOCATION_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.GOODS_ID))
            {
                strSql.AppendLine(" and GOODS_ID = '" + model.GOODS_ID + "'");
            }
            if (!string.IsNullOrEmpty(model.STORAGE_ID))
            {
                strSql.AppendLine(" and STORAGE_ID = '" + model.STORAGE_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.AREA_ID))
            {
                strSql.AppendLine(" and AREA_ID = '" + model.AREA_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.DOCCTNUMBER))
            {
                strSql.AppendLine(" and DOCCTNUMBER = '" + model.DOCCTNUMBER + "' ");
            }
            strSql.AppendLine(" order by DOCCTNUMBER");

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

        /// <summary>
        /// 插入库存占用表信息
        /// </summary>
        /// <param name="MIStockOccupyModel">库存占用表Model</param>
        public void InsertMIStockOccupy(MIStockOccupyModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("insert into T_MI_STOCK_OCCUPY(");
            strSql.Append("STOCK_ID,PUTIN_ID,STORAGE_ID,AREA_ID,LOCATION_ID,GOODS_ID,DOCCTNUMBER,OCCUPY_NUM,HIGH)");
            strSql.Append(" values (");
            strSql.Append(":STOCK_ID,:PUTIN_ID,:STORAGE_ID,:AREA_ID,:LOCATION_ID,:GOODS_ID,:DOCCTNUMBER,:OCCUPY_NUM)");
            OracleParameter[] parameters = {
					new OracleParameter(":STOCK_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":PUTIN_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":AREA_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":LOCATION_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":GOODS_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":DOCCTNUMBER",OracleDbType.Varchar2,50),
					new OracleParameter(":OCCUPY_NUM", OracleDbType.Decimal,4)};
            parameters[0].Value = model.STOCK_ID;
            parameters[1].Value = model.PUTIN_ID;
            parameters[2].Value = model.STORAGE_ID;
            parameters[3].Value = model.AREA_ID;
            parameters[4].Value = model.LOCATION_ID;
            parameters[5].Value = model.GOODS_ID;
            parameters[6].Value = model.DOCCTNUMBER;
            parameters[7].Value = model.OCCUPY_NUM;

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

        }

        /// <summary>
        /// 修改库存占用表信息
        /// </summary>
        /// <param name="MIStockOccupyModel">库存占用表Model</param>
        public void UpdateMIStockOccupy(MIStockOccupyModel model)
        {
            StringBuilder strSql = new StringBuilder();

            strSql.Append("update T_MI_STOCK_OCCUPY set ");
            strSql.Append("STOCK_ID=:STOCK_ID,");
            strSql.Append("PUTIN_ID=:PUTIN_ID,");
            strSql.Append("STORAGE_ID=:STORAGE_ID,");
            strSql.Append("AREA_ID=:AREA_ID,");
            strSql.Append("LOCATION_ID=:LOCATION_ID,");
            strSql.Append("GOODS_ID=:GOODS_ID,");
            strSql.Append("DOCCTNUMBER=:DOCCTNUMBER,");
            strSql.Append("OCCUPY_NUM=:OCCUPY_NUM");
            strSql.Append(" where STOCK_ID=:STOCK_ID and PUTIN_ID=:PUTIN_ID and STORAGE_ID=:STORAGE_ID and AREA_ID=:AREA_ID and LOCATION_ID=:LOCATION_ID and GOODS_ID=:GOODS_ID and DOCCTNUMBER=:DOCCTNUMBER ");
            OracleParameter[] parameters = {
					new OracleParameter(":STOCK_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":PUTIN_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":AREA_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":LOCATION_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":GOODS_ID",OracleDbType.Varchar2,50),
					new OracleParameter(":DOCCTNUMBER",OracleDbType.Varchar2,50),
					new OracleParameter(":OCCUPY_NUM", OracleDbType.Decimal,4)};
            parameters[0].Value = model.STOCK_ID;
            parameters[1].Value = model.PUTIN_ID;
            parameters[2].Value = model.STORAGE_ID;
            parameters[3].Value = model.AREA_ID;
            parameters[4].Value = model.LOCATION_ID;
            parameters[5].Value = model.GOODS_ID;
            parameters[6].Value = model.DOCCTNUMBER;
            parameters[7].Value = model.OCCUPY_NUM;

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

        /// <summary>
        /// 删除库存占用表信息
        /// </summary>
        /// <param name="MIStockOccupy"></param>
        public void DeleteMIStockOccupy(MIStockOccupyModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("delete from T_MI_STOCK_OCCUPY ");
            strSql.AppendLine(" where 1 = 1 ");
            if (!string.IsNullOrEmpty(model.STOCK_ID))
            {
                strSql.AppendLine(" and STOCK_ID = '" + model.STOCK_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.PUTIN_ID))
            {
                strSql.AppendLine(" and PUTIN_ID = '" + model.PUTIN_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.LOCATION_ID))
            {
                strSql.AppendLine(" and LOCATION_ID = '" + model.LOCATION_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.GOODS_ID))
            {
                strSql.AppendLine(" and GOODS_ID = '" + model.GOODS_ID + "'");
            }
            if (!string.IsNullOrEmpty(model.STORAGE_ID))
            {
                strSql.AppendLine(" and STORAGE_ID = '" + model.STORAGE_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.AREA_ID))
            {
                strSql.AppendLine(" and AREA_ID = '" + model.AREA_ID + "' ");
            }
            if (!string.IsNullOrEmpty(model.DOCCTNUMBER))
            {
                strSql.AppendLine(" and DOCCTNUMBER = '" + model.DOCCTNUMBER + "' ");
            }

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

   } 
  
}