ZT_WMS/wms.api/Controllers/PtController.cs

using AutoMapper;
using MathNet.Numerics.Distributions;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using System.Reflection.Emit;
using wms.dto;
using wms.dto.request;
using wms.dto.request.pt;
using wms.dto.request.pt.dto;
using wms.dto.request.share;
using wms.dto.response;
using wms.dto.response.pt;
using wms.service.IService;
using wms.sqlsugar;
using wms.sqlsugar.model.pt;
using wms.util.Ext;

namespace wms.api.Controllers
{
    /// <summary>
    /// 盘条库控制器
    /// </summary>
    [Route("api/[controller]/[action]")]
    [ApiController]
    public class PtController : BaseController
    {
        private readonly IPTService _ptService;
        private readonly ILogger<PtController> _logger;
        private readonly IMapper _mapper;
        static object lockerPurchaseBillTrans = new object();
        static object lockerErpUnlockStock = new object();
        static object lockerProductionStockOut = new object();
        static object lockerProductionFeedBack = new object();
        static object lockerStockChange = new object();
        static object lockerProductionBack = new object();
        static object lockerPtPurchTaskIn = new object();
        static object lockerPtApplyStockInLoc = new object();
        static object lockerPtCompleteTask = new object();
        static object lockerPtSrmPickOutCompleted = new object();
        static object lockerSyncMaterInfoList = new object();
        static object lockerPtWcsProductionOutTask = new object();
        static object lockerGetPtTunnelList = new object();


        public PtController(IPTService ptService, ILogger<PtController> logger, IMapper mapper) : base(ptService)
        {
            _ptService = ptService;
            _logger = logger;
            _mapper = mapper;
        }

