DeviceMessages endpoint

src/WorkFlowCheck.API/Controllers/SyncController.cs

@@ -1,5 +1,6 @@
 using Microsoft.AspNetCore.Mvc;
 using Serilog;
+using System.Text;
 using WorkFlowCheck.BL.Services;
 using WorkFlowCheck.BL.Services.Interfaces;
 using WorkFlowCheck.Common.DTO;
@@ -410,6 +411,56 @@ namespace WorkFlowCheck.API.Controllers
             return retVal;
         }
 
+        
+        [HttpPost("DeviceMessageSend")]
+        public async Task<ApiResponseDTO<bool>> DeviceMessageSend([FromBody] DeviceMessageDTO deviceMessageDTO)
+        {
+            var retVal = new ApiResponseDTO<bool>()
+            {
+                IsSuccess = true
+            };
 
+            try
+            {
+                var result = await _syncService.DeviceMessageSend(deviceMessageDTO);
+                retVal.Data = true;
+            }
+            catch (Exception ex)
+            {
+                retVal.IsSuccess = false;
+                retVal.Errors.Add(ex.Message);
+                Log.Error(ex.Message);
+            }
+            return retVal;
+        }
+
+        [HttpGet("DeviceMessageReadUnreaded/{deviceIdBase64}")]
+        public async Task<ApiResponseDTO<List<DeviceMessageDTO>>> DeviceMessageReadUnreaded(string deviceIdBase64)
+        {
+            var retVal = new ApiResponseDTO<List<DeviceMessageDTO>>()
+            {
+                IsSuccess = true,
+            };
+
+            byte[] byteArray = Convert.FromBase64String(deviceIdBase64);
+            string deviceId = Encoding.UTF8.GetString(byteArray);
+
+
+            var response = await _syncService.DeviceMessageReadUnreaded(deviceId);
+
+            if (response != null)
+            {
+
+                retVal.IsSuccess = true;
+                retVal.Data = response;
+            }
+            else
+            {
+                retVal.IsSuccess = false;
+                retVal.Errors.Add("No data!");
+            }
+
+            return retVal;
+        }
     }
 }