using HH.WMS.Entitys;
using HH.WMS.Entitys.Common;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using HH.WMS.Entitys.Basic;
using HH.WMS.DAL;
using HH.WMS.Common;
using HH.WMS.BLL;
using HH.WMS.DAL.CoreServer;
using HH.WMS.BLL.Interface;

namespace HH.WMS.BLL.CoreServer
{
    public class WaveServiceBLL : DapperBaseBLL
    {
        #region 生成波次分拣单
        /// <summary>
        /// 生成波次分拣单
        /// </summary>
        /// <param name="r"></param>
        /// <returns></returns>
        public OperateResult WaveCreate(BatchesResult r)
        {
            return UseTransaction(trans =>
            {
                //生成波次主表
                CreateDAL<DapperDAL<TN_WM_WAVE_MSTEntity>>().Add(r.WaveMst, trans);
                //生成波次子表
                CreateDAL<DapperDAL<TN_WM_WAVE_DTLEntity>>().AddRange(r.WaveMst.WaveDtlList, trans);

                if (r.ShortageOutList.Any())
                {
                    //存缺件的生成新的发货单--主表
                    CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().AddRange(r.ShortageOutList, trans);
                    var shortageOutDtl = new List<TN_WM_OUT_DTLEntity>();
                    r.ShortageOutList.ForEach(f => shortageOutDtl.AddRange(f.OutDtlList));
                    //子表
                    CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().AddRange(shortageOutDtl, trans);
                }
                //没有缺货的出库单，要改变状态
                var stayOutMst = r.OutMstList.FindAll(f => !r.ShortageOutList.Exists(e => e.CN_S_OP_NO == f.CN_S_OP_NO));
                if (stayOutMst.Any())
                {
                    //设置状态为待出库,赋值所属波次
                    CreateDAL<WaveServiceDAL>().UpdateOutState(stayOutMst, trans);
                }
                //全部缺货和取消的出库单
                CreateDAL<WaveServiceDAL>().CancelAndAllShortageOut(r.CancelAndAllShortageOut, trans);
                //记录仓库库存锁定明细
                CreateDAL<DapperDAL<TN_WM_B_OUTLOCKING_DTLEntity>>().AddRange(r.OutLockingDtlList, trans);
                //生成减少库存业务主表
                CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_MSTEntity>>().AddRange(r.ReduceInventoryMstList, trans);
                //生成减少库存业务子表
                r.ReduceInventoryMstList.ForEach(p =>
                {
                    //所有出库单子表数据
                    r.ReduceInventoryDtlList.AddRange(p.DTLEntity);
                });
                CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_DTLEntity>>().AddRange(r.ReduceInventoryDtlList, trans);
                //生成分拣单主表
                CreateDAL<DapperDAL<TN_WM_SORTING_LISTEntity>>().AddRange(r.SortingList, trans);
                //分拣单子表数据
                var sortingDtlList = new List<TN_WM_SORTING_DTLEntity>();
                r.SortingList.ForEach(p =>
                {
                    sortingDtlList.AddRange(p.SortingDtlList);
                });
                //生成分拣单子表
                CreateDAL<DapperDAL<TN_WM_SORTING_DTLEntity>>().AddRange(sortingDtlList, trans);
                //库区量表分配量上升
                CreateDAL<WaveServiceDAL>().UpdateAreaAlloc(r.StockAreaList, trans);
            });
        }
        #endregion

        #region 执行分拣
        /// <summary>
        /// 执行分拣
        /// </summary>
        /// <param name="sortingEntity"></param>
        /// <returns></returns>
        public OperateResult ExecuteSorting(TN_WM_SORTING_LISTEntity sortingEntity)
        {
            return UseTransaction(trans =>
            {
                //更新分拣单分拣中
                CreateDAL<DapperDAL<TN_WM_SORTING_LISTEntity>>().Update(new
                {
                    CN_S_STATE = Constants.Sorting_Being
                }, new
                {
                    CN_S_SORTING_NO = sortingEntity.CN_S_SORTING_NO
                }, trans);
                //更新波次状态为分拣中
                CreateDAL<DapperDAL<TN_WM_WAVE_MSTEntity>>().Update(new
                {
                    CN_S_STATE = Constants.Sorting_Being
                }, new
                {
                    CN_S_WAVE_NO = sortingEntity.CN_S_FROM_NO
                }, trans);
                //增加分拣明细
                CreateDAL<DapperDAL<TN_WM_SORTING_LOCATIONEntity>>().AddRange(sortingEntity.SortingLocationList, trans);
                if (sortingEntity.Tasks.Any())
                {
                    //增加出库任务
                    CreateDAL<DapperDAL<TN_WM_TASKEntity>>().AddRange(sortingEntity.Tasks, trans);
                    //起点置为预出库锁定,终点预入库锁定
                    foreach (var task in sortingEntity.Tasks)
                    {
                        if (task.EndAreaEntity.CN_C_IS_AUTO == Constants.Y)
                        {
                            CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().Update(new
                            {
                                CN_S_LOCATION_STATE = Constants.Location_State_OutLock
                            }, new
                            {
                                CN_S_LOCATION_CODE = task.CN_S_START_BIT
                            }, trans);
                            //存在终点
                            if (!string.IsNullOrEmpty(task.CN_S_END_BIT))
                            {
                                CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().Update(new
                                {
                                    CN_S_LOCATION_STATE = Constants.Location_State_InLock
                                }, new
                                {
                                    CN_S_LOCATION_CODE = task.CN_S_END_BIT
                                }, trans);

                                //发送ams任务
                                var sendAms = BLLCreator.Create<OtherSysApi>().SendAmsTask(task);
                                if (!sendAms.Success)
                                    throw new Exception(sendAms.Msg);
                            }
                        }
                    }
                }
            });
        }
        #endregion

        #region 执行任务
        /// <summary>
        /// 执行任务
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public OperateResult ExecuteTask(TN_WM_TASKEntity entity)
        {
            return UseTransaction(trans =>
            {
                //设置终点货位
                CreateDAL<DapperDAL<TN_WM_TASKEntity>>().Update(new
                {
                    CN_S_END_BIT = entity.CN_S_END_BIT,
                    CN_B_SENDAMS = true,
                }, new
                {
                    CN_S_TASK_NO = entity.CN_S_TASK_NO
                }, trans);
                //货位状态
                if (entity.EndAreaEntity.CN_C_IS_AUTO == Constants.Y)
                {
                    CreateDAL<DapperDAL<TN_WM_LOCATION_EXTEntity>>().Update(new
                    {
                        CN_S_LOCATION_STATE = Constants.Location_State_InLock
                    }, new
                    {
                        CN_S_LOCATION_CODE = entity.CN_S_END_BIT
                    }, trans);
                }
                //发送ams任务
                var sendAms = BLLCreator.Create<OtherSysApi>().SendAmsTask(entity);
                if (!sendAms.Success)
                    throw new Exception(sendAms.Msg);
            });
        }
        #endregion
    }
}