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:
邹宗楠
2023-01-03 16:17:16 +08:00
parent 36059bd1dc
commit 9902bf1ed4
4 changed files with 28 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
business/partner/purchase/mtwm/store_sku2.go
View File

@@ -343,7 +343,6 @@ func (p *PurchaseHandler) createOrUpdateStoreSkus(ctx *jxcontext.Context, storeI
} }
} }
globals.SugarLogger.Debugf("foodDataList=======mtwm %s", utils.Format4Output(foodDataList, false))
if globals.EnableMtwmStoreWrite { if globals.EnableMtwmStoreWrite {
if len(foodDataList) == 1 { if len(foodDataList) == 1 {
foodDataList[0]["skus"] = string(utils.MustMarshal(foodDataList[0]["skus"])) foodDataList[0]["skus"] = string(utils.MustMarshal(foodDataList[0]["skus"]))

0
business/partner/purchase/tiktok_store/mtwm.go → business/partner/purchase/tiktok_store/dy.go
View File

36
business/partner/purchase/tiktok_store/store_sku2.go
View File

@@ -130,17 +130,15 @@ func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOr
if status == model.SkuStatusNormal { // 下架 if status == model.SkuStatusNormal { // 下架
for _, v := range storeSkuList { for _, v := range storeSkuList {
// 子品商品id获取skuId // 子品商品id获取skuId
childrenSkuId, failedList := getProductSkuId4UpdateStock(api, v, storeID) //childrenSkuId, failedList := getProductSkuId4UpdateStock(api, v, storeID)
if len(failedList) > 0 { //if len(failedList) > 0 {
continue // continue
} //}
param := &sku_syncStock_request.SkuSyncStockParam{ param := &sku_syncStock_request.SkuSyncStockParam{
SkuId: childrenSkuId,
ProductId: utils.Str2Int64(v.VendorSkuID), ProductId: utils.Str2Int64(v.VendorSkuID),
Incremental: false, Incremental: false,
IdempotentId: "",
StockNum: 99999, StockNum: 99999,
OutWarehouseId: vendorStoreID, OutSkuId: int64(v.SkuID),
} }
if err := api.UpdateSkuStock(param); err != nil { if err := api.UpdateSkuStock(param); err != nil {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], fmt.Sprintf("上架商品,库存值最大化.%s", utils.Format4Output(param, false)))...) failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], fmt.Sprintf("上架商品,库存值最大化.%s", utils.Format4Output(param, false)))...)
@@ -149,18 +147,16 @@ func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOr
} else { // 上架 } else { // 上架
for _, v := range storeSkuList { for _, v := range storeSkuList {
// 子品商品id获取skuId // 子品商品id获取skuId
childrenSkuId, failedList := getProductSkuId4UpdateStock(api, v, storeID) //childrenSkuId, failedList := getProductSkuId4UpdateStock(api, v, storeID)
if len(failedList) > 0 { //if len(failedList) > 0 {
continue // continue
} //}
param := &sku_syncStock_request.SkuSyncStockParam{ param := &sku_syncStock_request.SkuSyncStockParam{
SkuId: childrenSkuId,
ProductId: utils.Str2Int64(v.VendorSkuID), ProductId: utils.Str2Int64(v.VendorSkuID),
Incremental: false, Incremental: false,
IdempotentId: "",
StockNum: 0, StockNum: 0,
OutWarehouseId: vendorStoreID, OutSkuId: int64(v.SkuID),
} }
if err := api.UpdateSkuStock(param); err != nil { if err := api.UpdateSkuStock(param); err != nil {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], fmt.Sprintf("下架商品,库存值为0失败.%s", utils.Format4Output(param, false)))...) failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], fmt.Sprintf("下架商品,库存值为0失败.%s", utils.Format4Output(param, false)))...)
@@ -203,18 +199,16 @@ func (p *PurchaseHandler) UpdateStoreSkusStock(ctx *jxcontext.Context, vendorOrg
tiktokApi := getAPI(storeSkuList[0].VendorOrgCode, storeID, vendorStoreID) tiktokApi := getAPI(storeSkuList[0].VendorOrgCode, storeID, vendorStoreID)
for _, v := range storeSkuList { for _, v := range storeSkuList {
// 子品商品id获取skuId // 子品商品id获取skuId
childrenSkuId, failedList := getProductSkuId4UpdateStock(tiktokApi, v, storeID) //childrenSkuId, failedList := getProductSkuId4UpdateStock(tiktokApi, v, storeID)
if len(failedList) > 0 { //if len(failedList) > 0 {
continue // continue
} //}
stockNum := &sku_syncStock_request.SkuSyncStockParam{ stockNum := &sku_syncStock_request.SkuSyncStockParam{
SkuId: childrenSkuId,
ProductId: utils.Str2Int64(v.VendorSkuID), ProductId: utils.Str2Int64(v.VendorSkuID),
Incremental: false, Incremental: false,
IdempotentId: "",
StockNum: int64(v.Stock), StockNum: int64(v.Stock),
OutWarehouseId: vendorStoreID, OutSkuId: int64(v.SkuID),
} }
if stockNum.StockNum == 0 { if stockNum.StockNum == 0 {
stockNum.StockNum = 99999 stockNum.StockNum = 99999

4
business/partner/purchase/tiktok_store/store_sku2_utils.go
View File

@@ -529,12 +529,10 @@ func upDateChildrenPriceStockLaunch(api *tiktokShop.API, storeSku *dao.StoreSkuS
} }
// 同步库存 // 同步库存
paramStock := &sku_syncStock_request.SkuSyncStockParam{ paramStock := &sku_syncStock_request.SkuSyncStockParam{
SkuId: skuId,
ProductId: childrenProductId, ProductId: childrenProductId,
Incremental: false, Incremental: false,
IdempotentId: "",
StockNum: int64(storeSku.Stock), StockNum: int64(storeSku.Stock),
OutWarehouseId: vendorStoreID, OutSkuId: int64(storeSku.SkuID),
} }
if paramStock.StockNum == 0 { if paramStock.StockNum == 0 {
paramStock.StockNum = 99999 paramStock.StockNum = 99999