449 lines
18 KiB
C#
449 lines
18 KiB
C#
using Infrastructure;
|
|
using Infrastructure.Attribute;
|
|
using SqlSugar;
|
|
using System;
|
|
using System.Globalization;
|
|
using System.Linq;
|
|
using System.Text.Json;
|
|
using ZR.Model.MES.mm;
|
|
using ZR.Model.MES.mm.Dto;
|
|
using ZR.Model.MES.pro;
|
|
using ZR.Model.MES.wms;
|
|
using ZR.Service.mes.mm.IService;
|
|
|
|
namespace ZR.Service.mes.mm
|
|
{
|
|
[AppService(ServiceType = typeof(IMaterialInputService), ServiceLifetime = LifeTime.Transient)]
|
|
public class MaterialInputService : BaseService<MmAgvLocation>, IMaterialInputService
|
|
{
|
|
private NLog.Logger logger;
|
|
|
|
public MaterialInputService()
|
|
{
|
|
logger = NLog.LogManager.GetCurrentClassLogger();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取AGV上料起点
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string[] Getstart_AGV_points()
|
|
{
|
|
List<MmAgvLocation> positions = Context
|
|
.Queryable<MmAgvLocation>()
|
|
.Where(it => it.AreaCode == 2)
|
|
.Where(it => it.Type == 0)
|
|
.ToList();
|
|
|
|
string[] cors = new string[positions.Count];
|
|
for (int i = 0; i < positions.Count; i++)
|
|
cors[i] = positions[i].Coordinate.ToString();
|
|
|
|
return cors;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取AGV上料终点
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string[] Getend_AGV_points()
|
|
{
|
|
List<MmAgvLocation> positions = Context
|
|
.Queryable<MmAgvLocation>()
|
|
.Where(it => it.AreaCode == 2)
|
|
.Where(it => it.Type == 1)
|
|
.ToList();
|
|
|
|
string[] cors = new string[positions.Count];
|
|
for (int i = 0; i < positions.Count; i++)
|
|
cors[i] = positions[i].Coordinate.ToString();
|
|
|
|
return cors;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取工单列表
|
|
/// </summary>
|
|
/// <param name="datetimespan"></param>
|
|
/// <returns></returns>
|
|
public (List<ProWorkorder_v2>, int) Getworkorderlist(WorkorderqueryDto query)
|
|
{
|
|
DateTime datetimespan = new DateTime(
|
|
query.datetimespan.Year,
|
|
query.datetimespan.Month,
|
|
query.datetimespan.Day,
|
|
0,
|
|
0,
|
|
0
|
|
);
|
|
|
|
// 获取年份和周数
|
|
Calendar calendar = new GregorianCalendar();
|
|
int year = calendar.GetYear(datetimespan);
|
|
int week = calendar.GetWeekOfYear(
|
|
datetimespan,
|
|
CalendarWeekRule.FirstFourDayWeek,
|
|
DayOfWeek.Sunday
|
|
);
|
|
|
|
// 获取这一周中的第几天
|
|
DayOfWeek dayOfWeek = datetimespan.DayOfWeek;
|
|
int dayOfWeekNumber = (int)dayOfWeek; // 将 DayOfWeek 枚举转换为从 1 开始的数字
|
|
Console.WriteLine(
|
|
"<-获取工单列表-> " + year + "年" + week + "周" + dayOfWeekNumber + "日"
|
|
);
|
|
logger.Error("<-获取工单列表-> " + year + "年" + week + "周" + dayOfWeekNumber + "日");
|
|
//todo 已经和正在配料的工单号和毛坯号不能变？？？？？？
|
|
int total = 0;
|
|
List<ProWorkorder_v2> WorkorderList = Context
|
|
.Queryable<ProWorkorder_v2>()
|
|
.Where(it => it.Year == year)
|
|
.Where(it => it.Week == week)
|
|
.Where(it => it.Date == dayOfWeekNumber)
|
|
.Where(it => it.Remark3 == "是" || it.Remark1 == "调试")
|
|
.ToList();
|
|
// .ToPageList(query.pageNum??1, query.pageSize??10, ref total);
|
|
|
|
foreach (ProWorkorder_v2 workorder in WorkorderList)
|
|
{
|
|
if (string.IsNullOrEmpty(workorder.ClientWorkorder))
|
|
{
|
|
workorder.ClientWorkorder = "调试:" + workorder.Id;
|
|
}
|
|
// 配料任务
|
|
bool isExist = Context
|
|
.Queryable<MmFkWorkorderIngredient>()
|
|
.Where(it => it.FkWorkorder == workorder.ClientWorkorder)
|
|
.Where(it => it.FkBlanknumber == workorder.BlankNumber)
|
|
.Any();
|
|
|
|
if (!isExist)
|
|
{
|
|
//插入配料任务
|
|
MmFkWorkorderIngredient ingredient = new MmFkWorkorderIngredient();
|
|
ingredient.FkWorkorder = workorder.ClientWorkorder ?? ("调试:" + workorder.Id);
|
|
ingredient.FkBlanknumber = workorder.BlankNumber;
|
|
ingredient.Isingredient = 0;
|
|
ingredient.Previous_numbered = 0;
|
|
ingredient.CreatedTime = DateTime.Now;
|
|
Context.Insertable(ingredient).ExecuteCommand();
|
|
}
|
|
else
|
|
{
|
|
// todo 有个漏洞 如果计划单 修改数量 remian 就不对
|
|
var ingredient = Context
|
|
.Queryable<MmFkWorkorderIngredient>()
|
|
.Where(it => it.FkWorkorder == workorder.ClientWorkorder)
|
|
.Where(it => it.FkBlanknumber == workorder.BlankNumber)
|
|
.First();
|
|
|
|
if (ingredient != null)
|
|
{
|
|
workorder.PreviousNumber =
|
|
workorder.PreviousNumber - (ingredient.Previous_numbered ?? 0);
|
|
}
|
|
}
|
|
}
|
|
WorkorderList.RemoveAll(num => num.PreviousNumber <= 0);
|
|
total = WorkorderList.Count;
|
|
|
|
int skip = ((query.pageNum ?? 1) - 1) * (query.pageSize ?? 10);
|
|
var returndata = WorkorderList
|
|
.OrderBy(it => it.Sort)
|
|
.Skip(skip)
|
|
.Take(query.pageSize ?? 10)
|
|
.ToList();
|
|
|
|
return (returndata, total);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 生成任务单
|
|
/// </summary>
|
|
/// <param name="task"></param>
|
|
/// <returns></returns>
|
|
public int Generatetask(IngredientTaskDto task, string name)
|
|
{
|
|
List<MmIngredientTask> ingredientTasks = new List<MmIngredientTask>();
|
|
long taskid = SnowFlakeSingle.Instance.NextId();
|
|
foreach (var item in task.workorders)
|
|
{
|
|
//todo 更改待上料数量
|
|
int remian = item.previousNumber - item.previousNumbered;
|
|
if (remian == 0)
|
|
{
|
|
//更改配料进度为完成
|
|
int result = Context
|
|
.Updateable<MmFkWorkorderIngredient>()
|
|
.Where(it => it.FkWorkorder == item.workorder)
|
|
.Where(it => it.FkBlanknumber == item.blanknumber)
|
|
.SetColumns(it => it.Previous_numbered == item.previousNumbered)
|
|
.SetColumns(it => it.Isingredient == 1)
|
|
.SetColumns(it => it.UpdatedTime == DateTime.Now)
|
|
.ExecuteCommand();
|
|
}
|
|
else
|
|
{
|
|
//更改配料进度 修改配料进度
|
|
Context
|
|
.Updateable<MmFkWorkorderIngredient>()
|
|
.Where(it => it.FkWorkorder == item.workorder)
|
|
.Where(it => it.FkBlanknumber == item.blanknumber)
|
|
.SetColumns(it => it.Previous_numbered == item.previousNumbered)
|
|
.SetColumns(it => it.UpdatedTime == DateTime.Now)
|
|
.SetColumns(it => it.Isingredient == 0)
|
|
.ExecuteCommand();
|
|
}
|
|
|
|
MmIngredientTask ingredientTask = new MmIngredientTask();
|
|
ingredientTask.AgvPosition = task.agv_position;
|
|
ingredientTask.TaskId = taskid.ToString();
|
|
ingredientTask.Workorder = item.workorder;
|
|
ingredientTask.Blanknumber = item.blanknumber;
|
|
ingredientTask.Isfinal = 0;
|
|
ingredientTask.PreviousNumber = item.previousNumber;
|
|
ingredientTask.PreviousNumbered = item.previousNumbered;
|
|
ingredientTask.CreatedBy = name;
|
|
ingredientTask.CreatedTime = DateTime.Now;
|
|
|
|
ingredientTasks.Add(ingredientTask);
|
|
}
|
|
|
|
return Context.Insertable(ingredientTasks).ExecuteCommand();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取配料任务
|
|
/// </summary>
|
|
/// <param name="queryParams"></param>
|
|
/// <returns></returns>
|
|
public List<MmIngredientTask> GetIngredientTask(IngredientTaskQueryDto queryParams)
|
|
{
|
|
// 获取当天的开始时间
|
|
DateTime startOfDay = queryParams.datetimespan.Date;
|
|
// 获取当天的结束时间
|
|
DateTime endOfDay = startOfDay.AddDays(1).AddTicks(-1);
|
|
return Context
|
|
.Queryable<MmIngredientTask>()
|
|
.Where(it => it.CreatedTime > startOfDay && it.CreatedTime < endOfDay)
|
|
.Where(it => it.Isfinal == 0)
|
|
.GroupBy(it => it.TaskId)
|
|
.Select(it => new MmIngredientTask()
|
|
{
|
|
TaskId = it.TaskId,
|
|
AgvPosition = SqlFunc.AggregateMax(it.AgvPosition),
|
|
CreatedTime = SqlFunc.AggregateMax(it.CreatedTime)
|
|
})
|
|
.ToList();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取配料任务(son) 详细情况
|
|
/// </summary>
|
|
/// <param name="taskId"></param>
|
|
/// <returns></returns>
|
|
public List<MmIngredientTask> GetIngredientTaskSon(string taskId)
|
|
{
|
|
return Context.Queryable<MmIngredientTask>().Where(it => it.TaskId == taskId).ToList();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取车间上料终点
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string[] Getfabgopoints()
|
|
{
|
|
return Context
|
|
.Queryable<MmAgvLocation>()
|
|
.Where(it => it.AreaCode == 3)
|
|
.Select(it => it.Coordinate)
|
|
.ToArray();
|
|
}
|
|
|
|
/// <summary>
|
|
/// agv从仓库到车间 进料
|
|
/// </summary>
|
|
/// <param name="start_point"></param>
|
|
/// <param name="end_point"></param>
|
|
/// <returns></returns>
|
|
public string AGV_schedule(string start_point, string end_point, string agvCode = "1743")
|
|
{
|
|
// Context.Updateable<MmAgvLocation>().Where(it => it.Coordinate == start_point).SetColumns(it => it.Status == 0).ExecuteCommand();
|
|
// Context.Updateable<MmAgvLocation>().Where(it => it.Coordinate == end_point).SetColumns(it => it.Status == 1).ExecuteCommand();
|
|
|
|
string url =
|
|
"https://192.168.60.1:443/rcms/services/rest/hikRpcService/genAgvSchedulingTask";
|
|
logger.Info(" 1.任务调度请求url " + url);
|
|
AGVtask_third task = new AGVtask_third();
|
|
task.reqCode = SnowFlakeSingle.Instance.NextId().ToString();
|
|
task.taskTyp = "F01";
|
|
task.agvCode = agvCode.Trim();
|
|
// MmAgvLocation start_object = Context.Queryable<MmAgvLocation>().Where(it => it.Coordinate == start_point).First();
|
|
// MmAgvLocation end_object = Context.Queryable<MmAgvLocation>().Where(it => it.Coordinate == end_point).First();
|
|
//判断是否跨楼层
|
|
if (end_point == "R1" || start_point == "R1")
|
|
{
|
|
task.taskTyp = "KLC";
|
|
}
|
|
|
|
task.positionCodePath = new List<AGV_location_third>
|
|
{
|
|
new AGV_location_third() { positionCode = start_point, type = "00" },
|
|
new AGV_location_third() { positionCode = end_point, type = "00" }
|
|
};
|
|
task.podDir = "0";
|
|
task.priority = "1";
|
|
|
|
string postData = JsonSerializer.Serialize(task);
|
|
|
|
logger.Info(" 2.任务调度请求数据 " + postData);
|
|
string response = HttpHelper.HttpPost(url, postData);
|
|
logger.Info(" 3.任务调度请求响应 " + response);
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 紧急终止AGV
|
|
/// </summary>
|
|
/// <param name="reqCode"></param>
|
|
public string EmergencyStopAgv(string reqCode)
|
|
{
|
|
logger.Info("\n 0.取消任务taskcode= " + reqCode);
|
|
string url = "https://192.168.60.1:443/rcms/services/rest/hikRpcService/cancelTask";
|
|
|
|
logger.Info(" 1.紧急终止AGV请求url " + url);
|
|
AGVtask_cancel_third req = new AGVtask_cancel_third();
|
|
req.reqCode = SnowFlakeSingle.Instance.NextId().ToString();
|
|
req.forceCancel = "0";
|
|
req.taskCode = reqCode;
|
|
string postData = JsonSerializer.Serialize(req);
|
|
|
|
logger.Info(" 2.紧急终止AGV请求数据 " + postData);
|
|
|
|
string response = HttpHelper.HttpPost(url, postData);
|
|
|
|
logger.Info(" 3.紧急终止AGV响应数据 " + response);
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 完成配料任务
|
|
/// 1.更改站点托盘
|
|
/// 2.完成的配料任务不可见
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public int FinishBatchingTask(string start_point, string end_point, string taskId)
|
|
{
|
|
int result = 0;
|
|
UseTran2(() =>
|
|
{
|
|
// Context.Updateable<MmAgvLocation>().Where(it => it.Coordinate == start_point).SetColumns(it => it.Status == 0).ExecuteCommand();
|
|
// Context.Updateable<MmAgvLocation>().Where(it => it.Coordinate == end_point).SetColumns(it => it.Status == 1).ExecuteCommand();
|
|
result = Context
|
|
.Updateable<MmIngredientTask>()
|
|
.Where(it => it.TaskId.Equals(taskId))
|
|
.SetColumns(it => it.Isfinal == 1)
|
|
.ExecuteCommand();
|
|
List<MmIngredientTask> tasks = Context
|
|
.Queryable<MmIngredientTask>()
|
|
.Where(it => it.TaskId.Equals(taskId))
|
|
.ToList();
|
|
for (int i = 0; i < tasks.Count; i++)
|
|
{
|
|
if (!string.IsNullOrEmpty(tasks[i].Workorder))
|
|
{
|
|
Context
|
|
.Updateable<ProWorkorder_v2>()
|
|
.Where(it => it.ClientWorkorder == tasks[i].Workorder)
|
|
.SetColumns(it => it.Status == 1)
|
|
.ExecuteCommand();
|
|
}
|
|
}
|
|
|
|
//查询毛坯号
|
|
List<MmIngredientTask> TO_blankList = Context
|
|
.Queryable<MmIngredientTask>()
|
|
.Where(it => it.TaskId == taskId)
|
|
.ToList();
|
|
foreach (var task in TO_blankList)
|
|
{
|
|
if (!string.IsNullOrEmpty(task.Blanknumber))
|
|
{
|
|
WmBlankInventory blankInventory = Context
|
|
.Queryable<WmBlankInventory>()
|
|
.Where(it => it.BlankNum == task.Blanknumber)
|
|
// 默认毛坯扣除
|
|
.Where(it => it.Type == 1)
|
|
.Where(it => it.Status == 1)
|
|
.First();
|
|
if (blankInventory == null)
|
|
{
|
|
continue;
|
|
}
|
|
//1 扣除库存
|
|
Context
|
|
.Updateable<WmBlankInventory>()
|
|
.SetColumns(it => it.Quantity == it.Quantity - task.PreviousNumbered)
|
|
.Where(it => it.Id == blankInventory.Id)
|
|
.ExecuteCommand();
|
|
//2 增加库存记录
|
|
WmBlankRecord res = new WmBlankRecord();
|
|
res.Id = SnowFlakeSingle.Instance.NextId().ToString();
|
|
res.FkBlankInventoryId = blankInventory.Id;
|
|
res.BlankNum = task.Blanknumber;
|
|
res.ChangeQuantity = task.PreviousNumbered;
|
|
res.Type = 3;
|
|
res.Status = 1;
|
|
res.ActionTime = DateTime.Now;
|
|
res.CreatedBy = "PDA上料";
|
|
res.CreatedTime = DateTime.Now;
|
|
|
|
//填写库存记录
|
|
Context.Insertable(res).ExecuteCommand();
|
|
}
|
|
}
|
|
});
|
|
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 车间返程起点
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string[] Emptycarreturn_start()
|
|
{
|
|
List<MmAgvLocation> positions = Context
|
|
.Queryable<MmAgvLocation>()
|
|
.Where(it => it.AreaCode == 3)
|
|
.ToList();
|
|
|
|
string[] cors = new string[positions.Count];
|
|
for (int i = 0; i < positions.Count; i++)
|
|
cors[i] = positions[i].Coordinate.ToString();
|
|
|
|
return cors;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 车间返程终点
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string[] Emptycarreturn_end()
|
|
{
|
|
List<MmAgvLocation> positions = Context
|
|
.Queryable<MmAgvLocation>()
|
|
.Where(it => it.AreaCode == 2)
|
|
.ToList();
|
|
|
|
string[] cors = new string[positions.Count];
|
|
for (int i = 0; i < positions.Count; i++)
|
|
cors[i] = positions[i].Coordinate.ToString();
|
|
|
|
return cors;
|
|
}
|
|
}
|
|
}
|