|
@@ -108,7 +108,7 @@ public class PushDomainService : IPushDomainService, IScopeDependency
|
|
|
}
|
|
|
#endregion
|
|
|
var message = _mapper.Map<Message>(messageDto);
|
|
|
- var id = await _messageRepository.AddAsync(message);//写入本地数据库
|
|
|
+ var id = await _messageRepository.AddAsync(message, cancellation);//写入本地数据库
|
|
|
|
|
|
PushMessageDto pushMessage = new()
|
|
|
{
|
|
@@ -120,7 +120,13 @@ public class PushDomainService : IPushDomainService, IScopeDependency
|
|
|
TelNumber = message.TelNumber
|
|
|
};
|
|
|
|
|
|
- await ExecuteAsync<PushMessageDto, SendSmsReponse>(_sendSmsConfiguration.Value.Url, pushMessage, cancellationToken: cancellation);
|
|
|
+ var result = await ExecuteAsync<PushMessageDto, SendSmsReponse>(_sendSmsConfiguration.Value.Url, pushMessage, cancellationToken: cancellation);
|
|
|
+ if (result != null && result.code == 0)
|
|
|
+ {
|
|
|
+ message.Status = EPushStatus.Success;
|
|
|
+ message.SendState = ESendState.Sending;
|
|
|
+ await _messageRepository.UpdateAsync(message, cancellation);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
/// <summary>
|