ClassTimeStatisticsServiceImpl.java 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852
  1. package com.xjrsoft.module.classtime.service.impl;
  2. import cn.hutool.core.bean.BeanUtil;
  3. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  4. import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  5. import com.github.yulichang.base.MPJBaseServiceImpl;
  6. import com.google.gson.Gson;
  7. import com.google.gson.JsonArray;
  8. import com.google.gson.JsonElement;
  9. import com.google.gson.JsonObject;
  10. import com.google.gson.JsonParser;
  11. import com.xjrsoft.common.enums.CourseAdjustTypeEnum;
  12. import com.xjrsoft.common.enums.CourseTimeTypeEnum;
  13. import com.xjrsoft.common.exception.MyException;
  14. import com.xjrsoft.module.classtime.dto.AddClassTimeStatisticsDto;
  15. import com.xjrsoft.module.classtime.entity.ClassTimeDelete;
  16. import com.xjrsoft.module.classtime.entity.ClassTimeStatistics;
  17. import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsRecord;
  18. import com.xjrsoft.module.classtime.entity.ClassTimeStatisticsSet;
  19. import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsMapper;
  20. import com.xjrsoft.module.classtime.mapper.ClassTimeStatisticsRecordMapper;
  21. import com.xjrsoft.module.classtime.service.IClassTimeDeleteService;
  22. import com.xjrsoft.module.classtime.service.IClassTimeStatisticsService;
  23. import com.xjrsoft.module.classtime.service.IClassTimeStatisticsSetService;
  24. import com.xjrsoft.module.classtime.vo.ClassTimeStatisticsRecordVo;
  25. import com.xjrsoft.module.classtime.vo.CourseListVo;
  26. import com.xjrsoft.module.classtime.vo.TeacherListVo;
  27. import com.xjrsoft.module.classtime.vo.WeekTimeRangeVo;
  28. import com.xjrsoft.module.oa.entity.WfTeacherCourseTime;
  29. import lombok.AllArgsConstructor;
  30. import org.apache.poi.ss.usermodel.Cell;
  31. import org.apache.poi.ss.usermodel.CellStyle;
  32. import org.apache.poi.ss.usermodel.Font;
  33. import org.apache.poi.ss.usermodel.HorizontalAlignment;
  34. import org.apache.poi.ss.usermodel.Row;
  35. import org.apache.poi.ss.usermodel.Sheet;
  36. import org.apache.poi.ss.usermodel.VerticalAlignment;
  37. import org.apache.poi.ss.usermodel.Workbook;
  38. import org.apache.poi.ss.util.CellRangeAddress;
  39. import org.apache.poi.xssf.usermodel.XSSFWorkbook;
  40. import org.springframework.stereotype.Service;
  41. import org.springframework.transaction.annotation.Transactional;
  42. import java.io.ByteArrayOutputStream;
  43. import java.io.IOException;
  44. import java.math.BigDecimal;
  45. import java.time.DayOfWeek;
  46. import java.time.LocalDate;
  47. import java.time.format.DateTimeFormatter;
  48. import java.util.ArrayList;
  49. import java.util.Arrays;
  50. import java.util.Date;
  51. import java.util.HashMap;
  52. import java.util.HashSet;
  53. import java.util.List;
  54. import java.util.Map;
  55. import java.util.Set;
  56. import java.util.concurrent.CompletableFuture;
  57. import java.util.stream.Collectors;
  58. /**
  59. * @title: 课时统计
  60. * @Author dzx
  61. * @Date: 2024-09-26
  62. * @Version 1.0
  63. */
  64. @Service
  65. @AllArgsConstructor
  66. public class ClassTimeStatisticsServiceImpl extends MPJBaseServiceImpl<ClassTimeStatisticsMapper, ClassTimeStatistics> implements IClassTimeStatisticsService {
  67. private final ClassTimeStatisticsMapper statisticsMapper;
  68. private final ClassTimeStatisticsRecordMapper recordMapper;
  69. private final IClassTimeStatisticsSetService statisticsSetService;
  70. private final IClassTimeDeleteService deleteService;
  71. @Override
  72. @Transactional(rollbackFor = Exception.class)
  73. public Boolean add(ClassTimeStatistics classTimeStatistics) {
  74. statisticsMapper.insert(classTimeStatistics);
  75. return true;
  76. }
  77. @Override
  78. @Transactional(rollbackFor = Exception.class)
  79. public Boolean update(ClassTimeStatistics classTimeStatistics) {
  80. statisticsMapper.updateById(classTimeStatistics);
  81. return true;
  82. }
  83. @Override
  84. @Transactional(rollbackFor = Exception.class)
  85. public Boolean delete(List<Long> ids) {
  86. statisticsMapper.deleteBatchIds(ids);
  87. recordMapper.delete(Wrappers.lambdaQuery(ClassTimeStatisticsRecord.class).in(ClassTimeStatisticsRecord::getClassTimeStatisticsId, ids));
  88. return true;
  89. }
  90. @Override
  91. @Transactional(rollbackFor = Exception.class)
  92. public Boolean add(AddClassTimeStatisticsDto dto) {
  93. ClassTimeStatistics classTimeStatistics = BeanUtil.toBean(dto, ClassTimeStatistics.class);
  94. classTimeStatistics.setStatus(0);
  95. classTimeStatistics.setCreateDate(new Date());
  96. //查询最新权重并保存到统计中
  97. Integer category = 1;
  98. List<ClassTimeStatisticsSet> list = statisticsSetService.list(
  99. new QueryWrapper<ClassTimeStatisticsSet>().lambda()
  100. .eq(ClassTimeStatisticsSet::getCategory, category)
  101. .orderByDesc(ClassTimeStatisticsSet::getCreateDate)
  102. );
  103. if(list.isEmpty()){
  104. throw new MyException("请先设置权重并进行保存");
  105. }
  106. classTimeStatistics.setWeightSetJson(list.get(0).getJsonContent());
  107. //查询最新费用并保存到统计中
  108. category = 2;
  109. list = statisticsSetService.list(
  110. new QueryWrapper<ClassTimeStatisticsSet>().lambda()
  111. .eq(ClassTimeStatisticsSet::getCategory, category)
  112. .orderByDesc(ClassTimeStatisticsSet::getCreateDate)
  113. );
  114. if(list.isEmpty()){
  115. throw new MyException("请先设置费用并进行保存");
  116. }
  117. classTimeStatistics.setCostSetJson(list.get(0).getJsonContent());
  118. this.save(classTimeStatistics);
  119. CompletableFuture.runAsync(() -> {
  120. refreshRecord(classTimeStatistics);
  121. });
  122. return true;
  123. }
  124. /**
  125. * 1、通过xjr_user和base_teacher查询所有教师,查询聘用类型为:正式聘用和外聘的
  126. * 2、根据统计的开始日期和结束日期查询课时补充(wf_teacher_course_time)中的教研会、督导听课、临近三年退休政策、出题、阅卷、周末培优
  127. * 3、根绝统计的开始日期和结束日期查询课程表(course_table)中的所有课程数据
  128. * 4、查询补班日期下的所有课程
  129. * 5、属于节假日的课程不查询
  130. * @param statistics
  131. */
  132. @Override
  133. @Transactional(rollbackFor = Exception.class)
  134. public Boolean refreshRecord(ClassTimeStatistics statistics) {
  135. try {
  136. // 1、查询教师
  137. List<TeacherListVo> teacherList = this.baseMapper.getTeacherList();
  138. // 2、查询补课课时
  139. List<WfTeacherCourseTime> courseTimeList = this.baseMapper.getWfTeacherCourseTimeList(statistics);
  140. //按照课时补充类型分类统计
  141. Map<String, List<WfTeacherCourseTime>> courseTimeMap = courseTimeList.stream().collect(Collectors.groupingBy(WfTeacherCourseTime::getCourseTimeType));
  142. JsonParser parser = new JsonParser();
  143. //费用设置jsonArray
  144. JsonArray costSetArray = parser.parse(statistics.getCostSetJson()).getAsJsonArray();
  145. Map<String, Double> costSetMap = new HashMap<>();
  146. for (JsonElement jsonElement : costSetArray) {
  147. JsonObject object = jsonElement.getAsJsonObject();
  148. costSetMap.put(object.get("field").getAsString(), object.get("value").getAsDouble());
  149. }
  150. //权重设置jsonArray
  151. JsonArray weightSetArray = parser.parse(statistics.getWeightSetJson()).getAsJsonArray();
  152. Map<String, Double> weightSetMap = new HashMap<>();
  153. for (JsonElement jsonElement : weightSetArray) {
  154. JsonObject object = jsonElement.getAsJsonObject();
  155. weightSetMap.put(object.get("label").getAsString(), object.get("value").getAsDouble());
  156. }
  157. //计算出这个时间段内一共多少周
  158. List<WeekTimeRangeVo> weekTimeRangeVos = calculateNaturalWeeks(statistics.getStartDate(), statistics.getEndDate());
  159. //查询课程数据,排除开节假日的数据
  160. List<CourseListVo> allCourseList = this.baseMapper.getCourseList(statistics);
  161. //查询删除课时的数据,将每个班删除的具体日期统计出来
  162. List<ClassTimeDelete> deleteList = deleteService.list(
  163. new QueryWrapper<ClassTimeDelete>().lambda()
  164. .ne(ClassTimeDelete::getStatus, 2)
  165. );
  166. Map<Long, List<ClassTimeDelete>> deleteDataMap = deleteList.stream().collect(Collectors.groupingBy(ClassTimeDelete::getClassId));
  167. Map<Long, Set<LocalDate>> deleteMap = new HashMap<>();//将每个班级计算出来所有被删除的日期存入map
  168. for (Long classId : deleteDataMap.keySet()) {
  169. List<LocalDate> dateList = new ArrayList<>();
  170. for (ClassTimeDelete classTimeDelete : deleteDataMap.get(classId)) {
  171. LocalDate currentDate = classTimeDelete.getStartDate();
  172. while (!currentDate.isAfter(classTimeDelete.getEndDate())) {
  173. dateList.add(currentDate);
  174. currentDate = currentDate.plusDays(1); // 增加一天
  175. }
  176. }
  177. //去重并存到map中
  178. deleteMap.put(classId, new HashSet<>(dateList));
  179. }
  180. DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
  181. //查询所有老师发起顶课通过的数量(只查询事假、病假),也要分别计算早自习、晚自习、正课、如果日期出入课时删除中,也需要跳过
  182. List<CourseListVo> allSubstituteList = this.baseMapper.getSubstituteList(statistics);
  183. List<ClassTimeStatisticsRecord> insertList = new ArrayList<>();
  184. //循环教师,准备开始计算
  185. for (TeacherListVo teacher : teacherList) {
  186. ClassTimeStatisticsRecord record = new ClassTimeStatisticsRecord();
  187. record.setUserId(teacher.getId());
  188. record.setClassTimeStatisticsId(statistics.getId());
  189. record.setEmployType(teacher.getEmployType());
  190. JsonArray allClassTimeDataArray = new JsonArray();
  191. Double allClassTime = 0D;
  192. //计算补充课时,算作正课课时,但是计算超出课时时不计算这部分
  193. for (String courseTimeType : courseTimeMap.keySet()) {
  194. List<WfTeacherCourseTime> courseTimes = courseTimeMap.get(courseTimeType);
  195. double sum = courseTimes.stream()
  196. .filter(x -> x.getTeacherIds().contains(teacher.getId().toString()))
  197. .mapToDouble(WfTeacherCourseTime::getCourseTime).sum();
  198. allClassTime = allClassTime + sum;
  199. if(CourseTimeTypeEnum.CTT001.getCode().equals(courseTimeType)){
  200. record.setClassTime1(sum);
  201. }else if(CourseTimeTypeEnum.CTT002.getCode().equals(courseTimeType)){
  202. record.setClassTime2(sum);
  203. }else if(CourseTimeTypeEnum.CTT003.getCode().equals(courseTimeType)){
  204. record.setClassTime3(sum);
  205. }else if(CourseTimeTypeEnum.CTT004.getCode().equals(courseTimeType)){
  206. record.setClassTime4(sum);
  207. }else if(CourseTimeTypeEnum.CTT005.getCode().equals(courseTimeType)){
  208. record.setClassTime5(sum);
  209. }else if(CourseTimeTypeEnum.CTT006.getCode().equals(courseTimeType)){
  210. record.setClassTime6(sum);
  211. }
  212. }
  213. //早自习、正课、晚辅、顶课、调课
  214. Double classTime7 = 0D,classTime8 = 0D,classTime9 = 0D,classTime10 = 0D,classTime11 = 0D;
  215. List<String> zkList = Arrays.asList("上1","上2","上3","上4","下1","下2","下3","下4");
  216. List<String> wzxList = Arrays.asList("晚1","晚2","晚3");
  217. //查询出老师的课程
  218. List<CourseListVo> courseList = allCourseList.stream()
  219. .filter(x -> x.getTeacherId().contains(teacher.getId().toString()))
  220. .collect(Collectors.toList());
  221. //循环,统计出各项数据
  222. for (CourseListVo courseListVo : courseList) {
  223. //如果这个课程数据包含在被删除的课时中,跳过不计算
  224. Set<LocalDate> deleteDates = deleteMap.get(courseListVo.getClassId());
  225. if(deleteDates != null && deleteDates.contains(courseListVo.getScheduleDate())){
  226. continue;
  227. }
  228. if("早自习".equals(courseListVo.getShortName())){
  229. classTime7 += weightSetMap.get(courseListVo.getShortName()) == null ? 0d : weightSetMap.get(courseListVo.getShortName());
  230. }else if(zkList.contains(courseListVo.getShortName())){
  231. classTime8 += weightSetMap.get(courseListVo.getShortName()) == null ? 0d : weightSetMap.get(courseListVo.getShortName());
  232. }else if(wzxList.contains(courseListVo.getShortName())){
  233. classTime9 += weightSetMap.get(courseListVo.getShortName()) == null ? 0d : weightSetMap.get(courseListVo.getShortName());
  234. }
  235. if(courseListVo.getAdjustType() != null && !courseListVo.getAdjustType().isEmpty()){
  236. if(CourseAdjustTypeEnum.courseExchange.getCode().equals(courseListVo.getAdjustType())){
  237. classTime11 += weightSetMap.get(courseListVo.getShortName());
  238. }
  239. }
  240. JsonObject courseJson = new JsonObject();
  241. courseJson.addProperty("type", courseListVo.getShortName());
  242. courseJson.addProperty("scheduleDate", courseListVo.getScheduleDate().format(formatter));
  243. courseJson.addProperty("content", courseListVo.getClassName() + "," + courseListVo.getCourseName());
  244. courseJson.addProperty("adjustType", courseListVo.getAdjustType());
  245. allClassTimeDataArray.add(courseJson);
  246. }
  247. record.setClassTime7(classTime7);
  248. record.setClassTime8(classTime8);
  249. record.setClassTime9(classTime9);
  250. record.setClassTime11(classTime11);
  251. JsonObject weekDataJson = new JsonObject();
  252. Double allTimes = 0d;
  253. Double allCcksTime = 0d;//总的超出课时,从每周的正课课时中计算
  254. BigDecimal ccksTime = BigDecimal.ZERO;//超出课时标准(每周)
  255. if("FB1601".equals(teacher.getEmployType())){
  256. ccksTime = BigDecimal.valueOf(costSetMap.get("cost7"));
  257. }else{//外聘FB1605、合作人员FB1609
  258. ccksTime = BigDecimal.valueOf(costSetMap.get("cost8"));
  259. }
  260. //存每周的数据
  261. for (WeekTimeRangeVo timeRangeVo : weekTimeRangeVos) {
  262. Double zkTimes = 0d;
  263. Double wzxTimes = 0d;
  264. Double dkTimes = 0d;
  265. Double tkTimes = 0d;
  266. for (CourseListVo courseListVo : courseList) {
  267. LocalDate scheduleDate = courseListVo.getScheduleDate();
  268. //如果这个课程数据包含在被删除的课时中,跳过不计算
  269. Set<LocalDate> deleteDates = deleteMap.get(courseListVo.getClassId());
  270. if(deleteDates != null && deleteDates.contains(scheduleDate)){
  271. continue;
  272. }
  273. if(!( (scheduleDate.equals(timeRangeVo.getMondayDate()) || scheduleDate.isAfter(timeRangeVo.getMondayDate()))
  274. && (scheduleDate.equals(timeRangeVo.getSundayDate()) || scheduleDate.isBefore(timeRangeVo.getSundayDate())))){
  275. continue;
  276. }
  277. if("早自习".equals(courseListVo.getShortName())){
  278. zkTimes += weightSetMap.get(courseListVo.getShortName()) == null ? 0d : weightSetMap.get(courseListVo.getShortName());
  279. }else if(zkList.contains(courseListVo.getShortName())){
  280. zkTimes += weightSetMap.get(courseListVo.getShortName()) == null ? 0d : weightSetMap.get(courseListVo.getShortName());
  281. }else if(wzxList.contains(courseListVo.getShortName())){
  282. wzxTimes += weightSetMap.get(courseListVo.getShortName()) == null ? 0d : weightSetMap.get(courseListVo.getShortName());
  283. }
  284. if(courseListVo.getAdjustType() != null && !courseListVo.getAdjustType().isEmpty()){
  285. if(CourseAdjustTypeEnum.courseSubstitute.getCode().equals(courseListVo.getAdjustType())){
  286. dkTimes += weightSetMap.get(courseListVo.getShortName());
  287. }else if(CourseAdjustTypeEnum.courseExchange.getCode().equals(courseListVo.getAdjustType())){
  288. tkTimes += weightSetMap.get(courseListVo.getShortName());
  289. }
  290. }
  291. }
  292. timeRangeVo.setZkTimes(zkTimes);
  293. timeRangeVo.setWzxTimes(wzxTimes);
  294. timeRangeVo.setDkTimes(dkTimes);
  295. timeRangeVo.setTkTimes(tkTimes);
  296. allTimes += (zkTimes + wzxTimes);
  297. if(zkTimes > ccksTime.doubleValue()){
  298. allCcksTime += zkTimes - ccksTime.doubleValue();
  299. }
  300. }
  301. weekDataJson.add("weekData", new Gson().toJsonTree(weekTimeRangeVos));
  302. weekDataJson.addProperty("allTimes", allTimes);
  303. record.setWeekData(weekDataJson.toString());
  304. //计算该老师发起的事假、病假顶课数据
  305. List<CourseListVo> substituteList = allSubstituteList.stream().filter(x -> x.getExchangeTeacherId().equals(teacher.getId()))
  306. .collect(Collectors.toList());
  307. Double reduceTime = 0d;
  308. for (CourseListVo courseListVo : substituteList) {
  309. Set<LocalDate> deleteDates = deleteMap.get(courseListVo.getClassId());
  310. if(deleteDates !=null && deleteDates.contains(courseListVo.getScheduleDate())){
  311. continue;
  312. }
  313. reduceTime += weightSetMap.get(courseListVo.getShortName());
  314. }
  315. substituteList = allSubstituteList.stream().filter(x -> x.getTeacherId().equals(teacher.getId().toString()))
  316. .collect(Collectors.toList());
  317. for (CourseListVo courseListVo : substituteList) {
  318. Set<LocalDate> deleteDates = deleteMap.get(courseListVo.getClassId());
  319. if(deleteDates !=null && deleteDates.contains(courseListVo.getScheduleDate())){
  320. continue;
  321. }
  322. reduceTime = reduceTime - weightSetMap.get(courseListVo.getShortName());
  323. }
  324. record.setClassTime10(reduceTime);
  325. //计算总课时
  326. allClassTime = allClassTime + classTime7 + classTime8 + classTime9;
  327. record.setAllClassTime(allClassTime);
  328. //计算费用,根据聘用类型判断费用问题
  329. Double classTimeAmount = 0d;
  330. Double beyondClassTimeAmount = 0d;
  331. BigDecimal zzxCost = BigDecimal.ZERO;//早自习费用
  332. if("FB1601".equals(teacher.getEmployType())){
  333. zzxCost = BigDecimal.valueOf(costSetMap.get("cost1"));
  334. }else{//外聘FB1605、合作人员FB1609
  335. zzxCost = BigDecimal.valueOf(costSetMap.get("cost2"));
  336. }
  337. classTimeAmount += BigDecimal.valueOf(classTime7).multiply(zzxCost).doubleValue();
  338. BigDecimal zkCost = BigDecimal.ZERO;//正课费用
  339. if("FB1601".equals(teacher.getEmployType())){
  340. zkCost = BigDecimal.valueOf(costSetMap.get("cost3"));
  341. }else{//外聘FB1605、合作人员FB1609
  342. zkCost = BigDecimal.valueOf(costSetMap.get("cost4"));
  343. }
  344. double classTime = classTime8
  345. + (record.getClassTime1() == null ? 0d:record.getClassTime1())
  346. + (record.getClassTime2() == null ? 0d:record.getClassTime2())
  347. + (record.getClassTime3() == null ? 0d:record.getClassTime3())
  348. + (record.getClassTime4() == null ? 0d:record.getClassTime4())
  349. + (record.getClassTime5() == null ? 0d:record.getClassTime5())
  350. + (record.getClassTime6() == null ? 0d:record.getClassTime6());
  351. classTimeAmount += BigDecimal.valueOf(classTime).multiply(zkCost).doubleValue();
  352. BigDecimal wzxCost = BigDecimal.ZERO;//晚自习费用
  353. if("FB1601".equals(teacher.getEmployType())){
  354. wzxCost = BigDecimal.valueOf(costSetMap.get("cost5"));
  355. }else{//外聘FB1605、合作人员FB1609
  356. wzxCost = BigDecimal.valueOf(costSetMap.get("cost6"));
  357. }
  358. classTimeAmount += BigDecimal.valueOf(classTime9).multiply(wzxCost).doubleValue();
  359. BigDecimal reduceTimeAmount = BigDecimal.ZERO;
  360. BigDecimal dkCost = BigDecimal.ZERO;//顶课费用,顶课老师加钱
  361. if("FB1601".equals(teacher.getEmployType())){
  362. dkCost = BigDecimal.valueOf(costSetMap.get("cost11"));
  363. }else{//外聘FB1605、合作人员FB1609
  364. dkCost = BigDecimal.valueOf(costSetMap.get("cost12"));
  365. }
  366. if(record.getClassTime10() != null && record.getClassTime10() > 0){
  367. reduceTimeAmount = BigDecimal.valueOf(record.getClassTime10()).multiply(dkCost);
  368. }
  369. BigDecimal bdkCost = BigDecimal.ZERO;//顶课费用,被顶课老师扣钱
  370. if("FB1601".equals(teacher.getEmployType())){
  371. bdkCost = BigDecimal.valueOf(costSetMap.get("cost13")==null?0:costSetMap.get("cost13"));
  372. }else{//外聘FB1605、合作人员FB1609
  373. bdkCost = BigDecimal.valueOf(costSetMap.get("cost14")==null?0:costSetMap.get("cost14"));
  374. }
  375. //计算被扣除的费用
  376. if(record.getClassTime10() != null && record.getClassTime10() < 0){
  377. reduceTimeAmount = bdkCost.multiply(BigDecimal.valueOf(record.getClassTime10()));
  378. }
  379. record.setClassTimeAmount(classTimeAmount);
  380. //计算超出的课时,需要先计算出每个周的开始结束时间
  381. BigDecimal ccksCost = BigDecimal.ZERO;
  382. if("FB1601".equals(teacher.getEmployType())){
  383. ccksCost = BigDecimal.valueOf(costSetMap.get("cost9"));
  384. }else{//外聘FB1605、合作人员FB1609
  385. ccksCost = BigDecimal.valueOf(costSetMap.get("cost10"));
  386. }
  387. //计算出总的超出课时并计算超课时费
  388. beyondClassTimeAmount = BigDecimal.valueOf(allCcksTime).multiply(ccksCost).doubleValue();
  389. if(!"FB1601".equals(teacher.getEmployType())){
  390. record.setBeyondClassTimeAmount(beyondClassTimeAmount);
  391. }
  392. //计算总金额,课时费+超课时费
  393. Double totalAmount = classTimeAmount + beyondClassTimeAmount + reduceTimeAmount.doubleValue();
  394. record.setTotalAmount(totalAmount);
  395. insertList.add(record);
  396. }
  397. if(!insertList.isEmpty()){
  398. //先删除
  399. recordMapper.delete(
  400. new QueryWrapper<ClassTimeStatisticsRecord>().lambda()
  401. .eq(ClassTimeStatisticsRecord::getClassTimeStatisticsId, statistics.getId())
  402. );
  403. for (ClassTimeStatisticsRecord record : insertList) {
  404. recordMapper.insert(record);
  405. }
  406. }
  407. statistics.setAllClassTime(insertList.stream().filter(x -> x.getAllClassTime() != null).mapToDouble(ClassTimeStatisticsRecord::getAllClassTime).sum());
  408. statistics.setTotalAmount(insertList.stream().filter(x -> x.getTotalAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getTotalAmount).sum());
  409. statistics.setBeyondClassTimeAmount(insertList.stream().filter(x -> x.getBeyondClassTimeAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getBeyondClassTimeAmount).sum());
  410. statistics.setClassTimeAmount(insertList.stream().filter(x -> x.getClassTimeAmount() != null).mapToDouble(ClassTimeStatisticsRecord::getClassTimeAmount).sum());
  411. statistics.setStatus(1);
  412. this.updateById(statistics);
  413. return true;
  414. }catch (Exception e){
  415. log.error(e.getMessage());
  416. throw new MyException("统计出错,请联系管理员");
  417. }
  418. }
  419. @Override
  420. public Boolean lockData(Long id) {
  421. ClassTimeStatistics statistics = this.getById(id);
  422. return null;
  423. }
  424. @Override
  425. public List<ClassTimeStatisticsRecordVo> getRecordList(Long id) {
  426. return this.baseMapper.getRecordList(id);
  427. }
  428. /**
  429. * 导出课时统计明细
  430. * @param id
  431. * @return
  432. */
  433. @Override
  434. public byte[] recordExport(Long id) throws IOException {
  435. try {
  436. //1、查询数据
  437. List<ClassTimeStatisticsRecordVo> recordList = this.baseMapper.getRecordList(id);
  438. //计算出一共有多少周
  439. ClassTimeStatistics statistics = this.getById(id);
  440. List<WeekTimeRangeVo> weekTimeRangeVos = calculateNaturalWeeks(statistics.getStartDate(), statistics.getEndDate());
  441. /**
  442. * 2、将查询出来的数据按照表头转换成二维数组
  443. * 前端固定表头:序号、工号、姓名、教研会、督导听课、临近三年退休政策、出题、阅卷、周末培优、早自习、正课(含调顶课时)、晚辅(含调顶课时)、顶课、调课
  444. * 中间动态表头:每周,总课时(含调顶课节)、顶课(节)、调课(节)、晚辅(节)......课时晚辅合计
  445. * 后端固定表头:总课时、课时费(元)、外聘教师超课时费(元)、总金额(元)
  446. */
  447. //计算一共多少列
  448. int column = 19 + (4 * weekTimeRangeVos.size());
  449. List<ArrayList<String>> dataList = new ArrayList<>();
  450. Integer sortCode = 1;
  451. JsonParser parser = new JsonParser();
  452. for (ClassTimeStatisticsRecordVo recordVo : recordList) {
  453. ArrayList<String> rowData = new ArrayList<>();
  454. rowData.add(sortCode.toString());//序号
  455. rowData.add(recordVo.getUserName());//工号
  456. rowData.add(recordVo.getName());//姓名
  457. rowData.add(recordVo.getClassTime1()==null?"":recordVo.getClassTime1().toString());//教研会
  458. rowData.add(recordVo.getClassTime2()==null?"":recordVo.getClassTime2().toString());//督导听课
  459. rowData.add(recordVo.getClassTime3()==null?"":recordVo.getClassTime3().toString());//临近三年退休政策
  460. rowData.add(recordVo.getClassTime4()==null?"":recordVo.getClassTime4().toString());//出题
  461. rowData.add(recordVo.getClassTime5()==null?"":recordVo.getClassTime5().toString());//阅卷
  462. rowData.add(recordVo.getClassTime6()==null?"":recordVo.getClassTime6().toString());//周末培优
  463. rowData.add(recordVo.getClassTime7()==null?"":recordVo.getClassTime7().toString());//早自习
  464. rowData.add(recordVo.getClassTime8()==null?"":recordVo.getClassTime8().toString());//正课(含调顶课时)
  465. rowData.add(recordVo.getClassTime9()==null?"":recordVo.getClassTime9().toString());//晚辅(含调顶课时)
  466. rowData.add(recordVo.getClassTime10()==null?"":recordVo.getClassTime10().toString());//顶课
  467. rowData.add(recordVo.getClassTime11()==null?"":recordVo.getClassTime11().toString());//调课
  468. //每周数据
  469. JsonObject weekDataJson = parser.parse(recordVo.getWeekData()).getAsJsonObject();
  470. JsonArray weekDataArray = weekDataJson.getAsJsonArray("weekData");
  471. for (int i = 0; i < weekDataArray.size(); i ++){
  472. JsonObject jsonElement = weekDataArray.get(i).getAsJsonObject();
  473. rowData.add(jsonElement.get("zkTimes").getAsString());//总课时(含调顶课节)
  474. rowData.add(jsonElement.get("dkTimes").getAsString());//顶课(节)
  475. rowData.add(jsonElement.get("tkTimes").getAsString());//调课(节)
  476. rowData.add(jsonElement.get("wzxTimes").getAsString());//晚辅(节)
  477. }
  478. rowData.add(weekDataJson.get("allTimes").getAsString());//课时晚辅合计
  479. rowData.add(recordVo.getAllClassTime().toString());//总课时
  480. rowData.add(recordVo.getClassTimeAmount().toString());//课时费(元)
  481. rowData.add(recordVo.getBeyondClassTimeAmount()==null?"":recordVo.getBeyondClassTimeAmount().toString());//外聘教师超课时费(元)
  482. rowData.add(recordVo.getTotalAmount().toString());//总金额(元)
  483. dataList.add(rowData);
  484. sortCode ++;
  485. }
  486. // 创建一个新的工作簿
  487. Workbook workbook = new XSSFWorkbook();
  488. // 创建一个工作表(sheet)
  489. String sheetName = "数据";
  490. Sheet sheet = workbook.createSheet(sheetName);
  491. // 创建一个字体对象
  492. Font font = workbook.createFont();
  493. font.setBold(true);// 设置为粗体
  494. font.setFontName("宋体");
  495. //font.setColor(IndexedColors.RED.getIndex()); // 设置字体颜色为红色
  496. font.setFontHeightInPoints((short)24);
  497. // 创建一个单元格样式对象
  498. CellStyle cellStyle = workbook.createCellStyle();
  499. cellStyle.setFont(font); // 将字体应用到样式
  500. cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
  501. cellStyle.setAlignment(HorizontalAlignment.CENTER);
  502. // 第一行表头
  503. {
  504. Row row = sheet.createRow(0);
  505. //合并第一行的列
  506. sheet.addMergedRegion(new CellRangeAddress(0, 0, 0, column - 1));
  507. //3、处理表头
  508. String title1 = statistics.getYear() + "年" + statistics.getMonth() + "月课时统计";
  509. // 创建单元格并设置值
  510. Cell cell = row.createCell(0);
  511. cell.setCellValue(title1);
  512. cell.setCellStyle(cellStyle);
  513. }
  514. //第二行表头
  515. createSecondTitle(workbook, sheet, statistics, weekTimeRangeVos.size() * 4 + 1);
  516. //第三行表头
  517. createThirdTitle(workbook, sheet, statistics.getMonth(), weekTimeRangeVos, 13);
  518. //第四行表头
  519. createFourthTitle(workbook, sheet, weekTimeRangeVos, 13);
  520. int dataRowNumber = 4;
  521. //设置样式
  522. font = workbook.createFont();
  523. font.setBold(false);// 设置为粗体
  524. font.setFontName("宋体");
  525. //font.setColor(IndexedColors.RED.getIndex()); // 设置字体颜色为红色
  526. font.setFontHeightInPoints((short)12);
  527. // 创建一个单元格样式对象
  528. cellStyle = workbook.createCellStyle();
  529. cellStyle.setFont(font); // 将字体应用到样式
  530. cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
  531. cellStyle.setAlignment(HorizontalAlignment.CENTER);
  532. for (ArrayList<String> rowData : dataList) {
  533. Row dataRow = sheet.createRow(dataRowNumber);
  534. for (int i = 0; i < rowData.size(); i ++){
  535. Cell row1cell2 = dataRow.createCell(i);
  536. row1cell2.setCellValue(rowData.get(i));
  537. row1cell2.setCellStyle(cellStyle);
  538. }
  539. dataRowNumber ++;
  540. }
  541. //写入文件
  542. ByteArrayOutputStream bot = new ByteArrayOutputStream();
  543. workbook.write(bot);
  544. return bot.toByteArray();
  545. }catch (Exception e){
  546. log.error(e.getMessage());
  547. throw new MyException("导出出错,请联系管理员");
  548. }
  549. }
  550. /**
  551. * 生成第二行表头
  552. * 前端固定表头:序号、工号、姓名、教研会、督导听课、临近三年退休政策、出题、阅卷、周末培优、早自习、正课(含调顶课时)、晚辅(含调顶课时)、顶课、调课
  553. * 中间动态表头:每周,总课时(含调顶课节)、顶课(节)、调课(节)、晚辅(节)......课时晚辅合计
  554. * 后端固定表头:总课时、课时费(元)、外聘教师超课时费(元)、总金额(元)
  555. */
  556. void createSecondTitle(Workbook workbook, Sheet sheet, ClassTimeStatistics statistics, int mergeCoulmn){
  557. Font font = workbook.createFont();
  558. font.setFontName("宋体");
  559. font.setFontHeightInPoints((short)12);
  560. CellStyle cellStyle = workbook.createCellStyle();
  561. cellStyle.setFont(font); // 将字体应用到样式
  562. cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
  563. cellStyle.setAlignment(HorizontalAlignment.CENTER);
  564. Row row1 = sheet.createRow(1);
  565. Cell row1cell1 = row1.createCell(0);
  566. row1cell1.setCellValue("序号");
  567. row1cell1.setCellStyle(cellStyle);
  568. Cell row1cell2 = row1.createCell(1);
  569. row1cell2.setCellValue("工号");
  570. row1cell2.setCellStyle(cellStyle);
  571. Cell row1cell3 = row1.createCell(2);
  572. row1cell3.setCellValue("姓名");
  573. row1cell3.setCellStyle(cellStyle);
  574. Cell row1cell4 = row1.createCell(3);
  575. row1cell4.setCellValue("教研会");
  576. row1cell4.setCellStyle(cellStyle);
  577. Cell row1cell5 = row1.createCell(4);
  578. row1cell5.setCellValue("督导听课");
  579. row1cell5.setCellStyle(cellStyle);
  580. Cell row1cell6 = row1.createCell(5);
  581. row1cell6.setCellValue("临近三年退休政策");
  582. row1cell6.setCellStyle(cellStyle);
  583. Cell row1cell7 = row1.createCell(6);
  584. row1cell7.setCellValue("出题");
  585. row1cell7.setCellStyle(cellStyle);
  586. Cell row1cell8 = row1.createCell(7);
  587. row1cell8.setCellValue("阅卷");
  588. row1cell8.setCellStyle(cellStyle);
  589. Cell row1cell9 = row1.createCell(8);
  590. row1cell9.setCellValue("周末培优");
  591. row1cell9.setCellStyle(cellStyle);
  592. Cell row1cell10 = row1.createCell(9);
  593. row1cell10.setCellValue("早自习");
  594. row1cell10.setCellStyle(cellStyle);
  595. Cell row1cell11 = row1.createCell(10);
  596. row1cell11.setCellValue("正课(含调顶课时)");
  597. row1cell11.setCellStyle(cellStyle);
  598. Cell row1cell12 = row1.createCell(11);
  599. row1cell12.setCellValue("晚辅(含调顶课时)");
  600. row1cell12.setCellStyle(cellStyle);
  601. Cell row1cell13 = row1.createCell(12);
  602. row1cell13.setCellValue("顶课");
  603. row1cell13.setCellStyle(cellStyle);
  604. Cell row1cell14 = row1.createCell(13);
  605. row1cell14.setCellValue("调课");
  606. row1cell14.setCellStyle(cellStyle);
  607. Cell row1cell15 = row1.createCell(14);
  608. row1cell15.setCellValue("正课课时数(平台导出" + statistics.getMonth() + "月)");
  609. row1cell15.setCellStyle(cellStyle);
  610. int index = 14 + mergeCoulmn;
  611. Cell row1cell16 = row1.createCell(index);
  612. row1cell16.setCellValue("总课时");
  613. row1cell16.setCellStyle(cellStyle);
  614. Cell row1cell17 = row1.createCell(index + 1);
  615. row1cell17.setCellValue("课时费(元)");
  616. row1cell17.setCellStyle(cellStyle);
  617. Cell row1cell18 = row1.createCell(index + 2);
  618. row1cell18.setCellValue("外聘教师超课时费(元)");
  619. row1cell18.setCellStyle(cellStyle);
  620. Cell row1cell19 = row1.createCell(index + 3);
  621. row1cell19.setCellValue("总金额(元)");
  622. row1cell19.setCellStyle(cellStyle);
  623. //合并表头
  624. for(int i = 0; i < 14; i ++){
  625. sheet.addMergedRegion(new CellRangeAddress(1, 3, i, i));
  626. }
  627. //合并中间动态表头
  628. sheet.addMergedRegion(new CellRangeAddress(1, 1, 14, index - 1));
  629. //合并前端表头
  630. for(int i = index; i < index + 4; i ++){
  631. sheet.addMergedRegion(new CellRangeAddress(1, 3, i, i));
  632. }
  633. }
  634. /**
  635. * 生成第三行表头
  636. * 关于周的表头,周一日期到周二日期,第几周,最后拼接一个单独的月份
  637. *
  638. * @param workbook
  639. * @param sheet
  640. * @param month 月份
  641. * @param weekTimeRangeVos 周的数据,包含周一的日期周二的日期
  642. * @param lastIndex 前一个表头的单元格
  643. */
  644. void createThirdTitle(Workbook workbook, Sheet sheet, int month, List<WeekTimeRangeVo> weekTimeRangeVos, int lastIndex){
  645. Font font = workbook.createFont();
  646. font.setFontName("宋体");
  647. font.setFontHeightInPoints((short)12);
  648. CellStyle cellStyle = workbook.createCellStyle();
  649. cellStyle.setFont(font); // 将字体应用到样式
  650. cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
  651. cellStyle.setAlignment(HorizontalAlignment.CENTER);
  652. //设置内容
  653. DateTimeFormatter formatter = DateTimeFormatter.ofPattern("MM.dd");
  654. int rowNumber = 2;
  655. Row row2 = sheet.createRow(rowNumber);
  656. for(int i = 0; i < weekTimeRangeVos.size(); i ++){
  657. WeekTimeRangeVo rangeVo = weekTimeRangeVos.get(i);
  658. String cellValue = rangeVo.getMondayDate().format(formatter) + "-"
  659. + rangeVo.getSundayDate().format(formatter) + "(第" + rangeVo.getWeeks() + "周)";
  660. Cell row1cell1 = row2.createCell(lastIndex + 1 + (i * 4));
  661. row1cell1.setCellValue(cellValue);
  662. row1cell1.setCellStyle(cellStyle);
  663. }
  664. //合并单元格
  665. int monthIndex = 0;
  666. for(int i = 0; i < weekTimeRangeVos.size(); i ++){
  667. int startCoulmn = lastIndex + 1 + (i * 4);
  668. int endCoulmn = startCoulmn + 3;
  669. sheet.addMergedRegion(new CellRangeAddress(rowNumber, rowNumber, startCoulmn, endCoulmn));
  670. monthIndex = endCoulmn;
  671. }
  672. Cell row1cell2 = row2.createCell(monthIndex + 1);
  673. row1cell2.setCellValue(month + "月");
  674. row1cell2.setCellStyle(cellStyle);
  675. }
  676. /**
  677. * 生成第四行表头
  678. * 表头内容:总课时(含调顶课节)、顶课(节)、顶课(节)、晚辅(节)、课时晚辅合计
  679. *
  680. * @param workbook
  681. * @param sheet
  682. * @param weekTimeRangeVos 周的数据,包含周一的日期周二的日期
  683. * @param lastIndex 前一个表头的单元格
  684. */
  685. void createFourthTitle(Workbook workbook, Sheet sheet, List<WeekTimeRangeVo> weekTimeRangeVos, int lastIndex){
  686. Font font = workbook.createFont();
  687. font.setFontName("宋体");
  688. font.setFontHeightInPoints((short)12);
  689. CellStyle cellStyle = workbook.createCellStyle();
  690. cellStyle.setFont(font); // 将字体应用到样式
  691. cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
  692. cellStyle.setAlignment(HorizontalAlignment.CENTER);
  693. int rowNumber = 3;
  694. Row row2 = sheet.createRow(rowNumber);
  695. int index = lastIndex + 1;
  696. for(int i = 0; i < weekTimeRangeVos.size(); i ++){
  697. Cell row1cell1 = row2.createCell(index);
  698. row1cell1.setCellValue("总课时(含调顶课节)");
  699. row1cell1.setCellStyle(cellStyle);
  700. index ++;
  701. Cell row1cell2 = row2.createCell(index);
  702. row1cell2.setCellValue("顶课(节)");
  703. row1cell2.setCellStyle(cellStyle);
  704. index ++;
  705. Cell row1cell3 = row2.createCell(index);
  706. row1cell3.setCellValue("顶课(节)");
  707. row1cell3.setCellStyle(cellStyle);
  708. index ++;
  709. Cell row1cell4 = row2.createCell(index);
  710. row1cell4.setCellValue("晚辅(节)");
  711. row1cell4.setCellStyle(cellStyle);
  712. index ++;
  713. }
  714. Cell row1cell5 = row2.createCell(index);
  715. row1cell5.setCellValue("课时晚辅合计");
  716. row1cell5.setCellStyle(cellStyle);
  717. }
  718. //计算日期内一共几个周,并返回每周的周一日期和周日日期
  719. private static List<WeekTimeRangeVo> calculateNaturalWeeks(LocalDate startDate, LocalDate endDate) {
  720. List<WeekTimeRangeVo> result = new ArrayList<>();
  721. // 获取第一个周一
  722. LocalDate currentMonday = startDate.with(DayOfWeek.MONDAY);
  723. // 如果 startDate 不是周一,则用下一个周一
  724. if (!startDate.isEqual(currentMonday) && startDate.isAfter(currentMonday)) {
  725. currentMonday = currentMonday.plusWeeks(1);
  726. }
  727. int weeks = 1;
  728. // 遍历每个周
  729. while (!currentMonday.isAfter(endDate)) {
  730. // 计算当前周的周日
  731. LocalDate currentSunday = currentMonday.plusDays(6);
  732. // 限制周日的范围
  733. if (currentSunday.isAfter(endDate)) {
  734. currentSunday = endDate;
  735. }
  736. // 添加结果
  737. WeekTimeRangeVo timeRangeVo = new WeekTimeRangeVo();
  738. timeRangeVo.setMondayDate(currentMonday);
  739. timeRangeVo.setSundayDate(currentSunday);
  740. timeRangeVo .setWeeks(weeks);
  741. result.add(timeRangeVo);
  742. // 移动到下一个周的周一
  743. currentMonday = currentMonday.plusWeeks(1);
  744. weeks ++;
  745. }
  746. return result;
  747. }
  748. }