From 8e2d6de4540c86774df77340fde51102b43fb436 Mon Sep 17 00:00:00 2001 From: jianghaiqing Date: Wed, 5 Jul 2023 12:14:59 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B4=BE=E8=BD=A6=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BookingTruck/BookingTruckService.cs | 44 ++++++++++++++++--- 1 file changed, 39 insertions(+), 5 deletions(-) diff --git a/Myshipping.Application/Service/BookingTruck/BookingTruckService.cs b/Myshipping.Application/Service/BookingTruck/BookingTruckService.cs index 8523e280..31bb677e 100644 --- a/Myshipping.Application/Service/BookingTruck/BookingTruckService.cs +++ b/Myshipping.Application/Service/BookingTruck/BookingTruckService.cs @@ -846,9 +846,34 @@ namespace Myshipping.Application throw Oops.Oh($"请求派车调度失败，原因={taskRlt.msg}", typeof(InvalidOperationException)); } - //派车后填写货物状态 - await _bookingOrderService.SetGoodsStatus("YPC", model.Id); - await _bookingOrderService.SendBookingOrder(new long[] { model.Id }); + //这里直接调用订舱服务的功能，担心有异常所以这里单独做了异常捕获 + try + { + //派车后填写货物状态 + await _bookingOrderService.SetGoodsStatus("YPC", model.Id); + + _logger.LogInformation("批次={no} id={id} 更新订舱的货物状态完成", batchNo, model.Id); + } + catch(Exception bkException) + { + _logger.LogInformation("批次={no} id={id} 更新订舱的货物状态 YPC异常，原因：{erro}", batchNo, model.Id, bkException.Message); + } + + //这里直接调用订舱服务的功能，担心有异常所以这里单独做了异常捕获 + try + { + //触发发送东胜 + var currRlt = await _bookingOrderService.SendBookingOrder(new long[] { model.Id }); + + string curMsg = JSON.Serialize(currRlt); + + _logger.LogInformation("批次={no} id={id} 触发发送东胜完成 结果={rlt}", batchNo, model.Id, curMsg); + } + catch (Exception bkException) + { + _logger.LogInformation("批次={no} id={id} 触发发送东胜完成，原因：{erro}", batchNo, model.Id, bkException.Message); + } + //更新派车订单为已提交 model.Status = BookingTruckStatus.SUBMITED.ToString(); model.UpdatedTime = DateTime.Now; @@ -1863,9 +1888,18 @@ namespace Myshipping.Application it.TRUCKER }).ExecuteCommand(); - var syncDongshengRlt = await _bookingOrderService.SendBookingOrder(new long[] { bookingTruckInfo.BookingId.Value }); + //这里直接调用订舱服务的功能，担心有异常所以这里单独做了异常捕获 + try + { + //触发发送东胜 + var syncDongshengRlt = await _bookingOrderService.SendBookingOrder(new long[] { bookingTruckInfo.BookingId.Value }); - _logger.LogInformation($"推送订舱同步东胜完毕，id={bookingTruckInfo.BookingId.Value} rlt={JSON.Serialize(syncDongshengRlt)}"); + _logger.LogInformation($"推送订舱同步东胜完毕，id={bookingTruckInfo.BookingId.Value} rlt={JSON.Serialize(syncDongshengRlt)}"); + } + catch (Exception bkException) + { + _logger.LogInformation("批次={no} id={id} 触发发送东胜完成，原因：{erro}", batchNo, bookingTruckInfo.BookingId.Value, bkException.Message); + } _logger.LogInformation("判断回写需要更新订舱的车队,更新完成"); }