Feature/price based res support

.gitignore

@@ -5,4 +5,5 @@
 */.project
 */.settings
 facedb.lck
-doxygenDoc
+doxygenDoc
+*/.Rapp.history

emlab-generation/.gitignore

@@ -2,3 +2,4 @@
 *.log
 log.roo
 facedb.properties
+/target/

emlab-generation/.settings/org.eclipse.jdt.core.prefs

@@ -9,6 +9,10 @@ org.eclipse.jdt.core.codeComplete.staticFieldPrefixes=
 org.eclipse.jdt.core.codeComplete.staticFieldSuffixes=
 org.eclipse.jdt.core.codeComplete.staticFinalFieldPrefixes=
 org.eclipse.jdt.core.codeComplete.staticFinalFieldSuffixes=
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+org.eclipse.jdt.core.compiler.compliance=1.6
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.source=1.6
 org.eclipse.jdt.core.formatter.align_type_members_on_columns=false
 org.eclipse.jdt.core.formatter.alignment_for_arguments_in_allocation_expression=16
 org.eclipse.jdt.core.formatter.alignment_for_arguments_in_annotation=0

emlab-generation/.settings/org.eclipse.jdt.ui.prefs

@@ -78,25 +78,28 @@ sp_cleanup.always_use_blocks=true
 sp_cleanup.always_use_parentheses_in_expressions=false
 sp_cleanup.always_use_this_for_non_static_field_access=false
 sp_cleanup.always_use_this_for_non_static_method_access=false
+sp_cleanup.convert_functional_interfaces=false
 sp_cleanup.convert_to_enhanced_for_loop=false
 sp_cleanup.correct_indentation=true
 sp_cleanup.format_source_code=true
-sp_cleanup.format_source_code_changes_only=true
+sp_cleanup.format_source_code_changes_only=false
+sp_cleanup.insert_inferred_type_arguments=false
 sp_cleanup.make_local_variable_final=false
 sp_cleanup.make_parameters_final=false
 sp_cleanup.make_private_fields_final=true
 sp_cleanup.make_type_abstract_if_missing_method=false
 sp_cleanup.make_variable_declarations_final=true
 sp_cleanup.never_use_blocks=false
 sp_cleanup.never_use_parentheses_in_expressions=true
-sp_cleanup.on_save_use_additional_actions=true
+sp_cleanup.on_save_use_additional_actions=false
 sp_cleanup.organize_imports=true
 sp_cleanup.qualify_static_field_accesses_with_declaring_class=false
 sp_cleanup.qualify_static_member_accesses_through_instances_with_declaring_class=true
 sp_cleanup.qualify_static_member_accesses_through_subtypes_with_declaring_class=true
 sp_cleanup.qualify_static_member_accesses_with_declaring_class=false
 sp_cleanup.qualify_static_method_accesses_with_declaring_class=false
 sp_cleanup.remove_private_constructors=true
+sp_cleanup.remove_redundant_type_arguments=false
 sp_cleanup.remove_trailing_whitespaces=true
 sp_cleanup.remove_trailing_whitespaces_all=true
 sp_cleanup.remove_trailing_whitespaces_ignore_empty=false
@@ -110,10 +113,13 @@ sp_cleanup.remove_unused_private_methods=true
 sp_cleanup.remove_unused_private_types=true
 sp_cleanup.sort_members=false
 sp_cleanup.sort_members_all=false
+sp_cleanup.use_anonymous_class_creation=false
 sp_cleanup.use_blocks=false
 sp_cleanup.use_blocks_only_for_return_and_throw=false
+sp_cleanup.use_lambda=false
 sp_cleanup.use_parentheses_in_expressions=false
 sp_cleanup.use_this_for_non_static_field_access=false
 sp_cleanup.use_this_for_non_static_field_access_only_if_necessary=true
 sp_cleanup.use_this_for_non_static_method_access=false
 sp_cleanup.use_this_for_non_static_method_access_only_if_necessary=true
+sp_cleanup.use_type_arguments=false

emlab-generation/facedb.script

@@ -35,7 +35,7 @@ CREATE SCHEMA PUBLIC AUTHORIZATION DBA
 CREATE SCHEMA AGENTSPRING_FACE AUTHORIZATION DBA
 SET SCHEMA AGENTSPRING_FACE
 CREATE MEMORY TABLE AGENTSPRING_FACE.SOURCES(ID INTEGER GENERATED BY DEFAULT AS IDENTITY(START WITH 0) NOT NULL PRIMARY KEY,TITLE VARCHAR(45) DEFAULT NULL,START VARCHAR(45) DEFAULT NULL,SCRIPT VARCHAR(16777216) NOT NULL)
