diff --git a/business/model/dao/store_sku.go b/business/model/dao/store_sku.go
index e04c7b799..206d74a82 100644
--- a/business/model/dao/store_sku.go
+++ b/business/model/dao/store_sku.go
@@ -797,7 +797,6 @@ func GetStoreSkuPriceAndWeight(db *DaoDB, vendorStoreID string, vendorID int, ve
 
 // 这个函数之前是要设置没有删除或同步标志不为0的，会导致将同步标志不为0且删除了的把标志去掉，现在改为只设置没有删除的
 func SetStoreSkuSyncStatus(db *DaoDB, vendorID int, storeIDs []int, skuIDs []int, syncStatus int) (num int64, err error) {
-	globals.SugarLogger.Debugf("============3")
 	isSingleStorePF := model.MultiStoresVendorMap[vendorID] != 1
 	fieldPrefix := ConvertDBFieldPrefix(model.VendorNames[vendorID])
 	sql := `
diff --git a/business/partner/purchase/tiktok_store/store_sku2_utils.go b/business/partner/purchase/tiktok_store/store_sku2_utils.go
index 9049c6027..87f80c8a2 100644
--- a/business/partner/purchase/tiktok_store/store_sku2_utils.go
+++ b/business/partner/purchase/tiktok_store/store_sku2_utils.go
@@ -125,6 +125,10 @@ func (p *PurchaseHandler) createOrUpdateStoreSkus(ctx *jxcontext.Context, storeI
 	if isCreate {
 		syncType = "创建商品"
 		for _, storeSku := range storeSkuList { // 创建商品
+			// 如果当前商品,主商品id,子商品id都已经存在了,就不在创建了,主要防止,后期更新时,某些商品为创建成功,批量修改数据库再去批量创建报错(商品已创建)
+			if storeSku.VendorMainId != "" && storeSku.VendorSkuID != "" && len(storeSku.VendorSkuID) == 19 {
+				continue
+			}
 			param := &product_addV2_request.ProductAddV2Param{
 				Name:             utils.LimitUTF8StringLen(storeSku.SkuName, mtwmapi.MaxSkuNameCharCount),
 				PayType:          tiktokShop.TiktokPayType1,
@@ -385,6 +389,7 @@ func (p *PurchaseHandler) createOrUpdateStoreSkus(ctx *jxcontext.Context, storeI
 			// 创建子商品
 			//param.FreightId = freightId
 			param.ProductId = utils.Str2Int64(storeSku.VendorSkuID)
+			param.MainProductId = utils.Str2Int64(storeSku.VendorMainId)
 			//param.SpecPrices = GetSpecPrices(param.Specs, vendorStoreID, tiktokResult.ProductId, storeSku)
 			// 获取门店限售模板
 			//saleLimitId, err := CreateSaleTemp(utils.Str2Int64(vendorStoreID), api)