DeviceMessages-hez backend fejlesztése

src/WorkFlowCheck.BL/Services/Interfaces/ISyncService.cs

@@ -32,7 +32,8 @@ namespace WorkFlowCheck.BL.Services.Interfaces
 
         Task<bool> DeviceMessageSend(DeviceMessageDTO deviceMessageDTO);
         Task<List<DeviceMessageDTO>> DeviceMessageReadUnreaded(string deviceId);
+        Task<List<DeviceMessageDTO>> DeviceMessageReadUnreadedRole(int roleId);
+
 
-       
     }
 }

src/WorkFlowCheck.BL/Services/SyncService.cs

@@ -553,5 +553,31 @@ namespace WorkFlowCheck.BL.Services
             }
             return retVal;
         }
+        public async Task<List<DeviceMessageDTO>> DeviceMessageReadUnreadedRole(int roleId)
+        {
+            var retVal = new List<DeviceMessageDTO>();
+            try
+            {
+                var res = await _dbContext.DeviceMessages
+                                    .Where(w => w.RoleId == roleId && w.IsReaded != true)
+                                    .ToListAsync();
+
+                if (res != null)
+                {
+                    retVal = _mapper.Map<List<DeviceMessageDTO>>(res);
+                    foreach (var deviceMessage in res)
+                    {
+                        deviceMessage.IsReaded = true;
+                        deviceMessage.ReceiveDate = DateTime.UtcNow;
+                    }
+                    await _dbContext.SaveChangesAsync();
+                }
+            }
+            catch (Exception ex)
+            {
+                Log.Error(ex.Message);
+            }
+            return retVal;
+        }
     }
 }

src/WorkFlowCheck.BL/Services/UserService.cs

@@ -93,6 +93,7 @@ namespace WorkFlowCheck.BL.Services
 
             try
             {
+                Log.ForContext("TAG", "AuditFlow").Information($"Bejelentkezési kísérlet: {userName}");
                 var user = await _dbContext.Users
                     .Include(i => i.UserRoles)
                     .ThenInclude(i => i.Role)
@@ -116,9 +117,13 @@ namespace WorkFlowCheck.BL.Services
                     }
                     user.JwtToken = GenerateJwtToken(userDTO);
                     await _dbContext.SaveChangesAsync();
-
+                    Log.ForContext("TAG", "AuditFlow").Information($"Sikeres bejelentkezés: {userName}");
                     retVal = _mapper.Map<UserDTO>(user);
                 }
+                else
+                {
+                    Log.ForContext("TAG", "AuditFlow").Error($"Sikertelen bejelenkezési kísérlet: {userName}");
+                }
             }
             catch (Exception ex)
             {