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.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);
    }
}