wanghu
@@ -0,0 +1,170 @@
|
||||
package com.yunhai.homework.service.impl;
|
||||
|
||||
import com.yunhai.homework.model.bsch.SchClassDto;
|
||||
import com.yunhai.homework.model.bsch.SchInfoDto;
|
||||
import com.yunhai.homework.model.bsch.SchStudentDto;
|
||||
import com.yunhai.homework.service.IClassService;
|
||||
import com.yunhai.homework.utils.UserContext;
|
||||
import com.yunhai.platform.apistd.BizException;
|
||||
import com.yunhai.platform.utils.exception.ErrorCode;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collection;
|
||||
import java.util.Collections;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.LinkedHashSet;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
/**
|
||||
* 实时名册门面（bschclass 直连，无本地快照）：
|
||||
* 学生名单 GetClaArrStulist（按班级集合）、全校学生 GetSchStulist（学生端身份）、
|
||||
* 班级名 GetVClassList 映射、学校 GUID GetUserSchFirst。
|
||||
* 班级ID/学生ID 均为用户中心数字ID 域（classId 即 bschclass sch_class.class_id）。
|
||||
*/
|
||||
@Service
|
||||
public class RosterService {
|
||||
|
||||
private static final Logger log = LoggerFactory.getLogger(RosterService.class);
|
||||
|
||||
private final IClassService classService;
|
||||
|
||||
public RosterService(IClassService classService) {
|
||||
this.classService = classService;
|
||||
}
|
||||
|
||||
/**
|
||||
* 名册条目：进度聚合/学生矩阵/提醒名单共用的 班级×学生 维度。
|
||||
*/
|
||||
public static class RosterEntry {
|
||||
public Integer studentId;
|
||||
public String studentName;
|
||||
public Integer classId;
|
||||
public String className;
|
||||
}
|
||||
|
||||
/**
|
||||
* 指定班级集合的在班学生（实时 bschclass GetClaArrStulist，一次批量外呼）。
|
||||
* 同班同学生去重；班级名经 GetVClassList 映射，缺失回退班级ID。
|
||||
*/
|
||||
public List<RosterEntry> roster(List<Integer> classIds) {
|
||||
if (classIds == null || classIds.isEmpty()) {
|
||||
return new ArrayList<>();
|
||||
}
|
||||
Map<Integer, String> names = classNames(classIds);
|
||||
Map<String, RosterEntry> distinct = new LinkedHashMap<>();
|
||||
for (SchStudentDto s : classService.getClaArrStuList(classIds)) {
|
||||
if (s == null || s.getStuId() == null || s.getClassId() == null || !classIds.contains(s.getClassId())) {
|
||||
continue;
|
||||
}
|
||||
RosterEntry e = new RosterEntry();
|
||||
e.studentId = s.getStuId();
|
||||
e.studentName = s.getStuName();
|
||||
e.classId = s.getClassId();
|
||||
e.className = names.getOrDefault(s.getClassId(), String.valueOf(s.getClassId()));
|
||||
distinct.putIfAbsent(s.getClassId() + ":" + s.getStuId(), e);
|
||||
}
|
||||
return new ArrayList<>(distinct.values());
|
||||
}
|
||||
|
||||
/**
|
||||
* 指定班级的在班学生数（一次批量外呼按班级分组计数；传入班级无学生计 0）。
|
||||
*/
|
||||
public Map<Integer, Integer> studentCounts(List<Integer> classIds) {
|
||||
Map<Integer, Integer> counts = new LinkedHashMap<>();
|
||||
for (Integer classId : classIds == null ? Collections.<Integer>emptyList() : classIds) {
|
||||
counts.put(classId, 0);
|
||||
}
|
||||
for (RosterEntry e : roster(classIds)) {
|
||||
counts.merge(e.classId, 1, Integer::sum);
|
||||
}
|
||||
return counts;
|
||||
}
|
||||
|
||||
/**
|
||||
* 班级ID → 班级名（bschclass GetVClassList 映射）。
|
||||
* 远端不可用或无学校身份时降级为空映射，由调用方回退班级ID展示，不阻断名单本身。
|
||||
*/
|
||||
public Map<Integer, String> classNames(Collection<Integer> classIds) {
|
||||
Map<Integer, String> names = new LinkedHashMap<>();
|
||||
if (classIds == null || classIds.isEmpty()) {
|
||||
return names;
|
||||
}
|
||||
try {
|
||||
String schSerId = currentSchSerId();
|
||||
if (schSerId == null) {
|
||||
return names;
|
||||
}
|
||||
Set<Integer> pending = new LinkedHashSet<>(classIds);
|
||||
for (SchClassDto c : classService.getSchClassList(schSerId)) {
|
||||
if (c != null && c.getClassId() != null && pending.remove(c.getClassId())
|
||||
&& StringUtils.hasText(c.getClassName())) {
|
||||
names.put(c.getClassId(), c.getClassName());
|
||||
}
|
||||
}
|
||||
} catch (BizException e) {
|
||||
log.warn("[roster] 班级名称映射失败, 回退班级ID展示: {}", e.getMessage());
|
||||
}
|
||||
return names;
|
||||
}
|
||||
|
||||
/** 班级ID → 班级名（单班便捷方法，缺失回退班级ID） */
|
||||
public String className(Integer classId) {
|
||||
if (classId == null) {
|
||||
return null;
|
||||
}
|
||||
String name = classNames(Collections.singletonList(classId)).get(classId);
|
||||
return StringUtils.hasText(name) ? name : String.valueOf(classId);
|
||||
}
|
||||
|
||||
/**
|
||||
* 当前登录学生所在班级条目（实时 bschclass 全校学生按登录人用户ID过滤）。
|
||||
* 学生ID = 登录人用户中心数字ID；一人多班各一条。
|
||||
*
|
||||
* @throws BizException 未登录 / 无学校身份 / 未匹配到学生名册
|
||||
*/
|
||||
public List<RosterEntry> mine() {
|
||||
Integer userId = UserContext.getUserId();
|
||||
if (userId == null) {
|
||||
throw new BizException(ErrorCode.FORBIDDEN, "未获取到登录身份");
|
||||
}
|
||||
String schSerId = currentSchSerId();
|
||||
if (schSerId == null) {
|
||||
throw new BizException(ErrorCode.FORBIDDEN, "未获取到学校身份");
|
||||
}
|
||||
List<RosterEntry> mine = new ArrayList<>();
|
||||
for (SchStudentDto s : classService.getSchStuList(schSerId)) {
|
||||
if (s != null && userId.equals(s.getStuId()) && s.getClassId() != null) {
|
||||
RosterEntry e = new RosterEntry();
|
||||
e.studentId = s.getStuId();
|
||||
e.studentName = s.getStuName();
|
||||
e.classId = s.getClassId();
|
||||
mine.add(e);
|
||||
}
|
||||
}
|
||||
if (mine.isEmpty()) {
|
||||
throw new BizException(ErrorCode.FORBIDDEN, "当前用户未匹配到学生名册，请联系管理员确认班级名册");
|
||||
}
|
||||
Map<Integer, String> names = classNames(mine.stream().map(e -> e.classId).collect(Collectors.toSet()));
|
||||
for (RosterEntry e : mine) {
|
||||
e.className = names.getOrDefault(e.classId, String.valueOf(e.classId));
|
||||
}
|
||||
return mine;
|
||||
}
|
||||
|
||||
/** 当前登录人学校的 bschclass GUID（无学校身份或上游未映射时返回 null） */
|
||||
private String currentSchSerId() {
|
||||
Integer schId = UserContext.getSchId();
|
||||
if (schId == null) {
|
||||
return null;
|
||||
}
|
||||
SchInfoDto sch = classService.getSchFirst(schId);
|
||||
return sch == null ? null : sch.getSchSerId();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user