支付分刷脸温度设置记录

device-api-service/src/main/java/com/xy/service/factory/device/impl/alipay/AliPayOpenDeviceFatoryImpl.java

@@ -136,35 +136,33 @@ public class AliPayOpenDeviceFatoryImpl implements DeviceFactory, SpiDeviceServi
                     //温度设置
                     Integer value = data.getInt("target");
                     alipayDeviceService.setAttributes(new DeviceSetAttr().setTerminalId(terminalId).setType("TEMP").setValue(String.valueOf(value)));
-                    //todo 写入记录
-                    new Thread(() -> {
-                        try {
-                            DeviceTempSetDto.Save save = new DeviceTempSetDto.Save()
-                                    .setDeviceId(commandMqtt.getDeviceId())
-                                    .setWorkMode(data.getStr("workModel"))
-                                    .setTempValue(data.getInt("target"))
-                                    .setTempValue1(data.getInt("target1"))
-                                    .setTempValue2(data.getInt("target2"))
-                                    .setTempValue3(data.getInt("target3"))
-                                    .setJob1StartTime(data.getInt("start1"))
-                                    .setJob1EndTime(data.getInt("end1"))
-                                    .setJob2StartTime(data.getInt("start2"))
-                                    .setJob2EndTime(data.getInt("end2"))
-                                    .setJob3StartTime(data.getInt("start3"))
-                                    .setJob3EndTime(data.getInt("end3"));
-                            String warningLow = data.getStr("warningLow");
-                            String warningHigh = data.getStr("warningHigh");
-                            if (!warningLow.equals("$warningLow$")) {
-                                save.setWarningLow(Integer.valueOf(warningLow));
-                            }
-                            if (!warningHigh.equals("$warningHigh$")) {
-                                save.setWarningHigh(Integer.valueOf(warningHigh));
-                            }
-                            deviceTempSetService.save(save);
-                        } catch (Exception e) {
-                            log.error("{}", e, templet);
+                    //写入记录
+                    try {
+                        DeviceTempSetDto.Save save = new DeviceTempSetDto.Save()
+                                .setDeviceId(commandMqtt.getDeviceId())
+                                .setWorkMode(data.getStr("workModel"))
+                                .setTempValue(data.getInt("target"))
+                                .setTempValue1(data.getInt("target1"))
+                                .setTempValue2(data.getInt("target2"))
+                                .setTempValue3(data.getInt("target3"))
+                                .setJob1StartTime(data.getInt("start1"))
+                                .setJob1EndTime(data.getInt("end1"))
+                                .setJob2StartTime(data.getInt("start2"))
+                                .setJob2EndTime(data.getInt("end2"))
+                                .setJob3StartTime(data.getInt("start3"))
+                                .setJob3EndTime(data.getInt("end3"));
+                        String warningLow = data.getStr("warningLow");
+                        String warningHigh = data.getStr("warningHigh");
+                        if (!warningLow.equals("$warningLow$")) {
+                            save.setWarningLow(Integer.valueOf(warningLow));
                         }
-                    }).start();
+                        if (!warningHigh.equals("$warningHigh$")) {
+                            save.setWarningHigh(Integer.valueOf(warningHigh));
+                        }
+                        deviceTempSetService.save(save);
+                    } catch (Exception e) {
+                        log.error("异常{}", templet);
+                    }
                 }
             }
         });