source: anuga_work/production/tonga/run_fangauta.py @ 6748

"""Script for running tsunami inundation scenario for Dampier, WA, Australia.

Source data such as elevation and boundary data is assumed to be available in
directories specified by project.py
The output sww file is stored in project.output_run_time_dir 

The scenario is defined by a triangular mesh created from project.polygon,
the elevation data and a simulated tsunami generated with URS code.

Ole Nielsen and Duncan Gray, GA - 2005 and Jane Sexton, Nick Bartzis, GA - 2006
"""

#------------------------------------------------------------------------------
# Import necessary modules
#------------------------------------------------------------------------------

# Standard modules
from os import sep
from os.path import dirname, basename
from os import mkdir, access, F_OK
from shutil import copy
import time
import sys
from math import radians

# Related major packages
from anuga.shallow_water import Time_boundary
from anuga.shallow_water import Domain
from anuga.shallow_water import Dirichlet_boundary
from anuga.shallow_water import Transmissive_boundary
from anuga.shallow_water import File_boundary
from anuga.shallow_water import Reflective_boundary
from anuga.shallow_water import Field_boundary
from Numeric import allclose
from anuga.shallow_water.data_manager import export_grid
from anuga.shallow_water.data_manager import convert_dem_from_ascii2netcdf, dem2pts
from anuga.pmesh.mesh_interface import create_mesh_from_regions
from anuga.shallow_water.data_manager import start_screen_catcher, copy_code_files,store_parameters
from anuga_parallel.parallel_api import distribute, numprocs, myid, barrier
from anuga_parallel.parallel_abstraction import get_processor_name
from anuga.caching import myhash
from anuga.damage_modelling.inundation_damage import add_depth_and_momentum2csv, inundation_damage
from anuga.fit_interpolate.benchmark_least_squares import mem_usage 

# Application specific imports
import project_fangauta                 # Definition of file names and polygons

def run_model(**kwargs):
    

    #------------------------------------------------------------------------------
    # Copy scripts to time stamped output directory and capture screen
    # output to file
    #------------------------------------------------------------------------------
    print "Processor Name:",get_processor_name()

    #copy script must be before screen_catcher
    #print kwargs

    print 'output_dir',kwargs['output_dir']
    if myid == 0:
        copy_code_files(kwargs['output_dir'],__file__, 
                 dirname(project_fangauta.__file__)+sep+ project_fangauta.__name__+'.py' )

        store_parameters(**kwargs)

    barrier()

    start_screen_catcher(kwargs['output_dir'], myid, numprocs)

    print "Processor Name:",get_processor_name()

    # filenames
#    meshes_dir_name = project.meshes_dir_name+'.msh'

    # creates copy of code in output dir
    print 'min triangles', project_fangauta.trigs_min,
    print 'Note: This is generally about 20% less than the final amount'

    #--------------------------------------------------------------------------
    # Create the triangular mesh based on overall clipping polygon with a
    # tagged
    # boundary and interior regions defined in project.py along with
    # resolutions (maximal area of per triangle) for each polygon
    #--------------------------------------------------------------------------
    
    if myid == 0:
    
        print 'start create mesh from regions'

        create_mesh_from_regions(project_fangauta.poly_all,
                             boundary_tags=project_fangauta.boundary_tags,
                             maximum_triangle_area=project_fangauta.res_poly_all,
                             filename=project_fangauta.meshes_dir_name+'.msh',
                             use_cache=False,
                             verbose=True)
    barrier()

    scenario='fixed_wave'
    
    #-------------------------------------------------------------------------
    # Setup computational domain
    #-------------------------------------------------------------------------
    print 'Setup computational domain'

    #domain = cache(Domain, (meshes_dir_name), {'use_cache':True, 'verbose':True}, verbose=True)
    #above don't work
    domain = Domain(project_fangauta.meshes_dir_name+'.msh', use_cache=False, verbose=True)
    print 'memory usage before del domain',mem_usage()
       
    print domain.statistics()
    print 'triangles',len(domain)
    
    kwargs['act_num_trigs']=len(domain)
    
    #-------------------------------------------------------------------------
    # Setup initial conditions
    #-------------------------------------------------------------------------
    if myid == 0:

        print 'Setup initial conditions'

        from polygon import Polygon_function
        #following sets the stage/water to be offcoast only
#        IC = Polygon_function( [(project.poly_mainland, -1.0)], default = kwargs['tide'],
#                                 geo_reference = domain.geo_reference)
#        domain.set_quantity('stage', IC)
        domain.set_quantity('stage',kwargs['tide'] )
