From 34bafb439a438c0f4e85ef7006dac590140d155c Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期五, 01 十一月 2024 14:50:15 +0800
Subject: [PATCH] 联调程序变动
---
Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs | 389 ++++++++++++++++++++++++++++---------------------------
1 files changed, 197 insertions(+), 192 deletions(-)
diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
index 0ef476a..e4f3339 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
@@ -1,10 +1,10 @@
-锘縰sing WIDESEA_Common;
-using WIDESEA_DTO;
-using WIDESEA_IStorageTaskRepository;
-using WIDESEA_Repository;
-using WIDESEA_StorageTaskRepository;
-
-namespace WIDESEA_StorageOutTaskServices;
+锘縰sing Mapster;
+using System.Collections.Generic;
+using WIDESEA_DTO.MOM;
+using WIDESEA_DTO.WMS;
+using WIDESEA_IStoragIntegrationServices;
+using WIDESEA_StoragIntegrationServices;
+namespace WIDESEA_StorageOutTaskServices;
public class Dt_TaskService : ServiceBase<Dt_Task, IDt_TaskRepository>, IDt_TaskService
{
@@ -22,6 +22,9 @@
private readonly IPointStackerRelationRepository _pointStackerRelationRepository;
private readonly ITaskExecuteDetailRepository _taskExecuteDetailRepository;
private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository;
+ private readonly IBoxingInfoRepository _boxingInfoRepository;
+ private readonly ICellStateService _cellStateService;
+ private readonly IProcessApplyService _processApplyService;
public Dt_TaskService(IDt_TaskRepository BaseDal,
IUnitOfWorkManage unitOfWorkManage,
@@ -36,7 +39,10 @@
IDt_WareAreaInfoRepository wareAreaInfoRepository,
IPointStackerRelationRepository pointStackerRelationRepository,
ITaskExecuteDetailRepository taskExecuteDetailRepository,
- ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository) : base(BaseDal)
+ ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
+ IBoxingInfoRepository boxingInfoRepository,
+ ICellStateService cellStateService,
+ IProcessApplyService processApplyService) : base(BaseDal)
{
_unitOfWorkManage = unitOfWorkManage;
_outOrderRepository = outOrderRepository;
@@ -51,12 +57,17 @@
_pointStackerRelationRepository = pointStackerRelationRepository;
_taskExecuteDetailRepository = taskExecuteDetailRepository;
_locationStatusChangeRecordRepository = locationStatusChangeRecordRepository;
+ _boxingInfoRepository = boxingInfoRepository;
+ _cellStateService = cellStateService;
+ _processApplyService = processApplyService
}
#region 澶栭儴鎺ュ彛鏂规硶
+ #region 鍫嗗灈鏈哄嚭搴撲换鍔″畬鎴�
+
/// <summary>
- /// 鍫嗗灈鏈轰换鍔″畬鎴�
+ /// 鍫嗗灈鏈哄嚭搴撲换鍔″畬鎴�
/// </summary>
/// <param name="saveModel">浠诲姟鏁版嵁鍚堥泦</param>
/// <returns>杩斿洖缁撴灉闆�</returns>
@@ -66,34 +77,46 @@
try
{
// 鏇存柊搴撳瓨鐘舵��
+ // 璁剧疆搴撲綅鐘舵�佷负绌洪棽
stock.LocationInfo.LocationStatus = LocationEnum.Free.ObjToInt();
+ // 璁剧疆搴撳瓨鐘舵�佷负鍑哄簱
stock.StockInfoDetails.ForEach(x =>
{
x.Status = 2;
});
// 鏇存柊浠诲姟鐘舵��
- task.TaskState = OutTaskStatusEnum.SC_OutFinish.ObjToInt();
+ task.TaskState = TaskOutStatusEnum.SC_OutFinish.ObjToInt();
task.CurrentAddress = task.NextAddress;
task.NextAddress = task.TargetAddress;
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍫嗗灈鏈哄嚭搴撳畬鎴�", "鏇存柊搴撳瓨鐘舵�佷笌浠诲姟鐘舵��");
// 浜嬪姟澶勭悊
+ // 寮�濮嬩簨鍔�
_unitOfWorkManage.BeginTran();
+ // 鏇存柊搴撳瓨淇℃伅
var isStockUpdated = _stockInfoRepository.UpdateData(stock);
+ // 鏇存柊浠诲姟淇℃伅
var isTaskUpdated = await Update(task);
+ // 濡傛灉搴撳瓨淇℃伅鍜屼换鍔′俊鎭兘鏇存柊鎴愬姛
if (isStockUpdated && isTaskUpdated)
{
+ // 璁板綍鏃ュ織
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍫嗗灈鏈哄嚭搴撳畬鎴�", $"浜嬪姟澶勭悊瀹屾垚锛屽簱瀛樼姸鎬佹洿鏂帮細{isStockUpdated}锛屼换鍔＄姸鎬佹洿鏂�:{isTaskUpdated}");
+ // 鎻愪氦浜嬪姟
_unitOfWorkManage.CommitTran();
+ // 杩斿洖鎴愬姛缁撴灉
return content.OK("浠诲姟瀹屾垚鎴愬姛");
}
else
{
+ // 璁板綍鏃ュ織
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍫嗗灈鏈哄嚭搴撳畬鎴�", $"浜嬪姟澶勭悊澶辫触锛屽簱瀛樼姸鎬佹洿鏂帮細{isStockUpdated}锛屼换鍔＄姸鎬佹洿鏂�:{isTaskUpdated}");
+ // 鍥炴粴浜嬪姟
_unitOfWorkManage.RollbackTran();
+ // 杩斿洖澶辫触缁撴灉
return content.Error("浠诲姟鎴栧簱瀛樻洿鏂板け璐�");
}
}
@@ -105,46 +128,9 @@
}
}
- /// <summary>
- /// 鍑哄簱浠诲姟瀹屾垚
- /// </summary>
- /// <param name="saveModel">浠诲姟鏁版嵁鍚堥泦</param>
- /// <returns>杩斿洖缁撴灉闆�</returns>
- public async Task<WebResponseContent> CompleteTaskAsync(Dt_Task task, DtStockInfo stock)
- {
- WebResponseContent content = new WebResponseContent();
+ #endregion 鍫嗗灈鏈哄嚭搴撲换鍔″畬鎴�
- try
- {
- // 鏇存柊鍑哄簱璁㈠崟鍜屽簱瀛樿揣浣嶄俊鎭�
- var orderStock = await UpdateOrderAndStockAsync(stock, task.PalletCode);
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�", $"鏇存柊鍑哄簱璁㈠崟鍜屽簱瀛樿揣浣嶄俊鎭�:{JsonConvert.SerializeObject(orderStock)}");
-
- // 妫�鏌ヨ鍗曟槸鍚﹀畬鎴愬苟澶勭悊鍚庣画鎿嶄綔
- if (IsOrderComplete(orderStock))
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�", $"璁㈠崟鍑哄簱瀹屾垚");
- // 澶勭悊宸插畬鎴愯鍗�
- await ProcessCompletedOrderAsync(orderStock, task);
- }
- else
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�", $"璁㈠崟鏆傛湭鍑哄簱瀹屾垚");
- // 澶勭悊鏈畬鎴愯鍗�
- await ProcessUpdateOrderAsync(orderStock, task);
- }
-
- content.OK("浠诲姟瀹屾垚");
- }
- catch (Exception err)
- {
- // 璁板綍寮傚父淇℃伅
- Console.WriteLine(err.Message.ToString());
- content.Error("浠诲姟瀹屾垚澶辫触");
- }
-
- return content;
- }
+ #region 绉诲簱浠诲姟瀹屾垚
/// <summary>
/// 绉诲簱浠诲姟瀹屾垚
@@ -159,7 +145,7 @@
// 鏇存柊璐т綅鍜屽簱瀛樹俊鎭�
(DtStockInfo updateStock, DtLocationInfo locationInf) = UpdateStockLocation(stock, task.NextAddress);
var taskHty = CreateHistoricalTask(task);
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"淇敼鍚庡簱瀛樻暟鎹細{JsonConvert.SerializeObject(updateStock)}锛屽師鍏堣揣浣嶆暟鎹細{locationInf}");
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"璐т綅鍦板潃锛歿task.TargetAddress},淇敼鍚庡簱瀛樻暟鎹細{JsonConvert.SerializeObject(updateStock)}锛屽師鍏堣揣浣嶆暟鎹細{locationInf}");
// 鎵ц鏁版嵁搴撲簨鍔�
bool isResult = await ExecuteTransaction(updateStock, taskHty, locationInf, task.TaskId);
@@ -174,6 +160,62 @@
}
return content;
}
+
+ #endregion 绉诲簱浠诲姟瀹屾垚
+
+ #region 鍏ュ簱浠诲姟瀹屾垚
+
+ /// <summary>
+ /// 鍏ュ簱浠诲姟瀹屾垚
+ /// </summary>
+ /// <param name="task">浠诲姟鏁版嵁鍚堥泦</param>
+ /// <returns>杩斿洖缁撴灉闆�</returns>
+ public async Task<WebResponseContent> CompleteInboundTaskAsync(Dt_Task task)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var boxing = await _boxingInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
+
+ var boxDetail = boxing.BoxingInfoDetails.Adapt<List<DtStockInfoDetail>>();
+ // 鍒涘缓搴撳瓨瀹炰緥妯″瀷
+ DtStockInfo stock = new DtStockInfo()
+ {
+ PalletCode = task.PalletCode,
+ LocationCode = task.TargetAddress,
+ CreateDate = DateTime.Now,
+ Creater = "system",
+ IsFull = boxing.IsFull,
+ StockInfoDetails = boxDetail,
+ LocationInfo = new DtLocationInfo()
+ };
+
+ // 鍒涘缓鍘嗗彶浠诲姟瀹炰緥妯″瀷
+ var taskHty = CreateHistoricalTask(task);
+
+ // 淇敼璐т綅淇℃伅涓烘湁璐�
+ var locationInf = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
+ locationInf.LocationStatus = (int)LocationEnum.Lock;
+
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍏ュ簱浠诲姟瀹屾垚", $"璐т綅鍦板潃锛歿task.TargetAddress},淇敼鍚庤揣浣嶆暟鎹細{locationInf}");
+
+ // 鎵ц鏁版嵁搴撲簨鍔�
+ bool isResult = await ExecuteTransaction(stock, taskHty, locationInf, task.TaskId);
+ if (isResult)
+ content.OK("鍏ュ簱浠诲姟瀹屾垚鎴愬姛");
+ else
+ content.Error("鍏ュ簱浠诲姟瀹屾垚澶辫触");
+ }
+ catch (Exception err)
+ {
+ Console.WriteLine(err.Message.ToString());
+ }
+ return content;
+ }
+
+ #endregion 鍏ュ簱浠诲姟瀹屾垚
+
+ #region 浠诲姟瀹屾垚
/// <summary>
/// 浠诲姟瀹屾垚
@@ -198,22 +240,32 @@
var stock = await _stockInfoRepository.QueryFirstAsync(x => x.PalletCode == task.PalletCode);
if (stock == null)
{
- return content.Error("搴撳瓨涓嶅瓨鍦�");
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "搴撳瓨涓嶅瓨鍦ㄥ瓨鍦紝鍒ゆ柇鏄惁鏄叆搴撲换鍔�", $"{task.TaskType}");
+ if (task.TaskType == (int)TaskTypeEnum.Inbound)
+ {
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍏ュ簱浠诲姟", "");
+ return await CompleteInboundTaskAsync(task);
+ }
+ else
+ {
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "搴撳瓨涓嶅瓨鍦ㄤ篃涓嶆槸鍏ュ簱浠诲姟", "");
+ return content.Error("搴撳瓨涓嶅瓨鍦�");
+ }
}
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "楠岃瘉搴撳瓨鏄惁瀛樺湪", JsonConvert.SerializeObject(stock));
if (task.TaskType == (int)TaskTypeEnum.Outbound)
{
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍑哄簱浠诲姟", "");
- if (task.TaskState == OutTaskStatusEnum.SC_OutExecuting.ObjToInt())
+ if (task.TaskState == TaskOutStatusEnum.SC_OutExecuting.ObjToInt())
{
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍫嗗灈鏈哄嚭搴撳畬鎴�", "");
return await CompleteStackTaskAsync(task, stock);
}
else
{
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�", "");
- return await CompleteTaskAsync(task, stock);
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "搴撳瓨涓嶅瓨鍦ㄤ篃涓嶆槸鍏ュ簱浠诲姟", "");
+ return content.Error("搴撳瓨涓嶅瓨鍦�");
}
}
else if (task.TaskType == (int)TaskTypeEnum.RelocationIn)
@@ -228,6 +280,10 @@
}
}
+ #endregion 浠诲姟瀹屾垚
+
+ #region 璇锋眰浠诲姟
+
/// <summary>
/// 璇锋眰浠诲姟
/// </summary>
@@ -240,7 +296,31 @@
try
{
// 鏍规嵁鎵樼洏鑾峰彇搴撳瓨淇℃伅
- var stockInfo = await _stockInfoRepository.QueryFirstAsync(x => x.PalletCode == input.PalletCode);
+ //var stockInfo = await _stockInfoRepository.QueryFirstAsync(x => x.PalletCode == input.PalletCode);
+ TrayCellsStatusDto trayCells = new TrayCellsStatusDto()
+ {
+ TrayBarcode = input.PalletCode
+ };
+ content = await _cellStateService.GetTrayCellStatusAsync(trayCells);
+ if (content.Status)
+ {
+ ResultTrayCellsStatus result = JsonConvert.DeserializeObject<ResultTrayCellsStatus>(content.Data.ToString());
+
+ ProcessApplyDto process = new ProcessApplyDto()
+ {
+ WipOrderNo = result.BindCode,
+ SerialNos = result.SerialNos.Select(item => new SerialNos
+ {
+ SerialNo = item.SerialNo
+ }).ToList()
+ };
+ content = await _processApplyService.GetProcessApplyAsync(process);
+ if (content.Status)
+ {
+ var X = SqlSugarHelper.Db.Queryable<Dt_EquipmentProcess>().Where(x => x.EquipmentType == "CH").ToList();
+ }
+
+ }
// 鑾峰彇浠撳簱鍖哄煙淇℃伅
var areaInfo = await _wareAreaInfoRepository.QueryFirstAsync(x => x.WareAreaCode == input.AreaCode);
@@ -250,7 +330,6 @@
if (task != null)
{
-
// 鏇存柊鐜版湁浠诲姟
content = await UpdateExistingTask(input, areaInfo.AreaID, task);
}
@@ -269,6 +348,8 @@
return content;
}
+
+ #endregion 璇锋眰浠诲姟
#endregion 澶栭儴鎺ュ彛鏂规硶
@@ -426,12 +507,16 @@
/// <returns>鏇存柊鍚庣殑璁㈠崟鍜屽簱瀛樹俊鎭�</returns>
private async Task<Dt_OutOrderAndStock> UpdateOrderAndStockAsync(DtStockInfo stock, string barCode)
{
+ //鏍规嵁PalletCode鑾峰彇璁㈠崟鍜屽簱瀛樹俊鎭�
var orderStock = await _outOrderAndStockRepository.GetOrderAndStock(palletCode: barCode);
+ //瀹屾垚鏁伴噺澧炲姞
orderStock.CompletedQuantity += stock.StockInfoDetails.Sum(x => x.StockQuantity);
+ //璁㈠崟璇︽儏瀹屾垚鏁伴噺澧炲姞
orderStock.OrderList.OrderDetailList.CompletedQuantity += stock.StockInfoDetails.Sum(x => x.StockQuantity);
+ //杩斿洖鏇存柊鍚庣殑璁㈠崟鍜屽簱瀛樹俊鎭�
return orderStock;
}
@@ -440,141 +525,22 @@
/// </summary>
/// <param name="orderStock">璁㈠崟鍜屽簱瀛樹俊鎭�</param>
/// <returns>鏄惁瀹屾垚</returns>
+ // 鍒ゆ柇璁㈠崟鏄惁瀹屾垚
private bool IsOrderComplete(Dt_OutOrderAndStock orderStock)
{
+ // 濡傛灉鍑哄簱鏁伴噺绛変簬瀹屾垚鍑哄簱鏁伴噺锛屽垯璁㈠崟瀹屾垚
return orderStock.CompletedQuantity == orderStock.OutboundQuantity;
}
/// <summary>
- /// 澶勭悊宸插畬鎴愮殑璁㈠崟
+ /// 鍒涘缓鍘嗗彶浠诲姟璁板綍
/// </summary>
- /// <param name="orderStock">璁㈠崟鍜屽簱瀛樹俊鎭�</param>
- /// <param name="task">浠诲姟鏁版嵁</param>
- /// <returns>寮傛浠诲姟</returns>
- private async Task ProcessCompletedOrderAsync(Dt_OutOrderAndStock orderStock, Dt_Task task)
- {
- // 鍒涘缓鍘嗗彶璁㈠崟璁板綍
- var stockHty = CreateHistoricalOrder(orderStock);
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟宸插畬鎴�", $"鍒涘缓鍘嗗彶璁㈠崟璁板綍锛歿JsonConvert.SerializeObject(stockHty)}");
-
- // 鍒涘缓鑾峰彇鍘嗗彶浠诲姟
- var taskHty = CreateHistoricalTask(task);
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟宸插畬鎴�", $"鍒涘缓鍘嗗彶浠诲姟璁板綍锛歿JsonConvert.SerializeObject(taskHty)}");
-
- _unitOfWorkManage.BeginTran();
-
- try
- {
- // 娣诲姞鍘嗗彶浠诲姟
- var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
-
- // 鍒犻櫎浠诲姟鏁版嵁
- var isTaskDelete = await Delete(task.TaskId);
-
- // 鎻掑叆鍘嗗彶璁㈠崟
- var isStockInsert = _outOrderAndStock_HtyRepository.InsertNav(stockHty);
-
- // 鍒犻櫎鍘熻鍗�
- var isOrderStockDelete = _outOrderAndStockRepository.DeleteNavOrderStock(orderStock);
-
- if (isStockInsert && isOrderStockDelete && isTaskHtyAdd && isTaskDelete)
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟宸插畬鎴�", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鎻掑叆鍘嗗彶璁㈠崟锛歿isStockInsert},鍒犻櫎鍘熻鍗�:{isOrderStockDelete}");
- _unitOfWorkManage.CommitTran();
- }
- else
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟宸插畬鎴�", $"娣诲姞鏁版嵁搴撳け璐�,璇锋鏌ユ暟鎹槸鍚︽纭�,鏁版嵁鍥炴粴銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鎻掑叆鍘嗗彶璁㈠崟锛歿isStockInsert},鍒犻櫎鍘熻鍗�:{isOrderStockDelete}");
- _unitOfWorkManage.RollbackTran();
- }
- }
- catch (Exception ex)
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, $"鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟宸插畬鎴�,绯荤粺寮傚父锛屽紓甯镐俊鎭細{ex.Message}", "鏃犲弬鏁�");
- _unitOfWorkManage.RollbackTran();
- throw; // 閲嶆柊鎶涘嚭寮傚父浠ヤ緵澶栭儴鎹曡幏
- }
- }
-
- /// <summary>
- /// 澶勭悊鏈畬鎴愯鍗�
- /// </summary>
- /// <param name="orderStock">璁㈠崟鍜屽簱瀛樹俊鎭�</param>
- /// <param name="task">浠诲姟鏁版嵁</param>
- /// <returns>寮傛浠诲姟</returns>
- private async Task ProcessUpdateOrderAsync(Dt_OutOrderAndStock orderStock, Dt_Task task)
- {
- // 鍒涘缓鑾峰彇鍘嗗彶浠诲姟
- var taskHty = CreateHistoricalTask(task);
-
- _unitOfWorkManage.BeginTran();
- try
- {
- // 娣诲姞鍘嗗彶浠诲姟
- var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
-
- // 鍒犻櫎浠诲姟鏁版嵁
- var isTaskDelete = await Delete(task.TaskId);
-
- // 鏇存柊璁㈠崟涓庡簱瀛�
- var isOrderUpdated = _outOrderAndStockRepository.UpdateNavOrderStock(orderStock);
- if (isTaskDelete && isTaskHtyAdd && isOrderUpdated)
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟鏆傛湭瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊璁㈠崟涓庡簱瀛橈細{isOrderUpdated}");
- _unitOfWorkManage.CommitTran();
- }
- else
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟鏆傛湭瀹屾垚", $"娣诲姞鏁版嵁搴撳け璐�,璇锋鏌ユ暟鎹槸鍚︽纭�,鏁版嵁鍥炴粴銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊璁㈠崟涓庡簱瀛橈細{isOrderUpdated}");
- _unitOfWorkManage.RollbackTran();
- }
- }
- catch (Exception err)
- {
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, $"鎬讳换鍔″嚭搴撳畬鎴�,璁㈠崟鏆傛湭瀹屾垚,绯荤粺寮傚父锛屽紓甯镐俊鎭細{err.Message}", "鏃犲弬鏁�");
- Console.WriteLine(err.Message.ToString());
- _unitOfWorkManage.RollbackTran();
- throw; // 閲嶆柊鎶涘嚭寮傚父浠ヤ緵澶栭儴鎹曡幏
- }
- }
-
- /// <summary>
- /// 鍒涘缓鍘嗗彶璁㈠崟璁板綍
- /// </summary>
- /// <param name="orderStock">璁㈠崟鍜屽簱瀛樹俊鎭�</param>
- /// <returns>鍘嗗彶璁㈠崟璁板綍</returns>
- private Dt_OutOrderAndStock_Hty CreateHistoricalOrder(Dt_OutOrderAndStock orderStock)
- {
- var stockHty = _mapper.Map<Dt_OutOrderAndStock_Hty>(orderStock);
-
- //stockHty.StockList.FinishTime = DateTime.Now;
- //stockHty.StockList.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
- //stockHty.StockList.SourceId = orderStock.StockList.GroupId;
- //stockHty.StockList.GroupId = 0;
-
- //stockHty.StockList.StockDetailList.ForEach(x =>
- //{
- // x.FinishTime = DateTime.Now;
- // x.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
- // x.GroupId = 0;
- //});
-
- stockHty.OrderList.FinishTime = DateTime.Now;
- stockHty.OrderList.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
- stockHty.OrderList.SourceId = orderStock.OrderList.Id;
- stockHty.OrderList.Id = 0;
-
- stockHty.OrderList.orderDetailList.FinishTime = DateTime.Now;
- stockHty.OrderList.orderDetailList.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
- stockHty.OrderList.orderDetailList.Id = 0;
-
- return stockHty;
- }
-
+ /// <param name="task"></param>
+ /// <returns></returns>
private Dt_Task_Hty CreateHistoricalTask(Dt_Task task)
{
// 鏇存柊浠诲姟鐘舵��
- task.TaskState = OutTaskStatusEnum.OutFinish.ObjToInt();
+ task.TaskState = TaskOutStatusEnum.OutFinish.ObjToInt();
task.CurrentAddress = task.NextAddress;
// 鍒涘缓鍘嗗彶浠诲姟
@@ -583,7 +549,7 @@
taskHty.TaskId = 0;
taskHty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
taskHty.SourceId = task.TaskId;
- taskHty.TaskState = OutTaskStatusEnum.OutFinish.ObjToInt();
+ taskHty.TaskState = TaskOutStatusEnum.OutFinish.ObjToInt();
return taskHty;
}
@@ -592,14 +558,20 @@
/// </summary>
/// <param name="stock">搴撳瓨瀵硅薄</param>
/// <param name="toLocation">鐩爣浣嶇疆</param>
+ // 鏇存柊搴撳瓨鍜屼綅缃俊鎭�
private (DtStockInfo, DtLocationInfo) UpdateStockLocation(DtStockInfo stock, string toLocation)
{
+ // 鑾峰彇搴撳瓨淇℃伅
var locationInfo = _locationRepository.QueryFirst(x => x.LocationCode == stock.LocationCode);
+ // 灏嗗簱瀛樼姸鎬佽缃负鍦ㄥ簱
locationInfo.LocationStatus = LocationEnum.InStock.ObjToInt();
+ // 灏嗗簱瀛樹綅缃缃负鐩爣浣嶇疆
stock.LocationCode = toLocation;
+ // 灏嗗簱瀛樼姸鎬佽缃负鍦ㄥ簱
stock.LocationInfo.LocationStatus = LocationEnum.InStock.ObjToInt();
+ // 杩斿洖鏇存柊鍚庣殑搴撳瓨鍜屼綅缃俊鎭�
return (stock, locationInfo);
}
@@ -615,8 +587,17 @@
_unitOfWorkManage.BeginTran();
try
{
- // 鏇存柊搴撳瓨
- var isUpdateStock = await _stockInfoRepository.UpdateDataAsync(stock);
+ var isUpdateStock = true;
+ if (taskHty.TaskType == (int)TaskTypeEnum.Outbound)
+ {
+ // 鏇存柊搴撳瓨
+ isUpdateStock = await _stockInfoRepository.UpdateDataAsync(stock);
+ }
+ else
+ {
+ // 娣诲姞搴撳瓨
+ isUpdateStock = await _stockInfoRepository.AddDataNavAsync(stock);
+ }
// 娣诲姞鍘嗗彶浠诲姟
var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
@@ -630,13 +611,13 @@
// 鎻愪氦鎴栧洖婊氫簨鍔�
if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc)
{
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊搴撳瓨锛歿isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊鎴栨坊鍔犲簱瀛橈細{isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
_unitOfWorkManage.CommitTran();
return true;
}
else
{
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"鏁版嵁澶勭悊澶辫触,璇锋鏌ユ暟鎹槸鍚︽纭�,鏁版嵁鍥炴粴銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊搴撳瓨锛歿isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
+ LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"鏁版嵁澶勭悊澶辫触,璇锋鏌ユ暟鎹槸鍚︽纭�,鏁版嵁鍥炴粴銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊搴撳瓨锛歿isUpdateStock},淇敼绉诲簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
_unitOfWorkManage.RollbackTran();
return false;
}
@@ -661,25 +642,28 @@
/// <returns></returns>
private async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input, int areaId, Dt_Task task)
{
+ // 鍒涘缓WebResponseContent瀵硅薄
WebResponseContent content = new WebResponseContent();
+ // 瀹氫箟鍙橀噺
string toAddress;
int taskState;
string original = task.CurrentAddress;
DtLocationInfo location = new DtLocationInfo();
int beforeStatus = 0;
+ // 鏍规嵁浠诲姟绫诲瀷鍒ゆ柇鏄嚭搴撲换鍔¤繕鏄叆搴撲换鍔�
if (input.Type == (int)TaskTypeEnum.Outbound)
{
// 澶勭悊鍑哄簱浠诲姟
toAddress = await GetRoadWayAsync(areaId, task.Roadway, input.Direction, input.Area, input.Type);
- taskState = (int)OutTaskStatusEnum.SC_OutFinish;
+ taskState = (int)TaskOutStatusEnum.SC_OutFinish;
}
else
{
// 澶勭悊鍏ュ簱浠诲姟
location = await GetLocationDistributeAsync(areaId, task.Roadway);
toAddress = location.LocationCode;
- taskState = (int)InTaskStatusEnum.Line_InFinish;
+ taskState = (int)TaskInStatusEnum.Line_InFinish;
beforeStatus = location.LocationStatus;
// 鏇存柊璐т綅淇℃伅
@@ -693,17 +677,21 @@
task.NextAddress = toAddress;
task.TaskState = taskState;
+ // 寮�濮嬩簨鍔�
_unitOfWorkManage.BeginTran();
+ // 瀹氫箟鍙橀噺
bool isUpdateLo = true;
bool isUpdateChange = true;
// 灏濊瘯鏇存柊浠诲姟
bool isResult = await BaseDal.UpdateDataAsync(task);
- bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, original, input.Position, InTaskStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));
+ bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, original, input.Position, TaskInStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));
if (input.Type != (int)TaskTypeEnum.Outbound)
{
+ // 鍒涘缓LocationChangeRecordDto瀵硅薄
LocationChangeRecordDto changeRecordDto = new LocationChangeRecordDto()
{
+ // 璁剧疆鍙橀噺
AfterStatus = location.LocationStatus,
BeforeStatus = beforeStatus,
TaskNum = task.TaskNum.Value,
@@ -711,17 +699,20 @@
LocationCode = location.LocationCode,
ChangeType = (int)StatusChangeTypeEnum.AutomaticStorage,
};
+ // 鏇存柊浣嶇疆鐘舵��
isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
isUpdateLo = await _locationRepository.UpdateDataAsync(location);
}
if (isResult && isUpdateLo && isTaskDetail)
{
+ // 鎻愪氦浜嬪姟
_unitOfWorkManage.CommitTran();
content.OK(data: task);
}
else
{
+ // 鍥炴粴浜嬪姟
_unitOfWorkManage.RollbackTran();
content.Error("鏇存柊浠诲姟澶辫触");
}
@@ -754,7 +745,7 @@
OrderNo = null,
PalletCode = input.PalletCode,
SourceAddress = input.Position,
- TaskState = (int)InTaskStatusEnum.InNew,
+ TaskState = (int)TaskInStatusEnum.InNew,
TaskType = (int)TaskTypeEnum.Inbound,
TaskNum = await BaseDal.GetTaskNo(),
Creater = "Systeam"
@@ -765,9 +756,23 @@
if (isResult)
{
task.TaskId = taskId;
- isResult = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(input.PalletCode, input.Position, ToAddress, InTaskStatusEnum.InNew.GetIntegralRuleTypeEnumDesc()));
+ isResult = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(input.PalletCode, input.Position, ToAddress, TaskInStatusEnum.InNew.GetIntegralRuleTypeEnumDesc()));
if (isResult)
- content.OK(data: task);
+ {
+ WMSTaskDTO taskDTO = new WMSTaskDTO()
+ {
+ TaskNum = 0,
+ Grade = 1,
+ PalletCode = DateTime.Now.ToString("MMddHHmmss"),
+ RoadWay = task.Roadway,
+ SourceAddress = "001-001-001",
+ TargetAddress = task.Roadway,
+ TaskState = (int)TaskInStatusEnum.InNew,
+ Id = 0,
+ TaskType = (int)TaskInboundTypeEnum.Inbound,
+ };
+ content.OK(data: taskDTO);
+ }
else
content.Error("娣诲姞浠诲姟澶辫触");
}
--
Gitblit v1.9.3