补扣接口

Myshipping.Application/Event/BookingFeeSubscriber.cs

@@ -77,8 +77,8 @@ namespace Myshipping.Application.Event
             //var feeUserId = sysCfg.FirstOrDefault(x => x.Code == "djyFeeApiUserId");
             //var feeKey = sysCfg.FirstOrDefault(x => x.Code == "djyFeeApiKey");
             if (feeUrl == null || string.IsNullOrEmpty(feeUrl.Value))
-                //|| feeUserId == null || string.IsNullOrEmpty(feeUserId.Value)
-                //|| feeKey == null || string.IsNullOrEmpty(feeKey.Value))
+            //|| feeUserId == null || string.IsNullOrEmpty(feeUserId.Value)
+            //|| feeKey == null || string.IsNullOrEmpty(feeKey.Value))
             {
                 var errMsg = "大简云扣费URL未配置";
                 _logger.LogError(errMsg);
@@ -89,6 +89,14 @@ namespace Myshipping.Application.Event
             foreach (var id in idToDo)
             {
                 var order = await repoBooking.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == id);
+                if (order == null)
+                {
+                    var errMsg = $"未找到id为 {id} 的订舱数据,扣费失败提醒";
+                    _logger.LogError(errMsg);
+                    DingTalkGroupHelper.SendDingTalkGroupMessage("bookingFeeNotify", "扣费失败提醒", errMsg);
+                    continue;
+                }
+
                 var iptId = string.IsNullOrEmpty(order.OPID) ? order.CreatedUserId.Value : Convert.ToInt64(order.OPID);
                 var user = await repoUser.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == iptId);
                 var keyList = await repoTenantParamValue.AsQueryable()

Myshipping.Application/Service/BookingOrder/BookingOrderService.cs

@@ -10290,8 +10290,8 @@ namespace Myshipping.Application
         /// 临时补扣费用
         /// </summary>
         /// <returns></returns>
-        [HttpGet("/BookingOrder/FeeById"), AllowAnonymous]
-        public async Task FeeById(List<long> idList, int bsType = 28, int sendtype = 0)
+        [HttpPost("/BookingOrder/FeeById"), AllowAnonymous]
+        public async Task FeeById([FromBody] List<long> idList, int bsType = 28, int sendtype = 0)
         {
             await _publisher.PublishAsync(new ChannelEventSource($"Booking:DoFeeRecord", new { bsType = bsType, sendtype = sendtype, idList = idList }));
         }