Compare commits
1 Commits
| Author | SHA1 | Date |
|---|---|---|
 杨赟
|
341ad37d45 | 1 year ago |
@ -1,85 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"git.oa00.com/supply-chain/service/client"
|
|
||||||
"git.oa00.com/supply-chain/service/lib/bean"
|
|
||||||
)
|
|
||||||
|
|
||||||
type address struct {
|
|
||||||
}
|
|
||||||
type AddressSearch struct {
|
|
||||||
AddressId int64
|
|
||||||
Mate int // 1=已匹配 2=未匹配
|
|
||||||
}
|
|
||||||
type ArgsAddressList struct {
|
|
||||||
Search AddressSearch
|
|
||||||
Page bean.Page
|
|
||||||
}
|
|
||||||
|
|
||||||
type AddressItem struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
ProvinceName string `json:"provinceName"`
|
|
||||||
CityName string `json:"cityName"`
|
|
||||||
CountyName string `json:"countyName"`
|
|
||||||
MateAddressId int64 `json:"mateAddressId"`
|
|
||||||
MateProvinceName string `json:"mateProvinceName"`
|
|
||||||
MateCityName string `json:"mateCityName"`
|
|
||||||
MateCountyName string `json:"mateCountyName"`
|
|
||||||
}
|
|
||||||
type ReplyAddressList struct {
|
|
||||||
Lists []AddressItem `json:"lists"`
|
|
||||||
Total int64 `json:"total"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// List @Title 地址列表
|
|
||||||
func (c *address) List(ctx context.Context, args ArgsAddressList) (reply ReplyAddressList, err error) {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "List", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type ArgsAddressMate struct {
|
|
||||||
AddressId int64 // 地址id
|
|
||||||
MateAddressID int64 // 修改匹配地址id
|
|
||||||
}
|
|
||||||
|
|
||||||
// Mate @Title 地址匹配
|
|
||||||
func (c *address) Mate(ctx context.Context, args ArgsAddressMate) error {
|
|
||||||
reply := 0
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return xClient.Call(ctx, "Mate", args, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// All @Title 地址
|
|
||||||
func (c *address) All(ctx context.Context, args AddressSearch) (reply []AddressItem, err error) {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "All", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type MateAddressItem struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
ProvinceName string `json:"provinceName"`
|
|
||||||
CityName string `json:"cityName"`
|
|
||||||
CountyName string `json:"countyName"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// MateAll @Title 匹配地址
|
|
||||||
func (c *address) MateAll(ctx context.Context) (reply []MateAddressItem, err error) {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "MateAll", 0, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
@ -1,62 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"git.oa00.com/supply-chain/service/client"
|
|
||||||
"git.oa00.com/supply-chain/service/lib/bean"
|
|
||||||
)
|
|
||||||
|
|
||||||
type brand struct {
|
|
||||||
}
|
|
||||||
type BrandSearch struct {
|
|
||||||
Name string // 商品名称
|
|
||||||
}
|
|
||||||
type ArgsBrandList struct {
|
|
||||||
Search BrandSearch
|
|
||||||
Page bean.Page
|
|
||||||
}
|
|
||||||
|
|
||||||
type BrandItem struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
MateBrandID int64 `json:"mateBrandID"`
|
|
||||||
}
|
|
||||||
type ReplyBrandList struct {
|
|
||||||
Lists []BrandItem `json:"lists"`
|
|
||||||
Total int64 `json:"total"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// List @Title 品牌列表
|
|
||||||
func (b *brand) List(ctx context.Context, args ArgsBrandList) (reply ReplyBrandList, err error) {
|
|
||||||
xClient, err := client.GetClient(b)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "List", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type ArgsBrandMate struct {
|
|
||||||
BrandId int64 // 品牌id
|
|
||||||
SupplyBrandId int64 // 修改匹配品牌id
|
|
||||||
}
|
|
||||||
|
|
||||||
// Mate @Title 品牌匹配
|
|
||||||
func (b *brand) Mate(ctx context.Context, args ArgsBrandMate) error {
|
|
||||||
reply := 0
|
|
||||||
xClient, err := client.GetClient(b)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return xClient.Call(ctx, "Mate", args, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// All @Title 品牌
|
|
||||||
func (b *brand) All(ctx context.Context, args BrandSearch) (reply []BrandItem, err error) {
|
|
||||||
xClient, err := client.GetClient(b)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "All", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
@ -1,74 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"git.oa00.com/supply-chain/service/client"
|
|
||||||
)
|
|
||||||
|
|
||||||
type callback struct {
|
|
||||||
}
|
|
||||||
|
|
||||||
// Cancel @TITLE 取消订单
|
|
||||||
func (c *callback) Cancel(ctx context.Context, sourceOrderSn string) error {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
reply := 0
|
|
||||||
return xClient.Call(ctx, "Cancel", sourceOrderSn, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// StockOut @Title 出库
|
|
||||||
func (c *callback) StockOut(ctx context.Context, sourceOrderSn string) error {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
reply := 0
|
|
||||||
return xClient.Call(ctx, "StockOut", sourceOrderSn, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Delivered @Title 订单妥投
|
|
||||||
func (c *callback) Delivered(ctx context.Context, sourceOrderSn string) error {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
reply := 0
|
|
||||||
return xClient.Call(ctx, "Delivered", sourceOrderSn, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Finish @Title 订单完成
|
|
||||||
func (c *callback) Finish(ctx context.Context, sourceOrderSn string) error {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
reply := 0
|
|
||||||
return xClient.Call(ctx, "Finish", sourceOrderSn, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Logistics @Title 更新包裹信息
|
|
||||||
func (c *callback) Logistics(ctx context.Context, sourceOrderSn string) error {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
reply := 0
|
|
||||||
return xClient.Call(ctx, "Logistics", sourceOrderSn, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
type ArgsCallbackAfsStepResult struct {
|
|
||||||
ReturnOrderCode string
|
|
||||||
ReturnOrderStatus int64
|
|
||||||
}
|
|
||||||
|
|
||||||
// AfsStepResult @Title 售后处理
|
|
||||||
func (c *callback) AfsStepResult(ctx context.Context, args ArgsCallbackAfsStepResult) error {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
reply := 0
|
|
||||||
return xClient.Call(ctx, "AfsStepResult", args, &reply)
|
|
||||||
}
|
|
||||||
@ -1,65 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"git.oa00.com/supply-chain/service/client"
|
|
||||||
"git.oa00.com/supply-chain/service/lib/bean"
|
|
||||||
)
|
|
||||||
|
|
||||||
type category struct {
|
|
||||||
}
|
|
||||||
type CategorySearch struct {
|
|
||||||
CategoryId int64
|
|
||||||
Mate int // 1=已匹配 2=未匹配
|
|
||||||
}
|
|
||||||
type ArgsCategoryList struct {
|
|
||||||
Search CategorySearch
|
|
||||||
Page bean.Page
|
|
||||||
}
|
|
||||||
|
|
||||||
type CategoryItem struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
FirstCategoryName string `json:"firstCategoryName"`
|
|
||||||
SecondCategoryName string `json:"secondCategoryName"`
|
|
||||||
ThirdCategoryName string `json:"thirdCategoryName"`
|
|
||||||
MateCategoryID int64 `json:"mateCategoryID"`
|
|
||||||
}
|
|
||||||
type ReplyCategoryList struct {
|
|
||||||
Lists []CategoryItem `json:"lists"`
|
|
||||||
Total int64 `json:"total"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// List @Title 类目列表
|
|
||||||
func (c *category) List(ctx context.Context, args ArgsCategoryList) (reply ReplyCategoryList, err error) {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "List", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type ArgsCategoryMate struct {
|
|
||||||
CategoryId int64 // 类目id
|
|
||||||
SupplyCategoryId int64 // 修改匹配类目id
|
|
||||||
}
|
|
||||||
|
|
||||||
// Mate @Title 类目匹配
|
|
||||||
func (c *category) Mate(ctx context.Context, args ArgsCategoryMate) error {
|
|
||||||
reply := 0
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return xClient.Call(ctx, "Mate", args, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
// All @Title 类目
|
|
||||||
func (c *category) All(ctx context.Context, args CategorySearch) (reply []CategoryItem, err error) {
|
|
||||||
xClient, err := client.GetClient(c)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "All", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
@ -1,191 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"git.oa00.com/supply-chain/service/client"
|
|
||||||
"git.oa00.com/supply-chain/service/lib/bean"
|
|
||||||
"github.com/shopspring/decimal"
|
|
||||||
)
|
|
||||||
|
|
||||||
const (
|
|
||||||
SkuStatusNone = 1 // 待处理
|
|
||||||
SkuStatusAdopt = 2 // 同步入库
|
|
||||||
SkuStatusReject = 3 // 废弃商品
|
|
||||||
)
|
|
||||||
|
|
||||||
type sku struct {
|
|
||||||
}
|
|
||||||
type SkuSearch struct {
|
|
||||||
Status int // 状态
|
|
||||||
Name string // 商品名称
|
|
||||||
Code string // sku编码
|
|
||||||
CategoryId int64 // 类目id
|
|
||||||
BrandName string // 品牌
|
|
||||||
MinSupplyPrice decimal.Decimal // 采购价最小
|
|
||||||
MaxSupplyPrice decimal.Decimal // 采购价最大
|
|
||||||
}
|
|
||||||
type ArgsSkuList struct {
|
|
||||||
Search SkuSearch
|
|
||||||
Page bean.Page
|
|
||||||
}
|
|
||||||
type SkuItem struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Code string `json:"code"`
|
|
||||||
MainPhoto string `json:"mainPhoto"`
|
|
||||||
BrandName string `json:"brandName"`
|
|
||||||
FirstCategoryName string `json:"firstCategoryName"`
|
|
||||||
SecondCategoryName string `json:"secondCategoryName"`
|
|
||||||
ThirdCategoryName string `json:"thirdCategoryName"`
|
|
||||||
SupplyPrice decimal.Decimal `json:"supplyPrice"`
|
|
||||||
GuidePrice decimal.Decimal `json:"guidePrice"`
|
|
||||||
ShelvesStatus int64 `json:"shelvesStatus"`
|
|
||||||
Status int64 `json:"status"`
|
|
||||||
CreatedAt int64 `json:"createdAt"`
|
|
||||||
UpdatedAt int64 `json:"updatedAt"`
|
|
||||||
MateBrandId int64 `json:"mateBrandId"`
|
|
||||||
MateCategoryId int64 `json:"mateCategoryId"`
|
|
||||||
}
|
|
||||||
type ReplySkuList struct {
|
|
||||||
Lists []SkuItem `json:"lists"`
|
|
||||||
Total int64 `json:"total"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// List @Title 商品列表
|
|
||||||
func (s *sku) List(ctx context.Context, args ArgsSkuList) (reply ReplySkuList, err error) {
|
|
||||||
xClient, err := client.GetClient(s)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
xClient.Call(ctx, "List", args, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type SkuImg struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
Path string `json:"path"`
|
|
||||||
ReplacePath string `json:"replacePath"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// Imgs @Title 获取预览图
|
|
||||||
func (s *sku) Imgs(ctx context.Context, skuId int64) (reply []SkuImg, err error) {
|
|
||||||
xClient, err := client.GetClient(s)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
err = xClient.Call(ctx, "Imgs", skuId, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type ReplySkuInfo struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
GoodsCode string `json:"goodsCode"`
|
|
||||||
GoodsName string `json:"goodsName"`
|
|
||||||
Code string `json:"code"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Title string `json:"title"`
|
|
||||||
SellPrice decimal.Decimal `json:"sellPrice"`
|
|
||||||
MarketPrice decimal.Decimal `json:"marketPrice"`
|
|
||||||
StartQty int64 `json:"startQty"`
|
|
||||||
ShelvesStatus int64 `json:"shelvesStatus"`
|
|
||||||
TaxCode string `json:"taxCode"`
|
|
||||||
TaxRate decimal.Decimal `json:"taxRate"`
|
|
||||||
BarCode string `json:"barCode"`
|
|
||||||
IsDeleted int64 `json:"isDeleted"`
|
|
||||||
BrandId int64 `json:"brandId"`
|
|
||||||
BrandCode string `json:"brandCode"`
|
|
||||||
BrandName string `json:"brandName"`
|
|
||||||
CategoryId int64 `json:"categoryId"`
|
|
||||||
FirstCategoryCode string `json:"firstCategoryCode"`
|
|
||||||
FirstCategoryName string `json:"firstCategoryName"`
|
|
||||||
SecondCategoryCode string `json:"secondCategoryCode"`
|
|
||||||
SecondCategoryName string `json:"secondCategoryName"`
|
|
||||||
ThirdCategoryCode string `json:"thirdCategoryCode"`
|
|
||||||
ThirdCategoryName string `json:"thirdCategoryName"`
|
|
||||||
ReturnGoodsRules int64 `json:"returnGoodsRules"`
|
|
||||||
GoodsCharacteristic string `json:"goodsCharacteristic"`
|
|
||||||
GoodsUnit string `json:"goodsUnit"`
|
|
||||||
ModelNumber string `json:"modelNumber"`
|
|
||||||
ProductPlace string `json:"productPlace"`
|
|
||||||
HaveShelfLife int64 `json:"haveShelfLife"`
|
|
||||||
ShelfLife string `json:"shelfLife"`
|
|
||||||
FragileGoods int64 `json:"fragileGoods"`
|
|
||||||
GrossWeight decimal.Decimal `json:"grossWeight"`
|
|
||||||
GrossWeightUnit string `json:"grossWeightUnit"`
|
|
||||||
Density decimal.Decimal `json:"density"`
|
|
||||||
Extent decimal.Decimal `json:"extent"`
|
|
||||||
Width decimal.Decimal `json:"width"`
|
|
||||||
Height decimal.Decimal `json:"height"`
|
|
||||||
CreatedAt int64 `json:"createdAt"`
|
|
||||||
UpdatedAt int64 `json:"updatedAt"`
|
|
||||||
MateBrandId int64 `json:"mateBrandId"`
|
|
||||||
MateCategoryId int64 `json:"mateCategoryId"`
|
|
||||||
Content string `json:"content"`
|
|
||||||
Imgs []SkuImg `json:"imgs"`
|
|
||||||
Attributes []SkuAttribute `json:"attributes"`
|
|
||||||
Specs []SkuSpec `json:"specs"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type SkuAttribute struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Value string `json:"value"`
|
|
||||||
}
|
|
||||||
type SkuSpec struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Value string `json:"value"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// Info @Title 获取详情
|
|
||||||
func (s *sku) Info(ctx context.Context, skuId int64) (reply ReplySkuInfo, err error) {
|
|
||||||
xClient, err := client.GetClient(s)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
err = xClient.Call(ctx, "Info", skuId, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
type ArgsSkuReplaceImg struct {
|
|
||||||
SkuId int64 // 商品id
|
|
||||||
ImgId int64 // 图片id
|
|
||||||
ImgPath string // 图片路径
|
|
||||||
}
|
|
||||||
|
|
||||||
// ReplaceImg @Title 替换图片
|
|
||||||
func (s *sku) ReplaceImg(ctx context.Context, args ArgsSkuReplaceImg) error {
|
|
||||||
reply := 0
|
|
||||||
xClient, err := client.GetClient(s)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return xClient.Call(ctx, "ReplaceImg", args, &reply)
|
|
||||||
}
|
|
||||||
|
|
||||||
type AdoptItem struct {
|
|
||||||
Id int64 `json:"id"`
|
|
||||||
Code string `json:"code"`
|
|
||||||
Name string `json:"name"`
|
|
||||||
Error string `json:"error"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// Adopt @Title 入库
|
|
||||||
func (s *sku) Adopt(ctx context.Context, skuIds []int64) (reply []AdoptItem, err error) {
|
|
||||||
xClient, err := client.GetClient(s)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
err = xClient.Call(ctx, "Adopt", skuIds, &reply)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
// Discard @Title 废弃
|
|
||||||
func (s *sku) Discard(ctx context.Context, skuIds []int64) error {
|
|
||||||
reply := 0
|
|
||||||
xClient, err := client.GetClient(s)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return xClient.Call(ctx, "Discard", skuIds, &reply)
|
|
||||||
}
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
type Skycrane struct {
|
|
||||||
Task task
|
|
||||||
Sku sku
|
|
||||||
Brand brand
|
|
||||||
Category category
|
|
||||||
Address address
|
|
||||||
Callback callback
|
|
||||||
}
|
|
||||||
@ -1,65 +0,0 @@
|
|||||||
package skycrane
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"git.oa00.com/supply-chain/service/client"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
const (
|
|
||||||
TaskStatusIng = 1 // 进行中
|
|
||||||
TaskStatusFinish = 2 // 结束
|
|
||||||
)
|
|
||||||
|
|
||||||
type task struct {
|
|
||||||
}
|
|
||||||
|
|
||||||
// Pull @Title 拉取商品
|
|
||||||
func (t *task) Pull(ctx context.Context) error {
|
|
||||||
a := 0
|
|
||||||
xClient, err := client.GetClient(t)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return xClient.Call(ctx, "Pull", 0, &a)
|
|
||||||
}
|
|
||||||
|
|
||||||
type TaskStatus struct {
|
|
||||||
ScrollId string `json:"scrollId"`
|
|
||||||
Total int64 `json:"total"`
|
|
||||||
Count int64 `json:"count"`
|
|
||||||
Status int `json:"status"` // 1=运行中 2=已完成
|
|
||||||
Msg string `json:"msg"`
|
|
||||||
StartTime time.Time `json:"startTime"`
|
|
||||||
LastTime time.Time `json:"lastTime"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetPullStatus @Title 获取拉取状态
|
|
||||||
func (t *task) GetPullStatus(ctx context.Context) (reply TaskStatus, err error) {
|
|
||||||
xClient, err := client.GetClient(t)
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
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
|
|
||||||
}
|
|
||||||
Loading…
Reference in new issue