#region << 版 本 注 释 >>
|
/*----------------------------------------------------------------
|
* 命名空间：WIDESEA_TaskInfoService
|
* 创建者：胡童庆
|
* 创建时间：2024/8/2 16:13:36
|
* 版本：V1.0.0
|
* 描述：
|
*
|
* ----------------------------------------------------------------
|
* 修改人：
|
* 修改时间：
|
* 版本：V1.0.1
|
* 修改说明：
|
*
|
*----------------------------------------------------------------*/
|
#endregion << 版 本 注 释 >>
|
|
using AutoMapper;
|
using Microsoft.AspNetCore.Mvc.ApiExplorer;
|
using Newtonsoft.Json;
|
using SqlSugar;
|
using System.Reflection.Emit;
|
using System.Threading.Tasks;
|
using WIDESEA_Common.CommonEnum;
|
using WIDESEA_Common.LocationEnum;
|
using WIDESEA_Common.OrderEnum;
|
using WIDESEA_Common.StockEnum;
|
using WIDESEA_Common.TaskEnum;
|
using WIDESEA_Common.WareHouseEnum;
|
using WIDESEA_Core;
|
using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_Core.Enums;
|
using WIDESEA_Core.Helper;
|
using WIDESEA_DTO;
|
using WIDESEA_DTO.Inbound;
|
using WIDESEA_DTO.Stock;
|
using WIDESEA_DTO.Task;
|
using WIDESEA_External.ERPService;
|
using WIDESEA_External.Model;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IBasicService;
|
using WIDESEA_IInboundRepository;
|
using WIDESEA_InboundRepository;
|
using WIDESEA_IOutboundRepository;
|
using WIDESEA_IOutboundService;
|
using WIDESEA_IRecordService;
|
using WIDESEA_IStockRepository;
|
using WIDESEA_IStockService;
|
using WIDESEA_ITaskInfoRepository;
|
using WIDESEA_ITaskInfoService;
|
using WIDESEA_Model.Models;
|
using WIDESEA_TaskInfoRepository;
|
|
namespace WIDESEA_TaskInfoService
|
{
|
public partial class TaskService : ServiceBase<Dt_Task, ITaskRepository>, ITaskService
|
{
|
private readonly IMapper _mapper;
|
private readonly IUnitOfWorkManage _unitOfWorkManage;
|
private readonly IStockRepository _stockRepository;
|
private readonly IBasicService _basicService;
|
private readonly IRecordService _recordService;
|
private readonly IStockService _stockService;
|
private readonly IBasicRepository _basicRepository;
|
private readonly IApiInfoRepository _apiInfoRepository;
|
private readonly IInvokeERPService _invokeERPService;
|
private readonly IPalletTypeInfoRepository _palletTypeInfoRepository;
|
private readonly IAGVStationInfoRepository _agvStationInfoRepository;
|
private readonly IPurchaseBSTOrderRepository _purchaseBSTOrderRepository;
|
private readonly IPurchaseBSTOrderDetailRepository _purchaseBSTOrderDetailRepository;
|
private readonly IOutBSTOrderDetailRepository _outBSTOrderDetailRepository;
|
private readonly IOutBSTOrderRepository _outBSTOrderRepository;
|
private readonly IOutBSTOrderDetailService _outBSTOrderDetailService;
|
public ITaskRepository Repository => BaseDal;
|
|
private Dictionary<string, OrderByType> _taskOrderBy = new()
|
{
|
{nameof(Dt_Task.Grade),OrderByType.Desc },
|
{nameof(Dt_Task.CreateDate),OrderByType.Asc},
|
};
|
|
public List<int> TaskInboundTypes => typeof(TaskTypeEnum).GetEnumIndexList().Where(x => x >= 500 && x < 900).ToList();
|
|
public List<int> TaskOutboundTypes => typeof(TaskTypeEnum).GetEnumIndexList().Where(x => x >= 100 && x < 500).ToList();
|
|
public TaskService(ITaskRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IStockRepository stockRepository, IBasicService basicService, IRecordService recordService, IStockService stockService, IBasicRepository basicRepository, IApiInfoRepository apiInfoRepository, IInvokeERPService invokeERPService, IPalletTypeInfoRepository palletTypeInfoRepository, IAGVStationInfoRepository agvStationInfoRepository, IPurchaseBSTOrderRepository purchaseBSTOrderRepository, IPurchaseBSTOrderDetailRepository purchaseBSTOrderDetailRepository, IOutBSTOrderDetailRepository outBSTOrderDetailRepository, IOutBSTOrderRepository outBSTOrderRepository,IOutBSTOrderDetailService outBSTOrderDetailService) : base(BaseDal)
|
{
|
_mapper = mapper;
|
_unitOfWorkManage = unitOfWorkManage;
|
_stockRepository = stockRepository;
|
_basicService = basicService;
|
_recordService = recordService;
|
_stockService = stockService;
|
_basicRepository = basicRepository;
|
_apiInfoRepository = apiInfoRepository;
|
_invokeERPService = invokeERPService;
|
_palletTypeInfoRepository = palletTypeInfoRepository;
|
_agvStationInfoRepository = agvStationInfoRepository;
|
_purchaseBSTOrderRepository = purchaseBSTOrderRepository;
|
_purchaseBSTOrderDetailRepository = purchaseBSTOrderDetailRepository;
|
_outBSTOrderRepository= outBSTOrderRepository;
|
_outBSTOrderDetailRepository= outBSTOrderDetailRepository;
|
_outBSTOrderDetailService= outBSTOrderDetailService;
|
}
|
|
/// <summary>
|
/// 任务信息推送至WCS
|
/// </summary>
|
/// <returns></returns>
|
public WebResponseContent PushTasksToWCS(List<Dt_Task> tasks, string agvDescription = "")
|
{
|
try
|
{
|
List<WMSTaskDTO> taskDTOs = _mapper.Map<List<WMSTaskDTO>>(tasks);
|
taskDTOs.ForEach(x =>
|
{
|
x.AGVArea = agvDescription;
|
});
|
string url = AppSettings.Get("WCS");
|
if (string.IsNullOrEmpty(url))
|
{
|
return WebResponseContent.Instance.Error($"未找到WCSApi地址,请检查配置文件");
|
}
|
string response = HttpHelper.Post($"{url}/api/Task/ReceiveTask", taskDTOs.Serialize());
|
|
return JsonConvert.DeserializeObject<WebResponseContent>(response) ?? WebResponseContent.Instance.Error("返回错误");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
/// <summary>
|
/// 放货完成
|
/// </summary>
|
/// <param name="code"></param>
|
/// <returns></returns>
|
public WebResponseContent PutFinish(string code, string barCode = "", string taskNum = "")
|
{
|
try
|
{
|
string url = AppSettings.Get("WCS");
|
if (string.IsNullOrEmpty(url))
|
{
|
return WebResponseContent.Instance.Error($"未找到WCSAApi地址,请检查配置文件");
|
}
|
string response = HttpHelper.Post($"{url}/api/CTU_AGV/PutFinish?code={code}&barCode={barCode}&taskNum={taskNum}" );
|
|
return JsonConvert.DeserializeObject<WebResponseContent>(response) ?? WebResponseContent.Instance.Error("返回错误");
|
}
|
catch (Exception ex)
|
{
|
return WebResponseContent.Instance.Error(ex.Message);
|
}
|
}
|
}
|
}
|
