SendStoreMessage数量少时任务不管理

2020-02-07 20:15:19 +08:00
parent 464399e145
commit c42bb64998
1 changed files with 1 additions and 1 deletions
--- 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)