课堂活跃度最后统一计算

sclass/src/main/java/com/xhkjedu/sclass/controller/classroom/ClassroomController.java

@@ -68,6 +68,8 @@ public class ClassroomController {
             List<Integer> classlst = new ArrayList<>();//用于更新班级课堂状态
             for (RoomPVo r : rooms) {
                 savelst.add(r.getRoomid());
+                Integer classid = null;
+                Integer schoolid = null;
                 List<RoomParamVo> params = r.getParams();
                 for (RoomParamVo param : params) {
                     String rtype = param.getRtype();
@@ -76,6 +78,8 @@ public class ClassroomController {
                     if (rtype.equals("startclass")) {//课堂--开始
                         TClassroom room = JSON.parseObject(jsonstr, TClassroom.class);
                         classlst.add(room.getClassid());
+                        classid = room.getClassid();
+                        schoolid = room.getSchoolid();
                         boolean rtn = classroomService.startClass(room);//课堂是否重复请求
                         if (rtn) {
                             break;//课堂重复请求结束循环，执行下个课堂数据
@@ -103,6 +107,7 @@ public class ClassroomController {
                         classroomPaperService.saveStudentScantron(student);
                     }
                 }
+                classroomService.saveStuActive(r.getRoomid(), classid, schoolid);
             }
 
             //最后更新课堂中实际上课学生数量

sclass/src/main/java/com/xhkjedu/sclass/mapper/classroom/ClassroomActivestudentMapper.java

@@ -4,6 +4,8 @@ import com.xhkjedu.sclass.base.TkMapper;
 import com.xhkjedu.sclass.model.classroom.TClassroomActivestudent;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 public interface ClassroomActivestudentMapper extends TkMapper<TClassroomActivestudent> {
     /**
      * 更新活跃值排名
@@ -31,4 +33,11 @@ public interface ClassroomActivestudentMapper extends TkMapper<TClassroomActives
      * @return java.lang.Integer
      **/
     Integer saveStuActive(@Param("roomid") Long roomid, @Param("classid") Integer classid,@Param("schoolid") Integer schoolid);
+
+    //根据课堂id获取互动ids
+    String getAsktidsByRoomId(@Param("roomid") Long roomid);
+
+    //课堂学生
+    List<TClassroomActivestudent> listRoomStu(@Param("roomid") Long roomid, @Param("classid") Integer classid
+            ,@Param("asktids") String asktids);
 }

sclass/src/main/java/com/xhkjedu/sclass/service/classroom/ClassroomService.java

@@ -1,27 +1,8 @@
 package com.xhkjedu.sclass.service.classroom;
 
-import com.xhkjedu.sclass.mapper.classroom.ClassroomActivestudentMapper;
-import com.xhkjedu.sclass.mapper.classroom.ClassroomAskstudentMapper;
-import com.xhkjedu.sclass.mapper.classroom.ClassroomAskteacherMapper;
-import com.xhkjedu.sclass.mapper.classroom.ClassroomFileMapper;
-import com.xhkjedu.sclass.mapper.classroom.ClassroomMapper;
-import com.xhkjedu.sclass.mapper.classroom.ClassroomPaperFileMapper;
-import com.xhkjedu.sclass.mapper.classroom.ClassroomSignMapper;
-import com.xhkjedu.sclass.model.classroom.TClassroom;
-import com.xhkjedu.sclass.model.classroom.TClassroomAskstudent;
-import com.xhkjedu.sclass.model.classroom.TClassroomAskteacher;
-import com.xhkjedu.sclass.model.classroom.TClassroomFile;
-import com.xhkjedu.sclass.model.classroom.TClassroomPaperFile;
-import com.xhkjedu.sclass.model.classroom.TClassroomSign;
-import com.xhkjedu.sclass.vo.classroom.ObjectiveVo;
-import com.xhkjedu.sclass.vo.classroom.ReportEQuestionVo;
-import com.xhkjedu.sclass.vo.classroom.ReportExamVo;
-import com.xhkjedu.sclass.vo.classroom.ReportRoomVo;
-import com.xhkjedu.sclass.vo.classroom.RoomCorrectCallVo;
-import com.xhkjedu.sclass.vo.classroom.RoomCorrectExamVo;
-import com.xhkjedu.sclass.vo.classroom.RoomCorrectVo;
-import com.xhkjedu.sclass.vo.classroom.RoomVo;
-import com.xhkjedu.sclass.vo.classroom.SubjectiveVo;
+import com.xhkjedu.sclass.mapper.classroom.*;
+import com.xhkjedu.sclass.model.classroom.*;
+import com.xhkjedu.sclass.vo.classroom.*;
 import com.xhkjedu.sclass.vo.paper.CheckClassVo;
 import com.xhkjedu.utils.N_Utils;
 import com.xhkjedu.vo.ResultVo;
@@ -32,8 +13,10 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 import javax.annotation.Resource;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -69,11 +52,11 @@ public class ClassroomService {
             Integer num = classroomMapper.getStudentNumById(room.getClassid());//根据班级id获取学生数量
             room.setClassnum(num);
             classroomMapper.save(room);
-            classroomActivestudentMapper.saveStuActive(room.getRoomid(), room.getClassid(), room.getSchoolid());
+            //classroomActivestudentMapper.saveStuActive(room.getRoomid(), room.getClassid(), room.getSchoolid());
         } catch (Exception e) {
             if (e instanceof DuplicateKeyException) {
                 rtn = true;
-                log.error("接口重复请求，课堂id：" + room.getRoomid() + ",课堂名称：" + room.getRoomname());
+                log.error("课堂数据已保存，课堂id：" + room.getRoomid() + ",课堂名称：" + room.getRoomname());
             } else {
                 log.error("开始课堂失败：" + e.getMessage());
             }
@@ -99,7 +82,7 @@ public class ClassroomService {
                 room.setEndtime(tClassroom.getCreatetime() + 60 * 45);
             }
             classroomMapper.endClass(room);//结束课堂
-            classroomActivestudentMapper.updateActiveRank(roomid);//更新活跃值排名
+            //classroomActivestudentMapper.updateActiveRank(roomid);//更新活跃值排名
         } catch (Exception e) {
             log.error("结束课堂失败：" + e.getMessage());
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -124,7 +107,7 @@ public class ClassroomService {
                 classroomSignMapper.save(sign);
                 //如果一个学生退出课堂再进来数据就不对了，最后计算
                 //classroomMapper.updateRealStuNum(sign.getRoomid());//更新班级实际签到学生数量
-                classroomActivestudentMapper.updateActiveNum(roomid, userid);//更新学生活跃值
+                //classroomActivestudentMapper.updateActiveNum(roomid, userid);//更新学生活跃值
             }
         } catch (Exception e) {
             log.error("保存学生签到信息失败：" + e.getMessage());
@@ -191,7 +174,7 @@ public class ClassroomService {
             }
             classroomAskstudentMapper.save(student);
             //保存成功更新学生活跃值
-            classroomActivestudentMapper.updateActiveNum(student.getRoomid(), student.getStudentid());
+            //classroomActivestudentMapper.updateActiveNum(student.getRoomid(), student.getStudentid());
         } catch (Exception e) {
             log.error("保存学生作答情况失败：" + e.getMessage());
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
@@ -459,4 +442,35 @@ public class ClassroomService {
     public List<Map> listStudent(Integer classid, String lsbid) {
         return classroomMapper.listStudent(classid, lsbid);
     }
+
+    //更新学生活跃度 2022/10/17 课堂活跃度最后统一计算
+    public void saveStuActive(Long roomid, Integer classid, Integer schoolid) {
+        String asktids = classroomActivestudentMapper.getAsktidsByRoomId(roomid);
+        List<TClassroomActivestudent> students = classroomActivestudentMapper.listRoomStu(roomid, classid, asktids);
+        if(N_Utils.isListEmpty(students)) return;
+        Map<Integer, Integer> rank=new HashMap<>();
+        setRank(students,rank);//计算排名
+        int timestamp = N_Utils.getSecondTimestamp();
+        students.forEach(s -> {
+            s.setRoomid(roomid);
+            s.setSchoolid(schoolid);
+            s.setActiverank(rank.get(s.getActivenum()));
+            s.setCreatetime(timestamp);
+        });
+        classroomActivestudentMapper.insertList(students);
+    }
+
+    //计算排名
+    private void setRank(List<TClassroomActivestudent> students, Map<Integer, Integer> rank) {
+        List<Map.Entry<Integer, List<TClassroomActivestudent>>> gslist2 = students.stream()
+                .collect(Collectors.groupingBy(TClassroomActivestudent::getActivenum)).entrySet()
+                .stream().sorted((s1, s2) -> -Double.compare(s1.getKey(), s2.getKey())).collect(Collectors.toList());
+        Integer index = 1;
+        for (Map.Entry<Integer, List<TClassroomActivestudent>> entry : gslist2) {
+            for (TClassroomActivestudent cs : entry.getValue()) {
+                rank.put(cs.getActivenum(), index);
+            }
+            index = index + entry.getValue().size();
+        }
+    }
 }

sclass/src/main/resources/mapper/classroom/ClassroomActivestudentMapper.xml

@@ -18,4 +18,18 @@
         insert into t_classroom_activestudent(roomid,studentid,createtime,schoolid)
         SELECT #{roomid},s.studentid,UNIX_TIMESTAMP(),#{schoolid} FROM t_class_student s WHERE s.classid=#{classid}
     </insert>
+    <!--根据课堂id获取互动ids-->
+    <select id="getAsktidsByRoomId" resultType="java.lang.String">
+        select group_concat(asktid) from t_classroom_askteacher where roomid=#{roomid}
+    </select>
+    <!--课堂学生-->
+    <select id="listRoomStu" resultType="com.xhkjedu.sclass.model.classroom.TClassroomActivestudent">
+        select cs.studentid,(
+            (select count(distinct s.userid) from t_classroom_sign s where s.roomid=#{roomid} and s.userid=cs.studentid)
+        <if test="asktids!=null and asktids!=''">
+            +(select count(*) from t_classroom_askstudent s where s.asktid in(${asktids}) and s.studentid=cs.studentid)
+        </if>
+        )activenum
+        from t_class_student cs where cs.classid=#{classid}
+    </select>
 </mapper>