vpu_live.py 66 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329
  1. import math
  2. import random
  3. import time
  4. import os
  5. import sys
  6. import gc
  7. import _thread as thread
  8. from optparse import OptionParser
  9. ...
  10. parser = OptionParser()
  11. parser.add_option("-m", "--mode", dest="mode",
  12. help="pixel mode pix,x,y --mode 40,10,8") #, metavar="FILE")
  13. parser.add_option("-X", "--XX", dest="XX", #default=1,
  14. help="x-split") #, metavar="FILE")
  15. parser.add_option("-x", "--xx", dest="xsplit", #default=1,
  16. help="x-split") #, metavar="FILE")
  17. parser.add_option("-y", "--yy", dest="ysplit",#default=1,
  18. help="y-split") #, metavar="FILE")
  19. parser.add_option("", "--start-univ", dest="start_univ",#default=1,
  20. help="set start-univers default=2") #, metavar="FILE")
  21. parser.add_option("", "--gobo-ch", dest="gobo_ch",#default=1,
  22. help="gobo ch univ on 1") #, metavar="FILE")
  23. #os.environ['SDL_VIDEO_WINDOW_POS'] = '%i,%i' % (200,164)
  24. parser.add_option("", "--win-pos", dest="win_pos",default="200,164",
  25. help="SDL_VIDEO_WINDOW_POS --win-pos=200,164") #, metavar="FILE")
  26. parser.add_option("", "--pixel-mapping", dest="pixel_mapping",default=0,
  27. help="pixel_mapping file/on --pixel-mapping=_x") #, metavar="FILE")
  28. parser.add_option("", "--countdown", dest="countdown",#default=1,
  29. help="enable countdown") #, metavar="FILE")
  30. parser.add_option("", "--videoplayer", dest="videoplayer",#default=1,
  31. help="enable videoplayer") #, metavar="FILE")
  32. #parser.add_option("-f", "--file", dest="filename",
  33. # help="write report to FILE", metavar="FILE")
  34. #parser.add_option("-q", "--quiet",
  35. # action="store_false", dest="verbose", default=True,
  36. # help="don't print status messages to stdout")
  37. (options, args) = parser.parse_args()
  38. for o in dir(options):
  39. if "_" in o:
  40. continue
  41. print(o,options.__getattribute__(o))
  42. START = time.time()
  43. # ===== ARTNET DMX =========
  44. import memcache
  45. mc = memcache.Client(['127.0.0.1:11211'], debug=0)
  46. def read_index():
  47. ips=mc.get("index")#cmd)
  48. if ips is None:
  49. ips = {}
  50. #for k,v in ips.items():
  51. # print(k,v)
  52. return ips
  53. def select_ip(ips, univ=2): # artnet univ
  54. _univ = ":{}".format(univ)
  55. for ip in ips: #high priority
  56. if "2.0.0" in ip and _univ in ip:
  57. return ip
  58. for ip in ips:
  59. if "ltp-out" in ip and _univ in ip:
  60. return ip
  61. FUNC = 0
  62. COUNTER = []
  63. if options.countdown:
  64. cdmx_start = options.countdown.split(",")
  65. for cdmx in cdmx_start:
  66. try:
  67. cdmx = int(cdmx)
  68. COUNTER.append({"DMX":cdmx,"DIM":0,"PAN":127,"TILT":127,"CONTROL":0,"SEC":10,"RED":255,"GREEN":255,"BLUE":255,"_time":time.time(),"_RUN":0,"_SEC":">{}<".format(cdmx)})
  69. except Exception as e:
  70. print("EXCEPTION COUNTER INIT ",cdmx)
  71. def read_dmx(ip):
  72. global frame
  73. r = ""
  74. if ip:
  75. #t = int(math.sin(time.time() - s)*10)
  76. r = mc.get(ip) #"2.0.0.13:2")
  77. frame += 1
  78. rr = [0]*512
  79. for i,v in enumerate(r):
  80. try: #cleanup ltp-out to int
  81. v = int(v)
  82. rr[i] = v
  83. except:pass
  84. r = rr
  85. if not r:
  86. c = 0
  87. #time.sleep(0.1)
  88. r = [0] *512
  89. for i in range(12*8+1):
  90. dmx = i*4
  91. #print(dmx)
  92. r[dmx:dmx+4] = [255,10,10,40]
  93. return r
  94. # ===== ARTNET DMX =========
  95. PLAYLIST = []
  96. try:
  97. PLAYLIST = open_playlist()
  98. except:pass
  99. class Vopen_NEW():
  100. def __init__(self,dmx=None,_id=None):
  101. global PLAYLIST
  102. self._id = _id
  103. self.fpath = '/home/user/Downloads/'
  104. self.fpath = '/home/user/LibreLight/video/'
  105. self.fname = '' #'bbb_sunflower_480x320.mp4'
  106. #self.fname = 'no-video.mp4'
  107. try:
  108. self.fname = PLAYLIST[0]
  109. except Exception as e:
  110. print("Exception set video from PLAYLIST 5543:",e)
  111. self.fps = 0
  112. self.scale = 50 #%
  113. self.dmx=dmx
  114. self.dim = 0
  115. self.x = 0
  116. self.y = 0
  117. self.init_count = 0
  118. self.cap = None
  119. self.shape = [200,200]
  120. self.img = None
  121. self.success = 1
  122. self.cv2 = None
  123. self._run = 0
  124. self.end = 0
  125. self._video_nr = 0
  126. self.ready = 0
  127. self.shape_x = 370
  128. self.shape_y = 235
  129. try:
  130. global cv2
  131. self.cv2 = cv2
  132. except:
  133. pass
  134. self.init()
  135. def init(self):
  136. print("---- ---- Vopen.init()",[self.fname,self._video_nr])
  137. print(PLAYLIST)
  138. self.time = 0
  139. self.t_delta = 0
  140. self.t_last = time.time()
  141. self.im = None
  142. self.pos = 0
  143. self.buffer = []
  144. self._init()
  145. self.init_count = 1
  146. def select_video(self,dmx_value):
  147. try:
  148. dmx_value = int(dmx_value/10)
  149. if self._video_nr != dmx_value:
  150. self._video_nr = dmx_value
  151. if self._video_nr < len(PLAYLIST):
  152. self.fname = str(PLAYLIST[self._video_nr])
  153. self.init()
  154. except Exception as e:
  155. print("Vopen.select_video()",dmx_value,e)
  156. def close_cap():
  157. pass
  158. def _init(self):
  159. self.cap = self.cv2.VideoCapture(self.fpath+self.fname, cv2.CAP_FFMPEG)
  160. self.Rcap = self.cap
  161. self.success, self.img = self.cap.read()
  162. def _del(self):
  163. pass
  164. def _read(self):
  165. ok = 0
  166. if self.success:
  167. self.success, self.img = self.cap.read()
  168. if self.fps == 0:
  169. self.fps = self.cap.get(cv2.CAP_PROP_FPS)
  170. self.img = self.cv2.cvtColor(self.img, self.cv2.COLOR_BGR2RGB)
  171. self.img = self.rescale_frame2(self.img, 200)
  172. #self.shape = self.img.shape[1::-1]
  173. self.buffer.append(self.img)
  174. #self.buffer.append(self.img)
  175. s = sys.getsizeof(self.buffer)/1024
  176. #print(s)
  177. ok = 1
  178. self.ready = 1
  179. #if len(self.buffer) >= 30:
  180. # self.ready = 1
  181. return ok
  182. def read(self):
  183. if len(self.buffer) <= 0:
  184. return
  185. try:
  186. if self.pos >= len(self.buffer):
  187. self.pos = len(self.buffer)-1
  188. self._img = self.buffer[int(self.pos)]
  189. self.img = self._img
  190. #self.img = self.cv2.cvtColor(self.img, self.cv2.COLOR_BGR2RGB)
  191. self.img = self.rescale_frame(self.img, percent=self.scale)
  192. self.shape = self.img.shape[1::-1]
  193. if self._run: # and len(self.buffer) > 400:
  194. t = time.time()
  195. self.t_delta = t-self.t_last
  196. self.t_last = t
  197. self.pos += self.t_delta*self.fps
  198. else:
  199. t = time.time()
  200. self.t_delta = 0
  201. self.t_last = t
  202. if self.pos >= len(self.buffer):
  203. #self.pos = 0 #len(self.buffer)-1
  204. self.pos = 0 # len(self.buffer)-1
  205. #print("video.read",self.pos)
  206. #self.shape = self.img.shape[1::-1]
  207. except Exception as e:
  208. print("exception 432",e,len(self.buffer),self.fname)
  209. #self.init()
  210. def prev(self):
  211. pass
  212. def rescale_frame2(self,frame, width):
  213. height = int(frame.shape[0]/frame.shape[1] * width )
  214. dim = (width, height)
  215. return self.cv2.resize(frame, dim, interpolation =cv2.INTER_AREA)
  216. def rescale_frame(self,frame, percent=75):
  217. width = int(frame.shape[1] * percent/ 100)
  218. height = int(frame.shape[0] * percent/ 100)
  219. dim = (width, height)
  220. return self.cv2.resize(frame, dim, interpolation =cv2.INTER_AREA)
  221. def next(self):
  222. self.read()
  223. try:
  224. if len(self.buffer) % 100 == 0:
  225. _id = str(self.__repr__)[-5:-1]
  226. # add DIMER to videplayer
  227. self.cv2.normalize(self.img, self.img, 0, self.dim, self.cv2.NORM_MINMAX)
  228. img = self.img
  229. if img is None:
  230. return
  231. shape = img.shape[1::-1]
  232. im = pygame.image.frombuffer(img.tobytes(), shape, "RGB")
  233. self.im = im
  234. if self._run and len(self.buffer) > 30:
  235. t = time.time()
  236. self.t_delta = t-self.t_last
  237. self.t_last = t
  238. self.pos += self.t_delta*self.fps
  239. #self.pos += 4 # speedupt for testing
  240. else:
  241. t = time.time()
  242. self.t_delta = 0
  243. self.t_last = t
  244. if self.pos >= len(self.buffer):
  245. self.pos = 0 # restart
  246. #self.pos = len(self.buffer)-1 # stay at the end
  247. except AttributeError as e:
  248. time.sleep(.05)
  249. #if self.init_count % 100 == 0:
  250. print("except 776",str(self).split(" ")[-1],e)
  251. #self.init()
  252. except Exception as e:
  253. print("except 756",str(self).split(" ")[-1], e)
  254. def draw(self,wn=None):
  255. if self.dim <= 1:
  256. return
  257. if self.scale < 255*.05:
  258. self.scale = 255*0.05
  259. # draw video background box
  260. __xw = int(self.shape_x*self.scale/255)
  261. __yw = int(self.shape_y*self.scale/255)
  262. #xx ,yy = (370,235)
  263. xx = self.shape_x #= xx
  264. yy = self.shape_y #= yy
  265. try:
  266. xx ,yy = self.im.get_size()[:2]
  267. self.shape_x = xx
  268. self.shape_y = yy
  269. except AttributeError as e:
  270. pass
  271. xx = int(xx*self.scale/255)
  272. yy = int(yy*self.scale/255)
  273. __xw = int(xx) #*self.scale/255)
  274. __yw = int(yy) #*self.scale/255)
  275. yellow = [105,50,0]
  276. yellow[0] = int(yellow[0]*self.dim/255)
  277. yellow[1] = int(yellow[1]*self.dim/255)
  278. yellow[2] = int(yellow[2]*self.dim/255)
  279. #print(yellow)
  280. if 1: #corner left up
  281. p1 = [self.x+2,self.y+2]
  282. p2 = [self.x+__xw-4,self.y+__yw-4]
  283. p3 = [self.x+__xw-4,self.y+2]
  284. p4 = [self.x+2,self.y+__yw-4]
  285. p1 = [self.x,self.y]
  286. p2 = [self.x+__xw,self.y+__yw]
  287. p3 = [self.x+__xw,self.y]
  288. p4 = [self.x,self.y+__yw]
  289. hx=int(xx/2)
  290. hy=int(yy/2)
  291. #print(hx,hy,xx,yy) #,ratio)
  292. #print("-")
  293. #print(sys.getsizeof(self.buffer))
  294. #print(sys.getsizeof(self))
  295. #print(sys.getsizeof(self.Rcap))
  296. #print(dir(self.Rcap))
  297. p1 = [self.x-hx,self.y-hy]
  298. p2 = [self.x+__xw-hx,self.y+__yw-hy]
  299. p3 = [self.x+__xw-hx,self.y-hy]
  300. p4 = [self.x-hx,self.y+__yw-hy]
  301. pygame.draw.rect(wn,yellow ,[p1[0] ,p1[1] ,__xw ,__yw])
  302. pygame.draw.rect(wn,[25,20,20],[p1[0]+1,p1[1]+1,__xw-2,__yw-2])
  303. pygame.draw.line(wn,yellow ,p1 ,p2)
  304. pygame.draw.line(wn,yellow ,p3 ,p4)
  305. if 0: #corner left up
  306. pygame.draw.rect(wn,yellow,[self.x,self.y,__xw,__yw])
  307. pygame.draw.rect(wn,[25,20,20],[self.x+1,self.y+1,__xw-2,__yw-2])
  308. pygame.draw.line(wn,yellow,[self.x+2,self.y+2],[self.x+__xw-4,self.y+__yw-4])
  309. pygame.draw.line(wn,yellow,[self.x+__xw-4,self.y+2],[self.x+2,self.y+__yw-4])
  310. if 0: #corner right down
  311. pygame.draw.rect(wn,yellow,[self.x-__xw,self.y-__yw,__xw,__yw])
  312. pygame.draw.rect(wn,[25,20,20],[self.x+1-__xw,self.y+1-__yw,__xw-2,__yw-2])
  313. pygame.draw.line(wn,yellow,[self.x+2-__xw,self.y+2-__yw],[self.x+__xw-4-__xw,self.y+__yw-4-__yw])
  314. pygame.draw.line(wn,yellow,[self.x+__xw-4-__xw,self.y+2-__yw],[self.x+2-__xw,self.y+__yw-4-__yw])
  315. #pygame.draw.line(wn,yellow,[self.x,self.y],[self.x,self.y+300])
  316. #pygame.draw.line(wn,yellow,[self.x,self.y],[self.x+300,self.y])
  317. pz = 0
  318. #txt = "FPS:{} F:{:05} von {:05} sec:{:0.02f} von {:0.02f}"
  319. #txt = txt.format(self.fps,int(self.pos),len(self.buffer),(-1),pz )
  320. #if self.end:
  321. # fr = font15.render(txt,1, (0,255,0))
  322. #else:
  323. # fr = font15.render(txt,1, (255,0,0))
  324. #wn.blit(fr,(10,main_size[1]-(self._id+1)*35))
  325. if self.ready and wn and self.im: # is not None:
  326. #wn.blit(self.im, (int(self.x), int(self.y)))
  327. #wn.blit(self.im, (int(self.x-__xw), int(self.y-__yw)))
  328. #xx ,yy = self._img.shape[:2]
  329. xx ,yy = self.im.get_size()[:2]
  330. #print(xx,yy)
  331. #wn.blit(self.im, (int(self.x+xx/2), int(self.y+yy/2)))
  332. wn.blit(self.im, (int(self.x-xx/2), int(self.y-yy/2)))
  333. def overlay(self,wn=None,mode="x"):
  334. # overlay
  335. y = main_size[1]-(self._id+1)*50
  336. pygame.draw.rect(wn,[255,200,0],[5,y,300,28+15])
  337. font15 = pygame.font.SysFont("freemonobold",17)
  338. pz = 0
  339. if self.end:
  340. rgb = [ 100,255,100]
  341. else:
  342. rgb = [255,100,0]
  343. pygame.draw.rect(wn,rgb,[220,y,80,13])
  344. _line = "error no _line"
  345. _line ="F:{:05} von {:05} sec:{:0.02f} von {:0.02f}"
  346. if self.fps == 0: # check if div zerro
  347. fps = 1
  348. _line = _line.format(int(self.pos),len(self.buffer),(-1),pz )
  349. else:
  350. pz = (len(self.buffer)/self.fps)
  351. _line = _line.format(self.fps,int(self.pos),len(self.buffer),(self.pos/self.fps),pz )
  352. fr = font15.render(_line ,1, (0,0,0))
  353. wn.blit(fr,(10,y))
  354. if self._run:
  355. mode = "run"
  356. else:
  357. mode = "pause"
  358. txt = "fps:{} id:{} nr:{} scale:{} "
  359. txt = txt.format(self.fps,self._id+1,self._video_nr,int(self.scale) )
  360. fr = font15.render(txt,1, (0,0,0))
  361. wn.blit(fr,(3,y+15))
  362. txt = "{}: {}"
  363. txt = txt.format(mode,self.fname )
  364. fr = font15.render(txt,1, (0,0,0))
  365. wn.blit(fr,(3,y+30))
  366. class Vopen():
  367. def __init__(self,dmx=None,_id=None):
  368. global PLAYLIST
  369. self._id = _id
  370. self.fpath = '/home/user/Downloads/'
  371. self.fpath = '/home/user/LibreLight/video/'
  372. self.fname = '' #'bbb_sunflower_480x320.mp4'
  373. #self.fname = 'no-video.mp4'
  374. try:
  375. self.fname = PLAYLIST[0]
  376. except Exception as e:
  377. print("Exception set video from PLAYLIST 5543:",e)
  378. self.fps = 0
  379. self.scale = 50 #%
  380. self.dmx=dmx
  381. self.dim = 0
  382. self.x = 0
  383. self.y = 0
  384. self.init_count = 0
  385. self.cap = None
  386. self.shape = [200,200]
  387. self.img = None
  388. self.success = 1
  389. self.cv2 = None
  390. self._run = 0
  391. self.end = 0
  392. self._video_nr = 0
  393. self.shape_x = 370
  394. self.shape_y = 235
  395. try:
  396. global cv2
  397. self.cv2 = cv2
  398. except:
  399. pass
  400. self.init()
  401. def init(self):
  402. print("---- ---- Vopen.init()",[self.fname,self._video_nr])
  403. print(PLAYLIST)
  404. self.time = 0
  405. self.t_delta = 0
  406. self.t_last = time.time()
  407. self.im = None
  408. self.pos = 0
  409. self.buffer = []
  410. self._init()
  411. self.init_count = 1
  412. def select_video(self,dmx_value):
  413. try:
  414. dmx_value = int(dmx_value/10)
  415. if self._video_nr != dmx_value:
  416. self._video_nr = dmx_value
  417. if self._video_nr < len(PLAYLIST):
  418. self.fname = str(PLAYLIST[self._video_nr])
  419. self.init()
  420. except Exception as e:
  421. print("Vopen.select_video()",dmx_value,e)
  422. def close_cap():
  423. print(dir(self.Rcap)) # = self.cv2.VideoCapture(self.fpath+self.fname)
  424. def _init(self):
  425. print(self)
  426. print("videoplayer.init()",self.fpath,self.fname)
  427. if not os.path.isfile(self.fpath+self.fname):
  428. print()
  429. print("video file does not exits !! >",self.fpath,self.fname)
  430. print()
  431. #exit()
  432. self.Rsuccess = 0
  433. if self.cv2:
  434. #self.Rcap = self.cv2.VideoCapture(self.fpath+self.fname)
  435. #self.Rcap = self.cv2.VideoCapture(self.fpath+self.fname, cv2.CAP_GSTREAMER)
  436. #GSTREAMER Assertion fctx->async_lock failed at libavcodec/pthread_frame.c:175
  437. self.Rcap = self.cv2.VideoCapture(self.fpath+self.fname, cv2.CAP_FFMPEG)
  438. #FFMPEG malloc(): unsorted double linked list corrupted ... Abgebrochen
  439. self.Rcap.read()
  440. self.Rfvs = FileVideoStream(self.fpath+self.fname).start()
  441. self.Rsuccess = 1
  442. self._read()
  443. def _del(self):
  444. #self.Rcap = self.cv2.VideoCapture(self.fpath+self.fname)
  445. #for i in dir(self.Rcap):
  446. # print(i)
  447. #print()
  448. #for i in dir(self.cv2):
  449. # print(i)
  450. time.sleep(0.01)
  451. self.buffer = [] #.append(self.img)
  452. self.Rcap.release()
  453. self.Rcap.retrieve()
  454. self.Rcap = None
  455. self.cap = None
  456. del self.Rcap #.release()
  457. #time.sleep(4)
  458. #sys.exit()
  459. #gc.collect()
  460. #import gc
  461. gc.collect()
  462. def _read(self):
  463. success = self.Rsuccess
  464. ok = 0
  465. if success and self.fname:
  466. cap = self.Rcap
  467. #fvs = self.Rfvs
  468. _break = 0
  469. try:
  470. success, self.img = cap.read()
  471. #self.img = fvs.read()
  472. if not success:
  473. self.Rcap.release()
  474. self.Rcap.retrieve()
  475. self.end = 1
  476. return
  477. if self.fps == 0:
  478. self.fps = cap.get(cv2.CAP_PROP_FPS)
  479. self.img = self.cv2.cvtColor(self.img, self.cv2.COLOR_BGR2RGB)
  480. self.img = self.rescale_frame2(self.img, 200)
  481. #ret, self.img = self.cv2.threshold(self.img, 100, 130, self.cv2.THRESH_BINARY) # treshold
  482. #self.img = self.cv2.Canny(self.img, 100, 200) # kanten
  483. #M = cv2.getPerspectiveTransform(Punkte_A, Punkte_B)
  484. #warped = cv2.warpPerspective(Bild, m, (420,594))
  485. #self.cv2.normalize(self.img, self.img, 0, self.dim, self.cv2.NORM_MINMAX)
  486. self.buffer.append(self.img)
  487. ok = 1
  488. if len(self.buffer) % 100 == 0:
  489. _id = str(self.__repr__)[-5:-1]
  490. print(_id,"video read",self.dmx,len(self.buffer),self.fname,"fps",self.fps,self.dim)
  491. except Exception as e:
  492. print("Excetpion","_init",self,e,end="")
  493. self.success = 1
  494. return ok
  495. def read(self):
  496. if len(self.buffer) <= 0:
  497. return
  498. try:
  499. if self.pos >= len(self.buffer):
  500. self.pos = len(self.buffer)-1
  501. self._img = self.buffer[int(self.pos)]
  502. self.img = self._img
  503. #self.img = self.cv2.cvtColor(self.img, self.cv2.COLOR_BGR2RGB)
  504. self.img = self.rescale_frame(self.img, percent=self.scale)
  505. if self._run: # and len(self.buffer) > 400:
  506. t = time.time()
  507. self.t_delta = t-self.t_last
  508. self.t_last = t
  509. self.pos += self.t_delta*self.fps
  510. else:
  511. t = time.time()
  512. self.t_delta = 0
  513. self.t_last = t
  514. if self.pos >= len(self.buffer):
  515. #self.pos = 0 #len(self.buffer)-1
  516. self.pos = 0 # len(self.buffer)-1
  517. #print("video.read",self.pos)
  518. self.shape = self.img.shape[1::-1]
  519. except Exception as e:
  520. print("exception 432",e,len(self.buffer),self.fname)
  521. #self.init()
  522. def prev(self):
  523. self.pos -= 1
  524. if self.pos < 0:
  525. self.pos = len(self.buffer)-1
  526. if self.pos >= len(self.buffer):
  527. self.pos = len(self.buffer)-1
  528. self.im = self.buffer[int(self.pos)]
  529. def rescale_frame2(self,frame, width):
  530. height = int(frame.shape[0]/frame.shape[1] * width )
  531. dim = (width, height)
  532. return self.cv2.resize(frame, dim, interpolation =cv2.INTER_AREA)
  533. def rescale_frame(self,frame, percent=75):
  534. width = int(frame.shape[1] * percent/ 100)
  535. height = int(frame.shape[0] * percent/ 100)
  536. dim = (width, height)
  537. return self.cv2.resize(frame, dim, interpolation =cv2.INTER_AREA)
  538. def next(self):
  539. self.read()
  540. try:
  541. if len(self.buffer) % 100 == 0:
  542. _id = str(self.__repr__)[-5:-1]
  543. # add DIMER to videplayer
  544. self.cv2.normalize(self.img, self.img, 0, self.dim, self.cv2.NORM_MINMAX)
  545. img = self.img
  546. if img is None:
  547. return
  548. self.im = pygame.image.frombuffer(img.tobytes(), self.shape, "RGB")
  549. if self._run and len(self.buffer) > 30:
  550. t = time.time()
  551. self.t_delta = t-self.t_last
  552. self.t_last = t
  553. self.pos += self.t_delta*self.fps
  554. #self.pos += 4 # speedupt for testing
  555. else:
  556. t = time.time()
  557. self.t_delta = 0
  558. self.t_last = t
  559. if self.pos >= len(self.buffer):
  560. self.pos = 0 # restart
  561. #self.pos = len(self.buffer)-1 # stay at the end
  562. except AttributeError as e:
  563. time.sleep(.05)
  564. #if self.init_count % 100 == 0:
  565. print("except 776",e)
  566. #self.init()
  567. except Exception as e:
  568. print("except 756",e)
  569. def draw(self,wn=None):
  570. if self.dim <= 1:
  571. return
  572. if self.scale < 255*.05:
  573. self.scale = 255*0.05
  574. # draw video background box
  575. __xw = int(self.shape_x*self.scale/255)
  576. __yw = int(self.shape_y*self.scale/255)
  577. #xx ,yy = (370,235)
  578. xx = self.shape_x #= xx
  579. yy = self.shape_y #= yy
  580. try:
  581. xx ,yy = self.im.get_size()[:2]
  582. self.shape_x = xx
  583. self.shape_y = yy
  584. except AttributeError as e:
  585. pass
  586. xx = int(xx*self.scale/255)
  587. yy = int(yy*self.scale/255)
  588. __xw = int(xx) #*self.scale/255)
  589. __yw = int(yy) #*self.scale/255)
  590. yellow = [105,50,0]
  591. yellow[0] = int(yellow[0]*self.dim/255)
  592. yellow[1] = int(yellow[1]*self.dim/255)
  593. yellow[2] = int(yellow[2]*self.dim/255)
  594. #print(yellow)
  595. if 1: #corner left up
  596. p1 = [self.x+2,self.y+2]
  597. p2 = [self.x+__xw-4,self.y+__yw-4]
  598. p3 = [self.x+__xw-4,self.y+2]
  599. p4 = [self.x+2,self.y+__yw-4]
  600. p1 = [self.x,self.y]
  601. p2 = [self.x+__xw,self.y+__yw]
  602. p3 = [self.x+__xw,self.y]
  603. p4 = [self.x,self.y+__yw]
  604. hx=int(xx/2)
  605. hy=int(yy/2)
  606. #print(hx,hy,xx,yy) #,ratio)
  607. #print("-")
  608. #print(sys.getsizeof(self.buffer))
  609. #print(sys.getsizeof(self))
  610. #print(sys.getsizeof(self.Rcap))
  611. #print(dir(self.Rcap))
  612. p1 = [self.x-hx,self.y-hy]
  613. p2 = [self.x+__xw-hx,self.y+__yw-hy]
  614. p3 = [self.x+__xw-hx,self.y-hy]
  615. p4 = [self.x-hx,self.y+__yw-hy]
  616. pygame.draw.rect(wn,yellow ,[p1[0] ,p1[1] ,__xw ,__yw])
  617. pygame.draw.rect(wn,[25,20,20],[p1[0]+1,p1[1]+1,__xw-2,__yw-2])
  618. pygame.draw.line(wn,yellow ,p1 ,p2)
  619. pygame.draw.line(wn,yellow ,p3 ,p4)
  620. if 0: #corner left up
  621. pygame.draw.rect(wn,yellow,[self.x,self.y,__xw,__yw])
  622. pygame.draw.rect(wn,[25,20,20],[self.x+1,self.y+1,__xw-2,__yw-2])
  623. pygame.draw.line(wn,yellow,[self.x+2,self.y+2],[self.x+__xw-4,self.y+__yw-4])
  624. pygame.draw.line(wn,yellow,[self.x+__xw-4,self.y+2],[self.x+2,self.y+__yw-4])
  625. if 0: #corner right down
  626. pygame.draw.rect(wn,yellow,[self.x-__xw,self.y-__yw,__xw,__yw])
  627. pygame.draw.rect(wn,[25,20,20],[self.x+1-__xw,self.y+1-__yw,__xw-2,__yw-2])
  628. pygame.draw.line(wn,yellow,[self.x+2-__xw,self.y+2-__yw],[self.x+__xw-4-__xw,self.y+__yw-4-__yw])
  629. pygame.draw.line(wn,yellow,[self.x+__xw-4-__xw,self.y+2-__yw],[self.x+2-__xw,self.y+__yw-4-__yw])
  630. #pygame.draw.line(wn,yellow,[self.x,self.y],[self.x,self.y+300])
  631. #pygame.draw.line(wn,yellow,[self.x,self.y],[self.x+300,self.y])
  632. pz = 0
  633. #txt = "FPS:{} F:{:05} von {:05} sec:{:0.02f} von {:0.02f}"
  634. #txt = txt.format(self.fps,int(self.pos),len(self.buffer),(-1),pz )
  635. #if self.end:
  636. # fr = font15.render(txt,1, (0,255,0))
  637. #else:
  638. # fr = font15.render(txt,1, (255,0,0))
  639. #wn.blit(fr,(10,main_size[1]-(self._id+1)*35))
  640. if self.success and wn and self.im: # is not None:
  641. #wn.blit(self.im, (int(self.x), int(self.y)))
  642. #wn.blit(self.im, (int(self.x-__xw), int(self.y-__yw)))
  643. #xx ,yy = self._img.shape[:2]
  644. xx ,yy = self.im.get_size()[:2]
  645. #print(xx,yy)
  646. #wn.blit(self.im, (int(self.x+xx/2), int(self.y+yy/2)))
  647. wn.blit(self.im, (int(self.x-xx/2), int(self.y-yy/2)))
  648. def overlay(self,wn=None,mode="x"):
  649. # overlay
  650. pygame.draw.rect(wn,[255,200,0],[5,main_size[1]-(self._id+1)*35,300,28])
  651. font15 = pygame.font.SysFont("freemonobold",17)
  652. pz = 0
  653. if self.end:
  654. rgb = [ 100,255,100]
  655. else:
  656. rgb = [255,100,0]
  657. pygame.draw.rect(wn,rgb,[220,main_size[1]-(self._id+1)*35,80,13])
  658. _line = "error no _line"
  659. _line ="FPS:{} F:{:05} von {:05} sec:{:0.02f} von {:0.02f}"
  660. if self.fps == 0: # check if div zerro
  661. _line = _line.format(self.fps,int(self.pos),len(self.buffer),(-1),pz )
  662. else:
  663. pz = (len(self.buffer)/self.fps)
  664. _line = _line.format(self.fps,int(self.pos),len(self.buffer),(self.pos/self.fps),pz )
  665. fr = font15.render(_line ,1, (0,0,0))
  666. wn.blit(fr,(10,main_size[1]-(self._id+1)*35))
  667. if self._run:
  668. mode = "run"
  669. else:
  670. mode = "pause"
  671. fr = font15.render(" {} {} >:{} ".format(self._id+1,self._video_nr,mode) ,1, (0,0,0))
  672. wn.blit(fr,(3,main_size[1]-(self._id+1)*35+15))
  673. fr = font15.render("{}".format(self.fname) ,1, (0,0,0))
  674. wn.blit(fr,(60,main_size[1]-(self._id+1)*35+15))
  675. VIDEO = []
  676. videoplayer=[]
  677. cv2 = None
  678. FileVideoStream = None
  679. _vid = 0
  680. if type(options.videoplayer) is str:
  681. try:
  682. import cv2
  683. except Exception as e:
  684. print("Except Import:",e)
  685. try:
  686. # faster video reading ... ???
  687. from imutils.video import FileVideoStream
  688. except Exception as e:
  689. print("Except Import:",e)
  690. max_videoplayer = 4
  691. dmx_start = options.videoplayer.split(",")
  692. for cdmx in dmx_start:
  693. if len(videoplayer) > max_videoplayer:
  694. print("-- videoplayer max count {} !! break".format(max_videoplayer))
  695. break
  696. print("-- videoplayer dmx:",cdmx)
  697. try:
  698. cdmx = int(cdmx)
  699. videoplayer.append( Vopen(cdmx,_id=_vid) )
  700. _vid += 1
  701. VIDEO.append({"DMX":cdmx,"DIM":0,"PAN":127,"TILT":127,"CONTROL":0,"SEC":10,"VIDEO":"3","RED":255,"GREEN":255,"BLUE":255,"_time":time.time(),"_RUN":0,"_SEC":">{}<".format(cdmx)})
  702. except Exception as e:
  703. print("EXCEPTION COUNTER INIT ",cdmx)
  704. def loop_videoplayer():
  705. while 1:
  706. _videoplayer = videoplayer[:]
  707. #print(".")
  708. ok = 0
  709. for i in _videoplayer: #.append( Vopen(cdmx,_id=_vid) )
  710. try:
  711. r = i._read() # read next frame from file
  712. if r:
  713. ok = 1
  714. except Exception as e:
  715. print("EXCEPTION loop_videoplayer ",e)
  716. time.sleep(0.002)
  717. if ok == 0:
  718. time.sleep(0.1)
  719. else:
  720. time.sleep(0.005)
  721. thread.start_new_thread(loop_videoplayer,())
  722. # ===== ======
  723. #self.fname = PLAYLIST[0]
  724. videoplayer2 = []
  725. def loop2_videoplayer():
  726. while 1:
  727. print()
  728. print()
  729. print()
  730. for i,v in enumerate(PLAYLIST):
  731. try:
  732. video1 = videoplayer2[i]
  733. video1.select_video(i)
  734. except:
  735. vi = Vopen(181,1)
  736. videoplayer2.append( vi )
  737. _videoplayer = videoplayer2[:]
  738. #print(".")
  739. ok = 0
  740. j =0
  741. for i in _videoplayer: #.append( Vopen(cdmx,_id=_vid) )
  742. try:
  743. r = i._read() # read next frame from file
  744. #print(j,len(videoplayer2),i,len(i.buffer))
  745. if r:
  746. print(j,len(videoplayer2),i,len(i.buffer))
  747. ok = 1
  748. except Exception as e:
  749. print("EXCEPTION loop2_videoplayer ",e)
  750. time.sleep(0.002)
  751. j += 1
  752. if ok == 0:
  753. pass#time.sleep(0.01)
  754. else:
  755. pass#time.sleep(0.005)
  756. #thread.start_new_thread(loop2_videoplayer,())
  757. p = 16
  758. block = [p,p]
  759. _x = 8
  760. _y = 8
  761. #HD = "0"
  762. if options.mode:
  763. try:
  764. HD = options.mode
  765. p,_x,_y = HD.split(",")
  766. _x = int(_x)
  767. _y = int(_y)
  768. p = int(p)
  769. block = [p,p]
  770. except Exception as e:
  771. print( "Exc",options.mode,e)
  772. HD_x = 2
  773. HD_y = 2
  774. print( [options.xsplit])
  775. print( [options.ysplit])
  776. try:
  777. if options.xsplit:
  778. HD_x = int(options.xsplit)
  779. if options.ysplit:
  780. HD_y = int(options.ysplit)
  781. except Exception as e:
  782. print( "Exc",options.mode,e)
  783. print("HD",HD_x,HD_y)
  784. print("xy",_x,_y)
  785. print("++++++++++++++++++", p,_x,_y)
  786. _x2 = _x
  787. try:
  788. if options.XX:
  789. pass#_x2 = int(options.XX)
  790. except Exception as e:
  791. print( "Exc",options.mode,e)
  792. print("_x2 , -X",_x2)
  793. # ===== GUI =========
  794. import pygame
  795. import pygame.gfxdraw
  796. import pygame.font
  797. clock = pygame.time.Clock()
  798. os.environ['SDL_VIDEO_WINDOW_POS'] = '%i,%i' % (200,164)
  799. if options.win_pos:
  800. if "," in options.win_pos:
  801. win_pos = options.win_pos.split(",")
  802. try:
  803. WIN_POS = '%i,%i' % (int(win_pos[0]),int(win_pos[1]) )
  804. os.environ['SDL_VIDEO_WINDOW_POS'] = WIN_POS
  805. except Excetpion as e:
  806. print("win_pos",win_pos,e)
  807. os.environ['SDL_VIDEO_CENTERED'] = '0'
  808. pg = pygame
  809. pygame.init()
  810. pygame.mixer.quit()
  811. f = pygame.font.get_fonts()
  812. for i in f:
  813. if "mono" in i.lower():
  814. print(i)
  815. font = pygame.font.SysFont("freemonobold",22)
  816. font10 = pygame.font.SysFont("freemonobold",10)
  817. font12 = pygame.font.SysFont("freemonobold",12)
  818. font15 = pygame.font.SysFont("freemonobold",15)
  819. font40 = pygame.font.SysFont("freemonobold",40)
  820. font80 = pygame.font.SysFont("freemonobold",70)
  821. #font = pygame.font.SysFont(None,30)
  822. fr = font.render("hallo" ,1, (200,0,255))
  823. PIXEL_MAPPING = 0
  824. grid_file = "/tmp/vpu_grid_hd.csv"
  825. text_file = "/home/user/LibreLight/vpu_text_hd.csv"
  826. play_list = "/tmp/vpu_playlist_hd.csv"
  827. pm_wy = 0
  828. if options.pixel_mapping:
  829. PIXEL_MAPPING = 1
  830. path = options.pixel_mapping
  831. path = path.replace("/","-")
  832. path = path.replace(".","-")
  833. path = path.replace("\"","-")
  834. path = path.replace("'","-")
  835. grid_file = "/home/user/LibreLight/vpu_grid_hd{}.csv".format(path)
  836. text_file = "/home/user/LibreLight/vpu_text_hd{}.csv".format(path)
  837. play_list = "/home/user/LibreLight/vpu_playlist_hd{}.csv".format(path)
  838. play_list = "/home/user/LibreLight/video/" #.format(path)
  839. #_x = 8
  840. #_y = 8
  841. print(" ",[options.pixel_mapping],"grid_file",grid_file)
  842. #grid_file = "/home/user/LibreLight/vpu_grid_hd.csv"
  843. main_size=(600,500)
  844. try:
  845. if _x < 8 and PIXEL_MAPPING >= 1:
  846. wx = 60+block[0] * 8
  847. else:
  848. wx = 60+block[0] * _x
  849. wy = 80+block[1] * _y
  850. #pm_wy = wy
  851. if type(options.videoplayer) is str:
  852. wy += 150 # video playlist
  853. main_size=(wx,wy)
  854. if PIXEL_MAPPING >= 1:
  855. pm_wy = 11*p #+ p*3
  856. main_size=(wx,wy+pm_wy)
  857. except Exception as e:
  858. print("Exception:",e)
  859. #main_size=(280,200)
  860. main_size = (main_size[0],main_size[1])
  861. window = pygame.display.set_mode(main_size,pg.RESIZABLE)#,32)#,pygame.FULLSCREEN) #x left->right ,y top-> bottom
  862. pg.display.set_caption('LibreLight VPU-SCREEN')
  863. class Fix():
  864. def __init__(self,_id,pos,block=[16,16],univ=0,dmx=0,ch=4):
  865. #print("Fix",_id)
  866. self._id = _id
  867. self.dmx = (_id-1) * ch +1 #dmx
  868. self.univ = univ
  869. self.ch = ch
  870. self.pos = pos
  871. self.rgb = [0,0,0]
  872. self.block = block #[10,10]
  873. self.x = pos[0]
  874. self.y = pos[1]
  875. self.strobo = time.time()
  876. self.bmp = 250
  877. self.sub_fix = []
  878. sub_block =[block[0]/HD_x,block[1]/HD_y]
  879. if _id <= 0: #exit
  880. return
  881. spalte = (_id-1)%_y +1
  882. zeile = int((_id-1)/_x2) #+1
  883. #zeile = zeile*_x*HD_x*HD_y
  884. add_row = _x*HD_x*HD_y
  885. #zeile 1
  886. sid = (_id-1)*2 + zeile*HD_x*_x2
  887. #for i in range(1,HD_x):
  888. sid = sid+1
  889. #sid = zeile
  890. sub_pos= [pos[0]*block[0],pos[1]*block[1]]
  891. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  892. self.sub_fix.append(sub_fix)
  893. sid = sid+1
  894. #sid = zeile
  895. sub_pos= [pos[0]*block[0]+block[0]/2,pos[1]*block[1]]
  896. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  897. self.sub_fix.append(sub_fix)
  898. #zeile 2
  899. sid = (_id-1)*2+1 + _x2*HD_x + zeile*HD_x*_x2 # int(add_row)
  900. #sid = sid+1
  901. #sid = HD_x
  902. sub_pos= [pos[0]*block[0],pos[1]*block[1]+block[1]/2]
  903. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  904. self.sub_fix.append(sub_fix)
  905. #sid = sid+1
  906. sid = sid+1
  907. sub_pos= [pos[0]*block[0]+block[0]/2,pos[1]*block[1]+block[1]/2]
  908. sub_fix = SubFix(sid,sub_pos,sub_block,univ,dmx,ch)
  909. self.sub_fix.append(sub_fix)
  910. def calc(self,data):
  911. _rgb = [0,255,0]
  912. return _rgb
  913. def sub_calc(self,data):
  914. _rgb = [0,255,0]
  915. for sub_fix in self.sub_fix:
  916. sub_fix.block = self.block[:]
  917. _rgb = sub_fix.calc(data)
  918. return _rgb
  919. def POS(self,x=0,y=0,a=0,b=0):
  920. A = (self.pos[0])*self.block[0]
  921. B = (self.pos[1])*self.block[1]
  922. C = self.block[0]-a
  923. D = self.block[1]-b
  924. return [x+A,y+B,C,D]
  925. def subPOS(self,x=0,y=0,a=0,b=0):
  926. __out = []
  927. for sub_fix in self.sub_fix:
  928. __out.append( sub_fix.POS(x,y,a,b) )
  929. return __out
  930. class SubFix():
  931. def __init__(self,_id,pos,block=[16,16],univ=0,dmx=0,ch=4):
  932. #print("Fix",_id)
  933. self._id = _id
  934. self.dmx = (_id-1) * ch +1 #dmx
  935. self.univ = univ
  936. self.ch = ch
  937. self.pos = pos
  938. self.rgb = [0,0,40]
  939. self.block = block #[10,10]
  940. self.x = pos[0]
  941. self.y = pos[1]
  942. self.strobo = time.time()
  943. self.bmp = 250
  944. def calc(self,data):
  945. #return [130,30,20]
  946. dmx_sub = [30]*10
  947. #print(dmx_sub)
  948. dmx = self.dmx -1
  949. _dmx_sub = []
  950. if self.dmx >= 0:
  951. dmx = rDMX(self.univ,self.dmx)-1
  952. if dmx+self.ch < len(data):
  953. _dmx_sub = data[dmx:dmx+self.ch]
  954. if _dmx_sub:
  955. dmx_sub = _dmx_sub
  956. #print(dmx_sub)
  957. dim = dmx_sub[0]/255
  958. #print("dmx",dmx,dmx_sub)
  959. r = dmx_sub[1]*dim
  960. g = dmx_sub[2]*dim
  961. b = dmx_sub[3]*dim
  962. r = int(r)
  963. g = int(g)
  964. b = int(b)
  965. self.rgb = [r,g,b]
  966. return self.rgb
  967. def POS(self,x=0,y=0,a=0,b=0):
  968. A = (self.pos[0]) #+self.block[0]
  969. B = (self.pos[1]) #+self.block[1]
  970. C = self.block[0]-a
  971. D = self.block[1]-b
  972. if NR:
  973. C-=1
  974. D-=1
  975. return [int(x+A),int(y+B),int(C),int(D)]
  976. class POINTER():
  977. def __init__(self):
  978. self.pos = [0,0,0,0]
  979. self.on = 0
  980. self.rgb = [0,100,10]
  981. self._x = 0
  982. self._y = 0
  983. self.x = 0
  984. self.y = 0
  985. self.fix = Fix(0 ,[999,999],[16,16],0,0,0)
  986. def row_move(self,x,y):
  987. self._x = x
  988. self._y = y
  989. def move(self,pos):
  990. self.pos = pos
  991. self.on = 1
  992. def cross(self,x,y):
  993. self.x = x
  994. self.y = y
  995. def draw(self,x,y):
  996. pos = self.pos[:]
  997. #print("draw",x,y,pos)
  998. pos[0] += x
  999. pos[1] += y
  1000. fix_x= self.fix.x
  1001. fix_y= self.fix.y +y
  1002. #print("draw",x,y,pos)
  1003. if self.on:
  1004. pygame.draw.rect(window,self.rgb,pos)
  1005. #pygame.draw.line(window,self.rgb, (pos[0],pos[1]) , (pos[0]+100,pos[1]) )
  1006. # mouse grid posision
  1007. fr = font15.render("{}/{}".format(fix_x+1,fix_y) ,1, (200,200,200))
  1008. _nr = fix_y * _x + fix_x +1
  1009. #fr = font15.render("{:02} {}/{}".format(_nr, fix_x+1,fix_y+1 ) ,1, (200,200,200))
  1010. fr = font15.render("{:02}".format(_nr ) ,1, (200,200,200))
  1011. window.blit(fr,(pos[0]+2,pos[1]+2 ))
  1012. window.blit(fr,(130,1))
  1013. # fix pos
  1014. txt=str(pos) #"[0, 0, 0, 0]"
  1015. fr = font15.render(txt ,1, (200,200,200))
  1016. #window.blit(fr,(pos[0]+2,pos[1]+2 ))
  1017. window.blit(fr,(10,1))
  1018. # univers
  1019. #fr = font15.render("{:02}:{:03}".format(fix.univ,fix.dmx) ,1, (200,200,200))
  1020. #window.blit(fr,(300,10))
  1021. # pointer
  1022. fr = font15.render("X:{:03}".format(self._x) ,1, (200,200,200))
  1023. window.blit(fr,(10,30))
  1024. fr = font15.render("Y:{:03}".format(self._y) ,1, (200,200,200))
  1025. window.blit(fr,(10,40))
  1026. # crosshair
  1027. self.rgb = [0,0,200]
  1028. pygame.draw.line(window,self.rgb, (self.x-p,self.y) , (self.x-2,self.y),4 )
  1029. pygame.draw.line(window,self.rgb, (self.x,self.y-p) , (self.x,self.y-2),4 )
  1030. self.rgb = [0,200,0]
  1031. pygame.draw.line(window,self.rgb, (self.x+2,self.y) , (self.x+p,self.y),4 )
  1032. pygame.draw.line(window,self.rgb, (self.x,self.y+2) , (self.x,self.y+p),4 )
  1033. self.rgb = [200,0,0]
  1034. pointer = POINTER()
  1035. NR = 0
  1036. running = True
  1037. def event():
  1038. global NR,running
  1039. for event in pygame.event.get():
  1040. #print(event.dict)
  1041. _button = None
  1042. if "button" in event.dict:
  1043. _button = event.dict["button"]
  1044. _state = None
  1045. if "state" in event.dict:
  1046. _state = event.state
  1047. _key = None
  1048. if "key" in event.dict:
  1049. _key = event.key
  1050. _pos = None
  1051. if "pos" in event.dict:
  1052. _pos = event.pos
  1053. _type = None
  1054. if "type" in event.dict:
  1055. _type = event.type
  1056. _type = event.type
  1057. _mod = None
  1058. if "mod" in event.dict:
  1059. _mod = event.mod
  1060. if 0:
  1061. print( " ")
  1062. print( "{:.02f}".format( time.time() - START ))
  1063. print("button -",_button,end="\t| ")
  1064. #print("state -",_state)
  1065. print("pos -",_pos)
  1066. print("type -",_type, end="\t| ")
  1067. print("key -",_key)
  1068. print("mod -",_mod)
  1069. try:
  1070. if _type == 5:
  1071. if _button == 1:
  1072. NR += 1
  1073. if NR > 1:
  1074. NR = 0
  1075. if _button == 3:
  1076. NR -= 1
  1077. if NR < 0:
  1078. NR = 1
  1079. if _pos:
  1080. posA = _pos
  1081. fix = find_pix(_pos[0]-40,_pos[1]-60+pm_wy)
  1082. if fix:
  1083. pos = fix.POS(40,60+pm_wy)
  1084. rgb = [0,0,0]
  1085. pointer.move(pos)
  1086. pointer.fix = fix
  1087. else:
  1088. pointer.on = 0
  1089. pointer.row_move(_pos[0],_pos[1])
  1090. pointer.cross(_pos[0],_pos[1])
  1091. if event.type == pygame.VIDEORESIZE:
  1092. window = pygame.display.set_mode((event.w, event.h), pygame.RESIZABLE)
  1093. except Exception as e:
  1094. print(e)
  1095. if event.type==pygame.QUIT:
  1096. running=False
  1097. fps = 0
  1098. frame = 0
  1099. frame_t = time.time()
  1100. IP = "yyy"
  1101. def draw_overlay():
  1102. global fps
  1103. fr = font.render("FPS:{}".format(fps) ,1, (200,0,255))
  1104. window.blit(fr,(10,10))
  1105. fr = font.render("ip:{}".format(IP) ,1, (200,0,255))
  1106. window.blit(fr,(80,10))
  1107. def calc_fps():
  1108. global fps,frame,frame_t
  1109. t = time.time()
  1110. if frame_t+1 < t:
  1111. fps = frame #frame_t- t #frame
  1112. frame = 1
  1113. frame_t = time.time()
  1114. TEXT_BLOCK = []
  1115. def _create_text_block():
  1116. print("======== CREATE NEW TEXT FILE !!",text_file)
  1117. f = open(text_file,"w")
  1118. for i in range(10):
  1119. f.write("TEXT {}\n".format(i+1))
  1120. f.close()
  1121. def open_text_block():
  1122. print("======== OPEN TEXT FILE !!",text_file)
  1123. _lines = []
  1124. try:
  1125. f = open(text_file,"r")
  1126. _lines = f.readlines()
  1127. f.close()
  1128. except FileNotFoundError as e:
  1129. print("TEXT",e)
  1130. _create_text_block()
  1131. if len(_lines) <= 0:
  1132. _create_text_block()
  1133. lines = []
  1134. for l in _lines:
  1135. #print(">> ",l.strip())
  1136. lines.append(l.strip())
  1137. if len(lines) <= 10:
  1138. for i in range(10-len(lines)):
  1139. lines.append("LINE ERROR")
  1140. return lines
  1141. TEXT_BLOCK = open_text_block()
  1142. TEXT_BLOCK_TIME = time.time()
  1143. # video playlist
  1144. PLAYLIST = []
  1145. def _create_playlist():
  1146. print("======== CREATE NEW PLAYLIST DIR !!",play_list)
  1147. os.system("mkdir -p /home/user/LibreLight/video")
  1148. f = open(play_list,"w")
  1149. f.write("bbb_sunflower_480x320.mp4\n")
  1150. for i in range(10-1):
  1151. f.write("Video-file {}\n".format(i+1+1))
  1152. f.close()
  1153. def open_playlist():
  1154. print("======== OPEN PLAYLIST DIR !!",play_list)
  1155. _lines = []
  1156. try:
  1157. #f = open(play_list,"r")
  1158. _lines = os.listdir(play_list)
  1159. _lines.sort()
  1160. #_lines = f.readlines()
  1161. #f.close()
  1162. except FileNotFoundError as e:
  1163. print("TEXT",e)
  1164. pass#_create_playlist()
  1165. if len(_lines) <= 0:
  1166. pass#_create_playlist()
  1167. lines = ['']*25 # first is empty
  1168. i=0
  1169. for l in _lines:
  1170. #print(">> ",l.strip(),len(lines))
  1171. l = l.strip()
  1172. if "_" in l:
  1173. ll = l.split("_",1)
  1174. print(">> ",ll)
  1175. #ll = int(ll)
  1176. try:
  1177. lll = int(ll[0])
  1178. #lines.append(l.strip())
  1179. lines[lll] = l
  1180. except:pass
  1181. if len(lines) <= 10:
  1182. for i in range(10-len(lines)):
  1183. lines.append("")#"LINE ERROR")
  1184. return lines
  1185. PLAYLIST_TIME = time.time()
  1186. PLAYLIST = open_playlist()
  1187. # ===== GUI =========
  1188. #def draw_circle(surface, x, y, radius, color):
  1189. def draw_circle(surface,color, pos, radius):
  1190. x,y=pos
  1191. pygame.gfxdraw.aacircle(surface, int(x), int(y), radius-1, color)
  1192. pygame.gfxdraw.filled_circle(surface, int(x), int(y), radius-1, color)
  1193. def rDMX(univ,dmx):
  1194. return univ*512+dmx
  1195. def generate_grid(mapping=0):
  1196. _log = []
  1197. #if PIXEL_MAPPING:
  1198. # log = open(grid_file,"w")
  1199. head = "i,univ,dmx,x,y,ch\n"
  1200. head = "i,univ,dmx,ch\n"
  1201. head = "univ,dmx,x,y,ch\n"
  1202. head = "nr,id,info\n"
  1203. print("csv:",head)
  1204. #if PIXEL_MAPPING:
  1205. # log.write(head)
  1206. _log.append(head)
  1207. dmx = 1-1
  1208. ch = 4
  1209. y=0
  1210. x=0
  1211. #for i in range((_y)*(_x)):
  1212. for i in range((8)*(8)):
  1213. #if x > _x and i%_x == 0:
  1214. if x > 8 and i%8 == 0:
  1215. #print("--> -->")
  1216. x=0
  1217. y+=1
  1218. _univ = int(dmx/512)
  1219. _dmx = dmx - (_univ)*512
  1220. pos=[x,y]
  1221. line="{},{},{},{},{},{}\n".format(i+1,_univ,_dmx+1,pos[0],pos[1],ch)
  1222. line="{},{},{},{},{}\n".format(_univ,_dmx+1,x,y,ch)
  1223. line="{},{},x\n".format(i+1,i+1)
  1224. #print("wcsv:",[line])
  1225. #if PIXEL_MAPPING:
  1226. # log.write(line)
  1227. _log.append(line)
  1228. dmx += ch
  1229. x+=1
  1230. if mapping and PIXEL_MAPPING:
  1231. print("CREATE NEW PIXELMAP FILE !!",grid_file)
  1232. log = open(grid_file,"w")
  1233. log.writelines(_log)
  1234. log.close()
  1235. return _log[:] #GRID
  1236. def init_grid(mapping=0,_x=4,_y=4):
  1237. if mapping and PIXEL_MAPPING:
  1238. try:
  1239. log = open(grid_file,"r")
  1240. except:
  1241. generate_grid(mapping=mapping)
  1242. log = open(grid_file,"r")
  1243. lines = log.readlines()
  1244. else:
  1245. lines = generate_grid()
  1246. GRID = []
  1247. y=0
  1248. x=0
  1249. print("CSV header",[lines[0]],[PIXEL_MAPPING])
  1250. for i,line in enumerate(lines[1:]): #exclude first line
  1251. #print("rcsv",[line])
  1252. line = line.strip()
  1253. line = line.split(",") # csv
  1254. if i >= _x and i%_x == 0:
  1255. x=0
  1256. y+=1
  1257. if y >= _y:
  1258. break
  1259. #i = int(line[0])
  1260. _id = int(line[1])
  1261. #univ = int(line[0])
  1262. #dmx = int(line[1])
  1263. #x = int(line[3])
  1264. #y = int(line[4])
  1265. #ch = int(line[4])
  1266. pos = [x,y]
  1267. f = Fix(_id,pos,block) #pos,univ,dmx,ch)
  1268. #f.x = x
  1269. #f.y = y
  1270. #f.block = block
  1271. GRID.append(f)
  1272. x+=1
  1273. #print("y, _y",y,_y)
  1274. return GRID
  1275. def find_pix(x,y):
  1276. global GRID
  1277. for fix in GRID:
  1278. X = 0
  1279. Y = 0
  1280. pos = fix.POS()
  1281. #pos = fix.POS()
  1282. #pos = fix.POS(40,60-pm_wy)
  1283. #pos = fix.POS(x,y+pm_wy)#40,60)
  1284. if x > pos[0] and x < pos[0]+pos[2]:
  1285. X = 1
  1286. if y > pos[1] and y < pos[1]+pos[3]:
  1287. Y = 1
  1288. if X and Y:
  1289. #print(pos,x,y)
  1290. #print("find",X,Y)
  1291. return fix
  1292. GRID = []
  1293. _GRID = []
  1294. _GRID = init_grid(_x=8,_y=8,mapping=1) #init_gird()
  1295. NR = 0
  1296. START_UNIV=2
  1297. if options.start_univ:
  1298. try:
  1299. START_UNIV=int(options.start_univ)
  1300. except Exception as e:
  1301. print("Exception START UNIV",e)
  1302. gobo_ch=1
  1303. if options.gobo_ch:
  1304. try:
  1305. gobo_ch=int(options.gobo_ch)
  1306. except Exception as e:
  1307. print("Exception gobo_ch",e)
  1308. if gobo_ch <= 0:
  1309. gobo_ch = 1
  1310. def draw_box(pos1,pos2,color=[128,128,128],text=1):
  1311. color = [200,0,0,127]
  1312. if text:
  1313. fr = font15.render("A" ,1, (200,200,200))
  1314. window.blit(fr,pos1)
  1315. fr = font15.render("B" ,1, (200,200,200))
  1316. window.blit(fr,[pos2[0]-10,pos2[1]-10])
  1317. # h unten
  1318. _pos1 = [pos1[0],pos2[1]]
  1319. _pos2 = [pos2[0],pos2[1]]
  1320. pygame.draw.aaline(window,color,_pos1,_pos2,1)
  1321. color = [255,255,0,127]
  1322. # h rechts
  1323. _pos1 = [pos2[0],pos1[1]]
  1324. _pos2 = [pos2[0],pos2[1]]
  1325. pygame.draw.aaline(window,color,_pos1,_pos2,1)
  1326. color = [0,200,0,127]
  1327. # h links
  1328. _pos1 = [pos1[0],pos1[1]]
  1329. _pos2 = [pos1[0],pos2[1]]
  1330. pygame.draw.aaline(window,color,_pos1,_pos2,1)
  1331. color = [0,0,200,127]
  1332. # h oben
  1333. _pos1 = [pos1[0],pos1[1]]
  1334. _pos2 = [pos2[0],pos1[1]]
  1335. pygame.draw.aaline(window,color,_pos1,_pos2,1)
  1336. def grab(x=55,y=55,w=60,h=60):
  1337. # usage
  1338. # sub = grab()
  1339. # window.blit(sub, (500,10))
  1340. crop = None
  1341. rect = pygame.Rect(x, y, w, h)
  1342. try:
  1343. sub = window.subsurface(rect)
  1344. #pixArray = pygame.PixelArray(screen)
  1345. crop = pygame.Surface((w,h))
  1346. crop.blit(sub, (0,0))
  1347. except ValueError as e:
  1348. pass#print("exception",e,"line715")
  1349. #except Exception as e:
  1350. # print("exception",e,"line715")
  1351. #print(rect)
  1352. return crop
  1353. def reshape(_x,_y):
  1354. """reshape LED-WALL Block/Pixel mapping"""
  1355. if PIXEL_MAPPING <= 0:
  1356. return None
  1357. global GRID
  1358. global _GRID
  1359. x = _x
  1360. y = _y
  1361. i = 0
  1362. counter = 0
  1363. z=0
  1364. x_min = 99999
  1365. x_max = 0
  1366. y_min = 99999
  1367. y_max = 0
  1368. # black background for -> output MAP
  1369. pygame.draw.rect(window,[0,0,20],[0,60,wx,pm_wy-10])
  1370. tmp_font = pygame.font.SysFont("freemonobold",int(p*0.8))
  1371. fr = tmp_font.render("OUTPUT" ,1, (255,255,255))
  1372. fr_r = fr.get_rect(center=(x+int(wx/2),int(60+pm_wy-p*1.5)))
  1373. window.blit(fr,fr_r)
  1374. fr = tmp_font.render("↑ ↑ MAP ↑ ↑" ,1, (255,255,255))
  1375. fr_r = fr.get_rect(center=(x+int(wx/2),int(60+pm_wy-p)))
  1376. window.blit(fr,fr_r)
  1377. fr = tmp_font.render("INPUT" ,1, (255,255,255))
  1378. fr_r = fr.get_rect(center=(x+int(wx/2),int(60+pm_wy-p/2)))
  1379. window.blit(fr,fr_r)
  1380. j = 0
  1381. for fix in _GRID:
  1382. if j >= 8*8: # max output size
  1383. break
  1384. j+=1
  1385. ii = i
  1386. #z= i # helping border offset
  1387. pos = fix.POS(40,60)
  1388. rgb = fix.rgb
  1389. # green
  1390. pygame.draw.rect(window,[0,40,0],pos)
  1391. xposs = [] #None #pos[:]
  1392. for fix2 in GRID:
  1393. if fix._id == fix2._id:
  1394. xposs.append( fix2.POS(40,60) )
  1395. for xpos in xposs:
  1396. sub = grab(xpos[0],xpos[1]+pm_wy,xpos[2],xpos[3])
  1397. if sub:
  1398. if 1:#j <= _x*_y: # max input size
  1399. window.blit(sub, (x+pos[0]+z,y+pos[1]+z))
  1400. else:
  1401. # red
  1402. pygame.draw.rect(window,[40,0,0],pos) #[x+pos[0]+2+z,y+pos[1]+2+z-pm_wy,12,9])
  1403. if xpos[0] < x_min:
  1404. x_min = xpos[0]
  1405. if xpos[0] > x_max:
  1406. x_max += xpos[2]
  1407. if xpos[1] < y_min:
  1408. y_min = xpos[1]
  1409. if xpos[1] > x_max:
  1410. y_max += xpos[3]
  1411. # DRAW FIX NUMBER on TOP
  1412. #apos = pos
  1413. #argb = rgb
  1414. apos = fix.POS(40,60+pm_wy)
  1415. argb = fix.rgb
  1416. # overwrite number overlay
  1417. if NR:
  1418. #pygame.draw.rect(window,[30,40,0],apos)
  1419. pygame.draw.rect(window,[20,40,0],[x+apos[0]+2+z,y+apos[1]+2+z-pm_wy,12,9])
  1420. if NR:# == 2:
  1421. if fix._id != i+1:
  1422. fr = font15.render("{:02}".format(fix._id) ,1, (255,255,0))
  1423. window.blit(fr,(x+apos[0]+2+z,y+apos[1]+2+z-pm_wy))
  1424. #print(fix._id,xposs,pos)
  1425. else:
  1426. fr = font15.render("{:02}".format(fix._id) ,1, (100,100,255))
  1427. window.blit(fr,(x+apos[0]+2+z,y+apos[1]+2+z-pm_wy))
  1428. i += 1
  1429. #print("--#")
  1430. # frame box
  1431. #pygame.draw.box(window,[100,0,0],[x+x_min,y+x_min,x_max+x_min,y_min+y_max])
  1432. pos1= [x+x_min,y+x_min]
  1433. pos2= [x_max+x_min,y_min+y_max]
  1434. #draw_box(pos1,pos2,text=0)
  1435. class Timer():
  1436. def __init__(self,start=120):
  1437. self.start = start
  1438. self.timer = self.start
  1439. self.timer_t = time.time()
  1440. def reset(self):
  1441. self.timer = self.start
  1442. def get(self):
  1443. self.timer -= time.time()-self.timer_t
  1444. self.timer_t = time.time()
  1445. if self.timer <= 0:
  1446. self.reset()
  1447. return self.timer
  1448. def reload_grid():
  1449. print("==== reload_grid")
  1450. global GRID
  1451. global _GRID
  1452. try:
  1453. GRID = init_grid(_x=_x,_y=_y) #init_gird()
  1454. _GRID = init_grid(_x=8,_y=8,mapping=1) #init_gird()
  1455. except Exception as e:
  1456. print("Except: grid re init",e)
  1457. VPU_TEXT = []
  1458. def load_vpu_text(nr=0):
  1459. txt = "NONE"
  1460. if not VPU_TEXT:
  1461. pass #create VPU_TEXT_FILE
  1462. if len(VPU_TEXT) > nr:
  1463. txt = VPU_TEXT[0]
  1464. return txt
  1465. grid_counter = time.time()
  1466. def draw_fix_nr(GRID):
  1467. global grid_counter
  1468. i=0
  1469. y=0
  1470. for fix in GRID:
  1471. pos = fix.POS(40,60+pm_wy)
  1472. rgb = fix.rgb
  1473. if NR:
  1474. pygame.draw.rect(window,[0,0,0],[pos[0]+2,pos[1]+2,12,9])
  1475. if fix._id%_x-1 == 0: # line break border
  1476. pygame.draw.line(window,[255,255,0],(pos[0],pos[1]+4),(pos[0],pos[1]+pos[3]-4),1)
  1477. pygame.draw.line(window,[255,255,0],(pos[0],pos[1]+int(pos[3]/2)),(pos[0]+int(pos[2]/2),int(pos[1]+pos[3]/2)),1)
  1478. if fix._id%_x == 0: # line break border
  1479. pygame.draw.line(window,[255,255,255],(pos[0]+pos[2]-1,pos[1]+4),(pos[0]+pos[2]-1,pos[1]+pos[3]-4),1)
  1480. pygame.draw.line(window,[255,255,255],(pos[0]+pos[2]-1,int(pos[1]+pos[3]/2)),(pos[0]+int(pos[2]/2-1),int(pos[1]+pos[3]/2)),1)
  1481. if grid_counter +5 < time.time():
  1482. grid_counter = time.time()
  1483. reload_grid()
  1484. if fix._id != i+1:
  1485. fr = font15.render("{:02}".format(fix._id) ,1, (255,255,0))
  1486. else:
  1487. fr = font15.render("{:02}".format(fix._id) ,1, (100,100,255))
  1488. window.blit(fr,(pos[0]+2,pos[1]+2))
  1489. i += 1
  1490. def draw_counter(COUNTER):
  1491. for count in COUNTER:
  1492. cpan = 0
  1493. ctilt = 0
  1494. cr=255
  1495. cg=255
  1496. cb=255
  1497. csize=10
  1498. cdim=0
  1499. k = "DIM"
  1500. if k in count:
  1501. cdim = int(count[k])
  1502. k = "RED"
  1503. if k in count:
  1504. cr = int(count[k])
  1505. k = "GREEN"
  1506. if k in count:
  1507. cg = int(count[k])
  1508. k = "BLUE"
  1509. if k in count:
  1510. cb = int(count[k])
  1511. k = "SIZE"
  1512. if k in count:
  1513. csize = int(count[k]) #/60*p)
  1514. if csize < 5:
  1515. csize = 5
  1516. k = "PAN"
  1517. if k in count:
  1518. cpan = int(count[k])/255*(block[0] *(_x))
  1519. #cpan = int(cpan * 1.2)
  1520. cpan = int(cpan)
  1521. k = "TILT"
  1522. if k in count:
  1523. ctilt = int(count[k])/255*(block[1] *(_y))
  1524. #ctilt = int(cpan * 1.2)
  1525. ctilt = int(ctilt)
  1526. ddim = cdim/255
  1527. if "DIM" in count and count["DIM"] > 0:
  1528. tmp_font = pygame.font.SysFont("freemonobold",int(p/100*csize))
  1529. rgb =(int(cr*ddim),int(cg*ddim),int(cb*ddim),cdim)
  1530. _sec = count["_SEC"]
  1531. try:
  1532. _sec = int(count["_SEC"])
  1533. except:
  1534. pass
  1535. if type(_sec) is int:
  1536. #print(_sec)
  1537. if _sec <= 60:
  1538. fr = tmp_font.render("{:0}".format(_sec) ,1, rgb)
  1539. else:
  1540. _xx = time.strftime("%M:%S",time.localtime(_sec))
  1541. #print("_xx",_xx)
  1542. fr = tmp_font.render("{}".format(_xx) ,1, rgb)
  1543. else:
  1544. fr = tmp_font.render("{}".format((count["_SEC"])) ,1, rgb)
  1545. fr_r = fr.get_rect(center=(40+cpan-(block[0]),60+ctilt+pm_wy))
  1546. pygame.draw.rect(window,[0,0,0],fr_r)
  1547. window.blit(fr,fr_r)
  1548. def draw_video(VIDEO):
  1549. global videplayer
  1550. i = 0
  1551. # set DMX-VALUE to videoplayer Object
  1552. for count in VIDEO:
  1553. cpan = 0
  1554. ctilt = 0
  1555. cr=255
  1556. cg=255
  1557. cb=255
  1558. csize=10
  1559. cdim=0
  1560. video1 = videoplayer[i]
  1561. k = "VIDEO"
  1562. if k in count:
  1563. #video1.select_video(count[k])
  1564. play_nr = int(count[k]/10)
  1565. if play_nr != video1._video_nr:
  1566. print( "+ + + + + + + + + + +", play_nr , video1._video_nr ,str(video1))
  1567. _vid = video1._id
  1568. _cdmx = video1.dmx
  1569. del_video1 = video1
  1570. video1 = Vopen(cdmx,_id=_vid)
  1571. video1.select_video(count[k])
  1572. videoplayer[i] = video1
  1573. del_video1._del()
  1574. del del_video1
  1575. k = "DIM"
  1576. if k in count:
  1577. cdim = int(count[k])
  1578. video1.dim = cdim
  1579. #if i == 0:
  1580. # print(i,cdim)
  1581. k = "SIZE"
  1582. if k in count:
  1583. csize = int(count[k]/16*p)
  1584. if csize < 5:
  1585. csize = 5
  1586. k = "PAN"
  1587. cpan_max = block[0] *(_x) #+block[0]
  1588. if k in count:
  1589. cpan = int(count[k]) / 255*cpan_max
  1590. cpan = int(cpan)
  1591. k = "TILT"
  1592. ctilt_max = block[1] *(_y) #+block[1]
  1593. if k in count:
  1594. ctilt = int(count[k]) / 255*ctilt_max
  1595. ctilt = int(ctilt)
  1596. k = "_reset"
  1597. if k in count:
  1598. if count[k]:
  1599. count[k] = 0
  1600. video1.pos = 0
  1601. k = "_RUN"
  1602. if k in count:
  1603. video1._run = count[k]
  1604. video1.pos
  1605. video1.x=40+0+cpan
  1606. video1.y=60+0+pm_wy+ctilt
  1607. video1.scale = int((csize))
  1608. if cdim:
  1609. video1.next()
  1610. i += 1
  1611. # draw
  1612. i=0
  1613. for count in VIDEO:
  1614. video1 = videoplayer[i]
  1615. video1.draw(window) #,x=0,y=0)
  1616. i+=1
  1617. i=0
  1618. for count in VIDEO:
  1619. video1 = videoplayer[i]
  1620. video1.overlay(window,"run")
  1621. i += 1
  1622. def counter_dmx(COUNTER,dataA):
  1623. for count in COUNTER:
  1624. cDMX=count["DMX"]-1
  1625. try:
  1626. count["DIM"] = dataA[cDMX]
  1627. count["PAN"] = dataA[cDMX+1]
  1628. count["TILT"] = dataA[cDMX+2]
  1629. count["CONTROL"] = dataA[cDMX+3]
  1630. if count["CONTROL"] >= 10 and count["CONTROL"] < 20:
  1631. count["_SEC"] = int(count["SEC"] - (time.time() - count["_time"]))
  1632. if count["CONTROL"] >= 20 and count["CONTROL"] < 30:
  1633. count["_RUN"] = 0
  1634. if count["CONTROL"] >= 30 and count["CONTROL"] < 40:
  1635. count["_RUN"] = 1
  1636. count["SIZE"] = dataA[cDMX+4]
  1637. count["SEC"] = dataA[cDMX+5]
  1638. if count["_RUN"]:
  1639. try:
  1640. count["_SEC"] = int(count["SEC"] - (time.time() - count["_time"]))
  1641. except Exception as e:
  1642. pass
  1643. if type(count["_SEC"]) is int:
  1644. if count["_SEC"] < 0:
  1645. count["_SEC"] = 0
  1646. for ti in range(10):
  1647. #print(ti,(ti+6)*10)
  1648. if count["CONTROL"] >= (ti+6)*10 and count["CONTROL"] < (ti+7)*10:
  1649. count["_SEC"] = "----" #text 1
  1650. try:
  1651. count["_SEC"] = TEXT_BLOCK[ti]
  1652. except Exception as e:
  1653. pass
  1654. if count["CONTROL"] >= 250 and count["CONTROL"] < 256:
  1655. count["_SEC"] = ">{}<".format(cDMX+1)
  1656. count["RED"] = dataA[cDMX+6]
  1657. count["GREEN"] = dataA[cDMX+7]
  1658. count["BLUE"] = dataA[cDMX+8]
  1659. except Exception as e:
  1660. print("EXC FUNC",e,count)
  1661. #print(count)
  1662. def video_dmx(VIDEO,dataA):
  1663. for count in VIDEO:
  1664. cDMX=count["DMX"]-1
  1665. try:
  1666. count["DIM"] = dataA[cDMX]
  1667. count["PAN"] = dataA[cDMX+1]
  1668. count["TILT"] = dataA[cDMX+2]
  1669. count["CONTROL"] = dataA[cDMX+3]
  1670. if count["CONTROL"] >= 10 and count["CONTROL"] < 20:
  1671. count["_reset"] = 1
  1672. if count["CONTROL"] >= 20 and count["CONTROL"] < 30:
  1673. if count["_RUN"] == 1:
  1674. print( "_RUN:0",count["DMX"]-1)
  1675. count["_RUN"] = 0
  1676. if count["CONTROL"] >= 30 and count["CONTROL"] < 40:
  1677. if count["_RUN"] == 0:
  1678. print( "_RUN:1",count["DMX"]-1)
  1679. count["_RUN"] = 1
  1680. count["SIZE"] = dataA[cDMX+4]#*2
  1681. count["SEC"] = dataA[cDMX+5]
  1682. count["VIDEO"] = dataA[cDMX+6]
  1683. #count["RED"] = dataA[cDMX+6]
  1684. #count["GREEN"] = dataA[cDMX+7]
  1685. #count["BLUE"] = dataA[cDMX+8]
  1686. except Exception as e:
  1687. print("VIDEOPLAYER EXCEPT FUNC",e,count)
  1688. #print(count)
  1689. def read_dmx_data(ip,ips):
  1690. ip = select_ip(ips,univ=START_UNIV)
  1691. IP = ip
  1692. data = read_dmx(ip)
  1693. ip = select_ip(ips,univ=START_UNIV+1)
  1694. data3 = read_dmx(ip)
  1695. data.extend(data3)
  1696. ip = select_ip(ips,univ=START_UNIV+2)
  1697. data3 = read_dmx(ip)
  1698. data.extend(data3)
  1699. ip = select_ip(ips,univ=START_UNIV+4)
  1700. data3 = read_dmx(ip)
  1701. data.extend(data3)
  1702. #ip = select_ip(ips,univ=START_UNIV+5)
  1703. #data3 = read_dmx(ip)
  1704. #data.extend(data3)
  1705. return data
  1706. def draw_gobo(GRID,data):
  1707. i = 0
  1708. dmx = 1
  1709. h = 1
  1710. v = 1
  1711. for fix in GRID:
  1712. pos = fix.POS(40,60+pm_wy)
  1713. rgb = fix.rgb
  1714. if 1:
  1715. # draw row/col grid number
  1716. if fix.pos[0] == 0:
  1717. fr = font12.render("{}".format(fix.pos[1]+1) ,1, (200,200,200))
  1718. window.blit(fr,(10,pos[1]+3 ))
  1719. if fix.pos[1] == 0:
  1720. fr = font12.render("{}".format(fix.pos[0]+1) ,1, (200,200,200))
  1721. window.blit(fr,(pos[0]+2,35 ))
  1722. pygame.draw.rect(window,rgb,pos)
  1723. # DRAW SUB-FIXTURE
  1724. j = 0
  1725. for subfix in fix.sub_fix:#calc(data):
  1726. subfix.calc(data)
  1727. #fix = subfix
  1728. spos = subfix.POS(40,60+pm_wy)
  1729. srgb = subfix.rgb
  1730. #print(fix.dmx,rgb,pos)
  1731. #pygame.draw.circle(window,rgb,(pos[0]+int(pos[2]/2),pos[1]+int(pos[3]/2)),int(pos[3]/2))
  1732. #FUNC = 0
  1733. if FUNC > 10 and FUNC <= 20: # big dot
  1734. draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
  1735. elif FUNC > 20 and FUNC <= 30:#small dot
  1736. draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1737. elif FUNC > 30 and FUNC <= 40:#donut
  1738. draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
  1739. draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1740. elif FUNC > 40 and FUNC <= 50: # rec with hole
  1741. pygame.draw.rect(window,srgb,spos)
  1742. draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1743. elif FUNC > 50 and FUNC <= 60: # rec with big hole
  1744. pygame.draw.rect(window,srgb,spos)
  1745. draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
  1746. elif FUNC > 60 and FUNC <= 70: # rec with donat
  1747. pygame.draw.rect(window,srgb,spos)
  1748. draw_circle(window,[0,0,0],(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/2))
  1749. draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1750. elif FUNC > 70 and FUNC <= 80: # rec boarder
  1751. pygame.draw.rect(window,srgb,[spos[0]+1,spos[1]+1,spos[2]-2,spos[3]-2])
  1752. elif FUNC > 80 and FUNC <= 90: # rec big boarder
  1753. pygame.draw.rect(window,srgb,[spos[0]+2,spos[1]+2,spos[2]-4,spos[3]-4])
  1754. elif FUNC > 90 and FUNC <= 100: # rec thin line
  1755. pygame.draw.rect(window,srgb,spos)
  1756. pygame.draw.rect(window,[0,0,0],[spos[0]+1,spos[1]+1,spos[2]-2,spos[3]-2])
  1757. elif FUNC > 100 and FUNC <= 110: # rec big line
  1758. pygame.draw.rect(window,srgb,spos)
  1759. pygame.draw.rect(window,[0,0,0],[spos[0]+2,spos[1]+2,spos[2]-4,spos[3]-4])
  1760. elif FUNC > 110 and FUNC <= 120: # rec with dot
  1761. pygame.draw.rect(window,srgb,spos)
  1762. pygame.draw.rect(window,[0,0,0],[spos[0]+1,spos[1]+1,spos[2]-2,spos[3]-2])
  1763. draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1764. elif FUNC > 120 and FUNC <= 130: # rec inline
  1765. pygame.draw.rect(window,srgb,[spos[0]+2,spos[1]+2,spos[2]-4,spos[3]-4])
  1766. pygame.draw.rect(window,[0,0,0],[spos[0]+3,spos[1]+3,spos[2]-6,spos[3]-6])
  1767. elif FUNC > 130 and FUNC <= 140: # 3 dot (heart)
  1768. draw_circle(window,srgb,(spos[0]+int(spos[2]/2)+2,spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1769. draw_circle(window,srgb,(spos[0]+int(spos[2]/2)-2,spos[1]+int(spos[3]/2)),int(spos[3]/3.5))
  1770. draw_circle(window,srgb,(spos[0]+int(spos[2]/2),spos[1]+int(spos[3]/2)+2),int(spos[3]/3.5))
  1771. else:
  1772. pygame.draw.rect(window,srgb,spos)
  1773. for subfix in fix.sub_fix:#calc(data):
  1774. subfix.calc(data)
  1775. #fix = subfix
  1776. spos = subfix.POS(40,60+pm_wy)
  1777. srgb = subfix.rgb
  1778. # draw row/col grid number
  1779. if subfix.pos[0] == 0:
  1780. fr = font12.render("{}".format(v ) ,1, (200,200,200))
  1781. window.blit(fr,(25,spos[1] ))
  1782. v += 1
  1783. if subfix.pos[1] == 0:
  1784. fr = font12.render("{}".format(1) ,1, (200,200,200))
  1785. fr = font12.render("{}".format(h ) ,1, (200,200,200))
  1786. h+=1
  1787. window.blit(fr,(spos[0],50 ))
  1788. if p >= 40:
  1789. if NR:
  1790. #fr = font15.render("{:02}".format(j+1) ,1, (0,200,255))
  1791. fr = font15.render("{:02}".format(subfix._id) ,1, (250,200,5))
  1792. window.blit(fr,(spos[0]+2,spos[1]+10))
  1793. j += 1
  1794. i += 1
  1795. ips=[]
  1796. dataA=[]
  1797. data=[]
  1798. def dmx_raw():
  1799. global ips,dataA,data
  1800. ips = read_index()
  1801. # ----
  1802. ip = select_ip(ips,univ=1) # univ 1 gobo
  1803. dataA = read_dmx(ip)
  1804. # ----
  1805. data = read_dmx_data(ip,ips)
  1806. if options.countdown:
  1807. counter_dmx(COUNTER,dataA)
  1808. if len(VIDEO) > 0:
  1809. video_dmx(VIDEO,dataA)
  1810. return ips,dataA,data
  1811. def dmx_loop():
  1812. while 1:
  1813. dmx_raw()
  1814. time.sleep(0.1)
  1815. dmx_raw()
  1816. thread.start_new_thread(dmx_loop,())
  1817. t1 = Timer(143)
  1818. time.sleep(0.33)
  1819. t2 = Timer(11)
  1820. count_tilt = 0
  1821. def main():
  1822. global IP
  1823. global GRID
  1824. global _GRID
  1825. global FUNC
  1826. global count_tilt
  1827. global TEXT_BLOCK
  1828. global TEXT_BLOCK_TIME
  1829. global PLAYLIST
  1830. global PLAYLIST_TIME
  1831. global dataA
  1832. GRID = init_grid(_x=_x,_y=_y) #init_gird()
  1833. #GRID = init_grid(_x=8,_y=8) #init_gird()
  1834. print("GRID LEN:",len(GRID))
  1835. s=time.time()
  1836. print("run")
  1837. r = ""
  1838. IP = "xx"
  1839. while running:
  1840. if TEXT_BLOCK_TIME+5 < time.time():
  1841. TEXT_BLOCK = open_text_block()
  1842. TEXT_BLOCK_TIME = time.time()
  1843. if PLAYLIST_TIME+6 < time.time():
  1844. PLAYLIST = open_playlist()
  1845. PLAYLIST_TIME = time.time()
  1846. pygame.display.flip()
  1847. event()
  1848. window.fill((10,0,30))
  1849. calc_fps()
  1850. draw_overlay()
  1851. # GRID loop
  1852. try:
  1853. ddd = 1023 #univ 3 512
  1854. #FUNC = data[ddd]
  1855. FUNC2 = dataA[gobo_ch-1]
  1856. FUNC = FUNC2
  1857. #print("FUNC", FUNC )#:ddd+512])
  1858. #FUNC = 15
  1859. except Exception as e:
  1860. print("EXC FUNC",e)
  1861. draw_gobo(GRID,data)
  1862. # DRAW FIX NUMBER on TOP
  1863. draw_fix_nr(GRID)
  1864. #COUNTER.append({"DMX":31,"DIM":0,"PAN":127,"TILT":127,"CONTROL":0,"SEC":10,"RED":255,"GREEN":255,"BLUE":255,"_time":time.time(),"_RUN":0,"_SEC":0})
  1865. if VIDEO:
  1866. draw_video(VIDEO)
  1867. if options.countdown:
  1868. draw_counter(COUNTER)
  1869. pointer.draw(0,pm_wy) #wy
  1870. spos = [0,0,0,0]
  1871. if PIXEL_MAPPING >= 1:
  1872. reshape(0,0) #start pos
  1873. else:
  1874. reshape(spos[0]+spos[2]+20,10) #start pos
  1875. #reshape(spos[0]+spos[2]+20,10) #start pos
  1876. pygame.display.flip()
  1877. #pg.time.wait(15)
  1878. #clock.tick(10)
  1879. clock.tick(25)
  1880. if 'SDL_VIDEO_WINDOW_POS' in os.environ:
  1881. del os.environ['SDL_VIDEO_WINDOW_POS'] #= '%i,%i' % (200,164)
  1882. #if 'SDL_VIDEO_CENTERED' in os.environ['SDL_VIDEO_CENTERED']:
  1883. # del os.environ['SDL_VIDEO_CENTERED'] #= '0'
  1884. if __name__ == "__main__":
  1885. main()