CIS/src/main/java/com/welampiot/service/impl/CableServiceImpl.java

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<CableDTO> devList = cableDao.getDevListByCableDTO(dto);
        List<CableDTO> 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);
    }
}