diff --git a/business/jxutils/weixinmsg/weixinmsg.go b/business/jxutils/weixinmsg/weixinmsg.go index 57453a2f8..5123629ac 100644 --- a/business/jxutils/weixinmsg/weixinmsg.go +++ b/business/jxutils/weixinmsg/weixinmsg.go @@ -709,7 +709,7 @@ func SendStoreMessage(ctx *jxcontext.Context, title, content string, storeIDs [] _, err = dao.UpdateEntity(db, msgStatus) return nil, err }, msgStatusList) - tasksch.ManageTask(rootTask).Run() + tasksch.HandleTask(rootTask, nil, len(msgStatusList) > 5).Run() if !isAsync { _, err = rootTask.GetResult(0)