屏蔽通知模块

TEAMModelFunction/NoticeServiceBus.cs

@@ -26,108 +26,108 @@ namespace TEAMModelFunction
             _dingDing = dingDing;
             _serviceBus = serviceBus;
         }
-        [FunctionName("Notice")]
-        public async  Task Notice([ServiceBusTrigger("active-task", "notice", Connection = "Azure:ServiceBus:ConnectionString")] string msg) {
-            var client = _azureCosmos.GetCosmosClient();
-            try {
-                await _dingDing.SendBotMsg($"NoticeServiceBus-Notice：\n发起通知{msg}", GroupNames.成都开发測試群組);
-                List<Task<string>> tasks = new List<Task<string>>();
-                List<Task> sessionTasks = new List<Task>();
-                var jsonMsg = JsonDocument.Parse(msg);
-                Notice notice = msg.ToObject<Notice>();
-                var blobcntr = "";
-                if (notice.scope.Equals("school"))
-                {
-                    blobcntr = notice.school;
-                }
-                else {
-                    blobcntr = notice.creatorId;
-                }
-                var urlNotice = $"{notice.sid}.json";
-                var blobNotice = new { 
-                    notice.sid, 
-                    notice.scode,
-                    notice.spk,
-                    notice.scope,
-                    notice.school,
-                    notice.type,
-                    notice.level,
-                    notice.data,
-                    notice.stime,
-                    notice.etime,
-                    notice.creatorId
-                };
-                tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, blobNotice.ToJsonString(), "notice", urlNotice));
-                var urlReceiver = $"{notice.sid}_receiver.json";
-                var blobReceiver = new
-                {
-                    notice.stuids,
-                    notice.tmdids
-                };
-                tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, blobReceiver.ToJsonString(), "notice", urlReceiver));
-                long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
-                // "ttl":2592000,不能超过30天（2592000），一天（3600），一周（25200）
-                long ttl = notice.etime - now;
-                long day30 = 2592000L * 1000;
-                if (ttl > day30) {
-                    ttl = day30;
-                }
-                if (notice.stuids.IsNotEmpty()) {
-                    //  List<Receiver> receivers = new List<Receiver>();
-                    foreach (var stu in notice.stuids) {
-                        Receiver receiver = new Receiver
-                        {
-                            id = notice.sid,
-                            pk = "Receiver",
-                            status = 0,
-                            school = stu.schoolId,
-                            scope = "school",
-                            code = $"Receiver-{stu.schoolId}-{stu.id}",
-                            ttl = (int)ttl,
-                            ctime= now,
-                            urlNotice=$"notice/{urlNotice}"
-                        };
-                        await client.GetContainer("TEAMModelOS", "Student").UpsertItemAsync<Receiver>(receiver,new Azure.Cosmos.PartitionKey(receiver.code));
-                        //  /student/{stuid}/receive/{notice.sid}.json
-                        //存放通知到学生容器空间
-                        var url = $"{stu.id}/receive/{notice.sid}.json";
-                        tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, receiver.ToJsonString(), "student", url));
-                        var messageBlob = new ServiceBusMessage(notice.ToJsonString()) { SessionId =$"{stu.schoolId}-{stu.id}"};
-                        messageBlob.ApplicationProperties.Add("name", "Receiver");
-                        sessionTasks.Add(_serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob));
-                    }
-                }
-                if (notice.tmdids.IsNotEmpty())
-                {
-                    foreach (var tmdid in notice.tmdids)
-                    {
-                        Receiver receiver = new Receiver
-                        {
-                            id = notice.sid,
-                            pk = "Receiver",
-                            status = 0,
-                            //school = stu.schoolId,
-                            scope = "school",
-                            code = $"Receiver-{tmdid}",
-                            ttl = (int)ttl,
-                            ctime = now,
-                            urlNotice = $"notice/{urlNotice}"
-                        };
-                        await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync<Receiver>(receiver, new Azure.Cosmos.PartitionKey(receiver.code));
-                        //  /student/{stuid}/receive/{notice.sid}.json
-                        //存放通知到学生容器空间
-                        var url = $"{notice.sid}.json";
-                        tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, receiver.ToJsonString(), "receive", url));
-                        var messageBlob = new ServiceBusMessage(notice.ToJsonString()) { SessionId = $"{tmdid}" };
-                        messageBlob.ApplicationProperties.Add("name", "Receiver");
-                        sessionTasks.Add(_serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob));
-                    }
-                }
-                await Task.WhenAll(sessionTasks);
-                await Task.WhenAll(tasks);
-            } catch (Exception ex) {
-                 await _dingDing.SendBotMsg($"NoticeServiceBus-Notice\n{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
-            }
-        }
+        //[FunctionName("Notice")]
+        //public async  Task Notice([ServiceBusTrigger("active-task", "notice", Connection = "Azure:ServiceBus:ConnectionString")] string msg) {
+        //    var client = _azureCosmos.GetCosmosClient();
+        //    try {
+        //        await _dingDing.SendBotMsg($"NoticeServiceBus-Notice：\n发起通知{msg}", GroupNames.成都开发測試群組);
+        //        List<Task<string>> tasks = new List<Task<string>>();
+        //        List<Task> sessionTasks = new List<Task>();
+        //        var jsonMsg = JsonDocument.Parse(msg);
+        //        Notice notice = msg.ToObject<Notice>();
+        //        var blobcntr = "";
+        //        if (notice.scope.Equals("school"))
+        //        {
+        //            blobcntr = notice.school;
+        //        }
+        //        else {
+        //            blobcntr = notice.creatorId;
+        //        }
+        //        var urlNotice = $"{notice.sid}.json";
+        //        var blobNotice = new { 
+        //            notice.sid, 
+        //            notice.scode,
+        //            notice.spk,
+        //            notice.scope,
+        //            notice.school,
+        //            notice.type,
+        //            notice.level,
+        //            notice.data,
+        //            notice.stime,
+        //            notice.etime,
+        //            notice.creatorId
+        //        };
+        //        tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, blobNotice.ToJsonString(), "notice", urlNotice));
+        //        var urlReceiver = $"{notice.sid}_receiver.json";
+        //        var blobReceiver = new
+        //        {
+        //            notice.stuids,
+        //            notice.tmdids
+        //        };
+        //        tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, blobReceiver.ToJsonString(), "notice", urlReceiver));
+        //        long now = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
+        //        // "ttl":2592000,不能超过30天（2592000），一天（3600），一周（25200）
+        //        long ttl = notice.etime - now;
+        //        long day30 = 2592000L * 1000;
+        //        if (ttl > day30) {
+        //            ttl = day30;
+        //        }
+        //        if (notice.stuids.IsNotEmpty()) {
+        //            //  List<Receiver> receivers = new List<Receiver>();
+        //            foreach (var stu in notice.stuids) {
+        //                Receiver receiver = new Receiver
+        //                {
+        //                    id = notice.sid,
+        //                    pk = "Receiver",
+        //                    status = 0,
+        //                    school = stu.schoolId,
+        //                    scope = "school",
+        //                    code = $"Receiver-{stu.schoolId}-{stu.id}",
+        //                    ttl = (int)ttl,
+        //                    ctime= now,
+        //                    urlNotice=$"notice/{urlNotice}"
+        //                };
+        //                await client.GetContainer("TEAMModelOS", "Student").UpsertItemAsync<Receiver>(receiver,new Azure.Cosmos.PartitionKey(receiver.code));
+        //                //  /student/{stuid}/receive/{notice.sid}.json
+        //                //存放通知到学生容器空间
+        //                var url = $"{stu.id}/receive/{notice.sid}.json";
+        //                tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, receiver.ToJsonString(), "student", url));
+        //                var messageBlob = new ServiceBusMessage(notice.ToJsonString()) { SessionId =$"{stu.schoolId}-{stu.id}"};
+        //                messageBlob.ApplicationProperties.Add("name", "Receiver");
+        //                sessionTasks.Add(_serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob));
+        //            }
+        //        }
+        //        if (notice.tmdids.IsNotEmpty())
+        //        {
+        //            foreach (var tmdid in notice.tmdids)
+        //            {
+        //                Receiver receiver = new Receiver
+        //                {
+        //                    id = notice.sid,
+        //                    pk = "Receiver",
+        //                    status = 0,
+        //                    //school = stu.schoolId,
+        //                    scope = "school",
+        //                    code = $"Receiver-{tmdid}",
+        //                    ttl = (int)ttl,
+        //                    ctime = now,
+        //                    urlNotice = $"notice/{urlNotice}"
+        //                };
+        //                await client.GetContainer("TEAMModelOS", "Teacher").UpsertItemAsync<Receiver>(receiver, new Azure.Cosmos.PartitionKey(receiver.code));
+        //                //  /student/{stuid}/receive/{notice.sid}.json
+        //                //存放通知到学生容器空间
+        //                var url = $"{notice.sid}.json";
+        //                tasks.Add(_azureStorage.UploadFileByContainer(blobcntr, receiver.ToJsonString(), "receive", url));
+        //                var messageBlob = new ServiceBusMessage(notice.ToJsonString()) { SessionId = $"{tmdid}" };
+        //                messageBlob.ApplicationProperties.Add("name", "Receiver");
+        //                sessionTasks.Add(_serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob));
+        //            }
+        //        }
+        //        await Task.WhenAll(sessionTasks);
+        //        await Task.WhenAll(tasks);
+        //    } catch (Exception ex) {
+        //         await _dingDing.SendBotMsg($"NoticeServiceBus-Notice\n{ex.Message}{ex.StackTrace}", GroupNames.成都开发測試群組);
+        //    }
+        //}
     }
 }

