京东商城门店库存同步

business/jxstore/cms/sync.go

@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"git.rosy.net.cn/jx-callback/business/partner/putils"
+	"git.rosy.net.cn/jx-callback/globals/api"
 
 	"git.rosy.net.cn/baseapi"
 	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
@@ -1089,6 +1090,7 @@ func (v *VendorSync) SyncJdsStoresSkus(ctx *jxcontext.Context, storeIDs []int, i
 	var (
 		db = dao.GetDB()
 	)
+	storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID}, nil)
 	_, hint, err = v.LoopStoresMap2(ctx, nil, db, fmt.Sprintf("同步京东商城库存商品信息:%v", storeIDs), isAsync, true, []int{model.VendorIDJDShop}, storeIDs, false,
 		func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (interface{}, error) {
 			loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
@@ -1097,6 +1099,7 @@ func (v *VendorSync) SyncJdsStoresSkus(ctx *jxcontext.Context, storeIDs []int, i
 					if storeMap.Status > model.StoreStatusDisabled && storeMap.StoreID != model.JdShopMainStoreID && storeMap.SyncRule != 0 {
 						err = syncJdsStoresSkus(ctx, db, nil, storeMap, isAsync, isContinueWhenError)
 					}
+					err = syncJdsStoreStock(ctx, db, storeSkus, storeMap)
 				}
 			}
 			return nil, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID)
@@ -1104,6 +1107,25 @@ func (v *VendorSync) SyncJdsStoresSkus(ctx *jxcontext.Context, storeIDs []int, i
 	return hint, err
 }
 
+func syncJdsStoreStock(ctx *jxcontext.Context, db *dao.DaoDB, storeSkus []*model.StoreSkuBind, storeMap *model.StoreMap) (err error) {
+	task := tasksch.NewParallelTask("syncJdsStoreStock", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			storeSku := batchItemList[0].(*model.StoreSkuBind)
+			stock := 0
+			if storeSku.Status == model.StoreSkuBindStatusNormal {
+				stock = 9999
+			}
+			storeSku2, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{storeSku.SkuID})
+			if storeSku.JdsID != 0 && len(storeSku2) > 0 {
+				err = api.JdShopAPI.UpdateSkuSiteStock(storeSku.JdsID, stock, utils.Str2Int(storeMap.VendorStoreID))
+			}
+			return retVal, err
+		}, storeSkus)
+	tasksch.HandleTask(task, nil, true).Run()
+	_, err = task.GetResult(0)
+	return err
+}
+
 func syncJdsStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, parentTask tasksch.ITask, storeMap *model.StoreMap, isAsync, isContinueWhenError bool) (err error) {
 	var (
 		mainSkusMap   = make(map[int][]*dao.StoreSkuSyncInfo)

business/partner/purchase/jdshop/store_sku.go

@@ -237,10 +237,10 @@ func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOr
 	if globals.EnableJdShopWrite {
 		var stock = 0
 		for _, v := range storeSkuList {
-			if status == model.SkuStatusNormal {
-				stock = 9999
-			}
 			if storeID == model.JdShopMainStoreID {
+				if status == model.SkuStatusNormal {
+					stock = 9999
+				}
 				if v.JdsStockSwitch == model.NO {
 					stock = 0
 				}
@@ -250,6 +250,9 @@ func (p *PurchaseHandler) UpdateStoreSkusStatus(ctx *jxcontext.Context, vendorOr
 				err = err2
 				if len(storeSkus) > 0 {
 					if storeSkus[0].JdsID != 0 && vendorStoreID != "" {
+						if storeSkus[0].Status == model.SkuStatusNormal {
+							stock = 9999
+						}
 						err = api.JdShopAPI.UpdateSkuSiteStock(storeSkus[0].JdsID, stock, utils.Str2Int(vendorStoreID))
 					}
 				}