"""
Substation Model
"""
from __future__ import division
import pandas as pd
import time
import numpy as np
import scipy
__author__ = "Jimeno A. Fonseca"
__copyright__ = "Copyright 2015, Architecture and Building Systems - ETH Zurich"
__credits__ = ["Jimeno A. Fonseca", "Tim Vollrath", "Thuy-An Nguyen"]
__license__ = "MIT"
__version__ = "0.1"
__maintainer__ = "Daren Thomas"
__email__ = "cea@arch.ethz.ch"
__status__ = "Production"
# Substation model
[docs]def substation_main(locator, total_demand, building_names, gv, Flag):
"""
this function calculates the temperatures and mass flow rates of the district heating network
at every costumer. Based on this, the script calculates the hourly temperature of the network at the plant.
This temperature needs to be equal to that of the customer with the highest temperature requirement plus thermal
losses in the network.
:param locator: path to locator function
:param total_demand: dataframe with total demand and names of all building in the area
:param building_names: dataframe with names of all buildings in the area
:param gv: path to global variables class
:param Flag: boolean, True if the function is called by the master optimizaiton. False if the fucntion is
called during preprocessing
"""
t0 = time.clock()
# generate empty vectors
Ths = np.zeros(8760)
Tww = np.zeros(8760)
Tcs = np.zeros(8760) + 1E6
# determine grid target temperatures at costumer side.
iteration = 0
buildings = []
for name in building_names:
buildings.append(pd.read_csv(locator.get_demand_results_folder() + '//' + name + ".csv",
usecols=['Name', 'Thsf_sup_C', 'Thsf_re_C', 'Tcsf_sup_C', 'Tcsf_re_C',
'Twwf_sup_C', 'Twwf_re_C', 'Qhsf_kWh', 'Qcsf_kWh', 'Qwwf_kWh',
'mcphsf_kWC', 'mcpwwf_kWC', 'mcpcsf_kWC',
'Ef_kWh']))
Ths = np.vectorize(calc_DH_supply)(Ths.copy(), buildings[iteration].Thsf_sup_C.values)
Tww = np.vectorize(calc_DH_supply)(Tww.copy(), buildings[iteration].Twwf_sup_C.values)
Tcs = np.vectorize(calc_DC_supply)(Tcs.copy(), buildings[iteration].Tcsf_sup_C.values)
iteration += 1
T_DHS = np.vectorize(calc_DH_supply)(Ths, Tww)
T_DHS_supply = np.where(T_DHS > 0, T_DHS + gv.dT_heat, T_DHS)
T_DCS_supply = np.where(Tcs != 1E6, Tcs - gv.dT_cool, 0)
# Calculate disconnected buildings files and substation operation.
if Flag:
index = 0
combi = [0] * len(building_names)
for name in building_names:
print name
dfRes = total_demand[(total_demand.Name == name)]
combi[index] = 1
key = "".join(str(e) for e in combi)
dfRes.to_csv(locator.get_optimization_substations_total_file(key), sep=',', float_format='%.3f')
combi[index] = 0
# calculate substation parameters per building
substation_model(locator, gv, buildings[index], T_DHS, T_DHS_supply, T_DCS_supply, Ths, Tww)
index += 1
else:
index =0
# calculate substation parameters per building
for name in building_names:
substation_model(locator, gv, buildings[index], T_DHS, T_DHS_supply, T_DCS_supply, Ths, Tww)
index += 1
print time.clock() - t0, "seconds process time for the Substation Routine \n"
[docs]def substation_model(locator, gv, building, t_DH, t_DH_supply, t_DC_supply, t_HS, t_WW):
'''
:param locator: path to locator function
:param gv: path to global variables class
:param building: dataframe with consumption data per building
:param t_DH: vector with hourly temperature of the district heating network without losses
:param t_DH_supply: vector with hourly temperature of the district heating netowork with losses
:param t_DC_supply: vector with hourly temperature of the district coolig network with losses
:param t_HS: maximum hourly temperature for all buildings connected due to space heating
:param t_WW: maximum hourly temperature for all buildings connected due to domestic hot water
:return:
Dataframe stored for every building with the mass flow rates and temperatures district heating and cooling
side in:
where fName_result: ID of the building accounting for the individual at which it belongs to.
'''
# calculate temperatures and massflow rates HEX for space heating costumers.
thi = t_DH_supply + 273 # In k
Qhsf = building.Qhsf_kWh.values * 1000 # in W
Qnom = max(Qhsf) # in W
if Qnom > 0:
tco = building.Thsf_sup_C.values + 273 # in K
tci = building.Thsf_re_C.values + 273 # in K
cc = building.mcphsf_kWC.values * 1000 # in W/K
index = np.where(Qhsf == Qnom)[0][0]
thi_0 = thi[index]
tci_0 = tci[index]
tco_0 = tco[index]
cc_0 = cc[index]
t_DH_return_hs, mcp_DH_hs, A_hex_hs = \
calc_substation_heating(Qhsf, thi, tco, tci, cc, cc_0, Qnom, thi_0, tci_0, tco_0, gv)
else:
t_DH_return_hs = np.zeros(8760)
mcp_DH_hs = np.zeros(8760)
A_hex_hs = 0
# calculate temperatures and massflow rates HEX for dhW costumers.
Qwwf = building.Qwwf_kWh.values * 1000 # in W
Qnom = max(Qwwf) # in W
if Qnom > 0:
tco = building.Twwf_sup_C.values + 273 # in K
tci = building.Twwf_re_C.values + 273 # in K
cc = building.mcpwwf_kWC.values * 1000 # in W/K
index = np.where(Qwwf == Qnom)[0][0]
thi_0 = thi[index]
tci_0 = tci[index]
tco_0 = tco[index]
cc_0 = cc[index]
t_DH_return_ww, mcp_DH_ww, A_hex_ww = \
calc_substation_heating(Qwwf, thi, tco, tci, cc, cc_0, Qnom, thi_0, tci_0, tco_0, gv)
else:
t_DH_return_ww = np.zeros(8760)
A_hex_ww = 0
mcp_DH_ww = np.zeros(8760)
# calculate mix temperature of return DH
t_DH_return = np.vectorize(calc_HEX_mix)(Qhsf, Qwwf, t_DH_return_ww, mcp_DH_ww, t_DH_return_hs, mcp_DH_hs)
mcp_DH = (mcp_DH_ww + mcp_DH_hs)
# calculate temperatures and massflow rates HEX for cooling costumers incl refrigeration and processes
Qcf = (abs(building.Qcsf_kWh.values)) * 1000 # in W
Qnom = max(Qcf) # in W
if Qnom > 0:
tci = t_DC_supply + 273 # in K
tho = building.Tcsf_sup_C.values + 273 # in K
thi = building.Tcsf_re_C.values + 273 # in K
ch = (abs(building.mcpcsf_kWC.values)) * 1000 # in W/K
index = np.where(Qcf == Qnom)[0][0]
tci_0 = tci[index] # in K
thi_0 = thi[index]
tho_0 = tho[index]
ch_0 = ch[index]
t_DC_return_cs, mcp_DC_cs, A_hex_cs = \
calc_substation_cooling(Qcf, thi, tho, tci, ch, ch_0, Qnom, thi_0, tci_0, tho_0, gv)
else:
t_DC_return_cs = t_DC_supply
mcp_DC_cs = 0
A_hex_cs = 0
# converting units and quantities:
T_return_DH_result_flat = t_DH_return + 273.0 # convert to K
T_supply_DH_result_flat = t_DH_supply + 273.0 # convert to K
mdot_DH_result_flat = mcp_DH * 1000 / gv.cp # convert from kW/K to kg/s
mdot_heating_result_flat = mcp_DH_hs * 1000 / gv.cp # convert from kW/K to kg/s
mdot_dhw_result_flat = mcp_DH_ww * 1000 / gv.cp # convert from kW/K to kg/s
mdot_cool_result_flat = mcp_DC_cs * 1000 / gv.cp # convert from kW/K to kg/s
T_r1_dhw_result_flat = t_DH_return_ww + 273.0 # convert to K
T_r1_heating_result_flat = t_DH_return_hs + 273.0 # convert to K
T_r1_cool_result_flat = t_DC_return_cs + 273.0 # convert to K
T_supply_DC_result_flat = t_DC_supply + 273.0 # convert to K
T_supply_max_all_buildings_flat = t_DH + 273.0 # convert to K
T_hotwater_max_all_buildings_flat = t_WW + 273.0 # convert to K
T_heating_sup_max_all_buildings_flat = t_HS + 273.0 # convert to K
Electr_array_all_flat = building.Ef_kWh.values * 1000 # convert to #to W
# save the results into a .csv file
results = pd.DataFrame({"mdot_DH_result": mdot_DH_result_flat,
"T_return_DH_result": T_return_DH_result_flat,
"T_supply_DH_result": T_supply_DH_result_flat,
"mdot_heating_result": mdot_heating_result_flat,
"mdot_dhw_result": mdot_dhw_result_flat,
"mdot_DC_result": mdot_cool_result_flat,
"T_r1_dhw_result": T_r1_dhw_result_flat,
"T_r1_heating_result": T_r1_heating_result_flat,
"T_return_DC_result": T_r1_cool_result_flat,
"T_supply_DC_result": T_supply_DC_result_flat,
"A_hex_heating_design": A_hex_hs,
"A_hex_dhw_design": A_hex_ww,
"A_hex_cool_design": A_hex_cs,
"Q_heating": Qhsf,
"Q_dhw": Qwwf,
"Q_cool": Qcf,
"T_total_supply_max_all_buildings_intern": T_supply_max_all_buildings_flat,
"T_hotwater_max_all_buildings_intern": T_hotwater_max_all_buildings_flat,
"T_heating_max_all_buildings_intern": T_heating_sup_max_all_buildings_flat,
"Electr_array_all_flat": Electr_array_all_flat})
results.to_csv(locator.get_optimization_substations_results_file(building.Name.values[0]), sep=',', index=False,
float_format='%.3f')
return results
# substation cooling
[docs]def calc_substation_cooling(Q, thi, tho, tci, ch, ch_0, Qnom, thi_0, tci_0, tho_0, gv):
'''
this function calculates the state of the heat exchanger at the substation of every customer with cooling needs
:param Q: cooling laad
:param thi: in temperature of primary side
:param tho: out temperature of primary side
:param tci: in temperature of secondary side
:param ch: capacity mass flow rate primary side
:param ch_0: nominal capacity mass flow rate primary side
:param Qnom: nominal cooling load
:param thi_0: nominal in temperature of primary side
:param tci_0: nominal in temperature of secondary side
:param tho_0: nominal out temperature of primary side
:param gv: path to global variables class
:return:
tco = out temperature of secondary side (district cooling network)
cc = capacity mass flow rate secondary side
Area_HEX_cooling = are of heat excahnger.
'''
# nominal conditions network side
cc_0 = ch_0 * (thi_0 - tho_0) / ((thi_0 - tci_0) * 0.9)
tco_0 = Qnom / cc_0 + tci_0
dTm_0 = calc_dTm_HEX(thi_0, tho_0, tci_0, tco_0, 'cool')
# Area heat exchange and UA_heating
Area_HEX_cooling, UA_cooling = calc_area_HEX(Qnom, dTm_0, gv.U_cool)
tco, cc = np.vectorize(calc_HEX_cooling)(Q, UA_cooling, thi, tho, tci, ch)
return tco, cc, Area_HEX_cooling
# substation heating
[docs]def calc_substation_heating(Q, thi, tco, tci, cc, cc_0, Qnom, thi_0, tci_0, tco_0, gv):
'''
This function calculates the mass flow rate, temperature of return (secondary side)
and heat exchanger area of every substation.
:param Q: heating load
:param thi: in temperature of secondary side
:param tco: out temperature of primary side
:param tci: in temperature of primary side
:param cc: capacity mass flow rate primary side
:param cc_0: nominal capacity mass flow rate primary side
:param Qnom: nominal cooling load
:param thi_0: nominal in temperature of secondary side
:param tci_0: nominal in temperature of primary side
:param tco_0: nominal out temperature of primary side
:param gv: path to global variables class
:return:
tho = out temperature of secondary side (district cooling network)
ch = capacity mass flow rate secondary side
Area_HEX_heating = are of heat excahnger.
'''
# nominal conditions network side
ch_0 = cc_0 * (tco_0 - tci_0) / ((thi_0 - tci_0) * 0.9)
tho_0 = thi_0 - Qnom / ch_0
dTm_0 = calc_dTm_HEX(thi_0, tho_0, tci_0, tco_0, 'heat')
# Area heat excahnge and UA_heating
Area_HEX_heating, UA_heating = calc_area_HEX(Qnom, dTm_0, gv.U_heat)
tho, ch = np.vectorize(calc_HEX_heating)(Q, UA_heating, thi, tco, tci, cc)
return tho, ch, Area_HEX_heating
# Heat exchanger model
[docs]def calc_HEX_cooling(Q, UA, thi, tho, tci, ch):
"""
This function calculates the mass flow rate, temperature of return (secondary side)
and heat exchanger area for a plate heat exchanger.
Method of Number of Transfer Units (NTU)
:param Q: cooling load
:param UA: coefficient representing the area of heat exchanger times the coefficient of transmittance of the
heat exchanger
:param thi: in temperature of primary side
:param tho: out temperature of primary side
:param tci: in temperature of secondary side
:param ch: capacity mass flow rate primary side
:return: - ``tco``, out temperature of secondary side (district cooling network)
- ``cc``, capacity mass flow rate secondary side
"""
if ch > 0:
eff = [0.1, 0]
Flag = False
tol = 0.00000001
while abs((eff[0] - eff[1]) / eff[0]) > tol:
if Flag == True:
eff[0] = eff[1]
else:
cmin = ch * (thi - tho) / ((thi - tci) * eff[0])
if cmin < ch:
cc = cmin
cmax = ch
else:
cc = cmin
cmax = cc
cmin = ch
cr = cmin / cmax
NTU = UA / cmin
eff[1] = calc_plate_HEX(NTU, cr)
cmin = ch * (thi - tho) / ((thi - tci) * eff[1])
tco = tci + eff[1] * cmin * (thi - tci) / cc
Flag = True
cc = Q / abs(tci - tco)
tco = tco - 273
else:
tco = 0
cc = 0
return np.float(tco), np.float(cc / 1000)
[docs]def calc_plate_HEX(NTU, cr):
"""
This function calculates the efficiency of exchange for a plate heat exchanger according to the NTU method of
AShRAE 90.1
:param NTU: number of transfer units
:param cr: ratio between min and max capacity mass flow rates
:return:
eff: efficiency of heat exchange
"""
eff = 1 - scipy.exp((1 / cr) * (NTU ** 0.22) * (scipy.exp(-cr * (NTU) ** 0.78) - 1))
return eff
[docs]def calc_shell_HEX(NTU, cr):
"""
This function calculates the efficiency of exchange for a tube-shell heat exchanger according to the NTU method of
AShRAE 90.1
:param NTU: number of transfer units
:param cr: ratio between min and max capacity mass flow rates
:return:
eff: efficiency of heat exchange
"""
eff = 2 * ((1 + cr + (1 + cr ** 2) ** (1 / 2)) * (
(1 + scipy.exp(-(NTU) * (1 + cr ** 2))) / (1 - scipy.exp(-(NTU) * (1 + cr ** 2))))) ** -1
return eff
[docs]def calc_HEX_mix(Q1, Q2, t1, m1, t2, m2):
"""
This function computes the average temperature between two vectors of heating demand.
In this case, domestic hotwater and space heating.
:param Q1: load heating
:param Q2: load domestic hot water
:param t1: out temperature of heat exchanger for space heating
:param m1: mas flow rate secondary side of heat exchanger for space heating
:param t2: out temperature of heat exchanger for domestic hot water
:param m2: mas flow rate secondary side of heat exchanger for domestic hot water
:return:
tavg: average out temperature.
"""
if Q1 > 0 or Q2 > 0:
tavg = (t1 * m1 + t2 * m2) / (m1 + m2)
else:
tavg = 0
return np.float(tavg)
[docs]def calc_HEX_heating(Q, UA, thi, tco, tci, cc):
"""
This function calculates the mass flow rate, temperature of return (secondary side)
and heat exchanger area for a shell-tube pleat exchanger in the heating case.
Method of Number of Transfer Units (NTU)
:param Q: load
:param UA: coefficient representing the area of heat exchanger times the coefficient of transmittance of the
heat exchanger
:param thi: in temperature of secondary side
:param tco: out temperature of primary side
:param tci: in temperature of primary side
:param cc: capacity mass flow rate primary side
:return: - ``tho``, out temperature of secondary side (district cooling network)
- ``ch``, capacity mass flow rate secondary side
"""
if Q > 0:
eff = [0.1, 0]
Flag = False
tol = 0.00000001
while abs((eff[0] - eff[1]) / eff[0]) > tol:
if Flag == True:
eff[0] = eff[1]
else:
cmin = cc * (tco - tci) / ((thi - tci) * eff[0])
if cmin < cc:
ch = cmin
cmax = cc
else:
ch = cmin
cmax = cmin
cmin = cc
cr = cmin / cmax
NTU = UA / cmin
eff[1] = calc_shell_HEX(NTU, cr)
cmin = cc * (tco - tci) / ((thi - tci) * eff[1])
tho = thi - eff[1] * cmin * (thi - tci) / ch
Flag = True
tho = tho - 273
else:
tho = 0
ch = 0
return np.float(tho), np.float(ch / 1000)
[docs]def calc_dTm_HEX(thi, tho, tci, tco, flag):
'''
This function estimates the logarithmic temperature difference between two streams
:param thi: in temperature hot stream
:param tho: out temperature hot stream
:param tci: in temperature cold stream
:param tco: out temperature cold stream
:param flag: heat: when using for the heating case, 'cool' otherwise
:return:
dtm = logaritimic temperature difference
'''
dT1 = thi - tco
dT2 = tho - tci
if flag == 'heat':
dTm = (dT1 - dT2) / scipy.log(dT1 / dT2)
else:
dTm = (dT2 - dT1) / scipy.log(dT2 / dT1)
return abs(dTm.real)
[docs]def calc_area_HEX(Qnom, dTm_0, U):
"""
Thi function calculates the area of a het exchanger at nominal conditions.
:param Qnom: nominal load
:param dTm_0: nominal logarithmic temperature difference
:param U: coeffiicent of transmissivity
:return: - ``area``, area of heat exchange
- ``UA``, coefficient representing the area of heat exchanger times the coefficient of transmittance of the
heat exchanger
"""
area = Qnom / (dTm_0 * U) # Qnom in W
UA = U * area
return area, UA
[docs]def calc_DC_supply(t_0, t_1):
"""
This function calculates the temperature of the district cooling network according to the minimum observed
(different to zero) in all buildings connected to the grid.
:param t_0: last minimum temperature
:param t_1: current minimum temperature to evaluate
:return: ``tmin``, new minimum temperature
"""
if t_0 == 0:
t_0 = 1E6
if t_1 > 0:
tmin = min(t_0, t_1)
else:
tmin = t_0
return tmin
[docs]def calc_DH_supply(t_0, t_1):
"""
This function calculates the temperature of the district heating network according to the maximum observed
in all buildings connected to the grid.
:param t_0: last maximum temperature
:param t_1: current maximum temperature
:return: ``tmax``, new maximum temperature
"""
tmax = max(t_0, t_1)
return tmax