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

- addVendorInfo2Err

Browse Source
This commit is contained in:
gazebo
2019-03-29 17:13:14 +08:00
parent 834a1f2206
commit 78cbee5284
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
business/jxstore/cms/sync.go
View File

@@ -235,6 +235,7 @@ func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID,
storeMap.SyncStatus = 0 storeMap.SyncStatus = 0
_, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus) _, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus)
} }
err = addVendorInfo2Err(err, loopMapInfo.VendorID)
return nil, err return nil, err
}) })
return hint, err return hint, err
@@ -345,6 +346,7 @@ func (v *VendorSync) SyncStoresCategory(ctx *jxcontext.Context, db *dao.DaoDB, v
return nil, err return nil, err
} }
_, err = handler.SyncStoreCategory(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false) _, err = handler.SyncStoreCategory(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false)
err = addVendorInfo2Err(err, loopMapInfo.VendorID)
} }
return nil, err return nil, err
}) })
@@ -375,6 +377,7 @@ func (v *VendorSync) SyncStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, vendo
return nil, err return nil, err
} }
_, err = handler.SyncStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, skuIDs, false, isContinueWhenError) _, err = handler.SyncStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, skuIDs, false, isContinueWhenError)
err = addVendorInfo2Err(err, loopMapInfo.VendorID)
} }
return nil, err return nil, err
}) })
@@ -398,6 +401,7 @@ func (v *VendorSync) FullSyncStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, v
return nil, err return nil, err
} }
_, err = handler.FullSyncStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false, isContinueWhenError) _, err = handler.FullSyncStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false, isContinueWhenError)
err = addVendorInfo2Err(err, loopMapInfo.VendorID)
} }
return nil, err return nil, err
}) })
@@ -421,6 +425,7 @@ func (v *VendorSync) DeleteRemoteStoreSkus(ctx *jxcontext.Context, db *dao.DaoDB
return nil, err return nil, err
} }
_, err = handler.DeleteRemoteStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false, isContinueWhenError) _, err = handler.DeleteRemoteStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false, isContinueWhenError)
err = addVendorInfo2Err(err, loopMapInfo.VendorID)
} }
return nil, err return nil, err
}) })
@@ -538,3 +543,10 @@ func isSyncError(err error) bool {
_, ok := err.(*SyncError) _, ok := err.(*SyncError)
return ok return ok
} }
func addVendorInfo2Err(inErr error, vendorID int) (outErr error) {
if inErr != nil {
outErr = fmt.Errorf("处理平台%s, %s", inErr.Error(), model.VendorChineseNames[vendorID])
}
return outErr
}