        /// <summary>
        /// 同步物料基础信息
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        [HttpPost]
        public string SyncMaterInfo(SyncMaterInfoRequest reqBody)
        {
            var result = new SRes();
            //_logger.LogInformation("请求参数：{@reqBody},{aa}", reqBody,1);
            PTSyncMaterInfoResponse resbody = JsonConvert.DeserializeObject<PTSyncMaterInfoResponse>(WmsServiceExportApi(reqBody));
            if (reqBody.SyncType == 1)
            {
                reqBody.PageIndex = 1;
                while (resbody.ResData.Any())
                {
                    _ptService.SyncMaterInfo(resbody.ResData);
                    reqBody.PageIndex++;
                    resbody = JsonConvert.DeserializeObject<PTSyncMaterInfoResponse>(WmsServiceExportApi(reqBody));
                }
            }
            else if (reqBody.SyncType == 2)
            {
                //拿到增量
                var increconf = _ptService.GetSysConfigByCode(Const.MESMaterialInitIncrement);
                if (increconf != null)
                {
                    reqBody.StartTime = DateTime.Parse(increconf.SContent);
                    //reqBody.Count = int.Parse(increconf.Remark);
                    resbody = JsonConvert.DeserializeObject<PTSyncMaterInfoResponse>(WmsServiceExportApi(reqBody));
                    if (resbody.ResData.Any())
                    {
                        if (_ptService.SyncMaterInfo(resbody.ResData))
                        {
                            var lastdata = resbody.ResData.OrderBy(p => p.UpdatedTime).Last();
                            _ptService.UpdateSysConfigModelColumns(new sqlsugar.model.UpdateModelColumns<ptSysConfig>()
                            {
                                Columns = it => new ptSysConfig { SContent = lastdata.UpdatedTime.ToString("yyyy-MM-dd HH:mm:ss.fff") },
                                WhereExpression = it => it.Code == Const.MESMaterialInitIncrement
                            });
                        }
                    }
                    else
                    {
                        result.ResCode = ResponseStatusCodeEnum.NoResult.GetHashCode();
                        result.ResMsg = ResponseStatusCodeEnum.NoResult.GetDescription();
                    }
                }
                else
                {
                    result.ResCode = ResponseStatusCodeEnum.AccountError.GetHashCode();
                    result.ResMsg = "没有配置信息" + Const.MESMaterialInitIncrement;
                }
            }
            else
            {
                if (!string.IsNullOrEmpty(reqBody.MatCode))
                {
                    resbody = JsonConvert.DeserializeObject<PTSyncMaterInfoResponse>(WmsServiceExportApi(reqBody));
                    if (resbody.ResData.Any())
                    {
                        if (_ptService.SyncMaterInfo(resbody.ResData))
                        {

                        }
                    }
                }
            }


            return result.ToCamelCaseString();
        }
        /// <summary>
        /// 采购到货单/采购退货单/到货重挂清单接口
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes PurchaseBillTrans(PurchaseBillTransReqest reqDto)
        {
            return ConcurrencyReqControl<PurchaseBillTransReqest, SRes>(lockerPurchaseBillTrans, "PurchaseBillTrans" + reqDto.BillCode, reqDto.BillCode, reqDto, _ptService.PurchaseBillTrans);
        }
        /// <summary>
        /// 盘条主数据接收
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes PtSyncMaterInfoList(PtSyncMaterInfoListRequest reqDto)
        {
            var res = new SRes();
            return ConcurrencyReqControl<PtSyncMaterInfoListRequest, SRes>(lockerSyncMaterInfoList, "PtSyncMaterInfoList", "物料主数据推送", reqDto, _ptService.GetSyncMaterInfo);
        }
        /// <summary>
        /// 采购到货单入库反馈/采购退货出库反馈/异常出库重挂反馈接口
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes PurchaseBillTransFeedBack(PtAutoPurchData request)
        {
            var res = new SRes();
            //自动推送
            if (request.Type == "1")
            {
                var list = _ptService.GetBillFeedbackList();
                if (!list.Any())
                {
                    res.ResCode = ResponseStatusCodeEnum.Fail.GetHashCode();
                    res.ResMsg = "没有取到数据" + ResponseStatusCodeEnum.Fail.GetDescription();
                }
                //采购入库单
                if (list.Where(p => p.TypeCode == PtFackbeekType.InterfaceType_PT_PurchaseStockIn.ToString()).ToList().Any())
                {
                    var purch = list.Where(p => p.TypeCode == PtFackbeekType.InterfaceType_PT_PurchaseStockIn.ToString()).ToList();
                    PurchaseBillTransFeedBackRequest purchaseBill = new PurchaseBillTransFeedBackRequest();
                    var dtolist = _mapper.Map<List<PurchaseBillTransFeedBackRequestItem>>(purch);
                    var purchs = purch.First();
                    purchaseBill.ListInfo = dtolist;
                    purchaseBill.BillCode = purchs.DocsNo;
                    purchaseBill.BillType = purchs.TypeCode;
                    purchaseBill.ReqId = purchs.ReqNo;
                    var resbody = JsonConvert.DeserializeObject<SRes>(WmsServiceExportApi(purchaseBill));
                    var ids = purch.Select(p => p.Id).ToList();
                    if (resbody.ResCode == ResponseStatusCodeEnum.Sucess.GetHashCode())
                    {
                        _ptService.UpdatePuchinfoModelColumns(new sqlsugar.model.UpdateModelColumns<ptBillPushinfo>()
                        {
                            Columns = it => new ptBillPushinfo() { PostResult = 1, PostQty = it.PostQty + 1, ResDesc = "自动推送", EditTime = DateTime.Now },
                            WhereExpression = it => ids.Contains(it.Id)
                        });
                    }
                    else
                    {
                        _ptService.UpdatePuchinfoModelColumns(new sqlsugar.model.UpdateModelColumns<ptBillPushinfo>()
                        {
                            Columns = it => new ptBillPushinfo() { PostResult = 2, PostQty = it.PostQty + 1, ResDesc = "自动推送", EditTime = DateTime.Now },
                            WhereExpression = it => ids.Contains(it.Id)
                        });
                    }
                }
                //重挂
                else if (list.Where(p => p.TypeCode == PtFackbeekType.InterfaceType_PT_AnewStockIn.ToString()).ToList().Any())
                {
                    var purch = list.Where(p => p.TypeCode == PtFackbeekType.InterfaceType_PT_AnewStockIn.ToString()).ToList();
                    PurchaseBillTransFeedBackRequest purchaseBill = new PurchaseBillTransFeedBackRequest();
                    var dtolist = _mapper.Map<List<PurchaseBillTransFeedBackRequestItem>>(purch);
                    var purchs = purch.First();
                    purchaseBill.ListInfo = dtolist;
                    purchaseBill.BillCode = purchs.DocsNo;
                    purchaseBill.BillType = purchs.TypeCode;
                    purchaseBill.ReqId = purchs.ReqNo;
                    var resbody = JsonConvert.DeserializeObject<SRes>(WmsServiceExportApi(purchaseBill));
                    var ids = purch.Select(p => p.Id).ToList();
                    if (resbody.ResCode == ResponseStatusCodeEnum.Sucess.GetHashCode())
                    {
                        _ptService.UpdatePuchinfoModelColumns(new sqlsugar.model.UpdateModelColumns<ptBillPushinfo>()
                        {
                            Columns = it => new ptBillPushinfo() { PostResult = 1, PostQty = it.PostQty + 1, ResDesc = "自动推送", EditTime = DateTime.Now },
                            WhereExpression = it => ids.Contains(it.Id)
                        });
                    }
                    else
                    {
                        _ptService.UpdatePuchinfoModelColumns(new sqlsugar.model.UpdateModelColumns<ptBillPushinfo>()
                        {
                            Columns = it => new ptBillPushinfo() { PostResult = 2, PostQty = it.PostQty + 1, ResDesc = "自动推送", EditTime = DateTime.Now },
                            WhereExpression = it => ids.Contains(it.Id)
                        });
                    }
                }
            }

            return res;
        }
        /// <summary>
        /// 放行单传输接口
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public ErpUnlockStockResponse ErpUnlockStock(ErpUnlockStockRequest reqDto)
        {
            return ConcurrencyReqControl<ErpUnlockStockRequest, ErpUnlockStockResponse>(lockerErpUnlockStock, "ErpUnlockStock" + reqDto.BillCode, reqDto.BillCode, reqDto, _ptService.ErpUnlockStock);
        }
        /// <summary>
        /// 生产领料单传输接口
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes ProductionStockOut(ProductionStockOutRequest reqDto)
        {
            return ConcurrencyReqControl<ProductionStockOutRequest, SRes>(lockerProductionStockOut, "ProductionStockOut" + reqDto.BillCode, reqDto.BillCode, reqDto, _ptService.ProductionStockOut);
        }
        /// <summary>
        /// 自动叫料
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes WcsProductionOutRequest(WcsProductionOutRequest request)
        {
            return ConcurrencyReqControl<WcsProductionOutRequest, SRes>(lockerPtWcsProductionOutTask, "WcsProductionOutRequest" + request.Endquip, request.Endquip, request, _ptService.WcsProductionOutRequest);
        }
        /// <summary>
        /// 生产领料/退料/改判反馈接口
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes ProductionFeedBack(ProductionFeedBackRequest reqDto)
        {
            return ConcurrencyReqControl<ProductionFeedBackRequest, SRes>(lockerProductionFeedBack, "ProductionFeedBack" + reqDto.BillCode, reqDto.BillCode, reqDto, _ptService.ProductionFeedBack);
        }

