using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.IData.IStock;
using System.Data;

using WMS.IData;using Oracle.ManagedDataAccess.Client;
using WMS.Model.Stock;
using WMS.DBUtility;

namespace WMS.SqlServerData.StockData
{
    public class AdjustListInfoData : IAdjustListInfo
    {

        /// <summary>
        /// 查询所有明细
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public DataTable GetAdjustList(AdjustListInfoModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append(@"select      f.STORAGE_AREA_NAME area_name,
                                        e.STORAGE_NAME storage_name,
                                        b.Goods_name goods_name,
                                        a.LIST_ID,
                                        a.LIST_INFO_GOODSID,
                                        a.LOC_ID,
                                        a.LIST_INFO_COUNT,
                                        a.REMARK,
                                        a.VERSION,
                                        a.OPERATORID,
                                        a.OPERATEDATE,
                                        a.NEWCOUNT,
                                        a.OLDCOUNT,
                                        a.STORAGE_ID,
                                        a.AREA_ID,a.PUTIN_ID");
            strSql.Append(" FROM T_STOCK_ADJUSTLIST_INFO a left join t_base_goods b on a.LIST_INFO_GOODSID = b.GOODS_ID");
            strSql.Append(" left join T_BASE_STORAGEINFO e on a.STORAGE_ID = e.STORAGE_ID");
            strSql.Append(" left join T_BASE_STORAGE_AREA f on a.AREA_ID = f.STORAGE_AREA_ID where 1=1");
            if (!string.IsNullOrEmpty(model.LIST_ID))
            {
                strSql.Append(" and a.LIST_ID='" + model.LIST_ID + "'");
            }
            if (!string.IsNullOrEmpty(model.LIST_INFO_GOODSID))
            {
                strSql.Append(" and a.LIST_INFO_GOODSID='" + model.LIST_ID + "'");
            }
            if (!string.IsNullOrEmpty(model.LOC_ID))
            {
                strSql.Append(" and a.LOC_ID='" + model.LOC_ID + "'");
            }
            strSql.Append(" order by a.LIST_INFO_GOODSID");

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

        #region 新增商品明细
        /// <summary>
        /// 新增商品明细
        /// </summary>
        /// <param name="list"></param>
        /// <returns></returns>
        public void ExecListAdd(AdjustListInfoModel list)
        {
          
         
                StringBuilder strSql = new StringBuilder();
                strSql.Append("insert into T_STOCK_ADJUSTLIST_INFO(");
                strSql.Append("LIST_ID,LIST_INFO_GOODSID,LOC_ID,LIST_INFO_COUNT,REMARK,VERSION,OPERATORID,OPERATEDATE,NEWCOUNT,OLDCOUNT,STORAGE_ID,AREA_ID)");
                strSql.Append(" values (");
                strSql.Append(":LIST_ID,:LIST_INFO_GOODSID,:LOC_ID,:LIST_INFO_COUNT,:REMARK,:VERSION,:OPERATORID,:OPERATEDATE,:NEWCOUNT,:OLDCOUNT,:STORAGE_ID,:AREA_ID)");
                OracleParameter[] parameters = {
					new OracleParameter(":LIST_ID",OracleDbType.Varchar2),
					new OracleParameter(":LIST_INFO_GOODSID",OracleDbType.Varchar2),
					new OracleParameter(":LOC_ID",OracleDbType.Varchar2),
					new OracleParameter(":LIST_INFO_COUNT", OracleDbType.Decimal),
					new OracleParameter(":REMARK",OracleDbType.Varchar2),
					new OracleParameter(":VERSION",OracleDbType.Varchar2),
					new OracleParameter(":OPERATORID",OracleDbType.Varchar2),
					new OracleParameter(":OPERATEDATE", OracleDbType.Date),
					new OracleParameter(":NEWCOUNT", OracleDbType.Decimal),
                   new OracleParameter(":OLDCOUNT",OracleDbType.Decimal),
                   new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
                   new OracleParameter(":AREA_ID",OracleDbType.Varchar2),
                   new OracleParameter(":PUTIN_ID",OracleDbType.Varchar2)
                                            };

                parameters[0].Value = list.LIST_ID;
                parameters[1].Value = list.LIST_INFO_GOODSID;
                parameters[2].Value = list.LOC_ID;
                parameters[3].Value = list.LIST_INFO_COUNT;
                parameters[4].Value = list.REMARK;
                parameters[5].Value = list.VERSION;
                parameters[6].Value = list.OPERATORID;
                parameters[7].Value = list.OPERATEDATE;
                parameters[8].Value = list.NEWCOUNT;
                parameters[9].Value = list.Oldcount;
                parameters[10].Value = list.Storage_id;
                parameters[11].Value = list.Area_id;
                parameters[12].Value = list.PUTIN_ID;


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

        #region 修改
        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        public void ExecListUpdate(AdjustListInfoModel model)
        {

            StringBuilder strSql = new StringBuilder();
            strSql.Append("update T_STOCK_ADJUSTLIST_INFO set ");
            strSql.Append("LIST_INFO_COUNT=:LIST_INFO_COUNT,");
            strSql.Append("REMARK=:REMARK,");
            strSql.Append("VERSION=:VERSION,");
            strSql.Append("OPERATORID=:OPERATORID,");
            strSql.Append("OPERATEDATE=:OPERATEDATE,");
            strSql.Append("NEWCOUNT=:NEWCOUNT");
            strSql.Append("OLDCOUNT=:OLDCOUNT");
            strSql.Append("LOC_ID=:LOC_ID");
            strSql.Append("STORAGE_ID=:STORAGE_ID");
            strSql.Append("AREA_ID=:AREA_ID");
            strSql.Append(" where LIST_ID=:LIST_ID and LOC_ID=:LOC_ID and LIST_INFO_GOODSID=:LIST_INFO_GOODSID");
            OracleParameter[] parameters = {
					new OracleParameter(":LIST_INFO_COUNT",OracleDbType.Varchar2),
					new OracleParameter(":REMARK",OracleDbType.Varchar2),
					new OracleParameter(":VERSION",OracleDbType.Varchar2),
					new OracleParameter(":OPERATORID",OracleDbType.Varchar2),
					new OracleParameter(":OPERATEDATE",OracleDbType.Varchar2),
					new OracleParameter(":NEWCOUNT", OracleDbType.Decimal),
                   new OracleParameter(":OLDCOUNT",OracleDbType.Decimal),
                   new OracleParameter(":LOC_ID",OracleDbType.Varchar2),
                   new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
                   new OracleParameter(":AREA_ID",OracleDbType.Varchar2),
                   new OracleParameter(":LIST_ID",OracleDbType.Varchar2),
                   new OracleParameter(":LIST_INFO_GOODSID",OracleDbType.Varchar2)  };


            parameters[0].Value = model.LIST_INFO_COUNT;
            parameters[1].Value = model.REMARK;
            parameters[2].Value = model.VERSION;
            parameters[3].Value = model.OPERATORID;
            parameters[4].Value = model.OPERATEDATE;
            parameters[5].Value = model.NEWCOUNT;
            parameters[6].Value = model.Oldcount;
            parameters[7].Value = model.LOC_ID;
            parameters[8].Value = model.Storage_id;
            parameters[9].Value = model.Area_id;
            parameters[10].Value = model.LIST_ID;
            parameters[11].Value = model.LIST_INFO_GOODSID;
            
           

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

        public string Get_StrLoc(string LOCATION_ID)
        {
            string sqlStr = "  select LOCATION_ID from T_BASE_STORAGE_AREA_LOCATION where LOCATION_ID='" + LOCATION_ID + "' and STATUS !='0'";
            string row = "";
            DataTable ds = new DataTable();
            try
            {
                ds = SystemDataObject.Instance.GetDataTable(sqlStr);
                if (ds != null)
                {
                    if (ds.Rows.Count > 0)
                    {
                        row = ds.Rows[0][0].ToString();

                        if (row.Length > 0)
                        {
                            row = "";
                            string sqlstr2 = "select * from T_MI_STOCK   where location_id='" + LOCATION_ID + "'";
                            ds = SystemDataObject.Instance.GetDataTable(sqlStr);
                            if (ds != null)
                            {
                                if (ds.Rows.Count > 0)
                                {
                                    row = ds.Rows[0][0].ToString();
                                }
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                row = "";
            }
            return row;
        }




        #region 删除库调整单明细存
        /// <summary>
        /// 删除库调整单明细存
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public void DelList(AdjustListInfoModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("delete from T_STOCK_ADJUSTLIST_INFO ");
            strSql.Append(" where LIST_ID=:LIST_INFO_ID");
            OracleParameter[] parameters = {
					new OracleParameter(":LIST_ID",OracleDbType.Varchar2)};
            parameters[0].Value = model.LIST_ID;

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

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