diff --git a/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskGroupUserAddExe.java b/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskGroupUserAddExe.java index bc39bb8..bce2d00 100644 --- a/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskGroupUserAddExe.java +++ b/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskGroupUserAddExe.java @@ -12,8 +12,11 @@ import com.zcloud.domain.persistence.dataobject.ProjectTaskDO; import com.zcloud.domain.persistence.dataobject.ProjectTaskGroupUserDO; import com.zcloud.domain.persistence.repository.ProjectTaskGroupUserRepository; 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 lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; @@ -31,12 +34,13 @@ import java.util.List; */ @Component @AllArgsConstructor +@Slf4j public class ProjectTaskGroupUserAddExe { private final ProjectTaskGroupUserGateway projectTaskGroupUserGateway; private final ProjectTaskGroupUserCoConvertor projectTaskGroupUserCoConvertor; private final ProjectTaskGroupUserRepository projectTaskGroupUserRepository; private final ProjectTaskRepository projectTaskRepository; - + private final TodoListEventPusherUtil todoListEventPusherUtil; @Transactional(rollbackFor = Exception.class) public boolean execute(ProjectTaskGroupUserAddCmd cmd) { ProjectTaskGroupUserE projectTaskGroupUserE = new ProjectTaskGroupUserE(); @@ -88,7 +92,16 @@ public class ProjectTaskGroupUserAddExe { code = ProjectTaskExecuteStatusEnum.WAIT_PERFECT.getCode(); } 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); + } } } diff --git a/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskScoreInfoAddExe.java b/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskScoreInfoAddExe.java index 8b97460..8dac212 100644 --- a/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskScoreInfoAddExe.java +++ b/web-app/src/main/java/com/zcloud/domain/command/ProjectTaskScoreInfoAddExe.java @@ -14,8 +14,11 @@ import com.zcloud.domain.persistence.dataobject.ProjectTaskGroupUserDO; import com.zcloud.domain.persistence.dataobject.ProjectTaskScoreInfoDO; import com.zcloud.domain.persistence.repository.ProjectTaskRepository; 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 lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; @@ -33,12 +36,13 @@ import java.util.List; */ @Component @AllArgsConstructor +@Slf4j public class ProjectTaskScoreInfoAddExe { private final ProjectTaskScoreInfoGateway projectTaskScoreInfoGateway; private final ProjectTaskScoreInfoCoConvertor projectTaskScoreInfoCoConvertor; private final ProjectTaskScoreInfoRepository projectTaskScoreInfoRepository; private final ProjectTaskRepository projectTaskRepository; - + private final TodoListEventPusherUtil todoListEventPusherUtil; @Transactional(rollbackFor = Exception.class) public boolean execute(ProjectTaskScoreInfoAddCmd cmd) { @@ -90,6 +94,17 @@ public class ProjectTaskScoreInfoAddExe { } 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); + } + } }