From a069a12647ab551281091efb0f066163d1c8c156 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期一, 02 六月 2025 17:36:30 +0800
Subject: [PATCH] 首页待办事项

---
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java |   39 ++++++++++++++++++++++++++++++++++++++-
 1 files changed, 38 insertions(+), 1 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java
index fef862b..9fac33e 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TExperimentSchemeController.java
@@ -52,8 +52,10 @@
     private final TProjectProposalService projectProposalService;
     private final TExperimentDispatchGroupService experimentDispatchGroupService;
     private final TProjectTeamStaffService projectTeamStaffService;
+    private final TProjectTeamService projectTeamService;
+    private final TNoticeService noticeService;
     @Autowired
-    public TExperimentSchemeController(TExperimentSchemeService experimentSchemeService, TokenService tokenService, ISysUserService sysUserService, SysUserMapper sysUserMapper, TExperimentSchemePersonService experimentSchemePersonService, TExperimentDispatchParticipantsService experimentDispatchParticipantsService, TExperimentDispatchService experimentDispatchService, TProjectProposalService projectProposalService, TExperimentDispatchGroupService experimentDispatchGroupService, TProjectTeamStaffService projectTeamStaffService) {
+    public TExperimentSchemeController(TExperimentSchemeService experimentSchemeService, TokenService tokenService, ISysUserService sysUserService, SysUserMapper sysUserMapper, TExperimentSchemePersonService experimentSchemePersonService, TExperimentDispatchParticipantsService experimentDispatchParticipantsService, TExperimentDispatchService experimentDispatchService, TProjectProposalService projectProposalService, TExperimentDispatchGroupService experimentDispatchGroupService, TProjectTeamStaffService projectTeamStaffService, TProjectTeamService projectTeamService, TNoticeService noticeService) {
         this.experimentSchemeService = experimentSchemeService;
         this.tokenService = tokenService;
         this.sysUserService = sysUserService;
@@ -64,6 +66,8 @@
         this.projectProposalService = projectProposalService;
         this.experimentDispatchGroupService = experimentDispatchGroupService;
         this.projectTeamStaffService = projectTeamStaffService;
+        this.projectTeamService = projectTeamService;
+        this.noticeService = noticeService;
     }
 
     /**
@@ -214,6 +218,23 @@
         TExperimentSchemeDTO dto = JSON.parseObject(param,TExperimentSchemeDTO.class);
         dto.setStatus(6);
         experimentSchemeService.updateById(dto);
+
+        // 通过当前用户查询项目组
+        Long userId = tokenService.getLoginUser().getUserId();
+        TProjectTeamStaff projectTeamStaff = projectTeamStaffService.getOne(Wrappers.lambdaQuery(TProjectTeamStaff.class)
+                .eq(TProjectTeamStaff::getUserId, userId)
+                .last("LIMIT 1"));
+        // 查询项目组
+        TProjectTeam projectTeam = projectTeamService.getById(projectTeamStaff.getTeamId());
+        // MESSAGE 添加消息
+        TProjectTeamStaff teamStaff = projectTeamStaffService.getOne(Wrappers.lambdaQuery(TProjectTeamStaff.class)
+                .eq(TProjectTeamStaff::getTeamId, projectTeam.getId())
+                .eq(TProjectTeamStaff::getRoleType, 3)
+                .last("LIMIT 1"));
+        if(Objects.nonNull(teamStaff)){
+            noticeService.saveNotice(teamStaff.getUserId(), "实验员已提交实验方案,请查收!", tokenService.getLoginUser().getUser().getNickName(),8);
+        }
+
         return R.ok();
     }
 
@@ -309,6 +330,22 @@
                 .set(TExperimentScheme::getStopFile, applicationTerminationDTO.getStopFile())
                 .set(TExperimentScheme::getStopFileName, applicationTerminationDTO.getStopFileName())
                 .set(TExperimentScheme::getCommitSign, applicationTerminationDTO.getCommitSign()));
+        // 通过当前用户查询项目组
+        Long userId = tokenService.getLoginUser().getUserId();
+        TProjectTeamStaff projectTeamStaff = projectTeamStaffService.getOne(Wrappers.lambdaQuery(TProjectTeamStaff.class)
+                .eq(TProjectTeamStaff::getUserId, userId)
+                .last("LIMIT 1"));
+        // 查询项目组
+        TProjectTeam projectTeam = projectTeamService.getById(projectTeamStaff.getTeamId());
+        // MESSAGE 添加消息
+        TProjectTeamStaff teamStaff = projectTeamStaffService.getOne(Wrappers.lambdaQuery(TProjectTeamStaff.class)
+                .eq(TProjectTeamStaff::getTeamId, projectTeam.getId())
+                .eq(TProjectTeamStaff::getRoleType, 2)
+                .last("LIMIT 1"));
+        if(Objects.nonNull(teamStaff)){
+            noticeService.saveNotice(teamStaff.getUserId(), "您有【1】条【实验方案中止申请】等待审批", tokenService.getLoginUser().getUser().getNickName(),2);
+        }
+
         return R.ok();
     }
 

--
Gitblit v1.7.1