DeviceService.cs 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. using IMCS.CCS.Repository;
  2. using System.Collections.Generic;
  3. using System.Threading.Tasks;
  4. using IMCS.CCS.Entitys;
  5. using IMCS.CCS.Common.Redis;
  6. using Newtonsoft.Json;
  7. namespace IMCS.CCS.Services
  8. {
  9. public class DeviceService: IDeviceService
  10. {
  11. private IDeviceRepository _repository;
  12. private IRedisService _redisService;
  13. public DeviceService(IDeviceRepository repository, IRedisService redisService) {
  14. _repository = repository;
  15. _redisService = redisService;
  16. }
  17. public List<Device> GetDeviceList()
  18. {
  19. return _repository.GetDeviceList();
  20. }
  21. public List<Device> GetDeviceAllList()
  22. {
  23. return _repository.GetDeviceAllList();
  24. }
  25. public List<Device> GetDevices()
  26. {
  27. return _repository.GetDevices();
  28. }
  29. //查询设备详情
  30. public async Task<Device> GetDeviceById(int id)
  31. {
  32. return await _repository.GetDeviceById(id);
  33. }
  34. //添加设备
  35. public async Task<bool> CreateDevice(Device device)
  36. {
  37. return await _repository.CreateDevice(device);
  38. }
  39. //更新设备
  40. public async Task<bool> UpdateDevice(Device device)
  41. {
  42. return await _repository.UpdateDevice(device);
  43. }
  44. //添加或修改,放入缓存
  45. public async Task<bool> UpdateAndCache(Device vo)
  46. {
  47. await _repository.UpdateDevice(vo);
  48. string callback_redis_key = "IMCS_CCS:DeviceList";
  49. List<Device> devices = _repository.GetDeviceAllList();
  50. await _redisService.Database.StringSetAsync(callback_redis_key, JsonConvert.SerializeObject(devices));
  51. return true;
  52. }
  53. }
  54. }