        /// <summary>
        /// 库存改判
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes StockChange(PtStockChangeRequest reqDto)
        {
            return ConcurrencyReqControl<PtStockChangeRequest, SRes>(lockerStockChange, "ProductionFeedBack" + reqDto.BillCode, reqDto.BillCode, reqDto, _ptService.StockChange);
        }
        /// <summary>
        /// 生产退料单接口
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes ProductionBack(ProductionBackRequest reqDto)
        {
            return ConcurrencyReqControl<ProductionBackRequest, SRes>(lockerProductionBack, "ProductionBack" + reqDto.BillCode, reqDto.BillCode, reqDto, _ptService.ProductionBack);
        }
        [HttpPost]
        public SRes WareCellInit(int row, int col, int deot, int rowcount, int tun)
        {
            return _ptService.WareCellInit(row, col, deot, rowcount, tun);
        }
        /// <summary>
        /// 实时库存查询接口
        /// </summary>
        /// <param name="reqDto"></param>
        /// <returns></returns>
        [HttpPost]
        public PTGetCurStockListResponse GetPtCurStockList(PtGetCurStockListRequest reqDto)
        {
            return _ptService.GetCurStockList(reqDto);
        }
    
        #region 盘条PDA功能
        /// <summary>
        /// 盘条解绑
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes<int> Unbounding(PtUnboundRequest request)
        {
            return _ptService.Unbounding(request);
        }
        /// <summary>
        /// pda单据查询
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string GetDocumentsAll(PtDocumentsRequest request)
        {
            return _ptService.GetPageDocumentsList(request).ToCamelCaseString();
        }
        /// <summary>
        /// pda单据明细查询（传单号）
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string GetDocumentDetails(PtDocumentsRequest request)
        {
            return _ptService.GetDocumentDetailListByDocsNo(request).ToCamelCaseString();
        }
        /// <summary>
        /// pda指定出库确定
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string PdaManualTask(PtManualTaskRequest request)
        {
            request.BusType = TaskBusType.TaskBusType_HJ_PdaManualOut.GetDescription();
            return _ptService.ManualTask(request);
        }
        /// <summary>
        /// pda质检领料出库确定
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string PdaQualityTask(PtManualTaskRequest request)
        {
            request.BusType = TaskBusType.TaskBusType_HJ_QualityOut.GetDescription();
            return _ptService.ManualTask(request);
        }
        /// <summary>
        /// pda重挂出库确定
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string PdaInactionStockTask(PtManualTaskRequest request)
        {
            request.BusType = TaskBusType.TaskBusType_HJ_AnewOut.GetDescription();
            return _ptService.ManualTask(request);
        }
        /// <summary>
        /// 获取设备报警信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string GetEquipErrorInfo(PtErrorInfoRequest request)
        {
            return "";
        }
        /// <summary>
        /// 获取物料报警信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string GetMaterErrorInfo(PtErrorInfoRequest request)
        {
            return "";
        }
        /// <summary>
        /// 获取业务报警信息
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string GetBusinessErrorInfo(PtErrorInfoRequest request)
        {
            return "";
        }
        /// <summary>
        /// 组盘
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string PdaGroupStock(PtGroupInTaskRequest request)
        {
            return _ptService.PdaGroupStock(request);
        }
        /// <summary>
        /// 生成入库任务
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public string PdaInsterInTask(PtGroupInTaskRequest request)
        {
            return _ptService.PdaInsterInTask(request);
        }
        #endregion
        /// <summary>
        /// PDA 采购入库
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes PdaPurchaseTask(PtUnboundRequest request)
        {
            lock (lockerPtPurchTaskIn)
            {
                return _ptService.PtPurchaseTask(request);
            }
        }
        #region WCS调用
        /// <summary>
        /// 获取巷道
        /// </summary>
        /// <param name="reqEntity"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes<string> GetTunnelPriorityList(GetTunnelPriorityListRequest reqEntity)
        {
            lock (lockerGetPtTunnelList)
            {
                return _ptService.GetPtTunnelPriorityList(reqEntity);
            } 
        }
        /// <summary>
        /// 分配货位
        /// </summary>
        /// <param name="reqEntity"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes<PtApplyStockInLocResponse> ApplyStockInLoc(PtApplyStockInLocRequest reqEntity)
        {
            return ConcurrencyReqControl<PtApplyStockInLocRequest, SRes<PtApplyStockInLocResponse>>(lockerPtApplyStockInLoc, "PtApplyStockInLoc" + reqEntity.TunnelNum, "分配货位" + reqEntity.PickUpEquipmentNo, reqEntity, _ptService.PtApplyStockInLoc);
        }
        /// <summary>
        /// 完成任务
        /// </summary>
        /// <param name="reqEntity"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes<int> CompleteTask(CompleteTaskRequest reqDto)
        {
            lock (lockerPtCompleteTask)
            {
                return _ptService.PtCompleteTask(reqDto);
            }
        }

        /// <summary>
        /// 堆垛机出库放货完成
        /// </summary>
        /// <param name="reqEntity"></param>
        /// <returns></returns>
        [HttpPost]
        public SRes<int> SrmPickOutCompleted(PtSrmPickOutCompletedRequest reqDto)
        {
            lock (lockerPtSrmPickOutCompleted)
            {
                return _ptService.PtSrmPickOutCompleted(reqDto);
            }
        }
        #endregion
    }
}