|
@@ -371,6 +371,23 @@ public class WebMediatorImpl implements ViewMediator {
|
|
|
agencyVOS = agencyVOList;
|
|
|
}
|
|
|
|
|
|
+ // 获取热门任务
|
|
|
+
|
|
|
+ List<CrowdTaskVO> taskVOList = taskDao.findMoreHotTasks().stream().map(crowdTestTaskPO -> {
|
|
|
+ CrowdTestTask task = new CrowdTestTask();
|
|
|
+ BeanUtils.copyProperties(crowdTestTaskPO, task);
|
|
|
+ return new CrowdTaskVO(task);
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+
|
|
|
+ List<CrowdTaskVO> taskVOS = new ArrayList<>();
|
|
|
+ if (taskVOList.size() > top) {
|
|
|
+ for (int i = 0; i < top; i++) {
|
|
|
+ taskVOS.add(taskVOList.get(i));
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ taskVOS = taskVOList;
|
|
|
+ }
|
|
|
+
|
|
|
// 获取合作机构
|
|
|
// List<Partner> partnerList = commonRepo.getAllPartner();
|
|
|
// List<PartnerVO> partnerVOS = partnerList.stream().map(partner -> {
|
|
@@ -384,6 +401,7 @@ public class WebMediatorImpl implements ViewMediator {
|
|
|
indexInfoDTO.setCompetitionList(competitionVOS);
|
|
|
indexInfoDTO.setResidentAgencyList(agencyVOS);
|
|
|
// indexInfoDTO.setPartnerList(partnerVOS);
|
|
|
+ indexInfoDTO.setTaskList(taskVOS);
|
|
|
return indexInfoDTO;
|
|
|
}
|
|
|
|
|
@@ -1272,18 +1290,28 @@ public class WebMediatorImpl implements ViewMediator {
|
|
|
@Override
|
|
|
public List<CrowdTaskVO> crowdTaskVos(){
|
|
|
List<CrowdTaskVO> authingList = new ArrayList<>();
|
|
|
+ Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
authingList.addAll(taskDao.findindexTask().stream().filter(crowdTestTaskPO -> crowdTestTaskPO.getDeadTime().getTime() > System.currentTimeMillis()).map(crowdTestTaskPO -> {
|
|
|
- //根据code值查询出来该任务的type
|
|
|
- Optional<TestTypePO> serviceType = testTypeDao.findByCode(crowdTestTaskPO.getType());
|
|
|
CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
|
BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
|
- crowdTestTask.setType(serviceType.get().getName());
|
|
|
+ crowdTestTask.setType(typeMap.get(crowdTestTaskPO.getType()));
|
|
|
return new CrowdTaskVO(crowdTestTask);
|
|
|
}).collect(Collectors.toList()));
|
|
|
return authingList;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ public List<CrowdTaskVO> crowdTaskVOSByTestTypeCode(String testTypeCode) {
|
|
|
+ Map<String, String> typeMap = commonRepo.getTypeCodeNameMap();
|
|
|
+ return taskDao.findByType(testTypeCode).stream().map(crowdTestTaskPO -> {
|
|
|
+ CrowdTestTask crowdTestTask = new CrowdTestTask();
|
|
|
+ BeanUtils.copyProperties(crowdTestTaskPO, crowdTestTask);
|
|
|
+ crowdTestTask.setType(typeMap.get(crowdTestTaskPO.getType()));
|
|
|
+ return new CrowdTaskVO(crowdTestTask);
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
public List<CrowdTaskVO> crowdTaskVosWaitingAccept() {
|
|
|
List<CrowdTestTaskPO> canAcceptTask = taskDao.findCanAcceptTask();
|
|
|
List<CrowdTaskVO> taskVOList = canAcceptTask.stream().filter(crowdTestTaskPO -> crowdTestTaskPO.getDeadTime().getTime() > System.currentTimeMillis()).map(crowdTestTaskPO -> {
|