增加构建通知

This commit is contained in:
dengqichen 2025-11-20 13:52:40 +08:00
parent 85bebb7fc3
commit 4654395a56
2 changed files with 7 additions and 12 deletions

View File

@ -257,14 +257,14 @@ public class TeamApplicationServiceImpl extends BaseServiceImpl<TeamApplication,
* *
* <p>删除逻辑 * <p>删除逻辑
* <ul> * <ul>
* <li>1. 逻辑删除所有关联的部署记录DeployRecord</li> * <li>1. 物理删除所有关联的部署记录DeployRecord</li>
* <li>2. 再物理删除团队应用TeamApplication</li> * <li>2. 再物理删除团队应用TeamApplication</li>
* </ul> * </ul>
* *
* <p>注意 * <p>注意
* <ul> * <ul>
* <li>TeamApplication 使用物理删除@LogicDelete(false)</li> * <li>TeamApplication 使用物理删除@LogicDelete(false)</li>
* <li>DeployRecord 使用逻辑删除@LogicDelete</li> * <li>DeployRecord 由于外键约束必须物理删除</li>
* </ul> * </ul>
*/ */
@Override @Override
@ -278,13 +278,10 @@ public class TeamApplicationServiceImpl extends BaseServiceImpl<TeamApplication,
if (!deployRecords.isEmpty()) { if (!deployRecords.isEmpty()) {
log.info("团队应用 {} 关联了 {} 条部署记录,开始级联删除", id, deployRecords.size()); log.info("团队应用 {} 关联了 {} 条部署记录,开始级联删除", id, deployRecords.size());
// 2. 逻辑删除所有关联的部署记录 // 2. 物理删除所有关联的部署记录避免外键约束冲突
deployRecords.forEach(record -> { deployRecordRepository.deleteAll(deployRecords);
record.setDeleted(true);
deployRecordRepository.save(record);
});
log.info("成功逻辑删除 {} 条部署记录", deployRecords.size()); log.info("成功物理删除 {} 条部署记录", deployRecords.size());
} else { } else {
log.info("团队应用 {} 没有关联的部署记录", id); log.info("团队应用 {} 没有关联的部署记录", id);
} }

View File

@ -69,8 +69,7 @@ public class HttpRequestNodeDelegate extends BaseNodeDelegate<HttpRequestInputMa
long responseTime = System.currentTimeMillis() - startTime; long responseTime = System.currentTimeMillis() - startTime;
parseResponse(response, responseTime, input.getResponseBodyType()); parseResponse(response, responseTime, input.getResponseBodyType());
logInfo(String.format("HTTP请求成功: 状态码=%d, 耗时=%dms, 响应大小=%d bytes", logInfo(String.format("HTTP请求成功: 状态码=%d, 耗时=%dms, 响应大小=%d bytes", output.getStatusCode(), output.getResponseTime(), output.getResponseSize()));
output.getStatusCode(), output.getResponseTime(), output.getResponseSize()));
} catch (HttpClientErrorException | HttpServerErrorException e) { } catch (HttpClientErrorException | HttpServerErrorException e) {
// HTTP错误4xx, 5xx // HTTP错误4xx, 5xx
@ -108,8 +107,7 @@ public class HttpRequestNodeDelegate extends BaseNodeDelegate<HttpRequestInputMa
// 尝试解析为JSON对象或数组 // 尝试解析为JSON对象或数组
Object jsonBody = parseJsonBody(body); Object jsonBody = parseJsonBody(body);
output.setResponseBody(jsonBody); output.setResponseBody(jsonBody);
logInfo(String.format("响应体(JSON): %s", body.length() > 500 ? logInfo(String.format("响应体(JSON): %s", body.length() > 500 ? body.substring(0, 500) + "..." : body));
body.substring(0, 500) + "..." : body));
} catch (Exception e) { } catch (Exception e) {
log.warn("JSON解析失败返回原始文本: {}", e.getMessage()); log.warn("JSON解析失败返回原始文本: {}", e.getMessage());
output.setResponseBody(body); output.setResponseBody(body);