gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*******************************************************************************
   2  * ============LICENSE_START========================================================================
   3  * ONAP : ccsdk feature sdnr wt
   4  * =================================================================================================
   5  * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
   6  * =================================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
   8  * in compliance with the License. You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software distributed under the License
  13  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  14  * or implied. See the License for the specific language governing permissions and limitations under
  15  * the License.
  16  * ============LICENSE_END==========================================================================
  17  ******************************************************************************/
  18 package org.onap.ccsdk.features.sdnr.wt.devicemanager.performancemanager.impl.database.service;
  19
  20 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
  21 import org.onap.ccsdk.features.sdnr.wt.devicemanager.types.PerformanceDataLtp;
  22 import org.slf4j.Logger;
  23 import org.slf4j.LoggerFactory;
  24
  25 public class MicrowaveHistoricalPerformanceWriterService {
  26
  27     private static final Logger LOG = LoggerFactory.getLogger(MicrowaveHistoricalPerformanceWriterService.class);
  28
  29     private final DataProvider dataProvider;
  30 //    private HtDataBaseReaderAndWriter<EsHistoricalPerformance15Minutes> historicalPerformance15mRW;
  31 //    private HtDataBaseReaderAndWriter<EsHistoricalPerformance24Hours> historicalPerformance24hRW;
  32 //    private HtDataBaseReaderAndWriter<EsHistoricalPerformanceLogEntry> historicalPerformanceLogRW;
  33
  34     @Deprecated
  35     public MicrowaveHistoricalPerformanceWriterService(DataProvider dataProvider) {
  36
  37         LOG.info("Create {} start", MicrowaveHistoricalPerformanceWriterService.class);
  38         this.dataProvider = dataProvider;
  39
  40         LOG.info("Create {} finished. DB Service {} started.", MicrowaveHistoricalPerformanceWriterService.class,
  41                 dataProvider != null ? "sucessfully" : "not");
  42     }
  43
  44
  45 //    public void writePM(AllPm pm) {
  46 //        LOG.debug("Write {} pm records", pm.size());
  47 //
  48 //        LOG.debug("Write 15m write to DB");
  49 //        historicalPerformance15mRW.doWrite(pm.getPm15());
  50 //        LOG.debug("Write 15m done, Write 24h write to DB");
  51 //        historicalPerformance24hRW.doWrite(pm.getPm24());
  52 //        LOG.debug("Write 24h done");
  53 //    }
  54 //
  55     /**
  56      * @param performanceDataLtp
  57      */
  58     public void writePM(PerformanceDataLtp performanceDataLtp) {
  59
  60         dataProvider.doWritePerformanceData(performanceDataLtp.getList());
  61     }
  62
  63     static public boolean isAvailable(MicrowaveHistoricalPerformanceWriterService s) {
  64
  65         if (s == null || s.dataProvider == null) {
  66             return false;
  67         }
  68         return true;
  69     }
  70
  71
  72
  73 }