|
|
@@ -0,0 +1,861 @@
|
|
|
+package com.xjrsoft.xjrsoftboot;
|
|
|
+
|
|
|
+import cn.dev33.satoken.secure.SaSecureUtil;
|
|
|
+import cn.hutool.db.Db;
|
|
|
+import com.google.gson.JsonArray;
|
|
|
+import com.google.gson.JsonElement;
|
|
|
+import com.google.gson.JsonObject;
|
|
|
+import com.google.gson.JsonParser;
|
|
|
+import com.xjrsoft.XjrSoftApplication;
|
|
|
+import com.xjrsoft.common.constant.GlobalConstant;
|
|
|
+import com.xjrsoft.common.utils.DatasourceUtil;
|
|
|
+import com.xjrsoft.module.courseTable.service.ICourseTableService;
|
|
|
+import com.xjrsoft.module.schedule.entity.JianyueData;
|
|
|
+import com.xjrsoft.module.schedule.util.DataUtil;
|
|
|
+import com.xjrsoft.module.schedule.util.ScheduleUtil;
|
|
|
+import org.junit.jupiter.api.Test;
|
|
|
+import org.junit.runner.RunWith;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.boot.test.context.SpringBootTest;
|
|
|
+import org.springframework.test.context.junit4.SpringRunner;
|
|
|
+
|
|
|
+import javax.crypto.Mac;
|
|
|
+import javax.crypto.spec.SecretKeySpec;
|
|
|
+import javax.sql.DataSource;
|
|
|
+import java.io.*;
|
|
|
+import java.net.HttpURLConnection;
|
|
|
+import java.net.MalformedURLException;
|
|
|
+import java.net.URL;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.HashSet;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import java.util.Set;
|
|
|
+
|
|
|
+// 简约课表测试
|
|
|
+@RunWith(SpringRunner.class)
|
|
|
+@SpringBootTest(classes = XjrSoftApplication.class)
|
|
|
+public class ScheduleTest {
|
|
|
+
|
|
|
+ public static final String ALGORITHM = "HmacSHA256";
|
|
|
+ public static final String apiUrl = "http://219.153.208.33:20000/api/v1/ScheduleFlowV2/OpenApi/";
|
|
|
+ @Autowired
|
|
|
+ private ICourseTableService courseTableService;
|
|
|
+
|
|
|
+ public static String calculateHMac(String key, String data) throws Exception {
|
|
|
+ Mac sha256_HMAC = Mac.getInstance(ALGORITHM);
|
|
|
+
|
|
|
+ SecretKeySpec secret_key = new SecretKeySpec(key.getBytes("UTF-8"), ALGORITHM);
|
|
|
+ sha256_HMAC.init(secret_key);
|
|
|
+
|
|
|
+ return byteArrayToHex(sha256_HMAC.doFinal(data.getBytes("UTF-8")));
|
|
|
+ }
|
|
|
+
|
|
|
+ public static String byteArrayToHex(byte[] a) {
|
|
|
+ StringBuilder sb = new StringBuilder(a.length * 2);
|
|
|
+ for (byte b : a)
|
|
|
+ sb.append(String.format("%02x", b));
|
|
|
+ return sb.toString();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 将加密后的字节数组转换成字符串
|
|
|
+ *
|
|
|
+ * @param b 字节数组
|
|
|
+ * @return 字符串
|
|
|
+ */
|
|
|
+ private static String byteArrayToHexString(byte[] b) {
|
|
|
+ StringBuilder hs = new StringBuilder();
|
|
|
+ String stmp;
|
|
|
+ for (int n = 0; b != null && n < b.length; n++) {
|
|
|
+ stmp = Integer.toHexString(b[n] & 0XFF);
|
|
|
+ if (stmp.length() == 1)
|
|
|
+ hs.append('0');
|
|
|
+ hs.append(stmp);
|
|
|
+ }
|
|
|
+ return hs.toString().toLowerCase();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * https://live.jianyuekb.com/api/v1/ScheduleFlowV2/OpenApi/
|
|
|
+ * schoolId：UUFM5TID45X
|
|
|
+ * secert：UUFM5TID45X
|
|
|
+ * password：Jh&NAbn6Rm#p@6ZZ
|
|
|
+ */
|
|
|
+ @Test
|
|
|
+ public void ScheduleFlowTest() throws Exception {
|
|
|
+ long timestamp = System.currentTimeMillis();
|
|
|
+ System.out.println("timestamp:" + timestamp);
|
|
|
+ String md5Str = SaSecureUtil.md5("@ak8To$xSHFoT6FoqsqYb3" + timestamp);
|
|
|
+
|
|
|
+
|
|
|
+ String sign = calculateHMac("UUXQ8G4W9IU", md5Str);
|
|
|
+ System.out.println("sign:" + sign);
|
|
|
+
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("pageIndex", 1);
|
|
|
+// paramJson.addProperty("pageSize", 200);
|
|
|
+
|
|
|
+ //获取时间戳
|
|
|
+// long timestamp = System.currentTimeMillis();
|
|
|
+ //生成签名
|
|
|
+// String sign = ScheduleUtil.createSign(timestamp);
|
|
|
+// String result = ScheduleUtil.doPost("http://219.153.208.33:20000/api/v1/ScheduleFlowV2/OpenApi/SchoolDistrict/page", paramJson.toString(), sign, timestamp);
|
|
|
+// System.out.println(result);
|
|
|
+
|
|
|
+ DataSource datasource = DatasourceUtil.getDataSource(GlobalConstant.DEFAULT_DATASOURCE_KEY);
|
|
|
+ try {
|
|
|
+ Db use = Db.use(datasource);
|
|
|
+ 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<Long, String>> dataMap = new HashMap<>();
|
|
|
+ for (String table : tables) {
|
|
|
+ Map<Long, String> tableData = new HashMap<>();
|
|
|
+ for (JianyueData jianyueData : list) {
|
|
|
+ if(!table.equals(jianyueData.getTableName())){
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ tableData.put(jianyueData.getSourceId(), jianyueData.getJianyueId());
|
|
|
+ }
|
|
|
+ dataMap.put(table, tableData);
|
|
|
+ }
|
|
|
+ DataUtil dataUtil = new DataUtil();
|
|
|
+ //查询校区
|
|
|
+ JsonArray schoolDistrictData = dataUtil.getSchoolDistrictData();
|
|
|
+ //推送年级
|
|
|
+ String tableName = "base_grade";
|
|
|
+ Map<Long, String> grade = dataUtil.insertGrade(use, tableName, schoolDistrictData.get(0).getAsString(), dataMap.get(tableName));
|
|
|
+ if(grade.isEmpty() && dataMap.get(tableName) != null){
|
|
|
+ grade = dataMap.get(tableName);
|
|
|
+ }
|
|
|
+
|
|
|
+ //推送学期
|
|
|
+ tableName = "base_semester";
|
|
|
+ dataUtil.insertSemester(use, tableName, dataMap.get(tableName));
|
|
|
+ //推送标签
|
|
|
+ tableName = "base_label";
|
|
|
+ Map<Long, String> tagMap = dataUtil.insertCourseTag(use, tableName, dataMap.get(tableName));
|
|
|
+ if(tagMap.isEmpty() && dataMap.get(tableName) != null){
|
|
|
+ tagMap = dataMap.get(tableName);
|
|
|
+ }
|
|
|
+ //推送课程
|
|
|
+ tableName = "base_course_subject";
|
|
|
+ dataUtil.insertCourse(use, tableName, dataMap.get(tableName), tagMap);
|
|
|
+ //推送教职工
|
|
|
+ tableName = "base_teacher";
|
|
|
+ Map<Long, String> teacherMap = dataUtil.insertTeacher(use, tableName, dataMap.get(tableName));
|
|
|
+ if(teacherMap.isEmpty() && dataMap.get(tableName) != null){
|
|
|
+ teacherMap = dataMap.get(tableName);
|
|
|
+ }
|
|
|
+ //推送学生
|
|
|
+ tableName = "base_student";
|
|
|
+ dataUtil.insertStudent(use, tableName, grade, dataMap.get(tableName));
|
|
|
+ //推送教室
|
|
|
+ tableName = "base_classroom";
|
|
|
+ Map<Long, String> classroomMap = dataUtil.insertClassRoom(use, tableName, schoolDistrictData.get(0).getAsString(), dataMap.get(tableName));
|
|
|
+ if(classroomMap.isEmpty() && dataMap.get(tableName) != null){
|
|
|
+ classroomMap = dataMap.get(tableName);
|
|
|
+ }
|
|
|
+ //推送行政班，先查询当前学期id
|
|
|
+ String currenSemeter = dataUtil.getCurrenSemeter();
|
|
|
+ tableName = "base_class";
|
|
|
+ dataUtil.insertClass(use, tableName, grade, teacherMap, currenSemeter, dataMap.get(tableName), classroomMap);
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ void SubstitutePreTestin(String sign, Long timestamp){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+ String url = apiUrl + "RescheduleApply/Extend/Substitute/PreTesting";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("timetableId", "4deba192-0b39-9821-5eac-3a1079ba6fbf");
|
|
|
+ jsonObject.addProperty("isCycles", Boolean.FALSE);
|
|
|
+ JsonArray extendIds = new JsonArray();
|
|
|
+ extendIds.add(14954799374790L);
|
|
|
+ jsonObject.add("extendIds", extendIds);
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ System.out.println(result);
|
|
|
+ }
|
|
|
+ void getPreCheck(String sign, Long timestamp){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+ String url = apiUrl + "RescheduleApply/Extend/PreTesting";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("timetableId", "1e77cf3e-a027-1665-8100-3a106a58b8ab");
|
|
|
+ jsonObject.addProperty("isCycles", Boolean.FALSE);
|
|
|
+// jsonObject.addProperty("startDate", "2024-01-01");
|
|
|
+// jsonObject.addProperty("endDate", "2024-01-31");
|
|
|
+// jsonObject.addProperty("dayOfweek", 5);
|
|
|
+ jsonObject.addProperty("numberOfday", 3);
|
|
|
+ jsonObject.addProperty("date", "2024-01-31");
|
|
|
+ jsonObject.addProperty("reschduleId", "4e2fc331-ce9d-f512-13fb-3a106a58bf82");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ System.out.println(result);
|
|
|
+ }
|
|
|
+
|
|
|
+ void getTimetable(String sign, Long timestamp){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+ String url = apiUrl + "RescheduleApply/Can/Reschedule/Timetable/List";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("timetableId", "1e77cf3e-a027-1665-8100-3a106a58b8ab");
|
|
|
+ jsonObject.addProperty("isCycles", Boolean.TRUE);
|
|
|
+ JsonObject cycles = new JsonObject();
|
|
|
+ cycles.addProperty("startDate", "2024-01-25");
|
|
|
+ cycles.addProperty("endDate", "2024-01-30");
|
|
|
+ cycles.addProperty("dayOfweek", 5);
|
|
|
+ cycles.addProperty("numberOfday", 3);
|
|
|
+ jsonObject.add("cycles", cycles);
|
|
|
+ jsonObject.addProperty("reschduleDate", "2024-02-02");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ System.out.println(result);
|
|
|
+ }
|
|
|
+ List<String> getClassInfo(String sign, Long timestamp){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+ String url = apiUrl + "Class/page";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("pageSize", "200");
|
|
|
+ jsonObject.addProperty("pageIndex", "1");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ System.out.println("ClassInfo:" + result);
|
|
|
+ JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+ JsonArray jsonArray = resultJson.get("data").getAsJsonObject().get("dataList").getAsJsonArray();
|
|
|
+ List<String> resultArray = new ArrayList<>();
|
|
|
+ for (JsonElement jsonElement : jsonArray) {
|
|
|
+ JsonObject asJsonObject = jsonElement.getAsJsonObject();
|
|
|
+ resultArray.add(asJsonObject.get("serialNo").getAsString());
|
|
|
+ }
|
|
|
+ return resultArray;
|
|
|
+ }
|
|
|
+ JsonArray getSchoolDistrictData(String sign, Long timestamp){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+// String url = apiUrl + "SchoolDistrict/Create";
|
|
|
+// JsonObject jsonObject = new JsonObject();
|
|
|
+// jsonObject.addProperty("name", "test1");
|
|
|
+// jsonObject.addProperty("shortName", "本部112");
|
|
|
+// jsonObject.addProperty("note", "本部211");
|
|
|
+// jsonObject.addProperty("sort", "2");
|
|
|
+// String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+
|
|
|
+ String url = apiUrl + "SchoolDistrict/page";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("pageSize", "15");
|
|
|
+ jsonObject.addProperty("pageIndex", "1");
|
|
|
+ String result = 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;
|
|
|
+ }
|
|
|
+
|
|
|
+ List<String> getGradeInfo(String sign, Long timestamp, JsonArray schoolDistrictIds){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+ String url = apiUrl + "TimeTable/List";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+// jsonObject.addProperty("schoolDistrictIds", schoolDistrictIds.toString());
|
|
|
+ jsonObject.addProperty("pageSize", "15");
|
|
|
+ jsonObject.addProperty("pageIndex", "1");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ System.out.println("grade:" + result);
|
|
|
+ JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+ JsonArray data = resultJson.get("data").getAsJsonArray();
|
|
|
+ if(data.size() == 0){
|
|
|
+ return new ArrayList<>();
|
|
|
+ }
|
|
|
+ JsonArray gradeArray = resultJson.get("data").getAsJsonObject().get("dataList").getAsJsonArray();
|
|
|
+ List<String> gradeIds = new ArrayList<>();
|
|
|
+ for (JsonElement jsonElement : gradeArray) {
|
|
|
+ JsonObject asJsonObject = jsonElement.getAsJsonObject();
|
|
|
+ gradeIds.add(asJsonObject.get("serialNo").getAsString());
|
|
|
+ }
|
|
|
+
|
|
|
+ return gradeIds;
|
|
|
+ }
|
|
|
+
|
|
|
+ JsonArray getScheduleInfo(String sign, Long timestamp, List<String> ids) throws IOException {
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+ String url = apiUrl + "TimeTable/List";
|
|
|
+ if(ids.isEmpty()){
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("startDate", "2024-01-01 00:00:00");
|
|
|
+ jsonObject.addProperty("endDate", "2024-02-21 23:59:59");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ File file = new File("D:\\workspace\\其他\\课表\\file.txt");
|
|
|
+ BufferedWriter writer = new BufferedWriter(new FileWriter(file));
|
|
|
+ writer.write(result); // 写入字符串内容
|
|
|
+ writer.close();
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ for (String id : ids) {
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("classSerialNo", id);
|
|
|
+ jsonObject.addProperty("startDate", "2024-01-01 00:00:00");
|
|
|
+ jsonObject.addProperty("endDate", "2024-02-21 23:59:59");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ System.out.println(id + ":" + result);
|
|
|
+ }
|
|
|
+
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+// List<String> insertClass(String sign, Long timestamp, String schoolDistrictId) throws InterruptedException {
|
|
|
+// List<ClassroomJianyuekbVo> dataList = baseClassroomMapper.getJianyueList();
|
|
|
+// String url = apiUrl + "class/create";
|
|
|
+// List<String> idList = new ArrayList<>();
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+//
|
|
|
+// String findUrl = apiUrl + "class/page";
|
|
|
+//
|
|
|
+// for (ClassroomJianyuekbVo classroom : dataList) {
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("schoolDistrictId", schoolDistrictId);
|
|
|
+// paramJson.addProperty("name", classroom.getName());
|
|
|
+//
|
|
|
+//// paramJson.addProperty("peopleCount", classroom.getPeopleCount());
|
|
|
+//// paramJson.addProperty("location", classroom.getLocation());
|
|
|
+// paramJson.addProperty("peopleCount", 50);
|
|
|
+// paramJson.addProperty("location", "无");
|
|
|
+// paramJson.addProperty("extendId", classroom.getExtendId());
|
|
|
+// paramJson.addProperty("floor", classroom.getFloor());
|
|
|
+//// String findResult = doPost(findUrl, paramJson.toString(), sign, timestamp);
|
|
|
+//// if(findResult != null){
|
|
|
+//// JsonObject resultJson = jsonParser.parse(findResult).getAsJsonObject();
|
|
|
+//// JsonObject data = resultJson.get("data").getAsJsonObject();
|
|
|
+//// if(data.get("total").getAsInt() != 0){
|
|
|
+//// //调用update
|
|
|
+//// }
|
|
|
+//// }
|
|
|
+//
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+// if(result == null){
|
|
|
+// System.out.println(paramJson.toString());
|
|
|
+// continue;
|
|
|
+// }
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+// idList.add(resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+// return idList;
|
|
|
+// }
|
|
|
+//
|
|
|
+// List<String> insertClassRoom(String sign, Long timestamp, String schoolDistrictId) throws InterruptedException {
|
|
|
+// List<ClassroomJianyuekbVo> dataList = baseClassroomMapper.getJianyueList();
|
|
|
+// String url = apiUrl + "classroom/create";
|
|
|
+// List<String> idList = new ArrayList<>();
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+//
|
|
|
+// String findUrl = apiUrl + "ClassRoom/page";
|
|
|
+//
|
|
|
+// for (ClassroomJianyuekbVo classroom : dataList) {
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("schoolDistrictId", schoolDistrictId);
|
|
|
+// paramJson.addProperty("name", classroom.getName());
|
|
|
+//
|
|
|
+//// paramJson.addProperty("peopleCount", classroom.getPeopleCount());
|
|
|
+//// paramJson.addProperty("location", classroom.getLocation());
|
|
|
+// paramJson.addProperty("peopleCount", 50);
|
|
|
+// paramJson.addProperty("location", "无");
|
|
|
+// paramJson.addProperty("extendId", classroom.getExtendId());
|
|
|
+// paramJson.addProperty("floor", classroom.getFloor());
|
|
|
+//// String findResult = doPost(findUrl, paramJson.toString(), sign, timestamp);
|
|
|
+//// if(findResult != null){
|
|
|
+//// JsonObject resultJson = jsonParser.parse(findResult).getAsJsonObject();
|
|
|
+//// JsonObject data = resultJson.get("data").getAsJsonObject();
|
|
|
+//// if(data.get("total").getAsInt() != 0){
|
|
|
+//// //调用update
|
|
|
+//// }
|
|
|
+//// }
|
|
|
+//
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+// if(result == null){
|
|
|
+// System.out.println(paramJson.toString());
|
|
|
+// continue;
|
|
|
+// }
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+// idList.add(resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+// return idList;
|
|
|
+// }
|
|
|
+//
|
|
|
+// List<String> insertStudent(String sign, Long timestamp, Map<Long, String> gradeMap) throws Exception {
|
|
|
+//
|
|
|
+// List<StudentJianyuekbVo> dataList = baseStudentMapper.getJianyueStudentList();
|
|
|
+// String url = apiUrl + "student/create";
|
|
|
+// List<String> idList = new ArrayList<>();
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+//
|
|
|
+// String findUrl = apiUrl + "Student/page";
|
|
|
+//
|
|
|
+// for (StudentJianyuekbVo student : dataList) {
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("registerNo", student.getRegisterNo());
|
|
|
+// paramJson.addProperty("gender", student.getGender());
|
|
|
+//
|
|
|
+// paramJson.addProperty("realName", student.getRealName());
|
|
|
+// paramJson.addProperty("alias", student.getAlias());
|
|
|
+// paramJson.addProperty("extendId", student.getExtendId());
|
|
|
+// paramJson.addProperty("gradeSerialNo", gradeMap.get(student.getGradeSerialNo()));
|
|
|
+//// String findResult = doPost(findUrl, paramJson.toString(), sign, timestamp);
|
|
|
+//// if(findResult != null){
|
|
|
+//// JsonObject resultJson = jsonParser.parse(findResult).getAsJsonObject();
|
|
|
+//// JsonObject data = resultJson.get("data").getAsJsonObject();
|
|
|
+//// if(data.get("total").getAsInt() != 0){
|
|
|
+//// //调用update
|
|
|
+//// }
|
|
|
+//// }
|
|
|
+// timestamp = System.currentTimeMillis();
|
|
|
+// System.out.println("timestamp:" + timestamp);
|
|
|
+// String md5Str = SaSecureUtil.md5("Jh&NAbn6Rm#p@6ZZ" + timestamp);
|
|
|
+//
|
|
|
+//
|
|
|
+// sign = calculateHMac("UUFM5TID45X", md5Str);
|
|
|
+// System.out.println("sign:" + sign);
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+// if(result == null){
|
|
|
+// System.out.println(paramJson.toString());
|
|
|
+// continue;
|
|
|
+// }
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+// idList.add(resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+// return idList;
|
|
|
+// }
|
|
|
+//
|
|
|
+// List<String> insertTeacher(String sign, Long timestamp) throws InterruptedException {
|
|
|
+// List<XjrUser> xjrUsers = xjrUserMapper.selectJoinList(
|
|
|
+// XjrUser.class, new MPJLambdaWrapper<XjrUser>()
|
|
|
+// .innerJoin("xjr_user_role_relation t2 on t.id = t2.user_id")
|
|
|
+// .eq("t2.role_id", 2)
|
|
|
+// );
|
|
|
+// String url = apiUrl + "teacher/create";
|
|
|
+// List<String> idList = new ArrayList<>();
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+//
|
|
|
+// String findUrl = apiUrl + "/Teacher/Page";
|
|
|
+//
|
|
|
+// for (XjrUser user : xjrUsers) {
|
|
|
+// Thread.sleep(1000);
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("jobNumber", user.getUserName());
|
|
|
+// paramJson.addProperty("gender", user.getGender());
|
|
|
+//
|
|
|
+// String name = user.getName().substring(0, 1) + user.getUserName();
|
|
|
+// paramJson.addProperty("name", name);
|
|
|
+// paramJson.addProperty("alias", name);
|
|
|
+// paramJson.addProperty("extendId", user.getId().toString());
|
|
|
+// String findResult = doPost(findUrl, paramJson.toString(), sign, timestamp);
|
|
|
+// if(findResult != null){
|
|
|
+// JsonObject resultJson = jsonParser.parse(findResult).getAsJsonObject();
|
|
|
+// JsonObject data = resultJson.get("data").getAsJsonObject();
|
|
|
+// if(data.get("total").getAsInt() != 0){
|
|
|
+// //调用update
|
|
|
+// }
|
|
|
+// }
|
|
|
+//
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+// if(result == null){
|
|
|
+// System.out.println(paramJson.toString());
|
|
|
+// continue;
|
|
|
+// }
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+// idList.add(resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+// return idList;
|
|
|
+// }
|
|
|
+//
|
|
|
+// List<String> insertCourse(String sign, Long timestamp){
|
|
|
+// List<BaseCourseSubject> list = baseCourseSubjectService.list(
|
|
|
+// new QueryWrapper<BaseCourseSubject>().lambda()
|
|
|
+// .eq(BaseCourseSubject::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
+// );
|
|
|
+// String url = apiUrl + "courseclass/Create";
|
|
|
+// List<String> idList = new ArrayList<>();
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+// for (BaseCourseSubject courseSubject : list) {
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("name", courseSubject.getName() + courseSubject.getCode());
|
|
|
+// paramJson.addProperty("code", courseSubject.getCode());
|
|
|
+// paramJson.addProperty("extendId", courseSubject.getId().toString());
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+// if(result == null){
|
|
|
+// System.out.println("result is null, paramJson: " + paramJson.toString());
|
|
|
+// continue;
|
|
|
+// }
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+// if(resultJson.get("code").getAsInt() == -1){
|
|
|
+// System.out.println("paramJson: " + paramJson.toString() + ", 返回结果：" + result);
|
|
|
+// }
|
|
|
+// idList.add(resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+//
|
|
|
+// return idList;
|
|
|
+// }
|
|
|
+//
|
|
|
+//
|
|
|
+//
|
|
|
+// List<String> insertSemester(String sign, Long timestamp){
|
|
|
+// List<BaseSemester> list = baseSemesterService.list(
|
|
|
+// new QueryWrapper<BaseSemester>().lambda()
|
|
|
+// .eq(BaseSemester::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
+// );
|
|
|
+// String url = apiUrl + "semester/Create";
|
|
|
+// List<String> idList = new ArrayList<>();
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+// SimpleDateFormat sdfYear = new SimpleDateFormat("yyyy");
|
|
|
+// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+// String spring = "春";
|
|
|
+// String autumn = "秋";
|
|
|
+//
|
|
|
+// for (BaseSemester semester : list) {
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+//
|
|
|
+// paramJson.addProperty("schoolYear", Integer.parseInt(sdfYear.format(semester.getStartDate())));
|
|
|
+// Integer period = null;
|
|
|
+// if(semester.getName().contains(String.valueOf(spring))){
|
|
|
+// period = 1;
|
|
|
+// }else if(semester.getName().contains(autumn)){
|
|
|
+// period = 2;
|
|
|
+// }
|
|
|
+// paramJson.addProperty("period", period);
|
|
|
+// paramJson.addProperty("startDate", sdf.format(semester.getStartDate()));
|
|
|
+// paramJson.addProperty("endDate", sdf.format(semester.getEndDate()));
|
|
|
+// paramJson.addProperty("extendId", semester.getId().toString());
|
|
|
+//
|
|
|
+// if(semester.getStartDate() != null && semester.getEndDate() != null && semester.getEndDate().getTime() > timestamp && semester.getStartDate().getTime() < timestamp){
|
|
|
+// paramJson.addProperty("isCurrent", Boolean.TRUE);
|
|
|
+// }else{
|
|
|
+// paramJson.addProperty("isCurrent", Boolean.FALSE);
|
|
|
+// }
|
|
|
+// System.out.println(paramJson.toString());
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+//
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+// idList.add(resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+//
|
|
|
+// return idList;
|
|
|
+// }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 由于简约中校区中的本部不能删除，如果没有多的校区，就只查询本部的id即可
|
|
|
+ * @param sign 签名
|
|
|
+ * @param timestamp 时间戳
|
|
|
+ * @return 返回添加好的校区id
|
|
|
+ */
|
|
|
+ String insertSchoolDistrictData(String sign, Long timestamp){
|
|
|
+ JsonParser jsonParser = new JsonParser();
|
|
|
+// String url = apiUrl + "SchoolDistrict/Create";
|
|
|
+// JsonObject jsonObject = new JsonObject();
|
|
|
+// jsonObject.addProperty("name", "test1");
|
|
|
+// jsonObject.addProperty("shortName", "本部112");
|
|
|
+// jsonObject.addProperty("note", "本部211");
|
|
|
+// jsonObject.addProperty("sort", "2");
|
|
|
+// String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+
|
|
|
+ String url = apiUrl + "SchoolDistrict/page";
|
|
|
+ JsonObject jsonObject = new JsonObject();
|
|
|
+ jsonObject.addProperty("keyword", "本部");
|
|
|
+ jsonObject.addProperty("pageSize", "15");
|
|
|
+ jsonObject.addProperty("pageIndex", "1");
|
|
|
+ String result = doPost(url, jsonObject.toString(), sign, timestamp);
|
|
|
+ JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+
|
|
|
+ String id = resultJson.get("data").getAsJsonObject().get("dataList").getAsJsonArray().get(0).getAsJsonObject().get("id").getAsString();
|
|
|
+ return id;
|
|
|
+ }
|
|
|
+
|
|
|
+// Map<Long, String> insertGrade(String sign, Long timestamp, String schoolDistrictId){
|
|
|
+// List<BaseGrade> list = baseGradeService.list(
|
|
|
+// new QueryWrapper<BaseGrade>().lambda()
|
|
|
+// .eq(BaseGrade::getDeleteMark, DeleteMark.NODELETE.getCode())
|
|
|
+// );
|
|
|
+// String url = apiUrl + "eduyear/create";
|
|
|
+// JsonParser jsonParser = new JsonParser();
|
|
|
+// Map<Long, String> idMap = new HashMap<>();
|
|
|
+// for (BaseGrade baseGrade : list) {
|
|
|
+// JsonObject paramJson = new JsonObject();
|
|
|
+// paramJson.addProperty("schoolDistrictId", schoolDistrictId);
|
|
|
+// paramJson.addProperty("period", 4);
|
|
|
+// paramJson.addProperty("startYear", baseGrade.getTitle().replaceAll("年", ""));
|
|
|
+// paramJson.addProperty("extendId", baseGrade.getId().toString());
|
|
|
+// paramJson.addProperty("year", 3);
|
|
|
+//
|
|
|
+// String result = doPost(url, paramJson.toString(), sign, timestamp);
|
|
|
+//
|
|
|
+// JsonObject resultJson = jsonParser.parse(result).getAsJsonObject();
|
|
|
+//
|
|
|
+// idMap.put(baseGrade.getId(), resultJson.get("data").getAsString());
|
|
|
+// }
|
|
|
+//
|
|
|
+// return idMap;
|
|
|
+// }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ public static String doGet(String httpurl) throws Exception {
|
|
|
+ long timestamp = System.currentTimeMillis();
|
|
|
+
|
|
|
+ String password = "";
|
|
|
+
|
|
|
+ String md5Str = SaSecureUtil.md5(String.format("Jh&NAbn6Rm#p@6ZZ%d", timestamp));
|
|
|
+
|
|
|
+ System.out.println(md5Str);
|
|
|
+
|
|
|
+ String sign = calculateHMac("a7dbed0dfc70ebd92934cf9292de8749e9af01a2405217be881f9e77f6ba5320", md5Str);
|
|
|
+
|
|
|
+ System.out.println(sign);
|
|
|
+
|
|
|
+
|
|
|
+ HttpURLConnection connection = null;
|
|
|
+ InputStream is = null;
|
|
|
+ BufferedReader br = null;
|
|
|
+ String result = null;// 返回结果字符串
|
|
|
+ try {
|
|
|
+ // 创建远程url连接对象
|
|
|
+ URL url = new URL(httpurl);
|
|
|
+ // 通过远程url连接对象打开一个连接，强转成httpURLConnection类
|
|
|
+ connection = (HttpURLConnection) url.openConnection();
|
|
|
+ connection.setRequestProperty("schoolId","UUFM5TID45X");
|
|
|
+ connection.setRequestProperty("sign",sign);
|
|
|
+ connection.setRequestProperty("timestamp",String.format("%d",timestamp));
|
|
|
+ // 设置连接方式：get
|
|
|
+ connection.setRequestMethod("GET");
|
|
|
+ // 设置连接主机服务器的超时时间：15000毫秒
|
|
|
+ connection.setConnectTimeout(15000);
|
|
|
+ // 设置读取远程返回的数据时间：60000毫秒
|
|
|
+ connection.setReadTimeout(60000);
|
|
|
+ // 发送请求
|
|
|
+ connection.connect();
|
|
|
+ // 通过connection连接，获取输入流
|
|
|
+ if (connection.getResponseCode() == 200) {
|
|
|
+ is = connection.getInputStream();
|
|
|
+ // 封装输入流is，并指定字符集
|
|
|
+ br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
|
|
+ // 存放数据
|
|
|
+ StringBuffer sbf = new StringBuffer();
|
|
|
+ String temp = null;
|
|
|
+ while ((temp = br.readLine()) != null) {
|
|
|
+ sbf.append(temp);
|
|
|
+ sbf.append("\r\n");
|
|
|
+ }
|
|
|
+ result = sbf.toString();
|
|
|
+ }
|
|
|
+ } catch (MalformedURLException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ // 关闭资源
|
|
|
+ if (null != br) {
|
|
|
+ try {
|
|
|
+ br.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (null != is) {
|
|
|
+ try {
|
|
|
+ is.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ connection.disconnect();// 关闭远程连接
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ public static String doPost(String httpUrl, String param, String sign, Long timestamp) {
|
|
|
+ HttpURLConnection connection = null;
|
|
|
+ InputStream is = null;
|
|
|
+ OutputStream os = null;
|
|
|
+ BufferedReader br = null;
|
|
|
+ String result = null;
|
|
|
+ OutputStreamWriter writer = null;
|
|
|
+ try {
|
|
|
+ URL url = new URL(httpUrl);
|
|
|
+ // 通过远程url连接对象打开连接
|
|
|
+ connection = (HttpURLConnection) url.openConnection();
|
|
|
+ connection.setRequestProperty("schoolId","UUFM5TID45X");
|
|
|
+ connection.setRequestProperty("sign",sign);
|
|
|
+ connection.setRequestProperty("timestamp",String.format("%d",timestamp));
|
|
|
+ // 设置连接请求方式
|
|
|
+ connection.setRequestMethod("POST");
|
|
|
+ // 设置连接主机服务器超时时间：15000毫秒
|
|
|
+ connection.setConnectTimeout(15000);
|
|
|
+ // 设置读取主机服务器返回数据超时时间：60000毫秒
|
|
|
+ connection.setReadTimeout(60000);
|
|
|
+ // 默认值为：false，当向远程服务器传送数据/写数据时，需要设置为true
|
|
|
+ connection.setDoOutput(true);
|
|
|
+ // 默认值为：true，当前向远程服务读取数据时，设置为true，该参数可有可无
|
|
|
+ connection.setDoInput(true);
|
|
|
+ // 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式。
|
|
|
+ connection.setRequestProperty("Content-Type", "application/json");
|
|
|
+ // 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0
|
|
|
+// connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
|
|
|
+ writer = new OutputStreamWriter(connection.getOutputStream(),"UTF-8");
|
|
|
+ //body参数放这里
|
|
|
+ writer.write(param);
|
|
|
+ writer.flush();
|
|
|
+
|
|
|
+ writer.close();
|
|
|
+ // 通过连接对象获取一个输出流
|
|
|
+// os = connection.getOutputStream();
|
|
|
+// // 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的
|
|
|
+// os.write(param.getBytes());
|
|
|
+ // 通过连接对象获取一个输入流，向远程读取
|
|
|
+ if (connection.getResponseCode() == 200) {
|
|
|
+ is = connection.getInputStream();
|
|
|
+ // 对输入流对象进行包装:charset根据工作项目组的要求来设置
|
|
|
+ br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
|
|
+ StringBuffer sbf = new StringBuffer();
|
|
|
+ String temp = null;
|
|
|
+ // 循环遍历一行一行读取数据
|
|
|
+ while ((temp = br.readLine()) != null) {
|
|
|
+ sbf.append(temp);
|
|
|
+ sbf.append("\r\n");
|
|
|
+ }
|
|
|
+ result = sbf.toString();
|
|
|
+ }else{
|
|
|
+ is = connection.getInputStream();
|
|
|
+ // 对输入流对象进行包装:charset根据工作项目组的要求来设置
|
|
|
+ br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
|
|
+ StringBuffer sbf = new StringBuffer();
|
|
|
+ String temp = null;
|
|
|
+ // 循环遍历一行一行读取数据
|
|
|
+ while ((temp = br.readLine()) != null) {
|
|
|
+ sbf.append(temp);
|
|
|
+ sbf.append("\r\n");
|
|
|
+ }
|
|
|
+ System.out.println(sbf.toString());
|
|
|
+ }
|
|
|
+ } catch (MalformedURLException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ // 关闭资源
|
|
|
+ if (null != br) {
|
|
|
+ try {
|
|
|
+ br.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (null != os) {
|
|
|
+ try {
|
|
|
+ os.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (null != is) {
|
|
|
+ try {
|
|
|
+ is.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 断开与远程地址url的连接
|
|
|
+ connection.disconnect();
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ public static String doPost(String httpUrl) {
|
|
|
+ HttpURLConnection connection = null;
|
|
|
+ InputStream is = null;
|
|
|
+ OutputStream os = null;
|
|
|
+ BufferedReader br = null;
|
|
|
+ String result = null;
|
|
|
+ OutputStreamWriter writer = null;
|
|
|
+ try {
|
|
|
+ URL url = new URL(httpUrl);
|
|
|
+ // 通过远程url连接对象打开连接
|
|
|
+ connection = (HttpURLConnection) url.openConnection();
|
|
|
+ connection.setRequestProperty("schoolId","UUFM5TID45X");
|
|
|
+ // 设置连接请求方式
|
|
|
+ connection.setRequestMethod("POST");
|
|
|
+ // 设置连接主机服务器超时时间：15000毫秒
|
|
|
+ connection.setConnectTimeout(15000);
|
|
|
+ // 设置读取主机服务器返回数据超时时间：60000毫秒
|
|
|
+ connection.setReadTimeout(60000);
|
|
|
+ // 默认值为：false，当向远程服务器传送数据/写数据时，需要设置为true
|
|
|
+ connection.setDoOutput(true);
|
|
|
+ // 默认值为：true，当前向远程服务读取数据时，设置为true，该参数可有可无
|
|
|
+ connection.setDoInput(true);
|
|
|
+ // 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式。
|
|
|
+ connection.setRequestProperty("Content-Type", "application/json");
|
|
|
+ // 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0
|
|
|
+// connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
|
|
|
+ writer = new OutputStreamWriter(connection.getOutputStream(),"UTF-8");
|
|
|
+ //body参数放这里
|
|
|
+ writer.flush();
|
|
|
+
|
|
|
+ writer.close();
|
|
|
+ // 通过连接对象获取一个输出流
|
|
|
+// os = connection.getOutputStream();
|
|
|
+// // 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的
|
|
|
+// os.write(param.getBytes());
|
|
|
+ // 通过连接对象获取一个输入流，向远程读取
|
|
|
+ if (connection.getResponseCode() == 200) {
|
|
|
+ is = connection.getInputStream();
|
|
|
+ // 对输入流对象进行包装:charset根据工作项目组的要求来设置
|
|
|
+ br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
|
|
+ StringBuffer sbf = new StringBuffer();
|
|
|
+ String temp = null;
|
|
|
+ // 循环遍历一行一行读取数据
|
|
|
+ while ((temp = br.readLine()) != null) {
|
|
|
+ sbf.append(temp);
|
|
|
+ sbf.append("\r\n");
|
|
|
+ }
|
|
|
+ result = sbf.toString();
|
|
|
+ }
|
|
|
+ } catch (MalformedURLException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ // 关闭资源
|
|
|
+ if (null != br) {
|
|
|
+ try {
|
|
|
+ br.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (null != os) {
|
|
|
+ try {
|
|
|
+ os.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (null != is) {
|
|
|
+ try {
|
|
|
+ is.close();
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 断开与远程地址url的连接
|
|
|
+ connection.disconnect();
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+}
|
phoenix