using HH.WMS.Common;
using HH.WMS.DAL;
using HH.WMS.DAL.Algorithm;
using HH.WMS.DAL.Basic;
using HH.WMS.DAL.External;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using HH.WMS.Entitys.External;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WMS.BLL.External
{
    public class TN_WM_TRANSPORT_TASKBLL : BaseBLL
    {
        #region 查询输送单元扭转指引
        /// <summary>
        /// 查询输送单元扭转指引
        /// </summary>
        /// <param name="ObjNo">对象编码</param>
        /// <param name="ItemCode">物料编码</param>
        /// <param name="pageIndex">分页索引</param>
        /// <param name="pageSize">分页大小</param>
        /// <returns></returns>
        public List<TN_WM_TRANSPORT_TASKEntity> GetSearchList(string strWhere, string strOrder, int pageIndex, int pageSize, out int totalPages, out int totalRows)
        {
            return CreateDAL<TN_WM_TRANSPORT_TASKDAL>().GetSearchList(strWhere, strOrder, pageSize, pageIndex, out  totalPages, out  totalRows);
        }
        public DataTable GetTaskEntity(string taskNo)
        {
            DataTable dt = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().GetTaskEntity(taskNo);
            return dt;
        }
        /// <summary>
        /// 获取流转任务对象列表
        /// </summary>
        /// <param name="strWhere"></param>
        /// <returns></returns>
        /// <history>[HanHe(xdl)] CREATED 2018/04/28</history>
        public List<TN_WM_TRANSPORT_TASKEntity> GetTransportTaskList(string strWhere)
        {
            return CreateDAL<TN_WM_TRANSPORT_TASKDAL>().GetTransportTaskList(strWhere);
        }
        public TN_WM_TRANSPORT_TASKEntity GetTransportTask(string taskNo)
        {
            TN_WM_TRANSPORT_TASKEntity dt = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().GetTransportTask(taskNo);
            return dt;
        }
        #endregion

        #region 改变任务状态 - 开始
        /// <summary>
        /// 改变任务状态 - 开始 
        /// </summary>
        /// <param name="lstGuid">主键</param>
        /// <param name="taskState">状态</param>
        /// <returns></returns>
        public SqlExecuteResult Start(string taskNo, string taskState)
        {
            SqlExecuteResult result = new SqlExecuteResult();

            return DAOManager.ExecuteTransaction(trans =>
            {
                result = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().UpdateState(taskNo, taskState, trans);
                if (!result.Success)
                {
                    DAOManager.RollbackTransaction(trans);
                    return result;
                }
                if (taskState == "执行中")
                {
                    result = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().UpdateStartTime(taskNo, trans);
                    if (!result.Success)
                    {
                        DAOManager.RollbackTransaction(trans);
                        return result;
                    }
                }
                return result;
            });
        }
        #endregion

        /// <summary>
        /// PDA专用 生成任务
        /// </summary>
        /// <param name="startPosition"></param>
        /// <param name="endPosition"></param>
        /// <param name="taskPriority"></param>
        /// <param name="objLocationEntity"></param>
        /// <param name="taskNo"></param>
        /// <param name="SendAms"></param>
        /// <returns></returns>
        public SqlExecuteResult CreateTransTask(string startPosition, string endPosition, string taskPriority, string tranType, TN_WM_B_OBJ_LOCATIONEntity objLocationEntity, string taskNo = "", bool SendAms = true)
        {
            try
            {
                TN_WM_TRANSPORT_TASKEntity transEntity = new TN_WM_TRANSPORT_TASKEntity();
                if (string.IsNullOrEmpty(taskNo))
                {
                    string postData = "{\"appCode\":\"" + Constants.appCode + "\",\"ruleName\":\"" + Constants.Rule_TransTaskNo + "\",\"orgId\":\"0\",\"orgFlag\":\"\"}";
                    taskNo = WebApiManager.HttpAutoBom_Post("api/BillRule/GenBillNo", postData);
                    if (string.IsNullOrEmpty(taskNo))
                    {
                        return new SqlExecuteResult() { Exception = new Exception("未获取到任务号") };
                    }
                }
                transEntity.CN_S_TASK_NO = taskNo;
                transEntity.CN_S_STATE = Constants.TaskStateList[Constants.TaskExecState_NoExec];
                transEntity.CN_T_CREATE = transEntity.CN_T_MODIFY = DateTime.Now.ToString();
                transEntity.CN_S_TASK_TYPE = tranType;

                transEntity.CN_S_CIR_OBJ = "托盘";
                if (objLocationEntity == null)
                {
                    var postData = "{\"appCode\":\"" + Constants.appCode + "\",\"ruleName\":\"" + Constants.VirtualTray + "\",\"orgId\":\"0\",\"orgFlag\":\"\"}";
                    transEntity.CN_S_CIR_OBJ_CODE = WebApiManager.HttpAutoBom_Post("api/BillRule/GenBillNo", postData);

                }
                else
                {
                    transEntity.CN_S_CIR_OBJ_CODE = objLocationEntity.CN_S_OBJ_CODE;
                }
                transEntity.CN_S_START_BIT = startPosition;
                transEntity.CN_S_END_BIT = endPosition;
                transEntity.CN_C_EXECUTED = "N";
                transEntity.CN_N_PRIORITY = int.Parse(taskPriority);
                transEntity.CN_S_PROJECT_CODE = "xme001";
                AutoBomLocationEntity endEntity = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetModel(endPosition);
                if (endEntity != null)
                {
                    transEntity.CN_S_END_AREA = endEntity.CN_S_AREA_CODE;
                }
                else
                {
                    return new SqlExecuteResult() { Exception = new Exception("结束点在mongo中不存在！") };
                }
                AutoBomLocationEntity startEntity = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetModel(startPosition);
                AutoBomStockAreaEntity startArea = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(startPosition);

                if (startEntity != null)
                {
                    transEntity.CN_S_START_AREA = startEntity.CN_S_AREA_CODE;
                }
                else
                {
                    return new SqlExecuteResult() { Exception = new Exception(" 起点在mongo中不存在！") };
                }
                AutoBomStockAreaEntity endArea = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(endPosition);
                transEntity.CN_S_STOCK_CODE = startArea.CN_S_STOCK_CODE;
                transEntity.CN_S_START_AREA_TYPE = startArea.CN_S_STRUCTURE;
                transEntity.CN_S_END_AREA_TYPE = endArea.CN_S_STRUCTURE;
                transEntity.CN_C_START_IS_CONTROL_QTY = startArea.CN_C_IS_CONTROL_QTY;
                transEntity.CN_C_END_IS_CONTROL_QTY = endArea.CN_C_IS_CONTROL_QTY;
                transEntity.CN_S_START_CONTROL_INV = startArea.CN_C_IS_INVENTORY;
                transEntity.CN_S_END_CONTROL_INV = endArea.CN_C_IS_INVENTORY;
                //transEntity.
                // transEntity.
                SqlExecuteResult result = DAOManager.ExecuteTransaction(trans =>
                {
                    result = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().Add(new List<TN_WM_TRANSPORT_TASKEntity>() { transEntity }, trans);
                    if (!result.Success)
                    {
                        DAOManager.RollbackTransaction(trans);
                        return result;
                    }
                    if (startArea.CN_C_IS_CONTROL_QTY.Equals("Y"))
                    {
                        CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtState(startPosition, Constants.Location_State_OutLock, Constants.Location_State_Normal, taskNo, trans);
                        if (!result.Success)
                        {
                            DAOManager.RollbackTransaction(trans);
                            return result;
                        }
                        else
                        {

                            if (result.Row <= 0)
                            {
                                DAOManager.RollbackTransaction(trans);
                                return new SqlExecuteResult() { Exception = new Exception("更新起点货位状态的时候，影响行数为0！请连接管理员") };
                            }
                            else
                            {
                                AutoBomLocationEntity locationModel = DALCreator.Create<TN_WMS_LOCATIONDAL>().GetModel(startPosition);
                                BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(startPosition, "正常", "预出库锁定", "PDA生成任务锁定起点货位", "PDA", "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE);

                            }

                        }
                    }

                    if (endArea.CN_C_IS_CONTROL_QTY.Equals("Y"))
                    {
                        CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtState(endPosition, Constants.Location_State_InLock, Constants.Location_State_Normal, taskNo, null);

                        if (!result.Success)
                        {
                            DAOManager.RollbackTransaction(trans);
                            return result;
                        }
                        else
                        {

                            if (result.Row <= 0)
                            {
                                DAOManager.RollbackTransaction(trans);
                                return new SqlExecuteResult() { Exception = new Exception("更新终点货位状态的时候，影响行数为0！请连接管理员") };
                            }
                            else
                            {
                                AutoBomLocationEntity locationModel = DALCreator.Create<TN_WMS_LOCATIONDAL>().GetModel(endPosition);
                                BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(endPosition, "正常", "预入库锁定", "PDA生成任务锁定终点货位", "PDA", "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE);
                            }

                        }
                    }
                    if (result.Success && SendAms)
                    {
                        result = new InfRequest().SendTask(new List<TN_WM_TRANSPORT_TASKEntity>() { transEntity });
                        Log.Info("CreateTransTask-SendAms", JsonConvert.SerializeObject(result));
                    }

                    return result;
                });
                return result;
            }
            catch (Exception ex)
            {
                Log.Info("CreateTransTask-CreateTransTask", ex.Message + ex.StackTrace.ToString());
                return new SqlExecuteResult() { Exception = ex };
            }
        }





        #region 改道
        /// <summary>
        /// 改道
        /// </summary>
        /// <param name="taskNo"></param>
        /// <param name="location"></param>
        /// <param name="updateArea"></param>
        /// <param name="type"></param>
        /// <returns></returns>
        public SqlExecuteResult UpdateWay(string taskNo, string location, string updateArea, string type)
        {
            SqlExecuteResult result = new SqlExecuteResult();
            TN_WM_TRANSPORT_TASKEntity taskEntity = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().GetTaskByNo(taskNo);
            //待修改的原来的货位
            string oriLocation = type.Equals("start") ? taskEntity.CN_S_START_BIT : taskEntity.CN_S_END_BIT;
            string guid = Guid.NewGuid().ToString();
            return DAOManager.ExecuteTransaction(trans =>
            {
                result = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().UpdateTaskPostion(taskNo, location, updateArea, type, trans);
                if (!result.Success)
                {
                    DAOManager.RollbackTransaction(trans);
                    return result;
                }
                if (result.Success)
                {
                    //将原来的货位置为正常
                    result = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationNormal(oriLocation, "正常", trans);
                    AutoBomLocationEntity locationModel = DALCreator.Create<TN_WMS_LOCATIONDAL>().GetModel(oriLocation);
                    BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(oriLocation, "", "正常", "AMS调用改道接口成功后将原货位设置为正常", "AMS", "", "", locationModel.CN_S_STOCK_CODE, locationModel.CN_S_AREA_CODE);
                    if (!result.Success)
                    {
                        DAOManager.RollbackTransaction(trans);
                        return result;
                    }
                }

                return result;
            });
        }
        #endregion

        public SqlExecuteResult ExecuteTransaction(string taskNo, string taskState)
        {
            var result = DAOManager.ExecuteTransaction(trans => {
                var sqlResult = new SqlExecuteResult();
                var transportTask = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().GetTaskByNo(taskNo);

                //起点、终点是否已经解绑
                //var startIsBindObjLocation = CreateDAL<TN_WM_B_OBJ_LOCATIONDAL>().GetModel(transportTask.CN_S_START_BIT, transportTask.CN_S_CIR_OBJ_CODE);
                //var endIsBindObjLocation = CreateDAL<TN_WM_B_OBJ_LOCATIONDAL>().GetModel(transportTask.CN_S_END_BIT, transportTask.CN_S_CIR_OBJ_CODE);
                //起点、终点是否属于当前任务号
                var startIsCurrentTask = CreateDAL<TN_WM_LOCATION_EXTDAL>().GetModel("  CN_S_LOCATION_CODE='" + transportTask.CN_S_START_BIT + "' AND CN_S_TASK_NO='" + taskNo + "' ");
                var endIsCurrentTask = CreateDAL<TN_WM_LOCATION_EXTDAL>().GetModel("  CN_S_LOCATION_CODE='" + transportTask.CN_S_END_BIT + "' AND CN_S_TASK_NO='" + taskNo + "' ");
                //托盘物料关联
                var trayItemRel = CreateDAL<HH.WMS.DAL.External.TN_WM_B_TRAY_ITEM_RELDAL>().GetItemRelModel(" CN_S_TRAY_CODE='" + transportTask.CN_S_CIR_OBJ_CODE + "' ");

                //更新任务状态
                sqlResult = CreateDAL<TN_WM_TRANSPORT_TASKDAL>().UpdateState(taskNo, taskState, trans);

                if (taskState.Equals("完成"))
                {
                    if (transportTask.CN_S_TASK_TYPE.Equals("入库"))
                    {

                    }
                }
                else if (taskState.Equals("取消"))
                {

                }

                return sqlResult;
            });

            return CreateDAL<ExecuteStateDAL>().ExecuteTransaction(taskNo, taskState);
        }
        public SqlExecuteResult UpdateTaskAuto(string taskNo, string taskState)
        {
            return CreateDAL<TN_WM_TRANSPORT_TASKDAL>().UpdateTaskAuto(taskNo, taskState, null);
        }
    }
}