using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
 
using System.Data;
using WMS.DBUtility;
using WMS.Model.CK;
using WMS.IData;
using WMS.IData.ICK;
using WMS.Model.Stock;

namespace WMS.SqlServerData.CKData
{
    public class PackWeighingData : IPackWeighing
    {

        #region 查询本表数据
        public DataTable GetPackWeighingData(PackWeighingModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append(@"  select t.LOGCOMID,
                                     l.log_com_name,
                                     t.SUMCOUNT,
                                     t.SUMWEIGHT,
                                     t.WEIGHTMONTH
                                FROM T_CK_PACKWEIGHING t
                                left join T_BASE_LOGISTICSCOMINFO l
                                  on t.logcomid = l.log_com_id 
                                where 1 = 1 ");

            if (!string.IsNullOrEmpty(model.LOGCOMID.Trim()))
            {
                strSql.Append(" and t.LOGCOMID = '" + model.LOGCOMID + "'");
            }
            if (!string.IsNullOrEmpty(model.WEIGHTMONTH.ToString()))
            {
                strSql.Append(" and t.WEIGHTMONTH = '" + model.WEIGHTMONTH + "'");
            }
            return SystemDataObject.Instance.GetDataTable(strSql.ToString());
        }
        #endregion

        #region 新增 本表
        /// <summary>
        /// 增加一条数据
        /// </summary>
        public void InsertPackWeighingData(PackWeighingModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append(@"insert into t_ck_packweighing
                                      (logcomid, sumcount, sumweight, weightmonth)
                                    values
                                      ('"+model.LOGCOMID+"','"+model.SUMCOUNT+"' , '"+model.SUMWEIGHT+"', '"+model.WEIGHTMONTH+"')");

      

            SystemDataObject.Instance.ExecuteSqlCommit(strSql.ToString());
        }
        #endregion

        #region 更新本表
        /// <summary>
        /// 更新一条数据
        /// </summary>
        public void UpdatePackWeighingData(PackWeighingModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("update T_CK_PACKWEIGHING set ");
            strSql.Append(" sumcount='"+model.SUMCOUNT+"',");
            strSql.Append(" sumweight='"+model.SUMWEIGHT+"' ");
            strSql.Append(" where logcomid=:logcomid and weightmonth='"+model.WEIGHTMONTH+"' ");
     

            SystemDataObject.Instance.ExecuteSqlCommit(strSql.ToString());
        }
        #endregion

        /// <summary>
        /// 同时更新本表、回写订单表、新增包装库存back表、删除包装库存表
        /// </summary>
        /// <param name="packmodel">包装称重Model</param>
        /// <param name="ordermodel">出库订单Model</param>
        /// <param name="mimodel">包装库存BackModel</param>
        /// <param name="expressno">快递单号</param>
        public void PassPackWeightingData(PackWeighingModel packmodel, OrdersModel ordermodel, MIPackStockBackModel mimodel, string expressno)
        {

            StringBuilder strSql = new StringBuilder();

            List<string> strSqllist = new List<string>();
    
            #region 更本表
            strSql.Append("update T_CK_PACKWEIGHING set ");
            strSql.Append(" sumcount=:sumcount,");
            strSql.Append(" sumweight=:sumweight ");
            strSql.Append(" where logcomid=:logcomid and weightmonth=:weightmonth ");
       
            #endregion

            #region 更订单表
            strSql = new StringBuilder();
            strSql.Append(@"update t_ck_orders
                               set WEIGHTING_TOTAL = :WEIGHTING_TOTAL,
                                   weighed_man  = :weighed_man,
                                   weighed_date = :weighed_date,
                                   STATUS = :STATUS
                               where expressno = :expressno
                              ");
          
            #endregion

            #region 增包装库存Back表
            strSql = new StringBuilder();
            strSql.Append("insert into T_MI_PACKSTOCK_BACK(");
            strSql.Append("ORDERS_ID,EXPRESSNO,GOOD_ID,STORAGE_ID,AREA_ID,LOCATION_ID,GOOD_NUM,PACK_NUM,PACK_DATE,GOOD_WEIGHT,ORI_NUM,CHANGE_NUM,OPERATE_DATE,OPERATE_MAN,LOG_ID)");
            strSql.Append(" values (");
            strSql.Append(":ORDERS_ID,:EXPRESSNO,:GOOD_ID,:STORAGE_ID,:AREA_ID,:LOCATION_ID,:GOOD_NUM,:PACK_NUM,:PACK_DATE,:GOOD_WEIGHT,:ORI_NUM,:CHANGE_NUM,:OPERATE_DATE,:OPERATE_MAN,:LOG_ID)");
           
            #endregion

          

          //  SystemDataObject.Instance.ExecuteList(strSqllist);
        }
        #region 回写出库通知单 称重重量等
        /// <summary>
        /// 回写出库表
        /// </summary>
        /// <param name="expressid"></param>
        public void UpdateOrderWeightScale(OrdersModel model)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append(@"update t_ck_orders set WEIGHTING_TOTAL = '"+model.WEIGHTING_TOTAL+"',"
                           + "        weighed_man  ='" + model.WEIGHED_MAN + "' ,"
                              +"     weighed_date = '"+model.WEIGHED_DATE+"',"
                              +"  where expressno = '"+ model .EXPRESSNO+ "'");
           
            SystemDataObject.Instance.ExecuteSqlCommit(strSql.ToString());
        }

        #endregion


        //新增到Back表
        public void InsertPackDataIntoBack(string expressno)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append(@"insert into t_mi_packstock_back select * from T_MI_PACKSTOCK  where expressno = '"+ expressno + "' ");
       
         
            SystemDataObject.Instance.ExecuteSqlCommit(strSql.ToString());
        }



        #region 直接删除拣货区 库存商品
        /// <summary>
        /// 删除一条数据
        /// </summary>
        public void DeletePackData(string expressno)
        {
            StringBuilder strSql = new StringBuilder();
            strSql.Append("delete from T_MI_PACKSTOCK ");
            strSql.Append(" where expressno= '" + expressno + "' ");
         
            SystemDataObject.Instance.ExecuteSqlCommit(strSql.ToString());
        }
        #endregion






        /// <summary>
        /// 获得重量上下限
        /// </summary>
        /// <param name="parammenu"></param>
        /// <returns></returns>
        public DataTable SearchWeightNum(string parammenu)
        {
            StringBuilder str = new StringBuilder();
            str.Append(" select Paramvalue from T_Sys_param where 1 = 1 ");
            str.Append(" and parammenu='" + parammenu + "'");
            return SystemDataObject.Instance.GetDataTable(str.ToString());
        }


        /// <summary>
        /// 更新重量上下限
        /// </summary>
        /// <param name="upnum"></param>
        /// <param name="downnum"></param>
        public void UpdateWeightNum(List<decimal> weightnum)
        {
            StringBuilder strSql = new StringBuilder();
            List<string> updatesqlstrlist = new List<string>();
          
            strSql.Append(" update t_sys_param ");
            strSql.Append(" set paramvalue =:paramvalue ");
            strSql.Append(" where paramtype =:paramtype  and  parammenu=:parammenu ");
          

            strSql.Append(" update t_sys_param ");
            strSql.Append(" set paramvalue =:paramvalue ");
            strSql.Append(" where paramtype =:paramtype  and  parammenu=:parammenu");
         

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




    }
}