using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.Model.RK;
using System.Data;
using WMS.IData;
using WMS.Common;
using WMS.Model.Base;

namespace WMS.Business.RK
{
    public class BussAcceptance : IBussFactory
    {
        #region 查
        /// <summary>
        ///  查 收货验收 查询数据
        /// </summary>
        /// <param name="model">验收Model</param>
        /// <returns></returns>
        public List<AcceptanceModel> GetAcceptanceData(AcceptanceModel model)
        {
            DataTable dt = DataProvider.Instance.Acceptance.GetAcceptanceData(model);
            List<AcceptanceModel> list = null;

            if (DataLogErrWrite(dt, "获取收货验收数据"))
            {
                list = ConvertHelper<AcceptanceModel>.ConvertToList(dt);
            }
            else
            {
                return list;
            }
            return list;
        }
        #endregion


        /// <summary>
        /// 查询入库批次明细表 除去 验单表已存在的商品数据
        /// </summary>
        /// <param name="lotid"></param>
        /// <returns></returns>
        public List<StorageLotInfoModel> GetStorageLotInfoDistanct(string lotid)
        {
            DataTable dt = DataProvider.Instance.Acceptance.GetStorageLotInfoDistanct(lotid);
            List<StorageLotInfoModel> list = null;

            if (DataLogErrWrite(dt, "获取收货验收数据"))
            {
                list = ConvertHelper<StorageLotInfoModel>.ConvertToList(dt);
            }
            else
            {
                return list;
            }
            return list;
        }





        #region 增
        /// <summary>
        /// 增 收货验收 写入数据库
        /// </summary>
        /// <param name="list">验收Model集合</param>
        /// <returns></returns>
        public string AddAcceptance(List<AcceptanceModel> list)
        {
            int i = 0;
           string acceptData= IBussFactory<WMS.Business.Base.BussDocumentTable>.Instance().GetDocumentStream("收货单");
            foreach (AcceptanceModel model in list)
            {
                model.ACCE_ID = acceptData;
                model.ACC_STATUS = "1";
                DataProvider.Instance.Acceptance.AddAcceptance(model);
                if (i == 0)
                {
                    Transaction = DataProvider.Instance.TranOracle;
                }
                logList.Add(DataProvider.Instance.logData);

                i++;
            }

            TaCmtOrRak();

            //MessageModel messModel = new MessageModel();
            //messModel.ID = "YS" + DateTime.Now.ToString("yyyyMMddHHmmss") + DataProvider.Instance.Message.GetSerialNum();
            //messModel.MENU_FORM = "FrmAcceptance";
            //messModel.MESS_CONTENT = "新增验收单,单据编号:" + list[0].ACCE_ID;
            //messModel.MESS_DATE = DateTime.Now;
            //messModel.MESS_DEP =  list[0].STORAGE_ID;
            //messModel.MESS_FLAG = "0";
            //messModel.MESS_STAR = list[0].OPERATORID;
            //messModel.MESS_STATUS = "0";
            //messModel.WORK_KIND = "0";
            //messModel.RELATIVE_NUMBER = list[0].ACCE_ID;
            //messModel.WORK_TYPE = "worktype007";
            //messModel.STO_ID = list[0].OPERATORID;
            //messModel.MESS_TYPE = "RK";
            //DataProvider.Instance.Message.Add(messModel);
            //logList.Add(DataProvider.Instance.logData);
            //   Transaction = DataProvider.Instance.TranOracle;
            //   TaCmtOrRak();

            return this.ErrText;
        }
        #endregion



        /// <summary>
        /// 更新收货验收 回写入库批次主表 明细表数据
        /// </summary>
        /// <param name="list"></param>
        /// <param name="stolist"></param>
        /// <param name="infolist"></param>
        /// <returns></returns>
        public string UpdateAcceptanceStorageData(List<AcceptanceModel> list, List<StorageLotModel> stolist, List<StorageLotInfoModel> infolist)
        {
            //DataProvider.Instance.Acceptance.UpdateAcceptanceStorageData(list, stolist, infolist);

            Transaction = DataProvider.Instance.TranOracle;
            logList.Add(DataProvider.Instance.logData);
            TaCmtOrRak();
            return this.ErrText;
        }
        public string UpdateAcceptance(List<AcceptanceModel> listModel)
        {
            for(int i=0;i<listModel.Count;i++)
            {
                DataProvider.Instance.Acceptance.UpdateAcceptance(listModel[i]);
                if (i==0)
                {  
                    Transaction = DataProvider.Instance.TranOracle; 
                }
                logList.Add(DataProvider.Instance.logData);
            }
            TaCmtOrRak();
            return ErrText;
        }
          
