SX-WMS/wms.service/Service/PTService.cs

using AutoMapper;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Text;
using wms.dto;
using wms.dto.response;
using wms.dto.response.pt;
using wms.service.IService;
using wms.sqlsugar;
using wms.sqlsugar.model;
using wms.sqlsugar.model.pt;
using wms.util.Check;
using wms.util.Ext;
using System.Linq;
using Newtonsoft.Json;
using Microsoft.Extensions.Logging;
using wms.util;
using wms.dto.request.pt;
using wms.dataservice.IDataSetvice;
using wms.dataservice;
using wms.dto.request.pt.dto;
using wms.dto.response.pt.dto;
using wms.util.Http;
using wms.dataservice.DataService;
using NPOI.SS.Formula.Functions;
using wms.dto.request;
using wms.dto.request.share;
using Org.BouncyCastle.Asn1.Ocsp;
using Castle.Core.Internal;
using WCS.Entity;

namespace wms.service.Service
{
    public class PTService : IPTService
    {
        private readonly IMapper _mapper;
        private readonly ILogger<PTService> _logger;
        private readonly IPTDataService _iptDataService;
        public PTService(IMapper mapper, ILogger<PTService> logger, IPTDataService iptDataService)
        {
            _mapper = mapper;
            _logger = logger;
            _iptDataService = iptDataService;
        }
        Repository<ptBaseContainer> _ptbaseContInfo => new Repository<ptBaseContainer>();
        Repository<ptSysConfig> _sysconfigrepository => new Repository<ptSysConfig>();
        Repository<ptBaseMater> _materrepository => new Repository<ptBaseMater>();
        RepositoryTask<ptWCS_TaskInfo> _ptwcsTaskinfo => new RepositoryTask<ptWCS_TaskInfo>();
        Repository<ptBaseWarehouse> _baseWareHouserepository => new Repository<ptBaseWarehouse>();
        Repository<ptBaseWareLocation> _baseWareLocationrepository => new Repository<ptBaseWareLocation>();
        Repository<ptBillDocsinfo> _docrepository => new Repository<ptBillDocsinfo>();
        Repository<ptBillPushinfo> _ptbillPushinfo => new Repository<ptBillPushinfo>();
        RepositoryTask<ptWCS_TaskOld> _ptwcsTaskold => new RepositoryTask<ptWCS_TaskOld>();
        Repository<ptSysJob> _sysJobrepository => new Repository<ptSysJob>();
        Repository<ptSysJobApiRelation> _sysJobApirepository => new Repository<ptSysJobApiRelation>();
        Repository<ptBillInvFlow> _ptBillInvFlow => new Repository<ptBillInvFlow>();
        Repository<ptBillInvnow> _ptbillInvnow => new Repository<ptBillInvnow>();
        Repository<ptBillInvinit> _ptbillInvinit => new Repository<ptBillInvinit>();
        RepositoryTask<ptWCS_TaskDtl> _ptwcsTaskdtl => new RepositoryTask<ptWCS_TaskDtl>();
        Repository<ptBillMesmiddle> _ptbillmes => new Repository<ptBillMesmiddle>();
        //Repository<ptBillPboxrule> _ptBillLocationMap => new Repository<ptBillPboxrule>();
        ITenant _db => SqlSugarHelper.Db;//处理事务

        /// <summary>
        /// 获取配置内容信息
        /// </summary>
        /// <param name="code">配置表code值</param>
        /// <returns></returns>
        public string GetSysConfigContentByCode(string code)
        {
            //先读缓存
            var cacheContent = RedisHelper.Get("sys_config" + code);
            if (!string.IsNullOrEmpty(cacheContent))
            {
                return cacheContent;
            }
            var sysconf = _sysconfigrepository.GetSingle(p => p.Code == code);
            if (sysconf == null)
            {
                throw new Exception("数据表没有配置" + code);
            }
            var content = sysconf.SContent;
            string sysname = sysconf.Default1;//所属系统mes/erp
            RedisHelper.Set("sys_config" + code, content + "|" + sysname);
            return content;
        }

        /// <summary>
        /// 获取配置信息
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public ptSysConfig GetSysConfigByCode(string code)
        {
            //Repository<dynamic> _billdtrepository = new Repository<dynamic>();
            return _sysconfigrepository.GetSingle(p => p.Code == code);
        }


        /// <summary>
        /// 获取物料信息
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public ptBaseMater GetBaseMaterByExpression(Expression<Func<ptBaseMater, bool>> WhereExpression)
        {
            return _materrepository.GetSingle(WhereExpression);
        }
        /// <summary>
        /// 获取配置信息
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public ptSysConfig GetSysConfigByExpression(Expression<Func<ptSysConfig, bool>> WhereExpression)
        {
            return _sysconfigrepository.GetSingle(WhereExpression);
        }

        /// <summary>
        /// 获取反馈信息
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public List<ptBillPushinfo> GetBillFeedbackList()
        {
            return _ptbillPushinfo.GetList(p => p.PostResult != 1 && p.PostQty <= 5).OrderBy(p => p.AddTime).Take(1).ToList();
        }
        public bool UpdatePuchinfoModelColumns(UpdateModelColumns<ptBillPushinfo> updateModel)
        {
            return _ptbillPushinfo.Update(updateModel.Columns, updateModel.WhereExpression);
        }
        /// <summary>
        /// 更新SysConfig表字段
        /// </summary>
        /// <param name="updateModel"></param>
        /// <returns></returns>
        public bool UpdateSysConfigModelColumns(UpdateModelColumns<ptSysConfig> updateModel)
        {
            return _sysconfigrepository.Update(updateModel.Columns, updateModel.WhereExpression);
        }
        public bool SyncMaterInfo(List<PTSyncMaterInfoResponseItem> ResData)
        {
            foreach (var item in ResData)
            {
                if (_materrepository.IsAny(p => p.Code == item.MatCode))
                {
                    _materrepository.UpdateModelColumns(p => new ptBaseMater() { IsHold = item.IsHold, HoldDuration = item.HoldDuration },
                       p => p.Code == item.MatCode);
                }
                else
                {
                    var model = _mapper.Map<ptBaseMater>(item);
                    _materrepository.Insert(model);
                }
            }
            return true;
        }
        public SRes PurchaseBillTrans(PurchaseBillTransReqest request)
        {
            var result = new SRes();
            if (string.IsNullOrEmpty(request.BillCode))
            {
                result.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                result.ResMsg = "单号" + ResponseStatusCodeEnum.ErrParamNotNull.GetDescription();
                return result;
            }
            if (!request.ListInfo.Any())
            {
                result.ResCode = ResponseStatusCodeEnum.DocDetailNotExist.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.DocDetailNotExist.GetDescription();
                return result;
            }

            var warehouse = _baseWareHouserepository.GetSingle(p => p.Code == request.WareCode);
            if (warehouse == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetDescription();
                return result;
            }
            //存单据
            var doc = _docrepository.GetSingle(p => p.DocsNo == request.BillCode);
            if (doc == null)
            {
                var docsinfo = new ptBillDocsinfo()
                {
                    DocsNo = request.BillCode,
                    WarehouseId = warehouse.Id,
                    ReqNo = request.ReqId,
                    Type = request.BillType,
                    StateNum = DocState.DocState_Create.GetHashCode(),
                    IsStop = 0,
                    JsonContent = JsonConvert.SerializeObject(request.ListInfo),
                    DownQty = request.ListInfo.Count,
                    AddWho = "wms",
                    EditWho = "wms"
                };
                var code = InsertBillInvinit(request, warehouse);
                if (code.ResCode == ResponseStatusCodeEnum.Sucess.GetHashCode())
                {
                    _docrepository.Insert(docsinfo);
                }
                else
                {
                    result.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                    result.ResMsg = "明细存储失败";
                    return result;
                }
            }
            else
            {
                _docrepository.UpdateModelColumns(p => new ptBillDocsinfo()
                {
                    JsonContent = JsonConvert.SerializeObject(request.ListInfo),
                    EditTime = DateTime.Now
                }, p => p.DocsNo == request.BillCode);
            }
            return result;
        }

