增加与ai大模型对话

huimv-employment/fe-api/src/main/java/com/huimv/employment/controller/mp/NotificationController.java

@@ -4,22 +4,25 @@ import com.huimv.employment.common.web.R;
 import com.huimv.employment.security.LoginUserHolder;
 import com.huimv.employment.service.notification.NotificationService;
 import com.huimv.employment.service.notification.dto.NotificationPageResponse;
+import com.huimv.employment.service.notification.dto.NotificationReadResponse;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.enums.ParameterIn;
 import io.swagger.v3.oas.annotations.security.SecurityRequirement;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
- * 消息与待办中心：当前登录用户查询本人通知。
+ * 消息与待办中心：当前登录用户查询、标记已读。
  */
 @RestController
 @RequestMapping("/api/v1/mp/notifications")
-@Tag(name = "消息与待办", description = "查询当前用户消息与待办")
+@Tag(name = "消息与待办", description = "查询当前用户消息与待办，标记已读")
 @SecurityRequirement(name = "Authorization")
 public class NotificationController {
 
@@ -51,4 +54,15 @@ public class NotificationController {
         Long userId = LoginUserHolder.require().getUserId();
         return R.ok(notificationService.listByUser(userId, notifyType, category, readFlag, handledFlag, page, size));
     }
+
+    @PostMapping("/{id}/read")
+    @Operation(summary = "标记消息已读",
+            description = "将当前用户名下指定消息的 read_flag 置为 true，并写入 read_time；已读则幂等返回。"
+                    + "同时返回最新 unread_count。")
+    public R<NotificationReadResponse> markRead(
+            @Parameter(name = "id", in = ParameterIn.PATH, description = "消息 ID", required = true)
+            @PathVariable("id") Long id) {
+        Long userId = LoginUserHolder.require().getUserId();
+        return R.ok(notificationService.markRead(userId, id));
+    }
 }

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/notification/NotificationService.java

@@ -2,12 +2,15 @@ package com.huimv.employment.service.notification;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huimv.employment.common.exception.BizException;
+import com.huimv.employment.common.exception.ErrorCode;
 import com.huimv.employment.dao.entity.FeEmploymentOrder;
 import com.huimv.employment.dao.entity.FeNotification;
 import com.huimv.employment.dao.entity.FeSettlementOrder;
 import com.huimv.employment.dao.mapper.FeNotificationMapper;
 import com.huimv.employment.service.notification.dto.NotificationItemResponse;
 import com.huimv.employment.service.notification.dto.NotificationPageResponse;
+import com.huimv.employment.service.notification.dto.NotificationReadResponse;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -98,6 +101,42 @@ public class NotificationService {
         return response;
     }
 
+    /**
+     * 标记消息已读：更新 {@code read_flag=true}、{@code read_time}（幂等）。
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public NotificationReadResponse markRead(Long userId, Long notificationId) {
+        if (userId == null) {
+            throw new BizException(ErrorCode.UNAUTHORIZED, "请先登录");
+        }
+        if (notificationId == null) {
+            throw new BizException(ErrorCode.BAD_REQUEST, "消息 ID 不能为空");
+        }
+        FeNotification existing = feNotificationMapper.selectById(notificationId);
+        if (existing == null) {
+            throw new BizException(ErrorCode.NOT_FOUND, "消息不存在");
+        }
+        if (existing.getUserId() == null || !userId.equals(existing.getUserId())) {
+            throw new BizException(ErrorCode.FORBIDDEN, "无权操作该消息");
+        }
+
+        if (!Boolean.TRUE.equals(existing.getReadFlag())) {
+            LocalDateTime now = LocalDateTime.now();
+            FeNotification update = new FeNotification();
+            update.setId(existing.getId());
+            update.setReadFlag(Boolean.TRUE);
+            update.setReadTime(now);
+            feNotificationMapper.updateById(update);
+            existing.setReadFlag(Boolean.TRUE);
+            existing.setReadTime(now);
+        }
+
+        NotificationReadResponse response = new NotificationReadResponse();
+        response.setItem(toItem(existing));
+        response.setUnreadCount(countUnread(userId));
+        return response;
+    }
+
     private long countUnread(Long userId) {
         Long count = feNotificationMapper.selectCount(new LambdaQueryWrapper<FeNotification>()
                 .eq(FeNotification::getUserId, userId)

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/notification/dto/NotificationReadResponse.java

@@ -0,0 +1,31 @@
+package com.huimv.employment.service.notification.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(description = "消息已读结果")
+public class NotificationReadResponse {
+
+    @Schema(description = "已读后的消息详情")
+    private NotificationItemResponse item;
+
+    @JsonProperty("unread_count")
+    @Schema(description = "当前用户未读消息数")
+    private Long unreadCount;
+
+    public NotificationItemResponse getItem() {
+        return item;
+    }
+
+    public void setItem(NotificationItemResponse item) {
+        this.item = item;
+    }
+
+    public Long getUnreadCount() {
+        return unreadCount;
+    }
+
+    public void setUnreadCount(Long unreadCount) {
+        this.unreadCount = unreadCount;
+    }
+}