|
@@ -129,7 +129,7 @@ public class RealtimeService : IRealtimeService, IScopeDependency
|
|
|
/// <param name="id"></param>
|
|
|
/// <param name="cancellationToken"></param>
|
|
|
/// <returns></returns>
|
|
|
- public async Task CircularRecoordAsync(string id,string title,string sendContent, CancellationToken cancellationToken)
|
|
|
+ public async Task CircularRecoordAsync(string id, string title, string sendContent, CancellationToken cancellationToken)
|
|
|
{
|
|
|
//获取所有需要推送的
|
|
|
var record = await _circularRecordRepository.Queryable().Where(x => x.Id == id).FirstAsync();
|
|
@@ -138,7 +138,7 @@ public class RealtimeService : IRealtimeService, IScopeDependency
|
|
|
{
|
|
|
//个人数量
|
|
|
await SendToUserAsync(record.UserId, RealtimeMethods.CircularRecord,
|
|
|
- new CircularRecoordDto() { CircularType = Share.Enums.Article.ECircularType.Person, Count = record.RecordCount,SendContent = sendContent,Title= title },
|
|
|
+ new CircularRecoordDto() { CircularType = Share.Enums.Article.ECircularType.Person, Count = record.RecordCount, SendContent = sendContent, Title = title },
|
|
|
cancellationToken);
|
|
|
}
|
|
|
else
|
|
@@ -152,7 +152,7 @@ public class RealtimeService : IRealtimeService, IScopeDependency
|
|
|
//数量
|
|
|
await SendToUserAsync(user.Id, RealtimeMethods.CircularRecord,
|
|
|
new CircularRecoordDto()
|
|
|
- { CircularType = Share.Enums.Article.ECircularType.Org, Count = record.RecordCount,SendContent = sendContent,Title = title },
|
|
|
+ { CircularType = Share.Enums.Article.ECircularType.Org, Count = record.RecordCount, SendContent = sendContent, Title = title },
|
|
|
cancellationToken);
|
|
|
|
|
|
}
|