消息通知

service/task/sync_data.go

@@ -1085,6 +1085,18 @@ func (s *SyncData) TaskMsgSendRetainedDataUpdate(ctx context.Context, completesI
 				sendPersonData.MsgType = "markdown"
 				sendPersonData.Markdown.Content = personMsg
 				s.SendMsgData(url, sendPersonData)
+				if mpsPerson[pName].Custodians != "" {
+					if _, ok := mpsPerson[mpsPerson[pName].Custodians]; ok {
+						custodiansMsg := fmt.Sprintf("<font color=\"warning\">%s的任务</font>", pName)
+						custodiansMsg += "\n"
+						custodiansMsg += personMsg
+						var custodiansData SendMsg
+						custodiansData.MsgType = "markdown"
+						custodiansData.Markdown.Content = custodiansMsg
+						urlCustodians := mpsPerson[mpsPerson[pName].Custodians].Url
+						s.SendMsgData(urlCustodians, custodiansData)
+					}
+				}
 			}
 		}
 	} else {
@@ -1103,7 +1115,9 @@ func (s *SyncData) TaskMsgSendRetainedDataUpdate(ctx context.Context, completesI
 		}
 		for pName, pMsg := range sendMsg {
 			if hour >= mpsPerson[pName].StartTime {
-				personMsg := pMsg
+				var personMsg = "# 付费播报 "
+				personMsg += fmt.Sprintf("<font color=\"warning\">%s</font>", time.Now().Format("2006-01-02 15:04:05"))
+				personMsg = pMsg
 				if _, ok := errSendMsg[pName]; ok {
 					personMsg += fmt.Sprintf("<font color=\"warning\">%s</font>", errSendMsg[pName])
 				}
@@ -1112,6 +1126,16 @@ func (s *SyncData) TaskMsgSendRetainedDataUpdate(ctx context.Context, completesI
 				sendPersonData.MsgType = "markdown"
 				sendPersonData.Markdown.Content = personMsg
 				s.SendMsgData(url, sendPersonData)
+				if mpsPerson[pName].Custodians != "" {
+					custodiansMsg := fmt.Sprintf("<font color=\"warning\">%s的任务</font>", pName)
+					custodiansMsg += "\n"
+					custodiansMsg += personMsg
+					var custodiansData SendMsg
+					custodiansData.MsgType = "markdown"
+					custodiansData.Markdown.Content = custodiansMsg
+					urlCustodians := mpsPerson[mpsPerson[pName].Custodians].Url
+					s.SendMsgData(urlCustodians, custodiansData)
+				}
 			}
 		}
 	}
@@ -1178,7 +1202,7 @@ func (s *SyncData) TaskMsgSendFreeDataUpdate(ctx context.Context, completesInfo
 		return
 	}
 	var taskStatistics = "%s:taskStatistics"
-	var retained = "付费播报 "
+	var retained = "# 付费播报 "
 	retained += fmt.Sprintf("<font color=\"warning\">%s</font>", time.Now().Format("2006-01-02 15:04:05"))
 	var errMsg = "**以下游戏付费效率为零:**"
 	var errMsgZ = ""
@@ -1264,12 +1288,26 @@ func (s *SyncData) TaskMsgSendFreeDataUpdate(ctx context.Context, completesInfo
 		retained += name
 		retained += msg
 		if hour >= mpsPerson[name].StartTime {
-			personMsg := msg
+			var personMsg = "# 付费播报 "
+			personMsg += fmt.Sprintf("<font color=\"warning\">%s</font>", time.Now().Format("2006-01-02 15:04:05"))
+			personMsg = msg
 			url := mpsPerson[name].Url
 			var sendPersonData SendMsg
 			sendPersonData.MsgType = "markdown"
 			sendPersonData.Markdown.Content = personMsg
 			s.SendMsgData(url, sendPersonData)
+			if mpsPerson[name].Custodians != "" {
+				if _, ok := mpsPerson[mpsPerson[name].Custodians]; ok {
+					custodiansMsg := fmt.Sprintf("<font color=\"warning\">%s的任务</font>", name)
+					custodiansMsg += "\n"
+					custodiansMsg += personMsg
+					var custodiansData SendMsg
+					custodiansData.MsgType = "markdown"
+					custodiansData.Markdown.Content = custodiansMsg
+					urlCustodians := mpsPerson[mpsPerson[name].Custodians].Url
+					s.SendMsgData(urlCustodians, custodiansData)
+				}
+			}
 		}
 	}
 	msg := retained