wkc/ccdi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

补充项目状态变更日志

Browse Source
This commit is contained in:
wkc
2026-03-18 17:03:23 +08:00
parent cc09936556
commit acf5249caf
4 changed files with 240 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
ccdi-project/src/main/java/com/ruoyi/ccdi/project/service/impl/CcdiProjectServiceImpl.java
View File

@@ -15,17 +15,21 @@ import com.ruoyi.lsfx.client.LsfxAnalysisClient;
import com.ruoyi.lsfx.domain.request.GetTokenRequest;
import com.ruoyi.lsfx.domain.response.GetTokenResponse;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import java.util.Date;
import java.util.Objects;
/**
* 项目Service实现类
*
* @author ruoyi
*/
@Slf4j
@Service
public class CcdiProjectServiceImpl implements ICcdiProjectService {
@@ -56,6 +60,9 @@ public class CcdiProjectServiceImpl implements ICcdiProjectService {
// 4. 保存到数据库
projectMapper.insert(project);
log.info("【项目】项目状态初始化: projectId={}, projectName={}, newStatus={}, newStatusLabel={}, operator={}",
project.getProjectId(), project.getProjectName(), project.getStatus(), resolveStatusLabel(project.getStatus()),
resolveOperator(project.getCreateBy()));
// 5. 返回VO
CcdiProjectVO vo = new CcdiProjectVO();
@@ -148,6 +155,7 @@ public class CcdiProjectServiceImpl implements ICcdiProjectService {
@Override
public void updateProjectStatus(Long projectId, String status, String operator) {
CcdiProject project = getRequiredProject(projectId);
String oldStatus = project.getStatus();
if (CcdiProjectStatusConstants.ARCHIVED.equals(project.getStatus())
&& !CcdiProjectStatusConstants.ARCHIVED.equals(status)) {
throw new ServiceException("已归档项目不允许重新进入打标流程");
@@ -156,6 +164,11 @@ public class CcdiProjectServiceImpl implements ICcdiProjectService {
project.setUpdateBy(operator);
project.setUpdateTime(new Date());
projectMapper.updateById(project);
if (!Objects.equals(oldStatus, status)) {
log.info("【项目】项目状态变更: projectId={}, projectName={}, oldStatus={}, oldStatusLabel={}, newStatus={}, newStatusLabel={}, operator={}",
project.getProjectId(), project.getProjectName(), oldStatus, resolveStatusLabel(oldStatus),
status, resolveStatusLabel(status), resolveOperator(operator));
}
}
@Override
@@ -182,6 +195,20 @@ public class CcdiProjectServiceImpl implements ICcdiProjectService {
return project;
}
private String resolveStatusLabel(String status) {
return switch (status) {
case CcdiProjectStatusConstants.PROCESSING -> "进行中";
case CcdiProjectStatusConstants.COMPLETED -> "已完成";
case CcdiProjectStatusConstants.ARCHIVED -> "已归档";
case CcdiProjectStatusConstants.TAGGING -> "打标中";
default -> "未知";
};
}
private String resolveOperator(String operator) {
return StringUtils.hasText(operator) ? operator : "system";
}
/**
* 调用流水分析平台获取projectId
*

103
ccdi-project/src/test/java/com/ruoyi/ccdi/project/service/impl/CcdiProjectServiceImplTest.java
View File

@@ -1,19 +1,28 @@
package com.ruoyi.ccdi.project.service.impl;
import ch.qos.logback.classic.Logger;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.core.read.ListAppender;
import com.ruoyi.ccdi.project.domain.CcdiProject;
import com.ruoyi.ccdi.project.domain.dto.CcdiProjectSaveDTO;
import com.ruoyi.ccdi.project.domain.vo.CcdiProjectStatusCountsVO;
import com.ruoyi.ccdi.project.mapper.CcdiProjectMapper;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.lsfx.client.LsfxAnalysisClient;
import com.ruoyi.lsfx.domain.response.GetTokenResponse;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;
import org.slf4j.LoggerFactory;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.when;
@ExtendWith(MockitoExtension.class)
@@ -58,4 +67,98 @@ class CcdiProjectServiceImplTest {
assertThrows(ServiceException.class,
() -> service.ensureProjectWritable(40L, "当前项目正在进行银行流水打标，暂不允许修改参数"));
}
@Test
void shouldLogProjectInitialStatusWhenProjectIsCreated() {
CcdiProjectSaveDTO dto = new CcdiProjectSaveDTO();
dto.setProjectName("专案A");
dto.setDescription("测试项目");
dto.setConfigType("default");
when(lsfxAnalysisClient.getToken(any())).thenReturn(buildTokenResponse(2001));
doAnswer(invocation -> {
CcdiProject project = invocation.getArgument(0);
project.setProjectId(88L);
return 1;
}).when(projectMapper).insert(any(CcdiProject.class));
Logger logger = (Logger) LoggerFactory.getLogger(CcdiProjectServiceImpl.class);
ListAppender<ILoggingEvent> logAppender = new ListAppender<>();
logAppender.start();
logger.addAppender(logAppender);
try {
service.createProject(dto);
assertTrue(logAppender.list.stream().map(ILoggingEvent::getFormattedMessage)
.anyMatch(message -> message.contains("项目状态初始化")
&& message.contains("projectId=88")
&& message.contains("projectName=专案A")
&& message.contains("newStatus=0")));
} finally {
logger.detachAppender(logAppender);
}
}
@Test
void shouldLogProjectStatusTransitionWhenStatusChanges() {
CcdiProject project = new CcdiProject();
project.setProjectId(40L);
project.setProjectName("专案B");
project.setStatus("0");
when(projectMapper.selectById(40L)).thenReturn(project);
Logger logger = (Logger) LoggerFactory.getLogger(CcdiProjectServiceImpl.class);
ListAppender<ILoggingEvent> logAppender = new ListAppender<>();
logAppender.start();
logger.addAppender(logAppender);
try {
service.updateProjectStatus(40L, "3", "tester");
assertTrue(logAppender.list.stream().map(ILoggingEvent::getFormattedMessage)
.anyMatch(message -> message.contains("项目状态变更")
&& message.contains("projectId=40")
&& message.contains("projectName=专案B")
&& message.contains("oldStatus=0")
&& message.contains("newStatus=3")
&& message.contains("operator=tester")));
} finally {
logger.detachAppender(logAppender);
}
}
@Test
void shouldNotLogProjectStatusTransitionWhenStatusDoesNotChange() {
CcdiProject project = new CcdiProject();
project.setProjectId(40L);
project.setProjectName("专案C");
project.setStatus("3");
when(projectMapper.selectById(40L)).thenReturn(project);
Logger logger = (Logger) LoggerFactory.getLogger(CcdiProjectServiceImpl.class);
ListAppender<ILoggingEvent> logAppender = new ListAppender<>();
logAppender.start();
logger.addAppender(logAppender);
try {
service.updateProjectStatus(40L, "3", "tester");
assertFalse(logAppender.list.stream().map(ILoggingEvent::getFormattedMessage)
.anyMatch(message -> message.contains("项目状态变更")
&& message.contains("projectId=40")));
} finally {
logger.detachAppender(logAppender);
}
}
private GetTokenResponse buildTokenResponse(Integer projectId) {
GetTokenResponse response = new GetTokenResponse();
response.setCode("200");
GetTokenResponse.TokenData data = new GetTokenResponse.TokenData();
data.setProjectId(projectId);
response.setData(data);
return response;
}
}