using System.Collections.Generic; using System.Threading.Tasks; using System; using InitQ.Abstractions; using InitQ.Cache; using InitQ.Attributes; using Newtonsoft.Json; using FBoxClientDriver.Contract; namespace Ropin.Environmentally.DcsService.Subscribe { public class RedisSubscribeBoxno : IRedisSubscribe { private readonly ICacheService _redisService; public RedisSubscribeBoxno(ICacheService redisService) { _redisService = redisService; } [Subscribe("fanyibox")] private async Task SubRedis(string monitorValueChangedData) { await _redisService.IncrementAsync("fanyibox_count", TimeSpan.FromDays(365)); IList value = JsonConvert.DeserializeObject>(monitorValueChangedData); } } }