package com.fzzy.igds.dzhwk.v1.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.fzzy.igds.dzhwk.domain.Gas;
|
import com.fzzy.igds.dzhwk.service.repository.GasRepository;
|
import com.fzzy.igds.dzhwk.v1.ApiV1Service;
|
import com.fzzy.igds.dzhwk.v1.dto.ApiV1Data2002;
|
import com.fzzy.igds.dzhwk.v1.dto.ApiV1ReqDto;
|
import com.ruoyi.common.utils.StringUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.springframework.stereotype.Service;
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* @Description 解析气体信息
|
* @Author CZT
|
* @Date 2025/6/04 20:11
|
*/
|
@Slf4j
|
@Service
|
public class ApiV1ServiceImpl2002 implements ApiV1Service {
|
|
@Resource
|
private GasRepository gasRepository;
|
|
@Override
|
public String getInterfaceId() {
|
return "2002";
|
}
|
|
@Override
|
public void analysis(String dataStr, ApiV1ReqDto configData) {
|
|
List<ApiV1Data2002> list = JSONObject.parseArray(dataStr, ApiV1Data2002.class);
|
if(null == list || list.isEmpty()){
|
log.error("-----未获取到气体检测信息，不解析---------");
|
return;
|
}
|
try {
|
Gas gas;
|
List<String> co2List = new ArrayList<>();
|
List<String> o2List = new ArrayList<>();
|
List<String> ph3List = new ArrayList<>();
|
List<String> n2List = new ArrayList<>();
|
Double max = 0.0;
|
Double min = 0.0;
|
Double sum = 0.0;
|
Double temp = 0.0;
|
for (ApiV1Data2002 apiData : list) {
|
gas = new Gas();
|
|
gas.setBatchId(apiData.getQtndjcdh());
|
gas.setCompanyId(configData.getSign());
|
gas.setDepotId(apiData.getHwdm());
|
gas.setType(apiData.getZylx() + "");
|
|
//CO2
|
if(StringUtils.isNotEmpty(apiData.getEyhthlzjh())){
|
String[] split = apiData.getEyhthlzjh().split("\\|");
|
String points = split[0];
|
String[] values = points.split(",");
|
for(int i = 0; i < values.length; i++){
|
temp = Double.valueOf(values[i]);
|
if (i ==0) {
|
sum = 0.0;
|
max = temp;
|
min = temp;
|
}
|
if(temp > max){
|
max = temp;
|
}
|
if(temp < min){
|
min = temp;
|
}
|
sum += temp;
|
o2List.add(values[i]);
|
}
|
gas.setPerCo2(sum / values.length);
|
gas.setPerCo2Max(max);
|
gas.setPerCo2Min(min);
|
}
|
|
//O2
|
if(StringUtils.isNotEmpty(apiData.getYqhlzjh())){
|
String[] split = apiData.getYqhlzjh().split("\\|");
|
String points = split[0];
|
String[] values = points.split(",");
|
for(int i = 0; i < values.length; i++){
|
temp = Double.valueOf(values[i]);
|
if (i ==0) {
|
sum = 0.0;
|
max = temp;
|
min = temp;
|
}
|
if(temp > max){
|
max = temp;
|
}
|
if(temp < min){
|
min = temp;
|
}
|
sum += temp;
|
o2List.add(values[i]);
|
}
|
gas.setPerO2(sum / values.length);
|
gas.setPerO2Max(max);
|
gas.setPerO2Min(min);
|
}
|
|
//Ph3
|
if(StringUtils.isNotEmpty(apiData.getLhqndzjh())){
|
String[] split = apiData.getLhqndzjh().split("\\|");
|
String points = split[0];
|
String[] values = points.split(",");
|
for(int i = 0; i < values.length; i++){
|
temp = Double.valueOf(values[i]);
|
if (i ==0) {
|
sum = 0.0;
|
max = temp;
|
min = temp;
|
}
|
if(temp > max){
|
max = temp;
|
}
|
if(temp < min){
|
min = temp;
|
}
|
sum += temp;
|
o2List.add(values[i]);
|
}
|
gas.setPerPh3(sum / values.length);
|
gas.setPerPh3Max(max);
|
gas.setPerPh3Min(min);
|
}
|
|
//N2
|
if(StringUtils.isNotEmpty(apiData.getDqndzjh())){
|
String[] split = apiData.getDqndzjh().split("\\|");
|
String points = split[0];
|
String[] values = points.split(",");
|
for(int i = 0; i < values.length; i++){
|
temp = Double.valueOf(values[i]);
|
if (i ==0) {
|
sum = 0.0;
|
max = temp;
|
min = temp;
|
}
|
if(temp > max){
|
max = temp;
|
}
|
if(temp < min){
|
min = temp;
|
}
|
sum += temp;
|
o2List.add(values[i]);
|
}
|
gas.setPerN2(sum / values.length);
|
gas.setPerN2Max(max);
|
gas.setPerN2Min(min);
|
}
|
|
//点位各气体浓度
|
String pointStr = "";
|
for(int i = 0; i < o2List.size(); i++){
|
pointStr += i + "," + co2List.get(i) + "," + o2List.get(i) + "," + ph3List.get(i) + "," + n2List.get(i) + ";";
|
}
|
gas.setPoints(pointStr);
|
|
gas.setReceiveDate(DateUtils.parseDate(apiData.getJcsj(), "yyyy-MM-dd HH:mm:ss"));
|
gas.setCheckUser("");
|
gas.setRemark("");
|
|
gasRepository.save(gas);
|
}
|
}catch (Exception e){
|
log.error("-----解析错误={}---------", e.toString());
|
}
|
|
}
|
}
|