        #region 改
            /// <summary>
            /// 改 收货验收 更新数据
            /// </summary>
            /// <param name="list">验收Model集合</param>
            /// <returns></returns>
        //    public string UpdateAcceptance(List<AcceptanceModel> list)
        //{
        //    DataProvider.Instance.Acceptance.UpdateAcceptance(list);

        //    Transaction = DataProvider.Instance.TranOracle;
        //    logList.Add(DataProvider.Instance.logData);
        //    TaCmtOrRak();
        //    return this.ErrText;
        //}
        #endregion

        /// <summary>
        /// 回写入库批次 个别字段信息
        /// </summary>
        /// <param name="list">入库批次Model集合</param>
        /// <returns></returns>
        public string UpdateStorage(List<StorageLotModel> list)
        {

            //DataProvider.Instance.Acceptance.UpdateStorage(list);

            Transaction = DataProvider.Instance.TranOracle;
            logList.Add(DataProvider.Instance.logData);
            TaCmtOrRak();
            return this.ErrText;

        }

        /// <summary>
        /// 回写入库批次、入库批次明细表 接收数量
        /// </summary>
        /// <param name="list"></param>
        /// <param name="listinfo"></param>
        /// <returns></returns>
        public string UpdateStorageData(List<StorageLotModel> list, List<StorageLotInfoModel> listinfo)
        {

            DataProvider.Instance.Acceptance.UpdateStorageData(list, listinfo);

            Transaction = DataProvider.Instance.TranOracle;
            logList.Add(DataProvider.Instance.logData);
            TaCmtOrRak();
            return this.ErrText;

        }



        #region 删
        /// <summary>
        /// 删 收货验收 删除数据
        /// </summary>
        /// <param name="model">验收Model集合</param>
        /// <returns></returns>
        public string DeleteAcceptance(List<AcceptanceModel> model)
        {
            DataProvider.Instance.Acceptance.DeleteAcceptance(model);

            Transaction = DataProvider.Instance.TranOracle;
            logList.Add(DataProvider.Instance.logData);

            //strs  单据编号
            foreach (AcceptanceModel strs in model)
            {
                string st = strs.ACCE_ID;
                DataProvider.Instance.Message.DeleteMessByRelativeNumber(st);
                logList.Add(DataProvider.Instance.logData);
            }
            TaCmtOrRak();

            return this.ErrText;
        }
        #endregion





        #region 删除数据添加到备份表
        /// <summary>
        /// 删除数据添加到备份表
        /// </summary>
        /// <param name="list">验收Model集合</param>
        /// <returns></returns>
        public string InsertAcceptanceBack(List<AcceptanceModel> list)
        {
            //先备份
            DataProvider.Instance.Acceptance.InsertAcceptanceBack(list);
            Transaction = DataProvider.Instance.TranOracle;
            logList.Add(DataProvider.Instance.logData);

            //在删除
            DataProvider.Instance.Acceptance.DeleteAcceptance(list);
            Transaction = DataProvider.Instance.TranOracle;
            logList.Add(DataProvider.Instance.logData);

            TaCmtOrRak();
            return this.ErrText;
        }
        #endregion


        /// <summary>
        /// 获得验收流水号
        /// </summary>
        /// <returns></returns>
        public string GetNextValNum()
        {
            return DataProvider.Instance.Acceptance.GetNextValNum();
        }



        public List<AcceptanceModel> GetWriteBackData(AcceptanceModel model)
        {
            DataTable dt = DataProvider.Instance.Acceptance.GetWriteBackData(model);
            List<AcceptanceModel> list = null;

            if (DataLogErrWrite(dt, "获取入库批次验收数据"))
            {
                list = ConvertHelper<AcceptanceModel>.ConvertToList(dt);
            }
            else
            {
                return list;
            }
            return list;
        }
    }
}