liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- force ignore DeleteRemoteSkus error in ebai.FullSyncStoreSkus

Browse Source
This commit is contained in:
gazebo
2019-01-16 11:45:33 +08:00
parent ec31b69982
commit 8d267069b0
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/model/store_sku.go
View File

@@ -43,11 +43,11 @@ type StoreSkuCategoryMap struct {
ElmID int64 `orm:"column(elm_id);index"` ElmID int64 `orm:"column(elm_id);index"`
EbaiID int64 `orm:"column(ebai_id);index"` EbaiID int64 `orm:"column(ebai_id);index"`
MtwmID string `orm:"column(mtwm_id);size(16)"` // 美团外卖没有ID，保存名字 MtwmID string `orm:"column(mtwm_id);index;size(16)"` // 美团外卖没有ID，保存名字
ElmSyncStatus int8 ElmSyncStatus int8 `orm:"default(2)"`
EbaiSyncStatus int8 EbaiSyncStatus int8 `orm:"default(2)"`
MtwmSyncStatus int8 MtwmSyncStatus int8 `orm:"default(2)"`
} }
func (*StoreSkuCategoryMap) TableUnique() [][]string { func (*StoreSkuCategoryMap) TableUnique() [][]string {

4
business/partner/purchase/ebai/store_sku.go
View File

@@ -149,6 +149,10 @@ func (p *PurchaseHandler) FullSyncStoreSkus(ctx *jxcontext.Context, parentTask t
switch step { switch step {
case 0: case 0:
err = p.DeleteRemoteSkus(ctx, rootTask, storeID, nil) err = p.DeleteRemoteSkus(ctx, rootTask, storeID, nil)
// 强制忽略删除SKU错误
if isContinueWhenError {
err = nil
}
case 1: case 1:
_, err = p.setStoreSkuSyncStatus(ctx, db, storeID, nil, model.SyncFlagNewMask) _, err = p.setStoreSkuSyncStatus(ctx, db, storeID, nil, model.SyncFlagNewMask)
case 2: case 2: