添加地址

configs/config.go

@@ -153,10 +153,10 @@ func init() {
 		ConfigEsAddress = "http://127.0.0.1:9200/recook/_analyze?pretty=true"
 	}
 	supply.InitSupply(supply.Config{
-		Url:       "",
-		ChannelId: 0,
-		AppKey:    "",
-		AppSecret: "",
+		Url:       "https://supply_api.reecook.cn/supply",
+		ChannelId: 1,
+		AppKey:    "33jTu4x683dEA3U3wiPj60RfZ1KIMQCq",
+		AppSecret: "wCWFon9CbP7KEFbczZ2wT8CcSRCKSdhSFIFK34e2jwlqm3dg5JGy1qlhTJwqllcs",
 	})
 	//rabbitmq.InitRabbitmq("127.0.0.1", 5672, "33jTu4x683dEA3U3wiPj60RfZ1KIMQCq", "wCWFon9CbP7KEFbczZ2wT8CcSRCKSdhSFIFK34e2jwlqm3dg5JGy1qlhTJwqllcs")
 }

internal/v2/controller/app/jcook/jcook.go

@@ -91,4 +91,28 @@ func (a *Proxy) Stock(c *gin.Context) {
 			"stock_state": resp[0].StockState,
 		})
 	}
+	if gs.ThirdPartyType == 5 {
+		id, _ := strconv.Atoi(gs.ThirdPartySkuId)
+		req := shama.SkuStockReq{
+			Address: p.Address,
+			SkuList: []shama.SkuQuantity{
+				{
+					SkuID:    uint(id),
+					Quantity: p.Quantity,
+				},
+			},
+		}
+		client := shama.GetClient()
+		var resp []shama.SkuStockResp
+		if err = client.Exec(req, &resp); err != nil {
+			log.Println(err)
+			back.Suc(c, "", gin.H{
+				"stock_state": 0,
+			})
+			return
+		}
+		back.Suc(c, "", gin.H{
+			"stock_state": resp[0].StockState,
+		})
+	}
 }