using Microsoft.EntityFrameworkCore;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using WIDESEA_Common;
|
using WIDESEA_Common.LoctionEnum;
|
using WIDESEA_Common.Tools;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Services.IRepositories;
|
using WIDESEA_Services.Repositories;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS
|
{
|
public partial class StackerExecutor
|
{
|
private static int _readRKSB_Down = 0;
|
/// <summary>
|
/// 负极涂布下料工作逻辑
|
/// </summary>
|
/// <param name="client"></param>
|
public static void RKSB_DownTask()
|
{
|
if (Interlocked.Exchange(ref _readRKSB_Down, 1) == 0)
|
{
|
Task.Run(() =>
|
{
|
try
|
{
|
VOLContext Context = new VOLContext();
|
Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
|
Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context);
|
Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
|
List<string> RKSBS = new List<string> { "入壳机1", "入壳机2" };
|
//循环处理涂布设备下料请求
|
foreach (var RKSB in RKSBS)
|
{
|
if (WCSService.Clients == null)
|
{
|
return;
|
}
|
PLCClient plc = WCSService.Clients.Find(v => v.PLCName == RKSB);
|
if (plc == null)
|
{
|
continue;
|
}
|
string SB_Up_Location = "XL-RKSB" + RKSB.Replace("入壳机", "");//拼接入壳下料口
|
string equipType = "RKSB" + RKSB.Replace("入壳机", "");//设备
|
//获取当前入壳设备是否有下料AGV任务
|
var SBtask = agvRepository.FindFirst(f => f.agv_fromaddress == SB_Up_Location);
|
//有结束本次循环
|
if (SBtask != null) { continue; }
|
//获取当前设备的下料请求
|
int requestRKDown = plc.ModbusPLCClient.ModbusTcpNetClient.ReadInt16("5308").Content;
|
if (requestRKDown==4)
|
{
|
#region 记录下料请求信号
|
WriteLog.GetLog().Write($"{plc.PLCName}下料请求：{requestRKDown}---{DateTime.Now}", $"入壳机下料请求");
|
#endregion
|
//找到对应缓存架货位，并确认空框
|
dt_stationinfo location = stationinfoRepository.Find(x => x.area == equipType && x.tpgd == false
|
&& x.wlgd == false && x.task == false).OrderBy(x => x.greenbuttontime).FirstOrDefault();
|
if (location != null)
|
{
|
WebResponseContent content = new WebResponseContent();
|
locRepository.DbContextBeginTransaction(() =>
|
{
|
//生成涂布机下料任务
|
dt_agvtask agvtask = new dt_agvtask()
|
{
|
agv_id = Guid.NewGuid(),
|
agv_tasknum = "KH-" + IdenxManager.GetTaskNo(),
|
agv_fromaddress = SB_Up_Location,//以设备起点
|
agv_toaddress = location.stationCode,
|
agv_code = "组装AGV调度",
|
agv_remark = "入壳下料任务",
|
agv_taskstate = AGVTaskStateEnum.Create.ToString(),
|
agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString(),
|
agv_worktype = 1,//工作类型
|
agv_materielid = "",
|
agv_qty = 1,
|
agv_createtime = DateTime.Now,
|
agv_grade = 0,//任务优先级
|
agv_userid = "WCS",
|
agv_barcode = "",
|
};
|
location.task = true;
|
var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry != null)
|
{
|
entry.State = EntityState.Detached;
|
}
|
int x = locRepository.Update(location, d => new { d.task}, true);
|
if (x == 1)
|
{
|
agvRepository.Add(agvtask, true);
|
return content.OK();
|
}
|
else
|
{
|
return content.Error();
|
}
|
|
});
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
WriteLog.GetLog().Write($"入壳机下料：{DateTime.Now} --------------{ex}", $"入壳机下料调度Error");
|
}
|
finally
|
{
|
|
Interlocked.Exchange(ref _readRKSB_Down, 0);
|
}
|
});
|
|
}
|
}
|
|
}
|
}
|
