diff --git a/skycrane/task.go b/skycrane/task.go index 31b6871..fa5d7ee 100644 --- a/skycrane/task.go +++ b/skycrane/task.go @@ -43,3 +43,23 @@ func (t *task) GetPullStatus(ctx context.Context) (reply TaskStatus, err error) err = xClient.Call(ctx, "GetPullStatus", 0, &reply) return } + +// Prices @Title 商品更新 +func (t *task) Prices(ctx context.Context) error { + a := 0 + xClient, err := client.GetClient(t) + if err != nil { + return err + } + return xClient.Call(ctx, "Prices", 0, &a) +} + +// GetPricesStatus @Title 获取拉取状态 +func (t *task) GetPricesStatus(ctx context.Context) (reply TaskStatus, err error) { + xClient, err := client.GetClient(t) + if err != nil { + return + } + err = xClient.Call(ctx, "GetPricesStatus", 0, &reply) + return +}