|
@@ -61,18 +61,23 @@ namespace TEAMModelBI.Controllers.BIBlob
|
|
|
|
|
|
await foreach (BlobItem blobItem in blobCilent.GetBlobsAsync(BlobTraits.None, BlobStates.None, $"visitCnt/{day}"))
|
|
|
{
|
|
|
- BlobClient tempClient = blobCilent.GetBlobClient(blobItem.Name);
|
|
|
- if (await tempClient.ExistsAsync())
|
|
|
+ string[] arr = blobItem.Name.Split('.');
|
|
|
+ string houzhui = arr[arr.Length - 1];
|
|
|
+ if (houzhui.Equals("json"))
|
|
|
{
|
|
|
- using (var meomoryStream = new MemoryStream())
|
|
|
+ BlobClient tempClient = blobCilent.GetBlobClient(blobItem.Name);
|
|
|
+ if (await tempClient.ExistsAsync())
|
|
|
{
|
|
|
- var response = blobCilent.GetBlobClient($"{blobItem.Name}").DownloadTo(meomoryStream);
|
|
|
- //var response = await blob.GetBlobClient($"{blobItem.Name}").DownloadToAsync(meomoryStream);
|
|
|
+ using (var meomoryStream = new MemoryStream())
|
|
|
+ {
|
|
|
+ var response = blobCilent.GetBlobClient($"{blobItem.Name}").DownloadTo(meomoryStream);
|
|
|
+ //var response = await blob.GetBlobClient($"{blobItem.Name}").DownloadToAsync(meomoryStream);
|
|
|
|
|
|
- RecCnt recCnt = Encoding.UTF8.GetString(meomoryStream.ToArray()).ToString().ToObject<RecCnt>();
|
|
|
+ RecCnt recCnt = Encoding.UTF8.GetString(meomoryStream.ToArray()).ToString().ToObject<RecCnt>();
|
|
|
|
|
|
- string name = stringSuffix.MidStrEx(blobItem.Name, "/", ".");
|
|
|
- days.Add(name, recCnt);
|
|
|
+ string name = stringSuffix.MidStrEx(blobItem.Name, "/", ".");
|
|
|
+ days.Add(name, recCnt);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|