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

物料刷新

Browse Source
This commit is contained in:
邹宗楠
2021-11-18 11:40:32 +08:00
parent 2edc33468a
commit 8d093d0d97
1 changed files with 70 additions and 70 deletions
Download Patch File Download Diff File Expand all files Collapse all files

140
business/jxstore/cms/store_sku.go
View File

@@ -4712,80 +4712,80 @@ func ReturnStoreSkuBind(ctx *jxcontext.Context, snapshotAt string, storeIDs, sku
} }
func RefreshMatterStock(ctx *jxcontext.Context, skuID int) (err error) { func RefreshMatterStock(ctx *jxcontext.Context, skuID int) (err error) {
var ( // var (
db = dao.GetDB() // db = dao.GetDB()
skuBindInfos []*StoreSkuBindInfo // skuBindInfos []*StoreSkuBindInfo
) // )
if skuID != 0 { // if skuID != 0 {
skus, err := dao.GetSkus(db, []int{skuID}, nil, nil, nil, nil) // skus, err := dao.GetSkus(db, []int{skuID}, nil, nil, nil, nil)
if err != nil || len(skus) == 0 { // if err != nil || len(skus) == 0 {
return err return err
} }
result, err := api.JdEclpAPI.QueryStock(skus[0].EclpID) // result, err := api.JdEclpAPI.QueryStock(skus[0].EclpID)
if err != nil || result == nil { // if err != nil || result == nil {
return err return err
} }
var isSale = 0 // var isSale = 0
if len(result) == 0 { // if len(result) == 0 {
isSale = -1 // isSale = -1
} else { // } else {
if result[0].UsableNum > 0 { // if result[0].UsableNum > 0 {
isSale = 1 // isSale = 1
} else { // } else {
isSale = -1 // isSale = -1
} // }
} // }
storeSkuList, _ := dao.GetStoresSkusInfo(db, nil, []int{skuID}) // storeSkuList, _ := dao.GetStoresSkusInfo(db, nil, []int{skuID})
for _, vv := range storeSkuList { // for _, vv := range storeSkuList {
var storeSkuBindSkus []*StoreSkuBindSkuInfo // var storeSkuBindSkus []*StoreSkuBindSkuInfo
storeSkuBindSku := &StoreSkuBindSkuInfo{ // storeSkuBindSku := &StoreSkuBindSkuInfo{
SkuID: vv.SkuID, // SkuID: vv.SkuID,
IsSale: isSale, // IsSale: isSale,
} // }
storeSkuBindSkus = append(storeSkuBindSkus, storeSkuBindSku) // storeSkuBindSkus = append(storeSkuBindSkus, storeSkuBindSku)
storeSkuBind := &StoreSkuBindInfo{ // storeSkuBind := &StoreSkuBindInfo{
StoreID: vv.StoreID, // StoreID: vv.StoreID,
// NameID: v.SkuNameID, // // NameID: v.SkuNameID,
Skus: storeSkuBindSkus, // Skus: storeSkuBindSkus,
} // }
skuBindInfos = append(skuBindInfos, storeSkuBind) // skuBindInfos = append(skuBindInfos, storeSkuBind)
} // }
} else { // } else {
go func() { // go func() {
result, _ := api.JdEclpAPI.QueryStock("") // result, _ := api.JdEclpAPI.QueryStock("")
for _, v := range result { // for _, v := range result {
skus, err := dao.GetSkus(db, nil, nil, nil, nil, []string{v.GoodsNo}) // skus, err := dao.GetSkus(db, nil, nil, nil, nil, []string{v.GoodsNo})
if err != nil || len(skus) == 0 { // if err != nil || len(skus) == 0 {
continue // continue
} // }
var isSale = 0 // var isSale = 0
if v.UsableNum > 0 { // if v.UsableNum > 0 {
isSale = 1 // isSale = 1
} else { // } else {
isSale = -1 // isSale = -1
} // }
storeSkuList, _ := dao.GetStoresSkusInfo(db, nil, []int{skus[0].ID}) // storeSkuList, _ := dao.GetStoresSkusInfo(db, nil, []int{skus[0].ID})
for _, vv := range storeSkuList { // for _, vv := range storeSkuList {
var storeSkuBindSkus []*StoreSkuBindSkuInfo // var storeSkuBindSkus []*StoreSkuBindSkuInfo
storeSkuBindSku := &StoreSkuBindSkuInfo{ // storeSkuBindSku := &StoreSkuBindSkuInfo{
SkuID: vv.SkuID, // SkuID: vv.SkuID,
IsSale: isSale, // IsSale: isSale,
} // }
storeSkuBindSkus = append(storeSkuBindSkus, storeSkuBindSku) // storeSkuBindSkus = append(storeSkuBindSkus, storeSkuBindSku)
storeSkuBind := &StoreSkuBindInfo{ // storeSkuBind := &StoreSkuBindInfo{
StoreID: vv.StoreID, // StoreID: vv.StoreID,
NameID: skus[0].NameID, // NameID: skus[0].NameID,
Skus: storeSkuBindSkus, // Skus: storeSkuBindSkus,
} // }
skuBindInfos = append(skuBindInfos, storeSkuBind) // skuBindInfos = append(skuBindInfos, storeSkuBind)
} // }
} // }
//物料店666666 // //物料店666666
updateStoresSkusWithoutSync(ctx, db, []int{666666}, skuBindInfos, false, false) // updateStoresSkusWithoutSync(ctx, db, []int{666666}, skuBindInfos, false, false)
}() // }()
//
} // }
return err // return err
} }
func buildStoreSkuBindInfosAndFocus(ctx *jxcontext.Context, db *dao.DaoDB, store *dao.StoreDetail, v *partner.SkuNameInfo, nameID int) (err error) { func buildStoreSkuBindInfosAndFocus(ctx *jxcontext.Context, db *dao.DaoDB, store *dao.StoreDetail, v *partner.SkuNameInfo, nameID int) (err error) {