#!/bin/env runhaskell {-# LANGUAGE OverloadedStrings #-} module Main where import Control.Monad import Data.Maybe import Data.List import System.Locale import System.Time import Network.CGI import Database.MySQL.Simple main = runCGI $ handleErrors cgiMain cgiMain :: CGI CGIResult cgiMain = do conn <- liftIO $ connect defaultConnectInfo { connectUser = "watermeter" , connectPassword = "xxxxxxxx" , connectDatabase = "watermeter" } today <- liftIO getClockTime let tomorrow = addToClockTime (noTimeDiff {tdDay = 1}) today daystart x = (toUTCTime x) { ctHour = 0, ctMin = 0 , ctSec = 0, ctPicosec = 0} dtstr x = formatCalendarTime defaultTimeLocale "%Y-%m-%d %H:%M:%S" x dlo = dtstr $ daystart today dhi = dtstr $ daystart tomorrow ilo <- getInput "lo" ihi <- getInput "hi" -- _ <- liftIO $ putStrLn $ " dlo=" ++ show dlo ++ " ilo=" ++ show ilo -- ++ " dhi=" ++ show dhi ++ " ihi=" ++ show ihi let slo = fromMaybe dlo ilo :: String shi = fromMaybe dhi ihi :: String [(olo, ohi)] <- liftIO $ query conn "select to_seconds(?), to_seconds(?);" [slo, shi] cold <- liftIO $ query conn "select to_seconds(timestamp) as time, value+adj as value from \ \(select c.timestamp timestamp, c.value value, \ \(select sum(value) from coldadj a where a.timestamp <= c.timestamp \ \) adj from coldcnt c \ \where timestamp between ? and ? order by timestamp \ \) t;" (slo, shi) hot <- liftIO $ query conn "select to_seconds(timestamp) as time, value+adj as value from \ \(select c.timestamp timestamp, c.value value, \ \(select sum(value) from hotadj a where a.timestamp <= c.timestamp \ \) adj from hotcnt c \ \where timestamp between ? and ? order by timestamp \ \) t;" (slo, shi) _ <- liftIO $ close conn setHeader "Content-type" "application/json" output $ "{\"range\": {\"lo\": " ++ show (olo :: Int) ++ ", \"hi\": " ++ show (ohi :: Int) ++ "}, \"cold\": [" ++ showjson cold ++ "], \"hot\": [" ++ showjson hot ++ "]}\n" showjson :: [(Int, Double)] -> String showjson l = intercalate "," $ map (\(t, c) -> "[" ++ show t ++ "," ++ show (floor c) ++ "]") l