package com.nanometer.smartlab.service;

import com.google.common.collect.ImmutableBiMap;
import com.nanometer.smartlab.dao.SysLaboratoryContainerDao;
import com.nanometer.smartlab.entity.SysLaboratory;
import com.nanometer.smartlab.entity.SysLaboratoryContainer;
import com.nanometer.smartlab.exception.AlarmCode;
import com.nanometer.smartlab.exception.AlarmException;
import com.nanometer.smartlab.exception.BusinessException;
import com.nanometer.smartlab.exception.ExceptionEnumCode;
import com.nanometer.smartlab.model.CommonPage;
import com.nanometer.smartlab.util.ExcelUtils;
import com.nanometer.smartlab.util.IDUtils;
import com.nanometer.smartlab.util.MessageUtil;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.dao.DataAccessException;
import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.*;

/**
 * Created by cmower on 17/11/20.
 */
@Service("sysLaboratoryContainerService")
public class SysLaboratoryContainerServiceImpl implements SysLaboratoryContainerService {

	private static Logger logger = Logger.getLogger(SysLaboratoryContainerService.class);

	@Resource(name = "sysLaboratoryContainerDao")
	SysLaboratoryContainerDao sysLaboratoryContainerDao;

	@Transactional(propagation = Propagation.REQUIRED)
	public List<SysLaboratoryContainer> getSysLaboratoryContainerList(String laboratoryType, String laboratoryName,
			String laboratoryId,String project,String controllerName, Integer first, Integer pageSize) {
		try {
			Map<String, Object> params = new HashMap<String, Object>();
			if (StringUtils.isNotBlank(laboratoryType)) {
				params.put("laboratoryType", laboratoryType);
			}
			if (StringUtils.isNotBlank(laboratoryName)) {
				params.put("laboratoryName", "%" + laboratoryName + "%");
			}
			if (StringUtils.isNotBlank(laboratoryId)) {
				params.put("laboratoryId", laboratoryId);
			}
			params.put("project", project);
			params.put("controllerName", controllerName);
			params.put("first", first);
			params.put("pageSize", pageSize);
			return this.sysLaboratoryContainerDao.getSysLaboratoryContainerList(params);
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

	@Override
	public CommonPage<SysLaboratoryContainer> getSysLaboratoryContainerList(Integer pageNum, Integer pageSize, String name, String controllerName) {
		if(pageNum==null||pageNum<1){
			pageNum=1;
		}
		if(pageSize==null||pageSize<1){
			pageSize=10;
		}
		if(pageSize>50){
			pageSize=50;
		}
		Map<String, Object> params = new HashMap<>();
		if (StringUtils.isNotBlank(name)) {
			params.put("laboratoryName","%" + name+ "%");
		}
		if (StringUtils.isNotBlank(controllerName)) {
			params.put("controllerName", "%" + controllerName + "%");
		}
		params.put("first", (pageNum-1)*pageSize);
		params.put("pageSize", pageSize);
		CommonPage commonPage=new CommonPage();
		commonPage.setPageNum(pageNum);
		commonPage.setPageSize(pageSize);
		Long total=new Long(sysLaboratoryContainerDao.getSysLaboratoryContainerTotalCount(params));
		commonPage.setTotal(total);
		commonPage.setTotalPage(CommonPage.getTotalPage(total,pageSize));
		List<SysLaboratoryContainer> sysReagents=sysLaboratoryContainerDao.getSysLaboratoryContainerSimpleInfoList(params);
		commonPage.setList(sysReagents);
		return commonPage;

	}

	@Transactional(propagation = Propagation.REQUIRED)
	public List<SysLaboratoryContainer> getSysLaboratoryContainerList(
			String laboratoryId) {
		 return getSysLaboratoryContainerList(null,null,laboratoryId,null,null,null,null);
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public int getSysLaboratoryContainerTotalCount(String laboratoryType, String laboratoryName, String laboratoryId,String project,String controllerName) {
		try {
			Map<String, Object> params = new HashMap<String, Object>();
			if (StringUtils.isNotBlank(laboratoryType)) {
				params.put("laboratoryType", laboratoryType);
			}
			if (StringUtils.isNotBlank(laboratoryName)) {
				params.put("laboratoryName", "%" + laboratoryName + "%");
			}
			if (StringUtils.isNotBlank(laboratoryId)) {
				params.put("laboratoryId", laboratoryId);
			}
			params.put("project", project);
			params.put("controllerName", controllerName);
			return this.sysLaboratoryContainerDao.getSysLaboratoryContainerTotalCount(params);
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public SysLaboratoryContainer getSysLaboratoryContainer(String id) {
		try {
			return this.sysLaboratoryContainerDao.getSysLaboratoryContainer(id);
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public SysLaboratoryContainer getSysLaboratoryContainerByContainerCode(String containerCode) {
		try {
			return this.sysLaboratoryContainerDao.getSysLaboratoryContainerByContainerCode(containerCode);
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public SysLaboratoryContainer insertSysLaboratoryContainer(SysLaboratoryContainer sysLaboratoryContainer) {
		try {
			if (sysLaboratoryContainer.getId() == null) {
				sysLaboratoryContainer.setId(IDUtils.uuid());
			}
			this.sysLaboratoryContainerDao.insertSysLaboratoryContainer(sysLaboratoryContainer);
			this.sysLaboratoryContainerDao.updateSLContainerUser(sysLaboratoryContainer);
			return sysLaboratoryContainer;
		} catch (DuplicateKeyException ex) {
			logger.warn(ex.getMessage(), ex);
			throw new AlarmException(AlarmCode.DATA_DUPLICATE,
					MessageUtil.getMessage(AlarmCode.DATA_DUPLICATE.getCode()));
		} catch (DataIntegrityViolationException ex) {
			logger.warn(ex.getMessage(), ex);
			throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
		} catch (DataAccessException ex) {
			logger.error(ex.getMessage(), ex);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public boolean updateSysLaboratoryContainer(SysLaboratoryContainer sysLaboratoryContainer) {
		try {
			int row = this.sysLaboratoryContainerDao.updateSysLaboratoryContainer(sysLaboratoryContainer);
			this.sysLaboratoryContainerDao.updateSLContainerUser(sysLaboratoryContainer);
			return row != 0;
		} catch (DuplicateKeyException ex) {
			logger.warn(ex.getMessage(), ex);
			throw new AlarmException(AlarmCode.DATA_DUPLICATE,
					MessageUtil.getMessage(AlarmCode.DATA_DUPLICATE.getCode()));
		} catch (DataIntegrityViolationException ex) {
			logger.warn(ex.getMessage(), ex);
			throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
		} catch (DataAccessException ex) {
			logger.error(ex.getMessage(), ex);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public boolean deleteSysLaboratoryContainer(List<SysLaboratoryContainer> sysLaboratoryContainerList) {
		try {
			if (sysLaboratoryContainerList == null || sysLaboratoryContainerList.size() == 0) {
				return false;
			}

			List<String> ids = new ArrayList<String>();
			for (SysLaboratoryContainer sysLaboratoryContainer : sysLaboratoryContainerList) {
				ids.add(sysLaboratoryContainer.getId());
				this.sysLaboratoryContainerDao.updateSLContainerUser(sysLaboratoryContainer);
			}

			int row = this.sysLaboratoryContainerDao.deleteSysLaboratoryContainers(ids);
			return row != 0;
		} catch (DataIntegrityViolationException ex) {
			logger.warn(ex.getMessage(), ex);
			throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
		} catch (DataAccessException ex) {
			logger.error(ex.getMessage(), ex);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public boolean isSysLaboratoryContainerExist(String containerCode, String editId) {
		try {
			Map<String, Object> params = new HashMap<String, Object>();
			params.put("containerCode", containerCode);
			params.put("editId", editId);
			int count = this.sysLaboratoryContainerDao.getSysLaboratoryContainerExist(params);
			return count > 0;
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

	@Override
	@Transactional(readOnly = true)
	public List<SysLaboratoryContainer> getSysLaboratoryContainerInfoList(String startTime, String endTime){
		Map<String, String> params = ImmutableBiMap.of("startTime",startTime,"endTime",endTime);
		return sysLaboratoryContainerDao.getSysLaboratoryContainerInfoList(params);
	}

	@Override
	public void insertSysReagentList(List<SysLaboratoryContainer> list) {
		for (SysLaboratoryContainer container :list
		) {
			SysLaboratoryContainer containermpl = new SysLaboratoryContainer();
			containermpl = sysLaboratoryContainerDao.getSysLaboratoryContainerByContainerCode(container.getContainerCode());
			if(containermpl!=null){
				container.setId(containermpl.getId());
				this.sysLaboratoryContainerDao.updateSysLaboratoryContainer(container);
			}else{
				if (containermpl == null) {
					container.setId(IDUtils.uuid());
				}
				this.sysLaboratoryContainerDao.insertSysLaboratoryContainer(container);
			}
		}
	}

	@Transactional(propagation = Propagation.REQUIRED)
	public void updateInfo(Float temp,Float humidity,Float voc1,String containerId,String flag) {
		try {
			Map<String, Object> params = new HashMap<String, Object>();
			params.put("temp", temp);
			params.put("humidity", humidity);
			params.put("voc1", voc1);
			params.put("containerId", containerId);
			params.put("flag", flag);
			this.sysLaboratoryContainerDao.updateInfo(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<Map> getContainerPersonInCharge(String containerCode) {
		try {
			return sysLaboratoryContainerDao.getContainerPersonInCharge(containerCode);
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

	@Override
	public Map selectLocationByContainerCode(String containerCode) {
		try {
			return sysLaboratoryContainerDao.selectLocationByContainerCode(containerCode);
		} catch (DataAccessException e) {
			logger.error(e.getMessage(), e);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), e);
		}
	}

    @Override
    public List<Map> exportExcelList(String laboratoryType, String laboratoryName,String project,String controllerName) {
		Map<String, String> params = new HashMap<>();
		params.put("type", laboratoryType);
		params.put("name", laboratoryName);
		params.put("project", project);
		params.put("controllerName", controllerName);
		return sysLaboratoryContainerDao.exportExcelList(params);
    }

	@Override
	public void export2Excel(List<Map> list) throws Exception {
		Map<String, String> map = new LinkedHashMap<>();
		map.put("labType", "实验室类型");
		map.put("labName", "实验室名称");
		map.put("controlName", "主控名称");
		map.put("containerCode", "临时存储库条码");
		map.put("containerType", "临时存储库类型");
		map.put("infoCode", "临时存储库状态码");
		map.put("structure", "临时存储库结构");
		map.put("name", "临时存储库名称");
		map.put("project", "课题组");
		ExcelUtils.export2Excel(list,"实验室临时存储库管理",map);

	}

    @Override
    public List<String> selectProjectsByContainerCode(String containerCode) {
		List<String> projects = sysLaboratoryContainerDao.selectProjectsByContainerCode(containerCode);
		if  (projects.size() > 0){
			List<String> projectList = new ArrayList<>();
			for (String project : projects){
				if (StringUtils.isNotBlank(project)){
					projectList.addAll(Arrays.asList(project.split(",")));
				}
			}
			return projectList;
		}
		return null;
    }

	@Override
	public boolean delBySlcIds(List<SysLaboratory> sysLaboratoryList) {
		try {
			if (sysLaboratoryList == null || sysLaboratoryList.size() == 0) {
				return false;
			}

			List<String> ids = new ArrayList<String>();
			for (SysLaboratory sysLaboratory : sysLaboratoryList) {
				ids.add(sysLaboratory.getId());
			}

			int row = this.sysLaboratoryContainerDao.delSlcIds(ids);
			return row != 0;
		} catch (DataIntegrityViolationException ex) {
			logger.warn(ex.getMessage(), ex);
			throw new AlarmException(AlarmCode.DATA_CONFICT, MessageUtil.getMessage(AlarmCode.DATA_CONFICT.getCode()));
		} catch (DataAccessException ex) {
			logger.error(ex.getMessage(), ex);
			throw new BusinessException(ExceptionEnumCode.DB_ERR,
					MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex);
		}
	}

}