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

“测试优化

Browse Source
This commit is contained in:
Rosy-zhudan
2019-08-30 14:09:50 +08:00
parent 8ec7239b1d
commit de91ac4a20
1 changed files with 29 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
business/jxstore/cms/sku.go
View File

@@ -1062,15 +1062,15 @@ func SortCategorySku(ctx *jxcontext.Context, catID int, skuIDList []int) (err er
} }
} }
dao.Begin(db) // dao.Begin(db)
defer func() { // defer func() {
if r := recover(); r != nil || err != nil { // if r := recover(); r != nil || err != nil {
dao.Rollback(db) // dao.Rollback(db)
if r != nil { // if r != nil {
panic(r) // panic(r)
} // }
} // }
}() // }()
nameIDList := []int{} nameIDList := []int{}
for _, value := range skuList { for _, value := range skuList {
seq := skuIDMap[value.ID] 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) _, 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)
// }
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
switch step {
case 0:
skuIDs, err2 := dao.GetSkuIDByNames(db, nameIDList) skuIDs, err2 := dao.GetSkuIDByNames(db, nameIDList)
if err = err2; err == nil && len(skuIDs) > 0 { if err = err2; err == nil && len(skuIDs) > 0 {
_, err = SetStoreSkuSyncStatus2(db, nil, partner.GetSingleStoreVendorIDs(), skuIDs, model.SyncFlagModifiedMask) _, err = SetStoreSkuSyncStatus2(db, nil, partner.GetSingleStoreVendorIDs(), skuIDs, model.SyncFlagModifiedMask)
} }
if err == nil {
dao.Commit(db)
} else {
dao.Rollback(db)
} }
return result, err
}
taskSeq := tasksch.NewSeqTask("SortCategorySku", ctx, taskSeqFunc, 1)
taskSeq.Run()
} }
return err return err