| | |
| | | @Service("EquipmentLogServiceImpl") |
| | | 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 selectEquipmentOporationMySql(String equipmentId) { |
| | | return this.baseMapper.selectEquipmentOporationMySql(equipmentId); |
| | |
| | | return this.baseMapper.selectEquipmentOporationSqlServer(equipmentId); |
| | | } |
| | | |
| | | @Override |
| | | public List<EquipmentLog> getEquipmentStatusList(List<String> equipmentIdList) { |
| | | return this.baseMapper.getEquipmentStatusList(equipmentIdList); |
| | | } |
| | | } |