Nasa高分卫星火点监测数据接入源码

package com.uav.service.impl; import com.alibaba.fastjson.JSON; import com.sun.org.apache.xml.internal.security.algorithms.implementations.SignatureDSA; import com.uav.entity.ScanData; import com.uav.service.IScanService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; import java.nio.charset.StandardCharsets; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.*; @Service public class ScanServiceImpl implements IScanService { //注入远程请求 @Autowired RestTemplate restTemplate; @Value("${nasa.api.url}") private String baseUrl; @Override public List<ScanData> findNasaFireData(Map<String, Object> params) throws NoSuchAlgorithmException { //获取数据的csv格式 String csvData=getRemoteNasaDataCsv(params); System.err.println(csvData); //解析csv格式并封装为ScanData //从第二行开始进行字符串解析 return covCsvDataToEntity(csvData); } private List<ScanData> covCsvDataToEntity(String csvData) throws NoSuchAlgorithmException { String[] lines = csvData.split("\n"); if (lines.length==1){ return null; } List<Map<String,Object>> mapList=covCsvDataToMap(lines); List<ScanData> scanDataList=new ArrayList<>(); mapList.forEach(map->{ ScanData scanData = JSON.parseObject(JSON.toJSONString(map), ScanData.class); scanDataList.add(scanData); }); return scanDataList; } private List<Map<String, Object>> covCsvDataToMap(String[] lines) throws NoSuchAlgorithmException { List<Map<String,Object>> dataList=new ArrayList<>(); String header = lines[0]; String[] keys = header.split(","); List<String[]> valueList=new ArrayList<>(); for (int i=1;i<lines.length;i++){ String[] values = lines[i].split(","); valueList.add(values); } for (int i=0;i<valueList.size();i++){ Map<String,Object> map=new HashMap<>(); String[] value = valueList.get(i); for (int j=0;j<keys.length;j++){ map.put(keys[j],value[j]); } map.put("id", strToHex(Arrays.toString(value))); dataList.add(map); } return dataList; } //请求并获取卫星监测的火点数据 @Override public String getRemoteNasaDataCsv(Map<String, Object> params) { String url = getRequestUrl(baseUrl, params); ResponseEntity<String> response = restTemplate.getForEntity(url, String.class, ""); return response.getBody(); } //url和参数拼接,如果为空则拼接空字符串 public static String getRequestUrl(String baseUrl,Map<String,Object> params){ return baseUrl+"/"+params.getOrDefault("MAP-KEY","")+"/" +params.getOrDefault("TYPE","")+"/"+ params.getOrDefault("Area","")+"/"+ params.getOrDefault("DayRange","")+"/"+ params.getOrDefault("Date",""); } private static String strToHex(String data) throws NoSuchAlgorithmException { MessageDigest digest = MessageDigest.getInstance("SHA-256"); byte[] hash = digest.digest(data.getBytes(StandardCharsets.UTF_8)); StringBuilder hexString = new StringBuilder(2 * hash.length); for (byte b : hash) { String hex = Integer.toHexString(0xff & b); if (hex.length() == 1) { hexString.append('0'); } hexString.append(hex); } return hexString.toString(); } }