zhouj1203@hotmail.com 1 年之前
父節點
當前提交
0b4ddcb40a

+ 4 - 4
TEAMModelOS.FunctionV4/CosmosDB/TriggerArt.cs

@@ -251,10 +251,10 @@ namespace TEAMModelOS.FunctionV4.CosmosDB
                             {
                             {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-艺术评测going{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-艺术评测going{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                             }
                             }
-                            finally {
+                           /* finally {
                                 string pkey = string.Format("{0}{1}{2}", art.code, "-", "pending");
                                 string pkey = string.Format("{0}{1}{2}", art.code, "-", "pending");
                                 await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
                                 await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
-                            }
+                            }*/
                             
                             
 
 
                             break;
                             break;
@@ -797,11 +797,11 @@ namespace TEAMModelOS.FunctionV4.CosmosDB
                             } catch (Exception e) {
                             } catch (Exception e) {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-艺术评测finish{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-艺术评测finish{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                             }
                             }
-                            finally
+                           /* finally
                             {
                             {
                                 string pk = string.Format("{0}{1}{2}", art.code, "-", "going");
                                 string pk = string.Format("{0}{1}{2}", art.code, "-", "going");
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
-                            }
+                            }*/
                             
                             
 
 
                             break;
                             break;

+ 4 - 4
TEAMModelOS.FunctionV4/CosmosDB/TriggerExam.cs

@@ -393,9 +393,9 @@ namespace TEAMModelOS.FunctionV4
                             finally
                             finally
                             {
                             {
                                 try {
                                 try {
-                                    //新增serviceBus 消息释放后处理table
+                                    /*//新增serviceBus 消息释放后处理table
                                     string pkey = string.Format("{0}{1}{2}", info.code, "-", "pending");
                                     string pkey = string.Format("{0}{1}{2}", info.code, "-", "pending");
-                                    await table.DeleteSingle<ChangeRecord>(pkey, data.id);
+                                    await table.DeleteSingle<ChangeRecord>(pkey, data.id);*/
                                     // 发送信息通知
                                     // 发送信息通知
                                     var messageEnd = new ServiceBusMessage(new { id = data.id, progress = "finish", code = data.code }.ToJsonString());
                                     var messageEnd = new ServiceBusMessage(new { id = data.id, progress = "finish", code = data.code }.ToJsonString());
                                     messageEnd.ApplicationProperties.Add("name", "Exam");
                                     messageEnd.ApplicationProperties.Add("name", "Exam");
@@ -551,11 +551,11 @@ namespace TEAMModelOS.FunctionV4
                             {
                             {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-{info.id}-评测finish状态异常{e.Message}\n{e.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}-{info.id}-评测finish状态异常{e.Message}\n{e.StackTrace}\n", GroupNames.醍摩豆服務運維群組);
                             }
                             }
-                            finally {
+                           /* finally {
                                 //新增serviceBus 消息释放后处理table
                                 //新增serviceBus 消息释放后处理table
                                 string pk = string.Format("{0}{1}{2}", info.code, "-", "going");
                                 string pk = string.Format("{0}{1}{2}", info.code, "-", "going");
                                 await table.DeleteSingle<ChangeRecord>(pk, data.id);
                                 await table.DeleteSingle<ChangeRecord>(pk, data.id);
-                            }
+                            }*/
                             break;
                             break;
                     }
                     }
                 }
                 }

+ 4 - 4
TEAMModelOS.FunctionV4/CosmosDB/TriggerHomework.cs

@@ -135,10 +135,10 @@ namespace TEAMModelOS.FunctionV4
                             } catch (Exception e) {
                             } catch (Exception e) {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动going{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动going{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                             }
                             }
-                            finally {
+                            /*finally {
                                 string pkey = string.Format("{0}{1}{2}", work.code, "-", "pending");
                                 string pkey = string.Format("{0}{1}{2}", work.code, "-", "pending");
                                 await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
                                 await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
-                            }
+                            }*/
                             
                             
                             
                             
                             //if (bustasks.IsNotEmpty())
                             //if (bustasks.IsNotEmpty())
@@ -172,10 +172,10 @@ namespace TEAMModelOS.FunctionV4
                             } catch (Exception e) {
                             } catch (Exception e) {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动finish{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修作业活动finish{e.Message}\n{e.StackTrace}", GroupNames.醍摩豆服務運維群組);
 
 
-                            } finally {
+                            } /*finally {
                                 string pk = string.Format("{0}{1}{2}", work.code, "-", "going");
                                 string pk = string.Format("{0}{1}{2}", work.code, "-", "going");
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
-                            }
+                            }*/
                             
                             
                                                 
                                                 
                             break;
                             break;

+ 4 - 4
TEAMModelOS.FunctionV4/CosmosDB/TriggerStudy.cs

@@ -222,10 +222,10 @@ namespace TEAMModelOS.FunctionV4
                             {
                             {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修活动异常-going {ex.Message}\n{ex.StackTrace}{tdata.ToJsonString()}{input}", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修活动异常-going {ex.Message}\n{ex.StackTrace}{tdata.ToJsonString()}{input}", GroupNames.醍摩豆服務運維群組);
                             }
                             }
-                            finally {
+                            /*finally {
                                 string pk = string.Format("{0}{1}{2}", study.code, "-", "pending");
                                 string pk = string.Format("{0}{1}{2}", study.code, "-", "pending");
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
-                            }
+                            }*/
                            
                            
                             break;
                             break;
                         case "finish":
                         case "finish":
@@ -257,10 +257,10 @@ namespace TEAMModelOS.FunctionV4
                             {
                             {
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修活动异常-finish {e.Message}\n{e.StackTrace}{tdata.ToJsonString()}{input}", GroupNames.醍摩豆服務運維群組);
                                 await _dingDing.SendBotMsg($"{Environment.GetEnvironmentVariable("Option:Location")}研修活动异常-finish {e.Message}\n{e.StackTrace}{tdata.ToJsonString()}{input}", GroupNames.醍摩豆服務運維群組);
                             }
                             }
-                            finally {
+                           /* finally {
                                 string pk = string.Format("{0}{1}{2}", study.code, "-", "going");
                                 string pk = string.Format("{0}{1}{2}", study.code, "-", "going");
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
                                 await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
-                            }
+                            }*/
                             break;
                             break;
                     }
                     }
                 }
                 }

+ 4 - 4
TEAMModelOS.FunctionV4/CosmosDB/TriggerSurvey.cs

@@ -300,8 +300,8 @@ namespace TEAMModelOS.FunctionV4
 #endif                           
 #endif                           
                             var messageSurveyEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
                             var messageSurveyEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
                             messageSurveyEnd.ApplicationProperties.Add("name", "Survey");
                             messageSurveyEnd.ApplicationProperties.Add("name", "Survey");
-                            string pkey = string.Format("{0}{1}{2}", survey.code, "-", "pending");
-                            await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
+                           /* string pkey = string.Format("{0}{1}{2}", survey.code, "-", "pending");
+                            await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);*/
                             if (changeRecords.Count > 0)
                             if (changeRecords.Count > 0)
                             {
                             {
                                 long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
                                 long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
@@ -475,8 +475,8 @@ namespace TEAMModelOS.FunctionV4
                                 _azureRedis.GetRedisClient(8).KeyDelete($"Survey:Submit:{survey.id}");
                                 _azureRedis.GetRedisClient(8).KeyDelete($"Survey:Submit:{survey.id}");
                                 break;
                                 break;
                             }
                             }
-                            string pk = string.Format("{0}{1}{2}", survey.code, "-", "going");
-                            await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
+                            /*string pk = string.Format("{0}{1}{2}", survey.code, "-", "going");
+                            await table.DeleteSingle<ChangeRecord>(pk, tdata.id);*/
                             //更新结束状态
                             //更新结束状态
                             //data.progress = "finish";
                             //data.progress = "finish";
                             //if (survey.scope .Equals("school"))
                             //if (survey.scope .Equals("school"))

+ 4 - 4
TEAMModelOS.FunctionV4/CosmosDB/TriggerVote.cs

@@ -304,8 +304,8 @@ namespace TEAMModelOS.FunctionV4
                             #endregion
                             #endregion
                             var messageVoteEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
                             var messageVoteEnd = new ServiceBusMessage(new { id = tdata.id, progress = "finish", code = tdata.code }.ToJsonString());
                             messageVoteEnd.ApplicationProperties.Add("name", "Vote");
                             messageVoteEnd.ApplicationProperties.Add("name", "Vote");
-                            string pk = string.Format("{0}{1}{2}", vote.code, "-", "pending");
-                            await table.DeleteSingle<ChangeRecord>(pk, tdata.id);
+                           /* string pk = string.Format("{0}{1}{2}", vote.code, "-", "pending");
+                            await table.DeleteSingle<ChangeRecord>(pk, tdata.id);*/
                             if (voteRecords.Count > 0)
                             if (voteRecords.Count > 0)
                             {
                             {
                                 long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
                                 long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync(Environment.GetEnvironmentVariable("Azure:ServiceBus:ActiveTask"), messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(tdata.endTime));
@@ -398,8 +398,8 @@ namespace TEAMModelOS.FunctionV4
                                 break;
                                 break;
                             }
                             }
                             await Task.WhenAll(tasks);
                             await Task.WhenAll(tasks);
-                            string pkey = string.Format("{0}{1}{2}", vote.code, "-", "going");
-                            await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);
+                          /*  string pkey = string.Format("{0}{1}{2}", vote.code, "-", "going");
+                            await table.DeleteSingle<ChangeRecord>(pkey, tdata.id);*/
                             break;
                             break;
                     }
                     }
                 }
                 }