数据同步方法实现

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/StationDataTaskImpl.java

+package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.jxiop.api.dto.DeviceDto;
+import com.yeejoin.amos.boot.module.jxiop.api.dto.IndexDto;
+import com.yeejoin.amos.boot.module.jxiop.api.dto.StationTaksDto;
+import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
+import com.yeejoin.amos.boot.module.jxiop.api.service.IStationDataTask;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.SjglZsjZsbtz;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.TpriDmpDatabook;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class StationDataTaskImpl implements IStationDataTask {
+    @Autowired
+    StationBasicServiceImpl stationBasicServiceImpl;
+
+    @Autowired
+    SjglZsjZsbtzServiceImpl sjglZsjZsbtzServiceImpl;
+
+    @Autowired
+    TpriDmpDatabookServiceImpl tpriDmpDatabookServiceImpl;
+
+    @Override
+    public List<StationTaksDto> getListStationBasic() {
+        List<StationTaksDto> stationTaksDtoList = new ArrayList<>();
+        List<StationBasic> stationBasicList= stationBasicServiceImpl.list();
+        stationBasicList.forEach(stationBasic -> {
+            StationTaksDto stationTaksDto = new StationTaksDto();
+            stationTaksDto.setStationNumber(stationBasic.getStationNumber());
+            stationTaksDto.setGateway(stationBasic.getGatewayId());
+            stationTaksDtoList.add(stationTaksDto);
+        });
+        return stationTaksDtoList;
+    }
+
+    @Override
+    public List<DeviceDto> getListDevice(StationTaksDto stationTaksDto) {
+        List<DeviceDto> deviceDtoList =   new ArrayList<>();
+        TpriDmpDatabook tpriDmpDatabook =  tpriDmpDatabookServiceImpl.getTpriDmpDatabookByDataName("风机");
+        List<SjglZsjZsbtz> sjglZsjZsbtzList  = sjglZsjZsbtzServiceImpl .getSjglZsjZsbtzList(tpriDmpDatabook.getDataid(),stationTaksDto.getStationNumber());
+        sjglZsjZsbtzList.forEach(sjglZsjZsbtz -> {
+            DeviceDto deviceDto = new DeviceDto();
+            deviceDto.setGateway(stationTaksDto.getGateway());
+            deviceDto.setNumberName("");
+        });
+        return deviceDtoList;
+    }
+
+    @Override
+    public List<IndexDto> getIndexDto(DeviceDto deviceDto) {
+        return null;
+    }
+
+    @Override
+    public void setMonitorFanIndicator(List<IndexDto> list) {
+
+    }
+}