#region << 版 本 注 释 >>
|
/*----------------------------------------------------------------
|
* 命名空间：WIDESEAWCS_TaskInfoService
|
* 创建者：胡童庆
|
* 创建时间：2024/8/2 16:13:36
|
* 版本：V1.0.0
|
* 描述：
|
*
|
* ----------------------------------------------------------------
|
* 修改人：
|
* 修改时间：
|
* 版本：V1.0.1
|
* 修改说明：
|
*
|
*----------------------------------------------------------------*/
|
#endregion << 版 本 注 释 >>
|
|
using AutoMapper;
|
using AutoMapper.Internal;
|
using Castle.Components.DictionaryAdapter.Xml;
|
using HslCommunication;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.AspNetCore.Mvc.RazorPages;
|
using Microsoft.OpenApi.Any;
|
using NetTaste;
|
using Newtonsoft.Json;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.DateTime;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
|
using SqlSugar;
|
using StackExchange.Profiling.Internal;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Data;
|
using System.Diagnostics;
|
using System.Diagnostics.CodeAnalysis;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Reflection;
|
using System.Reflection.Metadata;
|
using System.Security.Cryptography.Xml;
|
using System.Security.Policy;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA_Comm.Http;
|
using WIDESEA_Common.Log;
|
using WIDESEA_Core.Enums;
|
using WIDESEAWCS_Common.TaskEnum;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_Core.BaseServices;
|
using WIDESEAWCS_Core.Enums;
|
using WIDESEAWCS_Core.Utilities;
|
using WIDESEAWCS_DTO.Enum;
|
using WIDESEAWCS_DTO.TaskInfo;
|
using WIDESEAWCS_ITaskInfoRepository;
|
using WIDESEAWCS_ITaskInfoService;
|
using WIDESEAWCS_Model.Models;
|
using WIDESEAWCS_QuartzJob;
|
using WIDESEAWCS_QuartzJob.DTO;
|
using WIDESEAWCS_QuartzJob.Models;
|
using WIDESEAWCS_QuartzJob.Service;
|
using WIDESEAWCS_TaskInfoRepository;
|
using static Microsoft.IO.RecyclableMemoryStreamManager;
|
|
namespace WIDESEAWCS_TaskInfoService
|
{
|
public partial class TaskService
|
{
|
|
//============================================以下是后续新增内容查找任务=============================================================
|
#region wms任务模块
|
//任务下发
|
public ApiResponse saveTask(TransferTask transfer)
|
{
|
WriteLog.Write_Log("WMS任务下发接口", "WMS任务下发接口信息", "调取参数", transfer);
|
|
ApiResponse apiResponse = new ApiResponse();
|
try
|
{
|
if (transfer == null) return apiResponse.ErrorResponse("接收的WMS任务下发参数为空");
|
// 进一步校验必要字段
|
if (string.IsNullOrEmpty(transfer.taskType)) return apiResponse.ErrorResponse("任务类型不能为空");
|
if (string.IsNullOrEmpty(transfer.barCode)) return apiResponse.ErrorResponse("条码不能为空");
|
if (transfer.from == null || string.IsNullOrEmpty(transfer.from.code)) return apiResponse.ErrorResponse("起始位置不能为空");
|
if (transfer.to == null || string.IsNullOrEmpty(transfer.to.code)) return apiResponse.ErrorResponse("目标位置不能为空");
|
if (transfer.device == null || string.IsNullOrEmpty(transfer.device.uuid)) return apiResponse.ErrorResponse("设备标识不能为空");
|
|
Dt_Task? setask = BaseDal.QueryData(x => x.WMStaskid == transfer.barCode).FirstOrDefault();
|
if (setask != null) return apiResponse.ErrorResponse($"WCS已有当前任务，不可重复下发，托盘编号：{transfer.barCode}");
|
|
|
|
(int TaskType, int TaskState) = transfer.taskType switch
|
{
|
"in" => ((int)TaskTypeEnum.Inbound, (int)TaskInStatusEnum.InNew),
|
"out" => ((int)TaskTypeEnum.Outbound, (int)TaskOutStatusEnum.OutNew),
|
"check" => ((int)TaskTypeEnum.Inventorybound, (int)TaskinventoryStatusEnum.inventoryNew),
|
_ => (0, 0) // 保持原有的默认值
|
};
|
|
Dt_Task task = new Dt_Task();
|
task.TaskNum = BaseDal.GetTaskNum(nameof(SequenceEnum.SeqTaskNum)); //任务编号
|
task.PalletCode = transfer.original_barCode;
|
task.Roadway = transfer.from.code.Substring(0, 1);
|
task.TaskType = TaskType;
|
task.TaskState = TaskState;
|
task.SourceAddress = transfer.from.code;
|
task.TargetAddress = transfer.to.code;
|
task.CurrentAddress = transfer.from.code;
|
task.NextAddress = transfer.to.code;
|
task.Grade = 1;
|
task.Creater = "WMS";
|
task.CreateDate = DateTime.Now;
|
task.WMStaskid = transfer.barCode;
|
task.deviceuuid = transfer.device.uuid;
|
|
_unitOfWorkManage.BeginTran();
|
BaseDal.AddData(task);
|
_unitOfWorkManage.CommitTran();
|
return apiResponse.SuccessResponse();
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
|
}
|
}
|
|
|
|
//通知库口上料完成
|
public ApiResponse scanData(TaskReportingData taskReporting)
|
{
|
WriteLog.Write_Log("通知库口上料完成接口", "通知库口上料完成信息", "调取参数", taskReporting);
|
|
ApiResponse apiResponse = new ApiResponse();
|
try
|
{
|
if (taskReporting == null) return apiResponse.ErrorResponse("接收的WMS任务下发参数为空");
|
if (taskReporting.baseInfo == null) return apiResponse.ErrorResponse("库口基础数据baseInfo不能为空");
|
if (string.IsNullOrWhiteSpace(taskReporting.baseInfo.code)) return apiResponse.ErrorResponse("任务类型不能为空");
|
if (taskReporting.details == null || !taskReporting.details.Any()) return apiResponse.ErrorResponse("库口详情集合details不能为空/无数据");
|
|
|
|
return apiResponse.SuccessResponse();
|
}
|
catch (Exception ex)
|
{
|
return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
|
}
|
}
|
|
//获取库口状态
|
public ApiResponse getPortStatus(string[] datas)
|
{
|
WriteLog.Write_Log("获取库口状态接口", "获取库口状态信息", "调取参数", datas);
|
|
ApiResponse apiResponse = new ApiResponse();
|
try
|
{
|
|
|
Dictionary<string, int> portStatusDict = new Dictionary<string, int>();
|
|
foreach (string DeStateName in datas)
|
{
|
string DeciceCodes = "1003";
|
if (DeStateName.StartsWith("C")) DeciceCodes = "1004";
|
|
|
IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == DeciceCodes);
|
if (device == null) return apiResponse.ErrorResponse("WCS未能获取到库口实例");
|
CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
|
|
|
//是否可进出
|
DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == DeStateName && x.DeviceProParamName == "PermitHandShake");
|
//是否有货
|
DeviceProDTO? StationNumProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == DeStateName && x.DeviceProParamName == "StationNum");
|
if (deviceProDTO == null || StationNumProDTO ==null) return apiResponse.ErrorResponse($"WCS未找到库口：{DeStateName},对应的协议");
|
|
int statusValue = 0;
|
//1允许取 2允许放
|
int portStatus = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
|
//是否有货
|
int StationStatus = conveyorLine.Communicator.Read<ushort>(StationNumProDTO.DeviceProAddress);
|
|
|
if(DeStateName== "G01" || DeStateName == "G06" || DeStateName == "G07")
|
{
|
//有货，可进信号
|
statusValue = (portStatus == 1 && StationStatus == 1) ? 1 : (portStatus == 2 && StationStatus == 0) ?0: (portStatus == 0) ? 0 : 0;
|
}
|
else
|
{
|
statusValue = StationStatus == 1 ? 0 : 1;
|
}
|
portStatusDict[DeStateName] = statusValue;
|
}
|
|
return apiResponse.SuccessResponse(portStatusDict);
|
}
|
catch (Exception ex)
|
{
|
return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
|
}
|
}
|
|
|
//获取光幕状态
|
public ApiResponse getSafeStatus(string[] datas)
|
{
|
WriteLog.Write_Log("获取光幕状态接口", "获取光幕状态信息", "调取参数", setCurtain);
|
ApiResponse apiResponse = new ApiResponse();
|
try
|
{
|
Dictionary<string, int> portStatusDict = new Dictionary<string, int>();
|
foreach (string DeStateName in datas)
|
{
|
portStatusDict[DeStateName] = 1;
|
}
|
|
return apiResponse.SuccessResponse(portStatusDict);
|
}
|
catch (Exception ex)
|
{
|
return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
|
}
|
}
|
|
|
//设置光幕
|
public ApiResponse setCurtain(SetCurtainRequest setCurtain)
|
{
|
//获取WMS调取的参数
|
WriteLog.Write_Log("设置光幕接口", "设置光幕接口信息", $"库口名称：【{string.Join(",", setCurtain.Datas)}】,申请状态：【{setCurtain.Operate}】");
|
ApiResponse apiResponse = new ApiResponse();
|
bool HandShakeboolOPEN = false;
|
bool HandShakeboolCLOSE = false;
|
try
|
{
|
Dictionary<string, int> portStatusDict = new Dictionary<string, int>();
|
foreach (string DeStateName in setCurtain.Datas)
|
{
|
string DeciceCodes = "1003";
|
if (DeStateName.StartsWith("C")) DeciceCodes = "1004";
|
|
IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == DeciceCodes);
|
if (device == null) return apiResponse.ErrorResponse("WCS未能获取到库口实例");
|
|
CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
|
|
DeviceProDTO? HandShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == DeStateName && x.DeviceProParamName == "HandShake");
|
if (HandShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{setCurtain.Datas},对应的协议");
|
DeviceProDTO? Request = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == DeStateName && x.DeviceProParamName == "Request");
|
if (HandShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{setCurtain.Datas},对应的协议");
|
|
if (setCurtain.Operate.Equals("OPEN"))
|
{
|
//写入plc，agv退出中打开信号
|
if(DeStateName == "G01" || DeStateName == "G06" || DeStateName == "G07")
|
{
|
HandShakeboolOPEN = conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 0);
|
}
|
else
|
{
|
HandShakeboolOPEN = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 0);
|
}
|
|
}
|
else
|
{
|
//写入plc，agv进入关闭光栅信号
|
if (DeStateName == "G01" || DeStateName == "G06" || DeStateName == "G07")
|
{
|
HandShakeboolCLOSE = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 1) && conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 1);
|
}
|
else
|
{
|
HandShakeboolCLOSE = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 1);
|
}
|
|
}
|
}
|
if ((HandShakeboolOPEN && setCurtain.Operate.Equals("OPEN") )|| (HandShakeboolCLOSE && setCurtain.Operate.Equals("CLOSE")))
|
{
|
return apiResponse.SuccessResponse();
|
}
|
else
|
{
|
return apiResponse.ErrorResponse("写入plc进入信号失败");
|
}
|
}
|
catch (Exception ex)
|
{
|
return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
|
}
|
}
|
|
|
|
|
//agv进出状态反馈
|
public ApiResponse getAGVStatus(AgvUpdateRequest agvUpdateRequest)
|
{
|
//获取WMS调取的参数
|
WriteLog.Write_Log("agv进出状态反馈接口", "agv进出状态信息", $"库口名称：【{agvUpdateRequest.warehousenumber}】，申请状态：【{agvUpdateRequest.agvstatus}】");
|
|
ApiResponse apiResponse = new ApiResponse();
|
try
|
{
|
string DeciceCodes = "1003";
|
if (agvUpdateRequest.warehousenumber.StartsWith("C")) DeciceCodes = "1004";
|
|
IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == DeciceCodes);
|
if (device == null) return apiResponse.ErrorResponse("WCS未能获取到库口实例");
|
CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
|
|
//是否可进出
|
DeviceProDTO? HandShake = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "HandShake");
|
if (HandShake == null) return apiResponse.ErrorResponse($"WCS未找到库口：{agvUpdateRequest.warehousenumber},对应的协议");
|
DeviceProDTO? Request = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "Request");
|
|
if (agvUpdateRequest.agvstatus == 1)
|
{
|
bool HandShakebool = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 1);
|
if (HandShakebool)
|
{
|
if (Request != null)
|
{
|
conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 1);
|
}
|
//是否可进出 1允许取 2允许放
|
DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "PermitHandShake");
|
//是否有货
|
DeviceProDTO? StationNumProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == agvUpdateRequest.warehousenumber && x.DeviceProParamName == "StationNum");
|
if (deviceProDTO == null || StationNumProDTO == null) return apiResponse.ErrorResponse($"WCS未找到库口：{agvUpdateRequest.warehousenumber},对应的协议");
|
int statusValue = 0;
|
int portStatus = conveyorLine.Communicator.Read<ushort>(deviceProDTO.DeviceProAddress);
|
int StationStatus = conveyorLine.Communicator.Read<ushort>(StationNumProDTO.DeviceProAddress);
|
|
//有货，可进信号
|
statusValue = ((portStatus == 1 && StationStatus == 1) || (portStatus == 2 && StationStatus == 0)) ? 1 : (portStatus == 0) ? 0 : 0;
|
if (agvUpdateRequest.warehousenumber == "G01" || agvUpdateRequest.warehousenumber == "G06" || agvUpdateRequest.warehousenumber == "G07")
|
{
|
if (statusValue == 1)
|
{
|
return apiResponse.SuccessResponse();
|
|
}
|
else
|
{
|
conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 0);
|
return apiResponse.ErrorResponse("读取plc不可进入信息");
|
}
|
}
|
else
|
{
|
return apiResponse.SuccessResponse();
|
}
|
}
|
else
|
{
|
return apiResponse.ErrorResponse("写入plc进入信号失败");
|
}
|
}
|
else if (agvUpdateRequest.agvstatus == 2)
|
{
|
//写入输送线信号
|
bool portStatus = conveyorLine.Communicator.Write<short>(HandShake.DeviceProAddress, 0);
|
if (portStatus)
|
{
|
if (Request != null)
|
{
|
conveyorLine.Communicator.Write<short>(Request.DeviceProAddress, 0);
|
}
|
return apiResponse.SuccessResponse();
|
}
|
else
|
{
|
return apiResponse.ErrorResponse("写入plc清除信号失败");
|
}
|
}
|
else
|
{
|
return apiResponse.ErrorResponse($"agv对应的申请错误，字段：agvstatus，申请的值：{agvUpdateRequest.agvstatus}");
|
}
|
|
}
|
catch (Exception ex)
|
{
|
return apiResponse.ErrorResponse($"WCS任务添加错误，原因：{ex.Message}");
|
}
|
}
|
#endregion
|
|
|
|
#region 调取上游接口
|
public CommandResult taskreturn(int taskId, string taskType, string invType, string psd)
|
{
|
CommandResult commandResult = new CommandResult();
|
try
|
{
|
TaskInfo taskInfo1 = new TaskInfo();
|
taskInfo1.taskId = taskId;
|
taskInfo1.taskType = taskType;
|
taskInfo1.invType = invType;
|
taskInfo1.psd = "akjfapjfpadaoif";
|
|
commandResult = HttpHelper.Post<CommandResult>(urlWMStaskreturn, taskInfo1, "任务状态回调");
|
|
WriteLog.Write_Log("同步给上游反馈任务完成", "任务信息", $"任务号：{taskId}", $"调取参数：{taskInfo1.ToJsonString()},返回参数：{commandResult.ToJsonString()}");
|
return commandResult;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine("调取上游接口错误：原因："+ex.Message);
|
commandResult.status = "error";
|
string resujos = $"WCS接口错误，原因：{ex.Message}";
|
commandResult.result = resujos.ToJsonString();
|
|
WriteLog.Write_Log("同步给上游反馈任务完成", "任务信息", $"任务号：{taskId}", $"需要上传WMS信息内容：{commandResult.ToJsonString()},WCS接口错误，原因：{ex.Message}");
|
return commandResult;
|
}
|
|
}
|
|
public CommandResult deverror(string devuuid, string id, string errorcode, string errorinfo, string erroraddress, string warehouse, string remark, string devname, string dealType, string psd)
|
{
|
CommandResult commandResult = new CommandResult();
|
try
|
{
|
DeviceErrorRequest deviceErrorRequest = new DeviceErrorRequest
|
{
|
devErrorJsons = new List<DeviceErrorInfo>
|
{
|
new DeviceErrorInfo
|
{
|
devuuid = devuuid,
|
id = id,
|
errorcode = errorcode,
|
errorinfo = errorinfo,
|
erroraddress = erroraddress,
|
warehouse = warehouse,
|
remark = remark,
|
devname = devname
|
}
|
},
|
dealType = dealType,
|
psd = "akjfapjfpadaoif",
|
};
|
|
commandResult = HttpHelper.Post<CommandResult>(urlWMSdeverror, deviceErrorRequest, "设备故障回调");
|
WriteLog.Write_Log("同步给上游设备故障信息", "设备故障信息", $"设备id：{devuuid}，成功", $"调取参数：{deviceErrorRequest.ToJson()},返回参数：{commandResult.ToJson()}");
|
return commandResult;
|
}
|
catch (Exception ex)
|
{
|
commandResult.status = "error";
|
string resujos = $"WCS接口错误，原因：{ex.Message}";
|
commandResult.result = resujos.ToJsonString();
|
|
|
WriteLog.Write_Log("同步给上游设备故障信息", "设备故障信息", $"设备id：{devuuid}，失败", $"WCS接口错误，原因：{ex.Message}");
|
return commandResult;
|
}
|
|
}
|
|
|
public CommandResult liftinposition(string invtype, string invcode, string kloccode)
|
{
|
CommandResult commandResult = new CommandResult();
|
try
|
{
|
ShelvesPosition deviceErrorRequest = new ShelvesPosition
|
{
|
invtype= invtype,
|
invcode = invcode,
|
kloccode = kloccode
|
};
|
commandResult = HttpHelper.Post<CommandResult>(urlWMSliftinposition, deviceErrorRequest, "设备故障回调");
|
|
WriteLog.Write_Log("同步给上游提升到位信息", "信息内容", $"库口编号：{kloccode}，成功信息", $"调取参数：{deviceErrorRequest.ToJson()},返回参数：{commandResult.ToJson()}");
|
return commandResult;
|
}
|
catch (Exception ex)
|
{
|
commandResult.status = "error";
|
string resujos = $"WCS接口错误，原因：{ex.Message}";
|
commandResult.result = resujos.ToJsonString();
|
|
WriteLog.Write_Log("同步给上游提升到位信息", "信息内容", $"错误信息", $"WCS接口错误，原因：{ex.Message}");
|
return commandResult;
|
}
|
|
}
|
#endregion
|
}
|
}
|