-ALTER TABLE AGENTSPRING_FACE.SOURCES ALTER COLUMN ID RESTART WITH 73
+ALTER TABLE AGENTSPRING_FACE.SOURCES ALTER COLUMN ID RESTART WITH 74
 CREATE MEMORY TABLE AGENTSPRING_FACE.VISUALS(ID INTEGER GENERATED BY DEFAULT AS IDENTITY(START WITH 0) NOT NULL PRIMARY KEY,TITLE VARCHAR(45) DEFAULT NULL,CLASS VARCHAR(45) DEFAULT NULL,TYPE VARCHAR(45) DEFAULT NULL,YAXIS VARCHAR(45) DEFAULT NULL)
 ALTER TABLE AGENTSPRING_FACE.VISUALS ALTER COLUMN ID RESTART WITH 41
 CREATE MEMORY TABLE AGENTSPRING_FACE.VISUALS_SOURCES(VISUAL INTEGER NOT NULL,SOURCE INTEGER NOT NULL,PRIMARY KEY(VISUAL,SOURCE),FOREIGN KEY(VISUAL) REFERENCES AGENTSPRING_FACE.VISUALS(ID) ON DELETE CASCADE,FOREIGN KEY(SOURCE) REFERENCES AGENTSPRING_FACE.SOURCES(ID))
@@ -113,6 +113,7 @@ INSERT INTO SOURCES VALUES(69,'MarketStabilityReserve','Government','["Mark
 INSERT INTO SOURCES VALUES(70,'RevenuesProfitA','BigBank','flows = n.getNodes('CashFlow');\u000agroups = flows.groupBy{it.type}\u000aresult = [];\u000atotalCosts = 0;\u000atotalRevenue = 0;\u000atotalSpotRevenue = 0;\u000atotalLTCRevenue = 0;\u000atotalCMRevenue = 0;\u000atotalRESRevenue=0;\u000atotalCO2HedgingRevenue=0;\u000afor (key in groups.keySet()) {\u000a    if (key<3 || key>9) {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('TO_AGENT').collect{it.__type__.contains('EnergyProducer')}[0] && flow.out('TO_AGENT').out('INVESTOR_MARKET').out('ZONE').collect{it.name.equals('Country A')}[0]) {\u000a                totalRevenue += flow.money;\u000a            }\u000a        }\u000a        \u000a    } else {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('FROM_AGENT').collect{it.__type__.contains('EnergyProducer')}[0] && flow.out('FROM_AGENT').out('INVESTOR_MARKET').out('ZONE').collect{it.name.equals('Country A')}[0]) {\u000a                totalCosts += flow.money;\u000a            }\u000a        }\u000a    }\u000a       \u000a     if (key==1) {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('TO_AGENT').collect{it.__type__.contains('EnergyProducer')}[0] && flow.out('TO_AGENT').out('INVESTOR_MARKET').out('ZONE').collect{it.name.equals('Country A')}[0]) {\u000a                totalSpotRevenue += flow.money;\u000a            }\u000a        }\u000a        \u000a    }\u000a    \u000a     if (key==2) {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('TO_AGENT').collect{it.__type__.contains('EnergyProducer')}[0] && flow.out('TO_AGENT').out('INVESTOR_MARKET').out('ZONE').collect{it.name.equals('Country A')}[0]) {\u000a                totalLTCRevenue += flow.money;\u000a            }\u000a        }\u000a        \u000a    }\u000a    \u000a         if (key==11) {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('TO_AGENT').collect{it.__type__.contains('EnergyProducer')}[0] && flow.out('TO_AGENT').out('INVESTOR_MARKET').out('ZONE').collect{it.name.equals('Country A')}[0]) {\u000a                totalCMRevenue += flow.money;\u000a            }\u000a        }\u000a        \u000a    }\u000a    \u000a        \u000a             if (key==10) {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('TO_AGENT').collect{it.__type__.contains('EnergyProducer')}[0] && flow.out('TO_AGENT').out('INVESTOR_MARKET').out('ZONE').collect{it.name.equals('Country A')}[0]) {\u000a                totalRESRevenue += flow.money;\u000a            }\u000a        }\u000a        \u000a    }\u000a\u000aif (key==12) {\u000a        for (flow in groups[key]) {\u000a            if (flow.time != tick) continue;\u000a            if (flow.out('TO_AGENT').collect{it.__type__.contains('EnergyProducer')}[0]) {\u000a                totalCO2HedgingRevenue += flow.money;\u000a            }\u000a        }\u000a        }\u000a\u000a}\u000aresult.add(['Total Revenue', totalRevenue]);\u000aresult.add(['Revenue LTC', totalLTCRevenue]);\u000aresult.add(['Revenue Spot', totalSpotRevenue]);\u000aresult.add(['Revenue CM', totalCMRevenue])\u000aresult.add(['Revenue RES',totalRESRevenue])\u000aresult.add(['Revenue CO2Hedge', totalCO2HedgingRevenue]);\u000aresult.add(['Profit', totalRevenue - totalCosts]);\u000areturn result;')
 INSERT INTO SOURCES VALUES(71,'WindNodeInstallations','PowerGridNode','capacity=v.in('LOCATION').as('x').out('TECHNOLOGY').filter{it.name=='Wind'}.back('x').sum{it.actualNominalCapacity}\u000aif(capacity == null) capacity = 0\u000a[v.name, capacity]')
 INSERT INTO SOURCES VALUES(72,'OriginalCO2Cap','Government','cap=0\u000atry{cap = v.out("CO2CAP_TREND").collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){    \u000acap=v.out("CO2CAP_TREND").timeSeries.next()[tick.toInteger()];}\u000atry{capReduction = v.out("CO2CAPADJUSTMENT_TIMESERIES").timeSeries.next()[tick.toInteger()]} catch(Exception e){\u000a    capReduction=0\u000a}\u000areturn ["Original CO2 cap", cap+capReduction]')
+INSERT INTO SOURCES VALUES(73,'CheckQuery','PowerGridNode','v.in('LOCATION').as('x').out('TECHNOLOGY') //.filter{it==g.v(tech)}.back('x').filter{(it.dismantleTime > tick) && ((tick - (it.constructionStartTime + it.actualPermittime + it.actualLeadtime)) <= 2)}')
 INSERT INTO VISUALS VALUES(0,'Producer Cash Balance','chart','line','Euro')
 INSERT INTO VISUALS VALUES(1,'Producer Revenue','chart','area','EUR')
 INSERT INTO VISUALS VALUES(2,'CO2 Cap and Emissions','chart','line','')

emlab-generation/queries-Ranalysis.properties

@@ -831,4 +831,16 @@ segmentID=s.out('SEGMENTLOAD_SEGMENT').collect{it.segmentID}[0]
 hours=s.out('SEGMENTLOAD_SEGMENT').collect{it.lengthInHours}[0]
 finalResult.add([tick, s.baseLoad*growthfactor, market, segmentID, hours])
 }
