using HanHe.Utility.Data;
using HH.WMS.Common.External;
using HH.WMS.Entitys.Common;
using HH.WMS.Entitys.External;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Globalization;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WMS.DAL.External
{
    public class ExternalDAL : BaseDAL
    {
        #region 事务 执行存储过程(处理托盘、托盘产品关联、生成任务、设置任务号、更新货位状态)
        /// <summary>
        /// 事务 执行存储过程(处理托盘、托盘产品关联、生成任务、设置任务号、更新货位状态)
        /// </summary>
        /// <param name="transportTask"></param>
        /// <param name="inWorkAreaEntity"></param>
        /// <param name="startAreaClass"></param>
        /// <param name="endAreaClass"></param>
        /// <returns></returns>
        public SqlExecuteResult InWorkAreaTransaction(TN_WM_TRANSPORT_TASKEntity transportTask, InWorkAreaEntity inWorkAreaEntity)
        {
            try
            {
                DbCommand cmd = DataAccess.GetStoredProcCommand("prc_inWorkArea");
                //任务
                DbParameter param = new SqlParameter("tableTransportTask", SqlDbType.Structured); //这个类型很关键
                param.Value = GetWorkAreaTransport(transportTask);
                cmd.Parameters.Add(param);
                //物料集合
                param = new SqlParameter("tableTrayItem", SqlDbType.Structured) { Value = GetInWorkAreaTrayItem(inWorkAreaEntity) };
                cmd.Parameters.Add(param);
                DataAccess.AddInParameter(cmd, "trayCode", ComDbType.STRING, inWorkAreaEntity.trayCode);
                DataAccess.AddInParameter(cmd, "projectCode", ComDbType.STRING, inWorkAreaEntity.projectCode);
                DataAccess.AddInParameter(cmd, "isTransport", DbType.Byte, inWorkAreaEntity.isTransport == "Y" ? Convert.ToByte(true) : Convert.ToByte(false));

                //执行存储过程
                var result = DataAccessExtensive.ExecuteSingleData(DataAccess, cmd, null);
                return new SqlExecuteResult()
                {
                    Success = Convert.ToInt32(result.ItemArray[0]) == 0,
                    Exception = new Exception(result.ItemArray[1].ToString())
                };
            }
            catch (Exception ex)
            {
                return new SqlExecuteResult()
                {
                    Success = false,
                    Exception = ex
                };
            }
        }
        #endregion

        #region 任务（实体转DataTable）
        /// <summary>
        ///  任务（实体转DataTable）
        /// </summary>
        /// <param name="transportTask"></param>
        /// <returns></returns>

        private DataTable GetWorkAreaTransport(TN_WM_TRANSPORT_TASKEntity transportTask)
        {
            DataTable tb = new DataTable();
            tb.Columns.Add("CN_S_TASK_NO", typeof(string));
            tb.Columns.Add("CN_S_CIR_OBJ", typeof(string));
            tb.Columns.Add("CN_S_CIR_OBJ_CODE", typeof(string));
            tb.Columns.Add("CN_S_START_BIT", typeof(string));
            tb.Columns.Add("CN_S_END_BIT", typeof(string));
            tb.Columns.Add("CN_S_PRO_CODE", typeof(string));
            tb.Columns.Add("CN_S_STATE", typeof(string));
            tb.Columns.Add("CN_S_BF_TASK_NO", typeof(string));
            tb.Columns.Add("CN_S_AF_TASK_NO", typeof(string));
            tb.Columns.Add("CN_S_STOCK_CODE", typeof(string));
            tb.Columns.Add("CN_S_START_AREA", typeof(string));
            tb.Columns.Add("CN_S_END_AREA", typeof(string));
            tb.Columns.Add("CN_N_PRIORITY", typeof(int));
            tb.Columns.Add("CN_S_CREATOR", typeof(string));
            tb.Columns.Add("CN_S_CREATOR_BY", typeof(string));
            tb.Columns.Add("CN_T_CREATE", typeof(DateTime));
            tb.Columns.Add("CN_T_MODIFY", typeof(DateTime));
            tb.Columns.Add("CN_S_REMARK", typeof(string));
            tb.Columns.Add("CN_C_IS_AUTO", typeof(string));
            tb.Columns.Add("CN_S_TASK_TYPE", typeof(string));
            tb.Columns.Add("CN_C_START_IS_CONTROL_QTY", typeof(string));
            tb.Columns.Add("CN_C_END_IS_CONTROL_QTY", typeof(string));
            tb.Columns.Add("CN_S_START_AREA_TYPE", typeof(string));
            tb.Columns.Add("CN_S_END_AREA_TYPE", typeof(string));
            tb.Columns.Add("CN_S_START_CONTROL_INV", typeof(string));
            tb.Columns.Add("CN_S_END_CONTROL_INV", typeof(string));

            DataRow row = tb.NewRow();
            row[0] = transportTask.CN_S_TASK_NO;
            row[1] = transportTask.CN_S_CIR_OBJ;
            row[2] = transportTask.CN_S_CIR_OBJ_CODE;
            row[3] = transportTask.CN_S_START_BIT;
            row[4] = transportTask.CN_S_END_BIT;
            row[5] = transportTask.CN_S_PRO_CODE;
            row[6] = transportTask.CN_S_STATE;
            row[7] = transportTask.CN_S_BF_TASK_NO;
            row[8] = transportTask.CN_S_AF_TASK_NO;
            row[9] = transportTask.CN_S_STOCK_CODE;
            row[10] = transportTask.CN_S_START_AREA;
            row[11] = transportTask.CN_S_END_AREA;
            row[12] = transportTask.CN_N_PRIORITY;
            row[13] = transportTask.CN_S_CREATOR;
            row[14] = transportTask.CN_S_CREATOR_BY;
            row[15] = transportTask.CN_T_CREATE;
            row[16] = transportTask.CN_T_MODIFY;
            row[17] = transportTask.CN_S_REMARK;
            row[18] = transportTask.CN_C_IS_AUTO;
            row[19] = transportTask.CN_S_TASK_TYPE;
            row[20] = transportTask.CN_C_START_IS_CONTROL_QTY;
            row[21] = transportTask.CN_C_END_IS_CONTROL_QTY;
            row[22] = transportTask.CN_S_START_AREA_TYPE;
            row[23] = transportTask.CN_S_END_AREA_TYPE;
            row[24] = transportTask.CN_S_START_CONTROL_INV;
            row[25] = transportTask.CN_S_END_CONTROL_INV;
            tb.Rows.Add(row);

            return tb;
        }

        #endregion

        #region 物料集合（实体转DataTable）
        /// <summary>
        ///  物料集合（实体转DataTable）
        /// </summary>
        /// <param name="inWorkAreaEntity"></param>
        /// <returns></returns>
        private DataTable GetInWorkAreaTrayItem(InWorkAreaEntity inWorkAreaEntity)
        {

            DataTable tb = new DataTable();
            tb.Columns.Add("itemCode", typeof(string));
            tb.Columns.Add("itemName", typeof(string));
            tb.Columns.Add("itemPackUnit", typeof(string));
            tb.Columns.Add("qty", typeof(decimal));
            tb.Columns.Add("productionDate", typeof(DateTime));
            tb.Columns.Add("lotNo", typeof(string));
            tb.Columns.Add("itemState", typeof(string));

            if (inWorkAreaEntity.data == null)
            {
                tb.Rows.Add(tb.NewRow());
            }
            else
            {
                foreach (var itemEntity in inWorkAreaEntity.data)
                {
                    DataRow row = tb.NewRow();
                    row[0] = itemEntity.itemCode;
                    row[1] = itemEntity.itemName;
                    row[2] = itemEntity.itemPackUnit;
                    row[3] = itemEntity.qty;
                    row[4] = itemEntity.productionDate ?? DateTime.Now;
                    row[5] = itemEntity.lotNo == null ? "" : itemEntity.lotNo;
                    row[6] = itemEntity.itemState == null ? "" : itemEntity.itemState;
                    tb.Rows.Add(row);
                }
            }
            return tb;
        }

        #endregion


        #region 事务 执行存储过程(处理托盘、托盘产品关联、生成任务、设置任务号、更新货位状态)

        /// <summary>
        /// 事务 执行存储过程(处理托盘、托盘产品关联、生成任务、设置任务号、更新货位状态)
        /// </summary>
        /// <param name="executeOutWorkAreaPara"></param>
        /// <returns></returns>
        public SqlExecuteResult OutWorkAreaTransaction(ExecuteOutWorkAreaPara executeOutWorkAreaPara)
        {
            //TN_WM_TRANSPORT_TASKEntity transportTask, OutWorkAreaEntity outWorkAreaEntity, string startAreaClass, string endAreaClass
            try
            {
                DbCommand cmd = DataAccess.GetStoredProcCommand("prc_outWorkArea");
                //任务
                DbParameter param = new SqlParameter("tableTransportTask", SqlDbType.Structured); //这个类型很关键
                param.Value = GetWorkAreaTransport(executeOutWorkAreaPara.TransportList.FirstOrDefault());
                cmd.Parameters.Add(param);
                //add by liuying 
                DataAccess.AddInParameter(cmd, "projectCode", ComDbType.STRING, executeOutWorkAreaPara.OutWorkAreaEntity.projectCode);
                DataAccess.AddInParameter(cmd, "isTransport", DbType.Byte, executeOutWorkAreaPara.OutWorkAreaEntity.IsTransport == "Y" ? Convert.ToByte(true) : Convert.ToByte(false));
                //执行存储过程
                var result = DataAccessExtensive.ExecuteSingleData(DataAccess, cmd, null);

                return new SqlExecuteResult()
                {
                    Success = Convert.ToInt32(result.ItemArray[0]) == 0,
                    Exception = new Exception(result.ItemArray[1].ToString())
                };
            }
            catch (Exception ex)
            {
                return new SqlExecuteResult()
                {
                    Success = false,
                    Exception = ex
                };
            }
        }
        #endregion

        #region 执行出库

        public void ExecuteOutWorkArea()
        {
            //创建任务
            //更新起点、终点的货位扩展表
            //修改库存
        }

        #endregion 

        #region 物料集合（实体转DataTable）
        /// <summary>
        ///  物料集合（实体转DataTable）
        /// </summary>
        /// <param name="inWorkAreaEntity"></param>
        /// <returns></returns>
        private DataTable GetOutWorkAreaTrayItem(OutWorkAreaEntity inWorkAreaEntity)
        {
            DataTable tb = new DataTable();
            tb.Columns.Add("itemCode", typeof(string));
            tb.Columns.Add("itemName", typeof(string));
            tb.Columns.Add("itemPackUnit", typeof(string));
            tb.Columns.Add("qty", typeof(decimal));
            tb.Columns.Add("steelWireCode", typeof(string));
            tb.Columns.Add("glueStockCode", typeof(string));
            tb.Columns.Add("productionDate", typeof(DateTime));

            foreach (var itemEntity in inWorkAreaEntity.Data)
            {
                DataRow row = tb.NewRow();
                row[0] = itemEntity.ItemCode;
                row[1] = itemEntity.ItemName;
                row[2] = "";
                row[3] = itemEntity.UnitQty;
                row[4] = "";
                row[5] = "";
                row[6] = DateTime.Now.ToString(CultureInfo.InvariantCulture);
                tb.Rows.Add(row);
            }
            return tb;
        }

        #endregion
    }
}