package com.ruoyi.http.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.http.mapper.TqdianbiaoMeterMapper;
|
import com.ruoyi.http.pojo.TqdianbiaoMeter;
|
import com.ruoyi.http.service.TqdianbiaoMeterManageService;
|
import com.ruoyi.http.service.TqdianbiaoMeterSyncService;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
@Service
|
@RequiredArgsConstructor
|
public class TqdianbiaoMeterManageServiceImpl
|
extends ServiceImpl<TqdianbiaoMeterMapper, TqdianbiaoMeter>
|
implements TqdianbiaoMeterManageService {
|
|
private static final long MANUAL_METER_ID_BASE = 900_000_000L;
|
|
private final TqdianbiaoMeterSyncService meterSyncService;
|
|
@Override
|
public IPage<TqdianbiaoMeter> listPage(Page page, TqdianbiaoMeter query) {
|
return page(page, Wrappers.<TqdianbiaoMeter>lambdaQuery()
|
.and(StringUtils.isNotEmpty(query.getKeyword()), w -> w
|
.like(TqdianbiaoMeter::getMeterName, query.getKeyword())
|
.or()
|
.like(TqdianbiaoMeter::getAddress, query.getKeyword())
|
.or()
|
.like(TqdianbiaoMeter::getDescription, query.getKeyword()))
|
.eq(query.getMeterId() != null, TqdianbiaoMeter::getMeterId, query.getMeterId())
|
.eq(StringUtils.isNotEmpty(query.getSource()), TqdianbiaoMeter::getSource, query.getSource())
|
.orderByDesc(TqdianbiaoMeter::getUpdateTime));
|
}
|
|
@Override
|
public boolean addMeter(TqdianbiaoMeter meter) {
|
validateManualMeter(meter);
|
meter.setSource("manual");
|
meter.setMeterId(generateManualMeterId());
|
if (meter.getRate() == null) {
|
meter.setRate(1);
|
}
|
if (StringUtils.isEmpty(meter.getRelayState())) {
|
meter.setRelayState("1");
|
}
|
meter.setSyncTime(LocalDateTime.now());
|
return save(meter);
|
}
|
|
@Override
|
public boolean updateMeter(TqdianbiaoMeter meter) {
|
if (meter.getId() == null) {
|
throw new ServiceException("ID不能为空");
|
}
|
TqdianbiaoMeter existing = getById(meter.getId());
|
if (existing == null) {
|
throw new ServiceException("电表不存在");
|
}
|
if (StringUtils.isEmpty(meter.getAddress())) {
|
throw new ServiceException("表地址不能为空");
|
}
|
String meterName = StringUtils.isNotEmpty(meter.getMeterName()) ? meter.getMeterName() : meter.getAddress();
|
existing.setMeterName(meterName);
|
existing.setAddress(meter.getAddress());
|
existing.setDescription(meter.getDescription());
|
existing.setRelayState(meter.getRelayState());
|
if (existing.getSource() == null) {
|
existing.setSource("sync");
|
}
|
if ("manual".equals(existing.getSource())) {
|
existing.setRate(meter.getRate());
|
}
|
existing.setSyncTime(LocalDateTime.now());
|
return updateById(existing);
|
}
|
|
@Override
|
public boolean deleteByIds(List<Long> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
throw new ServiceException("请选择至少一条数据");
|
}
|
return removeBatchByIds(ids);
|
}
|
|
@Override
|
public int syncFromRemote() {
|
return meterSyncService.syncMeters();
|
}
|
|
private void validateManualMeter(TqdianbiaoMeter meter) {
|
if (StringUtils.isEmpty(meter.getMeterName())) {
|
throw new ServiceException("电表名称不能为空");
|
}
|
if (StringUtils.isEmpty(meter.getAddress())) {
|
throw new ServiceException("表地址不能为空");
|
}
|
}
|
|
private Long generateManualMeterId() {
|
TqdianbiaoMeter maxManual = getOne(
|
Wrappers.<TqdianbiaoMeter>lambdaQuery()
|
.eq(TqdianbiaoMeter::getSource, "manual")
|
.orderByDesc(TqdianbiaoMeter::getMeterId)
|
.last("LIMIT 1"),
|
false);
|
if (maxManual == null || maxManual.getMeterId() == null) {
|
return MANUAL_METER_ID_BASE + 1;
|
}
|
return maxManual.getMeterId() + 1;
|
}
|
}
|
