用户操作推系统通知功能开发

ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/annotations/aspect/OperationNotificationAspect.java → ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/annotations/OperationNotificationAspect.java

@@ -1,9 +1,8 @@
-package com.ruoyi.platform.annotations.aspect;
+package com.ruoyi.platform.annotations;
 
 import cn.hutool.core.collection.CollectionUtil;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.security.utils.SecurityUtils;
-import com.ruoyi.platform.annotations.OperationNotification;
 import com.ruoyi.system.api.RemoteAuthService;
 import com.ruoyi.system.api.RemoteInfoPublishService;
 import com.ruoyi.system.api.domain.NewSysNotificationParamsVo;
@@ -128,7 +127,7 @@ public class OperationNotificationAspect {
         newSysNotificationParamsVo.setReceivers(receiver);
         newSysNotificationParamsVo.setContent(content);
 
-//        infoPublishService.pushSysInfo(newSysNotificationParamsVo);
+        infoPublishService.pushSysInfo(newSysNotificationParamsVo);
     }
 
     /**

ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/dataset/NewDatasetFromGitController.java

@@ -3,18 +3,16 @@ package com.ruoyi.platform.controller.dataset;
 import cn.hutool.core.collection.CollectionUtil;
 import com.ruoyi.common.core.web.domain.AjaxResult;
 import com.ruoyi.common.security.utils.SecurityUtils;
-import com.ruoyi.platform.annotations.OperationNotification;
 import com.ruoyi.platform.domain.Dataset;
 import com.ruoyi.platform.service.NewDatasetService;
 import com.ruoyi.platform.utils.DVCUtils;
 import com.ruoyi.platform.vo.LabelDatasetVersionVo;
 import com.ruoyi.platform.vo.NewDatasetVo;
 import com.ruoyi.platform.vo.QueryModelMetricsVo;
+import com.ruoyi.platform.annotations.OperationNotification;
 import com.ruoyi.system.api.model.LoginUser;
 import io.swagger.annotations.ApiOperation;
-import org.springframework.core.io.InputStreamResource;
 import org.springframework.data.domain.PageRequest;
-import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 

ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/workflow/WorkflowController.java

@@ -5,6 +5,7 @@ import com.ruoyi.common.core.web.domain.GenericsAjaxResult;
 import com.ruoyi.platform.domain.Workflow;
 import com.ruoyi.platform.service.WorkflowService;
 import com.ruoyi.platform.vo.WorkflowVo;
+import com.ruoyi.platform.annotations.OperationNotification;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.data.domain.Page;
@@ -78,6 +79,7 @@ public class WorkflowController extends BaseController {
      */
     @PostMapping
     @ApiOperation("新增流水线")
+    @OperationNotification(type = "INSERT",content = "添加流水线:#{#workflow.name}",param = "workflow")
     public GenericsAjaxResult<Workflow> add(@RequestBody Workflow workflow) throws Exception {
         return genericsSuccess(this.workflowService.insert(workflow));
     }