/* groovylint-disable CompileStatic, CouldBeElvis, CouldBeSwitchStatement, DuplicateMapLiteral, DuplicateNumberLiteral, DuplicateStringLiteral, ImplicitClosureParameter, InsecureRandom, LineLength, MethodCount, MethodSize, PublicMethodsBeforeNonPublicMethods, SpaceAroundOperator, ThrowException, UnnecessaryGetter, UnnecessarySetter */ /** * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except * in compliance with the License. You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License * for the specific language governing permissions and limitations under the License. * * This DTH is coded based on iquix's tuya-window-shade DTH and these other files: * https://github.com/iquix/Smartthings/blob/master/devicetypes/iquix/tuya-window-shade.src/tuya-window-shade.groovy * https://raw.githubusercontent.com/shin4299/XiaomiSJ/master/devicetypes/shinjjang/zemismart-zigbee-blind.src/zemismart-zigbee-blind.groovy * https://templates.blakadder.com/zemismart_YH002.html * https://github.com/zigpy/zha-device-handlers/blob/f3302257fbb57f9f9f99ecbdffdd2e7862cc1fd7/zhaquirks/tuya/__init__.py#L846 * * VERSION HISTORY * * 1.0.0 (2021-03-09) [Amos Yuen] - Initial Commit * 2.0.0 (2021-03-09) [Amos Yuen] - Change tilt mode open()/close() commands to use set position to open/close all the way.; Rename pause() to stop(); Remove superfluous setDirection() setMode() functions * 2.1.0 (2021-05-01) [Amos Yuen] - Add pushable button capability Add configurable close and open position thresholds * 2.2.0 (2021-06-06) [Amos Yuen] - Add commands for stepping; Fix push command not sending zigbee commands * 2.3.0 (2021-06-09) [Amos Yuen] - Add presence attribute to indicate whether device is responsive; * 3.0.0 (2021-06-18) [Amos Yuen] - Support new window shade command startPositionChange(); Rename stop() to stopPositionChange(); Handle ack and set time zigbee messages * 3.1.0 (2022-04-07) [kkossev] - added new devices fingerprints; blind position reporting; Tuya time synchronization; * 3.1.1 (2022-04-26) [kkossev] - added more TS0601 fingerprints; atomicState bug fix; added invertPosition option; added 'SwitchLevel' capability (Alexa); added POSITION_UPDATE_TIMEOUT timer * 3.1.2 (2022-04-30) [kkossev] - added AdvancedOptions; positionReportTimeout as preference parameter; added Switch capability; commands Open/Close/Stop differ depending on the model/manufacturer * 3.1.3 (2022-05-01) [kkossev] - _TZE200_nueqqe6k and _TZE200_rddyvrci O/C/S commands correction; startPositionChange bug fix; * 3.1.4 (2022-05-02) [kkossev] - added 'target' state variable; handle mixedDP2reporting; Configure() loads default Advanced Options depending on model/manufacturer; added INFO logging; added importUrl: * 3.1.5 (2022-05-02) [kkossev] - _TZE200_rddyvrci O/C/S commands DP bug fix: added Refresh and Battery capabilities; mixedDP2reporting logic rewritten * 3.1.6 (2022-05-13) [kkossev] - _TZE200_gubdgai2 defaults fixed; 4 new models fingerprints and defaults added. * 3.1.7 (2022-05-14) [kkossev] - _TZE200_fzo2pocs ZM25TQ Tubular motor test; reversed O/S/C commands bug fix; added new option 'Substitute Open/Close with SetPosition command' * 3.2.0 (2022-05-22) [kkossev] - code moved to the new repository amosyuen/hubitat-zemismart-zigbee/; code cleanup * 3.2.1 (2022-05-23) [Amos Yuen] - Fixed bug with parsing speed * 3.2.2 (2022-05-26) [kkossev] - _TZE200_zah67ekd and _TZE200_wmcdj3aq Open/Close/Stop commands fixes * 3.2.3 (2022-09-22) [kkossev] - _TZE200_zpzndjez inClusters correction; secure updateWindowShadeArrived() for null values; * 3.2.4 (2022-12-02) [kkossev] - added _TZE200_7eue9vhc ZM25RX-0.8/30; _TZE200_fdtjuw7u _TZE200_r0jdjrvi _TZE200_bqcqqjpb * 3.2.5 (2022-12-12) [kkossev] - _TZE200_fzo2pocs new device version fingerprint ; added _TZE200_udank5zs; secured code for missing 'windowShade' state; unscheduling of old periodic tasks; _TZE200_7eue9vhc not inverted * 3.3.0 (2022-12-30) [kkossev] - TS130F Curtain Modules support; _TZE200_nhyj64w2 Touch Curtain Switch - moesCalibraion; ZM85 _TZE200_cf1sl3tj support, including calibration; * 3.3.1 (2023-03-09) [kkossev] - added _TZE200_hsgrhjpf * 3.3.2 (2023-08-10) [kkossev] - replaced some warnings with debug level logs; removed 'enable trace logging' and 'log Unexpected Messages' options; * 3.3.3 (2023-10-20) [kkossev] - _TZE200_zah67ekd checks; code reformatting; * 3.3.4 (2023-12-13) [kkossev] - added _TZE200_cxu0jkjk (AM02); _TZE200_nv6nxo0c * 3.4.0 (2024-03-02) [kkossev] - Groovy lint; added targetPosition attribute; minor bug fixes; added _TZE200_gaj531w3; POSITION_UPDATE_TIMEOUT default value changed to 15 seconds; * 3.5.0 (2025-03-08) [kkossev] - secured settings.mode and settings.direction for null values; added add checkDriverVersion(); added TS0601 _TZE284_myikb7qz; _TZE200_9p5xmj5r Hiladuo Motorized roller shade; Lidl _TZB000_42ha4rsc * added _TZE204_57hjqelq _TZE200_axgvo9jh _TZE200_zxxfv8wi _TZE204_lh3arisb _TZE200_eegnwoyw _TZE600_ogyg1y6b _TZE200_cpbo62rn _TZE200_libht6ua _TZE200_zvo63cmo _TZE200_g5xqosu7 _TZE204_g5xqosu7 _TZE204_r0jdjrvi _TZE200_p2qzzazi _TZE200_clm4gdw4 _TZE200_2vfxweng _TZE204_2rvvqjoa _TZE200_zyrdrmno _TZE200_p6vz3wzt _TZE200_jhkttplm _TZE200_5nldle7w * hopefully fixed _TZE200_pw7mji0l setlevel position; added _TZE200_eevqq1uv ; added _TZE200_icka1clh AM43; added TS011F manufacturers _TZ3000_8h7wgocw _TZ3000_e3vhyirx _TZ3000_yruungrl _TZ3000_jwv3cwak _TZ3000_74hsp7qy _TZ3210_dwytrmda * 3.5.1 (2025-03-11) [kkossev] - TS0601 _TZE284_myikb7qz Tuya DPs updates - Tnx @dan18 (does it use ZM85 calibration commands?) ; added Ping() command; added Refresh() command; finally replaced Presence w/ healthCheck ! * 3.6.0 (2025-09-14) [kkossev] - moved to https://github.com/HubitatCommunity/zemismart-zigbee-blind repository. Corrected importUrl * * TODO: https://github.com/Koenkk/zigbee2mqtt/issues/17436#issuecomment-1537534974 - ZM25TQ calibration commands * TODO: evaluate whether adding retries for setPos is possible : https://community.hubitat.com/t/release-zemismart-zigbee-blind-driver/67525/371?u=kkossev */ //import groovy.json.JsonOutput //import hubitat.helper.HexUtils import groovy.transform.Field import hubitat.zigbee.zcl.DataType private String textVersion() { return '3.6.0 - 2025-09-14 9:23 PM' } private String textCopyright() { return 'Copyright ©2021-2025\nAmos Yuen, kkossev, iquix, ShinJjang' } @Field static final Boolean _DEBUG = false metadata { definition(name: 'ZemiSmart Zigbee Blind', namespace: 'amosyuen', author: 'Amos Yuen', importUrl: 'https://raw.githubusercontent.com/HubitatCommunity/zemismart-zigbee-blind/refs/heads/main/Zemismart%20Zigbee%20Blind.groovy', singleThreaded: true ) { capability 'Actuator' capability 'Configuration' //capability 'PresenceSensor' capability 'HealthCheck' // finally, replaced the misused Presence capability starting from version 3.5.1 capability 'PushableButton' capability 'WindowShade' capability 'Switch' capability 'SwitchLevel' capability 'Battery' capability 'Refresh' attribute 'speed', 'number' attribute 'targetPosition', 'number' attribute 'healthStatus', 'enum', ['unknown', 'offline', 'online'] attribute 'rtt', 'number' command 'configure', [[name: '*** will load all defaults! ***']] command 'push', [[name: 'button number*', type: 'NUMBER', description: '1: Open, 2: Close, 3: Stop, 4: Step Open, 5: Step Close']] command 'stepClose', [[name: 'step', type: 'NUMBER', description: 'Amount to change position towards close. Defaults to defaultStepAmount if not set.']] command 'stepOpen', [[name: 'step', type: 'NUMBER', description: 'Amount to change position towards open. Defaults to defaultStepAmount if not set.']] command 'setSpeed', [[name: 'speed*', type: 'NUMBER', description: 'Motor speed (0 to 100). Values below 5 may not work.']] command 'calibrate', [ [name:'cmd', type: 'ENUM', description: 'command', constraints: (settableParsMap.keySet() as List)], [name:'val', type: 'STRING', description: 'preference parameter value', constraints: ['STRING']] ] command 'ping' if (_DEBUG == true) { command 'test', [[name: 'test', type: 'STRING', description: 'test']] } fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019', model:'mcdj3aq', manufacturer:'_TYST11_wmcdj3aq', deviceJoinName: 'Zemismart Zigbee Blind' // direction is reversed ? // Stop and Close inverted or not? fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019', model:'owvfni3', manufacturer:'_TYST11_cowvfr', deviceJoinName: 'Zemismart Zigbee Curtain Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019', model:'??????', manufacturer:'_TZE200_zah67ekd', deviceJoinName: 'Zemismart Zigbee Blind' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_zah67ekd', deviceJoinName: 'Zemismart Zigbee Blind Motor' // AM43-0.45/40-ES-EZ fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_icka1clh', deviceJoinName: 'Zemismart Zigbee Blind Motor' // not tested "AM43-0.45/40-ES-EB" fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_xuzcvlku' ,deviceJoinName: 'Zemismart Zigbee Blind Motor M515EGBZTN' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_gubdgai2' ,deviceJoinName: 'Zemismart Zigbee Blind Motor M515EGBZTN' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_iossyxra' ,deviceJoinName: 'Zemismart Tubular Roller Blind Motor AM15' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_uzinxci0' ,deviceJoinName: 'Zignito Tubular Roller Blind Motor AM15' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_nueqqe6k' ,deviceJoinName: 'Zemismart Zigbee Blind Motor M515EGZT' // mixedDP2reporting; {0x0000: 0x0000, 0x0001: 0x0002, 0x0002: 0x0001} fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_yenbr4om' ,deviceJoinName: 'Tuya Zigbee Blind Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_5sbebbzs' ,deviceJoinName: 'Tuya Zigbee Blind Tubular Motor' // mixedDP2reporting fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_xaabybja' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // supportDp1State fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_hsgrhjpf' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // https://community.hubitat.com/t/tuya-zigbee-roller-shade-blind-motor-hubitat-issues/91223/184?u=kkossev https://www.aliexpress.com/item/4000739390813.html fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_68nvbio9' ,deviceJoinName: 'Tuya Tubular Motor ZM25EL' // default commands https://www.aliexpress.com/item/1005001874380608.html fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_9p5xmj5r' ,deviceJoinName: 'Hiladuo Motorized roller shade' // https://community.hubitat.com/t/zigbee-motorized-zebra-shades-not-showing-any-commands/149153/9?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_eevqq1uv' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_zuz7f94z' ,deviceJoinName: 'Tuya Zigbee Blind Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_ergbiejo' ,deviceJoinName: 'Tuya Zigbee Blind Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_rddyvrci' ,deviceJoinName: 'Zemismart Zigbee Blind Motor AM43' // !!! close: 1, open: 2, stop: 0 fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_wmcdj3aq' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // !!! close: 0, open: 2, stop: 1 fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_cowvfni3' ,deviceJoinName: 'Zemismart Zigbee Curtain Motor' // !!! close: 0, open: 2, stop: 1 Curtain Motor ! Do NOT invert ! fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TYST11_cowvfni3' ,deviceJoinName: 'Zemismart Zigbee Curtain Motor' // !!! close: 0, open: 2, stop: 1 Curtain Motor fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_cf1sl3tj' ,deviceJoinName: 'Zemismart Electric Curtain Robot Rechargeable zm85el-2z' //https://www.zemismart.com/products/zm85el-2z fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_3i3exuay' ,deviceJoinName: 'Tuya Zigbee Blind Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,EF00,0000', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_zpzndjez' ,deviceJoinName: 'Zignito Zigbee Tubular Roller Blind Motor' // https://www.ajaxonline.co.uk/product/zignito-zigbee-roller-blind-motor/ fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_nhyj64w2' ,deviceJoinName: 'Touch Curtain Switch RF' // model: 'ZTS-EUR-C' https://community.hubitat.com/t/moes-curtain-switch/102691/16?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,000A,0004,0005,EF00', outClusters:'0019', model:'TS0601', manufacturer:'_TZE200_fzo2pocs' ,deviceJoinName: 'Zemismart ZM25TQ Tubular motor' // app. version 52 //inverted reporting; default O/C/S fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_fzo2pocs' ,deviceJoinName: 'Motorized Window Opener' // app. version 53 //https://www.aliexpress.com/item/1005004251482469.html fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,000A,0004,0005,EF00', outClusters:'0019', model:'TS0601', manufacturer:'_TZE200_4vobcgd3' ,deviceJoinName: 'Zemismart Zigbee Tubular motor' // onClusters may be wrong fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_5zbp6j0u' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_rmymn92d' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // inverted reporting fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_nogaemzt' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_7eue9vhc' ,deviceJoinName: 'Zemismart Zigbee Rechargable Roller Motor' // ZM25RX-0.8/30 inverted reporting? fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_fdtjuw7u' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_gaj531w3' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_r0jdjrvi' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_bqcqqjpb' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_udank5zs' ,deviceJoinName: 'Motorized Window Opener' // similar to _TZE200_fzo2pocs fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_cxu0jkjk' ,deviceJoinName: 'Tuya Zigbee AM02 motor' // https://community.hubitat.com/t/window-roller-shutter-blinds-with-hubitat/125954/10?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_nv6nxo0c' ,deviceJoinName: 'Tuya Zigbee AM25 Tubular Motor' //Model: Am25-1/30-ES-EZ (DC5v rechargeable) https://community.hubitat.com/t/looking-for-driver-moes-tubular-motor-roller-blind-am25-zigbee-version/125406?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_nw1r9hp6' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_3ylew7b4' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_llm0epxg' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_n1aauwb4' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_xu4a5rhj' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE204_r0jdjrvi' ,deviceJoinName: 'Zemismart Zigbee Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_g5wdnuow' ,deviceJoinName: 'Tuya Zigbee Window Pusher' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_pw7mji0l' ,deviceJoinName: 'Tuya Zigbee Roller Blinds' // https://community.hubitat.com/t/zemismart-set-level-position/129242?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_feolm6rk' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_nkoabg8w' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_pk0sfzvr' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE204_guvc7pdy' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE204_57hjqelq' ,deviceJoinName: 'Roximo Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_axgvo9jh' ,deviceJoinName: 'Somgoms Curtain Switch' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_zxxfv8wi' ,deviceJoinName: 'HUARUI Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE204_lh3arisb' ,deviceJoinName: 'Novato Smart curtain track' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_ol5jlkkr' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_b2u1drdv' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_eegnwoyw' ,deviceJoinName: 'Zemismart Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE600_ogyg1y6b' ,deviceJoinName: 'Nova Digital ZBCMR-01 Roller Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_cpbo62rn' ,deviceJoinName: 'Tuya LY-108 Cover' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_libht6ua' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_zvo63cmo' ,deviceJoinName: 'Tuya Zigbee Curtain Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_g5xqosu7' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE204_g5xqosu7' ,deviceJoinName: 'Tuya Zigbee Blind Motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE284_fzo2pocs' ,deviceJoinName: 'Tuya Cover motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_p2qzzazi' ,deviceJoinName: 'Tuya Cover motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_clm4gdw4' ,deviceJoinName: 'Tuya Cover motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_2vfxweng' ,deviceJoinName: 'Tuya Cover motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE204_2rvvqjoa' ,deviceJoinName: 'Tuya Cover motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_zyrdrmno' ,deviceJoinName: 'Tuya Cover motor' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_p6vz3wzt' ,deviceJoinName: 'Tuya Curtain/blind switch' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_jhkttplm' ,deviceJoinName: 'Homeetec Curtain/blind switch' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE200_5nldle7w' ,deviceJoinName: 'Homeetec Curtain/blind switch' // not tested // fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_zirycpws' ,deviceJoinName: 'Zigbee Curtain Module QS-Zigbee-CP03' // https://www.aliexpress.com/item/1005003697194481.html fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_1dd0d5yi' ,deviceJoinName: 'Zigbee Curtain Module' // https://community.hubitat.com/t/moes-smart-curtain-switch-module-ms-108zr/125260/3?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3210_dwytrmda' ,deviceJoinName: 'Zigbee Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_4uuaja4a' ,deviceJoinName: 'Zigbee Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_fccpjz5z' ,deviceJoinName: 'Zigbee Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_vd43bbfq' ,deviceJoinName: 'Zigbee Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_ke7pzj5d' ,deviceJoinName: 'Zigbee Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_8h7wgocw' ,deviceJoinName: 'Danor SK-Z802C-US Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_e3vhyirx' ,deviceJoinName: 'LoraTap SC500ZB Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_yruungrl' ,deviceJoinName: 'Nous B4Z Curtain Switch' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_jwv3cwak' ,deviceJoinName: 'Nous L12Z Curtain Module' // not tested fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,0006,0102,0000', outClusters:'0019,000A', model:'TS130F', manufacturer:'_TZ3000_74hsp7qy' ,deviceJoinName: 'Zemismart Smart curtain/shutter switch' // not tested // fingerprint profileId:'0104', endpointId:'01', inClusters:'0004,0005,EF00,0000,ED00', outClusters:'0019,000A', model:'TS0601', manufacturer:'_TZE284_myikb7qz' ,deviceJoinName: 'Blindsmart plantation shutter motor' // https://community.hubitat.com/t/release-zemismart-zigbee-blind-driver/67525/499?u=kkossev fingerprint profileId:'0104', endpointId:'01', inClusters:'0000,0004,0005,EF00', outClusters:'0019,000A', model:'TS030F', manufacturer:'_TZB000_42ha4rsc' ,deviceJoinName: 'Lidl HG09648 Livarno roller blinds' // not tested // defaults are : open: 0, stop: 1, close: 2 } preferences { input('enableInfoLog', 'bool', title: 'Enable descriptionText logging', required: true, defaultValue: true) input('enableDebugLog', 'bool', title: 'Enable debug logging', required: true, defaultValue: false) input('mode', 'enum', title: 'Mode', description: '
  • lift - motor moves until button pressed again
    • ' + '
  • tilt - pressing button < 1.5s, movement stops on release' + '; pressing button > 1.5s, motor moves until button pressed again
    • ', options: MODE_MAP, required: true, defaultValue: DEFAULT_MODE) input('direction', 'enum', title: 'Direction', options: DIRECTION_MAP, required: true, defaultValue: DEFAULT_DIRECTION) input('maxClosedPosition', 'number', title: 'Max Closed Position', description: 'The max position value that window shade state should be set to closed', required: true, defaultValue: 1) input('minOpenPosition', 'number', title: 'Min Open Position', description: 'The min position value that window shade state should be set to open', required: true, defaultValue: 99) input('defaultStepAmount', 'number', title: 'Default Step Amount', description: 'The default step amount', required: true, defaultValue: 10) input('advancedOptions', 'bool', title: 'Show Advanced options', description: 'These advanced options should have been already set correctly for your device/model when device was Configred', required: true, defaultValue: false) if (advancedOptions == true) { input('invertPosition', 'bool', title: 'Invert position reporting', description: 'Some devices report the position 0..100 inverted', required: true, defaultValue: false) input('mixedDP2reporting', 'bool', title: 'Ignore the first Position report', description: 'Some devices report both the Target and the Current positions the same way', required: true, defaultValue: false) input('substituteOpenClose', 'bool', title: 'Substitute Open/Close commands with SetPosition', description: "Turn this option on if your motor does not work in 'lift' mode", required: true, defaultValue: false) input('positionReportTimeout', 'number', title: 'Position report timeout, ms', description: 'The maximum time between position reports', required: true, defaultValue: POSITION_UPDATE_TIMEOUT) input('forcedTS130F', 'bool', title: 'Force TS130F Model', description: 'Force TS130F model if Data section shows endpointId: F2', required: true, defaultValue: false) input name: 'healthCheckMethod', type: 'enum', title: 'Healthcheck Method', options: HealthcheckMethodOpts.options, defaultValue: HealthcheckMethodOpts.defaultValue, required: true, description: 'Method to check device online/offline status.' input name: 'healthCheckInterval', type: 'enum', title: 'Healthcheck Interval', options: HealthcheckIntervalOpts.options, defaultValue: HealthcheckIntervalOpts.defaultValue, required: true, description: 'How often the hub will check the device health.
    3 consecutive failures will result in status "offline"' } } } @Field final int DEFAULT_MODE = 1 @Field final String MODE_TILT = '0' @Field final Map MODE_MAP = [1: 'lift', 0: 'tilt'] @Field final Map MODE_MAP_REVERSE = MODE_MAP.collectEntries { [(it.value): it.key] } @Field final List MODES = MODE_MAP*.value @Field final int DEFAULT_DIRECTION = 0 @Field final Map DIRECTION_MAP = [0: 'forward', 1: 'reverse'] @Field final Map MOVING_MAP = [0: 'up/open', 1: 'stop', 2: 'down/close' ] @Field final Map DIRECTION_MAP_REVERSE = DIRECTION_MAP.collectEntries { [(it.value): it.key] } @Field final List DIRECTIONS = DIRECTION_MAP*.value @Field final int CHECK_FOR_RESPONSE_INTERVAL_SECONDS = 60 @Field final int HEARTBEAT_INTERVAL_SECONDS = 4000 // a little more than 1 hour @Field final int POSITION_UPDATE_TIMEOUT = 15000 // in milliseconds @Field final int INVALID_POSITION = -1 @Field final int MIN_STEP = 10 @Field static final Integer COMMAND_TIMEOUT = 10 // timeout time in seconds @Field static final Integer MAX_PING_MILISECONDS = 10000 // rtt more than 10 seconds will be ignored @Field static final int PING_ATTR_ID = 0x01 @Field static final Integer PRESENCE_COUNT_THRESHOLD = 3 // missing 3 checks will set the device healthStatus to offline @Field static final Map HealthcheckMethodOpts = [ // used by healthCheckMethod defaultValue: 1, options: [0: 'Disabled', 1: 'Activity check', 2: 'Periodic polling'] ] @Field static final Map HealthcheckIntervalOpts = [ // used by healthCheckInterval defaultValue: 240, options: [2: 'Every 2 Mins', 10: 'Every 10 Mins', 30: 'Every 30 Mins', 60: 'Every 1 Hour', 240: 'Every 4 Hours', 720: 'Every 12 Hours'] ] @Field final int tuyaMovingState = 0xf000 // type: enum8 @Field final int tuyaCalibration = 0xf001 // type: enum8 @Field final int tuyaMotorReversal = 0xf002 // type: enum8 @Field final int moesCalibrationTime = 0xf003 // type: uint16 @Field final Map ZM85EL_MODE = [0: 'morning', 1: 'night'] // DP=4; enum @Field final Map ZM85EL_SITUATION_SET = [0: 'fully_open', 1: 'fully_close'] // DP=11; enum @Field final Map ZM85EL_BORDER = [0: 'up', 1: 'down', 2: 'up_delete', 3: 'down_delete', 4: 'remove_top_bottom'] // DP=16; enum @Field final Map ZM85EL_CLICK_CONTROL = [0: 'up', 1: 'down'] // DP=20; enum String getModel() { return settings?.forcedTS130F == true ? 'TS130F' : device.getDataValue('model') } boolean isTS130F() { return getModel() == 'TS130F' } boolean isZM85EL() { return device.getDataValue('manufacturer') in ['_TZE200_cf1sl3tj'] } boolean isAM43() { return device.getDataValue('manufacturer') in ['_TZE200_zah67ekd', '_TZE200_icka1clh'] } boolean isAM02() { return device.getDataValue('manufacturer') in ['_TZE200_iossyxra', '_TZE200_cxu0jkjk'] } boolean isCurtainMotor() { String manufacturer = device.getDataValue('manufacturer') return manufacturer in ['_TYST11_cowvfni3', '_TZE200_cowvfni3', '_TYST11_cowvfr'] } boolean isPlantationShutter() { return device.getDataValue('manufacturer') in ['_TZE284_myikb7qz'] } boolean isMoesCoverSwitch() { return device.getDataValue('manufacturer') in ['_TZE200_nhyj64w2'] } // Open - default 0x00 int getDpCommandOpen() { String manufacturer = device.getDataValue('manufacturer') if (manufacturer in ['_TZE200_rddyvrci', '_TZE200_cowvfni3', '_TYST11_cowvfni3']) { return DP_COMMAND_CLOSE //0x02 } return DP_COMMAND_OPEN //0x00 } // Stop - default 0x01 int getDpCommandStop() { String manufacturer = device.getDataValue('manufacturer') if (manufacturer in ['_TZE200_nueqqe6k'] || isTS130F()) { return DP_COMMAND_CLOSE //0x02 } else if (manufacturer in ['_TZE200_rddyvrci']) { return DP_COMMAND_OPEN //0x00 } return DP_COMMAND_STOP //0x01 } // Close - default 0x02 int getDpCommandClose() { String manufacturer = device.getDataValue('manufacturer') if (manufacturer in ['_TZE200_nueqqe6k', '_TZE200_rddyvrci'] || isTS130F()) { return DP_COMMAND_STOP //0x01 } else if (manufacturer in ['_TZE200_cowvfni3', '_TYST11_cowvfni3']) { return DP_COMMAND_OPEN //0x00 } return DP_COMMAND_CLOSE //0x02 } boolean isMixedDP2reporting() { return (device.getDataValue('manufacturer') in ['_TZE200_xuzcvlku', '_TZE200_nueqqe6k', '_TZE200_5sbebbzs', '_TZE200_gubdgai2']) } boolean isInvertedPositionReporting() { return (device.getDataValue('manufacturer') in ['_TZE200_xuzcvlku', '_TZE200_nueqqe6k', '_TZE200_5sbebbzs', '_TZE200_gubdgai2', '_TZE200_fzo2pocs', '_TZE200_wmcdj3aq', '_TZE200_nogaemzt', '_TZE200_xaabybja', '_TZE200_yenbr4om', '_TZE200_zpzndjez', '_TZE200_zuz7f94z', '_TZE200_rmymn92d', '_TZE200_udank5zs']) } boolean isZM25TQ() { return device.getDataValue('manufacturer') in ['_TZE200_fzo2pocs', '_TZE200_udank5zs'] } boolean isOpenCloseSubstituted() { return device.getDataValue('manufacturer') in ['_TZE200_rddyvrci', '_TZE200_fzo2pocs', '_TZE200_udank5zs', '_TZE200_68nvbio9', '_TZE200_9p5xmj5r', '_TZE200_pw7mji0l'] } int getPositionReportTimeout() { return isZM85EL() ? 15000 : POSITION_UPDATE_TIMEOUT } // // Life Cycle // void installed() { configure() } void checkHealthStatusConfiguration() { final int healthMethod = (settings.healthCheckMethod as Integer) ?: 0 if (healthMethod == 1 || healthMethod == 2) { // [0: 'Disabled', 1: 'Activity check', 2: 'Periodic polling'] // schedule the periodic timer final int interval = (settings.healthCheckInterval as Integer) ?: 0 if (interval > 0) { log.info "scheduling health check every ${interval} minutes by ${HealthcheckMethodOpts.options[healthCheckMethod as int]} method" scheduleDeviceHealthCheck(interval, healthMethod) } } else { unScheduleDeviceHealthCheck() // unschedule the periodic job, depending on the healthMethod log.info 'Health Check is disabled!' } if (device.currentValue('presence') != null) { device.deleteCurrentState('presence') // deprecated! } if (device.currentValue('healthStatus') == null) { sendHealthStatusEvent('unknown') } } // This method is called when the preferences of a device are updated. void updated() { configure(fullInit = false) // calls unschedule() ! logDebug("updated ${device.displayName} model=${getModel()} manufacturer=${device.getDataValue('manufacturer')}") // added 2025/03/10 checkDriverVersion() if (settings.enableDebugLog) { runIn(86400, 'logsOff') } checkHealthStatusConfiguration() } // version 3.4.1 - 2025-03-08 12:24 PM void checkDriverVersion() { if (state.driverVersion == null || textVersion() != state.driverVersion) { logDebug "checkDriverVersion: updating the settings from the current driver version ${state.driverVersion} to the new version ${textVersion()}" logInfo "Updated to version ${textVersion()}" state.driverVersion = textVersion() configure(fullInit = false) checkHealthStatusConfiguration() } } void configure(boolean fullInit = true) { state.version = textVersion() state.copyright = textCopyright() //if (state.lastHeardMillis == null) { state.lastHeardMillis = 0 } // not used anymore if (state.target == null || state.target < 0 || state.target > 100) { state.target = 0 } state.isTargetRcvd = false sendEvent(name: 'numberOfButtons', value: 5, type: 'digital') sendEvent(name: 'targetPosition', value: 50, type: 'digital') unschedule() // added 2022/12/10 // Must run async otherwise, one will block the other runIn(1, 'setMode') runIn(2, 'setDirection') if (settings.enableInfoLog == null || fullInit == true) { device.updateSetting('enableInfoLog', [value: true, type: 'bool']) } if (settings.enableDebugLog == null || fullInit == true) { device.updateSetting('enableDebugLog', [value: false, type: 'bool']) } if (settings.advancedOptions == null || fullInit == true) { device.updateSetting('advancedOptions', [value: false, type: 'bool']) } // Reset the Advanced Options parameters to their default values depending on the model/manufacturer if (settings.mode == null || fullInit == true) { device.updateSetting('mode', [value: DEFAULT_MODE.toString(), type: 'enum']) } if (settings.direction == null || fullInit == true) { device.updateSetting('direction', [value: DEFAULT_DIRECTION.toString(), type: 'enum']) } if (settings.mixedDP2reporting == null || fullInit == true) { device.updateSetting('mixedDP2reporting', [value: isMixedDP2reporting(), type: 'bool']) } if (settings.invertPosition == null || fullInit == true) { device.updateSetting('invertPosition', [value: isInvertedPositionReporting(), type: 'bool']) } if (settings.substituteOpenClose == null || fullInit == true) { device.updateSetting('substituteOpenClose', [value: isOpenCloseSubstituted(), type: 'bool']) } if (settings.positionReportTimeout == null || fullInit == true) { device.updateSetting('positionReportTimeout', [value: getPositionReportTimeout(), type: 'number']) } if (settings.maxClosedPosition == null || fullInit == true) { device.updateSetting('maxClosedPosition', [value: 1, type: 'number']) } if (settings.minOpenPosition == null || fullInit == true) { device.updateSetting('minOpenPosition', [value: 99, type: 'number']) } if (settings.forcedTS130F == null || fullInit == true) { device.updateSetting('forcedTS130F', [value: false, type: 'bool']) } if (fullInit || settings?.healthCheckMethod == null) { device.updateSetting('healthCheckMethod', [value: HealthcheckMethodOpts.defaultValue.toString(), type: 'enum']) } if (fullInit || settings?.healthCheckInterval == null) { device.updateSetting('healthCheckInterval', [value: HealthcheckIntervalOpts.defaultValue.toString(), type: 'enum']) } if (isZM85EL()) { logDebug "isZM85EL() = ${isZM85EL()}" } if (settings?.maxClosedPosition < 0 || settings?.maxClosedPosition > 100) { /* groovylint-disable-next-line ThrowException */ throw new Exception("Invalid maxClosedPosition \"${maxClosedPosition}\" should be between" + ' 0 and 100 inclusive.') } if (settings?.minOpenPosition < 0 || settings?.minOpenPosition > 100) { /* groovylint-disable-next-line ThrowException */ throw new Exception("Invalid minOpenPosition \"${minOpenPosition}\" should be between 0" + ' and 100 inclusive.') } if (settings?.maxClosedPosition >= settings?.minOpenPosition) { /* groovylint-disable-next-line ThrowException */ throw new Exception("maxClosedPosition \"${minOpenPosition}\" must be less than" + " minOpenPosition \"${minOpenPosition}\".") } logInfo("${device.displayName} configured : model=${getModel()} manufacturer=${device.getDataValue('manufacturer')}") logDebug(" fullInit=${fullInit} invertPosition=${settings.invertPosition}, positionReportTimeout=${positionReportTimeout}, mixedDP2reporting=${settings.mixedDP2reporting}, substituteOpenClose=${settings.substituteOpenClose}") } void setDirection() { try { int directionValue = (settings?.direction ?: DEFAULT_DIRECTION) as int logDebug("setDirection: directionText=${DIRECTION_MAP[directionValue]}, directionValue=${directionValue}") sendTuyaCommand(DP_ID_DIRECTION, DP_TYPE_ENUM, directionValue, 2) return } catch (Exception e) { logWarn("setDirection: ${e}") device.removeSetting("direction") device.updateSetting('direction', [value: DEFAULT_DIRECTION.toString(), type: 'enum']) } } void setMode() { if (settings?.mode != null) { int modeValue = (settings?.mode ?: DEFAULT_MODE) as int logDebug("setMode: modeText=${MODE_MAP[modeValue]}, modeValue=${modeValue}") sendTuyaCommand(DP_ID_MODE, DP_TYPE_ENUM, modeValue, 2) } else { logWarn "setMode: mode was null" device.updateSetting('mode', [value: DEFAULT_MODE.toString(), type: 'enum']) } } // // Messages // @Field final int CLUSTER_TUYA = 0xEF00 @Field final int ZIGBEE_COMMAND_SET_DATA = 0x00 @Field final int ZIGBEE_COMMAND_REPORTING = 0x01 @Field final int ZIGBEE_COMMAND_SET_DATA_RESPONSE = 0x02 @Field final int ZIGBEE_COMMAND_ACK = 0x0B @Field final int ZIGBEE_COMMAND_SET_TIME = 0x24 @Field final int DP_ID_COMMAND = 0x01 @Field final int DP_ID_TARGET_POSITION = 0x02 @Field final int DP_ID_CURRENT_POSITION = 0x03 @Field final int DP_ID_DIRECTION = 0x05 @Field final int DP_ID_COMMAND_REMOTE = 0x07 @Field final int DP_ID_MODE = 0x65 @Field final int DP_ID_SPEED = 0x69 @Field final int DP_ID_BATTERY = 0x0D @Field final int DP_TYPE_BOOL = 0x01 @Field final int DP_TYPE_VALUE = 0x02 @Field final int DP_TYPE_ENUM = 0x04 @Field final int DP_COMMAND_OPEN = 0x00 @Field final int DP_COMMAND_STOP = 0x01 @Field final int DP_COMMAND_CLOSE = 0x02 @Field final int DP_COMMAND_CONTINUE = 0x03 @Field final int DP_COMMAND_LIFTPERCENT = 0x05 @Field final int DP_COMMAND_CUSTOM = 0x06 void parse(String description) { checkDriverVersion() // added 03/08/2025 if (state.stats != null) { state.stats?.rxCtr= (state.stats?.rxCtr ?: 0) + 1 } else { state.stats = [:] } // updateRxStats(state) // +1 ms if (state.lastRx != null) { state.lastRx?.timeStamp = unix2formattedDate(now()) } else { state.lastRx = [:] } unscheduleCommandTimeoutCheck() setHealthStatusOnline() // updatePresence(true) // depricated! replaced with healthCheckMethod if (description == null || (!description.startsWith('catchall:') && !description.startsWith('read attr -'))) { logWarn "parse: Unhandled description=${description}" return null } final Map descMap = zigbee.parseDescriptionAsMap(description) if (descMap.clusterInt != CLUSTER_TUYA) { parseNonTuyaMessage(descMap) return null } final int command = zigbee.convertHexToInt(descMap.command) switch (command) { case ZIGBEE_COMMAND_SET_DATA_RESPONSE: // 0x02 case ZIGBEE_COMMAND_REPORTING : // 0x01 if (!descMap?.data || descMap.data.size() < 7) { logWarn "parse: Invalid data size for SET_DATA_RESPONSE descMap=${descMap}" return null } parseSetDataResponse(descMap) break case ZIGBEE_COMMAND_ACK: // 0x0B if (!descMap?.data || descMap.data.size() < 2) { logWarn "parse: Invalid data size for ACK descMap=${descMap}" return null } logDebug "parse: ACK command=${descMap.data[0]}" break case 0x10 : // TUYA_MCU_VERSION_REQ logDebug "Tuya MCU Version Request : ${descMap?.data}" break case 0x11 : // TUYA_MCU_VERSION_RSP logDebug "Tuya MCU Version Respinse : ${descMap?.data}" break case ZIGBEE_COMMAND_SET_TIME: // 0x24 processTuyaSetTime() break default: logWarn "parse: Unhandled command=${command} descMap=${descMap}" break } } void parseNonTuyaMessage(final Map descMap) { if (descMap == null) { return } if (descMap.cluster == '0000' && descMap.attrId == '0001') { if (state.states?.isPing ?: false) { handlePingResponse() } else { logDebug "Tuya check-in message (attribute ${descMap.attrId} reported: ${descMap.value})" } return } else if (descMap?.clusterId == '0102' || descMap?.cluster == '0102') { // windowCovering standard cluster logDebug "windowCovering standard cluster descMap=${descMap}" if (descMap?.command == '01' || descMap?.command == '0A') { //read attribute response or reportResponse if (descMap?.data != null && descMap?.data[2] == '86') { logWarn "read attribute response: unsupported cluster ${descMap?.clusterId} attribute ${descMap.data[1] + descMap.data[0]} (status ${descMap.data[2]})" } else { if (descMap?.attrId == '0008') { int dataValue = zigbee.convertHexToInt(descMap?.value) logInfo "WindowCovering cluster ${descMap?.cluster} attribute CurrentPositionLiftPercentage ${descMap?.attrId} value : ${dataValue}" restartPositionReportTimeout() updateWindowShadeArrived(dataValue) updatePosition(dataValue) } else if (descMap?.attrId == 'F000') { int val = zigbee.convertHexToInt(descMap?.value) logInfo "WindowCovering cluster ${descMap?.cluster} attribute PositionState ${descMap?.attrId} value : ${val} - ${MOVING_MAP[val]}" // TODO ! } else if (descMap?.attrId == 'F001') { logInfo "WindowCovering cluster ${descMap?.cluster} attribute UpDownConfirm ${descMap?.attrId} value : ${zigbee.convertHexToInt(descMap?.value)}" // TODO ! } else if (descMap?.attrId == 'F002') { logInfo "WindowCovering cluster ${descMap?.cluster} attribute ControlBack ${descMap?.attrId} value : ${zigbee.convertHexToInt(descMap?.value)}" // TODO ! } else if (descMap?.attrId == 'F003') { logInfo "WindowCovering cluster ${descMap?.cluster} attribute ScheduleTime ${descMap?.attrId} value : ${zigbee.convertHexToInt(descMap?.value)}" // TODO! } else { logInfo "read attribute response: cluster ${descMap?.cluster} attribute ${descMap?.attrId} value : ${zigbee.convertHexToInt(descMap?.value)}" } } } else if (descMap?.command == '04') { //write attribute response if (descMap.data[0] == '86') { logWarn "writeAttributeResponse: unsupported cluster ${descMap?.clusterId} attribute ${descMap.data[2] + descMap.data[1]} (status ${descMap.data[0]})" } else { logInfo "writeAttributeResponse: cluster ${descMap?.clusterId} OK (data : ${descMap.data})" } } else if (descMap?.command == '0B') { // ZCL Command Response logDebug "ZCL Default Response to command ${descMap.data[0]} for cluster:${descMap.clusterId} , data=${descMap.data} (Status: ${descMap.data[1] == '00' ? 'Success' : 'Failure'})" } else { logWarn "windowCovering unprocessed command ${descMap?.command}" } } else if ((descMap?.clusterId == '0006' || descMap?.cluster == '0006') && descMap?.attrId == '8001' && descMap?.command in ['01', '0A']) { logInfo "OnOff cluster ${descMap?.cluster} attribute IndicatorMode ${descMap?.attrId} value : ${zigbee.convertHexToInt(descMap?.value)}" } else if ((descMap?.clusterId == '0013' || descMap?.cluster == '0013') && descMap?.profileId == '0000') { logDebug "ZDO cluster ${descMap?.clusterId} device announcement Device network ID: ${descMap.data[2]}${descMap.data[1]}, Capability Information: ${descMap.data[11]}" } else { logDebug "parse: Not a Tuya Message descMap=${descMap}" } } /* * Data (sending and receiving) generally have this format: * [2 bytes] (packet id) * [1 byte] (dp ID) * [1 byte] (dp type) * [2 bytes] (fnCmd length in bytes) * [variable bytes] (fnCmd) * * https://developer.tuya.com/en/docs/iot-device-dev/zigbee-curtain-switch-access-standard?id=K9ik6zvra3twv */ void parseSetDataResponse(final Map descMap) { logDebug "parse: descMap=${descMap}" /* groovylint-disable-next-line NoDef, VariableTypeRequired */ def data = descMap.data int dp = zigbee.convertHexToInt(data[2]) int dataValue = zigbee.convertHexToInt(data[6..-1].join()) switch (dp) { case 0x01 : // DP_ID_COMMAND restartPositionReportTimeout() if (dataValue == getDpCommandOpen()) { // OPEN - typically 0x00 logDebug("parse (01): opening (DP=1, data=${dataValue})") updateWindowShadeOpening() } else if (dataValue == getDpCommandStop()) { // STOP - typically 0x01 logDebug("parse (01): stopping (DP=1, data=${dataValue})") } else if (dataValue == getDpCommandClose()) { // CLOSE - typically 0x02 logDebug("parse (01): closing (DP=1, data=${dataValue})") updateWindowShadeClosing() } else if (dataValue == DP_COMMAND_CONTINUE) { // CONTINUE - 0x03 logDebug("parse (01): continuing (DP=1, data=${dataValue})") } else { logWarn "parse (01): Unexpected DP_ID_COMMAND dataValue=${dataValue}" } break case 0x02 : // DP_ID_TARGET_POSITION: // for M515EGBZTN blinds models - this is ALSO the actual/current position ! if (dataValue >= 0 && dataValue <= 100) { if (invertPosition == true) { dataValue = 100 - dataValue } restartPositionReportTimeout() if (settings?.mixedDP2reporting == true) { if (state.isTargetRcvd == false) { // only for setPosition commands; Open and Close do not report the target pos! if (dataValue == state.target) { logDebug("parse (02): received target ${dataValue} from mixedDP2reporting device") } else { logWarn "parse (02): received target ${dataValue} from mixedDP2reporting device, set target was ${state.target}" } state.isTargetRcvd = true } else { logDebug "parse (02): reveived current position ${dataValue} from mixedDP2reporting device" logDebug("parse (02): moved to position ${dataValue}") updateWindowShadeMoving(dataValue) updatePosition(dataValue) } } else { // for all other models - this is the Target position logDebug("parse (02): received target ${dataValue}") state.isTargetRcvd = true sendEvent(name: 'targetPosition', value: dataValue, type: 'physical') } } else { logWarn "parse (02): Unexpected DP_ID_TARGET_POSITION dataValue=${dataValue}" } break case 0x03 : // DP_ID_CURRENT_POSITION: Current Position or Moes Cover Calibration if (isMoesCoverSwitch()) { logDebug("parse (03): Moes Cover Calibration DP ${dp} value = ${dataValue}") } else { // all other models - this is the Current position if (dataValue >= 0 && dataValue <= 100) { if (invertPosition == true) { dataValue = 100 - dataValue } logDebug("parse (03): arrived at position ${dataValue}") // for AM43 and ZM85 this is received just once, when arrived at the destination point! if (isZM85EL()) { stopPositionReportTimeout() } else { // TODO - same filtering for AM43 ! restartPositionReportTimeout() } updateWindowShadeArrived(dataValue) updatePosition(dataValue) } else { logWarn "parse (03): Unexpected DP_ID_CURRENT_POSITION dataValue=${dataValue}" } } break case 0x04 : // working mode {“range”:[“morning”,“night”],“type”:“enum”} logDebug("parse (04): isZM85EL=${isZM85EL()} mode = ${ZM85EL_MODE[dataValue as int]} (value = ${dataValue})") break case 0x05 : //DP_ID_DIRECTION: Motor Direction (0-forward 1-backward), enum String directionText = DIRECTION_MAP[dataValue] if (directionText != null) { logDebug("parse (05): Motor Direction=${directionText}") updateDirection(dataValue) } else { logWarn "parse (05): Unexpected DP_ID_DIRECTION dataValue=${dataValue}" } break case 0x06: // 0x06: Arrived at destination (with fncmd==0) logDebug "parse (06): Arrived at destination (dataValue==${dataValue})" break case 0x07 : //DP_ID_COMMAND_REMOTE: Remote Command / work_state (or Moes Curtain switch Backlight?) if (isMoesCoverSwitch()) { logDebug("parse (07): Moes Curtain switch Backlight DP ${dp} value = ${dataValue}") } else if (isZM85EL()) { logDebug("parse (07): moving from ZM85 up/down keys (data=${dataValue})") updateWindowShadeUndefined() } else { if (dataValue == 0) { // _TZE200_68nvbio9 sends 0x00 on both open and close commands from the remote! :( logDebug("parse (07): movement command from remote (data=${descMap.data} dataValue=${dataValue})") // we do not know in which direction the motor is moving .. sendEvent(name:'windowShade', value: 'moving', type: 'physical') sendEvent(name:'targetPosition', value: '?', type: 'digital') logInfo "movement command from remote (${dataValue})" //updateWindowShadeOpening() } /*else if (dataValue == 1) { logDebug("parse (07): closing from remote (data=${descMap.data} dataValue=${dataValue})") updateWindowShadeClosing() } */else { logWarn "parse (07): Unexpected DP_ID_COMMAND_REMOTE (data=${descMap.data} dataValue=${dataValue})" } restartPositionReportTimeout() } break case 0x08: // also, for unknown curtain motors : Countdown {“range”:[“cancel”,“1h”,“2h”,“3h”,“4h”],“type”:“enum”} logDebug("parse (08): Moes motor reversal DP ${dp} value = ${dataValue}") // isMoesCoverSwitch() break case 0x09: // for unknown curtain motors : Left time (Display the remaining time of the countdown) {“unit”:“s”,“min”:0,“max”:86400,“scale”:0,“step”:1,“type” :“value”} logDebug("parse (09): Moes motor reversal DP ${dp} value = ${dataValue}") break case 0x0A: // (10) "Total Time" 0..120000 milliseconds (2 minutes) plantation shutter logDebug("parse (10): Total Time (DP ${dp}) value = ${dataValue} ms") break case 0x0B : // (11) situation_set - enum ["fully_open", "fully_close"] logDebug("parse (11): isZM85EL=${isZM85EL()} isPlantationShutter=${isPlantationShutter()} -> situation_set = ${ZM85EL_SITUATION_SET[dataValue as int]} (value = ${dataValue})") break case 0x0C : // (12) fault - Bitmap logDebug("parse (12): fault code (DP ${dp}) value = ${dataValue}") break case 0x0D : // (13) DP_ID_BATTERY: Battery if (dataValue >= 0 && dataValue <= 100) { logDebug("parse (13): battery=${dataValue}") updateBattery(dataValue) } else { logWarn "parse (13): Unexpected DP_ID_BATTERY dataValue=${dataValue}" } break case 0x0E : // (14) indicator light status for Moes Curtain switch ? {“range”:[“relay”,“pos”,“none”],“type”:“enum”} logDebug "parse (14): indicator light status for Moes Curtain switch value = ${dataValue}" break case 0x10 : // (16) ZM85EL_BORDER logDebug("parse (16): isZM85EL=${isZM85EL()} isPlantationShutter=${isPlantationShutter()} -> BORDER = ${ZM85EL_BORDER[dataValue as int]} (value = ${dataValue})") break case 0x13 : // (19) position_best - Integer (0..100) logDebug("parse (19): position_best (DP ${dp}) value = ${dataValue}") break case 0x14 : // (20) click_control (2) Enum ["up", "down"] logDebug("parse (20): isZM85EL=${isZM85EL()} click_control = ${ZM85EL_CLICK_CONTROL[dataValue as int]} (value = ${dataValue})") break case 0x65 : // (101) DP_ID_MODE: // enum 0: tilt , 1: lift if (isPlantationShutter()) { logDebug("parse (101): Plantation Shutter Child Lock =${dataValue}") } else { String modeText = MODE_MAP[dataValue] if (modeText != null) { logDebug("parse (101): mode=${modeText}") updateMode(dataValue) } else { logWarn "parse: Unexpected DP_ID_MODE dataValue=${dataValue}" } } break case 0x66 : // (102) AM43 factory reset if (isPlantationShutter()) { logDebug("parse (102): Plantation Shutter set mode =${dataValue}") } else { logDebug('parse (102): AM43 factory reset') } break case 0x67 : // (103) ZM25TQ UP limit (when direction is Forward; probably reversed in Backward direction?) // AM43 'set_upper_limit' if (isPlantationShutter()) { logDebug("parse (103): Plantation Shutter Motor operating mode =${dataValue}") } else { logDebug("parse (103): ZM25TQ/AM43 Up limit was ${dataValue == 0 ? 'reset' : 'set'} (direction:${settings.direction}) (raw:${dataValue})") } break case 0x68 : // (104) ZM25TQ Middle limit // AM43 'set_bottom_limit' logDebug("parse (104): ZM25TQ Middle / AM43 bottom limit was ${dataValue == 0 ? 'reset' : 'set'} (direction:${settings.direction}) (raw:${dataValue})") break case 0x69 : // (105) DP_ID_SPEED: // Motor speed or ZM25TQ Down limit // AM43 motor_speed if (isZM25TQ()) { logDebug("parse (105): ZM25TQ Down limit was ${dataValue == 0 ? 'reset' : 'set'} (direction:${settings.direction})") } else { // Motor speed for AM43 if (dataValue >= 0 && dataValue <= 100) { logDebug("parse (105): speed=${dataValue}") updateSpeed(dataValue) } else { logWarn "parse (105): Unexpected DP_ID_SPEED dataValue=${dataValue}" } } break case 0x6A: // 106 logDebug("parse (106): ZM25TQ motor mode (DP=${dp}) value = ${dataValue}") break default: logWarn "parse: Unknown DP_ID dp=0x${data[2]}, dataType=0x${data[3]} dataValue=${dataValue}" break } } void processTuyaSetTime() { logDebug('time synchronization request') // every 61 minutes int offset = 0 try { offset = location.getTimeZone().getOffset(new Date().getTime()) } catch (e) { log.error "${device.displayName} cannot resolve current location. please set location in Hubitat location setting. Setting timezone offset to zero" } List cmds = zigbee.command(CLUSTER_TUYA, ZIGBEE_COMMAND_SET_TIME, '0008' + zigbee.convertToHexString((int)(now() / 1000), 8) + zigbee.convertToHexString((int)((now() + offset) / 1000), 8)) logDebug "sending time data : ${cmds}" cmds.each { sendHubCommand(new hubitat.device.HubAction(it, hubitat.device.Protocol.ZIGBEE)) } } /* groovylint-disable-next-line UnusedPrivateMethod */ private boolean ignorePositionReport(int position) { int lastPosition = device.currentValue('position') ?: 0 lastPosition = lastPosition != null ? lastPosition : INVALID_POSITION logDebug("ignorePositionReport: position=${position}, lastPosition=${lastPosition}") if (lastPosition == INVALID_POSITION || isWithinOne(position)) { logDebug 'Ignore invalid reports' return true } return false } private boolean isWithinOne(int position) { int lastPosition = device.currentValue('position') ?: 0 lastPosition = lastPosition != null ? lastPosition : INVALID_POSITION if (lastPosition != INVALID_POSITION && Math.abs(position - lastPosition) <= 1) { logDebug "isWithinOne:true (position=${position}, lastPosition=${lastPosition})" return true } logDebug "isWithinOne:false (position=${position}, lastPosition=${lastPosition})" return false } private void updateDirection(int directionValue) { String directionText = DIRECTION_MAP[directionValue] logDebug("updateDirection: directionText=${directionText}, directionValue=${directionValue}") if (directionValue != (settings?.direction as int)) { setDirection() } } private void updateMode(int modeValue) { String modeText = MODE_MAP[modeValue] logDebug("updateMode: modeText=${modeText}, modeValue=${modeValue}") if (modeValue != ((settings?.mode ?: DEFAULT_MODE) as int)) { setMode() } } private void updatePosition(final int position) { logDebug "updatePosition(): position=${position}" sendEvent(name: 'position', value: position, unit: '%') sendEvent(name: 'level', value: position, unit: '%') if (position <= settings?.maxClosedPosition) { sendEvent(name:'switch', value: 'off') } else { sendEvent(name:'switch', value: 'on') } if (isWithinOne(position)) { logDebug "updatePosition(${position}): arrived!" updateWindowShadeArrived(position) stopPositionReportTimeout() // added 12/30/2022 } } /* finally deprecated! private void updatePresence(final boolean present) { //logDebug "updatePresence: present=${present}" if (present) { state.lastHeardMillis = now() checkHeartbeat() } state.waitingForResponseSinceMillis = null sendEvent(name: 'presence', value: present ? 'present' : 'not present') } */ private void updateSpeed(final int speed) { logDebug("updateSpeed: speed=${speed}") sendEvent(name: 'speed', value: speed) } private void updateBattery(final int battery) { logInfo("battery is ${battery} %") sendEvent(name: 'battery', value: battery) } private void updateWindowShadeMoving(int position) { int lastPosition = device.currentValue('position') ?: 0 logDebug("updateWindowShadeMoving: position=${position} (lastPosition=${lastPosition}), target=${state.target}") if (lastPosition < position) { updateWindowShadeOpening() } else if (lastPosition > position) { updateWindowShadeClosing() } } private void updateWindowShadeOpening() { logDebug 'updateWindowShadeOpening()' if ((device.currentValue('windowShade') ?: 'undefined') != 'opening') { sendEvent(name:'windowShade', value: 'opening') logInfo 'is opening' } } private void updateWindowShadeClosing() { logDebug 'updateWindowShadeClosing()' if ((device.currentValue('windowShade') ?: 'undefined') != 'closing') { sendEvent(name:'windowShade', value: 'closing') logInfo 'is closing' } } private void updateWindowShadeUndefined() { logDebug 'updateWindowShadeUndefined()' if ((device.currentValue('windowShade') ?: 'undefined') != 'moving') { sendEvent(name:'windowShade', value: 'moving') logInfo 'is moving' } } // called from updatePosition(), setPosition(), endOfMovement() private void updateWindowShadeArrived(int positionParam=null) { int position = positionParam if (position == null) { position = device.currentValue('position') ?: INVALID_POSITION } logDebug("updateWindowShadeArrived: position=${position}") if (position == INVALID_POSITION || position < 0 || position > 100) { logWarn 'updateWindowShadeArrived: Need to setup limits on device' sendEvent(name: 'windowShade', value: 'unknown') logInfo 'windowShade is unknown' stopPositionReportTimeout() // added 12/30/2022 } else if (position <= settings?.maxClosedPosition) { if ((device.currentValue('windowShade') ?: 'undefined') != 'closed') { sendEvent(name: 'windowShade', value: 'closed') logInfo 'is closed' stopPositionReportTimeout() // added 12/30/2022 } } else if (position >= settings?.minOpenPosition) { if ((device.currentValue('windowShade') ?: 'undefined') != 'open') { sendEvent(name: 'windowShade', value: 'open') logInfo 'is open' stopPositionReportTimeout() // added 12/30/2022 } } else { if ((device.currentValue('windowShade') ?: 'undefined') != 'partially open') { sendEvent(name: 'windowShade', value: 'partially open') logInfo "is partially open ${position}%" } } } // // Actions // void refresh() { checkDriverVersion() if (getModel() == 'TS0601') { logDebug 'refresh(): queryAllTuyaDP()' sendZigbeeCommands(zigbee.command(0xEF00, 0x03)) } else { logDebug 'Refresh(): onOff' sendZigbeeCommands(zigbee.onOffRefresh()) } } void close() { // 0 % if ((settings?.mode ?: DEFAULT_MODE) == MODE_TILT || settings?.substituteOpenClose == true) { logDebug("sending command close ${settings?.substituteOpenClose == true ? 'substituted with setPosition(0)' : 'MODE_TILT'} ") setPosition(0) } else { state.target = 0 state.isTargetRcvd = true sendEvent(name: 'targetPosition', value: 0, type: 'digital') restartPositionReportTimeout() int dpCommandClose = getDpCommandClose() logDebug "sending command close (${dpCommandClose}), direction = ${DIRECTION_MAP[settings.direction as int]} (${settings.direction as int})" if (isTS130F()) { sendZigbeeCommands(zigbee.command(0x0102, dpCommandClose as int, [destEndpoint:0x01], delay = 200)) } else if (isZM85EL() || isPlantationShutter()) { // situation_set setPosition(0) } else { sendTuyaCommand(DP_ID_COMMAND, DP_TYPE_ENUM, dpCommandClose, 2) } } } void open() { // 100 % if ((settings?.mode ?: DEFAULT_MODE) == MODE_TILT || settings?.substituteOpenClose == true) { logDebug "sending command open : ${settings?.substituteOpenClose == true ? 'substituted with setPosition(100)' : 'MODE_TILT'} " setPosition(100) } else { state.target = 100 state.isTargetRcvd = true sendEvent(name: 'targetPosition', value: 100, type: 'digital') restartPositionReportTimeout() int dpCommandOpen = getDpCommandOpen() logDebug "sending command open (${dpCommandOpen}), direction = ${DIRECTION_MAP[settings.direction as int]} (${settings.direction as int})" if (isTS130F()) { sendZigbeeCommands(zigbee.command(0x0102, dpCommandOpen as int, [destEndpoint:0x01], delay = 200)) } else if (isZM85EL() || isPlantationShutter()) { // situation_set ? setPosition(100) } else { sendTuyaCommand(DP_ID_COMMAND, DP_TYPE_ENUM, dpCommandOpen, 2) } } } void on() { open() } void off() { close() } void startPositionChange(final String state) { logDebug("startPositionChange: ${state}") switch (state) { case 'close' : close() break case 'open' : open() break default : throw new Exception("Unsupported startPositionChange state \"${state}\"") } } void stopPositionChange() { int dpCommandStop = getDpCommandStop() logDebug "sending command stopPositionChange (${dpCommandStop})" restartPositionReportTimeout() sendEvent(name: 'targetPosition', value: '?', type: 'digital') if (isTS130F()) { sendZigbeeCommands(zigbee.command(0x0102, dpCommandStop as int, [destEndpoint:0x01], delay = 200)) } else { sendTuyaCommand(DP_ID_COMMAND, DP_TYPE_ENUM, dpCommandStop, 2) } } /* groovylint-disable-next-line UnusedMethodParameter */ void setLevel(BigDecimal level, BigDecimal duration = null) { setPosition(level) } void setPosition(BigDecimal positionParam) { logDebug "setPosition: positionParam=${positionParam}" int position = positionParam as int if (position == null || position < 0 || position > 100) { throw new Exception("Invalid position ${position}. Position must be between 0 and 100 inclusive.") } state.target = position sendEvent(name: 'targetPosition', value: position, type: 'digital') if (isWithinOne(position)) { // Motor is off by one sometimes, so set it to desired value if within one // sendEvent(name: "position", value: position) logDebug('setPosition: no need to move!') updateWindowShadeArrived(position) state.isTargetRcvd = false return null } updateWindowShadeMoving(position) logDebug("setPosition: target is ${position}, currentPosition=${device.currentValue('position')}") if (invertPosition == true) { position = 100 - position } restartPositionReportTimeout() state.isTargetRcvd = false sendTuyaCommand(DP_ID_TARGET_POSITION, DP_TYPE_VALUE, position.intValue(), 8) } void restartPositionReportTimeout() { int timeout = settings?.positionReportTimeout as Integer if (timeout > 100) { // milliseconds runInMillis(timeout, endOfMovement, [overwrite: true]) } else { stopPositionReportTimeout() } } void stopPositionReportTimeout() { logDebug 'stopPositionReportTimeout(): unscheduling endOfMovement timer' unschedule(endOfMovement) } void stepClose(final BigDecimal stepParam=settings?.defaultStepAmount) { BigDecimal step = Math.max(MIN_STEP, stepParam?.doubleValue()) if (isZM85EL()) { setZM85ClickControlDown() } else { logDebug("stepClose: step=${step}") BigDecimal position = Math.max(0, Math.min(100, ((device.currentValue('position') ?: 100).doubleValue() - step.doubleValue()))) sendEvent(name: 'targetPosition', value: position, unit: '%', type: 'digital') setPosition(position) } } void stepOpen(final BigDecimal stepParam=settings?.defaultStepAmount) { BigDecimal step = Math.max(MIN_STEP, stepParam?.doubleValue()) if (isZM85EL()) { setZM85ClickControlUp() } else { logDebug("stepOpen: step=${step}") BigDecimal position = Math.max(0, Math.min(100, ((device.currentValue('position') ?: 0).doubleValue() + step.doubleValue()))) sendEvent(name: 'targetPosition', value: position, unit: '%', type: 'digital') setPosition(position) } } void setSpeed(final BigDecimal speed) { logDebug("setSpeed: speed=${speed}") if (speed < 0 || speed > 100) { throw new Exception("Invalid speed ${speed}. Speed must be between 0 and 100 inclusive.") } sendTuyaCommand(DP_ID_SPEED, DP_TYPE_ENUM, speed.intValue(), 8) } void push(final BigDecimal buttonNumber) { logDebug "push: buttonNumber=${buttonNumber}" sendEvent(name: 'pushed', value: buttonNumber, isStateChange: true) switch (buttonNumber) { case 1: open() break case 2: close() break case 3: stopPositionChange() break case 4: stepOpen() break case 5: stepClose() break default: throw new Exception("Unsupported buttonNumber \"${buttonNumber}\"") } } // scheduled from restartPositionReportTimeout() void endOfMovement() { logWarn 'endOfMovement() timeout!' updateWindowShadeArrived((device.currentValue('position', true) ?: 0) as int) } // // Helpers // private void sendTuyaCommand(int dp, int dpType, int fnCmd, int fnCmdLength) { /* depricated ! state.waitingForResponseSinceMillis = now() checkForResponse() */ String dpHex = zigbee.convertToHexString(dp, 2) String dpTypeHex = zigbee.convertToHexString(dpType, 2) String fnCmdHex = zigbee.convertToHexString(fnCmd, fnCmdLength) logDebug "sendTuyaCommand: dp=0x${dpHex}, dpType=0x${dpTypeHex}, fnCmd=0x${fnCmdHex}, fnCmdLength=${fnCmdLength}" String message = (randomPacketId().toString() + dpHex + dpTypeHex + zigbee.convertToHexString((fnCmdLength / 2) as int, 4) + fnCmdHex) sendZigbeeCommands(zigbee.command(CLUSTER_TUYA, ZIGBEE_COMMAND_SET_DATA, message)) } private String randomPacketId() { return zigbee.convertToHexString(new Random().nextInt(65536), 4) } /* depricated ! void checkForResponse() { //logDebug "checkForResponse: waitingForResponseSinceMillis=${state.waitingForResponseSinceMillis}" if (state.waitingForResponseSinceMillis == null) { return null } int waitMillis = (CHECK_FOR_RESPONSE_INTERVAL_SECONDS * 1000 - (now() - state.waitingForResponseSinceMillis)) //logDebug "checkForResponse: waitMillis=${waitMillis}" if (waitMillis <= 0) { updatePresence(false) } else { runInMillis(waitMillis, checkForResponse, [overwrite: true]) } } */ /* depricated ! void checkHeartbeat() { int waitMillis = (HEARTBEAT_INTERVAL_SECONDS * 1000 - (now() - state.lastHeardMillis)) //logDebug "checkHeartbeat: waitMillis=${waitMillis}" if (waitMillis <= 0) { updatePresence(false) } else { runInMillis(waitMillis, checkHeartbeat, [overwrite: true]) } } */ private void logInfo(final String text) { if (!enableInfoLog) { return } log.info "${device.displayName} " + text } private void logDebug(final String text) { if (!enableDebugLog) { return } log.debug "${device.displayName} " + text } private void logWarn(final String text) { if (!enableDebugLog) { return } log.warn "${device.displayName} " + text } /* groovylint-disable-next-line MethodParameterTypeRequired, NoDef */ Integer safeToInt(val, Integer defaultVal=0) { return "${val}"?.isInteger() ? "${val}".toInteger() : defaultVal } /* groovylint-disable-next-line MethodParameterTypeRequired, NoDef, NoDouble */ Double safeToDouble(val, Double defaultVal=0.0) { return "${val}"?.isDouble() ? "${val}".toDouble() : defaultVal } void sendZigbeeCommands(List cmd) { logDebug "sendZigbeeCommands (cmd=$cmd)" hubitat.device.HubMultiAction allActions = new hubitat.device.HubMultiAction() cmd.each { allActions.add(new hubitat.device.HubAction(it, hubitat.device.Protocol.ZIGBEE)) if (state.txCounter != null) { state.txCounter = state.txCounter + 1 } else { state.txCounter = 1 } } sendHubCommand(allActions) } void setNotImplemented() { logWarn "not implemented!" } //--------------------- void setTS130FCalibrationTime(int val) { int calibrationTime = val * 10 logInfo "changing moesCalibrationTime to : ${val} seconds (raw ${calibrationTime})" List cmd = zigbee.writeAttribute(0x0102, moesCalibrationTime, DataType.UINT16, calibrationTime as int, [destEndpoint:0x01], delay = 200) + zigbee.readAttribute(0x0102, moesCalibrationTime, [destEndpoint:0x01], delay = 200) sendZigbeeCommands(cmd) } void setTS130FCalibrationOn() { logInfo "setting TS130F CalibrationOn}" // On is 0 ? List cmd = zigbee.writeAttribute(0x0102, tuyaCalibration, DataType.ENUM8, 1, [destEndpoint:0x01], delay = 200) + zigbee.readAttribute(0x0102, tuyaCalibration, [destEndpoint:0x01], delay = 200) sendZigbeeCommands(cmd) } void setTS130FCalibrationOff() { logInfo "setting TS130F CalibrationOff" // Off is 1 ? List cmd = zigbee.writeAttribute(0x0102, tuyaCalibration, DataType.ENUM8, 0, [destEndpoint:0x01], delay = 200) + zigbee.readAttribute(0x0102, tuyaCalibration, [destEndpoint:0x01], delay = 200) sendZigbeeCommands(cmd) } void setMoesCalibrationOn() { logInfo "setting setMoesCalibrationOn"; sendTuyaCommand(0x03, DP_TYPE_ENUM, 0x00, 2) } void setMoesCalibrationOff() { logInfo "setting setMoesCalibrationOff"; sendTuyaCommand(0x03, DP_TYPE_ENUM, 0x01, 2) } void setMoesBacklightOn() { logInfo "setting Moes Backlight On"; sendTuyaCommand(0x07, DP_TYPE_BOOL, 0x01, 2) } void setMoesBacklightOff() { logInfo "setting Moes Backlight Off"; sendTuyaCommand(0x07, DP_TYPE_BOOL, 0x00, 2) } void setMoesMotorReversalOn() { logInfo "setting Moes Motor Reversal On"; sendTuyaCommand(0x08, DP_TYPE_ENUM, 0x01, 2) } void setMoesMotorReversalOff() { logInfo "setting Moes Motor Reversal Off"; sendTuyaCommand(0x08, DP_TYPE_ENUM, 0x00, 2) } void setZM85UpperLimit() { logInfo "setting ZM85 Upper limit"; sendTuyaCommand(0x10, DP_TYPE_ENUM, 0x00, 2) } void setZM85LowerLimit() { logInfo "setting ZM85 Lower limit"; sendTuyaCommand(0x10, DP_TYPE_ENUM, 0x01, 2) } void removeZM85UpperLimit() { logInfo "removing ZM85 Upper limit"; sendTuyaCommand(0x10, DP_TYPE_ENUM, 0x02, 2) } void removeZM85LowerLimit() { logInfo "removing ZM85 Lower limit"; sendTuyaCommand(0x10, DP_TYPE_ENUM, 0x03, 2) } void removeZM85TopBottom() { logInfo "removing ZM85 both Top and Bottom limits"; sendTuyaCommand(0x10, DP_TYPE_ENUM, 0x04, 2) } void setZM85ClickControlUp() { logInfo "ZM85 Click Control Up"; sendTuyaCommand(0x14, DP_TYPE_ENUM, 0x00, 2) } void setZM85ClickControlDown() { logInfo "ZM85 Click Control Down"; sendTuyaCommand(0x14, DP_TYPE_ENUM, 0x01, 2) } void setZM85ModeMorning() { logInfo "ZM85 Mode Morning"; sendTuyaCommand(0x04, DP_TYPE_ENUM, 0x00, 2) } void setZM85ModeNight() { logInfo "ZM85 Mode Night"; sendTuyaCommand(0x04, DP_TYPE_ENUM, 0x01, 2) } @Field static final Map settableParsMap = [ 'TS130F Calibration Time': [ min: 1, scale: 0, max: 99, step: 1, type: 'number', defaultValue: 7 , function: 'setTS130FCalibrationTime'], 'TS130F Calibration On' : [ type: 'none', function: 'setTS130FCalibrationOn'], 'TS130F Calibration Off' : [ type: 'none', function: 'setTS130FCalibrationOff'], 'Moes Calibration On' : [ type: 'none', function: 'setMoesCalibrationOn'], 'Moes Calibration Off' : [ type: 'none', function: 'setMoesCalibrationOff'], 'Moes Backlight On' : [ type: 'none', function: 'setMoesBacklightOn'], 'Moes Backlight Off' : [ type: 'none', function: 'setMoesBacklightOff'], 'Moes Motor Reversal On' : [ type: 'none', function: 'setMoesMotorReversalOn'], 'Moes Motor Reversal Off' : [ type: 'none', function: 'setMoesMotorReversalOff'], 'ZM85 Set Upper Limit' : [ type: 'none', function: 'setZM85UpperLimit'], 'ZM85 Set Lower Limit' : [ type: 'none', function: 'setZM85LowerLimit'], 'ZM85 Remove Upper Limit' : [ type: 'none', function: 'removeZM85UpperLimit'], 'ZM85 Remove Lower Limit' : [ type: 'none', function: 'removeZM85LowerLimit'], 'ZM85 Remove Both Limits' : [ type: 'none', function: 'removeZM85TopBottom'], 'ZM85 Mode Morning' : [ type: 'none', function: 'setZM85ModeMorning'], 'ZM85 Mode Night' : [ type: 'none', function: 'setZM85ModeNight'] ] void calibrate(String par=null, String val=null ) { logDebug "calibrate ${par} ${val}" List cmds = [] /* groovylint-disable-next-line NoDef, VariableTypeRequired */ def value = null Boolean validated = false if (par == null || !(par in (settableParsMap.keySet() as List))) { logWarn "calibrate: parameter ${par} must be one of these : ${settableParsMap.keySet() as List}" return } if (settableParsMap[par]?.type != null && settableParsMap[par]?.type != 'none' ) { value = settableParsMap[par]?.type == 'number' ? safeToInt(val, -1) : safeToDouble(val, -1.0) if (value >= settableParsMap[par]?.min && value <= settableParsMap[par]?.max) { validated = true } if (validated == false) { log.warn "calibrate: parameter par value ${val} must be within ${settableParsMap[par]?.min} and ${settableParsMap[par]?.max}" return } } // String func try { func = settableParsMap[par]?.function //def type = settableParsMap[par]?.type //device.updateSetting("$par", [value:value, type:type]) if (value != null) { cmds = "$func"(value) } else { cmds = "$func"() } } catch (e) { logWarn "calibrate: Exception ${e} caught while processing $func($val)" return } logDebug "calibrate: executed $func($val)" } String getCron(int timeInSeconds) { final Random rnd = new Random() int minutes = (timeInSeconds / 60 ) as int int hours = (minutes / 60 ) as int if (hours > 23) { hours = 23 } String cron if (timeInSeconds < 60) { cron = "*/$timeInSeconds * * * * ? *" } else { if (minutes < 60) { cron = "${rnd.nextInt(59)} ${rnd.nextInt(9)}/$minutes * ? * *" } else { cron = "${rnd.nextInt(59)} ${rnd.nextInt(59)} */$hours ? * *" } } return cron } private void scheduleDeviceHealthCheck(final int intervalMins, final int healthMethod) { if (healthMethod == 1 || healthMethod == 2) { String cron = getCron(intervalMins * 60) schedule(cron, 'deviceHealthCheck') logDebug "deviceHealthCheck is scheduled every ${intervalMins} minutes" } else { logWarn 'deviceHealthCheck is not scheduled!' unschedule('deviceHealthCheck') } } private void unScheduleDeviceHealthCheck() { unschedule('deviceHealthCheck') device.deleteCurrentState('healthStatus') logWarn 'device health check is disabled!' } // called when any event was received from the Zigbee device in the parse () method. private void setHealthStatusOnline() { if (state.health == null) { state.health = [:] } state.health?.checkCtr3 = 0 if (!((device.currentValue('healthStatus') ?: 'unknown') in ['online'])) { sendHealthStatusEvent('online') logInfo 'is now online!' } } private void deviceHealthCheck() { checkDriverVersion() if (state.health == null) { state.health = [:] } int ctr = state.health?.checkCtr3 ?: 0 if (ctr >= PRESENCE_COUNT_THRESHOLD) { if ((device.currentValue('healthStatus') ?: 'unknown') != 'offline' ) { logWarn 'not present!' sendHealthStatusEvent('offline') } } else { logDebug "deviceHealthCheck - online (notPresentCounter=${(ctr + 1)})" } state.health?.checkCtr3 = ctr + 1 if (settings?.healthCheckMethod as int == 2) { state.health?.isHealthCheck = true ping() // proactively ping the device... } } private void sendHealthStatusEvent(final String value) { String descriptionText = "healthStatus changed to ${value}" sendEvent(name: 'healthStatus', value: value, descriptionText: descriptionText, isStateChange: true, type: 'digital') if (value == 'online') { logInfo "${descriptionText}" } else { if (settings?.enableInfoLog) { log.warn "${device.displayName}} ${descriptionText}" } } } private void scheduleCommandTimeoutCheck(int delay = COMMAND_TIMEOUT) { if (state.states == null) { state.states = [:] } state.states?.isTimeoutCheck = true runIn(delay, 'deviceCommandTimeout') } void unscheduleCommandTimeoutCheck() { if (state.states == null) { state.states = [:] } if (state.states?.isTimeoutCheck == true) { state.states?.isTimeoutCheck = false unschedule('deviceCommandTimeout') } } void deviceCommandTimeout() { logWarn 'no response received (sleepy device or offline?)' sendRttEvent('timeout') if (state.stats == null) { state.stats = [:] } ; if (state.health == null) { state.health = [:] } state.stats?.pingsFail = (state.stats?.pingsFail ?: 0) + 1 if (state.health?.isHealthCheck == true) { logWarn 'device health check failed!' state.health?.checkCtr3 = (state.health?.checkCtr3 ?: 0 ) + 1 if (state.health?.checkCtr3 >= PRESENCE_COUNT_THRESHOLD) { if ((device.currentValue('healthStatus') ?: 'unknown') != 'offline' ) { sendHealthStatusEvent('offline') } } state.health['isHealthCheck'] = false } } public void sendRttEvent(String value=null) { Long now = new Date().getTime() if (state.lastTx == null ) { state.lastTx = [:] } int timeRunning = now.toInteger() - (state.lastTx?.pingTime ?: now).toInteger() String descriptionText = "Round-trip time is ${timeRunning} ms (min=${state.stats?.pingsMin} max=${state.stats?.pingsMax} average=${state.stats?.pingsAvg})" if (value == null) { logInfo "${descriptionText}" sendEvent(name: 'rtt', value: timeRunning, descriptionText: descriptionText, unit: 'ms', type: 'physical') } else { descriptionText = "Round-trip time : ${value}" logInfo "${descriptionText}" sendEvent(name: 'rtt', value: value, descriptionText: descriptionText, type: 'physical') } } public void ping() { if (state.lastTx == null ) { state.lastTx = [:] } ; state.lastTx?.pingTime = new Date().getTime() if (state.states == null ) { state.states = [:] } ; state.states?.isPing = true scheduleCommandTimeoutCheck() int pingAttr = PING_ATTR_ID sendZigbeeCommands(zigbee.readAttribute(zigbee.BASIC_CLUSTER, pingAttr, [:], 0) ) logDebug 'ping...' } @Field static final int ROLLING_AVERAGE_N = 10 private BigDecimal approxRollingAverage(BigDecimal avgPar, BigDecimal newSample) { BigDecimal avg = avgPar if (avg == null || avg == 0) { avg = newSample } avg -= avg / ROLLING_AVERAGE_N avg += newSample / ROLLING_AVERAGE_N return avg } void handlePingResponse() { Long now = new Date().getTime() if (state.lastRx == null) { state.lastRx = [:] } ; if (state.lastTx == null) { state.lastTx = [:] } ; if (state.stats == null) { state.stats = [:] ; state.stats['pingsOK'] = 0 } state.lastRx?.checkInTime = now int timeRunning = now.toInteger() - (state.lastTx?.pingTime ?: '0').toInteger() if (timeRunning > 0 && timeRunning < MAX_PING_MILISECONDS) { state.stats?.pingsOK = (state.stats?.pingsOK ?: 0) + 1 if (timeRunning < safeToInt((state.stats?.pingsMin ?: '9999'))) { state.stats?.pingsMin = timeRunning } if (timeRunning > safeToInt((state.stats?.pingsMax ?: '0'))) { state.stats?.pingsMax = timeRunning } state.stats?.pingsAvg = approxRollingAverage(safeToDouble(state.stats?.pingsAvg), safeToDouble(timeRunning)) as int sendRttEvent() } else { logWarn "unexpected ping timeRunning=${timeRunning} " } state.states['isPing'] = false } String unix2formattedDate(Long unixTime) { try { if (unixTime == null) { return null } /* groovylint-disable-next-line NoJavaUtilDate */ Date date = new Date(unixTime.toLong()) return date.format('yyyy-MM-dd HH:mm:ss.SSS', location.timeZone) } catch (e) { logDebug "Error formatting date: ${e.message}. Returning current time instead." return new Date().format('yyyy-MM-dd HH:mm:ss.SSS', location.timeZone) } } void test(final String par) { logWarn "test: ${par}" //device.updateSetting('direction', [value: DEFAULT_DIRECTION.toString(), type: 'enum']) String description = "catchall: 0104 EF00 01 01 0040 00 E174 01 00 0000 02 01 00356704000100" parse(par) }