|
|
@@ -11,6 +11,7 @@ import com.xunmei.common.core.constant.ErrorMsgConstants;
|
|
|
import com.xunmei.common.core.constant.SecurityConstants;
|
|
|
import com.xunmei.common.core.domain.edu.dto.SysLearningMaterialsPageDto;
|
|
|
import com.xunmei.common.core.domain.edu.vo.SysLearningMaterialsPageVo;
|
|
|
+import com.xunmei.common.core.domain.letter.dto.CoreIntroduceLetterApproveRequestDto;
|
|
|
import com.xunmei.common.core.domain.message.dto.CoreAnnouncementNotificationAppPageDto;
|
|
|
import com.xunmei.common.core.domain.message.vo.MessageAppPageVo;
|
|
|
import com.xunmei.common.core.domain.panel.adapter.PanelAdapter;
|
|
|
@@ -26,6 +27,7 @@ import com.xunmei.core.edu.service.ICoreEduTrainingTaskService;
|
|
|
import com.xunmei.core.edu.service.ISysLearningMaterialsService;
|
|
|
import com.xunmei.core.evaluate.service.ICoreEvaluateTaskService;
|
|
|
import com.xunmei.core.letter.service.ICoreIntroduceLetterService;
|
|
|
+import com.xunmei.core.letter.service.ICoreOutInRecordService;
|
|
|
import com.xunmei.core.message.service.ICoreAnnouncementNotificationService;
|
|
|
import com.xunmei.core.panel.service.PanelService;
|
|
|
import com.xunmei.core.question.service.IQuestionService;
|
|
|
@@ -92,6 +94,7 @@ public class PanelServiceImpl implements PanelService {
|
|
|
@Autowired
|
|
|
private ICoreAnnouncementNotificationService notificationService;
|
|
|
|
|
|
+
|
|
|
@Override
|
|
|
public List<PanelResultVo> selectPage() throws ExecutionException, InterruptedException, TimeoutException {
|
|
|
List<Long> roles = RemoteCallHandlerExecutor.executeRemoteCall(
|
|
|
@@ -144,9 +147,16 @@ public class PanelServiceImpl implements PanelService {
|
|
|
CompletableFuture<List<PanelListVo>> questionTaskFuture = CompletableFuture.supplyAsync(() ->
|
|
|
questionService.selectCurUserTaskList(panelListDto), threadPoolTaskExecutor
|
|
|
);
|
|
|
+
|
|
|
+ //出入审批
|
|
|
+ CompletableFuture<List<PanelListVo>> letterOutInFuture = CompletableFuture.supplyAsync(() ->
|
|
|
+
|
|
|
+ coreIntroduceLetterService.selectToDoApproveListForAPP(panelListDto), threadPoolTaskExecutor
|
|
|
+ );
|
|
|
+
|
|
|
CompletableFuture<Void> allQueries = CompletableFuture.allOf(
|
|
|
resumptionTaskFuture, protectionTaskFuture, monitorTaskFuture, evaluateTaskFuture,
|
|
|
- safetyTaskFuture, drillTaskFuture, eduTrainingTaskFuture, recLitFuture
|
|
|
+ safetyTaskFuture, drillTaskFuture, eduTrainingTaskFuture, recLitFuture,questionTaskFuture, letterOutInFuture
|
|
|
);
|
|
|
|
|
|
allQueries.get(TIMEOUT, TimeUnit.SECONDS);
|
|
|
@@ -154,7 +164,7 @@ public class PanelServiceImpl implements PanelService {
|
|
|
List<PanelListVo> resultList = Stream.of(
|
|
|
resumptionTaskFuture.join(), protectionTaskFuture.join(), monitorTaskFuture.join(), evaluateTaskFuture.join(),
|
|
|
safetyTaskFuture.join(), drillTaskFuture.join(), eduTrainingTaskFuture.join(), recLitFuture.join(),
|
|
|
- questionTaskFuture.join()
|
|
|
+ questionTaskFuture.join(),letterOutInFuture.join()
|
|
|
)
|
|
|
.flatMap(Collection::stream)
|
|
|
.collect(Collectors.toList());
|