MyEMS / myems

    ####################################################################################################################

    # Step 4: Insert into energy database

    ####################################################################################################################

    while len(normalized_values) > 0:

        insert_100 = normalized_values[:100]

        normalized_values = normalized_values[100:]

        try:

            add_values = (" INSERT INTO tbl_meter_hourly (meter_id, start_datetime_utc, actual_value) "

                          " VALUES  ")

            for meta_data in insert_100:

                add_values += " (" + str(meter['id']) + ","

                add_values += "'" + meta_data['start_datetime_utc'].isoformat()[0:19] + "',"

                add_values += str(meta_data['actual_value']) + "), "

            # trim ", " at the end of string and then execute

            cursor_energy_db.execute(add_values[:-2])

            cnx_energy_db.commit()

        except Exception as e:

            error_string = "Error in step 4.1 of meter.worker " + str(e) + " for '" + meter['name'] + "'"

            if cursor_energy_db:

                cursor_energy_db.close()

            if cnx_energy_db:

                cnx_energy_db.close()

            print(error_string)

            return error_string

    if cursor_energy_db:

        cursor_energy_db.close()

    print("saving energy values to table energy virtual meter hourly...")

    while len(normalized_values) > 0:

        insert_100 = normalized_values[:100]

        normalized_values = normalized_values[100:]

        try:

            add_values = (" INSERT INTO tbl_virtual_meter_hourly "

                          " (virtual_meter_id, start_datetime_utc, actual_value) "

                          " VALUES  ")

            for meta_data in insert_100:

                add_values += " (" + str(virtual_meter['id']) + ","

                add_values += "'" + meta_data['start_datetime_utc'].isoformat()[0:19] + "',"

                add_values += str(meta_data['actual_value']) + "), "

            print("add_values:" + add_values)

            # trim ", " at the end of string and then execute

            cursor_energy_db.execute(add_values[:-2])

            cnx_energy_db.commit()

        except Exception as e:

            if cursor_energy_db:

                cursor_energy_db.close()

            if cnx_energy_db:

                cnx_energy_db.close()

            return "Error in step 4.2 virtual meter worker " + str(e) + " for '" + virtual_meter['name'] + "'"

    if cursor_energy_db:

        cursor_energy_db.close()