From b12d7dad77e05e18803fc0fa225edd24ad4d03e4 Mon Sep 17 00:00:00 2001 From: Rosy-zhudan Date: Mon, 2 Sep 2019 11:13:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E9=87=8D=E6=8E=92=E5=BA=8F?= =?UTF-8?q?=E5=95=86=E5=93=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sku.go | 26 ++++++++------------------ 1 file changed, 8 insertions(+), 18 deletions(-) diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 08aa5b8c9..acc3403e9 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -1075,33 +1075,23 @@ func SortCategorySkus(ctx *jxcontext.Context, catID int, skuIDList []int) (err e nameIDList := []int{} for _, value := range skuList { seq := skuIDMap[value.ID] - kvs := map[string]interface{}{ - model.FieldSkuSeq: seq, - //model.FieldJdSyncStatus: (value.JdSyncStatus | model.SyncFlagModifiedMask), + if value.Seq != seq { + kvs := map[string]interface{}{ + model.FieldSkuSeq: seq, + //model.FieldJdSyncStatus: (value.JdSyncStatus | model.SyncFlagModifiedMask), + } + dao.UpdateEntityLogically(db, value, kvs, userName, nil) + nameIDList = append(nameIDList, value.NameID) } - dao.UpdateEntityLogically(db, value, kvs, userName, nil) - nameIDList = append(nameIDList, value.NameID) } //_, err = CurVendorSync.SyncSkus(ctx, db, nameIDList, []int{}, false, false, userName) - if err == nil { + if err == nil && len(nameIDList) > 0 { dao.Commit(db) skuIDs, err2 := dao.GetSkuIDByNames(db, nameIDList) if err = err2; err == nil && len(skuIDs) > 0 { _, err = SetStoreSkuSyncStatus2(db, nil, partner.GetSingleStoreVendorIDs(), skuIDs, model.SyncFlagModifiedMask) } - // taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { - // switch step { - // case 0: - // skuIDs, err2 := dao.GetSkuIDByNames(db, nameIDList) - // if err = err2; err == nil && len(skuIDs) > 0 { - // _, err = SetStoreSkuSyncStatus2(db, nil, partner.GetSingleStoreVendorIDs(), skuIDs, model.SyncFlagModifiedMask) - // } - // } - // return result, err - // } - // taskSeq := tasksch.NewSeqTask("SortCategorySku", ctx, taskSeqFunc, 1) - // taskSeq.Run() } else { dao.Rollback(db) }