diff --git a/ReadService/MessageClient.cs b/ReadService/MessageClient.cs index 036119d..70a5933 100644 --- a/ReadService/MessageClient.cs +++ b/ReadService/MessageClient.cs @@ -28,7 +28,7 @@ namespace ReadService public void StartListening() { - Console.WriteLine("Redis启动监听朗读声音服务~~~"); + Console.WriteLine("启动监听朗读声音服务~~~"); _redisHandler.SubscribeToChannel("read_messages", OnMessageReceived); } diff --git a/ReadService/ReadBusiness.cs b/ReadService/ReadBusiness.cs deleted file mode 100644 index 095cf8b..0000000 --- a/ReadService/ReadBusiness.cs +++ /dev/null @@ -1,83 +0,0 @@ -using Microsoft.Extensions.Hosting; -using Serilog; -using SlnMesnac.Common; -using SlnMesnac.Model.domain; -using SlnMesnac.Repository.service; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; - -namespace ReadService -{ - public class ReadBusiness : IHostedService - { - - private IMesProductReadInfoService _mesProductReadInfoService; - - - public ReadBusiness(IMesProductReadInfoService mesProductReadInfoService) - { - _mesProductReadInfoService = mesProductReadInfoService; - } - - - public Task StartAsync(CancellationToken cancellationToken) - { - // 启动你的监听逻辑 - ListenRead(); - return Task.CompletedTask; - } - - public Task StopAsync(CancellationToken cancellationToken) - { - // 对于清理工作,可以在这里实现 - return Task.CompletedTask; - } - - - - public void ListenRead() - { - SpeechStr.Instance.Speak("开始监听朗读业务"); - Console.WriteLine("开始监听朗读业务"); - Task.Run(() => - { - - while (true) - { - try - { - // Log.Information("读取业务"); - MesProductReadInfo? mesProductReadInfo = _mesProductReadInfoService.Query(x => x.UseFlag == 1 && x.ReadStatus != 2).OrderBy(x => x.ReadId).FirstOrDefault(); - if (mesProductReadInfo != null) - { - Log.Information($"总次数:{mesProductReadInfo.ReadTotal} 朗读第次数{mesProductReadInfo.ReadCount} 开始朗读:====>{mesProductReadInfo.ReadInfo}"); - SpeechStr.Instance.Speak(mesProductReadInfo.ReadInfo); - mesProductReadInfo.ReadCount++; - mesProductReadInfo.ReadStatus = 1; - mesProductReadInfo.UpdateTime = DateTime.Now; - if (mesProductReadInfo.ReadCount >= mesProductReadInfo.ReadTotal) - { - mesProductReadInfo.ReadStatus = 2; - mesProductReadInfo.EndTime = DateTime.Now; - } - _mesProductReadInfoService.Update(mesProductReadInfo); - Thread.Sleep(1500); - } - else - { - Thread.Sleep(1000 * 10); - } - } - catch (Exception ex) - { - Log.Error(ex.Message); - } - } - }); - } - - } -}