]> git.basschouten.com Git - openhab-addons.git/blob
ad6cb704e3518b08609dd8a4e4c97664fe4a9b72
[openhab-addons.git] /
1 /**
2  * Copyright (c) 2010-2024 Contributors to the openHAB project
3  *
4  * See the NOTICE file(s) distributed with this work for additional
5  * information.
6  *
7  * This program and the accompanying materials are made available under the
8  * terms of the Eclipse Public License 2.0 which is available at
9  * http://www.eclipse.org/legal/epl-2.0
10  *
11  * SPDX-License-Identifier: EPL-2.0
12  */
13 package org.openhab.binding.knx.internal.dpt;
14
15 import static org.openhab.binding.knx.internal.KNXBindingConstants.disableUoM;
16
17 import java.math.BigDecimal;
18 import java.text.ParseException;
19 import java.text.SimpleDateFormat;
20 import java.util.Calendar;
21 import java.util.Date;
22 import java.util.Locale;
23 import java.util.Set;
24 import java.util.regex.Matcher;
25 import java.util.regex.Pattern;
26
27 import org.eclipse.jdt.annotation.NonNullByDefault;
28 import org.eclipse.jdt.annotation.Nullable;
29 import org.openhab.core.library.types.DateTimeType;
30 import org.openhab.core.library.types.DecimalType;
31 import org.openhab.core.library.types.HSBType;
32 import org.openhab.core.library.types.IncreaseDecreaseType;
33 import org.openhab.core.library.types.OnOffType;
34 import org.openhab.core.library.types.OpenClosedType;
35 import org.openhab.core.library.types.PercentType;
36 import org.openhab.core.library.types.QuantityType;
37 import org.openhab.core.library.types.StopMoveType;
38 import org.openhab.core.library.types.StringType;
39 import org.openhab.core.library.types.UpDownType;
40 import org.openhab.core.types.Type;
41 import org.openhab.core.types.UnDefType;
42 import org.openhab.core.util.ColorUtil;
43 import org.slf4j.Logger;
44 import org.slf4j.LoggerFactory;
45
46 import tuwien.auto.calimero.KNXException;
47 import tuwien.auto.calimero.KNXFormatException;
48 import tuwien.auto.calimero.KNXIllegalArgumentException;
49 import tuwien.auto.calimero.dptxlator.DPTXlator;
50 import tuwien.auto.calimero.dptxlator.DPTXlator1BitControlled;
51 import tuwien.auto.calimero.dptxlator.DPTXlator2ByteUnsigned;
52 import tuwien.auto.calimero.dptxlator.DPTXlator3BitControlled;
53 import tuwien.auto.calimero.dptxlator.DPTXlator64BitSigned;
54 import tuwien.auto.calimero.dptxlator.DPTXlator8BitUnsigned;
55 import tuwien.auto.calimero.dptxlator.DPTXlatorBoolean;
56 import tuwien.auto.calimero.dptxlator.DPTXlatorDateTime;
57 import tuwien.auto.calimero.dptxlator.DPTXlatorSceneControl;
58 import tuwien.auto.calimero.dptxlator.TranslatorTypes;
59
60 /**
61  * This class decodes raw data received from the KNX bus to an openHAB datatype
62  *
63  * Parts of this code are based on the openHAB KNXCoreTypeMapper by Kai Kreuzer et al.
64  *
65  * @author Jan N. Klug - Initial contribution
66  */
67 @NonNullByDefault
68 public class ValueDecoder {
69     private static final Logger LOGGER = LoggerFactory.getLogger(ValueDecoder.class);
70
71     private static final String TIME_DAY_FORMAT = "EEE, HH:mm:ss";
72     private static final String TIME_FORMAT = "HH:mm:ss";
73     private static final String DATE_FORMAT = "yyyy-MM-dd";
74     // RGB: "r:123 g:123 b:123" value-range: 0-255
75     private static final Pattern RGB_PATTERN = Pattern.compile("r:(?<r>\\d+) g:(?<g>\\d+) b:(?<b>\\d+)");
76     // RGBW: "100 27 25 12 %", value range: 0-100, invalid values: "-"
77     private static final Pattern RGBW_PATTERN = Pattern
78             .compile("(?:(?<r>[\\d,.]+)|-)\\s(?:(?<g>[\\d,.]+)|-)\\s(?:(?<b>[\\d,.]+)|-)\\s(?:(?<w>[\\d,.]+)|-)\\s%");
79     // xyY: "(0,123 0,123) 56 %", value range 0-1 for xy (comma or point as decimal point), 0-100 for Y, invalid values
80     // omitted
81     public static final Pattern XYY_PATTERN = Pattern
82             .compile("(?:\\((?<x>\\d+(?:[,.]\\d+)?) (?<y>\\d+(?:[,.]\\d+)?)\\))?\\s*(?:(?<Y>\\d+(?:[,.]\\d+)?)\\s%)?");
83
84     private static boolean check235001(byte[] data) throws KNXException {
85         if (data.length != 6) {
86             throw new KNXFormatException("DPT235 broken frame");
87         }
88         if ((data[5] & 2) == 0) {
89             LOGGER.trace("DPT235.001 w/o ActiveEnergy ignored");
90             return false;
91         }
92         return true;
93     }
94
95     private static boolean check23561001(byte[] data) throws KNXException {
96         if (data.length != 6) {
97             throw new KNXFormatException("DPT235 broken frame");
98         }
99         if ((data[5] & 1) == 0) {
100             LOGGER.trace("DPT235.61001 w/o Tariff ignored");
101             return false;
102         }
103         return true;
104     }
105
106     /**
107      * convert the raw value received to the corresponding openHAB value
108      *
109      * @param dptId the DPT of the given data
110      * @param data a byte array containing the value
111      * @param preferredType the preferred datatype for this conversion
112      * @return the data converted to an openHAB Type (or null if conversion failed)
113      */
114     public static @Nullable Type decode(String dptId, byte[] data, Class<? extends Type> preferredType) {
115         try {
116             String value = "";
117             String translatorDptId = dptId;
118             DPTXlator translator;
119             try {
120                 translator = TranslatorTypes.createTranslator(0, DPTUtil.NORMALIZED_DPT.getOrDefault(dptId, dptId));
121                 translator.setData(data);
122                 value = translator.getValue();
123                 translatorDptId = translator.getType().getID();
124             } catch (KNXException e) {
125                 // special handling for decoding DPTs not yet supported by Calimero
126                 if ("235.001".equals(dptId)) {
127                     if (!check235001(data)) {
128                         return null;
129                     }
130                     translator = TranslatorTypes.createTranslator(0, "13.010");
131                     translator.setData(data);
132                     value = translator.getValue();
133                     dptId = "13.010";
134                     translatorDptId = dptId;
135                 } else if ("235.61001".equals(dptId)) {
136                     if (!check23561001(data)) {
137                         return null;
138                     }
139                     translator = TranslatorTypes.createTranslator(0, "5.006");
140                     translator.setData(new byte[] { data[4] });
141                     value = translator.getValue();
142                     dptId = "5.006";
143                     translatorDptId = dptId;
144                 } else {
145                     // no known special case, handle unknown translator outer try block
146                     throw e;
147                 }
148             }
149             String id = dptId; // prefer using the user-supplied DPT
150
151             Matcher m = DPTUtil.DPT_PATTERN.matcher(id);
152             if (!m.matches() || m.groupCount() != 2) {
153                 LOGGER.trace("User-Supplied DPT '{}' did not match for sub-type, using DPT returned from Translator",
154                         id);
155                 id = translatorDptId;
156                 m = DPTUtil.DPT_PATTERN.matcher(id);
157                 if (!m.matches() || m.groupCount() != 2) {
158                     LOGGER.warn("Couldn't identify main/sub number in dptID '{}'", id);
159                     return null;
160                 }
161             }
162             LOGGER.trace("Finally using datapoint DPT = {}", id);
163
164             String mainType = m.group("main");
165             String subType = m.group("sub");
166
167             switch (mainType) {
168                 case "1":
169                     return handleDpt1(subType, translator, preferredType);
170                 case "2":
171                     DPTXlator1BitControlled translator1BitControlled = (DPTXlator1BitControlled) translator;
172                     int decValue = (translator1BitControlled.getControlBit() ? 2 : 0)
173                             + (translator1BitControlled.getValueBit() ? 1 : 0);
174                     return new DecimalType(decValue);
175                 case "3":
176                     return handleDpt3(subType, translator);
177                 case "10":
178                     return handleDpt10(value);
179                 case "11":
180                     return DateTimeType.valueOf(new SimpleDateFormat(DateTimeType.DATE_PATTERN)
181                             .format(new SimpleDateFormat(DATE_FORMAT).parse(value)));
182                 case "18":
183                     DPTXlatorSceneControl translatorSceneControl = (DPTXlatorSceneControl) translator;
184                     int decimalValue = translatorSceneControl.getSceneNumber();
185                     if (value.startsWith("learn")) {
186                         decimalValue += 0x80;
187                     }
188                     return new DecimalType(decimalValue);
189                 case "19":
190                     return handleDpt19(translator, data);
191                 case "20":
192                 case "21":
193                     return handleStringOrDecimal(data, value, preferredType, 8);
194                 case "22":
195                     return handleStringOrDecimal(data, value, preferredType, 16);
196                 case "16":
197                 case "28":
198                 case "250": // Map all combined color transitions to String,
199                 case "252": // as no native support is planned.
200                 case "253": // Currently only one subtype 2xx.600
201                 case "254": // is defined for those DPTs.
202                     return StringType.valueOf(value);
203                 case "243": // color translation, fix regional
204                 case "249": // settings
205                     return StringType.valueOf(value.replace(',', '.').replace(". ", ", "));
206                 case "232":
207                     return handleDpt232(value, subType);
208                 case "242":
209                     return handleDpt242(value);
210                 case "251":
211                     return handleDpt251(value, subType, preferredType);
212                 default:
213                     return handleNumericDpt(id, translator, preferredType);
214             }
215         } catch (NumberFormatException | KNXFormatException | KNXIllegalArgumentException | ParseException e) {
216             LOGGER.info("Translator couldn't parse data '{}' for datapoint type '{}' ({}).", data, dptId, e.getClass());
217         } catch (KNXException e) {
218             LOGGER.warn("Failed creating a translator for datapoint type '{}'.", dptId, e);
219         }
220
221         return null;
222     }
223
224     private static Type handleDpt1(String subType, DPTXlator translator, Class<? extends Type> preferredType) {
225         DPTXlatorBoolean translatorBoolean = (DPTXlatorBoolean) translator;
226         switch (subType) {
227             case "008":
228                 return translatorBoolean.getValueBoolean() ? UpDownType.DOWN : UpDownType.UP;
229             case "009":
230             case "019":
231                 // default is OpenClosedType (Contact), but it may be mapped to OnOffType as well
232                 if (OnOffType.class.equals(preferredType)) {
233                     return OnOffType.from(translatorBoolean.getValueBoolean());
234                 }
235
236                 // This is wrong for DPT 1.009. It should be true -> CLOSE, false -> OPEN, but unfortunately
237                 // can't be fixed without breaking a lot of working installations.
238                 // The documentation has been updated to reflect that. / @J-N-K
239                 return translatorBoolean.getValueBoolean() ? OpenClosedType.OPEN : OpenClosedType.CLOSED;
240             case "010":
241                 return translatorBoolean.getValueBoolean() ? StopMoveType.MOVE : StopMoveType.STOP;
242             case "022":
243                 return DecimalType.valueOf(translatorBoolean.getValueBoolean() ? "1" : "0");
244             default:
245                 // default is OnOffType (Switch), but it may be mapped to OpenClosedType as well
246                 if (OpenClosedType.class.equals(preferredType)) {
247                     return translatorBoolean.getValueBoolean() ? OpenClosedType.OPEN : OpenClosedType.CLOSED;
248                 }
249
250                 return OnOffType.from(translatorBoolean.getValueBoolean());
251         }
252     }
253
254     private static @Nullable Type handleDpt3(String subType, DPTXlator translator) {
255         DPTXlator3BitControlled translator3BitControlled = (DPTXlator3BitControlled) translator;
256         if (translator3BitControlled.getStepCode() == 0) {
257             LOGGER.debug("convertRawDataToType: KNX DPT_Control_Dimming: break received.");
258             return UnDefType.NULL;
259         }
260         switch (subType) {
261             case "007":
262                 return translator3BitControlled.getControlBit() ? IncreaseDecreaseType.INCREASE
263                         : IncreaseDecreaseType.DECREASE;
264             case "008":
265                 return translator3BitControlled.getControlBit() ? UpDownType.DOWN : UpDownType.UP;
266             default:
267                 LOGGER.warn("DPT3, subtype '{}' is unknown.", subType);
268                 return null;
269         }
270     }
271
272     private static Type handleDpt10(String value) throws ParseException {
273         // Calimero will provide either TIME_DAY_FORMAT or TIME_FORMAT, no-day is not printed
274         Date date = null;
275         try {
276             date = new SimpleDateFormat(TIME_DAY_FORMAT, Locale.US).parse(value);
277         } catch (ParseException pe) {
278             date = new SimpleDateFormat(TIME_FORMAT, Locale.US).parse(value);
279         }
280         return DateTimeType.valueOf(new SimpleDateFormat(DateTimeType.DATE_PATTERN).format(date));
281     }
282
283     private static @Nullable Type handleDpt19(DPTXlator translator, byte[] data) throws KNXFormatException {
284         DPTXlatorDateTime translatorDateTime = (DPTXlatorDateTime) translator;
285         if (translatorDateTime.isFaultyClock()) {
286             // Not supported: faulty clock
287             LOGGER.debug("KNX clock msg ignored: clock faulty bit set, which is not supported");
288             return null;
289         } else if (!translatorDateTime.isValidField(DPTXlatorDateTime.YEAR)
290                 && translatorDateTime.isValidField(DPTXlatorDateTime.DATE)) {
291             // Not supported: "/1/1" (month and day without year)
292             LOGGER.debug("KNX clock msg ignored: no year, but day and month, which is not supported");
293             return null;
294         } else if (translatorDateTime.isValidField(DPTXlatorDateTime.YEAR)
295                 && !translatorDateTime.isValidField(DPTXlatorDateTime.DATE)) {
296             // Not supported: "1900" (year without month and day)
297             LOGGER.debug("KNX clock msg ignored: no day and month, but year, which is not supported");
298             return null;
299         } else if (!translatorDateTime.isValidField(DPTXlatorDateTime.YEAR)
300                 && !translatorDateTime.isValidField(DPTXlatorDateTime.DATE)
301                 && !translatorDateTime.isValidField(DPTXlatorDateTime.TIME)) {
302             // Not supported: No year, no date and no time
303             LOGGER.debug("KNX clock msg ignored: no day and month or year, which is not supported");
304             return null;
305         }
306
307         Calendar cal = Calendar.getInstance();
308         if (translatorDateTime.isValidField(DPTXlatorDateTime.YEAR)
309                 && !translatorDateTime.isValidField(DPTXlatorDateTime.TIME)) {
310             // Pure date format, no time information
311             cal.setTimeInMillis(translatorDateTime.getValueMilliseconds());
312             String value = new SimpleDateFormat(DateTimeType.DATE_PATTERN).format(cal.getTime());
313             return DateTimeType.valueOf(value);
314         } else if (!translatorDateTime.isValidField(DPTXlatorDateTime.YEAR)
315                 && translatorDateTime.isValidField(DPTXlatorDateTime.TIME)) {
316             // Pure time format, no date information
317             cal.clear();
318             cal.set(Calendar.HOUR_OF_DAY, translatorDateTime.getHour());
319             cal.set(Calendar.MINUTE, translatorDateTime.getMinute());
320             cal.set(Calendar.SECOND, translatorDateTime.getSecond());
321             String value = new SimpleDateFormat(DateTimeType.DATE_PATTERN).format(cal.getTime());
322             return DateTimeType.valueOf(value);
323         } else if (translatorDateTime.isValidField(DPTXlatorDateTime.YEAR)
324                 && translatorDateTime.isValidField(DPTXlatorDateTime.TIME)) {
325             // Date format and time information
326             try {
327                 cal.setTimeInMillis(translatorDateTime.getValueMilliseconds());
328             } catch (KNXFormatException ignore) {
329                 // throws KNXFormatException in case DST (SUTI) flag does not match calendar
330                 // As the spec regards the SUTI flag as purely informative, flip it and try again.
331                 if (data.length < 8) {
332                     return null;
333                 }
334                 data[6] = (byte) (data[6] ^ 0x01);
335                 translator.setData(data, 0);
336                 cal.setTimeInMillis(translatorDateTime.getValueMilliseconds());
337             }
338             String value = new SimpleDateFormat(DateTimeType.DATE_PATTERN).format(cal.getTime());
339             return DateTimeType.valueOf(value);
340         } else {
341             LOGGER.warn("Failed to convert '{}'", translator.getValue());
342             return null;
343         }
344     }
345
346     private static @Nullable Type handleStringOrDecimal(byte[] data, String value, Class<? extends Type> preferredType,
347             int bits) {
348         if (DecimalType.class.equals(preferredType)) {
349             try {
350                 // need a new translator for 8 bit unsigned, as Calimero handles only the string type
351                 if (bits == 8) {
352                     DPTXlator8BitUnsigned translator = new DPTXlator8BitUnsigned("5.010");
353                     translator.setData(data);
354                     return new DecimalType(translator.getValueUnsigned());
355                 } else if (bits == 16) {
356                     DPTXlator2ByteUnsigned translator = new DPTXlator2ByteUnsigned("7.001");
357                     translator.setData(data);
358                     return new DecimalType(translator.getValueUnsigned());
359                 } else {
360                     return null;
361                 }
362             } catch (KNXFormatException e) {
363                 return null;
364             }
365         } else {
366             return StringType.valueOf(value);
367         }
368     }
369
370     private static @Nullable Type handleDpt232(String value, String subType) {
371         Matcher rgb = RGB_PATTERN.matcher(value);
372         if (rgb.matches()) {
373             int r = Integer.parseInt(rgb.group("r"));
374             int g = Integer.parseInt(rgb.group("g"));
375             int b = Integer.parseInt(rgb.group("b"));
376
377             switch (subType) {
378                 case "600":
379                     return HSBType.fromRGB(r, g, b);
380                 case "60000":
381                     // MDT specific: mis-use 232.600 for hsv instead of rgb
382                     DecimalType hue = new DecimalType(coerceToRange(r * 360.0 / 255.0, 0.0, 359.9999));
383                     PercentType sat = new PercentType(BigDecimal.valueOf(coerceToRange(g / 2.55, 0.0, 100.0)));
384                     PercentType bright = new PercentType(BigDecimal.valueOf(coerceToRange(b / 2.55, 0.0, 100.0)));
385                     return new HSBType(hue, sat, bright);
386                 default:
387                     LOGGER.warn("Unknown subtype '232.{}', no conversion possible.", subType);
388                     return null;
389             }
390         }
391         LOGGER.warn("Failed to convert '{}' (DPT 232): Pattern does not match", value);
392         return null;
393     }
394
395     private static @Nullable Type handleDpt242(String value) {
396         Matcher xyY = XYY_PATTERN.matcher(value);
397         if (xyY.matches()) {
398             String stringx = xyY.group("x");
399             String stringy = xyY.group("y");
400             String stringY = xyY.group("Y");
401
402             if (stringx != null && stringy != null) {
403                 double x = Double.parseDouble(stringx.replace(",", "."));
404                 double y = Double.parseDouble(stringy.replace(",", "."));
405                 if (stringY == null) {
406                     return ColorUtil.xyToHsb(new double[] { x, y });
407                 } else {
408                     double pY = Double.parseDouble(stringY.replace(",", "."));
409                     return ColorUtil.xyToHsb(new double[] { x, y, pY / 100.0 });
410                 }
411             }
412         }
413         LOGGER.warn("Failed to convert '{}' (DPT 242): Pattern does not match", value);
414         return null;
415     }
416
417     private static @Nullable Type handleDpt251(String value, String subType, Class<? extends Type> preferredType) {
418         Matcher rgbw = RGBW_PATTERN.matcher(value);
419         if (rgbw.matches()) {
420             String rString = rgbw.group("r");
421             String gString = rgbw.group("g");
422             String bString = rgbw.group("b");
423             String wString = rgbw.group("w");
424
425             switch (subType) {
426                 case "600":
427                     if (rString != null && gString != null && bString != null && HSBType.class.equals(preferredType)) {
428                         // does not support PercentType and r,g,b valid -> HSBType
429                         int r = coerceToRange((int) (Double.parseDouble(rString.replace(",", ".")) * 2.55), 0, 255);
430                         int g = coerceToRange((int) (Double.parseDouble(gString.replace(",", ".")) * 2.55), 0, 255);
431                         int b = coerceToRange((int) (Double.parseDouble(bString.replace(",", ".")) * 2.55), 0, 255);
432
433                         return HSBType.fromRGB(r, g, b);
434                     } else if (wString != null && PercentType.class.equals(preferredType)) {
435                         // does support PercentType and w valid -> PercentType
436                         BigDecimal w = new BigDecimal(wString.replace(",", "."));
437
438                         return new PercentType(w);
439                     }
440                 case "60600":
441                     // special type used by OH for .600 indicating that RGBW should be handled with a single HSBType,
442                     // typically we use HSBType for RGB and PercentType for W.
443                     if (rString != null && gString != null && bString != null && wString != null
444                             && HSBType.class.equals(preferredType)) {
445                         // does support PercentType and w valid -> PercentType
446                         int r = coerceToRange((int) (Double.parseDouble(rString.replace(",", ".")) * 2.55), 0, 255);
447                         int g = coerceToRange((int) (Double.parseDouble(gString.replace(",", ".")) * 2.55), 0, 255);
448                         int b = coerceToRange((int) (Double.parseDouble(bString.replace(",", ".")) * 2.55), 0, 255);
449                         int w = coerceToRange((int) (Double.parseDouble(wString.replace(",", ".")) * 2.55), 0, 255);
450
451                         return ColorUtil.rgbToHsb(new int[] { r, g, b, w });
452                     }
453                 default:
454                     LOGGER.warn("Unknown subtype '251.{}', no conversion possible.", subType);
455                     return null;
456             }
457
458         }
459         LOGGER.warn("Failed to convert '{}' (DPT 251): Pattern does not match or invalid content", value);
460         return null;
461     }
462
463     private static @Nullable Type handleNumericDpt(String id, DPTXlator translator, Class<? extends Type> preferredType)
464             throws KNXFormatException {
465         Set<Class<? extends Type>> allowedTypes = DPTUtil.getAllowedTypes(id);
466
467         double value = translator.getNumericValue();
468         if (allowedTypes.contains(PercentType.class)
469                 && (HSBType.class.equals(preferredType) || PercentType.class.equals(preferredType))) {
470             return new PercentType(BigDecimal.valueOf(Math.round(value)));
471         }
472
473         if (allowedTypes.contains(QuantityType.class) && !disableUoM) {
474             String unit = DPTUnits.getUnitForDpt(id);
475             if (unit != null) {
476                 if (translator instanceof DPTXlator64BitSigned translatorSigned) {
477                     // prevent loss of precision, do not represent 64bit decimal using double
478                     return new QuantityType<>(translatorSigned.getValueSigned() + " " + unit);
479                 }
480                 return new QuantityType<>(value + " " + unit);
481             } else {
482                 LOGGER.trace("Could not determine unit for DPT '{}', fallback to plain decimal", id);
483             }
484         }
485
486         if (allowedTypes.contains(DecimalType.class)) {
487             if (translator instanceof DPTXlator64BitSigned translatorSigned) {
488                 // prevent loss of precision, do not represent 64bit decimal using double
489                 return new DecimalType(translatorSigned.getValueSigned());
490             }
491             return new DecimalType(value);
492         }
493
494         LOGGER.warn("Failed to convert '{}' (DPT '{}'): no matching type found", value, id);
495         return null;
496     }
497
498     private static double coerceToRange(double value, double min, double max) {
499         return Math.min(Math.max(value, min), max);
500     }
501
502     private static int coerceToRange(int value, int min, int max) {
503         return Math.min(Math.max(value, min), max);
504     }
505 }