package com.welampiot.service.impl; import com.welampiot.dao.CableDao; import com.welampiot.dto.CableDTO; import com.welampiot.service.CableService; import com.welampiot.vo.CableVO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; /** * ClassName: CableServiceImpl * Package: com.welampiot.service.impl * Description: * * @Author: zhj_Start * @Create: 2023/4/21 - 11:25 * @Version: v1.0 */ @Service public class CableServiceImpl implements CableService { @Autowired private CableDao cableDao; @Override public CableVO getDevListByCableDTO(CableDTO dto) { CableVO vo = new CableVO(); List devList = cableDao.getDevListByCableDTO(dto); List list = new ArrayList<>(); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); devList.forEach(cableDTO ->{ if (cableDTO.getOnline() != null && cableDTO.getOnline() == 1){ cableDTO.setOnline(1); }else { cableDTO.setOnline(0); } if (cableDTO.getType() != null && cableDTO.getType() == 2){ cableDTO.setType(2); }else if (cableDTO.getType() != null && cableDTO.getType() == 1){ cableDTO.setType(1); }else { cableDTO.setType(0); } if (cableDTO.getManhole1A() != null && cableDTO.getManhole1A() == 0){ cableDTO.setManhole1A(0); } if (cableDTO.getManhole2A() != null && cableDTO.getManhole2A() == 0){ cableDTO.setManhole2A(0); } if (cableDTO.getManhole2A() != null && cableDTO.getManhole2A() == 0){ cableDTO.setManhole2A(0); } if (cableDTO.getManhole3A() != null && cableDTO.getManhole3A() == 0){ cableDTO.setManhole3A(0); } if (cableDTO.getManhole4A() != null && cableDTO.getManhole4A() == 0){ cableDTO.setManhole4A(0); } if (cableDTO.getManhole5A() != null && cableDTO.getManhole5A() == 0){ cableDTO.setManhole5A(0); } if (cableDTO.getTemperature1A() != null && cableDTO.getTemperature1A() == 0){ cableDTO.setTemperature1A(0); } if (cableDTO.getTemperature2A() != null && cableDTO.getTemperature2A() == 0){ cableDTO.setTemperature2A(0); } if (cableDTO.getTemperature3A() != null && cableDTO.getTemperature3A() == 0){ cableDTO.setTemperature3A(0); } if (cableDTO.getGasA() != null && cableDTO.getGasA() == 0){ cableDTO.setGasA(0); } if (cableDTO.getUpdateTime() != null && !cableDTO.getUpdateTime().equals("")){ Date cmdTime; try { cmdTime = simpleDateFormat.parse(cableDTO.getUpdateTime()); } catch (ParseException e) { throw new RuntimeException(e); } //判断时区,为null默认东八区 long timezone = cableDTO.getTimezone() == null ? 8 : cableDTO.getTimezone(); long l = cmdTime.getTime() + timezone * 3600 * 1000; cmdTime = new Date(l); cableDTO.setUpdateTime(simpleDateFormat.format(cmdTime)); }else { cableDTO.setUpdateTime(""); } if (cableDTO.getManhole1V() == null || cableDTO.getManhole1V().equals("0.0")){ cableDTO.setManhole1V("0"); } if (cableDTO.getManhole1X() == null || cableDTO.getManhole1X().equals("0.0")){ cableDTO.setManhole1X("0"); } if (cableDTO.getManhole1Y() == null || cableDTO.getManhole1Y().equals("0.0")){ cableDTO.setManhole1Y("0"); } if (cableDTO.getManhole1Z() == null || cableDTO.getManhole1Z().equals("0.0")){ cableDTO.setManhole1Z("0"); } if (cableDTO.getManhole2V() == null || cableDTO.getManhole2V().equals("0.0")){ cableDTO.setManhole2V("0"); } if (cableDTO.getManhole2X() == null || cableDTO.getManhole2X().equals("0.0")){ cableDTO.setManhole2X("0"); } if (cableDTO.getManhole2Y() == null || cableDTO.getManhole2Y().equals("0.0")){ cableDTO.setManhole2Y("0"); } if (cableDTO.getManhole2Z() == null || cableDTO.getManhole2Z().equals("0.0")){ cableDTO.setManhole2Z("0"); } if (cableDTO.getManhole3V() == null || cableDTO.getManhole3V().equals("0.0")){ cableDTO.setManhole3V("0"); } if (cableDTO.getManhole3X() == null || cableDTO.getManhole3X().equals("0.0")){ cableDTO.setManhole3X("0"); } if (cableDTO.getManhole3Y() == null || cableDTO.getManhole3Y().equals("0.0")){ cableDTO.setManhole3Y("0"); } if (cableDTO.getManhole3Z() == null || cableDTO.getManhole3Z().equals("0.0")){ cableDTO.setManhole3Z("0"); } if (cableDTO.getManhole4V() == null || cableDTO.getManhole4V().equals("0.0")){ cableDTO.setManhole4V("0"); } if (cableDTO.getManhole4X() == null || cableDTO.getManhole4X().equals("0.0")){ cableDTO.setManhole4X("0"); } if (cableDTO.getManhole4Y() == null || cableDTO.getManhole4Y().equals("0.0")){ cableDTO.setManhole4Y("0"); } if (cableDTO.getManhole4Z() == null || cableDTO.getManhole4Z().equals("0.0")){ cableDTO.setManhole4Z("0"); } if (cableDTO.getManhole5V() == null || cableDTO.getManhole5V().equals("0.0")){ cableDTO.setManhole5V("0"); } if (cableDTO.getManhole5X() == null || cableDTO.getManhole5X().equals("0.0")){ cableDTO.setManhole5X("0"); } if (cableDTO.getManhole5Y() == null || cableDTO.getManhole5Y().equals("0.0")){ cableDTO.setManhole5Y("0"); } if (cableDTO.getManhole5Z() == null || cableDTO.getManhole5Z().equals("0.0")){ cableDTO.setManhole5Z("0"); } if (cableDTO.getTemperature1T() == null || cableDTO.getTemperature1T().equals("0.0")){ cableDTO.setTemperature1T("0"); } if (cableDTO.getTemperature1V() == null || cableDTO.getTemperature1V().equals("0.0")){ cableDTO.setTemperature1V("0"); } if (cableDTO.getTemperature2T() == null || cableDTO.getTemperature2T().equals("0.0")){ cableDTO.setTemperature2T("0"); } if (cableDTO.getTemperature2V() == null || cableDTO.getTemperature2V().equals("0.0")){ cableDTO.setTemperature2V("0"); } if (cableDTO.getTemperature3T() == null || cableDTO.getTemperature3T().equals("0.0")){ cableDTO.setTemperature3T("0"); } if (cableDTO.getTemperature3V() == null || cableDTO.getTemperature3V().equals("0.0")){ cableDTO.setTemperature3V("0"); } if (cableDTO.getWaterV() == null || cableDTO.getWaterV().equals("0.0")){ cableDTO.setWaterV("0"); } if (cableDTO.getGasV() == null || cableDTO.getGasV().equals("0.0")){ cableDTO.setGasV("0"); } if (cableDTO.getO2() == null || cableDTO.getO2().equals("0.0")){ cableDTO.setO2("0"); } list.add(cableDTO); }); vo.setList(list); return vo; } @Override public CableVO getDataByCableDTO(CableDTO dto) { CableVO vo = new CableVO(); vo.setTotal(cableDao.getTotalByCableDTO(dto)); vo.setOnlineCount(cableDao.getOnlineTotalByCableDTO(dto)); vo.setTempAlarmCount(cableDao.getTempAlarmTotalByCableDTO(dto)); vo.setWaterAlarmCount(cableDao.getWaterAlarmTotalByCableDTO(dto)); vo.setManholeAlarmCount(cableDao.getManholeAlarmTotalByCableDTO(dto)); vo.setCh4AlarmCount(cableDao.getCh4AlarmTotalByCableDTO(dto)); vo.setCo2AlarmCount(cableDao.getCo2AlarmTotalByCableDTO(dto)); vo.setH2sAlarmCount(cableDao.getH2sAlarmTotalByCableDTO(dto)); vo.setO2AlarmCount(cableDao.getO2AlarmTotalByCableDTO(dto)); return vo; } @Override public void deleteCableById(Integer id) { cableDao.deleteCableById(id); } @Override public CableDTO getCableById(Integer id) { return cableDao.getCableById(id); } @Override public Integer getCableCountByLampPoleId(Integer lampPoleId) { return cableDao.getCableCountByLampPoleId(lampPoleId); } @Override public CableDTO getCableByLampPoleId(Integer lampPoleId) { return cableDao.getCableByLampPoleId(lampPoleId); } @Override public void updateLampPoleCableData(CableDTO dto) { cableDao.updateLampPoleCableData(dto); } @Override public Integer checkCableData(CableDTO dto) { return cableDao.checkCableData(dto); } }