diff --git a/business/partner/purchase/ebai/store_sku.go b/business/partner/purchase/ebai/store_sku.go
index be48e933e..b812e05bd 100644
--- a/business/partner/purchase/ebai/store_sku.go
+++ b/business/partner/purchase/ebai/store_sku.go
@@ -155,7 +155,9 @@ func (p *PurchaseHandler) FullSyncStoreSkus(ctx *jxcontext.Context, parentTask t
 		case 1:
 			_, err = p.setStoreSkuSyncStatus(ctx, db, storeID, nil, model.SyncFlagNewMask)
 		case 2:
-			err = p.DeleteRemoteCategories(ctx, rootTask, storeID, nil)
+			if err = p.DeleteRemoteCategories(ctx, rootTask, storeID, nil); err == nil {
+				_, err = dao.SetStoreCategorySyncStatus(db, model.VendorIDEBAI, storeID, nil, model.SyncFlagNewMask)
+			}
 		case 3:
 			err = p.SyncLocalStoreCategory(db, storeID, userName)
 		case 4:
@@ -190,7 +192,9 @@ func (p *PurchaseHandler) DeleteRemoteStoreSkus(ctx *jxcontext.Context, parentTa
 		case 1:
 			_, err = p.setStoreSkuSyncStatus(ctx, db, storeID, nil, model.SyncFlagNewMask)
 		case 2:
-			err = p.DeleteRemoteCategories(ctx, rootTask, storeID, nil)
+			if err = p.DeleteRemoteCategories(ctx, rootTask, storeID, nil); err == nil {
+				_, err = dao.SetStoreCategorySyncStatus(db, model.VendorIDEBAI, storeID, nil, model.SyncFlagNewMask)
+			}
 		}
 		return nil, err
 	}, 3)
diff --git a/business/partner/purchase/mtwm/store_sku.go b/business/partner/purchase/mtwm/store_sku.go
index dd4616b9d..e0051f2c8 100644
--- a/business/partner/purchase/mtwm/store_sku.go
+++ b/business/partner/purchase/mtwm/store_sku.go
@@ -303,7 +303,9 @@ func (p *PurchaseHandler) FullSyncStoreSkus(ctx *jxcontext.Context, parentTask t
 	rootTask := tasksch.NewSeqTask("美团外卖FullSyncStoreSkus", userName, func(rootTask *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
 		switch step {
 		case 0:
-			err = p.DeleteRemoteSkus(ctx, rootTask, storeID, nil)
+			if err = p.DeleteRemoteSkus(ctx, rootTask, storeID, nil); err == nil {
+				_, err = dao.SetStoreCategorySyncStatus(db, model.VendorIDMTWM, storeID, nil, model.SyncFlagNewMask)
+			}
 		case 1:
 			_, err = dao.SetStoreSkuSyncStatus(db, model.VendorIDMTWM, storeID, nil, model.SyncFlagNewMask)
 		case 2: