From 78cbee52846249f97df5ed613a012348da6deef5 Mon Sep 17 00:00:00 2001 From: gazebo Date: Fri, 29 Mar 2019 17:13:14 +0800 Subject: [PATCH] - addVendorInfo2Err --- business/jxstore/cms/sync.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index a7fa532f7..7b98f21ae 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -235,6 +235,7 @@ func (v *VendorSync) SyncStore(ctx *jxcontext.Context, db *dao.DaoDB, vendorID, storeMap.SyncStatus = 0 _, err = dao.UpdateEntity(db, storeMap, model.FieldSyncStatus) } + err = addVendorInfo2Err(err, loopMapInfo.VendorID) return nil, err }) return hint, err @@ -345,6 +346,7 @@ func (v *VendorSync) SyncStoresCategory(ctx *jxcontext.Context, db *dao.DaoDB, v return nil, err } _, err = handler.SyncStoreCategory(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false) + err = addVendorInfo2Err(err, loopMapInfo.VendorID) } return nil, err }) @@ -375,6 +377,7 @@ func (v *VendorSync) SyncStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, vendo return nil, err } _, err = handler.SyncStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, skuIDs, false, isContinueWhenError) + err = addVendorInfo2Err(err, loopMapInfo.VendorID) } return nil, err }) @@ -398,6 +401,7 @@ func (v *VendorSync) FullSyncStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, v return nil, err } _, err = handler.FullSyncStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false, isContinueWhenError) + err = addVendorInfo2Err(err, loopMapInfo.VendorID) } return nil, err }) @@ -421,6 +425,7 @@ func (v *VendorSync) DeleteRemoteStoreSkus(ctx *jxcontext.Context, db *dao.DaoDB return nil, err } _, err = handler.DeleteRemoteStoreSkus(ctx, t, loopMapInfo.StoreMapList[0].StoreID, false, isContinueWhenError) + err = addVendorInfo2Err(err, loopMapInfo.VendorID) } return nil, err }) @@ -538,3 +543,10 @@ func isSyncError(err error) bool { _, ok := err.(*SyncError) 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 +}