using Dapper;
using Estsh.Core.Dapper;
using Estsh.Core.IRepositories;
using Estsh.Core.Model.Result;
using Estsh.Core.Models;
using Estsh.Core.Repository.IRepositories;
using System.Collections;
using System.Data;
using System.Text;

/***************************************************************************************************
*
* 更新人：sitong.dong
* 描述：盘点单生产
* 修改时间：2022.06.22
* 修改日志：系统迭代升级
*
**************************************************************************************************/
namespace Estsh.Core.Repositories
{

    public class CheckStockDiffRepository : BaseRepository<WmsCheckStockList>, ICheckStockDiffRepository
    {
        public CheckStockDiffRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext)
        {
        }
        #region  成员方法

        /// <summary>
        /// 根据分页条件获取分页数据列表
        /// </summary>
        public Hashtable GetTotalData(string orderNo, string partNo)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                Hashtable result = new Hashtable();
                DynamicParameters value = new DynamicParameters();
                value.Add("@orderNo", orderNo);
                value.Add("@partNo", partNo);
                List<WmsCheckStockList> depts = dbConn.Query<WmsCheckStockList>("sys_check_difftotal", value, commandType: CommandType.StoredProcedure).ToList();
                result.Add("dataList", depts);
                result.Add("totalCount", depts.Count);
                return result;
            }
        }

        /// <summary>
        ///盘点单集合
        /// </summary>
        /// <returns>数据集</returns>
        public List<KeyValueResult> GetChkNo(string dtpDate)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("SELECT DISTINCT order_no AS [value],order_no AS [key] FROM dbo.wms_check_stock a ");
                SqlStringBuilder.Append("LEFT JOIN sap_cyco b ON a.order_no = CAST(b.IBLNR AS VARCHAR) + CAST(b.GJAHR AS VARCHAR) ");
                SqlStringBuilder.Append("WHERE a.create_time = @createDate AND b.XLOEK <> 'X' and a.enabled='Y'  ");
                DynamicParameters ht = new DynamicParameters();
                ht.Add("@createDate", dtpDate);

                List<KeyValueResult> result = dbConn.Query<KeyValueResult>(SqlStringBuilder.ToString(), ht).ToList();
                return result;
            }
        }

        /// <summary>
        ///盘点差异类型
        /// </summary>
        /// <returns>数据集</returns>
        public List<KeyValueResult> GetDiffType()
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append(" SELECT enum_value AS [key] , enum_desc AS [value] FROM dbo.sys_enum WHERE enum_type = 'g_check_diff_type' and enabled='Y'  ORDER BY enum_value ");

                List<KeyValueResult> result = dbConn.Query<KeyValueResult>(SqlStringBuilder.ToString()).ToList();
                return result;
            }
        }

        /// <summary>
        ///零件号
        /// </summary>
        /// <returns>数据集</returns>
        public List<KeyValueResult> GetPartNo()
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append(" SELECT part_id AS [value] , part_no  AS [key]  FROM sys_part WHERE ENABLED = 'Y' and enabled='Y'  AND part_type = '0' ORDER BY part_no ");

                List<KeyValueResult> result = dbConn.Query<KeyValueResult>(SqlStringBuilder.ToString()).ToList();
                return result;
            }
        }

        /// <summary>
        ///
        /// </summary>
        /// <returns>数据集</returns>
        public List<dynamic> CreateChkNo(string cbChkCommand, string userId)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
    
                DynamicParameters Params = new DynamicParameters();
                Params.Add("@orderNo", cbChkCommand);
                Params.Add("@userId", userId);

                List<dynamic> depts = dbConn.Query<dynamic>("sys_check_createchk", Params, commandType: CommandType.StoredProcedure).ToList();
                return depts;
            }
        }

        #endregion  成员方法
    }
}