zcloud_gbs
/
zcloud_gbs_domain
11
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

消息待办

master
zhaokai 2026-04-03 17:43:33 +08:00
parent 824f448f4f
commit 033160a095
2 changed files with 31 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
web-app/src/main/java/com/zcloud/domain/command/ProjectTaskGroupUserAddExe.java
View File

@ -12,8 +12,11 @@ import com.zcloud.domain.persistence.dataobject.ProjectTaskDO;
import com.zcloud.domain.persistence.dataobject.ProjectTaskGroupUserDO; import com.zcloud.domain.persistence.dataobject.ProjectTaskGroupUserDO;
import com.zcloud.domain.persistence.repository.ProjectTaskGroupUserRepository; import com.zcloud.domain.persistence.repository.ProjectTaskGroupUserRepository;
import com.zcloud.domain.persistence.repository.ProjectTaskRepository; import com.zcloud.domain.persistence.repository.ProjectTaskRepository;
import com.zcloud.gbscommon.todolistmq.TodoListEventPusherUtil;
import com.zcloud.gbscommon.todolistmq.event.TodoListCompleteEvent;
import com.zcloud.gbscommon.utils.Tools; import com.zcloud.gbscommon.utils.Tools;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -31,12 +34,13 @@ import java.util.List;
*/ */
@Component @Component
@AllArgsConstructor @AllArgsConstructor
@Slf4j
public class ProjectTaskGroupUserAddExe { public class ProjectTaskGroupUserAddExe {
private final ProjectTaskGroupUserGateway projectTaskGroupUserGateway; private final ProjectTaskGroupUserGateway projectTaskGroupUserGateway;
private final ProjectTaskGroupUserCoConvertor projectTaskGroupUserCoConvertor; private final ProjectTaskGroupUserCoConvertor projectTaskGroupUserCoConvertor;
private final ProjectTaskGroupUserRepository projectTaskGroupUserRepository; private final ProjectTaskGroupUserRepository projectTaskGroupUserRepository;
private final ProjectTaskRepository projectTaskRepository; private final ProjectTaskRepository projectTaskRepository;
private final TodoListEventPusherUtil todoListEventPusherUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(ProjectTaskGroupUserAddCmd cmd) { public boolean execute(ProjectTaskGroupUserAddCmd cmd) {
ProjectTaskGroupUserE projectTaskGroupUserE = new ProjectTaskGroupUserE(); ProjectTaskGroupUserE projectTaskGroupUserE = new ProjectTaskGroupUserE();
@ -88,7 +92,16 @@ public class ProjectTaskGroupUserAddExe {
code = ProjectTaskExecuteStatusEnum.WAIT_PERFECT.getCode(); code = ProjectTaskExecuteStatusEnum.WAIT_PERFECT.getCode();
} }
projectTaskRepository.updateExecuteStatusBatchById(code, Arrays.asList(projectTaskDO.getId())); projectTaskRepository.updateExecuteStatusBatchById(code, Arrays.asList(projectTaskDO.getId()));
try{
//评分完成待办
TodoListCompleteEvent event1 = new TodoListCompleteEvent();
event1.setForeignSubsidiaryKey(projectTaskDO.getId());// 业务附表ID 没有附表时为foreignKey的值
log.info("完成待办,请求：{}",projectTaskDO.getId());
boolean b = todoListEventPusherUtil.sendMessageCompleteEvent(event1);
log.info("完成待办,结果：{}",b);
}catch (Exception e){
log.error("删除待办失败",e);
}
} }
} }

17
web-app/src/main/java/com/zcloud/domain/command/ProjectTaskScoreInfoAddExe.java
View File

@ -14,8 +14,11 @@ import com.zcloud.domain.persistence.dataobject.ProjectTaskGroupUserDO;
import com.zcloud.domain.persistence.dataobject.ProjectTaskScoreInfoDO; import com.zcloud.domain.persistence.dataobject.ProjectTaskScoreInfoDO;
import com.zcloud.domain.persistence.repository.ProjectTaskRepository; import com.zcloud.domain.persistence.repository.ProjectTaskRepository;
import com.zcloud.domain.persistence.repository.ProjectTaskScoreInfoRepository; import com.zcloud.domain.persistence.repository.ProjectTaskScoreInfoRepository;
import com.zcloud.gbscommon.todolistmq.TodoListEventPusherUtil;
import com.zcloud.gbscommon.todolistmq.event.TodoListCompleteEvent;
import com.zcloud.gbscommon.utils.Tools; import com.zcloud.gbscommon.utils.Tools;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
@ -33,12 +36,13 @@ import java.util.List;
*/ */
@Component @Component
@AllArgsConstructor @AllArgsConstructor
@Slf4j
public class ProjectTaskScoreInfoAddExe { public class ProjectTaskScoreInfoAddExe {
private final ProjectTaskScoreInfoGateway projectTaskScoreInfoGateway; private final ProjectTaskScoreInfoGateway projectTaskScoreInfoGateway;
private final ProjectTaskScoreInfoCoConvertor projectTaskScoreInfoCoConvertor; private final ProjectTaskScoreInfoCoConvertor projectTaskScoreInfoCoConvertor;
private final ProjectTaskScoreInfoRepository projectTaskScoreInfoRepository; private final ProjectTaskScoreInfoRepository projectTaskScoreInfoRepository;
private final ProjectTaskRepository projectTaskRepository; private final ProjectTaskRepository projectTaskRepository;
private final TodoListEventPusherUtil todoListEventPusherUtil;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean execute(ProjectTaskScoreInfoAddCmd cmd) { public boolean execute(ProjectTaskScoreInfoAddCmd cmd) {
@ -90,6 +94,17 @@ public class ProjectTaskScoreInfoAddExe {
} }
projectTaskRepository.updateExecuteStatusBatchById(code, Arrays.asList(projectTaskDO.getId())); projectTaskRepository.updateExecuteStatusBatchById(code, Arrays.asList(projectTaskDO.getId()));
try{
//评分完成待办
TodoListCompleteEvent event1 = new TodoListCompleteEvent();
event1.setForeignSubsidiaryKey(projectTaskDO.getId());// 业务附表ID 没有附表时为foreignKey的值
log.info("完成待办,请求：{}",projectTaskDO.getId());
boolean b = todoListEventPusherUtil.sendMessageCompleteEvent(event1);
log.info("完成待办,结果：{}",b);
}catch (Exception e){
log.error("删除待办失败",e);
}
} }
} }