Commit 54f0b3e6 authored by 李世星's avatar 李世星

Merge branch 'lisx' into 'developer'

fix(修改模板): 202301301651

See merge request !17
parents 74c231d5 09f7c237
Pipeline #16081 passed with stage
in 0 seconds
......@@ -73,9 +73,9 @@ func CreateDingMessage(messageType string, msg interface{}, mobiles []string) DD
func pluginNotice(msg interface{}) string {
mateData := msg.(*entity.Matedata)
templateBuff := bytes.NewBuffer([]byte{})
templateBuff.WriteString(fmt.Sprintf("# 服务通知 \r\n > (节点):%s", mateData.SourceAgent))
templateBuff.WriteString(fmt.Sprintf("# 服务通知 \r\n > 【节点】:%s", mateData.SourceAgent))
for key, value := range mateData.Data {
templateBuff.WriteString(fmt.Sprintf(" \r\n > (%s):%s", key, value))
templateBuff.WriteString(fmt.Sprintf(" \r\n > 【%s】:%s", key, value))
}
templateBuff.WriteString(fmt.Sprintf(" \r\n ###### %s", time.Now().Format("2006/01/02 15:04:05")))
......
......@@ -121,6 +121,7 @@ func ReadingMessage(ctx context.Context, c *Customer) {
}
matedata, err = c.Format(string(reader.Config().Topic), string(m.Value))
matedata.SourceAgent = "默认节点"
for _, header := range m.Headers {
if header.Key == "source_agent" {
matedata.SourceAgent = string(header.Value)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment