using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
using HH.WCS.Mobox3.DSZSH.models;
|
using HH.WCS.Mobox3.DSZSH.util;
|
using HH.WCS.Mobox3.DSZSH.wms;
|
using Newtonsoft.Json;
|
|
namespace HH.WCS.Mobox3.DSZSH.core {
|
public class Monitor {
|
public static void CheckInbound() {
|
var taskName = TaskName.托盘_满托下线入库;
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
try {
|
// 查产线是否有物料信息
|
|
var itemCode = "";
|
var batchNo = "";
|
var cntrCode = "";
|
var startLocCode = "";
|
|
var cgDetail = new TN_CG_Detail {
|
S_ITEM_CODE = itemCode,
|
S_BATCH_NO = batchNo,
|
S_CNTR_CODE = cntrCode,
|
};
|
|
var startLoc = db.Queryable<TN_Location>()
|
.Where(l => l.S_CODE == startLocCode) // 指定：起点货位号
|
.Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y") // 筛选：未上锁
|
.First();
|
|
|
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
|
}
|
|
public static void CheckOutboundOrder() {
|
var taskName = TaskName.成品胶出库;
|
var db = new SqlHelper<object>().GetInstance();
|
var info = $"轮询--{taskName}--";
|
|
try {
|
var orderList = db.Queryable<TN_Outbound_Order>()
|
.Where(c => c.N_B_STATE == 1)
|
.OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
|
.ToList();
|
|
if (orderList.Count == 0) {
|
info += $"暂无待执行的{taskName}单";
|
LogHelper.Info(info);
|
return;
|
}
|
|
var detailList = new List<TN_Outbound_Detail>();
|
foreach (var order in orderList) {
|
var doingCount = db.Queryable<TN_Outbound_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中
|
var allCount = db.Queryable<TN_Outbound_Detail>()
|
.Count(d => d.S_OO_NO == order.S_NO);
|
info += $"统计{taskName}单'{order.S_NO}'任务已下发：{doingCount}/{allCount}";
|
LogHelper.Info(info);
|
|
if (doingCount == allCount) {
|
order.N_B_STATE = 2; // 所有任务都已执行
|
db.Updateable<TN_Outbound_Order>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
continue;
|
}
|
|
var lastDetail = db.Queryable<TN_Outbound_Detail>()
|
.Where(d => d.S_OO_NO == order.S_NO && d.N_B_STATE == 2) // TODO 或者改成查task
|
.First();
|
|
if (lastDetail != null) {
|
info += $"{taskName}单'{order.S_NO}'上一个任务仍在进行中：" + JsonConvert.SerializeObject(lastDetail);
|
LogHelper.Info(info);
|
continue;
|
}
|
|
var outboundDetail = db.Queryable<TN_Outbound_Detail>()
|
.Where(a => a.S_OO_NO == order.S_NO && a.N_B_STATE == 1) // 已下发
|
.First();
|
|
if (outboundDetail == null) {
|
info += $"仍有任务未执行完成，但当前没有已下发的任务";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
detailList.Add(outboundDetail);
|
}
|
|
if (detailList.Count == 0) {
|
// 上面流程已经打印过日志
|
return;
|
}
|
|
foreach (var detail in detailList) {
|
var startLoc = db.Queryable<TN_Location>()
|
.LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE)
|
.First();
|
|
if (startLoc == null) {
|
LogHelper.Info($"轮询--{taskName}：没有找到合适的起点货位！");
|
continue;
|
}
|
|
var endLoc = db.Queryable<TN_Location>()
|
.Where(a => a.S_AREA_CODE == detail.S_END_AREA)
|
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y")
|
.Where(a => a.N_CURRENT_NUM == 0).First();
|
|
if (endLoc == null) {
|
LogHelper.Info($"轮询--{taskName}：没有找到合适的终点货位！单号'{detail.S_OO_NO}'要求终点库区为'{detail.S_END_AREA}'");
|
continue;
|
}
|
|
detail.N_B_STATE = 2;
|
|
var cntId = detail.S_CNTR_CODE;
|
var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
|
|
LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
|
LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Updateable<TN_Outbound_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info += $"修改明细表状态为完成--失败！";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info += $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info += $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info += $"生成任务'{taskName}'失败，容器号{cntId}，起点{startLoc.S_CODE}，终点货架{endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
tran.CommitTran();
|
info += $"生成任务'{taskName}'成功，容器号{cntId}，起点{startLoc.S_CODE}，终点货架{endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
}
|
}
|
catch (Exception ex) {
|
info += $"发生了异常：{ex.Message}";
|
LogHelper.InfoEx(ex);
|
}
|
}
|
|
public static void CheckCheckOrder() {
|
var taskName = TaskName.抽检_出库;
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
|
try {
|
var orderList = db.Queryable<TN_Check_Order>()
|
.Where(c => c.N_B_STATE == 1)
|
.OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
|
.ToList();
|
|
if (orderList.Count == 0) {
|
LogHelper.Info($"轮询--{taskName}--暂无待执行的{taskName}单");
|
return;
|
}
|
|
var detailList = new List<TN_Check_Detail>();
|
foreach (var order in orderList) {
|
var doingCount = db.Queryable<TN_Check_Detail>()
|
.Count(d => d.S_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中
|
var allCount = db.Queryable<TN_Check_Detail>()
|
.Count(d => d.S_NO == order.S_NO);
|
LogHelper.Info($"轮询--{taskName}--统计{taskName}单'{order.S_NO}'任务已下发：{doingCount}/{allCount}");
|
|
if (doingCount == allCount) {
|
order.N_B_STATE = 2; // 所有任务都已执行
|
db.Updateable<TN_Check_Order>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
continue;
|
}
|
|
var checkDetailList = db.Queryable<TN_Check_Detail>()
|
.Where(a => a.S_NO == order.S_NO && a.N_B_STATE == 1) // 已下发
|
.ToList();
|
|
if (checkDetailList.Count == 0) {
|
LogHelper.Info($"轮询--{taskName}--仍有任务未执行完成，但当前没有已下发的任务");
|
continue;
|
}
|
|
foreach (var checkDetail in checkDetailList) {
|
detailList.Add(checkDetail);
|
}
|
}
|
|
foreach (var detail in detailList) {
|
var startLoc = db.Queryable<TN_Location>()
|
.LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE)
|
.First();
|
|
if (startLoc == null) {
|
LogHelper.Info($"轮询--{taskName}：没有找到合适的起点货位！");
|
continue;
|
}
|
|
var endLoc = db.Queryable<TN_Location>()
|
.Where(l => l.S_AREA_CODE == detail.S_END_AREA)
|
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y") // 筛选：未上锁
|
.Where(a => a.N_CURRENT_NUM == 0).First();
|
|
if (endLoc == null) {
|
LogHelper.Info($"轮询--{taskName}：没有找到合适的终点货位！");
|
continue;
|
}
|
|
detail.N_B_STATE = 2;
|
|
var cntId = detail.S_CNTR_CODE;
|
var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
|
|
LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
|
LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Updateable<TN_Check_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
LogHelper.Info($"轮询--{taskName}：修改{taskName}单明细表状态为完成--失败！");
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败，容器号{cntId}，起点{startLoc.S_CODE}，终点货架{endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
tran.CommitTran();
|
info = $"生成任务'{taskName}'成功，容器号{cntId}，起点{startLoc.S_CODE}，终点货架{endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
}
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
}
|
|
public static void CheckShiftOrder() {
|
var taskName = TaskName.移库;
|
var db = new SqlHelper<object>().GetInstance();
|
var info = "";
|
try {
|
var orderList = db.Queryable<TN_Shift_Order>()
|
.Where(c => c.N_B_STATE == 1)
|
.OrderBy(c => c.T_CREATE, SqlSugar.OrderByType.Asc)
|
.ToList();
|
|
if (orderList.Count == 0) {
|
LogHelper.Info($"轮询--{taskName}--暂无待执行的{taskName}单");
|
return;
|
}
|
|
var detailList = new List<TN_Shift_Detail>();
|
foreach (var order in orderList) {
|
var doingCount = db.Queryable<TN_Shift_Detail>()
|
.Count(d => d.S_NO == order.S_NO && d.N_B_STATE >= 2); // 执行中
|
var allCount = db.Queryable<TN_Shift_Detail>()
|
.Count(d => d.S_NO == order.S_NO);
|
LogHelper.Info($"轮询--{taskName}--统计{taskName}单'{order.S_NO}'任务已下发：{doingCount}/{allCount}");
|
|
if (doingCount == allCount) {
|
order.N_B_STATE = 2; // 所有任务都已执行
|
db.Updateable<TN_Shift_Order>(order).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
|
continue;
|
}
|
|
var checkDetailList = db.Queryable<TN_Shift_Detail>()
|
.Where(a => a.S_NO == order.S_NO && a.N_B_STATE == 1) // 已下发
|
.ToList();
|
|
if (checkDetailList.Count == 0) {
|
LogHelper.Info($"轮询--{taskName}--仍有任务未执行完成，但当前没有已下发的任务");
|
continue;
|
}
|
|
foreach (var checkDetail in checkDetailList) {
|
detailList.Add(checkDetail);
|
}
|
}
|
|
foreach (var detail in detailList) {
|
var startLoc = db.Queryable<TN_Location>()
|
.LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
|
.Where((l, c) => c.S_CNTR_CODE == detail.S_CNTR_CODE)
|
.First();
|
|
if (startLoc == null) {
|
LogHelper.Info($"轮询--{taskName}：没有找到合适的起点货位！");
|
continue;
|
}
|
|
var endLoc = db.Queryable<TN_Location>()
|
.Where(l => l.S_AREA_CODE == detail.S_END_AREA)
|
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y") // 筛选：未上锁
|
.Where(a => a.N_CURRENT_NUM == 0).First();
|
|
if (endLoc == null) {
|
LogHelper.Info($"轮询--{taskName}：没有找到合适的终点货位！");
|
continue;
|
}
|
|
detail.N_B_STATE = 2;
|
|
var cntId = detail.S_CNTR_CODE;
|
var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
|
|
LocationHelper.LockLoc(ref startLoc, 2); // 起点出库锁
|
LocationHelper.LockLoc(ref endLoc, 1); // 终点入库锁
|
|
using (var tran = db.Ado.UseTran()) {
|
if (db.Updateable<TN_Shift_Detail>(detail).UpdateColumns(it => it.N_B_STATE).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
LogHelper.Info($"轮询--{taskName}：修改{taskName}单明细表状态为完成--失败！");
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
|
it.N_LOCK_STATE,
|
it.S_LOCK_STATE,
|
it.S_LOCK_OP,
|
it.T_MODIFY
|
}).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
|
tran.RollbackTran();
|
info = $"生成任务'{taskName}'失败，容器号{cntId}，起点{startLoc.S_CODE}，终点货架{endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
|
tran.CommitTran();
|
info = $"生成任务'{taskName}'成功，容器号{cntId}，起点{startLoc.S_CODE}，终点货架{endLoc.S_CODE}";
|
LogHelper.Info(info);
|
continue;
|
}
|
}
|
}
|
catch (Exception ex) {
|
LogHelper.InfoEx(ex);
|
}
|
}
|
}
|
}
|
