package com.nanometer.smartlab.service;
|
|
import com.nanometer.smartlab.dao.SysContainerSensorsDao;
|
import com.nanometer.smartlab.dao.SysLaboratoryContainerDao;
|
import com.nanometer.smartlab.dao.SysWarehouseContainerDao;
|
import com.nanometer.smartlab.entity.SysContainerSensors;
|
import com.nanometer.smartlab.entity.SysLaboratoryContainer;
|
import com.nanometer.smartlab.entity.SysWarehouseContainer;
|
import com.nanometer.smartlab.entity.dto.ContainerStatusMngDto;
|
import com.nanometer.smartlab.exception.BusinessException;
|
import com.nanometer.smartlab.exception.ExceptionEnumCode;
|
import com.nanometer.smartlab.util.Constants;
|
import com.nanometer.smartlab.util.IDUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.time.DateFormatUtils;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.apache.log4j.Logger;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.Assert;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.sql.SQLException;
|
import java.util.*;
|
|
|
@Service("sysContainerSensorsService")
|
public class SysContainerSensorsServiceImpl implements SysContainerSensorsService {
|
|
private static Logger logger = Logger.getLogger(SysContainerSensorsServiceImpl.class);
|
|
|
@Resource(name = "sysContainerSensorsDao")
|
private SysContainerSensorsDao sysContainerSensorsDao;
|
@Resource
|
private SysLaboratoryContainerDao sysLaboratoryContainerDao;
|
@Resource
|
private SysWarehouseContainerDao sysWarehouseContainerDao;
|
|
@Override
|
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = {RuntimeException.class, SQLException.class,})
|
public int add(SysContainerSensors sysContainerSensors) throws RuntimeException {
|
return sysContainerSensorsDao.insertSelective(sysContainerSensors);
|
}
|
|
@Override
|
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = {RuntimeException.class, SQLException.class,})
|
public void syncSysContainerSensors(List<LinkedHashMap> sensorsList) throws Exception {
|
Assert.notNull(sensorsList, "请求参数不能为空!");
|
for (Map params : sensorsList) {
|
String containerCode = params.containsKey("containerCode")?params.get("containerCode").toString():"";
|
SysContainerSensors sensors = new SysContainerSensors();
|
sensors.setId(IDUtils.uuid());
|
sensors.setFlag(params.containsKey("Flag")?String.valueOf(params.get("Flag")):"");
|
sensors.setHumidity(params.containsKey("Humidity")?(int) params.get("Humidity"):0);
|
sensors.setTemp(params.containsKey("Temp")?(double) params.get("Temp"):0);
|
sensors.setVoc1(params.containsKey("voc1")?(double) params.get("voc1"):0);
|
|
SysLaboratoryContainer laboratoryContainer = sysLaboratoryContainerDao.getSysLaboratoryContainerByContainerCode(containerCode);
|
if (Objects.isNull(laboratoryContainer)) {
|
SysWarehouseContainer warehouseContainer = sysWarehouseContainerDao.getSysWarehouseContainerByContainerCode(containerCode);
|
if (Objects.isNull(warehouseContainer)) {
|
logger.error("The containerCode:"+containerCode+" has not been exists!");
|
continue;
|
} else {
|
sensors.setType(SysContainerSensors.TYPE_WAREHOUSE_CONTAINER);
|
sensors.setContainerId(warehouseContainer.getId());
|
}
|
} else {
|
sensors.setType(SysContainerSensors.TYPE_LABORATORY_CONTAINER);
|
sensors.setContainerId(laboratoryContainer.getId());
|
}
|
sensors.setUpdateTime(DateUtils.parseDate(params.get("updateTime").toString(), Constants.TIME_PATTERN_YYYY_MM_DD_HH_MM_SS));
|
sysContainerSensorsDao.insertSelective(sensors);
|
}
|
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public SysContainerSensors get(String id) throws RuntimeException {
|
return sysContainerSensorsDao.selectByPrimaryKey(id);
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public List<SysContainerSensors> getListBySelective(Map<String, Object> params) throws RuntimeException {
|
return sysContainerSensorsDao.getListBySelective(params);
|
}
|
|
@Override
|
@Transactional(readOnly = true)
|
public int countBySelective(Map<String, Object> params) throws RuntimeException {
|
return sysContainerSensorsDao.countBySelective(params);
|
}
|
|
/**
|
* @discription 返回所有信息
|
* @author celin
|
* @param params
|
* @return 暂存列表list
|
* @throws RuntimeException
|
*/
|
@Override
|
public List<ContainerStatusMngDto> selectInfo(Map<String, Object> params) throws RuntimeException {
|
return sysContainerSensorsDao.selectAll(params);
|
}
|
|
@Override
|
public int countAll(Map<String, Object> params) throws RuntimeException {
|
return sysContainerSensorsDao.countAll(params);
|
}
|
|
@Override
|
public ContainerStatusMngDto getRowData(String rowKey) {
|
return sysContainerSensorsDao.getRowData(rowKey);
|
}
|
|
@Override
|
public Map<String,BigDecimal> selectMaxTemperature(String selectedContainerId, String beginDate, String endDate) {
|
if (StringUtils.isBlank(selectedContainerId))
|
throw new BusinessException(ExceptionEnumCode.PARAM_NULL,"参数为空");
|
return sysContainerSensorsDao.selectMaxTemperature( selectedContainerId, beginDate, endDate);
|
}
|
|
@Override
|
public Map<String,BigDecimal> selectMaxHumidity(String selectedContainerId, String beginDate, String endDate) {
|
if (StringUtils.isBlank(selectedContainerId))
|
throw new BusinessException(ExceptionEnumCode.PARAM_NULL,"参数为空");
|
return sysContainerSensorsDao.selectMaxHumidity(selectedContainerId, beginDate, endDate);
|
}
|
|
@Override
|
public Map<String,BigDecimal> selectMaxVoc(String selectedContainerId, String beginDate, String endDate) {
|
if (StringUtils.isBlank(selectedContainerId))
|
throw new BusinessException(ExceptionEnumCode.PARAM_NULL,"参数为空");
|
return sysContainerSensorsDao.selectMaxVoc(selectedContainerId, beginDate, endDate);
|
}
|
|
|
}
|
