|
|
@@ -1,22 +1,33 @@
|
|
|
package com.gyee.runeconomy.service;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.gyee.runeconomy.model.auto.ProEconWtAlysisDay;
|
|
|
+import com.gyee.runeconomy.model.auto.TurbineInfoDay;
|
|
|
import com.gyee.runeconomy.service.auto.IProEconWtAlysisDayService;
|
|
|
+import com.gyee.runeconomy.service.auto.ITurbineInfoDayService;
|
|
|
import com.gyee.runeconomy.util.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import java.text.ParseException;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
+import java.util.Calendar;
|
|
|
import java.util.Date;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import java.util.function.Function;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
@Service
|
|
|
public class WtAlysisDayService {
|
|
|
|
|
|
@Resource
|
|
|
private IProEconWtAlysisDayService proEconWtAlysisDayService;
|
|
|
+ @Resource
|
|
|
+ private ITurbineInfoDayService turbineInfoDayService;
|
|
|
|
|
|
|
|
|
public Page<ProEconWtAlysisDay> wtAlysisDayList(Integer pageNum, Integer pageSize, String wtId, String beginDate, String endDate) {
|
|
|
@@ -51,10 +62,57 @@ public class WtAlysisDayService {
|
|
|
queryWrapper.orderByAsc(ProEconWtAlysisDay::getRecordDate);
|
|
|
//执行查询
|
|
|
proEconWtAlysisDayService.page(pageInfo, queryWrapper);
|
|
|
+
|
|
|
+
|
|
|
+ QueryWrapper<TurbineInfoDay> qw = new QueryWrapper<>();
|
|
|
+ qw.lambda().eq(TurbineInfoDay::getTurbineId, wtId).between(TurbineInfoDay::getRecordDate, begin, end)
|
|
|
+ .orderByAsc(TurbineInfoDay::getRecordDate);
|
|
|
+ IPage<TurbineInfoDay> page01 = new Page<>(pageNum, pageSize);
|
|
|
+ IPage<TurbineInfoDay> page1 = turbineInfoDayService.page(page01, qw);
|
|
|
+ Map<Date, TurbineInfoDay> dayMap = page1.getRecords().stream().collect(Collectors.toMap(TurbineInfoDay::getRecordDate, Function.identity()));
|
|
|
+
|
|
|
+ pageInfo.getRecords().forEach(rsl -> {
|
|
|
+ TurbineInfoDay day = dayMap.get(rsl.getRecordDate());
|
|
|
+ rsl.setRfdl(day.getRfdl());
|
|
|
+ double yfdl = calFdl(rsl.getWindturbineId(), "month", rsl.getRecordDate());
|
|
|
+ rsl.setYfdl(yfdl);
|
|
|
+ double nfdl = calFdl(rsl.getWindturbineId(), "year", rsl.getRecordDate());
|
|
|
+ rsl.setNfdl(nfdl);
|
|
|
+ rsl.setRpjfs(day.getPjfs());
|
|
|
+ rsl.setRssdl(day.getGzss() + day.getJhjxss() + day.getXdss() + day.getXnss() + day.getSlss());
|
|
|
+ rsl.setRgzxs(day.getGzMin() / 60);
|
|
|
+ rsl.setRjxxs(day.getJxMin() / 60);
|
|
|
+ rsl.setRyxxs(day.getYxMin() / 60);
|
|
|
+ });
|
|
|
+
|
|
|
}
|
|
|
|
|
|
return pageInfo;
|
|
|
}
|
|
|
|
|
|
|
|
|
+ public double calFdl(String windturbineId, String type, Date endDate) {
|
|
|
+ Calendar calendar = Calendar.getInstance();
|
|
|
+ calendar.setTime(endDate);
|
|
|
+ Date firstDay = null;
|
|
|
+ if ("month".equals(type)) {
|
|
|
+ calendar.set(Calendar.DAY_OF_MONTH, 1);
|
|
|
+ firstDay = calendar.getTime();
|
|
|
+ } else if ("year".equals(type)) {
|
|
|
+ calendar.set(Calendar.MONTH, 0);
|
|
|
+ calendar.set(Calendar.DAY_OF_MONTH, 1);
|
|
|
+ firstDay = calendar.getTime();
|
|
|
+ }
|
|
|
+ QueryWrapper<TurbineInfoDay> currentqw = new QueryWrapper<>();
|
|
|
+ currentqw.select("station_id,MAX(record_date) AS record_date,SUM(rfdl) AS rfdl")
|
|
|
+ .ge("record_date", firstDay)
|
|
|
+ .le("record_date", endDate)
|
|
|
+ .eq("turbine_id", windturbineId)
|
|
|
+ .like("station_id", "_FDC_")
|
|
|
+ .groupBy("station_id");
|
|
|
+ List<TurbineInfoDay> monthData = turbineInfoDayService.list(currentqw);
|
|
|
+ return monthData.get(0).getRfdl();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
}
|
wangb