From dfb67ae65d678da26d0fa880efa185591d6ff970 Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期五, 28 十一月 2025 14:46:31 +0800
Subject: [PATCH] """ 支持任务状态分组及路径与配置更新
---
项目代码/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs | 701 ++++++++++++++++++++++++++++++++--------------------------
1 files changed, 386 insertions(+), 315 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
index 93056e6..e9f8f4b 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs"
@@ -105,8 +105,12 @@
WebResponseContent content = new WebResponseContent();
try
{
- var locationStart = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.SourceAddress);
- var locationEnd = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
+ if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.CarryGroup)
+ {
+ var result1 = UpdateLocationStatus(task.SourceAddress, LocationEnum.Free, task.TaskNum.Value, StatusChangeTypeEnum.AutomaticOutbound);
+ await _locationStatusChangeRecordRepository.AddDataAsync(result1.Item1);
+ await _locationRepository.UpdateDataAsync(result1.Item2);
+ }
task.TaskState = (int)TaskOutStatusEnum.OutFinish;
var taskHty = task.Adapt<Dt_Task_Hty>();
@@ -115,16 +119,16 @@
taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
stock.ModifyDate = DateTime.Now;
stock.LocationCode = task.TargetAddress;
- var result1 = UpdateLocationStatus(locationStart, LocationEnum.Free, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
- var result2 = UpdateLocationStatus(locationEnd, LocationEnum.InStock, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ var result2 = UpdateLocationStatus(task.TargetAddress, LocationEnum.InStock, task.TaskNum.Value, StatusChangeTypeEnum.AutomaticOutbound);
+
DtStockInfo_Hty stockInfo_Hty = stock.Adapt<DtStockInfo_Hty>();
var orderDetails = _orderOutDetailsRepository.QueryData(x => x.PalletCode == task.PalletCode);
List<Dt_OrderOutDetails_Hty> orderdetailshtys = new List<Dt_OrderOutDetails_Hty>();
orderDetails.ForEach(item =>
- {
- orderdetailshtys.Add(item.Adapt<Dt_OrderOutDetails_Hty>());
- });
+ {
+ orderdetailshtys.Add(item.Adapt<Dt_OrderOutDetails_Hty>());
+ });
await ERPAllocateOut(stock);
@@ -176,27 +180,28 @@
boxingInfo.BoxingInfoDetails = mergedDetails;
}
- await _unitOfWorkManage.UseTranAsync(async () =>
- {
+ //await _unitOfWorkManage.UseTranAsync(async () =>
+ //{
+ _unitOfWorkManage.BeginTran();
await DeleteStockInfoAsync(stock.Id);
_boxingInfoRepository.UpdateDataNav(boxingInfo);
await DeleteStockInfoDetailsAsync(stock.StockInfoDetails);
await AddStockInfoHtyAsync(stockInfo_Hty);
- await _locationStatusChangeRecordRepository.AddDataAsync(result1.Item1);
await _locationStatusChangeRecordRepository.AddDataAsync(result2.Item1);
- await _locationRepository.UpdateDataAsync(result1.Item2);
await _locationRepository.UpdateDataAsync(result2.Item2);
await _orderOutDetailsRepository.DeleteDataAsync(orderDetails);
await SqlSugarHelper.DbWMS.Insertable(orderdetailshtys).ExecuteCommandAsync();
await DeleteTaskAsync(task.TaskId);
await AddTaskHtyAsync(taskHty);
- });
+ _unitOfWorkManage.CommitTran();
+ //});
content.OK("鍑哄簱瀹屾垚");
}
catch (Exception ex)
{
+ _unitOfWorkManage.RollbackTran();
task.ErrorMessage = ex.Message;
await BaseDal.UpdateDataAsync(task);
return content.Error(ex.Message);
@@ -227,14 +232,21 @@
taskHty.OperateType = App.User.UserName != null ? (int)OperateTypeEnum.浜哄伐瀹屾垚 : (int)OperateTypeEnum.鑷姩瀹屾垚;
taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
- stock.ModifyDate = DateTime.Now;
- stock.LocationCode = task.TargetAddress;
- var result = UpdateLocationStatus(locationEnd, LocationEnum.InStock, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticRelocation);
+ if (stock != null)
+ {
+ stock.ModifyDate = DateTime.Now;
+ stock.LocationCode = task.TargetAddress;
+ }
+ var result1 = UpdateLocationStatus(locationStart.LocationCode, LocationEnum.Free, task.TaskNum.Value, StatusChangeTypeEnum.AutomaticRelocation);
+ var result2 = UpdateLocationStatus(locationEnd.LocationCode, LocationEnum.InStock, task.TaskNum.Value, StatusChangeTypeEnum.AutomaticRelocation);
await _unitOfWorkManage.UseTranAsync(async () =>
{
- await _locationStatusChangeRecordRepository.AddDataAsync(result.Item1);
- await _locationRepository.UpdateDataAsync(result.Item2);
- _stockInfoRepository.UpdateData(stock);
+ await _locationStatusChangeRecordRepository.AddDataAsync(result1.Item1);
+ await _locationRepository.UpdateDataAsync(result1.Item2);
+ await _locationStatusChangeRecordRepository.AddDataAsync(result2.Item1);
+ await _locationRepository.UpdateDataAsync(result2.Item2);
+ if (stock != null)
+ _stockInfoRepository.UpdateData(stock);
await DeleteTaskAsync(task.TaskId);
await AddTaskHtyAsync(taskHty);
});
@@ -262,14 +274,20 @@
try
{
var boxinfo = await _boxingInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
- var locationStart = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.SourceAddress);
- var locationEnd = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
if (boxinfo == null)
{
return content.Error("鏈壘鍒扮粍鐩樻暟鎹�");
}
- await ERPAllocate(boxinfo);
+
+ if (task.TaskState.GetTaskStateGroup() == TaskStateGroup.CarryGroup)
+ {
+ var result1 = UpdateLocationStatus(task.SourceAddress, LocationEnum.Free, task.TaskNum.Value, StatusChangeTypeEnum.AutomaticInbound);
+ await _locationStatusChangeRecordRepository.AddDataAsync(result1.Item1);
+ await _locationRepository.UpdateDataAsync(result1.Item2);
+ }
+
+
var stock = CreateStock(boxinfo, task);
@@ -279,23 +297,24 @@
taskHty.OperateType = App.User.UserName != null ? (int)OperateTypeEnum.浜哄伐瀹屾垚 : (int)OperateTypeEnum.鑷姩瀹屾垚;
taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
- var result1 = UpdateLocationStatus(task.SourceAddress, LocationEnum.Free, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
- var result2 = UpdateLocationStatus(task.TargetAddress, LocationEnum.InStock, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+ var result2 = UpdateLocationStatus(task.TargetAddress, LocationEnum.InStock, task.TaskNum.Value, StatusChangeTypeEnum.AutomaticInbound);
- await _unitOfWorkManage.UseTranAsync(async () =>
- {
- await _stockInfoRepository.AddDataNavAsync(stock);
+ //await _unitOfWorkManage.UseTranAsync(async () =>
+ //{
+ _unitOfWorkManage.BeginTran();
+ await _stockInfoRepository.AddDataNavAsync(stock);
await DeleteTaskAsync(task.TaskId);
await AddTaskHtyAsync(taskHty);
await _locationStatusChangeRecordRepository.AddDataAsync(result2.Item1);
- await _locationStatusChangeRecordRepository.AddDataAsync(result1.Item1);
await _locationRepository.UpdateDataAsync(result2.Item2);
- await _locationRepository.UpdateDataAsync(result1.Item2);
- });
+ _unitOfWorkManage.CommitTran();
+ //});
+ await ERPAllocate(boxinfo);
content.OK("鍏ュ簱瀹屾垚");
}
catch (Exception ex)
{
+ _unitOfWorkManage.RollbackTran();
task.ErrorMessage = ex.Message;
await BaseDal.UpdateDataAsync(task);
return content.Error(ex.Message);
@@ -505,7 +524,7 @@
foreach (var item in boxingInfo.BoxingInfoDetails)
{
- var ERPStock = SqlSugarHelper.DBERPtext.Queryable<鐢ㄥ弸鍗虫椂搴撳瓨_ST>().Where(x => x.瀛樺偍鍦扮偣鍚嶇О == item.Warehouse && x.鏂欏彿 == item.MaterielCode && x.鍝佸悕 == item.MaterielName && x.搴撳瓨鏁伴噺 >= item.Quantity).ToList().FirstOrDefault();
+ var ERPStock = SqlSugarHelper.DBERP.Queryable<鐢ㄥ弸鍗虫椂搴撳瓨_ST>().Where(x => x.瀛樺偍鍦扮偣鍚嶇О == item.Warehouse && x.鏂欏彿 == item.MaterielCode && x.鍝佸悕 == item.MaterielName && x.搴撳瓨鏁伴噺 >= item.Quantity).ToList().FirstOrDefault();
if (ERPStock == null)
{
return content.Error($"缁勭洏鏁版嵁鏈湪ERP搴撳瓨鏁版嵁涓紝璇蜂汉宸ョ‘璁ゆ暟鎹槸鍚︽纭�");
@@ -522,72 +541,47 @@
return content.Error($"璧风偣搴撲綅{StartAddress.LocationCode}鎼繍璺緞琚崰鐢紝璇蜂汉宸ョ‘璁ゅ啀涓嬪彂浠诲姟");
}
Dt_Task taskNew = new Dt_Task();
- DtLocationInfo Endlocation= new DtLocationInfo();
- if (taskDto.AreaId != 0)
+ var area = _areaInfoRepository.QueryFirst(x => x.AreaID == taskDto.AreaId);
+ if (area == null)
{
- switch (taskDto.AreaId)
- {
- case 1:
- Endlocation = await GetEmptyLocation("SC1");
- taskNew = InboundStakerArea(taskDto, StartAddress, Endlocation);
- break;
- case 2:
- case 3:
- case 4:
- case 5:
- case 6:
- Endlocation = await GetAGVEmptyCacheLocation(taskDto.AreaId, StartAddress);
- taskNew = InboundAGVCacheArea(taskDto, StartAddress, Endlocation);
- break;
- default:
- return content.Error("璇烽�夋嫨姝ｇ‘鐨勫尯鍩熶俊鎭�");
- }
+ return content.Error("璇烽�夋嫨鍏ュ簱鍖哄煙");
}
- else if (taskDto.TargetAddress != null)
+
+ var locationInfo = await _locationRepository.QueryDataAsync(x => x.AreaId == area.AreaID && x.EnalbeStatus == 1 && x.LocationStatus == (int)LocationEnum.Free);
+
+ var taskArea = BaseDal.QueryData(x => x.TargetAddress == area.AreaName && x.TaskType == (int)TaskInboundTypeEnum.Inbound);
+
+ if (locationInfo.Count - taskArea.Count <= 0)
{
- Endlocation = _locationRepository.QueryFirst(x => x.LocationCode == taskDto.TargetAddress);
- if (Endlocation != null && Endlocation.LocationStatus == (int)LocationEnum.Free && Endlocation.EnalbeStatus == 1)
- {
- switch (Endlocation.AreaId)
- {
- case 1:
- taskNew = InboundStakerArea(taskDto, StartAddress, Endlocation);
- break;
- case 2:
- case 3:
- case 4:
- case 5:
- case 6:
- taskNew = InboundAGVCacheArea(taskDto, StartAddress, Endlocation);
- break;
- default:
- return content.Error("璐т綅鍖哄煙鏈壘鍒�");
- }
- }
- else
- {
- return content.OK("鐩爣搴撲綅涓嶅彲鐢�");
- }
+ return content.Error("璇ュ尯鍩熸棤鍙敤搴撲綅锛岃閫夋嫨鍏朵粬鍖哄煙");
}
- else
+
+ switch (taskDto.AreaId)
{
- return content.Error("璇烽�夋嫨鍏ュ簱鍖哄煙鎴栫粓鐐瑰湴鍧�");
+ case 1:
+ taskNew = InboundStakerArea(taskDto, StartAddress, area);
+ break;
+ case 2:
+ case 3:
+ case 4:
+ case 5:
+ case 6:
+ taskNew = InboundAGVCacheArea(taskDto, StartAddress, area);
+ break;
+ default:
+ return content.Error("璇烽�夋嫨姝ｇ‘鐨勫尯鍩熶俊鎭�");
}
var taskDTO = CreateListTaskDTO(taskNew);
-
- var result1 = UpdateLocationStatus(StartAddress, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
- var result2 = UpdateLocationStatus(Endlocation, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+
+ var result = UpdateLocationStatus(StartAddress.LocationCode, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
await _unitOfWorkManage.UseTranAsync(async () =>
{
- await _locationStatusChangeRecordRepository.AddDataAsync(result1.Item1);
- await _locationStatusChangeRecordRepository.AddDataAsync(result2.Item1);
- await _locationRepository.UpdateDataAsync(result1.Item2);
- await _locationRepository.UpdateDataAsync(result2.Item2);
+ await _locationStatusChangeRecordRepository.AddDataAsync(result.Item1);
+ await _locationRepository.UpdateDataAsync(result.Item2);
BaseDal.AddData(taskNew);
});
return content = await SendWCSTask(taskDTO);
- //return content.OK("鎴愬姛");
}
catch (Exception err)
{
@@ -595,18 +589,15 @@
}
}
- public Dt_Task InboundStakerArea(RequestTaskDto taskDto, DtLocationInfo StartAddress,DtLocationInfo EndLocation)
+ public Dt_Task InboundStakerArea(RequestTaskDto taskDto, DtLocationInfo StartAddress,Dt_AreaInfo area)
{
var station = _stationManagerRepository.QueryFirst(x => x.stationType == 1 && x.Roadway == "SC1");
- if (EndLocation == null)
- {
- throw new Exception("鏃犳硶鑾峰彇璐т綅淇℃伅");
- }
+
return new Dt_Task
{
Grade = 1,
Roadway = "SC1",
- TargetAddress = EndLocation.LocationCode,
+ TargetAddress = area.AreaName,
Dispatchertime = DateTime.Now,
MaterialNo = "",
NextAddress = station.stationChildCode,
@@ -624,22 +615,18 @@
};
}
- public Dt_Task InboundAGVCacheArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, DtLocationInfo location)
+ public Dt_Task InboundAGVCacheArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, Dt_AreaInfo area)
{
WebResponseContent content = new WebResponseContent();
- if (location == null)
- {
- throw new Exception("鏃犳硶鑾峰彇璐т綅淇℃伅");
- }
Dt_Task taskNew = new Dt_Task();
- if (StartAddress.Floor != location.Floor)
+ if (StartAddress.Floor != area.Spare1)
{
- taskNew = RequestAcrossFloorTask(StartAddress, location, (int)TaskInboundTypeEnum.Inbound, taskDto);
+ taskNew = RequestAcrossFloorTask(StartAddress, area, (int)TaskInboundTypeEnum.Inbound, taskDto);
}
else
{
- taskNew = RequestAGVCarryTask(StartAddress, location, (int)TaskInboundTypeEnum.Inbound, taskDto);
+ taskNew = RequestAGVCarryTask(StartAddress, GetAGVEmptyCacheLocation(area.AreaID, StartAddress).Result, (int)TaskInboundTypeEnum.Inbound, taskDto);
}
return taskNew;
@@ -675,47 +662,6 @@
content.Error(ex.Message);
}
return content;
- }
-
- public async Task<WebResponseContent> RequestLocationAsync(RequestTaskDto input)
- {
- await _semaphoreUpdate.WaitAsync();
- WebResponseContent content = new WebResponseContent();
- try
- {
- Dt_Task task = BaseDal.QueryFirst(x => x.PalletCode == input.PalletCode);
- if (task == null)
- {
- return content.Error("浠诲姟瀵硅薄涓虹┖");
- }
-
- task.TaskState = (int)TaskInStatusEnum.Line_InFinish;
- var location = await GetEmptyLocation(task.Roadway);
- if (location == null)
- {
- return content.Error("鏃犳硶鑾峰彇璐т綅淇℃伅");
- }
- int beforeStatus = location.LocationStatus;
-
- location.LocationStatus = (int)LocationEnum.Lock;
- task.CurrentAddress = input.Position;
- task.TargetAddress = location.LocationCode;
- task.NextAddress = location.LocationCode;
- task.TaskState = (int)TaskInStatusEnum.Line_InFinish;
- // 寮�濮嬩簨鍔�
- var isResult = await UpdateTaskAsync(task, location, beforeStatus);
- if (!isResult)
- {
- _unitOfWorkManage.RollbackTran();
- return content.Error("鏇存柊浠诲姟澶辫触");
- }
- return content.OK(data: task);
- }
- catch (Exception)
- {
- throw;
- }
- finally { _semaphoreUpdate.Release(); }
}
#endregion
@@ -769,7 +715,7 @@
});
var taskDto = CreateListTaskDTO(taskNew);
- var result = GetlcoationState(taskNew, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ var result = GetlcoationState(taskNew, StatusChangeTypeEnum.AutomaticOutbound);
await _unitOfWorkManage.UseTranAsync(async () =>
{
await BaseDal.AddDataAsync(taskNew);
@@ -838,7 +784,7 @@
stock.StockInfoDetails = details;
var taskDto = CreateListTaskDTO(taskNew);
- var result = GetlcoationState(taskNew, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ var result = GetlcoationState(taskNew, StatusChangeTypeEnum.AutomaticOutbound);
await _unitOfWorkManage.UseTranAsync(async () =>
{
await BaseDal.AddDataAsync(taskNew);
@@ -921,7 +867,7 @@
stock.StockInfoDetails = details;
var taskDto = CreateListTaskDTO(taskNew);
- var result = GetlcoationState(taskNew, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ var result = GetlcoationState(taskNew, StatusChangeTypeEnum.AutomaticOutbound);
await _unitOfWorkManage.UseTranAsync(async () =>
{
await BaseDal.AddDataAsync(taskNew);
@@ -938,36 +884,16 @@
}
}
- public (List<DtLocationStatusChangeRecord>,List<DtLocationInfo>) GetlcoationState(Dt_Task task,int StatusChangeTypeEnum)
+ public (List<DtLocationStatusChangeRecord>,List<DtLocationInfo>) GetlcoationState(Dt_Task task, StatusChangeTypeEnum StatusChangeTypeEnum)
{
List<DtLocationStatusChangeRecord> locationStatusChangeRecords = new List<DtLocationStatusChangeRecord>();
List<DtLocationInfo> locations = new List<DtLocationInfo>();
- var result1 = UpdateLocationStatus(task.SourceAddress, LocationEnum.InStockDisable, task.TaskNum.Value, StatusChangeTypeEnum);
- var result2 = UpdateLocationStatus(task.TargetAddress, LocationEnum.Lock, task.TaskNum.Value, StatusChangeTypeEnum);
- locationStatusChangeRecords.AddRange(result1.Item1);
- locationStatusChangeRecords.AddRange(result2.Item1);
- locations.AddRange(result1.Item2);
- locations.AddRange(result2.Item2);
+ var result = UpdateLocationStatus(task.SourceAddress, LocationEnum.InStockDisable, task.TaskNum.Value, (int)StatusChangeTypeEnum);
+ locationStatusChangeRecords.AddRange(result.Item1);
+ locations.AddRange(result.Item2);
return (locationStatusChangeRecords,locations);
}
-
- public (List<DtLocationStatusChangeRecord>, List<DtLocationInfo>) GetlcoationState(List<Dt_Task> tasks, int StatusChangeTypeEnum)
- {
- List<DtLocationStatusChangeRecord> locationStatusChangeRecords = new List<DtLocationStatusChangeRecord>();
- List<DtLocationInfo> locations = new List<DtLocationInfo>();
- foreach (var item in tasks)
- {
- var result1 = UpdateLocationStatus(item.SourceAddress, LocationEnum.InStockDisable, item.TaskNum.Value, StatusChangeTypeEnum);
- var result2 = UpdateLocationStatus(item.TargetAddress, LocationEnum.Lock, item.TaskNum.Value, StatusChangeTypeEnum);
- locationStatusChangeRecords.AddRange(result1.Item1);
- locationStatusChangeRecords.AddRange(result2.Item1);
- locations.AddRange(result1.Item2);
- locations.AddRange(result2.Item2);
- }
- return (locationStatusChangeRecords, locations);
- }
-
/// <summary>
/// 璇锋眰鍑哄簱浠诲姟
@@ -991,66 +917,43 @@
{
throw new Exception($"璧风偣搴撲綅{StartAddress.LocationCode}鍑哄簱璺緞琚崰鐢紝璇风◢鍚庨噸璇�");
}
- DtLocationInfo location = null;
- if (taskDto.AreaId != 0)
- {
- if (taskDto.AreaId == 1)
- {
- location = await GetEmptyLocation("SC1");
- }
- else
- {
- location = await GetAGVEmptyCacheLocation(taskDto.AreaId, StartAddress);
- }
- }
- else if (taskDto.TargetAddress != null)
- {
- location = _locationRepository.QueryFirst(x => x.LocationCode == taskDto.TargetAddress);
+ var area = _areaInfoRepository.QueryFirst(x => x.AreaID == 2);
- if (location != null && location.LocationStatus != (int)LocationEnum.Free && location.EnalbeStatus == 1)
- {
- throw new Exception("鐩爣搴撲綅涓嶅彲鐢�");
- }
- }
- else
+ var locationInfo = await _locationRepository.QueryDataAsync(x => x.AreaId == area.AreaID && x.EnalbeStatus == 1 && x.LocationStatus == (int)LocationEnum.Free);
+
+ var taskArea = BaseDal.QueryData(x => x.TargetAddress == area.AreaName && x.TaskType == (int)TaskInboundTypeEnum.Inbound);
+
+ if (locationInfo.Count - taskArea.Count <= 0)
{
- throw new Exception("璇烽�夋嫨鍏ュ簱鍖哄煙鎴栫粓鐐瑰湴鍧�");
+ throw new Exception($"鍑哄簱缂撳瓨鍖烘棤鍙敤搴撲綅锛岃娓呯悊搴撲綅鍚庡啀璇�");
}
+
switch (StartAddress.AreaId)
{
case 1:
- return OutboundStakerArea(taskDto, StartAddress, location);
+ return OutboundStakerArea(taskDto, StartAddress, area);
case 2:
case 3:
case 4:
case 5:
case 6:
- return OutboundAGVCacheArea(taskDto, StartAddress, location);
+ return OutboundAGVCacheArea(taskDto, StartAddress, area);
default:
throw new Exception("璇烽�夋嫨姝ｇ‘鐨勫尯鍩熶俊鎭�");
}
}
- public Dt_Task OutboundStakerArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, DtLocationInfo location)
+ public Dt_Task OutboundStakerArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, Dt_AreaInfo area)
{
var station = _stationManagerRepository.QueryFirst(x => x.stationType == 1 && x.Roadway == "SC1");
- if (location == null)
- {
- throw new Exception("缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
- }
-
- if (location.AreaId == 5 || location.AreaId == 6)
- {
- throw new Exception("褰撳墠鍖哄煙涓嶅彲鍑哄簱锛岃鑱旂郴绠＄悊鍛�");
- }
return new Dt_Task
{
Grade = Convert.ToInt32(StartAddress.Remark),
Roadway = "SC1",
- TargetAddress = location.LocationCode,
+ TargetAddress = area.AreaName,
Dispatchertime = DateTime.Now,
MaterialNo = taskDto.MaterielCode,
NextAddress = station.stationChildCode,
@@ -1068,25 +971,89 @@
};
}
- public Dt_Task OutboundAGVCacheArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, DtLocationInfo location)
+ public Dt_Task OutboundAGVCacheArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, Dt_AreaInfo area)
{
- if (location == null)
- {
- throw new Exception("璧风偣鏈畾涔夋垨缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
- }
Dt_Task taskNew = new Dt_Task();
- if (StartAddress.Floor != location.Floor)
+ if (StartAddress.Floor != area.Spare1)
{
- taskNew = RequestAcrossFloorTask(StartAddress, location, taskDto.TaskType, taskDto);
+ taskNew = RequestAcrossFloorTask(StartAddress, area, taskDto.TaskType, taskDto);
}
else
{
- taskNew = RequestAGVCarryTask(StartAddress, location, taskDto.TaskType, taskDto);
+ taskNew = RequestAGVCarryTask(StartAddress, GetAGVEmptyCacheLocation(taskDto.AreaId, StartAddress).Result, taskDto.TaskType, taskDto);
}
return taskNew;
}
#endregion 璇锋眰鍑哄簱锛堝疄鐩�&绌虹洏锛�
+
+ #region 璇锋眰绉诲簱浠诲姟
+ public async Task<WebResponseContent> RequestRelocationTaskAsync(string SourceAddress,string TargetAddress)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var startLocation = await _locationRepository.QueryFirstAsync(x => x.LocationCode == SourceAddress);
+ var endLocation = await _locationRepository.QueryFirstAsync(x => x.LocationCode == TargetAddress);
+
+ if (!startLocation.IsNotEmptyOrNull() || !endLocation.IsNotEmptyOrNull())
+ {
+ return content.Error("搴撲綅淇℃伅涓嶅瓨鍦�");
+ }
+ if (endLocation.LocationStatus != (int)LocationEnum.Free)
+ {
+ return content.Error($"缁堢偣搴撲綅{endLocation.LocationCode}鏈浜庣┖闂茬姸鎬侊紝璇蜂汉宸ョ‘璁ゅ簱浣嶇姸鎬�");
+ }
+ if ((startLocation.AreaId == 1 || endLocation.AreaId == 1) && startLocation.AreaId != endLocation.AreaId)
+ {
+ return content.Error("绉诲簱璧风偣搴撲綅涓庣粓鐐瑰簱浣嶄笉鍦ㄥ悓涓�鍖哄煙");
+ }
+ if (startLocation.Floor != endLocation.Floor)
+ {
+ return content.Error("绉诲簱璧风偣搴撲綅涓庣粓鐐瑰簱浣嶄笉鍦ㄥ悓涓�妤煎眰");
+ }
+
+ var stock = await _stockInfoRepository.QueryFirstAsync(x => x.LocationCode == startLocation.LocationCode);
+ var taskNew = new Dt_Task
+ {
+ Grade = startLocation.Floor == "1F" ? 10 : 1,
+ Roadway = endLocation.RoadwayNo,
+ TargetAddress = endLocation.LocationCode,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = endLocation.LocationCode,
+ OrderNo = null,
+ PalletCode = stock == null ? "M" + DateTime.Now.ToString("MMddHHmmss") + "-" + new Random().Next(100, 1000) : stock.PalletCode,
+ SourceAddress = startLocation.LocationCode,
+ CurrentAddress = startLocation.LocationCode,
+ TaskState = startLocation.AreaId == 1 ? (int)TaskRelocationStatusEnum.RelocationNew : (int)TaskRelocationStatusEnum.RelocationNewAGV,
+ TaskType = (int)TaskRelocationTypeEnum.Relocation,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ AGVTaskNum = GenerateUniqueId(),
+ Floor = startLocation.Floor,
+ };
+
+
+ var result = AddTaskAsync(new List<Dt_Task>() { taskNew });
+ await _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ await _locationStatusChangeRecordRepository.AddDataAsync(result.Item2);
+ await _locationRepository.UpdateDataAsync(result.Item1);
+ await BaseDal.AddDataAsync(taskNew);
+ });
+ await SendWCSTask(CreateListTaskDTO(taskNew));
+ return content.OK("鎴愬姛");
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+
+ #endregion
#region 璇锋眰璺ㄦゼ灞�2浠诲姟
/// <summary>
@@ -1111,14 +1078,15 @@
{
stationManager = _stationManagerRepository.QueryFirst(x => x.stationType == 5 && x.stationFloor == "1F");
}
+ content = await RequestLocation(taskDto.PalletCode);
Dt_Task taskNew = new Dt_Task
{
Grade = 1,
Roadway = "AGV",
- TargetAddress = task.TargetAddress,
+ TargetAddress = content.Data.ToString(),
Dispatchertime = DateTime.Now,
MaterialNo = "",
- NextAddress = task.TargetAddress,
+ NextAddress = content.Data.ToString(),
OrderNo = null,
PalletCode = task.PalletCode,
SourceAddress = task.SourceAddress,
@@ -1137,9 +1105,10 @@
taskHty.FinishTime = DateTime.Now;
taskHty.OperateType = App.User.UserName != null ? (int)OperateTypeEnum.浜哄伐瀹屾垚 : (int)OperateTypeEnum.鑷姩瀹屾垚;
taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
+
+ await UpdateStartLocationInfo(taskNew);
await _unitOfWorkManage.UseTranAsync(async () =>
{
-
await DeleteTaskAsync(task.TaskId);
await AddTaskHtyAsync(taskHty);
BaseDal.AddData(taskNew);
@@ -1155,7 +1124,7 @@
#endregion
#region 璇锋眰璺ㄦゼ灞備换鍔�
- public Dt_Task RequestAcrossFloorTask(DtLocationInfo StartAddress, DtLocationInfo EndAddress, int TaskType, RequestTaskDto taskDto)
+ public Dt_Task RequestAcrossFloorTask(DtLocationInfo StartAddress, Dt_AreaInfo area, int TaskType, RequestTaskDto taskDto)
{
WebResponseContent content = new WebResponseContent();
@@ -1164,7 +1133,7 @@
{
Grade = StartAddress.Column,
Roadway = "AGV",
- TargetAddress = EndAddress.LocationCode,
+ TargetAddress = area.AreaName,
Dispatchertime = DateTime.Now,
MaterialNo = taskDto.MaterielCode,
NextAddress = next.stationChildCode,
@@ -1249,22 +1218,22 @@
{
return content.Error($"涓�娣变綅寮傚父閿佸畾鏆備笉鍙嚭搴�");
}
- else if (locationLateral != null && locationLateral.LocationStatus == (int)LocationEnum.InStockDisable && locationLateral.EnalbeStatus == 1)
+ else if (locationLateral != null && (locationLateral.LocationStatus == (int)LocationEnum.InStockDisable|| locationLateral.LocationStatus == (int)LocationEnum.InStock) && locationLateral.EnalbeStatus == 1)
{
+ var taskLateral = BaseDal.QueryFirst(x => x.SourceAddress == locationLateral.LocationCode);
+ if (taskLateral != null)
+ {
+ return content.OK(data: _mapper.Map<WMSTaskDTO>(taskLateral));
+ }
+
var TargetAddress = await GetEmptyLocation("SC1");
if (TargetAddress == null)
{
return content.Error($"鏈壘鍒板彲鍒嗛厤璐т綅,璇锋煡鐪嬫槸鍚﹁繕鏈夌┖闂插彲浣跨敤璐т綅");
}
-
- //todo鏌ヨ鍐呬晶搴撳瓨淇℃伅
var stock = await _stockInfoRepository.QueryFirstAsync(x => x.LocationCode == locationLateral.LocationCode);
- if (stock == null)
- {
- return content.Error($"鏈壘鍒版祬浣峽locationLateral.LocationCode}搴撳瓨淇℃伅");
- }
Dt_Task taskNew = new Dt_Task
{
Grade = 1,
@@ -1274,7 +1243,7 @@
MaterialNo = "",
NextAddress = TargetAddress.LocationCode,
OrderNo = null,
- PalletCode = stock.PalletCode,
+ PalletCode = stock == null ? "M" + DateTime.Now.ToString("MMddHHmmss") + "-" + new Random().Next(100, 1000) : stock.PalletCode,
SourceAddress = locationLateral.LocationCode,
CurrentAddress = locationLateral.LocationCode,
TaskState = (int)TaskRelocationStatusEnum.RelocationNew,
@@ -1287,7 +1256,6 @@
var taskDTO = CreateListTaskDTO(taskNew);
var isResult = await AddTaskAsync(taskNew, locationLateral, TargetAddress);
- UpdateLocationStatus(TargetAddress, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticRelocation);
if (!isResult)
{
_unitOfWorkManage.RollbackTran();
@@ -1321,7 +1289,7 @@
if (location == null)
{
- return content.Error("鏈壘鍒拌揣浣嶆垨鑰呰搴撲綅涓嶆槸浜屾繁璐т綅");
+ return content.Error($"鏈壘鍒拌揣浣嶄俊鎭瘂taskDto.Position}");
}
List<DtLocationInfo> locationInfos = new List<DtLocationInfo>();
switch (location.AreaId)
@@ -1343,14 +1311,14 @@
}
List<WMSTaskDTO> taskDTO = new List<WMSTaskDTO>();
-
+ List<Dt_Task> taskNew = new List<Dt_Task>();
foreach (var item in locationInfos)
{
- if ((item.LocationStatus == 0 || item.LocationStatus == (int)LocationEnum.FreeDisable) && item.EnalbeStatus == 1)
+ if(item.LocationStatus == (int)LocationEnum.Lock)
{
- continue;
+ return content.Error($"{item.LocationCode}璺緞琚崰鐢紝璇风◢鍚庡啀璇�");
}
- else
+ if ((item.LocationStatus == (int)LocationEnum.InStockDisable || item.LocationStatus == (int)LocationEnum.InStock) && item.EnalbeStatus == 1)
{
DtLocationInfo Targetlocation = await GetAGVEmptyCacheLocation(item.AreaId, item);
@@ -1358,23 +1326,18 @@
{
return content.Error("璧风偣鏈畾涔夋垨缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
}
- //todo鏌ヨ绉诲簱搴撳瓨淇℃伅
var stock = _stockInfoRepository.QueryFirst(x => x.LocationCode == item.LocationCode);
- if (stock == null)
- {
- return content.Error($"鏈壘鍒版祬浣峽item.LocationCode}搴撳瓨淇℃伅");
- }
- var Relocationtask = BaseDal.QueryFirst(x => x.PalletCode == stock.PalletCode && x.TaskType == (int)TaskRelocationTypeEnum.Relocation);
- Dt_Task taskNew = new Dt_Task();
+
+ var Relocationtask = BaseDal.QueryFirst(x => x.SourceAddress == item.LocationCode);
+
if (Relocationtask != null)
{
taskDTO.Add(CreateTaskDTO(Relocationtask));
- //return content.OK(data:taskDTO);
continue;
}
else
{
- taskNew = new Dt_Task
+ taskNew.Add(new Dt_Task
{
Grade = item.Column,
Roadway = "AGV",
@@ -1383,10 +1346,10 @@
MaterialNo = "",
NextAddress = Targetlocation.LocationCode,
OrderNo = null,
- PalletCode = stock.PalletCode,
+ PalletCode = stock == null ? "M" + DateTime.Now.ToString("MMddHHmmss") + "-" + new Random().Next(100, 1000) : stock.PalletCode,
SourceAddress = item.LocationCode,
CurrentAddress = item.LocationCode,
- TaskState = (int)TaskAGVCarryStatusEnum.CarryNew,
+ TaskState = (int)TaskRelocationStatusEnum.RelocationNewAGV,
TaskType = (int)TaskRelocationTypeEnum.Relocation,
TaskNum = BaseDal.GetTaskNo().Result,
CreateDate = DateTime.Now,
@@ -1394,20 +1357,20 @@
AGVTaskNum = GenerateUniqueId(),
Floor = item.Floor,
Remark = item.AreaId.ToString(),
- };
+ });
}
- taskDTO.Add(CreateTaskDTO(taskNew));
-
- var isResult = await AddTaskAsync(taskNew, item, Targetlocation);
- UpdateLocationStatus(Targetlocation, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticRelocation);
- if (!isResult)
- {
- _unitOfWorkManage.RollbackTran();
- return content.Error("鏂板浠诲姟澶辫触");
- }
-
+
}
}
+ taskDTO = CreateTaskDTO(taskNew);
+
+ var result = AddTaskAsync(taskNew);
+ await _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ await _locationStatusChangeRecordRepository.AddDataAsync(result.Item2);
+ await _locationRepository.UpdateDataAsync(result.Item1);
+ await BaseDal.AddDataAsync(taskNew);
+ });
return content.OK(data: taskDTO);
}
catch (Exception ex)
@@ -1416,6 +1379,82 @@
}
}
+
+ #endregion
+
+ #region 鏇存柊璧风偣璐т綅淇℃伅
+ public async Task<WebResponseContent> UpdateStartLocationInfo(Dt_Task task)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ if (task == null)
+ return content.OK();
+ var result = UpdateLocationStatus(task.SourceAddress, LocationEnum.Free, task.TaskNum.Value, task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup ? (int)StatusChangeTypeEnum.AutomaticOutbound : (int)StatusChangeTypeEnum.AutomaticInbound);
+
+ await _locationStatusChangeRecordRepository.AddDataAsync(result.Item1);
+ await _locationRepository.UpdateDataAsync(result.Item2);
+
+ return content.OK();
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+
+ #endregion
+
+ #region 鑾峰彇缁堢偣璐т綅淇℃伅
+ public async Task<WebResponseContent> RequestLocation(string palletCode)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == palletCode);
+ if (task == null)
+ return content.Error("鏈壘鍒颁换鍔�");
+ var areaInfo = await _areaInfoRepository.QueryFirstAsync(x => x.AreaName == task.TargetAddress);
+ if (areaInfo == null)
+ return content.Error($"鏈壘鍒扮粓鐐瑰尯鍩熶俊鎭瘂task.TargetAddress}璇疯仈绯荤鐞嗗憳");
+ var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress);
+ DtLocationInfo locationInfo = new DtLocationInfo();
+ switch (areaInfo.AreaID)
+ {
+ case 1:
+ locationInfo = await GetEmptyLocation("SC1");
+ break;
+ case 2:
+ case 3:
+ case 4:
+ case 5:
+ case 6:
+ locationInfo = await GetAGVEmptyCacheLocation(areaInfo.AreaID, location);
+ break;
+ default:
+ return content.Error("璇烽�夋嫨姝ｇ‘鐨勫尯鍩熶俊鎭�");
+ }
+ if (locationInfo == null)
+ {
+ return content.Error("鏈壘鍒板彲鍒嗛厤璐т綅,璇锋煡鐪嬫槸鍚﹁繕鏈夌┖闂插彲浣跨敤璐т綅");
+ }
+ task.CurrentAddress = task.NextAddress;
+ task.TargetAddress = locationInfo.LocationCode;
+ task.NextAddress = locationInfo.LocationCode;
+
+ var result = UpdateLocationStatus(locationInfo.LocationCode, LocationEnum.Lock, task.TaskNum.Value, task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup ? StatusChangeTypeEnum.AutomaticOutbound : StatusChangeTypeEnum.AutomaticInbound);
+ await BaseDal.UpdateDataAsync(task);
+ await _locationStatusChangeRecordRepository.AddDataAsync(result.Item1);
+ await _locationRepository.UpdateDataAsync(result.Item2);
+
+ return content.OK(data: locationInfo.LocationCode);
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
#endregion
@@ -1456,37 +1495,6 @@
}
return content;
}
- #endregion
-
- #region 鑾峰彇浠诲姟鏁版嵁
- public async Task<WebResponseContent> GetTaskData()
- {
- WebResponseContent content = new WebResponseContent();
- try
- {
- var task = await BaseDal.QueryDataAsync(x => true);
- var taskData = new List<TaskData>
- {
- new TaskData { Status = "宸插彇娑�", Count = task.Count+50 },
- new TaskData { Status = "宸插畬鎴�", Count = 735 }
- };
-
- // 鏋勫缓绗﹀悎瑕佹眰鐨勬牸寮�
- var result = taskData.Select(item => new
- {
- value = item.Count,
- name = item.Status,
- itemStyle = new { color = item.Status == "宸插彇娑�" ? "#FF0000" : "#00FF00" }
- }).ToList();
-
- return content.OK(data: result);
- }
- catch (Exception ex)
- {
- return content.Error(ex.Message);
- }
- }
-
#endregion
#endregion 澶栭儴鎺ュ彛鏂规硶
@@ -1960,9 +1968,6 @@
changeRecordDto.Add(dtLocationStatusChangeRecord);
}
}
- //_locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
-
- //_locationRepository.UpdateData(locations);
return (changeRecordDto,locations);
}
@@ -1987,20 +1992,12 @@
{
item.LocationStatus = (int)LocationEnum.Lock;
}
- else if (item.LocationStatus == (int)LocationEnum.Free)
- {
- item.LocationStatus = (int)LocationEnum.FreeDisable;
- }
}
else if (locationStatus == LocationEnum.InStock)
{
if (item.LocationCode == location.LocationCode)
{
item.LocationStatus = (int)LocationEnum.InStock;
- }
- else if (item.LocationStatus == (int)LocationEnum.FreeDisable)
- {
- item.LocationStatus = (int)LocationEnum.Free;
}
}
else if (locationStatus == LocationEnum.InStockDisable)
@@ -2009,21 +2006,10 @@
{
item.LocationStatus = (int)LocationEnum.InStockDisable;
}
- else if (item.LocationStatus == (int)LocationEnum.Free)
- {
- item.LocationStatus = (int)LocationEnum.FreeDisable;
- }
}
else if (locationStatus == LocationEnum.Free)
{
- if (item.LocationCode == location.LocationCode)
- {
- item.LocationStatus = (int)LocationEnum.Free;
- }
- else if (item.LocationStatus == (int)LocationEnum.FreeDisable || item.LocationStatus == (int)LocationEnum.InStockDisable)
- {
- item.LocationStatus = (int)LocationEnum.Free;
- }
+ item.LocationStatus = (int)LocationEnum.Free;
}
}
List<DtLocationStatusChangeRecord> changeRecordDto = new List<DtLocationStatusChangeRecord>();
@@ -2046,10 +2032,28 @@
changeRecordDto.Add(dtLocationStatusChangeRecord);
}
}
- //_locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
-
- //_locationRepository.UpdateData(locations);
return (changeRecordDto, locations);
+ }
+
+ public (DtLocationStatusChangeRecord, DtLocationInfo) UpdateLocationStatus(string locationCode, LocationEnum locationStatus, int taskNum, StatusChangeTypeEnum StatusChangeType)
+ {
+ var location = _locationRepository.QueryFirst(x => x.LocationCode == locationCode);
+ int Beforelocation = location.LocationStatus;
+
+ location.LocationStatus = (int)locationStatus;
+
+ DtLocationStatusChangeRecord dtLocationStatusChangeRecord = new DtLocationStatusChangeRecord()
+ {
+ ChangeType = (int)StatusChangeType,
+ LocationCode = locationCode,
+ LocationId = location.Id,
+ Creater = "System",
+ TaskNum = taskNum,
+ AfterStatus = location.LocationStatus,
+ BeforeStatus = Beforelocation,
+ };
+
+ return (dtLocationStatusChangeRecord, location);
}
public List<DtLocationInfo> GetGroupLocations(DtLocationInfo location)
@@ -2125,6 +2129,30 @@
Remark = task.Remark,
Floor = task.Floor,
};
+ }
+ private List<WMSTaskDTO> CreateTaskDTO(List<Dt_Task> task)
+ {
+ List<WMSTaskDTO> taskNews = new List<WMSTaskDTO>();
+ foreach (var item in task)
+ {
+ taskNews.Add(new WMSTaskDTO
+ {
+ TaskNum = item.TaskNum.Value,
+ Grade = item.Grade.Value,
+ PalletCode = item.PalletCode,
+ RoadWay = item.Roadway,
+ SourceAddress = item.SourceAddress,
+ TargetAddress = item.TargetAddress,
+ TaskState = item.TaskState,
+ Id = 0,
+ TaskType = item.TaskType,
+ AGVTaskNum = item.AGVTaskNum,
+ Remark = item.Remark,
+ Floor = item.Floor,
+ });
+ }
+
+ return taskNews;
}
private async Task DeleteStockInfoAsync(int stockId)
@@ -2288,7 +2316,6 @@
private async Task<bool> AddTaskAsync(Dt_Task task, DtLocationInfo StartAddress, DtLocationInfo EndAddress)
{
- //UpdateLocationStatus
bool isResult = await BaseDal.AddDataAsync(task) > 0;
int SourcebeforeStatus = StartAddress.LocationStatus;
@@ -2325,6 +2352,46 @@
bool Target = await _locationRepository.UpdateDataAsync(EndAddress);
return isResult && Source && Target;
+ }
+
+ private (List<DtLocationInfo>,List<DtLocationStatusChangeRecord>) AddTaskAsync(List<Dt_Task> task)
+ {
+ List<DtLocationStatusChangeRecord> changeRecordDto = new List<DtLocationStatusChangeRecord>();
+ List<DtLocationInfo> locationos = new List<DtLocationInfo>();
+ foreach (var item in task)
+ {
+ var SourceAddress = _locationRepository.QueryFirst(x => x.LocationCode == item.SourceAddress);
+ var TargetAddress = _locationRepository.QueryFirst(x => x.LocationCode == item.TargetAddress);
+ int SourcebeforeStatus = SourceAddress.LocationStatus;
+
+ int TargetbeforeStatus = TargetAddress.LocationStatus;
+
+ SourceAddress.LocationStatus = (int)LocationEnum.InStockDisable;
+ TargetAddress.LocationStatus = (int)LocationEnum.Lock;
+ changeRecordDto.Add(new DtLocationStatusChangeRecord()
+ {
+ ChangeType = (int)StatusChangeTypeEnum.AutomaticRelocation,
+ LocationCode = TargetAddress.LocationCode,
+ LocationId = TargetAddress.Id,
+ Creater = "System",
+ TaskNum = item.TaskNum,
+ AfterStatus = TargetAddress.LocationStatus,
+ BeforeStatus = TargetbeforeStatus,
+ });
+ changeRecordDto.Add(new DtLocationStatusChangeRecord
+ {
+ AfterStatus = TargetAddress.LocationStatus,
+ BeforeStatus = TargetbeforeStatus,
+ TaskNum = item.TaskNum.Value,
+ Creater = "System",
+ LocationId = TargetAddress.Id,
+ LocationCode = TargetAddress.LocationCode,
+ ChangeType = (int)StatusChangeTypeEnum.AutomaticRelocation,
+ });
+ locationos.Add(TargetAddress);
+ locationos.Add(SourceAddress);
+ }
+ return (locationos, changeRecordDto);
}
/// <summary>
@@ -2414,6 +2481,11 @@
foreach (var item in locations)
{
var locationLateral = _locationRepository.QueryData(x => x.Row == item.Row && x.Column < item.Column && x.Remark == item.Remark);
+ if (locationLateral.Count == 0)
+ {
+ locationInfos.Add(item);
+ continue;
+ }
bool Isavailable = true;
foreach (var lateral in locationLateral)
{
@@ -2461,17 +2533,18 @@
locationInfos.Add(item);
continue;
}
- foreach (var Lateral in locationLateral)
+ bool Isavailable = true;
+ foreach (var lateral in locationLateral)
{
- if (locationInfos.Contains(Lateral))
- continue;
- if (Lateral.LocationStatus == (int)LocationEnum.Free && Lateral.EnalbeStatus == 1)
+ if (lateral.LocationStatus != (int)LocationEnum.Free && lateral.EnalbeStatus == 1)
{
- locationInfos.Add(item);
+ Isavailable = false;
+ continue;
}
}
+ if (Isavailable)
+ locationInfos.Add(item);
}
-
return locationInfos.Distinct().OrderBy(x => x.Column).ThenBy(x => x.Row).FirstOrDefault();
}
@@ -2490,8 +2563,6 @@
public bool LocationIsOutBound(DtLocationInfo location)
{
-
- int sum = 0;
if (location.AreaId == 1)
{
if (location.Depth == 2)
--
Gitblit v1.9.3