# test example python script for use in CSS/BOY
# accessing a file using environ variable to point
# to the location of the file, read from file and
# show how to access a PV linked to the script as
# PV trigger.
#
# make sure that DBHOME is defined to the location
# where the file hvdb.txt is locatate. 

from org.csstudio.opibuilder.scriptUtil import PVUtil
from org.csstudio.opibuilder.scriptUtil import ConsoleUtil
from org.csstudio.utility.pv import PVFactory
import re
import os
import time
from threading import Thread

ConsoleUtil.writeInfo("cdcreadfromdatabase.py start!")
#s1 = dir(PVFactory)
#ConsoleUtil.writeInfo( str(s1) )
#l1 = PVFactory.getSupportedPrefixes()
#ConsoleUtil.writeInfo( str(l1) )

loc = os.getenv("DBHOME")
filename = loc+'/hvdb.txt'
inf = open(filename)

line = inf.readline()
line = inf.readline()
HVMainFrame = ['hv0','hv0','hv0','hv0','hv0','hv0','hv0']
HVModule = [0,0,0,0,0,0,0]
idx = 0;
lastline = line
line = inf.readline()
while (line):
	s = re.split("\s+",line)
	#ConsoleUtil.writeInfo(line+"  :"+s[0])
	if (re.match("CDC",s[0])):
		#ConsoleUtil.writeInfo(line)
		lastline = line
		if (s[5] == '23'):
			HVMainFrame[idx] = s[3]
 			HVModule[idx] = s[4]
			idx = idx+1
	line = inf.readline()

s = re.split("\s+",lastline)
HVMainFrame[6] = s[3]
HVModule[6] = s[4]

#for i in range(0,7) :
#	ConsoleUtil.writeInfo( HVMainFrame[i]+":"+str(HVModule[i]))

a1 = PVUtil.getString(pvs[0])

ConsoleUtil.writeInfo( "a1 is "+a1)


def accpv(str1):
	#access an arbitrary pv not associated with the current widget
	#str1 = "hv1:0:0:status"
	ConsoleUtil.writeInfo( "start thread with "+str1)
	pvN = PVFactory.createPV(str1)
	print "after PVFactory"
	pvN.start()
	print "after start()"
	cnt = 0
	status1 = pvN.isConnected()
	ConsoleUtil.writeInfo( "status is "+status1)

	while (( not (status1)) and (cnt<20) ):
	       	cnt += 1
	       	time.sleep(0.1)
	       	status1 = pvN.isConnected()
		ConsoleUtil.writeInfo(str(cnt)) 
			
		
	if (cnt<20):
	       	ConsoleUtil.writeInfo( "epics variable is connected!")
	       	val = pvN.getValue()
	       	ConsoleUtil.writeInfo( "and the value is "+val)
       	else:
       		ConsoleUtil.writeInfo( "epics variable is NOT connected!")

       	pvN.stop()

t = Thread(target=accpv, args=("hv1:0:0:status",))
t.start()