tangjiang 10 months ago
parent
commit
6d5c795b17
1 changed files with 7 additions and 5 deletions
  1. 7 5
      src/DataSharing.Application/Receivers/ProvinceReceiver.cs

+ 7 - 5
src/DataSharing.Application/Receivers/ProvinceReceiver.cs

@@ -19,7 +19,6 @@ using DataSharing.Share.Dtos.Province.XieTong.Send;
 using DataSharing.Share.Enums;
 using DataSharing.WebPortal;
 using DotNetCore.CAP;
-using Hotline.Share.Dtos.DataSharing.PusherHotlineDto;
 using Hotline.Share.Dtos.Knowledge;
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Dtos.TrCallCenter;
@@ -28,7 +27,6 @@ using Hotline.Share.Enums.FlowEngine;
 using Hotline.Share.Enums.Order;
 using MapsterMapper;
 using Microsoft.Extensions.Logging;
-using StackExchange.Redis;
 using System.Security.Cryptography;
 using System.Text;
 using System.Web;
@@ -2449,13 +2447,17 @@ namespace DataSharing.Application.Receivers
                 default:
                     break;
             }
+            var userInfoSend = await _dsUserTokenInfoRepository.GetAsync(p => p.PlatformSource == dto.Source.ToString() && p.State == "1", cancellationToken);
+            if (userInfoSend is null)
+                return;
+            string source = userInfoSend.PlatformSourceName;
+            string secretKey = GetMD5(source + userInfoSend.AccountSecret);
 
-            var userInfo = await _dsUserTokenInfoRepository.GetAsync(p => p.PlatformSource == PlatformSource && p.State == "1", cancellationToken);
+            var userInfo = await _dsUserTokenInfoRepository.GetAsync(p => p.PlatformSource == dto.Source.ToString() && p.State == "1", cancellationToken);
             if (userInfo is null)
                 return;
 
-            string source = userInfo.PlatformSourceName;
-            string secretKey = GetMD5(source + userInfo.AccountSecret);
+
 
             Dictionary<string, object> dic = new()
             {