diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go index 84cfdb786..2a90dcb99 100644 --- a/business/jxstore/cms/store_sku.go +++ b/business/jxstore/cms/store_sku.go @@ -4345,9 +4345,19 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool) for _, v := range addMatters { var ( skuName *model.SkuName + skuNames []*model.SkuName storeSkus []*model.StoreSkuBind ) - skuNames, _ := dao.GetSkuNames(db, []int{v.NameID}, nil, "", false) + sql := ` + SELECT * + FROM jxd_dev_0.sku_name t1 + LEFT JOIN jxd_dev_0.sku t2 ON t2.name_id = t1.id + WHERE t1.deleted_at = ? + AND t1.id = ? + AND t2.exd_sku_id <> '' + ` + sqlParams := []interface{}{utils.DefaultTimeValue, v.NameID} + err = dao.GetRows(db, &skuNames, sql, sqlParams) if len(skuNames) > 0 { skuName = skuNames[0] } @@ -4377,9 +4387,9 @@ func SyncMatterC4ToGy(ctx *jxcontext.Context, isContinueWhenError, isAsync bool) if err != nil { return retVal, err } - sql := "SELECT * FROM jxd_dev_0.store_sku_bind WHERE store_id = ? AND sku_id = ? " - sqlParams := []interface{}{model.MatterStoreID, v.ID} - err = dao.GetRows(db, &storeSkus, sql, sqlParams) + sql = "SELECT * FROM jxd_dev_0.store_sku_bind WHERE store_id = ? AND sku_id = ? " + sqlParams2 := []interface{}{model.MatterStoreID, v.ID} + err = dao.GetRows(db, &storeSkus, sql, sqlParams2) if err != nil { return retVal, err }