统计人数

core/src/main/java/com/mooctest/crowd/domain/dao/UserTaskCountDao.java

@@ -2,7 +2,10 @@ package com.mooctest.crowd.domain.dao;
 
 import com.mooctest.crowd.domain.model.UserTaskCountPO;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.CrudRepository;
+import org.springframework.data.repository.query.Param;
 
 import javax.transaction.Transactional;
 import java.util.List;
@@ -17,4 +20,10 @@ public interface UserTaskCountDao extends CrudRepository<UserTaskCountPO, Long>,
 
     Optional<UserTaskCountPO> findById(Long id);
 
+    List<UserTaskCountPO> findAll();
+
+    @Modifying
+    @Query(nativeQuery = true,value="UPDATE user_task_count SET UTC_COUNT=?1 WHERE UTC_USER_ID=?2")
+    void updateCount(@Param("userId") long userId,@Param("count") long count);
+
 }

site/src/main/java/com/mooctest/crowd/site/mediator/ViewMediator.java

@@ -125,5 +125,5 @@ List<CrowdTestProjectVO>   AllByPage();
 
     List<CrowdTestProjectVO> crowdTestProjectsWaitingAccept();
 
-    UserTaskCountVO getCount();
+    List<UserTaskCountVO> getCount();
 }

site/src/main/java/com/mooctest/crowd/site/mediator/impl/WebMediatorImpl.java

@@ -1130,9 +1130,21 @@ public class WebMediatorImpl implements ViewMediator {
     }
 
     @Override
-    public UserTaskCountVO getCount() {
+    public List<UserTaskCountVO> getCount() {
         List<RankCountInfo> rankCountInfos = taskToUserDao.findTotalCountOfUser();
-        return null;
+        for(int i=0;i<rankCountInfos.size();i++){
+            userTaskCountDao.updateCount(rankCountInfos.get(i).getEntityId(),rankCountInfos.get(i).getCount());
+        }
+        List<UserTaskCountVO> userTaskCountVOList = new ArrayList<>();
+        userTaskCountDao.findAll().forEach(userTaskCountPO ->{
+            UserTaskCountVO userTaskCountVO =new UserTaskCountVO();
+            userTaskCountVO.setId(userTaskCountPO.getId());
+            userTaskCountVO.setUserId(userTaskCountPO.getUserId());
+            userTaskCountVO.setCount(userTaskCountPO.getCount());
+            userTaskCountVO.setType(userTaskCountPO.getType());
+            userTaskCountVOList.add(userTaskCountVO);
+        });
+        return userTaskCountVOList;
     }
 
     @Override

site/src/main/java/com/mooctest/crowd/site/service/CommonService.java

@@ -48,5 +48,5 @@ public interface CommonService {
 
     DataDTO getAllData();
 
-    UserTaskCountVO getCount();
+    List<UserTaskCountVO> getCount();
 }

site/src/main/java/com/mooctest/crowd/site/service/impl/CommonServiceImpl.java

@@ -199,8 +199,8 @@ public class CommonServiceImpl implements CommonService {
     }
 
     @Override
-    public UserTaskCountVO getCount() {
-        return null;
+    public List<UserTaskCountVO> getCount() {
+        return viewMediator.getCount();
     }
 
     Pageable getPageable(SearchConditionVO searchConditionVO) {