diff --git a/config.yaml b/config.yaml index b5a93a7e..61f9ff25 100644 --- a/config.yaml +++ b/config.yaml @@ -50,3 +50,7 @@ resource: welcome-new: type: emotion path: 58e4150be2bba8f7b71974b10391f9e9 + # 水群排行榜词云,只能是图片,末尾的`\%s`也是必须的 + wordcloud: + type: image + path: D:\Share\wordcloud\%s diff --git a/tasks/watergroup/month.go b/tasks/watergroup/month.go index aad80892..1a40cf5d 100644 --- a/tasks/watergroup/month.go +++ b/tasks/watergroup/month.go @@ -2,6 +2,7 @@ package watergroup import ( "fmt" + "go-wechat/config" "go-wechat/service" "go-wechat/utils" "log" @@ -21,11 +22,17 @@ func Month() { for _, group := range groups { // 消息统计 dealMonth(group.Wxid) + + res, ok := config.Conf.Resource["wordcloud"] + if !ok { + continue + } + // 获取上个月月份 yd := time.Now().Local().AddDate(0, 0, -1).Format("200601") // 发送词云 fileName := fmt.Sprintf("%s_%s.png", yd, group.Wxid) - utils.SendImage(group.Wxid, "D:\\Share\\wordcloud\\"+fileName, 0) + utils.SendImage(group.Wxid, fmt.Sprintf(res.Path, fileName), 0) } } diff --git a/tasks/watergroup/week.go b/tasks/watergroup/week.go index 7db3f54d..084310dd 100644 --- a/tasks/watergroup/week.go +++ b/tasks/watergroup/week.go @@ -2,6 +2,7 @@ package watergroup import ( "fmt" + "go-wechat/config" "go-wechat/service" "go-wechat/utils" "log" @@ -21,11 +22,17 @@ func Week() { for _, group := range groups { // 消息统计 dealWeek(group.Wxid) + + res, ok := config.Conf.Resource["wordcloud"] + if !ok { + continue + } + // 获取上周周数 year, weekNo := time.Now().Local().AddDate(0, 0, -1).ISOWeek() // 发送词云 fileName := fmt.Sprintf("%d%d_%s.png", year, weekNo, group.Wxid) - utils.SendImage(group.Wxid, "D:\\Share\\wordcloud\\"+fileName, 0) + utils.SendImage(group.Wxid, fmt.Sprintf(res.Path, fileName), 0) } } diff --git a/tasks/watergroup/yesterday.go b/tasks/watergroup/yesterday.go index 42612374..5a3f0d84 100644 --- a/tasks/watergroup/yesterday.go +++ b/tasks/watergroup/yesterday.go @@ -2,6 +2,7 @@ package watergroup import ( "fmt" + "go-wechat/config" "go-wechat/service" "go-wechat/utils" "log" @@ -23,11 +24,17 @@ func Yesterday() { for _, group := range groups { // 消息统计 dealYesterday(group.Wxid) + + res, ok := config.Conf.Resource["wordcloud"] + if !ok { + continue + } + // 获取昨日日期 yd := time.Now().Local().AddDate(0, 0, -1).Format("20060102") // 发送词云 fileName := fmt.Sprintf("%s_%s.png", yd, group.Wxid) - utils.SendImage(group.Wxid, "D:\\Share\\wordcloud\\"+fileName, 0) + utils.SendImage(group.Wxid, fmt.Sprintf(res.Path, fileName), 0) } }