devLink苗情设备数据服务

fastbee-service/fastbee-device-service/src/main/java/com/fastbee/deviceData/api/devlink/service/DevLinkMiaoQingDataService.java

@@ -0,0 +1,55 @@
+package com.fastbee.deviceData.api.devlink.service;
+
+import com.fastbee.deviceData.domain.DeviceRealtimedataMiaoqing;
+import com.fastbee.deviceData.domain.DeviceRealtimedataPhotovoltaic;
+import com.fastbee.deviceData.mapper.DeviceRealtimedataMiaoqingMapper;
+import com.fastbee.deviceData.mapper.DeviceRealtimedataPhotovoltaicMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+/**
+ * devLink苗情设备数据服务
+ */
+@Service
+public class DevLinkMiaoQingDataService extends DevLinkRealTimeDataService {
+    @Autowired
+    private DevLinkAuthorizationService authorizationService;
+    @Autowired
+    private DeviceRealtimedataMiaoqingMapper deviceRealtimedataMiaoqingMapper;
+    public DeviceRealtimedataMiaoqing setData(Map<String, String> propertiesMap){
+        DeviceRealtimedataMiaoqing miaoqing = DeviceRealtimedataMiaoqing.builder()
+                .airTemp(toBigDecimalValue(propertiesMap.get("airTemp")))
+                .mppTemp(toBigDecimalValue(propertiesMap.get("mppTemp")))
+                .batteryCap(Long.parseLong(propertiesMap.get("batteryCap")))
+                .batteryVolt(toBigDecimalValue(propertiesMap.get("batteryVolt")))
+                .batteryCur(toBigDecimalValue(propertiesMap.get("batteryCur")))
+                .batteryPower(toBigDecimalValue(propertiesMap.get("batteryPower")))
+                .loadVolt(toBigDecimalValue(propertiesMap.get("loadVolt")))
+                .loadCur(toBigDecimalValue(propertiesMap.get("loadCur")))
+                .loadPower(toBigDecimalValue(propertiesMap.get("loadPower")))
+                .photVolt(toBigDecimalValue(propertiesMap.get("photVolt")))
+                .photCur(toBigDecimalValue(propertiesMap.get("photCur")))
+                .photPower(toBigDecimalValue(propertiesMap.get("photPower")))
+                .cumChargeDay(toBigDecimalValue(propertiesMap.get("cum_charge_day")))
+                .cumChargeMon(toBigDecimalValue(propertiesMap.get("cum_charge_mon")))
+                .cumChargeYear(toBigDecimalValue(propertiesMap.get("cum_charge_year")))
+                .cumChargeAll(toBigDecimalValue(propertiesMap.get("cum_charge_all")))
+                .cumEleDay(toBigDecimalValue(propertiesMap.get("cum_ele_day")))
+                .cumEleMon(toBigDecimalValue(propertiesMap.get("cum_ele_mon")))
+                .cumEleYear(toBigDecimalValue(propertiesMap.get("cum_ele_year")))
+                .cumEleAll(toBigDecimalValue(propertiesMap.get("cum_ele_all")))
+                .shoudong(toBigDecimalValue(propertiesMap.get("shoudong")))
+                .control(toBigDecimalValue(propertiesMap.get("control")))
+                .build();
+        System.err.println(miaoqing);
+        return miaoqing;
+    }
+
+    public static void main(String[] args) {
+        DevLinkMiaoQingDataService devLinkMiaoQingDataService = new DevLinkMiaoQingDataService();
+        Map<String, String> metDeviceRealData = devLinkMiaoQingDataService.getMetDeviceRealData("3275");
+        devLinkMiaoQingDataService.setData(metDeviceRealData);
+    }
+}

fastbee-service/fastbee-device-service/src/main/java/com/fastbee/deviceData/domain/DeviceRealtimedataMiaoqing.java

@@ -5,8 +5,7 @@ import java.util.Date;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
-import lombok.Data;
+import lombok.*;
-import lombok.EqualsAndHashCode;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.apache.commons.lang3.builder.ToStringStyle;
 import com.fastbee.common.annotation.Excel;
@@ -19,6 +18,9 @@ import com.fastbee.common.core.domain.BaseEntity;
  * @date 2024-11-14
  */
 @ApiModel(value = "DeviceRealtimedataMiaoqing",description = "苗青设备实时数据 iot_device_realtimedata_miaoQing")
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
 @Data
 @EqualsAndHashCode(callSuper = true)
 public class DeviceRealtimedataMiaoqing extends BaseEntity
@@ -136,12 +138,12 @@ private static final long serialVersionUID = 1L;
     /** 手动控制模式 */
             @Excel(name = "手动控制模式")
             @ApiModelProperty("手动控制模式")
-    private Long shoudong;
+    private BigDecimal shoudong;
 
     /** 远程通断电 */
             @Excel(name = "远程通断电")
             @ApiModelProperty("远程通断电")
-    private Long control;
+    private BigDecimal control;
 
     /** 保存时间 */
     @JsonFormat(pattern = "yyyy-MM-dd")