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

namespace HH.WMS.BLL.Check
{
    public class TN_WM_CHECK_LISTBLL : DapperBaseBLL
    {
        #region 获取分页列表
        /// <summary>
        /// 获取分页列表
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public DataTable GetDataTable(dynamic obj)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetDataTable(obj);
            Dictionary<string, string> stockDic = new Dictionary<string, string>();
            Dictionary<string, string> areaDic = new Dictionary<string, string>();
            dt.Columns.Add("CN_S_STOCK_NAME");
            dt.Columns.Add("CN_S_AREA_NAME");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_CODE"].ToString())) //获取仓库名称
                {
                    if (!stockDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_CODE"].ToString()))
                    {
                        TN_AB_STOCKEntity stockentity = CreateDAL<TN_WM_MONGODAL>().GetStockentity("CN_S_STOCK_CODE", dt.Rows[i]["CN_S_STOCK_CODE"].ToString());//获取仓库名称
                        if (stockentity != null)
                        {
                            dt.Rows[i]["CN_S_STOCK_NAME"] = stockentity.CN_S_STOCK_NAME;
                            stockDic.Add(dt.Rows[i]["CN_S_STOCK_CODE"].ToString(), stockentity.CN_S_STOCK_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_STOCK_NAME"] = stockDic[dt.Rows[i]["CN_S_STOCK_CODE"].ToString()];
                    }
                }
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))//获取库区名称
                {
                    if (!areaDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))
                    {
                        AutoBomStockAreaEntity areaentity = CreateDAL<TN_WMS_AREADAL>().GetModel(dt.Rows[i]["CN_S_STOCK_AREA"].ToString());//获取库区名称
                        if (areaentity != null)
                        {
                            dt.Rows[i]["CN_S_AREA_NAME"] = areaentity.CN_S_AREA_NAME;
                            areaDic.Add(dt.Rows[i]["CN_S_STOCK_AREA"].ToString(), areaentity.CN_S_AREA_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_AREA_NAME"] = areaDic[dt.Rows[i]["CN_S_STOCK_AREA"].ToString()];
                    }
                }
            }
            return dt;
        }

