GateFlowGroup2.py

from java.util import Calendar
from java.util import TimeZone
from usace.rowcps.headless import LoggingOptions

def compute_All_Flowgroups(officeID, location, startCal, endCal):
    # Takes in locations defined by user in group and computes all flow groups
    try:
        gateCalc.computeAll(officeID, location, startCal.getTime(), endCal.getTime())
    except Exception as e:
        print "Error Computing all Flow Groups at {0} {1}".format(officeID, location)
        print e
        print ''


def compute_Single_Flowgroup(officeID, location, startCal, endCal, flowGroup):
    try:
        gateCalc.computeFlowGroup(officeID, location, startCal.getTime(), endCal.getTime(), "Flow.{0}.{1}".format(location, flowGroup))
    except Exception as e:
        print "Error Computing Flow Group {0} at {1}".format(officeID, location)
        print e
        print ''

    # #gateCalc.computeFlowGroup("SWF", "ACTT2",  startCal.getTime(), endCal.getTime(), "Flow.ACTT2.Pump_Out_Total")
# Description of: LoggingOptions.setDbMessageLevel(int level)
#
# Adds Time Series logging messages in the OracleTimeSeriesDaoImpl.  Recommended
# level is 2, as this provides basic information about the time series
# retrieval/storage.
#
# Message Level | Description
# --------------|-------------------------------------------------------------------------------------------------------------------------------|
# <=0           | Default value, does not do anything.  Lower values do not change behavior.                                                  |
# 1             | Logs message when no data is found.  Logs message when data is found, how much was retrieved or stored, and how long it took. |
# 2             | Adds message with name of time series, and the units to retrieve/store.                                                       |
# 3             | Adds message with the current time.                                                                                           |
# 4             | Adds message with first 10 dates and values from each time series.                                                            |
# >4            | Same as 4, but shows all values retrieved from each time series.  Higher values do not change behavior.                       |
# --------------|-------------------------------------------------------------------------------------------------------------------------------|

LoggingOptions.setDbMessageLevel(2)


# Description of: LoggingOptions.setMetricsEnabled(boolean value)
#
# Enables or disables the storage of REGI's Metric data pertaining to the
# performance of the application.  This is incredibly helpful for identifying
# issues where the application takes an excessive amount of time to operate.
#
# Metrics also log the location of the files as an INFO message if they are
# enabled.
#
# By default, Metrics are disabled.

# LoggingOptions.setMetricsEnabled(True)

# not all of Regi is scriptable, registry is an object created by the java class RegiCLI that contains a list of
# the implemented scriptable calculations
names = registry.getNames(1.0)

# this retrieves a Gate Flow calculation object
gateCalc = registry.getCalculation(1.0, "Gate Flow")

# Time zone must be set because the Solaris time zone is UTC
timeZone = TimeZone.getTimeZone("US/Central")

# Defaults to start of the day 5 days ago, and ends at the top of the current hour today
# configure the start calendar
startCal = Calendar.getInstance(timeZone)
startCal.add(Calendar.DAY_OF_MONTH, -5)
#startCal.add(Calendar.HOUR, -7)
startCal.set(Calendar.MINUTE, 0)
startCal.set(Calendar.SECOND, 0)
startCal.set(Calendar.MILLISECOND, 0)


# configure the end calendar
endCal = Calendar.getInstance(timeZone)
endCal.set(Calendar.MINUTE, 0)
endCal.set(Calendar.SECOND, 0)
endCal.set(Calendar.MILLISECOND, 0)
#endCal.add(Calendar.MONTH, -3)

# Calendar can be adjusted using the following functions:
#   startCal.set(Calendar.DATE, 1)          # Sets the date of the calendar.
#   startCal.set(Calendar.HOUR_OF_DAY, 1)   # Sets the hour of the day to 0100 (1-24)
#   startCal.set(Calendar.YEAR, 2020)       # Sets the year
#   startCal.set(Calendar.MONTH, 4)         # Sets the month (month 4 means May to Java)

officeID = "SWT"

# the gateCalc object can perform its calculation for a single flow group
# the computeFlowGroup method takes:
# officeId
# projectId
# startDate
# endDate
# gateCalc.computeFlowGroup("SWF", "LEWT2",  startCal.getTime(), endCal.getTime(), "Flow.LEWT2.ConduitGate_Total")

#
#  GROUP 2 PROJECTS (SELF-TIMED TRANSMISSIONS WITHIN THE FIRST 2 - 4 MINUTES OF THE TOP OF THE HOUR)
#

#ARCA
gateCalc.computeFlowGroup("SWT", "ARCA",  startCal.getTime(), endCal.getTime(), "Flow.ARCA.Project_Total")
gateCalc.computeFlowGroup("SWT", "ARCA",  startCal.getTime(), endCal.getTime(), "Flow.ARCA.Gated_Total")

#ARBU
gateCalc.computeFlowGroup("SWT", "ARBU",  startCal.getTime(), endCal.getTime(), "Flow.ARBU.Project_Total")
gateCalc.computeFlowGroup("SWT", "ARBU",  startCal.getTime(), endCal.getTime(), "Flow.ARBU.Gated_Total")

#BIRC
gateCalc.computeFlowGroup("SWT", "BIRC",  startCal.getTime(), endCal.getTime(), "Flow.BIRC.Project_Total")
gateCalc.computeFlowGroup("SWT", "BIRC",  startCal.getTime(), endCal.getTime(), "Flow.BIRC.Gated_Total")

#ROBE
gateCalc.computeFlowGroup("SWT", "ROBE",  startCal.getTime(), endCal.getTime(), "Flow.ROBE.Project_Total")
gateCalc.computeFlowGroup("SWT", "ROBE",  startCal.getTime(), endCal.getTime(), "Flow.ROBE.Gated_Total")
gateCalc.computeFlowGroup("SWT", "ROBE",  startCal.getTime(), endCal.getTime(), "Flow.ROBE.Turbine_Total")

#WAUR
gateCalc.computeFlowGroup("SWT", "WAUR",  startCal.getTime(), endCal.getTime(), "Flow.WAUR.Project_Total")
gateCalc.computeFlowGroup("SWT", "WAUR",  startCal.getTime(), endCal.getTime(), "Flow.WAUR.Gated_Total")