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:
邹宗楠
2022-10-27 19:57:46 +08:00
parent 411dce6354
commit 762ecd3082
3 changed files with 41 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/model/dao/thing_map.go
View File

@@ -50,7 +50,8 @@ func GetThingToTiktokMapList(db *DaoDB, vendorId int, thingId int64) (cats []*mo
WHERE thing_id = ? AND vendor_id = ? t1.deleted_at = ? WHERE thing_id = ? AND vendor_id = ? t1.deleted_at = ?
` `
sqlParams := []interface{}{ sqlParams := []interface{}{
vendorId, thingId, thingId,
vendorId,
utils.DefaultTimeValue, utils.DefaultTimeValue,
} }

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

@@ -211,12 +211,11 @@ func (p *PurchaseHandler) DeleteStoreSkus(ctx *jxcontext.Context, storeID int, v
return failedList, err return failedList, err
} }
// UpdateStoreSkusStatus 批量更新商品上下架 // UpdateStoreSkusStatus 批量更新商品上下架(上架商品库存更新最大,下架商品库存为0)
func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo, status int) (failedList []*partner.StoreSkuInfoWithErr, err error) { func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, storeSkuList []*partner.StoreSkuInfo, status int) (failedList []*partner.StoreSkuInfoWithErr, err error) {
api := getAPI(vendorOrgCode, storeID, vendorStoreID) api := getAPI(vendorOrgCode, storeID, vendorStoreID)
if status == model.SkuStatusNormal { // 上架 if status == model.SkuStatusNormal { // 上架
for _, v := range storeSkuList { for _, v := range storeSkuList {
// p.createOrUpdateStoreSkus(ctx, storeID, vendorStoreID, storeSkuList, false)
if err := api.EditStoreCommodityCommit(&product_editV2_commit_request.ProductEditV2Param2{ if err := api.EditStoreCommodityCommit(&product_editV2_commit_request.ProductEditV2Param2{
ProductId: utils.Str2Int64(v.VendorSkuID), ProductId: utils.Str2Int64(v.VendorSkuID),
Commit: true, Commit: true,
@@ -225,14 +224,38 @@ func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOr
} else { } else {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "上架商品正常")...) failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "上架商品正常")...)
} }
if err := api.UpdateSkuStock(&sku_syncStock_request.SkuSyncStockParam{
SkuId: utils.Str2Int64(v.VendorSkuAttrId),
ProductId: utils.Str2Int64(v.VendorSkuID),
Incremental: false,
IdempotentId: "",
StockNum: 9999,
OutWarehouseId: vendorStoreID,
}); err != nil {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "上架商品异常,添加固定库存")...)
} else {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "上架商品正常,添加固定库存")...)
}
} }
} else { // 下架 } else { // 下架
for _, v := range storeSkuList { for _, v := range storeSkuList {
err := api.ProductSetOffline(utils.Str2Int64(v.VendorSkuID)) //err := api.ProductSetOffline(utils.Str2Int64(v.VendorSkuID))
if err == nil { //if err == nil {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "下架商品正常")...) // failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "下架商品正常")...)
//} else {
// failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "下架商品异常")...)
//}
if err := api.UpdateSkuStock(&sku_syncStock_request.SkuSyncStockParam{
SkuId: utils.Str2Int64(v.VendorSkuAttrId),
ProductId: utils.Str2Int64(v.VendorSkuID),
Incremental: false,
IdempotentId: "",
StockNum: 0,
OutWarehouseId: vendorStoreID,
}); err != nil {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "下架商品异常,库存更新为0")...)
} else { } else {
failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "下架商品异常")...) failedList = append(failedList, putils.GetErrMsg2FailedSingleList(v, err, storeID, model.VendorChineseNames[model.VendorIDDD], "上架商品正常,库存更新为0")...)
} }
} }
} }

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

@@ -531,13 +531,9 @@ func GetSpecPrices(specs, storeId string, mainSkuId int64, localSku *dao.StoreSk
{InfoType: "weight", InfoUnit: localSku.SpecUnit, InfoValue: fmt.Sprintf("%f", localSku.SpecQuality)}, {InfoType: "weight", InfoUnit: localSku.SpecUnit, InfoValue: fmt.Sprintf("%f", localSku.SpecQuality)},
}, },
} }
if mainSkuId == 0 { sku.StockNum = localSku.Stock
sku.StockNum = 0
} else {
sku.StockNum = 0
sku.SkuType = 1 sku.SkuType = 1
sku.StockNumMap = map[string]int64{storeId: int64(localSku.Stock)} sku.StockNumMap = map[string]int64{storeId: int64(localSku.Stock)}
}
skuSize = append(skuSize, sku) skuSize = append(skuSize, sku)
} }
case 2: case 2:
@@ -557,13 +553,9 @@ func GetSpecPrices(specs, storeId string, mainSkuId int64, localSku *dao.StoreSk
{InfoType: "weight", InfoUnit: localSku.SpecUnit, InfoValue: fmt.Sprintf("%f", localSku.SpecQuality)}, {InfoType: "weight", InfoUnit: localSku.SpecUnit, InfoValue: fmt.Sprintf("%f", localSku.SpecQuality)},
}, },
} }
if mainSkuId == 0 { sku.StockNum = localSku.Stock
sku.StockNum = 0
} else {
sku.StockNum = 0
sku.SkuType = 1 sku.SkuType = 1
sku.StockNumMap = map[string]int64{storeId: int64(localSku.Stock)} sku.StockNumMap = map[string]int64{storeId: int64(localSku.Stock)}
}
skuSize = append(skuSize, sku) skuSize = append(skuSize, sku)
} }
} }
@@ -587,13 +579,10 @@ func GetSpecPrices(specs, storeId string, mainSkuId int64, localSku *dao.StoreSk
{InfoType: "weight", InfoUnit: localSku.SpecUnit, InfoValue: fmt.Sprintf("%f", localSku.SpecQuality)}, {InfoType: "weight", InfoUnit: localSku.SpecUnit, InfoValue: fmt.Sprintf("%f", localSku.SpecQuality)},
}, },
} }
if mainSkuId == 0 { sku.StockNum = localSku.Stock
sku.StockNum = 0
} else {
sku.StockNum = 0 sku.StockNum = 0
sku.SkuType = 1 sku.SkuType = 1
sku.StockNumMap = map[string]int64{storeId: int64(localSku.Stock)} sku.StockNumMap = map[string]int64{storeId: int64(localSku.Stock)}
}
skuSize = append(skuSize, sku) skuSize = append(skuSize, sku)
} }
} }