diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go
index 667ce646b..e087db5ba 100644
--- a/business/jxstore/cms/sync_store_sku.go
+++ b/business/jxstore/cms/sync_store_sku.go
@@ -585,14 +585,8 @@ func AddCreateFlagForJxStoreSku(ctx *jxcontext.Context, parentTask tasksch.ITask
 				storeSkuList, err := dao.GetStoresSkusInfo(db, []int{storeID}, skuIDList)
 				if err == nil {
 					for _, skuBind := range storeSkuList {
-						if vendorID == model.VendorIDMTWM {
-							skuBind.MtwmSyncStatus |= model.SyncFlagNewMask
-						} else if vendorID == model.VendorIDEBAI {
-							skuBind.EbaiSyncStatus |= model.SyncFlagNewMask
-						} else if vendorID == model.VendorIDJD {
-							skuBind.JdSyncStatus |= model.SyncFlagNewMask
-						}
-						dao.UpdateEntity(db, skuBind)
+						fieldStatus := dao.GetSyncStatusStructField(model.VendorNames[vendorID])
+						dao.UpdateEntityLogicallyAndUpdateSyncStatus(db, skuBind, nil, ctx.GetUserName(), nil, fieldStatus, model.SyncFlagNewMask)
 					}
 				}
 			}