|
|
|
@ -12,6 +12,9 @@ import com.thing.qingyuan.chargeStation.service.EquipmentInfoService; |
|
|
|
import com.thing.qingyuan.chargeStation.service.StationInfoService; |
|
|
|
import com.thing.qingyuan.screen.*; |
|
|
|
import com.thing.qingyuan.screen.service.StationScreenService; |
|
|
|
import com.thing.sys.security.context.UserContext; |
|
|
|
import com.thing.thing.entity.dto.IotThingEntityDTO; |
|
|
|
import com.thing.thing.entity.service.IotThingEntityService; |
|
|
|
import lombok.RequiredArgsConstructor; |
|
|
|
import org.apache.commons.collections4.CollectionUtils; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
@ -30,6 +33,7 @@ import java.util.stream.IntStream; |
|
|
|
@RequiredArgsConstructor |
|
|
|
public class StationScreenServiceImpl implements StationScreenService { |
|
|
|
private final TsKvService tsKvService; |
|
|
|
private final IotThingEntityService thingEntityService; |
|
|
|
private final StationInfoService stationInfoService; |
|
|
|
private final EquipmentInfoService equipmentInfoService; |
|
|
|
private final ConnectorInfoService connectorInfoService; |
|
|
|
@ -74,6 +78,7 @@ public class StationScreenServiceImpl implements StationScreenService { |
|
|
|
@Override |
|
|
|
public StationDailyInfo getDailyInfo(String thingCode) { |
|
|
|
StationInfoEntity station = stationInfoService.getById(thingCode); |
|
|
|
Optional<IotThingEntityDTO> entityByCode = thingEntityService.findEntityByCode(thingCode, UserContext.getRealTenantCode(), true); |
|
|
|
List<EquipmentInfoDTO> pileList = equipmentInfoService.getByStationId(thingCode); |
|
|
|
EquipmentInfoDTO summedPile = pileList.stream().reduce(EquipmentInfoDTO::add).orElse(null); |
|
|
|
List<TsKvDTO> tskvList = |
|
|
|
@ -84,6 +89,7 @@ public class StationScreenServiceImpl implements StationScreenService { |
|
|
|
System.currentTimeMillis(), |
|
|
|
true); |
|
|
|
StationDailyInfo stationDailyInfo = StationDailyInfo.assemble(station, summedPile, tskvList); |
|
|
|
entityByCode.ifPresent(entityDTO -> stationDailyInfo.setUrl(entityDTO.getImg())); |
|
|
|
return stationDailyInfo.setEquipmentNum(CollectionUtils.size(pileList)); |
|
|
|
} |
|
|
|
|
|
|
|
|