From a4333018fea664d61608b314f2a571905077aef3 Mon Sep 17 00:00:00 2001
From: 刘磊 <1161824510@qq.com>
Date: 星期二, 05 八月 2025 15:31:00 +0800
Subject: [PATCH] 同步
---
项目代码/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs | 292 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 145 insertions(+), 147 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 d87023b..d57a2d1 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"
@@ -5,10 +5,12 @@
using System.Diagnostics;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
+using WIDESEA_Comm.WCSInterface.Requst;
using WIDESEA_Core.Const;
using WIDESEA_DTO.WMS;
using WIDESEA_IServices;
using WIDESEA_IStoragIntegrationServices;
+using WIDESEA_StoragIntegrationServices;
using WIDESEAWCS_BasicInfoRepository;
using WIDESEAWCS_Model.Models;
using WIDESEAWCS_QuartzJob.Models;
@@ -28,19 +30,21 @@
private readonly IDt_StationManagerRepository _stationManagerRepository;
private readonly ISys_ConfigService _configService;
private readonly IDt_PalletStockInfoRepository _palletStockInfoRepository;
+ private readonly IDt_PalletStockInfoDetailRepository _palletStockInfoDetailRepository;
+ private readonly IDt_PalletStockInfo_htyRepository _palletStockInfo_HtyRepository;
+ private readonly IBoxingInfoRepository _boxingInfoRepository;
+
+ public static string AGV_Interface = "http://192.168.1.195:10200/";
public Dt_TaskService(IDt_TaskRepository BaseDal,
IUnitOfWorkManage unitOfWorkManage,
- IDt_OutOrderRepository outOrderRepository,
- IStockInfoRepository stockInfoRepository,
IDt_Task_HtyRepository task_HtyRepository,
IMapper mapper,
ILocationInfoRepository locationRepository,
ITaskExecuteDetailRepository taskExecuteDetailRepository,
ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
- IStockInfoDetailRepository stockInfoDetailRepository,
IDt_StationManagerRepository stationManagerRepository,
- ISys_ConfigService configService, IDt_PalletStockInfoRepository palletStockInfoRepository) : base(BaseDal)
+ ISys_ConfigService configService, IDt_PalletStockInfoRepository palletStockInfoRepository, IDt_PalletStockInfo_htyRepository palletStockInfo_HtyRepository, IBoxingInfoRepository boxingInfoRepository, IDt_PalletStockInfoDetailRepository palletStockInfoDetailRepository) : base(BaseDal)
{
_unitOfWorkManage = unitOfWorkManage;
@@ -52,12 +56,14 @@
_stationManagerRepository = stationManagerRepository;
_configService = configService;
_palletStockInfoRepository = palletStockInfoRepository;
+ _palletStockInfo_HtyRepository = palletStockInfo_HtyRepository;
+ _boxingInfoRepository = boxingInfoRepository;
+ _palletStockInfoDetailRepository = palletStockInfoDetailRepository;
}
#region 澶栭儴鎺ュ彛鏂规硶
#region 鍏ュ簱浠诲姟瀹屾垚
-
/// <summary>
/// 瀹屾垚鍏ュ簱浠诲姟
/// </summary>
@@ -70,8 +76,7 @@
try
{
- // 鑾峰彇MES淇℃伅鍜岀洰鏍囦綅缃俊鎭�
- //var mes_Wheels = await _InWheels_MesRepository.QueryFirstNavAsync(x => x.Wheels_Num == task.PalletCode);
+ // 鑾峰彇搴撲綅淇℃伅
var locationInf = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
int lastStatus = locationInf.LocationStatus;
@@ -81,14 +86,24 @@
// 鍒涘缓鍘嗗彶浠诲姟瀹炰緥妯″瀷
var taskHty = CreateHistoricalTask(task);
+ //鑾峰彇缁勭洏淇℃伅
+ var boxinginfo = await _boxingInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
+
// 鏍规嵁鍒涘缓搴撳瓨瀹炰緥妯″瀷
+ var boxDetail = boxinginfo.BoxingInfoDetails.Adapt<List<Dt_PalletStockInfoDetail>>();
Dt_PalletStockInfo palletStockInfo = new Dt_PalletStockInfo
{
-
+ CreateDate = DateTime.Now,
+ Creater = task.Creater,
+ LocationCode = task.TargetAddress,
+ StockStatus = 2,
+ PalletCode = task.PalletCode,
+ AreaCode = task.Roadway,
+ StockInfoDetails = boxDetail
};
// 鎵ц鏁版嵁搴撲簨鍔�
- bool isResult = await ExecuteTransaction(palletStockInfo, taskHty, locationInf, task.TaskId);
+ bool isResult = await ExecuteTransaction(palletStockInfo, taskHty, locationInf, task.TaskId, boxinginfo);
if (isResult)
{
_locationStatusChangeRecordRepository.AddLocationStatusChangeRecord(locationInf, lastStatus, (int)StatusChangeTypeEnum.AutomaticStorage, task.TaskNum);
@@ -111,28 +126,43 @@
#endregion 鍏ュ簱浠诲姟瀹屾垚
#region 鍑哄簱浠诲姟瀹屾垚
- public async Task<WebResponseContent> CompleteStackTaskAsync(Dt_Task task, Dt_PalletStockInfo stock)
+ public async Task<WebResponseContent> CompleteStackTaskAsync(Dt_Task task)
{
WebResponseContent content = new WebResponseContent();
try
{
// 鏇存柊搴撲綅鐘舵�佷笌浠诲姟鐘舵��
- //(var loc, var tas) = UpdateStockAndTaskStatus(stock, task);
- //var taskHty = task.Adapt<Dt_Task_Hty>();
- //taskHty.FinishTime = DateTime.Now;
- //taskHty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
+ var stock = _palletStockInfoRepository.QueryFirst(x => x.PalletCode == task.PalletCode);
- //Dt_WheelsStock_hty stockInfo_Hty = stock.Adapt<Dt_WheelsStock_hty>();
- //stockInfo_Hty.FinishWheelDate = DateTime.Now;
- //stockInfo_Hty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
+ (var loc, var tas) = UpdateStockAndTaskStatus(stock, task);
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ taskHty.FinishTime = DateTime.Now;
+ taskHty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
- //// 浜嬪姟澶勭悊
- //await _unitOfWorkManage.UseTranAsync(async () =>
- //{
- // var isLocationUpdate = await _locationRepository.UpdateDataAsync(loc); //鏇存柊搴撲綅
- // //var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(task.TaskId); //鍒犻櫎浠诲姟
- // var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0; //鍔犲叆鍘嗗彶浠诲姟
- //});
+ Dt_PalletStockInfo_hty stockInfo_Hty = stock.Adapt<Dt_PalletStockInfo_hty>();
+ stockInfo_Hty.FinishTime = DateTime.Now;
+ stockInfo_Hty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
+
+ var boxinfo = _boxingInfoRepository.QueryFirst(x => x.PalletCode == task.PalletCode);
+
+ // 浜嬪姟澶勭悊
+ await _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ var isLocationUpdate = await _locationRepository.UpdateDataAsync(loc); //鏇存柊搴撲綅
+ var isPalletHty = await _palletStockInfo_HtyRepository.AddDataAsync(stockInfo_Hty); //娣诲姞鍘嗗彶搴撳瓨璁板綍
+ //var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(task.TaskId); //鍒犻櫎浠诲姟
+ await BaseDal.UpdateDataAsync(task); //鍙栨秷鍒犻櫎浠诲姟锛屾敼涓哄畬鎴愮姸鎬侊紱骞禬MS鐣岄潰鐢变汉宸ョ‘璁ゅ畬鎴�
+ var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0; //鍔犲叆鍘嗗彶浠诲姟
+ var isDelete = await _palletStockInfoRepository.DeleteDataAsync(stock); //鍒犻櫎搴撳瓨
+ await DeleteStockInfoDetailsAsync(stock.StockInfoDetails); //鍒犻櫎搴撳瓨鏄庣粏
+ //if (boxinfo != null)
+ //{
+ // var isDeleteBoxing = await _boxingInfoRepository.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxinfo.Id)
+ // .Include(x => x.BoxingInfoDetails)
+ // .ExecuteCommandAsync(); //鍒犻櫎缁勭洏
+ //}
+
+ });
return content.OK("浠诲姟瀹屾垚鎴愬姛", task.Remark);
}
@@ -143,7 +173,7 @@
}
}
- private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(Dt_WheelsStock stock, Dt_Task task)
+ private (DtLocationInfo, Dt_Task) UpdateStockAndTaskStatus(Dt_PalletStockInfo stock, Dt_Task task)
{
var location = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
int lastStatus = location.LocationStatus;
@@ -184,22 +214,18 @@
// 楠岃瘉搴撳瓨鏄惁瀛樺湪
- var stock = await _palletStockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
+ //var stock = await _palletStockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
// 鏍规嵁浠诲姟绫诲瀷璋冪敤鐩稿簲鐨勫畬鎴愪换鍔℃柟娉�
switch (task.TaskType)
{
case (int)TaskInboundTypeEnum.Inbound:
- case (int)TaskInboundTypeEnum.InWheels:
- case (int)TaskInboundTypeEnum.InBrake:
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍏ュ簱浠诲姟", "");
return await CompleteInboundTaskAsync(task);
case (int)TaskOutboundTypeEnum.Outbound:
- case (int)TaskOutboundTypeEnum.OutBrake:
- case (int)TaskOutboundTypeEnum.OutWheels:
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍑哄簱浠诲姟", "");
- return await CompleteStackTaskAsync(task, stock);
+ return await CompleteStackTaskAsync(task);
default:
return content.Error("浠诲姟绫诲瀷涓嶅瓨鍦�");
}
@@ -208,11 +234,6 @@
#endregion 浠诲姟瀹屾垚
#region 璇锋眰浠诲姟鍏ュ簱
-
- #region
-
- #endregion 璇锋眰浠诲姟鍏ュ簱
-
/// <summary>
/// 鏇存柊浠诲姟璐т綅
/// </summary>
@@ -227,7 +248,7 @@
if (task == null)
return content.Error($"鏆傛湭鎵惧埌銆恵input.PalletCode}銆戠殑浠诲姟");
- return content = await UpdateExistingTask(input, task);
+ return content; //= await UpdateExistingTask(input, task);
}
catch (Exception err)
{
@@ -237,29 +258,6 @@
#endregion 澶栭儴鎺ュ彛鏂规硶
- #region 璇锋眰鍑哄簱锛堝疄鐩橈級
-
-
- /// <summary>
- /// 鍒涘缓浠诲姟DTO
- /// </summary>
- private WMSTaskDTO CreateTaskDTO(Dt_Task task)
- {
- return new WMSTaskDTO
- {
- TaskNum = task.TaskNum.Value,
- Grade = task.Grade.Value,
- PalletCode = task.PalletCode,
- RoadWay = task.Roadway,
- SourceAddress = task.SourceAddress,
- TargetAddress = task.TargetAddress,
- TaskState = task.TaskState.Value,
- Id = 0,
- TaskType = task.TaskType
- };
- }
-
- #endregion 璇锋眰鍑哄簱锛堝疄鐩�&绌虹洏锛�
#region 浠诲姟鐘舵�佹洿鏀�
@@ -328,9 +326,9 @@
return content.Error("鏈煡璇㈠埌瀵瑰簲鐨勫簱瀛樹俊鎭�");
}
- if (stockInfo.StockStatus != 1) return content.Error("鎸囧畾澶辫触锛氬綋鍓嶇姸鎬佷笉鍏佽鎸囧畾鍑哄簱");
+ if (stockInfo.StockStatus != 2) return content.Error("鎸囧畾澶辫触锛氬綋鍓嶇姸鎬佷笉鍏佽鎸囧畾鍑哄簱");
- stockInfo.StockStatus = 4;
+ stockInfo.StockStatus = 3;
//鏌ヨ搴撲綅鏄惁閿佸畾锛�
var location = _locationRepository.QueryFirst(x => x.LocationCode == stockInfo.LocationCode);
@@ -344,73 +342,85 @@
{
return content.Error($"銆恵palletCode}銆戝凡瀛樺湪浠诲姟");
}
- // var stationInfo = _stationManagerRepository.QueryFirst(x => x.stationChildCode == station);
+
+ var stationInfo = _stationManagerRepository.QueryFirst(x => x.stationChildCode == station);
+
// 鍒涘缓骞舵坊鍔犱换鍔″埌鏁版嵁搴�
+ string agvId = Guid.NewGuid().ToString().Replace("-", "").Take(16);
task = new Dt_Task
{
Grade = 1,
- Roadway = "SC1",
- TargetAddress = station,
+ Roadway = stationInfo.Roadway,
+ TargetAddress = stationInfo.stationLocation,
Dispatchertime = DateTime.Now,
MaterialNo = "",
- NextAddress = "2010",
+ NextAddress = stationInfo.stationLocation,
OrderNo = null,
PalletCode = stockInfo.PalletCode,
SourceAddress = stockInfo.LocationCode,
CurrentAddress = stockInfo.LocationCode,
TaskState = (int)TaskOutStatusEnum.OutNew,
- TaskType = (int)TaskOutboundTypeEnum.OutWheels,
+ TaskType = (int)TaskOutboundTypeEnum.Outbound,
TaskNum = BaseDal.GetTaskNo().Result,
Creater = "System",
CreateDate = DateTime.Now,
TaskId = 0,
- //task_bak1 = JsonConvert.SerializeObject(checkInfo)
+ AGVtaskId = agvId
};
- // 鍒涘缓浠诲姟浼犺緭鐢ㄧ殑DTO瀵硅薄
- var taskDTO = CreateTaskDTO(task);
- // 鑾峰彇WMS IP鍦板潃鐢ㄤ簬鍙戦�佷换鍔¤姹�
- var wmsIpAddress = GetWCSIpReceiveTask();
- if (wmsIpAddress == null)
+ addtask schedulingTask = new addtask
{
- throw new InvalidOperationException("WMS IP 鏈厤缃�");
- }
+ task_id = task.AGVtaskId,
+ task_type = task.TaskType == (int)TaskTypeEnum.Inbound ? "push" : "pop",
+ work_begin = task.SourceAddress,
+ work_end = task.TargetAddress
+ };
- var tasks = new List<WMSTaskDTO>() { taskDTO };
- // 鍙戦�佷换鍔¤姹傚埌WMS
- var result = HttpHelper.Post(wmsIpAddress, tasks.ToJsonString());
+ string address = AGV_Interface + "add_task";
+
+ string result = HttpsClient.PostAsync(address, schedulingTask.ToDictionary()).Result;
+
content = JsonConvert.DeserializeObject<WebResponseContent>(result);
- if (content.Status)
+
+ if (content.ack != 0)
{
- // 娣诲姞浠诲姟鍒版暟鎹簱
- BaseDal.AddData(task);
- // 鏇存柊搴撲綅浣嶇疆鐘舵�佷负涓嶅彲鐢�
- _locationRepository.UpdateData(location);
- _palletStockInfoRepository.UpdateData(stockInfo);
+ Console.WriteLine($"璇锋眰RCS寮傚父锛歿content.msg}");
+ LogFactory.GetLog("涓嬪彂AGV浠诲姟").Info(true, $"\r\r--------------------------------------");
+ LogFactory.GetLog("涓嬪彂AGV浠诲姟").Info(true, $"璇锋眰鍙傛暟锛歿schedulingTask.ToJsonString()}");
+ LogFactory.GetLog("涓嬪彂AGV浠诲姟").Info(true, $"鍝嶅簲鍙傛暟锛歿content.ToJsonString()}");
+ throw new Exception(content.msg);
}
+
+ _unitOfWorkManage.BeginTran();
+ // 娣诲姞浠诲姟鍒版暟鎹簱
+ BaseDal.AddData(task);
+ // 鏇存柊搴撲綅浣嶇疆鐘舵�佷负涓嶅彲鐢�
+ _locationRepository.UpdateData(location);
+ _palletStockInfoRepository.UpdateData(stockInfo);
+
+ _unitOfWorkManage.CommitTran();
}
catch (Exception ex)
{
+ _unitOfWorkManage.RollbackTran();
Console.WriteLine($"鍙戠敓寮傚父: {ex.Message}");
content.Error(ex.Message);
}
-
return content;
}
- private string GetWCSIpReceiveTask()
+ private string GetAGVIpReceiveTask()
{
- //var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
- //var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;
- //var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveTask)?.ConfigValue;
- //if (wmsBase == null || ipAddress == null)
- //{
- // return null;
- //}
- //return wmsBase + ipAddress;
- return null;
+ var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
+ var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.AGVIPAddress)?.ConfigValue;
+ var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.addTask)?.ConfigValue;
+ if (wmsBase == null || ipAddress == null)
+ {
+ return null;
+ }
+ return wmsBase + ipAddress;
}
#endregion 鎸囧畾浠诲姟鍑哄簱
@@ -601,6 +611,20 @@
#region private 鍐呴儴鏂规硶
+
+ private async Task DeleteStockInfoDetailsAsync(IEnumerable<Dt_PalletStockInfoDetail> details)
+ {
+ if (details != null)
+ {
+ var ids = details.Select(x => (object)x.Id).ToArray();
+ var isStockDetailUpdated = await _palletStockInfoDetailRepository.DeleteDataByIdsAsync(ids);
+ if (!isStockDetailUpdated)
+ {
+ throw new Exception("搴撳瓨璇︽儏淇℃伅鏇存柊澶辫触");
+ }
+ }
+ }
+
/// <summary>
/// 鍒涘缓鍘嗗彶浠诲姟璁板綍
/// </summary>
@@ -626,27 +650,6 @@
return taskHty;
}
- /// <summary>
- /// 鏇存柊搴撳瓨浣嶇疆
- /// </summary>
- /// <param name="stock">搴撳瓨瀵硅薄</param>
- /// <param name="toLocation">鐩爣浣嶇疆</param>
- // 鏇存柊搴撳瓨鍜屼綅缃俊鎭�
- private (Dt_WheelsStock, DtLocationInfo, DtLocationInfo) UpdateStockLocation(Dt_WheelsStock stock, Dt_Task task)
- {
- //淇敼鏉ユ簮搴撲綅鍜� 鐩爣搴撲綅鐘舵��
- var fromLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
- fromLocation.LocationStatus = (int)LocationEnum.Free;
- var toLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.TargetAddress && x.RoadwayNo == task.Roadway);
- toLocation.LocationStatus = (int)LocationEnum.InStock;
-
- // 灏嗗簱瀛樹綅缃缃负鐩爣浣嶇疆
- stock.Wheels_Location = task.TargetAddress;
-
- // 杩斿洖鏇存柊鍚庣殑搴撳瓨鍜屼綅缃俊鎭�
- return (stock, fromLocation, toLocation);
- }
-
#region 鎵ц鏁版嵁搴撲簨鍔�
/// <summary>
/// 鎵ц鏁版嵁搴撲簨鍔�
@@ -655,30 +658,25 @@
/// <param name="taskHty">鍘嗗彶浠诲姟瀵硅薄</param>
/// <param name="taskId">浠诲姟ID</param>
/// <returns></returns>
- private async Task<bool> ExecuteTransaction(Dt_PalletStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId /*Dt_InWheels_mes inWheels_Mes = null*/)
+ private async Task<bool> ExecuteTransaction(Dt_PalletStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId, DtBoxingInfo boxingInfo)
{
_unitOfWorkManage.BeginTran();
try
{
- var isUpdateStock = false;
- var isDeleteWheelsMes = false;
-
-
+ var isUpdateStock = true;
+ var isDeleteBoxing = true;
// 娣诲姞搴撳瓨
- isUpdateStock = _palletStockInfoRepository.AddData(stock) > 0;
- //if (inWheels_Mes != null)
- //{
- // isDeleteWheelsMes = _InWheels_MesRepository.DeleteData(inWheels_Mes);
+ isUpdateStock = await _palletStockInfoRepository.AddDataNavAsync(stock);
- // //var wheels_Mes_Hty = inWheels_Mes.Adapt<Dt_InWheels_mes_hty>();
-
- // //wheels_Mes_Hty.Wheels_CurrentStatue = "2";
- // //wheels_Mes_Hty.FinishDate = DateTime.Now;
- // //wheels_Mes_Hty.OperateType = (int)OperateTypeEnum.鑷姩瀹屾垚;
-
- // //_InWheels_Mes_HtyRepository.AddData(wheels_Mes_Hty);
- //}
-
+ //鍒犻櫎缁勭洏鏁版嵁
+ if (boxingInfo != null)
+ {
+ boxingInfo.CurrentStatue = 5;
+ isDeleteBoxing = await _boxingInfoRepository.Db.DeleteNav<DtBoxingInfo>(x => x.Id == boxingInfo.Id)
+ .Include(x => x.BoxingInfoDetails)
+ .ExecuteCommandAsync();
+ }
+ //var box = _boxingInfoRepository.dele(boxingInfo);
// 娣诲姞鍘嗗彶浠诲姟
var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
@@ -690,7 +688,7 @@
var isTaskDelete = await Delete(taskId);
// 鎻愪氦鎴栧洖婊氫簨鍔�
- if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteWheelsMes)
+ if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc && isDeleteBoxing)
{
LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "浠诲姟瀹屾垚", $"浜嬪姟澶勭悊瀹屾垚,鎻愪氦浜嬪姟銆傛坊鍔犲巻鍙蹭换鍔★細{isTaskHtyAdd},鍒犻櫎浠诲姟鏁版嵁锛歿isTaskDelete},鏇存柊鎴栨坊鍔犲簱瀛橈細{isUpdateStock},淇敼鍏ュ簱鍓嶈揣浣嶇姸鎬侊細{isUpdateLoc}");
_unitOfWorkManage.CommitTran();
@@ -734,24 +732,24 @@
var content = new WebResponseContent();
// 鑾峰彇搴撲綅
- var location = RequestLocation(input);
- if (location == null)
- {
- return content.Error("鏃犳硶鑾峰彇璐т綅淇℃伅");
- }
+ //var location = RequestLocation(input);
+ //if (location == null)
+ //{
+ // return content.Error("鏃犳硶鑾峰彇璐т綅淇℃伅");
+ //}
- string toAddress = location.LocationCode;
- int taskState = (int)TaskInStatusEnum.Line_InFinish;
- int beforeStatus = location.LocationStatus;
- // 鏇存柊璐т綅淇℃伅
- location.LocationStatus = (int)LocationEnum.Lock;
+ //string toAddress = location.LocationCode;
+ //int taskState = (int)TaskInStatusEnum.Line_InFinish;
+ //int beforeStatus = location.LocationStatus;
+ //// 鏇存柊璐т綅淇℃伅
+ //location.LocationStatus = (int)LocationEnum.Lock;
// 鏇存柊浠诲姟淇℃伅
- MapTaskProperties(task, input, toAddress, taskState);
+ //MapTaskProperties(task, input, toAddress, taskState);
_unitOfWorkManage.BeginTran();
// 寮�濮嬩簨鍔�
- var isResult = await UpdateTaskAsync(task, location, beforeStatus);
+ var isResult = false; //await UpdateTaskAsync(task, location, beforeStatus);
if (!isResult)
{
_unitOfWorkManage.RollbackTran();
--
Gitblit v1.9.3