using HH.WCS.Hexafluo.dispatch;
|
using HH.WCS.Hexafluo.util;
|
using HH.WCS.Hexafluo.wms;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
|
namespace HH.WCS.Hexafluo.core
|
{
|
/// <summary>
|
/// 定时轮询任务
|
/// </summary>
|
public class MonitorAgvPriy
|
{
|
private static object locko4 = new object();
|
/// <summary>
|
/// 调整优先级
|
/// </summary>
|
public static void CheckCamera()
|
{
|
try
|
{
|
//lock (locko4)
|
//{
|
var chi = new SqlHelper<object>().GetInstance();
|
var newDb2 = chi.CopyNew();
|
DateTime datt = DateTime.Now;
|
//提高优先级
|
var TaskList1 = newDb2.Queryable<WMSTask>().Where(e => e.S_NOTE == "自管任务" && e.S_READ_LOCK == "N" && e.S_B_STATE == "未执行" && e.S_TYPE == "出库" && e.T_MODIFY < datt.AddMinutes(-20) && e.N_PRIORITY == 0)
|
.ToList();
|
if (!TaskList1.Any())
|
{
|
|
//调整优先级
|
foreach (var task in TaskList1)
|
{
|
LogHelper.Info("处理自管任务", $" 出库 任务提高优先级 {JsonConvert.SerializeObject(task)}");
|
var ddd = newDb2.Queryable<WMSTask>().Where(e => e.S_SRC_NO == task.S_SRC_NO).ToList();
|
var fff = ddd.Select(e => e.S_ID).ToList();
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = 30, T_MODIFY = DateTime.Now }).Where(x => fff.Contains(x.S_ID)).ExecuteCommand();
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
//提高出库agv的优先级
|
var TaskList2 = newDb2.Queryable<WMSTask>().Where(e => e.S_NOTE == "agv任务" && e.S_B_STATE == "已推送" && e.S_TYPE == "出库" && e.T_MODIFY < datt.AddMinutes(-20) && e.N_PRIORITY == 0 && e.S_Main_task == "子任务")
|
.ToList();
|
if (!TaskList2.Any())
|
{
|
//查询对应的立库任务是否完成
|
var TaskList3 = newDb2.Queryable<WMSTask>().Where(e => e.S_NOTE == "立库任务" && e.S_B_STATE == "完成" && e.S_TYPE == "出库" && e.S_Main_task == "子任务" && TaskList2.Select(c => c.S_SRC_NO).ToList().Contains(e.S_SRC_NO))
|
.ToList();
|
if (!TaskList3.Any())
|
{
|
TaskList2 = TaskList2.FindAll(e => TaskList3.Select(c => c.S_SRC_NO).ToList().Contains(e.S_SRC_NO)).ToList();
|
//调整优先级
|
foreach (var task in TaskList2)
|
{
|
//查询这个任务的立库任务是否完成了
|
LogHelper.Info("处理自管任务", $" 出库 任务提高优先级 {JsonConvert.SerializeObject(task)}");
|
var ddd = newDb2.Queryable<WMSTask>().Where(e => e.S_SRC_NO == task.S_SRC_NO).ToList();
|
var fff = ddd.Select(e => e.S_ID).ToList();
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = 20, T_MODIFY = DateTime.Now }).Where(x => fff.Contains(x.S_ID)).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(task.S_TASK_NO, 20);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
|
//调整优先级
|
var State = new List<string> { "未执行", "已推送", "执行中" };
|
List<string> Arealist = new List<string>() { "LBJT", "TCYYXB", "NCYYXB", "TCXB", "TTXB", "NCXB", "DSXB", "TMXB", "TQXB", "DSCKJBW", "DSCXK", "TMJT" };
|
List<string> TTArea = new List<string>() { "TCXB", "TTXB", "NCXB", "DSXB", "TMXB", "TQXB" };
|
var TaskList4 = newDb2.Queryable<WMSTask>().Where(e => e.S_NOTE == "agv任务" && State.Contains(e.S_B_STATE) && Arealist.Contains(e.S_START_LAREA) && e.T_MODIFY < datt.AddMinutes(-2)).ToList();
|
if (TaskList4.Any())
|
{
|
var Lbjt = TaskList4.FindAll(e => e.S_START_LAREA == "LBJT" && e.T_MODIFY < datt.AddMinutes(-5)).ToList();
|
if (Lbjt.Any())
|
{
|
foreach (var item in Lbjt)
|
{
|
if (item.S_B_STATE == "未执行")
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
else
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
var TCYYXB = TaskList4.FindAll(e => e.S_START_LAREA == "TCYYXB" && e.T_MODIFY < datt.AddMinutes(-2)).ToList();
|
if (TCYYXB.Any())
|
{
|
foreach (var item in TCYYXB)
|
{
|
if (item.S_B_STATE == "未执行")
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
else
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
var NCYYXB = TaskList4.FindAll(e => e.S_START_LAREA == "NCYYXB" && e.T_MODIFY < datt.AddMinutes(-4)).ToList();
|
if (NCYYXB.Any())
|
{
|
foreach (var item in NCYYXB)
|
{
|
if (item.S_B_STATE == "未执行")
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
else
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
var TCXB = TaskList4.FindAll(e => TTArea.Contains(e.S_START_LAREA) && e.T_MODIFY < datt.AddMinutes(-20)).ToList();
|
if (TCXB.Any())
|
{
|
foreach (var item in TCXB)
|
{
|
if (item.S_B_STATE == "未执行")
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
else
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
var DSCKJBW = TaskList4.FindAll(e => e.S_START_LAREA == "DSCKJBW" && e.T_MODIFY < datt.AddMinutes(-2) && e.S_B_STATE != "未执行").ToList();
|
if (DSCKJBW.Any())
|
{
|
foreach (var item in DSCKJBW)
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
var DSCXK = TaskList4.FindAll(e => e.S_START_LAREA == "DSCXK" && e.T_MODIFY < datt.AddMinutes(-5)).ToList();
|
if (DSCXK.Any())
|
{
|
foreach (var item in DSCXK)
|
{
|
if (item.S_B_STATE == "未执行")
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
else
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
|
|
var TMJT = TaskList4.FindAll(e => e.S_START_LAREA == "TMJT" && e.T_MODIFY < datt.AddMinutes(-3)).ToList();
|
if (TMJT.Any())
|
{
|
foreach (var item in TMJT)
|
{
|
if (item.S_B_STATE != "未执行")
|
{
|
try
|
{
|
newDb2.BeginTran();
|
var I = newDb2.Updateable<WMSTask>().SetColumns(it => new WMSTask() { N_PRIORITY = item.N_PRIORITY + 1, T_MODIFY = DateTime.Now }).Where(x => x.S_ID == item.S_ID).ExecuteCommand();
|
var Agvstr = NDCHelper.ChangeParamPri(item.S_TASK_NO, item.N_PRIORITY + 1);
|
newDb2.CommitTran();
|
}
|
catch (Exception)
|
{
|
newDb2.RollbackTran();
|
}
|
}
|
}
|
}
|
}
|
// }
|
}
|
catch (System.Exception ex)
|
{
|
LogHelper.Info("处理自管任务", ex.Message + ex.StackTrace);
|
}
|
}
|
}
|
}
|
