package com.nanometer.smartlab.service;

import java.io.IOException;
import java.sql.Timestamp;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang.StringUtils;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.dao.DataAccessException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.nanometer.smartlab.dao.SysWarningDao;
import com.nanometer.smartlab.entity.SysWarning;
import com.nanometer.smartlab.exception.BusinessException;
import com.nanometer.smartlab.exception.ExceptionEnumCode;
import com.nanometer.smartlab.util.MessageUtil;


@Service("sysWarningService")
public class SysWarningServiceImpl implements SysWarningService {
	private static Logger logger = Logger.getLogger(SysWarningServiceImpl.class);

    @Resource(name = "sysWarningDao")
    SysWarningDao sysWarningDao;
    @Value("${alarm.url}")
    String alarmUrl;


    @Override
    public void insert(SysWarning sysWarning) {
        sysWarningDao.insertWatning(sysWarning);
    }


    @Transactional(propagation = Propagation.REQUIRED)
    public List<SysWarning> 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.sysWarningDao.getSysWarningList(params);
        } catch (DataAccessException e) {
            logger.error(e.getMessage(), e);
            throw new BusinessException(ExceptionEnumCode.DB_ERR, MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
        }
    }

    @Override
    public SysWarning getSysWarning(Long id) {
        try {
            return this.sysWarningDao.getSysWarning(id);
        } catch (DataAccessException e) {
            logger.error(e.getMessage(), e);
            throw new BusinessException(ExceptionEnumCode.DB_ERR, MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
        }
    }

    @Override
    public void updateSysWarning(SysWarning selectedWarning) throws IOException {
        try {
            Map<String,Object> params = new HashMap<>();
            params.put("memo", selectedWarning.getMemo());
            params.put("status", selectedWarning.getStatus());
            params.put("id", selectedWarning.getId());
            //给大屏信息发送处理信息
            //页面只允许修改完成转台
            if (selectedWarning.getDapingAlarmId()!=null && StringUtils.isNotBlank(alarmUrl)){
                JSONObject json=new JSONObject();
                json.put("dataType", "data");
                json.put("id", selectedWarning.getDapingAlarmId());
                CloseableHttpClient client2 = HttpClients.createDefault();
                HttpPost post2 = new HttpPost(alarmUrl);
                post2.setHeader("Content-Type", "application/json;charset=UTF-8");
                StringEntity se = new StringEntity(json.toString(), "UTF-8");
                se.setContentEncoding("UTF-8");
                se.setContentType("application/json");
                post2.setEntity(se);
                CloseableHttpResponse response2 = client2.execute(post2);
                String resData2 = EntityUtils.toString(response2.getEntity());
                client2.close();
                logger.info(resData2);
            }else{
                logger.info("关联daping的告警id为空 ");
            }
            this.sysWarningDao.updateSysWarning(params);
        } catch (DataAccessException e) {
            logger.error(e.getMessage(), e);
            throw new BusinessException(ExceptionEnumCode.DB_ERR, MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
        }
    }


    @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.sysWarningDao.getSysWarningTotalCount(params);
        } catch (DataAccessException e) {
            logger.error(e.getMessage(), e);
            throw new BusinessException(ExceptionEnumCode.DB_ERR, MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
        }
	}
}