@@ -45,7 +45,7 @@ public class ImportApplicationBase<TSource, TEntity, TMix> : IImportApplication
public virtual async Task ImportAsync(Action<string> log, CancellationToken token)
{
log($"正在查询旧数据...");
- //var sql = GetSourceList().ToSqlString();
+ var sql = GetSourceList().ToSqlString();
Sources = await GetSourceList().ToListAsync(token);
log($"共查询到{Sources.Count}条数据");
@@ -68,6 +68,7 @@ public class SnapshotUserInfoApplication : ImportApplicationBase<WeChatUserEntit
return _sourceRepo.Queryable()
.Where(m => m.WUR_UserType == "ssp")
+ .WhereIF(_instance.Keyword.NotNullOrEmpty(), m => m.WUR_PhoneNum == _instance.Keyword)
.WhereIF(key.NotNullOrEmpty(), m => m.WUR_Openid == key);
}