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

Accept Merge Request #2: (don -> mark)

Browse Source 
Merge Request: 优化重排序商品
Created By: @zhudan
Accepted By: @zhudan
URL: https://rosydev.coding.net/p/jx-callback/git/merge/2
This commit is contained in:
zhudan
2019-09-02 11:21:01 +08:00
parent a32c805785 b12d7dad77
commit 6c8ab5cc6c
1 changed files with 8 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1075,33 +1075,23 @@ func SortCategorySkus(ctx *jxcontext.Context, catID int, skuIDList []int) (err e
nameIDList := []int{} nameIDList := []int{}
for _, value := range skuList { for _, value := range skuList {
seq := skuIDMap[value.ID] seq := skuIDMap[value.ID]
kvs := map[string]interface{}{ if value.Seq != seq {
model.FieldSkuSeq: seq, kvs := map[string]interface{}{
//model.FieldJdSyncStatus: (value.JdSyncStatus | model.SyncFlagModifiedMask), 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) //_, err = CurVendorSync.SyncSkus(ctx, db, nameIDList, []int{}, false, false, userName)
if err == nil { if err == nil && len(nameIDList) > 0 {
dao.Commit(db) dao.Commit(db)
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)
} }
// 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 { } else {
dao.Rollback(db) dao.Rollback(db)
} }