98_powerMap.pm 56 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894
  1. ###############################################################################
  2. # $Id: 98_powerMap.pm 14012 2017-04-17 13:09:41Z loredo $
  3. #
  4. # TODO
  5. # - document how to include powerMap for other module maintainers
  6. # (see 50_HP1000)
  7. #
  8. package main;
  9. use strict;
  10. use warnings;
  11. use Data::Dumper;
  12. use Unit;
  13. # module hashes ###############################################################
  14. my %powerMap_tmpl = (
  15. # Format example for devices w/ model support:
  16. #
  17. # '<TYPE>' => {
  18. # '(<INTERNAL>|<Attribute>)' => {
  19. # '<VAL of INTERNAL or Attribute>' => {
  20. #
  21. # # This is the actual powerMap definition
  22. # '<Reading>' => {
  23. # '<VAL>' => '<Watt>',
  24. # },
  25. # },
  26. # },
  27. #
  28. #
  29. # # This is w/ user attributes
  30. #
  31. # '(<INTERNAL>|<Attribute>)' => {
  32. # '<VAL of INTERNAL or Attribute>' => {
  33. # 'attribute1' => 'value1',
  34. # 'attribute2' => 'value2',
  35. #
  36. # # This is the actual powerMap definition
  37. # 'map' => {
  38. # '<Reading>' => {
  39. # '<VAL>' => '<Watt>',
  40. # },
  41. # },
  42. # },
  43. # },
  44. # },
  45. # Format example for devices w/o model support:
  46. #
  47. # '<TYPE>' => {
  48. #
  49. # # This is the actual powerMap definition
  50. # '<Reading>' => {
  51. # '<VAL>' => '<Watt>',
  52. # },
  53. # },
  54. # Format example for mapping table and user attributes:
  55. #
  56. # '<TYPE>' => {
  57. # 'attribute1' => 'value1',
  58. # 'attribute2' => 'value2',
  59. #
  60. # # This is the actual powerMap definition
  61. # 'map' => {
  62. # '<Reading>' => {
  63. # '<VAL>' => '<Watt>',
  64. # },
  65. # },
  66. # },
  67. # TYPE alias to mirror values
  68. #
  69. # '<TYPE1>' => '<TYPE2>',
  70. #
  71. FS20 => {
  72. state => {
  73. 0 => 0.5,
  74. 100 => 60,
  75. },
  76. },
  77. HMCCU => {
  78. state => {
  79. '*' => 7.5,
  80. },
  81. },
  82. HMCCUCHN => "HMCCUDEV", # alias / forward to other TYPE
  83. HMCCUDEV => {
  84. ccutype => {
  85. 'HM-LC-Dim1TPBU-FM' => {
  86. hmstate => {
  87. unreachable => 0,
  88. working => 101,
  89. up => 101,
  90. down => 101,
  91. 0 => 1.0,
  92. 100 => 101,
  93. },
  94. },
  95. 'HM-LC-Dim1T-FM' => {
  96. hmstate => {
  97. unreachable => 0,
  98. working => 23.5,
  99. up => 23.5,
  100. down => 23.5,
  101. 0 => 1.0,
  102. 100 => 23.5,
  103. },
  104. },
  105. 'HM-LC-Sw2-PB-FM' => {
  106. hmstate => {
  107. unreachable => 0,
  108. off => 0.25,
  109. on => 100.25,
  110. },
  111. },
  112. 'HM-LC-Bl1PBU-FM' => {
  113. hmstate => {
  114. unreachable => 0,
  115. working => 121,
  116. up => 121,
  117. down => 121,
  118. '*' => 0.5,
  119. },
  120. },
  121. 'HM-LC-Bl1-SM' => {
  122. hmstate => {
  123. unreachable => 0,
  124. working => 121,
  125. up => 121,
  126. down => 121,
  127. '*' => 0.4,
  128. },
  129. },
  130. },
  131. },
  132. HUEBridge => {
  133. model => 'modelid',
  134. modelid => {
  135. BSB001 => {
  136. rname_E => 'energy',
  137. rname_P => 'consumption',
  138. map => {
  139. state => {
  140. 0 => 0,
  141. '*' => 1.669,
  142. },
  143. },
  144. },
  145. BSB002 => {
  146. rname_E => 'energy',
  147. rname_P => 'consumption',
  148. map => {
  149. state => {
  150. 0 => 0,
  151. '*' => 1.669,
  152. },
  153. },
  154. },
  155. },
  156. },
  157. HUEDevice => {
  158. model => 'modelid',
  159. modelid => {
  160. # Hue Bulb
  161. LCT001 => {
  162. rname_E => 'energy',
  163. rname_P => 'consumption',
  164. map => {
  165. pct => {
  166. 0 => 0.4,
  167. 100 => 8.5,
  168. },
  169. state => {
  170. unreachable => 0,
  171. '*' => 'pct',
  172. },
  173. },
  174. },
  175. # Hue Spot BR30
  176. LCT002 => {},
  177. # Hue Spot GU10
  178. LCT003 => {},
  179. # Hue Bulb V2
  180. LCT007 => {
  181. rname_E => 'energy',
  182. rname_P => 'consumption',
  183. map => {
  184. pct => {
  185. 0 => 0.4,
  186. 100 => 10,
  187. },
  188. state => {
  189. unreachable => 0,
  190. '*' => 'pct',
  191. },
  192. },
  193. },
  194. # Hue Bulb V3
  195. LCT010 => {
  196. rname_E => 'energy',
  197. rname_P => 'consumption',
  198. map => {
  199. pct => {
  200. 0 => 0.4,
  201. 100 => 8.5,
  202. },
  203. state => {
  204. unreachable => 0,
  205. '*' => 'pct',
  206. },
  207. },
  208. },
  209. # Hue BR30
  210. LCT011 => {},
  211. # Hue Bulb V3
  212. LCT014 => {},
  213. # Living Colors G2
  214. LLC001 => {},
  215. # Living Colors Bloom
  216. LLC005 => {},
  217. # Living Colors Gen3 Iris
  218. LLC006 => {},
  219. # Living Colors Gen3 Bloom
  220. LLC007 => {},
  221. # Living Colors Iris
  222. LLC010 => {},
  223. # Living Colors Bloom
  224. LLC011 => {},
  225. # Living Colors Bloom
  226. LLC012 => {},
  227. # Disney Living Colors
  228. LLC013 => {},
  229. # Living Colors Aura
  230. LLC014 => {},
  231. # Hue Go
  232. LLC020 => {},
  233. # Hue LightStrip
  234. LST001 => {
  235. rname_E => 'energy',
  236. rname_P => 'consumption',
  237. map => {
  238. pct => {
  239. 0 => 0.4,
  240. 100 => 12,
  241. },
  242. state => {
  243. unreachable => 0,
  244. '*' => 'pct',
  245. },
  246. },
  247. },
  248. # Hue LightStrip Plus
  249. LST002 => {
  250. rname_E => 'energy',
  251. rname_P => 'consumption',
  252. map => {
  253. pct => {
  254. 0 => 0.4,
  255. 100 => 20.5,
  256. },
  257. state => {
  258. unreachable => 0,
  259. '*' => 'pct',
  260. },
  261. },
  262. },
  263. # Living Whites Bulb
  264. LWB001 => {
  265. rname_E => 'energy',
  266. rname_P => 'consumption',
  267. map => {
  268. pct => {
  269. 0 => 0.4,
  270. 10 => 1.2,
  271. 20 => 1.7,
  272. 30 => 1.9,
  273. 40 => 2.3,
  274. 50 => 2.7,
  275. 60 => 3.4,
  276. 70 => 4.7,
  277. 80 => 5.9,
  278. 90 => 7.5,
  279. 100 => 9.2,
  280. },
  281. state => {
  282. unreachable => 0,
  283. '*' => 'pct',
  284. },
  285. },
  286. },
  287. # Living Whites Bulb
  288. LWB003 => {
  289. rname_E => 'energy',
  290. rname_P => 'consumption',
  291. map => {
  292. pct => {
  293. 0 => 0.4,
  294. 10 => 1.2,
  295. 20 => 1.7,
  296. 30 => 1.9,
  297. 40 => 2.3,
  298. 50 => 2.7,
  299. 60 => 3.4,
  300. 70 => 4.7,
  301. 80 => 5.9,
  302. 90 => 7.5,
  303. 100 => 9.2,
  304. },
  305. state => {
  306. unreachable => 0,
  307. '*' => 'pct',
  308. },
  309. },
  310. },
  311. # Hue Lux
  312. LWB004 => {},
  313. # Hue Lux
  314. LWB006 => {},
  315. # Hue Lux
  316. LWB007 => {},
  317. # Hue A19 White Ambience
  318. LTW001 => {},
  319. # Hue A19 White Ambience
  320. LTW004 => {},
  321. # Hue GU10 White Ambience
  322. LTW013 => {},
  323. # Hue GU10 White Ambience
  324. LTW014 => {},
  325. # Color Light Module
  326. LLM001 => {},
  327. # Color Temperature Module
  328. LLM010 => {},
  329. # Color Temperature Module
  330. LLM011 => {},
  331. # Color Temperature Module
  332. LLM012 => {},
  333. # LivingWhites Outlet
  334. LWL001 => {},
  335. # Hue Dimmer Switch
  336. RWL020 => {},
  337. # Hue Dimmer Switch
  338. RWL021 => {},
  339. # Hue Tap
  340. ZGPSWITCH => {},
  341. # dresden elektronik FLS-H lp
  342. 'FLS-H3' => {},
  343. # dresden elektronik FLS-PP lp
  344. 'FLS-PP3' => {},
  345. # LIGHTIFY Flex RGBW
  346. 'Flex RGBW' => {},
  347. # LIGHTIFY Classic A60 RGBW
  348. 'Classic A60 RGBW' => {},
  349. # LIGHTIFY Gardenspot Mini RGB
  350. 'Gardenspot RGB' => {},
  351. # LIGHTIFY Surface light tunable white
  352. 'Surface Light TW' => {},
  353. # LIGHTIFY Classic A60 tunable white
  354. 'Classic A60 TW' => {},
  355. # LIGHTIFY Classic B40 tunable white
  356. 'Classic B40 TW' => {},
  357. # LIGHTIFY PAR16 50 tunable white
  358. 'PAR16 50 TW' => {},
  359. # LIGHTIFY Plug
  360. 'Plug - LIGHTIFY' => {},
  361. # LIGHTIFY Plug
  362. 'Plug 01' => {},
  363. # Busch-Jaeger ZigBee Light Link Relais
  364. 'RM01' => {},
  365. # Busch-Jaeger ZigBee Light Link Dimmer
  366. 'DM01' => {},
  367. },
  368. },
  369. netatmo => {
  370. model => {
  371. NAMain => {
  372. temperature => {
  373. '*' => 5,
  374. },
  375. },
  376. },
  377. },
  378. Panstamp => {
  379. 'Pumpe_Heizkreis' => {
  380. 'off' => "0,Pumpe_Boiler,Brenner",
  381. 'on' => "30,Pumpe_Boiler,Brenner",
  382. },
  383. 'Pumpe_Boiler' => {
  384. 'off' => "0,Pumpe_Heizkreis,Brenner",
  385. 'on' => "30,Pumpe_Heizkreis,Brenner",
  386. },
  387. 'Brenner' => {
  388. 'off' => "0,Pumpe_Heizkreis,Pumpe_Boiler",
  389. 'on' => "40,Pumpe_Heizkreis,Pumpe_Boiler",
  390. },
  391. },
  392. SONOSPLAYER => {
  393. model => {
  394. Sonos_S6 => {
  395. stateAV => {
  396. disappeared => 0,
  397. off => 2.2,
  398. mute => 2.2,
  399. pause => 2.2,
  400. on => 14.5,
  401. },
  402. },
  403. Sonos_S5 => {
  404. stateAV => {
  405. disappeared => 0,
  406. off => 8.3,
  407. mute => 8.3,
  408. pause => 8.3,
  409. on => 14.5,
  410. },
  411. },
  412. Sonos_S3 => {
  413. stateAV => {
  414. disappeared => 0,
  415. off => 4.4,
  416. mute => 4.4,
  417. pause => 4.4,
  418. on => 11.3,
  419. },
  420. },
  421. Sonos_S1 => {
  422. stateAV => {
  423. disappeared => 0,
  424. off => 3.8,
  425. mute => 3.8,
  426. pause => 3.8,
  427. on => 5.2,
  428. },
  429. },
  430. },
  431. },
  432. );
  433. # initialize ##################################################################
  434. sub powerMap_Initialize($) {
  435. my ($hash) = @_;
  436. my $TYPE = "powerMap";
  437. $hash->{DefFn} = $TYPE . "_Define";
  438. $hash->{UndefFn} = $TYPE . "_Undefine";
  439. $hash->{SetFn} = $TYPE . "_Set";
  440. $hash->{GetFn} = $TYPE . "_Get";
  441. $hash->{AttrFn} = $TYPE . "_Attr";
  442. $hash->{NotifyFn} = $TYPE . "_Notify";
  443. $hash->{AttrList} =
  444. "disable:1,0 disabledForIntervals do_not_notify:1,0 "
  445. . $TYPE
  446. . "_gridV:230,110 "
  447. . $TYPE
  448. . "_eventChainWarnOnly:1,0 "
  449. . $readingFnAttributes;
  450. addToAttrList( $TYPE . "_noEnergy:1,0" );
  451. addToAttrList( $TYPE . "_noPower:1,0" );
  452. addToAttrList( $TYPE . "_interval" );
  453. addToAttrList( $TYPE . "_rname_P:textField" );
  454. addToAttrList( $TYPE . "_rname_E:textField" );
  455. addToAttrList( $TYPE . ":textField-long" );
  456. }
  457. # regular Fn ##################################################################
  458. sub powerMap_Define($$) {
  459. my ( $hash, $def ) = @_;
  460. my ( $name, $type, $rest ) = split( /[\s]+/, $def, 3 );
  461. my $TYPE = $hash->{TYPE};
  462. my $d = $modules{$TYPE}{defptr};
  463. return "Usage: define <name> $TYPE" if ($rest);
  464. return "$TYPE device already defined as $d->{NAME}" if ( defined($d) );
  465. my $interval = AttrVal( $name, $TYPE . "_interval", 900 );
  466. $interval = 900 unless ( looks_like_number($interval) );
  467. $interval = 30 if ( $interval < 30 );
  468. $modules{$TYPE}{defptr} = $hash;
  469. $hash->{INTERVAL} = $interval;
  470. $hash->{STATE} = "Initialized";
  471. return;
  472. }
  473. sub powerMap_Undefine($$) {
  474. my ( $hash, $arg ) = @_;
  475. my $name = $hash->{NAME};
  476. my $TYPE = $hash->{TYPE};
  477. delete $modules{$TYPE}{defptr};
  478. # terminate powerMap for each device
  479. foreach ( devspec2array("i:pM_update=.+") ) {
  480. RemoveInternalTimer("$name|$_");
  481. delete $defs{$_}{pM_update};
  482. delete $defs{$_}{pM_interval};
  483. }
  484. return;
  485. }
  486. sub powerMap_Set($@) {
  487. my ( $hash, @a ) = @_;
  488. return "Missing argument" if ( @a < 2 );
  489. my $TYPE = $hash->{TYPE};
  490. my $name = shift @a;
  491. my $argument = shift @a;
  492. my $value = join( " ", @a ) if (@a);
  493. my $assign;
  494. my $maps = powerMap_findPowerMaps($name);
  495. foreach ( sort keys %{$maps} ) {
  496. $assign .= "," if ($assign);
  497. $assign .= $_;
  498. }
  499. my %powerMap_sets = ( "assign" => "assign:$assign", );
  500. return "Unknown argument $argument, choose one of "
  501. . join( " ", values %powerMap_sets )
  502. unless ( exists( $powerMap_sets{$argument} ) );
  503. my $ret;
  504. if ( $argument eq "assign" ) {
  505. my @devices = devspec2array($value);
  506. return "No matching device found." unless (@devices);
  507. foreach my $d (@devices) {
  508. next
  509. unless ( ref( $maps->{$d}{map} ) eq "HASH"
  510. && keys %{ $maps->{$d}{map} } );
  511. # write attributes
  512. $Data::Dumper::Terse = 1;
  513. $Data::Dumper::Deepcopy = 1;
  514. $Data::Dumper::Sortkeys = 1;
  515. foreach ( sort keys %{ $maps->{$d} } ) {
  516. my $n = $_;
  517. $n = $TYPE if ( $_ eq "map" );
  518. $n = $TYPE . "_" . $_ unless ( $n =~ /^$TYPE/ );
  519. my $txt = $maps->{$d}{$_};
  520. $txt = Dumper( $maps->{$d}{$_} ) if ( $_ eq "map" );
  521. $ret .= CommandAttr( undef, "$d $n $txt" );
  522. $ret .= "$d - Added attribute $n\n" if ( @devices > 1 );
  523. }
  524. $Data::Dumper::Terse = 0;
  525. $Data::Dumper::Deepcopy = 0;
  526. $Data::Dumper::Sortkeys = 0;
  527. }
  528. }
  529. return $ret;
  530. }
  531. sub powerMap_Get($@) {
  532. my ( $hash, @a ) = @_;
  533. return "Missing argument" if ( @a < 2 );
  534. my $TYPE = $hash->{TYPE};
  535. my $name = shift @a;
  536. my $argument = shift @a;
  537. my $value = join( " ", @a ) if (@a);
  538. my %powerMap_gets = ( "devices" => "devices:noArg", );
  539. return "Unknown argument $argument, choose one of "
  540. . join( " ", values %powerMap_gets )
  541. unless ( exists( $powerMap_gets{$argument} ) );
  542. my $ret;
  543. if ( $argument eq "devices" ) {
  544. my $pmdevs = powerMap_findPowerMaps( $name, ":PM_ENABLED" );
  545. return keys %{$pmdevs}
  546. ? join( "\n", sort keys %{$pmdevs} )
  547. : "No powerMap enabled devices found.";
  548. }
  549. return $ret;
  550. }
  551. sub powerMap_Attr(@) {
  552. my ( $cmd, $name, $attribute, $value ) = @_;
  553. my $hash = $defs{$name};
  554. my $TYPE = $hash->{TYPE};
  555. if ( $attribute eq "disable" ) {
  556. readingsSingleUpdate( $hash, "state", "disabled", 1 )
  557. if ( $value and $value == 1 );
  558. readingsSingleUpdate( $hash, "state", "enabled", 1 )
  559. if ( $cmd eq "del" or !$value );
  560. }
  561. return if ( IsDisabled($name) );
  562. if ( $attribute eq $TYPE . "_interval" ) {
  563. my $interval = $cmd eq "set" ? $value : 900;
  564. $interval = 900 unless ( looks_like_number($interval) );
  565. $interval = 30 if ( $interval < 30 );
  566. $hash->{INTERVAL} = $interval;
  567. }
  568. return;
  569. }
  570. sub powerMap_Notify($$) {
  571. my ( $hash, $dev_hash ) = @_;
  572. my $name = $hash->{NAME};
  573. my $dev = $dev_hash->{NAME};
  574. my $TYPE = $hash->{TYPE};
  575. return
  576. if (
  577. !$init_done
  578. or IsDisabled($name)
  579. or IsDisabled($dev)
  580. or $name eq $dev # do not process own events
  581. or powerMap_AttrVal( $name, $dev, "noPower", 0 )
  582. or ( !$modules{ $defs{$dev}{TYPE} }{$TYPE}
  583. and !$defs{$dev}{$TYPE}
  584. and $dev ne "global" )
  585. );
  586. my $events = deviceEvents( $dev_hash, 1 );
  587. return unless ($events);
  588. Log3 $name, 5, "$TYPE: Entering powerMap_Notify() for $dev";
  589. # global events
  590. if ( $dev eq "global" ) {
  591. foreach my $event ( @{$events} ) {
  592. next unless ( defined($event) );
  593. # initialize or terminate powerMap for each device
  594. if ( $event =~ /^(INITIALIZED|REREADCFG|SHUTDOWN)$/ ) {
  595. foreach ( keys %{ powerMap_findPowerMaps( $name, ":PM_$1" ) } )
  596. {
  597. next
  598. if ( $_ eq "global"
  599. or $_ eq $name
  600. or
  601. powerMap_AttrVal( $name, $_, $TYPE . "_noEnergy", 0 ) );
  602. powerMap_update("$name|$dev") if ( $1 eq "SHUTDOWN" );
  603. next
  604. unless ( $1 eq "SHUTDOWN"
  605. || powerMap_load( $name, $_, undef, 1 ) );
  606. Log3 $name, 4, "$TYPE: $1 for $_";
  607. }
  608. }
  609. # device attribute deleted
  610. elsif ( $event =~ m/^(DELETEATTR)\s(.*)\s($TYPE)(\s+(.*))?/ ) {
  611. powerMap_unload( $name, $2 );
  612. }
  613. # device attribute changed
  614. elsif ( $event =~
  615. m/^(ATTR|DELETEATTR)\s(.*)\s($TYPE[a-zA-Z_]*)(\s+(.*))?/ )
  616. {
  617. next unless ( powerMap_load( $name, $2 ) );
  618. Log3 $name, 4, "$TYPE: UPDATED for $2";
  619. }
  620. # device was deleted
  621. elsif ( $event =~ m/^(DELETED)\s(.*)/ ) {
  622. powerMap_unload( $name, $2 );
  623. }
  624. # device was newly defined, modified or renamed
  625. elsif ( $event =~ m/^(DEFINED|MODIFIED|RENAMED)\s(.*)/ ) {
  626. next unless ( powerMap_load( $name, $2 ) );
  627. Log3 $name, 4, "$TYPE: INITIALIZED for $2";
  628. }
  629. }
  630. return;
  631. }
  632. my $rname_e = powerMap_AttrVal( $name, $dev, "rname_E", "pM_energy" );
  633. my $rname_p = powerMap_AttrVal( $name, $dev, "rname_P", "pM_consumption" );
  634. my $powerRecalcDone;
  635. # foreign device events
  636. foreach my $event ( @{$events} ) {
  637. next
  638. if (!$event
  639. or $event =~ /^($rname_e|$rname_p): /
  640. or $event !~ /: / );
  641. # only recalculate once no matter
  642. # how many events we get at once
  643. unless ($powerRecalcDone) {
  644. my $power = powerMap_power( $name, $dev, $event );
  645. if ( defined($power) ) {
  646. $powerRecalcDone = 1;
  647. powerMap_update( "$name|$dev", $power );
  648. # recalculate CHANGEDWITHSTATE
  649. # for target device in deviceEvents()
  650. $dev_hash->{CHANGEDWITHSTATE} = [];
  651. last;
  652. }
  653. }
  654. }
  655. readingsSingleUpdate( $hash, "state", "Last device: $dev", 1 )
  656. if ($powerRecalcDone);
  657. return undef;
  658. }
  659. # module Fn ####################################################################
  660. sub powerMap_AttrVal($$$$) {
  661. my ( $p, $d, $n, $default ) = @_;
  662. my $TYPE = $defs{$p}{TYPE};
  663. Log3 $p, 6, "$TYPE: Entering powerMap_AttrVal() for $d";
  664. return $default if ( !$TYPE );
  665. # device attribute
  666. #
  667. my $da = AttrVal( $d, $TYPE . "_" . $n, AttrVal( $d, $n, undef ) );
  668. return $da if ( defined($da) );
  669. # device INTERNAL
  670. #
  671. # $defs{device}{TYPE}{attribute}
  672. return $defs{$d}{$TYPE}{$n}
  673. if ( $d
  674. && IsDevice($d)
  675. && defined( $defs{$d}{$TYPE} )
  676. && defined( $defs{$d}{$TYPE}{$n} ) );
  677. # $defs{device}{.TYPE}{attribute}
  678. return $defs{$d}{".$TYPE"}{$n}
  679. if ( $d
  680. && IsDevice($d)
  681. && defined( $defs{$d}{".$TYPE"} )
  682. && defined( $defs{$d}{".$TYPE"}{$n} ) );
  683. # $defs{device}{TYPE_attribute}
  684. return $defs{$d}{ $TYPE . "_" . $n }
  685. if ( $d
  686. && IsDevice($d)
  687. && defined( $defs{$d}{ $TYPE . "_" . $n } ) );
  688. # $defs{device}{attribute}
  689. return $defs{$d}{$n}
  690. if ( $d
  691. && IsDevice($d)
  692. && defined( $defs{$d}{$n} ) );
  693. # $defs{device}{.TYPE_attribute}
  694. return $defs{$d}{ "." . $TYPE . "_" . $n }
  695. if ( $d
  696. && IsDevice($d)
  697. && defined( $defs{$d}{ "." . $TYPE . "_" . $n } ) );
  698. # $defs{device}{.attribute}
  699. return $defs{$d}{".$n"}
  700. if ( $d
  701. && IsDevice($d)
  702. && defined( $defs{$d}{".$n"} ) );
  703. # module HASH
  704. #
  705. my $t = GetType($d);
  706. # $modules{module}{TYPE}{attribute}
  707. return $modules{$t}{$TYPE}{$n}
  708. if ( $t
  709. && defined( $modules{$t} )
  710. && defined( $modules{$t}{$TYPE} )
  711. && defined( $modules{$t}{$TYPE}{$n} ) );
  712. # $modules{module}{TYPE}{TYPE_attribute}
  713. return $modules{$t}{$TYPE}{ $TYPE . "_" . $n }
  714. if ( $t
  715. && defined( $modules{$t} )
  716. && defined( $modules{$t}{$TYPE} )
  717. && defined( $modules{$t}{$TYPE}{ $TYPE . "_" . $n } ) );
  718. # module attribute
  719. #
  720. return AttrVal( $p, $TYPE . "_" . $n, AttrVal( $p, $n, $default ) );
  721. }
  722. sub powerMap_load($$;$$) {
  723. my ( $name, $dev, $unload, $modSupport ) = @_;
  724. my $dev_hash = $defs{$dev};
  725. my $TYPE = $defs{$name}{TYPE};
  726. Log3 $name, 5, "$TYPE: Entering powerMap_load() for $dev";
  727. unless ($dev_hash) {
  728. RemoveInternalTimer("$name|$dev");
  729. delete $dev_hash->{pM_update}
  730. if ( defined( $dev_hash->{pM_update} ) );
  731. delete $dev_hash->{pM_interval}
  732. if ( defined( $dev_hash->{pM_interval} ) );
  733. return;
  734. }
  735. my $powerMap = $unload ? undef : AttrVal( $dev, $TYPE, undef );
  736. my $rname_e = powerMap_AttrVal( $name, $dev, "rname_E", "pM_energy" );
  737. my $rname_p = powerMap_AttrVal( $name, $dev, "rname_P", "pM_consumption" );
  738. # Support for Unit.pm
  739. $dev_hash->{readingsDesc}{$rname_e} = { rtype => 'whr', };
  740. $dev_hash->{readingsDesc}{$rname_p} = { rtype => 'w', };
  741. # Enable Unit.pm for DbLog
  742. if ( $modules{ $dev_hash->{TYPE} }{DbLog_splitFn}
  743. or $dev_hash->{DbLog_splitFn}
  744. or $dev_hash->{'.DbLog_splitFn'} )
  745. {
  746. Log3 $name, 5,
  747. "$TYPE: $dev has defined it's own DbLog_splitFn; "
  748. . "won't enable unit support with DbLog but rather "
  749. . "let this to the module itself";
  750. }
  751. else {
  752. Log3 $name, 4, "$TYPE: Enabled unit support for $dev";
  753. $dev_hash->{'.DbLog_splitFn'} = "Unit_DbLog_split";
  754. }
  755. # restore original powerMap from module
  756. if ( defined( $dev_hash->{$TYPE}{map} )
  757. and defined( $dev_hash->{$TYPE}{'map.module'} ) )
  758. {
  759. Log3 $dev, 5,
  760. "$TYPE $dev: Updated device hash with module mapping table";
  761. delete $dev_hash->{$TYPE}{map};
  762. $dev_hash->{$TYPE}{map} = $dev_hash->{$TYPE}{'map.module'};
  763. delete $dev_hash->{$TYPE}{'map.module'};
  764. }
  765. # delete device specific map
  766. elsif ( $unload && defined( $dev_hash->{$TYPE}{map} ) ) {
  767. delete $dev_hash->{$TYPE}{map};
  768. }
  769. unless ($powerMap) {
  770. return powerMap_update("$name|$dev")
  771. if ($modSupport);
  772. RemoveInternalTimer("$name|$dev");
  773. delete $dev_hash->{pM_update}
  774. if ( defined( $dev_hash->{pM_update} ) );
  775. delete $dev_hash->{pM_interval}
  776. if ( defined( $dev_hash->{pM_interval} ) );
  777. return;
  778. }
  779. if ( $powerMap =~ m/=>/
  780. and $powerMap !~ m/\$/ )
  781. {
  782. $powerMap = "{" . $powerMap . "}" if ( $powerMap !~ m/^{.*}$/s );
  783. my $map = eval $powerMap;
  784. if ($@) {
  785. Log3 $dev, 3,
  786. "$TYPE $dev: Unable to evaluate attribute $TYPE: " . $@;
  787. }
  788. elsif ( ref($map) ne "HASH" ) {
  789. Log3 $dev, 3,
  790. "$TYPE $dev: Attribute $TYPE was not defined in HASH format";
  791. }
  792. else {
  793. # backup any pre-existing definitions from module
  794. if ( defined( $dev_hash->{$TYPE}{map} ) ) {
  795. Log3 $dev, 4,
  796. "$TYPE $dev: Updated device hash with user mapping table";
  797. $dev_hash->{$TYPE}{'map.module'} =
  798. $dev_hash->{$TYPE}{map};
  799. delete $dev_hash->{$TYPE}{map};
  800. }
  801. else {
  802. Log3 $dev, 4,
  803. "$TYPE $dev: Updated device hash with mapping table";
  804. }
  805. $dev_hash->{$TYPE}{map} = $map;
  806. powerMap_verifyEventChain( $name, $dev, $map );
  807. return powerMap_update("$name|$dev");
  808. }
  809. }
  810. else {
  811. Log3 $dev, 3, "$TYPE $dev: Illegal format for attribute $TYPE";
  812. }
  813. return 0;
  814. }
  815. sub powerMap_unload($$) {
  816. my ( $n, $d ) = @_;
  817. return powerMap_load( $n, $d, 1 );
  818. }
  819. sub powerMap_findPowerMaps($;$) {
  820. my ( $name, $dev ) = @_;
  821. my %maps;
  822. # directly return any existing device specific definition
  823. if ( $dev && $dev !~ /^:/ ) {
  824. return {}
  825. unless ( IsDevice($dev) );
  826. return $defs{$dev}{powerMap}{map}
  827. if (
  828. $defs{$dev}{powerMap}{map}
  829. && ref( $defs{$dev}{powerMap}{map} ) eq "HASH"
  830. && keys %{ $defs{$dev}{powerMap}{map} }
  831. && powerMap_verifyEventChain(
  832. $name, $dev, $defs{$dev}{powerMap}{map}
  833. )
  834. );
  835. }
  836. # get all devices with direct powerMap definitions
  837. else {
  838. foreach ( devspec2array("i:powerMap=.+") ) {
  839. $maps{$_}{map} = $defs{$_}{powerMap}{map}
  840. if ( $defs{$_}{powerMap}{map}
  841. && ref( $defs{$_}{powerMap}{map} ) eq "HASH"
  842. && keys %{ $defs{$_}{powerMap}{map} } );
  843. }
  844. # during initialization, also find devices where we
  845. # need to load their custom attribute into the hash
  846. if ( $dev && $dev eq ":PM_INITIALIZED" ) {
  847. foreach ( devspec2array("a:powerMap=.+") ) {
  848. $maps{$_}{map} = {} if ( !$maps{$_}{map} );
  849. }
  850. }
  851. }
  852. # search templates from modules
  853. foreach
  854. my $TYPE ( $dev && $dev !~ /^:/ ? $defs{$dev}{TYPE} : keys %modules )
  855. {
  856. next
  857. unless ( $modules{$TYPE}{powerMap}
  858. && keys %{ $modules{$TYPE}{powerMap} } );
  859. my $t = $modules{$TYPE}{powerMap};
  860. my $modelSupport = 0;
  861. # modules w/ model support
  862. unless ( $t->{map} ) {
  863. foreach my $ta ( keys %{$t} ) {
  864. my $a = $t->{$ta};
  865. $a = $t->{ $t->{$ta} }
  866. if ( !ref( $t->{$ta} )
  867. && $t->{ $t->{$ta} } );
  868. next unless ( ref($a) eq "HASH" && !$a->{map} );
  869. foreach my $tm ( keys %{$a} ) {
  870. my $m = $a->{$tm};
  871. $m = $a->{ $a->{$tm} }
  872. if ( !ref( $a->{$tm} )
  873. && $a->{ $a->{$tm} } );
  874. next unless ( ref($m) eq "HASH" );
  875. $modelSupport = 1;
  876. foreach ( devspec2array("TYPE=$TYPE:FILTER=$ta=$tm") ) {
  877. next if ( $maps{$_} );
  878. if ( $m->{map} ) {
  879. next unless ( keys %{ $m->{map} } );
  880. $maps{$_} = $m;
  881. }
  882. else {
  883. next unless ( keys %{$m} );
  884. $maps{$_}{map} = $m;
  885. }
  886. }
  887. }
  888. }
  889. }
  890. # modules w/o model support
  891. unless ($modelSupport) {
  892. foreach ( devspec2array("TYPE=$TYPE") ) {
  893. next if ( $maps{$_} );
  894. if ( $t->{map} ) {
  895. next unless ( keys %{ $t->{map} } );
  896. $maps{$_} = $t;
  897. }
  898. else {
  899. next unless ( keys %{$t} );
  900. $maps{$_}{map} = $t;
  901. }
  902. }
  903. }
  904. }
  905. # find possible template for each Fhem device
  906. unless ($dev) {
  907. foreach my $TYPE ( keys %powerMap_tmpl ) {
  908. next unless ( $modules{$TYPE} );
  909. my $t = $powerMap_tmpl{$TYPE};
  910. $t = $powerMap_tmpl{ $powerMap_tmpl{$TYPE} }
  911. if ( !ref( $powerMap_tmpl{$TYPE} )
  912. && $powerMap_tmpl{ $powerMap_tmpl{$TYPE} } );
  913. my $modelSupport = 0;
  914. # modules w/ model support
  915. foreach my $ta ( keys %{$t} ) {
  916. my $a = $t->{$ta};
  917. $a = $t->{ $t->{$ta} }
  918. if ( !ref( $t->{$ta} )
  919. && $t->{ $t->{$ta} } );
  920. next unless ( ref($a) eq "HASH" );
  921. foreach my $m ( keys %{$a} ) {
  922. next
  923. unless ( ref( $a->{$m} ) eq "HASH"
  924. && !$a->{map} );
  925. $modelSupport = 1;
  926. foreach ( devspec2array("TYPE=$TYPE:FILTER=$ta=$m") ) {
  927. next if ( $maps{$_} );
  928. if ( $a->{$m}{map} ) {
  929. next unless ( keys %{ $a->{$m}{map} } );
  930. $maps{$_} = $a->{$m};
  931. }
  932. else {
  933. next unless ( keys %{ $a->{$m} } );
  934. $maps{$_}{map} = $a->{$m};
  935. }
  936. }
  937. }
  938. }
  939. # modules w/o model support
  940. unless ($modelSupport) {
  941. foreach ( devspec2array("TYPE=$TYPE") ) {
  942. next if ( $maps{$_} );
  943. if ( $t->{map} ) {
  944. next unless ( keys %{ $t->{map} } );
  945. $maps{$_} = $t;
  946. }
  947. else {
  948. next unless ( keys %{$t} );
  949. $maps{$_}{map} = $t;
  950. }
  951. }
  952. }
  953. }
  954. }
  955. foreach my $d ( keys %maps ) {
  956. # filter devices where no reading exists
  957. unless ( $dev && $dev eq ":PM_INITIALIZED" ) {
  958. if ( !$maps{$d}{map} || ref( $maps{$d}{map} ) ne "HASH" ) {
  959. delete $maps{$d};
  960. next;
  961. }
  962. my $verified = 0;
  963. foreach ( keys %{ $maps{$d}{map} } ) {
  964. if ( ReadingsVal( $d, $_, undef ) ) {
  965. $verified = 1;
  966. last;
  967. }
  968. }
  969. delete $maps{$d} unless ($verified);
  970. }
  971. powerMap_verifyEventChain( $name, $d, $maps{$d}{map} );
  972. }
  973. return {}
  974. if ( $dev && $dev !~ /^:/ && !defined( $maps{$dev} ) );
  975. return $maps{$dev}{map} if ( $dev && $dev !~ /^:/ );
  976. return \%maps;
  977. }
  978. sub powerMap_verifyEventChain($$$) {
  979. my ( $name, $dev, $map ) = @_;
  980. my $TYPE = $defs{$name}{TYPE};
  981. my %filter;
  982. return 0 unless ( ref($map) eq "HASH" );
  983. my $attrminint = AttrVal( $dev, "event-min-interval", undef );
  984. if ($attrminint) {
  985. my @a = split( /,/, $attrminint );
  986. $filter{attrminint} = \@a;
  987. }
  988. my $attraggr = AttrVal( $dev, "event-aggregator", undef );
  989. if ($attraggr) {
  990. my @a = split( /,/, $attraggr );
  991. $filter{attraggr} = \@a;
  992. }
  993. my $attreocr = AttrVal( $dev, "event-on-change-reading", undef );
  994. if ($attreocr) {
  995. my @a = split( /,/, $attreocr );
  996. $filter{attreocr} = \@a;
  997. }
  998. my $attreour = AttrVal( $dev, "event-on-update-reading", undef );
  999. if ($attreour) {
  1000. my @a = split( /,/, $attreour );
  1001. $filter{attreour} = \@a;
  1002. }
  1003. my $attrtocr = AttrVal( $dev, "timestamp-on-change-reading", undef );
  1004. if ($attrtocr) {
  1005. my @a = split( /,/, $attrtocr );
  1006. $filter{attrtocr} = \@a;
  1007. }
  1008. return 1 unless ( keys %filter );
  1009. my $leocr = "";
  1010. foreach my $reading ( keys %{$map} ) {
  1011. # verify reocr + reour
  1012. if ( $filter{attreocr} || $filter{attreour} ) {
  1013. my $eocr = $filter{attreocr}
  1014. && (
  1015. my @eocrv = grep {
  1016. my $l = $_;
  1017. $l =~ s/:.*//;
  1018. ( $reading =~ m/^$l$/ ) ? $_ : undef
  1019. } @{ $filter{attreocr} }
  1020. );
  1021. my $eour = $filter{attreour}
  1022. && grep( $reading =~ m/^$_$/, @{ $filter{attreour} } );
  1023. unless ($eour) {
  1024. if (
  1025. !$eocr
  1026. || ( $eocrv[0] =~ m/.*:(.*)/
  1027. && ( !looks_like_number($1) || $1 > 0 ) )
  1028. )
  1029. {
  1030. $leocr .= "," if ( $leocr ne "" );
  1031. $leocr .= $reading;
  1032. }
  1033. if ( $filter{attrtocr}
  1034. && grep( $reading =~ m/^$_$/, @{ $filter{attrtocr} } ) )
  1035. {
  1036. Log3 $dev, 2,
  1037. "$TYPE $dev: WARNING - Attribute "
  1038. . "timestamp-on-change-reading is not compatible "
  1039. . "when using $TYPE with reading '$reading'";
  1040. }
  1041. }
  1042. }
  1043. # verify min-interval
  1044. my @v = grep {
  1045. my $l = $_;
  1046. $l =~ s/:.*//;
  1047. ( $reading =~ m/^$l$/ ) ? $_ : undef
  1048. } @{ $filter{attrminint} };
  1049. if (@v) {
  1050. Log3 $dev, 2,
  1051. "$TYPE $dev: WARNING - Attribute "
  1052. . "event-min-interval is not compatible "
  1053. . "when using $TYPE with reading '$reading'";
  1054. }
  1055. # verify aggregator
  1056. my @v2 = grep {
  1057. my $l = $_;
  1058. $l =~ s/:.*//;
  1059. ( $reading =~ m/^$l$/ ) ? $_ : undef
  1060. } @{ $filter{attraggr} };
  1061. if (@v2) {
  1062. Log3 $dev, 2,
  1063. "$TYPE $dev: WARNING - Attribute "
  1064. . "event-aggregator is not compatible "
  1065. . "when using $TYPE with reading '$reading'";
  1066. }
  1067. }
  1068. if ( $leocr ne "" ) {
  1069. if ( powerMap_AttrVal( $name, $dev, "eventChainWarnOnly", 0 ) ) {
  1070. Log3 $dev, 2,
  1071. "$TYPE $dev: ERROR: Broken event chain - Attributes "
  1072. . "event-on-change-reading or event-on-update-reading "
  1073. . "need to contain reading(s) '$leocr'";
  1074. }
  1075. else {
  1076. Log3 $dev, 2,
  1077. "$TYPE $dev: NOTE - Attribute "
  1078. . "event-on-change-reading adjusted "
  1079. . "to fulfill event chain for reading(s) '$leocr'";
  1080. $attreocr .= "," if ($attreocr);
  1081. $attreocr .= $leocr;
  1082. CommandAttr( undef, "$dev event-on-change-reading $attreocr" );
  1083. }
  1084. }
  1085. return 1;
  1086. }
  1087. sub powerMap_power($$$;$);
  1088. sub powerMap_power($$$;$) {
  1089. my ( $name, $dev, $event, $loop ) = @_;
  1090. my $hash = $defs{$name};
  1091. my $TYPE = $hash->{TYPE};
  1092. my $power = 0;
  1093. my $powerMap = powerMap_findPowerMaps( $name, $dev );
  1094. return unless ( defined($powerMap) and ref($powerMap) eq "HASH" );
  1095. if ( $event =~ /^([A-Za-z\d_\.\-\/]+):\s+(.*)$/ ) {
  1096. my ( $reading, $val ) = ( $1, $2 );
  1097. my $num = ( $val =~ /(-?\d+(\.\d+)?)/ ? $1 : $val );
  1098. my $valueAliases = {
  1099. initialized => '0',
  1100. unavailable => '0',
  1101. disappeared => '0',
  1102. absent => '0',
  1103. disabled => '0',
  1104. disconnected => '0',
  1105. off => '0',
  1106. on => '100',
  1107. connected => '100',
  1108. enabled => '100',
  1109. present => '100',
  1110. appeared => '100',
  1111. available => '100',
  1112. };
  1113. $num = $valueAliases->{ lc($val) }
  1114. if ( defined( $valueAliases->{ lc($val) } )
  1115. and looks_like_number( $valueAliases->{ lc($val) } ) );
  1116. # no power consumption defined for this reading
  1117. return unless ( defined( $powerMap->{$reading} ) );
  1118. Log3 $name, 5, "$TYPE: Entering powerMap_power() for $dev:$reading";
  1119. Log3 $dev, 5, "$TYPE $dev: $reading: val=$val num=$num";
  1120. # direct assigned power consumption (value)
  1121. if ( defined( $powerMap->{$reading}{$val} ) ) {
  1122. $power = $powerMap->{$reading}{$val};
  1123. }
  1124. # valueAliases mapping
  1125. elsif ( defined( $valueAliases->{ lc($val) } )
  1126. and
  1127. defined( $powerMap->{$reading}{ $valueAliases->{ lc($val) } } ) )
  1128. {
  1129. $power = $powerMap->{$reading}{ $valueAliases->{ lc($val) } };
  1130. }
  1131. # direct assigned power consumption (numeric)
  1132. elsif ( defined( $powerMap->{$reading}{$num} ) ) {
  1133. $power = $powerMap->{$reading}{$num};
  1134. }
  1135. # value interpolation
  1136. elsif ( looks_like_number($num) ) {
  1137. my ( $val1, $val2 );
  1138. foreach ( sort { $a cmp $b } keys( %{ $powerMap->{$reading} } ) ) {
  1139. next unless ( looks_like_number($_) );
  1140. $val1 = $_ if ( $_ < $num );
  1141. $val2 = $_ if ( $_ > $num );
  1142. last if ( defined($val2) );
  1143. }
  1144. if ($val2) {
  1145. Log3 $dev, 5,
  1146. "$TYPE $dev: $reading: Interpolating power value "
  1147. . "between $val1 and $val2";
  1148. my $y1 = $powerMap->{$reading}{$val1};
  1149. $y1 =~ s/^([-\.\d]+)(.*)/$1/g;
  1150. my $y1t = $2;
  1151. $y1 = 0 unless ( looks_like_number($y1) );
  1152. my $y2 = $powerMap->{$reading}{$val2};
  1153. $y2 =~ s/^([-\.\d]+)(.*)/$1/g;
  1154. my $y2t = $2;
  1155. $y2 = 0 unless ( looks_like_number($y2) );
  1156. my $m = ( ($y2) - ($y1) ) / ( ($val2) - ($val1) );
  1157. my $b =
  1158. ( ( ($val2) * ($y1) ) - ( ($val1) * ($y2) ) ) /
  1159. ( ($val2) - ($val1) );
  1160. my $powerFormat =
  1161. powerMap_AttrVal( $name, $dev, "format_P", undef );
  1162. if ($powerFormat) {
  1163. $power =
  1164. sprintf( $powerFormat, ( ($m) * ($num) ) + ($b) );
  1165. }
  1166. else {
  1167. $power = ( ($m) * ($num) ) + ($b);
  1168. }
  1169. if ( !$loop && $power - $y1 < $y2 - $power ) {
  1170. $power .= $y1t;
  1171. }
  1172. elsif ( !$loop ) {
  1173. $power .= $y2t;
  1174. }
  1175. }
  1176. elsif ( defined( $powerMap->{$reading}{'*'} ) ) {
  1177. $power = $powerMap->{$reading}{'*'};
  1178. }
  1179. else {
  1180. Log3 $dev, 3, "$TYPE $dev: Power value interpolation failed";
  1181. }
  1182. }
  1183. elsif ( defined( $powerMap->{$reading}{'*'} ) ) {
  1184. $power = $powerMap->{$reading}{'*'};
  1185. }
  1186. # consider additional readings if desired
  1187. unless ( looks_like_number($power) ) {
  1188. my $sum = 0;
  1189. my $rlist = join( ",", keys %{$powerMap} );
  1190. $power =~ s/\*/$rlist/;
  1191. foreach ( split( ",", $power ) ) {
  1192. next if ( $reading eq $_ );
  1193. if ( looks_like_number($_) ) {
  1194. $sum += $_;
  1195. last if ($loop);
  1196. }
  1197. elsif ( defined( $powerMap->{$_} ) && !$loop ) {
  1198. Log3 $dev, 5, "$TYPE $dev: $_: Adding to total";
  1199. my $ret = powerMap_power( $name, $dev,
  1200. "$_: " . ReadingsVal( $dev, $_, "" ), 1 );
  1201. $sum += $ret if ( looks_like_number($ret) );
  1202. }
  1203. }
  1204. $power = $sum;
  1205. }
  1206. }
  1207. return "?" unless ( looks_like_number($power) );
  1208. return $power;
  1209. }
  1210. sub powerMap_energy($$;$) {
  1211. my ( $name, $dev, $P1 ) = @_;
  1212. my $hash = $defs{$name};
  1213. my $dev_hash = $defs{$dev};
  1214. my $TYPE = $hash->{TYPE};
  1215. my $rname_e = powerMap_AttrVal( $name, $dev, "rname_E", "pM_energy" );
  1216. my $rname_p = powerMap_AttrVal( $name, $dev, "rname_P", "pM_consumption" );
  1217. Log3 $name, 5, "$TYPE: Entering powerMap_energy() for $dev";
  1218. my $E0 = ReadingsVal( $dev, $rname_e, 0 );
  1219. my $P0 = ReadingsVal( $dev, $rname_p, 0 );
  1220. $P0 = 0 unless ( looks_like_number($P0) );
  1221. $P1 = $P0 unless ( defined($P1) );
  1222. $P1 = 0 unless ( looks_like_number($P1) );
  1223. my $Dt = ReadingsAge( $dev, $rname_e, 0 ) / 3600;
  1224. my $DE = $P0 * $Dt;
  1225. my $E1 = $E0 + $DE;
  1226. Log3( $dev, 4,
  1227. "$TYPE $dev: energy calculation results:\n"
  1228. . " energyOld : $E0 Wh\n"
  1229. . " powerOld : $P0 W\n"
  1230. . " power : $P1 W\n"
  1231. . " timeframe : $Dt h\n"
  1232. . " energyDiff: $DE Wh\n"
  1233. . " energy : $E1 Wh" );
  1234. return ( $E1, $P1 );
  1235. }
  1236. sub powerMap_update($;$) {
  1237. my ( $name, $dev ) = split( "\\|", shift );
  1238. my ($power) = @_;
  1239. my $hash = $defs{$name};
  1240. my $dev_hash = $defs{$dev};
  1241. my $TYPE = $hash->{TYPE};
  1242. RemoveInternalTimer("$name|$dev");
  1243. delete $dev_hash->{pM_update}
  1244. if ( defined( $dev_hash->{pM_update} ) );
  1245. delete $dev_hash->{pM_interval}
  1246. if ( defined( $dev_hash->{pM_interval} ) );
  1247. return
  1248. unless ( !IsDisabled($name) and defined($hash) and defined($dev_hash) );
  1249. Log3 $name, 5, "$TYPE: Entering powerMap_update() for $dev";
  1250. my $rname_e = powerMap_AttrVal( $name, $dev, "rname_E", "pM_energy" );
  1251. my $rname_p = powerMap_AttrVal( $name, $dev, "rname_P", "pM_consumption" );
  1252. readingsBeginUpdate($dev_hash);
  1253. unless ( powerMap_AttrVal( $name, $dev, "noEnergy", 0 ) ) {
  1254. my ( $energy, $P1 ) = powerMap_energy( $name, $dev, $power );
  1255. readingsBulkUpdate( $dev_hash, $rname_e . "_begin", time() )
  1256. unless ( ReadingsVal( $dev, $rname_e, undef ) );
  1257. readingsBulkUpdate( $dev_hash, $rname_e, $energy );
  1258. if ($P1) {
  1259. $dev_hash->{pM_interval} =
  1260. powerMap_AttrVal( $name, $dev, $TYPE . "_interval",
  1261. $hash->{INTERVAL} );
  1262. $dev_hash->{pM_interval} = 900
  1263. unless ( looks_like_number( $dev_hash->{pM_interval} ) );
  1264. $dev_hash->{pM_interval} = 30
  1265. if ( $dev_hash->{pM_interval} < 30 );
  1266. my $next = gettimeofday() + $dev_hash->{pM_interval};
  1267. $dev_hash->{pM_update} = FmtDateTime($next);
  1268. Log3 $dev, 5,
  1269. "$TYPE $dev: next update in "
  1270. . $dev_hash->{pM_interval}
  1271. . " s at "
  1272. . $dev_hash->{pM_update};
  1273. InternalTimer( $next, "powerMap_update", "$name|$dev" );
  1274. }
  1275. else {
  1276. Log3 $dev, 5, "$TYPE $dev: no power consumption, update paused";
  1277. }
  1278. }
  1279. readingsBulkUpdate( $dev_hash, $rname_p, $power )
  1280. if ( defined($power) );
  1281. readingsEndUpdate( $dev_hash, 1 );
  1282. return 1;
  1283. }
  1284. 1;
  1285. # commandref ##################################################################
  1286. =pod
  1287. =item helper
  1288. =item summary maps power and calculates energy (as Readings)
  1289. =item summary_DE leitet Leistung ab und berechnet Energie (als Readings)
  1290. =begin html
  1291. <a name="powerMap"></a>
  1292. <h3>powerMap</h3>
  1293. (en | <a href="commandref_DE.html#powerMap">de</a>)
  1294. <div>
  1295. <ul>
  1296. powerMap will help to determine current power consumption and calculates
  1297. energy consumption either when power changes or within regular interval.<br>
  1298. These new values may be used to collect energy consumption for devices w/o
  1299. power meter (e.g. fridge, lighting or FHEM server) and for further processing
  1300. using module <a href="#ElectricityCalculator">ElectricityCalculator</a>.
  1301. <br>
  1302. <a name="powerMapdefine"></a>
  1303. <b>Define</b>
  1304. <ul>
  1305. <code>define &lt;name&gt; powerMap</code><br>
  1306. You may only define one single instance of powerMap.
  1307. </ul><br>
  1308. <a name="powerMapset"></a>
  1309. <b>Set</b>
  1310. <ul>
  1311. <li>
  1312. <code>assign <a href="#devspec">&lt;devspec&gt;</a></code><br>
  1313. Adds pre-defined powerMap attributes to one or more devices
  1314. for further customization.
  1315. </li>
  1316. </ul><br>
  1317. <a name="powerMapget"></a>
  1318. <b>Get</b>
  1319. <ul>
  1320. <li>
  1321. <code>devices</code><br>
  1322. Lists all devices having set an attribute named 'powerMap'.
  1323. </li>
  1324. </ul><br>
  1325. <a name="powerMapreadings"></a>
  1326. <b>Readings</b><br>
  1327. <ul>
  1328. Device specific readings:
  1329. <ul>
  1330. <li>
  1331. <code>pM_energy</code><br>
  1332. A counter for consumed energy in Wh.<br>
  1333. Hint: In order to have the calculation working, attribute
  1334. <code>timestamp-on-change-reading</code> may not be set for
  1335. reading pM_energy!
  1336. </li><br>
  1337. <li>
  1338. <code>pM_energy_begin</code><br>
  1339. Unix timestamp when collection started and device started to consume
  1340. energy for the very first time.
  1341. </li><br>
  1342. <li>
  1343. <code>pM_consumption</code><br>
  1344. Current power consumption of device in W.
  1345. </li>
  1346. </ul><br>
  1347. </ul>
  1348. <a name="powerMapattr"></a>
  1349. <b>Attribute</b>
  1350. <ul>
  1351. <li>
  1352. <code>disable 1</code><br>
  1353. No readings will be created or calculated by this module.
  1354. </li><br>
  1355. <li>
  1356. <code>powerMap_eventChainWarnOnly &lt;1&gt;</code><br>
  1357. When set, event chain will NOT be repaired automatically if readings
  1358. were found to be required for powerMap but their events are currently
  1359. suppressed because they are either missing from attributes event-on-change-reading
  1360. or event-on-update-reading. Instead, manual intervention is required.
  1361. </li><br>
  1362. <li>
  1363. <code>powerMap_interval &lt;seconds&gt;</code><br>
  1364. Interval in seconds to calculate energy.<br>
  1365. Default value is 900 seconds.
  1366. </li><br>
  1367. <li>
  1368. <code>powerMap_noEnergy 1</code><br>
  1369. No energy consumption will be calculated for that device.
  1370. </li><br>
  1371. <li>
  1372. <code>powerMap_noPower 1</code><br>
  1373. No power consumption will be determined for that device and
  1374. consequently no energy consumption at all.
  1375. </li><br>
  1376. <li>
  1377. <code>powerMap_rname_E</code><br>
  1378. Sets reading name for energy consumption.<br>
  1379. Default value is 'pM_energy'.
  1380. </li><br>
  1381. <li>
  1382. <code>powerMap_rname_P</code><br>
  1383. Sets reading name for power consumption.<br>
  1384. Default value is 'pM_consumption'.
  1385. </li><br>
  1386. <li>
  1387. <code>powerMap<pre>
  1388. {
  1389. '&lt;reading&gt;' =&gt; {
  1390. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1391. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1392. ...
  1393. },
  1394. '&lt;reading&gt;' {
  1395. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1396. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1397. ...
  1398. },
  1399. ...
  1400. }</pre>
  1401. </code> (device specific)<br>
  1402. A Hash containing event(=reading) names and possible values of it. Each value can be assigned a
  1403. corresponding power consumption.<br>
  1404. For devices with dimming capability intemediate values will be linearly interpolated. For this
  1405. to work two separate numbers will be sufficient.<br>
  1406. <br>
  1407. Text values will automatically get any numbers extracted from it and be used for interpolation.
  1408. (example: dim50% will automatically be interpreted as 50).<br>
  1409. In addition "off" and "on" will be translated to 0 and 100 respectively.<br>
  1410. If the value cannot be interpreted in any way, 0 power consumption will be assumed.<br>
  1411. Explicitly set definitions in powerMap attribute always get precedence.<br>
  1412. <br>
  1413. In case several power values need to be summarized, the name of other readings may be added after
  1414. number value, separated by comma. The current status of that reading will then be considered for
  1415. total power calculcation. To consider all readings powerMap knows, just add an *.<br>
  1416. <br>
  1417. Example for FS20 socket:
  1418. <ul>
  1419. <code><pre>
  1420. 'state' =&gt; {
  1421. '0' =&gt; 0,
  1422. '100' =&gt; 60,
  1423. },
  1424. </pre></code><br>
  1425. </ul><br>
  1426. Example for HUE white light bulb:
  1427. <ul>
  1428. <code><pre>
  1429. 'pct' =&gt; {
  1430. '0' =&gt; 0.4,
  1431. '10' =&gt; 1.2,
  1432. '20' =&gt; 1.7,
  1433. '30' =&gt; 1.9,
  1434. '40' =&gt; 2.3,
  1435. '50' =&gt; 2.7,
  1436. '60' =&gt; 3.4,
  1437. '70' =&gt; 4.7,
  1438. '80' =&gt; 5.9,
  1439. '90' =&gt; 7.5,
  1440. '100' =&gt; 9.2,
  1441. },
  1442. 'state' =&gt; {
  1443. 'unreachable' =&gt; 0,
  1444. '*' =&gt; 'pct',
  1445. },
  1446. </pre></code><br>
  1447. </ul>
  1448. </li>
  1449. </ul>
  1450. </ul>
  1451. </div>
  1452. =end html
  1453. =begin html_DE
  1454. <a name="powerMap"></a>
  1455. <h3>powerMap</h3>
  1456. (<a href="commandref.html#powerMap">en</a> | de)
  1457. <div>
  1458. <ul>
  1459. powerMap ermittelt die aktuelle Leistungsaufnahme eines Ger&auml;ts und
  1460. berechnet den Energieverbrauch bei &Auml;nderung oder in einem
  1461. regelm&auml;&szlig;igen Intervall.<br>
  1462. Diese neuen Werte k&ouml;nnen genutzt werden, um den Stromverbrauch f&uuml;r
  1463. Ger&auml;te ohne Z&auml;hler (z.B. K&uuml;hlschrank, Beleuchtung oder
  1464. FHEM-Server) zu erfassen und mit dem Modul ElectricityCalculator weiter
  1465. zu verarbeiten.<br>
  1466. <br>
  1467. <a name="powerMapdefine"></a>
  1468. <b>Define</b>
  1469. <ul>
  1470. <code>define &lt;name&gt; powerMap</code><br>
  1471. Es kann immer nur eine powerMap Instanz definiert sein.
  1472. </ul><br>
  1473. <a name="powerMapset"></a>
  1474. <b>Set</b>
  1475. <ul>
  1476. <li>
  1477. <code>assign <a href="#devspec">&lt;devspec&gt;</a></code><br>
  1478. Weist einem oder mehreren Ger&auml;ten vordefinierte powerMap Attribute zu,
  1479. um diese anschlie&szlig;end anpassen zu k&ouml;nnen.
  1480. </li>
  1481. </ul><br>
  1482. <a name="powerMapget"></a>
  1483. <b>Get</b>
  1484. <ul>
  1485. <li>
  1486. <code>devices</code><br>
  1487. Listet alle Ger&auml;te auf, die das Attribut 'powerMap' gesetzt haben.
  1488. </li>
  1489. </ul><br>
  1490. <a name="powerMapreadings"></a>
  1491. <b>Readings</b><br>
  1492. <ul>
  1493. Ger&auml;tespezifische Readings:
  1494. <ul>
  1495. <li>
  1496. <code>pM_energy</code><br>
  1497. Ein Z&auml;hler f&uuml;r die bisher bezogene Energie in Wh.<br>
  1498. Hinweis: F&uuml;r eine korrekte Berechnung darf das Attribut
  1499. <code>timestamp-on-change-reading</code> nicht für das Reading
  1500. pM_energy gesetzt sein!
  1501. </li><br>
  1502. <li>
  1503. <code>pM_energy_begin</code><br>
  1504. Unix Timestamp, an dem die Aufzeichnung begonnen wurde und das
  1505. Ger&auml;t erstmalig Energie verbraucht hat.
  1506. </li><br>
  1507. <li>
  1508. <code>pM_consumption</code><br>
  1509. Die aktuelle Leistungsaufnahme des Ger&auml;tes in W.
  1510. </li>
  1511. </ul><br>
  1512. </ul>
  1513. <a name="powerMapattr"></a>
  1514. <b>Attribute</b>
  1515. <ul>
  1516. <li>
  1517. <code>disable 1</code><br>
  1518. Es werden keine Readings mehr durch das Modul erzeugt oder berechnet.
  1519. </li><br>
  1520. <li>
  1521. <code>powerMap_eventChainWarnOnly &lt;1&gt;</code><br>
  1522. Sofern gesetzt, wird die Ereigniskette NICHT automatisch repariert, falls
  1523. Readings zwar als f&uuml;r powerMap notwendig identifiziert wurden, ihre
  1524. Events jedoch derzeit dadurch unterdr&uuml;ckt werden, weil sie nicht in
  1525. einem der Attribute event-on-change-reading oder event-on-update-reading
  1526. enthalten sind. Stattdessen ist ein manueller Eingriff erforderlich.
  1527. </li><br>
  1528. <li>
  1529. <code>powerMap_interval &lt;seconds&gt;</code><br>
  1530. Intervall in Sekunden, in dem neue Werte f&uuml;r die Energie berechnet
  1531. werden.<br>
  1532. Der Vorgabewert ist 900 Sekunden.
  1533. </li><br>
  1534. <li>
  1535. <code>powerMap_noEnergy 1</code><br>
  1536. F&uuml;r das Ger&auml;t wird kein Energieverbrauch berechnet.
  1537. </li><br>
  1538. <li>
  1539. <code>powerMap_noPower 1</code><br>
  1540. F&uuml;r das Ger&auml;t wird keine Leistungsaufnahme abgeleitet und
  1541. daher auch kein Energieverbrauch berechnet.
  1542. </li><br>
  1543. <li>
  1544. <code>powerMap_rname_E</code><br>
  1545. Definiert den Reading Namen, in dem der Z&auml;hler f&uuml;r die bisher
  1546. bezogene Energie gespeichert wird.<br>
  1547. Der Vorgabewert ist 'pM_energy'.
  1548. </li><br>
  1549. <li>
  1550. <code>powerMap_rname_P</code><br>
  1551. Definiert den Reading Namen, in dem die aktuelle Leistungsaufnahme
  1552. des Ger&auml;tes gespeichert wird.<br>
  1553. Der Vorgabewert ist 'pM_consumption'.
  1554. </li><br>
  1555. <li>
  1556. <code>powerMap<pre>
  1557. {
  1558. '&lt;reading&gt;' =&gt; {
  1559. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1560. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1561. ...
  1562. },
  1563. '&lt;reading&gt;' {
  1564. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1565. '&lt;value&gt;' =&gt; &lt;power&gt;,
  1566. ...
  1567. },
  1568. ...
  1569. }</pre>
  1570. </code> (ger&auml;tespezifisch)<br>
  1571. Ein Hash mit den Event(=Reading) Namen und seinen möglichen Werten, um diesen
  1572. die dazugeh&ouml;rige Leistungsaufnahme zuzuordnen.<br>
  1573. Bei dimmbaren Ger&auml;ten wird f&uuml;r die Zwischenschritte der Wert
  1574. durch eine lineare Interpolation ermittelt, so dass mindestens zwei Zahlenwerte ausreichen.<br>
  1575. <br>
  1576. Aus Textwerten, die eine Zahl enthalten, wird automatisch die Zahl extrahiert und
  1577. f&uuml;r die Interpolation verwendet (Beispiel: dim50% wird automatisch als 50 interpretiert).<br>
  1578. Au&szlig;erdem werden "off" und "on" automatisch als 0 respektive 100 interpretiert.<br>
  1579. Nicht interpretierbare Werte f&uuml;hren dazu, dass eine Leistungsaufnahme von 0 angenommen wird.<br>
  1580. Explizit in powerMap enthaltene Definitionen haben immer vorrang.<br>
  1581. <br>
  1582. F&uuml;r den Fall, dass mehrere Verbrauchswerte addiert werden sollen, kann der Name von anderen
  1583. Readings direkt hinter dem eigentliche Wert mit einem Komma abgetrennt angegeben werden.
  1584. Der aktuelle Status dieses Readings wird dann bei der Berechnung des Gesamtverbrauchs ebenfalls
  1585. ber&uumL;cksichtigt. Sollen alle in powerMap bekannten Readings ber&uuml;cksichtigt werden, kann
  1586. auch einfach ein * angegeben werden.<br>
  1587. <br>
  1588. Beispiel f&uuml;r einen FS20 Stecker:
  1589. <ul>
  1590. <code><pre>
  1591. 'state' =&gt; {
  1592. '0' =&gt; 0,
  1593. '100' =&gt; 60,
  1594. },
  1595. </pre></code><br>
  1596. </ul><br>
  1597. Beispiel f&uuml;r eine HUE white Gl&uuml;hlampe:
  1598. <ul>
  1599. <code><pre>
  1600. 'pct' =&gt; {
  1601. '0' =&gt; 0.4,
  1602. '10' =&gt; 1.2,
  1603. '20' =&gt; 1.7,
  1604. '30' =&gt; 1.9,
  1605. '40' =&gt; 2.3,
  1606. '50' =&gt; 2.7,
  1607. '60' =&gt; 3.4,
  1608. '70' =&gt; 4.7,
  1609. '80' =&gt; 5.9,
  1610. '90' =&gt; 7.5,
  1611. '100' =&gt; 9.2,
  1612. },
  1613. 'state' =&gt; {
  1614. 'unreachable' =&gt; 0,
  1615. '*' =&gt; 'pct',
  1616. },
  1617. </pre></code><br>
  1618. </ul>
  1619. </li>
  1620. </ul>
  1621. </ul>
  1622. </div>
  1623. =end html_DE
  1624. =cut