-return finalResult",
+return finalResult",
+
+"TABLE_FinancialReports", "DecarbonizationModel", "financialReports=g.idx('__types__')[[className:'emlab.gen.domain.market.electricity.FinancialPowerPlantReport']].filter{it.time==tick};
+finalResult = [];
+columnNames=['tick', 'spotMarketRevenue', 'capacityMarketRevenue', 'strategicReserveRevenue', 'co2HedgingRevenue', 'overallRevenue','commodityCosts','co2Costs','variableCosts','fixedCosts','fullLoadHours','production','powerPlantName','technology','location','powerPlantOwner','operationalStatus','firstYearOfPowerPlantOperation','nominalCapacity','investedCapital'];
+finalResult.add(columnNames);
+for(v in financialReports){
+firstYearOfOperation=v.out('FINANCIALREPORT_POWERPLANT').constructionStartTime.next()+v.out('FINANCIALREPORT_POWERPLANT').actualPermittime.next()+v.out('FINANCIALREPORT_POWERPLANT').actualLeadtime.next()
+powerPlantSize=v.out('FINANCIALREPORT_POWERPLANT').actualNominalCapacity.next()
+actualInvestedCapital=v.out('FINANCIALREPORT_POWERPLANT').actualInvestedCapital.next()
+finalResult.add([v.time, v.spotMarketRevenue, v.capacityMarketRevenue, v.strategicReserveRevenue, v.co2HedgingRevenue, v.overallRevenue, v.commodityCosts, v.co2Costs, v.variableCosts, v.fixedCosts, v.fullLoadHours, v.production, v.out('FINANCIALREPORT_POWERPLANT').name.next(),v.out('FINANCIALREPORT_POWERPLANT').out('TECHNOLOGY').name.next(),v.out('FINANCIALREPORT_POWERPLANT').out('LOCATION').name.next(),v.out('FINANCIALREPORT_POWERPLANT').out('POWERPLANT_OWNER').name.next(),v.powerPlantStatus,firstYearOfOperation,powerPlantSize,actualInvestedCapital]);
+};
+return finalResult;",

emlab-generation/queries.properties

@@ -38,62 +38,10 @@ return productionsum;",
 
 "MarketStabilityReserve", "Government", "return v.stabilityReserve",
 
