优化工单商铺数量限制

OrderSupportTicket/Services/EventSourceTicketRealtimeService.cs

@@ -40,9 +40,8 @@ public sealed class EventSourceTicketRealtimeService
 
 		TicketApiService.ValidateOptions(options);
 		StopCore();
-
-		var uri = BuildEventsUri(options);
-		var source = new EventSource(uri);
+		var config = BuildEventsUri(options);
+		var source = new EventSource(config);
 		source.Opened += OnOpened;
 		source.Closed += OnClosed;
 		source.MessageReceived += OnMessageReceived;
@@ -77,7 +76,6 @@ public sealed class EventSourceTicketRealtimeService
 	{
 		try
 		{
-			NLogger.Instance.Info("工单服务连接成");
 			await source.StartAsync();
 			lock (_sync)
 			{
@@ -182,22 +180,45 @@ public sealed class EventSourceTicketRealtimeService
 			new TicketRealtimeStateChangedEventArgs(state, message));
 	}
 
-	private static Uri BuildEventsUri(TicketClientOptions options)
+	//private static Uri BuildEventsUri(TicketClientOptions options)
+	//{
+	//	var appIds = options.AppIds
+	//		.Where(a => !string.IsNullOrWhiteSpace(a))
+	//		.Distinct(StringComparer.Ordinal)
+	//		.Select(a => "appId=" + Uri.EscapeDataString(a.Trim()));
+	//	var query = new[]
+	//	{
+	//		"purchaseAccount=" + Uri.EscapeDataString(options.UserName)
+	//	}.Concat(appIds);
+
+	//	return new Uri(
+	//		TicketApiService.ServerUrl
+	//		+ EventsPath
+	//		+ "?"
+	//		+ string.Join("&", query),
+	//		UriKind.Absolute);
+	//}
+
+	private static Configuration BuildEventsUri(TicketClientOptions options)
 	{
 		var appIds = options.AppIds
 			.Where(a => !string.IsNullOrWhiteSpace(a))
 			.Distinct(StringComparer.Ordinal)
-			.Select(a => "appId=" + Uri.EscapeDataString(a.Trim()));
+			.Select(a => Uri.EscapeDataString(a.Trim()));
 		var query = new[]
 		{
 			"purchaseAccount=" + Uri.EscapeDataString(options.UserName)
-		}.Concat(appIds);
-
-		return new Uri(
+		};
+		var uri = new Uri(
 			TicketApiService.ServerUrl
 			+ EventsPath
 			+ "?"
 			+ string.Join("&", query),
 			UriKind.Absolute);
+		ConfigurationBuilder builder = Configuration.Builder(uri);
+		builder.RequestHeader("X-AppIds", $"[\"{string.Join("\",\"", appIds)}\"]");
+		builder._responseStartTimeout = TimeSpan.FromSeconds(30);
+		
+		return builder.Build();
 	}
 }