using HH.Redis.ReisModel;
using HH.WMS.BLL.SysMgr;
using HH.WMS.Common;
using HH.WMS.DAL;
using HH.WMS.DAL.Basic;
using HH.WMS.DAL.OutStock;
using HH.WMS.Entitys;
using HH.WMS.Entitys.Basic;
using HH.WMS.Entitys.Common;
using HH.WMS.Entitys.Entitys;
using HH.WMS.Entitys.Entitys.Mes;
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.OutStock
{
    public class TN_WM_OUT_MSTBLL : DapperBaseBLL
    {
        #region 出库订单新增
        /// <summary>
        /// 出库订单新增
        /// </summary>
        /// <param name="outMst"></param>
        /// <returns></returns>
        public OperateResult AddOut(TN_WM_OUT_MSTEntity outMst)
        {
            return UseTransaction(trans =>
            {
                //新增主表
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Add(outMst, trans);
                //新增子表
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().AddRange(outMst.OutDtlList, trans);
            });
        }
        #endregion

        #region 出库订单修改
        /// <summary>
        /// 出库订单修改
        /// </summary>
        /// <param name="outMst"></param>
        /// <returns></returns>
        public OperateResult UpdateOut(TN_WM_OUT_MSTEntity outMst)
        {
            return UseTransaction(trans =>
            {
                //修改主表
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(outMst, new { CN_S_OP_NO = outMst.CN_S_OP_NO }, trans);
                //删除子表
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Delete(new { CN_S_OP_NO = outMst.CN_S_OP_NO }, trans);
                //新增子表
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().AddRange(outMst.OutDtlList, trans);
            });
        }
        #endregion

        #region 删除出库订单
        /// <summary>
        /// 删除出库订单
        /// </summary>
        /// <param name="opNo"></param>
        /// <returns></returns>
        public OperateResult DeleteOut(string opNo)
        {
            return UseTransaction(trans =>
            {
                //删除出库订单主表
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Delete(new { CN_S_OP_NO = opNo }, trans);
                //删除出库订单子表
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Delete(new { CN_S_OP_NO = opNo }, trans);
            });
        }
        #endregion

        #region 获取出库主子表
        /// <summary>
        /// 获取出库主子表
        /// </summary>
        /// <param name="CN_S_OP_NO"></param>
        /// <returns></returns>
        public TN_WM_OUT_MSTEntity GetOutMstAndDtl(string CN_S_OP_NO)
        {
            TN_WM_OUT_MSTEntity outMst = CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().GetSingleEntity(new { CN_S_OP_NO = CN_S_OP_NO });
            List<TN_WM_OUT_DTLEntity> outDtlList = CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().GetList(new { CN_S_OP_NO = CN_S_OP_NO });
            outMst.OutDtlList = outDtlList;
            return outMst;
        }
        #endregion

        #region 修改主子表状态
        /// <summary>
        /// 修改主子表状态
        /// </summary>
        /// <param name="opNo"></param>
        /// <param name="state"></param>
        /// <returns></returns>
        public OperateResult UpdateOutState(string opNo, string state)
        {
            return UseTransaction(trans =>
            {
                //修改主表状态
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = state }, new { CN_S_OP_NO = opNo }, trans);
                //修改子表状态
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = state }, new { CN_S_OP_NO = opNo }, trans);
            });
        }
        #endregion

        #region 获取出库订单所有客户
        /// <summary>
        /// 获取出库订单所有客户
        /// </summary>
        /// <returns></returns>
        public List<TN_WM_OUT_MSTEntity> GetDistinctCustom()
        {
            return CreateDAL<TN_WM_OUT_MSTDAL>().GetDistinctCustom();
        }
        #endregion

        #region 提交
        /// <summary>
        /// 提交
        /// </summary>
        /// <returns></returns>
        public OperateResult SubmitOut(string opNo, List<TN_WM_B_STOCK_QTYEntity> stockList, RedisUserEntity user)
        {
            return UseTransaction(trans =>
            {
                //修改主表状态
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = Constants.State_Submit }, new { CN_S_OP_NO = opNo }, trans);
                //修改子表状态
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = Constants.State_Submit }, new { CN_S_OP_NO = opNo }, trans);
                //库存编辑量上升
                CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockEditingQty(stockList, trans);
                //添加日志
                CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(opNo, Constants.Operate_Sumit, user), trans);
            });
        }
        #endregion

        #region 取消
        /// <summary>
        /// 取消
        /// </summary>
        /// <param name="outMst"></param>
        /// <param name="stockList"></param>
        /// <param name="user"></param>
        /// <returns></returns>
        public OperateResult CancelOut(TN_WM_OUT_MSTEntity outMst, List<TN_WM_B_STOCK_QTYEntity> stockList, RedisUserEntity user)
        {
            return UseTransaction(trans =>
            {
                if (outMst.CN_S_STATE == Constants.State_Submit)
                {
                    CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockEditingQty(stockList, trans);
                }
                if (outMst.CN_S_STATE == Constants.State_Audit)
                {
                    CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockAllocQty(stockList, trans);
                }
                //修改主表状态
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = Constants.State_Cancel }, new { CN_S_OP_NO = outMst.CN_S_OP_NO }, trans);
                //修改子表状态
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = Constants.State_Cancel }, new { CN_S_OP_NO = outMst.CN_S_OP_NO }, trans);
                //添加日志
                CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(outMst.CN_S_OP_NO, Constants.State_Cancel, user), trans);
            });
        }
        #endregion

        #region 驳回
        /// <summary>
        /// 驳回
        /// </summary>
        /// <param name="rejectEntity"></param>
        /// <returns></returns>
        public OperateResult OutReject(TN_WM_B_REJECTEntity rejectEntity, List<TN_WM_B_STOCK_QTYEntity> stockList, RedisUserEntity user)
        {
            return UseTransaction(trans =>
            {
                //修改主表状态
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = Constants.State_Reject }, new { CN_S_OP_NO = rejectEntity.CN_S_FROM_NO }, trans);
                //修改子表状态
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = Constants.State_Reject }, new { CN_S_OP_NO = rejectEntity.CN_S_FROM_NO }, trans);
                //添加驳回记录
                CreateDAL<DapperDAL<TN_WM_B_REJECTEntity>>().Add(rejectEntity, trans);
                //仓库编辑量下降
                CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockEditingQty(stockList, trans);
                //添加日志
                CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(rejectEntity.CN_S_FROM_NO, Constants.Operate_Reject, user), trans);
            });
        }
        #endregion

        #region 审核
        /// <summary>
        /// 审核
        /// </summary>
        /// <param name="opNo"></param>
        /// <param name="stockList"></param>
        /// <returns></returns>
        public OperateResult AuditOut(string opNo, List<TN_WM_B_STOCK_QTYEntity> stockList, List<TN_WM_B_AREA_QTYEntity> areaList, RedisUserEntity user, TN_WM_OUT_MSTEntity outMst, List<TN_WM_B_TRAY_ITEM_MSTEntity> trayItemMstList = null, List<TN_WM_B_TRAY_LOCATIONEntity> trayLocationList = null, List<TN_WM_REDUCE_INVENTORY_MSTEntity> reduceMst = null)
        {
            var operateResult = UseTransaction(trans =>
            {
                //状态置为'已审核'
                string state = Constants.State_Audit;
                string timeStamp = DateTime.Now.ToString("yyyyMMddHHmmssffff");

                if (outMst.CN_S_OP_TYPE.Equals(Constants.OutOpType_WxXs) || outMst.CN_S_OP_TYPE.Equals(Constants.OutOpType_WxXh))
                {
                    //库区量表下降
                    CreateDAL<TN_WM_B_AREA_QTYDAL>().UpdateAreaQty(areaList, trans);
                    state = Constants.State_Completed;
                    //消耗出库直接降库存
                    CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockQty(stockList, trans, timeStamp);


                    //下降托盘物料数据量
                    CreateDAL<TN_WM_SORTING_LISTDAL>().DropTrayItemQty(trayItemMstList, null, trans);
                    //出库单数据
                    if (reduceMst != null)
                    {
                        //出库单子表数据
                        List<TN_WM_REDUCE_INVENTORY_DTLEntity> reduceInventoryDtlList = new List<TN_WM_REDUCE_INVENTORY_DTLEntity>();
                        reduceMst.ForEach(p =>
                        {
                            reduceInventoryDtlList.AddRange(p.DTLEntity);
                        });
                        CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_MSTEntity>>().AddRange(reduceMst, trans);
                        CreateDAL<DapperDAL<TN_WM_REDUCE_INVENTORY_DTLEntity>>().AddRange(reduceInventoryDtlList, trans);
                    }
                }
                else
                {
                    //库存分配量上升
                    CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockAllocQty(stockList, trans, timeStamp);
                }
                //全部为消耗出库直接结束单据 ,状态置为'已完成'
                if (outMst.OutDtlList.Sum(x => x.CN_F_QUANTITY) ==
                    outMst.OutDtlList.Where(x => x.CN_C_AUTO_INOUT).Sum(y => y.CN_F_QUANTITY))
                {
                    state = Constants.State_Completed;
                }
                //存在大件时拆单
                if (outMst.BigOutMst != null)
                {
                    //生成新的大件单据
                    CreateDapperDAL<TN_WM_OUT_MSTEntity>().Add(outMst.BigOutMst, trans);
                    CreateDapperDAL<TN_WM_OUT_DTLEntity>().AddRange(outMst.BigOutMst.OutDtlList, trans);
                    //添加日志
                    CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(outMst.BigOutMst.CN_S_OP_NO, Constants.State_Audit, user), trans);
                    //生成新的非大件的单据
                    if (outMst.OtherOutMst != null)
                    {
                        CreateDapperDAL<TN_WM_OUT_MSTEntity>().Add(outMst.OtherOutMst, trans);
                        CreateDapperDAL<TN_WM_OUT_DTLEntity>().AddRange(outMst.OtherOutMst.OutDtlList, trans);
                        //添加日志
                        CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(outMst.OtherOutMst.CN_S_OP_NO, Constants.State_Audit, user), trans);
                    }
                    //取消当前的单据
                    CreateDapperDAL<TN_WM_OUT_MSTEntity>().Update(new
                    {
                        CN_B_CANCEL = true
                    }, new
                    {
                        CN_S_OP_NO = outMst.CN_S_OP_NO
                    }, trans);
                    //添加日志
                    CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(opNo, Constants.State_Cancel, user), trans);
                }
                else
                {
                    //修改主表状态
                    CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(
                        new
                        {
                            CN_S_STATE = state,
                            CN_S_AUDITOR = user.CN_S_NAME,
                            CN_T_AUDIT_TIME = DateTime.Now,
                            CN_S_MODIFY = user.CN_S_NAME,
                            CN_S_MODIFY_BY = user.CN_S_LOGIN,
                            CN_T_MODIFY = DateTime.Now
                        },
                        new { CN_S_OP_NO = opNo }, trans);
                    //修改子表状态
                    CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = state }, new { CN_S_OP_NO = opNo }, trans);
                }
                //库存编辑量下降
                stockList.ForEach(s => { s.CN_S_TIMESTAMP = timeStamp; });
                CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockEditingQty(stockList, trans);
                //添加日志
                CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(opNo, Constants.Operate_Audit, user), trans);
            });
            if ((outMst.CN_S_OP_TYPE.Equals(Constants.OutOpType_WxXs) || outMst.CN_S_OP_TYPE.Equals(Constants.OutOpType_WxXh)) && operateResult.Success && trayLocationList != null)
            {
                var currentTrayItemMst = CreateDAL<DapperDAL<TN_WM_B_TRAY_ITEM_MSTEntity>>().GetList(new
                {
                    CN_S_TRAY_CODE = trayLocationList.Select(x => x.CN_S_TRAY_CODE).ToList()
                });
                List<TN_WM_B_TRAY_LOCATIONEntity> clearLocations = new List<TN_WM_B_TRAY_LOCATIONEntity>();
                foreach (var trayLocation in trayLocationList)
                {
                    if (!currentTrayItemMst.FindAll(x => x.CN_S_TRAY_CODE.Equals(trayLocation.CN_S_TRAY_CODE)).Any())
                        clearLocations.Add(trayLocation);
                }
                if (clearLocations.Any())
                {
                    operateResult = UseTransaction(trans =>
                    {
                        foreach (var clearLocation in clearLocations)
                        {
                            CreateDAL<TN_WM_SORTING_LISTDAL>().ClearLocationByTrayCode(clearLocation, trans);
                        }
                    });
                }
            }
            return operateResult;
        }
        #endregion

        #region 反审
        /// <summary>
        /// 反审
        /// </summary>
        /// <param name="opNo"></param>
        /// <param name="stockList"></param>
        /// <returns></returns>
        public OperateResult ReAuditOut(string opNo, List<TN_WM_B_STOCK_QTYEntity> stockList, RedisUserEntity user)
        {
            return UseTransaction(trans =>
            {
                //修改主表状态
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Update(new { CN_S_STATE = Constants.State_ReAudit }, new { CN_S_OP_NO = opNo }, trans);
                //修改子表状态
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().Update(new { CN_S_STATE = Constants.State_ReAudit }, new { CN_S_OP_NO = opNo }, trans);
                //库存分配量下降
                string timeStamp = DateTime.Now.ToString("yyyyMMddHHmmssffff");
                CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockAllocQty(stockList, trans, timeStamp);
                //库存编辑量上升
                stockList.ForEach(s => { s.CN_S_TIMESTAMP = timeStamp; });
                CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockEditingQty(stockList, trans);
                //添加日志
                CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(opNo, Constants.Operate_ReAudit, user), trans);
            });

        }
        #endregion

        #region 合单
        /// <summary>
        /// 合单 
        /// </summary>
        /// <param name="newOutMstEntity"></param>
        /// <param name="oldOutMstList"></param>
        /// <returns></returns>
        public OperateResult MergeOrder(TN_WM_OUT_MSTEntity newOutMstEntity, List<TN_WM_OUT_MSTEntity> oldOutMstList, RedisUserEntity user)
        {
            return UseTransaction(trans =>
            {
                //合单的单据状态设 取消,父单据号
                CreateDAL<TN_WM_OUT_MSTDAL>().UpdateMstMerage(oldOutMstList, trans);
                //新增合单的主表
                CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Add(newOutMstEntity, trans);
                //新增合单的子表
                CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().AddRange(newOutMstEntity.OutDtlList, trans);
                //添加日志
                string progRess = Constants.Operate_MergeOrder + "：" + newOutMstEntity.CN_S_OP_NO + ";来源：" + string.Join(",", oldOutMstList.Select(x => x.CN_S_OP_NO));
                CreateDAL<DapperDAL<TN_WM_B_BILL_EXECEntity>>().Add(OutBillExec(newOutMstEntity.CN_S_OP_NO, Constants.Operate_MergeOrder, user, progRess), trans);
            });
        }
        #endregion

        #region 获取订单日志实体
        /// <summary>
        /// 获取订单日志实体
        /// </summary>
        /// <param name="opNo"></param>
        /// <param name="opType"></param>
        /// <param name="user"></param>
        /// <returns></returns>
        public TN_WM_B_BILL_EXECEntity OutBillExec(string opNo, string operate, RedisUserEntity user, string progRess = "")
        {
            return new TN_WM_B_BILL_EXECEntity()
            {
                CN_GUID = Guid.NewGuid().ToString(),
                CN_C_IS_KEY = Constants.Y,
                CN_S_EXECUTOR = user.CN_S_LOGIN,
                CN_S_EXECUTOR_BY = user.CN_S_NAME,
                CN_S_NOTE = "",
                CN_S_OP_NO = opNo,
                CN_S_OP_TYPE = Constants.Out,
                CN_S_PROGRESS = string.IsNullOrEmpty(progRess) ? operate + "：" + opNo : progRess,
                CN_T_EXECUTE = DateTime.Now
            };
        }
        #endregion

        #region 获取出库单主子表信息
        /// <summary>
        /// 获取出库单主子表信息
        /// </summary>
        /// <param name="outNo"></param>
        /// <returns></returns>
        public TN_WM_OUT_MSTEntity GetOut(string outNo)
        {
            if (string.IsNullOrEmpty(outNo))
                throw new Exception("出库单不可为空");
            var outMst = CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().GetSingleEntity(new
            {
                CN_S_OP_NO = outNo
            });
            if (outMst == null)
                throw new Exception("未找到出库单：" + outNo);
            var outDtl = CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().GetList(new
            {
                CN_S_OP_NO = outNo
            });
            if (!outDtl.Any())
                throw new Exception("未找到出库单：" + outNo + "的物料");
            outMst.OutDtlList = outDtl;
            return outMst;
        }
        #endregion

        #region 获取出库单主子表信息
        /// <summary>
        /// 获取出库单主子表信息
        /// </summary>
        /// <param name="outList"></param>
        /// <returns></returns>
        public List<TN_WM_OUT_MSTEntity> GetOutList(List<string> outList)
        {
            var outMstList = CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().GetList(new
            {
                CN_S_OP_NO = outList
            });
            var outDtlList = CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().GetList(new
            {
                CN_S_OP_NO = outList
            });
            foreach (var outMst in outMstList)
            {
                var currentOutDtl = outDtlList.FindAll(x => x.CN_S_OP_NO == outMst.CN_S_OP_NO);
                if (!currentOutDtl.Any())
                    throw new Exception("未找到出库单：" + outMst.CN_S_OP_NO + "的物料");
                outMst.OutDtlList = currentOutDtl;
            }
            return outMstList;
        }
        #endregion

        #region 获取出库单主子表信息
        /// <summary>
        /// 获取出库单主子表信息
        /// </summary>
        /// <param name="outList"></param>
        /// <returns></returns>
        public List<TN_WM_OUT_MSTEntity> GetOutListByWave(string waveNo)
        {
            var outMstList = CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().GetList(new
            {
                CN_S_WAVE_CODE = waveNo
            });
            var outDtlList = CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().GetList(new
            {
                CN_S_OP_NO = outMstList.Select(s => s.CN_S_OP_NO).ToList()
            });
            foreach (var outMst in outMstList)
            {
                var currentOutDtl = outDtlList.FindAll(x => x.CN_S_OP_NO == outMst.CN_S_OP_NO);
                if (!currentOutDtl.Any())
                    throw new Exception("未找到出库单：" + outMst.CN_S_OP_NO + "的物料");
                outMst.OutDtlList = currentOutDtl;
            }
            return outMstList;
        }
        #endregion

        #region K3出库对接
        public OperateResult K3_Out(object Param, IDbTransaction trans)
        {

            //获取策略：是否需要与K3对接
            string isUseK3 = "";// GetStrategy(stockCode, StrategyKey.IsUseK3);

            //吉鑫祥项目需要反馈K3系统 
            if (Constants.SysConfig.APP_NAME == "JXX" && isUseK3.Equals("Y"))
            {
            }


            return OperateResult.Error("未知");
        }



        #endregion

        #region  根据包装箱编码查询数据
        /// <summary>
        /// 根据包装箱编码查询数据
        /// </summary>
        /// <returns></returns>
        /// <history>[HanHe(LT)] CREATED 2019/1/8</history>
        public DataTable GetOutPack(string sqlwhere)
        {
            return CreateDAL<TN_WM_OUT_MSTDAL>().GetOutPack(sqlwhere);
        }


        /// <summary>
        /// 根据包装箱编码查询数据
        /// </summary>
        /// <returns></returns>
        /// <history>[HanHe(LT)] CREATED 2019/1/8</history>
        public DataTable GetBoxdtl(string sqlwhere)
        {
            DataTable dt = CreateDAL<TN_WM_OUT_MSTDAL>().GetBoxdtl(sqlwhere);
            dt.Columns.Add("CN_S_MODEL");
            //dt.Columns.Add("CN_S_MEASURE_UNIT");
            Dictionary<string, string> itemDic = new Dictionary<string, string>();
            foreach (DataRow row in dt.Rows)
            {
                if (!string.IsNullOrEmpty(row["CN_S_ITEM_CODE"].ToString()))
                {
                    if (!itemDic.ContainsKey(row["CN_S_ITEM_CODE"].ToString()))
                    {
                        AutoBomItemEntity ItemEntity = CreateDAL<TN_WMS_ITEMDAL>().GetItemEntity(row["CN_S_ITEM_CODE"].ToString());
                        row["CN_S_MODEL"] = ItemEntity == null ? "" : ItemEntity.CN_S_MODEL;
                        row["CN_S_MEASURE_UNIT"] = ItemEntity == null ? "" : ItemEntity.CN_S_MEASURE_UNIT;
                        itemDic.Add(row["CN_S_ITEM_CODE"].ToString(), ItemEntity == null ? "" : ItemEntity.CN_S_MODEL + "|" + ItemEntity.CN_S_MEASURE_UNIT);

                    }
                    else
                    {
                        var s = itemDic[row["CN_S_ITEM_CODE"].ToString()].Split('|');
                        row["CN_S_MODEL"] = s[0];
                        row["CN_S_MEASURE_UNIT"] = s[1];
                    }
                }
            }
            return dt;
        }
        #endregion

        #region U8服务调用-新增出库单主子表
        /// <summary>
        /// U8服务调用-新增出库单主子表
        /// </summary>
        /// <param name="mstList">出库单主子表集合</param>
        /// <returns></returns>
        public OperateResult AddU8OutData(List<TN_WM_OUT_MSTEntity> mstList)
        {
            #region 组织数据锁定库存，增加分配量
            //待批分数据
            List<BatchesEntity> batchesList = new List<BatchesEntity>();
            foreach (var mst in mstList)
            {
                foreach (var dtl in mst.OutDtlList)
                {
                    batchesList.Add(new BatchesEntity()
                    {
                        ItemCode = dtl.CN_S_ITEM_CODE,
                        ItemState = dtl.CN_S_ITEM_STATE,
                        ItemArrivalLot = dtl.CN_S_LOT_CODE,
                        ItemProductionLot = dtl.CN_S_PRODUCTION_BATCH,
                        Owner = mst.CN_S_OWNER,
                        Qty = dtl.CN_F_QUANTITY,
                        StockCode = mst.CN_S_STOCK_CODE,
                        AreaCode = mst.CN_S_AREA,
                        OpNo = mst.CN_S_OP_NO,
                        OutMst = mst,
                        IsFilter = dtl.CN_C_AUTO_INOUT
                    });
                }
            }
            //当前子表物料库存
            var stockList = BLLCreator.Create<DapperBLL<TN_WM_B_STOCK_QTYEntity>>().GetList(new
            {
                CN_S_ITEM_CODE = batchesList.Select(p => p.ItemCode).ToList()
            });
            //算法策略
            List<string> lstStrate = BLLCreator.Create<TN_WM_B_STRATEGYBLL>().GetStrateListByAreaOrStock("", "", Constants.Out)
                 .OrderByDescending(a => a.CN_N_PRIORITY).Select(o => o.CN_S_CODE).ToList();

            //Log.Info("AddU8OutData mstList", JsonConvert.SerializeObject(mstList));
            //Log.Info("AddU8OutData batchesList", JsonConvert.SerializeObject(batchesList));
            //正批分分配量
            var batchResult = stockList.BatchesStockQty(batchesList, BatchesType.ForwardBatch, StockBatchesField.AllocationQty, lstStrate);
            if (!batchResult.Success) return batchResult;

            #endregion

            OperateResult operateResult = UseTransaction(trans =>
            {
                for (int i = 0; i < mstList.Count; i++)
                {
                    CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Add(mstList[i], trans);

                    CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().AddRange(mstList[i].OutDtlList, trans);
                }
                //增加量表分配量
                CreateDAL<TN_WM_B_STOCK_QTYDAL>().UpdateStockAllocQty(stockList, trans);
            });
            return operateResult;
        }
        #endregion

        #region MES调用-接收出库订单
        public MesDYResponse CreateOutOrder(StockOutCreateRequest request)
        {
            DeliveryOrder deliveryOrder = request.DeliveryOrder;
            if (string.IsNullOrEmpty(deliveryOrder.StockCode))
            {
                var stockList = CreateDAL<TN_AB_B_STOCK_AREADAL>().GetStockList();
                if (stockList.Any())
                {
                    deliveryOrder.StockCode = stockList[0].CN_S_STOCK_CODE;
                }
            }

            TN_WM_OUT_MSTEntity outMst = new TN_WM_OUT_MSTEntity();
            List<TN_WM_OUT_DTLEntity> outDtlList = new List<TN_WM_OUT_DTLEntity>();

            outMst.CN_GUID = Guid.NewGuid().ToString().ToUpper(); //guid
            outMst.CN_S_OP_NO = deliveryOrder.DeliveryOrderCode; //发货通知单号
            outMst.CN_S_MODIFY = deliveryOrder.Creator; //修改人
            outMst.CN_S_MODIFY_BY = deliveryOrder.CreatorBy; //修改人
            outMst.CN_S_OWNER = deliveryOrder.OwnerCode;  //货主
            outMst.CN_T_MODIFY = DateTime.Now;  //修改时间
            outMst.CN_S_STOCK_CODE = deliveryOrder.StockCode;   //仓库编码
            outMst.CN_S_OP_TYPE = deliveryOrder.OrderType;    //业务类型
            outMst.CN_S_CREATOR = deliveryOrder.Creator;    //创建人
            outMst.CN_T_OP_DATE = Convert.ToDateTime(deliveryOrder.CreateTime);    //业务日期
            outMst.CN_S_CREATOR_BY = deliveryOrder.CreatorBy;    //创建人
            outMst.CN_T_CREATE = DateTime.Now;   //创建时间
            outMst.CN_S_STATE = Constants.State_Audit; //,:CN_S_STATE
            outMst.CN_S_DELIVERY_MODE = ""; //提货方式
            outMst.CN_S_VENDOR_NO = deliveryOrder.SupplierCode;  //供应商编码
            outMst.CN_S_VENDOR_NAME = deliveryOrder.SupplierName;//供应商名称
            outMst.CN_S_OP_FROM = "MES";   //MES来源
            outMst.CN_S_FROM_NO = deliveryOrder.FromOrderNo;  //来源单号
            outMst.CN_S_NOTE = deliveryOrder.Note;   //摘要
            outMst.CN_S_WAVE_CODE = "";   //波次
            outMst.CN_S_FORWARDING_WAY = deliveryOrder.TransportMode;   //发运方式
            outMst.CN_S_VENDOR_NO = deliveryOrder.SupplierCode;
            outMst.CN_S_CUSTOMER_NAME = deliveryOrder.SupplierName;


            outMst.CN_S_OPERATOR = deliveryOrder.Operator; //制单人
            outMst.CN_S_AUDITOR = "汉和信息"; //审核人
            outMst.CN_T_AUDIT_TIME = DateTime.Now;  //审核日期
            outMst.CN_S_AUDIT_REMARK = "";  //审核备注
            outMst.CN_S_CONTRACT_NUM = "";  //合同号

            if (request.OrderLines.Count > 0)
            {
                foreach (var orderLine in request.OrderLines)
                {
                    TN_WM_OUT_DTLEntity outDtl = new TN_WM_OUT_DTLEntity();
                    outDtl.CN_GUID = Guid.NewGuid().ToString().ToUpper(); //guid
                    outDtl.CN_S_OP_NO = deliveryOrder.DeliveryOrderCode;   //发货通知单号
                    outDtl.CN_S_CREATOR = deliveryOrder.Creator;    //创建人
                    outDtl.CN_N_ROW_NO = Convert.ToInt32(orderLine.OrderLineNo);        //行号
                    outDtl.CN_S_SERIAL_NO = "";     //产品序列号
                    outDtl.CN_S_CREATOR_BY = deliveryOrder.CreatorBy;    //创建人
                    outDtl.CN_S_ITEM_CODE = orderLine.ItemCode;     //物料编码
                    outDtl.CN_T_CREATE = DateTime.Now;                //创建时间
                    outDtl.CN_S_ITEM_NAME = orderLine.ItemName;     //物料名称
                    outDtl.CN_S_MODIFY = deliveryOrder.Creator;   //修改人
                    outDtl.CN_S_MODIFY_BY = deliveryOrder.CreatorBy;    //修改人
                    outDtl.CN_T_MODIFY = DateTime.Now;               //修改时间
                    outDtl.CN_S_ITEM_STATE = orderLine.itemState;     //物料状态
                    outDtl.CN_S_PRODUCTION_BATCH = orderLine.BatchCode;    //批次
                    outDtl.CN_F_QUANTITY = orderLine.PlanQty;   //数量
                    outDtl.CN_F_ADDUP_DELIVERY_QTY = 0;     //
                    outDtl.CN_S_STATE = Constants.State_Audit;   //状态
                    outDtl.CN_S_NOTE = "";     //备注
                    outDtl.CN_F_ADDUP_OUTSTOCK_QTY = 0;
                    outDtl.CN_F_ADDUP_RETSTOCK_QTY = 0;
                    outDtl.CN_F_SALE_PRICE = 0;   //销售价格
                    outDtl.CN_F_SALE_MONEY = 0;   //销售金额

                    AutoBomItemEntity itemenity = BLLCreator.Create<CoreServer.MongoBLL>().GetItemEntity(orderLine.ItemCode);
                    if (itemenity != null)
                    {
                        outDtl.CN_S_MODEL = itemenity.CN_S_MODEL;  //规格型号
                        outDtl.CN_S_FIGURE_NO = itemenity.CN_S_FIGURE_NO;   //图号
                        outDtl.CN_C_IS_WARRANTY_PARTS = itemenity.CN_C_IS_WARRNTY_PARTS;   //是否质保件
                        outDtl.CN_S_MEASURE_UNIT = itemenity.CN_S_MEASURE_UNIT;     //单位
                    }
                    outDtlList.Add(outDtl);
                }
            }
            OperateResult operateResult = UseTransaction(trans =>
         {
             CreateDAL<DapperDAL<TN_WM_OUT_MSTEntity>>().Add(outMst, trans);

             CreateDAL<DapperDAL<TN_WM_OUT_DTLEntity>>().AddRange(outDtlList, trans);

         });

            MesDYResponse response = new MesDYResponse();
            //出库单创建日期
            response.CreateTime = request.DeliveryOrder.CreateTime;
            //出库单号
            response.DeliveryOrderId = request.DeliveryOrder.DeliveryOrderCode;
            //响应结果：True False
            response.Flag = operateResult.Success.ToString();
            //消息
            if (!operateResult.Success)
                response.Message = operateResult.Msg;
            return response;
        }
        #endregion

        #region 获取非内销的审核单据
        /// <summary>
        /// 获取非内销的审核单据
        /// </summary>
        /// <returns></returns>
        public List<TN_WM_OUT_MSTEntity> GetNeNxAuditedList()
        {
            return CreateDAL<TN_WM_OUT_MSTDAL>().GetNeNxAuditedList();
        }
        #endregion
    }
}