From 94342d6dcd5225a5a1e0f4dc14b159accd4fd2cf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Mon, 31 Aug 2020 15:22:08 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=A1=E6=A0=B8=E6=97=B6=E5=88=A0=E9=99=A4?= =?UTF-8?q?=E9=87=8D=E5=A4=8D=E7=9A=84=E5=BE=85=E5=AE=A1=E6=A0=B8=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/store_sku.go | 4 ++-- business/jxstore/tempop/tempop.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go index f39b6511a..7ba20c673 100644 --- a/business/jxstore/cms/store_sku.go +++ b/business/jxstore/cms/store_sku.go @@ -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) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 9c1b56a0c..5528803ea 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -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 }