|
@@ -2,9 +2,12 @@ package com.xjrsoft.module.classtime.service.impl;
|
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
|
+import com.alibaba.excel.EasyExcel;
|
|
|
|
|
+import com.alibaba.excel.support.ExcelTypeEnum;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.github.yulichang.base.MPJBaseServiceImpl;
|
|
import com.github.yulichang.base.MPJBaseServiceImpl;
|
|
|
|
|
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
|
|
import com.google.gson.Gson;
|
|
import com.google.gson.Gson;
|
|
|
import com.google.gson.JsonArray;
|
|
import com.google.gson.JsonArray;
|
|
|
import com.google.gson.JsonElement;
|
|
import com.google.gson.JsonElement;
|
|
@@ -13,25 +16,36 @@ import com.google.gson.JsonParser;
|
|
|
import com.xjrsoft.common.enums.CourseAdjustTypeEnum;
|
|
import com.xjrsoft.common.enums.CourseAdjustTypeEnum;
|
|
|
import com.xjrsoft.common.enums.CourseTimeTypeEnum;
|
|
import com.xjrsoft.common.enums.CourseTimeTypeEnum;
|
|
|
import com.xjrsoft.common.enums.DeleteMark;
|
|
import com.xjrsoft.common.enums.DeleteMark;
|
|
|
|
|
+import com.xjrsoft.common.enums.EnabledMark;
|
|
|
import com.xjrsoft.common.exception.MyException;
|
|
import com.xjrsoft.common.exception.MyException;
|
|
|
import com.xjrsoft.common.mybatis.SqlRunnerAdapter;
|
|
import com.xjrsoft.common.mybatis.SqlRunnerAdapter;
|
|
|
|
|
+import com.xjrsoft.common.utils.VoToColumnUtil;
|
|
|
import com.xjrsoft.module.classtime.dto.AddClassTimeStatisticsDto;
|
|
import com.xjrsoft.module.classtime.dto.AddClassTimeStatisticsDto;
|
|
|
|
|
+import com.xjrsoft.module.classtime.dto.CourseRecordDto;
|
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeDelete;
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeDelete;
|
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeStatistics;
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeStatistics;
|
|
|
|
|
+import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsAdministration;
|
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsRecord;
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsRecord;
|
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsSet;
|
|
import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsSet;
|
|
|
|
|
+import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsAdministrationMapper;
|
|
|
import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsMapper;
|
|
import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsMapper;
|
|
|
import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsRecordMapper;
|
|
import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsRecordMapper;
|
|
|
import com.xjrsoft.module.classtime.service.IClassTimeDeleteService;
|
|
import com.xjrsoft.module.classtime.service.IClassTimeDeleteService;
|
|
|
import com.xjrsoft.module.classtime.service.IClassTimeStatisticsService;
|
|
import com.xjrsoft.module.classtime.service.IClassTimeStatisticsService;
|
|
|
import com.xjrsoft.module.classtime.service.IClassTimeStatisticsSetService;
|
|
import com.xjrsoft.module.classtime.service.IClassTimeStatisticsSetService;
|
|
|
|
|
+import com.xjrsoft.module.classtime.vo.ClassTimeStatisticsAdministrationExcelVo;
|
|
|
import com.xjrsoft.module.classtime.vo.ClassTimeStatisticsRecordVo;
|
|
import com.xjrsoft.module.classtime.vo.ClassTimeStatisticsRecordVo;
|
|
|
|
|
+import com.xjrsoft.module.classtime.vo.CourseClassTimeStatisticsRecordVo;
|
|
|
import com.xjrsoft.module.classtime.vo.CourseListVo;
|
|
import com.xjrsoft.module.classtime.vo.CourseListVo;
|
|
|
import com.xjrsoft.module.classtime.vo.TeacherListVo;
|
|
import com.xjrsoft.module.classtime.vo.TeacherListVo;
|
|
|
import com.xjrsoft.module.classtime.vo.WeekTimeRangeVo;
|
|
import com.xjrsoft.module.classtime.vo.WeekTimeRangeVo;
|
|
|
import com.xjrsoft.module.oa.entity.WfTeacherCourseTime;
|
|
import com.xjrsoft.module.oa.entity.WfTeacherCourseTime;
|
|
|
|
|
+import com.xjrsoft.module.organization.entity.User;
|
|
|
|
|
+import com.xjrsoft.module.organization.service.IUserService;
|
|
|
import com.xjrsoft.module.system.entity.DictionaryDetail;
|
|
import com.xjrsoft.module.system.entity.DictionaryDetail;
|
|
|
import com.xjrsoft.module.system.service.IDictionarydetailService;
|
|
import com.xjrsoft.module.system.service.IDictionarydetailService;
|
|
|
|
|
+import com.xjrsoft.module.teacher.entity.BaseTeacher;
|
|
|
|
|
+import com.xjrsoft.module.teacher.entity.XjrUser;
|
|
|
import lombok.AllArgsConstructor;
|
|
import lombok.AllArgsConstructor;
|
|
|
import me.zhyd.oauth.log.Log;
|
|
import me.zhyd.oauth.log.Log;
|
|
|
import org.apache.poi.ss.usermodel.Cell;
|
|
import org.apache.poi.ss.usermodel.Cell;
|
|
@@ -46,18 +60,20 @@ import org.apache.poi.ss.util.CellRangeAddress;
|
|
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
+import org.springframework.web.multipart.MultipartFile;
|
|
|
|
|
|
|
|
import java.io.ByteArrayOutputStream;
|
|
import java.io.ByteArrayOutputStream;
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
|
|
+import java.math.RoundingMode;
|
|
|
import java.time.DayOfWeek;
|
|
import java.time.DayOfWeek;
|
|
|
import java.time.LocalDate;
|
|
import java.time.LocalDate;
|
|
|
import java.time.format.DateTimeFormatter;
|
|
import java.time.format.DateTimeFormatter;
|
|
|
import java.time.temporal.ChronoUnit;
|
|
import java.time.temporal.ChronoUnit;
|
|
|
import java.util.ArrayList;
|
|
import java.util.ArrayList;
|
|
|
import java.util.Arrays;
|
|
import java.util.Arrays;
|
|
|
|
|
+import java.util.Collection;
|
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
|
import java.util.HashMap;
|
|
import java.util.HashMap;
|
|
|
-import java.util.HashSet;
|
|
|
|
|
import java.util.LinkedHashMap;
|
|
import java.util.LinkedHashMap;
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
import java.util.Map;
|
|
@@ -83,6 +99,10 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
private final IClassTimeDeleteService deleteService;
|
|
private final IClassTimeDeleteService deleteService;
|
|
|
private final IDictionarydetailService dictionaryService;
|
|
private final IDictionarydetailService dictionaryService;
|
|
|
|
|
|
|
|
|
|
+ private final ClassTimeStatisticsAdministrationMapper administrationMapper;
|
|
|
|
|
+
|
|
|
|
|
+ private final IUserService userService;
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Boolean add(ClassTimeStatistics classTimeStatistics) {
|
|
public Boolean add(ClassTimeStatistics classTimeStatistics) {
|
|
@@ -90,6 +110,36 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
return true;
|
|
return true;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public Boolean addCourse(AddClassTimeStatisticsDto dto) {
|
|
|
|
|
+ ClassTimeStatistics classTimeStatistics = BeanUtil.toBean(dto, ClassTimeStatistics.class);
|
|
|
|
|
+ classTimeStatistics.setStatus(0);
|
|
|
|
|
+ classTimeStatistics.setCategory(2);
|
|
|
|
|
+ classTimeStatistics.setCreateDate(new Date());
|
|
|
|
|
+
|
|
|
|
|
+ List<WeekTimeRangeVo> weekTimeRangeVos = calculateNaturalWeeks(classTimeStatistics.getStartDate(), classTimeStatistics.getEndDate());
|
|
|
|
|
+ classTimeStatistics.setWeeks(weekTimeRangeVos.size());
|
|
|
|
|
+ //查询最新权重并保存到统计中
|
|
|
|
|
+ Integer category = 3;
|
|
|
|
|
+ List<ClassTimeStatisticsSet> list = statisticsSetService.list(
|
|
|
|
|
+ new QueryWrapper<ClassTimeStatisticsSet>().lambda()
|
|
|
|
|
+ .eq(ClassTimeStatisticsSet::getCategory, category)
|
|
|
|
|
+ .orderByDesc(ClassTimeStatisticsSet::getCreateDate)
|
|
|
|
|
+ );
|
|
|
|
|
+ if(list.isEmpty()){
|
|
|
|
|
+ throw new MyException("请先设置权重并进行保存");
|
|
|
|
|
+ }
|
|
|
|
|
+ classTimeStatistics.setWeightSetJson(list.get(0).getJsonContent());
|
|
|
|
|
+
|
|
|
|
|
+ this.save(classTimeStatistics);
|
|
|
|
|
+
|
|
|
|
|
+ CompletableFuture.runAsync(() -> {
|
|
|
|
|
+ refreshCourseRecord(classTimeStatistics);
|
|
|
|
|
+ });
|
|
|
|
|
+
|
|
|
|
|
+ return true;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Boolean update(ClassTimeStatistics classTimeStatistics) {
|
|
public Boolean update(ClassTimeStatistics classTimeStatistics) {
|
|
@@ -97,6 +147,14 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
return true;
|
|
return true;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public Boolean updateCourse(ClassTimeStatistics classTimeStatistics) {
|
|
|
|
|
+ List<WeekTimeRangeVo> weekTimeRangeVos = calculateNaturalWeeks(classTimeStatistics.getStartDate(), classTimeStatistics.getEndDate());
|
|
|
|
|
+ classTimeStatistics.setWeeks(weekTimeRangeVos.size());
|
|
|
|
|
+ statisticsMapper.updateById(classTimeStatistics);
|
|
|
|
|
+ return true;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Boolean delete(List<Long> ids) {
|
|
public Boolean delete(List<Long> ids) {
|
|
@@ -111,6 +169,7 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
public Boolean add(AddClassTimeStatisticsDto dto) {
|
|
public Boolean add(AddClassTimeStatisticsDto dto) {
|
|
|
ClassTimeStatistics classTimeStatistics = BeanUtil.toBean(dto, ClassTimeStatistics.class);
|
|
ClassTimeStatistics classTimeStatistics = BeanUtil.toBean(dto, ClassTimeStatistics.class);
|
|
|
classTimeStatistics.setStatus(0);
|
|
classTimeStatistics.setStatus(0);
|
|
|
|
|
+ classTimeStatistics.setCategory(1);
|
|
|
classTimeStatistics.setCreateDate(new Date());
|
|
classTimeStatistics.setCreateDate(new Date());
|
|
|
|
|
|
|
|
//查询最新权重并保存到统计中
|
|
//查询最新权重并保存到统计中
|
|
@@ -151,7 +210,6 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
* 3、根绝统计的开始日期和结束日期查询课程表(course_table)中的所有课程数据
|
|
* 3、根绝统计的开始日期和结束日期查询课程表(course_table)中的所有课程数据
|
|
|
* 4、查询补班日期下的所有课程
|
|
* 4、查询补班日期下的所有课程
|
|
|
* 5、属于节假日的课程不查询
|
|
* 5、属于节假日的课程不查询
|
|
|
- * @param statistics
|
|
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -164,6 +222,7 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
new QueryWrapper<DictionaryDetail>().lambda()
|
|
new QueryWrapper<DictionaryDetail>().lambda()
|
|
|
.eq(DictionaryDetail::getItemId, 1833772737004875778L)
|
|
.eq(DictionaryDetail::getItemId, 1833772737004875778L)
|
|
|
.eq(DictionaryDetail::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
.eq(DictionaryDetail::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
|
|
+ .eq(DictionaryDetail::getEnabledMark, EnabledMark.ENABLED.getCode())
|
|
|
.orderByAsc(DictionaryDetail::getCode)
|
|
.orderByAsc(DictionaryDetail::getCode)
|
|
|
);
|
|
);
|
|
|
Map<String, String> CourseTimeTypeMap = CourseTimeTypeList.stream().collect(Collectors.toMap(DictionaryDetail::getCode, DictionaryDetail::getName));
|
|
Map<String, String> CourseTimeTypeMap = CourseTimeTypeList.stream().collect(Collectors.toMap(DictionaryDetail::getCode, DictionaryDetail::getName));
|
|
@@ -199,6 +258,8 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
List<ClassTimeDelete> deleteList = deleteService.list(
|
|
List<ClassTimeDelete> deleteList = deleteService.list(
|
|
|
new QueryWrapper<ClassTimeDelete>().lambda()
|
|
new QueryWrapper<ClassTimeDelete>().lambda()
|
|
|
.ne(ClassTimeDelete::getStatus, 2)
|
|
.ne(ClassTimeDelete::getStatus, 2)
|
|
|
|
|
+ .eq(ClassTimeDelete::getEnabledMark, EnabledMark.ENABLED.getCode())
|
|
|
|
|
+ .eq(ClassTimeDelete::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
);
|
|
);
|
|
|
Map<Long, List<ClassTimeDelete>> deleteDataMap = deleteList.stream().collect(Collectors.groupingBy(ClassTimeDelete::getClassId));
|
|
Map<Long, List<ClassTimeDelete>> deleteDataMap = deleteList.stream().collect(Collectors.groupingBy(ClassTimeDelete::getClassId));
|
|
|
Map<Long, Map<LocalDate, String>> deleteMap = new HashMap<>();//将每个班级计算出来所有被删除的日期存入map
|
|
Map<Long, Map<LocalDate, String>> deleteMap = new HashMap<>();//将每个班级计算出来所有被删除的日期存入map
|
|
@@ -259,7 +320,7 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
}
|
|
}
|
|
|
record.setCourseTimeTypeData(courseTimeTypeJson.toString());
|
|
record.setCourseTimeTypeData(courseTimeTypeJson.toString());
|
|
|
|
|
|
|
|
- //早自习、正课、晚辅、顶课、调课
|
|
|
|
|
|
|
+ //早自习、正课、晚辅
|
|
|
Double classTime7 = 0D,classTime8 = 0D,classTime9 = 0D,classTime11 = 0D;
|
|
Double classTime7 = 0D,classTime8 = 0D,classTime9 = 0D,classTime11 = 0D;
|
|
|
|
|
|
|
|
List<String> zkList = Arrays.asList("上1","上2","上3","上4","下1","下2","下3","下4");
|
|
List<String> zkList = Arrays.asList("上1","上2","上3","上4","下1","下2","下3","下4");
|
|
@@ -501,7 +562,7 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
//计算总金额,课时费+超课时费
|
|
//计算总金额,课时费+超课时费
|
|
|
Double totalAmount = classTimeAmount + beyondClassTimeAmount + reduceTimeAmount.doubleValue();
|
|
Double totalAmount = classTimeAmount + beyondClassTimeAmount + reduceTimeAmount.doubleValue();
|
|
|
record.setTotalAmount(totalAmount);
|
|
record.setTotalAmount(totalAmount);
|
|
|
- record.setAllClassTimeData(calculateClassTime(allClassTimeDataArray, weightSetMap, allDateList));
|
|
|
|
|
|
|
+ record.setAllClassTimeData(calculateClassTime(allClassTimeDataArray, weightSetMap, allDateList, new ArrayList<>(CourseTimeTypeMap.values())));
|
|
|
record.setCreateDate(new Date());
|
|
record.setCreateDate(new Date());
|
|
|
|
|
|
|
|
insertList.add(record);
|
|
insertList.add(record);
|
|
@@ -519,13 +580,14 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
statistics.setTotalAmount(insertList.stream().filter(x -> x.getTotalAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getTotalAmount).sum());
|
|
statistics.setTotalAmount(insertList.stream().filter(x -> x.getTotalAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getTotalAmount).sum());
|
|
|
statistics.setBeyondClassTimeAmount(insertList.stream().filter(x -> x.getBeyondClassTimeAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getBeyondClassTimeAmount).sum());
|
|
statistics.setBeyondClassTimeAmount(insertList.stream().filter(x -> x.getBeyondClassTimeAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getBeyondClassTimeAmount).sum());
|
|
|
statistics.setClassTimeAmount(insertList.stream().filter(x -> x.getClassTimeAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getClassTimeAmount).sum());
|
|
statistics.setClassTimeAmount(insertList.stream().filter(x -> x.getClassTimeAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getClassTimeAmount).sum());
|
|
|
- statistics.setStatus(1);
|
|
|
|
|
- this.updateById(statistics);
|
|
|
|
|
- return true;
|
|
|
|
|
}catch (Exception e){
|
|
}catch (Exception e){
|
|
|
Log.error(e.getMessage(), e);
|
|
Log.error(e.getMessage(), e);
|
|
|
throw new MyException("统计出错,请联系管理员");
|
|
throw new MyException("统计出错,请联系管理员");
|
|
|
|
|
+ }finally {
|
|
|
|
|
+ statistics.setStatus(1);
|
|
|
|
|
+ this.updateById(statistics);
|
|
|
}
|
|
}
|
|
|
|
|
+ return true;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -539,10 +601,13 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
return this.baseMapper.getRecordList(id);
|
|
return this.baseMapper.getRecordList(id);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public List<CourseClassTimeStatisticsRecordVo> getCourseRecordList(CourseRecordDto dto) {
|
|
|
|
|
+ return this.baseMapper.getCourseRecordList(dto);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 导出课时统计明细
|
|
* 导出课时统计明细
|
|
|
- * @param id
|
|
|
|
|
- * @return
|
|
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
public byte[] recordExport(Long id) {
|
|
public byte[] recordExport(Long id) {
|
|
@@ -698,6 +763,220 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public Boolean refreshCourseRecord(ClassTimeStatistics statistics) {
|
|
|
|
|
+ try {
|
|
|
|
|
+ // 1、查询教师
|
|
|
|
|
+ List<TeacherListVo> teacherList = this.baseMapper.getTeacherList();
|
|
|
|
|
+
|
|
|
|
|
+ //查询课程数据,排除开节假日的数据
|
|
|
|
|
+ List<CourseListVo> allCourseList = this.baseMapper.getCourseList(statistics);
|
|
|
|
|
+ allCourseList.addAll(this.baseMapper.getHolidayReplaceCourseList(statistics));
|
|
|
|
|
+
|
|
|
|
|
+ //查询删除课时的数据,将每个班删除的具体日期统计出来
|
|
|
|
|
+ List<ClassTimeDelete> deleteList = deleteService.list(
|
|
|
|
|
+ new QueryWrapper<ClassTimeDelete>().lambda()
|
|
|
|
|
+ .ne(ClassTimeDelete::getStatus, 2)
|
|
|
|
|
+ .eq(ClassTimeDelete::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
|
|
+ .eq(ClassTimeDelete::getEnabledMark, EnabledMark.ENABLED.getCode())
|
|
|
|
|
+ );
|
|
|
|
|
+ Map<Long, List<ClassTimeDelete>> deleteDataMap = deleteList.stream().collect(Collectors.groupingBy(ClassTimeDelete::getClassId));
|
|
|
|
|
+ Map<Long, Map<LocalDate, String>> deleteMap = new HashMap<>();//将每个班级计算出来所有被删除的日期存入map
|
|
|
|
|
+ for (Long classId : deleteDataMap.keySet()) {
|
|
|
|
|
+ Map<LocalDate, String> dateMap = new HashMap<>();
|
|
|
|
|
+ for (ClassTimeDelete classTimeDelete : deleteDataMap.get(classId)) {
|
|
|
|
|
+ LocalDate currentDate = classTimeDelete.getStartDate();
|
|
|
|
|
+ while (!currentDate.isAfter(classTimeDelete.getEndDate())) {
|
|
|
|
|
+ dateMap.put(currentDate, classTimeDelete.getTimePeriod());
|
|
|
|
|
+ currentDate = currentDate.plusDays(1); // 增加一天
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ //去重并存到map中
|
|
|
|
|
+ deleteMap.put(classId, dateMap);
|
|
|
|
|
+ }
|
|
|
|
|
+ JsonParser parser = new JsonParser();
|
|
|
|
|
+
|
|
|
|
|
+ //权重设置jsonArray
|
|
|
|
|
+ JsonArray weightSetArray = parser.parse(statistics.getWeightSetJson()).getAsJsonArray();
|
|
|
|
|
+ Map<String, Double> weightLabelMap = new LinkedHashMap<>();
|
|
|
|
|
+ Map<String, Double> weightFieldMap = new LinkedHashMap<>();
|
|
|
|
|
+ for (JsonElement jsonElement : weightSetArray) {
|
|
|
|
|
+ JsonObject object = jsonElement.getAsJsonObject();
|
|
|
|
|
+ weightLabelMap.put(object.get("label").getAsString(), object.get("value").getAsDouble());
|
|
|
|
|
+ weightFieldMap.put(object.get("field").getAsString(), object.get("value").getAsDouble());
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ //查询行政工作量并转成map
|
|
|
|
|
+ List<ClassTimeStatisticsAdministration> administrationList = administrationMapper.selectList(
|
|
|
|
|
+ new QueryWrapper<ClassTimeStatisticsAdministration>().lambda()
|
|
|
|
|
+ .eq(ClassTimeStatisticsAdministration::getClassTimeStatisticsId, statistics.getId())
|
|
|
|
|
+ .eq(ClassTimeStatisticsAdministration::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
|
|
+ .eq(ClassTimeStatisticsAdministration::getEnabledMark, EnabledMark.ENABLED.getCode())
|
|
|
|
|
+ );
|
|
|
|
|
+ Map<Long, Double> administrationMap = administrationList.stream().collect(Collectors.toMap(ClassTimeStatisticsAdministration::getUserId, ClassTimeStatisticsAdministration::getWorkload));
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ List<ClassTimeStatisticsRecord> insertList = new ArrayList<>();
|
|
|
|
|
+ for (TeacherListVo teacher : teacherList) {
|
|
|
|
|
+ ClassTimeStatisticsRecord record = new ClassTimeStatisticsRecord();
|
|
|
|
|
+ record.setUserId(teacher.getId());
|
|
|
|
|
+ record.setClassTimeStatisticsId(statistics.getId());
|
|
|
|
|
+ record.setEmployType(teacher.getEmployType());
|
|
|
|
|
+ record.setClassTime1(statistics.getWeeks());
|
|
|
|
|
+
|
|
|
|
|
+ //早自习、正课、晚辅、顶课、调课
|
|
|
|
|
+ Double classTime7 = 0D,classTime8 = 0D,classTime9 = 0D;
|
|
|
|
|
+
|
|
|
|
|
+ List<String> zkList = Arrays.asList("上1","上2","上3","上4","下1","下2","下3","下4");
|
|
|
|
|
+ List<String> wzxList = Arrays.asList("晚1","晚2","晚3");
|
|
|
|
|
+ //查询出老师的课程
|
|
|
|
|
+ List<CourseListVo> courseList = allCourseList.stream()
|
|
|
|
|
+ .filter(x -> x.getTeacherId().contains(teacher.getId().toString()))
|
|
|
|
|
+ .collect(Collectors.toList());
|
|
|
|
|
+
|
|
|
|
|
+ //循环,统计出各项数据
|
|
|
|
|
+ for (CourseListVo courseListVo : courseList) {
|
|
|
|
|
+ Map<LocalDate, String> deleteDates = deleteMap.get(courseListVo.getClassId());
|
|
|
|
|
+ if(deleteDates != null && deleteDates.containsKey(courseListVo.getScheduleDate()) && deleteDates.get(courseListVo.getScheduleDate()) != null
|
|
|
|
|
+ && deleteDates.get(courseListVo.getScheduleDate()).contains(courseListVo.getTimeNumber()) ){
|
|
|
|
|
+ continue;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ if("早自习".equals(courseListVo.getShortName())){
|
|
|
|
|
+ classTime8 += weightLabelMap.get(courseListVo.getShortName()) == null ? 0d : weightLabelMap.get(courseListVo.getShortName());
|
|
|
|
|
+ }else if(zkList.contains(courseListVo.getShortName())){
|
|
|
|
|
+ classTime8 += weightLabelMap.get(courseListVo.getShortName()) == null ? 0d : weightLabelMap.get(courseListVo.getShortName());
|
|
|
|
|
+ }else if(wzxList.contains(courseListVo.getShortName())){
|
|
|
|
|
+ classTime9 += weightLabelMap.get(courseListVo.getShortName()) == null ? 0d : weightLabelMap.get(courseListVo.getShortName());
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ record.setClassTime7(classTime7);
|
|
|
|
|
+ record.setClassTime8(classTime8);
|
|
|
|
|
+ record.setClassTime9(classTime9);
|
|
|
|
|
+ //计算总课时:正课课时+晚辅
|
|
|
|
|
+ Double allTimes = classTime8 + classTime9;
|
|
|
|
|
+ record.setAllClassTime(allTimes);
|
|
|
|
|
+ //计算周平均课时:总课时÷总周次
|
|
|
|
|
+ double classTime2 = BigDecimal.valueOf(allTimes).divide(BigDecimal.valueOf(record.getClassTime1()),2, RoundingMode.HALF_UP).doubleValue();
|
|
|
|
|
+ record.setClassTime2(classTime2);
|
|
|
|
|
+ //行政工作量
|
|
|
|
|
+ record.setClassTime3(administrationMap.get(record.getUserId()));
|
|
|
|
|
+
|
|
|
|
|
+ //总平均课时
|
|
|
|
|
+ Double classTime4 = (record.getClassTime3()==null?0D:record.getClassTime3()) + (record.getClassTime2()==null?0D:record.getClassTime2());
|
|
|
|
|
+ record.setClassTime4(classTime4);
|
|
|
|
|
+
|
|
|
|
|
+ Double time13 = weightFieldMap.get("time13");
|
|
|
|
|
+ if(classTime4 > time13){
|
|
|
|
|
+ record.setClassTime5(time13);
|
|
|
|
|
+ }else{
|
|
|
|
|
+ record.setClassTime5(classTime4);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ insertList.add(record);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ if(!insertList.isEmpty()){
|
|
|
|
|
+ Double overWorkloadNumber = statistics.getOverWorkloadNumber() == null ? 0D : statistics.getOverWorkloadNumber();
|
|
|
|
|
+ Double time14 = weightFieldMap.get("time14");//工作量得分
|
|
|
|
|
+ Double time13 = weightFieldMap.get("time13");//超工作量得分
|
|
|
|
|
+ if(statistics.getOverWorkloadNumberStatus() != 1){
|
|
|
|
|
+ //取出最大总平均课时
|
|
|
|
|
+ Double maxClassTime4 = insertList.stream().mapToDouble(ClassTimeStatisticsRecord::getClassTime4).max().getAsDouble();
|
|
|
|
|
+ //计算超工作量基数
|
|
|
|
|
+ if(!maxClassTime4.equals(time13)){
|
|
|
|
|
+
|
|
|
|
|
+ overWorkloadNumber = BigDecimal.valueOf(time14).divide((BigDecimal.valueOf(maxClassTime4).subtract(BigDecimal.valueOf(time13))),2, RoundingMode.HALF_UP).doubleValue();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ double allClassTime = insertList.stream().filter(x -> x.getAllClassTime() != null).mapToDouble(ClassTimeStatisticsRecord::getAllClassTime).sum();
|
|
|
|
|
+ statistics.setAllClassTime(allClassTime);
|
|
|
|
|
+ statistics.setOverWorkloadNumber(overWorkloadNumber);
|
|
|
|
|
+ //先删除
|
|
|
|
|
+ String sql = "delete from class_time_statistics_record where class_time_statistics_id = " + statistics.getId();
|
|
|
|
|
+ SqlRunnerAdapter.db().delete(sql);
|
|
|
|
|
+ for (ClassTimeStatisticsRecord record : insertList) {
|
|
|
|
|
+ if(overWorkloadNumber != 0D && time13 < record.getClassTime4()){
|
|
|
|
|
+ double classTime6 = BigDecimal.valueOf(record.getClassTime4())
|
|
|
|
|
+ .subtract(BigDecimal.valueOf(time13))
|
|
|
|
|
+ .multiply(BigDecimal.valueOf(overWorkloadNumber)).doubleValue();
|
|
|
|
|
+ if(classTime6 > 0d){
|
|
|
|
|
+ record.setClassTime6(classTime6);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ recordMapper.insert(record);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }catch (Exception e){
|
|
|
|
|
+ Log.error(e.getMessage(), e);
|
|
|
|
|
+ throw new MyException("刷新统计出错,请联系管理员");
|
|
|
|
|
+ }finally {
|
|
|
|
|
+ statistics.setStatus(1);
|
|
|
|
|
+ this.updateById(statistics);
|
|
|
|
|
+ }
|
|
|
|
|
+ return true;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public Boolean importAdministration(Long classTimeStatisticsId, MultipartFile file){
|
|
|
|
|
+ try {
|
|
|
|
|
+ List<Map<Integer, Object>> excelDataList = EasyExcel.read(file.getInputStream()).sheet().headRowNumber(2).doReadSync();
|
|
|
|
|
+ List<User> teacherList = userService.list(
|
|
|
|
|
+ new MPJLambdaWrapper<User>()
|
|
|
|
|
+ .select(User::getId)
|
|
|
|
|
+ .select(XjrUser.class, x -> VoToColumnUtil.fieldsToColumns(XjrUser.class).contains(x.getProperty()))
|
|
|
|
|
+ .innerJoin(BaseTeacher.class, BaseTeacher::getUserId, User::getId)
|
|
|
|
|
+ );
|
|
|
|
|
+ List<ClassTimeStatisticsAdministration> insertList = new ArrayList<>();
|
|
|
|
|
+ Map<String, Long> userMap = teacherList.stream().collect(Collectors.toMap(User::getUserName, User::getId));
|
|
|
|
|
+ for (Map<Integer, Object> rowData : excelDataList) {
|
|
|
|
|
+ String userName = rowData.get(1).toString();
|
|
|
|
|
+ ClassTimeStatisticsAdministration data = new ClassTimeStatisticsAdministration(){{
|
|
|
|
|
+ setClassTimeStatisticsId(classTimeStatisticsId);
|
|
|
|
|
+ setUserId(userMap.get(userName));
|
|
|
|
|
+ setWorkload(Double.parseDouble(rowData.get(3).toString()));
|
|
|
|
|
+ }};
|
|
|
|
|
+ insertList.add(data);
|
|
|
|
|
+ }
|
|
|
|
|
+ if(!insertList.isEmpty()){
|
|
|
|
|
+ String sql = "delete from class_time_statistics_administration where class_time_statistics_id = " + classTimeStatisticsId;
|
|
|
|
|
+ SqlRunnerAdapter.db().delete(sql);
|
|
|
|
|
+ for (ClassTimeStatisticsAdministration administration : insertList) {
|
|
|
|
|
+ administrationMapper.insert(administration);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ CompletableFuture.runAsync(() -> {
|
|
|
|
|
+ ClassTimeStatistics statistics = this.getById(classTimeStatisticsId);
|
|
|
|
|
+ refreshCourseRecord(statistics);
|
|
|
|
|
+ });
|
|
|
|
|
+ }
|
|
|
|
|
+ return true;
|
|
|
|
|
+ }catch (Exception e){
|
|
|
|
|
+ Log.error(e.getMessage(), e);
|
|
|
|
|
+ throw new MyException("导入行政工作量报错,请联系管理员");
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public byte[] exportAdministration(Long classTimeStatisticsId) {
|
|
|
|
|
+ CourseRecordDto dto = new CourseRecordDto() {{
|
|
|
|
|
+ setId(classTimeStatisticsId);
|
|
|
|
|
+ }};
|
|
|
|
|
+ List<CourseClassTimeStatisticsRecordVo> recordList = this.getCourseRecordList(dto);
|
|
|
|
|
+ List<ClassTimeStatisticsAdministrationExcelVo> list = new ArrayList<>();
|
|
|
|
|
+ int sortCode = 1;
|
|
|
|
|
+ for (CourseClassTimeStatisticsRecordVo el : recordList) {
|
|
|
|
|
+ ClassTimeStatisticsAdministrationExcelVo excelVo = BeanUtil.toBean(el, ClassTimeStatisticsAdministrationExcelVo.class);
|
|
|
|
|
+ excelVo.setSortCode(sortCode);
|
|
|
|
|
+ list.add(excelVo);
|
|
|
|
|
+ sortCode ++;
|
|
|
|
|
+ }
|
|
|
|
|
+ ByteArrayOutputStream bot = new ByteArrayOutputStream();
|
|
|
|
|
+ EasyExcel.write(bot, ClassTimeStatisticsAdministrationExcelVo.class).automaticMergeHead(false).excelType(ExcelTypeEnum.XLSX).sheet().doWrite(list);
|
|
|
|
|
+
|
|
|
|
|
+ return bot.toByteArray();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 生成第二行表头
|
|
* 生成第二行表头
|
|
|
* 前端固定表头:序号、工号、姓名、教研会、督导听课、临近三年退休政策、出题、阅卷、周末培优、早自习、正课(含调顶课时)、晚辅(含调顶课时)、顶课、调课
|
|
* 前端固定表头:序号、工号、姓名、教研会、督导听课、临近三年退休政策、出题、阅卷、周末培优、早自习、正课(含调顶课时)、晚辅(含调顶课时)、顶课、调课
|
|
@@ -801,8 +1080,6 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
* 生成第三行表头
|
|
* 生成第三行表头
|
|
|
* 关于周的表头,周一日期到周二日期,第几周,最后拼接一个单独的月份
|
|
* 关于周的表头,周一日期到周二日期,第几周,最后拼接一个单独的月份
|
|
|
*
|
|
*
|
|
|
- * @param workbook
|
|
|
|
|
- * @param sheet
|
|
|
|
|
* @param month 月份
|
|
* @param month 月份
|
|
|
* @param weekTimeRangeVos 周的数据,包含周一的日期周二的日期
|
|
* @param weekTimeRangeVos 周的数据,包含周一的日期周二的日期
|
|
|
* @param lastIndex 前一个表头的单元格
|
|
* @param lastIndex 前一个表头的单元格
|
|
@@ -849,8 +1126,6 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
* 生成第四行表头
|
|
* 生成第四行表头
|
|
|
* 表头内容:总课时(含调顶课节)、顶课(节)、调课(节)、晚辅(节)、课时晚辅合计
|
|
* 表头内容:总课时(含调顶课节)、顶课(节)、调课(节)、晚辅(节)、课时晚辅合计
|
|
|
*
|
|
*
|
|
|
- * @param workbook
|
|
|
|
|
- * @param sheet
|
|
|
|
|
* @param weekTimeRangeVos 周的数据,包含周一的日期周二的日期
|
|
* @param weekTimeRangeVos 周的数据,包含周一的日期周二的日期
|
|
|
* @param lastIndex 前一个表头的单元格
|
|
* @param lastIndex 前一个表头的单元格
|
|
|
*/
|
|
*/
|
|
@@ -947,7 +1222,7 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
return dates;
|
|
return dates;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- String calculateClassTime(JsonArray allClassTimeDataArray, Map<String, Double> weightSetMap, List<LocalDate> allDateList){
|
|
|
|
|
|
|
+ String calculateClassTime(JsonArray allClassTimeDataArray, Map<String, Double> weightSetMap, List<LocalDate> allDateList, List<String> CourseTimeTypeSet){
|
|
|
JsonObject result = new JsonObject();
|
|
JsonObject result = new JsonObject();
|
|
|
//计算纵向的合计
|
|
//计算纵向的合计
|
|
|
Double allClassTime = 0d;
|
|
Double allClassTime = 0d;
|
|
@@ -1006,8 +1281,7 @@ public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTime
|
|
|
columnTitleJson.addProperty("adjustType", "");
|
|
columnTitleJson.addProperty("adjustType", "");
|
|
|
columnTitle.add(columnTitleJson);
|
|
columnTitle.add(columnTitleJson);
|
|
|
}
|
|
}
|
|
|
- String[] courseTimeTypes = CourseTimeTypeEnum.getValues();
|
|
|
|
|
- for (String courseTimeType : courseTimeTypes) {
|
|
|
|
|
|
|
+ for (String courseTimeType : CourseTimeTypeSet) {
|
|
|
double sum = 0d;
|
|
double sum = 0d;
|
|
|
JsonObject columnTitleJson = new JsonObject();
|
|
JsonObject columnTitleJson = new JsonObject();
|
|
|
for (JsonElement jsonElement : allClassTimeDataArray) {
|
|
for (JsonElement jsonElement : allClassTimeDataArray) {
|