108 lines
4.6 KiB
C#
108 lines
4.6 KiB
C#
using CirculateTool;
|
||
using WcsMain.Business.CommonAction;
|
||
using WcsMain.DataBase.Dao;
|
||
using WcsMain.DataBase.TableEntity;
|
||
using WcsMain.Enum;
|
||
using WcsMain.EquipOperation.Entity;
|
||
using WcsMain.EquipOperation.StackerConvey;
|
||
|
||
namespace WcsMain.Business.CirculationTask.StackerConvey;
|
||
|
||
/// <summary>
|
||
/// 过账，PLC任务回告 ---- 库前输送线
|
||
/// </summary>
|
||
[Circulation]
|
||
public class CheckAccount(AppWcsTaskDao wcsTaskDao, StackerConveyOperation stackerConveyOperation, WCSTaskExecuteEvent wcsTaskEvent)
|
||
{
|
||
private readonly WCSTaskExecuteEvent _wcsTaskEvent = wcsTaskEvent;
|
||
private readonly StackerConveyOperation _stackerConveyOperation = stackerConveyOperation;
|
||
private readonly AppWcsTaskDao _wcsTaskDao = wcsTaskDao;
|
||
|
||
/// <summary>
|
||
/// PLC过账
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[Circulation("监控PLC地址，过账", 1000)]
|
||
public bool CheckAccountTask()
|
||
{
|
||
List<TaskFeedBackEntity>? taskFeedBackEntities = _stackerConveyOperation.GetConveyTaskFeedBackData(20);
|
||
if (taskFeedBackEntities == default || taskFeedBackEntities.Count < 1) {return true; }
|
||
foreach (TaskFeedBackEntity taskFeedBackEntity in taskFeedBackEntities)
|
||
{
|
||
if (taskFeedBackEntity.PlcId == 0) { continue; }
|
||
List<AppWcsTask>? wcsTasks = _wcsTaskDao.Select(new AppWcsTask() { PlcId = taskFeedBackEntity.PlcId });
|
||
if (wcsTasks == default)
|
||
{
|
||
ConsoleLog.Error($"【异常】库前输送过账查询任务数据失败，和数据库服务器连接中断");
|
||
Thread.Sleep(2000);
|
||
continue; // 网络连接中断
|
||
}
|
||
if (wcsTasks.Count < 1)
|
||
{
|
||
ConsoleLog.Warning($"【提示】库前输送过账区获取任务ID：{taskFeedBackEntity.PlcId}，无关联任务");
|
||
_stackerConveyOperation.ClearFeedBackData(taskFeedBackEntity); // 清除过账
|
||
continue; // 任务无数据
|
||
}
|
||
var wcsTask = wcsTasks[0];
|
||
switch (taskFeedBackEntity.FeedBackType)
|
||
{
|
||
case (int)TaskFeedBackTypeEnum.cancel: // 任务取消
|
||
CancelTask(taskFeedBackEntity, wcsTask);
|
||
break;
|
||
case (int)TaskFeedBackTypeEnum.complete: // 任务完成
|
||
CompleteTask(taskFeedBackEntity, wcsTask);
|
||
break;
|
||
default:
|
||
OtherTaskFeedBackType(taskFeedBackEntity); // 其他任务类型，
|
||
break;
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 过账任务取消
|
||
/// </summary>
|
||
/// <param name="taskFeedBackEntity"></param>
|
||
private void CancelTask(TaskFeedBackEntity taskFeedBackEntity, AppWcsTask wcsTask)
|
||
{
|
||
ConsoleLog.Warning($"【提示】库前输送过账区获取任务ID：{taskFeedBackEntity.PlcId}，任务已经被取消，后续任务也一并取消,任务号：{wcsTask.TaskId}");
|
||
string? cleanAccountErr = _stackerConveyOperation.ResetFeedBackData(taskFeedBackEntity); // 清除过账
|
||
if (!string.IsNullOrEmpty(cleanAccountErr))
|
||
{
|
||
ConsoleLog.Warning($"[警告]取消任务清除过账区发生异常，信息：{cleanAccountErr}");
|
||
}
|
||
/* 执行 WMS 任务异常动作 */
|
||
_wcsTaskEvent.ErrTaskEvent(wcsTask, "任务被PLC取消");
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 过账任务完成
|
||
/// </summary>
|
||
/// <param name="taskFeedBackEntity"></param>
|
||
private void CompleteTask(TaskFeedBackEntity taskFeedBackEntity, AppWcsTask wcsTask)
|
||
{
|
||
ConsoleLog.Tip($"[提示]过账区获取任务ID：{taskFeedBackEntity.PlcId}，任务已经完成,任务号：{wcsTask.TaskId}");
|
||
string? cleanAccountErr = _stackerConveyOperation.ResetFeedBackData(taskFeedBackEntity); // 清除过账
|
||
if (!string.IsNullOrEmpty(cleanAccountErr))
|
||
{
|
||
ConsoleLog.Warning($"[警告]完成任务清除过账区发生异常，信息：{cleanAccountErr}");
|
||
}
|
||
/* 执行 WMS 任务完成动作 */
|
||
_wcsTaskEvent.CompleteTaskEvent(wcsTask, "PLC上报完成");
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 其他过账类型
|
||
/// </summary>
|
||
/// <param name="taskFeedBackEntity"></param>
|
||
private void OtherTaskFeedBackType(TaskFeedBackEntity taskFeedBackEntity)
|
||
{
|
||
ConsoleLog.Warning($"[警告]过账区获取任务ID：{taskFeedBackEntity.PlcId}，无法识别的过账类型：{taskFeedBackEntity.FeedBackType}");
|
||
_stackerConveyOperation.ResetFeedBackData(taskFeedBackEntity); // 清除过账
|
||
}
|
||
|
||
} |