package org.jeecg.modules.mdc.service.impl;

import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.jeecg.modules.mdc.entity.EquipmentLog;
import org.jeecg.modules.mdc.mapper.EquipmentLogMapper;
import org.jeecg.modules.mdc.service.IEquipmentLogService;
import org.jeecg.modules.mdc.service.IMdcAlarmInfoService;
import org.jeecg.modules.mdc.service.IMdcEquipmentService;
import org.jeecg.modules.mdc.subcontrol.vo.AllEquipmentLogVo;
import org.jeecg.modules.mdc.util.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.Date;
import java.util.List;

/**
 * @author: LiuS
 * @create: 2023-04-12 14:41
 */
@Service
public class EquipmentLogServiceImpl extends ServiceImpl<EquipmentLogMapper, EquipmentLog> implements IEquipmentLogService {
    @Override
    public List<EquipmentLog> findEquipmentLogByEndTime(String equipmentId, Date maxDate) {
        LambdaQueryChainWrapper<EquipmentLog> lambdaQuery = this.lambdaQuery();
        lambdaQuery.eq(EquipmentLog::getEquipmentId, equipmentId);
        if (maxDate != null) {
            lambdaQuery.ge(EquipmentLog::getCollectTime, maxDate);
        }
        lambdaQuery.ne(EquipmentLog::getOporation, 22);
        lambdaQuery.ne(EquipmentLog::getOporation, 23);
        lambdaQuery.orderByAsc(EquipmentLog::getCollectTime);
        return lambdaQuery.list();
    }

    @Override
    public List<EquipmentLog> findEquipmentLogByErrorEndTime(String equipmentId, Date endTime) {
        LambdaQueryChainWrapper<EquipmentLog> lambdaQuery = this.lambdaQuery();
        lambdaQuery.eq(EquipmentLog::getEquipmentId, equipmentId);
        if (endTime != null) {
            lambdaQuery.ge(EquipmentLog::getCollectTime, endTime);
        }
        lambdaQuery.in(EquipmentLog::getOporation, Arrays.asList(0, 22, 23));
        lambdaQuery.orderByAsc(EquipmentLog::getCollectTime);
        return lambdaQuery.list();
    }

    @Override
    public EquipmentLog getRow(String equipmentid, Date startTime) {
        return this.baseMapper.getRow(equipmentid, startTime);
    }

    @Override
    public EquipmentLog selectEquipmentOporation(String equipmentId) {
        return this.baseMapper.selectEquipmentOporation(equipmentId);
    }

    @Override
    public List<EquipmentLog> getEquipmentStatusList(List<String> equipmentIdList) {
        return this.baseMapper.getEquipmentStatusList(equipmentIdList);
    }

    @Override
    public List<AllEquipmentLogVo> getALLEquipmentLog() {
        //获取当前时间24小时之前的设备报警数据
        Date yesterday = DateUtils.getPreviousDay(DateUtils.getNow());
        List<AllEquipmentLogVo> list = this.baseMapper.findAllEquipmentLog(yesterday);
        return list;
    }

    @Override
    public EquipmentLog findEquipmentLog(String equipmentId) {
        return this.baseMapper.getOne(equipmentId);
    }
}