        private SRes InsertBillInvinit(PurchaseBillTransReqest request, ptBaseWarehouse warehouse)
        {
            var result = new SRes();
            List<ptBillInvinit> invlist = new List<ptBillInvinit>();
            //明细存条码表
            foreach (var item in request.ListInfo)
            {
                var mater = _materrepository.GetSingle(p => p.Code == item.MatCode);
                if (mater == null)
                {
                    result.ResCode = ResponseStatusCodeEnum.BaseMaterCodeNotExist.GetHashCode();
                    result.ResMsg = item.MatCode + ResponseStatusCodeEnum.BaseMaterCodeNotExist.GetDescription();
                    return result;
                }
                var invinit = new ptBillInvinit()
                {
                    WarehouseId = warehouse.Id,
                    ContGrpBarCode = item.RFID,
                    ContGrpId = GetId(),
                    BoxBarCode = item.RFID,
                    BoilerNo = item.BoilerNo,
                    PackNo = item.PackNo,
                    BatchNo = item.Batch,
                    CLBarCode = item.MatBarCode,
                    CaQty = item.Carbon,
                    ProductTime = item.ProductDate,
                    BrandNo = item.Brand,
                    ExecStd = item.ExecStandard,
                    LicenceCode = item.Licence,
                    TolWQty = item.Weight,
                    HoldDuration = item.HoldDuration,
                    Describe = item.Describe,
                    InvStateCode = InvState.InvEcecState_BuildUp.ToString(),
                    InvBarCode = item.MatBarCode,
                    ExecStateCode = InvLockState.InvState_Lock.ToString(),
                    InDocsNo = request.BillCode,
                    InDocsRowNo = request.BillCode,
                    MatId = 1111,
                    MatCode = item.MatCode,
                    RFIDBarCode = item.RFID,
                    HWTypeCode = "",
                    ExecDocsNo = request.BillCode,
                    ExecDocsRowNo = request.BillCode,
                    ExecDocsTypeCode = request.BillType,
                    HWBarCode = item.RFID,
                    RodBarCode = item.RodBar,
                    InvInOut = 1,
                    ExecWho = "",
                    MatName = "",
                    Size = 1,
                    SuppCode = request.SupCode,
                    SuppName = request.SupName
                };
                invlist.Add(_mapper.Map<ptBillInvinit>(invinit));
            }
            _ptbillInvinit.InsertRange(invlist);
            return result;
        }
        public SRes PurchaseBillTransFeedBack(PurchaseBillTransFeedBackRequest reqDto)
        {
            var result = new SRes();

            return result;
        }
        /// <summary>
        /// 放行单传输
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        public ErpUnlockStockResponse ErpUnlockStock(ErpUnlockStockRequest reqDto)
        {
            var result = new ErpUnlockStockResponse() { ListInfo = new List<ErpUnlockStockResponseItem>()};
            if (!reqDto.ListInfo.Any())
            {
                result.ResCode = ResponseStatusCodeEnum.DocDetailNotExist.GetHashCode();
                result.ResMsg = reqDto.BillCode + ResponseStatusCodeEnum.DocDetailNotExist.GetDescription();
                return result;
            }
            var inv = _ptbillInvnow.GetList(p => p.InDocsNo == reqDto.BillCode && p.ExecStateCode == InvLockState.InvState_Lock.ToString() && p.InvStateCode == InvState.InvEcecState_In.ToString());
            if (!inv.Any())
            {
                result.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                result.ResMsg = reqDto.BillCode + "不存在库存明细";
                return result;
            }
            foreach (var item in reqDto.ListInfo)
            {
                if (inv.Where(p => p.ContGrpBarCode == item.RFID && p.CLBarCode == item.MatBarCode).Any())
                {
                    var stock = inv.Where(p => p.ContGrpBarCode == item.RFID && p.CLBarCode == item.MatBarCode).First();
                    var flow = _mapper.Map<ptBillInvFlow>(stock);
                    flow.Id = GetId();
                    flow.ExecStateCode = item.State == "Normal" ? InvLockState.InvState_Normal.ToString() : InvLockState.InvState_Lock.ToString();
                    flow.EditTime = DateTime.Now;
                    flow.AddTime = DateTime.Now;
                    try
                    {
                        _db.BeginTran();
                        _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                        {
                            ExecStateCode = item.State == "Normal" ? InvLockState.InvState_Normal.ToString() : InvLockState.InvState_Lock.ToString(),
                            EditTime = DateTime.Now
                        }, p => p.ContGrpBarCode == item.RFID && p.CLBarCode == item.MatBarCode);
                        _ptBillInvFlow.Insert(flow);
                        _db.CommitTran();
                        var erpUnlockStock = new ErpUnlockStockResponseItem()
                        {
                            RFID = item.RFID,
                            MatBarCode = item.MatBarCode,
                            ResState = "S",
                            ResDesc = ""
                        };
                        result.ListInfo.Add(_mapper.Map<ErpUnlockStockResponseItem>(erpUnlockStock));
                    }
                    catch (Exception ex)
                    {
                        _db.RollbackTran();
                        var erpUnlockStock = new ErpUnlockStockResponseItem()
                        {
                            RFID = item.RFID,
                            MatBarCode = item.MatBarCode,
                            ResState = "E",
                            ResDesc = "放行失败"
                        };
                        result.ListInfo.Add(_mapper.Map<ErpUnlockStockResponseItem>(erpUnlockStock));
                    }
                }
                else
                {
                    var unlockStock = new ErpUnlockStockResponseItem()
                    {
                        RFID = item.RFID,
                        MatBarCode = item.MatBarCode,
                        ResState = "E",
                        ResDesc = "未找到该RFID条码"
                    };
                    result.ListInfo.Add(_mapper.Map<ErpUnlockStockResponseItem>(unlockStock));
                    continue;
                }
            }
            return result;
        }
        /// <summary>
        /// 车间自动叫料出库
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public SRes WcsProductionOutRequest(WcsProductionOutRequest request)
        {
            var result = new SRes();
            var equip = _sysconfigrepository.GetList(p => p.SType == Const.Type);
            var syscom = equip.Where(p => p.Code == request.Endquip).First();
            if (!string.IsNullOrEmpty(syscom.Default1))
            {
                _sysconfigrepository.UpdateSetColumnsTrue(p => new ptSysConfig()
                {
                    Default1 = "",
                    EditTime = DateTime.Now
                }, p => p.Code == request.Endquip);
            }
            var mesRequest = _ptbillmes.GetList();
            foreach (var item in mesRequest)
            {
               
            }
            //添加单据
            //var doc = _docrepository.GetSingle(p => p.DocsNo == mesRequest.BillCode);
            //if (doc == null)
            //{
            //    var docsinfo = new ptBillDocsinfo()
            //    {
            //        DocsNo = mesRequest.BillCode,
            //        WarehouseId = 1685164446336552960,
            //        ReqNo = GetId().ToString(),
            //        TypeNum = PtDocType.DocType_PT_ProductionStockOut.ToString(),
            //        StateNum = DocState.DocState_Create.GetHashCode(),
            //        IsStop = 0,
            //        JsonContent = JsonConvert.SerializeObject(mesRequest),
            //        AddWho = "wms",
            //        EditWho = "wms"
            //    };
            //    _docrepository.Insert(docsinfo);
            //}
            //else
            //{
            //    _docrepository.UpdateModelColumns(p => new ptBillDocsinfo()
            //    {
            //        JsonContent = JsonConvert.SerializeObject(mesRequest),
            //        EditTime = DateTime.Now
            //    }, p => p.DocsNo == mesRequest.BillCode);
            //}
            //申请出库
            //var res = ApplyProductionStockOut(_mapper.Map<ProductionStockOutRequest>(mesRequest));
            return result;
        }

        /// <summary>
        /// 生产领料出库
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        public SRes ProductionStockOut(ProductionStockOutRequest reqDto)
        {
            var result = new SRes();
            var ware = _baseWareHouserepository.GetSingle(p => p.Code == reqDto.WareCode);
            if (ware == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetHashCode();
                result.ResMsg = reqDto.WareCode + ResponseStatusCodeEnum.WarehouseCodeNotExist.GetDescription();
                return result;
            }
            if (string.IsNullOrEmpty(reqDto.BillCode) || string.IsNullOrEmpty(reqDto.MatCode))
            {
                result.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                result.ResMsg = "单号与物料编码不可为空";
                return result;
            }

            //var mesRequest = new ptBillMesmiddle()
            //{
            //    BillCode = reqDto.BillCode,
            //    PackNo = reqDto.PackNo,
            //    MatCode = reqDto.MatCode,
            //    MatBarCode = reqDto.MatBarCode,
            //    BoilerNo = reqDto.BoilerNo,
            //    WareCode = reqDto.WareCode
            //};
            //_ptbillmes.Insert(mesRequest);
            //添加单据
            var doc = _docrepository.GetSingle(p => p.DocsNo == reqDto.BillCode);
            if (doc == null)
            {
                var docsinfo = new ptBillDocsinfo()
                {
                    DocsNo = reqDto.BillCode,
                    WarehouseId = ware.Id,
                    ReqNo = GetId().ToString(),
                    Type = PtDocType.DocType_PT_ProductionStockOut.ToString(),
                    StateNum = DocState.DocState_Create.GetHashCode(),
                    IsStop = 0,
                    JsonContent = JsonConvert.SerializeObject(reqDto),
                    AddWho = "wms",
                    EditWho = "wms"
                };
                _docrepository.Insert(docsinfo);
            }
            else
            {
                _docrepository.UpdateModelColumns(p => new ptBillDocsinfo()
                {
                    JsonContent = JsonConvert.SerializeObject(reqDto),
                    EditTime = DateTime.Now
                }, p => p.DocsNo == reqDto.BillCode);
            }
            //申请出库
            result = ApplyProductionStockOut(reqDto);
            return result;
        }
        /// <summary>
        /// 申请出库
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        private SRes ApplyProductionStockOut(ProductionStockOutRequest request)
        {
            var res = new SRes();
            //考虑巷道剩余空轮数量
            var locationlist = from loc in _baseWareLocationrepository.GetList(p => p.IsStop == 0 && p.StateNum == LocationState.LocationState_Full.GetHashCode())
                               join stock in _ptbillInvnow.GetList(p => p.InvStateCode == InvState.InvEcecState_In.ToString() && p.ExecStateCode == InvLockState.InvState_Normal.ToString())
                               on loc.ContGrpBarCode equals stock.ContGrpBarCode
                               orderby stock.ProductTime
                               select new
                               {
                                   stock.MatCode,
                                   stock.InvBarCode,
                                   stock.BoilerNo,
                                   stock.RodBarCode,
                                   stock.Grade,
                                   stock.PackNo,
                                   stock.InvStateCode,
                                   stock.ProductTime,
                                   loc.Col,
                                   loc.Layer,
                                   loc.Shelf,
                                   loc.Depth,
                                   loc.Code,
                                   loc.Tunnel,
                                   loc.WarehouseCode,
                                   loc.ContGrpBarCode,
                                   loc.Id,
                                   loc.StateNum,
                               };
            if (!string.IsNullOrEmpty(request.MatCode))
            {
                locationlist = locationlist.Where(p => p.MatCode == request.MatCode);
            }
            if (!string.IsNullOrEmpty(request.MatBarCode))
            {
                locationlist = locationlist.Where(p => p.InvBarCode == request.MatBarCode);
            }
            if (!string.IsNullOrEmpty(request.BoilerNo))
            {
                locationlist = locationlist.Where(p => p.BoilerNo == request.BoilerNo);
            }
            if (!string.IsNullOrEmpty(request.PackNo))
            {
                locationlist = locationlist.Where(p => p.PackNo == request.PackNo);
            }

            if (locationlist == null || !locationlist.Any())
            {
                res.ResCode = ResponseStatusCodeEnum.NotEnoughStock.GetHashCode();
                res.ResMsg = request.MatCode + "|" + request.BoilerNo + ResponseStatusCodeEnum.NotEnoughStock.GetDescription();
                return res;
            }

            if (string.IsNullOrEmpty(request.BoilerNo))
            {
                //多个炉号业务处理
                var boilernum = locationlist.Select(p => new { p.BoilerNo, p.ProductTime } ).Distinct().OrderBy(p => p.ProductTime).ToList();
                if (boilernum.Count() > 1)
                {
                    List<string> boils = new List<string>();
                    for (int i = 0; i < boilernum.Count(); i++)
                    {
                        var boil = boilernum;
                        foreach (var item in boil)
                        {
                            if (item.BoilerNo == boilernum[i].BoilerNo)
                            {
                                continue;
                            }
                            if (DateTime.Equals(boilernum[i].ProductTime, item.ProductTime))
                            {
                                boils.Add(item.BoilerNo);
                            }
                        }
                    }
                    boils = boils.Distinct().ToList();
                    if (boils.Any())
                    {
                        //多个炉号的生产时间在同一天的
                        locationlist = locationlist.Where(p => boils.Contains(p.BoilerNo)).GroupBy(p => p.BoilerNo).OrderBy(p => p.Count()).First();
                    }
                    else
                    {
                        var loca = locationlist.OrderBy(p => p.ProductTime).First();
                        locationlist = locationlist.Where(p => p.BoilerNo == loca.BoilerNo).OrderBy(p => p.PackNo);
                    }
                   
                }
            }
            //出库任务
            var temploc = locationlist.First();
            var outstation = "";
            switch (temploc.Tunnel)
            {
                case 1:
                    outstation = "";
                    break;
                case 2:
                    outstation = "";
                    break;
                case 3:
                    outstation = "";
                    break;
                case 4:
                    outstation = "";
                    break;
                case 5:
                    outstation = "";
                    break;
                case 6:
                    outstation = "";
                    break;
                case 7:
                    outstation = "";
                    break;
                case 8:
                    outstation = "";
                    break;
                default:
                    break;
            }

            var sotck = _ptbillInvnow.GetFirst(p => p.ContGrpBarCode == temploc.ContGrpBarCode && p.InvStateCode == InvState.InvEcecState_In.ToString() && p.ExecStateCode == InvLockState.InvState_Normal.ToString());
            try
            {
                _db.BeginTran();
                //货位表
                _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_StockOut.GetHashCode() }, p => p.Id == temploc.Id);
                //库存表
                _ptbillInvnow.UpdateModelColumns(p => new ptBillInvnow() { InvStateCode = InvState.InvEcecState_OutGoing.ToString(), EditTime = DateTime.Now }, p => p.Id == sotck.Id);
                var invflow = _mapper.Map<ptBillInvFlow>(sotck);

