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

1

Browse Source
This commit is contained in:
邹宗楠
2025-01-15 14:23:11 +08:00
parent bbe2a71c03
commit 6009eec666
2 changed files with 59 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
business/jxstore/cms/sync_store_sku.go
View File

@@ -818,6 +818,17 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
_, err = updateStoreSku(dao.GetDB(), vendorID, successList, model.SyncFlagNewMask)
}
// 保存被修改的商品提供记录
skuList := make([]string, 0, 0)
for _, v := range batchedStoreSkuList {
skuList = append(skuList, utils.Int2Str(v.SkuID))
}
skuSuccessList := make([]string, 0, 0)
for _, v := range successList {
skuSuccessList = append(skuSuccessList, utils.Int2Str(v.SkuID))
}
AddEventDetail(db, ctx, model.OperateUpdate, vendorID, model.ThingTypeSku, storeID, fmt.Sprintf("skuList:%s,time:%s", strings.Join(skuList, ","), utils.Time2TimeStr(time.Now())), fmt.Sprintf("skuSuccessList:%s", strings.Join(skuSuccessList, ",")))
if vendorID == model.VendorIDDD {
_, err = updateStoreSku(dao.GetDB(), vendorID, batchedStoreSkuList, model.SyncFlagNewMask)
}
@@ -837,6 +848,18 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
if len(successList) > 0 {
_, err = updateStoreSku(dao.GetDB(), vendorID, successList, model.SyncFlagModifiedMask)
}
// 保存被修改的商品提供记录
skuList := make([]string, 0, 0)
for _, v := range batchedStoreSkuList {
skuList = append(skuList, utils.Int2Str(v.SkuID))
}
skuSuccessList := make([]string, 0, 0)
for _, v := range successList {
skuSuccessList = append(skuSuccessList, utils.Int2Str(v.SkuID))
}
AddEventDetail(db, ctx, model.OperateUpdate, vendorID, model.ThingTypeSku, storeID, fmt.Sprintf("skuList:%s,time:%s", strings.Join(skuList, ","), utils.Time2TimeStr(time.Now())), fmt.Sprintf("skuSuccessList:%s", strings.Join(skuSuccessList, ",")))
return nil, len(successList), err
}, ctx, task, updateList, singleStoreHandler.GetStoreSkusBatchSize(partner.FuncUpdateStoreSkus), isContinueWhenError2)
}
@@ -879,6 +902,17 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
if len(successList) > 0 {
updateStoreSku(dao.GetDB(), vendorID, bareSku2Sync(successList), model.SyncFlagSaleMask)
}
// 保存被修改的商品提供记录
skuList := make([]string, 0, 0)
for _, v := range batchedStoreSkuList {
skuList = append(skuList, utils.Int2Str(v.SkuID))
}
skuSuccessList := make([]string, 0, 0)
for _, v := range successList {
skuSuccessList = append(skuSuccessList, utils.Int2Str(v.SkuID))
}
AddEventDetail(db, ctx, model.OperateUpdate, vendorID, model.ThingTypeSku, storeID, fmt.Sprintf("skuList:%s,status:%d", strings.Join(skuList, ","), status), fmt.Sprintf("skuSuccessList:%s", strings.Join(skuSuccessList, ",")))
return nil, len(successList), err
}, ctx, task, statusList, storeSkuHandler.GetStoreSkusBatchSize(partner.FuncUpdateStoreSkusStatus), isContinueWhenError2)
}