| | |
| | | using SqlSugar; |
| | | using WIDESEA_IStockService; |
| | | using WIDESEA_Common.StockEnum; |
| | | using HslCommunication.WebSocket; |
| | | |
| | | namespace WIDESEA_WMSServer.Controllers.LargeScreen |
| | | { |
| | |
| | | [ApiController] |
| | | public class LargeController : ControllerBase |
| | | { |
| | | //private readonly IOutboundService _outboundService; |
| | | //private readonly ITaskService _taskService; |
| | | //private readonly ITask_HtyService _task_HtyService; |
| | | //private readonly IBasicService _basicService; |
| | | //private readonly IMesProInOrderService _mesProInOrderService; |
| | | //private readonly IOutProStockInfoService _outProStockInfoService; |
| | | //private readonly IProStockInfoDetailService _proStockInfoDetailService; |
| | | //private readonly IProStockInfoService _proStockInfoService; |
| | | private readonly IOutboundService _outboundService; |
| | | private readonly ITaskService _taskService; |
| | | private readonly ITask_HtyService _task_HtyService; |
| | | private readonly IBasicService _basicService; |
| | | private readonly IMesProInOrderService _mesProInOrderService; |
| | | private readonly IOutProStockInfoService _outProStockInfoService; |
| | | private readonly WebSocketServer _webSocketServer; |
| | | private readonly IProStockInfoDetailService _proStockInfoDetailService; |
| | | private readonly IProStockInfoService _proStockInfoService; |
| | | |
| | | //public LargeController(IOutboundService outboundService, ITaskService taskService, ITask_HtyService task_HtyService, IBasicService basicService, IMesProInOrderService mesProInOrderService, IOutProStockInfoService outProStockInfoService,IProStockInfoDetailService proStockInfoDetailService, IProStockInfoService proStockInfoService) |
| | | //{ |
| | | // _outboundService = outboundService; |
| | | // _taskService = taskService; |
| | | // _task_HtyService = task_HtyService; |
| | | // _basicService = basicService; |
| | | // _mesProInOrderService = mesProInOrderService; |
| | | // _outProStockInfoService = outProStockInfoService; |
| | | // _proStockInfoDetailService= proStockInfoDetailService; |
| | | // _proStockInfoService=proStockInfoService; |
| | | //} |
| | | public LargeController(IOutboundService outboundService, ITaskService taskService, ITask_HtyService task_HtyService, IBasicService basicService, IMesProInOrderService mesProInOrderService, IOutProStockInfoService outProStockInfoService, IProStockInfoDetailService proStockInfoDetailService, IProStockInfoService proStockInfoService, WebSocketServer webSocketServer) |
| | | { |
| | | _outboundService = outboundService; |
| | | _taskService = taskService; |
| | | _task_HtyService = task_HtyService; |
| | | _basicService = basicService; |
| | | _mesProInOrderService = mesProInOrderService; |
| | | _outProStockInfoService = outProStockInfoService; |
| | | _proStockInfoDetailService = proStockInfoDetailService; |
| | | _proStockInfoService = proStockInfoService; |
| | | _webSocketServer = webSocketServer; |
| | | } |
| | | /// <summary> |
| | | /// 娴嬭瘯 |
| | | /// </summary> |
| | | /// <returns></returns> |
| | | [HttpPost, Route("PushInfoSocket"), AllowAnonymous] |
| | | public WebResponseContent ProMonthTaskStatistics(string info) |
| | | { |
| | | WebSocketSession[] webSocketSession = _webSocketServer.OnlineSessions; |
| | | if (webSocketSession != null) |
| | | { |
| | | _webSocketServer.SendClientPayload(webSocketSession[0], "鍚屾剰"); |
| | | } |
| | | return WebResponseContent.Instance.OK(_webSocketServer.OnlineSessions.Select(x=>x.Url).Serialize()); |
| | | } |
| | | ///// <summary> |
| | | ///// 鎴愬搧褰撴湀浠诲姟缁熻 |
| | | ///// </summary> |
| | |
| | | // try |
| | | // { |
| | | // var list = _proStockInfoDetailService.Repository.QueryData(x => true).GroupBy(x => x.ProductCode).Select(x => new { pCode = x.Key, qtys = x.Sum(x=>x.StockPcsQty) }).OrderByDescending(x=>x.qtys).Take(5); |
| | | |
| | | |
| | | // content.OK("鎴愬姛", list); |
| | | // } |
| | | // catch (Exception ex) |