From 7c4442a30e2c0f9ccf95a949f6cb8a184a648ebc Mon Sep 17 00:00:00 2001 From: HopeLi <1278288511@qq.com> Date: Thu, 22 May 2025 10:06:25 +0800 Subject: [PATCH] 0522 ljc --- .../engine/constant/CommonConstant.java | 133 ++++++ .../engine/constant/SymbolConstant.java | 73 +++ .../engine/constant/SysConfigConstant.java | 15 + .../engine/context/ConstantContext.java | 54 +++ .../engine/context/ConstantContextHolder.java | 435 ++++++++++++++++++ .../process/engine/druid/DruidProperties.java | 167 +++++++ .../ci/process/engine/enums/DbIdEnum.java | 53 +++ .../ci/process/engine/oauth/OauthConfigs.java | 29 ++ .../engine/pojo/CryptogramConfigs.java | 33 ++ .../process/engine/worker/ScaSbomWorker.java | 35 +- 10 files changed, 1001 insertions(+), 26 deletions(-) create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/CommonConstant.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SymbolConstant.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SysConfigConstant.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContext.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContextHolder.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/druid/DruidProperties.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/enums/DbIdEnum.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/oauth/OauthConfigs.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/pojo/CryptogramConfigs.java diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/CommonConstant.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/CommonConstant.java new file mode 100644 index 00000000..0f0b91f3 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/CommonConstant.java @@ -0,0 +1,133 @@ +package cd.casic.ci.process.engine.constant; + +import lombok.Data; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName CommonConstant + * @Date: 2025/5/22 9:58 + * @Description: + */ +public interface CommonConstant { + /** + * id + */ + String ID = "id"; + + /** + * 名称 + */ + String NAME = "name"; + + /** + * 编码 + */ + String CODE = "code"; + + /** + * 值 + */ + String VALUE = "value"; + + /** + * 默认标识状态的字段名称 + */ + String STATUS = "status"; + + /** + * 默认逻辑删除的状态值 + */ + String DEFAULT_LOGIC_DELETE_VALUE = "2"; + + /** + * 用户代理 + */ + String USER_AGENT = "User-Agent"; + + /** + * 请求头token表示 + */ + String AUTHORIZATION = "Authorization"; + + /** + * token名称 + */ + String TOKEN_NAME = "token"; + + /** + * token类型 + */ + String TOKEN_TYPE_BEARER = "Bearer"; + + /** + * 首页提示语 + */ + String INDEX_TIPS = "Welcome To Ops"; + + /** + * 未知标识 + */ + String UNKNOWN = "Unknown"; + + /** + * 默认包名 + */ + String DEFAULT_PACKAGE_NAME = "cd.casic"; + + /** + * 默认密码 + */ + String DEFAULT_PASSWORD = "123456"; + + /** + * 请求号在header中的唯一标识 + */ + String REQUEST_NO_HEADER_NAME = "Request-No"; + + /** + * 数据库链接URL标识 + */ + String DATABASE_URL_NAME = "DATABASE_URL_NAME"; + + /** + * 数据库链接驱动标识 + */ + String DATABASE_DRIVER_NAME = "DATABASE_DRIVER_NAME"; + + /** + * 数据库用户标识 + */ + String DATABASE_USER_NAME = "DATABASE_USER_NAME"; + + /** + * 点选验证码 + */ + String IMAGE_CODE_TYPE = "clickWord"; + + /** + * undefined未知 + */ + String UNDEFINED = "undefined"; + + /** + * 数据库配置文件地址 + */ + String DB_PROPERTIES_PATH = "resources/db.properties"; + /** + * resources路径 + */ + String RESOURCES_DIR = "resources"; + + /** + * 开发资源路径 + */ + String DEV_RESOURCES_PATH = "classpath:"; + /* integration*/ + String VERSION_TYPE_INTEGRATION = "integrationTest"; + /* 單元測試 */ + String VERSION_TYPE_UNIT = "unitTest"; + String VERSION_TYPE_STATIC = "staticTest"; + String TASK4_TEST_TYPE = "task4"; + String SONAR_TEST_TYPE = "sonarqube"; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SymbolConstant.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SymbolConstant.java new file mode 100644 index 00000000..b64963f1 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SymbolConstant.java @@ -0,0 +1,73 @@ +package cd.casic.ci.process.engine.constant; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName SymbolConstant + * @Date: 2025/5/22 9:53 + * @Description: + */ +public interface SymbolConstant { + + String PERIOD = "."; + + String COMMA = ","; + + String COLON = ":"; + + String SEMICOLON = ";"; + + String EXCLAMATION_MARK = "!"; + + String QUESTION_MARK = "?"; + + String HYPHEN = "-"; + + String ASTERISK = "*"; + + String APOSTROPHE = "`"; + + String DASH = "-"; + + String UNDER_SCORE = "_"; + + String SINGLE_QUOTATION_MARK = "'"; + + String DOUBLE_QUOTATION_MARK = "\""; + + String LEFT_ROUND_BRACKETS = "("; + + String RIGHT_ROUND_BRACKETS = ")"; + + String LEFT_SQUARE_BRACKETS = "["; + + String RIGHT_SQUARE_BRACKETS = "]"; + + String LEFT_ANGLE_BRACKETS = "<"; + + String RIGHT_ANGLE_BRACKETS = ">"; + + String LEFT_CURLY_BRACKETS = "{"; + + String RIGHT_CURLY_BRACKETS = "}"; + + String DOLLAR = "$"; + + String PERCENT = "%"; + + String LEFT_DIVIDE = "/"; + + String RIGHT_DIVIDE = "\\"; + + String LEFT_DOUBLE_DIVIDE = "//"; + + String RIGHT_DOUBLE_DIVIDE = "\\\\"; + + String EQUAL = "="; + + String LF = "\n"; + + String SPACE_4 = " "; + + Long N_N_1_L = -1L; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SysConfigConstant.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SysConfigConstant.java new file mode 100644 index 00000000..0ce0135b --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/constant/SysConfigConstant.java @@ -0,0 +1,15 @@ +package cd.casic.ci.process.engine.constant; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName SysConfigConstant + * @Date: 2025/5/22 9:53 + * @Description: + */ +public interface SysConfigConstant { + /** + * 不需要xss过滤的接口 + */ + String OPS_UN_XSS_FILTER_URL = "OPS_UN_XSS_FILTER_URL"; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContext.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContext.java new file mode 100644 index 00000000..45363884 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContext.java @@ -0,0 +1,54 @@ +package cd.casic.ci.process.engine.context; + +import cn.hutool.core.lang.Dict; +import cn.hutool.core.util.ObjectUtil; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName ConstantContext + * @Date: 2025/5/22 10:03 + * @Description: + */ +public class ConstantContext { + /** + * 所有的常量，可以增删改查 + */ + private static final Dict CONSTANTS_HOLDER = Dict.create(); + + /** + * 添加系统常量 + * + * @author yubaoshan + * @date 2020/6/20 22:32 + */ + public static void putConstant(String code, Object value) { + if (ObjectUtil.hasEmpty(code, value)) { + return; + } + CONSTANTS_HOLDER.put(code, value); + } + + /** + * 删除常量，系统常量无法删除，在sysConfig已判断 + * + * @author yubaoshan + * @date 2020/6/20 22:32 + */ + public static void deleteConstant(String code) { + if (ObjectUtil.hasEmpty(code)) { + return; + } + CONSTANTS_HOLDER.remove(code); + } + + /** + * 获取系统常量本身 + * + * @author yubaoshan + * @date 2020/6/20 22:32 + */ + public static Dict me() { + return CONSTANTS_HOLDER; + } +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContextHolder.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContextHolder.java new file mode 100644 index 00000000..7bf44ee8 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/context/ConstantContextHolder.java @@ -0,0 +1,435 @@ +package cd.casic.ci.process.engine.context; + + +import cd.casic.ci.process.engine.constant.CommonConstant; +import cd.casic.ci.process.engine.constant.SymbolConstant; +import cd.casic.ci.process.engine.constant.SysConfigConstant; +import cd.casic.ci.process.engine.druid.DruidProperties; +import cd.casic.ci.process.engine.oauth.OauthConfigs; +import cd.casic.ci.process.engine.pojo.CryptogramConfigs; +import cd.casic.framework.commons.exception.ServiceException; +import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants; +import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.convert.Convert; +import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.RandomUtil; +import cn.hutool.core.util.StrUtil; +import cn.hutool.log.Log; + +import java.util.List; + +/** + * 系统参数配置获取 + * + * @author xuyuxiang + * @date 2020/4/14 15:34 + */ +public class ConstantContextHolder { + + private static final Log log = Log.get(); + + /** + * 获取租户功能是否开启 + * + * @author xuyuxiang + * @date 2020/9/3 + */ + public static Boolean getTenantOpenFlag() { + return getSysConfigWithDefault("OPS_TENANT_OPEN", Boolean.class, false); + } + + /** + * 获取放开xss过滤的接口 + * + * @author yubaoshan + * @date 2020/6/20 22:13 + */ + public static List getUnXssFilterUrl() { + String snowyUnXssFilterUrl = getSysConfigWithDefault(SysConfigConstant.OPS_UN_XSS_FILTER_URL, String.class, null); + if (ObjectUtil.isEmpty(snowyUnXssFilterUrl)) { + return CollectionUtil.newArrayList(); + } else { + return CollectionUtil.toList(snowyUnXssFilterUrl.split(SymbolConstant.COMMA)); + } + } + + /** + * 获取演示环境开关是否开启，默认为false + * + * @author yubaoshan + * @date 2020/6/20 22:13 + */ + public static Boolean getDemoEnvFlag() { + return getSysConfigWithDefault("OPS_DEMO_ENV_FLAG", Boolean.class, false); + } + + + /** + * 获取Druid默认用户名密码 + * + * @author yubaoshan + * @date 2022/5/16 + */ + public static DruidProperties getDruidLoginConfigs() { + String snowyDruidLoginUsername = getSysConfigWithDefault("OPS_DRUID_LOGIN_USERNAME", String.class, RandomUtil.randomString(10)); + String snowyDruidLoginPassword = getSysConfigWithDefault("OPS_DRUID_LOGIN_PASSWORD", String.class, RandomUtil.randomString(10)); + + DruidProperties druidProperties = new DruidProperties(); + druidProperties.setLoginUsername(snowyDruidLoginUsername); + druidProperties.setLoginPassword(snowyDruidLoginPassword); + return druidProperties; + } + + + /** + * 获取jwt密钥，默认是32位随机字符串 + * + * @author yubaoshan + * @date 2020/6/19 18:08 + */ + public static String getJwtSecret() { + return getSysConfigWithDefault("OPS_JWT_SECRET", String.class, RandomUtil.randomString(32)); + } + + /** + * 获取默认密码 + * + * @author yubaoshan + * @date 2020/6/19 18:08 + */ + public static String getDefaultPassWord() { + return getSysConfigWithDefault("OPS_DEFAULT_PASSWORD", String.class, CommonConstant.DEFAULT_PASSWORD); + } + + /** + * 获取会话过期时间，默认2小时 + * + * @author yubaoshan + * @date 2020/7/9 16:18 + */ + public static Long getSessionTokenExpireSec() { + return getSysConfigWithDefault("OPS_SESSION_EXPIRE", Long.class, 2 * 60 * 60L); + } + + /** + * 获取token过期时间（单位：秒） + *

+ * 默认时间1天 + * + * @author xuyuxiang + * @date 2020/6/19 18:08 + */ + public static Long getTokenExpireSec() { + return getSysConfigWithDefault("OPS_TOKEN_EXPIRE", Long.class, 86400L); + } + + /** + * 获取自定义的windows环境本地文件上传路径 + * + * @author xuyuxiang + * @date 2020/6/19 18:09 + */ + public static String getDefaultFileUploadPathForWindows() { + return getSysConfigWithDefault("OPS_FILE_UPLOAD_PATH_FOR_WINDOWS", String.class, ""); + } + + /** + * 获取自定义的linux环境本地文件上传路径 + * + * @author xuyuxiang + * @date 2020/6/19 18:09 + */ + public static String getDefaultFileUploadPathForLinux() { + return getSysConfigWithDefault("OPS_FILE_UPLOAD_PATH_FOR_LINUX", String.class, ""); + } + + /** + * 获取是否允许单用户登陆的开关， 默认为false + * + * @author xuyuxiang + * @date 2020/6/19 18:09 + */ + public static Boolean getEnableSingleLogin() { + return getSysConfigWithDefault("OPS_ENABLE_SINGLE_LOGIN", Boolean.class, false); + } + + /** + * 获取阿里云定位接口 + * + * @author xuyuxiang + * @date 2020/7/20 9:20 + **/ + public static String getIpGeoApi() { + return getSysConfig("OPS_IP_GEO_API", String.class, false); + } + + /** + * 获取阿里云定位appCode + * + * @author xuyuxiang + * @date 2020/7/20 10:33 + **/ + public static String getIpGeoAppCode() { + return getSysConfig("OPS_IP_GEO_APP_CODE", String.class, false); + } + + /** + * 获取Oauth码云第三方登录的配置 + * + * @author xuyuxiang + * @date 2020/7/28 17:16 + **/ + public static OauthConfigs getGiteeOauthConfigs() { + String snowyClientId = getSysConfig("OPS_OAUTH_GITEE_CLIENT_ID", String.class, true); + String snowyClientSecret = getSysConfig("OPS_OAUTH_GITEE_CLIENT_SECRET", String.class, true); + String snowyRedirectUri = getSysConfig("OPS_OAUTH_GITEE_REDIRECT_URI", String.class, true); + + OauthConfigs oauthConfigs = new OauthConfigs(); + oauthConfigs.setClientId(snowyClientId); + oauthConfigs.setClientSecret(snowyClientSecret); + oauthConfigs.setRedirectUri(snowyRedirectUri); + return oauthConfigs; + } + + /** + * 获取OauthGithub第三方登录的配置 + * + * @author xuyuxiang + * @date 2020/7/28 17:16 + **/ + public static OauthConfigs getGithubOauthConfigs() { + String snowyClientId = getSysConfig("OPS_OAUTH_GITHUB_CLIENT_ID", String.class, true); + String snowyClientSecret = getSysConfig("OPS_OAUTH_GITHUB_CLIENT_SECRET", String.class, true); + String snowyRedirectUri = getSysConfig("OPS_OAUTH_GITHUB_REDIRECT_URI", String.class, true); + + OauthConfigs oauthConfigs = new OauthConfigs(); + oauthConfigs.setClientId(snowyClientId); + oauthConfigs.setClientSecret(snowyClientSecret); + oauthConfigs.setRedirectUri(snowyRedirectUri); + return oauthConfigs; + } + + /** + * 获取是否允许Oauth用户登陆的开关， 默认为false + * + * @author xuyuxiang + * @date 2020/7/28 16:37 + **/ + public static Boolean getEnableOauthLogin() { + return getSysConfigWithDefault("OPS_ENABLE_OAUTH_LOGIN", Boolean.class, false); + } + + /** + * 获取前端项目的地址 + * + * @author xuyuxiang + * @date 2020/7/29 14:08 + **/ + public static String getWebUrl() { + return getSysConfig("OPS_WEB_URL", String.class, true); + } + + /** + * 获取支付宝支付成功转发地址 + * + * @author xuyuxiang + * @date 2020/7/29 14:08 + **/ + public static String getAlipayReturnUrl() { + return getSysConfig("OPS_ALIPAY_RETURN_URL", String.class, true); + } + + /** + * 获取OnlyOffice地址 + * + * @author xuyuxiang + * @date 2020/7/29 14:08 + **/ + public static String getOnlyOfficeUrl() { + return getSysConfig("OPS_ONLY_OFFICE_SERVICE_URL", String.class, true); + } + + /** + * 获取config表中的配置，如果为空返回默认值 + * + * @param configCode 变量名称，对应sys_config表中的code + * @param clazz 返回变量值的类型 + * @param defaultValue 如果结果为空返回此默认值 + * @author yubaoshan + * @date 2020/6/20 22:03 + */ + public static T getSysConfigWithDefault(String configCode, Class clazz, T defaultValue) { + String configValue = ConstantContext.me().getStr(configCode); + if (ObjectUtil.isEmpty(configValue)) { + // 将默认值加入到缓存常量 + log.warn(">>> 系统配置sys_config表中存在空项，configCode为：{}，系统采用默认值：{}", configCode, defaultValue); + ConstantContext.me().put(configCode, defaultValue); + return defaultValue; + } else { + try { + return Convert.convert(clazz, configValue); + } catch (Exception e) { + return defaultValue; + } + } + } + + /** + * 获取config表中的配置，如果为空，是否抛出异常 + * + * @param configCode 变量名称，对应sys_config表中的code + * @param clazz 返回变量值的类型 + * @param nullThrowExp 若为空是否抛出异常 + * @author yubaoshan + * @date 2020/6/20 22:03 + */ + public static T getSysConfig(String configCode, Class clazz, Boolean nullThrowExp) { + String configValue = ConstantContext.me().getStr(configCode); + if (ObjectUtil.isEmpty(configValue)) { + if (nullThrowExp) { + String format = StrUtil.format(">>> 系统配置sys_config表中存在空项，configCode为：{}", configCode); + log.error(format); + throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(), format); + } else { + return null; + } + } else { + try { + return Convert.convert(clazz, configValue); + } catch (Exception e) { + if (nullThrowExp) { + String format = StrUtil.format(">>> 系统配置sys_config表中存在格式错误的值，configCode={}，configValue={}", configCode, configValue); + log.error(format); + throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(), format); + } else { + return null; + } + } + } + } + + /** + * 获取验证码 开关标识 + * + * @author Jax + * @Date 2021/1/21 15:22 + */ + public static Boolean getCaptchaOpenFlag() { + return getSysConfigWithDefault("OPS_CAPTCHA_OPEN", Boolean.class, true); + } + + /** + * 获取加解密的配置 + * + * @author yubaoshan + */ + public static CryptogramConfigs getCryptogramConfigs() { + boolean snowyTokenEncDec = getSysConfigWithDefault("OPS_TOKEN_ENCRYPTION_OPEN", Boolean.class, true); + boolean snowyVisLogEnc = getSysConfigWithDefault("OPS_VISLOG_ENCRYPTION_OPEN", Boolean.class, true); + boolean snowyOpLogEnc = getSysConfigWithDefault("OPS_OPLOG_ENCRYPTION_OPEN", Boolean.class, true); + boolean snowyFieldEncDec = getSysConfigWithDefault("OPS_FIELD_ENC_DEC_OPEN", Boolean.class, true); + + CryptogramConfigs cryptogramConfigs = new CryptogramConfigs(); + cryptogramConfigs.setTokenEncDec(snowyTokenEncDec); + cryptogramConfigs.setVisLogEnc(snowyVisLogEnc); + cryptogramConfigs.setOpLogEnc(snowyOpLogEnc); + cryptogramConfigs.setFieldEncDec(snowyFieldEncDec); + return cryptogramConfigs; + } + + /** + * 获取代码仓存储路径配置 + * + * @author herenbin + */ + public static String getGitRepositoryFilePath() { + return getSysConfigWithDefault("OPS_VCS_PATH", String.class, "vcs"); + } + + /** + * 获取OnRoad系统账户配置账号 + * + * @author herenbin + */ + public static String getSystemOnRoad() { + return getSysConfigWithDefault("OPS_SYSTEM_ONROAD", String.class, "onroad"); + } + + /** + * 获取 + * + * @author herenbin + */ + public static String getToperaReport() { + return getSysConfigWithDefault("OPS_URL_TOPERA_REPORT", String.class, "http://127.0.0.1:8785"); + } + + /** + * 获取代码扫描服务器地址 + * + * @author herenbin + */ + public static String getScan() { + return getSysConfigWithDefault("OPS_URL_SCAN", String.class, "http://127.0.0.1:8086"); + } + + /** + * 获取OnRoad服务器地址 + * + * @author herenbin + */ + public static String getOnRoadIp() { + return getSysConfigWithDefault("OPS_URL_ON_ROAD", String.class, "http://127.0.0.1:8766"); + } + + /** + * 获取任务四的ip信息 + * + * @author liuyuchao + */ + public static String getSmartRocketIp() { + return getSysConfigWithDefault("OPS_URL_SMART_ROCKET", String.class, "http://192.168.0.158"); + } + + /** + * 获取sonarqube的ip信息 + * + * @author liuyuchao + */ + public static String getSonarqubeIp() { + return getSysConfigWithDefault("SONARQUBE", String.class, "http://192.168.0.17:9002"); + } + + /** + * 获取安世客户端地址 + * + * @author pangrongan + */ + public static String getModelClient() { + return getSysConfigWithDefault("OPS_MODEL_CLIENT", String.class, "http://192.168.0.121:9856"); + } + + /** + * 获取onsim报告 + * + * @author pangrongan + */ + public static String getOnsimReport() { + return getSysConfigWithDefault("OPS_ONSIM_REPORT", String.class, "http://127.0.0.1:8090/providers/onsim/-sim_dsp-a-b-c-result-test_elf-index.html/onsimCoverRate"); + } + + /** + * SCA地址 + */ + public static String getScaIp() { + return getSysConfigWithDefault("OPS_URL_SCA", String.class, "https://175.6.27.252:30002"); + } + + /** + * SCA token + * SCA默认写死 + */ + public static String getScaToken() { + return getSysConfigWithDefault("OPS_TOKEN_SCA", String.class, "6b906a14493644af801efbcdee7cd390"); + } +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/druid/DruidProperties.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/druid/DruidProperties.java new file mode 100644 index 00000000..e892ae12 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/druid/DruidProperties.java @@ -0,0 +1,167 @@ +package cd.casic.ci.process.engine.druid; + +import cd.casic.ci.process.engine.enums.DbIdEnum; +import cn.hutool.log.Log; +import com.alibaba.druid.pool.DruidDataSource; +import lombok.Data; + +import java.sql.SQLException; +import java.util.Properties; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName DruidProperties + * @Date: 2025/5/22 9:55 + * @Description: + */ +@Data +public class DruidProperties { + + private static final Log log = Log.get(); + + /** + * mysql校验语句 + */ + private final String MYSQL_VALIDATE_QUERY_SQL = "select 1"; + + /** + * oracle校验语句 + */ + private final String ORACLE_VALIDATE_QUERY_SQL = "select 1 from dual"; + + /** + * postgresql校验语句 + */ + private final String POSTGRESQL_VALIDATE_QUERY_SQL = "select version()"; + + /** + * sqlserver校验语句 + */ + private final String SQLSERVER_VALIDATE_QUERY_SQL = "select 1"; + + /** + * 达梦数据库校验语句 + */ + private final String DM_VALIDATE_QUERY_SQL = "select 1"; + + /** + * 人大金仓数据库校验语句 + */ + private final String KINGBASEES_VALIDATE_QUERY_SQL = "select 1"; + + private String loginUsername; + + private String loginPassword; + + private String url; + + private String username; + + private String password; + + private String driverClassName; + + private Integer initialSize = 2; + + private Integer minIdle = 1; + + private Integer maxActive = 20; + + private Integer maxWait = 60000; + + private Integer timeBetweenEvictionRunsMillis = 60000; + + private Integer minEvictableIdleTimeMillis = 300000; + + private String validationQuery; + + private Boolean testWhileIdle = true; + + private Boolean testOnBorrow = true; + + private Boolean testOnReturn = true; + + private Boolean poolPreparedStatements = true; + + private Integer maxPoolPreparedStatementPerConnectionSize = 20; + + private String filters = "stat,slf4j"; + + private String dataSourceName; + + public void config(DruidDataSource dataSource) { + + dataSource.setUrl(url); + dataSource.setUsername(username); + dataSource.setPassword(password); + + dataSource.setDriverClassName(driverClassName); + //定义初始连接数 + dataSource.setInitialSize(initialSize); + //最小空闲 + dataSource.setMinIdle(minIdle); + //定义最大连接数 + dataSource.setMaxActive(maxActive); + //最长等待时间 + dataSource.setMaxWait(maxWait); + + //配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 + dataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis); + + //配置一个连接在池中最小生存的时间，单位是毫秒 + dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis); + dataSource.setValidationQuery(getValidateQueryByUrl(url)); + dataSource.setTestWhileIdle(testWhileIdle); + dataSource.setTestOnBorrow(testOnBorrow); + dataSource.setTestOnReturn(testOnReturn); + + //打开PSCache，并且指定每个连接上PSCache的大小 + dataSource.setPoolPreparedStatements(poolPreparedStatements); + dataSource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize); + + try { + dataSource.setFilters(filters); + } catch (SQLException e) { + log.error(">>> 数据库连接池初始化异常：{}", e.getMessage()); + } + } + + public Properties createProperties() { + Properties properties = new Properties(); + properties.put("url", this.url); + properties.put("username", this.username); + properties.put("password", this.password); + properties.put("driverClassName", this.driverClassName); + properties.put("initialSize", this.initialSize); + properties.put("maxActive", this.maxActive); + properties.put("minIdle", this.minIdle); + properties.put("maxWait", this.maxWait); + properties.put("poolPreparedStatements", this.poolPreparedStatements); + properties.put("maxPoolPreparedStatementPerConnectionSize", this.maxPoolPreparedStatementPerConnectionSize); + properties.put("validationQuery", getValidateQueryByUrl(this.url)); + properties.put("testOnBorrow", this.testOnBorrow); + properties.put("testOnReturn", this.testOnReturn); + properties.put("testWhileIdle", this.testWhileIdle); + properties.put("timeBetweenEvictionRunsMillis", this.timeBetweenEvictionRunsMillis); + properties.put("minEvictableIdleTimeMillis", this.minEvictableIdleTimeMillis); + properties.put("filters", this.filters); + return properties; + } + + private String getValidateQueryByUrl(String url) { + if (url.contains(DbIdEnum.ORACLE.getName())) { + return ORACLE_VALIDATE_QUERY_SQL; + } else if (url.contains(DbIdEnum.PG_SQL.getName())) { + return POSTGRESQL_VALIDATE_QUERY_SQL; + } else if (url.contains(DbIdEnum.MS_SQL.getName())) { + return SQLSERVER_VALIDATE_QUERY_SQL; + } else if (url.contains(DbIdEnum.DM_SQL.getName())) { + return DM_VALIDATE_QUERY_SQL; + } else if (url.contains(DbIdEnum.KINGBASE_ES.getName())) { + return KINGBASEES_VALIDATE_QUERY_SQL; + } else { + return MYSQL_VALIDATE_QUERY_SQL; + } + } +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/enums/DbIdEnum.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/enums/DbIdEnum.java new file mode 100644 index 00000000..ec9bcd21 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/enums/DbIdEnum.java @@ -0,0 +1,53 @@ +package cd.casic.ci.process.engine.enums; + +import lombok.Getter; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName DbIdEnum + * @Date: 2025/5/22 9:56 + * @Description: + */ +@Getter +public enum DbIdEnum { + /** + * mysql + */ + MYSQL("mysql", "mysql"), + + /** + * pgsql + */ + PG_SQL("pgsql", "postgresql"), + + /** + * oracle + */ + ORACLE("oracle", "oracle"), + + /** + * mssql + */ + MS_SQL("mssql", "sqlserver"), + + /** + * 达梦数据库 + */ + DM_SQL("dm", "dm"), + + /** + * 人大金仓数据库 + */ + KINGBASE_ES("kingbase", "kingbasees"); + + private final String code; + + private final String name; + + DbIdEnum(String code, String name) { + this.code = code; + this.name = name; + } + +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/oauth/OauthConfigs.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/oauth/OauthConfigs.java new file mode 100644 index 00000000..49b146e7 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/oauth/OauthConfigs.java @@ -0,0 +1,29 @@ +package cd.casic.ci.process.engine.oauth; + +import lombok.Data; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName OauthConfigs + * @Date: 2025/5/22 10:02 + * @Description: + */ +@Data +public class OauthConfigs { + + /** + * clientId + */ + private String clientId; + + /** + * clientSecret + */ + private String clientSecret; + + /** + * 回调地址 + */ + private String redirectUri; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/pojo/CryptogramConfigs.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/pojo/CryptogramConfigs.java new file mode 100644 index 00000000..796137fe --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/pojo/CryptogramConfigs.java @@ -0,0 +1,33 @@ +package cd.casic.ci.process.engine.pojo; + +import lombok.Data; + +/** + * @author HopeLi + * @version v1.0 + * @ClassName CryptogramConfigs + * @Date: 2025/5/22 10:05 + * @Description: + */ +@Data +public class CryptogramConfigs { + /** + * token是否加解密 + */ + private Boolean tokenEncDec; + + /** + * 操作日志是否加密 + */ + private Boolean opLogEnc; + + /** + * 登录登出日志是否加密 + */ + private Boolean visLogEnc; + + /** + * 铭感字段值是否加解密 + */ + private Boolean fieldEncDec; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/ScaSbomWorker.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/ScaSbomWorker.java index 88ff7492..19fd61ff 100644 --- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/ScaSbomWorker.java +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/ScaSbomWorker.java @@ -1,7 +1,7 @@ package cd.casic.ci.process.engine.worker; import cd.casic.ci.common.pipeline.annotation.Plugin; -import cd.casic.ci.process.engine.configinfo.ScaSbomConfigInfo; +import cd.casic.ci.process.engine.context.ConstantContextHolder; import cd.casic.ci.process.engine.runContext.BaseRunContext; import cd.casic.ci.process.engine.runContext.TaskRunContext; import cd.casic.ci.process.process.dataObject.base.PipBaseElement; @@ -10,7 +10,6 @@ import cd.casic.ci.process.process.dataObject.target.TargetVersion; import cd.casic.ci.process.process.dataObject.task.PipTask; import cd.casic.ci.process.process.service.pipeline.PipelineService; import cd.casic.ci.process.process.service.target.impl.TargetVersionServiceImpl; -import cd.casic.ci.process.process.service.task.impl.TaskServiceImpl; import cd.casic.framework.commons.exception.ServiceException; import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants; import cn.hutool.core.util.ObjectUtil; @@ -19,7 +18,6 @@ import com.alibaba.fastjson.JSONObject; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.springframework.beans.BeanUtils; import org.springframework.core.io.FileSystemResource; import org.springframework.http.*; import org.springframework.util.LinkedMultiValueMap; @@ -52,9 +50,6 @@ public class ScaSbomWorker extends HttpWorker{ @Resource private TargetVersionServiceImpl targetVersionService; - @Resource - private TaskServiceImpl pipelineNodeInfoService; - public String work(BaseRunContext workerParam) { int statusCode = 0; @@ -118,42 +113,30 @@ public class ScaSbomWorker extends HttpWorker{ String message = response.getString("message"); if (message.equals("success")) { - nodeLogger.appendNow("==================SCA上传成功================="); JSONObject data = response.getJSONObject("data"); Integer scaTaskId = data.getInteger("scaTaskId"); - Integer applicationId = data.getInteger("applicationId"); - - scaSbomConfigInfo.setScaTaskId(scaTaskId); - scaSbomConfigInfo.setApplicationId(applicationId); - //更新到节点json数据 - String nodeJson = JSON.toJSONString(scaSbomConfigInfo); - pipelineNodeConfigInfo.setInfo(nodeJson); - PipelineNodeInfoParam pipelineNodeInfoParam = new PipelineNodeInfoParam(); - BeanUtils.copyProperties(pipelineNodeConfigInfo, pipelineNodeInfoParam); - pipelineNodeInfoService.update(pipelineNodeInfoParam); - workerParam.getPipelineNodeConfigInfo().setInfo(nodeJson); pollTaskStatus(restTemplate, scaTaskId); } else if (message.equals("应用已经存在")) { - Integer oldScaTaskId = scaSbomConfigInfo.getScaTaskId(); - Integer oldApplicationId = scaSbomConfigInfo.getApplicationId(); + Integer oldScaTaskId = (Integer) scaSbomConfigInfo.get("taskId"); + Integer oldApplicationId = (Integer) scaSbomConfigInfo.get("applicationId"); int restartResult = reStartTask(restTemplate, oldApplicationId); if (restartResult != 0) { return; } pollTaskStatus(restTemplate, oldScaTaskId); } else { - nodeLogger.appendNow("==================SCA接口异常，调用失败================="); + throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"SCA-SBOM节点执行失败"); } } - private MultiValueMap buildRequestBody(ScaSbomConfigInfo scaSbomConfigInfo, File file) { + private MultiValueMap buildRequestBody(Map scaSbomConfigInfo, File file) { MultiValueMap body = new LinkedMultiValueMap<>(); body.add("file", new FileSystemResource(file)); - body.add("projectName", scaSbomConfigInfo.getProjectName()); - body.add("applicationName", scaSbomConfigInfo.getApplicationName()); - body.add("applicationVersion", scaSbomConfigInfo.getApplicationVersion()); - body.add("applicationDescription", scaSbomConfigInfo.getApplicationDescription()); + body.add("projectName", scaSbomConfigInfo.get("projectName")); + body.add("applicationName", scaSbomConfigInfo.get("applicationName")); + body.add("applicationVersion", scaSbomConfigInfo.get("applicationVersion")); + body.add("applicationDescription", scaSbomConfigInfo.get("applicationDescription")); return body; }