更新银豹未关注的sku的ybid等

business/jxstore/cms/sync_store_sku.go

@@ -325,10 +325,20 @@ func updateStoreSku(db *dao.DaoDB, vendorID int, storeSkuList []*dao.StoreSkuSyn
 			updateItemList[k] = sku2Update(vendorID, v, syncStatus)
 		}
 		num, err = dao.BatchUpdateEntityByKV(db, updateItemList)
+		if vendorID == model.VendorIDYB {
+			err = updateYbOhterSku(db, storeSkuList)
+		}
 	}
 	return num, err
 }
 
+func updateYbOhterSku(db *dao.DaoDB, storeSkuList []*dao.StoreSkuSyncInfo) (err error) {
+	for _, v := range storeSkuList {
+		err = dao.UpdateYbOtherSku(db, v)
+	}
+	return err
+}
+
 func isSkuLockTimeValid(sku *dao.StoreSkuSyncInfo) bool {
 	return sku.LockTime != nil && time.Now().Sub(*sku.LockTime) < 0
 }

business/model/dao/store_sku.go

@@ -1478,3 +1478,22 @@ func GetStoreSkusAndSkuName(db *DaoDB, storeIDs, skuIDs, nameIDs []int) (storeSk
 	err = GetRows(db, &storeSkuAndName, sql, sqlParams...)
 	return storeSkuAndName, err
 }
+
+func UpdateYbOtherSku(db *DaoDB, storeSkuSyncInfo *StoreSkuSyncInfo) (err error) {
+	sql := `
+		UPDATE store_sku_bind a
+		JOIN sku b ON a.sku_id = b.id AND b.name_id = ?
+		JOIN (SELECT * FROM store_sku_bind WHERE sku_id = ?)c ON c.store_id = a.store_id
+		SET a.yb_id = c.yb_id,a.yb_sync_status = c.yb_sync_status,a.yb_price = c.yb_price
+		WHERE a.store_id = ?
+		AND a.yb_sync_status <> ?  
+	`
+	sqlParams := []interface{}{
+		storeSkuSyncInfo.NameID,
+		storeSkuSyncInfo.SkuID,
+		storeSkuSyncInfo.StoreID,
+		0,
+	}
+	_, err = ExecuteSQL(db, sql, sqlParams)
+	return err
+}