From d4b0b578752a1478f6c11b352fbb8d2bad1f9e1d Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期三, 22 十月 2025 17:18:49 +0800
Subject: [PATCH] 1
---
项目代码/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs | 1918 ++++++++++++++++++++++++++++++++++++++++++++++-------------
1 files changed, 1,485 insertions(+), 433 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 5e91b77..ede4e60 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"
@@ -1,18 +1,38 @@
-锘縰sing Mapster;
+锘縰sing AngleSharp.Dom;
+using log4net.Core;
+using Mapster;
using Masuit.Tools;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion.Internal;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
+using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup;
+using OfficeOpenXml.Table.PivotTable;
using SixLabors.Fonts.Tables.AdvancedTypographic;
using SqlSugar;
using System;
+using System.Collections.Generic;
+using System.Linq.Expressions;
+using System.Reflection;
+using System.Reflection.Metadata;
+using System.Security.Policy;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using WIDESEA_Cache;
+using WIDESEA_Common;
+using WIDESEA_Core.BaseRepository;
using WIDESEA_Core.Const;
+using WIDESEA_Core.Enums;
+using WIDESEA_DTO.ERP;
using WIDESEA_DTO.Location;
+using WIDESEA_DTO.Stock;
using WIDESEA_DTO.WMS;
+using WIDESEA_IOrderRepository;
using WIDESEA_IServices;
using WIDESEA_Model.Models;
+using WIDESEA_Model.Models.Basic;
+using WIDESEA_Model.Models.ERP;
using WIDESEAWCS_BasicInfoRepository;
using WIDESEAWCS_QuartzJob.Models;
+using static System.Collections.Specialized.BitVector32;
namespace WIDESEA_StorageTaskServices;
@@ -31,7 +51,8 @@
private readonly IDt_AreaInfoRepository _areaInfoRepository; //鍖哄煙
private readonly IDt_StationManagerRepository _stationManagerRepository;
private readonly ISys_ConfigService _configService;
- private readonly ISimpleCacheService _simpleCacheService;
+ private readonly IDt_OutboundOrderRepository _outorderRepository;
+ private readonly IDt_OutboundOrderDetailRepository _outorderdetailRepository;
public Dt_TaskService(IDt_TaskRepository BaseDal,
IUnitOfWorkManage unitOfWorkManage,
@@ -46,7 +67,8 @@
IStockInfoDetailRepository stockInfoDetailRepository,
IDt_StationManagerRepository stationManagerRepository,
ISys_ConfigService configService,
- ISimpleCacheService simpleCacheService) : base(BaseDal)
+ IDt_OutboundOrderRepository outorderRepository,
+ IDt_OutboundOrderDetailRepository outorderdetailRepository) : base(BaseDal)
{
_unitOfWorkManage = unitOfWorkManage;
_stockInfoRepository = stockInfoRepository;
@@ -60,7 +82,8 @@
_stockInfoDetailRepository = stockInfoDetailRepository;
_stationManagerRepository = stationManagerRepository;
_configService = configService;
- _simpleCacheService = simpleCacheService;
+ _outorderRepository = outorderRepository;
+ _outorderdetailRepository = outorderdetailRepository;
}
#region 澶栭儴鎺ュ彛鏂规硶
@@ -72,7 +95,33 @@
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);
+ task.TaskState = (int)TaskOutStatusEnum.OutFinish;
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ taskHty.FinishTime = DateTime.Now;
+ taskHty.OperateType = App.User.UserName != null ? (int)OperateTypeEnum.浜哄伐瀹屾垚 : (int)OperateTypeEnum.鑷姩瀹屾垚;
+ taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
+
+ //DtStockInfo_Hty stockInfo_Hty = stock.Adapt<DtStockInfo_Hty>();
+ //stockInfo_Hty.ModifyDate = DateTime.Now;
+ stock.ModifyDate = DateTime.Now;
+ stock.LocationCode = task.TargetAddress;
+ await _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ //await DeleteStockInfoAsync(stock.Id);
+ //await DeleteStockInfoDetailsAsync(stock.StockInfoDetails);
+ //await AddStockInfoHtyAsync(stockInfo_Hty);
+ _stockInfoRepository.UpdateData(stock);
+
+ UpdateLocationStatus(locationStart, LocationEnum.Free, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ UpdateLocationStatus(locationEnd, LocationEnum.InStock, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+
+ await DeleteTaskAsync(task.TaskId);
+ await AddTaskHtyAsync(taskHty);
+ });
+ content.OK("鍑哄簱瀹屾垚");
}
catch (Exception ex)
{
@@ -81,60 +130,7 @@
return content;
}
- private async Task DeleteStockInfoAsync(int stockId)
- {
- var isStockUpdated = await _stockInfoRepository.DeleteDataByIdAsync(stockId);
- if (!isStockUpdated)
- {
- throw new Exception("搴撳瓨淇℃伅鏇存柊澶辫触");
- }
- }
-
- private async Task AddStockInfoHtyAsync(DtStockInfo_Hty dtStock)
- {
- var isStockAdd = await SqlSugarHelper.DbWMS.InsertNav(dtStock).IncludesAllFirstLayer().ExecuteCommandAsync();
- if (!isStockAdd)
- {
- throw new Exception("搴撳瓨鍘嗗彶淇℃伅娣诲姞澶辫触");
- }
- }
-
- private async Task UpdateLocationAsync(DtLocationInfo info)
- {
- var isStockUpdated = await _locationRepository.UpdateDataAsync(info);
- if (!isStockUpdated)
- {
- throw new Exception("搴撲綅淇℃伅鏇存柊澶辫触");
- }
- }
-
- private async Task DeleteStockInfoDetailsAsync(IEnumerable<DtStockInfoDetail> details)
- {
- var ids = details.Select(x => (object)x.Id).ToArray();
- var isStockDetailUpdated = await _stockInfoDetailRepository.DeleteDataByIdsAsync(ids);
- if (!isStockDetailUpdated)
- {
- throw new Exception("搴撳瓨璇︽儏淇℃伅鏇存柊澶辫触");
- }
- }
-
- private async Task DeleteTaskAsync(int taskId)
- {
- var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(taskId);
- if (!isTaskUpdated)
- {
- throw new Exception("浠诲姟淇℃伅鏇存柊澶辫触");
- }
- }
-
- private async Task AddTaskHtyAsync(Dt_Task_Hty taskHty)
- {
- var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
- if (!isTaskAdd)
- {
- throw new Exception("鍘嗗彶浠诲姟淇℃伅娣诲姞澶辫触");
- }
- }
+
#endregion 鍑哄簱浠诲姟瀹屾垚
@@ -150,17 +146,27 @@
WebResponseContent content = new WebResponseContent();
try
{
- // 鏇存柊璐т綅鍜屽簱瀛樹俊鎭�
- (DtStockInfo updateStock, DtLocationInfo locationInForm, DtLocationInfo locationInfoTo) = UpdateStockLocation(stock, task);
- var taskHty = CreateHistoricalTask(task);
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "绉诲簱浠诲姟瀹屾垚", $"璐т綅鍦板潃锛歿task.TargetAddress},淇敼鍚庡簱瀛樻暟鎹細{JsonConvert.SerializeObject(updateStock)}锛屽師鍏堣揣浣嶆暟鎹細{locationInForm}");
+ var locationStart = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.SourceAddress);
+ var locationEnd = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
- // 鎵ц鏁版嵁搴撲簨鍔�
- bool isResult = false;
- if (isResult)
- content.OK("绉诲簱浠诲姟瀹屾垚鎴愬姛");
- else
- content.Error("绉诲簱浠诲姟瀹屾垚澶辫触");
+ task.TaskState = (int)TaskOutStatusEnum.OutFinish;
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ taskHty.FinishTime = DateTime.Now;
+ 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;
+
+ await _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ //UpdateLocationStatus(locationStart, LocationEnum.Free, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+ UpdateLocationStatus(locationEnd, LocationEnum.InStock, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticRelocation);
+ _stockInfoRepository.UpdateData(stock);
+ await DeleteTaskAsync(task.TaskId);
+ await AddTaskHtyAsync(taskHty);
+ });
+ content.OK("绉诲簱瀹屾垚");
}
catch (Exception err)
{
@@ -180,21 +186,103 @@
/// <returns>杩斿洖缁撴灉闆�</returns>
public async Task<WebResponseContent> CompleteInboundTaskAsync(Dt_Task task)
{
- // 鍒濆鍖栧搷搴斿唴瀹�
WebResponseContent content = new WebResponseContent();
try
{
-
+ var stock = await _stockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode && x.StockStatus == (int)StockStateEmun.缁勭洏鏆傚瓨);
+ var locationStart = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.SourceAddress);
+ var locationEnd = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
+
+ if (stock == null)
+ {
+ return content.Error("鏈壘鍒扮粍鐩樻暟鎹�");
+ }
+ stock.LocationCode = task.TargetAddress;
+ stock.StockStatus = (int)StockStateEmun.宸插叆搴�;
+
+ task.TaskState = (int)TaskInStatusEnum.InFinish;
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ 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 _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ await _stockInfoRepository.UpdateDataAsync(stock);
+ await DeleteTaskAsync(task.TaskId);
+ await AddTaskHtyAsync(taskHty);
+ UpdateLocationStatus(locationStart, LocationEnum.Free, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+ UpdateLocationStatus(locationEnd, LocationEnum.InStock, task.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+ });
+ content.OK("鍏ュ簱瀹屾垚");
}
catch (Exception ex)
{
- content.Error(ex.Message);
+ return content.Error(ex.Message);
}
return content;
}
#endregion 鍏ュ簱浠诲姟瀹屾垚
+
+ #region AGV鎼繍浠诲姟瀹屾垚
+ public async Task<WebResponseContent> CompleteCarryTaskAsync(Dt_Task task,DtStockInfo stockInfo)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var Sourcelocation = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.SourceAddress);
+ var Targetlocation = await _locationRepository.QueryFirstAsync(x => x.LocationCode == task.TargetAddress);
+
+ //UpdateLocationStatus(Sourcelocation, LocationEnum.Free);
+ //UpdateLocationStatus(Targetlocation, LocationEnum.InStock);
+
+ task.TaskState = (int)TaskAGVCarryStatusEnum.CarryFinish;
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ 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 _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ await DeleteTaskAsync(task.TaskId);
+ await AddTaskHtyAsync(taskHty);
+ });
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ return content;
+ }
+
+ #endregion
+
+ #region AGV璺ㄦゼ灞備换鍔″畬鎴�
+ public async Task<WebResponseContent> CompleteAcrossFloorTaskAsync(Dt_Task task, DtStockInfo stockInfo)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ task.TaskState = (int)TaskAcrossFloorStatusEnum.CarryFinish;
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ 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 _unitOfWorkManage.UseTranAsync(async () =>
+ {
+ await DeleteTaskAsync(task.TaskId);
+ await AddTaskHtyAsync(taskHty);
+ });
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ return content;
+ }
+
+ #endregion
#region 浠诲姟瀹屾垚
@@ -222,68 +310,136 @@
// 楠岃瘉搴撳瓨鏄惁瀛樺湪
var stock = await _stockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == task.PalletCode);
- // 鏍规嵁浠诲姟绫诲瀷璋冪敤鐩稿簲鐨勫畬鎴愪换鍔℃柟娉�
- switch (task.TaskType)
+
+ if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
{
- case (int)TaskInboundTypeEnum.Inbound:
- case (int)TaskInboundTypeEnum.InTray:
- case (int)TaskInboundTypeEnum.InNG:
- case (int)TaskInboundTypeEnum.InQuality:
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍏ュ簱浠诲姟", "");
- return await CompleteInboundTaskAsync(task);
-
- case (int)TaskOutboundTypeEnum.OutTray:
- case (int)TaskOutboundTypeEnum.Outbound:
- case (int)TaskOutboundTypeEnum.OutNG:
-
- LogFactory.GetLog("浠诲姟瀹屾垚").InfoFormat(true, "鍑哄簱浠诲姟", "");
- return await CompleteOutboundTaskAsync(task, stock);
-
- case (int)TaskRelocationTypeEnum.Relocation:
- return await CompleteTransferTaskAsync(task, stock);
- default:
- return content.Error("浠诲姟绫诲瀷涓嶅瓨鍦�");
+ return await CompleteOutboundTaskAsync(task, stock);
+ }
+ else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
+ {
+ return await CompleteInboundTaskAsync(task);
+ }
+ else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.RelocationGroup)
+ {
+ return await CompleteTransferTaskAsync(task, stock);
+ }
+ else
+ {
+ return content.Error("鏈壘鍒颁换鍔＄被鍨�");
}
}
#endregion 浠诲姟瀹屾垚
+ #region 鍙栨秷浠诲姟
+ public WebResponseContent TaskCancel(int taskNum)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ Dt_Task task = BaseDal.QueryFirst(x => x.TaskNum == taskNum);
+ if (task == null)
+ {
+ return content = WebResponseContent.Instance.Error("鏈壘鍒颁换鍔′俊鎭�");
+ }
+ _unitOfWorkManage.BeginTran();
+ MethodInfo? methodInfo = GetType().GetMethod(((TaskTypeEnum)task.TaskType) + "TaskCancel");
+ if (methodInfo != null)
+ {
+ WebResponseContent? responseContent = (WebResponseContent?)methodInfo.Invoke(this, new object[] { task });
+ if (responseContent != null)
+ {
+ if (responseContent != null)
+ {
+
+ }
+ }
+ }
+ return content = WebResponseContent.Instance.Error("鏈壘鍒颁换鍔＄被鍨嬪搴斾笟鍔″鐞嗛�昏緫");
+ }
+ catch (Exception ex)
+ {
+ _unitOfWorkManage.RollbackTran();
+ return content = WebResponseContent.Instance.Error(ex.Message);
+ }
+ }
+ #endregion
+
#region 璇锋眰浠诲姟鍏ュ簱
- public async Task<WebResponseContent> RequestTaskAsync(RequestTaskDto input)
- {
- WebResponseContent content = new WebResponseContent();
-
- try
- {
-
- }
- catch (Exception err)
- {
- // 鏇磋缁嗙殑寮傚父澶勭悊锛屽彲浠ユ牴鎹紓甯哥被鍨嬭褰曚笉鍚岀殑閿欒鏃ュ織绛�
- content.Error(err.Message);
- Console.WriteLine(err.Message);
- LogFactory.GetLog($"璇锋眰鍏ュ簱寮傚父").Info(true, $"寮傚父淇℃伅銆恵err.Message}銆戝紓甯歌銆恵err.StackTrace}銆�");
- }
-
- return content;
- }
-
- /// <summary>
- /// 鏇存柊浠诲姟璐т綅
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- public async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input)
+ public async Task<WebResponseContent> RequestInboundTaskAsync(RequestTaskDto taskDto)
{
WebResponseContent content = new WebResponseContent();
try
{
- var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == input.PalletCode);
- if (task == null)
- return content.Error($"鏆傛湭鎵惧埌銆恵input.PalletCode}銆戠殑浠诲姟");
+ var stock = await _stockInfoRepository.QueryFirstNavAsync(x => x.PalletCode == taskDto.PalletCode && x.StockStatus == (int)StockStateEmun.缁勭洏鏆傚瓨);
+ if (stock == null)
+ {
+ return content.Error("鎵樼洏淇℃伅涓嶅瓨鍦紝璇风‘璁ゆ墭鐩樺凡缁勭洏鎴愬姛");
+ }
- return content = await UpdateExistingTask(input, task);
+ //foreach (var item in boxingInfo.BoxingInfoDetails)
+ //{
+ // var ERPStock = SqlSugarHelper.DBERP.Queryable<WMS_鐢ㄥ弸搴撳瓨涓�瑙堣〃_ST>().Where(x => x.浠撳簱鍚嶇О == item.Warehouse && x.鏂欏彿 == item.MaterielCode && x.鍝佸悕 == item.MaterielName).ToList().FirstOrDefault();
+ // if (ERPStock == null)
+ // {
+ // return content.Error($"缁勭洏鏁版嵁鏈湪ERP搴撳瓨鏁版嵁涓紝璇蜂汉宸ョ‘璁ゆ暟鎹槸鍚︽纭�");
+ // }
+ //}
+
+ var StartAddress = await _locationRepository.QueryFirstAsync(x => x.LocationCode == taskDto.Position);
+ if (StartAddress == null)
+ {
+ return content.Error("璧风偣搴撲綅鏈壘鍒�");
+ }
+ if (!LocationIsOutBound(StartAddress))
+ {
+ return content.Error($"璧风偣搴撲綅{StartAddress.LocationCode}鎼繍璺緞琚崰鐢紝璇蜂汉宸ョ‘璁ゅ啀涓嬪彂浠诲姟");
+ }
+ if (taskDto.AreaId != 0)
+ {
+ switch (taskDto.AreaId)
+ {
+ case 1:
+ return await InboundStakerArea(taskDto, StartAddress);
+ case 2:
+ case 3:
+ case 4:
+ case 5:
+ case 6:
+ return await InboundAGVCacheArea(taskDto, StartAddress, await GetAGVEmptyCacheLocation(taskDto.AreaId, StartAddress));
+ default:
+ return content.Error("璇烽�夋嫨姝ｇ‘鐨勫尯鍩熶俊鎭�");
+ }
+ }
+ else if (taskDto.TargetAddress != null)
+ {
+ var location = _locationRepository.QueryFirst(x => x.LocationCode == taskDto.TargetAddress);
+ if (location != null && location.LocationStatus == (int)LocationEnum.Free && location.EnalbeStatus == 1)
+ {
+ switch (location.AreaId)
+ {
+ case 1:
+ return await InboundStakerArea(taskDto, StartAddress);
+ case 2:
+ case 3:
+ case 4:
+ case 5:
+ case 6:
+ return await InboundAGVCacheArea(taskDto, StartAddress, location);
+ default:
+ return content.Error("璐т綅鍖哄煙鏈壘鍒�");
+ }
+ }
+ else
+ {
+ return content.OK("鐩爣搴撲綅涓嶅彲鐢�");
+ }
+ }
+ else
+ {
+ return content.OK("璇烽�夋嫨鍏ュ簱鍖哄煙鎴栫粓鐐瑰湴鍧�");
+ }
}
catch (Exception err)
{
@@ -291,114 +447,96 @@
}
}
- /// <summary>
- /// 绌烘墭鐩樺叆搴撶敵璇�
- /// </summary>
- /// <param name="input"></param>
- /// <returns></returns>
- public async Task<WebResponseContent> RequestTrayInTaskAsync(RequestTaskDto input)
+ public async Task<WebResponseContent> InboundStakerArea(RequestTaskDto taskDto,DtLocationInfo StartAddress)
{
WebResponseContent content = new WebResponseContent();
try
{
- content.OK();
- }
- catch (Exception ex)
- {
- content.Error(ex.Message);
- }
- return content;
- }
+ var station = _stationManagerRepository.QueryFirst(x => x.stationType == 1 && x.Roadway == "SC1");
+ Dt_Task taskNew = new Dt_Task
+ {
+ Grade = 1,
+ Roadway = "SC1",
+ TargetAddress = "SC1",
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = station.stationChildCode,
+ OrderNo = null,
+ PalletCode = taskDto.PalletCode,
+ SourceAddress = taskDto.Position,
+ CurrentAddress = taskDto.Position,
+ TaskState = (int)TaskInStatusEnum.InNew,
+ TaskType = (int)TaskInboundTypeEnum.Inbound,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ AGVTaskNum = GenerateUniqueId(),
+ Floor = "1F",
+ };
+ var taskDTO = CreateListTaskDTO(taskNew);
- #endregion 璇锋眰浠诲姟鍏ュ簱
+ BaseDal.AddData(taskNew);
- #region 璇锋眰鍑哄簱锛堝疄鐩�&绌虹洏锛�
-
- /// <summary>
- /// 璇锋眰鎵樼洏浠诲姟
- /// </summary>
- /// <param name="position">鐩爣浣嶇疆</param>
- /// <param name="tag">鎵樼洏绫诲瀷锛�1锛氬疄鐩橈紝2锛氱┖鐩橈級</param>
- /// <param name="areaCode">鍖哄煙缂栫爜</param>
- /// <param name="roadways">宸烽亾缂栫爜闆嗗悎</param>
- /// <returns>杩斿洖缁撴灉闆�</returns>
- public async Task<WebResponseContent> RequestTrayOutTaskAsync(string position, int tag, string areaCode, List<string> areaCodes, string productionLine)
- {
- WebResponseContent content = new WebResponseContent();
- try
- {
-
+ UpdateLocationStatus(StartAddress, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+ //UpdateLocationStatus(location, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
- // 杩斿洖鎴愬姛鍝嶅簲
- return content.OK();
+ //return content.OK();
+ return content = await SendWCSTask(taskDTO);
}
catch (Exception ex)
{
- // 璁板綍寮傚父淇℃伅骞舵姏鍑�
- LogFactory.GetLog("璇锋眰鎵樼洏浠诲姟").Error(true, ex);
- ConsoleHelper.WriteErrorLine("璇锋眰绌�/瀹炴墭鐩樹换鍔�" + ex.Message + "\r\n" + ex.StackTrace);
+ _unitOfWorkManage.RollbackTran();
return content.Error(ex.Message);
}
}
- /// <summary>
- /// 鍒涘缓浠诲姟瀹炰緥
- /// </summary>
- private Dt_Task CreateTask(DtStockInfo stockInfo, string position, int tag)
+ public async Task<WebResponseContent> InboundAGVCacheArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, DtLocationInfo location)
{
- return new Dt_Task
+ WebResponseContent content = new WebResponseContent();
+ try
{
- Grade = tag == 104 ? (stockInfo.LocationInfo.RoadwayNo.Contains("CWSC") ? 1 : 2) : (stockInfo.LocationInfo.RoadwayNo.Contains("CWSC") ? 2 : 1),
- Roadway = stockInfo.LocationInfo.RoadwayNo,
- TargetAddress = position,
- Dispatchertime = DateTime.Now,
- MaterialNo = "",
- NextAddress = position,
- OrderNo = null,
- PalletCode = stockInfo.PalletCode,
- SourceAddress = stockInfo.LocationCode,
- CurrentAddress = stockInfo.LocationCode,
- TaskState = (int)TaskOutStatusEnum.OutNew,
- TaskType = tag,
- TaskNum = BaseDal.GetTaskNo().Result,
- Creater = "System", // 淇鎷煎啓閿欒
- CreateDate = DateTime.Now,
- TaskId = 0,
- ProductionLine = stockInfo.ProductionLine,
- ProcessCode = stockInfo.ProcessCode,
- };
+ if (location == null)
+ {
+ return content.Error("璧风偣鏈畾涔夋垨缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
+ }
+ Dt_Task taskNew = new Dt_Task();
+ if (StartAddress.Floor != location.Floor)
+ {
+ taskNew= RequestAcrossFloorTask(StartAddress,location, (int)TaskInboundTypeEnum.Inbound,taskDto.PalletCode);
+ }
+ else
+ {
+ taskNew = RequestAGVCarryTask(StartAddress, location, (int)TaskInboundTypeEnum.Inbound, taskDto.PalletCode);
+ }
+
+ var taskDTO = CreateListTaskDTO(taskNew);
+ _unitOfWorkManage.BeginTran();
+
+ UpdateLocationStatus(StartAddress, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+ UpdateLocationStatus(location, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticInbound);
+
+ BaseDal.AddData(taskNew);
+
+ _unitOfWorkManage.CommitTran();
+ //return content.OK();
+ return content = await SendWCSTask(taskDTO);
+ }
+ catch (Exception ex)
+ {
+ _unitOfWorkManage.RollbackTran();
+ return content.Error(ex.Message);
+ }
}
+ #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,
- ProductionLine = task.ProductionLine,
- };
- }
-
- #endregion 璇锋眰鍑哄簱锛堝疄鐩�&绌虹洏锛�
-
- #region 浠诲姟鐘舵�佹洿鏀�
-
- /// <summary>
- /// 鏇存柊浠诲姟鐘舵��&鍑哄簱瑙ｇ洏
- /// </summary>
- /// <param name="taskNum"></param>
- /// <param name="taskState"></param>
+ /// <param name="input"></param>
/// <returns></returns>
public async Task<WebResponseContent> UpdateTaskStatus(int taskNum, int taskState)
{
@@ -409,7 +547,7 @@
if (task == null)
return content.Error("鏈壘鍒颁换鍔�");
- if (taskState == (int)TaskOutStatusEnum.Line_OutFinish || taskState == (int)TaskInStatusEnum.SC_InFinish)
+ if (taskState == (int)TaskOutStatusEnum.Line_OutFinish || taskState == (int)TaskInStatusEnum.SC_InFinish || taskState == (int)TaskRelocationStatusEnum.SC_RelocationFinish || taskState == (int)TaskAGVCarryStatusEnum.AGV_CarryFinish)
{
var taskHty = CreateHistoricalTask(task);
await _unitOfWorkManage.UseTranAsync(async () =>
@@ -440,11 +578,892 @@
return content;
}
- #endregion 浠诲姟鐘舵�佹洿鏀�
+ 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
+
+ #region 璇锋眰鍑哄簱
+ public async Task<WebResponseContent> OtherOutBoundTaskAsync(string palletCode)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ DtStockInfo stcok = await _stockInfoRepository.QueryFirstAsync(x => x.PalletCode == palletCode);
+ if (stcok == null)
+ {
+ return content.Error("鎵樼洏淇℃伅涓嶅瓨鍦紝璇风‘璁ゆ墭鐩樺凡鍏ュ簱鎴愬姛");
+ }
+ var location = await _locationRepository.QueryFirstAsync(x => x.LocationCode == stcok.LocationCode);
+ if (location.AreaId == 2)
+ {
+ return content.Error("璇ユ墭鐩樺簱瀛樺凡鍦ㄥ嚭搴撶紦瀛樺尯");
+ }
+ return await RequestOutboundTaskAsync(new RequestTaskDto { PalletCode = palletCode, AreaId = 2, Position = stcok.LocationCode ,TaskType = (int)TaskOutboundTypeEnum.OutOther });
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+
+ /// <summary>
+ /// 璇锋眰鍑哄簱浠诲姟
+ /// </summary>
+ /// <param name="taskDto"></param>
+ /// <returns></returns>
+ public async Task<WebResponseContent> RequestOutboundTaskAsync(RequestTaskDto taskDto)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ DtStockInfo stcok = await _stockInfoRepository.QueryFirstAsync(x => x.PalletCode == taskDto.PalletCode);
+ if (stcok == null)
+ {
+ return content.Error("鎵樼洏淇℃伅涓嶅瓨鍦紝璇风‘璁ゆ墭鐩樺凡鍏ュ簱鎴愬姛");
+ }
+
+ var StartAddress = await _locationRepository.QueryFirstAsync(x => x.LocationCode == taskDto.Position);
+ if (StartAddress == null)
+ {
+ return content.Error("璧风偣搴撲綅鏈壘鍒�");
+ }
+ if (!LocationIsOutBound(StartAddress))
+ {
+ return content.Error($"璧风偣搴撲綅{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);
+
+ if (location != null && location.LocationStatus != (int)LocationEnum.Free && location.EnalbeStatus == 1)
+ {
+ return content.OK("鐩爣搴撲綅涓嶅彲鐢�");
+ }
+ }
+ else
+ {
+ return content.OK("璇烽�夋嫨鍏ュ簱鍖哄煙鎴栫粓鐐瑰湴鍧�");
+ }
+
+ switch (StartAddress.AreaId)
+ {
+ case 1:
+ return await OutboundStakerArea(taskDto, StartAddress, location);
+ case 2:
+ case 3:
+ case 4:
+ case 5:
+ case 6:
+ return await OutboundAGVCacheArea(taskDto, StartAddress, location);
+ default:
+ return content.Error("璇烽�夋嫨姝ｇ‘鐨勫尯鍩熶俊鎭�");
+ }
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+ public async Task<WebResponseContent> OutboundStakerArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, DtLocationInfo location)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var station = _stationManagerRepository.QueryFirst(x => x.stationType == 1 && x.Roadway == "SC1");
+
+ if (location == null)
+ {
+ return content.Error("缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
+ }
+
+ if (location.AreaId == 5 || location.AreaId == 6)
+ {
+ return content.Error("褰撳墠鍖哄煙涓嶅彲鍑哄簱锛岃鑱旂郴绠＄悊鍛�");
+ }
+ Dt_Task taskNew = new Dt_Task
+ {
+ Grade = Convert.ToInt32(StartAddress.Remark),
+ Roadway = "SC1",
+ TargetAddress = location.LocationCode,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = station.stationChildCode,
+ OrderNo = null,
+ PalletCode = taskDto.PalletCode,
+ SourceAddress = taskDto.Position,
+ CurrentAddress = taskDto.Position,
+ TaskState = (int)TaskOutStatusEnum.OutNew,
+ TaskType = taskDto.TaskType,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ AGVTaskNum = GenerateUniqueId(),
+ Floor = "1F",
+ };
+ var taskDTO = CreateListTaskDTO(taskNew);
+
+ UpdateLocationStatus(StartAddress, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ UpdateLocationStatus(location, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+
+ BaseDal.AddData(taskNew);
+ //return content.OK();
+ return content = await SendWCSTask(taskDTO);
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+ public async Task<WebResponseContent> OutboundAGVCacheArea(RequestTaskDto taskDto, DtLocationInfo StartAddress, DtLocationInfo location)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ if (location == null)
+ {
+ return content.Error("璧风偣鏈畾涔夋垨缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
+ }
+ Dt_Task taskNew = new Dt_Task();
+ if (StartAddress.Floor != location.Floor)
+ {
+ taskNew = RequestAcrossFloorTask(StartAddress, location, taskDto.TaskType, taskDto.PalletCode);
+ }
+ else
+ {
+ taskNew = RequestAGVCarryTask(StartAddress, location, taskDto.TaskType, taskDto.PalletCode);
+ }
+
+ var taskDTO = CreateListTaskDTO(taskNew);
+
+ UpdateLocationStatus(StartAddress, LocationEnum.InStockDisable, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+ UpdateLocationStatus(location, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticOutbound);
+
+ BaseDal.AddData(taskNew);
+ //return content.OK();
+ return content = await SendWCSTask(taskDTO);
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+ #endregion 璇锋眰鍑哄簱锛堝疄鐩�&绌虹洏锛�
+
+ #region 璇锋眰璺ㄦゼ灞�2浠诲姟
+ /// <summary>
+ /// 璇锋眰璺ㄦゼ灞�2浠诲姟
+ /// </summary>
+ /// <param name="taskDto"></param>
+ /// <returns></returns>
+ public async Task<WebResponseContent> AcrossFloorTaskAsync(RequestAcrossFloorTaskDto taskDto)
+ {
+ WebResponseContent content=new WebResponseContent();
+ try
+ {
+ var task = BaseDal.QueryFirst(x => x.TaskNum == Convert.ToInt32(taskDto.TaskNum) && x.PalletCode == taskDto.PalletCode);
+ if(task == null)
+ return content.Error("鏈壘鍒颁换鍔�");
+ Dt_StationManager stationManager = new Dt_StationManager();
+ if (task.Floor == "1F")
+ {
+ stationManager = _stationManagerRepository.QueryFirst(x => x.stationType == 5 && x.stationFloor == "2F");
+ }
+ else
+ {
+ stationManager = _stationManagerRepository.QueryFirst(x => x.stationType == 5 && x.stationFloor == "1F");
+ }
+ Dt_Task taskNew = new Dt_Task
+ {
+ Grade = 1,
+ Roadway = "AGV",
+ TargetAddress = task.TargetAddress,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = task.TargetAddress,
+ OrderNo = null,
+ PalletCode = task.PalletCode,
+ SourceAddress = task.SourceAddress,
+ CurrentAddress = stationManager.stationChildCode,
+ TaskState = (int)TaskAcrossFloorStatusEnum.SecondCarry,
+ TaskType = task.TaskType,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ AGVTaskNum = GenerateUniqueId(),
+ Floor = stationManager.stationFloor,
+ };
+ var taskDTO = CreateTaskDTO(taskNew);
+ task.TaskState = (int)TaskAcrossFloorStatusEnum.FirstCarryFinish;
+ var taskHty = task.Adapt<Dt_Task_Hty>();
+ 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 _unitOfWorkManage.UseTranAsync(async () =>
+ {
+
+ await DeleteTaskAsync(task.TaskId);
+ await AddTaskHtyAsync(taskHty);
+ BaseDal.AddData(taskNew);
+ });
+ return content.OK(data: taskDTO);
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+ #endregion
+
+ #region 璇锋眰璺ㄦゼ灞備换鍔�
+ public Dt_Task RequestAcrossFloorTask(DtLocationInfo StartAddress,DtLocationInfo EndAddress,int TaskType,string palletCode)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var next = _stationManagerRepository.QueryFirst(x => x.stationType == 5 && x.stationFloor == StartAddress.Floor);
+ return new Dt_Task
+ {
+ Grade = StartAddress.Column,
+ Roadway = "AGV",
+ TargetAddress = EndAddress.LocationCode,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = next.stationChildCode,
+ OrderNo = null,
+ PalletCode = palletCode,
+ SourceAddress = StartAddress.LocationCode,
+ CurrentAddress = StartAddress.LocationCode,
+ TaskState = (int)TaskAcrossFloorStatusEnum.CarryNew,
+ TaskType = TaskType,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ Remark = StartAddress.AreaId.ToString(),
+ AGVTaskNum = GenerateUniqueId(),
+ Floor = StartAddress.Floor,
+ };
+ }
+ catch (Exception ex)
+ {
+ return null;
+ }
+ }
+ #endregion
+
+ #region 璇锋眰AGV鎼繍浠诲姟
+ public Dt_Task RequestAGVCarryTask(DtLocationInfo StartAddress, DtLocationInfo EndAddress, int TaskType, string palletCode)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ return new Dt_Task
+ {
+ Grade = StartAddress.Column,
+ Roadway = "AGV",
+ TargetAddress = EndAddress.LocationCode,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = EndAddress.LocationCode,
+ OrderNo = null,
+ PalletCode = palletCode,
+ SourceAddress = StartAddress.LocationCode,
+ CurrentAddress = StartAddress.LocationCode,
+ TaskState = (int)TaskAGVCarryStatusEnum.CarryNew,
+ TaskType = TaskType,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ Remark = StartAddress.AreaId.ToString(),
+ AGVTaskNum = GenerateUniqueId(),
+ Floor = StartAddress.Floor,
+ };
+ }
+ catch (Exception ex)
+ {
+ return null;
+ }
+ }
+
+ #endregion
+
+ #region 鍒ゆ柇鏄惁闇�瑕佺Щ搴�
+
+ /// <summary>
+ /// 鍒ゆ柇鍫嗗灈鏈哄嚭搴撴槸鍚﹂渶瑕佺Щ搴�
+ /// </summary>
+ /// <param name="taskDto"></param>
+ /// <returns></returns>
+ public async Task<WebResponseContent> StackerIsNeedRelocationAsync(RequestTaskDto taskDto)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var task = BaseDal.QueryFirst(x => x.PalletCode == taskDto.PalletCode && x.TaskNum == taskDto.TaskNum);
+ if (task == null)
+ {
+ return content.Error("鏈壘鍒颁换鍔�");
+ }
+
+ var location = await _locationRepository.QueryFirstAsync(x => x.LocationCode == taskDto.Position);
+
+ if (location == null || location.Depth != 2)
+ {
+ return content.OK(data: _mapper.Map<WMSTaskDTO>(task));
+ }
+
+ var locationLateral = _locationRepository.QueryFirst(x => x.RoadwayNo == location.RoadwayNo && x.Row == 1 && x.Layer == location.Layer && x.Column == location.Column);
+ if (locationLateral != null && (locationLateral.LocationStatus == (int)LocationEnum.FreeDisable || locationLateral.LocationStatus == (int)LocationEnum.Free) && locationLateral.EnalbeStatus == 1)
+ {
+ return content.OK(data: _mapper.Map<WMSTaskDTO>(task));
+ }
+ else if (locationLateral != null && locationLateral.LocationStatus == 1 && locationLateral.EnalbeStatus == 1)
+ {
+ return content.Error($"涓�娣变綅寮傚父閿佸畾鏆備笉鍙嚭搴�");
+ }
+ else if (locationLateral != null && locationLateral.LocationStatus == (int)LocationEnum.InStockDisable && locationLateral.EnalbeStatus == 1)
+ {
+ var TargetAddress = await GetEmptyLocation("SC1");
+
+ if (TargetAddress == null)
+ {
+ return content.Error($"鏈壘鍒板彲鍒嗛厤璐т綅,璇锋煡鐪嬫槸鍚﹁繕鏈夌┖闂插彲浣跨敤璐т綅");
+ }
+
+ //todo鏌ヨ鍐呬晶搴撳瓨淇℃伅
+ var stock = await _stockInfoRepository.QueryFirstAsync(x => x.LocationCode == locationLateral.LocationCode);
+
+ Dt_Task taskNew = new Dt_Task
+ {
+ Grade = 1,
+ Roadway = "SC1",
+ TargetAddress = TargetAddress.LocationCode,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = TargetAddress.LocationCode,
+ OrderNo = null,
+ PalletCode = taskDto.PalletCode + "001",
+ SourceAddress = locationLateral.LocationCode,
+ CurrentAddress = locationLateral.LocationCode,
+ TaskState = (int)TaskRelocationStatusEnum.RelocationNew,
+ TaskType = (int)TaskRelocationTypeEnum.Relocation,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ Floor = "1F",
+ };
+ var taskDTO = CreateListTaskDTO(taskNew);
+
+ var isResult = await AddTaskAsync(taskNew, locationLateral, TargetAddress);
+ //UpdateLocationStatus(TargetAddress, LocationEnum.Lock);
+ UpdateLocationStatus(TargetAddress, LocationEnum.Lock, taskNew.TaskNum.Value, (int)StatusChangeTypeEnum.AutomaticRelocation);
+ if (!isResult)
+ {
+ _unitOfWorkManage.RollbackTran();
+ return content.Error("鏂板浠诲姟澶辫触");
+ }
+ return content.OK(data: taskDTO);
+ }
+ else
+ {
+ return content.Error("璐т綅寮傚父闇�浜哄伐纭鎵嶅彲鍑哄簱");
+ }
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+ public async Task<WebResponseContent> AGVIsNeedRelocationAsync(RequestTaskDto taskDto)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ var task = BaseDal.QueryFirst(x => x.PalletCode == taskDto.PalletCode && x.TaskNum == taskDto.TaskNum);
+ if (task == null)
+ {
+ return content.Error("鏈壘鍒颁换鍔�");
+ }
+
+ var location = await _locationRepository.QueryFirstAsync(x => x.LocationCode == taskDto.Position);
+
+ if (location == null)
+ {
+ return content.Error("鏈壘鍒拌揣浣嶆垨鑰呰搴撲綅涓嶆槸浜屾繁璐т綅");
+ }
+ List<DtLocationInfo> locationInfos = new List<DtLocationInfo>();
+ switch (location.AreaId)
+ {
+ case 2:
+ locationInfos = _locationRepository.QueryData(x => x.Row == location.Row && x.Column > location.Column && x.Remark == location.Remark && x.AreaId == location.AreaId);
+ break;
+ case 5:
+ case 6:
+ locationInfos = _locationRepository.QueryData(x => x.Row == location.Row && x.Column < location.Column && x.Remark == location.Remark && x.AreaId == location.AreaId);
+ break;
+ default:
+ break;
+ }
+
+ if (locationInfos.Count == 0)
+ {
+ return content.OK(data: new List<WMSTaskDTO> { _mapper.Map<WMSTaskDTO>(task) });
+ }
+
+ List<WMSTaskDTO> taskDTO = new List<WMSTaskDTO>();
+
+ foreach (var item in locationInfos)
+ {
+ if ((item.LocationStatus == 0 || item.LocationStatus == (int)LocationEnum.FreeDisable) && item.EnalbeStatus == 1)
+ {
+ continue;
+ }
+ else
+ {
+ DtLocationInfo Targetlocation = await GetAGVEmptyCacheLocation(item.AreaId, item);
+
+ if (Targetlocation == null)
+ {
+ return content.Error("璧风偣鏈畾涔夋垨缁堢偣鍖哄煙鏈壘鍒扮┖闂插簱浣�");
+ }
+ //todo鏌ヨ绉诲簱搴撳瓨淇℃伅
+
+ Dt_Task taskNew = new Dt_Task
+ {
+ Grade = item.Column,
+ Roadway = "AGV",
+ TargetAddress = Targetlocation.LocationCode,
+ Dispatchertime = DateTime.Now,
+ MaterialNo = "",
+ NextAddress = Targetlocation.LocationCode,
+ OrderNo = null,
+ PalletCode = _random.Next(0, 10000).ToString(),
+ SourceAddress = item.LocationCode,
+ CurrentAddress = item.LocationCode,
+ TaskState = (int)TaskAGVCarryStatusEnum.CarryNew,
+ TaskType = (int)TaskRelocationTypeEnum.Relocation,
+ TaskNum = BaseDal.GetTaskNo().Result,
+ CreateDate = DateTime.Now,
+ TaskId = 0,
+ 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("鏂板浠诲姟澶辫触");
+ }
+
+ }
+ }
+ return content.OK(data: taskDTO);
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+
+ #endregion
+
+ #region 鑾峰彇AGV浠诲姟鍙�
+
+ private static readonly Random _random = new Random();
+
+ public static string GenerateUniqueId()
+ {
+ // 鑾峰彇褰撳墠姣绾ф椂闂存埑
+ long timestamp = DateTimeOffset.Now.ToUnixTimeMilliseconds();
+
+ // 鐢熸垚4浣嶉殢鏈烘暟锛�0000-9999锛�
+ int randomNumber = _random.Next(0, 10000);
+ string randomPart = randomNumber.ToString("D4"); // 琛ラ浂鍒�4浣�
+
+ return $"{timestamp}{randomPart}";
+ }
+ #endregion
+
+ #region 鑾峰彇浠诲姟淇℃伅
+ public WebResponseContent GetTaskInfo()
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ Expression<Func<Dt_Task, bool>> expression = x => true;
+ if (!App.User.IsSuperAdmin)
+ {
+ expression = x => x.Creater == App.User.UserName;
+ }
+ var task = BaseDal.Db.Queryable<Dt_Task>().OrderByDescending(x => x.CreateDate).Take(100).Select(x => new Dt_Task { TaskNum = x.TaskNum, PalletCode = x.PalletCode, TaskType = x.TaskType, SourceAddress = x.SourceAddress, TargetAddress = x.TargetAddress }).ToList();
+ content = WebResponseContent.Instance.OK(data: task);
+ }
+ catch (Exception ex)
+ {
+ content = WebResponseContent.Instance.Error(ex.Message);
+ }
+ return content;
+ }
+ #endregion
#endregion 澶栭儴鎺ュ彛鏂规硶
+ #region 璋冪敤WCS鎺ュ彛
+ private string GetWCSIPAddress(string baseIp, string name)
+ {
+ var configz = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
+ var wcsBasez = configz.Where(x => x.ConfigKey == baseIp).FirstOrDefault()?.ConfigValue;
+ var address = configz.Where(x => x.ConfigKey == name).FirstOrDefault()?.ConfigValue;
+ if (wcsBasez == null || address == null)
+ {
+ throw new InvalidOperationException("WMS IP 鏈厤缃�");
+ }
+ return wcsBasez + address;
+ }
+ public async Task<WebResponseContent> SendWCSTask(List<WMSTaskDTO> taskDTO)
+ {
+ WebResponseContent content = new WebResponseContent();
+ var AgvSendTaskAddrss = GetWCSIPAddress(SysConfigConst.WCSIPAddress, SysConfigConst.ReceiveTask);
+ // 鍙戦�佽姹傚苟绛夊緟鍝嶅簲
+ var result = await HttpHelper.PostAsync(AgvSendTaskAddrss, taskDTO.ToJsonString());
+
+ content = JsonConvert.DeserializeObject<WebResponseContent>(result.ToString());
+
+ return content;
+ }
+ #endregion
+
+ #region ERP鎺ュ彛璋冪敤
+ public string GetERPIPAddress(string baseIp, string name)
+ {
+ var configz = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
+ var wcsBasez = configz.Where(x => x.ConfigKey == baseIp).FirstOrDefault()?.ConfigValue;
+ var address = configz.Where(x => x.ConfigKey == name).FirstOrDefault()?.ConfigValue;
+ if (wcsBasez == null || address == null)
+ {
+ throw new InvalidOperationException("WMS IP 鏈厤缃�");
+ }
+ return wcsBasez + address;
+ }
+
+ public async Task<WebResponseContent> SendERPTaskCompletion(string palletCode)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ DtStockInfo stock = await _stockInfoRepository.QueryFirstNavAsync(x=>x.PalletCode== palletCode);
+ Allocate allocate = new Allocate
+ {
+ context = new Context
+ {
+ CultureName = "zh-CN",
+ EntCode = "001",
+ OrgCode = "102",
+ UserCode = "MH0551"
+ },
+ documentTypeCode = "TransIn002",
+ businessDate = DateTime.Now.ToString("yyyy-MM-dd"),
+ isApproved = true,
+
+ transferInList = stock.StockInfoDetails.Select(item => new transferInList
+ {
+ ItemCode = item.MaterielCode,
+ TransInWHCode = item.Warehouse,
+ TransInQty = item.Quantity,
+ TransOutWHCode = "001",
+ }).ToList()
+ };
+ return content.OK(data: allocate);
+ }
+ catch (Exception ex)
+ {
+ return content.Error(ex.Message);
+ }
+ }
+
+
+ #endregion
+
#region 鍐呴儴璋冪敤鏂规硶
+
+ public void UpdateLocationStatus(DtLocationInfo location, LocationEnum locationStatus, int taskNum, int StatusChangeType)
+ {
+ List<DtLocationInfo> locations = GetGroupLocations(location);
+
+ List<DtLocationInfo> Beforelocation = locations.Select(x => new DtLocationInfo
+ {
+ Id = x.Id,
+ LocationCode = x.LocationCode,
+ LocationStatus = x.LocationStatus
+ }).ToList();
+
+ foreach (var item in locations)
+ {
+ if (locationStatus == LocationEnum.Lock)
+ {
+ if (item.LocationCode == location.LocationCode)
+ {
+ 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)
+ {
+ if (item.LocationStatus == (int)LocationEnum.InStock)
+ {
+ 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;
+ }
+ }
+ }
+ List<LocationChangeRecordDto> changeRecordDto = new List<LocationChangeRecordDto>();
+ foreach (var item in Beforelocation)
+ {
+ var loc = locations.Where(x => x.LocationCode == item.LocationCode).FirstOrDefault();
+ if (loc != null)
+ {
+ changeRecordDto.Add(new LocationChangeRecordDto()
+ {
+ AfterStatus = loc.LocationStatus,
+ BeforeStatus = item.LocationStatus,
+ TaskNum = taskNum,
+ LocationId = loc.Id,
+ LocationCode = loc.LocationCode,
+ ChangeType = StatusChangeType,
+ });
+ }
+ }
+ _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
+
+ _locationRepository.UpdateData(locations);
+ }
+
+ public List<DtLocationInfo> GetGroupLocations(DtLocationInfo location)
+ {
+ List<DtLocationInfo> locationInfos = _locationRepository.QueryData(x => x.AreaId == location.AreaId);
+ List<DtLocationInfo> locations = new List<DtLocationInfo>() { location };
+ if (location.AreaId == 1)
+ {
+ if (location.Depth == 2)
+ {
+ DtLocationInfo? locationInfo = locationInfos.FirstOrDefault(x => x.Depth == 1 && x.Column == location.Column && x.Layer == location.Layer && x.Row == 1);
+ if (locationInfo != null)
+ {
+ locations.Add(locationInfo);
+ }
+ }
+ }
+ else if (location.AreaId == 2)
+ {
+ var locationLateral = _locationRepository.QueryData(x => x.Row == location.Row && x.Column > location.Column && x.Remark == location.Remark);
+ if (locationLateral.Count > 0)
+ {
+ locations.AddRange(locationLateral);
+ }
+ }
+ else if (location.AreaId == 5 || location.AreaId == 6)
+ {
+ var locationLateral = _locationRepository.QueryData(x => x.Row == location.Row && x.Column < location.Column && x.Remark == location.Remark);
+ if (locationLateral.Count > 0)
+ {
+ locations.AddRange(locationLateral);
+ }
+ }
+ return locations;
+
+ }
+
+ /// <summary>
+ /// 鍒涘缓浠诲姟DTO
+ /// </summary>
+ private List<WMSTaskDTO> CreateListTaskDTO(Dt_Task task)
+ {
+ return new List<WMSTaskDTO> { 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,
+ Id = 0,
+ TaskType = task.TaskType,
+ AGVTaskNum = task.AGVTaskNum,
+ } };
+ }
+
+ 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,
+ Id = 0,
+ TaskType = task.TaskType,
+ AGVTaskNum = task.AGVTaskNum,
+ Remark= task.Remark
+ };
+ }
+
+ private async Task DeleteStockInfoAsync(int stockId)
+ {
+ var isStockUpdated = await _stockInfoRepository.DeleteDataByIdAsync(stockId);
+ if (!isStockUpdated)
+ {
+ throw new Exception("搴撳瓨淇℃伅鏇存柊澶辫触");
+ }
+ }
+
+ private async Task AddStockInfoHtyAsync(DtStockInfo_Hty dtStock)
+ {
+ var isStockAdd = await SqlSugarHelper.DbWMS.InsertNav(dtStock).IncludesAllFirstLayer().ExecuteCommandAsync();
+ if (!isStockAdd)
+ {
+ throw new Exception("搴撳瓨鍘嗗彶淇℃伅娣诲姞澶辫触");
+ }
+ }
+
+ private async Task DeleteBoxingInfoAsync(int boxingId)
+ {
+ var isStockUpdated = await _stockInfoRepository.DeleteDataByIdAsync(boxingId);
+ if (!isStockUpdated)
+ {
+ throw new Exception("搴撳瓨淇℃伅鏇存柊澶辫触");
+ }
+ }
+
+ private async Task AddBoxingHtyAsync(DtBoxingInfo_Hty boxingInfo)
+ {
+ var isStockAdd = await SqlSugarHelper.DbWMS.InsertNav(boxingInfo).IncludesAllFirstLayer().ExecuteCommandAsync();
+ if (!isStockAdd)
+ {
+ throw new Exception("缁勭洏鍘嗗彶淇℃伅娣诲姞澶辫触");
+ }
+ }
+
+
+ private async Task DeleteStockInfoDetailsAsync(IEnumerable<DtStockInfoDetail> details)
+ {
+ var ids = details.Select(x => (object)x.Id).ToArray();
+ var isStockDetailUpdated = await _stockInfoDetailRepository.DeleteDataByIdsAsync(ids);
+ if (!isStockDetailUpdated)
+ {
+ throw new Exception("搴撳瓨璇︽儏淇℃伅鏇存柊澶辫触");
+ }
+ }
+
+ private async Task DeleteTaskAsync(int taskId)
+ {
+ var isTaskUpdated = await BaseDal.DeleteDataByIdAsync(taskId);
+ if (!isTaskUpdated)
+ {
+ throw new Exception("浠诲姟淇℃伅鏇存柊澶辫触");
+ }
+ }
+
+ private async Task AddTaskHtyAsync(Dt_Task_Hty taskHty)
+ {
+ var isTaskAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;
+ if (!isTaskAdd)
+ {
+ throw new Exception("鍘嗗彶浠诲姟淇℃伅娣诲姞澶辫触");
+ }
+ }
public override WebResponseContent DeleteData(object[] key)
{
@@ -482,7 +1501,10 @@
{
return await BaseDal.QueryFirstAsync(x => x.TaskNum == taskNum);
}
-
+ public async Task<Dt_Task> GetByTaskAddress(string SourceAddress, string TargetAddress)
+ {
+ return await BaseDal.QueryFirstAsync(x => x.SourceAddress == SourceAddress|| x.TargetAddress== TargetAddress);
+ }
#endregion 鍐呴儴璋冪敤鏂规硶
#region private 鍐呴儴鏂规硶
@@ -511,105 +1533,16 @@
return taskHty;
}
- /// <summary>
- /// 鏇存柊搴撳瓨浣嶇疆
- /// </summary>
- /// <param name="stock">搴撳瓨瀵硅薄</param>
- /// <param name="toLocation">鐩爣浣嶇疆</param>
- // 鏇存柊搴撳瓨鍜屼綅缃俊鎭�
- private (DtStockInfo, DtLocationInfo, DtLocationInfo) UpdateStockLocation(DtStockInfo stock, Dt_Task task)
- {
- //淇敼鏉ユ簮搴撲綅鍜� 鐩爣搴撲綅鐘舵��
- var fromLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
- fromLocation.LocationStatus = LocationEnum.Free.ObjToInt();
- var toLocation = _locationRepository.QueryFirst(x => x.LocationCode == task.SourceAddress && x.RoadwayNo == task.Roadway);
- toLocation.LocationStatus = LocationEnum.InStock.ObjToInt();
-
- // 灏嗗簱瀛樹綅缃缃负鐩爣浣嶇疆
- stock.LocationCode = task.TargetAddress;
-
- // 杩斿洖鏇存柊鍚庣殑搴撳瓨鍜屼綅缃俊鎭�
- return (stock, fromLocation, toLocation);
- }
#region 浠诲姟璇锋眰鏂规硶
private static readonly SemaphoreSlim _semaphoreUpdate = new SemaphoreSlim(1, 1);
// 鏇存柊浠诲姟璐т綅
- private async Task<WebResponseContent> UpdateExistingTask(RequestTaskDto input, Dt_Task task)
- {
- await _semaphoreUpdate.WaitAsync();
- try
- {
- if (task == null)
- {
- return new WebResponseContent().Error("浠诲姟瀵硅薄涓虹┖");
- }
-
- try
- {
- // 鍒涘缓WebResponseContent瀵硅薄
- var content = new WebResponseContent();
-
-
- var location = await GetEmptyLocation(task.Roadway);
- 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;
-
- // 鏇存柊浠诲姟淇℃伅
- MapTaskProperties(task, input, toAddress, taskState);
-
- // 寮�濮嬩簨鍔�
- var isResult = await UpdateTaskAsync(task, location, beforeStatus);
- if (!isResult)
- {
- _unitOfWorkManage.RollbackTran();
- return content.Error("鏇存柊浠诲姟澶辫触");
- }
-
- // 鎻愪氦浜嬪姟
- _unitOfWorkManage.CommitTran();
- return content.OK(data: task);
-
- }
- catch (Exception ex)
- {
- // 鍥炴粴浜嬪姟
- _unitOfWorkManage.RollbackTran();
- // 杩欓噷鍙互娣诲姞鏃ュ織璁板綍
- return new WebResponseContent().Error($"鏇存柊浠诲姟鏃跺彂鐢熼敊璇�: {ex.Message}");
- }
- }
- catch (Exception)
- {
- throw;
- }
- finally { _semaphoreUpdate.Release(); }
- }
-
- private void MapTaskProperties(Dt_Task task, RequestTaskDto input, string toAddress, int taskState)
- {
- task.CurrentAddress = input.Position;
- task.TargetAddress = toAddress;
- task.NextAddress = toAddress;
- task.TaskState = taskState;
- }
-
// 淇敼浠诲姟
private async Task<bool> UpdateTaskAsync(Dt_Task task, DtLocationInfo location, int beforeStatus)
{
bool isResult = await BaseDal.UpdateDataAsync(task);
- bool isTaskDetail = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(task.PalletCode, task.CurrentAddress, task.TargetAddress, TaskInStatusEnum.Line_InFinish.GetIntegralRuleTypeEnumDesc()));
-
LocationChangeRecordDto changeRecordDto = new LocationChangeRecordDto()
{
AfterStatus = location.LocationStatus,
@@ -617,98 +1550,55 @@
TaskNum = task.TaskNum.Value,
LocationId = location.Id,
LocationCode = location.LocationCode,
- ChangeType = (int)StatusChangeTypeEnum.AutomaticStorage,
+ ChangeType = (int)StatusChangeTypeEnum.AutomaticInbound,
};
bool isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
bool isUpdateLo = await _locationRepository.UpdateDataAsync(location);
- return isResult && isUpdateLo && isTaskDetail;
+ return isResult && isUpdateLo;
}
- /// <summary>
- /// 鍒涘缓鏂颁换鍔�
- /// </summary>
- /// <param name="input">璇锋眰妯″瀷</param>
- /// <param name="process">宸烽亾</param>
- /// <param name="flag">鏍囪瘑锛�0-鍏ュ簱锛�1-绌烘墭鐩樺叆搴擄紝2-NG鍏ュ簱锛�3-鍑哄簱锛�</param>
- /// <returns></returns>
- private async Task<WebResponseContent> CreateNewTask(RequestTaskDto input, string productionLine, string processCode, List<string> process = null, int flag = 0)
+ private async Task<bool> AddTaskAsync(Dt_Task task, DtLocationInfo StartAddress, DtLocationInfo EndAddress)
{
- WebResponseContent content = new WebResponseContent();
+ //UpdateLocationStatus
+ bool isResult = await BaseDal.AddDataAsync(task) > 0;
+ int SourcebeforeStatus = StartAddress.LocationStatus;
- // 鑾峰彇鐩爣鍦板潃
- //string ToAddress = await GetRoadWayAsync(process);
- string ToAddress = string.Empty;
- if (flag < 2)
- ToAddress = await GetRoadWayAsync(process);
- else
- ToAddress = process[0];
- if (string.IsNullOrEmpty(ToAddress))
+ int TargetbeforeStatus = EndAddress.LocationStatus;
+
+ StartAddress.LocationStatus = (int)LocationEnum.InStockDisable;
+
+ EndAddress.LocationStatus = (int)LocationEnum.Lock;
+
+ List<LocationChangeRecordDto> changeRecordDto = new List<LocationChangeRecordDto>()
{
- return content.Error("鏃犳硶鑾峰彇鐩爣鍦板潃");
- }
- // 鍒涘缓鏂颁换鍔″疄渚�
- var task = new Dt_Task
- {
- CurrentAddress = input.Position,
- Grade = 1,
- Roadway = ToAddress,
- TargetAddress = ToAddress,
- Dispatchertime = DateTime.Now,
- MaterialNo = "",
- NextAddress = ToAddress,
- OrderNo = null,
- PalletCode = input.PalletCode,
- SourceAddress = input.Position,
- TaskState = flag == 3 ? (int)TaskOutStatusEnum.OutNew : (int)TaskInStatusEnum.InNew,
- TaskType = flag == 0 ? (int)TaskInboundTypeEnum.Inbound : flag == 1 ? (int)TaskInboundTypeEnum.InTray : flag == 2 ? (int)TaskInboundTypeEnum.InNG : (int)TaskOutboundTypeEnum.Outbound,
- TaskNum = await BaseDal.GetTaskNo(),
- Creater = "System",
- ProductionLine = productionLine,
- ProcessCode = processCode
+ new LocationChangeRecordDto()
+ {
+ AfterStatus = StartAddress.LocationStatus,
+ BeforeStatus = SourcebeforeStatus,
+ TaskNum = task.TaskNum.Value,
+ LocationId = StartAddress.Id,
+ LocationCode = StartAddress.LocationCode,
+ ChangeType = (int)StatusChangeTypeEnum.AutomaticInbound,
+ },
+ new LocationChangeRecordDto()
+ {
+ AfterStatus = EndAddress.LocationStatus,
+ BeforeStatus = TargetbeforeStatus,
+ TaskNum = task.TaskNum.Value,
+ LocationId = EndAddress.Id,
+ LocationCode = EndAddress.LocationCode,
+ ChangeType = (int)StatusChangeTypeEnum.AutomaticInbound,
+ },
};
- // 灏濊瘯娣诲姞鏂颁换鍔�
- var taskId = await BaseDal.AddDataAsync(task);
- bool isResult = taskId > 0;
- if (isResult)
- {
- task.TaskId = taskId;
- isResult = await _taskExecuteDetailRepository.AddDetailAsync(task, false, TaskDescription.GetTaskUpdateDescription(input.PalletCode, input.Position, ToAddress, TaskInStatusEnum.InNew.GetIntegralRuleTypeEnumDesc()));
+ bool isUpdateChange = _locationStatusChangeRecordRepository.AddStatusChangeRecord(changeRecordDto);
+ bool Source = await _locationRepository.UpdateDataAsync(StartAddress);
+ bool Target = await _locationRepository.UpdateDataAsync(EndAddress);
- //var location = _locationRepository.QueryFirst(x => x.RoadwayNo == task.Roadway && x.LocationCode == task.TargetAddress);
- //location.LocationStatus = (int)LocationEnum.Lock;
- //var isLocation = _locationRepository.UpdateData(location);
-
- if (isResult)
- {
- // 鍒涘缓WMS浠诲姟
- WMSTaskDTO taskDTO = new WMSTaskDTO()
- {
- TaskNum = task.TaskNum.Value,
- Grade = 1,
- PalletCode = task.PalletCode,
- RoadWay = task.Roadway,
- SourceAddress = task.SourceAddress,
- TargetAddress = task.TargetAddress,
- TaskState = task.TaskState.Value,
- Id = 0,
- TaskType = task.TaskType,
- ProductionLine = task.ProductionLine
- };
- content.OK(data: taskDTO);
- }
- else
- content.Error("娣诲姞浠诲姟澶辫触");
- }
- else
- content.Error("娣诲姞浠诲姟澶辫触");
- return content;
+ return isResult && Source && Target;
}
-
- private static readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
- private static List<LocationCache> locationCaches = new List<LocationCache>();
/// <summary>
/// 鑾峰彇璐т綅鍙�
@@ -716,85 +1606,247 @@
/// <returns></returns>
public async Task<DtLocationInfo> GetEmptyLocation(string roadWay)
{
- await _semaphore.WaitAsync();
try
{
- List<LocationCache> removeItems = locationCaches.Where(x => (DateTime.Now - x.DateTime).TotalMinutes > 5).ToList();//鏌ヨ娣诲姞闈欐�佸彉閲忚秴杩�5鍒嗛挓鐨勮揣浣�
- int count = removeItems.Count;
- for (int i = 0; i < count; i++)
+ List<DtLocationInfo> locations = await _locationRepository.QueryDataAsync(x => x.RoadwayNo == "SC1" && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == 1);
+ if (locations.Count < 2)
{
- locationCaches.Remove(removeItems[i]);//绉婚櫎鏌ヨ娣诲姞闈欐�佸彉閲忚秴杩�5鍒嗛挓鐨勮揣浣�
+ return null;
}
- List<string> lockLocations = locationCaches.Select(x => x.LocationCode).ToList();
+ List<DtLocationInfo> locationInfos = new List<DtLocationInfo>();
+ var locationInside = locations.Where(x => x.Row == 3).ToList();
- List<DtLocationInfo> LocationInfoList = await _locationRepository.QueryDataAsync(x => x.RoadwayNo == roadWay && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == EnableEnum.Enable.ObjToInt());
-
- List<DtLocationInfo> LocationInfoResult = new List<DtLocationInfo>();
- foreach (DtLocationInfo item in LocationInfoList)
+ if (locations.Where(x => x.Row == 2).OrderBy(x => x.Layer).ThenBy(x => x.Column).FirstOrDefault() != null)
{
- DtLocationInfo locationItem = new DtLocationInfo();
-
- if (item.Depth == 2)
+ return locations.Where(x => x.Row == 2).ToList().OrderBy(x => x.Layer).ThenBy(x => x.Column).FirstOrDefault();
+ }
+ else if (locationInside.Count > 0)
+ {
+ foreach (var item in locationInside)
{
- locationItem = _locationRepository.QueryFirst(x => x.Column == item.Column && x.RoadwayNo == item.RoadwayNo && x.Layer == item.Layer && x.Depth != item.Depth && x.Row != item.Row && (SqlFunc.Abs(x.Row - item.Row) == 1) && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == EnableEnum.Enable.ObjToInt());
- if (locationItem != null)
- {
- LocationInfoResult.Add(item);
- }
- }
- else
- {
- locationItem = _locationRepository.QueryFirst(x => x.Column == item.Column && x.RoadwayNo == item.RoadwayNo && x.Layer == item.Layer && x.Depth != item.Depth && x.Row != item.Row && (SqlFunc.Abs(x.Row - item.Row) == 1) && x.LocationStatus == (int)LocationEnum.InStock && x.EnalbeStatus == EnableEnum.Enable.ObjToInt());
- if (locationItem != null)
+ var locationLateral = _locationRepository.QueryFirst(x => x.Row == 1 && x.Layer == item.Layer && x.Column == item.Column);
+ if (locationLateral.LocationStatus == (int)LocationEnum.Free && locationLateral.EnalbeStatus == 1)
{
- LocationInfoResult.Add(item);
+ locationInfos.Add(item);
}
}
- }
- if (LocationInfoResult.Count < 2)
- {
- throw new Exception("褰撳墠绌洪棽璐т綅涓嶈冻锛�");
- }
- return LocationInfoResult.Where(x => !lockLocations.Contains(x.LocationCode)).OrderByDescending(x => x.Depth).ThenBy(x => x.Column).ThenBy(x => x.Layer).FirstOrDefault();
+ return locationInfos.Distinct().OrderBy(x => x.Layer).ThenBy(x => x.Column).FirstOrDefault();
+ }
+ else if (locations.Where(x => x.Row == 1).OrderBy(x => x.Layer).ThenBy(x => x.Column).FirstOrDefault() != null)
+ {
+ return locations.Where(x => x.Row == 1).OrderBy(x => x.Layer).ThenBy(x => x.Column).FirstOrDefault();
+ }
+ else
+ {
+ return null;
+ }
}
catch (Exception ex)
{
throw new Exception(ex.Message);
}
- finally
- {
- _semaphore.Release();
- }
}
- /// <summary>
- /// 鏍规嵁宸烽亾鑾峰彇宸烽亾鎴栫珯鍙�
- /// </summary>
- /// <returns></returns>
- public async Task<string> GetRoadWayAsync(List<string> process)
+
+ public async Task<DtLocationInfo> GetAGVEmptyCacheLocation(int AreaId, DtLocationInfo loc)
{
- var deviceCode = await SqlSugarHelper.DbWCS.Queryable<Dt_DeviceInfo>()
- .Where(x => x.DeviceStatus == 1.ToString() && process.Contains(x.DeviceCode))
- .Select(x => x.DeviceCode).ToListAsync();
-
- var minGroup = _locationRepository.QueryData(x => deviceCode.Contains(x.RoadwayNo) && x.LocationStatus == (int)LocationEnum.Free)
- .GroupBy(x => x.RoadwayNo)
- .OrderByDescending(g => g.Count()) // 鏍规嵁姣忎釜缁勭殑鍏冪礌鏁伴噺鎺掑簭
- .ToList(); // 鍙栧嚭鏁伴噺鏈�澶氱殑缁�
-
- Dictionary<string, int> result = new Dictionary<string, int>();
- foreach (var item in minGroup)
+ try
{
- var number = BaseDal.QueryData(x => x.TargetAddress == item.Key && x.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup).Count();
- result.Add(item.Key, item.Count() - number);
+ if(loc==null)
+ {
+ return null;
+ }
+ switch (AreaId)
+ {
+ case 2:
+ return await FromShallowToDeep(AreaId, loc);
+ case 3:
+ return await AGVLIKU(AreaId);
+ case 5:
+ case 6:
+ return await FromDeepToShallow(AreaId, loc);
+ default:
+ return null;
+ }
+
}
-
- string minRoadwayNo = result.OrderByDescending(x => x.Value).FirstOrDefault().Key; // 鏁伴噺鏈�澶氱殑缁勭殑Key
-
- return minRoadwayNo;
+ catch (Exception ex)
+ {
+ throw new Exception(ex.Message);
+ }
}
+ /// <summary>
+ /// 鐢辨繁鍒版祬
+ /// </summary>
+ /// <param name="AreaId"></param>
+ /// <returns></returns>
+ public async Task<DtLocationInfo> FromDeepToShallow(int AreaId, DtLocationInfo loc)
+ {
+ try
+ {
+ List<DtLocationInfo> locations = new List<DtLocationInfo>();
+
+ if (AreaId == loc.AreaId)
+ {
+ locations = await _locationRepository.QueryDataAsync(x => x.AreaId == AreaId && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == 1 && x.Row != loc.Row);
+ }
+ else
+ {
+ locations = await _locationRepository.QueryDataAsync(x => x.AreaId == AreaId && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == 1);
+ }
+ if (locations.Count == 0)
+ {
+ return null;
+ }
+ List<DtLocationInfo> locationInfos = new List<DtLocationInfo>();
+ foreach (var item in locations)
+ {
+ var locationLateral = _locationRepository.QueryData(x => x.Row == item.Row && x.Column < item.Column && x.Remark == item.Remark);
+ bool Isavailable = true;
+ foreach (var lateral in locationLateral)
+ {
+ if (lateral.LocationStatus != (int)LocationEnum.Free && lateral.EnalbeStatus == 1)
+ {
+ Isavailable = false;
+ continue;
+ }
+ }
+ if(Isavailable)
+ locationInfos.Add(item);
+ }
+
+ return locationInfos.Distinct().OrderByDescending(x => x.Column).ThenBy(x => x.Row).FirstOrDefault();
+ }
+ catch (Exception ex)
+ {
+ throw new Exception(ex.Message);
+ }
+ }
+
+ /// <summary>
+ /// 鐢辨祬鍒版繁
+ /// </summary>
+ /// <param name="AreaId"></param>
+ /// <returns></returns>
+ public async Task<DtLocationInfo> FromShallowToDeep(int AreaId, DtLocationInfo loc)
+ {
+ try
+ {
+ List<DtLocationInfo> locations = new List<DtLocationInfo>();
+
+ if (AreaId == loc.AreaId)
+ {
+ locations = await _locationRepository.QueryDataAsync(x => x.AreaId == AreaId && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == 1 && x.Row != loc.Row);
+ }
+ else
+ {
+ locations = await _locationRepository.QueryDataAsync(x => x.AreaId == AreaId && x.LocationStatus == (int)LocationEnum.Free && x.EnalbeStatus == 1);
+ }
+
+ if (locations.Count == 0)
+ {
+ return null;
+ }
+ List<DtLocationInfo> locationInfos = new List<DtLocationInfo>();
+ 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;
+ }
+ foreach (var Lateral in locationLateral)
+ {
+ if (locationInfos.Contains(Lateral))
+ continue;
+ if (Lateral.LocationStatus == (int)LocationEnum.Free && Lateral.EnalbeStatus == 1)
+ {
+ locationInfos.Add(item);
+ }
+ }
+ }
+
+ return locationInfos.Distinct().OrderBy(x => x.Column).ThenBy(x => x.Row).FirstOrDefault();
+ }
+ catch (Exception ex)
+ {
+ throw new Exception(ex.Message);
+ }
+ }
+
+
+ public async Task<DtLocationInfo> AGVLIKU(int AreaId)
+ {
+ WebResponseContent content = new WebResponseContent();
+ try
+ {
+ List<DtLocationInfo> locations = await _locationRepository.QueryDataAsync(x => x.AreaId == AreaId && x.LocationStatus == 0 && x.EnalbeStatus == 1);
+ var location = locations.OrderBy(x => x.Layer).ThenBy(x => x.Column).FirstOrDefault();
+ return location;
+ }
+ catch (Exception ex)
+ {
+ throw new Exception(ex.Message);
+ }
+ }
+
+
+ public bool LocationIsOutBound(DtLocationInfo location)
+ {
+ try
+ {
+ int sum = 0;
+ if (location.AreaId == 1)
+ {
+ if (location.Depth == 2)
+ {
+ var locationLateral = _locationRepository.QueryFirst(x => x.Row == 1 && x.Column == location.Column && x.Layer == location.Layer);
+
+ if (locationLateral.LocationStatus == (int)LocationEnum.Lock && locationLateral.EnalbeStatus == 1)
+ {
+ return false;
+ }
+ }
+ }
+
+ else if (location.AreaId == 2)
+ {
+ var locationLateral = _locationRepository.QueryData(x => x.Row == location.Row && x.Column > location.Column && x.Remark == location.Remark);
+
+ foreach (var Lateral in locationLateral)
+ {
+ if (Lateral.LocationStatus == (int)LocationEnum.Lock && Lateral.EnalbeStatus == 1)
+ {
+ return false;
+ }
+ }
+ }
+
+ else if (location.AreaId == 5 || location.AreaId == 6)
+ {
+ var locationLateral = _locationRepository.QueryData(x => x.Row == location.Row && x.Column < location.Column && x.Remark == location.Remark);
+
+ foreach (var lateral in locationLateral)
+ {
+ if (lateral.LocationStatus == (int)LocationEnum.Lock && lateral.EnalbeStatus == 1)
+ {
+ return false;
+ }
+ }
+ }
+
+ return true;
+ }
+ catch (Exception)
+ {
+ return false;
+ }
+ }
+
+
#endregion 浠诲姟璇锋眰鏂规硶
#endregion private 鍐呴儴鏂规硶
--
Gitblit v1.9.3