void insert(List<MmItemResultJsonEntity> resultJsonList);
| | |
| | | List<Object[]> getData(String outputId, Date predictTime, String timeFormat); |
| | | |
| | | String getDoubleData(String outputId, Date predictTime); |
| | | |
| | | void insert(List<MmItemResultJsonEntity> resultJsonList); |
| | | } |
| | |
| | | MmItemResultJsonEntity mmItemResultJsonEntity = baseDao.selectOne(wrapper); |
| | | return null == mmItemResultJsonEntity ? null : mmItemResultJsonEntity.getCumulant(); |
| | | } |
| | | |
| | | @Override |
| | | public void insert(List<MmItemResultJsonEntity> resultJsonList) { |
| | | baseDao.insertBatch(resultJsonList); |
| | | } |
| | | } |
| | |
| | | resultJsonList.add(resultJson); |
| | | } |
| | | // json结果存入mysql |
| | | mmItemResultJsonService.insertBatch(resultJsonList); |
| | | mmItemResultJsonService.insert(resultJsonList); |
| | | // double结果存入influxdb |
| | | influxDBService.asyncWriteModelResults(importList); |
| | | influxDBService.asyncWriteModelResults(lastList); |