api/src/main/java/com/xjrsoft/module/schedule/util/DataUtil.java

package com.xjrsoft.module.schedule.util;

import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Entity;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.xjrsoft.common.mybatis.SqlRunnerAdapter;
import com.xjrsoft.common.utils.SqlRunnerAdapterUtil;
import com.xjrsoft.module.base.entity.*;
import com.xjrsoft.module.organization.entity.Department;
import com.xjrsoft.module.schedule.vo.StudentJianyuekbVo;
import com.xjrsoft.module.teacher.entity.XjrUser;
import lombok.extern.slf4j.Slf4j;

import java.text.SimpleDateFormat;
import java.util.*;

/**
 * @author dzx
 * @date 2024/1/23
 */
@Slf4j
public class DataUtil {

    /**
     * 推送校区信息
     * 此处将班级所属的部门当做校区进行推送
     */
    public Map<String, String> insertSchoolDistrict(String tableName, Map<String, String> ids) throws Exception {
        String sql = "SELECT * FROM " + tableName + " WHERE id IN (" +
                "SELECT DISTINCT org_id FROM base_class WHERE delete_mark = 0 " +
                ")";
        List<Map<String, Object>> dataList = SqlRunnerAdapter.db().selectList(sql, Department.class);

        Map<String, String> idMap = new HashMap<>();
        JsonParser jsonParser = new JsonParser();
        for (Map<String, Object> departmentMap : dataList) {
            Department department = SqlRunnerAdapterUtil.convertMapToEntity(departmentMap, Department.class);
            String url = ScheduleUtil.apiUrl + "SchoolDistrict/Create";
            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("name", department.getName());

            paramJson.addProperty("not", department.getRemark());
            paramJson.addProperty("sort", department.getSortCode());
            paramJson.addProperty("shortName", department.getName());
            paramJson.addProperty("extendId", department.getId());
            long timestamp = System.currentTimeMillis();
            String sign = ScheduleUtil.createSign(timestamp);
            ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (ids != null && ids.get(department.getId().toString()) != null) {
                url = ScheduleUtil.apiUrl + "SchoolDistrict/Update";
                paramJson.addProperty("id", ids.get(department.getId().toString()));
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }
            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (result == null) {
                continue;
            }
            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            idMap.put(department.getId().toString(), resultJson.get("data").getAsString());
        }
        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    public Map<String, String> insertClass(String tableName, Map<String, String> gradeMap,
                                           Map<String, String> teacherMap, String semesterSerialNo, Map<String, String> ids, Map<String, String> classroomMap) throws Exception {
        String sql = "SELECT * FROM " + tableName + " WHERE delete_mark = 0 and is_graduate = 1";
        List<Map<String, Object>> dataList = SqlRunnerAdapter.db().selectList(sql);

        long timestamp = System.currentTimeMillis();
        //生成签名
        String sign = ScheduleUtil.createSign(timestamp);
        JsonArray semesterSerialNos = new JsonArray();
        semesterSerialNos.add(semesterSerialNo);
        JsonObject paramJson = new JsonObject();
        paramJson.add("semesterSerialNos", semesterSerialNos);
        paramJson.addProperty("pageSize", 200);
        paramJson.addProperty("pageIndex", 1);
        String url = ScheduleUtil.apiUrl + "Class/page";
        String doPost = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);


        JsonParser parser = new JsonParser();
        JsonObject jsonObject = parser.parse(doPost).getAsJsonObject();
        JsonArray jsonArray = jsonObject.get("data").getAsJsonObject().get("dataList").getAsJsonArray();
        List<String> jianyueIds = new ArrayList<>();//当前学期已存在的班级
        for (JsonElement jsonElement : jsonArray) {
            JsonObject object = jsonElement.getAsJsonObject();
            jianyueIds.add(object.get("serialNo").getAsString());
        }


        Map<String, String> idMap = new HashMap<>();
        JsonParser jsonParser = new JsonParser();
        for (Map<String, Object> baseClassMap : dataList) {
            BaseClass baseClass = SqlRunnerAdapterUtil.convertMapToEntity(baseClassMap, BaseClass.class);
            url = ScheduleUtil.apiUrl + "class/create";
            paramJson = new JsonObject();
            if (baseClass.getTeacherId() != null && teacherMap.get(baseClass.getTeacherId().toString()) != null) {
                paramJson.addProperty("teacherSerialNo", teacherMap.get(baseClass.getTeacherId().toString()));
            }
            paramJson.addProperty("name", baseClass.getName());

            paramJson.addProperty("semesterSerialNo", semesterSerialNo);
            paramJson.addProperty("eduYearSerialNo", gradeMap.get(baseClass.getOrgId() + "_" + baseClass.getGradeId().toString()));
            paramJson.addProperty("extendId", baseClass.getId());
            if (baseClass.getClassroomId() != null && classroomMap.get(baseClass.getClassroomId().toString()) != null) {
                paramJson.addProperty("classRoomSerialNo", classroomMap.get(baseClass.getClassroomId().toString()));
            }
            if (ids != null && ids.get(baseClass.getId().toString()) != null && jianyueIds.contains(ids.get(baseClass.getId().toString()))) {
                url = ScheduleUtil.apiUrl + "class/update";
                paramJson.addProperty("serialNo", ids.get(baseClass.getId().toString()));
                timestamp = System.currentTimeMillis();
                //生成签名
                sign = ScheduleUtil.createSign(timestamp);
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }

            //获取时间戳
            timestamp = System.currentTimeMillis();
            //生成签名
            sign = ScheduleUtil.createSign(timestamp);
            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (result == null) {
                continue;
            }
            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            if (!"".equals(resultJson.get("data").getAsString())) {
                idMap.put(baseClass.getId().toString(), resultJson.get("data").getAsString());
            }
        }
        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    public Map<String, String> insertClassRoom(String tableName, String schoolDistrictId, Map<String, String> ids) throws Exception {
        String sql = "SELECT t1.name, t1.capacity AS people_count,t2.name AS location, t1.floor_num AS floor, t1.id AS extendId FROM " + tableName + " t1" +
                " INNER JOIN base_office_build t2 ON t1.office_build_id = t2.id" +
                " WHERE t1.delete_mark = 0 AND t2.delete_mark = 0";
        List<Map<String, Object>> dataList = SqlRunnerAdapter.db().selectList(sql);

        JsonParser jsonParser = new JsonParser();
        Map<String, String> idMap = new HashMap<>();
        for (Map<String, Object> classroom : dataList) {
            String url = ScheduleUtil.apiUrl + "classroom/create";
            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("schoolDistrictId", schoolDistrictId);
            paramJson.addProperty("name", classroom.get("name").toString());

            paramJson.addProperty("peopleCount", 50);
            paramJson.addProperty("location", classroom.get("location") == null ? "" : classroom.get("location").toString());
            paramJson.addProperty("extendId", classroom.get("extendId").toString());
            paramJson.addProperty("floor", classroom.get("floor") == null ? 0 : Integer.parseInt(classroom.get("floor").toString()));

            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);

            if (ids != null && ids.get(classroom.get("extendId").toString()) != null) {
                url = ScheduleUtil.apiUrl + "classroom/update";
                paramJson.addProperty("serialNo", ids.get(classroom.get("extendId").toString()));
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }

            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (result == null) {
                continue;
            }
            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            idMap.put(classroom.get("extendId").toString(), resultJson.get("data").getAsString());
        }
        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    public Map<String, String> insertStudent(String tableName, Map<String, String> gradeMap, Map<String, String> ids) throws Exception {
        String sql = "SELECT t1.id AS register_no, t2.name AS real_name,t3.grade_id AS grade_serial_no," +
                " t2.name AS alias,t2.gender,t2.id AS extend_id FROM " + tableName + " t1" +
                " INNER JOIN xjr_user t2 ON t1.user_id = t2.id" +
                " INNER JOIN base_student_school_roll t3 ON t1.user_id = t3.user_id" +
                " WHERE t1.delete_mark = 0 AND t2.delete_mark = 0" +
                " AND t1.student_id IS NOT NULL AND t1.student_id != ''" +
                " AND t3.archives_status = 'FB2901'";
        List<Map<String, Object>> dataList = SqlRunnerAdapter.db().selectList(sql, StudentJianyuekbVo.class);

        JsonParser jsonParser = new JsonParser();
        Map<String, String> idMap = new HashMap<>();
        for (Map<String, Object> student : dataList) {
            String url = ScheduleUtil.apiUrl + "student/create";
            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("registerNo", student.get("register_no").toString());
            String gender = student.get("gender") == null ? "SB10001" : student.get("gender").toString();
            if ("SB10001".equals(gender)) {
                paramJson.addProperty("gender", 1);
            } else if ("SB10002".equals(gender)) {
                paramJson.addProperty("gender", 2);
            }

            paramJson.addProperty("realName", student.get("real_name").toString());
            paramJson.addProperty("alias", student.get("alias") == null ? "" : student.get("alias").toString());
            paramJson.addProperty("extendId", student.get("extend_id").toString());
            paramJson.addProperty("gradeSerialNo", gradeMap.get(student.get("grade_serial_no").toString()));
            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);

            if (ids != null && ids.get(student.get("extend_id").toString()) != null) {
                paramJson.addProperty("serialNo", ids.get(student.get("extend_id").toString()));
                url = ScheduleUtil.apiUrl + "student/update";
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }

            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (result == null) {
                continue;
            }
            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            idMap.put(student.get("extend_id").toString(), resultJson.get("data").getAsString());
        }
        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    /**
     * 新增教职工
     */
    public Map<String, String> insertTeacher(String tableName, Map<String, String> ids) throws Exception {
        String sql = "select t1.* from xjr_user t1" +
                " inner join xjr_user_role_relation t2 on t1.id = t2.user_id" +
                " inner join " + tableName + " t3 on t1.id = t3.user_id" +
                " where t1.delete_mark = 0 and t2.role_id = 2";
        List<Map<String, Object>> xjrUsers = SqlRunnerAdapter.db().selectList(sql, XjrUser.class);
        JsonParser jsonParser = new JsonParser();

        Map<String, String> idMap = new HashMap<>();
        for (Map<String, Object> user : xjrUsers) {
            String url = ScheduleUtil.apiUrl + "teacher/create";
            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("jobNumber", user.get("user_name").toString());
            if (user.get("gender") != null) {
                if ("SB10001".equals(user.get("gender").toString())) {
                    paramJson.addProperty("gender", 1);
                } else if ("SB10002".equals(user.get("gender").toString())) {
                    paramJson.addProperty("gender", 2);
                }
            }

            paramJson.addProperty("name", user.get("name").toString());
            paramJson.addProperty("alias", user.get("nick_name") == null ? "" : user.get("nick_name").toString());
            paramJson.addProperty("extendId", user.get("id").toString());
            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);
            if (ids != null && ids.get(user.get("id").toString()) != null) {
                url = ScheduleUtil.apiUrl + "teacher/update";
                paramJson.addProperty("serialNo", ids.get(user.get("id").toString()));
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }

            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (result == null) {
                continue;
            }
            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            idMap.put(user.get("id").toString(), resultJson.get("data").getAsString());
        }
        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    /**
     * 新增课程
     */
    public Map<String, String> insertCourse(String tableName, Map<String, String> ids, Map<String, String> tagMap) throws Exception {
        String sql = "select * from " + tableName + " where delete_mark = 0";
        List<Map<String, Object>> list = SqlRunnerAdapter.db().selectList(sql, BaseCourseSubject.class);

        Map<String, String> idMap = new HashMap<>();
        JsonParser jsonParser = new JsonParser();
        for (Map<String, Object> courseSubjectMap : list) {
            BaseCourseSubject courseSubject = SqlRunnerAdapterUtil.convertMapToEntity(courseSubjectMap, BaseCourseSubject.class);
            String url = ScheduleUtil.apiUrl + "courseclass/Create";

            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("name", courseSubject.getName());
            paramJson.addProperty("code", courseSubject.getCode());
            paramJson.addProperty("extendId", courseSubject.getId().toString());
            if (courseSubject.getBaseLabelId() != null && tagMap.get(courseSubject.getBaseLabelId().toString()) != null) {
                JsonArray jsonArray = new JsonArray();
                jsonArray.add(tagMap.get(courseSubject.getBaseLabelId().toString()));
                paramJson.add("tagSerialNos", jsonArray);
            }

            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);

            if (ids != null && ids.get(courseSubject.getId().toString()) != null) {
                url = ScheduleUtil.apiUrl + "courseclass/update";
                paramJson.addProperty("id", ids.get(courseSubject.getId().toString()));
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }

            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
            if (result == null) {
                continue;
            }
            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            if (StrUtil.isEmpty(resultJson.get("data").getAsString())) {
                continue;
            }
            idMap.put(courseSubject.getId().toString(), resultJson.get("data").getAsString());
        }
        //插入记录表
        insertRecord(tableName, idMap);

        return idMap;
    }

