using HslCommunication;
|
using System;
|
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_Services.Services;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS
|
{
|
public partial class StackerExecutor
|
{
|
public static object requestFJTSJ = new object();//requestZJJK
|
private static int _readTSJDOWNSignalsoFTSJ = 0;//_readZTBUPSignalso
|
|
/// <summary>
|
/// 负极辊分下料工作逻辑
|
/// </summary>
|
/// <param name="client"></param>
|
public static void F_TSJ_DownTask()
|
{
|
|
if (Interlocked.Exchange(ref _readTSJDOWNSignalsoFTSJ, 1) == 0)
|
{
|
Task.Run(() =>
|
{
|
try
|
{
|
VOLContext Context = new VOLContext();
|
WebResponseContent responseContent = new WebResponseContent();
|
Idt_task_numberRepository tasknumberRep = new dt_task_numberRepository(Context);
|
dt_task_numberService tasknumber = new dt_task_numberService(tasknumberRep);
|
Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
|
Ibase_routing_tableRepository routingRepository = new base_routing_tableRepository(Context);
|
Ibill_pda_groupdiskRepository pdaRepository = new bill_pda_groupdiskRepository(Context);
|
Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
|
Idt_agvtask_htyRepository agvhtyRepository = new dt_agvtask_htyRepository(Context);
|
Ibill_group_stockRepository groupRepository = new bill_group_stockRepository(Context);
|
|
if (WCSService.Clients == null)
|
{
|
return;
|
}
|
PLCClient plc = WCSService.Clients.Find(v => v.PLCName == "负极箔材提升机");
|
if (plc == null)
|
{
|
return;
|
}
|
//当前设备有没有下料请求
|
//bool TSJ_CL = Convert.ToBoolean(plc.ReadValue("R_Feedingrequest".ToString(), plc.PLCDescroption));
|
OperateResult<bool> TSJ_CL = plc.SiemensPLCClient.SiemensS7NetClient.ReadBool("DB51.93");
|
if (TSJ_CL.Content)
|
{
|
//查看当前辊分机设备是否有AGV任务
|
var SBtask = agvRepository.FindFirst(f => f.agv_fromaddress == plc.PLCDescroption);
|
//有结束本次循环
|
if (SBtask != null) { return; }
|
base_ware_location ware_Locations = locRepository.FindFirst(d => d.upper_code == "FJ-BCHCJ37" && d.location_state == LoctionStateEnum.LocationState_Empty.ToString() && d.tpgd == 0 && d.status == 1 && d.task == 2);
|
if (ware_Locations != null)
|
{
|
//生成提升机机下料任务
|
dt_agvtask agvtask = new dt_agvtask
|
{
|
agv_id = Guid.NewGuid(),
|
agv_tasknum = "KH-" + IdenxManager.GetTaskNo(),
|
agv_fromaddress = plc.PLCDescroption,
|
agv_toaddress = ware_Locations.upper_code,
|
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 = "",
|
};
|
|
ware_Locations.task = 1;
|
ware_Locations.update_time = DateTime.Now;
|
int a = locRepository.Update(ware_Locations, d => new { d.task, d.update_time }, true);
|
if (a == 1)
|
{
|
agvRepository.Add(agvtask, true);
|
//WriteDBLog.Info($"负极提升机下料任务生成").Write($"生成任务:{agvtask.agv_tasknum},终点货位【{ware_Locations.upper_code}】状态：托盘光电检测：{ware_Locations.tpgd},状态：{ware_Locations.location_state},更新时间：{ware_Locations.wireless_time}", $"负极提升机下料任务生成");
|
//WriteDBLog.Info($"负极提升机下料任务生成").Write($"----------------任务生成成功 {DateTime.Now} -------------- {Environment.NewLine}", $"负极提升机下料任务生成");
|
}
|
//WriteLog.GetLog("设备呼叫").Write($"设备 {plc.PLCDescroption} 呼叫成功，任务{agvtask.agv_tasknum}生成", "设备呼叫");
|
}
|
}
|
|
|
}
|
catch (Exception ex)
|
{
|
WriteLog.GetLog().Write($"负极提升机下料：{DateTime.Now} --------------{ex}", $"负极提升机下料调度");
|
}
|
finally
|
{
|
|
Interlocked.Exchange(ref _readTSJDOWNSignalsoFTSJ, 0);
|
}
|
});
|
|
}
|
}
|
|
}
|
}
|
