using HanHe.Utility.Data;
using HH.WMS.Common;
using HH.WMS.DAL;
using HH.WMS.Entitys.Algorithm;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WMS.DAL.CoreServer
{
    public class BasicDataDAL : DapperBaseDAL
    {
        public DataTable GetInventoryData()
        {
            string sql = @" select top 50 * from Inventory where bIsRead_WMS=0 ";
            DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
            DataTable dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
            return dt;
        }

        public DataTable GetWarehouseData()
        {
            string sql = @" select top 50 * from Warehouse where bIsRead_WMS=0 ";
            DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
            DataTable dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
            return dt;
        }

        public DataTable GetCustomerData()
        {
            string sql = @"select top 50 * from  Customer where bIsRead_WMS=0 ";
            DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
            DataTable dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
            return dt;
        }

        public DataTable GetVendnrData()
        {
            string sql = @"select top 50 * from Vendor where bIsRead_WMS=0 ";
            DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
            DataTable dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
            return dt;
        }

        public SqlExecuteResult UpdateInventoryCheckState(List<PLM_itemEntity> itemEntityList)
        {
            List<DbCommand> cmdlist = new List<DbCommand>();
            foreach (PLM_itemEntity entity in itemEntityList)
            {
                string strSql = @"update Inventory set bIsRead_WMS=1,cReader_WMS=:cReader_WMS,dReadDate_WMS=getdate() WHERE cInvCode=:cInvCode ";
                DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
                DataAccess.AddInParameter(cmd, "cReader_WMS", ComDbType.STRING, "汉和信息");
                DataAccess.AddInParameter(cmd, "cInvCode", ComDbType.STRING, entity.CODE);
                cmdlist.Add(cmd);
            }
            return ExecuteCommands(cmdlist, null);
        }

        public List<U8RebackData> GetStockData()
        {
            List<U8RebackData> u8RebackData = new List<U8RebackData>();
            string u8_zhangtaoDB = System.Configuration.ConfigurationManager.AppSettings["U8_zhangtaoDB"].ToString();
            string u8_stockCode = System.Configuration.ConfigurationManager.AppSettings["U8_stockCode"].ToString();

            if (string.IsNullOrEmpty(u8_zhangtaoDB)||string.IsNullOrEmpty(u8_stockCode))
            {
                Log.Info("u8_zhangtaoDB或者u8_stockCode未设置", "");
                return u8RebackData;
            }
            string sql = @"select * from " + u8_zhangtaoDB + ".dbo.v_SSYY_CurrentStock where cWhCode in(" + u8_stockCode + ")  and iQuantity!=0";
            DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
            u8RebackData = DataAccessExtensive.ExecuteListEntity<U8RebackData>(this.DataAccess, cmd, SetEntity);
            return u8RebackData;
        }

        private void SetEntity(U8RebackData entity, IDataReader reader)
        {
            SetEntityUti(entity, "cWhCode", "cWhCode", reader);
            SetEntityUti(entity, "cWhName", "cWhName", reader);
            SetEntityUti(entity, "cInvStd", "cInvStd", reader);
            SetEntityUti(entity, "cInvCode", "cInvCode", reader);
            SetEntityUti(entity, "cInvName", "cInvName", reader);
            SetEntityUti(entity, "cComUnitCode", "cComUnitCode", reader);
            SetEntityUti(entity, "cComUnitName", "cComUnitName", reader);
            SetEntityUti(entity, "cBatch", "cBatch", reader);
            SetEntityUti(entity, "iQuantity", "iQuantity", reader);
        }

        public SqlExecuteResult UpdateWarehouseCheckState(List<TN_AB_STOCKEntity> stockEntityList)
        {
            List<DbCommand> cmdlist = new List<DbCommand>();
            foreach (TN_AB_STOCKEntity entity in stockEntityList)
            {
                string strSql = @"update Warehouse set bIsRead_WMS=1,cReader_WMS=:cReader_WMS,dReadDate_WMS=getdate() WHERE cWhCode=:cWhCode ";
                DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
                DataAccess.AddInParameter(cmd, "cReader_WMS", ComDbType.STRING, "汉和信息");
                DataAccess.AddInParameter(cmd, "cWhCode", ComDbType.STRING, entity.CN_S_STOCK_CODE);
                cmdlist.Add(cmd);
            }
            return ExecuteCommands(cmdlist, null);
        }

        public SqlExecuteResult UpdateCustomerCheckState(List<PLM_CusEntity> customEntityList)
        {
            List<DbCommand> cmdlist = new List<DbCommand>();
            foreach (PLM_CusEntity entity in customEntityList)
            {
                string strSql = @"update Customer set bIsRead_WMS=1,cReader_WMS=:cReader_WMS,dReadDate_WMS=getdate() WHERE cCusCode=:cCusCode ";
                DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
                DataAccess.AddInParameter(cmd, "cReader_WMS", ComDbType.STRING, "汉和信息");
                DataAccess.AddInParameter(cmd, "cCusCode", ComDbType.STRING, entity.COUSTOMER_CODE);
                cmdlist.Add(cmd);
            }
            return ExecuteCommands(cmdlist, null);
        }

        public SqlExecuteResult UpdateVendnrCheckState(List<PLM_VenEntity> vendnrEntityList)
        {
            List<DbCommand> cmdlist = new List<DbCommand>();
            foreach (PLM_VenEntity entity in vendnrEntityList)
            {
                string strSql = @"update Vendor set bIsRead_WMS=1,cReader_WMS=:cReader_WMS,dReadDate_WMS=getdate() WHERE cVenCode=:cVenCode ";
                DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
                DataAccess.AddInParameter(cmd, "cReader_WMS", ComDbType.STRING, "汉和信息");
                DataAccess.AddInParameter(cmd, "cVenCode", ComDbType.STRING, entity.VENDOR_CODE);
                cmdlist.Add(cmd);
            }
            return ExecuteCommands(cmdlist, null);
        }
    }
}