|
@@ -18,11 +18,15 @@ import com.jiayue.ipp.common.data.entity.*;
|
|
import lombok.Data;
|
|
import lombok.Data;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.io.FileUtils;
|
|
import org.apache.commons.io.FileUtils;
|
|
|
|
+import org.springframework.scheduling.annotation.Async;
|
|
|
|
+import org.springframework.scheduling.annotation.EnableAsync;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.io.*;
|
|
import java.io.*;
|
|
import java.text.SimpleDateFormat;
|
|
import java.text.SimpleDateFormat;
|
|
|
|
+import java.time.LocalDate;
|
|
|
|
+import java.time.LocalDateTime;
|
|
import java.time.ZoneId;
|
|
import java.time.ZoneId;
|
|
import java.util.*;
|
|
import java.util.*;
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
@@ -36,6 +40,7 @@ import java.util.stream.Collectors;
|
|
*/
|
|
*/
|
|
@Service
|
|
@Service
|
|
@Slf4j
|
|
@Slf4j
|
|
|
|
+@EnableAsync
|
|
public class GenerateBackPassDataService {
|
|
public class GenerateBackPassDataService {
|
|
private final WindPowerReal15MinFD0001Service windPowerReal15MinFD0001Service;
|
|
private final WindPowerReal15MinFD0001Service windPowerReal15MinFD0001Service;
|
|
|
|
|
|
@@ -51,6 +56,10 @@ public class GenerateBackPassDataService {
|
|
|
|
|
|
private final WindPowerReal15MinFD0007Service windPowerReal15MinFD0007Service;
|
|
private final WindPowerReal15MinFD0007Service windPowerReal15MinFD0007Service;
|
|
|
|
|
|
|
|
+ private final WindPowerReal15MinFD0029Service windPowerReal15MinFD0029Service;
|
|
|
|
+
|
|
|
|
+ private final WindPowerReal15MinFD0030Service windPowerReal15MinFD0030Service;
|
|
|
|
+
|
|
private static final String IMAGE_TYPE = "jpg";
|
|
private static final String IMAGE_TYPE = "jpg";
|
|
private static final String PLACE = "-0.99|";
|
|
private static final String PLACE = "-0.99|";
|
|
private static final Long oneDay = 3600 * 24 * 1000L - 1000L;
|
|
private static final Long oneDay = 3600 * 24 * 1000L - 1000L;
|
|
@@ -70,6 +79,10 @@ public class GenerateBackPassDataService {
|
|
|
|
|
|
private final JiaYueWindPowerDqResultCoverFD0007Service jiaYueWindPowerDqResultCoverFD0007Service;
|
|
private final JiaYueWindPowerDqResultCoverFD0007Service jiaYueWindPowerDqResultCoverFD0007Service;
|
|
|
|
|
|
|
|
+ private final JiaYueWindPowerDqResultCoverFD0029Service jiaYueWindPowerDqResultCoverFD0029Service;
|
|
|
|
+
|
|
|
|
+ private final JiaYueWindPowerDqResultCoverFD0030Service jiaYueWindPowerDqResultCoverFD0030Service;
|
|
|
|
+
|
|
private final JiaYueWindPowerCdqResultCoverFD0001Service jiaYueWindPowerCdqResultCoverFD0001Service;
|
|
private final JiaYueWindPowerCdqResultCoverFD0001Service jiaYueWindPowerCdqResultCoverFD0001Service;
|
|
|
|
|
|
private final JiaYueWindPowerCdqResultCoverFD0002Service jiaYueWindPowerCdqResultCoverFD0002Service;
|
|
private final JiaYueWindPowerCdqResultCoverFD0002Service jiaYueWindPowerCdqResultCoverFD0002Service;
|
|
@@ -84,13 +97,16 @@ public class GenerateBackPassDataService {
|
|
|
|
|
|
private final JiaYueWindPowerCdqResultCoverFD0007Service jiaYueWindPowerCdqResultCoverFD0007Service;
|
|
private final JiaYueWindPowerCdqResultCoverFD0007Service jiaYueWindPowerCdqResultCoverFD0007Service;
|
|
|
|
|
|
|
|
+ private final JiaYueWindPowerCdqResultCoverFD0029Service jiaYueWindPowerCdqResultCoverFD0029Service;
|
|
|
|
+
|
|
|
|
+ private final JiaYueWindPowerCdqResultCoverFD0030Service jiaYueWindPowerCdqResultCoverFD0030Service;
|
|
|
|
|
|
public GenerateBackPassDataService(WindPowerReal15MinFD0001Service windPowerReal15MinFD0001Service,WindPowerReal15MinFD0002Service windPowerReal15MinFD0002Service,WindPowerReal15MinFD0003Service windPowerReal15MinFD0003Service,WindPowerReal15MinFD0004Service windPowerReal15MinFD0004Service,WindPowerReal15MinFD0005Service windPowerReal15MinFD0005Service,
|
|
public GenerateBackPassDataService(WindPowerReal15MinFD0001Service windPowerReal15MinFD0001Service,WindPowerReal15MinFD0002Service windPowerReal15MinFD0002Service,WindPowerReal15MinFD0003Service windPowerReal15MinFD0003Service,WindPowerReal15MinFD0004Service windPowerReal15MinFD0004Service,WindPowerReal15MinFD0005Service windPowerReal15MinFD0005Service,
|
|
- WindPowerReal15MinFD0006Service windPowerReal15MinFD0006Service,WindPowerReal15MinFD0007Service windPowerReal15MinFD0007Service,JiaYueWindPowerDqResultCoverFD0001Service jiaYueWindPowerDqResultCoverFD0001Service,JiaYueWindPowerDqResultCoverFD0002Service jiaYueWindPowerDqResultCoverFD0002Service,
|
|
|
|
|
|
+ WindPowerReal15MinFD0006Service windPowerReal15MinFD0006Service,WindPowerReal15MinFD0007Service windPowerReal15MinFD0007Service,WindPowerReal15MinFD0029Service windPowerReal15MinFD0029Service,WindPowerReal15MinFD0030Service windPowerReal15MinFD0030Service,JiaYueWindPowerDqResultCoverFD0001Service jiaYueWindPowerDqResultCoverFD0001Service,JiaYueWindPowerDqResultCoverFD0002Service jiaYueWindPowerDqResultCoverFD0002Service,
|
|
JiaYueWindPowerDqResultCoverFD0003Service jiaYueWindPowerDqResultCoverFD0003Service,JiaYueWindPowerDqResultCoverFD0004Service jiaYueWindPowerDqResultCoverFD0004Service,JiaYueWindPowerDqResultCoverFD0005Service jiaYueWindPowerDqResultCoverFD0005Service,JiaYueWindPowerDqResultCoverFD0006Service jiaYueWindPowerDqResultCoverFD0006Service,
|
|
JiaYueWindPowerDqResultCoverFD0003Service jiaYueWindPowerDqResultCoverFD0003Service,JiaYueWindPowerDqResultCoverFD0004Service jiaYueWindPowerDqResultCoverFD0004Service,JiaYueWindPowerDqResultCoverFD0005Service jiaYueWindPowerDqResultCoverFD0005Service,JiaYueWindPowerDqResultCoverFD0006Service jiaYueWindPowerDqResultCoverFD0006Service,
|
|
- JiaYueWindPowerDqResultCoverFD0007Service jiaYueWindPowerDqResultCoverFD0007Service,JiaYueWindPowerCdqResultCoverFD0001Service jiaYueWindPowerCdqResultCoverFD0001Service,JiaYueWindPowerCdqResultCoverFD0002Service jiaYueWindPowerCdqResultCoverFD0002Service,
|
|
|
|
|
|
+ JiaYueWindPowerDqResultCoverFD0007Service jiaYueWindPowerDqResultCoverFD0007Service,JiaYueWindPowerDqResultCoverFD0029Service jiaYueWindPowerDqResultCoverFD0029Service,JiaYueWindPowerDqResultCoverFD0030Service jiaYueWindPowerDqResultCoverFD0030Service,JiaYueWindPowerCdqResultCoverFD0001Service jiaYueWindPowerCdqResultCoverFD0001Service,JiaYueWindPowerCdqResultCoverFD0002Service jiaYueWindPowerCdqResultCoverFD0002Service,
|
|
JiaYueWindPowerCdqResultCoverFD0003Service jiaYueWindPowerCdqResultCoverFD0003Service,JiaYueWindPowerCdqResultCoverFD0004Service jiaYueWindPowerCdqResultCoverFD0004Service,JiaYueWindPowerCdqResultCoverFD0005Service jiaYueWindPowerCdqResultCoverFD0005Service,JiaYueWindPowerCdqResultCoverFD0006Service jiaYueWindPowerCdqResultCoverFD0006Service,
|
|
JiaYueWindPowerCdqResultCoverFD0003Service jiaYueWindPowerCdqResultCoverFD0003Service,JiaYueWindPowerCdqResultCoverFD0004Service jiaYueWindPowerCdqResultCoverFD0004Service,JiaYueWindPowerCdqResultCoverFD0005Service jiaYueWindPowerCdqResultCoverFD0005Service,JiaYueWindPowerCdqResultCoverFD0006Service jiaYueWindPowerCdqResultCoverFD0006Service,
|
|
- JiaYueWindPowerCdqResultCoverFD0007Service jiaYueWindPowerCdqResultCoverFD0007Service){
|
|
|
|
|
|
+ JiaYueWindPowerCdqResultCoverFD0007Service jiaYueWindPowerCdqResultCoverFD0007Service,JiaYueWindPowerCdqResultCoverFD0029Service jiaYueWindPowerCdqResultCoverFD0029Service,JiaYueWindPowerCdqResultCoverFD0030Service jiaYueWindPowerCdqResultCoverFD0030Service){
|
|
this.windPowerReal15MinFD0001Service = windPowerReal15MinFD0001Service;
|
|
this.windPowerReal15MinFD0001Service = windPowerReal15MinFD0001Service;
|
|
this.windPowerReal15MinFD0002Service = windPowerReal15MinFD0002Service;
|
|
this.windPowerReal15MinFD0002Service = windPowerReal15MinFD0002Service;
|
|
this.windPowerReal15MinFD0003Service = windPowerReal15MinFD0003Service;
|
|
this.windPowerReal15MinFD0003Service = windPowerReal15MinFD0003Service;
|
|
@@ -98,6 +114,8 @@ public class GenerateBackPassDataService {
|
|
this.windPowerReal15MinFD0005Service = windPowerReal15MinFD0005Service;
|
|
this.windPowerReal15MinFD0005Service = windPowerReal15MinFD0005Service;
|
|
this.windPowerReal15MinFD0006Service = windPowerReal15MinFD0006Service;
|
|
this.windPowerReal15MinFD0006Service = windPowerReal15MinFD0006Service;
|
|
this.windPowerReal15MinFD0007Service = windPowerReal15MinFD0007Service;
|
|
this.windPowerReal15MinFD0007Service = windPowerReal15MinFD0007Service;
|
|
|
|
+ this.windPowerReal15MinFD0029Service = windPowerReal15MinFD0029Service;
|
|
|
|
+ this.windPowerReal15MinFD0030Service = windPowerReal15MinFD0030Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0001Service = jiaYueWindPowerDqResultCoverFD0001Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0001Service = jiaYueWindPowerDqResultCoverFD0001Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0002Service = jiaYueWindPowerDqResultCoverFD0002Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0002Service = jiaYueWindPowerDqResultCoverFD0002Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0003Service = jiaYueWindPowerDqResultCoverFD0003Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0003Service = jiaYueWindPowerDqResultCoverFD0003Service;
|
|
@@ -105,6 +123,8 @@ public class GenerateBackPassDataService {
|
|
this.jiaYueWindPowerDqResultCoverFD0005Service = jiaYueWindPowerDqResultCoverFD0005Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0005Service = jiaYueWindPowerDqResultCoverFD0005Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0006Service = jiaYueWindPowerDqResultCoverFD0006Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0006Service = jiaYueWindPowerDqResultCoverFD0006Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0007Service = jiaYueWindPowerDqResultCoverFD0007Service;
|
|
this.jiaYueWindPowerDqResultCoverFD0007Service = jiaYueWindPowerDqResultCoverFD0007Service;
|
|
|
|
+ this.jiaYueWindPowerDqResultCoverFD0029Service = jiaYueWindPowerDqResultCoverFD0029Service;
|
|
|
|
+ this.jiaYueWindPowerDqResultCoverFD0030Service = jiaYueWindPowerDqResultCoverFD0030Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0001Service = jiaYueWindPowerCdqResultCoverFD0001Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0001Service = jiaYueWindPowerCdqResultCoverFD0001Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0002Service = jiaYueWindPowerCdqResultCoverFD0002Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0002Service = jiaYueWindPowerCdqResultCoverFD0002Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0003Service = jiaYueWindPowerCdqResultCoverFD0003Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0003Service = jiaYueWindPowerCdqResultCoverFD0003Service;
|
|
@@ -112,284 +132,121 @@ public class GenerateBackPassDataService {
|
|
this.jiaYueWindPowerCdqResultCoverFD0004Service = jiaYueWindPowerCdqResultCoverFD0004Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0004Service = jiaYueWindPowerCdqResultCoverFD0004Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0006Service = jiaYueWindPowerCdqResultCoverFD0006Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0006Service = jiaYueWindPowerCdqResultCoverFD0006Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0007Service = jiaYueWindPowerCdqResultCoverFD0007Service;
|
|
this.jiaYueWindPowerCdqResultCoverFD0007Service = jiaYueWindPowerCdqResultCoverFD0007Service;
|
|
|
|
+ this.jiaYueWindPowerCdqResultCoverFD0029Service = jiaYueWindPowerCdqResultCoverFD0029Service;
|
|
|
|
+ this.jiaYueWindPowerCdqResultCoverFD0030Service = jiaYueWindPowerCdqResultCoverFD0030Service;
|
|
}
|
|
}
|
|
|
|
+
|
|
/**
|
|
/**
|
|
- * 生成实际功率json文件
|
|
|
|
|
|
+ * 每天凌晨一点零五分生成回传短期、超短期。实际功率数据
|
|
|
|
+ * @return
|
|
*/
|
|
*/
|
|
-// @Scheduled(cron = "0 48 1 * * ?")
|
|
|
|
-// public void genRealPowerDataJsonFile() {
|
|
|
|
-//
|
|
|
|
-// long time = System.currentTimeMillis() - 86400000l;
|
|
|
|
-// // 获取startTime和endTime
|
|
|
|
-// Date startTime = DateTimeUtil.getDayStartTime(time);
|
|
|
|
-// Date endTime = DateTimeUtil.getDayLastTime(time);
|
|
|
|
-//
|
|
|
|
-// List list = new ArrayList();
|
|
|
|
-// list.add("FD0001");
|
|
|
|
-// list.add("FD0002");
|
|
|
|
-// list.add("FD0003");
|
|
|
|
-// list.add("FD0005");
|
|
|
|
-// list.add("FD0006");
|
|
|
|
-// list.add("FD0007");
|
|
|
|
-//
|
|
|
|
-// List<ElectricField> electricFieldList = new ArrayList<>();
|
|
|
|
-// ElectricField electricField1 = new ElectricField();
|
|
|
|
-// electricField1.setBelongForecastManufactor("SYJY");
|
|
|
|
-// electricField1.setCapacity(new BigDecimal(30.0000));
|
|
|
|
-// electricField1.setElectricFieldTypeEnum("2");
|
|
|
|
-// electricField1.setForecastManufactor("SYJY");
|
|
|
|
-// electricField1.setId("138c6aebdf6ddc792495bc35fa3e4adb");
|
|
|
|
-// electricField1.setName("天津中能融合测试站A");
|
|
|
|
-// electricField1.setStationCode("J00770");
|
|
|
|
-// electricField1.setSign("FD0001");
|
|
|
|
-// electricField1.setNetSubstationName("J00770");
|
|
|
|
-//
|
|
|
|
-// ElectricField electricField2 = new ElectricField();
|
|
|
|
-// electricField2.setBelongForecastManufactor("SYJY");
|
|
|
|
-// electricField2.setCapacity(new BigDecimal(12.0000));
|
|
|
|
-// electricField2.setElectricFieldTypeEnum("2");
|
|
|
|
-// electricField2.setForecastManufactor("SYJY");
|
|
|
|
-// electricField2.setId("30a9f02678beb7101e628d7c7e22c5d6");
|
|
|
|
-// electricField2.setName("天津中能融合测试站C");
|
|
|
|
-// electricField2.setStationCode("J00942");
|
|
|
|
-// electricField2.setSign("FD0003");
|
|
|
|
-// electricField2.setNetSubstationName("J00942");
|
|
|
|
-//
|
|
|
|
-// ElectricField electricField3 = new ElectricField();
|
|
|
|
-// electricField3.setBelongForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setCapacity(new BigDecimal(20.0000));
|
|
|
|
-// electricField3.setElectricFieldTypeEnum("2");
|
|
|
|
-// electricField2.setForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setId("d712c1ef348714a5afafcf130c256cc9");
|
|
|
|
-// electricField3.setName("中能融合测试站B");
|
|
|
|
-// electricField3.setStationCode("J00941");
|
|
|
|
-// electricField3.setSign("FD0002");
|
|
|
|
-// electricField3.setNetSubstationName("J00941");
|
|
|
|
-//
|
|
|
|
-// ElectricField electricField5 = new ElectricField();
|
|
|
|
-// electricField3.setBelongForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setCapacity(new BigDecimal(99.0000));
|
|
|
|
-// electricField3.setElectricFieldTypeEnum("2");
|
|
|
|
-// electricField2.setForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setId("d712c1ef348714a5afafcf130c256cc5");
|
|
|
|
-// electricField3.setName("内蒙古中能融合测试站E");
|
|
|
|
-// electricField3.setStationCode("J00929");
|
|
|
|
-// electricField3.setSign("FD0005");
|
|
|
|
-// electricField3.setNetSubstationName("J00929");
|
|
|
|
-//
|
|
|
|
-// ElectricField electricField6 = new ElectricField();
|
|
|
|
-// electricField3.setBelongForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setCapacity(new BigDecimal(50.0000));
|
|
|
|
-// electricField3.setElectricFieldTypeEnum("2");
|
|
|
|
-// electricField2.setForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setId("d712c1ef348714a5afafcf130c256cc6");
|
|
|
|
-// electricField3.setName("河南中能融合测试站F");
|
|
|
|
-// electricField3.setStationCode("J00930");
|
|
|
|
-// electricField3.setSign("FD0006");
|
|
|
|
-// electricField3.setNetSubstationName("J00930");
|
|
|
|
-//
|
|
|
|
-// ElectricField electricField7 = new ElectricField();
|
|
|
|
-// electricField3.setBelongForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setCapacity(new BigDecimal(50.0000));
|
|
|
|
-// electricField3.setElectricFieldTypeEnum("2");
|
|
|
|
-// electricField2.setForecastManufactor("SYJY");
|
|
|
|
-// electricField3.setId("d712c1ef348714a5afafcf130c256cc7");
|
|
|
|
-// electricField3.setName("天津中能融合测试站F");
|
|
|
|
-// electricField3.setStationCode("J00931");
|
|
|
|
-// electricField3.setSign("FD0007");
|
|
|
|
-// electricField3.setNetSubstationName("J00931");
|
|
|
|
-//
|
|
|
|
-// electricFieldList.add(electricField1);
|
|
|
|
-// electricFieldList.add(electricField2);
|
|
|
|
-// electricFieldList.add(electricField3);
|
|
|
|
-// electricFieldList.add(electricField5);
|
|
|
|
-// electricFieldList.add(electricField6);
|
|
|
|
-// electricFieldList.add(electricField7);
|
|
|
|
-//
|
|
|
|
-// List<WindPowerReal15MinFD0001> windPowerReal15MinFD0001List = windPowerReal15MinFD0001Service.getAll(startTime, endTime);
|
|
|
|
-// List<WindPowerReal15MinFD0002> windPowerReal15MinFD0002List = windPowerReal15MinFD0002Service.getAll(startTime, endTime);
|
|
|
|
-// List<WindPowerReal15MinFD0003> windPowerReal15MinFD0003List = windPowerReal15MinFD0003Service.getAll(startTime, endTime);
|
|
|
|
-// List<WindPowerReal15MinFD0005> windPowerReal15MinFD0005List = windPowerReal15MinFD0005Service.getAll(startTime, endTime);
|
|
|
|
-// List<WindPowerReal15MinFD0006> windPowerReal15MinFD0006List = windPowerReal15MinFD0006Service.getAll(startTime, endTime);
|
|
|
|
-// List<WindPowerReal15MinFD0007> windPowerReal15MinFD0007List = windPowerReal15MinFD0007Service.getAll(startTime, endTime);
|
|
|
|
-// // 根据电站编号查询对应实际功率
|
|
|
|
-// for (int i = 0; i < list.size(); i++) {
|
|
|
|
-//
|
|
|
|
-// for (ElectricField electricField : electricFieldList) {
|
|
|
|
-// // 判断场站标识是否跟数据库中的场站id相同
|
|
|
|
-// String zxglPath = sysParameterService.getSysParameterAndStationCode("zxgl_config", "", electricField.getStationCode());
|
|
|
|
-//
|
|
|
|
-// if (!zxglPath.equals("")) {
|
|
|
|
-// FileOutputStream fileOutputStream = null;
|
|
|
|
-// try {
|
|
|
|
-// log.info("开始生成【{}】实际功率json文件", electricField.getStationCode());
|
|
|
|
-// String content = electricField.getStationCode() + "|" + startTime.getTime() + "|rp|";
|
|
|
|
-// //为了确保无数据缺失,遍历时间
|
|
|
|
-// long sTimeL = startTime.getTime();
|
|
|
|
-// long eTimeL = endTime.getTime();
|
|
|
|
-// for (long m = sTimeL; m < eTimeL; m += 900000l) {
|
|
|
|
-// long finalI = m;
|
|
|
|
-// List<? extends Serializable> filterList = new ArrayList<>();
|
|
|
|
-// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0001")) {
|
|
|
|
-// filterList = windPowerReal15MinFD0001List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-// }
|
|
|
|
-// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0002")) {
|
|
|
|
-// filterList = windPowerReal15MinFD0002List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-// }
|
|
|
|
-// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0003")) {
|
|
|
|
-// filterList = windPowerReal15MinFD0003List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-// }
|
|
|
|
-// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0005")) {
|
|
|
|
-// filterList = windPowerReal15MinFD0005List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-// }
|
|
|
|
-// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0006")) {
|
|
|
|
-// filterList = windPowerReal15MinFD0006List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-// }
|
|
|
|
-// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0007")) {
|
|
|
|
-// filterList = windPowerReal15MinFD0007List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-// }
|
|
|
|
-// if (filterList != null && filterList.size() > 0) {
|
|
|
|
-// try {
|
|
|
|
-// Method getValueMethod = filterList.get(0).getClass().getMethod("getValue");
|
|
|
|
-// Object value = getValueMethod.invoke(filterList.get(0));
|
|
|
|
-// content = content + value.toString() + "|";
|
|
|
|
-// } catch (NoSuchMethodException e) {
|
|
|
|
-// throw new RuntimeException(e);
|
|
|
|
-// } catch (IllegalAccessException e) {
|
|
|
|
-// throw new RuntimeException(e);
|
|
|
|
-// } catch (InvocationTargetException e) {
|
|
|
|
-// throw new RuntimeException(e);
|
|
|
|
-// }
|
|
|
|
-//
|
|
|
|
-// } else {
|
|
|
|
-// content = content + "-0.99|";
|
|
|
|
-// }
|
|
|
|
-//
|
|
|
|
-// }
|
|
|
|
-// for (int j = 0; j < 96; j++) {
|
|
|
|
-// content = content + "-0.99|";
|
|
|
|
-// }
|
|
|
|
-// String zipContent = GzipUtil.zip(content).replace("\r\n", "");
|
|
|
|
-//
|
|
|
|
-// String taskNo = getTaskNo(electricField);
|
|
|
|
-//
|
|
|
|
-// JSONObject jsonObject = new JSONObject();
|
|
|
|
-// jsonObject.putOnce("taskNo", taskNo);
|
|
|
|
-// jsonObject.putOnce("taskType", "stationData-rp");
|
|
|
|
-// jsonObject.putOnce("partNo", 1);
|
|
|
|
-// jsonObject.putOnce("partTotal", 1);
|
|
|
|
-// jsonObject.putOnce("data", zipContent);
|
|
|
|
-//
|
|
|
|
-// String qrCodeContent = jsonObject.toString();
|
|
|
|
-//
|
|
|
|
-// String fileName = electricField.getStationCode() + "-" + DateFormatUtils.format(new Date(), "yyyyMMddHHmm") + "-realpower.json";
|
|
|
|
|
|
+ @Scheduled(cron = "0 50 11 * * *")
|
|
|
|
+ @Async
|
|
|
|
+ public Map<String, Object> generateQRCode() {
|
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
|
+ try {
|
|
|
|
+ List<ElectricField> electricFieldList = new ArrayList<>();
|
|
|
|
+ ElectricField electricField = new ElectricField();
|
|
|
|
+ electricField.setStationCode("J00770");
|
|
|
|
+ electricField.setSign("FD0001");
|
|
|
|
+
|
|
|
|
+ ElectricField electricField2 = new ElectricField();
|
|
|
|
+ electricField2.setStationCode("J00941");
|
|
|
|
+ electricField2.setSign("FD0002");
|
|
|
|
+
|
|
|
|
+ ElectricField electricField3 = new ElectricField();
|
|
|
|
+ electricField3.setStationCode("J00942");
|
|
|
|
+ electricField3.setSign("FD0003");
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ // 新增宁夏吴忠石窖沟电站
|
|
|
|
+ ElectricField electricField4 = new ElectricField();
|
|
|
|
+ electricField4.setStationCode("J00988");
|
|
|
|
+ electricField4.setSign("FD0004");
|
|
|
|
+
|
|
|
|
+ ElectricField electricField5 = new ElectricField();
|
|
|
|
+ electricField5.setStationCode("J00929");
|
|
|
|
+ electricField5.setSign("FD0005");
|
|
|
|
+
|
|
|
|
+ ElectricField electricField6 = new ElectricField();
|
|
|
|
+ electricField6.setStationCode("J00930");
|
|
|
|
+ electricField6.setSign("FD0006");
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ ElectricField electricField7 = new ElectricField();
|
|
|
|
+ electricField7.setStationCode("J00931");
|
|
|
|
+ electricField7.setSign("FD0007");
|
|
|
|
+
|
|
|
|
+ ElectricField electricField29 = new ElectricField();
|
|
|
|
+ electricField29.setStationCode("J01034");
|
|
|
|
+ electricField29.setSign("FD0029");
|
|
|
|
+
|
|
|
|
+ ElectricField electricField30 = new ElectricField();
|
|
|
|
+ electricField30.setStationCode("J01033");
|
|
|
|
+ electricField30.setSign("FD0030");
|
|
|
|
+
|
|
|
|
+ electricFieldList.add(electricField);
|
|
|
|
+ electricFieldList.add(electricField2);
|
|
|
|
+ electricFieldList.add(electricField3);
|
|
|
|
+ electricFieldList.add(electricField4);
|
|
|
|
+ electricFieldList.add(electricField5);
|
|
|
|
+ electricFieldList.add(electricField6);
|
|
|
|
+ electricFieldList.add(electricField7);
|
|
|
|
+ electricFieldList.add(electricField29);
|
|
|
|
+ electricFieldList.add(electricField30);
|
|
//
|
|
//
|
|
-// File file = new File(zxglPath + File.separator + fileName);
|
|
|
|
|
|
+// // 开始日期和结束日期
|
|
|
|
+// LocalDate startDate = LocalDate.of(2024, 6, 11);
|
|
|
|
+// LocalDate endDate = LocalDate.of(2024, 6, 26);
|
|
//
|
|
//
|
|
-// fileOutputStream = new FileOutputStream(file);
|
|
|
|
-// fileOutputStream.write(qrCodeContent.getBytes(Charset.forName("utf-8")));
|
|
|
|
-// fileOutputStream.flush();
|
|
|
|
-// fileOutputStream.close();
|
|
|
|
|
|
+// // 存储结果的列表
|
|
|
|
+// List<Date> dateList = new ArrayList<>();
|
|
//
|
|
//
|
|
-// log.info("实际功率json文件【{}】生成成功", fileName);
|
|
|
|
-// } catch (IOException e) {
|
|
|
|
-// e.printStackTrace();
|
|
|
|
-// }
|
|
|
|
|
|
+// // 遍历日期范围
|
|
|
|
+// LocalDate currentDate = startDate;
|
|
|
|
+// while (!currentDate.isAfter(endDate)) {
|
|
|
|
+// // 获取当天的00:00
|
|
|
|
+// LocalDateTime startOfDay = currentDate.atStartOfDay();
|
|
//
|
|
//
|
|
-// }
|
|
|
|
|
|
+// // 转换为Date
|
|
|
|
+// Date startOfDayDate = Date.from(startOfDay.atZone(ZoneId.systemDefault()).toInstant());
|
|
//
|
|
//
|
|
-//// if (electricField.getSign().equals(list.get(i)) && list.get(i).equals("FD0003")) {
|
|
|
|
-//// String zxglPath = sysParameterService.getSysParameterAndStationCode("zxgl_config", "", electricField.getStationCode());
|
|
|
|
-////
|
|
|
|
-//// if (!zxglPath.equals("")) {
|
|
|
|
-//// FileOutputStream fileOutputStream = null;
|
|
|
|
-//// try {
|
|
|
|
-//// log.info("开始生成【{}】实际功率json文件", electricField.getStationCode());
|
|
|
|
-//// String content = electricField.getStationCode() + "|" + startTime.getTime() + "|rp|";
|
|
|
|
-//// //为了确保无数据缺失,遍历时间
|
|
|
|
-//// long sTimeL = startTime.getTime();
|
|
|
|
-//// long eTimeL = endTime.getTime();
|
|
|
|
-//// for (long m = sTimeL; m < eTimeL; m += 900000l) {
|
|
|
|
-//// long finalI = m;
|
|
|
|
-//// List<WindPowerReal15MinFD0003> filterList = windPowerReal15MinFD0003List.stream().filter(p -> Timestamp.valueOf(p.getDateTime()).getTime() == finalI).collect(Collectors.toList());
|
|
|
|
-////
|
|
|
|
-//// if (filterList != null && filterList.size() > 0) {
|
|
|
|
-//// content = content + filterList.get(0).getValue().toString() + "|";
|
|
|
|
-//// } else {
|
|
|
|
-//// content = content + "-0.99|";
|
|
|
|
-//// }
|
|
|
|
-////
|
|
|
|
-//// }
|
|
|
|
-//// for (int j = 0; j < 96; j++) {
|
|
|
|
-//// content = content + "-0.99|";
|
|
|
|
-//// }
|
|
|
|
-//// String zipContent = GzipUtil.zip(content).replace("\r\n", "");
|
|
|
|
-////
|
|
|
|
-//// String taskNo = getTaskNo(electricField);
|
|
|
|
-////
|
|
|
|
-//// JSONObject jsonObject = new JSONObject();
|
|
|
|
-//// jsonObject.putOnce("taskNo", taskNo);
|
|
|
|
-//// jsonObject.putOnce("taskType", "stationData-rp");
|
|
|
|
-//// jsonObject.putOnce("partNo", 1);
|
|
|
|
-//// jsonObject.putOnce("partTotal", 1);
|
|
|
|
-//// jsonObject.putOnce("data", zipContent);
|
|
|
|
-////
|
|
|
|
-//// String qrCodeContent = jsonObject.toString();
|
|
|
|
-////
|
|
|
|
-//// String fileName = electricField.getStationCode() + "-" + DateFormatUtils.format(new Date(), "yyyyMMddHHmm") + "-realpower.json";
|
|
|
|
-////
|
|
|
|
-//// File file = new File(zxglPath + File.separator + fileName);
|
|
|
|
-////
|
|
|
|
-//// fileOutputStream = new FileOutputStream(file);
|
|
|
|
-//// fileOutputStream.write(qrCodeContent.getBytes(Charset.forName("utf-8")));
|
|
|
|
-//// fileOutputStream.flush();
|
|
|
|
-//// fileOutputStream.close();
|
|
|
|
-////
|
|
|
|
-//// log.info("实际功率json文件【{}】生成成功", fileName);
|
|
|
|
-//// } catch (IOException e) {
|
|
|
|
-//// e.printStackTrace();
|
|
|
|
-//// }
|
|
|
|
-////
|
|
|
|
-//// }
|
|
|
|
-//// }
|
|
|
|
|
|
+// // 添加到列表中
|
|
|
|
+// dateList.add(startOfDayDate);
|
|
|
|
+// currentDate = currentDate.plusDays(1);
|
|
// }
|
|
// }
|
|
-// }
|
|
|
|
-//
|
|
|
|
-//
|
|
|
|
-// }
|
|
|
|
- @Scheduled(fixedRate = 60000L)
|
|
|
|
- public void realPowerForQr() {
|
|
|
|
-
|
|
|
|
- String zxglPath = "/home/syjy/huichuan";
|
|
|
|
-
|
|
|
|
- File zxglPathFile = new File(zxglPath + File.separator + "new");
|
|
|
|
|
|
|
|
- log.info("开始扫描正向隔离回传目录{}", zxglPathFile.getPath());
|
|
|
|
- String bakPath = zxglPath + File.separator + "bak";
|
|
|
|
- if (zxglPathFile.exists()) {
|
|
|
|
|
|
+// for (int i = 0; i < dateList.size(); i++) {
|
|
|
|
+ for (int j = 0; j < electricFieldList.size(); j++) {
|
|
|
|
+// map = generateQR(electricFieldList.get(j), dateList.get(i));
|
|
|
|
+ map = generateQR(electricFieldList.get(j));
|
|
|
|
+ toJson(map);
|
|
|
|
+ }
|
|
|
|
+// }
|
|
|
|
+ log.info("任务执行完成!");
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ log.error("生成二维码失败");
|
|
|
|
+ // 处理生成二维码失败的情况
|
|
|
|
+ }
|
|
|
|
+ return map;
|
|
|
|
+ }
|
|
|
|
|
|
- for (String s : zxglPathFile.list()) {
|
|
|
|
|
|
|
|
- List<String> list;
|
|
|
|
- File file = null;
|
|
|
|
- try {
|
|
|
|
- file = new File(zxglPathFile.getPath() + File.separator + s);
|
|
|
|
- list = EfileUtil.getFileContent(file);
|
|
|
|
- TaskResultRequestVO taskResultRequestVO = new TaskResultRequestVO();
|
|
|
|
- log.info("开始回传二维码数据,文件名:{}", file.getName());
|
|
|
|
- taskResultRequestVO.setTaskResult(String.join("", list));
|
|
|
|
- String url = "https://api.jiayuepowertech.com:8080/task/result";
|
|
|
|
- // 构造请求对象
|
|
|
|
- HttpRequest request = HttpRequest.put(url).body(JsonBeanUtil.beanToJson(taskResultRequestVO));
|
|
|
|
- // 发送请求并获取响应对象
|
|
|
|
- HttpResponse response = request.execute();
|
|
|
|
- log.info("回传二维码数据状态=》{}", response.body());
|
|
|
|
- FileUtils.moveFile(file, new File(bakPath + File.separator + file.getName()));
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- log.info("回传二维码数据失败,文件名:{}", file.getName());
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
|
|
+ public void prettyPrintJson(String json) {
|
|
|
|
+ try {
|
|
|
|
+ TaskResultRequestVO taskResultRequestVO = new TaskResultRequestVO();
|
|
|
|
+ log.info("开始回传二维码数据,文件名:{}");
|
|
|
|
+ taskResultRequestVO.setTaskResult(String.join("", json));
|
|
|
|
+ String url = "https://api.jiayuepowertech.com:8080/task/result";
|
|
|
|
+ // 构造请求对象
|
|
|
|
+ HttpRequest request = HttpRequest.put(url).body(JsonBeanUtil.beanToJson(taskResultRequestVO));
|
|
|
|
+ // 发送请求并获取响应对象
|
|
|
|
+ HttpResponse response = request.execute();
|
|
|
|
+ log.info("回传二维码数据状态=》{}", response.body());
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ log.info("回传二维码数据失败");
|
|
|
|
+ e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -430,7 +287,7 @@ public class GenerateBackPassDataService {
|
|
|
|
|
|
|
|
|
|
//短期
|
|
//短期
|
|
- List<String> st = generateShortTermContent(startTime.getTime(), endTime.getTime(), electricField);
|
|
|
|
|
|
+ List<String> st = generateShortTermContent(startTime.getTime()- 3600 * 24 * 1000L, endTime.getTime()- 3600 * 24 * 1000L, electricField);
|
|
//二维码名字
|
|
//二维码名字
|
|
StringBuilder name = new StringBuilder("E1短期");
|
|
StringBuilder name = new StringBuilder("E1短期");
|
|
dqMap.put(name.toString(), st);
|
|
dqMap.put(name.toString(), st);
|
|
@@ -473,14 +330,47 @@ public class GenerateBackPassDataService {
|
|
//T00003-rp|2023-04-14
|
|
//T00003-rp|2023-04-14
|
|
stringBuilder.append(electricField.getStationCode()).append("-").append("rp").append("|").append(sdf.format(startTime)).append("|");
|
|
stringBuilder.append(electricField.getStationCode()).append("-").append("rp").append("|").append(sdf.format(startTime)).append("|");
|
|
|
|
|
|
- List<WindPowerReal15MinFD0001> windPowerReal15MinFD0001List = windPowerReal15MinFD0001Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
- List<WindPowerReal15MinFD0002> windPowerReal15MinFD0002List = windPowerReal15MinFD0002Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
- List<WindPowerReal15MinFD0003> windPowerReal15MinFD0003List = windPowerReal15MinFD0003Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
- List<WindPowerReal15MinFD0004> windPowerReal15MinFD0004List = windPowerReal15MinFD0004Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
- List<WindPowerReal15MinFD0005> windPowerReal15MinFD0005List = windPowerReal15MinFD0005Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
- List<WindPowerReal15MinFD0006> windPowerReal15MinFD0006List = windPowerReal15MinFD0006Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
- List<WindPowerReal15MinFD0007> windPowerReal15MinFD0007List = windPowerReal15MinFD0007Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
-
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0001> windPowerReal15MinFD0001List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0002> windPowerReal15MinFD0002List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0003> windPowerReal15MinFD0003List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0004> windPowerReal15MinFD0004List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0005> windPowerReal15MinFD0005List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0006> windPowerReal15MinFD0006List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0007> windPowerReal15MinFD0007List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0029> windPowerReal15MinFD0029List = new ArrayList<>();
|
|
|
|
+ List<WindPowerReal15MinFD0030> windPowerReal15MinFD0030List = new ArrayList<>();
|
|
|
|
+
|
|
|
|
+ switch (electricField.getSign()){
|
|
|
|
+ case "FD0001":
|
|
|
|
+ windPowerReal15MinFD0001List = windPowerReal15MinFD0001Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0002":
|
|
|
|
+ windPowerReal15MinFD0002List = windPowerReal15MinFD0002Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0003":
|
|
|
|
+ windPowerReal15MinFD0003List = windPowerReal15MinFD0003Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0004":
|
|
|
|
+ windPowerReal15MinFD0004List = windPowerReal15MinFD0004Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0005":
|
|
|
|
+ windPowerReal15MinFD0005List = windPowerReal15MinFD0005Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0006":
|
|
|
|
+ windPowerReal15MinFD0006List = windPowerReal15MinFD0006Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0007":
|
|
|
|
+ windPowerReal15MinFD0007List = windPowerReal15MinFD0007Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0029":
|
|
|
|
+ windPowerReal15MinFD0029List = windPowerReal15MinFD0029Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0030":
|
|
|
|
+ windPowerReal15MinFD0030List = windPowerReal15MinFD0030Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
|
|
|
|
+ break;
|
|
|
|
+ default:
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
|
|
for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
|
|
for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
|
|
long finalTime = stepTime;
|
|
long finalTime = stepTime;
|
|
@@ -493,7 +383,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0002")) {
|
|
if (electricField.getSign().equals("FD0002")) {
|
|
- List<WindPowerReal15MinFD0002> filterList = windPowerReal15MinFD0002List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0002> filterList = windPowerReal15MinFD0002List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -501,7 +391,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0003")) {
|
|
if (electricField.getSign().equals("FD0003")) {
|
|
- List<WindPowerReal15MinFD0003> filterList = windPowerReal15MinFD0003List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0003> filterList = windPowerReal15MinFD0003List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -509,7 +399,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0004")) {
|
|
if (electricField.getSign().equals("FD0004")) {
|
|
- List<WindPowerReal15MinFD0004> filterList = windPowerReal15MinFD0004List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0004> filterList = windPowerReal15MinFD0004List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -517,7 +407,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0005")) {
|
|
if (electricField.getSign().equals("FD0005")) {
|
|
- List<WindPowerReal15MinFD0005> filterList = windPowerReal15MinFD0005List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0005> filterList = windPowerReal15MinFD0005List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -525,7 +415,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0006")) {
|
|
if (electricField.getSign().equals("FD0006")) {
|
|
- List<WindPowerReal15MinFD0006> filterList = windPowerReal15MinFD0006List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0006> filterList = windPowerReal15MinFD0006List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -533,13 +423,30 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0007")) {
|
|
if (electricField.getSign().equals("FD0007")) {
|
|
- List<WindPowerReal15MinFD0007> filterList = windPowerReal15MinFD0007List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<WindPowerReal15MinFD0007> filterList = windPowerReal15MinFD0007List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
|
|
+ if (!filterList.isEmpty()) {
|
|
|
|
+ content.append(filterList.get(0).getValue()).append("|");
|
|
|
|
+ } else {
|
|
|
|
+ content.append(PLACE);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (electricField.getSign().equals("FD0029")) {
|
|
|
|
+ List<WindPowerReal15MinFD0029> filterList = windPowerReal15MinFD0029List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
|
|
+ if (!filterList.isEmpty()) {
|
|
|
|
+ content.append(filterList.get(0).getActivePower()).append("|");
|
|
|
|
+ } else {
|
|
|
|
+ content.append(PLACE);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (electricField.getSign().equals("FD0030")) {
|
|
|
|
+ List<WindPowerReal15MinFD0030> filterList = windPowerReal15MinFD0030List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
content.append(filterList.get(0).getValue()).append("|");
|
|
} else {
|
|
} else {
|
|
content.append(PLACE);
|
|
content.append(PLACE);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+
|
|
}
|
|
}
|
|
|
|
|
|
stringBuilder.append(content);
|
|
stringBuilder.append(content);
|
|
@@ -578,7 +485,7 @@ public class GenerateBackPassDataService {
|
|
StringBuilder name = new StringBuilder("E1");
|
|
StringBuilder name = new StringBuilder("E1");
|
|
|
|
|
|
content.append(electricField.getStationCode()).append("-").append("st").append("-").append(name).append("|");
|
|
content.append(electricField.getStationCode()).append("-").append("st").append("-").append(name).append("|");
|
|
- List<Long> lDate = DateMomentUtil.getEveryDay(startTime, startTime + 24 * 60 * 60 * 1000 - 1000L);
|
|
|
|
|
|
+ List<Long> lDate = DateMomentUtil.getEveryDay(startTime+24 * 60 * 60 * 1000 , startTime + 48 * 60 * 60 * 1000 - 1000L);
|
|
for (int i = 0; i < lDate.size(); i++) {
|
|
for (int i = 0; i < lDate.size(); i++) {
|
|
content.append(sdf.format(lDate.get(i)));
|
|
content.append(sdf.format(lDate.get(i)));
|
|
if (i != lDate.size() - 1) {
|
|
if (i != lDate.size() - 1) {
|
|
@@ -588,14 +495,47 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0001> jiaYueWindPowerDqResultCoverFD0001List = jiaYueWindPowerDqResultCoverFD0001Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0002> jiaYueWindPowerDqResultCoverFD0002List = jiaYueWindPowerDqResultCoverFD0002Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0003> jiaYueWindPowerDqResultCoverFD0003List = jiaYueWindPowerDqResultCoverFD0003Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0004> jiaYueWindPowerDqResultCoverFD0004List = jiaYueWindPowerDqResultCoverFD0004Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0005> jiaYueWindPowerDqResultCoverFD0005List = jiaYueWindPowerDqResultCoverFD0005Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0006> jiaYueWindPowerDqResultCoverFD0006List = jiaYueWindPowerDqResultCoverFD0006Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerDqResultCoverFD0007> jiaYueWindPowerDqResultCoverFD0007List = jiaYueWindPowerDqResultCoverFD0007Service.findByDataDate(new Date(startTime));
|
|
|
|
-
|
|
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0001> jiaYueWindPowerDqResultCoverFD0001List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0002> jiaYueWindPowerDqResultCoverFD0002List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0003> jiaYueWindPowerDqResultCoverFD0003List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0004> jiaYueWindPowerDqResultCoverFD0004List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0005> jiaYueWindPowerDqResultCoverFD0005List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0006> jiaYueWindPowerDqResultCoverFD0006List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0007> jiaYueWindPowerDqResultCoverFD0007List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0029> jiaYueWindPowerDqResultCoverFD0029List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0030> jiaYueWindPowerDqResultCoverFD0030List = new ArrayList<>();
|
|
|
|
+
|
|
|
|
+ switch (electricField.getSign()){
|
|
|
|
+ case "FD0001":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0001List = jiaYueWindPowerDqResultCoverFD0001Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0002":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0002List = jiaYueWindPowerDqResultCoverFD0002Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0003":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0003List = jiaYueWindPowerDqResultCoverFD0003Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0004":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0004List = jiaYueWindPowerDqResultCoverFD0004Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0005":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0005List = jiaYueWindPowerDqResultCoverFD0005Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0006":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0006List = jiaYueWindPowerDqResultCoverFD0006Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0007":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0007List = jiaYueWindPowerDqResultCoverFD0007Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0029":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0029List = jiaYueWindPowerDqResultCoverFD0029Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0030":
|
|
|
|
+ jiaYueWindPowerDqResultCoverFD0030List = jiaYueWindPowerDqResultCoverFD0030Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ default:
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
|
|
for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
|
|
for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
|
|
long finalTime = stepTime;
|
|
long finalTime = stepTime;
|
|
@@ -608,7 +548,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0002")) {
|
|
if (electricField.getSign().equals("FD0002")) {
|
|
- List<JiaYueWindPowerDqResultCoverFD0002> filterList = jiaYueWindPowerDqResultCoverFD0002List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0002> filterList = jiaYueWindPowerDqResultCoverFD0002List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond()* 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -616,7 +556,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0003")) {
|
|
if (electricField.getSign().equals("FD0003")) {
|
|
- List<JiaYueWindPowerDqResultCoverFD0003> filterList = jiaYueWindPowerDqResultCoverFD0003List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0003> filterList = jiaYueWindPowerDqResultCoverFD0003List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond()* 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -655,6 +595,22 @@ public class GenerateBackPassDataService {
|
|
content.append(PLACE);
|
|
content.append(PLACE);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+ if (electricField.getSign().equals("FD0029")) {
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0029> filterList = jiaYueWindPowerDqResultCoverFD0029List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
|
|
+ if (!filterList.isEmpty()) {
|
|
|
|
+ content.append(filterList.get(0).getActivePower()).append("|");
|
|
|
|
+ } else {
|
|
|
|
+ content.append(PLACE);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (electricField.getSign().equals("FD0030")) {
|
|
|
|
+ List<JiaYueWindPowerDqResultCoverFD0030> filterList = jiaYueWindPowerDqResultCoverFD0030List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
|
|
+ if (!filterList.isEmpty()) {
|
|
|
|
+ content.append(filterList.get(0).getActivePower()).append("|");
|
|
|
|
+ } else {
|
|
|
|
+ content.append(PLACE);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -702,13 +658,47 @@ public class GenerateBackPassDataService {
|
|
content.append("|");
|
|
content.append("|");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- List<JiaYueWindPowerCdqResultCoverFD0001> jiaYueWindPowerCdqResultCoverFD0001List = jiaYueWindPowerCdqResultCoverFD0001Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerCdqResultCoverFD0002> jiaYueWindPowerCdqResultCoverFD0002List = jiaYueWindPowerCdqResultCoverFD0002Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerCdqResultCoverFD0003> jiaYueWindPowerCdqResultCoverFD0003List = jiaYueWindPowerCdqResultCoverFD0003Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerCdqResultCoverFD0004> jiaYueWindPowerCdqResultCoverFD0004List = jiaYueWindPowerCdqResultCoverFD0004Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerCdqResultCoverFD0005> jiaYueWindPowerCdqResultCoverFD0005List = jiaYueWindPowerCdqResultCoverFD0005Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerCdqResultCoverFD0006> jiaYueWindPowerCdqResultCoverFD0006List = jiaYueWindPowerCdqResultCoverFD0006Service.findByDataDate(new Date(startTime));
|
|
|
|
- List<JiaYueWindPowerCdqResultCoverFD0007> jiaYueWindPowerCdqResultCoverFD0007List = jiaYueWindPowerCdqResultCoverFD0007Service.findByDataDate(new Date(startTime));
|
|
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0001> jiaYueWindPowerCdqResultCoverFD0001List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0002> jiaYueWindPowerCdqResultCoverFD0002List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0003> jiaYueWindPowerCdqResultCoverFD0003List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0004> jiaYueWindPowerCdqResultCoverFD0004List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0005> jiaYueWindPowerCdqResultCoverFD0005List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0006> jiaYueWindPowerCdqResultCoverFD0006List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0007> jiaYueWindPowerCdqResultCoverFD0007List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0029> jiaYueWindPowerCdqResultCoverFD0029List = new ArrayList<>();
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0030> jiaYueWindPowerCdqResultCoverFD0030List = new ArrayList<>();
|
|
|
|
+
|
|
|
|
+ switch (electricField.getSign()){
|
|
|
|
+ case "FD0001":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0001List = jiaYueWindPowerCdqResultCoverFD0001Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0002":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0002List = jiaYueWindPowerCdqResultCoverFD0002Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0003":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0003List = jiaYueWindPowerCdqResultCoverFD0003Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0004":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0004List = jiaYueWindPowerCdqResultCoverFD0004Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0005":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0005List = jiaYueWindPowerCdqResultCoverFD0005Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0006":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0006List = jiaYueWindPowerCdqResultCoverFD0006Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0007":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0007List = jiaYueWindPowerCdqResultCoverFD0007Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0029":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0029List = jiaYueWindPowerCdqResultCoverFD0029Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ case "FD0030":
|
|
|
|
+ jiaYueWindPowerCdqResultCoverFD0030List = jiaYueWindPowerCdqResultCoverFD0030Service.findByDataDate(new Date(startTime));
|
|
|
|
+ break;
|
|
|
|
+ default:
|
|
|
|
+ break;
|
|
|
|
+ }
|
|
|
|
|
|
for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
|
|
for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
|
|
long finalTime = stepTime;
|
|
long finalTime = stepTime;
|
|
@@ -721,7 +711,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0002")) {
|
|
if (electricField.getSign().equals("FD0002")) {
|
|
- List<JiaYueWindPowerCdqResultCoverFD0002> filterList = jiaYueWindPowerCdqResultCoverFD0002List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0002> filterList = jiaYueWindPowerCdqResultCoverFD0002List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond()* 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -729,7 +719,7 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (electricField.getSign().equals("FD0003")) {
|
|
if (electricField.getSign().equals("FD0003")) {
|
|
- List<JiaYueWindPowerCdqResultCoverFD0003> filterList = jiaYueWindPowerCdqResultCoverFD0003List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() == finalTime).collect(Collectors.toList());
|
|
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0003> filterList = jiaYueWindPowerCdqResultCoverFD0003List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond()* 1000L == finalTime).collect(Collectors.toList());
|
|
if (!filterList.isEmpty()) {
|
|
if (!filterList.isEmpty()) {
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
content.append(filterList.get(0).getActivePower()).append("|");
|
|
} else {
|
|
} else {
|
|
@@ -768,6 +758,22 @@ public class GenerateBackPassDataService {
|
|
content.append(PLACE);
|
|
content.append(PLACE);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+ if (electricField.getSign().equals("FD0029")) {
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0029> filterList = jiaYueWindPowerCdqResultCoverFD0029List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
|
|
+ if (!filterList.isEmpty()) {
|
|
|
|
+ content.append(filterList.get(0).getActivePower()).append("|");
|
|
|
|
+ } else {
|
|
|
|
+ content.append(PLACE);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if (electricField.getSign().equals("FD0030")) {
|
|
|
|
+ List<JiaYueWindPowerCdqResultCoverFD0030> filterList = jiaYueWindPowerCdqResultCoverFD0030List.stream().filter(p -> p.getPreDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
|
|
|
|
+ if (!filterList.isEmpty()) {
|
|
|
|
+ content.append(filterList.get(0).getActivePower()).append("|");
|
|
|
|
+ } else {
|
|
|
|
+ content.append(PLACE);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
List<String> qrCodeContents1 = GzipUtil.pubZipList(content.toString(), packSize);
|
|
List<String> qrCodeContents1 = GzipUtil.pubZipList(content.toString(), packSize);
|
|
@@ -798,81 +804,6 @@ public class GenerateBackPassDataService {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 每天凌晨一点零五分生成回传短期、超短期。实际功率数据
|
|
|
|
- * @return
|
|
|
|
- */
|
|
|
|
- @Scheduled(cron = "0 5 1 * * *")
|
|
|
|
- public Map<String, Object> generateQRCode() {
|
|
|
|
- Map<String, Object> map = new HashMap<>();
|
|
|
|
- try {
|
|
|
|
- // 定时调用
|
|
|
|
- Calendar startyesterday = Calendar.getInstance();
|
|
|
|
- startyesterday.add(Calendar.DAY_OF_MONTH, -1);
|
|
|
|
- startyesterday.set(Calendar.HOUR_OF_DAY, 0);
|
|
|
|
- startyesterday.set(Calendar.MINUTE, 0);
|
|
|
|
- startyesterday.set(Calendar.SECOND, 0);
|
|
|
|
- startyesterday.set(Calendar.MILLISECOND, 0);
|
|
|
|
-
|
|
|
|
- Calendar endyesterday = Calendar.getInstance();
|
|
|
|
- endyesterday.add(Calendar.DAY_OF_MONTH, -1);
|
|
|
|
- endyesterday.set(Calendar.HOUR_OF_DAY, 23);
|
|
|
|
- endyesterday.set(Calendar.MINUTE, 59);
|
|
|
|
- endyesterday.set(Calendar.SECOND, 59);
|
|
|
|
- endyesterday.set(Calendar.MILLISECOND, 999);
|
|
|
|
-
|
|
|
|
- List<ElectricField> electricFieldList = new ArrayList<>();
|
|
|
|
- ElectricField electricField = new ElectricField();
|
|
|
|
- electricField.setStationCode("J00770");
|
|
|
|
- electricField.setSign("FD0001");
|
|
|
|
-
|
|
|
|
- ElectricField electricField2 = new ElectricField();
|
|
|
|
- electricField2.setStationCode("J00941");
|
|
|
|
- electricField2.setSign("FD0002");
|
|
|
|
-
|
|
|
|
- ElectricField electricField3 = new ElectricField();
|
|
|
|
- electricField3.setStationCode("J00942");
|
|
|
|
- electricField3.setSign("FD0003");
|
|
|
|
-
|
|
|
|
-
|
|
|
|
- // 新增宁夏吴忠石窖沟电站
|
|
|
|
- ElectricField electricField4 = new ElectricField();
|
|
|
|
- electricField4.setStationCode("J00988");
|
|
|
|
- electricField4.setSign("FD0004");
|
|
|
|
-
|
|
|
|
- ElectricField electricField5 = new ElectricField();
|
|
|
|
- electricField5.setStationCode("J00929");
|
|
|
|
- electricField5.setSign("FD0005");
|
|
|
|
-
|
|
|
|
- ElectricField electricField6 = new ElectricField();
|
|
|
|
- electricField6.setStationCode("J00930");
|
|
|
|
- electricField6.setSign("FD0006");
|
|
|
|
-
|
|
|
|
-
|
|
|
|
- ElectricField electricField7 = new ElectricField();
|
|
|
|
- electricField7.setStationCode("J00931");
|
|
|
|
- electricField7.setSign("FD0007");
|
|
|
|
-
|
|
|
|
- electricFieldList.add(electricField);
|
|
|
|
- electricFieldList.add(electricField2);
|
|
|
|
- electricFieldList.add(electricField3);
|
|
|
|
- electricFieldList.add(electricField4);
|
|
|
|
- electricFieldList.add(electricField5);
|
|
|
|
- electricFieldList.add(electricField6);
|
|
|
|
- electricFieldList.add(electricField7);
|
|
|
|
-
|
|
|
|
- for (int i = 0; i < electricFieldList.size(); i++) {
|
|
|
|
- map = generateQR(electricFieldList.get(i));
|
|
|
|
- toJson(map);
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- log.error("生成二维码失败");
|
|
|
|
- // 处理生成二维码失败的情况
|
|
|
|
- }
|
|
|
|
- return map;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- /**
|
|
|
|
* 生成回传短期、超短期、实际功率json文件
|
|
* 生成回传短期、超短期、实际功率json文件
|
|
* @param map
|
|
* @param map
|
|
*/
|
|
*/
|
|
@@ -894,30 +825,7 @@ public class GenerateBackPassDataService {
|
|
} catch (JsonProcessingException e) {
|
|
} catch (JsonProcessingException e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
- String fileName = null;
|
|
|
|
-// if (entry1.getKey().contains("超短期")) {
|
|
|
|
-// if (entry1.getKey().contains("点数")) {
|
|
|
|
-// fileName = entry.getKey() + "_Point" + entry1.getKey().substring(4, 6) + "_" + System.currentTimeMillis() + ".json";
|
|
|
|
-// } else {
|
|
|
|
-// fileName = entry.getKey() + "_Avg_" + System.currentTimeMillis() + ".json";
|
|
|
|
-// }
|
|
|
|
-// } else if (entry1.getKey().contains("中期")) {
|
|
|
|
-// if (entry1.getKey().contains("平均值")) {
|
|
|
|
-// fileName = entry.getKey() + "_Avg_" + System.currentTimeMillis() + ".json";
|
|
|
|
-// } else {
|
|
|
|
-// fileName = entry.getKey() + "_" + System.currentTimeMillis() + ".json";
|
|
|
|
-// }
|
|
|
|
-// } else {
|
|
|
|
- fileName = entry.getKey() + "_" + System.currentTimeMillis() + ".json";
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
- String filePath = "/home/syjy/huichuan/new/" + fileName;
|
|
|
|
- //写入文件
|
|
|
|
- try (FileWriter fileWriter = new FileWriter(filePath)) {
|
|
|
|
- fileWriter.write(prettyPrintJson);
|
|
|
|
- } catch (IOException e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }
|
|
|
|
|
|
+ this.prettyPrintJson(prettyPrintJson);
|
|
});
|
|
});
|
|
});
|
|
});
|
|
// }
|
|
// }
|