using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using WIDESEA_Core.Attributes;
|
using WIDESEA_Core;
|
using WIDESEA_DTO;
|
using WIDESEA_IBasicService;
|
using WIDESEA_IInboundRepository;
|
using WIDESEA_IInboundService;
|
using WIDESEA_IOutboundService;
|
using WIDESEA_ITaskInfoService;
|
using WIDESEA_TaskInfoService;
|
using WIDESEA_DTO.ERP;
|
using WIDESEA_DTO.MES;
|
using WIDESEA_Core.Helper;
|
using Autofac.Core;
|
using WIDESEA_DTO.Stock;
|
using WIDESEA_Common.TaskEnum;
|
using WIDESEA_Common.LocationEnum;
|
using System.Collections.Generic;
|
using WIDESEA_Model.Models;
|
using SqlSugar;
|
using WIDESEA_IStockService;
|
using WIDESEA_Common.StockEnum;
|
using HslCommunication.WebSocket;
|
|
namespace WIDESEA_WMSServer.Controllers.LargeScreen
|
{
|
[Route("api/Large")]
|
[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 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, 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>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[HttpPost, Route("ProMonthTaskStatistics"), AllowAnonymous]
|
//public WebResponseContent ProMonthTaskStatistics()
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
// //获取当月成品的任务总量
|
// int inboundCount = _taskService.Repository.QueryData(x => x.TaskType == TaskTypeEnum.InProduct.ObjToInt()).Count;
|
// int outboundCount = _taskService.Repository.QueryData(x => x.TaskType == TaskTypeEnum.OutProduct.ObjToInt()).Count;
|
// int backboundCount = _taskService.Repository.QueryData(x => x.TaskType == TaskTypeEnum.EmptyProductBack.ObjToInt()).Count;
|
// int surplusCount = _taskService.Repository.QueryData(x => x.TaskType == TaskTypeEnum.InProductBack.ObjToInt()).Count;
|
// content.OK("成功", new { inboundCount, outboundCount, backboundCount, surplusCount });
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
///// <summary>
|
///// 成品货位
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[HttpPost, Route("ProLocationStatistics"), AllowAnonymous]
|
//public WebResponseContent ProLocationStatistics(int Id)
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
// //获取成品的货位
|
// int freeCount = _basicService.LocationInfoService.Repository.QueryData(x => x.LocationStatus == LocationStatusEnum.Free.ObjToInt() && x.WarehouseId == Id).Count;
|
// int inStockCount = _basicService.LocationInfoService.Repository.QueryData(x => x.LocationStatus == LocationStatusEnum.InStock.ObjToInt() && x.WarehouseId == Id).Count;
|
// int lockCount = _basicService.LocationInfoService.Repository.QueryData(x => x.LocationStatus != LocationStatusEnum.Free.ObjToInt() && x.LocationStatus != LocationStatusEnum.InStock.ObjToInt() && x.WarehouseId == Id).Count;
|
// content.OK("成功", new { freeCount, inStockCount, lockCount });
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
///// <summary>
|
///// 成品入库产量
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[HttpPost, Route("Productions"), AllowAnonymous]
|
//public WebResponseContent Productions()
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
// List<Object> list = new List<Object>();
|
// DateTime dateTody = DateTime.Today.AddDays(+1);
|
// for (int i = 1; i <= 7; i++)
|
// {
|
// DateTime date = dateTody.AddDays(-1);
|
// List<Dt_MesProInOrder> mesIn = _mesProInOrderService.Repository.Db.Queryable<Dt_MesProInOrder>().Where(x => x.CreateDate < dateTody && x.CreateDate >= date).Includes(x => x.Details).ToList();
|
// int PcsCounts = 0;
|
// foreach (var item in mesIn)
|
// {
|
// PcsCounts+=(int)item.Details.Sum(x=>x.OKPCSQTY);
|
// }
|
// dateTody = date;
|
// list.Add(new { today = date.ToString("MM/dd"), pcsCounts = PcsCounts });
|
// }
|
// content.OK("成功", list);
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
///// <summary>
|
///// 成品出库产量
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[HttpPost, Route("ProductionsOut"), AllowAnonymous]
|
//public WebResponseContent ProductionsOut()
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
// List<Object> list = new List<Object>();
|
// DateTime dateTody = DateTime.Today.AddDays(+1);
|
// for (int i = 1; i <= 7; i++)
|
// {
|
// DateTime date = dateTody.AddDays(-1);
|
// List<Dt_ProOutOrder> mesIn = _outboundService.ProOutOrderService.Repository.Db.Queryable<Dt_ProOutOrder>().Where(x => x.CreateDate < dateTody && x.CreateDate >= date).Includes(x => x.Details).ToList();
|
// int PcsCounts = 0;
|
// foreach (var item in mesIn)
|
// {
|
// PcsCounts += (int)item.Details.Sum(x => x.QtyPcs);
|
// }
|
// dateTody = date;
|
// list.Add(new { today = date.ToString("MM/dd"), pcsCounts = PcsCounts });
|
// }
|
// content.OK("成功", list);
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
///// <summary>
|
///// 成品出库产量
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[HttpPost, Route("ProductionRanking"), AllowAnonymous]
|
//public WebResponseContent ProductionRanking()
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// 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)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
///// <summary>
|
///// 成品库存
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[HttpPost, Route("ProductionStock"), AllowAnonymous]
|
//public WebResponseContent ProductionStock()
|
//{
|
// WebResponseContent content = new WebResponseContent();
|
// try
|
// {
|
// int cpCount = 0;
|
// int yfCount = 0;
|
// int wsCount = 0;
|
// List<Dt_ProStockInfo> cpproStockInfos = _proStockInfoService.Repository.Db.Queryable<Dt_ProStockInfo>().Where(x => x.ProStockAttribute == ProStockAttributeEnum.成品.ObjToInt()).Includes(x => x.proStockInfoDetails).ToList();
|
// List<Dt_ProStockInfo> yfproStockInfos = _proStockInfoService.Repository.Db.Queryable<Dt_ProStockInfo>().Where(x => x.ProStockAttribute == ProStockAttributeEnum.研发.ObjToInt()).Includes(x => x.proStockInfoDetails).ToList();
|
// List<Dt_ProStockInfo> wsproStockInfos = _proStockInfoService.Repository.Db.Queryable<Dt_ProStockInfo>().Where(x => x.ProStockAttribute == ProStockAttributeEnum.尾数.ObjToInt()).Includes(x => x.proStockInfoDetails).ToList();
|
// foreach (var item in cpproStockInfos)
|
// {
|
// cpCount +=(int) item.proStockInfoDetails.Sum(x => x.StockPcsQty);
|
// }
|
// foreach (var item in yfproStockInfos)
|
// {
|
// yfCount += (int)item.proStockInfoDetails.Sum(x => x.StockPcsQty);
|
// }
|
// foreach (var item in wsproStockInfos)
|
// {
|
// wsCount += (int)item.proStockInfoDetails.Sum(x => x.StockPcsQty);
|
// }
|
// content.OK("成功", new { cpCount, yfCount, wsCount });
|
// }
|
// catch (Exception ex)
|
// {
|
// content.Error(ex.Message);
|
// }
|
// return content;
|
//}
|
}
|
}
|
