#region << 版 本 注 释 >>
|
/*----------------------------------------------------------------
|
* 命名空间：WIDESEAWCS_Tasks.ConveyorLineJob
|
* 创建者：胡童庆
|
* 创建时间：2024/8/2 16:13:36
|
* 版本：V1.0.0
|
* 描述：
|
*
|
* ----------------------------------------------------------------
|
* 修改人：
|
* 修改时间：
|
* 版本：V1.0.1
|
* 修改说明：
|
*
|
*----------------------------------------------------------------*/
|
#endregion << 版 本 注 释 >>
|
|
using AutoMapper;
|
using Quartz;
|
using SqlSugar;
|
using System.Threading.Tasks;
|
using WIDESEA_Common.Log;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_ISystemServices;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_Model.Models.System;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_QuartzJob.DTO;
|
using WIDESEAWCS_QuartzJob.Models;
|
using WIDESEAWCS_QuartzJob.Service;
|
using WIDESEAWCS_Tasks.ConveyorLineJob;
|
|
namespace WIDESEAWCS_Tasks
|
{
|
[DisallowConcurrentExecution]
|
public class CommonConveyorLineJob : IJob
|
{
|
private readonly ITaskService _taskService;
|
private readonly ITaskExecuteDetailService _taskExecuteDetailService;
|
private readonly IRouterService _routerService;
|
private readonly IPlatformStationService _PlatformStationService;
|
|
private readonly IMapper _mapper;
|
|
public CommonConveyorLineJob(ITaskService taskService, ITaskExecuteDetailService taskExecuteDetailService, IRouterService routerService, IMapper mapper, IPlatformStationService platformStation)
|
{
|
_taskService = taskService;
|
_taskExecuteDetailService = taskExecuteDetailService;
|
_routerService = routerService;
|
_mapper = mapper;
|
_PlatformStationService = platformStation;
|
}
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
CommonConveyorLine conveyorLine = (CommonConveyorLine)context.JobDetail.JobDataMap.Get("JobParams");
|
if (conveyorLine != null)
|
{
|
//读取输送线入库，空托，检修入库口申请
|
RequestInbound(conveyorLine);
|
|
//获取出库任务，下发至输送线
|
RequestInSCLine(conveyorLine);
|
}
|
}
|
catch (Exception ex)
|
{
|
//Console.Out.WriteLine(nameof(CommonConveyorLineJob) + ":" + ex.ToString());
|
}
|
return Task.CompletedTask;
|
}
|
|
/// <summary>
|
/// 输送线请求入库
|
/// </summary>
|
/// <param name="conveyorLine">输送线实例对象</param>
|
public void RequestInbound(CommonConveyorLine conveyorLine)
|
{
|
try
|
{
|
List<PlatformStation> platformsList = _PlatformStationService.GetPlatformList(conveyorLine.DeviceCode);
|
foreach (var plctationitem in platformsList)
|
{
|
ConveyorTaskCommand command = lineCommand(conveyorLine, plctationitem.Station_code);
|
|
int kd = 1;
|
if (command != null && kd!=1)
|
{
|
//是否需要写入反馈
|
DeviceProDTO? deviceProDTO6 = conveyorLine.DeviceProDTOs.Find(x => x.DeviceChildCode == plctationitem.Station_code && x.DeviceProParamName == "HandShake" && x.DeviceProParamType == "DeviceCommand");
|
if (command.HandShake && command.Barcodest != "")
|
{
|
//调取申请
|
WebResponseContent content = _taskService.RequestWMSTask(int.Parse(command.Barcodest), int.Parse(plctationitem.Station_code));
|
if (content.Status)
|
{
|
|
conveyorLine.Communicator.Write(deviceProDTO6.DeviceProAddress, (bool)true);
|
wcsWriteLog(plctationitem.Station_code, "成功", $"{command.Barcodest}，反馈输送线读取到入库申请信号：true");
|
}
|
}
|
/* else
|
{
|
//conveyorLine.Communicator.Write(deviceProDTO6.DeviceProAddress, (bool)false);
|
//未读取到输送线申请
|
wcsWriteLog(plctationitem.Station_code, "错误", $"未读取到输送线入库申请或托盘条码为0,申请：{command.HandShake},托盘条码：{command.Barcodest}");
|
}*/
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
wcsWriteLog("输送线请求错误", "错误", $"错误信息：{ex.Message}");
|
throw;
|
}
|
}
|
|
/// <summary>
|
/// 读取堆垛机出库站台信息，进行任务完成
|
/// </summary>
|
/// <param name="conveyorLine">输送线实例对象</param>
|
public void RequestInSCLine(CommonConveyorLine conveyorLine)
|
{
|
try
|
{
|
PlatformStation platformsList = _PlatformStationService.GetPlatInData();
|
ConveyorTaskCommand command = lineCommand(conveyorLine, platformsList.Station_code);
|
DeviceProDTO? deviceProDTO6 = conveyorLine.DeviceProDTOs.Find(x => x.DeviceChildCode == platformsList.Station_code && x.DeviceProParamName == "StationNum" && x.DeviceProParamType == "DeviceCommand");
|
DeviceProDTO? deviceProDTO7 = conveyorLine.DeviceProDTOs.Find(x => x.DeviceChildCode == platformsList.Station_code && x.DeviceProParamName == "HandShake" && x.DeviceProParamType == "DeviceCommand");
|
if (command.HandShake && command.Barcodest != "")
|
{
|
//调取申请
|
Dt_Task task = _taskService.QueryConveyorLineTask(int.Parse(platformsList.Station_code), command.Barcodest);
|
if (task != null)
|
{
|
conveyorLine.Communicator.Write(deviceProDTO6.DeviceProAddress, (short)int.Parse(task.NextAddress));
|
|
_taskService.StackCraneTaskCompleted(task.TaskNum);
|
conveyorLine.Communicator.Write(deviceProDTO7.DeviceProAddress, (bool)true);
|
|
WriteLog.Write_Log("堆垛机放货站台", platformsList.Station_code + "站台", "成功", new { 信息 = $"写入条码：{command.Barcodest}，去向：{task.NextAddress}" });
|
}
|
/* else
|
{
|
WriteLog.Write_Log("堆垛机放货站台", platformsList.Station_code + "站台", "错误", new { 信息 = $"未找到条码：{command.Barcodest}的任务号" });
|
}*/
|
}
|
/* else
|
{
|
//conveyorLine.Communicator.Write(deviceProDTO6.DeviceProAddress, (int)0);
|
WriteLog.Write_Log("堆垛机放货站台", platformsList.Station_code + "站台", "错误", new { 信息 = $"未读取到检修出库放货站台申请或托盘条码，申请：{command.HandShake}，托盘条码：{command.Barcodest}，并清空写入条码" });
|
}*/
|
}
|
catch (Exception ex)
|
{
|
wcsWriteLog("堆垛机站台进行任务完成", "错误", $"错误信息：{ex.Message}");
|
throw;
|
}
|
}
|
|
/// <summary>
|
/// 读取信息记录
|
/// </summary>
|
/// <param name="SCLLinStack"></param>
|
/// <param name="Logtype"></param>
|
/// <param name="Magessadd"></param>
|
public void wcsWriteLog(string SCLLinStack, string Logtype, string Magessadd)
|
{
|
WriteLog.Write_Log("堆垛机取货站台", SCLLinStack + "站台", Logtype, new { 信息 = Magessadd });
|
}
|
|
|
public ConveyorTaskCommand lineCommand(CommonConveyorLine conveyorLine, string Station_code)
|
{
|
try
|
{
|
ConveyorTaskCommand conveyorLineCommand = new ConveyorTaskCommand();
|
List<DeviceProDTO> deviceProDTO6 = conveyorLine.DeviceProDTOs
|
.Where(x => x.DeviceChildCode == Station_code
|
&& DBLine.ListDBdata.Contains(x.DeviceProParamName)
|
&& x.DeviceProParamType == "ReadDeviceCommand")
|
.ToList();
|
foreach (var item in deviceProDTO6)
|
{
|
var paramName = item.DeviceProParamName;
|
var propertyInfo = typeof(ConveyorTaskCommand).GetProperty(paramName);
|
|
if (propertyInfo != null)
|
{
|
if (item.DeviceDataType == "bool")
|
{
|
var value = conveyorLine.Communicator.Read<bool>(item.DeviceProAddress);
|
propertyInfo.SetValue(conveyorLineCommand, value);
|
}
|
else if (item.DeviceDataType == "string")
|
{
|
var value = conveyorLine.Communicator.Read<string>(item.DeviceProAddress);
|
propertyInfo.SetValue(conveyorLineCommand, value);
|
}
|
}
|
}
|
return conveyorLineCommand;
|
}
|
catch (Exception ex)
|
{
|
wcsWriteLog("出库站台", "错误", $"错误信息：{ex.Message}");
|
throw;
|
}
|
}
|
|
|
}
|
}
|
