diff --git a/CoreCms.Net.RedisMQ/WeChatPayShippingSubscribe.cs b/CoreCms.Net.RedisMQ/WeChatPayShippingSubscribe.cs index da6a12be..ce0a1e94 100644 --- a/CoreCms.Net.RedisMQ/WeChatPayShippingSubscribe.cs +++ b/CoreCms.Net.RedisMQ/WeChatPayShippingSubscribe.cs @@ -170,7 +170,7 @@ namespace CoreCms.Net.RedisMQ return; } - var weChatUserInfo = await _weChatInfoServices.QueryByClauseAsync(p => p.userId == user.id); + var weChatUserInfo = await _weChatInfoServices.QueryByClauseAsync(p => p.userId == user.id && p.type == (int)GlobalEnumVars.UserAccountTypes.微信小程序); if (weChatUserInfo == null) { NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + ":用户信息openId获取失败");