qlhb/Ropin.Environmentally.LedgeService1/Subscribe/RedisSubscribeBoxno.cs

using FBoxClientDriver.Contract;
using InitQ.Abstractions;
using InitQ.Attributes;
using InitQ.Cache;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace Ropin.Environmentally.LedgeService1.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<DataMonitorValueChangedArgs> value = JsonConvert.DeserializeObject<IList<DataMonitorValueChangedArgs>>(monitorValueChangedData);   


        }
    }
}