package com.ruoyi.other.emind.service;
|
|
import com.ruoyi.other.emind.domain.EmindEnergyChain;
|
import com.ruoyi.other.emind.domain.EmindStation;
|
import com.ruoyi.other.emind.dto.EmindEnergyChainDto;
|
import com.ruoyi.other.emind.mapper.EmindEnergyChainMapper;
|
import com.ruoyi.other.emind.mapper.EmindStationMapper;
|
import com.ruoyi.other.emind.util.EmindCloudApiUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.Clock;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/** 根据有效储能站点全量同步 eMind 能量链。 */
|
@Service
|
@ConditionalOnProperty(prefix = "emind", name = "enabled", havingValue = "true")
|
public class EmindEnergyChainSyncService {
|
private final EmindCloudApiUtil api;
|
private final EmindStationMapper stationMapper;
|
private final EmindEnergyChainMapper chainMapper;
|
private final Clock clock;
|
|
@Autowired
|
public EmindEnergyChainSyncService(EmindCloudApiUtil api,
|
EmindStationMapper stationMapper,
|
EmindEnergyChainMapper chainMapper) {
|
this(api, stationMapper, chainMapper, Clock.systemDefaultZone());
|
}
|
|
EmindEnergyChainSyncService(EmindCloudApiUtil api,
|
EmindStationMapper stationMapper,
|
EmindEnergyChainMapper chainMapper,
|
Clock clock) {
|
this.api = api;
|
this.stationMapper = stationMapper;
|
this.chainMapper = chainMapper;
|
this.clock = clock;
|
}
|
|
/** 所有站点请求成功后才更新本地冗余。 */
|
@Transactional(rollbackFor = Exception.class)
|
public int syncEnergyChains() {
|
List<EmindStation> stations = stationMapper.selectRemoteActiveStations();
|
LocalDateTime syncedAt = LocalDateTime.now(clock);
|
List<EmindEnergyChain> chains = new ArrayList<>();
|
for (EmindStation station : stations) {
|
if(station.getSourceType() == 1) {
|
List<EmindEnergyChainDto> remoteChains = api.getEnergyChains(station.getStationId());
|
for (EmindEnergyChainDto remote : remoteChains) {
|
chains.add(toEntity(station, remote, syncedAt));
|
}
|
}
|
}
|
chainMapper.markAllDeleted(syncedAt);
|
if (!chains.isEmpty()) {
|
chainMapper.upsertBatch(chains);
|
}
|
return chains.size();
|
}
|
|
private EmindEnergyChain toEntity(EmindStation station,
|
EmindEnergyChainDto source,
|
LocalDateTime syncedAt) {
|
EmindEnergyChain target = new EmindEnergyChain();
|
target.setStationLocalId(station.getId());
|
target.setStationId(station.getStationId());
|
target.setStationName(station.getName());
|
target.setElinkId(source.getElinkId());
|
target.setUuid(source.getUuid());
|
target.setElinkName(source.getElinkName());
|
target.setTotalActivePower(source.getTotalActivePower());
|
target.setTotalReactivePower(source.getTotalReactivePower());
|
target.setMaxChargePower(source.getMaxChargePower());
|
target.setMaxDischargePower(source.getMaxDischargePower());
|
target.setPhaseACurrent(source.getPhaseACurrent());
|
target.setPhaseBCurrent(source.getPhaseBCurrent());
|
target.setPhaseCCurrent(source.getPhaseCCurrent());
|
target.setDischargeableEnergy(source.getDischargeableEnergy());
|
target.setSoc(source.getSoc());
|
target.setChargedEnergyToday(source.getChargedEnergyToday());
|
target.setDischargedEnergyToday(source.getDischargedEnergyToday());
|
target.setRecordTime(source.getRecordTime());
|
target.setSourceType(EmindEnergyChain.SOURCE_REMOTE);
|
target.setManagementDeleted(0);
|
target.setDelFlag(0);
|
target.setSyncedAt(syncedAt);
|
return target;
|
}
|
}
|
