using IWareCC.CacheInfo;
|
using IWareCC.CacheInfo.Container;
|
using IWareCC.Conveyor.Entity;
|
using IWareCC.ORM;
|
using IWareCC.Properties;
|
using IWareCommon.Enum.Common;
|
using IWareCommon.Help;
|
using IWareCommon.Util;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IWareCC.Conveyor.Handle.FinishConveyorTaskAuto
|
{
|
public class 获取当前的输送线任务: IHandler
|
{
|
/// <summary>
|
/// 该节点的下一个节点
|
/// </summary>
|
private IHandler nextHandler = null;
|
public IHandler NextHandler
|
{
|
set { nextHandler = value; }
|
}
|
|
private ConveyorEntity Conveyor;
|
|
/// <summary>
|
/// 任务容器
|
/// </summary>
|
private PartTaskContainer DecompositionTaskContainer;
|
|
|
public 获取当前的输送线任务( PartTaskContainer decompositionTaskContainer)
|
{
|
|
this.DecompositionTaskContainer = decompositionTaskContainer;
|
}
|
|
|
public void Handle()
|
{
|
using (var dbModel = new DbModel())
|
{
|
try
|
{
|
|
var task = dbModel.PartTasks.OrderBy(x=>x.finishtimes).FirstOrDefault(x => x.isreleased == (int)EYesOrNo.是 && x.isfinished == (int)EYesOrNo.否 && x.eqtype == (int)EPartTaskType.输送线任务);
|
|
if (task == null)
|
{
|
// LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/", "获取当前的输送线任务:{0}", "没有找到待完成的任务");
|
return;
|
}
|
string name = "Line" + task.sourceplace;
|
var conveyor = CacheEntity.Conveyors.FirstOrDefault(x => x.ConveyorName == name);
|
Conveyor = conveyor;
|
|
//if (!Conveyor.RAck && !Conveyor.WSTP && task.voidlabel < 3)
|
//{
|
// string msg = "";
|
// var flag = Conveyor.SendTask(Conveyor.DeviceId, int.Parse(task.taskcode), task.toplace, task.heighttype, out msg);
|
// if (flag)
|
// {
|
// if (Conveyor.WriteValue(Conveyor.OpcWriteItems.STP, 1))
|
// {
|
// task.voidlabel += 1;
|
// dbModel.SaveChanges();
|
// }
|
// }
|
// LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "选择一个未执行的输送线的任务:输送线{0}已在任务中，任务发送成功，但设备未接收到，重新发送", Conveyor.ConveyorName);
|
// return;
|
//}
|
//else if (!Conveyor.RAck && !Conveyor.WSTP && task.voidlabel > 3)
|
//{
|
// LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "选择一个未执行的输送线的任务:输送线{0}已在任务中，任务发送失败，但设备未接收任务已达3次，重新发送", Conveyor.ConveyorName);
|
//}
|
|
if (Conveyor.RAck && Conveyor.WSTP)
|
{
|
if (!Conveyor.WriteValue(Conveyor.OpcWriteItems.STP, 0))
|
{
|
Conveyor.WriteValue(Conveyor.OpcWriteItems.STP, 0);
|
}
|
LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "选择一个未执行的输送线的任务:输送线{0}已在任务中，不能下发任务", Conveyor.ConveyorName);
|
return;
|
}
|
|
|
task.finishtimes += 1;
|
|
dbModel.SaveChanges();
|
|
|
DecompositionTaskContainer.DecompositionTask = task;
|
LogTextHelper.WriteLine(Resources.LogDir + @"/完成输送线任务/" + Conveyor.ConveyorName, "获取当前的输送线任务:{0}", DecompositionTaskContainer.DecompositionTask.id);
|
|
if (nextHandler != null)
|
{
|
nextHandler.Handle();
|
}
|
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLog(Resources.LogDir, this.ToString(), "Handle", ex.Message);
|
}
|
}
|
}
|
}
|
}
|
