12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970 |
- using WCS.Repository;
- using System.Collections.Generic;
- using System.Threading.Tasks;
- using WCS.Entitys;
- using Newtonsoft.Json;
- using WCS.Model;
- using StackExchange.Redis;
- namespace WCS.Services
- {
- public class DeviceService: IDeviceService
- {
- private readonly IDeviceRepository _repository;
- private readonly IConnectionMultiplexer _redis;
- public DeviceService(IDeviceRepository repository, IConnectionMultiplexer redis) {
- _repository = repository;
- _redis = redis;
- }
- //所有使用的设备
- public List<WcsDevice> GetDeviceList()
- {
- return _repository.GetDeviceList();
- }
- //所有使用的设备
- public List<WcsDevice> GetDeviceAllList()
- {
- return _repository.GetDeviceAllList();
- }
- public List<WcsDevice> GetDevices()
- {
- return _repository.GetDevices();
- }
- //查询设备详情
- public async Task<WcsDevice> GetDeviceById(int id)
- {
- return await _repository.GetDeviceById(id);
- }
- //添加设备
- public async Task<bool> CreateDevice(WcsDevice device)
- {
- return await _repository.CreateDevice(device);
- }
- //更新设备
- public async Task<bool> UpdateDevice(WcsDevice device)
- {
- return await _repository.UpdateDevice(device);
- }
- //添加或修改,放入缓存
- public async Task<bool> UpdateAndCache(WcsDevice vo)
- {
- await _repository.UpdateDevice(vo);
-
- //所有使用的设备
- List<WcsDevice> allUseDevices = _repository.GetDeviceAllList();
- await _redis.GetDatabase().StringSetAsync("WCS:" + RedisKeyEnum.ALLUseDeviceList, JsonConvert.SerializeObject(allUseDevices));
- //所有的设备
- List<WcsDevice> allDevices = _repository.GetDevices();
- await _redis.GetDatabase().StringSetAsync("WCS:" + RedisKeyEnum.ALLDeviceList, JsonConvert.SerializeObject(allDevices));
- return true;
- }
- }
- }
|