From 9f410f0b3aeefbd413c0482b74991e4d81a089d8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E6=B2=85?= <907037276@qq.com> Date: Mon, 30 Oct 2023 18:35:35 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81swagger=E6=8E=A5=E5=8F=A3=E6=96=87?= =?UTF-8?q?=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ibeetl/admin/core/entity/CoreUser.java | 10 +- .../ibeetl/jlw/service/LoginTodoService.java | 2 +- .../jlw/service/SchoolClassService.java | 10 + .../jlw/service/UniversityFacultyService.java | 7 + .../jlw/service/UniversitySystemService.java | 8 + .../com/ibeetl/jlw/web/AccountController.java | 1 + .../com/ibeetl/jlw/web/TestController.java | 889 +++++++++--------- 7 files changed, 478 insertions(+), 449 deletions(-) diff --git a/admin-core/src/main/java/com/ibeetl/admin/core/entity/CoreUser.java b/admin-core/src/main/java/com/ibeetl/admin/core/entity/CoreUser.java index 2a1d52a7..87302b30 100644 --- a/admin-core/src/main/java/com/ibeetl/admin/core/entity/CoreUser.java +++ b/admin-core/src/main/java/com/ibeetl/admin/core/entity/CoreUser.java @@ -257,10 +257,10 @@ public class CoreUser extends BaseEntity implements AbstractToken { } public void setOldId(Long oldId) { - if(oldId==null){ - this.oldId=id; - }else{ - this.oldId = oldId; - } + this.oldId = oldId; + } + + public CoreUser() { + this.oldId=id; } } diff --git a/web/src/main/java/com/ibeetl/jlw/service/LoginTodoService.java b/web/src/main/java/com/ibeetl/jlw/service/LoginTodoService.java index 363a1062..01986721 100644 --- a/web/src/main/java/com/ibeetl/jlw/service/LoginTodoService.java +++ b/web/src/main/java/com/ibeetl/jlw/service/LoginTodoService.java @@ -73,7 +73,7 @@ public class LoginTodoService { .schoolClass(first.getClassName()) .studentNo(student.getStudentSn()) .classId(student.getClassId().toString()) - .userId(coreUser.getId().toString()) + .userId(coreUser.getOldId().toString()) .build(); consumer.accept(loginTodo); return loginTodo; diff --git a/web/src/main/java/com/ibeetl/jlw/service/SchoolClassService.java b/web/src/main/java/com/ibeetl/jlw/service/SchoolClassService.java index bc7fa8fd..6a9b071f 100644 --- a/web/src/main/java/com/ibeetl/jlw/service/SchoolClassService.java +++ b/web/src/main/java/com/ibeetl/jlw/service/SchoolClassService.java @@ -259,4 +259,14 @@ public class SchoolClassService extends CoreBaseService { public List> getClassListByMajorId(String majorId) { return schoolClassDao.getClassListByMajorId(majorId); } + + public SchoolClass getByNameAndMajorId(String name, Long majorId,Long collegeId,Long facultyId) { + SchoolClassQuery query = new SchoolClassQuery(); + query.setClassName(name); + query.setUniversitySystemId(majorId); + query.setClassStatus(1); + query.setUniversitiesCollegesId(collegeId); + query.setUniversityFacultyId(facultyId); + return getFirst(getValuesByQueryNotWithPermission(query)); + } } \ No newline at end of file diff --git a/web/src/main/java/com/ibeetl/jlw/service/UniversityFacultyService.java b/web/src/main/java/com/ibeetl/jlw/service/UniversityFacultyService.java index 95060f80..5309ee2a 100644 --- a/web/src/main/java/com/ibeetl/jlw/service/UniversityFacultyService.java +++ b/web/src/main/java/com/ibeetl/jlw/service/UniversityFacultyService.java @@ -233,4 +233,11 @@ public class UniversityFacultyService extends CoreBaseService return getByName(name, null); } + public UniversityFaculty getByNameAndSchoolId(String name, Long schoolId) { + UniversityFacultyQuery query = new UniversityFacultyQuery(); + query.setUniversityFacultyStatus(1); + query.setUniversityFacultyName(name.trim()); + query.setUniversitiesCollegesId(schoolId); + return getFirst(getValuesByQueryNotWithPermission(query)); + } } diff --git a/web/src/main/java/com/ibeetl/jlw/service/UniversitySystemService.java b/web/src/main/java/com/ibeetl/jlw/service/UniversitySystemService.java index df0a8cf4..c3415d18 100644 --- a/web/src/main/java/com/ibeetl/jlw/service/UniversitySystemService.java +++ b/web/src/main/java/com/ibeetl/jlw/service/UniversitySystemService.java @@ -230,4 +230,12 @@ public class UniversitySystemService extends CoreBaseService{ public List> getUniversitySystemListByOrgId(Long orgId){ return universitySystemDao.getUniversitySystemListByOrgId(orgId); } + + public UniversitySystem getByNameAndSchoolIdAndCollegeId(String name,Long facultyId){ + UniversitySystemQuery universitySystemQuery = new UniversitySystemQuery(); + universitySystemQuery.setUniversitySystemName(name); + universitySystemQuery.setUniversityFacultyId(facultyId); + universitySystemQuery.setUniversitySystemStatus(1); + return getFirst(universitySystemDao.getValuesByQueryNotWithPermission(universitySystemQuery)); + } } diff --git a/web/src/main/java/com/ibeetl/jlw/web/AccountController.java b/web/src/main/java/com/ibeetl/jlw/web/AccountController.java index dc9d9aee..9801c1bd 100644 --- a/web/src/main/java/com/ibeetl/jlw/web/AccountController.java +++ b/web/src/main/java/com/ibeetl/jlw/web/AccountController.java @@ -835,6 +835,7 @@ public class AccountController { List coreUsers = userService.getCoreUserList(coreUser); int i = 0; for (CoreUser user : coreUsers) { + if(user.getOldId()!=null){continue;} Connection conn = openConn(); PreparedStatement ps = conn.prepareStatement("select * from EduUsers where username = '" + user.getCode() + "' and IsDeleted = 0"); diff --git a/web/src/main/java/com/ibeetl/jlw/web/TestController.java b/web/src/main/java/com/ibeetl/jlw/web/TestController.java index 536b771e..6323c6eb 100644 --- a/web/src/main/java/com/ibeetl/jlw/web/TestController.java +++ b/web/src/main/java/com/ibeetl/jlw/web/TestController.java @@ -1,445 +1,448 @@ -//package com.ibeetl.jlw.web; -// -//import cn.hutool.core.util.StrUtil; -//import cn.jlw.Interceptor.SCoreUser; -//import cn.jlw.oldAliPay.pc.util.Stringutils; -//import com.google.gson.Gson; -//import com.google.gson.JsonArray; -//import com.google.gson.JsonObject; -//import com.ibeetl.admin.core.entity.CoreUser; -//import com.ibeetl.admin.core.service.CoreUserService; -//import com.ibeetl.jlw.entity.*; -//import com.ibeetl.jlw.entity.dto.CreateUserDTO; -//import com.ibeetl.jlw.enums.GenderEnum; -//import com.ibeetl.jlw.service.*; -//import com.ibeetl.jlw.web.query.UniversitiesCollegesJurisdictionExperimentalSystemQuery; -//import com.ibeetl.jlw.web.query.UniversityFacultyQuery; -//import com.ibeetl.jlw.web.query.UniversitySystemQuery; -//import io.swagger.annotations.Api; -//import io.swagger.annotations.ApiOperation; -//import org.apache.regexp.RE; -//import org.springframework.beans.factory.annotation.Autowired; -//import org.springframework.web.bind.annotation.PostMapping; -//import org.springframework.web.bind.annotation.RequestMapping; -//import org.springframework.web.bind.annotation.RestController; -// -//import java.sql.*; -//import java.text.SimpleDateFormat; -//import java.util.ArrayList; -//import java.util.Collections; -//import java.util.Date; -//import java.util.List; -// -//@Api(tags = "数据迁移") -//@RestController -//@RequestMapping("test") -//public class TestController { -// -// @Autowired -// private UniversitiesCollegesService universitiesCollegesService; -// @Autowired -// private UniversityFacultyService universityFacultyService; -// @Autowired -// private CoreUserService coreUserService; -// @Autowired -// private UniversitySystemService universitySystemService; -// @Autowired -// private SchoolClassService schoolClassService; -// @Autowired -// private TeacherService teacherService; -// @Autowired -// private StudentService studentService; -// @Autowired -// private ResourcesApplicationService resourcesApplicationService; -// @Autowired -// private UniversitiesCollegesJurisdictionExperimentalSystemService universitiesCollegesJurisdictionExperimentalSystemService; -// -// private final static String URL = "jdbc:sqlserver://120.79.161.177:1433;databaseName=Test.Zhiyun_v2.0;trustServerCertificate=true;encrypt=true"; -// private final static String USER = "sa"; -// private final static String PASSWORD = "sztzjy@2017"; -// -// // 打开数据库连接 -// public static Connection openConn() throws SQLException { -// try { -// Connection connection = DriverManager.getConnection(URL, USER, PASSWORD); -// if (connection != null) { -// System.out.println("成功建立数据库连接"); -// return connection; -// } else { -// throw new SQLException("无法建立数据库连接"); -// } -// } catch (SQLException e) { -// throw new SQLException("无法建立数据库连接: " + e.getMessage(), e); -// } -// } -// -// // 关闭数据库连接 -// public static void closeConn(Connection connection) { -// if (connection != null) { -// try { -// connection.close(); -// System.out.println("数据库连接已关闭"); -// } catch (SQLException e) { -// System.err.println("无法关闭数据库连接: " + e.getMessage()); -// } -// } -// } -// -// @ApiOperation("迁移学校及学校管理员数据") -// @PostMapping("/school") -// public void school() throws SQLException { -// Connection conn = null; -// PreparedStatement ps = null; -// try { -// conn = openConn(); -// -// String sql = "select EduSchools.Name,EduLevel.LevelName,EduUsers.EmailAddress, " + -// "EduUsers.UserName,EduSchools.IsDeleted from EduSchools " + -// "join EduUsers on EduSchools.Id=EduUsers.SchoolId " + -// "join EduUserRoles on EduUsers.Id = EduUserRoles.UserId " + -// "join EduLevel on EduSchools.LevelId=EduLevel.Id where " + -// "EduUserRoles.RoleId=2"; -// ps = conn.prepareStatement(sql); -// ResultSet resultSet = ps.executeQuery(); -// while (resultSet.next()) { -// UniversitiesColleges universitiesColleges = new UniversitiesColleges(); -// CreateUserDTO createUserDTO = new CreateUserDTO(); -// universitiesColleges.setUniversitiesCollegesName(resultSet.getString(1)); -// universitiesColleges.setUniversitiesCollegesGrade(resultSet.getString(2)); -// universitiesColleges.setUniversitiesCollegesProvince("广东省"); -// universitiesColleges.setUniversitiesCollegesCity("深圳市"); -// universitiesColleges.setUniversitiesCollegesContacts(resultSet.getString(4)); -// universitiesColleges.setUniversitiesCollegesContactsEmail(resultSet.getString(3)); -// universitiesColleges.setUniversitiesCollegesStatus(resultSet.getInt(5) + 1); -// universitiesColleges.setAddTime(new Date()); -// universitiesColleges.setUniversitiesCollegesStatus(1); -// createUserDTO.setUserCode(resultSet.getString(4)); -// createUserDTO.setPassword("123qwe"); -// universitiesCollegesService.addAndCreateCoreUser(universitiesColleges, createUserDTO); -// } -// } catch (Exception e) { -// e.printStackTrace(); -// } finally { -// ps.close(); -// closeConn(conn); -// } -// } -// -// -// @ApiOperation("迁移院系数据") -// @PostMapping("updateCollage") -// public void updateCollage() throws SQLException { -// -// Connection conn = null; -// PreparedStatement ps = null; -// try { -// conn = openConn(); -// -// String sql = "SELECT" + -// " col.Name AS collegeName," + -// " sch.Name AS schoolName," + -// " col.Contacts," + -// " col.PhoneNo," + -// " col.Address," + -// " col.IsDeleted" + -// " " + -// "FROM " + -// " EduColleges col" + -// " JOIN EduSchools sch " + -// "ON" + -// " col.SchoolId = sch.id"; -// ps = conn.prepareStatement(sql); -// ResultSet resultSet = ps.executeQuery(); -// while (resultSet.next()) { -// UniversityFacultyQuery universityFacultyQuery = new UniversityFacultyQuery(); -// CoreUser coreUser = new CoreUser(); -// universityFacultyQuery.setUniversityFacultyName(resultSet.getString(1)); -// universityFacultyQuery.setUniversityFacultyContact(resultSet.getString(3)); -// universityFacultyQuery.setUniversityFacultyContactTel(resultSet.getString(4)); -// universityFacultyQuery.setUniversityFacultyContactAddress(resultSet.getString(5)); -// -// UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(2)); -// if (universitiesColleges == null) { -// continue; -// } -// universityFacultyQuery.setUniversitiesCollegesId(universitiesColleges.getUniversitiesCollegesId()); -// universityFacultyQuery.setUniversityFacultyStatus(resultSet.getInt(6) + 1); -// universityFacultyQuery.setUniversityFacultyAddTime(new Date()); -// CoreUser userByCode = coreUserService.getUserByCode(universitiesColleges.getUniversitiesCollegesContacts()); -// if (userByCode != null) { -// universityFacultyQuery.setUserId(userByCode.getId()); -// } else { -// universityFacultyQuery.setUserId(Long.valueOf(100)); -// } -// universityFacultyQuery.setOrgId(universitiesColleges.getOrgId()); -// universityFacultyService.add(universityFacultyQuery); -// } -// } catch (Exception e) { -// e.printStackTrace(); -// } finally { -// ps.close(); -// closeConn(conn); -// } -// -// -// } -// -// -// @ApiOperation("迁移专业数据") -// @PostMapping("updateMajor") -// public void updateMajor() throws SQLException { -// Connection conn = null; -// PreparedStatement ps = null; -// try { -// conn = openConn(); -//// UniversitySystemQuery universitySystemQuery; -// -// String sql = "SELECT " + -// " ma.Name AS majorName, " + -// " ma.Contacts, " + -// " ma.PhoneNo, " + -// " ma.IsDeleted, " + -// " col.Name AS colName, " + -// " sch.Name AS schName " + -// "FROM " + -// " EduMajors ma " + -// " JOIN EduColleges col ON ma.CollegeId = col.Id " + -// " JOIN EduSchools sch ON col.schoolId = sch.id"; -// ps = conn.prepareStatement(sql); -// ResultSet resultSet = ps.executeQuery(); -// while (resultSet.next()) { -// UniversitySystemQuery universitySystemQuery = new UniversitySystemQuery(); -// universitySystemQuery.setUniversitySystemName(resultSet.getString(1)); -// universitySystemQuery.setUniversitySystemContact(resultSet.getString(2)); -// universitySystemQuery.setUniversitySystemContactTel(resultSet.getString(3)); -// universitySystemQuery.setUniversitySystemAddTime(new Date()); -// universitySystemQuery.setUniversitySystemStatus(resultSet.getInt(4) + 1); -// UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(6)); -// if (universitiesColleges == null) { -// continue; -// } -// UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(5), universitiesColleges.getUniversitiesCollegesId()); -// if (universityFaculty == null) { -// continue; -// } -// universitySystemQuery.setUniversityFacultyId(universityFaculty.getUniversityFacultyId()); -// -// universitySystemQuery.setOrgId(universitiesColleges.getOrgId()); -// universitySystemQuery.setUserId(universitiesColleges.getUserId()); -// universitySystemService.add(universitySystemQuery); -// } -// -// } catch (Exception e) { -// e.printStackTrace(); -// } finally { -// ps.close(); -// closeConn(conn); -// } -// } -// -// -// @ApiOperation("迁移班级数据") -// @PostMapping("updateClasses") -// public void updateClasses() throws SQLException { -// Connection conn = null; -// PreparedStatement ps = null; -// try { -// conn = openConn(); -//// UniversitySystemQuery universitySystemQuery; -// -// String sql = "SELECT " + -// " sch.Name as schName, " + -// " col.Name as colName, " + -// " maj.Name as majName, " + -// " cla.Name as claName, " + -// " cla.IsDeleted " + -// "FROM " + -// " EduClasses cla " + -// " JOIN EduMajors maj ON cla.MajorId = maj.Id " + -// " JOIN EduColleges col ON maj.CollegeId = col.Id " + -// " JOIN EduSchools sch ON col.schoolId = sch.id"; -// ps = conn.prepareStatement(sql); -// ResultSet resultSet = ps.executeQuery(); -// while (resultSet.next()) { -// -// -// String claName = resultSet.getString(4); -// -// SchoolClass serviceByName = schoolClassService.getByName(claName); -// if (serviceByName != null) { -// continue; -// } -// SchoolClass schoolClass = new SchoolClass(); -// schoolClass.setClassName(resultSet.getString(4)); -// UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(1)); -// if (universitiesColleges == null) { -// continue; -// } -// schoolClass.setUniversitiesCollegesId(universitiesColleges.getUniversitiesCollegesId()); -// String uniqueClassSn = schoolClassService.buildClassSnEnsureUnique(universitiesColleges, schoolClass.getClassName()); -// schoolClass.setClassSn(uniqueClassSn); -// schoolClass.setOrgId(universitiesColleges.getOrgId()); -// UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(2), universitiesColleges.getUniversitiesCollegesId()); -// if (universityFaculty == null) { -// continue; -// } -// schoolClass.setUniversityFacultyId(universityFaculty.getUniversityFacultyId()); -// UniversitySystem universitySystem = universitySystemService.getByNameAndSchoolIdAndCollegeId(resultSet.getString(3), universityFaculty.getUniversityFacultyId()); -// if (universitySystem == null) { -// continue; -// } -// schoolClass.setUniversitySystemId(universitySystem.getUniversitySystemId()); -// schoolClass.setOrgId(universitiesColleges.getOrgId()); -// schoolClass.setUserId(Long.valueOf(100)); -// schoolClass.setClassStatus(resultSet.getInt(5) + 1); -// schoolClassService.save(schoolClass); -// } -// -// } catch (Exception e) { -// e.printStackTrace(); -// } finally { -// ps.close(); -// closeConn(conn); -// } -// } -// -// @ApiOperation("迁移教师数据") -// @PostMapping("updateTeacher") -// public void updateTeacher() throws SQLException { -// Connection conn = null; -// PreparedStatement ps = null; -// try { -// conn = openConn(); -// -// String sql = "SELECT " + -// " sch.Name AS schName, " + -// " col.Name AS colName, " + -// " maj.Name AS majName, " + -// " tea.Name AS teacherName, " + -// " tea.TeacherNo AS teacherNo, " + -// " tea.PhoneNo, " + -// " tea.Sex, " + -// " tea.IsDeleted " + -// "FROM " + -// " EduTeachers tea " + -// " JOIN EduColleges col ON tea.CollegeId = col.Id " + -// " JOIN EduMajors maj ON tea.MajorId = maj.Id " + -// " JOIN EduSchools sch ON tea.SchoolId = sch.Id"; -// ps = conn.prepareStatement(sql); -// ResultSet resultSet = ps.executeQuery(); -// while (resultSet.next()) { -// Teacher teacher = new Teacher(); -// UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(1)); -// if (universitiesColleges == null) { -// continue; -// } -// UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(2), universitiesColleges.getUniversitiesCollegesId()); -// if (universityFaculty == null) { -// continue; -// } -// UniversitySystem universitySystem = universitySystemService.getByNameAndSchoolIdAndCollegeId(resultSet.getString(3), universityFaculty.getUniversityFacultyId()); -// if (universitySystem == null) { -// continue; -// } -// teacher.setTeacherName(resultSet.getString(4)); -// teacher.setUniversitiesCollegesId(universitiesColleges.getUniversitiesCollegesId()); -// teacher.setUniversityFacultyId(universityFaculty.getUniversityFacultyId()); -// teacher.setUniversitySystemId(universitySystem.getUniversitySystemId()); -// teacher.setTeacherMobile(resultSet.getString(6)); -// teacher.setTeacherJobNumber(resultSet.getString(5)); -// teacher.setTeacherStatus(resultSet.getInt(8) + 1); -// int anInt = resultSet.getInt(7); -// GenderEnum genderEnum; -// if (anInt == 1) { -// genderEnum = GenderEnum.MAN; -// } else { -// genderEnum = GenderEnum.WOMAN; -// } -// teacher.setTeacherGender(genderEnum); -// teacher.setAddTime(new Date()); -// teacherService.add(teacher); -// } -// -// } catch (Exception e) { -// e.printStackTrace(); -// } finally { -// ps.close(); -// closeConn(conn); -// } -// } -// -// -// @ApiOperation("迁移学生数据") -// @PostMapping("updateStudent") -// public void updateStudent() throws SQLException { -// Connection conn = null; -// PreparedStatement ps = null; -// try { -// conn = openConn(); -// String sql = "SELECT " + -// " sch.Name AS schName, " + -// " col.Name AS colName, " + -// " maj.Name AS majName, " + -// " stu.Name AS studentName, " + -// " stu.StudentNo AS StudentNo, " + -// " stu.PhoneNo, " + -// " stu.Sex, " + -// " stu.IsDeleted, " + -// " cla.Name " + -// "FROM " + -// " EduStudents stu " + -// " JOIN EduColleges col ON stu.CollegeId = col.Id " + -// " JOIN EduMajors maj ON stu.MajorId = maj.Id " + -// " JOIN EduSchools sch ON stu.SchoolId = sch.Id " + -// " JOIN EduClasses cla ON stu.ClassId = cla.Id"; -// ps = conn.prepareStatement(sql); -// ResultSet resultSet = ps.executeQuery(); -// while (resultSet.next()) { -// Student student = new Student(); -// student.setStudentName(resultSet.getString(4)); -// student.setStudentSn(resultSet.getString(5)); -// student.setStudentMobile(resultSet.getString(6)); -// int anInt = resultSet.getInt(7); -// GenderEnum genderEnum; -// if (anInt == 1) { -// genderEnum = GenderEnum.MAN; -// } else { -// genderEnum = GenderEnum.WOMAN; -// } -// student.setStudentGender(genderEnum); -// student.setAddTime(new Date()); -// UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(1)); -// if (universitiesColleges == null) { -// continue; -// } -// UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(2), universitiesColleges.getUniversitiesCollegesId()); -// if (universityFaculty == null) { -// continue; -// } -// UniversitySystem universitySystem = universitySystemService.getByNameAndSchoolIdAndCollegeId(resultSet.getString(3), universityFaculty.getUniversityFacultyId()); -// if (universitySystem == null) { -// continue; -// } -// SchoolClass schoolClass = schoolClassService.getByNameAndMajorId(resultSet.getString(9), -// universitySystem.getUniversitySystemId(), -// universitiesColleges.getUniversitiesCollegesId(), -// universityFaculty.getUniversityFacultyId() -// ); -// if (universitiesColleges == null || universityFaculty == null || universitySystem == null || schoolClass == null) { -// continue; -// } -// student.setClassId(schoolClass.getClassId()); -// studentService.add(student); -// } -// } catch (Exception ex) { -// ex.printStackTrace(); -// } finally { -// ps.close(); -// closeConn(conn); -// } -// } -// -// +package com.ibeetl.jlw.web; + +import cn.hutool.core.util.StrUtil; +import cn.jlw.Interceptor.SCoreUser; +import cn.jlw.oldAliPay.pc.util.Stringutils; +import com.google.gson.Gson; +import com.google.gson.JsonArray; +import com.google.gson.JsonObject; +import com.ibeetl.admin.core.entity.CoreUser; +import com.ibeetl.admin.core.service.CoreUserService; +import com.ibeetl.jlw.entity.*; +import com.ibeetl.jlw.entity.dto.CreateUserDTO; +import com.ibeetl.jlw.enums.GenderEnum; +import com.ibeetl.jlw.service.*; +import com.ibeetl.jlw.web.query.UniversitiesCollegesJurisdictionExperimentalSystemQuery; +import com.ibeetl.jlw.web.query.UniversityFacultyQuery; +import com.ibeetl.jlw.web.query.UniversitySystemQuery; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.apache.regexp.RE; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.sql.*; +import java.text.SimpleDateFormat; +import java.util.*; +import java.util.Date; + +@Api(tags = "数据迁移") +@RestController +@RequestMapping("test") +public class TestController { + + @Autowired + private UniversitiesCollegesService universitiesCollegesService; + @Autowired + private UniversityFacultyService universityFacultyService; + @Autowired + private CoreUserService coreUserService; + @Autowired + private UniversitySystemService universitySystemService; + @Autowired + private SchoolClassService schoolClassService; + @Autowired + private TeacherService teacherService; + @Autowired + private StudentService studentService; + @Autowired + private ResourcesApplicationService resourcesApplicationService; + @Autowired + private UniversitiesCollegesJurisdictionExperimentalSystemService universitiesCollegesJurisdictionExperimentalSystemService; + + private final static String URL = "jdbc:sqlserver://120.79.161.177:1433;databaseName=Test.Zhiyun_v2.0;trustServerCertificate=true;encrypt=true"; + private final static String USER = "sa"; + private final static String PASSWORD = "sztzjy@2017"; + + // 打开数据库连接 + public static Connection openConn() throws SQLException { + try { + Connection connection = DriverManager.getConnection(URL, USER, PASSWORD); + if (connection != null) { + System.out.println("成功建立数据库连接"); + return connection; + } else { + throw new SQLException("无法建立数据库连接"); + } + } catch (SQLException e) { + throw new SQLException("无法建立数据库连接: " + e.getMessage(), e); + } + } + + // 关闭数据库连接 + public static void closeConn(Connection connection) { + if (connection != null) { + try { + connection.close(); + System.out.println("数据库连接已关闭"); + } catch (SQLException e) { + System.err.println("无法关闭数据库连接: " + e.getMessage()); + } + } + } + + @ApiOperation("迁移学校及学校管理员数据") + @PostMapping("/school") + public void school() throws SQLException { + Connection conn = null; + PreparedStatement ps = null; + try { + conn = openConn(); + + String sql = "select EduSchools.Name,EduLevel.LevelName,EduUsers.EmailAddress, " + + "EduUsers.UserName,EduSchools.IsDeleted from EduSchools " + + "join EduUsers on EduSchools.Id=EduUsers.SchoolId " + + "join EduUserRoles on EduUsers.Id = EduUserRoles.UserId " + + "join EduLevel on EduSchools.LevelId=EduLevel.Id where " + + "EduUserRoles.RoleId=2"; + ps = conn.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + while (resultSet.next()) { + UniversitiesColleges universitiesColleges = new UniversitiesColleges(); + CreateUserDTO createUserDTO = new CreateUserDTO(); + universitiesColleges.setUniversitiesCollegesName(resultSet.getString(1)); + universitiesColleges.setUniversitiesCollegesGrade(resultSet.getString(2)); + universitiesColleges.setUniversitiesCollegesProvince("广东省"); + universitiesColleges.setUniversitiesCollegesCity("深圳市"); + universitiesColleges.setUniversitiesCollegesContacts(resultSet.getString(4)); + universitiesColleges.setUniversitiesCollegesContactsEmail(resultSet.getString(3)); + universitiesColleges.setUniversitiesCollegesStatus(resultSet.getInt(5) + 1); + universitiesColleges.setAddTime(new Date()); + universitiesColleges.setUniversitiesCollegesStatus(1); + createUserDTO.setUserCode(resultSet.getString(4)); + createUserDTO.setPassword("123qwe"); + universitiesCollegesService.addAndCreateCoreUser(universitiesColleges, createUserDTO); + } + } catch (Exception e) { + e.printStackTrace(); + } finally { + ps.close(); + closeConn(conn); + } + } + + + @ApiOperation("迁移院系数据") + @PostMapping("updateCollage") + public void updateCollage() throws SQLException { + + Connection conn = null; + PreparedStatement ps = null; + try { + conn = openConn(); + + String sql = "SELECT" + + " col.Name AS collegeName," + + " sch.Name AS schoolName," + + " col.Contacts," + + " col.PhoneNo," + + " col.Address," + + " col.IsDeleted" + + " " + + "FROM " + + " EduColleges col" + + " JOIN EduSchools sch " + + "ON" + + " col.SchoolId = sch.id"; + ps = conn.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + while (resultSet.next()) { + UniversityFacultyQuery universityFacultyQuery = new UniversityFacultyQuery(); + CoreUser coreUser = new CoreUser(); + universityFacultyQuery.setUniversityFacultyName(resultSet.getString(1)); + universityFacultyQuery.setUniversityFacultyContact(resultSet.getString(3)); + universityFacultyQuery.setUniversityFacultyContactTel(resultSet.getString(4)); + universityFacultyQuery.setUniversityFacultyContactAddress(resultSet.getString(5)); + + UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(2)); + if (universitiesColleges == null) { + continue; + } + universityFacultyQuery.setUniversitiesCollegesId(universitiesColleges.getUniversitiesCollegesId()); + universityFacultyQuery.setUniversityFacultyStatus(resultSet.getInt(6) + 1); + universityFacultyQuery.setUniversityFacultyAddTime(new Date()); + CoreUser userByCode = coreUserService.getUserByCode(universitiesColleges.getUniversitiesCollegesContacts()); + if (userByCode != null) { + universityFacultyQuery.setUserId(userByCode.getId()); + } else { + universityFacultyQuery.setUserId(Long.valueOf(100)); + } + universityFacultyQuery.setOrgId(universitiesColleges.getOrgId()); + universityFacultyService.add(universityFacultyQuery); + } + } catch (Exception e) { + e.printStackTrace(); + } finally { + ps.close(); + closeConn(conn); + } + + + } + + + @ApiOperation("迁移专业数据") + @PostMapping("updateMajor") + public void updateMajor() throws SQLException { + Connection conn = null; + PreparedStatement ps = null; + try { + conn = openConn(); +// UniversitySystemQuery universitySystemQuery; + + String sql = "SELECT " + + " ma.Name AS majorName, " + + " ma.Contacts, " + + " ma.PhoneNo, " + + " ma.IsDeleted, " + + " col.Name AS colName, " + + " sch.Name AS schName " + + "FROM " + + " EduMajors ma " + + " JOIN EduColleges col ON ma.CollegeId = col.Id " + + " JOIN EduSchools sch ON col.schoolId = sch.id"; + ps = conn.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + while (resultSet.next()) { + UniversitySystemQuery universitySystemQuery = new UniversitySystemQuery(); + universitySystemQuery.setUniversitySystemName(resultSet.getString(1)); + universitySystemQuery.setUniversitySystemContact(resultSet.getString(2)); + universitySystemQuery.setUniversitySystemContactTel(resultSet.getString(3)); + universitySystemQuery.setUniversitySystemAddTime(new Date()); + universitySystemQuery.setUniversitySystemStatus(resultSet.getInt(4) + 1); + UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(6)); + if (universitiesColleges == null) { + continue; + } + UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(5), universitiesColleges.getUniversitiesCollegesId()); + if (universityFaculty == null) { + continue; + } + universitySystemQuery.setUniversityFacultyId(universityFaculty.getUniversityFacultyId()); + + universitySystemQuery.setOrgId(universitiesColleges.getOrgId()); + universitySystemQuery.setUserId(universitiesColleges.getUserId()); + universitySystemService.add(universitySystemQuery); + } + + } catch (Exception e) { + e.printStackTrace(); + } finally { + ps.close(); + closeConn(conn); + } + } + + + @ApiOperation("迁移班级数据") + @PostMapping("updateClasses") + public void updateClasses() throws SQLException { + Connection conn = null; + PreparedStatement ps = null; + try { + conn = openConn(); +// UniversitySystemQuery universitySystemQuery; + + String sql = "SELECT " + + " sch.Name as schName, " + + " col.Name as colName, " + + " maj.Name as majName, " + + " cla.Name as claName, " + + " cla.IsDeleted " + + "FROM " + + " EduClasses cla " + + " JOIN EduMajors maj ON cla.MajorId = maj.Id " + + " JOIN EduColleges col ON maj.CollegeId = col.Id " + + " JOIN EduSchools sch ON col.schoolId = sch.id"; + ps = conn.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + while (resultSet.next()) { + + + String claName = resultSet.getString(4); + + SchoolClass serviceByName = schoolClassService.getByName(claName); + if (serviceByName != null) { + continue; + } + SchoolClass schoolClass = new SchoolClass(); + schoolClass.setClassName(resultSet.getString(4)); + UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(1)); + if (universitiesColleges == null) { + continue; + } + schoolClass.setUniversitiesCollegesId(universitiesColleges.getUniversitiesCollegesId()); + String uniqueClassSn = schoolClassService.buildClassSnEnsureUnique(universitiesColleges, schoolClass.getClassName()); + schoolClass.setClassSn(uniqueClassSn); + schoolClass.setOrgId(universitiesColleges.getOrgId()); + UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(2), universitiesColleges.getUniversitiesCollegesId()); + if (universityFaculty == null) { + continue; + } + schoolClass.setUniversityFacultyId(universityFaculty.getUniversityFacultyId()); + UniversitySystem universitySystem = universitySystemService.getByNameAndSchoolIdAndCollegeId(resultSet.getString(3), universityFaculty.getUniversityFacultyId()); + if (universitySystem == null) { + continue; + } + schoolClass.setUniversitySystemId(universitySystem.getUniversitySystemId()); + schoolClass.setOrgId(universitiesColleges.getOrgId()); + schoolClass.setUserId(Long.valueOf(100)); + schoolClass.setClassStatus(resultSet.getInt(5) + 1); + schoolClassService.save(schoolClass); + } + + } catch (Exception e) { + e.printStackTrace(); + } finally { + ps.close(); + closeConn(conn); + } + } + + @ApiOperation("迁移教师数据") + @PostMapping("updateTeacher") + public void updateTeacher() throws SQLException { + Connection conn = null; + PreparedStatement ps = null; + try { + conn = openConn(); + + String sql = "SELECT " + + " sch.Name AS schName, " + + " col.Name AS colName, " + + " maj.Name AS majName, " + + " tea.Name AS teacherName, " + + " tea.TeacherNo AS teacherNo, " + + " tea.PhoneNo, " + + " tea.Sex, " + + " tea.IsDeleted " + + "FROM " + + " EduTeachers tea " + + " JOIN EduColleges col ON tea.CollegeId = col.Id " + + " JOIN EduMajors maj ON tea.MajorId = maj.Id " + + " JOIN EduSchools sch ON tea.SchoolId = sch.Id where sch.Id = 117"; + ps = conn.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + while (resultSet.next()) { + Teacher teacher = new Teacher(); + UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(1)); + if (universitiesColleges == null) { + continue; + } + UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(2), universitiesColleges.getUniversitiesCollegesId()); + if (universityFaculty == null) { + continue; + } + UniversitySystem universitySystem = universitySystemService.getByNameAndSchoolIdAndCollegeId(resultSet.getString(3), universityFaculty.getUniversityFacultyId()); + if (universitySystem == null) { + continue; + } + teacher.setTeacherName(resultSet.getString(4)); + teacher.setUniversitiesCollegesId(universitiesColleges.getUniversitiesCollegesId()); + teacher.setUniversityFacultyId(universityFaculty.getUniversityFacultyId()); + teacher.setUniversitySystemId(universitySystem.getUniversitySystemId()); + teacher.setTeacherMobile(resultSet.getString(6)); + teacher.setTeacherJobNumber(resultSet.getString(5)); + teacher.setTeacherStatus(resultSet.getInt(8) + 1); + int anInt = resultSet.getInt(7); + GenderEnum genderEnum; + if (anInt == 1) { + genderEnum = GenderEnum.MAN; + } else { + genderEnum = GenderEnum.WOMAN; + } + teacher.setTeacherGender(genderEnum); + teacher.setAddTime(new Date()); + teacherService.add(teacher); + } + + } catch (Exception e) { + e.printStackTrace(); + } finally { + ps.close(); + closeConn(conn); + } + } + + + @ApiOperation("迁移学生数据") + @PostMapping("updateStudent") + public void updateStudent() throws SQLException { + Connection conn = null; + PreparedStatement ps = null; + try { + conn = openConn(); + String sql = "SELECT " + + " sch.Name AS schName, " + + " col.Name AS colName, " + + " maj.Name AS majName, " + + " stu.Name AS studentName, " + + " stu.StudentNo AS StudentNo, " + + " stu.PhoneNo, " + + " stu.Sex, " + + " stu.IsDeleted, " + + " cla.Name " + + "FROM " + + " EduStudents stu " + + " JOIN EduColleges col ON stu.CollegeId = col.Id " + + " JOIN EduMajors maj ON stu.MajorId = maj.Id " + + " JOIN EduSchools sch ON stu.SchoolId = sch.Id " + + " JOIN EduClasses cla ON stu.ClassId = cla.Id where sch.Id = 117"; + ps = conn.prepareStatement(sql); + ResultSet resultSet = ps.executeQuery(); + while (resultSet.next()) { + Student student = new Student(); + student.setStudentName(resultSet.getString(4)); + student.setStudentSn(resultSet.getString(5)); + student.setStudentMobile(resultSet.getString(6)); + String username = resultSet.getString(5); + Map studentByNo = coreUserService.getStudentByNo(username); + if(studentByNo!=null){ + continue; + } + int anInt = resultSet.getInt(7); + GenderEnum genderEnum; + if (anInt == 1) { + genderEnum = GenderEnum.MAN; + } else { + genderEnum = GenderEnum.WOMAN; + } + student.setStudentGender(genderEnum); + student.setAddTime(new Date()); + UniversitiesColleges universitiesColleges = universitiesCollegesService.getByName(resultSet.getString(1)); + if (universitiesColleges == null) { + continue; + } + UniversityFaculty universityFaculty = universityFacultyService.getByNameAndSchoolId(resultSet.getString(2), universitiesColleges.getUniversitiesCollegesId()); + if (universityFaculty == null) { + continue; + } + UniversitySystem universitySystem = universitySystemService.getByNameAndSchoolIdAndCollegeId(resultSet.getString(3), universityFaculty.getUniversityFacultyId()); + if (universitySystem == null) { + continue; + } + SchoolClass schoolClass = schoolClassService.getByNameAndMajorId(resultSet.getString(9), + universitySystem.getUniversitySystemId(), + universitiesColleges.getUniversitiesCollegesId(), + universityFaculty.getUniversityFacultyId() + ); + if (universitiesColleges == null || universityFaculty == null || universitySystem == null || schoolClass == null) { + continue; + } + student.setClassId(schoolClass.getClassId()); + studentService.add(student); + } + } catch (Exception ex) { + ex.printStackTrace(); + } finally { + ps.close(); + closeConn(conn); + } + } + + // @ApiOperation("迁移应用系统") // @PostMapping("copyApplications") // public void copyApplications() { @@ -523,4 +526,4 @@ // e.printStackTrace(); // } // } -//} +}