liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

返回hint

Browse Source
This commit is contained in:
苏尹岚
2020-09-27 18:21:42 +08:00
parent a0f72978d9
commit 2df553eb8b
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
business/jxstore/cms/store.go
View File

@@ -3612,10 +3612,10 @@ func GetStoreAudit(ctx *jxcontext.Context, statuss []int, keyword, applyTimeStar
return pagedInfo, err return pagedInfo, err
} }
func StoreAudit(ctx *jxcontext.Context, storeAudits []*model.StoreAudit, status int) (err error) { func StoreAudit(ctx *jxcontext.Context, storeAudits []*model.StoreAudit, status int) (hint string, err error) {
db := dao.GetDB() db := dao.GetDB()
if status != model.StoreAuditStatusCreated && status != model.StoreAuditStatusRejected { if status != model.StoreAuditStatusCreated && status != model.StoreAuditStatusRejected {
return fmt.Errorf("审核标志不正确！") return "", fmt.Errorf("审核标志不正确！")
} }
task := tasksch.NewParallelTask("StoreAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("StoreAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
@@ -3662,6 +3662,6 @@ func StoreAudit(ctx *jxcontext.Context, storeAudits []*model.StoreAudit, status
return retVal, err return retVal, err
}, storeAudits) }, storeAudits)
tasksch.HandleTask(task, nil, true).Run() tasksch.HandleTask(task, nil, true).Run()
task.GetID() hint = task.GetID()
return err return err
} }

2
controllers/cms_store.go
View File

@@ -898,7 +898,7 @@ func (c *StoreController) StoreAudit() {
c.callStoreAudit(func(params *tStoreStoreAuditParams) (retVal interface{}, errCode string, err error) { c.callStoreAudit(func(params *tStoreStoreAuditParams) (retVal interface{}, errCode string, err error) {
var stores []*model.StoreAudit var stores []*model.StoreAudit
if err = utils.UnmarshalUseNumber([]byte(params.Payload), &stores); err == nil { if err = utils.UnmarshalUseNumber([]byte(params.Payload), &stores); err == nil {
err = cms.StoreAudit(params.Ctx, stores, params.Status) retVal, err = cms.StoreAudit(params.Ctx, stores, params.Status)
} }
return retVal, "", err return retVal, "", err
}) })