固德威场站详情相关代码采集

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/constant/GoodWeConstant.java

 package com.yeejoin.amos.api.householdapi.constant;
 
 import java.time.format.DateTimeFormatter;
+import java.util.HashMap;
 
 /**
  * 固德威常量
  */
 
 public class GoodWeConstant {
+    public static final HashMap<String, String> stationStaus = new HashMap<String, String>() {
+        {
+            put("-1", "离线");
+            put("0", "待机");
+            put("1", "正常");
+            put("2", "停机");
+        }
+    };
 
     public static String baseurl = "http://openapi.sems.com.cn";
     public static String account = "18679135705";
@@ -32,6 +41,7 @@ public class GoodWeConstant {
     public static String resovleRule_data_records = "data,records";
     public static String resovleRule_data = "data";
     public static String requestPost = "POST";
+    public static String requestGet = "GET";
     public static String datePattern = "yyyy-MM-dd HH:mm:ss.SSS";
     public static DateTimeFormatter formatter = DateTimeFormatter.ofPattern(datePattern);
     public static Double kwhToMwh = 0.0001;

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/controller/HouseholdTestController.java

@@ -51,7 +51,8 @@ public class HouseholdTestController {
     @PostMapping(value = "/goodweDemo")
     @ApiOperation(httpMethod = "POST", value = "固德威示例", notes = "固德威示例")
     public void goodweDemo() throws IOException {
-        goodWeDataAcquisitionService.stationList();
+//        goodWeDataAcquisitionService.stationList();
+        goodWeDataAcquisitionService.stationDetail();
     }
 
     /**

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/face/orm/houseapi/entity/tdeingine/GoodWeStationDetail.java

+package com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+@Data
+@TableName(value = "goodwe_station_detail", autoResultMap = true)
+public class GoodWeStationDetail {
+    @TableField("created_time")
+    private long createdTime;
+    @TableField("powerstation_id")
+    private String powerstation_id;
+    @TableField("stationname")
+    private String stationname;
+    @TableField("address")
+    private String address;
+    @TableField("owner_name")
+    private String owner_name;
+    @TableField("owner_phone")
+    private String owner_phone;
+    @TableField("turnon_time")
+    private String turnon_time;
+    @TableField("capacity")
+    private Double capacity;
+    @TableField("longitude")
+    private String longitude;
+    @TableField("latitude")
+    private String latitude;
+    @TableField("powerstation_type")
+    private String powerstation_type;
+    @TableField("status")
+    private Integer status;
+    @TableField("pac")
+    private Double pac;
+    @TableField("eday")
+    private Double eday;
+    @TableField("etotal")
+    private Double etotal;
+
+}

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/face/orm/mapper/tdengine/GoodWeStationDetailMapper.java

+package com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.GoodWeStationDetail;
+
+public interface GoodWeStationDetailMapper extends BaseMapper<GoodWeStationDetail> {
+}

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/face/orm/mapper/tdengine/GoodWeStationMonitorListMapper.java

@@ -2,6 +2,11 @@ package com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.GoodWeStationMonitorList;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
 
 public interface GoodWeStationMonitorListMapper extends BaseMapper<GoodWeStationMonitorList> {
+    @Select("select powerstation_id from goodwe_station_monitor_list group by powerstation_id")
+    List<String> getStationIds ();
 }

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/face/service/impl/GoodWeDataAcquisitionServiceImpl.java

@@ -3,7 +3,9 @@ package com.yeejoin.amos.api.householdapi.face.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.yeejoin.amos.api.householdapi.Utils.GoodWeRequestUtil;
 import com.yeejoin.amos.api.householdapi.constant.GoodWeConstant;
+import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.GoodWeStationDetail;
 import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.GoodWeStationMonitorList;
+import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.GoodWeStationDetailMapper;
 import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.GoodWeStationMonitorListMapper;
 import com.yeejoin.amos.api.householdapi.face.service.GoodWeDataAcquisitionService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -17,6 +19,8 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
     GoodWeRequestUtil goodWeRequestUtil;
     @Autowired
     GoodWeStationMonitorListMapper goodWeStationMonitorListMapper;
+    @Autowired
+    GoodWeStationDetailMapper goodWeStationDetailMapper;
 
     @Override
     public void stationList() {
@@ -35,10 +39,21 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
 
     @Override
     public void stationDetail() {
-        HashMap<String, Object> requestInfo = new HashMap<>();
-        requestInfo.put("page_index", 1);
-        requestInfo.put("page_size", 200);
-        String requstParam = JSON.toJSONString(requestInfo);
+        List<String> stationIds = goodWeStationMonitorListMapper.getStationIds();
+        stationIds.forEach(stationId ->{
+
+            HashMap<String, Object> requestInfo = new HashMap<>();
+            String requstParam = JSON.toJSONString(requestInfo);
+            String apiurl = GoodWeConstant.stationDetailUrl+"?id="+stationId;
+            List<GoodWeStationDetail> goodWeStationDetails  =goodWeRequestUtil.getResPonse(apiurl, GoodWeConstant.requestGet, requstParam, GoodWeConstant.resovleRule_data, GoodWeStationDetail.class);
+            if(goodWeStationDetails.size()>0){
+                goodWeStationDetails.forEach(goodWeStationDetail -> {
+                    goodWeStationDetail.setCreatedTime(System.currentTimeMillis());
+                    goodWeStationDetailMapper.insert(goodWeStationDetail);
+                });
+            }
+        });
+
 
     }