import datetime
|
|
from pub.extactJSON import ParserMOI as moiParser
|
from pub.queryMoi import QueryElevation as moiEvApi
|
from pub.postgis import Dbconnect
|
|
from parser import Updateev0
|
from parser import GetMoiEvBy84
|
|
class Db():
|
|
def __init__(self,dbConf):
|
self.dbConf=dbConf
|
self.updateid=0
|
self.dtStart=datetime.datetime.now()
|
self.dtNext=datetime.datetime.now()
|
|
def resetTabelEv(self,tablename,dbSRS='3826',srcgeom='geom',desgeom='geom'):
|
#print (self.dbConf)
|
self.gis3d= Dbconnect()
|
print('setEv')
|
self.gis3d.tryConn(self.dbConf)
|
|
print('db ok')
|
poi= Updateev0 (tablename,self.updDB,dbSRS=dbSRS,srcgeom=srcgeom,desgeom=desgeom) #self.writeFile)
|
|
#other connection
|
self.gis3d.fetchTable( self.dbConf,
|
poi.sql_sel() ,
|
fnProc=poi
|
)
|
self.gis3d.destroyConn()
|
|
def getTableEv(self,tablename,limit=100,dbSRS='3826',srcgeom='geom',desgeom='geom'):
|
|
self.gis3d= Dbconnect()
|
print('getEv')
|
|
self.gis3d.tryConn(self.dbConf)
|
|
print('db ok,limit={},srs={}'.format(limit,dbSRS))
|
|
poi= GetMoiEvBy84 (tablename,self.updDB,limit=limit,fnErr=self.writeFile,dbSRS=dbSRS,srcgeom=srcgeom,desgeom=desgeom) #self.writeFile) #self.updDB) #self.writeFile)
|
#poi= GetMoiEvBy84 (tablename,self.writeFile,limit=limit,fnErr=self.writeFile,dbSRS=dbSRS,srcgeom=srcgeom,desgeom=desgeom) #self.writeFile) #self.updDB) #self.writeFile)
|
|
self.dtStart=datetime.datetime.now()
|
#other connection
|
self.gis3d.fetchTable( self.dbConf,
|
poi.sql_sel() ,
|
fnProc=poi
|
)
|
print ('total {}'.format(datetime.datetime.now()-self.dtStart))
|
self.gis3d.destroyConn()
|
|
|
def updDB(self,sql_upd,wkt,id,table):
|
|
#print('update id',id)
|
#self.updateid=self.updateid+1
|
if(self.updateid % 100 == 0):
|
dtnow= datetime.datetime.now()
|
print('count:',self.updateid,'{}({})({} @ {})'.format(table,id,dtnow-self.dtNext, dtnow-self.dtStart))
|
self.dtNext=datetime.datetime.now()
|
|
self.updateid=self.updateid+1
|
#print ('update!{}'.format(id,wkt))
|
self.gis3d.executeWithConn(sql_upd.format(wkt,id))
|
# # print('nothing')
|
|
def writeFile(self,sql_upd,wkt,id,table):
|
#print('writefile',id)
|
print(id)
|
fname='logs/{}.{}.log'.format(table,self.dtStart.strftime('%Y%m%d_%H%M%S') )
|
print ('error@({})-->{}'.format(id,fname ) )
|
fp = open(fname, "a")
|
lines =[sql_upd.format(wkt,id),";\n"]
|
# ["One\n", "Two\n", "Three\n", "Four\n", "Five\n"]
|
fp.writelines(lines)
|
fp.close()
|
