添加任务

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
+}