12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316 |
- package com.jiayue.ipfcst.client.service;
- import cn.hutool.core.date.DateUtil;
- import cn.hutool.http.HttpRequest;
- import cn.hutool.http.HttpResponse;
- import cn.hutool.json.JSONArray;
- import cn.hutool.json.JSONObject;
- import com.fasterxml.jackson.core.JsonProcessingException;
- import com.fasterxml.jackson.databind.ObjectMapper;
- import com.jiayue.ipfcst.client.service.impl.JiaYueWindPowerDqResultFD0002CoverServiceImpl;
- import com.jiayue.ipfcst.client.utils.GzipUtil;
- import com.jiayue.ipfcst.client.utils.JsonBeanUtil;
- import com.jiayue.ipfcst.client.utils.TimeUtils;
- import com.jiayue.ipfcst.common.core.exception.BusinessException;
- import com.jiayue.ipfcst.common.core.util.DateMomentUtil;
- import com.jiayue.ipfcst.common.core.util.DateTimeUtil;
- import com.jiayue.ipp.common.data.entity.*;
- import lombok.Data;
- import lombok.extern.slf4j.Slf4j;
- import org.springframework.scheduling.annotation.Async;
- import org.springframework.scheduling.annotation.EnableAsync;
- import org.springframework.scheduling.annotation.Scheduled;
- import org.springframework.stereotype.Service;
- import java.io.*;
- import java.math.BigDecimal;
- import java.math.RoundingMode;
- import java.text.SimpleDateFormat;
- import java.time.LocalDate;
- import java.time.LocalDateTime;
- import java.time.ZoneId;
- import java.util.*;
- import java.util.Date;
- import java.util.stream.Collectors;
- /**
- * 生成回传数据
- *
- * @Author: tl
- * @Date: 2023/6/29 9:47
- */
- @Service
- @Slf4j
- @EnableAsync
- public class GenerateBackPassDataService {
- private final WindPowerReal15MinFD0001Service windPowerReal15MinFD0001Service;
- private final WindPowerReal15MinFD0002Service windPowerReal15MinFD0002Service;
- private final WindPowerReal15MinFD0003Service windPowerReal15MinFD0003Service;
- private final WindPowerReal15MinFD0004Service windPowerReal15MinFD0004Service;
- private final WindPowerReal15MinFD0005Service windPowerReal15MinFD0005Service;
- private final WindPowerReal15MinFD0006Service windPowerReal15MinFD0006Service;
- private final WindPowerReal15MinFD0007Service windPowerReal15MinFD0007Service;
- private final WindPowerReal15MinFD0029Service windPowerReal15MinFD0029Service;
- private final WindPowerReal15MinFD0030Service windPowerReal15MinFD0030Service;
- private final WindPowerReal15MinFD0031Service windPowerReal15MinFD0031Service;
- private final PvPowerReal15MinGF0001Service pvPowerReal15MinGF0001Service;
- private final PvPowerReal15MinGF0002Service pvPowerReal15MinGF0002Service;
- private final PvPowerReal15MinGF0012Service pvPowerReal15MinGF0012Service;
- private final PvPowerReal15MinGF0013Service pvPowerReal15MinGF0013Service;
- private static final String IMAGE_TYPE = "jpg";
- private static final String PLACE = "-0.99|";
- private static final Long oneDay = 3600 * 24 * 1000L - 1000L;
- private static final Integer packSize = 2000;
- private final JiaYueWindPowerDqResultCoverFD0001Service jiaYueWindPowerDqResultCoverFD0001Service;
- private final JiaYueWindPowerDqResultCoverFD0002Service jiaYueWindPowerDqResultCoverFD0002Service;
- private final JiaYueWindPowerDqResultCoverFD0003Service jiaYueWindPowerDqResultCoverFD0003Service;
- private final JiaYueWindPowerDqResultCoverFD0004Service jiaYueWindPowerDqResultCoverFD0004Service;
- private final JiaYueWindPowerDqResultCoverFD0005Service jiaYueWindPowerDqResultCoverFD0005Service;
- private final JiaYueWindPowerDqResultCoverFD0006Service jiaYueWindPowerDqResultCoverFD0006Service;
- private final JiaYueWindPowerDqResultCoverFD0007Service jiaYueWindPowerDqResultCoverFD0007Service;
- private final JiaYueWindPowerDqResultCoverFD0029Service jiaYueWindPowerDqResultCoverFD0029Service;
- private final JiaYueWindPowerDqResultCoverFD0030Service jiaYueWindPowerDqResultCoverFD0030Service;
- private final JiaYueWindPowerDqResultCoverFD0031Service jiaYueWindPowerDqResultCoverFD0031Service;
- private final JiaYueWindPowerDqResultCoverGF0001Service jiaYueWindPowerDqResultCoverGF0001Service;
- private final JiaYueWindPowerDqResultCoverGF0002Service jiaYueWindPowerDqResultCoverGF0002Service;
- private final JiaYueWindPowerDqResultCoverGF0012Service jiaYueWindPowerDqResultCoverGF0012Service;
- private final JiaYueWindPowerDqResultCoverGF0013Service jiaYueWindPowerDqResultCoverGF0013Service;
- private final JiaYueWindPowerCdqResultCoverFD0001Service jiaYueWindPowerCdqResultCoverFD0001Service;
- private final JiaYueWindPowerCdqResultCoverFD0002Service jiaYueWindPowerCdqResultCoverFD0002Service;
- private final JiaYueWindPowerCdqResultCoverFD0003Service jiaYueWindPowerCdqResultCoverFD0003Service;
- private final JiaYueWindPowerCdqResultCoverFD0004Service jiaYueWindPowerCdqResultCoverFD0004Service;
- private final JiaYueWindPowerCdqResultCoverFD0005Service jiaYueWindPowerCdqResultCoverFD0005Service;
- private final JiaYueWindPowerCdqResultCoverFD0006Service jiaYueWindPowerCdqResultCoverFD0006Service;
- private final JiaYueWindPowerCdqResultCoverFD0007Service jiaYueWindPowerCdqResultCoverFD0007Service;
- private final JiaYueWindPowerCdqResultCoverFD0029Service jiaYueWindPowerCdqResultCoverFD0029Service;
- private final JiaYueWindPowerCdqResultCoverFD0030Service jiaYueWindPowerCdqResultCoverFD0030Service;
- private final JiaYueWindPowerCdqResultCoverFD0031Service jiaYueWindPowerCdqResultCoverFD0031Service;
- private final JiaYueWindPowerCdqResultCoverGF0001Service jiaYueWindPowerCdqResultCoverGF0001Service;
- private final JiaYueWindPowerCdqResultCoverGF0002Service jiaYueWindPowerCdqResultCoverGF0002Service;
- private final JiaYueWindPowerCdqResultCoverGF0012Service jiaYueWindPowerCdqResultCoverGF0012Service;
- private final JiaYueWindPowerCdqResultCoverGF0013Service jiaYueWindPowerCdqResultCoverGF0013Service;
- public GenerateBackPassDataService(PvPowerReal15MinGF0001Service pvPowerReal15MinGF0001Service,PvPowerReal15MinGF0002Service pvPowerReal15MinGF0002Service,PvPowerReal15MinGF0012Service pvPowerReal15MinGF0012Service,PvPowerReal15MinGF0013Service pvPowerReal15MinGF0013Service,WindPowerReal15MinFD0001Service windPowerReal15MinFD0001Service,WindPowerReal15MinFD0002Service windPowerReal15MinFD0002Service,WindPowerReal15MinFD0003Service windPowerReal15MinFD0003Service,WindPowerReal15MinFD0004Service windPowerReal15MinFD0004Service,WindPowerReal15MinFD0005Service windPowerReal15MinFD0005Service,
- WindPowerReal15MinFD0006Service windPowerReal15MinFD0006Service,WindPowerReal15MinFD0007Service windPowerReal15MinFD0007Service,WindPowerReal15MinFD0029Service windPowerReal15MinFD0029Service,WindPowerReal15MinFD0030Service windPowerReal15MinFD0030Service,WindPowerReal15MinFD0031Service windPowerReal15MinFD0031Service,JiaYueWindPowerDqResultCoverGF0001Service jiaYueWindPowerDqResultCoverGF0001Service,JiaYueWindPowerDqResultCoverGF0002Service jiaYueWindPowerDqResultCoverGF0002Service,JiaYueWindPowerDqResultCoverGF0012Service jiaYueWindPowerDqResultCoverGF0012Service,JiaYueWindPowerDqResultCoverGF0013Service jiaYueWindPowerDqResultCoverGF0013Service,JiaYueWindPowerDqResultCoverFD0001Service jiaYueWindPowerDqResultCoverFD0001Service,JiaYueWindPowerDqResultCoverFD0002Service jiaYueWindPowerDqResultCoverFD0002Service,
- JiaYueWindPowerDqResultCoverFD0003Service jiaYueWindPowerDqResultCoverFD0003Service,JiaYueWindPowerDqResultCoverFD0004Service jiaYueWindPowerDqResultCoverFD0004Service,JiaYueWindPowerDqResultCoverFD0005Service jiaYueWindPowerDqResultCoverFD0005Service,JiaYueWindPowerDqResultCoverFD0006Service jiaYueWindPowerDqResultCoverFD0006Service,
- JiaYueWindPowerDqResultCoverFD0007Service jiaYueWindPowerDqResultCoverFD0007Service,JiaYueWindPowerDqResultCoverFD0029Service jiaYueWindPowerDqResultCoverFD0029Service,JiaYueWindPowerDqResultCoverFD0030Service jiaYueWindPowerDqResultCoverFD0030Service,JiaYueWindPowerDqResultCoverFD0031Service jiaYueWindPowerDqResultCoverFD0031Service,JiaYueWindPowerCdqResultCoverGF0001Service jiaYueWindPowerCdqResultCoverGF0001Service,JiaYueWindPowerCdqResultCoverGF0002Service jiaYueWindPowerCdqResultCoverGF0002Service,JiaYueWindPowerCdqResultCoverGF0012Service jiaYueWindPowerCdqResultCoverGF0012Service,JiaYueWindPowerCdqResultCoverGF0013Service jiaYueWindPowerCdqResultCoverGF0013Service,JiaYueWindPowerCdqResultCoverFD0001Service jiaYueWindPowerCdqResultCoverFD0001Service,JiaYueWindPowerCdqResultCoverFD0002Service jiaYueWindPowerCdqResultCoverFD0002Service,
- JiaYueWindPowerCdqResultCoverFD0003Service jiaYueWindPowerCdqResultCoverFD0003Service,JiaYueWindPowerCdqResultCoverFD0004Service jiaYueWindPowerCdqResultCoverFD0004Service,JiaYueWindPowerCdqResultCoverFD0005Service jiaYueWindPowerCdqResultCoverFD0005Service,JiaYueWindPowerCdqResultCoverFD0006Service jiaYueWindPowerCdqResultCoverFD0006Service,
- JiaYueWindPowerCdqResultCoverFD0007Service jiaYueWindPowerCdqResultCoverFD0007Service,JiaYueWindPowerCdqResultCoverFD0029Service jiaYueWindPowerCdqResultCoverFD0029Service,JiaYueWindPowerCdqResultCoverFD0030Service jiaYueWindPowerCdqResultCoverFD0030Service,JiaYueWindPowerCdqResultCoverFD0031Service jiaYueWindPowerCdqResultCoverFD0031Service){
- this.windPowerReal15MinFD0001Service = windPowerReal15MinFD0001Service;
- this.windPowerReal15MinFD0002Service = windPowerReal15MinFD0002Service;
- this.windPowerReal15MinFD0003Service = windPowerReal15MinFD0003Service;
- this.windPowerReal15MinFD0004Service = windPowerReal15MinFD0004Service;
- this.windPowerReal15MinFD0005Service = windPowerReal15MinFD0005Service;
- this.windPowerReal15MinFD0006Service = windPowerReal15MinFD0006Service;
- this.windPowerReal15MinFD0007Service = windPowerReal15MinFD0007Service;
- this.windPowerReal15MinFD0029Service = windPowerReal15MinFD0029Service;
- this.windPowerReal15MinFD0030Service = windPowerReal15MinFD0030Service;
- this.windPowerReal15MinFD0031Service = windPowerReal15MinFD0031Service;
- this.pvPowerReal15MinGF0001Service = pvPowerReal15MinGF0001Service;
- this.pvPowerReal15MinGF0002Service = pvPowerReal15MinGF0002Service;
- this.pvPowerReal15MinGF0012Service = pvPowerReal15MinGF0012Service;
- this.pvPowerReal15MinGF0013Service = pvPowerReal15MinGF0013Service;
- this.jiaYueWindPowerDqResultCoverFD0001Service = jiaYueWindPowerDqResultCoverFD0001Service;
- this.jiaYueWindPowerDqResultCoverFD0002Service = jiaYueWindPowerDqResultCoverFD0002Service;
- this.jiaYueWindPowerDqResultCoverFD0003Service = jiaYueWindPowerDqResultCoverFD0003Service;
- this.jiaYueWindPowerDqResultCoverFD0004Service = jiaYueWindPowerDqResultCoverFD0004Service;
- this.jiaYueWindPowerDqResultCoverFD0005Service = jiaYueWindPowerDqResultCoverFD0005Service;
- this.jiaYueWindPowerDqResultCoverFD0006Service = jiaYueWindPowerDqResultCoverFD0006Service;
- this.jiaYueWindPowerDqResultCoverFD0007Service = jiaYueWindPowerDqResultCoverFD0007Service;
- this.jiaYueWindPowerDqResultCoverFD0029Service = jiaYueWindPowerDqResultCoverFD0029Service;
- this.jiaYueWindPowerDqResultCoverFD0030Service = jiaYueWindPowerDqResultCoverFD0030Service;
- this.jiaYueWindPowerDqResultCoverFD0031Service = jiaYueWindPowerDqResultCoverFD0031Service;
- this.jiaYueWindPowerDqResultCoverGF0001Service = jiaYueWindPowerDqResultCoverGF0001Service;
- this.jiaYueWindPowerDqResultCoverGF0002Service = jiaYueWindPowerDqResultCoverGF0002Service;
- this.jiaYueWindPowerDqResultCoverGF0012Service = jiaYueWindPowerDqResultCoverGF0012Service;
- this.jiaYueWindPowerDqResultCoverGF0013Service = jiaYueWindPowerDqResultCoverGF0013Service;
- this.jiaYueWindPowerCdqResultCoverFD0001Service = jiaYueWindPowerCdqResultCoverFD0001Service;
- this.jiaYueWindPowerCdqResultCoverFD0002Service = jiaYueWindPowerCdqResultCoverFD0002Service;
- this.jiaYueWindPowerCdqResultCoverFD0003Service = jiaYueWindPowerCdqResultCoverFD0003Service;
- this.jiaYueWindPowerCdqResultCoverFD0005Service = jiaYueWindPowerCdqResultCoverFD0005Service;
- this.jiaYueWindPowerCdqResultCoverFD0004Service = jiaYueWindPowerCdqResultCoverFD0004Service;
- this.jiaYueWindPowerCdqResultCoverFD0006Service = jiaYueWindPowerCdqResultCoverFD0006Service;
- this.jiaYueWindPowerCdqResultCoverFD0007Service = jiaYueWindPowerCdqResultCoverFD0007Service;
- this.jiaYueWindPowerCdqResultCoverFD0029Service = jiaYueWindPowerCdqResultCoverFD0029Service;
- this.jiaYueWindPowerCdqResultCoverFD0030Service = jiaYueWindPowerCdqResultCoverFD0030Service;
- this.jiaYueWindPowerCdqResultCoverFD0031Service = jiaYueWindPowerCdqResultCoverFD0031Service;
- this.jiaYueWindPowerCdqResultCoverGF0001Service = jiaYueWindPowerCdqResultCoverGF0001Service;
- this.jiaYueWindPowerCdqResultCoverGF0002Service = jiaYueWindPowerCdqResultCoverGF0002Service;
- this.jiaYueWindPowerCdqResultCoverGF0012Service = jiaYueWindPowerCdqResultCoverGF0012Service;
- this.jiaYueWindPowerCdqResultCoverGF0013Service = jiaYueWindPowerCdqResultCoverGF0013Service;
- }
- /**
- * 每天凌晨一点零五分生成回传短期、超短期。实际功率数据
- * @return
- */
- @Scheduled(cron = "0 5 1,12,18 * * *")
- @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");
- ElectricField electricField31 = new ElectricField();
- electricField30.setStationCode("J01043");
- electricField30.setSign("FD0031");
- // 光伏电站
- ElectricField electricFieldGF0001 = new ElectricField();
- electricFieldGF0001.setStationCode("J01056");
- electricFieldGF0001.setSign("GF0001");
- ElectricField electricFieldGF0002 = new ElectricField();
- electricFieldGF0002.setStationCode("J01057");
- electricFieldGF0002.setSign("GF0002");
- ElectricField electricFieldGF0012 = new ElectricField();
- electricFieldGF0012.setStationCode("J01061");
- electricFieldGF0012.setSign("GF0012");
- ElectricField electricFieldGF0013 = new ElectricField();
- electricFieldGF0013.setStationCode("J01062");
- electricFieldGF0013.setSign("GF0013");
- 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);
- electricFieldList.add(electricField31);
- electricFieldList.add(electricFieldGF0001);
- electricFieldList.add(electricFieldGF0002);
- electricFieldList.add(electricFieldGF0012);
- electricFieldList.add(electricFieldGF0013);
- //
- // // 开始日期和结束日期
- // LocalDate startDate = LocalDate.of(2024, 1, 2);
- // LocalDate endDate = LocalDate.of(2024, 8, 13);
- //
- // // 存储结果的列表
- // List<Date> dateList = new ArrayList<>();
- //
- // // 遍历日期范围
- // LocalDate currentDate = startDate;
- // while (!currentDate.isAfter(endDate)) {
- // // 获取当天的00:00
- // LocalDateTime startOfDay = currentDate.atStartOfDay();
- //
- // // 转换为Date
- // Date startOfDayDate = Date.from(startOfDay.atZone(ZoneId.systemDefault()).toInstant());
- //
- // // 添加到列表中
- // dateList.add(startOfDayDate);
- // currentDate = currentDate.plusDays(1);
- // }
- //
- // 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);
- // Thread.sleep(1000);
- }
- // }
- log.info("任务执行完成!");
- } catch (Exception e) {
- e.printStackTrace();
- log.error("生成二维码失败");
- // 处理生成二维码失败的情况
- }
- return map;
- }
- 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();
- }
- }
- @Data
- class TaskResultRequestVO {
- private static final long serialVersionUID = 1L;
- private String taskResult;
- }
- /**
- * @return
- */
- /**
- * 查询回传短期、超短期、实际功率所需数据
- * @param electricField
- * @return
- */
- public Map<String, Object> generateQR(ElectricField electricField) {
- Long time = new Date().getTime() - 60 * 60 * 24 * 1000L;
- // 获取昨日开始时间结束时间
- Date startTime = new Date(TimeUtils.getDayStartTime(time));
- Date endTime = new Date(startTime.getTime() + 60 * 60 * 24 * 1000L - 1000L);
- Map<String, Object> map = new HashMap<>();
- try {
- //各个二维码显示设置
- Map<String, List<String>> dqMap = new TreeMap<>();
- Map<String, List<String>> cdqMap = new HashMap<>();
- Map<String, List<String>> rpMap = new HashMap<>();
- //超短期 stationData-QR T00003-ust-点位
- List<String> ust = generateUltraShortTermContent(startTime.getTime(), startTime.getTime() + 3600 * 24 * 1000L - 1000, electricField);
- cdqMap.put("超短期第1点数据", ust);
- //短期
- List<String> st = generateShortTermContent(startTime.getTime()- 3600 * 24 * 1000L, endTime.getTime()- 3600 * 24 * 1000L, electricField);
- //二维码名字
- StringBuilder name = new StringBuilder("E1短期");
- dqMap.put(name.toString(), st);
- //实际功率stationData-QR T00003-rp
- List<String> rp = generateRealPowerCodeContent(startTime.getTime(), endTime.getTime(), electricField);
- rpMap.put("实际功率", rp);
- map.put("ultraShortTerm", cdqMap);
- map.put("shortTerm", dqMap);
- map.put("realPower", rpMap);
- } catch (Exception e) {
- e.printStackTrace();
- }
- return map;
- }
- /**
- * 实际功率二维码内容生成
- *
- * @param startTime 开始时间
- * @param endTime 结束时间
- * @return 二维码生成内容集
- * @throws IOException io异常
- * @throws BusinessException 业务异常
- */
- public List<String> generateRealPowerCodeContent(Long startTime, Long endTime, ElectricField electricField) throws IOException, BusinessException {
- long timeStep = 900000L;
- if (startTime % timeStep != 0) {
- startTime = startTime - (startTime % timeStep) + timeStep;
- }
- StringBuilder content = new StringBuilder();
- StringBuilder instContent = new StringBuilder();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- StringBuilder stringBuilder = new StringBuilder();
- //T00003-rp|2023-04-14
- stringBuilder.append(electricField.getStationCode()).append("-").append("rp").append("|").append(sdf.format(startTime)).append("|");
- 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<>();
- List<WindPowerReal15MinFD0031> windPowerReal15MinFD0031List = new ArrayList<>();
- List<PvPowerReal15MinGF0001> pvPowerReal15MinGF0001List = new ArrayList<>();
- List<PvPowerReal15MinGF0002> pvPowerReal15MinGF0002List = new ArrayList<>();
- List<PvPowerReal15MinGF0012> pvPowerReal15MinGF0012List = new ArrayList<>();
- List<PvPowerReal15MinGF0013> pvPowerReal15MinGF0013List = 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;
- case "FD0031":
- windPowerReal15MinFD0031List = windPowerReal15MinFD0031Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
- break;
- case "GF0001":
- pvPowerReal15MinGF0001List = pvPowerReal15MinGF0001Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
- break;
- case "GF0002":
- pvPowerReal15MinGF0002List = pvPowerReal15MinGF0002Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
- break;
- case "GF0012":
- pvPowerReal15MinGF0012List = pvPowerReal15MinGF0012Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
- break;
- case "GF0013":
- pvPowerReal15MinGF0013List = pvPowerReal15MinGF0013Service.getAll(new Date(startTime), new Date(startTime + 24 * 60 * 60 * 1000L - 1000));
- break;
- default:
- break;
- }
- for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
- long finalTime = stepTime;
- if (electricField.getSign().equals("FD0001")) {
- List<WindPowerReal15MinFD0001> filterList = windPowerReal15MinFD0001List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0001 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0002")) {
- List<WindPowerReal15MinFD0002> filterList = windPowerReal15MinFD0002List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0002 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0003")) {
- List<WindPowerReal15MinFD0003> filterList = windPowerReal15MinFD0003List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0003 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0004")) {
- List<WindPowerReal15MinFD0004> filterList = windPowerReal15MinFD0004List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0004 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0005")) {
- List<WindPowerReal15MinFD0005> filterList = windPowerReal15MinFD0005List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0005 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0006")) {
- List<WindPowerReal15MinFD0006> filterList = windPowerReal15MinFD0006List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0006 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0007")) {
- List<WindPowerReal15MinFD0007> filterList = windPowerReal15MinFD0007List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0007 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.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());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0029 p : filterList) {
- avg = avg.add(new BigDecimal(p.getActivePower()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getActivePower()).append("|");
- } else {
- content.append(PLACE);
- instContent.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());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0030 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("FD0031")) {
- List<WindPowerReal15MinFD0031> filterList = windPowerReal15MinFD0031List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (WindPowerReal15MinFD0031 p : filterList) {
- avg = avg.add(new BigDecimal(p.getValue()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getValue()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("GF0001")) {
- List<PvPowerReal15MinGF0001> filterList = pvPowerReal15MinGF0001List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (PvPowerReal15MinGF0001 p : filterList) {
- avg = avg.add(new BigDecimal(p.getActivePower()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getActivePower()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("GF0002")) {
- List<PvPowerReal15MinGF0002> filterList = pvPowerReal15MinGF0002List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (PvPowerReal15MinGF0002 p : filterList) {
- avg = avg.add(new BigDecimal(p.getActivePower()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getActivePower()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("GF0012")) {
- List<PvPowerReal15MinGF0012> filterList = pvPowerReal15MinGF0012List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (PvPowerReal15MinGF0012 p : filterList) {
- avg = avg.add(new BigDecimal(p.getActivePower()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getActivePower()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- if (electricField.getSign().equals("GF0013")) {
- List<PvPowerReal15MinGF0013> filterList = pvPowerReal15MinGF0013List.stream().filter(p -> p.getDateTime().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000L == finalTime).collect(Collectors.toList());
- BigDecimal avg = new BigDecimal(0);
- //取前15分钟的平均值 13:30取13:16-13:30的平均值
- for (PvPowerReal15MinGF0013 p : filterList) {
- avg = avg.add(new BigDecimal(p.getActivePower()));
- }
- if (!filterList.isEmpty()) {
- content.append(avg.divide(new BigDecimal(filterList.size()), 2, RoundingMode.HALF_UP)).append("|");
- instContent.append(filterList.get(0).getActivePower()).append("|");
- } else {
- content.append(PLACE);
- instContent.append(PLACE);
- }
- }
- }
- stringBuilder.append(content);
- stringBuilder.append(instContent);
- List<String> qrCodeContents = GzipUtil.pubZipList(stringBuilder.toString(), packSize);
- List<String> result = new ArrayList<>();
- String taskNo = getTaskNo(electricField);
- for (int i = 0; i < qrCodeContents.size(); i++) {
- JSONObject jsonObject = new JSONObject();
- jsonObject.putOnce("taskNo", taskNo);
- jsonObject.putOnce("taskType", "stationData-QR");
- jsonObject.putOnce("partNo", i + 1);
- jsonObject.putOnce("partTotal", qrCodeContents.size());
- jsonObject.putOnce("data", qrCodeContents.get(i));
- result.add(i, jsonObject.toString());
- }
- return result;
- }
- /**
- * 上报短期二维码内容生成
- *
- * @param startTime 开始时间
- * @param endTime 结束时间
- * @return 二维码生成内容集
- * @throws IOException IO异常
- * @throws BusinessException 业务异常
- */
- public List<String> generateShortTermContent(Long startTime, Long endTime, ElectricField electricField) throws IOException, BusinessException {
- long timeStep = 900000L;
- if (startTime % timeStep != 0) {
- startTime = startTime - (startTime % timeStep) + timeStep;
- }
- StringBuilder content = new StringBuilder();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- StringBuilder name = new StringBuilder("E1");
- content.append(electricField.getStationCode()).append("-").append("st").append("-").append(name).append("|");
- List<Long> lDate = DateMomentUtil.getEveryDay(startTime+24 * 60 * 60 * 1000 , startTime + 48 * 60 * 60 * 1000 - 1000L);
- for (int i = 0; i < lDate.size(); i++) {
- content.append(sdf.format(lDate.get(i)));
- if (i != lDate.size() - 1) {
- content.append(",");
- } else {
- content.append("|");
- }
- }
- 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<>();
- List<JiaYueWindPowerDqResultCoverFD0031> jiaYueWindPowerDqResultCoverFD0031List = new ArrayList<>();
- List<JiaYueWindPowerDqResultCoverGF0001> jiaYueWindPowerDqResultCoverGF0001List = new ArrayList<>();
- List<JiaYueWindPowerDqResultCoverGF0002> jiaYueWindPowerDqResultCoverGF0002List = new ArrayList<>();
- List<JiaYueWindPowerDqResultCoverGF0012> jiaYueWindPowerDqResultCoverGF0012List = new ArrayList<>();
- List<JiaYueWindPowerDqResultCoverGF0013> jiaYueWindPowerDqResultCoverGF0013List = 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;
- case "FD0031":
- jiaYueWindPowerDqResultCoverFD0031List = jiaYueWindPowerDqResultCoverFD0031Service.findByDataDate(new Date(startTime));
- break;
- case "GF0001":
- jiaYueWindPowerDqResultCoverGF0001List = jiaYueWindPowerDqResultCoverGF0001Service.findByDataDate(new Date(startTime));
- break;
- case "GF0002":
- jiaYueWindPowerDqResultCoverGF0002List = jiaYueWindPowerDqResultCoverGF0002Service.findByDataDate(new Date(startTime));
- break;
- case "GF0012":
- jiaYueWindPowerDqResultCoverGF0012List = jiaYueWindPowerDqResultCoverGF0012Service.findByDataDate(new Date(startTime));
- break;
- case "GF0013":
- jiaYueWindPowerDqResultCoverGF0013List = jiaYueWindPowerDqResultCoverGF0013Service.findByDataDate(new Date(startTime));
- break;
- default:
- break;
- }
- for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
- long finalTime = stepTime;
- if (electricField.getSign().equals("FD0001")) {
- List<JiaYueWindPowerDqResultCoverFD0001> filterList = jiaYueWindPowerDqResultCoverFD0001List.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("FD0002")) {
- List<JiaYueWindPowerDqResultCoverFD0002> filterList = jiaYueWindPowerDqResultCoverFD0002List.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("FD0003")) {
- List<JiaYueWindPowerDqResultCoverFD0003> filterList = jiaYueWindPowerDqResultCoverFD0003List.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("FD0004")) {
- List<JiaYueWindPowerDqResultCoverFD0004> filterList = jiaYueWindPowerDqResultCoverFD0004List.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("FD0005")) {
- List<JiaYueWindPowerDqResultCoverFD0005> filterList = jiaYueWindPowerDqResultCoverFD0005List.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("FD0006")) {
- List<JiaYueWindPowerDqResultCoverFD0006> filterList = jiaYueWindPowerDqResultCoverFD0006List.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("FD0007")) {
- List<JiaYueWindPowerDqResultCoverFD0007> filterList = jiaYueWindPowerDqResultCoverFD0007List.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("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);
- }
- }
- if (electricField.getSign().equals("FD0031")) {
- List<JiaYueWindPowerDqResultCoverFD0031> filterList = jiaYueWindPowerDqResultCoverFD0031List.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("GF0001")) {
- List<JiaYueWindPowerDqResultCoverGF0001> filterList = jiaYueWindPowerDqResultCoverGF0001List.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("GF0002")) {
- List<JiaYueWindPowerDqResultCoverGF0002> filterList = jiaYueWindPowerDqResultCoverGF0002List.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("GF0012")) {
- List<JiaYueWindPowerDqResultCoverGF0012> filterList = jiaYueWindPowerDqResultCoverGF0012List.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("GF0013")) {
- List<JiaYueWindPowerDqResultCoverGF0013> filterList = jiaYueWindPowerDqResultCoverGF0013List.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> result = new ArrayList<>();
- String taskNo = getTaskNo(electricField);
- for (int i = 0; i < qrCodeContents1.size(); i++) {
- JSONObject jsonObject = new JSONObject();
- jsonObject.putOnce("taskNo", taskNo);
- jsonObject.putOnce("taskType", "stationData-QR");
- jsonObject.putOnce("partNo", i + 1);
- jsonObject.putOnce("partTotal", qrCodeContents1.size());
- jsonObject.putOnce("data", qrCodeContents1.get(i));
- result.add(i, jsonObject.toString());
- }
- return result;
- }
- /**
- * 上报超短期二维码内容生成
- *
- * @param startTime 开始时间
- * @param endTime 结束时间
- * @return 二维码生成内容集
- * @throws IOException IO异常
- * @throws BusinessException 业务异常
- */
- public List<String> generateUltraShortTermContent(Long startTime, Long endTime, ElectricField electricField) throws IOException, BusinessException {
- long timeStep = 900000L;
- if (startTime % timeStep != 0) {
- startTime = startTime - (startTime % timeStep) + timeStep;
- }
- StringBuilder content = new StringBuilder();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
- content.append(electricField.getStationCode()).append("-").append("ust").append("-").append(1).append("|");
- List<Long> lDate = DateMomentUtil.getEveryDay(startTime, endTime);
- for (int i = 0; i < lDate.size(); i++) {
- content.append(sdf.format(lDate.get(i)));
- if (i != lDate.size() - 1) {
- content.append(",");
- } else {
- content.append("|");
- }
- }
- 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<>();
- List<JiaYueWindPowerCdqResultCoverFD0031> jiaYueWindPowerCdqResultCoverFD0031List = new ArrayList<>();
- List<JiaYueWindPowerCdqResultCoverGF0001> jiaYueWindPowerCdqResultCoverGF0001List = new ArrayList<>();
- List<JiaYueWindPowerCdqResultCoverGF0002> jiaYueWindPowerCdqResultCoverGF0002List = new ArrayList<>();
- List<JiaYueWindPowerCdqResultCoverGF0012> jiaYueWindPowerCdqResultCoverGF0012List = new ArrayList<>();
- List<JiaYueWindPowerCdqResultCoverGF0013> jiaYueWindPowerCdqResultCoverGF0013List = 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;
- case "FD0031":
- jiaYueWindPowerCdqResultCoverFD0031List = jiaYueWindPowerCdqResultCoverFD0031Service.findByDataDate(new Date(startTime));
- break;
- case "GF0001":
- jiaYueWindPowerCdqResultCoverGF0001List = jiaYueWindPowerCdqResultCoverGF0001Service.findByDataDate(new Date(startTime));
- break;
- case "GF0002":
- jiaYueWindPowerCdqResultCoverGF0002List = jiaYueWindPowerCdqResultCoverGF0002Service.findByDataDate(new Date(startTime));
- break;
- case "GF0012":
- jiaYueWindPowerCdqResultCoverGF0012List = jiaYueWindPowerCdqResultCoverGF0012Service.findByDataDate(new Date(startTime));
- break;
- case "GF0013":
- jiaYueWindPowerCdqResultCoverGF0013List = jiaYueWindPowerCdqResultCoverGF0013Service.findByDataDate(new Date(startTime));
- break;
- default:
- break;
- }
- for (long stepTime = startTime; stepTime <= endTime; stepTime = stepTime + timeStep) {
- long finalTime = stepTime;
- if (electricField.getSign().equals("FD0001")) {
- List<JiaYueWindPowerCdqResultCoverFD0001> filterList = jiaYueWindPowerCdqResultCoverFD0001List.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("FD0002")) {
- List<JiaYueWindPowerCdqResultCoverFD0002> filterList = jiaYueWindPowerCdqResultCoverFD0002List.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("FD0003")) {
- List<JiaYueWindPowerCdqResultCoverFD0003> filterList = jiaYueWindPowerCdqResultCoverFD0003List.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("FD0004")) {
- List<JiaYueWindPowerCdqResultCoverFD0004> filterList = jiaYueWindPowerCdqResultCoverFD0004List.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("FD0005")) {
- List<JiaYueWindPowerCdqResultCoverFD0005> filterList = jiaYueWindPowerCdqResultCoverFD0005List.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("FD0006")) {
- List<JiaYueWindPowerCdqResultCoverFD0006> filterList = jiaYueWindPowerCdqResultCoverFD0006List.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("FD0007")) {
- List<JiaYueWindPowerCdqResultCoverFD0007> filterList = jiaYueWindPowerCdqResultCoverFD0007List.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("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);
- }
- }
- if (electricField.getSign().equals("FD0031")) {
- List<JiaYueWindPowerCdqResultCoverFD0031> filterList = jiaYueWindPowerCdqResultCoverFD0031List.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("GF0001")) {
- List<JiaYueWindPowerCdqResultCoverGF0001> filterList = jiaYueWindPowerCdqResultCoverGF0001List.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("GF0002")) {
- List<JiaYueWindPowerCdqResultCoverGF0002> filterList = jiaYueWindPowerCdqResultCoverGF0002List.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("GF0012")) {
- List<JiaYueWindPowerCdqResultCoverGF0012> filterList = jiaYueWindPowerCdqResultCoverGF0012List.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("GF0013")) {
- List<JiaYueWindPowerCdqResultCoverGF0013> filterList = jiaYueWindPowerCdqResultCoverGF0013List.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> result = new ArrayList<>();
- String taskNo = getTaskNo(electricField);
- for (int i = 0; i < qrCodeContents1.size(); i++) {
- JSONObject jsonObject = new JSONObject();
- jsonObject.putOnce("taskNo", taskNo);
- jsonObject.putOnce("taskType", "stationData-QR");
- jsonObject.putOnce("partNo", i + 1);
- jsonObject.putOnce("partTotal", qrCodeContents1.size());
- jsonObject.putOnce("data", qrCodeContents1.get(i));
- result.add(i, jsonObject.toString());
- }
- return result;
- }
- /**
- * 获取taskNo编号
- *
- * @param electricField 场站对象
- * @return 编号
- */
- private String getTaskNo(ElectricField electricField) {
- Date date = DateUtil.date();
- return electricField.getStationCode() + DateUtil.format(date, "yyMMddHHmmss");
- }
- /**
- * 生成回传短期、超短期、实际功率json文件
- * @param map
- */
- public void toJson(Map<String, Object> map) {
- map.entrySet().stream().forEach(entry -> {
- Map<String, Object> value = (Map<String, Object>) entry.getValue();
- value.entrySet().stream().forEach(entry1 -> {
- ObjectMapper objectMapper = new ObjectMapper();
- JSONArray jsonArray = new JSONArray(entry1.getValue().toString());// 将entry1.getValue()转换为JSON数组
- JSONObject jsonObject = jsonArray.getJSONObject(0);// 获取数组中的第一个JSONObject对象
- String json = null;
- String prettyPrintJson = null;
- try {
- json = objectMapper.writeValueAsString(jsonObject);
- Object formattedJson = objectMapper.readValue(json, Object.class);
- prettyPrintJson = objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(formattedJson);
- } catch (JsonProcessingException e) {
- e.printStackTrace();
- }
- this.prettyPrintJson(prettyPrintJson);
- });
- });
- // }
- }
- /**
- * 这几个表清除所有数据,在进行数据同步(基础信息表)
- */
- // @Scheduled(cron = "0 30 0 * * ?")
- // @Scheduled(cron = "0 48 2 * * ?")
- public void synchronizeInfoData() {
- log.info("---------------------------开始同步基础信息---------------------------");
- // // 数据类型信息表
- // List<DataTypeInfo> dataTypeInfoList = dataTypeInfoService.get();
- // // 查询本地所有数据
- // List<DataTypeInfo> dataTypeInfos = dataTypeInfoService.getAll();
- // if (dataTypeInfos != null && dataTypeInfos.size() > 0) {
- // // 先删除数据
- // dataTypeInfoService.deleteAll();
- // }
- // // 将远端数据插入到本地
- // dataTypeInfoService.put(dataTypeInfoList);
- // // 风电场基本信息表(厂商专供)
- // List<WindFarmInfoEncryption> windFarmInfoEncryptionList = windFarmInfoEncryptionService.get();
- // // 查询本地所有数据
- // List<WindFarmInfoEncryption> windFarmInfoEncryptions = windFarmInfoEncryptionService.getAll();
- // if (windFarmInfoEncryptions != null && windFarmInfoEncryptions.size() > 0) {
- // // 先删除数据
- // windFarmInfoEncryptionService.deleteAll();
- // }
- // windFarmInfoEncryptionService.put(windFarmInfoEncryptionList);
- // // 测风塔信息
- // List<WindTowerInfo> windTowerInfoList = windTowerInfoService.get();
- // // 查询本地所有数据
- // List<WindTowerInfo> windTowerInfos = windTowerInfoService.getAll();
- // if (windTowerInfos != null && windTowerInfos.size() > 0) {
- // // 先删除数据
- // windTowerInfoService.deleteAll();
- // }
- // windTowerInfoService.put(windTowerInfoList);
- // // 风电机组基本信息表
- // List<WindUnitInfo> windUnitInfoList = windUnitInfoService.get();
- // // 查询本地所有数据
- // List<WindUnitInfo> windUnitInfos = windUnitInfoService.getAll();
- // if (windUnitInfos != null && windUnitInfos.size() > 0) {
- // // 先删除数据
- // windUnitInfoService.deleteAll();
- // }
- // windUnitInfoService.put(windUnitInfoList);
- // // 风电机组型号基本信息表
- // List<WindUnitModelInfo> windUnitModelInfoList = windUnitModelInfoService.get();
- // // 查询本地所有数据
- // List<WindUnitModelInfo> windUnitModelInfos = windUnitModelInfoService.getAll();
- // if (windUnitModelInfos != null && windUnitModelInfos.size() > 0) {
- // // 先删除数据
- // windUnitModelInfoService.deleteAll();
- // }
- // windUnitModelInfoService.put(windUnitModelInfoList);
- // List<WindUnitModelWsAndPower> windUnitModelWsAndPowerList = windUnitModelWsAndPowerService.get();
- // // 查询本地所有数据
- // List<WindUnitModelWsAndPower> windUnitModelWsAndPowers = windUnitModelWsAndPowerService.getAll();
- // if (windUnitModelWsAndPowers != null && windUnitModelWsAndPowers.size() > 0) {
- // // 先删除数据
- // windUnitModelWsAndPowerService.deleteAll();
- // }
- // windUnitModelWsAndPowerService.put(windUnitModelWsAndPowerList);
- log.info("---------------------------同步基础信息结束---------------------------");
- }
- /**
- * 这几个表每天同步昨天的数据
- */
- // @Scheduled(cron = "0 48 2 * * ?")
- public void synchronizeRealData() {
- log.info("---------------------------开始同步昨日数据---------------------------");
- long time = System.currentTimeMillis() - 86400000l;
- // 获取startTime和endTime
- Date startTime = DateTimeUtil.getDayStartTime(time);
- Date endTime = DateTimeUtil.getDayLastTime(time);
- // List<WindTowerCdqResultCover> windTowerCdqResultCoverList = windTowerCdqResultCoverService.get(startTime, endTime);
- // windTowerCdqResultCoverService.put(windTowerCdqResultCoverList);
- //
- // List<WindPowerCdqResultCover> windPowerCdqResultCoverList = windPowerCdqResultCoverService.get(startTime, endTime);
- // windPowerCdqResultCoverService.put(windPowerCdqResultCoverList);
- //
- // List<WindPowerDqResultCover> windPowerDqResultCoverList = windPowerDqResultCoverService.get(startTime, endTime);
- // windPowerDqResultCoverService.put(windPowerDqResultCoverList);
- // List<WindPowerReal15MinFD0001> windPowerReal15MinFD0001List = windPowerReal15MinFD0001Service.get(startTime, endTime);
- // windPowerReal15MinFD0001Service.put(windPowerReal15MinFD0001List);
- //
- // List<WindPowerReal15MinFD0002> windPowerReal15MinFD0002List = windPowerReal15MinFD0002Service.get(startTime, endTime);
- // windPowerReal15MinFD0002Service.put(windPowerReal15MinFD0002List);
- //
- // List<WindPowerReal15MinFD0003> windPowerReal15MinFD0003List = windPowerReal15MinFD0003Service.get(startTime, endTime);
- // windPowerReal15MinFD0003Service.put(windPowerReal15MinFD0003List);
- //
- // List<WindPowerReal15MinFD0005> windPowerReal15MinFD0005List = windPowerReal15MinFD0005Service.get(startTime, endTime);
- // windPowerReal15MinFD0005Service.put(windPowerReal15MinFD0005List);
- //
- // List<WindPowerReal15MinFD0006> windPowerReal15MinFD0006List = windPowerReal15MinFD0006Service.get(startTime, endTime);
- // windPowerReal15MinFD0006Service.put(windPowerReal15MinFD0006List);
- //
- // List<WindPowerReal15MinFD0007> windPowerReal15MinFD0007List = windPowerReal15MinFD0007Service.get(startTime, endTime);
- // windPowerReal15MinFD0007Service.put(windPowerReal15MinFD0007List);
- // List<WindTower15Min> windTower15MinList = windTower15MinService.get(startTime, endTime);
- // windTower15MinService.put(windTower15MinList);
- //
- //
- // List<WindTowerDqResultCover> windTowerDqResultCoverList = windTowerDqResultCoverService.get(startTime, endTime);
- // windTowerDqResultCoverService.put(windTowerDqResultCoverList);
- log.info("---------------------------同步昨日数据结束---------------------------");
- }
- }
|