    /**
     * 新增学期
     */
    public Map<String, String>
    insertSemester(String tableName, Map<String, String> ids) throws Exception {
        String sql = "select * from " + tableName + " where delete_mark = 0 order by start_date desc limit 3";
        List<Map<String, Object>> list = SqlRunnerAdapter.db().selectList(sql, BaseSemester.class);

        Map<String, String> idMap = new HashMap<>();
        JsonParser jsonParser = new JsonParser();
        SimpleDateFormat sdfYear = new SimpleDateFormat("yyyy");
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String spring = "春";
        String autumn = "秋";

        for (Map<String, Object> semesterMap : list) {
            BaseSemester semester = SqlRunnerAdapterUtil.convertMapToEntity(semesterMap, BaseSemester.class);
            String url = ScheduleUtil.apiUrl + "semester/Create";
            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("schoolYear", Integer.parseInt(sdfYear.format(semester.getStartDate())) - 1);
            Integer period = null;
            if (semester.getName().contains(spring)) {
                period = 2;
            } else if (semester.getName().contains(autumn)) {
                period = 1;
            }
            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);
            paramJson.addProperty("period", period);
            paramJson.addProperty("startDate", sdf.format(semester.getTeachingStart()));
            paramJson.addProperty("endDate", sdf.format(semester.getTeachingEnd()));
            paramJson.addProperty("extendId", semester.getId().toString());

            if (semester.getStartDate() != null && semester.getTeachingStart() != null && semester.getTeachingEnd().getTime() > timestamp && semester.getTeachingStart().getTime() < timestamp) {
                paramJson.addProperty("isCurrent", Boolean.TRUE);
            } else if (semester.getStartDate() != null && semester.getTeachingStart() != null && semester.getTeachingEnd().getTime() > timestamp && semester.getTeachingStart().getTime() > timestamp) {
                paramJson.addProperty("isCurrent", Boolean.TRUE);
            } else {
                paramJson.addProperty("isCurrent", Boolean.FALSE);
            }
            if (ids != null && ids.get(semester.getId().toString()) != null) {
                url = ScheduleUtil.apiUrl + "semester/update";
                paramJson.addProperty("serialNo", ids.get(semester.getId().toString()));
                ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                continue;
            }

            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);

            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
            if (StrUtil.isNotEmpty(resultJson.get("data").getAsString())) {
                idMap.put(semester.getId().toString(), resultJson.get("data").getAsString());
            }
        }
        //插入记录表
        insertRecord(tableName, idMap);

        return idMap;
    }

    public Map<String, String> insertCourseTag(String tableName, Map<String, String> ids) throws Exception {
        String sql = "select * from " + tableName + " where delete_mark = 0" +
                " and id in (select distinct base_label_id from base_course_subject where delete_mark = 0)";
        List<Map<String, Object>> list = SqlRunnerAdapter.db().selectList(sql, BaseLabel.class);
        String url = ScheduleUtil.apiUrl + "courseclass/tag/create";
        JsonParser jsonParser = new JsonParser();
        Map<String, String> idMap = new HashMap<>();
        for (Map<String, Object> departmentMap : list) {
            BaseLabel department = SqlRunnerAdapterUtil.convertMapToEntity(departmentMap, BaseLabel.class);
            if (ids != null && ids.get(department.getId().toString()) != null) {
                continue;
            }
            JsonObject paramJson = new JsonObject();
            paramJson.addProperty("name", department.getName());

            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);

            String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);

            JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();

            idMap.put(department.getId().toString(), resultJson.get("data").getAsString());
        }
        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    /**
     * 插入年级
     *
     * @param tableName         表名字
     * @param schoolDistrictMap 校区id
     * @param ids               数据库id和jianyue的对应关系
     * @return 返回数据库和jianyue的对应关系
     */
    public Map<String, String> insertGrade(String tableName, Map<String, String> schoolDistrictMap, Map<String, String> ids) throws Exception {
        String sql = "select * from " + tableName + " where delete_mark = 0 and status = 1";
        List<Map<String, Object>> list = SqlRunnerAdapter.db().selectList(sql, BaseGrade.class);

        JsonParser jsonParser = new JsonParser();
        Map<String, String> idMap = new HashMap<>();
        for (String gradeId : schoolDistrictMap.keySet()) {
            for (Map<String, Object> baseGradeMap : list) {
                BaseGrade baseGrade = SqlRunnerAdapterUtil.convertMapToEntity(baseGradeMap, BaseGrade.class);
                String url = ScheduleUtil.apiUrl + "eduyear/create";
                JsonObject paramJson = new JsonObject();
                paramJson.addProperty("schoolDistrictId", schoolDistrictMap.get(gradeId));
                paramJson.addProperty("period", 4);
                paramJson.addProperty("startYear", baseGrade.getTitle().replaceAll("年", ""));
                paramJson.addProperty("extendId", baseGrade.getId().toString());
                paramJson.addProperty("year", 3);

                //获取时间戳
                long timestamp = System.currentTimeMillis();
                //生成签名
                String sign = ScheduleUtil.createSign(timestamp);

                if (ids != null && ids.get(gradeId + "_" + baseGrade.getId().toString()) != null) {
                    paramJson.addProperty("serialNo", ids.get(gradeId + "_" + baseGrade.getId().toString()));
                    url = ScheduleUtil.apiUrl + "eduyear/update";
                    ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);
                    continue;
                }

                String result = ScheduleUtil.doPost(url, paramJson.toString(), sign, timestamp);

                JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();

                idMap.put(gradeId + "_" + baseGrade.getId().toString(), resultJson.get("data").getAsString());
            }
        }

        //插入记录表
        insertRecord(tableName, idMap);
        return idMap;
    }

    /**
     * 查询校区id
     */
    public JsonArray getSchoolDistrictData() throws Exception {
        JsonParser jsonParser = new JsonParser();

        String url = ScheduleUtil.apiUrl + "SchoolDistrict/page";
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty("pageSize", "15");
        jsonObject.addProperty("pageIndex", "1");

        //获取时间戳
        long timestamp = System.currentTimeMillis();
        //生成签名
        String sign = ScheduleUtil.createSign(timestamp);
        String result = ScheduleUtil.doPost(url, jsonObject.toString(), sign, timestamp);
        JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();

        JsonArray jsonArray = resultJson.get("data").getAsJsonObject().get("dataList").getAsJsonArray();
        JsonArray resultArray = new JsonArray();
        for (JsonElement jsonElement : jsonArray) {
            JsonObject asJsonObject = jsonElement.getAsJsonObject();
            resultArray.add(asJsonObject.get("id").getAsString());
        }
        return resultArray;
    }

    /**
     * 查询当前学期的id
     *
     * @return 返回当前学期的id
     */
    public String getCurrenSemeter() throws Exception {
        JsonParser jsonParser = new JsonParser();

        String url = ScheduleUtil.apiUrl + "Semester/Page";
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty("pageSize", "15");
        jsonObject.addProperty("pageIndex", "1");

        //获取时间戳
        long timestamp = System.currentTimeMillis();
        //生成签名
        String sign = ScheduleUtil.createSign(timestamp);
        String result = ScheduleUtil.doPost(url, jsonObject.toString(), sign, timestamp);
        JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();

        JsonArray jsonArray = resultJson.get("data").getAsJsonObject().get("dataList").getAsJsonArray();
        String currentSemeterId = null;
        for (JsonElement jsonElement : jsonArray) {
            JsonObject asJsonObject = jsonElement.getAsJsonObject();
            if (asJsonObject.get("isCurrent").getAsBoolean()) {
                currentSemeterId = asJsonObject.get("serialNo").getAsString();
            }
        }
        return currentSemeterId;
    }

    public JsonArray getScheduleInfoByClass(Map<String, Long> classMap, Date startDate, Date endDate) throws Exception {
        JsonParser jsonParser = new JsonParser();
        String url = ScheduleUtil.apiUrl + "TimeTable/List";
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        JsonArray dataMap = new JsonArray();
        for (String classId : classMap.keySet()) {
            //获取时间戳
            long timestamp = System.currentTimeMillis();
            //生成签名
            String sign = ScheduleUtil.createSign(timestamp);
            JsonObject jsonObject = new JsonObject();
            jsonObject.addProperty("classSerialNo", classId);
            jsonObject.addProperty("startDate", sdf.format(startDate));
            jsonObject.addProperty("endDate", sdf.format(endDate));
            String result = ScheduleUtil.doPost(url, jsonObject.toString(), sign, timestamp);

            JsonObject asJsonObject = jsonParser.parse(result).getAsJsonObject();
            dataMap.addAll(asJsonObject.get("data").getAsJsonArray());
        }
        return dataMap;
    }

    public JsonArray getScheduleInfoByGrade(String eduYearSerialNo, String startDate, String endDate) throws Exception {
        JsonParser jsonParser = new JsonParser();
        String url = ScheduleUtil.apiUrl + "TimeTable/List";
        //获取时间戳
        long timestamp = System.currentTimeMillis();
        //生成签名
        String sign = ScheduleUtil.createSign(timestamp);
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty("eduYearSerialNo", eduYearSerialNo);
        jsonObject.addProperty("startDate", startDate);
        jsonObject.addProperty("endDate", endDate);
        String result = ScheduleUtil.doPost(url, jsonObject.toString(), sign, timestamp);
        JsonObject asJsonObject = jsonParser.parse(result).getAsJsonObject();
        return asJsonObject.get("data").getAsJsonArray();
    }

    public JsonArray getScheduleInfoByClass(String classSerialNo, String startDate, String endDate) throws Exception {
        JsonParser jsonParser = new JsonParser();
        String url = ScheduleUtil.apiUrl + "TimeTable/List";
        //获取时间戳
        long timestamp = System.currentTimeMillis();
        //生成签名
        String sign = ScheduleUtil.createSign(timestamp);
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty("classSerialNo", classSerialNo);
        jsonObject.addProperty("startDate", startDate);
        jsonObject.addProperty("endDate", endDate);
        String result = ScheduleUtil.doPost(url, jsonObject.toString(), sign, timestamp);
        JsonObject asJsonObject = jsonParser.parse(result).getAsJsonObject();
        return asJsonObject.get("data").getAsJsonArray();
    }

    /**
     * @param data         接口数据
     * @param classroomMap 教室对应关系
     * @param coureseMap   课程对应关系
     * @param semesterMap  学期对应关系
     * @param teacherMap   教师对应关系
     */
    public void insertCourseTable(JsonArray data, Map<String, String> classroomMap, Map<String, String> coureseMap,
                                  Map<String, String> semesterMap, Map<String, String> teacherMap, Map<String, String> classMap) {
//        List<String> sqls = new ArrayList<>();
//        Map<Integer, String> week = ScheduleUtil.getWeek();
        Map<Integer, Integer> tmePeriod = ScheduleUtil.getTmePeriod();
        int count = 1;
        for (JsonElement jsonElement : data) {
            JsonObject asJsonObject = jsonElement.getAsJsonObject();
            long id = System.currentTimeMillis();
            JsonArray teachers = asJsonObject.get("teachers").getAsJsonArray();
            if (asJsonObject.get("courseClassId").isJsonNull() || coureseMap.get(asJsonObject.get("courseClassId").getAsString()) == null) {
                continue;
            }
            String numberOfDayName = asJsonObject.get("numberOfDayName").getAsString();
            Integer timeNumber = 0;//节次
            if (!StrUtil.isEmpty(numberOfDayName)) {
                timeNumber = Integer.parseInt(numberOfDayName.substring(numberOfDayName.length() - 1));
            }
//            String updateSql = "update course_table set status = 3 where class_id = " + classMap.get(asJsonObject.get("classSerialNo").getAsString())
//                    + " and time_period = " + tmePeriod.get(asJsonObject.get("timeOption").getAsInt())
//                    + " and time_number = " + timeNumber
//                    + " and weeks = " + asJsonObject.get("dayOfWeek").getAsInt()
//                    + " and course_id = " + coureseMap.get(asJsonObject.get("courseClassId").getAsString())
//                    + " and schedule_date = '" + asJsonObject.get("scheduleDate").getAsString() + "'";

            String sql = "INSERT INTO course_table(id,base_semester_id,teacher_id,teacher_name,teacher_serial_no,course_id,course_name," +
                    "class_id, class_name,weeks,weeks_cn,time_period,time_number,site_id,site_name,status," +
                    "create_date,schedule_date,jianyue_id, start_time, end_time) select " + id + String.format("%04d", count) + ","
                    + semesterMap.get(asJsonObject.get("semesterSerialNo").getAsString()) + ",";
            if (teachers.size() > 0) {
                JsonObject teacherJson = teachers.get(0).getAsJsonObject();
//                updateSql += " and teacher_id = " + teacherMap.get(teacherJson.get("teacherSerialNo").getAsString());
                sql += (teacherMap.get(teacherJson.get("teacherSerialNo").getAsString()) == null ? 0 : teacherMap.get(teacherJson.get("teacherSerialNo").getAsString())) + ","
                        + "'" + teacherJson.get("name").getAsString() + "',"
                        + "'" + teacherJson.get("teacherSerialNo").getAsString() + "',";
            } else {
                sql += "0,'',null,";
            }
            sql += coureseMap.get(asJsonObject.get("courseClassId").getAsString()) + ","
                    + "'" + asJsonObject.get("courseClassName").getAsString() + "',"
                    + classMap.get(asJsonObject.get("classSerialNo").getAsString()) + ","
                    + "'" + asJsonObject.get("className").getAsString() + "',"
                    + asJsonObject.get("dayOfWeek").getAsInt() + ","
                    + "'" + asJsonObject.get("dayOfWeekName").getAsString() + "',"
                    + tmePeriod.get(asJsonObject.get("timeOption").getAsInt()) + ","
                    + timeNumber + ","
                    + (classroomMap.get(asJsonObject.get("classRoomSerialNo").getAsString()) == null ? 0 : classroomMap.get(asJsonObject.get("classRoomSerialNo").getAsString())) + ","
                    + "'" + asJsonObject.get("classRoomName").getAsString() + "',1,now(),"
                    + "'" + asJsonObject.get("scheduleDate").getAsString() + "',"
                    + "'" + asJsonObject.get("id").getAsString() + "', '" + asJsonObject.get("startTime").getAsString() + "', '" + asJsonObject.get("endTime").getAsString() +"' FROM DUAL"
                    + " WHERE NOT EXISTS(SELECT 1 FROM course_table WHERE jianyue_id = '" + asJsonObject.get("id").getAsString() + "' and status = 1)";
//            sqls.add(updateSql);
//            sqls.add(sql);
            SqlRunnerAdapter.db().insert(sql);
            count++;
        }
    }

    public Set<String> insertCourseTableEntiy(JsonArray data, Map<String, String> classroomMap, Map<String, String> coureseMap,
                                              Map<String, String> semesterMap, Map<String, String> teacherMap, Map<String, String> classMap
            , String courseReceiveMsgId, String startDate, String endDate) {
        String sql = "SELECT jianyue_id FROM course_table" +
                " where schedule_date between '" + startDate + "' and '" + endDate + "'";
        List<Map<String, Object>> oldDataList = SqlRunnerAdapter.db().selectList(sql);
        Set<String> serialNos = new HashSet<>();
        for (Map<String, Object> objectMap : oldDataList) {
            serialNos.add(objectMap.get("jianyue_id").toString());
        }
        Map<Integer, Integer> tmePeriod = ScheduleUtil.getTmePeriod();
        String tableName = "course_table";
        List<Entity> entityList = new ArrayList();
        SimpleDateFormat sdf = new SimpleDateFormat("yyy-MM-dd HH:mm:ss");
        Set<String> teacherIdList = new HashSet<>();
        for (JsonElement jsonElement : data) {
            JsonObject asJsonObject = jsonElement.getAsJsonObject();
            JsonArray teachers = asJsonObject.get("teachers").getAsJsonArray();
            if (asJsonObject.get("courseClassId").isJsonNull() || coureseMap.get(asJsonObject.get("courseClassId").getAsString()) == null) {
                continue;
            }
            if (serialNos.contains(asJsonObject.get("id").getAsString())) {
                continue;
            }
            int timeNumber = asJsonObject.get("numberOfDay").getAsInt();//节次
            String classId = classMap.get(asJsonObject.get("classSerialNo").getAsString());
            String scheduleDate = asJsonObject.get("scheduleDate").getAsString();
            String courseClassId = coureseMap.get(asJsonObject.get("courseClassId").getAsString());
            String courseClassName = asJsonObject.get("courseClassName").getAsString();
            String siteId = (classroomMap.get(asJsonObject.get("classRoomSerialNo").getAsString()) == null ? "0" : classroomMap.get(asJsonObject.get("classRoomSerialNo").getAsString()));
            List<String> teacherIds = new ArrayList<>();
            List<String> teacherNames = new ArrayList<>();
            List<String> teacher_serial_nos = new ArrayList<>();
            for (JsonElement teacher : teachers) {
                JsonObject teacherJson = teacher.getAsJsonObject();
                teacherIds.add(teacherMap.get(teacherJson.get("teacherSerialNo").getAsString()) == null ? "0" : teacherMap.get(teacherJson.get("teacherSerialNo").getAsString()));
                teacherNames.add(teacherJson.get("name").getAsString());
                teacher_serial_nos.add(teacherJson.get("teacherSerialNo").getAsString());
                teacherIdList.add(teacherMap.get(teacherJson.get("teacherSerialNo").getAsString()));
            }
            String teacherId = "0";
            if (!teacherIds.isEmpty()) {
                teacherId = teacherIds.toString().replace("[", "").replace("]", "");
            }
            String teacherName = "";
            if (!teacherNames.isEmpty()) {
                teacherName = teacherNames.toString().replace("[", "").replace("]", "");
            }
            String teacher_serial_no = "";
            if (!teacher_serial_nos.isEmpty()) {
                teacher_serial_no = teacher_serial_nos.toString().replace("[", "").replace("]", "");
            }
            String keyInfo = teacherId + "_" + classId + "_" + scheduleDate + "_" + courseClassId + "_" + siteId + "_" + timeNumber;

            Entity entity = Entity.create(tableName);
            entity.set("id", IdUtil.getSnowflakeNextId());
            entity.set("base_semester_id", semesterMap.get(asJsonObject.get("semesterSerialNo").getAsString()));

            entity.set("teacher_name", teacherName);
            entity.set("teacher_serial_no", teacher_serial_no);
            entity.set("teacher_id", teacherId);
            entity.set("course_id", courseClassId);
            entity.set("course_name", courseClassName);
            entity.set("class_id", classId);
            entity.set("class_name", asJsonObject.get("className").getAsString());
            entity.set("weeks", asJsonObject.get("dayOfWeek").getAsInt());
            entity.set("weeks_cn", asJsonObject.get("dayOfWeekName").getAsString());
            entity.set("time_period", tmePeriod.get(asJsonObject.get("timeOption").getAsInt()));
            entity.set("time_number", timeNumber);
            entity.set("site_id", siteId);
            entity.set("site_name", asJsonObject.get("classRoomName").getAsString());
            entity.set("status", 1);
            entity.set("create_date", sdf.format(new Date()));
            entity.set("schedule_date", scheduleDate);
            entity.set("jianyue_id", asJsonObject.get("id").getAsString());
            entity.set("key_info", keyInfo);
            entity.set("course_receive_msg_id", courseReceiveMsgId);
            entityList.add(entity);
        }
        if (!entityList.isEmpty()) {
            SqlRunnerAdapter.db().dynamicInsertBatch(tableName, entityList);
        }

        return teacherIdList;
    }

    /**
     * 提取课时相关信息
     *
     * @param data 数据
     */
    public void insertClassTime(JsonArray data) {
        Map<String, JsonObject> infoMap = new HashMap<>();
        Map<Integer, Integer> tmePeriod = ScheduleUtil.getTmePeriod();
        for (JsonElement jsonElement : data) {
            JsonObject asJsonObject = jsonElement.getAsJsonObject();
            String numberOfDayName = asJsonObject.get("numberOfDayName").getAsString();
            JsonObject json = new JsonObject();
            json.add("startTime", asJsonObject.get("startTime"));
            json.add("endTime", asJsonObject.get("endTime"));
            json.addProperty("tmePeriod", tmePeriod.get(asJsonObject.get("timeOption").getAsInt()));
            json.add("numberOfDay", asJsonObject.get("numberOfDay"));
            infoMap.put(numberOfDayName, json);
        }
        int count = 1;
        for (String number : infoMap.keySet()) {
            JsonObject jsonObject = infoMap.get(number);
            int timeNumber = jsonObject.get("numberOfDay").getAsInt();//节次
            long id = System.currentTimeMillis();

            String sql = "INSERT INTO class_time(id,time_period,number,full_name,short_name,create_date,summer_start_time"
                    + ",summer_end_time,winter_start_time,winter_end_time) select " + id + String.format("%04d", count) + ","
                    + jsonObject.get("tmePeriod").getAsInt() + ","
                    + timeNumber + ","
                    + "'" + number + "',"
                    + "'" + number + "',now(),"
                    + "'" + jsonObject.get("startTime").getAsString() + "',"
                    + "'" + jsonObject.get("endTime").getAsString() + "',"
                    + "'" + jsonObject.get("startTime").getAsString() + "',"
                    + "'" + jsonObject.get("endTime").getAsString() + "' FROM DUAL"
                    + " WHERE NOT EXISTS(SELECT * FROM class_time WHERE time_period = "
                    + jsonObject.get("tmePeriod").getAsInt()
                    + " and number = " + timeNumber + ")";
//            sqls.add(sql);
            SqlRunnerAdapter.db().insert(sql);

            String updSql = "update class_time set" +
                    " summer_start_time = '" + jsonObject.get("startTime").getAsString() + "'," +
                    " summer_end_time = '" + jsonObject.get("endTime").getAsString() + "'," +
                    " winter_start_time = '" + jsonObject.get("startTime").getAsString() + "'," +
                    " winter_end_time = '" + jsonObject.get("endTime").getAsString() + "'" +
                    " WHERE time_period = " + jsonObject.get("tmePeriod").getAsInt() + " and number = " + timeNumber;
            SqlRunnerAdapter.db().insert(updSql);
            count++;
        }
    }

    /**
     * 保存节次数据
     *
     * @param infoMap
     */
    public void saveClassTime(Map<String, JsonObject> infoMap) {

    }

    public void syncClass(String tableName, String currenSemeter) throws Exception {
        String sql = "select * from base_class where delete_mark = 0 and is_graduate = 1";
        List<Map<String, Object>> classList = SqlRunnerAdapter.db().selectList(sql);
        Map<String, String> classNameIdMap = new HashMap<>();
        for (Map<String, Object> objectMap : classList) {
            classNameIdMap.put(objectMap.get("name").toString(), objectMap.get("id").toString());
        }

        long timestamp = System.currentTimeMillis();
        String sign = ScheduleUtil.createSign(timestamp);
        String url = ScheduleUtil.apiUrl + "Class/page";

        JsonObject pageJson = new JsonObject();
        JsonArray semesterSerialNos = new JsonArray();
        semesterSerialNos.add(currenSemeter);
        JsonObject paramJson = new JsonObject();
        paramJson.add("semesterSerialNos", semesterSerialNos);
        pageJson.addProperty("pageSize", 2000);
        pageJson.addProperty("pageIndex", 1);
        JsonParser parser = new JsonParser();
        String doPost = ScheduleUtil.doPost(url, pageJson.toString(), sign, timestamp);
        JsonArray dataList = parser.parse(doPost).getAsJsonObject().get("data").getAsJsonObject().get("dataList").getAsJsonArray();

        for (JsonElement jsonElement : dataList) {
            JsonObject object = jsonElement.getAsJsonObject();
            if (!object.get("semesterSerialNo").getAsString().equals(currenSemeter)) {
                continue;
            }
            String name = object.get("name").getAsString();
            if (!classNameIdMap.containsKey(name)) {
                continue;
            }

            String insertSql = "INSERT INTO jianyue_data(create_date,table_name,source_id,jianyue_id)" +
                    " select now(), '" + tableName + "', '" + classNameIdMap.get(name) + "', '" + object.get("serialNo").getAsString() + "'" +
                    " where NOT EXISTS (" +
                    " SELECT 1 FROM jianyue_data WHERE jianyue_id = '" + object.get("serialNo").getAsString() + "'" +
                    " );";
            SqlRunnerAdapter.db().insert(insertSql);
        }
    }


    /**
     * 插入记录表
     *
     * @param tableName 表名字
     * @param idsMap    id对应关系
     */
    public void insertRecord(String tableName, Map<String, String> idsMap) {
        if (idsMap.isEmpty()) {
            return;
        }
//        List<String> sqls = new ArrayList<>();
        for (String sourceId : idsMap.keySet()) {
            String sql = "INSERT INTO jianyue_data(create_date,table_name,source_id,jianyue_id) value(now(),'"
                    + tableName + "','" + sourceId + "','" + idsMap.get(sourceId) + "')";
//            sqls.add(sql);
            SqlRunnerAdapter.db().insert(sql);
        }
    }


}