package com.nanometer.smartlab.service;
|
|
import java.sql.Timestamp;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.apache.commons.lang.StringUtils;
|
import org.apache.log4j.Logger;
|
import org.springframework.dao.DataAccessException;
|
import org.springframework.stereotype.Service;
|
|
import com.nanometer.smartlab.dao.SysAlarmDao;
|
import com.nanometer.smartlab.entity.SysAlarm;
|
import com.nanometer.smartlab.exception.BusinessException;
|
import com.nanometer.smartlab.exception.ExceptionEnumCode;
|
import com.nanometer.smartlab.util.MessageUtil;
|
|
@Service("sysAlarmService")
|
public class SysAlarmServiceImpl implements SysAlarmService {
|
|
private static Logger logger = Logger.getLogger(SysAlarmServiceImpl.class);
|
|
@Resource(name = "sysAlarmDao")
|
SysAlarmDao sysAlarmDao;
|
@Override
|
public int getSysWarningTotalCount(String code, Timestamp startTime, Timestamp endTime) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
if (StringUtils.isNotBlank(code)) {
|
params.put("containerCode", "%" + code + "%");
|
}
|
if(startTime != null)
|
{
|
params.put("startWarningTime", startTime);
|
}
|
if(endTime != null)
|
{
|
params.put("endWarningTime", endTime);
|
}
|
|
return this.sysAlarmDao.getSysAlarmTotalCount(params);
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR, MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
|
@Override
|
public List<SysAlarm> getSysWarningList(String code, Timestamp startTime, Timestamp endTime, Integer first,
|
Integer pageSize) {
|
try {
|
Map<String, Object> params = new HashMap<String, Object>();
|
if (StringUtils.isNotBlank(code)) {
|
params.put("containerCode", "%" + code + "%");
|
}
|
params.put("startWarningTime", startTime);
|
params.put("endWarningTime", endTime);
|
params.put("first", first);
|
params.put("pageSize", pageSize);
|
return this.sysAlarmDao.getSysAlarmList(params);
|
} catch (DataAccessException e) {
|
logger.error(e.getMessage(), e);
|
throw new BusinessException(ExceptionEnumCode.DB_ERR, MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
|
}
|
}
|
|
}
|