更新缓存包

src/yibin/Push.YiBin.Host/config/appsettings.Development.json

@@ -21,7 +21,7 @@
   "Cache": {
     "Host": "110.188.24.182",
     "Port": 50179,
-    //"Password": "fengwo22@@",
+    "Password": "fengwo123!$!$",
     "Database": 4
   },
   "Swagger": true,

src/yibin/Push.YiBin.Host/config/appsettings.json

@@ -21,7 +21,7 @@
   "Cache": {
     "Host": "110.188.24.182",
     "Port": 50179,
-    //"Password": "fengwo22@@",
+    "Password": "fengwo123!$!$",
     "Database": 4
   },
   "Swagger": true,

src/yibin/Push.YiBin/Push.YiBin.csproj

@@ -12,7 +12,7 @@
         <PackageReference Include="Quartz.Jobs" Version="3.9.0" />
         <PackageReference Include="System.Linq.Dynamic.Core" Version="1.3.7" />
       <PackageReference Include="XF.Domain.Repository" Version="1.0.6" />
-      <PackageReference Include="XF.EasyCaching" Version="1.0.4" />
+      <PackageReference Include="XF.EasyCaching" Version="1.0.6" />
     </ItemGroup>
 
     <ItemGroup>

src/yibin/Push.YiBin/PushDomainService.cs

@@ -134,7 +134,7 @@ public class PushDomainService : IPushDomainService, IScopeDependency
         int WaitSendId = GenerateWaitSendId();
         message.WaitSendId = WaitSendId;
 
-        _logger.LogInformation($"取到WaitSendId值：{WaitSendId}");
+        _logger.LogInformation($"取到WaitSendId值：{WaitSendId}"+DateTime.Now);
 
         //调用短信发送业务
         var strResult = await SmsSend(messageDto, WaitSendId);
@@ -381,7 +381,7 @@ public class PushDomainService : IPushDomainService, IScopeDependency
     /// <returns></returns>
     private async Task<string> SmsSend(Share.Dtos.MessageDto messageDto, int WaitSendId)
     {
-        _logger.LogInformation("准备短信推送");
+        _logger.LogInformation("准备短信推送---------------------"+DateTime.Now);
         string strResult;
         try
         {
@@ -484,7 +484,7 @@ public class PushDomainService : IPushDomainService, IScopeDependency
     /// <returns></returns>
     private async Task<string> PostHelper(string url, HttpContent content)
     {
-        _logger.LogInformation($"准备推送短信, {nameof(PostHelper)}");
+        _logger.LogInformation($"准备推送短信, {nameof(PostHelper)}"+DateTime.Now);
         var result = string.Empty;
         try
         {

src/yibin/Push.YiBin/TaskSendMessageJob.cs

@@ -45,7 +45,7 @@ namespace Push.YiBin
         /// <returns></returns>
         public async Task Execute(IJobExecutionContext context)
         {
-            _logger.LogWarning("进来了，时间是：" + DateTime.Now);
+           // _logger.LogWarning("进来了，时间是：" + DateTime.Now);
             var tasks = await _waitMessageRepository.Queryable()
                   .Where(d => d.Status == EPushStatus.Waiting && d.SendTimes <= 3)
                   .OrderBy(d => d.CreationTime)
@@ -58,7 +58,9 @@ namespace Push.YiBin
                     sendTask.Status = EPushStatus.Pushing;
                     if (await _waitMessageRepository.Updateable(sendTask).ExecuteCommandWithOptLockAsync() > 0)
                     {
+                        _logger.LogWarning("执行前，时间是：" + DateTime.Now);
                         var result = await _pushDomainService.PushNewAsync(_mapper.Map<Share.Dtos.MessageDto>(sendTask));
+                        _logger.LogWarning("执行后，时间是：" + DateTime.Now);
                         if (result.SendState == ESendState.Sending && result.Status == EPushStatus.Success)
                         {
                             //删除待推送表