using HH.WMS.BLL.CoreServer;
using HH.WMS.BLL.Interface;
using HH.WMS.Common;
using HH.WMS.DAL;
using HH.WMS.DAL.Basic;
using HH.WMS.DAL.InStock;
using HH.WMS.DAL.OutStock;
using HH.WMS.Entitys;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using HH.WMS.Entitys.Entitys.PrintDataSource;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WMS.BLL.OutStock
{
    public class TN_WM_WAVE_MSTBLL : DapperBaseBLL
    {
        #region 打单
        /// <summary>
        /// 打单
        /// </summary>
        /// <param name="bResult"></param>
        /// <returns></returns>
        public OperateResult CreateBill(BatchesResult bResult)
        {
            return UseTransaction(trans =>
            {
                //生成波次主表
                CreateDAL<DapperDAL<TN_WM_WAVE_MSTEntity>>().Add(bResult.WaveMst, trans);
                //生成波次子表
                CreateDAL<DapperDAL<TN_WM_WAVE_DTLEntity>>().AddRange(bResult.WaveMst.WaveDtlList, trans);
                //修改出库订单主子表状态
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdateState(bResult.OutMstList, trans);
                bResult.OutMstList.ForEach(x => x.CN_S_WAVE_CODE = bResult.WaveMst.CN_S_WAVE_NO);
                //修改波次
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdateWave(bResult.OutMstList, trans);
                //记录仓库库存锁定明细
                CreateDAL<DapperDAL<TN_WM_B_OUTLOCKING_DTLEntity>>().AddRange(bResult.OutLockingDtlList, trans);
                //生成出库单主表
                CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_MSTEntity>>().AddRange(bResult.ReduceInventoryMstList, trans);
                //生成出库单子表
                CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_DTLEntity>>().AddRange(bResult.ReduceInventoryDtlList, trans);
                //生成分拣单
                CreateDAL<DapperDAL<TN_WM_SORTING_LISTEntity>>().AddRange(bResult.SortingList, trans);
                var sortingDtlList = new List<TN_WM_SORTING_DTLEntity>();
                var sortingLocationList = new List<TN_WM_SORTING_LOCATIONEntity>();
                bResult.SortingList.ForEach(p =>
                {
                    sortingDtlList.AddRange(p.SortingDtlList);
                    sortingLocationList.AddRange(p.SortingLocationList);
                });
                //生成分拣单子表
                CreateDAL<DapperDAL<TN_WM_SORTING_DTLEntity>>().AddRange(sortingDtlList, trans);
                ////生成分拣单明细
                CreateDAL<DapperDAL<TN_WM_SORTING_LOCATIONEntity>>().AddRange(sortingLocationList, trans);
                //库区量表分配量上升
                CreateDAL<TN_WM_B_AREA_QTYDAL>().UpdateAreaAlloc(bResult.StockAreaList, trans);
                //托盘物料分配量上升
                CreateDAL<TN_WM_B_TRAY_ITEM_RELDAL>().UpdateTrayItemAllocQty(bResult.TrayItemList, trans);

                foreach (var sortingEntity in bResult.SortingList)
                {
                    //生成任务
                    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

        public OperateResult GenerateSorting(BatchesResult bResult)
        {
            return UseTransaction(trans =>
            {
                //生成波次主表
                CreateDAL<DapperDAL<TN_WM_WAVE_MSTEntity>>().Add(bResult.WaveMst, trans);
                //生成波次子表
                CreateDAL<DapperDAL<TN_WM_WAVE_DTLEntity>>().AddRange(bResult.WaveMst.WaveDtlList, trans);
                //修改出库订单主子表状态和子表数量
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdateStateAndQty(bResult.OutMstList, trans);
                bResult.OutMstList.ForEach(x => x.CN_S_WAVE_CODE = bResult.WaveMst.CN_S_WAVE_NO);
                //修改波次
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdateWave(bResult.OutMstList, trans);
                //记录仓库库存锁定明细
                CreateDAL<DapperDAL<TN_WM_B_OUTLOCKING_DTLEntity>>().AddRange(bResult.OutLockingDtlList, trans);
                //生成出库单主表
                CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_MSTEntity>>().AddRange(bResult.ReduceInventoryMstList, trans);
                //生成出库单子表
                CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_DTLEntity>>().AddRange(bResult.ReduceInventoryDtlList, trans);
                //生成分拣单
                CreateDAL<DapperDAL<TN_WM_SORTING_LISTEntity>>().AddRange(bResult.SortingList, trans);
                var sortingDtlList = new List<TN_WM_SORTING_DTLEntity>();
                var sortingLocationList = new List<TN_WM_SORTING_LOCATIONEntity>();
                bResult.SortingList.ForEach(p =>
                {
                    sortingDtlList.AddRange(p.SortingDtlList);
                    sortingLocationList.AddRange(p.SortingLocationList);
                });
                //生成分拣单子表
                CreateDAL<DapperDAL<TN_WM_SORTING_DTLEntity>>().AddRange(sortingDtlList, trans);
                //生成分拣单明细
                CreateDAL<DapperDAL<TN_WM_SORTING_LOCATIONEntity>>().AddRange(sortingLocationList, trans);
                //库区量表分配量上升
                CreateDAL<TN_WM_B_AREA_QTYDAL>().UpdateAreaAlloc(bResult.StockAreaList, trans);
                //托盘物料分配量上升
                CreateDAL<TN_WM_B_TRAY_ITEM_RELDAL>().UpdateTrayItemAllocQty(bResult.TrayItemList, trans);

                foreach (var sortingEntity in bResult.SortingList)
                {
                    //生成任务
                    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);
                                }
                            }
                        }
                    }
                }
            });
        }

        #region 保存物流
        /// <summary>
        /// 保存物流
        /// </summary>
        /// <param name="param"></param>
        /// <returns></returns>
        public OperateResult SaveWayBill(object param)
        {
            return CreateDAL<TN_WM_WAVE_MSTDAL>().SaveWayBill(param);
        }
        #endregion

        #region 保存打印信息
        /// <summary>
        /// 保存打印信息
        /// </summary>
        /// <param name="outMstList"></param>
        /// <param name="printTask"></param>
        /// <param name="printType"></param>
        /// <param name="outPackList"></param>
        /// <returns></returns>
        public OperateResult SavePrinter(List<TN_WM_OUT_MSTEntity> outMstList, TN_WM_PRINT_TASKEntity printTask, PrintType printType,
            List<TN_WM_B_OUT_PACKEntity> outPackList)
        {
            return UseTransaction(trans =>
            {
                //添加打印任务
                CreateDAL<DapperDAL<TN_WM_PRINT_TASKEntity>>().Add(printTask, trans);
                //更新物流单打印标识
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdatePrint(outMstList, printType, trans);
                //添加包装码
                if (outPackList != null && outPackList.Any())
                    CreateDAL<DapperDAL<TN_WM_B_OUT_PACKEntity>>().AddRange(outPackList, trans);
            });
        }
        #endregion

        #region 保存发货打印任务
        /// <summary>
        /// 保存发货打印任务
        /// </summary>
        /// <param name="outMstList"></param>
        /// <param name="printTask"></param>
        /// <returns></returns>
        public OperateResult SaveInvoicePrint(List<TN_WM_OUT_MSTEntity> outMstList, TN_WM_PRINT_TASKEntity printTask)
        {
            return UseTransaction(trans =>
            {
                //添加打印任务
                CreateDAL<DapperDAL<TN_WM_PRINT_TASKEntity>>().Add(printTask, trans);
                //更新发货单打印标识
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdatePrint(outMstList, PrintType.Invoice, trans);
            });
        }
        #endregion

        #region 确认包装复验
        /// <summary>
        /// 确认包装复验
        /// </summary>
        /// <param name="reviewItems"></param>
        /// <param name="boxDtlList"></param>
        /// <returns></returns>
        public OperateResult ConfirmReview(bool isAllReview, string outNo, List<TN_WM_ORDER_SORTING_RELEntity> reviewItems, List<TN_WM_B_BOX_DTLEntity> boxDtlList)
        {
            return UseTransaction(trans =>
            {
                CreateDAL<DapperDAL<TN_WM_ORDER_SORTING_RELEntity>>().AddRange(reviewItems, trans);
                if (boxDtlList.Any())
                    CreateDAL<DapperDAL<TN_WM_B_BOX_DTLEntity>>().AddRange(boxDtlList, trans);
                if (isAllReview)
                {
                    //修改主表状态
                    CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = Constants.State_Rechecked }, new { CN_S_OP_NO = outNo }, trans);
                    //修改子表状态
                    CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = Constants.State_Rechecked }, new { CN_S_OP_NO = outNo }, trans);
                }
            });
        }
        #endregion

        #region 确认发货
        /// <summary>
        /// 确认发货
        /// </summary>
        /// <param name="opNo"></param>
        /// <returns></returns>
        public OperateResult DeliverGoods(string opNo)
        {
            //K3对接，销售出库
            string isUseK3 = "";
            string stockCode = "";

            var currentOutMst = CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().GetSingleEntity(new
            {
                CN_S_OP_NO = opNo
            });
            if (currentOutMst != null)
                stockCode = currentOutMst.CN_S_STOCK_CODE;

            // 出库发送K3-拼接销售出库实体
            List<K3_SalesDeliveryEntity> K3SalesDeliveryList = new List<K3_SalesDeliveryEntity>();

            //获取策略：是否需要与K3对接
            isUseK3 = GetStrategy(stockCode, StrategyKey.IsUseK3);
            //吉鑫祥项目需要反馈K3系统 
            if (Constants.SysConfig.APP_NAME== "JXX" && isUseK3.Equals("Y"))
            {
                //拼接实体
                List<K3_SalesDeliveryEntity> returnEntity = new InfK3Request().GetSalesDeliveryData(opNo);
                if (returnEntity.Any())
                {
                    K3SalesDeliveryList.AddRange(returnEntity);
                }
            }

            //库存锁定明细
            var outLockDtl = CreateDAL<DapperDAL<TN_WM_B_OUTLOCKING_DTLEntity>>().GetList(new
            {
                CN_S_FROM_NO = opNo
            });

            OperateResult or = UseTransaction(trans =>
            {
                //吉鑫祥项目需要反馈K3系统 
                if (K3SalesDeliveryList.Any())
                {
                    OperateResult re = new InfK3Request().sendK3_Sales_Delivery(K3SalesDeliveryList);
                    if (!re.Success)
                    {
                        throw new Exception(re.Msg);
                    }
                }

                //修改主表状态
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = Constants.State_Completed }, new { CN_S_OP_NO = opNo }, trans);
                //修改子表状态
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = Constants.State_Completed }, new { CN_S_OP_NO = opNo }, trans);
                //降库存
                if (outLockDtl.Any())
                {
                    CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateAllocQtyByLock(Constants.Rule_OutOrder, outLockDtl, trans);
                    //删除锁定明细
                    CreateDAL<TN_WM_B_STOCK_QTYDAL>().DeleteOutLock(outLockDtl, trans);
                }

                //OperateResult or = new OutCommint().OutCommit(currentOutMst.CN_S_OP_TYPE, currentOutMst.CN_S_FROM_NO);
                //OperateResult or = new OutCommint().UpdateRdrecordCheckFlag(currentOutMst.CN_S_FROM_NO, currentOutMst.CN_S_OP_TYPE);
                //or = new OtherSysApi().OutOrderConmit(currentOutMst.CN_S_OP_TYPE, currentOutMst.CN_S_FROM_NO);
                //if (or.Status == ResultStatus.Error)
                //    throw new Exception(or.Msg);
            });
            if (or.Status == ResultStatus.Success)
            {
                or = new OtherSysApi().OutOrderConmit(currentOutMst.CN_S_OP_TYPE, currentOutMst.CN_S_FROM_NO);
                return or;
            }
            return or;
        }
        #endregion

        #region 确认分播
        /// <summary>
        /// 确认分播
        /// </summary>
        /// <param name="waveNo"></param>
        /// <returns></returns>
        public OperateResult ConfirmSowing(string waveNo)
        {
            return UseTransaction(trans =>
            {
                CreateDAL<DapperDAL<TN_WM_WAVE_MSTEntity>>().Update(new
                {
                    CN_S_STATE = Constants.Wave_Sowed
                }, new
                {
                    CN_S_WAVE_NO = waveNo
                }, trans);
                CreateDAL<DapperDAL<TN_WM_WAVE_DTLEntity>>().Update(new
                {
                    CN_S_STATE = Constants.Wave_Sowed
                }, new
                {
                    CN_S_WAVE_NO = waveNo
                }, trans);
            });
        }
        #endregion

        #region 波次列表
        /// <summary>
        /// 波次列表
        /// </summary>
        /// <param name="searchModel"></param>
        /// <returns></returns>
        public OperateResult WaveList(SearchModel searchModel)
        {
            return CreateDAL<TN_WM_WAVE_MSTDAL>().WaveList(searchModel);
        }
        #endregion


        public OperateResult UpdateRdrecordCheckFlag(string opFromNo, string opType)
        {
            OperateResult updateState = new OperateResult() { Success = true, Msg = "" };
            try
            {
                Log.Info("开始进入出库确认更新", opFromNo + "||" + opType);
                string tableName = "";//表名
                switch (opType)
                {
                    case "其他出库":
                        tableName = "Rdrecord09$Rdrecords09";
                        break;
                    case "销售出库":
                        tableName = "Rdrecord32$Rdrecords32";
                        break;
                    default:
                        break;
                }

                Log.Info("确认tableName", tableName);

                //string opDatastr = WebApiManager.HttpWMS_Get("Api/Out/GetOutU8Data?opNo=" + opFromNo);

                //Log.Info("获取WMS数据", opDatastr);

                //OperateResult opData = JsonConvert.DeserializeObject<OperateResult>(opDatastr);

                TN_WM_OUT_MSTEntity outMst =CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().ExecuteSingleEntity<TN_WM_OUT_MSTEntity>("select * from TN_WM_OUT_MST where CN_S_FROM_NO='" + opFromNo + "'");

                if (string.IsNullOrEmpty(tableName))
                {
                    //updateState.Success = false;
                    //updateState.Msg = "更新失败，根据提供的业务类型，未定位到具体表！";
                    return OperateResult.Error("更新失败，根据提供的业务类型，未定位到具体表！");
                }

                Log.Info("解析WMS数据成功，开始更新中间表", "");
                SqlExecuteResult result = BLLCreator.Create<OutDataBLL>().UpdateRdrecordCheckFlag(opFromNo, tableName, outMst);
                //SqlExecuteResult result = new OutDataDAL().UpdateRdrecordCheckFlag(opFromNo, tableName, outMst);
                if (!result.Success)
                {
                    //updateState.Success = false;
                    //updateState.Msg = result.Exception.ToString();
                    Log.Info("出库确认更新", JsonConvert.SerializeObject(updateState));
                    return OperateResult.Error(result.Exception.ToString());
                }
                return updateState;
            }
            catch (Exception ex)
            {
                Log.Info("确认tableName", ex.Message.ToString());
                return OperateResult.Error(ex.Message);
            }

        }
    }
}