update

TEAMModelOS.SDK/Models/Service/BI/BILogAnalyseService.cs

@@ -171,25 +171,25 @@ namespace TEAMModelOS.SDK.Models.Service.BI
                     saveCnts.minCnts = minCnts;
 
                     recCnts.Add(saveCnts);
-                    ////保存存至Blob文件
-                    //var url = await _azureStorage.GetBlobContainerClient("0-public").UploadFileByContainer(saveCnts.ToJsonString(), $"visitCnt/{cDay}", $"{cHour}.json");
+                    //保存存至Blob文件
+                    var url = await _azureStorage.GetBlobContainerClient("0-public").UploadFileByContainer(saveCnts.ToJsonString(), $"visitCnt/{cDay}", $"{cHour}.json");
 
-                    //urls.Add(url);
+                    urls.Add(url);
                 }
 
-                //var azureClient = _azureStorage.GetBlobContainerClient("0-public");//获取容器连接地址
-                //int expireTime = int.Parse(DateTimeOffset.UtcNow.AddDays(-180).ToString("yyyyMMdd"));
-                //await foreach (var blobItem in azureClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, prefix: "visitCnt"))
-                //{
-                //    string[] sub_name = blobItem.Name.Split('/');
-                //    if (sub_name.Length > 2)
-                //    {
-                //        if (int.Parse(sub_name[1]) <= expireTime)
-                //        {
-                //            await azureClient.GetBlobBaseClient(blobItem.Name).DeleteIfExistsAsync();
-                //        }
-                //    }
-                //}
+                var azureClient = _azureStorage.GetBlobContainerClient("0-public");//获取容器连接地址
+                int expireTime = int.Parse(DateTimeOffset.UtcNow.AddDays(-180).ToString("yyyyMMdd"));
+                await foreach (var blobItem in azureClient.GetBlobsAsync(BlobTraits.None, BlobStates.None, prefix: "visitCnt"))
+                {
+                    string[] sub_name = blobItem.Name.Split('/');
+                    if (sub_name.Length > 2)
+                    {
+                        if (int.Parse(sub_name[1]) <= expireTime)
+                        {
+                            await azureClient.GetBlobBaseClient(blobItem.Name).DeleteIfExistsAsync();
+                        }
+                    }
+                }
 
             } catch (Exception ex) { }