TEAMModelFunction/TriggerExam.cs

@@ -197,9 +197,9 @@ namespace TEAMModelFunction
                         data = new { }.ToJsonString()
 
                     };
-                    var messageBlob = new ServiceBusMessage(notice.ToJsonString());
-                    messageBlob.ApplicationProperties.Add("name", "Notice");
-                    await _serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob);
+                    //var messageBlob = new ServiceBusMessage(notice.ToJsonString());
+                    //messageBlob.ApplicationProperties.Add("name", "Notice");
+                    //await _serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob);
                     #endregion
                     if (examClassResults.Count == 0)
                     {

TEAMModelFunction/TriggerSurvey.cs

@@ -147,9 +147,9 @@ namespace TEAMModelFunction
                             data = new { }.ToJsonString()
 
                         };
-                        var messageBlob = new ServiceBusMessage(notice.ToJsonString());
-                        messageBlob.ApplicationProperties.Add("name", "Notice");
-                        await _serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob);
+                        //var messageBlob = new ServiceBusMessage(notice.ToJsonString());
+                        //messageBlob.ApplicationProperties.Add("name", "Notice");
+                        //await _serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob);
                         #endregion
                         await _dingDing.SendBotMsg($"问卷调查{tdata.id}写入完成！", GroupNames.成都开发測試群組);
                         var messageSurveyEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = tdata.code }.ToJsonString());

TEAMModelFunction/TriggerVote.cs

@@ -156,9 +156,9 @@ namespace TEAMModelFunction
                             data=new { }.ToJsonString()
 
                         };
-                        var messageBlob = new ServiceBusMessage(notice.ToJsonString());
-                        messageBlob.ApplicationProperties.Add("name", "Notice");
-                        await _serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob);
+                        //var messageBlob = new ServiceBusMessage(notice.ToJsonString());
+                        //messageBlob.ApplicationProperties.Add("name", "Notice");
+                        //await _serviceBus.GetServiceBusClient().SendMessageAsync("active-task", messageBlob);
                         #endregion
                         var messageVoteEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = tdata.code }.ToJsonString());
                         messageVoteEnd.ApplicationProperties.Add("name", "Vote");