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


namespace WMS.SqlServerData.RKData
{
    class CodeDiskData : ICodeDisk
    {
        #region 获取码盘信息
        /// <summary>
        /// 获取码盘信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public DataTable GetCodeDisk(CodeDiskModel model)
        {
            string sql = "";

            #region 查询SQL

            sql +=@" select a.WAREHOUSING_ID,        --通知单编号
                             a.STORAGE_AREA_ID,       --库区编号
                             d.storage_area_name Storage_area_name,     --库区名称
                             a.LOCATION_ID,           --库位编号
                             a.Pallet_ID,           　--商品编号
                             b.goods_name Goods_name,            --商品名称
                             a.GOODS_ID,              --备注
                             a.UNIT,                  --UNIT
                             a.GOODS_NUM,             --商品数量
                             a.PRODUCTION_DATE,       --生产日期
                             a.TOTAL_VOLUME,          --总体积
                             a.TOTAL_ROUGH_WEIGHT,    --总毛重
                             a.TOTAL_NET_WEIGH,       --总净重
                             a.SCALE_UNIT,            --重量UNIT
                             a.TOTAL_MONEY,           --总金额
                             a.CODEDISK_PER,          --码盘人
                             e.name Codedisk_per_name,--码盘人名称
                             a.CODEDISK_DATE,         --码盘时间
                             a.REMARK,                --备注
                             a.VERSION,               --版本
                             a.OPERATORID,            --操作人
                             a.OPERATEDATE,           --操作日期
                             a.GVOLUME,               --UNIT体积
                             a.GOODS_TYPEID,          --商品类别
                             f.GOODS_TYPE_NAME goods_type_name,        --商品类别名称
                             a.PRICE, --标准金额
                             a.LOT_ID ,a.PROVIDER_ID,a.ProDucLotId,--
                             a.BARCODE,a.STORAGE_ID,m.AUTOSTS,a.ConveyorID
                             from T_RK_CODEDISK a
                             left join t_base_storage_area d on a.STORAGE_AREA_ID = d.storage_area_id 
                             left join t_base_goods b on a.GOODS_ID = b.goods_id
                             left join t_base_userinfo e on a.CODEDISK_PER = e.user_id
                             left join T_BASE_GOODS_TYPE f on a.GOODS_TYPEID = f.GOODS_TYPE_ID
                               left join T_BASE_STORAGEINFO m on m.STORAGE_ID=a.STORAGE_ID
                             where 1 = 1 ";
            if (!string.IsNullOrEmpty(model.STORAGE_ID))
            {
                sql += " and a.STORAGE_ID='" + model.STORAGE_ID + "'";
            }
            if (!string.IsNullOrEmpty(model.Warehousing_id))
            {
                sql += " and WAREHOUSING_ID='" + model.Warehousing_id + "'";
            }
            if (!string.IsNullOrEmpty(model.Goods_id))
            {
                sql += " and GOODS_ID = '" + model.Goods_id + "'";
            }
            if (!string.IsNullOrEmpty(model.LOCATION_ID))
            {
                sql += " and LOCATION_ID = '" + model.LOCATION_ID + "'";
            }
            if(!string.IsNullOrEmpty(model.Storage_area_id))
            {
                sql += " and a.Storage_area_id='"+model.Storage_area_id+"'";
            }
            if (!string.IsNullOrEmpty(model.LOT_ID))
            {
                sql += " and a.LOT_ID='" + model.LOT_ID + "'";
            }
            sql += " and sts = '0'";
            sql += " order by a.GOODS_TYPEID,a.Pallet_ID,OPERATEDATE desc";
            #endregion

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

        #region 新增或修改码盘
        public void AddZpData(CodeDiskModel list_model)
        { 
            string sql =@"insert into T_RK_CODEDISK(
                                         WAREHOUSING_ID,        --通知单编号
                                         STORAGE_AREA_ID,       --库区编号
                                         LOCATION_ID,           --库位编号
                                         Pallet_ID,           　--商品编号
                                         GOODS_ID,              --备注
                                         UNIT,                  --UNIT
                                         GOODS_NUM,             --商品数量
                                         TOTAL_VOLUME,          --总体积
                                         TOTAL_ROUGH_WEIGHT,    --总毛重
                                         TOTAL_NET_WEIGH,       --总净重
                                         TOTAL_MONEY,           --总金额
                                         CODEDISK_PER,          --码盘人 
                                         REMARK,                --备注 
                                         PRODUCTION_DATE,       --生产日期
                                         OPERATORID,            --操作人 
                                         GVOLUME,               --UNIT体积 
                                         SCALE_UNIT,            --重量UNIT   
                                         PRICE  ,                --标准金额
                                           LOT_ID,STORAGE_ID,ConveyorID,PROVIDER_ID,ProDucLotId
                                         ) values 
                                  ('" + list_model.Warehousing_id + "'," + 
                                  "'" + list_model.Storage_area_id + "'," +
                                  "'" + list_model.LOCATION_ID + "'," +
                                  "'" + list_model.Pallet_id + "'," +
                                  "'" + list_model.Goods_id + "'," +
                                  "'" + list_model.Unit + "' , " +
                                  "'" + list_model.Goods_Num + "' ," +
                                  "'" + list_model.Total_volume + "' ,  " +
                                  "'" + list_model.Total_rough_weight + "' ," +
                                  "'" + list_model.Total_net_weigh + "' , " +
                                  "'" + list_model.Total_money + "', " +
                                  "'" + list_model.Codedisk_per + "'," + 
                                  "'" + list_model.Remark + "'," + 
                                  "'" + list_model.Production_date + "'," +
                                  "'" + list_model.OperatorID + "'," + 
                                  "'" + list_model.Gvolume + "'," + 
                                  "'" + list_model.Scale_unit + "'," +
                                  "'" + list_model.Price + "','"+ list_model.LOT_ID + "'," +
                                  "'" + list_model.STORAGE_ID + "','"+list_model.ConveyorID+"',"+
                                  "'"+ list_model .PROVIDER_ID+ "','"+ list_model .ProDucLotId+ "')";

            SystemDataObject.Instance.ExecuteSql(sql);




        }
        /// <summary>
        /// 新增或修改码盘
        /// </summary>
        /// <param name="model"></param>
        /// <param name="flg">0 新增，1 修改</param>
        /// <returns></returns>
        public void ExecCodeDIskUpdate(CodeDiskModel list_model)
        {

            #region 修改SQL
            string sql =@"update T_RK_CODEDISK set STORAGE_AREA_ID =:STORAGE_AREA_ID,       --库区编号
                                              LOCATION_ID=:LOCATION_ID,                --库位编号
                                              Pallet_ID=:Pallet_ID,                    --商品编号
                                              GOODS_ID=:GOODS_ID,                      --备注
                                              UNIT=:UNIT,                              --UNIT
                                              GOODS_NUM=:GOODS_NUM,                    --商品数量
                                              TOTAL_VOLUME=:TOTAL_VOLUME,              --总体积
                                              TOTAL_ROUGH_WEIGHT=:TOTAL_ROUGH_WEIGHT,  --总毛重
                                              TOTAL_NET_WEIGH=:TOTAL_NET_WEIGH,        --总净重
                                              TOTAL_MONEY=:TOTAL_MONEY,                --总金额
                                              CODEDISK_PER=:CODEDISK_PER,              --码盘人
                                              CODEDISK_DATE=:CODEDISK_DATE,            --码盘时间
                                              REMARK=:REMARK,                          --备注
                                              VERSION=:VERSION,                         --版本
                                              PRODUCTION_DATE=:PRODUCTION_DATE,         --生产日期
                                              OPERATORID=:OPERATORID,                   --操作人
                                              OPERATEDATE=:OPERATEDATE,                 --操作日期
                                              GVOLUME=:GVOLUM,                          --UNIT体积
                                              GOODS_TYPEID =:GOODS_TYPEID,             --商品类别
                                              SCALE_UNIT =:SCALE_UNIT,                 --重量UNIT
                                              price =:PRICE,
                                              ConveyorID=:ConveyorID
                                              from T_RK_CODEDISK
                                              where WAREHOUSING_ID =  :WAREHOUSING_ID   --通知单编号 ";


            #endregion


            SystemDataObject.Instance.ExecuteSql(sql);
        }
        #endregion


        #region 删除码盘
        public void DelCiskCtlGoodsId(string ctl,string orderId,string goodsId)
        {
            string sqlStr = "delete T_RK_CODEDISK where PALLET_ID ='" + ctl + "' and GOODS_ID='"+goodsId+"'" +
                " and  WAREHOUSING_ID='"+orderId+"' ";
            SystemDataObject.Instance.ExecuteSql(sqlStr);
        }
        public void DelCiskCtl(string ctl)
        {
            string sqlStr = "delete T_RK_CODEDISK where PALLET_ID ='"+ctl+"' ";
            SystemDataObject.Instance.ExecuteSql(sqlStr);
        }
        /// <summary>
        /// 删除码盘
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int DelCodeDisk(CodeDiskModel model)
        {
            string sql = "";
            int resut = 0;

            #region 删除SQL

            sql += "delete from T_RK_CODEDISK where WAREHOUSING_ID=:WAREHOUSING_ID";
            OracleParameter[] parameter = new OracleParameter[] { 
           new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2)};
            parameter[0].Value = model.Warehousing_id;

            #endregion

            resut = SystemDataObject.Instance.ExecuteSqlCommit(sql, parameter);

            return resut;
        }
        public void UpdateDiskPallet(string ctl,string newctl)
        {
            string sqlStr =@" update T_RK_CODEDISK set PALLET_ID ='"+newctl+"'where PALLET_ID='"+ ctl + "'";

            SystemDataObject.Instance.ExecuteSql(sqlStr);
        }
        #endregion
    }
}