8 from TileCoolDcs
import TileDCSDataInfo
13 re_ai = re.compile(
"ATLTILLV(\\d{2})(:ELMB/LVCAN.*_)(\\d*)/AI/M5VMB_TEMP2.value")
14 re_states = re.compile(
"ATLTILLV(\\d{2})(:ELMB/LVCAN.*_)(\\d*)/states.ForDAQ_MBHV")
15 re_hv = re.compile(
"ATLTILLV(\\d{2}):Drawer(\\d*).Readings.Monitoring.hvOut1.value")
16 re_hvset = re.compile(
"ATLTILLV(\\d{2}):Drawer(\\d*).Readings.Requests.hvOut1.order")
17 re_daq = re.compile(
"ATLTILSCS:DAQ(.*).state")
20 partitionID = { 0 :
"EBA",
29 info = TileDCSDataInfo.TileDCSDataInfo()
30 dbstring=info.get_dbstring(
'ORACLE',
int(par[1])
if len(par)>1
and par[1].isdigit()
else 2)
35 print (
"Connecting to",dbstring[0])
37 db = ROOT.TSQLServer.Connect( dbstring[0], dbstring[1], dbstring[2])
40 statement =
"select ELEMENT_NAME, SYS_ID, DP_ID from ATLAS_PVSSTIL.elements"
41 stmt = db.Statement(statement)
42 if stmt.Process()
is True:
44 while stmt.NextResultRow():
46 element_name = stmt.GetString(0)
47 sys_id = stmt.GetString(1)
48 dp_id = stmt.GetString(2)
51 channel_id = dp_id + (
'000'+sys_id)[-3:]
54 result_ai = re_ai.search(element_name)
55 result_states = re_states.search(element_name)
56 result_hv = re_hv.search(element_name)
57 result_hvset = re_hvset.search(element_name)
58 result_daq = re_daq.search(element_name)
61 partition = partitionID[
int(result_ai.groups()[0])]
62 drawer = partition+(
'00'+result_ai.groups()[2])[-2:]
64 for part
in result_ai.groups():
67 buffer.append(
"/TILE/DCS/AI\t%s\t%s\t%s\n"%(drawer,channel_id,oracleId) )
70 partition = partitionID[
int(result_states.groups()[0])]
71 drawer = partition+(
'00'+result_states.groups()[2])[-2:]
73 for part
in result_states.groups():
76 buffer.append(
"/TILE/DCS/STATES\t%s\t%s\t%s\n"%(drawer,channel_id,oracleId) )
79 part = result_hv.groups()
80 partition = partitionID[
int(part[0])]
81 drawer = partition+(
'00'+part[1])[-2:]
82 oracleId =
"ATLTILLV"+part[0]
83 oracleId +=
":Drawer"+part[1]+
".Readings.Monitoring"
84 buffer.append(
"/TILE/DCS/HV\t%s\t%s\t%s\n"%(drawer,channel_id,oracleId) )
87 part = result_hvset.groups()
88 partition = partitionID[
int(part[0])]
89 drawer = partition+(
'00'+part[1])[-2:]
90 oracleId =
"ATLTILLV"+part[0]
91 oracleId +=
":Drawer"+part[1]+
".Readings.Requests"
92 buffer.append(
"/TILE/DCS/HVSET\t%s\t%s\t%s\n"%(drawer,channel_id,oracleId) )
95 part = result_daq.groups()
96 partition = part[0][:3]
97 oracleId =
"ATLTILSCS:DAQ"+partition+
".state"
99 drawer = partition +
"XX"
100 buffer.append(
"/DAQdummy/%s/DAQdummy\t%s\t%s\t%s\n"%(partition,drawer,channel_id,oracleId) )
104 oldname=info.find_data_file(
"cool_channel_id.dat")
105 newname=
"cool_channel_id.dat"
106 print (
"Old file:", oldname)
107 print (
"New file:", newname)