ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

config upd

Browse Source
This commit is contained in:
xiaolipro 2025-09-28 09:40:16 +08:00
parent f3276404ac
commit 52c16b3738
3 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/TrackCenter.Api/appsettings.json
View File

@ -140,9 +140,9 @@
"ScanTransportWarningDetailsGenerateTaskMinuteInterval": 5
},
"InterfaceRelayParamsConfig": {
"OrderPath": "[*]",
"OrderPath": "",
"OrderNoName": "trackNo",
"TrackDetailsPath": "data[*]",
"TrackDetailsPath": "data",
"TrackContentCodeName": "code",
"TrackStatusName": "status",
"TrackContentName": "content",

4
src/TrackCenter.Application/Dtos/TrackPush/EditTrackPushConfigInput.cs
View File

@ -5,12 +5,12 @@ public class EditTrackPushConfigInput
/// <summary>
/// 客户
/// </summary>
public string Customer { get; set; }
public string? Customer { get; set; }
/// <summary>
/// 应用
/// </summary>
public string AppKey { get; set; }
public string? AppKey { get; set; }
public int? Id { get; set; }

14
src/TrackCenter.Application/Rabbit/TrackRefreshEventHandler.cs
View File

@ -74,7 +74,7 @@ public class TrackRefreshEventHandler : ITransientDependency, IRabbitHandler
}
var attach = Base64Helper.DeSerialize<TrackRefreshAttach>(@event.Attach);
if (attach is null || @event.Data == null)
if (attach is null || @event.Data.IsNullOrWhiteSpace())
{
_logger.LogWarning("请求id: {@RequestId}，轨迹消费失败，attach或data解析为空", @event.RequestId);
return;
@ -88,7 +88,7 @@ public class TrackRefreshEventHandler : ITransientDependency, IRabbitHandler
return;
}
var data = JObject.Parse(@event.Data);
var data = JToken.Parse(@event.Data);
var orderToken = data.SelectToken(config.ParamConfig.OrderPath);
if (orderToken is JArray orderTokens)
@ -217,23 +217,23 @@ public class TrackRefreshEventHandler : ITransientDependency, IRabbitHandler
// 轨迹发生ISO时间
var trackIsoTime = paramConfig.TrackIsoTimeName == null
? null
: trackToken.SelectToken(paramConfig.TrackIsoTimeName)?.ToObject<DateTimeOffset>();
: trackToken.SelectToken(paramConfig.TrackIsoTimeName)?.Value<DateTimeOffset>();
// 轨迹发生UTC时间
var trackUtcTime = paramConfig.TrackUtcTimeName == null
? null
: trackToken.SelectToken(paramConfig.TrackUtcTimeName)?.ToObject<DateTime>();
: trackToken.SelectToken(paramConfig.TrackUtcTimeName)?.Value<DateTime>();
// 轨迹发生时间
var trackTime = trackIsoTime?.DateTime ?? (paramConfig.TrackTimeName == null
? null
: trackToken.SelectToken(paramConfig.TrackTimeName)?.ToObject<DateTime>());
: trackToken.SelectToken(paramConfig.TrackTimeName)?.Value<DateTime>());
// 轨迹发生时区
var trackTimeZone = (float?) trackIsoTime?.Offset.TotalHours ?? (paramConfig.TrackTimeZoneName == null
? null
: trackToken.SelectToken(paramConfig.TrackTimeZoneName)?.ToObject<float>());
: trackToken.SelectToken(paramConfig.TrackTimeZoneName)?.Value<float>());
// 轨迹发生地
var trackPlace = paramConfig.TrackPlaceName == null
? null
: trackToken.SelectToken(paramConfig.TrackPlaceName)?.ToObject<string>();
: trackToken.SelectToken(paramConfig.TrackPlaceName)?.Value<string>();
// 轨迹扩展信息，根据输入的多个字段提取报文内容，构建一个新的对象的json形式
var trackExtra = paramConfig.TrackExtraNames == null
? null