kedaya_haitao/us-coach-spider
1
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases 1 Wiki Activity

feat 添加新的商品

Browse Source
This commit is contained in:
timerzz 2024-11-21 15:44:31 +08:00
parent 63633ede61
commit bec654c8ce
1 changed files with 26 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
spider/controller.go
View File

@ -269,6 +269,13 @@ func (c *Controller) saveProducts(articles []v2.Article) {
} }
func (c *Controller) FetchArticleDetail(ctx context.Context, pid string) error { func (c *Controller) FetchArticleDetail(ctx context.Context, pid string) error {
old, err := c.storage.ProviderArticle().Get(storage.NewGetProviderArticleQuery().SetProviderId(c.providerId).SetPid(pid))
if err == nil {
return fmt.Errorf("该商品已经存在")
}
if !errors.As(err, &gorm.ErrRecordNotFound) {
return err
}
resp, err := c.client.RequestProductDetail(ctx, pid) resp, err := c.client.RequestProductDetail(ctx, pid)
if err != nil { if err != nil {
return fmt.Errorf("请求商品信息失败: %v", err) return fmt.Errorf("请求商品信息失败: %v", err)
@ -279,18 +286,25 @@ func (c *Controller) FetchArticleDetail(ctx context.Context, pid string) error {
EnglishName: resp.Name, EnglishName: resp.Name,
Pid: resp.Id, Pid: resp.Id,
Brand: v2.Brand_Coach, Brand: v2.Brand_Coach,
Providers: []v2.ProviderArticle{
{
ProviderId: c.providerId,
Brand: v2.Brand_Coach,
Pid: pid,
SkuID: pid,
Available: resp.Inventory.Orderable,
Ast: resp.Inventory.Ats,
Link: fmt.Sprintf("%s/%s", "https://www.coachoutlet.com", resp.Url),
},
},
} }
pArticle := v2.ProviderArticle{
ProviderId: c.providerId,
Brand: v2.Brand_Coach,
Pid: pid,
SkuID: pid,
Available: resp.Inventory.Orderable,
Ast: resp.Inventory.Ats,
Link: fmt.Sprintf("%s/%s", "https://www.coachoutlet.com", resp.Url),
Cost: utils.CalculateProviderPrice(
append(c.provider.CalculateProcess, old.CalculateProcess...),
map[string]float64{
"originalPrice": resp.Prices.CurrentPrice,
"freight": c.provider.Config.Freight,
"exchangeRate": c.provider.Config.ExchangeRate,
}),
}
pArticle.HistoryPrice = append(pArticle.HistoryPrice, pArticle.Cost)
article.Providers = append(article.Providers, pArticle)
if len(resp.ImageGroups) > 0 { if len(resp.ImageGroups) > 0 {
article.Image = resp.ImageGroups[0].Images[0].Src article.Image = resp.ImageGroups[0].Images[0].Src
} }
@ -298,7 +312,7 @@ func (c *Controller) FetchArticleDetail(ctx context.Context, pid string) error {
return nil return nil
} }
func (c *Controller)FetchArticleAts(ctx context.Context, pid string) error { func (c *Controller) FetchArticleAts(ctx context.Context, pid string) error {
pArticle, err := c.storage.ProviderArticle().Get(storage.NewGetProviderArticleQuery().SetProviderId(c.providerId).SetPid(pid)) pArticle, err := c.storage.ProviderArticle().Get(storage.NewGetProviderArticleQuery().SetProviderId(c.providerId).SetPid(pid))
if err != nil { if err != nil {
return fmt.Errorf("获取商品信息失败: %v", err) return fmt.Errorf("获取商品信息失败: %v", err)