{
"sourceSeriesId": [
  130041, 130032, 130033
],
"procedure": "EXEC [equis].[sp_insert_dt_logger_datum_plus_measure] @target_series_id, @source_series_ids, @start_date, @end_date, @facility_id, @sys_loc_code;"
}

IF OBJECT_ID(N'[equis].[sp_insert_dt_logger_datum_plus_measure]') IS NOT NULL

DROP PROCEDURE [equis].[sp_insert_dt_logger_datum_plus_measure];

GO

CREATE PROCEDURE [equis].[sp_insert_dt_logger_datum_plus_measure]

(

  @target_series_id BIGINT

,@source_series_ids VARCHAR(100)

,@start_date       DATETIME2(0)

,@end_date         DATETIME2(0)

,@facility_id       BIGINT

,@sys_loc_code     VARCHAR(20)

)

AS

BEGIN

DECLARE @source_series_ids_table TABLE

(

   id BIGINT

);

INSERT INTO

   @source_series_ids_table (id)

SELECT DISTINCT

   TRY_CAST(id.value AS BIGINT)

FROM

   equis.split(@source_series_ids) AS id;

DECLARE @temp_datum TABLE

(

    datum_utc_dt DATETIME2(0)

  ,datum_value REAL

);

INSERT INTO

   @temp_datum (datum_utc_dt, datum_value)

SELECT

    datum_utc_dt

  ,MAX(datum_value + equis.fn_logger_measure_datum(@facility_id, @sys_loc_code, datum_utc_dt))

FROM

   dt_logger_datum

WHERE

       logger_series_id IN (SELECT id FROM @source_series_ids_table)

  AND datum_utc_dt BETWEEN @start_date AND @end_date

GROUP BY

   datum_utc_dt;

MERGE

   dt_logger_datum d

USING

   @temp_datum t

ON

       d.logger_series_id = @target_series_id

  AND d.datum_utc_dt = t.datum_utc_dt

WHEN MATCHED THEN

  UPDATE SET d.datum_value = t.datum_value

WHEN NOT MATCHED THEN

  INSERT (logger_series_id, datum_utc_dt, datum_value)

  VALUES (@target_series_id, t.datum_utc_dt, t.datum_value);

END