add(feature/REQ-3714) 判空,删除工种

This commit is contained in:
zhangran 2025-03-21 11:55:28 +08:00
parent bb233e3c0d
commit ddacfb236c
4 changed files with 31 additions and 17 deletions

View File

@ -17,8 +17,8 @@ import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
/**
* @author zhanghongbo
@ -60,12 +60,15 @@ public class WorkerProfessionSkillTagRepositoryImpl implements WorkerProfessionS
return;
}
List<WorkerProfessionSkillTag> delete = ids.stream().map(id -> {
WorkerProfessionSkillTag workerProfessionSkillTag = new WorkerProfessionSkillTag();
workerProfessionSkillTag.setId(id);
workerProfessionSkillTag.setIsDelete(id);
return workerProfessionSkillTag;
}).collect(Collectors.toList());
workerProfessionSkillTagDao.updateBatchById(delete);
List<WorkerProfessionSkillTag> skillTags = workerProfessionSkillTagDao.listByIds(ids);
if (CollUtil.isEmpty(skillTags)) {
return ;
}
Date date = new Date();
skillTags.forEach(skillTag -> {
skillTag.setIsDelete(skillTag.getId());
skillTag.setUpdateAt(date);
});
workerProfessionSkillTagDao.updateBatchById(skillTags);
}
}

View File

@ -16,8 +16,8 @@ import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
/**
* @author zhanghongbo
@ -58,12 +58,16 @@ public class WorkerProfessionTagRepositoryImpl implements WorkerProfessionTagRep
if (CollUtil.isEmpty(ids)) {
return ;
}
List<WorkerProfessionTag> delete = ids.stream().map(id -> {
WorkerProfessionTag workerProfessionTag = new WorkerProfessionTag();
workerProfessionTag.setId(id);
workerProfessionTag.setIsDelete(id);
return workerProfessionTag;
}).collect(Collectors.toList());
workerProfessionTagDao.updateBatchById(delete);
List<WorkerProfessionTag> workerProfessionTags = workerProfessionTagDao.listByIds(ids);
if (CollUtil.isEmpty(workerProfessionTags)) {
return ;
}
Date date = new Date();
workerProfessionTags.forEach(workerProfessionTag -> {
workerProfessionTag.setIsDelete(workerProfessionTag.getId());
workerProfessionTag.setUpdateAt(date);
});
workerProfessionTagDao.updateBatchById(workerProfessionTags);
}
}

View File

@ -161,7 +161,7 @@ public class DeletePlatTeamWorkerProcessor implements NodeUserProcessor {
nodeUserFoundationService.delete(nodeUserDelete);
// 删除平台工人工种和技能标签
DeleteWorkerProfession workerProfession = DeleteWorkerProfession.builder()
.scene(TeamSceneEnum.PROJECT_TEAM.name())
.scene(TeamSceneEnum.PLAT_TEAM.name())
.personIds(param.getPersonIds())
.isResign(Boolean.TRUE)
.orgNodeId(nodeId)
@ -212,6 +212,9 @@ public class DeletePlatTeamWorkerProcessor implements NodeUserProcessor {
queryBo.setStatusList(Arrays.asList(WorkerInviteStatusEnum.WAIT_LEADER_APPROVE.getValue(), WorkerInviteStatusEnum.WAIT_LABOUR_APPROVE.getValue()));
queryBo.setIncludeDeleted(Boolean.FALSE);
List<ProjectWorkerInviteRepository.ProjectWorkerInviteResp> workerInvites = projectWorkerInviteRepository.list(queryBo);
if (CollUtil.isEmpty(workerInvites)) {
return ;
}
List<Long> inviteIds = workerInvites.stream().map(ProjectWorkerInviteRepository.ProjectWorkerInviteResp::getId).collect(Collectors.toList());
List<String> processInstanceIds = workerInvites.stream().map(ProjectWorkerInviteRepository.ProjectWorkerInviteResp::getProcessInstanceId).filter(StringUtils::hasText).collect(Collectors.toList());

View File

@ -19,6 +19,7 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@ -110,12 +111,15 @@ public class OrgWorkerHistoryFoundationServiceImpl implements OrgWorkerHistoryFo
.jsonStrData(professionSkillTags)
.build());
}
Date date = new Date();
return WorkerProfessionHistory.builder()
.personId(first.getPersonId())
.orgNodeId(first.getOrgNodeId())
.workspaceId(first.getWorkspaceId())
.bizData(first.getBizData())
.jsonContent(JSON.toJSONString(historyDataList))
.createAt(date)
.updateAt(date)
.build();
}
}