using NongFuWebApi.Services;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using static NongFuWebApi.Controllers.AMSModel;
|
|
namespace NongFuWebApi.Controllers
|
{
|
public class TaskHelper
|
{
|
|
/// <summary>
|
/// 淳安-查询托盘信息(单体)
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static ChunAnTrayInfo GetChunAnTrayInfo(string trayCode, string trayNum)
|
{
|
//var order = new SqlHelper<ChunAnTrayInfo>().Get(a => a.trayCode == trayCode && a.trayNum == trayNum, a => a.dateTime, true);
|
var order = new SqlHelper<ChunAnTrayInfo>().Get(a => a.trayCode == trayCode, a => a.dateTime, true);
|
return order;
|
}
|
|
/// <summary>
|
/// 靖宇-查询托盘信息(单体)
|
/// </summary>
|
/// <param name="lineNo"></param>
|
/// <returns></returns>
|
public static ThirdPartTrayInfo GetJingYuTrayInfo(string trayCode, string trayNum)
|
{
|
//var order = new SqlHelper<ChunAnTrayInfo>().Get(a => a.trayCode == trayCode && a.trayNum == trayNum, a => a.dateTime, true);
|
var order = new SqlHelper<ThirdPartTrayInfo>().Get(a => a.trayCode == trayCode, a => a.dateTime, true);
|
return order;
|
}
|
/// <summary>
|
/// 淳安-插入托盘信息
|
/// </summary>
|
/// <param name="wmsTask"></param>
|
/// <returns></returns>
|
internal static bool ChunAnInsertTrayInfo(ChunAnTrayInfo trayInfo)
|
{
|
//插入屏幕表托盘信息
|
var db1 = new SqlHelper<ChunAnScreenData>().GetInstance();
|
ChunAnScreenData ChunAnScreenInfo = new ChunAnScreenData()
|
{
|
DeviceNameNo = trayInfo.deviceName,
|
DataTypeNo = "托盘数据",
|
TrayCode = trayInfo.trayCode,
|
TrayCodeTime = trayInfo.dateTime
|
};
|
db1.Insertable(ChunAnScreenInfo).ExecuteCommand();
|
//插入托盘表托盘信息
|
var db = new SqlHelper<ChunAnTrayInfo>().GetInstance();
|
return db.Insertable(trayInfo).ExecuteCommand() > 0;
|
}
|
|
/// <summary>
|
/// 淳安-插入托盘信息
|
/// </summary>
|
/// <param name="wmsTask"></param>
|
/// <returns></returns>
|
internal static bool JingyuInsertTrayInfo(ThirdPartTrayInfo trayInfo)
|
{
|
////插入屏幕表托盘信息
|
//var db1 = new SqlHelper<ChunAnScreenData>().GetInstance();
|
//ChunAnScreenData ChunAnScreenInfo = new ChunAnScreenData()
|
//{
|
// DeviceNameNo = trayInfo.deviceName,
|
// DataTypeNo = "托盘数据",
|
// TrayCode = trayInfo.trayCode,
|
// TrayCodeTime = trayInfo.dateTime
|
//};
|
//db1.Insertable(ChunAnScreenInfo).ExecuteCommand();
|
//插入托盘表托盘信息
|
var db = new SqlHelper<ThirdPartTrayInfo>().GetInstance();
|
return db.Insertable(trayInfo).ExecuteCommand() > 0;
|
}
|
|
/// <summary>
|
/// 淳安-插入工单信息
|
/// </summary>
|
/// <param name="wmsTask"></param>
|
/// <returns></returns>
|
internal static bool ChunAnInsertWork(ChunAnWorkOrder wmsTask)
|
{
|
var db = new SqlHelper<ChunAnWorkOrder>().GetInstance();
|
return db.Insertable(wmsTask).ExecuteCommand() > 0;
|
}
|
|
/// <summary>
|
/// 靖宇-插入工单信息
|
/// </summary>
|
/// <param name="wmsTask"></param>
|
/// <returns></returns>
|
internal static bool JingYuInsertWork(WorkOrder1 wmsTask)
|
{
|
var db = new SqlHelper<WorkOrder1>().GetInstance();
|
return db.Insertable(wmsTask).ExecuteCommand() > 0;
|
}
|
/// <summary>
|
/// 淳安-更改工单状态
|
/// </summary>
|
/// <param name="task"></param>
|
/// <param name="status"></param>
|
/// <returns></returns>
|
internal static bool UpdateStatus(ChunAnWorkOrder task, string status, string dateTime, string extData = "")
|
{
|
var res = false;
|
var db = new SqlHelper<ChunAnWorkOrder>().GetInstance();
|
task.SQL_State = status;
|
task.SQL_PLAN_END = dateTime;
|
db.Updateable(task).UpdateColumns(it => new { it.SQL_State, it.SQL_PLAN_END }).ExecuteCommand();
|
return res;
|
}
|
/// <summary>
|
/// 靖宇-更改工单状态
|
/// </summary>
|
/// <param name="task"></param>
|
/// <param name="status"></param>
|
/// <returns></returns>
|
internal static bool UpdateStatus1(WorkOrder1 task, string status, string dateTime, string extData = "")
|
{
|
var res = false;
|
var db = new SqlHelper<WorkOrder1>().GetInstance();
|
task.S_WorkState = status;
|
task.S_PLAN_END = dateTime;
|
db.Updateable(task).UpdateColumns(it => new { it.S_WorkState, it.S_PLAN_END }).ExecuteCommand();
|
return res;
|
}
|
|
/// <summary>
|
/// 锁定或解锁库位（排）
|
/// </summary>
|
/// <param name="db"></param>
|
/// <param name="Row"></param>
|
/// <param name="AreaCode"></param>
|
/// <param name="UnType">true-解锁 false-锁定</param>
|
/// <param name="IsSend">true-传输富勒库位解锁锁定信息 false-不传输富勒库位锁定解锁信息</param>
|
public static void YiKuUnLockRow(SqlSugar.SqlSugarClient db, string Row, string AreaCode, bool UnType = true, bool IsSend = true, bool FuleDel = false)
|
{
|
//正式环境 无需传输库区编码，排号唯一（传输空值也行）
|
//var Srow = db.Queryable<RowLock>().Where(a => a.N_ROW == rowNo).First();
|
|
var Srow = db.Queryable<RowLock>().Where(a => a.N_ROW == Row && a.S_AREA_CODE == AreaCode).First();
|
if (UnType)
|
{
|
//解锁
|
if (Srow != null && Srow.S_LOCK_STATE.Trim() != "无")
|
{
|
Srow.S_LOCK_STATE = "无";
|
db.Updateable(Srow).UpdateColumns(a => new { a.S_LOCK_STATE }).ExecuteCommand();
|
if (!FuleDel)
|
{
|
//// ChunAnAnalysisMoveLib 移库库位解锁、分拣出库解锁 同时查询一下输送线下线中间表 删除占用数据
|
var moveLib = db.Queryable<ChunAnAnalysisMoveLib>().Where(a => a.AreaCode == AreaCode && a.RowNo == Row).First();
|
if (moveLib != null) db.Deleteable<ChunAnAnalysisMoveLib>(a => a.AreaCode == AreaCode && a.RowNo == Row).ExecuteCommand();
|
}
|
|
//插入中间表数据 避免农夫网关对调用IP进行限制
|
//if (IsSend) TaskProcess.AreaRowLockState(Srow.N_ROW.Trim(), false);
|
if (IsSend) InsertCacheTable(Srow.N_ROW.Trim(), false);
|
}
|
}
|
else
|
{
|
//锁定
|
if (Srow != null && Srow.S_LOCK_STATE.Trim() == "无")
|
{
|
Srow.S_LOCK_STATE = "其他锁";
|
db.Updateable(Srow).UpdateColumns(a => new { a.S_LOCK_STATE }).ExecuteCommand();
|
if (FuleDel)
|
{
|
// ChunAnAnalysisMoveLib 移库库位解锁、分拣出库解锁 同时查询一下输送线下线中间表 删除占用数据
|
var moveLib = db.Queryable<ChunAnAnalysisMoveLib>().Where(a => a.AreaCode == AreaCode && a.RowNo == Row).First();
|
if (moveLib != null) db.Deleteable<ChunAnAnalysisMoveLib>(a => a.AreaCode == AreaCode && a.RowNo == Row).ExecuteCommand();
|
}
|
|
//插入中间表数据 避免农夫网关对调用IP进行限制
|
if (IsSend) InsertCacheTable(Srow.N_ROW.Trim());
|
}
|
}
|
}
|
|
public static bool UpdateLocStock(Location loc, string stock)
|
{
|
bool res = false;
|
var db = new SqlHelper<Location>().GetInstance();
|
loc.S_LOCK_STATE = stock;
|
res = db.Updateable(loc).UpdateColumns(it => new { it.S_LOCK_STATE }).ExecuteCommand() > 0;
|
return res;
|
|
}
|
|
/// <summary>
|
/// 更新屏幕表数据
|
/// </summary>
|
/// <param name="a"></param>
|
/// <param name="db"></param>
|
public static void UpdateScreenTable(TrayInfo a, SqlSugar.SqlSugarClient db)
|
{
|
var screen = db.Queryable<ChunAnScreenData>().Where(it => it.DataTypeNo == "托盘数据" && it.TrayCode == a.trayCode).First();
|
if (screen != null)
|
{
|
screen.TrayCode = a.sign;
|
db.Updateable(screen).UpdateColumns(b => new { b.TrayCode }).ExecuteCommand();
|
}
|
}
|
|
/// <summary>
|
/// 插入 富勒托盘数据中间表 托盘数据 靖宇
|
/// 20230918新增优化项-判断当前产线是否存在对应执行中的有码工单，如果存在，则插入，反之，不插入
|
/// </summary>
|
/// <param name="a"></param>
|
/// <param name="TrayCode"></param>
|
public static bool InsertTrayCodeJy(TrayInfo a, string TrayCode, string deviceName, SqlSugar.SqlSugarClient db, ref string msg)
|
{
|
bool result = false;
|
var workInfo = db.Queryable<WorkOrder1>().Where(b => b.S_PLineNo == deviceName && b.S_WorkNo == a.workNo && b.S_WorkState == "执行中" && b.S_ORDER_TYPE == "产线下线").First();
|
if (workInfo != null)
|
{
|
ThirdPartTrayInfo TrayInfo = new ThirdPartTrayInfo()
|
{
|
deviceName = a.deviceName,
|
workNo = a.workNo,
|
trayCode = TrayCode,
|
trayNum = a.trayNum,
|
dateTime = a.dateTime,
|
batchNo = a.batchNo,
|
trayRule = a.trayRule,
|
itemLayer = a.itemLayer
|
};
|
result = JingyuInsertTrayInfo(TrayInfo);
|
//富勒下发托盘修改工单表托盘层数字段
|
workInfo.S_ItemLayer = a.itemLayer;
|
db.Updateable(workInfo).UpdateColumns(b => new { b.S_ItemLayer}).ExecuteCommand();
|
}
|
else msg += $"插入托盘数据异常：当前产线：{deviceName}，无对应执行中的有码模式工单，故此托盘：{TrayCode}不进行插入动作！";
|
|
return result;
|
}
|
|
/// <summary>
|
/// 插入 富勒托盘数据中间表 托盘数据
|
/// 20230918新增优化项-判断当前产线是否存在对应执行中的有码工单，如果存在，则插入，反之，不插入
|
/// </summary>
|
/// <param name="a"></param>
|
/// <param name="TrayCode"></param>
|
public static bool InsertTrayCode(TrayInfo a, string TrayCode, string deviceName, SqlSugar.SqlSugarClient db, ref string msg)
|
{
|
bool result = false;
|
var workInfo = db.Queryable<ChunAnWorkOrder>().Where(b => b.SQL_PLineNo == deviceName && b.SQL_State == "执行中" && b.SQL_ORDER_TYPE == "产线下线").First();
|
if (workInfo != null)
|
{
|
ChunAnTrayInfo ChunAnTrayInfo = new ChunAnTrayInfo()
|
{
|
deviceName = a.deviceName,
|
workNo = a.workNo,
|
trayCode = TrayCode,
|
trayNum = a.trayNum,
|
dateTime = a.dateTime,
|
batchNo = a.batchNo,
|
trayRule = a.trayRule,
|
itemLayer = a.itemLayer
|
};
|
result = ChunAnInsertTrayInfo(ChunAnTrayInfo);
|
}
|
else msg += $"插入托盘数据异常：当前产线：{deviceName}，无对应执行中的有码模式工单，故此托盘：{TrayCode}不进行插入动作！";
|
|
return result;
|
}
|
|
/// <summary>
|
/// 中间数据缓存表
|
/// </summary>
|
/// <param name="row"></param>
|
/// <param name="state"></param>
|
private static void InsertCacheTable(string row, bool state = true)
|
{
|
string ext2 = state ? "0" : "1";
|
var db = new SqlHelper<ChunAnCacheData>().GetInstance();
|
var cacheData = db.Queryable<ChunAnCacheData>().Where(a => a.DataSign == "HttpData" && a.Ext1 == row && a.Ext2 == ext2).First();
|
if (cacheData == null)
|
{
|
ChunAnCacheData chunAnCacheData = new ChunAnCacheData
|
{
|
DataSign = "HttpData",
|
Ext1 = row,
|
Ext2 = ext2
|
};
|
db.Insertable(chunAnCacheData).ExecuteCommand();
|
}
|
}
|
}
|
}
|