        /// <summary>
        /// 获取汇总分页列表
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public DataTable GetGroupDT(string sqlWhere)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetGroupDT(sqlWhere);
            Dictionary<string, string> stockDic = new Dictionary<string, string>();
            Dictionary<string, string> areaDic = new Dictionary<string, string>();
            dt.Columns.Add("CN_S_STOCK_NAME");
            dt.Columns.Add("CN_S_AREA_NAME");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_CODE"].ToString())) //获取仓库名称
                {
                    if (!stockDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_CODE"].ToString()))
                    {
                        TN_AB_STOCKEntity stockentity = CreateDAL<TN_WM_MONGODAL>().GetStockentity("CN_S_STOCK_CODE", dt.Rows[i]["CN_S_STOCK_CODE"].ToString());//获取仓库名称
                        if (stockentity != null)
                        {
                            dt.Rows[i]["CN_S_STOCK_NAME"] = stockentity.CN_S_STOCK_NAME;
                            stockDic.Add(dt.Rows[i]["CN_S_STOCK_CODE"].ToString(), stockentity.CN_S_STOCK_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_STOCK_NAME"] = stockDic[dt.Rows[i]["CN_S_STOCK_CODE"].ToString()];
                    }
                }
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))//获取库区名称
                {
                    if (!areaDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))
                    {
                        AutoBomStockAreaEntity areaentity = CreateDAL<TN_WMS_AREADAL>().GetModel(dt.Rows[i]["CN_S_STOCK_AREA"].ToString());//获取库区名称
                        if (areaentity != null)
                        {
                            dt.Rows[i]["CN_S_AREA_NAME"] = areaentity.CN_S_AREA_NAME;
                            areaDic.Add(dt.Rows[i]["CN_S_STOCK_AREA"].ToString(), areaentity.CN_S_AREA_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_AREA_NAME"] = areaDic[dt.Rows[i]["CN_S_STOCK_AREA"].ToString()];
                    }
                }
            }
            return dt;
        }
        /// <summary>
        /// 获取分页列表
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public DataTable GetDataTableGroup(string sqlWhere, string OrdeBy, int pageSize, int pageIndex)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetDataTableGroup(sqlWhere, OrdeBy, pageSize, pageIndex);
            dt.Columns.Add("CN_S_AREA_NAME");
            Dictionary<string, string> areaDic = new Dictionary<string, string>();
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))//获取库区名称
                {
                    if (!areaDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))
                    {
                        AutoBomStockAreaEntity areaentity = CreateDAL<TN_WMS_AREADAL>().GetModel(dt.Rows[i]["CN_S_STOCK_AREA"].ToString());//获取库区名称
                        if (areaentity != null)
                        {
                            dt.Rows[i]["CN_S_AREA_NAME"] = areaentity.CN_S_AREA_NAME;
                            areaDic.Add(dt.Rows[i]["CN_S_STOCK_AREA"].ToString(), areaentity.CN_S_AREA_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_AREA_NAME"] = areaDic[dt.Rows[i]["CN_S_STOCK_AREA"].ToString()];
                    }
                }
            }
            return dt;
        }


        /// <summary>
        /// 获取列表
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public DataTable GetEntity(string sqlwhere)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetEntity(sqlwhere);
            Dictionary<string, string> stockDic = new Dictionary<string, string>();
            Dictionary<string, string> areaDic = new Dictionary<string, string>();
            dt.Columns.Add("CN_S_STOCK_NAME");
            dt.Columns.Add("CN_S_AREA_NAME");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_CODE"].ToString())) //获取仓库名称
                {
                    if (!stockDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_CODE"].ToString()))
                    {
                        TN_AB_STOCKEntity stockentity = CreateDAL<TN_WM_MONGODAL>().GetStockentity("CN_S_STOCK_CODE", dt.Rows[i]["CN_S_STOCK_CODE"].ToString());//获取仓库名称
                        if (stockentity != null)
                        {
                            dt.Rows[i]["CN_S_STOCK_NAME"] = stockentity.CN_S_STOCK_NAME;
                            stockDic.Add(dt.Rows[i]["CN_S_STOCK_CODE"].ToString(), stockentity.CN_S_STOCK_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_STOCK_NAME"] = stockDic[dt.Rows[i]["CN_S_STOCK_CODE"].ToString()];
                    }
                }
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))//获取库区名称
                {
                    if (!areaDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))
                    {
                        AutoBomStockAreaEntity areaentity = CreateDAL<TN_WMS_AREADAL>().GetModel(dt.Rows[i]["CN_S_STOCK_AREA"].ToString());//获取库区名称
                        if (areaentity != null)
                        {
                            dt.Rows[i]["CN_S_AREA_NAME"] = areaentity.CN_S_AREA_NAME;
                            areaDic.Add(dt.Rows[i]["CN_S_STOCK_AREA"].ToString(), areaentity.CN_S_AREA_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_AREA_NAME"] = areaDic[dt.Rows[i]["CN_S_STOCK_AREA"].ToString()];
                    }
                }
            }
            return dt;
        }


        /// <summary>
        /// 获取列表
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public DataTable GetList(string sqlwhere)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetList(sqlwhere);
            Dictionary<string, string> stockDic = new Dictionary<string, string>();
            Dictionary<string, string> areaDic = new Dictionary<string, string>();
            dt.Columns.Add("CN_S_STOCK_NAME");
            dt.Columns.Add("CN_S_AREA_NAME");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_CODE"].ToString())) //获取仓库名称
                {
                    if (!stockDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_CODE"].ToString()))
                    {
                        TN_AB_STOCKEntity stockentity = CreateDAL<TN_WM_MONGODAL>().GetStockentity("CN_S_STOCK_CODE", dt.Rows[i]["CN_S_STOCK_CODE"].ToString());//获取仓库名称
                        if (stockentity != null)
                        {
                            dt.Rows[i]["CN_S_STOCK_NAME"] = stockentity.CN_S_STOCK_NAME;
                            stockDic.Add(dt.Rows[i]["CN_S_STOCK_CODE"].ToString(), stockentity.CN_S_STOCK_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_STOCK_NAME"] = stockDic[dt.Rows[i]["CN_S_STOCK_CODE"].ToString()];
                    }
                }
                if (!string.IsNullOrEmpty(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))//获取库区名称
                {
                    if (!areaDic.ContainsKey(dt.Rows[i]["CN_S_STOCK_AREA"].ToString()))
                    {
                        AutoBomStockAreaEntity areaentity = CreateDAL<TN_WMS_AREADAL>().GetModel(dt.Rows[i]["CN_S_STOCK_AREA"].ToString());//获取库区名称
                        if (areaentity != null)
                        {
                            dt.Rows[i]["CN_S_AREA_NAME"] = areaentity.CN_S_AREA_NAME;
                            areaDic.Add(dt.Rows[i]["CN_S_STOCK_AREA"].ToString(), areaentity.CN_S_AREA_NAME);
                        }
                    }
                    else
                    {
                        dt.Rows[i]["CN_S_AREA_NAME"] = areaDic[dt.Rows[i]["CN_S_STOCK_AREA"].ToString()];
                    }
                }
            }
            return dt;
        }
        #endregion

        #region 获取盘点结果查询
        /// <summary>
        /// 获取盘点结果查询
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        ///  <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public DataTable GetDataTable(string sqlwhere)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetDataTable(sqlwhere);
            dt.Columns.Add("CN_C_IS_SN");
            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_C_IS_SN"] = ItemEntity == null ? "" : ItemEntity.CN_C_IS_SN;
                        itemDic.Add(row["CN_S_ITEM_CODE"].ToString(), ItemEntity == null ? "" : ItemEntity.CN_C_IS_SN);
                    }
                    else
                    {
                        row["CN_C_IS_SN"] = itemDic[row["CN_S_ITEM_CODE"].ToString()];
                    }
                }
            }
            return dt;
        }

        /// <summary>
        /// 获取盘点结果查询
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        ///  <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public List<TN_WM_CHECK_LISTEntity> GetUnitCheckList(string opNo, string trayCode, string locationCode)
        {
            string sqlWhere = " where CN_S_OP_NO='" + opNo + "' and CN_S_ISCHECK='N' ";
            if (!string.IsNullOrEmpty(trayCode))
            {
                sqlWhere += " AND CN_S_TRAY_CODE = '" + trayCode + "'";
            }
            if (!string.IsNullOrEmpty(locationCode))
            {
                sqlWhere += " AND CN_S_LOCATION_CODE = '" + locationCode + "'";
            }

            List<TN_WM_CHECK_LISTEntity> list = CreateDAL<TN_WM_CHECK_LISTDAL>().GetUnitCheckList(sqlWhere);

            foreach (TN_WM_CHECK_LISTEntity entity in list)
            {
                AutoBomItemEntity ItemEntity = CreateDAL<TN_WMS_ITEMDAL>().GetItemEntity(entity.CN_S_ITEM_CODE);
                entity.CN_C_IS_SN = ItemEntity == null ? "" : ItemEntity.CN_C_IS_SN;
                entity.AuxiliaryUnitList = ItemEntity == null ? null : ItemEntity.AuxiliaryUnitList;
            }
            return list;
        }

        /// <summary>
        /// 获取二次盘点盘点结果查询
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        ///  <history>[HanHe(lt)] CREATED 2018/8/21</history>
        public List<TN_WM_CHECK_LISTEntity> GetChecklist(string sqlwhere)
        {
            List<TN_WM_CHECK_LISTEntity> list = CreateDAL<TN_WM_CHECK_LISTDAL>().GetChecklist(sqlwhere);
            foreach (TN_WM_CHECK_LISTEntity entity in list)
            {
                AutoBomItemEntity ItemEntity = CreateDAL<TN_WMS_ITEMDAL>().GetItemEntity(entity.CN_S_ITEM_CODE);
                entity.CN_C_IS_SN = ItemEntity == null ? "" : ItemEntity.CN_C_IS_SN;
                entity.AuxiliaryUnitList = ItemEntity == null ? null : ItemEntity.AuxiliaryUnitList;
            }
            return list;
        }
        #endregion

        #region 根据盘点查询托盘与物料表
        /// <summary>
        /// 根据盘点查询托盘与物料表
        /// </summary>
        /// <param name="sqlwhere"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/24</history>
        public List<TN_WM_CHECK_LISTEntity> GetTrayitemByOpno(string sqlwhere, string type)
        {
            return CreateDAL<TN_WM_CHECK_LISTDAL>().GetTrayitemByOpno(sqlwhere, type);
        }
        #endregion

        #region 根据托盘编码获取盘点托盘信息
        /// <summary>
        /// 根据托盘编码获取盘点托盘信息
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        ///  <history>[HanHe(lt)] CREATED 2018/8/27</history>
        public DataTable GetTrayCheckByCode(string sqlwhere)
        {
            return CreateDAL<TN_WM_CHECK_LISTDAL>().GetTrayCheckByCode(sqlwhere);
        }
        #endregion

        #region 根据托盘编码获取盘点托盘信息
        /// <summary>
        /// 根据托盘编码获取盘点托盘信息
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        ///  <history>[HanHe(lt)] CREATED 2018/8/27</history>
        public DataTable GetTrayItemByCode(string sqlwhere)
        {
            return CreateDAL<TN_WM_CHECK_LISTDAL>().GetTrayItemByCode(sqlwhere);
        }
        #endregion

        #region  盘点执行
        /// <summary>
        ///盘点执行 
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/29</history>
        public SqlExecuteResult CheckImplementConfirm(TN_WM_CHECK_MSTEntity entitymst, List<TN_WM_CHECK_LISTEntity> entitylist1, List<TN_WM_CHECK_LISTEntity> entitylist2)
        {
            SqlExecuteResult result = new SqlExecuteResult();
            return DAOManager.ExecuteTransaction(trans =>
            {

                //result = CreateDAL<TN_WM_CHECK_MSTDAL>().UpdateMsts(entitymst, trans);//修改主表
                //if (!result.Success)
                //{
                //    DAOManager.RollbackTransaction(trans);
                //    return result;
                //}
                result = CreateDAL<TN_WM_CHECK_LISTDAL>().UpdateQTY(entitylist1, trans);//修改盘点明细数量
                if (!result.Success)
                {
                    DAOManager.RollbackTransaction(trans);
                    return result;
                }

                result = CreateDAL<TN_WM_CHECK_LISTDAL>().Addlist(entitylist2, entitymst.CN_S_MODIFY_BY, DateTime.Now, trans);//新增明细
                if (!result.Success)
                {
                    DAOManager.RollbackTransaction(trans);
                    return result;
                }
                return result;
            });
        }
        #endregion

        #region 根据货位获取托盘信息
        /// <summary>
        /// 根据托盘编码获取盘点托盘信息
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        ///  <history>[HanHe(lt)] CREATED 2018/8/27</history>
        public DataTable GetTrayByLocationCode(string sqlwhere)
        {
            return CreateDAL<TN_WM_CHECK_LISTDAL>().GetTrayByLocationCode(sqlwhere);
        }
        #endregion

        #region  盘点执行
        /// <summary>
        ///盘点执行 
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/29</history>
        //public SqlExecuteResult SaveCheck(JObject obj)
        //{
        //    SqlExecuteResult result = new SqlExecuteResult();
        //    List<TN_WM_CHECK_LISTEntity> entity = JsonConvert.DeserializeObject<List<TN_WM_CHECK_LISTEntity>>(obj.Value
        //        <object>("entitylist").ToString());
        //    List<TN_WM_CHECK_LISTEntity> entitylistadd = entity.Where(o => o.CN_S_OPERATION.Contains("3")).ToList();
        //    List<TN_WM_CHECK_LISTEntity> entitylistUpdate = entity.Where(o => o.CN_S_OPERATION.Contains("1")).ToList();


        //    #region 入库任务
        //    string CN_S_OP_NO = entity[0].CN_S_OP_NO;
        //    string CN_S_TRAY_CODE = entity[0].CN_S_TRAY_CODE;
        //    string orgCode = obj.Value<string>("orgCode");
        //    string orgFlag = obj.Value<string>("orgFlag");
        //    string deviceNo = obj.Value<string>("deviceNo");

        //    string creator = obj.Value<string>("creator");
        //    string creatorBy = obj.Value<string>("creatorby");
        //    string postData = "{\"appCode\":\"AutoWMS\",\"ruleName\":\"" + Constants.Rule_InTaskNo + "\",\"orgId\":\"" + orgCode + "\",\"orgFlag\":\"" + orgFlag + "\"}";
        //    string opNo = WebApiManager.HttpAutoBom_Post("api/BillRule/GenBillNo", postData);

        //    if (string.IsNullOrEmpty(opNo))
        //    {
        //        result.Exception = new Exception("生成单据编码失败!");
        //        return result;
        //    }

        //    List<Device> deviceList = new List<Device>();

        //    //TaskTransferEntity taskentity = new TaskTransferEntity();
        //    //string clValue = SysConfig.GetValue(Constants.CL_WorkPlatform_Model);

        //    //TaskTransferEntity taskTransfer = new TaskTransferEntity()
        //    //{
        //    //    WorkType = Constants.WorkType_UpperReachesIn
        //    //};

        //    //if (clValue.Equals(Constants.CL_WorkPlatform_Model_Value.货位.ToString()))
        //    //    taskTransfer.StartBit = deviceNo;
        //    //if (clValue.Equals(Constants.CL_WorkPlatform_Model_Value.分拣区.ToString()))
        //    //    taskTransfer.StartArea = deviceNo;
        //    //MsgEntity msg = BLLCreator.Create<TaskTransferBLL>().GetWorkPosition(taskTransfer);

        //    //if (!msg.Success)
        //    //{
        //    //    return new SqlExecuteResult() { Exception = new Exception(msg.Msg) };
        //    //}
        //    //List<TN_AB_B_WORK_AREA_PROEntity> pros = (List<TN_AB_B_WORK_AREA_PROEntity>)msg.Data;

        //    string itemcode = "";
        //    if (entity.Count > 0)
        //    {
        //        itemcode = entity[0].CN_S_ITEM_CODE;
        //    }

        //    //调用入库算法-调用调用AutoBom接口，获取空货位
        //    InAlgorEnitty iAe = new InAlgorEnitty()
        //    {
        //        //  stockCode = listCode[0].Trim(),
        //        stockAreaCode = "",//pros[0].CN_S_END_AREA_CODE,
        //        logicCode = "",
        //        locationQty = 1,
        //        trayCode = CN_S_TRAY_CODE,
        //        itemCode = itemcode
        //    };
        //    iAe.lstDevice = deviceList;

        //    var paramString = JsonConvert.SerializeObject(iAe);
        //    // string resultBit = HH.WMS.Common.WebApiManager.HttpWMS_Post("api/Algor/In", paramString);
        //    //  OutResultEntity are = JsonConvert.DeserializeObject<OutResultEntity>(resultBit);
        //    InResultEntity irEresult = BLLCreator.Create<In_AlgorBLL>().In(iAe);
        //    if (!irEresult.Success)
        //    {
        //        result.Exception = new Exception(irEresult.Msg);//货位获取失败！
        //        return result;
        //    }

        //    // 拼接任务实体
        //    List<TN_WM_IN_TASKEntity> taskList = new List<TN_WM_IN_TASKEntity>();
        //    TN_WM_IN_TASKEntity taskEntity = new TN_WM_IN_TASKEntity();

        //    taskEntity.CN_S_TASK_NO = opNo;
        //    taskEntity.CN_S_BILL_NO = "";
        //    taskEntity.CN_S_TRAY_CODE = CN_S_TRAY_CODE;
        //    taskEntity.CN_S_START_AREA = pros[0].CN_S_START_AREA_CODE;
        //    taskEntity.CN_S_START_BIT = deviceNo;
        //    taskEntity.CN_S_END_AREA = pros[0].CN_S_END_AREA_CODE;
        //    taskEntity.CN_S_END_BIT = irEresult.lstLocation[0].locationCode;
        //    taskEntity.CN_S_STATE = "未执行";
        //    taskEntity.CN_T_START = DateTime.Now;
        //    taskEntity.CN_S_BF_TASK_NO = "";
        //    taskEntity.CN_S_AF_TASK_NO = "";
        //    taskEntity.CN_S_STOCK_CODE = "";
        //    taskEntity.CN_S_OP_TYPE = "上架";

        //    taskEntity.CN_GUID = System.Guid.NewGuid().ToString().ToUpper();
        //    taskEntity.CN_S_CREATOR = creator;
        //    taskEntity.CN_S_CREATOR_BY = creatorBy;
        //    taskEntity.CN_S_MODIFY = creator;
        //    taskEntity.CN_S_MODIFY_BY = creatorBy;
        //    taskEntity.CN_T_CREATE = DateTime.Now;
        //    taskEntity.CN_T_MODIFY = DateTime.Now;
        //    taskEntity.CN_S_STATUS = "新建";
        //    taskEntity.CN_S_DEPARTMENT = orgCode;
        //    taskEntity.CN_S_ORGAN = orgCode;
        //    taskEntity.CN_S_CREATE_TYPE = "手工";
        //    taskEntity.CN_S_FROM = "WMS";
        //    taskList.Add(taskEntity);
        //    #endregion

        //    if (entitylistadd.Count > 0)
        //    {
        //        List<string> packlist = entitylistadd.Select(p => p.CN_S_PACK_CODE).ToList();
        //        var packcode = string.Join("','", packlist);
        //        DataTable dt = CreateDAL<TN_WM_B_BARCODEDAL>().GetBarCodeDatatable("AND CN_S_PACKING_CODE in ('" + packcode + "')");

        //        int row = CreateDAL<TN_WM_CHECK_LISTDAL>().GetMaxRow(" where CN_S_OP_NO='" + entitylistadd[0].CN_S_OP_NO + "'");
        //        DateTime tiem = DateTime.Now;
        //        foreach (TN_WM_CHECK_LISTEntity item in entitylistadd)
        //        {
        //            DataView dv = dt.DefaultView;

        //            dv.RowFilter = "CN_S_PACKING_CODE = '" + item.CN_S_PACK_CODE + "'";
        //            DataTable danew = dv.ToTable();
        //            AutoBomItemEntity itemEntity = BLLCreator.Create<TN_WMS_ITEMBLL>().GetItem(danew.Rows[0]["CN_S_ITEM_CODE"].ToString());
        //            item.CN_S_ITEM_CODE = danew.Rows[0]["CN_S_ITEM_CODE"].ToString();
        //            item.CN_S_ITEM_NAME = danew.Rows[0]["CN_S_ITEM_NAME"].ToString();
        //            item.CN_S_ITEM_STATE = danew.Rows[0]["CN_S_ITEM_STATE"].ToString();
        //            item.CN_S_OWNER = danew.Rows[0]["CN_S_OWNER"].ToString();
        //            item.CN_S_DTL_ROW = ++row;
        //            item.CN_S_LOT_NO = danew.Rows[0]["CN_S_LOT_CODE"].ToString();
        //            item.CN_S_FIGURE_NO = itemEntity == null ? "" : itemEntity.CN_S_FIGURE_NO;
        //            item.CN_S_MODEL = itemEntity == null ? "" : itemEntity.CN_S_MODEL;
        //            item.CN_S_MEASURE_UNIT = itemEntity == null ? "" : itemEntity.CN_S_MEASURE_UNIT;
        //            item.CN_S_ISCHECK = "Y";
        //            item.CN_S_ISWIN = "Y";
        //            item.CN_F_QUANTITY = 0;
        //            item.CN_F_CHECK_QTY = Convert.ToDecimal(danew.Rows[0]["CN_S_PACK_NUM"]);
        //            item.CN_S_OPERATOR = creatorBy;
        //            item.CN_T_OPERATE = tiem;

        //        }
        //    }

        //    return DAOManager.ExecuteTransaction(trans =>
        //    {

        //        //给货位扩展表指定任务编码
        //        result = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationTaskNoIn(taskList, trans);
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }

        //        result = CreateDAL<TN_WM_CHECK_LISTDAL>().UpdateQTY(entitylistUpdate, trans);//修改盘点明细数量
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }

        //        result = CreateDAL<TN_WM_CHECK_LISTDAL>().AddChecklist(entitylistadd, trans);//新增明细
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }

        //        //生成入库任务
        //        result = CreateDAL<TN_WM_IN_TASKDAL>().Add(taskList, trans);
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }

        //        //调用方法，下达AMS指令
        //        result = new InfRequest().SendTask(taskList);
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }
        //        return result;
        //    });
        //}
        #endregion



        #region 执行下达任务
        ///// <summary>
        ///// 执行下达任务
        ///// </summary>
        ///// <param name="obj"></param>
        ///// <returns></returns>
        ///// <history>[HanHe(lt)] CREATED 2018/8/30</history>
        //public SqlExecuteResult CheckTask(TN_WM_CHECK_MSTEntity entity)
        //{
        //    SqlExecuteResult result = new SqlExecuteResult();
        //    List<AutoBomStockAreaEntity> areaentity = CreateDAL<TN_WM_MONGODAL>().GetList("", "1");//获取库区

        //    DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetDataTable("where CN_S_OP_NO='" + entity.CN_S_OP_NO + "'");
        //    //
        //    var info = areaentity.Where(w => w.CN_C_IS_AUTO.Contains("Y") && dt.AsEnumerable().Where(d => d.Field<string>("CN_S_STOCK_AREA").Contains(w.CN_S_AREA_CODE)).Any()).Select(s => s.CN_S_AREA_CODE).ToList();
        //    if (info.Any())
        //    {
        //        //判断自动库是否执行
        //        var areaCodelist = areaentity.Where(w => w.CN_C_IS_AUTO.Contains("Y")).Select(s => s.CN_S_AREA_CODE).ToList();
        //        var areaNamelist = areaentity.Where(w => w.CN_C_IS_AUTO.Contains("Y")).Select(s => s.CN_S_AREA_NAME).ToList();
        //        var areaCodes = string.Join("','", areaCodelist);
        //        var areaNames = string.Join(",", areaNamelist);
        //        string sqlWhere = " AND CN_S_OP_NO IN (SELECT CN_S_OP_NO FROM dbo.tn_wm_check_dtl WHERE CN_S_STOCK_AREA IN ('" + areaCodes + "'))";
        //        DataTable dtms = CreateDAL<TN_WM_CHECK_LISTDAL>().GetExist(sqlWhere);
        //        if (dtms.Rows.Count > 0)
        //        {
        //            return new SqlExecuteResult() { Exception = new Exception("库区【" + areaNames + "】已有盘点单在执行！") };
        //        }

        //    }
        //    List<TN_WM_OUT_TASKEntity> list = new List<TN_WM_OUT_TASKEntity>();//定义出库任务
        //    string endBit = "";
        //    //分组库区
        //    var checkarea = from t in dt.AsEnumerable()
        //                    group t by new { CN_S_STOCK_AREA = t.Field<string>("CN_S_STOCK_AREA"), CN_S_STOCK_CODE = t.Field<string>("CN_S_STOCK_CODE") } into m
        //                    select new
        //                    {
        //                        CN_S_STOCK_AREA = m.Key.CN_S_STOCK_AREA,
        //                        CN_S_STOCK_CODE = m.Key.CN_S_STOCK_CODE
        //                    };


        //    foreach (var g in checkarea)
        //    {
        //        var area = areaentity.Where(x => x.CN_S_STOCK_CODE.Contains("" + g.CN_S_STOCK_CODE + "") && x.CN_S_AREA_CODE.Contains("" + g.CN_S_STOCK_AREA + "")).Select(y => y.CN_C_IS_AUTO).ToArray();
        //        if (area.Length > 0)
        //        {
        //            if (area[0] != "Y")
        //            {
        //                continue;
        //            }
        //        }

        //        List<string> endAreas = new List<string>();
        //        HH.WMS.Entitys.Func.MsgEntity msg = new HH.WMS.Entitys.Func.MsgEntity();
        //        TaskTransferEntity taskTransferEntity = new TaskTransferEntity()
        //        {
        //            WorkType = Constants.WorkType_LowerReachesOut,
        //            CirObj = Constants.TU_Tray,
        //            StartArea = g.CN_S_STOCK_AREA//赋值起始库区
        //        };
        //        if (SysConfig.GetValue(Constants.CL_FullTaryNoNeedSorting).Equals("Y"))
        //            taskTransferEntity.IsTrayAll = false;
        //        msg = BLLCreator.Create<TaskTransferBLL>().GetWorkPosition(taskTransferEntity);


        //        if (!msg.Success)
        //        {
        //            return new SqlExecuteResult() { Exception = new Exception("" + msg.Msg + "") };
        //        }
        //        List<TN_AB_B_WORK_AREA_PROEntity> pickAreaPros = (List<TN_AB_B_WORK_AREA_PROEntity>)msg.Data;
        //        if (pickAreaPros.Count == 1)
        //        {
        //            //只存在一个分拣台
        //            if (pickAreaPros[0].CN_C_IS_AUTO == "Y")
        //                endAreas.Add(pickAreaPros[0].CN_S_END_AREA_CODE);
        //        }
        //        else
        //        {
        //            #region 判断分拣任务是否根据策略进行均衡分配
        //            string cfg = SysConfig.GetValue(Constants.CL_PickDivideWorkMode);
        //            if (cfg.Length > 0)
        //            {
        //                switch (cfg)
        //                {
        //                    case "分拣台任务均衡":
        //                        cfg = SysConfig.GetValue(Constants.CL_IsControlPickTaskEquilibrium);
        //                        if (cfg.Length == 0)
        //                        {
        //                            //msg.Success = false;
        //                            //msg.Msg = "请维护是否控制分拣任务均衡策略";
        //                            return new SqlExecuteResult() { Exception = new Exception("请维护是否控制分拣任务均衡策略") };
        //                        }
        //                        else
        //                        {
        //                            if (cfg.Equals("N"))
        //                            {
        //                                endAreas = pickAreaPros.Where(x => x.CN_C_IS_AUTO == "Y").Select(x => x.CN_S_END_AREA_CODE).ToList<string>();
        //                            }
        //                        }; break;
        //                    case "只有一个分拣台":
        //                        endAreas = pickAreaPros.Where(x => x.CN_C_IS_AUTO == "Y").Select(x => x.CN_S_END_AREA_CODE).ToList<string>();
        //                        break;
        //                }
        //            }
        //            else
        //            {
        //                //msg.Success = false;
        //                //msg.Msg = "请维护拣货分工模式策略";
        //                return new SqlExecuteResult() { Exception = new Exception("请维护拣货分工模式策略") };
        //            }
        //            #endregion
        //        }

        //        //分组货位托盘
        //        var groupLocation = from t in dt.AsEnumerable().Where(n => n.Field<string>("CN_S_STOCK_AREA") == "" + g.CN_S_STOCK_AREA + "")
        //                            group t by new { CN_S_LOCATION_CODE = t.Field<string>("CN_S_LOCATION_CODE"), CN_S_TRAY_CODE = t.Field<string>("CN_S_TRAY_CODE") } into m
        //                            select new
        //                            {
        //                                CN_S_LOCATION_CODE = m.Key.CN_S_LOCATION_CODE,
        //                                CN_S_TRAY_CODE = m.Key.CN_S_TRAY_CODE
        //                            };




        //        foreach (var l in groupLocation)
        //        {
        //            string postData = "{\"appCode\":\"AutoWMS\",\"ruleName\":\"" + Constants.Rule_OutTaskNo + "\",\"orgId\":\"" + entity.OrgCode + "\",\"orgFlag\":\"" + entity.OrgFlag + "\"}";
        //            string outTaskNo = WebApiManager.HttpAutoBom_Post("api/BillRule/GenBillNo", postData);
        //            list.Add(new TN_WM_OUT_TASKEntity()
        //            {
        //                CN_S_DEAL_MODE = "系统",
        //                CN_S_START_BIT = l.CN_S_LOCATION_CODE,
        //                CN_S_END_AREA = endBit.Length > 0 ? endAreas[0] : "",
        //                CN_S_END_BIT = endBit,
        //                CN_S_FROM_NO = entity.CN_S_OP_NO,
        //                CN_S_OP_FROM = "盘点",
        //                CN_S_OP_TYPE = "盘点出库",
        //                CN_S_STATE = "未执行",
        //                CN_S_TASK_NO = outTaskNo,
        //                CN_S_TRAY_CODE = l.CN_S_TRAY_CODE,
        //                CN_GUID = Guid.NewGuid().ToString(),
        //                CN_S_CREATOR = entity.CN_S_CREATOR,
        //                CN_S_CREATOR_BY = entity.CN_S_CREATOR_BY,
        //                CN_T_CREATE = DateTime.Now.ToString(),
        //                CN_T_MODIFY = DateTime.Now.ToString(),
        //                END_AREAS = endAreas,
        //                CN_S_CREATE_TYPE = "系统",
        //                CN_N_PRIORITY = 1

        //            });
        //        }

        //    }

        //    return DAOManager.ExecuteTransaction(trans =>
        //    {
        //        if (list.Count > 0)
        //        {
        //            //生成任务
        //            result = CreateDAL<TN_WM_OUT_TASKDAL>().Add(list, trans);
        //            if (!result.Success)
        //            {
        //                DAOManager.RollbackTransaction(trans);
        //                return result;
        //            }

        //            //获取出库任务号与货位
        //            List<string> location = list.Select(x => x.CN_S_TASK_NO + "|" + x.CN_S_START_BIT).ToList();

        //            result = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationStateTask(location, "预出库锁定", trans);
        //            if (!result.Success)
        //            {
        //                DAOManager.RollbackTransaction(trans);
        //                return result;
        //            }
        //        }
        //        //修改
        //        result = CreateDAL<TN_WM_CHECK_MSTDAL>().UpdateMsts(entity, trans);
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }
        //        if (list.Count > 0)
        //        {
        //            result = new InfRequest().SendTask(list);
        //        }
        //        return result;
        //    });
        //}
        #endregion

        #region 根据盘点单更新状态
        /// <summary>
        /// 根据盘点单更新状态
        /// </summary>
        /// <param name="state"></param>
        /// <param name="sqlwhere"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/12/17</history>
        public OperateResult UpdateMstByOpNo(string state, string sqlwhere)
        {
            return CreateDAL<TN_WM_CHECK_MSTDAL>().UpdateMstByOpNo(state, sqlwhere, null);
        }

        #endregion

        #region 获取执行单号
        /// <summary>
        /// 获取执行单号
        /// </summary>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/30</history>
        public DataTable GetopNo()
        {
            //判断自动库是否执行
            List<AutoBomStockAreaEntity> areaentity = CreateDAL<TN_WM_MONGODAL>().GetList("", "1");//获取库区
            var arealist = areaentity.Where(w => w.CN_C_IS_AUTO.Contains("Y")).Select(s => s.CN_S_AREA_CODE).ToList();
            var areaCodes = string.Join("','", arealist);
            string sqlWhere = " AND CN_S_OP_NO in (SELECT CN_S_OP_NO FROM dbo.tn_wm_check_dtl WHERE CN_S_STOCK_AREA IN ('" + areaCodes + "'))";

            return CreateDAL<TN_WM_CHECK_LISTDAL>().GetExist(sqlWhere);
        }
        #endregion

        #region 根据盘点单托盘编码更新
        /// <summary>
        /// 根据盘点单托盘编码更新
        /// </summary>
        /// <param name="entity">实体类</param>
        /// <param name="trans">事务</param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/9/17</history>
        //public SqlExecuteResult UpdateByCode(JObject obj)
        //{
        //    SqlExecuteResult result = new SqlExecuteResult();
        //    #region 入库任务
        //    string CN_S_OP_NO = obj.Value<string>("opNo");
        //    string CN_S_TRAY_CODE = obj.Value<string>("TrayCode");
        //    string orgCode = obj.Value<string>("orgCode");
        //    string orgFlag = obj.Value<string>("orgFlag");
        //    string deviceNo = obj.Value<string>("deviceNo");

        //    string creator = obj.Value<string>("creator");
        //    string creatorBy = obj.Value<string>("creatorby");
        //    string postData = "{\"appCode\":\"AutoWMS\",\"ruleName\":\"" + Constants.Rule_InTaskNo + "\",\"orgId\":\"" + orgCode + "\",\"orgFlag\":\"" + orgFlag + "\"}";
        //    string opNo = WebApiManager.HttpAutoBom_Post("api/BillRule/GenBillNo", postData);

        //    if (string.IsNullOrEmpty(opNo))
        //    {
        //        result.Exception = new Exception("生成单据编码失败!");
        //        return result;
        //    }

        //    List<Device> deviceList = new List<Device>();

        //    TaskTransferEntity taskentity = new TaskTransferEntity();
        //    string clValue = SysConfig.GetValue(Constants.CL_WorkPlatform_Model);

        //    TaskTransferEntity taskTransfer = new TaskTransferEntity()
        //    {
        //        WorkType = Constants.WorkType_UpperReachesIn
        //    };

        //    if (clValue.Equals(Constants.CL_WorkPlatform_Model_Value.货位.ToString()))
        //        taskTransfer.StartBit = deviceNo;
        //    if (clValue.Equals(Constants.CL_WorkPlatform_Model_Value.分拣区.ToString()))
        //        taskTransfer.StartArea = deviceNo;
        //    MsgEntity msg = BLLCreator.Create<TaskTransferBLL>().GetWorkPosition(taskTransfer);

        //    if (!msg.Success)
        //    {
        //        return new SqlExecuteResult() { Exception = new Exception(msg.Msg) };
        //    }
        //    List<TN_AB_B_WORK_AREA_PROEntity> pros = (List<TN_AB_B_WORK_AREA_PROEntity>)msg.Data;

        //    string itemcode = "";
        //    //if (lstQuery.Count > 0)
        //    //{
        //    //    itemcode = lstQuery[0].CN_S_ITEM_CODE;
        //    //}

        //    //调用入库算法-调用调用AutoBom接口，获取空货位
        //    InAlgorEnitty iAe = new InAlgorEnitty()
        //    {
        //        //  stockCode = listCode[0].Trim(),
        //        stockAreaCode = pros[0].CN_S_END_AREA_CODE,// listCode[1].Trim(),
        //        logicCode = "",
        //        locationQty = 1,
        //        trayCode = CN_S_TRAY_CODE,
        //        itemCode = itemcode
        //    };
        //    iAe.lstDevice = deviceList;

        //    var paramString = JsonConvert.SerializeObject(iAe);
        //    // string resultBit = HH.WMS.Common.WebApiManager.HttpWMS_Post("api/Algor/In", paramString);
        //    //  OutResultEntity are = JsonConvert.DeserializeObject<OutResultEntity>(resultBit);
        //    InResultEntity irEresult = BLLCreator.Create<In_AlgorBLL>().In(iAe);
        //    if (!irEresult.Success)
        //    {
        //        result.Exception = new Exception(irEresult.Msg);//货位获取失败！
        //        return result;
        //    }

        //    // 拼接任务实体
        //    List<TN_WM_IN_TASKEntity> taskList = new List<TN_WM_IN_TASKEntity>();
        //    TN_WM_IN_TASKEntity taskEntity = new TN_WM_IN_TASKEntity();

        //    taskEntity.CN_S_TASK_NO = opNo;
        //    taskEntity.CN_S_BILL_NO = "";
        //    taskEntity.CN_S_TRAY_CODE = CN_S_TRAY_CODE;
        //    taskEntity.CN_S_START_AREA = pros[0].CN_S_START_AREA_CODE;
        //    taskEntity.CN_S_START_BIT = deviceNo;
        //    taskEntity.CN_S_END_AREA = pros[0].CN_S_END_AREA_CODE;
        //    taskEntity.CN_S_END_BIT = irEresult.lstLocation[0].locationCode;
        //    taskEntity.CN_S_STATE = "未执行";
        //    taskEntity.CN_T_START = DateTime.Now;
        //    taskEntity.CN_S_BF_TASK_NO = "";
        //    taskEntity.CN_S_AF_TASK_NO = "";
        //    taskEntity.CN_S_STOCK_CODE = "";
        //    taskEntity.CN_S_OP_TYPE = "上架";

        //    taskEntity.CN_GUID = System.Guid.NewGuid().ToString().ToUpper();
        //    taskEntity.CN_S_CREATOR = creator;
        //    taskEntity.CN_S_CREATOR_BY = creatorBy;
        //    taskEntity.CN_S_MODIFY = creator;
        //    taskEntity.CN_S_MODIFY_BY = creatorBy;
        //    taskEntity.CN_T_CREATE = DateTime.Now;
        //    taskEntity.CN_T_MODIFY = DateTime.Now;
        //    taskEntity.CN_S_STATUS = "新建";
        //    taskEntity.CN_S_DEPARTMENT = orgCode;
        //    taskEntity.CN_S_ORGAN = orgCode;
        //    taskEntity.CN_S_CREATE_TYPE = "手工";
        //    taskEntity.CN_S_FROM = "WMS";
        //    taskList.Add(taskEntity);
        //    #endregion
        //    return DAOManager.ExecuteTransaction(trans =>
        //    {
        //        result = CreateDAL<TN_WM_CHECK_LISTDAL>().UpdateByCode(CN_S_OP_NO, CN_S_TRAY_CODE, null);//修改盘点明细数量
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }

        //        //生成入库任务
        //        result = CreateDAL<TN_WM_IN_TASKDAL>().Add(taskList, trans);
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }

        //        //调用方法，下达AMS指令
        //        result = new InfRequest().SendTask(taskList);
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }
        //        return result;
        //    });
        //}
        #endregion

        #region 出库任务状态修改
        /// <summary>
        /// 出库任务状态修改
        /// </summary>
        /// <param name="obj"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/9/25</history>
        //public SqlExecuteResult SetOutTaskByopNo(JObject obj)
        //{
        //    string CN_S_OP_NO = obj.Value<string>("opNo");
        //    string CN_S_TRAY_CODE = obj.Value<string>("TrayCode");
        //    string deviceNo = obj.Value<string>("deviceNo");
        //    string orgId = obj.Value<string>("orgId");
        //    string orgFlag = obj.Value<string>("orgFlag");
        //    string Operator = obj.Value<string>("Operator");
        //    SqlExecuteResult result = new SqlExecuteResult();
        //    return DAOManager.ExecuteTransaction(trans =>
        //    {
        //        result = CreateDAL<TN_WM_OUT_TASKDAL>().SetOutTaskByopNo(CN_S_OP_NO, CN_S_TRAY_CODE, deviceNo, "完成", null);//修改出库任务为完成
        //        if (!result.Success)
        //        {
        //            DAOManager.RollbackTransaction(trans);
        //            return result;
        //        }
        //        DataTable dt = CreateDAL<TN_WM_OUT_TASKDAL>().GetTasklist(" WHERE CN_S_FROM_NO='" + CN_S_OP_NO + "' AND CN_S_TRAY_CODE='" + CN_S_TRAY_CODE + "'");
        //        result = BLL.BLLCreator.Create<TN_WM_OUT_TASKBLL>().Complete(dt.Rows[0]["CN_S_TASK_NO"].ToString(), "完成", orgId, orgFlag, Operator);
        //        return result;
        //    });
        //}
        #endregion

        #region 根据货位获取托盘中物料
        /// <summary>
        /// 根据货位获取托盘中物料
        /// </summary>
        /// <param name="sqlwhere">查询条件</param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2019/1/2</history>
        public DataTable GetTrayitemBylocation(string locationCode)
        {
            DataTable dt = CreateDAL<TN_WM_CHECK_LISTDAL>().GetTrayitemBylocation(locationCode);
            dt.Columns.Add("CN_C_IS_SN");
            foreach (DataRow row in dt.Rows)
            {
                AutoBomItemEntity ItemEntity = CreateDAL<TN_WMS_ITEMDAL>().GetItemEntity(row["CN_S_ITEM_CODE"].ToString());
                row["CN_C_IS_SN"] = ItemEntity == null ? "" : ItemEntity.CN_C_IS_SN;
            }
            return dt;
        }
        #endregion

        #region  PDA盘点执行
        /// <summary>
        ///盘点执行 
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        /// <history>[HanHe(lt)] CREATED 2018/8/29</history>
        public OperateResult SaveCheckPDA(TN_WM_CHECK_MAINEntity entity, RedisUserEntity user)
        {
            List<TN_WM_LOCATION_EXTEntity> GetModel = BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().GetModel("where CN_S_LOCATION_CODE='" + entity.CN_S_LOCATION_CODE + "'");
            if (GetModel.Count == 0)
            {
                return OperateResult.Error("在表TN_WM_LOCATION_EXT中未查询到该货位！");
            }
            AutoBomStockAreaEntity areaModel = DALCreator.Create<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(entity.CN_S_LOCATION_CODE);
            if (areaModel == null)
            {
                //非法的目的货位
                return OperateResult.Error(string.Format("在mongo(TN_AB_B_STOCK_AREA或TN_AB_STOCK_LOCATION表)中未查询到该货位信息！", entity.CN_S_LOCATION_CODE));
            }
            //货位状态：正常
            if (GetModel[0].CN_S_LOCATION_STATE != Constants.Location_State_Normal && GetModel[0].CN_S_LOCATION_STATE != Constants.Location_Check_Lock)
            {
                return OperateResult.Error(string.Format("当前货位状态为{0},不允许盘点保存！", GetModel[0].CN_S_LOCATION_STATE));
            }

            foreach (TN_WM_CHECK_LISTEntity clEntity in entity.row)
            {
                clEntity.CN_GUID = Guid.NewGuid().ToString();
                clEntity.CN_S_STOCK_AREA = areaModel.CN_S_AREA_CODE;
                clEntity.CN_S_STOCK_CODE = areaModel.CN_S_STOCK_CODE;
                clEntity.CN_S_CREATOR = user.CN_S_LOGIN;
                clEntity.CN_S_CREATOR_BY = user.CN_S_NAME;
                clEntity.CN_T_CREATE = DateTime.Now;
                clEntity.CN_S_MODIFY = user.CN_S_LOGIN;
                clEntity.CN_S_MODIFY_BY = user.CN_S_NAME;
                clEntity.CN_T_MODIFY = DateTime.Now;
            }

            OperateResult operateResult = UseTransaction(trans =>
            {
                if (GetModel[0].CN_S_LOCATION_STATE == Constants.Location_State_Normal)
                {
                    operateResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtStateLock(entity.CN_S_LOCATION_CODE, Constants.Location_Check_Lock, Constants.Location_State_Normal, "", "", trans);
                    if (operateResult.AffectedRows == 0)
                    {
                        throw new Exception("盘点锁定货位状态并发冲突,该货位状态可能已经发生变化");
                    }
                    BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(entity.CN_S_LOCATION_CODE, Constants.Location_State_Normal, Constants.Location_Check_Lock, "PDA盘点锁定货位", "PDA", user.CN_S_LOGIN, "", areaModel.CN_S_STOCK_CODE, areaModel.CN_S_AREA_CODE, trans);
                }

                CreateDAL<DapperDAL<TN_WM_CHECK_LISTEntity>>().AddRange(entity.row, trans);
                //更新托盘贮存状态
                if (!string.IsNullOrEmpty(entity.CN_S_USE_STATE))
                {
                    CreateDAL<DapperDAL<TN_WM_B_TRAY_INFOEntity>>().Update(new
                    {
                        CN_S_USE_STATE = entity.CN_S_USE_STATE
                    }, new
                    {
                        CN_S_TRAY_CODE = entity.CN_S_TRAY_CODE
                    }, trans);
                }
            });

            return operateResult;
        }
        #endregion

        #region PDA 盘点锁定解锁货位
        public OperateResult LockLocation(string locationCode, RedisUserEntity userEntity)
        {
            TN_WM_LOCATION_EXTEntity locationExt = BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().GetExtModel(" where CN_S_LOCATION_CODE='" + locationCode + "'");
            if (locationExt == null)
            {
                return OperateResult.Error("在表TN_WM_LOCATION_EXT中未查询到该货位！");
            }
            if (locationExt.CN_S_LOCATION_STATE != Constants.Location_State_Normal)
            {
                return OperateResult.Error(string.Format("当前货位状态为{0},不允许盘点该货位！", locationExt.CN_S_LOCATION_STATE));
            }
            AutoBomStockAreaEntity areaE = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(locationCode);
            if (areaE == null)
            {
                //非法的目的货位
                return OperateResult.Error(string.Format("在mongo(TN_AB_B_STOCK_AREA或TN_AB_STOCK_LOCATION表)中未查询到该货位{0}的库区信息！", locationCode));
            }
            OperateResult operateResult = UseTransaction(trans =>
            {
                operateResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtStateLock(locationCode, Constants.Location_Check_Lock, Constants.Location_State_Normal, "", "", trans);

                if (operateResult.AffectedRows == 0)
                {
                    throw new Exception("锁定货位状态并发冲突,该货位状态可能已经发生变化");
                }
                BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(locationCode, Constants.Location_State_Normal, Constants.Location_Check_Lock, "PDA盘点锁定货位", "PDA", userEntity.CN_S_LOGIN, "", areaE.CN_S_STOCK_CODE, areaE.CN_S_AREA_CODE, trans);
            });
            return operateResult;
        }
        public OperateResult UnLockLocation(string locationCode, RedisUserEntity userEntity)
        {
            TN_WM_LOCATION_EXTEntity locationExt = BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().GetExtModel(" where CN_S_LOCATION_CODE='" + locationCode + "'");
            if (locationExt == null)
            {
                return OperateResult.Error("在表TN_WM_LOCATION_EXT中未查询到该货位！");
            }
            if (locationExt.CN_S_LOCATION_STATE != Constants.Location_Check_Lock)
            {
                return OperateResult.Error(string.Format("当前货位状态为{0},不需要解锁！", locationExt.CN_S_LOCATION_STATE));
            }
            AutoBomStockAreaEntity areaE = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(locationCode);
            if (areaE == null)
            {
                //非法的目的货位
                return OperateResult.Error(string.Format("在mongo(TN_AB_B_STOCK_AREA或TN_AB_STOCK_LOCATION表)中未查询到该货位{0}的库区信息！", locationCode));
            }
            //再检查盘点数据是否已提交，已提交的不能解锁
            List<TN_WM_CHECK_LISTEntity> lstCheck = CreateDAL<TN_WM_CHECK_LISTDAL>().CheckList(locationCode);
            if(lstCheck.Count>0)
            {
                return OperateResult.Error("当前货位的盘点数据已生成单据,不允许解锁！");
            }

            OperateResult operateResult = UseTransaction(trans =>
            {
                CreateDAL<DapperDAL<TN_WM_CHECK_LISTEntity>>().Delete(new { CN_S_LOCATION_CODE = locationCode }, trans);
                operateResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtStateLock(locationCode, Constants.Location_State_Normal, Constants.Location_Check_Lock, "", "", trans);

                if (operateResult.AffectedRows == 0)
                {
                    throw new Exception("解锁货位状态并发冲突,该货位状态可能已经发生变化");
                }
                BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(locationCode, Constants.Location_Check_Lock, Constants.Location_State_Normal, "PDA盘点解锁货位", "PDA", userEntity.CN_S_LOGIN, "", areaE.CN_S_STOCK_CODE, areaE.CN_S_AREA_CODE, trans);
            });
            return operateResult;
        }
        #endregion
        #region PDA 人工搬运锁定解锁货位
        public OperateResult LockLocationManual(string locationCode, RedisUserEntity userEntity)
        {
            TN_WM_LOCATION_EXTEntity locationExt = BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().GetExtModel(" where CN_S_LOCATION_CODE='" + locationCode + "'");
            if (locationExt == null)
            {
                return OperateResult.Error("在表TN_WM_LOCATION_EXT中未查询到该货位！");
            }
            if (locationExt.CN_S_LOCATION_STATE != Constants.Location_State_Normal)
            {
                return OperateResult.Error(string.Format("当前货位状态为{0},不允许搬运该货位！", locationExt.CN_S_LOCATION_STATE));
            }
            AutoBomStockAreaEntity areaE = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(locationCode);
            if (areaE == null)
            {
                //非法的目的货位
                return OperateResult.Error(string.Format("在mongo(TN_AB_B_STOCK_AREA或TN_AB_STOCK_LOCATION表)中未查询到该货位{0}的库区信息！", locationCode));
            }
            OperateResult operateResult = UseTransaction(trans =>
            {
                operateResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtStateLock(locationCode, Constants.Location_Carry_Lock, Constants.Location_State_Normal, "", "", trans);

                if (operateResult.AffectedRows == 0)
                {
                    throw new Exception("锁定货位状态并发冲突,该货位状态可能已经发生变化");
                }
                BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(locationCode, Constants.Location_State_Normal, Constants.Location_Carry_Lock, "PDA人工搬运锁定货位", "PDA", userEntity.CN_S_LOGIN, "", areaE.CN_S_STOCK_CODE, areaE.CN_S_AREA_CODE, trans);
            });
            return operateResult;
        }
        public OperateResult UnLockLocationManual(string locationCode, RedisUserEntity userEntity)
        {
            TN_WM_LOCATION_EXTEntity locationExt = BLLCreator.Create<TN_WM_LOCATION_EXTBLL>().GetExtModel(" where CN_S_LOCATION_CODE='" + locationCode + "'");
            if (locationExt == null)
            {
                return OperateResult.Error("在表TN_WM_LOCATION_EXT中未查询到该货位！");
            }
            if (locationExt.CN_S_LOCATION_STATE != Constants.Location_Carry_Lock)
            {
                return OperateResult.Error(string.Format("当前货位状态为{0},不需要解锁,只能解锁搬运锁定的货位！", locationExt.CN_S_LOCATION_STATE));
            }
            AutoBomStockAreaEntity areaE = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetAreaModelByLocation(locationCode);
            if (areaE == null)
            {
                //非法的目的货位
                return OperateResult.Error(string.Format("在mongo(TN_AB_B_STOCK_AREA或TN_AB_STOCK_LOCATION表)中未查询到该货位{0}的库区信息！", locationCode));
            }
     

            OperateResult operateResult = UseTransaction(trans =>
            {

                operateResult = CreateDAL<TN_WM_LOCATION_EXTDAL>().UpdateLocationExtStateLock(locationCode, Constants.Location_State_Normal, Constants.Location_Carry_Lock, "", "", trans);

                if (operateResult.AffectedRows == 0)
                {
                    throw new Exception("解锁货位状态并发冲突,该货位状态可能已经发生变化");
                }
                BLLCreator.Create<TN_WM_B_LOCATION_CHANGEBLL>().AddStateChange(locationCode, Constants.Location_Carry_Lock, Constants.Location_State_Normal, "PDA人工搬运解锁货位", "PDA", userEntity.CN_S_LOGIN, "", areaE.CN_S_STOCK_CODE, areaE.CN_S_AREA_CODE, trans);
            });
            return operateResult;
        }
        #endregion
    }
}