diff --git a/business/jxstore/cms/sku.go b/business/jxstore/cms/sku.go index 4540ef494..8171cfe08 100644 --- a/business/jxstore/cms/sku.go +++ b/business/jxstore/cms/sku.go @@ -1062,15 +1062,15 @@ func SortCategorySku(ctx *jxcontext.Context, catID int, skuIDList []int) (err er } } - dao.Begin(db) - defer func() { - if r := recover(); r != nil || err != nil { - dao.Rollback(db) - if r != nil { - panic(r) - } - } - }() + // dao.Begin(db) + // defer func() { + // if r := recover(); r != nil || err != nil { + // dao.Rollback(db) + // if r != nil { + // panic(r) + // } + // } + // }() nameIDList := []int{} for _, value := range skuList { seq := skuIDMap[value.ID] @@ -1088,15 +1088,27 @@ func SortCategorySku(ctx *jxcontext.Context, catID int, skuIDList []int) (err er _, err = CurVendorSync.SyncSku(ctx, db, nameID, -1, false, false, userName) } - skuIDs, err2 := dao.GetSkuIDByNames(db, nameIDList) - if err = err2; err == nil && len(skuIDs) > 0 { - _, err = SetStoreSkuSyncStatus2(db, nil, partner.GetSingleStoreVendorIDs(), skuIDs, model.SyncFlagModifiedMask) - } - if err == nil { - dao.Commit(db) - } else { - dao.Rollback(db) + // skuIDs, err2 := dao.GetSkuIDByNames(db, nameIDList) + // if err = err2; err == nil && len(skuIDs) > 0 { + // _, err = SetStoreSkuSyncStatus2(db, nil, partner.GetSingleStoreVendorIDs(), skuIDs, model.SyncFlagModifiedMask) + // } + // if err == nil { + // dao.Commit(db) + // } else { + // dao.Rollback(db) + // } + 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() } return err