|
|
using Khd.Core.Domain.Models;
|
|
|
using Khd.Core.EntityFramework;
|
|
|
using Khd.Core.Library.Mapper;
|
|
|
using Khd.Core.Wcs.Global;
|
|
|
using Masuit.Tools;
|
|
|
using Masuit.Tools.Logging;
|
|
|
using Microsoft.CodeAnalysis;
|
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
|
using Microsoft.Extensions.Hosting;
|
|
|
using SixLabors.ImageSharp;
|
|
|
using System.Data;
|
|
|
using Z.EntityFramework.Plus;
|
|
|
|
|
|
namespace Khd.Core.Wcs.Wcs
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 根据出入库记录创建出入库任务
|
|
|
/// </summary>
|
|
|
public class CreateTaskByRecord
|
|
|
{
|
|
|
private readonly IHost _host;
|
|
|
public CreateTaskByRecord(IHost host)
|
|
|
{
|
|
|
this._host = host;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 启动上件扫描监听
|
|
|
/// </summary>
|
|
|
public void StartPoint()
|
|
|
{
|
|
|
////背负式Agv返库任务
|
|
|
//var createBearAgvReturnThread = new Thread(CreateBearAgvReturnLogic);
|
|
|
//createBearAgvReturnThread.Start();
|
|
|
////五楼半成品入库任务
|
|
|
//var createFiveProductInTaskThread = new Thread(CreateFiveProductInTaskLogic);
|
|
|
//createFiveProductInTaskThread.Start();
|
|
|
////五楼成品出库任务
|
|
|
//var createFiveProductTaskThread = new Thread(CreateFiveProductTaskLogic);
|
|
|
//createFiveProductTaskThread.Start();
|
|
|
////五楼CTU出库任务以及原材料出库任务
|
|
|
//var createRawTaskThread = new Thread(CreateRawTaskLogic);
|
|
|
//createRawTaskThread.Start();
|
|
|
////五楼柜体拆分返库任务
|
|
|
//var createRawInThread = new Thread(CreateRawInTaskLogic);
|
|
|
//createRawInThread.Start();
|
|
|
////三楼去翻转机任务
|
|
|
//var createThirdOutTaskThread = new Thread(CreateThirdOutTaskLogic);
|
|
|
//createThirdOutTaskThread.Start();
|
|
|
////二楼成品出库任务
|
|
|
//var CreateSecondProductTaskThread = new Thread(CreateSecondProductTaskLogic);
|
|
|
//CreateSecondProductTaskThread.Start();
|
|
|
////三楼托盘收集架满5个或10个时出库合盘任务
|
|
|
//var createEmptyTrayThread = new Thread(CreateEmptyTrayLogic);
|
|
|
//createEmptyTrayThread.Start();
|
|
|
////二楼废品区人工调度任务
|
|
|
//var createThirdWasterTaskThread = new Thread(CreateThirdWasterTaskLogic);
|
|
|
//createThirdWasterTaskThread.Start();
|
|
|
|
|
|
Console.WriteLine(DateTime.Now + ":出库任务监听启动成功");
|
|
|
LogManager.Info("出库任务监听启动成功");
|
|
|
}
|
|
|
|
|
|
private void CreateRawInTaskLogic(object? obj)
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
WcsTask? wcsTask = dbContext.WcsTask.Where(t => t.nextPointId == 28 && t.useFlag == 0 && t.currPointId == 29).FirstOrDefault();
|
|
|
if (wcsTask != null)
|
|
|
{
|
|
|
WmsRawInstock? wmsRawInstock = dbContext.WmsRawInstock.Where(t => t.warehouseId == 511 && t.instockType == "2" && t.executeStatus == "0").FirstOrDefault();
|
|
|
if (wmsRawInstock != null)
|
|
|
{
|
|
|
MesBasePalletInfo? mesBasePalletInfo = dbContext.MesBasePalletInfo.FirstOrDefault(t => t.palletInfoCode == wcsTask.containerNo);
|
|
|
if (mesBasePalletInfo != null)
|
|
|
{
|
|
|
MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.FirstOrDefault(t => t.barcodeInfo == mesBasePalletInfo.materialBarcode);
|
|
|
if (mesBaseBarcodeInfo != null)
|
|
|
{
|
|
|
WmsRawInstockDetail wmsRawInstockDetail = new WmsRawInstockDetail
|
|
|
{
|
|
|
rawInstockDetailId = StaticData.SnowId.NextId(),
|
|
|
stackAmount = 1,
|
|
|
erpStatus = "0",
|
|
|
executeStatus = "1",
|
|
|
qualityStatus = "0",
|
|
|
activeFlag = "1",
|
|
|
createBy = "WCS",
|
|
|
createDate = DateTime.Now,
|
|
|
erpAmount = 0,
|
|
|
instockAmount = 1,
|
|
|
instockBatch = mesBasePalletInfo.materialBarcode,
|
|
|
instockTime = DateTime.Now,
|
|
|
instockWay = "2",
|
|
|
locationCode = wcsTask.endPointNo,
|
|
|
machineName = mesBaseBarcodeInfo.machineName,
|
|
|
materialBarcode = mesBasePalletInfo.materialBarcode,
|
|
|
materialId = mesBaseBarcodeInfo.materialId,
|
|
|
materialProductionDate = mesBaseBarcodeInfo.productionDate,
|
|
|
planAmount = 1,
|
|
|
poNo = mesBaseBarcodeInfo.poNo,
|
|
|
rawInstockId = wmsRawInstock.rawInstockId,
|
|
|
taskCode = wmsRawInstock.taskCode,
|
|
|
};
|
|
|
dbContext.Add(wmsRawInstockDetail);
|
|
|
wmsRawInstock.executeStatus = "1";
|
|
|
wcsTask.useFlag = 1;
|
|
|
dbContext.Update(wmsRawInstock);
|
|
|
dbContext.Update(wcsTask);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 根据人工任务生成可执行任务
|
|
|
/// </summary>
|
|
|
/// <param name="obj"></param>
|
|
|
private void CreateThirdWasterTaskLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
bool hasTask = dbContext.WcsTask.Where(t => t.nextPointId == 9).Any();
|
|
|
if (!hasTask)
|
|
|
{
|
|
|
WcsTaskManual? wcsTaskManual = dbContext.WcsTaskManual.Where(t => t.nextPointId == 9 || t.nextPointId == 8).OrderBy(t => t.createBy).FirstOrDefault();
|
|
|
if (wcsTaskManual != null)
|
|
|
{
|
|
|
WcsTask wcsTask = CoreMapper.Map<WcsTask>(wcsTaskManual);
|
|
|
wcsTask.createTime = DateTime.Now;
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
dbContext.Remove(wcsTaskManual);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 3楼托盘库
|
|
|
/// </summary>
|
|
|
/// <param name="obj"></param>
|
|
|
private void CreateEmptyTrayLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
BaseEquip agvEquip = StaticData.BaseEquip.First(t => t.objid == 9);
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
bool canCreate = dbContext.WcsTask.Where(t => t.nextPointId == 9).Where(t=>t.taskStatus<5).Any();
|
|
|
if (!canCreate)
|
|
|
{
|
|
|
BaseEquip baseEquip = dbContext.BaseEquip.First(t => t.objid == 35);
|
|
|
//if (baseEquip.emptyCount == (SystemData.maxTray / 2))
|
|
|
//{
|
|
|
// var endEquip = dbContext.BaseEquip.FirstOrDefault(t => t.equipType == 15 && t.equipStatus == 1 && t.emptyCount == (SystemData.maxTray / 2));
|
|
|
// if (endEquip != null)
|
|
|
// {
|
|
|
// var wcsTask = new WcsTask()
|
|
|
// {
|
|
|
// objid = StaticData.SnowId.NextId(),
|
|
|
// serialNo = SystemData.GetSerialNo(dbContext),
|
|
|
// taskType = 40,
|
|
|
// nextPointId = agvEquip.objid,
|
|
|
// nextPointNo = agvEquip.equipNo,
|
|
|
// endPointId = baseEquip.objid,
|
|
|
// endPointNo = baseEquip.equipNo,
|
|
|
// currPointId = endEquip.objid,
|
|
|
// currPointNo = endEquip.equipNo,
|
|
|
// equipmentNo = agvEquip.equipNo,
|
|
|
// useFlag = 1,
|
|
|
// qty = 5,
|
|
|
// isEmpty = "1",
|
|
|
// taskStatus = 0,
|
|
|
// createBy = "WCS",
|
|
|
// createTime = DateTime.Now,
|
|
|
// floorNo = 3,
|
|
|
// fromFloorNo = 3,
|
|
|
// masterId = 0,
|
|
|
// orderId = 0,
|
|
|
// materialId = 0,
|
|
|
// };
|
|
|
// WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
// dbContext.Add(wcsTask);
|
|
|
// dbContext.Add(wcsTaskLog);
|
|
|
// dbContext.SaveChanges();
|
|
|
// }
|
|
|
// else
|
|
|
// {
|
|
|
// endEquip = dbContext.BaseEquip.FirstOrDefault(t => t.equipType == 15 && t.equipStatus == 0 && t.emptyCount == 0);
|
|
|
// if (endEquip != null)
|
|
|
// {
|
|
|
// var wcsTask = new WcsTask()
|
|
|
// {
|
|
|
// objid = StaticData.SnowId.NextId(),
|
|
|
// serialNo = SystemData.GetSerialNo(dbContext),
|
|
|
// taskType = 43,
|
|
|
// nextPointId = agvEquip.objid,
|
|
|
// nextPointNo = agvEquip.equipNo,
|
|
|
// endPointId = endEquip.objid,
|
|
|
// endPointNo = endEquip.equipNo,
|
|
|
// currPointId = baseEquip.objid,
|
|
|
// currPointNo = baseEquip.equipNo,
|
|
|
// equipmentNo = agvEquip.equipNo,
|
|
|
// useFlag = 1,
|
|
|
// qty = 5,
|
|
|
// isEmpty = "1",
|
|
|
// taskStatus = 0,
|
|
|
// createBy = "WCS",
|
|
|
// createTime = DateTime.Now,
|
|
|
// floorNo = 3,
|
|
|
// fromFloorNo = 3,
|
|
|
// masterId = 0,
|
|
|
// orderId = 0,
|
|
|
// materialId = 0,
|
|
|
// };
|
|
|
// WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
// dbContext.Add(wcsTask);
|
|
|
// dbContext.Add(wcsTaskLog);
|
|
|
// dbContext.SaveChanges();
|
|
|
// }
|
|
|
// }
|
|
|
//}
|
|
|
//else
|
|
|
if (baseEquip.emptyCount == SystemData.maxTray)
|
|
|
{
|
|
|
var endEquip = dbContext.BaseEquip.FirstOrDefault(t => t.equipType == 15 && t.equipStatus == 0 && t.emptyCount == 0);
|
|
|
if (endEquip != null)
|
|
|
{
|
|
|
var wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
serialNo = SystemData.GetSerialNo(dbContext),
|
|
|
taskType = 43,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = endEquip.objid,
|
|
|
endPointNo = endEquip.equipNo,
|
|
|
currPointId = baseEquip.objid,
|
|
|
currPointNo = baseEquip.equipNo,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = SystemData.maxTray,
|
|
|
isEmpty = "1",
|
|
|
taskStatus = 0,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
floorNo = 3,
|
|
|
fromFloorNo = 3,
|
|
|
masterId = 0,
|
|
|
orderId = 0,
|
|
|
materialId = 0,
|
|
|
};
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 背负式Agv退库
|
|
|
/// </summary>
|
|
|
private void BackReturnTaskLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
WcsTask? wcsTask = dbContext.WcsTask.Where(t => t.taskType == 28).FirstOrDefault();
|
|
|
if (wcsTask != null)
|
|
|
{
|
|
|
WmsRawInstock? wmsRawInstock = dbContext.WmsRawInstock.Where(t => t.instockType == "2" && t.warehouseId == 511 && t.executeStatus == "0").FirstOrDefault();
|
|
|
if (wmsRawInstock != null)
|
|
|
{
|
|
|
wcsTask.useFlag = 1;
|
|
|
wcsTask.createTime = DateTime.Now;
|
|
|
wmsRawInstock.executeStatus = "1";
|
|
|
wmsRawInstock.beginTime = DateTime.Now;
|
|
|
WmsRawInstockDetail wmsRawInstockDetail = new WmsRawInstockDetail()
|
|
|
{
|
|
|
rawInstockDetailId = StaticData.SnowId.NextId(),
|
|
|
rawInstockId = wmsRawInstock.rawInstockId,
|
|
|
instockWay = "2",
|
|
|
activeFlag = "1",
|
|
|
stackAmount = 1,
|
|
|
createBy = "WCS",
|
|
|
createDate = DateTime.Now,
|
|
|
materialId = wmsRawInstock.materialId,
|
|
|
instockAmount = 1,
|
|
|
executeStatus = "0",
|
|
|
};
|
|
|
dbContext.Update(wmsRawInstock);
|
|
|
dbContext.Update(wcsTask);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch
|
|
|
{
|
|
|
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 半成品入库
|
|
|
/// </summary>
|
|
|
/// <param name="obj"></param>
|
|
|
private void CreateFiveProductInTaskLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
BaseEquip agvEquip = StaticData.BaseEquip.First(t => t.objid == 28);
|
|
|
BaseEquip endEquip = StaticData.BaseEquip.First(t => t.objid == 30);
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
bool task = dbContext.WcsTask.Where(t => t.nextPointId == 28 && t.taskStatus <= 5).Any();
|
|
|
if (!task)
|
|
|
{
|
|
|
var wmsProductInstock = dbContext.WmsProductInstock
|
|
|
.Where(t => t.productType == "2")
|
|
|
.Where(t => t.auditStatus == "1")
|
|
|
.Where(t => t.warehouseId == 521)
|
|
|
.FirstOrDefault();
|
|
|
if (wmsProductInstock != null && wmsProductInstock.executeStatus == "0")
|
|
|
{
|
|
|
var wmsBaseLocation = dbContext.WmsBaseLocation
|
|
|
.Where(t => t.warehouseId == 521)
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => t.locationStatus == "1")
|
|
|
.Where(t => t.containerCode == null)
|
|
|
.OrderByDescending(t => t.locColumn)
|
|
|
.FirstOrDefault();
|
|
|
if (wmsBaseLocation != null)
|
|
|
{
|
|
|
var wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
serialNo = SystemData.GetSerialNo(dbContext),
|
|
|
taskType = 34,
|
|
|
endPointId = wmsBaseLocation.locationId,
|
|
|
endPointNo = wmsBaseLocation.locationCode,
|
|
|
currPointId = endEquip.objid,
|
|
|
currPointNo = endEquip.equipNo,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = 1,
|
|
|
containerNo = wmsProductInstock.palletInfoCode,
|
|
|
taskStatus = 0,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
floorNo = 5,
|
|
|
fromFloorNo = 5,
|
|
|
isEmpty = "0",
|
|
|
masterId = wmsProductInstock.productId,
|
|
|
orderId = wmsProductInstock.productInstockId,
|
|
|
materialId = wmsProductInstock.productId,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
materialBarcode = wmsProductInstock.productBatch,
|
|
|
};
|
|
|
WmsProductInstockDetail wmsProductInstockDetail = new WmsProductInstockDetail()
|
|
|
{
|
|
|
erpAmount = 0,
|
|
|
productId = wmsProductInstock.productId,
|
|
|
executeStatus = "1",
|
|
|
productInstockDetailId = StaticData.SnowId.NextId(),
|
|
|
instockAmount = 1,
|
|
|
instockBy = "WCS",
|
|
|
instockDate = DateTime.Now,
|
|
|
instockWay = "2",
|
|
|
locationCode = wmsBaseLocation.locationCode,
|
|
|
planAmount = 1,
|
|
|
productBarcode = wmsProductInstock.productBatch,
|
|
|
productBatch = wmsProductInstock.productBatch,
|
|
|
productInstockId = wmsProductInstock.productInstockId,
|
|
|
};
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
wmsProductInstock.executeStatus = "1";
|
|
|
wmsBaseLocation.instockFlag = "1";
|
|
|
wmsBaseLocation.locationStatus = "4";
|
|
|
dbContext.Add(wmsProductInstockDetail);
|
|
|
dbContext.Update(wmsProductInstock);
|
|
|
dbContext.Update(wmsBaseLocation);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 创建去翻转机的任务
|
|
|
/// </summary>
|
|
|
/// <param name="obj"></param>
|
|
|
/// <exception cref="NotImplementedException"></exception>
|
|
|
private void CreateThirdOutTaskLogic()
|
|
|
{
|
|
|
BaseEquip endEquip = StaticData.BaseEquip.First(t => t.objid == 31);
|
|
|
BaseEquip baseEquip = StaticData.BaseEquip.First(t => t.objid == 9);
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
bool task = dbContext.WcsTask.Where(t => t.nextPointId == 9 && t.taskStatus <= 5).Any();
|
|
|
if (!task)
|
|
|
{
|
|
|
endEquip = dbContext.BaseEquip.First(t => t.objid == 31);
|
|
|
if (endEquip.emptyCount == 0)
|
|
|
{
|
|
|
WcsTask? wcsTask = dbContext.WcsTask.FirstOrDefault(t => t.endPointId == endEquip.objid);
|
|
|
if (wcsTask == null)
|
|
|
{
|
|
|
WcsTaskManual? wcsTaskManual = dbContext.WcsTaskManual.Where(t => t.taskType == 999).FirstOrDefault();
|
|
|
if (wcsTaskManual != null)
|
|
|
{
|
|
|
var wmsRawOutstock = dbContext.WmsRawOutstock.FirstOrDefault(t => t.rawOutstockId == wcsTaskManual.orderId);
|
|
|
if (wmsRawOutstock != null)
|
|
|
{
|
|
|
var wmsRawStocks = dbContext.WmsRawStock
|
|
|
.Where(t => t.saleOrderId == wmsRawOutstock.saleOrderId)
|
|
|
.Where(t => t.warehouseId == 311)
|
|
|
.ToList();
|
|
|
var AllWmsBaseLocations = dbContext.WmsBaseLocation.Where(t => t.warehouseId == 311).ToList();
|
|
|
var wmsBaseLocations = AllWmsBaseLocations
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.delFlag == "0")
|
|
|
.Where(t => t.locationScrapType == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => t.warehouseId == 311)
|
|
|
.OrderByDescending(t=>t.locRow)
|
|
|
.ThenByDescending(t=>t.locColumn)
|
|
|
.ToList();
|
|
|
var bill = from a in wmsBaseLocations
|
|
|
from b in wmsRawStocks
|
|
|
where a.locationCode == b.locationCode
|
|
|
select new { a, b };
|
|
|
WmsBaseLocation? wmsBaseLocation = null;
|
|
|
WmsRawStock? wmsRawStock = null;
|
|
|
bill = bill.OrderBy(t => t.b.instockDate);
|
|
|
var fistbill = bill.FirstOrDefault();
|
|
|
if (fistbill != null)
|
|
|
{
|
|
|
int? locRow = 0;
|
|
|
if (fistbill.a.locRow % 2 == 1)
|
|
|
{
|
|
|
locRow = fistbill.a.locRow + 1;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
locRow = fistbill.a.locRow - 1;
|
|
|
}
|
|
|
|
|
|
var lastbill = bill.Where(t => t.a.locRow == locRow)
|
|
|
.Where(t => t.a.locColumn == fistbill.a.locColumn)
|
|
|
.Where(t => t.a.locDeep == 2)
|
|
|
.FirstOrDefault();
|
|
|
wmsBaseLocation = fistbill.a;
|
|
|
if (lastbill != null)
|
|
|
{
|
|
|
if (lastbill.b.instockDate != null && fistbill.b.instockDate != null)
|
|
|
{
|
|
|
|
|
|
if (wmsBaseLocation.locDeep == 1)
|
|
|
{
|
|
|
int? row = 0;
|
|
|
if (wmsBaseLocation.locRow % 2 == 1)
|
|
|
{
|
|
|
row = wmsBaseLocation.locRow + 1;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
row = wmsBaseLocation.locRow - 1;
|
|
|
}
|
|
|
var lowLocationBill = bill.Where(t => t.a.locRow == locRow).Where(t => t.a.locColumn == wmsBaseLocation.locColumn).Where(t => t.a.warehouseId == wmsBaseLocation.warehouseId).FirstOrDefault();
|
|
|
if (lowLocationBill != null)
|
|
|
{
|
|
|
wmsBaseLocation = lowLocationBill.a;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
WmsBaseLocation? fromBaseLocation = AllWmsBaseLocations.Where(t => t.locRow == row)
|
|
|
.Where(t => t.locColumn == wmsBaseLocation.locColumn)
|
|
|
.Where(t => t.warehouseId == wmsBaseLocation.warehouseId).FirstOrDefault();
|
|
|
if (fromBaseLocation != null && !string.IsNullOrEmpty(fromBaseLocation.containerCode))
|
|
|
{
|
|
|
WmsBaseLocation? toLocation = AllWmsBaseLocations.Where(t => t.warehouseId == wmsBaseLocation.warehouseId)
|
|
|
.Where(t => t.locDeep == 1)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode))
|
|
|
.Where(t=>t.locColumn>wmsBaseLocation.locColumn)
|
|
|
.OrderBy(t => t.locColumn)
|
|
|
.FirstOrDefault();
|
|
|
toLocation ??= AllWmsBaseLocations.Where(t => t.warehouseId == wmsBaseLocation.warehouseId)
|
|
|
.Where(t => t.locDeep == 1)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode))
|
|
|
.Where(t => t.locColumn < wmsBaseLocation.locColumn)
|
|
|
.OrderByDescending(t => t.locColumn)
|
|
|
.FirstOrDefault();
|
|
|
toLocation ??= AllWmsBaseLocations.Where(t => t.warehouseId == wmsBaseLocation.warehouseId)
|
|
|
.Where(t => t.warehouseId != wmsBaseLocation.locationId)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode))
|
|
|
.FirstOrDefault();
|
|
|
if (toLocation != null)
|
|
|
{
|
|
|
var RemoveTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
taskType = 67,
|
|
|
containerNo = fromBaseLocation.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now.AddSeconds(-10),
|
|
|
taskStatus = 0,
|
|
|
currPointId = fromBaseLocation.locationId,
|
|
|
currPointNo = fromBaseLocation.locationCode,
|
|
|
nextPointId = baseEquip.objid,
|
|
|
nextPointNo = baseEquip.equipNo,
|
|
|
endPointId = toLocation.locationId,
|
|
|
endPointNo = toLocation.locationCode,
|
|
|
equipmentNo = baseEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = 1
|
|
|
};
|
|
|
toLocation.locationStatus = "4";
|
|
|
toLocation.instockFlag = "1";
|
|
|
toLocation.updateBy = "WCS";
|
|
|
toLocation.updateTime = DateTime.Now;
|
|
|
fromBaseLocation.updateBy = "WCS";
|
|
|
fromBaseLocation.updateTime = DateTime.Now;
|
|
|
fromBaseLocation.outstockFlag = "1";
|
|
|
fromBaseLocation.locationStatus = "4";
|
|
|
dbContext.Update(toLocation);
|
|
|
dbContext.Update(fromBaseLocation);
|
|
|
dbContext.Add(RemoveTask);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(RemoveTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
if (wmsBaseLocation != null)
|
|
|
{
|
|
|
wmsRawStock = wmsRawStocks.Where(t => t.locationCode == wmsBaseLocation.locationCode).First();
|
|
|
MesBasePalletInfo? mesBasePalletInfo = dbContext.MesBasePalletInfo.FirstOrDefault(t => t.palletInfoCode == wmsRawStock.palletInfoCode);
|
|
|
if (mesBasePalletInfo != null)
|
|
|
{
|
|
|
MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.FirstOrDefault(t => t.barcodeInfo == mesBasePalletInfo.materialBarcode);
|
|
|
if (mesBaseBarcodeInfo != null)
|
|
|
{
|
|
|
WmsRawOutstockDetail wmsRawOutstockDetail = new WmsRawOutstockDetail()
|
|
|
{
|
|
|
rawOutstockDetailId = StaticData.SnowId.NextId(),
|
|
|
createBy = "WCS",
|
|
|
createDate = DateTime.Now,
|
|
|
executeStatus = "0",
|
|
|
erpAmount = 0,
|
|
|
erpStatus = "0",
|
|
|
instockBatch = mesBaseBarcodeInfo.batchCode,
|
|
|
stackAmount = 1,
|
|
|
locationCode = wmsBaseLocation.locationCode,
|
|
|
rawOutstockId = wmsRawOutstock.rawOutstockId,
|
|
|
planAmount = 1,
|
|
|
outstockWay = "2",
|
|
|
outstockPerson = "WCS",
|
|
|
outstockTime = DateTime.Now,
|
|
|
materialProductionDate = mesBaseBarcodeInfo.productionDate,
|
|
|
materialBarcode = mesBasePalletInfo.materialBarcode,
|
|
|
materialId = wmsRawOutstock.materialId,
|
|
|
machineName = mesBaseBarcodeInfo.machineName,
|
|
|
outstockAmount = 1,
|
|
|
taskCode = wmsRawOutstock.taskCode
|
|
|
};
|
|
|
wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = wmsRawOutstock.rawOutstockId,
|
|
|
taskType = 41,
|
|
|
containerNo = wmsBaseLocation.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
taskStatus = 0,
|
|
|
materialId = wmsRawOutstock.materialId,
|
|
|
currPointId = wmsBaseLocation.locationId,
|
|
|
currPointNo = wmsBaseLocation.locationCode,
|
|
|
nextPointId = baseEquip.objid,
|
|
|
nextPointNo = baseEquip.equipNo,
|
|
|
endPointId = endEquip.objid,
|
|
|
endPointNo = endEquip.equipNo,
|
|
|
equipmentNo = endEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = 1
|
|
|
};
|
|
|
wmsBaseLocation.outstockFlag = "1";
|
|
|
wmsBaseLocation.locationStatus = "6";
|
|
|
dbContext.Update(wmsBaseLocation);
|
|
|
dbContext.Add(wmsRawOutstockDetail);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
dbContext.Remove(wcsTaskManual);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 创建返库任务
|
|
|
/// </summary>
|
|
|
/// <param name="obj"></param>
|
|
|
private void CreateBearAgvReturnLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
BaseEquip endEquip = StaticData.BaseEquip.First(t => t.objid == 21);
|
|
|
BaseEquip baseEquip = StaticData.BaseEquip.First(t => t.objid == 10);
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
var wmsRawReturn = dbContext.WmsRawReturn
|
|
|
.Where(t => t.auditStatus == "1")
|
|
|
.Where(t => t.executeStatus == "0")
|
|
|
.FirstOrDefault();
|
|
|
if (wmsRawReturn != null)
|
|
|
{
|
|
|
bool hasTask = dbContext.WcsTask.Where(t => t.nextPointId == baseEquip.objid).Any();
|
|
|
if (!hasTask)
|
|
|
{
|
|
|
//任务未开始Status=0
|
|
|
BaseEquip? startEquip = StaticData.BaseEquip.FirstOrDefault(t => t.equipNo == wmsRawReturn.endStationCode);
|
|
|
if (startEquip != null)
|
|
|
{
|
|
|
WcsTask wcsTask = new()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = wmsRawReturn.rawReturnId,
|
|
|
taskType = 48,
|
|
|
containerNo = null,
|
|
|
currPointId = startEquip.objid,
|
|
|
currPointNo = startEquip.equipNo,
|
|
|
nextPointId = baseEquip.objid,
|
|
|
nextPointNo = baseEquip.equipNo,
|
|
|
endPointId = endEquip.objid,
|
|
|
endPointNo = endEquip.equipNo,
|
|
|
serialNo = SystemData.GetSerialNo(dbContext),
|
|
|
taskStatus = 0,
|
|
|
createTime = DateTime.Now,
|
|
|
createBy = "WCS",
|
|
|
materialId = wmsRawReturn.materialId,
|
|
|
qty = 1,
|
|
|
useFlag = 1,
|
|
|
equipmentNo = startEquip.equipNo,
|
|
|
remark = "装配区返库",
|
|
|
floorNo = 5,
|
|
|
masterId = wmsRawReturn.materialId,
|
|
|
fromFloorNo = 5,
|
|
|
//materialNo = wmsRawReturn.materialBatch,
|
|
|
};
|
|
|
wmsRawReturn.executeStatus = "1";
|
|
|
dbContext.Add(wcsTask);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
dbContext.Update(wmsRawReturn);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 成品出库
|
|
|
/// </summary>
|
|
|
private void CreateFiveProductTaskLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
BaseEquip lineEquip = dbContext.BaseEquip.First(t => t.objid == 5);
|
|
|
if (lineEquip.equipStatus == 0)
|
|
|
{
|
|
|
bool task = dbContext.WcsTask.Where(t => t.nextPointId == 28 && t.taskStatus <= 5).Any();
|
|
|
if (!task)
|
|
|
{
|
|
|
var proStock = dbContext.WmsProductStock
|
|
|
.Where(t => t.warehouseId == 531)
|
|
|
.Where(t => t.activeFlag == "1").ToList();
|
|
|
var proOutStock = dbContext.WmsProductOutstock
|
|
|
.Where(t => t.outstockQty < t.applyQty)
|
|
|
.Where(t => t.auditStatus == "1")
|
|
|
.Where(t => t.warehouseId == 531)
|
|
|
.Where(t => t.productType == "3")
|
|
|
.Where(t => t.executeStatus == "0" || t.executeStatus == "1").ToList();
|
|
|
//获取最早入库时间
|
|
|
foreach (var item in proOutStock)
|
|
|
{
|
|
|
task = dbContext.WcsTask.Where(t => t.nextPointId == 28 && t.taskStatus <= 5).Any();
|
|
|
if (!task)
|
|
|
{
|
|
|
BaseEquip endEquip = dbContext.BaseEquip.First(t => t.floorNo == 5 && t.equipType == 1);
|
|
|
|
|
|
var wmsproStocks = proStock
|
|
|
.Where(t => t.productId == item.productId && t.warehouseId == item.warehouseId)
|
|
|
.Where(t => t.totalAmount > t.frozenAmount)
|
|
|
.Select(t => t.locationCode)
|
|
|
.ToList();
|
|
|
List<WmsBaseLocation> AllWmsBaseLocations = dbContext.WmsBaseLocation.Where(t => t.warehouseId == item.warehouseId).ToList();
|
|
|
var wmsBaseLocations = AllWmsBaseLocations
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.delFlag == "0")
|
|
|
.Where(t => t.locationScrapType == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => t.locationStatus == "1")
|
|
|
.Where(t => t.warehouseId == item.warehouseId)
|
|
|
.Where(t => wmsproStocks.Contains(t.locationCode))
|
|
|
.ToList();
|
|
|
|
|
|
decimal needNumber = Convert.ToDecimal(item.applyQty - item.outstockQty);
|
|
|
if (needNumber <= 0)
|
|
|
{
|
|
|
item.executeStatus = "2";
|
|
|
dbContext.Update(item);
|
|
|
dbContext.SaveChanges();
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
var bill = from a in wmsBaseLocations
|
|
|
from b in proStock
|
|
|
where a.locationCode == b.locationCode
|
|
|
select new { a, b };
|
|
|
|
|
|
BaseEquip agvEquip = StaticData.BaseEquip.First(t => t.objid == 28);
|
|
|
foreach (var b in bill)
|
|
|
{
|
|
|
item.executeStatus = "1";
|
|
|
WmsBaseLocation location = b.a;
|
|
|
WmsProductStock stock = b.b;
|
|
|
WcsTask wcsTask;
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
MesBasePalletInfo? mesBasePalletInfo = dbContext.MesBasePalletInfo.FirstOrDefault(t => t.palletInfoCode == stock.palletInfoCode);
|
|
|
if (mesBasePalletInfo != null)
|
|
|
{
|
|
|
|
|
|
if (location.locDeep == 1)
|
|
|
{
|
|
|
int? row = 0;
|
|
|
if (location.locRow % 2 == 1)
|
|
|
{
|
|
|
row = location.locRow + 1;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
row = location.locRow - 1;
|
|
|
}
|
|
|
var lowLocationBill = bill.Where(t => t.a.locRow == row).Where(t => t.a.locColumn == location.locColumn).Where(t => t.a.warehouseId == location.warehouseId).FirstOrDefault();
|
|
|
if (lowLocationBill != null)
|
|
|
{
|
|
|
location = lowLocationBill.a;
|
|
|
stock = lowLocationBill.b;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
WmsBaseLocation? wmsBaseLocation = AllWmsBaseLocations.Where(t => t.locRow == row)
|
|
|
.Where(t => t.locColumn == location.locColumn)
|
|
|
.Where(t => t.warehouseId == location.warehouseId).FirstOrDefault();
|
|
|
if (wmsBaseLocation != null && !string.IsNullOrEmpty(wmsBaseLocation.containerCode))
|
|
|
{
|
|
|
WmsBaseLocation? toLocation = AllWmsBaseLocations.Where(t => t.warehouseId == location.warehouseId)
|
|
|
.Where(t => t.locDeep == 1)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode)).FirstOrDefault();
|
|
|
toLocation ??= AllWmsBaseLocations.Where(t => t.warehouseId == location.warehouseId)
|
|
|
.Where(t => t.warehouseId != location.locationId)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode))
|
|
|
.FirstOrDefault();
|
|
|
if (toLocation != null)
|
|
|
{
|
|
|
var RemoveTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.productOutstockId,
|
|
|
taskType = 38,
|
|
|
containerNo = wmsBaseLocation.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now.AddSeconds(-10),
|
|
|
taskStatus = 0,
|
|
|
materialId = item.productId,
|
|
|
currPointId = wmsBaseLocation.locationId,
|
|
|
currPointNo = wmsBaseLocation.locationCode,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = toLocation.locationId,
|
|
|
endPointNo = toLocation.locationCode,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = 1
|
|
|
};
|
|
|
toLocation.locationStatus = "4";
|
|
|
toLocation.instockFlag = "1";
|
|
|
toLocation.updateBy = "WCS";
|
|
|
toLocation.updateTime = DateTime.Now;
|
|
|
wmsBaseLocation.updateBy = "WCS";
|
|
|
wmsBaseLocation.updateTime = DateTime.Now;
|
|
|
wmsBaseLocation.outstockFlag = "1";
|
|
|
wmsBaseLocation.locationStatus = "4";
|
|
|
dbContext.Update(toLocation);
|
|
|
dbContext.Update(wmsBaseLocation);
|
|
|
dbContext.Add(RemoveTask);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(RemoveTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
continue;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
WmsProductOutstockDetail detail = new()
|
|
|
{
|
|
|
productId = item.productId,
|
|
|
productOutstockId = item.productOutstockId,
|
|
|
locationCode = location.locationCode,
|
|
|
executeStatus = "1",
|
|
|
beginTime = DateTime.Now,
|
|
|
warehouseId = item.warehouseId,
|
|
|
erpAmount = 0,
|
|
|
confirmAmount = 0,
|
|
|
outstockAmount = 1,
|
|
|
planAmount = 1,
|
|
|
productBatch = item.productBatch,
|
|
|
productOutstockDetailId = StaticData.SnowId.NextId(),
|
|
|
productBarcode = mesBasePalletInfo.materialBarcode
|
|
|
};
|
|
|
wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.productOutstockId,
|
|
|
taskType = 38,
|
|
|
containerNo = location.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
taskStatus = 0,
|
|
|
materialId = item.productId,
|
|
|
currPointId = location.locationId,
|
|
|
currPointNo = location.locationCode,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = lineEquip.objid,
|
|
|
endPointNo = lineEquip.equipNo,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = 1
|
|
|
};
|
|
|
location.outstockFlag = "1";
|
|
|
location.locationStatus = "6";
|
|
|
location.updateBy = "WCS";
|
|
|
location.updateTime = DateTime.Now;
|
|
|
dbContext.Add(detail);
|
|
|
dbContext.Update(location);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Update(stock);
|
|
|
dbContext.SaveChanges();
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (item.beginTime == null)
|
|
|
{
|
|
|
item.beginTime = DateTime.Now;
|
|
|
}
|
|
|
dbContext.Update(item);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
Console.WriteLine(ex.Message + ex.StackTrace);
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 成品出库
|
|
|
/// </summary>
|
|
|
private void CreateSecondProductTaskLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
BaseEquip lineEquip = dbContext.BaseEquip.First(t => t.objid == 2);
|
|
|
if (lineEquip.equipStatus == 0)
|
|
|
{
|
|
|
bool task = dbContext.WcsTask.Where(t => t.nextPointId == 8 && t.taskStatus <= 7).Any();
|
|
|
if (!task)
|
|
|
{
|
|
|
var proStock = dbContext.WmsProductStock
|
|
|
.Where(t => t.warehouseId == 231)
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.totalAmount > t.frozenAmount)
|
|
|
.ToList();
|
|
|
var proOutStock = dbContext.WmsProductOutstock
|
|
|
.Where(t => t.outstockQty < t.applyQty)
|
|
|
.Where(t => t.auditStatus == "1")
|
|
|
.Where(t => t.warehouseId == 231)
|
|
|
.Where(t => t.productType == "3")
|
|
|
.Where(t => t.executeStatus == "0" || t.executeStatus == "1").ToList();
|
|
|
//获取最早入库时间
|
|
|
foreach (var item in proOutStock)
|
|
|
{
|
|
|
|
|
|
var wmsproStocks = proStock
|
|
|
.Where(t => t.productId == item.productId && t.saleOrderId == item.saleOrderId && t.warehouseId == item.warehouseId)
|
|
|
.Select(t => t.palletInfoCode)
|
|
|
.ToList();
|
|
|
List<WmsBaseLocation> AllWmsBaseLocations = dbContext.WmsBaseLocation.Where(t => t.warehouseId == item.warehouseId).ToList();
|
|
|
var wmsBaseLocations = AllWmsBaseLocations
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.delFlag == "0")
|
|
|
.Where(t => t.locationScrapType == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.locationStatus == "1")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => t.warehouseId == item.warehouseId)
|
|
|
.Where(t => wmsproStocks.Contains(t.containerCode))
|
|
|
.ToList();
|
|
|
|
|
|
decimal needNumber = Convert.ToDecimal(item.applyQty - item.outstockQty);
|
|
|
if (needNumber <= 0)
|
|
|
{
|
|
|
item.executeStatus = "2";
|
|
|
dbContext.Update(item);
|
|
|
dbContext.SaveChanges();
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
var bill = from a in wmsBaseLocations
|
|
|
from b in proStock
|
|
|
where a.containerCode == b.palletInfoCode
|
|
|
select new { a, b };
|
|
|
WmsBaseLocation? location = null;
|
|
|
WmsProductStock? stock = null;
|
|
|
BaseEquip agvEquip = StaticData.BaseEquip.First(t => t.objid == 8);
|
|
|
BaseEquip endEquip = StaticData.BaseEquip.First(t => t.objid == 1);
|
|
|
foreach (var b in bill)
|
|
|
{
|
|
|
item.executeStatus = "1";
|
|
|
location = b.a;
|
|
|
stock = b.b;
|
|
|
WcsTask wcsTask;
|
|
|
int qty = 0;
|
|
|
if (stock.totalAmount - stock.frozenAmount <= needNumber)
|
|
|
{
|
|
|
item.outstockQty += stock.totalAmount - stock.frozenAmount;
|
|
|
qty = Convert.ToInt32(stock.totalAmount - stock.frozenAmount);
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
item.outstockQty += needNumber;
|
|
|
qty = Convert.ToInt32(needNumber);
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
}
|
|
|
MesBasePalletInfo? mesBasePalletInfo = dbContext.MesBasePalletInfo.FirstOrDefault(t => t.palletInfoCode == location.containerCode);
|
|
|
if (mesBasePalletInfo != null)
|
|
|
{
|
|
|
WmsProductOutstockDetail detail = new()
|
|
|
{
|
|
|
productId = item.productId,
|
|
|
productOutstockId = item.productOutstockId,
|
|
|
locationCode = location.locationCode,
|
|
|
executeStatus = "1",
|
|
|
beginTime = DateTime.Now,
|
|
|
warehouseId = item.warehouseId,
|
|
|
erpAmount = 0,
|
|
|
confirmAmount = 0,
|
|
|
outstockAmount = 1,
|
|
|
planAmount = 1,
|
|
|
productBatch = item.productBatch,
|
|
|
productOutstockDetailId = StaticData.SnowId.NextId(),
|
|
|
productBarcode = mesBasePalletInfo.materialBarcode,
|
|
|
};
|
|
|
if (location.locDeep == 1)//如果是深库位
|
|
|
{
|
|
|
int? row = 0;
|
|
|
if (location.locRow % 2 == 1)
|
|
|
{
|
|
|
row = location.locRow + 1;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
row = location.locRow - 1;
|
|
|
}
|
|
|
var lowLocationBill = bill.Where(t => t.a.locRow == row).Where(t => t.a.locColumn == location.locColumn).Where(t => t.a.warehouseId == location.warehouseId).FirstOrDefault();
|
|
|
if (lowLocationBill != null)
|
|
|
{
|
|
|
location = lowLocationBill.a;
|
|
|
stock = lowLocationBill.b;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
WmsBaseLocation? wmsBaseLocation = AllWmsBaseLocations.Where(t => t.locRow == row)
|
|
|
.Where(t => t.locColumn == location.locColumn)
|
|
|
.Where(t => t.warehouseId == location.warehouseId).FirstOrDefault();
|
|
|
if (wmsBaseLocation != null && !string.IsNullOrEmpty(wmsBaseLocation.containerCode))
|
|
|
{
|
|
|
WmsBaseLocation? toLocation = AllWmsBaseLocations.Where(t => t.warehouseId == location.warehouseId)
|
|
|
.Where(t => t.locDeep == 1)
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.delFlag == "0")
|
|
|
.Where(t => t.locationScrapType == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.locationStatus == "1")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode)).FirstOrDefault();
|
|
|
toLocation ??= AllWmsBaseLocations.Where(t => t.warehouseId == location.warehouseId)
|
|
|
.Where(t => t.warehouseId != location.locationId)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode))
|
|
|
.FirstOrDefault();
|
|
|
if (toLocation != null)
|
|
|
{
|
|
|
var RemoveTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.productOutstockId,
|
|
|
taskType = 55,
|
|
|
containerNo = wmsBaseLocation.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now.AddSeconds(-10),
|
|
|
taskStatus = 0,
|
|
|
materialId = item.productId,
|
|
|
currPointId = wmsBaseLocation.locationId,
|
|
|
currPointNo = wmsBaseLocation.locationCode,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = toLocation.locationId,
|
|
|
endPointNo = toLocation.locationCode,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = qty
|
|
|
};
|
|
|
toLocation.locationStatus = "4";
|
|
|
toLocation.instockFlag = "1";
|
|
|
toLocation.updateBy = "WCS";
|
|
|
toLocation.updateTime = DateTime.Now;
|
|
|
wmsBaseLocation.updateBy = "WCS";
|
|
|
wmsBaseLocation.updateTime = DateTime.Now;
|
|
|
wmsBaseLocation.outstockFlag = "1";
|
|
|
wmsBaseLocation.locationStatus = "4";
|
|
|
dbContext.Update(toLocation);
|
|
|
dbContext.Update(wmsBaseLocation);
|
|
|
dbContext.Add(RemoveTask);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(RemoveTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
continue;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.productOutstockId,
|
|
|
taskType = 50,
|
|
|
containerNo = location.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
taskStatus = 0,
|
|
|
materialId = item.productId,
|
|
|
currPointId = location.locationId,
|
|
|
currPointNo = location.locationCode,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = endEquip.objid,
|
|
|
endPointNo = endEquip.equipNo,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = qty
|
|
|
};
|
|
|
location.outstockFlag = "1";
|
|
|
location.locationStatus = "6";
|
|
|
location.updateBy = "WCS";
|
|
|
location.updateTime = DateTime.Now;
|
|
|
dbContext.Add(detail);
|
|
|
dbContext.Update(location);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Update(stock);
|
|
|
WcsTaskLog wcsTaskLog1 = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog1);
|
|
|
dbContext.SaveChanges();
|
|
|
if (qty >= needNumber)
|
|
|
{
|
|
|
break;
|
|
|
}
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (item.beginTime == null)
|
|
|
{
|
|
|
item.beginTime = DateTime.Now;
|
|
|
}
|
|
|
dbContext.Update(item);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
Console.WriteLine(ex.Message + ex.StackTrace);
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(5000);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 原材料出库
|
|
|
/// </summary>
|
|
|
private void CreateRawTaskLogic()
|
|
|
{
|
|
|
using var scope = _host.Services.CreateScope();
|
|
|
using var dbContext = scope.ServiceProvider.GetRequiredService<DefaultDbContext>();
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
dbContext.ChangeTracker.Entries().ToList().ForEach(e => e.Reload());
|
|
|
//原材料库存
|
|
|
var rawStock = dbContext.WmsRawStock
|
|
|
.Where(t => t.activeFlag == "1").ToList();
|
|
|
//原材料出库记录
|
|
|
var rawOutStock = dbContext.WmsRawOutstock
|
|
|
.Where(t => t.executeStatus == "0" || t.executeStatus == "1")
|
|
|
.Where(t => t.outstockAmount > t.realOutstockAmount)
|
|
|
.Where(t => t.auditStatus == "1")
|
|
|
.ToList();
|
|
|
List<WcsTaskManual> wcsTaskManuals = dbContext.WcsTaskManual.Where(t => t.nextPointId == 11).OrderBy(t => t.createBy).ToList();
|
|
|
if (wcsTaskManuals.Count > 0)
|
|
|
{
|
|
|
WcsOutstockLock wcsOutstockLock = dbContext.WcsOutstockLock.Where(t => t.warehouseId == 512).First();
|
|
|
int taskCount = dbContext.WcsTask.Where(t => t.nextPointId == 11).Count();
|
|
|
if (taskCount == 0 && wcsOutstockLock.qty == 0 && wcsOutstockLock.boxStatus == 0)
|
|
|
{
|
|
|
foreach (var wcs in wcsTaskManuals.Take(6))
|
|
|
{
|
|
|
WcsTask wcsTask = CoreMapper.Map<WcsTask>(wcs);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(wcsTask);
|
|
|
wcsOutstockLock.qty += 1;
|
|
|
wcsOutstockLock.boxStatus = 1;
|
|
|
dbContext.Update(wcsOutstockLock);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
dbContext.WcsTaskManual.Where(t => t.objid == wcs.objid).Delete();
|
|
|
}
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
foreach (var item in rawOutStock)
|
|
|
{
|
|
|
decimal? RealOutNumber = item.realOutstockAmount;
|
|
|
var endEquip = StaticData.BaseEquip.FirstOrDefault(t => t.equipNo == item.endStationCode);
|
|
|
if (endEquip != null && endEquip.floorNo == 5)
|
|
|
{
|
|
|
lock (SystemData.outStockLock)
|
|
|
{
|
|
|
#region CTU出库，没用背负Agv的逻辑
|
|
|
//if (endEquip.equipType == 8)//CTU出库
|
|
|
//{
|
|
|
// var wcsOutstockLock = dbContext.WcsOutstockLock.Where(t => t.warehouseId == 512).First();
|
|
|
// if (wcsOutstockLock.qty == 0 && wcsOutstockLock.boxStatus == 0)
|
|
|
// {
|
|
|
// var wmsRawStocks = rawStock
|
|
|
// .Where(t => t.materialId == item.materialId)
|
|
|
// .Where(t => t.warehouseId == item.warehouseId)
|
|
|
// .Select(t => t.locationCode)
|
|
|
// .ToList();
|
|
|
|
|
|
// var wmsBaseLocations = dbContext.WmsBaseLocation
|
|
|
// .Where(t => t.activeFlag == "1")
|
|
|
// .Where(t => t.delFlag == "0")
|
|
|
// .Where(t => t.locationScrapType == "1")
|
|
|
// .Where(t => t.instockFlag == "0")
|
|
|
// .Where(t => t.outstockFlag == "0")
|
|
|
// .Where(t => t.ContainerStatus == "1")
|
|
|
// .Where(t => t.warehouseId == item.warehouseId)
|
|
|
// .Where(t => wmsRawStocks.Contains(t.locationCode))
|
|
|
// .ToList();
|
|
|
|
|
|
// decimal? needNumber = item.outstockAmount - RealOutNumber;
|
|
|
|
|
|
// var bill = from a in wmsBaseLocations
|
|
|
// from b in rawStock
|
|
|
// where a.locationCode == b.locationCode
|
|
|
// select new { a, b };
|
|
|
// //如果第一列满足需求,则按第一列排序,否则按最后一列排序
|
|
|
// if (bill.Where(t => t.a.locColumn == 1).Select(t => t.b.totalAmount - t.b.frozenAmount).Sum() > needNumber)
|
|
|
// {
|
|
|
// bill = bill.OrderBy(t => t.a.locColumn).ToList();
|
|
|
// }
|
|
|
// else
|
|
|
// {
|
|
|
// bill = bill.OrderByDescending(t => t.a.locColumn).ToList();
|
|
|
// }
|
|
|
// //做数量限制
|
|
|
|
|
|
// //bill = bill.Take(5 - dbContext.WcsCmd.Where(t => t.cmdStatus < 3 && t.nextPointId == 20).Count());
|
|
|
// bill = bill.Take(6);
|
|
|
// BaseEquip ctuEquip = StaticData.BaseEquip.First(t => t.objid == 11);
|
|
|
// BaseEquip lineEquip = StaticData.BaseEquip.First(t => t.objid == 20);
|
|
|
// foreach (var b in bill)
|
|
|
// {
|
|
|
// needNumber = item.outstockAmount - RealOutNumber;
|
|
|
// item.executeStatus = "1";
|
|
|
// WmsBaseLocation location = b.a;
|
|
|
// WmsRawStock stock = b.b;
|
|
|
// WcsTask wcsTask;
|
|
|
// int qty = 0;
|
|
|
// if (stock.totalAmount - stock.frozenAmount <= needNumber)//该料箱全部出
|
|
|
// {
|
|
|
// RealOutNumber += stock.totalAmount - stock.frozenAmount;
|
|
|
// qty = Convert.ToInt32(stock.totalAmount - stock.frozenAmount);
|
|
|
// stock.updateDate = DateTime.Now;
|
|
|
// }
|
|
|
// else
|
|
|
// {
|
|
|
// RealOutNumber += needNumber;
|
|
|
// qty = Convert.ToInt32(needNumber);
|
|
|
// stock.updateDate = DateTime.Now;
|
|
|
// }
|
|
|
// wcsTask = new WcsTask()
|
|
|
// {
|
|
|
// objid = StaticData.SnowId.NextId(),
|
|
|
// orderId = item.rawOutstockId,
|
|
|
// taskType = 38,
|
|
|
// containerNo = location.containerCode,
|
|
|
// createBy = "WCS",
|
|
|
// createTime = DateTime.Now,
|
|
|
// taskStatus = -1,
|
|
|
// materialId = item.materialId,
|
|
|
// currPointId = location.locationId,
|
|
|
// currPointNo = location.locationCode,
|
|
|
// nextPointId = ctuEquip.objid,
|
|
|
// nextPointNo = ctuEquip.equipNo,
|
|
|
// endPointId = lineEquip.objid,
|
|
|
// endPointNo = lineEquip.equipNo,
|
|
|
// equipmentNo = ctuEquip.equipNo,
|
|
|
// ud1 = location.locColumn,
|
|
|
// useFlag = 1,
|
|
|
// qty = qty
|
|
|
// };
|
|
|
// MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.Where(t => t.barcodeInfo == stock.instockBatch).FirstOrDefault();
|
|
|
// if (mesBaseBarcodeInfo != null)
|
|
|
// {
|
|
|
// WmsRawOutstockDetail wmsProductOutstockDetail = new WmsRawOutstockDetail()
|
|
|
// {
|
|
|
// rawOutstockDetailId = StaticData.SnowId.NextId(),
|
|
|
// rawOutstockId = item.rawOutstockId,
|
|
|
// materialId = item.materialId,
|
|
|
// createDate = DateTime.Now,
|
|
|
// createBy = "WCS",
|
|
|
// taskCode = wcsTask.objid.ToString(),
|
|
|
// executeStatus = "1",
|
|
|
// locationCode = location.locationCode,
|
|
|
// outstockAmount = qty,
|
|
|
// planAmount = item.outstockAmount,
|
|
|
// warehouseId = item.warehouseId,
|
|
|
// materialBarcode = mesBaseBarcodeInfo.barcodeInfo,
|
|
|
// instockBatch = mesBaseBarcodeInfo.batchCode,
|
|
|
// stackAmount = qty,
|
|
|
// outstockPerson = "WCS",
|
|
|
// outstockTime = DateTime.Now,
|
|
|
// outstockWay = "2",
|
|
|
// materialProductionDate = mesBaseBarcodeInfo.productionDate
|
|
|
// };
|
|
|
// location.outstockFlag = "1";
|
|
|
// location.locationStatus = "6";
|
|
|
// location.updateBy = "WCS";
|
|
|
// location.updateTime = DateTime.Now;
|
|
|
// wcsOutstockLock.boxStatus = 1;
|
|
|
// dbContext.Add(wmsProductOutstockDetail);
|
|
|
// dbContext.Update(location);
|
|
|
// dbContext.Add(wcsTask);
|
|
|
// dbContext.Update(stock);
|
|
|
// if (qty >= needNumber)
|
|
|
// {
|
|
|
// break;
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
// if (item.beginTime == null)
|
|
|
// {
|
|
|
// item.beginTime = DateTime.Now;
|
|
|
// }
|
|
|
// dbContext.Update(wcsOutstockLock);
|
|
|
// dbContext.Update(item);
|
|
|
// dbContext.SaveChanges();
|
|
|
// }
|
|
|
//}//CTU出库
|
|
|
#endregion
|
|
|
if (endEquip.equipType == 10)//CTU出库到装配区
|
|
|
{
|
|
|
BaseEquip endStationCodeEquip = dbContext.BaseEquip.First(t => t.objid == 10);
|
|
|
if (!string.IsNullOrEmpty(endStationCodeEquip.endStationCode))
|
|
|
{
|
|
|
bool CreateSuccess = false;
|
|
|
var wcsOutstockLock = dbContext.WcsOutstockLock
|
|
|
.Where(t => t.warehouseId == 512)
|
|
|
.First();
|
|
|
if (wcsOutstockLock.qty == 0 && wcsOutstockLock.boxStatus == 0)
|
|
|
{
|
|
|
var orderList = rawOutStock.Where(t => t.endStationCode == endStationCodeEquip.endStationCode).ToList();
|
|
|
List<WcsTask> tasks = new();
|
|
|
List<long?> canOut = orderList.Select(t => t.saleOrderId).ToList();
|
|
|
rawStock = rawStock.Where(t => canOut.Contains(t.saleOrderId)).OrderByDescending(t => t.saleOrderId).ToList();
|
|
|
//对物料和数量进行分组
|
|
|
var list = orderList.GroupBy(t => t.materialId).Select(t => new
|
|
|
{
|
|
|
MaterialId = t.Key,
|
|
|
TotalAmount = t.Sum(x => x.outstockAmount),
|
|
|
realOutstockAmount = t.Sum(x => x.realOutstockAmount)
|
|
|
}
|
|
|
).ToList();
|
|
|
foreach (var order in list)
|
|
|
{
|
|
|
if (tasks.Count >= 6)
|
|
|
{
|
|
|
break;
|
|
|
}
|
|
|
var wmsRawStocks = rawStock
|
|
|
.Where(t => t.materialId == order.MaterialId && t.warehouseId == 512)
|
|
|
.Select(t => t.palletInfoCode)
|
|
|
.ToList();
|
|
|
var AllWmsBaseLocations = dbContext.WmsBaseLocation.Where(t => t.warehouseId == 512).ToList();
|
|
|
var wmsBaseLocations = AllWmsBaseLocations
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.delFlag == "0")
|
|
|
.Where(t => t.locationScrapType == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => t.locationStatus == "1")
|
|
|
.Where(t => t.warehouseId == 512)
|
|
|
.Where(t => wmsRawStocks.Contains(t.containerCode))
|
|
|
.ToList();
|
|
|
decimal? needNumber = order.TotalAmount - order.realOutstockAmount;
|
|
|
|
|
|
var bill = from a in wmsBaseLocations
|
|
|
from b in rawStock
|
|
|
where a.containerCode == b.palletInfoCode
|
|
|
select new { a, b };
|
|
|
//如果第一列满足需求,则按第一列排序,否则按最后一列排序
|
|
|
if (bill.Where(t => t.a.locColumn == 1).Select(t => t.b.totalAmount - t.b.frozenAmount).Sum() >= needNumber)
|
|
|
{
|
|
|
bill = bill.OrderBy(t => t.a.locColumn).ToList();
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
bill = bill.OrderByDescending(t => t.a.locColumn).ToList();
|
|
|
}
|
|
|
BaseEquip ctuEquip = StaticData.BaseEquip.First(t => t.objid == 11);
|
|
|
BaseEquip lineEquip = StaticData.BaseEquip.First(t => t.objid == 20);
|
|
|
foreach (var b in bill)
|
|
|
{
|
|
|
if (tasks.Where(t => t.containerNo == b.a.containerCode).Any() || tasks.Count >= 6)
|
|
|
{
|
|
|
continue;
|
|
|
}
|
|
|
WmsBaseLocation location = b.a;
|
|
|
WmsRawStock stock = b.b;
|
|
|
int qty = 0;
|
|
|
if (stock.totalAmount - stock.frozenAmount <= needNumber)//该料箱全部出
|
|
|
{
|
|
|
RealOutNumber += stock.totalAmount - stock.frozenAmount;
|
|
|
qty = Convert.ToInt32(stock.totalAmount - stock.frozenAmount);
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
RealOutNumber += needNumber;
|
|
|
qty = Convert.ToInt32(needNumber);
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
}
|
|
|
WmsRawOutstock? wmsRawOutstock = orderList.Where(t => t.materialId == order.MaterialId).FirstOrDefault();
|
|
|
if (wmsRawOutstock != null)
|
|
|
{
|
|
|
WcsTask wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = wmsRawOutstock.rawOutstockId,
|
|
|
taskType = 30,
|
|
|
containerNo = location.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
taskStatus = 0,
|
|
|
materialId = wmsRawOutstock.materialId,
|
|
|
currPointId = location.locationId,
|
|
|
currPointNo = location.locationCode,
|
|
|
nextPointId = ctuEquip.objid,
|
|
|
nextPointNo = ctuEquip.equipNo,
|
|
|
endPointId = lineEquip.objid,
|
|
|
endPointNo = lineEquip.equipNo,
|
|
|
equipmentNo = ctuEquip.equipNo,
|
|
|
ud1 = location.locColumn,
|
|
|
useFlag = 1,
|
|
|
qty = qty
|
|
|
};
|
|
|
tasks.Add(wcsTask);
|
|
|
location.outstockFlag = "1";
|
|
|
location.locationStatus = "6";
|
|
|
location.updateBy = "WCS";
|
|
|
location.ContainerStatus = "2";
|
|
|
location.updateTime = DateTime.Now;
|
|
|
wcsOutstockLock.qty += 1;
|
|
|
wcsOutstockLock.boxStatus = 1;
|
|
|
dbContext.Update(location);
|
|
|
dbContext.Update(stock);
|
|
|
CreateSuccess = true;
|
|
|
if (tasks.Count >= 6)
|
|
|
{
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#region 原逻辑
|
|
|
//foreach (var order in orderList)
|
|
|
//{
|
|
|
// if(tasks.Count >= 6)
|
|
|
// {
|
|
|
// break;
|
|
|
// }
|
|
|
// WcsTask? task = dbContext.WcsTask.FirstOrDefault(t => t.taskType == 32);
|
|
|
// if (task == null)
|
|
|
// {
|
|
|
// var wmsRawStocks = rawStock
|
|
|
// .Where(t => t.materialId == order.materialId && t.warehouseId == order.warehouseId)
|
|
|
// .Select(t => t.palletInfoCode)
|
|
|
// .ToList();
|
|
|
|
|
|
// var wmsBaseLocations = dbContext.WmsBaseLocation
|
|
|
// .Where(t => t.activeFlag == "1")
|
|
|
// .Where(t => t.delFlag == "0")
|
|
|
// .Where(t => t.locationScrapType == "1")
|
|
|
// .Where(t => t.instockFlag == "0")
|
|
|
// .Where(t => t.outstockFlag == "0")
|
|
|
// .Where(t => t.warehouseId == order.warehouseId)
|
|
|
// .Where(t => wmsRawStocks.Contains(t.containerCode))
|
|
|
// .ToList();
|
|
|
|
|
|
// decimal? needNumber = order.outstockAmount - RealOutNumber;
|
|
|
|
|
|
// var bill = from a in wmsBaseLocations
|
|
|
// from b in rawStock
|
|
|
// where a.containerCode == b.palletInfoCode
|
|
|
// select new { a, b };
|
|
|
// //如果第一列满足需求,则按第一列排序,否则按最后一列排序
|
|
|
// if (bill.Where(t => t.a.locColumn == 1).Select(t => t.b.totalAmount - t.b.frozenAmount).Sum() > needNumber)
|
|
|
// {
|
|
|
// bill = bill.OrderBy(t => t.a.locColumn).ToList();
|
|
|
// }
|
|
|
// else
|
|
|
// {
|
|
|
// bill = bill.OrderByDescending(t => t.a.locColumn).ToList();
|
|
|
// }
|
|
|
// //做数量限制
|
|
|
// bill = bill.Take(5 - dbContext.WcsCmd.Where(t => t.cmdStatus < 3 && t.nextPointId == 20).Count());
|
|
|
// BaseEquip ctuEquip = StaticData.BaseEquip.First(t => t.objid == 11);
|
|
|
// BaseEquip lineEquip = StaticData.BaseEquip.First(t => t.objid == 20);
|
|
|
// foreach (var b in bill)
|
|
|
// {
|
|
|
// if (tasks.Where(t => t.containerNo == b.a.containerCode).Any())
|
|
|
// {
|
|
|
// continue;
|
|
|
// }
|
|
|
// item.executeStatus = "1";
|
|
|
// WmsBaseLocation location = b.a;
|
|
|
// WmsRawStock stock = b.b;
|
|
|
// int qty = 0;
|
|
|
// if (stock.totalAmount - stock.frozenAmount <= needNumber)//该料箱全部出
|
|
|
// {
|
|
|
// RealOutNumber += stock.totalAmount - stock.frozenAmount;
|
|
|
// qty = Convert.ToInt32(stock.totalAmount - stock.frozenAmount);
|
|
|
// stock.updateDate = DateTime.Now;
|
|
|
// }
|
|
|
// else
|
|
|
// {
|
|
|
// RealOutNumber += needNumber;
|
|
|
// qty = Convert.ToInt32(needNumber);
|
|
|
// stock.updateDate = DateTime.Now;
|
|
|
// }
|
|
|
// WcsTask wcsTask = new WcsTask()
|
|
|
// {
|
|
|
// objid = StaticData.SnowId.NextId(),
|
|
|
// orderId = item.rawOutstockId,
|
|
|
// taskType = 30,
|
|
|
// containerNo = location.containerCode,
|
|
|
// createBy = "WCS",
|
|
|
// createTime = DateTime.Now,
|
|
|
// taskStatus = 0,
|
|
|
// materialId = item.materialId,
|
|
|
// currPointId = location.locationId,
|
|
|
// currPointNo = location.locationCode,
|
|
|
// nextPointId = ctuEquip.objid,
|
|
|
// nextPointNo = ctuEquip.equipNo,
|
|
|
// endPointId = lineEquip.objid,
|
|
|
// endPointNo = lineEquip.equipNo,
|
|
|
// equipmentNo = ctuEquip.equipNo,
|
|
|
// ud1 = location.locColumn,
|
|
|
// useFlag = 0,
|
|
|
// qty = qty
|
|
|
// };
|
|
|
// tasks.Add(wcsTask);
|
|
|
// MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.Where(t => t.barcodeInfo == stock.instockBatch).FirstOrDefault();
|
|
|
// if (mesBaseBarcodeInfo != null)
|
|
|
// {
|
|
|
// WmsRawOutstockDetail wmsProductOutstockDetail = new WmsRawOutstockDetail()
|
|
|
// {
|
|
|
// rawOutstockDetailId = StaticData.SnowId.NextId(),
|
|
|
// rawOutstockId = item.rawOutstockId,
|
|
|
// materialId = item.materialId,
|
|
|
// createDate = DateTime.Now,
|
|
|
// createBy = "WCS",
|
|
|
// taskCode = wcsTask.objid.ToString(),
|
|
|
// executeStatus = "1",
|
|
|
// locationCode = location.locationCode,
|
|
|
// outstockAmount = qty,
|
|
|
// planAmount = item.outstockAmount,
|
|
|
// warehouseId = item.warehouseId,
|
|
|
// materialBarcode = mesBaseBarcodeInfo.barcodeInfo,
|
|
|
// instockBatch = mesBaseBarcodeInfo.batchCode,
|
|
|
// stackAmount = qty,
|
|
|
// outstockPerson = "WCS",
|
|
|
// outstockTime = DateTime.Now,
|
|
|
// outstockWay = "2",
|
|
|
// materialProductionDate = mesBaseBarcodeInfo.productionDate
|
|
|
// };
|
|
|
// details.Add(wmsProductOutstockDetail);
|
|
|
// location.outstockFlag = "1";
|
|
|
// location.locationStatus = "6";
|
|
|
// location.updateBy = "WCS";
|
|
|
// location.updateTime = DateTime.Now;
|
|
|
// wcsOutstockLock.qty += 1;
|
|
|
// wcsOutstockLock.boxStatus = 1;
|
|
|
// dbContext.Update(wcsOutstockLock);
|
|
|
// dbContext.Update(location);
|
|
|
// dbContext.Add(wcsTask);
|
|
|
// dbContext.Update(stock);
|
|
|
// CreateSuccess = true;
|
|
|
// if (tasks.Count >= 6)
|
|
|
// {
|
|
|
// break;
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
//}
|
|
|
#endregion
|
|
|
|
|
|
}
|
|
|
if (CreateSuccess)
|
|
|
{
|
|
|
foreach (var orderItem in orderList)
|
|
|
{
|
|
|
if (orderItem.beginTime == null)
|
|
|
{
|
|
|
orderItem.beginTime = DateTime.Now;
|
|
|
}
|
|
|
orderItem.executeStatus = "1";
|
|
|
}
|
|
|
BaseEquip startStationEquip = StaticData.BaseEquip.First(t => t.objid == 21);
|
|
|
BaseEquip bearAgvEquip = StaticData.BaseEquip.First(t => t.objid == 10);
|
|
|
BaseEquip endStationEquip = StaticData.BaseEquip.First(t => t.equipNo == item.endStationCode);
|
|
|
bool hasTask = dbContext.WcsTask.Where(t => t.taskType == 32).Any();
|
|
|
if (!hasTask)
|
|
|
{
|
|
|
WcsTask bearAgvTask = new()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.rawOutstockId,
|
|
|
taskType = 32,
|
|
|
containerNo = null,
|
|
|
currPointId = startStationEquip.objid,
|
|
|
currPointNo = startStationEquip.equipNo,
|
|
|
nextPointId = bearAgvEquip.objid,
|
|
|
nextPointNo = bearAgvEquip.equipNo,
|
|
|
endPointId = endStationEquip.objid,
|
|
|
endPointNo = endStationEquip.equipNo,
|
|
|
serialNo = SystemData.GetSerialNo(dbContext),
|
|
|
taskStatus = 0,
|
|
|
createTime = DateTime.Now,
|
|
|
createBy = "WCS",
|
|
|
materialId = item.materialId,
|
|
|
qty = 1,
|
|
|
useFlag = 1,
|
|
|
equipmentNo = startStationEquip.equipNo,
|
|
|
remark = "组装出库",
|
|
|
floorNo = 5,
|
|
|
masterId = item.materialId,
|
|
|
fromFloorNo = 5,
|
|
|
};
|
|
|
dbContext.Add(bearAgvTask);
|
|
|
}
|
|
|
|
|
|
if (item.beginTime == null)
|
|
|
{
|
|
|
item.beginTime = DateTime.Now;
|
|
|
}
|
|
|
dbContext.UpdateRange(orderList);
|
|
|
dbContext.Update(item);
|
|
|
}
|
|
|
endStationCodeEquip.endStationCode = null;
|
|
|
dbContext.Update(endStationCodeEquip);
|
|
|
if (tasks.Count > 0)
|
|
|
{
|
|
|
dbContext.AddRange(tasks);
|
|
|
dbContext.Update(wcsOutstockLock);
|
|
|
}
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
if (endEquip.equipType == 12 || endEquip.equipType == 13)//原材料到柜体验收区
|
|
|
{
|
|
|
bool hasTask = dbContext.WcsTask.Where(t => t.nextPointId == 28 && t.useFlag == 1 && t.taskStatus <= 5).Any();
|
|
|
if (!hasTask)
|
|
|
{
|
|
|
if (endEquip.emptyCount == 0)
|
|
|
{
|
|
|
var wmsRawStocks = rawStock
|
|
|
.Where(t => t.materialId == item.materialId && t.warehouseId == item.warehouseId)
|
|
|
.WhereIf(endEquip.equipType == 13, t => t.completeFlag == "0")
|
|
|
.WhereIf(endEquip.equipType == 12, t => t.completeFlag == "1")
|
|
|
.Where(t => t.saleOrderId == item.saleOrderId)
|
|
|
.Where(t => t.totalAmount > t.frozenAmount)
|
|
|
.Select(t => t.palletInfoCode)
|
|
|
.ToList();
|
|
|
List<WmsBaseLocation> AllWmsBaseLocations = dbContext.WmsBaseLocation.Where(t => t.warehouseId == item.warehouseId).ToList();
|
|
|
var wmsBaseLocations = AllWmsBaseLocations
|
|
|
.Where(t => t.activeFlag == "1")
|
|
|
.Where(t => t.delFlag == "0")
|
|
|
.Where(t => t.locationScrapType == "1")
|
|
|
.Where(t => t.instockFlag == "0")
|
|
|
.Where(t => t.outstockFlag == "0")
|
|
|
.Where(t => t.locationStatus == "1")
|
|
|
.Where(t => t.warehouseId == item.warehouseId)
|
|
|
.Where(t => wmsRawStocks.Contains(t.containerCode))
|
|
|
.ToList();
|
|
|
|
|
|
decimal? needNumber = item.outstockAmount - item.realOutstockAmount;
|
|
|
if (needNumber <= 0)
|
|
|
{
|
|
|
item.executeStatus = "2";
|
|
|
dbContext.Update(item);
|
|
|
dbContext.SaveChanges();
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
var bill = from a in wmsBaseLocations
|
|
|
from b in rawStock
|
|
|
where a.containerCode == b.palletInfoCode
|
|
|
select new { a, b };
|
|
|
|
|
|
|
|
|
BaseEquip agvEquip = StaticData.BaseEquip.First(t => t.objid == 28);
|
|
|
BaseEquip lineEquip = StaticData.BaseEquip.First(t => t.equipNo == item.endStationCode);
|
|
|
foreach (var b in bill)
|
|
|
{
|
|
|
item.executeStatus = "1";
|
|
|
WmsBaseLocation location = b.a;
|
|
|
WmsRawStock stock = b.b;
|
|
|
WcsTask wcsTask;
|
|
|
int qty = 0;
|
|
|
if (stock.totalAmount - stock.frozenAmount <= needNumber)//该料箱全部出
|
|
|
{
|
|
|
item.realOutstockAmount += stock.totalAmount - stock.frozenAmount;
|
|
|
qty = Convert.ToInt32(stock.totalAmount - stock.frozenAmount);
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
item.realOutstockAmount += needNumber;
|
|
|
qty = Convert.ToInt32(needNumber);
|
|
|
stock.updateDate = DateTime.Now;
|
|
|
}
|
|
|
MesBaseBarcodeInfo? mesBaseBarcodeInfo = dbContext.MesBaseBarcodeInfo.Where(t => t.barcodeInfo == stock.instockBatch).FirstOrDefault();
|
|
|
if (mesBaseBarcodeInfo != null)
|
|
|
{
|
|
|
if (location.locDeep == 1)
|
|
|
{
|
|
|
int? row = 0;
|
|
|
if (location.locRow % 2 == 1)//五楼原材料与其他的深浅库位相反
|
|
|
{
|
|
|
row = location.locRow - 1;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
row = location.locRow + 1;
|
|
|
}
|
|
|
var lowLocationBill = bill.Where(t => t.a.locRow == row).Where(t => t.a.locColumn == location.locColumn).Where(t => t.a.warehouseId == location.warehouseId).FirstOrDefault();
|
|
|
if (lowLocationBill != null)
|
|
|
{
|
|
|
location = lowLocationBill.a;
|
|
|
stock = lowLocationBill.b;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
WmsBaseLocation? wmsBaseLocation = AllWmsBaseLocations.Where(t => t.locRow == row)
|
|
|
.Where(t => t.locColumn == location.locColumn)
|
|
|
.Where(t => t.warehouseId == location.warehouseId).FirstOrDefault();
|
|
|
if (wmsBaseLocation != null && !string.IsNullOrEmpty(wmsBaseLocation.containerCode))
|
|
|
{
|
|
|
WmsBaseLocation? toLocation = AllWmsBaseLocations.Where(t => t.warehouseId == location.warehouseId)
|
|
|
.Where(t => t.locDeep == 1)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode)).FirstOrDefault();
|
|
|
toLocation ??= AllWmsBaseLocations.Where(t => t.warehouseId == location.warehouseId)
|
|
|
.Where(t => t.warehouseId != location.locationId)
|
|
|
.Where(t => string.IsNullOrEmpty(t.containerCode))
|
|
|
.FirstOrDefault();
|
|
|
if (toLocation != null)
|
|
|
{
|
|
|
var RemoveTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.rawOutstockId,
|
|
|
taskType = 38,
|
|
|
containerNo = wmsBaseLocation.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now.AddSeconds(-10),
|
|
|
taskStatus = 0,
|
|
|
materialId = item.materialId,
|
|
|
currPointId = wmsBaseLocation.locationId,
|
|
|
currPointNo = wmsBaseLocation.locationCode,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = toLocation.locationId,
|
|
|
endPointNo = toLocation.locationCode,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = qty
|
|
|
};
|
|
|
toLocation.locationStatus = "4";
|
|
|
toLocation.instockFlag = "1";
|
|
|
toLocation.updateBy = "WCS";
|
|
|
toLocation.updateTime = DateTime.Now;
|
|
|
wmsBaseLocation.updateBy = "WCS";
|
|
|
wmsBaseLocation.updateTime = DateTime.Now;
|
|
|
wmsBaseLocation.outstockFlag = "1";
|
|
|
wmsBaseLocation.locationStatus = "4";
|
|
|
dbContext.Update(toLocation);
|
|
|
dbContext.Update(wmsBaseLocation);
|
|
|
dbContext.Add(RemoveTask);
|
|
|
WcsTaskLog wcsTaskLog = CoreMapper.Map<WcsTaskLog>(RemoveTask);
|
|
|
dbContext.Add(wcsTaskLog);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
continue;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
wcsTask = new WcsTask()
|
|
|
{
|
|
|
objid = StaticData.SnowId.NextId(),
|
|
|
orderId = item.rawOutstockId,
|
|
|
taskType = endEquip.equipType == 12 ? 46 : 33,//如果是12那么就是原材料到柜体验收区,如果是13那么就是原材料到背板安装区
|
|
|
containerNo = location.containerCode,
|
|
|
createBy = "WCS",
|
|
|
createTime = DateTime.Now,
|
|
|
taskStatus = 0,
|
|
|
materialId = item.materialId,
|
|
|
currPointId = location.locationId,
|
|
|
currPointNo = location.locationCode,
|
|
|
nextPointId = agvEquip.objid,
|
|
|
nextPointNo = agvEquip.equipNo,
|
|
|
endPointId = lineEquip.objid,
|
|
|
endPointNo = lineEquip.equipNo,
|
|
|
equipmentNo = agvEquip.equipNo,
|
|
|
useFlag = 1,
|
|
|
qty = qty
|
|
|
};
|
|
|
WmsRawOutstockDetail wmsProductOutstockDetail = new WmsRawOutstockDetail()
|
|
|
{
|
|
|
rawOutstockDetailId = StaticData.SnowId.NextId(),
|
|
|
rawOutstockId = item.rawOutstockId,
|
|
|
materialId = item.materialId,
|
|
|
createDate = DateTime.Now,
|
|
|
createBy = "WCS",
|
|
|
taskCode = wcsTask.objid.ToString(),
|
|
|
executeStatus = "1",
|
|
|
locationCode = location.locationCode,
|
|
|
outstockAmount = qty,
|
|
|
planAmount = item.outstockAmount,
|
|
|
warehouseId = item.warehouseId,
|
|
|
materialBarcode = mesBaseBarcodeInfo.barcodeInfo,
|
|
|
instockBatch = mesBaseBarcodeInfo.batchCode,
|
|
|
stackAmount = qty,
|
|
|
outstockPerson = "WCS",
|
|
|
outstockTime = DateTime.Now,
|
|
|
outstockWay = "2",
|
|
|
materialProductionDate = mesBaseBarcodeInfo.productionDate
|
|
|
};
|
|
|
dbContext.Add(wmsProductOutstockDetail);
|
|
|
location.outstockFlag = "1";
|
|
|
location.locationStatus = "6";
|
|
|
location.updateBy = "WCS";
|
|
|
location.updateTime = DateTime.Now;
|
|
|
endEquip.emptyCount = 1;
|
|
|
dbContext.Update(endEquip);
|
|
|
dbContext.Update(location);
|
|
|
dbContext.Add(wcsTask);
|
|
|
dbContext.Update(stock);
|
|
|
dbContext.SaveChanges();
|
|
|
}
|
|
|
if (item.beginTime == null)
|
|
|
{
|
|
|
item.beginTime = DateTime.Now;
|
|
|
}
|
|
|
dbContext.Update(item);
|
|
|
dbContext.SaveChanges();
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogManager.Error(ex);
|
|
|
}
|
|
|
Thread.Sleep(1000);
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
}
|