#        domain.set_quantity('stage', kwargs['tide'])
        domain.set_quantity('friction', kwargs['friction']) 
        
        print 'Start Set quantity',kwargs['bathy_file']

        domain.set_quantity('elevation', 
                            filename = kwargs['bathy_file'],
                            use_cache = False,
                            verbose = True,
                            alpha = kwargs['alpha'])
        print 'Finished Set quantity'
    barrier()
    
    #------------------------------------------------------
    # Distribute domain to implement parallelism !!!
    #------------------------------------------------------

    if numprocs > 1:
        domain=distribute(domain)

    #------------------------------------------------------
    # Set domain parameters
    #------------------------------------------------------
    print 'domain id', id(domain)
    domain.set_name(kwargs['aa_scenario_name'])
    domain.set_datadir(kwargs['output_dir'])
    domain.set_default_order(2) # Apply second order scheme
    domain.set_minimum_storable_height(0.01) # Don't store anything less than 1cm
    domain.set_store_vertices_uniquely(False)
    domain.set_quantities_to_be_stored(['stage', 'xmomentum', 'ymomentum'])
    domain.tight_slope_limiters = 1
    #domain.set_maximum_allowed_speed(0.1) # Allow a little runoff (0.1 is OK)
    print 'domain id', id(domain)

      
    #-------------------------------------------------------------------------
    # Setup boundary conditions 
    #-------------------------------------------------------------------------
    print 'Available boundary tags', domain.get_boundary_tags()
    print 'domain id', id(domain)
    #print 'Reading Boundary file',project.boundaries_dir_namea + '.sww'
    Bt = Transmissive_boundary(domain)
    Br = Reflective_boundary(domain)
    Bd = Dirichlet_boundary([kwargs['tide'],0,0])
    Bo = Dirichlet_boundary([kwargs['tide']+5.0,0,0])
    
    from math import sin, pi
    Bw = Time_boundary(domain = domain,
                                f=lambda t: [0.5*sin(t*radians(2*pi/60)), 0, 0])
        
    domain.set_boundary({'land':Bt,'mouth':Bw})

    #----------------------------------------------------------------------------
    # Evolve system through time
    #--------------------------------------------------------------------
    import time
    t0 = time.time()
    
    for t in domain.evolve(yieldstep=10, finaltime = 10800): 
            domain.write_time()
            domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=21600,skip_initial_step=True):
                           
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/180)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=32400,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/300)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=43200,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/420)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            
     
    for t in domain.evolve(10,finaltime=54001,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/540)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            
                          
    for t in domain.evolve(10,finaltime=64800,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/660)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=75600,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/780)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=86400,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/900)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=97200,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/1020)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            

    for t in domain.evolve(10,finaltime=108000,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/1140)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
                            
    for t in domain.evolve(10,finaltime=11800,skip_initial_step=True):
        Bw = Time_boundary(domain = domain,
                                        f=lambda t: [0.5*sin(t*radians(2*pi/1260)), 0, 0])
        domain.set_boundary({'land':Bt,'mouth':Bw})
        domain.write_time()
        domain.write_boundary_statistics(tags = 'mouth')
        
    x, y = domain.get_maximum_inundation_location()
    q = domain.get_maximum_inundation_elevation()

    print 'Maximum runup observed at (%.2f, %.2f) with elevation %.2f' %(x,y,q)

    print 'That took %.2f seconds' %(time.time()-t0)

    #kwargs 'completed' must be added to write the final parameters to file
    kwargs['completed']=str(time.time()-t0)
    
    if myid==0:
        store_parameters(**kwargs)
    barrier
    
    print 'memory usage before del domain1',mem_usage()

def export_model(**kwargs):    
    #store_parameters(**kwargs)
    
#    print 'memory usage before del domain',mem_usage()
    #del domain
    print 'memory usage after del domain',mem_usage()
    
    swwfile = kwargs['output_dir']+kwargs['aa_scenario_name']
    print'swwfile',swwfile
    
    export_grid(swwfile, extra_name_out = 'town',
            quantities = ['speed','depth','elevation','stage'], # '(xmomentum**2 + ymomentum**2)**0.5' defaults to elevation
            #quantities = ['speed','depth'], # '(xmomentum**2 + ymomentum**2)**0.5' defaults to elevation
            timestep = None,
            reduction = max,
            cellsize = kwargs['export_cellsize'],
            NODATA_value = -1E-030,
            easting_min = project_fangauta.eastingmin,
            easting_max = project_fangauta.eastingmax,
            northing_min = project_fangauta.northingmin,
            northing_max = project_fangauta.northingmax,
            verbose = False,
            origin = None,
            datum = 'WGS84',
            format = 'asc')
    
#-------------------------------------------------------------
if __name__ == "__main__":
    
    kwargs={}
    kwargs['est_num_trigs']=project_fangauta.trigs_min
    kwargs['num_cpu']=numprocs
    kwargs['host']=project_fangauta.host
    kwargs['res_factor']=project_fangauta.res_factor
    kwargs['starttime']=project_fangauta.starttime
    kwargs['yieldstep']=project_fangauta.yieldstep
    kwargs['midtime']=project_fangauta.midtime
    kwargs['finaltime']=project_fangauta.finaltime
    kwargs['output_dir']=project_fangauta.output_run_time_dir
    kwargs['bathy_file']=project_fangauta.combined_dir_name+'.txt'
#    kwargs['bathy_file']=project.combined_small_dir_name + '.pts'
    kwargs['boundary_file']=project_fangauta.boundaries_in_dir_name + '.sww'
    kwargs['file_name']=project_fangauta.home+'detail.csv'
    kwargs['aa_scenario_name']=project_fangauta.scenario_name
    kwargs['ab_time']=project_fangauta.time
    kwargs['res_factor']= project_fangauta.res_factor
    kwargs['tide']=project_fangauta.tide
    kwargs['user']=project_fangauta.user
    kwargs['alpha'] = project_fangauta.alpha
    kwargs['friction']=project_fangauta.friction
    kwargs['time_thinning'] = project_fangauta.time_thinning
    kwargs['dir_comment']=project_fangauta.dir_comment
    kwargs['export_cellsize']=project_fangauta.export_cellsize

    run_model(**kwargs)
      
    if myid==0:
        export_model(**kwargs)
    barrier