测试环境数据采集异常问题处理。

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/Utils/GolangRequestUtil.java

@@ -4,12 +4,14 @@ import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.http.HttpUtil;
+import cn.hutool.log.Log;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.amos.api.householdapi.constant.GoLangConstant;
 import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.houseapi.HousepvapiRecords;
 import com.yeejoin.amos.api.householdapi.face.orm.mapper.houseapi.HousepvapiRecordsMapper;
 import com.yeejoin.amos.openapi.enums.PVProducerInfoEnum;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
@@ -17,7 +19,7 @@ import org.springframework.util.ObjectUtils;
 import java.util.*;
 
 @Component
-
+@Slf4j
 public class GolangRequestUtil {
 
     @Autowired
@@ -124,6 +126,7 @@ public class GolangRequestUtil {
         }
         housepvapiRecords.setResponse(respone);
         housepvapiRecordsMapper.insert(housepvapiRecords);
+        log.info("锦浪云数据请求详情："+JSONObject.toJSONString(housepvapiRecords));
         return respone;
     }
 

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/Utils/ImasterUtils.java

@@ -12,6 +12,7 @@ import com.yeejoin.amos.api.householdapi.constant.ImasterConstant;
 import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.houseapi.HousepvapiRecords;
 import com.yeejoin.amos.api.householdapi.face.orm.mapper.houseapi.HousepvapiRecordsMapper;
 import com.yeejoin.amos.openapi.enums.PVProducerInfoEnum;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
@@ -20,6 +21,7 @@ import org.springframework.util.ObjectUtils;
 import java.util.*;
 
 @Component
+@Slf4j
 public class ImasterUtils {
 
     private String redisKey = "XSRF-TOKEN";
@@ -252,6 +254,7 @@ public class ImasterUtils {
         }
         housepvapiRecords.setResponse(respone);
         housepvapiRecordsMapper.insert(housepvapiRecords);
+        log.info("华为数据请求详情："+JSONObject.toJSONString(housepvapiRecords));
         return respone;
     }
 

amos-boot-data/amos-boot-data-housepvapi/src/main/java/com/yeejoin/amos/api/householdapi/Utils/KsolarRequestUtil.java

@@ -134,6 +134,7 @@ public class KsolarRequestUtil {
         }
         housepvapiRecords.setResponse(respone);
         housepvapiRecordsMapper.insert(housepvapiRecords);
+        log.info("科士达数据请求详情："+JSONObject.toJSONString(housepvapiRecords));
         return respone;
     }
 

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

@@ -103,6 +103,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
     private TdHYGFInverterTotalGenerateMapper tdHYGFInverterTotalGenerateMapper;
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void stationList() {
 
@@ -124,6 +125,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
     }
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void stationDetail() {
         List<String> stationIds = golangStationMapper.getStationIds();
@@ -295,6 +297,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
 
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void collectorList() {
 //        List<String> stationIds = golangStationMapper.getStationIds();
@@ -324,6 +327,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
     }
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void collectorDetail() {
         List<Long> collectorIds = golangCollectorListMapper.getCollectIds();
@@ -399,6 +403,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
     }
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void inverterList() {
 //        List<String> stationIds = golangStationMapper.getStationIds();
@@ -428,6 +433,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
     }
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void inverterDetail() {
         List<String> inverterSns = golangInverterListMapper.getInverterSns();
@@ -689,6 +695,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
     }
 
     @Scheduled(cron = "${dataRequstScheduled.jinlangyun}")
+    @Async
     @Override
     public void inverAlramInfo() {
         List<String> inverterIds = golangInverterListMapper.getInverterSns();