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);
        }
	}

}