| 325 | } |
| 326 | |
| 327 | func CacheGetChannel(id int) (*Channel, error) { |
| 328 | if !common.MemoryCacheEnabled { |
| 329 | return GetChannelById(id, true) |
| 330 | } |
| 331 | channelSyncLock.RLock() |
| 332 | defer channelSyncLock.RUnlock() |
| 333 | |
| 334 | c, ok := channelsIDM[id] |
| 335 | if !ok { |
| 336 | return nil, fmt.Errorf("渠道# %d，已不存在", id) |
| 337 | } |
| 338 | if c.Status != common.ChannelStatusEnabled { |
| 339 | return nil, fmt.Errorf("渠道# %d，已被禁用", id) |
| 340 | } |
| 341 | return c, nil |
| 342 | } |
| 343 | |
| 344 | func CacheGetChannelInfo(id int) (*ChannelInfo, error) { |
| 345 | if !common.MemoryCacheEnabled { |