bonus
/
SafetyAlertSystem
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

注释三方接口代码数据

This commit is contained in:
mashuai 2024-09-20 15:18:17 +08:00
parent 8b176c956b
commit ee5f206117
5 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbPeopleServiceImpl.java
View File

@ -225,7 +225,7 @@ public class TbPeopleServiceImpl implements TbPeopleService {
public List<TbPeople> getList() { public List<TbPeople> getList() {
List<TbPeople> list = new ArrayList<>(); List<TbPeople> list = new ArrayList<>();
try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword); /*try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword);
Statement selectStmt = sourceConn.createStatement()) { Statement selectStmt = sourceConn.createStatement()) {
String selectQuery = "SELECT t1.real_name as relName, t1.id_card as idCard,t2.gender as sex, t1.position_code as postCode, t2.mobile as relPhone, t1.team_id as teamId FROM dky_get_working_team_member t1 " + String selectQuery = "SELECT t1.real_name as relName, t1.id_card as idCard,t2.gender as sex, t1.position_code as postCode, t2.mobile as relPhone, t1.team_id as teamId FROM dky_get_working_team_member t1 " +
@ -267,7 +267,7 @@ public class TbPeopleServiceImpl implements TbPeopleService {
} }
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException("Failed to connect to database", e); throw new RuntimeException("Failed to connect to database", e);
} }*/
return list; return list;
} }

4
bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbProDepartServiceImpl.java
View File

@ -196,7 +196,7 @@ public class TbProDepartServiceImpl implements TbProDepartService {
public List<TbProDepart> getList() { public List<TbProDepart> getList() {
List<TbProDepart> list = new ArrayList<>(); List<TbProDepart> list = new ArrayList<>();
try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword); /*try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword);
Statement selectStmt = sourceConn.createStatement()) { Statement selectStmt = sourceConn.createStatement()) {
String selectQuery = "SELECT t2.project_department_name AS departName, t2.department_type AS departType, t1.province AS areaName, t1.legal_repr AS headUser, " + String selectQuery = "SELECT t2.project_department_name AS departName, t2.department_type AS departType, t1.province AS areaName, t1.legal_repr AS headUser, " +
@ -237,7 +237,7 @@ public class TbProDepartServiceImpl implements TbProDepartService {
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException("Failed to connect to database", e); throw new RuntimeException("Failed to connect to database", e);
} }*/
return list; return list;
} }
} }

4
bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbProPowerServiceImpl.java
View File

@ -285,7 +285,7 @@ public class TbProPowerServiceImpl implements TbProPowerService {
@Override @Override
public List<TbProPower> getList() { public List<TbProPower> getList() {
List<TbProPower> list = new ArrayList<>(); List<TbProPower> list = new ArrayList<>();
try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword); /*try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword);
Statement selectStmt = sourceConn.createStatement()) { Statement selectStmt = sourceConn.createStatement()) {
String selectQuery = "SELECT * FROM dky_get_sm_tower_safety WHERE delete_flag = 0"; String selectQuery = "SELECT * FROM dky_get_sm_tower_safety WHERE delete_flag = 0";
@ -314,7 +314,7 @@ public class TbProPowerServiceImpl implements TbProPowerService {
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException("Failed to connect to database", e); throw new RuntimeException("Failed to connect to database", e);
} }*/
return list; return list;
} }
} }

12
bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbProjectServiceImpl.java
View File

@ -144,10 +144,10 @@ public class TbProjectServiceImpl implements TbProjectService {
List<TbProjectVo> projectVoList = new ArrayList<>(); List<TbProjectVo> projectVoList = new ArrayList<>();
List<TbProjectPowerVo> powers = new ArrayList<>(); List<TbProjectPowerVo> powers = new ArrayList<>();
try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword); /*try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword);
Statement selectStmt = sourceConn.createStatement()) { Statement selectStmt = sourceConn.createStatement()) {
String selectQuery = "SELECT * FROM dky_get_single_project"; String selectQuery = "SELECT * FROM dky_get_single_project";*/
/*//工程、杆塔组装 /*//工程、杆塔组装
String selectQuery = "SELECT t1.single_project_name AS proName," + String selectQuery = "SELECT t1.single_project_name AS proName," +
@ -162,7 +162,7 @@ public class TbProjectServiceImpl implements TbProjectService {
"AND t2.delete_flag = 0 " + "AND t2.delete_flag = 0 " +
"WHERE t1.delete_flag = 0";*/ "WHERE t1.delete_flag = 0";*/
try (ResultSet rs = selectStmt.executeQuery(selectQuery)) { /*try (ResultSet rs = selectStmt.executeQuery(selectQuery)) {
while (rs.next()) { while (rs.next()) {
String proName = rs.getString("single_project_name"); String proName = rs.getString("single_project_name");
String proTypeName = rs.getString("single_project_type"); String proTypeName = rs.getString("single_project_type");
@ -182,7 +182,7 @@ public class TbProjectServiceImpl implements TbProjectService {
} }
projectVoList.add(tbProjectVo); projectVoList.add(tbProjectVo);
} }
} }*/
/*while (rs.next()) { /*while (rs.next()) {
//工程名称 //工程名称
String proName = rs.getString("proName"); String proName = rs.getString("proName");
@ -220,13 +220,13 @@ public class TbProjectServiceImpl implements TbProjectService {
} }
}*/ }*/
} catch (SQLException e) { /*} catch (SQLException e) {
throw new RuntimeException("Failed to execute SQL query", e); throw new RuntimeException("Failed to execute SQL query", e);
} }
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException("Failed to connect to database", e); throw new RuntimeException("Failed to connect to database", e);
} }*/
/*if (CollectionUtils.isNotEmpty(powers)) { /*if (CollectionUtils.isNotEmpty(powers)) {
// 使用 Stream API 对数据进行分组 // 使用 Stream API 对数据进行分组

4
bonus-modules/bonus-base/src/main/java/com/bonus/base/service/impl/TbTeamServiceImpl.java
View File

@ -262,7 +262,7 @@ public class TbTeamServiceImpl implements TbTeamService {
@Override @Override
public List<TbTeam> getList() { public List<TbTeam> getList() {
List<TbTeam> list = new ArrayList<>(); List<TbTeam> list = new ArrayList<>();
try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword); /*try (Connection sourceConn = DriverManager.getConnection(sourceUrl, sourceUser, sourcePassword);
Statement selectStmt = sourceConn.createStatement()) { Statement selectStmt = sourceConn.createStatement()) {
String selectQuery = "SELECT t1.working_team_name as teamName,t3.gender as sex,t3.id_card as idCard, " + String selectQuery = "SELECT t1.working_team_name as teamName,t3.gender as sex,t3.id_card as idCard, " +
@ -314,7 +314,7 @@ public class TbTeamServiceImpl implements TbTeamService {
} }
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException("Failed to connect to database", e); throw new RuntimeException("Failed to connect to database", e);
} }*/
return list; return list;
} }
} }