vpu_live.py 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716
  1. import math
  2. import random
  3. import time
  4. import os
  5. from optparse import OptionParser
  6. ...
  7. parser = OptionParser()
  8. parser.add_option("-m", "--mode", dest="mode",
  9. help="pixel mode") #, metavar="FILE")
  10. parser.add_option("-X", "--XX", dest="XX", #default=1,
  11. help="x-split") #, metavar="FILE")
  12. parser.add_option("-x", "--xx", dest="xsplit", #default=1,
  13. help="x-split") #, metavar="FILE")
  14. parser.add_option("-y", "--yy", dest="ysplit",#default=1,
  15. help="y-split") #, metavar="FILE")
  16. #parser.add_option("-f", "--file", dest="filename",
  17. # help="write report to FILE", metavar="FILE")
  18. #parser.add_option("-q", "--quiet",
  19. # action="store_false", dest="verbose", default=True,
  20. # help="don't print status messages to stdout")
  21. (options, args) = parser.parse_args()
  22. START = time.time()
  23. # ===== ARTNET DMX =========
  24. import memcache
  25. mc = memcache.Client(['127.0.0.1:11211'], debug=0)
  26. def read_index():
  27. ips=mc.get("index")#cmd)
  28. if ips is None:
  29. ips = {}
  30. #for k,v in ips.items():
  31. # print(k,v)
  32. return ips
  33. def select_ip(ips, univ=2): # artnet univ
  34. _univ = ":{}".format(univ)
  35. for ip in ips: #high priority
  36. if "2.0.0" in ip and _univ in ip:
  37. return ip
  38. for ip in ips:
  39. if "ltp-out" in ip and _univ in ip:
  40. return ip
  41. def read_dmx(ip):
  42. global frame
  43. r = ""
  44. if ip:
  45. #t = int(math.sin(time.time() - s)*10)
  46. r = mc.get(ip) #"2.0.0.13:2")
  47. frame += 1
  48. rr = [0]*512
  49. for i,v in enumerate(r):
  50. try: #cleanup ltp-out to int
  51. v = int(v)
  52. rr[i] = v
  53. except:pass
  54. r = rr
  55. if not r:
  56. c = 0
  57. #time.sleep(0.1)
  58. r = [0] *512
  59. for i in range(12*8+1):
  60. dmx = i*4
  61. #print(dmx)
  62. r[dmx:dmx+4] = [255,10,10,40]
  63. return r
  64. # ===== ARTNET DMX =========
  65. p = 16
  66. block = [p,p]
  67. _x = 8
  68. _y = 8
  69. #HD = "0"
  70. if options.mode:
  71. try:
  72. HD = options.mode
  73. p,_x,_y = HD.split(",")
  74. _x = int(_x)
  75. _y = int(_y)
  76. p = int(p)
  77. block = [p,p]
  78. except Exception as e:
  79. print( "Exc",options.mode,e)
  80. HD_x = 2
  81. HD_y = 2
  82. print( [options.xsplit])
  83. print( [options.ysplit])
  84. try:
  85. if options.xsplit:
  86. HD_x = int(options.xsplit)
  87. if options.ysplit:
  88. HD_y = int(options.ysplit)
  89. except Exception as e:
  90. print( "Exc",options.mode,e)
  91. print("HD",HD_x,HD_y)
  92. print("xy",_x,_y)
  93. print("++++++++++++++++++", p,_x,_y)
  94. _x2 = _x
  95. try:
  96. if options.XX:
  97. _x2 = int(options.XX)
  98. except Exception as e:
  99. print( "Exc",options.mode,e)
  100. print("_x2 , -X",_x2)
  101. # ===== GUI =========
  102. import pygame
  103. import pygame.gfxdraw
  104. import pygame.font
  105. os.environ['SDL_VIDEO_WINDOW_POS'] = '%i,%i' % (200,184)
  106. os.environ['SDL_VIDEO_CENTERED'] = '0'
  107. pg = pygame
  108. pygame.init()
  109. pygame.mixer.quit()
  110. f = pygame.font.get_fonts()
  111. for i in f:
  112. if "mono" in i.lower():
  113. print(i)
  114. font = pygame.font.SysFont("freemonobold",22)
  115. font10 = pygame.font.SysFont("freemonobold",10)
  116. font12 = pygame.font.SysFont("freemonobold",12)
  117. font15 = pygame.font.SysFont("freemonobold",15)
  118. #font = pygame.font.SysFont(None,30)
  119. fr = font.render("hallo" ,1, (200,0,255))
  120. main_size=(600,500)
  121. try:
  122. wx = 100+block[0] * _x
  123. wy = 100+block[1] * _y
  124. main_size=(wx,wy)
  125. except Exception as e:
  126. print("Exception:",e)
  127. #main_size=(280,200)
  128. window = pygame.display.set_mode(main_size,pg.RESIZABLE)#,32)#,pygame.FULLSCREEN) #x left->right ,y top-> bottom
  129. pg.display.set_caption('LibreLight LED-SCREEN')
  130. class Fix():
  131. def __init__(self,_id,pos,block=[16,16],univ=0,dmx=0,ch=4):
  132. #print("Fix",_id)
  133. self._id = _id
  134. self.dmx = (_id-1) * ch +1 #dmx
  135. self.univ = univ
  136. self.ch = ch
  137. self.pos = pos
  138. self.rgb = [0,0,140]
  139. self.block = block #[10,10]
  140. self.x = pos[0]
  141. self.y = pos[1]
  142. self.strobo = time.time()
  143. self.bmp = 250
  144. self.sub_fix = []
  145. sub_block =[block[0]/HD_x,block[1]/HD_y]
  146. spalte = (_id-1)%_y +1
  147. zeile = int((_id-1)/_x2) #+1
  148. #zeile = zeile*_x*HD_x*HD_y
  149. add_row = _x*HD_x*HD_y
  150. #zeile 1
  151. sid = (_id-1)*2 + zeile*HD_x*_x2
  152. #for i in range(1,HD_x):
  153. sid = sid+1
  154. #sid = zeile
  155. sub_pos= [pos[0]*block[0],pos[1]*block[1]]
  156. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  157. self.sub_fix.append(sub_fix)
  158. sid = sid+1
  159. #sid = zeile
  160. sub_pos= [pos[0]*block[0]+block[0]/2,pos[1]*block[1]]
  161. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  162. self.sub_fix.append(sub_fix)
  163. #zeile 2
  164. sid = (_id-1)*2+1 + _x2*HD_x + zeile*HD_x*_x2 # int(add_row)
  165. #sid = sid+1
  166. #sid = HD_x
  167. sub_pos= [pos[0]*block[0],pos[1]*block[1]+block[1]/2]
  168. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  169. self.sub_fix.append(sub_fix)
  170. #sid = sid+1
  171. sid = sid+1
  172. sub_pos= [pos[0]*block[0]+block[0]/2,pos[1]*block[1]+block[1]/2]
  173. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  174. self.sub_fix.append(sub_fix)
  175. def calc(self,data):
  176. _rgb = [0,255,0]
  177. return _rgb
  178. def sub_calc(self,data):
  179. _rgb = [0,255,0]
  180. for sub_fix in self.sub_fix:
  181. sub_fix.block = self.block[:]
  182. _rgb = sub_fix.calc(data)
  183. return _rgb
  184. def POS(self,x=0,y=0,a=0,b=0):
  185. A = (self.pos[0])*self.block[0]
  186. B = (self.pos[1])*self.block[1]
  187. C = self.block[0]-a
  188. D = self.block[1]-b
  189. return [x+A,y+B,C,D]
  190. def subPOS(self,x=0,y=0,a=0,b=0):
  191. __out = []
  192. for sub_fix in self.sub_fix:
  193. __out.append( sub_fix.POS(x,y,a,b) )
  194. return __out
  195. class SubFix():
  196. def __init__(self,_id,pos,block=[16,16],univ=0,dmx=0,ch=4):
  197. #print("Fix",_id)
  198. self._id = _id
  199. self.dmx = (_id-1) * ch +1 #dmx
  200. self.univ = univ
  201. self.ch = ch
  202. self.pos = pos
  203. self.rgb = [0,0,40]
  204. self.block = block #[10,10]
  205. self.x = pos[0]
  206. self.y = pos[1]
  207. self.strobo = time.time()
  208. self.bmp = 250
  209. def calc(self,data):
  210. #return [130,30,20]
  211. dmx_sub = [30]*10
  212. #print(dmx_sub)
  213. dmx = self.dmx -1
  214. _dmx_sub = []
  215. if self.dmx >= 0:
  216. dmx = rDMX(self.univ,self.dmx)-1
  217. if dmx+self.ch < len(data):
  218. _dmx_sub = data[dmx:dmx+self.ch]
  219. if _dmx_sub:
  220. dmx_sub = _dmx_sub
  221. #print(dmx_sub)
  222. dim = dmx_sub[0]/255
  223. #print("dmx",dmx,dmx_sub)
  224. r = dmx_sub[1]*dim
  225. g = dmx_sub[2]*dim
  226. b = dmx_sub[3]*dim
  227. r = int(r)
  228. g = int(g)
  229. b = int(b)
  230. self.rgb = [r,g,b]
  231. return self.rgb
  232. def POS(self,x=0,y=0,a=0,b=0):
  233. A = (self.pos[0]) #+self.block[0]
  234. B = (self.pos[1]) #+self.block[1]
  235. C = self.block[0]-a
  236. D = self.block[1]-b
  237. if NR:
  238. C-=1
  239. D-=1
  240. return [x+A,y+B,C,D]
  241. class POINTER():
  242. def __init__(self):
  243. self.pos = [0,0,0,0]
  244. self.on = 0
  245. self.rgb = [0,100,10]
  246. self._x = 0
  247. self._y = 0
  248. self.x = 0
  249. self.y = 0
  250. self.fix = Fix(0 ,[999,999],[16,16],0,0,0)
  251. def row_move(self,x,y):
  252. self._x = x
  253. self._y = y
  254. def move(self,pos):
  255. self.pos = pos
  256. self.on = 1
  257. def cross(self,x,y):
  258. self.x = x
  259. self.y = y
  260. def draw(self):
  261. if self.on:
  262. pygame.draw.rect(window,self.rgb,self.pos)
  263. #pygame.draw.line(window,self.rgb, (self.pos[0],self.pos[1]) , (self.pos[0]+100,self.pos[1]) )
  264. # mouse grid posision
  265. fr = font15.render("{}/{}".format(self.fix.x+1,self.fix.y) ,1, (200,200,200))
  266. _nr = self.fix.y * _x + self.fix.x +1
  267. #fr = font15.render("{:02} {}/{}".format(_nr, self.fix.x+1,self.fix.y+1 ) ,1, (200,200,200))
  268. fr = font15.render("{:02}".format(_nr ) ,1, (200,200,200))
  269. window.blit(fr,(self.pos[0]+2,self.pos[1]+2 ))
  270. window.blit(fr,(200,25))
  271. # fix pos
  272. txt=str(self.pos)
  273. fr = font15.render(txt ,1, (200,200,200))
  274. #window.blit(fr,(self.pos[0]+2,self.pos[1]+2 ))
  275. window.blit(fr,(200,10))
  276. # univers
  277. #fr = font15.render("{:02}:{:03}".format(self.fix.univ,self.fix.dmx) ,1, (200,200,200))
  278. #window.blit(fr,(300,10))
  279. # pointer
  280. fr = font15.render("X:{:03}".format(self._x) ,1, (200,200,200))
  281. window.blit(fr,(10,30))
  282. fr = font15.render("Y:{:03}".format(self._y) ,1, (200,200,200))
  283. window.blit(fr,(10,40))
  284. # crosshair
  285. self.rgb = [0,0,200]
  286. pygame.draw.line(window,self.rgb, (self.x-p,self.y) , (self.x-2,self.y) )
  287. pygame.draw.line(window,self.rgb, (self.x,self.y-p) , (self.x,self.y-2) )
  288. self.rgb = [0,200,0]
  289. pygame.draw.line(window,self.rgb, (self.x+2,self.y) , (self.x+p,self.y) )
  290. pygame.draw.line(window,self.rgb, (self.x,self.y+2) , (self.x,self.y+p) )
  291. self.rgb = [200,0,0]
  292. pointer = POINTER()
  293. NR = 0
  294. running = True
  295. def event():
  296. global NR,running
  297. for event in pygame.event.get():
  298. #print(event.dict)
  299. _button = None
  300. if "button" in event.dict:
  301. _button = event.dict["button"]
  302. _state = None
  303. if "state" in event.dict:
  304. _state = event.state
  305. _key = None
  306. if "key" in event.dict:
  307. _key = event.key
  308. _pos = None
  309. if "pos" in event.dict:
  310. _pos = event.pos
  311. _type = None
  312. if "type" in event.dict:
  313. _type = event.type
  314. _type = event.type
  315. _mod = None
  316. if "mod" in event.dict:
  317. _mod = event.mod
  318. print( " ")
  319. print( "{:.02f}".format( time.time() - START ))
  320. print("button -",_button,end="\t| ")
  321. #print("state -",_state)
  322. print("pos -",_pos)
  323. print("type -",_type, end="\t| ")
  324. print("key -",_key)
  325. print("mod -",_mod)
  326. try:
  327. if _type == 5:
  328. if _button == 1:
  329. NR += 1
  330. if NR > 1:
  331. NR = 0
  332. if _button == 3:
  333. NR -= 1
  334. if NR < 0:
  335. NR = 1
  336. if _pos:
  337. posA = _pos
  338. fix = find_pix(_pos[0]-40,_pos[1]-60)
  339. if fix:
  340. pos = fix.POS(40,60)
  341. rgb = [0,0,0]
  342. pointer.move(pos)
  343. pointer.fix = fix
  344. else:
  345. pointer.on = 0
  346. pointer.row_move(_pos[0],_pos[1])
  347. pointer.cross(_pos[0],_pos[1])
  348. except Exception as e:
  349. print(e)
  350. if event.type==pygame.QUIT:
  351. running=False
  352. fps = 0
  353. frame = 0
  354. frame_t = time.time()
  355. IP = "yyy"
  356. def draw_overlay():
  357. global fps
  358. fr = font.render("FPS:{}".format(fps) ,1, (200,0,255))
  359. window.blit(fr,(10,10))
  360. fr = font.render("ip:{}".format(IP) ,1, (200,0,255))
  361. window.blit(fr,(80,10))
  362. def calc_fps():
  363. global fps,frame,frame_t
  364. t = time.time()
  365. if frame_t+1 < t:
  366. fps = frame #frame_t- t #frame
  367. frame = 1
  368. frame_t = time.time()
  369. # ===== GUI =========
  370. #def draw_circle(surface, x, y, radius, color):
  371. def draw_circle(surface,color, pos, radius):
  372. x,y=pos
  373. pygame.gfxdraw.aacircle(surface, int(x), int(y), radius-1, color)
  374. pygame.gfxdraw.filled_circle(surface, int(x), int(y), radius-1, color)
  375. def rDMX(univ,dmx):
  376. return univ*512+dmx
  377. grid_file = "/tmp/vpu_grid.csv"
  378. grid_file = "/home/user/LibreLight/vpu_grid_hd.csv"
  379. def generate_grid():
  380. log = open(grid_file,"w")
  381. head = "i,univ,dmx,x,y,ch\n"
  382. head = "i,univ,dmx,ch\n"
  383. head = "univ,dmx,x,y,ch\n"
  384. head = "nr,id,info\n"
  385. print("csv:",head)
  386. log.write(head)
  387. dmx = 1-1
  388. ch = 4
  389. y=0
  390. x=0
  391. for i in range((_y)*(_x)):
  392. if x > _x and i%_x == 0:
  393. print("--> -->")
  394. x=0
  395. y+=1
  396. _univ = int(dmx/512)
  397. _dmx = dmx - (_univ)*512
  398. pos=[x,y]
  399. line="{},{},{},{},{},{}\n".format(i+1,_univ,_dmx+1,pos[0],pos[1],ch)
  400. line="{},{},{},{},{}\n".format(_univ,_dmx+1,x,y,ch)
  401. line="{},{},x\n".format(i+1,i+1)
  402. print("wcsv:",[line])
  403. log.write(line)
  404. dmx += ch
  405. x+=1
  406. log.close()
  407. return GRID
  408. def init_grid():
  409. try:
  410. log = open(grid_file,"r")
  411. except:
  412. generate_grid()
  413. log = open(grid_file,"r")
  414. lines = log.readlines()
  415. GRID = []
  416. y=0
  417. x=0
  418. print("CSV header",[lines[0]])
  419. for i,line in enumerate(lines[1:]): #exclude first line
  420. #print("rcsv",[line])
  421. line = line.strip()
  422. line = line.split(",") # csv
  423. if i >= _x and i%_x == 0:
  424. x=0
  425. y+=1
  426. if y > _y:
  427. break
  428. #i = int(line[0])
  429. _id = int(line[1])
  430. #univ = int(line[0])
  431. #dmx = int(line[1])
  432. #x = int(line[3])
  433. #y = int(line[4])
  434. #ch = int(line[4])
  435. pos = [x,y]
  436. f = Fix(_id,pos,block) #pos,univ,dmx,ch)
  437. #f.x = x
  438. #f.y = y
  439. #f.block = block
  440. GRID.append(f)
  441. x+=1
  442. #print("y, _y",y,_y)
  443. return GRID
  444. def find_pix(x,y):
  445. global GRID
  446. for fix in GRID:
  447. X = 0
  448. Y = 0
  449. pos = fix.POS()
  450. if x > pos[0] and x < pos[0]+pos[2]:
  451. X = 1
  452. if y > pos[1] and y < pos[1]+pos[3]:
  453. Y = 1
  454. if X and Y:
  455. print(pos,x,y)
  456. print("find",X,Y)
  457. return fix
  458. GRID = []
  459. NR = 0
  460. START_UNIV=2
  461. def main():
  462. global IP,GRID
  463. counter = time.time()
  464. GRID = init_grid() #init_gird()
  465. print("GRID LEN:",len(GRID))
  466. s=time.time()
  467. print("run")
  468. r = ""
  469. IP = "xx"
  470. while running:
  471. event()
  472. pygame.display.flip()
  473. window.fill((0,0,0))
  474. calc_fps()
  475. draw_overlay()
  476. ips = read_index()
  477. ip = select_ip(ips,univ=START_UNIV)
  478. IP = ip
  479. #print("IP",ip)
  480. data = read_dmx(ip)
  481. ip = select_ip(ips,univ=START_UNIV+1)
  482. data3 = read_dmx(ip)
  483. data.extend(data3)
  484. ip = select_ip(ips,univ=START_UNIV+2)
  485. data3 = read_dmx(ip)
  486. data.extend(data3)
  487. #ip = select_ip(ips,univ=START_UNIV+4)
  488. #data3 = read_dmx(ip)
  489. #data.extend(data3)
  490. # GRID loop
  491. i = 0
  492. dmx = 1
  493. h = 1
  494. v = 1
  495. for fix in GRID:
  496. pos = fix.POS(40,60)
  497. rgb = fix.rgb
  498. if 1:
  499. # draw row/col grid number
  500. if fix.pos[0] == 0:
  501. fr = font12.render("{}".format(fix.pos[1]+1) ,1, (200,200,200))
  502. window.blit(fr,(10,pos[1]+3 ))
  503. if fix.pos[1] == 0:
  504. fr = font12.render("{}".format(fix.pos[0]+1) ,1, (200,200,200))
  505. window.blit(fr,(pos[0]+2,35 ))
  506. pygame.draw.rect(window,rgb,pos)
  507. # DRAW SUB-FIXTURE
  508. j = 0
  509. for subfix in fix.sub_fix:#calc(data):
  510. subfix.calc(data)
  511. #fix = subfix
  512. spos = subfix.POS(40,60)
  513. srgb = subfix.rgb
  514. #print(fix.dmx,rgb,pos)
  515. pygame.draw.rect(window,srgb,spos)
  516. #pygame.draw.circle(window,rgb,(pos[0]+int(pos[2]/2),pos[1]+int(pos[3]/2)),int(pos[3]/2))
  517. #draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
  518. # draw row/col grid number
  519. if subfix.pos[0] == 0:
  520. fr = font12.render("{}".format(v ) ,1, (200,200,200))
  521. window.blit(fr,(25,spos[1] ))
  522. v += 1
  523. if subfix.pos[1] == 0:
  524. fr = font12.render("{}".format(1) ,1, (200,200,200))
  525. fr = font12.render("{}".format(h ) ,1, (200,200,200))
  526. h+=1
  527. window.blit(fr,(spos[0],50 ))
  528. if NR:
  529. #fr = font15.render("{:02}".format(j+1) ,1, (0,200,255))
  530. fr = font15.render("{:02}".format(subfix._id) ,1, (250,200,5))
  531. window.blit(fr,(spos[0]+2,spos[1]+10))
  532. j += 1
  533. i += 1
  534. # DRAW FIX NUMBER on TOP
  535. i=0
  536. for fix in GRID:
  537. pos = fix.POS(40,60)
  538. rgb = fix.rgb
  539. if NR:
  540. pygame.draw.rect(window,[0,0,0],[pos[0]+2,pos[1]+2,12,9])
  541. #if NR == 1:
  542. # fr = font15.render("{:02}".format(i+1) ,1, (200,0,255))
  543. # window.blit(fr,(pos[0]+2,pos[1]+2))
  544. #elif NR == 2:
  545. if NR:# == 2:
  546. if counter +5 < time.time():
  547. counter = time.time()
  548. try:
  549. GRID = init_grid() #init_gird()
  550. except Exception as e:
  551. print("Except: grid re init",e)
  552. if fix._id != i+1:
  553. fr = font15.render("{:02}".format(fix._id) ,1, (255,255,0))
  554. else:
  555. fr = font15.render("{:02}".format(fix._id) ,1, (100,100,255))
  556. window.blit(fr,(pos[0]+2,pos[1]+2))
  557. i += 1
  558. pointer.draw()
  559. pygame.display.flip()
  560. pg.time.wait(10)
  561. if __name__ == "__main__":
  562. main()