loser/JM-WechatMini
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: loser:0d688ccae5375475e06aba208f778e71d52972c4
Branches Tags
loser:main
loser:master
..
compare: loser:8aa2b355d981535327cfe02ce0c21baabbcb189f
Branches Tags
loser:master
loser:main

2 Commits
0d688ccae5 ... 8aa2b355d9

Author SHA1 Message Date
Echo
8aa2b355d9 🎨 新增手动触发接口 2024-04-02 15:09:31 +08:00
Echo
4bb385b766 🎨 修改定时任务错误逻辑 2024-04-02 15:02:46 +08:00
3 changed files with 6 additions and 7 deletions
Show Stats Expand all files Collapse all files

3
initialize/router.go
View File

@ -55,8 +55,7 @@ func Routers() *gin.Engine {
r.OkWithData(len(jobs), c) r.OkWithData(len(jobs), c)
}) })
PublicGroup.GET("/task/send", func(c *gin.Context) { PublicGroup.GET("/task/send", func(c *gin.Context) {
tag, _ := task.WxTask.FindJobsByTag("sendMsg") task.SendMsg2User()
r.OkWithData(tag[0].NextRun(), c)
}) })
} }

4
task/user.go
View File

@ -27,7 +27,7 @@ func CheckUserSurgeryDate() {
func SendMsg2User() { func SendMsg2User() {
go func() { go func() {
global.GVA_LOG.Info("执行发送消息定时任务") global.GVA_LOG.Info("创建发送消息定时任务")
var ut []common.UserTodo var ut []common.UserTodo
err := global.GVA_DB.Model(&common.UserTodo{}).Find(&ut).Error err := global.GVA_DB.Model(&common.UserTodo{}).Find(&ut).Error
if err != nil { if err != nil {
@ -47,7 +47,7 @@ func SendMsg2User() {
} }
// 根据用户手术信息 发送提醒消息 // 根据用户手术信息 发送提醒消息
if todo.RemindPeriod == 0 && todo.IsFinish == 0 { if todo.RemindPeriod == user.IsSurgery && todo.IsFinish == 0 {
// 根据年月日时发送消息 // 根据年月日时发送消息
job, err := WxTask.Every(1).Day().At(todo.RemindTime).LimitRunsTo(1).Do(MiniappSendMsg, strconv.Itoa(int(user.ID)), strconv.Itoa(int(todo.ID))) job, err := WxTask.Every(1).Day().At(todo.RemindTime).LimitRunsTo(1).Do(MiniappSendMsg, strconv.Itoa(int(user.ID)), strconv.Itoa(int(todo.ID)))
//job, err := WxTask.Cron("0 30 23 30 3 2024").Do(MiniappSendMsg, strconv.Itoa(int(user.ID)), strconv.Itoa(int(todo.ID))) //job, err := WxTask.Cron("0 30 23 30 3 2024").Do(MiniappSendMsg, strconv.Itoa(int(user.ID)), strconv.Itoa(int(todo.ID)))

6
task/wxMsg.go
View File

@ -1,7 +1,6 @@
package task package task
import ( import (
"fmt"
"github.com/medivhzhan/weapp/v3" "github.com/medivhzhan/weapp/v3"
msg "github.com/medivhzhan/weapp/v3/subscribemessage" msg "github.com/medivhzhan/weapp/v3/subscribemessage"
"go.uber.org/zap" "go.uber.org/zap"
@ -67,6 +66,7 @@ func MiniappSendMsg(userId string, utId string) {
err = global.GVA_DB.Model(&common.UserTodo{}).Where("id = ?", utId).First(&ut).Error err = global.GVA_DB.Model(&common.UserTodo{}).Where("id = ?", utId).First(&ut).Error
if err != nil { if err != nil {
global.GVA_LOG.Error("定时任务获取用户Todo列表失败：", zap.Error(err)) global.GVA_LOG.Error("定时任务获取用户Todo列表失败：", zap.Error(err))
return
} }
var msgDatas []msg.SendRequest var msgDatas []msg.SendRequest
@ -111,7 +111,7 @@ func MiniappSendMsg(userId string, utId string) {
err = send.GetResponseError() err = send.GetResponseError()
if err != nil { if err != nil {
fmt.Printf("微信返回错误: %#v", err) global.GVA_LOG.Error("发送失败: %#v", zap.Any("返回结果: %#v", send))
return return
} }
global.GVA_LOG.Info("发送成功: %#v", zap.Any("返回结果: %#v", send)) global.GVA_LOG.Info("发送成功: %#v", zap.Any("返回结果: %#v", send))
@ -125,7 +125,7 @@ func MiniappSendMsg(userId string, utId string) {
err = send.GetResponseError() err = send.GetResponseError()
if err != nil { if err != nil {
fmt.Printf("微信返回错误: %#v", err) global.GVA_LOG.Error("发送失败: %#v", zap.Any("返回结果: %#v", send))
return return
} }
global.GVA_LOG.Info("发送成功: %#v", zap.Any("返回结果: %#v", send)) global.GVA_LOG.Info("发送成功: %#v", zap.Any("返回结果: %#v", send))