| | |
| | | @Resource |
| | | private DaPointService daPointService; |
| | | |
| | | public List<InfluxPointValuePOJO> handle(Date collectTime, List<DaPointDTO> dtos, Map<String, Object> dataMap) { |
| | | public List<InfluxPointValuePOJO> handle(Date collectTime, List<DaPointDTO> dtos, Map<String, Object> dataMap,List<String> listGood,List<String> listBad) { |
| | | log.info("常量点处理开始"); |
| | | List<InfluxPointValuePOJO> result = new ArrayList<>(); |
| | | if (CollectionUtils.isEmpty(dtos)) { |
| | |
| | | pojo.setTimestamp(collectTime.toInstant()); |
| | | dataMap.put(dto.getPointNo(), dto.getDefaultValue()); |
| | | result.add(pojo); |
| | | listGood.add(dto.getPointNo()); |
| | | }); |
| | | log.info("常量点处理结束"); |
| | | return result; |