| | |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public List<Object[]> getData(String outputId, Date predictTime, String timeFormat, int decimalPlaces) { |
| | | List<Object[]> result = new ArrayList<>(); |
| | | QueryWrapper<StAdjustResultEntity> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("output_id", outputId) |
| | | .eq("adjust_time", DateUtils.format(predictTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)); |
| | | StAdjustResultEntity data = baseDao.selectOne(wrapper); |
| | | if (data == null || StringUtils.isBlank(data.getJsonValue())) { |
| | | return result; |
| | | } |
| | | List<Double> valueList = JSONArray.parseArray(data.getJsonValue(), Double.class); |
| | | if (CollectionUtils.isEmpty(valueList)) { |
| | | return result; |
| | | } |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.setTime(predictTime); |
| | | valueList.forEach(value -> { |
| | | Object[] dv = {DateUtils.format(calendar.getTime(), timeFormat), new BigDecimal(value).setScale(decimalPlaces, BigDecimal.ROUND_HALF_UP)}; |
| | | calendar.add(Calendar.MINUTE, 1); |
| | | result.add(dv); |
| | | }); |
| | | return result; |
| | | } |
| | | |
| | | @Override |
| | | public StAdjustResultRespVO getInfo(String id) { |
| | | StAdjustResultEntity entity = baseDao.selectById(id); |
| | | StAdjustResultRespVO result = ConvertUtils.sourceToTarget(entity, StAdjustResultRespVO.class); |