                invflow.InvStateCode = InvState.InvEcecState_OutGoing.ToString();
                invflow.AddTime = DateTime.Now;
                invflow.Id = IdFactory.NewId();
                _ptBillInvFlow.Insert(invflow);
                //添加出库任务
                CreateStockOutTask(new PtCreateStockOutTaskRequest()
                {
                    ContGrpBarCode = temploc.ContGrpBarCode,
                    CellNo = temploc.Code,
                    EquCode = outstation,
                    Qty = sotck.LengthQty,
                    Tunnel = temploc.Tunnel.ToString(),
                    WarehouseCode = temploc.WarehouseCode,
                    MatCode = request.MatCode,
                    InvBarCode = request.MatBarCode,
                    BusType = PtTaskBusType.TaskBusType_PT_ProductionStockOut.GetDescription(),
                    DocNo = request.BillCode
                });
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                _logger.LogInformation(ex.ToString());
                res.ResCode = ResponseStatusCodeEnum.DataSaveErr.GetHashCode();
                res.ResMsg = ResponseStatusCodeEnum.DataSaveErr.GetDescription();
                return res;
            }
            return res;
        }
        private SRes<ptWCS_TaskInfo> CreateStockOutTask(PtCreateStockOutTaskRequest reqDto)
        {
            var res = new SRes<ptWCS_TaskInfo>();
            var wcstask = new ptWCS_TaskInfo()
            {
                Type = TaskType.OutDepot,
                Status = TaskStatus.NewBuild,
                Priority = 0,
                Device = "SRM" + reqDto.Tunnel,
                SrmStation = reqDto.EquCode,
                AddrFrom = reqDto.CellNo,
                AddrTo = reqDto.EquCode,
                LastInteractionPoint = "",
                BarCode = reqDto.ContGrpBarCode,
                Length = reqDto.Qty,
                AddTime = DateTime.Now,
                StartTime = DateTime.Now,
                DocID = int.Parse(reqDto.DocNo),
                PalletType = 1,
                ProdLine = 0,
                AddWho = "wms",
                WarehouseCode = reqDto.WarehouseCode,
                Enabled = true,
                Tunnel = reqDto.Tunnel,
                BusType = reqDto.BusType,
                MatCode = reqDto.MatCode,
                MaterialCode = reqDto.MatCode,
                InvBarCode = reqDto.InvBarCode
            };

            try
            {
                _db.BeginTran();
                var task = _ptwcsTaskinfo.InsertReturnEntity(wcstask);
                var taskold = _mapper.Map<ptWCS_TaskOld>(task);
                _ptwcsTaskold.InsertableSplitTable(taskold);
                var taskdetail = new ptWCS_TaskDtl()
                {
                    ID = Guid.NewGuid(),
                    CurPoint = reqDto.CellNo,
                    AddTime = DateTime.Now,
                    AddWho = "wms",
                    Enabled = true,
                    ParentTaskCode = task.ID,
                    Desc = reqDto.CellNo + "生产领料出库",
                };
                _ptwcsTaskdtl.InsertableSplitTable(taskdetail);
                _db.CommitTran();
                res.ResData = task;
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                res.ResCode = ResponseStatusCodeEnum.DataSaveErr.GetHashCode();
                res.ResMsg = ResponseStatusCodeEnum.DataSaveErr.GetDescription();
                _logger.LogInformation("保存任务异常：" + ex.ToString());
                return res;
            }
            return res;
        }
        public SRes ProductionFeedBack(ProductionFeedBackRequest reqDto)
        {
            var result = new SRes();

            return result;
        }
        public SRes StockChange(PtStockChangeRequest reqDto)
        {
            var result = new SRes();
            if (!reqDto.ListInfo.Any())
            {
                result.ResCode = ResponseStatusCodeEnum.DocDetailNotExist.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.DocDetailNotExist.GetDescription();
                return result;
            }
            var ware = _baseWareHouserepository.GetSingle(p => p.Code == reqDto.WareCode);
            if (ware == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetHashCode();
                result.ResMsg = reqDto.WareCode + ResponseStatusCodeEnum.WarehouseCodeNotExist.GetDescription();
                return result;
            }
            var doc = _docrepository.GetSingle(p => p.DocsNo == reqDto.BillCode);
            if (doc == null)
            {
                var docno = new ptBillDocsinfo()
                {
                    DocsNo = reqDto.BillCode,
                    IsStop = 0,
                    WarehouseId = ware.Id,
                    ReqNo = reqDto.ReqId,
                    Type = PtDocType.DocType_PT_StateTrans.ToString(),
                    StateNum = DocState.DocState_Create.GetHashCode(),
                    JsonContent = JsonConvert.SerializeObject(reqDto.ListInfo),
                    AddWho = "mes",
                    EditWho = "mes"
                };
                _docrepository.Insert(docno);
            }
            foreach (var item in reqDto.ListInfo)
            {
                var puch = new ptBillPushinfo()
                {
                    DocsNo = reqDto.BillCode,
                    TypeCode = PtFackbeekType.StateTrans.ToString(),
                    RFIDBarCode = item.RFID,
                    HWBarCode = item.RFID,
                    CLBarCode = item.MatBarCode,
                    WarehouseId = ware.Id,
                    WarehouseCode = ware.Code,
                    ReqNo = Guid.NewGuid().ToString(),
                    BoilerNo = item.BoilerNo,
                    PackNo = item.PackNo
                };
                var stock = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == item.RFID);
                if (stock == null)
                {
                    puch.ResStateCode = "E";
                    puch.ResDesc = item.RFID + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                    _ptbillPushinfo.Insert(puch);
                    continue;
                }
                else
                {
                    if (stock.InvStateCode == InvState.InvEcecState_In.ToString() || stock.InvStateCode == InvState.InvEcecState_BuildUp.ToString())
                    {
                        if (item.State == "Lock" || item.State == "Normal")
                        {
                            var it = _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                            {
                                ExecStateCode = item.State == "Lock" ? InvLockState.InvState_Lock.ToString() : InvLockState.InvState_Normal.ToString(),
                                EditTime = DateTime.Now,
                                BoilerNo = item.BoilerNo,
                                PackNo = item.PackNo,
                                Memo = item.Reason
                            }, p => p.ContGrpBarCode == item.RFID);
                            var nov = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == item.RFID);
                            var flow = _mapper.Map<ptBillInvFlow>(nov);
                            flow.Id = GetId();
                            flow.AddTime = DateTime.Now;
                            flow.EditTime = DateTime.Now;
                            puch.ResStateCode = "S";
                            puch.ResDesc = "成功";
                            _ptbillPushinfo.Insert(puch);
                            _ptBillInvFlow.Insert(flow);
                            continue;
                        }
                        else
                        {
                            _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                            {
                                IsFast = item.State == "Fast" ? true : false,
                                EditTime = DateTime.Now,
                                BoilerNo = item.BoilerNo,
                                PackNo = item.PackNo,
                                Memo = item.Reason
                            }, p => p.ContGrpBarCode == item.RFID);
                            var nov = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == item.RFID);
                            var flow = _mapper.Map<ptBillInvFlow>(nov);
                            flow.Id = GetId();
                            flow.AddTime = DateTime.Now;
                            flow.EditTime = DateTime.Now;
                            puch.ResStateCode = "S";
                            puch.ResDesc = "成功";
                            _ptbillPushinfo.Insert(puch);
                            _ptBillInvFlow.Insert(flow);
                            continue;
                        }
                    }
                    //堆垛机还未上报放货完成
                    else if (stock.InvStateCode == InvState.InvEcecState_OutGoing.ToString() && stock.PutRow != 0 && stock.PutCol != 0 && stock.PutLayer != 0)
                    {
                        if (item.State == "Lock" || item.State == "Normal")
                        {
                            _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                            {
                                ExecStateCode = item.State == "Lock" ? InvLockState.InvState_Lock.ToString() : InvLockState.InvState_Normal.ToString(),
                                EditTime = DateTime.Now,
                                BoilerNo = item.BoilerNo,
                                PackNo = item.PackNo,
                                Memo = item.Reason,
                                InvStateCode = InvState.InvEcecState_In.ToString()
                            }, p => p.ContGrpBarCode == item.RFID);
                            var nov = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == item.RFID);
                            var flow = _mapper.Map<ptBillInvFlow>(nov);
                            flow.Id = GetId();
                            flow.AddTime = DateTime.Now;
                            flow.EditTime = DateTime.Now;
                            puch.ResStateCode = "S";
                            puch.ResDesc = "成功";
                            _ptbillPushinfo.Insert(puch);
                            _ptBillInvFlow.Insert(flow);
                            //出库任务取消
                            continue;
                        }
                        else
                        {
                            _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                            {
                                IsFast = item.State == "Fast" ? true : false,
                                EditTime = DateTime.Now,
                                BoilerNo = item.BoilerNo,
                                PackNo = item.PackNo,
                                Memo = item.Reason,
                                InvStateCode = InvState.InvEcecState_In.ToString()
                            }, p => p.ContGrpBarCode == item.RFID);
                            var nov = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == item.RFID);
                            var flow = _mapper.Map<ptBillInvFlow>(nov);
                            flow.Id = GetId();
                            flow.AddTime = DateTime.Now;
                            flow.EditTime = DateTime.Now;
                            puch.ResStateCode = "S";
                            puch.ResDesc = "成功";
                            _ptbillPushinfo.Insert(puch);
                            _ptBillInvFlow.Insert(flow);
                            //出库任务取消
                            continue;
                        }
                    }
                    //已上报放货完成
                    else if (stock.InvStateCode == InvState.InvEcecState_OutGoing.ToString() && stock.PutRow == 0 && stock.PutCol == 0 && stock.PutLayer == 0)
                    {
                        
                    }
                }
            }
            return result;
        }
        public SRes ProductionBack(ProductionBackRequest reqDto)
        {
            var result = new SRes();
            if (!reqDto.ListInfo.Any() || string.IsNullOrEmpty(reqDto.BillCode) || string.IsNullOrEmpty(reqDto.WareCode))
            {
                result.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.ErrParamNotNull.GetDescription();
                return result;
            }
            var ware = _baseWareHouserepository.GetSingle(p => p.Code == reqDto.WareCode);
            if (ware == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetDescription();
                return result;
            }
            var doc = _docrepository.GetSingle(p => p.DocsNo == reqDto.BillCode);
            if (doc == null)
            {
                var docno = new ptBillDocsinfo()
                {
                    DocsNo = reqDto.BillCode,
                    IsStop = 0,
                    WarehouseId = ware.Id,
                    ReqNo = reqDto.BillCode,
                    Type = PtDocType.DocType_PT_ProductionBackStockIn.ToString(),
                    StateNum = DocState.DocState_Create.GetHashCode(),
                    JsonContent = JsonConvert.SerializeObject(reqDto.ListInfo),
                    AddWho = "mes",
                    EditWho = "mes"
                };
                _docrepository.Insert(docno);
            }
            foreach (var item in reqDto.ListInfo)
            {
                var flowold = _ptBillInvFlow.AsQueryable().Where(p => p.ContGrpBarCode == item.RFID).OrderByDescending(p => p.EditTime).First();
                var mater = _materrepository.GetSingle(p => p.Code == flowold.MatCode);
                var nov = new ptBillInvnow()
                {
                    WarehouseId = ware.Id,
                    ContGrpBarCode = item.RFID,
                    ContGrpId = GetId(),
                    BoxBarCode = item.RFID,
                    BoilerNo = item.BoilerNo,
                    PackNo = item.PackNo,
                    CLBarCode = item.MatBarCode,
                    InvStateCode = InvState.InvEcecState_BuildUp.ToString(),
                    InvBarCode = item.MatBarCode,
                    ExecStateCode = item.State == "Lock" ? InvLockState.InvState_Lock.ToString() : InvLockState.InvState_Normal.ToString(),
                    InDocsNo = reqDto.BillCode,
                    InDocsRowNo = reqDto.BillCode,
                    MatId = mater.Id,
                    MatCode = mater.Code,
                    RFIDBarCode = item.RFID,
                    HWTypeCode = mater.SpoolType,
                    ExecDocsNo = reqDto.BillCode,
                    ExecDocsRowNo = reqDto.BillCode,
                    ExecDocsTypeCode = PtDocType.DocType_PT_ProductionBackStockIn.ToString(),
                    HWBarCode = item.RFID,
                    RodBarCode = item.RFID,
                    InvInOut = 1,
                    MatName = mater.Name,
                    Size = 1,
                    IsBack = true
                };
                var task = new ptWCS_TaskInfo()
                {
                    Status = TaskStatus.NewBuild,
                    Type = TaskType.EnterDepot,
                    Priority = 0,
                    Device = item.LocCode,
                    SrmStation = item.LocCode,
                    AddrFrom = item.LocCode,
                    BarCode = item.RFID,
                    StartTime = DateTime.Now,
                    AddTime = DateTime.Now,
                    EditTime = DateTime.Now,
                    AddWho = "wms",
                    EditWho = "wms",
                    WarehouseCode = ware.Code,
                    WorkBench = item.LocCode,
                    AddrTo = "",
                    Tunnel = "",
                    PalletType = 1,
                    MaterialCode = mater.Code,
                    MatCode = mater.Code,
                    BusType = PtTaskBusType.TaskBusType_PT_ProductionBackStockIn.GetDescription()
                };
                try
                {
                    _db.BeginTran();
                    _ptbillInvnow.Insert(nov);
                    _ptBillInvFlow.Insert(_mapper.Map<ptBillInvFlow>(nov));
                    var wcs = _ptwcsTaskinfo.InsertReturnEntity(task);
                    var wcsold = _mapper.Map<ptWCS_TaskOld>(wcs);
                    _ptwcsTaskold.InsertableSplitTable(wcsold);
                    var taskdetail = new ptWCS_TaskDtl()
                    {
                        ID = Guid.NewGuid(),
                        CurPoint = item.LocCode,
                        AddTime = DateTime.Now,
                        AddWho = "wms",
                        Enabled = true,
                        ParentTaskCode = wcs.ID,
                        Desc = wcs.BusType
                    };
                    _ptwcsTaskdtl.InsertableSplitTable(taskdetail);
                    _db.CommitTran();
                }
                catch (Exception ex)
                {
                    _db.RollbackTran();
                    result.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                    result.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                    return result;
                }
            }
            return result;
        }
        public PTGetCurStockListResponse GetCurStockList(PtGetCurStockListRequest reqDto)
        {
            var result = new PTGetCurStockListResponse() { list = new List<PtResDataItem>() };
            int count = 0;
            var stock = _ptbillInvnow.Context.Queryable<ptBillInvnow, ptBaseMater>((inv, mater) => new object[]
                        {
                            JoinType.Left, inv.MatCode == mater.Code
                        })
                        .Where((inv, mater) => inv.InvStateCode == InvState.InvEcecState_In.ToString())
                        .WhereIF(string.IsNullOrEmpty(reqDto.MatCode), (inv, mater) => inv.MatCode.Contains(reqDto.MatCode))
                        .WhereIF(string.IsNullOrEmpty(reqDto.MatName), (inv, mater) => inv.MatName.Contains(reqDto.MatName))
                        .WhereIF(string.IsNullOrEmpty(reqDto.BoilerNo), (inv, mater) => inv.BoilerNo.Contains(reqDto.BoilerNo))
                        .WhereIF(string.IsNullOrEmpty(reqDto.RFID), (inv, mater) => inv.ContGrpBarCode.Contains(reqDto.RFID))
                        .WhereIF(string.IsNullOrEmpty(reqDto.MatBarCode), (inv, mater) => inv.InvBarCode.Contains(reqDto.MatBarCode))
                        .WhereIF(string.IsNullOrEmpty(reqDto.Batch), (inv, mater) => inv.BatchNo.Contains(reqDto.Batch))
                        .Select((inv, mater) => new PtResDataItem()
                        {
                            RFID = inv.ContGrpBarCode,
                            RodBar = inv.RodBarCode,
                            BoilerNo = inv.BoilerNo,
                            MatBarCode = inv.InvBarCode,
                            PackNo = inv.PackNo,
                            Batch = inv.BatchNo,
                            Carbon = inv.CaQty,
                            ProductDate = inv.ProductTime,
                            Brand = inv.BrandNo,
                            Describe = inv.Describe,
                            ExecStandard = inv.ExecStd,
                            Licence = inv.LicenceCode,
                            PackWeight = inv.TolWQty,
                            FigureNo = mater.FigureNo,
                            ComCode = mater.ComCode,
                            ComName = mater.ComName,
                            CalcUnit = mater.CalcUnit,
                            StockUnit = mater.StockUnit,
                            Weight = mater.Weight,
                            WeightUnit = mater.WeightUnit,
                            IsHold = mater.IsHold,
                            HoldDuration = inv.HoldDuration,
                            LocCell = inv.PutCol.ToString(),
                            LocLayer = inv.PutLayer.ToString(),
                            LocRow = inv.PutRow.ToString(),
                            LocCode = inv.PutRow.ToString() + inv.PutCol.ToString() + inv.PutLayer.ToString(),
                            WareCode = "pthouse"
                        })
                        .ToPageList(reqDto.PageIndex, reqDto.PageSize, ref count);

            result.TotalCount = stock.Count();
            result.list = stock;
            return result;
        }
        /// <summary>
        /// 采购入库任务
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public SRes PtPurchaseTask(PtUnboundRequest request)
        {
            var result = new SRes();
            try
            {
                var stock = new ptBillInvnow()
                {
                    WarehouseId = 1685164446336552960,
                    ContGrpBarCode = "Test" + DateTime.Now.ToString("hhmmssfff"),
                    ContGrpId = GetId(),
                    InvStateCode = InvState.InvEcecState_BuildUp.ToString(),
                    ExecStateCode = InvLockState.InvState_Lock.ToString()
                };
                var task = new ptWCS_TaskInfo()
                {
                    Status = TaskStatus.NewBuild,
                    Type = TaskType.EnterDepot,
                    Priority = 0,
                    Device = request.Equip,
                    SrmStation = request.Equip,
                    AddrFrom = request.Equip,
                    BarCode = stock.ContGrpBarCode,
                    StartTime = DateTime.Now,
                    AddTime = DateTime.Now,
                    EditTime = DateTime.Now,
                    AddWho = "wms",
                    EditWho = "wms",
                    WarehouseCode = Const.PtWareHouse,
                    WorkBench = request.Equip,
                    AddrTo = "",
                    Tunnel = "",
                    PalletType = 1,
                    MaterialCode = "",
                    BusType = PtTaskBusType.TaskBusType_PT_PurchaseStockIn.GetDescription()
                };
                _db.BeginTran();
                _ptbillInvnow.Insert(stock);
                var wcs = _ptwcsTaskinfo.InsertReturnEntity(task);
                var wcsold = _mapper.Map<ptWCS_TaskOld>(wcs);
                _ptwcsTaskold.InsertableSplitTable(wcsold);
                var taskdetail = new ptWCS_TaskDtl()
                {
                    ID = Guid.NewGuid(),
                    CurPoint = request.Equip,
                    AddTime = DateTime.Now,
                    AddWho = "wms",
                    Enabled = true,
                    ParentTaskCode = wcs.ID,
                    Desc = wcs.BusType
                };
                _ptwcsTaskdtl.InsertableSplitTable(taskdetail);
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                result.ResCode = ResponseStatusCodeEnum.DataSaveErr.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.DataSaveErr.GetDescription() + ex.Message;
                return result;
            }
            return result;
        }
        /// <summary>
        /// 生成库存
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        public SRes InsertStockInfo(string code)
        {
            var result = new SRes();
            //查询条码表
            var barcode = _ptbillInvinit.GetSingle(p => p.ContGrpBarCode == code);
            if (barcode == null)
            {
                result.ResCode = ResponseStatusCodeEnum.BaseBarcodeNotExist.GetHashCode();
                result.ResMsg = code + ResponseStatusCodeEnum.BaseBarcodeNotExist.GetDescription();
                return result;
            }
            var invlist = _ptbillInvnow.GetList(p => p.ContGrpBarCode.StartsWith("Test"));
            if (!invlist.Any())
            {
                result.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                result.ResMsg = code + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                return result;
            }
            var inv = invlist.First();
            var stock = _mapper.Map<ptBillInvnow>(barcode);
            stock.AddTime = DateTime.Now;
            stock.EditTime = DateTime.Now;
            try
            {
                _db.BeginTran();
                _ptbillInvnow.DeleteById(inv.Id);
                _ptbillInvnow.Insert(stock);
                _ptBillInvFlow.Insert(_mapper.Map<ptBillInvFlow>(stock));
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                result.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                result.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                return result;
            }
            return result;
        }
        private long GetId()
        {
            return IdFactory.NewId();
        }
        public SRes<int> Unbounding(PtUnboundRequest request)
        {
            var res = new SRes<int>() { ResCode = 500 };
            var task = _ptwcsTaskinfo.GetList(p => p.AddrFrom == request.Equip && p.Status < TaskStatus.Finish);
            if (task.Any())
            {
                res.ResCode = ResponseStatusCodeEnum.IsTaskNotUnbounding.GetHashCode();
                res.ResMsg = ResponseStatusCodeEnum.IsTaskNotUnbounding.GetDescription();
                return res;
            }
            var equip = _baseWareLocationrepository.GetSingle(p => p.Code == request.Equip);
            if (equip == null)
            {
                res.ResCode = ResponseStatusCodeEnum.EquipInfoNotExist.GetHashCode();
                res.ResMsg = ResponseStatusCodeEnum.EquipInfoNotExist.GetDescription();
                return res;
            }
            var stock = _iptDataService.GetStockByEquip(request.Equip);
            if (stock.Any())
            {
                _baseWareLocationrepository.UpdateSetColumnsTrue(p => new ptBaseWareLocation()
                {
                    ContGrpId = Const.Zero,
                    ContGrpBarCode = "",
                    EditTime = DateTime.Now
                }, p => request.Equip == p.Code);
                _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                {
                    InvStateCode = InvState.InvEcecState_Out.ToString(),
                    EditTime = DateTime.Now
                }, p => stock.Contains(p.HWBarCode));
                res.ResCode = ResponseStatusCodeEnum.Sucess.GetHashCode();
            }
            else
            {
                res.ResMsg = ResponseStatusCodeEnum.StockNotExist.GetDescription();
            }
            return res;
        }
        public SRes<PtDocumentsdetailList> GetDocumentDetailListByDocsNo(PtDocumentsRequest request)
        {
            var res = new SRes<PtDocumentsdetailList>() { ResDataList = new List<PtDocumentsdetailList>() };
            var list = _iptDataService.GetDocumentDetailListByDocsNo(request);
            res.ResDataList = list.Item1;
            res.ToCount = list.Item2;
            res.PageIndex = request.PageIndex;
            res.PageSize = request.PageSize;
            res.PageNumber = Math.Ceiling((decimal)res.ToCount / res.PageSize);
            return res;
        }
        public SRes<PtDocumentsResponse> GetPageDocumentsList(PtDocumentsRequest request)
        {
            var res = new SRes<PtDocumentsResponse>() { ResDataList = new List<PtDocumentsResponse>() };
            if (request.TypeCode == null)
            {
                res.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                res.ResMsg = "单据类型" + ResponseStatusCodeEnum.ErrParamNotNull.GetDescription();
                return res;
            }
            var list = _iptDataService.GetPageDocumentsList(request);
            res.ResDataList = list.Item1;
            res.ToCount = list.Item2;
            res.PageIndex = request.PageIndex;
            res.PageSize = request.PageSize;
            res.PageNumber = Math.Ceiling((decimal)res.ToCount / res.PageSize);
            return res;
        }
        public string ManualTask(PtManualTaskRequest request)
        {
            var res = new SRes();
            if (!request.Location.Any())
            {
                res.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                res.ResMsg = "货位" + ResponseStatusCodeEnum.ErrParamNotNull.GetDescription();
                return res.ToCamelCaseString();
            }
            try
            {
                foreach (var item in request.Location)
                {
                    var location = _baseWareLocationrepository.GetSingle(p => p.Code == item);
                    if (location == null)
                    {
                        res.ResCode = ResponseStatusCodeEnum.WareLocationCodeNotExist.GetHashCode();
                        res.ResMsg = item + ResponseStatusCodeEnum.WareLocationCodeNotExist.GetDescription();
                        return res.ToCamelCaseString();
                    }
                    if (location.StateNum != LocationState.LocationState_Full.GetHashCode())
                    {
                        res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                        res.ResMsg = item + ResponseStatusCodeEnum.Fail.GetDescription() + "货位状态不满足出库条件";
                        return res.ToCamelCaseString();
                    }
                    if (location.IsStop == Const.One)
                    {
                        res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                        res.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription() + item + "被禁用";
                        return res.ToCamelCaseString();
                    }
                    var stock = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == location.ContGrpBarCode && p.InvStateCode == InvState.InvEcecState_In.ToString());
                    if (stock == null)
                    {
                        res.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                        res.ResMsg = ResponseStatusCodeEnum.StockNotExist.GetDescription();
                        return res.ToCamelCaseString();
                    }
                    if (stock.ExecStateCode != InvLockState.InvState_Normal.ToString())
                    {
                        res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                        res.ResMsg =  stock.ContGrpBarCode + "状态已被锁定，不允许出库";
                        return res.ToCamelCaseString();
                    }
                    if (stock.InvStateCode != InvState.InvEcecState_In.ToString())
                    {
                        res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                        res.ResMsg = item + "组盘状态不是已入库";
                        return res.ToCamelCaseString();
                    }

                    ptWCS_TaskInfo ptwcsTask = new ptWCS_TaskInfo();
                    ptwcsTask.Status = TaskStatus.NewBuild;
                    ptwcsTask.Type = TaskType.OutDepot;
                    ptwcsTask.Priority = 0;
                    ptwcsTask.Device = "SRM" + location.Tunnel;
                    ptwcsTask.SrmStation = request.EndPoint;
                    ptwcsTask.AddrFrom = item;
                    ptwcsTask.BarCode = stock.ContGrpBarCode;
                    ptwcsTask.StartTime = DateTime.Now;
                    ptwcsTask.AddTime = DateTime.Now;
                    ptwcsTask.EditTime = DateTime.Now;
                    ptwcsTask.AddWho = "wms";
                    ptwcsTask.WarehouseCode = location.WarehouseCode;
                    ptwcsTask.Enabled = true;
                    ptwcsTask.WorkBench = request.EndPoint;
                    ptwcsTask.AddrTo = request.EndPoint;
                    ptwcsTask.Tunnel = location.Tunnel.ToString();
                    ptwcsTask.PalletType = 1;
                    ptwcsTask.Length = stock.LengthQty;
                    ptwcsTask.MaterialCode = stock.MatCode;
                    ptwcsTask.OutType = OutTypeEnum.全自动手动出库任务;
                    ptwcsTask.BusType = request.BusType;
                    _db.BeginTran();

                    var wcs = _ptwcsTaskinfo.InsertReturnEntity(ptwcsTask);
                    var wcstaskold = _mapper.Map<ptWCS_TaskOld>(wcs);
                    _ptwcsTaskold.InsertableSplitTable(wcstaskold);
                    var taskdtl = new ptWCS_TaskDtl()
                    {
                        ID = Guid.NewGuid(),
                        CurPoint = item,
                        AddTime = DateTime.Now,
                        AddWho = "wms",
                        Enabled = true,
                        ParentTaskCode = wcs.ID,
                        Desc = wcs.OutType.ToString(),
                    };
                    _ptwcsTaskdtl.InsertableSplitTable(taskdtl);
                    _baseWareLocationrepository.UpdateSetColumnsTrue(p => new ptBaseWareLocation()
                    {
                        StateNum = LocationState.LocationState_StockOut.GetHashCode(),
                        EditTime = DateTime.Now
                    }, p => p.Code == item);
                    _ptbillInvnow.UpdateSetColumnsTrue(p => new ptBillInvnow()
                    {
                        InvStateCode = InvState.InvEcecState_OutGoing.ToString(),
                        EditTime = DateTime.Now
                    }, p => p.ContGrpBarCode == stock.ContGrpBarCode);
                    var flow = _mapper.Map<ptBillInvFlow>(stock);
                    flow.Id = IdFactory.NewId();
                    flow.InvStateCode = InvState.InvEcecState_OutGoing.ToString();
                    flow.EditTime = DateTime.Now;
                    _ptBillInvFlow.Insert(flow);
                    _db.CommitTran();
                }
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                _logger.LogInformation("出库异常：" + ex.Message);
                res.ResCode = ResponseStatusCodeEnum.DataSaveErr.GetHashCode();
                res.ResMsg = ResponseStatusCodeEnum.DataSaveErr.GetDescription();
                return res.ToCamelCaseString();
            }

            return res.ToCamelCaseString();
        }
        public SRes WareCellInit(int row, int col, int deot, int rowcount, int tun)
        {
            var res = new SRes();
            for (int i = 0; i < row; i++)
            {
                string shlf = tun.ToString();
                if (row == 2)
                {
                    if (i == 0)
                    {
                        shlf = shlf + "L";
                    }
                    else
                    {
                        shlf = shlf + "R";
                    }
                }
                for (int j = 0; j < deot; j++)
                {
                    for (int k = 0; k < col; k++)
                    {
                        var code = new ptBaseWareLocation()
                        {
                            Code = (rowcount + i).ToString() + "-" + (k + 1).ToString() + "-" + (j + 1).ToString() + "-" + shlf + "-" + "01",
                            Tunnel = tun,
                            IsStop = 0,
                            Name = (rowcount + i).ToString() + "行" + (k + 1).ToString() + "列" + (j + 1).ToString() + "层" + shlf + "货架" + 1 + "深度",
                            WarehouseId = 1685164446336552960,
                            WarehouseCode = "pthouse",
                            WareAreaId = 1685164446352102710,
                            StateNum = 1,
                            TypeNum = 1,
                            Size = 1,
                            Row = (rowcount + i),
                            Col = (k + 1),
                            Layer = (j + 1),
                            Depth = 1,
                            SCRel = "",
                            ContGrpId = 0,
                            ContGrpBarCode = "",
                            AddWho = "wms",
                            EditWho = "wms",
                            Shelf = shlf,
                            Sort = j * col + (k + 1),

                        };
                        _baseWareLocationrepository.Insert(code);
                    }
 
                }

            }
            return res;
        }
        public string PdaGroupStock(PtGroupInTaskRequest request)
        {
            var res = new SRes();
            if (!request.RFIDBarCode.Any())
            {
                res.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                res.ResMsg = "RFID" + ResponseStatusCodeEnum.ErrParamNotNull.GetDescription();
                return res.ToCamelCaseString();
            }
            foreach (var item in request.RFIDBarCode)
            {
                var code = _ptbaseContInfo.GetSingle(p => p.ContBarCode == item);
                if (code == null)
                {
                    var initbarcode = InsertContInfo(item);
                    if (initbarcode == false)
                    {
                        res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                        res.ResMsg = "同步" + ResponseStatusCodeEnum.Fail.GetDescription();
                        return res.ToCamelCaseString();
                    }
                }
                var bar = _ptbaseContInfo.GetSingle(p => p.ContBarCode == item);
                //var mater = _materrepository.GetSingle(p => p.Code == barcode.MatCode);
                //if (mater == null)
                //{
                //    res.ResCode = ResponseStatusCodeEnum.BaseMaterCodeNotExist.GetHashCode();
                //    res.ResMsg = item + ResponseStatusCodeEnum.BaseMaterCodeNotExist.GetDescription();
                //    return res.ToCamelCaseString();
                //}
                var stock = _ptbillInvnow.GetSingle(p => p.ContGrpBarCode == item);
                if (stock != null)
                {
                    res.ResCode = ResponseStatusCodeEnum.GroupStockDetailMaterialBarCodeExist.GetHashCode();
                    res.ResMsg = item + ResponseStatusCodeEnum.GroupStockDetailMaterialBarCodeExist.GetDescription();
                    return res.ToCamelCaseString();
                }
                var task = _ptwcsTaskold.AsQueryable().Where(p => p.BarCode == item && p.Status < TaskStatus.Finish).SplitTable(p => p.Take(2)).First();
                if (task != null)
                {
                    res.ResCode = ResponseStatusCodeEnum.WcsTaskExist.GetHashCode();
                    res.ResMsg = item + ResponseStatusCodeEnum.WcsTaskExist.GetDescription();
                    return res.ToCamelCaseString();
                }
                try
                {
                    ptBillInvnow container = new ptBillInvnow();
                    container.ContGrpId = GetId();
                    container.ContGrpBarCode = item;
                    container.BoxBarCode = item;
                    container.InvStateCode = InvState.InvEcecState_BuildUp.ToString();
                    container.InvBarCode = item;
                    container.ExecStateCode = InvLockState.InvState_Normal.ToString();
                    container.InDocsNo = "";
                    container.InDocsRowNo = "";
                    container.WarehouseId = bar.WarehouseId;
                    //container.MatId = mater.Id;
                    //container.MatCode = mater.Code;
                    container.TolWQty = bar.WidthQty;
                    container.NetWQty = bar.LengthQty;
                    container.TareWQty = bar.WeightQty;
                    container.LengthQty = bar.LengthQty;
                    container.RFIDBarCode = item;
                    //container.HWTypeCode = mater.SpoolType;
                    container.SolderQty = bar.HighQty;
                    container.ExecDocsNo = "";
                    container.ExecDocsRowNo = "";
                    container.ExecDocsTypeCode = "";
                    container.HWBarCode = item;
                    container.InvInOut = 1;
                    container.ExecWho = "人工组盘";
                    //container.MatName = mater.Name;
                    container.Size = 1;
                    _db.BeginTran();
                    if (_ptbillInvnow.Insert(container))
                    {
                        _ptBillInvFlow.Insert(_mapper.Map<ptBillInvFlow>(container));
                    }
                    _db.CommitTran();
                }
                catch (Exception ex)
                {
                    _db.RollbackTran();
                    _logger.LogInformation("组盘异常：" + item + ex.Message);
                    res.ResCode = ResponseStatusCodeEnum.DataSaveErr.GetHashCode();
                    res.ResMsg = item + ResponseStatusCodeEnum.DataSaveErr.GetDescription();
                    return res.ToCamelCaseString();
                }
            }
            return res.ToCamelCaseString();
        }
        public string PdaInsterInTask(PtGroupInTaskRequest request)
        {
            var res = new SRes();

            if (!request.RFIDBarCode.Any())
            {
                res.ResCode = ResponseStatusCodeEnum.ErrParamNotNull.GetHashCode();
                res.ResMsg = "RFID" + ResponseStatusCodeEnum.ErrParamNotNull.GetDescription();
                return res.ToCamelCaseString();
            }
            try
            {
                if (request.BusType == 1)
                {
                    foreach (var item in request.RFIDBarCode)
                    {
                        var stock = _ptbillInvnow.GetSingle(p => p.RFIDBarCode == item && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
                        if (stock == null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        var task = _ptwcsTaskold.AsQueryable().Where(p => p.BarCode == item && p.Status < TaskStatus.Finish).SplitTable(p => p.Take(1)).First();
                        if (task != null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.WcsTaskExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.WcsTaskExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        //分解入库任务
                        var it = InsertTaskIn(new PtTaskRsponse() { BusType = TaskBusType.TaskBusType_HJ_QualityStockIn.GetDescription(), ContGrpBarCode = stock.ContGrpBarCode, ContGrpId = stock.ContGrpId, StartPoint = request.Equip, Size = 1, Remark = stock.MatCode });
                        if (!it)
                        {
                            res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                            res.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                            return res.ToCamelCaseString();
                        }
                    }
                }
                else if (request.BusType == 2)
                {
                    foreach (var item in request.RFIDBarCode)
                    {
                        var stock = _ptbillInvnow.GetSingle(p => p.RFIDBarCode == item && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
                        if (stock == null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        var task = _ptwcsTaskold.AsQueryable().Where(p => p.BarCode == item && p.Status < TaskStatus.Finish).SplitTable(p => p.Take(1)).First();
                        if (task != null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.WcsTaskExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.WcsTaskExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        //分解入库任务
                        var it = InsertTaskIn(new PtTaskRsponse() { BusType = TaskBusType.TaskBusType_HJ_AnewStockIn.GetDescription(), ContGrpBarCode = stock.ContGrpBarCode, ContGrpId = stock.ContGrpId, StartPoint = request.Equip, Size = 1, Remark = stock.MatCode });
                        if (!it)
                        {
                            res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                            res.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                            return res.ToCamelCaseString();
                        }
                    }
                }
                else if (request.BusType == 3)
                {
                    foreach (var item in request.RFIDBarCode)
                    {
                        var stock = _ptbillInvnow.GetSingle(p => p.RFIDBarCode == item && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
                        if (stock == null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        var task = _ptwcsTaskold.AsQueryable().Where(p => p.BarCode == item && p.Status < TaskStatus.Finish).SplitTable(p => p.Take(1)).First();
                        if (task != null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.WcsTaskExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.WcsTaskExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        //分解入库任务
                        var it = InsertTaskIn(new PtTaskRsponse() { BusType = TaskBusType.TaskBusType_HJ_OtherStockIn.GetDescription(), ContGrpBarCode = stock.ContGrpBarCode, ContGrpId = stock.ContGrpId, StartPoint = request.Equip, Size = 1, Remark = stock.MatCode });
                        if (!it)
                        {
                            res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                            res.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                            return res.ToCamelCaseString();
                        }
                    }
                }
                else if (request.BusType == 4)
                {
                    foreach (var item in request.RFIDBarCode)
                    {
                        var stock = _ptbillInvnow.GetSingle(p => p.RFIDBarCode == item && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
                        if (stock == null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        var task = _ptwcsTaskold.AsQueryable().Where(p => p.BarCode == item && p.Status < TaskStatus.Finish).SplitTable(p => p.Take(1)).First();
                        if (task != null)
                        {
                            res.ResCode = ResponseStatusCodeEnum.WcsTaskExist.GetHashCode();
                            res.ResMsg = item + ResponseStatusCodeEnum.WcsTaskExist.GetDescription();
                            return res.ToCamelCaseString();
                        }
                        //分解入库任务
                        var it = InsertTaskIn(new PtTaskRsponse() { BusType = TaskBusType.TaskBusType_HJ_PurchaseSpoolStockIn.GetDescription(), ContGrpBarCode = stock.ContGrpBarCode, ContGrpId = stock.ContGrpId, StartPoint = request.Equip, Size = 1, Remark = stock.MatCode });
                        if (!it)
                        {
                            res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                            res.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                            return res.ToCamelCaseString();
                        }
                    }
                }
                else
                {
                    res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                    res.ResMsg = "RFID：" + string.Join(',', request.RFIDBarCode) + "业务类型错误";
                    return res.ToCamelCaseString();
                }
            }
            catch (Exception ex)
            {
                _logger.LogInformation("任务下发失败：" + ex.Message);
                res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                res.ResMsg = ResponseStatusCodeEnum.Fail.GetDescription();
                return res.ToCamelCaseString();
            }
            return res.ToCamelCaseString();
        }
        private bool InsertTaskIn(PtTaskRsponse request)
        {
            var bar = _ptbaseContInfo.GetSingle(p => p.ContBarCode == request.ContGrpBarCode);
            if (bar == null)
            {
                return false;
            }
            var ware = _baseWareHouserepository.GetSingle(p => p.Id == bar.WarehouseId);
            if (ware == null)
            {
                return false;
            }
            try
            {
                ptWCS_TaskInfo billTask = new ptWCS_TaskInfo();
                billTask.Status = TaskStatus.NewBuild;
                billTask.Type = TaskType.EnterDepot;
                billTask.Priority = 0;
                billTask.Device = "srm";
                billTask.SrmStation = request.StartPoint;
                billTask.AddrFrom = request.StartPoint;
                billTask.BarCode = request.ContGrpBarCode;
                billTask.StartTime = DateTime.Now;
                billTask.AddWho = "wms";
                billTask.WarehouseCode = ware.Code;
                billTask.Enabled = true;
                billTask.WorkBench = request.StartPoint;
                billTask.AddrTo = "";
                //billTask.Floor = 2;
                billTask.Tunnel = "";
                billTask.PalletType = 1;
                billTask.AddTime = DateTime.Now;
                billTask.EditTime = DateTime.Now;
                billTask.MaterialCode = request.Remark;
                billTask.MatCode = request.Remark;
                billTask.BusType = request.BusType;

                _db.BeginTran();
                var wcs = _ptwcsTaskinfo.InsertReturnEntity(billTask);
                var taskold = _mapper.Map<ptWCS_TaskOld>(wcs);
                _ptwcsTaskold.InsertableSplitTable(taskold);
                var taskdetail = new ptWCS_TaskDtl()
                {
                    ID = Guid.NewGuid(),
                    CurPoint = request.StartPoint,
                    AddTime = DateTime.Now,
                    AddWho = "wms",
                    Enabled = true,
                    ParentTaskCode = wcs.ID,
                    Desc = request.StartPoint + "pda入库",
                };
                _ptwcsTaskdtl.InsertableSplitTable(taskdetail);
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                return false;
            }
            return true;
        }
        private bool InsertContInfo(string code)
        {
            try
            {
                ptBaseContainer barcode = new ptBaseContainer();
                barcode.ContBarCode = code;
                barcode.TypeCode = ContainerType.ContainerType_RFID.ToString();
                barcode.PrintQty = 1;
                //barcode.WarehouseId = 1668442390064664576;
                barcode.Name = code;
               // barcode.WeightQty = 158;
                _ptbaseContInfo.Insert(barcode);
            }
            catch (Exception ex)
            {
                return false;
            }
            return true;
        }

        /// <summary>
        /// 分配巷道
        /// </summary>
        /// <param name="reqEntity"></param>
        /// <returns></returns>
        public SRes<string> GetPtTunnelPriorityList(GetTunnelPriorityListRequest reqEntity)
        {
            var result = new SRes<string>();
            var wcstask = _ptwcsTaskold.AsQueryable().Where(p => p.ID == reqEntity.TaskNum).SplitTable(p => p.Take(2)).First();
            if (wcstask == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WcsTaskNotExist.GetHashCode();
                result.ResMsg = reqEntity.TaskNum + ResponseStatusCodeEnum.WcsTaskNotExist.GetDescription();
                return result;
            }
            //先处理库存
            var p = InsertStockInfo(reqEntity.Memo1);
            if (p.ResCode != ResponseStatusCodeEnum.Sucess.GetHashCode())
            {
                result.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                result.ResMsg = "库存更新" + ResponseStatusCodeEnum.Fail.GetDescription();
                return result;
            }

            //获取任务数占用最少的
            var wcstasks = _ptwcsTaskinfo.GetList(p => p.WarehouseCode == wcstask.WarehouseCode && p.Type == TaskType.EnterDepot && p.Status < TaskStatus.Finish &&
            p.Tunnel != "0" && p.Tunnel != "" && p.Tunnel != null).ToList();
            var tunnelcountlist = new List<TunnelCountTemp>();
            var runningtasks = wcstasks;
            if (runningtasks.Any())
            {
                tunnelcountlist = (from task in runningtasks.GroupBy(p => p.Tunnel)
                                   select new TunnelCountTemp
                                   {
                                       Tunnel = task.Key,
                                       Count = task.Count()
                                   }).ToList();
            }

            //获取库位所有巷道列表
            var alltunnels = _baseWareLocationrepository.GetList().Select(p => p.Tunnel).Distinct();
            foreach (var item in alltunnels)
            {
                if (!tunnelcountlist.Where(p => p.Tunnel == item.ToString()).Any())
                {
                    tunnelcountlist.Add(new TunnelCountTemp()
                    {
                        Tunnel = item.ToString(),
                        Count = 0
                    });
                }
            }
            var tasktunnelcountlist = tunnelcountlist.OrderBy(p => p.Count).ToList(); 
            var warehouse = _baseWareHouserepository.GetSingle(p => p.Code == wcstask.WarehouseCode);
            //获取已占用库位最少的货架
            var threshold = 5; //int.Parse(ConfigUtil.GetConfiguration["Threshold"]);//阈值
            //获取所有有货的货位
            var locationsreturn = _baseWareLocationrepository.GetList(p => p.WarehouseId == warehouse.Id && p.StateNum == LocationState.LocationState_Full.GetHashCode());
            //获取所有可用货位的数量
            var shelflocationcount = _baseWareLocationrepository.GetList(p => p.WarehouseCode == wcstask.WarehouseCode && p.TypeNum == LocationType.LocationType_StorageLocation.GetHashCode() && p.IsStop == 0).GroupBy(p => new { p.Tunnel, p.Shelf }).Select(p => new { Tunnel = p.Key.Tunnel, Shelf = p.Key.Shelf, LocationCount = p.Select(q => q.Id).Count() });
            if (locationsreturn == null || !locationsreturn.Any())
            {
                result.ResData = string.Join(",", tasktunnelcountlist.OrderBy(p => p.Count).Select(p => p.Tunnel));
            }
            else
            {
                var grouplocationtunnels = (from location in locationsreturn.GroupBy(p => p.Tunnel)
                                            select new TunnelCountTemp
                                            {
                                                Tunnel = location.Key.ToString(),
                                                Count = location.Count(),
                                                Proportion = location.Count() / (shelflocationcount.Where(p => p.Tunnel == location.Key).Any() ? decimal.Parse(shelflocationcount.Where(p => p.Tunnel == location.Key).Sum(p => p.LocationCount).ToString()) : 1)
                                            }).ToList().OrderBy(p => p.Count).ToList();


                foreach (var item in alltunnels)
                {
                    if (!grouplocationtunnels.Where(p => p.Tunnel == item.ToString()).Any())
                    {
                        grouplocationtunnels.Add(new TunnelCountTemp()
                        {
                            Tunnel = item.ToString(),
                            Count = 0,
                            Proportion = 0
                        });
                    }
                }

                grouplocationtunnels = grouplocationtunnels.OrderBy(p => p.Proportion).ToList();
                var sorttunnels = grouplocationtunnels.OrderBy(p => p.Proportion).Select(p => p.Tunnel).ToList();
                for (var i = 0; i < grouplocationtunnels.Count - 1; i++)
                {
                    if (tasktunnelcountlist.Where(p => p.Tunnel == grouplocationtunnels[i].Tunnel).First().Count - threshold > tasktunnelcountlist.Where(p => p.Tunnel == grouplocationtunnels[i + 1].Tunnel).First().Count)
                    {
                        sorttunnels[i] = grouplocationtunnels[i + 1].Tunnel;
                        sorttunnels[i + 1] = grouplocationtunnels[i].Tunnel;
                        i++;
                    }
                    else
                    {
                        sorttunnels[i] = grouplocationtunnels[i].Tunnel;
                    }
                }
                result.ResData = string.Join(",", sorttunnels);
            }
            //删除没有空闲货位的货架
            var arrresultTunnels = result.ResData.Split(',');
            //获取可分配货位的数
            var emptylocationsreturn = _baseWareLocationrepository.GetList(p => p.WarehouseCode == wcstask.WarehouseCode && p.StateNum == LocationState.LocationState_Empty.GetHashCode() && p.IsStop == 0);
            var resultTunenls = new List<string>();
            foreach (var sorttunnel in arrresultTunnels)
            {
                var tunneltaskcount = wcstasks.Where(p => p.Tunnel == sorttunnel).Count();
                int left = 0;

                if (emptylocationsreturn.Where(p => p.Tunnel == int.Parse(sorttunnel)).Count() - tunneltaskcount > left)
                {
                    resultTunenls.Add(sorttunnel);
                }  
            }
            result.ResData = string.Join(",", resultTunenls);
            //根据配置过滤禁用的巷道
            var disabletunnels = _sysconfigrepository.GetList(p => p.SType == "InStop" && !string.IsNullOrEmpty(p.SContent));
            if (disabletunnels != null && disabletunnels.Any())
            {
                var resultTunenlsNew = new List<string>();
                var resultTunenlsTemp = result.ResData.Split(',');
                foreach (var tun in resultTunenlsTemp)
                {
                    if (!disabletunnels.Select(p => p.Default1).Contains(tun))
                    {
                        resultTunenlsNew.Add(tun);
                    }
                }
                result.ResData = string.Join(",", resultTunenlsNew);

            }
            return result;
        }
        public SRes<PtApplyStockInLocResponse> PtApplyStockInLoc(PtApplyStockInLocRequest reqEntity)
        {
            var res = ApplyStockInLocTemp(reqEntity);
            if (string.IsNullOrEmpty(res.ResData.CellNo))
            {
                return res;
            }

            try
            {
                _db.BeginTran();
                //更新货位
                _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_StockIn.GetHashCode(), ContGrpBarCode = "", ContGrpId = 0, EditTime = DateTime.Now },
                       p => p.Code == res.ResData.CellNo);
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                _logger.LogInformation(ex.ToString());
            }
            return res;
        }
        private SRes<PtApplyStockInLocResponse> ApplyStockInLocTemp(PtApplyStockInLocRequest reqEntity)
        {
            var res = new SRes<PtApplyStockInLocResponse>()
            {
                ResCode = ResponseStatusCodeEnum.Sucess.GetHashCode(),
                ResMsg = ResponseStatusCodeEnum.Sucess.GetDescription(),
                ResData = new PtApplyStockInLocResponse()
            };
            var wcstask = _ptwcsTaskold.AsQueryable().Where(p => p.ID == reqEntity.TaskNum).SplitTable(tabs => tabs.Take(2)).First(); ;
            if (wcstask == null)
            {
                res.ResCode = ResponseStatusCodeEnum.WcsTaskNotExist.GetHashCode();
                res.ResMsg = reqEntity.TaskNum + ResponseStatusCodeEnum.WcsTaskNotExist.GetDescription();
                return res;
            }
            if (wcstask.Type == TaskType.OutDepot)
            {
                res.ResCode = ResponseStatusCodeEnum.ErrParam.GetHashCode();
                res.ResMsg = "该任务是出库任务，不能分配货位；wms任务号" + wcstask.ID;
                return res;
            }
            if (!string.IsNullOrEmpty(wcstask.AddrTo) && wcstask.AddrTo != "srm")
            {

                res.ResData.TunnelNum = wcstask.Tunnel;
                res.ResData.CellNo = wcstask.AddrTo;
                res.ResData.Row = wcstask.AddrTo.Split('-')[0] != null ? int.Parse(wcstask.AddrTo.Split('-')[0]) : 0;
                res.ResData.Colomn = wcstask.AddrTo.Split('-')[1] != null ? int.Parse(wcstask.AddrTo.Split('-')[1]) : 0;
                res.ResData.Layer = wcstask.AddrTo.Split('-')[2] != null ? int.Parse(wcstask.AddrTo.Split('-')[2]) : 0;
                return res;
            }
            if (reqEntity.TunnelNum <= 0)
            {
                res.ResCode = ResponseStatusCodeEnum.NotTunnelNum.GetHashCode();
                res.ResMsg = reqEntity.TaskNum + ResponseStatusCodeEnum.NotTunnelNum.GetDescription();
                return res;
            }
            var warehouse = _baseWareHouserepository.GetFirst(p => p.Code == wcstask.WarehouseCode);
            if (warehouse == null)
            {
                res.ResCode = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetHashCode();
                res.ResMsg = wcstask.WarehouseCode + ResponseStatusCodeEnum.WarehouseCodeNotExist.GetDescription();
                return res;
            }
            //验证库存
            var stock = _ptbillInvnow.GetFirst(p => p.HWBarCode == wcstask.BarCode && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
            if (stock == null)
            {
                res.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                res.ResMsg = wcstask.BarCode + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                return res;
            }
            var locell = new PtApplyLocRequest()
            {
                MaterialId = stock.MatId,
                MaterialCode = stock.MatCode,
                Size = stock.Size,
                TunnelNum = reqEntity.TunnelNum,
                WarehuoseId = warehouse.Id,
                IsMove = wcstask.Type == TaskType.TransferDepot ? true : false,
            };
            //预留货位数量
            var emptyLoc = _baseWareLocationrepository.AsQueryable().Where(p => p.IsStop == 0
            && p.StateNum == LocationState.LocationState_Empty.GetHashCode()
            && p.TypeNum == LocationType.LocationType_StorageLocation.GetHashCode()
            && p.Tunnel == locell.TunnelNum
            && p.WarehouseId == locell.WarehuoseId
            && p.Size == locell.Size
            ).OrderBy(p => p.Sort).ToList();

            if (!emptyLoc.Any())
            {
                res.ResCode = ResponseStatusCodeEnum.NotEnoughLocation.GetHashCode();
                res.ResMsg = reqEntity.TunnelNum + ResponseStatusCodeEnum.NotEnoughLocation.GetDescription();
                return res;
            }
            //移库预留货位
            if (!locell.IsMove && emptyLoc.Count <= int.Parse(AppSettings.GetConfig("IsMoveCellCount")))
            {
                res.ResCode = ResponseStatusCodeEnum.NotEnoughLocation.GetHashCode();
                res.ResMsg = reqEntity.TunnelNum + "巷道的可用货位数" + emptyLoc.Count + ",禁止分配货位，预留移库使用";
                return res;
            }

            var loc = emptyLoc.First();
            res.ResData.TunnelNum = loc.Tunnel.ToString();
            res.ResData.CellNo = loc.Code;
            res.ResData.Row = loc.Row;
            res.ResData.Colomn = loc.Col;
            res.ResData.Layer = loc.Layer;
            return res;
        }
        public SRes<int> PtCompleteTask(CompleteTaskRequest reqDto)
        {
            var result = new SRes<int>()
            {
                ResCode = ResponseStatusCodeEnum.Sucess.GetHashCode(),
                ResMsg = ResponseStatusCodeEnum.Sucess.GetDescription(),
                ResData = reqDto.TaskNum
            };
            var task = _ptwcsTaskold.AsQueryable().Where(p => p.ID == reqDto.TaskNum).SplitTable(tabs => tabs.Take(2)).First();
            if (task == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WcsTaskNotExist.GetHashCode();
                result.ResMsg = reqDto.TaskNum + ResponseStatusCodeEnum.WcsTaskNotExist.GetDescription();
                return result;
            }
            var warehouse = _baseWareHouserepository.GetSingle(p => p.Code == task.WarehouseCode);
            if (warehouse == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WarehouseCodeNotExist.GetHashCode();
                result.ResMsg = task.WarehouseCode + ResponseStatusCodeEnum.WarehouseCodeNotExist.GetDescription();
                return result;
            }
            if (task.Type == TaskType.EnterDepot)
            {
                //库存,货位
                try
                {
                    var stock = _ptbillInvnow.GetFirst(p => p.ContGrpBarCode == task.BarCode && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
                    if (stock == null)
                    {
                        result.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                        result.ResMsg = task.BarCode + "没有已组盘的信息";
                        return result;
                    }
                    _db.BeginTran();
                    int row = int.Parse(task.AddrTo.Split('-')[0]);
                    int col = int.Parse(task.AddrTo.Split('-')[1]);
                    int layer = int.Parse(task.AddrTo.Split('-')[2]);

                    //更新库存
                    _ptbillInvnow.UpdateModelColumns(p => new ptBillInvnow() { InvStateCode = InvState.InvEcecState_In.ToString(), PutRow = row, PutCol = col, PutLayer = layer, OneInTime = DateTime.Now, EditTime = DateTime.Now, ExecStateCode = InvLockState.InvState_Lock.ToString() },
                           p => p.ContGrpBarCode == task.BarCode && p.InvStateCode == InvState.InvEcecState_BuildUp.ToString());
                    _ptbillInvinit.Delete(p => p.ContGrpBarCode == stock.ContGrpBarCode);
                    //更新货位
                    _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_Full.GetHashCode(), ContGrpBarCode = stock.ContGrpBarCode, ContGrpId = stock.ContGrpId, EditTime = DateTime.Now },
                           p => p.Code.Contains(task.AddrTo));
                    var stocklist = _ptbillInvnow.GetList(p => p.ContGrpBarCode == task.BarCode && p.InvStateCode == InvState.InvEcecState_In.ToString());
                    foreach (var item in stocklist)
                    {
                        item.Id = IdFactory.NewId();
                        item.AddTime = DateTime.Now;
                    }
                    _ptBillInvFlow.InsertRange(_mapper.Map<List<ptBillInvFlow>>(stocklist));
                    var list = new List<ptBillPushinfo>();

                    string pushtype = "";
                    if (task.BusType == PtTaskBusType.TaskBusType_PT_PurchaseStockIn.GetDescription())
                    {
                        pushtype = PtFackbeekType.InterfaceType_PT_PurchaseStockIn.ToString();
                    }
                    else if (task.BusType == PtTaskBusType.TaskBusType_PT_ProductionBackStockIn.GetDescription())
                    {
                        pushtype = PtFackbeekType.ReturnMat.ToString();
                    }

                    //回调数据
                    foreach (var item in stocklist)
                    {
                        list.Add(new ptBillPushinfo
                        {
                            DocsNo = stock.InDocsNo,
                            TypeCode = pushtype,
                            RFIDBarCode = stock.ContGrpBarCode,
                            HWBarCode = stock.RodBarCode,
                            CLBarCode = item.CLBarCode,
                            WarehouseId = warehouse.Id,
                            WarehouseCode = warehouse.Code,
                            WareCellId = 0,
                            WareCellCode = task.AddrTo,
                            MatId = item.MatId,
                            MatCode = item.MatCode,
                            MatName = item.MatName,
                            ReqNo = Guid.NewGuid().ToString()
                        });
                    }
                    _ptbillPushinfo.InsertRange(list);
                    _db.CommitTran();
                }
                catch (Exception ex)
                {
                    _db.RollbackTran();
                    result.ResCode = ResponseStatusCodeEnum.InnerServerErr.GetHashCode();
                    result.ResMsg = task.ID + "完成任务异常";
                    _logger.LogInformation("完成任务异常" + ex.ToString());
                }
            }
            else if (task.Type == TaskType.OutDepot)
            {
                //库存删除
                var stocklist = _ptbillInvnow.GetList(p => p.ContGrpBarCode == task.BarCode && p.InvStateCode == InvState.InvEcecState_OutGoing.ToString());
                if (stocklist == null || !stocklist.Any())
                {
                    result.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                    result.ResMsg = reqDto.TaskNum + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                    return result;
                }
                var flowlist = _mapper.Map<List<ptBillInvFlow>>(stocklist);
                foreach (var item in flowlist)
                {
                    item.Id = IdFactory.NewId();
                    item.InvStateCode = InvState.InvEcecState_Out.ToString();
                    item.AddTime = DateTime.Now;
                    item.Memo = "任务完成";
                }
                var list = new List<ptBillPushinfo>();
                string pushtype = "";
                if (task.BusType == PtTaskBusType.TaskBusType_PT_ProductionStockOut.GetDescription())
                {
                    pushtype = PtFackbeekType.PickMat.ToString();
                    //回调数据
                    foreach (var item in stocklist)
                    {
                        list.Add(new ptBillPushinfo
                        {
                            DocsNo = item.InDocsNo,
                            TypeCode = pushtype,
                            RFIDBarCode = item.ContGrpBarCode,
                            HWBarCode = item.HWBarCode,
                            CLBarCode = item.CLBarCode,
                            WarehouseId = warehouse.Id,
                            WarehouseCode = warehouse.Code,
                            WareCellId = 0,
                            WareCellCode = task.AddrTo,
                            MatId = item.MatId,
                            MatCode = item.MatCode,
                            MatName = item.MatName,
                            ReqNo = Guid.NewGuid().ToString()
                        });
                    }
                }

                try
                {
                    _db.BeginTran();
                    _ptbillInvnow.Delete(p => stocklist.Select(p => p.Id).ToList().Contains(p.Id));
                    _ptbillInvinit.Delete(p => p.ContGrpBarCode == task.BarCode);

                    _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_Empty.GetHashCode(), ContGrpBarCode = "", ContGrpId = 0, EditTime = DateTime.Now },
                        p => p.StateNum == LocationState.LocationState_StockOut.GetHashCode() && p.ContGrpId == flowlist.First().ContGrpId && p.Code.Contains(task.AddrFrom));
                    _ptbillPushinfo.InsertRange(list);
                    _ptBillInvFlow.InsertRange(flowlist);

                    _db.CommitTran();
                }
                catch (Exception ex)
                {
                    _db.RollbackTran();
                    _logger.LogInformation(ex.ToString());
                    result.ResCode = ResponseStatusCodeEnum.InnerServerErr.GetHashCode();
                    result.ResMsg = task.ID + "完成任务异常";
                }
            }
            else if (task.Type == TaskType.TransferDepot)
            {
                var fromcell = _baseWareLocationrepository.GetFirst(p => p.Code == task.AddrFrom);
                var grcontid = fromcell.ContGrpId;
                var grcontcode = fromcell.ContGrpBarCode;
                var fromcellno = fromcell.Code;
                var tocellno = task.AddrTo;

                try
                {
                    _db.BeginTran();
                    _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_Empty.GetHashCode(), ContGrpBarCode = "", ContGrpId = 0, EditTime = DateTime.Now }, p => p.Code.Contains(fromcellno));
                    _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_Full.GetHashCode(), ContGrpBarCode = grcontcode, ContGrpId = grcontid, EditTime = DateTime.Now }, p => p.Code.Contains(tocellno));

                    int row = int.Parse(tocellno.Split('-')[0]);
                    int col = int.Parse(tocellno.Split('-')[1]);
                    int layer = int.Parse(tocellno.Split('-')[2]);
                    _ptbillInvnow.UpdateModelColumns(p => new ptBillInvnow() { PutRow = row, PutCol = col, PutLayer = layer }, p => p.ContGrpId == grcontid && p.InvStateCode == InvState.InvEcecState_In.ToString());
                    var stock = _ptbillInvnow.GetFirst(p => p.ContGrpId == grcontid && p.ContGrpBarCode == grcontcode && p.InvStateCode == InvState.InvEcecState_In.ToString());

                    //流水表
                    var flow = _mapper.Map<ptBillInvFlow>(stock);
                    flow.Id = IdFactory.NewId();
                    flow.AddTime = DateTime.Now;
                    flow.Memo = grcontcode + "移库(" + fromcellno + "至" + tocellno + ")";
                    _ptBillInvFlow.Insert(flow);
                    //推送表
                    _db.CommitTran();
                }
                catch (Exception ex)
                {
                    _db.RollbackTran();
                    result.ResCode = ResponseStatusCodeEnum.InnerServerErr.GetHashCode();
                    result.ResMsg = task.ID + "完成任务异常";
                    _logger.LogInformation("完成任务异常" + ex.ToString());
                }

            }
            return result;
        }
        public SRes<int> PtSrmPickOutCompleted(PtSrmPickOutCompletedRequest reqDto)
        {
            var result = new SRes<int>()
            {
                ResCode = ResponseStatusCodeEnum.Sucess.GetHashCode(),
                ResMsg = ResponseStatusCodeEnum.Sucess.GetDescription(),
                ResData = reqDto.TaskNum
            };
            var wcstask = _ptwcsTaskold.AsQueryable().Where(p => p.ID == reqDto.TaskNum).SplitTable(tabs => tabs.Take(2)).First();
            if (wcstask == null)
            {
                result.ResCode = ResponseStatusCodeEnum.WcsTaskNotExist.GetHashCode();
                result.ResMsg = reqDto.TaskNum + ResponseStatusCodeEnum.WcsTaskNotExist.GetDescription();
                return result;
            }
            if (wcstask.Type != TaskType.OutDepot)
            {
                result.ResCode = ResponseStatusCodeEnum.OnlyStockOutAvil.GetHashCode();
                result.ResMsg = reqDto.TaskNum + ResponseStatusCodeEnum.OnlyStockOutAvil.GetDescription();
                return result;
            }
            if (wcstask.Status >= TaskStatus.Finish)
            {
                result.ResCode = ResponseStatusCodeEnum.WcsTaskStateIsComplete.GetHashCode();
                result.ResMsg = reqDto.TaskNum + ResponseStatusCodeEnum.WcsTaskStateIsComplete.GetDescription();
                return result;
            }
            try
            {
                _db.BeginTran();
                //更新库存
                _ptbillInvnow.UpdateModelColumns(p => new ptBillInvnow() { PutRow = 0, PutCol = 0, PutLayer = 0 }, p => p.InvStateCode == InvState.InvEcecState_OutGoing.ToString() && p.ContGrpBarCode == wcstask.BarCode);
                var stocklist = _ptbillInvnow.GetList(p => p.ContGrpBarCode == wcstask.BarCode && p.InvStateCode == InvState.InvEcecState_OutGoing.ToString());
                if (stocklist == null || !stocklist.Any())
                {
                    result.ResCode = ResponseStatusCodeEnum.StockNotExist.GetHashCode();
                    result.ResMsg = reqDto.TaskNum + ResponseStatusCodeEnum.StockNotExist.GetDescription();
                    return result;
                }
                var flowlist = _mapper.Map<List<ptBillInvFlow>>(stocklist);
                foreach (var item in flowlist)
                {
                    item.Id = IdFactory.NewId();
                    item.AddTime = DateTime.Now;
                    item.Memo = "堆垛机出库放货完成";
                }
                //货位
                _baseWareLocationrepository.UpdateModelColumns(p => new ptBaseWareLocation() { StateNum = LocationState.LocationState_Empty.GetHashCode(), ContGrpBarCode = "", ContGrpId = 0, EditTime = DateTime.Now },
                         p => p.ContGrpBarCode == wcstask.BarCode && p.Code.Contains(wcstask.AddrFrom));
                _ptBillInvFlow.InsertRange(flowlist);
                _db.CommitTran();
            }
            catch (Exception ex)
            {
                _db.RollbackTran();
                _logger.LogInformation(ex.ToString());
                result.ResCode = ResponseStatusCodeEnum.InnerServerErr.GetHashCode();
                result.ResMsg = wcstask.ID + "堆垛机出库放货完成异常";
            }

            return result;
        }
        public SRes GetSyncMaterInfo(PtSyncMaterInfoListRequest ResData)
        {
            var res = new SRes();
            if (!string.IsNullOrEmpty(ResData.MatCode))
            {
                ResData.UpdatedTime = DateTime.Now.ToString();
                if (_materrepository.IsAny(p => p.Code == ResData.MatCode))
                {
                    _materrepository.UpdateModelColumns(p => new ptBaseMater() { IsHold = ResData.IsHold, HoldDuration = ResData.HoldDuration, Name = ResData.MatName, EditTime = DateTime.Now, Description = ResData.Describe },
                       p => p.Code == ResData.MatCode);
                }
                else
                {
                    var model = _mapper.Map<ptBaseMater>(ResData);
                    model.AddTime = DateTime.Now;
                    model.WarehouseId = 263682712;
                    _materrepository.Insert(model);
                }
            }
            return res;
        }
    }
}