hechunping пре 1 година
родитељ
комит
301d382737

+ 10 - 0
device-api-service/src/main/java/com/xy/service/factory/cmd/impl/SetsCmdServiceImpl.java

@@ -3,10 +3,12 @@ package com.xy.service.factory.cmd.impl;
 import cn.hutool.json.JSONObject;
 import com.xy.annotate.Factory;
 import com.xy.device.EnumMqttCmdTempletSets;
+import com.xy.dto.DeviceSetRecordsDto;
 import com.xy.dto.DeviceTempSetDto;
 import com.xy.dto.MqttCmdDto;
 import com.xy.dto.PaterDto;
 import com.xy.entity.DeviceTempSet;
+import com.xy.service.DeviceSetRecordsServiceImpl;
 import com.xy.service.DeviceTempSetServiceImpl;
 import com.xy.service.factory.cmd.CmdService;
 import com.xy.utils.R;
@@ -22,6 +24,7 @@ import java.util.List;
 public class SetsCmdServiceImpl implements CmdService {
 
     private DeviceTempSetServiceImpl deviceTempSetService;
+    private DeviceSetRecordsServiceImpl deviceSetRecordsService;
 
     @Override
     public R senCommand(List<MqttCmdDto> mqttDtos) {
@@ -53,6 +56,13 @@ public class SetsCmdServiceImpl implements CmdService {
                     save.setWarningHigh(Integer.valueOf(warningHigh));
                 }
                 deviceTempSetService.save(save);
+            } else {
+                DeviceSetRecordsDto.Save save = new DeviceSetRecordsDto.Save();
+                save.setType(type)
+                        .setDeviceId(mqttDto.getDeviceId())
+                        .setContent(data.toString())
+                        ;
+                deviceSetRecordsService.save(save);
             }
         }
         return R.ok();