using Dapper;
using Estsh.Core.Dapper;
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 CheckFreezeRepository : BaseRepository<SysPart>, ICheckFreezeRepository
    {
        public CheckFreezeRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext)
        {
        }
        #region  成员方法

        /// <summary>
        /// 根据分页条件获取分页数据列表
        /// </summary>
        public Hashtable getListByPage(string cbChkCommand, int userId)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                Hashtable result = new Hashtable();
                DynamicParameters Params = new DynamicParameters();
                Params.Add("@orderNo", cbChkCommand);
                Params.Add("@flag", 0);
                Params.Add("@userID", userId);
                Params.Add("@rVal", null, DbType.String, ParameterDirection.Output, 10);
                Params.Add("@rMsg", null, DbType.String, ParameterDirection.Output, 255);

                List<SysPart> depts = dbConn.Query<SysPart>("sys_check_freezeorthaw", Params, commandType: CommandType.StoredProcedure).ToList();
                result.Add("dataList", depts);
                string rVal = Params.Get<string>("@rVal");
                string rmsg = Params.Get<string>("@rMsg");
                result.Add("totalCount", depts.Count);
                result.Add("rVal", rVal);
                result.Add("rmsg", rmsg);
                return result;
            }
        }

        /// <summary>
        ///盘点单集合
        /// </summary>
        /// <returns>数据集</returns>
        public List<KeyValueResult> GetChkCommandList()
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                StringBuilder querySen = new StringBuilder(1024);
                querySen.AppendLine(" SELECT DISTINCT order_no AS [value],order_no AS [key] FROM dbo.wms_check_stock   WHERE status = 'A' and enabled='Y'  ");
                List<KeyValueResult> result = dbConn.Query<KeyValueResult>(querySen.ToString()).ToList();
                return result;

            }
        }

        /// <summary>
        ///冻结
        /// </summary>
        /// <returns>数据集</returns>
        public List<dynamic> Freeze(string cbChkCommand, string userId)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();

                DynamicParameters Params = new DynamicParameters();
                Params.Add("@orderNo", cbChkCommand);
                Params.Add("@flag", 1);
                Params.Add("@userID", userId);
                Params.Add("@rVal", "");
                Params.Add("@rMsg", "");
                

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

        /// <summary>
        ///解冻
        /// </summary>
        /// <returns>数据集</returns>
        public List<dynamic> Thaw(string cbChkCommand, string userId)
        {
            using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
            {
                dbConn.Open();
                DynamicParameters Params = new DynamicParameters();
                Params.Add("@orderNo", cbChkCommand);
                Params.Add("@flag", 2);
                Params.Add("@userID", userId);
                Params.Add("@rVal", "");
                Params.Add("@rMsg", "");

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

        #endregion  成员方法
    }
}