package com.fzzy.igds.dzhwk.v1.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.fzzy.igds.dzhwk.domain.MAreationData;
|
import com.fzzy.igds.dzhwk.service.repository.AreationDataRepository;
|
import com.fzzy.igds.dzhwk.v1.ApiV1Service;
|
import com.fzzy.igds.dzhwk.v1.dto.ApiV1Data2005;
|
import com.fzzy.igds.dzhwk.v1.dto.ApiV1ReqDto;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
/**
|
* @Description 解析机械通风信息
|
* @Author CZT
|
* @Date 2025/6/04 20:11
|
*/
|
@Slf4j
|
@Service
|
public class ApiV1ServiceImpl2005 implements ApiV1Service {
|
|
@Resource
|
private AreationDataRepository repository;
|
|
@Override
|
public String getInterfaceId() {
|
return "2005";
|
}
|
|
@Override
|
public void analysis(String dataStr, ApiV1ReqDto configData) {
|
|
List<ApiV1Data2005> list = JSONObject.parseArray(dataStr, ApiV1Data2005.class);
|
if(null == list || list.isEmpty()){
|
log.error("-----未获取到信息，不解析---------");
|
return;
|
}
|
try {
|
MAreationData data;
|
for (ApiV1Data2005 apiData : list) {
|
data = new MAreationData();
|
data.setCompanyId(configData.getSign());
|
data.setDeptId(configData.getDeptId());
|
|
BeanUtils.copyProperties(apiData, data);
|
|
|
data.setDepotId(apiData.getAjdm());
|
data.setObjective(apiData.getTfmd());
|
data.setType(apiData.getTflx());
|
data.setAirSupplyMode(apiData.getSffs());
|
data.setZysqw(apiData.getZysqw());
|
data.setZysqs(apiData.getZysqs());
|
data.setStartTime(DateUtils.parseDate(apiData.getTfrq(), "yyyy-MM-dd"));
|
|
data.setLongTime(apiData.getTfsc());
|
data.setBeforeTempAvg(apiData.getZyqpjlw());
|
data.setAfterTempAvg(apiData.getJshpjlw());
|
|
data.setBeforPerWetAvg(apiData.getZyqpjsf());
|
data.setAfterPerWetAvg(apiData.getZyhpjsf());
|
data.setChargeUser(apiData.getTfzyfzr());
|
data.setOperators(apiData.getTfzyry());
|
|
data.setUpdateTime(DateUtils.parseDate(apiData.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
|
|
repository.save(data);
|
}
|
}catch (Exception e){
|
log.error("-----解析错误={}---------", e.toString());
|
}
|
}
|
}
|
