From 07654e28654f4b4db03e8b11273362fee758179b Mon Sep 17 00:00:00 2001
From: even <827656971@qq.com>
Date: Wed, 30 Apr 2025 15:27:12 +0800
Subject: [PATCH] =?UTF-8?q?service=EF=BC=88=E6=B7=BB=E5=8A=A0ws=E4=BE=9D?=
=?UTF-8?q?=E8=B5=96=EF=BC=89=20=E8=BF=81=E7=A7=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
modules/module-ci-process-biz/pom.xml | 5 +
.../impl/PipelineYamlServiceImpl.java | 1291 +++++++++--------
.../service/impl/PipelineExecServiceImpl.java | 725 ++++-----
.../task/artifact/model/TaskArtifact.java | 64 +
.../task/artifact/model/XpackRepository.java | 16 +
.../artifact/model/XpackRepositoryQuery.java | 27 +
.../service/TaskArtifactXpackService.java | 28 +
.../process/task/build/model/TaskBuild.java | 52 +
.../process/task/code/model/TaskCode.java | 52 +
.../process/task/code/model/ThirdBranch.java | 17 +
.../process/task/code/model/ThirdHouse.java | 25 +
.../process/task/code/model/ThirdQuery.java | 23 +
.../process/task/code/model/ThirdUser.java | 17 +
.../code/service/SpotbugsScanService.java | 44 +
.../code/service/TaskCodeGittokService.java | 47 +
.../codescan/model/SpotbugsBugCategory.java | 32 +
.../task/codescan/model/SpotbugsBugClass.java | 53 +
.../codescan/model/SpotbugsBugClassStats.java | 64 +
.../task/codescan/model/SpotbugsBugCode.java | 41 +
.../task/codescan/model/SpotbugsBugField.java | 41 +
.../codescan/model/SpotbugsBugFileStats.java | 42 +
.../codescan/model/SpotbugsBugInstance.java | 140 ++
.../codescan/model/SpotbugsBugMethod.java | 62 +
.../model/SpotbugsBugPackageStats.java | 55 +
.../codescan/model/SpotbugsBugPattern.java | 63 +
.../task/codescan/model/SpotbugsBugQuery.java | 47 +
.../codescan/model/SpotbugsBugSourceLine.java | 65 +
.../codescan/model/SpotbugsBugSummary.java | 184 +++
.../task/codescan/model/TaskCodeScan.java | 150 ++
.../codescan/service/TaskCodeScanService.java | 62 +
.../process/task/test/model/MavenTest.java | 49 +
.../task/test/model/MavenTestQuery.java | 30 +
.../task/test/model/RelevanceTestOn.java | 36 +
.../task/test/model/RelevanceTestOnQuery.java | 22 +
.../process/task/test/model/TaskTest.java | 67 +
.../process/task/test/model/TestOnApiEnv.java | 14 +
.../task/test/model/TestOnApiEnvQuery.java | 20 +
.../process/task/test/model/TestOnAppEnv.java | 16 +
.../task/test/model/TestOnAppEnvQuery.java | 22 +
.../test/model/TestOnPlanCaseInstance.java | 28 +
.../TestOnPlanCaseInstanceBindQuery.java | 27 +
.../task/test/model/TestOnPlanInstance.java | 55 +
.../task/test/model/TestOnPlanQuery.java | 30 +
.../task/test/model/TestOnPlanTestData.java | 19 +
.../task/test/model/TestOnRelevance.java | 17 +
.../task/test/model/TestOnRepository.java | 12 +
.../task/test/model/TestOnTestPlan.java | 12 +
.../process/task/test/model/TestOnWebEnv.java | 14 +
.../task/test/model/TestOnWebEnvQuery.java | 24 +
.../task/test/model/TestPlanExecResult.java | 23 +
.../task/test/service/MavenTestService.java | 33 +
.../test/service/RelevanceTestOnService.java | 78 +
.../task/test/service/TaskTestOnService.java | 121 ++
.../ws/config/MatflowWebSocketConfig.java | 39 +
.../ws/server/SocketServerHandler.java | 152 ++
.../ws/server/WebSocketMessageService.java | 16 +
.../impl/WebSocketMessageServiceImpl.java | 364 +++++
57 files changed, 3877 insertions(+), 997 deletions(-)
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/artifact/model/TaskArtifact.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/artifact/model/XpackRepository.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/artifact/model/XpackRepositoryQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/artifact/service/TaskArtifactXpackService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/build/model/TaskBuild.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/model/TaskCode.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/model/ThirdBranch.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/model/ThirdHouse.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/model/ThirdQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/model/ThirdUser.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/service/SpotbugsScanService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/code/service/TaskCodeGittokService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugCategory.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugClass.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugClassStats.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugCode.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugField.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugFileStats.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugInstance.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugMethod.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugPackageStats.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugPattern.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugSourceLine.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/SpotbugsBugSummary.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/model/TaskCodeScan.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/codescan/service/TaskCodeScanService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/MavenTest.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/MavenTestQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/RelevanceTestOn.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/RelevanceTestOnQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TaskTest.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnApiEnv.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnApiEnvQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnAppEnv.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnAppEnvQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnPlanCaseInstance.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnPlanCaseInstanceBindQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnPlanInstance.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnPlanQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnPlanTestData.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnRelevance.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnRepository.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnTestPlan.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnWebEnv.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestOnWebEnvQuery.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/model/TestPlanExecResult.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/service/MavenTestService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/service/RelevanceTestOnService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/task/test/service/TaskTestOnService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/ws/config/MatflowWebSocketConfig.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/ws/server/SocketServerHandler.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/ws/server/WebSocketMessageService.java
create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/ws/server/impl/WebSocketMessageServiceImpl.java
diff --git a/modules/module-ci-process-biz/pom.xml b/modules/module-ci-process-biz/pom.xml
index ed81253..327b96d 100644
--- a/modules/module-ci-process-biz/pom.xml
+++ b/modules/module-ci-process-biz/pom.xml
@@ -42,6 +42,11 @@
ognl
ognl
+
+ org.springframework
+ spring-websocket
+ 6.1.13
+
\ No newline at end of file
diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/pipeline/definition/impl/PipelineYamlServiceImpl.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/pipeline/definition/impl/PipelineYamlServiceImpl.java
index 0cb1fc2..b4ef221 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/pipeline/definition/impl/PipelineYamlServiceImpl.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/pipeline/definition/impl/PipelineYamlServiceImpl.java
@@ -1,641 +1,650 @@
-//package cd.casic.module.process.pipeline.definition.impl;
-//
-//
-//import cd.casic.ci.commons.bean.engine.job.Tasks;
-//import cd.casic.ci.commons.bean.process.stage.Stage;
-//import cd.casic.module.process.engine.task.TasksService;
-//import cd.casic.module.process.pipeline.definition.PipelineYamlService;
-//import cd.casic.module.process.pipeline.definition.entity.PipelineEntity;
-//import cd.casic.module.process.process.definition.dao.PipelineDao;
-//import cd.casic.module.process.setting.service.AuthHostService;
-//import cd.casic.module.process.setting.service.AuthService;
-//import cd.casic.module.process.setting.service.AuthThirdService;
-//import cd.casic.module.process.stages.service.StageService;
-//import cd.casic.module.process.support.util.util.PipelineFinal;
-//import com.alibaba.fastjson.JSONObject;
-//import org.slf4j.Logger;
-//import org.slf4j.LoggerFactory;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.stereotype.Service;
-//import org.yaml.snakeyaml.DumperOptions;
-//import org.yaml.snakeyaml.Yaml;
-//
-//import java.util.*;
-//
-//@Service
-//public class PipelineYamlServiceImpl implements PipelineYamlService {
-//
-// @Autowired
-// PipelineDao pipelineDao;
-//
-// @Autowired
-// AuthHostService authHostService;
-//
-// @Autowired
-// AuthThirdService authThirdService;
-//
-// @Autowired
-// TaskTestOnService taskTestOnService;
-//
-// @Autowired
-// TaskCodeGittokService taskCodeGittokService;
-//
-// @Autowired
-// TaskArtifactXpackService taskArtifactXpackService;
-//
-// @Autowired
-// AuthService authService;
-//
-// @Autowired
-// PipelineYamlService pipelineYamlService;
-//
-// @Autowired
-// TasksService tasksService;
-//
-// @Autowired
-// StageService stageService;
-//
-// private static final Logger logger = LoggerFactory.getLogger(PipelineYamlService.class);
-//
-//
-// @Override
-// public String importPipelineYaml(String pipelineId){
-//
-// PipelineEntity pipeline = pipelineDao.findPipelineById(pipelineId);
-//
-// Map properties = new HashMap<>();
-// properties.put("pipeline", Map.of("name", pipeline.getName()));
-//
-// DumperOptions options = new DumperOptions();
-// options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK);
-//
-// Yaml yaml = new Yaml(options);
-//
-// // 将Java对象转换为YAML字符串
-// String yamlString = yaml.dump(properties);
-//
-// return importStageYaml(yamlString,pipelineId);
-//
-// // int type = pipeline.getType();
-// //
-// // if (type == 1){
-// // return importTaskYaml(yamlString,pipelineId);
-// // }else {
-// // return importStageYaml(yamlString,pipelineId);
-// // }
-// }
-//
-// // /**
-// // * 导出多任务配置为Yaml格式
-// // * @param yamlString yaml
-// // * @param pipelineId 流水线
-// // * @return Yaml格式支付串
-// // */
-// // private String importTaskYaml(String yamlString,String pipelineId){
-// //
-// // DumperOptions options = new DumperOptions();
-// // options.setDefaultFlowStyle(DumperOptions.FlowStyle.BLOCK);
-// //
-// // Yaml yaml = new Yaml(options);
-// // Map data = yaml.load(yamlString);
-// //
-// // List