package com.moral.api.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.moral.api.entity.HistorySecondRadar;
|
import com.moral.api.mapper.HistorySecondRadarMapper;
|
import com.moral.api.service.HistorySecondRadarService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.stereotype.Service;
|
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.stream.IntStream;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author moral
|
* @since 2026-05-14
|
*/
|
@Service
|
public class HistorySecondRadarServiceImpl extends ServiceImpl<HistorySecondRadarMapper, HistorySecondRadar> implements HistorySecondRadarService {
|
|
private final DateTimeFormatter INPUT_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
|
private final DateTimeFormatter OUTPUT_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
@Override
|
public void insertHistorySecond(Map<String, Object> data) {
|
Map<String, Object> dataResult = new HashMap<>();
|
HistorySecondRadar historySecondRadar = new HistorySecondRadar();
|
String time = data.get("time").toString();
|
String radarTime = data.get("DataTime").toString();
|
Map<String,Double> a34004 = highMap(data.get("a34004-Avg").toString());
|
historySecondRadar.setPm25(String.valueOf(a34004.get("value")));
|
historySecondRadar.setHighPm25(String.valueOf(a34004.get("high")));
|
|
Map<String,Double> a34002 = highMap(data.get("a34002-Avg").toString());
|
historySecondRadar.setPm10(String.valueOf(a34002.get("value")));
|
historySecondRadar.setHighPm10(String.valueOf(a34002.get("high")));
|
|
Map<String,Double> a01561 = highMap(data.get("a01561-Avg").toString());
|
historySecondRadar.setBoundaryLayer(String.valueOf(a01561.get("value")));
|
LocalDateTime dateTime = LocalDateTime.parse(time, INPUT_FORMATTER);
|
historySecondRadar.setTime(dateTime);
|
dataResult.put("a34004-Avg",data.get("a34004-Avg"));
|
dataResult.put("a34002-Avg",data.get("a34002-Avg"));
|
dataResult.put("a01561-Avg",data.get("a01561-Avg"));
|
dataResult.put("QN",data.get("QN"));
|
dataResult.put("CN",data.get("CN"));
|
dataResult.put("MN",data.get("MN"));
|
dataResult.put("DataTime",data.get("DataTime"));
|
dataResult.put("time",data.get("time"));
|
historySecondRadar.setRadarData(JSON.toJSONString(dataResult));
|
historySecondRadar.setRadarTime(LocalDateTime.parse(radarTime, INPUT_FORMATTER));
|
this.save(historySecondRadar);
|
}
|
private Map<String,Double> highMap(String data){
|
data = data.replace(",", "");
|
Map<String,Double> map = new HashMap<>();
|
double[] values = Arrays.stream(data.split("\\*"))
|
.mapToDouble(Double::parseDouble)
|
.toArray();
|
int maxIndex = IntStream.range(0, values.length)
|
.boxed()
|
.max((i, j) -> Double.compare(values[i], values[j]))
|
.orElse(-1);
|
if (maxIndex != -1) {
|
double maxValue = values[maxIndex];
|
map.put("value",maxValue);
|
// 3. 计算距离 (假设第1个值对应7.5米，即 (index+1)*7.5)
|
double distance = (maxIndex + 1) * 7.5;
|
map.put("high",distance);
|
}else {
|
map.put("value",0d);
|
map.put("high",0d);
|
}
|
return map;
|
}
|
|
public static void main(String[] args) {
|
String inputStr = "20260513110500";
|
DateTimeFormatter inputFormatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
|
LocalDateTime dateTime = LocalDateTime.parse(inputStr, inputFormatter);
|
System.out.println(dateTime);
|
DateTimeFormatter outputFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
}
|
}
|
