using AngleSharp.Io; using LogLibrary.Log; using Masuit.Tools; using Newtonsoft.Json; using WIDESEA_Common; using WIDESEA_Core; using WIDESEA_Core.Const; using WIDESEA_Core.Helper; using WIDESEA_DTO; using WIDESEA_DTO.MOM; using WIDESEA_IRepository; using WIDESEA_IServices; using WIDESEA_IStorageBasicService; using WIDESEA_IStoragIntegrationServices; using static Org.BouncyCastle.Math.EC.ECCurve; namespace WIDESEA_StoragIntegrationServices; public class CellStateService : ICellStateService { private readonly LogFactory LogFactory = new LogFactory(); private readonly IBoxingInfoService _boxingInfoService; private readonly ISys_ConfigService _configService; public CellStateService(IBoxingInfoService boxingInfoService, ISys_ConfigService configRepository) { _boxingInfoService = boxingInfoService; _configService = configRepository; } /// /// 单电芯属性获取 /// /// 电芯数据 /// public async Task GetCellStateAsync(CellStateDto input) { WebResponseContent content = new WebResponseContent(); try { input.SessionId = Guid.NewGuid().ToString(); input.EmployeeNo = "MITest"; input.RequestTime = TimeZoneInfo.ConvertTimeToUtc(DateTime.Now).ToString("yyyy-MM-ddTHH:mm:ss.fffZ"); var inputJson = Masuit.Tools.ObjectExtensions.ToDictionary(input); var configs = _configService.GetConfigsByCategory(CateGoryConst.SYS_MOMIPAddress); var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.MOMBaseIP)?.ConfigValue; var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.CellState)?.ConfigValue; if (wmsBase == null || ipAddress == null) { throw new InvalidOperationException("WMS IP 未配置"); } var wmsIpAddress = wmsBase + ipAddress; var result = HttpsClient.PostAsync(wmsIpAddress, inputJson).Result; LogFactory.GetLog("单电芯属性获取").Info(true, $"\r\r--------------------------------------"); LogFactory.GetLog("单电芯属性获取").Info(true, result); return result; } catch (Exception err) { //Console.WriteLine(err.Message.ToString()); LogFactory.GetLog("单电芯属性获取").Error(true, $"\r\r--------------------------------------"); LogFactory.GetLog("单电芯属性获取").Error(true, $"请求参数: {JsonConvert.SerializeObject(input)}"); LogFactory.GetLog("单电芯属性获取").Error(true, err.Message); LogFactory.GetLog("单电芯属性获取").Error(true, err.StackTrace); } return Task.FromResult(null); } /// /// 整盘电芯属性获取 /// /// 电芯数据 /// public async Task GetTrayCellStatusAsync(TrayCellsStatusDto input) { WebResponseContent content = new WebResponseContent(); try { input.SessionId = Guid.NewGuid().ToString(); input.EmployeeNo = "MITest"; input.RequestTime = TimeZoneInfo.ConvertTimeToUtc(DateTime.Now).ToString("yyyy-MM-ddTHH:mm:ss.fffZ"); var inputJson = Masuit.Tools.ObjectExtensions.ToDictionary(input); var configs = _configService.GetConfigsByCategory(CateGoryConst.SYS_MOMIPAddress); var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.MOMBaseIP)?.ConfigValue; var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.TrayCellsStatus)?.ConfigValue; if (wmsBase == null || ipAddress == null) { throw new InvalidOperationException("WMS IP 未配置"); } var wmsIpAddress = wmsBase + ipAddress; var result = HttpsClient.PostAsync(wmsIpAddress, inputJson).Result; var respone = JsonConvert.DeserializeObject(result.ToString()); if (!respone.Success) { MoMErrorMsg.AddMoMErrorMsg(0, input.TrayBarcode, respone.MOMMessage, SysConfigConst.TrayCellsStatus); } else { MoMErrorMsg.DeleteMoMErrorMsg(0, input.TrayBarcode); } LogFactory.GetLog("整盘电芯属性获取").Info(true, $"\r\r--------------------------------------"); LogFactory.GetLog("整盘电芯属性获取").Info(true, result); content.OK(data: result); } catch (Exception err) { //MoMErrorMsg.AddMoMErrorMsg(0, input.TrayBarcode, err.Message, SysConfigConst.TrayCellsStatus); //Console.WriteLine(err.Message.ToString()); LogFactory.GetLog("整盘电芯属性获取").Error(true, $"\r\r--------------------------------------"); LogFactory.GetLog("整盘电芯属性获取").Error(true, $"请求参数: {JsonConvert.SerializeObject(input)}"); LogFactory.GetLog("整盘电芯属性获取").Error(true, err.Message); LogFactory.GetLog("整盘电芯属性获取").Error(true, err.StackTrace); } return content; } }