using Microsoft.AspNetCore.Mvc;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Numeric;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Security.Cryptography;
|
using System.Xml.Linq;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_WMS.IRepositories;
|
using WIDESEA_WMS.Repositories;
|
|
namespace WIDESEA_WebApi.Controllers
|
{
|
|
[Route("api/[controller]")]
|
[ApiController]
|
public class LargescreenController : Controller //大屏幕数据
|
{
|
#region 第一板块统计图，未使用
|
/// <summary>
|
/// 月，日出入库数量统计
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("Statistical_chart")]
|
public object Statistical_chart()
|
{
|
VOLContext volContext = new VOLContext();
|
Idt_stationinfoRepository db = new dt_stationinfoRepository(volContext);
|
|
string[] stationCodes = { "A", "B", "C", "D01" };
|
var query = db.Find(a => a.stationCode.Contains("A") || a.stationCode.Contains("B") || a.stationCode.Contains("C") || a.stationCode.Contains("D01")).ToList();
|
|
|
List<Tuple<string, int, string, int>> responseData = new List<Tuple<string, int, string, int>>(); // 获取被占用的数据
|
string[] stationCodes2 = { "A01001", "A01002", "B", "C", "D01" };
|
|
var sum = query.Count();
|
|
foreach (string code in stationCodes2)
|
{
|
|
int totalCount = query.Count(a => a.stationCode.Contains(code));
|
|
string percentage = ((double)totalCount / sum).ToString("P0");
|
|
int occupiedCount = query.Count(a => a.stationCode.Contains(code) && a.location_state == "Stroge");
|
|
string name = "";
|
switch (code)
|
{
|
case "A01001":
|
name = "小托盘叠放区";
|
break;
|
case "A01002":
|
name = "大托盘叠放区";
|
break;
|
case "B":
|
name = "库区2";
|
break;
|
case "C":
|
name = "库区3";
|
break;
|
case "D01":
|
name = "库区4";
|
break;
|
default:
|
break;
|
}
|
|
responseData.Add(Tuple.Create(name, totalCount, percentage, occupiedCount));
|
}
|
|
|
var data = new
|
{
|
responseData,
|
};
|
return Ok(data);
|
}
|
|
#endregion
|
|
#region 第一板块
|
/// <summary>
|
/// 月，日出入库数量统计
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("Total_quantityndex")]
|
public object Total_quantityndex()
|
{
|
VOLContext volContext = new VOLContext();
|
Idt_agvtask_htyRepository db = new dt_agvtask_htyRepository(volContext);
|
var startDate = new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
|
var endDate = startDate.AddMonths(1).AddDays(-1);
|
var today = DateTime.Today;
|
|
var data2 = db.Find(x => x.agv_createtime >= startDate && x.agv_createtime <= endDate);
|
|
var data3 = db.Find(x => x.agv_createtime >= today && x.agv_createtime < today.AddDays(1)).ToList();
|
|
// 统计这月的入库数量
|
var monthlyInventory = data2.Where(x => x.agv_tasktype == "TaskType_Inbound").Sum(x => x.agv_qty);
|
|
// 统计这月的出库数量
|
var monthlyOutbound = data2.Where(x => x.agv_tasktype == "TaskType_Outbound").Sum(x => x.agv_qty);
|
|
// 统计今日入库数量
|
var dayInventory = data3.Where(x => x.agv_tasktype == "TaskType_Inbound").Sum(x => x.agv_qty);
|
|
// 统计今日出库数量
|
var dayOutbound = data3.Where(x => x.agv_tasktype == "TaskType_Outbound").Sum(x => x.agv_qty);
|
|
var data = new
|
{
|
monthlyInventory,
|
monthlyOutbound,
|
dayInventory,
|
dayOutbound
|
};
|
return Ok(data);
|
}
|
|
#endregion
|
|
#region 第二板块
|
/// <summary>
|
/// 具体出入库数据
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("Outbound_inventory")]
|
public object Outbound_inventory()
|
{
|
#region 使用中的内容
|
VOLContext volContext = new VOLContext();
|
Idt_agvtask_htyRepository db = new dt_agvtask_htyRepository(volContext);
|
Idt_stationinfoRepository db2 = new dt_stationinfoRepository(volContext);
|
var today = DateTime.Today;
|
var data2 = db.Find(x => x.agv_createtime >= today && x.agv_createtime < today.AddDays(1)).ToList();
|
|
|
//今日待检测入库
|
var dayTaskType_Inbound = data2.Where(x => x.agv_tasktype == "TaskType_Inbound").Sum(x => x.agv_qty);
|
//待检测出库
|
var dayTaskType_Outbound = data2.Where(x => x.agv_tasktype == "TaskType_Outbound").Sum(x => x.agv_qty);
|
//外协库入库
|
var dayTaskType_OutsourceInbound = data2.Where(x => x.agv_tasktype == "TaskType_OutsourceInbound").Sum(x => x.agv_qty);
|
//外协库出库
|
var dayTaskType_OutsourceOutbound = data2.Where(x => x.agv_tasktype == "TaskType_OutsourceOutbound").Sum(x => x.agv_qty);
|
//待检移库外协
|
var dayTaskType_OutsourceCarry = data2.Where(x => x.agv_tasktype == "TaskType_OutsourceCarry").Sum(x => x.agv_qty);
|
//空托数量
|
var dayTaskType_EmptyPallet = data2.Where(x => x.agv_tasktype == "TaskType_EmptyPallet").Sum(x => x.agv_qty);
|
|
//统计月入库总量
|
var startDate = new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
|
var endDate = startDate.AddMonths(1).AddDays(-1);
|
var data4 = db.Find(x => x.agv_createtime >= startDate && x.agv_createtime <= endDate);
|
// 统计这月的入库数量
|
var monthlyInventory = data4.Where(x => x.agv_tasktype == "TaskType_Inbound").Sum(x => x.agv_qty);
|
// 统计这月的出库数量
|
var monthlyOutbound = data4.Where(x => x.agv_tasktype == "TaskType_Outbound").Sum(x => x.agv_qty);
|
// 统计今日入库数量
|
var dayInventory = data2.Where(x => x.agv_tasktype == "TaskType_Inbound").Sum(x => x.agv_qty);
|
|
// 统计今日出库数量
|
var dayOutbound = data2.Where(x => x.agv_tasktype == "TaskType_Outbound").Sum(x => x.agv_qty);
|
|
|
var data3 = db2.Find(_ => true).Where(x => x.stationCode.Contains("A") || x.stationCode.Contains("B") || x.stationCode.Contains("C") || x.stationCode.Contains("D01")).ToList();
|
|
//库区图号数量,外加空托数量
|
var Number_wheels1 = data3.Where(_ => true)
|
.GroupBy(s => new
|
{
|
stationType = string.IsNullOrEmpty(s.stationType) ? s.tray_type : s.stationType,
|
s.tray_type
|
}).Select(g => new
|
{
|
stationType = g.Key.stationType,
|
totalQuantity = g.Sum(s => s.quantity),
|
tray_type = g.Key.tray_type
|
}).ToList();
|
|
var Number_wheels = Number_wheels1.Where(x => x.stationType != "LargeTray" && x.stationType != "SmallTray").ToList();
|
#endregion
|
|
|
#region 未使用的内容
|
//统计下料口合格率与不合格率1单元
|
var dayTaskType_Inbound2 = data2.Where(x => x.agv_tasktype == "TaskType_Inbound" && (x.agv_fromaddress == "X01001001" || x.agv_fromaddress == "X01001002") && x.agv_createtime >= today && x.agv_createtime < today.AddDays(1)).Sum(x => x.agv_qty);
|
//外协库入库1单元
|
var dayTaskType_OutsourceInbound2 = data2.Where(x => x.agv_tasktype == "TaskType_OutsourceInbound" && x.agv_fromaddress == "X01001003" && x.agv_createtime >= today && x.agv_createtime < today.AddDays(1)).Sum(x => x.agv_qty);
|
//统计下料口合格率与不合格率2单元
|
var dayTaskType_Inbound3 = data2.Where(x => x.agv_tasktype == "TaskType_Inbound" && (x.agv_fromaddress == "X02001001" || x.agv_fromaddress == "X02001002") && x.agv_createtime >= today && x.agv_createtime < today.AddDays(1)).Sum(x => x.agv_qty);
|
//外协库入库2单元
|
var dayTaskType_OutsourceInbound3 = data2.Where(x => x.agv_tasktype == "TaskType_OutsourceInbound" && x.agv_fromaddress == "X02001003" && x.agv_createtime >= today && x.agv_createtime < today.AddDays(1)).Sum(x => x.agv_qty);
|
|
var sumkq = dayTaskType_Inbound2 + dayTaskType_OutsourceInbound2;
|
var sumkq2 = dayTaskType_Inbound3 + dayTaskType_OutsourceInbound3;
|
|
var qualified1 = ((float)dayTaskType_Inbound2 / (float)sumkq).ToString("P0");
|
|
var qualified2 = ((float)dayTaskType_Inbound3 / (float)sumkq2).ToString("P0");
|
|
|
//统计库区占用百分比
|
var sumkw = data3.Where(a => a.stationCode.Contains("B") || a.stationCode.Contains("C") || a.stationCode.Contains("D01")).Count(); //获取库区库位
|
var sumzy = data3.Where(a => (a.stationCode.Contains("B") || a.stationCode.Contains("C") || a.stationCode.Contains("D01")) && a.location_state == "Stroge").Count(); //获取被占用的
|
var areaper = ((double)sumzy / sumkw).ToString("P0");
|
#endregion
|
|
|
|
|
|
var data = new
|
{
|
dayTaskType_Inbound,
|
dayTaskType_Outbound,
|
dayTaskType_OutsourceInbound,
|
dayTaskType_OutsourceOutbound,
|
dayTaskType_OutsourceCarry,
|
dayTaskType_EmptyPallet,
|
qualified1,
|
qualified2,
|
areaper,
|
Number_wheels,
|
monthlyInventory,
|
monthlyOutbound,
|
dayInventory,
|
dayOutbound,
|
};
|
return Ok(data);
|
}
|
#endregion
|
|
#region 第三板块
|
/// <summary>
|
/// 展示库区数据
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("Warehouse_area")]
|
public object Warehouse_area()
|
{
|
|
|
VOLContext volContext = new VOLContext();
|
Idt_stationinfoRepository db = new dt_stationinfoRepository(volContext);
|
string[] areas = { "2", "3", "4" };
|
var data2 = db.Find(a => areas.Contains(a.area)).ToList();
|
var dataList = new List<dynamic>();
|
|
foreach (string area in areas)
|
{
|
var data = data2.Where(x => x.area == area)
|
.GroupBy(x => new { x.area, x.line, x.stationType })
|
.Select(x => new
|
{
|
Area = x.Key.area,
|
x.Key.line,
|
x.Key.stationType,
|
combined_heatNumber = string.Join(", ", x.Select(y => y.heatNumber).Distinct())
|
})
|
.OrderBy(x => x.Area)
|
.ThenBy(x => x.line)
|
.GroupBy(x => x.line) // 使用 GroupBy 按 Line 字段分组
|
.Select(group =>
|
{
|
// 找到每个分组中第一个 stationType 不为空的元素
|
var firstWithStationType = group.FirstOrDefault(x => !string.IsNullOrEmpty(x.stationType));
|
if (firstWithStationType != null)
|
{
|
return firstWithStationType;
|
}
|
else
|
{
|
// 如果分组中都是 stationType 为空，则返回第一个元素（此时即为 stationType 为空的）
|
return group.First();
|
}
|
})
|
.ToList();
|
|
dataList = dataList.Concat(data).ToList();
|
}
|
return Ok(dataList);
|
}
|
#endregion
|
|
#region 第四板块
|
/// <summary>
|
/// 5日内的出入库
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("fifteenTotal_quantityndex")]
|
public object fifteenTotal_quantityndex()
|
{
|
VOLContext volContext = new VOLContext();
|
Idt_agvtask_htyRepository db = new dt_agvtask_htyRepository(volContext);
|
var startDate = DateTime.Today.AddDays(-5); // 获取当前日期之前15天的日期
|
var today = DateTime.Today;
|
var dateRange = Enumerable.Range(0, 5).Select(offset => today.AddDays(-offset)); // 获取最近15天的日期范围
|
|
var data2 = db.Find(x => x.agv_createtime >= startDate && x.agv_createtime < today.AddDays(1)).ToList();
|
|
var result = dateRange.Reverse().Select(date =>
|
{
|
// 统计当日入库数量
|
var dayInventory = data2.Where(x => x.agv_createtime >= date && x.agv_createtime < date.AddDays(1) && x.agv_tasktype == "TaskType_Inbound").Sum(x => x.agv_qty);
|
|
// 统计当日出库数量
|
var dayOutbound = data2.Where(x => x.agv_createtime >= date && x.agv_createtime < date.AddDays(1) && x.agv_tasktype == "TaskType_Outbound").Sum(x => x.agv_qty);
|
|
return new
|
{
|
Date = date.ToString("MM-dd"),
|
Day_inventory = dayInventory,
|
Day_outbound = dayOutbound
|
};
|
});
|
|
var data = new
|
{
|
Daily_statistics = result.ToList(),
|
};
|
return Ok(data);
|
}
|
#endregion
|
|
#region 第六板块
|
/// <summary>
|
/// 当前agv任务
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost("Current_agvtask")]
|
public object Current_agvtask()
|
{
|
VOLContext volContext = new VOLContext();
|
Idt_agvtaskRepository db = new dt_agvtaskRepository(volContext);
|
var dataList = db.Find(_ => true).OrderByDescending(x => x.agv_createtime).ToList();
|
|
var data = dataList.Where(x => x.agv_taskstate != "队列" && x.agv_taskstate != "Queue" && x.agv_taskstate != "暂停" && x.agv_taskstate != "Pause").ToList();
|
if (data.Count <= 15)
|
{
|
data = dataList.Take(15).ToList();
|
}
|
foreach (var item in data)
|
{
|
switch (item.agv_tasktype)
|
{
|
case "TaskType_OutsourceCarry":
|
item.agv_tasktype = "待检移库外协";
|
break;
|
case "TaskType_OutsourceOutbound":
|
item.agv_tasktype = "外协库出库";
|
break;
|
case "TaskType_EmptyPallet":
|
item.agv_tasktype = "空托任务";
|
break;
|
case "TaskType_OutsourceInbound":
|
item.agv_tasktype = "外协库入库";
|
break;
|
case "TaskType_Inbound":
|
item.agv_tasktype = "待检库入库";
|
break;
|
case "TaskType_Outbound":
|
item.agv_tasktype = "待检库出库";
|
break;
|
case "TaskType_Carry":
|
item.agv_tasktype = "待检库内移库";
|
break;
|
default:
|
return "未知任务类型";
|
}
|
|
switch (item.agv_taskstate)
|
{
|
case "Create":
|
item.agv_taskstate = "新建";
|
break;
|
case "Complete":
|
item.agv_taskstate = "起点已完成";
|
break;
|
case "Complete1":
|
item.agv_taskstate = "终点已完成";
|
break;
|
case "Executing1":
|
item.agv_taskstate = "终点执行中";
|
break;
|
case "Executing":
|
item.agv_taskstate = "起点执行中";
|
break;
|
case "Queue":
|
item.agv_taskstate = "队列";
|
break;
|
case "SendOut":
|
item.agv_taskstate = "已下发";
|
break;
|
case "Pause":
|
item.agv_taskstate = "暂停";
|
break;
|
default:
|
return "未知任务状态";
|
}
|
|
}
|
return Ok(data);
|
|
}
|
#endregion
|
|
#region 第七板块（新增内容）
|
/// <summary>
|
/// 工单信息VV_Workinfo
|
/// </summary>
|
/// <returns></returns>
|
/*[HttpPost("Workinfo_information")]
|
public object Workinfo_information()
|
{
|
|
}*/
|
#endregion
|
}
|
}
|