-"MsrUpperTriggerinTonPA", "Government", "try{cap = v.out('STABILITY_RESERVE_UPPER_TRIGGER').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){    
-cap=v.out('STABILITY_RESERVE_UPPER_TRIGGER').timeSeries.next()[tick.toInteger()]}
-model = points = g.idx('__types__')[[className:'emlab.gen.domain.agent.DecarbonizationModel']].next()
-msrActive = model.stabilityReserveIsActive && (tick >= model.stabilityReserveFirstYearOfOperation)
-if(msrActive){
-    return cap
-} else{
-    return 'NA'
-}",
-
-"MsrAddingPercentage", "Government", "try{cap = v.out('STABILITY_RESERVE_ADDING_PERCENTAGE').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){    
-cap=v.out('STABILITY_RESERVE_ADDING_PERCENTAGE').timeSeries.next()[tick.toInteger()]}
-model = points = g.idx('__types__')[[className:'emlab.gen.domain.agent.DecarbonizationModel']].next()
-msrActive = model.stabilityReserveIsActive && (tick >= model.stabilityReserveFirstYearOfOperation)
-if(msrActive){
-    return cap
-} else{
-    return 'NA'
-}",
-
-"MsrLowerTriggerinTonPA", "Government", "try{cap = v.out('STABILITY_RESERVE_LOWER_TRIGGER').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){    
-cap=v.out('STABILITY_RESERVE_LOWER_TRIGGER').timeSeries.next()[tick.toInteger()]}
-model = points = g.idx('__types__')[[className:'emlab.gen.domain.agent.DecarbonizationModel']].next()
-msrActive = model.stabilityReserveIsActive && (tick >= model.stabilityReserveFirstYearOfOperation)
-if(msrActive){
-    return cap
-} else{
-    return 'NA'
-}",
-
-"MsrReleaseQuantityTonPA", "Government", "try{cap = v.out('STABILITY_RESERVE_RELEASE_QUANTITY').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){    
-cap=v.out('STABILITY_RESERVE_RELEASE_QUANTITY').timeSeries.next()[tick.toInteger()]}
-model = points = g.idx('__types__')[[className:'emlab.gen.domain.agent.DecarbonizationModel']].next()
-msrActive = model.stabilityReserveIsActive && (tick >= model.stabilityReserveFirstYearOfOperation)
-if(msrActive){
-    return cap
-} else{
-    return 'NA'
-}",
-
 "CO2CapinTonpA", "Government", "try{cap = v.out('CO2CAP_TREND').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){
 cap = v.out('CO2CAP_TREND').timeSeries.next()[tick.toInteger()];}
 return ['CO2_cap', cap]",
 
-"OriginalCO2CapinTonpA", "Government", "cap=0
-try{cap = v.out('CO2CAP_TREND').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){    
-cap=v.out('CO2CAP_TREND').timeSeries.next()[tick.toInteger()];}
-try{capReduction = v.out('CO2CAPADJUSTMENT_TIMESERIES').timeSeries.next()[tick.toInteger()]} catch(Exception e){
-    capReduction=0
-}
-return ['OriginalCO2Cap', cap+capReduction]",
-
-"CO2CapReductioninTonpA", "Government", "try{capReduction = v.out('CO2CAPADJUSTMENT_TIMESERIES').timeSeries.next()[tick.toInteger()]} catch(Exception e){
-    capReduction=0}
-return ['Co2CapReductioninTonpA', capReduction]",
-
 "NationalMinCO2PriceinEURpTon", "NationalGovernment","try{price = v.out('MINCO2PRICE_TREND').collect{f.getTrendValue(it, tick)}[0];} catch(Exception e){  
 price = v.out('MINCO2PRICE_TREND').timeSeries.next()[tick.toInteger()];}
 return [v.out('GOVERNED_ZONE').collect{it.name}[0], price];",
@@ -131,15 +79,7 @@ return [v.name, sum]",
 if(!point.hasNext()){price = 0} else {price=point.next().getProperty('price')}
 return price",
 
-"MsrEmergencyTrigger", "CO2Auction", "point=v.in('MARKET_POINT').filter{it.time==tick && it.forecast==false}
-if(!point.hasNext()){emergencyTrigger=false} else {emergencyTrigger=point.next().getProperty('emergencyTriggerActivated')}
-return emergencyTrigger",
-
-"MsrEmergencyTriggerOutflow", "CO2Auction", "point=v.in('MARKET_POINT').filter{it.time==tick && it.forecast==false}
-if(!point.hasNext()){outflow = 0} else {outflow=point.next().getProperty('emergencyTriggerOutflow')}
-return outflow",
-
-"Forc_CO2Auction", "CO2Auction", "point=v.in('MARKET_POINT').filter{it.time==tick+3 && it.forecast==true}
+"Forc_CO2Auction", "CO2Auction", "point=v.in('MARKET_POINT').filter{it.time==tick && it.forecast==true}
 if(!point.hasNext()){price = 0} else {price=point.next().getProperty('price')}
 return price",