pull/1/head
puxcofief 8 months ago
parent cf35f821ec
commit 5d8c73cfc8

@ -1,159 +1,202 @@
package com.cn.service.impl; package com.cn.service.impl; // 定义服务实现类的包名
import java.sql.SQLException; import java.sql.SQLException; // 导入SQLException用于处理数据库操作中可能抛出的异常
import java.util.ArrayList; import java.util.ArrayList; // 导入ArrayList类用于创建动态数组
import java.util.List; import java.util.List; // 导入List接口用于操作列表集合
import org.apache.log4j.Logger; import org.apache.log4j.Logger; // 导入Logger类用于记录日志信息
import com.cn.dao.TrainDao; import com.cn.dao.TrainDao; // 导入TrainDao接口用于访问车次数据
import com.cn.dao.impl.TrainDaoImpl; import com.cn.dao.impl.TrainDaoImpl; // 导入TrainDao接口的实现类用于具体的数据库操作
import com.cn.domain.Train; import com.cn.domain.Train; // 导入Train类该类定义了车次的数据结构
import com.cn.service.TrainService; import com.cn.service.TrainService; // 导入TrainService接口该接口定义了车次服务的方法
/** /**
* * TrainService
* @ClassName: TrainServiceImpl * @ClassName: TrainServiceImpl TrainServiceImpl
* @Description: TrainService * @Description: TrainService
* @author: ljy * @author: ljy
* @date: 2019914 10:47:50 * @date: 2019914 10:47:50
*/ */
public class TrainServiceImpl implements TrainService { public class TrainServiceImpl implements TrainService {
private TrainDao trainDao = new TrainDaoImpl(); private TrainDao trainDao = new TrainDaoImpl(); // 成员变量用于数据库操作的TrainDao对象使用TrainDaoImpl实现类
private static Logger logger = Logger.getLogger(TrainServiceImpl.class); private static Logger logger = Logger.getLogger(TrainServiceImpl.class); // 日志记录器,用于记录日志信息
/**
*
* @param train
* @return
*/
@Override @Override
public int add(Train train) { public int add(Train train) {
int recordNumber = 0; int recordNumber = 0; // 记录数默认为0
if(train!=null) { if(train!=null) { // 检查传入的车次对象是否为null
try { try {
recordNumber = trainDao.add(train); recordNumber = trainDao.add(train); // 调用TrainDao的add方法添加车次
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
}else { }else {
logger.debug("TrainServiceImpl.add 中 train为null"); logger.debug("TrainServiceImpl.add 中 train为null"); // 记录调试日志当train为null时
} }
return recordNumber; return recordNumber; // 返回记录数
} }
/**
* ID
* @param trainId ID
* @return
*/
@Override @Override
public int delete(Integer trainId) { public int delete(Integer trainId) {
int recordNumber = 0; int recordNumber = 0; // 记录数默认为0
if(trainId!=null && trainId!=0) { if(trainId!=null && trainId!=0) { // 检查传入的车次ID是否为null或0
try { try {
recordNumber = trainDao.delete(trainId); recordNumber = trainDao.delete(trainId); // 调用TrainDao的delete方法删除车次
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
}else { }else {
logger.debug("TrainServiceImpl.delete 中 trainId为null或0"); logger.debug("TrainServiceImpl.delete 中 trainId为null或0"); // 记录调试日志当trainId为null或0时
} }
return recordNumber; return recordNumber; // 返回记录数
} }
/**
*
* @param train
* @return
*/
@Override @Override
public int update(Train train) { public int update(Train train) {
int recordNumber = 0; int recordNumber = 0; // 记录数默认为0
if(train!=null) { if(train!=null) { // 检查传入的车次对象是否为null
try { try {
recordNumber = trainDao.update(train); recordNumber = trainDao.update(train); // 调用TrainDao的update方法更新车次
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
}else { }else {
logger.debug("TrainServiceImpl.update 中 train为null"); logger.debug("TrainServiceImpl.update 中 train为null"); // 记录调试日志当train为null时
} }
return recordNumber; return recordNumber; // 返回记录数
} }
/**
*
* @return
*/
@Override @Override
public List<Train> getAll() { public List<Train> getAll() {
List<Train> list = null; List<Train> list = null; // 车次列表默认为null
try { try {
list = trainDao.getAll(); list = trainDao.getAll(); // 调用TrainDao的getAll方法获取所有车次信息
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
return list; return list; // 返回车次列表
} }
/**
* ID
* @param trainId ID
* @return ID
*/
@Override @Override
public Train getById(Integer trainId) { public Train getById(Integer trainId) {
Train train = null; Train train = null; // 车次对象默认为null
if(trainId!=null && trainId!=0) { if(trainId!=null && trainId!=0) { // 检查传入的车次ID是否为null或0
try { try {
train = trainDao.getById(trainId); train = trainDao.getById(trainId); // 调用TrainDao的getById方法根据车次ID获取车次
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
}else { }else {
logger.debug("TrainServiceImpl.getById 中 trainId为null或0"); logger.debug("TrainServiceImpl.getById 中 trainId为null或0"); // 记录调试日志当trainId为null或0时
} }
return train; return train; // 返回车次对象
} }
/**
*
* @param trainNumber
* @return
*/
@Override @Override
public List<Train> getByTrainNumber(String trainNumber) { public List<Train> getByTrainNumber(String trainNumber) {
List<Train> list = null; List<Train> list = null; // 车次列表默认为null
if(trainNumber!=null && !"".equals(trainNumber)) { if(trainNumber!=null && !"".equals(trainNumber)) { // 检查传入的车次号是否为空或空字符串
try { try {
list = trainDao.getByTrainNumber(trainNumber); list = trainDao.getByTrainNumber(trainNumber); // 调用TrainDao的getByTrainNumber方法根据车次号获取车次
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
} }
return list; return list; // 返回车次列表
} }
/**
*
* @param startStation
* @param endStation
* @param startTime
* @return
*/
@Override @Override
public List<Train> getByStartEndStation(String startStation, String endStation, String startTime) { public List<Train> getByStartEndStation(String startStation, String endStation, String startTime) {
List<Train> list = null; List<Train> list = null; // 车次列表默认为null
if(startStation!=null && !"".equals(startStation) && endStation!=null && !"".equals(endStation) if(startStation!=null && !"".equals(startStation) && endStation!=null && !"".equals(endStation)
&& startTime!=null && !"".equals(startTime)) { && startTime!=null && !"".equals(startTime)) { // 检查传入的起始站、终点站和开车时间是否为空或空字符串
try { try {
list = trainDao.getByStartEndStation(startStation, endStation, startTime); list = trainDao.getByStartEndStation(startStation, endStation, startTime); // 调用TrainDao的getByStartEndStation方法根据起始站、终点站和开车时间获取车次
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
} else { } else {
logger.debug("TrainServiceImpl.getByStartEndStation: 信息不完整!!!"); logger.debug("TrainServiceImpl.getByStartEndStation: 信息不完整!!!"); // 记录调试日志,当起始站、终点站或开车时间信息不完整时
} }
return list; return list; // 返回车次列表
} }
/**
*
* @return
*/
@Override @Override
public List<Train> getAllStartStation() { public List<Train> getAllStartStation() {
List<Train> list = null; List<Train> list = null; // 车次列表默认为null
try { try {
list = trainDao.getAllStartStation(); list = trainDao.getAllStartStation(); // 调用TrainDao的getAllStartStation方法获取所有非重复的起始站
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
return list; return list; // 返回车次列表
} }
/**
*
* @return
*/
@Override @Override
public List<Train> getAllEndStation() { public List<Train> getAllEndStation() {
List<Train> list = null; List<Train> list = null; // 车次列表默认为null
try { try {
list = trainDao.getAllEndStation(); list = trainDao.getAllEndStation(); // 调用TrainDao的getAllEndStation方法获取所有非重复的终点站
} catch (SQLException e) { } catch (SQLException e) {
logger.error(e.toString()); logger.error(e.toString()); // 记录错误日志
e.printStackTrace(); e.printStackTrace(); // 打印异常堆栈跟踪
} }
return list; return list; // 返回车次列表
} }
} }
Loading…
Cancel
Save