api/src/main/java/com/xjrsoft/module/schedule/controller/ScheduleController.java

package com.xjrsoft.module.schedule.controller;

import cn.dev33.satoken.annotation.SaCheckPermission;
import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Db;
import com.google.gson.JsonArray;
import com.xjrsoft.common.constant.GlobalConstant;
import com.xjrsoft.common.enums.DeleteMark;
import com.xjrsoft.common.enums.EnabledMark;
import com.xjrsoft.common.model.result.RT;
import com.xjrsoft.common.utils.DatasourceUtil;
import com.xjrsoft.module.base.entity.BaseSemester;
import com.xjrsoft.module.courseTable.service.ICourseTableService;
import com.xjrsoft.module.schedule.dto.CourseTableDto;
import com.xjrsoft.module.schedule.entity.CourseReceiveMsg;
import com.xjrsoft.module.schedule.entity.JianyueData;
import com.xjrsoft.module.schedule.service.ICourseReceiveMsgService;
import com.xjrsoft.module.schedule.service.IJianyueDataService;
import com.xjrsoft.module.schedule.util.DataUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.sql.DataSource;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

/**
* @title: 寝室
* @Author dzx
* @Date: 2023-12-27
* @Version 1.0i see you monster歌曲
*/
@RestController
@RequestMapping("/schedule" + "/schedule")
@Api(value = "/schedule"  + "/schedule",tags = "课表代码")
@AllArgsConstructor
public class ScheduleController {


    private final ICourseReceiveMsgService courseReceiveMsgService;
    private final IJianyueDataService jianyueDataService;
    private final ICourseTableService courseTableService;

    @GetMapping(value = "/receive-msg")
    @ApiOperation(value="接收消息")
    @SaCheckPermission("room:detail")
    public RT<CourseReceiveMsg> receiveMsg(@RequestParam String schoolId, @RequestParam String eduYearSerialNo, @RequestParam String startDate, @RequestParam String endDate) throws Exception {
        CourseReceiveMsg courseReceiveMsg = new CourseReceiveMsg();
        courseReceiveMsg.setCreateDate(new Date());
        courseReceiveMsg.setSchoolId(schoolId);
        courseReceiveMsg.setEduYearSerialNo(eduYearSerialNo);
        courseReceiveMsg.setStartDate(startDate);
        courseReceiveMsg.setEndDate(endDate);
        courseReceiveMsg.setDeleteMark(DeleteMark.NODELETE.getCode());
        courseReceiveMsg.setEnabledMark(EnabledMark.ENABLED.getCode());
        courseReceiveMsgService.save(courseReceiveMsg);

        DataSource datasource = DatasourceUtil.getDataSource(GlobalConstant.DEFAULT_DATASOURCE_KEY);
        Db use = Db.use(datasource);
        DataUtil dataUtil = new DataUtil();
        JsonArray scheduleInfo = dataUtil.getScheduleInfoByGrade(eduYearSerialNo, startDate, endDate);
        String sql = "SELECT distinct table_name FROM jianyue_data WHERE 1 = 1";
        List<JianyueData> query = use.query(sql, JianyueData.class);
        Set<String> tables = new HashSet<>();
        for (JianyueData jianyueData : query) {
            tables.add(jianyueData.getTableName());
        }
        sql = "SELECT * FROM jianyue_data WHERE 0 = 0";
        List<JianyueData> list = use.query(sql, JianyueData.class);
        Map<String, Map<String, Long>> dataMap = new HashMap<>();
        for (String table : tables) {
            Map<String, Long> tableData = new HashMap<>();
            for (JianyueData jianyueData : list) {
                if(!table.equals(jianyueData.getTableName())){
                    continue;
                }
                tableData.put(jianyueData.getJianyueId(), jianyueData.getSourceId());
            }
            dataMap.put(table, tableData);
        }

        //获取学期
        String tableName = "base_semester";
        Map<String, Long> semesterMap = dataMap.get(tableName);
        //获取课程
        tableName = "base_course_subject";
        Map<String, Long> courseMap = dataMap.get(tableName);
        //获取教职工
        tableName = "base_teacher";
        Map<String, Long> teacherMap = dataMap.get(tableName);
        //获取行政班
        tableName = "base_class";
        Map<String, Long> classMap = dataMap.get(tableName);

        tableName = "base_classroom";
        Map<String, Long> classroomMap = dataMap.get(tableName);
        dataUtil.insertCourseTable(use, scheduleInfo, classroomMap, courseMap, semesterMap, teacherMap, classMap);

        //查询当前学期id
        String currenSemeter = dataUtil.getCurrenSemeter();
        if(StrUtil.isEmpty(currenSemeter)){
            return RT.ok(courseReceiveMsg);
        }
        sql = "SELECT * FROM base_semester WHERE id = (select source_id from jianyue_data where jianyue_id = '" + currenSemeter + "')";
        List<BaseSemester> semesters = use.query(sql, BaseSemester.class);
        if(semesters.isEmpty()){
            return RT.ok(courseReceiveMsg);
        }
        BaseSemester baseSemester = semesters.get(0);
        dataUtil.insertClassTime(use, scheduleInfo, baseSemester);
        return RT.ok(courseReceiveMsg);
    }

    @GetMapping(value = "/course-table")
    @ApiOperation(value="接收消息")
    @SaCheckPermission("room:detail")
    public RT<CourseReceiveMsg> courseInfo(CourseTableDto dto){
        courseTableService.list();
        return null;
    }

}