后台线程配置
This commit is contained in:
hehaibing-1996
@ -18,105 +18,105 @@ namespace WCS.BLL.Manager
|
||||
{
|
||||
public static void InitBackgroundThread()
|
||||
{
|
||||
#region 定时任务:回传Mes入库出库
|
||||
Task.Run(() =>
|
||||
{
|
||||
while (true)
|
||||
{
|
||||
//每5秒同步一次
|
||||
Thread.Sleep(5000);
|
||||
try
|
||||
{
|
||||
var records = DbHelp.db.Queryable<InOutRecord>()
|
||||
.Where(t => t.OperateTime > DateTime.Now.AddDays(-3)) //只查询回传三天内数据
|
||||
.Where(t => t.IsUpload == false)
|
||||
.Includes(t => t.StoreInfo)
|
||||
.OrderBy(t => t.Id)
|
||||
.ToList();
|
||||
//入库记录上传
|
||||
var inventoryDetails = records.Where(t => t.Direction == DirectionEnum.入库)
|
||||
.WhereIF(!string.IsNullOrEmpty(LocalFile.Config.GroupName), t => t.GroupName == LocalFile.Config.GroupName)
|
||||
.ToList();
|
||||
if (inventoryDetails != null && inventoryDetails.Count > 0)
|
||||
{
|
||||
for (int i = 0; i < inventoryDetails.Count; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
//请求WMS上传入库记录
|
||||
var data = new InputStockInRequest
|
||||
{
|
||||
materialBar = inventoryDetails[i].MatSN,
|
||||
shelfCode = inventoryDetails[i].BigShelfCode,
|
||||
shelfX = "R" + inventoryDetails[i].R,
|
||||
shelfY = "C" + inventoryDetails[i].C,
|
||||
shelfZ = inventoryDetails[i].Wei,
|
||||
inUser = inventoryDetails[i].OperateUser,
|
||||
inTime = inventoryDetails[i].OperateTime.ToString("yyyy-MM-dd HH:mm:ss"),
|
||||
};
|
||||
Guid guid = Guid.NewGuid();
|
||||
var result = ApiHelp.GetDataFromHttp<ResponseCommon>(LocalFile.Config.InputStockInStr, data, "POST", true);
|
||||
if (result != null && (result.Code == 200))
|
||||
{
|
||||
//上传成功 更改上传状态
|
||||
inventoryDetails[i].IsUpload = true;
|
||||
DbHelp.db.Updateable(inventoryDetails[i]).ExecuteCommand();
|
||||
}
|
||||
//#region 定时任务:回传Mes入库出库
|
||||
//Task.Run(() =>
|
||||
//{
|
||||
// while (true)
|
||||
// {
|
||||
// //每5秒同步一次
|
||||
// Thread.Sleep(5000);
|
||||
// try
|
||||
// {
|
||||
// var records = DbHelp.db.Queryable<InOutRecord>()
|
||||
// .Where(t => t.OperateTime > DateTime.Now.AddDays(-3)) //只查询回传三天内数据
|
||||
// .Where(t => t.IsUpload == false)
|
||||
// .Includes(t => t.StoreInfo)
|
||||
// .OrderBy(t => t.Id)
|
||||
// .ToList();
|
||||
// //入库记录上传
|
||||
// var inventoryDetails = records.Where(t => t.Direction == DirectionEnum.入库)
|
||||
// .WhereIF(!string.IsNullOrEmpty(LocalFile.Config.GroupName), t => t.GroupName == LocalFile.Config.GroupName)
|
||||
// .ToList();
|
||||
// if (inventoryDetails != null && inventoryDetails.Count > 0)
|
||||
// {
|
||||
// for (int i = 0; i < inventoryDetails.Count; i++)
|
||||
// {
|
||||
// try
|
||||
// {
|
||||
// //请求WMS上传入库记录
|
||||
// var data = new InputStockInRequest
|
||||
// {
|
||||
// materialBar = inventoryDetails[i].MatSN,
|
||||
// shelfCode = inventoryDetails[i].BigShelfCode,
|
||||
// shelfX = "R" + inventoryDetails[i].R,
|
||||
// shelfY = "C" + inventoryDetails[i].C,
|
||||
// shelfZ = inventoryDetails[i].Wei,
|
||||
// inUser = inventoryDetails[i].OperateUser,
|
||||
// inTime = inventoryDetails[i].OperateTime.ToString("yyyy-MM-dd HH:mm:ss"),
|
||||
// };
|
||||
// Guid guid = Guid.NewGuid();
|
||||
// var result = ApiHelp.GetDataFromHttp<ResponseCommon>(LocalFile.Config.InputStockInStr, data, "POST", true);
|
||||
// if (result != null && (result.Code == 200))
|
||||
// {
|
||||
// //上传成功 更改上传状态
|
||||
// inventoryDetails[i].IsUpload = true;
|
||||
// DbHelp.db.Updateable(inventoryDetails[i]).ExecuteCommand();
|
||||
// }
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
|
||||
}
|
||||
Thread.Sleep(200);
|
||||
}
|
||||
}
|
||||
// }
|
||||
// Thread.Sleep(200);
|
||||
// }
|
||||
// }
|
||||
|
||||
//出库记录上传
|
||||
var outRecord = records.Where(t => t.Direction == DirectionEnum.出库)
|
||||
.Where(t => !string.IsNullOrEmpty(t.OrderNumber))
|
||||
.WhereIF(!string.IsNullOrEmpty(LocalFile.Config.GroupName), t => t.GroupName == LocalFile.Config.GroupName)
|
||||
.ToList();
|
||||
if (outRecord != null && outRecord.Count > 0)
|
||||
{
|
||||
for (int i = 0; i < outRecord.Count; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
var retString = string.Empty;
|
||||
// //出库记录上传
|
||||
// var outRecord = records.Where(t => t.Direction == DirectionEnum.出库)
|
||||
// .Where(t => !string.IsNullOrEmpty(t.OrderNumber))
|
||||
// .WhereIF(!string.IsNullOrEmpty(LocalFile.Config.GroupName), t => t.GroupName == LocalFile.Config.GroupName)
|
||||
// .ToList();
|
||||
// if (outRecord != null && outRecord.Count > 0)
|
||||
// {
|
||||
// for (int i = 0; i < outRecord.Count; i++)
|
||||
// {
|
||||
// try
|
||||
// {
|
||||
// var retString = string.Empty;
|
||||
|
||||
var data = new BunkerOutRequest()
|
||||
{
|
||||
materialBar = outRecord[i].MatSN,
|
||||
outType = 0,
|
||||
pickBillNumber = outRecord[i].OrderNumber,
|
||||
qty = outRecord[i].MatQty,
|
||||
};
|
||||
var result = ApiHelp.GetDataFromHttp<ResponseCommon>(LocalFile.Config.BunkerOutStr, data, "POST", true);
|
||||
//请求成功
|
||||
if (result != null && result.Code == 200)
|
||||
{
|
||||
//上传成功 更改上传状态
|
||||
outRecord[i].IsUpload = true;
|
||||
DbHelp.db.Updateable(outRecord[i]).ExecuteCommand();
|
||||
}
|
||||
// var data = new BunkerOutRequest()
|
||||
// {
|
||||
// materialBar = outRecord[i].MatSN,
|
||||
// outType = 0,
|
||||
// pickBillNumber = outRecord[i].OrderNumber,
|
||||
// qty = outRecord[i].MatQty,
|
||||
// };
|
||||
// var result = ApiHelp.GetDataFromHttp<ResponseCommon>(LocalFile.Config.BunkerOutStr, data, "POST", true);
|
||||
// //请求成功
|
||||
// if (result != null && result.Code == 200)
|
||||
// {
|
||||
// //上传成功 更改上传状态
|
||||
// outRecord[i].IsUpload = true;
|
||||
// DbHelp.db.Updateable(outRecord[i]).ExecuteCommand();
|
||||
// }
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
|
||||
}
|
||||
Thread.Sleep(200);
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logs.Write("【定时任务】上传异常：" + ex.Message);
|
||||
}
|
||||
}
|
||||
});
|
||||
#endregion
|
||||
// }
|
||||
// Thread.Sleep(200);
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// Logs.Write("【定时任务】上传异常：" + ex.Message);
|
||||
// }
|
||||
// }
|
||||
//});
|
||||
//#endregion
|
||||
|
||||
#region 定时任务：超时退出 出库、入库、盘点模式
|
||||
Task.Run(() =>
|
||||
@ -169,97 +169,97 @@ namespace WCS.BLL.Manager
|
||||
});
|
||||
#endregion
|
||||
|
||||
#region 定时任务：海康未扫物料码的物料更新数据
|
||||
Task.Run(() =>
|
||||
{
|
||||
while (true)
|
||||
{
|
||||
//间隔20秒同步一次
|
||||
Thread.Sleep(20000);
|
||||
try
|
||||
{
|
||||
var inventoryDetails = DbHelp.db.Queryable<InventoryDetail>()
|
||||
.Where(t => t.MatName == "暂时未知")
|
||||
.Where(t => t.InstoreTime > DateTime.Now.AddDays(-3))
|
||||
.ToList();
|
||||
if (inventoryDetails != null && inventoryDetails.Count > 0)
|
||||
{
|
||||
for (int i = 0; i < inventoryDetails.Count; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
//请求WMS获取物料的信息
|
||||
var request = new QueryBybarRequest()
|
||||
{
|
||||
materialBar = inventoryDetails[i].MatSN
|
||||
};
|
||||
var result = ApiHelp.GetDataFromHttp<QueryBybarResponse>(LocalFile.Config.QueryBybar, request, "POST", true);
|
||||
if (result != null && (result.code == 200) && result.data != null && result.data.Count() > 0)
|
||||
{
|
||||
//查询成功 更改数值
|
||||
var instoreDto = result.data.FirstOrDefault();
|
||||
inventoryDetails[i].MatCode = instoreDto.materialCode;
|
||||
inventoryDetails[i].MatName = instoreDto.materialName;
|
||||
inventoryDetails[i].MatBatch = instoreDto.batchNo;
|
||||
inventoryDetails[i].MatSpec = instoreDto.materialSpec;
|
||||
inventoryDetails[i].MatQty = (int)instoreDto.materialQty;
|
||||
DbHelp.db.Updateable(inventoryDetails[i]).ExecuteCommand();
|
||||
}
|
||||
//#region 定时任务：海康未扫物料码的物料更新数据
|
||||
//Task.Run(() =>
|
||||
//{
|
||||
// while (true)
|
||||
// {
|
||||
// //间隔20秒同步一次
|
||||
// Thread.Sleep(20000);
|
||||
// try
|
||||
// {
|
||||
// var inventoryDetails = DbHelp.db.Queryable<InventoryDetail>()
|
||||
// .Where(t => t.MatName == "暂时未知")
|
||||
// .Where(t => t.InstoreTime > DateTime.Now.AddDays(-3))
|
||||
// .ToList();
|
||||
// if (inventoryDetails != null && inventoryDetails.Count > 0)
|
||||
// {
|
||||
// for (int i = 0; i < inventoryDetails.Count; i++)
|
||||
// {
|
||||
// try
|
||||
// {
|
||||
// //请求WMS获取物料的信息
|
||||
// var request = new QueryBybarRequest()
|
||||
// {
|
||||
// materialBar = inventoryDetails[i].MatSN
|
||||
// };
|
||||
// var result = ApiHelp.GetDataFromHttp<QueryBybarResponse>(LocalFile.Config.QueryBybar, request, "POST", true);
|
||||
// if (result != null && (result.code == 200) && result.data != null && result.data.Count() > 0)
|
||||
// {
|
||||
// //查询成功 更改数值
|
||||
// var instoreDto = result.data.FirstOrDefault();
|
||||
// inventoryDetails[i].MatCode = instoreDto.materialCode;
|
||||
// inventoryDetails[i].MatName = instoreDto.materialName;
|
||||
// inventoryDetails[i].MatBatch = instoreDto.batchNo;
|
||||
// inventoryDetails[i].MatSpec = instoreDto.materialSpec;
|
||||
// inventoryDetails[i].MatQty = (int)instoreDto.materialQty;
|
||||
// DbHelp.db.Updateable(inventoryDetails[i]).ExecuteCommand();
|
||||
// }
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
|
||||
}
|
||||
Thread.Sleep(500);
|
||||
}
|
||||
}
|
||||
// }
|
||||
// Thread.Sleep(500);
|
||||
// }
|
||||
// }
|
||||
|
||||
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logs.Write("【定时任务】更新海康物料信息异常：" + ex.Message);
|
||||
}
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// Logs.Write("【定时任务】更新海康物料信息异常：" + ex.Message);
|
||||
// }
|
||||
|
||||
Thread.Sleep(3000);
|
||||
try
|
||||
{
|
||||
var inventoryDetails = DbHelp.db.Queryable<InventoryDetail>()
|
||||
.Where(t => t.WarehouseCode == null)
|
||||
.Where(t => t.InstoreTime > DateTime.Now.AddDays(-30))
|
||||
.ToList();
|
||||
if (inventoryDetails != null && inventoryDetails.Count > 0)
|
||||
{
|
||||
for (int i = 0; i < inventoryDetails.Count; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
var url = $"http://192.168.2.23:9213/integrate/hkwsInventoryDetail/selectMaterialBar?materialBar={inventoryDetails[i].MatSN}";
|
||||
var result = ApiHelp.GetDataFromHttp<SelectMaterialBarResponse>(url, null, "POST", false);
|
||||
if (result != null && result.code == 200 && result.data != null && !string.IsNullOrEmpty(result.data.warehouseCode))
|
||||
{
|
||||
//查询成功 更改数值
|
||||
inventoryDetails[i].WarehouseCode = result.data.warehouseCode;
|
||||
DbHelp.db.Updateable(inventoryDetails[i]).ExecuteCommand();
|
||||
}
|
||||
// Thread.Sleep(3000);
|
||||
// try
|
||||
// {
|
||||
// var inventoryDetails = DbHelp.db.Queryable<InventoryDetail>()
|
||||
// .Where(t => t.WarehouseCode == null)
|
||||
// .Where(t => t.InstoreTime > DateTime.Now.AddDays(-30))
|
||||
// .ToList();
|
||||
// if (inventoryDetails != null && inventoryDetails.Count > 0)
|
||||
// {
|
||||
// for (int i = 0; i < inventoryDetails.Count; i++)
|
||||
// {
|
||||
// try
|
||||
// {
|
||||
// var url = $"http://192.168.2.23:9213/integrate/hkwsInventoryDetail/selectMaterialBar?materialBar={inventoryDetails[i].MatSN}";
|
||||
// var result = ApiHelp.GetDataFromHttp<SelectMaterialBarResponse>(url, null, "POST", false);
|
||||
// if (result != null && result.code == 200 && result.data != null && !string.IsNullOrEmpty(result.data.warehouseCode))
|
||||
// {
|
||||
// //查询成功 更改数值
|
||||
// inventoryDetails[i].WarehouseCode = result.data.warehouseCode;
|
||||
// DbHelp.db.Updateable(inventoryDetails[i]).ExecuteCommand();
|
||||
// }
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logs.Write("【定时任务】更新仓库代码异常：" + ex.Message);
|
||||
}
|
||||
Thread.Sleep(500);
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
}
|
||||
}
|
||||
});
|
||||
#endregion
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// Logs.Write("【定时任务】更新仓库代码异常：" + ex.Message);
|
||||
// }
|
||||
// Thread.Sleep(500);
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// }
|
||||
// }
|
||||
//});
|
||||
//#endregion
|
||||
|
||||
#region 定时任务：监测警示灯关灯机制
|
||||
//判断灯颜色和模式是否对应
|
||||
|
||||
@ -39,6 +39,9 @@ namespace WebApi
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD>ط<EFBFBD><D8B7>߳<EFBFBD>
|
||||
WarningManager.StartWarningMessageThread();
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>̨<EFBFBD><CCA8><EFBFBD><EFBFBD>Ӳ<EFBFBD><D3B2>״̬<D7B4>߳<EFBFBD> <20><>ʱ<EFBFBD>˳<EFBFBD>ģʽ<C4A3><CABD><EFBFBD><EFBFBD><EFBFBD>عصƵȻ<C6B5><C8BB><EFBFBD>
|
||||
MXBackgroundThread.InitBackgroundThread();
|
||||
|
||||
//<2F><>Ѷ<EFBFBD><D1B6>˾<EFBFBD><CBBE>̨<EFBFBD>߳<EFBFBD>
|
||||
if (LocalFile.Config.IsMx)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user