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

审核时删除重复的待审核信息

Browse Source
This commit is contained in:
苏尹岚
2020-08-31 15:22:08 +08:00
parent c30d1ab17a
commit 94342d6dcd
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jxstore/cms/store_sku.go
View File

@@ -4721,7 +4721,7 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
}
return storeSkuAudits2, "", err
}
// deletedDuplicateWaitAuditData(ctx, db)
deletedDuplicateWaitAuditData(ctx, db)
task := tasksch.NewParallelTask("StoreSkuPriceAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeAudit := batchItemList[0].(*model.StoreSkuAudit)
@@ -4802,7 +4802,7 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
return nil, hint, err
}
func DeletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
func deletedDuplicateWaitAuditData(ctx *jxcontext.Context, db *dao.DaoDB) {
var (
duplicateDatas []*model.StoreSkuAudit
duplicateStore = make(map[int][]*model.StoreSkuAudit)

2
business/jxstore/tempop/tempop.go
View File

@@ -1583,7 +1583,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// fmt.Println("addList2", addList)
// fmt.Println("updateList2", utils.Format4Output(updateList, false))
// fmt.Println("deleteList2", deleteList)
cms.DeletedDuplicateWaitAuditData(ctx, dao.GetDB())
// cms.DeletedDuplicateWaitAuditData(ctx, dao.GetDB())
return err
}